feat(airbrake): add airbrake integration

feat: put favicon and notifications page behind feature flags

.devcontainer/devcontainer.json

@@ -8,7 +8,7 @@
       "version": "latest"
     },
     "ghcr.io/devcontainers/features/node:1": {
-      "version": 16
+      "version": 20
     },
     "ghcr.io/devcontainers/features/common-utils:1": {
       "username": "vscode",

.github/workflows/ci.yml

@@ -16,7 +16,7 @@ jobs:
       - uses: actions/checkout@v2
       - uses: actions/setup-node@v2
         with:
-          node-version: '16'
+          node-version: '18'
           cache: 'yarn'
           cache-dependency-path: yarn.lock
       - run: echo "💡 The ${{ github.repository }} repository has been cloned to the runner."
@@ -24,7 +24,7 @@ jobs:
       - run: yarn --frozen-lockfile
       - run: yarn lint
       - run: echo "🍏 This job's status is ${{ job.status }}."
-  build-backend:
+  start-backend-server:
     runs-on: ubuntu-latest
     steps:
       - run: echo "🎉 The job was automatically triggered by a ${{ github.event_name }} event."
@@ -33,13 +33,36 @@ jobs:
       - uses: actions/checkout@v2
       - uses: actions/setup-node@v2
         with:
-          node-version: '16'
+          node-version: '18'
           cache: 'yarn'
           cache-dependency-path: yarn.lock
       - run: echo "💡 The ${{ github.repository }} repository has been cloned to the runner."
       - run: echo "🖥️ The workflow is now ready to test your code on the runner."
       - run: yarn --frozen-lockfile && yarn lerna bootstrap
-      - run: cd packages/backend && yarn build
+      - run: cd packages/backend && yarn start
+        env:
+          ENCRYPTION_KEY: sample_encryption_key
+          WEBHOOK_SECRET_KEY: sample_webhook_secret_key
+      - run: echo "🍏 This job's status is ${{ job.status }}."
+  start-backend-worker:
+    runs-on: ubuntu-latest
+    steps:
+      - run: echo "🎉 The job was automatically triggered by a ${{ github.event_name }} event."
+      - run: echo "🐧 This job is now running on a ${{ runner.os }} server hosted by GitHub!"
+      - run: echo "🔎 The name of your branch is ${{ github.ref }} and your repository is ${{ github.repository }}."
+      - uses: actions/checkout@v2
+      - uses: actions/setup-node@v2
+        with:
+          node-version: '18'
+          cache: 'yarn'
+          cache-dependency-path: yarn.lock
+      - run: echo "💡 The ${{ github.repository }} repository has been cloned to the runner."
+      - run: echo "🖥️ The workflow is now ready to test your code on the runner."
+      - run: yarn --frozen-lockfile && yarn lerna bootstrap
+      - run: cd packages/backend && yarn start:worker
+        env:
+          ENCRYPTION_KEY: sample_encryption_key
+          WEBHOOK_SECRET_KEY: sample_webhook_secret_key
       - run: echo "🍏 This job's status is ${{ job.status }}."
   build-web:
     runs-on: ubuntu-latest
@@ -50,7 +73,7 @@ jobs:
       - uses: actions/checkout@v2
       - uses: actions/setup-node@v2
         with:
-          node-version: '16'
+          node-version: '18'
           cache: 'yarn'
           cache-dependency-path: yarn.lock
       - run: echo "💡 The ${{ github.repository }} repository has been cloned to the runner."
@@ -60,21 +83,3 @@ jobs:
         env:
           CI: false
       - run: echo "🍏 This job's status is ${{ job.status }}."
-  build-cli:
-    runs-on: ubuntu-latest
-    steps:
-      - run: echo "🎉 The job was automatically triggered by a ${{ github.event_name }} event."
-      - run: echo "🐧 This job is now running on a ${{ runner.os }} server hosted by GitHub!"
-      - run: echo "🔎 The name of your branch is ${{ github.ref }} and your repository is ${{ github.repository }}."
-      - uses: actions/checkout@v2
-      - uses: actions/setup-node@v2
-        with:
-          node-version: '16'
-          cache: 'yarn'
-          cache-dependency-path: yarn.lock
-      - run: echo "💡 The ${{ github.repository }} repository has been cloned to the runner."
-      - run: echo "🖥️ The workflow is now ready to test your code on the runner."
-      - run: yarn --frozen-lockfile && yarn lerna bootstrap
-      - run: cd packages/backend && yarn build
-      - run: cd packages/cli && yarn build
-      - run: echo "🍏 This job's status is ${{ job.status }}."

.github/workflows/playwright.yml

@@ -63,13 +63,13 @@ jobs:
       - name: Install Playwright Browsers
         run: yarn playwright install --with-deps
       - name: Build Automatisch
-        run: yarn lerna run --scope=@*/{web,backend,cli} build
+        run: yarn lerna run --scope=@*/{web,cli} build
         env:
           # Keep this until we clean up warnings in build processes
           CI: false
       - name: Migrate database
         working-directory: ./packages/backend
-        run: yarn db:migrate --migrations-directory ./dist/src/db/migrations
+        run: yarn db:migrate
       - name: Seed user
         working-directory: ./packages/backend
         run: yarn db:seed:user &
@@ -96,7 +96,7 @@ jobs:
         run: yarn start &
         working-directory: ./packages/backend
       - name: Run Automatisch worker
-        run: node dist/src/worker.js &
+        run: yarn start:worker &
         working-directory: ./packages/backend
       - name: Setup upterm session
         if: false

.node-version

@@ -1 +1 @@
-16.15.0
+18.19.0

.nvmrc

@@ -1 +1 @@
-16.15.0
+18.19.0

docker/Dockerfile

@@ -1,5 +1,5 @@
 # syntax=docker/dockerfile:1
-FROM node:16-alpine
+FROM node:18-alpine
 WORKDIR /automatisch
 
 RUN \

docker/Dockerfile.cloud

@@ -1,17 +1,22 @@
 # syntax=docker/dockerfile:1
-FROM node:16-alpine
-WORKDIR /automatisch
+FROM node:18-alpine
 
 ENV PORT 3000
 
-RUN ls -lna
+RUN \
+  apk --no-cache add --virtual build-dependencies python3 build-base git
 
-# copy the app, note .dockerignore
-COPY . ./
+RUN git clone https://github.com/automatisch/automatisch.git
 
-RUN yarn
-RUN yarn lerna bootstrap
-RUN yarn lerna run --scope=@*/{web,backend,cli} build
+WORKDIR /automatisch
+
+RUN yarn install
+
+RUN if [ "$WORKER" != "true" ]; then cd packages/web && yarn build; fi
+
+RUN \
+  rm -rf /usr/local/share/.cache/ && \
+  apk del build-dependencies
 
 COPY ./docker/entrypoint-cloud.sh /entrypoint-cloud.sh
 

docker/entrypoint-cloud.sh

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

package.json

@@ -6,8 +6,7 @@
     "start": "lerna run --stream --parallel --scope=@*/{web,backend} dev",
     "start:web": "lerna run --stream --scope=@*/web dev",
     "start:backend": "lerna run --stream --scope=@*/backend dev",
-    "lint": "lerna run --no-bail --stream --parallel --scope=@*/{web,backend,cli} lint",
-    "build:watch": "lerna run --no-bail --stream --parallel --scope=@*/{web,backend,cli} build:watch",
+    "lint": "lerna run --no-bail --stream --parallel --scope=@*/{web,backend} lint",
     "build:docs": "cd ./packages/docs && yarn install && yarn build"
   },
   "workspaces": {
@@ -18,7 +17,6 @@
       "**/babel-loader",
       "**/webpack",
       "**/@automatisch/web",
-      "**/@automatisch/types",
       "**/ajv"
     ]
   },

packages/backend/.eslintrc.json

@@ -0,0 +1,12 @@
+{
+  "root": true,
+  "env": {
+    "node": true,
+    "es6": true
+  },
+  "extends": ["eslint:recommended", "prettier"],
+  "parserOptions": {
+    "ecmaVersion": "latest",
+    "sourceType": "module"
+  }
+}

packages/backend/bin/database/client.js

@@ -0,0 +1,9 @@
+import pg from 'pg';
+
+const client = new pg.Client({
+  host: 'localhost',
+  user: 'postgres',
+  port: 5432,
+});
+
+export default client;

packages/backend/bin/database/client.ts

@@ -1,9 +0,0 @@
-import { Client } from 'pg';
-
-const client = new Client({
-  host: 'localhost',
-  user: 'postgres',
-  port: 5432,
-});
-
-export default client;

packages/backend/bin/database/convert-migrations.js

@@ -0,0 +1,31 @@
+import appConfig from '../../src/config/app.js';
+import logger from '../../src/helpers/logger.js';
+import '../../src/config/orm.js';
+import { client as knex } from '../../src/config/database.js';
+
+export const renameMigrationsAsJsFiles = async () => {
+  if (!appConfig.isDev) {
+    return;
+  }
+
+  try {
+    const tableExists = await knex.schema.hasTable('knex_migrations');
+
+    if (tableExists) {
+      await knex('knex_migrations')
+        .where('name', 'like', '%.ts')
+        .update({
+          name: knex.raw("REPLACE(name, '.ts', '.js')"),
+        });
+      logger.info(
+        `Migration file names with typescript renamed as JS file names!`
+      );
+    }
+  } catch (err) {
+    logger.error(err.message);
+  }
+
+  await knex.destroy();
+};
+
+renameMigrationsAsJsFiles();

packages/backend/bin/database/create.js

@@ -0,0 +1,3 @@
+import { createDatabaseAndUser } from './utils.js';
+
+createDatabaseAndUser();

packages/backend/bin/database/create.ts

