feat(WebSocket Node): New node

packages/nodes-base/nodes/Google/Gmail/v2/MessageLabelDescription.ts

@@ -0,0 +1,76 @@
+import {
+	INodeProperties,
+} from 'n8n-workflow';
+
+export const messageLabelOperations: INodeProperties[] = [
+	{
+		displayName: 'Operation',
+		name: 'operation',
+		type: 'options',
+		noDataExpression: true,
+		displayOptions: {
+			show: {
+				resource: [
+					'messageLabel',
+				],
+			},
+		},
+		options: [
+			{
+				name: 'Add',
+				value: 'add',
+				action: 'Add a label to a message',
+			},
+			{
+				name: 'Remove',
+				value: 'remove',
+				action: 'Remove a label from a message',
+			},
+		],
+		default: 'add',
+	},
+];
+
+export const messageLabelFields: INodeProperties[] = [
+	{
+		displayName: 'Message ID',
+		name: 'messageId',
+		type: 'string',
+		default: '',
+		required: true,
+		displayOptions: {
+			show: {
+				resource: [
+					'messageLabel',
+				],
+				operation: [
+					'add',
+					'remove',
+				],
+			},
+		},
+		placeholder: '172ce2c4a72cc243',
+	},
+	{
+		displayName: 'Label Names or IDs',
+		name: 'labelIds',
+		type: 'multiOptions',
+		typeOptions: {
+			loadOptionsMethod: 'getLabels',
+		},
+		default: [],
+		required: true,
+		displayOptions: {
+			show: {
+				resource: [
+					'messageLabel',
+				],
+				operation: [
+					'add',
+					'remove',
+				],
+			},
+		},
+		description: 'Choose from the list, or specify IDs using an <a href="https://docs.n8n.io/code-examples/expressions/">expression</a>',
+	},
+];

packages/nodes-base/nodes/Google/Gmail/v2/ThreadLabelDescription.ts

@@ -0,0 +1,75 @@
+import {
+	INodeProperties,
+} from 'n8n-workflow';
+
+export const threadLabelOperations: INodeProperties[] = [
+	{
+		displayName: 'Operation',
+		name: 'operation',
+		type: 'options',
+		noDataExpression: true,
+		displayOptions: {
+			show: {
+				resource: [
+					'threadLabel',
+				],
+			},
+		},
+		options: [
+			{
+				name: 'Add',
+				value: 'add',
+				action: 'Add a thread label',
+			},
+			{
+				name: 'Remove',
+				value: 'remove',
+				action: 'Remove a thread label',
+			},
+		],
+		default: 'add',
+	},
+];
+
+export const threadLabelFields: INodeProperties[] = [
+	{
+		displayName: 'Thread ID',
+		name: 'threadId',
+		type: 'string',
+		default: '',
+		required: true,
+		displayOptions: {
+			show: {
+				resource: [
+					'threadLabel',
+				],
+				operation: [
+					'add',
+					'remove',
+				],
+			},
+		},
+	},
+	{
+		displayName: 'Label ID Names or IDs',
+		name: 'labelIds',
+		type: 'multiOptions',
+		description: 'Choose from the list, or specify IDs using an <a href="https://docs.n8n.io/code-examples/expressions/">expression</a>',
+		typeOptions: {
+			loadOptionsMethod: 'getLabels',
+		},
+		default: [],
+		required: true,
+		displayOptions: {
+			show: {
+				resource: [
+					'threadLabel',
+				],
+				operation: [
+					'add',
+					'remove',
+				],
+			},
+		},
+	},
+];

packages/nodes-base/nodes/WebSocket/WebSocket.node.json

@@ -0,0 +1,14 @@
+{
+	"node": "n8n-nodes-base.webSocket",
+	"nodeVersion": "1.0",
+	"codexVersion": "1.0",
+	"categories": ["Development"],
+	"resources": {
+		"primaryDocumentation": [
+			{
+				"url": "https://docs.n8n.io/integrations/builtin/app-nodes/n8n-nodes-base.websocket/"
+			}
+		]
+	},
+	"alias": ["Socket", "Channel", "wss"]
+}

packages/nodes-base/nodes/WebSocket/WebSocket.node.ts

