Method ping

apps/webapp/app/services/endpointApi.server.ts:48–115

(endpointId: string)

  constructor(private apiKey: string, private url: string) {}

  async ping(endpointId: string): Promise<PongResponse> {
    const response = await safeFetch(this.url, {
      method: "POST",
      headers: {
        "x-trigger-api-key": this.apiKey,
        "x-trigger-endpoint-id": endpointId,
        "x-trigger-action": "PING",
      },
    });

    if (!response) {
      return {
        ok: false,
        error: `Could not connect to endpoint ${this.url}`,
      };
    }

    if (response.status === 401) {
      const body = await safeBodyFromResponse(response, ErrorWithStackSchema);

      if (body) {
        return {
          ok: false,
          error: body.message,
        } as const;
      }

      return {
        ok: false,
        error: `Trigger API key is invalid`,
      } as const;
    }

    if (!response.ok) {
      return {
        ok: false,
        error: `Could not connect to endpoint ${this.url}. Status code: ${response.status}`,
      };
    }

    const pongResponse = await safeParseBodyFromResponse(response, PongResponseSchema);

    if (!pongResponse) {
      return {
        ok: false,
        error: `Could not parse response from endpoint. Make sure it points to the correct URL (you might be missing /api/trigger)`,
      };
    }

    if (!pongResponse.success) {
      return {
        ok: false,
        error: `Endpoint ${this.url} responded with error: ${pongResponse.error.message}`,
      };
    }

    const headers = EndpointHeadersSchema.safeParse(Object.fromEntries(response.headers.entries()));