Function createTrpcClient

src/shell/platform/createTrpcClient.ts:37–96

(apiKey: string, deps: Deps)

const timeoutMs = 15_000;

export function createTrpcClient(apiKey: string, deps: Deps): TrpcClient {
  const authHeader = { Authorization: `Bearer ${apiKey}` };
  const { logger } = deps;

  async function withLogging<T>(
    path: string,
    call: () => Promise<WireResult<T>>,
  ): Promise<WireResult<T>> {
    logger?.debug(`→ ${path}`);
    const result = await call();
    if (result.ok) {
      logger?.debug(`← ${path} ok`);
    } else {
      const e = result.error;
      const raw = e.kind === "http" ? e.body : e.cause.message;
      const clipped = raw.length > 200 ? raw.slice(0, 200) + "…" : raw;
      const msg = e.kind === "http" ? `${e.status} ${clipped}` : clipped;
      logger?.warn(`← ${path} error (${e.kind}): ${msg}`);
    }
    return result;
  }

  return {
    query: (path, input, schema) => {
      const encoded = encodeURIComponent(
        JSON.stringify(superjson.serialize(input)),
      );
      const url = `${deps.baseUrl}/api/trpc/${path}?input=${encoded}`;
      return withLogging(path, () =>
        send(
          deps.fetch,
          url,
          {
            headers: authHeader,
            method: "GET",
            signal: AbortSignal.timeout(timeoutMs),
          },
          schema,
        ),
      );
    },
    mutation: (path, input, schema) => {
      const url = `${deps.baseUrl}/api/trpc/${path}`;
      const body = JSON.stringify(superjson.serialize(input));
      return withLogging(path, () =>
        send(
          deps.fetch,
          url,
          {
            body,
            headers: { ...authHeader, "content-type": "application/json" },
            method: "POST",
            signal: AbortSignal.timeout(timeoutMs),
          },
          schema,
        ),
      );
    },