feat(firebase): add create firebase realtime database record action

.dockerignore

@@ -4,9 +4,5 @@
 **/.devcontainer
 **/.github
 **/.vscode
-**/.env
-**/.env.test
-**/.env.production
-**/yarn-error.log
 packages/docs
 packages/e2e-test

docker/Dockerfile

@@ -1,25 +1,14 @@
 # syntax=docker/dockerfile:1
 FROM node:18-alpine
-
-ENV PORT 3000
-
-RUN \
-  apk --no-cache add --virtual build-dependencies python3 build-base git
-
 WORKDIR /automatisch
 
-# copy the app, note .dockerignore
-COPY . /automatisch
-
-RUN yarn
-
-RUN cd packages/web && yarn build
-
 RUN \
+  apk --no-cache add --virtual build-dependencies python3 build-base && \
+  yarn global add @automatisch/cli@0.10.0 --network-timeout 1000000 && \
   rm -rf /usr/local/share/.cache/ && \
   apk del build-dependencies
 
-COPY ./docker/entrypoint.sh /entrypoint.sh
+COPY ./entrypoint.sh /entrypoint.sh
 
 EXPOSE 3000
 ENTRYPOINT ["sh", "/entrypoint.sh"]

docker/entrypoint.sh

@@ -2,12 +2,8 @@
 
 set -e
 
-cd packages/backend
-
 if [ -n "$WORKER" ]; then
-  yarn start:worker
+  automatisch start-worker
 else
-  yarn db:migrate
-  yarn db:seed:user
-  yarn start
+  automatisch start
 fi

packages/backend/package.json

@@ -31,7 +31,7 @@
     "accounting": "^0.4.1",
     "ajv-formats": "^2.1.1",
     "axios": "1.6.0",
-    "bcrypt": "^5.1.0",
+    "bcrypt": "^5.0.1",
     "bullmq": "^3.0.0",
     "cors": "^2.8.5",
     "crypto-js": "^4.1.1",
