Function report

apps/cloud/src/auth/mirror-feeders.node.test.ts:1530–1561

(
    org: string,
    backfilledAt: Date | null,
    active: number,
    workos: Partial<WorkOSClientService> = {},
  )

    });

  const report = (
    org: string,
    backfilledAt: Date | null,
    active: number,
    workos: Partial<WorkOSClientService> = {},
  ) =>
    Effect.gen(function* () {
      const reported: { organizationId: string; seats: number }[] = [];
      const writes: string[] = [];
      const recording = Layer.succeed(AutumnService)({
        use: () => Effect.die("the seat reporter sets seats, it does not read"),
        ensureCustomer: () => Effect.void,
        checkExecutionBalance: () => Effect.die("the seat reporter does not check balances"),
        trackExecution: () => Effect.void,
        setMemberSeats: (organizationId, seats) =>
          Effect.sync(() => {
            reported.push({ organizationId, seats });
          }),
      });
      yield* forkReportMemberSeats(org).pipe(
        Effect.provide(
          Layer.mergeAll(
            recordingMirror(backfilledAt, writes),
            directoryWith(org, active),
            recording,
            stubWorkOS(workos),
          ),
        ),
      );
      // The Autumn call is forked; it is synchronous here, so it has landed.
      return { reported, writes };
    });

  it.effect(
    "sets the active member count of a scanned organization without touching WorkOS",