api: gate: add playurl to logs (#2133)

livepeer · Apr 16, 2024 · a9aca49 · a9aca49
1 parent 0ed60af
commit a9aca49
Showing 1 changed file with 33 additions and 15 deletions.
diff --git a/packages/api/src/controllers/access-control.ts b/packages/api/src/controllers/access-control.ts
@@ -116,22 +116,40 @@ async function fireGateWebhook(
     );
   }
   if ("pull" in content && content.pull) {
-    let referer: string, origin: string;
-    if (payload?.webhookPayload?.headers) {
-      referer = payload?.webhookPayload?.headers["Referer"];
-      origin = payload?.webhookPayload?.headers["Origin"];
+    try {
+      let referer: string, origin: string;
+      if (payload?.webhookPayload?.headers) {
+        referer = payload?.webhookPayload?.headers["Referer"];
+        origin = payload?.webhookPayload?.headers["Origin"];
+      }
+      let playURL = payload?.webhookPayload?.playURL;
+      let playDomain = payload?.webhookPayload?.playDomain;
+      console.log(
+        `access-control: gate: webhook=${
+          webhook.id
+        } statusCode=${statusCode} respSpanId=${resp?.headers.get(
+          "X-Tlive-Spanid"
+        )} respBody=${Buffer.from(respBody).toString("base64")} duration=${
+          process.hrtime(startTime)[1] / 1e6
+        }ms accessKey=${payload.accessKey} playbackId=${
+          content.playbackId
+        } webhook=${
+          webhook.id
+        } referer=${referer} origin=${origin} playURL=${playURL} playDomain=${playDomain}`
+      );
+    } catch (e) {
+      console.log(
+        `access-control: gate: webhook=${
+          webhook.id
+        } statusCode=${statusCode} respSpanId=${resp?.headers.get(
+          "X-Tlive-Spanid"
+        )} respBody=${Buffer.from(respBody).toString("base64")} duration=${
+          process.hrtime(startTime)[1] / 1e6
+        }ms accessKey=${payload.accessKey} playbackId=${
+          content.playbackId
+        } webhook=${webhook.id}`
+      );
     }
-    console.log(
-      `access-control: gate: webhook=${
-        webhook.id
-      } statusCode=${statusCode} respSpanId=${resp?.headers.get(
-        "X-Tlive-Spanid"
-      )} respBody=${Buffer.from(respBody).toString("base64")} duration=${
-        process.hrtime(startTime)[1] / 1e6
-      }ms accessKey=${payload.accessKey} playbackId=${
-        content.playbackId
-      } webhook=${webhook.id} referer=${referer} origin=${origin}`
-    );
   } else {
     console.log(
       `access-control: gate: webhook=${