@@ -95,7 +95,6 @@
     "url": "https://github.com/automatisch/automatisch/issues"
   },
   "devDependencies": {
-    "node-gyp": "^10.1.0",
     "nodemon": "^2.0.13",
     "supertest": "^6.3.3",
     "vitest": "^1.1.3"

packages/backend/src/apps/azure-openai/index.js

@@ -11,7 +11,7 @@ export default defineApp({
     'https://azure.microsoft.com/en-us/products/ai-services/openai-service',
   apiBaseUrl: '',
   iconUrl: '{BASE_URL}/apps/azure-openai/assets/favicon.svg',
-  authDocUrl: '{DOCS_URL}/apps/azure-openai/connection',
+  authDocUrl: 'https://automatisch.io/docs/apps/azure-openai/connection',
   primaryColor: '000000',
   supportsConnections: true,
   beforeRequest: [setBaseUrl, addAuthHeader],

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

@@ -7,7 +7,7 @@ export default defineApp({
   name: 'Carbone',
   key: 'carbone',
   iconUrl: '{BASE_URL}/apps/carbone/assets/favicon.svg',
-  authDocUrl: '{DOCS_URL}/apps/carbone/connection',
+  authDocUrl: 'https://automatisch.io/docs/apps/carbone/connection',
   supportsConnections: true,
   baseUrl: 'https://carbone.io',
   apiBaseUrl: 'https://api.carbone.io',

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

@@ -5,7 +5,7 @@ export default defineApp({
   name: 'Datastore',
   key: 'datastore',
   iconUrl: '{BASE_URL}/apps/datastore/assets/favicon.svg',
-  authDocUrl: '{DOCS_URL}/apps/datastore/connection',
+  authDocUrl: 'https://automatisch.io/docs/apps/datastore/connection',
   supportsConnections: false,
   baseUrl: '',
   apiBaseUrl: '',

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

@@ -7,7 +7,7 @@ export default defineApp({
   name: 'DeepL',
   key: 'deepl',
   iconUrl: '{BASE_URL}/apps/deepl/assets/favicon.svg',
-  authDocUrl: '{DOCS_URL}/apps/deepl/connection',
+  authDocUrl: 'https://automatisch.io/docs/apps/deepl/connection',
   supportsConnections: true,
   baseUrl: 'https://deepl.com',
   apiBaseUrl: 'https://api.deepl.com',

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

@@ -5,7 +5,7 @@ export default defineApp({
   name: 'Delay',
   key: 'delay',
   iconUrl: '{BASE_URL}/apps/delay/assets/favicon.svg',
-  authDocUrl: '{DOCS_URL}/apps/delay/connection',
+  authDocUrl: 'https://automatisch.io/docs/apps/delay/connection',
   supportsConnections: false,
   baseUrl: '',
   apiBaseUrl: '',

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

@@ -10,7 +10,7 @@ export default defineApp({
   name: 'Discord',
   key: 'discord',
   iconUrl: '{BASE_URL}/apps/discord/assets/favicon.svg',
-  authDocUrl: '{DOCS_URL}/apps/discord/connection',
+  authDocUrl: 'https://automatisch.io/docs/apps/discord/connection',
   supportsConnections: true,
   baseUrl: 'https://discord.com',
   apiBaseUrl: 'https://discord.com/api',

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

@@ -7,7 +7,7 @@ export default defineApp({
   name: 'Dropbox',
   key: 'dropbox',
   iconUrl: '{BASE_URL}/apps/dropbox/assets/favicon.svg',
-  authDocUrl: '{DOCS_URL}/apps/dropbox/connection',
+  authDocUrl: 'https://automatisch.io/docs/apps/dropbox/connection',
   supportsConnections: true,
   baseUrl: 'https://dropbox.com',
   apiBaseUrl: 'https://api.dropboxapi.com',

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

@@ -5,7 +5,7 @@ export default defineApp({
   name: 'Filter',
   key: 'filter',
   iconUrl: '{BASE_URL}/apps/filter/assets/favicon.svg',
-  authDocUrl: '{DOCS_URL}/apps/filter/connection',
+  authDocUrl: 'https://automatisch.io/docs/apps/filter/connection',
   supportsConnections: false,
   baseUrl: '',
   apiBaseUrl: '',

packages/backend/src/apps/firebase/actions/create-cloud-firestore-document/index.js

@@ -0,0 +1,116 @@
+import defineAction from '../../../../helpers/define-action.js';
+
+export default defineAction({
+  name: 'Create Cloud Firestore document',
+  key: 'createCloudFirestoreDocument',
+  description: 'Creates a new document within a Cloud Firestore collection.',
+  arguments: [
+    {
+      label: 'Collection',
+      key: 'collectionId',
+      type: 'dropdown',
+      required: true,
+      description: '',
+      variables: true,
+      source: {
+        type: 'query',
+        name: 'getDynamicData',
+        arguments: [
+          {
+            name: 'key',
+            value: 'listFirestoreCollections',
+          },
+        ],
+      },
+    },
+    {
+      label: 'Convert Numerics',
+      key: 'convertNumerics',
+      type: 'dropdown',
+      required: false,
+      description:
+        "If any value represents a valid numerical value, whether it's an integer or a floating-point number, this field directs the database to store it as a numeric data type instead of a string.",
+      variables: true,
+      options: [
+        { label: 'Yes', value: true },
+        { label: 'No', value: false },
+      ],
+    },
+    {
+      label: 'Document ID',
+      key: 'documentId',
+      type: 'string',
+      required: false,
+      description:
+        'The document ID to use for this document. If not specified, an ID will be assigned.',
+      variables: true,
+    },
+    {
+      label: 'Document Data',
+      key: 'documentData',
+      type: 'dynamic',
+      required: false,
+      description: '',
+      fields: [
+        {
+          label: 'Key',
+          key: 'key',
+          type: 'string',
+          required: false,
+          variables: true,
+        },
+        {
+          label: 'Value',
+          key: 'value',
+          type: 'string',
+          required: false,
+          variables: true,
+        },
+      ],
+    },
+  ],
+
+  async run($) {
+    const projectId = $.auth.data.projectId;
+    const { collectionId, documentId, documentData, convertNumerics } =
+      $.step.parameters;
+
+    const documentDataObject = documentData.reduce((result, entry) => {
+      const key = entry.key?.toLowerCase();
+      const value = entry.value;
+      const isNumber = !isNaN(parseFloat(value));
+
+      if (key && value) {
+        const formattedValue =
+          convertNumerics && isNumber
+            ? { integerValue: parseFloat(value) }
+            : { stringValue: value };
+
+        return {
+          ...result,
+          [key]: formattedValue,
+        };
+      }
+
+      return result;
+    }, {});
+
+    const body = {
+      fields: documentDataObject,
+    };
+
+    const { data } = await $.http.post(
+      `/v1/projects/${projectId}/databases/(default)/documents/${collectionId}?documentId=${documentId}`,
+      body,
+      {
+        additionalProperties: {
+          setFirestoreBaseUrl: true,
+        },
+      }
+    );
+
+    $.setActionItem({
+      raw: data,
+    });
+  },
+});

packages/backend/src/apps/firebase/actions/create-firebase-realtime-database-record/index.js

@@ -0,0 +1,100 @@
+import defineAction from '../../../../helpers/define-action.js';
+
+export default defineAction({
+  name: 'Create Firebase Realtime Database Record',
+  key: 'createFirebaseRealtimeDatabaseRecord',
+  description: 'Creates a child object within your Firebase Realtime Database.',
+  arguments: [
+    {
+      label: 'Path',
+      key: 'path',
+      type: 'string',
+      required: true,
+      description:
+        "Indicate the path to the key of the object where the child objects to be queried are located, for example, 'foo/bar/here'.",
+      variables: true,
+    },
+    {
+      label: 'Convert Numerics',
+      key: 'convertNumerics',
+      type: 'dropdown',
+      required: false,
+      description:
+        "If any value represents a valid numerical value, whether it's an integer or a floating-point number, this field directs the database to store it as a numeric data type instead of a string.",
+      variables: true,
+      options: [
+        { label: 'Yes', value: true },
+        { label: 'No', value: false },
+      ],
+    },
+    {
+      label: 'New ID',
+      key: 'newId',
+      type: 'string',
+      required: false,
+      description:
+        'The key to use for this object, or leave it blank for Firebase to create one automatically.',
+      variables: true,
+    },
+    {
+      label: 'Data',
+      key: 'childData',
+      type: 'dynamic',
+      required: false,
+      description: '',
+      fields: [
+        {
+          label: 'Key',
+          key: 'key',
+          type: 'string',
+          required: false,
+          variables: true,
+        },
+        {
+          label: 'Value',
+          key: 'value',
+          type: 'string',
+          required: false,
+          variables: true,
+        },
+      ],
+    },
+  ],
+
+  async run($) {
+    let path = $.step.parameters.path;
+    const { convertNumerics, newId, childData } = $.step.parameters;
+
+    if (newId) {
+      path = `${path}/${newId}.json`;
+    } else {
+      path = `${path}.json`;
+    }
+
+    const formattedChildObjectData = childData.reduce((result, entry) => {
+      const key = entry?.key;
+      const value = entry?.value;
+      const isNumber = !isNaN(parseFloat(value));
+
+      if (isNumber && convertNumerics) {
+        result[key] = parseFloat(value);
+      } else {
+        result[key] = value;
+      }
+
+      return result;
+    }, {});
+
+    const body = formattedChildObjectData;
+
+    const { data } = await $.http.post(path, body, {
+      additionalProperties: {
+        setFirestoreBaseUrl: false,
+      },
+    });
+
+    $.setActionItem({
+      raw: data,
+    });
+  },
+});

packages/backend/src/apps/firebase/actions/find-cloud-firestore-document/index.js

@@ -0,0 +1,53 @@
+import defineAction from '../../../../helpers/define-action.js';
+
+export default defineAction({
+  name: 'Find Cloud Firestore document',
+  key: 'findCloudFirestoreDocument',
+  description: 'Finds a document within a collection.',
+  arguments: [
+    {
+      label: 'Collection',
+      key: 'collectionId',
+      type: 'dropdown',
+      required: true,
+      description: '',
+      variables: true,
+      source: {
+        type: 'query',
+        name: 'getDynamicData',
+        arguments: [
+          {
+            name: 'key',
+            value: 'listFirestoreCollections',
+          },
+        ],
+      },
+    },
+    {
+      label: 'Document ID',
+      key: 'documentId',
+      type: 'string',
+      required: true,
+      description: '',
+      variables: true,
+    },
+  ],
+
+  async run($) {
+    const projectId = $.auth.data.projectId;
+    const { collectionId, documentId } = $.step.parameters;
+
+    const { data } = await $.http.get(
+      `/v1/projects/${projectId}/databases/(default)/documents/${collectionId}/${documentId}`,
+      {
+        additionalProperties: {
+          setFirestoreBaseUrl: true,
+        },
+      }
+    );
+
+    $.setActionItem({
+      raw: data,
+    });
+  },
+});

packages/backend/src/apps/firebase/actions/index.js

@@ -0,0 +1,9 @@
+import createCloudFirestoreDocument from './create-cloud-firestore-document/index.js';
+import createFirebaseRealtimeDatabaseRecord from './create-firebase-realtime-database-record/index.js';
+import findCloudFirestoreDocument from './find-cloud-firestore-document/index.js';
+
+export default [
+  createCloudFirestoreDocument,
+  createFirebaseRealtimeDatabaseRecord,
+  findCloudFirestoreDocument,
+];

packages/backend/src/apps/firebase/auth/generate-auth-url.js

@@ -1,24 +1,23 @@
 import { URLSearchParams } from 'url';
+import authScope from '../common/auth-scope.js';
 
 export default async function generateAuthUrl($) {
   const oauthRedirectUrlField = $.app.auth.fields.find(
     (field) => field.key == 'oAuthRedirectUrl'
   );
   const redirectUri = oauthRedirectUrlField.value;
-  const state = Math.random().toString();
   const searchParams = new URLSearchParams({
     client_id: $.auth.data.clientId,
     redirect_uri: redirectUri,
+    prompt: 'select_account',
+    scope: authScope.join(' '),
     response_type: 'code',
-    state: state,
+    access_type: 'offline',
   });
 
-  const url = `${
-    $.auth.data.instanceUrl
-  }/login/oauth/authorize?${searchParams.toString()}`;
+  const url = `https://accounts.google.com/o/oauth2/v2/auth?${searchParams.toString()}`;
 
   await $.auth.set({
     url,
-    originalState: state,
   });
 }

packages/backend/src/apps/firebase/auth/index.js

@@ -11,23 +11,12 @@ export default {
       type: 'string',
       required: true,
       readOnly: true,
-      value: '{WEB_APP_URL}/app/gitea/connections/add',
+      value: '{WEB_APP_URL}/app/firebase/connections/add',
       placeholder: null,
       description:
-        'When asked to input a redirect URL in Gitea, enter the URL above.',
+        'When asked to input a redirect URL in Google Cloud, enter the URL above.',
       clickToCopy: true,
     },
-    {
-      key: 'instanceUrl',
-      label: 'Instance URL',
-      type: 'string',
-      required: true,
-      readOnly: false,
-      value: null,
-      placeholder: null,
-      description: null,
-      clickToCopy: false,
-    },
     {
       key: 'clientId',
       label: 'Client ID',
@@ -50,6 +39,29 @@ export default {
       description: null,
       clickToCopy: false,
     },
+    {
+      key: 'projectId',
+      label: 'Project ID',
+      type: 'string',
+      required: true,
+      readOnly: false,
+      value: null,
+      placeholder: null,
+      description: 'The project id of your Firebase project',
+      clickToCopy: false,
+    },
+    {
+      key: 'realtimeDatabaseId',
+      label: 'Realtime Database Domain',
+      type: 'string',
+      required: false,
+      readOnly: false,
+      value: null,
+      placeholder: null,
+      description:
+        'If you want to use Realtime Database, please provide the domain of your Realtime Database (https://{{domain}}.firebaseio.com)',
+      clickToCopy: false,
+    },
   ],
 
   generateAuthUrl,

packages/backend/src/apps/firebase/auth/is-still-verified.js

@@ -2,7 +2,7 @@ import getCurrentUser from '../common/get-current-user.js';
 
 const isStillVerified = async ($) => {
   const currentUser = await getCurrentUser($);
-  return !!currentUser.email;
+  return !!currentUser.resourceName;
 };
 
 export default isStillVerified;

packages/backend/src/apps/firebase/auth/refresh-token.js

@@ -1,5 +1,7 @@
 import { URLSearchParams } from 'node:url';
 
+import authScope from '../common/auth-scope.js';
+
 const refreshToken = async ($) => {
   const params = new URLSearchParams({
     client_id: $.auth.data.clientId,
@@ -9,11 +11,11 @@ const refreshToken = async ($) => {
   });
 
   const { data } = await $.http.post(
-    `${$.auth.data.instanceUrl}/login/oauth/access_token`,
+    'https://oauth2.googleapis.com/token',
     params.toString(),
     {
       additionalProperties: {
-        skipAddingBaseUrl: true,
+        skipAddingAuthHeader: true,
       },
     }
   );
@@ -21,8 +23,8 @@ const refreshToken = async ($) => {
   await $.auth.set({
     accessToken: data.access_token,
     expiresIn: data.expires_in,
+    scope: authScope.join(' '),
     tokenType: data.token_type,
-    refreshToken: data.refresh_token,
   });
 };
 

packages/backend/src/apps/firebase/auth/verify-credentials.js

@@ -1,28 +1,22 @@
 import getCurrentUser from '../common/get-current-user.js';
-import { URLSearchParams } from 'url';
 
 const verifyCredentials = async ($) => {
-  if ($.auth.data.originalState !== $.auth.data.state) {
-    throw new Error(`The 'state' parameter does not match.`);
-  }
   const oauthRedirectUrlField = $.app.auth.fields.find(
     (field) => field.key == 'oAuthRedirectUrl'
   );
   const redirectUri = oauthRedirectUrlField.value;
-  const params = new URLSearchParams({
-    client_id: $.auth.data.clientId,
-    client_secret: $.auth.data.clientSecret,
-    code: $.auth.data.code,
-    grant_type: 'authorization_code',
-    redirect_uri: redirectUri,
-  });
-
   const { data } = await $.http.post(
-    `${$.auth.data.instanceUrl}/login/oauth/access_token`,
-    params.toString(),
+    `https://oauth2.googleapis.com/token`,
+    {
+      client_id: $.auth.data.clientId,
+      client_secret: $.auth.data.clientSecret,
+      code: $.auth.data.code,
+      grant_type: 'authorization_code',
+      redirect_uri: redirectUri,
+    },
     {
       additionalProperties: {
-        skipAddingBaseUrl: true,
+        skipAddingAuthHeader: true,
       },
     }
   );
@@ -33,17 +27,23 @@ const verifyCredentials = async ($) => {
   });
 
   const currentUser = await getCurrentUser($);
-  const screenName = [currentUser.username, currentUser.email]
-    .filter(Boolean)
-    .join(' @ ');
+
+  const { displayName } = currentUser.names.find(
+    (name) => name.metadata.primary
+  );
+  const { value: email } = currentUser.emailAddresses.find(
+    (emailAddress) => emailAddress.metadata.primary
+  );
 
   await $.auth.set({
     clientId: $.auth.data.clientId,
     clientSecret: $.auth.data.clientSecret,
+    scope: $.auth.data.scope,
+    idToken: data.id_token,
     expiresIn: data.expires_in,
     refreshToken: data.refresh_token,
-    repoOwner: currentUser.username,
-    screenName,
+    resourceName: currentUser.resourceName,
+    screenName: `${displayName} - ${email}`,
   });
 };
 

packages/backend/src/apps/firebase/common/auth-scope.js

@@ -0,0 +1,9 @@
+const authScope = [
+  'https://www.googleapis.com/auth/datastore',
+  'https://www.googleapis.com/auth/firebase.database',
+  'https://www.googleapis.com/auth/datastore',
+  'https://www.googleapis.com/auth/userinfo.email',
+  'https://www.googleapis.com/auth/userinfo.profile',
+];
+
+export default authScope;

packages/backend/src/apps/firebase/common/get-current-user.js

@@ -0,0 +1,13 @@
+const getCurrentUser = async ($) => {
+  const { data: currentUser } = await $.http.get(
+    'https://people.googleapis.com/v1/people/me?personFields=names,emailAddresses',
+    {
+      additionalProperties: {
+        skipAddingAuthHeader: true,
+      },
+    }
+  );
+  return currentUser;
+};
+
+export default getCurrentUser;

packages/backend/src/apps/firebase/common/set-base-url.js

@@ -0,0 +1,16 @@
+const setBaseUrl = ($, requestConfig) => {
+  const realtimeDatabaseId = $.auth.data.realtimeDatabaseId;
+
+  if (requestConfig.additionalProperties?.skipAddingAuthHeader)
+    return requestConfig;
+
+  if (requestConfig.additionalProperties?.setFirestoreBaseUrl) {
+    requestConfig.baseURL = 'https://firestore.googleapis.com';
+  } else {
+    requestConfig.baseURL = `https://${realtimeDatabaseId}.firebaseio.com`;
+  }
+
+  return requestConfig;
+};
+
+export default setBaseUrl;

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

@@ -0,0 +1,3 @@
+import listFirestoreCollections from './list-firestore-collections/index.js';
+
+export default [listFirestoreCollections];

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

@@ -0,0 +1,32 @@
+export default {
+  name: 'List firestore collections',
+  key: 'listFirestoreCollections',
+
+  async run($) {
+    const firestoreCollections = {
+      data: [],
+    };
+    const projectId = $.auth.data.projectId;
+
+    const { data } = await $.http.post(
+      `/v1/projects/${projectId}/databases/(default)/documents:listCollectionIds`,
+      null,
+      {
+        additionalProperties: {
+          setFirestoreBaseUrl: true,
+        },
+      }
+    );
+
+    if (data.collectionIds?.length) {
+      for (const collectionId of data.collectionIds) {
+        firestoreCollections.data.push({
+          value: collectionId,
+          name: collectionId,
+        });
+      }
+    }
+
+    return firestoreCollections;
+  },
+};

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

@@ -4,18 +4,20 @@ import auth from './auth/index.js';
 import setBaseUrl from './common/set-base-url.js';
 import triggers from './triggers/index.js';
 import dynamicData from './dynamic-data/index.js';
+import actions from './actions/index.js';
 
 export default defineApp({
-  name: 'Gitea',
-  key: 'gitea',
-  iconUrl: '{BASE_URL}/apps/gitea/assets/favicon.svg',
-  authDocUrl: '{DOCS_URL}/apps/gitea/connection',
-  supportsConnections: true,
-  baseUrl: '',
+  name: 'Firebase',
+  key: 'firebase',
+  baseUrl: 'https://firebase.google.com',
   apiBaseUrl: '',
-  primaryColor: '609926',
+  iconUrl: '{BASE_URL}/apps/firebase/assets/favicon.svg',
+  authDocUrl: 'https://automatisch.io/docs/apps/firebase/connection',
+  primaryColor: 'FFA000',
+  supportsConnections: true,
   beforeRequest: [setBaseUrl, addAuthHeader],
   auth,
   triggers,
   dynamicData,
+  actions,
 });

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

@@ -0,0 +1,7 @@
+import newChildObjectInFirebaseRealtimeDatabase from './new-child-object-in-a-firebase-realtime-database/index.js';
+import newDocumentsWithinFirestoreCollection from './new-documents-within-firestore-collection/index.js';
+
+export default [
+  newChildObjectInFirebaseRealtimeDatabase,
+  newDocumentsWithinFirestoreCollection,
+];

packages/backend/src/apps/firebase/triggers/new-child-object-in-a-firebase-realtime-database/index.js

@@ -0,0 +1,75 @@
+import Crypto from 'crypto';
+import defineTrigger from '../../../../helpers/define-trigger.js';
+
+export default defineTrigger({
+  name: 'New child object in a firebase realtime database',
+  key: 'newChildObjectInFirebaseRealtimeDatabase',
+  pollInterval: 15,
+  description:
+    'Triggers when a new child object is generated within a specific path.',
+  arguments: [
+    {
+      label: 'Path',
+      key: 'path',
+      type: 'string',
+      required: true,
+      description:
+        "Indicate the path to the key of the object where the child objects to be queried are located, for example, 'foo/bar/here.json'.",
+      variables: true,
+    },
+    {
+      label: 'Order',
+      key: 'order',
+      type: 'string',
+      required: false,
+      description:
+        'The key or path of the child that should be utilized for comparing objects/records. If unspecified, the order of $key is used.',
+      variables: true,
+    },
+    {
+      label: 'Location of newest objects',
+      key: 'locationOfNewestObjects',
+      type: 'dropdown',
+      required: false,
+      description:
+        'Specifies whether the new 100 records are positioned at the "top" or the "bottom" of the ordering. If left unspecified, the assumption is that the bottom/last result represents the "newest objects" (limitToLast).',
+      variables: true,
+      options: [
+        { label: 'Top of results', value: 'limitToFirst' },
+        { label: 'Bottom of results', value: 'limitToLast' },
+      ],
+    },
+  ],
+
+  async run($) {
+    const { path, order, locationOfNewestObjects } = $.step.parameters;
+
+    const params = {};
+
+    if (order) {
+      params.orderBy = `"${order}"`;
+    }
+
+    if (locationOfNewestObjects) {
+      params[`${locationOfNewestObjects}`] = 100;
+    }
+
+    const { data } = await $.http.get(path, {
+      params,
+      additionalProperties: {
+        setFirestoreBaseUrl: false,
+      },
+    });
+
+    if (!data) {
+      return;
+    }
+
+    $.pushTriggerItem({
+      raw: data,
+      meta: {
+        internalId: Crypto.randomUUID(),
+      },
+    });
+  },
+});

packages/backend/src/apps/firebase/triggers/new-documents-within-firestore-collection/index.js

@@ -0,0 +1,66 @@
+import defineTrigger from '../../../../helpers/define-trigger.js';
+
+export default defineTrigger({
+  name: 'New documents within a firestore collection',
+  key: 'newDocumentsWithinFirestoreCollection',
+  pollInterval: 15,
+  description:
+    'Triggers when a new document is added within a Cloud Firestore collection.',
+  arguments: [
+    {
+      label: 'Collection',
+      key: 'collectionId',
+      type: 'dropdown',
+      required: true,
+      description: '',
+      variables: true,
+      source: {
+        type: 'query',
+        name: 'getDynamicData',
+        arguments: [
+          {
+            name: 'key',
+            value: 'listFirestoreCollections',
+          },
+        ],
+      },
+    },
+  ],
+
+  async run($) {
+    const projectId = $.auth.data.projectId;
+    const collectionId = $.step.parameters.collectionId;
+    const params = {
+      pageSize: 100,
+      pageToken: undefined,
+    };
+
+    do {
+      const { data } = await $.http.get(
+        `/v1/projects/${projectId}/databases/(default)/documents/${collectionId}`,
+        {
+          params,
+          additionalProperties: {
+            setFirestoreBaseUrl: true,
+          },
+        }
+      );
+      params.pageToken = data.nextPageToken;
+
+      if (!data?.documents?.length) {
+        return;
+      }
+
+      for (const document of data.documents) {
+        const nameParts = document.name.split('/');
+        const id = nameParts[nameParts.length - 1];
+        $.pushTriggerItem({
+          raw: document,
+          meta: {
+            internalId: id,
+          },
+        });
+      }
+    } while (params.pageToken);
+  },
+});

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

@@ -8,7 +8,7 @@ export default defineApp({
   name: 'Flickr',
   key: 'flickr',
   iconUrl: '{BASE_URL}/apps/flickr/assets/favicon.svg',
-  authDocUrl: '{DOCS_URL}/apps/flickr/connection',
+  authDocUrl: 'https://automatisch.io/docs/apps/flickr/connection',
   docUrl: 'https://automatisch.io/docs/flickr',
   primaryColor: '000000',
   supportsConnections: true,

packages/backend/src/apps/flowers-software/index.js

@@ -7,7 +7,7 @@ export default defineApp({
   name: 'Flowers Software',
   key: 'flowers-software',
   iconUrl: '{BASE_URL}/apps/flowers-software/assets/favicon.svg',
-  authDocUrl: '{DOCS_URL}/apps/flowers-software/connection',
+  authDocUrl: 'https://automatisch.io/docs/apps/flowers-software/connection',
   supportsConnections: true,
   baseUrl: 'https://flowers-software.com',
   apiBaseUrl: 'https://webapp.flowers-software.com/api',

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

@@ -6,7 +6,7 @@ export default defineApp({
   name: 'Formatter',
   key: 'formatter',
   iconUrl: '{BASE_URL}/apps/formatter/assets/favicon.svg',
-  authDocUrl: '{DOCS_URL}/apps/formatter/connection',
+  authDocUrl: 'https://automatisch.io/docs/apps/formatter/connection',
   supportsConnections: false,
   baseUrl: '',
   apiBaseUrl: '',

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

@@ -10,7 +10,7 @@ export default defineApp({
   baseUrl: 'https://ghost.org',
   apiBaseUrl: '',
   iconUrl: '{BASE_URL}/apps/ghost/assets/favicon.svg',
-  authDocUrl: '{DOCS_URL}/apps/ghost/connection',
+  authDocUrl: 'https://automatisch.io/docs/apps/ghost/connection',
   primaryColor: '15171A',
   supportsConnections: true,
   beforeRequest: [setBaseUrl, addAuthHeader],

packages/backend/src/apps/gitea/assets/favicon.svg

@@ -1 +0,0 @@
-<svg xmlns="http://www.w3.org/2000/svg" viewBox="0 0 640 640" style="enable-background:new 0 0 640 640" xml:space="preserve" width="32" height="32"><path style="fill:#fff" d="m395.9 484.2-126.9-61c-12.5-6-17.9-21.2-11.8-33.8l61-126.9c6-12.5 21.2-17.9 33.8-11.8 17.2 8.3 27.1 13 27.1 13l-.1-109.2 16.7-.1.1 117.1s57.4 24.2 83.1 40.1c3.7 2.3 10.2 6.8 12.9 14.4 2.1 6.1 2 13.1-1 19.3l-61 126.9c-6.2 12.7-21.4 18.1-33.9 12z"/><path style="fill:#609926" d="M622.7 149.8c-4.1-4.1-9.6-4-9.6-4s-117.2 6.6-177.9 8c-13.3.3-26.5.6-39.6.7v117.2c-5.5-2.6-11.1-5.3-16.6-7.9 0-36.4-.1-109.2-.1-109.2-29 .4-89.2-2.2-89.2-2.2s-141.4-7.1-156.8-8.5c-9.8-.6-22.5-2.1-39 1.5-8.7 1.8-33.5 7.4-53.8 26.9C-4.9 212.4 6.6 276.2 8 285.8c1.7 11.7 6.9 44.2 31.7 72.5 45.8 56.1 144.4 54.8 144.4 54.8s12.1 28.9 30.6 55.5c25 33.1 50.7 58.9 75.7 62 63 0 188.9-.1 188.9-.1s12 .1 28.3-10.3c14-8.5 26.5-23.4 26.5-23.4S547 483 565 451.5c5.5-9.7 10.1-19.1 14.1-28 0 0 55.2-117.1 55.2-231.1-1.1-34.5-9.6-40.6-11.6-42.6zM125.6 353.9c-25.9-8.5-36.9-18.7-36.9-18.7S69.6 321.8 60 295.4c-16.5-44.2-1.4-71.2-1.4-71.2s8.4-22.5 38.5-30c13.8-3.7 31-3.1 31-3.1s7.1 59.4 15.7 94.2c7.2 29.2 24.8 77.7 24.8 77.7s-26.1-3.1-43-9.1zm300.3 107.6s-6.1 14.5-19.6 15.4c-5.8.4-10.3-1.2-10.3-1.2s-.3-.1-5.3-2.1l-112.9-55s-10.9-5.7-12.8-15.6c-2.2-8.1 2.7-18.1 2.7-18.1L322 273s4.8-9.7 12.2-13c.6-.3 2.3-1 4.5-1.5 8.1-2.1 18 2.8 18 2.8L467.4 315s12.6 5.7 15.3 16.2c1.9 7.4-.5 14-1.8 17.2-6.3 15.4-55 113.1-55 113.1z"/><path style="fill:#609926" d="M326.8 380.1c-8.2.1-15.4 5.8-17.3 13.8-1.9 8 2 16.3 9.1 20 7.7 4 17.5 1.8 22.7-5.4 5.1-7.1 4.3-16.9-1.8-23.1l24-49.1c1.5.1 3.7.2 6.2-.5 4.1-.9 7.1-3.6 7.1-3.6 4.2 1.8 8.6 3.8 13.2 6.1 4.8 2.4 9.3 4.9 13.4 7.3.9.5 1.8 1.1 2.8 1.9 1.6 1.3 3.4 3.1 4.7 5.5 1.9 5.5-1.9 14.9-1.9 14.9-2.3 7.6-18.4 40.6-18.4 40.6-8.1-.2-15.3 5-17.7 12.5-2.6 8.1 1.1 17.3 8.9 21.3 7.8 4 17.4 1.7 22.5-5.3 5-6.8 4.6-16.3-1.1-22.6 1.9-3.7 3.7-7.4 5.6-11.3 5-10.4 13.5-30.4 13.5-30.4.9-1.7 5.7-10.3 2.7-21.3-2.5-11.4-12.6-16.7-12.6-16.7-12.2-7.9-29.2-15.2-29.2-15.2s0-4.1-1.1-7.1c-1.1-3.1-2.8-5.1-3.9-6.3 4.7-9.7 9.4-19.3 14.1-29-4.1-2-8.1-4-12.2-6.1-4.8 9.8-9.7 19.7-14.5 29.5-6.7-.1-12.9 3.5-16.1 9.4-3.4 6.3-2.7 14.1 1.9 19.8l-24.6 50.4z"/></svg>

packages/backend/src/apps/gitea/common/get-current-user.js

@@ -1,6 +0,0 @@
-const getCurrentUser = async ($) => {
-  const { data: currentUser } = await $.http.get(`/user`);
-  return currentUser;
-};
-
-export default getCurrentUser;

packages/backend/src/apps/gitea/common/set-base-url.js

@@ -1,14 +0,0 @@
-const setBaseUrl = ($, requestConfig) => {
-  if (requestConfig.additionalProperties?.skipAddingBaseUrl)
-    return requestConfig;
-
-  const instanceUrl = $.auth.data.instanceUrl;
-
-  if (instanceUrl) {
-    requestConfig.baseURL = `${instanceUrl}/api/v1`;
-  }
-
-  return requestConfig;
-};
-
-export default setBaseUrl;

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

@@ -1,4 +0,0 @@
-import listLabels from './list-labels/index.js';
-import listRepos from './list-repos/index.js';
-
-export default [listLabels, listRepos];

packages/backend/src/apps/gitea/dynamic-data/list-labels/index.js

@@ -1,40 +0,0 @@
-export default {
-  name: 'List labels',
-  key: 'listLabels',
-
-  async run($) {
-    const labels = {
-      data: [],
-    };
-    const repoOwner = $.auth.data.repoOwner;
-    const repo = $.step.parameters.repo;
-
-    const params = {
-      page: 1,
-      limit: 100,
-    };
-
-    let totalCount;
-    let totalRequestedCount;
-    do {
-      const { data, headers } = await $.http.get(
-        `/repos/${repoOwner}/${repo}/labels`,
-        { params }
-      );
-      params.page = params.page + 1;
-      totalCount = Number(headers['x-total-count']);
-      totalRequestedCount = params.page * params.limit;
-
-      if (data?.length) {
-        for (const label of data) {
-          labels.data.push({
-            value: label.name,
-            name: label.name,
-          });
-        }
-      }
-    } while (totalRequestedCount <= totalCount);
-
-    return labels;
-  },
-};

packages/backend/src/apps/gitea/dynamic-data/list-repos/index.js

@@ -1,35 +0,0 @@
-export default {
-  name: 'List repos',
-  key: 'listRepos',
-
-  async run($) {
-    const repos = {
-      data: [],
-    };
-
-    const params = {
-      page: 1,
-      limit: 100,
-    };
-
-    let totalCount;
-    let totalRequestedCount;
-    do {
-      const { data, headers } = await $.http.get('/user/repos', { params });
-      params.page = params.page + 1;
-      totalCount = Number(headers['x-total-count']);
-      totalRequestedCount = params.page * params.limit;
-
-      if (data?.length) {
-        for (const repo of data) {
-          repos.data.push({
-            value: repo.name,
-            name: repo.name,
-          });
-        }
-      }
-    } while (totalRequestedCount <= totalCount);
-
-    return repos;
-  },
-};

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

@@ -1,5 +0,0 @@
-import newIssues from './new-issues/index.js';
-import newStargazers from './new-stargazers/index.js';
-import newWatchers from './new-watchers/index.js';
-
-export default [newIssues, newStargazers, newWatchers];

packages/backend/src/apps/gitea/triggers/new-issues/index.js

@@ -1,121 +0,0 @@
-import defineTrigger from '../../../../helpers/define-trigger.js';
-
-export default defineTrigger({
-  name: 'New issues',
-  key: 'newIssues',
-  pollInterval: 15,
-  description: 'Triggers when a new issue is created.',
-  arguments: [
-    {
-      label: 'Repo',
-      key: 'repo',
-      type: 'dropdown',
-      required: true,
-      variables: true,
-      source: {
-        type: 'query',
-        name: 'getDynamicData',
-        arguments: [
-          {
-            name: 'key',
-            value: 'listRepos',
-          },
-        ],
-      },
-    },
-    {
-      label: 'Which types of issues should this trigger on?',
-      key: 'issueType',
-      type: 'dropdown',
-      description: 'Defaults to any issue you can see.',
-      required: true,
-      variables: true,
-      value: 'all',
-      options: [
-        {
-          label: 'Closed',
-          value: 'closed',
-        },
-        {
-          label: 'Open',
-          value: 'open',
-        },
-        {
-          label: 'All',
-          value: 'all',
-        },
-      ],
-    },
-    {
-      label: 'Labels',
-      key: 'labels',
-      type: 'dynamic',
-      required: false,
-      fields: [
-        {
-          label: 'Label',
-          key: 'label',
-          type: 'dropdown',
-          description: 'Only trigger on issues when this label is added.',
-          required: false,
-          variables: true,
-          dependsOn: ['parameters.repo'],
-          source: {
-            type: 'query',
-            name: 'getDynamicData',
-            arguments: [
-              {
-                name: 'key',
-                value: 'listLabels',
-              },
-              {
-                name: 'parameters.repo',
-                value: '{parameters.repo}',
-              },
-            ],
-          },
-        },
-      ],
-    },
-  ],
-
-  async run($) {
-    const repo = $.step.parameters.repo;
-    const issueType = $.step.parameters.issueType;
-    const allLabels = $.step.parameters.labels;
-    const formattedAllLabels = allLabels.map((label) => label.label).join(',');
-    const repoOwner = $.auth.data.repoOwner;
-
-    const params = {
-      page: 1,
-      limit: 100,
-      state: issueType,
-      labels: formattedAllLabels,
-    };
-
-    let totalCount;
-    let totalRequestedCount;
-    do {
-      const { data, headers } = await $.http.get(
-        `/repos/${repoOwner}/${repo}/issues`,
-        {
-          params,
-        }
-      );
-      params.page = params.page + 1;
-      totalCount = Number(headers['x-total-count']);
-      totalRequestedCount = params.page * params.limit;
-
-      if (data?.length) {
-        for (const issue of data) {
-          $.pushTriggerItem({
-            raw: issue,
-            meta: {
-              internalId: issue.id.toString(),
-            },
-          });
-        }
-      }
-    } while (totalRequestedCount <= totalCount);
-  },
-});

packages/backend/src/apps/gitea/triggers/new-stargazers/index.js

@@ -1,61 +0,0 @@
-import defineTrigger from '../../../../helpers/define-trigger.js';
-
-export default defineTrigger({
-  name: 'New stargazers',
-  key: 'newStargazers',
-  pollInterval: 15,
-  description: 'Triggers when a user stars a repository.',
-  arguments: [
-    {
-      label: 'Repo',
-      key: 'repo',
-      type: 'dropdown',
-      required: true,
-      variables: true,
-      source: {
-        type: 'query',
-        name: 'getDynamicData',
-        arguments: [
-          {
-            name: 'key',
-            value: 'listRepos',
-          },
-        ],
-      },
-    },
-  ],
-
-  async run($) {
-    const repo = $.step.parameters.repo;
-    const repoOwner = $.auth.data.repoOwner;
-    const params = {
-      page: 1,
-      limit: 100,
-    };
-
-    let totalCount;
-    let totalRequestedCount;
-    do {
-      const { data, headers } = await $.http.get(
-        `/repos/${repoOwner}/${repo}/stargazers`,
-        {
-          params,
-        }
-      );
-      params.page = params.page + 1;
-      totalCount = Number(headers['x-total-count']);
-      totalRequestedCount = params.page * params.limit;
-
-      if (data?.length) {
-        for (const stargazer of data) {
-          $.pushTriggerItem({
-            raw: stargazer,
-            meta: {
-              internalId: stargazer.id.toString(),
-            },
-          });
-        }
-      }
-    } while (totalRequestedCount <= totalCount);
-  },
-});

packages/backend/src/apps/gitea/triggers/new-watchers/index.js

@@ -1,61 +0,0 @@
-import defineTrigger from '../../../../helpers/define-trigger.js';
-
-export default defineTrigger({
-  name: 'New watchers',
-  key: 'newWatchers',
-  pollInterval: 15,
-  description: 'Triggers when a user watches a repository.',
-  arguments: [
-    {
-      label: 'Repo',
-      key: 'repo',
-      type: 'dropdown',
-      required: true,
-      variables: true,
-      source: {
-        type: 'query',
-        name: 'getDynamicData',
-        arguments: [
-          {
-            name: 'key',
-            value: 'listRepos',
-          },
-        ],
-      },
-    },
-  ],
-
-  async run($) {
-    const repo = $.step.parameters.repo;
-    const repoOwner = $.auth.data.repoOwner;
-    const params = {
-      page: 1,
-      limit: 100,
-    };
-
-    let totalCount;
-    let totalRequestedCount;
-    do {
-      const { data, headers } = await $.http.get(
-        `/repos/${repoOwner}/${repo}/subscribers`,
-        {
-          params,
-        }
-      );
-      params.page = params.page + 1;
-      totalCount = Number(headers['x-total-count']);
-      totalRequestedCount = params.page * params.limit;
-
-      if (data?.length) {
-        for (const subscriber of data) {
-          $.pushTriggerItem({
-            raw: subscriber,
-            meta: {
-              internalId: subscriber.id.toString(),
-            },
-          });
-        }
-      }
-    } while (totalRequestedCount <= totalCount);
-  },
-});

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

@@ -11,7 +11,7 @@ export default defineApp({
   baseUrl: 'https://github.com',
   apiBaseUrl: 'https://api.github.com',
   iconUrl: '{BASE_URL}/apps/github/assets/favicon.svg',
-  authDocUrl: '{DOCS_URL}/apps/github/connection',
+  authDocUrl: 'https://automatisch.io/docs/apps/github/connection',
   primaryColor: '000000',
   supportsConnections: true,
   beforeRequest: [addAuthHeader],

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

@@ -11,7 +11,7 @@ export default defineApp({
   baseUrl: 'https://gitlab.com',
   apiBaseUrl: 'https://gitlab.com',
   iconUrl: '{BASE_URL}/apps/gitlab/assets/favicon.svg',
-  authDocUrl: '{DOCS_URL}/apps/gitlab/connection',
+  authDocUrl: 'https://automatisch.io/docs/apps/gitlab/connection',
   primaryColor: 'FC6D26',
   supportsConnections: true,
   beforeRequest: [setBaseUrl, addAuthHeader],

packages/backend/src/apps/google-calendar/index.js

@@ -10,7 +10,7 @@ export default defineApp({
   baseUrl: 'https://calendar.google.com',
   apiBaseUrl: 'https://www.googleapis.com/calendar',
   iconUrl: '{BASE_URL}/apps/google-calendar/assets/favicon.svg',
-  authDocUrl: '{DOCS_URL}/apps/google-calendar/connection',
+  authDocUrl: 'https://automatisch.io/docs/apps/google-calendar/connection',
   primaryColor: '448AFF',
   supportsConnections: true,
   beforeRequest: [addAuthHeader],

packages/backend/src/apps/google-drive/index.js

@@ -10,7 +10,7 @@ export default defineApp({
   baseUrl: 'https://drive.google.com',
   apiBaseUrl: 'https://www.googleapis.com/drive',
   iconUrl: '{BASE_URL}/apps/google-drive/assets/favicon.svg',
-  authDocUrl: '{DOCS_URL}/apps/google-drive/connection',
+  authDocUrl: 'https://automatisch.io/docs/apps/google-drive/connection',
   primaryColor: '1FA463',
   supportsConnections: true,
   beforeRequest: [addAuthHeader],

packages/backend/src/apps/google-forms/index.js

@@ -10,7 +10,7 @@ export default defineApp({
   baseUrl: 'https://docs.google.com/forms',
   apiBaseUrl: 'https://forms.googleapis.com',
   iconUrl: '{BASE_URL}/apps/google-forms/assets/favicon.svg',
-  authDocUrl: '{DOCS_URL}/apps/google-forms/connection',
+  authDocUrl: 'https://automatisch.io/docs/apps/google-forms/connection',
   primaryColor: '673AB7',
   supportsConnections: true,
   beforeRequest: [addAuthHeader],

packages/backend/src/apps/google-sheets/index.js

@@ -12,7 +12,7 @@ export default defineApp({
   baseUrl: 'https://docs.google.com/spreadsheets',
   apiBaseUrl: 'https://sheets.googleapis.com',
   iconUrl: '{BASE_URL}/apps/google-sheets/assets/favicon.svg',
-  authDocUrl: '{DOCS_URL}/apps/google-sheets/connection',
+  authDocUrl: 'https://automatisch.io/docs/apps/google-sheets/connection',
   primaryColor: '0F9D58',
   supportsConnections: true,
   beforeRequest: [addAuthHeader],

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

@@ -10,7 +10,7 @@ export default defineApp({
   baseUrl: 'https://tryhelix.ai',
   apiBaseUrl: 'https://app.tryhelix.ai',
   iconUrl: '{BASE_URL}/apps/helix/assets/favicon.svg',
-  authDocUrl: '{DOCS_URL}/apps/helix/connection',
+  authDocUrl: 'https://automatisch.io/docs/apps/helix/connection',
   primaryColor: '000000',
   supportsConnections: true,
   beforeRequest: [setBaseUrl, addAuthHeader],

packages/backend/src/apps/http-request/index.js

@@ -5,7 +5,7 @@ export default defineApp({
   name: 'HTTP Request',
   key: 'http-request',
   iconUrl: '{BASE_URL}/apps/http-request/assets/favicon.svg',
-  authDocUrl: '{DOCS_URL}/apps/http-request/connection',
+  authDocUrl: 'https://automatisch.io/docs/apps/http-request/connection',
   supportsConnections: false,
   baseUrl: '',
   apiBaseUrl: '',

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

@@ -7,7 +7,7 @@ export default defineApp({
   name: 'HubSpot',
   key: 'hubspot',
   iconUrl: '{BASE_URL}/apps/hubspot/assets/favicon.svg',
-  authDocUrl: '{DOCS_URL}/apps/hubspot/connection',
+  authDocUrl: 'https://automatisch.io/docs/apps/hubspot/connection',
   supportsConnections: true,
   baseUrl: 'https://www.hubspot.com',
   apiBaseUrl: 'https://api.hubapi.com',

packages/backend/src/apps/invoice-ninja/index.js

@@ -12,7 +12,7 @@ export default defineApp({
   baseUrl: 'https://invoiceninja.com',
   apiBaseUrl: 'https://invoicing.co/api',
   iconUrl: '{BASE_URL}/apps/invoice-ninja/assets/favicon.svg',
-  authDocUrl: '{DOCS_URL}/apps/invoice-ninja/connection',
+  authDocUrl: 'https://automatisch.io/docs/apps/invoice-ninja/connection',
   primaryColor: '000000',
   supportsConnections: true,
   beforeRequest: [setBaseUrl, addAuthHeader],

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

@@ -10,7 +10,7 @@ export default defineApp({
   name: 'Mattermost',
   key: 'mattermost',
   iconUrl: '{BASE_URL}/apps/mattermost/assets/favicon.svg',
-  authDocUrl: '{DOCS_URL}/apps/mattermost/connection',
+  authDocUrl: 'https://automatisch.io/docs/apps/mattermost/connection',
   baseUrl: 'https://mattermost.com',
   apiBaseUrl: '', // there is no cloud version of this app, user always need to provide address of own instance when creating connection
   primaryColor: '4a154b',

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

@@ -10,7 +10,7 @@ export default defineApp({
   baseUrl: 'https://miro.com',
   apiBaseUrl: 'https://api.miro.com',
   iconUrl: '{BASE_URL}/apps/miro/assets/favicon.svg',
-  authDocUrl: '{DOCS_URL}/apps/miro/connection',
+  authDocUrl: 'https://automatisch.io/docs/apps/miro/connection',
   primaryColor: 'F2CA02',
   supportsConnections: true,
   beforeRequest: [addAuthHeader],

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

@@ -12,7 +12,7 @@ export default defineApp({
   baseUrl: 'https://notion.com',
   apiBaseUrl: 'https://api.notion.com',
   iconUrl: '{BASE_URL}/apps/notion/assets/favicon.svg',
-  authDocUrl: '{DOCS_URL}/apps/notion/connection',
+  authDocUrl: 'https://automatisch.io/docs/apps/notion/connection',
   primaryColor: '000000',
   supportsConnections: true,
   beforeRequest: [addAuthHeader, addNotionVersionHeader],

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

@@ -7,7 +7,7 @@ export default defineApp({
   name: 'Ntfy',
   key: 'ntfy',
   iconUrl: '{BASE_URL}/apps/ntfy/assets/favicon.svg',
-  authDocUrl: '{DOCS_URL}/apps/ntfy/connection',
+  authDocUrl: 'https://automatisch.io/docs/apps/ntfy/connection',
   supportsConnections: true,
   baseUrl: 'https://ntfy.sh',
   apiBaseUrl: 'https://ntfy.sh',

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

@@ -6,7 +6,7 @@ export default defineApp({
   name: 'Odoo',
   key: 'odoo',
   iconUrl: '{BASE_URL}/apps/odoo/assets/favicon.svg',
-  authDocUrl: '{DOCS_URL}/apps/odoo/connection',
+  authDocUrl: 'https://automatisch.io/docs/apps/odoo/connection',
   supportsConnections: true,
   baseUrl: 'https://odoo.com',
   apiBaseUrl: '',

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

@@ -10,7 +10,7 @@ export default defineApp({
   baseUrl: 'https://openai.com',
   apiBaseUrl: 'https://api.openai.com',
   iconUrl: '{BASE_URL}/apps/openai/assets/favicon.svg',
-  authDocUrl: '{DOCS_URL}/apps/openai/connection',
+  authDocUrl: 'https://automatisch.io/docs/apps/openai/connection',
   primaryColor: '000000',
   supportsConnections: true,
   beforeRequest: [addAuthHeader],

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

@@ -12,7 +12,7 @@ export default defineApp({
   baseUrl: '',
   apiBaseUrl: '',
   iconUrl: '{BASE_URL}/apps/pipedrive/assets/favicon.svg',
-  authDocUrl: '{DOCS_URL}/apps/pipedrive/connection',
+  authDocUrl: 'https://automatisch.io/docs/apps/pipedrive/connection',
   primaryColor: 'FFFFFF',
   supportsConnections: true,
   beforeRequest: [setBaseUrl, addAuthHeader],

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

@@ -8,7 +8,7 @@ export default defineApp({
   name: 'Placetel',
   key: 'placetel',
   iconUrl: '{BASE_URL}/apps/placetel/assets/favicon.svg',
-  authDocUrl: '{DOCS_URL}/apps/placetel/connection',
+  authDocUrl: 'https://automatisch.io/docs/apps/placetel/connection',
   supportsConnections: true,
   baseUrl: 'https://placetel.de',
   apiBaseUrl: 'https://api.placetel.de',

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

@@ -6,7 +6,7 @@ export default defineApp({
   name: 'PostgreSQL',
   key: 'postgresql',
   iconUrl: '{BASE_URL}/apps/postgresql/assets/favicon.svg',
-  authDocUrl: '{DOCS_URL}/apps/postgresql/connection',
+  authDocUrl: 'https://automatisch.io/docs/apps/postgresql/connection',
   supportsConnections: true,
   baseUrl: '',
   apiBaseUrl: '',

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

@@ -9,7 +9,7 @@ export default defineApp({
   baseUrl: 'https://pushover.net',
   apiBaseUrl: 'https://api.pushover.net',
   iconUrl: '{BASE_URL}/apps/pushover/assets/favicon.svg',
-  authDocUrl: '{DOCS_URL}/apps/pushover/connection',
+  authDocUrl: 'https://automatisch.io/docs/apps/pushover/connection',
   primaryColor: '249DF1',
   supportsConnections: true,
   auth,

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

@@ -10,7 +10,7 @@ export default defineApp({
   baseUrl: 'https://www.reddit.com',
   apiBaseUrl: 'https://oauth.reddit.com',
   iconUrl: '{BASE_URL}/apps/reddit/assets/favicon.svg',
-  authDocUrl: '{DOCS_URL}/apps/reddit/connection',
+  authDocUrl: 'https://automatisch.io/docs/apps/reddit/connection',
   primaryColor: 'FF4500',
   supportsConnections: true,
   beforeRequest: [addAuthHeader],

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

@@ -7,7 +7,7 @@ export default defineApp({
   name: 'Remove.bg',
   key: 'removebg',
   iconUrl: '{BASE_URL}/apps/removebg/assets/favicon.svg',
-  authDocUrl: '{DOCS_URL}/apps/removebg/connection',
+  authDocUrl: 'https://automatisch.io/docs/apps/removebg/connection',
   supportsConnections: true,
   baseUrl: 'https://www.remove.bg',
   apiBaseUrl: 'https://api.remove.bg/v1.0',

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

@@ -5,7 +5,7 @@ export default defineApp({
   name: 'RSS',
   key: 'rss',
   iconUrl: '{BASE_URL}/apps/rss/assets/favicon.svg',
-  authDocUrl: '{DOCS_URL}/apps/rss/connection',
+  authDocUrl: 'https://automatisch.io/docs/apps/rss/connection',
   supportsConnections: false,
   baseUrl: '',
   apiBaseUrl: '',

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

@@ -9,7 +9,7 @@ export default defineApp({
   name: 'Salesforce',
   key: 'salesforce',
   iconUrl: '{BASE_URL}/apps/salesforce/assets/favicon.svg',
-  authDocUrl: '{DOCS_URL}/connections/salesforce',
+  authDocUrl: 'https://automatisch.io/docs/connections/salesforce',
   supportsConnections: true,
   baseUrl: 'https://salesforce.com',
   apiBaseUrl: '',

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

@@ -6,7 +6,7 @@ export default defineApp({
   key: 'scheduler',
   iconUrl: '{BASE_URL}/apps/scheduler/assets/favicon.svg',
   docUrl: 'https://automatisch.io/docs/scheduler',
-  authDocUrl: '{DOCS_URL}/apps/scheduler/connection',
+  authDocUrl: 'https://automatisch.io/docs/apps/scheduler/connection',
   baseUrl: '',
   apiBaseUrl: '',
   primaryColor: '0059F7',

packages/backend/src/apps/self-hosted-llm/index.js

@@ -11,7 +11,7 @@ export default defineApp({
   baseUrl: '',
   apiBaseUrl: '',
   iconUrl: '{BASE_URL}/apps/self-hosted-llm/assets/favicon.svg',
-  authDocUrl: '{DOCS_URL}/apps/self-hosted-llm/connection',
+  authDocUrl: 'https://automatisch.io/docs/apps/self-hosted-llm/connection',
   primaryColor: '000000',
   supportsConnections: true,
   beforeRequest: [setBaseUrl, addAuthHeader],

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

@@ -9,7 +9,7 @@ export default defineApp({
   name: 'SignalWire',
   key: 'signalwire',
   iconUrl: '{BASE_URL}/apps/signalwire/assets/favicon.svg',
-  authDocUrl: '{DOCS_URL}/apps/signalwire/connection',
+  authDocUrl: 'https://automatisch.io/docs/apps/signalwire/connection',
   supportsConnections: true,
   baseUrl: 'https://signalwire.com',
   apiBaseUrl: '',

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

@@ -9,7 +9,7 @@ export default defineApp({
   name: 'Slack',
   key: 'slack',
   iconUrl: '{BASE_URL}/apps/slack/assets/favicon.svg',
-  authDocUrl: '{DOCS_URL}/apps/slack/connection',
+  authDocUrl: 'https://automatisch.io/docs/apps/slack/connection',
   supportsConnections: true,
   baseUrl: 'https://slack.com',
   apiBaseUrl: 'https://slack.com/api',

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

@@ -6,7 +6,7 @@ export default defineApp({
   name: 'SMTP',
   key: 'smtp',
   iconUrl: '{BASE_URL}/apps/smtp/assets/favicon.svg',
-  authDocUrl: '{DOCS_URL}/apps/smtp/connection',
+  authDocUrl: 'https://automatisch.io/docs/apps/smtp/connection',
   supportsConnections: true,
   baseUrl: '',
   apiBaseUrl: '',

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

@@ -7,7 +7,7 @@ export default defineApp({
   name: 'Spotify',
   key: 'spotify',
   iconUrl: '{BASE_URL}/apps/spotify/assets/favicon.svg',
-  authDocUrl: '{DOCS_URL}/apps/spotify/connection',
+  authDocUrl: 'https://automatisch.io/docs/apps/spotify/connection',
   supportsConnections: true,
   baseUrl: 'https://spotify.com',
   apiBaseUrl: 'https://api.spotify.com',

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

@@ -7,7 +7,7 @@ export default defineApp({
   name: 'Strava',
   key: 'strava',
   iconUrl: '{BASE_URL}/apps/strava/assets/favicon.svg',
-  authDocUrl: '{DOCS_URL}/connections/strava',
+  authDocUrl: 'https://automatisch.io/docs/connections/strava',
   supportsConnections: true,
   baseUrl: 'https://www.strava.com',
   apiBaseUrl: 'https://www.strava.com/api',

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

@@ -7,7 +7,7 @@ export default defineApp({
   name: 'Stripe',
   key: 'stripe',
   iconUrl: '{BASE_URL}/apps/stripe/assets/favicon.svg',
-  authDocUrl: '{DOCS_URL}/apps/stripe/connection',
+  authDocUrl: 'https://automatisch.io/docs/apps/stripe/connection',
   supportsConnections: true,
   baseUrl: 'https://stripe.com',
   apiBaseUrl: 'https://api.stripe.com',

packages/backend/src/apps/telegram-bot/index.js

@@ -7,7 +7,7 @@ export default defineApp({
   name: 'Telegram',
   key: 'telegram-bot',
   iconUrl: '{BASE_URL}/apps/telegram-bot/assets/favicon.svg',
-  authDocUrl: '{DOCS_URL}/apps/telegram-bot/connection',
+  authDocUrl: 'https://automatisch.io/docs/apps/telegram-bot/connection',
   supportsConnections: true,
   baseUrl: 'https://telegram.org',
   apiBaseUrl: 'https://api.telegram.org',

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

@@ -9,7 +9,7 @@ export default defineApp({
   name: 'Todoist',
   key: 'todoist',
   iconUrl: '{BASE_URL}/apps/todoist/assets/favicon.svg',
-  authDocUrl: '{DOCS_URL}/apps/todoist/connection',
+  authDocUrl: 'https://automatisch.io/docs/apps/todoist/connection',
   supportsConnections: true,
   baseUrl: 'https://todoist.com',
   apiBaseUrl: 'https://api.todoist.com/rest/v2',

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

@@ -10,7 +10,7 @@ export default defineApp({
   baseUrl: 'https://trello.com/',
   apiBaseUrl: 'https://api.trello.com',
   iconUrl: '{BASE_URL}/apps/trello/assets/favicon.svg',
-  authDocUrl: '{DOCS_URL}/apps/trello/connection',
+  authDocUrl: 'https://automatisch.io/docs/apps/trello/connection',
   supportsConnections: true,
   primaryColor: '0079bf',
   beforeRequest: [addAuthHeader],

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

@@ -9,7 +9,7 @@ export default defineApp({
   name: 'Twilio',
   key: 'twilio',
   iconUrl: '{BASE_URL}/apps/twilio/assets/favicon.svg',
-  authDocUrl: '{DOCS_URL}/apps/twilio/connection',
+  authDocUrl: 'https://automatisch.io/docs/apps/twilio/connection',
   supportsConnections: true,
   baseUrl: 'https://twilio.com',
   apiBaseUrl: 'https://api.twilio.com',

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

@@ -8,7 +8,7 @@ export default defineApp({
   name: 'Twitter',
   key: 'twitter',
   iconUrl: '{BASE_URL}/apps/twitter/assets/favicon.svg',
-  authDocUrl: '{DOCS_URL}/apps/twitter/connection',
+  authDocUrl: 'https://automatisch.io/docs/apps/twitter/connection',
   supportsConnections: true,
   baseUrl: 'https://twitter.com',
   apiBaseUrl: 'https://api.twitter.com',

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

@@ -8,7 +8,7 @@ export default defineApp({
   name: 'Typeform',
   key: 'typeform',
   iconUrl: '{BASE_URL}/apps/typeform/assets/favicon.svg',
-  authDocUrl: '{DOCS_URL}/apps/typeform/connection',
+  authDocUrl: 'https://automatisch.io/docs/apps/typeform/connection',
   supportsConnections: true,
   baseUrl: 'https://typeform.com',
   apiBaseUrl: 'https://api.typeform.com',

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

@@ -6,7 +6,7 @@ export default defineApp({
   name: 'Webhook',
   key: 'webhook',
   iconUrl: '{BASE_URL}/apps/webhook/assets/favicon.svg',
-  authDocUrl: '{DOCS_URL}/apps/webhook/connection',
+  authDocUrl: 'https://automatisch.io/docs/apps/webhook/connection',
   supportsConnections: false,
   baseUrl: '',
   apiBaseUrl: '',

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

@@ -9,7 +9,7 @@ export default defineApp({
   name: 'WordPress',
   key: 'wordpress',
   iconUrl: '{BASE_URL}/apps/wordpress/assets/favicon.svg',
-  authDocUrl: '{DOCS_URL}/apps/wordpress/connection',
+  authDocUrl: 'https://automatisch.io/docs/apps/wordpress/connection',
   supportsConnections: true,
   baseUrl: 'https://wordpress.com',
   apiBaseUrl: '',

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

@@ -10,7 +10,7 @@ export default defineApp({
   baseUrl: 'https://go.xero.com',
   apiBaseUrl: 'https://api.xero.com',
   iconUrl: '{BASE_URL}/apps/xero/assets/favicon.svg',
-  authDocUrl: '{DOCS_URL}/apps/xero/connection',
+  authDocUrl: 'https://automatisch.io/docs/apps/xero/connection',
   primaryColor: '13B5EA',
   supportsConnections: true,
   beforeRequest: [addAuthHeader],

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

@@ -9,7 +9,7 @@ export default defineApp({
   baseUrl: 'https://www.youtube.com/',
   apiBaseUrl: 'https://www.googleapis.com/youtube',
   iconUrl: '{BASE_URL}/apps/youtube/assets/favicon.svg',
-  authDocUrl: '{DOCS_URL}/apps/youtube/connection',
+  authDocUrl: 'https://automatisch.io/docs/apps/youtube/connection',
   primaryColor: 'FF0000',
   supportsConnections: true,
   beforeRequest: [addAuthHeader],

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

@@ -11,7 +11,7 @@ export default defineApp({
   baseUrl: 'https://zendesk.com/',
   apiBaseUrl: '',
   iconUrl: '{BASE_URL}/apps/zendesk/assets/favicon.svg',
-  authDocUrl: '{DOCS_URL}/apps/zendesk/connection',
+  authDocUrl: 'https://automatisch.io/docs/apps/zendesk/connection',
   primaryColor: '17494d',
   supportsConnections: true,
   beforeRequest: [addAuthHeader],

packages/backend/src/config/app.js

@@ -38,9 +38,6 @@ if (process.env.WEB_APP_URL) {
 let webhookUrl = new URL(process.env.WEBHOOK_URL || apiUrl).toString();
 webhookUrl = webhookUrl.substring(0, webhookUrl.length - 1);
 
-const publicDocsUrl = 'https://automatisch.io/docs';
-const docsUrl = process.env.DOCS_URL || publicDocsUrl;
-
 const appEnv = process.env.APP_ENV || 'development';
 
 const appConfig = {
@@ -76,7 +73,6 @@ const appConfig = {
   baseUrl: apiUrl,
   webAppUrl,
   webhookUrl,
-  docsUrl,
   telemetryEnabled: process.env.TELEMETRY_ENABLED === 'false' ? false : true,
   requestBodySizeLimit: '1mb',
   smtpHost: process.env.SMTP_HOST,

packages/backend/src/config/cors-options.js

@@ -2,7 +2,7 @@ import appConfig from './app.js';
 
 const corsOptions = {
   origin: appConfig.webAppUrl,
-  methods: 'GET,HEAD,POST,DELETE',
+  methods: 'POST',
   credentials: true,
   optionsSuccessStatus: 200,
 };

packages/backend/src/controllers/api/v1/access-tokens/revoke-access-token.js

@@ -1,15 +0,0 @@
-export default async (request, response) => {
-  const token = request.params.token;
-
-  const accessToken = await request.currentUser
-    .$relatedQuery('accessTokens')
-    .findOne({
-      token,
-      revoked_at: null,
-    })
-    .throwIfNotFound();
-
-  await accessToken.revoke();
-
-  response.status(204).send();
-};

packages/backend/src/controllers/api/v1/access-tokens/revoke-access-token.test.js

@@ -1,54 +0,0 @@
-import { expect, describe, it, beforeEach } from 'vitest';
-import request from 'supertest';
-import app from '../../../../app.js';
-import createAuthTokenByUserId from '../../../../helpers/create-auth-token-by-user-id';
-import { createUser } from '../../../../../test/factories/user.js';
-import AccessToken from '../../../../models/access-token.js';
-
-describe('DELETE /api/v1/access-tokens/:token', () => {
-  let token;
-
-  beforeEach(async () => {
-    const currentUser = await createUser({
-      email: 'user@automatisch.io',
-      password: 'password',
-    });
-    token = await createAuthTokenByUserId(currentUser.id);
-  });
-
-  it('should respond with HTTP 204 with correct token', async () => {
-    await request(app)
-      .delete(`/api/v1/access-tokens/${token}`)
-      .set('Authorization', token)
-      .expect(204);
-
-    const revokedToken = await AccessToken.query().findOne({ token });
-
-    expect(revokedToken).toBeDefined();
-    expect(revokedToken.revokedAt).not.toBeNull();
-  });
-
-  it('should respond with HTTP 401 with incorrect credentials', async () => {
-    await request(app)
-      .delete(`/api/v1/access-tokens/${token}`)
-      .set('Authorization', 'wrong-token')
-      .expect(401);
-
-    const unrevokedToken = await AccessToken.query().findOne({ token });
-
-    expect(unrevokedToken).toBeDefined();
-    expect(unrevokedToken.revokedAt).toBeNull();
-  });
-
-  it('should respond with HTTP 404 with correct credentials, but non-valid token', async () => {
-    await request(app)
-      .delete('/api/v1/access-tokens/wrong-token')
-      .set('Authorization', token)
-      .expect(404);
-
-    const unrevokedToken = await AccessToken.query().findOne({ token });
-
-    expect(unrevokedToken).toBeDefined();
-    expect(unrevokedToken.revokedAt).toBeNull();
-  });
-});

packages/backend/src/controllers/api/v1/admin/apps/get-auth-client.ee.test.js

@@ -22,7 +22,7 @@ describe('GET /api/v1/admin/apps/:appKey/auth-clients/:appAuthClientId', () => {
       appKey: 'deepl',
     });
 
-    token = await createAuthTokenByUserId(currentUser.id);
+    token = createAuthTokenByUserId(currentUser.id);
   });
 
   it('should return specified app auth client', async () => {

packages/backend/src/controllers/api/v1/admin/apps/get-auth-clients.ee.test.js

@@ -17,7 +17,7 @@ describe('GET /api/v1/admin/apps/:appKey/auth-clients', () => {
     adminRole = await createRole({ key: 'admin' });
     currentUser = await createUser({ roleId: adminRole.id });
 
-    token = await createAuthTokenByUserId(currentUser.id);
+    token = createAuthTokenByUserId(currentUser.id);
   });
 
   it('should return specified app auth client info', async () => {

packages/backend/src/controllers/api/v1/admin/permissions/get-permissions-catalog.ee.test.js

@@ -14,7 +14,7 @@ describe('GET /api/v1/admin/permissions/catalog', () => {
     role = await createRole({ key: 'admin' });
     currentUser = await createUser({ roleId: role.id });
 
-    token = await createAuthTokenByUserId(currentUser.id);
+    token = createAuthTokenByUserId(currentUser.id);
   });
 
   it('should return roles', async () => {

packages/backend/src/controllers/api/v1/admin/roles/get-role.ee.test.js

@@ -18,7 +18,7 @@ describe('GET /api/v1/admin/roles/:roleId', () => {
     permissionTwo = await createPermission({ roleId: role.id });
     currentUser = await createUser({ roleId: role.id });
 
-    token = await createAuthTokenByUserId(currentUser.id);
+    token = createAuthTokenByUserId(currentUser.id);
   });
 
   it('should return role', async () => {

packages/backend/src/controllers/api/v1/admin/roles/get-roles.ee.test.js

@@ -15,7 +15,7 @@ describe('GET /api/v1/admin/roles', () => {
     roleTwo = await createRole({ key: 'user' });
     currentUser = await createUser({ roleId: roleOne.id });
 
-    token = await createAuthTokenByUserId(currentUser.id);
+    token = createAuthTokenByUserId(currentUser.id);
   });
 
   it('should return roles', async () => {

packages/backend/src/controllers/api/v1/admin/saml-auth-providers/get-role-mappings.ee.test.js

@@ -28,7 +28,7 @@ describe('GET /api/v1/admin/saml-auth-providers/:samlAuthProviderId/role-mapping
       remoteRoleName: 'User',
     });
 
-    token = await createAuthTokenByUserId(currentUser.id);
+    token = createAuthTokenByUserId(currentUser.id);
   });
 
   it('should return role mappings', async () => {

packages/backend/src/controllers/api/v1/admin/saml-auth-providers/get-saml-auth-provider.ee.test.js

@@ -17,7 +17,7 @@ describe('GET /api/v1/admin/saml-auth-provider/:samlAuthProviderId', () => {
     currentUser = await createUser({ roleId: role.id });
     samlAuthProvider = await createSamlAuthProvider();
 
-    token = await createAuthTokenByUserId(currentUser.id);
+    token = createAuthTokenByUserId(currentUser.id);
   });
 
   it('should return saml auth provider with specified id', async () => {