// 共通ログスキーマ
interface BaseLogSchema {
  // 必須フィールド
  timestamp: string;         // ISO 8601 (UTC)
  level: 'TRACE' | 'DEBUG' | 'INFO' | 'WARN' | 'ERROR' | 'FATAL';
  message: string;           // 人間が読めるメッセージ
  service: string;           // サービス名 (e.g., "order-service")
  environment: string;       // 環境 (e.g., "production")
  version: string;           // アプリケーションバージョン

  // トレーサビリティ（必須）
  traceId: string;           // 分散トレースID
  spanId: string;            // SpanID
  requestId: string;         // リクエスト固有ID

  // インフラ情報
  hostname: string;          // ホスト名 / Pod名
  pid: number;               // プロセスID
}

interface ExtendedLogSchema extends BaseLogSchema {
  // ビジネスコンテキスト（オプション）
  userId?: string;           // ユーザーID（メールアドレスではなくIDを使用）
  orderId?: string;
  paymentId?: string;
  productId?: string;

  // パフォーマンス情報（オプション）
  duration?: number;         // 処理時間（ms）
  statusCode?: number;       // HTTPステータスコード

  // エラー情報（オプション）
  error?: {
    name: string;
    message: string;
    code?: string;
    stack?: string;          // 本番ではサンプリング
  };
}

// 機密情報の除外ルール
const SENSITIVE_FIELDS = [
  'password', 'token', 'secret', 'creditCard',
  'email', 'phoneNumber', 'address',
];

import pino, { Logger } from 'pino';
import { IncomingMessage } from 'http';

const SENSITIVE_KEYS = ['password', 'token', 'secret', 'creditCard', 'authorization'];

function redactSensitive(obj: Record<string, unknown>): Record<string, unknown> {
  const result = { ...obj };
  for (const key of Object.keys(result)) {
    if (SENSITIVE_KEYS.some((s) => key.toLowerCase().includes(s))) {
      result[key] = '[REDACTED]';
    }
  }
  return result;
}

export function createLogger(serviceName: string): Logger {
  return pino({
    level: process.env.LOG_LEVEL || 'info',
    timestamp: pino.stdTimeFunctions.isoTime,
    base: {
      service: serviceName,
      environment: process.env.NODE_ENV || 'development',
      version: process.env.APP_VERSION || 'unknown',
      hostname: process.env.HOSTNAME || 'localhost',
      pid: process.pid,
    },
    redact: {
      paths: ['password', '*.password', 'authorization', '*.token'],
      censor: '[REDACTED]',
    },
    formatters: {
      level(label) {
        return { level: label.toUpperCase() };
      },
    },
  });
}

export function createRequestLogger(
  baseLogger: Logger,
  req: IncomingMessage
): Logger {
  return baseLogger.child({
    traceId: req.headers['x-trace-id'] || generateId(),
    spanId: generateId(),
    requestId: req.headers['x-request-id'] || generateId(),
    method: req.method,
    path: req.url,
  });
}

function generateId(): string {
  return Math.random().toString(36).substring(2, 15);
}

# ログレベルガイドライン

## レベル定義

| レベル | 定義 | 本番出力 |
|--------|------|---------|
| TRACE | メソッドの入出力、変数の値 | No |
| DEBUG | 内部処理の詳細（キャッシュヒット等） | No（障害時のみ一時的に有効化） |
| INFO | 正常な業務イベントの記録 | Yes |
| WARN | 注意が必要だが処理は継続可能 | Yes |
| ERROR | エラー発生、個別リクエストが失敗 | Yes |
| FATAL | プロセス停止を伴う致命的エラー | Yes |

## 具体例

