feat(wordpress): add find post action

fix(datastore): make value column text

.devcontainer/docker-compose.yml

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

docker/Dockerfile.cloud

@@ -1,24 +0,0 @@
-# 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:0.10.0
+FROM automatischio/automatisch:latest
 WORKDIR /automatisch
 
 RUN apk add --no-cache openssl dos2unix

docker/entrypoint-cloud.sh

@@ -1,13 +0,0 @@
-#!/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

packages/backend/bin/database/utils.js

@@ -2,6 +2,7 @@ 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';
@@ -21,6 +22,14 @@ 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();
@@ -37,6 +46,8 @@ 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

@@ -67,6 +67,7 @@
     "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"
   },

packages/backend/src/apps/airtable/actions/create-record/index.js

@@ -0,0 +1,92 @@
+import defineAction from '../../../../helpers/define-action.js';
+
+export default defineAction({
+  name: 'Create record',
+  key: 'createRecord',
+  description: 'Creates a new record with fields that automatically populate.',
+  arguments: [
+    {
+      label: 'Base',
+      key: 'baseId',
+      type: 'dropdown',
+      required: true,
+      description: 'Base in which to create the record.',
+      variables: true,
+      source: {
+        type: 'query',
+        name: 'getDynamicData',
+        arguments: [
+          {
+            name: 'key',
+            value: 'listBases',
+          },
+        ],
+      },
+    },
+    {
+      label: 'Table',
+      key: 'tableId',
+      type: 'dropdown',
+      required: true,
+      dependsOn: ['parameters.baseId'],
+      description: '',
+      variables: true,
+      source: {
+        type: 'query',
+        name: 'getDynamicData',
+        arguments: [
+          {
+            name: 'key',
+            value: 'listTables',
+          },
+          {
+            name: 'parameters.baseId',
+            value: '{parameters.baseId}',
+          },
+        ],
+      },
+      additionalFields: {
+        type: 'query',
+        name: 'getDynamicFields',
+        arguments: [
+          {
+            name: 'key',
+            value: 'listFields',
+          },
+          {
+            name: 'parameters.baseId',
+            value: '{parameters.baseId}',
+          },
+          {
+            name: 'parameters.tableId',
+            value: '{parameters.tableId}',
+          },
+        ],
+      },
+    },
+  ],
+
+  async run($) {
+    const { baseId, tableId, ...rest } = $.step.parameters;
+
+    const fields = Object.entries(rest).reduce((result, [key, value]) => {
+      if (Array.isArray(value)) {
+        result[key] = value.map((item) => item.value);
+      } else if (value !== '') {
+        result[key] = value;
+      }
+      return result;
+    }, {});
+
+    const body = {
+      typecast: true,
+      fields,
+    };
+
+    const { data } = await $.http.post(`/v0/${baseId}/${tableId}`, body);
+
+    $.setActionItem({
+      raw: data,
+    });
+  },
+});

packages/backend/src/apps/airtable/actions/find-record/index.js

@@ -0,0 +1,174 @@
+import defineAction from '../../../../helpers/define-action.js';
+import { URLSearchParams } from 'url';
+
+export default defineAction({
+  name: 'Find record',
+  key: 'findRecord',
+  description:
+    "Finds a record using simple field search or use Airtable's formula syntax to find a matching record.",
+  arguments: [
+    {
+      label: 'Base',
+      key: 'baseId',
+      type: 'dropdown',
+      required: true,
+      description: 'Base in which to create the record.',
+      variables: true,
+      source: {
+        type: 'query',
+        name: 'getDynamicData',
+        arguments: [
+          {
+            name: 'key',
+            value: 'listBases',
+          },
+        ],
+      },
+    },
+    {
+      label: 'Table',
+      key: 'tableId',
+      type: 'dropdown',
+      required: true,
+      dependsOn: ['parameters.baseId'],
+      description: '',
+      variables: true,
+      source: {
+        type: 'query',
+        name: 'getDynamicData',
+        arguments: [
+          {
+            name: 'key',
+            value: 'listTables',
+          },
+          {
+            name: 'parameters.baseId',
+            value: '{parameters.baseId}',
+          },
+        ],
+      },
+    },
+    {
+      label: 'Search by field',
+      key: 'tableField',
+      type: 'dropdown',
+      required: false,
+      dependsOn: ['parameters.baseId', 'parameters.tableId'],
+      description: '',
+      variables: true,
+      source: {
+        type: 'query',
+        name: 'getDynamicData',
+        arguments: [
+          {
+            name: 'key',
+            value: 'listTableFields',
+          },
+          {
+            name: 'parameters.baseId',
+            value: '{parameters.baseId}',
+          },
+          {
+            name: 'parameters.tableId',
+            value: '{parameters.tableId}',
+          },
+        ],
+      },
+    },
+    {
+      label: 'Search Value',
+      key: 'searchValue',
+      type: 'string',
+      required: false,
+      variables: true,
+      description:
+        'The value of unique identifier for the record. For date values, please use the ISO format (e.g., "YYYY-MM-DD").',
+    },
+    {
+      label: 'Search for exact match?',
+      key: 'exactMatch',
+      type: 'dropdown',
+      required: true,
+      description: '',
+      variables: true,
+      options: [
+        { label: 'Yes', value: 'true' },
+        { label: 'No', value: 'false' },
+      ],
+    },
+    {
+      label: 'Search Formula',
+      key: 'searchFormula',
+      type: 'string',
+      required: false,
+      variables: true,
+      description:
+        'Instead, you have the option to use an Airtable search formula for locating records according to sophisticated criteria and across various fields.',
+    },
+    {
+      label: 'Limit to View',
+      key: 'limitToView',
+      type: 'dropdown',
+      required: false,
+      dependsOn: ['parameters.baseId', 'parameters.tableId'],
+      description:
+        'You have the choice to restrict the search to a particular view ID if desired.',
+      variables: true,
+      source: {
+        type: 'query',
+        name: 'getDynamicData',
+        arguments: [
+          {
+            name: 'key',
+            value: 'listTableViews',
+          },
+          {
+            name: 'parameters.baseId',
+            value: '{parameters.baseId}',
+          },
+          {
+            name: 'parameters.tableId',
+            value: '{parameters.tableId}',
+          },
+        ],
+      },
+    },
+  ],
+
+  async run($) {
+    const {
+      baseId,
+      tableId,
+      tableField,
+      searchValue,
+      exactMatch,
+      searchFormula,
+      limitToView,
+    } = $.step.parameters;
+
+    let filterByFormula;
+
+    if (tableField && searchValue) {
+      filterByFormula =
+        exactMatch === 'true'
+          ? `{${tableField}} = '${searchValue}'`
+          : `LOWER({${tableField}}) = LOWER('${searchValue}')`;
+    } else {
+      filterByFormula = searchFormula;
+    }
+
+    const body = new URLSearchParams({
+      filterByFormula,
+      view: limitToView,
+    });
+
+    const { data } = await $.http.post(
+      `/v0/${baseId}/${tableId}/listRecords`,
+      body
+    );
+
+    $.setActionItem({
+      raw: data,
+    });
+  },
+});

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

@@ -0,0 +1,4 @@
+import createRecord from './create-record/index.js';
+import findRecord from './find-record/index.js';
+
+export default [createRecord, findRecord];

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

@@ -0,0 +1,9 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<svg width="256px" height="215px" viewBox="0 0 256 215" version="1.1" xmlns="http://www.w3.org/2000/svg" xmlns:xlink="http://www.w3.org/1999/xlink" preserveAspectRatio="xMidYMid">
+	<g>
+		<path d="M114.25873,2.70101695 L18.8604023,42.1756384 C13.5552723,44.3711638 13.6102328,51.9065311 18.9486282,54.0225085 L114.746142,92.0117514 C123.163769,95.3498757 132.537419,95.3498757 140.9536,92.0117514 L236.75256,54.0225085 C242.08951,51.9065311 242.145916,44.3711638 236.83934,42.1756384 L141.442459,2.70101695 C132.738459,-0.900338983 122.961284,-0.900338983 114.25873,2.70101695" fill="#FFBF00"></path>
+		<path d="M136.349071,112.756863 L136.349071,207.659101 C136.349071,212.173089 140.900664,215.263892 145.096461,213.600615 L251.844122,172.166219 C254.281184,171.200072 255.879376,168.845451 255.879376,166.224705 L255.879376,71.3224678 C255.879376,66.8084791 251.327783,63.7176768 247.131986,65.3809537 L140.384325,106.815349 C137.94871,107.781496 136.349071,110.136118 136.349071,112.756863" fill="#26B5F8"></path>
+		<path d="M111.422771,117.65355 L79.742409,132.949912 L76.5257763,134.504714 L9.65047684,166.548104 C5.4112904,168.593211 0.000578531073,165.503855 0.000578531073,160.794612 L0.000578531073,71.7210757 C0.000578531073,70.0173017 0.874160452,68.5463864 2.04568588,67.4384994 C2.53454463,66.9481944 3.08848814,66.5446689 3.66412655,66.2250305 C5.26231864,65.2661153 7.54173107,65.0101153 9.47981017,65.7766689 L110.890522,105.957098 C116.045234,108.002206 116.450206,115.225166 111.422771,117.65355" fill="#ED3049"></path>
+		<path d="M111.422771,117.65355 L79.742409,132.949912 L2.04568588,67.4384994 C2.53454463,66.9481944 3.08848814,66.5446689 3.66412655,66.2250305 C5.26231864,65.2661153 7.54173107,65.0101153 9.47981017,65.7766689 L110.890522,105.957098 C116.045234,108.002206 116.450206,115.225166 111.422771,117.65355" fill-opacity="0.25" fill="#000000"></path>
+	</g>
+</svg>

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

@@ -0,0 +1,38 @@
+import crypto from 'crypto';
+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 = crypto.randomBytes(100).toString('base64url');
+  const codeVerifier = crypto.randomBytes(96).toString('base64url');
+  const codeChallenge = crypto
+    .createHash('sha256')
+    .update(codeVerifier)
+    .digest('base64')
+    .replace(/=/g, '')
+    .replace(/\+/g, '-')
+    .replace(/\//g, '_');
+
+  const searchParams = new URLSearchParams({
+    client_id: $.auth.data.clientId,
+    redirect_uri: redirectUri,
+    response_type: 'code',
+    scope: authScope.join(' '),
+    state,
+    code_challenge: codeChallenge,
+    code_challenge_method: 'S256',
+  });
+
+  const url = `https://airtable.com/oauth2/v1/authorize?${searchParams.toString()}`;
+
+  await $.auth.set({
+    url,
+    originalCodeChallenge: codeChallenge,
+    originalState: state,
+    codeVerifier,
+  });
+}

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

@@ -0,0 +1,48 @@
+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/airtable/connections/add',
+      placeholder: null,
+      description:
+        'When asked to input a redirect URL in Airtable, enter the URL above.',
+      clickToCopy: true,
+    },
+    {
+      key: 'clientId',
+      label: 'Client ID',
+      type: 'string',
+      required: true,
+      readOnly: false,
+      value: null,
+      placeholder: null,
+      description: null,
+      clickToCopy: false,
+    },
+    {
+      key: 'clientSecret',
+      label: 'Client Secret',
+      type: 'string',
+      required: true,
+      readOnly: false,
+      value: null,
+      placeholder: null,
+      description: null,
+      clickToCopy: false,
+    },
+  ],
+
+  generateAuthUrl,
+  verifyCredentials,
+  isStillVerified,
+  refreshToken,
+};

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

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

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

@@ -0,0 +1,40 @@
+import { URLSearchParams } from 'node:url';
+
+import authScope from '../common/auth-scope.js';
+
+const refreshToken = async ($) => {
+  const params = new URLSearchParams({
+    client_id: $.auth.data.clientId,
+    grant_type: 'refresh_token',
+    refresh_token: $.auth.data.refreshToken,
+  });
+
+  const basicAuthToken = Buffer.from(
+    $.auth.data.clientId + ':' + $.auth.data.clientSecret
+  ).toString('base64');
+
+  const { data } = await $.http.post(
+    'https://airtable.com/oauth2/v1/token',
+    params.toString(),
+    {
+      headers: {
+        'Content-Type': 'application/x-www-form-urlencoded',
+        Authorization: `Basic ${basicAuthToken}`,
+      },
+      additionalProperties: {
+        skipAddingAuthHeader: true,
+      },
+    }
+  );
+
+  await $.auth.set({
+    accessToken: data.access_token,
+    refreshToken: data.refresh_token,
+    expiresIn: data.expires_in,
+    refreshExpiresIn: data.refresh_expires_in,
+    scope: authScope.join(' '),
+    tokenType: data.token_type,
+  });
+};
+
+export default refreshToken;

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