@@ -1,3 +0,0 @@
-import { createDatabaseAndUser } from './utils';
-
-createDatabaseAndUser();

packages/backend/bin/database/drop.js

@@ -0,0 +1,3 @@
+import { dropDatabase } from './utils.js';
+
+dropDatabase();

packages/backend/bin/database/drop.ts

@@ -1,3 +0,0 @@
-import { dropDatabase } from './utils';
-
-dropDatabase();

packages/backend/bin/database/seed-user.js

@@ -0,0 +1,3 @@
+import { createUser } from './utils.js';
+
+createUser();

packages/backend/bin/database/seed-user.ts

@@ -1,3 +0,0 @@
-import { createUser } from './utils';
-
-createUser();

packages/backend/bin/database/utils.js

@@ -0,0 +1,134 @@
+import appConfig from '../../src/config/app.js';
+import logger from '../../src/helpers/logger.js';
+import client from './client.js';
+import User from '../../src/models/user.js';
+import Role from '../../src/models/role.js';
+import '../../src/config/orm.js';
+import process from 'process';
+
+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',
+    roleId: role.id,
+  };
+
+  try {
+    const userCount = await User.query().resultSize();
+
+    if (userCount === 0) {
+      const user = await User.query().insertAndFetch(userParams);
+      logger.info(`User has been saved: ${user.email}`);
+    } else {
+      logger.info('No need to seed a user.');
+    }
+  } catch (err) {
+    if (err.nativeError.code !== UNIQUE_VIOLATION_CODE) {
+      throw err;
+    }
+
+    logger.info(`User already exists: ${email}`);
+  }
+
+  process.exit(0);
+}
+
+export const createDatabaseAndUser = async (
+  database = appConfig.postgresDatabase,
+  user = appConfig.postgresUsername
+) => {
+  await client.connect();
+  await createDatabase(database);
+  await createDatabaseUser(user);
+  await grantPrivileges(database, user);
+
+  await client.end();
+  process.exit(0);
+};
+
+export const createDatabase = async (database = appConfig.postgresDatabase) => {
+  const DUPLICATE_DB_CODE = '42P04';
+
+  try {
+    await client.query(`CREATE DATABASE ${database}`);
+    logger.info(`Database: ${database} created!`);
+  } catch (err) {
+    if (err.code !== DUPLICATE_DB_CODE) {
+      throw err;
+    }
+
+    logger.info(`Database: ${database} already exists!`);
+  }
+};
+
+export const createDatabaseUser = async (user = appConfig.postgresUsername) => {
+  const DUPLICATE_OBJECT_CODE = '42710';
+
+  try {
+    const result = await client.query(`CREATE USER ${user}`);
+    logger.info(`Database User: ${user} created!`);
+
+    return result;
+  } catch (err) {
+    if (err.code !== DUPLICATE_OBJECT_CODE) {
+      throw err;
+    }
+
+    logger.info(`Database User: ${user} already exists!`);
+  }
+};
+
+export const grantPrivileges = async (
+  database = appConfig.postgresDatabase,
+  user = appConfig.postgresUsername
+) => {
+  await client.query(
+    `GRANT ALL PRIVILEGES ON DATABASE ${database} TO ${user};`
+  );
+
+  logger.info(`${user} has granted all privileges on ${database}!`);
+};
+
+export const dropDatabase = async () => {
+  if (appConfig.appEnv != 'development' && appConfig.appEnv != 'test') {
+    const errorMessage =
+      'Drop database command can be used only with development or test environments!';
+
+    logger.error(errorMessage);
+    return;
+  }
+
+  await client.connect();
+  await dropDatabaseAndUser();
+
+  await client.end();
+};
+
+export const dropDatabaseAndUser = async (
+  database = appConfig.postgresDatabase,
+  user = appConfig.postgresUsername
+) => {
+  await client.query(`DROP DATABASE IF EXISTS ${database}`);
+  logger.info(`Database: ${database} removed!`);
+
+  await client.query(`DROP USER IF EXISTS ${user}`);
+  logger.info(`Database User: ${user} removed!`);
+};

packages/backend/bin/database/utils.ts

@@ -1,131 +0,0 @@
-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',
-    roleId: role.id,
-  };
-
-  try {
-    const userCount = await User.query().resultSize();
-
-    if (userCount === 0) {
-      const user = await User.query().insertAndFetch(userParams);
-      logger.info(`User has been saved: ${user.email}`);
-    } else {
-      logger.info('No need to seed a user.');
-    }
-  } catch (err) {
-    if ((err as any).nativeError.code !== UNIQUE_VIOLATION_CODE) {
-      throw err;
-    }
-
-    logger.info(`User already exists: ${email}`);
-  }
-}
-
-export const createDatabaseAndUser = async (
-  database = appConfig.postgresDatabase,
-  user = appConfig.postgresUsername
-) => {
-  await client.connect();
-  await createDatabase(database);
-  await createDatabaseUser(user);
-  await grantPrivileges(database, user);
-
-  await client.end();
-};
-
-export const createDatabase = async (database = appConfig.postgresDatabase) => {
-  const DUPLICATE_DB_CODE = '42P04';
-
-  try {
-    await client.query(`CREATE DATABASE ${database}`);
-    logger.info(`Database: ${database} created!`);
-  } catch (err) {
-    if ((err as any).code !== DUPLICATE_DB_CODE) {
-      throw err;
-    }
-
-    logger.info(`Database: ${database} already exists!`);
-  }
-};
-
-export const createDatabaseUser = async (user = appConfig.postgresUsername) => {
-  const DUPLICATE_OBJECT_CODE = '42710';
-
-  try {
-    const result = await client.query(`CREATE USER ${user}`);
-    logger.info(`Database User: ${user} created!`);
-
-    return result;
-  } catch (err) {
-    if ((err as any).code !== DUPLICATE_OBJECT_CODE) {
-      throw err;
-    }
-
-    logger.info(`Database User: ${user} already exists!`);
-  }
-};
-
-export const grantPrivileges = async (
-  database = appConfig.postgresDatabase,
-  user = appConfig.postgresUsername
-) => {
-  await client.query(
-    `GRANT ALL PRIVILEGES ON DATABASE ${database} TO ${user};`
-  );
-
-  logger.info(`${user} has granted all privileges on ${database}!`);
-};
-
-export const dropDatabase = async () => {
-  if (appConfig.appEnv != 'development' && appConfig.appEnv != 'test') {
-    const errorMessage =
-      'Drop database command can be used only with development or test environments!';
-
-    logger.error(errorMessage);
-    return;
-  }
-
-  await client.connect();
-  await dropDatabaseAndUser();
-
-  await client.end();
-};
-
-export const dropDatabaseAndUser = async (
-  database = appConfig.postgresDatabase,
-  user = appConfig.postgresUsername
-) => {
-  await client.query(`DROP DATABASE IF EXISTS ${database}`);
-  logger.info(`Database: ${database} removed!`);
-
-  await client.query(`DROP USER IF EXISTS ${user}`);
-  logger.info(`Database User: ${user} removed!`);
-};

packages/backend/database-utils.d.ts

@@ -1 +0,0 @@
-export * from './dist/bin/database/utils';

packages/backend/database-utils.js

@@ -1,2 +0,0 @@
-/* eslint-disable */
-module.exports = require('./dist/bin/database/utils');

packages/backend/database.d.ts

@@ -1 +0,0 @@
-export * from './dist/src/config/database';

packages/backend/database.js

@@ -1,2 +0,0 @@
-/* eslint-disable */
-module.exports = require('./dist/src/config/database');

packages/backend/jest.config.js

@@ -1,9 +0,0 @@
-/** @type {import('ts-jest').JestConfigWithTsJest} */
-module.exports = {
-  preset: 'ts-jest',
-  testEnvironment: 'node',
-  setupFilesAfterEnv: ['./test/setup/global-hooks.ts'],
-  globalTeardown: './test/setup/global-teardown.ts',
-  collectCoverage: true,
-  collectCoverageFrom: ['src/graphql/queries/*.ts'],
-};

packages/backend/knexfile.js

@@ -0,0 +1,33 @@
+import { knexSnakeCaseMappers } from 'objection';
+import appConfig from './src/config/app.js';
+import path from 'path';
+import { fileURLToPath } from 'url';
+
+const fileExtension = 'js';
+const __dirname = path.dirname(fileURLToPath(import.meta.url));
+
+const knexConfig = {
+  client: 'pg',
+  connection: {
+    host: appConfig.postgresHost,
+    port: appConfig.postgresPort,
+    user: appConfig.postgresUsername,
+    password: appConfig.postgresPassword,
+    database: appConfig.postgresDatabase,
+    ssl: appConfig.postgresEnableSsl,
+  },
+  asyncStackTraces: appConfig.isDev,
+  searchPath: [appConfig.postgresSchema],
+  pool: { min: 0, max: 20 },
+  migrations: {
+    directory: __dirname + '/src/db/migrations',
+    extension: fileExtension,
+    loadExtensions: [`.${fileExtension}`],
+  },
+  seeds: {
+    directory: __dirname + '/src/db/seeds',
+  },
+  ...(appConfig.isTest ? knexSnakeCaseMappers() : {}),
+};
+
+export default knexConfig;

packages/backend/knexfile.ts

