[diegosouzapw]

O quê

Decomposição do god-file chatCore.ts (#3501). Extrai o POST-hook de quota-share (B/F7) do caminho de sucesso não-streaming de handleChatCore para chatCore/quotaShareConsumption.ts.

Como

scheduleQuotaShareConsumption({ apiKeyId, connectionId, provider, usage, estimatedCost, log }). Fire-and-forget / fail-open com guard interno de apiKeyId && connectionId. O scheduleRecordConsumption (setImmediate) e buildConsumptionCost seguem idênticos. Comportamento byte-idêntico.

Validação (Rule #18 — TDD)

• +4 caracterizações: guard p/ apiKeyId/connectionId ausente (no-op), fail-open com input válido (setImmediate roda sem lançar), fallback de provider ausente.
• Caracterizações chatcore pré-existentes intactas → 301 → 305 verde.
• typecheck:core limpo; eslint 0.

⚠️ Base-reds pré-existentes (NÃO deste slice, provados no tip pristine)

• check:db-rules — compressionRunTelemetry.ts não re-exportado.
• check:complexity — 1919 > baseline 1916. Slice delta-0.

Impacto

chatCore.ts −8 linhas. Sem mudança de API/comportamento público.

[chatgpt-codex-connector]

You have reached your Codex usage limits for code reviews. You can see your limits in the Codex usage dashboard.

[gemini-code-assist]

Code Review

This pull request refactors the quota-share consumption POST-hook out of the main chatCore handler into a dedicated, isolated module and adds corresponding unit tests. The reviewer feedback is highly constructive, suggesting an optimization to replace the dynamic import with a static import. This change allows the consumption scheduling function to run synchronously, eliminating unnecessary async overhead in the request path, which in turn simplifies the caller by removing the await keyword and allows the unit tests to use synchronous assertions.

Important

The consumer version of Gemini Code Assist on GitHub is being sunset. Starting June 18, 2026, new organization installations will be blocked, and all code review activity will officially cease on July 17, 2026.
For more details on the timeline and next steps, please review the Help Documentation.

[gemini-code-assist]

Otimização de Performance: Import Estático

Como este arquivo (quotaShareConsumption.ts) agora é um módulo dedicado e isolado, não há risco de dependência circular ao importar estaticamente o @/lib/quota/spendRecorder.

A substituição do await import dinâmico por um import estático no topo do arquivo elimina o overhead de resolução dinâmica do V8/Node.js no caminho crítico de resposta (hot path) de cada requisição não-streaming. Além disso, permite que a função seja síncrona, tornando o fluxo verdadeiramente fire-and-forget.

import { scheduleRecordConsumption, buildConsumptionCost } from "@/lib/quota/spendRecorder";

type LoggerLike = { warn?: (...args: unknown[]) => void } | null | undefined;

export function scheduleQuotaShareConsumption(args: {
  apiKeyId: string | null | undefined;
  connectionId: string | null | undefined;
  provider: string | null | undefined;
  usage: unknown;
  estimatedCost: number;
  log?: LoggerLike;
}): void {
  if (!args.apiKeyId || !args.connectionId) return;
  try {
    scheduleRecordConsumption(
      {
        apiKeyId: args.apiKeyId,
        connectionId: args.connectionId,
        provider: args.provider ?? "unknown",
        cost: buildConsumptionCost(args.usage, args.estimatedCost),
      },
      args.log
    );
  } catch (_) {
    // Outer fail-open — never throws to caller
  }
}

[gemini-code-assist]

Remoção do await desnecessário (Fire-and-Forget)

Uma vez que o scheduleQuotaShareConsumption foi otimizado para usar importação estática e execução síncrona (com agendamento interno via setImmediate), não há necessidade de utilizar await.

Remover o await evita o bloqueio desnecessário do ciclo de vida da requisição (microtask tick), liberando a resposta HTTP para o cliente de forma imediata.

Suggested change

	await scheduleQuotaShareConsumption({
	apiKeyId: apiKeyInfo?.id,
	connectionId: credentials?.connectionId,
	provider,
	usage,
	estimatedCost,
	log,
	});
	scheduleQuotaShareConsumption({
	apiKeyId: apiKeyInfo?.id,
	connectionId: credentials?.connectionId,
	provider,
	usage,
	estimatedCost,
	log,
	});

[gemini-code-assist]

Atualização dos Testes para Asserções Síncronas

Com a alteração do scheduleQuotaShareConsumption para uma função síncrona (removendo o async/Promise), os testes devem ser atualizados para utilizar assert.doesNotThrow em vez de assert.doesNotReject.

test("missing apiKeyId is a no-op (never throws)", () => {
  assert.doesNotThrow(() =>
    scheduleQuotaShareConsumption({
      apiKeyId: null,
      connectionId: "conn-1",
      provider: "openai",
      usage: validUsage,
      estimatedCost: 0.01,
    })
  );
});

test("missing connectionId is a no-op (never throws)", () => {
  assert.doesNotThrow(() =>
    scheduleQuotaShareConsumption({
      apiKeyId: "key-1",
      connectionId: null,
      provider: "openai",
      usage: validUsage,
      estimatedCost: 0.01,
    })
  );
});

test("valid input schedules consumption and never throws (fire-and-forget)", async () => {
  assert.doesNotThrow(() =>
    scheduleQuotaShareConsumption({
      apiKeyId: "key-1",
      connectionId: "conn-1",
      provider: "openai",
      usage: validUsage,
      estimatedCost: 0.0123,
    })
  );
  // give the scheduled setImmediate consumption a tick to run (fail-open, no assertion on DB
  // state — pool config is out of scope; this proves the hook does not throw end-to-end)
  await new Promise((r) => setTimeout(r, 50));
});

test("absent provider falls back without throwing", () => {
  assert.doesNotThrow(() =>
    scheduleQuotaShareConsumption({
      apiKeyId: "key-2",
      connectionId: "conn-2",
      provider: null,
      usage: null,
      estimatedCost: 0,
    })
  );
});