replayRun function added to the SDK

Author: matt-aitken

.changeset/new-rivers-tell.md

@@ -0,0 +1,6 @@
+---
+"@trigger.dev/sdk": patch
+"@trigger.dev/core": patch
+---
+
+Added replayRun function to the SDK

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

@@ -9,6 +9,7 @@ import {
   BatchTriggerTaskRequestBody,
   BatchTriggerTaskResponse,
   CreateUploadPayloadUrlResponseBody,
+  ReplayRunResponse,
 } from "../schemas";
 
 export type TriggerOptions = {
@@ -88,6 +89,18 @@ export class ApiClient {
     );
   }
 
+  replayRun(runId: string) {
+    return zodfetch(
+      ReplayRunResponse,
+      `${this.baseUrl}/api/v1/runs/${runId}/replay`,
+      {
+        method: "POST",
+        headers: this.#getHeaders(false),
+      },
+      zodFetchOptions
+    );
+  }
+
   #getHeaders(spanParentAsLink: boolean) {
     const headers: Record<string, string> = {
       "Content-Type": "application/json",

packages/core/src/v3/schemas/api.ts

@@ -198,3 +198,9 @@ export const CreateUploadPayloadUrlResponseBody = z.object({
 });
 
 export type CreateUploadPayloadUrlResponseBody = z.infer<typeof CreateUploadPayloadUrlResponseBody>;
+
+export const ReplayRunResponse = z.object({
+  id: z.string(),
+});
+
+export type ReplayRunResponse = z.infer<typeof ReplayRunResponse>;

packages/trigger-sdk/src/v3/index.ts

@@ -8,3 +8,5 @@ import type { Context } from "./shared";
 export type { Context };
 
 export { logger, type LogLevel } from "@trigger.dev/core/v3";
+
+export { replayRun } from "./management";

packages/trigger-sdk/src/v3/management.ts

@@ -0,0 +1,18 @@
+import { ReplayRunResponse, apiClientManager } from "@trigger.dev/core/v3";
+import { apiClientMissingError } from "./shared";
+
+export async function replayRun(runId: string): Promise<ReplayRunResponse> {
+  const apiClient = apiClientManager.client;
+
+  if (!apiClient) {
+    throw apiClientMissingError();
+  }
+
+  const response = await apiClient.replayRun(runId);
+
+  if (!response.ok) {
+    throw new Error(response.error);
+  }
+
+  return response.data;
+}

packages/trigger-sdk/src/v3/shared.ts

@@ -562,7 +562,7 @@ async function handleTaskRunExecutionResult<TOutput>(
   }
 }
 
-function apiClientMissingError() {
+export function apiClientMissingError() {
   const hasBaseUrl = !!apiClientManager.baseURL;
   const hasAccessToken = !!apiClientManager.accessToken;
   if (!hasBaseUrl && !hasAccessToken) {