Latest lockfile

Co-authored-by: github-actions[bot] <github-actions[bot]@users.noreply.github.com>

.changeset/config.json

@@ -2,17 +2,10 @@
   "$schema": "https://unpkg.com/@changesets/config@2.2.0/schema.json",
   "changelog": "@changesets/cli/changelog",
   "commit": false,
-  "fixed": [],
+  "fixed": [["@trigger.dev/*"]],
   "linked": [],
   "access": "public",
   "baseBranch": "main",
   "updateInternalDependencies": "patch",
-  "ignore": [
-    "wss",
-    "webapp",
-    "integrations",
-    "emails",
-    "internal-cli",
-    "integration-catalog"
-  ]
+  "ignore": ["webapp", "emails", "@trigger.dev/database"]
 }

.docker/pizzly-server.env.example

@@ -1,8 +0,0 @@
-# You need to stop and re-run docker to switch, `pnpm run docker:db`
-# To login using GitHub and connect via OAuth with most integrations
-AUTH_CALLBACK_URL=http://localhost:3004/oauth/callback
-# To connect with Slack
-# AUTH_CALLBACK_URL=https://<ngrok subdomain>.eu.ngrok.io/oauth/callback
-
-# You only need to use this locally if you specify PIZZLY_SECRET_KEY in the webapp .env file
-# PIZZLY_SECRET_KEY=<secret_key>

.dockerignore

@@ -3,6 +3,7 @@
 .github
 # editor
 .idea
+.vscode
 # dependencies
 node_modules
 .pnp
@@ -34,4 +35,11 @@ cypress/screenshots
 cypress/videos
 
 apps/**/styles/tailwind.css
-packages/**/styles/tailwind.css
+packages/**/styles/tailwind.css
+
+.changeset
+examples
+CHANGESETS.md
+CONTRIBUTING.md
+README.md
+LICENSE

.env.example

@@ -0,0 +1,36 @@
+# YOU MIGHT LIKE TO MODIFY THESE VARIABLES
+SESSION_SECRET=abcdef1234
+MAGIC_LINK_SECRET=abcdef1234
+ENCRYPTION_KEY=ae13021afef0819c3a307ad487071c06 # Must be a random 16 byte hex string. You can generate an encryption key by running `openssl rand -hex 16` in your terminal
+LOGIN_ORIGIN=http://localhost:3030
+DATABASE_URL=postgresql://postgres:postgres@localhost:5432/postgres?schema=public
+# This sets the URL used for direct connections to the database and should only be needed in limited circumstances
+# See: https://www.prisma.io/docs/reference/api-reference/prisma-schema-reference#fields:~:text=the%20shadow%20database.-,directUrl,-No
+DIRECT_URL=${DATABASE_URL}
+REMIX_APP_PORT=3030
+APP_ENV=development
+APP_ORIGIN=http://localhost:3030
+NODE_ENV=development
+
+# OPTIONAL VARIABLES
+# This is used for logging in via GitHub. You can leave these commented out if you don't want to use GitHub for authentication.
+# AUTH_GITHUB_CLIENT_ID=
+# AUTH_GITHUB_CLIENT_SECRET=
+
+# Resend is an email service used for signing in to Trigger.dev via a Magic Link.
+# Emails will print to the console if you leave these commented out
+### Visit https://resend.com, create an account and get your API key. Then insert it below along with your From and Reply To email addresses. Visit https://resend.com/docs for more information.
+# RESEND_API_KEY=<api_key>
+# FROM_EMAIL=
+# REPLY_TO_EMAIL=
+
+# CLOUD VARIABLES
+POSTHOG_PROJECT_KEY=
+PLAIN_API_KEY= 
+CLOUD_AIRTABLE_CLIENT_ID=
+CLOUD_AIRTABLE_CLIENT_SECRET=
+CLOUD_GITHUB_CLIENT_ID=
+CLOUD_GITHUB_CLIENT_SECRET=
+CLOUD_SLACK_APP_HOST=
+CLOUD_SLACK_CLIENT_ID=
+CLOUD_SLACK_CLIENT_SECRET= 

.github/workflows/publish.yml

