feat(appwrite): add new documents trigger

packages/backend/src/apps/appwrite/dynamic-data/index.js

@@ -0,0 +1,4 @@
+import listCollections from './list-collections/index.js';
+import listDatabases from './list-databases/index.js';
+
+export default [listCollections, listDatabases];

packages/backend/src/apps/appwrite/dynamic-data/list-collections/index.js

@@ -0,0 +1,33 @@
+export default {
+  name: 'List collections',
+  key: 'listCollections',
+
+  async run($) {
+    const collections = {
+      data: [],
+    };
+    const databaseId = $.step.parameters.databaseId;
+
+    if (!databaseId) {
+      return collections;
+    }
+
+    const { data } = await $.http.get(
+      `/v1/databases/${databaseId}/collections`
+    );
+
+    if (data?.collections) {
+      const sortedCollections = data.collections.sort((a, b) =>
+        a.$createdAt - b.$createdAt ? 1 : -1
+      );
+      for (const collection of sortedCollections) {
+        collections.data.push({
+          value: collection.$id,
+          name: collection.name,
+        });
+      }
+    }
+
+    return collections;
+  },
+};

packages/backend/src/apps/appwrite/dynamic-data/list-databases/index.js

@@ -0,0 +1,26 @@
+export default {
+  name: 'List databases',
+  key: 'listDatabases',
+
+  async run($) {
+    const databases = {
+      data: [],
+    };
+
+    const { data } = await $.http.get('/v1/databases');
+
+    if (data?.databases) {
+      const sortedDatabases = data.databases.sort((a, b) =>
+        a.$createdAt - b.$createdAt ? 1 : -1
+      );
+      for (const database of sortedDatabases) {
+        databases.data.push({
+          value: database.$id,
+          name: database.name,
+        });
+      }
+    }
+
+    return databases;
+  },
+};

packages/backend/src/apps/appwrite/index.js

@@ -2,6 +2,8 @@ import defineApp from '../../helpers/define-app.js';
 import addAuthHeader from './common/add-auth-header.js';
 import setBaseUrl from './common/set-base-url.js';
 import auth from './auth/index.js';
+import triggers from './triggers/index.js';
+import dynamicData from './dynamic-data/index.js';
 
 export default defineApp({
   name: 'Appwrite',
@@ -14,4 +16,6 @@ export default defineApp({
   supportsConnections: true,
   beforeRequest: [setBaseUrl, addAuthHeader],
   auth,
+  triggers,
+  dynamicData,
 });

packages/backend/src/apps/appwrite/triggers/index.js

@@ -0,0 +1,3 @@
+import newDocuments from './new-documents/index.js';
+
+export default [newDocuments];

packages/backend/src/apps/appwrite/triggers/new-documents/index.js

@@ -0,0 +1,76 @@
+import defineTrigger from '../../../../helpers/define-trigger.js';
+
+export default defineTrigger({
+  name: 'New documents',
+  key: 'newDocuments',
+  pollInterval: 15,
+  description: 'Triggers when a new document is created.',
+  arguments: [
+    {
+      label: 'Database',
+      key: 'databaseId',
+      type: 'dropdown',
+      required: true,
+      description: '',
+      variables: true,
+      source: {
+        type: 'query',
+        name: 'getDynamicData',
+        arguments: [
+          {
+            name: 'key',
+            value: 'listDatabases',
+          },
+        ],
+      },
+    },
+    {
+      label: 'Collection',
+      key: 'collectionId',
+      type: 'dropdown',
+      required: true,
+      dependsOn: ['parameters.databaseId'],
+      description: '',
+      variables: true,
+      source: {
+        type: 'query',
+        name: 'getDynamicData',
+        arguments: [
+          {
+            name: 'key',
+            value: 'listCollections',
+          },
+          {
+            name: 'parameters.databaseId',
+            value: '{parameters.databaseId}',
+          },
+        ],
+      },
+    },
+  ],
+
+  async run($) {
+    const { databaseId, collectionId } = $.step.parameters;
+
+    const { data } = await $.http.get(
+      `/v1/databases/${databaseId}/collections/${collectionId}/documents`
+    );
+
+    if (!data?.documents?.length) {
+      return;
+    }
+
+    const sortedDocuments = data.documents.sort((a, b) =>
+      a.$createdAt - b.$createdAt ? 1 : -1
+    );
+
+    for (const document of sortedDocuments) {
+      $.pushTriggerItem({
+        raw: document,
+        meta: {
+          internalId: document.$id,
+        },
+      });
+    }
+  },
+});