Function POST

packages/astro/src/index.ts:5–52

(ctx)

export function createAstroRoute(client: TriggerClient) {
  const POST: APIRoute = async (ctx) => {
    if (ctx.request.method === "HEAD") {
      return new Response(null, { status: 200 });
    }

    try {
      // Prepare the request to be a fetch-compatible Request object:
      const requestHeaders = ctx.request.headers;
      const requestMethod = ctx.request.method;
      const responseHeaders: Record<string, string> = {};

      for (const [headerName, headerValue] of requestHeaders.entries()) {
        responseHeaders[headerName] = headerValue;
      }

      // Create a new Request object to be passed to the TriggerClient
      // where we pass the clone the incoming request metadata such as
      // headers, method, body.
      const request = new Request("https://express.js/api/trigger", {
        headers: responseHeaders,
        method: requestMethod,
        body: ctx.request.body,
        // @ts-ignore
        duplex: "half",
      });

      // This handshake handler knows how to authenticate requests,
      // call the run() function of the job, and so on
      const response = await client.handleRequest(request);

      if (!response) {
        return new Response(JSON.stringify({ error: "Not found" }), {
          status: 404,
        });
      }

      // Optionally can do something with the job's finished
      // execution's response body
      return new Response(JSON.stringify(response.body), {
        status: response.status,
        headers: response.headers,
      });
    } catch (err) {
      return new Response(JSON.stringify({ error: "Internal server error" }), {
        status: 500,
      });
    }
  };

  return {
    POST,