|
@@ -21,6 +21,8 @@ export default class WebSocketModule extends BaseModule {
|
|
|
*/
|
|
|
public constructor() {
|
|
|
super("websocket");
|
|
|
+
|
|
|
+ this.jobApiDefault = false;
|
|
|
}
|
|
|
|
|
|
/**
|
|
@@ -148,6 +150,12 @@ export default class WebSocketModule extends BaseModule {
|
|
|
`No callback reference provided for job ${moduleJob}`
|
|
|
);
|
|
|
|
|
|
+ const module = this.moduleManager.getModule(moduleName);
|
|
|
+ if (!module) throw new Error(`Module "${moduleName}" not found`);
|
|
|
+
|
|
|
+ const job = module.getJob(jobName);
|
|
|
+ if (!job.api) throw new Error(`Job "${jobName}" not found.`);
|
|
|
+
|
|
|
const res = await this.jobQueue.runJob("api", "runJob", {
|
|
|
moduleName,
|
|
|
jobName,
|