@@ -0,0 +1,210 @@
+name: 🚀 Publish Trigger.dev Docker
+
+on:
+  push:
+    branches:
+      - main
+    tags:
+      - "v.docker.*"
+    paths:
+      - ".github/workflows/publish.yml"
+      - "packages/**"
+      - "!packages/**/*.md"
+      - "!packages/**/*.eslintrc"
+      - "apps/**"
+      - "!apps/**/*.md"
+      - "!apps/**/*.eslintrc"
+      - "integrations/**"
+      - "!integrations/**/*.md"
+      - "!integrations/**/*.eslintrc"
+      - "pnpm-lock.yaml"
+      - "pnpm-workspace.yaml"
+      - "turbo.json"
+      - "docker/Dockerfile"
+      - "docker/scripts/**"
+
+permissions:
+  id-token: write
+  packages: write
+  contents: read
+
+concurrency:
+  group: ${{ github.workflow }}-${{ github.ref }}
+
+env:
+  AWS_REGION: us-east-1
+
+jobs:
+  typecheck:
+    name: ʦ TypeScript
+    runs-on: buildjet-4vcpu-ubuntu-2204
+    steps:
+      - name: ⬇️ Checkout repo
+        uses: actions/checkout@v3
+        with:
+          fetch-depth: 0
+
+      - name: ⎔ Setup pnpm
+        uses: pnpm/action-setup@v2.2.4
+        with:
+          version: 7.18
+
+      - name: ⎔ Setup node
+        uses: buildjet/setup-node@v3
+        with:
+          node-version: 18
+          cache: "pnpm"
+
+      - name: 📥 Download deps
+        run: pnpm install --frozen-lockfile
+
+      - name: 📀 Generate Prisma Client
+        run: pnpm run generate
+
+      - name: 🔎 Type check
+        run: pnpm run typecheck --filter webapp
+
+  unitTests:
+    name: Unit Tests
+    runs-on: buildjet-4vcpu-ubuntu-2204
+    steps:
+      - name: ⬇️ Checkout repo
+        uses: actions/checkout@v3
+        with:
+          fetch-depth: 0
+
+      - name: ⎔ Setup pnpm
+        uses: pnpm/action-setup@v2.2.4
+        with:
+          version: 7.18
+
+      - name: ⎔ Setup node
+        uses: buildjet/setup-node@v3
+        with:
+          node-version: 18
+          cache: "pnpm"
+
+      - name: 📥 Download deps
+        run: pnpm install --frozen-lockfile
+
+      - name: Run Unit Tests
+        run: |
+          pnpm run test
+
+  e2e:
+    name: e2e Tests
+    runs-on: buildjet-4vcpu-ubuntu-2204
+    steps:
+      - name: ⬇️ Checkout repo
+        uses: actions/checkout@v3
+        with:
+          fetch-depth: 0
+
+      - name: ⎔ Setup pnpm
+        uses: pnpm/action-setup@v2.2.4
+        with:
+          version: 7.18
+
+      - name: ⎔ Setup node
+        uses: buildjet/setup-node@v3
+        with:
+          node-version: 18
+          cache: "pnpm"
+
+      - name: 📥 Download deps
+        run: pnpm install --frozen-lockfile
+
+      - name: Install Playwright Browsers
+        run: npx playwright install --with-deps
+
+      - name: Run Playwright tests
+        run: |
+          # Setup environment variables
+          cp ./.env.example ./.env
+          cp ./examples/nextjs-test/.env.example ./examples/nextjs-test/.env.local
+
+          # Build packages
+          pnpm run build --filter @examples/nextjs-test^...
+          pnpm --filter @trigger.dev/database generate
+
+          # Move trigger-cli bin to correct place
+          pnpm install --frozen-lockfile
+
+          # Execute tests
+          pnpm run docker
+          pnpm run db:migrate
+          pnpm run db:seed
+          pnpm run test:e2e
+
+          # Cleanup
+          pnpm run docker:stop
+
+      - name: Upload Playwright report
+        uses: actions/upload-artifact@v3
+        if: always()
+        with:
+          name: playwright-report
+          path: playwright-report/
+          retention-days: 30
+
+  publish:
+    needs: [typecheck, unitTests, e2e]
+    runs-on: buildjet-4vcpu-ubuntu-2204
+    outputs:
+      version: ${{ steps.get_version.outputs.version }}
+      short_sha: ${{ steps.get_commit.outputs.sha_short }}
+    steps:
+      - name: ⬇️ Checkout repo
+        uses: actions/checkout@v3
+
+      - name: 🆚 Get the version
+        id: get_version
+        run: |
+          IMAGE_TAG="${GITHUB_REF#refs/tags/}"
+          if [[ $GITHUB_REF == refs/tags/* ]]; then
+            if [[ $IMAGE_TAG == v.docker.* ]]; then
+              ORIGINAL_VERSION="${IMAGE_TAG#v.docker.}"
+              IMAGE_TAG="v${ORIGINAL_VERSION}"
+            fi
+            echo "IMAGE_TAG=${IMAGE_TAG}"
+          elif [[ $GITHUB_REF == refs/heads/* ]]; then
+            IMAGE_TAG="${GITHUB_REF#refs/heads/}"
+            echo "IMAGE_TAG=${IMAGE_TAG}"
+          else
+            echo "Invalid reference: ${GITHUB_REF}"
+            exit 1
+          fi
+          echo "::set-output name=version::${IMAGE_TAG}"
+      - name: 🔢 Get the commit hash
+        id: get_commit
+        run: |
+          echo ::set-output name=sha_short::$(echo ${{ github.sha }} | cut -c1-7)
+
+      - name: 🐳 Build Docker Image
+        run: |
+          docker build -t release_build_image -f ./docker/Dockerfile .
+
+      - name: 🐙 Login to GitHub Container Registry
+        uses: docker/login-action@v2
+        with:
+          registry: ghcr.io
+          username: ${{ github.repository_owner }}
+          password: ${{ secrets.GITHUB_TOKEN }}
+
+      - name: 🐙 Push to GitHub Container Registry
+        run: |
+          docker tag release_build_image $REGISTRY/$REPOSITORY:$IMAGE_TAG
+          docker push $REGISTRY/$REPOSITORY:$IMAGE_TAG
+        env:
+          REGISTRY: ghcr.io/triggerdotdev
+          REPOSITORY: trigger.dev
+          IMAGE_TAG: ${{ steps.get_version.outputs.version }}
+
+      - name: 🐙 Push 'latest' to GitHub Container Registry
+        if: startsWith(github.ref, 'refs/tags/')
+        run: |
+          docker tag release_build_image $REGISTRY/$REPOSITORY:latest
+          docker push $REGISTRY/$REPOSITORY:latest
+        env:
+          REGISTRY: ghcr.io/triggerdotdev
+          REPOSITORY: trigger.dev

.github/workflows/release.yml

@@ -0,0 +1,77 @@
+name: 🦋 Changesets Release
+
+on:
+  push:
+    branches:
+      - main
+    paths:
+      - ".github/workflows/release.yml"
+      - "packages/**"
+      - "!packages/**/*.md"
+      - "changesets/**"
+      - "integrations/**"
+      - "!integrations/**/*.md"
+      - "pnpm-lock.yaml"
+      - "pnpm-workspace.yaml"
+      - "turbo.json"
+
+jobs:
+  release:
+    name: 🦋 Changesets Release
+    runs-on: buildjet-4vcpu-ubuntu-2204
+    if: |
+      github.repository == 'triggerdotdev/trigger.dev'
+    outputs:
+      published_packages: ${{ steps.changesets.outputs.publishedPackages }}
+      published: ${{ steps.changesets.outputs.published }}
+    steps:
+      - name: 🛑 Cancel Previous Runs
+        uses: styfle/cancel-workflow-action@0.11.0
+
+      - name: ⬇️ Checkout repo
+        uses: actions/checkout@v3
+        with:
+          fetch-depth: 0
+
+      - name: ⎔ Setup pnpm
+        uses: pnpm/action-setup@v2.2.4
+        with:
+          version: 7.18
+
+      - name: ⎔ Setup node
+        uses: buildjet/setup-node@v3
+        with:
+          node-version: 18
+          cache: "pnpm"
+
+      - name: 📥 Download deps
+        run: pnpm install --frozen-lockfile
+
+      - name: 📀 Generate Prisma Client
+        run: pnpm run generate
+
+      - name: 🔎 Type check
+        run: pnpm run typecheck
+
+      - name: 🔐 Setup npm auth
+        run: |
+          echo "registry=https://registry.npmjs.org" >> ~/.npmrc
+          echo "//registry.npmjs.org/:_authToken=${{ secrets.NPM_TOKEN }}" >> ~/.npmrc
+
+        # This action has two responsibilities. The first time the workflow runs
+        # (initial push to the `main` branch) it will create a new branch and
+        # then open a PR with the related changes for the new version. After the
+        # PR is merged, the workflow will run again and this action will build +
+        # publish to npm.
+      - name: 🚀 PR / Publish
+        id: changesets
+        uses: changesets/action@v1
+        with:
+          version: pnpm run changeset:version
+          commit: "chore: Update version for release"
+          title: "chore: Update version for release"
+          publish: pnpm run changeset:release
+          createGithubReleases: false
+        env:
+          GITHUB_TOKEN: ${{ secrets.GITHUB_TOKEN }}
+          NPM_TOKEN: ${{ secrets.NPM_TOKEN }}

.gitignore

@@ -45,4 +45,10 @@ yarn-error.log*
 .output
 apps/**/public/build
 .tests-container-id.txt
-.sentryclirc
+.sentryclirc
+.buildt
+
+**/tmp/
+/test-results/
+/playwright-report/
+/playwright/.cache/

.infisical.json

@@ -1 +1 @@
-{"workspaceId":"63e5e42daf9a537ba8d9503c"}
+{ "workspaceId": "63e5e42daf9a537ba8d9503c" }

.npmrc

@@ -1 +1,2 @@
-link-workspace-packages=false
+link-workspace-packages=false
+public-hoist-pattern[]=*prisma*

.nvmrc

@@ -1 +1 @@
-v16.19.0
+v18.12.1

.prettierignore

@@ -0,0 +1,11 @@
+node_modules
+.env
+.env.local
+pnpm-lock.yaml
+tailwind.css
+.babelrc.json
+**/.react-email/
+**/storybook-static/
+**/.changeset/
+**/build/
+**/dist/

.vscode/launch.json

@@ -5,19 +5,12 @@
   "version": "0.2.0",
   "configurations": [
     {
-      "command": "pnpm run idev --filter webapp",
+      "command": "pnpm run dev --filter webapp",
       "name": "Run webapp",
       "request": "launch",
       "type": "node-terminal",
       "cwd": "${workspaceFolder}"
     },
-    {
-      "command": "pnpm run dev --filter integrations",
-      "name": "Run integrations",
-      "request": "launch",
-      "type": "node-terminal",
-      "cwd": "${workspaceFolder}"
-    },
     {
       "type": "chrome",
       "request": "launch",

.vscode/trigger.code-workspace

@@ -1,19 +0,0 @@
-{
-  "folders": [
-    {
-      "name": "trigger.dev",
-      "path": "../"
-    },
-    {
-      "name": "Webapp",
-      "path": "../apps/webapp"
-    },
-    {
-      "name": "Integrations",
-      "path": "../apps/integrations"
-    }
-  ],
-  "settings": {
-    "vitest.commandLine": "pnpm exec vitest"
-  }
-}

.warp/triggerdotdev.yaml.example

@@ -1,70 +0,0 @@
-# Warp Launch Configuration
-#
-#
-# Use this to start a certain configuration of windows, tabs, and panes
-# Open the launch configuration palette to access and open any launch configuration
-#
-# This file defines your launch configuration
-# More on how to do so here:
-# https://docs.warp.dev/features/session-management/launch-configurations
-#
-# All launch configurations are stored under ~/.warp/launch_configurations/
-# Edit them anytime!
-#
-# You can also add commands that run on-start for your launch configurations like so:
-# ---
-# name: Example with Command
-# windows:
-#  - tabs:
-#      - layout:
-#          cwd: /Users/warp-user/project
-#          commands:
-#            - exec: code .
-
----
-name: Triggerdotdev
-windows:
-  - tabs:
-      - title: webapp
-        layout:
-          split_direction: vertical
-          panes:
-            - cwd: /Users/eric/code/triggerdotdev/trigger.dev
-              commands:
-                - exec: pnpm run build --filter webapp
-                - exec: pnpm run i-dev --filter webapp
-            - cwd: /Users/eric/code/triggerdotdev/trigger.dev/apps/webapp
-      - title: integrations
-        layout:
-          split_direction: vertical
-          panes:
-            - cwd: /Users/eric/code/triggerdotdev/trigger.dev
-              commands:
-                - exec: pnpm run dev --filter integrations
-            - cwd: /Users/eric/code/triggerdotdev/trigger.dev/apps/integrations
-      - title: ngrok
-        layout:
-          split_direction: horizontal
-          panes:
-            - cwd: /Users/eric/code/triggerdotdev/trigger.dev
-              commands:
-                - exec: ./scripts/proxy-webapp.sh <your-trigger-dev>
-            - cwd: /Users/eric/code/triggerdotdev/trigger.dev
-              commands:
-                - exec: ./scripts/proxy-pizzly.sh <your-pizzly-dev>
-      - title: wss and examples
-        layout:
-          split_direction: horizontal
-          panes:
-            - cwd: /Users/eric/code/triggerdotdev/trigger.dev/apps/wss
-              commands:
-                - exec: LOG_LEVEL=debug pnpm run dev
-            - cwd: /Users/eric/code/triggerdotdev/trigger.dev/examples
-      - title: emails
-        layout:
-          split_direction: horizontal
-          panes:
-            - cwd: /Users/eric/Work/Git/APIHero/trigger.dev/packages/emails
-              commands:
-                - exec: pnpm run dev
-            - cwd: /Users/eric/Work/Git/APIHero/trigger.dev/packages/emails

CHANGESETS.md

@@ -4,22 +4,22 @@ Trigger.dev uses [changesets](https://github.com/changesets/changesets) to manag
 
 ## Adding a changeset
 
-To add a changeset, use `pnpm run changeset:add` and follow the instructions [here](https://github.com/changesets/changesets/blob/main/docs/adding-a-changeset.md). Please only ever select one of our public packages when adding a changeset, which currently are:
+To add a changeset, use `pnpm run changeset:add` and follow the instructions [here](https://github.com/changesets/changesets/blob/main/docs/adding-a-changeset.md). Please only ever select one of our public packages when adding a changeset.
 
-- `@trigger.dev/sdk`
-- `@trigger.dev/integration-sdk`
-- `@trigger.dev/github`
-- `@trigger.dev/slack`
-- `@trigger.dev/shopify`
-- `@trigger.dev/resend`
-
-## Release instructions
+## Release instructions (local only)
 
 Based on the instructions [here](https://github.com/changesets/changesets/blob/main/docs/intro-to-using-changesets.md)
 
 1. Run `pnpm run changeset:version`
 2. Run `pnpm run changeset:release`
 
+## Release instructions (CI)
+
+Please follow the best-practice of adding changesets in the same commit as the code making the change with `pnpm run changeset:add`, as it will allow our release.yml CI workflow to function properly:
+
+- Anytime new changesets are added in a commit in the `main` branch, the [release.yml](./.github/workflows/release.yml) workflow will run and will automatically create/update a PR with a fresh run of `pnpm run changeset:version`.
+- When the version PR is merged into `main`, the release.yml workflow will automatically run `pnpm run changeset:release` to build and release packages to npm.
+
 ## Pre-release instructions
 
 1. Add changesets as usual `pnpm run changeset:add`

CONTRIBUTING.md

@@ -0,0 +1,293 @@
+# Contributing to Trigger.dev
+
+Thank you for taking the time to contribute to Trigger.dev. Your involvement is not just welcomed, but we encourage it! 🚀
+
+Please take some time to read this guide to understand contributing best practices for Trigger.dev.
+
+Thank you for helping us make Trigger.dev even better! 🤩
+
+## Developing
+
+The development branch is `main`. This is the branch that all pull
+requests should be made against. The changes on the `main`
+branch are tagged into a release monthly.
+
+### Prerequisites
+
+- [Node.js](https://nodejs.org/en) version >=16.x
+- [pnpm package manager](https://pnpm.io/installation) version 7
+- [Docker](https://www.docker.com/get-started/)
+
+### Setup
+
+1. Clone the repo into a public GitHub repository or [fork the repo](https://github.com/triggerdotdev/trigger.dev/fork). If you plan to distribute the code, keep the source code public to comply with the [Apache Licence 2.0](https://github.com/triggerdotdev/trigger.dev/blob/main/LICENSE).
+
+   ```
+   git clone https://github.com/triggerdotdev/trigger.dev.git
+   ```
+
+   > If you are on windows, run the following command on gitbash with admin privileges:
+   > `git clone -c core.symlinks=true https://github.com/triggerdotdev/trigger.dev.git`
+
+2. Navigate to the project folder
+   ```
+   cd trigger.dev
+   ```
+3. Install the required packages using pnpm.
+   ```
+   pnpm i
+   ```
+4. Create your `.env` file
+   ```
+   cp .env.example .env
+   ```
+5. Open it and generate a new value for `ENCRYPTION_KEY`:
+
+   `ENCRYPTION_KEY` is used to two-way encrypt OAuth access tokens and so you'll probably want to actually generate a unique value, and it must be a random 16 byte hex string. You can generate one with the following command:
+
+   ```sh
+   openssl rand -hex 16
+   ```
+
+   Feel free to update `SESSION_SECRET` and `MAGIC_LINK_SECRET` as well using the same method.
+
+6. Start Docker. This starts the required services like Postgres. If this is your first time using Docker, consider going through this [guide](DOCKER_INSTALLATION.md)
+   ```
+   pnpm run docker
+   ```
+7. Migrate the database
+   ```
+   pnpm run db:migrate
+   ```
+8. Build the app
+   ```
+   pnpm run build --filter webapp
+   ```
+9. Run the seed script
+   ```
+   pnpm run db:seed
+   ```
+10. Run the app. See the section below.
+
+## Running
+
+1. You can run the app with:
+
+   ```
+   pnpm run dev --filter webapp
+   ```
+
+   It should run on port `3030`: [http://localhost:3030](http://localhost:3030/)
+
+2. Once the app is running click the magic link button and enter your email.
+3. Check your terminal, the magic link email should have printed out as following:
+
+   ```sh
+   webapp:dev: Log in to Trigger.dev
+   webapp:dev:
+   webapp:dev: Click here to log in with this magic link
+   webapp:dev: [http://localhost:3030/magic?token=U2FsdGVkX18OvB0JxgaswTLCSbaRz%2FY82TN0EZWhSzFyZYwgG%2BIzKVTkeiaOtWfotPw7F8RwFzCHh53aBpMEu%2B%2B%2FItb%2FcJYh89MSjc3Pz92bevoEjqxSQ%2Ff%2BZbks09JOpqlBbYC3FzGWC8vuSVFBlxqLXxteSDLthZSUaC%2BS2LaA%2BJgp%2BLO7hgjAaC2lXbCHrM7MTgTdXOFt7i0Dvvuwz6%2BWY25RnfomZOPqDsyH0xz8Q2rzPTz0Xu53WSXrZ1hd]
+   webapp:dev:
+   webapp:dev: If you didn't try to log in, you can safely ignore this email.
+   ```
+
+   Paste the magic link shown in your terminal into your browser to login.
+
+## Adding and running migrations
+
+1. Modify packages/database/prisma/schema.prisma file
+2. Change directory to the packages/database folder
+   ```sh
+   cd packages/database
+   ```
+3. Generate the Prisma client
+
+   ```sh
+   pnpm run generate
+   ```
+
+   The above updates the prisma client generated into node_modules/.prisma/client folder. This helps with typing of relevant prisma models. It ensures typescript
+   recognizes fields added or removed from a model and type-checks appropriately.
+
+4. Create and apply the migrations
+
+   ```
+   pnpm run db:migrate:dev
+   ```
+
+   This creates a migration file and executes the migrations against your database and applies changes to the database schema(s)
+
+5. Commit generated migrations as well as changes to the schema.prisma file
+6. If you're using VSCode you may need to restart the Typescript server in the webapp to get updated type inference. Open a TypeScript file, then open the Command Palette (View > Command Palette) and run `TypeScript: Restart TS server`.
+
+## Testing CLI changes
+
+To test CLI changes, follow the steps below:
+
+1. Build the CLI and watch for changes
+
+```sh
+cd packages/cli
+pnpm run dev
+```
+
+2. Open a new Terminal window and run the webapp locally and then create a new project in the dashboard. Copy out the dev API key.
+
+3. Create a new temporary Next.js app in examples directory
+
+```sh
+pnpm create next-app@latest
+```
+
+Follow the prompts to create a TypeScript project using the App Directory.
+
+4. Then once that's finished, add the `@trigger.dev/cli` to the `devDependencies` of the newly created Next.js app's `package.json` file, like so:
+
+```json
+{
+  "devDependencies": { "@trigger.dev/cli": "workspace:*" }
+}
+```
+
+5. Open a new terminal window, navigate into the example, and initialize the CLI:
+
+```sh
+cd examples/your-newly-created-nextjs-project
+pnpm i
+pnpm exec trigger-cli init
+```
+
+6. When prompted, select `self-hosted` and enter `localhost:3030` for your local version of the webapp. When asked for an API key, use the key you copied earlier.
+
+7. Run the CLI
+
+```sh
+pnpm exec trigger-cli dev
+```
+
+8. After running the CLI, start your newly created Next.js project. You should now be able to see the changes.
+
+9. Please remember to delete the temporary project you created after you've tested the changes, and before you raise a PR.
+
+## Running end-to-end webapp tests
+
+To run the end-to-end tests, follow the steps below:
+
+1. Set up environment variables (copy example envs into the correct place)
+
+```sh
+cp ./.env.example ./.env
+cp ./examples/nextjs-test/.env.example ./examples/nextjs-test/.env.local
+```
+
+2. Set up dependencies
+
+```sh
+# Build packages
+pnpm run build --filter @examples/nextjs-test^...
+pnpm --filter @trigger.dev/database generate
+
+# Move trigger-cli bin to correct place
+pnpm install --frozen-lockfile
+
+# Install playwrite browsers (ONE TIME ONLY)
+npx playwright install
+```
+
+3. Set up the database
+
+```sh
+pnpm run docker
+pnpm run db:migrate
+pnpm run db:seed
+```
+
+4. Run the end-to-end tests
+
+```sh
+pnpm run test:e2e
+```
+
+### Cleanup
+
+The end-to-end tests use a `setup` and `teardown` script to seed the database with test data. If the test runner doesn't exit cleanly, then the database can be left in a state where the tests can't run because the `setup` script will try to create data that already exists. If this happens, you can manually delete the `users` and `organizations` from the database using prisma studio:
+
+```sh
+# With the database running (i.e. pnpm run docker)
+pnpm run db:studio
+```
+
+## Add sample jobs
+
+The [examples/jobs-starter](./examples/jobs-starter/) project defines simple jobs you can get started with.
+
+1. `cd` into `examples/jobs-starter`
+2. Create a `.env.local` file with the following content,
+   replacing `[TRIGGER_DEV_API_KEY]` with an actual key:
+
+```env
+TRIGGER_API_KEY=[TRIGGER_DEV_API_KEY]
+TRIGGER_API_URL=http://localhost:3030
+```
+
+`TRIGGER_API_URL` is used to configure the URL for your Trigger.dev instance,
+where the jobs will be registered.
+
+3. Run the `jobs-starter` app:
+
+```sh
+pnpm dev
+```
+
+4. Navigate to your trigger.dev instance ([http://localhost:3030](http://localhost:3030/)), to see the jobs.
+   You can use the test feature to trigger them.
+
+## Making a pull request
+
+**If you get errors, be sure to fix them before committing.**
+
+- Be sure to [check the "Allow edits from maintainers" option](https://docs.github.com/en/pull-requests/collaborating-with-pull-requests/working-with-forks/allowing-changes-to-a-pull-request-branch-created-from-a-fork) while creating you PR.
+- If your PR refers to or fixes an issue, be sure to add `refs #XXX` or `fixes #XXX` to the PR description. Replacing `XXX` with the respective issue number. See more about [Linking a pull request to an issue
+  ](https://docs.github.com/en/issues/tracking-your-work-with-issues/linking-a-pull-request-to-an-issue).
+- Be sure to fill the PR Template accordingly.
+
+## Adding changesets
+
+We use [changesets](https://github.com/changesets/changesets) to manage our package versions and changelogs. If you've never used changesets before, first read [their guide here](https://github.com/changesets/changesets/blob/main/docs/adding-a-changeset.md).
+
+If you are contributing a change to any packages in this monorepo (anything in either the `/packages` or `/integrations` directories), then you will need to add a changeset to your Pull Requests before they can be merged.
+
+To add a changeset, run the following command in the root of the repo
+
+```sh
+pnpm run changeset:add
+```
+
+Here's an example of creating a `patch` changeset for the `@trigger.dev/github` and `@trigger.dev/slack` packages (click to view):
+
+[![asciicast](https://asciinema.org/a/599228.svg)](https://asciinema.org/a/599228)
+
+You will be prompted to select which packages to include in the changeset. Only select the packages that you have made changes for.
+
+Most of the time the changes you'll make are likely to be categorized as patch releases. If you feel like there is the need for a minor or major release of the package based on the changes being made, add the changeset as such and it will be discussed during PR review.
+
+## Troubleshooting
+
+### EADDRINUSE: address already in use :::3030
+
+When receiving the following error message:
+
+```sh
+webapp:dev: Error: listen EADDRINUSE: address already in use :::3030
+```
+
+The process running on port `3030` should be destroyed.
+
+1. Get the `PID` of the process running on PORT `3030`
+   ```sh
+   lsof -i :3030
+   ```
+2. Kill the process
+   ```sh
+   sudo kill -9 <PID>
+   ```

DEPLOYMENT.md

@@ -1,32 +0,0 @@
-# Trigger.dev Deployment Guide
-
-## StreamNative Cloud - Hosted Pulsar
-
-### Generic client credentials
-
-```sh
-snctl auth export-service-account webapp --key-file webapp-credentials.json
-snctl auth export-service-account websocketserver --key-file wss-credentials.json
-```
-
-### Topics
-
-#### Triggers (`persistent://triggerdotdev/workflows/triggers`)
-
-Events that trigger workflows to run. These are sent by the "platform" and read by the Web Socket Servers, which then coordinate with the hosts for running the workflows
-
-#### Run Commands (`persistent://triggerdotdev/workflows/run-commands`)
-
-These are events that come from hosts and are published by the Web Socket Servers, e.g. Sending Integration Requests, Sending Logs, Initializing a Delay
-
-#### Run Command Responses (`persistent://triggerdotdev/workflows/run-command-responses`)
-
-These are events that come from the platform and are read by the Web Socket Servers, to resolve or reject a previous Run Command
-
-#### Integration Requests (`persistent://triggerdotdev/queues/integration-requests`)
-
-This is an internal queue used by the platform to perform integration requests, and retry them.
-
-#### App Task Queue (`persistent://triggerdotdev/queues/background-tasks`)
-
-This is an internal queue used by the platform to do tasks in a queue. Basically a background job system.

DEVELOPMENT.md

@@ -1,231 +0,0 @@
-# Initial setup
-
-## Prerequisites
-
-### Pulsar requirements
-
-1. Ensure you have Homebrew installed by running `which brew` in terminal. If it's not found then you should install it: https://brew.sh/. Run `which brew` again to check it's found. If it's not you may need to [add it your path](https://stackoverflow.com/questions/36657321/after-installing-homebrew-i-get-zsh-command-not-found-brew)
-
-2. Run `brew install libpulsar` to install the C++ libraries that the pulsar-client depends on
-
-3. Make sure you have Python installed on your machine by running `which python3` in terminal.
-
-4. If python isn't found then you should install it: https://www.python.org/downloads/. In a new terminal window run `which python3` again.
-
-5. Run `npm config set python /the/path/from/the/which/python3/command` inserting the path from step 2 or 3
-
-6. Install node-gyp: `npm install -g node-gyp`
-
-7. Make sure you have the Xcode command line tools installed by running `xcode-select --install` from the terminal. If it says they're already installed then you're set.
-
-8. Run this in the terminal:
-
-```sh
-export CPLUS_INCLUDE_PATH="$CPLUS_INCLUDE_PATH:$(brew --prefix)/include"
-export LIBRARY_PATH="$LIBRARY_PATH:$(brew --prefix)/lib"
-export PULSAR_CPP_DIR=/opt/homebrew/Cellar/libpulsar/3.1.0
-```
-
-9. Run `pnpm install` in the same terminal window.
-
-## Building and running the webapp
-
-> **Warning**
-> All the following commands should be launched from the **monorepo root directory**
-
-1. Install the dependencies.
-   ```bash
-   pnpm install
-   ```
-2. Optionally, if you are testing auth (pizzly) or webhooks (webapp) then you'll need to use ngrok to proxy internet traffic to your local machine
-
-   Get access to ngrok and then follow the instructions here to get it setup: https://ngrok.com/download (use homebrew) and make sure to authenticate.
-
-   Then run the following scripts to start proxying:
-
-   ```sh
-   ./scripts/proxy-pizzly.sh dan-pizzly-dev
-   ./scripts/proxy-webapp.sh dan-trigger-dev
-   ```
-
-3. Environment variables. You will need to create copies of the `.env.example` files in `app/webapp`
-
-   ```sh
-   cp ./apps/webapp/.env.example ./apps/webapp/.env
-   ```
-
-   Then you will need to fill in the fields with real values.
-
-   You also need to create the `pizzly-server.env` files under the `.docker` directory:
-
-   ```sh
-   cp ./.docker/pizzly-server.env.example ./.docker/pizzly-server.env
-   ```
-
-   Next, update the `AUTH_CALLBACK_URL` env var in the `pizzly-server.env` env file with the value provided to the `./scripts/proxy-pizzly.sh` command. Using the example above the `AUTH_CALLBACK_URL` would be `AUTH_CALLBACK_URL=https://dan-pizzly-dev.eu.ngrok.io/oauth/callback`.
-
-   If you aren't proxying pizzly according to step 2, then leave the `pizzly-server.env` file empty.
-
-   If you are proxying the webapp according to step 2 then in `webapp/.env`, set the `APP_ORIGIN` to the `NGROK_SUBDOMAIN` provided to the `./scripts/proxy-webapp.sh` command, e.g. `APP_ORIGIN=https://dan-trigger-dev.eu.ngrok.io`
-
-4. Start postgresql, redis, pizzly server, followed by pulsar standalone
-
-   ```bash
-   pnpm run docker:services
-   pnpm run docker:pulsar
-   ```
-
-   > **Note:** The npm script will complete while Docker sets up the container in the background. Ensure that Docker has finished and your container is running before proceeding.
-
-5. Generate prisma schema
-   ```bash
-   pnpm run generate
-   ```
-6. Run the Prisma migration to the database
-
-   ```bash
-   pnpm run db:migrate:deploy
-   ```
-
-7. Run the first build (with dependencies via the `...` option)
-
-   ```bash
-   pnpm run build --filter=webapp...
-   ```
-
-   **Running simply `pnpm run build` will build everything, including the Remix app.**
-
-8. Run the Remix dev server
-
-```bash
-pnpm run dev --filter=webapp
-```
-
-## Attaching an API integration using Pizzly
-
-```bash
-PIZZLY_HOSTPORT=http://localhost:3004 npx pizzly config:create github github <client-id> <client-secret> "repo,user"
-```
-
-## Tests, Typechecks, Lint, Install packages...
-
-Check the `turbo.json` file to see the available pipelines.
-
-- Run the Cypress tests and Dev
-  ```bash
-  pnpm run test:e2e:dev --filter=webapp
-  ```
-- Lint everything
-  ```bash
-  pnpm run lint
-  ```
-- Typecheck the whole monorepo
-  ```bash
-  pnpm run typecheck
-  ```
-- Test the whole monorepo
-  ```bash
-  pnpm run test
-  or
-  pnpm run test:dev
-  ```
-- How to install an npm package in the Remix app ?
-  ```bash
-  pnpm add dayjs --filter webapp
-  ```
-- Tweak the tsconfigs, eslint configs in the `config-package` folder. Any package or app will then extend from these configs.
-
-# Running a workflow locally
-
-## After pulling a change
-
-1. Ensure there are no database migrations to run
-
-```bash
-pnpm run db:migrate:dev
-```
-
-2. Generate the Prisma database client
-
-```bash
-pnpm run generate
-```
-
-3. Install packages
-
-```bash
-pnpm install
-```
-
-4. Build everything
-
-```bash
-pnpm run build
-```
-
-5. Install packages again, this makes sure the local packages are linked
-
-```bash
-pnpm install
-```
-
-## Running the servers
-
-1. Ensure the docker containers are running
-
-```bash
-pnpm run docker:services
-pnpm run docker:pulsar
-```
-
-2. Run the webapp
-
-```bash
-pnpm run dev --filter=webapp
-```
-
-3. Run the Web Socket Server
-
-```bash
-pnpm run dev --filter=wss
-```
-
-4. Build all the @trigger.dev/\* packages
-
-```bash
-pnpm run dev --filter="@trigger.dev/*"
-```
-
-## Running the smoke test
-
-1. Run the smoke test workflow
-
-```bash
-cd ./examples/smoke-test
-pnpm run dev
-```
-
-2. Running the workflow requires you to send data to the local API.
-
-You can use this cURL command to send a `user.created` event. This will run the workflow and generate the corresponding logs.
-
-```bash
-curl --request POST \
-  --url http://localhost:3000/api/v1/events \
-  --header 'Authorization: Bearer trigger_dev_zC25mKNn6c0q' \
-  --header 'Content-Type: application/json' \
-  --data '{
-	"name": "user.created",
-	"payload": {
-		"id": "123"
-	}
-}'
-```
-
-## Dependency & Package graph
-
-![Dependency Graph](assets/dependencyGraph.png)
-
-## Warp Launch Configuration
-
-Setup a custom launch configuration for the Warp terminal ([docs here](https://docs.warp.dev/features/sessions/launch-configurations)) by copying the `.warp/triggerdotdev.yaml.example` file to `~/.warp/launch_configurations/triggerdotdev.yaml`. Make sure you edit the file and replace `<your-trigger-dev>` and `<your-pizzly-dev>` with your custom ngrok subdomains.

DOCKER_INSTALLATION.md

@@ -0,0 +1,126 @@
+This guide covers installing Docker and Docker Compose. If you're looking for instructions for running Trigger.dev in docker, [see here](https://github.com/triggerdotdev/docker).
+
+## Setting up Docker for the first time.
+
+In the contributing guide of Trigger.dev, there's a section that requires you to start Docker.
+
+If you don't have Docker installed on your machine, you'll run into some complications (errors).
+
+Below are the steps on how you can avoid that.
+
+First you need to setup docker-compose as it is an underlying tool that this command: `pnpm run docker` fires behind the scene.
+
+## Linux
+
+To install Docker Compose on Linux Ubuntu via the terminal, you can follow these steps:
+
+1. Update the package index on your system by running the following command:
+
+   ```shell
+   sudo apt update
+   ```
+
+2. Install the required dependencies by running the following command:
+
+   ```shell
+   sudo apt install curl
+   ```
+
+3. Download the Docker Compose binary into the `/usr/local/bin` directory using the `curl` command:
+
+   ```shell
+   sudo curl -L "https://github.com/docker/compose/releases/latest/download/docker-compose-$(uname -s)-$(uname -m)" -o /usr/local/bin/docker-compose
+   ```
+
+4. Set the appropriate permissions to make the `docker-compose` binary executable:
+
+   ```shell
+   sudo chmod +x /usr/local/bin/docker-compose
+   ```
+
+5. Verify that Docker Compose has been successfully installed by running the following command:
+
+   ```shell
+   docker-compose --version
+   ```
+
+   This command should display the version information of Docker Compose without any errors.
+
+After following these steps, you should have Docker Compose installed on your Ubuntu system, and you can use it by running `docker-compose` commands in the terminal.
+
+When you've verified that the `docker-compose` package is installed and you proceed to start Docker with `pnpm run docker`.
+
+You'll probably get an error similar to the one below:
+
+```shell
+Cannot connect to the Docker daemon at unix:///var/run/docker.sock. Is the docker daemon running?
+ ELIFECYCLE  Command failed with exit code 1.
+```
+
+The error message suggests that the Docker daemon is not running on your system. The Docker daemon is responsible for managing and running Docker containers.
+
+To resolve this issue, you may need to install Docker properly on your Ubuntu system. Here are the steps to install Docker on Ubuntu:
+
+1. Update the package index on your system by running the following command:
+
+   ```shell
+   sudo apt update
+   ```
+
+2. Install the necessary packages to allow apt to use repositories over HTTPS:
+
+   ```shell
+   sudo apt install apt-transport-https ca-certificates curl software-properties-common
+   ```
+
+3. Add the official Docker GPG key to your system by running the following command:
+
+   ```shell
+   curl -fsSL https://download.docker.com/linux/ubuntu/gpg | sudo gpg --dearmor -o /usr/share/keyrings/docker-archive-keyring.gpg
+   ```
+
+4. Add the Docker repository to the APT sources list:
+
+   ```shell
+   echo "deb [arch=amd64 signed-by=/usr/share/keyrings/docker-archive-keyring.gpg] https://download.docker.com/linux/ubuntu $(lsb_release -cs) stable" | sudo tee /etc/apt/sources.list.d/docker.list > /dev/null
+   ```
+
+5. Update the package index again:
+
+   ```shell
+   sudo apt update
+   ```
+
+6. Install Docker by running the following command:
+
+   ```shell
+   sudo apt install docker-ce docker-ce-cli containerd.io
+   ```
+
+7. After the installation is complete, verify that Docker is installed correctly by running the following command:
+
+   ```shell
+   docker --version
+   ```
+
+   This command should display the version information of Docker without any errors.
+
+Once Docker is installed and verified, you should be able to start the Docker daemon and run the `pnpm run docker` command without encountering any issues.
+
+## Windows
+
+1. Download the Docker Desktop installer from the Docker website: [Docker Desktop for Windows](https://www.docker.com/products/docker-desktop)
+
+2. Run the installer and follow the instructions to install Docker Desktop.
+
+3. After installation, Docker Desktop should be running automatically.
+
+## macOS
+
+1. Download the Docker Desktop installer from the Docker website: [Docker Desktop for Mac](https://www.docker.com/products/docker-desktop)
+
+2. Run the installer and follow the instructions to install Docker Desktop.
+
+3. After installation, Docker Desktop should be running automatically.
+
+Please note that the instructions provided above are for the most common scenarios. For specific versions or different distributions, it's always a good idea to consult the official Docker documentation for the respective operating systems.

LICENSE

@@ -1,25 +1,201 @@
-Copyright (c) 2022 API Hero Inc.
+                                 Apache License
+                           Version 2.0, January 2004
+                        http://www.apache.org/licenses/
 
-Portions of this software are licensed as follows:
+   TERMS AND CONDITIONS FOR USE, REPRODUCTION, AND DISTRIBUTION
 
-- All content that resides under any "ee/" directory of this repository, if such directories exists, are licensed under the license defined in "ee/LICENSE".
-- All third party components incorporated into the Trigger.dev Software are licensed under the original license provided by the owner of the applicable component.
-- Content outside of the above mentioned directories or restrictions above is available under the "MIT Expat" license as defined below.
+   1. Definitions.
 
-Permission is hereby granted, free of charge, to any person obtaining a copy
-of this software and associated documentation files (the "Software"), to deal
-in the Software without restriction, including without limitation the rights
-to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
-copies of the Software, and to permit persons to whom the Software is
-furnished to do so, subject to the following conditions:
+      "License" shall mean the terms and conditions for use, reproduction,
+      and distribution as defined by Sections 1 through 9 of this document.
 
-The above copyright notice and this permission notice shall be included in all
-copies or substantial portions of the Software.
+      "Licensor" shall mean the copyright owner or entity authorized by
+      the copyright owner that is granting the License.
 
-THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
-IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
-FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
-AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
-LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
-OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
-SOFTWARE.
+      "Legal Entity" shall mean the union of the acting entity and all
+      other entities that control, are controlled by, or are under common
+      control with that entity. For the purposes of this definition,
+      "control" means (i) the power, direct or indirect, to cause the
+      direction or management of such entity, whether by contract or
+      otherwise, or (ii) ownership of fifty percent (50%) or more of the
+      outstanding shares, or (iii) beneficial ownership of such entity.
+
+      "You" (or "Your") shall mean an individual or Legal Entity
+      exercising permissions granted by this License.
+
+      "Source" form shall mean the preferred form for making modifications,
+      including but not limited to software source code, documentation
+      source, and configuration files.
+
+      "Object" form shall mean any form resulting from mechanical
+      transformation or translation of a Source form, including but
+      not limited to compiled object code, generated documentation,
+      and conversions to other media types.
+
+      "Work" shall mean the work of authorship, whether in Source or
+      Object form, made available under the License, as indicated by a
+      copyright notice that is included in or attached to the work
+      (an example is provided in the Appendix below).
+
+      "Derivative Works" shall mean any work, whether in Source or Object
+      form, that is based on (or derived from) the Work and for which the
+      editorial revisions, annotations, elaborations, or other modifications
+      represent, as a whole, an original work of authorship. For the purposes
+      of this License, Derivative Works shall not include works that remain
+      separable from, or merely link (or bind by name) to the interfaces of,
+      the Work and Derivative Works thereof.
+
+      "Contribution" shall mean any work of authorship, including
+      the original version of the Work and any modifications or additions
+      to that Work or Derivative Works thereof, that is intentionally
+      submitted to Licensor for inclusion in the Work by the copyright owner
+      or by an individual or Legal Entity authorized to submit on behalf of
+      the copyright owner. For the purposes of this definition, "submitted"
+      means any form of electronic, verbal, or written communication sent
+      to the Licensor or its representatives, including but not limited to
+      communication on electronic mailing lists, source code control systems,
+      and issue tracking systems that are managed by, or on behalf of, the
+      Licensor for the purpose of discussing and improving the Work, but
+      excluding communication that is conspicuously marked or otherwise
+      designated in writing by the copyright owner as "Not a Contribution."
+
+      "Contributor" shall mean Licensor and any individual or Legal Entity
+      on behalf of whom a Contribution has been received by Licensor and
+      subsequently incorporated within the Work.
+
+   2. Grant of Copyright License. Subject to the terms and conditions of
+      this License, each Contributor hereby grants to You a perpetual,
+      worldwide, non-exclusive, no-charge, royalty-free, irrevocable
+      copyright license to reproduce, prepare Derivative Works of,
+      publicly display, publicly perform, sublicense, and distribute the
+      Work and such Derivative Works in Source or Object form.
+
+   3. Grant of Patent License. Subject to the terms and conditions of
+      this License, each Contributor hereby grants to You a perpetual,
+      worldwide, non-exclusive, no-charge, royalty-free, irrevocable
+      (except as stated in this section) patent license to make, have made,
+      use, offer to sell, sell, import, and otherwise transfer the Work,
+      where such license applies only to those patent claims licensable
+      by such Contributor that are necessarily infringed by their
+      Contribution(s) alone or by combination of their Contribution(s)
+      with the Work to which such Contribution(s) was submitted. If You
+      institute patent litigation against any entity (including a
+      cross-claim or counterclaim in a lawsuit) alleging that the Work
+      or a Contribution incorporated within the Work constitutes direct
+      or contributory patent infringement, then any patent licenses
+      granted to You under this License for that Work shall terminate
+      as of the date such litigation is filed.
+
+   4. Redistribution. You may reproduce and distribute copies of the
+      Work or Derivative Works thereof in any medium, with or without
+      modifications, and in Source or Object form, provided that You
+      meet the following conditions:
+
+      (a) You must give any other recipients of the Work or
+          Derivative Works a copy of this License; and
+
+      (b) You must cause any modified files to carry prominent notices
+          stating that You changed the files; and
+
+      (c) You must retain, in the Source form of any Derivative Works
+          that You distribute, all copyright, patent, trademark, and
+          attribution notices from the Source form of the Work,
+          excluding those notices that do not pertain to any part of
+          the Derivative Works; and
+
+      (d) If the Work includes a "NOTICE" text file as part of its
+          distribution, then any Derivative Works that You distribute must
+          include a readable copy of the attribution notices contained
+          within such NOTICE file, excluding those notices that do not
+          pertain to any part of the Derivative Works, in at least one
+          of the following places: within a NOTICE text file distributed
+          as part of the Derivative Works; within the Source form or
+          documentation, if provided along with the Derivative Works; or,
+          within a display generated by the Derivative Works, if and
+          wherever such third-party notices normally appear. The contents
+          of the NOTICE file are for informational purposes only and
+          do not modify the License. You may add Your own attribution
+          notices within Derivative Works that You distribute, alongside
+          or as an addendum to the NOTICE text from the Work, provided
+          that such additional attribution notices cannot be construed
+          as modifying the License.
+
+      You may add Your own copyright statement to Your modifications and
+      may provide additional or different license terms and conditions
+      for use, reproduction, or distribution of Your modifications, or
+      for any such Derivative Works as a whole, provided Your use,
+      reproduction, and distribution of the Work otherwise complies with
+      the conditions stated in this License.
+
+   5. Submission of Contributions. Unless You explicitly state otherwise,
+      any Contribution intentionally submitted for inclusion in the Work
+      by You to the Licensor shall be under the terms and conditions of
+      this License, without any additional terms or conditions.
+      Notwithstanding the above, nothing herein shall supersede or modify
+      the terms of any separate license agreement you may have executed
+      with Licensor regarding such Contributions.
+
+   6. Trademarks. This License does not grant permission to use the trade
+      names, trademarks, service marks, or product names of the Licensor,
+      except as required for reasonable and customary use in describing the
+      origin of the Work and reproducing the content of the NOTICE file.
+
+   7. Disclaimer of Warranty. Unless required by applicable law or
+      agreed to in writing, Licensor provides the Work (and each
+      Contributor provides its Contributions) on an "AS IS" BASIS,
+      WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or
+      implied, including, without limitation, any warranties or conditions
+      of TITLE, NON-INFRINGEMENT, MERCHANTABILITY, or FITNESS FOR A
+      PARTICULAR PURPOSE. You are solely responsible for determining the
+      appropriateness of using or redistributing the Work and assume any
+      risks associated with Your exercise of permissions under this License.
+
+   8. Limitation of Liability. In no event and under no legal theory,
+      whether in tort (including negligence), contract, or otherwise,
+      unless required by applicable law (such as deliberate and grossly
+      negligent acts) or agreed to in writing, shall any Contributor be
+      liable to You for damages, including any direct, indirect, special,
+      incidental, or consequential damages of any character arising as a
+      result of this License or out of the use or inability to use the
+      Work (including but not limited to damages for loss of goodwill,
+      work stoppage, computer failure or malfunction, or any and all
+      other commercial damages or losses), even if such Contributor
+      has been advised of the possibility of such damages.
+
+   9. Accepting Warranty or Additional Liability. While redistributing
+      the Work or Derivative Works thereof, You may choose to offer,
+      and charge a fee for, acceptance of support, warranty, indemnity,
+      or other liability obligations and/or rights consistent with this
+      License. However, in accepting such obligations, You may act only
+      on Your own behalf and on Your sole responsibility, not on behalf
+      of any other Contributor, and only if You agree to indemnify,
+      defend, and hold each Contributor harmless for any liability
+      incurred by, or claims asserted against, such Contributor by reason
+      of your accepting any such warranty or additional liability.
+
+   END OF TERMS AND CONDITIONS
+
+   APPENDIX: How to apply the Apache License to your work.
+
+      To apply the Apache License to your work, attach the following
+      boilerplate notice, with the fields enclosed by brackets "[]"
+      replaced with your own identifying information. (Don't include
+      the brackets!)  The text should be enclosed in the appropriate
+      comment syntax for the file format. We also recommend that a
+      file or class name and description of purpose be included on the
+      same "printed page" as the copyright notice for easier
+      identification within third-party archives.
+
+   Copyright [yyyy] [name of copyright owner]
+
+   Licensed under the Apache License, Version 2.0 (the "License");
+   you may not use this file except in compliance with the License.
+   You may obtain a copy of the License at
+
+       http://www.apache.org/licenses/LICENSE-2.0
+
+   Unless required by applicable law or agreed to in writing, software
+   distributed under the License is distributed on an "AS IS" BASIS,
+   WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+   See the License for the specific language governing permissions and
+   limitations under the License.

README.md

@@ -1,204 +1,65 @@
 <div align="center">
+<picture>
+  <source media="(prefers-color-scheme: dark)" srcset="https://imagedelivery.net/3TbraffuDZ4aEf8KWOmI_w/a45d1fa2-0ae8-4a39-4409-f4f934bfae00/public">
+  <source media="(prefers-color-scheme: light)" srcset="https://imagedelivery.net/3TbraffuDZ4aEf8KWOmI_w/3f5ad4c1-c4c8-4277-b622-290e7f37bd00/public">
+  <img alt="Trigger.dev logo" src="https://imagedelivery.net/3TbraffuDZ4aEf8KWOmI_w/a45d1fa2-0ae8-4a39-4409-f4f934bfae00/public">
+</picture>
+  
+### The background jobs framework for Next.js
 
-![Hero](https://raw.githubusercontent.com/triggerdotdev/trigger.dev/eebe37109e33beae6390ee19029fce8a5934c84b/apps/webapp/public/images/logo-banner.png)
+[Discord](https://discord.gg/JtBAxBr2m3) | [Website](https://trigger.dev) | [Issues](https://github.com/triggerdotdev/trigger.dev/issues) | [Docs](https://trigger.dev/docs)
 
-[![Twitter](https://img.shields.io/twitter/url/https/twitter.com/triggerdotdev.svg?style=social&label=Follow%20%40trigger.dev)](https://twitter.com/triggerdotdev) [![YouTube Channel Subscribers](https://img.shields.io/youtube/channel/subscribers/UCu-PdxpWtIrrd7vW0N5T6ZA?style=social)](https://www.youtube.com/@triggerdotdev)
+[![Twitter](https://img.shields.io/twitter/url/https/twitter.com/triggerdotdev.svg?style=social&label=Follow%20%40trigger.dev)](https://twitter.com/triggerdotdev)
 [![GitHub Repo stars](https://img.shields.io/github/stars/triggerdotdev/trigger.dev?style=social)](https://github.com/triggerdotdev/trigger.dev)
 
-[Website](https://trigger.dev) | [Community](https://discord.gg/JtBAxBr2m3) | [Docs](https://docs.trigger.dev)
 </div>
 
+# About Trigger.dev
 
-# **✨ Trigger.dev**
-### **The developer-first open source Zapier alternative.**
+Create long-running jobs directly in your codebase with features like API integrations, webhooks, scheduling and delays.
 
+### Long running Jobs on serverless
 
-Trigger.dev is an open source platform that makes it easy for developers to create event-driven background tasks directly in their code. Build, test and run workflows locally using our SDK. Subscribe to webhooks, schedule jobs, run background jobs and add long delays easily and reliably. In our web app you get full visibility of every run your workflow has ever made making it easier to monitor and debug.
+Reliably run jobs and don’t worry about function timeouts, we handle those for you.
 
-&nbsp;
+- Auto-resume after a function timeout
+- Auto-resume after a server outage
+- Add delays of up to a year
 
-# **⭐️ Features:**
+### In your codebase
 
-- 👂 Easily subscribe to [webhooks](https://docs.trigger.dev/triggers/webhooks)
-  — they work locally without tunnelling.
-- 🔥 Fire your own [custom events](https://docs.trigger.dev/triggers/custom-events)—a single event can trigger multiple workflows.
-- 📆 [Schedule workflows](https://docs.trigger.dev/triggers/scheduled)—easily repeat tasks or use CRON syntax for advanced cases.
-- 🚦 Add [long delays](https://docs.trigger.dev/functions/delays) inside workflows (up to a year) and they will pick up where they left off.
-- 🤝 When your server goes down [it’s not a problem](https://docs.trigger.dev/guides/resumability), workflows will reconnect and continue.
-- 🪧 [View every step of every run](https://docs.trigger.dev/viewing-runs), with data, previews and errors.
-- 👋 Connect to and authenticate with APIs using our custom integrations.
-- 🚗 If you have a custom use case, we support [Fetch for calling any HTTP endpoint](https://docs.trigger.dev/functions/fetch) or [webhooks](https://docs.trigger.dev/triggers/webhooks) for subscribing to events from APIs.
-- 📡 All API calls are automatically retried with exponential back off.
-- 😀 TypeScript SDK, so whether you’re using JavaScript or TypeScript you will have a great experience.
+Create Jobs where they belong: in your codebase. Version control, localhost, test, review, and deploy like you're already used to.
 
-&nbsp;
+### Secure by design
 
-# **🌱 Documentation:**
+We only receive Triggers and the data you choose to send to us. You can even completely self-host the entire platform.
 
-- [Getting Started with Trigger.dev](https://docs.trigger.dev/getting-started)
-- Example workflows
-  - [Welcome email drip campaign using Resend and Slack](https://docs.trigger.dev/examples/resend)
-  - [Post to Slack when a GitHub issue is created or modified](https://docs.trigger.dev/examples/slack)
-  - [Create a new product on Shopify](https://docs.trigger.dev/examples/shopify)
-  - [When a GitHub repo is starred, post information about the user to Slack](https://docs.trigger.dev/examples/github)
-- Triggers:
-  - [Webhooks](https://docs.trigger.dev/triggers/webhooks)
-  - [Custom events](https://docs.trigger.dev/triggers/custom-events)
-  - [Scheduled](https://docs.trigger.dev/triggers/scheduled)
-- Functions:
-  - [Fetch](https://docs.trigger.dev/functions/fetch)
-  - [Logging](https://docs.trigger.dev/functions/logging)
-  - [Delays](https://docs.trigger.dev/functions/delays)
-  - [Send event](https://docs.trigger.dev/functions/send-event)
-  - [Loops, conditionals, etc](https://docs.trigger.dev/functions/loops-conditionals-etc)
+### Don't worry about deployment
 
-&nbsp;
+Just use our SDK to write Jobs in your Next.js codebase. There's nothing extra to deploy and no CI to configure, your Jobs just connect to our cloud. Or you can always self-host.
 
-# 🔬 **Anatomy of a workflow**
+### Full visibility of every job run
 
-* You create workflows in code on your server using our SDK
-* Each API integration is a separate package, e.g. `@trigger.dev/slack`
-* Each workflow has an event that triggers it, e.g. `github.events.newStarEvent`, `scheduleEvent`, `customEvent`
-* Each workflow has a `run` function that is called when the event is triggered
-* If we don't have an integration for the API you want to use, you can use `fetch` to call any HTTP endpoint and `webhookEvent` to subscribe to webhooks
+View every Task in every Run so you can tell exactly what happened.
 
-## **Example workflows**
+![image](https://www.trigger.dev/build/_assets/web-app-2QFKXFLW.png)
 
-<details open><summary> Post to Slack when a GitHub issue is created or modified
-</summary>
+### Built-in integrations
 
-_Integrations required: Slack, GitHub_
+Easily integrate with hundreds of third-party APIs – including your own. Use API keys (which never leave your server) or let us handle OAuth for you. Install our integration packages and easily subscribe to webhooks and perform common tasks, or you can easily use your existing favorite Node.JS SDKs and get resumability and idempotency through our `runTask` function.
 
-```ts
-import { Trigger } from "@trigger.dev/sdk";
-import * as github from "@trigger.dev/github";
-import * as slack from "@trigger.dev/slack";
+### Trigger.dev Connect (coming soon)
 
-new Trigger({
-  id: "new-github-star-to-slack",
-  name: "New GitHub Star: triggerdotdev/trigger.dev",
-  apiKey: "<my_api_key>",
-  on: github.events.newStarEvent({
-    repo: "triggerdotdev/trigger.dev",
-  }),
-  run: async (event) => {
-    await slack.postMessage("github-stars", {
-      channelName: "github-stars",
-      text: `New GitHub star from \n<${event.sender.html_url}|${event.sender.login}>`,
-    });
-  },
-}).listen();
-```
+Easily add integrations for your users.
 
-</details>
+# Getting started
 
-<details><summary>Welcome email drip campaign
-</summary>
+Visit our docs [here](https://trigger.dev/docs).
 
-_Integrations required: Slack, Resend_
+## Self-host
 
-```ts
-import { customEvent, Trigger, sendEvent } from "@trigger.dev/sdk";
-import * as resend from "@trigger.dev/resend";
-import * as slack from "@trigger.dev/slack";
-import React from "react";
-import { z } from "zod";
-import { getUser } from "../db";
-import { InactiveEmail, TipsEmail, WelcomeEmail } from "./email-templates";
+We provide an official trigger.dev docker image you can use to easily self-host the platform. We're working on more extensive guides but we currently provide a [Fly.io example repository](https://github.com/triggerdotdev/fly.io) with instructions in the README for deploying and using a self-hosted instance of Trigger.dev on Fly.io.
 
-new Trigger({
-  id: "welcome-email-campaign",
-  name: "Welcome email drip campaign",
-  apiKey: "<my_api_key>",
-  on: customEvent({
-    name: "user.created",
-    schema: z.object({
-      userId: z.string(),
-    }),
-  }),
-  async run(event, context) {
-    //get the user data from the database
-    const user = await getUser(event.userId);
+## Development
 
-    await slack.postMessage("send-to-slack", {
-      channelName: "new-users",
-      text: `New user signed up: ${user.name} (${user.email})`,
-    });
-
-    //Send the first email
-    const welcomeResponse = await resend.sendEmail("welcome-email", {
-      from: "Trigger.dev <james@email.trigger.dev>",
-      replyTo: "James <james@trigger.dev>",
-      to: user.email,
-      subject: "Welcome to Trigger.dev",
-      react: <WelcomeEmail name={user.name} />,
-    });
-    await context.logger.debug(
-      `Sent welcome email to ${welcomeResponse.to} with id ${welcomeResponse.id}`
-    );
-
-    //wait 1 day, check if the user has created a workflow and send the appropriate email
-    await context.waitFor("wait-a-while", { days: 1 });
-    const updatedUser = await getUser(event.userId);
-
-    if (updatedUser.hasOnboarded) {
-      await resend.sendEmail("onboarding-complete", {
-        from: "Trigger.dev <james@email.trigger.dev>",
-        replyTo: "James <james@trigger.dev>",
-        to: updatedUser.email,
-        subject: "Pro tips for workflows",
-        react: <TipsEmail name={updatedUser.name} />,
-      });
-    } else {
-      await resend.sendEmail("onboarding-incomplete", {
-        from: "Trigger.dev <james@email.trigger.dev>",
-        replyTo: "James <james@trigger.dev>",
-        to: updatedUser.email,
-        subject: "Help with your first workflow",
-        react: <InactiveEmail name={updatedUser.name} />,
-      });
-    }
-  },
-}).listen();
-```
-
-</details>
-
-[More examples here](https://docs.trigger.dev/examples/examples)
-
-&nbsp;
-
-# 👀 **Viewing runs:**
-
-One of the most powerful features of Trigger.dev is the [runs page](https://docs.trigger.dev/viewing-runs). All of the steps in a workflow, including the initial event, can be viewed in detail. See the status / output of each step, the logs, rich previews, errors and much more.
-
-![Viewing runs](https://imagedelivery.net/3TbraffuDZ4aEf8KWOmI_w/7343f3b2-2342-493b-5007-78f60ba5b700/public)
-
-&nbsp;
-
-# **🏠 Running Trigger.dev locally:**
-
-To run Trigger.dev locally, [follow these steps](https://github.com/triggerdotdev/trigger.dev/blob/main/DEVELOPMENT.md).
-
-&nbsp;
-
-# **👏 Contributing:**
-
-We are open source and love contributions!
-
-- Request a feature in our [Discord community](https://discord.gg/JtBAxBr2m3)
-- Open a PR
-
-&nbsp;
-
-# **🧘‍♂️ Self-hosting guide:**
-
-Please subscribe to the [GitHub issue](https://github.com/triggerdotdev/trigger.dev/issues/48) to be notified when it's live.
-
-&nbsp;
-
-
-# **📧 Support & contact:**
-
-- Join our [Discord community](https://discord.gg/JtBAxBr2m3)
-- If you have any other questions, get in touch at [hello@trigger.dev](mailto:hello@trigger.dev)
+To setup and develop locally or contribute to the open source project, follow our [developement guide](./CONTRIBUTING.md).

apps/integrations/.eslintrc.json

@@ -1,21 +0,0 @@
-{
-  "extends": [
-    "eslint:recommended",
-    "plugin:@typescript-eslint/recommended",
-    "prettier"
-  ],
-  "env": {
-    "node": true,
-    "commonjs": true
-  },
-  "parser": "@typescript-eslint/parser",
-  "plugins": ["@typescript-eslint"],
-  "root": true,
-  "rules": {
-    "@typescript-eslint/explicit-function-return-type": "off",
-    "@typescript-eslint/no-explicit-any": "off",
-    "@typescript-eslint/no-unused-vars": "off",
-    "no-console": "off"
-  },
-  "ignorePatterns": ["**/dist/*.js"]
-}

apps/integrations/.gitignore

@@ -1,105 +0,0 @@
-# Logs
-logs
-*.log
-npm-debug.log*
-yarn-debug.log*
-yarn-error.log*
-lerna-debug.log*
-
-# Diagnostic reports (https://nodejs.org/api/report.html)
-report.[0-9]*.[0-9]*.[0-9]*.[0-9]*.json
-
-# Runtime data
-pids
-*.pid
-*.seed
-*.pid.lock
-
-# Directory for instrumented libs generated by jscoverage/JSCover
-lib-cov
-
-# Coverage directory used by tools like istanbul
-coverage
-*.lcov
-
-# nyc test coverage
-.nyc_output
-
-# Grunt intermediate storage (https://gruntjs.com/creating-plugins#storing-task-files)
-.grunt
-
-# Bower dependency directory (https://bower.io/)
-bower_components
-
-# node-waf configuration
-.lock-wscript
-
-# Compiled binary addons (https://nodejs.org/api/addons.html)
-build/Release
-
-# Dependency directories
-node_modules/
-jspm_packages/
-
-# TypeScript v1 declaration files
-typings/
-
-# TypeScript cache
-*.tsbuildinfo
-
-# Optional npm cache directory
-.npm
-
-# Optional eslint cache
-.eslintcache
-
-# Microbundle cache
-.rpt2_cache/
-.rts2_cache_cjs/
-.rts2_cache_es/
-.rts2_cache_umd/
-
-# Optional REPL history
-.node_repl_history
-
-# Output of 'npm pack'
-*.tgz
-
-# Yarn Integrity file
-.yarn-integrity
-
-# dotenv environment variables file
-.env
-.env.test
-
-# parcel-bundler cache (https://parceljs.org/)
-.cache
-
-# Next.js build output
-.next
-
-# Nuxt.js build / generate output
-.nuxt
-dist
-
-# Gatsby files
-.cache/
-# Comment in the public line in if your project uses Gatsby and *not* Next.js
-# https://nextjs.org/blog/next-9-1#public-directory-support
-# public
-
-# vuepress build output
-.vuepress/dist
-
-# Serverless directories
-.serverless/
-
-# FuseBox cache
-.fusebox/
-
-# DynamoDB Local files
-.dynamodb/
-
-# TernJS port file
-.tern-port
-.DS_Store

apps/integrations/.infisical.json

@@ -1 +0,0 @@
-{ "workspaceId": "63ea6cff29733e58db1e6b80" }

apps/integrations/.prettierignore

@@ -1,4 +0,0 @@
-node_modules
-
-/build
-.env

apps/integrations/Dockerfile

@@ -1,55 +0,0 @@
-FROM node:16-bullseye AS pruner
-RUN apt-get update && apt-get install openssl -y
-WORKDIR /app
-RUN npm install turbo@1.7.0 -g
-COPY . .
-RUN turbo prune --scope=integrations --docker
-RUN find . -name "node_modules" -type d -prune -exec rm -rf '{}' +
-
-# Base strategy to have layer caching
-FROM node:16-bullseye AS base
-RUN apt-get update && apt-get install openssl -y
-WORKDIR /app
-COPY .gitignore .gitignore
-COPY --from=pruner /app/out/json/ .
-COPY --from=pruner /app/out/pnpm-lock.yaml ./pnpm-lock.yaml
-COPY --from=pruner /app/out/pnpm-workspace.yaml ./pnpm-workspace.yaml
-
-FROM base AS production-deps
-WORKDIR /app
-RUN npm install turbo@1.7.0 -g
-RUN corepack enable
-ENV NODE_ENV production
-COPY --from=pruner /app/out/full/apps/integrations/prisma/schema.prisma /app/apps/integrations/prisma/schema.prisma
-RUN pnpm install --prod --frozen-lockfile
-RUN pnpx prisma generate --schema /app/apps/integrations/prisma/schema.prisma
-
-FROM base AS builder
-WORKDIR /app
-RUN npm install turbo@1.7.0 -g
-COPY turbo.json turbo.json
-RUN corepack enable
-COPY --from=pruner /app/out/full/ .
-ENV NODE_ENV development
-RUN pnpm install --ignore-scripts --frozen-lockfile
-ENV NODE_ENV production
-RUN pnpm run generate
-RUN pnpm run build --filter=integrations...
-RUN pnpx prisma migrate deploy --schema apps/integrations/prisma/schema.prisma
-
-# Runner
-FROM node:16-bullseye AS runner
-RUN apt-get update && apt-get install openssl -y
-WORKDIR /app
-RUN corepack enable
-ENV NODE_ENV production
-RUN addgroup --system --gid 1001 nodejs
-RUN adduser --system --uid 1001 expressjs
-RUN chown -R expressjs:nodejs /app
-USER expressjs
-
-COPY --from=pruner --chown=expressjs:nodejs /app/out/full/ .
-COPY --from=production-deps --chown=expressjs:nodejs /app .
-COPY --from=builder --chown=expressjs:nodejs /app/apps/integrations/dist/index.js ./apps/integrations/dist/index.js
-
-ENTRYPOINT ["pnpm", "--filter", "integrations", "run", "start"]

apps/integrations/README.md

@@ -1,2 +0,0 @@
-# trigger-integrations
-You can create API integrations using this data and system

apps/integrations/package.json

@@ -1,63 +0,0 @@
-{
-  "private": true,
-  "name": "integrations",
-  "version": "1.0.0",
-  "description": "API integrations in a format that can be used to generate clients",
-  "main": "./dist/index.js",
-  "scripts": {
-    "build": "tsup",
-    "start": "node dist/index.js",
-    "dev": "concurrently \"tsup --watch\" \"nodemon -r dotenv/config -q dist/index.js\"",
-    "test": "vitest",
-    "lint": "eslint --no-error-on-unmatched-pattern src/**",
-    "lint-fix": "eslint --no-error-on-unmatched-pattern --fix src/**",
-    "generate-integrations": "tsx src/trigger/sdk/generate.ts",
-    "generate": "prisma generate",
-    "db:migrate:deploy": "prisma migrate deploy",
-    "db:migrate:dev": "prisma migrate dev"
-  },
-  "dependencies": {
-    "@cfworker/json-schema": "^1.12.5",
-    "@prisma/client": "^4.3.0",
-    "express": "^4.18.1",
-    "express-async-errors": "^3.1.1",
-    "json-pointer": "^0.6.2",
-    "json-schema-deref-sync": "^0.14.0",
-    "json-schema-to-typescript": "^11.0.3",
-    "loglevel": "^1.8.1",
-    "morgan": "^1.10.0",
-    "node-fetch": "^3.3.0",
-    "zod": "^3.20.2"
-  },
-  "devDependencies": {
-    "@types/eslint": "^8.4.6",
-    "@types/express": "^4.17.13",
-    "@types/json-pointer": "^1.0.31",
-    "@types/morgan": "^1.9.3",
-    "@types/node": "^18.13.0",
-    "@typescript-eslint/eslint-plugin": "^5.51.0",
-    "concurrently": "^7.6.0",
-    "dotenv": "^16.0.3",
-    "eslint": "^8.34.0",
-    "eslint-config-prettier": "^8.5.0",
-    "eslint-config-standard-with-typescript": "^34.0.0",
-    "eslint-plugin-import": "^2.27.5",
-    "eslint-plugin-n": "^15.6.1",
-    "eslint-plugin-promise": "^6.1.1",
-    "nock": "^13.3.0",
-    "nodemon": "^2.0.19",
-    "prisma": "^4.3.0",
-    "rimraf": "^4.1.2",
-    "tiny-invariant": "^1.2.0",
-    "ts-morph": "^17.0.1",
-    "tsup": "^6.6.2",
-    "tsx": "^3.12.3",
-    "typescript": "^4.9.5",
-    "vite": "^4.1.1",
-    "vite-tsconfig-paths": "^4.0.5",
-    "vitest": "^0.28.4"
-  },
-  "engines": {
-    "node": ">=16.0.0"
-  }
-}

apps/integrations/prisma/migrations/20230213221827_init/migration.sql

@@ -1,20 +0,0 @@
--- CreateTable
-CREATE TABLE "Cache" (
-    "id" TEXT NOT NULL,
-    "namespace" TEXT NOT NULL,
-    "key" TEXT NOT NULL,
-    "value" TEXT NOT NULL,
-    "expiresAt" TIMESTAMP(3) NOT NULL,
-    "createdAt" TIMESTAMP(3) NOT NULL DEFAULT CURRENT_TIMESTAMP,
-
-    CONSTRAINT "Cache_pkey" PRIMARY KEY ("id")
-);
-
--- CreateIndex
-CREATE UNIQUE INDEX "Cache_key_key" ON "Cache"("key");
-
--- CreateIndex
-CREATE INDEX "Cache_namespace_key_idx" ON "Cache"("namespace", "key");
-
--- CreateIndex
-CREATE UNIQUE INDEX "Cache_namespace_key_key" ON "Cache"("namespace", "key");

apps/integrations/prisma/migrations/20230213222130_non_unique_key/migration.sql

@@ -1,5 +0,0 @@
--- DropIndex
-DROP INDEX "Cache_key_key";
-
--- DropIndex
-DROP INDEX "Cache_namespace_key_idx";

apps/integrations/prisma/migrations/20230213223405_optional_ttl/migration.sql

@@ -1,2 +0,0 @@
--- AlterTable
-ALTER TABLE "Cache" ALTER COLUMN "expiresAt" DROP NOT NULL;

apps/integrations/prisma/schema.prisma

@@ -1,22 +0,0 @@
-datasource db {
-  provider = "postgresql"
-  url      = env("DATABASE_URL")
-}
-
-generator client {
-  provider        = "prisma-client-js"
-  output          = "../node_modules/.prisma/client"
-  binaryTargets   = ["native", "debian-openssl-1.1.x"]
-  previewFeatures = ["orderByNulls"]
-}
-
-model Cache {
-  id    String @id @default(cuid())
-  namespace String
-  key String
-  value String
-  expiresAt DateTime?
-  createdAt DateTime @default(now())
-
-  @@unique([namespace, key])
-}

apps/integrations/src/api/v2/action/createParametersBody.ts

@@ -1,35 +0,0 @@
-import { InputSpec } from "core/action/types";
-
-export function createParametersBody(
-  inputSpec: InputSpec,
-  params?: Record<string | number, any> | undefined
-) {
-  //separate the parameters and body by looking at the spec and pulling properties out
-  let parameters: Record<string, any> | undefined = undefined;
-  let body: any = undefined;
-
-  if (params) {
-    inputSpec.parameters?.forEach((p) => {
-      if (!parameters) {
-        parameters = {};
-      }
-      parameters[p.name] = params[p.name];
-    });
-
-    const bodyProperties = inputSpec.body?.properties;
-    if (bodyProperties) {
-      body = {};
-      Object.keys(bodyProperties).forEach((name) => {
-        const value = params?.[name];
-        if (value !== undefined) {
-          body[name] = value;
-        }
-      });
-    }
-  }
-
-  return {
-    parameters,
-    body,
-  };
-}

apps/integrations/src/api/v2/action/display.ts

@@ -1,50 +0,0 @@
-import { DisplayProperties } from "core/action/types";
-import { Request, Response } from "express";
-import { catalog } from "integrations/catalog";
-import { z } from "zod";
-import { createParametersBody } from "./createParametersBody";
-import { getServiceAction } from "./validation";
-
-const requestBodySchema = z.object({
-  params: z.record(z.string().or(z.number()), z.any()).optional(),
-});
-
-export async function handleActionDisplay(req: Request, res: Response) {
-  const serviceActionResult = getServiceAction(req.params);
-
-  if (!serviceActionResult.success) {
-    res
-      .status(404)
-      .send(
-        JSON.stringify({ success: false, error: serviceActionResult.error })
-      );
-    return;
-  }
-
-  const { service, action } = serviceActionResult;
-
-  const parsedRequestBody = requestBodySchema.safeParse(req.body);
-  if (!parsedRequestBody.success) {
-    res.status(400).send(
-      JSON.stringify({
-        success: false,
-        error: {
-          type: "invalid_body",
-          message: "Action not found",
-          service,
-          action,
-          issues: parsedRequestBody.error.issues,
-        },
-      })
-    );
-    return;
-  }
-
-  const requestData = createParametersBody(
-    action.spec.input,
-    parsedRequestBody.data.params
-  );
-
-  const displayProperties = await action.displayProperties(requestData);
-  res.send(JSON.stringify({ success: true, properties: displayProperties }));
-}

apps/integrations/src/api/v2/action/index.ts

@@ -1,148 +0,0 @@
-import { PostgresCacheService } from "cache/postgresCache";
-import { AuthCredentials } from "core/authentication/types";
-import { Service } from "core/service/types";
-import { validateInputs } from "core/validation/inputs";
-import { Request, Response } from "express";
-import { z } from "zod";
-import { error, ReturnResponse } from "../requestUtilities";
-import { createParametersBody } from "./createParametersBody";
-import { getServiceAction } from "./validation";
-
-const requestBodySchema = z.object({
-  credentials: z.object({ accessToken: z.string() }).optional(),
-  params: z.record(z.string().or(z.number()), z.any()).optional(),
-  metadata: z.object({
-    requestId: z.string(),
-    workflowId: z.string(),
-    connectionId: z.string(),
-  }),
-});
-
-export async function handleAction(req: Request, res: Response) {
-  const serviceActionResult = getServiceAction(req.params);
-
-  if (!serviceActionResult.success) {
-    res
-      .status(404)
-      .send(JSON.stringify(error(404, false, serviceActionResult.error)));
-    return;
-  }
-
-  const { service, action } = serviceActionResult;
-
-  const parsedRequestBody = requestBodySchema.safeParse(req.body);
-
-  if (!parsedRequestBody.success) {
-    res.status(400).send(
-      JSON.stringify(
-        error(400, false, {
-          type: "invalid_body",
-          message: "Action not found",
-          service,
-          action,
-          issues: parsedRequestBody.error.issues,
-        })
-      )
-    );
-    return;
-  }
-
-  //for v1 of this API we're building the credentials from the action
-  //this is fine for now but we'll want to use the connection in future to cover complex cases
-  let credentials: AuthCredentials | undefined = undefined;
-  if (parsedRequestBody.data.credentials && action.spec.input.security) {
-    const firstSecurityMethod = Object.entries(action.spec.input.security)[0];
-    if (firstSecurityMethod) {
-      const [name, scopes] = firstSecurityMethod;
-      //get the full info from the service
-      const securityMethod = service.authentication[name];
-
-      switch (securityMethod.type) {
-        case "oauth2":
-          credentials = {
-            type: "oauth2",
-            name,
-            accessToken: parsedRequestBody.data.credentials.accessToken,
-            scopes,
-          };
-          break;
-        case "api_key":
-          credentials = {
-            type: "api_key",
-            name,
-            api_key: parsedRequestBody.data.credentials.accessToken,
-            scopes,
-          };
-          break;
-        default:
-          throw new Error(
-            `Not implemented credentials for: ${JSON.stringify(securityMethod)}`
-          );
-      }
-    }
-  }
-
-  const { parameters, body } = createParametersBody(
-    action.spec.input,
-    parsedRequestBody.data.params
-  );
-
-  const inputValidationResult = await validateInputs(action.spec.input, {
-    parameters,
-    body,
-    credentials,
-  });
-  if (!inputValidationResult.success) {
-    res
-      .status(400)
-      .send(JSON.stringify(error(400, false, inputValidationResult.error)));
-    return;
-  }
-
-  const { metadata } = parsedRequestBody.data;
-  const cache = new PostgresCacheService(`${metadata.connectionId}-${service}`);
-
-  try {
-    const data = await action.action(
-      { credentials, parameters, body },
-      cache,
-      metadata
-    );
-
-    //convert into the format for the webapp
-    const response: ReturnResponse = {
-      ok: true,
-      isRetryable: isRetryable(service, data.status),
-      response: {
-        output: data.body ?? {},
-        context: {
-          statusCode: data.status,
-          headers: data.headers,
-        },
-      },
-    };
-    res.send(JSON.stringify(response));
-  } catch (e: any) {
-    console.error(e);
-
-    if (e instanceof Error) {
-      res
-        .status(500)
-        .send(JSON.stringify(error(500, false, { error: JSON.stringify(e) })));
-      return;
-    }
-
-    if ("error" in e) {
-      res.status(500).send(JSON.stringify(error(500, false, e.error)));
-      return;
-    }
-
-    res
-      .status(500)
-      .send(JSON.stringify(error(500, false, { error: JSON.stringify(e) })));
-  }
-}
-
-function isRetryable(service: Service, status: number): boolean {
-  return service.retryableStatusCodes.includes(status);
-}

apps/integrations/src/api/v2/action/validation.ts

@@ -1,50 +0,0 @@
-import { Action } from "core/action/types";
-import { Service } from "core/service/types";
-import { Request } from "express";
-import { catalog } from "integrations/catalog";
-
-type ServiceActionResult =
-  | {
-      success: true;
-      service: Service;
-      action: Action;
-    }
-  | {
-      success: false;
-      error: Record<string, any>;
-    };
-
-export function getServiceAction(
-  params: Request["params"]
-): ServiceActionResult {
-  const { service, action } = params;
-
-  const matchingService = Object.values(catalog.services).find(
-    (s) => s.service === service
-  );
-
-  if (!matchingService) {
-    return {
-      success: false,
-      error: { type: "missing_service", message: "Service not found", service },
-    };
-  }
-
-  const matchingAction = Object.values(matchingService.actions).find(
-    (a) => a.name === action
-  );
-
-  if (!matchingAction) {
-    return {
-      success: false,
-      error: {
-        type: "missing_action",
-        message: "Action not found",
-        service,
-        action,
-      },
-    };
-  }
-
-  return { success: true, service: matchingService, action: matchingAction };
-}

apps/integrations/src/api/v2/fetch.ts

@@ -1,116 +0,0 @@
-import { AuthCredentials } from "core/authentication/types";
-import { HTTPMethodSchema } from "core/endpoint/types";
-import { serviceFetch } from "core/fetch/serviceFetch";
-import { Request, Response } from "express";
-import { catalog } from "integrations/catalog";
-import { z } from "zod";
-import { error } from "./requestUtilities";
-
-const requestBodySchema = z.object({
-  credentials: z.object({ accessToken: z.string() }).optional(),
-  path: z.string(),
-  method: HTTPMethodSchema,
-  headers: z.record(z.string(), z.string()).optional(),
-  body: z.any(),
-});
-
-type ReturnResponse = {
-  response: NormalizedResponse;
-  isRetryable: boolean;
-  ok: boolean;
-};
-
-type NormalizedResponse = {
-  output: NonNullable<any>;
-  context: any;
-};
-
-export async function handleAction(req: Request, res: Response) {
-  const { service } = req.params;
-
-  const matchingService = Object.values(catalog.services).find(
-    (s) => s.service === service
-  );
-
-  if (!matchingService) {
-    return {
-      success: false,
-      error: { type: "missing_service", message: "Service not found", service },
-    };
-  }
-
-  const parsedRequestBody = requestBodySchema.safeParse(req.body);
-
-  if (!parsedRequestBody.success) {
-    res.status(400).send(
-      JSON.stringify(
-        error(400, false, {
-          type: "invalid_body",
-          message: "Invalid input",
-          issues: parsedRequestBody.error.issues,
-        })
-      )
-    );
-    return;
-  }
-
-  //v1 build credentials from the service authentication info
-  let credentials: AuthCredentials | undefined = undefined;
-  if (parsedRequestBody.data.credentials) {
-    //just get the first security method
-    const [name, securityMethod] = Object.entries(
-      matchingService.authentication
-    )[0];
-
-    switch (securityMethod.type) {
-      case "oauth2":
-        credentials = {
-          type: "oauth2",
-          name,
-          accessToken: parsedRequestBody.data.credentials.accessToken,
-          scopes: Object.keys(securityMethod.scopes),
-        };
-        break;
-      case "api_key":
-        credentials = {
-          type: "api_key",
-          name,
-          api_key: parsedRequestBody.data.credentials.accessToken,
-          scopes: Object.keys(securityMethod.scopes),
-        };
-        break;
-      default:
-        throw new Error(
-          `Not implemented credentials for: ${JSON.stringify(securityMethod)}`
-        );
-    }
-  }
-
-  const url = matchingService.baseUrl + parsedRequestBody.data.path;
-
-  const data = await serviceFetch({
-    url,
-    method: parsedRequestBody.data.method,
-    headers: parsedRequestBody.data.headers,
-    body: parsedRequestBody.data.body,
-    authentication: matchingService.authentication,
-    credentials,
-  });
-
-  const response: ReturnResponse = {
-    ok: true,
-    isRetryable: isRetryable(data.status),
-    response: {
-      output: data.body ?? {},
-      context: {
-        statusCode: data.status,
-        headers: data.headers,
-      },
-    },
-  };
-  res.send(JSON.stringify(response));
-}
-
-function isRetryable(statusCode: number) {
-  return [408, 429, 500, 502, 503, 504].includes(statusCode);
-}

apps/integrations/src/api/v2/requestUtilities.ts

@@ -1,29 +0,0 @@
-export type ReturnResponse = {
-  response: NormalizedResponse;
-  isRetryable: boolean;
-  ok: boolean;
-};
-
-export type NormalizedResponse = {
-  output: NonNullable<any>;
-  context: any;
-};
-
-export function error(
-  status: number,
-  isRetryable: boolean,
-  error: Record<string, any>
-): ReturnResponse {
-  const response: ReturnResponse = {
-    ok: false,
-    isRetryable,
-    response: {
-      output: error,
-      context: {
-        statusCode: status,
-        headers: {},
-      },
-    },
-  };
-  return response;
-}

apps/integrations/src/api/v2/services.ts

@@ -1,36 +0,0 @@
-import { IntegrationAuthentication } from "core/authentication/types";
-import { Service } from "core/service/types";
-import { Request, Response } from "express";
-import { catalog } from "integrations/catalog";
-
-type ServiceMetadata = {
-  name: string;
-  service: string;
-  version: string;
-  icon: string;
-  live: boolean;
-  authentication: IntegrationAuthentication;
-};
-
-export async function handleServices(req: Request, res: Response) {
-  const servicesMetadata: Record<string, ServiceMetadata> = {};
-  Object.entries(catalog.services).forEach(([key, service]) => {
-    if (service.live === false) return;
-    const metadata = omitExtraInfo(service);
-    servicesMetadata[key] = {
-      ...metadata,
-      icon: `/integrations/${metadata.service}.png`,
-    };
-  });
-
-  res.send(
-    JSON.stringify({
-      services: servicesMetadata,
-    })
-  );
-}
-
-function omitExtraInfo(service: Service): ServiceMetadata {
-  const { actions, retryableStatusCodes, ...rest } = service;
-  return rest;
-}

apps/integrations/src/cache/db.server.ts

@@ -1,58 +0,0 @@
-import { PrismaClient, Prisma } from ".prisma/client";
-import invariant from "tiny-invariant";
-
-export { Prisma };
-
-let prisma: PrismaClient;
-
-declare global {
-  // eslint-disable-next-line no-var
-  var __db__: PrismaClient;
-}
-
-// this is needed because in development we don't want to restart
-// the server with every change, but we want to make sure we don't
-// create a new connection to the DB with every change either.
-// in production we'll have a single connection to the DB.
-if (process.env.NODE_ENV === "production") {
-  prisma = getClient();
-} else {
-  if (!global.__db__) {
-    global.__db__ = getClient();
-  }
-  prisma = global.__db__;
-}
-
-function getClient() {
-  const { DATABASE_URL } = process.env;
-  invariant(typeof DATABASE_URL === "string", "DATABASE_URL env var not set");
-
-  // Remove the username:password in the url and print that to the console
-  const urlWithoutCredentials = new URL(DATABASE_URL);
-  urlWithoutCredentials.password = "";
-
-  console.log(
-    `1. 🔌 setting up prisma client to ${urlWithoutCredentials.toString()}`
-  );
-
-  const client = new PrismaClient({
-    datasources: {
-      db: {
-        url: DATABASE_URL,
-      },
-    },
-    log: ["warn", "error"],
-  });
-
-  console.log(`2.0 🔌 prisma client connecting`);
-
-  // connect eagerly
-  client.$connect();
-
-  console.log(`3.0 🔌 prisma client connected`);
-
-  return client;
-}
-
-export { prisma };
-export type { PrismaClient } from ".prisma/client";

apps/integrations/src/cache/postgresCache.ts

@@ -1,53 +0,0 @@
-import type { Prisma, Cache } from ".prisma/client";
-import { prisma } from "./db.server";
-import { CacheService } from "core/cache/types";
-
-export class PostgresCacheService implements CacheService {
-  constructor(private readonly namespace: string) {}
-
-  async get(key: string) {
-    const cachedRow = await prisma.cache.findFirst({
-      where: {
-        namespace: this.namespace,
-        key,
-        OR: [
-          { expiresAt: null },
-          {
-            expiresAt: {
-              gt: new Date(),
-            },
-          },
-        ],
-      },
-    });
-
-    if (cachedRow) {
-      return cachedRow.value;
-    }
-
-    return null;
-  }
-
-  async set(key: string, value: string, ttl?: number): Promise<void> {
-    const expiresAt = ttl ? new Date(Date.now() + ttl * 1000) : null;
-
-    await prisma.cache.upsert({
-      where: {
-        namespace_key: {
-          namespace: this.namespace,
-          key,
-        },
-      },
-      update: {
-        value,
-        expiresAt,
-      },
-      create: {
-        namespace: this.namespace,
-        key,
-        value,
-        expiresAt,
-      },
-    });
-  }
-}

apps/integrations/src/core/action/getDisplayProperties.ts

@@ -1,27 +0,0 @@
-import { EndpointSpecMetadata } from "core/endpoint/types";
-import { RequestData } from "core/request/types";
-
-export async function getDisplayProperties(
-  data: RequestData,
-  displayProperties: EndpointSpecMetadata["displayProperties"]
-) {
-  return {
-    title: interpolateString(displayProperties.title, {
-      parameters: data.parameters,
-      body: data.body,
-    }),
-  };
-}
-
-function interpolateString(
-  template: string,
-  data: Record<string | number, any>
-) {
-  return template.replace(/\${([^}]+)}/g, (_, key) => {
-    return key
-      .split(".")
-      .reduce((obj: Record<string | number, any>, prop: string | number) => {
-        return obj[prop];
-      }, data);
-  });
-}

apps/integrations/src/core/action/makeAction.ts

@@ -1,74 +0,0 @@
-import { CacheService } from "core/cache/types";
-import { Endpoint } from "core/endpoint/types";
-import { RequestData, RequestResponse } from "core/request/types";
-import { getDisplayProperties } from "./getDisplayProperties";
-import { Action, Metadata } from "./types";
-import { makeInputSpec, makeOutputSpec } from "./utilities";
-
-/** Create an action where you specify the spec and action */
-export const makeAdvancedAction = ({
-  endpoint,
-  spec,
-  action,
-}: {
-  endpoint: Endpoint;
-  spec: Action["spec"];
-  action: (
-    data: RequestData,
-    cache?: CacheService,
-    metadata?: Metadata
-  ) => Promise<RequestResponse>;
-}) => {
-  const displayProperties = async (data: RequestData) => {
-    return getDisplayProperties(
-      data,
-      endpoint.spec.endpointSpec.metadata.displayProperties
-    );
-  };
-
-  return {
-    name: endpoint.spec.endpointSpec.metadata.name,
-    description: endpoint.spec.endpointSpec.metadata.description,
-    path: endpoint.spec.endpointSpec.path,
-    method: endpoint.spec.endpointSpec.method,
-    spec,
-    action,
-    displayProperties,
-  };
-};
-
-/** Creates an action that calls an endpoint */
-export const makeSimpleAction = (endpoint: Endpoint) => {
-  const action = async (
-    data: RequestData,
-    cache?: CacheService,
-    metadata?: Metadata
-  ) => {
-    //a simple request doesn't use the cache or metadata
-    return await endpoint.request(data);
-  };
-
-  return makeAdvancedAction({
-    endpoint,
-    spec: {
-      input: makeInputSpec(endpoint),
-      output: makeOutputSpec(endpoint),
-    },
-    action,
-  });
-};
-
-export const makeSimpleActions = <
-  TEndpoints extends Record<string, Endpoint>,
-  K extends keyof TEndpoints
->(
-  endpoints: TEndpoints
-): Record<K, Action> => {
-  const actions: any = {};
-
-  Object.entries(endpoints).forEach(([name, endpoint]) => {
-    actions[name as K] = makeSimpleAction(endpoint);
-  });
-
-  return actions;
-};

apps/integrations/src/core/action/types.ts

@@ -1,42 +0,0 @@
-import { CacheService } from "core/cache/types";
-import { EndpointSpec, HTTPMethod } from "core/endpoint/types";
-import { RequestData, RequestResponse } from "core/request/types";
-
-export type InputSpec = {
-  security?: EndpointSpec["security"];
-  parameters?: EndpointSpec["parameters"];
-  body?: NonNullable<EndpointSpec["request"]["body"]>["schema"];
-};
-
-export type OutputSpec = {
-  responses: EndpointSpec["responses"];
-};
-
-export type Metadata = Record<string, any>;
-
-export type DisplayProperties = {
-  title: string;
-};
-
-export type Action = {
-  name: string;
-  description: string;
-  path: string;
-  method: HTTPMethod;
-  spec: {
-    input: InputSpec;
-    output: OutputSpec;
-  };
-  action: (
-    /** The data to be sent to the endpoint */
-    data: RequestData,
-    /** The cache service to use for caching */
-    cache?: CacheService,
-    /** Additional metadata that can be used to modify the request */
-    metadata?: Metadata
-  ) => Promise<RequestResponse>;
-  displayProperties: (
-    /** The data to be sent to the endpoint */
-    data: RequestData
-  ) => Promise<DisplayProperties>;
-};

apps/integrations/src/core/action/utilities.ts

@@ -1,49 +0,0 @@
-import { Endpoint } from "core/endpoint/types";
-import { InputSpec, OutputSpec } from "./types";
-
-export function makeInputSpec(endpoint: Endpoint): InputSpec {
-  return {
-    security: endpoint.spec.endpointSpec.security,
-    parameters: endpoint.spec.endpointSpec.parameters,
-    body: endpoint.spec.endpointSpec.request.body?.schema,
-  };
-}
-
-export function makeOutputSpec(endpoint: Endpoint): OutputSpec {
-  return {
-    responses: endpoint.spec.endpointSpec.responses,
-  };
-}
-
-export function combineSecurityScopes(
-  securities: (Record<string, string[]> | undefined)[]
-): Record<string, string[]> | undefined {
-  const securityA = securities[0];
-  const securityB = securities[1];
-
-  //where a key already exists, concatenate the scope arrays together
-  //where a key does not exist, add it to the object
-  let combined: Record<string, string[]> = {};
-
-  if (securityA) {
-    combined = {
-      ...securityA,
-    };
-  }
-
-  if (securityB) {
-    for (const key in securityB) {
-      if (combined[key]) {
-        combined[key] = [...combined[key], ...securityB[key]];
-      } else {
-        combined[key] = securityB[key];
-      }
-    }
-  }
-
-  if (securities.length > 2) {
-    return combineSecurityScopes([combined, ...securities.slice(2)]);
-  }
-
-  return combined;
-}

apps/integrations/src/core/authentication/credentials.test.ts

@@ -1,82 +0,0 @@
-import { EndpointSpec } from "core/endpoint/types";
-import { FetchConfig } from "core/request/types";
-import { expect, test } from "vitest";
-import { checkRequiredScopes, applyCredentials } from "./credentials";
-import { AuthCredentials, IntegrationAuthentication } from "./types";
-
-test("Required scopes present", async () => {
-  const credentials: AuthCredentials = {
-    type: "oauth2",
-    name: "authName",
-    accessToken: "token",
-    scopes: ["scope1", "scope2"],
-  };
-
-  const requiredScopes = ["scope1", "scope2"];
-
-  const result = checkRequiredScopes(requiredScopes, credentials);
-  expect(result.success).toEqual(true);
-});
-
-test("Required scopes missing", async () => {
-  const credentials: AuthCredentials = {
-    type: "oauth2",
-    name: "authName",
-    accessToken: "token",
-    scopes: ["scope1", "scope2"],
-  };
-
-  const requiredScopes = ["scope1", "scope2", "scope3"];
-
-  const result = checkRequiredScopes(requiredScopes, credentials);
-  expect(result.success).toEqual(false);
-  if (result.success) throw new Error("Should not be success");
-  expect(result.missingScopes).toEqual(["scope3"]);
-});
-
-test("Applied credentials", async () => {
-  const credentials: AuthCredentials = {
-    type: "oauth2",
-    name: "authName",
-    accessToken: "123456",
-    scopes: ["scope1", "scope2"],
-  };
-  const endpointSecurity: EndpointSpec["security"] = {
-    authName: ["scope1", "scope2"],
-  };
-
-  const integrationAuthentication: IntegrationAuthentication = {
-    authName: {
-      type: "oauth2",
-      placement: {
-        in: "header",
-        type: "bearer",
-        key: "Authorization",
-      },
-      authorizationUrl: "https://example.com",
-      tokenUrl: "https://example.com",
-      flow: "accessCode",
-      scopes: {
-        scope1: "scope1",
-        scope2: "scope2",
-      },
-    },
-  };
-
-  const existingFetch: FetchConfig = {
-    url: "https://example.com",
-    method: "GET",
-    headers: {
-      "Content-Type": "application/json",
-    },
-  };
-
-  const fetchConfig = applyCredentials(existingFetch, {
-    endpointSecurity,
-    authentication: integrationAuthentication,
-    credentials,
-  });
-
-  expect(fetchConfig.headers.Authorization).toEqual("Bearer 123456");
-  expect(fetchConfig.headers["Content-Type"]).toEqual("application/json");
-});

apps/integrations/src/core/authentication/credentials.ts

@@ -1,107 +0,0 @@
-import { EndpointSpec } from "core/endpoint/types";
-import { InsufficientScopesError } from "core/request/errors";
-import { FetchConfig } from "core/request/types";
-import { IntegrationAuthentication, AuthCredentials } from "./types";
-
-/** Apply the given credentials to the given fetch config */
-export function applyCredentials(
-  fetch: FetchConfig,
-  {
-    endpointSecurity,
-    authentication,
-    credentials,
-  }: {
-    endpointSecurity: EndpointSpec["security"];
-    authentication: IntegrationAuthentication;
-    credentials: AuthCredentials;
-  }
-): FetchConfig {
-  if (endpointSecurity === undefined) return fetch;
-  // check if the credentials have the required scopes
-  const requiredScopes = endpointSecurity[credentials.name] ?? [];
-  const scopesCheckResult = checkRequiredScopes(requiredScopes, credentials);
-  if (!scopesCheckResult.success) {
-    const error: InsufficientScopesError = {
-      type: "insufficient_scopes",
-      missingScopes: scopesCheckResult.missingScopes,
-    };
-    throw error;
-  }
-
-  return addCredentialsToConfig(fetch, { authentication, credentials });
-}
-
-export function addCredentialsToConfig(
-  fetch: FetchConfig,
-  {
-    authentication,
-    credentials,
-  }: {
-    authentication: IntegrationAuthentication;
-    credentials: AuthCredentials;
-  }
-) {
-  // apply the credentials
-  switch (credentials.type) {
-    case "oauth2": {
-      const authConfig = authentication[credentials.name];
-      switch (authConfig.placement.in) {
-        case "header": {
-          fetch.headers[
-            authConfig.placement.key
-          ] = `Bearer ${credentials.accessToken}`;
-          return fetch;
-        }
-      }
-      break;
-    }
-    case "api_key": {
-      const authConfig = authentication[credentials.name];
-      if (authConfig.placement.in === "header") {
-        let value = "";
-        switch (authConfig.placement.type) {
-          case "basic":
-            value = `Basic ${credentials.api_key}`;
-            break;
-          case "bearer":
-            value = `Bearer ${credentials.api_key}`;
-            break;
-        }
-        fetch.headers[authConfig.placement.key] = value;
-      }
-      return fetch;
-    }
-  }
-
-  throw new Error("Invalid credentials");
-}
-
-type ScopesCheckResult =
-  | {
-      success: true;
-    }
-  | {
-      success: false;
-      missingScopes: string[];
-    };
-
-/** Check if the given credentials have the required scopes */
-export function checkRequiredScopes(
-  requiredScopes: string[],
-  credentials: AuthCredentials
-): ScopesCheckResult {
-  const missingScopes = requiredScopes.filter(
-    (scope) => !credentials.scopes.includes(scope)
-  );
-
-  if (missingScopes.length > 0) {
-    return {
-      success: false,
-      missingScopes,
-    };
-  }
-
-  return {
-    success: true,
-  };
-}

apps/integrations/src/core/authentication/types.ts

@@ -1,61 +0,0 @@
-import { z } from "zod";
-
-export type IntegrationAuthentication = Record<
-  string,
-  AuthenticationDefinition
->;
-
-type AuthenticationDefinition = OAuth2Authentication | APIKeyAuthentication;
-
-type OAuth2Authentication = {
-  type: "oauth2";
-  placement: AuthenticationPlacement;
-  authorizationUrl: string;
-  tokenUrl: string;
-  flow: "accessCode" | "implicit" | "password" | "application";
-  scopes: Record<string, string>;
-};
-
-type APIKeyAuthentication = {
-  type: "api_key";
-  placement: AuthenticationPlacement;
-  documentation: string;
-  scopes: Record<string, string>;
-  additionalFields?: {
-    key: string;
-    fieldType: "text";
-    name: string;
-    placeholder?: string;
-    description: string;
-  }[];
-};
-
-type AuthenticationPlacement = HeaderAuthentication;
-
-interface HeaderAuthentication {
-  in: "header";
-  type: "basic" | "bearer";
-  key: string;
-}
-
-const OAuth2CredentialsSchema = z.object({
-  type: z.literal("oauth2"),
-  name: z.string(),
-  accessToken: z.string(),
-  scopes: z.array(z.string()),
-});
-
-const APIKeyCredentialsSchema = z.object({
-  type: z.literal("api_key"),
-  name: z.string(),
-  api_key: z.string(),
-  additionalFields: z.record(z.string(), z.string()).optional(),
-  scopes: z.array(z.string()),
-});
-
-export const AuthCredentialsSchema = z.discriminatedUnion("type", [
-  OAuth2CredentialsSchema,
-  APIKeyCredentialsSchema,
-]);
-
-export type AuthCredentials = z.infer<typeof AuthCredentialsSchema>;

apps/integrations/src/core/cache/types.ts

@@ -1,4 +0,0 @@
-export interface CacheService {
-  get: (key: string) => Promise<string | null>;
-  set: (key: string, value: string, ttl?: number) => Promise<void>;
-}

apps/integrations/src/core/catalog.ts

@@ -1,5 +0,0 @@
-import { Service } from "./service/types";
-
-export type Catalog = {
-  services: Record<string, Service>;
-};

apps/integrations/src/core/endpoint/endpoint.ts

@@ -1,36 +0,0 @@
-import { IntegrationAuthentication } from "core/authentication/types";
-import { requestEndpoint } from "core/request/requestEndpoint";
-import { RequestData, RequestResponse, RequestSpec } from "core/request/types";
-import { Endpoint, EndpointSpec } from "./types";
-
-export const makeEndpoint = (spec: RequestSpec) => {
-  const request = async (data: RequestData) => {
-    return await requestEndpoint(spec, data);
-  };
-
-  return {
-    spec,
-    request,
-  };
-};
-
-export const makeEndpoints = <
-  TSpecs extends Record<string, EndpointSpec>,
-  K extends keyof TSpecs
->(
-  baseUrl: string,
-  authentication: IntegrationAuthentication,
-  specs: TSpecs
-): Record<K, Endpoint> => {
-  const endpoints: any = {};
-
-  Object.entries(specs).forEach(([name, spec]) => {
-    endpoints[name as K] = makeEndpoint({
-      baseUrl,
-      endpointSpec: spec,
-      authentication,
-    });
-  });
-
-  return endpoints;
-};

apps/integrations/src/core/endpoint/types.ts

@@ -1,71 +0,0 @@
-import { RequestData, RequestResponse, RequestSpec } from "core/request/types";
-import { JSONSchema } from "core/schemas/types";
-import { z } from "zod";
-
-export type Endpoint = {
-  spec: RequestSpec;
-  request: (data: RequestData) => Promise<RequestResponse>;
-};
-
-export const HTTPMethodSchema = z.union([
-  z.literal("GET"),
-  z.literal("POST"),
-  z.literal("PUT"),
-  z.literal("PATCH"),
-  z.literal("DELETE"),
-  z.literal("HEAD"),
-  z.literal("OPTIONS"),
-  z.literal("TRACE"),
-]);
-
-export type HTTPMethod = z.infer<typeof HTTPMethodSchema>;
-
-export interface EndpointSpec {
-  path: string;
-  method: HTTPMethod;
-  metadata: EndpointSpecMetadata;
-  parameters?: EndpointSpecParameter[];
-  security?: Record<string, string[]>;
-  request: EndpointSpecRequest;
-  responses: { default: EndpointSpecResponse[] } & Record<
-    string,
-    EndpointSpecResponse[]
-  >;
-}
-
-export interface EndpointSpecParameter {
-  name: string;
-  description: string;
-  in: "query" | "path" | "header";
-  required?: boolean;
-  schema: JSONSchema;
-}
-
-interface EndpointSpecRequest {
-  headers?: Record<string, string>;
-  body?: {
-    schema: JSONSchema;
-  };
-}
-
-export interface EndpointSpecResponse {
-  success: boolean;
-  name: string;
-  description?: string;
-  schema?: JSONSchema;
-}
-
-export interface EndpointSpecMetadata {
-  name: string;
-  description: string;
-  displayProperties: {
-    title: string;
-  };
-  externalDocs?: ExternalDocs;
-  tags: string[];
-}
-
-interface ExternalDocs {
-  description: string;
-  url: string;
-}

apps/integrations/src/core/fetch/fetchUtilities.ts

@@ -1,43 +0,0 @@
-import { RequestResponse } from "core/request/types";
-import { type Response } from "node-fetch";
-
-export async function getFetch() {
-  return (await import("node-fetch")).default;
-}
-
-export async function safeGetJson(response: Response) {
-  try {
-    return await response.json();
-  } catch (error) {
-    return undefined;
-  }
-}
-
-export function normalizeHeaders(headers: Headers): Record<string, string> {
-  const normalizedHeaders: Record<string, string> = {};
-
-  headers.forEach((value, key) => {
-    normalizedHeaders[key.toLowerCase()] = value;
-  });
-
-  return normalizedHeaders;
-}
-
-export function responseFromCaughtError(error: any): RequestResponse {
-  if (error instanceof Error) {
-    return {
-      success: false,
-      status: 400,
-      headers: {},
-      body: { error: error.message },
-    };
-  }
-
-  //convert the error into JSON
-  return {
-    success: false,
-    status: 400,
-    headers: {},
-    body: { error: JSON.stringify(error) },
-  };
-}

apps/integrations/src/core/fetch/serviceFetch.test.ts

@@ -1,29 +0,0 @@
-import { authentication } from "integrations/airtable/authentication";
-import { startNock, stopNock } from "testing/nock";
-import { describe, expect, test } from "vitest";
-import { serviceFetch } from "./serviceFetch";
-const authToken = () => process.env.AIRTABLE_TOKEN ?? "";
-
-describe("serviceFetch", async () => {
-  test("simple GET", async () => {
-    const accessToken = authToken();
-
-    const nockDone = await startNock("serviceFetch.simple.get");
-    const response = await serviceFetch({
-      url: "https://api.airtable.com/v0/appBlf3KsalIQeMUo/tblvXn2TOeVPC9c6m/recHcnB1MbBr9Rd2P",
-      method: "GET",
-      authentication: authentication,
-      credentials: {
-        type: "oauth2",
-        name: "oauth",
-        accessToken,
-        scopes: ["data.records:read"],
-      },
-    });
-
-    expect(response.status).toEqual(200);
-    expect(response.success).toEqual(true);
-    expect(response.body).not.toBeNull();
-    stopNock(nockDone);
-  });
-});

apps/integrations/src/core/fetch/serviceFetch.ts

@@ -1,73 +0,0 @@
-import { addCredentialsToConfig } from "core/authentication/credentials";
-import {
-  AuthCredentials,
-  IntegrationAuthentication,
-} from "core/authentication/types";
-import { HTTPMethod } from "core/endpoint/types";
-import { FetchConfig, RequestResponse } from "core/request/types";
-import {
-  getFetch,
-  normalizeHeaders,
-  responseFromCaughtError,
-  safeGetJson,
-} from "./fetchUtilities";
-
-export type ServiceFetchOptions = {
-  url: string;
-  method: HTTPMethod;
-  headers?: Record<string, string>;
-  body?: any;
-  authentication: IntegrationAuthentication;
-  credentials?: AuthCredentials;
-};
-
-export async function serviceFetch({
-  url,
-  method = "GET",
-  headers,
-  body,
-  credentials,
-  authentication,
-}: ServiceFetchOptions): Promise<RequestResponse> {
-  let fetchConfig: FetchConfig = {
-    url,
-    method,
-    headers: {
-      ...headers,
-    },
-    body: JSON.stringify(body),
-  };
-
-  if (credentials == null) {
-    throw {
-      type: "missing_credentials",
-    };
-  }
-
-  fetchConfig = addCredentialsToConfig(fetchConfig, {
-    authentication,
-    credentials,
-  });
-
-  const fetchObject = {
-    method: fetchConfig.method,
-    headers: fetchConfig.headers,
-    body: fetchConfig.body,
-  };
-
-  try {
-    const fetch = await getFetch();
-    const response = await fetch(url, fetchObject);
-
-    const json = await safeGetJson(response);
-
-    return {
-      success: response.ok,
-      status: response.status,
-      headers: normalizeHeaders(response.headers),
-      body: json,
-    };
-  } catch (error: any) {
-    return responseFromCaughtError(error);
-  }
-}

apps/integrations/src/core/request/errors.ts

@@ -1,66 +0,0 @@
-import { JSONSchemaError } from "core/schemas/types";
-
-export type RequestError =
-  | RequestBodyInvalid
-  | ParameterMissing
-  | ParametersInvalid
-  | ExtraParametersError
-  | InsufficientScopesError
-  | MissingResponseSpec
-  | ResponseBodyInvalid
-  | BodyMissing
-  | MissingCredentialsError;
-
-export interface RequestBodyInvalid {
-  type: "request_body_invalid";
-  errors: any[];
-}
-
-export interface BodyMissing {
-  type: "missing_body";
-}
-
-export interface ParameterMissing {
-  type: "missing_parameter";
-  parameter: {
-    name: string;
-  };
-}
-
-export interface ParametersInvalid {
-  type: "parameter_invalid";
-  parameter: {
-    name: string;
-    value: any;
-  };
-  errors: JSONSchemaError[];
-}
-
-export interface ExtraParametersError {
-  type: "extra_parameters";
-  parameters: Array<{
-    name: string;
-    value: any;
-  }>;
-}
-
-export interface MissingCredentialsError {
-  type: "missing_credentials";
-}
-
-export interface InsufficientScopesError {
-  type: "insufficient_scopes";
-  missingScopes: string[];
-}
-
-export interface MissingResponseSpec {
-  type: "no_response_spec";
-  status: number;
-}
-
-export interface ResponseBodyInvalid {
-  type: "response_invalid";
-  errors: Array<{ name: string; errors: JSONSchemaError[] }>;
-  status: number;
-  body?: any;
-}

apps/integrations/src/core/request/requestEndpoint.ts

@@ -1,209 +0,0 @@
-import { applyCredentials } from "core/authentication/credentials";
-import { EndpointSpec, EndpointSpecResponse } from "core/endpoint/types";
-import {
-  getFetch,
-  normalizeHeaders,
-  responseFromCaughtError,
-  safeGetJson,
-} from "core/fetch/fetchUtilities";
-import { JSONSchemaError } from "core/schemas/types";
-import { validate } from "core/schemas/validate";
-import {
-  FetchConfig,
-  RequestData,
-  RequestResponse,
-  RequestSpec,
-} from "./types";
-
-export async function requestEndpoint(
-  { baseUrl, endpointSpec, authentication }: RequestSpec,
-  { parameters, body, credentials }: RequestData
-): Promise<RequestResponse> {
-  const { method, security, request, responses } = endpointSpec;
-  let path = endpointSpec.path;
-
-  // validate the request body
-  if (body == null && request.body?.schema != null) {
-    throw {
-      type: "missing_body",
-    };
-  }
-
-  const requestValid = await validate(body, request.body?.schema);
-  if (!requestValid.success) {
-    throw {
-      type: "request_body_invalid",
-      errors: requestValid.errors,
-    };
-  }
-
-  let headers: Record<string, string> = {};
-
-  // validate and add the parameters
-  if (endpointSpec.parameters != null) {
-    for (const parameter of endpointSpec.parameters) {
-      const { name, in: location, required } = parameter;
-
-      // if the parameter is missing
-      if (parameters === undefined || parameters[name] == null) {
-        if (required) {
-          throw {
-            type: "missing_parameter",
-            parameter: {
-              name,
-            },
-          };
-        } else {
-          continue;
-        }
-      }
-
-      const element = parameters[name];
-      //validate the parameter against the schema
-      const valid = await validate(element, parameter.schema);
-      if (!valid.success) {
-        throw {
-          type: "parameter_invalid",
-          parameter: {
-            name,
-            value: element,
-          },
-          errors: valid.errors,
-        };
-      }
-
-      //add the parameter
-      switch (location) {
-        case "path":
-          path = path.replace(`{${name}}`, element as string);
-          break;
-        case "query": {
-          if (parameter.schema?.type === "array") {
-            const array = element as Array<string>;
-            for (const item of array) {
-              path = `${path}${path.includes("?") ? "&" : "?"}${name}=${item}`;
-            }
-            break;
-          }
-
-          path = `${path}${path.includes("?") ? "&" : "?"}${name}=${element}`;
-          break;
-        }
-        case "header":
-          headers = {
-            ...headers,
-            [name]: `${element}`,
-          };
-          break;
-      }
-    }
-  }
-
-  // add headers from the config
-  for (const name in request.headers) {
-    if (Object.prototype.hasOwnProperty.call(request.headers, name)) {
-      const element = request.headers[name];
-      headers = {
-        ...headers,
-        [name]: element,
-      };
-    }
-  }
-
-  // build the fetch config
-  const url = `${baseUrl}${path}`;
-  let fetchConfig: FetchConfig = {
-    url,
-    method,
-    headers: {
-      ...headers,
-    },
-    body: JSON.stringify(body),
-  };
-
-  // apply credentials
-  if (security != null) {
-    if (credentials == null) {
-      throw {
-        type: "missing_credentials",
-      };
-    }
-    fetchConfig = applyCredentials(fetchConfig, {
-      endpointSecurity: security,
-      authentication,
-      credentials,
-    });
-  }
-
-  // do the fetch and try get the JSON
-  const fetchObject = {
-    method: fetchConfig.method,
-    headers: fetchConfig.headers,
-    body: fetchConfig.body,
-  };
-
-  try {
-    const fetch = await getFetch();
-    const response = await fetch(fetchConfig.url, fetchObject);
-    const json = await safeGetJson(response);
-
-    // validate the response against the specs
-    const responseSpecs = getResponseSpecsForStatusCode(
-      response.status,
-      responses
-    );
-    if (!responseSpecs) {
-      throw {
-        type: "no_response_spec",
-        status: response.status,
-      };
-    }
-
-    // start with the first spec and loop through them, if one succeeds then return that
-    const specErrors: Array<{ name: string; errors: JSONSchemaError[] }> = [];
-    for (const spec of responseSpecs) {
-      const responseValid = await validate(json, spec.schema);
-      if (responseValid.success) {
-        return {
-          success: spec.success,
-          status: response.status,
-          headers: normalizeHeaders(response.headers),
-          body: json,
-        };
-      } else {
-        if (responseValid.errors != null) {
-          specErrors.push({ name: spec.name, errors: responseValid.errors });
-        }
-      }
-    }
-
-    throw {
-      type: "response_invalid",
-      status: response.status,
-      body: json,
-      errors: specErrors,
-    };
-  } catch (error: any) {
-    return responseFromCaughtError(error);
-  }
-}
-
-/** Get the appropriate endpoint response object based on the status code. It supports wild cards like 20x and 2xx */
-function getResponseSpecsForStatusCode(
-  statusCode: number,
-  endpointResponseSpecs: EndpointSpec["responses"]
-): EndpointSpecResponse[] {
-  let specs = endpointResponseSpecs[statusCode.toString()];
-  if (specs) return specs;
-
-  specs =
-    endpointResponseSpecs[
-      `${statusCode.toString().charAt(0)}${statusCode.toString().charAt(1)}x`
-    ];
-  if (specs) return specs;
-
-  specs = endpointResponseSpecs[`${statusCode.toString().charAt(0)}xx`];
-  if (specs) return specs;
-
-  return endpointResponseSpecs.default;
-}

apps/integrations/src/core/request/types.ts

@@ -1,30 +0,0 @@
-import {
-  IntegrationAuthentication,
-  AuthCredentials,
-} from "core/authentication/types";
-import { HTTPMethod, EndpointSpec } from "core/endpoint/types";
-
-export interface FetchConfig {
-  url: string;
-  method: HTTPMethod;
-  headers: Record<string, string>;
-  body?: any;
-}
-
-export interface RequestSpec {
-  baseUrl: string;
-  endpointSpec: EndpointSpec;
-  authentication: IntegrationAuthentication;
-}
-export interface RequestData {
-  parameters?: Record<string, any>;
-  body?: any;
-  credentials?: AuthCredentials;
-}
-
-export interface RequestResponse {
-  success: boolean;
-  status: number;
-  headers?: Record<string, string>;
-  body?: any;
-}

apps/integrations/src/core/schemas/json-schema-deref-sync.d.ts

@@ -1 +0,0 @@
-declare module "json-schema-deref-sync";

apps/integrations/src/core/schemas/makeSchema.ts

@@ -1,141 +0,0 @@
-import { JSONSchema } from "./types";
-
-export function makeStringSchema(
-  title: string,
-  description?: string,
-  options?: {
-    defaultValue?: string;
-    enum?: string[];
-  }
-): JSONSchema {
-  const schema: JSONSchema = {
-    type: "string",
-    title,
-  };
-
-  if (description) {
-    schema.description = description;
-  }
-
-  if (options?.defaultValue) {
-    schema.default = options.defaultValue;
-  }
-
-  if (options?.enum) {
-    schema.enum = options.enum;
-  }
-
-  return schema;
-}
-
-export function makeNumberSchema(
-  title: string,
-  description?: string,
-  options?: {
-    defaultValue: number;
-  }
-): JSONSchema {
-  const schema: JSONSchema = {
-    type: "number",
-    title,
-  };
-
-  if (description) {
-    schema.description = description;
-  }
-
-  if (options?.defaultValue) {
-    schema.default = options.defaultValue;
-  }
-
-  return schema;
-}
-
-export function makeBooleanSchema(
-  title: string,
-  description?: string,
-  options?: {
-    defaultValue?: boolean;
-    enum?: boolean;
-  }
-): JSONSchema {
-  const schema: JSONSchema = {
-    title,
-    type: "boolean",
-  };
-
-  if (description) {
-    schema.description = description;
-  }
-
-  if (options?.defaultValue) {
-    schema.default = options.defaultValue;
-  }
-
-  if (options?.enum) {
-    schema.enum = [options.enum];
-  }
-
-  return schema;
-}
-
-export function makeArraySchema(title: string, items: JSONSchema): JSONSchema {
-  return {
-    type: "array",
-    title,
-    items,
-  };
-}
-
-export function makeObjectSchema(
-  title: string,
-  options: {
-    optionalProperties?: Record<string, JSONSchema>;
-    requiredProperties?: Record<string, JSONSchema>;
-    additionalProperties?: boolean | JSONSchema;
-  }
-): JSONSchema {
-  let properties: Record<string, JSONSchema> | undefined = undefined;
-
-  if (options.optionalProperties || options.requiredProperties) {
-    properties = {};
-  }
-
-  if (options.optionalProperties) {
-    properties = {
-      ...properties,
-      ...options.optionalProperties,
-    };
-  }
-
-  if (options.requiredProperties) {
-    properties = {
-      ...properties,
-      ...options.requiredProperties,
-    };
-  }
-
-  return {
-    type: "object",
-    title,
-    properties,
-    required: options.requiredProperties
-      ? Object.keys(options.requiredProperties)
-      : undefined,
-    additionalProperties: options.additionalProperties,
-  };
-}
-
-export function makeOneOf(title: string, schemas: JSONSchema[]): JSONSchema {
-  return {
-    title,
-    oneOf: schemas,
-  };
-}
-
-export function makeAnyOf(title: string, schemas: JSONSchema[]): JSONSchema {
-  return {
-    title,
-    anyOf: schemas,
-  };
-}

apps/integrations/src/core/schemas/openApi.test.ts

@@ -1,13 +0,0 @@
-import { expect, test } from "vitest";
-import spec from "./test-openapi-spec-v2.json";
-import { dereferenceSpec, schemaFromOpenApiSpecV2 } from "./openApi";
-
-test("Returns the correct schema", async () => {
-  const dereferenced = dereferenceSpec(spec);
-  const schema = schemaFromOpenApiSpecV2(
-    dereferenced,
-    "/paths//conversations.list/get/responses/200/schema"
-  );
-  expect(schema.type).toEqual("object");
-  expect(schema.additionalProperties).toEqual(false);
-});

apps/integrations/src/core/schemas/openApi.ts

@@ -1,15 +0,0 @@
-import deref from "json-schema-deref-sync";
-import pointer from "json-pointer";
-import { type JSONSchema } from "./types";
-
-export function dereferenceSpec(spec: any): any {
-  return deref(spec);
-}
-
-// todo validate that it's a valid json schema
-export function schemaFromOpenApiSpecV2(spec: any, path: string): JSONSchema {
-  // we need to escape the path because it contains ~ and / characters
-  path = path.replace(/~/g, "~0").replace(/\/\//g, "/~1");
-  const schema = pointer.get(spec as pointer.JsonObject, path);
-  return schema;
-}

apps/integrations/src/core/schemas/types.ts

@@ -1,4 +0,0 @@
-import { Schema, OutputUnit } from "@cfworker/json-schema";
-
-export type JSONSchema = Schema;
-export type JSONSchemaError = OutputUnit;

apps/integrations/src/core/schemas/validate.ts

@@ -1,57 +0,0 @@
-import { JSONSchema } from "./types";
-
-export async function validate(data: any, schema?: JSONSchema) {
-  try {
-    if (schema === undefined) {
-      return {
-        success: true as const,
-      };
-    }
-
-    if (data === undefined) {
-      return {
-        success: false as const,
-        errors: [
-          {
-            keyword: "undefined",
-            keywordLocation: "undefined",
-            instanceLocation: "undefined",
-            error: "data is undefined",
-          },
-        ],
-      };
-    }
-
-    const Validator = await getValidator();
-    const validator = new Validator(schema);
-    const result = validator.validate(data);
-    if (!result.valid) {
-      return {
-        success: false as const,
-        errors: result.errors,
-      };
-    }
-
-    return {
-      success: true as const,
-    };
-  } catch (e: any) {
-    console.error(e);
-    return {
-      success: false as const,
-      errors: [
-        {
-          keyword: "undefined",
-          keywordLocation: "undefined",
-          instanceLocation: "undefined",
-          error: e.toString(),
-        },
-      ],
-    };
-  }
-}
-
-async function getValidator() {
-  const tool = await import("@cfworker/json-schema");
-  return tool.Validator;
-}

apps/integrations/src/core/service/types.ts

@@ -1,13 +0,0 @@
-import { Action } from "core/action/types";
-import { IntegrationAuthentication } from "core/authentication/types";
-
-export type Service = {
-  name: string;
-  service: string;
-  version: string;
-  baseUrl: string;
-  live: boolean;
-  authentication: IntegrationAuthentication;
-  actions: Record<string, Action>;
-  retryableStatusCodes: number[];
-};

apps/integrations/src/core/validation/inputs.ts

@@ -1,109 +0,0 @@
-import { InputSpec } from "core/action/types";
-import { checkRequiredScopes } from "core/authentication/credentials";
-import { RequestError } from "core/request/errors";
-import { RequestData, RequestSpec } from "core/request/types";
-import { validate } from "core/schemas/validate";
-
-type ValidationResult =
-  | {
-      success: true;
-    }
-  | {
-      success: false;
-      error: RequestError;
-    };
-
-export async function validateInputs(
-  inputSpec: InputSpec,
-  { parameters, body, credentials }: RequestData
-): Promise<ValidationResult> {
-  if (inputSpec.security) {
-    if (credentials === undefined) {
-      return {
-        success: false,
-        error: {
-          type: "missing_credentials",
-        },
-      };
-    }
-    const requiredScopes = inputSpec.security[credentials.name] ?? [];
-    const result = checkRequiredScopes(requiredScopes, credentials);
-
-    if (!result.success) {
-      return {
-        success: false,
-        error: {
-          type: "insufficient_scopes",
-          missingScopes: result.missingScopes,
-        },
-      };
-    }
-  }
-
-  // validate the request body exists if it should
-  if (body == null && inputSpec.body != null) {
-    return {
-      success: false,
-      error: {
-        type: "missing_body",
-      },
-    };
-  }
-
-  //validate the request body against the schema
-  const requestValid = await validate(body, inputSpec.body);
-  if (!requestValid.success) {
-    return {
-      success: false,
-      error: {
-        type: "request_body_invalid",
-        errors: requestValid.errors,
-      },
-    };
-  }
-
-  //validate the parameters
-  if (inputSpec.parameters != null) {
-    for (const parameter of inputSpec.parameters) {
-      const { name, required } = parameter;
-
-      // if the parameter is missing
-      if (parameters === undefined || parameters[name] == null) {
-        if (required) {
-          return {
-            success: false,
-            error: {
-              type: "missing_parameter",
-              parameter: {
-                name,
-              },
-            },
-          };
-        } else {
-          continue;
-        }
-      }
-
-      const element = parameters[name];
-      //validate the parameter against the schema
-      const valid = await validate(element, parameter.schema);
-      if (!valid.success) {
-        return {
-          success: false,
-          error: {
-            type: "parameter_invalid",
-            parameter: {
-              name,
-              value: element,
-            },
-            errors: valid.errors,
-          },
-        };
-      }
-    }
-  }
-
-  return {
-    success: true,
-  };
-}

apps/integrations/src/fixtures/action.conversations.list.json

@@ -1,75 +0,0 @@
-[
-    {
-        "scope": "https://slack.com:443",
-        "method": "GET",
-        "path": "/api/conversations.list?limit=3",
-        "body": "",
-        "status": 200,
-        "response": [
-            "13a10900e45a2e5f5f662b462e26151762c481e859dbffffde6956a4097eb37f02aa77df7d8db575e3fea335752c0a039e145027e3d40b2d00eba4129d035425d78756f60ba204af170b1f86483c07dee72fe4317870e818d6cdc59b7d081878c0287860ab6e19cd3bf225f61be1bc2382ac0003f2e24cce767358bdc5ff27e6efe91e15d4cecfa8a6aaeaa6eeeaf667d1c49ef8fb383a0c655532f02ae7e5e72c8ac21662b52b9fbf2ed41ddc25fcc145a24ddfb1d411d84be8b4ff04dbb1b7b63ebf31fc3bfed0b427f133131f2a9ed4f65f9d87833bea7962df1dcbb40c575534c5b0150ce8e822c38f0726b8c1a31775894ab417e0d9318cb3c3335335424a29fa12934fe2d87ceefa561a8129f271cb7784f29485b4fd55e0491abc5f00ce6df0e046706922da1285233d68fe538d002f132a1be061b31db24c20e0de211ded031dfdc7403381cc3efb633986e2d0cae55b25863e82922a674915308c922049729e62948938a552fde834122d2af230a4ad5404eb6368268695184d5a6b371a5b02166f21265a49a688495cc46831de9149e52d1de762e84a357473940f6c7da403cff8c744e37194d39b870b86ef4f71a40ab47210eafedec73fa66bb99aa36aaa6acc30179aa4d4548102cec5c0a3e46de9484720aa1fd1458a057d8fa70eb30d722b62ad1bfdaf51732b0c120ad5261e0936adc6e03e980bf5b38efe852022fc10052d45ff3cb4e9a73bcca22c88540219b11b9ff60572714c9e4bede4f2e2fa97ef83a8cfa3a06aeb94601a99baa6d96693b436663171fddf9a64af46731d453115ddd0d4d9b7d5af35e352b56742300a313884c29056bed452699f53febf3154c19949cfb0d0f7301142aadafa91c1303d001ec4a72f59f8541fdd1e3d3cbc3c7f0437caf536fcff03"
-        ],
-        "rawHeaders": [
-            "date",
-            "Sat, 18 Feb 2023 16:06:41 GMT",
-            "server",
-            "Apache",
-            "x-powered-by",
-            "HHVM/4.153.1",
-            "access-control-allow-origin",
-            "*",
-            "referrer-policy",
-            "no-referrer",
-            "x-slack-backend",
-            "r",
-            "x-slack-unique-id",
-            "Y_D3kQScXBLeo8CcHpwldgAAECY",
-            "strict-transport-security",
-            "max-age=31536000; includeSubDomains; preload",
-            "access-control-allow-headers",
-            "slack-route, x-slack-version-ts, x-b3-traceid, x-b3-spanid, x-b3-parentspanid, x-b3-sampled, x-b3-flags",
-            "access-control-expose-headers",
-            "x-slack-req-id, retry-after",
-            "x-oauth-scopes",
-            "channels:read,channels:join,channels:manage,chat:write,groups:write,im:write,mpim:write,chat:write.customize,reactions:write",
-            "x-accepted-oauth-scopes",
-            "channels:read,groups:read,mpim:read,im:read,read",
-            "expires",
-            "Mon, 26 Jul 1997 05:00:00 GMT",
-            "cache-control",
-            "private, no-cache, no-store, must-revalidate",
-            "pragma",
-            "no-cache",
-            "x-xss-protection",
-            "0",
-            "x-content-type-options",
-            "nosniff",
-            "x-slack-req-id",
-            "10d2571cfa8e50b57c91d537221aff81",
-            "vary",
-            "Accept-Encoding",
-            "content-encoding",
-            "br",
-            "content-length",
-            "654",
-            "content-type",
-            "application/json; charset=utf-8",
-            "x-envoy-upstream-service-time",
-            "118",
-            "x-backend",
-            "main_normal main_canary_with_overflow main_control_with_overflow",
-            "x-server",
-            "slack-www-hhvm-main-iad-cxtr",
-            "x-slack-shared-secret-outcome",
-            "no-match",
-            "via",
-            "envoy-www-iad-scsk, envoy-edge-lhr-csok",
-            "x-edge-backend",
-            "envoy-www",
-            "x-slack-edge-shared-secret-outcome",
-            "no-match",
-            "connection",
-            "close"
-        ],
-        "responseIsBinary": false
-    }
-]

apps/integrations/src/fixtures/airtable.createRecord.json

@@ -1,53 +0,0 @@
-[
-    {
-        "scope": "https://api.airtable.com:443",
-        "method": "POST",
-        "path": "/v0/appBlf3KsalIQeMUo/tblvXn2TOeVPC9c6m",
-        "body": {
-            "fields": {
-                "Employee": "Employee single create"
-            }
-        },
-        "status": 200,
-        "response": {
-            "id": "recY9ZLK96wNBblmo",
-            "createdTime": "2023-02-18T17:05:53.000Z",
-            "fields": {
-                "Employee": "Employee single create"
-            }
-        },
-        "rawHeaders": [
-            "Date",
-            "Sat, 18 Feb 2023 17:05:53 GMT",
-            "Content-Type",
-            "120",
-            "Connection",
-            "close",
-            "Set-Cookie",
-            "AWSALB=uxQV2kzjELpFGUscnluykIVz7XOSrD1HxCYqoKdrnnPDt2Djy+EBfTKTDx4p0fAh1qD5c3/jRM2bCy9rhptozXyMsWOCDL7v2H3E6VRso6pGZm+kmcdzFjjoIO36; Expires=Sat, 25 Feb 2023 17:05:53 GMT; Path=/",
-            "Set-Cookie",
-            "AWSALBCORS=uxQV2kzjELpFGUscnluykIVz7XOSrD1HxCYqoKdrnnPDt2Djy+EBfTKTDx4p0fAh1qD5c3/jRM2bCy9rhptozXyMsWOCDL7v2H3E6VRso6pGZm+kmcdzFjjoIO36; Expires=Sat, 25 Feb 2023 17:05:53 GMT; Path=/; SameSite=None; Secure",
-            "Server",
-            "Tengine",
-            "Set-Cookie",
-            "brw=brwL5hqTq5iBqCg9Q; path=/; expires=Sun, 18 Feb 2024 17:05:53 GMT; domain=.airtable.com; samesite=none; secure",
-            "Strict-Transport-Security",
-            "max-age=31536000; includeSubDomains; preload",
-            "access-control-allow-origin",
-            "*",
-            "access-control-allow-methods",
-            "DELETE,GET,OPTIONS,PATCH,POST,PUT",
-            "access-control-allow-headers",
-            "authorization,content-length,content-type,user-agent,x-airtable-application-id,x-airtable-user-agent,x-api-version,x-requested-with",
-            "X-Frame-Options",
-            "DENY",
-            "X-Content-Type-Options",
-            "nosniff",
-            "Vary",
-            "Accept-Encoding",
-            "airtable-uncompressed-content-length",
-            "114"
-        ],
-        "responseIsBinary": false
-    }
-]

apps/integrations/src/fixtures/airtable.createRecords.json

@@ -1,73 +0,0 @@
-[
-    {
-        "scope": "https://api.airtable.com:443",
-        "method": "POST",
-        "path": "/v0/appBlf3KsalIQeMUo/tblvXn2TOeVPC9c6m",
-        "body": {
-            "records": [
-                {
-                    "fields": {
-                        "Employee": "Employee #1"
-                    }
-                },
-                {
-                    "fields": {
-                        "Employee": "Employee #2"
-                    }
-                }
-            ]
-        },
-        "status": 200,
-        "response": {
-            "records": [
-                {
-                    "id": "recGy1FsSzQnQ1Q5G",
-                    "createdTime": "2023-02-18T17:05:09.000Z",
-                    "fields": {
-                        "Employee": "Employee #1"
-                    }
-                },
-                {
-                    "id": "recfrk4NonMC37k3q",
-                    "createdTime": "2023-02-18T17:05:09.000Z",
-                    "fields": {
-                        "Employee": "Employee #2"
-                    }
-                }
-            ]
-        },
-        "rawHeaders": [
-            "Date",
-            "Sat, 18 Feb 2023 17:05:09 GMT",
-            "Content-Type",
-            "145",
-            "Connection",
-            "close",
-            "Set-Cookie",
-            "AWSALB=S3w+xLzGuJ4YZa7uQpSGEZYmk2IXTVlsJ9yVl+E2aUbEW5BtGoPl4lNa9pwXEpNvI29HEMTQgpuOXAnvfTFKzm+ot6y2DAQJwqa1nDNgQVRZ2z6lNn602nx0ebhI; Expires=Sat, 25 Feb 2023 17:05:08 GMT; Path=/",
-            "Set-Cookie",
-            "AWSALBCORS=S3w+xLzGuJ4YZa7uQpSGEZYmk2IXTVlsJ9yVl+E2aUbEW5BtGoPl4lNa9pwXEpNvI29HEMTQgpuOXAnvfTFKzm+ot6y2DAQJwqa1nDNgQVRZ2z6lNn602nx0ebhI; Expires=Sat, 25 Feb 2023 17:05:08 GMT; Path=/; SameSite=None; Secure",
-            "Server",
-            "Tengine",
-            "Set-Cookie",
-            "brw=brw7GK0C3hS9Fnih9; path=/; expires=Sun, 18 Feb 2024 17:05:08 GMT; domain=.airtable.com; samesite=none; secure",
-            "Strict-Transport-Security",
-            "max-age=31536000; includeSubDomains; preload",
-            "access-control-allow-origin",
-            "*",
-            "access-control-allow-methods",
-            "DELETE,GET,OPTIONS,PATCH,POST,PUT",
-            "access-control-allow-headers",
-            "authorization,content-length,content-type,user-agent,x-airtable-application-id,x-airtable-user-agent,x-api-version,x-requested-with",
-            "X-Frame-Options",
-            "DENY",
-            "X-Content-Type-Options",
-            "nosniff",
-            "Vary",
-            "Accept-Encoding",
-            "airtable-uncompressed-content-length",
-            "221"
-        ],
-        "responseIsBinary": false
-    }
-]

apps/integrations/src/fixtures/airtable.deleteRecord.json

@@ -1,97 +0,0 @@
-[
-    {
-        "scope": "https://api.airtable.com:443",
-        "method": "POST",
-        "path": "/v0/appBlf3KsalIQeMUo/tblvXn2TOeVPC9c6m",
-        "body": {
-            "fields": {
-                "Employee": "Delete now #3"
-            }
-        },
-        "status": 200,
-        "response": {
-            "id": "recyubpGhZWle9GOS",
-            "createdTime": "2023-02-18T17:25:39.000Z",
-            "fields": {
-                "Employee": "Delete now #3"
-            }
-        },
-        "rawHeaders": [
-            "Date",
-            "Sat, 18 Feb 2023 17:25:38 GMT",
-            "Content-Type",
-            "121",
-            "Connection",
-            "close",
-            "Set-Cookie",
-            "AWSALB=jt7yHA1t0HaG6Wp2xE4aJWZdQ59coYaZrRwqp8gwZmizt1A1N1H+xEqqycwyHEJtuK/6Rvc5FGcWdsJZQD2kbg5MSS0aropskjuOcOWICRp4+IHNWdYH5Osmcfre; Expires=Sat, 25 Feb 2023 17:25:38 GMT; Path=/",
-            "Set-Cookie",
-            "AWSALBCORS=jt7yHA1t0HaG6Wp2xE4aJWZdQ59coYaZrRwqp8gwZmizt1A1N1H+xEqqycwyHEJtuK/6Rvc5FGcWdsJZQD2kbg5MSS0aropskjuOcOWICRp4+IHNWdYH5Osmcfre; Expires=Sat, 25 Feb 2023 17:25:38 GMT; Path=/; SameSite=None; Secure",
-            "Server",
-            "Tengine",
-            "Set-Cookie",
-            "brw=brwoFcsjVo3nFDHPT; path=/; expires=Sun, 18 Feb 2024 17:25:38 GMT; domain=.airtable.com; samesite=none; secure",
-            "Strict-Transport-Security",
-            "max-age=31536000; includeSubDomains; preload",
-            "access-control-allow-origin",
-            "*",
-            "access-control-allow-methods",
-            "DELETE,GET,OPTIONS,PATCH,POST,PUT",
-            "access-control-allow-headers",
-            "authorization,content-length,content-type,user-agent,x-airtable-application-id,x-airtable-user-agent,x-api-version,x-requested-with",
-            "X-Frame-Options",
-            "DENY",
-            "X-Content-Type-Options",
-            "nosniff",
-            "Vary",
-            "Accept-Encoding",
-            "airtable-uncompressed-content-length",
-            "105"
-        ],
-        "responseIsBinary": false
-    },
-    {
-        "scope": "https://api.airtable.com:443",
-        "method": "DELETE",
-        "path": "/v0/appBlf3KsalIQeMUo/tblvXn2TOeVPC9c6m/recyubpGhZWle9GOS",
-        "body": "",
-        "status": 200,
-        "response": {
-            "deleted": true,
-            "id": "recyubpGhZWle9GOS"
-        },
-        "rawHeaders": [
-            "Date",
-            "Sat, 18 Feb 2023 17:25:39 GMT",
-            "Content-Type",
-            "59",
-            "Connection",
-            "close",
-            "Set-Cookie",
-            "AWSALB=SjG+vAIOeCRwgx9Zhi7bVWiFG0acnh1G6+u2nL+ZUfo+4ON1RPjGdhX41SiaekKoYBmW2oCbSynCYAXKGnQjJYaOmPFAeIkml0VZuXSCv1Jm8P2PsXR+DoKIvZTk; Expires=Sat, 25 Feb 2023 17:25:39 GMT; Path=/",
-            "Set-Cookie",
-            "AWSALBCORS=SjG+vAIOeCRwgx9Zhi7bVWiFG0acnh1G6+u2nL+ZUfo+4ON1RPjGdhX41SiaekKoYBmW2oCbSynCYAXKGnQjJYaOmPFAeIkml0VZuXSCv1Jm8P2PsXR+DoKIvZTk; Expires=Sat, 25 Feb 2023 17:25:39 GMT; Path=/; SameSite=None; Secure",
-            "Server",
-            "Tengine",
-            "Set-Cookie",
-            "brw=brwUynCRjs24wfp6Z; path=/; expires=Sun, 18 Feb 2024 17:25:39 GMT; domain=.airtable.com; samesite=none; secure",
-            "Strict-Transport-Security",
-            "max-age=31536000; includeSubDomains; preload",
-            "access-control-allow-origin",
-            "*",
-            "access-control-allow-methods",
-            "DELETE,GET,OPTIONS,PATCH,POST,PUT",
-            "access-control-allow-headers",
-            "authorization,content-length,content-type,user-agent,x-airtable-application-id,x-airtable-user-agent,x-api-version,x-requested-with",
-            "X-Frame-Options",
-            "DENY",
-            "X-Content-Type-Options",
-            "nosniff",
-            "Vary",
-            "Accept-Encoding",
-            "airtable-uncompressed-content-length",
-            "41"
-        ],
-        "responseIsBinary": false
-    }
-]

apps/integrations/src/fixtures/airtable.deleteRecords.json

@@ -1,125 +0,0 @@
-[
-    {
-        "scope": "https://api.airtable.com:443",
-        "method": "POST",
-        "path": "/v0/appBlf3KsalIQeMUo/tblvXn2TOeVPC9c6m",
-        "body": {
-            "records": [
-                {
-                    "fields": {
-                        "Employee": "Delete now #1"
-                    }
-                },
-                {
-                    "fields": {
-                        "Employee": "Delete now #2"
-                    }
-                }
-            ]
-        },
-        "status": 200,
-        "response": {
-            "records": [
-                {
-                    "id": "recTR6YLOshwwyi1O",
-                    "createdTime": "2023-02-18T17:22:12.000Z",
-                    "fields": {
-                        "Employee": "Delete now #1"
-                    }
-                },
-                {
-                    "id": "recuQVL2gpUjN64py",
-                    "createdTime": "2023-02-18T17:22:12.000Z",
-                    "fields": {
-                        "Employee": "Delete now #2"
-                    }
-                }
-            ]
-        },
-        "rawHeaders": [
-            "Date",
-            "Sat, 18 Feb 2023 17:22:12 GMT",
-            "Content-Type",
-            "154",
-            "Connection",
-            "close",
-            "Set-Cookie",
-            "AWSALB=IAMzoMptPLC7k7rWXTocxJiu8ciJvbHqD17c0EPaM38k1FkzA/zW7S+tRKK6LOzrVFyLL8GUgFtdfDGFELrQ8uO1bADYnEiB4vfOAXjRwSBA2Dc61N3O+MIWMdnM; Expires=Sat, 25 Feb 2023 17:22:12 GMT; Path=/",
-            "Set-Cookie",
-            "AWSALBCORS=IAMzoMptPLC7k7rWXTocxJiu8ciJvbHqD17c0EPaM38k1FkzA/zW7S+tRKK6LOzrVFyLL8GUgFtdfDGFELrQ8uO1bADYnEiB4vfOAXjRwSBA2Dc61N3O+MIWMdnM; Expires=Sat, 25 Feb 2023 17:22:12 GMT; Path=/; SameSite=None; Secure",
-            "Server",
-            "Tengine",
-            "Set-Cookie",
-            "brw=brwFID6JiyKkz2OUb; path=/; expires=Sun, 18 Feb 2024 17:22:12 GMT; domain=.airtable.com; samesite=none; secure",
-            "Strict-Transport-Security",
-            "max-age=31536000; includeSubDomains; preload",
-            "access-control-allow-origin",
-            "*",
-            "access-control-allow-methods",
-            "DELETE,GET,OPTIONS,PATCH,POST,PUT",
-            "access-control-allow-headers",
-            "authorization,content-length,content-type,user-agent,x-airtable-application-id,x-airtable-user-agent,x-api-version,x-requested-with",
-            "X-Frame-Options",
-            "DENY",
-            "X-Content-Type-Options",
-            "nosniff",
-            "Vary",
-            "Accept-Encoding",
-            "airtable-uncompressed-content-length",
-            "225"
-        ],
-        "responseIsBinary": false
-    },
-    {
-        "scope": "https://api.airtable.com:443",
-        "method": "DELETE",
-        "path": "/v0/appBlf3KsalIQeMUo/tblvXn2TOeVPC9c6m?records=recTR6YLOshwwyi1O&records=recuQVL2gpUjN64py",
-        "body": "",
-        "status": 200,
-        "response": {
-            "records": [
-                {
-                    "deleted": true,
-                    "id": "recTR6YLOshwwyi1O"
-                },
-                {
-                    "deleted": true,
-                    "id": "recuQVL2gpUjN64py"
-                }
-            ]
-        },
-        "rawHeaders": [
-            "Date",
-            "Sat, 18 Feb 2023 17:22:13 GMT",
-            "Content-Type",
-            "91",
-            "Connection",
-            "close",
-            "Set-Cookie",
-            "AWSALB=psOMBihmNThSHe+ZEkpP1CKmbhnepN53OlaE2Eyi0zBUDOzM7dHGR7ptEm8ebKfpyqDolVl93quNNO44wwIfZqZHuSPVGyZsJWJoM2FsHY4G4HaFCJZoPEkqRFFs; Expires=Sat, 25 Feb 2023 17:22:12 GMT; Path=/",
-            "Set-Cookie",
-            "AWSALBCORS=psOMBihmNThSHe+ZEkpP1CKmbhnepN53OlaE2Eyi0zBUDOzM7dHGR7ptEm8ebKfpyqDolVl93quNNO44wwIfZqZHuSPVGyZsJWJoM2FsHY4G4HaFCJZoPEkqRFFs; Expires=Sat, 25 Feb 2023 17:22:12 GMT; Path=/; SameSite=None; Secure",
-            "Server",
-            "Tengine",
-            "Set-Cookie",
-            "brw=brwq5X9BQFhfFj5lr; path=/; expires=Sun, 18 Feb 2024 17:22:12 GMT; domain=.airtable.com; samesite=none; secure",
-            "Strict-Transport-Security",
-            "max-age=31536000; includeSubDomains; preload",
-            "access-control-allow-origin",
-            "*",
-            "access-control-allow-methods",
-            "DELETE,GET,OPTIONS,PATCH,POST,PUT",
-            "access-control-allow-headers",
-            "authorization,content-length,content-type,user-agent,x-airtable-application-id,x-airtable-user-agent,x-api-version,x-requested-with",
-            "X-Frame-Options",
-            "DENY",
-            "X-Content-Type-Options",
-            "nosniff",
-            "Vary",
-            "Accept-Encoding",
-            "airtable-uncompressed-content-length",
-            "97"
-        ],
-        "responseIsBinary": false
-    }
-]

apps/integrations/src/fixtures/airtable.getRecord.json

@@ -1,79 +0,0 @@
-[
-    {
-        "scope": "https://api.airtable.com:443",
-        "method": "GET",
-        "path": "/v0/appBlf3KsalIQeMUo/tblvXn2TOeVPC9c6m/recHcnB1MbBr9Rd2P",
-        "body": "",
-        "status": 200,
-        "response": {
-            "id": "recHcnB1MbBr9Rd2P",
-            "createdTime": "2023-01-03T12:05:53.000Z",
-            "fields": {
-                "Employee": "Faith Butterworth",
-                "Phone": "(123) 456-7890",
-                "Headshot": [
-                    {
-                        "id": "att3ibwyOXULYL15O",
-                        "width": 950,
-                        "height": 700,
-                        "url": "https://v5.airtableusercontent.com/v1/15/15/1676750400000/0Hy62Ommo3C1BR3r_TsIMw/xGdMUGBUycsvzqjCPHlIuKyvUCM_Y6InDa7Bz15pCaGtWXyue5BlHYak_kFJYmgVXbgvWAXkaigRk7xdcUHiZU66F33CrAUP36ihAFT3-eU/-_khPf6Rh8P9uLt3Oc55HupkyS000nORrpvZpY1bKwI",
-                        "filename": "headshot-purple-2 (1).png",
-                        "size": 191272,
-                        "type": "image/png",
-                        "thumbnails": {
-                            "small": {
-                                "url": "https://v5.airtableusercontent.com/v1/15/15/1676750400000/MlmaPKrIg1yOj_qipSwKhg/fVQ5W7QtoxoAszvbIHT2dksddzWQi2ETkCewMXRSY2NIiX6wD1LWuC6d4VICHwRCz_6sKW4vhwZ1vkScFYpcgQ/Iy8lz5HcTKpTrG8gBq4fQJRyPAdnfYrwn3u05_lovmc",
-                                "width": 49,
-                                "height": 36
-                            },
-                            "large": {
-                                "url": "https://v5.airtableusercontent.com/v1/15/15/1676750400000/BBIfL5Oqc8BAHkugmNUkXA/JygSzSF9lLJi1U1dP1xCpH1QTSJwxb2FRvJssEdxZubfzVIa9iofsOn5HKsIFLuPl2K3yYCvaxAD3ZsHa7WCig/Rpbg9vWTPa6-oxoPUO4gqkOBFHzadVBHEZhjJoIu6Y8",
-                                "width": 695,
-                                "height": 512
-                            },
-                            "full": {
-                                "url": "https://v5.airtableusercontent.com/v1/15/15/1676750400000/xlrKts_ACw09qLqsAW16EQ/qrDMlQpI1cVdPCe0uw6ZJw9FeZCcwenmFzZ317qbsO0q8ZY2DY5k-bpPFYBaS4KkqztczIOqdnCBIYiuJ3_wqA/4LU_0QW7hp8Rw828Z_ov3GNcZa86pywziLdQy364XXE",
-                                "width": 3000,
-                                "height": 3000
-                            }
-                        }
-                    }
-                ],
-                "Employee type": "Contractor"
-            }
-        },
-        "rawHeaders": [
-            "Date",
-            "Sat, 18 Feb 2023 16:02:10 GMT",
-            "Content-Type",
-            "872",
-            "Connection",
-            "close",
-            "Set-Cookie",
-            "AWSALB=PhNLtNqLT//gbRBjRTywLiyg0lY3ZGo9Q2LLwOqLnAwsXcrRIaaELYV7A+s2lJlrAsid5UKIKld15Jq1nLyroXxAcFPd3vcbq6ku7tK7LE8HnOQiaMOV9gOoxqoa; Expires=Sat, 25 Feb 2023 16:02:10 GMT; Path=/",
-            "Set-Cookie",
-            "AWSALBCORS=PhNLtNqLT//gbRBjRTywLiyg0lY3ZGo9Q2LLwOqLnAwsXcrRIaaELYV7A+s2lJlrAsid5UKIKld15Jq1nLyroXxAcFPd3vcbq6ku7tK7LE8HnOQiaMOV9gOoxqoa; Expires=Sat, 25 Feb 2023 16:02:10 GMT; Path=/; SameSite=None; Secure",
-            "Server",
-            "Tengine",
-            "Set-Cookie",
-            "brw=brwuEVkvPW1vATlmC; path=/; expires=Sun, 18 Feb 2024 16:02:10 GMT; domain=.airtable.com; samesite=none; secure",
-            "Strict-Transport-Security",
-            "max-age=31536000; includeSubDomains; preload",
-            "access-control-allow-origin",
-            "*",
-            "access-control-allow-methods",
-            "DELETE,GET,OPTIONS,PATCH,POST,PUT",
-            "access-control-allow-headers",
-            "authorization,content-length,content-type,user-agent,x-airtable-application-id,x-airtable-user-agent,x-api-version,x-requested-with",
-            "X-Frame-Options",
-            "DENY",
-            "X-Content-Type-Options",
-            "nosniff",
-            "Vary",
-            "Accept-Encoding",
-            "airtable-uncompressed-content-length",
-            "1320"
-        ],
-        "responseIsBinary": false
-    }
-]

apps/integrations/src/fixtures/airtable.listRecords.advanced.json

@@ -1,112 +0,0 @@
-[
-    {
-        "scope": "https://api.airtable.com:443",
-        "method": "POST",
-        "path": "/v0/appBlf3KsalIQeMUo/tblvXn2TOeVPC9c6m/listRecords",
-        "body": {
-            "timeZone": "America/Los_Angeles",
-            "userLocale": "en",
-            "sort": [
-                {
-                    "field": "Employee",
-                    "direction": "asc"
-                }
-            ],
-            "fields": [
-                "Employee"
-            ]
-        },
-        "status": 200,
-        "response": {
-            "records": [
-                {
-                    "id": "recWhRejYoDn5CNsB",
-                    "createdTime": "2023-01-23T07:46:46.000Z",
-                    "fields": {}
-                },
-                {
-                    "id": "recFeH8y7qLNR6CxB",
-                    "createdTime": "2023-01-22T23:15:09.000Z",
-                    "fields": {
-                        "Employee": "Employee 7"
-                    }
-                },
-                {
-                    "id": "recRo4MuSqRcb33pp",
-                    "createdTime": "2023-01-23T00:48:36.000Z",
-                    "fields": {
-                        "Employee": "Employee 9"
-                    }
-                },
-                {
-                    "id": "recHcnB1MbBr9Rd2P",
-                    "createdTime": "2023-01-03T12:05:53.000Z",
-                    "fields": {
-                        "Employee": "Faith Butterworth"
-                    }
-                },
-                {
-                    "id": "recbKWDa9URtGWIGG",
-                    "createdTime": "2023-01-03T12:05:53.000Z",
-                    "fields": {
-                        "Employee": "Harley Holbrook"
-                    }
-                },
-                {
-                    "id": "rec3cPi3z4s6oe9SD",
-                    "createdTime": "2023-01-22T23:51:21.000Z",
-                    "fields": {
-                        "Employee": "Jimmy dean"
-                    }
-                },
-                {
-                    "id": "recGPicQa5yIo9dBY",
-                    "createdTime": "2023-01-22T19:22:05.000Z",
-                    "fields": {
-                        "Employee": "Matt Aitken"
-                    }
-                },
-                {
-                    "id": "recElL0yiCgIEVcyc",
-                    "createdTime": "2023-01-03T12:05:53.000Z",
-                    "fields": {
-                        "Employee": "Quinn Nguyen"
-                    }
-                }
-            ]
-        },
-        "rawHeaders": [
-            "Date",
-            "Sat, 18 Feb 2023 16:24:53 GMT",
-            "Content-Type",
-            "338",
-            "Connection",
-            "close",
-            "Set-Cookie",
-            "AWSALB=4+PtBWlCPjGrIo2V0YEi8J0ogkebmIOEMfx8TOaOhZvHsaXUZ1TQV+5DlPbCxYxrXoXbbP/F0iRXc3qLGC8LVtm5VIkxt0NDhBENoLsdbBAWF1bbmlOs2DM3N+k3; Expires=Sat, 25 Feb 2023 16:24:53 GMT; Path=/",
-            "Set-Cookie",
-            "AWSALBCORS=4+PtBWlCPjGrIo2V0YEi8J0ogkebmIOEMfx8TOaOhZvHsaXUZ1TQV+5DlPbCxYxrXoXbbP/F0iRXc3qLGC8LVtm5VIkxt0NDhBENoLsdbBAWF1bbmlOs2DM3N+k3; Expires=Sat, 25 Feb 2023 16:24:53 GMT; Path=/; SameSite=None; Secure",
-            "Server",
-            "Tengine",
-            "Set-Cookie",
-            "brw=brw4B3gkaAL97bpKd; path=/; expires=Sun, 18 Feb 2024 16:24:53 GMT; domain=.airtable.com; samesite=none; secure",
-            "Strict-Transport-Security",
-            "max-age=31536000; includeSubDomains; preload",
-            "access-control-allow-origin",
-            "*",
-            "access-control-allow-methods",
-            "DELETE,GET,OPTIONS,PATCH,POST,PUT",
-            "access-control-allow-headers",
-            "authorization,content-length,content-type,user-agent,x-airtable-application-id,x-airtable-user-agent,x-api-version,x-requested-with",
-            "X-Frame-Options",
-            "DENY",
-            "X-Content-Type-Options",
-            "nosniff",
-            "Vary",
-            "Accept-Encoding",
-            "airtable-uncompressed-content-length",
-            "829"
-        ],
-        "responseIsBinary": false
-    }
-]

apps/integrations/src/fixtures/airtable.listRecords.simple.json

@@ -1,218 +0,0 @@
-[
-    {
-        "scope": "https://api.airtable.com:443",
-        "method": "POST",
-        "path": "/v0/appBlf3KsalIQeMUo/tblvXn2TOeVPC9c6m/listRecords",
-        "body": {},
-        "status": 200,
-        "response": {
-            "records": [
-                {
-                    "id": "rec3cPi3z4s6oe9SD",
-                    "createdTime": "2023-01-22T23:51:21.000Z",
-                    "fields": {
-                        "Employee": "Jimmy dean",
-                        "Phone": "7778",
-                        "Employee type": "Employee",
-                        "Manager": {
-                            "id": "usrpWV6yqSVvzVO0j",
-                            "email": "matt@trigger.dev",
-                            "name": "Matt Aitken"
-                        }
-                    }
-                },
-                {
-                    "id": "recElL0yiCgIEVcyc",
-                    "createdTime": "2023-01-03T12:05:53.000Z",
-                    "fields": {
-                        "Employee": "Quinn Nguyen",
-                        "Phone": "(123) 456-7890",
-                        "Headshot": [
-                            {
-                                "id": "attx14Pa1lP0DMgRw",
-                                "width": 950,
-                                "height": 700,
-                                "url": "https://v5.airtableusercontent.com/v1/15/15/1676743200000/5gbGs-cRWoOC46FxBWQZKw/ph_QI1srGvvZArxOz207bnKOs-xlIXF8ZqMlk5ssMr-jbiMuFfXOjmjadjOACGFRyQ9nE59Dpy7540UU_6bpgsQ_tMKtCFaaf2a4ieIPEEU/ptI5mq4oczxmmrz-RRWb3MSegywNfAwWf--9mL5IT34",
-                                "filename": "headshot-pink-1.png",
-                                "size": 215411,
-                                "type": "image/png",
-                                "thumbnails": {
-                                    "small": {
-                                        "url": "https://v5.airtableusercontent.com/v1/15/15/1676743200000/3bEGb1n_oJxadHpHMcDg_w/1Mga_f3JNzLtWq_an_E7I98CxejzOpiALmDJHRdI0XcBbVwIv-vzj96mY-XeAL0W32Q_WCQPu4TqWzisnlqLYg/7pJLZzaspSp1339lIgp1o1Nb1durOAoIx-IflDRI8gY",
-                                        "width": 49,
-                                        "height": 36
-                                    },
-                                    "large": {
-                                        "url": "https://v5.airtableusercontent.com/v1/15/15/1676743200000/7Xr67It2dJ296uYyumST1g/HH8QTjlaP0frLwscoJy3vJLvOdKwz1zHL_ll8zMtfFkm1uFB9-nRkA09YeSojhemScYjpvIB7OoxJTh3lqU-jQ/8jtF2js5F47hndbxts2_ZIFZaxkuq3G0BxbomG1wRDA",
-                                        "width": 695,
-                                        "height": 512
-                                    },
-                                    "full": {
-                                        "url": "https://v5.airtableusercontent.com/v1/15/15/1676743200000/O1xGv0NoeaGTVYYDxpZnuQ/IBXER_7M4O9QqAmv_9pF2evdf5_9YzeVmdzk3Rsi2gFaK6ueREni-Kaw6Xg8VORqFpHNtUQ7JrV_5Ya4zhSuXg/VAGl2IqW98-D0E1RgBretLYJCmNCDqledVmdTrUOEIU",
-                                        "width": 3000,
-                                        "height": 3000
-                                    }
-                                }
-                            }
-                        ],
-                        "Employee type": "Employee"
-                    }
-                },
-                {
-                    "id": "recFeH8y7qLNR6CxB",
-                    "createdTime": "2023-01-22T23:15:09.000Z",
-                    "fields": {
-                        "Employee": "Employee 7",
-                        "Phone": "342567",
-                        "Employee type": "Contractor",
-                        "Manager": {
-                            "id": "usrpWV6yqSVvzVO0j",
-                            "email": "matt@trigger.dev",
-                            "name": "Matt Aitken"
-                        }
-                    }
-                },
-                {
-                    "id": "recGPicQa5yIo9dBY",
-                    "createdTime": "2023-01-22T19:22:05.000Z",
-                    "fields": {
-                        "Employee": "Matt Aitken",
-                        "Phone": "12345678",
-                        "Employee type": "Employee",
-                        "Manager": {
-                            "id": "usrpWV6yqSVvzVO0j",
-                            "email": "matt@trigger.dev",
-                            "name": "Matt Aitken"
-                        }
-                    }
-                },
-                {
-                    "id": "recHcnB1MbBr9Rd2P",
-                    "createdTime": "2023-01-03T12:05:53.000Z",
-                    "fields": {
-                        "Employee": "Faith Butterworth",
-                        "Phone": "(123) 456-7890",
-                        "Headshot": [
-                            {
-                                "id": "att3ibwyOXULYL15O",
-                                "width": 950,
-                                "height": 700,
-                                "url": "https://v5.airtableusercontent.com/v1/15/15/1676743200000/xV5UysTMWXnI9p8E8KMTlA/Ov21BA--8-n8JC_sH7-sx_Iub_aXA1PGiVAohUAhE5SuEtqSMGhN39pRHI3tmu3LqEh8iDz8pTZ_TdWHVV8riCTBPEm8NvvD3o6BtJTRXcE/LJjYfS0Wh_KMcmkgL-82HOLXyhhDHnMsFvrqL1OCtXQ",
-                                "filename": "headshot-purple-2 (1).png",
-                                "size": 191272,
-                                "type": "image/png",
-                                "thumbnails": {
-                                    "small": {
-                                        "url": "https://v5.airtableusercontent.com/v1/15/15/1676743200000/L9WFjSk92HlOH9RDdrP7MA/7AgbUc3M9KuDz5plvUFL5dsRwt55PiqcnPvoDIawWfk0w_N4GDZPTPDiiqxFOsUMNOk4CB1RuBZFFLNEfu0bRA/RYcp3x_oGgLtvOi7CtUplGM_rmU-EdbBQ5zdcr7L-Yo",
-                                        "width": 49,
-                                        "height": 36
-                                    },
-                                    "large": {
-                                        "url": "https://v5.airtableusercontent.com/v1/15/15/1676743200000/Zl-Thn_JCnnb_-j9CpJ0lg/9hIAzhles7CH7n0EgRzrg-_qVCz1G6oHXX8M7A70KVUBy3Ttnc1NwoSKLMj7JxmYkqc8hYCRU4qRA_S22sS1cw/BhQLDmDmMAUd4sUaxVfTbHnxPGJD9q0_NPB3l7rYz4o",
-                                        "width": 695,
-                                        "height": 512
-                                    },
-                                    "full": {
-                                        "url": "https://v5.airtableusercontent.com/v1/15/15/1676743200000/4E18KjffN_36eSJ65hCEFg/1_ts6X0NwupOAEyHnehE_hy5ROdSOt1jODcXv5Cny3Wn4O5r3Ewl3vgsg3Lebkwv40iJo7tbtblZEdtZMecpJA/GBgtTGmld0ZH7_4FygTqipHkEpQVn4dt3CmGBnOo6Wc",
-                                        "width": 3000,
-                                        "height": 3000
-                                    }
-                                }
-                            }
-                        ],
-                        "Employee type": "Contractor"
-                    }
-                },
-                {
-                    "id": "recRo4MuSqRcb33pp",
-                    "createdTime": "2023-01-23T00:48:36.000Z",
-                    "fields": {
-                        "Employee": "Employee 9",
-                        "Phone": "12345678",
-                        "Employee type": "Employee",
-                        "Manager": {
-                            "id": "usrpWV6yqSVvzVO0j",
-                            "email": "matt@trigger.dev",
-                            "name": "Matt Aitken"
-                        }
-                    }
-                },
-                {
-                    "id": "recWhRejYoDn5CNsB",
-                    "createdTime": "2023-01-23T07:46:46.000Z",
-                    "fields": {}
-                },
-                {
-                    "id": "recbKWDa9URtGWIGG",
-                    "createdTime": "2023-01-03T12:05:53.000Z",
-                    "fields": {
-                        "Employee": "Harley Holbrook",
-                        "Phone": "(123) 456-7890",
-                        "Headshot": [
-                            {
-                                "id": "attIMHgGEnN0YutyM",
-                                "width": 950,
-                                "height": 700,
-                                "url": "https://v5.airtableusercontent.com/v1/15/15/1676743200000/Fz00EH3JBLCN7V_swur5cg/p3tx8jWcy5175n6bvK9aCabwdIfMur6wDrly_X6A8cL6YnO5JBKK0YJW1EjrEzjCtkj0uJ0PAS4lbwD2hMsKlKUZjopUmDegHLnms_ucOxE/6HP7Qw3GHTGiAmHUM21jHC5fhLcyfTrlD9qrs35a9-I",
-                                "filename": "headshot-yellow-2.png",
-                                "size": 349926,
-                                "type": "image/png",
-                                "thumbnails": {
-                                    "small": {
-                                        "url": "https://v5.airtableusercontent.com/v1/15/15/1676743200000/Cyg5kaW38cKzs03TbM-X3g/8omtIQVimV1MrD9PPtj2SaAlOA3CxuCdqHWoVPxi6UELMV2w7EhFv9Ko3WexIF5bcQyd9-N4RLFGvd5__VgP6A/suCIwJkTLliZrHLwioXIUqnrkJ7gIOxtNrdQtkDrBjk",
-                                        "width": 49,
-                                        "height": 36
-                                    },
-                                    "large": {
-                                        "url": "https://v5.airtableusercontent.com/v1/15/15/1676743200000/g3EV5PxrbBETRQ9Qzn5WYg/rloz8wROtoNA6Ab9HEykJEmHtnmqUzxnnksoNJU7Y1NjeoV6dQQQZxLTjQBYJukBQfil4EXI8b_ejtARnkANhw/RwNwembhBCNpNJPThTWE_Fae3KtNvBQf-nDboeTP06c",
-                                        "width": 695,
-                                        "height": 512
-                                    },
-                                    "full": {
-                                        "url": "https://v5.airtableusercontent.com/v1/15/15/1676743200000/hFdCcDELa9Y1qNU8ynA-gA/rY9pKGsa3U-i95eAYUT9qPkXhakhXNpWaWBOKsKSSvmc0MFERzMvBTQ9X6hfBBOWdJNPm2ewSI5qaMk1OqdDYg/IVswNEnsz2QWGQtpfHLGHHaAZEWVam08gd7vSXPVMOI",
-                                        "width": 3000,
-                                        "height": 3000
-                                    }
-                                }
-                            }
-                        ],
-                        "Employee type": "On leave"
-                    }
-                }
-            ]
-        },
-        "rawHeaders": [
-            "Date",
-            "Sat, 18 Feb 2023 15:58:57 GMT",
-            "Content-Type",
-            "2247",
-            "Connection",
-            "close",
-            "Set-Cookie",
-            "AWSALB=eKX9sqNvujzmAJZfcbDUrm7NlI8Xe9niXH7mrVhWbrGQZxHi9a8M9cKLI067MCp0mv5UfHVCEeUvkQbnHW8lB/LQwpch1qdox/a0c+J5kcVIGXWLH8zOB6pv2t42; Expires=Sat, 25 Feb 2023 15:58:57 GMT; Path=/",
-            "Set-Cookie",
-            "AWSALBCORS=eKX9sqNvujzmAJZfcbDUrm7NlI8Xe9niXH7mrVhWbrGQZxHi9a8M9cKLI067MCp0mv5UfHVCEeUvkQbnHW8lB/LQwpch1qdox/a0c+J5kcVIGXWLH8zOB6pv2t42; Expires=Sat, 25 Feb 2023 15:58:57 GMT; Path=/; SameSite=None; Secure",
-            "Server",
-            "Tengine",
-            "Set-Cookie",
-            "brw=brwJiIPgBOUtNPjri; path=/; expires=Sun, 18 Feb 2024 15:58:57 GMT; domain=.airtable.com; samesite=none; secure",
-            "Strict-Transport-Security",
-            "max-age=31536000; includeSubDomains; preload",
-            "access-control-allow-origin",
-            "*",
-            "access-control-allow-methods",
-            "DELETE,GET,OPTIONS,PATCH,POST,PUT",
-            "access-control-allow-headers",
-            "authorization,content-length,content-type,user-agent,x-airtable-application-id,x-airtable-user-agent,x-api-version,x-requested-with",
-            "X-Frame-Options",
-            "DENY",
-            "X-Content-Type-Options",
-            "nosniff",
-            "Vary",
-            "Accept-Encoding",
-            "airtable-uncompressed-content-length",
-            "4968"
-        ],
-        "responseIsBinary": false
-    }
-]

apps/integrations/src/fixtures/airtable.updateRecord.json

@@ -1,83 +0,0 @@
-[
-    {
-        "scope": "https://api.airtable.com:443",
-        "method": "PATCH",
-        "path": "/v0/appBlf3KsalIQeMUo/tblvXn2TOeVPC9c6m/recHcnB1MbBr9Rd2P",
-        "body": {
-            "fields": {
-                "Employee": "John Doe II"
-            }
-        },
-        "status": 200,
-        "response": {
-            "id": "recHcnB1MbBr9Rd2P",
-            "createdTime": "2023-01-03T12:05:53.000Z",
-            "fields": {
-                "Employee": "John Doe II",
-                "Phone": "(123) 456-7890",
-                "Headshot": [
-                    {
-                        "id": "att3ibwyOXULYL15O",
-                        "width": 950,
-                        "height": 700,
-                        "url": "https://v5.airtableusercontent.com/v1/15/15/1676750400000/0Hy62Ommo3C1BR3r_TsIMw/xGdMUGBUycsvzqjCPHlIuKyvUCM_Y6InDa7Bz15pCaGtWXyue5BlHYak_kFJYmgVXbgvWAXkaigRk7xdcUHiZU66F33CrAUP36ihAFT3-eU/-_khPf6Rh8P9uLt3Oc55HupkyS000nORrpvZpY1bKwI",
-                        "filename": "headshot-purple-2 (1).png",
-                        "size": 191272,
-                        "type": "image/png",
-                        "thumbnails": {
-                            "small": {
-                                "url": "https://v5.airtableusercontent.com/v1/15/15/1676750400000/MlmaPKrIg1yOj_qipSwKhg/fVQ5W7QtoxoAszvbIHT2dksddzWQi2ETkCewMXRSY2NIiX6wD1LWuC6d4VICHwRCz_6sKW4vhwZ1vkScFYpcgQ/Iy8lz5HcTKpTrG8gBq4fQJRyPAdnfYrwn3u05_lovmc",
-                                "width": 49,
-                                "height": 36
-                            },
-                            "large": {
-                                "url": "https://v5.airtableusercontent.com/v1/15/15/1676750400000/BBIfL5Oqc8BAHkugmNUkXA/JygSzSF9lLJi1U1dP1xCpH1QTSJwxb2FRvJssEdxZubfzVIa9iofsOn5HKsIFLuPl2K3yYCvaxAD3ZsHa7WCig/Rpbg9vWTPa6-oxoPUO4gqkOBFHzadVBHEZhjJoIu6Y8",
-                                "width": 695,
-                                "height": 512
-                            },
-                            "full": {
-                                "url": "https://v5.airtableusercontent.com/v1/15/15/1676750400000/xlrKts_ACw09qLqsAW16EQ/qrDMlQpI1cVdPCe0uw6ZJw9FeZCcwenmFzZ317qbsO0q8ZY2DY5k-bpPFYBaS4KkqztczIOqdnCBIYiuJ3_wqA/4LU_0QW7hp8Rw828Z_ov3GNcZa86pywziLdQy364XXE",
-                                "width": 3000,
-                                "height": 3000
-                            }
-                        }
-                    }
-                ],
-                "Employee type": "Contractor"
-            }
-        },
-        "rawHeaders": [
-            "Date",
-            "Sat, 18 Feb 2023 16:56:09 GMT",
-            "Content-Type",
-            "868",
-            "Connection",
-            "close",
-            "Set-Cookie",
-            "AWSALB=2CpHsb1CL3MMw3hBwb9rVw+mR1QJ7rNbVnCS1fkDNEEi3FM0b4jSEGQ0FhjkIkdkQfLhOMrCXK95XbgEImuhWJuv4FKNdOIk6hNaJawWjFq6kh/mOMlFi7HU8r8h; Expires=Sat, 25 Feb 2023 16:56:09 GMT; Path=/",
-            "Set-Cookie",
-            "AWSALBCORS=2CpHsb1CL3MMw3hBwb9rVw+mR1QJ7rNbVnCS1fkDNEEi3FM0b4jSEGQ0FhjkIkdkQfLhOMrCXK95XbgEImuhWJuv4FKNdOIk6hNaJawWjFq6kh/mOMlFi7HU8r8h; Expires=Sat, 25 Feb 2023 16:56:09 GMT; Path=/; SameSite=None; Secure",
-            "Server",
-            "Tengine",
-            "Set-Cookie",
-            "brw=brwP6XoEdwHyGdxxZ; path=/; expires=Sun, 18 Feb 2024 16:56:09 GMT; domain=.airtable.com; samesite=none; secure",
-            "Strict-Transport-Security",
-            "max-age=31536000; includeSubDomains; preload",
-            "access-control-allow-origin",
-            "*",
-            "access-control-allow-methods",
-            "DELETE,GET,OPTIONS,PATCH,POST,PUT",
-            "access-control-allow-headers",
-            "authorization,content-length,content-type,user-agent,x-airtable-application-id,x-airtable-user-agent,x-api-version,x-requested-with",
-            "X-Frame-Options",
-            "DENY",
-            "X-Content-Type-Options",
-            "nosniff",
-            "Vary",
-            "Accept-Encoding",
-            "airtable-uncompressed-content-length",
-            "1314"
-        ],
-        "responseIsBinary": false
-    }
-]

apps/integrations/src/fixtures/airtable.updateRecords.json

@@ -1,92 +0,0 @@
-[
-    {
-        "scope": "https://api.airtable.com:443",
-        "method": "PATCH",
-        "path": "/v0/appBlf3KsalIQeMUo/tblvXn2TOeVPC9c6m",
-        "body": {
-            "records": [
-                {
-                    "id": "recHcnB1MbBr9Rd2P",
-                    "fields": {
-                        "Employee": "John Doe"
-                    }
-                }
-            ]
-        },
-        "status": 200,
-        "response": {
-            "records": [
-                {
-                    "id": "recHcnB1MbBr9Rd2P",
-                    "createdTime": "2023-01-03T12:05:53.000Z",
-                    "fields": {
-                        "Employee": "John Doe",
-                        "Phone": "(123) 456-7890",
-                        "Headshot": [
-                            {
-                                "id": "att3ibwyOXULYL15O",
-                                "width": 950,
-                                "height": 700,
-                                "url": "https://v5.airtableusercontent.com/v1/15/15/1676750400000/0Hy62Ommo3C1BR3r_TsIMw/xGdMUGBUycsvzqjCPHlIuKyvUCM_Y6InDa7Bz15pCaGtWXyue5BlHYak_kFJYmgVXbgvWAXkaigRk7xdcUHiZU66F33CrAUP36ihAFT3-eU/-_khPf6Rh8P9uLt3Oc55HupkyS000nORrpvZpY1bKwI",
-                                "filename": "headshot-purple-2 (1).png",
-                                "size": 191272,
-                                "type": "image/png",
-                                "thumbnails": {
-                                    "small": {
-                                        "url": "https://v5.airtableusercontent.com/v1/15/15/1676750400000/MlmaPKrIg1yOj_qipSwKhg/fVQ5W7QtoxoAszvbIHT2dksddzWQi2ETkCewMXRSY2NIiX6wD1LWuC6d4VICHwRCz_6sKW4vhwZ1vkScFYpcgQ/Iy8lz5HcTKpTrG8gBq4fQJRyPAdnfYrwn3u05_lovmc",
-                                        "width": 49,
-                                        "height": 36
-                                    },
-                                    "large": {
-                                        "url": "https://v5.airtableusercontent.com/v1/15/15/1676750400000/BBIfL5Oqc8BAHkugmNUkXA/JygSzSF9lLJi1U1dP1xCpH1QTSJwxb2FRvJssEdxZubfzVIa9iofsOn5HKsIFLuPl2K3yYCvaxAD3ZsHa7WCig/Rpbg9vWTPa6-oxoPUO4gqkOBFHzadVBHEZhjJoIu6Y8",
-                                        "width": 695,
-                                        "height": 512
-                                    },
-                                    "full": {
-                                        "url": "https://v5.airtableusercontent.com/v1/15/15/1676750400000/xlrKts_ACw09qLqsAW16EQ/qrDMlQpI1cVdPCe0uw6ZJw9FeZCcwenmFzZ317qbsO0q8ZY2DY5k-bpPFYBaS4KkqztczIOqdnCBIYiuJ3_wqA/4LU_0QW7hp8Rw828Z_ov3GNcZa86pywziLdQy364XXE",
-                                        "width": 3000,
-                                        "height": 3000
-                                    }
-                                }
-                            }
-                        ],
-                        "Employee type": "Contractor"
-                    }
-                }
-            ]
-        },
-        "rawHeaders": [
-            "Date",
-            "Sat, 18 Feb 2023 16:46:03 GMT",
-            "Content-Type",
-            "870",
-            "Connection",
-            "close",
-            "Set-Cookie",
-            "AWSALB=aRijGYsG1c7HW7/3PfA+iqX9yfDtsVgoPBVm4dkHcigHjt0gpNbzI/GN4nVRaRPorF1fOAE0jRrIREfxlnx9YcqQP097XI6IpF109sT5W5dRnY6rzb2gyGS93Vhn; Expires=Sat, 25 Feb 2023 16:46:03 GMT; Path=/",
-            "Set-Cookie",
-            "AWSALBCORS=aRijGYsG1c7HW7/3PfA+iqX9yfDtsVgoPBVm4dkHcigHjt0gpNbzI/GN4nVRaRPorF1fOAE0jRrIREfxlnx9YcqQP097XI6IpF109sT5W5dRnY6rzb2gyGS93Vhn; Expires=Sat, 25 Feb 2023 16:46:03 GMT; Path=/; SameSite=None; Secure",
-            "Server",
-            "Tengine",
-            "Set-Cookie",
-            "brw=brwkAO755Iu5BkpXR; path=/; expires=Sun, 18 Feb 2024 16:46:03 GMT; domain=.airtable.com; samesite=none; secure",
-            "Strict-Transport-Security",
-            "max-age=31536000; includeSubDomains; preload",
-            "access-control-allow-origin",
-            "*",
-            "access-control-allow-methods",
-            "DELETE,GET,OPTIONS,PATCH,POST,PUT",
-            "access-control-allow-headers",
-            "authorization,content-length,content-type,user-agent,x-airtable-application-id,x-airtable-user-agent,x-api-version,x-requested-with",
-            "X-Frame-Options",
-            "DENY",
-            "X-Content-Type-Options",
-            "nosniff",
-            "Vary",
-            "Accept-Encoding",
-            "airtable-uncompressed-content-length",
-            "1325"
-        ],
-        "responseIsBinary": false
-    }
-]

apps/integrations/src/fixtures/airtable.upsertRecords.json

@@ -1,114 +0,0 @@
-[
-    {
-        "scope": "https://api.airtable.com:443",
-        "method": "PATCH",
-        "path": "/v0/appBlf3KsalIQeMUo/tblvXn2TOeVPC9c6m",
-        "body": {
-            "performUpsert": {
-                "fieldsToMergeOn": [
-                    "Employee"
-                ]
-            },
-            "records": [
-                {
-                    "fields": {
-                        "Employee": "John Doe"
-                    }
-                },
-                {
-                    "fields": {
-                        "Employee": "Jane Doe"
-                    }
-                }
-            ]
-        },
-        "status": 200,
-        "response": {
-            "records": [
-                {
-                    "id": "recHcnB1MbBr9Rd2P",
-                    "createdTime": "2023-01-03T12:05:53.000Z",
-                    "fields": {
-                        "Employee": "John Doe",
-                        "Phone": "(123) 456-7890",
-                        "Headshot": [
-                            {
-                                "id": "att3ibwyOXULYL15O",
-                                "width": 950,
-                                "height": 700,
-                                "url": "https://v5.airtableusercontent.com/v1/15/15/1676750400000/0Hy62Ommo3C1BR3r_TsIMw/xGdMUGBUycsvzqjCPHlIuKyvUCM_Y6InDa7Bz15pCaGtWXyue5BlHYak_kFJYmgVXbgvWAXkaigRk7xdcUHiZU66F33CrAUP36ihAFT3-eU/-_khPf6Rh8P9uLt3Oc55HupkyS000nORrpvZpY1bKwI",
-                                "filename": "headshot-purple-2 (1).png",
-                                "size": 191272,
-                                "type": "image/png",
-                                "thumbnails": {
-                                    "small": {
-                                        "url": "https://v5.airtableusercontent.com/v1/15/15/1676750400000/MlmaPKrIg1yOj_qipSwKhg/fVQ5W7QtoxoAszvbIHT2dksddzWQi2ETkCewMXRSY2NIiX6wD1LWuC6d4VICHwRCz_6sKW4vhwZ1vkScFYpcgQ/Iy8lz5HcTKpTrG8gBq4fQJRyPAdnfYrwn3u05_lovmc",
-                                        "width": 49,
-                                        "height": 36
-                                    },
-                                    "large": {
-                                        "url": "https://v5.airtableusercontent.com/v1/15/15/1676750400000/BBIfL5Oqc8BAHkugmNUkXA/JygSzSF9lLJi1U1dP1xCpH1QTSJwxb2FRvJssEdxZubfzVIa9iofsOn5HKsIFLuPl2K3yYCvaxAD3ZsHa7WCig/Rpbg9vWTPa6-oxoPUO4gqkOBFHzadVBHEZhjJoIu6Y8",
-                                        "width": 695,
-                                        "height": 512
-                                    },
-                                    "full": {
-                                        "url": "https://v5.airtableusercontent.com/v1/15/15/1676750400000/xlrKts_ACw09qLqsAW16EQ/qrDMlQpI1cVdPCe0uw6ZJw9FeZCcwenmFzZ317qbsO0q8ZY2DY5k-bpPFYBaS4KkqztczIOqdnCBIYiuJ3_wqA/4LU_0QW7hp8Rw828Z_ov3GNcZa86pywziLdQy364XXE",
-                                        "width": 3000,
-                                        "height": 3000
-                                    }
-                                }
-                            }
-                        ],
-                        "Employee type": "Contractor"
-                    }
-                },
-                {
-                    "id": "recpyQHEcTiiwzAAe",
-                    "createdTime": "2023-02-18T16:49:12.000Z",
-                    "fields": {
-                        "Employee": "Jane Doe"
-                    }
-                }
-            ],
-            "updatedRecords": [
-                "recHcnB1MbBr9Rd2P"
-            ],
-            "createdRecords": [
-                "recpyQHEcTiiwzAAe"
-            ]
-        },
-        "rawHeaders": [
-            "Date",
-            "Sat, 18 Feb 2023 16:49:12 GMT",
-            "Content-Type",
-            "931",
-            "Connection",
-            "close",
-            "Set-Cookie",
-            "AWSALB=/B2FI/4JzHLz69XGh0fnXEzIHT58xav2z9CRaJPk/mxxK+IPKjzX/Kd13DU/uJsnD5QcWRgFZjepxA7s8HoojMSUw3+Vkav3Db4mPcly8wQXp88r5BEUjDvFso9o; Expires=Sat, 25 Feb 2023 16:49:12 GMT; Path=/",
-            "Set-Cookie",
-            "AWSALBCORS=/B2FI/4JzHLz69XGh0fnXEzIHT58xav2z9CRaJPk/mxxK+IPKjzX/Kd13DU/uJsnD5QcWRgFZjepxA7s8HoojMSUw3+Vkav3Db4mPcly8wQXp88r5BEUjDvFso9o; Expires=Sat, 25 Feb 2023 16:49:12 GMT; Path=/; SameSite=None; Secure",
-            "Server",
-            "Tengine",
-            "Set-Cookie",
-            "brw=brwsqrG8CnBxgniFg; path=/; expires=Sun, 18 Feb 2024 16:49:12 GMT; domain=.airtable.com; samesite=none; secure",
-            "Strict-Transport-Security",
-            "max-age=31536000; includeSubDomains; preload",
-            "access-control-allow-origin",
-            "*",
-            "access-control-allow-methods",
-            "DELETE,GET,OPTIONS,PATCH,POST,PUT",
-            "access-control-allow-headers",
-            "authorization,content-length,content-type,user-agent,x-airtable-application-id,x-airtable-user-agent,x-api-version,x-requested-with",
-            "X-Frame-Options",
-            "DENY",
-            "X-Content-Type-Options",
-            "nosniff",
-            "Vary",
-            "Accept-Encoding",
-            "airtable-uncompressed-content-length",
-            "1504"
-        ],
-        "responseIsBinary": false
-    }
-]

apps/integrations/src/fixtures/chat.postMessage.badchannel.json

@@ -1,78 +0,0 @@
-[
-    {
-        "scope": "https://slack.com:443",
-        "method": "POST",
-        "path": "/api/chat.postMessage",
-        "body": {
-            "channel": "C00AAAAAAAA",
-            "text": "This channel doesn't exist, so message won't send"
-        },
-        "status": 200,
-        "response": [
-            "13270000045439f20ace64f1259fdc9ec3444e00b2e6817cef2beb4e3f1ab2011262c998a76bb93c"
-        ],
-        "rawHeaders": [
-            "date",
-            "Sat, 18 Feb 2023 16:06:42 GMT",
-            "server",
-            "Apache",
-            "x-powered-by",
-            "HHVM/4.153.1",
-            "access-control-allow-origin",
-            "*",
-            "referrer-policy",
-            "no-referrer",
-            "x-slack-backend",
-            "r",
-            "x-slack-unique-id",
-            "Y_D3kqn7oMaK4u0tyzhR0AAAEDY",
-            "strict-transport-security",
-            "max-age=31536000; includeSubDomains; preload",
-            "access-control-allow-headers",
-            "slack-route, x-slack-version-ts, x-b3-traceid, x-b3-spanid, x-b3-parentspanid, x-b3-sampled, x-b3-flags",
-            "access-control-expose-headers",
-            "x-slack-req-id, retry-after",
-            "x-oauth-scopes",
-            "channels:read,channels:join,channels:manage,chat:write,groups:write,im:write,mpim:write,chat:write.customize,reactions:write",
-            "x-accepted-oauth-scopes",
-            "chat:write",
-            "expires",
-            "Mon, 26 Jul 1997 05:00:00 GMT",
-            "cache-control",
-            "private, no-cache, no-store, must-revalidate",
-            "pragma",
-            "no-cache",
-            "x-xss-protection",
-            "0",
-            "x-content-type-options",
-            "nosniff",
-            "x-slack-req-id",
-            "ebbefac5397dbab5385db0aae08cf6b3",
-            "vary",
-            "Accept-Encoding",
-            "content-encoding",
-            "br",
-            "content-length",
-            "40",
-            "content-type",
-            "application/json; charset=utf-8",
-            "x-envoy-upstream-service-time",
-            "93",
-            "x-backend",
-            "main_normal main_canary_with_overflow main_control_with_overflow",
-            "x-server",
-            "slack-www-hhvm-main-iad-dihx",
-            "x-slack-shared-secret-outcome",
-            "no-match",
-            "via",
-            "envoy-www-iad-uqca, envoy-edge-lhr-ozbu",
-            "x-edge-backend",
-            "envoy-www",
-            "x-slack-edge-shared-secret-outcome",
-            "no-match",
-            "connection",
-            "close"
-        ],
-        "responseIsBinary": false
-    }
-]

apps/integrations/src/fixtures/chat.postMessage.json

@@ -1,78 +0,0 @@
-[
-    {
-        "scope": "https://slack.com:443",
-        "method": "POST",
-        "path": "/api/chat.postMessage",
-        "body": {
-            "channel": "C04GWUTDC3W",
-            "text": "This the Trigger.dev integrations test"
-        },
-        "status": 200,
-        "response": [
-            "132a0300c4f7dfcd9f56ce9d9f9342c8d6f68b484575e2661a76992518653ed6029993da6eeb1ffccd5ee7345e3bb70b6a2dc047cc6a474c8790110b4b6112e38710141d5d7f7f7e5c14e36f28ac9610f8244dd23821e74d1688288302d2d790231ad355b5df82a0e0e8fa972e9eeeae73eef97ed686181b0ad73ce882605eae7aede863d1ef76db0bd36a6fa27fe9e317b9002e2360a92b8c47fc31049f8e6edce7e7ebcbcd1ba9a03e9b3101f2b01b4fd93d33e1da644bc8ff7161faf2553ea405e1dab9e6672888b8ed2456c3b4c796c43df1a8dab9fcc53ca1fa78c294ffe6b7c20bc170baaa060a937a4be63de7f627f531276273af355d3dd88e517b0185cce397a058db09ab71d2bca74b29d992ad9b657572babef0e99649c9b2cb3197da8159b25dbd5ab2f5d9ac64496a7192be18348e881e3192189d34d057f0f9d534a00667852a365b685402cac16b4132aa117b171387829075f67ae7f319"
-        ],
-        "rawHeaders": [
-            "date",
-            "Sat, 18 Feb 2023 16:06:41 GMT",
-            "server",
-            "Apache",
-            "x-powered-by",
-            "HHVM/4.153.1",
-            "access-control-allow-origin",
-            "*",
-            "referrer-policy",
-            "no-referrer",
-            "x-slack-backend",
-            "r",
-            "x-slack-unique-id",
-            "Y_D3kaZTOTsosPP4CQqdxwAAAD8",
-            "strict-transport-security",
-            "max-age=31536000; includeSubDomains; preload",
-            "access-control-allow-headers",
-            "slack-route, x-slack-version-ts, x-b3-traceid, x-b3-spanid, x-b3-parentspanid, x-b3-sampled, x-b3-flags",
-            "access-control-expose-headers",
-            "x-slack-req-id, retry-after",
-            "x-oauth-scopes",
-            "channels:read,channels:join,channels:manage,chat:write,groups:write,im:write,mpim:write,chat:write.customize,reactions:write",
-            "x-accepted-oauth-scopes",
-            "chat:write",
-            "expires",
-            "Mon, 26 Jul 1997 05:00:00 GMT",
-            "cache-control",
-            "private, no-cache, no-store, must-revalidate",
-            "pragma",
-            "no-cache",
-            "x-xss-protection",
-            "0",
-            "x-content-type-options",
-            "nosniff",
-            "x-slack-req-id",
-            "bd4f8b61920e9df75d67e4cfeb504ab9",
-            "vary",
-            "Accept-Encoding",
-            "content-encoding",
-            "br",
-            "content-length",
-            "351",
-            "content-type",
-            "application/json; charset=utf-8",
-            "x-envoy-upstream-service-time",
-            "141",
-            "x-backend",
-            "main_normal main_canary_with_overflow main_control_with_overflow",
-            "x-server",
-            "slack-www-hhvm-main-iad-mhht",
-            "x-slack-shared-secret-outcome",
-            "no-match",
-            "via",
-            "envoy-www-iad-qbeb, envoy-edge-lhr-vvct",
-            "x-edge-backend",
-            "envoy-www",
-            "x-slack-edge-shared-secret-outcome",
-            "no-match",
-            "connection",
-            "close"
-        ],
-        "responseIsBinary": false
-    }
-]

apps/integrations/src/fixtures/conversations.list.json

@@ -1,75 +0,0 @@
-[
-    {
-        "scope": "https://slack.com:443",
-        "method": "GET",
-        "path": "/api/conversations.list?limit=1",
-        "body": "",
-        "status": 200,
-        "response": [
-            "13b70300c4c8b67c7d337bad87225e710b16c4026732712e9d6da4139c5a54d3ce1324f223350ae881931e68f7fe6f2e24241b5ae4fce77333b3308328b0bdc4c2a6b0c47fd8fe99218bb08d13c7b0eeaf3fed1350d47ec5b10d59b12bca7aac133d4690f51821096e8017ee6455da533537753e31a7cf1f8a4134bc504d55d54dddd5edb6948833517f6a3b0cb0cc0dea32ab8b76a2c2b0c8a4d6b369799577425dd5010f896e52233616b8cbf8b8df824e74d5d5cf1fc5e9f8fd719fd94f603a045e61471fcef3f123a9795cbe1f966919aeaa688a612b14de3162df8f279060601b5ea44a20d17d8337c7302e4f2e4d558826a6c8229a3e6ec7f23bfa639a72cc9ae6e29f85125e05bc3b2a819318db3338ce776ce35ed4d248740b126c7a503e5423e15e3c991b886c598e5622e0ce7dc37abc6fe8684101b30acd3947bb1c13d3a154d39724844e2171995571e95794c47e1c677542492aa2844b4dee39115d926741c0bb52eec747642206ab11f9b5d631d92d819adefc4a7429f12192908486c57ab7442a76f9301383deac46a939aa07554cf5b06d2cfe028d6b812d9122d694e12ac0b13c8f7d9c6302b6115dbca7c16b73fa70fa64dc9d450f6f85d8c36201"
-        ],
-        "rawHeaders": [
-            "date",
-            "Sat, 18 Feb 2023 16:06:42 GMT",
-            "server",
-            "Apache",
-            "x-powered-by",
-            "HHVM/4.153.1",
-            "access-control-allow-origin",
-            "*",
-            "referrer-policy",
-            "no-referrer",
-            "x-slack-backend",
-            "r",
-            "x-slack-unique-id",
-            "Y_D3khlLQ9vqek922QY0uQAAECM",
-            "strict-transport-security",
-            "max-age=31536000; includeSubDomains; preload",
-            "access-control-allow-headers",
-            "slack-route, x-slack-version-ts, x-b3-traceid, x-b3-spanid, x-b3-parentspanid, x-b3-sampled, x-b3-flags",
-            "access-control-expose-headers",
-            "x-slack-req-id, retry-after",
-            "x-oauth-scopes",
-            "channels:read,channels:join,channels:manage,chat:write,groups:write,im:write,mpim:write,chat:write.customize,reactions:write",
-            "x-accepted-oauth-scopes",
-            "channels:read,groups:read,mpim:read,im:read,read",
-            "expires",
-            "Mon, 26 Jul 1997 05:00:00 GMT",
-            "cache-control",
-            "private, no-cache, no-store, must-revalidate",
-            "pragma",
-            "no-cache",
-            "x-xss-protection",
-            "0",
-            "x-content-type-options",
-            "nosniff",
-            "x-slack-req-id",
-            "c9ac7f0c1a73910e91a87a6cd3925462",
-            "vary",
-            "Accept-Encoding",
-            "content-encoding",
-            "br",
-            "content-length",
-            "452",
-            "content-type",
-            "application/json; charset=utf-8",
-            "x-envoy-upstream-service-time",
-            "115",
-            "x-backend",
-            "main_normal main_canary_with_overflow main_control_with_overflow",
-            "x-server",
-            "slack-www-hhvm-main-iad-bmkm",
-            "x-slack-shared-secret-outcome",
-            "no-match",
-            "via",
-            "envoy-www-iad-vpph, envoy-edge-lhr-tspo",
-            "x-edge-backend",
-            "envoy-www",
-            "x-slack-edge-shared-secret-outcome",
-            "no-match",
-            "connection",
-            "close"
-        ],
-        "responseIsBinary": false
-    }
-]

apps/integrations/src/fixtures/sendgrid.mailSend.json

@@ -1,56 +0,0 @@
-[
-    {
-        "scope": "https://api.sendgrid.com:443",
-        "method": "POST",
-        "path": "/v3/mail/send",
-        "body": {
-            "from": {
-                "email": "matt@email.trigger.dev"
-            },
-            "subject": "Hello, World!",
-            "content": [
-                {
-                    "type": "text/plain",
-                    "value": "Email body here"
-                }
-            ],
-            "personalizations": [
-                {
-                    "to": [
-                        {
-                            "email": "matt@trigger.dev"
-                        }
-                    ],
-                    "subject": "Hello, World!"
-                }
-            ]
-        },
-        "status": 202,
-        "response": "",
-        "rawHeaders": [
-            "Server",
-            "nginx",
-            "Date",
-            "Sun, 19 Feb 2023 19:16:30 GMT",
-            "Content-Length",
-            "0",
-            "Connection",
-            "close",
-            "X-Message-Id",
-            "D9FX-x6ETvKlMlzEi0Qlpg",
-            "Access-Control-Allow-Origin",
-            "https://sendgrid.api-docs.io",
-            "Access-Control-Allow-Methods",
-            "POST",
-            "Access-Control-Allow-Headers",
-            "Authorization, Content-Type, On-behalf-of, x-sg-elas-acl",
-            "Access-Control-Max-Age",
-            "600",
-            "X-No-CORS-Reason",
-            "https://sendgrid.com/docs/Classroom/Basics/API/cors.html",
-            "Strict-Transport-Security",
-            "max-age=600; includeSubDomains"
-        ],
-        "responseIsBinary": false
-    }
-]

apps/integrations/src/fixtures/sendgrid.marketingContacts.json

@@ -1,59 +0,0 @@
-[
-    {
-        "scope": "https://api.sendgrid.com:443",
-        "method": "PUT",
-        "path": "/v3/marketing/contacts",
-        "body": {
-            "contacts": [
-                {
-                    "email": "matt+1@mattaitken.com",
-                    "first_name": "Matt",
-                    "last_name": "Aitken"
-                }
-            ]
-        },
-        "status": 202,
-        "response": {
-            "job_id": "1befbf98-bfdc-4565-ba5a-c7e8b91f2678"
-        },
-        "rawHeaders": [
-            "Server",
-            "nginx",
-            "Date",
-            "Mon, 20 Feb 2023 15:21:43 GMT",
-            "Content-Type",
-            "application/json",
-            "Content-Length",
-            "50",
-            "Connection",
-            "close",
-            "x-amzn-requestid",
-            "6fcf9591-e37d-4fb9-b175-59d434ba45c6",
-            "access-control-allow-origin",
-            "*",
-            "access-control-allow-headers",
-            "AUTHORIZATION, Content-Type, On-behalf-of, x-sg-elas-acl, X-Recaptcha, X-Request-Source",
-            "x-amz-apigw-id",
-            "ApNxLHMAvHcFjkA=",
-            "access-control-allow-methods",
-            "PUT,OPTIONS,DELETE,OPTIONS",
-            "access-control-expose-headers",
-            "Link, Location",
-            "x-amzn-trace-id",
-            "Root=1-63f39007-0392a34047f268f366e7d4ce;Sampled=0",
-            "x-envoy-upstream-service-time",
-            "231",
-            "referrer-policy",
-            "strict-origin-when-cross-origin",
-            "x-content-type-options",
-            "nosniff",
-            "x-ratelimit-limit",
-            "200",
-            "x-ratelimit-remaining",
-            "197",
-            "x-ratelimit-reset",
-            "17"
-        ],
-        "responseIsBinary": false
-    }
-]

apps/integrations/src/fixtures/serviceFetch.simple.get.json

@@ -1,79 +0,0 @@
-[
-    {
-        "scope": "https://api.airtable.com:443",
-        "method": "GET",
-        "path": "/v0/appBlf3KsalIQeMUo/tblvXn2TOeVPC9c6m/recHcnB1MbBr9Rd2P",
-        "body": "",
-        "status": 200,
-        "response": {
-            "id": "recHcnB1MbBr9Rd2P",
-            "createdTime": "2023-01-03T12:05:53.000Z",
-            "fields": {
-                "Employee": "John Doe II",
-                "Phone": "(123) 456-7890",
-                "Headshot": [
-                    {
-                        "id": "att3ibwyOXULYL15O",
-                        "width": 950,
-                        "height": 700,
-                        "url": "https://v5.airtableusercontent.com/v1/15/15/1676995200000/D_htRl39BrNhGxsiGlNpcQ/tYWJWmeq3WBDaQCZIeDn-IAKEczimZduMBB30Xq48IYOla6DEq2h59YjRRAQZr4xH-YCc7n3cf4GAXlxPXYAYGfo2e0K230BdUzQXk43vrc/Y61oM8Pgbyu_5-jhuGhea9r2mpjjm5lxIGOJPP5BaO4",
-                        "filename": "headshot-purple-2 (1).png",
-                        "size": 191272,
-                        "type": "image/png",
-                        "thumbnails": {
-                            "small": {
-                                "url": "https://v5.airtableusercontent.com/v1/15/15/1676995200000/1Ev7NzTXpXw2FnaLtcYrzg/NZwW2F5QNr7qa_SXXlDx9vhjD_oxlwvSCboJj2T_S1WC0J0WWYYOWr6pfn_s_Z3aOU34l-v7ScjvQdL9vDtczQ/U0GygRlbr35RvoD2S-yyeJ3IWrbOqEjFe1D_-8KKpNY",
-                                "width": 49,
-                                "height": 36
-                            },
-                            "large": {
-                                "url": "https://v5.airtableusercontent.com/v1/15/15/1676995200000/lgoKQYxOC2eUe51PTO-_yg/dKv1Cx9ws40PNDnn2Y8bKlv4fbCfyGDshlFno1NOrEkceHJW-cCWG5E97cBs4B389t0Rf8SK3dMt8RkUOyueCg/3WxWv9_VvEua1zls82Z4Dca3yjWD9Cp2e6ldqrhzTKg",
-                                "width": 695,
-                                "height": 512
-                            },
-                            "full": {
-                                "url": "https://v5.airtableusercontent.com/v1/15/15/1676995200000/Rihc4R_4ndQBrAHA49_j7Q/3V3Js1Xsx4AxXmxVkurk09ZpYY0kmOJHJlhDqybO5Zws1tP1oZZC4mCaRRnMLpx3XLu41c5aALWuo7Jl7UC2yQ/1Kej1MQjyAGYqcSVqo4_1GHLMOoF9puGps0NxQCCHpQ",
-                                "width": 3000,
-                                "height": 3000
-                            }
-                        }
-                    }
-                ],
-                "Employee type": "Contractor"
-            }
-        },
-        "rawHeaders": [
-            "Date",
-            "Tue, 21 Feb 2023 12:47:49 GMT",
-            "Content-Type",
-            "867",
-            "Connection",
-            "close",
-            "Set-Cookie",
-            "AWSALB=P04kqBtI/0ytyUg9Fjvlqdj/79QEnNQZOJrk8expPLgAkwq3exJsTzPeYwbkOAkiuGDomuXqutUq6flBHmrEFz1du9r03QrsztyUe1mYaFVAoAPR4BacSk6CNE/8; Expires=Tue, 28 Feb 2023 12:47:49 GMT; Path=/",
-            "Set-Cookie",
-            "AWSALBCORS=P04kqBtI/0ytyUg9Fjvlqdj/79QEnNQZOJrk8expPLgAkwq3exJsTzPeYwbkOAkiuGDomuXqutUq6flBHmrEFz1du9r03QrsztyUe1mYaFVAoAPR4BacSk6CNE/8; Expires=Tue, 28 Feb 2023 12:47:49 GMT; Path=/; SameSite=None; Secure",
-            "Server",
-            "Tengine",
-            "Set-Cookie",
-            "brw=brwJ69m62Pda820BR; path=/; expires=Wed, 21 Feb 2024 12:47:49 GMT; domain=.airtable.com; samesite=none; secure",
-            "Strict-Transport-Security",
-            "max-age=31536000; includeSubDomains; preload",
-            "access-control-allow-origin",
-            "*",
-            "access-control-allow-methods",
-            "DELETE,GET,OPTIONS,PATCH,POST,PUT",
-            "access-control-allow-headers",
-            "authorization,content-length,content-type,user-agent,x-airtable-application-id,x-airtable-user-agent,x-api-version,x-requested-with",
-            "X-Frame-Options",
-            "DENY",
-            "X-Content-Type-Options",
-            "nosniff",
-            "Vary",
-            "Accept-Encoding",
-            "airtable-uncompressed-content-length",
-            "1314"
-        ],
-        "responseIsBinary": false
-    }
-]

apps/integrations/src/generators/combineSchemas.test.ts

@@ -1,106 +0,0 @@
-import { EndpointSpec } from "core/endpoint/types";
-import { JSONSchema } from "core/schemas/types";
-import { expect, test } from "vitest";
-import { createInputSchema } from "./combineSchemas";
-
-test("create input schema when only a body schema", async () => {
-  try {
-    const schema: JSONSchema = {
-      type: "object",
-      required: ["channel"],
-      properties: {
-        as_user: {
-          type: "string",
-          description:
-            "Pass true to post the message as the authed user, instead of as a bot. Defaults to false. See [authorship](#authorship) below.",
-        },
-        attachments: {
-          type: "string",
-          description:
-            "A JSON-based array of structured attachments, presented as a URL-encoded string.",
-        },
-        channel: {
-          type: "string",
-          description:
-            "Channel, private group, or IM channel to send message to. Can be an encoded ID, or a name. See [below](#channels) for more details.",
-        },
-      },
-    };
-
-    const inputSchema = createInputSchema({ body: schema });
-    expect(inputSchema).toEqual(schema);
-  } catch (e: any) {
-    console.error(JSON.stringify(e.errors, null, 2));
-    expect(e).toEqual(null);
-  }
-});
-
-test("combine input body and parameters into a schema", async () => {
-  try {
-    const bodySchema: JSONSchema = {
-      type: "object",
-      required: ["channel"],
-      properties: {
-        as_user: {
-          type: "string",
-          description:
-            "Pass true to post the message as the authed user, instead of as a bot. Defaults to false. See [authorship](#authorship) below.",
-        },
-        attachments: {
-          type: "string",
-          description:
-            "A JSON-based array of structured attachments, presented as a URL-encoded string.",
-        },
-        channel: {
-          type: "string",
-          description:
-            "Channel, private group, or IM channel to send message to. Can be an encoded ID, or a name. See [below](#channels) for more details.",
-        },
-      },
-    };
-    const parameters: EndpointSpec["parameters"] = [
-      {
-        name: "limit",
-        description: "The maximum number of items to return.",
-        in: "path",
-        required: true,
-        schema: {
-          type: "integer",
-          description: "The maximum number of items to return.",
-        },
-      },
-    ];
-
-    const inputSchema = createInputSchema({ body: bodySchema, parameters });
-    expect(inputSchema).toMatchInlineSnapshot(`
-      {
-        "properties": {
-          "as_user": {
-            "description": "Pass true to post the message as the authed user, instead of as a bot. Defaults to false. See [authorship](#authorship) below.",
-            "type": "string",
-          },
-          "attachments": {
-            "description": "A JSON-based array of structured attachments, presented as a URL-encoded string.",
-            "type": "string",
-          },
-          "channel": {
-            "description": "Channel, private group, or IM channel to send message to. Can be an encoded ID, or a name. See [below](#channels) for more details.",
-            "type": "string",
-          },
-          "limit": {
-            "description": "The maximum number of items to return.",
-            "type": "integer",
-          },
-        },
-        "required": [
-          "channel",
-          "limit",
-        ],
-        "type": "object",
-      }
-    `);
-  } catch (e: any) {
-    console.error(JSON.stringify(e.errors, null, 2));
-    expect(e).toEqual(null);
-  }
-});

apps/integrations/src/generators/combineSchemas.ts

@@ -1,79 +0,0 @@
-import { Action } from "core/action/types";
-import { JSONSchema } from "core/schemas/types";
-
-export function generateInputOutputSchemas(
-  spec: Action["spec"],
-  name: string
-): {
-  input: JSONSchema | undefined;
-  output: JSONSchema | undefined;
-} {
-  const inputSchema = createInputSchema(spec.input);
-  if (inputSchema) inputSchema.title = `${name}Input`;
-
-  const outputSchema = createSuccessfulOutputSchema(spec.output);
-  if (outputSchema) outputSchema.title = `${name}Output`;
-
-  return {
-    input: inputSchema,
-    output: outputSchema,
-  };
-}
-
-export function createInputSchema(
-  spec: Action["spec"]["input"]
-): JSONSchema | undefined {
-  let inputSchema: JSONSchema | undefined = spec.body;
-
-  if (spec.parameters && spec.parameters.length > 0) {
-    if (!inputSchema) {
-      inputSchema = {
-        type: "object",
-        properties: {},
-      };
-    }
-
-    inputSchema = {
-      type: "object",
-      properties: {
-        ...inputSchema.properties,
-        ...Object.fromEntries(
-          spec.parameters.map((p) => [
-            p.name,
-            { ...p.schema, description: p.description },
-          ])
-        ),
-      },
-      required: [
-        ...(inputSchema.required ?? []),
-        ...spec.parameters.filter((p) => p.required).map((p) => p.name),
-      ],
-    };
-  }
-
-  return inputSchema;
-}
-
-export function createSuccessfulOutputSchema(
-  spec: Action["spec"]["output"]
-): JSONSchema | undefined {
-  if (spec === undefined) return undefined;
-
-  //combine all "success" output schemas into a union
-  const outputSuccessSchemas = Object.values(spec.responses).flatMap((s) =>
-    s.flatMap((r) => (r.success ? r.schema : []))
-  );
-  return outputSuccessSchemas.length === 1
-    ? outputSuccessSchemas[0]
-    : createDiscriminatedUnionSchema(`Output`, outputSuccessSchemas);
-}
-
-function createDiscriminatedUnionSchema(
-  name: string,
-  schemas: JSONSchema[]
-): JSONSchema {
-  return {
-    $id: name,
-    oneOf: schemas,
-  };
-}

apps/integrations/src/generators/generateTypes.test.ts

@@ -1,119 +0,0 @@
-import { expect, test } from "vitest";
-import { getTypesFromSchema as generateTypesFromSchema } from "./generateTypes";
-
-test("simple schema type generation", async () => {
-  try {
-    const schema = {
-      type: "object",
-      properties: {
-        channel: {
-          type: "string",
-          description: "ID of conversation to join",
-        },
-      },
-      required: ["channel"],
-    };
-
-    const data = await generateTypesFromSchema(schema, "Input");
-    expect(data).toMatchInlineSnapshot(`
-      "export interface Input {
-      /**
-       * ID of conversation to join
-       */
-      channel: string
-      }
-      "
-    `);
-  } catch (e: any) {
-    console.error(JSON.stringify(e.errors, null, 2));
-    expect(e).toEqual(null);
-  }
-});
-
-test("advanced schema type generation", async () => {
-  try {
-    const schema = {
-      type: "object",
-      properties: {
-        channel: {
-          type: "string",
-        },
-        message: {
-          type: "object",
-          properties: {
-            attachments: {
-              type: "array",
-              items: {
-                type: "object",
-                properties: {
-                  fallback: {
-                    type: "string",
-                  },
-                  id: {
-                    type: "number",
-                  },
-                  text: {
-                    type: "string",
-                  },
-                },
-                required: ["fallback", "id", "text"],
-              },
-            },
-            bot_id: {
-              type: "string",
-            },
-            subtype: {
-              type: "string",
-            },
-            text: {
-              type: "string",
-            },
-            ts: {
-              type: "string",
-            },
-            type: {
-              type: "string",
-            },
-            user: {
-              type: "string",
-            },
-          },
-          required: ["bot_id", "text", "ts", "type"],
-        },
-        ok: {
-          type: "boolean",
-        },
-        ts: {
-          type: "string",
-        },
-      },
-      required: ["channel", "message", "ok", "ts"],
-    };
-
-    const data = await generateTypesFromSchema(schema, "Input");
-    expect(data).toMatchInlineSnapshot(`
-      "export interface Input {
-      channel: string
-      message: {
-      attachments?: {
-      fallback: string
-      id: number
-      text: string
-      }[]
-      bot_id: string
-      subtype?: string
-      text: string
-      ts: string
-      type: string
-      user?: string
-      }
-      ok: boolean
-      ts: string
-      }
-      "
-    `);
-  } catch (e: any) {
-    console.error(JSON.stringify(e.errors, null, 2));
-    expect(e).toEqual(null);
-  }
-});

apps/integrations/src/generators/generateTypes.ts

@@ -1,10 +0,0 @@
-import { compile } from "json-schema-to-typescript";
-
-export async function getTypesFromSchema(schema: any, name: string) {
-  const ts = await compile(schema, name, {
-    additionalProperties: false,
-    bannerComment: "",
-    format: false,
-  });
-  return ts;
-}

apps/integrations/src/index.ts

@@ -1,62 +0,0 @@
-import { handleAction } from "api/v2/action";
-import { handleActionDisplay } from "api/v2/action/display";
-import { handleServices } from "api/v2/services";
-import dotenv from "dotenv";
-import express, { Express, NextFunction, Request, Response } from "express";
-import morgan from "morgan";
-
-dotenv.config();
-
-const app: Express = express();
-const port = process.env.PORT ?? 3006;
-
-app.use(express.json());
-app.use(morgan("combined"));
-
-const checkAuthentication = function (
-  req: Request,
-  res: Response,
-  next: NextFunction
-) {
-  //if the path is /healthcheck, skip authentication
-  if (req.path === "/healthcheck") {
-    next();
-    return;
-  }
-
-  const authHeader = req.headers.authorization;
-  if (!authHeader) {
-    res.status(401).send("Unauthorized");
-    return;
-  }
-
-  const auth = authHeader.split(" ");
-  if (auth.length !== 2 || auth[0] !== "Bearer") {
-    res.status(401).send("Unauthorized");
-    return;
-  }
-
-  const token = auth[1];
-  if (token !== process.env.API_TOKEN) {
-    res.status(401).send("Unauthorized");
-    return;
-  }
-
-  next();
-};
-
-app.use(checkAuthentication);
-
-app.get("/", (req: Request, res: Response) => {
-  res.send("Trigger.dev integrations service");
-});
-app.get("/healthcheck", (req: Request, res: Response) => {
-  res.send("OK");
-});
-app.get("/api/v2/services", handleServices);
-app.post("/api/v2/:service/action/:action/display", handleActionDisplay);
-app.post("/api/v2/:service/action/:action", handleAction);
-
-app.listen(port, () => {
-  console.log(`⚡️[server]: Server is running at http://localhost:${port}`);
-});

apps/integrations/src/integrations/airtable/actions/actions.ts

@@ -1,5 +0,0 @@
-import { makeSimpleActions } from "core/action/makeAction";
-import endpoints from "../endpoints/endpoints";
-
-const actions = makeSimpleActions(endpoints);
-export default actions;

apps/integrations/src/integrations/airtable/authentication.ts

@@ -1,24 +0,0 @@
-import { IntegrationAuthentication } from "core/authentication/types";
-
-export const authentication: IntegrationAuthentication = {
-  oauth: {
-    type: "oauth2",
-    placement: {
-      in: "header",
-      type: "bearer",
-      key: "Authorization",
-    },
-    authorizationUrl: "https://airtable.com/oauth2/v1/authorize",
-    tokenUrl: "https://airtable.com/oauth2/v1/token",
-    flow: "accessCode",
-    scopes: {
-      "data.records:read": "data.records:read",
-      "data.records:write": "data.records:write",
-      "data.recordComments:read": "data.recordComments:read",
-      "data.recordComments:write": "data.recordComments:write",
-      "schema.bases:read": "schema.bases:read",
-      "schema.bases:write": "schema.bases:write",
-      "webhook:manage": "webhook:manage",
-    },
-  },
-};

apps/integrations/src/integrations/airtable/common/schemas.ts

@@ -1,532 +0,0 @@
-import { EndpointSpecParameter } from "core/endpoint/types";
-import {
-  makeArraySchema,
-  makeBooleanSchema,
-  makeNumberSchema,
-  makeObjectSchema,
-  makeOneOf,
-  makeStringSchema,
-} from "core/schemas/makeSchema";
-import { JSONSchema } from "core/schemas/types";
-
-export const CollaboratorSchema = makeObjectSchema("A Collaborator", {
-  requiredProperties: {
-    id: makeStringSchema("Collaborator ID"),
-    email: makeStringSchema("Collaborator Email"),
-    name: makeStringSchema("Collaborator Name"),
-  },
-  additionalProperties: true,
-});
-
-export const ThumbnailSchema = makeObjectSchema("A Thumbnail", {
-  requiredProperties: {
-    url: makeStringSchema("Thumbnail URL"),
-    width: makeNumberSchema("Thumbnail Width"),
-    height: makeNumberSchema("Thumbnail Height"),
-  },
-  additionalProperties: true,
-});
-
-export const AttachmentSchema = makeObjectSchema("An Attachment", {
-  requiredProperties: {
-    id: makeStringSchema("Attachment ID"),
-    url: makeStringSchema("Attachment URL"),
-    filename: makeStringSchema("Attachment Filename"),
-    size: makeNumberSchema("Attachment Size"),
-    type: makeStringSchema("Attachment Type"),
-  },
-  optionalProperties: {
-    height: makeNumberSchema("Attachment Height"),
-    width: makeNumberSchema("Attachment Width"),
-    thumbnails: makeObjectSchema("Thumbnails", {
-      requiredProperties: {
-        small: ThumbnailSchema,
-        large: ThumbnailSchema,
-        full: ThumbnailSchema,
-      },
-      additionalProperties: true,
-    }),
-  },
-  additionalProperties: true,
-});
-
-export const FieldSchema = makeOneOf("FieldValue", [
-  makeStringSchema("StringValue"),
-  makeNumberSchema("NumberValue"),
-  makeBooleanSchema("BooleanValue"),
-  CollaboratorSchema,
-  makeArraySchema("Collaborators", CollaboratorSchema),
-  makeArraySchema("StringValues", makeStringSchema("StringValue")),
-  makeArraySchema("Attachments", AttachmentSchema),
-]);
-
-export const BaseIdParam: EndpointSpecParameter = {
-  name: "baseId",
-  in: "path",
-  description: "The ID of the base",
-  schema: {
-    type: "string",
-  },
-  required: true,
-};
-
-export const TableIdOrNameParam: EndpointSpecParameter = {
-  name: "tableIdOrName",
-  in: "path",
-  description: "The name or id of the table",
-  schema: {
-    type: "string",
-  },
-  required: true,
-};
-
-export const RecordIdParam: EndpointSpecParameter = {
-  name: "recordId",
-  in: "path",
-  description: "The ID of the record",
-  schema: {
-    type: "string",
-  },
-  required: true,
-};
-
-export const TimeZoneSchema: JSONSchema = {
-  title: "Timezone",
-  description:
-    "The time zone that should be used to format dates when using string as the cellFormat. This parameter is required when using string as the cellFormat",
-  type: "string",
-  enum: [
-    "utc",
-    "client",
-    "Africa/Abidjan",
-    "Africa/Accra",
-    "Africa/Addis_Ababa",
-    "Africa/Algiers",
-    "Africa/Asmara",
-    "Africa/Bamako",
-    "Africa/Bangui",
-    "Africa/Banjul",
-    "Africa/Bissau",
-    "Africa/Blantyre",
-    "Africa/Brazzaville",
-    "Africa/Bujumbura",
-    "Africa/Cairo",
-    "Africa/Casablanca",
-    "Africa/Ceuta",
-    "Africa/Conakry",
-    "Africa/Dakar",
-    "Africa/Dar_es_Salaam",
-    "Africa/Djibouti",
-    "Africa/Douala",
-    "Africa/El_Aaiun",
-    "Africa/Freetown",
-    "Africa/Gaborone",
-    "Africa/Harare",
-    "Africa/Johannesburg",
-    "Africa/Juba",
-    "Africa/Kampala",
-    "Africa/Khartoum",
-    "Africa/Kigali",
-    "Africa/Kinshasa",
-    "Africa/Lagos",
-    "Africa/Libreville",
-    "Africa/Lome",
-    "Africa/Luanda",
-    "Africa/Lubumbashi",
-    "Africa/Lusaka",
-    "Africa/Malabo",
-    "Africa/Maputo",
-    "Africa/Maseru",
-    "Africa/Mbabane",
-    "Africa/Mogadishu",
-    "Africa/Monrovia",
-    "Africa/Nairobi",
-    "Africa/Ndjamena",
-    "Africa/Niamey",
-    "Africa/Nouakchott",
-    "Africa/Ouagadougou",
-    "Africa/Porto-Novo",
-    "Africa/Sao_Tome",
-    "Africa/Tripoli",
-    "Africa/Tunis",
-    "Africa/Windhoek",
-    "America/Adak",
-    "America/Anchorage",
-    "America/Anguilla",
-    "America/Antigua",
-    "America/Araguaina",
-    "America/Argentina/Buenos_Aires",
-    "America/Argentina/Catamarca",
-    "America/Argentina/Cordoba",
-    "America/Argentina/Jujuy",
-    "America/Argentina/La_Rioja",
-    "America/Argentina/Mendoza",
-    "America/Argentina/Rio_Gallegos",
-    "America/Argentina/Salta",
-    "America/Argentina/San_Juan",
-    "America/Argentina/San_Luis",
-    "America/Argentina/Tucuman",
-    "America/Argentina/Ushuaia",
-    "America/Aruba",
-    "America/Asuncion",
-    "America/Atikokan",
-    "America/Bahia",
-    "America/Bahia_Banderas",
-    "America/Barbados",
-    "America/Belem",
-    "America/Belize",
-    "America/Blanc-Sablon",
-    "America/Boa_Vista",
-    "America/Bogota",
-    "America/Boise",
-    "America/Cambridge_Bay",
-    "America/Campo_Grande",
-    "America/Cancun",
-    "America/Caracas",
-    "America/Cayenne",
-    "America/Cayman",
-    "America/Chicago",
-    "America/Chihuahua",
-    "America/Costa_Rica",
-    "America/Creston",
-    "America/Cuiaba",
-    "America/Curacao",
-    "America/Danmarkshavn",
-    "America/Dawson",
-    "America/Dawson_Creek",
-    "America/Denver",
-    "America/Detroit",
-    "America/Dominica",
-    "America/Edmonton",
-    "America/Eirunepe",
-    "America/El_Salvador",
-    "America/Fort_Nelson",
-    "America/Fortaleza",
-    "America/Glace_Bay",
-    "America/Godthab",
-    "America/Goose_Bay",
-    "America/Grand_Turk",
-    "America/Grenada",
-    "America/Guadeloupe",
-    "America/Guatemala",
-    "America/Guayaquil",
-    "America/Guyana",
-    "America/Halifax",
-    "America/Havana",
-    "America/Hermosillo",
-    "America/Indiana/Indianapolis",
-    "America/Indiana/Knox",
-    "America/Indiana/Marengo",
-    "America/Indiana/Petersburg",
-    "America/Indiana/Tell_City",
-    "America/Indiana/Vevay",
-    "America/Indiana/Vincennes",
-    "America/Indiana/Winamac",
-    "America/Inuvik",
-    "America/Iqaluit",
-    "America/Jamaica",
-    "America/Juneau",
-    "America/Kentucky/Louisville",
-    "America/Kentucky/Monticello",
-    "America/Kralendijk",
-    "America/La_Paz",
-    "America/Lima",
-    "America/Los_Angeles",
-    "America/Lower_Princes",
-    "America/Maceio",
-    "America/Managua",
-    "America/Manaus",
-    "America/Marigot",
-    "America/Martinique",
-    "America/Matamoros",
-    "America/Mazatlan",
-    "America/Menominee",
-    "America/Merida",
-    "America/Metlakatla",
-    "America/Mexico_City",
-    "America/Miquelon",
-    "America/Moncton",
-    "America/Monterrey",
-    "America/Montevideo",
-    "America/Montserrat",
-    "America/Nassau",
-    "America/New_York",
-    "America/Nipigon",
-    "America/Nome",
-    "America/Noronha",
-    "America/North_Dakota/Beulah",
-    "America/North_Dakota/Center",
-    "America/North_Dakota/New_Salem",
-    "America/Nuuk",
-    "America/Ojinaga",
-    "America/Panama",
-    "America/Pangnirtung",
-    "America/Paramaribo",
-    "America/Phoenix",
-    "America/Port-au-Prince",
-    "America/Port_of_Spain",
-    "America/Porto_Velho",
-    "America/Puerto_Rico",
-    "America/Punta_Arenas",
-    "America/Rainy_River",
-    "America/Rankin_Inlet",
-    "America/Recife",
-    "America/Regina",
-    "America/Resolute",
-    "America/Rio_Branco",
-    "America/Santarem",
-    "America/Santiago",
-    "America/Santo_Domingo",
-    "America/Sao_Paulo",
-    "America/Scoresbysund",
-    "America/Sitka",
-    "America/St_Barthelemy",
-    "America/St_Johns",
-    "America/St_Kitts",
-    "America/St_Lucia",
-    "America/St_Thomas",
-    "America/St_Vincent",
-    "America/Swift_Current",
-    "America/Tegucigalpa",
-    "America/Thule",
-    "America/Thunder_Bay",
-    "America/Tijuana",
-    "America/Toronto",
-    "America/Tortola",
-    "America/Vancouver",
-    "America/Whitehorse",
-    "America/Winnipeg",
-    "America/Yakutat",
-    "America/Yellowknife",
-    "Antarctica/Casey",
-    "Antarctica/Davis",
-    "Antarctica/DumontDUrville",
-    "Antarctica/Macquarie",
-    "Antarctica/Mawson",
-    "Antarctica/McMurdo",
-    "Antarctica/Palmer",
-    "Antarctica/Rothera",
-    "Antarctica/Syowa",
-    "Antarctica/Troll",
-    "Antarctica/Vostok",
-    "Arctic/Longyearbyen",
-    "Asia/Aden",
-    "Asia/Almaty",
-    "Asia/Amman",
-    "Asia/Anadyr",
-    "Asia/Aqtau",
-    "Asia/Aqtobe",
-    "Asia/Ashgabat",
-    "Asia/Atyrau",
-    "Asia/Baghdad",
-    "Asia/Bahrain",
-    "Asia/Baku",
-    "Asia/Bangkok",
-    "Asia/Barnaul",
-    "Asia/Beirut",
-    "Asia/Bishkek",
-    "Asia/Brunei",
-    "Asia/Chita",
-    "Asia/Choibalsan",
-    "Asia/Colombo",
-    "Asia/Damascus",
-    "Asia/Dhaka",
-    "Asia/Dili",
-    "Asia/Dubai",
-    "Asia/Dushanbe",
-    "Asia/Famagusta",
-    "Asia/Gaza",
-    "Asia/Hebron",
-    "Asia/Ho_Chi_Minh",
-    "Asia/Hong_Kong",
-    "Asia/Hovd",
-    "Asia/Irkutsk",
-    "Asia/Istanbul",
-    "Asia/Jakarta",
-    "Asia/Jayapura",
-    "Asia/Jerusalem",
-    "Asia/Kabul",
-    "Asia/Kamchatka",
-    "Asia/Karachi",
-    "Asia/Kathmandu",
-    "Asia/Khandyga",
-    "Asia/Kolkata",
-    "Asia/Krasnoyarsk",
-    "Asia/Kuala_Lumpur",
-    "Asia/Kuching",
-    "Asia/Kuwait",
-    "Asia/Macau",
-    "Asia/Magadan",
-    "Asia/Makassar",
-    "Asia/Manila",
-    "Asia/Muscat",
-    "Asia/Nicosia",
-    "Asia/Novokuznetsk",
-    "Asia/Novosibirsk",
-    "Asia/Omsk",
-    "Asia/Oral",
-    "Asia/Phnom_Penh",
-    "Asia/Pontianak",
-    "Asia/Pyongyang",
-    "Asia/Qatar",
-    "Asia/Qostanay",
-    "Asia/Qyzylorda",
-    "Asia/Rangoon",
-    "Asia/Riyadh",
-    "Asia/Sakhalin",
-    "Asia/Samarkand",
-    "Asia/Seoul",
-    "Asia/Shanghai",
-    "Asia/Singapore",
-    "Asia/Srednekolymsk",
-    "Asia/Taipei",
-    "Asia/Tashkent",
-    "Asia/Tbilisi",
-    "Asia/Tehran",
-    "Asia/Thimphu",
-    "Asia/Tokyo",
-    "Asia/Tomsk",
-    "Asia/Ulaanbaatar",
-    "Asia/Urumqi",
-    "Asia/Ust-Nera",
-    "Asia/Vientiane",
-    "Asia/Vladivostok",
-    "Asia/Yakutsk",
-    "Asia/Yangon",
-    "Asia/Yekaterinburg",
-    "Asia/Yerevan",
-    "Atlantic/Azores",
-    "Atlantic/Bermuda",
-    "Atlantic/Canary",
-    "Atlantic/Cape_Verde",
-    "Atlantic/Faroe",
-    "Atlantic/Madeira",
-    "Atlantic/Reykjavik",
-    "Atlantic/South_Georgia",
-    "Atlantic/St_Helena",
-    "Atlantic/Stanley",
-    "Australia/Adelaide",
-    "Australia/Brisbane",
-    "Australia/Broken_Hill",
-    "Australia/Currie",
-    "Australia/Darwin",
-    "Australia/Eucla",
-    "Australia/Hobart",
-    "Australia/Lindeman",
-    "Australia/Lord_Howe",
-    "Australia/Melbourne",
-    "Australia/Perth",
-    "Australia/Sydney",
-    "Europe/Amsterdam",
-    "Europe/Andorra",
-    "Europe/Astrakhan",
-    "Europe/Athens",
-    "Europe/Belgrade",
-    "Europe/Berlin",
-    "Europe/Bratislava",
-    "Europe/Brussels",
-    "Europe/Bucharest",
-    "Europe/Budapest",
-    "Europe/Busingen",
-    "Europe/Chisinau",
-    "Europe/Copenhagen",
-    "Europe/Dublin",
-    "Europe/Gibraltar",
-    "Europe/Guernsey",
-    "Europe/Helsinki",
-    "Europe/Isle_of_Man",
-    "Europe/Istanbul",
-    "Europe/Jersey",
-    "Europe/Kaliningrad",
-    "Europe/Kiev",
-    "Europe/Kirov",
-    "Europe/Lisbon",
-    "Europe/Ljubljana",
-    "Europe/London",
-    "Europe/Luxembourg",
-    "Europe/Madrid",
-    "Europe/Malta",
-    "Europe/Mariehamn",
-    "Europe/Minsk",
-    "Europe/Monaco",
-    "Europe/Moscow",
-    "Europe/Nicosia",
-    "Europe/Oslo",
-    "Europe/Paris",
-    "Europe/Podgorica",
-    "Europe/Prague",
-    "Europe/Riga",
-    "Europe/Rome",
-    "Europe/Samara",
-    "Europe/San_Marino",
-    "Europe/Sarajevo",
-    "Europe/Saratov",
-    "Europe/Simferopol",
-    "Europe/Skopje",
-    "Europe/Sofia",
-    "Europe/Stockholm",
-    "Europe/Tallinn",
-    "Europe/Tirane",
-    "Europe/Ulyanovsk",
-    "Europe/Uzhgorod",
-    "Europe/Vaduz",
-    "Europe/Vatican",
-    "Europe/Vienna",
-    "Europe/Vilnius",
-    "Europe/Volgograd",
-    "Europe/Warsaw",
-    "Europe/Zagreb",
-    "Europe/Zaporozhye",
-    "Europe/Zurich",
-    "Indian/Antananarivo",
-    "Indian/Chagos",
-    "Indian/Christmas",
-    "Indian/Cocos",
-    "Indian/Comoro",
-    "Indian/Kerguelen",
-    "Indian/Mahe",
-    "Indian/Maldives",
-    "Indian/Mauritius",
-    "Indian/Mayotte",
-    "Indian/Reunion",
-    "Pacific/Apia",
-    "Pacific/Auckland",
-    "Pacific/Bougainville",
-    "Pacific/Chatham",
-    "Pacific/Chuuk",
-    "Pacific/Easter",
-    "Pacific/Efate",
-    "Pacific/Enderbury",
-    "Pacific/Fakaofo",
-    "Pacific/Fiji",
-    "Pacific/Funafuti",
-    "Pacific/Galapagos",
-    "Pacific/Gambier",
-    "Pacific/Guadalcanal",
-    "Pacific/Guam",
-    "Pacific/Honolulu",
-    "Pacific/Kanton",
-    "Pacific/Kiritimati",
-    "Pacific/Kosrae",
-    "Pacific/Kwajalein",
-    "Pacific/Majuro",
-    "Pacific/Marquesas",
-    "Pacific/Midway",
-    "Pacific/Nauru",
-    "Pacific/Niue",
-    "Pacific/Norfolk",
-    "Pacific/Noumea",
-    "Pacific/Pago_Pago",
-    "Pacific/Palau",
-    "Pacific/Pitcairn",
-    "Pacific/Pohnpei",
-    "Pacific/Port_Moresby",
-    "Pacific/Rarotonga",
-    "Pacific/Saipan",
-    "Pacific/Tahiti",
-    "Pacific/Tarawa",
-    "Pacific/Tongatapu",
-    "Pacific/Wake",
-    "Pacific/Wallis",
-  ],
-};

apps/integrations/src/integrations/airtable/endpoints/endpoints.ts

@@ -1,8 +0,0 @@
-import { makeEndpoints } from "core/endpoint/endpoint";
-import { authentication } from "../authentication";
-import * as specs from "./specs";
-
-const baseUrl = "https://api.airtable.com/v0";
-
-const endpoints = makeEndpoints(baseUrl, authentication, specs);
-export default endpoints;

apps/integrations/src/integrations/airtable/endpoints/specs.ts

@@ -1,606 +0,0 @@
-import { EndpointSpec, EndpointSpecResponse } from "core/endpoint/types";
-import {
-  makeAnyOf,
-  makeArraySchema,
-  makeBooleanSchema,
-  makeNumberSchema,
-  makeObjectSchema,
-  makeStringSchema,
-} from "core/schemas/makeSchema";
-import {
-  BaseIdParam,
-  FieldSchema,
-  RecordIdParam,
-  TableIdOrNameParam,
-  TimeZoneSchema,
-} from "../common/schemas";
-
-const errorResponse: EndpointSpecResponse = {
-  success: false,
-  name: "Error",
-  description: "Error response",
-  schema: {
-    $schema: "http://json-schema.org/draft-07/schema#",
-    type: "object",
-    oneOf: [
-      {
-        type: "object",
-        properties: {
-          error: {
-            type: "string",
-          },
-        },
-        required: ["error"],
-      },
-      {
-        type: "object",
-        properties: {
-          error: {
-            type: "object",
-            properties: {
-              type: {
-                type: "string",
-              },
-            },
-            required: ["type"],
-          },
-        },
-        required: ["error"],
-      },
-    ],
-  },
-};
-
-export const listRecords: EndpointSpec = {
-  path: "/{baseId}/{tableIdOrName}/listRecords",
-  method: "POST",
-  metadata: {
-    name: "listRecords",
-    description: `List records in a table. Note that table names and table ids can be used interchangeably. We recommend using table IDs so you don't need to modify your API request when your table name changes.\n
-      The server returns one page of records at a time. Each page will contain pageSize records, which is 100 by default. If there are more records, the response will contain an offset. To fetch the next page of records, include offset in the next request's parameters. Pagination will stop when you've reached the end of your table. If the maxRecords parameter is passed, pagination will stop once you've reached this maximum.\n
-      Returned records do not include any fields with "empty" values, e.g. "", [], or false.`,
-    displayProperties: {
-      title: "List records from table ${parameters.tableIdOrName}",
-    },
-    externalDocs: {
-      description: "API method documentation",
-      url: "https://airtable.com/developers/web/api/list-records",
-    },
-    tags: ["records"],
-  },
-  security: {
-    oauth: ["data.records:read"],
-  },
-  parameters: [BaseIdParam, TableIdOrNameParam],
-  request: {
-    headers: {
-      "Content-Type": "application/json; charset=utf-8",
-    },
-    body: {
-      schema: makeObjectSchema("List records body", {
-        optionalProperties: {
-          timeZone: TimeZoneSchema,
-          userLocal: makeStringSchema(
-            "userLocal",
-            "The user locale that should be used to format dates when using string as the cellFormat. This parameter is required when using string as the cellFormat."
-          ),
-          pageSize: makeNumberSchema(
-            "pageSize",
-            "The number of records returned in each request. Must be less than or equal to 100. Default is 100."
-          ),
-          maxRecords: makeNumberSchema(
-            "maxRecords",
-            "The maximum total number of records that will be returned in your requests. If this value is larger than pageSize (which is 100 by default), you may have to load multiple pages to reach this total."
-          ),
-          offset: makeStringSchema(
-            "offset",
-            "To fetch the next page of records, include offset from the previous request in the next request's parameters."
-          ),
-          view: makeStringSchema(
-            "view",
-            "The name or ID of a view in the table. If set, only the records in that view will be returned. The records will be sorted according to the order of the view unless the sort parameter is included, which overrides that order. Fields hidden in this view will be returned in the results. To only return a subset of fields, use the fields parameter."
-          ),
-          sort: makeArraySchema(
-            "Sort",
-            makeObjectSchema("Sort field", {
-              requiredProperties: {
-                field: makeStringSchema("Field name"),
-              },
-              optionalProperties: {
-                direction: makeStringSchema("Direction", "Direction", {
-                  enum: ["asc", "desc"],
-                }),
-              },
-            })
-          ),
-          filterByFormula: makeStringSchema(
-            "filterByFormula",
-            `A formula used to filter records. The formula will be evaluated for each record, and if the result is not 0, false, "", NaN, [], or #Error! the record will be included in the response. If combined with the view parameter, only records in that view which satisfy the formula will be returned. For example, to only include records where the column named "Category" equals "Programming", pass in: filterByFormula={Category}="Programming"`
-          ),
-          fields: makeArraySchema(
-            "Only data for fields whose names or IDs are in this list will be included in the result. If you don't need every field, you can use this parameter to reduce the amount of data transferred.",
-            makeStringSchema("Field name")
-          ),
-        },
-      }),
-    },
-  },
-  responses: {
-    200: [
-      {
-        success: true,
-        name: "Success",
-        description: "Typical success response",
-        schema: makeObjectSchema("List records success body", {
-          optionalProperties: {
-            offset: makeStringSchema(
-              "offset",
-              "To fetch the next page of records, include offset from the previous request in the next request's parameters."
-            ),
-          },
-          requiredProperties: {
-            records: makeArraySchema(
-              "Records",
-              makeObjectSchema("Record", {
-                requiredProperties: {
-                  id: makeStringSchema("Record ID"),
-                  createdTime: makeStringSchema(
-                    "createdTime",
-                    `A date timestamp in the ISO format, eg:"2018-01-01T00:00:00.000Z"`
-                  ),
-                  fields: makeObjectSchema("Fields", {
-                    additionalProperties: FieldSchema,
-                  }),
-                },
-              })
-            ),
-          },
-        }),
-      },
-    ],
-    default: [errorResponse],
-  },
-};
-
-export const getRecord: EndpointSpec = {
-  path: "/{baseId}/{tableIdOrName}/{recordId}",
-  method: "GET",
-  metadata: {
-    name: "getRecord",
-    description:
-      'Retrieve a single record. Any "empty" fields (e.g. "", [], or false) in the record will not be returned.',
-    displayProperties: {
-      title:
-        "Get record ${parameters.recordId} from table ${parameters.tableIdOrName}",
-    },
-    externalDocs: {
-      description: "API method documentation",
-      url: "https://airtable.com/developers/web/api/get-record",
-    },
-    tags: ["records"],
-  },
-  security: {
-    oauth: ["data.records:read"],
-  },
-  parameters: [BaseIdParam, TableIdOrNameParam, RecordIdParam],
-  request: {
-    headers: {
-      "Content-Type": "application/json; charset=utf-8",
-    },
-  },
-  responses: {
-    200: [
-      {
-        success: true,
-        name: "Success",
-        description: "Typical success response",
-        schema: makeObjectSchema("Successful response", {
-          requiredProperties: {
-            createdTime: makeStringSchema(
-              "createdTime",
-              "When the record was created"
-            ),
-            fields: makeObjectSchema("Fields", {
-              additionalProperties: FieldSchema,
-            }),
-            id: makeStringSchema("id", "The record id"),
-          },
-        }),
-      },
-    ],
-    default: [errorResponse],
-  },
-};
-
-export const updateRecords: EndpointSpec = {
-  path: "/{baseId}/{tableIdOrName}",
-  method: "PATCH",
-  metadata: {
-    name: "updateRecords",
-    description: `Updates up to 10 records, or upserts them when performUpsert is set.`,
-    displayProperties: {
-      title: "Update records for table ${parameters.tableIdOrName}",
-    },
-    externalDocs: {
-      description: "API method documentation",
-      url: "https://airtable.com/developers/web/api/update-multiple-records",
-    },
-    tags: ["records"],
-  },
-  security: {
-    oauth: ["data.records:write"],
-  },
-  parameters: [BaseIdParam, TableIdOrNameParam],
-  request: {
-    headers: {
-      "Content-Type": "application/json; charset=utf-8",
-    },
-    body: {
-      schema: makeObjectSchema("Update records body", {
-        optionalProperties: {
-          performUpsert: makeObjectSchema("Perform upsert", {
-            requiredProperties: {
-              fieldsToMergeOn: makeArraySchema(
-                "Fields to merge on",
-                makeStringSchema("Field name")
-              ),
-            },
-          }),
-          typecast: makeBooleanSchema(
-            "typecast",
-            "If set to true, Airtable will try to convert string values into the appropriate cell value. This conversion is only performed on a best-effort basis. To ensure your data's integrity, this should only be used when necessary. Defaults to false when unset."
-          ),
-        },
-        requiredProperties: {
-          records: makeArraySchema(
-            "Records to update/upsert",
-            makeObjectSchema("Record", {
-              requiredProperties: {
-                fields: makeObjectSchema("Fields", {
-                  additionalProperties: FieldSchema,
-                }),
-              },
-              optionalProperties: {
-                id: makeStringSchema(
-                  "id",
-                  "Record ID. Required when performUpsert is not set."
-                ),
-              },
-            })
-          ),
-        },
-      }),
-    },
-  },
-  responses: {
-    200: [
-      {
-        success: true,
-        name: "Success",
-        description: "Typical success response",
-        schema: makeAnyOf("Update/upsert records success body", [
-          makeObjectSchema("Update response", {
-            requiredProperties: {
-              records: makeArraySchema(
-                "Records",
-                makeObjectSchema("Record", {
-                  requiredProperties: {
-                    id: makeStringSchema("Record ID"),
-                    createdTime: makeStringSchema(
-                      "createdTime",
-                      `A date timestamp in the ISO format, eg:"2018-01-01T00:00:00.000Z"`
-                    ),
-                    fields: makeObjectSchema("Fields", {
-                      additionalProperties: FieldSchema,
-                    }),
-                  },
-                })
-              ),
-            },
-          }),
-          makeObjectSchema("Upsert response", {
-            requiredProperties: {
-              createdRecords: makeArraySchema(
-                "Created records",
-                makeStringSchema("Record ID")
-              ),
-              updatedRecords: makeArraySchema(
-                "Updated records",
-                makeStringSchema("Record ID")
-              ),
-              records: makeArraySchema(
-                "Records",
-                makeObjectSchema("Record", {
-                  requiredProperties: {
-                    id: makeStringSchema("Record ID"),
-                    createdTime: makeStringSchema(
-                      "createdTime",
-                      `A date timestamp in the ISO format, eg:"2018-01-01T00:00:00.000Z"`
-                    ),
-                    fields: makeObjectSchema("Fields", {
-                      additionalProperties: FieldSchema,
-                    }),
-                  },
-                })
-              ),
-            },
-          }),
-        ]),
-      },
-    ],
-    default: [errorResponse],
-  },
-};
-
-export const updateRecord: EndpointSpec = {
-  path: "/{baseId}/{tableIdOrName}/{recordId}",
-  method: "PATCH",
-  metadata: {
-    name: "updateRecord",
-    description: `Updates a single record.`,
-    displayProperties: {
-      title:
-        "Update record ${parameters.recordId} for table ${parameters.tableIdOrName}",
-    },
-    externalDocs: {
-      description: "API method documentation",
-      url: "https://airtable.com/developers/web/api/update-record",
-    },
-    tags: ["records"],
-  },
-  security: {
-    oauth: ["data.records:write"],
-  },
-  parameters: [BaseIdParam, TableIdOrNameParam, RecordIdParam],
-  request: {
-    headers: {
-      "Content-Type": "application/json; charset=utf-8",
-    },
-    body: {
-      schema: makeObjectSchema("Update record body", {
-        optionalProperties: {
-          typecast: makeBooleanSchema(
-            "typecast",
-            "If set to true, Airtable will try to convert string values into the appropriate cell value. This conversion is only performed on a best-effort basis. To ensure your data's integrity, this should only be used when necessary. Defaults to false when unset."
-          ),
-        },
-        requiredProperties: {
-          fields: makeObjectSchema("Fields", {
-            additionalProperties: FieldSchema,
-          }),
-        },
-      }),
-    },
-  },
-  responses: {
-    200: [
-      {
-        success: true,
-        name: "Success",
-        description: "Typical success response",
-        schema: makeObjectSchema("Update record success body", {
-          requiredProperties: {
-            id: makeStringSchema("Record ID"),
-            createdTime: makeStringSchema(
-              "createdTime",
-              `A date timestamp in the ISO format, eg:"2018-01-01T00:00:00.000Z"`
-            ),
-            fields: makeObjectSchema("Fields", {
-              additionalProperties: FieldSchema,
-            }),
-          },
-        }),
-      },
-    ],
-    default: [errorResponse],
-  },
-};
-
-export const createRecords: EndpointSpec = {
-  path: "/{baseId}/{tableIdOrName}",
-  method: "POST",
-  metadata: {
-    name: "createRecords",
-    description: `Create up to 10 records`,
-    displayProperties: {
-      title: "Create records for table ${parameters.tableIdOrName}",
-    },
-    externalDocs: {
-      description: "API method documentation",
-      url: "https://airtable.com/developers/web/api/create-records",
-    },
-    tags: ["records"],
-  },
-  security: {
-    oauth: ["data.records:write"],
-  },
-  parameters: [BaseIdParam, TableIdOrNameParam],
-  request: {
-    headers: {
-      "Content-Type": "application/json; charset=utf-8",
-    },
-    body: {
-      schema: makeObjectSchema("Create records body", {
-        optionalProperties: {
-          typecast: makeBooleanSchema(
-            "typecast",
-            "If set to true, Airtable will try to convert string values into the appropriate cell value. This conversion is only performed on a best-effort basis. To ensure your data's integrity, this should only be used when necessary. Defaults to false when unset."
-          ),
-          fields: makeObjectSchema("Fields", {
-            additionalProperties: FieldSchema,
-          }),
-          records: makeArraySchema(
-            "Records to update/upsert",
-            makeObjectSchema("Record", {
-              requiredProperties: {
-                fields: makeObjectSchema("Fields", {
-                  additionalProperties: FieldSchema,
-                }),
-              },
-            })
-          ),
-        },
-      }),
-    },
-  },
-  responses: {
-    200: [
-      {
-        success: true,
-        name: "Success",
-        description: "Typical success response",
-        schema: makeAnyOf("Create records success body", [
-          makeObjectSchema("Multiple records created response", {
-            requiredProperties: {
-              records: makeArraySchema(
-                "Records",
-                makeObjectSchema("Record", {
-                  requiredProperties: {
-                    id: makeStringSchema("Record ID"),
-                    createdTime: makeStringSchema(
-                      "createdTime",
-                      `A date timestamp in the ISO format, eg:"2018-01-01T00:00:00.000Z"`
-                    ),
-                    fields: makeObjectSchema("Fields", {
-                      additionalProperties: FieldSchema,
-                    }),
-                  },
-                })
-              ),
-            },
-          }),
-          makeObjectSchema("Single record created response", {
-            requiredProperties: {
-              id: makeStringSchema("Record ID"),
-              createdTime: makeStringSchema(
-                "createdTime",
-                `A date timestamp in the ISO format, eg:"2018-01-01T00:00:00.000Z"`
-              ),
-              fields: makeObjectSchema("Fields", {
-                additionalProperties: FieldSchema,
-              }),
-            },
-          }),
-        ]),
-      },
-    ],
-    default: [errorResponse],
-  },
-};
-
-export const deleteRecords: EndpointSpec = {
-  path: "/{baseId}/{tableIdOrName}",
-  method: "DELETE",
-  metadata: {
-    name: "deleteRecords",
-    description: `Delete more than one records with the given record IDs. Note you can't delete a single record with this.`,
-    displayProperties: {
-      title: "Delete records for table ${parameters.tableIdOrName}",
-    },
-    externalDocs: {
-      description: "API method documentation",
-      url: "https://airtable.com/developers/web/api/delete-multiple-records",
-    },
-    tags: ["records"],
-  },
-  security: {
-    oauth: ["data.records:write"],
-  },
-  parameters: [
-    BaseIdParam,
-    TableIdOrNameParam,
-    {
-      name: "records",
-      in: "query",
-      description: "An array of record IDs to delete",
-      schema: makeArraySchema(
-        "Records to delete",
-        makeStringSchema("Record ID")
-      ),
-      required: true,
-    },
-  ],
-  request: {
-    headers: {
-      "Content-Type": "application/json; charset=utf-8",
-    },
-  },
-  responses: {
-    200: [
-      {
-        success: true,
-        name: "Success",
-        description: "Typical success response",
-        schema: makeObjectSchema("Delete records response", {
-          requiredProperties: {
-            records: makeArraySchema(
-              "Records",
-              makeObjectSchema("Deleted record", {
-                requiredProperties: {
-                  id: makeStringSchema("Record ID"),
-                  deleted: makeBooleanSchema(
-                    "deleted",
-                    "Whether the record was deleted",
-                    {
-                      enum: true,
-                    }
-                  ),
-                },
-              })
-            ),
-          },
-        }),
-      },
-    ],
-    default: [errorResponse],
-  },
-};
-
-export const deleteRecord: EndpointSpec = {
-  path: "/{baseId}/{tableIdOrName}/{recordId}",
-  method: "DELETE",
-  metadata: {
-    name: "deleteRecord",
-    description: `Delete a single record.`,
-    displayProperties: {
-      title:
-        "Delete record ${parameters.recordId} for table ${parameters.tableIdOrName}",
-    },
-    externalDocs: {
-      description: "API method documentation",
-      url: "https://airtable.com/developers/web/api/delete-record",
-    },
-    tags: ["records"],
-  },
-  security: {
-    oauth: ["data.records:write"],
-  },
-  parameters: [BaseIdParam, TableIdOrNameParam, RecordIdParam],
-  request: {
-    headers: {
-      "Content-Type": "application/json; charset=utf-8",
-    },
-  },
-  responses: {
-    200: [
-      {
-        success: true,
-        name: "Success",
-        description: "Typical success response",
-        schema: makeObjectSchema("Delete records response", {
-          requiredProperties: {
-            id: makeStringSchema("Record ID"),
-            deleted: makeBooleanSchema(
-              "deleted",
-              "Whether the record was deleted",
-              {
-                enum: true,
-              }
-            ),
-          },
-        }),
-      },
-    ],
-    default: [errorResponse],
-  },
-};

apps/integrations/src/integrations/airtable/index.ts

@@ -1,14 +0,0 @@
-import { Service } from "core/service/types";
-import { authentication } from "./authentication";
-import actions from "./actions/actions";
-
-export const airtable: Service = {
-  name: "Airtable",
-  service: "airtable",
-  version: "0.1.21",
-  baseUrl: "https://api.airtable.com/v0",
-  live: true,
-  authentication,
-  actions,
-  retryableStatusCodes: [408, 429, 500, 502, 503, 504],
-};

apps/integrations/src/integrations/airtable/tests/endpoints.test.ts

@@ -1,356 +0,0 @@
-import { startNock, stopNock } from "testing/nock";
-import { describe, expect, test } from "vitest";
-import endpoints from "../endpoints/endpoints";
-const authToken = () => process.env.AIRTABLE_TOKEN ?? "";
-
-describe("airtable.endpoints", async () => {
-  test("listRecords simple", async () => {
-    const accessToken = authToken();
-
-    const nockDone = await startNock("airtable.listRecords.simple");
-    const data = await endpoints.listRecords.request({
-      parameters: {
-        baseId: "appBlf3KsalIQeMUo",
-        tableIdOrName: "tblvXn2TOeVPC9c6m",
-      },
-      body: {},
-      credentials: {
-        type: "oauth2",
-        name: "oauth",
-        accessToken,
-        scopes: ["data.records:read"],
-      },
-    });
-
-    expect(data.status).toEqual(200);
-    expect(data.success).toEqual(true);
-    expect(data.body).not.toBeNull();
-    stopNock(nockDone);
-  });
-
-  test("listRecords advanced", async () => {
-    const accessToken = authToken();
-
-    const nockDone = await startNock("airtable.listRecords.advanced");
-    const data = await endpoints.listRecords.request({
-      parameters: {
-        baseId: "appBlf3KsalIQeMUo",
-        tableIdOrName: "tblvXn2TOeVPC9c6m",
-      },
-      body: {
-        timeZone: "America/Los_Angeles",
-        userLocale: "en",
-        sort: [
-          {
-            field: "Employee",
-            direction: "asc",
-          },
-        ],
-        fields: ["Employee"],
-      },
-      credentials: {
-        type: "oauth2",
-        name: "oauth",
-        accessToken,
-        scopes: ["data.records:read"],
-      },
-    });
-
-    expect(data.status).toEqual(200);
-    expect(data.success).toEqual(true);
-    expect(data.body).not.toBeNull();
-    stopNock(nockDone);
-  });
-
-  test("getRecord", async () => {
-    const accessToken = authToken();
-
-    const nockDone = await startNock("airtable.getRecord");
-    const data = await endpoints.getRecord.request({
-      parameters: {
-        baseId: "appBlf3KsalIQeMUo",
-        tableIdOrName: "tblvXn2TOeVPC9c6m",
-        recordId: "recHcnB1MbBr9Rd2P",
-      },
-      credentials: {
-        type: "oauth2",
-        name: "oauth",
-        accessToken,
-        scopes: ["data.records:read"],
-      },
-    });
-
-    expect(data.status).toEqual(200);
-    expect(data.success).toEqual(true);
-    expect(data.body).not.toBeNull();
-    stopNock(nockDone);
-  });
-
-  test("updateRecords", async () => {
-    const accessToken = authToken();
-
-    const nockDone = await startNock("airtable.updateRecords");
-    const data = await endpoints.updateRecords.request({
-      parameters: {
-        baseId: "appBlf3KsalIQeMUo",
-        tableIdOrName: "tblvXn2TOeVPC9c6m",
-      },
-      body: {
-        records: [
-          {
-            id: "recHcnB1MbBr9Rd2P",
-            fields: {
-              Employee: "John Doe",
-            },
-          },
-        ],
-      },
-      credentials: {
-        type: "oauth2",
-        name: "oauth",
-        accessToken,
-        scopes: ["data.records:write"],
-      },
-    });
-
-    expect(data.status).toEqual(200);
-    expect(data.success).toEqual(true);
-    expect(data.body).not.toBeNull();
-    stopNock(nockDone);
-  });
-
-  test("upsertRecords", async () => {
-    const accessToken = authToken();
-
-    const nockDone = await startNock("airtable.upsertRecords");
-    const data = await endpoints.updateRecords.request({
-      parameters: {
-        baseId: "appBlf3KsalIQeMUo",
-        tableIdOrName: "tblvXn2TOeVPC9c6m",
-      },
-      body: {
-        performUpsert: {
-          fieldsToMergeOn: ["Employee"],
-        },
-        records: [
-          {
-            fields: {
-              Employee: "John Doe",
-            },
-          },
-          {
-            fields: {
-              Employee: "Jane Doe",
-            },
-          },
-        ],
-      },
-      credentials: {
-        type: "oauth2",
-        name: "oauth",
-        accessToken,
-        scopes: ["data.records:write"],
-      },
-    });
-
-    expect(data.status).toEqual(200);
-    expect(data.success).toEqual(true);
-    expect(data.body).not.toBeNull();
-    stopNock(nockDone);
-  });
-
-  test("updateRecord", async () => {
-    const accessToken = authToken();
-
-    const nockDone = await startNock("airtable.updateRecord");
-    const data = await endpoints.updateRecord.request({
-      parameters: {
-        baseId: "appBlf3KsalIQeMUo",
-        tableIdOrName: "tblvXn2TOeVPC9c6m",
-        recordId: "recHcnB1MbBr9Rd2P",
-      },
-      body: {
-        fields: {
-          Employee: "John Doe II",
-        },
-      },
-      credentials: {
-        type: "oauth2",
-        name: "oauth",
-        accessToken,
-        scopes: ["data.records:write"],
-      },
-    });
-
-    expect(data.status).toEqual(200);
-    expect(data.success).toEqual(true);
-    expect(data.body).not.toBeNull();
-    stopNock(nockDone);
-  });
-
-  test("createRecords", async () => {
-    const accessToken = authToken();
-
-    const nockDone = await startNock("airtable.createRecords");
-    const data = await endpoints.createRecords.request({
-      parameters: {
-        baseId: "appBlf3KsalIQeMUo",
-        tableIdOrName: "tblvXn2TOeVPC9c6m",
-      },
-      body: {
-        records: [
-          {
-            fields: {
-              Employee: "Employee #1",
-            },
-          },
-          {
-            fields: {
-              Employee: "Employee #2",
-            },
-          },
-        ],
-      },
-      credentials: {
-        type: "oauth2",
-        name: "oauth",
-        accessToken,
-        scopes: ["data.records:write"],
-      },
-    });
-
-    expect(data.status).toEqual(200);
-    expect(data.success).toEqual(true);
-    expect(data.body).not.toBeNull();
-    stopNock(nockDone);
-  });
-
-  test("createRecord", async () => {
-    const accessToken = authToken();
-
-    const nockDone = await startNock("airtable.createRecord");
-    const data = await endpoints.createRecords.request({
-      parameters: {
-        baseId: "appBlf3KsalIQeMUo",
-        tableIdOrName: "tblvXn2TOeVPC9c6m",
-      },
-      body: {
-        fields: {
-          Employee: "Employee single create",
-        },
-      },
-      credentials: {
-        type: "oauth2",
-        name: "oauth",
-        accessToken,
-        scopes: ["data.records:write"],
-      },
-    });
-
-    expect(data.status).toEqual(200);
-    expect(data.success).toEqual(true);
-    expect(data.body).not.toBeNull();
-    stopNock(nockDone);
-  });
-
-  test("deleteRecords", async () => {
-    const accessToken = authToken();
-
-    const nockDone = await startNock("airtable.deleteRecords");
-    const data = await endpoints.createRecords.request({
-      parameters: {
-        baseId: "appBlf3KsalIQeMUo",
-        tableIdOrName: "tblvXn2TOeVPC9c6m",
-      },
-      body: {
-        records: [
-          {
-            fields: {
-              Employee: "Delete now #1",
-            },
-          },
-          {
-            fields: {
-              Employee: "Delete now #2",
-            },
-          },
-        ],
-      },
-      credentials: {
-        type: "oauth2",
-        name: "oauth",
-        accessToken,
-        scopes: ["data.records:write"],
-      },
-    });
-
-    expect(data.status).toEqual(200);
-    expect(data.success).toEqual(true);
-    expect(data.body).not.toBeNull();
-
-    const deletedData = await endpoints.deleteRecords.request({
-      parameters: {
-        baseId: "appBlf3KsalIQeMUo",
-        tableIdOrName: "tblvXn2TOeVPC9c6m",
-        records: data.body.records.map((record: any) => record.id),
-      },
-      credentials: {
-        type: "oauth2",
-        name: "oauth",
-        accessToken,
-        scopes: ["data.records:write"],
-      },
-    });
-
-    expect(deletedData.status).toEqual(200);
-    expect(deletedData.success).toEqual(true);
-    expect(deletedData.body).not.toBeNull();
-    stopNock(nockDone);
-  });
-
-  test("deleteRecord", async () => {
-    const accessToken = authToken();
-
-    const nockDone = await startNock("airtable.deleteRecord");
-    const data = await endpoints.createRecords.request({
-      parameters: {
-        baseId: "appBlf3KsalIQeMUo",
-        tableIdOrName: "tblvXn2TOeVPC9c6m",
-      },
-      body: {
-        fields: {
-          Employee: "Delete now #3",
-        },
-      },
-      credentials: {
-        type: "oauth2",
-        name: "oauth",
-        accessToken,
-        scopes: ["data.records:write"],
-      },
-    });
-
-    expect(data.status).toEqual(200);
-    expect(data.success).toEqual(true);
-    expect(data.body).not.toBeNull();
-
-    const deletedData = await endpoints.deleteRecord.request({
-      parameters: {
-        baseId: "appBlf3KsalIQeMUo",
-        tableIdOrName: "tblvXn2TOeVPC9c6m",
-        recordId: data.body.id,
-      },
-      credentials: {
-        type: "oauth2",
-        name: "oauth",
-        accessToken,
-        scopes: ["data.records:write"],
-      },
-    });
-
-    expect(deletedData.status).toEqual(200);
-    expect(deletedData.success).toEqual(true);
-    expect(deletedData.body).not.toBeNull();
-    stopNock(nockDone);
-  });
-});

apps/integrations/src/integrations/catalog.ts

@@ -1,10 +0,0 @@
-import { Catalog } from "core/catalog";
-import { airtable } from "./airtable";
-import { sendgrid } from "./sendgrid";
-
-export const catalog: Catalog = {
-  services: {
-    airtable,
-    sendgrid,
-  },
-};

apps/integrations/src/integrations/sendgrid/actions/actions.ts

@@ -1,5 +0,0 @@
-import { makeSimpleActions } from "core/action/makeAction";
-import endpoints from "../endpoints/endpoints";
-
-const actions = makeSimpleActions(endpoints);
-export default actions;