mirror of
https://github.com/dunglas/frankenphp.git
synced 2025-12-24 13:38:11 +08:00
102 lines
2.5 KiB
Go
102 lines
2.5 KiB
Go
//go:build !nomercure
|
|
|
|
package frankenphp
|
|
|
|
// #include <stdint.h>
|
|
// #include <php.h>
|
|
import "C"
|
|
import (
|
|
"log/slog"
|
|
"unsafe"
|
|
|
|
"github.com/dunglas/mercure"
|
|
)
|
|
|
|
type mercureContext struct {
|
|
mercureHub *mercure.Hub
|
|
}
|
|
|
|
//export go_mercure_publish
|
|
func go_mercure_publish(threadIndex C.uintptr_t, topics *C.struct__zval_struct, data *C.zend_string, private bool, id, typ *C.zend_string, retry uint64) (generatedID *C.zend_string, error C.short) {
|
|
thread := phpThreads[threadIndex]
|
|
ctx := thread.context()
|
|
fc := thread.frankenPHPContext()
|
|
|
|
if fc.mercureHub == nil {
|
|
if fc.logger.Enabled(ctx, slog.LevelError) {
|
|
fc.logger.LogAttrs(ctx, slog.LevelError, "No Mercure hub configured")
|
|
}
|
|
|
|
return nil, 1
|
|
}
|
|
|
|
u := &mercure.Update{
|
|
Event: mercure.Event{
|
|
Data: GoString(unsafe.Pointer(data)),
|
|
ID: GoString(unsafe.Pointer(id)),
|
|
Retry: retry,
|
|
Type: GoString(unsafe.Pointer(typ)),
|
|
},
|
|
Private: private,
|
|
Debug: fc.logger.Enabled(ctx, slog.LevelDebug),
|
|
}
|
|
|
|
zvalType := C.zval_get_type(topics)
|
|
switch zvalType {
|
|
case C.IS_STRING:
|
|
u.Topics = []string{GoString(unsafe.Pointer(*(**C.zend_string)(unsafe.Pointer(&topics.value[0]))))}
|
|
case C.IS_ARRAY:
|
|
ts, err := GoPackedArray[string](unsafe.Pointer(*(**C.zend_array)(unsafe.Pointer(&topics.value[0]))))
|
|
if err != nil {
|
|
if fc.logger.Enabled(ctx, slog.LevelError) {
|
|
fc.logger.LogAttrs(ctx, slog.LevelError, "invalid topics type", slog.Any("error", err))
|
|
}
|
|
|
|
return nil, 1
|
|
}
|
|
|
|
u.Topics = ts
|
|
default:
|
|
// Never happens as the function is called from C with proper types
|
|
panic("invalid topics type")
|
|
}
|
|
|
|
if err := fc.mercureHub.Publish(ctx, u); err != nil {
|
|
if fc.logger.Enabled(ctx, slog.LevelError) {
|
|
fc.logger.LogAttrs(ctx, slog.LevelError, "Unable to publish Mercure update", slog.Any("error", err))
|
|
}
|
|
|
|
return nil, 2
|
|
}
|
|
|
|
return (*C.zend_string)(PHPString(u.ID, false)), 0
|
|
}
|
|
|
|
func (w *worker) configureMercure(o *workerOpt) {
|
|
if o.mercureHub == nil {
|
|
return
|
|
}
|
|
|
|
w.mercureHub = o.mercureHub
|
|
}
|
|
|
|
// WithMercureHub sets the mercure.Hub to use to publish updates
|
|
func WithMercureHub(hub *mercure.Hub) RequestOption {
|
|
return func(o *frankenPHPContext) error {
|
|
o.mercureHub = hub
|
|
|
|
return nil
|
|
}
|
|
}
|
|
|
|
// WithWorkerMercureHub sets the mercure.Hub in the worker script and used to dispatch hot reloading-related mercure.Update.
|
|
func WithWorkerMercureHub(hub *mercure.Hub) WorkerOption {
|
|
return func(w *workerOpt) error {
|
|
w.mercureHub = hub
|
|
|
|
w.requestOptions = append(w.requestOptions, WithMercureHub(hub))
|
|
|
|
return nil
|
|
}
|
|
}
|