feat(gmail): add send to trash action

.devcontainer/docker-compose.yml

@@ -36,6 +36,7 @@ services:
   keycloak:
     image: quay.io/keycloak/keycloak:21.1
     restart: always
+    container_name: keycloak
     environment:
       - KEYCLOAK_ADMIN=admin
       - KEYCLOAK_ADMIN_PASSWORD=admin

.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/Dockerfile.cloud

@@ -0,0 +1,24 @@
+# syntax=docker/dockerfile:1
+FROM node:18-alpine
+
+ENV PORT 3000
+
+RUN \
+  apk --no-cache add --virtual build-dependencies python3 build-base git
+
+RUN git clone https://github.com/automatisch/automatisch.git
+
+WORKDIR /automatisch
+
+RUN yarn install
+
+RUN if [ "$WORKER" != "true" ]; then cd packages/web && yarn build; fi
+
+RUN \
+  rm -rf /usr/local/share/.cache/ && \
+  apk del build-dependencies
+
+COPY ./docker/entrypoint-cloud.sh /entrypoint-cloud.sh
+
+EXPOSE 3000
+ENTRYPOINT ["sh", "/entrypoint-cloud.sh"]

docker/Dockerfile.compose

@@ -1,5 +1,5 @@
 # syntax=docker/dockerfile:1
-FROM automatischio/automatisch:latest
+FROM automatischio/automatisch:0.10.0
 WORKDIR /automatisch
 
 RUN apk add --no-cache openssl dos2unix

docker/entrypoint-cloud.sh

@@ -0,0 +1,13 @@
+#!/bin/sh
+
+set -e
+
+cd packages/backend
+
+if [ -n "$WORKER" ]; then
+  yarn start:worker
+else
+  yarn db:migrate
+  yarn db:seed:user
+  yarn start
+fi

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/bin/database/utils.js

@@ -2,7 +2,6 @@ import appConfig from '../../src/config/app.js';
 import logger from '../../src/helpers/logger.js';
 import client from './client.js';
 import User from '../../src/models/user.js';
-import Config from '../../src/models/config.js';
 import Role from '../../src/models/role.js';
 import '../../src/config/orm.js';
 import process from 'process';
@@ -22,14 +21,6 @@ export async function createUser(
   email = 'user@automatisch.io',
   password = 'sample'
 ) {
-  if (appConfig.disableSeedUser) {
-    logger.info('Seed user is disabled.');
-
-    process.exit(0);
-
-    return;
-  }
-
   const UNIQUE_VIOLATION_CODE = '23505';
 
   const role = await fetchAdminRole();
@@ -46,8 +37,6 @@ export async function createUser(
     if (userCount === 0) {
       const user = await User.query().insertAndFetch(userParams);
       logger.info(`User has been saved: ${user.email}`);
-
-      await Config.markInstallationCompleted();
     } else {
       logger.info('No need to seed a user.');
     }

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",
@@ -67,7 +67,6 @@
     "pluralize": "^8.0.0",
     "raw-body": "^2.5.2",
     "showdown": "^2.1.0",
-    "uuid": "^9.0.1",
     "winston": "^3.7.1",
     "xmlrpc": "^1.3.2"
   },
@@ -96,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/changedetection/actions/create-watch/index.js

@@ -1,29 +0,0 @@
-import defineAction from '../../../../helpers/define-action.js';
-
-export default defineAction({
-  name: 'Create a watch',
-  key: 'createWatch',
-  description: 'Creates a new change detection watch for a specific website.',
-  arguments: [
-    {
-      label: 'URL',
-      key: 'url',
-      type: 'string',
-      required: true,
-      variables: true,
-      description: 'Url you want to monitor',
-    },
-  ],
-
-  async run($) {
-    const url = $.step.parameters.url;
-
-    const body = {
-      url,
-    };
-
-    const response = await $.http.post('/v1/watch', body);
-
-    $.setActionItem({ raw: response.data });
-  },
-});

packages/backend/src/apps/changedetection/actions/delete-watch/index.js

@@ -1,29 +0,0 @@
-import defineAction from '../../../../helpers/define-action.js';
-
-export default defineAction({
-  name: 'Delete a watch',
-  key: 'deleteWatch',
-  description: 'Deletes a change detection watch.',
-  arguments: [
-    {
-      label: 'Watch ID',
-      key: 'watchId',
-      type: 'string',
-      required: true,
-      variables: true,
-      description: 'Watch id you want to delete',
-    },
-  ],
-
-  async run($) {
-    const watchId = $.step.parameters.watchId;
-
-    await $.http.delete(`/v1/watch/${watchId}`);
-
-    $.setActionItem({
-      raw: {
-        result: 'successful',
-      },
-    });
-  },
-});

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

@@ -1,4 +0,0 @@
-import createWatch from './create-watch/index.js';
-import deleteWatch from './delete-watch/index.js';
-
-export default [createWatch, deleteWatch];

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

@@ -1,44 +0,0 @@
-import verifyCredentials from './verify-credentials.js';
-import isStillVerified from './is-still-verified.js';
-
-export default {
-  fields: [
-    {
-      key: 'screenName',
-      label: 'Screen Name',
-      type: 'string',
-      required: true,
-      readOnly: false,
-      value: null,
-      placeholder: null,
-      description:
-        'Screen name of your connection to be used on Automatisch UI.',
-      clickToCopy: false,
-    },
-    {
-      key: 'instanceUrl',
-      label: 'Instance URL',
-      type: 'string',
-      required: true,
-      readOnly: false,
-      value: null,
-      placeholder: null,
-      description: null,
-      clickToCopy: false,
-    },
-    {
-      key: 'apiKey',
-      label: 'API Key',
-      type: 'string',
-      required: true,
-      readOnly: false,
-      value: null,
-      placeholder: null,
-      description: 'Changedetection API key of your account.',
-      clickToCopy: false,
-    },
-  ],
-
-  verifyCredentials,
-  isStillVerified,
-};

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

@@ -1,8 +0,0 @@
-import verifyCredentials from './verify-credentials.js';
-
-const isStillVerified = async ($) => {
-  await verifyCredentials($);
-  return true;
-};
-
-export default isStillVerified;

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

@@ -1,10 +0,0 @@
-const verifyCredentials = async ($) => {
-  await $.http.get('/v1/systeminfo');
-
-  await $.auth.set({
-    screenName: $.auth.data.screenName,
-    apiKey: $.auth.data.apiKey,
-  });
-};
-
-export default verifyCredentials;

packages/backend/src/apps/changedetection/common/add-auth-header.js

@@ -1,9 +0,0 @@
-const addAuthHeader = ($, requestConfig) => {
-  if ($.auth.data?.apiKey) {
-    requestConfig.headers['x-api-key'] = $.auth.data.apiKey;
-  }
-
-  return requestConfig;
-};
-
-export default addAuthHeader;

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

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

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

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

packages/backend/src/apps/changedetection/dynamic-data/list-watches/index.js

@@ -1,24 +0,0 @@
-export default {
-  name: 'List watches',
-  key: 'listWatches',
-
-  async run($) {
-    const watches = {
-      data: [],
-    };
-
-    const { data } = await $.http.get('/v1/watch');
-    const watchIds = Object.keys(data);
-
-    if (watchIds?.length) {
-      for (const watchId of watchIds) {
-        watches.data.push({
-          value: watchId,
-          name: data[watchId].url,
-        });
-      }
-    }
-
-    return watches;
-  },
-};

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

@@ -1,23 +0,0 @@
-import defineApp from '../../helpers/define-app.js';
-import addAuthHeader from './common/add-auth-header.js';
-import auth from './auth/index.js';
-import setBaseUrl from './common/set-base-url.js';
-import actions from './actions/index.js';
-import dynamicData from './dynamic-data/index.js';
-import triggers from './triggers/index.js';
-
-export default defineApp({
-  name: 'Changedetection',
-  key: 'changedetection',
-  iconUrl: '{BASE_URL}/apps/changedetection/assets/favicon.svg',
-  authDocUrl: '{DOCS_URL}/apps/changedetection/connection',
-  supportsConnections: true,
-  baseUrl: 'https://changedetection.io',
-  apiBaseUrl: '',
-  primaryColor: '3056d3',
-  beforeRequest: [setBaseUrl, addAuthHeader],
-  auth,
-  actions,
-  dynamicData,
-  triggers,
-});

packages/backend/src/apps/changedetection/triggers/changed-watch/index.js

@@ -1,43 +0,0 @@
-import defineTrigger from '../../../../helpers/define-trigger.js';
-
-export default defineTrigger({
-  name: 'Changed watch',
-  key: 'changedWatch',
-  pollInterval: 15,
-  description: 'Triggers when any changes detected.',
-  arguments: [
-    {
-      label: 'Watch',
-      key: 'watchId',
-      type: 'dropdown',
-      required: true,
-      description: '',
-      variables: true,
-      source: {
-        type: 'query',
-        name: 'getDynamicData',
-        arguments: [
-          {
-            name: 'key',
-            value: 'listWatches',
-          },
-        ],
-      },
-    },
-  ],
-
-  async run($) {
-    const watchId = $.step.parameters.watchId;
-
-    const { data } = await $.http.get(`v1/watch/${watchId}`);
-
-    if (Object.keys(data).length !== 0) {
-      $.pushTriggerItem({
-        raw: data,
-        meta: {
-          internalId: `${watchId}-${data.last_changed}`,
-        },
-      });
-    }
-  },
-});

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

@@ -1,3 +0,0 @@
-import changedWatch from './changed-watch/index.js';
-
-export default [changedWatch];

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/disqus/assets/favicon.svg

@@ -1,16 +0,0 @@
-<?xml version="1.0" encoding="utf-8"?>
-<!-- Generator: Adobe Illustrator 16.0.0, SVG Export Plug-In . SVG Version: 6.00 Build 0)  -->
-<!DOCTYPE svg PUBLIC "-//W3C//DTD SVG 1.1//EN" "http://www.w3.org/Graphics/SVG/1.1/DTD/svg11.dtd">
-<svg version="1.1" id="Layer_1" xmlns="http://www.w3.org/2000/svg" xmlns:xlink="http://www.w3.org/1999/xlink" x="0px" y="0px"
-	 width="200px" height="200px" viewBox="0 0 200 200" enable-background="new 0 0 200 200" xml:space="preserve">
-<g id="background">
-	<rect fill="#2E9FFF" width="200" height="200"/>
-</g>
-<g id="Layer_2">
-</g>
-<path fill="#FFFFFF" d="M102.535,167.5c-16.518,0-31.621-6.036-43.298-16.021L30.5,155.405l11.102-27.401
-	c-3.868-8.535-6.038-18.01-6.038-28.004c0-37.277,29.984-67.5,66.971-67.5c36.984,0,66.965,30.223,66.965,67.5
-	C169.5,137.284,139.52,167.5,102.535,167.5z M139.102,99.807v-0.188c0-19.479-13.736-33.367-37.42-33.367h-25.58v67.5h25.201
-	C125.171,133.753,139.102,119.284,139.102,99.807L139.102,99.807z M101.964,117.168h-7.482V82.841h7.482
-	c10.989,0,18.283,6.265,18.283,17.07v0.188C120.247,110.995,112.953,117.168,101.964,117.168z"/>
-</svg>

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

