test: add delete flow tests

test(connection): write model tests

.github/workflows/playwright.yml

@@ -12,6 +12,9 @@ on:
   workflow_dispatch:
 
 env:
+  BULLMQ_DASHBOARD_USERNAME: root
+  BULLMQ_DASHBOARD_PASSWORD: sample
+  ENABLE_BULLMQ_DASHBOARD: true
   ENCRYPTION_KEY: sample_encryption_key
   WEBHOOK_SECRET_KEY: sample_webhook_secret_key
   APP_SECRET_KEY: sample_app_secret_key
@@ -22,6 +25,7 @@ env:
   POSTGRES_PASSWORD: automatisch_password
   REDIS_HOST: localhost
   APP_ENV: production
+  PORT: 3000
   LICENSE_KEY: dummy_license_key
 
 jobs:

packages/backend/package.json

@@ -23,8 +23,6 @@
   "dependencies": {
     "@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",
@@ -41,11 +39,7 @@
     "express": "~4.18.2",
     "express-async-errors": "^3.1.1",
     "express-basic-auth": "^1.2.1",
-    "express-graphql": "^0.12.0",
     "fast-xml-parser": "^4.0.11",
-    "graphql-middleware": "^6.1.15",
-    "graphql-shield": "^7.5.0",
-    "graphql-tools": "^8.2.0",
     "handlebars": "^4.7.7",
     "http-errors": "~1.6.3",
     "http-proxy-agent": "^7.0.0",

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

@@ -12,7 +12,7 @@ export default defineApp({
   apiBaseUrl: 'https://api.airtable.com',
   iconUrl: '{BASE_URL}/apps/airtable/assets/favicon.svg',
   authDocUrl: '{DOCS_URL}/apps/airtable/connection',
-  primaryColor: 'FFBF00',
+  primaryColor: '#FFBF00',
   supportsConnections: true,
   beforeRequest: [addAuthHeader],
   auth,

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

@@ -12,7 +12,7 @@ export default defineApp({
   apiBaseUrl: 'https://cloud.appwrite.io',
   iconUrl: '{BASE_URL}/apps/appwrite/assets/favicon.svg',
   authDocUrl: '{DOCS_URL}/apps/appwrite/connection',
-  primaryColor: 'FD366E',
+  primaryColor: '#FD366E',
   supportsConnections: true,
   beforeRequest: [setBaseUrl, addAuthHeader],
   auth,

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

@@ -12,7 +12,7 @@ export default defineApp({
   apiBaseUrl: '',
   iconUrl: '{BASE_URL}/apps/azure-openai/assets/favicon.svg',
   authDocUrl: '{DOCS_URL}/apps/azure-openai/connection',
-  primaryColor: '000000',
+  primaryColor: '#000000',
   supportsConnections: true,
   beforeRequest: [setBaseUrl, addAuthHeader],
   auth,

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

@@ -11,7 +11,7 @@ export default defineApp({
   supportsConnections: true,
   baseUrl: 'https://carbone.io',
   apiBaseUrl: 'https://api.carbone.io',
-  primaryColor: '6f42c1',
+  primaryColor: '#6f42c1',
   beforeRequest: [addAuthHeader],
   auth,
   actions,

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

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

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

@@ -8,7 +8,7 @@ export default defineApp({
   apiBaseUrl: '',
   iconUrl: '{BASE_URL}/apps/code/assets/favicon.svg',
   authDocUrl: '{DOCS_URL}/apps/code/connection',
-  primaryColor: '000000',
+  primaryColor: '#000000',
   supportsConnections: false,
   actions,
 });

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

@@ -9,6 +9,6 @@ export default defineApp({
   supportsConnections: false,
   baseUrl: '',
   apiBaseUrl: '',
-  primaryColor: '001F52',
+  primaryColor: '#001F52',
   actions,
 });

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

@@ -9,6 +9,6 @@ export default defineApp({
   supportsConnections: false,
   baseUrl: '',
   apiBaseUrl: '',
-  primaryColor: '001F52',
+  primaryColor: '#001F52',
   actions,
 });

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

@@ -11,7 +11,7 @@ export default defineApp({
   supportsConnections: true,
   baseUrl: 'https://deepl.com',
   apiBaseUrl: 'https://api.deepl.com',
-  primaryColor: '0d2d45',
+  primaryColor: '#0d2d45',
   beforeRequest: [addAuthHeader],
   auth,
   actions,

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

@@ -9,6 +9,6 @@ export default defineApp({
   supportsConnections: false,
   baseUrl: '',
   apiBaseUrl: '',
-  primaryColor: '001F52',
+  primaryColor: '#001F52',
   actions,
 });

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

@@ -14,7 +14,7 @@ export default defineApp({
   supportsConnections: true,
   baseUrl: 'https://discord.com',
   apiBaseUrl: 'https://discord.com/api',
-  primaryColor: '5865f2',
+  primaryColor: '#5865f2',
   beforeRequest: [addAuthHeader],
   auth,
   dynamicData,

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

@@ -11,7 +11,7 @@ export default defineApp({
   apiBaseUrl: 'https://disqus.com/api',
   iconUrl: '{BASE_URL}/apps/disqus/assets/favicon.svg',
   authDocUrl: '{DOCS_URL}/apps/disqus/connection',
-  primaryColor: '2E9FFF',
+  primaryColor: '#2E9FFF',
   supportsConnections: true,
   beforeRequest: [addAuthHeader],
   auth,

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

@@ -11,7 +11,7 @@ export default defineApp({
   supportsConnections: true,
   baseUrl: 'https://dropbox.com',
   apiBaseUrl: 'https://api.dropboxapi.com',
-  primaryColor: '0061ff',
+  primaryColor: '#0061ff',
   beforeRequest: [addAuthHeader],
   auth,
   actions,

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

@@ -9,6 +9,6 @@ export default defineApp({
   supportsConnections: false,
   baseUrl: '',
   apiBaseUrl: '',
-  primaryColor: '001F52',
+  primaryColor: '#001F52',
   actions,
 });

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

@@ -10,7 +10,7 @@ export default defineApp({
   iconUrl: '{BASE_URL}/apps/flickr/assets/favicon.svg',
   authDocUrl: '{DOCS_URL}/apps/flickr/connection',
   docUrl: 'https://automatisch.io/docs/flickr',
-  primaryColor: '000000',
+  primaryColor: '#000000',
   supportsConnections: true,
   baseUrl: 'https://www.flickr.com/',
   apiBaseUrl: 'https://www.flickr.com/services',

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

@@ -11,7 +11,7 @@ export default defineApp({
   supportsConnections: true,
   baseUrl: 'https://flowers-software.com',
   apiBaseUrl: 'https://webapp.flowers-software.com/api',
-  primaryColor: '02AFC7',
+  primaryColor: '#02AFC7',
   beforeRequest: [addAuthHeader],
   auth,
   triggers,

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

@@ -10,7 +10,7 @@ export default defineApp({
   supportsConnections: false,
   baseUrl: '',
   apiBaseUrl: '',
-  primaryColor: '001F52',
+  primaryColor: '#001F52',
   actions,
   dynamicFields,
 });

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

@@ -11,7 +11,7 @@ export default defineApp({
   apiBaseUrl: '',
   iconUrl: '{BASE_URL}/apps/ghost/assets/favicon.svg',
   authDocUrl: '{DOCS_URL}/apps/ghost/connection',
-  primaryColor: '15171A',
+  primaryColor: '#15171A',
   supportsConnections: true,
   beforeRequest: [setBaseUrl, addAuthHeader],
   auth,

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

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

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

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

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

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

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

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

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

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

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

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

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

@@ -12,7 +12,7 @@ export default defineApp({
   apiBaseUrl: 'https://tasks.googleapis.com',
   iconUrl: '{BASE_URL}/apps/google-tasks/assets/favicon.svg',
   authDocUrl: '{DOCS_URL}/apps/google-tasks/connection',
-  primaryColor: '0066DA',
+  primaryColor: '#0066DA',
   supportsConnections: true,
   beforeRequest: [addAuthHeader],
   auth,

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

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

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

@@ -9,6 +9,6 @@ export default defineApp({
   supportsConnections: false,
   baseUrl: '',
   apiBaseUrl: '',
-  primaryColor: '000000',
+  primaryColor: '#000000',
   actions,
 });

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

@@ -11,7 +11,7 @@ export default defineApp({
   supportsConnections: true,
   baseUrl: 'https://www.hubspot.com',
   apiBaseUrl: 'https://api.hubapi.com',
-  primaryColor: 'F95C35',
+  primaryColor: '#F95C35',
   beforeRequest: [addAuthHeader],
   auth,
   actions,

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

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

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

@@ -9,11 +9,11 @@ export default defineApp({
   name: 'Jotform',
   key: 'jotform',
   iconUrl: '{BASE_URL}/apps/jotform/assets/favicon.svg',
-  authDocUrl: 'https://automatisch.io/docs/apps/jotform/connection',
+  authDocUrl: '{DOCS_URL}/apps/jotform/connection',
   supportsConnections: true,
   baseUrl: 'https://www.jotform.com',
   apiBaseUrl: 'https://api.jotform.com',
-  primaryColor: 'FF6100',
+  primaryColor: '#FF6100',
   beforeRequest: [setBaseUrl, addAuthHeader],
   auth,
   triggers,

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

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

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

@@ -7,11 +7,11 @@ export default defineApp({
   name: 'MailerLite',
   key: 'mailerlite',
   iconUrl: '{BASE_URL}/apps/mailerlite/assets/favicon.svg',
-  authDocUrl: 'https://automatisch.io/docs/apps/mailerlite/connection',
+  authDocUrl: '{DOCS_URL}/apps/mailerlite/connection',
   supportsConnections: true,
   baseUrl: 'https://www.mailerlite.com',
   apiBaseUrl: 'https://connect.mailerlite.com/api',
-  primaryColor: '09C269',
+  primaryColor: '#09C269',
   beforeRequest: [addAuthHeader],
   auth,
   triggers,

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

@@ -13,7 +13,7 @@ export default defineApp({
   authDocUrl: '{DOCS_URL}/apps/mattermost/connection',
   baseUrl: 'https://mattermost.com',
   apiBaseUrl: '', // there is no cloud version of this app, user always need to provide address of own instance when creating connection
-  primaryColor: '4a154b',
+  primaryColor: '#4a154b',
   supportsConnections: true,
   beforeRequest: [setBaseUrl, addXRequestedWithHeader, addAuthHeader],
   auth,

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

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

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

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

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

@@ -11,7 +11,7 @@ export default defineApp({
   supportsConnections: true,
   baseUrl: 'https://ntfy.sh',
   apiBaseUrl: 'https://ntfy.sh',
-  primaryColor: '56bda8',
+  primaryColor: '#56bda8',
   beforeRequest: [addAuthHeader],
   auth,
   actions,

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

@@ -10,7 +10,7 @@ export default defineApp({
   supportsConnections: true,
   baseUrl: 'https://odoo.com',
   apiBaseUrl: '',
-  primaryColor: '9c5789',
+  primaryColor: '#9c5789',
   auth,
   actions,
 });

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

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

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

@@ -13,7 +13,7 @@ export default defineApp({
   apiBaseUrl: '',
   iconUrl: '{BASE_URL}/apps/pipedrive/assets/favicon.svg',
   authDocUrl: '{DOCS_URL}/apps/pipedrive/connection',
-  primaryColor: 'FFFFFF',
+  primaryColor: '#FFFFFF',
   supportsConnections: true,
   beforeRequest: [setBaseUrl, addAuthHeader],
   auth,

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

@@ -12,7 +12,7 @@ export default defineApp({
   supportsConnections: true,
   baseUrl: 'https://placetel.de',
   apiBaseUrl: 'https://api.placetel.de',
-  primaryColor: '069dd9',
+  primaryColor: '#069dd9',
   beforeRequest: [addAuthHeader],
   auth,
   triggers,

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

@@ -10,7 +10,7 @@ export default defineApp({
   supportsConnections: true,
   baseUrl: '',
   apiBaseUrl: '',
-  primaryColor: '336791',
+  primaryColor: '#336791',
   auth,
   actions,
 });

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

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

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

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

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

@@ -11,7 +11,7 @@ export default defineApp({
   supportsConnections: true,
   baseUrl: 'https://www.remove.bg',
   apiBaseUrl: 'https://api.remove.bg/v1.0',
-  primaryColor: '55636c',
+  primaryColor: '#55636c',
   beforeRequest: [addAuthHeader],
   auth,
   actions,

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

@@ -9,6 +9,6 @@ export default defineApp({
   supportsConnections: false,
   baseUrl: '',
   apiBaseUrl: '',
-  primaryColor: 'ff8800',
+  primaryColor: '#ff8800',
   triggers,
 });

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

@@ -13,7 +13,7 @@ export default defineApp({
   supportsConnections: true,
   baseUrl: 'https://salesforce.com',
   apiBaseUrl: '',
-  primaryColor: '00A1E0',
+  primaryColor: '#00A1E0',
   beforeRequest: [addAuthHeader],
   auth,
   triggers,

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

@@ -9,7 +9,7 @@ export default defineApp({
   authDocUrl: '{DOCS_URL}/apps/scheduler/connection',
   baseUrl: '',
   apiBaseUrl: '',
-  primaryColor: '0059F7',
+  primaryColor: '#0059F7',
   supportsConnections: false,
   triggers,
 });

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

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

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

@@ -13,7 +13,7 @@ export default defineApp({
   supportsConnections: true,
   baseUrl: 'https://signalwire.com',
   apiBaseUrl: '',
-  primaryColor: '044cf6',
+  primaryColor: '#044cf6',
   beforeRequest: [addAuthHeader],
   auth,
   triggers,

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

@@ -13,7 +13,7 @@ export default defineApp({
   supportsConnections: true,
   baseUrl: 'https://slack.com',
   apiBaseUrl: 'https://slack.com/api',
-  primaryColor: '4a154b',
+  primaryColor: '#4a154b',
   beforeRequest: [addAuthHeader],
   auth,
   actions,

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

@@ -10,7 +10,7 @@ export default defineApp({
   supportsConnections: true,
   baseUrl: '',
   apiBaseUrl: '',
-  primaryColor: '2DAAE1',
+  primaryColor: '#2DAAE1',
   auth,
   actions,
 });

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

@@ -11,7 +11,7 @@ export default defineApp({
   supportsConnections: true,
   baseUrl: 'https://spotify.com',
   apiBaseUrl: 'https://api.spotify.com',
-  primaryColor: '000000',
+  primaryColor: '#000000',
   beforeRequest: [addAuthHeader],
   auth,
   actions,

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

@@ -11,7 +11,7 @@ export default defineApp({
   supportsConnections: true,
   baseUrl: 'https://www.strava.com',
   apiBaseUrl: 'https://www.strava.com/api',
-  primaryColor: 'fc4c01',
+  primaryColor: '#fc4c01',
   beforeRequest: [addAuthHeader],
   auth,
   actions,

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

@@ -11,7 +11,7 @@ export default defineApp({
   supportsConnections: true,
   baseUrl: 'https://stripe.com',
   apiBaseUrl: 'https://api.stripe.com',
-  primaryColor: '635bff',
+  primaryColor: '#635bff',
   beforeRequest: [addAuthHeader],
   auth,
   triggers,

packages/backend/src/apps/telegram-bot/index.js

@@ -11,7 +11,7 @@ export default defineApp({
   supportsConnections: true,
   baseUrl: 'https://telegram.org',
   apiBaseUrl: 'https://api.telegram.org',
-  primaryColor: '2AABEE',
+  primaryColor: '#2AABEE',
   beforeRequest: [addAuthHeader],
   auth,
   actions,

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

@@ -13,7 +13,7 @@ export default defineApp({
   supportsConnections: true,
   baseUrl: 'https://todoist.com',
   apiBaseUrl: 'https://api.todoist.com/rest/v2',
-  primaryColor: 'e44332',
+  primaryColor: '#e44332',
   beforeRequest: [addAuthHeader],
   auth,
   triggers,

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

@@ -12,7 +12,7 @@ export default defineApp({
   iconUrl: '{BASE_URL}/apps/trello/assets/favicon.svg',
   authDocUrl: '{DOCS_URL}/apps/trello/connection',
   supportsConnections: true,
-  primaryColor: '0079bf',
+  primaryColor: '#0079bf',
   beforeRequest: [addAuthHeader],
   auth,
   actions,

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

@@ -13,7 +13,7 @@ export default defineApp({
   supportsConnections: true,
   baseUrl: 'https://twilio.com',
   apiBaseUrl: 'https://api.twilio.com',
-  primaryColor: 'e1000f',
+  primaryColor: '#e1000f',
   beforeRequest: [addAuthHeader],
   auth,
   triggers,

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

@@ -12,7 +12,7 @@ export default defineApp({
   supportsConnections: true,
   baseUrl: 'https://twitter.com',
   apiBaseUrl: 'https://api.twitter.com',
-  primaryColor: '1da1f2',
+  primaryColor: '#1da1f2',
   beforeRequest: [addAuthHeader],
   auth,
   triggers,

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

@@ -12,7 +12,7 @@ export default defineApp({
   supportsConnections: true,
   baseUrl: 'https://typeform.com',
   apiBaseUrl: 'https://api.typeform.com',
-  primaryColor: '262627',
+  primaryColor: '#262627',
   beforeRequest: [addAuthHeader],
   auth,
   triggers,

packages/backend/src/apps/vtiger-crm/index.js

@@ -14,7 +14,7 @@ export default defineApp({
   supportsConnections: true,
   baseUrl: '',
   apiBaseUrl: '',
-  primaryColor: '39a86d',
+  primaryColor: '#39a86d',
   beforeRequest: [setBaseUrl, addAuthHeader],
   auth,
   triggers,

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

@@ -10,7 +10,7 @@ export default defineApp({
   supportsConnections: false,
   baseUrl: '',
   apiBaseUrl: '',
-  primaryColor: '0059F7',
+  primaryColor: '#0059F7',
   actions,
   triggers,
 });

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

@@ -13,7 +13,7 @@ export default defineApp({
   supportsConnections: true,
   baseUrl: 'https://wordpress.com',
   apiBaseUrl: '',
-  primaryColor: '464342',
+  primaryColor: '#464342',
   beforeRequest: [setBaseUrl, addAuthHeader],
   auth,
   triggers,

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

@@ -11,7 +11,7 @@ export default defineApp({
   apiBaseUrl: 'https://api.xero.com',
   iconUrl: '{BASE_URL}/apps/xero/assets/favicon.svg',
   authDocUrl: '{DOCS_URL}/apps/xero/connection',
-  primaryColor: '13B5EA',
+  primaryColor: '#13B5EA',
   supportsConnections: true,
   beforeRequest: [addAuthHeader],
   auth,

packages/backend/src/apps/you-need-a-budget/index.js

@@ -10,7 +10,7 @@ export default defineApp({
   apiBaseUrl: 'https://api.ynab.com/v1',
   iconUrl: '{BASE_URL}/apps/you-need-a-budget/assets/favicon.svg',
   authDocUrl: '{DOCS_URL}/apps/you-need-a-budget/connection',
-  primaryColor: '19223C',
+  primaryColor: '#19223C',
   supportsConnections: true,
   beforeRequest: [addAuthHeader],
   auth,

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

@@ -10,7 +10,7 @@ export default defineApp({
   apiBaseUrl: 'https://www.googleapis.com/youtube',
   iconUrl: '{BASE_URL}/apps/youtube/assets/favicon.svg',
   authDocUrl: '{DOCS_URL}/apps/youtube/connection',
-  primaryColor: 'FF0000',
+  primaryColor: '#FF0000',
   supportsConnections: true,
   beforeRequest: [addAuthHeader],
   auth,

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

@@ -12,7 +12,7 @@ export default defineApp({
   apiBaseUrl: '',
   iconUrl: '{BASE_URL}/apps/zendesk/assets/favicon.svg',
   authDocUrl: '{DOCS_URL}/apps/zendesk/connection',
-  primaryColor: '17494d',
+  primaryColor: '#17494d',
   supportsConnections: true,
   beforeRequest: [addAuthHeader],
   auth,

packages/backend/src/controllers/api/v1/admin/config/update.ee.js

@@ -1,23 +1,28 @@
-import pick from 'lodash/pick.js';
 import { renderObject } from '../../../../../helpers/renderer.js';
 import Config from '../../../../../models/config.js';
 
 export default async (request, response) => {
-  const config = configParams(request);
+  const config = await Config.query().updateFirstOrInsert(
-
+    configParams(request)
-  await Config.batchUpdate(config);
+  );
 
   renderObject(response, config);
 };
 
 const configParams = (request) => {
-  const updatableConfigurationKeys = [
+  const {
-    'logo.svgData',
+    logoSvgData,
-    'palette.primary.dark',
+    palettePrimaryDark,
-    'palette.primary.light',
+    palettePrimaryLight,
-    'palette.primary.main',
+    palettePrimaryMain,
-    'title',
+    title,
-  ];
+  } = request.body;
 
-  return pick(request.body, updatableConfigurationKeys);
+  return {
+    logoSvgData,
+    palettePrimaryDark,
+    palettePrimaryLight,
+    palettePrimaryMain,
+    title,
+  };
 };

packages/backend/src/controllers/api/v1/admin/config/update.ee.test.js

@@ -5,7 +5,7 @@ import app from '../../../../../app.js';
 import createAuthTokenByUserId from '../../../../../helpers/create-auth-token-by-user-id.js';
 import { createUser } from '../../../../../../test/factories/user.js';
 import { createRole } from '../../../../../../test/factories/role.js';
-import { createBulkConfig } from '../../../../../../test/factories/config.js';
+import { updateConfig } from '../../../../../../test/factories/config.js';
 import * as license from '../../../../../helpers/license.ee.js';
 
 describe('PATCH /api/v1/admin/config', () => {
@@ -30,13 +30,13 @@ describe('PATCH /api/v1/admin/config', () => {
 
     const appConfig = {
       title,
-      'palette.primary.main': palettePrimaryMain,
+      palettePrimaryMain: palettePrimaryMain,
-      'palette.primary.dark': palettePrimaryDark,
+      palettePrimaryDark: palettePrimaryDark,
-      'palette.primary.light': palettePrimaryLight,
+      palettePrimaryLight: palettePrimaryLight,
-      'logo.svgData': logoSvgData,
+      logoSvgData: logoSvgData,
     };
 
-    await createBulkConfig(appConfig);
+    await updateConfig(appConfig);
 
     const newTitle = 'Updated title';
 
@@ -51,7 +51,7 @@ describe('PATCH /api/v1/admin/config', () => {
       .expect(200);
 
     expect(response.body.data.title).toEqual(newTitle);
-    expect(response.body.meta.type).toEqual('Object');
+    expect(response.body.meta.type).toEqual('Config');
   });
 
   it('should return created config for unexisting config', async () => {
@@ -68,7 +68,7 @@ describe('PATCH /api/v1/admin/config', () => {
       .expect(200);
 
     expect(response.body.data.title).toEqual(newTitle);
-    expect(response.body.meta.type).toEqual('Object');
+    expect(response.body.meta.type).toEqual('Config');
   });
 
   it('should return null for deleted config entry', async () => {
@@ -83,6 +83,6 @@ describe('PATCH /api/v1/admin/config', () => {
       .expect(200);
 
     expect(response.body.data.title).toBeNull();
-    expect(response.body.meta.type).toEqual('Object');
+    expect(response.body.meta.type).toEqual('Config');
   });
 });

packages/backend/src/controllers/api/v1/admin/users/create-user.js

@@ -6,7 +6,7 @@ export default async (request, response) => {
   const user = await User.query().insertAndFetch(await userParams(request));
   await user.sendInvitationEmail();
 
-  renderObject(response, user, { status: 201 });
+  renderObject(response, user, { status: 201, serializer: 'AdminUser' });
 };
 
 const userParams = async (request) => {

packages/backend/src/controllers/api/v1/admin/users/create-user.test.js

@@ -6,7 +6,7 @@ import User from '../../../../../models/user.js';
 import Role from '../../../../../models/role.js';
 import { createUser } from '../../../../../../test/factories/user.js';
 import { createRole } from '../../../../../../test/factories/role.js';
-import createUserMock from '../../../../../../test/mocks/rest/api/v1/users/create-user.js';
+import createUserMock from '../../../../../../test/mocks/rest/api/v1/admin/users/create-user.js';
 
 describe('POST /api/v1/admin/users', () => {
   let currentUser, adminRole, token;

packages/backend/src/controllers/api/v1/automatisch/config.ee.js

@@ -1,25 +1,8 @@
-import appConfig from '../../../../config/app.js';
 import Config from '../../../../models/config.js';
 import { renderObject } from '../../../../helpers/renderer.js';
 
 export default async (request, response) => {
-  const defaultConfig = {
+  const config = await Config.get();
-    disableNotificationsPage: appConfig.disableNotificationsPage,
-    disableFavicon: appConfig.disableFavicon,
-    additionalDrawerLink: appConfig.additionalDrawerLink,
-    additionalDrawerLinkIcon: appConfig.additionalDrawerLinkIcon,
-    additionalDrawerLinkText: appConfig.additionalDrawerLinkText,
-  };
-
-  let config = await Config.query().orderBy('key', 'asc');
-
-  config = config.reduce((computedConfig, configEntry) => {
-    const { key, value } = configEntry;
-
-    computedConfig[key] = value?.data;
-
-    return computedConfig;
-  }, defaultConfig);
 
   renderObject(response, config);
 };

packages/backend/src/controllers/api/v1/automatisch/config.ee.test.js

@@ -1,66 +1,47 @@
 import { vi, expect, describe, it } from 'vitest';
 import request from 'supertest';
-import { createConfig } from '../../../../../test/factories/config.js';
+import { updateConfig } from '../../../../../test/factories/config.js';
 import app from '../../../../app.js';
 import configMock from '../../../../../test/mocks/rest/api/v1/automatisch/config.js';
 import * as license from '../../../../helpers/license.ee.js';
 import appConfig from '../../../../config/app.js';
 
 describe('GET /api/v1/automatisch/config', () => {
-  it('should return Automatisch config', async () => {
+  it('should return Automatisch config along with static config', async () => {
     vi.spyOn(license, 'hasValidLicense').mockResolvedValue(true);
+    vi.spyOn(appConfig, 'disableNotificationsPage', 'get').mockReturnValue(
+      true
+    );
+    vi.spyOn(appConfig, 'disableFavicon', 'get').mockReturnValue(true);
+    vi.spyOn(appConfig, 'additionalDrawerLink', 'get').mockReturnValue('link');
+    vi.spyOn(appConfig, 'additionalDrawerLinkIcon', 'get').mockReturnValue(
+      'icon'
+    );
+    vi.spyOn(appConfig, 'additionalDrawerLinkText', 'get').mockReturnValue(
+      'text'
+    );
 
-    const logoConfig = await createConfig({
+    const config = await updateConfig({
-      key: 'logo.svgData',
+      logoSvgData: '<svg>Sample</svg>',
-      value: { data: '<svg>Sample</svg>' },
+      palettePrimaryDark: '#001f52',
-    });
+      palettePrimaryLight: '#4286FF',
-
+      palettePrimaryMain: '#0059F7',
-    const primaryDarkConfig = await createConfig({
+      title: 'Sample Title',
-      key: 'palette.primary.dark',
-      value: { data: '#001F52' },
-    });
-
-    const primaryLightConfig = await createConfig({
-      key: 'palette.primary.light',
-      value: { data: '#4286FF' },
-    });
-
-    const primaryMainConfig = await createConfig({
-      key: 'palette.primary.main',
-      value: { data: '#0059F7' },
-    });
-
-    const titleConfig = await createConfig({
-      key: 'title',
-      value: { data: 'Sample Title' },
     });
 
     const response = await request(app)
       .get('/api/v1/automatisch/config')
       .expect(200);
 
-    const expectedPayload = configMock(
+    const expectedPayload = configMock({
-      logoConfig,
+      ...config,
-      primaryDarkConfig,
+      disableNotificationsPage: true,
-      primaryLightConfig,
+      disableFavicon: true,
-      primaryMainConfig,
+      additionalDrawerLink: 'link',
-      titleConfig
+      additionalDrawerLinkIcon: 'icon',
-    );
+      additionalDrawerLinkText: 'text',
+    });
 
-    expect(response.body).toEqual(expectedPayload);
+    expect(response.body).toStrictEqual(expectedPayload);
-  });
-
-  it('should return additional environment variables', async () => {
-    vi.spyOn(appConfig, 'disableNotificationsPage', 'get').mockReturnValue(true);
-    vi.spyOn(appConfig, 'disableFavicon', 'get').mockReturnValue(true);
-    vi.spyOn(appConfig, 'additionalDrawerLink', 'get').mockReturnValue('link');
-    vi.spyOn(appConfig, 'additionalDrawerLinkIcon', 'get').mockReturnValue('icon');
-    vi.spyOn(appConfig, 'additionalDrawerLinkText', 'get').mockReturnValue('text');
-
-    expect(appConfig.disableNotificationsPage).toEqual(true);
-    expect(appConfig.disableFavicon).toEqual(true);
-    expect(appConfig.additionalDrawerLink).toEqual('link');
-    expect(appConfig.additionalDrawerLinkIcon).toEqual('icon');
-    expect(appConfig.additionalDrawerLinkText).toEqual('text');
   });
 });

packages/backend/src/controllers/api/v1/installation/users/create-user.test.js

@@ -5,7 +5,7 @@ import Config from '../../../../../models/config.js';
 import User from '../../../../../models/user.js';
 import { createRole } from '../../../../../../test/factories/role';
 import { createUser } from '../../../../../../test/factories/user';
-import { createInstallationCompletedConfig } from '../../../../../../test/factories/config';
+import { markInstallationCompleted } from '../../../../../../test/factories/config';
 
 describe('POST /api/v1/installation/users', () => {
   let adminRole;
@@ -59,7 +59,7 @@ describe('POST /api/v1/installation/users', () => {
 
   describe('for completed installations', () => {
     beforeEach(async () => {
-      await createInstallationCompletedConfig();
+      await markInstallationCompleted();
     });
 
     it('should respond with HTTP 403 when installation completed', async () => {

packages/backend/src/controllers/api/v1/steps/create-dynamic-data.test.js

@@ -169,7 +169,7 @@ describe('POST /api/v1/steps/:stepId/dynamic-data', () => {
           dynamicDataKey: 'listRepos',
           parameters: {},
         })
-        .expect(200);
+        .expect(422);
 
       expect(response.body.errors).toEqual(errors);
     });

packages/backend/src/controllers/api/v1/steps/update-step.js

@@ -0,0 +1,22 @@
+import { renderObject } from '../../../../helpers/renderer.js';
+
+export default async (request, response) => {
+  let step = await request.currentUser.authorizedSteps
+    .findById(request.params.stepId)
+    .throwIfNotFound();
+
+  step = await step.updateFor(request.currentUser, stepParams(request));
+
+  renderObject(response, step);
+};
+
+const stepParams = (request) => {
+  const { connectionId, appKey, key, parameters } = request.body;
+
+  return {
+    connectionId,
+    appKey,
+    key,
+    parameters,
+  };
+};

packages/backend/src/controllers/api/v1/steps/update-step.test.js

@@ -0,0 +1,211 @@
+import { describe, it, beforeEach, expect } from 'vitest';
+import request from 'supertest';
+import Crypto from 'crypto';
+import app from '../../../../app.js';
+import createAuthTokenByUserId from '../../../../helpers/create-auth-token-by-user-id.js';
+import { createUser } from '../../../../../test/factories/user.js';
+import { createConnection } from '../../../../../test/factories/connection.js';
+import { createFlow } from '../../../../../test/factories/flow.js';
+import { createStep } from '../../../../../test/factories/step.js';
+import { createPermission } from '../../../../../test/factories/permission.js';
+import updateStepMock from '../../../../../test/mocks/rest/api/v1/steps/update-step.js';
+
+describe('PATCH /api/v1/steps/:stepId', () => {
+  let currentUser, token;
+
+  beforeEach(async () => {
+    currentUser = await createUser();
+
+    token = await createAuthTokenByUserId(currentUser.id);
+  });
+
+  it('should update the step of the current user', async () => {
+    const currentUserFlow = await createFlow({ userId: currentUser.id });
+    const currentUserConnection = await createConnection({
+      key: 'deepl',
+    });
+
+    await createStep({
+      flowId: currentUserFlow.id,
+      connectionId: currentUserConnection.id,
+    });
+
+    const actionStep = await createStep({
+      flowId: currentUserFlow.id,
+      connectionId: currentUserConnection.id,
+      appKey: 'deepl',
+      key: 'translateText',
+    });
+
+    await createPermission({
+      action: 'read',
+      subject: 'Flow',
+      roleId: currentUser.roleId,
+      conditions: ['isCreator'],
+    });
+
+    await createPermission({
+      action: 'update',
+      subject: 'Flow',
+      roleId: currentUser.roleId,
+      conditions: ['isCreator'],
+    });
+
+    const response = await request(app)
+      .patch(`/api/v1/steps/${actionStep.id}`)
+      .set('Authorization', token)
+      .send({
+        parameters: {
+          text: 'Hello world!',
+          targetLanguage: 'de',
+        },
+      })
+      .expect(200);
+
+    const refetchedStep = await actionStep.$query();
+
+    const expectedResponse = updateStepMock(refetchedStep);
+
+    expect(response.body).toStrictEqual(expectedResponse);
+  });
+
+  it('should update the step of the another user', async () => {
+    const anotherUser = await createUser();
+    const anotherUserFlow = await createFlow({ userId: anotherUser.id });
+    const anotherUserConnection = await createConnection({
+      key: 'deepl',
+    });
+
+    await createStep({
+      flowId: anotherUserFlow.id,
+      connectionId: anotherUserConnection.id,
+    });
+
+    const actionStep = await createStep({
+      flowId: anotherUserFlow.id,
+      connectionId: anotherUserConnection.id,
+    });
+
+    await createPermission({
+      action: 'read',
+      subject: 'Flow',
+      roleId: currentUser.roleId,
+      conditions: [],
+    });
+
+    await createPermission({
+      action: 'update',
+      subject: 'Flow',
+      roleId: currentUser.roleId,
+      conditions: [],
+    });
+
+    const response = await request(app)
+      .patch(`/api/v1/steps/${actionStep.id}`)
+      .set('Authorization', token)
+      .send({
+        parameters: {
+          text: 'Hello world!',
+          targetLanguage: 'de',
+        },
+      })
+      .expect(200);
+
+    const refetchedStep = await actionStep.$query();
+
+    const expectedResponse = updateStepMock(refetchedStep);
+
+    expect(response.body).toStrictEqual(expectedResponse);
+  });
+
+  it('should return not found response for inaccessible connection', async () => {
+    const currentUserFlow = await createFlow({ userId: currentUser.id });
+
+    const anotherUser = await createUser();
+    const anotherUserConnection = await createConnection({
+      key: 'deepl',
+      userId: anotherUser.id,
+    });
+
+    await createStep({
+      flowId: currentUserFlow.id,
+    });
+
+    const actionStep = await createStep({
+      flowId: currentUserFlow.id,
+    });
+
+    await createPermission({
+      action: 'read',
+      subject: 'Flow',
+      roleId: currentUser.roleId,
+      conditions: ['isCreator'],
+    });
+
+    await createPermission({
+      action: 'update',
+      subject: 'Flow',
+      roleId: currentUser.roleId,
+      conditions: ['isCreator'],
+    });
+
+    await createPermission({
+      action: 'read',
+      subject: 'Connection',
+      roleId: currentUser.roleId,
+      conditions: ['isCreator'],
+    });
+
+    await request(app)
+      .patch(`/api/v1/steps/${actionStep.id}`)
+      .set('Authorization', token)
+      .send({
+        connectionId: anotherUserConnection.id,
+      })
+      .expect(404);
+  });
+
+  it('should return not found response for not existing step UUID', async () => {
+    await createPermission({
+      action: 'update',
+      subject: 'Flow',
+      roleId: currentUser.roleId,
+      conditions: [],
+    });
+
+    await createPermission({
+      action: 'read',
+      subject: 'Flow',
+      roleId: currentUser.roleId,
+      conditions: [],
+    });
+
+    const notExistingStepUUID = Crypto.randomUUID();
+
+    await request(app)
+      .patch(`/api/v1/steps/${notExistingStepUUID}`)
+      .set('Authorization', token)
+      .expect(404);
+  });
+
+  it('should return bad request response for invalid step UUID', async () => {
+    await createPermission({
+      action: 'update',
+      subject: 'Flow',
+      roleId: currentUser.roleId,
+      conditions: [],
+    });
+
+    await createPermission({
+      action: 'read',
+      subject: 'Flow',
+      roleId: currentUser.roleId,
+      conditions: [],
+    });
+
+    await request(app)
+      .patch('/api/v1/steps/invalidStepUUID')
+      .set('Authorization', token)
+      .expect(400);
+  });
+});

packages/backend/src/db/migrations/20240919100138_make_config_single_record.js

@@ -0,0 +1,105 @@
+export async function up(knex) {
+  await knex.schema.alterTable('config', (table) => {
+    table.dropUnique('key');
+
+    table.string('key').nullable().alter();
+    table.boolean('installation_completed').defaultTo(false);
+    table.text('logo_svg_data');
+    table.text('palette_primary_dark');
+    table.text('palette_primary_light');
+    table.text('palette_primary_main');
+    table.string('title');
+  });
+
+  const config = await knex('config').select('key', 'value');
+
+  const newConfigData = {
+    logo_svg_data: getValueForKey(config, 'logo.svgData'),
+    palette_primary_dark: getValueForKey(config, 'palette.primary.dark'),
+    palette_primary_light: getValueForKey(config, 'palette.primary.light'),
+    palette_primary_main: getValueForKey(config, 'palette.primary.main'),
+    title: getValueForKey(config, 'title'),
+    installation_completed: getValueForKey(config, 'installation.completed'),
+  };
+
+  const [configEntry] = await knex('config')
+    .insert(newConfigData)
+    .select('id')
+    .returning('id');
+
+  await knex('config').where('id', '!=', configEntry.id).delete();
+
+  await knex.schema.alterTable('config', (table) => {
+    table.dropColumn('key');
+    table.dropColumn('value');
+  });
+}
+
+export async function down(knex) {
+  await knex.schema.alterTable('config', (table) => {
+    table.string('key');
+    table.jsonb('value').notNullable().defaultTo({});
+  });
+
+  const configRow = await knex('config').first();
+
+  const config = [
+    {
+      key: 'logo.svgData',
+      value: {
+        data: configRow.logo_svg_data,
+      },
+    },
+    {
+      key: 'palette.primary.dark',
+      value: {
+        data: configRow.palette_primary_dark,
+      },
+    },
+    {
+      key: 'palette.primary.light',
+      value: {
+        data: configRow.palette_primary_light,
+      },
+    },
+    {
+      key: 'palette.primary.main',
+      value: {
+        data: configRow.palette_primary_main,
+      },
+    },
+    {
+      key: 'title',
+      value: {
+        data: configRow.title,
+      },
+    },
+    {
+      key: 'installation.completed',
+      value: {
+        data: configRow.installation_completed,
+      },
+    },
+  ];
+
+  await knex('config').insert(config).returning('id');
+
+  await knex('config').where('id', '=', configRow.id).delete();
+
+  await knex.schema.alterTable('config', (table) => {
+    table.dropColumn('installation_completed');
+    table.dropColumn('logo_svg_data');
+    table.dropColumn('palette_primary_dark');
+    table.dropColumn('palette_primary_light');
+    table.dropColumn('palette_primary_main');
+    table.dropColumn('title');
+
+    table.string('key').unique().notNullable().alter();
+  });
+}
+
+function getValueForKey(rows, key) {
+  const row = rows.find((row) => row.key === key);
+
+  return row?.value?.data || null;
+}

packages/backend/src/graphql/mutation-resolvers.js

@@ -1,37 +0,0 @@
-import updateStep from './mutations/update-step.js';
-
-// Converted mutations
-import executeFlow from './mutations/execute-flow.js';
-import updateUser from './mutations/update-user.ee.js';
-import deleteStep from './mutations/delete-step.js';
-import verifyConnection from './mutations/verify-connection.js';
-import createFlow from './mutations/create-flow.js';
-import deleteCurrentUser from './mutations/delete-current-user.ee.js';
-import updateCurrentUser from './mutations/update-current-user.js';
-import generateAuthUrl from './mutations/generate-auth-url.js';
-import createConnection from './mutations/create-connection.js';
-import deleteFlow from './mutations/delete-flow.js';
-import resetConnection from './mutations/reset-connection.js';
-import updateConnection from './mutations/update-connection.js';
-import createUser from './mutations/create-user.ee.js';
-import updateFlowStatus from './mutations/update-flow-status.js';
-
-const mutationResolvers = {
-  createConnection,
-  createFlow,
-  createUser,
-  deleteCurrentUser,
-  deleteFlow,
-  deleteStep,
-  executeFlow,
-  generateAuthUrl,
-  resetConnection,
-  updateConnection,
-  updateCurrentUser,
-  updateFlowStatus,
-  updateStep,
-  updateUser,
-  verifyConnection,
-};
-
-export default mutationResolvers;

packages/backend/src/graphql/mutations/create-connection.js

@@ -1,48 +0,0 @@
-import App from '../../models/app.js';
-import AppConfig from '../../models/app-config.js';
-
-const createConnection = async (_parent, params, context) => {
-  context.currentUser.can('create', 'Connection');
-
-  const { key, appAuthClientId } = params.input;
-
-  const app = await App.findOneByKey(key);
-
-  const appConfig = await AppConfig.query().findOne({ key });
-
-  let formattedData = params.input.formattedData;
-  if (appConfig) {
-    if (appConfig.disabled)
-      throw new Error(
-        'This application has been disabled for new connections!'
-      );
-
-    if (!appConfig.allowCustomConnection && formattedData)
-      throw new Error(`Custom connections cannot be created for ${app.name}!`);
-
-    if (appConfig.shared && !formattedData) {
-      const authClient = await appConfig
-        .$relatedQuery('appAuthClients')
-        .findById(appAuthClientId)
-        .where({
-          active: true,
-        })
-        .throwIfNotFound();
-
-      formattedData = authClient.formattedAuthDefaults;
-    }
-  }
-
-  const createdConnection = await context.currentUser
-    .$relatedQuery('connections')
-    .insert({
-      key,
-      appAuthClientId,
-      formattedData,
-      verified: false,
-    });
-
-  return createdConnection;
-};
-
-export default createConnection;

packages/backend/src/graphql/mutations/create-flow.js

@@ -1,45 +0,0 @@
-import App from '../../models/app.js';
-import Step from '../../models/step.js';
-
-const createFlow = async (_parent, params, context) => {
-  context.currentUser.can('create', 'Flow');
-
-  const connectionId = params?.input?.connectionId;
-  const appKey = params?.input?.triggerAppKey;
-
-  if (appKey) {
-    await App.findOneByKey(appKey);
-  }
-
-  const flow = await context.currentUser.$relatedQuery('flows').insert({
-    name: 'Name your flow',
-  });
-
-  if (connectionId) {
-    const hasConnection = await context.currentUser
-      .$relatedQuery('connections')
-      .findById(connectionId);
-
-    if (!hasConnection) {
-      throw new Error('The connection does not exist!');
-    }
-  }
-
-  await Step.query().insert({
-    flowId: flow.id,
-    type: 'trigger',
-    position: 1,
-    appKey,
-    connectionId,
-  });
-
-  await Step.query().insert({
-    flowId: flow.id,
-    type: 'action',
-    position: 2,
-  });
-
-  return flow;
-};
-
-export default createFlow;

packages/backend/src/graphql/mutations/create-user.ee.js

@@ -1,66 +0,0 @@
-import appConfig from '../../config/app.js';
-import User from '../../models/user.js';
-import Role from '../../models/role.js';
-import emailQueue from '../../queues/email.js';
-import {
-  REMOVE_AFTER_30_DAYS_OR_150_JOBS,
-  REMOVE_AFTER_7_DAYS_OR_50_JOBS,
-} from '../../helpers/remove-job-configuration.js';
-
-const createUser = async (_parent, params, context) => {
-  context.currentUser.can('create', 'User');
-
-  const { fullName, email } = params.input;
-
-  const existingUser = await User.query().findOne({
-    email: email.toLowerCase(),
-  });
-
-  if (existingUser) {
-    throw new Error('User already exists!');
-  }
-
-  const userPayload = {
-    fullName,
-    email,
-    status: 'invited',
-  };
-
-  try {
-    context.currentUser.can('update', 'Role');
-
-    userPayload.roleId = params.input.role.id;
-  } catch {
-    // void
-    const role = await Role.findAdmin();
-    userPayload.roleId = role.id;
-  }
-
-  const user = await User.query().insert(userPayload);
-
-  await user.generateInvitationToken();
-
-  const jobName = `Invitation Email - ${user.id}`;
-  const acceptInvitationUrl = `${appConfig.webAppUrl}/accept-invitation?token=${user.invitationToken}`;
-
-  const jobPayload = {
-    email: user.email,
-    subject: 'You are invited!',
-    template: 'invitation-instructions',
-    params: {
-      fullName: user.fullName,
-      acceptInvitationUrl,
-    },
-  };
-
-  const jobOptions = {
-    removeOnComplete: REMOVE_AFTER_7_DAYS_OR_50_JOBS,
-    removeOnFail: REMOVE_AFTER_30_DAYS_OR_150_JOBS,
-  };
-
-  await emailQueue.add(jobName, jobPayload, jobOptions);
-
-  return { user, acceptInvitationUrl };
-};
-
-export default createUser;

packages/backend/src/graphql/mutations/delete-app-auth-client.ee.js

@@ -1,16 +0,0 @@
-import AppAuthClient from '../../models/app-auth-client';
-
-const deleteAppAuthClient = async (_parent, params, context) => {
-  context.currentUser.can('delete', 'App');
-
-  await AppAuthClient.query()
-    .delete()
-    .findOne({
-      id: params.input.id,
-    })
-    .throwIfNotFound();
-
-  return;
-};
-
-export default deleteAppAuthClient;

packages/backend/src/graphql/mutations/delete-current-user.ee.js

@@ -1,58 +0,0 @@
-import { Duration } from 'luxon';
-import deleteUserQueue from '../../queues/delete-user.ee.js';
-import flowQueue from '../../queues/flow.js';
-import Flow from '../../models/flow.js';
-import ExecutionStep from '../../models/execution-step.js';
-import appConfig from '../../config/app.js';
-
-const deleteCurrentUser = async (_parent, params, context) => {
-  const id = context.currentUser.id;
-
-  const flows = await context.currentUser.$relatedQuery('flows').where({
-    active: true,
-  });
-
-  const repeatableJobs = await flowQueue.getRepeatableJobs();
-
-  for (const flow of flows) {
-    const job = repeatableJobs.find((job) => job.id === flow.id);
-
-    if (job) {
-      await flowQueue.removeRepeatableByKey(job.key);
-    }
-  }
-
-  const executionIds = (
-    await context.currentUser
-      .$relatedQuery('executions')
-      .select('executions.id')
-  ).map((execution) => execution.id);
-  const flowIds = flows.map((flow) => flow.id);
-
-  await ExecutionStep.query().delete().whereIn('execution_id', executionIds);
-  await context.currentUser.$relatedQuery('executions').delete();
-  await context.currentUser.$relatedQuery('steps').delete();
-  await Flow.query().whereIn('id', flowIds).delete();
-  await context.currentUser.$relatedQuery('connections').delete();
-  await context.currentUser.$relatedQuery('identities').delete();
-
-  if (appConfig.isCloud) {
-    await context.currentUser.$relatedQuery('subscriptions').delete();
-    await context.currentUser.$relatedQuery('usageData').delete();
-  }
-
-  await context.currentUser.$query().delete();
-
-  const jobName = `Delete user - ${id}`;
-  const jobPayload = { id };
-  const millisecondsFor30Days = Duration.fromObject({ days: 30 }).toMillis();
-  const jobOptions = {
-    delay: millisecondsFor30Days,
-  };
-
-  await deleteUserQueue.add(jobName, jobPayload, jobOptions);
-
-  return true;
-};
-
-export default deleteCurrentUser;

packages/backend/src/graphql/mutations/delete-flow.js

@@ -1,53 +0,0 @@
-import Flow from '../../models/flow.js';
-import ExecutionStep from '../../models/execution-step.js';
-import globalVariable from '../../helpers/global-variable.js';
-import logger from '../../helpers/logger.js';
-
-const deleteFlow = async (_parent, params, context) => {
-  const conditions = context.currentUser.can('delete', 'Flow');
-  const isCreator = conditions.isCreator;
-  const allFlows = Flow.query();
-  const userFlows = context.currentUser.$relatedQuery('flows');
-  const baseQuery = isCreator ? userFlows : allFlows;
-
-  const flow = await baseQuery
-    .findOne({
-      id: params.input.id,
-    })
-    .throwIfNotFound();
-
-  const triggerStep = await flow.getTriggerStep();
-  const trigger = await triggerStep?.getTriggerCommand();
-
-  if (trigger?.type === 'webhook' && trigger.unregisterHook) {
-    const $ = await globalVariable({
-      flow,
-      connection: await triggerStep.$relatedQuery('connection'),
-      app: await triggerStep.getApp(),
-      step: triggerStep,
-    });
-
-    try {
-      await trigger.unregisterHook($);
-    } catch (error) {
-      // suppress error as the remote resource might have been already deleted
-      logger.debug(
-        `Failed to unregister webhook for flow ${flow.id}: ${error.message}`
-      );
-    }
-  }
-
-  const executionIds = (
-    await flow.$relatedQuery('executions').select('executions.id')
-  ).map((execution) => execution.id);
-
-  await ExecutionStep.query().delete().whereIn('execution_id', executionIds);
-
-  await flow.$relatedQuery('executions').delete();
-  await flow.$relatedQuery('steps').delete();
-  await flow.$query().delete();
-
-  return;
-};
-
-export default deleteFlow;

packages/backend/src/graphql/mutations/delete-step.js

@@ -1,40 +0,0 @@
-import Step from '../../models/step.js';
-
-const deleteStep = async (_parent, params, context) => {
-  const conditions = context.currentUser.can('update', 'Flow');
-  const isCreator = conditions.isCreator;
-  const allSteps = Step.query();
-  const userSteps = context.currentUser.$relatedQuery('steps');
-  const baseQuery = isCreator ? userSteps : allSteps;
-
-  const step = await baseQuery
-    .withGraphFetched('flow')
-    .findOne({
-      'steps.id': params.input.id,
-    })
-    .throwIfNotFound();
-
-  await step.$relatedQuery('executionSteps').delete();
-  await step.$query().delete();
-
-  const nextSteps = await step.flow
-    .$relatedQuery('steps')
-    .where('position', '>', step.position);
-
-  const nextStepQueries = nextSteps.map(async (nextStep) => {
-    await nextStep.$query().patch({
-      position: nextStep.position - 1,
-    });
-  });
-
-  await Promise.all(nextStepQueries);
-
-  step.flow = await step.flow
-    .$query()
-    .withGraphJoined('steps')
-    .orderBy('steps.position', 'asc');
-
-  return step;
-};
-
-export default deleteStep;

packages/backend/src/graphql/mutations/execute-flow.js

@@ -1,28 +0,0 @@
-import testRun from '../../services/test-run.js';
-import Step from '../../models/step.js';
-
-const executeFlow = async (_parent, params, context) => {
-  const conditions = context.currentUser.can('update', 'Flow');
-  const isCreator = conditions.isCreator;
-  const allSteps = Step.query();
-  const userSteps = context.currentUser.$relatedQuery('steps');
-  const baseQuery = isCreator ? userSteps : allSteps;
-
-  const { stepId } = params.input;
-
-  const untilStep = await baseQuery.clone().findById(stepId).throwIfNotFound();
-
-  const { executionStep } = await testRun({ stepId });
-
-  if (executionStep.isFailed) {
-    throw new Error(JSON.stringify(executionStep.errorDetails));
-  }
-
-  await untilStep.$query().patch({
-    status: 'completed',
-  });
-
-  return { data: executionStep.dataOut, step: untilStep };
-};
-
-export default executeFlow;

packages/backend/src/graphql/mutations/generate-auth-url.js

@@ -1,30 +0,0 @@
-import globalVariable from '../../helpers/global-variable.js';
-import App from '../../models/app.js';
-
-const generateAuthUrl = async (_parent, params, context) => {
-  context.currentUser.can('create', 'Connection');
-
-  const connection = await context.currentUser
-    .$relatedQuery('connections')
-    .findOne({
-      id: params.input.id,
-    })
-    .throwIfNotFound();
-
-  if (!connection.formattedData) {
-    return null;
-  }
-
-  const authInstance = (
-    await import(`../../apps/${connection.key}/auth/index.js`)
-  ).default;
-
-  const app = await App.findOneByKey(connection.key);
-
-  const $ = await globalVariable({ connection, app });
-  await authInstance.generateAuthUrl($);
-
-  return connection.formattedData;
-};
-
-export default generateAuthUrl;

packages/backend/src/graphql/mutations/reset-connection.js

@@ -1,22 +0,0 @@
-const resetConnection = async (_parent, params, context) => {
-  context.currentUser.can('create', 'Connection');
-
-  let connection = await context.currentUser
-    .$relatedQuery('connections')
-    .findOne({
-      id: params.input.id,
-    })
-    .throwIfNotFound();
-
-  if (!connection.formattedData) {
-    return null;
-  }
-
-  connection = await connection.$query().patchAndFetch({
-    formattedData: { screenName: connection.formattedData.screenName },
-  });
-
-  return connection;
-};
-
-export default resetConnection;

packages/backend/src/graphql/mutations/update-connection.js

@@ -1,33 +0,0 @@
-import AppAuthClient from '../../models/app-auth-client.js';
-
-const updateConnection = async (_parent, params, context) => {
-  context.currentUser.can('create', 'Connection');
-
-  let connection = await context.currentUser
-    .$relatedQuery('connections')
-    .findOne({
-      id: params.input.id,
-    })
-    .throwIfNotFound();
-
-  let formattedData = params.input.formattedData;
-
-  if (params.input.appAuthClientId) {
-    const appAuthClient = await AppAuthClient.query()
-      .findById(params.input.appAuthClientId)
-      .throwIfNotFound();
-
-    formattedData = appAuthClient.formattedAuthDefaults;
-  }
-
-  connection = await connection.$query().patchAndFetch({
-    formattedData: {
-      ...connection.formattedData,
-      ...formattedData,
-    },
-  });
-
-  return connection;
-};
-
-export default updateConnection;

packages/backend/src/graphql/mutations/update-current-user.js

@@ -1,11 +0,0 @@
-const updateCurrentUser = async (_parent, params, context) => {
-  const user = await context.currentUser.$query().patchAndFetch({
-    email: params.input.email,
-    password: params.input.password,
-    fullName: params.input.fullName,
-  });
-
-  return user;
-};
-
-export default updateCurrentUser;

packages/backend/src/graphql/mutations/update-flow-status.js

@@ -1,91 +0,0 @@
-import Flow from '../../models/flow.js';
-import flowQueue from '../../queues/flow.js';
-import {
-  REMOVE_AFTER_30_DAYS_OR_150_JOBS,
-  REMOVE_AFTER_7_DAYS_OR_50_JOBS,
-} from '../../helpers/remove-job-configuration.js';
-import globalVariable from '../../helpers/global-variable.js';
-
-const JOB_NAME = 'flow';
-const EVERY_15_MINUTES_CRON = '*/15 * * * *';
-
-const updateFlowStatus = async (_parent, params, context) => {
-  const conditions = context.currentUser.can('publish', 'Flow');
-  const isCreator = conditions.isCreator;
-  const allFlows = Flow.query();
-  const userFlows = context.currentUser.$relatedQuery('flows');
-  const baseQuery = isCreator ? userFlows : allFlows;
-
-  let flow = await baseQuery
-    .clone()
-    .findOne({
-      id: params.input.id,
-    })
-    .throwIfNotFound();
-
-  const newActiveValue = params.input.active;
-
-  if (flow.active === newActiveValue) {
-    return flow;
-  }
-
-  const triggerStep = await flow.getTriggerStep();
-
-  if (triggerStep.status === 'incomplete') {
-    throw flow.IncompleteStepsError;
-  }
-
-  const trigger = await triggerStep.getTriggerCommand();
-  const interval = trigger.getInterval?.(triggerStep.parameters);
-  const repeatOptions = {
-    pattern: interval || EVERY_15_MINUTES_CRON,
-  };
-
-  if (trigger.type === 'webhook') {
-    const $ = await globalVariable({
-      flow,
-      connection: await triggerStep.$relatedQuery('connection'),
-      app: await triggerStep.getApp(),
-      step: triggerStep,
-      testRun: false,
-    });
-
-    if (newActiveValue && trigger.registerHook) {
-      await trigger.registerHook($);
-    } else if (!newActiveValue && trigger.unregisterHook) {
-      await trigger.unregisterHook($);
-    }
-  } else {
-    if (newActiveValue) {
-      flow = await flow.$query().patchAndFetch({
-        publishedAt: new Date().toISOString(),
-      });
-
-      const jobName = `${JOB_NAME}-${flow.id}`;
-
-      await flowQueue.add(
-        jobName,
-        { flowId: flow.id },
-        {
-          repeat: repeatOptions,
-          jobId: flow.id,
-          removeOnComplete: REMOVE_AFTER_7_DAYS_OR_50_JOBS,
-          removeOnFail: REMOVE_AFTER_30_DAYS_OR_150_JOBS,
-        }
-      );
-    } else {
-      const repeatableJobs = await flowQueue.getRepeatableJobs();
-      const job = repeatableJobs.find((job) => job.id === flow.id);
-
-      await flowQueue.removeRepeatableByKey(job.key);
-    }
-  }
-
-  flow = await flow.$query().withGraphFetched('steps').patchAndFetch({
-    active: newActiveValue,
-  });
-
-  return flow;
-};
-
-export default updateFlowStatus;

packages/backend/src/graphql/mutations/update-flow.js

@@ -1,18 +0,0 @@
-const updateFlow = async (_parent, params, context) => {
-  context.currentUser.can('update', 'Flow');
-
-  let flow = await context.currentUser
-    .$relatedQuery('flows')
-    .findOne({
-      id: params.input.id,
-    })
-    .throwIfNotFound();
-
-  flow = await flow.$query().patchAndFetch({
-    name: params.input.name,
-  });
-
-  return flow;
-};
-
-export default updateFlow;

packages/backend/src/graphql/mutations/update-role.ee.js

@@ -1,62 +0,0 @@
-import Role from '../../models/role.js';
-import Permission from '../../models/permission.js';
-import permissionCatalog from '../../helpers/permission-catalog.ee.js';
-
-const updateRole = async (_parent, params, context) => {
-  context.currentUser.can('update', 'Role');
-
-  const { id, name, description, permissions } = params.input;
-
-  const role = await Role.query().findById(id).throwIfNotFound();
-
-  try {
-    const updatedRole = await Role.transaction(async (trx) => {
-      await role.$relatedQuery('permissions', trx).delete();
-
-      if (permissions?.length) {
-        const sanitizedPermissions = permissions
-          .filter((permission) => {
-            const { action, subject, conditions } = permission;
-
-            const relevantAction = permissionCatalog.actions.find(
-              (actionCatalogItem) => actionCatalogItem.key === action
-            );
-            const validSubject = relevantAction.subjects.includes(subject);
-            const validConditions = conditions.every((condition) => {
-              return !!permissionCatalog.conditions.find(
-                (conditionCatalogItem) => conditionCatalogItem.key === condition
-              );
-            });
-
-            return validSubject && validConditions;
-          })
-          .map((permission) => ({
-            ...permission,
-            roleId: role.id,
-          }));
-
-        await Permission.query().insert(sanitizedPermissions);
-      }
-
-      await role.$query(trx).patch({
-        name,
-        description,
-      });
-
-      return await Role.query(trx)
-        .leftJoinRelated({
-          permissions: true,
-        })
-        .withGraphFetched({
-          permissions: true,
-        })
-        .findById(id);
-    });
-
-    return updatedRole;
-  } catch (err) {
-    throw new Error('The role could not be updated!');
-  }
-};
-
-export default updateRole;

packages/backend/src/graphql/mutations/update-step.js

@@ -1,68 +0,0 @@
-import App from '../../models/app.js';
-import Step from '../../models/step.js';
-import Connection from '../../models/connection.js';
-
-const updateStep = async (_parent, params, context) => {
-  const { isCreator } = context.currentUser.can('update', 'Flow');
-  const userSteps = context.currentUser.$relatedQuery('steps');
-  const allSteps = Step.query();
-  const baseQuery = isCreator ? userSteps : allSteps;
-
-  const { input } = params;
-
-  let step = await baseQuery
-    .findOne({
-      'steps.id': input.id,
-      flow_id: input.flow.id,
-    })
-    .throwIfNotFound();
-
-  if (input.connection.id) {
-    let canSeeAllConnections = false;
-    try {
-      const conditions = context.currentUser.can('read', 'Connection');
-
-      canSeeAllConnections = !conditions.isCreator;
-    } catch {
-      // void
-    }
-
-    const userConnections = context.currentUser.$relatedQuery('connections');
-    const allConnections = Connection.query();
-    const baseConnectionsQuery = canSeeAllConnections
-      ? allConnections
-      : userConnections;
-
-    const connection = await baseConnectionsQuery
-      .clone()
-      .findById(input.connection?.id);
-
-    if (!connection) {
-      throw new Error('The connection does not exist!');
-    }
-  }
-
-  if (step.isTrigger) {
-    await App.checkAppAndTrigger(input.appKey, input.key);
-  }
-
-  if (step.isAction) {
-    await App.checkAppAndAction(input.appKey, input.key);
-  }
-
-  step = await Step.query()
-    .patchAndFetchById(input.id, {
-      key: input.key,
-      appKey: input.appKey,
-      connectionId: input.connection.id,
-      parameters: input.parameters,
-      status: 'incomplete'
-    })
-    .withGraphFetched('connection');
-
-  await step.updateWebhookUrl();
-
-  return step;
-};
-
-export default updateStep;

packages/backend/src/graphql/mutations/update-user.ee.js

@@ -1,27 +0,0 @@
-import User from '../../models/user.js';
-
-const updateUser = async (_parent, params, context) => {
-  context.currentUser.can('update', 'User');
-
-  const userPayload = {
-    email: params.input.email,
-    fullName: params.input.fullName,
-  };
-
-  try {
-    context.currentUser.can('update', 'Role');
-
-    userPayload.roleId = params.input.role.id;
-  } catch {
-    // void
-  }
-
-  const user = await User.query().patchAndFetchById(
-    params.input.id,
-    userPayload
-  );
-
-  return user;
-};
-
-export default updateUser;

packages/backend/src/graphql/mutations/verify-connection.js

@@ -1,29 +0,0 @@
-import App from '../../models/app.js';
-import globalVariable from '../../helpers/global-variable.js';
-
-const verifyConnection = async (_parent, params, context) => {
-  context.currentUser.can('create', 'Connection');
-
-  let connection = await context.currentUser
-    .$relatedQuery('connections')
-    .findOne({
-      id: params.input.id,
-    })
-    .throwIfNotFound();
-
-  const app = await App.findOneByKey(connection.key);
-  const $ = await globalVariable({ connection, app });
-  await app.auth.verifyCredentials($);
-
-  connection = await connection.$query().patchAndFetch({
-    verified: true,
-    draft: false,
-  });
-
-  return {
-    ...connection,
-    app,
-  };
-};
-
-export default verifyConnection;

packages/backend/src/graphql/resolvers.js

@@ -1,7 +0,0 @@
-import mutationResolvers from './mutation-resolvers.js';
-
-const resolvers = {
-  Mutation: mutationResolvers,
-};
-
-export default resolvers;