alighasami
3d5eaf9445
Security: Sync from Public / sync-from-public (push) Has been cancelled
Test: Benchmark Nightly / build (push) Has been cancelled
Test: Benchmark Nightly / Notify Cats on failure (push) Has been cancelled
CI: Python / Checks (push) Has been cancelled
Test: Evals Python / Workflow Comparison Python (push) Has been cancelled
Util: Check Docs URLs / check-docs-urls (push) Has been cancelled
Test: Visual Storybook / Cloudflare Pages (push) Has been cancelled
Test: E2E Performance / build-and-test-performance (push) Has been cancelled
Test: Workflows Nightly / Run Workflow Tests (push) Has been cancelled
Util: Cleanup CI Docker Images / Delete stale CI images (push) Has been cancelled
Test: Benchmark Destroy Env / build (push) Has been cancelled
Util: Update Node Popularity / update-popularity (push) Has been cancelled
Test: E2E Coverage Weekly / Coverage Tests (push) Has been cancelled
73 lines
2.5 KiB
TypeScript
73 lines
2.5 KiB
TypeScript
import EventSource from 'eventsource';
|
||
import type {
|
||
IDataObject,
|
||
ITriggerFunctions,
|
||
INodeType,
|
||
INodeTypeDescription,
|
||
ITriggerResponse,
|
||
} from 'n8n-workflow';
|
||
import { NodeConnectionTypes, jsonParse } from 'n8n-workflow';
|
||
|
||
export class SseTrigger implements INodeType {
|
||
description: INodeTypeDescription = {
|
||
displayName: 'SSE Trigger',
|
||
name: 'sseTrigger',
|
||
icon: 'fa:cloud-download-alt',
|
||
iconColor: 'dark-blue',
|
||
group: ['trigger'],
|
||
version: 1,
|
||
description: 'Triggers the workflow when Server-Sent Events occur',
|
||
eventTriggerDescription: '',
|
||
activationMessage: 'You can now make calls to your SSE URL to trigger executions.',
|
||
defaults: {
|
||
name: 'SSE Trigger',
|
||
color: '#225577',
|
||
},
|
||
triggerPanel: {
|
||
header: '',
|
||
executionsHelp: {
|
||
inactive:
|
||
"<b>While building your workflow</b>, click the 'execute step' button, then trigger an SSE event. This will trigger an execution, which will show up in this editor.<br /> <br /><b>Once you're happy with your workflow</b>, publish it. Then every time a change is detected, the workflow will execute. These executions will show up in the <a data-key='executions'>executions list</a>, but not in the editor.",
|
||
active:
|
||
"<b>While building your workflow</b>, click the 'execute step' button, then trigger an SSE event. This will trigger an execution, which will show up in this editor.<br /> <br /><b>Your workflow will also execute automatically</b>, since it's activated. Every time a change is detected, this node will trigger an execution. These executions will show up in the <a data-key='executions'>executions list</a>, but not in the editor.",
|
||
},
|
||
activationHint:
|
||
'Once you’ve finished building your workflow, publish it to have it also listen continuously (you just won’t see those executions here).',
|
||
},
|
||
inputs: [],
|
||
outputs: [NodeConnectionTypes.Main],
|
||
properties: [
|
||
{
|
||
displayName: 'URL',
|
||
name: 'url',
|
||
type: 'string',
|
||
default: '',
|
||
placeholder: 'http://example.com',
|
||
description: 'The URL to receive the SSE from',
|
||
required: true,
|
||
},
|
||
],
|
||
};
|
||
|
||
async trigger(this: ITriggerFunctions): Promise<ITriggerResponse> {
|
||
const url = this.getNodeParameter('url') as string;
|
||
|
||
const eventSource = new EventSource(url);
|
||
|
||
eventSource.onmessage = (event) => {
|
||
const eventData = jsonParse<IDataObject>(event.data as string, {
|
||
errorMessage: 'Invalid JSON for event data',
|
||
});
|
||
this.emit([this.helpers.returnJsonArray([eventData])]);
|
||
};
|
||
|
||
async function closeFunction() {
|
||
eventSource.close();
|
||
}
|
||
|
||
return {
|
||
closeFunction,
|
||
};
|
||
}
|
||
}
|