Function noneWhenGone

apps/cloud/scripts/drain-workos-events.ts:65–71

(fn: () => Promise<A>)

  (cause as { readonly status: unknown }).status === 404;

const noneWhenGone = <A>(fn: () => Promise<A>) =>
  Effect.tryPromise({ try: fn, catch: (cause) => cause }).pipe(
    Effect.map(Option.some),
    Effect.catch((cause) =>
      isNotFound(cause) ? Effect.succeed(Option.none<A>()) : Effect.fail(cause),
    ),
  );

// One pass is bounded by the replay's page budget; loop until the stream
// is drained, another run owns it, or the backfill has not run.