@@ -0,0 +1,56 @@
+import getCurrentUser from '../common/get-current-user.js';
+
+const verifyCredentials = async ($) => {
+  if ($.auth.data.originalState !== $.auth.data.state) {
+    throw new Error("The 'state' parameter does not match.");
+  }
+  if ($.auth.data.originalCodeChallenge !== $.auth.data.code_challenge) {
+    throw new Error("The 'code challenge' parameter does not match.");
+  }
+  const oauthRedirectUrlField = $.app.auth.fields.find(
+    (field) => field.key == 'oAuthRedirectUrl'
+  );
+  const redirectUri = oauthRedirectUrlField.value;
+  const basicAuthToken = Buffer.from(
+    $.auth.data.clientId + ':' + $.auth.data.clientSecret
+  ).toString('base64');
+
+  const { data } = await $.http.post(
+    'https://airtable.com/oauth2/v1/token',
+    {
+      code: $.auth.data.code,
+      client_id: $.auth.data.clientId,
+      redirect_uri: redirectUri,
+      grant_type: 'authorization_code',
+      code_verifier: $.auth.data.codeVerifier,
+    },
+    {
+      headers: {
+        'Content-Type': 'application/x-www-form-urlencoded',
+        Authorization: `Basic ${basicAuthToken}`,
+      },
+      additionalProperties: {
+        skipAddingAuthHeader: true,
+      },
+    }
+  );
+
+  await $.auth.set({
+    accessToken: data.access_token,
+    tokenType: data.token_type,
+  });
+
+  const currentUser = await getCurrentUser($);
+
+  await $.auth.set({
+    clientId: $.auth.data.clientId,
+    clientSecret: $.auth.data.clientSecret,
+    scope: $.auth.data.scope,
+    expiresIn: data.expires_in,
+    refreshExpiresIn: data.refresh_expires_in,
+    refreshToken: data.refresh_token,
+    screenName: currentUser.email,
+  });
+};
+
+export default verifyCredentials;

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

@@ -0,0 +1,12 @@
+const addAuthHeader = ($, requestConfig) => {
+  if (
+    !requestConfig.additionalProperties?.skipAddingAuthHeader &&
+    $.auth.data?.accessToken
+  ) {
+    requestConfig.headers.Authorization = `${$.auth.data.tokenType} ${$.auth.data.accessToken}`;
+  }
+
+  return requestConfig;
+};
+
+export default addAuthHeader;

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

@@ -0,0 +1,12 @@
+const authScope = [
+  'data.records:read',
+  'data.records:write',
+  'data.recordComments:read',
+  'data.recordComments:write',
+  'schema.bases:read',
+  'schema.bases:write',
+  'user.email:read',
+  'webhook:manage',
+];
+
+export default authScope;

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

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

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

@@ -0,0 +1,6 @@
+import listBases from './list-bases/index.js';
+import listTableFields from './list-table-fields/index.js';
+import listTableViews from './list-table-views/index.js';
+import listTables from './list-tables/index.js';
+
+export default [listBases, listTableFields, listTableViews, listTables];

packages/backend/src/apps/airtable/dynamic-data/list-bases/index.js

@@ -0,0 +1,28 @@
+export default {
+  name: 'List bases',
+  key: 'listBases',
+
+  async run($) {
+    const bases = {
+      data: [],
+    };
+
+    const params = {};
+
+    do {
+      const { data } = await $.http.get('/v0/meta/bases', { params });
+      params.offset = data.offset;
+
+      if (data?.bases) {
+        for (const base of data.bases) {
+          bases.data.push({
+            value: base.id,
+            name: base.name,
+          });
+        }
+      }
+    } while (params.offset);
+
+    return bases;
+  },
+};

packages/backend/src/apps/airtable/dynamic-data/list-table-fields/index.js

@@ -0,0 +1,39 @@
+export default {
+  name: 'List table fields',
+  key: 'listTableFields',
+
+  async run($) {
+    const tableFields = {
+      data: [],
+    };
+    const { baseId, tableId } = $.step.parameters;
+
+    if (!baseId) {
+      return tableFields;
+    }
+
+    const params = {};
+
+    do {
+      const { data } = await $.http.get(`/v0/meta/bases/${baseId}/tables`, {
+        params,
+      });
+      params.offset = data.offset;
+
+      if (data?.tables) {
+        for (const table of data.tables) {
+          if (table.id === tableId) {
+            table.fields.forEach((field) => {
+              tableFields.data.push({
+                value: field.name,
+                name: field.name,
+              });
+            });
+          }
+        }
+      }
+    } while (params.offset);
+
+    return tableFields;
+  },
+};

packages/backend/src/apps/airtable/dynamic-data/list-table-views/index.js

@@ -0,0 +1,39 @@
+export default {
+  name: 'List table views',
+  key: 'listTableViews',
+
+  async run($) {
+    const tableViews = {
+      data: [],
+    };
+    const { baseId, tableId } = $.step.parameters;
+
+    if (!baseId) {
+      return tableViews;
+    }
+
+    const params = {};
+
+    do {
+      const { data } = await $.http.get(`/v0/meta/bases/${baseId}/tables`, {
+        params,
+      });
+      params.offset = data.offset;
+
+      if (data?.tables) {
+        for (const table of data.tables) {
+          if (table.id === tableId) {
+            table.views.forEach((view) => {
+              tableViews.data.push({
+                value: view.id,
+                name: view.name,
+              });
+            });
+          }
+        }
+      }
+    } while (params.offset);
+
+    return tableViews;
+  },
+};

packages/backend/src/apps/airtable/dynamic-data/list-tables/index.js

@@ -0,0 +1,35 @@
+export default {
+  name: 'List tables',
+  key: 'listTables',
+
+  async run($) {
+    const tables = {
+      data: [],
+    };
+    const baseId = $.step.parameters.baseId;
+
+    if (!baseId) {
+      return tables;
+    }
+
+    const params = {};
+
+    do {
+      const { data } = await $.http.get(`/v0/meta/bases/${baseId}/tables`, {
+        params,
+      });
+      params.offset = data.offset;
+
+      if (data?.tables) {
+        for (const table of data.tables) {
+          tables.data.push({
+            value: table.id,
+            name: table.name,
+          });
+        }
+      }
+    } while (params.offset);
+
+    return tables;
+  },
+};

packages/backend/src/apps/airtable/dynamic-fields/index.js

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

packages/backend/src/apps/airtable/dynamic-fields/list-fields/index.js

@@ -0,0 +1,86 @@
+const hasValue = (value) => value !== null && value !== undefined;
+
+export default {
+  name: 'List fields',
+  key: 'listFields',
+
+  async run($) {
+    const options = [];
+    const { baseId, tableId } = $.step.parameters;
+
+    if (!hasValue(baseId) || !hasValue(tableId)) {
+      return;
+    }
+
+    const { data } = await $.http.get(`/v0/meta/bases/${baseId}/tables`);
+
+    const selectedTable = data.tables.find((table) => table.id === tableId);
+
+    if (!selectedTable) return;
+
+    selectedTable.fields.forEach((field) => {
+      if (field.type === 'singleSelect') {
+        options.push({
+          label: field.name,
+          key: field.name,
+          type: 'dropdown',
+          required: false,
+          variables: true,
+          options: field.options.choices.map((choice) => ({
+            label: choice.name,
+            value: choice.id,
+          })),
+        });
+      } else if (field.type === 'multipleSelects') {
+        options.push({
+          label: field.name,
+          key: field.name,
+          type: 'dynamic',
+          required: false,
+          variables: true,
+          fields: [
+            {
+              label: 'Value',
+              key: 'value',
+              type: 'dropdown',
+              required: false,
+              variables: true,
+              options: field.options.choices.map((choice) => ({
+                label: choice.name,
+                value: choice.id,
+              })),
+            },
+          ],
+        });
+      } else if (field.type === 'checkbox') {
+        options.push({
+          label: field.name,
+          key: field.name,
+          type: 'dropdown',
+          required: false,
+          variables: true,
+          options: [
+            {
+              label: 'Yes',
+              value: 'true',
+            },
+            {
+              label: 'No',
+              value: 'false',
+            },
+          ],
+        });
+      } else {
+        options.push({
+          label: field.name,
+          key: field.name,
+          type: 'string',
+          required: false,
+          variables: true,
+        });
+      }
+    });
+
+    return options;
+  },
+};

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

@@ -0,0 +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 dynamicData from './dynamic-data/index.js';
+import dynamicFields from './dynamic-fields/index.js';
+
+export default defineApp({
+  name: 'Airtable',
+  key: 'airtable',
+  baseUrl: 'https://airtable.com',
+  apiBaseUrl: 'https://api.airtable.com',
+  iconUrl: '{BASE_URL}/apps/airtable/assets/favicon.svg',
+  authDocUrl: '{DOCS_URL}/apps/airtable/connection',
+  primaryColor: 'FFBF00',
+  supportsConnections: true,
+  beforeRequest: [addAuthHeader],
+  auth,
+  actions,
+  dynamicData,
+  dynamicFields,
+});

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

@@ -0,0 +1 @@
+<svg xmlns:xlink="http://www.w3.org/1999/xlink" xmlns="http://www.w3.org/2000/svg" width="132" height="24" fill="none" viewBox="0 0 132 24"><path fill="#19191C" d="M38.557 19.495c2.16 0 3.25-1.113 3.725-1.87h.214c.094.805.664 1.562 1.779 1.562h2.111V16.82h-.545c-.38 0-.57-.213-.57-.545V6.776h-2.8v1.516h-.213c-.545-.758-1.684-1.824-3.772-1.824-3.321 0-5.789 2.748-5.789 6.514s2.515 6.513 5.86 6.513m.498-2.7c-1.969 0-3.51-1.445-3.51-3.79 0-2.297 1.494-3.86 3.487-3.86 1.898 0 3.487 1.397 3.487 3.86 0 2.108-1.352 3.79-3.463 3.79M48.04 24h2.799v-6.376h.213c.522.758 1.637 1.871 3.844 1.871 3.321 0 5.741-2.795 5.741-6.513 0-3.743-2.586-6.514-5.931-6.514-2.135 0-3.18 1.16-3.678 1.8h-.213V6.776h-2.776V24m6.263-7.134c-1.922 0-3.512-1.42-3.512-3.884 0-2.108 1.353-3.885 3.464-3.885 1.97 0 3.511 1.54 3.511 3.885 0 2.297-1.494 3.884-3.463 3.884M62.082 24h2.8v-6.376h.213c.522.758 1.637 1.871 3.843 1.871 3.321 0 5.51-2.795 5.51-6.513 0-3.743-2.355-6.514-5.7-6.514-2.135 0-3.179 1.16-3.677 1.8h-.214V6.776h-2.775zm6.263-7.134c-1.922 0-3.511-1.42-3.511-3.884 0-2.108 1.352-3.885 3.463-3.885 1.97 0 3.512 1.54 3.512 3.885 0 2.297-1.495 3.884-3.464 3.884m9.805 2.61h3.961l2.254-9.735h.143l2.253 9.735H90.7l3.153-12.412h-2.821l-2.254 9.759h-.214l-2.253-9.759h-3.725l-2.278 9.759h-.213l-2.23-9.759h-2.99l3.274 12.412m17.123 0h2.8V13.34c0-2.345 1.09-3.79 3.131-3.79h1.233V6.756h-.925c-1.59 0-2.8 1.09-3.274 2.132h-.19V7.064h-2.775zm21.057 0h2.183v-2.487h-2.159c-.854 0-1.21-.38-1.21-1.256V9.528h3.511V7.064h-3.511V3.582h-2.657v3.482h-2.325v2.464h2.159v6.229c0 2.63 1.589 3.719 4.009 3.719m9.693.019c2.586 0 4.864-1.279 5.67-3.86l-2.562-.616c-.451 1.373-1.755 2.084-3.131 2.084-2.041 0-3.393-1.326-3.417-3.41h9.419v-.782c0-3.695-2.301-6.443-6.097-6.443-3.346 0-6.216 2.63-6.216 6.537 0 3.79 2.538 6.49 6.334 6.49m-3.416-7.84c.166-1.492 1.518-2.747 3.298-2.747 1.708 0 3.108 1.066 3.25 2.747h-6.548"/><path fill="#19191C" fill-rule="evenodd" d="M108.916 19.476h-2.8V9.528h-2.182V7.064h4.982z" clip-rule="evenodd"/><path fill="#19191C" d="M107.309 5.342c1.02 0 1.779-.758 1.779-1.753 0-.971-.759-1.73-1.779-1.73-1.021 0-1.78.759-1.78 1.73 0 .995.759 1.753 1.78 1.753"/><path fill="#FD366E" d="M24.443 16.432v5.478H10.752c-3.989 0-7.472-2.203-9.335-5.478A11.041 11.041 0 0 1 0 11.695v-1.48a10.97 10.97 0 0 1 .381-2.247C1.661 3.368 5.82 0 10.751 0c4.934 0 9.092 3.37 10.371 7.967h-5.854c-.96-1.499-2.624-2.49-4.516-2.49s-3.555.991-4.516 2.49a5.47 5.47 0 0 0-.67 1.494 5.562 5.562 0 0 0-.202 1.494 5.5 5.5 0 0 0 1.69 3.983 5.32 5.32 0 0 0 3.698 1.494h13.69"/><path fill="#FD366E" d="M24.443 9.46v5.478h-9.994a5.5 5.5 0 0 0 1.691-3.983 5.56 5.56 0 0 0-.203-1.494h8.506"/></svg>

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