@@ -1,21 +0,0 @@
-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 searchParams = new URLSearchParams({
-    client_id: $.auth.data.apiKey,
-    scope: authScope.join(','),
-    response_type: 'code',
-    redirect_uri: redirectUri,
-  });
-
-  const url = `https://disqus.com/api/oauth/2.0/authorize/?${searchParams.toString()}`;
-
-  await $.auth.set({
-    url,
-  });
-}

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

@@ -1,48 +0,0 @@
-import generateAuthUrl from './generate-auth-url.js';
-import verifyCredentials from './verify-credentials.js';
-import refreshToken from './refresh-token.js';
-import isStillVerified from './is-still-verified.js';
-
-export default {
-  fields: [
-    {
-      key: 'oAuthRedirectUrl',
-      label: 'OAuth Redirect URL',
-      type: 'string',
-      required: true,
-      readOnly: true,
-      value: '{WEB_APP_URL}/app/disqus/connections/add',
-      placeholder: null,
-      description:
-        'When asked to input a redirect URL in Disqus, enter the URL above.',
-      clickToCopy: true,
-    },
-    {
-      key: 'apiKey',
-      label: 'API Key',
-      type: 'string',
-      required: true,
-      readOnly: false,
-      value: null,
-      placeholder: null,
-      description: null,
-      clickToCopy: false,
-    },
-    {
-      key: 'apiSecret',
-      label: 'API Secret',
-      type: 'string',
-      required: true,
-      readOnly: false,
-      value: null,
-      placeholder: null,
-      description: null,
-      clickToCopy: false,
-    },
-  ],
-
-  generateAuthUrl,
-  verifyCredentials,
-  isStillVerified,
-  refreshToken,
-};

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

@@ -1,8 +0,0 @@
-import getCurrentUser from '../common/get-current-user.js';
-
-const isStillVerified = async ($) => {
-  const currentUser = await getCurrentUser($);
-  return !!currentUser.response.username;
-};
-
-export default isStillVerified;

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

@@ -1,26 +0,0 @@
-import { URLSearchParams } from 'node:url';
-import authScope from '../common/auth-scope.js';
-
-const refreshToken = async ($) => {
-  const params = new URLSearchParams({
-    grant_type: 'refresh_token',
-    client_id: $.auth.data.apiKey,
-    client_secret: $.auth.data.apiSecret,
-    refresh_token: $.auth.data.refreshToken,
-  });
-
-  const { data } = await $.http.post(
-    `https://disqus.com/api/oauth/2.0/access_token/`,
-    params.toString()
-  );
-
-  await $.auth.set({
-    accessToken: data.access_token,
-    refreshToken: data.refresh_token,
-    expiresIn: data.expires_in,
-    scope: authScope.join(','),
-    tokenType: data.token_type,
-  });
-};
-
-export default refreshToken;

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

@@ -1,34 +0,0 @@
-import { URLSearchParams } from 'url';
-
-const verifyCredentials = async ($) => {
-  const oauthRedirectUrlField = $.app.auth.fields.find(
-    (field) => field.key == 'oAuthRedirectUrl'
-  );
-  const redirectUri = oauthRedirectUrlField.value;
-  const params = new URLSearchParams({
-    grant_type: 'authorization_code',
-    client_id: $.auth.data.apiKey,
-    client_secret: $.auth.data.apiSecret,
-    redirect_uri: redirectUri,
-    code: $.auth.data.code,
-  });
-
-  const { data } = await $.http.post(
-    `https://disqus.com/api/oauth/2.0/access_token/`,
-    params.toString()
-  );
-
-  await $.auth.set({
-    accessToken: data.access_token,
-    tokenType: data.token_type,
-    apiKey: $.auth.data.apiKey,
-    apiSecret: $.auth.data.apiSecret,
-    scope: $.auth.data.scope,
-    userId: data.user_id,
-    expiresIn: data.expires_in,
-    refreshToken: data.refresh_token,
-    screenName: data.username,
-  });
-};
-
-export default verifyCredentials;

packages/backend/src/apps/disqus/common/add-auth-header.js

@@ -1,15 +0,0 @@
-import { URLSearchParams } from 'url';
-
-const addAuthHeader = ($, requestConfig) => {
-  const params = new URLSearchParams({
-    access_token: $.auth.data.accessToken,
-    api_key: $.auth.data.apiKey,
-    api_secret: $.auth.data.apiSecret,
-  });
-
-  requestConfig.params = params;
-
-  return requestConfig;
-};
-
-export default addAuthHeader;

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

@@ -1,3 +0,0 @@
-const authScope = ['read', 'write', 'admin', 'email'];
-
-export default authScope;

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

@@ -1,10 +0,0 @@
-const getCurrentUser = async ($) => {
-  try {
-    const { data: currentUser } = await $.http.get('/3.0/users/details.json');
-    return currentUser;
-  } catch (error) {
-    throw new Error('You are not authenticated.');
-  }
-};
-
-export default getCurrentUser;

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

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

packages/backend/src/apps/disqus/dynamic-data/list-forums/index.js

@@ -1,36 +0,0 @@
-export default {
-  name: 'List forums',
-  key: 'listForums',
-
-  async run($) {
-    const forums = {
-      data: [],
-    };
-
-    const params = {
-      limit: 100,
-      order: 'desc',
-      cursor: undefined,
-    };
-
-    let more;
-    do {
-      const { data } = await $.http.get('/3.0/users/listForums.json', {
-        params,
-      });
-      params.cursor = data.cursor.next;
-      more = data.cursor.hasNext;
-
-      if (data.response?.length) {
-        for (const forum of data.response) {
-          forums.data.push({
-            value: forum.id,
-            name: forum.id,
-          });
-        }
-      }
-    } while (more);
-
-    return forums;
-  },
-};

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

