| import { Pool } from 'pg' |
| import { randomUUID } from 'crypto' |
| import { createServiceClient } from './supabase/server' |
|
|
| type LogLevel = 'all' | 'light' | 'mini' | 'off' |
|
|
| const level = (process.env.LOG_LEVEL as LogLevel) || 'light' |
| const LOCAL_DB_URL = process.env.LOCAL_DATABASE_URL |
|
|
| let pool: Pool | null = null |
| let logsTableReady = false |
|
|
| if (LOCAL_DB_URL) { |
| pool = new Pool({ connectionString: LOCAL_DB_URL }) |
| } |
|
|
| async function ensureLogsTable() { |
| if (!pool || logsTableReady) return |
| try { |
| await pool.query(` |
| CREATE TABLE IF NOT EXISTS logs ( |
| id UUID PRIMARY KEY DEFAULT gen_random_uuid(), |
| created_at TIMESTAMP DEFAULT NOW(), |
| lang VARCHAR, |
| ip VARCHAR, |
| user_agent VARCHAR, |
| module VARCHAR, |
| operation VARCHAR, |
| data JSONB, |
| error TEXT, |
| level VARCHAR |
| ); |
| `) |
| logsTableReady = true |
| } catch (e) { |
| console.error('[logger] Failed to ensure logs table:', e) |
| } |
| } |
|
|
| export interface LogPayload { |
| module: string |
| operation: string |
| data?: Record<string, any> | null |
| error?: string | null |
| ip?: string | null |
| userAgent?: string | null |
| lang?: string | null |
| } |
|
|
| export async function logEvent(payload: LogPayload) { |
| if (level === 'off') return |
|
|
| const shouldIncludeUA = level === 'all' |
| const shouldIncludeData = level === 'all' |
|
|
| const row = { |
| id: randomUUID(), |
| created_at: new Date().toISOString(), |
| lang: payload.lang ?? null, |
| ip: payload.ip ?? null, |
| user_agent: shouldIncludeUA ? payload.userAgent ?? null : null, |
| module: payload.module, |
| operation: payload.operation, |
| data: shouldIncludeData ? payload.data ?? null : null, |
| error: payload.error ?? null, |
| level |
| } |
|
|
| |
| if (pool) { |
| await ensureLogsTable() |
| try { |
| await pool.query( |
| 'INSERT INTO logs(id, created_at, lang, ip, user_agent, module, operation, data, error, level) VALUES($1,$2,$3,$4,$5,$6,$7,$8,$9,$10)', |
| [row.id, row.created_at, row.lang, row.ip, row.user_agent, row.module, row.operation, row.data, row.error, row.level] |
| ) |
| return |
| } catch (e) { |
| console.error('[logger] Failed to insert log into local DB:', e) |
| } |
| } |
|
|
| |
| try { |
| if (process.env.SUPABASE_SERVICE_ROLE_KEY && process.env.SUPABASE_URL) { |
| const supabase = await createServiceClient() |
| |
| await supabase.from('logs' as any).insert(row as any) |
| return |
| } |
| } catch (e) { |
| console.error('[logger] Failed to insert log into Supabase:', e) |
| } |
|
|
| |
| console.info('[logger] (fallback)', row) |
| } |
|
|
