feat(bigin-by-zoho-crm): add create task action

.devcontainer/boot.sh

@@ -28,7 +28,7 @@ cd packages/web
 rm -rf .env
 echo "
 PORT=$WEB_PORT
-REACT_APP_BACKEND_URL=http://localhost:$BACKEND_PORT
+REACT_APP_GRAPHQL_URL=http://localhost:$BACKEND_PORT/graphql
 " >> .env
 cd $CURRENT_DIR
 

.dockerignore

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

.eslintrc.js

@@ -0,0 +1,18 @@
+module.exports = {
+  root: true,
+  parser: '@typescript-eslint/parser',
+  plugins: ['@typescript-eslint'],
+  extends: [
+    'eslint:recommended',
+    'plugin:@typescript-eslint/recommended',
+    'prettier',
+  ],
+  overrides: [
+    {
+      files: ['**/*.test.ts', '**/test/**/*.ts'],
+      rules: {
+        '@typescript-eslint/ban-ts-comment': ['off'],
+      },
+    },
+  ],
+};

.github/workflows/ci.yml

@@ -22,7 +22,7 @@ jobs:
       - run: echo "💡 The ${{ github.repository }} repository has been cloned to the runner."
       - run: echo "🖥️ The workflow is now ready to test your code on the runner."
       - run: yarn --frozen-lockfile
-      - run: cd packages/backend && yarn lint
+      - run: yarn lint
       - run: echo "🍏 This job's status is ${{ job.status }}."
   start-backend-server:
     runs-on: ubuntu-latest

.github/workflows/docs-change.yml

@@ -1,32 +0,0 @@
-name: Automatisch Docs Change
-on:
-  pull_request:
-    paths:
-      - 'packages/docs/**'
-jobs:
-  label:
-    runs-on: ubuntu-latest
-    steps:
-      - name: Checkout repository
-        uses: actions/checkout@v3
-      - name: Label PR
-        uses: actions/github-script@v6
-        with:
-          script: |
-            const { pull_request } = context.payload;
-
-            const label = 'documentation-change';
-            const hasLabel = pull_request.labels.some(({ name }) => name === label);
-
-            if (!hasLabel) {
-              await github.rest.issues.addLabels({
-                owner: context.repo.owner,
-                repo: context.repo.repo,
-                issue_number: pull_request.number,
-                labels: [label],
-              });
-
-              console.log(`Label "${label}" added to PR #${pull_request.number}`);
-            } else {
-              console.log(`Label "${label}" already exists on PR #${pull_request.number}`);
-            }

.github/workflows/playwright.yml

@@ -62,9 +62,8 @@ jobs:
         run: yarn && yarn lerna bootstrap
       - name: Install Playwright Browsers
         run: yarn playwright install --with-deps
-      - name: Build Automatisch web
+      - name: Build Automatisch
-        working-directory: ./packages/web
+        run: yarn lerna run --scope=@*/{web,cli} build
-        run: yarn build
         env:
           # Keep this until we clean up warnings in build processes
           CI: false

docker/Dockerfile

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

docker/entrypoint.sh

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

package.json

@@ -6,6 +6,7 @@
     "start": "lerna run --stream --parallel --scope=@*/{web,backend} dev",
     "start:web": "lerna run --stream --scope=@*/web dev",
     "start:backend": "lerna run --stream --scope=@*/backend dev",