@@ -1,30 +0,0 @@
-import { knexSnakeCaseMappers } from 'objection';
-import appConfig from './src/config/app';
-
-const fileExtension = appConfig.isDev || appConfig.isTest ? 'ts' : 'js';
-
-const knexConfig = {
-  client: 'pg',
-  connection: {
-    host: appConfig.postgresHost,
-    port: appConfig.postgresPort,
-    user: appConfig.postgresUsername,
-    password: appConfig.postgresPassword,
-    database: appConfig.postgresDatabase,
-    ssl: appConfig.postgresEnableSsl,
-  },
-  asyncStackTraces: appConfig.isDev,
-  searchPath: [appConfig.postgresSchema],
-  pool: { min: 0, max: 20 },
-  migrations: {
-    directory: __dirname + '/src/db/migrations',
-    extension: fileExtension,
-    loadExtensions: [`.${fileExtension}`],
-  },
-  seeds: {
-    directory: __dirname + '/src/db/seeds',
-  },
-  ...(appConfig.isTest ? knexSnakeCaseMappers() : {}),
-};
-
-export default knexConfig;

packages/backend/logger.d.ts

@@ -1 +0,0 @@
-export * from './dist/src/helpers/logger';

packages/backend/logger.js

@@ -1,2 +0,0 @@
-/* eslint-disable */
-module.exports = require('./dist/src/helpers/logger');

packages/backend/package.json

@@ -3,27 +3,23 @@
   "version": "0.10.0",
   "license": "See LICENSE file",
   "description": "The open source Zapier alternative. Build workflow automation without spending time and money.",
+  "type": "module",
   "scripts": {
-    "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",
-    "start": "node dist/src/server.js",
-    "pretest": "APP_ENV=test ts-node ./test/setup/prepare-test-env.ts",
-    "test": "APP_ENV=test jest --verbose",
+    "dev": "nodemon --watch 'src/**/*.js' --exec 'node' src/server.js",
+    "worker": "nodemon --watch 'src/**/*.js' --exec 'node' src/worker.js",
+    "start": "node src/server.js",
+    "start:worker": "node src/worker.js",
+    "pretest": "APP_ENV=test node ./test/setup/prepare-test-env.js",
+    "test": "APP_ENV=test vitest run",
     "lint": "eslint . --ignore-path ../../.eslintignore",
-    "db:create": "ts-node ./bin/database/create.ts",
-    "db:seed:user": "ts-node ./bin/database/seed-user.ts",
-    "db:drop": "ts-node ./bin/database/drop.ts",
+    "db:create": "node ./bin/database/create.js",
+    "db:seed:user": "node ./bin/database/seed-user.js",
+    "db:drop": "node ./bin/database/drop.js",
     "db:migration:create": "knex migrate:make",
     "db:rollback": "knex migrate:rollback",
-    "db:migrate": "knex migrate:latest",
-    "copy-statics": "copyfiles src/**/*.{graphql,json,svg,hbs} dist",
-    "prepack": "yarn build",
-    "prebuild": "rm -rf ./dist"
+    "db:migrate": "node ./bin/database/convert-migrations.js && knex migrate:latest"
   },
   "dependencies": {
-    "@automatisch/web": "^0.10.0",
     "@bull-board/express": "^3.10.1",
     "@casl/ability": "^6.5.0",
     "@graphql-tools/graphql-file-loader": "^7.3.4",
@@ -32,10 +28,6 @@
     "@rudderstack/rudder-sdk-node": "^1.1.2",
     "@sentry/node": "^7.42.0",
     "@sentry/tracing": "^7.42.0",
-    "@types/accounting": "^0.4.2",
-    "@types/luxon": "^2.3.1",
-    "@types/passport": "^1.0.12",
-    "@types/xmlrpc": "^1.3.7",
     "accounting": "^0.4.1",
     "ajv-formats": "^2.1.1",
     "axios": "1.6.0",
@@ -87,26 +79,15 @@
     }
   ],
   "homepage": "https://github.com/automatisch/automatisch#readme",
-  "main": "dist/src/app",
+  "main": "src/server",
   "directories": {
     "bin": "bin",
     "src": "src",
     "test": "__tests__"
   },
   "files": [
-    "dist",
     "bin",
-    "src",
-    "server.js",
-    "server.d.ts",
-    "worker.js",
-    "worker.d.ts",
-    "logger.js",
-    "logger.d.ts",
-    "database.js",
-    "database.d.ts",
-    "database-utils.js",
-    "database-utils.d.ts"
+    "src"
   ],
   "repository": {
     "type": "git",
@@ -116,34 +97,9 @@
     "url": "https://github.com/automatisch/automatisch/issues"
   },
   "devDependencies": {
-    "@automatisch/types": "^0.10.0",
-    "@faker-js/faker": "^8.1.0",
-    "@types/bcrypt": "^5.0.0",
-    "@types/bull": "^3.15.8",
-    "@types/cors": "^2.8.12",
-    "@types/crypto-js": "^4.0.2",
-    "@types/express": "^4.17.15",
-    "@types/http-errors": "^1.8.1",
-    "@types/jest": "^29.5.5",
-    "@types/jsonwebtoken": "^8.5.8",
-    "@types/lodash.get": "^4.4.6",
-    "@types/memory-cache": "^0.2.2",
-    "@types/morgan": "^1.9.3",
-    "@types/multer": "1.4.7",
-    "@types/node": "^16.10.2",
-    "@types/nodemailer": "^6.4.4",
-    "@types/pg": "^8.6.1",
-    "@types/pino": "^7.0.5",
-    "@types/pluralize": "^0.0.30",
-    "@types/showdown": "^2.0.1",
-    "@types/supertest": "^2.0.14",
-    "jest": "^29.7.0",
     "nodemon": "^2.0.13",
-    "sinon": "^11.1.2",
     "supertest": "^6.3.3",
-    "ts-jest": "^29.1.1",
-    "ts-node": "^10.2.1",
-    "ts-node-dev": "^1.1.8"
+    "vitest": "^1.1.3"
   },
   "publishConfig": {
     "access": "public"

packages/backend/server.d.ts

@@ -1 +0,0 @@
-export * from './dist/src/server';

packages/backend/server.js

@@ -1,2 +0,0 @@
-/* eslint-disable */
-module.exports = require('./dist/src/server.js');

packages/backend/src/app.js

@@ -0,0 +1,70 @@
+import createError from 'http-errors';
+import express from 'express';
+import cors from 'cors';
+
+import appConfig from './config/app.js';
+import corsOptions from './config/cors-options.js';
+import morgan from './helpers/morgan.js';
+import * as Sentry from './helpers/sentry.ee.js';
+import appAssetsHandler from './helpers/app-assets-handler.js';
+import webUIHandler from './helpers/web-ui-handler.js';
+import errorHandler from './helpers/error-handler.js';
+import './config/orm.js';
+import {
+  createBullBoardHandler,
+  serverAdapter,
+} from './helpers/create-bull-board-handler.js';
+import injectBullBoardHandler from './helpers/inject-bull-board-handler.js';
+import router from './routes/index.js';
+import configurePassport from './helpers/passport.js';
+
+createBullBoardHandler(serverAdapter);
+
+const app = express();
+
+Sentry.init(app);
+
+Sentry.attachRequestHandler(app);
+Sentry.attachTracingHandler(app);
+
+injectBullBoardHandler(app, serverAdapter);
+
+appAssetsHandler(app);
+
+app.use(morgan);
+
+app.use(
+  express.json({
+    limit: appConfig.requestBodySizeLimit,
+    verify(req, res, buf) {
+      req.rawBody = buf;
+    },
+  })
+);
+app.use(
+  express.urlencoded({
+    extended: true,
+    limit: appConfig.requestBodySizeLimit,
+    verify(req, res, buf) {
+      req.rawBody = buf;
+    },
+  })
+);
+app.use(cors(corsOptions));
+
+configurePassport(app);
+
+app.use('/', router);
+
+webUIHandler(app);
+
+// catch 404 and forward to error handler
+app.use(function (req, res, next) {
+  next(createError(404));
+});
+
+Sentry.attachErrorHandler(app);
+
+app.use(errorHandler);
+
+export default app;

packages/backend/src/app.ts

@@ -1,71 +0,0 @@
-import createError from 'http-errors';
-import express from 'express';
-import cors from 'cors';
-
-import { IRequest } from '@automatisch/types';
-import appConfig from './config/app';
-import corsOptions from './config/cors-options';
-import morgan from './helpers/morgan';
-import * as Sentry from './helpers/sentry.ee';
-import appAssetsHandler from './helpers/app-assets-handler';
-import webUIHandler from './helpers/web-ui-handler';
-import errorHandler from './helpers/error-handler';
-import './config/orm';
-import {
-  createBullBoardHandler,
-  serverAdapter,
-} 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);
-
-const app = express();
-
-Sentry.init(app);
-
-Sentry.attachRequestHandler(app);
-Sentry.attachTracingHandler(app);
-
-injectBullBoardHandler(app, serverAdapter);
-
-appAssetsHandler(app);
-
-app.use(morgan);
-
-app.use(
-  express.json({
-    limit: appConfig.requestBodySizeLimit,
-    verify(req, res, buf) {
-      (req as IRequest).rawBody = buf;
-    },
-  })
-);
-app.use(
-  express.urlencoded({
-    extended: true,
-    limit: appConfig.requestBodySizeLimit,
-    verify(req, res, buf) {
-      (req as IRequest).rawBody = buf;
-    },
-  })
-);
-app.use(cors(corsOptions));
-
-configurePassport(app);
-
-app.use('/', router);
-
-webUIHandler(app);
-
-// catch 404 and forward to error handler
-app.use(function (req, res, next) {
-  next(createError(404));
-});
-
-Sentry.attachErrorHandler(app);
-
-app.use(errorHandler);
-
-export default app;

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

