Function resolveExemption

apps/cloud/src/engine/execution-rate-limit.ts:281–312

(organizationId: string)

   * known-paid org into a block mid-workload.
   */
  const resolveExemption = (organizationId: string): Effect.Effect<boolean> =>
    Effect.suspend(() => {
      if (!isExempt) return Effect.succeed(false);
      const nowMs = now();
      const cached = exemptionCache.get(organizationId);
      if (cached && cached.expiresAtMs > nowMs) return Effect.succeed(cached.exempt);
      return isExempt(organizationId).pipe(
        Effect.timeoutOrElse({
          duration: `${EXEMPTION_CHECK_TIMEOUT_MS} millis`,
          orElse: () =>
            Effect.fail(new ExemptionCheckTimeoutError({ timeoutMs: EXEMPTION_CHECK_TIMEOUT_MS })),
        }),
        Effect.map((exempt) => {
          writeExemptionCache(organizationId, exempt, nowMs);
          return exempt;
        }),
        Effect.catch((error: unknown) =>
          Effect.gen(function* () {
            yield* Effect.sync(() => {
              console.warn(
                `[rate-limit] exemption lookup failed for ${organizationId}; treating as ${
                  cached ? "last known" : "not exempt"
                }:`,
                error,
              );
            });
            yield* captureCauseEffect(error);
            return cached?.exempt ?? false;
          }),
        ),
      );
    });

  const decide = (organizationId: string): Effect.Effect<GateDecision> =>
    Effect.suspend(() => {