feat: add modify existing workflow action and output schema validation

.github/workflows/ci.yml

@@ -22,7 +22,10 @@ jobs:
       - uses: actions/checkout@v4
       - uses: oven-sh/setup-bun@v2
       - run: bun install
-      - run: bun run crawl-nodes
+      - run: bun run crawl
+        env:
+          N8N_API_KEY: ${{ secrets.N8N_API_KEY }}
+          N8N_HOST: ${{ secrets.N8N_HOST }}
       - run: bun run test:unit
 
   test-integration:
@@ -32,7 +35,10 @@ jobs:
       - uses: actions/checkout@v4
       - uses: oven-sh/setup-bun@v2
       - run: bun install
-      - run: bun run crawl-nodes
+      - run: bun run crawl
+        env:
+          N8N_API_KEY: ${{ secrets.N8N_API_KEY }}
+          N8N_HOST: ${{ secrets.N8N_HOST }}
       - run: bun run test:integration
 
   test-e2e:
@@ -42,7 +48,10 @@ jobs:
       - uses: actions/checkout@v4
       - uses: oven-sh/setup-bun@v2
       - run: bun install
-      - run: bun run crawl-nodes
+      - run: bun run crawl
+        env:
+          N8N_API_KEY: ${{ secrets.N8N_API_KEY }}
+          N8N_HOST: ${{ secrets.N8N_HOST }}
       - run: bun run test:e2e
 
   build:
@@ -53,5 +62,8 @@ jobs:
       - uses: actions/checkout@v4
       - uses: oven-sh/setup-bun@v2
       - run: bun install
-      - run: bun run crawl-nodes
+      - run: bun run crawl
+        env:
+          N8N_API_KEY: ${{ secrets.N8N_API_KEY }}
+          N8N_HOST: ${{ secrets.N8N_HOST }}
       - run: bun run build

.github/workflows/npm-deploy.yml

@@ -70,8 +70,11 @@ jobs:
       - name: Install dependencies
         run: bun install
 
-      - name: Generate node catalog
-        run: bun run crawl-nodes
+      - name: Generate node catalog and schemas
+        run: bun run crawl
+        env:
+          N8N_API_KEY: ${{ secrets.N8N_API_KEY }}
+          N8N_HOST: ${{ secrets.N8N_HOST }}
 
       - name: Build package
         run: bun run build

.github/workflows/schema-update.yml

@@ -0,0 +1,79 @@
+name: Schema Update
+
+on:
+  schedule:
+    - cron: '0 3 * * 1' # Monday 3AM UTC
+  workflow_dispatch:
+
+jobs:
+  check:
+    runs-on: ubuntu-latest
+    permissions:
+      contents: write
+      actions: write
+    steps:
+      - uses: actions/checkout@v4
+      - uses: oven-sh/setup-bun@v2
+      - run: bun install
+
+      - name: Generate schemas
+        run: bun run crawl
+        env:
+          N8N_API_KEY: ${{ secrets.N8N_API_KEY }}
+          N8N_HOST: ${{ secrets.N8N_HOST }}
+
+      - run: bun run build
+
+      - name: Download latest release
+        run: |
+          mkdir -p /tmp/latest
+          bunx npm pack @elizaos/plugin-n8n-workflow@latest --pack-destination /tmp
+          tar xzf /tmp/elizaos-plugin-n8n-workflow-*.tgz -C /tmp/latest
+
+      - name: Compare with latest release
+        id: compare
+        run: |
+          CHANGED=false
+
+          for file in defaultNodes.json schemaIndex.json triggerSchemaIndex.json; do
+            NEW="dist/data/$file"
+            OLD="/tmp/latest/package/dist/data/$file"
+
+            if [ ! -f "$NEW" ]; then
+              continue
+            fi
+
+            if [ ! -f "$OLD" ]; then
+              echo "$file: NEW file (not in latest release)"
+              CHANGED=true
+              continue
+            fi
+
+            if ! diff <(jq -S . "$NEW") <(jq -S . "$OLD") > /dev/null 2>&1; then
+              echo "$file: CHANGED"
+              CHANGED=true
+            else
+              echo "$file: unchanged"
+            fi
+          done
+
+          echo "changed=$CHANGED" >> $GITHUB_OUTPUT
+
+      - name: Bump version
+        if: steps.compare.outputs.changed == 'true'
+        run: |
+          git config user.name "github-actions[bot]"
+          git config user.email "github-actions[bot]@users.noreply.github.com"
+          npm version patch --no-git-tag-version
+          VERSION=$(jq -r .version package.json)
+          git add package.json
+          git commit -m "chore: bump to v${VERSION} (schema update)"
+          git push
+        env:
+          GITHUB_TOKEN: ${{ secrets.GITHUB_TOKEN }}
+
+      - name: Trigger publish
+        if: steps.compare.outputs.changed == 'true'
+        run: gh workflow run npm-deploy.yml
+        env:
+          GITHUB_TOKEN: ${{ secrets.GITHUB_TOKEN }}

.gitignore

@@ -36,6 +36,11 @@ coverage/
 .temp/
 tmp/
 temp/
-# Generated node catalog (run `bun run crawl-nodes` to regenerate)
+# Generated data files (run `bun run crawl` to regenerate)
 src/data/defaultNodes.json
+src/data/schemaIndex.json
+src/data/triggerSchemaIndex.json
+
+# Script cache
+.cache/
 

__tests__/fixtures/workflows.ts

@@ -62,6 +62,28 @@ export function createSlackNode(overrides?: Partial<N8nNode>): N8nNode {
   };
 }
 
