diff --git a/pkg/module/net/module.go b/pkg/module/net/module.go index 29eeb80..7047b8e 100644 --- a/pkg/module/net/module.go +++ b/pkg/module/net/module.go @@ -38,9 +38,10 @@ func (m *Module) broadcast(call goja.FunctionCall, rt *goja.Runtime) goja.Value } data := call.Argument(0).Export() + ctx := context.Background() - msg := module.NewServerMessage(nil, data) - if err := m.bus.Publish(context.Background(), msg); err != nil { + msg := module.NewServerMessage(ctx, data) + if err := m.bus.Publish(ctx, msg); err != nil { panic(rt.ToValue(errors.WithStack(err))) }