@@ -0,0 +1 @@
+<svg height="255" preserveAspectRatio="xMidYMid" viewBox="0 0 256 255" width="256" xmlns="http://www.w3.org/2000/svg"><path d="m128.636514 155.746615v-155.23361889h-3.522242v.06873152l-124.60824865 64.03287157v60.8642488h.00597665v3.234366h-.00597665v60.868233l124.60824865 64.747082h3.842989v-98.581914z" fill="#ff8e4a"/><path d="m129.941416 254.328529 125.568498-64.747082v-124.9668478l-125.887253-64.10160309h-2.243237v253.81055289h2.243237" fill="#f48746"/><path d="m109.097837 87.2551595h36.19561v59.2077195h-36.19561z" fill="#ff8e4a"/><path d="m66.1735097 188.397074h14.8639378c9.4102412 0 12.6087471-2.238257 15.6189883-9.988981l8.2796572-21.353587h45.159596l8.280653 21.353587c3.011238 7.750724 6.396016 9.988981 15.805261 9.988981h14.677665v-19.114335h-3.011237c-3.19751 0-4.704622-.689307-5.831222-3.790194l-39.516638-99.3658524h-25.779299l-39.703907 99.3658524c-1.1285915 3.100887-2.632716 3.790194-5.833214 3.790194h-3.0102413zm44.4075333-49.939922 11.478163-30.655253c2.445448-6.714771 5.269417-18.2556889 5.269417-18.2556889h.375533s2.822972 11.5409179 5.269416 18.2556889l11.478163 30.655253z" fill="#fff"/><path d="m231.204856 150.082739v-51.8086223c.235082 4.5233303 2.970397 16.8432063 24.305058 27.8512063v11.653479zm0-53.1623343v1.353712c-.029883-.5926848-.01793-1.0479066 0-1.353712zm.041837-.4392841s-.022911.1534008-.041837.4392841v-.4392841z" fill="#d4763c"/><path d="m231.155051 94.3016342c-.013946.9931207.05877 1.8945993.049805 2.0460078-.01793.2480312-2.220327 16.094132 24.305058 29.777681v-60.863253c-23.325883 12.0349884-24.449494 25.7414475-24.354863 29.0395642" fill="#ff8e4a"/></svg>

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

@@ -0,0 +1,44 @@
+import verifyCredentials from './verify-credentials.js';
+import isStillVerified from './is-still-verified.js';
+
+export default {
+  fields: [
+    {
+      key: 'screenName',
+      label: 'Screen Name',
+      type: 'string',
+      required: true,
+      readOnly: false,
+      value: null,
+      placeholder: null,
+      description:
+        'Screen name of your connection to be used on Automatisch UI.',
+      clickToCopy: false,
+    },
+    {
+      key: 'instanceUrl',
+      label: 'Instance URL',
+      type: 'string',
+      required: true,
+      readOnly: false,
+      value: null,
+      placeholder: null,
+      description: 'Your subdomain as https://{yoursubdomain}.airbrake.io',
+      clickToCopy: false,
+    },
+    {
+      key: 'authToken',
+      label: 'Auth Token',
+      type: 'string',
+      required: true,
+      readOnly: false,
+      value: null,
+      placeholder: null,
+      description: 'Airbrake Auth Token of your account.',
+      clickToCopy: false,
+    },
+  ],
+
+  verifyCredentials,
+  isStillVerified,
+};

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

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

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

@@ -0,0 +1,14 @@
+const verifyCredentials = async ($) => {
+  await $.http.get(`/api/v4/projects?key=${$.auth.data.authToken}`, {
+    additionalProperties: {
+      skipAddingAuthToken: true,
+    },
+  });
+
+  await $.auth.set({
+    screenName: $.auth.data.screenName,
+    authToken: $.auth.data.authToken,
+  });
+};
+
+export default verifyCredentials;

packages/backend/src/apps/airbrake/common/add-auth-token.js

@@ -0,0 +1,10 @@
+const addAuthToken = ($, requestConfig) => {
+  if (requestConfig.additionalProperties?.skipAddingAuthToken)
+    return requestConfig;
+
+  requestConfig.url = requestConfig.url + `?key=${$.auth.data.authToken}`;
+
+  return requestConfig;
+};
+
+export default addAuthToken;

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

@@ -0,0 +1,11 @@
+const setBaseUrl = ($, requestConfig) => {
+  const subdomain = $.auth.data.instanceUrl;
+
+  if (subdomain) {
+    requestConfig.baseURL = `https://${subdomain}.airbrake.io`;
+  }
+
+  return requestConfig;
+};
+
+export default setBaseUrl;

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

@@ -0,0 +1,17 @@
+import defineApp from '../../helpers/define-app.js';
+import setBaseUrl from './common/set-base-url.js';
+import auth from './auth/index.js';
+import addAuthToken from './common/add-auth-token.js';
+
+export default defineApp({
+  name: 'Airbrake',
+  key: 'airbrake',
+  iconUrl: '{BASE_URL}/apps/airbrake/assets/favicon.svg',
+  authDocUrl: 'https://automatisch.io/docs/apps/airbrake/connection',
+  supportsConnections: true,
+  baseUrl: 'https://www.airbrake.io',
+  apiBaseUrl: '',
+  primaryColor: 'f58c54',
+  beforeRequest: [setBaseUrl, addAuthToken],
+  auth,
+});

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

@@ -0,0 +1,3 @@
+import sendPrompt from './send-prompt/index.js';
+
+export default [sendPrompt];

packages/backend/src/apps/azure-openai/actions/send-prompt/index.js

@@ -0,0 +1,97 @@
+import defineAction from '../../../../helpers/define-action.js';
+
+const castFloatOrUndefined = (value) => {
+  return value === '' ? undefined : parseFloat(value);
+};
+
+export default defineAction({
+  name: 'Send prompt',
+  key: 'sendPrompt',
+  description: 'Creates a completion for the provided prompt and parameters.',
+  arguments: [
+    {
+      label: 'Prompt',
+      key: 'prompt',
+      type: 'string',
+      required: true,
+      variables: true,
+      description: 'The text to analyze.',
+    },
+    {
+      label: 'Temperature',
+      key: 'temperature',
+      type: 'string',
+      required: false,
+      variables: true,
+      description:
+        'What sampling temperature to use, between 0 and 2. Higher values means the model will take more risks. Try 0.9 for more creative applications, and 0 (argmax sampling) for ones with a well-defined answer. We generally recommend altering this or Top P but not both.',
+    },
+    {
+      label: 'Maximum tokens',
+      key: 'maxTokens',
+      type: 'string',
+      required: false,
+      variables: true,
+      description:
+        'The maximum number of tokens to generate in the completion.',
+    },
+    {
+      label: 'Stop Sequence',
+      key: 'stopSequence',
+      type: 'string',
+      required: false,
+      variables: true,
+      description:
+        'Single stop sequence where the API will stop generating further tokens. The returned text will not contain the stop sequence.',
+    },
+    {
+      label: 'Top P',
+      key: 'topP',
+      type: 'string',
+      required: false,
+      variables: true,
+      description:
+        'An alternative to sampling with temperature, called nucleus sampling, where the model considers the results of the tokens with top_p probability mass. So 0.1 means only the tokens comprising the top 10% probability mass are considered. We generally recommend altering this or temperature but not both.',
+    },
+    {
+      label: 'Frequency Penalty',
+      key: 'frequencyPenalty',
+      type: 'string',
+      required: false,
+      variables: true,
+      description: `Number between -2.0 and 2.0. Positive values penalize new tokens based on their existing frequency in the text so far, decreasing the model's likelihood to repeat the same line verbatim.`,
+    },
+    {
+      label: 'Presence Penalty',
+      key: 'presencePenalty',
+      type: 'string',
+      required: false,
+      variables: true,
+      description: `Number between -2.0 and 2.0. Positive values penalize new tokens based on whether they appear in the text so far, increasing the model's likelihood to talk about new topics.`,
+    },
+  ],
+
+  async run($) {
+    const payload = {
+      model: $.step.parameters.model,
+      prompt: $.step.parameters.prompt,
+      temperature: castFloatOrUndefined($.step.parameters.temperature),
+      max_tokens: castFloatOrUndefined($.step.parameters.maxTokens),
+      stop: $.step.parameters.stopSequence || null,
+      top_p: castFloatOrUndefined($.step.parameters.topP),
+      frequency_penalty: castFloatOrUndefined(
+        $.step.parameters.frequencyPenalty
+      ),
+      presence_penalty: castFloatOrUndefined($.step.parameters.presencePenalty),
+    };
+
+    const { data } = await $.http.post(
+      `/deployments/${$.auth.data.deploymentId}/completions`,
+      payload
+    );
+
+    $.setActionItem({
+      raw: data,
+    });
+  },
+});

packages/backend/src/apps/azure-openai/assets/favicon.svg

