test: rewrite flow editor tests with playwright

feat: Implement initial version of formatter app

.devcontainer/docker-compose.yml

@@ -33,7 +33,32 @@ services:
       - '6379:6379'
     expose:
       - 6379
+  keycloak:
+    image: quay.io/keycloak/keycloak:21.1
+    restart: always
+    container_name: keycloak
+    environment:
+      - KEYCLOAK_ADMIN=admin
+      - KEYCLOAK_ADMIN_PASSWORD=admin
+      - KC_DB=postgres
+      - KC_DB_URL_HOST=postgres
+      - KC_DB_URL_DATABASE=keycloak
+      - KC_DB_USERNAME=automatisch_user
+      - KC_DB_PASSWORD=automatisch_password
+      - KC_HEALTH_ENABLED=true
+    ports:
+      - "8080:8080"
+    command: start-dev
+    depends_on:
+      - postgres
+    healthcheck:
+      test: "curl -f http://localhost:8080/health/ready || exit 1"
+    volumes:
+      - keycloak:/opt/keycloak/data/
+    expose:
+      - 8080
 
 volumes:
   postgres_data:
   redis_data:
+  keycloak:

.dockerignore

@@ -0,0 +1,8 @@
+**/node_modules/
+**/dist/
+**/logs/
+**/.devcontainer
+**/.github
+**/.vscode
+packages/docs
+packages/e2e-test

.github/workflows/playwright.yml

@@ -0,0 +1,25 @@
+name: Automatisch UI Test
+on:
+  schedule:
+    - cron: '0 12 * * *'
+jobs:
+  test:
+    timeout-minutes: 60
+    runs-on: ubuntu-latest
+    steps:
+      - uses: actions/checkout@v3
+      - uses: actions/setup-node@v3
+        with:
+          node-version: 18
+      - name: Install dependencies
+        run: yarn
+      - name: Install Playwright Browsers
+        run: yarn playwright install --with-deps
+      - name: Run Playwright tests
+        run: yarn playwright test
+      - uses: actions/upload-artifact@v3
+        if: always()
+        with:
+          name: playwright-report
+          path: playwright-report/
+          retention-days: 30

.gitignore

@@ -125,3 +125,6 @@ dist
 .yarn/build-state.yml
 .yarn/install-state.gz
 .pnp.*
+
+# MacOS finder preferences
+.DS_store

docker/Dockerfile

@@ -4,7 +4,7 @@ WORKDIR /automatisch
 
 RUN \
   apk --no-cache add --virtual build-dependencies python3 build-base && \
-  yarn global add @automatisch/cli@0.6.1 --network-timeout 1000000 && \
+  yarn global add @automatisch/cli@0.8.0 --network-timeout 1000000 && \
   rm -rf /usr/local/share/.cache/ && \
   apk del build-dependencies
 

docker/Dockerfile.cloud

@@ -0,0 +1,19 @@
+# syntax=docker/dockerfile:1
+FROM node:16-alpine
+WORKDIR /automatisch
+
+ENV PORT 3000
+
+RUN ls -lna
+
+# copy the app, note .dockerignore
+COPY . ./
+
+RUN yarn
+RUN yarn lerna bootstrap
+RUN yarn lerna run --scope=@*/{web,backend,cli} build
+
+COPY ./docker/entrypoint-cloud.sh /entrypoint-cloud.sh
+
+EXPOSE 3000
+ENTRYPOINT ["sh", "/entrypoint-cloud.sh"]

docker/Dockerfile.compose

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

docker/entrypoint-cloud.sh

@@ -0,0 +1,9 @@
+#!/bin/sh
+
+set -e
+
+if [ -n "$WORKER" ]; then
+  yarn automatisch start-worker
+else
+  yarn automatisch start
+fi

lerna.json

@@ -2,7 +2,7 @@
   "packages": [
     "packages/*"
   ],