@@ -0,0 +1,65 @@
+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: 'projectId',
+      label: 'Project ID',
+      type: 'string',
+      required: true,
+      readOnly: false,
+      value: null,
+      placeholder: null,
+      description: 'Project ID of your Appwrite project.',
+      clickToCopy: false,
+    },
+    {
+      key: 'apiKey',
+      label: 'API Key',
+      type: 'string',
+      required: true,
+      readOnly: false,
+      value: null,
+      placeholder: null,
+      description: 'API key of your Appwrite project.',
+      clickToCopy: false,
+    },
+    {
+      key: 'instanceUrl',
+      label: 'Appwrite instance URL',
+      type: 'string',
+      required: false,
+      readOnly: false,
+      placeholder: '',
+      description: '',
+      clickToCopy: true,
+    },
+    {
+      key: 'host',
+      label: 'Host Name',
+      type: 'string',
+      required: true,
+      readOnly: false,
+      value: null,
+      placeholder: null,
+      description: 'Host name of your Appwrite project.',
+      clickToCopy: false,
+    },
+  ],
+
+  verifyCredentials,
+  isStillVerified,
+};

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

@@ -0,0 +1,5 @@
+const verifyCredentials = async ($) => {
+  await $.http.get('/v1/users');
+};
+
+export default verifyCredentials;

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

@@ -0,0 +1,16 @@
+const addAuthHeader = ($, requestConfig) => {
+  requestConfig.headers['Content-Type'] = 'application/json';
+
+  if ($.auth.data?.apiKey && $.auth.data?.projectId) {
+    requestConfig.headers['X-Appwrite-Project'] = $.auth.data.projectId;
+    requestConfig.headers['X-Appwrite-Key'] = $.auth.data.apiKey;
+  }
+
+  if ($.auth.data?.host) {
+    requestConfig.headers['Host'] = $.auth.data.host;
+  }
+
+  return requestConfig;
+};
+
+export default addAuthHeader;

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

@@ -0,0 +1,13 @@
+const setBaseUrl = ($, requestConfig) => {
+  const instanceUrl = $.auth.data.instanceUrl;
+
+  if (instanceUrl) {
+    requestConfig.baseURL = instanceUrl;
+  } else if ($.app.apiBaseUrl) {
+    requestConfig.baseURL = $.app.apiBaseUrl;
+  }
+
+  return requestConfig;
+};
+
+export default setBaseUrl;

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

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

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

@@ -0,0 +1,44 @@
+export default {
+  name: 'List collections',
+  key: 'listCollections',
+
+  async run($) {
+    const collections = {
+      data: [],
+    };
+    const databaseId = $.step.parameters.databaseId;
+
+    if (!databaseId) {
+      return collections;
+    }
+
+    const params = {
+      queries: [
+        JSON.stringify({
+          method: 'orderAsc',
+          attribute: 'name',
+        }),
+        JSON.stringify({
+          method: 'limit',
+          values: [100],
+        }),
+      ],
+    };
+
+    const { data } = await $.http.get(
+      `/v1/databases/${databaseId}/collections`,
+      { params }
+    );
+
+    if (data?.collections) {
+      for (const collection of data.collections) {
+        collections.data.push({
+          value: collection.$id,
+          name: collection.name,
+        });
+      }
+    }
+
+    return collections;
+  },
+};

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

@@ -0,0 +1,36 @@
+export default {
+  name: 'List databases',
+  key: 'listDatabases',
+
+  async run($) {
+    const databases = {
+      data: [],
+    };
+
+    const params = {
+      queries: [
+        JSON.stringify({
+          method: 'orderAsc',
+          attribute: 'name',
+        }),
+        JSON.stringify({
+          method: 'limit',
+          values: [100],
+        }),
+      ],
+    };
+
+    const { data } = await $.http.get('/v1/databases', { params });
+
+    if (data?.databases) {
+      for (const database of data.databases) {
+        databases.data.push({
+          value: database.$id,
+          name: database.name,
+        });
+      }
+    }
+
+    return databases;
+  },
+};

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

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

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

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

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

@@ -0,0 +1,104 @@
+import defineTrigger from '../../../../helpers/define-trigger.js';
+
+export default defineTrigger({
+  name: 'New documents',
+  key: 'newDocuments',
+  pollInterval: 15,
+  description: 'Triggers when a new document is created.',
+  arguments: [
+    {
+      label: 'Database',
+      key: 'databaseId',
+      type: 'dropdown',
+      required: true,
+      description: '',
+      variables: true,
+      source: {
+        type: 'query',
+        name: 'getDynamicData',
+        arguments: [
+          {
+            name: 'key',
+            value: 'listDatabases',
+          },
+        ],
+      },
+    },
+    {
+      label: 'Collection',
+      key: 'collectionId',
+      type: 'dropdown',
+      required: true,
+      dependsOn: ['parameters.databaseId'],
+      description: '',
+      variables: true,
+      source: {
+        type: 'query',
+        name: 'getDynamicData',
+        arguments: [
+          {
+            name: 'key',
+            value: 'listCollections',
+          },
+          {
+            name: 'parameters.databaseId',
+            value: '{parameters.databaseId}',
+          },
+        ],
+      },
+    },
+  ],
+
+  async run($) {
+    const { databaseId, collectionId } = $.step.parameters;
+
+    const limit = 1;
+    let lastDocumentId = undefined;
+    let offset = 0;
+    let documentCount = 0;
+
+    do {
+      const params = {
+        queries: [
+          JSON.stringify({
+            method: 'orderDesc',
+            attribute: '$createdAt',
+          }),
+          JSON.stringify({
+            method: 'limit',
+            values: [limit],
+          }),
+          // An invalid cursor shouldn't be sent.
+          lastDocumentId &&
+            JSON.stringify({
+              method: 'cursorAfter',
+              values: [lastDocumentId],
+            }),
+        ].filter(Boolean),
+      };
+
+      const { data } = await $.http.get(
+        `/v1/databases/${databaseId}/collections/${collectionId}/documents`,
+        { params }
+      );
+
+      const documents = data?.documents;
+      documentCount = documents?.length;
+      offset = offset + limit;
+      lastDocumentId = documents[documentCount - 1]?.$id;
+
+      if (!documentCount) {
+        return;
+      }
+
+      for (const document of documents) {
+        $.pushTriggerItem({
+          raw: document,
+          meta: {
+            internalId: document.$id,
+          },
+        });
+      }
+    } while (documentCount === limit);
+  },
+});

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

@@ -0,0 +1,16 @@
+<?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

@@ -0,0 +1,21 @@
+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

@@ -0,0 +1,48 @@
+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

@@ -0,0 +1,8 @@
+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

@@ -0,0 +1,26 @@
+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

@@ -0,0 +1,34 @@
+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

@@ -0,0 +1,15 @@
+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

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

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

@@ -0,0 +1,10 @@
+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

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

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

@@ -0,0 +1,36 @@
+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

@@ -0,0 +1,20 @@
+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

@@ -0,0 +1,4 @@
+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

@@ -0,0 +1,92 @@
+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

@@ -0,0 +1,60 @@
+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/formatter/actions/date-time/transformers/format-date-time.js

@@ -5,11 +5,24 @@ const formatDateTime = ($) => {
 
   const fromFormat = $.step.parameters.fromFormat;
   const fromTimezone = $.step.parameters.fromTimezone;
+  let inputDateTime;
 
-  const inputDateTime = DateTime.fromFormat(input, fromFormat, {
-    zone: fromTimezone,
-    setZone: true,
-  });
+  if (fromFormat === 'X') {
+    inputDateTime = DateTime.fromSeconds(Number(input), fromFormat, {
+      zone: fromTimezone,
+      setZone: true,
+    });
+  } else if (fromFormat === 'x') {
+    inputDateTime = DateTime.fromMillis(Number(input), fromFormat, {
+      zone: fromTimezone,
+      setZone: true,
+    });
+  } else {
+    inputDateTime = DateTime.fromFormat(input, fromFormat, {
+      zone: fromTimezone,
+      setZone: true,
+    });
+  }
 
   const toFormat = $.step.parameters.toFormat;
   const toTimezone = $.step.parameters.toTimezone;

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

@@ -2,6 +2,7 @@ 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';
@@ -10,12 +11,14 @@ 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,
@@ -24,6 +27,7 @@ const transformers = {
   pluralize,
   replace,
   stringToBase64,
+  encodeUri,
   trimWhitespace,
   useDefaultValue,
 };
@@ -43,6 +47,10 @@ 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' },
@@ -51,6 +59,7 @@ 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

@@ -0,0 +1,8 @@
+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

@@ -0,0 +1,8 @@
+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,5 +1,6 @@
 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';
@@ -8,6 +9,7 @@ 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';
@@ -19,6 +21,7 @@ import formatDateTime from './date-time/format-date-time.js';
 const options = {
   base64ToString,
   capitalize,
+  encodeUriComponent,
   extractEmailAddress,
   extractNumber,
   htmlToMarkdown,
@@ -27,6 +30,7 @@ const options = {
   pluralize,
   replace,
   stringToBase64,
+  encodeUri,
   trimWhitespace,
   useDefaultValue,
   performMathOperation,

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

@@ -0,0 +1,12 @@
+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

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

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

@@ -0,0 +1,31 @@
+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

@@ -0,0 +1,70 @@
+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

@@ -0,0 +1,57 @@
+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

@@ -0,0 +1,6 @@
+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

@@ -0,0 +1,108 @@
+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

@@ -0,0 +1,16 @@
+<?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/auth/generate-auth-url.js

@@ -0,0 +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 searchParams = new URLSearchParams({
+    client_id: $.auth.data.clientId,
+    redirect_uri: redirectUri,
+    prompt: 'select_account',
+    scope: authScope.join(' '),
+    response_type: 'code',
+    access_type: 'offline',
+  });
+
+  const url = `https://accounts.google.com/o/oauth2/v2/auth?${searchParams.toString()}`;
+
+  await $.auth.set({
+    url,
+  });
+}

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

@@ -0,0 +1,48 @@
+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/google-tasks/connections/add',
+      placeholder: null,
+      description:
+        'When asked to input a redirect URL in Google Cloud, enter the URL above.',
+      clickToCopy: true,
+    },
+    {
+      key: 'clientId',
+      label: 'Client ID',
+      type: 'string',
+      required: true,
+      readOnly: false,
+      value: null,
+      placeholder: null,
+      description: null,
+      clickToCopy: false,
+    },
+    {
+      key: 'clientSecret',
+      label: 'Client Secret',
+      type: 'string',
+      required: true,
+      readOnly: false,
+      value: null,
+      placeholder: null,
+      description: null,
+      clickToCopy: false,
+    },
+  ],
+
+  generateAuthUrl,
+  verifyCredentials,
+  isStillVerified,
+  refreshToken,
+};

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

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

packages/backend/src/apps/google-tasks/auth/refresh-token.js

