tangle-network
diff --git a/‎src/connectors/adapters/__tests__/quickbooks.test.ts‎
Lines changed: 10 additions & 0 deletions b/‎src/connectors/adapters/__tests__/quickbooks.test.ts‎
Lines changed: 10 additions & 0 deletions
diff --git a/‎src/connectors/adapters/__tests__/sendgrid.test.ts‎
Lines changed: 15 additions & 1 deletion b/‎src/connectors/adapters/__tests__/sendgrid.test.ts‎
Lines changed: 15 additions & 1 deletion
diff --git a/‎src/connectors/adapters/__tests__/typeform.test.ts‎
Lines changed: 8 additions & 0 deletions b/‎src/connectors/adapters/__tests__/typeform.test.ts‎
Lines changed: 8 additions & 0 deletions
diff --git a/‎src/connectors/adapters/__tests__/whatsapp-business.test.ts‎
Lines changed: 9 additions & 3 deletions b/‎src/connectors/adapters/__tests__/whatsapp-business.test.ts‎
Lines changed: 9 additions & 3 deletions
diff --git a/‎src/connectors/adapters/__tests__/xero.test.ts‎
Lines changed: 21 additions & 7 deletions b/‎src/connectors/adapters/__tests__/xero.test.ts‎
Lines changed: 21 additions & 7 deletions
diff --git a/‎src/connectors/adapters/__tests__/zendesk.test.ts‎
Lines changed: 5 additions & 0 deletions b/‎src/connectors/adapters/__tests__/zendesk.test.ts‎
Lines changed: 5 additions & 0 deletions
diff --git a/‎src/connectors/adapters/n8n.ts‎
Lines changed: 96 additions & 0 deletions b/‎src/connectors/adapters/n8n.ts‎
Lines changed: 96 additions & 0 deletions
diff --git a/‎src/connectors/adapters/nocodb.ts‎
Lines changed: 89 additions & 0 deletions b/‎src/connectors/adapters/nocodb.ts‎
Lines changed: 89 additions & 0 deletions
@@ -43,11 +43,16 @@ describe('quickbooks adapter manifest', () => {
         'customers.get',
         'customers.create',
         'customers.update',
+        'customers.delete',
         'invoices.get',
         'invoices.create',
         'invoices.update',
+        'invoices.delete',
+        'invoices.send',
         'items.create',
         'payments.create',
+        'bills.create',
+        'vendors.create',
       ].sort(),
     )
     const reads = quickbooksConnector.manifest.capabilities
@@ -60,12 +65,17 @@ describe('quickbooks adapter manifest', () => {
       .sort()
     expect(reads).toEqual(['customers.get', 'entities.query', 'invoices.get'])
     expect(mutations).toEqual([
+      'bills.create',
       'customers.create',
+      'customers.delete',
       'customers.update',
       'invoices.create',
+      'invoices.delete',
+      'invoices.send',
       'invoices.update',
       'items.create',
       'payments.create',
+      'vendors.create',
     ])
   })
 
 
