Method registerEndpoint

packages/cli/src/utils/triggerApi.ts:147–201

(options: CreateEndpointOptions)

  }

  async registerEndpoint(options: CreateEndpointOptions): Promise<EndpointResponse> {
    const response = await fetch(`${this.baseUrl}/api/v1/endpoints`, {
      method: "POST",
      headers: {
        "Content-Type": "application/json",
        Authorization: `Bearer ${this.apiKey}`,
      },
      body: JSON.stringify(options),
    });

    if (!response.ok) {
      const rawBody = await response.text();

      if (typeof rawBody === "string") {
        const rawJson = safeJsonParse(rawBody);

        if (!rawJson) {
          return {
            ok: false,
            error: "An unknown issue occurred when registering with Trigger.dev",
            retryable: true,
          };
        }

        const parsedJson = z.object({ error: z.string() }).safeParse(rawJson);

        if (!parsedJson.success) {
          return {
            ok: false,
            error: "An unknown issue occurred when registering with Trigger.dev",
            retryable: true,
          };
        }

        return {
          ok: false,
          error: parsedJson.data.error,
          retryable: RETRYABLE_PATTERN.test(parsedJson.data.error),
        };
      } else {
        return {
          ok: false,
          error: "An unknown issue occurred when registering with Trigger.dev",
          retryable: true,
        };
      }
    }

    const data = await response.json();

    return {
      ok: true,
      data: data as any as EndpointData,
    };
  }

  async getEndpointIndex(indexId: string) {
    const response = await fetch(`${this.baseUrl}/api/v1/endpointindex/${indexId}`, {