+    "lint": "lerna run --no-bail --stream --parallel --scope=@*/{web,backend} lint",
     "build:docs": "cd ./packages/docs && yarn install && yarn build"
   },
   "workspaces": {
@@ -20,6 +21,8 @@
     ]
   },
   "devDependencies": {
+    "@typescript-eslint/eslint-plugin": "^5.9.1",
+    "@typescript-eslint/parser": "^5.9.1",
     "eslint": "^8.13.0",
     "eslint-config-prettier": "^8.3.0",
     "eslint-plugin-prettier": "^4.0.0",

packages/backend/package.json

@@ -11,7 +11,7 @@
     "start:worker": "node src/worker.js",
     "pretest": "APP_ENV=test node ./test/setup/prepare-test-env.js",
     "test": "APP_ENV=test vitest run",
-    "lint": "eslint .",
+    "lint": "eslint . --ignore-path ../../.eslintignore",
     "db:create": "node ./bin/database/create.js",
     "db:seed:user": "node ./bin/database/seed-user.js",
     "db:drop": "node ./bin/database/drop.js",
@@ -31,14 +31,13 @@
     "accounting": "^0.4.1",
     "ajv-formats": "^2.1.1",
     "axios": "1.6.0",
-    "bcrypt": "^5.1.0",
+    "bcrypt": "^5.0.1",
     "bullmq": "^3.0.0",
     "cors": "^2.8.5",
     "crypto-js": "^4.1.1",
     "debug": "~2.6.9",
     "dotenv": "^10.0.0",
     "express": "~4.18.2",
-    "express-async-handler": "^1.2.0",
     "express-basic-auth": "^1.2.1",
     "express-graphql": "^0.12.0",
     "fast-xml-parser": "^4.0.11",
@@ -95,7 +94,6 @@
     "url": "https://github.com/automatisch/automatisch/issues"
   },
   "devDependencies": {
-    "node-gyp": "^10.1.0",
     "nodemon": "^2.0.13",
     "supertest": "^6.3.3",
     "vitest": "^1.1.3"

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

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

packages/backend/src/apps/bigin-by-zoho-crm/actions/create-company/index.js

@@ -0,0 +1,161 @@
+import defineAction from '../../../../helpers/define-action.js';
+
+export default defineAction({
+  name: 'Create company',
+  key: 'createCompany',
+  description: 'Creates a new company.',
+  arguments: [
+    {
+      label: 'Company Owner',
+      key: 'companyOwnerId',
+      type: 'dropdown',
+      required: false,
+      description: '',
+      variables: true,
+      source: {
+        type: 'query',
+        name: 'getDynamicData',
+        arguments: [
+          {
+            name: 'key',
+            value: 'listContactOwners',
+          },
+        ],
+      },
+    },
+    {
+      label: 'Company Name',
+      key: 'companyName',
+      type: 'string',
+      required: true,
+      description: '',
+      variables: true,
+    },
+    {
+      label: 'Phone',
+      key: 'phone',
+      type: 'string',
+      required: false,
+      description: '',
+      variables: true,
+    },
+    {
+      label: 'Website',
+      key: 'website',
+      type: 'string',
+      required: false,
+      description: '',
+      variables: true,
+    },
+    {
+      label: 'Tags',
+      key: 'tags',
+      type: 'dynamic',
+      required: false,
+      description: '',
+      fields: [
+        {
+          label: 'Tag',
+          key: 'tag',
+          type: 'string',
+          required: false,
+          variables: true,
+        },
+      ],
+    },
+    {
+      label: 'Description',
+      key: 'description',
+      type: 'string',
+      required: false,
+      description: '',
+      variables: true,
+    },
+    {
+      label: 'Billing Street',
+      key: 'billingStreet',
+      type: 'string',
+      required: false,
+      description: '',
+      variables: true,
+    },
+    {
+      label: 'Billing City',
+      key: 'billingCity',
+      type: 'string',
+      required: false,
+      description: '',
+      variables: true,
+    },
+    {
+      label: 'Billing State',
+      key: 'billingState',
+      type: 'string',
+      required: false,
+      description: '',
+      variables: true,
+    },
+    {
+      label: 'Billing Country',
+      key: 'billingCountry',
+      type: 'string',
+      required: false,
+      description: '',
+      variables: true,
+    },
+    {
+      label: 'Billing Code',
+      key: 'billingCode',
+      type: 'string',
+      required: false,
+      description: '',
+      variables: true,
+    },
+  ],
+
+  async run($) {
+    const {
+      contactOwnerId,
+      companyName,
+      phone,
+      website,
+      tags,
+      description,
+      billingStreet,
+      billingCity,
+      billingState,
+      billingCountry,
+      billingCode,
+    } = $.step.parameters;
+
+    const allTags = tags.map((tag) => ({
+      name: tag.tag,
+    }));
+
+    const body = {
+      data: [
+        {
+          Owner: {
+            id: contactOwnerId,
+          },
+          Account_Name: companyName,
+          Phone: phone,
+          Website: website,
+          Tag: allTags,
+          Description: description,
+          Billing_Street: billingStreet,
+          Billing_City: billingCity,
+          Billing_State: billingState,
+          Billing_Country: billingCountry,
+          Billing_Code: billingCode,
+        },
+      ],
+    };
+
+    const { data } = await $.http.post(`/bigin/v2/Accounts`, body);
+
+    $.setActionItem({
+      raw: data[0],
+    });
+  },
+});

packages/backend/src/apps/bigin-by-zoho-crm/actions/create-contact/index.js

@@ -0,0 +1,217 @@
+import defineAction from '../../../../helpers/define-action.js';
+
+export default defineAction({
+  name: 'Create contact',
+  key: 'createContact',
+  description: 'Creates a new contact.',
+  arguments: [
+    {
+      label: 'Contact Owner',
+      key: 'contactOwnerId',
+      type: 'dropdown',
+      required: false,
+      description: '',
+      variables: true,
+      source: {
+        type: 'query',
+        name: 'getDynamicData',
+        arguments: [
+          {
+            name: 'key',
+            value: 'listContactOwners',
+          },
+        ],
+      },
+    },
+    {
+      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: 'Title',
+      key: 'title',
+      type: 'string',
+      required: false,
+      description: '',
+      variables: true,
+    },
+    {
+      label: 'Email',
+      key: 'email',
+      type: 'string',
+      required: false,
+      description: '',
+      variables: true,
+    },
+    {
+      label: 'Company ID',
+      key: 'companyId',
+      type: 'dropdown',
+      required: false,
+      description: '',
+      variables: true,
+      source: {
+        type: 'query',
+        name: 'getDynamicData',
+        arguments: [
+          {
+            name: 'key',
+            value: 'listCompanies',
+          },
+        ],
+      },
+    },
+    {
+      label: 'Mobile',
+      key: 'mobile',
+      type: 'string',
+      required: false,
+      description: '',
+      variables: true,
+    },
+    {
+      label: 'Email Opt Out',
+      key: 'emailOptOut',
+      type: 'dropdown',
+      required: false,
+      description: '',
+      variables: true,
+      options: [
+        { label: 'True', value: true },
+        { label: 'False', value: false },
+      ],
+    },
+    {
+      label: 'Tags',
+      key: 'tags',
+      type: 'dynamic',
+      required: false,
+      description: '',
+      fields: [
+        {
+          label: 'Tag',
+          key: 'tag',
+          type: 'string',
+          required: false,
+          variables: true,
+        },
+      ],
+    },
+    {
+      label: 'Description',
+      key: 'description',
+      type: 'string',
+      required: false,
+      description: '',
+      variables: true,
+    },
+    {
+      label: 'Mailing Street',
+      key: 'mailingStreet',
+      type: 'string',
+      required: false,
+      description: '',
+      variables: true,
+    },
+    {
+      label: 'Mailing City',
+      key: 'mailingCity',
+      type: 'string',
+      required: false,
+      description: '',
+      variables: true,
+    },
+    {
+      label: 'Mailing State',
+      key: 'mailingState',
+      type: 'string',
+      required: false,
+      description: '',
+      variables: true,
+    },
+    {
+      label: 'Mailing Country',
+      key: 'mailingCountry',
+      type: 'string',
+      required: false,
+      description: '',
+      variables: true,
+    },
+    {
+      label: 'Mailing Zip',
+      key: 'mailingZip',
+      type: 'string',
+      required: false,
+      description: '',
+      variables: true,
+    },
+  ],
+
+  async run($) {
+    const {
+      contactOwnerId,
+      firstName,
+      lastName,
+      title,
+      email,
+      companyId,
+      mobile,
+      emailOptOut,
+      tags,
+      description,
+      mailingStreet,
+      mailingCity,
+      mailingState,
+      mailingCountry,
+      mailingZip,
+    } = $.step.parameters;
+
+    const allTags = tags.map((tag) => ({
+      name: tag.tag,
+    }));
+
+    const body = {
+      data: [
+        {
+          Owner: {
+            id: contactOwnerId,
+          },
+          Account_Name: {
+            id: companyId,
+          },
+          First_Name: firstName,
+          Last_Name: lastName,
+          Title: title,
+          Email: email,
+          Mobile: mobile,
+          Email_Opt_Out: emailOptOut,
+          Tag: allTags,
+          Description: description,
+          Mailing_Street: mailingStreet,
+          Mailing_City: mailingCity,
+          Mailing_State: mailingState,
+          Mailing_Country: mailingCountry,
+          Mailing_Zip: mailingZip,
+        },
+      ],
+    };
+
+    const { data } = await $.http.post(`/bigin/v2/Contacts`, body);
+
+    $.setActionItem({
+      raw: data[0],
+    });
+  },
+});

packages/backend/src/apps/bigin-by-zoho-crm/actions/create-event/index.js

@@ -0,0 +1,293 @@
+import defineAction from '../../../../helpers/define-action.js';
+
+export default defineAction({
+  name: 'Create event',
+  key: 'createEvent',
+  description: 'Creates a new event.',
+  arguments: [
+    {
+      label: 'Host',
+      key: 'hostId',
+      type: 'dropdown',
+      required: false,
+      description: '',
+      variables: true,
+      source: {
+        type: 'query',
+        name: 'getDynamicData',
+        arguments: [
+          {
+            name: 'key',
+            value: 'listContactOwners',
+          },
+        ],
+      },
+    },
+    {
+      label: 'Title',
+      key: 'title',
+      type: 'string',
+      required: true,
+      description: '',
+      variables: true,
+    },
+    {
+      label: 'From',
+      key: 'from',
+      type: 'string',
+      required: true,
+      description: 'The date format is ISO8601 (yyyy-mm-ddTHH:mm:ssZ).',
+      variables: true,
+    },
+    {
+      label: 'To',
+      key: 'to',
+      type: 'string',
+      required: true,
+      description: 'The date format is ISO8601 (yyyy-mm-ddTHH:mm:ssZ).',
+      variables: true,
+    },
+    {
+      label: 'All Day',
+      key: 'allDay',
+      type: 'dropdown',
+      required: false,
+      description: '',
+      variables: true,
+      options: [
+        { label: 'True', value: true },
+        { label: 'False', value: false },
+      ],
+    },
+    {
+      label: 'Frequency (Recurring Activity)',
+      key: 'frequency',
+      type: 'dropdown',
+      required: false,
+      description:
+        'Specifies the frequency of event recurrence. The options include DAILY, WEEKLY, MONTHLY, or YEARLY.',
+      variables: true,
+      options: [
+        { label: 'Daily Events', value: 'DAILY' },
+        { label: 'Weekly Events', value: 'WEEKLY' },
+        { label: 'Monthly Events', value: 'MONTHLY' },
+      ],
+    },
+    {
+      label: 'Interval (Recurring Activity)',
+      key: 'interval',
+      type: 'string',
+      required: false,
+      description:
+        'Specifies the time difference between individual events. The INTERVAL can be anywhere from 1 to 99. For instance, with a WEEKLY event set at an INTERVAL of 2, there will be a two-week gap between each occurrence.',
+      variables: true,
+    },
+    {
+      label: 'By Month Day (Recurring Activity)',
+      key: 'byMonthDay',
+      type: 'string',
+      required: false,
+      description:
+        'This specifies the date within the month when the event recurs. The BYMONTHDAY value can be any number from 1 to 31. This rule applies exclusively to events that repeat monthly or yearly.',
+      variables: true,
+    },
+    {
+      label: 'By Week (Recurring Activity)',
+      key: 'byWeek',
+      type: 'dropdown',
+      required: false,
+      description:
+        'Only relevant for events that occur on a monthly or yearly basis.',
+      variables: true,
+      options: [
+        { label: 'First week of the month', value: '1' },
+        { label: 'Second week of the month', value: '2' },
+        { label: 'Third week of the month', value: '3' },
+        { label: 'Fourth week of the month', value: '4' },
+        { label: 'Last week of the month', value: '-1' },
+      ],
+    },
+    {
+      label: 'By Day (Recurring Activity)',
+      key: 'byDay',
+      type: 'string',
+      required: false,
+      description:
+        'This signifies the weekday when the event recurs. The options include SU, MO, TU, WE, TH, FR, or SA. This rule applies to events that repeat daily, weekly, monthly, and yearly (should not be combined with INTERVAL).',
+      variables: true,
+    },
+    {
+      label: 'Count (Recurring Activity)',
+      key: 'count',
+      type: 'string',
+      required: false,
+      description:
+        'Specifies the number of events you wish to generate. The count value range from 1 to 99.',
+      variables: true,
+    },
+    {
+      label: 'Until (Recurring Activity)',
+      key: 'until',
+      type: 'string',
+      required: false,
+      description:
+        'Specifies the concluding date for the event recurrence. Please input the date in the YYYY-MM-DD format.',
+      variables: true,
+    },
+    {
+      label: 'Reminder',
+      key: 'reminder',
+      type: 'dropdown',
+      required: false,
+      description:
+        'Provide the reminder list to notify or prompt participants prior to the event.',
+      variables: true,
+      options: [
+        { label: '5 min', value: '5 minutes' },
+        { label: '10 min', value: '10 minutes' },
+        { label: '15 min', value: '15 minutes' },
+        { label: '1 hrs', value: '1 hours' },
+        { label: '2 hrs', value: '2 hours' },
+        { label: '1 days', value: '1 days' },
+        { label: '2 days', value: '2 days' },
+        { label: '1 weeks', value: '1 weeks' },
+      ],
+    },
+    {
+      label: 'Location',
+      key: 'location',
+      type: 'string',
+      required: false,
+      description: '',
+      variables: true,
+    },
+    {
+      label: 'Related Module',
+      key: 'relatedModule',
+      type: 'dropdown',
+      required: false,
+      description: '',
+      variables: true,
+      options: [
+        { label: 'Companies', value: 'Accounts' },
+        { label: 'Contacts', value: 'Contacts' },
+        { label: 'Deals', value: 'Deals' },
+      ],
+    },
+    {
+      label: 'Participants',
+      key: 'participants',
+      type: 'dynamic',
+      required: false,
+      description: 'Email Address of participants.',
+      fields: [
+        {
+          label: 'Participant',
+          key: 'participant',
+          type: 'string',
+          required: false,
+          variables: true,
+        },
+      ],
+    },
+    {
+      label: 'Description',
+      key: 'description',
+      type: 'string',
+      required: false,
+      description: '',
+      variables: true,
+    },
+    {
+      label: 'Tags',
+      key: 'tags',
+      type: 'dynamic',
+      required: false,
+      description: '',
+      fields: [
+        {
+          label: 'Tag',
+          key: 'tag',
+          type: 'string',
+          required: false,
+          variables: true,
+        },
+      ],
+    },
+  ],
+
+  async run($) {
+    const {
+      hostId,
+      title,
+      from,
+      to,
+      allDay,
+      frequency,
+      interval,
+      byMonthDay,
+      byDay,
+      byWeek,
+      count,
+      until,
+      reminder,
+      location,
+      relatedModule,
+      participants,
+      description,
+      tags,
+    } = $.step.parameters;
+
+    const allTags = tags.map((tag) => ({
+      name: tag.tag,
+    }));
+
+    const allParticipants = participants.map((participant) => ({
+      type: 'email',
+      participant: participant.participant,
+    }));
+
+    const [unit, period] = reminder.split(' ');
+
+    let rrule = `FREQ=${frequency};INTERVAL=${interval};`;
+    if (count) rrule += `COUNT=${count};`;
+    if (byMonthDay) rrule += `BYMONTHDAY=${byMonthDay};`;
+    if (byDay) rrule += `BYDAY=${byDay};`;
+    if (byWeek) rrule += `BYSETPOS=${byWeek};`;
+    if (until) rrule += `UNTIL=${until};`;
+
+    const body = {
+      data: [
+        {
+          Owner: {
+            id: hostId,
+          },
+          Event_Title: title,
+          Start_DateTime: from,
+          End_DateTime: to,
+          All_day: allDay,
+          $se_module: relatedModule,
+          Recurring_Activity: {
+            RRULE: rrule,
+          },
+          Remind_At: [
+            {
+              unit: Number(unit),
+              period,
+            },
+          ],
+          Venue: location,
+          Participants: allParticipants,
+          Description: description,
+          Tag: allTags,
+        },
+      ],
+    };
+
+    const { data } = await $.http.post(`/bigin/v2/Events`, body);
+
+    $.setActionItem({
+      raw: data,
+    });
+  },
+});

packages/backend/src/apps/bigin-by-zoho-crm/actions/create-task/index.js

@@ -0,0 +1,246 @@
+import defineAction from '../../../../helpers/define-action.js';
+
+export default defineAction({
+  name: 'Create task',
+  key: 'createTask',
+  description: 'Creates a new task.',
+  arguments: [
+    {
+      label: 'Task Owner',
+      key: 'taskOwnerId',
+      type: 'dropdown',
+      required: false,
+      description: '',
+      variables: true,
+      source: {
+        type: 'query',
+        name: 'getDynamicData',
+        arguments: [
+          {
+            name: 'key',
+            value: 'listContactOwners',
+          },
+        ],
+      },
+    },
+    {
+      label: 'Subject',
+      key: 'subject',
+      type: 'string',
+      required: true,
+      description: '',
+      variables: true,
+    },
+    {
+      label: 'Due Date',
+      key: 'dueDate',
+      type: 'string',
+      required: true,
+      description: 'The date format is yyyy-mm-dd.',
+      variables: true,
+    },
+    {
+      label: 'Frequency (Recurring Activity)',
+      key: 'frequency',
+      type: 'dropdown',
+      required: false,
+      description:
+        'Specifies the frequency of event recurrence. The options include DAILY, WEEKLY, MONTHLY, or YEARLY.',
+      variables: true,
+      options: [
+        { label: 'None', value: 'NONE' },
+        { label: 'Daily Events', value: 'DAILY' },
+        { label: 'Weekly Events', value: 'WEEKLY' },
+        { label: 'Monthly Events', value: 'MONTHLY' },
+      ],
+    },
+    {
+      label: 'Interval (Recurring Activity)',
+      key: 'interval',
+      type: 'string',
+      required: false,
+      description:
+        'Specifies the time difference between individual events. The INTERVAL can be anywhere from 1 to 99. For instance, with a WEEKLY event set at an INTERVAL of 2, there will be a two-week gap between each occurrence.',
+      variables: true,
+    },
+    {
+      label: 'Start Date (Recurring Activity)',
+      key: 'startDate',
+      type: 'string',
+      required: false,
+      description: 'The date format is yyyy-mm-dd.',
+      variables: true,
+    },
+    {
+      label: 'By Month Day (Recurring Activity)',
+      key: 'byMonthDay',
+      type: 'string',
+      required: false,
+      description:
+        'This specifies the date within the month when the event recurs. The BYMONTHDAY value can be any number from 1 to 31. This rule applies exclusively to events that repeat monthly or yearly.',
+      variables: true,
+    },
+    {
+      label: 'By Week (Recurring Activity)',
+      key: 'byWeek',
+      type: 'dropdown',
+      required: false,
+      description:
+        'Only relevant for events that occur on a monthly or yearly basis.',
+      variables: true,
+      options: [
+        { label: 'First week of the month', value: '1' },
+        { label: 'Second week of the month', value: '2' },
+        { label: 'Third week of the month', value: '3' },
+        { label: 'Fourth week of the month', value: '4' },
+        { label: 'Last week of the month', value: '-1' },
+      ],
+    },
+    {
+      label: 'By Day (Recurring Activity)',
+      key: 'byDay',
+      type: 'dropdown',
+      required: false,
+      description:
+        'This signifies the weekday when the event recurs. This rule applies to events that repeat daily, weekly, monthly, and yearly (should not be combined with INTERVAL).',
+      variables: true,
+      options: [
+        { label: 'Sunday', value: 'SU' },
+        { label: 'Monday', value: 'MO' },
+        { label: 'Tuesday', value: 'TU' },
+        { label: 'Wednesday', value: 'WE' },
+        { label: 'Thursday', value: 'TH' },
+        { label: 'Friday', value: 'FR' },
+        { label: 'Saturday', value: 'SA' },
+      ],
+    },
+    {
+      label: 'Count (Recurring Activity)',
+      key: 'count',
+      type: 'string',
+      required: false,
+      description:
+        'Specifies the number of events you wish to generate. The count value range from 1 to 99.',
+      variables: true,
+    },
+    {
+      label: 'Until (Recurring Activity)',
+      key: 'until',
+      type: 'string',
+      required: false,
+      description:
+        'Specifies the concluding date for the event recurrence. Please input the date in the YYYY-MM-DD format.',
+      variables: true,
+    },
+    {
+      label: 'Description',
+      key: 'description',
+      type: 'string',
+      required: false,
+      description: '',
+      variables: true,
+    },
+    {
+      label: 'Priority',
+      key: 'priority',
+      type: 'dropdown',
+      required: false,
+      description: '',
+      variables: true,
+      options: [
+        { label: 'High', value: 'High' },
+        { label: 'Normal', value: 'Normal' },
+      ],
+    },
+    {
+      label: 'Status',
+      key: 'status',
+      type: 'dropdown',
+      required: false,
+      description: '',
+      variables: true,
+      options: [
+        { label: 'In Progress', value: 'In Progress' },
+        { label: 'Completed', value: 'Completed' },
+      ],
+    },
+    {
+      label: 'Tags',
+      key: 'tags',
+      type: 'dynamic',
+      required: false,
+      description: '',
+      fields: [
+        {
+          label: 'Tag',
+          key: 'tag',
+          type: 'string',
+          required: false,
+          variables: true,
+        },
+      ],
+    },
+  ],
+
+  async run($) {
+    const {
+      taskOwnerId,
+      subject,
+      dueDate,
+      frequency,
+      startDate,
+      interval,
+      byMonthDay,
+      byDay,
+      byWeek,
+      count,
+      until,
+      description,
+      priority,
+      status,
+      tags,
+    } = $.step.parameters;
+
+    const allTags = tags.map((tag) => ({
+      name: tag.tag,
+    }));
+
+    let rrule;
+    if (frequency) rrule += `FREQ=${frequency};`;
+    if (interval) rrule += `INTERVAL=${interval};`;
+    if (count) rrule += `COUNT=${count};`;
+    if (byMonthDay) rrule += `BYMONTHDAY=${byMonthDay};`;
+    if (byDay) rrule += `BYDAY=${byDay};`;
+    if (byWeek) rrule += `BYSETPOS=${byWeek};`;
+    if (until) rrule += `UNTIL=${until};`;
+    if (startDate) rrule += `DTSTART=${startDate}`;
+
+    const body = {
+      data: [
+        {
+          Owner: {
+            id: taskOwnerId,
+          },
+          Subject: subject,
+          Due_Date: dueDate,
+          Description: description,
+          Priority: priority,
+          Status: status,
+          Tag: allTags,
+        },
+      ],
+    };
+
+    if (rrule) {
+      body.data[0].Recurring_Activity = {
+        RRULE: rrule,
+      };
+    }
+
+    const { data } = await $.http.post(`/bigin/v2/Tasks`, body);
+
+    $.setActionItem({
+      raw: data,
+    });
+  },
+});

packages/backend/src/apps/bigin-by-zoho-crm/actions/index.js

@@ -0,0 +1,6 @@
+import createCompany from './create-company/index.js';
+import createContact from './create-contact/index.js';
+import createEvent from './create-event/index.js';
+import createTask from './create-task/index.js';
+
+export default [createCompany, createContact, createEvent, createTask];

packages/backend/src/apps/bigin-by-zoho-crm/assets/favicon.svg

@@ -0,0 +1,32 @@
+<svg xmlns:xlink="http://www.w3.org/1999/xlink" xmlns="http://www.w3.org/2000/svg" id="b" data-name="Layer 2" width="327.714" height="120" viewBox="0 0 327.714 120">
+  <defs>
+    <style>
+      .d {
+        fill: #039649;
+      }
+    </style>
+  </defs>
+  <g id="c" data-name="Layer 1">
+    <g>
+      <path class="d" d="m52.39,120c-1.801,0-3.6-.6-5.101-1.5-2.1-1.5-3.6-4.2-3.6-6.9v-24.6L1.09,12.901C-.41,9.9-.41,6.601,1.391,4.2,2.891,1.5,5.89,0,8.89,0h78c2.999,0,5.698,1.5,7.199,4.2,1.801,2.702,1.801,6.3.301,9.002l-5.101,9h10.201c2.999,0,5.698,1.5,7.199,4.2,1.801,2.7,1.801,6.3.301,9l-29.701,51.3v18.599c0,3.899-2.399,6.9-5.999,8.099l-16.2,6.3c-.6.301-1.799.301-2.7.301M8.89,8.4q-.301.301-.301.602l42.301,73.798c1.199,2.1,1.199,3.299,1.199,4.501v23.998s.301.301.6,0l16.2-6.3h.6v-17.999c0-1.199,0-3.299,1.201-4.8l29.4-50.999c0-.301,0-.6-.301-.6l-53.699-.301,14.399,24.901,10.201-17.7c1.199-2.1,3.6-2.7,5.7-1.5,2.1,1.199,2.7,3.6,1.498,5.7l-11.998,20.699c-2.702,4.2-8.701,3.901-11.102.301l-17.4-30.9c-1.199-1.799-1.199-4.2,0-6.3,1.201-2.1,3.301-3.6,5.7-3.6h36.6l7.499-12.899s0-.301-.299-.602H8.89Z"/>
+      <g>
+        <path d="m181.725,48.737c0,3.089-.54,5.684-1.618,7.788-1.081,2.104-2.548,3.79-4.407,5.062-1.858,1.27-4.016,2.179-6.476,2.726-2.459.547-5.069.819-7.828.819h-24.591V6.521h23.034c2.676,0,5.198.24,7.561.718,2.364.479,4.427,1.311,6.189,2.5,1.762,1.189,3.149,2.787,4.16,4.795,1.011,2.008,1.517,4.53,1.517,7.562,0,3.17-.786,5.813-2.357,7.93-1.57,2.119-3.913,3.628-7.028,4.53,4.017.819,6.995,2.371,8.935,4.652s2.91,5.458,2.91,9.529Zm-33.813-17.624h10.533c1.612,0,3.033-.136,4.263-.41,1.23-.272,2.268-.738,3.115-1.393.846-.656,1.489-1.55,1.927-2.684.436-1.134.655-2.562.655-4.284,0-1.612-.267-2.923-.799-3.934-.532-1.01-1.25-1.809-2.152-2.398-.902-.587-1.967-.99-3.197-1.209s-2.542-.328-3.934-.328h-10.411v16.64Zm0,26.067h12.09c1.64,0,3.115-.169,4.427-.512,1.311-.342,2.424-.894,3.341-1.66.915-.764,1.612-1.748,2.091-2.951.478-1.202.716-2.663.716-4.385,0-1.802-.294-3.285-.881-4.447-.588-1.161-1.394-2.083-2.419-2.766s-2.227-1.154-3.606-1.414c-1.381-.26-2.863-.39-4.447-.39h-11.312v18.525Z"/>
+        <path d="m202.257,9.555c0,.847-.151,1.633-.451,2.356-.3.724-.716,1.34-1.25,1.844-.532.507-1.167.902-1.905,1.189s-1.53.431-2.377.431c-.819,0-1.598-.144-2.336-.431s-1.388-.69-1.947-1.209c-.56-.519-.998-1.133-1.311-1.844-.315-.711-.471-1.489-.471-2.336s.156-1.626.471-2.336c.314-.711.744-1.325,1.291-1.845.546-.519,1.187-.922,1.925-1.209s1.53-.431,2.377-.431c.821,0,1.598.144,2.336.431s1.373.69,1.907,1.209c.532.52.955,1.134,1.27,1.845.314.71.471,1.489.471,2.336Zm-.778,12.705v42.871h-10.246V22.261h10.246Z"/>
+        <path d="m254.186,61.935c0,3.361-.587,6.236-1.762,8.627-1.174,2.391-2.78,4.352-4.815,5.882-2.036,1.529-4.407,2.65-7.111,3.361-2.706.71-5.589,1.065-8.648,1.065-2.023,0-4.037-.157-6.045-.471-2.009-.314-3.908-.861-5.697-1.64-1.79-.778-3.395-1.837-4.816-3.175-1.421-1.34-2.555-3.021-3.402-5.042l8.074-3.525c.519,1.202,1.202,2.193,2.049,2.971.847.779,1.797,1.408,2.848,1.885,1.051.479,2.172.814,3.361,1.005s2.398.287,3.628.287c1.885,0,3.572-.232,5.062-.696,1.489-.466,2.752-1.169,3.79-2.111,1.039-.943,1.838-2.132,2.399-3.566.559-1.434.839-3.107.839-5.02v-6.393c-.71,1.229-1.592,2.336-2.643,3.319-1.053.983-2.207,1.824-3.464,2.52s-2.582,1.237-3.976,1.62c-1.393.383-2.814.574-4.263.574-3.033,0-5.737-.56-8.114-1.681-2.377-1.119-4.379-2.636-6.005-4.55-1.625-1.912-2.862-4.139-3.709-6.68-.847-2.542-1.27-5.233-1.27-8.074,0-2.814.451-5.491,1.353-8.033.901-2.542,2.192-4.775,3.873-6.702,1.68-1.927,3.709-3.464,6.086-4.611,2.376-1.147,5.054-1.721,8.033-1.721,2.923,0,5.621.594,8.094,1.782,2.472,1.189,4.473,3.082,6.004,5.677v-6.557h10.246v39.674Zm-33.198-19.017c0,1.666.252,3.265.758,4.795s1.237,2.876,2.193,4.037c.957,1.162,2.137,2.084,3.545,2.767s3.013,1.025,4.816,1.025c2.021,0,3.784-.355,5.287-1.066,1.502-.711,2.746-1.673,3.729-2.89.985-1.215,1.722-2.643,2.213-4.283.492-1.64.738-3.374.738-5.206,0-1.802-.239-3.49-.716-5.062-.479-1.57-1.203-2.93-2.173-4.077s-2.179-2.056-3.626-2.726c-1.449-.67-3.157-1.005-5.123-1.005-2.049,0-3.812.363-5.287,1.086-1.476.724-2.684,1.709-3.628,2.951-.943,1.243-1.633,2.699-2.069,4.365-.438,1.666-.656,3.429-.656,5.287Z"/>
+        <path d="m277.096,9.555c0,.847-.151,1.633-.451,2.356-.3.724-.716,1.34-1.25,1.844-.532.507-1.167.902-1.905,1.189s-1.53.431-2.377.431c-.819,0-1.598-.144-2.336-.431s-1.388-.69-1.947-1.209c-.56-.519-.998-1.133-1.311-1.844-.315-.711-.471-1.489-.471-2.336s.156-1.626.471-2.336c.314-.711.744-1.325,1.291-1.845.546-.519,1.187-.922,1.925-1.209s1.53-.431,2.377-.431c.821,0,1.598.144,2.336.431s1.373.69,1.907,1.209c.532.52.955,1.134,1.27,1.845.314.71.471,1.489.471,2.336Zm-.778,12.705v42.871h-10.246V22.261h10.246Z"/>
+        <path d="m308.451,29.801c-1.585,0-2.999.24-4.243.718-1.243.479-2.288,1.162-3.135,2.049-.847.889-1.496,1.961-1.947,3.217-.451,1.258-.676,2.651-.676,4.181v25.165h-10.246V22.261h10.246v6.803c.683-1.338,1.537-2.492,2.562-3.462,1.025-.97,2.165-1.769,3.422-2.399,1.257-.627,2.59-1.091,3.997-1.393,1.406-.3,2.82-.451,4.241-.451,2.623,0,4.884.431,6.783,1.291s3.464,2.049,4.694,3.565c1.229,1.517,2.131,3.307,2.704,5.37s.861,4.311.861,6.742v26.805h-10.328v-25.822c0-3.005-.711-5.341-2.132-7.008-1.421-1.666-3.688-2.5-6.803-2.5Z"/>
+      </g>
+      <g>
+        <path d="m152.871,102.12c0,1.138-.168,2.221-.507,3.25-.337,1.028-.828,1.935-1.471,2.72s-1.436,1.41-2.379,1.874-2.021.696-3.234.696c-.579,0-1.155-.061-1.723-.183-.569-.121-1.107-.306-1.613-.553-.505-.247-.974-.561-1.407-.941s-.801-.822-1.107-1.328v2.72h-2.625v-24.446h2.625v10.689c.273-.464.632-.882,1.076-1.257.442-.374.93-.696,1.463-.964.531-.27,1.082-.477,1.652-.626.569-.146,1.122-.22,1.66-.22,1.244,0,2.34.227,3.289.679.95.454,1.743,1.068,2.38,1.843s1.117,1.685,1.44,2.728c.321,1.044.482,2.151.482,3.321Zm-13.536.126c0,.917.123,1.756.371,2.515.249.759.614,1.415,1.1,1.968.485.553,1.079.984,1.787,1.289.706.306,1.517.459,2.435.459.991,0,1.813-.178,2.467-.53.653-.354,1.178-.828,1.573-1.424.395-.595.674-1.283.838-2.063.163-.78.245-1.603.245-2.467,0-.801-.104-1.576-.308-2.325-.206-.748-.52-1.415-.941-1.999-.422-.586-.958-1.055-1.605-1.407-.648-.354-1.415-.53-2.3-.53-.981,0-1.827.174-2.538.521-.711.349-1.3.818-1.764,1.409-.464.59-.806,1.28-1.028,2.071s-.332,1.629-.332,2.514Z"/>
+        <path d="m169.949,93.834l-9.141,22.297h-2.656l3.131-7.464-6.388-14.833h2.814l4.965,11.86,4.586-11.86h2.689Z"/>
+        <path d="m194.11,108.034v2.34h-16.414v-1.139l13.189-19.228h-12.05v-2.246h15.465v1.139l-12.84,19.134h12.65Z"/>
+        <path d="m213.229,102.215c0,1.202-.206,2.319-.617,3.352-.411,1.034-.986,1.927-1.723,2.681-.739.753-1.611,1.344-2.618,1.77-1.007.428-2.106.641-3.296.641-1.256,0-2.388-.222-3.4-.665s-1.874-1.053-2.585-1.834-1.257-1.697-1.637-2.752c-.38-1.053-.57-2.192-.57-3.416,0-1.191.201-2.3.601-3.329.4-1.028.964-1.92,1.692-2.68.727-.759,1.594-1.354,2.601-1.787s2.116-.648,3.329-.648c1.254,0,2.391.22,3.408.663s1.881,1.055,2.593,1.835,1.26,1.697,1.644,2.751c.385,1.055.578,2.192.578,3.416Zm-13.726.031c0,.886.117,1.708.349,2.467s.579,1.418,1.043,1.977c.464.558,1.038.995,1.723,1.311.685.317,1.481.476,2.388.476.938,0,1.753-.175,2.443-.522.691-.349,1.263-.816,1.717-1.407.452-.591.79-1.275,1.012-2.056.22-.78.332-1.602.332-2.466,0-.844-.117-1.646-.349-2.404-.232-.759-.579-1.429-1.043-2.008s-1.038-1.038-1.723-1.376c-.685-.337-1.481-.505-2.388-.505-.971,0-1.802.174-2.498.521-.696.349-1.265.82-1.708,1.416-.443.595-.77,1.288-.981,2.078-.21.792-.316,1.624-.316,2.498Z"/>
+        <path d="m224.423,95.827c-.696,0-1.323.105-1.881.316s-1.034.512-1.423.902c-.391.39-.691.864-.902,1.423s-.316,1.186-.316,1.881v10.026h-2.625v-24.446h2.625v10.531c.253-.516.564-.956.933-1.32s.777-.663,1.226-.902c.447-.237.933-.411,1.454-.521.522-.111,1.057-.166,1.605-.166,1.033,0,1.937.171,2.712.513.775.343,1.423.818,1.945,1.424.522.605.915,1.326,1.178,2.157.263.833.395,1.745.395,2.735v9.994h-2.625v-10.184c0-1.423-.36-2.506-1.083-3.25-.722-.742-1.795-1.114-3.217-1.114Z"/>
+        <path d="m251.685,102.215c0,1.202-.206,2.319-.617,3.352-.411,1.034-.986,1.927-1.723,2.681-.739.753-1.611,1.344-2.618,1.77-1.007.428-2.106.641-3.296.641-1.256,0-2.388-.222-3.4-.665s-1.874-1.053-2.585-1.834-1.257-1.697-1.637-2.752c-.38-1.053-.57-2.192-.57-3.416,0-1.191.201-2.3.601-3.329.4-1.028.964-1.92,1.692-2.68.727-.759,1.594-1.354,2.601-1.787s2.116-.648,3.329-.648c1.254,0,2.391.22,3.408.663s1.881,1.055,2.593,1.835,1.26,1.697,1.644,2.751c.385,1.055.578,2.192.578,3.416Zm-13.726.031c0,.886.117,1.708.349,2.467s.579,1.418,1.043,1.977c.464.558,1.038.995,1.723,1.311.685.317,1.481.476,2.388.476.938,0,1.753-.175,2.443-.522.691-.349,1.263-.816,1.717-1.407.452-.591.79-1.275,1.012-2.056.22-.78.332-1.602.332-2.466,0-.844-.117-1.646-.349-2.404-.232-.759-.579-1.429-1.043-2.008s-1.038-1.038-1.723-1.376c-.685-.337-1.481-.505-2.388-.505-.971,0-1.802.174-2.498.521-.696.349-1.265.82-1.708,1.416-.443.595-.77,1.288-.981,2.078-.21.792-.316,1.624-.316,2.498Z"/>
+        <path d="m281.097,103.923c-.38.959-.884,1.85-1.511,2.672-.627.823-1.346,1.534-2.157,2.135-.812.601-1.703,1.073-2.673,1.415-.969.342-1.976.514-3.02.514-1.76,0-3.312-.295-4.656-.886-1.345-.59-2.472-1.407-3.385-2.45-.912-1.044-1.603-2.279-2.072-3.709-.469-1.428-.704-2.98-.704-4.657,0-1.033.114-2.037.341-3.013.227-.974.553-1.889.98-2.743.428-.854.95-1.637,1.565-2.348.617-.711,1.318-1.32,2.104-1.827.785-.505,1.652-.901,2.601-1.186.949-.284,1.961-.426,3.036-.426,1.012,0,2.003.148,2.973.442.971.295,1.866.718,2.689,1.266.822.548,1.55,1.209,2.182,1.984s1.127,1.642,1.486,2.602l-2.246.98c-.295-.768-.673-1.468-1.13-2.095-.459-.627-.989-1.162-1.59-1.604-.601-.443-1.265-.785-1.992-1.029-.728-.242-1.508-.363-2.341-.363-1.359,0-2.532.268-3.518.806s-1.797,1.254-2.435,2.151c-.638.895-1.107,1.919-1.407,3.067-.301,1.149-.451,2.335-.451,3.558,0,1.244.166,2.424.498,3.543.333,1.117.833,2.098,1.503,2.94.669.844,1.507,1.513,2.514,2.008,1.007.496,2.18.744,3.518.744.801,0,1.576-.143,2.325-.428.749-.284,1.44-.671,2.072-1.162.632-.49,1.191-1.064,1.675-1.723.485-.658.864-1.357,1.139-2.095l2.088.917Z"/>
+        <path d="m287.991,100.539v9.835h-2.751v-22.613h7.431c1.044,0,2.042.111,2.997.332.954.222,1.795.586,2.522,1.092.728.505,1.307,1.168,1.74,1.984.431.818.648,1.822.648,3.013,0,.885-.137,1.673-.411,2.364-.275.691-.66,1.289-1.155,1.795-.496.507-1.086.925-1.771,1.257-.685.333-1.44.583-2.261.752l6.926,10.026h-3.068l-6.736-9.835h-4.112Zm0-2.183h4.871c.727,0,1.393-.075,1.999-.228s1.131-.402,1.574-.744c.442-.342.785-.785,1.028-1.328s.363-1.21.363-2.001c0-.801-.126-1.466-.378-1.992-.254-.527-.601-.943-1.044-1.25-.443-.305-.967-.521-1.573-.648s-1.262-.189-1.968-.189h-4.871v8.38Z"/>
+        <path d="m308.231,91.335v19.039h-2.529v-22.613h3.826l7.242,17.932,7.148-17.932h3.795v22.613h-2.752v-19.039l-7.653,19.039h-1.17l-7.907-19.039Z"/>
+      </g>
+    </g>
+  </g>
+</svg>

packages/backend/src/apps/bigin-by-zoho-crm/auth/generate-auth-url.js

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

packages/backend/src/apps/bigin-by-zoho-crm/auth/index.js

@@ -11,21 +11,28 @@ export default {
       type: 'string',
       required: true,
       readOnly: true,
-      value: '{WEB_APP_URL}/app/gitea/connections/add',
+      value: '{WEB_APP_URL}/app/bigin-by-zoho-crm/connections/add',
       placeholder: null,
       description:
-        'When asked to input a redirect URL in Gitea, enter the URL above.',
+        'When asked to input a redirect URL in Bigin By Zoho CRM, enter the URL above.',
       clickToCopy: true,
     },
     {
-      key: 'instanceUrl',
+      key: 'region',
-      label: 'Instance URL',
+      label: 'Region',
-      type: 'string',
+      type: 'dropdown',
       required: true,
       readOnly: false,
       value: null,
       placeholder: null,
-      description: null,
+      description: '',
+      options: [
+        { label: 'United States', value: 'us' },
+        { label: 'European Union', value: 'eu' },
+        { label: 'Australia', value: 'au' },
+        { label: 'India', value: 'in' },
+        { label: 'China', value: 'cn' },
+      ],
       clickToCopy: false,
     },
     {

packages/backend/src/apps/bigin-by-zoho-crm/auth/is-still-verified.js

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

packages/backend/src/apps/bigin-by-zoho-crm/auth/refresh-token.js

@@ -1,15 +1,19 @@
 import { URLSearchParams } from 'node:url';
 
+import authScope from '../common/auth-scope.js';
+import { regionUrlMap } from '../common/region-url-map.js';
+
 const refreshToken = async ($) => {
+  const location = $.auth.data.location;
   const params = new URLSearchParams({
     client_id: $.auth.data.clientId,
     client_secret: $.auth.data.clientSecret,
-    grant_type: 'refresh_token',
     refresh_token: $.auth.data.refreshToken,
+    grant_type: 'refresh_token',
   });
 
   const { data } = await $.http.post(
-    `${$.auth.data.instanceUrl}/login/oauth/access_token`,
+    `${regionUrlMap[location]}/oauth/v2/token`,
     params.toString(),
     {
       additionalProperties: {
@@ -20,9 +24,10 @@ const refreshToken = async ($) => {
 
   await $.auth.set({
     accessToken: data.access_token,
-    expiresIn: data.expires_in,
+    apiDomain: data.api_domain,
+    scope: authScope.join(','),
     tokenType: data.token_type,
-    refreshToken: data.refresh_token,
+    expiresIn: data.expires_in,
   });
 };
 

packages/backend/src/apps/bigin-by-zoho-crm/auth/verify-credentials.js

@@ -1,48 +1,44 @@
-import getCurrentUser from '../common/get-current-user.js';
+import { URLSearchParams } from 'node:url';
-import { URLSearchParams } from 'url';
+import { regionUrlMap } from '../common/region-url-map.js';
+import getCurrentOrganization from '../common/get-current-organization.js';
 
 const verifyCredentials = async ($) => {
-  if ($.auth.data.originalState !== $.auth.data.state) {
-    throw new Error(`The 'state' parameter does not match.`);
-  }
   const oauthRedirectUrlField = $.app.auth.fields.find(
     (field) => field.key == 'oAuthRedirectUrl'
   );
   const redirectUri = oauthRedirectUrlField.value;
+  const location = $.auth.data.location;
   const params = new URLSearchParams({
     client_id: $.auth.data.clientId,
     client_secret: $.auth.data.clientSecret,
     code: $.auth.data.code,
-    grant_type: 'authorization_code',
     redirect_uri: redirectUri,
+    grant_type: 'authorization_code',
   });
 
   const { data } = await $.http.post(
-    `${$.auth.data.instanceUrl}/login/oauth/access_token`,
+    `${regionUrlMap[location]}/oauth/v2/token`,
-    params.toString(),
+    params.toString()
-    {
-      additionalProperties: {
-        skipAddingBaseUrl: true,
-      },
-    }
   );
 
   await $.auth.set({
     accessToken: data.access_token,
     tokenType: data.token_type,
+    apiDomain: data.api_domain,
   });
 
-  const currentUser = await getCurrentUser($);
+  const organization = await getCurrentOrganization($);
-  const screenName = [currentUser.username, currentUser.email]
+
+  const screenName = [organization.company_name, organization.primary_email]
     .filter(Boolean)
     .join(' @ ');
 
   await $.auth.set({
     clientId: $.auth.data.clientId,
     clientSecret: $.auth.data.clientSecret,
+    scope: $.auth.data.scope,
     expiresIn: data.expires_in,
     refreshToken: data.refresh_token,
-    repoOwner: currentUser.username,
     screenName,
   });
 };

packages/backend/src/apps/bigin-by-zoho-crm/common/add-auth-header.js

@@ -1,6 +1,6 @@
 const addAuthHeader = ($, requestConfig) => {
   if ($.auth.data?.accessToken) {
-    requestConfig.headers.Authorization = `${$.auth.data.tokenType} ${$.auth.data.accessToken}`;
+    requestConfig.headers.Authorization = `Zoho-oauthtoken ${$.auth.data.accessToken}`;
   }
 
   return requestConfig;

packages/backend/src/apps/bigin-by-zoho-crm/common/auth-scope.js

@@ -0,0 +1,10 @@
+const authScope = [
+  'ZohoBigin.notifications.ALL',
+  'ZohoBigin.users.ALL',
+  'ZohoBigin.modules.ALL',
+  'ZohoBigin.org.READ',
+  'ZohoBigin.settings.ALL',
+  'ZohoBigin.modules.ALL',
+];
+
+export default authScope;

packages/backend/src/apps/bigin-by-zoho-crm/common/get-current-organization.js

@@ -0,0 +1,6 @@
+const getCurrentOrganization = async ($) => {
+  const response = await $.http.get('/bigin/v2/org');
+  return response.data.org[0];
+};
+
+export default getCurrentOrganization;

packages/backend/src/apps/bigin-by-zoho-crm/common/region-url-map.js

@@ -0,0 +1,8 @@
+export const regionUrlMap = {
+  us: 'https://accounts.zoho.com',
+  au: 'https://accounts.zoho.com.au',
+  eu: 'https://accounts.zoho.eu',
+  in: 'https://accounts.zoho.in',
+  cn: 'https://accounts.zoho.com.cn',
+  jp: 'https://accounts.zoho.jp',
+};

packages/backend/src/apps/bigin-by-zoho-crm/common/set-base-url.js

@@ -2,10 +2,10 @@ const setBaseUrl = ($, requestConfig) => {
   if (requestConfig.additionalProperties?.skipAddingBaseUrl)
     return requestConfig;
 
-  const instanceUrl = $.auth.data.instanceUrl;
+  const apiDomain = $.auth.data.apiDomain;
 
-  if (instanceUrl) {
+  if (apiDomain) {
-    requestConfig.baseURL = `${instanceUrl}/api/v1`;
+    requestConfig.baseURL = apiDomain;
   }
 
   return requestConfig;

packages/backend/src/apps/bigin-by-zoho-crm/dynamic-data/index.js

@@ -0,0 +1,5 @@
+import listCompanies from './list-companies/index.js';
+import listOrganizations from './list-organizations/index.js';
+import listContactOwners from './list-contact-owners/index.js';
+
+export default [listCompanies, listOrganizations, listContactOwners];

packages/backend/src/apps/bigin-by-zoho-crm/dynamic-data/list-companies/index.js

@@ -0,0 +1,39 @@
+export default {
+  name: 'List companies',
+  key: 'listCompanies',
+
+  async run($) {
+    const companies = {
+      data: [],
+    };
+
+    const params = new URLSearchParams({
+      page: 1,
+      pageSize: 200,
+      fields: 'Account_Name',
+    });
+
+    let next = false;
+    do {
+      const { data } = await $.http.get('/bigin/v2/Accounts', { params });
+
+      if (data.info.more_records) {
+        params.page = params.page + 1;
+        next = true;
+      } else {
+        next = false;
+      }
+
+      if (data.data) {
+        for (const account of data.data) {
+          companies.data.push({
+            value: account.id,
+            name: account.Account_Name,
+          });
+        }
+      }
+    } while (next);
+
+    return companies;
+  },
+};

packages/backend/src/apps/bigin-by-zoho-crm/dynamic-data/list-contact-owners/index.js

@@ -0,0 +1,39 @@
+export default {
+  name: 'List contact owners',
+  key: 'listContactOwners',
+
+  async run($) {
+    const contactOwners = {
+      data: [],
+    };
+
+    const params = {
+      type: 'AllUsers',
+      page: 1,
+      pageSize: 200,
+    };
+
+    let next = false;
+    do {
+      const { data } = await $.http.get('/bigin/v2/users', params);
+
+      if (data.users.length === params.pageSize) {
+        next = true;
+        params.page = params.page + 1;
+      } else {
+        next = false;
+      }
+
+      if (data.users) {
+        for (const user of data.users) {
+          contactOwners.data.push({
+            value: user.id,
+            name: user.full_name,
+          });
+        }
+      }
+    } while (next);
+
+    return contactOwners;
+  },
+};

packages/backend/src/apps/bigin-by-zoho-crm/dynamic-data/list-organizations/index.js

@@ -0,0 +1,23 @@
+export default {
+  name: 'List organizations',
+  key: 'listOrganizations',
+
+  async run($) {
+    const organizations = {
+      data: [],
+    };
+
+    const { data } = await $.http.get('/bigin/v2/org');
+
+    if (data.org) {
+      for (const org of data.org) {
+        organizations.data.push({
+          value: org.id,
+          name: org.company_name,
+        });
+      }
+    }
+
+    return organizations;
+  },
+};

packages/backend/src/apps/bigin-by-zoho-crm/index.js

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

packages/backend/src/apps/bigin-by-zoho-crm/triggers/index.js

@@ -0,0 +1,7 @@
+import newCalls from './new-calls/index.js';
+import newCompanies from './new-companies/index.js';
+import newContacts from './new-contacts/index.js';
+import newProducts from './new-products/index.js';
+import newTasks from './new-tasks/index.js';
+
+export default [newCalls, newCompanies, newContacts, newProducts, newTasks];

packages/backend/src/apps/bigin-by-zoho-crm/triggers/new-calls/index.js

@@ -0,0 +1,89 @@
+import Crypto from 'crypto';
+import defineTrigger from '../../../../helpers/define-trigger.js';
+
+export default defineTrigger({
+  name: 'New calls',
+  key: 'newCalls',
+  type: 'webhook',
+  description: 'Triggers when a new call is added.',
+  arguments: [
+    {
+      label: 'Organization',
+      key: 'organizationId',
+      type: 'dropdown',
+      required: true,
+      description: '',
+      variables: false,
+      source: {
+        type: 'query',
+        name: 'getDynamicData',
+        arguments: [
+          {
+            name: 'key',
+            value: 'listOrganizations',
+          },
+        ],
+      },
+    },
+  ],
+
+  async run($) {
+    const dataItem = {
+      raw: $.request.body,
+      meta: {
+        internalId: Crypto.randomUUID(),
+      },
+    };
+
+    $.pushTriggerItem(dataItem);
+  },
+
+  async testRun($) {
+    const organizationId = $.step.parameters.organizationId;
+
+    const sampleEventData = {
+      ids: ['111111111111111111'],
+      token: null,
+      module: 'Calls',
+      operation: 'insert',
+      channel_id: organizationId,
+      server_time: 1708426963120,
+      query_params: {},
+      resource_uri: `${$.auth.data.apiDomain}/bigin/v1/Calls`,
+      affected_fields: [],
+    };
+
+    const dataItem = {
+      raw: sampleEventData,
+      meta: {
+        internalId: sampleEventData.channel_id,
+      },
+    };
+
+    $.pushTriggerItem(dataItem);
+  },
+
+  async registerHook($) {
+    const organizationId = $.step.parameters.organizationId;
+
+    const payload = {
+      watch: [
+        {
+          channel_id: organizationId,
+          notify_url: $.webhookUrl,
+          events: ['Calls.create'],
+        },
+      ],
+    };
+
+    await $.http.post('/bigin/v2/actions/watch', payload);
+
+    await $.flow.setRemoteWebhookId(organizationId);
+  },
+
+  async unregisterHook($) {
+    await $.http.delete(
+      `/bigin/v2/actions/watch?channel_ids=${$.flow.remoteWebhookId}`
+    );
+  },
+});

packages/backend/src/apps/bigin-by-zoho-crm/triggers/new-companies/index.js

@@ -0,0 +1,89 @@
+import Crypto from 'crypto';
+import defineTrigger from '../../../../helpers/define-trigger.js';
+
+export default defineTrigger({
+  name: 'New companies',
+  key: 'newCompanies',
+  type: 'webhook',
+  description: 'Triggers when a new company is created.',
+  arguments: [
+    {
+      label: 'Organization',
+      key: 'organizationId',
+      type: 'dropdown',
+      required: true,
+      description: '',
+      variables: false,
+      source: {
+        type: 'query',
+        name: 'getDynamicData',
+        arguments: [
+          {
+            name: 'key',
+            value: 'listOrganizations',
+          },
+        ],
+      },
+    },
+  ],
+
+  async run($) {
+    const dataItem = {
+      raw: $.request.body,
+      meta: {
+        internalId: Crypto.randomUUID(),
+      },
+    };
+
+    $.pushTriggerItem(dataItem);
+  },
+
+  async testRun($) {
+    const organizationId = $.step.parameters.organizationId;
+
+    const sampleEventData = {
+      ids: ['111111111111111111'],
+      token: null,
+      module: 'Accounts',
+      operation: 'insert',
+      channel_id: organizationId,
+      server_time: 1708426963120,
+      query_params: {},
+      resource_uri: `${$.auth.data.apiDomain}/bigin/v1/Accounts`,
+      affected_fields: [],
+    };
+
+    const dataItem = {
+      raw: sampleEventData,
+      meta: {
+        internalId: sampleEventData.channel_id,
+      },
+    };
+
+    $.pushTriggerItem(dataItem);
+  },
+
+  async registerHook($) {
+    const organizationId = $.step.parameters.organizationId;
+
+    const payload = {
+      watch: [
+        {
+          channel_id: organizationId,
+          notify_url: $.webhookUrl,
+          events: ['Accounts.create'],
+        },
+      ],
+    };
+
+    await $.http.post('/bigin/v2/actions/watch', payload);
+
+    await $.flow.setRemoteWebhookId(organizationId);
+  },
+
+  async unregisterHook($) {
+    await $.http.delete(
+      `/bigin/v2/actions/watch?channel_ids=${$.flow.remoteWebhookId}`
+    );
+  },
+});

packages/backend/src/apps/bigin-by-zoho-crm/triggers/new-contacts/index.js

@@ -0,0 +1,89 @@
+import Crypto from 'crypto';
+import defineTrigger from '../../../../helpers/define-trigger.js';
+
+export default defineTrigger({
+  name: 'New contacts',
+  key: 'newContacts',
+  type: 'webhook',
+  description: 'Triggers when a new contact is created.',
+  arguments: [
+    {
+      label: 'Organization',
+      key: 'organizationId',
+      type: 'dropdown',
+      required: true,
+      description: '',
+      variables: false,
+      source: {
+        type: 'query',
+        name: 'getDynamicData',
+        arguments: [
+          {
+            name: 'key',
+            value: 'listOrganizations',
+          },
+        ],
+      },
+    },
+  ],
+
+  async run($) {
+    const dataItem = {
+      raw: $.request.body,
+      meta: {
+        internalId: Crypto.randomUUID(),
+      },
+    };
+
+    $.pushTriggerItem(dataItem);
+  },
+
+  async testRun($) {
+    const organizationId = $.step.parameters.organizationId;
+
+    const sampleEventData = {
+      ids: ['111111111111111111'],
+      token: null,
+      module: 'Contacts',
+      operation: 'insert',
+      channel_id: organizationId,
+      server_time: 1708426963120,
+      query_params: {},
+      resource_uri: `${$.auth.data.apiDomain}/bigin/v1/Contacts`,
+      affected_fields: [],
+    };
+
+    const dataItem = {
+      raw: sampleEventData,
+      meta: {
+        internalId: sampleEventData.channel_id,
+      },
+    };
+
+    $.pushTriggerItem(dataItem);
+  },
+
+  async registerHook($) {
+    const organizationId = $.step.parameters.organizationId;
+
+    const payload = {
+      watch: [
+        {
+          channel_id: organizationId,
+          notify_url: $.webhookUrl,
+          events: ['Contacts.create'],
+        },
+      ],
+    };
+
+    await $.http.post('/bigin/v2/actions/watch', payload);
+
+    await $.flow.setRemoteWebhookId(organizationId);
+  },
+
+  async unregisterHook($) {
+    await $.http.delete(
+      `/bigin/v2/actions/watch?channel_ids=${$.flow.remoteWebhookId}`
+    );
+  },
+});

packages/backend/src/apps/bigin-by-zoho-crm/triggers/new-products/index.js

@@ -0,0 +1,89 @@
+import Crypto from 'crypto';
+import defineTrigger from '../../../../helpers/define-trigger.js';
+
+export default defineTrigger({
+  name: 'New products',
+  key: 'newProducts',
+  type: 'webhook',
+  description: 'Triggers when a new product is created.',
+  arguments: [
+    {
+      label: 'Organization',
+      key: 'organizationId',
+      type: 'dropdown',
+      required: true,
+      description: '',
+      variables: false,
+      source: {
+        type: 'query',
+        name: 'getDynamicData',
+        arguments: [
+          {
+            name: 'key',
+            value: 'listOrganizations',
+          },
+        ],
+      },
+    },
+  ],
+
+  async run($) {
+    const dataItem = {
+      raw: $.request.body,
+      meta: {
+        internalId: Crypto.randomUUID(),
+      },
+    };
+
+    $.pushTriggerItem(dataItem);
+  },
+
+  async testRun($) {
+    const organizationId = $.step.parameters.organizationId;
+
+    const sampleEventData = {
+      ids: ['111111111111111111'],
+      token: null,
+      module: 'Products',
+      operation: 'insert',
+      channel_id: organizationId,
+      server_time: 1708426963120,
+      query_params: {},
+      resource_uri: `${$.auth.data.apiDomain}/bigin/v1/Products`,
+      affected_fields: [],
+    };
+
+    const dataItem = {
+      raw: sampleEventData,
+      meta: {
+        internalId: sampleEventData.channel_id,
+      },
+    };
+
+    $.pushTriggerItem(dataItem);
+  },
+
+  async registerHook($) {
+    const organizationId = $.step.parameters.organizationId;
+
+    const payload = {
+      watch: [
+        {
+          channel_id: organizationId,
+          notify_url: $.webhookUrl,
+          events: ['Products.create'],
+        },
+      ],
+    };
+
+    await $.http.post('/bigin/v2/actions/watch', payload);
+
+    await $.flow.setRemoteWebhookId(organizationId);
+  },
+
+  async unregisterHook($) {
+    await $.http.delete(
+      `/bigin/v2/actions/watch?channel_ids=${$.flow.remoteWebhookId}`
+    );
+  },
+});

packages/backend/src/apps/bigin-by-zoho-crm/triggers/new-tasks/index.js

@@ -0,0 +1,89 @@
+import Crypto from 'crypto';
+import defineTrigger from '../../../../helpers/define-trigger.js';
+
+export default defineTrigger({
+  name: 'New tasks',
+  key: 'newTasks',
+  type: 'webhook',
+  description: 'Triggers when a new task is created.',
+  arguments: [
+    {
+      label: 'Organization',
+      key: 'organizationId',
+      type: 'dropdown',
+      required: true,
+      description: '',
+      variables: false,
+      source: {
+        type: 'query',
+        name: 'getDynamicData',
+        arguments: [
+          {
+            name: 'key',
+            value: 'listOrganizations',
+          },
+        ],
+      },
+    },
+  ],
+
+  async run($) {
+    const dataItem = {
+      raw: $.request.body,
+      meta: {
+        internalId: Crypto.randomUUID(),
+      },
+    };
+
+    $.pushTriggerItem(dataItem);
+  },
+
+  async testRun($) {
+    const organizationId = $.step.parameters.organizationId;
+
+    const sampleEventData = {
+      ids: ['111111111111111111'],
+      token: null,
+      module: 'Tasks',
+      operation: 'insert',
+      channel_id: organizationId,
+      server_time: 1708426963120,
+      query_params: {},
+      resource_uri: `${$.auth.data.apiDomain}/bigin/v1/Tasks`,
+      affected_fields: [],
+    };
+
+    const dataItem = {
+      raw: sampleEventData,
+      meta: {
+        internalId: sampleEventData.channel_id,
+      },
+    };
+
+    $.pushTriggerItem(dataItem);
+  },
+
+  async registerHook($) {
+    const organizationId = $.step.parameters.organizationId;
+
+    const payload = {
+      watch: [
+        {
+          channel_id: organizationId,
+          notify_url: $.webhookUrl,
+          events: ['Tasks.create'],
+        },
+      ],
+    };
+
+    await $.http.post('/bigin/v2/actions/watch', payload);
+
+    await $.flow.setRemoteWebhookId(organizationId);
+  },
+
+  async unregisterHook($) {
+    await $.http.delete(
+      `/bigin/v2/actions/watch?channel_ids=${$.flow.remoteWebhookId}`
+    );
+  },
+});

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

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

packages/backend/src/apps/datastore/actions/get-value/index.js

@@ -1,27 +0,0 @@
-import defineAction from '../../../../helpers/define-action.js';
-
-export default defineAction({
-  name: 'Get value',
-  key: 'getValue',
-  description: 'Get value from the persistent datastore.',
-  arguments: [
-    {
-      label: 'Key',
-      key: 'key',
-      type: 'string',
-      required: true,
-      description: 'The key of your value to get.',
-      variables: true,
-    },
-  ],
-
-  async run($) {
-    const keyValuePair = await $.datastore.get({
-      key: $.step.parameters.key,
-    });
-
-    $.setActionItem({
-      raw: keyValuePair,
-    });
-  },
-});

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

@@ -1,4 +0,0 @@
-import getValue from './get-value/index.js';
-import setValue from './set-value/index.js';
-
-export default [getValue, setValue];

packages/backend/src/apps/datastore/actions/set-value/index.js

@@ -1,36 +0,0 @@
-import defineAction from '../../../../helpers/define-action.js';
-
-export default defineAction({
-  name: 'Set value',
-  key: 'setValue',
-  description: 'Set value to the persistent datastore.',
-  arguments: [
-    {
-      label: 'Key',
-      key: 'key',
-      type: 'string',
-      required: true,
-      description: 'The key of your value to set.',
-      variables: true,
-    },
-    {
-      label: 'Value',
-      key: 'value',
-      type: 'string',
-      required: true,
-      description: 'The value to set.',
-      variables: true,
-    },
-  ],
-
-  async run($) {
-    const keyValuePair = await $.datastore.set({
-      key: $.step.parameters.key,
-      value: $.step.parameters.value,
-    });
-
-    $.setActionItem({
-      raw: keyValuePair,
-    });
-  },
-});

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

@@ -1,13 +0,0 @@
-<?xml version="1.0"?>
-<svg xmlns="http://www.w3.org/2000/svg" fill="#000000" width="800px" height="800px" viewBox="0 0 32 32" id="icon">
-  <defs>
-    <style>.cls-1{fill:none;}</style>
-  </defs>
-  <title>datastore</title>
-  <circle cx="23" cy="23" r="1"/>
-  <rect x="8" y="22" width="12" height="2"/>
-  <circle cx="23" cy="9" r="1"/>
-  <rect x="8" y="8" width="12" height="2"/>
-  <path d="M26,14a2,2,0,0,0,2-2V6a2,2,0,0,0-2-2H6A2,2,0,0,0,4,6v6a2,2,0,0,0,2,2H8v4H6a2,2,0,0,0-2,2v6a2,2,0,0,0,2,2H26a2,2,0,0,0,2-2V20a2,2,0,0,0-2-2H24V14ZM6,6H26v6H6ZM26,26H6V20H26Zm-4-8H10V14H22Z"/>
-  <rect id="_Transparent_Rectangle_" data-name="&lt;Transparent Rectangle&gt;" class="cls-1" width="32" height="32"/>
-</svg>

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

@@ -1,14 +0,0 @@
-import defineApp from '../../helpers/define-app.js';
-import actions from './actions/index.js';
-
-export default defineApp({
-  name: 'Datastore',
-  key: 'datastore',
-  iconUrl: '{BASE_URL}/apps/datastore/assets/favicon.svg',
-  authDocUrl: '{DOCS_URL}/apps/datastore/connection',
-  supportsConnections: false,
-  baseUrl: '',
-  apiBaseUrl: '',
-  primaryColor: '001F52',
-  actions,
-});

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

packages/backend/src/apps/helix/actions/new-chat/index.js

@@ -1,3 +1,4 @@
+import FormData from 'form-data';
 import defineAction from '../../../../helpers/define-action.js';
 
 export default defineAction({
@@ -5,51 +6,45 @@ export default defineAction({
   key: 'newChat',
   description: 'Create a new chat session for Helix AI.',
   arguments: [
-    {
-      label: 'Session ID',
-      key: 'sessionId',
-      type: 'string',
-      required: false,
-      description:
-        'ID of the chat session to continue. Leave empty to start a new chat.',
-      variables: true,
-    },
-    {
-      label: 'System Prompt',
-      key: 'systemPrompt',
-      type: 'string',
-      required: false,
-      description:
-        'Optional system prompt to start the chat with. It will be used only for new chat sessions.',
-      variables: true,
-    },
     {
       label: 'Input',
       key: 'input',
       type: 'string',
       required: true,
-      description: 'User input to start the chat with.',
+      description: 'Prompt to start the chat with.',
       variables: true,
     },
   ],
 
   async run($) {
-    const response = await $.http.post('/api/v1/sessions/chat', {
+    const formData = new FormData();
-      session_id: $.step.parameters.sessionId,
+    formData.append('input', $.step.parameters.input);
-      system: $.step.parameters.systemPrompt,
+    formData.append('mode', 'inference');
-      messages: [
+    formData.append('type', 'text');
-        {
+
-          role: 'user',
+    const sessionResponse = await $.http.post('/api/v1/sessions', formData, {
-          content: {
+      headers: {
-            content_type: 'text',
+        ...formData.getHeaders(),
-            parts: [$.step.parameters.input],
+      },
-          },
-        },
-      ],
     });
 
-    $.setActionItem({
+    const sessionId = sessionResponse.data.id;
-      raw: response.data,
+
-    });
+    let chatGenerated = false;
+
+    while (!chatGenerated) {
+      const response = await $.http.get(`/api/v1/sessions/${sessionId}`);
+
+      const message =
+        response.data.interactions[response.data.interactions.length - 1];
+
+      if (message.creator === 'system' && message.state === 'complete') {
+        $.setActionItem({
+          raw: message,
+        });
+
+        chatGenerated = true;
+      }
+    }
   },
 });

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

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

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

@@ -90,7 +90,7 @@ export default defineAction({
 
   async run($) {
     const method = $.step.parameters.method;
-    const data = $.step.parameters.data || null;
+    const data = $.step.parameters.data;
     const url = $.step.parameters.url;
     const headers = $.step.parameters.headers;
 
@@ -108,17 +108,14 @@ export default defineAction({
       return result;
     }, {});
 
-    let expectedResponseContentType = headersObject.accept;
+    let contentType = headersObject['content-type'];
 
     // in case HEAD request is not supported by the URL
     try {
       const metadataResponse = await $.http.head(url, {
         headers: headersObject,
       });
-
+      contentType = metadataResponse.headers['content-type'];
-      if (!expectedResponseContentType) {
-        expectedResponseContentType = metadataResponse.headers['content-type'];
-      }
 
       throwIfFileSizeExceedsLimit(metadataResponse.headers['content-length']);
       // eslint-disable-next-line no-empty
@@ -131,7 +128,7 @@ export default defineAction({
       headers: headersObject,
     };
 
-    if (!isPossiblyTextBased(expectedResponseContentType)) {
+    if (!isPossiblyTextBased(contentType)) {
       requestData.responseType = 'arraybuffer';
     }
 
@@ -141,7 +138,7 @@ export default defineAction({
 
     let responseData = response.data;
 
-    if (!isPossiblyTextBased(expectedResponseContentType)) {
+    if (!isPossiblyTextBased(contentType)) {
       responseData = Buffer.from(responseData).toString('base64');
     }
 

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

packages/backend/src/apps/pipedrive/actions/create-deal/index.js

@@ -64,17 +64,32 @@ export default defineAction({
       value: '1',
       description:
         'The ID of the stage this deal will be added to. If omitted, the deal will be placed in the first stage of the default pipeline.',
-      variables: true,
+      options: [
-      source: {
+        {
-        type: 'query',
+          label: 'Qualified (Pipeline)',
-        name: 'getDynamicData',
+          value: 1,
-        arguments: [
+        },
-          {
+        {
-            name: 'key',
+          label: 'Contact Made (Pipeline)',
-            value: 'listStages',
+          value: 2,
-          },
+        },
-        ],
+        {
-      },
+          label: 'Prospect Qualified (Pipeline)',
+          value: 3,
+        },
+        {
+          label: 'Needs Defined (Pipeline)',
+          value: 4,
+        },
+        {
+          label: 'Proposal Made (Pipeline)',
+          value: 5,
+        },
+        {
+          label: 'Negotiations Started (Pipeline)',
+          value: 6,
+        },
+      ],
     },
     {
       label: 'Owner',

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

@@ -1,25 +1,23 @@
 import listActivityTypes from './list-activity-types/index.js';
 import listCurrencies from './list-currencies/index.js';
 import listDeals from './list-deals/index.js';
-import listLeadLabels from './list-lead-labels/index.js';
 import listLeads from './list-leads/index.js';
-import listOrganizationLabelField from './list-organization-label-field/index.js';
+import listLeadLabels from './list-lead-labels/index.js';
 import listOrganizations from './list-organizations/index.js';
+import listOrganizationLabelField from './list-organization-label-field/index.js';
 import listPersonLabelField from './list-person-label-field/index.js';
 import listPersons from './list-persons/index.js';
-import listStages from './list-stages/index.js';
 import listUsers from './list-users/index.js';
 
 export default [
   listActivityTypes,
   listCurrencies,
   listDeals,
-  listLeadLabels,
   listLeads,
-  listOrganizationLabelField,
+  listLeadLabels,
   listOrganizations,
+  listOrganizationLabelField,
   listPersonLabelField,
   listPersons,
-  listStages,
   listUsers,
 ];

packages/backend/src/apps/pipedrive/dynamic-data/list-stages/index.js

@@ -1,23 +0,0 @@
-export default {
-  name: 'List stages',
-  key: 'listStages',
-
-  async run($) {
-    const stages = {
-      data: [],
-    };
-
-    const { data } = await $.http.get('/api/v1/stages');
-
-    if (data.data?.length) {
-      for (const stage of data.data) {
-        stages.data.push({
-          value: stage.id,
-          name: stage.name,
-        });
-      }
-    }
-
-    return stages;
-  },
-};

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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