refactor: migrate n8n node to official n8n-node CLI tooling

.github/workflows/n8n-ci.yml

@@ -0,0 +1,29 @@
+name: n8n Node CI
+
+on:
+  pull_request:
+    paths:
+      - 'n8n/**'
+  push:
+    branches: [main]
+    paths:
+      - 'n8n/**'
+
+jobs:
+  build:
+    runs-on: ubuntu-latest
+    defaults:
+      run:
+        working-directory: n8n
+    steps:
+      - uses: actions/checkout@v4
+
+      - uses: actions/setup-node@v4
+        with:
+          node-version: '22'
+
+      - run: npm install
+
+      - run: npm run lint
+
+      - run: npm run build

.github/workflows/n8n-publish.yml

@@ -0,0 +1,34 @@
+name: Publish n8n Node to npm
+
+on:
+  release:
+    types: [published]
+  workflow_dispatch:
+
+jobs:
+  publish:
+    runs-on: ubuntu-latest
+    if: startsWith(github.ref, 'refs/tags/n8n-')
+    permissions:
+      contents: read
+      id-token: write
+    defaults:
+      run:
+        working-directory: n8n
+    steps:
+      - uses: actions/checkout@v4
+
+      - uses: actions/setup-node@v4
+        with:
+          node-version: '22'
+          registry-url: 'https://registry.npmjs.org'
+
+      - run: npm install
+
+      - run: npm run lint
+
+      - run: npm run build
+
+      - run: npm publish --provenance --access public
+        env:
+          NODE_AUTH_TOKEN: ${{ secrets.NPM_TOKEN }}

n8n/.prettierrc.js

@@ -0,0 +1,12 @@
+module.exports = {
+	semi: true,
+	trailingComma: 'all',
+	bracketSpacing: true,
+	useTabs: true,
+	tabWidth: 2,
+	arrowParens: 'always',
+	singleQuote: true,
+	quoteProps: 'as-needed',
+	endOfLine: 'lf',
+	printWidth: 100,
+};

n8n/eslint.config.mjs

@@ -0,0 +1,3 @@
+import { config } from '@n8n/node-cli/eslint';
+
+export default config;

n8n/nodes/Tinyfish/GenericFunctions.ts