+export function createGmailTriggerNode(overrides?: Partial<N8nNode>): N8nNode {
+  return {
+    name: 'Gmail Trigger',
+    type: 'n8n-nodes-base.gmailTrigger',
+    typeVersion: 1,
+    position: [250, 300],
+    parameters: {},
+    ...overrides,
+  };
+}
+
+export function createGithubTriggerNode(overrides?: Partial<N8nNode>): N8nNode {
+  return {
+    name: 'GitHub Trigger',
+    type: 'n8n-nodes-base.githubTrigger',
+    typeVersion: 1,
+    position: [250, 300],
+    parameters: {},
+    ...overrides,
+  };
+}
+
 // ============================================================================
 // WORKFLOWS
 // ============================================================================

__tests__/integration/actions/createWorkflow.test.ts

@@ -332,8 +332,45 @@ describe('CREATE_N8N_WORKFLOW action', () => {
       const lastText = calls[calls.length - 1][0].text;
       expect(lastText).toContain('Modified Workflow'); // modified workflow name
 
-      // Should store updated draft in cache
+      // Should store updated draft in cache with originMessageId
       expect(runtime.setCache).toHaveBeenCalled();
+      const setCacheCall = (runtime.setCache as any).mock.calls.find((c: unknown[]) =>
+        (c[0] as string).startsWith('workflow_draft:')
+      );
+      expect(setCacheCall).toBeDefined();
+      const storedDraft = setCacheCall[1] as WorkflowDraft;
+      expect(storedDraft.originMessageId).toBe(message.id);
+    });
+
+    test('second call with same message.id after modify skips without callback (anti-loop)', async () => {
+      const draft = createDraftInCache();
+      draft.originMessageId = 'msg-001';
+
+      const mockService = createMockService();
+      const runtime = createMockRuntime({
+        services: { [N8N_WORKFLOW_SERVICE_TYPE]: mockService },
+        cache: { 'workflow_draft:user-001': draft },
+      });
+
+      const message = createMockMessage({ content: { text: 'Oui' } });
+      const callback = createMockCallback();
+
+      const result = await createWorkflowAction.handler(
+        runtime,
+        message,
+        createMockState(),
+        {},
+        callback
+      );
+
+      expect(result?.success).toBe(true);
+      expect(result?.data).toEqual({ awaitingUserInput: true });
+      // No service calls — skipped entirely
+      expect(mockService.modifyWorkflowDraft).not.toHaveBeenCalled();
+      expect(mockService.generateWorkflowDraft).not.toHaveBeenCalled();
+      expect(mockService.deployWorkflow).not.toHaveBeenCalled();
+      // No callback — agent gets no output to loop on
+      expect((callback as any).mock.calls.length).toBe(0);
     });
 
     test('expired draft is cleared and treated as new', async () => {
@@ -513,6 +550,79 @@ describe('CREATE_N8N_WORKFLOW action', () => {
     });
   });
 
+  // ==========================================================================
+  // MODIFY INCLUDES CHANGES IN PREVIEW
+  // ==========================================================================
+
+  describe('handler - modify includes changes in preview', () => {
+    test('preview data includes changed parameters after modify', async () => {
+      const draft: WorkflowDraft = {
+        workflow: {
+          name: 'Gmail Forward',
+          nodes: [
+            {
+              name: 'Gmail Trigger',
+              type: 'n8n-nodes-base.gmailTrigger',
+              typeVersion: 1,
+              position: [0, 0] as [number, number],
+              parameters: { pollTimes: { item: [{ mode: 'everyMinute' }] } },
+            },
+            {
+              name: 'Forward Email',
+              type: 'n8n-nodes-base.gmail',
+              typeVersion: 2,
+              position: [200, 0] as [number, number],
+              parameters: { operation: 'send', sendTo: '[email protected]' },
+              credentials: { gmailOAuth2Api: { id: 'cred-1', name: 'Gmail' } },
+            },
+          ],
+          connections: {
+            'Gmail Trigger': { main: [[{ node: 'Forward Email', type: 'main', index: 0 }]] },
+          },
+        },
+        prompt: 'Forward emails',
+        userId: 'user-001',
+        createdAt: Date.now(),
+      };
+
+      const modifiedWorkflow = {
+        ...draft.workflow,
+        nodes: [
+          draft.workflow.nodes[0],
+          {
+            ...draft.workflow.nodes[1],
+            parameters: { operation: 'send', sendTo: '[email protected]' },
+          },
+        ],
+      };
+
+      const mockService = createMockService({
+        modifyWorkflowDraft: mock(() => Promise.resolve(modifiedWorkflow)),
+      });
+
+      const runtime = createMockRuntime({
+        services: { [N8N_WORKFLOW_SERVICE_TYPE]: mockService },
+        useModel: createUseModelMock({ intent: 'modify', reason: 'User wants to modify' }),
+        cache: { 'workflow_draft:user-001': draft },
+      });
+
+      const callback = createMockCallback();
+
+      await createWorkflowAction.handler(
+        runtime,
+        createMockMessage({ content: { text: 'change email to [email protected]' } }),
+        createMockState(),
+        { intent: 'modify', modification: 'change email to [email protected]' },
+        callback
+      );
+
+      // The callback text should contain the new email (changes are passed to formatActionResponse)
+      const calls = (callback as any).mock.calls;
+      const lastText = calls[calls.length - 1][0].text;
+      expect(lastText).toContain('[email protected]');
+    });
+  });
+
   // ==========================================================================
   // CALLBACK SUCCESS STATUS TESTS
   // ==========================================================================