Function action

apps/webapp/app/routes/api.v1.schedules.ts:16–76

({ request }: ActionFunctionArgs)

});

export async function action({ request }: ActionFunctionArgs) {
  // Ensure this is a POST request
  if (request.method.toUpperCase() !== "POST") {
    return { status: 405, body: "Method Not Allowed" };
  }

  // Authenticate the request
  const authenticationResult = await authenticateApiRequest(request);

  if (!authenticationResult) {
    return json({ error: "Invalid or Missing API Key" }, { status: 401 });
  }

  const rawBody = await request.json();

  const body = CreateScheduleOptions.safeParse(rawBody);

  if (!body.success) {
    return json({ error: "Invalid request body", issues: body.error.issues }, { status: 400 });
  }

  const service = new UpsertTaskScheduleService();

  try {
    const options: UpsertSchedule = {
      taskIdentifier: body.data.task,
      cron: body.data.cron,
      environments: [authenticationResult.environment.id],
      externalId: body.data.externalId,
      deduplicationKey: body.data.deduplicationKey,
    };

    const schedule = await service.call(authenticationResult.environment.projectId, options);

    const responseObject: ScheduleObject = {
      id: schedule.id,
      task: schedule.task,
      active: schedule.active,
      generator: {
        type: "CRON",
        expression: schedule.cron,
        description: schedule.cronDescription,
      },
      externalId: schedule.externalId ?? undefined,
      deduplicationKey: schedule.deduplicationKey,
      environments: schedule.environments,
      nextRun: schedule.nextRun,
    };

    return json(responseObject, { status: 200 });
  } catch (error) {
    if (error instanceof ServiceValidationError) {
      return json({ error: error.message }, { status: 422 });
    }

    return json(
      { error: error instanceof Error ? error.message : "Internal Server Error" },
      { status: 500 }