@@ -0,0 +1,6 @@
+<svg width="256px" height="260px" viewBox="0 0 256 260" version="1.1" xmlns="http://www.w3.org/2000/svg" xmlns:xlink="http://www.w3.org/1999/xlink" preserveAspectRatio="xMidYMid">
+    <title>OpenAI</title>
+    <g>
+        <path d="M239.183914,106.202783 C245.054304,88.5242096 243.02228,69.1733805 233.607599,53.0998864 C219.451678,28.4588021 190.999703,15.7836129 163.213007,21.739505 C147.554077,4.32145883 123.794909,-3.42398554 100.87901,1.41873898 C77.9631105,6.26146349 59.3690093,22.9572536 52.0959621,45.2214219 C33.8436494,48.9644867 18.0901721,60.392749 8.86672513,76.5818033 C-5.443491,101.182962 -2.19544431,132.215255 16.8986662,153.320094 C11.0060865,170.990656 13.0197283,190.343991 22.4238231,206.422991 C36.5975553,231.072344 65.0680342,243.746566 92.8695738,237.783372 C105.235639,251.708249 123.001113,259.630942 141.623968,259.52692 C170.105359,259.552169 195.337611,241.165718 204.037777,214.045661 C222.28734,210.296356 238.038489,198.869783 247.267014,182.68528 C261.404453,158.127515 258.142494,127.262775 239.183914,106.202783 L239.183914,106.202783 Z M141.623968,242.541207 C130.255682,242.559177 119.243876,238.574642 110.519381,231.286197 L112.054146,230.416496 L163.724595,200.590881 C166.340648,199.056444 167.954321,196.256818 167.970781,193.224005 L167.970781,120.373788 L189.815614,133.010026 C190.034132,133.121423 190.186235,133.330564 190.224885,133.572774 L190.224885,193.940229 C190.168603,220.758427 168.442166,242.484864 141.623968,242.541207 Z M37.1575749,197.93062 C31.456498,188.086359 29.4094818,176.546984 31.3766237,165.342426 L32.9113895,166.263285 L84.6329973,196.088901 C87.2389349,197.618207 90.4682717,197.618207 93.0742093,196.088901 L156.255402,159.663793 L156.255402,184.885111 C156.243557,185.149771 156.111725,185.394602 155.89729,185.550176 L103.561776,215.733903 C80.3054953,229.131632 50.5924954,221.165435 37.1575749,197.93062 Z M23.5493181,85.3811273 C29.2899861,75.4733097 38.3511911,67.9162648 49.1287482,64.0478825 L49.1287482,125.438515 C49.0891492,128.459425 50.6965386,131.262556 53.3237748,132.754232 L116.198014,169.025864 L94.3531808,181.662102 C94.1132325,181.789434 93.8257461,181.789434 93.5857979,181.662102 L41.3526015,151.529534 C18.1419426,138.076098 10.1817681,108.385562 23.5493181,85.125333 L23.5493181,85.3811273 Z M203.0146,127.075598 L139.935725,90.4458545 L161.7294,77.8607748 C161.969348,77.7334434 162.256834,77.7334434 162.496783,77.8607748 L214.729979,108.044502 C231.032329,117.451747 240.437294,135.426109 238.871504,154.182739 C237.305714,172.939368 225.050719,189.105572 207.414262,195.67963 L207.414262,134.288998 C207.322521,131.276867 205.650697,128.535853 203.0146,127.075598 Z M224.757116,94.3850867 L223.22235,93.4642272 L171.60306,63.3828173 C168.981293,61.8443751 165.732456,61.8443751 163.110689,63.3828173 L99.9806554,99.8079259 L99.9806554,74.5866077 C99.9533004,74.3254088 100.071095,74.0701869 100.287609,73.9215426 L152.520805,43.7889738 C168.863098,34.3743518 189.174256,35.2529043 204.642579,46.0434841 C220.110903,56.8340638 227.949269,75.5923959 224.757116,94.1804513 L224.757116,94.3850867 Z M88.0606409,139.097931 L66.2158076,126.512851 C65.9950399,126.379091 65.8450965,126.154176 65.8065367,125.898945 L65.8065367,65.684966 C65.8314495,46.8285367 76.7500605,29.6846032 93.8270852,21.6883055 C110.90411,13.6920079 131.063833,16.2835462 145.5632,28.338998 L144.028434,29.2086986 L92.3579852,59.0343142 C89.7419327,60.5687513 88.1282597,63.3683767 88.1117998,66.4011901 L88.0606409,139.097931 Z M99.9294965,113.5185 L128.06687,97.3011417 L156.255402,113.5185 L156.255402,145.953218 L128.169187,162.170577 L99.9806554,145.953218 L99.9294965,113.5185 Z" fill="#000000"></path>
+    </g>
+</svg>

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

@@ -0,0 +1,58 @@
+import verifyCredentials from './verify-credentials.js';
+import isStillVerified from './is-still-verified.js';
+
+export default {
+  fields: [
+    {
+      key: 'screenName',
+      label: 'Screen Name',
+      type: 'string',
+      required: true,
+      readOnly: false,
+      value: null,
+      placeholder: null,
+      description:
+        'Screen name of your connection to be used on Automatisch UI.',
+      clickToCopy: false,
+    },
+    {
+      key: 'yourResourceName',
+      label: 'Your Resource Name',
+      type: 'string',
+      required: true,
+      readOnly: false,
+      value: null,
+      placeholder: null,
+      description: 'The name of your Azure OpenAI Resource.',
+      docUrl: 'https://automatisch.io/docs/azure-openai#your-resource-name',
+      clickToCopy: false,
+    },
+    {
+      key: 'deploymentId',
+      label: 'Deployment ID',
+      type: 'string',
+      required: true,
+      readOnly: false,
+      value: null,
+      placeholder: null,
+      description: 'The deployment name you chose when you deployed the model.',
+      docUrl: 'https://automatisch.io/docs/azure-openai#deployment-id',
+      clickToCopy: false,
+    },
+    {
+      key: 'apiKey',
+      label: 'API Key',
+      type: 'string',
+      required: true,
+      readOnly: false,
+      value: null,
+      placeholder: null,
+      description: 'Azure OpenAI API key of your account.',
+      docUrl: 'https://automatisch.io/docs/azure-openai#api-key',
+      clickToCopy: false,
+    },
+  ],
+
+  verifyCredentials,
+  isStillVerified,
+};

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

@@ -0,0 +1,6 @@
+const isStillVerified = async ($) => {
+  await $.http.get('/fine_tuning/jobs');
+  return true;
+};
+
+export default isStillVerified;

packages/backend/src/apps/azure-openai/auth/verify-credentials.js

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

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

@@ -0,0 +1,13 @@
+const addAuthHeader = ($, requestConfig) => {
+  if ($.auth.data?.apiKey) {
+    requestConfig.headers['api-key'] = $.auth.data.apiKey;
+  }
+
+  requestConfig.params = {
+    'api-version': '2023-10-01-preview',
+  };
+
+  return requestConfig;
+};
+
+export default addAuthHeader;

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

@@ -0,0 +1,11 @@
+const setBaseUrl = ($, requestConfig) => {
+  const yourResourceName = $.auth.data.yourResourceName;
+
+  if (yourResourceName) {
+    requestConfig.baseURL = `https://${yourResourceName}.openai.azure.com/openai`;
+  }
+
+  return requestConfig;
+};
+
+export default setBaseUrl;

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

@@ -0,0 +1,20 @@
+import defineApp from '../../helpers/define-app.js';
+import setBaseUrl from './common/set-base-url.js';
+import addAuthHeader from './common/add-auth-header.js';
+import auth from './auth/index.js';
+import actions from './actions/index.js';
+
+export default defineApp({
+  name: 'Azure OpenAI',
+  key: 'azure-openai',
+  baseUrl:
+    'https://azure.microsoft.com/en-us/products/ai-services/openai-service',
+  apiBaseUrl: '',
+  iconUrl: '{BASE_URL}/apps/azure-openai/assets/favicon.svg',
+  authDocUrl: 'https://automatisch.io/docs/apps/azure-openai/connection',
+  primaryColor: '000000',
+  supportsConnections: true,
+  beforeRequest: [setBaseUrl, addAuthHeader],
+  auth,
+  actions,
+});

packages/backend/src/apps/carbone/actions/add-template/index.js

@@ -0,0 +1,35 @@
+import defineAction from '../../../../helpers/define-action.js';
+
+export default defineAction({
+  name: 'Add Template',
+  key: 'addTemplate',
+  description:
+    'Creates an attachment of a specified object by given parent ID.',
+  arguments: [
+    {
+      label: 'Templete Data',
+      key: 'templateData',
+      type: 'string',
+      required: true,
+      variables: true,
+      description: 'The content of your new Template in XML/HTML format.',
+    },
+  ],
+
+  async run($) {
+    const templateData = $.step.parameters.templateData;
+
+    const base64Data = Buffer.from(templateData).toString('base64');
+    const dataURI = `data:application/xml;base64,${base64Data}`;
+
+    const body = JSON.stringify({ template: dataURI });
+
+    const response = await $.http.post('/template', body, {
+      headers: {
+        'Content-Type': 'application/json',
+      },
+    });
+
+    $.setActionItem({ raw: response.data });
+  },
+});

packages/backend/src/apps/carbone/actions/add-template/index.ts

@@ -1,35 +0,0 @@
-import defineAction from '../../../../helpers/define-action';
-
-export default defineAction({
-  name: 'Add Template',
-  key: 'addTemplate',
-  description:
-    'Creates an attachment of a specified object by given parent ID.',
-  arguments: [
-    {
-      label: 'Templete Data',
-      key: 'templateData',
-      type: 'string' as const,
-      required: true,
-      variables: true,
-      description: 'The content of your new Template in XML/HTML format.',
-    },
-  ],
-
-  async run($) {
-    const templateData = $.step.parameters.templateData as string;
-
-    const base64Data = Buffer.from(templateData).toString('base64');
-    const dataURI = `data:application/xml;base64,${base64Data}`;
-
-    const body = JSON.stringify({ template: dataURI });
-
-    const response = await $.http.post('/template', body, {
-      headers: {
-        'Content-Type': 'application/json',
-      },
-    });
-
-    $.setActionItem({ raw: response.data });
-  },
-});

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

@@ -0,0 +1,3 @@
+import addTemplate from './add-template/index.js';
+
+export default [addTemplate];

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

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

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

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

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

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

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

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

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

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

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

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

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

@@ -1,12 +0,0 @@
-import { IGlobalVariable } from '@automatisch/types';
-
-const verifyCredentials = async ($: IGlobalVariable) => {
-  await $.http.get('/templates');
-
-  await $.auth.set({
-    screenName: $.auth.data.screenName,
-    apiKey: $.auth.data.apiKey,
-  });
-};
-
-export default verifyCredentials;

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

