Method handleRequest

packages/nestjs/src/index.ts:168–221

* Forward the request to the TriggerDev client

(
      res: any,
      method: string,
      requestHeaders: unknown,
      requestBody?: unknown
    )

     * Forward the request to the TriggerDev client
     */
    public async handleRequest(
      res: any,
      method: string,
      requestHeaders: unknown,
      requestBody?: unknown
    ): Promise<unknown> {
      // try {
      const headers = new StandardHeaders();

      Object.entries(requestHeaders || {}).forEach(([key, value]) => {
        headers.set(key, value as string);
      });

      // Create a new Request object (hardcode the url because it doesn't really matter what it is)
      const standardRequest = new StandardRequest("https://nestjs.com/api/trigger", {
        headers,
        method,
        // @ts-ignore
        body: requestBody ? JSON.stringify(requestBody) : undefined,
      });

      const response = await this.client.handleRequest(standardRequest);

      if (!response) {
        throw new NotFoundException({ error: "Not found" });
      }

      /**
       * NestJS users mostly use either Express or Fastify, but they have
       * different response object APIs, so we need to figure out which one
       * is being used and set the status code and headers accordingly.
       */
      if (isExpressResponse(res)) {
        res.status(response.status);

        if (response.headers) {
          // Merges the headers, so no need to iterate over them
          res.set(response.headers);
        }
      } else if (isFastifyReply(res)) {
        res.code(response.status);

        if (response.headers) {
          // Same merge behaviour as Express
          res.headers(response.headers);
        }
      } else {
        throw new InternalServerErrorException(
          "Unable to indetify the framework to set the status code, are you using Express or Fastify?"
        );
      }

      return response.body;
    }
  }

  return TriggerDevController;