Function run

src/app/api/generate/stream/route.ts:209–844

()

      };

      const run = async () => {
        let audit = createGenerationSessionAudit({
          sessionId: randomUUID(),
          provider: "unknown",
          model: "unknown",
        });
        let estimate: GenerationEstimateResult | null = null;
        let quotaReservation: ComplimentaryQuotaReservation | null = null;
        const actualUsages: GenerationTokenUsage[] = [];
        let hasCompleteMeasuredUsage = true;
        let storageVisibility: ArtifactVisibility = githubPat?.trim()
          ? "private"
          : "public";

        const persistTerminalAudit = async (nextAudit = audit) => {
          await persistTerminalSessionAudit({
            username,
            repo,
            githubPat,
            visibility: storageVisibility,
            audit: nextAudit,
          });
        };

        try {
          throwIfAborted(generationAbortController.signal);
          const provider = getProvider();
          const providerLabel = getProviderLabel(provider);
          const model = getModel(provider);

          if (isComplimentaryGateEnabled() && !apiKey) {
            if (provider !== "openai") {
              const error = getComplimentaryProviderMismatchMessage();
              audit = withFailure(
                {
                  ...audit,
                  provider,
                  model,
                  quotaStatus: "denied",
                },
                {
                  failureStage: "started",
                  validationError: error,
                },
              );
              await persistTerminalAudit();
              send({
                status: "error",
                session_id: audit.sessionId,
                error,
                error_code: "COMPLIMENTARY_GATE_PROVIDER_MISMATCH",
                failure_stage: "started",
                validation_error: error,
                cost_summary: audit.finalCost ?? audit.estimatedCost,
                latest_session_audit: audit,
              });
              closeStream();
              return;