domainkit/client

/**
 * A host that mounts only part of the group declares only those groups. `Transport.capabilities`
 * reports what is there, and `@domainkit/react` renders only those parts of the flow.
 */
export const connectOnly = Transport.fromFetch("/api/domainkit", {
  capabilities: ["connection"],
});

export const declared = Transport.capabilities(connectOnly); // ["connection"]

/** Point it at the path the route group is mounted on. No credential ever reaches this code. */
export const transport = Transport.fromFetch("/api/domainkit");

/** Headers can be static or resolved per request, for a token your app refreshes on its own. */
export const authenticated = Transport.fromFetch("https://api.acme.dev/domainkit", {
  headers: async () => ({ authorization: `Bearer ${await currentAccessToken()}` }),
});

/** Every method is an `Effect` that fails with the `DomainKit.Error` the lifecycle raised. */
export const plan = Effect.gen(function* () {
  const provisioning = transport.provisioning;
  if (provisioning === undefined) return null;
  return yield* provisioning.plan({
    domain: "app.example.com",
    requirements: [DnsRecord.cname({ name: "app.example.com", target: "edge.acme.dev" })],
  });
});

/**
 * Verification takes the requirements to look for. Without them the server uses the domain's
 * latest provisioning receipt, and a domain with neither answers `InvalidInput`.
 */
export const readiness = Effect.gen(function* () {
  const verification = transport.verification;
  if (verification === undefined) return null;
  return yield* verification.observe("app.example.com", {
    requirements: [DnsRecord.cname({ name: "app.example.com", target: "edge.acme.dev" })],
  });
});

/**
 * `latest` reads the stored readiness without observing, for a surface whose host owns the clock.
 * It is `null` until the domain has been observed once.
 */
export const stored = Effect.gen(function* () {
  const verification = transport.verification;
  if (verification === undefined) return null;
  return yield* verification.latest("app.example.com");
});

/** The same transport in Promises, for a component tree that does not run Effect. */
export const api = Transport.toAsync(transport);

export const inspect = async (domain: string) => api.connection?.inspect(domain);