// ---------------------------------------------------------------------------// Seat-count reporting — the WorkOS → Autumn reconciliation for seat billing// --------------------------------------------------------------------------- import { Effect } from "effect"; import { WorkOSClient } from "../../auth/workos";import { AutumnService } from "./service"; /** * Report the organization's billable seat count to Autumn: active members * only — a pending invite occupies a seat for the plan gate but is not * billed until the person joins. * * Seats change through paths the app never sees a mutation for (invitation * acceptance in AuthKit, SSO JIT provisioning, join by domain, WorkOS * dashboard edits), so this reconciles from a full recount rather than * tracking deltas. It runs after in-app membership mutations AND on every * login callback, so drift from out-of-band changes heals on the next * sign-in. Fire-and-forget-safe: errors are logged, never surfaced. */export const reportMemberSeats = (  organizationId: string,): Effect.Effect<void, never, WorkOSClient | AutumnService> =>  Effect.gen(function* () {    const workos = yield* WorkOSClient;    const autumn = yield* AutumnService;    const memberships = yield* workos.listOrgMembers(organizationId);    const seats = memberships.data.filter((m) => m.status === "active").length;    yield* autumn.setMemberSeats(organizationId, seats);  }).pipe(    Effect.catch((error) =>      Effect.logWarning("reportMemberSeats: seat recount failed", { organizationId, error }),    ),    Effect.withSpan("billing.reportMemberSeats"),  ); /** * Fork `reportMemberSeats` off the calling request, mirroring how execution * tracking is forked: billing must never stall or fail a user-facing * request. Only boot-scoped services are captured (WorkOS + Autumn — no * request-scoped resources), so the forked fiber cannot outlive anything it * depends on. */export const forkReportMemberSeats = (  organizationId: string,): Effect.Effect<void, never, WorkOSClient | AutumnService> =>  Effect.gen(function* () {    const ctx = yield* Effect.context<WorkOSClient | AutumnService>();    yield* Effect.sync(() => {      Effect.runForkWith(ctx)(reportMemberSeats(organizationId));    });  });