Function logRequest

apps/api/src/services/logging/log_job.ts:189–239

(request: LoggedRequest)

};

export async function logRequest(request: LoggedRequest) {
  const logger = _logger.child({
    module: "log_job",
    method: "logRequest",
    requestId: request.id,
    teamId: request.team_id,
    zeroDataRetention: request.zeroDataRetention,
  });

  // Emit a one-time PostHog milestone the first time this team uses each
  // surface (playground / sdk / mcp / cli / api / ...). Fire-and-forget.
  // Skip zero-data-retention requests — don't send their metadata to PostHog.
  if (!request.zeroDataRetention) {
    trackFirstSurfaceUse({
      teamId: request.team_id,
      origin: request.origin,
      kind: request.kind,
      apiVersion: request.api_version,
      apiKeyId: request.api_key_id,
    });
  }

  // Sanitize user-provided fields (most likely sources of null bytes)
  const sanitizedOrigin = sanitizeString(request.origin);
  const sanitizedIntegration = sanitizeString(request.integration ?? null);
  const sanitizedTargetHint = request.zeroDataRetention
    ? "<redacted due to zero data retention>"
    : sanitizeString(request.target_hint);

  await robustInsert(
    "requests",
    {
      id: request.id,
      kind: request.kind,
      api_version: request.api_version,
      team_id:
        request.team_id === "preview" || request.team_id?.startsWith("preview_")
          ? previewTeamId
          : request.team_id,
      origin: sanitizedOrigin,
      integration: sanitizedIntegration,
      target_hint: sanitizedTargetHint,
      dr_clean_by: request.zeroDataRetention
        ? new Date(Date.now() + 24 * 60 * 60 * 1000)
        : null,
      api_key_id: request.api_key_id ?? null,
    },
    true,
    logger,
  );
}

export type LoggedScrape = {
  id: string;