@@ -1,20 +0,0 @@
-import defineApp from '../../helpers/define-app.js';
-import addAuthHeader from './common/add-auth-header.js';
-import auth from './auth/index.js';
-import dynamicData from './dynamic-data/index.js';
-import triggers from './triggers/index.js';
-
-export default defineApp({
-  name: 'Disqus',
-  key: 'disqus',
-  baseUrl: 'https://disqus.com',
-  apiBaseUrl: 'https://disqus.com/api',
-  iconUrl: '{BASE_URL}/apps/disqus/assets/favicon.svg',
-  authDocUrl: '{DOCS_URL}/apps/disqus/connection',
-  primaryColor: '2E9FFF',
-  supportsConnections: true,
-  beforeRequest: [addAuthHeader],
-  auth,
-  dynamicData,
-  triggers,
-});

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

@@ -1,4 +0,0 @@
-import newComments from './new-comments/index.js';
-import newFlaggedComments from './new-flagged-comments/index.js';
-
-export default [newComments, newFlaggedComments];

packages/backend/src/apps/disqus/triggers/new-comments/index.js

@@ -1,92 +0,0 @@
-import defineTrigger from '../../../../helpers/define-trigger.js';
-import { URLSearchParams } from 'url';
-
-export default defineTrigger({
-  name: 'New comments',
-  key: 'newComments',
-  pollInterval: 15,
-  description: 'Triggers when a new comment is posted in a forum using Disqus.',
-  arguments: [
-    {
-      label: 'Post Types',
-      key: 'postTypes',
-      type: 'dynamic',
-      required: false,
-      description:
-        'Which posts should be considered for inclusion in the trigger?',
-      fields: [
-        {
-          label: 'Type',
-          key: 'type',
-          type: 'dropdown',
-          required: false,
-          description: '',
-          variables: true,
-          options: [
-            { label: 'Unapproved Posts', value: 'unapproved' },
-            { label: 'Approved Posts', value: 'approved' },
-            { label: 'Spam Posts', value: 'spam' },
-            { label: 'Deleted Posts', value: 'deleted' },
-            { label: 'Flagged Posts', value: 'flagged' },
-            { label: 'Highlighted Posts', value: 'highlighted' },
-          ],
-        },
-      ],
-    },
-    {
-      label: 'Forum',
-      key: 'forumId',
-      type: 'dropdown',
-      required: true,
-      description: 'Select the forum where you want comments to be triggered.',
-      variables: true,
-      source: {
-        type: 'query',
-        name: 'getDynamicData',
-        arguments: [
-          {
-            name: 'key',
-            value: 'listForums',
-          },
-        ],
-      },
-    },
-  ],
-
-  async run($) {
-    const forumId = $.step.parameters.forumId;
-    const postTypes = $.step.parameters.postTypes;
-    const formattedCommentTypes = postTypes
-      .filter((type) => type.type !== '')
-      .map((type) => type.type);
-
-    const params = new URLSearchParams({
-      limit: '100',
-      forum: forumId,
-    });
-
-    if (formattedCommentTypes.length) {
-      formattedCommentTypes.forEach((type) => params.append('include', type));
-    }
-
-    let more;
-    do {
-      const { data } = await $.http.get(
-        `/3.0/posts/list.json?${params.toString()}`
-      );
-      params.set('cursor', data.cursor.next);
-      more = data.cursor.hasNext;
-
-      if (data.response?.length) {
-        for (const comment of data.response) {
-          $.pushTriggerItem({
-            raw: comment,
-            meta: {
-              internalId: comment.id,
-            },
-          });
-        }
-      }
-    } while (more);
-  },
-});

packages/backend/src/apps/disqus/triggers/new-flagged-comments/index.js

@@ -1,60 +0,0 @@
-import defineTrigger from '../../../../helpers/define-trigger.js';
-import { URLSearchParams } from 'url';
-
-export default defineTrigger({
-  name: 'New flagged comments',
-  key: 'newFlaggedComments',
-  pollInterval: 15,
-  description: 'Triggers when a Disqus comment is marked with a flag',
-  arguments: [
-    {
-      label: 'Forum',
-      key: 'forumId',
-      type: 'dropdown',
-      required: true,
-      description: 'Select the forum where you want comments to be triggered.',
-      variables: true,
-      source: {
-        type: 'query',
-        name: 'getDynamicData',
-        arguments: [
-          {
-            name: 'key',
-            value: 'listForums',
-          },
-        ],
-      },
-    },
-  ],
-
-  async run($) {
-    const forumId = $.step.parameters.forumId;
-    const isFlaggedFilter = 5;
-
-    const params = new URLSearchParams({
-      limit: 100,
-      forum: forumId,
-      filters: [isFlaggedFilter],
-    });
-
-    let more;
-    do {
-      const { data } = await $.http.get(
-        `/3.0/posts/list.json?${params.toString()}`
-      );
-      params.set('cursor', data.cursor.next);
-      more = data.cursor.hasNext;
-
-      if (data.response?.length) {
-        for (const comment of data.response) {
-          $.pushTriggerItem({
-            raw: comment,
-            meta: {
-              internalId: comment.id,
-            },
-          });
-        }
-      }
-    } while (more);
-  },
-});

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/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/actions/text/index.js

@@ -2,7 +2,6 @@ import defineAction from '../../../../helpers/define-action.js';
 
 import base64ToString from './transformers/base64-to-string.js';
 import capitalize from './transformers/capitalize.js';
-import encodeUriComponent from './transformers/encode-uri-component.js';
 import extractEmailAddress from './transformers/extract-email-address.js';
 import extractNumber from './transformers/extract-number.js';
 import htmlToMarkdown from './transformers/html-to-markdown.js';
@@ -11,14 +10,12 @@ import markdownToHtml from './transformers/markdown-to-html.js';
 import pluralize from './transformers/pluralize.js';
 import replace from './transformers/replace.js';
 import stringToBase64 from './transformers/string-to-base64.js';
