Latest lockfile

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

apps/yalt/package.json

@@ -9,7 +9,7 @@
   },
   "devDependencies": {
     "@cloudflare/workers-types": "~4.20231121.0",
-    "wrangler": "^3.20.0"
+    "wrangler": "^3.21.0"
   },
   "dependencies": {
     "@trigger.dev/yalt": "workspace:*"

apps/yalt/src/index.ts

@@ -51,8 +51,9 @@ type RouteDecision =
 	| { type: 'not_found' };
 
 function routeUrl(url: URL, env: Env): RouteDecision {
-	if (url.host.startsWith('localhost:')) {
-		const searchParams = new URLSearchParams(url.search);
+	const searchParams = new URLSearchParams(url.search);
+
+	if (searchParams.has('t')) {
 		const name = searchParams.get('t');
 
 		if (name) {

apps/yalt/wrangler.toml

@@ -2,6 +2,7 @@ name = "yalt"
 main = "src/index.ts"
 compatibility_date = "2023-12-06"
 workers_dev = false
+logpush = true
 
 routes = [
   { pattern = "*.yalt.dev/*", zone_name = "yalt.dev" },

integrations/airtable/CHANGELOG.md

@@ -1,5 +1,12 @@
 # @trigger.dev/airtable
 
+## 2.3.7
+
+### Patch Changes
+
+- @trigger.dev/integration-kit@2.3.7
+- @trigger.dev/sdk@2.3.7
+
 ## 2.3.6
 
 ### Patch Changes

integrations/airtable/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@trigger.dev/airtable",
-  "version": "2.3.6",
+  "version": "2.3.7",
   "description": "Trigger.dev integration for airtable",
   "main": "./dist/index.js",
   "types": "./dist/index.d.ts",
@@ -25,8 +25,8 @@
     "typecheck": "tsc --noEmit"
   },
   "dependencies": {
-    "@trigger.dev/integration-kit": "workspace:^2.3.6",
-    "@trigger.dev/sdk": "workspace:^2.3.6",
+    "@trigger.dev/integration-kit": "workspace:^2.3.7",
+    "@trigger.dev/sdk": "workspace:^2.3.7",
     "airtable": "^0.12.1",
     "zod": "3.22.3"
   },

integrations/github/CHANGELOG.md

@@ -1,5 +1,12 @@
 # @trigger.dev/github
 
+## 2.3.7
+
+### Patch Changes
+
+- @trigger.dev/integration-kit@2.3.7
+- @trigger.dev/sdk@2.3.7
+
 ## 2.3.6
 
 ### Patch Changes

integrations/github/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@trigger.dev/github",
-  "version": "2.3.6",
+  "version": "2.3.7",
   "description": "The official GitHub integration for Trigger.dev",
   "main": "./dist/index.js",
   "types": "./dist/index.d.ts",
@@ -29,8 +29,8 @@
     "@octokit/request": "^6.2.5",
     "@octokit/request-error": "^4.0.1",
     "@octokit/webhooks": "^10.4.0",
-    "@trigger.dev/integration-kit": "workspace:^2.3.6",
-    "@trigger.dev/sdk": "workspace:^2.3.6",
+    "@trigger.dev/integration-kit": "workspace:^2.3.7",
+    "@trigger.dev/sdk": "workspace:^2.3.7",
     "octokit": "^2.0.14",
     "zod": "3.22.3"
   },

integrations/linear/CHANGELOG.md

@@ -1,5 +1,12 @@
 # @trigger.dev/linear
 
+## 2.3.7
+
+### Patch Changes
+
+- @trigger.dev/integration-kit@2.3.7
+- @trigger.dev/sdk@2.3.7
+
 ## 2.3.6
 
 ### Patch Changes

integrations/linear/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@trigger.dev/linear",
-  "version": "2.3.6",
+  "version": "2.3.7",
   "description": "Trigger.dev integration for @linear/sdk",
   "main": "./dist/index.js",
   "types": "./dist/index.d.ts",
@@ -26,8 +26,8 @@
   },
   "dependencies": {
     "@linear/sdk": "^8.0.0",
-    "@trigger.dev/integration-kit": "workspace:^2.3.6",
-    "@trigger.dev/sdk": "workspace:^2.3.6",
+    "@trigger.dev/integration-kit": "workspace:^2.3.7",
+    "@trigger.dev/sdk": "workspace:^2.3.7",
     "zod": "3.22.3"
   },
   "engines": {

integrations/openai/CHANGELOG.md

@@ -1,5 +1,13 @@
 # @trigger.dev/slack
 
+## 2.3.7
+
+### Patch Changes
+
+- 771feb53: Awaiting completion with threads/runs now works with the "requires_action" status
+  - @trigger.dev/integration-kit@2.3.7
+  - @trigger.dev/sdk@2.3.7
+
 ## 2.3.6
 
 ### Patch Changes

integrations/openai/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@trigger.dev/openai",
-  "version": "2.3.6",
+  "version": "2.3.7",
   "description": "The official OpenAI integration for Trigger.dev",
   "main": "./dist/index.js",
   "types": "./dist/index.d.ts",
@@ -42,8 +42,8 @@
   },
   "dependencies": {
     "openai": "^4.16.1",
-    "@trigger.dev/sdk": "workspace:^2.3.6",
-    "@trigger.dev/integration-kit": "workspace:^2.3.6"
+    "@trigger.dev/sdk": "workspace:^2.3.7",
+    "@trigger.dev/integration-kit": "workspace:^2.3.7"
   },
   "engines": {
     "node": ">=18.0.0"

integrations/openai/src/threads.ts

@@ -16,7 +16,7 @@ export class Threads {
   constructor(
     private runTask: OpenAIRunTask,
     private options: OpenAIIntegrationOptions
-  ) { }
+  ) {}
 
   /**
    * Create a thread and run it in one task.
@@ -113,7 +113,7 @@ export class Threads {
           responseFilter: {
             status: [200],
             body: {
-              status: ["completed", "expired", "cancelled", "failed"],
+              status: ["completed", "expired", "cancelled", "failed", "requires_action"],
             },
           },
         });
@@ -262,7 +262,7 @@ class Runs {
   constructor(
     private runTask: OpenAIRunTask,
     private options: OpenAIIntegrationOptions
-  ) { }
+  ) {}
 
   /**
    * Creates a run and waits for it to complete by polling in the background.
@@ -306,7 +306,7 @@ class Runs {
           responseFilter: {
             status: [200],
             body: {
-              status: ["completed", "expired", "cancelled", "failed"],
+              status: ["completed", "expired", "cancelled", "failed", "requires_action"],
             },
           },
         });
@@ -355,7 +355,7 @@ class Runs {
           responseFilter: {
             status: [200],
             body: {
-              status: ["completed", "expired", "cancelled", "failed"],
+              status: ["completed", "expired", "cancelled", "failed", "requires_action"],
             },
           },
         });
@@ -552,7 +552,7 @@ class Messages {
   constructor(
     private runTask: OpenAIRunTask,
     private options: OpenAIIntegrationOptions
-  ) { }
+  ) {}
 
   /**
    * Returns messages for a given thread.
@@ -562,12 +562,12 @@ class Messages {
     threadId: string,
     params?: Prettify<OpenAI.Beta.Threads.MessageListParams>,
     options?: OpenAIRequestOptions
-  ): Promise<OpenAI.Beta.Threads.ThreadMessage[]>
+  ): Promise<OpenAI.Beta.Threads.ThreadMessage[]>;
   list(
     key: IntegrationTaskKey,
     threadId: string,
     options?: OpenAIRequestOptions
-  ): Promise<OpenAI.Beta.Threads.ThreadMessage[]>
+  ): Promise<OpenAI.Beta.Threads.ThreadMessage[]>;
   async list(
     key: IntegrationTaskKey,
     threadId: string,
@@ -615,7 +615,7 @@ class Messages {
   async listAll(
     key: IntegrationTaskKey,
     threadId: string,
-    options: OpenAIRequestOptions = {},
+    options: OpenAIRequestOptions = {}
   ): Promise<OpenAI.Beta.Threads.ThreadMessage[]> {
     return this.runTask(
       key,

integrations/plain/CHANGELOG.md

@@ -1,5 +1,12 @@
 # @trigger.dev/plain
 
+## 2.3.7
+
+### Patch Changes
+
+- @trigger.dev/integration-kit@2.3.7
+- @trigger.dev/sdk@2.3.7
+
 ## 2.3.6
 
 ### Patch Changes

integrations/plain/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@trigger.dev/plain",
-  "version": "2.3.6",
+  "version": "2.3.7",
   "description": "The official Plain.com integration for Trigger.dev",
   "main": "./dist/index.js",
   "types": "./dist/index.d.ts",
@@ -24,8 +24,8 @@
     "build:tsup": "tsup"
   },
   "dependencies": {
-    "@trigger.dev/integration-kit": "workspace:^2.3.6",
-    "@trigger.dev/sdk": "workspace:^2.3.6",
+    "@trigger.dev/integration-kit": "workspace:^2.3.7",
+    "@trigger.dev/sdk": "workspace:^2.3.7",
     "@team-plain/typescript-sdk": "^2.7.0"
   },
   "engines": {

integrations/replicate/CHANGELOG.md

@@ -1,5 +1,12 @@
 # @trigger.dev/replicate
 
+## 2.3.7
+
+### Patch Changes
+
+- @trigger.dev/integration-kit@2.3.7
+- @trigger.dev/sdk@2.3.7
+
 ## 2.3.6
 
 ### Patch Changes

integrations/replicate/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@trigger.dev/replicate",
-  "version": "2.3.6",
+  "version": "2.3.7",
   "description": "Trigger.dev integration for replicate",
   "main": "./dist/index.js",
   "types": "./dist/index.d.ts",
@@ -25,8 +25,8 @@
     "typecheck": "tsc --noEmit"
   },
   "dependencies": {
-    "@trigger.dev/integration-kit": "workspace:^2.3.6",
-    "@trigger.dev/sdk": "workspace:^2.3.6",
+    "@trigger.dev/integration-kit": "workspace:^2.3.7",
+    "@trigger.dev/sdk": "workspace:^2.3.7",
     "replicate": "^0.18.1",
     "zod": "3.22.3"
   },

integrations/resend/CHANGELOG.md

@@ -1,5 +1,12 @@
 # @trigger.dev/resend
 
+## 2.3.7
+
+### Patch Changes
+
+- @trigger.dev/integration-kit@2.3.7
+- @trigger.dev/sdk@2.3.7
+
 ## 2.3.6
 
 ### Patch Changes

integrations/resend/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@trigger.dev/resend",
-  "version": "2.3.6",
+  "version": "2.3.7",
   "description": "The official Resend.com integration for Trigger.dev",
   "main": "./dist/index.js",
   "types": "./dist/index.d.ts",
@@ -24,8 +24,8 @@
     "build:tsup": "tsup"
   },
   "dependencies": {
-    "@trigger.dev/integration-kit": "workspace:^2.3.6",
-    "@trigger.dev/sdk": "workspace:^2.3.6",
+    "@trigger.dev/integration-kit": "workspace:^2.3.7",
+    "@trigger.dev/sdk": "workspace:^2.3.7",
     "resend": "^2.0.0"
   },
   "engines": {

integrations/sendgrid/CHANGELOG.md

@@ -1,5 +1,12 @@
 # @trigger.dev/sendgrid
 
+## 2.3.7
+
+### Patch Changes
+
+- @trigger.dev/integration-kit@2.3.7
+- @trigger.dev/sdk@2.3.7
+
 ## 2.3.6
 
 ### Patch Changes

integrations/sendgrid/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@trigger.dev/sendgrid",
-  "version": "2.3.6",
+  "version": "2.3.7",
   "description": "Trigger.dev integration for @sendgrid/mail",
   "main": "./dist/index.js",
   "types": "./dist/index.d.ts",
@@ -26,8 +26,8 @@
   },
   "dependencies": {
     "@sendgrid/mail": "^7.7.0",
-    "@trigger.dev/sdk": "workspace:^2.3.6",
-    "@trigger.dev/integration-kit": "workspace:^2.3.6"
+    "@trigger.dev/sdk": "workspace:^2.3.7",
+    "@trigger.dev/integration-kit": "workspace:^2.3.7"
   },
   "engines": {
     "node": ">=16.8.0"

integrations/shopify/CHANGELOG.md

@@ -1,5 +1,12 @@
 # @trigger.dev/shopify
 
+## 2.3.7
+
+### Patch Changes
+
+- @trigger.dev/integration-kit@2.3.7
+- @trigger.dev/sdk@2.3.7
+
 ## 2.3.6
 
 ### Patch Changes

integrations/shopify/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@trigger.dev/shopify",
-  "version": "2.3.6",
+  "version": "2.3.7",
   "description": "Trigger.dev integration for @shopify/shopify-api",
   "main": "./dist/index.js",
   "types": "./dist/index.d.ts",
@@ -26,8 +26,8 @@
   },
   "dependencies": {
     "@shopify/shopify-api": "^8.0.2",
-    "@trigger.dev/sdk": "workspace:^2.3.6",
-    "@trigger.dev/integration-kit": "workspace:^2.3.6",
+    "@trigger.dev/sdk": "workspace:^2.3.7",
+    "@trigger.dev/integration-kit": "workspace:^2.3.7",
     "zod": "3.22.3"
   },
   "engines": {

integrations/slack/CHANGELOG.md

@@ -1,5 +1,11 @@
 # @trigger.dev/slack
 
+## 2.3.7
+
+### Patch Changes
+
+- @trigger.dev/sdk@2.3.7
+
 ## 2.3.6
 
 ### Patch Changes

integrations/slack/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@trigger.dev/slack",
-  "version": "2.3.6",
+  "version": "2.3.7",
   "description": "The official Slack integration for Trigger.dev",
   "main": "./dist/index.js",
   "types": "./dist/index.d.ts",
@@ -25,7 +25,7 @@
   },
   "dependencies": {
     "@slack/web-api": "^6.8.1",
-    "@trigger.dev/sdk": "workspace:^2.3.6",
+    "@trigger.dev/sdk": "workspace:^2.3.7",
     "zod": "3.22.3"
   },
   "engines": {

integrations/stripe/CHANGELOG.md

@@ -1,5 +1,12 @@
 # @trigger.dev/stripe
 
+## 2.3.7
+
+### Patch Changes
+
+- @trigger.dev/integration-kit@2.3.7
+- @trigger.dev/sdk@2.3.7
+
 ## 2.3.6
 
 ### Patch Changes

integrations/stripe/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@trigger.dev/stripe",
-  "version": "2.3.6",
+  "version": "2.3.7",
   "description": "Trigger.dev integration for stripe",
   "main": "./dist/index.js",
   "types": "./dist/index.d.ts",
@@ -25,8 +25,8 @@
     "typecheck": "tsc --noEmit"
   },
   "dependencies": {
-    "@trigger.dev/integration-kit": "workspace:^2.3.6",
-    "@trigger.dev/sdk": "workspace:^2.3.6",
+    "@trigger.dev/integration-kit": "workspace:^2.3.7",
+    "@trigger.dev/sdk": "workspace:^2.3.7",
     "stripe": "^12.14.0",
     "zod": "3.22.3"
   },

integrations/supabase/CHANGELOG.md

@@ -1,5 +1,12 @@
 # @trigger.dev/supabase
 
+## 2.3.7
+
+### Patch Changes
+
+- @trigger.dev/integration-kit@2.3.7
+- @trigger.dev/sdk@2.3.7
+
 ## 2.3.6
 
 ### Patch Changes

integrations/supabase/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@trigger.dev/supabase",
-  "version": "2.3.6",
+  "version": "2.3.7",
   "description": "Trigger.dev integration for @supabase/supabase-js",
   "main": "./dist/index.js",
   "types": "./dist/index.d.ts",
@@ -26,8 +26,8 @@
   },
   "dependencies": {
     "@supabase/supabase-js": "^2.26.0",
-    "@trigger.dev/integration-kit": "workspace:^2.3.6",
-    "@trigger.dev/sdk": "workspace:^2.3.6",
+    "@trigger.dev/integration-kit": "workspace:^2.3.7",
+    "@trigger.dev/sdk": "workspace:^2.3.7",
     "supabase-management-js": "^1.0.0",
     "zod": "3.22.3"
   },

integrations/typeform/CHANGELOG.md

@@ -1,5 +1,12 @@
 # @trigger.dev/typeform
 
+## 2.3.7
+
+### Patch Changes
+
+- @trigger.dev/integration-kit@2.3.7
+- @trigger.dev/sdk@2.3.7
+
 ## 2.3.6
 
 ### Patch Changes

integrations/typeform/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@trigger.dev/typeform",
-  "version": "2.3.6",
+  "version": "2.3.7",
   "description": "The official Typeform integration for Trigger.dev",
   "main": "./dist/index.js",
   "types": "./dist/index.d.ts",
@@ -24,8 +24,8 @@
     "typecheck": "tsc --noEmit"
   },
   "dependencies": {
-    "@trigger.dev/integration-kit": "workspace:^2.3.6",
-    "@trigger.dev/sdk": "workspace:^2.3.6",
+    "@trigger.dev/integration-kit": "workspace:^2.3.7",
+    "@trigger.dev/sdk": "workspace:^2.3.7",
     "@typeform/api-client": "^1.8.0",
     "zod": "3.22.3"
   },

packages/astro/CHANGELOG.md

@@ -1,5 +1,11 @@
 # @trigger.dev/astro
 
+## 2.3.7
+
+### Patch Changes
+
+- @trigger.dev/sdk@2.3.7
+
 ## 2.3.6
 
 ### Patch Changes

packages/astro/package.json

@@ -1,7 +1,7 @@
 {
   "name": "@trigger.dev/astro",
   "description": "An Astro-native integration for Trigger.dev background jobs platform",
-  "version": "2.3.6",
+  "version": "2.3.7",
   "main": "./dist/index.js",
   "types": "./dist/index.d.ts",
   "files": [
@@ -20,7 +20,7 @@
     "build:tsup": "tsup"
   },
   "peerDependencies": {
-    "@trigger.dev/sdk": "workspace:^2.3.6"
+    "@trigger.dev/sdk": "workspace:^2.3.7"
   },
   "devDependencies": {
     "astro": "^3.0.12",

packages/cli/CHANGELOG.md

@@ -1,5 +1,14 @@
 # create-trigger
 
+## 2.3.7
+
+### Patch Changes
+
+- dfa47b62: Don't proxy certain headers across the Yalt boundary as it can mess-up proxied local requests
+- Updated dependencies [dfa47b62]
+  - @trigger.dev/yalt@2.3.7
+  - @trigger.dev/core@2.3.7
+
 ## 2.3.6
 
 ### Patch Changes

packages/cli/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@trigger.dev/cli",
-  "version": "2.3.6",
+  "version": "2.3.7",
   "description": "The Trigger.dev CLI",
   "main": "./dist/index.js",
   "types": "./dist/index.d.ts",

packages/cli/src/commands/dev.ts

@@ -516,11 +516,16 @@ async function createNativeTunnel(
     // import WS dynamically
     const WebSocket = await import("ws");
 
-    yaltTunnel = new YaltTunnel(response.url, `${hostname}:${port}`, {
-      WebSocket: WebSocket.default,
-      connectionTimeout: 1000,
-      maxRetries: 10,
-    });
+    yaltTunnel = new YaltTunnel(
+      response.url,
+      `${hostname}:${port}`,
+      {
+        WebSocket: WebSocket.default,
+        connectionTimeout: 1000,
+        maxRetries: 10,
+      },
+      { verbose: process.env.TUNNEL_VERBOSE === "1" }
+    );
 
     await yaltTunnel.connect();
 

packages/core-backend/CHANGELOG.md

@@ -1,5 +1,7 @@
 # @trigger.dev/core-backend
 
+## 2.3.7
+
 ## 2.3.6
 
 ## 2.3.5

packages/core-backend/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@trigger.dev/core-backend",
-  "version": "2.3.6",
+  "version": "2.3.7",
   "description": "Core code used across `@trigger.dev/sdk` and Trigger.dev server",
   "license": "MIT",
   "main": "./dist/index.js",

packages/core/CHANGELOG.md

@@ -1,5 +1,7 @@
 # internal-platform
 
+## 2.3.7
+
 ## 2.3.6
 
 ## 2.3.5

packages/core/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@trigger.dev/core",
-  "version": "2.3.6",
+  "version": "2.3.7",
   "description": "Core code used across the Trigger.dev SDK and platform",
   "license": "MIT",
   "main": "./dist/index.js",

packages/core/src/searchParams.ts

@@ -8,7 +8,9 @@ export function urlWithSearchParams(
 
   const urlObj = new URL(url);
   for (const [key, value] of Object.entries(params)) {
-    urlObj.searchParams.append(key, String(value));
+    if (value !== undefined) {
+      urlObj.searchParams.append(key, String(value));
+    }
   }
   return urlObj.toString();
 }

packages/eslint-plugin/CHANGELOG.md

@@ -1,5 +1,7 @@
 # @trigger.dev/eslint-plugin
 
+## 2.3.7
+
 ## 2.3.6
 
 ## 2.3.5

packages/eslint-plugin/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@trigger.dev/eslint-plugin",
-  "version": "2.3.6",
+  "version": "2.3.7",
   "description": "ESLint plugin with trigger.dev best practices",
   "keywords": [
     "eslint",

packages/express/CHANGELOG.md

@@ -1,5 +1,11 @@
 # @trigger.dev/express
 
+## 2.3.7
+
+### Patch Changes
+
+- @trigger.dev/sdk@2.3.7
+
 ## 2.3.6
 
 ### Patch Changes

packages/express/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@trigger.dev/express",
-  "version": "2.3.6",
+  "version": "2.3.7",
   "description": "Official Express adapter for Trigger.dev",
   "license": "MIT",
   "main": "./dist/index.js",
@@ -23,7 +23,7 @@
     "./package.json": "./package.json"
   },
   "devDependencies": {
-    "@trigger.dev/sdk": "workspace:^2.3.6",
+    "@trigger.dev/sdk": "workspace:^2.3.7",
     "@trigger.dev/tsconfig": "workspace:*",
     "@types/debug": "^4.1.7",
     "@types/express": "^4.17.13",
@@ -39,7 +39,7 @@
     "build:tsup": "tsup"
   },
   "peerDependencies": {
-    "@trigger.dev/sdk": "workspace:^2.3.6"
+    "@trigger.dev/sdk": "workspace:^2.3.7"
   },
   "dependencies": {
     "debug": "^4.3.4",

packages/hono/CHANGELOG.md

@@ -1,5 +1,11 @@
 # @trigger.dev/hono
 
+## 2.3.7
+
+### Patch Changes
+
+- @trigger.dev/sdk@2.3.7
+
 ## 2.3.6
 
 ### Patch Changes

packages/hono/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@trigger.dev/hono",
-  "version": "2.3.6",
+  "version": "2.3.7",
   "description": "A Trigger.dev adapter for Hono.dev",
   "license": "MIT",
   "main": "./dist/index.js",
@@ -32,7 +32,7 @@
   },
   "peerDependencies": {
     "hono": "3.x",
-    "@trigger.dev/sdk": "workspace:^2.3.6"
+    "@trigger.dev/sdk": "workspace:^2.3.7"
   },
   "devDependencies": {
     "@trigger.dev/tsconfig": "workspace:*",

packages/integration-kit/CHANGELOG.md

@@ -1,5 +1,11 @@
 # @trigger.dev/integration-kit
 
+## 2.3.7
+
+### Patch Changes
+
+- @trigger.dev/core@2.3.7
+
 ## 2.3.6
 
 ### Patch Changes

packages/integration-kit/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@trigger.dev/integration-kit",
-  "version": "2.3.6",
+  "version": "2.3.7",
   "description": "Trigger.dev Integration Kit has helpers to make creating integrations easier",
   "license": "MIT",
   "main": "./dist/index.js",

packages/nestjs/CHANGELOG.md

@@ -1,5 +1,11 @@
 # @trigger.dev/nestjs
 
+## 2.3.7
+
+### Patch Changes
+
+- @trigger.dev/sdk@2.3.7
+
 ## 2.3.6
 
 ### Patch Changes

packages/nestjs/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@trigger.dev/nestjs",
-  "version": "2.3.6",
+  "version": "2.3.7",
   "description": "Official NestJS adapter for Trigger.dev",
   "license": "MIT",
   "main": "./dist/index.js",
@@ -23,7 +23,7 @@
     "./package.json": "./package.json"
   },
   "devDependencies": {
-    "@trigger.dev/sdk": "workspace:^2.3.6",
+    "@trigger.dev/sdk": "workspace:^2.3.7",
     "@trigger.dev/tsconfig": "workspace:*",
     "@types/debug": "^4.1.7",
     "@types/express": "^4.17.13",
@@ -41,7 +41,7 @@
   },
   "peerDependencies": {
     "@nestjs/common": ">=10.0.0",
-    "@trigger.dev/sdk": "workspace:^2.3.6"
+    "@trigger.dev/sdk": "workspace:^2.3.7"
   },
   "dependencies": {
     "@nestjs/common": "^10.2.4",

packages/nextjs/CHANGELOG.md

@@ -1,5 +1,11 @@
 # @trigger.dev/nextjs
 
+## 2.3.7
+
+### Patch Changes
+
+- @trigger.dev/sdk@2.3.7
+
 ## 2.3.6
 
 ### Patch Changes

packages/nextjs/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@trigger.dev/nextjs",
-  "version": "2.3.6",
+  "version": "2.3.7",
   "description": "Trigger.dev Next.js integration",
   "license": "MIT",
   "main": "./dist/index.js",
@@ -41,7 +41,7 @@
     "build:tsup": "tsup"
   },
   "peerDependencies": {
-    "@trigger.dev/sdk": "workspace:^2.3.6",
+    "@trigger.dev/sdk": "workspace:^2.3.7",
     "next": ">=12.0.0"
   },
   "dependencies": {

packages/react/CHANGELOG.md

@@ -1,5 +1,11 @@
 # @trigger.dev/react
 
+## 2.3.7
+
+### Patch Changes
+
+- @trigger.dev/core@2.3.7
+
 ## 2.3.6
 
 ### Patch Changes

packages/react/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@trigger.dev/react",
-  "version": "2.3.6",
+  "version": "2.3.7",
   "description": "Trigger.dev React SDK",
   "license": "MIT",
   "types": "dist/index.d.ts",
@@ -27,7 +27,7 @@
   },
   "dependencies": {
     "@tanstack/react-query": "5.0.0-beta.2",
-    "@trigger.dev/core": "workspace:^2.3.6",
+    "@trigger.dev/core": "workspace:^2.3.7",
     "debug": "^4.3.4",
     "zod": "3.22.3"
   },

packages/remix/CHANGELOG.md

@@ -1,5 +1,11 @@
 # @trigger.dev/remix
 
+## 2.3.7
+
+### Patch Changes
+
+- @trigger.dev/sdk@2.3.7
+
 ## 2.3.6
 
 ### Patch Changes

packages/remix/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@trigger.dev/remix",
-  "version": "2.3.6",
+  "version": "2.3.7",
   "description": "Trigger.dev Remix integration",
   "license": "MIT",
   "main": "./dist/index.js",
@@ -39,7 +39,7 @@
     "build:tsup": "tsup"
   },
   "peerDependencies": {
-    "@trigger.dev/sdk": "workspace:^2.3.6",
+    "@trigger.dev/sdk": "workspace:^2.3.7",
     "@remix-run/server-runtime": ">1.19.0"
   },
   "dependencies": {

packages/sveltekit/CHANGELOG.md

@@ -1,5 +1,11 @@
 # @trigger.dev/sveltekit
 
+## 2.3.7
+
+### Patch Changes
+
+- @trigger.dev/sdk@2.3.7
+
 ## 2.3.6
 
 ### Patch Changes

packages/sveltekit/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@trigger.dev/sveltekit",
-  "version": "2.3.6",
+  "version": "2.3.7",
   "description": "Trigger.dev svelteKit integration",
   "license": "MIT",
   "main": "./dist/index.js",
@@ -39,7 +39,7 @@
     "build:tsup": "tsup"
   },
   "peerDependencies": {
-    "@trigger.dev/sdk": "workspace:^2.3.6"
+    "@trigger.dev/sdk": "workspace:^2.3.7"
   },
   "dependencies": {
     "debug": "^4.3.4"

packages/testing/CHANGELOG.md

@@ -1,5 +1,12 @@
 # @trigger.dev/testing
 
+## 2.3.7
+
+### Patch Changes
+
+- @trigger.dev/core@2.3.7
+- @trigger.dev/sdk@2.3.7
+
 ## 2.3.6
 
 ### Patch Changes

packages/testing/package.json

@@ -1,7 +1,7 @@
 {
   "name": "@trigger.dev/testing",
   "description": "A collection of useful tools to write tests for Trigger.dev.",
-  "version": "2.3.6",
+  "version": "2.3.7",
   "license": "MIT",
   "main": "./dist/index.js",
   "types": "./dist/index.d.ts",

packages/trigger-sdk/CHANGELOG.md

@@ -1,5 +1,12 @@
 # @trigger.dev/sdk
 
+## 2.3.7
+
+### Patch Changes
+
+- @trigger.dev/core@2.3.7
+- @trigger.dev/core-backend@2.3.7
+
 ## 2.3.6
 
 ### Patch Changes

packages/trigger-sdk/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@trigger.dev/sdk",
-  "version": "2.3.6",
+  "version": "2.3.7",
   "description": "trigger.dev Node.JS SDK",
   "license": "MIT",
   "main": "./dist/index.js",
@@ -30,8 +30,8 @@
     "typecheck": "tsc --noEmit"
   },
   "dependencies": {
-    "@trigger.dev/core": "workspace:^2.3.6",
-    "@trigger.dev/core-backend": "workspace:^2.3.6",
+    "@trigger.dev/core": "workspace:^2.3.7",
+    "@trigger.dev/core-backend": "workspace:^2.3.7",
     "chalk": "^5.2.0",
     "cronstrue": "^2.21.0",
     "debug": "^4.3.4",

packages/yalt/CHANGELOG.md

@@ -1,5 +1,11 @@
 # @trigger.dev/yalt
 
+## 2.3.7
+
+### Patch Changes
+
+- dfa47b62: Don't proxy certain headers across the Yalt boundary as it can mess-up proxied local requests
+
 ## 2.3.6
 
 ### Patch Changes

packages/yalt/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@trigger.dev/yalt",
-  "version": "2.3.6",
+  "version": "2.3.7",
   "description": "yalt.dev client library",
   "license": "MIT",
   "main": "./dist/index.js",
@@ -31,18 +31,19 @@
     "typecheck": "tsc --noEmit"
   },
   "dependencies": {
-    "zod": "3.22.3",
-    "partysocket": "^0.0.17"
+    "partysocket": "^0.0.17",
+    "zod": "3.22.3"
   },
   "devDependencies": {
     "@trigger.dev/tsconfig": "workspace:*",
+    "@trigger.dev/tsup": "workspace:*",
+    "@types/debug": "^4.1.7",
     "@types/jest": "^29.5.3",
     "@types/node": "18",
     "jest": "^29.6.2",
     "rimraf": "^3.0.2",
     "ts-jest": "^29.1.1",
     "tsup": "^8.0.1",
-    "@trigger.dev/tsup": "workspace:*",
     "typescript": "^5.3.0"
   },
   "engines": {

packages/yalt/src/index.ts

@@ -36,7 +36,7 @@ export async function createRequestMessage(id: string, request: Request): Promis
   return {
     type: "request",
     id,
-    headers: Object.fromEntries(headers),
+    headers: stripHeaders(Object.fromEntries(headers)),
     method,
     url,
     body,
@@ -86,26 +86,48 @@ export class YaltApiClient {
   }
 }
 
-export type YaltTunnelOptions = {
+export type YaltTunnelSocketOptions = {
   WebSocket?: any;
   connectionTimeout?: number;
   maxRetries?: number;
 };
+
+export type YaltTunnelOptions = {
+  verbose?: boolean;
+};
+
 export class YaltTunnel {
   socket?: WebSocket;
 
   constructor(
     private url: string,
     private address: string,
+    private socketOptions: YaltTunnelSocketOptions = {},
     private options: YaltTunnelOptions = {}
   ) {}
 
+  private log(message: string, properties: Record<string, any> = {}) {
+    if (this.options.verbose) {
+      console.log(JSON.stringify({ message, ...properties }));
+    }
+  }
+
   async connect() {
-    this.socket = new WebSocket(`wss://${this.url}/connect`, [], this.options);
+    this.log("Connecting to tunnel", {
+      url: this.url,
+      address: this.address,
+      socketOptions: this.socketOptions,
+    });
 
-    this.socket.addEventListener("open", () => {});
+    this.socket = new WebSocket(`wss://${this.url}/connect`, [], this.socketOptions);
 
-    this.socket.addEventListener("close", (event) => {});
+    this.socket.addEventListener("open", (args) => {
+      this.log("Connected to tunnel");
+    });
+
+    this.socket.addEventListener("close", (event) => {
+      this.log("Disconnected from tunnel", { event: event.code, reason: event.reason });
+    });
 
     this.socket.addEventListener("message", async (event) => {
       const data = JSON.parse(
@@ -115,7 +137,7 @@ export class YaltTunnel {
       const message = ServerMessages.safeParse(data);
 
       if (!message.success) {
-        console.error(message.error);
+        this.log("Received invalid message", { data });
         return;
       }
 
@@ -132,7 +154,7 @@ export class YaltTunnel {
     });
 
     this.socket.addEventListener("error", (event) => {
-      console.error(event);
+      this.log("Socket error", { error: event.message });
     });
   }
 
@@ -147,13 +169,31 @@ export class YaltTunnel {
 
     let response: Response | null = null;
 
+    this.log("Sending local request", {
+      originalUrl: originalUrl.href,
+      requestId: request.id,
+      headers: request.headers,
+    });
+
     try {
       response = await fetch(originalUrl.href, {
         method: request.method,
-        headers: request.headers,
+        headers: stripHeaders(request.headers),
         body: request.body,
       });
     } catch (error) {
+      if (error instanceof Error) {
+        this.log("Error sending local request", {
+          error: error.message,
+          name: error.name,
+          stack: error.stack,
+          requestId: request.id,
+          cause: "cause" in error ? error.cause : undefined,
+        });
+      } else {
+        this.log("Error sending local request", { error, requestId: request.id });
+      }
+
       // Return a 502 response
       response = new Response(
         JSON.stringify({
@@ -164,15 +204,33 @@ export class YaltTunnel {
     }
 
     try {
-      await sendResponse(request.id, response, this.socket);
+      await this.sendResponse(request.id, response, this.socket);
     } catch (error) {
       console.error(error);
     }
   }
+
+  private async sendResponse(id: string, response: Response, socket: WebSocket) {
+    const message = await createResponseMessage(id, response);
+
+    this.log("Sending response", { requestId: id, status: response.status });
+
+    return socket.send(JSON.stringify(message));
+  }
 }
 
-async function sendResponse(id: string, response: Response, socket: WebSocket) {
-  const message = await createResponseMessage(id, response);
+// Remove headers that should not be included like connection, host, etc
+function stripHeaders(headers: Record<string, string>) {
+  const blacklistHeaders = [
+    "connection",
+    "cf-ray",
+    "cf-connecting-ip",
+    "host",
+    "cf-ipcountry",
+    "content-length",
+  ];
 
-  return socket.send(JSON.stringify(message));
+  return Object.fromEntries(
+    Object.entries(headers).filter(([key]) => !blacklistHeaders.includes(key.toLowerCase()))
+  );
 }

pnpm-lock.yaml

@@ -399,12 +399,12 @@ importers:
     specifiers:
       '@cloudflare/workers-types': ~4.20231121.0
       '@trigger.dev/yalt': workspace:*
-      wrangler: ^3.20.0
+      wrangler: ^3.21.0
     dependencies:
       '@trigger.dev/yalt': link:../../packages/yalt
     devDependencies:
       '@cloudflare/workers-types': 4.20231121.0
-      wrangler: 3.20.0
+      wrangler: 3.21.0
 
   config-packages/eslint-config-custom:
     specifiers:
@@ -444,8 +444,8 @@ importers:
 
   integrations/airtable:
     specifiers:
-      '@trigger.dev/integration-kit': workspace:^2.3.6
-      '@trigger.dev/sdk': workspace:^2.3.6
+      '@trigger.dev/integration-kit': workspace:^2.3.7
+      '@trigger.dev/sdk': workspace:^2.3.7
       '@trigger.dev/tsconfig': workspace:*
       '@trigger.dev/tsup': workspace:*
       '@types/node': 16.x
@@ -474,8 +474,8 @@ importers:
       '@octokit/types': ^9.2.3
       '@octokit/webhooks': ^10.4.0
       '@octokit/webhooks-types': ^6.10.0
-      '@trigger.dev/integration-kit': workspace:^2.3.6
-      '@trigger.dev/sdk': workspace:^2.3.6
+      '@trigger.dev/integration-kit': workspace:^2.3.7
+      '@trigger.dev/sdk': workspace:^2.3.7
       '@trigger.dev/tsconfig': workspace:*
       '@trigger.dev/tsup': workspace:*
       '@types/node': '18'
@@ -505,8 +505,8 @@ importers:
   integrations/linear:
     specifiers:
       '@linear/sdk': ^8.0.0
-      '@trigger.dev/integration-kit': workspace:^2.3.6
-      '@trigger.dev/sdk': workspace:^2.3.6
+      '@trigger.dev/integration-kit': workspace:^2.3.7
+      '@trigger.dev/sdk': workspace:^2.3.7
       '@trigger.dev/tsconfig': workspace:*
       '@trigger.dev/tsup': workspace:*
       '@types/node': 16.x
@@ -529,8 +529,8 @@ importers:
 
   integrations/openai:
     specifiers:
-      '@trigger.dev/integration-kit': workspace:^2.3.6
-      '@trigger.dev/sdk': workspace:^2.3.6
+      '@trigger.dev/integration-kit': workspace:^2.3.7
+      '@trigger.dev/sdk': workspace:^2.3.7
       '@trigger.dev/tsconfig': workspace:*
       '@trigger.dev/tsup': workspace:*
       '@types/jest': ^29.5.3
@@ -559,8 +559,8 @@ importers:
   integrations/plain:
     specifiers:
       '@team-plain/typescript-sdk': ^2.7.0
-      '@trigger.dev/integration-kit': workspace:^2.3.6
-      '@trigger.dev/sdk': workspace:^2.3.6
+      '@trigger.dev/integration-kit': workspace:^2.3.7
+      '@trigger.dev/sdk': workspace:^2.3.7
       '@trigger.dev/tsconfig': workspace:*
       '@trigger.dev/tsup': workspace:*
       '@types/node': '18'
@@ -581,8 +581,8 @@ importers:
 
   integrations/replicate:
     specifiers:
-      '@trigger.dev/integration-kit': workspace:^2.3.6
-      '@trigger.dev/sdk': workspace:^2.3.6
+      '@trigger.dev/integration-kit': workspace:^2.3.7
+      '@trigger.dev/sdk': workspace:^2.3.7
       '@trigger.dev/tsconfig': workspace:*
       '@trigger.dev/tsup': workspace:*
       '@types/node': 16.x
@@ -606,8 +606,8 @@ importers:
 
   integrations/resend:
     specifiers:
-      '@trigger.dev/integration-kit': workspace:^2.3.6
-      '@trigger.dev/sdk': workspace:^2.3.6
+      '@trigger.dev/integration-kit': workspace:^2.3.7
+      '@trigger.dev/sdk': workspace:^2.3.7
       '@trigger.dev/tsconfig': workspace:*
       '@trigger.dev/tsup': workspace:*
       '@types/node': '18'
@@ -630,8 +630,8 @@ importers:
   integrations/sendgrid:
     specifiers:
       '@sendgrid/mail': ^7.7.0
-      '@trigger.dev/integration-kit': workspace:^2.3.6
-      '@trigger.dev/sdk': workspace:^2.3.6
+      '@trigger.dev/integration-kit': workspace:^2.3.7
+      '@trigger.dev/sdk': workspace:^2.3.7
       '@trigger.dev/tsconfig': workspace:*
       '@trigger.dev/tsup': workspace:*
       '@types/node': 16.x
@@ -653,8 +653,8 @@ importers:
   integrations/shopify:
     specifiers:
       '@shopify/shopify-api': ^8.0.2
-      '@trigger.dev/integration-kit': workspace:^2.3.6
-      '@trigger.dev/sdk': workspace:^2.3.6
+      '@trigger.dev/integration-kit': workspace:^2.3.7
+      '@trigger.dev/sdk': workspace:^2.3.7
       '@trigger.dev/tsconfig': workspace:*
       '@trigger.dev/tsup': workspace:*
       '@types/node': 16.x
@@ -678,7 +678,7 @@ importers:
   integrations/slack:
     specifiers:
       '@slack/web-api': ^6.8.1
-      '@trigger.dev/sdk': workspace:^2.3.6
+      '@trigger.dev/sdk': workspace:^2.3.7
       '@trigger.dev/tsconfig': workspace:*
       '@trigger.dev/tsup': workspace:*
       '@types/node': '18'
@@ -700,8 +700,8 @@ importers:
 
   integrations/stripe:
     specifiers:
-      '@trigger.dev/integration-kit': workspace:^2.3.6
-      '@trigger.dev/sdk': workspace:^2.3.6
+      '@trigger.dev/integration-kit': workspace:^2.3.7
+      '@trigger.dev/sdk': workspace:^2.3.7
       '@trigger.dev/tsup': workspace:*
       '@types/node': 16.x
       rimraf: ^3.0.2
@@ -726,8 +726,8 @@ importers:
   integrations/supabase:
     specifiers:
       '@supabase/supabase-js': ^2.26.0
-      '@trigger.dev/integration-kit': workspace:^2.3.6
-      '@trigger.dev/sdk': workspace:^2.3.6
+      '@trigger.dev/integration-kit': workspace:^2.3.7
+      '@trigger.dev/sdk': workspace:^2.3.7
       '@trigger.dev/tsconfig': workspace:*
       '@trigger.dev/tsup': workspace:*
       '@types/node': 18.x
@@ -752,8 +752,8 @@ importers:
 
   integrations/typeform:
     specifiers:
-      '@trigger.dev/integration-kit': workspace:^2.3.6
-      '@trigger.dev/sdk': workspace:^2.3.6
+      '@trigger.dev/integration-kit': workspace:^2.3.7
+      '@trigger.dev/sdk': workspace:^2.3.7
       '@trigger.dev/tsup': workspace:*
       '@typeform/api-client': ^1.8.0
       '@types/node': 16.x
@@ -1019,7 +1019,7 @@ importers:
 
   packages/express:
     specifiers:
-      '@trigger.dev/sdk': workspace:^2.3.6
+      '@trigger.dev/sdk': workspace:^2.3.7
       '@trigger.dev/tsconfig': workspace:*
       '@trigger.dev/tsup': workspace:*
       '@types/debug': ^4.1.7
@@ -1089,7 +1089,7 @@ importers:
     specifiers:
       '@nestjs/common': ^10.2.4
       '@remix-run/web-fetch': ^4.3.5
-      '@trigger.dev/sdk': workspace:^2.3.6
+      '@trigger.dev/sdk': workspace:^2.3.7
       '@trigger.dev/tsconfig': workspace:*
       '@trigger.dev/tsup': workspace:*
       '@types/debug': ^4.1.7
@@ -1148,7 +1148,7 @@ importers:
   packages/react:
     specifiers:
       '@tanstack/react-query': 5.0.0-beta.2
-      '@trigger.dev/core': workspace:^2.3.6
+      '@trigger.dev/core': workspace:^2.3.7
       '@trigger.dev/tsconfig': workspace:*
       '@types/debug': ^4.1.7
       '@types/react': 18.2.17
@@ -1251,8 +1251,8 @@ importers:
 
   packages/trigger-sdk:
     specifiers:
-      '@trigger.dev/core': workspace:^2.3.6
-      '@trigger.dev/core-backend': workspace:^2.3.6
+      '@trigger.dev/core': workspace:^2.3.7
+      '@trigger.dev/core-backend': workspace:^2.3.7
       '@trigger.dev/tsconfig': workspace:*
       '@trigger.dev/tsup': workspace:*
       '@types/debug': ^4.1.7
@@ -1312,6 +1312,7 @@ importers:
     specifiers:
       '@trigger.dev/tsconfig': workspace:*
       '@trigger.dev/tsup': workspace:*
+      '@types/debug': ^4.1.7
       '@types/jest': ^29.5.3
       '@types/node': '18'
       jest: ^29.6.2
@@ -1327,6 +1328,7 @@ importers:
     devDependencies:
       '@trigger.dev/tsconfig': link:../../config-packages/tsconfig
       '@trigger.dev/tsup': link:../../config-packages/tsup
+      '@types/debug': 4.1.7
       '@types/jest': 29.5.3
       '@types/node': 18.17.1
       jest: 29.6.2_@types+node@18.17.1
@@ -33143,12 +33145,13 @@ packages:
       - utf-8-validate
     dev: true
 
-  /wrangler/3.20.0:
-    resolution: {integrity: sha512-7mg25zJByhBmrfG+CbImSid7JNd5lxGovLA167ndtE8Yrqd3TUukrGWL8o0RCQIm0FUcgl2nCzWArJDShlZVKA==}
+  /wrangler/3.21.0:
+    resolution: {integrity: sha512-DLoo4XfjeyuGRAVWZFHmU1jWnZIfyLGDm6Ika9oy/CLCPfJzVJvf2jI70EU5BlEHWDZXMSJKw7FDdgSqwhaQXg==}
     engines: {node: '>=16.17.0'}
     hasBin: true
     dependencies:
       '@cloudflare/kv-asset-handler': 0.2.0
+      '@cspotcode/source-map-support': 0.8.1
       '@esbuild-plugins/node-globals-polyfill': 0.2.3_esbuild@0.17.19
       '@esbuild-plugins/node-modules-polyfill': 0.2.2_esbuild@0.17.19
       blake3-wasm: 2.1.5
@@ -33160,7 +33163,6 @@ packages:
       resolve.exports: 2.0.2
       selfsigned: 2.4.1
       source-map: 0.6.1
-      source-map-support: 0.5.21
       xxhash-wasm: 1.0.2
     optionalDependencies:
       fsevents: 2.3.3