Function applyEvent

apps/cloud/src/auth/workos-events-sync.node.test.ts:247–257

(event: WorkOsMirroredEvent)

 * instance-wide; each apply moves it to a fresh id, which is what a run does.
 */
const applyEvent = (event: WorkOsMirroredEvent) =>
  Effect.gen(function* () {
    const mirror = yield* WorkOsMirror;
    const write = yield* planEvent(event);
    const prev = yield* mirror.getCursor();
    const outcomes = yield* mirror.applyPage(prev, freshId("event"), [write]);
    expect(Option.isSome(outcomes), "no other run contends in a single-event apply").toBe(true);
    const outcome: WorkOsEventOutcome | undefined = Option.getOrElse(outcomes, () => [])[0];
    expect(outcome, "one write, one outcome").toBeDefined();
    return outcome ?? "absent";
  });

describe("applyEvent", () => {
  it("mirrors a user, refreshes it, refuses an older update, and deletes it", async () => {