@@ -3,6 +3,8 @@ import { logger } from "~/services/logger.server";
33import { BasePresenter } from "./basePresenter.server" ;
44import { type RunListItem , RunListPresenter } from "./RunListPresenter.server" ;
55import { waitpointStatusToApiStatus } from "./WaitpointListPresenter.server" ;
6+ import { WaitpointId } from "@trigger.dev/core/v3/isomorphic" ;
7+ import { env } from "~/env.server" ;
68
79export type WaitpointDetail = NonNullable < Awaited < ReturnType < WaitpointPresenter [ "call" ] > > > ;
810
@@ -35,6 +37,7 @@ export class WaitpointPresenter extends BasePresenter {
3537 completedAfter : true ,
3638 completedAt : true ,
3739 createdAt : true ,
40+ resolver : true ,
3841 connectedRuns : {
3942 select : {
4043 friendlyId : true ,
@@ -83,6 +86,11 @@ export class WaitpointPresenter extends BasePresenter {
8386 return {
8487 id : waitpoint . friendlyId ,
8588 type : waitpoint . type ,
89+ resolver : waitpoint . resolver ,
90+ callbackUrl :
91+ waitpoint . resolver === "HTTP_CALLBACK"
92+ ? generateWaitpointCallbackUrl ( waitpoint . friendlyId )
93+ : undefined ,
8694 status : waitpointStatusToApiStatus ( waitpoint . status , waitpoint . outputIsError ) ,
8795 idempotencyKey : waitpoint . idempotencyKey ,
8896 userProvidedIdempotencyKey : waitpoint . userProvidedIdempotencyKey ,
@@ -100,3 +108,9 @@ export class WaitpointPresenter extends BasePresenter {
100108 } ;
101109 }
102110}
111+
112+ export function generateWaitpointCallbackUrl ( waitpointId : string ) {
113+ return `${
114+ env . API_ORIGIN ?? env . APP_ORIGIN
115+ } /api/v1/waitpoints/http-callback/${ WaitpointId . toFriendlyId ( waitpointId ) } /callback`;
116+ }
0 commit comments