wkulhanek/bonob
1
0
Fork 0
mirror of https://github.com/wkulhanek/bonob.git synced 2025-12-21 17:33:29 +01:00
Code Issues 1 Packages Projects Releases Wiki Activity

Add additional debug logging around /stream endpoint

Browse Source
This commit is contained in:
simojenki
2021-09-30 10:30:49 +10:00
parent 1cf7453908
commit fbb621c7c4
1 changed files with 6 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
src/server.ts
View File

@@ -3,6 +3,7 @@ import express, { Express, Request } from "express";
import * as Eta from "eta"; import * as Eta from "eta";
import path from "path"; import path from "path";
import sharp from "sharp"; import sharp from "sharp";
import { v4 as uuid } from "uuid";
import { PassThrough, Transform, TransformCallback } from "stream"; import { PassThrough, Transform, TransformCallback } from "stream";
@@ -289,8 +290,10 @@ function server(
app.get("/stream/track/:id", async (req, res) => { app.get("/stream/track/:id", async (req, res) => {
const id = req.params["id"]!; const id = req.params["id"]!;
const trace = uuid();
logger.info( logger.info(
`-> /stream/track/${id}, headers=${JSON.stringify(req.headers)}` `${trace} bnb<- ${req.method} /stream/track/${id}, headers=${JSON.stringify(req.headers)}`
); );
const authToken = pipe( const authToken = pipe(
req.header(BONOB_ACCESS_TOKEN_HEADER), req.header(BONOB_ACCESS_TOKEN_HEADER),
@@ -313,7 +316,7 @@ function server(
) )
.then(({ stream }) => { .then(({ stream }) => {
logger.info( logger.info(
`stream response from music service for ${id}, status=${ `${trace} bnb<- stream response from music service for ${id}, status=${
stream.status stream.status
}, headers=(${JSON.stringify(stream.headers)})` }, headers=(${JSON.stringify(stream.headers)})`
); );
@@ -337,7 +340,7 @@ function server(
sendStream: boolean; sendStream: boolean;
}) => { }) => {
logger.info( logger.info(
`<- /stream/track/${id}, status=${status}, headers=${JSON.stringify( `${trace} bnb-> /stream/track/${id}, status=${status}, headers=${JSON.stringify(
headers headers
)}` )}`
); );