-import encodeUri from './transformers/encode-uri.js';
 import trimWhitespace from './transformers/trim-whitespace.js';
 import useDefaultValue from './transformers/use-default-value.js';
 
 const transformers = {
   base64ToString,
   capitalize,
-  encodeUriComponent,
   extractEmailAddress,
   extractNumber,
   htmlToMarkdown,
@@ -27,7 +24,6 @@ const transformers = {
   pluralize,
   replace,
   stringToBase64,
-  encodeUri,
   trimWhitespace,
   useDefaultValue,
 };
@@ -47,10 +43,6 @@ export default defineAction({
       options: [
         { label: 'Base64 to String', value: 'base64ToString' },
         { label: 'Capitalize', value: 'capitalize' },
-        {
-          label: 'Encode URI Component',
-          value: 'encodeUriComponent',
-        },
         { label: 'Convert HTML to Markdown', value: 'htmlToMarkdown' },
         { label: 'Convert Markdown to HTML', value: 'markdownToHtml' },
         { label: 'Extract Email Address', value: 'extractEmailAddress' },
@@ -59,7 +51,6 @@ export default defineAction({
         { label: 'Pluralize', value: 'pluralize' },
         { label: 'Replace', value: 'replace' },
         { label: 'String to Base64', value: 'stringToBase64' },
-        { label: 'Encode URI', value: 'encodeUri' },
         { label: 'Trim Whitespace', value: 'trimWhitespace' },
         { label: 'Use Default Value', value: 'useDefaultValue' },
       ],

packages/backend/src/apps/formatter/actions/text/transformers/encode-uri-component.js

@@ -1,8 +0,0 @@
-const encodeUriComponent = ($) => {
-  const input = $.step.parameters.input;
-  const encodedString = encodeURIComponent(input);
-
-  return encodedString;
-};
-
-export default encodeUriComponent;

packages/backend/src/apps/formatter/actions/text/transformers/encode-uri.js

@@ -1,8 +0,0 @@
-const encodeUri = ($) => {
-  const input = $.step.parameters.input;
-  const encodedString = encodeURI(input);
-
-  return encodedString;
-};
-
-export default encodeUri;

packages/backend/src/apps/formatter/dynamic-fields/list-transform-options/index.js

@@ -1,6 +1,5 @@
 import base64ToString from './text/base64-to-string.js';
 import capitalize from './text/capitalize.js';
-import encodeUriComponent from './text/encode-uri-component.js';
 import extractEmailAddress from './text/extract-email-address.js';
 import extractNumber from './text/extract-number.js';
 import htmlToMarkdown from './text/html-to-markdown.js';
@@ -9,7 +8,6 @@ import markdownToHtml from './text/markdown-to-html.js';
 import pluralize from './text/pluralize.js';
 import replace from './text/replace.js';
 import stringToBase64 from './text/string-to-base64.js';
-import encodeUri from './text/encode-uri.js';
 import trimWhitespace from './text/trim-whitespace.js';
 import useDefaultValue from './text/use-default-value.js';
 import performMathOperation from './numbers/perform-math-operation.js';
@@ -21,7 +19,6 @@ import formatDateTime from './date-time/format-date-time.js';
 const options = {
   base64ToString,
   capitalize,
-  encodeUriComponent,
   extractEmailAddress,
   extractNumber,
   htmlToMarkdown,
@@ -30,7 +27,6 @@ const options = {
   pluralize,
   replace,
   stringToBase64,
-  encodeUri,
   trimWhitespace,
   useDefaultValue,
   performMathOperation,

packages/backend/src/apps/formatter/dynamic-fields/list-transform-options/text/encode-uri-component.js

@@ -1,12 +0,0 @@
-const encodeUriComponent = [
-  {
-    label: 'Input',
-    key: 'input',
-    type: 'string',
-    required: true,
-    description: 'URI Component to encode',
-    variables: true,
-  },
-];
-
-export default encodeUriComponent;

packages/backend/src/apps/formatter/dynamic-fields/list-transform-options/text/encode-uri.js

@@ -1,12 +0,0 @@
-const encodeUri = [
-  {
-    label: 'Input',
-    key: 'input',
-    type: 'string',
-    required: true,
-    description: 'URI to encode',
-    variables: true,
-  },
-];
-
-export default encodeUri;

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/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/gmail/actions/create-draft/index.js

@@ -0,0 +1,204 @@
+import defineAction from '../../../../helpers/define-action.js';
+
+export default defineAction({
+  name: 'Create draft',
+  key: 'createDraft',
+  description: 'Create a new draft email message.',
+  arguments: [
+    {
+      label: 'Subject',
+      key: 'subject',
+      type: 'string',
+      required: true,
+      description: '',
+      variables: true,
+    },
+    {
+      label: 'TOs',
+      key: 'tos',
+      type: 'dynamic',
+      required: false,
+      description: '',
+      fields: [
+        {
+          label: 'To',
+          key: 'to',
+          type: 'string',
+          required: false,
+          variables: true,
+        },
+      ],
+    },
+    {
+      label: 'CCs',
+      key: 'ccs',
+      type: 'dynamic',
+      required: false,
+      description: '',
+      fields: [
+        {
+          label: 'CC',
+          key: 'cc',
+          type: 'string',
+          required: false,
+          variables: true,
+        },
+      ],
+    },
+    {
+      label: 'BCCs',
+      key: 'bccs',
+      type: 'dynamic',
+      required: false,
+      description: '',
+      fields: [
+        {
+          label: 'BCC',
+          key: 'bcc',
+          type: 'string',
+          required: false,
+          variables: true,
+        },
+      ],
+    },
+    {
+      label: 'From',
+      key: 'from',
+      type: 'dropdown',
+      required: false,
+      description:
+        'Select an email address or alias from your Gmail Account. Defaults to the primary email address.',
+      variables: true,
+      source: {
+        type: 'query',
+        name: 'getDynamicData',
+        arguments: [
+          {
+            name: 'key',
+            value: 'listEmails',
+          },
+        ],
+      },
+    },
+    {
+      label: 'From Name',
+      key: 'fromName',
+      type: 'string',
+      required: false,
+      description: '',
+      variables: true,
+    },
+    {
+      label: 'Body Type',
+      key: 'bodyType',
+      type: 'dropdown',
+      required: false,
+      description: '',
+      variables: true,
+      options: [
+        {
+          label: 'plain',
+          value: 'plain',
+        },
+        {
+          label: 'html',
+          value: 'html',
+        },
+      ],
+    },
+    {
+      label: 'Body',
+      key: 'emailBody',
+      type: 'string',
+      required: true,
+      description: '',
+      variables: true,
+    },
+    {
+      label: 'Signature',
+      key: 'signature',
+      type: 'dropdown',
+      required: false,
+      description: '',
+      variables: true,
+      source: {
+        type: 'query',
+        name: 'getDynamicData',
+        arguments: [
+          {
+            name: 'key',
+            value: 'listSignatures',
+          },
+        ],
+      },
+    },
+  ],
+
+  async run($) {
+    const {
+      tos,
+      ccs,
+      bccs,
+      from,
+      fromName,
+      subject,
+      bodyType,
+      emailBody,
+      signature,
+    } = $.step.parameters;
+    const userId = $.auth.data.userId;
+
+    const allTos = tos?.map((entry) => entry.to);
+    const allCcs = ccs?.map((entry) => entry.cc);
+    const allBccs = bccs?.map((entry) => entry.bcc);
+    const contentType =
+      bodyType === 'html'
+        ? 'text/html; charset="UTF-8"'
+        : 'text/plain; charset="UTF-8"';
+
+    const email =
+      'From: ' +
+      fromName +
+      ' <' +
+      from +
+      '>' +
+      '\r\n' +
+      'To: ' +
+      allTos.join(',') +
+      '\r\n' +
+      'Cc: ' +
+      allCcs.join(',') +
+      '\r\n' +
+      'Bcc: ' +
+      allBccs.join(',') +
+      '\r\n' +
+      'Subject: ' +
+      subject +
+      '\r\n' +
+      'Content-Type: ' +
+      contentType +
+      '\r\n' +
+      '\r\n' +
+      emailBody +
+      '\r\n' +
+      '\r\n' +
+      signature;
+
+    const base64EncodedEmailBody = Buffer.from(email).toString('base64');
+
+    const body = {
+      message: {
+        raw: base64EncodedEmailBody,
+      },
+    };
+
+    const { data } = await $.http.post(
+      `/gmail/v1/users/${userId}/drafts`,
+      body
+    );
+
+    $.setActionItem({
+      raw: data,
+    });
+  },
+});

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

@@ -0,0 +1,6 @@
+import createDraft from './create-draft/index.js';
+import replyToEmail from './reply-to-email/index.js';
+import sendEmail from './send-email/index.js';
+import sendToTrash from './send-to-trash/index.js';
+
+export default [createDraft, replyToEmail, sendEmail, sendToTrash];

packages/backend/src/apps/gmail/actions/reply-to-email/index.js

@@ -0,0 +1,228 @@
+import defineAction from '../../../../helpers/define-action.js';
+
+export default defineAction({
+  name: 'Reply to email',
+  key: 'replyToEmail',
+  description: 'Respond to an email.',
+  arguments: [
+    {
+      label: 'Thread',
+      key: 'threadId',
+      type: 'dropdown',
+      required: false,
+      description: '',
+      variables: true,
+      source: {
+        type: 'query',
+        name: 'getDynamicData',
+        arguments: [
+          {
+            name: 'key',
+            value: 'listThreads',
+          },
+        ],
+      },
+    },
+    {
+      label: 'TOs',
+      key: 'tos',
+      type: 'dynamic',
+      required: false,
+      description: 'Who will receive this email?',
+      fields: [
+        {
+          label: 'To',
+          key: 'to',
+          type: 'string',
+          required: false,
+          variables: true,
+        },
+      ],
+    },
+    {
+      label: 'CCs',
+      key: 'ccs',
+      type: 'dynamic',
+      required: false,
+      description:
+        'Who else needs to be included in the CC field of this email?',
+      fields: [
+        {
+          label: 'CC',
+          key: 'cc',
+          type: 'string',
+          required: false,
+          variables: true,
+        },
+      ],
+    },
+    {
+      label: 'BCCs',
+      key: 'bccs',
+      type: 'dynamic',
+      required: false,
+      description:
+        'Who else needs to be included in the BCC field of this email?',
+      fields: [
+        {
+          label: 'BCC',
+          key: 'bcc',
+          type: 'string',
+          required: false,
+          variables: true,
+        },
+      ],
+    },
+    {
+      label: 'From',
+      key: 'from',
+      type: 'dropdown',
+      required: false,
+      description:
+        'Choose an email address or alias from your Gmail Account. This defaults to the primary email address.',
+      variables: true,
+      source: {
+        type: 'query',
+        name: 'getDynamicData',
+        arguments: [
+          {
+            name: 'key',
+            value: 'listEmails',
+          },
+        ],
+      },
+    },
+    {
+      label: 'From Name',
+      key: 'fromName',
+      type: 'string',
+      required: false,
+      description: '',
+      variables: true,
+    },
+    {
+      label: 'Reply To',
+      key: 'replyTo',
+      type: 'string',
+      required: false,
+      description: 'Specify a single reply address other than your own.',
+      variables: true,
+    },
+    {
+      label: 'Body Type',
+      key: 'bodyType',
+      type: 'dropdown',
+      required: false,
+      description: '',
+      variables: true,
+      options: [
+        {
+          label: 'plain',
+          value: 'plain',
+        },
+        {
+          label: 'html',
+          value: 'html',
+        },
+      ],
+    },
+    {
+      label: 'Body',
+      key: 'emailBody',
+      type: 'string',
+      required: true,
+      description: '',
+      variables: true,
+    },
+    {
+      label: 'Label',
+      key: 'labelId',
+      type: 'dropdown',
+      required: false,
+      description: '',
+      variables: true,
+      source: {
+        type: 'query',
+        name: 'getDynamicData',
+        arguments: [
+          {
+            name: 'key',
+            value: 'listLabels',
+          },
+        ],
+      },
+    },
+  ],
+
+  async run($) {
+    const {
+      tos,
+      ccs,
+      bccs,
+      from,
+      fromName,
+      replyTo,
+      threadId,
+      bodyType,
+      emailBody,
+      labelId,
+    } = $.step.parameters;
+    const userId = $.auth.data.userId;
+
+    const allTos = tos?.map((entry) => entry.to);
+    const allCcs = ccs?.map((entry) => entry.cc);
+    const allBccs = bccs?.map((entry) => entry.bcc);
+    const contentType =
+      bodyType === 'html'
+        ? 'text/html; charset="UTF-8"'
+        : 'text/plain; charset="UTF-8"';
+
+    const email =
+      'From: ' +
+      fromName +
+      ' <' +
+      from +
+      '>' +
+      '\r\n' +
+      'In-Reply-To: ' +
+      threadId +
+      '\r\n' +
+      'References: ' +
+      threadId +
+      '\r\n' +
+      'Reply-To: ' +
+      replyTo +
+      '\r\n' +
+      'To: ' +
+      allTos.join(',') +
+      '\r\n' +
+      'Cc: ' +
+      allCcs.join(',') +
+      '\r\n' +
+      'Bcc: ' +
+      allBccs.join(',') +
+      '\r\n' +
+      'Content-Type: ' +
+      contentType +
+      '\r\n' +
+      '\r\n' +
+      emailBody;
+
+    const base64EncodedEmailBody = Buffer.from(email).toString('base64');
+
+    const body = {
+      threadId: threadId,
+      labelIds: [labelId],
+      raw: base64EncodedEmailBody,
+    };
+
+    const { data } = await $.http.post(
+      `/gmail/v1/users/${userId}/messages/send`,
+      body
+    );
+
+    $.setActionItem({
+      raw: data,
+    });
+  },
+});

packages/backend/src/apps/gmail/actions/send-email/index.js

@@ -0,0 +1,234 @@
+import defineAction from '../../../../helpers/define-action.js';
+
+export default defineAction({
+  name: 'Send email',
+  key: 'sendEmail',
+  description: 'Send a new email message.',
+  arguments: [
+    {
+      label: 'TOs',
+      key: 'tos',
+      type: 'dynamic',
+      required: false,
+      description: '',
+      fields: [
+        {
+          label: 'To',
+          key: 'to',
+          type: 'string',
+          required: false,
+          variables: true,
+        },
+      ],
+    },
+    {
+      label: 'CCs',
+      key: 'ccs',
+      type: 'dynamic',
+      required: false,
+      description: '',
+      fields: [
+        {
+          label: 'CC',
+          key: 'cc',
+          type: 'string',
+          required: false,
+          variables: true,
+        },
+      ],
+    },
+    {
+      label: 'BCCs',
+      key: 'bccs',
+      type: 'dynamic',
+      required: false,
+      description: '',
+      fields: [
+        {
+          label: 'BCC',
+          key: 'bcc',
+          type: 'string',
+          required: false,
+          variables: true,
+        },
+      ],
+    },
+    {
+      label: 'From',
+      key: 'from',
+      type: 'dropdown',
+      required: false,
+      description:
+        'Select an email address or alias from your Gmail Account. Defaults to the primary email address.',
+      variables: true,
+      source: {
+        type: 'query',
+        name: 'getDynamicData',
+        arguments: [
+          {
+            name: 'key',
+            value: 'listEmails',
+          },
+        ],
+      },
+    },
+    {
+      label: 'From Name',
+      key: 'fromName',
+      type: 'string',
+      required: false,
+      description: '',
+      variables: true,
+    },
+    {
+      label: 'Reply To',
+      key: 'replyTo',
+      type: 'string',
+      required: false,
+      description: 'Specify a single reply address other than your own.',
+      variables: true,
+    },
+    {
+      label: 'Subject',
+      key: 'subject',
+      type: 'string',
+      required: true,
+      description: '',
+      variables: true,
+    },
+    {
+      label: 'Body Type',
+      key: 'bodyType',
+      type: 'dropdown',
+      required: false,
+      description: '',
+      variables: true,
+      options: [
+        {
+          label: 'plain',
+          value: 'plain',
+        },
+        {
+          label: 'html',
+          value: 'html',
+        },
+      ],
+    },
+    {
+      label: 'Body',
+      key: 'emailBody',
+      type: 'string',
+      required: true,
+      description: '',
+      variables: true,
+    },
+    {
+      label: 'Signature',
+      key: 'signature',
+      type: 'dropdown',
+      required: false,
+      description: '',
+      variables: true,
+      source: {
+        type: 'query',
+        name: 'getDynamicData',
+        arguments: [
+          {
+            name: 'key',
+            value: 'listSignatures',
+          },
+        ],
+      },
+    },
+    {
+      label: 'Label',
+      key: 'labelId',
+      type: 'dropdown',
+      required: false,
+      description: '',
+      variables: true,
+      source: {
+        type: 'query',
+        name: 'getDynamicData',
+        arguments: [
+          {
+            name: 'key',
+            value: 'listLabels',
+          },
+        ],
+      },
+    },
+  ],
+
+  async run($) {
+    const {
+      tos,
+      ccs,
+      bccs,
+      from,
+      fromName,
+      replyTo,
+      subject,
+      bodyType,
+      emailBody,
+      signature,
+      labelId,
+    } = $.step.parameters;
+    const userId = $.auth.data.userId;
+
+    const allTos = tos?.map((entry) => entry.to);
+    const allCcs = ccs?.map((entry) => entry.cc);
+    const allBccs = bccs?.map((entry) => entry.bcc);
+    const contentType =
+      bodyType === 'html'
+        ? 'text/html; charset="UTF-8"'
+        : 'text/plain; charset="UTF-8"';
+
+    const email =
+      'From: ' +
+      fromName +
+      ' <' +
+      from +
+      '>' +
+      '\r\n' +
+      'Reply-To: ' +
+      replyTo +
+      '\r\n' +
+      'To: ' +
+      allTos.join(',') +
+      '\r\n' +
+      'Cc: ' +
+      allCcs.join(',') +
+      '\r\n' +
+      'Bcc: ' +
+      allBccs.join(',') +
+      '\r\n' +
+      'Subject: ' +
+      subject +
+      '\r\n' +
+      'Content-Type: ' +
+      contentType +
+      '\r\n' +
+      '\r\n' +
+      emailBody +
+      '\r\n' +
+      '\r\n' +
+      signature;
+
+    const base64EncodedEmailBody = Buffer.from(email).toString('base64');
+
+    const body = {
+      labelIds: [labelId],
+      raw: base64EncodedEmailBody,
+    };
+
+    const { data } = await $.http.post(
+      `/gmail/v1/users/${userId}/messages/send`,
+      body
+    );
+
+    $.setActionItem({
+      raw: data,
+    });
+  },
+});

packages/backend/src/apps/gmail/actions/send-to-trash/index.js

@@ -0,0 +1,30 @@
+import defineAction from '../../../../helpers/define-action.js';
+
+export default defineAction({
+  name: 'Send to trash',
+  key: 'sendToTrash',
+  description: 'Send an existing email message to the trash.',
+  arguments: [
+    {
+      label: 'Message ID',
+      key: 'messageId',
+      type: 'string',
+      required: true,
+      description: '',
+      variables: true,
+    },
+  ],
+
+  async run($) {
+    const { messageId } = $.step.parameters;
+    const userId = $.auth.data.userId;
+
+    const { data } = await $.http.post(
+      `/gmail/v1/users/${userId}/messages/${messageId}/trash`
+    );
+
+    $.setActionItem({
+      raw: data,
+    });
+  },
+});

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

@@ -0,0 +1,11 @@
+<svg xmlns="http://www.w3.org/2000/svg" viewBox="0 49.4 512 399.42">
+  <g fill="none" fill-rule="evenodd">
+    <g fill-rule="nonzero">
+      <path fill="#4285f4" d="M34.91 448.818h81.454V251L0 163.727V413.91c0 19.287 15.622 34.91 34.91 34.91z"/>
+      <path fill="#34a853" d="M395.636 448.818h81.455c19.287 0 34.909-15.622 34.909-34.909V163.727L395.636 251z"/>
+      <path fill="#fbbc04" d="M395.636 99.727V251L512 163.727v-46.545c0-43.142-49.25-67.782-83.782-41.891z"/>
+    </g>
+    <path fill="#ea4335" d="M116.364 251V99.727L256 204.455 395.636 99.727V251L256 355.727z"/>
+    <path fill="#c5221f" fill-rule="nonzero" d="M0 117.182v46.545L116.364 251V99.727L83.782 75.291C49.25 49.4 0 74.04 0 117.18z"/>
+  </g>
+</svg>

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

@@ -11,7 +11,7 @@ export default {
       type: 'string',
       required: true,
       readOnly: true,
-      value: '{WEB_APP_URL}/app/google-tasks/connections/add',
+      value: '{WEB_APP_URL}/app/gmail/connections/add',
       placeholder: null,
       description:
         'When asked to input a redirect URL in Google Cloud, enter the URL above.',

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

@@ -1,4 +1,5 @@
 import { URLSearchParams } from 'node:url';
+
 import authScope from '../common/auth-scope.js';
 
 const refreshToken = async ($) => {

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

@@ -36,6 +36,7 @@ const verifyCredentials = async ($) => {
     refreshToken: data.refresh_token,
     resourceName: currentUser.resourceName,
     screenName: `${displayName} - ${email}`,
+    userId: email,
   });
 };
 

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

@@ -1,5 +1,6 @@
 const authScope = [
-  'https://www.googleapis.com/auth/tasks',
+  'https://www.googleapis.com/auth/gmail.compose',
+  'https://www.googleapis.com/auth/gmail.modify',
   'https://www.googleapis.com/auth/userinfo.email',
   'https://www.googleapis.com/auth/userinfo.profile',
 ];

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

@@ -0,0 +1,6 @@
+import listEmails from './list-emails/index.js';
+import listLabels from './list-labels/index.js';
+import listSignatures from './list-signatures/index.js';
+import listThreads from './list-threads/index.js';
+
+export default [listEmails, listLabels, listSignatures, listThreads];

packages/backend/src/apps/gmail/dynamic-data/list-emails/index.js

@@ -0,0 +1,23 @@
+import getCurrentUser from '../../common/get-current-user.js';
+
+export default {
+  name: 'List emails',
+  key: 'listEmails',
+
+  async run($) {
+    const emails = {
+      data: [],
+    };
+
+    const currentUser = await getCurrentUser($);
+
+    for (const emailAddress of currentUser.emailAddresses) {
+      emails.data.push({
+        value: emailAddress.value,
+        name: emailAddress.value,
+      });
+    }
+
+    return emails;
+  },
+};

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

@@ -0,0 +1,22 @@
+export default {
+  name: 'List labels',
+  key: 'listLabels',
+
+  async run($) {
+    const labels = {
+      data: [],
+    };
+    const userId = $.auth.data.userId;
+
+    const { data } = await $.http.get(`/gmail/v1/users/${userId}/labels`);
+
+    for (const label of data.labels) {
+      labels.data.push({
+        value: label.id,
+        name: label.name,
+      });
+    }
+
+    return labels;
+  },
+};

packages/backend/src/apps/gmail/dynamic-data/list-signatures/index.js

@@ -0,0 +1,24 @@
+export default {
+  name: 'List signatures',
+  key: 'listSignatures',
+
+  async run($) {
+    const signatures = {
+      data: [],
+    };
+    const userId = $.auth.data.userId;
+
+    const { data } = await $.http.get(
+      `/gmail/v1/users/${userId}/settings/sendAs`
+    );
+
+    for (const sendAs of data.sendAs) {
+      signatures.data.push({
+        value: sendAs.signature,
+        name: sendAs.sendAsEmail,
+      });
+    }
+
+    return signatures;
+  },
+};

packages/backend/src/apps/gmail/dynamic-data/list-threads/index.js

@@ -0,0 +1,31 @@
+export default {
+  name: 'List threads',
+  key: 'listThreads',
+
+  async run($) {
+    const threads = {
+      data: [],
+    };
+    const userId = $.auth.data.userId;
+
+    const { data } = await $.http.get(`/gmail/v1/users/${userId}/threads`);
+
+    if (data.threads) {
+      for (const thread of data.threads) {
+        const { data: threadData } = await $.http.get(
+          `/gmail/v1/users/${userId}/threads/${thread.id}`
+        );
+        const subject = threadData.messages[0].payload.headers.find(
+          (header) => header.name === 'Subject'
+        );
+
+        threads.data.push({
+          value: thread.id,
+          name: subject?.value,
+        });
+      }
+    }
+
+    return threads;
+  },
+};

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

@@ -1,22 +1,22 @@
 import defineApp from '../../helpers/define-app.js';
 import addAuthHeader from './common/add-auth-header.js';
 import auth from './auth/index.js';
-import actions from './actions/index.js';
 import triggers from './triggers/index.js';
 import dynamicData from './dynamic-data/index.js';
+import actions from './actions/index.js';
 
 export default defineApp({
-  name: 'Google Tasks',
-  key: 'google-tasks',
-  baseUrl: 'https://calendar.google.com/calendar/u/0/r/tasks',
-  apiBaseUrl: 'https://tasks.googleapis.com',
-  iconUrl: '{BASE_URL}/apps/google-tasks/assets/favicon.svg',
-  authDocUrl: '{DOCS_URL}/apps/google-tasks/connection',
-  primaryColor: '0066DA',
+  name: 'Gmail',
+  key: 'gmail',
+  baseUrl: 'https://mail.google.com',
+  apiBaseUrl: 'https://gmail.googleapis.com',
+  iconUrl: '{BASE_URL}/apps/gmail/assets/favicon.svg',
+  authDocUrl: 'https://automatisch.io/docs/apps/gmail/connection',
+  primaryColor: 'ea4335',
   supportsConnections: true,
   beforeRequest: [addAuthHeader],
   auth,
-  actions,
-  dynamicData,
   triggers,
+  dynamicData,
+  actions,
 });

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

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

packages/backend/src/apps/gmail/triggers/new-emails/index.js

@@ -0,0 +1,68 @@
+import defineTrigger from '../../../../helpers/define-trigger.js';
+
+export default defineTrigger({
+  name: 'New emails',
+  key: 'newEmails',
+  pollInterval: 15,
+  description:
+    'Triggers when a new email is received in the specified mailbox.',
+  arguments: [
+    {
+      label: 'Label',
+      key: 'labelId',
+      type: 'dropdown',
+      required: false,
+      description:
+        "If you don't choose a label, this Zap will trigger for all emails, including Drafts.",
+      variables: true,
+      source: {
+        type: 'query',
+        name: 'getDynamicData',
+        arguments: [
+          {
+            name: 'key',
+            value: 'listLabels',
+          },
+        ],
+      },
+    },
+  ],
+
+  async run($) {
+    const userId = $.auth.data.userId;
+    const labelId = $.step.parameters.labelId;
+
+    const params = {
+      maxResults: 500,
+      pageToken: undefined,
+    };
+
+    if (labelId) {
+      params.labelIds = labelId;
+    }
+
+    do {
+      const { data } = await $.http.get(`/gmail/v1/users/${userId}/messages`, {
+        params,
+      });
+      params.pageToken = data.nextPageToken;
+
+      if (!data?.messages?.length) {
+        return;
+      }
+
+      for (const message of data.messages) {
+        const { data: messageData } = await $.http.get(
+          `/gmail/v1/users/${userId}/messages/${message.id}`
+        );
+
+        $.pushTriggerItem({
+          raw: messageData,
+          meta: {
+            internalId: messageData.id,
+          },
+        });
+      }
+    } while (params.pageToken);
+  },
+});

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/google-tasks/actions/create-task-list/index.js

@@ -1,31 +0,0 @@
-import defineAction from '../../../../helpers/define-action.js';
-
-export default defineAction({
-  name: 'Create task list',
-  key: 'createTaskList',
-  description: 'Creates a new task list.',
-  arguments: [
-    {
-      label: 'List Title',
-      key: 'listTitle',
-      type: 'string',
-      required: true,
-      description: '',
-      variables: true,
-    },
-  ],
-
-  async run($) {
-    const listTitle = $.step.parameters.listTitle;
-
-    const body = {
-      title: listTitle,
-    };
-
-    const { data } = await $.http.post('/tasks/v1/users/@me/lists', body);
-
-    $.setActionItem({
-      raw: data,
-    });
-  },
-});

packages/backend/src/apps/google-tasks/actions/create-task/index.js

@@ -1,70 +0,0 @@
-import defineAction from '../../../../helpers/define-action.js';
-
-export default defineAction({
-  name: 'Create task',
-  key: 'createTask',
-  description: 'Creates a new task.',
-  arguments: [
-    {
-      label: 'Task List',
-      key: 'taskListId',
-      type: 'dropdown',
-      required: true,
-      description: '',
-      variables: true,
-      source: {
-        type: 'query',
-        name: 'getDynamicData',
-        arguments: [
-          {
-            name: 'key',
-            value: 'listTaskLists',
-          },
-        ],
-      },
-    },
-    {
-      label: 'Title',
-      key: 'title',
-      type: 'string',
-      required: true,
-      description: '',
-      variables: true,
-    },
-    {
-      label: 'Notes',
-      key: 'notes',
-      type: 'string',
-      required: false,
-      description: '',
-      variables: true,
-    },
-    {
-      label: 'Due Date',
-      key: 'due',
-      type: 'string',
-      required: false,
-      description: 'RFC 3339 timestamp.',
-      variables: true,
-    },
-  ],
-
-  async run($) {
-    const { taskListId, title, notes, due } = $.step.parameters;
-
-    const body = {
-      title,
-      notes,
-      due,
-    };
-
-    const { data } = await $.http.post(
-      `/tasks/v1/lists/${taskListId}/tasks`,
-      body
-    );
-
-    $.setActionItem({
-      raw: data,
-    });
-  },
-});

packages/backend/src/apps/google-tasks/actions/find-task/index.js

@@ -1,57 +0,0 @@
-import defineAction from '../../../../helpers/define-action.js';
-
-export default defineAction({
-  name: 'Find task',
-  key: 'findTask',
-  description: 'Looking for a specific task.',
-  arguments: [
-    {
-      label: 'Task List',
-      key: 'taskListId',
-      type: 'dropdown',
-      required: true,
-      description: 'The list to be searched.',
-      variables: true,
-      source: {
-        type: 'query',
-        name: 'getDynamicData',
-        arguments: [
-          {
-            name: 'key',
-            value: 'listTaskLists',
-          },
-        ],
-      },
-    },
-    {
-      label: 'Title',
-      key: 'title',
-      type: 'string',
-      required: true,
-      description: '',
-      variables: true,
-    },
-  ],
-
-  async run($) {
-    const taskListId = $.step.parameters.taskListId;
-    const title = $.step.parameters.title;
-
-    const params = {
-      showCompleted: true,
-      showHidden: true,
-    };
-
-    const { data } = await $.http.get(`/tasks/v1/lists/${taskListId}/tasks`, {
-      params,
-    });
-
-    const filteredTask = data.items?.filter((task) =>
-      task.title.includes(title)
-    );
-
-    $.setActionItem({
-      raw: filteredTask[0],
-    });
-  },
-});

packages/backend/src/apps/google-tasks/actions/index.js

@@ -1,6 +0,0 @@
-import createTask from './create-task/index.js';
-import createTaskList from './create-task-list/index.js';
-import findTask from './find-task/index.js';
-import updateTask from './update-task/index.js';
-
-export default [createTask, createTaskList, findTask, updateTask];

packages/backend/src/apps/google-tasks/actions/update-task/index.js

@@ -1,108 +0,0 @@
-import defineAction from '../../../../helpers/define-action.js';
-
-export default defineAction({
-  name: 'Update task',
-  key: 'updateTask',
-  description: 'Updates an existing task.',
-  arguments: [
-    {
-      label: 'Task List',
-      key: 'taskListId',
-      type: 'dropdown',
-      required: true,
-      description: '',
-      variables: true,
-      source: {
-        type: 'query',
-        name: 'getDynamicData',
-        arguments: [
-          {
-            name: 'key',
-            value: 'listTaskLists',
-          },
-        ],
-      },
-    },
-    {
-      label: 'Task',
-      key: 'taskId',
-      type: 'dropdown',
-      required: true,
-      description: 'Ensure that you choose a list before proceeding.',
-      variables: true,
-      dependsOn: ['parameters.taskListId'],
-      source: {
-        type: 'query',
-        name: 'getDynamicData',
-        arguments: [
-          {
-            name: 'key',
-            value: 'listTasks',
-          },
-          {
-            name: 'parameters.taskListId',
-            value: '{parameters.taskListId}',
-          },
-        ],
-      },
-    },
-    {
-      label: 'Title',
-      key: 'title',
-      type: 'string',
-      required: false,
-      description: 'Provide a new title for the revised task.',
-      variables: true,
-    },
-    {
-      label: 'Status',
-      key: 'status',
-      type: 'dropdown',
-      required: false,
-      description:
-        'Specify the status of the updated task. If you opt for a custom value, enter either "needsAttention" or "completed."',
-      variables: true,
-      options: [
-        { label: 'Incomplete', value: 'needsAction' },
-        { label: 'Complete', value: 'completed' },
-      ],
-    },
-    {
-      label: 'Notes',
-      key: 'notes',
-      type: 'string',
-      required: false,
-      description: 'Provide a note for the revised task.',
-      variables: true,
-    },
-    {
-      label: 'Due Date',
-      key: 'due',
-      type: 'string',
-      required: false,
-      description:
-        'Specify the deadline for the task (as a RFC 3339 timestamp).',
-      variables: true,
-    },
-  ],
-
-  async run($) {
-    const { taskListId, taskId, title, status, notes, due } = $.step.parameters;
-
-    const body = {
-      title,
-      status,
-      notes,
-      due,
-    };
-
-    const { data } = await $.http.patch(
-      `/tasks/v1/lists/${taskListId}/tasks/${taskId}`,
-      body
-    );
-
-    $.setActionItem({
-      raw: data,
-    });
-  },
-});

packages/backend/src/apps/google-tasks/assets/favicon.svg

@@ -1,16 +0,0 @@
-<?xml version="1.0" encoding="utf-8"?>
-<svg version="1.1"
-	 id="svg8849" inkscape:version="1.1 (c68e22c387, 2021-05-23)" sodipodi:docname="google tasks.svg" xmlns:inkscape="http://www.inkscape.org/namespaces/inkscape" xmlns:sodipodi="http://sodipodi.sourceforge.net/DTD/sodipodi-0.dtd" xmlns:svg="http://www.w3.org/2000/svg"
-	 xmlns="http://www.w3.org/2000/svg" xmlns:xlink="http://www.w3.org/1999/xlink" x="0px" y="0px" width="527.1px" height="500px"
-	 viewBox="0 0 527.1 500" enable-background="new 0 0 527.1 500" xml:space="preserve">
-<sodipodi:namedview  bordercolor="#eeeeee" borderopacity="1" id="namedview8851" inkscape:bbox-nodes="true" inkscape:bbox-paths="true" inkscape:current-layer="layer1" inkscape:cx="280.62992" inkscape:cy="277.14384" inkscape:document-units="mm" inkscape:object-paths="true" inkscape:pagecheckerboard="0" inkscape:pageopacity="0" inkscape:pageshadow="0" inkscape:snap-bbox="true" inkscape:snap-bbox-edge-midpoints="true" inkscape:snap-bbox-midpoints="true" inkscape:snap-center="true" inkscape:snap-global="true" inkscape:snap-intersection-paths="true" inkscape:snap-midpoints="true" inkscape:snap-object-midpoints="true" inkscape:snap-page="true" inkscape:snap-smooth-nodes="true" inkscape:snap-text-baseline="true" inkscape:window-height="1009" inkscape:window-maximized="1" inkscape:window-width="1920" inkscape:window-x="1912" inkscape:window-y="760" inkscape:zoom="1.4342733" pagecolor="#505050" showgrid="false" units="px">
-	</sodipodi:namedview>
-<g>
-	<polygon fill="#0066DA" points="410.4,58.3 368.8,81.2 348.2,120.6 368.8,168.8 407.8,211 450,187.5 475.9,142.8 450,87.5 	"/>
-	<path fill="#2684FC" d="M249.3,219.4l98.9-98.9c29.1,22.1,50.5,53.8,59.6,90.4L272.1,346.7c-12.2,12.2-32,12.2-44.2,0l-91.5-91.5
-		c-9.8-9.8-9.8-25.6,0-35.3l39-39c9.8-9.8,25.6-9.8,35.3,0L249.3,219.4z M519.8,63.6l-39.7-39.7c-9.7-9.7-25.6-9.7-35.3,0
-		l-34.4,34.4c27.5,23,49.9,51.8,65.5,84.5l43.9-43.9C529.6,89.2,529.6,73.3,519.8,63.6z M412.5,250c0,89.8-72.8,162.5-162.5,162.5
-		S87.5,339.8,87.5,250S160.2,87.5,250,87.5c36.9,0,70.9,12.3,98.2,33.1l62.2-62.2C367,21.9,311.1,0,250,0C111.9,0,0,111.9,0,250
-		s111.9,250,250,250s250-111.9,250-250c0-38.3-8.7-74.7-24.1-107.2L407.8,211C410.8,223.5,412.5,236.6,412.5,250z"/>
-</g>
-</svg>

packages/backend/src/apps/google-tasks/dynamic-data/index.js

@@ -1,4 +0,0 @@
-import listTaskLists from './list-task-lists/index.js';
-import listTasks from './list-tasks/index.js';
-
-export default [listTaskLists, listTasks];

packages/backend/src/apps/google-tasks/dynamic-data/list-task-lists/index.js

@@ -1,33 +0,0 @@
-export default {
-  name: 'List task lists',
-  key: 'listTaskLists',
-
-  async run($) {
-    const taskLists = {
-      data: [],
-    };
-
-    const params = {
-      maxResults: 100,
-      pageToken: undefined,
-    };
-
-    do {
-      const { data } = await $.http.get('/tasks/v1/users/@me/lists', {
-        params,
-      });
-      params.pageToken = data.nextPageToken;
-
-      if (data.items) {
-        for (const taskList of data.items) {
-          taskLists.data.push({
-            value: taskList.id,
-            name: taskList.title,
-          });
-        }
-      }
-    } while (params.pageToken);
-
-    return taskLists;
-  },
-};

packages/backend/src/apps/google-tasks/dynamic-data/list-tasks/index.js

@@ -1,40 +0,0 @@
-export default {
-  name: 'List tasks',
-  key: 'listTasks',
-
-  async run($) {
-    const tasks = {
-      data: [],
-    };
-    const taskListId = $.step.parameters.taskListId;
-
-    const params = {
-      maxResults: 100,
-      pageToken: undefined,
-    };
-
-    if (!taskListId) {
-      return tasks;
-    }
-
-    do {
-      const { data } = await $.http.get(`/tasks/v1/lists/${taskListId}/tasks`, {
-        params,
-      });
-      params.pageToken = data.nextPageToken;
-
-      if (data.items) {
-        for (const task of data.items) {
-          if (task.title !== '') {
-            tasks.data.push({
-              value: task.id,
-              name: task.title,
-            });
-          }
-        }
-      }
-    } while (params.pageToken);
-
-    return tasks;
-  },
-};

packages/backend/src/apps/google-tasks/triggers/index.js

@@ -1,5 +0,0 @@
-import newCompletedTasks from './new-completed-tasks/index.js';
-import newTaskLists from './new-task-lists/index.js';
-import newTasks from './new-tasks/index.js';
-
-export default [newCompletedTasks, newTaskLists, newTasks];

packages/backend/src/apps/google-tasks/triggers/new-completed-tasks/index.js

@@ -1,59 +0,0 @@
-import defineTrigger from '../../../../helpers/define-trigger.js';
-
-export default defineTrigger({
-  name: 'New completed tasks',
-  key: 'newCompletedTasks',
-  pollInterval: 15,
-  description: 'Triggers when a task is finished within a specified task list.',
-  arguments: [
-    {
-      label: 'Task List',
-      key: 'taskListId',
-      type: 'dropdown',
-      required: true,
-      description: '',
-      variables: true,
-      source: {
-        type: 'query',
-        name: 'getDynamicData',
-        arguments: [
-          {
-            name: 'key',
-            value: 'listTaskLists',
-          },
-        ],
-      },
-    },
-  ],
-
-  async run($) {
-    const taskListId = $.step.parameters.taskListId;
-
-    const params = {
-      maxResults: 100,
-      showCompleted: true,
-      showHidden: true,
-      pageToken: undefined,
-    };
-
-    do {
-      const { data } = await $.http.get(`/tasks/v1/lists/${taskListId}/tasks`, {
-        params,
-      });
-      params.pageToken = data.nextPageToken;
-
-      if (data.items?.length) {
-        for (const task of data.items) {
-          if (task.status === 'completed') {
-            $.pushTriggerItem({
-              raw: task,
-              meta: {
-                internalId: task.id,
-              },
-            });
-          }
-        }
-      }
-    } while (params.pageToken);
-  },
-});

packages/backend/src/apps/google-tasks/triggers/new-task-lists/index.js

@@ -1,31 +0,0 @@
-import defineTrigger from '../../../../helpers/define-trigger.js';
-
-export default defineTrigger({
-  name: 'New task lists',
-  key: 'newTaskLists',
-  pollInterval: 15,
-  description: 'Triggers when a new task list is created.',
-
-  async run($) {
-    const params = {
-      maxResults: 100,
-      pageToken: undefined,
-    };
-
-    do {
-      const { data } = await $.http.get('/tasks/v1/users/@me/lists');
-      params.pageToken = data.nextPageToken;
-
-      if (data.items?.length) {
-        for (const taskList of data.items.reverse()) {
-          $.pushTriggerItem({
-            raw: taskList,
-            meta: {
-              internalId: taskList.id,
-            },
-          });
-        }
-      }
-    } while (params.pageToken);
-  },
-});

packages/backend/src/apps/google-tasks/triggers/new-tasks/index.js

@@ -1,53 +0,0 @@
-import defineTrigger from '../../../../helpers/define-trigger.js';
-
-export default defineTrigger({
-  name: 'New tasks',
-  key: 'newTasks',
-  pollInterval: 15,
-  description: 'Triggers when a new task is created.',
-  arguments: [
-    {
-      label: 'Task List',
-      key: 'taskListId',
-      type: 'dropdown',
-      required: true,
-      description: '',
-      variables: true,
-      source: {
-        type: 'query',
-        name: 'getDynamicData',
-        arguments: [
-          {
-            name: 'key',
-            value: 'listTaskLists',
-          },
-        ],
-      },
-    },
-  ],
-
-  async run($) {
-    const taskListId = $.step.parameters.taskListId;
-
-    const params = {
-      maxResults: 100,
-      pageToken: undefined,
-    };
-
-    do {
-      const { data } = await $.http.get(`/tasks/v1/lists/${taskListId}/tasks`);
-      params.pageToken = data.nextPageToken;
-
-      if (data.items?.length) {
-        for (const task of data.items) {
-          $.pushTriggerItem({
-            raw: task,
-            meta: {
-              internalId: task.id,
-            },
-          });
-        }
-      }
-    } while (params.pageToken);
-  },
-});

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',