Function setMemberSeats

apps/cloud/src/extensions/billing/service.ts:183–216

(organizationId: string, seats: number)

    }).pipe(Effect.withSpan("autumn.trackExecution"));

  const setMemberSeats = (organizationId: string, seats: number) =>
    Effect.gen(function* () {
      yield* Effect.annotateCurrentSpan({
        "autumn.customer.id": organizationId,
        "autumn.members.seats": seats,
      });
      // getOrCreate rather than get: reuses the provisioning repair, so an
      // org Autumn has never seen gets its customer minted here instead of
      // 404ing forever.
      const customer = yield* use((c) => c.customers.getOrCreate({ customerId: organizationId }));
      // Plans that predate seat pricing have no members balance to set.
      // Existing subscribers stay on those versions deliberately, so this is
      // a steady state, not an error.
      if (customer.balances["members"] == null) {
        yield* Effect.annotateCurrentSpan({ "autumn.members.skipped": true });
        return;
      }
      yield* use((c) =>
        c.balances.update({ customerId: organizationId, featureId: "members", usage: seats }),
      );
    }).pipe(
      Effect.catch((error) =>
        Effect.gen(function* () {
          // Silent seat drift means wrong invoices, so failures page just
          // like a lost execution track.
          yield* Effect.sync(() => {
            console.error("[billing] seat sync failed:", error);
          });
          yield* captureCauseEffect(error);
          yield* Effect.annotateCurrentSpan({ "autumn.members.failed": true });
        }),
      ),
      Effect.withSpan("autumn.setMemberSeats"),
    );

  const checkExecutionBalance = (organizationId: string) =>
    Effect.gen(function* () {