@@ -32,17 +32,31 @@ describe('sendgrid adapter', () => {
     expect(sendgridConnector.manifest.auth.kind).toBe('api-key')
     const names = sendgridConnector.manifest.capabilities.map((c) => c.name).sort()
     expect(names).toEqual([
+      'contacts.delete',
       'contacts.get',
       'contacts.search',
       'contacts.upsert',
+      'lists.addContacts',
       'lists.create',
+      'lists.delete',
+      'lists.removeContacts',
       'lists.search',
       'mail.send',
+      'suppressions.create',
     ])
     const readers = sendgridConnector.manifest.capabilities.filter((c) => c.class === 'read').map((c) => c.name)
     const mutators = sendgridConnector.manifest.capabilities.filter((c) => c.class === 'mutation').map((c) => c.name)
     expect(readers).toEqual(['contacts.search', 'contacts.get', 'lists.search'])
-    expect(mutators).toEqual(['mail.send', 'contacts.upsert', 'lists.create'])
+    expect(mutators).toEqual([
+      'mail.send',
+      'contacts.upsert',
+      'lists.create',
+      'contacts.delete',
+      'lists.delete',
+      'lists.addContacts',
+      'lists.removeContacts',
+      'suppressions.create',
+    ])
   })
 
   it('exposes both executeRead and executeMutation handlers', () => {
 
@@ -53,11 +53,15 @@ describe('typeform adapter', () => {
     const names = typeformConnector.manifest.capabilities.map((c) => c.name).sort()
     expect(names).toEqual([
       'account.get',
+      'forms.create',
+      'forms.delete',
       'forms.get',
       'forms.list',
       'forms.update',
+      'images.create',
       'responses.delete',
       'responses.list',
+      'themes.list',
       'webhooks.delete',
       'webhooks.get',
       'webhooks.list',
@@ -71,12 +75,16 @@ describe('typeform adapter', () => {
       'forms.get',
       'forms.list',
       'responses.list',
+      'themes.list',
       'webhooks.get',
       'webhooks.list',
       'workspaces.list',
     ])
     expect(mutators).toEqual([
+      'forms.create',
+      'forms.delete',
       'forms.update',
+      'images.create',
       'responses.delete',
       'webhooks.delete',
       'webhooks.upsert',
 
@@ -65,14 +65,20 @@ describe('whatsappBusiness adapter', () => {
       'send_template_message',
       'list_message_templates',
       'get_business_phone_number',
+      'media.upload',
+      'templates.create',
+      'templates.delete',
+      'messages.mark-read',
     ])
 
     for (const cap of adapter.manifest.capabilities) {
       if (cap.class === 'mutation') {
-        // outbound chat is append-only — Meta has no idempotency primitive on /messages,
-        // so MutationGuard owns dedup above us.
-        expect(cap.cas).toBe('none')
         expect(cap.externalEffect).toBe(true)
+        if (cap.name === 'send_text_message' || cap.name === 'send_template_message') {
+          // outbound chat is append-only — Meta has no idempotency primitive on /messages,
+          // so MutationGuard owns dedup above us.
+          expect(cap.cas).toBe('none')
+        }
       }
     }
   })
 
@@ -52,20 +52,34 @@ describe('xero adapter manifest', () => {
     const names = xeroConnector.manifest.capabilities.map((c) => c.name).sort()
     expect(names).toEqual(
       [
-        'contacts.search',
-        'contacts.get',
+        'accounts.search',
+        'contacts.archive',
         'contacts.create',
+        'contacts.get',
+        'contacts.search',
         'contacts.update',
-        'invoices.search',
-        'invoices.get',
+        'credit-notes.create',
         'invoices.create',
-        'accounts.search',
-      ].sort(),
+        'invoices.delete',
+        'invoices.email',
+        'invoices.get',
+        'invoices.search',
+        'payments.create',
+      ],
     )
     const reads = xeroConnector.manifest.capabilities.filter((c) => c.class === 'read').map((c) => c.name)
     const mutations = xeroConnector.manifest.capabilities.filter((c) => c.class === 'mutation').map((c) => c.name)
     expect(reads.sort()).toEqual(['accounts.search', 'contacts.get', 'contacts.search', 'invoices.get', 'invoices.search'])
-    expect(mutations.sort()).toEqual(['contacts.create', 'contacts.update', 'invoices.create'])
+    expect(mutations.sort()).toEqual([
+      'contacts.archive',
+      'contacts.create',
+      'contacts.update',
+      'credit-notes.create',
+      'invoices.create',
+      'invoices.delete',
+      'invoices.email',
+      'payments.create',
+    ])
 
     const contactRead = xeroConnector.manifest.capabilities.find((c) => c.name === 'contacts.search')!
     expect(contactRead.requiredScopes).toEqual(['accounting.contacts'])
 
@@ -67,12 +67,17 @@ describe('zendeskConnector', () => {
     const byName = Object.fromEntries(caps.map((c) => [c.name, c]))
 
     expect(Object.keys(byName).sort()).toEqual([
+      'tickets.add-comment',
       'tickets.create',
+      'tickets.delete',
       'tickets.get',
+      'tickets.merge',
       'tickets.search',
       'tickets.update',
       'users.create',
+      'users.delete',
       'users.search',
+      'users.update',
     ])
 
     expect(byName['tickets.search'].class).toBe('read')
 
@@ -137,5 +137,101 @@ export const n8nConnector = declarativeRestConnector({
         body: '{payload}',
       },
     },
+    {
+      name: 'workflows.create',
+      class: 'mutation',
+      description:
+        'Create a new n8n workflow. `definition` must include the full workflow JSON shape n8n expects (name, nodes, connections, settings). Newly-created workflows start inactive.',
+      parameters: {
+        type: 'object',
+        properties: {
+          definition: {
+            type: 'object',
+            description: 'Full workflow definition (name, nodes, connections, settings, etc.).',
+          },
+        },
+        required: ['definition'],
+      },
+      request: {
+        method: 'POST',
+        path: '/api/v1/workflows',
+        body: '{definition}',
+      },
+      cas: 'native-idempotency',
+      externalEffect: true,
+    },
+    {
+      name: 'workflows.update',
+      class: 'mutation',
+      description:
+        'Replace an n8n workflow definition. `definition` is the full workflow JSON (nodes, connections, settings) that overwrites the existing record.',
+      parameters: {
+        type: 'object',
+        properties: {
+          workflowId: { type: 'string' },
+          definition: {
+            type: 'object',
+            description: 'Full workflow definition replacing the current one.',
+          },
+        },
+        required: ['workflowId', 'definition'],
+      },
+      request: {
+        method: 'PUT',
+        path: '/api/v1/workflows/{workflowId}',
+        body: '{definition}',
+      },
+      cas: 'native-idempotency',
+      externalEffect: true,
+    },
+    {
+      name: 'workflows.delete',
+      class: 'mutation',
+      description: 'Permanently delete an n8n workflow by id.',
+      parameters: {
+        type: 'object',
+        properties: { workflowId: { type: 'string' } },
+        required: ['workflowId'],
+      },
+      request: {
+        method: 'DELETE',
+        path: '/api/v1/workflows/{workflowId}',
+      },
+      cas: 'native-idempotency',
+      externalEffect: true,
+    },
+    {
+      name: 'executions.delete',
+      class: 'mutation',
+      description: 'Delete a past n8n execution record by id.',
+      parameters: {
+        type: 'object',
+        properties: { executionId: { type: 'string' } },
+        required: ['executionId'],
+      },
+      request: {
+        method: 'DELETE',
+        path: '/api/v1/executions/{executionId}',
+      },
+      cas: 'native-idempotency',
+      externalEffect: true,
+    },
+    {
+      name: 'executions.stop',
+      class: 'mutation',
+      description:
+        'Stop a running n8n execution. Returns the final execution record once the runtime acknowledges the stop signal.',
+      parameters: {
+        type: 'object',
+        properties: { executionId: { type: 'string' } },
+        required: ['executionId'],
+      },
+      request: {
+        method: 'POST',
+        path: '/api/v1/executions/{executionId}/stop',
+      },
+      cas: 'native-idempotency',
+      externalEffect: true,
+    },
   ],
 })
@@ -108,5 +108,94 @@ export const nocodbConnector = declarativeRestConnector({
       },
       cas: 'optimistic-read-verify',
     },
+    {
+      name: 'tables.list',
+      class: 'read',
+      description: 'List tables in a NocoDB base/project.',
+      parameters: {
+        type: 'object',
+        properties: {
+          projectId: { type: 'string', description: 'The base/project ID to list tables for.' },
+        },
+        required: ['projectId'],
+      },
+      request: {
+        method: 'GET',
+        path: '/api/v1/db/meta/projects/{projectId}/tables',
+      },
+    },
+    {
+      name: 'tables.create',
+      class: 'mutation',
+      description:
+        'Create a new table inside a NocoDB base/project. `definition` carries the table schema (table_name, title, columns).',
+      parameters: {
+        type: 'object',
+        properties: {
+          projectId: { type: 'string', description: 'The base/project ID to create the table in.' },
+          definition: {
+            type: 'object',
+            description: 'Table definition (table_name, title, columns, etc.).',
+          },
+        },
+        required: ['projectId', 'definition'],
+      },
+      request: {
+        method: 'POST',
+        path: '/api/v1/db/meta/projects/{projectId}/tables',
+        body: '{definition}',
+      },
+      cas: 'native-idempotency',
+      externalEffect: true,
+    },
+    {
+      name: 'fields.create',
+      class: 'mutation',
+      description:
+        'Add a column/field to an existing NocoDB table. `column` describes the new field (column_name, title, uidt, etc.).',
+      parameters: {
+        type: 'object',
+        properties: {
+          tableId: { type: 'string', description: 'The table ID to add the column to.' },
+          column: {
+            type: 'object',
+            description: 'Column definition (column_name, title, uidt, etc.).',
+          },
+        },
+        required: ['tableId', 'column'],
+      },
+      request: {
+        method: 'POST',
+        path: '/api/v1/db/meta/tables/{tableId}/columns',
+        body: '{column}',
+      },
+      cas: 'native-idempotency',
+      externalEffect: true,
+    },
+    {
+      name: 'records.bulk-create',
+      class: 'mutation',
+      description:
+        'Insert many records into a NocoDB table in one request. `records` is an array of field-value objects.',
+      parameters: {
+        type: 'object',
+        properties: {
+          tableId: { type: 'string', description: 'The table ID to insert into.' },
+          records: {
+            type: 'array',
+            description: 'Array of record objects to insert.',
+            items: { type: 'object' },
+          },
+        },
+        required: ['tableId', 'records'],
+      },
+      request: {
+        method: 'POST',
+        path: '/api/v1/db/data/bulk/noco/{tableId}',
+        body: '{records}',
+      },
+      cas: 'native-idempotency',
+      externalEffect: true,
+    },
   ],
 })