[{"_1":2,"_176":-5,"_177":-5},"loaderData",{"_3":4,"_92":93},"root",{"_5":6,"_35":36,"_65":66},"ctx",{"_7":8,"_23":-5,"_24":25,"_26":27,"_28":20,"_29":20,"_30":20,"_31":32,"_33":20,"_34":20},"auth",{"_9":-5,"_10":-5,"_11":-5,"_12":-5,"_13":-5,"_14":-5,"_15":-5,"_16":-5,"_17":-5,"_18":-5,"_19":20,"_21":22},"sessionClaims","sessionId","sessionStatus","userId","actor","orgId","orgRole","orgSlug","orgPermissions","factorVerificationAge","isAuthenticated",false,"tokenType","session_token","user","preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","notificationCount",0,"flagDenols","isTeamOrgMember","ENV",{"_37":38,"_39":40,"_41":42,"_43":44,"_45":46,"_47":48,"_49":50,"_51":52,"_53":54,"_55":56,"_57":58,"_59":60,"_61":62,"_63":64},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","VAL_RUNTIME_NAME","prod","RENDER_GIT_COMMIT","4e736cb42e83c17c10d9f33412034a74b06f3941","RENDER_GIT_BRANCH","main","CLERK_PUBLISHABLE_KEY","pk_live_Y2xlcmsudmFsLnRvd24k","POSTHOG_API_TOKEN","phc_nmoyuAkStEZuUp69rYlg1DZgrIt19Gx0Y4Hwf8tGgJP","POSTHOG_API_HOST","https://wart.val.town","WEB_API_TEMPLATE","https://{val}.web.val.run","APP_URL","https://www.val.town","MODULE_URL","https://esm.town","VANITY_WEB_API_TEMPLATE","https://{label}.val.run/","DENOLS_URL","https://lsp.val.town","NODE_ENV","production","API_URL","https://api.val.town","clerkState",{"_67":68},"__internal_clerk_state",{"_69":70,"_71":46,"_72":73,"_74":73,"_75":20,"_76":73,"_77":73,"_78":73,"_79":73,"_80":81,"_90":20,"_91":20},"__clerk_ssr_state",{"_21":22,"_9":-5,"_10":-5,"_11":-5,"_12":-5,"_13":-5,"_14":-5,"_15":-5,"_16":-5,"_17":-5,"_18":-5,"_19":20},"__publishableKey","__proxyUrl","","__domain","__isSatellite","__signInUrl","__signUpUrl","__afterSignInUrl","__afterSignUpUrl","__clerk_debug",{"_82":20,"_19":20,"_83":73,"_84":85,"_86":73,"_87":46,"_88":20,"_89":73},"isSignedIn","proxyUrl","reason","session-token-and-uat-missing","message","publishableKey","isSatellite","domain","__telemetryDisabled","__telemetryDebug","routes/embed.x.$handle.$name.$",{"_94":95,"_96":97,"_98":99,"_100":101,"_150":151,"_173":174,"_175":-5},"handle","ianmenethil","name","ZenServer","path","src/utils/logger.ts","project",{"_102":103,"_96":97,"_104":105,"_106":-5,"_107":20,"_108":109,"_110":73,"_111":-5,"_12":112,"_113":114,"_115":116,"_117":116,"_118":-5,"_119":32,"_14":120,"_121":122,"_123":122,"_124":125,"_126":125,"_127":125,"_128":122,"_129":122,"_23":130,"_133":134,"_136":137,"_149":20},"id","619e7f00-58a9-11f0-a700-f69ea79377d9","createdAt",["D",1751614495896],"deletedAt","legacyEnvVars","privacy","unlisted","description","imageUrl","5856754a-b1b9-4358-87d1-77f1d9f79e45","pinnedFileId","9f5c41ce-58a9-11f0-947f-f69ea79377d9","pinPreview",true,"pinMigrated","screenshotVersion","likeCount","7559f40a-a274-4a9b-8f8b-7486509c3949","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm",{"_94":95,"_131":132},"profileImageUrl","https://img.clerk.com/eyJ0eXBlIjoicHJveHkiLCJzcmMiOiJodHRwczovL2ltYWdlcy5jbGVyay5kZXYvb2F1dGhfZ2l0aHViL2ltZ18ycXU1U2ZIVEk3NnhGTXRySE0wbWdYQncxSnYifQ","org",{"_94":95,"_135":132,"_12":112},"avatar","branch",{"_138":139,"_96":44,"_102":140,"_141":103,"_142":-5,"_143":-5,"_144":-5,"_145":-5,"_146":-5,"_147":97,"_148":95},"version",883,"619ecc08-58a9-11f0-a700-f69ea79377d9","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","isOwned","file",{"_102":152,"_96":153,"_154":155,"_156":157,"_158":140,"_159":160,"_161":116,"_104":162,"_138":163,"_164":165,"_166":167,"_168":20,"_169":-5,"_98":170},"e351889c-5f4f-11f0-bb77-0224a6c84d84","logger.ts","fileId","a03ac0fc-58a9-11f0-947f-f69ea79377d9","parentId","9f14f27e-58a9-11f0-9a99-f69ea79377d9","branchId","branchVersion",699,"latest",["D",1752345716919],14,"fileType","script","content","// F:\\val.town\\ZenServer\\src\\utils\\logger.ts\r\n// deno-lint-ignore-file no-explicit-any\r\n/**\r\n * Structured logging utilities for ZenServer.\r\n * Provides centralized logging with emoji support, correlation IDs, and configurable outputs.\r\n */\r\n\r\nimport { getCurrentDateTimeInSydneyInYYYYMMDDTHHMMSS } from \"./dateUtils.ts\";\r\nimport {\r\n getLogger,\r\n ConsoleHandler,\r\n FileHandler,\r\n LevelName,\r\n LogRecord,\r\n setup,\r\n} from \"https://deno.land/std@0.224.0/log/mod.ts\";\r\nimport { environment } from \"../config/environment.ts\";\r\nimport { generateCorrelationId as cryptoGenerateCorrelationId } from \"./crypto.ts\";\r\n\r\nexport type LogLevel = \"DEBUG\" | \"INFO\" | \"WARN\" | \"ERROR\";\r\n\r\nexport interface LogEntry {\r\n timestamp: string;\r\n level: LogLevel;\r\n message: string;\r\n service?: string;\r\n correlationId?: string;\r\n metadata?: Record;\r\n}\r\n\r\nexport interface PerformanceEvent {\r\n type: string;\r\n operation: string;\r\n duration: number;\r\n success: boolean;\r\n metadata?: Record;\r\n}\r\n\r\nexport interface SecurityEvent {\r\n type: string;\r\n severity: \"low\" | \"medium\" | \"high\" | \"critical\";\r\n clientIP: string;\r\n userAgent?: string;\r\n details?: Record;\r\n}\r\n\r\n// ========================================\r\n// Logger Configuration\r\n// ========================================\r\n\r\n// Lazy load log file paths using environment configuration\r\nfunction getLogPaths() {\r\n return {\r\n LOG_DIR: environment.LOG_DIR,\r\n APP_LOG_FILE: `${environment.LOG_DIR}/${environment.APP_LOG_FILE}`,\r\n ERROR_LOG_FILE: `${environment.LOG_DIR}/${environment.ERROR_LOG_FILE}`,\r\n API_LOG_FILE: `${environment.LOG_DIR}/${environment.API_LOG_FILE}`,\r\n };\r\n}\r\n\r\n// Clear all log files on startup\r\nasync function clearLogFiles() {\r\n // Only clear logs in development mode\r\n if (environment.APP_ENV === \"prod\") {\r\n console.log(\"📁 Log files preserved (production mode)\");\r\n return;\r\n }\r\n\r\n const { APP_LOG_FILE, ERROR_LOG_FILE, API_LOG_FILE } = getLogPaths();\r\n const logFiles = [APP_LOG_FILE, ERROR_LOG_FILE, API_LOG_FILE];\r\n\r\n for (const logFile of logFiles) {\r\n try {\r\n await Deno.remove(logFile);\r\n console.log(`🧹 Cleared log file: ${logFile}`);\r\n } catch (e) {\r\n // File doesn't exist or can't be removed - that's ok\r\n if (e.name !== \"NotFound\") {\r\n console.warn(`Warning: Could not clear ${logFile}:`, e.message);\r\n }\r\n }\r\n }\r\n}\r\n\r\nlet isInitialized = false;\r\nlet currentCorrelationId: string | null = null;\r\n\r\n// Default configuration using environment settings\r\nfunction getDefaultConfig() {\r\n return {\r\n level: (environment.LOG_LEVEL.toUpperCase() as LogLevel),\r\n format: \"text\" as \"text\" | \"json\",\r\n outputs: [\"console\"] as (\"console\" | \"file\")[],\r\n fileName: `${environment.LOG_DIR}/zenserver.log`,\r\n enableEmojis: true,\r\n enableCorrelationIds: true,\r\n };\r\n}\r\n\r\nlet currentConfig = getDefaultConfig();\r\n\r\n/**\r\n * Clears all log files - useful for fresh start on server restart.\r\n */\r\nexport async function clearLogs(): Promise {\r\n await clearLogFiles();\r\n}\r\n\r\n/**\r\n * Initializes the logging system with configuration.\r\n */\r\nexport async function initializeLogging(\r\n config?: Partial,\r\n clearOnStart: boolean = true\r\n): Promise {\r\n if (isInitialized) {\r\n return;\r\n }\r\n\r\n // Merge with default config\r\n currentConfig = { ...getDefaultConfig(), ...config };\r\n\r\n // In production, only use console handler\r\n if (environment.APP_ENV === \"prod\") {\r\n await setup({\r\n handlers: {\r\n console: new ConsoleHandler(currentConfig.level as LevelName, {\r\n formatter:\r\n currentConfig.format === \"json\" ? formatAsJSON : formatAsText,\r\n }),\r\n },\r\n loggers: {\r\n default: {\r\n level: currentConfig.level as LevelName,\r\n handlers: [\"console\"],\r\n },\r\n },\r\n });\r\n\r\n console.log(\"📝 Logger initialized (production mode - console only)\");\r\n } else {\r\n // Development mode - clear logs and set up file handlers\r\n if (clearOnStart) {\r\n await clearLogFiles();\r\n }\r\n\r\n // Ensure log directory exists before setting up handlers\r\n const { LOG_DIR, APP_LOG_FILE, ERROR_LOG_FILE, API_LOG_FILE } =\r\n getLogPaths();\r\n try {\r\n await Deno.mkdir(LOG_DIR, { recursive: true });\r\n } catch (e) {\r\n if (e && e.name !== \"AlreadyExists\") {\r\n console.error(\"Failed to create log directory:\", e);\r\n }\r\n }\r\n\r\n await setup({\r\n handlers: {\r\n // Console handler (text or JSON)\r\n console: new ConsoleHandler(currentConfig.level as LevelName, {\r\n formatter:\r\n currentConfig.format === \"json\" ? formatAsJSON : formatAsText,\r\n }),\r\n // App log file (all logs, JSON)\r\n applog: new FileHandler(currentConfig.level as LevelName, {\r\n filename: APP_LOG_FILE,\r\n formatter: formatAsJSON,\r\n }),\r\n // Error log file (all logs, JSON; filter in logError below)\r\n errorlog: new FileHandler(currentConfig.level as LevelName, {\r\n filename: ERROR_LOG_FILE,\r\n formatter: formatAsJSON,\r\n }),\r\n // API log file (all logs, JSON; filter in logInfo/logHttpRequest/logHttpResponse below)\r\n apilog: new FileHandler(currentConfig.level as LevelName, {\r\n filename: API_LOG_FILE,\r\n formatter: formatAsJSON,\r\n }),\r\n },\r\n loggers: {\r\n default: {\r\n level: currentConfig.level as LevelName,\r\n handlers: [\"console\", \"applog\", \"errorlog\", \"apilog\"],\r\n },\r\n },\r\n });\r\n\r\n console.log(\"📝 Logger initialized (development mode - console + files)\");\r\n }\r\n\r\n isInitialized = true;\r\n}\r\n\r\n// ========================================\r\n// Correlation ID Management\r\n// ========================================\r\n\r\n/**\r\n * Generates a new correlation ID for request tracking.\r\n */\r\nexport function generateCorrelationId(): string {\r\n return cryptoGenerateCorrelationId();\r\n}\r\n\r\n/**\r\n * Sets the correlation ID for the current context.\r\n */\r\nexport function setCorrelationId(correlationId: string): void {\r\n currentCorrelationId = correlationId;\r\n}\r\n\r\n/**\r\n * Gets the current correlation ID.\r\n */\r\nexport function getCorrelationId(): string | null {\r\n return currentCorrelationId;\r\n}\r\n\r\n/**\r\n * Clears the current correlation ID.\r\n */\r\nexport function clearCorrelationId(): void {\r\n currentCorrelationId = null;\r\n}\r\n\r\n/**\r\n * Executes a function with a specific correlation ID context.\r\n */\r\nexport async function withCorrelationId(\r\n correlationId: string,\r\n fn: () => Promise | T\r\n): Promise {\r\n const previousId = currentCorrelationId;\r\n setCorrelationId(correlationId);\r\n\r\n try {\r\n return await fn();\r\n } finally {\r\n currentCorrelationId = previousId;\r\n }\r\n}\r\n\r\n// ========================================\r\n// Color and Emoji Mappings\r\n// ========================================\r\n\r\n// ANSI color codes\r\nexport const COLORS = {\r\n reset: \"\\x1b[0m\",\r\n bright: \"\\x1b[1m\",\r\n dim: \"\\x1b[2m\",\r\n\r\n // Text colors\r\n black: \"\\x1b[30m\",\r\n red: \"\\x1b[31m\",\r\n green: \"\\x1b[32m\",\r\n yellow: \"\\x1b[33m\",\r\n blue: \"\\x1b[34m\",\r\n magenta: \"\\x1b[35m\",\r\n cyan: \"\\x1b[36m\",\r\n white: \"\\x1b[37m\",\r\n gray: \"\\x1b[90m\",\r\n\r\n // Bright colors\r\n brightRed: \"\\x1b[91m\",\r\n brightGreen: \"\\x1b[92m\",\r\n brightYellow: \"\\x1b[93m\",\r\n brightBlue: \"\\x1b[94m\",\r\n brightMagenta: \"\\x1b[95m\",\r\n brightCyan: \"\\x1b[96m\",\r\n brightWhite: \"\\x1b[97m\",\r\n};\r\n\r\nconst LEVEL_EMOJIS: Record = {\r\n DEBUG: \"🔍\",\r\n INFO: \"ℹ️\",\r\n WARN: \"⚠️\",\r\n ERROR: \"❌\",\r\n};\r\n\r\nconst LEVEL_COLORS: Record = {\r\n DEBUG: COLORS.gray,\r\n INFO: COLORS.cyan,\r\n WARN: COLORS.yellow,\r\n ERROR: COLORS.red,\r\n};\r\n\r\nexport const OPERATION_EMOJIS: Record = {\r\n // HTTP Operations\r\n http_request: \"📨\",\r\n http_response: \"📤\",\r\n http_error: \"💥\",\r\n\r\n // Security Operations\r\n security_check: \"🔐\",\r\n auth_success: \"✅\",\r\n auth_failure: \"🚫\",\r\n honeypot_trigger: \"🍯\",\r\n rate_limit: \"⏱️\",\r\n cors_check: \"🌐\",\r\n\r\n // Database Operations\r\n db_query: \"💾\",\r\n db_insert: \"➕\",\r\n db_update: \"✏️\",\r\n db_delete: \"🗑️\",\r\n db_error: \"💿\",\r\n\r\n // Crypto Operations\r\n crypto_hash: \"🔒\",\r\n crypto_sign: \"✍️\",\r\n crypto_verify: \"🔍\",\r\n crypto_random: \"🎲\",\r\n\r\n // Business Logic\r\n nonce_generate: \"🎫\",\r\n nonce_validate: \"🔍\",\r\n nonce_expire: \"⏰\",\r\n payment_hash: \"💳\",\r\n booking_check: \"📋\",\r\n\r\n // System Operations\r\n startup: \"🚀\",\r\n shutdown: \"🛑\",\r\n health_check: \"💚\",\r\n cleanup: \"🧹\",\r\n config_load: \"⚙️\",\r\n // Debugger\r\n debug_event: \"🐞\",\r\n};\r\n\r\n// ========================================\r\n// Log Formatters\r\n// ========================================\r\n\r\n/**\r\n * Formats log entry as JSON.\r\n */\r\nfunction formatAsJSON(logRecord: LogRecord): string {\r\n const entry: LogEntry = {\r\n timestamp: getCurrentDateTimeInSydneyInYYYYMMDDTHHMMSS(),\r\n level: logRecord.levelName as LogLevel,\r\n message: logRecord.msg,\r\n service: \"zenserver-api\",\r\n ...(currentConfig.enableCorrelationIds && currentCorrelationId\r\n ? {\r\n correlationId: currentCorrelationId,\r\n }\r\n : {}),\r\n ...(logRecord.args.length > 0\r\n ? {\r\n metadata: logRecord.args[0] as Record,\r\n }\r\n : {}),\r\n };\r\n\r\n return JSON.stringify(entry);\r\n}\r\n\r\n/**\r\n * Formats log entry as human-readable text.\r\n */\r\nfunction formatAsText(logRecord: LogRecord): string {\r\n const _timestamp = getCurrentDateTimeInSydneyInYYYYMMDDTHHMMSS();\r\n const level = logRecord.levelName as LogLevel;\r\n const levelColor = LEVEL_COLORS[level];\r\n\r\n // *** TIMESTAMP CONTROL: Comment/uncomment the line below to show/hide timestamps ***\r\n // let message = `${COLORS.gray}[${timestamp}]${COLORS.reset}`;\r\n let message = \"\";\r\n\r\n if (currentConfig.enableEmojis) {\r\n message = `${LEVEL_EMOJIS[level]} ${message}`;\r\n } else {\r\n message += ` ${levelColor}${level}${COLORS.reset}`;\r\n }\r\n\r\n // *** FILENAME CONTROL: Show filename for WARN/ERROR, hide for INFO/DEBUG ***\r\n // To always show filename, uncomment the block below and comment the conditional block\r\n /*\r\n if (logRecord.args.length > 0 && logRecord.args[0]?.source) {\r\n message += ` ${COLORS.green}[${logRecord.args[0].source}]${COLORS.reset}`;\r\n }\r\n */\r\n\r\n // Conditional filename display: only for WARN/ERROR levels\r\n const arg0 = logRecord.args[0];\r\n if (\r\n logRecord.args.length > 0 &&\r\n arg0 &&\r\n typeof arg0 === \"object\" &&\r\n !Array.isArray(arg0)\r\n ) {\r\n const args = { ...(arg0 as Record) };\r\n delete args.source; // Remove source from metadata display\r\n if (Object.keys(args).length > 0) {\r\n message += ` ${COLORS.blue}${JSON.stringify(args)}${COLORS.reset}`;\r\n }\r\n }\r\n\r\n // Correlation ID in magenta\r\n if (currentConfig.enableCorrelationIds && currentCorrelationId) {\r\n message += ` ${COLORS.magenta}[${currentCorrelationId}]${COLORS.reset}`;\r\n }\r\n\r\n // Main message in level color\r\n message += `: ${levelColor}${logRecord.msg}${COLORS.reset}`;\r\n\r\n return message;\r\n}\r\n\r\n// ========================================\r\n// Core Logging Functions\r\n// ========================================\r\n\r\n/**\r\n * Gets the caller filename from the stack trace.\r\n */\r\nfunction getCaller(): string | null {\r\n try {\r\n const stack = new Error().stack;\r\n if (!stack) return null;\r\n\r\n const lines = stack.split(\"\\n\");\r\n // Skip current function, createLogEntry, and logInfo/logWarn/etc\r\n for (let i = 3; i < lines.length; i++) {\r\n const line = lines[i];\r\n if (line && (line.includes(\"file://\") || line.includes(\".ts:\"))) {\r\n // Handle various path formats: file:// URLs, WSL paths, Windows paths\r\n const patterns = [\r\n /file:\\/\\/.*\\/([^\\/]+\\.ts):\\d+:\\d+/, // Standard file:// URLs\r\n /file:\\/\\/\\/[A-Z]:.*\\\\([^\\\\]+\\.ts):\\d+:\\d+/, // Windows file:// URLs\r\n /\\/mnt\\/[a-z]\\/.*\\/([^\\/]+\\.ts):\\d+:\\d+/, // WSL paths\r\n /[A-Z]:\\\\.*\\\\([^\\\\]+\\.ts):\\d+:\\d+/, // Windows paths\r\n /\\/.*\\/([^\\/]+\\.ts):\\d+:\\d+/, // Generic Unix paths\r\n ];\r\n\r\n for (const pattern of patterns) {\r\n const match = line.match(pattern);\r\n if (match && match[1]) {\r\n return match[1];\r\n }\r\n }\r\n }\r\n }\r\n return null;\r\n } catch {\r\n return null;\r\n }\r\n}\r\n\r\nfunction createLogEntry(\r\n level: LogLevel,\r\n message: string,\r\n data?: any,\r\n operation?: string,\r\n error?: Error\r\n): void {\r\n // Add operation emoji to message if available\r\n if (operation && OPERATION_EMOJIS[operation] && currentConfig.enableEmojis) {\r\n message = `${OPERATION_EMOJIS[operation]} ${message}`;\r\n }\r\n\r\n // Add error details to data if error is provided\r\n if (error) {\r\n data = {\r\n ...data,\r\n error: {\r\n name: error.name,\r\n message: error.message,\r\n stack: error.stack,\r\n },\r\n };\r\n }\r\n\r\n // In production, only use default logger (console only)\r\n if (environment.APP_ENV === \"prod\") {\r\n const logger = getLogger();\r\n switch (level) {\r\n case \"DEBUG\":\r\n logger.debug(message, data);\r\n break;\r\n case \"INFO\":\r\n logger.info(message, data);\r\n break;\r\n case \"WARN\":\r\n logger.warn(message, data);\r\n break;\r\n case \"ERROR\":\r\n logger.error(message, data);\r\n break;\r\n }\r\n return;\r\n }\r\n\r\n // Development mode - use specialized loggers\r\n // Write to errorlog only if level is ERROR\r\n if (level === \"ERROR\") {\r\n const logger = getLogger(\"errorlog\");\r\n logger.error(message, data);\r\n }\r\n // Write to apilog only if API log\r\n const isApiLog = (() => {\r\n const msg = message || \"\";\r\n return (\r\n msg.includes(\"📨\") || // http_request\r\n msg.includes(\"📤\") || // http_response\r\n msg.includes(\"💥\") || // http_error\r\n msg.includes(\"http_request\") ||\r\n msg.includes(\"http_response\") ||\r\n msg.includes(\"http_error\")\r\n );\r\n })();\r\n if (isApiLog) {\r\n const logger = getLogger(\"apilog\");\r\n // Use INFO for API logs\r\n logger.info(message, data);\r\n }\r\n // Always log to default (console + applog)\r\n const logger = getLogger();\r\n switch (level) {\r\n case \"DEBUG\":\r\n logger.debug(message, data);\r\n break;\r\n case \"INFO\":\r\n logger.info(message, data);\r\n break;\r\n case \"WARN\":\r\n logger.warn(message, data);\r\n break;\r\n case \"ERROR\":\r\n logger.error(message, data);\r\n break;\r\n }\r\n}\r\n\r\n/**\r\n * Logs debug information.\r\n */\r\nexport function debug(message: string, data?: any): void {\r\n createLogEntry(\"DEBUG\", message, data);\r\n}\r\n\r\nexport function logDebug(\r\n message: string,\r\n operation?: string,\r\n metadata?: Record\r\n): void {\r\n const caller = getCaller();\r\n const enhancedMetadata = {\r\n ...metadata,\r\n ...(caller ? { source: caller } : {}),\r\n };\r\n createLogEntry(\"DEBUG\", message, enhancedMetadata, operation);\r\n}\r\n\r\n/**\r\n * Logs general information.\r\n */\r\nexport function info(message: string, data?: any): void {\r\n createLogEntry(\"INFO\", message, data);\r\n}\r\n\r\nexport function logInfo(\r\n message: string,\r\n operation?: string,\r\n metadata?: Record\r\n): void {\r\n const caller = getCaller();\r\n const enhancedMetadata = {\r\n ...metadata,\r\n ...(caller ? { source: caller } : {}),\r\n };\r\n createLogEntry(\"INFO\", message, enhancedMetadata, operation);\r\n}\r\n\r\n/**\r\n * Logs warning messages.\r\n */\r\nexport function warn(message: string, data?: any): void {\r\n createLogEntry(\"WARN\", message, data);\r\n}\r\n\r\nexport function logWarn(\r\n message: string,\r\n operation?: string,\r\n metadata?: Record\r\n): void {\r\n const caller = getCaller();\r\n const enhancedMetadata = {\r\n ...metadata,\r\n ...(caller ? { source: caller } : {}),\r\n };\r\n createLogEntry(\"WARN\", message, enhancedMetadata, operation);\r\n}\r\n\r\n/**\r\n * Logs error messages.\r\n */\r\nexport function error(message: string, data?: any): void {\r\n createLogEntry(\"ERROR\", message, data);\r\n}\r\n\r\nexport function logError(\r\n message: string,\r\n error?: Error,\r\n operation?: string,\r\n metadata?: Record\r\n): void {\r\n const caller = getCaller();\r\n const enhancedMetadata = {\r\n ...metadata,\r\n ...(caller ? { source: caller } : {}),\r\n };\r\n createLogEntry(\"ERROR\", message, enhancedMetadata, operation, error);\r\n}\r\n\r\n// ========================================\r\n// Specialized Logging Functions\r\n// ========================================\r\n\r\n/**\r\n * Logs HTTP request information.\r\n */\r\nexport function logHttpRequest(\r\n method: string,\r\n path: string,\r\n clientIP: string,\r\n userAgent?: string\r\n): void {\r\n logInfo(`${method} ${path}`, \"http_request\", {\r\n method,\r\n path,\r\n clientIP,\r\n userAgent,\r\n });\r\n}\r\n\r\n/**\r\n * Logs HTTP response information.\r\n */\r\nexport function logHttpResponse(\r\n method: string,\r\n path: string,\r\n status: number,\r\n duration: number\r\n): void {\r\n const level = status >= 400 ? \"WARN\" : \"INFO\";\r\n const operation = status >= 500 ? \"http_error\" : \"http_response\";\r\n\r\n createLogEntry(\r\n level,\r\n `${method} ${path} - ${status} (${duration}ms)`,\r\n {\r\n method,\r\n path,\r\n status,\r\n duration,\r\n },\r\n operation\r\n );\r\n}\r\n\r\n/**\r\n * Logs security events.\r\n */\r\nexport function logSecurityEvent(event: SecurityEvent): void {\r\n const level =\r\n event.severity === \"critical\" || event.severity === \"high\"\r\n ? \"ERROR\"\r\n : \"WARN\";\r\n\r\n createLogEntry(\r\n level,\r\n `Security event: ${event.type}`,\r\n {\r\n type: event.type,\r\n severity: event.severity,\r\n clientIP: event.clientIP,\r\n userAgent: event.userAgent,\r\n details: event.details,\r\n },\r\n \"security_check\"\r\n );\r\n}\r\n\r\n/**\r\n * Logs performance events.\r\n */\r\nexport function logPerformanceEvent(event: PerformanceEvent): void {\r\n const level = event.success ? \"DEBUG\" : \"WARN\";\r\n\r\n createLogEntry(\r\n level,\r\n `${event.operation} completed in ${event.duration}ms`,\r\n {\r\n operation: event.operation,\r\n duration: event.duration,\r\n success: event.success,\r\n metadata: event.metadata,\r\n },\r\n event.type\r\n );\r\n}\r\n\r\n/**\r\n * Logs database operations.\r\n */\r\nexport function logDatabaseOperation(\r\n operation: string,\r\n table: string,\r\n duration: number,\r\n rowsAffected?: number,\r\n error?: Error\r\n): void {\r\n if (error) {\r\n logError(`Database ${operation} failed on ${table}`, error, \"db_error\", {\r\n table,\r\n duration,\r\n rowsAffected,\r\n });\r\n } else {\r\n logDebug(`Database ${operation} on ${table} (${duration}ms)`, \"db_query\", {\r\n table,\r\n duration,\r\n rowsAffected,\r\n });\r\n }\r\n}\r\n\r\n/**\r\n * Logs nonce operations.\r\n */\r\nexport function logNonceOperation(\r\n operation: \"generate\" | \"validate\" | \"expire\" | \"reuse\",\r\n nonce: string,\r\n bookingId?: string,\r\n metadata?: Record\r\n): void {\r\n const maskedNonce = `${nonce.substring(0, 8)}...`;\r\n const operationMap = {\r\n generate: \"nonce_generate\",\r\n validate: \"nonce_validate\",\r\n expire: \"nonce_expire\",\r\n reuse: \"nonce_validate\",\r\n };\r\n\r\n logInfo(\r\n `Nonce ${operation}: ${maskedNonce}${\r\n bookingId ? ` for booking ${bookingId}` : \"\"\r\n }`,\r\n operationMap[operation],\r\n {\r\n operation,\r\n nonce: maskedNonce,\r\n bookingId,\r\n ...metadata,\r\n }\r\n );\r\n}\r\n\r\n/**\r\n * Logs authentication events.\r\n */\r\nexport function logAuthEvent(\r\n type:\r\n | \"success\"\r\n | \"failure\"\r\n | \"generate\"\r\n | \"validate\"\r\n | \"exchange\"\r\n | \"refresh\"\r\n | \"internal\",\r\n method: string,\r\n clientIP: string,\r\n details?: Record\r\n): void {\r\n const operation = type === \"success\" ? \"auth_success\" : \"auth_failure\";\r\n const level = type === \"success\" ? \"INFO\" : \"WARN\";\r\n\r\n createLogEntry(\r\n level,\r\n `Authentication ${type} via ${method}`,\r\n {\r\n type,\r\n method,\r\n clientIP,\r\n ...details,\r\n },\r\n operation\r\n );\r\n}\r\n\r\n/**\r\n * Logs crypto operations.\r\n */\r\nexport function logCryptoOperation(\r\n operation: \"hash\" | \"sign\" | \"verify\" | \"random\",\r\n algorithm: string,\r\n success: boolean,\r\n duration?: number\r\n): void {\r\n const operationMap = {\r\n hash: \"crypto_hash\",\r\n sign: \"crypto_sign\",\r\n verify: \"crypto_verify\",\r\n random: \"crypto_random\",\r\n };\r\n\r\n logDebug(\r\n `Crypto ${operation} (${algorithm}) - ${success ? \"success\" : \"failed\"}`,\r\n operationMap[operation],\r\n {\r\n operation,\r\n algorithm,\r\n success,\r\n duration,\r\n }\r\n );\r\n}\r\n\r\n// ========================================\r\n// Performance Monitoring\r\n// ========================================\r\n\r\n/**\r\n * Measures and logs the duration of an operation.\r\n */\r\nexport async function measureAndLog(\r\n operation: string,\r\n fn: () => Promise | T,\r\n logLevel: LogLevel = \"DEBUG\"\r\n): Promise {\r\n const startTime = performance.now();\r\n let success = true;\r\n let error: Error | undefined;\r\n\r\n try {\r\n const result = await fn();\r\n return result;\r\n } catch (e) {\r\n success = false;\r\n error = e instanceof Error ? e : new Error(String(e));\r\n throw error;\r\n } finally {\r\n const duration = Math.round(performance.now() - startTime);\r\n\r\n if (error) {\r\n logError(`${operation} failed (${duration}ms)`, error, operation, {\r\n duration,\r\n success,\r\n });\r\n } else {\r\n createLogEntry(\r\n logLevel,\r\n `${operation} completed (${duration}ms)`,\r\n { duration, success },\r\n operation\r\n );\r\n }\r\n }\r\n}\r\n\r\n/**\r\n * Creates a performance timer for manual measurement.\r\n */\r\nexport function createTimer(operation: string) {\r\n const startTime = performance.now();\r\n\r\n return {\r\n stop: (metadata?: Record) => {\r\n const duration = Math.round(performance.now() - startTime);\r\n logDebug(`${operation} completed (${duration}ms)`, operation, {\r\n duration,\r\n ...metadata,\r\n });\r\n return duration;\r\n },\r\n };\r\n}\r\n\r\n// ========================================\r\n// Request Logging Middleware Helper\r\n// ========================================\r\n\r\n/**\r\n * Creates request logging data for middleware.\r\n */\r\nexport function createRequestLog(request: Request): {\r\n correlationId: string;\r\n startTime: number;\r\n logData: Record;\r\n} {\r\n const correlationId = generateCorrelationId();\r\n const startTime = performance.now();\r\n const url = new URL(request.url);\r\n\r\n const logData = {\r\n method: request.method,\r\n path: url.pathname,\r\n query: url.search,\r\n userAgent: request.headers.get(\"user-agent\"),\r\n origin: request.headers.get(\"origin\"),\r\n referer: request.headers.get(\"referer\"),\r\n };\r\n\r\n return { correlationId, startTime, logData };\r\n}\r\n\r\n/**\r\n * Logs request completion.\r\n */\r\nexport function logRequestCompletion(\r\n logData: Record,\r\n response: Response,\r\n startTime: number\r\n): void {\r\n const duration = Math.round(performance.now() - startTime);\r\n\r\n logHttpResponse(logData.method, logData.path, response.status, duration);\r\n}\r\n\r\n// ========================================\r\n// Health Check Logging\r\n// ========================================\r\n\r\n/**\r\n * Logs application startup.\r\n */\r\nexport function logStartup(version: string, environment: string): void {\r\n logInfo(\r\n `ZenServer API v${version} starting in ${environment} mode`,\r\n \"startup\",\r\n { version, environment }\r\n );\r\n}\r\n\r\n/**\r\n * Logs application shutdown.\r\n */\r\nexport function logShutdown(reason: string): void {\r\n logInfo(`ZenServer API shutting down: ${reason}`, \"shutdown\", { reason });\r\n}\r\n\r\n/**\r\n * Logs health check results.\r\n */\r\nexport function logHealthCheck(\r\n service: string,\r\n healthy: boolean,\r\n details?: Record\r\n): void {\r\n const level = healthy ? \"INFO\" : \"ERROR\";\r\n createLogEntry(\r\n level,\r\n `Health check ${service}: ${healthy ? \"healthy\" : \"unhealthy\"}`,\r\n { service, healthy, ...details },\r\n \"health_check\"\r\n );\r\n}\r\n\r\n// ========================================\r\n// Legacy Logger Class (for compatibility)\r\n// ========================================\r\n\r\nclass Logger {\r\n private logLevel: LogLevel;\r\n\r\n constructor(logLevel: LogLevel = \"INFO\") {\r\n this.logLevel = logLevel;\r\n // Initialize on first logger creation\r\n if (!isInitialized) {\r\n initializeLogging({ level: logLevel }).catch(console.error);\r\n }\r\n }\r\n\r\n debug(message: string, data?: any): void {\r\n debug(message, data);\r\n }\r\n\r\n info(message: string, data?: any): void {\r\n info(message, data);\r\n }\r\n\r\n warn(message: string, data?: any): void {\r\n warn(message, data);\r\n }\r\n\r\n error(message: string, data?: any): void {\r\n error(message, data);\r\n }\r\n\r\n // Security-specific logging methods\r\n security(eventType: string, details: any): void {\r\n warn(`SECURITY EVENT: ${eventType}`, details);\r\n }\r\n\r\n audit(action: string, details: any): void {\r\n info(`AUDIT: ${action}`, details);\r\n }\r\n}\r\n\r\n// Create singleton logger instance for compatibility\r\nexport const logger = new Logger(environment.LOG_LEVEL.toUpperCase() as LogLevel);\r\n\r\n// Save original console methods\r\nconst originalConsole = {\r\n log: console.log,\r\n error: console.error,\r\n warn: console.warn,\r\n debug: console.debug,\r\n};\r\n\r\n/**\r\n * Override console methods to use the logger\r\n */\r\nexport function overrideConsole(): void {\r\n console.log = (...args: any[]) => {\r\n const message = args\r\n .map((arg) =>\r\n typeof arg === \"object\" ? JSON.stringify(arg) : String(arg)\r\n )\r\n .join(\" \");\r\n info(message);\r\n };\r\n\r\n console.error = (...args: any[]) => {\r\n const message = args\r\n .map((arg) =>\r\n typeof arg === \"object\" ? JSON.stringify(arg) : String(arg)\r\n )\r\n .join(\" \");\r\n error(message);\r\n };\r\n\r\n console.warn = (...args: any[]) => {\r\n const message = args\r\n .map((arg) =>\r\n typeof arg === \"object\" ? JSON.stringify(arg) : String(arg)\r\n )\r\n .join(\" \");\r\n warn(message);\r\n };\r\n\r\n console.debug = (...args: any[]) => {\r\n const message = args\r\n .map((arg) =>\r\n typeof arg === \"object\" ? JSON.stringify(arg) : String(arg)\r\n )\r\n .join(\" \");\r\n debug(message);\r\n };\r\n}\r\n\r\n/**\r\n * Restore original console methods\r\n */\r\nexport function restoreConsole(): void {\r\n console.log = originalConsole.log;\r\n console.error = originalConsole.error;\r\n console.warn = originalConsole.warn;\r\n console.debug = originalConsole.debug;\r\n}\r\n\r\nexport default {\r\n // Initialization\r\n initializeLogging,\r\n clearLogs,\r\n\r\n // Correlation ID management\r\n generateCorrelationId,\r\n setCorrelationId,\r\n getCorrelationId,\r\n clearCorrelationId,\r\n withCorrelationId,\r\n\r\n // Core logging\r\n logDebug,\r\n logInfo,\r\n logWarn,\r\n logError,\r\n\r\n // Specialized logging\r\n logHttpRequest,\r\n logHttpResponse,\r\n logSecurityEvent,\r\n logPerformanceEvent,\r\n logDatabaseOperation,\r\n logNonceOperation,\r\n logAuthEvent,\r\n logCryptoOperation,\r\n\r\n // Performance monitoring\r\n measureAndLog,\r\n createTimer,\r\n\r\n // Request logging\r\n createRequestLog,\r\n logRequestCompletion,\r\n\r\n // System logging\r\n logStartup,\r\n logShutdown,\r\n logHealthCheck,\r\n\r\n // Console override\r\n overrideConsole,\r\n restoreConsole,\r\n};\r\n","deleted","label",[171,172,153],"src","utils","permalink","https://www.val.town/x/ianmenethil/ZenServer/code/src/utils/logger.ts","extension","actionData","errors"]