import { json } from "@remix-run/server-runtime";
import { type WaitpointRetrieveTokenResponse } from "@trigger.dev/core/v3";
import { WaitpointId } from "@trigger.dev/core/v3/isomorphic";
import { z } from "zod";
import { $replica, runOpsNewReplica, runOpsSplitReadEnabled } from "~/db.server";
import { ApiWaitpointPresenter } from "~/presenters/v3/ApiWaitpointPresenter.server";
import { createLoaderApiRoute } from "~/services/routeBuilders/apiBuilder.server";

export const loader = createLoaderApiRoute(
  {
    params: z.object({
      waitpointFriendlyId: z.string(),
    }),
    findResource: async () => 1, // This is a dummy function, we don't need to find a resource
  },
  async ({ params, authentication }) => {
    const presenter = new ApiWaitpointPresenter(undefined, undefined, {
      newClient: runOpsNewReplica,
      legacyReplica: $replica,
      splitEnabled: runOpsSplitReadEnabled,
    });
    const result: WaitpointRetrieveTokenResponse = await presenter.call(
      authentication.environment,
      WaitpointId.toId(params.waitpointFriendlyId)
    );
    return json(result);
  }
);