Function decide

apps/cloud/src/engine/execution-gate.ts:153–182

(organizationId: string)

        };

  const decide = (organizationId: string): Effect.Effect<GateDecision> =>
    Effect.suspend(() => {
      const nowMs = Date.now();
      const cached = cache.get(organizationId);
      if (cached && cached.expiresAtMs > nowMs) {
        return Effect.succeed(toDecision(organizationId, cached.allowed));
      }
      return checkBalance(organizationId).pipe(
        Effect.timeoutOrElse({
          duration: `${timeoutMs} millis`,
          orElse: () => Effect.fail(new GateCheckTimeoutError({ timeoutMs })),
        }),
        Effect.map(({ allowed }) => {
          writeCache(organizationId, allowed, nowMs);
          return toDecision(organizationId, allowed);
        }),
        // FAIL OPEN: Autumn errors, timeouts, and missing customers/features
        // must never block executions. Reported like `trackExecution` so a
        // billing outage still pages; the error outcome is never cached.
        Effect.catch((error: unknown) =>
          Effect.gen(function* () {
            yield* Effect.sync(() => {
              console.warn("[billing] execution balance check failed open:", error);
            });
            yield* captureCauseEffect(error);
            return { blocked: false } as const satisfies GateDecision;
          }),
        ),
      );
    });

  return {
    /** Wrap an engine so the balance gate runs before each new execution. */