+ setS3Headers(res, s3Response)
+
+ const streamReplacer = filename.endsWith('.m3u8') && doReinjectVideoFileToken(req)
+ ? new StreamReplacer(line => injectQueryToPlaylistUrls(line, buildReinjectVideoFileTokenQuery(req, filename.endsWith('master.m3u8'))))
+ : new PassThrough()
+
+ return pipeline(
+ stream,
+ streamReplacer,
+ res,
+ err => {
+ if (!err) return
+
+ handleObjectStorageFailure(res, err)
+ }
+ )