Add logging

package.json

@@ -1,6 +1,6 @@
 {
   "name": "odo-stream",
-  "version": "1.3.0",
+  "version": "1.3.1",
   "scripts": {
     "dev": "next dev",
     "build": "next build",

src/app/api/live/route.ts

@@ -3,16 +3,29 @@ import { NextRequest, NextResponse } from 'next/server'
 
 import { RS_URL, STREAM_TOKEN_COOKIE_NAME } from '../../../constants'
 import { verify } from '../../../lib/jwt'
+import * as logger from '../../../lib/logger'
 
 export const dynamic = 'force-dynamic'
 export const fetchCache = 'force-no-store'
 export const revalidate = 0
 
 export async function GET(request: NextRequest): Promise<Response> {
-  try {
-    const token = request.cookies.get(STREAM_TOKEN_COOKIE_NAME)
-    const claims = token ? await verify(token.value) : undefined
+  const ip =
+    request.headers.get('x-real-ip') ||
+    request.headers.get('x-forwarded-for') ||
+    request.ip
+  const token = request.cookies.get(STREAM_TOKEN_COOKIE_NAME)
+  const claims = token ? await verify(token.value) : undefined
+
+  const meta = {
+    geo: request.geo?.city as string,
+    ip: ip as string,
+    viewerId: claims?.viewerId as string,
+  }
 
+  logger.info('Live request', meta)
+
+  try {
     if (!claims) {
       throw HttpError.Unauthorized('Invalid token')
     }
@@ -31,6 +44,8 @@ export async function GET(request: NextRequest): Promise<Response> {
       cause: e,
     })
 
+    logger.error(`Live error: ${error.message}`, meta)
+
     return new NextResponse(error.message)
   }
 }

src/components/player.tsx

@@ -18,7 +18,7 @@ const hlsConfig = {
   initialLiveManifestSize: 2, // preload 2 chunks before autostart
   liveDurationInfinity: true, // instructs browser that video is live
   liveMaxLatencyDuration: 10, // if higher than this, adujst to liveSyncDuration
-  liveSyncDuration: 3, // how close to live to target? shorter than 3sec causes frequent buffering issues
+  liveSyncDuration: 5, // how close to live to target? shorter than 3sec causes frequent buffering issues
   lowLatencyMode: true, // enable low latency mode
   maxBufferLength: 10, // limit forward buffer
   maxLiveSyncPlaybackRate: 2, // if running behind, speed up video

src/lib/logger.ts

@@ -0,0 +1,26 @@
+export enum LOG_LEVEL {
+  INFO = 'INFO',
+  WARN = 'WARN',
+  ERROR = 'ERROR',
+}
+
+const loggerFn = {
+  [LOG_LEVEL.ERROR]: console.error,
+  [LOG_LEVEL.INFO]: console.log,
+  [LOG_LEVEL.WARN]: console.warn,
+}
+
+export function log(level: LOG_LEVEL) {
+  return (message: string, meta: Record<string, string> = {}) => {
+    const metaString = Object.entries(meta)
+      .filter(([, value]) => Boolean(value))
+      .map(([key, value]) => `[${key}=${value}]`)
+      .join('')
+
+    loggerFn[level](`[${level}]${metaString} ${message}`)
+  }
+}
+
+export const info = log(LOG_LEVEL.INFO)
+export const warn = log(LOG_LEVEL.WARN)
+export const error = log(LOG_LEVEL.ERROR)