@@ -0,0 +1,10 @@
+const addAuthHeader = ($, requestConfig) => {
+  if ($.auth.data?.apiKey) {
+    requestConfig.headers.Authorization = `Bearer ${$.auth.data.apiKey}`;
+    requestConfig.headers['carbone-version'] = '4';
+  }
+
+  return requestConfig;
+};
+
+export default addAuthHeader;

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

@@ -1,12 +0,0 @@
-import { TBeforeRequest } from '@automatisch/types';
-
-const addAuthHeader: TBeforeRequest = ($, requestConfig) => {
-  if ($.auth.data?.apiKey) {
-    requestConfig.headers.Authorization = `Bearer ${$.auth.data.apiKey}`;
-    requestConfig.headers['carbone-version'] = '4';
-  }
-
-  return requestConfig;
-};
-
-export default addAuthHeader;

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

@@ -0,0 +1,18 @@
+import defineApp from '../../helpers/define-app.js';
+import addAuthHeader from './common/add-auth-header.js';
+import auth from './auth/index.js';
+import actions from './actions/index.js';
+
+export default defineApp({
+  name: 'Carbone',
+  key: 'carbone',
+  iconUrl: '{BASE_URL}/apps/carbone/assets/favicon.svg',
+  authDocUrl: 'https://automatisch.io/docs/apps/carbone/connection',
+  supportsConnections: true,
+  baseUrl: 'https://carbone.io',
+  apiBaseUrl: 'https://api.carbone.io',
+  primaryColor: '6f42c1',
+  beforeRequest: [addAuthHeader],
+  auth,
+  actions,
+});

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

@@ -1,18 +0,0 @@
-import defineApp from '../../helpers/define-app';
-import addAuthHeader from './common/add-auth-header';
-import auth from './auth';
-import actions from './actions';
-
-export default defineApp({
-  name: 'Carbone',
-  key: 'carbone',
-  iconUrl: '{BASE_URL}/apps/carbone/assets/favicon.svg',
-  authDocUrl: 'https://automatisch.io/docs/apps/carbone/connection',
-  supportsConnections: true,
-  baseUrl: 'https://carbone.io',
-  apiBaseUrl: 'https://api.carbone.io',
-  primaryColor: '6f42c1',
-  beforeRequest: [addAuthHeader],
-  auth,
-  actions,
-});

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

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

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

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

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

@@ -0,0 +1,77 @@
+import qs from 'qs';
+import defineAction from '../../../../helpers/define-action.js';
+
+export default defineAction({
+  name: 'Translate text',
+  key: 'translateText',
+  description: 'Translates text from one language to another.',
+  arguments: [
+    {
+      label: 'Text',
+      key: 'text',
+      type: 'string',
+      required: true,
+      description: 'Text to be translated.',
+      variables: true,
+    },
+    {
+      label: 'Target Language',
+      key: 'targetLanguage',
+      type: 'dropdown',
+      required: true,
+      description: 'Language to translate the text to.',
+      variables: true,
+      value: '',
+      options: [
+        { label: 'Bulgarian', value: 'BG' },
+        { label: 'Chinese (simplified)', value: 'ZH' },
+        { label: 'Czech', value: 'CS' },
+        { label: 'Danish', value: 'DA' },
+        { label: 'Dutch', value: 'NL' },
+        { label: 'English', value: 'EN' },
+        { label: 'English (American)', value: 'EN-US' },
+        { label: 'English (British)', value: 'EN-GB' },
+        { label: 'Estonian', value: 'ET' },
+        { label: 'Finnish', value: 'FI' },
+        { label: 'French', value: 'FR' },
+        { label: 'German', value: 'DE' },
+        { label: 'Greek', value: 'EL' },
+        { label: 'Hungarian', value: 'HU' },
+        { label: 'Indonesian', value: 'ID' },
+        { label: 'Italian', value: 'IT' },
+        { label: 'Japanese', value: 'JA' },
+        { label: 'Latvian', value: 'LV' },
+        { label: 'Lithuanian', value: 'LT' },
+        { label: 'Polish', value: 'PL' },
+        { label: 'Portuguese', value: 'PT' },
+        { label: 'Portuguese (Brazilian)', value: 'PT-BR' },
+        {
+          label:
+            'Portuguese (all Portuguese varieties excluding Brazilian Portuguese)',
+          value: 'PT-PT',
+        },
+        { label: 'Romanian', value: 'RO' },
+        { label: 'Russian', value: 'RU' },
+        { label: 'Slovak', value: 'SK' },
+        { label: 'Slovenian', value: 'SL' },
+        { label: 'Spanish', value: 'ES' },
+        { label: 'Swedish', value: 'SV' },
+        { label: 'Turkish', value: 'TR' },
+        { label: 'Ukrainian', value: 'UK' },
+      ],
+    },
+  ],
+
+  async run($) {
+    const stringifiedBody = qs.stringify({
+      text: $.step.parameters.text,
+      target_lang: $.step.parameters.targetLanguage,
+    });
+
+    const response = await $.http.post('/v2/translate', stringifiedBody);
+
+    $.setActionItem({
+      raw: response.data,
+    });
+  },
+});

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

@@ -1,77 +0,0 @@
-import qs from 'qs';
-import defineAction from '../../../../helpers/define-action';
-
-export default defineAction({
-  name: 'Translate text',
-  key: 'translateText',
-  description: 'Translates text from one language to another.',
-  arguments: [
-    {
-      label: 'Text',
-      key: 'text',
-      type: 'string' as const,
-      required: true,
-      description: 'Text to be translated.',
-      variables: true,
-    },
-    {
-      label: 'Target Language',
-      key: 'targetLanguage',
-      type: 'dropdown' as const,
-      required: true,
-      description: 'Language to translate the text to.',
-      variables: true,
-      value: '',
-      options: [
-        { label: 'Bulgarian', value: 'BG' },
-        { label: 'Chinese (simplified)', value: 'ZH' },
-        { label: 'Czech', value: 'CS' },
-        { label: 'Danish', value: 'DA' },
-        { label: 'Dutch', value: 'NL' },
-        { label: 'English', value: 'EN' },
-        { label: 'English (American)', value: 'EN-US' },
-        { label: 'English (British)', value: 'EN-GB' },
-        { label: 'Estonian', value: 'ET' },
-        { label: 'Finnish', value: 'FI' },
-        { label: 'French', value: 'FR' },
-        { label: 'German', value: 'DE' },
-        { label: 'Greek', value: 'EL' },
-        { label: 'Hungarian', value: 'HU' },
-        { label: 'Indonesian', value: 'ID' },
-        { label: 'Italian', value: 'IT' },
-        { label: 'Japanese', value: 'JA' },
-        { label: 'Latvian', value: 'LV' },
-        { label: 'Lithuanian', value: 'LT' },
-        { label: 'Polish', value: 'PL' },
-        { label: 'Portuguese', value: 'PT' },
-        { label: 'Portuguese (Brazilian)', value: 'PT-BR' },
-        {
-          label:
-            'Portuguese (all Portuguese varieties excluding Brazilian Portuguese)',
-          value: 'PT-PT',
-        },
-        { label: 'Romanian', value: 'RO' },
-        { label: 'Russian', value: 'RU' },
-        { label: 'Slovak', value: 'SK' },
-        { label: 'Slovenian', value: 'SL' },
-        { label: 'Spanish', value: 'ES' },
-        { label: 'Swedish', value: 'SV' },
-        { label: 'Turkish', value: 'TR' },
-        { label: 'Ukrainian', value: 'UK' },
-      ],
-    },
-  ],
-
-  async run($) {
-    const stringifiedBody = qs.stringify({
-      text: $.step.parameters.text,
-      target_lang: $.step.parameters.targetLanguage,
-    });
-
-    const response = await $.http.post('/v2/translate', stringifiedBody);
-
-    $.setActionItem({
-      raw: response.data,
-    });
-  },
-});

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

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

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

@@ -1,33 +0,0 @@
-import verifyCredentials from './verify-credentials';
-import isStillVerified from './is-still-verified';
-
-export default {
-  fields: [
-    {
-      key: 'screenName',
-      label: 'Screen Name',
-      type: 'string' as const,
-      required: true,
-      readOnly: false,
-      value: null,
-      placeholder: null,
-      description:
-        'Screen name of your connection to be used on Automatisch UI.',
-      clickToCopy: false,
-    },
-    {
-      key: 'authenticationKey',
-      label: 'Authentication Key',
-      type: 'string' as const,
-      required: true,
-      readOnly: false,
-      value: null,
-      placeholder: null,
-      description: 'DeepL authentication key of your account.',
-      clickToCopy: false,
-    },
-  ],
-
-  verifyCredentials,
-  isStillVerified,
-};

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

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

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

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

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

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

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

@@ -1,11 +0,0 @@
-import { IGlobalVariable } from '@automatisch/types';
-
-const verifyCredentials = async ($: IGlobalVariable) => {
-  await $.http.get('/v2/usage');
-
-  await $.auth.set({
-    screenName: $.auth.data.screenName,
-  });
-};
-
-export default verifyCredentials;

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

@@ -0,0 +1,10 @@
+const addAuthHeader = ($, requestConfig) => {
+  if ($.auth.data?.authenticationKey) {
+    const authorizationHeader = `DeepL-Auth-Key ${$.auth.data.authenticationKey}`;
+    requestConfig.headers.Authorization = authorizationHeader;
+  }
+
+  return requestConfig;
+};
+
+export default addAuthHeader;

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