@@ -0,0 +1,25 @@
+import { URLSearchParams } from 'node:url';
+import authScope from '../common/auth-scope.js';
+
+const refreshToken = async ($) => {
+  const params = new URLSearchParams({
+    client_id: $.auth.data.clientId,
+    client_secret: $.auth.data.clientSecret,
+    grant_type: 'refresh_token',
+    refresh_token: $.auth.data.refreshToken,
+  });
+
+  const { data } = await $.http.post(
+    'https://oauth2.googleapis.com/token',
+    params.toString()
+  );
+
+  await $.auth.set({
+    accessToken: data.access_token,
+    expiresIn: data.expires_in,
+    scope: authScope.join(' '),
+    tokenType: data.token_type,
+  });
+};
+
+export default refreshToken;

packages/backend/src/apps/google-tasks/auth/verify-credentials.js

@@ -0,0 +1,42 @@
+import getCurrentUser from '../common/get-current-user.js';
+
+const verifyCredentials = async ($) => {
+  const oauthRedirectUrlField = $.app.auth.fields.find(
+    (field) => field.key == 'oAuthRedirectUrl'
+  );
+  const redirectUri = oauthRedirectUrlField.value;
+  const { data } = await $.http.post(`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,
+  });
+
+  await $.auth.set({
+    accessToken: data.access_token,
+    tokenType: data.token_type,
+  });
+
+  const currentUser = await getCurrentUser($);
+
+  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,
+    resourceName: currentUser.resourceName,
+    screenName: `${displayName} - ${email}`,
+  });
+};
+
+export default verifyCredentials;

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

@@ -0,0 +1,9 @@
+const addAuthHeader = ($, requestConfig) => {
+  if ($.auth.data?.accessToken) {
+    requestConfig.headers.Authorization = `${$.auth.data.tokenType} ${$.auth.data.accessToken}`;
+  }
+
+  return requestConfig;
+};
+
+export default addAuthHeader;

packages/backend/src/apps/google-tasks/common/auth-scope.js

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

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

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

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

@@ -0,0 +1,4 @@
+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

@@ -0,0 +1,33 @@
+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

@@ -0,0 +1,40 @@
+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/index.js

@@ -0,0 +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';
+
+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',
+  supportsConnections: true,
+  beforeRequest: [addAuthHeader],
+  auth,
+  actions,
+  dynamicData,
+  triggers,
+});

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

@@ -0,0 +1,5 @@
+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

@@ -0,0 +1,59 @@
+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

@@ -0,0 +1,31 @@
+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

@@ -0,0 +1,53 @@
+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/monday/actions/create-board/index.js

@@ -1,70 +0,0 @@
-import defineAction from '../../../../helpers/define-action.js';
-
-export default defineAction({
-  name: 'Create board',
-  key: 'createBoard',
-  description: 'Creates a new board.',
-  arguments: [
-    {
-      label: 'Board Name',
-      key: 'boardName',
-      type: 'string',
-      required: true,
-      description: 'Title for the board.',
-      variables: true,
-    },
-    {
-      label: 'Board Kind',
-      key: 'boardKind',
-      type: 'dropdown',
-      required: true,
-      description: '',
-      variables: true,
-      options: [
-        {
-          label: 'Main',
-          value: 'public',
-        },
-        {
-          label: 'Private',
-          value: 'private',
-        },
-        {
-          label: 'Shareable',
-          value: 'share',
-        },
-      ],
-    },
-    {
-      label: 'Template ID',
-      key: 'templateId',
-      type: 'string',
-      required: false,
-      description:
-        "When you switch on developer mode, you'll spot the template IDs in your template store. Additionally, you have the option to utilize the Board ID from any board you've saved as a template.",
-      variables: true,
-    },
-  ],
-
-  async run($) {
-    const { boardName, boardKind, templateId } = $.step.parameters;
-
-    const body = {
-      query: `mutation {
-        create_board (board_name: "${boardName}", board_kind: ${boardKind}${
-        templateId ? `, template_id: ${templateId}` : ''
-      }) {
-          id
-          name
-          board_kind
-        }
-      }`,
-    };
-
-    const { data } = await $.http.post('/', body);
-
-    $.setActionItem({
-      raw: data,
-    });
-  },
-});

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

@@ -1,3 +0,0 @@
-import createBoard from './create-board/index.js';
-
-export default [createBoard];

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

@@ -1,8 +0,0 @@
-<?xml version="1.0" encoding="UTF-8"?>
-<svg width="256px" height="156px" viewBox="0 0 256 156" version="1.1" xmlns="http://www.w3.org/2000/svg" xmlns:xlink="http://www.w3.org/1999/xlink" preserveAspectRatio="xMidYMid">
-    <g>
-        <path d="M31.8458633,153.488694 C20.3244423,153.513586 9.68073708,147.337265 3.98575204,137.321731 C-1.62714067,127.367831 -1.29055839,115.129325 4.86093879,105.498969 L62.2342919,15.4033556 C68.2125882,5.54538256 79.032489,-0.333585033 90.5563073,0.0146553508 C102.071737,0.290611552 112.546041,6.74705604 117.96667,16.9106216 C123.315033,27.0238906 122.646488,39.1914174 116.240607,48.6847625 L58.9037201,138.780375 C52.9943022,147.988884 42.7873202,153.537154 31.8458633,153.488694 L31.8458633,153.488694 Z" fill="#F62B54"></path>
-        <path d="M130.25575,153.488484 C118.683837,153.488484 108.035731,147.301291 102.444261,137.358197 C96.8438154,127.431292 97.1804475,115.223704 103.319447,105.620522 L160.583402,15.7315506 C166.47539,5.73210989 177.327374,-0.284878136 188.929728,0.0146553508 C200.598885,0.269918151 211.174058,6.7973526 216.522421,17.0078646 C221.834319,27.2183766 221.056375,39.4588356 214.456008,48.9278699 L157.204209,138.816842 C151.313487,147.985468 141.153618,153.5168 130.25575,153.488484 Z" fill="#FFCC00"></path>
-        <ellipse fill="#00CA72" cx="226.465527" cy="125.324379" rx="29.5375538" ry="28.9176274"></ellipse>
-    </g>
-</svg>

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

@@ -1,21 +0,0 @@
-import verifyCredentials from './verify-credentials.js';
-import isStillVerified from './is-still-verified.js';
-
-export default {
-  fields: [
-    {
-      key: 'apiToken',
-      label: 'API Token',
-      type: 'string',
-      required: true,
-      readOnly: false,
-      value: null,
-      placeholder: null,
-      description: 'Monday.com API token of your account.',
-      clickToCopy: false,
-    },
-  ],
-
-  verifyCredentials,
-  isStillVerified,
-};

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

@@ -1,18 +0,0 @@
-const verifyCredentials = async ($) => {
-  const body = {
-    query: 'query { me { name, email } }',
-  };
-
-  const { data } = await $.http.post('/', body);
-
-  const screenName = [data.data.me.name, data.data.me.email]
-    .filter(Boolean)
-    .join(' @ ');
-
-  await $.auth.set({
-    screenName,
-    apiToken: $.auth.data.apiToken,
-  });
-};
-
-export default verifyCredentials;

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

@@ -1,9 +0,0 @@
-const addAuthHeader = ($, requestConfig) => {
-  if ($.auth.data?.apiToken) {
-    requestConfig.headers.Authorization = $.auth.data.apiToken;
-  }
-
-  return requestConfig;
-};
-
-export default addAuthHeader;

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

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

packages/backend/src/apps/monday/triggers/new-boards/index.js

@@ -1,29 +0,0 @@
-import defineTrigger from '../../../../helpers/define-trigger.js';
-
-export default defineTrigger({
-  name: 'New board',
-  key: 'newBoard',
-  pollInterval: 15,
-  description: 'Triggers when a new board is created.',
-
-  async run($) {
-    const body = {
-      query: 'query { boards { id, name } }',
-    };
-
-    const { data } = await $.http.post('/', body);
-
-    if (!data?.data?.boards?.length) {
-      return;
-    }
-
-    for (const board of data.data.boards) {
-      $.pushTriggerItem({
-        raw: board,
-        meta: {
-          internalId: board.id,
-        },
-      });
-    }
-  },
-});

packages/backend/src/apps/vtiger-crm/actions/create-case/fields.js

@@ -0,0 +1,408 @@
+export const fields = [
+  {
+    label: 'Summary',
+    key: 'summary',
+    type: 'string',
+    required: true,
+    description: '',
+    variables: true,
+  },
+  {
+    label: 'Record Currency',
+    key: 'recordCurrencyId',
+    type: 'dropdown',
+    required: false,
+    description: '',
+    variables: true,
+    source: {
+      type: 'query',
+      name: 'getDynamicData',
+      arguments: [
+        {
+          name: 'key',
+          value: 'listRecordCurrencies',
+        },
+      ],
+    },
+  },
+  {
+    label: 'Case Title',
+    key: 'caseTitle',
+    type: 'string',
+    required: true,
+    description: '',
+    variables: true,
+  },
+  {
+    label: 'Status',
+    key: 'status',
+    type: 'dropdown',
+    required: true,
+    description: '',
+    variables: true,
+    source: {
+      type: 'query',
+      name: 'getDynamicData',
+      arguments: [
+        {
+          name: 'key',
+          value: 'listCaseOptions',
+        },
+        {
+          name: 'parameters.status',
+          value: 'casestatus',
+        },
+      ],
+    },
+  },
+  {
+    label: 'Priority',
+    key: 'priority',
+    type: 'dropdown',
+    required: true,
+    description: '',
+    variables: true,
+    source: {
+      type: 'query',
+      name: 'getDynamicData',
+      arguments: [
+        {
+          name: 'key',
+          value: 'listCaseOptions',
+        },
+        {
+          name: 'parameters.priority',
+          value: 'casepriority',
+        },
+      ],
+    },
+  },
+  {
+    label: 'Contact',
+    key: 'contactId',
+    type: 'dropdown',
+    required: true,
+    description: '',
+    variables: true,
+    source: {
+      type: 'query',
+      name: 'getDynamicData',
+      arguments: [
+        {
+          name: 'key',
+          value: 'listContacts',
+        },
+      ],
+    },
+  },
+  {
+    label: 'Organization',
+    key: 'organizationId',
+    type: 'dropdown',
+    required: false,
+    description: '',
+    variables: true,
+    source: {
+      type: 'query',
+      name: 'getDynamicData',
+      arguments: [
+        {
+          name: 'key',
+          value: 'listOrganizations',
+        },
+      ],
+    },
+  },
+  {
+    label: 'Group',
+    key: 'groupId',
+    type: 'dropdown',
+    required: false,
+    description: '',
+    variables: true,
+    source: {
+      type: 'query',
+      name: 'getDynamicData',
+      arguments: [
+        {
+          name: 'key',
+          value: 'listGroups',
+        },
+      ],
+    },
+  },
+  {
+    label: 'Assigned To',
+    key: 'assignedTo',
+    type: 'string',
+    required: false,
+    description: '',
+    variables: true,
+  },
+  {
+    label: 'Product',
+    key: 'productId',
+    type: 'dropdown',
+    required: false,
+    description: '',
+    variables: true,
+    source: {
+      type: 'query',
+      name: 'getDynamicData',
+      arguments: [
+        {
+          name: 'key',
+          value: 'listProducts',
+        },
+      ],
+    },
+  },
+  {
+    label: 'Channel',
+    key: 'channel',
+    type: 'dropdown',
+    required: false,
+    description: '',
+    variables: true,
+    source: {
+      type: 'query',
+      name: 'getDynamicData',
+      arguments: [
+        {
+          name: 'key',
+          value: 'listCaseOptions',
+        },
+        {
+          name: 'parameters.channel',
+          value: 'casechannel',
+        },
+      ],
+    },
+  },
+  {
+    label: 'Resolution',
+    key: 'resolution',
+    type: 'string',
+    required: false,
+    description: '',
+    variables: true,
+  },
+  {
+    label: 'Category',
+    key: 'category',
+    type: 'dropdown',
+    required: false,
+    description: '',
+    variables: true,
+    source: {
+      type: 'query',
+      name: 'getDynamicData',
+      arguments: [
+        {
+          name: 'key',
+          value: 'listCaseOptions',
+        },
+        {
+          name: 'parameters.category',
+          value: 'impact_type',
+        },
+      ],
+    },
+  },
+  {
+    label: 'Sub Category',
+    key: 'subCategory',
+    type: 'dropdown',
+    required: false,
+    description: '',
+    variables: true,
+    source: {
+      type: 'query',
+      name: 'getDynamicData',
+      arguments: [
+        {
+          name: 'key',
+          value: 'listCaseOptions',
+        },
+        {
+          name: 'parameters.subCategory',
+          value: 'impact_area',
+        },
+      ],
+    },
+  },
+  {
+    label: 'Resolution Type',
+    key: 'resolutionType',
+    type: 'dropdown',
+    required: false,
+    description: '',
+    variables: true,
+    source: {
+      type: 'query',
+      name: 'getDynamicData',
+      arguments: [
+        {
+          name: 'key',
+          value: 'listCaseOptions',
+        },
+        {
+          name: 'parameters.resolutionType',
+          value: 'resolution_type',
+        },
+      ],
+    },
+  },
+  {
+    label: 'Deferred Date',
+    key: 'deferredDate',
+    type: 'string',
+    required: false,
+    description: 'format: yyyy-mm-dd',
+    variables: true,
+  },
+  {
+    label: 'Service Contract',
+    key: 'serviceContractId',
+    type: 'dropdown',
+    required: false,
+    description: '',
+    variables: true,
+    source: {
+      type: 'query',
+      name: 'getDynamicData',
+      arguments: [
+        {
+          name: 'key',
+          value: 'listServiceContracts',
+        },
+      ],
+    },
+  },
+  {
+    label: 'Asset',
+    key: 'assetId',
+    type: 'dropdown',
+    required: false,
+    description: '',
+    variables: true,
+    source: {
+      type: 'query',
+      name: 'getDynamicData',
+      arguments: [
+        {
+          name: 'key',
+          value: 'listAssets',
+        },
+      ],
+    },
+  },
+  {
+    label: 'SLA',
+    key: 'slaId',
+    type: 'dropdown',
+    required: false,
+    description: '',
+    variables: true,
+    source: {
+      type: 'query',
+      name: 'getDynamicData',
+      arguments: [
+        {
+          name: 'key',
+          value: 'listSlaNames',
+        },
+      ],
+    },
+  },
+  {
+    label: 'Is Billable',
+    key: 'isBillable',
+    type: 'dropdown',
+    required: false,
+    description: '',
+    variables: true,
+    options: [
+      { label: 'True', value: '1' },
+      { label: 'False', value: '-1' },
+    ],
+  },
+  {
+    label: 'Service',
+    key: 'service',
+    type: 'dropdown',
+    required: false,
+    description: '',
+    variables: true,
+    source: {
+      type: 'query',
+      name: 'getDynamicData',
+      arguments: [
+        {
+          name: 'key',
+          value: 'listServices',
+        },
+      ],
+    },
+  },
+  {
+    label: 'Rate',
+    key: 'rate',
+    type: 'string',
+    required: false,
+    description: '',
+    variables: true,
+  },
+  {
+    label: 'Service Type',
+    key: 'serviceType',
+    type: 'dropdown',
+    required: false,
+    description: '',
+    variables: true,
+    source: {
+      type: 'query',
+      name: 'getDynamicData',
+      arguments: [
+        {
+          name: 'key',
+          value: 'listCaseOptions',
+        },
+        {
+          name: 'parameters.serviceType',
+          value: 'servicetype',
+        },
+      ],
+    },
+  },
+  {
+    label: 'Service Location',
+    key: 'serviceLocation',
+    type: 'dropdown',
+    required: false,
+    description: '',
+    variables: true,
+    source: {
+      type: 'query',
+      name: 'getDynamicData',
+      arguments: [
+        {
+          name: 'key',
+          value: 'listCaseOptions',
+        },
+        {
+          name: 'parameters.serviceLocation',
+          value: 'servicelocation',
+        },
+      ],
+    },
+  },
+  {
+    label: 'Work Location',
+    key: 'workLocation',
+    type: 'string',
+    required: false,
+    description: '',
+    variables: true,
+  },
+];

packages/backend/src/apps/vtiger-crm/actions/create-case/index.js

@@ -0,0 +1,78 @@
+import defineAction from '../../../../helpers/define-action.js';
+import { fields } from './fields.js';
+
+export default defineAction({
+  name: 'Create case',
+  key: 'createCase',
+  description: 'Create a new case.',
+  arguments: fields,
+
+  async run($) {
+    const {
+      summary,
+      recordCurrencyId,
+      caseTitle,
+      status,
+      priority,
+      contactId,
+      organizationId,
+      groupId,
+      assignedTo,
+      productId,
+      channel,
+      resolution,
+      category,
+      subCategory,
+      resolutionType,
+      deferredDate,
+      serviceContractId,
+      assetId,
+      slaId,
+      isBillable,
+      service,
+      rate,
+      serviceType,
+      serviceLocation,
+      workLocation,
+    } = $.step.parameters;
+
+    const elementData = {
+      description: summary,
+      record_currency_id: recordCurrencyId,
+      title: caseTitle,
+      casestatus: status,
+      casepriority: priority,
+      contact_id: contactId,
+      parent_id: organizationId,
+      group_id: groupId,
+      assigned_user_id: assignedTo,
+      product_id: productId,
+      casechannel: channel,
+      resolution: resolution,
+      impact_type: category,
+      impact_area: subCategory,
+      resolution_type: resolutionType,
+      deferred_date: deferredDate,
+      servicecontract_id: serviceContractId,
+      asset_id: assetId,
+      slaid: slaId,
+      is_billable: isBillable,
+      billing_service: service,
+      rate: rate,
+      servicetype: serviceType,
+      servicelocation: serviceLocation,
+      work_location: workLocation,
+    };
+
+    const body = {
+      operation: 'create',
+      sessionName: $.auth.data.sessionName,
+      element: JSON.stringify(elementData),
+      elementType: 'Cases',
+    };
+
+    const response = await $.http.post('/webservice.php', body);
+
+    $.setActionItem({ raw: response.data });
+  },
+});

packages/backend/src/apps/vtiger-crm/actions/create-contact/fields.js

@@ -0,0 +1,649 @@
+export const fields = [
+  {
+    label: 'Salutation',
+    key: 'salutation',
+    type: 'dropdown',
+    required: false,
+    description: '',
+    variables: true,
+    options: [
+      { label: 'Mr.', value: 'Mr.' },
+      { label: 'Ms.', value: 'Ms.' },
+      { label: 'Mrs.', value: 'Mrs.' },
+      { label: 'Dr.', value: 'Dr.' },
+      { label: 'Prof.', value: 'Prof.' },
+    ],
+  },
+  {
+    label: 'First Name',
+    key: 'firstName',
+    type: 'string',
+    required: false,
+    description: '',
+    variables: true,
+  },
+  {
+    label: 'Last Name',
+    key: 'lastName',
+    type: 'string',
+    required: true,
+    description: '',
+    variables: true,
+  },
+  {
+    label: 'Primary Email',
+    key: 'primaryEmail',
+    type: 'string',
+    required: false,
+    description: '',
+    variables: true,
+  },
+  {
+    label: 'Office Phone',
+    key: 'officePhone',
+    type: 'string',
+    required: false,
+    description: '',
+    variables: true,
+  },
+  {
+    label: 'Mobile Phone',
+    key: 'mobilePhone',
+    type: 'string',
+    required: false,
+    description: '',
+    variables: true,
+  },
+  {
+    label: 'Home Phone',
+    key: 'homePhone',
+    type: 'string',
+    required: false,
+    description: '',
+    variables: true,
+  },
+  {
+    label: 'Date of Birth',
+    key: 'dateOfBirth',
+    type: 'string',
+    required: false,
+    description: 'format: yyyy-mm-dd',
+    variables: true,
+  },
+  {
+    label: 'Fax',
+    key: 'fax',
+    type: 'string',
+    required: false,
+    description: '',
+    variables: true,
+  },
+  {
+    label: 'Organization',
+    key: 'organizationId',
+    type: 'dropdown',
+    required: false,
+    description: '',
+    variables: true,
+    source: {
+      type: 'query',
+      name: 'getDynamicData',
+      arguments: [
+        {
+          name: 'key',
+          value: 'listOrganizations',
+        },
+      ],
+    },
+  },
+  {
+    label: 'Title',
+    key: 'title',
+    type: 'dropdown',
+    required: false,
+    description: '',
+    variables: true,
+    source: {
+      type: 'query',
+      name: 'getDynamicData',
+      arguments: [
+        {
+          name: 'key',
+          value: 'listContactOptions',
+        },
+        {
+          name: 'parameters.title',
+          value: 'listContactOptions',
+        },
+      ],
+    },
+  },
+  {
+    label: 'Department',
+    key: 'department',
+    type: 'string',
+    required: false,
+    description: '',
+    variables: true,
+  },
+  {
+    label: 'Reports To',
+    key: 'reportsTo',
+    type: 'dropdown',
+    required: false,
+    description: '',
+    variables: true,
+    source: {
+      type: 'query',
+      name: 'getDynamicData',
+      arguments: [
+        {
+          name: 'key',
+          value: 'listContacts',
+        },
+      ],
+    },
+  },
+  {
+    label: 'Lead Source',
+    key: 'leadSource',
+    type: 'dropdown',
+    required: false,
+    description: '',
+    variables: true,
+    source: {
+      type: 'query',
+      name: 'getDynamicData',
+      arguments: [
+        {
+          name: 'key',
+          value: 'listContactOptions',
+        },
+        {
+          name: 'parameters.leadSource',
+          value: 'leadsource',
+        },
+      ],
+    },
+  },
+  {
+    label: 'Secondary Email',
+    key: 'secondaryEmail',
+    type: 'string',
+    required: false,
+    description: '',
+    variables: true,
+  },
+  {
+    label: 'Assigned To',
+    key: 'assignedTo',
+    type: 'string',
+    required: false,
+    description: '',
+    variables: true,
+  },
+  {
+    label: 'Do Not Call',
+    key: 'doNotCall',
+    type: 'dropdown',
+    required: false,
+    description: '',
+    variables: true,
+    options: [
+      { label: 'True', value: '1' },
+      { label: 'False', value: '-1' },
+    ],
+  },
+  {
+    label: 'Notify Owner',
+    key: 'notifyOwner',
+    type: 'dropdown',
+    required: false,
+    description: '',
+    variables: true,
+    options: [
+      { label: 'True', value: '1' },
+      { label: 'False', value: '-1' },
+    ],
+  },
+  {
+    label: 'Twitter Username',
+    key: 'twitterUsername',
+    type: 'string',
+    required: false,
+    description: '',
+    variables: true,
+  },
+  {
+    label: 'SLA',
+    key: 'slaId',
+    type: 'dropdown',
+    required: false,
+    description: '',
+    variables: true,
+    source: {
+      type: 'query',
+      name: 'getDynamicData',
+      arguments: [
+        {
+          name: 'key',
+          value: 'listSlaNames',
+        },
+      ],
+    },
+  },
+  {
+    label: 'Lifecycle Stage',
+    key: 'lifecycleStage',
+    type: 'dropdown',
+    required: false,
+    description: '',
+    variables: true,
+    source: {
+      type: 'query',
+      name: 'getDynamicData',
+      arguments: [
+        {
+          name: 'key',
+          value: 'listContactOptions',
+        },
+        {
+          name: 'parameters.lifecycleStage',
+          value: 'contacttype',
+        },
+      ],
+    },
+  },
+  {
+    label: 'Status',
+    key: 'status',
+    type: 'dropdown',
+    required: false,
+    description: '',
+    variables: true,
+    source: {
+      type: 'query',
+      name: 'getDynamicData',
+      arguments: [
+        {
+          name: 'key',
+          value: 'listContactOptions',
+        },
+        {
+          name: 'parameters.status',
+          value: 'contactstatus',
+        },
+      ],
+    },
+  },
+  {
+    label: 'Happiness Rating',
+    key: 'happinessRating',
+    type: 'dropdown',
+    required: false,
+    description: '',
+    variables: true,
+    source: {
+      type: 'query',
+      name: 'getDynamicData',
+      arguments: [
+        {
+          name: 'key',
+          value: 'listContactOptions',
+        },
+        {
+          name: 'parameters.happinessRating',
+          value: 'happiness_rating',
+        },
+      ],
+    },
+  },
+  {
+    label: 'Record Currency',
+    key: 'recordCurrencyId',
+    type: 'dropdown',
+    required: false,
+    description: '',
+    variables: true,
+    source: {
+      type: 'query',
+      name: 'getDynamicData',
+      arguments: [
+        {
+          name: 'key',
+          value: 'listRecordCurrencies',
+        },
+      ],
+    },
+  },
+  {
+    label: 'Referred By',
+    key: 'referredBy',
+    type: 'dropdown',
+    required: false,
+    description: '',
+    variables: true,
+    source: {
+      type: 'query',
+      name: 'getDynamicData',
+      arguments: [
+        {
+          name: 'key',
+          value: 'listContacts',
+        },
+      ],
+    },
+  },
+  {
+    label: 'Email Opt-in',
+    key: 'emailOptin',
+    type: 'dropdown',
+    required: false,
+    description: '',
+    variables: true,
+    source: {
+      type: 'query',
+      name: 'getDynamicData',
+      arguments: [
+        {
+          name: 'key',
+          value: 'listContactOptions',
+        },
+        {
+          name: 'parameters.emailOptin',
+          value: 'emailoptin',
+        },
+      ],
+    },
+  },
+  {
+    label: 'SMS Opt-in',
+    key: 'smsOptin',
+    type: 'dropdown',
+    required: false,
+    description: '',
+    variables: true,
+    source: {
+      type: 'query',
+      name: 'getDynamicData',
+      arguments: [
+        {
+          name: 'key',
+          value: 'listContactOptions',
+        },
+        {
+          name: 'parameters.smsOptin',
+          value: 'smsoptin',
+        },
+      ],
+    },
+  },
+  {
+    label: 'Language',
+    key: 'language',
+    type: 'dropdown',
+    required: false,
+    description: '',
+    variables: true,
+    source: {
+      type: 'query',
+      name: 'getDynamicData',
+      arguments: [
+        {
+          name: 'key',
+          value: 'listContactOptions',
+        },
+        {
+          name: 'parameters.language',
+          value: 'language',
+        },
+      ],
+    },
+  },
+  {
+    label: 'Source Campaign',
+    key: 'sourceCampaignId',
+    type: 'dropdown',
+    required: false,
+    description: '',
+    variables: true,
+    source: {
+      type: 'query',
+      name: 'getDynamicData',
+      arguments: [
+        {
+          name: 'key',
+          value: 'listCampaignSources',
+        },
+      ],
+    },
+  },
+  {
+    label: 'Portal User',
+    key: 'portalUser',
+    type: 'dropdown',
+    required: false,
+    description: '',
+    variables: true,
+    options: [
+      { label: 'True', value: '1' },
+      { label: 'False', value: '-1' },
+    ],
+  },
+  {
+    label: 'Support Start Date',
+    key: 'supportStartDate',
+    type: 'string',
+    required: false,
+    description: 'format: yyyy-mm-dd',
+    variables: true,
+  },
+  {
+    label: 'Support End Date',
+    key: 'supportEndDate',
+    type: 'string',
+    required: false,
+    description: 'format: yyyy-mm-dd',
+    variables: true,
+  },
+  {
+    label: 'Other Country',
+    key: 'otherCountry',
+    type: 'dropdown',
+    required: false,
+    description: '',
+    variables: true,
+    source: {
+      type: 'query',
+      name: 'getDynamicData',
+      arguments: [
+        {
+          name: 'key',
+          value: 'listContactOptions',
+        },
+        {
+          name: 'parameters.otherCountry',
+          value: 'othercountry',
+        },
+      ],
+    },
+  },
+  {
+    label: 'Mailing Country',
+    key: 'mailingCountry',
+    type: 'dropdown',
+    required: false,
+    description: '',
+    variables: true,
+    source: {
+      type: 'query',
+      name: 'getDynamicData',
+      arguments: [
+        {
+          name: 'key',
+          value: 'listContactOptions',
+        },
+        {
+          name: 'parameters.mailingCountry',
+          value: 'mailingcountry',
+        },
+      ],
+    },
+  },
+  {
+    label: 'Mailing Street',
+    key: 'mailingStreet',
+    type: 'string',
+    required: false,
+    description: '',
+    variables: true,
+  },
+  {
+    label: 'Other Street',
+    key: 'otherStreet',
+    type: 'string',
+    required: false,
+    description: '',
+    variables: true,
+  },
+  {
+    label: 'Mailing PO Box',
+    key: 'mailingPoBox',
+    type: 'string',
+    required: false,
+    description: '',
+    variables: true,
+  },
+  {
+    label: 'Other PO Box',
+    key: 'otherPoBox',
+    type: 'string',
+    required: false,
+    description: '',
+    variables: true,
+  },
+  {
+    label: 'Mailing City',
+    key: 'mailingCity',
+    type: 'string',
+    required: false,
+    description: '',
+    variables: true,
+  },
+  {
+    label: 'Other City',
+    key: 'otherCity',
+    type: 'string',
+    required: false,
+    description: '',
+    variables: true,
+  },
+  {
+    label: 'Mailing State',
+    key: 'mailingState',
+    type: 'dropdown',
+    required: false,
+    description: '',
+    variables: true,
+    source: {
+      type: 'query',
+      name: 'getDynamicData',
+      arguments: [
+        {
+          name: 'key',
+          value: 'listContactOptions',
+        },
+        {
+          name: 'parameters.mailingState',
+          value: 'mailingstate',
+        },
+      ],
+    },
+  },
+  {
+    label: 'Other State',
+    key: 'otherState',
+    type: 'dropdown',
+    required: false,
+    description: '',
+    variables: true,
+    source: {
+      type: 'query',
+      name: 'getDynamicData',
+      arguments: [
+        {
+          name: 'key',
+          value: 'listContactOptions',
+        },
+        {
+          name: 'parameters.otherState',
+          value: 'otherstate',
+        },
+      ],
+    },
+  },
+  {
+    label: 'Mailing Zip',
+    key: 'mailingZip',
+    type: 'string',
+    required: false,
+    description: '',
+    variables: true,
+  },
+  {
+    label: 'Other Zip',
+    key: 'otherZip',
+    type: 'string',
+    required: false,
+    description: '',
+    variables: true,
+  },
+  {
+    label: 'Description',
+    key: 'description',
+    type: 'string',
+    required: false,
+    description: '',
+    variables: true,
+  },
+  {
+    label: 'Contact Image',
+    key: 'contactImage',
+    type: 'string',
+    required: false,
+    description: '',
+    variables: true,
+  },
+  {
+    label: 'Linkedin URL',
+    key: 'linkedinUrl',
+    type: 'string',
+    required: false,
+    description: '',
+    variables: true,
+  },
+  {
+    label: 'Linkedin Followers',
+    key: 'linkedinFollowers',
+    type: 'string',
+    required: false,
+    description: '',
+    variables: true,
+  },
+  {
+    label: 'Facebook URL',
+    key: 'facebookUrl',
+    type: 'string',
+    required: false,
+    description: '',
+    variables: true,
+  },
+  {
+    label: 'Facebook Followers',
+    key: 'facebookFollowers',
+    type: 'string',
+    required: false,
+    description: '',
+    variables: true,
+  },
+];

packages/backend/src/apps/vtiger-crm/actions/create-contact/index.js

@@ -0,0 +1,129 @@
+import defineAction from '../../../../helpers/define-action.js';
+import { fields } from './fields.js';
+
+export default defineAction({
+  name: 'Create contact',
+  key: 'createContact',
+  description: 'Create a new contact.',
+  arguments: fields,
+
+  async run($) {
+    const {
+      salutation,
+      firstName,
+      lastName,
+      primaryEmail,
+      officePhone,
+      mobilePhone,
+      homePhone,
+      dateOfBirth,
+      fax,
+      organizationId,
+      title,
+      department,
+      reportsTo,
+      leadSource,
+      secondaryEmail,
+      assignedTo,
+      doNotCall,
+      notifyOwner,
+      twitterUsername,
+      slaId,
+      lifecycleStage,
+      status,
+      happinessRating,
+      recordCurrencyId,
+      referredBy,
+      emailOptin,
+      smsOptin,
+      language,
+      sourceCampaignId,
+      portalUser,
+      supportStartDate,
+      supportEndDate,
+      otherCountry,
+      mailingCountry,
+      mailingStreet,
+      otherStreet,
+      mailingPoBox,
+      otherPoBox,
+      mailingCity,
+      otherCity,
+      mailingState,
+      otherState,
+      mailingZip,
+      otherZip,
+      description,
+      contactImage,
+      linkedinUrl,
+      linkedinFollowers,
+      facebookUrl,
+      facebookFollowers,
+    } = $.step.parameters;
+
+    const elementData = {
+      salutationtype: salutation,
+      firstname: firstName,
+      lastname: lastName,
+      email: primaryEmail,
+      phone: officePhone,
+      mobile: mobilePhone,
+      homephone: homePhone,
+      birthday: dateOfBirth,
+      fax: fax,
+      account_id: organizationId,
+      title: title,
+      department: department,
+      contact_id: reportsTo,
+      leadsource: leadSource,
+      secondaryemail: secondaryEmail,
+      assigned_user_id: assignedTo || $.auth.data.userId,
+      donotcall: doNotCall,
+      notify_owner: notifyOwner,
+      emailoptout: emailOptin,
+      primary_twitter: twitterUsername,
+      slaid: slaId,
+      contacttype: lifecycleStage,
+      contactstatus: status,
+      happiness_rating: happinessRating,
+      record_currency_id: recordCurrencyId,
+      referred_by: referredBy,
+      emailoptin: emailOptin,
+      smsoptin: smsOptin,
+      language: language,
+      source_campaign: sourceCampaignId,
+      portal: portalUser,
+      support_start_date: supportStartDate,
+      support_end_date: supportEndDate,
+      othercountry: otherCountry,
+      mailingcountry: mailingCountry,
+      mailingstreet: mailingStreet,
+      otherstreet: otherStreet,
+      mailingpobox: mailingPoBox,
+      otherpobox: otherPoBox,
+      mailingcity: mailingCity,
+      othercity: otherCity,
+      mailingstate: mailingState,
+      otherstate: otherState,
+      mailingzip: mailingZip,
+      otherzip: otherZip,
+      description: description,
+      imagename: contactImage,
+      primary_linkedin: linkedinUrl,
+      followers_linkedin: linkedinFollowers,
+      primary_facebook: facebookUrl,
+      followers_facebook: facebookFollowers,
+    };
+
+    const body = {
+      operation: 'create',
+      sessionName: $.auth.data.sessionName,
+      element: JSON.stringify(elementData),
+      elementType: 'Contacts',
+    };
+
+    const response = await $.http.post('/webservice.php', body);
+
+    $.setActionItem({ raw: response.data });
+  },
+});

packages/backend/src/apps/vtiger-crm/actions/create-lead/fields.js

@@ -0,0 +1,395 @@
+export const fields = [
+  {
+    label: 'Salutation',
+    key: 'salutation',
+    type: 'dropdown',
+    required: false,
+    description: '',
+    variables: true,
+    options: [
+      { label: 'Mr.', value: 'Mr.' },
+      { label: 'Ms.', value: 'Ms.' },
+      { label: 'Mrs.', value: 'Mrs.' },
+      { label: 'Dr.', value: 'Dr.' },
+      { label: 'Prof.', value: 'Prof.' },
+    ],
+  },
+  {
+    label: 'First Name',
+    key: 'firstName',
+    type: 'string',
+    required: false,
+    description: '',
+    variables: true,
+  },
+  {
+    label: 'Last Name',
+    key: 'lastName',
+    type: 'string',
+    required: true,
+    description: '',
+    variables: true,
+  },
+  {
+    label: 'Company',
+    key: 'company',
+    type: 'string',
+    required: false,
+    description: '',
+    variables: true,
+  },
+  {
+    label: 'Primary Email',
+    key: 'primaryEmail',
+    type: 'string',
+    required: false,
+    description: '',
+    variables: true,
+  },
+  {
+    label: 'Office Phone',
+    key: 'officePhone',
+    type: 'string',
+    required: false,
+    description: '',
+    variables: true,
+  },
+  {
+    label: 'Designation',
+    key: 'designation',
+    type: 'dropdown',
+    required: false,
+    description: '',
+    variables: true,
+    source: {
+      type: 'query',
+      name: 'getDynamicData',
+      arguments: [
+        {
+          name: 'key',
+          value: 'listLeadOptions',
+        },
+        {
+          name: 'parameters.designation',
+          value: 'designation',
+        },
+      ],
+    },
+  },
+  {
+    label: 'Mobile Phone',
+    key: 'mobilePhone',
+    type: 'string',
+    required: false,
+    description: '',
+    variables: true,
+  },
+  {
+    label: 'Industry',
+    key: 'industry',
+    type: 'dropdown',
+    required: false,
+    description: '',
+    variables: true,
+    source: {
+      type: 'query',
+      name: 'getDynamicData',
+      arguments: [
+        {
+          name: 'key',
+          value: 'listLeadOptions',
+        },
+        {
+          name: 'parameters.industry',
+          value: 'industry',
+        },
+      ],
+    },
+  },
+  {
+    label: 'Website',
+    key: 'website',
+    type: 'string',
+    required: false,
+    description: '',
+    variables: true,
+  },
+  {
+    label: 'Annual Revenue',
+    key: 'annualRevenue',
+    type: 'string',
+    required: false,
+    description: '',
+    variables: true,
+  },
+  {
+    label: 'Lead Source',
+    key: 'leadSource',
+    type: 'dropdown',
+    required: false,
+    description: '',
+    variables: true,
+    source: {
+      type: 'query',
+      name: 'getDynamicData',
+      arguments: [
+        {
+          name: 'key',
+          value: 'listLeadOptions',
+        },
+        {
+          name: 'parameters.leadSource',
+          value: 'leadsource',
+        },
+      ],
+    },
+  },
+  {
+    label: 'Lead Status',
+    key: 'leadStatus',
+    type: 'dropdown',
+    required: false,
+    description: '',
+    variables: true,
+    source: {
+      type: 'query',
+      name: 'getDynamicData',
+      arguments: [
+        {
+          name: 'key',
+          value: 'listLeadOptions',
+        },
+        {
+          name: 'parameters.leadStatus',
+          value: 'leadstatus',
+        },
+      ],
+    },
+  },
+  {
+    label: 'Assigned To',
+    key: 'assignedTo',
+    type: 'string',
+    required: false,
+    description: '',
+    variables: true,
+  },
+  {
+    label: 'Fax',
+    key: 'fax',
+    type: 'string',
+    required: false,
+    description: '',
+    variables: true,
+  },
+  {
+    label: 'Number of Employees',
+    key: 'numberOfEmployees',
+    type: 'string',
+    required: false,
+    description: '',
+    variables: true,
+  },
+  {
+    label: 'Twitter Username',
+    key: 'twitterUsername',
+    type: 'string',
+    required: false,
+    description: '',
+    variables: true,
+  },
+  {
+    label: 'Record Currency',
+    key: 'recordCurrencyId',
+    type: 'dropdown',
+    required: false,
+    description: '',
+    variables: true,
+    source: {
+      type: 'query',
+      name: 'getDynamicData',
+      arguments: [
+        {
+          name: 'key',
+          value: 'listRecordCurrencies',
+        },
+      ],
+    },
+  },
+  {
+    label: 'Email Opt-in',
+    key: 'emailOptin',
+    type: 'dropdown',
+    required: false,
+    description: '',
+    variables: true,
+    source: {
+      type: 'query',
+      name: 'getDynamicData',
+      arguments: [
+        {
+          name: 'key',
+          value: 'listLeadOptions',
+        },
+        {
+          name: 'parameters.emailOptin',
+          value: 'emailoptin',
+        },
+      ],
+    },
+  },
+  {
+    label: 'SMS Opt-in',
+    key: 'smsOptin',
+    type: 'dropdown',
+    required: false,
+    description: '',
+    variables: true,
+    source: {
+      type: 'query',
+      name: 'getDynamicData',
+      arguments: [
+        {
+          name: 'key',
+          value: 'listLeadOptions',
+        },
+        {
+          name: 'parameters.smsOptin',
+          value: 'smsoptin',
+        },
+      ],
+    },
+  },
+  {
+    label: 'Language',
+    key: 'language',
+    type: 'dropdown',
+    required: false,
+    description: '',
+    variables: true,
+    source: {
+      type: 'query',
+      name: 'getDynamicData',
+      arguments: [
+        {
+          name: 'key',
+          value: 'listLeadOptions',
+        },
+        {
+          name: 'parameters.language',
+          value: 'language',
+        },
+      ],
+    },
+  },
+  {
+    label: 'Source Campaign',
+    key: 'sourceCampaignId',
+    type: 'dropdown',
+    required: false,
+    description: '',
+    variables: true,
+    source: {
+      type: 'query',
+      name: 'getDynamicData',
+      arguments: [
+        {
+          name: 'key',
+          value: 'listCampaignSources',
+        },
+      ],
+    },
+  },
+  {
+    label: 'Country',
+    key: 'country',
+    type: 'dropdown',
+    required: false,
+    description: '',
+    variables: true,
+    source: {
+      type: 'query',
+      name: 'getDynamicData',
+      arguments: [
+        {
+          name: 'key',
+          value: 'listLeadOptions',
+        },
+        {
+          name: 'parameters.country',
+          value: 'country',
+        },
+      ],
+    },
+  },
+  {
+    label: 'Street',
+    key: 'street',
+    type: 'string',
+    required: false,
+    description: '',
+    variables: true,
+  },
+  {
+    label: 'PO Box',
+    key: 'poBox',
+    type: 'string',
+    required: false,
+    description: '',
+    variables: true,
+  },
+  {
+    label: 'Postal Code',
+    key: 'postalCode',
+    type: 'string',
+    required: false,
+    description: '',
+    variables: true,
+  },
+  {
+    label: 'City',
+    key: 'city',
+    type: 'string',
+    required: false,
+    description: '',
+    variables: true,
+  },
+  {
+    label: 'State',
+    key: 'state',
+    type: 'dropdown',
+    required: false,
+    description: '',
+    variables: true,
+    source: {
+      type: 'query',
+      name: 'getDynamicData',
+      arguments: [
+        {
+          name: 'key',
+          value: 'listLeadOptions',
+        },
+        {
+          name: 'parameters.state',
+          value: 'state',
+        },
+      ],
+    },
+  },
+  {
+    label: 'Description',
+    key: 'description',
+    type: 'string',
+    required: false,
+    description: '',
+    variables: true,
+  },
+  {
+    label: 'Lead Image',
+    key: 'leadImage',
+    type: 'string',
+    required: false,
+    description: '',
+    variables: true,
+  },
+];

packages/backend/src/apps/vtiger-crm/actions/create-lead/index.js

@@ -0,0 +1,88 @@
+import defineAction from '../../../../helpers/define-action.js';
+import { fields } from './fields.js';
+
+export default defineAction({
+  name: 'Create lead',
+  key: 'createLead',
+  description: 'Create a new lead.',
+  arguments: fields,
+
+  async run($) {
+    const {
+      salutation,
+      firstName,
+      lastName,
+      company,
+      primaryEmail,
+      officePhone,
+      designation,
+      mobilePhone,
+      industry,
+      website,
+      annualRevenue,
+      leadSource,
+      leadStatus,
+      assignedTo,
+      fax,
+      numberOfEmployees,
+      twitterUsername,
+      recordCurrencyId,
+      emailOptin,
+      smsOptin,
+      language,
+      sourceCampaignId,
+      country,
+      street,
+      poBox,
+      postalCode,
+      city,
+      state,
+      description,
+      leadImage,
+    } = $.step.parameters;
+
+    const elementData = {
+      salutationtype: salutation,
+      firstname: firstName,
+      lastname: lastName,
+      company: company,
+      email: primaryEmail,
+      phone: officePhone,
+      designation: designation,
+      mobile: mobilePhone,
+      industry: industry,
+      website: website,
+      annualrevenue: annualRevenue,
+      leadsource: leadSource,
+      leadstatus: leadStatus,
+      assigned_user_id: assignedTo || $.auth.data.userId,
+      fax: fax,
+      noofemployees: numberOfEmployees,
+      primary_twitter: twitterUsername,
+      record_currency_id: recordCurrencyId,
+      emailoptin: emailOptin,
+      smsoptin: smsOptin,
+      language: language,
+      source_campaign: sourceCampaignId,
+      country: country,
+      lane: street,
+      pobox: poBox,
+      code: postalCode,
+      city: city,
+      state: state,
+      description: description,
+      imagename: leadImage,
+    };
+
+    const body = {
+      operation: 'create',
+      sessionName: $.auth.data.sessionName,
+      element: JSON.stringify(elementData),
+      elementType: 'Leads',
+    };
+
+    const response = await $.http.post('/webservice.php', body);
+
+    $.setActionItem({ raw: response.data });
+  },
+});

packages/backend/src/apps/vtiger-crm/actions/create-opportunity/fields.js

@@ -0,0 +1,244 @@
+export const fields = [
+  {
+    label: 'Deal Name',
+    key: 'dealName',
+    type: 'string',
+    required: true,
+    description: '',
+    variables: true,
+  },
+  {
+    label: 'Amount',
+    key: 'amount',
+    type: 'string',
+    required: false,
+    description: '',
+    variables: true,
+  },
+  {
+    label: 'Organization',
+    key: 'organizationId',
+    type: 'dropdown',
+    required: false,
+    description: '',
+    variables: true,
+    source: {
+      type: 'query',
+      name: 'getDynamicData',
+      arguments: [
+        {
+          name: 'key',
+          value: 'listOrganizations',
+        },
+      ],
+    },
+  },
+  {
+    label: 'Contact',
+    key: 'contactId',
+    type: 'dropdown',
+    required: false,
+    description: '',
+    variables: true,
+    source: {
+      type: 'query',
+      name: 'getDynamicData',
+      arguments: [
+        {
+          name: 'key',
+          value: 'listContacts',
+        },
+      ],
+    },
+  },
+  {
+    label: 'Expected Close Date',
+    key: 'expectedCloseDate',
+    type: 'string',
+    required: true,
+    description: 'Format: yyyy-mm-dd',
+    variables: true,
+  },
+  {
+    label: 'Pipeline',
+    key: 'pipeline',
+    type: 'dropdown',
+    required: true,
+    value: 'Standart',
+    description: '',
+    variables: true,
+    options: [{ label: 'Standart', value: 'Standart' }],
+  },
+  {
+    label: 'Sales Stage',
+    key: 'salesStage',
+    type: 'dropdown',
+    required: false,
+    description: '',
+    variables: true,
+    source: {
+      type: 'query',
+      name: 'getDynamicData',
+      arguments: [
+        {
+          name: 'key',
+          value: 'listOpportunityOptions',
+        },
+        {
+          name: 'parameters.salesStage',
+          value: 'sales_stage',
+        },
+      ],
+    },
+  },
+  {
+    label: 'Assigned To',
+    key: 'assignedTo',
+    type: 'string',
+    required: false,
+    description: 'Default is the id of the account connected to Automatisch.',
+    variables: true,
+  },
+  {
+    label: 'Lead Source',
+    key: 'leadSource',
+    type: 'dropdown',
+    required: false,
+    description: '',
+    variables: true,
+    source: {
+      type: 'query',
+      name: 'getDynamicData',
+      arguments: [
+        {
+          name: 'key',
+          value: 'listOpportunityOptions',
+        },
+        {
+          name: 'parameters.leadSource',
+          value: 'leadsource',
+        },
+      ],
+    },
+  },
+  {
+    label: 'Next Step',
+    key: 'nextStep',
+    type: 'string',
+    required: false,
+    description: '',
+    variables: true,
+  },
+  {
+    label: 'Type',
+    key: 'type',
+    type: 'dropdown',
+    required: false,
+    description: '',
+    variables: true,
+    source: {
+      type: 'query',
+      name: 'getDynamicData',
+      arguments: [
+        {
+          name: 'key',
+          value: 'listOpportunityOptions',
+        },
+        {
+          name: 'parameters.type',
+          value: 'opportunity_type',
+        },
+      ],
+    },
+  },
+  {
+    label: 'Probability',
+    key: 'probability',
+    type: 'string',
+    required: false,
+    description: '',
+    variables: true,
+  },
+  {
+    label: 'Campaign Source',
+    key: 'campaignSourceId',
+    type: 'dropdown',
+    required: false,
+    description: '',
+    variables: true,
+    source: {
+      type: 'query',
+      name: 'getDynamicData',
+      arguments: [
+        {
+          name: 'key',
+          value: 'listCampaignSources',
+        },
+      ],
+    },
+  },
+  {
+    label: 'Weighted Revenue',
+    key: 'weightedRevenue',
+    type: 'string',
+    required: false,
+    description: '',
+    variables: true,
+  },
+  {
+    label: 'Adjusted Amount',
+    key: 'adjustedAmount',
+    type: 'string',
+    required: false,
+    description: '',
+    variables: true,
+  },
+  {
+    label: 'Lost Reason',
+    key: 'lostReason',
+    type: 'dropdown',
+    required: false,
+    description: '',
+    variables: true,
+    source: {
+      type: 'query',
+      name: 'getDynamicData',
+      arguments: [
+        {
+          name: 'key',
+          value: 'listOpportunityOptions',
+        },
+        {
+          name: 'parameters.lostReason',
+          value: 'lost_reason',
+        },
+      ],
+    },
+  },
+  {
+    label: 'Record Currency',
+    key: 'recordCurrencyId',
+    type: 'dropdown',
+    required: false,
+    description: '',
+    variables: true,
+    source: {
+      type: 'query',
+      name: 'getDynamicData',
+      arguments: [
+        {
+          name: 'key',
+          value: 'listRecordCurrencies',
+        },
+      ],
+    },
+  },
+  {
+    label: 'Description',
+    key: 'description',
+    type: 'string',
+    required: false,
+    description: '',
+    variables: true,
+  },
+];

packages/backend/src/apps/vtiger-crm/actions/create-opportunity/index.js

@@ -0,0 +1,64 @@
+import defineAction from '../../../../helpers/define-action.js';
+import { fields } from './fields.js';
+
+export default defineAction({
+  name: 'Create opportunity',
+  key: 'createOpportunity',
+  description: 'Create a new opportunity.',
+  arguments: fields,
+
+  async run($) {
+    const {
+      dealName,
+      amount,
+      organizationId,
+      contactId,
+      expectedCloseDate,
+      pipeline,
+      salesStage,
+      assignedTo,
+      leadSource,
+      nextStep,
+      type,
+      probability,
+      campaignSourceId,
+      weightedRevenue,
+      adjustedAmount,
+      lostReason,
+      recordCurrencyId,
+      description,
+    } = $.step.parameters;
+
+    const elementData = {
+      potentialname: dealName,
+      amount,
+      related_to: organizationId,
+      contact_id: contactId,
+      closingdate: expectedCloseDate,
+      pipeline,
+      sales_stage: salesStage,
+      assigned_user_id: assignedTo || $.auth.data.userId,
+      leadsource: leadSource,
+      nextstep: nextStep,
+      opportunity_type: type,
+      probability: probability,
+      campaignid: campaignSourceId,
+      forecast_amount: weightedRevenue,
+      adjusted_amount: adjustedAmount,
+      lost_reason: lostReason,
+      record_currency_id: recordCurrencyId,
+      description,
+    };
+
+    const body = {
+      operation: 'create',
+      sessionName: $.auth.data.sessionName,
+      element: JSON.stringify(elementData),
+      elementType: 'Potentials',
+    };
+
+    const response = await $.http.post('/webservice.php', body);
+
+    $.setActionItem({ raw: response.data });
+  },
+});

packages/backend/src/apps/vtiger-crm/actions/create-todo/fields.js

@@ -0,0 +1,357 @@
+export const fields = [
+  {
+    label: 'Name',
+    key: 'name',
+    type: 'string',
+    required: true,
+    description: '',
+    variables: true,
+  },
+  {
+    label: 'Assigned To',
+    key: 'assignedTo',
+    type: 'string',
+    required: false,
+    description: 'Default is the id of the account connected to Automatisch.',
+    variables: true,
+  },
+  {
+    label: 'Start Date & Time',
+    key: 'startDateAndTime',
+    type: 'string',
+    required: false,
+    description: 'Format: yyyy-mm-dd',
+    variables: true,
+  },
+  {
+    label: 'Due Date',
+    key: 'dueDate',
+    type: 'string',
+    required: false,
+    description: 'Format: yyyy-mm-dd',
+    variables: true,
+  },
+  {
+    label: 'Stage',
+    key: 'stage',
+    type: 'dropdown',
+    required: true,
+    description: '',
+    variables: true,
+    source: {
+      type: 'query',
+      name: 'getDynamicData',
+      arguments: [
+        {
+          name: 'key',
+          value: 'listTodoOptions',
+        },
+        {
+          name: 'parameters.stage',
+          value: 'taskstatus',
+        },
+      ],
+    },
+  },
+  {
+    label: 'Contact',
+    key: 'contactId',
+    type: 'dropdown',
+    required: false,
+    description: '',
+    variables: true,
+    source: {
+      type: 'query',
+      name: 'getDynamicData',
+      arguments: [
+        {
+          name: 'key',
+          value: 'listContacts',
+        },
+      ],
+    },
+  },
+  {
+    label: 'Priority',
+    key: 'priority',
+    type: 'dropdown',
+    required: true,
+    description: '',
+    variables: true,
+    options: [
+      { label: 'High', value: 'High' },
+      { label: 'Medium', value: 'Medium' },
+      { label: 'Low', value: 'Low' },
+    ],
+  },
+  {
+    label: 'Send Notification',
+    key: 'sendNotification',
+    type: 'dropdown',
+    required: false,
+    description: '',
+    variables: true,
+    options: [
+      { label: 'True', value: 'true' },
+      { label: 'False', value: 'false' },
+    ],
+  },
+  {
+    label: 'Location',
+    key: 'location',
+    type: 'string',
+    required: false,
+    description: '',
+    variables: true,
+  },
+  {
+    label: 'Record Currency',
+    key: 'recordCurrencyId',
+    type: 'dropdown',
+    required: false,
+    description: '',
+    variables: true,
+    source: {
+      type: 'query',
+      name: 'getDynamicData',
+      arguments: [
+        {
+          name: 'key',
+          value: 'listRecordCurrencies',
+        },
+      ],
+    },
+  },
+  {
+    label: 'Milestone',
+    key: 'milestone',
+    type: 'dropdown',
+    required: false,
+    description: '',
+    variables: true,
+    source: {
+      type: 'query',
+      name: 'getDynamicData',
+      arguments: [
+        {
+          name: 'key',
+          value: 'listMilestones',
+        },
+      ],
+    },
+  },
+  {
+    label: 'Previous Task',
+    key: 'previousTask',
+    type: 'dropdown',
+    required: false,
+    description: '',
+    variables: true,
+    source: {
+      type: 'query',
+      name: 'getDynamicData',
+      arguments: [
+        {
+          name: 'key',
+          value: 'listTasks',
+        },
+      ],
+    },
+  },
+  {
+    label: 'Parent Task',
+    key: 'parentTask',
+    type: 'dropdown',
+    required: false,
+    description: '',
+    variables: true,
+    source: {
+      type: 'query',
+      name: 'getDynamicData',
+      arguments: [
+        {
+          name: 'key',
+          value: 'listTasks',
+        },
+      ],
+    },
+  },
+  {
+    label: 'Task Type',
+    key: 'taskType',
+    type: 'dropdown',
+    required: true,
+    description: '',
+    variables: true,
+    source: {
+      type: 'query',
+      name: 'getDynamicData',
+      arguments: [
+        {
+          name: 'key',
+          value: 'listTodoOptions',
+        },
+        {
+          name: 'parameters.taskType',
+          value: 'tasktype',
+        },
+      ],
+    },
+  },
+  {
+    label: 'Skipped Reason',
+    key: 'skippedReason',
+    type: 'dropdown',
+    required: false,
+    description: '',
+    variables: true,
+    source: {
+      type: 'query',
+      name: 'getDynamicData',
+      arguments: [
+        {
+          name: 'key',
+          value: 'listTodoOptions',
+        },
+        {
+          name: 'parameters.skippedReason',
+          value: 'skipped_reason',
+        },
+      ],
+    },
+  },
+  {
+    label: 'Estimate',
+    key: 'estimate',
+    type: 'string',
+    required: false,
+    description: '',
+    variables: true,
+  },
+  {
+    label: 'Related Task',
+    key: 'relatedTask',
+    type: 'dropdown',
+    required: false,
+    description: '',
+    variables: true,
+    source: {
+      type: 'query',
+      name: 'getDynamicData',
+      arguments: [
+        {
+          name: 'key',
+          value: 'listTasks',
+        },
+      ],
+    },
+  },
+  {
+    label: 'Project',
+    key: 'projectId',
+    type: 'dropdown',
+    required: false,
+    description: '',
+    variables: true,
+    source: {
+      type: 'query',
+      name: 'getDynamicData',
+      arguments: [
+        {
+          name: 'key',
+          value: 'listProjects',
+        },
+      ],
+    },
+  },
+  {
+    label: 'Organization',
+    key: 'organizationId',
+    type: 'dropdown',
+    required: false,
+    description: '',
+    variables: true,
+    source: {
+      type: 'query',
+      name: 'getDynamicData',
+      arguments: [
+        {
+          name: 'key',
+          value: 'listOrganizations',
+        },
+      ],
+    },
+  },
+  {
+    label: 'Send Email Reminder Before',
+    key: 'sendEmailReminderBefore',
+    type: 'string',
+    required: false,
+    description: '',
+    variables: true,
+  },
+  {
+    label: 'Description',
+    key: 'description',
+    type: 'string',
+    required: false,
+    description: '',
+    variables: true,
+  },
+  {
+    label: 'Is Billable',
+    key: 'isBillable',
+    type: 'dropdown',
+    required: false,
+    description: '',
+    variables: true,
+    options: [
+      { label: 'True', value: '1' },
+      { label: 'False', value: '-1' },
+    ],
+  },
+  {
+    label: 'Service',
+    key: 'service',
+    type: 'dropdown',
+    required: false,
+    description: '',
+    variables: true,
+    source: {
+      type: 'query',
+      name: 'getDynamicData',
+      arguments: [
+        {
+          name: 'key',
+          value: 'listServices',
+        },
+      ],
+    },
+  },
+  {
+    label: 'Rate',
+    key: 'rate',
+    type: 'string',
+    required: false,
+    description: '',
+    variables: true,
+  },
+  {
+    label: 'SLA',
+    key: 'slaId',
+    type: 'dropdown',
+    required: false,
+    description: '',
+    variables: true,
+    source: {
+      type: 'query',
+      name: 'getDynamicData',
+      arguments: [
+        {
+          name: 'key',
+          value: 'listSlaNames',
+        },
+      ],
+    },
+  },
+];

packages/backend/src/apps/vtiger-crm/actions/create-todo/index.js

@@ -0,0 +1,78 @@
+import defineAction from '../../../../helpers/define-action.js';
+import { fields } from './fields.js';
+
+export default defineAction({
+  name: 'Create todo',
+  key: 'createTodo',
+  description: 'Create a new todo.',
+  arguments: fields,
+
+  async run($) {
+    const {
+      name,
+      assignedTo,
+      startDateAndTime,
+      dueDate,
+      stage,
+      contactId,
+      priority,
+      sendNotification,
+      location,
+      recordCurrencyId,
+      milestone,
+      previousTask,
+      parentTask,
+      taskType,
+      skippedReason,
+      estimate,
+      relatedTask,
+      projectId,
+      organizationId,
+      sendEmailReminderBefore,
+      description,
+      isBillable,
+      service,
+      rate,
+      slaId,
+    } = $.step.parameters;
+
+    const elementData = {
+      subject: name,
+      assigned_user_id: assignedTo || $.auth.data.userId,
+      date_start: startDateAndTime,
+      due_date: dueDate,
+      taskstatus: stage,
+      contact_id: contactId,
+      taskpriority: priority,
+      sendnotification: sendNotification,
+      location: location,
+      record_currency_id: recordCurrencyId,
+      milestone: milestone,
+      dependent_on: previousTask,
+      parent_task: parentTask,
+      tasktype: taskType,
+      skipped_reason: skippedReason,
+      estimate: estimate,
+      related_task: relatedTask,
+      related_project: projectId,
+      account_id: organizationId,
+      reminder_time: sendEmailReminderBefore,
+      description: description,
+      is_billable: isBillable,
+      billing_service: service,
+      rate: rate,
+      slaid: slaId,
+    };
+
+    const body = {
+      operation: 'create',
+      sessionName: $.auth.data.sessionName,
+      element: JSON.stringify(elementData),
+      elementType: 'Calendar',
+    };
+
+    const response = await $.http.post('/webservice.php', body);
+
+    $.setActionItem({ raw: response.data });
+  },
+});