From d3c8d79fbcb5944d485a0d3e91aa9a8d765ddd31 Mon Sep 17 00:00:00 2001 From: Alexander Onnikov Date: Wed, 11 Jun 2025 17:53:31 +0700 Subject: [PATCH] add logging to love webhook handlers (#9214) Signed-off-by: Alexander Onnikov --- services/love/src/main.ts | 19 +++++++++++++++++-- 1 file changed, 17 insertions(+), 2 deletions(-) diff --git a/services/love/src/main.ts b/services/love/src/main.ts index 16df0c779f..f3e4229ef3 100644 --- a/services/love/src/main.ts +++ b/services/love/src/main.ts @@ -105,6 +105,8 @@ export const main = async (): Promise => { const event = await receiver.receive(req.body, req.get('Authorization')) if (event.event === 'egress_ended' && event.egressInfo !== undefined) { for (const res of event.egressInfo.fileResults) { + ctx.info('webhook event', { event: event.event, egress: event.egressInfo }) + const data = dataByUUID.get(res.filename) if (data !== undefined && storageConfig !== undefined) { const storedBlob = await saveFile(ctx, data.wsIds, storageConfig, s3storageConfig, res.filename) @@ -119,12 +121,25 @@ export const main = async (): Promise => { } } - await saveLiveKitEgressBilling(ctx, event.egressInfo) + try { + await saveLiveKitEgressBilling(ctx, event.egressInfo) + } catch { + // Ensure we don't fail the webhook if billing fails + } res.send() return + } else if (event.event === 'room_started' && event.room !== undefined) { + const { sid, name } = event.room + ctx.info('webhook event', { event: event.event, room: { sid, name } }) } else if (event.event === 'room_finished' && event.room !== undefined) { - await saveLiveKitSessionBilling(ctx, event.room.sid) + const { sid, name } = event.room + ctx.info('webhook event', { event: event.event, room: { sid, name } }) + try { + await saveLiveKitSessionBilling(ctx, event.room.sid) + } catch { + // Ensure we don't fail the webhook if billing fails + } res.send() return }