@@ -1,12 +0,0 @@
-import { TBeforeRequest } from '@automatisch/types';
-
-const addAuthHeader: TBeforeRequest = ($, requestConfig) => {
-  if ($.auth.data?.authenticationKey) {
-    const authorizationHeader = `DeepL-Auth-Key ${$.auth.data.authenticationKey}`;
-    requestConfig.headers.Authorization = authorizationHeader;
-  }
-
-  return requestConfig;
-};
-
-export default addAuthHeader;

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

@@ -0,0 +1,18 @@
+import defineApp from '../../helpers/define-app.js';
+import addAuthHeader from './common/add-auth-header.js';
+import auth from './auth/index.js';
+import actions from './actions/index.js';
+
+export default defineApp({
+  name: 'DeepL',
+  key: 'deepl',
+  iconUrl: '{BASE_URL}/apps/deepl/assets/favicon.svg',
+  authDocUrl: 'https://automatisch.io/docs/apps/deepl/connection',
+  supportsConnections: true,
+  baseUrl: 'https://deepl.com',
+  apiBaseUrl: 'https://api.deepl.com',
+  primaryColor: '0d2d45',
+  beforeRequest: [addAuthHeader],
+  auth,
+  actions,
+});

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

@@ -1,18 +0,0 @@
-import defineApp from '../../helpers/define-app';
-import addAuthHeader from './common/add-auth-header';
-import auth from './auth';
-import actions from './actions';
-
-export default defineApp({
-  name: 'DeepL',
-  key: 'deepl',
-  iconUrl: '{BASE_URL}/apps/deepl/assets/favicon.svg',
-  authDocUrl: 'https://automatisch.io/docs/apps/deepl/connection',
-  supportsConnections: true,
-  baseUrl: 'https://deepl.com',
-  apiBaseUrl: 'https://api.deepl.com',
-  primaryColor: '0d2d45',
-  beforeRequest: [addAuthHeader],
-  auth,
-  actions,
-});

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

@@ -0,0 +1,56 @@
+import defineAction from '../../../../helpers/define-action.js';
+
+export default defineAction({
+  name: 'Delay for',
+  key: 'delayFor',
+  description:
+    'Delays the execution of the next action by a specified amount of time.',
+  arguments: [
+    {
+      label: 'Delay for unit',
+      key: 'delayForUnit',
+      type: 'dropdown',
+      required: true,
+      value: null,
+      description: 'Delay for unit, e.g. minutes, hours, days, weeks.',
+      variables: true,
+      options: [
+        {
+          label: 'Minutes',
+          value: 'minutes',
+        },
+        {
+          label: 'Hours',
+          value: 'hours',
+        },
+        {
+          label: 'Days',
+          value: 'days',
+        },
+        {
+          label: 'Weeks',
+          value: 'weeks',
+        },
+      ],
+    },
+    {
+      label: 'Delay for value',
+      key: 'delayForValue',
+      type: 'string',
+      required: true,
+      description: 'Delay for value, use a number, e.g. 1, 2, 3.',
+      variables: true,
+    },
+  ],
+
+  async run($) {
+    const { delayForUnit, delayForValue } = $.step.parameters;
+
+    const dataItem = {
+      delayForUnit,
+      delayForValue,
+    };
+
+    $.setActionItem({ raw: dataItem });
+  },
+});

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

@@ -1,56 +0,0 @@
-import defineAction from '../../../../helpers/define-action';
-
-export default defineAction({
-  name: 'Delay for',
-  key: 'delayFor',
-  description:
-    'Delays the execution of the next action by a specified amount of time.',
-  arguments: [
-    {
-      label: 'Delay for unit',
-      key: 'delayForUnit',
-      type: 'dropdown' as const,
-      required: true,
-      value: null,
-      description: 'Delay for unit, e.g. minutes, hours, days, weeks.',
-      variables: true,
-      options: [
-        {
-          label: 'Minutes',
-          value: 'minutes',
-        },
-        {
-          label: 'Hours',
-          value: 'hours',
-        },
-        {
-          label: 'Days',
-          value: 'days',
-        },
-        {
-          label: 'Weeks',
-          value: 'weeks',
-        },
-      ],
-    },
-    {
-      label: 'Delay for value',
-      key: 'delayForValue',
-      type: 'string' as const,
-      required: true,
-      description: 'Delay for value, use a number, e.g. 1, 2, 3.',
-      variables: true,
-    },
-  ],
-
-  async run($) {
-    const { delayForUnit, delayForValue } = $.step.parameters;
-
-    const dataItem = {
-      delayForUnit,
-      delayForValue,
-    };
-
-    $.setActionItem({ raw: dataItem });
-  },
-});

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

@@ -0,0 +1,28 @@
+import defineAction from '../../../../helpers/define-action.js';
+
+export default defineAction({
+  name: 'Delay until',
+  key: 'delayUntil',
+  description:
+    'Delays the execution of the next action until a specified date.',
+  arguments: [
+    {
+      label: 'Delay until (Date)',
+      key: 'delayUntil',
+      type: 'string',
+      required: true,
+      description: 'Delay until the date. E.g. 2022-12-18',
+      variables: true,
+    },
+  ],
+
+  async run($) {
+    const { delayUntil } = $.step.parameters;
+
+    const dataItem = {
+      delayUntil,
+    };
+
+    $.setActionItem({ raw: dataItem });
+  },
+});

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

@@ -1,28 +0,0 @@
-import defineAction from '../../../../helpers/define-action';
-
-export default defineAction({
-  name: 'Delay until',
-  key: 'delayUntil',
-  description:
-    'Delays the execution of the next action until a specified date.',
-  arguments: [
-    {
-      label: 'Delay until (Date)',
-      key: 'delayUntil',
-      type: 'string' as const,
-      required: true,
-      description: 'Delay until the date. E.g. 2022-12-18',
-      variables: true,
-    },
-  ],
-
-  async run($) {
-    const { delayUntil } = $.step.parameters;
-
-    const dataItem = {
-      delayUntil,
-    };
-
-    $.setActionItem({ raw: dataItem });
-  },
-});

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

@@ -0,0 +1,4 @@
+import delayFor from './delay-for/index.js';
+import delayUntil from './delay-until/index.js';
+
+export default [delayFor, delayUntil];

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

@@ -1,4 +0,0 @@
-import delayFor from './delay-for';
-import delayUntil from './delay-until';
-
-export default [delayFor, delayUntil];

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

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

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

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

packages/backend/src/apps/discord/actions/create-scheduled-event/index.js

@@ -0,0 +1,88 @@
+import defineAction from '../../../../helpers/define-action.js';
+
+export default defineAction({
+  name: 'Create a scheduled event',
+  key: 'createScheduledEvent',
+  description: 'Creates a scheduled event',
+  arguments: [
+    {
+      label: 'Type',
+      key: 'entityType',
+      type: 'dropdown',
+      required: true,
+      variables: true,
+      options: [
+        { label: 'Stage channel', value: 1 },
+        { label: 'Voice channel', value: 2 },
+        { label: 'External', value: 3 },
+      ],
+      additionalFields: {
+        type: 'query',
+        name: 'getDynamicFields',
+        arguments: [
+          {
+            name: 'key',
+            value: 'listExternalScheduledEventFields',
+          },
+          {
+            name: 'parameters.entityType',
+            value: '{parameters.entityType}',
+          },
+        ],
+      },
+    },
+    {
+      label: 'Name',
+      key: 'name',
+      type: 'string',
+      required: true,
+      variables: true,
+    },
+    {
+      label: 'Description',
+      key: 'description',
+      type: 'string',
+      required: false,
+      variables: true,
+    },
+    {
+      label: 'Image',
+      key: 'image',
+      type: 'string',
+      required: false,
+      description:
+        'Image as DataURI scheme [data:image/<jpeg/png/gif>;base64,BASE64_ENCODED_<JPEG/PNG/GIF>_IMAGE_DATA]',
+      variables: true,
+    },
+  ],
+
+  async run($) {
+    const data = {
+      channel_id: $.step.parameters.channel_id,
+      name: $.step.parameters.name,
+      privacy_level: 2,
+      scheduled_start_time: $.step.parameters.scheduledStartTime,
+      scheduled_end_time: $.step.parameters.scheduledEndTime,
+      description: $.step.parameters.description,
+      entity_type: $.step.parameters.entityType,
+      image: $.step.parameters.image,
+    };
+
+    const isExternal = $.step.parameters.entityType === 3;
+
+    if (isExternal) {
+      data.entity_metadata = {
+        location: $.step.parameters.location,
+      };
+
+      data.channel_id = null;
+    }
+
+    const response = await $.http?.post(
+      `/guilds/${$.auth.data.guildId}/scheduled-events`,
+      data
+    );
+
+    $.setActionItem({ raw: response.data });
+  },
+});

packages/backend/src/apps/discord/actions/create-scheduled-event/index.ts

