feat(notion): add auth and new DB items trigger

packages/backend/src/apps/notion/triggers/index.ts

@@ -0,0 +1,3 @@
+import newDatabaseItems from './new-database-items';
+
+export default [newDatabaseItems];

packages/backend/src/apps/notion/triggers/new-database-items/index.ts

@@ -0,0 +1,32 @@
+import defineTrigger from '../../../../helpers/define-trigger';
+import newDatabaseItems from './new-database-items';
+
+export default defineTrigger({
+  name: 'New database items',
+  key: 'newDatabaseItems',
+  pollInterval: 15,
+  description: 'Triggers when a new database item is created',
+  arguments: [
+    {
+      label: 'Database',
+      key: 'databaseId',
+      type: 'dropdown' as const,
+      required: false,
+      variables: false,
+      source: {
+        type: 'query',
+        name: 'getDynamicData',
+        arguments: [
+          {
+            name: 'key',
+            value: 'listDatabases',
+          },
+        ],
+      },
+    },
+  ],
+
+  async run($) {
+    await newDatabaseItems($);
+  },
+});

packages/backend/src/apps/notion/triggers/new-database-items/new-database-items.ts

@@ -0,0 +1,50 @@
+import { IGlobalVariable } from '@automatisch/types';
+
+type DatabaseItem = {
+  id: string;
+}
+
+type ResponseData = {
+  results: DatabaseItem[];
+  next_cursor?: string;
+}
+
+type Payload = {
+  sorts: [
+    {
+      timestamp: 'created_time' | 'last_edited_time';
+      direction: 'ascending' | 'descending';
+    }
+  ];
+  start_cursor?: string;
+};
+
+const newDatabaseItems = async ($: IGlobalVariable) => {
+  const payload: Payload = {
+    sorts: [
+      {
+        timestamp: 'created_time',
+        direction: 'descending'
+      }
+    ],
+  };
+
+  const databaseId = $.step.parameters.databaseId as string;
+  const path = `/v1/databases/${databaseId}/query`;
+  do {
+    const response = await $.http.post<ResponseData>(path, payload);
+
+    payload.start_cursor = response.data.next_cursor;
+
+    for (const databaseItem of response.data.results) {
+      $.pushTriggerItem({
+        raw: databaseItem,
+        meta: {
+          internalId: databaseItem.id,
+        }
+      })
+    }
+  } while (payload.start_cursor);
+};
+
+export default newDatabaseItems;