-  "version": "0.6.1",
+  "version": "0.8.0",
   "npmClient": "yarn",
   "useWorkspaces": true,
   "command": {

packages/backend/bin/database/utils.ts

@@ -2,18 +2,33 @@ import appConfig from '../../src/config/app';
 import logger from '../../src/helpers/logger';
 import client from './client';
 import User from '../../src/models/user';
+import Role from '../../src/models/role';
 import '../../src/config/orm';
 
+async function fetchAdminRole() {
+  const role = await Role
+    .query()
+    .where({
+      key: 'admin'
+    })
+    .limit(1)
+    .first();
+
+  return role;
+}
+
 export async function createUser(
   email = 'user@automatisch.io',
   password = 'sample'
 ) {
   const UNIQUE_VIOLATION_CODE = '23505';
+
+  const role = await fetchAdminRole();
   const userParams = {
     email,
     password,
     fullName: 'Initial admin',
-    role: 'admin',
+    roleId: role.id,
   };
 
   try {

packages/backend/knexfile.ts

@@ -12,6 +12,7 @@ const knexConfig = {
     database: appConfig.postgresDatabase,
     ssl: appConfig.postgresEnableSsl,
   },
+  asyncStackTraces: appConfig.isDev,
   searchPath: [appConfig.postgresSchema],
   pool: { min: 0, max: 20 },
   migrations: {

packages/backend/package.json

@@ -1,10 +1,10 @@
 {
   "name": "@automatisch/backend",
-  "version": "0.6.1",
+  "version": "0.8.0",
   "license": "See LICENSE file",
   "description": "The open source Zapier alternative. Build workflow automation without spending time and money.",
   "scripts": {
-    "dev": "ts-node-dev --exit-child src/server.ts",
+    "dev": "ts-node-dev --watch 'src/graphql/schema.graphql' --exit-child src/server.ts",
     "worker": "nodemon --watch 'src/**/*.ts' --exec 'ts-node' src/worker.ts",
     "build": "tsc && yarn copy-statics",
     "build:watch": "nodemon --watch 'src/**/*.ts' --watch 'bin/**/*.ts' --exec yarn build --ext ts",
@@ -22,14 +22,18 @@
     "prebuild": "rm -rf ./dist"
   },
   "dependencies": {
-    "@automatisch/web": "^0.6.1",
+    "@automatisch/web": "^0.8.0",
     "@bull-board/express": "^3.10.1",
+    "@casl/ability": "^6.5.0",
     "@graphql-tools/graphql-file-loader": "^7.3.4",
     "@graphql-tools/load": "^7.5.2",
+    "@node-saml/passport-saml": "^4.0.4",
     "@rudderstack/rudder-sdk-node": "^1.1.2",
     "@sentry/node": "^7.42.0",
     "@sentry/tracing": "^7.42.0",
     "@types/luxon": "^2.3.1",
+    "@types/passport": "^1.0.12",
+    "@types/xmlrpc": "^1.3.7",
     "ajv-formats": "^2.1.1",
     "axios": "0.24.0",
     "bcrypt": "^5.0.1",
@@ -49,6 +53,8 @@
     "graphql-type-json": "^0.3.2",
     "handlebars": "^4.7.7",
     "http-errors": "~1.6.3",
+    "http-proxy-agent": "^7.0.0",
+    "https-proxy-agent": "^7.0.1",
     "jsonwebtoken": "^9.0.0",
     "knex": "^2.4.0",
     "lodash.get": "^4.4.2",
@@ -56,13 +62,17 @@
     "memory-cache": "^0.2.0",
     "morgan": "^1.10.0",
     "multer": "1.4.5-lts.1",
+    "node-html-markdown": "^1.3.0",
     "nodemailer": "6.7.0",
     "oauth-1.0a": "^2.2.6",
     "objection": "^3.0.0",
+    "passport": "^0.6.0",
     "pg": "^8.7.1",
     "php-serialize": "^4.0.2",
+    "showdown": "^2.1.0",
     "stripe": "^11.13.0",
-    "winston": "^3.7.1"
+    "winston": "^3.7.1",
+    "xmlrpc": "^1.3.2"
   },
   "contributors": [
     {
@@ -100,7 +110,7 @@
     "url": "https://github.com/automatisch/automatisch/issues"
   },
   "devDependencies": {
-    "@automatisch/types": "^0.6.1",
+    "@automatisch/types": "^0.8.0",
     "@types/bcrypt": "^5.0.0",
     "@types/bull": "^3.15.8",
     "@types/cors": "^2.8.12",
@@ -116,6 +126,7 @@
     "@types/nodemailer": "^6.4.4",
     "@types/pg": "^8.6.1",
     "@types/pino": "^7.0.5",
+    "@types/showdown": "^2.0.1",
     "ava": "^3.15.0",
     "nodemon": "^2.0.13",
     "sinon": "^11.1.2",

packages/backend/src/app.ts

@@ -17,6 +17,7 @@ import {
 } from './helpers/create-bull-board-handler';
 import injectBullBoardHandler from './helpers/inject-bull-board-handler';
 import router from './routes';
+import configurePassport from './helpers/passport';
 
 createBullBoardHandler(serverAdapter);
 
@@ -50,6 +51,9 @@ app.use(
   })
 );
 app.use(cors(corsOptions));
+
+configurePassport(app);
+
 app.use('/', router);
 
 webUIHandler(app);

packages/backend/src/apps/deepl/actions/translate-text/index.ts

@@ -2,7 +2,7 @@ import qs from 'qs';
 import defineAction from '../../../../helpers/define-action';
 
 export default defineAction({
-  name: 'Translate Text',
+  name: 'Translate text',
   key: 'translateText',
   description: 'Translates text from one language to another.',
   arguments: [
@@ -20,7 +20,7 @@ export default defineAction({
       type: 'dropdown' as const,
       required: true,
       description: 'Language to translate the text to.',
-      variables: false,
+      variables: true,
       value: '',
       options: [
         { label: 'Bulgarian', value: 'BG' },

packages/backend/src/apps/delay/actions/delay-for/index.ts

@@ -1,7 +1,7 @@
 import defineAction from '../../../../helpers/define-action';
 
 export default defineAction({
-  name: 'Delay For',
+  name: 'Delay for',
   key: 'delayFor',
   description:
     'Delays the execution of the next action by a specified amount of time.',
@@ -13,7 +13,7 @@ export default defineAction({
       required: true,
       value: null,
       description: 'Delay for unit, e.g. minutes, hours, days, weeks.',
-      variables: false,
+      variables: true,
       options: [
         {
           label: 'Minutes',

packages/backend/src/apps/delay/actions/delay-until/index.ts

@@ -1,7 +1,7 @@
 import defineAction from '../../../../helpers/define-action';
 
 export default defineAction({
-  name: 'Delay Until',
+  name: 'Delay until',
   key: 'delayUntil',
   description:
     'Delays the execution of the next action until a specified date.',

packages/backend/src/apps/discord/actions/send-message-to-channel/index.ts

@@ -11,7 +11,7 @@ export default defineAction({
       type: 'dropdown' as const,
       required: true,
       description: 'Pick a channel to send the message to.',
-      variables: false,
+      variables: true,
       source: {
         type: 'query',
         name: 'getDynamicData',

packages/backend/src/apps/discord/dynamic-data/list-channels/index.ts

@@ -19,8 +19,8 @@ export default {
 
     channels.data = response.data
       .filter((channel: IJSONObject) => {
-        // filter in text channels only
+        // filter in text channels and announcement channels only
-        return channel.type === 0;
+        return channel.type === 0 || channel.type === 5;
       })
       .map((channel: IJSONObject) => {
         return {

packages/backend/src/apps/filter/actions/continue/index.ts

@@ -10,7 +10,7 @@ type TGroupItem = {
 type TGroup = Record<'and', TGroupItem[]>;
 
 const isEqual = (a: string, b: string) => a === b;
-const isNotEqual = (a: string, b: string) => !isEqual(a, b)
+const isNotEqual = (a: string, b: string) => !isEqual(a, b);
 const isGreaterThan = (a: string, b: string) => Number(a) > Number(b);
 const isLessThan = (a: string, b: string) => Number(a) < Number(b);
 const isGreaterThanOrEqual = (a: string, b: string) => Number(a) >= Number(b);
@@ -18,6 +18,36 @@ const isLessThanOrEqual = (a: string, b: string) => Number(a) <= Number(b);
 const contains = (a: string, b: string) => a.includes(b);
 const doesNotContain = (a: string, b: string) => !contains(a, b);
 
+const shouldContinue = (orGroups: TGroup[]) => {
+  let atLeastOneGroupMatches = false;
+
+  for (const group of orGroups) {
+    let groupMatches = true;
+
+    for (const condition of group.and) {
+      const conditionMatches = operate(
+        condition.operator,
+        condition.key,
+        condition.value
+      );
+
+      if (!conditionMatches) {
+        groupMatches = false;
+
+        break;
+      }
+    }
+
+    if (groupMatches) {
+      atLeastOneGroupMatches = true;
+
+      break;
+    }
+  }
+
+  return atLeastOneGroupMatches;
+}
+
 type TOperatorFunc = (a: string, b: string) => boolean;
 
 type TOperators = {
@@ -66,7 +96,7 @@ export default defineAction({
       return groups;
     }, []);
 
-    if (matchingGroups.length === 0) {
+    if (!shouldContinue(orGroups)) {
       $.execution.exit();
     }
 

packages/backend/src/apps/flowers-software/triggers/new-activity/index.ts

@@ -20,12 +20,14 @@ export default defineTrigger({
   ],
 
   async testRun($) {
-    if (!isEmpty($.lastExecutionStep?.dataOut)) {
+    const lastExecutionStep = await $.getLastExecutionStep();
+
+    if (!isEmpty(lastExecutionStep?.dataOut)) {
       $.pushTriggerItem({
-        raw: $.lastExecutionStep.dataOut,
+        raw: lastExecutionStep.dataOut,
         meta: {
           internalId: '',
-        }
+        },
       });
     }
   },
@@ -35,20 +37,15 @@ export default defineTrigger({
       name: $.flow.id,
       type: 'POST',
       url: $.webhookUrl,
-      filters: [$.step.parameters.filters]
+      filters: [$.step.parameters.filters],
     };
 
-    const { data } = await $.http.post(
+    const { data } = await $.http.post(`/v2/public/api/webhooks`, payload);
-      `/v2/public/api/webhooks`,
-      payload
-    );
 
     await $.flow.setRemoteWebhookId(data.id);
   },
 
   async unregisterHook($) {
-    await $.http.delete(
+    await $.http.delete(`/v2/public/api/webhooks/${$.flow.remoteWebhookId}`);
-      `/v2/public/api/webhooks/${$.flow.remoteWebhookId}`
-    );
   },
 });

packages/backend/src/apps/formatter/actions/index.ts

@@ -0,0 +1,3 @@
+import text from './text';
+
+export default [text];

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

@@ -0,0 +1,64 @@
+import defineAction from '../../../../helpers/define-action';
+import capitalize from './transformers/capitalize';
+import htmlToMarkdown from './transformers/html-to-markdown';
+import markdownToHtml from './transformers/markdown-to-html';
+import useDefaultValue from './transformers/use-default-value';
+import extractEmailAddress from './transformers/extract-email-address';
+
+const transformers = {
+  capitalize,
+  htmlToMarkdown,
+  markdownToHtml,
+  useDefaultValue,
+  extractEmailAddress,
+};
+
+export default defineAction({
+  name: 'Text',
+  key: 'text',
+  description:
+    'Transform text data to capitalize, extract emails, apply default value, and much more.',
+  arguments: [
+    {
+      label: 'Transform',
+      key: 'transform',
+      type: 'dropdown' as const,
+      required: true,
+      description: 'Pick a channel to send the message to.',
+      variables: true,
+      options: [
+        { label: 'Capitalize', value: 'capitalize' },
+        { label: 'Convert HTML to Markdown', value: 'htmlToMarkdown' },
+        { label: 'Convert Markdown to HTML', value: 'markdownToHtml' },
+        { label: 'Use Default Value', value: 'useDefaultValue' },
+        { label: 'Extract Email Address', value: 'extractEmailAddress' },
+      ],
+      additionalFields: {
+        type: 'query',
+        name: 'getDynamicFields',
+        arguments: [
+          {
+            name: 'key',
+            value: 'listTransformOptions',
+          },
+          {
+            name: 'parameters.transform',
+            value: '{parameters.transform}',
+          },
+        ],
+      },
+    },
+  ],
+
+  async run($) {
+    const transformerName = $.step.parameters
+      .transform as keyof typeof transformers;
+    const output = transformers[transformerName]($);
+
+    $.setActionItem({
+      raw: {
+        output,
+      },
+    });
+  },
+});

packages/backend/src/apps/formatter/actions/text/transformers/capitalize.ts

@@ -0,0 +1,11 @@
+import { IGlobalVariable } from '@automatisch/types';
+import { capitalize as lodashCapitalize } from 'lodash';
+
+const capitalize = ($: IGlobalVariable) => {
+  const input = $.step.parameters.input as string;
+  const capitalizedInput = input.replace(/\w+/g, lodashCapitalize);
+
+  return capitalizedInput;
+};
+
+export default capitalize;

packages/backend/src/apps/formatter/actions/text/transformers/extract-email-address.ts

@@ -0,0 +1,12 @@
+import { IGlobalVariable } from '@automatisch/types';
+
+const extractEmailAddress = ($: IGlobalVariable) => {
+  const input = $.step.parameters.input as string;
+  const emailRegexp =
+    /[a-z0-9!#$%&'*+/=?^_`{|}~-]+(?:\.[a-z0-9!#$%&'*+/=?^_`{|}~-]+)*@(?:[a-z0-9](?:[a-z0-9-]*[a-z0-9])?\.)+[a-z0-9](?:[a-z0-9-]*[a-z0-9])?/;
+
+  const email = input.match(emailRegexp);
+  return email ? email[0] : '';
+};
+
+export default extractEmailAddress;

packages/backend/src/apps/formatter/actions/text/transformers/html-to-markdown.ts

@@ -0,0 +1,11 @@
+import { IGlobalVariable } from '@automatisch/types';
+import { NodeHtmlMarkdown } from 'node-html-markdown';
+
+const htmlToMarkdown = ($: IGlobalVariable) => {
+  const input = $.step.parameters.input as string;
+
+  const markdown = NodeHtmlMarkdown.translate(input);
+  return markdown;
+};
+
+export default htmlToMarkdown;

packages/backend/src/apps/formatter/actions/text/transformers/markdown-to-html.ts

@@ -0,0 +1,13 @@
+import { IGlobalVariable } from '@automatisch/types';
+import showdown from 'showdown';
+
+const converter = new showdown.Converter();
+
+const markdownToHtml = ($: IGlobalVariable) => {
+  const input = $.step.parameters.input as string;
+
+  const html = converter.makeHtml(input);
+  return html;
+};
+
+export default markdownToHtml;

packages/backend/src/apps/formatter/actions/text/transformers/use-default-value.ts

@@ -0,0 +1,13 @@
+import { IGlobalVariable } from '@automatisch/types';
+
+const useDefaultValue = ($: IGlobalVariable) => {
+  const input = $.step.parameters.input as string;
+
+  if (input && input.trim().length > 0) {
+    return input;
+  }
+
+  return $.step.parameters.defaultValue as string;
+};
+
+export default useDefaultValue;

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

@@ -0,0 +1,3 @@
+<svg width="800px" height="800px" viewBox="0 0 24 24" fill="none" xmlns="http://www.w3.org/2000/svg">
+  <path d="M4 4H20M4 12H20M4 20H20M4 8H14M4 16H14" stroke="#000000" stroke-width="2" stroke-linecap="round" stroke-linejoin="round"/>
+</svg>

packages/backend/src/apps/formatter/dynamic-fields/index.ts

@@ -0,0 +1,3 @@
+import listTransformOptions from './list-transform-options';
+
+export default [listTransformOptions];

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

@@ -0,0 +1,23 @@
+import { IGlobalVariable, IJSONObject } from '@automatisch/types';
+import capitalize from './options/capitalize';
+import htmlToMarkdown from './options/html-to-markdown';
+import markdownToHtml from './options/markdown-to-html';
+import useDefaultValue from './options/use-default-value';
+import extractEmailAddress from './options/extract-email-address';
+
+const options: IJSONObject = {
+  capitalize,
+  htmlToMarkdown,
+  markdownToHtml,
+  useDefaultValue,
+  extractEmailAddress,
+};
+
+export default {
+  name: 'List fields after transform',
+  key: 'listTransformOptions',
+
+  async run($: IGlobalVariable) {
+    return options[$.step.parameters.transform as string];
+  },
+};

packages/backend/src/apps/formatter/dynamic-fields/list-transform-options/options/capitalize.ts

@@ -0,0 +1,12 @@
+const capitalize = [
+  {
+    label: 'Input',
+    key: 'input',
+    type: 'string' as const,
+    required: true,
+    description: 'Text that will be capitalized.',
+    variables: true,
+  },
+];
+
+export default capitalize;

packages/backend/src/apps/formatter/dynamic-fields/list-transform-options/options/extract-email-address.ts

@@ -0,0 +1,12 @@
+const extractEmailAddress = [
+  {
+    label: 'Input',
+    key: 'input',
+    type: 'string' as const,
+    required: true,
+    description: 'Text that will be searched for an email address.',
+    variables: true,
+  },
+];
+
+export default extractEmailAddress;

packages/backend/src/apps/formatter/dynamic-fields/list-transform-options/options/html-to-markdown.ts

@@ -0,0 +1,12 @@
+const htmlToMarkdown = [
+  {
+    label: 'Input',
+    key: 'input',
+    type: 'string' as const,
+    required: true,
+    description: 'HTML that will be converted to Markdown.',
+    variables: true,
+  },
+];
+
+export default htmlToMarkdown;

packages/backend/src/apps/formatter/dynamic-fields/list-transform-options/options/markdown-to-html.ts

@@ -0,0 +1,12 @@
+const markdownToHtml = [
+  {
+    label: 'Input',
+    key: 'input',
+    type: 'string' as const,
+    required: true,
+    description: 'Markdown text that will be converted to HTML.',
+    variables: true,
+  },
+];
+
+export default markdownToHtml;

packages/backend/src/apps/formatter/dynamic-fields/list-transform-options/options/use-default-value.ts

@@ -0,0 +1,21 @@
+const useDefaultValue = [
+  {
+    label: 'Input',
+    key: 'input',
+    type: 'string' as const,
+    required: true,
+    description: 'Text you want to check whether it is empty or not.',
+    variables: true,
+  },
+  {
+    label: 'Default Value',
+    key: 'defaultValue',
+    type: 'string' as const,
+    required: true,
+    description:
+      'Text that will be used as a default value if the input is empty.',
+    variables: true,
+  },
+];
+
+export default useDefaultValue;

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

@@ -0,0 +1,16 @@
+import defineApp from '../../helpers/define-app';
+import actions from './actions';
+import dynamicFields from './dynamic-fields';
+
+export default defineApp({
+  name: 'Formatter',
+  key: 'formatter',
+  iconUrl: '{BASE_URL}/apps/formatter/assets/favicon.svg',
+  authDocUrl: 'https://automatisch.io/docs/apps/formatter/connection',
+  supportsConnections: false,
+  baseUrl: '',
+  apiBaseUrl: '',
+  primaryColor: '001F52',
+  actions,
+  dynamicFields,
+});

packages/backend/src/apps/github/actions/create-issue/index.ts

@@ -11,7 +11,7 @@ export default defineAction({
       key: 'repo',
       type: 'dropdown' as const,
       required: false,
-      variables: false,
+      variables: true,
       source: {
         type: 'query',
         name: 'getDynamicData',

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

@@ -6,7 +6,7 @@ import actions from './actions';
 import dynamicData from './dynamic-data';
 
 export default defineApp({
-  name: 'Github',
+  name: 'GitHub',
   key: 'github',
   baseUrl: 'https://github.com',
   apiBaseUrl: 'https://api.github.com',

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

@@ -0,0 +1,2 @@
+<!-- https://about.gitlab.com/images/press/logo/svg/gitlab-logo-500.svg -->
+<svg xmlns="http://www.w3.org/2000/svg" viewBox="0 0 380 380"><defs><style>.cls-1{fill:#e24329;}.cls-2{fill:#fc6d26;}.cls-3{fill:#fca326;}</style></defs><g id="LOGO"><path class="cls-1" d="M282.83,170.73l-.27-.69-26.14-68.22a6.81,6.81,0,0,0-2.69-3.24,7,7,0,0,0-8,.43,7,7,0,0,0-2.32,3.52l-17.65,54H154.29l-17.65-54A6.86,6.86,0,0,0,134.32,99a7,7,0,0,0-8-.43,6.87,6.87,0,0,0-2.69,3.24L97.44,170l-.26.69a48.54,48.54,0,0,0,16.1,56.1l.09.07.24.17,39.82,29.82,19.7,14.91,12,9.06a8.07,8.07,0,0,0,9.76,0l12-9.06,19.7-14.91,40.06-30,.1-.08A48.56,48.56,0,0,0,282.83,170.73Z"/><path class="cls-2" d="M282.83,170.73l-.27-.69a88.3,88.3,0,0,0-35.15,15.8L190,229.25c19.55,14.79,36.57,27.64,36.57,27.64l40.06-30,.1-.08A48.56,48.56,0,0,0,282.83,170.73Z"/><path class="cls-3" d="M153.43,256.89l19.7,14.91,12,9.06a8.07,8.07,0,0,0,9.76,0l12-9.06,19.7-14.91S209.55,244,190,229.25C170.45,244,153.43,256.89,153.43,256.89Z"/><path class="cls-2" d="M132.58,185.84A88.19,88.19,0,0,0,97.44,170l-.26.69a48.54,48.54,0,0,0,16.1,56.1l.09.07.24.17,39.82,29.82s17-12.85,36.57-27.64Z"/></g></svg>

packages/backend/src/apps/gitlab/auth/generate-auth-url.ts

@@ -0,0 +1,24 @@
+import { IGlobalVariable } from '@automatisch/types';
+import { URL, URLSearchParams } from 'url';
+import getBaseUrl from '../common/get-base-url';
+
+export default async function generateAuthUrl($: IGlobalVariable) {
+  // ref: https://docs.gitlab.com/ee/api/oauth2.html#authorization-code-flow
+
+  const scopes = ['api', 'read_user'];
+
+  const searchParams = new URLSearchParams({
+    client_id: $.auth.data.clientId as string,
+    redirect_uri: $.auth.data.oAuthRedirectUrl as string,
+    scope: scopes.join(' '),
+    response_type: 'code',
+    state: Date.now().toString(),
+  });
+
+  const baseUrl = getBaseUrl($);
+  const path = `/oauth/authorize?${searchParams.toString()}`;
+
+  await $.auth.set({
+    url: new URL(path, baseUrl).toString(),
+  });
+}

packages/backend/src/apps/gitlab/auth/index.ts

@@ -0,0 +1,63 @@
+import generateAuthUrl from './generate-auth-url';
+import verifyCredentials from './verify-credentials';
+import isStillVerified from './is-still-verified';
+import refreshToken from './refresh-token';
+
+export default {
+  fields: [
+    {
+      key: 'oAuthRedirectUrl',
+      label: 'OAuth Redirect URL',
+      type: 'string' as const,
+      required: true,
+      readOnly: true,
+      value: '{WEB_APP_URL}/app/gitlab/connections/add',
+      placeholder: null,
+      description:
+        'When asked to input an OAuth callback or redirect URL in Gitlab OAuth, enter the URL above.',
+      docUrl: 'https://automatisch.io/docs/gitlab#oauth-redirect-url',
+      clickToCopy: true,
+    },
+    {
+      key: 'instanceUrl',
+      label: 'Gitlab instance URL',
+      type: 'string' as const,
+      required: false,
+      readOnly: false,
+      value: 'https://gitlab.com',
+      placeholder: 'https://gitlab.com',
+      description: 'Your Gitlab instance URL. Default is https://gitlab.com.',
+      docUrl: 'https://automatisch.io/docs/gitlab#oauth-redirect-url',
+      clickToCopy: true,
+    },
+    {
+      key: 'clientId',
+      label: 'Client ID',
+      type: 'string' as const,
+      required: true,
+      readOnly: false,
+      value: null,
+      placeholder: null,
+      description: null,
+      docUrl: 'https://automatisch.io/docs/gitlab#client-id',
+      clickToCopy: false,
+    },
+    {
+      key: 'clientSecret',
+      label: 'Client Secret',
+      type: 'string' as const,
+      required: true,
+      readOnly: false,
+      value: null,
+      placeholder: null,
+      description: null,
+      docUrl: 'https://automatisch.io/docs/gitlab#client-secret',
+      clickToCopy: false,
+    },
+  ],
+
+  generateAuthUrl,
+  refreshToken,
+  verifyCredentials,
+  isStillVerified,
+};

packages/backend/src/apps/gitlab/auth/is-still-verified.ts

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

packages/backend/src/apps/gitlab/auth/refresh-token.ts

@@ -0,0 +1,24 @@
+import { IGlobalVariable } from '@automatisch/types';
+import { URLSearchParams } from 'url';
+
+const refreshToken = async ($: IGlobalVariable) => {
+  // ref: https://docs.gitlab.com/ee/api/oauth2.html#authorization-code-flow
+
+  const params = new URLSearchParams({
+    grant_type: 'refresh_token',
+    client_id: $.auth.data.clientId as string,
+    client_secret: $.auth.data.clientSecret as string,
+    refresh_token: $.auth.data.refreshToken as string,
+  });
+
+  const { data } = await $.http.post('/oauth/token', params.toString());
+
+  await $.auth.set({
+    accessToken: data.access_token,
+    expiresIn: data.expires_in,
+    tokenType: data.token_type,
+    refreshToken: data.refresh_token,
+  });
+};
+
+export default refreshToken;

packages/backend/src/apps/gitlab/auth/verify-credentials.ts

@@ -0,0 +1,47 @@
+import { IGlobalVariable } from '@automatisch/types';
+import getCurrentUser from '../common/get-current-user';
+
+const verifyCredentials = async ($: IGlobalVariable) => {
+  // ref: https://docs.gitlab.com/ee/api/oauth2.html#authorization-code-flow
+
+  const response = await $.http.post(
+    '/oauth/token',
+    {
+      client_id: $.auth.data.clientId,
+      client_secret: $.auth.data.clientSecret,
+      code: $.auth.data.code,
+      grant_type: 'authorization_code',
+      redirect_uri: $.auth.data.oAuthRedirectUrl,
+    },
+    {
+      headers: {
+        Accept: 'application/json',
+      },
+    }
+  );
+
+  const data = response.data;
+
+  $.auth.data.accessToken = data.access_token;
+
+  const currentUser = await getCurrentUser($);
+  const screenName = [
+    currentUser.username,
+    $.auth.data.instanceUrl,
+  ]
+    .filter(Boolean)
+    .join(' @ ');
+
+  await $.auth.set({
+    clientId: $.auth.data.clientId,
+    clientSecret: $.auth.data.clientSecret,
+    accessToken: data.access_token,
+    refreshToken: data.refresh_token,
+    scope: data.scope,
+    tokenType: data.token_type,
+    userId: currentUser.id,
+    screenName,
+  });
+};
+
+export default verifyCredentials;

packages/backend/src/apps/gitlab/common/add-auth-header.ts

@@ -0,0 +1,11 @@
+import { TBeforeRequest } from '@automatisch/types';
+
+const addAuthHeader: TBeforeRequest = ($, requestConfig) => {
+  if ($.auth.data?.accessToken) {
+    requestConfig.headers = requestConfig.headers || {};
+    requestConfig.headers.Authorization = `Bearer ${$.auth.data.accessToken}`;
+  }
+  return requestConfig;
+};
+
+export default addAuthHeader;

packages/backend/src/apps/gitlab/common/get-base-url.ts

@@ -0,0 +1,15 @@
+import { IGlobalVariable } from '@automatisch/types';
+
+const getBaseUrl = ($: IGlobalVariable): string => {
+  if ($.auth.data.instanceUrl) {
+    return $.auth.data.instanceUrl as string;
+  }
+
+  if ($.app.apiBaseUrl) {
+    return $.app.apiBaseUrl;
+  }
+
+  return $.app.baseUrl;
+};
+
+export default getBaseUrl;

packages/backend/src/apps/gitlab/common/get-current-user.ts

@@ -0,0 +1,11 @@
+import { IGlobalVariable, IJSONObject } from '@automatisch/types';
+
+const getCurrentUser = async ($: IGlobalVariable): Promise<IJSONObject> => {
+  // ref: https://docs.gitlab.com/ee/api/users.html#list-current-user
+
+  const response = await $.http.get('/api/v4/user');
+  const currentUser = response.data;
+  return currentUser;
+};
+
+export default getCurrentUser;

packages/backend/src/apps/gitlab/common/paginate-all.ts

@@ -0,0 +1,33 @@
+import { IGlobalVariable, IJSONObject } from '@automatisch/types';
+import type { AxiosResponse } from 'axios';
+import parseLinkHeader from '../../../helpers/parse-header-link';
+
+type TResponse = {
+  data: IJSONObject[];
+  error?: IJSONObject;
+};
+
+export default async function paginateAll(
+  $: IGlobalVariable,
+  request: Promise<AxiosResponse>
+) {
+  const response = await request;
+
+  const aggregatedResponse: TResponse = {
+    data: [...response.data],
+  };
+
+  let links = parseLinkHeader(response.headers.link);
+
+  while (links.next) {
+    const nextPageResponse = await $.http.request({
+      ...response.config,
+      url: links.next.uri,
+    });
+
+    aggregatedResponse.data.push(...nextPageResponse.data);
+    links = parseLinkHeader(nextPageResponse.headers.link);
+  }
+
+  return aggregatedResponse;
+}

packages/backend/src/apps/gitlab/common/set-base-url.ts

@@ -0,0 +1,13 @@
+import { TBeforeRequest } from '@automatisch/types';
+
+const setBaseUrl: TBeforeRequest = ($, requestConfig) => {
+  if ($.auth.data.instanceUrl) {
+    requestConfig.baseURL = $.auth.data.instanceUrl as string;
+  } else if ($.app.apiBaseUrl) {
+    requestConfig.baseURL = $.app.apiBaseUrl as string;
+  }
+
+  return requestConfig;
+};
+
+export default setBaseUrl;

packages/backend/src/apps/gitlab/dynamic-data/index.ts

@@ -0,0 +1,3 @@
+import listProjects from './list-projects';
+
+export default [listProjects];

packages/backend/src/apps/gitlab/dynamic-data/list-projects/index.ts

@@ -0,0 +1,33 @@
+import { IGlobalVariable } from '@automatisch/types';
+import paginateAll from '../../common/paginate-all';
+
+export default {
+  name: 'List projects',
+  key: 'listProjects',
+
+  async run($: IGlobalVariable) {
+    // ref:
+    //  - https://docs.gitlab.com/ee/api/projects.html#list-all-projects
+    //  - https://docs.gitlab.com/ee/api/rest/index.html#keyset-based-pagination
+    const firstPageRequest = $.http.get('/api/v4/projects', {
+      params: {
+        simple: true,
+        pagination: 'keyset',
+        membership: true,
+        order_by: 'id',
+        sort: 'asc',
+      },
+    });
+
+    const response = await paginateAll($, firstPageRequest);
+
+    response.data = response.data.map((repo: { name: string; id: number }) => {
+      return {
+        value: repo.id,
+        name: repo.name,
+      };
+    });
+
+    return response;
+  },
+};

packages/backend/src/apps/gitlab/index.d.ts

@@ -0,0 +1 @@
+

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

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

packages/backend/src/apps/gitlab/triggers/confidential-issue-event/index.ts

@@ -0,0 +1,27 @@
+import { IRawTrigger } from '@automatisch/types';
+import defineTrigger from '../../../../helpers/define-trigger';
+import { GITLAB_EVENT_TYPE } from '../types';
+import {
+  getRegisterHookFn,
+  getTestRunFn,
+  projectArgumentDescriptor,
+  unregisterHook,
+} from '../lib';
+
+// confidential_issues_events has the same event data as issues_events
+import data from './issue_event';
+
+export const triggerDescriptor: IRawTrigger = {
+  name: 'Confidential issue event',
+  description:
+    'Confidential issue event (triggered when a new confidential issue is created or an existing issue is updated, closed, or reopened)',
+  // info: 'https://docs.gitlab.com/ee/user/project/integrations/webhook_events.html#issue-events',
+  key: GITLAB_EVENT_TYPE.confidential_issues_events,
+  type: 'webhook',
+  arguments: [projectArgumentDescriptor],
+  testRun: getTestRunFn(data),
+  registerHook: getRegisterHookFn(GITLAB_EVENT_TYPE.confidential_issues_events),
+  unregisterHook,
+};
+
+export default defineTrigger(triggerDescriptor);

packages/backend/src/apps/gitlab/triggers/confidential-issue-event/issue_event.ts

@@ -0,0 +1,159 @@
+// https://docs.gitlab.com/ee/user/project/integrations/webhook_events.html#issue-events
+
+export default {
+  object_kind: 'issue',
+  event_type: 'issue',
+  user: {
+    id: 1,
+    name: 'Administrator',
+    username: 'root',
+    avatar_url:
+      'http://www.gravatar.com/avatar/e64c7d89f26bd1972efa854d13d7dd61?s=40\u0026d=identicon',
+    email: 'admin@example.com',
+  },
+  project: {
+    id: 1,
+    name: 'Gitlab Test',
+    description: 'Aut reprehenderit ut est.',
+    web_url: 'http://example.com/gitlabhq/gitlab-test',
+    avatar_url: null,
+    git_ssh_url: 'git@example.com:gitlabhq/gitlab-test.git',
+    git_http_url: 'http://example.com/gitlabhq/gitlab-test.git',
+    namespace: 'GitlabHQ',
+    visibility_level: 20,
+    path_with_namespace: 'gitlabhq/gitlab-test',
+    default_branch: 'master',
+    ci_config_path: null,
+    homepage: 'http://example.com/gitlabhq/gitlab-test',
+    url: 'http://example.com/gitlabhq/gitlab-test.git',
+    ssh_url: 'git@example.com:gitlabhq/gitlab-test.git',
+    http_url: 'http://example.com/gitlabhq/gitlab-test.git',
+  },
+  object_attributes: {
+    id: 301,
+    title: 'New API: create/update/delete file',
+    assignee_ids: [51],
+    assignee_id: 51,
+    author_id: 51,
+    project_id: 14,
+    created_at: '2013-12-03T17:15:43Z',
+    updated_at: '2013-12-03T17:15:43Z',
+    updated_by_id: 1,
+    last_edited_at: null,
+    last_edited_by_id: null,
+    relative_position: 0,
+    description: 'Create new API for manipulations with repository',
+    milestone_id: null,
+    state_id: 1,
+    confidential: false,
+    discussion_locked: true,
+    due_date: null,
+    moved_to_id: null,
+    duplicated_to_id: null,
+    time_estimate: 0,
+    total_time_spent: 0,
+    time_change: 0,
+    human_total_time_spent: null,
+    human_time_estimate: null,
+    human_time_change: null,
+    weight: null,
+    iid: 23,
+    url: 'http://example.com/diaspora/issues/23',
+    state: 'opened',
+    action: 'open',
+    severity: 'high',
+    escalation_status: 'triggered',
+    escalation_policy: {
+      id: 18,
+      name: 'Engineering On-call',
+    },
+    labels: [
+      {
+        id: 206,
+        title: 'API',
+        color: '#ffffff',
+        project_id: 14,
+        created_at: '2013-12-03T17:15:43Z',
+        updated_at: '2013-12-03T17:15:43Z',
+        template: false,
+        description: 'API related issues',
+        type: 'ProjectLabel',
+        group_id: 41,
+      },
+    ],
+  },
+  repository: {
+    name: 'Gitlab Test',
+    url: 'http://example.com/gitlabhq/gitlab-test.git',
+    description: 'Aut reprehenderit ut est.',
+    homepage: 'http://example.com/gitlabhq/gitlab-test',
+  },
+  assignees: [
+    {
+      name: 'User1',
+      username: 'user1',
+      avatar_url:
+        'http://www.gravatar.com/avatar/e64c7d89f26bd1972efa854d13d7dd61?s=40\u0026d=identicon',
+    },
+  ],
+  assignee: {
+    name: 'User1',
+    username: 'user1',
+    avatar_url:
+      'http://www.gravatar.com/avatar/e64c7d89f26bd1972efa854d13d7dd61?s=40\u0026d=identicon',
+  },
+  labels: [
+    {
+      id: 206,
+      title: 'API',
+      color: '#ffffff',
+      project_id: 14,
+      created_at: '2013-12-03T17:15:43Z',
+      updated_at: '2013-12-03T17:15:43Z',
+      template: false,
+      description: 'API related issues',
+      type: 'ProjectLabel',
+      group_id: 41,
+    },
+  ],
+  changes: {
+    updated_by_id: {
+      previous: null,
+      current: 1,
+    },
+    updated_at: {
+      previous: '2017-09-15 16:50:55 UTC',
+      current: '2017-09-15 16:52:00 UTC',
+    },
+    labels: {
+      previous: [
+        {
+          id: 206,
+          title: 'API',
+          color: '#ffffff',
+          project_id: 14,
+          created_at: '2013-12-03T17:15:43Z',
+          updated_at: '2013-12-03T17:15:43Z',
+          template: false,
+          description: 'API related issues',
+          type: 'ProjectLabel',
+          group_id: 41,
+        },
+      ],
+      current: [
+        {
+          id: 205,
+          title: 'Platform',
+          color: '#123123',
+          project_id: 14,
+          created_at: '2013-12-03T17:15:43Z',
+          updated_at: '2013-12-03T17:15:43Z',
+          template: false,
+          description: 'Platform related issues',
+          type: 'ProjectLabel',
+          group_id: 41,
+        },
+      ],
+    },
+  },
+};

packages/backend/src/apps/gitlab/triggers/confidential-note-event/index.ts

@@ -0,0 +1,27 @@
+import { IRawTrigger } from '@automatisch/types';
+import defineTrigger from '../../../../helpers/define-trigger';
+import { GITLAB_EVENT_TYPE } from '../types';
+import {
+  getRegisterHookFn,
+  getTestRunFn,
+  projectArgumentDescriptor,
+  unregisterHook,
+} from '../lib';
+
+// confidential_note_events has the same event data as note_events
+import data from './note_event';
+
+export const triggerDescriptor: IRawTrigger = {
+  name: 'Confidential comment event',
+  description:
+    'Confidential comment event (triggered when a new confidential comment is made on commits, merge requests, issues, and code snippets)',
+  // info: 'https://docs.gitlab.com/ee/user/project/integrations/webhook_events.html#comment-events',
+  key: GITLAB_EVENT_TYPE.confidential_note_events,
+  type: 'webhook',
+  arguments: [projectArgumentDescriptor],
+  testRun: getTestRunFn(data),
+  registerHook: getRegisterHookFn(GITLAB_EVENT_TYPE.confidential_note_events),
+  unregisterHook,
+};
+
+export default defineTrigger(triggerDescriptor);

packages/backend/src/apps/gitlab/triggers/confidential-note-event/note_event.ts

@@ -0,0 +1,74 @@
+// https://docs.gitlab.com/ee/user/project/integrations/webhook_events.html#comment-events
+
+export default {
+  object_kind: 'note',
+  event_type: 'note',
+  user: {
+    id: 1,
+    name: 'Administrator',
+    username: 'root',
+    avatar_url:
+      'http://www.gravatar.com/avatar/e64c7d89f26bd1972efa854d13d7dd61?s=40\u0026d=identicon',
+    email: 'admin@example.com',
+  },
+  project_id: 5,
+  project: {
+    id: 5,
+    name: 'Gitlab Test',
+    description: 'Aut reprehenderit ut est.',
+    web_url: 'http://example.com/gitlabhq/gitlab-test',
+    avatar_url: null,
+    git_ssh_url: 'git@example.com:gitlabhq/gitlab-test.git',
+    git_http_url: 'http://example.com/gitlabhq/gitlab-test.git',
+    namespace: 'GitlabHQ',
+    visibility_level: 20,
+    path_with_namespace: 'gitlabhq/gitlab-test',
+    default_branch: 'master',
+    homepage: 'http://example.com/gitlabhq/gitlab-test',
+    url: 'http://example.com/gitlabhq/gitlab-test.git',
+    ssh_url: 'git@example.com:gitlabhq/gitlab-test.git',
+    http_url: 'http://example.com/gitlabhq/gitlab-test.git',
+  },
+  repository: {
+    name: 'Gitlab Test',
+    url: 'http://example.com/gitlab-org/gitlab-test.git',
+    description: 'Aut reprehenderit ut est.',
+    homepage: 'http://example.com/gitlab-org/gitlab-test',
+  },
+  object_attributes: {
+    id: 1243,
+    note: 'This is a commit comment. How does this work?',
+    noteable_type: 'Commit',
+    author_id: 1,
+    created_at: '2015-05-17 18:08:09 UTC',
+    updated_at: '2015-05-17 18:08:09 UTC',
+    project_id: 5,
+    attachment: null,
+    line_code: 'bec9703f7a456cd2b4ab5fb3220ae016e3e394e3_0_1',
+    commit_id: 'cfe32cf61b73a0d5e9f13e774abde7ff789b1660',
+    noteable_id: null,
+    system: false,
+    st_diff: {
+      diff: '--- /dev/null\n+++ b/six\n@@ -0,0 +1 @@\n+Subproject commit 409f37c4f05865e4fb208c771485f211a22c4c2d\n',
+      new_path: 'six',
+      old_path: 'six',
+      a_mode: '0',
+      b_mode: '160000',
+      new_file: true,
+      renamed_file: false,
+      deleted_file: false,
+    },
+    url: 'http://example.com/gitlab-org/gitlab-test/commit/cfe32cf61b73a0d5e9f13e774abde7ff789b1660#note_1243',
+  },
+  commit: {
+    id: 'cfe32cf61b73a0d5e9f13e774abde7ff789b1660',
+    message:
+      'Add submodule\n\nSigned-off-by: Example User \u003cuser@example.com.com\u003e\n',
+    timestamp: '2014-02-27T10:06:20+02:00',
+    url: 'http://example.com/gitlab-org/gitlab-test/commit/cfe32cf61b73a0d5e9f13e774abde7ff789b1660',
+    author: {
+      name: 'Example User',
+      email: 'user@example.com',
+    },
+  },
+};

packages/backend/src/apps/gitlab/triggers/deployment-event/deployment_event.ts

@@ -0,0 +1,45 @@
+// https://docs.gitlab.com/ee/user/project/integrations/webhook_events.html#deployment-events
+
+export default {
+  object_kind: 'deployment',
+  status: 'success',
+  status_changed_at: '2021-04-28 21:50:00 +0200',
+  deployment_id: 15,
+  deployable_id: 796,
+  deployable_url:
+    'http://10.126.0.2:3000/root/test-deployment-webhooks/-/jobs/796',
+  environment: 'staging',
+  environment_slug: 'staging',
+  environment_external_url: 'https://staging.example.com',
+  project: {
+    id: 30,
+    name: 'test-deployment-webhooks',
+    description: '',
+    web_url: 'http://10.126.0.2:3000/root/test-deployment-webhooks',
+    avatar_url: null,
+    git_ssh_url: 'ssh://vlad@10.126.0.2:2222/root/test-deployment-webhooks.git',
+    git_http_url: 'http://10.126.0.2:3000/root/test-deployment-webhooks.git',
+    namespace: 'Administrator',
+    visibility_level: 0,
+    path_with_namespace: 'root/test-deployment-webhooks',
+    default_branch: 'master',
+    ci_config_path: '',
+    homepage: 'http://10.126.0.2:3000/root/test-deployment-webhooks',
+    url: 'ssh://vlad@10.126.0.2:2222/root/test-deployment-webhooks.git',
+    ssh_url: 'ssh://vlad@10.126.0.2:2222/root/test-deployment-webhooks.git',
+    http_url: 'http://10.126.0.2:3000/root/test-deployment-webhooks.git',
+  },
+  short_sha: '279484c0',
+  user: {
+    id: 1,
+    name: 'Administrator',
+    username: 'root',
+    avatar_url:
+      'https://www.gravatar.com/avatar/e64c7d89f26bd1972efa854d13d7dd61?s=80&d=identicon',
+    email: 'admin@example.com',
+  },
+  user_url: 'http://10.126.0.2:3000/root',
+  commit_url:
+    'http://10.126.0.2:3000/root/test-deployment-webhooks/-/commit/279484c09fbe69ededfced8c1bb6e6d24616b468',
+  commit_title: 'Add new file',
+};

packages/backend/src/apps/gitlab/triggers/deployment-event/index.ts

@@ -0,0 +1,26 @@
+import { IRawTrigger } from '@automatisch/types';
+import defineTrigger from '../../../../helpers/define-trigger';
+import { GITLAB_EVENT_TYPE } from '../types';
+import {
+  getRegisterHookFn,
+  getTestRunFn,
+  projectArgumentDescriptor,
+  unregisterHook,
+} from '../lib';
+
+import data from './deployment_event';
+
+export const triggerDescriptor: IRawTrigger = {
+  name: 'Deployment event',
+  description:
+    'Deployment event (triggered when a deployment starts, succeeds, fails or is canceled)',
+  // info: 'https://docs.gitlab.com/ee/user/project/integrations/webhook_events.html#deployment-events',
+  key: GITLAB_EVENT_TYPE.deployment_events,
+  type: 'webhook',
+  arguments: [projectArgumentDescriptor],
+  testRun: getTestRunFn(data),
+  registerHook: getRegisterHookFn(GITLAB_EVENT_TYPE.deployment_events),
+  unregisterHook,
+};
+
+export default defineTrigger(triggerDescriptor);

packages/backend/src/apps/gitlab/triggers/feature-flag-event/feature_flag_event.ts

@@ -0,0 +1,38 @@
+// https://docs.gitlab.com/ee/user/project/integrations/webhook_events.html#feature-flag-events
+
+export default {
+  object_kind: 'feature_flag',
+  project: {
+    id: 1,
+    name: 'Gitlab Test',
+    description: 'Aut reprehenderit ut est.',
+    web_url: 'http://example.com/gitlabhq/gitlab-test',
+    avatar_url: null,
+    git_ssh_url: 'git@example.com:gitlabhq/gitlab-test.git',
+    git_http_url: 'http://example.com/gitlabhq/gitlab-test.git',
+    namespace: 'GitlabHQ',
+    visibility_level: 20,
+    path_with_namespace: 'gitlabhq/gitlab-test',
+    default_branch: 'master',
+    ci_config_path: null,
+    homepage: 'http://example.com/gitlabhq/gitlab-test',
+    url: 'http://example.com/gitlabhq/gitlab-test.git',
+    ssh_url: 'git@example.com:gitlabhq/gitlab-test.git',
+    http_url: 'http://example.com/gitlabhq/gitlab-test.git',
+  },
+  user: {
+    id: 1,
+    name: 'Administrator',
+    username: 'root',
+    avatar_url:
+      'https://www.gravatar.com/avatar/e64c7d89f26bd1972efa854d13d7dd61?s=80&d=identicon',
+    email: 'admin@example.com',
+  },
+  user_url: 'http://example.com/root',
+  object_attributes: {
+    id: 6,
+    name: 'test-feature-flag',
+    description: 'test-feature-flag-description',
+    active: true,
+  },
+};

packages/backend/src/apps/gitlab/triggers/feature-flag-event/index.ts

@@ -0,0 +1,26 @@
+import { IRawTrigger } from '@automatisch/types';
+import defineTrigger from '../../../../helpers/define-trigger';
+import { GITLAB_EVENT_TYPE } from '../types';
+import {
+  getRegisterHookFn,
+  getTestRunFn,
+  projectArgumentDescriptor,
+  unregisterHook,
+} from '../lib';
+
+import data from './feature_flag_event';
+
+export const triggerDescriptor: IRawTrigger = {
+  name: 'Feature flag event',
+  description:
+    'Feature flag event (triggered when a feature flag is turned on or off)',
+  // info: 'https://docs.gitlab.com/ee/user/project/integrations/webhook_events.html#feature-flag-events',
+  key: GITLAB_EVENT_TYPE.feature_flag_events,
+  type: 'webhook',
+  arguments: [projectArgumentDescriptor],
+  testRun: getTestRunFn(data),
+  registerHook: getRegisterHookFn(GITLAB_EVENT_TYPE.feature_flag_events),
+  unregisterHook,
+};
+
+export default defineTrigger(triggerDescriptor);

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

@@ -0,0 +1,29 @@
+import confidentialIssueEvent from './confidential-issue-event';
+import confidentialNoteEvent from './confidential-note-event';
+import deploymentEvent from './deployment-event';
+import featureFlagEvent from './feature-flag-event';
+import issueEvent from './issue-event';
+import jobEvent from './job-event';
+import mergeRequestEvent from './merge-request-event';
+import noteEvent from './note-event';
+import pipelineEvent from './pipeline-event';
+import pushEvent from './push-event';
+import releaseEvent from './release-event';
+import tagPushEvent from './tag-push-event';
+import wikiPageEvent from './wiki-page-event';
+
+export default [
+  confidentialIssueEvent,
+  confidentialNoteEvent,
+  deploymentEvent,
+  featureFlagEvent,
+  issueEvent,
+  jobEvent,
+  mergeRequestEvent,
+  noteEvent,
+  pipelineEvent,
+  pushEvent,
+  releaseEvent,
+  tagPushEvent,
+  wikiPageEvent,
+];

packages/backend/src/apps/gitlab/triggers/issue-event/index.ts

@@ -0,0 +1,26 @@
+import { IRawTrigger } from '@automatisch/types';
+import defineTrigger from '../../../../helpers/define-trigger';
+import { GITLAB_EVENT_TYPE } from '../types';
+import {
+  getRegisterHookFn,
+  getTestRunFn,
+  projectArgumentDescriptor,
+  unregisterHook,
+} from '../lib';
+
+import data from './issue_event';
+
+export const triggerDescriptor: IRawTrigger = {
+  name: 'Issue event',
+  description:
+    'Issue event (triggered when a new issue is created or an existing issue is updated, closed, or reopened)',
+  // info: 'https://docs.gitlab.com/ee/user/project/integrations/webhook_events.html#issue-events',
+  key: GITLAB_EVENT_TYPE.issues_events,
+  type: 'webhook',
+  arguments: [projectArgumentDescriptor],
+  testRun: getTestRunFn(data),
+  registerHook: getRegisterHookFn(GITLAB_EVENT_TYPE.issues_events),
+  unregisterHook,
+};
+
+export default defineTrigger(triggerDescriptor);

packages/backend/src/apps/gitlab/triggers/issue-event/issue_event.ts

@@ -0,0 +1,159 @@
+// https://docs.gitlab.com/ee/user/project/integrations/webhook_events.html#issue-events
+
+export default {
+  object_kind: 'issue',
+  event_type: 'issue',
+  user: {
+    id: 1,
+    name: 'Administrator',
+    username: 'root',
+    avatar_url:
+      'http://www.gravatar.com/avatar/e64c7d89f26bd1972efa854d13d7dd61?s=40\u0026d=identicon',
+    email: 'admin@example.com',
+  },
+  project: {
+    id: 1,
+    name: 'Gitlab Test',
+    description: 'Aut reprehenderit ut est.',
+    web_url: 'http://example.com/gitlabhq/gitlab-test',
+    avatar_url: null,
+    git_ssh_url: 'git@example.com:gitlabhq/gitlab-test.git',
+    git_http_url: 'http://example.com/gitlabhq/gitlab-test.git',
+    namespace: 'GitlabHQ',
+    visibility_level: 20,
+    path_with_namespace: 'gitlabhq/gitlab-test',
+    default_branch: 'master',
+    ci_config_path: null,
+    homepage: 'http://example.com/gitlabhq/gitlab-test',
+    url: 'http://example.com/gitlabhq/gitlab-test.git',
+    ssh_url: 'git@example.com:gitlabhq/gitlab-test.git',
+    http_url: 'http://example.com/gitlabhq/gitlab-test.git',
+  },
+  object_attributes: {
+    id: 301,
+    title: 'New API: create/update/delete file',
+    assignee_ids: [51],
+    assignee_id: 51,
+    author_id: 51,
+    project_id: 14,
+    created_at: '2013-12-03T17:15:43Z',
+    updated_at: '2013-12-03T17:15:43Z',
+    updated_by_id: 1,
+    last_edited_at: null,
+    last_edited_by_id: null,
+    relative_position: 0,
+    description: 'Create new API for manipulations with repository',
+    milestone_id: null,
+    state_id: 1,
+    confidential: false,
+    discussion_locked: true,
+    due_date: null,
+    moved_to_id: null,
+    duplicated_to_id: null,
+    time_estimate: 0,
+    total_time_spent: 0,
+    time_change: 0,
+    human_total_time_spent: null,
+    human_time_estimate: null,
+    human_time_change: null,
+    weight: null,
+    iid: 23,
+    url: 'http://example.com/diaspora/issues/23',
+    state: 'opened',
+    action: 'open',
+    severity: 'high',
+    escalation_status: 'triggered',
+    escalation_policy: {
+      id: 18,
+      name: 'Engineering On-call',
+    },
+    labels: [
+      {
+        id: 206,
+        title: 'API',
+        color: '#ffffff',
+        project_id: 14,
+        created_at: '2013-12-03T17:15:43Z',
+        updated_at: '2013-12-03T17:15:43Z',
+        template: false,
+        description: 'API related issues',
+        type: 'ProjectLabel',
+        group_id: 41,
+      },
+    ],
+  },
+  repository: {
+    name: 'Gitlab Test',
+    url: 'http://example.com/gitlabhq/gitlab-test.git',
+    description: 'Aut reprehenderit ut est.',
+    homepage: 'http://example.com/gitlabhq/gitlab-test',
+  },
+  assignees: [
+    {
+      name: 'User1',
+      username: 'user1',
+      avatar_url:
+        'http://www.gravatar.com/avatar/e64c7d89f26bd1972efa854d13d7dd61?s=40\u0026d=identicon',
+    },
+  ],
+  assignee: {
+    name: 'User1',
+    username: 'user1',
+    avatar_url:
+      'http://www.gravatar.com/avatar/e64c7d89f26bd1972efa854d13d7dd61?s=40\u0026d=identicon',
+  },
+  labels: [
+    {
+      id: 206,
+      title: 'API',
+      color: '#ffffff',
+      project_id: 14,
+      created_at: '2013-12-03T17:15:43Z',
+      updated_at: '2013-12-03T17:15:43Z',
+      template: false,
+      description: 'API related issues',
+      type: 'ProjectLabel',
+      group_id: 41,
+    },
+  ],
+  changes: {
+    updated_by_id: {
+      previous: null,
+      current: 1,
+    },
+    updated_at: {
+      previous: '2017-09-15 16:50:55 UTC',
+      current: '2017-09-15 16:52:00 UTC',
+    },
+    labels: {
+      previous: [
+        {
+          id: 206,
+          title: 'API',
+          color: '#ffffff',
+          project_id: 14,
+          created_at: '2013-12-03T17:15:43Z',
+          updated_at: '2013-12-03T17:15:43Z',
+          template: false,
+          description: 'API related issues',
+          type: 'ProjectLabel',
+          group_id: 41,
+        },
+      ],
+      current: [
+        {
+          id: 205,
+          title: 'Platform',
+          color: '#123123',
+          project_id: 14,
+          created_at: '2013-12-03T17:15:43Z',
+          updated_at: '2013-12-03T17:15:43Z',
+          template: false,
+          description: 'Platform related issues',
+          type: 'ProjectLabel',
+          group_id: 41,
+        },
+      ],
+    },
+  },
+};

packages/backend/src/apps/gitlab/triggers/job-event/index.ts

@@ -0,0 +1,25 @@
+import { IRawTrigger } from '@automatisch/types';
+import defineTrigger from '../../../../helpers/define-trigger';
+import { GITLAB_EVENT_TYPE } from '../types';
+import {
+  getRegisterHookFn,
+  getTestRunFn,
+  projectArgumentDescriptor,
+  unregisterHook,
+} from '../lib';
+
+import data from './job_event';
+
+export const triggerDescriptor: IRawTrigger = {
+  name: 'Job event',
+  description: 'Job event (triggered when the status of a job changes)',
+  // info: 'https://docs.gitlab.com/ee/user/project/integrations/webhook_events.html#job-events',
+  key: GITLAB_EVENT_TYPE.job_events,
+  type: 'webhook',
+  arguments: [projectArgumentDescriptor],
+  testRun: getTestRunFn(data),
+  registerHook: getRegisterHookFn(GITLAB_EVENT_TYPE.job_events),
+  unregisterHook,
+};
+
+export default defineTrigger(triggerDescriptor);

packages/backend/src/apps/gitlab/triggers/job-event/job_event.ts

@@ -0,0 +1,60 @@
+// https://docs.gitlab.com/ee/user/project/integrations/webhook_events.html#job-events
+
+export default {
+  object_kind: 'build',
+  ref: 'gitlab-script-trigger',
+  tag: false,
+  before_sha: '2293ada6b400935a1378653304eaf6221e0fdb8f',
+  sha: '2293ada6b400935a1378653304eaf6221e0fdb8f',
+  build_id: 1977,
+  build_name: 'test',
+  build_stage: 'test',
+  build_status: 'created',
+  build_created_at: '2021-02-23T02:41:37.886Z',
+  build_started_at: null,
+  build_finished_at: null,
+  build_duration: null,
+  build_queued_duration: 1095.588715, // duration in seconds
+  build_allow_failure: false,
+  build_failure_reason: 'script_failure',
+  retries_count: 2, // the second retry of this job
+  pipeline_id: 2366,
+  project_id: 380,
+  project_name: 'gitlab-org/gitlab-test',
+  user: {
+    id: 3,
+    name: 'User',
+    email: 'user@gitlab.com',
+    avatar_url:
+      'http://www.gravatar.com/avatar/e32bd13e2add097461cb96824b7a829c?s=80\u0026d=identicon',
+  },
+  commit: {
+    id: 2366,
+    name: 'Build pipeline',
+    sha: '2293ada6b400935a1378653304eaf6221e0fdb8f',
+    message: 'test\n',
+    author_name: 'User',
+    author_email: 'user@gitlab.com',
+    status: 'created',
+    duration: null,
+    started_at: null,
+    finished_at: null,
+  },
+  repository: {
+    name: 'gitlab_test',
+    description: 'Atque in sunt eos similique dolores voluptatem.',
+    homepage: 'http://192.168.64.1:3005/gitlab-org/gitlab-test',
+    git_ssh_url: 'git@192.168.64.1:gitlab-org/gitlab-test.git',
+    git_http_url: 'http://192.168.64.1:3005/gitlab-org/gitlab-test.git',
+    visibility_level: 20,
+  },
+  runner: {
+    active: true,
+    runner_type: 'project_type',
+    is_shared: false,
+    id: 380987,
+    description: 'shared-runners-manager-6.gitlab.com',
+    tags: ['linux', 'docker'],
+  },
+  environment: null,
+};

packages/backend/src/apps/gitlab/triggers/lib.ts

@@ -0,0 +1,89 @@
+import { IGlobalVariable, IJSONObject } from '@automatisch/types';
+import Crypto from 'crypto';
+import { GITLAB_EVENT_TYPE } from './types';
+import appConfig from '../../../config/app';
+
+export const projectArgumentDescriptor = {
+  label: 'Project',
+  key: 'projectId',
+  type: 'dropdown' as const,
+  required: true,
+  description: 'Pick a project to receive events from',
+  variables: false,
+  source: {
+    type: 'query',
+    name: 'getDynamicData',
+    arguments: [
+      {
+        name: 'key',
+        value: 'listProjects',
+      },
+    ],
+  },
+};
+
+export const getTestRunFn =
+  (eventData: IJSONObject) => ($: IGlobalVariable) => {
+    /*
+      Not fetching actual events from gitlab and using static event data from documentation
+      as there is no way to filter out events of one category using gitlab event types,
+      filtering is very limited and uses different grouping than what is applicable when creating a webhook.
+
+      ref:
+        - https://docs.gitlab.com/ee/api/events.html#target-types
+        - https://docs.gitlab.com/ee/api/projects.html#add-project-hook
+    */
+
+    if (!eventData) {
+      return;
+    }
+
+    const dataItem = {
+      raw: eventData,
+      meta: {
+        // there is no distinct id on gitlab event object thus creating it
+        internalId: Crypto.randomUUID(),
+      },
+    };
+
+    $.pushTriggerItem(dataItem);
+
+    return Promise.resolve();
+  };
+
+export const getRegisterHookFn =
+  (eventType: GITLAB_EVENT_TYPE) => async ($: IGlobalVariable) => {
+    // ref: https://docs.gitlab.com/ee/api/projects.html#add-project-hook
+
+    const subscriptionPayload = {
+      url: $.webhookUrl,
+      token: appConfig.webhookSecretKey,
+      enable_ssl_verification: true,
+      [eventType]: true,
+    };
+
+    if (
+      ['wildcard', 'regex'].includes(
+        $.step.parameters.branch_filter_strategy as string
+      )
+    ) {
+      subscriptionPayload.branch_filter_strategy = $.step.parameters
+        .branch_filter_strategy as string;
+      subscriptionPayload.push_events_branch_filter = $.step.parameters
+        .push_events_branch_filter as string;
+    }
+
+    const { data } = await $.http.post(
+      `/api/v4/projects/${$.step.parameters.projectId}/hooks`,
+      subscriptionPayload
+    );
+
+    await $.flow.setRemoteWebhookId(data.id.toString());
+  };
+
+export const unregisterHook = async ($: IGlobalVariable) => {
+  // ref: https://docs.gitlab.com/ee/api/projects.html#delete-project-hook
+  await $.http.delete(
+    `/api/v4/projects/${$.step.parameters.projectId}/hooks/${$.flow.remoteWebhookId}`
+  );
+};

packages/backend/src/apps/gitlab/triggers/merge-request-event/index.ts

@@ -0,0 +1,26 @@
+import { IRawTrigger } from '@automatisch/types';
+import defineTrigger from '../../../../helpers/define-trigger';
+import { GITLAB_EVENT_TYPE } from '../types';
+import {
+  getRegisterHookFn,
+  getTestRunFn,
+  projectArgumentDescriptor,
+  unregisterHook,
+} from '../lib';
+
+import data from './merge_request_event';
+
+export const triggerDescriptor: IRawTrigger = {
+  name: 'Merge request event',
+  description:
+    'Merge request event (triggered when merge request is created, updated, or closed)',
+  // info: 'https://docs.gitlab.com/ee/user/project/integrations/webhook_events.html#merge-request-events',
+  key: GITLAB_EVENT_TYPE.merge_requests_events,
+  type: 'webhook',
+  arguments: [projectArgumentDescriptor],
+  testRun: getTestRunFn(data),
+  registerHook: getRegisterHookFn(GITLAB_EVENT_TYPE.merge_requests_events),
+  unregisterHook,
+};
+
+export default defineTrigger(triggerDescriptor);

packages/backend/src/apps/gitlab/triggers/merge-request-event/merge_request_event.ts

@@ -0,0 +1,208 @@
+// https://docs.gitlab.com/ee/user/project/integrations/webhook_events.html#merge-request-events
+
+export default {
+  object_kind: 'merge_request',
+  event_type: 'merge_request',
+  user: {
+    id: 1,
+    name: 'Administrator',
+    username: 'root',
+    avatar_url:
+      'http://www.gravatar.com/avatar/e64c7d89f26bd1972efa854d13d7dd61?s=40\u0026d=identicon',
+    email: 'admin@example.com',
+  },
+  project: {
+    id: 1,
+    name: 'Gitlab Test',
+    description: 'Aut reprehenderit ut est.',
+    web_url: 'http://example.com/gitlabhq/gitlab-test',
+    avatar_url: null,
+    git_ssh_url: 'git@example.com:gitlabhq/gitlab-test.git',
+    git_http_url: 'http://example.com/gitlabhq/gitlab-test.git',
+    namespace: 'GitlabHQ',
+    visibility_level: 20,
+    path_with_namespace: 'gitlabhq/gitlab-test',
+    default_branch: 'master',
+    ci_config_path: '',
+    homepage: 'http://example.com/gitlabhq/gitlab-test',
+    url: 'http://example.com/gitlabhq/gitlab-test.git',
+    ssh_url: 'git@example.com:gitlabhq/gitlab-test.git',
+    http_url: 'http://example.com/gitlabhq/gitlab-test.git',
+  },
+  repository: {
+    name: 'Gitlab Test',
+    url: 'http://example.com/gitlabhq/gitlab-test.git',
+    description: 'Aut reprehenderit ut est.',
+    homepage: 'http://example.com/gitlabhq/gitlab-test',
+  },
+  object_attributes: {
+    id: 99,
+    iid: 1,
+    target_branch: 'master',
+    source_branch: 'ms-viewport',
+    source_project_id: 14,
+    author_id: 51,
+    assignee_ids: [6],
+    assignee_id: 6,
+    reviewer_ids: [6],
+    title: 'MS-Viewport',
+    created_at: '2013-12-03T17:23:34Z',
+    updated_at: '2013-12-03T17:23:34Z',
+    last_edited_at: '2013-12-03T17:23:34Z',
+    last_edited_by_id: 1,
+    milestone_id: null,
+    state_id: 1,
+    state: 'opened',
+    blocking_discussions_resolved: true,
+    work_in_progress: false,
+    first_contribution: true,
+    merge_status: 'unchecked',
+    target_project_id: 14,
+    description: '',
+    total_time_spent: 1800,
+    time_change: 30,
+    human_total_time_spent: '30m',
+    human_time_change: '30s',
+    human_time_estimate: '30m',
+    url: 'http://example.com/diaspora/merge_requests/1',
+    source: {
+      name: 'Awesome Project',
+      description: 'Aut reprehenderit ut est.',
+      web_url: 'http://example.com/awesome_space/awesome_project',
+      avatar_url: null,
+      git_ssh_url: 'git@example.com:awesome_space/awesome_project.git',
+      git_http_url: 'http://example.com/awesome_space/awesome_project.git',
+      namespace: 'Awesome Space',
+      visibility_level: 20,
+      path_with_namespace: 'awesome_space/awesome_project',
+      default_branch: 'master',
+      homepage: 'http://example.com/awesome_space/awesome_project',
+      url: 'http://example.com/awesome_space/awesome_project.git',
+      ssh_url: 'git@example.com:awesome_space/awesome_project.git',
+      http_url: 'http://example.com/awesome_space/awesome_project.git',
+    },
+    target: {
+      name: 'Awesome Project',
+      description: 'Aut reprehenderit ut est.',
+      web_url: 'http://example.com/awesome_space/awesome_project',
+      avatar_url: null,
+      git_ssh_url: 'git@example.com:awesome_space/awesome_project.git',
+      git_http_url: 'http://example.com/awesome_space/awesome_project.git',
+      namespace: 'Awesome Space',
+      visibility_level: 20,
+      path_with_namespace: 'awesome_space/awesome_project',
+      default_branch: 'master',
+      homepage: 'http://example.com/awesome_space/awesome_project',
+      url: 'http://example.com/awesome_space/awesome_project.git',
+      ssh_url: 'git@example.com:awesome_space/awesome_project.git',
+      http_url: 'http://example.com/awesome_space/awesome_project.git',
+    },
+    last_commit: {
+      id: 'da1560886d4f094c3e6c9ef40349f7d38b5d27d7',
+      message: 'fixed readme',
+      title: 'Update file README.md',
+      timestamp: '2012-01-03T23:36:29+02:00',
+      url: 'http://example.com/awesome_space/awesome_project/commits/da1560886d4f094c3e6c9ef40349f7d38b5d27d7',
+      author: {
+        name: 'GitLab dev user',
+        email: 'gitlabdev@dv6700.(none)',
+      },
+    },
+    labels: [
+      {
+        id: 206,
+        title: 'API',
+        color: '#ffffff',
+        project_id: 14,
+        created_at: '2013-12-03T17:15:43Z',
+        updated_at: '2013-12-03T17:15:43Z',
+        template: false,
+        description: 'API related issues',
+        type: 'ProjectLabel',
+        group_id: 41,
+      },
+    ],
+    action: 'open',
+    detailed_merge_status: 'mergeable',
+  },
+  labels: [
+    {
+      id: 206,
+      title: 'API',
+      color: '#ffffff',
+      project_id: 14,
+      created_at: '2013-12-03T17:15:43Z',
+      updated_at: '2013-12-03T17:15:43Z',
+      template: false,
+      description: 'API related issues',
+      type: 'ProjectLabel',
+      group_id: 41,
+    },
+  ],
+  changes: {
+    updated_by_id: {
+      previous: null,
+      current: 1,
+    },
+    updated_at: {
+      previous: '2017-09-15 16:50:55 UTC',
+      current: '2017-09-15 16:52:00 UTC',
+    },
+    labels: {
+      previous: [
+        {
+          id: 206,
+          title: 'API',
+          color: '#ffffff',
+          project_id: 14,
+          created_at: '2013-12-03T17:15:43Z',
+          updated_at: '2013-12-03T17:15:43Z',
+          template: false,
+          description: 'API related issues',
+          type: 'ProjectLabel',
+          group_id: 41,
+        },
+      ],
+      current: [
+        {
+          id: 205,
+          title: 'Platform',
+          color: '#123123',
+          project_id: 14,
+          created_at: '2013-12-03T17:15:43Z',
+          updated_at: '2013-12-03T17:15:43Z',
+          template: false,
+          description: 'Platform related issues',
+          type: 'ProjectLabel',
+          group_id: 41,
+        },
+      ],
+    },
+    last_edited_at: {
+      previous: null,
+      current: '2023-03-15 00:00:10 UTC',
+    },
+    last_edited_by_id: {
+      previous: null,
+      current: 3278533,
+    },
+  },
+  assignees: [
+    {
+      id: 6,
+      name: 'User1',
+      username: 'user1',
+      avatar_url:
+        'http://www.gravatar.com/avatar/e64c7d89f26bd1972efa854d13d7dd61?s=40\u0026d=identicon',
+    },
+  ],
+  reviewers: [
+    {
+      id: 6,
+      name: 'User1',
+      username: 'user1',
+      avatar_url:
+        'http://www.gravatar.com/avatar/e64c7d89f26bd1972efa854d13d7dd61?s=40\u0026d=identicon',
+    },
+  ],
+};

packages/backend/src/apps/gitlab/triggers/note-event/index.ts

@@ -0,0 +1,26 @@
+import { IRawTrigger } from '@automatisch/types';
+import defineTrigger from '../../../../helpers/define-trigger';
+import { GITLAB_EVENT_TYPE } from '../types';
+import {
+  getRegisterHookFn,
+  getTestRunFn,
+  projectArgumentDescriptor,
+  unregisterHook,
+} from '../lib';
+
+import data from './note_event';
+
+export const triggerDescriptor: IRawTrigger = {
+  name: 'Comment event',
+  description:
+    'Comment event (triggered when a new comment is made on commits, merge requests, issues, and code snippets)',
+  // info: 'https://docs.gitlab.com/ee/user/project/integrations/webhook_events.html#comment-events',
+  key: GITLAB_EVENT_TYPE.note_events,
+  type: 'webhook',
+  arguments: [projectArgumentDescriptor],
+  testRun: getTestRunFn(data),
+  registerHook: getRegisterHookFn(GITLAB_EVENT_TYPE.note_events),
+  unregisterHook,
+};
+
+export default defineTrigger(triggerDescriptor);

packages/backend/src/apps/gitlab/triggers/note-event/note_event.ts

@@ -0,0 +1,74 @@
+// https://docs.gitlab.com/ee/user/project/integrations/webhook_events.html#comment-events
+
+export default {
+  object_kind: 'note',
+  event_type: 'note',
+  user: {
+    id: 1,
+    name: 'Administrator',
+    username: 'root',
+    avatar_url:
+      'http://www.gravatar.com/avatar/e64c7d89f26bd1972efa854d13d7dd61?s=40\u0026d=identicon',
+    email: 'admin@example.com',
+  },
+  project_id: 5,
+  project: {
+    id: 5,
+    name: 'Gitlab Test',
+    description: 'Aut reprehenderit ut est.',
+    web_url: 'http://example.com/gitlabhq/gitlab-test',
+    avatar_url: null,
+    git_ssh_url: 'git@example.com:gitlabhq/gitlab-test.git',
+    git_http_url: 'http://example.com/gitlabhq/gitlab-test.git',
+    namespace: 'GitlabHQ',
+    visibility_level: 20,
+    path_with_namespace: 'gitlabhq/gitlab-test',
+    default_branch: 'master',
+    homepage: 'http://example.com/gitlabhq/gitlab-test',
+    url: 'http://example.com/gitlabhq/gitlab-test.git',
+    ssh_url: 'git@example.com:gitlabhq/gitlab-test.git',
+    http_url: 'http://example.com/gitlabhq/gitlab-test.git',
+  },
+  repository: {
+    name: 'Gitlab Test',
+    url: 'http://example.com/gitlab-org/gitlab-test.git',
+    description: 'Aut reprehenderit ut est.',
+    homepage: 'http://example.com/gitlab-org/gitlab-test',
+  },
+  object_attributes: {
+    id: 1243,
+    note: 'This is a commit comment. How does this work?',
+    noteable_type: 'Commit',
+    author_id: 1,
+    created_at: '2015-05-17 18:08:09 UTC',
+    updated_at: '2015-05-17 18:08:09 UTC',
+    project_id: 5,
+    attachment: null,
+    line_code: 'bec9703f7a456cd2b4ab5fb3220ae016e3e394e3_0_1',
+    commit_id: 'cfe32cf61b73a0d5e9f13e774abde7ff789b1660',
+    noteable_id: null,
+    system: false,
+    st_diff: {
+      diff: '--- /dev/null\n+++ b/six\n@@ -0,0 +1 @@\n+Subproject commit 409f37c4f05865e4fb208c771485f211a22c4c2d\n',
+      new_path: 'six',
+      old_path: 'six',
+      a_mode: '0',
+      b_mode: '160000',
+      new_file: true,
+      renamed_file: false,
+      deleted_file: false,
+    },
+    url: 'http://example.com/gitlab-org/gitlab-test/commit/cfe32cf61b73a0d5e9f13e774abde7ff789b1660#note_1243',
+  },
+  commit: {
+    id: 'cfe32cf61b73a0d5e9f13e774abde7ff789b1660',
+    message:
+      'Add submodule\n\nSigned-off-by: Example User \u003cuser@example.com.com\u003e\n',
+    timestamp: '2014-02-27T10:06:20+02:00',
+    url: 'http://example.com/gitlab-org/gitlab-test/commit/cfe32cf61b73a0d5e9f13e774abde7ff789b1660',
+    author: {
+      name: 'Example User',
+      email: 'user@example.com',
+    },
+  },
+};

packages/backend/src/apps/gitlab/triggers/pipeline-event/index.ts

@@ -0,0 +1,26 @@
+import { IRawTrigger } from '@automatisch/types';
+import defineTrigger from '../../../../helpers/define-trigger';
+import { GITLAB_EVENT_TYPE } from '../types';
+import {
+  getRegisterHookFn,
+  getTestRunFn,
+  projectArgumentDescriptor,
+  unregisterHook,
+} from '../lib';
+
+import data from './pipeline_event';
+
+export const triggerDescriptor: IRawTrigger = {
+  name: 'Pipeline event',
+  description:
+    'Pipeline event (triggered when the status of a pipeline changes)',
+  // info: 'https://docs.gitlab.com/ee/user/project/integrations/webhook_events.html#pipeline-events',
+  key: GITLAB_EVENT_TYPE.pipeline_events,
+  type: 'webhook',
+  arguments: [projectArgumentDescriptor],
+  testRun: getTestRunFn(data),
+  registerHook: getRegisterHookFn(GITLAB_EVENT_TYPE.pipeline_events),
+  unregisterHook,
+};
+
+export default defineTrigger(triggerDescriptor);

packages/backend/src/apps/gitlab/triggers/pipeline-event/pipeline_event.ts

@@ -0,0 +1,254 @@
+// https://docs.gitlab.com/ee/user/project/integrations/webhook_events.html#pipeline-events
+
+export default {
+  object_kind: 'pipeline',
+  object_attributes: {
+    id: 31,
+    iid: 3,
+    ref: 'master',
+    tag: false,
+    sha: 'bcbb5ec396a2c0f828686f14fac9b80b780504f2',
+    before_sha: 'bcbb5ec396a2c0f828686f14fac9b80b780504f2',
+    source: 'merge_request_event',
+    status: 'success',
+    stages: ['build', 'test', 'deploy'],
+    created_at: '2016-08-12 15:23:28 UTC',
+    finished_at: '2016-08-12 15:26:29 UTC',
+    duration: 63,
+    variables: [
+      {
+        key: 'NESTOR_PROD_ENVIRONMENT',
+        value: 'us-west-1',
+      },
+    ],
+  },
+  merge_request: {
+    id: 1,
+    iid: 1,
+    title: 'Test',
+    source_branch: 'test',
+    source_project_id: 1,
+    target_branch: 'master',
+    target_project_id: 1,
+    state: 'opened',
+    merge_status: 'can_be_merged',
+    detailed_merge_status: 'mergeable',
+    url: 'http://192.168.64.1:3005/gitlab-org/gitlab-test/merge_requests/1',
+  },
+  user: {
+    id: 1,
+    name: 'Administrator',
+    username: 'root',
+    avatar_url:
+      'http://www.gravatar.com/avatar/e32bd13e2add097461cb96824b7a829c?s=80\u0026d=identicon',
+    email: 'user_email@gitlab.com',
+  },
+  project: {
+    id: 1,
+    name: 'Gitlab Test',
+    description: 'Atque in sunt eos similique dolores voluptatem.',
+    web_url: 'http://192.168.64.1:3005/gitlab-org/gitlab-test',
+    avatar_url: null,
+    git_ssh_url: 'git@192.168.64.1:gitlab-org/gitlab-test.git',
+    git_http_url: 'http://192.168.64.1:3005/gitlab-org/gitlab-test.git',
+    namespace: 'Gitlab Org',
+    visibility_level: 20,
+    path_with_namespace: 'gitlab-org/gitlab-test',
+    default_branch: 'master',
+  },
+  commit: {
+    id: 'bcbb5ec396a2c0f828686f14fac9b80b780504f2',
+    message: 'test\n',
+    timestamp: '2016-08-12T17:23:21+02:00',
+    url: 'http://example.com/gitlab-org/gitlab-test/commit/bcbb5ec396a2c0f828686f14fac9b80b780504f2',
+    author: {
+      name: 'User',
+      email: 'user@gitlab.com',
+    },
+  },
+  source_pipeline: {
+    project: {
+      id: 41,
+      web_url: 'https://gitlab.example.com/gitlab-org/upstream-project',
+      path_with_namespace: 'gitlab-org/upstream-project',
+    },
+    pipeline_id: 30,
+    job_id: 3401,
+  },
+  builds: [
+    {
+      id: 380,
+      stage: 'deploy',
+      name: 'production',
+      status: 'skipped',
+      created_at: '2016-08-12 15:23:28 UTC',
+      started_at: null,
+      finished_at: null,
+      duration: null,
+      queued_duration: null,
+      failure_reason: null,
+      when: 'manual',
+      manual: true,
+      allow_failure: false,
+      user: {
+        id: 1,
+        name: 'Administrator',
+        username: 'root',
+        avatar_url:
+          'http://www.gravatar.com/avatar/e32bd13e2add097461cb96824b7a829c?s=80\u0026d=identicon',
+        email: 'admin@example.com',
+      },
+      runner: null,
+      artifacts_file: {
+        filename: null,
+        size: null,
+      },
+      environment: {
+        name: 'production',
+        action: 'start',
+        deployment_tier: 'production',
+      },
+    },
+    {
+      id: 377,
+      stage: 'test',
+      name: 'test-image',
+      status: 'success',
+      created_at: '2016-08-12 15:23:28 UTC',
+      started_at: '2016-08-12 15:26:12 UTC',
+      finished_at: '2016-08-12 15:26:29 UTC',
+      duration: 17.0,
+      queued_duration: 196.0,
+      failure_reason: null,
+      when: 'on_success',
+      manual: false,
+      allow_failure: false,
+      user: {
+        id: 1,
+        name: 'Administrator',
+        username: 'root',
+        avatar_url:
+          'http://www.gravatar.com/avatar/e32bd13e2add097461cb96824b7a829c?s=80\u0026d=identicon',
+        email: 'admin@example.com',
+      },
+      runner: {
+        id: 380987,
+        description: 'shared-runners-manager-6.gitlab.com',
+        active: true,
+        runner_type: 'instance_type',
+        is_shared: true,
+        tags: ['linux', 'docker', 'shared-runner'],
+      },
+      artifacts_file: {
+        filename: null,
+        size: null,
+      },
+      environment: null,
+    },
+    {
+      id: 378,
+      stage: 'test',
+      name: 'test-build',
+      status: 'failed',
+      created_at: '2016-08-12 15:23:28 UTC',
+      started_at: '2016-08-12 15:26:12 UTC',
+      finished_at: '2016-08-12 15:26:29 UTC',
+      duration: 17.0,
+      queued_duration: 196.0,
+      failure_reason: 'script_failure',
+      when: 'on_success',
+      manual: false,
+      allow_failure: false,
+      user: {
+        id: 1,
+        name: 'Administrator',
+        username: 'root',
+        avatar_url:
+          'http://www.gravatar.com/avatar/e32bd13e2add097461cb96824b7a829c?s=80\u0026d=identicon',
+        email: 'admin@example.com',
+      },
+      runner: {
+        id: 380987,
+        description: 'shared-runners-manager-6.gitlab.com',
+        active: true,
+        runner_type: 'instance_type',
+        is_shared: true,
+        tags: ['linux', 'docker'],
+      },
+      artifacts_file: {
+        filename: null,
+        size: null,
+      },
+      environment: null,
+    },
+    {
+      id: 376,
+      stage: 'build',
+      name: 'build-image',
+      status: 'success',
+      created_at: '2016-08-12 15:23:28 UTC',
+      started_at: '2016-08-12 15:24:56 UTC',
+      finished_at: '2016-08-12 15:25:26 UTC',
+      duration: 17.0,
+      queued_duration: 196.0,
+      failure_reason: null,
+      when: 'on_success',
+      manual: false,
+      allow_failure: false,
+      user: {
+        id: 1,
+        name: 'Administrator',
+        username: 'root',
+        avatar_url:
+          'http://www.gravatar.com/avatar/e32bd13e2add097461cb96824b7a829c?s=80\u0026d=identicon',
+        email: 'admin@example.com',
+      },
+      runner: {
+        id: 380987,
+        description: 'shared-runners-manager-6.gitlab.com',
+        active: true,
+        runner_type: 'instance_type',
+        is_shared: true,
+        tags: ['linux', 'docker'],
+      },
+      artifacts_file: {
+        filename: null,
+        size: null,
+      },
+      environment: null,
+    },
+    {
+      id: 379,
+      stage: 'deploy',
+      name: 'staging',
+      status: 'created',
+      created_at: '2016-08-12 15:23:28 UTC',
+      started_at: null,
+      finished_at: null,
+      duration: null,
+      queued_duration: null,
+      failure_reason: null,
+      when: 'on_success',
+      manual: false,
+      allow_failure: false,
+      user: {
+        id: 1,
+        name: 'Administrator',
+        username: 'root',
+        avatar_url:
+          'http://www.gravatar.com/avatar/e32bd13e2add097461cb96824b7a829c?s=80\u0026d=identicon',
+        email: 'admin@example.com',
+      },
+      runner: null,
+      artifacts_file: {
+        filename: null,
+        size: null,
+      },
+      environment: {
+        name: 'staging',
+        action: 'start',
+        deployment_tier: 'staging',
+      },
+    },
+  ],
+};

packages/backend/src/apps/gitlab/triggers/push-event/index.ts

@@ -0,0 +1,62 @@
+import { IRawTrigger } from '@automatisch/types';
+import defineTrigger from '../../../../helpers/define-trigger';
+import { GITLAB_EVENT_TYPE } from '../types';
+import {
+  getRegisterHookFn,
+  getTestRunFn,
+  projectArgumentDescriptor,
+  unregisterHook,
+} from '../lib';
+
+import data from './push_event';
+
+export const branchFilterStrategyArgumentDescriptor = {
+  label: 'What type of filter to use?',
+  key: 'branch_filter_strategy',
+  type: 'dropdown' as const,
+  description: 'Defaults to including all branches',
+  required: true,
+  variables: false,
+  value: 'all_branches',
+  options: [
+    {
+      label: 'All branches',
+      value: 'all_branches',
+    },
+    {
+      label: 'Wildcard pattern (ex: *-stable)',
+      value: 'wildcard',
+    },
+    {
+      label: 'Regular expression (ex: ^(feature|hotfix)/)',
+      value: 'regex',
+    },
+  ],
+};
+
+export const pushEventsBranchFilterArgumentDescriptor = {
+  label: 'Filter value',
+  key: 'push_events_branch_filter',
+  description: 'Leave empty when using "all branches"',
+  type: 'string' as const,
+  required: false,
+  variables: false,
+};
+
+export const triggerDescriptor: IRawTrigger = {
+  name: 'Push event',
+  description: 'Push event (triggered when you push to the repository)',
+  // info: 'https://docs.gitlab.com/ee/user/project/integrations/webhook_events.html#push-events',
+  key: GITLAB_EVENT_TYPE.push_events,
+  type: 'webhook',
+  arguments: [
+    projectArgumentDescriptor,
+    branchFilterStrategyArgumentDescriptor,
+    pushEventsBranchFilterArgumentDescriptor,
+  ],
+  testRun: getTestRunFn(data),
+  registerHook: getRegisterHookFn(GITLAB_EVENT_TYPE.push_events),
+  unregisterHook,
+};
+
+export default defineTrigger(triggerDescriptor);

packages/backend/src/apps/gitlab/triggers/push-event/push_event.ts

@@ -0,0 +1,75 @@
+// https://docs.gitlab.com/ee/user/project/integrations/webhook_events.html#push-events
+
+export default {
+  object_kind: 'push',
+  event_name: 'push',
+  before: '95790bf891e76fee5e1747ab589903a6a1f80f22',
+  after: 'da1560886d4f094c3e6c9ef40349f7d38b5d27d7',
+  ref: 'refs/heads/master',
+  checkout_sha: 'da1560886d4f094c3e6c9ef40349f7d38b5d27d7',
+  user_id: 4,
+  user_name: 'John Smith',
+  user_username: 'jsmith',
+  user_email: 'john@example.com',
+  user_avatar:
+    'https://s.gravatar.com/avatar/d4c74594d841139328695756648b6bd6?s=8://s.gravatar.com/avatar/d4c74594d841139328695756648b6bd6?s=80',
+  project_id: 15,
+  project: {
+    id: 15,
+    name: 'Diaspora',
+    description: '',
+    web_url: 'http://example.com/mike/diaspora',
+    avatar_url: null,
+    git_ssh_url: 'git@example.com:mike/diaspora.git',
+    git_http_url: 'http://example.com/mike/diaspora.git',
+    namespace: 'Mike',
+    visibility_level: 0,
+    path_with_namespace: 'mike/diaspora',
+    default_branch: 'master',
+    homepage: 'http://example.com/mike/diaspora',
+    url: 'git@example.com:mike/diaspora.git',
+    ssh_url: 'git@example.com:mike/diaspora.git',
+    http_url: 'http://example.com/mike/diaspora.git',
+  },
+  repository: {
+    name: 'Diaspora',
+    url: 'git@example.com:mike/diaspora.git',
+    description: '',
+    homepage: 'http://example.com/mike/diaspora',
+    git_http_url: 'http://example.com/mike/diaspora.git',
+    git_ssh_url: 'git@example.com:mike/diaspora.git',
+    visibility_level: 0,
+  },
+  commits: [
+    {
+      id: 'b6568db1bc1dcd7f8b4d5a946b0b91f9dacd7327',
+      message:
+        'Update Catalan translation to e38cb41.\n\nSee https://gitlab.com/gitlab-org/gitlab for more information',
+      title: 'Update Catalan translation to e38cb41.',
+      timestamp: '2011-12-12T14:27:31+02:00',
+      url: 'http://example.com/mike/diaspora/commit/b6568db1bc1dcd7f8b4d5a946b0b91f9dacd7327',
+      author: {
+        name: 'Jordi Mallach',
+        email: 'jordi@softcatala.org',
+      },
+      added: ['CHANGELOG'],
+      modified: ['app/controller/application.rb'],
+      removed: [],
+    },
+    {
+      id: 'da1560886d4f094c3e6c9ef40349f7d38b5d27d7',
+      message: 'fixed readme',
+      title: 'fixed readme',
+      timestamp: '2012-01-03T23:36:29+02:00',
+      url: 'http://example.com/mike/diaspora/commit/da1560886d4f094c3e6c9ef40349f7d38b5d27d7',
+      author: {
+        name: 'GitLab dev user',
+        email: 'gitlabdev@dv6700.(none)',
+      },
+      added: ['CHANGELOG'],
+      modified: ['app/controller/application.rb'],
+      removed: [],
+    },
+  ],
+  total_commits_count: 4,
+};

packages/backend/src/apps/gitlab/triggers/release-event/index.ts

@@ -0,0 +1,25 @@
+import { IRawTrigger } from '@automatisch/types';
+import defineTrigger from '../../../../helpers/define-trigger';
+import { GITLAB_EVENT_TYPE } from '../types';
+import {
+  getRegisterHookFn,
+  getTestRunFn,
+  projectArgumentDescriptor,
+  unregisterHook,
+} from '../lib';
+
+import data from './release_event';
+
+export const triggerDescriptor: IRawTrigger = {
+  name: 'Release event',
+  description: 'Release event (triggered when a release is created or updated)',
+  // info: 'https://docs.gitlab.com/ee/user/project/integrations/webhook_events.html#release-events',
+  key: GITLAB_EVENT_TYPE.releases_events,
+  type: 'webhook',
+  arguments: [projectArgumentDescriptor],
+  testRun: getTestRunFn(data),
+  registerHook: getRegisterHookFn(GITLAB_EVENT_TYPE.releases_events),
+  unregisterHook,
+};
+
+export default defineTrigger(triggerDescriptor);

packages/backend/src/apps/gitlab/triggers/release-event/release_event.ts

@@ -0,0 +1,72 @@
+// https://docs.gitlab.com/ee/user/project/integrations/webhook_events.html#release-events
+
+export default {
+  object_kind: 'release',
+  id: 1,
+  created_at: '2020-11-02 12:55:12 UTC',
+  description: 'v1.1 has been released',
+  name: 'v1.1',
+  released_at: '2020-11-02 12:55:12 UTC',
+  tag: 'v1.1',
+  project: {
+    id: 2,
+    name: 'release-webhook-example',
+    description: '',
+    web_url: 'https://example.com/gitlab-org/release-webhook-example',
+    avatar_url: null,
+    git_ssh_url: 'ssh://git@example.com/gitlab-org/release-webhook-example.git',
+    git_http_url: 'https://example.com/gitlab-org/release-webhook-example.git',
+    namespace: 'Gitlab',
+    visibility_level: 0,
+    path_with_namespace: 'gitlab-org/release-webhook-example',
+    default_branch: 'master',
+    ci_config_path: null,
+    homepage: 'https://example.com/gitlab-org/release-webhook-example',
+    url: 'ssh://git@example.com/gitlab-org/release-webhook-example.git',
+    ssh_url: 'ssh://git@example.com/gitlab-org/release-webhook-example.git',
+    http_url: 'https://example.com/gitlab-org/release-webhook-example.git',
+  },
+  url: 'https://example.com/gitlab-org/release-webhook-example/-/releases/v1.1',
+  action: 'create',
+  assets: {
+    count: 5,
+    links: [
+      {
+        id: 1,
+        external: true, // deprecated in GitLab 15.9, will be removed in GitLab 16.0.
+        link_type: 'other',
+        name: 'Changelog',
+        url: 'https://example.net/changelog',
+      },
+    ],
+    sources: [
+      {
+        format: 'zip',
+        url: 'https://example.com/gitlab-org/release-webhook-example/-/archive/v1.1/release-webhook-example-v1.1.zip',
+      },
+      {
+        format: 'tar.gz',
+        url: 'https://example.com/gitlab-org/release-webhook-example/-/archive/v1.1/release-webhook-example-v1.1.tar.gz',
+      },
+      {
+        format: 'tar.bz2',
+        url: 'https://example.com/gitlab-org/release-webhook-example/-/archive/v1.1/release-webhook-example-v1.1.tar.bz2',
+      },
+      {
+        format: 'tar',
+        url: 'https://example.com/gitlab-org/release-webhook-example/-/archive/v1.1/release-webhook-example-v1.1.tar',
+      },
+    ],
+  },
+  commit: {
+    id: 'ee0a3fb31ac16e11b9dbb596ad16d4af654d08f8',
+    message: 'Release v1.1',
+    title: 'Release v1.1',
+    timestamp: '2020-10-31T14:58:32+11:00',
+    url: 'https://example.com/gitlab-org/release-webhook-example/-/commit/ee0a3fb31ac16e11b9dbb596ad16d4af654d08f8',
+    author: {
+      name: 'Example User',
+      email: 'user@example.com',
+    },
+  },
+};

packages/backend/src/apps/gitlab/triggers/tag-push-event/index.ts

@@ -0,0 +1,26 @@
+import { IRawTrigger } from '@automatisch/types';
+import defineTrigger from '../../../../helpers/define-trigger';
+import { GITLAB_EVENT_TYPE } from '../types';
+import {
+  getRegisterHookFn,
+  getTestRunFn,
+  projectArgumentDescriptor,
+  unregisterHook,
+} from '../lib';
+
+import data from './tag_push_event';
+
+export const triggerDescriptor: IRawTrigger = {
+  name: 'Tag event',
+  description:
+    'Tag event (triggered when you create or delete tags in the repository)',
+  // info: 'https://docs.gitlab.com/ee/user/project/integrations/webhook_events.html#tag-events',
+  key: GITLAB_EVENT_TYPE.tag_push_events,
+  type: 'webhook',
+  arguments: [projectArgumentDescriptor],
+  testRun: getTestRunFn(data),
+  registerHook: getRegisterHookFn(GITLAB_EVENT_TYPE.tag_push_events),
+  unregisterHook,
+};
+
+export default defineTrigger(triggerDescriptor);

packages/backend/src/apps/gitlab/triggers/tag-push-event/tag_push_event.ts

@@ -0,0 +1,43 @@
+// https://docs.gitlab.com/ee/user/project/integrations/webhook_events.html#tag-events
+
+export default {
+  object_kind: 'tag_push',
+  event_name: 'tag_push',
+  before: '0000000000000000000000000000000000000000',
+  after: '82b3d5ae55f7080f1e6022629cdb57bfae7cccc7',
+  ref: 'refs/tags/v1.0.0',
+  checkout_sha: '82b3d5ae55f7080f1e6022629cdb57bfae7cccc7',
+  user_id: 1,
+  user_name: 'John Smith',
+  user_avatar:
+    'https://s.gravatar.com/avatar/d4c74594d841139328695756648b6bd6?s=8://s.gravatar.com/avatar/d4c74594d841139328695756648b6bd6?s=80',
+  project_id: 1,
+  project: {
+    id: 1,
+    name: 'Example',
+    description: '',
+    web_url: 'http://example.com/jsmith/example',
+    avatar_url: null,
+    git_ssh_url: 'git@example.com:jsmith/example.git',
+    git_http_url: 'http://example.com/jsmith/example.git',
+    namespace: 'Jsmith',
+    visibility_level: 0,
+    path_with_namespace: 'jsmith/example',
+    default_branch: 'master',
+    homepage: 'http://example.com/jsmith/example',
+    url: 'git@example.com:jsmith/example.git',
+    ssh_url: 'git@example.com:jsmith/example.git',
+    http_url: 'http://example.com/jsmith/example.git',
+  },
+  repository: {
+    name: 'Example',
+    url: 'ssh://git@example.com/jsmith/example.git',
+    description: '',
+    homepage: 'http://example.com/jsmith/example',
+    git_http_url: 'http://example.com/jsmith/example.git',
+    git_ssh_url: 'git@example.com:jsmith/example.git',
+    visibility_level: 0,
+  },
+  commits: [],
+  total_commits_count: 0,
+};

packages/backend/src/apps/gitlab/triggers/types.ts

@@ -0,0 +1,24 @@
+export enum GITLAB_EVENT_TYPE {
+  // ref: https://docs.gitlab.com/ee/api/projects.html#add-project-hook
+  confidential_issues_events = 'confidential_issues_events',
+  confidential_note_events = 'confidential_note_events',
+  deployment_events = 'deployment_events',
+  feature_flag_events = 'feature_flag_events',
+  issues_events = 'issues_events',
+  job_events = 'job_events',
+  merge_requests_events = 'merge_requests_events',
+  note_events = 'note_events',
+  pipeline_events = 'pipeline_events',
+  push_events = 'push_events',
+  releases_events = 'releases_events',
+  tag_push_events = 'tag_push_events',
+  wiki_page_events = 'wiki_page_events',
+}
+
+export type EventDescriptor = {
+  name: string;
+  description: string;
+  info?: string;
+  type: GITLAB_EVENT_TYPE;
+  data: any;
+};

packages/backend/src/apps/gitlab/triggers/wiki-page-event/index.ts

@@ -0,0 +1,26 @@
+import { IRawTrigger } from '@automatisch/types';
+import defineTrigger from '../../../../helpers/define-trigger';
+import { GITLAB_EVENT_TYPE } from '../types';
+import {
+  getRegisterHookFn,
+  getTestRunFn,
+  projectArgumentDescriptor,
+  unregisterHook,
+} from '../lib';
+
+import data from './wiki_page_event';
+
+export const triggerDescriptor: IRawTrigger = {
+  name: 'Wiki page event',
+  description:
+    'Wiki page event (triggered when a wiki page is created, updated, or deleted)',
+  // info: 'https://docs.gitlab.com/ee/user/project/integrations/webhook_events.html#wiki-page-events',
+  key: GITLAB_EVENT_TYPE.wiki_page_events,
+  type: 'webhook',
+  arguments: [projectArgumentDescriptor],
+  testRun: getTestRunFn(data),
+  registerHook: getRegisterHookFn(GITLAB_EVENT_TYPE.wiki_page_events),
+  unregisterHook,
+};
+
+export default defineTrigger(triggerDescriptor);

packages/backend/src/apps/gitlab/triggers/wiki-page-event/wiki_page_event.ts

@@ -0,0 +1,48 @@
+// https://docs.gitlab.com/ee/user/project/integrations/webhook_events.html#wiki-page-events
+
+export default {
+  object_kind: 'wiki_page',
+  user: {
+    id: 1,
+    name: 'Administrator',
+    username: 'root',
+    avatar_url:
+      'http://www.gravatar.com/avatar/e64c7d89f26bd1972efa854d13d7dd61?s=80\u0026d=identicon',
+    email: 'admin@example.com',
+  },
+  project: {
+    id: 1,
+    name: 'awesome-project',
+    description: 'This is awesome',
+    web_url: 'http://example.com/root/awesome-project',
+    avatar_url: null,
+    git_ssh_url: 'git@example.com:root/awesome-project.git',
+    git_http_url: 'http://example.com/root/awesome-project.git',
+    namespace: 'root',
+    visibility_level: 0,
+    path_with_namespace: 'root/awesome-project',
+    default_branch: 'master',
+    homepage: 'http://example.com/root/awesome-project',
+    url: 'git@example.com:root/awesome-project.git',
+    ssh_url: 'git@example.com:root/awesome-project.git',
+    http_url: 'http://example.com/root/awesome-project.git',
+  },
+  wiki: {
+    web_url: 'http://example.com/root/awesome-project/-/wikis/home',
+    git_ssh_url: 'git@example.com:root/awesome-project.wiki.git',
+    git_http_url: 'http://example.com/root/awesome-project.wiki.git',
+    path_with_namespace: 'root/awesome-project.wiki',
+    default_branch: 'master',
+  },
+  object_attributes: {
+    title: 'Awesome',
+    content: 'awesome content goes here',
+    format: 'markdown',
+    message: 'adding an awesome page to the wiki',
+    slug: 'awesome',
+    url: 'http://example.com/root/awesome-project/-/wikis/awesome',
+    action: 'create',
+    diff_url:
+      'http://example.com/root/awesome-project/-/wikis/home/diff?version_id=78ee4a6705abfbff4f4132c6646dbaae9c8fb6ec',
+  },
+};

packages/backend/src/apps/google-drive/dynamic-data/list-folders/index.ts

@@ -1,7 +1,7 @@
 import { IGlobalVariable, IJSONObject } from '@automatisch/types';
 
 export default {
-  name: 'List Folders',
+  name: 'List folders',
   key: 'listFolders',
 
   async run($: IGlobalVariable) {
@@ -11,13 +11,20 @@ export default {
       data: [],
     };
 
-    const params = {
+    const params: Record<string, unknown> = {
       q: `mimeType='application/vnd.google-apps.folder'`,
       orderBy: 'createdTime desc',
       pageToken: undefined as unknown as string,
       pageSize: 1000,
+      driveId: $.step.parameters.driveId,
+      supportsAllDrives: true,
     };
 
+    if ($.step.parameters.driveId) {
+      params.includeItemsFromAllDrives = true;
+      params.corpora = 'drive';
+    }
+
     do {
       const { data } = await $.http.get(
         `https://www.googleapis.com/drive/v3/files`,

packages/backend/src/apps/google-drive/triggers/new-files-in-folder/index.ts

@@ -2,7 +2,7 @@ import defineTrigger from '../../../../helpers/define-trigger';
 import newFilesInFolder from './new-files-in-folder';
 
 export default defineTrigger({
-  name: 'New Files in Folder',
+  name: 'New files in folder',
   key: 'newFilesInFolder',
   pollInterval: 15,
   description:
@@ -32,6 +32,7 @@ export default defineTrigger({
       key: 'folderId',
       type: 'dropdown' as const,
       required: false,
+      dependsOn: ['parameters.driveId'],
       description:
         'Check a specific folder for new files. Please note: new files added to subfolders inside the folder you choose here will NOT trigger this flow. Defaults to the top-level folder if none is picked.',
       variables: false,
@@ -43,6 +44,10 @@ export default defineTrigger({
             name: 'key',
             value: 'listFolders',
           },
+          {
+            name: 'parameters.driveId',
+            value: '{parameters.driveId}',
+          },
         ],
       },
     },

packages/backend/src/apps/google-drive/triggers/new-files-in-folder/new-files-in-folder.ts

@@ -7,15 +7,21 @@ const newFilesInFolder = async ($: IGlobalVariable) => {
   } else {
     q += ` and parents in 'root'`;
   }
-  const params = {
+  const params: Record<string, unknown> = {
     pageToken: undefined as unknown as string,
     orderBy: 'createdTime desc',
     fields: '*',
     pageSize: 1000,
     q,
     driveId: $.step.parameters.driveId,
+    supportsAllDrives: true,
   };
 
+  if ($.step.parameters.driveId) {
+    params.includeItemsFromAllDrives = true;
+    params.corpora = 'drive';
+  }
+
   do {
     const { data } = await $.http.get(`/v3/files`, { params });
     params.pageToken = data.nextPageToken;

packages/backend/src/apps/google-drive/triggers/new-files/index.ts

@@ -2,7 +2,7 @@ import defineTrigger from '../../../../helpers/define-trigger';
 import newFiles from './new-files';
 
 export default defineTrigger({
-  name: 'New Files',
+  name: 'New files',
   key: 'newFiles',
   pollInterval: 15,
   description: 'Triggers when any new file is added (inside of any folder).',

packages/backend/src/apps/google-drive/triggers/new-files/new-files.ts

@@ -1,15 +1,21 @@
 import { IGlobalVariable } from '@automatisch/types';
 
 const newFiles = async ($: IGlobalVariable) => {
-  const params = {
+  const params: Record<string, unknown> = {
     pageToken: undefined as unknown as string,
     orderBy: 'createdTime desc',
     fields: '*',
     pageSize: 1000,
     q: `mimeType!='application/vnd.google-apps.folder'`,
     driveId: $.step.parameters.driveId,
+    supportsAllDrives: true,
   };
 
+  if ($.step.parameters.driveId) {
+    params.includeItemsFromAllDrives = true;
+    params.corpora = 'drive';
+  }
+
   do {
     const { data } = await $.http.get('/v3/files', { params });
     params.pageToken = data.nextPageToken;

packages/backend/src/apps/google-drive/triggers/new-folders/index.ts

@@ -2,7 +2,7 @@ import defineTrigger from '../../../../helpers/define-trigger';
 import newFolders from './new-folders';
 
 export default defineTrigger({
-  name: 'New Folders',
+  name: 'New folders',
   key: 'newFolders',
   pollInterval: 15,
   description:
@@ -32,6 +32,7 @@ export default defineTrigger({
       key: 'folderId',
       type: 'dropdown' as const,
       required: false,
+      dependsOn: ['parameters.driveId'],
       description:
         'Check a specific folder for new subfolders. Please note: new folders added to subfolders inside the folder you choose here will NOT trigger this flow. Defaults to the top-level folder if none is picked.',
       variables: false,
@@ -43,6 +44,10 @@ export default defineTrigger({
             name: 'key',
             value: 'listFolders',
           },
+          {
+            name: 'parameters.driveId',
+            value: '{parameters.driveId}',
+          },
         ],
       },
     },

packages/backend/src/apps/google-drive/triggers/new-folders/new-folders.ts

@@ -8,15 +8,21 @@ const newFolders = async ($: IGlobalVariable) => {
     q += ` and parents in 'root'`;
   }
 
-  const params = {
+  const params: Record<string, unknown> = {
     pageToken: undefined as unknown as string,
     orderBy: 'createdTime desc',
     fields: '*',
     pageSize: 1000,
     q,
     driveId: $.step.parameters.driveId,
+    supportsAllDrives: true,
   };
 
+  if ($.step.parameters.driveId) {
+    params.includeItemsFromAllDrives = true;
+    params.corpora = 'drive';
+  }
+
   do {
     const { data } = await $.http.get(`/v3/files`, { params });
     params.pageToken = data.nextPageToken;

packages/backend/src/apps/google-drive/triggers/updated-files/index.ts

@@ -2,7 +2,7 @@ import defineTrigger from '../../../../helpers/define-trigger';
 import updatedFiles from './updated-files';
 
 export default defineTrigger({
-  name: 'Updated Files',
+  name: 'Updated files',
   key: 'updatedFiles',
   pollInterval: 15,
   description:
@@ -32,6 +32,7 @@ export default defineTrigger({
       key: 'folderId',
       type: 'dropdown' as const,
       required: false,
+      dependsOn: ['parameters.driveId'],
       description:
         'Check a specific folder for updated files. Please note: files located in subfolders of the folder you choose here will NOT trigger this flow. Defaults to the top-level folder if none is picked.',
       source: {
@@ -42,6 +43,10 @@ export default defineTrigger({
             name: 'key',
             value: 'listFolders',
           },
+          {
+            name: 'parameters.driveId',
+            value: '{parameters.driveId}',
+          },
         ],
       },
     },

packages/backend/src/apps/google-drive/triggers/updated-files/updated-files.ts

@@ -12,15 +12,21 @@ const updatedFiles = async ($: IGlobalVariable) => {
     q += ` and parents in 'root'`;
   }
 
-  const params = {
+  const params: Record<string, unknown> = {
     pageToken: undefined as unknown as string,
     orderBy: 'modifiedTime desc',
     fields: '*',
     pageSize: 1000,
     q,
     driveId: $.step.parameters.driveId,
+    supportsAllDrives: true,
   };
 
+  if ($.step.parameters.driveId) {
+    params.includeItemsFromAllDrives = true;
+    params.corpora = 'drive';
+  }
+
   do {
     const { data } = await $.http.get(`/v3/files`, { params });
     params.pageToken = data.nextPageToken;

packages/backend/src/apps/google-forms/triggers/new-form-responses/index.ts

@@ -2,7 +2,7 @@ import defineTrigger from '../../../../helpers/define-trigger';
 import newFormResponses from './new-form-responses';
 
 export default defineTrigger({
-  name: 'New Form Responses',
+  name: 'New form responses',
   key: 'newFormResponses',
   pollInterval: 15,
   description: 'Triggers when a new form response is submitted.',

packages/backend/src/apps/google-sheets/actions/create-spreadsheet-row/index.ts

@@ -0,0 +1,145 @@
+import defineAction from '../../../../helpers/define-action';
+
+type TSheetsResponse = {
+  sheets: {
+    properties: {
+      sheetId: string;
+      title: string;
+    };
+  }[];
+};
+
+export default defineAction({
+  name: 'Create spreadsheet row',
+  key: 'createSpreadsheetRow',
+  description: 'Creates a new row in a specified spreadsheet.',
+  arguments: [
+    {
+      label: 'Drive',
+      key: 'driveId',
+      type: 'dropdown' as const,
+      required: false,
+      description:
+        'The Google Drive where your spreadsheet resides. If nothing is selected, then your personal Google Drive will be used.',
+      variables: true,
+      source: {
+        type: 'query',
+        name: 'getDynamicData',
+        arguments: [
+          {
+            name: 'key',
+            value: 'listDrives',
+          },
+        ],
+      },
+    },
+    {
+      label: 'Spreadsheet',
+      key: 'spreadsheetId',
+      type: 'dropdown' as const,
+      required: true,
+      dependsOn: ['parameters.driveId'],
+      description: 'The spreadsheets in your Google Drive.',
+      variables: true,
+      source: {
+        type: 'query',
+        name: 'getDynamicData',
+        arguments: [
+          {
+            name: 'key',
+            value: 'listSpreadsheets',
+          },
+          {
+            name: 'parameters.driveId',
+            value: '{parameters.driveId}',
+          },
+        ],
+      },
+    },
+    {
+      label: 'Worksheet',
+      key: 'worksheetId',
+      type: 'dropdown' as const,
+      required: true,
+      dependsOn: ['parameters.spreadsheetId'],
+      description: 'The worksheets in your selected spreadsheet.',
+      variables: true,
+      source: {
+        type: 'query',
+        name: 'getDynamicData',
+        arguments: [
+          {
+            name: 'key',
+            value: 'listWorksheets',
+          },
+          {
+            name: 'parameters.spreadsheetId',
+            value: '{parameters.spreadsheetId}',
+          },
+        ],
+      },
+      additionalFields: {
+        type: 'query',
+        name: 'getDynamicFields',
+        arguments: [
+          {
+            name: 'key',
+            value: 'listSheetHeaders',
+          },
+          {
+            name: 'parameters.worksheetId',
+            value: '{parameters.worksheetId}',
+          },
+          {
+            name: 'parameters.spreadsheetId',
+            value: '{parameters.spreadsheetId}',
+          },
+        ],
+      },
+    },
+  ],
+
+  async run($) {
+    const {
+      data: { sheets },
+    } = await $.http.get<TSheetsResponse>(
+      `/v4/spreadsheets/${$.step.parameters.spreadsheetId}`
+    );
+
+    const selectedSheet = sheets.find(
+      (sheet) => sheet.properties.sheetId === $.step.parameters.worksheetId
+    );
+
+    const sheetName = selectedSheet.properties.title;
+
+    const range = sheetName;
+
+    const dataValues = Object.entries($.step.parameters)
+      .filter((entry: [string, string]) => entry[0].startsWith('header-'))
+      .map((value) => value[1]);
+
+    const values = [dataValues];
+
+    const params = {
+      valueInputOption: 'USER_ENTERED',
+      insertDataOption: 'INSERT_ROWS',
+      includeValuesInResponse: true,
+    };
+
+    const body = {
+      majorDimension: 'ROWS',
+      range,
+      values,
+    };
+
+    const { data } = await $.http.post(
+      `/v4/spreadsheets/${$.step.parameters.spreadsheetId}/values/${range}:append`,
+      body,
+      { params }
+    );
+
+    $.setActionItem({
+      raw: data,
+    });
+  },
+});

packages/backend/src/apps/google-sheets/actions/create-spreadsheet/index.ts

@@ -0,0 +1,105 @@
+import defineAction from '../../../../helpers/define-action';
+
+type THeaders = {
+  __id: string;
+  header: string;
+}[];
+
+export default defineAction({
+  name: 'Create spreadsheet',
+  key: 'createSpreadsheet',
+  description:
+    'Create a blank spreadsheet or duplicate an existing spreadsheet. Optionally, provide headers.',
+  arguments: [
+    {
+      label: 'Title',
+      key: 'title',
+      type: 'string' as const,
+      required: true,
+      description: '',
+      variables: true,
+    },
+    {
+      label: 'Spreadsheet to copy',
+      key: 'spreadsheetId',
+      type: 'dropdown' as const,
+      required: false,
+      description: 'Choose a spreadsheet to copy its data.',
+      variables: true,
+      source: {
+        type: 'query',
+        name: 'getDynamicData',
+        arguments: [
+          {
+            name: 'key',
+            value: 'listSpreadsheets',
+          },
+        ],
+      },
+    },
+    {
+      label: 'Headers',
+      key: 'headers',
+      type: 'dynamic' as const,
+      required: false,
+      description:
+        'These headers are ignored if "Spreadsheet to Copy" is selected.',
+      fields: [
+        {
+          label: 'Header',
+          key: 'header',
+          type: 'string' as const,
+          required: true,
+          variables: true,
+        },
+      ],
+    },
+  ],
+
+  async run($) {
+    if ($.step.parameters.spreadsheetId) {
+      const body = { name: $.step.parameters.title };
+
+      const { data } = await $.http.post(
+        `https://www.googleapis.com/drive/v3/files/${$.step.parameters.spreadsheetId}/copy`,
+        body
+      );
+
+      $.setActionItem({
+        raw: data,
+      });
+    } else {
+      const headers = $.step.parameters.headers as THeaders;
+      const values = headers.map((entry) => entry.header);
+
+      const spreadsheetBody = {
+        properties: {
+          title: $.step.parameters.title,
+        },
+        sheets: [
+          {
+            data: [
+              {
+                startRow: 0,
+                startColumn: 0,
+                rowData: [
+                  {
+                    values: values.map((header) => ({
+                      userEnteredValue: { stringValue: header },
+                    })),
+                  },
+                ],
+              },
+            ],
+          },
+        ],
+      };
+
+      const { data } = await $.http.post('/v4/spreadsheets', spreadsheetBody);
+
+      $.setActionItem({
+        raw: data,
+      });
+    }
+  },
+});

packages/backend/src/apps/google-sheets/actions/create-worksheet/index.ts

@@ -0,0 +1,191 @@
+import { IJSONObject } from '@automatisch/types';
+import defineAction from '../../../../helpers/define-action';
+
+type THeaders = {
+  __id: string;
+  header: string;
+}[];
+
+type TSheetsResponse = {
+  sheets: {
+    properties: {
+      sheetId: string;
+      title: string;
+    };
+  }[];
+};
+
+type TBody = {
+  requests: IJSONObject[];
+};
+
+export default defineAction({
+  name: 'Create worksheet',
+  key: 'createWorksheet',
+  description:
+    'Create a blank worksheet with a title. Optionally, provide headers.',
+  arguments: [
+    {
+      label: 'Drive',
+      key: 'driveId',
+      type: 'dropdown' as const,
+      required: false,
+      description:
+        'The Google Drive where your spreadsheet resides. If nothing is selected, then your personal Google Drive will be used.',
+      variables: true,
+      source: {
+        type: 'query',
+        name: 'getDynamicData',
+        arguments: [
+          {
+            name: 'key',
+            value: 'listDrives',
+          },
+        ],
+      },
+    },
+    {
+      label: 'Spreadsheet',
+      key: 'spreadsheetId',
+      type: 'dropdown' as const,
+      required: true,
+      dependsOn: ['parameters.driveId'],
+      variables: true,
+      source: {
+        type: 'query',
+        name: 'getDynamicData',
+        arguments: [
+          {
+            name: 'key',
+            value: 'listSpreadsheets',
+          },
+          {
+            name: 'parameters.driveId',
+            value: '{parameters.driveId}',
+          },
+        ],
+      },
+    },
+    {
+      label: 'Title',
+      key: 'title',
+      type: 'string' as const,
+      required: true,
+      description: '',
+      variables: true,
+    },
+    {
+      label: 'Headers',
+      key: 'headers',
+      type: 'dynamic' as const,
+      required: false,
+      fields: [
+        {
+          label: 'Header',
+          key: 'header',
+          type: 'string' as const,
+          required: true,
+          variables: true,
+        },
+      ],
+    },
+    {
+      label: 'Overwrite',
+      key: 'overwrite',
+      type: 'dropdown' as const,
+      required: false,
+      value: false,
+      description:
+        'If a worksheet with the specified title exists, its content would be lost. Please, use with caution.',
+      variables: true,
+      options: [
+        {
+          label: 'Yes',
+          value: 'true',
+        },
+        {
+          label: 'No',
+          value: 'false',
+        },
+      ],
+    },
+  ],
+
+  async run($) {
+    const {
+      data: { sheets },
+    } = await $.http.get<TSheetsResponse>(
+      `/v4/spreadsheets/${$.step.parameters.spreadsheetId}`
+    );
+    const selectedSheet = sheets.find(
+      (sheet) => sheet.properties.title === $.step.parameters.title
+    );
+    const headers = $.step.parameters.headers as THeaders;
+    const values = headers.map((entry) => entry.header);
+
+    const body: TBody = {
+      requests: [
+        {
+          addSheet: {
+            properties: {
+              title: $.step.parameters.title,
+            },
+          },
+        },
+      ],
+    };
+
+    if ($.step.parameters.overwrite === 'true' && selectedSheet) {
+      body.requests.unshift({
+        deleteSheet: {
+          sheetId: selectedSheet.properties.sheetId,
+        },
+      });
+    }
+
+    const { data } = await $.http.post(
+      `https://sheets.googleapis.com/v4/spreadsheets/${$.step.parameters.spreadsheetId}:batchUpdate`,
+      body
+    );
+
+    if (values.length) {
+      const body = {
+        requests: [
+          {
+            updateCells: {
+              rows: [
+                {
+                  values: values.map((header) => ({
+                    userEnteredValue: { stringValue: header },
+                  })),
+                },
+              ],
+              fields: '*',
+              start: {
+                sheetId:
+                  data.replies[data.replies.length - 1].addSheet.properties
+                    .sheetId,
+                rowIndex: 0,
+                columnIndex: 0,
+              },
+            },
+          },
+        ],
+      };
+
+      const { data: response } = await $.http.post(
+        `https://sheets.googleapis.com/v4/spreadsheets/${$.step.parameters.spreadsheetId}:batchUpdate`,
+        body
+      );
+
+      $.setActionItem({
+        raw: response,
+      });
+      return;
+    }
+
+    $.setActionItem({
+      raw: data,
+    });
+  },
+});

packages/backend/src/apps/google-sheets/actions/index.ts

@@ -0,0 +1,5 @@
+import createSpreadsheet from './create-spreadsheet';
+import createSpreadsheetRow from './create-spreadsheet-row';
+import createWorksheet from './create-worksheet';
+
+export default [createSpreadsheet, createSpreadsheetRow, createWorksheet];

packages/backend/src/apps/google-sheets/dynamic-data/index.ts

@@ -1,3 +1,5 @@
 import listDrives from './list-drives';
+import listSpreadsheets from './list-spreadsheets';
+import listWorksheets from './list-worksheets';
 
-export default [listDrives];
+export default [listDrives, listSpreadsheets, listWorksheets];

packages/backend/src/apps/google-sheets/dynamic-data/list-spreadsheets/index.ts

@@ -0,0 +1,47 @@
+import { IGlobalVariable, IJSONObject } from '@automatisch/types';
+
+export default {
+  name: 'List spreadsheets',
+  key: 'listSpreadsheets',
+
+  async run($: IGlobalVariable) {
+    const spreadsheets: {
+      data: IJSONObject[];
+    } = {
+      data: [],
+    };
+
+    const params: Record<string, unknown> = {
+      q: `mimeType='application/vnd.google-apps.spreadsheet'`,
+      pageSize: 100,
+      pageToken: undefined as unknown as string,
+      orderBy: 'createdTime desc',
+      driveId: $.step.parameters.driveId,
+      supportsAllDrives: true,
+    };
+
+    if ($.step.parameters.driveId) {
+      params.includeItemsFromAllDrives = true;
+      params.corpora = 'drive';
+    }
+
+    do {
+      const { data } = await $.http.get(
+        `https://www.googleapis.com/drive/v3/files`,
+        { params }
+      );
+      params.pageToken = data.nextPageToken;
+
+      if (data.files?.length) {
+        for (const file of data.files) {
+          spreadsheets.data.push({
+            value: file.id,
+            name: file.name,
+          });
+        }
+      }
+    } while (params.pageToken);
+
+    return spreadsheets;
+  },
+};

packages/backend/src/apps/google-sheets/dynamic-data/list-worksheets/index.ts

@@ -0,0 +1,42 @@
+import { IGlobalVariable, IJSONObject } from '@automatisch/types';
+
+export default {
+  name: 'List worksheets',
+  key: 'listWorksheets',
+
+  async run($: IGlobalVariable) {
+    const spreadsheetId = $.step.parameters.spreadsheetId as string;
+
+    const worksheets: {
+      data: IJSONObject[];
+    } = {
+      data: [],
+    };
+
+    if (!spreadsheetId) {
+      return worksheets;
+    }
+
+    const params: Record<string, unknown> = {
+      pageToken: undefined as unknown as string,
+    };
+
+    do {
+      const { data } = await $.http.get(`/v4/spreadsheets/${spreadsheetId}`, {
+        params,
+      });
+      params.pageToken = data.nextPageToken;
+
+      if (data.sheets?.length) {
+        for (const sheet of data.sheets) {
+          worksheets.data.push({
+            value: sheet.properties.sheetId,
+            name: sheet.properties.title,
+          });
+        }
+      }
+    } while (params.pageToken);
+
+    return worksheets;
+  },
+};