Function decide

apps/cloud/src/engine/execution-rate-limit.ts:129–161

(organizationId: string)

  const now = options?.now ?? Date.now;

  const decide = (organizationId: string): Effect.Effect<GateDecision> =>
    Effect.suspend(() => {
      const windowId = Math.floor(now() / windowMs);
      return increment(organizationId, windowId).pipe(
        Effect.timeoutOrElse({
          duration: `${timeoutMs} millis`,
          orElse: () => Effect.fail(new RateLimitCheckTimeoutError({ timeoutMs })),
        }),
        Effect.map(
          (count): GateDecision =>
            count > limit
              ? {
                  blocked: true,
                  error: new ExecutionRateLimitExceededError({
                    organizationId,
                    message: RATE_LIMIT_BLOCKED_MESSAGE,
                  }),
                }
              : { blocked: false },
        ),
        // FAIL OPEN: the backstop must never block executions because its
        // counter is unreachable or slow.
        Effect.catch((error: unknown) =>
          Effect.gen(function* () {
            yield* Effect.sync(() => {
              console.warn("[rate-limit] execution rate limit check failed open:", error);
            });
            yield* captureCauseEffect(error);
            return { blocked: false } as const satisfies GateDecision;
          }),
        ),
      );
    });

  return {
    decorate: (organizationId, engine) => withPreExecutionGate(engine, decide(organizationId)),