@@ -1,102 +0,0 @@
-import defineAction from '../../../../helpers/define-action';
-
-export default defineAction({
-  name: 'Create a scheduled event',
-  key: 'createScheduledEvent',
-  description: 'Creates a scheduled event',
-  arguments: [
-    {
-      label: 'Type',
-      key: 'entityType',
-      type: 'dropdown' as const,
-      required: true,
-      variables: true,
-      options: [
-        { label: 'Stage channel', value: 1 },
-        { label: 'Voice channel', value: 2 },
-        { label: 'External', value: 3 }
-      ],
-      additionalFields: {
-        type: 'query',
-        name: 'getDynamicFields',
-        arguments: [
-          {
-            name: 'key',
-            value: 'listExternalScheduledEventFields',
-          },
-          {
-            name: 'parameters.entityType',
-            value: '{parameters.entityType}',
-          },
-        ],
-      },
-    },
-    {
-      label: 'Name',
-      key: 'name',
-      type: 'string' as const,
-      required: true,
-      variables: true,
-    },
-    {
-      label: 'Description',
-      key: 'description',
-      type: 'string' as const,
-      required: false,
-      variables: true,
-    },
-    {
-      label: 'Image',
-      key: 'image',
-      type: 'string' as const,
-      required: false,
-      description: 'Image as DataURI scheme [data:image/<jpeg/png/gif>;base64,BASE64_ENCODED_<JPEG/PNG/GIF>_IMAGE_DATA]',
-      variables: true,
-    },
-  ],
-
-  async run($) {
-    type entity_metadata = {
-      location: string
-    }
-
-    type guild_event = {
-      channel_id: number,
-      name: string,
-      privacy_level: number,
-      scheduled_start_time: string,
-      scheduled_end_time?: string,
-      description?: string,
-      entity_type?: number,
-      entity_metadata?: entity_metadata,
-      image?: string, //data:image/jpeg;base64,BASE64_ENCODED_JPEG_IMAGE_DATA
-    }
-
-
-    const data: guild_event = {
-      channel_id: $.step.parameters.channel_id as number,
-      name: $.step.parameters.name as string,
-      privacy_level: 2,
-      scheduled_start_time: $.step.parameters.scheduledStartTime as string,
-      scheduled_end_time: $.step.parameters.scheduledEndTime as string,
-      description: $.step.parameters.description as string,
-      entity_type: $.step.parameters.entityType as number,
-      image: $.step.parameters.image as string,
-    };
-
-    const isExternal = $.step.parameters.entityType === 3;
-    if (isExternal) {
-      data.entity_metadata = {
-        location: $.step.parameters.location as string,
-      };
-      data.channel_id = null;
-    }
-
-    const response = await $.http?.post(
-      `/guilds/${$.auth.data.guildId}/scheduled-events`,
-      data
-    );
-
-    $.setActionItem({ raw: response.data });
-  },
-});

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

@@ -0,0 +1,4 @@
+import sendMessageToChannel from './send-message-to-channel/index.js';
+import createScheduledEvent from './create-scheduled-event/index.js';
+
+export default [sendMessageToChannel, createScheduledEvent];

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

@@ -1,4 +0,0 @@
-import sendMessageToChannel from './send-message-to-channel';
-import createScheduledEvent from './create-scheduled-event';
-
-export default [sendMessageToChannel, createScheduledEvent];

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

@@ -0,0 +1,48 @@
+import defineAction from '../../../../helpers/define-action.js';
+
+export default defineAction({
+  name: 'Send a message to channel',
+  key: 'sendMessageToChannel',
+  description: 'Sends a message to a specific channel you specify.',
+  arguments: [
+    {
+      label: 'Channel',
+      key: 'channel',
+      type: 'dropdown',
+      required: true,
+      description: 'Pick a channel to send the message to.',
+      variables: true,
+      source: {
+        type: 'query',
+        name: 'getDynamicData',
+        arguments: [
+          {
+            name: 'key',
+            value: 'listChannels',
+          },
+        ],
+      },
+    },
+    {
+      label: 'Message text',
+      key: 'message',
+      type: 'string',
+      required: true,
+      description: 'The content of your new message.',
+      variables: true,
+    },
+  ],
+
+  async run($) {
+    const data = {
+      content: $.step.parameters.message,
+    };
+
+    const response = await $.http?.post(
+      `/channels/${$.step.parameters.channel}/messages`,
+      data
+    );
+
+    $.setActionItem({ raw: response.data });
+  },
+});

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

@@ -1,47 +0,0 @@
-import defineAction from '../../../../helpers/define-action';
-
-export default defineAction({
-  name: 'Send a message to channel',
-  key: 'sendMessageToChannel',
-  description: 'Sends a message to a specific channel you specify.',
-  arguments: [
-    {
-      label: 'Channel',
-      key: 'channel',
-      type: 'dropdown' as const,
-      required: true,
-      description: 'Pick a channel to send the message to.',
-      variables: true,
-      source: {
-        type: 'query',
-        name: 'getDynamicData',
-        arguments: [
-          {
-            name: 'key',
-            value: 'listChannels',
-          },
-        ],
-      },
-    },
-    {
-      label: 'Message text',
-      key: 'message',
-      type: 'string' as const,
-      required: true,
-      description: 'The content of your new message.',
-      variables: true,
-    },
-  ],
-
-  async run($) {
-    const data = {
-      content: $.step.parameters.message as string,
-    };
-    const response = await $.http?.post(
-      `/channels/${$.step.parameters.channel}/messages`,
-      data
-    );
-
-    $.setActionItem({ raw: response.data });
-  },
-});

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

@@ -0,0 +1,22 @@
+import { URLSearchParams } from 'url';
+import scopes from '../common/scopes.js';
+
+export default async function generateAuthUrl($) {
+  const oauthRedirectUrlField = $.app.auth.fields.find(
+    (field) => field.key == 'oAuthRedirectUrl'
+  );
+
+  const callbackUrl = oauthRedirectUrlField.value;
+
+  const searchParams = new URLSearchParams({
+    client_id: $.auth.data.consumerKey,
+    redirect_uri: callbackUrl,
+    response_type: 'code',
+    permissions: '2146958591',
+    scope: scopes.join(' '),
+  });
+
+  const url = `${$.app.apiBaseUrl}/oauth2/authorize?${searchParams.toString()}`;
+
+  await $.auth.set({ url });
+}

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

@@ -1,22 +0,0 @@
-import { IField, IGlobalVariable } from '@automatisch/types';
-import { URLSearchParams } from 'url';
-import scopes from '../common/scopes';
-
-export default async function generateAuthUrl($: IGlobalVariable) {
-  const oauthRedirectUrlField = $.app.auth.fields.find(
-    (field: IField) => field.key == 'oAuthRedirectUrl'
-  );
-  const callbackUrl = oauthRedirectUrlField.value as string;
-
-  const searchParams = new URLSearchParams({
-    client_id: $.auth.data.consumerKey as string,
-    redirect_uri: callbackUrl,
-    response_type: 'code',
-    permissions: '2146958591',
-    scope: scopes.join(' '),
-  });
-
-  const url = `${$.app.apiBaseUrl}/oauth2/authorize?${searchParams.toString()}`;
-
-  await $.auth.set({ url });
-}

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

@@ -0,0 +1,61 @@
+import generateAuthUrl from './generate-auth-url.js';
+import verifyCredentials from './verify-credentials.js';
+import isStillVerified from './is-still-verified.js';
+
+export default {
+  fields: [
+    {
+      key: 'oAuthRedirectUrl',
+      label: 'OAuth Redirect URL',
+      type: 'string',
+      required: true,
+      readOnly: true,
+      value: '{WEB_APP_URL}/app/discord/connections/add',
+      placeholder: null,
+      description:
+        'When asked to input an OAuth callback or redirect URL in Discord OAuth, enter the URL above.',
+      docUrl: 'https://automatisch.io/docs/discord#oauth-redirect-url',
+      clickToCopy: true,
+    },
+    {
+      key: 'consumerKey',
+      label: 'Consumer Key',
+      type: 'string',
+      required: true,
+      readOnly: false,
+      value: null,
+      placeholder: null,
+      description: null,
+      docUrl: 'https://automatisch.io/docs/discord#consumer-key',
+      clickToCopy: false,
+    },
+    {
+      key: 'consumerSecret',
+      label: 'Consumer Secret',
+      type: 'string',
+      required: true,
+      readOnly: false,
+      value: null,
+      placeholder: null,
+      description: null,
+      docUrl: 'https://automatisch.io/docs/discord#consumer-secret',
+      clickToCopy: false,
+    },
+    {
+      key: 'botToken',
+      label: 'Bot token',
+      type: 'string',
+      required: true,
+      readOnly: false,
+      value: null,
+      placeholder: null,
+      description: null,
+      docUrl: 'https://automatisch.io/docs/discord#bot-token',
+      clickToCopy: false,
+    },
+  ],
+
+  generateAuthUrl,
+  verifyCredentials,
+  isStillVerified,
+};

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

@@ -1,61 +0,0 @@
-import generateAuthUrl from './generate-auth-url';
-import verifyCredentials from './verify-credentials';
-import isStillVerified from './is-still-verified';
-
-export default {
-  fields: [
-    {
-      key: 'oAuthRedirectUrl',
-      label: 'OAuth Redirect URL',
-      type: 'string' as const,
-      required: true,
-      readOnly: true,
-      value: '{WEB_APP_URL}/app/discord/connections/add',
-      placeholder: null,
-      description:
-        'When asked to input an OAuth callback or redirect URL in Discord OAuth, enter the URL above.',
-      docUrl: 'https://automatisch.io/docs/discord#oauth-redirect-url',
-      clickToCopy: true,
-    },
-    {
-      key: 'consumerKey',
-      label: 'Consumer Key',
-      type: 'string' as const,
-      required: true,
-      readOnly: false,
-      value: null,
-      placeholder: null,
-      description: null,
-      docUrl: 'https://automatisch.io/docs/discord#consumer-key',
-      clickToCopy: false,
-    },
-    {
-      key: 'consumerSecret',
-      label: 'Consumer Secret',
-      type: 'string' as const,
-      required: true,
-      readOnly: false,
-      value: null,
-      placeholder: null,
-      description: null,
-      docUrl: 'https://automatisch.io/docs/discord#consumer-secret',
-      clickToCopy: false,
-    },
-    {
-      key: 'botToken',
-      label: 'Bot token',
-      type: 'string' as const,
-      required: true,
-      readOnly: false,
-      value: null,
-      placeholder: null,
-      description: null,
-      docUrl: 'https://automatisch.io/docs/discord#bot-token',
-      clickToCopy: false,
-    },
-  ],
-
-  generateAuthUrl,
-  verifyCredentials,
-  isStillVerified,
-};