We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 22dd42e commit 665471fCopy full SHA for 665471f
src/backend/src/modules/broadcast/BroadcastService.js
@@ -20,6 +20,7 @@ const { AdvancedBase } = require("@heyputer/putility");
20
const BaseService = require("../../services/BaseService");
21
const { CLink } = require("./connection/CLink");
22
const { SLink } = require("./connection/SLink");
23
+const { Context } = require("../../util/context");
24
25
class BroadcastService extends BaseService {
26
static MODULES = {
@@ -96,7 +97,10 @@ class BroadcastService extends BaseService {
96
97
}
98
99
meta.from_outside = true;
- svc_event.emit(key, data, meta);
100
+ const context = Context.get(undefined, { allow_fallback: true });
101
+ context.arun(async () => {
102
+ await svc_event.emit(key, data, meta);
103
+ });
104
});
105
106
0 commit comments