@@ -0,0 +1,177 @@
+import type { IExecuteFunctions } from 'n8n-core';
+import type { INodeExecutionData, INodeType, INodeTypeDescription } from 'n8n-workflow';
+import { WebSocket as WebSocketClient } from 'ws';
+import type { ClientBinaryType } from './interface';
+
+export class WebSocket implements INodeType {
+	description: INodeTypeDescription = {
+		displayName: 'WebSocket',
+		name: 'webSocket',
+		icon: 'file:websocket.svg',
+		group: ['input'],
+		version: 1,
+		description: 'Send messages to a WebSocket server',
+		defaults: {
+			name: 'WebSocket',
+		},
+		inputs: ['main'],
+		outputs: ['main'],
+		properties: [
+			{
+				displayName: 'Address',
+				name: 'address',
+				type: 'string',
+				default: '',
+				required: true,
+			},
+			{
+				displayName: 'Use Input Data',
+				name: 'useInputData',
+				type: 'boolean',
+				default: true,
+				required: true,
+				description: 'Whether to use the input data or the message property',
+			},
+			{
+				displayName: 'Message',
+				name: 'message',
+				type: 'string',
+				default: '',
+				required: true,
+				displayOptions: {
+					show: {
+						useInputData: [false],
+					},
+				},
+			},
+			{
+				displayName: 'Options',
+				name: 'options',
+				type: 'collection',
+				placeholder: 'Add Option',
+				default: {},
+				options: [
+					{
+						displayName: 'Binary Type',
+						name: 'binaryType',
+						type: 'options',
+						default: 'nodebuffer',
+						options: [
+							{
+								name: 'Node Buffer',
+								value: 'nodebuffer',
+							},
+							{
+								name: 'Array Buffer',
+								value: 'arraybuffer',
+							},
+							{
+								name: 'Fragments',
+								value: 'fragments',
+							},
+						],
+					},
+					{
+						displayName: 'Message Encoding',
+						name: 'encoding',
+						type: 'string',
+						default: 'utf8',
+					},
+					{
+						displayName: 'Parse JSON',
+						name: 'toJson',
+						type: 'boolean',
+						default: false,
+					},
+				],
+			},
+		],
+	};
+
+	async execute(this: IExecuteFunctions): Promise<INodeExecutionData[][]> {
+		const items = this.getInputData();
+
+		const returnData: INodeExecutionData[] = [];
+
+		const address = this.getNodeParameter('address', 0) as string;
+		const options = this.getNodeParameter('options', 0);
+		const useInputData = this.getNodeParameter('useInputData', 0) as boolean;
+
+		const client = new WebSocketClient(address);
+
+		if (options.binaryType) {
+			client.binaryType = options.binaryType as ClientBinaryType;
+		}
+
+		// eslint-disable-next-line @typescript-eslint/no-this-alias
+		const self = this;
+
+		async function manualTriggerFunction() {
+			return new Promise((resolve, reject) => {
+				client.on('open', () => {
+					if (useInputData) {
+						for (let i = 0; i < items.length; i++) {
+							const item = items[i].json;
+							client.send(JSON.stringify(item), (error) => {
+								if (error) {
+									if (self.continueOnFail()) {
+										returnData.push({ json: { error: error.message } });
+									} else {
+										throw error;
+									}
+								}
+							});
+							returnData.push({ json: items[i].json });
+						}
+						resolve(true);
+					} else {
+						const message = self.getNodeParameter('message', 0) as string;
+						client.send(message, (error) => {
+							if (error) {
+								if (self.continueOnFail()) {
+									returnData.push({ json: { error: error.message } });
+								} else {
+									throw error;
+								}
+							}
+						});
+						returnData.push({ json: { message } });
+						resolve(true);
+					}
+				});
+
+				// client.on('message', (data, isBinary) => {
+				// 	const message = isBinary ? data : data.toString(encoding as BufferEncoding);
+				// 	console.log('message', message);
+				// 	if (useInputData) {
+				// 		if (message === JSON.stringify(items[items.length - 1].json)) {
+				// 			resolve(true);
+				// 		}
+				// 	} else {
+				// 		if (message === self.getNodeParameter('message', 0)) {
+				// 			resolve(true);
+				// 		}
+				// 	}
+				// });
+
+				client.on('error', (error) => {
+					if (self.continueOnFail()) {
+						returnData.push({ json: { error: error.message } });
+					} else {
+						reject(error);
+					}
+				});
+			});
+		}
+
+		await manualTriggerFunction();
+
+		while (client.bufferedAmount > 0) {
+			await new Promise((resolve) => setTimeout(resolve, 100));
+		}
+
+		client.terminate();
+
+		return this.prepareOutputData(returnData);
+	}
+}

packages/nodes-base/nodes/WebSocket/WebSocketTrigger.node.json

@@ -0,0 +1,14 @@
+{
+	"node": "n8n-nodes-base.webSocketTrigger",
+	"nodeVersion": "1.0",
+	"codexVersion": "1.0",
+	"categories": ["Development"],
+	"resources": {
+		"primaryDocumentation": [
+			{
+				"url": "https://docs.n8n.io/integrations/builtin/app-nodes/n8n-nodes-base.websockettrigger/"
+			}
+		]
+	},
+	"alias": ["Socket", "Channel", "wss"]
+}