File size: 1,172 Bytes
aec3094 | 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 | import type { EventMessageTypes as EventMessage } from '@/eventbus/event-message-classes';
import { EventMessageNode } from '@/eventbus/event-message-classes/event-message-node';
import { EventMessageWorkflow } from '@/eventbus/event-message-classes/event-message-workflow';
export const setupMessages = (executionId: string, workflowName: string): EventMessage[] => {
return [
new EventMessageWorkflow({
eventName: 'n8n.workflow.started',
payload: { executionId },
}),
new EventMessageNode({
eventName: 'n8n.node.started',
payload: {
executionId,
workflowName,
nodeName: 'When clicking "Execute workflow"',
nodeType: 'n8n-nodes-base.manualTrigger',
nodeId: '123',
},
}),
new EventMessageNode({
eventName: 'n8n.node.finished',
payload: {
executionId,
workflowName,
nodeName: 'When clicking "Execute workflow"',
nodeType: 'n8n-nodes-base.manualTrigger',
nodeId: '123',
},
}),
new EventMessageNode({
eventName: 'n8n.node.started',
payload: {
executionId,
workflowName,
nodeName: 'DebugHelper',
nodeType: 'n8n-nodes-base.debugHelper',
nodeId: '123',
},
}),
];
};
|