Google ジェミニ API Telemetry

import { GoogleGenAI } from "@google/genai";

async function emitModelOutcome(data) {
  try {
    const delivery = await fetch("https://api.telemetry.sh/log", {
      method: "POST",
      headers: {
        Authorization: process.env.TELEMETRY_API_KEY,
        "Content-Type": "application/json",
      },
      body: JSON.stringify({ table: "llm_request_completed", data }),
      signal: AbortSignal.timeout(1000),
    });
    if (!delivery.ok) throw new Error("telemetry_delivery_unconfirmed");
  } catch {
    try { console.warn("Telemetry delivery unconfirmed"); } catch {}
  }
}

const gemini = new GoogleGenAI({ apiKey: process.env.GEMINI_API_KEY });
const startedAt = performance.now();

try {
  const response = await gemini.models.generateContent({
    model: process.env.GEMINI_MODEL,
    contents: userInput,
  });
  const usage = response.usageMetadata;

  await emitModelOutcome({
    provider: "google",
    model: process.env.GEMINI_MODEL,
    feature: "support_draft",
    status: "success",
    latency_ms: Math.round(performance.now() - startedAt),
    input_tokens: usage?.promptTokenCount,
    output_tokens: usage?.candidatesTokenCount,
    total_tokens: usage?.totalTokenCount,
    prompt_version: "support-v4",
  });

  return response;
} catch (error) {
  await emitModelOutcome({
    provider: "google",
    model: process.env.GEMINI_MODEL,
    feature: "support_draft",
    status: "failed",
    latency_ms: Math.round(performance.now() - startedAt),
    error_type: "provider_request_failed",
  });
  throw error;
}