feat: add modify existing workflow action and output schema validation

.github/workflows/npm-deploy.yml

@@ -70,8 +70,14 @@ 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
+
+      - name: Capture trigger schemas
+        run: bun run scripts/capture-trigger-schemas.ts --from-existing
+        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,82 @@
+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
+
+      - name: Capture trigger schemas
+        run: bun run scripts/capture-trigger-schemas.ts --from-existing
+        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

@@ -513,6 +513,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
   // ==========================================================================