@@ -52,7 +52,6 @@ function getActionableMessage(error: unknown): string | undefined {
 
 /**
  * Make an authenticated request to the TinyFish API.
- * Retries on 429/5xx with exponential backoff (max 3 retries).
  */
 export async function tinyfishApiRequest(
 	this: IExecuteFunctions,
@@ -135,93 +134,89 @@ export async function consumeSseStream(
 
 	let lastProgress = '';
 
-	try {
-		const response = await fetch(`${API_BASE_URL}/v1/automation/run-sse`, {
-			method: 'POST',
-			headers: {
-				'X-API-Key': apiKey,
-				'Content-Type': 'application/json',
-			},
-			body: JSON.stringify(payload),
-		});
-
-		if (!response.ok) {
-			const errorText = await response.text();
-			throw new NodeOperationError(this.getNode(), `API request failed with status ${response.status}: ${errorText}`);
-		}
+	const response = await fetch(`${API_BASE_URL}/v1/automation/run-sse`, {
+		method: 'POST',
+		headers: {
+			'X-API-Key': apiKey,
+			'Content-Type': 'application/json',
+		},
+		body: JSON.stringify(payload),
+	});
+
+	if (!response.ok) {
+		const errorText = await response.text();
+		throw new NodeOperationError(this.getNode(), `API request failed with status ${response.status}: ${errorText}`);
+	}
 
-		if (!response.body) {
-			throw new NodeOperationError(this.getNode(), 'Response body is empty');
-		}
+	if (!response.body) {
+		throw new NodeOperationError(this.getNode(), 'Response body is empty');
+	}
 
-		const reader = response.body.getReader();
-		const decoder = new TextDecoder();
-		let buffer = '';
-		let finalResult: IDataObject | null = null;
-		let runId = '';
-		let streamingUrl = '';
+	const reader = response.body.getReader();
+	const decoder = new TextDecoder();
+	let buffer = '';
+	let finalResult: IDataObject | null = null;
+	let runId = '';
+	let streamingUrl = '';
 
-		while (true) {
-			const { done, value } = await reader.read();
+	while (true) {
+		const { done, value } = await reader.read();
 
-			buffer += decoder.decode(value, { stream: true });
-			if (done) {
-				buffer += decoder.decode();
-			}
-			const lines = buffer.split('\n');
-			buffer = lines.pop() ?? '';
+		buffer += decoder.decode(value, { stream: true });
+		if (done) {
+			buffer += decoder.decode();
+		}
+		const lines = buffer.split('\n');
+		buffer = lines.pop() ?? '';
 
-			for (const line of lines) {
-				if (!line.startsWith('data: ')) continue;
+		for (const line of lines) {
+			if (!line.startsWith('data: ')) continue;
 
-				let eventData: IDataObject;
-				try {
-					eventData = JSON.parse(line.slice(6)) as IDataObject;
-				} catch {
-					continue;
-				}
+			let eventData: IDataObject;
+			try {
+				eventData = JSON.parse(line.slice(6)) as IDataObject;
+			} catch {
+				continue;
+			}
 
-				const eventType = eventData.type as string;
-
-				if (eventType === 'STARTED') {
-					runId = (eventData.runId as string) || '';
-				} else if (eventType === 'STREAMING_URL') {
-					streamingUrl = (eventData.streamingUrl as string) || '';
-				} else if (eventType === 'PROGRESS') {
-					lastProgress = (eventData.purpose as string) || '';
-				} else if (eventType === 'COMPLETE') {
-					const status = eventData.status as string;
-					if (status === 'COMPLETED') {
-						finalResult = {
-							status: 'COMPLETED',
-							runId,
-							streamingUrl,
-							lastProgress,
-							resultJson: eventData.resultJson || {},
-						};
-					} else {
-						finalResult = {
-							status: status || 'FAILED',
-							runId,
-							lastProgress,
-							error: eventData.error || 'Unknown error',
-						};
-					}
+			const eventType = eventData.type as string;
+
+			if (eventType === 'STARTED') {
+				runId = (eventData.runId as string) || '';
+			} else if (eventType === 'STREAMING_URL') {
+				streamingUrl = (eventData.streamingUrl as string) || '';
+			} else if (eventType === 'PROGRESS') {
+				lastProgress = (eventData.purpose as string) || '';
+			} else if (eventType === 'COMPLETE') {
+				const status = eventData.status as string;
+				if (status === 'COMPLETED') {
+					finalResult = {
+						status: 'COMPLETED',
+						runId,
+						streamingUrl,
+						lastProgress,
+						resultJson: eventData.resultJson || {},
+					};
+				} else {
+					finalResult = {
+						status: status || 'FAILED',
+						runId,
+						lastProgress,
+						error: eventData.error || 'Unknown error',
+					};
 				}
 			}
-
-			if (done) break;
 		}
 
-		if (!finalResult) {
-			throw new NodeOperationError(
-				this.getNode(),
-				'SSE stream ended without a COMPLETE event',
-			);
-		}
+		if (done) break;
+	}
 
-		return finalResult;
-	} catch (error) {
-		throw error;
+	if (!finalResult) {
+		throw new NodeOperationError(
+			this.getNode(),
+			'SSE stream ended without a COMPLETE event',
+		);
 	}
+
+	return finalResult;
 }

n8n/nodes/Tinyfish/Tinyfish.node.ts

@@ -5,7 +5,7 @@ import type {
 	INodeType,
 	INodeTypeDescription,
 } from 'n8n-workflow';
-import { NodeOperationError } from 'n8n-workflow';
+import { NodeConnectionTypes, NodeOperationError } from 'n8n-workflow';
 
 import {
 	operationField,
@@ -34,8 +34,8 @@ export class Tinyfish implements INodeType {
 		defaults: {
 			name: 'TinyFish Web Agent',
 		},
-		inputs: ['main'],
-		outputs: ['main'],
+		inputs: [NodeConnectionTypes.Main],
+		outputs: [NodeConnectionTypes.Main],
 		usableAsTool: true,
 		credentials: [
 			{

n8n/nodes/Tinyfish/TinyfishDescription.ts

@@ -4,20 +4,20 @@ export const operationField: INodeProperties = {
 	displayName: 'Operation',
 	name: 'operation',
 	type: 'options',
+	noDataExpression: true,
 	default: 'runSse',
 	options: [
 		{
-			name: 'Run (SSE Streaming)',
-			value: 'runSse',
-			action: 'Run automation with SSE streaming',
-			description:
-				'Recommended for most tasks. Streams real-time progress events and returns the final result. Best for tasks that may take 30+ seconds.',
+			name: 'Get Run',
+			value: 'getRun',
+			action: 'Get run details',
+			description: 'Retrieve the status and result of a previously started async run by its ID',
 		},
 		{
-			name: 'Run (Sync)',
-			value: 'runSync',
-			action: 'Run automation synchronously',
-			description: 'Execute and wait for the complete result in a single response. Use for quick extractions under 60 seconds.',
+			name: 'List Runs',
+			value: 'listRuns',
+			action: 'List automation runs',
+			description: 'List past automation runs with optional status filter. Useful for monitoring or retrieving results.',
 		},
 		{
 			name: 'Run (Async)',
@@ -26,16 +26,17 @@ export const operationField: INodeProperties = {
 			description: 'Returns a run ID immediately without waiting. Use with Get Run to poll for results. Best for batch processing multiple URLs in parallel.',
 		},
 		{
-			name: 'Get Run',
-			value: 'getRun',
-			action: 'Get run details',
-			description: 'Retrieve the status and result of a previously started async run by its ID',
+			name: 'Run (SSE Streaming)',
+			value: 'runSse',
+			action: 'Run automation with SSE streaming',
+			description:
+				'Recommended for most tasks. Streams real-time progress events and returns the final result. Best for tasks that may take 30+ seconds.',
 		},
 		{
-			name: 'List Runs',
-			value: 'listRuns',
-			action: 'List automation runs',
-			description: 'List past automation runs with optional status filter. Useful for monitoring or retrieving results.',
+			name: 'Run (Sync)',
+			value: 'runSync',
+			action: 'Run automation synchronously',
+			description: 'Execute and wait for the complete result in a single response. Use for quick extractions under 60 seconds.',
 		},
 	],
 };
@@ -171,7 +172,7 @@ export const listRunsFields: INodeProperties[] = [
 		displayName: 'Limit',
 		name: 'limit',
 		type: 'number',
-		default: 20,
+		default: 50,
 		description: 'Max number of results to return',
 		typeOptions: {
 			minValue: 1,