logger.ts

import { NextRequest, userAgent } from 'next/server'

export class logger {
  static async info(message: string, request: NextRequest) {
    this.log(request, 'INFO', message)
  }

  static async warn(message: string, request: NextRequest) {
    this.log(request, 'WARN', message)
  }

  static async error(message: string, request: NextRequest) {
    this.log(request, 'ERROR', message)
  }

  static async log(req: NextRequest, logLevel: string, logMessage: string) {
    const { isBot, browser, device, engine, os, cpu } = userAgent(req)

    const data = {
      event_ts: new Date().toISOString(),
      ip_address: req.ip,
      city: req.geo?.city ?? 'unknown',
      country: req.geo?.country ?? 'unknown',
      region: req.geo?.region ?? 'unknown',
      latitude: req.geo?.latitude ?? 'unknown',
      longitude: req.geo?.longitude ?? 'unknown',
      protocol: req.headers.get('x-forwarded-proto') ?? 'unknown',
      method: req.method,
      host: req.headers.get('host'),
      url: req.url,
      headers: Array.from(req.headers.keys()).join(','),
      useragent: req.headers.get('user-agent') ?? 'unknown',
      referer: req.headers.get('referer') ?? 'unknown',
      acceptencoding: req.headers.get('accept-encoding') ?? 'unknown',
      acceptlanguage: req.headers.get('accept-language') ?? 'unknown',
      acceptcharset: req.headers.get('accept-charset'),
      origin: req.headers.get('origin') ??'unknown',
      xforwaredforip: req.headers.get('x-forwarded-for') ?? 'unknown',
      connection: req.headers.get('connection') ?? 'unknown',
      cachecontrol: req.headers.get('cache-control') ?? 'unknown',
      contenttype: req.headers.get('content-type') ?? 'unknown',
      from: req.headers.get('from') ?? 'unknown',
      via: req.headers.get('via') ?? 'unknown',
      contentlength: req.headers.get('content-length'),
      isbot: isBot,
      browsername: browser.name ?? 'unknown',
      browserversion: browser.version ?? 'unknown',
      devicemodel: device.model ?? 'unknown',
      devicetype: device.type ?? 'unknown',
      devicevendor: device.vendor ?? 'unknown',
      enginename: engine.name ?? 'unknown',
      engineversion: engine.version ?? 'unknown',
      osname: os.name ?? 'unknown',
      osversion: os.version ?? 'unknown',
      cpuarchitecture: cpu.architecture ?? 'unknown',
      log_level: logLevel,
      log_message: logMessage,
    }

    await this.sendToTinybird(data)
  }

  static async sendToTinybird(data: Record<string, unknown>) {
    await fetch(
      `https://api.tinybird.co/v0/events?name=logs`,
      {
        method: 'POST',
        body: JSON.stringify(data),
        headers: { Authorization: `Bearer ${process.env.TINYBIRD_TOKEN}` },
      }
    )
  }
}