🤖🌏

nodes/SignalTrigger/SignalTrigger.node.ts

@@ -0,0 +1,96 @@
+
+import {
+  ITriggerFunctions,
+  INodeExecutionData,
+  INodeType,
+  INodeTypeDescription,
+  NodeApiError,
+  ITriggerResponse,
+  NodeConnectionType,
+} from 'n8n-workflow';
+import { EventSource } from 'eventsource';
+import debug from 'debug';
+
+const signalTriggerDebug = debug('n8n:nodes:signal-trigger');
+
+export class SignalTrigger implements INodeType {
+  description: INodeTypeDescription = {
+    displayName: 'Signal Trigger',
+    name: 'signalTrigger',
+    group: ['trigger'],
+    version: 1,
+    description: 'Triggers when a new message is received',
+    defaults: {
+      name: 'Signal Trigger',
+    },
+		inputs: [],
+		outputs: [NodeConnectionType.Main],
+    credentials: [
+      {
+        name: 'signalCliApi',
+        required: true,
+      },
+    ],
+    properties: [
+      {
+        displayName: 'Account',
+        name: 'account',
+        type: 'string',
+        default: '',
+        required: true,
+      },
+    ],
+  };
+
+  async trigger(this: ITriggerFunctions): Promise<ITriggerResponse> {
+    const credentials = await this.getCredentials('signalCliApi');
+    if (!credentials.url) {
+      throw new NodeApiError(this.getNode(), { message: 'Signal CLI API URL is not set in credentials' });
+    }
+    const url = `${credentials.url}/api/v1/events`;
+
+    const eventSource = new EventSource(url);
+
+    eventSource.onmessage = (event) => {
+      signalTriggerDebug('Received event: %o', event);
+      try {
+        const data = JSON.parse(event.data);
+        const message = data.dataMessage?.message;
+        if (message) {
+          const item: INodeExecutionData = {
+            json: { message },
+          };
+          this.emit([this.helpers.returnJsonArray([item])]);
+        }
+      } catch (error) {
+        this.logger.error('Error parsing message from Signal API', { error });
+      }
+    };
+
+    
+
+    return new Promise((resolve, reject) => {
+      eventSource.onerror = (err) => {
+        this.logger.error('EventSource error');
+        reject(err);
+      };
+
+      eventSource.onopen = () => {
+        signalTriggerDebug('Connected to %s', url);
+
+        eventSource.onerror = (err) => {
+          this.logger.error('EventSource error', {error: err });
+        };
+
+        resolve({
+          closeFunction: async () => {
+            eventSource.close();
+          },
+        });
+      }
+    });
+
+    
+
+  }
+}