Function createControllerByPath

packages/nestjs/src/index.ts:144–225

* Used to create a custom controller for NestJS with specific path to handle TriggerDev requests. * * @param customProvider The provider to use to inject the TriggerDev client * @param path The path to use for the controller

(customProvider: InjectionToken, path: string)

 * @param path The path to use for the controller
 */
function createControllerByPath(customProvider: InjectionToken, path: string) {
  @Controller(path)
  class TriggerDevController {
    constructor(
      @InjectTriggerDevClient(customProvider)
      private readonly client: TriggerClient
    ) {}

    @Head()
    @HttpCode(200)
    public empty() {}

    @Post()
    public handleRequestPost(
      @Res({ passthrough: true }) res: any,
      @Headers() headers: unknown,
      @Body() body?: unknown
    ): Promise<unknown> {
      return this.handleRequest(res, "POST", headers, body);
    }

    /**
     * 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);