1. INFO: 注文の作成成功 → `logger.info({ orderId }, 'Order created')`
2. INFO: ユーザーのログイン成功 → `logger.info({ userId }, 'User logged in')`
3. WARN: リトライ発生 → `logger.warn({ orderId, attempt }, 'Payment retry')`
4. WARN: 在庫残り少 → `logger.warn({ productId, stock }, 'Low stock')`
5. ERROR: 決済タイムアウト → `logger.error({ orderId, err }, 'Payment timeout')`
6. ERROR: DB接続失敗（個別クエリ） → `logger.error({ query, err }, 'DB query failed')`
7. FATAL: DB接続プール枯渇 → `logger.fatal({ err }, 'DB pool exhausted')`

## アンチパターン

1. すべてのログをINFOで出力する（レベルの意味がなくなる）
2. ERRORログにスタックトレースを含めない（デバッグが困難になる）
3. ループ内でINFOログを出力する（ログ量が爆発する）
4. 機密情報（パスワード、トークン）をログに含める
5. メッセージだけのログ（コンテキスト情報なし）

# ログ集約アーキテクチャ設計書

architecture:
  shipper: Fluent Bit  # 軽量なログ転送エージェント
  storage: Grafana Loki  # 低コストなログストレージ
  visualization: Grafana  # ダッシュボード

flow:
  - サービスがstdoutにJSON構造化ログを出力
  - Fluent Bit(DaemonSet)がコンテナログを収集
  - Fluent Bitがラベル(service, level)を付与してLokiに送信
  - GrafanaでLogQLクエリを使って検索・可視化

retention_policy:
  - level: ERROR/FATAL
    retention: 90日
    storage_class: hot
  - level: WARN
    retention: 30日
    storage_class: warm
  - level: INFO
    retention: 14日
    storage_class: warm
  - level: DEBUG
    retention: 3日
    storage_class: cold

cost_optimization:
  - 正常系INFOログは10%サンプリング
  - ヘルスチェック(/health)のログは除外
  - DEBUG/TRACEは本番では原則出力しない

# 1. エラースパイクの確認（5分単位で集計）
{service=~".*"} | json | level="ERROR"
  | line_format "{{.service}}" | rate([5m])

# 2. エラーが多いサービスの特定
{service=~".*"} | json | level="ERROR"
  | stats count by (service)

# 3. エラーコード別の内訳
{service="order-service"} | json | level="ERROR"
  | stats count by (errorCode)

# 4. 特定のエラーの詳細ログ
{service="payment-service"} | json | level="ERROR"
  | line_format "{{.timestamp}} {{.message}} orderId={{.orderId}}"

# 5. 特定リクエストの全経路追跡
{service=~".*"} | json | traceId="abc123def456"
  | line_format "{{.timestamp}} [{{.service}}] {{.level}} {{.message}}"

# 6. デプロイイベントとの相関
{service="deployment"} | json
  | line_format "{{.timestamp}} {{.message}} version={{.version}}"

const alertRules = [
  {
    name: 'Critical: Payment Error Spike',
    condition: 'payment-serviceのERRORが1分間に10件以上',
    severity: 'critical',
    notification: ['PagerDuty', 'Slack #oncall'],
    cooldown: '5分',  // 5分以内の再通知を抑制
  },
  {
    name: 'Critical: API Gateway 5xx Spike',
    condition: 'api-gatewayの5xxレスポンスが5分間で全体の5%以上',
    severity: 'critical',
    notification: ['PagerDuty', 'Slack #oncall'],
    cooldown: '5分',
  },
  {
    name: 'Warning: Order Service High Latency',
    condition: 'order-serviceのduration P95が3秒以上が10分間継続',
    severity: 'warning',
    notification: ['Slack #monitoring'],
    cooldown: '30分',
  },
  {
    name: 'Warning: Retry Rate High',
    condition: 'WARNログにretryが含まれるログが5分間に50件以上',
    severity: 'warning',
    notification: ['Slack #monitoring'],
    cooldown: '15分',
  },
  {
    name: 'Critical: FATAL Log Detected',
    condition: 'FATALレベルのログが1件でも発生',
    severity: 'critical',
    notification: ['PagerDuty', 'Slack #oncall'],
    cooldown: '1分',
  },
];