feat(core): add shared compute gateway client and template creation types

Author: nicktrn

packages/core/package.json

@@ -52,7 +52,8 @@
       "./v3/runEngineWorker": "./src/v3/runEngineWorker/index.ts",
       "./v3/machines": "./src/v3/machines/index.ts",
       "./v3/serverOnly": "./src/v3/serverOnly/index.ts",
-      "./v3/isomorphic": "./src/v3/isomorphic/index.ts"
+      "./v3/isomorphic": "./src/v3/isomorphic/index.ts",
+      "./v3/compute": "./src/v3/compute/index.ts"
     },
     "sourceDialects": [
       "@triggerdotdev/source"
@@ -577,6 +578,17 @@
         "types": "./dist/commonjs/v3/isomorphic/index.d.ts",
         "default": "./dist/commonjs/v3/isomorphic/index.js"
       }
+    },
+    "./v3/compute": {
+      "import": {
+        "@triggerdotdev/source": "./src/v3/compute/index.ts",
+        "types": "./dist/esm/v3/compute/index.d.ts",
+        "default": "./dist/esm/v3/compute/index.js"
+      },
+      "require": {
+        "types": "./dist/commonjs/v3/compute/index.d.ts",
+        "default": "./dist/commonjs/v3/compute/index.js"
+      }
     }
   },
   "type": "module",

packages/core/src/v3/compute/gatewayClient.ts

@@ -0,0 +1,46 @@
+import type { TemplateCreateRequest } from "./types.js";
+
+export type ComputeGatewayClientOptions = {
+  gatewayUrl: string;
+  authToken?: string;
+  timeoutMs: number;
+};
+
+export class ComputeGatewayClient {
+  constructor(private opts: ComputeGatewayClientOptions) {}
+
+  async createTemplate(
+    req: TemplateCreateRequest,
+    options?: { signal?: AbortSignal }
+  ): Promise<{ accepted: boolean; templateId?: string }> {
+    const url = `${this.opts.gatewayUrl}/api/templates`;
+
+    const headers: Record<string, string> = {
+      "Content-Type": "application/json",
+    };
+    if (this.opts.authToken) {
+      headers["Authorization"] = `Bearer ${this.opts.authToken}`;
+    }
+
+    const signal = options?.signal ?? AbortSignal.timeout(this.opts.timeoutMs);
+
+    const response = await fetch(url, {
+      method: "POST",
+      headers,
+      body: JSON.stringify(req),
+      signal,
+    });
+
+    if (!response.ok) {
+      const errorBody = await response.text().catch(() => "unknown error");
+      throw new Error(`Gateway template creation failed (${response.status}): ${errorBody}`);
+    }
+
+    if (response.status === 202) {
+      return { accepted: true };
+    }
+
+    const result = await response.json();
+    return { accepted: false, templateId: result.template_id };
+  }
+}

packages/core/src/v3/compute/index.ts

@@ -0,0 +1,7 @@
+export { ComputeGatewayClient } from "./gatewayClient.js";
+export type { ComputeGatewayClientOptions } from "./gatewayClient.js";
+export {
+  TemplateCreateRequestSchema,
+  TemplateCallbackPayloadSchema,
+} from "./types.js";
+export type { TemplateCreateRequest, TemplateCallbackPayload } from "./types.js";

packages/core/src/v3/compute/types.ts

@@ -0,0 +1,24 @@
+import { z } from "zod";
+
+export const TemplateCreateRequestSchema = z.object({
+  image: z.string(),
+  cpu: z.number(),
+  memory_mb: z.number(),
+  callback: z
+    .object({
+      url: z.string(),
+      metadata: z.record(z.string()).optional(),
+    })
+    .optional(),
+});
+export type TemplateCreateRequest = z.infer<typeof TemplateCreateRequestSchema>;
+
+export const TemplateCallbackPayloadSchema = z.object({
+  template_id: z.string().optional(),
+  image: z.string(),
+  status: z.enum(["completed", "failed"]),
+  error: z.string().optional(),
+  metadata: z.record(z.string()).optional(),
+  duration_ms: z.number().optional(),
+});
+export type TemplateCallbackPayload = z.infer<typeof TemplateCallbackPayloadSchema>;