BinaryNinja/tvapp2
4
1
Fork 0
mirror of https://github.com/TheBinaryNinja/tvapp2.git synced 2026-06-04 06:45:41 -04:00
Code Issues Packages Projects Releases Wiki Activity

refactor: log category labels

Browse Source
This commit is contained in:
Aetherx
2025-05-04 13:29:44 -07:00
parent 5c6756d98f
commit e398e1acc4
1 changed files with 203 additions and 128 deletions
Download Patch File Download Diff File Expand all files Collapse all files

331
tvapp2/index.js
View File

@@ -61,7 +61,6 @@ let FILE_GZP_SIZE = 0;
let FILE_M3U_MODIFIED = 0; let FILE_M3U_MODIFIED = 0;
let FILE_XML_MODIFIED = 0; let FILE_XML_MODIFIED = 0;
let FILE_GZP_MODIFIED = 0; let FILE_GZP_MODIFIED = 0;
const FOLDER_WWW = 'www';
/* /*
Define > Environment Variables || Defaults Define > Environment Variables || Defaults
@@ -318,13 +317,14 @@ const semaphore = new Semaphore( 5 );
async function downloadFile( url, filePath ) async function downloadFile( url, filePath )
{ {
Log.info( `file`, chalk.yellow( `[download]` ), chalk.white( `ℹ️` ),
chalk.blueBright( `<msg>` ), chalk.gray( `Downloading external file` ),
chalk.blueBright( `<src>` ), chalk.gray( `${ url }` ),
chalk.blueBright( `<dest>` ), chalk.gray( `${ filePath }` ) );
return new Promise( ( resolve, reject ) => return new Promise( ( resolve, reject ) =>
{ {
Log.info( `file`, chalk.yellow( `[download]` ), chalk.white( `ℹ️` ),
chalk.blueBright( `<msg>` ), chalk.gray( `Preparing to download external file` ),
chalk.blueBright( `<src>` ), chalk.gray( `${ url }` ),
chalk.blueBright( `<dest>` ), chalk.gray( `${ filePath }` ) );
const isHttps = new URL( url ).protocol === 'https:'; const isHttps = new URL( url ).protocol === 'https:';
const httpModule = isHttps ? https : http; const httpModule = isHttps ? https : http;
const file = fs.createWriteStream( filePath ); const file = fs.createWriteStream( filePath );
@@ -334,10 +334,10 @@ async function downloadFile( url, filePath )
if ( response.statusCode !== 200 ) if ( response.statusCode !== 200 )
{ {
Log.error( `file`, chalk.redBright( `[download]` ), chalk.white( `❌` ), Log.error( `file`, chalk.redBright( `[download]` ), chalk.white( `❌` ),
chalk.redBright( `<msg>` ), chalk.gray( `Attempt to download file returned non-200 status` ), chalk.redBright( `<msg>` ), chalk.gray( `Attempt to download external file returned non-200 status` ),
chalk.redBright( `<code>` ), chalk.gray( `${ response.statusCode }` ),
chalk.redBright( `<src>` ), chalk.gray( `${ url }` ), chalk.redBright( `<src>` ), chalk.gray( `${ url }` ),
chalk.redBright( `<dest>` ), chalk.gray( `${ filePath }` ), chalk.redBright( `<dest>` ), chalk.gray( `${ filePath }` ) );
chalk.redBright( `<code>` ), chalk.gray( `${ response.statusCode }` ) );
return reject( new Error( `Failed to download file: ${ url }. Status code: ${ response.statusCode }` ) ); return reject( new Error( `Failed to download file: ${ url }. Status code: ${ response.statusCode }` ) );
} }
@@ -345,10 +345,10 @@ async function downloadFile( url, filePath )
file.on( 'finish', () => file.on( 'finish', () =>
{ {
Log.ok( `file`, chalk.yellow( `[download]` ), chalk.white( `✅` ), Log.ok( `file`, chalk.yellow( `[download]` ), chalk.white( `✅` ),
chalk.greenBright( `<msg>` ), chalk.gray( `Successfully downloaded and wrote new file` ), chalk.greenBright( `<msg>` ), chalk.gray( `Successfully downloaded external file` ),
chalk.greenBright( `<code>` ), chalk.gray( `${ response.statusCode }` ),
chalk.greenBright( `<src>` ), chalk.gray( `${ url }` ), chalk.greenBright( `<src>` ), chalk.gray( `${ url }` ),
chalk.greenBright( `<dest>` ), chalk.gray( `${ filePath }` ), chalk.greenBright( `<dest>` ), chalk.gray( `${ filePath }` ) );
chalk.greenBright( `<code>` ), chalk.gray( `${ response.statusCode }` ) );
file.close( () => resolve( true ) ); file.close( () => resolve( true ) );
}); });
@@ -356,7 +356,7 @@ async function downloadFile( url, filePath )
.on( 'error', ( err ) => .on( 'error', ( err ) =>
{ {
Log.error( `file`, chalk.redBright( `[download]` ), chalk.white( `❌` ), Log.error( `file`, chalk.redBright( `[download]` ), chalk.white( `❌` ),
chalk.redBright( `<msg>` ), chalk.gray( `Failed to download source file` ), chalk.redBright( `<msg>` ), chalk.gray( `Failed to download external source file` ),
chalk.redBright( `<error>` ), chalk.gray( `${ err.message }` ), chalk.redBright( `<error>` ), chalk.gray( `${ err.message }` ),
chalk.redBright( `<src>` ), chalk.gray( `${ url }` ), chalk.redBright( `<src>` ), chalk.gray( `${ url }` ),
chalk.redBright( `<dest>` ), chalk.gray( `${ filePath }` ) ); chalk.redBright( `<dest>` ), chalk.gray( `${ filePath }` ) );
@@ -442,7 +442,7 @@ async function getFile( url, filePath )
try try
{ {
Log.debug( `file`, chalk.yellow( `[requests]` ), chalk.white( `⚙️` ), Log.debug( `file`, chalk.yellow( `[requests]` ), chalk.white( `⚙️` ),
chalk.blueBright( `<msg>` ), chalk.gray( `Requesting to download file` ), chalk.blueBright( `<msg>` ), chalk.gray( `Requesting to download external file` ),
chalk.blueBright( `<src>` ), chalk.gray( `${ url }` ), chalk.blueBright( `<src>` ), chalk.gray( `${ url }` ),
chalk.blueBright( `<dest>` ), chalk.gray( `${ filePath }` ) ); chalk.blueBright( `<dest>` ), chalk.gray( `${ filePath }` ) );
@@ -453,9 +453,9 @@ async function getFile( url, filePath )
if ( fs.existsSync( filePath ) ) if ( fs.existsSync( filePath ) )
{ {
Log.warn( `file`, chalk.yellow( `[requests]` ), chalk.white( `⚠️` ), Log.warn( `file`, chalk.yellow( `[requests]` ), chalk.white( `⚠️` ),
chalk.blueBright( `<msg>` ), chalk.gray( `Download failed - Using existing local file ${ filePath }` ), chalk.yellowBright( `<msg>` ), chalk.gray( `Download failed - Using existing local file ${ filePath }` ),
chalk.blueBright( `<src>` ), chalk.gray( `${ url }` ), chalk.yellowBright( `<src>` ), chalk.gray( `${ url }` ),
chalk.blueBright( `<dest>` ), chalk.gray( `${ filePath }` ) ); chalk.yellowBright( `<dest>` ), chalk.gray( `${ filePath }` ) );
} }
else else
{ {
@@ -478,76 +478,72 @@ async function getFile( url, filePath )
async function createGzip( ) async function createGzip( )
{ {
Log.info( `gzip`, chalk.yellow( `[generate]` ), chalk.white( `ℹ️` ),
chalk.blueBright( `<msg>` ), chalk.gray( `Preparing to create compressed XML gz file` ),
chalk.blueBright( `<src>` ), chalk.gray( `${ envFileXML }` ),
chalk.blueBright( `<dest>` ), chalk.gray( `${ envFileGZP }` ) );
return new Promise( ( resolve, reject ) => return new Promise( ( resolve, reject ) =>
{ {
Log.debug( `gzip`, chalk.yellow( `[generate]` ), chalk.white( `⚙️` ),
chalk.blueBright( `<msg>` ), chalk.gray( `Promise to create compressed gz started` ), Log.info( `.gzp`, chalk.yellow( `[generate]` ), chalk.white( `ℹ️` ),
chalk.blueBright( `<src>` ), chalk.gray( `${ envFileXML }` ), chalk.blueBright( `<msg>` ), chalk.gray( `Preparing to create compressed XML gz file` ),
chalk.blueBright( `<dest>` ), chalk.gray( `${ envFileGZP }` ) ); chalk.blueBright( `<src>` ), chalk.gray( `${ FILE_XML }` ),
chalk.blueBright( `<dest>` ), chalk.gray( `${ FILE_GZP }` ) );
fs.readFile( FILE_XML, ( err, buf ) => fs.readFile( FILE_XML, ( err, buf ) =>
{ {
Log.debug( `gzip`, chalk.yellow( `[generate]` ), chalk.white( `⚙️` ), Log.debug( `.gzp`, chalk.yellow( `[generate]` ), chalk.white( `⚙️` ),
chalk.blueBright( `<msg>` ), chalk.gray( `Reading source XML file` ), chalk.blueBright( `<msg>` ), chalk.gray( `Reading source XML file` ),
chalk.blueBright( `<src>` ), chalk.gray( `${ envFileXML }` ), chalk.blueBright( `<src>` ), chalk.gray( `${ FILE_XML }` ),
chalk.blueBright( `<dest>` ), chalk.gray( `${ envFileGZP }` ) ); chalk.blueBright( `<dest>` ), chalk.gray( `${ FILE_GZP }` ) );
if ( err ) if ( err )
{ {
Log.error( `gzip`, chalk.redBright( `[generate]` ), chalk.white( `❌` ), Log.error( `.gzp`, chalk.redBright( `[generate]` ), chalk.white( `❌` ),
chalk.redBright( `<msg>` ), chalk.gray( `Could not read source XML file` ), chalk.redBright( `<msg>` ), chalk.gray( `Could not read source XML file` ),
chalk.redBright( `<error>` ), chalk.gray( `${ err }` ), chalk.redBright( `<error>` ), chalk.gray( `${ err }` ),
chalk.redBright( `<src>` ), chalk.gray( `${ envFileXML }` ), chalk.redBright( `<src>` ), chalk.gray( `${ FILE_XML }` ),
chalk.redBright( `<dest>` ), chalk.gray( `${ envFileGZP }` ) ); chalk.redBright( `<dest>` ), chalk.gray( `${ FILE_GZP }` ) );
return reject( new Error( `Could not read file ${ envFileXML }. Error: ${ err }` ) ); return reject( new Error( `Could not read file ${ envFileXML }. Error: ${ err }` ) );
} }
zlib.gzip( buf, ( err, buf ) => zlib.gzip( buf, ( err, buf ) =>
{ {
Log.debug( `gzip`, chalk.yellow( `[generate]` ), chalk.white( `⚙️` ), Log.debug( `.gzp`, chalk.yellow( `[generate]` ), chalk.white( `⚙️` ),
chalk.blueBright( `<msg>` ), chalk.gray( `Starting zlib.gzip` ), chalk.blueBright( `<msg>` ), chalk.gray( `Starting zlib.gzip` ),
chalk.blueBright( `<src>` ), chalk.gray( `${ envFileXML }` ), chalk.blueBright( `<src>` ), chalk.gray( `${ FILE_XML }` ),
chalk.blueBright( `<dest>` ), chalk.gray( `${ envFileGZP }` ) ); chalk.blueBright( `<dest>` ), chalk.gray( `${ FILE_GZP }` ) );
if ( err ) if ( err )
{ {
Log.error( `gzip`, chalk.redBright( `[generate]` ), chalk.white( `❌` ), Log.error( `.gzp`, chalk.redBright( `[generate]` ), chalk.white( `❌` ),
chalk.redBright( `<msg>` ), chalk.gray( `Could not create gz archive` ), chalk.redBright( `<msg>` ), chalk.gray( `Could not create gz archive` ),
chalk.redBright( `<error>` ), chalk.gray( `${ err }` ), chalk.redBright( `<error>` ), chalk.gray( `${ err }` ),
chalk.redBright( `<src>` ), chalk.gray( `${ envFileXML }` ), chalk.redBright( `<src>` ), chalk.gray( `${ FILE_XML }` ),
chalk.redBright( `<dest>` ), chalk.gray( `${ envFileGZP }` ) ); chalk.redBright( `<dest>` ), chalk.gray( `${ FILE_GZP }` ) );
return reject( new Error( `Could not create ${ envFileGZP }. Error: ${ err }` ) ); return reject( new Error( `Could not create ${ envFileGZP }. Error: ${ err }` ) );
} }
Log.info( `gzip`, chalk.yellow( `[generate]` ), chalk.white( `ℹ️` ), Log.info( `.gzp`, chalk.yellow( `[generate]` ), chalk.white( `ℹ️` ),
chalk.blueBright( `<msg>` ), chalk.gray( `Started creating gz archive from XML source` ), chalk.blueBright( `<msg>` ), chalk.gray( `Started creating gz archive from XML source` ),
chalk.blueBright( `<src>` ), chalk.gray( `${ envFileXML }` ), chalk.blueBright( `<src>` ), chalk.gray( `${ FILE_XML }` ),
chalk.blueBright( `<dest>` ), chalk.gray( `${ envFileGZP }` ) ); chalk.blueBright( `<dest>` ), chalk.gray( `${ FILE_GZP }` ) );
fs.writeFile( `${ FILE_GZP }`, buf, ( err ) => fs.writeFile( `${ FILE_GZP }`, buf, ( err ) =>
{ {
if ( err ) if ( err )
{ {
Log.error( `gzip`, chalk.redBright( `[generate]` ), chalk.white( `❌` ), Log.error( `.gzp`, chalk.redBright( `[generate]` ), chalk.white( `❌` ),
chalk.redBright( `<msg>` ), chalk.gray( `Could not write to and create gz archive` ), chalk.redBright( `<msg>` ), chalk.gray( `Could not write to and create gz archive` ),
chalk.redBright( `<error>` ), chalk.gray( `${ err }` ), chalk.redBright( `<error>` ), chalk.gray( `${ err }` ),
chalk.redBright( `<src>` ), chalk.gray( `${ envFileXML }` ), chalk.redBright( `<src>` ), chalk.gray( `${ FILE_XML }` ),
chalk.redBright( `<dest>` ), chalk.gray( `${ envFileGZP }` ) ); chalk.redBright( `<dest>` ), chalk.gray( `${ FILE_GZP }` ) );
return reject( new Error( `Could not write XML file ${ envFileXML } to ${ envFileGZP }. Error: ${ err }` ) ); return reject( new Error( `Could not write XML file ${ envFileXML } to ${ envFileGZP }. Error: ${ err }` ) );
} }
Log.ok( `gzip`, chalk.yellow( `[generate]` ), chalk.white( `✅` ), Log.ok( `.gzp`, chalk.yellow( `[generate]` ), chalk.white( `✅` ),
chalk.greenBright( `<msg>` ), chalk.gray( `Successfully created compressed gz archive from XML source file` ), chalk.greenBright( `<msg>` ), chalk.gray( `Successfully created compressed gz archive from XML source file` ),
chalk.greenBright( `<src>` ), chalk.gray( `${ envFileXML }` ), chalk.greenBright( `<src>` ), chalk.gray( `${ FILE_XML }` ),
chalk.greenBright( `<dest>` ), chalk.gray( `${ envFileGZP }` ) ); chalk.greenBright( `<dest>` ), chalk.gray( `${ FILE_GZP }` ) );
resolve( true ); resolve( true );
}); });
@@ -566,22 +562,29 @@ async function getGzip( )
{ {
try try
{ {
Log.debug( `.gzp`, chalk.yellow( `[requests]` ), chalk.white( `⚙️` ),
chalk.blueBright( `<msg>` ), chalk.gray( `Requesting to create compressed gzip from uncompressed XML data` ),
chalk.blueBright( `<src>` ), chalk.gray( `${ FILE_XML }` ),
chalk.blueBright( `<dest>` ), chalk.gray( `${ FILE_GZP }` ) );
await createGzip( ); await createGzip( );
} }
catch ( err ) catch ( err )
{ {
if ( fs.existsSync( FILE_XML ) ) if ( fs.existsSync( FILE_XML ) )
{ {
Log.warn( `gzip`, chalk.yellow( `[compress]` ), chalk.white( `⚠️` ), Log.warn( `.gzp`, chalk.yellow( `[requests]` ), chalk.white( `⚠️` ),
chalk.blueBright( `<msg>` ), chalk.yellowBright( `Source xml file found, but gzip failed generate a compressed .gz fileL` ), chalk.yellowBright( `<msg>` ), chalk.yellowBright( `Cannot get compressed gzip; but source XML file found and can be used` ),
chalk.blueBright( `<src>` ), chalk.gray( `${ FILE_XML }` ) ); chalk.yellowBright( `<src>` ), chalk.gray( `${ FILE_XML }` ),
chalk.yellowBright( `<dest>` ), chalk.gray( `${ FILE_GZP }` ) );
} }
else else
{ {
Log.error( `gzip`, chalk.redBright( `[compress]` ), chalk.white( `❌` ), Log.error( `.gzp`, chalk.redBright( `[requests]` ), chalk.white( `❌` ),
chalk.redBright( `<msg>` ), chalk.gray( `Source XML file not found; cannot create compressed gzip` ), chalk.redBright( `<msg>` ), chalk.gray( `Failed to get compressed gzip, and source XML file not found` ),
chalk.redBright( `<error>` ), chalk.gray( `${ err.message }` ), chalk.redBright( `<error>` ), chalk.gray( `${ err.message }` ),
chalk.redBright( `<src>` ), chalk.gray( `${ FILE_XML }` ) ); chalk.redBright( `<src>` ), chalk.gray( `${ FILE_XML }` ),
chalk.redBright( `<dest>` ), chalk.gray( `${ FILE_GZP }` ) );
throw err; throw err;
} }
@@ -621,15 +624,17 @@ async function fetchRemote( url, req )
} }
}, ( resp ) => }, ( resp ) =>
{ {
Log.info( `conn`, chalk.yellow( `[retrieve]` ), chalk.white( `ℹ️` ), Log.info( `remo`, chalk.yellow( `[retrieve]` ), chalk.white( `ℹ️` ),
chalk.blueBright( `<msg>` ), chalk.gray( `Processing encoding types for remote fetch` ), chalk.blueBright( `<msg>` ), chalk.gray( `Getting response from remote fetch request` ),
chalk.blueBright( `<client>` ), chalk.gray( `${ clientIp( req ) }` ),
chalk.blueBright( `<code>` ), chalk.gray( `${ resp.statusCode }` ), chalk.blueBright( `<code>` ), chalk.gray( `${ resp.statusCode }` ),
chalk.blueBright( `<url>` ), chalk.gray( `${ url }` ) ); chalk.blueBright( `<url>` ), chalk.gray( `${ url }` ) );
if ( resp.statusCode !== 200 ) if ( resp.statusCode !== 200 )
{ {
Log.error( `conn`, chalk.redBright( `[retrieve]` ), chalk.white( `❌` ), Log.error( `remo`, chalk.redBright( `[retrieve]` ), chalk.white( `❌` ),
chalk.redBright( `<msg>` ), chalk.gray( `Server returned status code other than 200` ), chalk.redBright( `<msg>` ), chalk.gray( `Remote fetch returned status code other than 200` ),
chalk.redBright( `<client>` ), chalk.gray( `${ clientIp( req ) }` ),
chalk.redBright( `<code>` ), chalk.gray( `${ resp.statusCode }` ), chalk.redBright( `<code>` ), chalk.gray( `${ resp.statusCode }` ),
chalk.redBright( `<url>` ), chalk.gray( `${ url }` ) ); chalk.redBright( `<url>` ), chalk.gray( `${ url }` ) );
@@ -650,8 +655,9 @@ async function fetchRemote( url, req )
{ {
if ( err ) if ( err )
{ {
Log.error( `conn`, chalk.redBright( `[retrieve]` ), chalk.white( `❌` ), Log.error( `remo`, chalk.redBright( `[retrieve]` ), chalk.white( `❌` ),
chalk.redBright( `<msg>` ), chalk.gray( `Could not complete encoding type ${ encoding }` ), chalk.redBright( `<msg>` ), chalk.gray( `Remote fetch could not complete encoding type ${ encoding }` ),
chalk.redBright( `<client>` ), chalk.gray( `${ clientIp( req ) }` ),
chalk.redBright( `<error>` ), chalk.gray( `${ err }` ), chalk.redBright( `<error>` ), chalk.gray( `${ err }` ),
chalk.redBright( `<encoding>` ), chalk.gray( `${ encoding }` ), chalk.redBright( `<encoding>` ), chalk.gray( `${ encoding }` ),
chalk.redBright( `<code>` ), chalk.gray( `${ resp.statusCode }` ), chalk.redBright( `<code>` ), chalk.gray( `${ resp.statusCode }` ),
@@ -660,8 +666,9 @@ async function fetchRemote( url, req )
return reject( err ); return reject( err );
} }
Log.debug( `conn`, chalk.yellow( `[retrieve]` ), chalk.white( `⚙️` ), Log.debug( `remo`, chalk.yellow( `[retrieve]` ), chalk.white( `⚙️` ),
chalk.blueBright( `<msg>` ), chalk.gray( `Processing encoding type ${ encoding }` ), chalk.blueBright( `<msg>` ), chalk.gray( `Remote fetch detected encoding type ${ encoding }; decoding` ),
chalk.blueBright( `<client>` ), chalk.gray( `${ clientIp( req ) }` ),
chalk.blueBright( `<encoding>` ), chalk.gray( `${ encoding }` ), chalk.blueBright( `<encoding>` ), chalk.gray( `${ encoding }` ),
chalk.blueBright( `<code>` ), chalk.gray( `${ resp.statusCode }` ), chalk.blueBright( `<code>` ), chalk.gray( `${ resp.statusCode }` ),
chalk.blueBright( `<url>` ), chalk.gray( `${ url }` ) ); chalk.blueBright( `<url>` ), chalk.gray( `${ url }` ) );
@@ -675,8 +682,9 @@ async function fetchRemote( url, req )
{ {
if ( err ) if ( err )
{ {
Log.error( `conn`, chalk.redBright( `[retrieve]` ), chalk.white( `❌` ), Log.error( `remo`, chalk.redBright( `[retrieve]` ), chalk.white( `❌` ),
chalk.redBright( `<msg>` ), chalk.gray( `Could not complete encoding type ${ encoding }` ), chalk.redBright( `<msg>` ), chalk.gray( `Remote fetch could not complete encoding type ${ encoding }` ),
chalk.redBright( `<client>` ), chalk.gray( `${ clientIp( req ) }` ),
chalk.redBright( `<error>` ), chalk.gray( `${ err }` ), chalk.redBright( `<error>` ), chalk.gray( `${ err }` ),
chalk.redBright( `<encoding>` ), chalk.gray( `${ encoding }` ), chalk.redBright( `<encoding>` ), chalk.gray( `${ encoding }` ),
chalk.redBright( `<code>` ), chalk.gray( `${ resp.statusCode }` ), chalk.redBright( `<code>` ), chalk.gray( `${ resp.statusCode }` ),
@@ -685,8 +693,9 @@ async function fetchRemote( url, req )
return reject( err ); return reject( err );
} }
Log.debug( `conn`, chalk.yellow( `[retrieve]` ), chalk.white( `⚙️` ), Log.debug( `remo`, chalk.yellow( `[retrieve]` ), chalk.white( `⚙️` ),
chalk.blueBright( `<msg>` ), chalk.gray( `Processing encoding type ${ encoding }` ), chalk.blueBright( `<msg>` ), chalk.gray( `Remote fetch detected encoding type ${ encoding }; decoding` ),
chalk.blueBright( `<client>` ), chalk.gray( `${ clientIp( req ) }` ),
chalk.blueBright( `<encoding>` ), chalk.gray( `${ encoding }` ), chalk.blueBright( `<encoding>` ), chalk.gray( `${ encoding }` ),
chalk.blueBright( `<code>` ), chalk.gray( `${ resp.statusCode }` ), chalk.blueBright( `<code>` ), chalk.gray( `${ resp.statusCode }` ),
chalk.blueBright( `<url>` ), chalk.gray( `${ url }` ) ); chalk.blueBright( `<url>` ), chalk.gray( `${ url }` ) );
@@ -700,8 +709,9 @@ async function fetchRemote( url, req )
{ {
if ( err ) if ( err )
{ {
Log.error( `conn`, chalk.redBright( `[retrieve]` ), chalk.white( `❌` ), Log.error( `remo`, chalk.redBright( `[retrieve]` ), chalk.white( `❌` ),
chalk.redBright( `<msg>` ), chalk.gray( `Could not complete encoding type ${ encoding } (brotli decompress)` ), chalk.redBright( `<msg>` ), chalk.gray( `Remote fetch could not complete encoding type ${ encoding } (brotli decompress)` ),
chalk.redBright( `<client>` ), chalk.gray( `${ clientIp( req ) }` ),
chalk.redBright( `<error>` ), chalk.gray( `${ err }` ), chalk.redBright( `<error>` ), chalk.gray( `${ err }` ),
chalk.redBright( `<encoding>` ), chalk.gray( `${ encoding }` ), chalk.redBright( `<encoding>` ), chalk.gray( `${ encoding }` ),
chalk.redBright( `<code>` ), chalk.gray( `${ resp.statusCode }` ), chalk.redBright( `<code>` ), chalk.gray( `${ resp.statusCode }` ),
@@ -710,8 +720,9 @@ async function fetchRemote( url, req )
return reject( err ); return reject( err );
} }
Log.debug( `conn`, chalk.yellow( `[retrieve]` ), chalk.white( `⚙️` ), Log.debug( `remo`, chalk.yellow( `[retrieve]` ), chalk.white( `⚙️` ),
chalk.blueBright( `<msg>` ), chalk.gray( `Processing encoding type ${ encoding } (brotli decompress)` ), chalk.blueBright( `<msg>` ), chalk.gray( `Remote fetch detected encoding type ${ encoding } (brotli decompress); decoding` ),
chalk.blueBright( `<client>` ), chalk.gray( `${ clientIp( req ) }` ),
chalk.blueBright( `<encoding>` ), chalk.gray( `${ encoding }` ), chalk.blueBright( `<encoding>` ), chalk.gray( `${ encoding }` ),
chalk.blueBright( `<code>` ), chalk.gray( `${ resp.statusCode }` ), chalk.blueBright( `<code>` ), chalk.gray( `${ resp.statusCode }` ),
chalk.blueBright( `<url>` ), chalk.gray( `${ url }` ) ); chalk.blueBright( `<url>` ), chalk.gray( `${ url }` ) );
@@ -721,6 +732,13 @@ async function fetchRemote( url, req )
} }
else else
{ {
Log.debug( `remo`, chalk.yellow( `[retrieve]` ), chalk.white( `⚙️` ),
chalk.blueBright( `<msg>` ), chalk.gray( `Remote fetch contains no headers to decode; resolving buffer` ),
chalk.blueBright( `<client>` ), chalk.gray( `${ clientIp( req ) }` ),
chalk.blueBright( `<encoding>` ), chalk.gray( `${ encoding }` ),
chalk.blueBright( `<code>` ), chalk.gray( `${ resp.statusCode }` ),
chalk.blueBright( `<url>` ), chalk.gray( `${ url }` ) );
resolve( buffer ); resolve( buffer );
} }
}); });
@@ -729,6 +747,12 @@ async function fetchRemote( url, req )
}); });
} }
/*
Serve Keys
@url https://tvapp2.domain.lan/keys?uri=https://v16.thetvapp.to/hls/WABCDT1/tracks-v2a1/mono.m3u8?token=a0b2C-1ae-qaxAV5iKAd8g&expires=1746394920&user_id=EjLZVsIiJphafFxXRVWRdVWPvzTqpWBZbchvsTwpAlrQZzFuZMpdSn==
*/
async function serveKey( req, res ) async function serveKey( req, res )
{ {
try try
@@ -765,8 +789,8 @@ async function serveKey( req, res )
return res.end( JSON.stringify( statusCheck ) ); return res.end( JSON.stringify( statusCheck ) );
} }
Log.debug( `conn`, chalk.yellow( `[response]` ), chalk.white( `⚙️` ), Log.debug( `keys`, chalk.yellow( `[response]` ), chalk.white( `⚙️` ),
chalk.blueBright( `<msg>` ), chalk.gray( `Valid paramUrl specified; establishing connection` ), chalk.blueBright( `<msg>` ), chalk.gray( `Valid paramUrl specified; establishing connection to serve key to client` ),
chalk.blueBright( `<cat>` ), chalk.gray( `serveKey` ), chalk.blueBright( `<cat>` ), chalk.gray( `serveKey` ),
chalk.blueBright( `<client>` ), chalk.gray( `${ clientIp( req ) }` ), chalk.blueBright( `<client>` ), chalk.gray( `${ clientIp( req ) }` ),
chalk.blueBright( `<url>` ), chalk.gray( `${ req.url }` ), chalk.blueBright( `<url>` ), chalk.gray( `${ req.url }` ),
@@ -777,8 +801,8 @@ async function serveKey( req, res )
'Content-Type': 'application/octet-stream' 'Content-Type': 'application/octet-stream'
}); });
Log.ok( `key`, chalk.yellow( `[response]` ), chalk.white( `✅` ), Log.ok( `keys`, chalk.yellow( `[response]` ), chalk.white( `✅` ),
chalk.greenBright( `<msg>` ), chalk.greenBright( `Found valid uri parameter` ), chalk.greenBright( `<msg>` ), chalk.gray( `Serving key to client` ),
chalk.greenBright( `<cat>` ), chalk.gray( `serveKey` ), chalk.greenBright( `<cat>` ), chalk.gray( `serveKey` ),
chalk.greenBright( `<client>` ), chalk.gray( `${ clientIp( req ) }` ), chalk.greenBright( `<client>` ), chalk.gray( `${ clientIp( req ) }` ),
chalk.greenBright( `<code>` ), chalk.gray( `200` ), chalk.greenBright( `<code>` ), chalk.gray( `200` ),
@@ -795,7 +819,7 @@ async function serveKey( req, res )
ip: envIpContainer, ip: envIpContainer,
gateway: envIpGateway, gateway: envIpGateway,
client: clientIp( req ), client: clientIp( req ),
message: `Failed to serve key; try{} failed`, message: `Failed to serve key; try{} failed. Ensure you specify a valid uri to tvapp / tvpass`,
error: `${ err.message }`, error: `${ err.message }`,
status: 'unhealthy', status: 'unhealthy',
ref: req.url, ref: req.url,
@@ -809,7 +833,7 @@ async function serveKey( req, res )
'Content-Type': 'application/json' 'Content-Type': 'application/json'
}); });
Log.error( `key`, chalk.yellow( `[response]` ), chalk.white( `❌` ), Log.error( `keys`, chalk.yellow( `[response]` ), chalk.white( `❌` ),
chalk.redBright( `<msg>` ), chalk.gray( `${ statusCheck.message }` ), chalk.redBright( `<msg>` ), chalk.gray( `${ statusCheck.message }` ),
chalk.redBright( `<cat>` ), chalk.gray( `serveKey` ), chalk.redBright( `<cat>` ), chalk.gray( `serveKey` ),
chalk.redBright( `<client>` ), chalk.gray( `${ clientIp( req ) }` ), chalk.redBright( `<client>` ), chalk.gray( `${ clientIp( req ) }` ),
@@ -848,7 +872,7 @@ function buildCookieHeader()
return pairs.join( '; ' ); return pairs.join( '; ' );
} }
function fetchPage( url ) function fetchPage( url, req )
{ {
return new Promise( ( resolve, reject ) => return new Promise( ( resolve, reject ) =>
{ {
@@ -865,15 +889,17 @@ function fetchPage( url )
{ {
Log.info( `http`, chalk.yellow( `[retrieve]` ), chalk.white( `ℹ️` ), Log.info( `http`, chalk.yellow( `[retrieve]` ), chalk.white( `ℹ️` ),
chalk.blueBright( `<msg>` ), chalk.gray( `status code returned` ), chalk.blueBright( `<msg>` ), chalk.gray( `status code returned` ),
chalk.blueBright( `<url>` ), chalk.gray( `${ url }` ), chalk.blueBright( `<client>` ), chalk.gray( `${ clientIp( req ) }` ),
chalk.blueBright( `<status>` ), chalk.gray( `${ res.statusCode }` ) ); chalk.blueBright( `<code>` ), chalk.gray( `${ res.statusCode }` ),
chalk.blueBright( `<url>` ), chalk.gray( `${ url }` ) );
if ( res.statusCode !== 200 ) if ( res.statusCode !== 200 )
{ {
Log.debug( `http`, chalk.yellow( `[retrieve]` ), chalk.white( `⚙️` ), Log.debug( `http`, chalk.yellow( `[retrieve]` ), chalk.white( `⚙️` ),
chalk.blueBright( `<msg>` ), chalk.gray( `failed to load url; status 200 was not returned` ), chalk.blueBright( `<msg>` ), chalk.gray( `failed to load url; status 200 was not returned` ),
chalk.blueBright( `<url>` ), chalk.gray( `${ url }` ), chalk.blueBright( `<client>` ), chalk.gray( `${ clientIp( req ) }` ),
chalk.blueBright( `<status>` ), chalk.gray( `${ res.statusCode }` ) ); chalk.blueBright( `<code>` ), chalk.gray( `${ res.statusCode }` ),
chalk.blueBright( `<url>` ), chalk.gray( `${ url }` ) );
return reject( new Error( `page did not return code 200 status ${ res.statusCode } => ${ url }` ) ); return reject( new Error( `page did not return code 200 status ${ res.statusCode } => ${ url }` ) );
} }
@@ -881,10 +907,11 @@ function fetchPage( url )
if ( res.headers['set-cookie']) if ( res.headers['set-cookie'])
{ {
Log.debug( `http`, chalk.yellow( `[retrieve]` ), chalk.white( `⚙️` ), Log.debug( `http`, chalk.yellow( `[retrieve]` ), chalk.white( `⚙️` ),
chalk.blueBright( `<msg>` ), chalk.gray( `setting headers` ), chalk.blueBright( `<msg>` ), chalk.gray( `setting headers` ),
chalk.blueBright( `<url>` ), chalk.gray( `${ url }` ), chalk.blueBright( `<client>` ), chalk.gray( `${ clientIp( req ) }` ),
chalk.blueBright( `<header>` ), chalk.gray( `set-cookie` ), chalk.blueBright( `<code>` ), chalk.gray( `${ res.statusCode }` ),
chalk.blueBright( `<status>` ), chalk.gray( `${ res.statusCode }` ) ); chalk.blueBright( `<url>` ), chalk.gray( `${ url }` ),
chalk.blueBright( `<header>` ), chalk.gray( `set-cookie` ) );
parseSetCookieHeaders( res.headers['set-cookie']); parseSetCookieHeaders( res.headers['set-cookie']);
} }
@@ -901,13 +928,12 @@ async function getTokenizedUrl( channelUrl, req )
{ {
try try
{ {
const html = await fetchPage( channelUrl ); const html = await fetchPage( channelUrl, req );
let streamName; let streamName;
let streamHost; let streamHost;
Log.debug( `m3u8`, chalk.yellow( `[tokenize]` ), chalk.white( `⚙️` ), Log.debug( `play`, chalk.yellow( `[tokenize]` ), chalk.white( `⚙️` ),
chalk.blueBright( `<msg>` ), chalk.gray( `Attempting to tokenize url ` ), chalk.blueBright( `<msg>` ), chalk.gray( `Requesting to get tokenize url ` ),
chalk.blueBright( `<client>` ), chalk.gray( `${ clientIp( req ) }` ), chalk.blueBright( `<client>` ), chalk.gray( `${ clientIp( req ) }` ),
chalk.blueBright( `<channelUrl>` ), chalk.gray( `${ channelUrl }` ) ); chalk.blueBright( `<channelUrl>` ), chalk.gray( `${ channelUrl }` ) );
@@ -924,7 +950,7 @@ async function getTokenizedUrl( channelUrl, req )
const streamNameMatch = html.match( /id="stream_name" name="([^"]+)"/ ); const streamNameMatch = html.match( /id="stream_name" name="([^"]+)"/ );
if ( !streamNameMatch ) if ( !streamNameMatch )
{ {
Log.error( `m3u8`, chalk.yellow( `[tokenize]` ), chalk.white( `❌` ), Log.error( `play`, chalk.yellow( `[tokenize]` ), chalk.white( `❌` ),
chalk.redBright( `<msg>` ), chalk.gray( `Cannot find streamNameMatch; returned empty` ), chalk.redBright( `<msg>` ), chalk.gray( `Cannot find streamNameMatch; returned empty` ),
chalk.redBright( `<client>` ), chalk.gray( `${ clientIp( req ) }` ), chalk.redBright( `<client>` ), chalk.gray( `${ clientIp( req ) }` ),
chalk.redBright( `<url>` ), chalk.grey( `${ channelUrl }` ), chalk.redBright( `<url>` ), chalk.grey( `${ channelUrl }` ),
@@ -935,7 +961,7 @@ async function getTokenizedUrl( channelUrl, req )
streamName = streamNameMatch[1]; streamName = streamNameMatch[1];
Log.debug( `m3u8`, chalk.yellow( `[tokenize]` ), chalk.white( `⚙️` ), Log.debug( `play`, chalk.yellow( `[tokenize]` ), chalk.white( `⚙️` ),
chalk.blueBright( `<msg>` ), chalk.gray( `streamName found` ), chalk.blueBright( `<msg>` ), chalk.gray( `streamName found` ),
chalk.blueBright( `<client>` ), chalk.gray( `${ clientIp( req ) }` ), chalk.blueBright( `<client>` ), chalk.gray( `${ clientIp( req ) }` ),
chalk.blueBright( `<channelUrl>` ), chalk.gray( `${ channelUrl }` ), chalk.blueBright( `<channelUrl>` ), chalk.gray( `${ channelUrl }` ),
@@ -954,10 +980,10 @@ async function getTokenizedUrl( channelUrl, req )
}; };
const tokenUrl = `https://${ streamHost }/token/${ streamName }?quality=${ envStreamQuality.toLowerCase() }`; const tokenUrl = `https://${ streamHost }/token/${ streamName }?quality=${ envStreamQuality.toLowerCase() }`;
const tokenResponse = await fetchPage( tokenUrl ); const tokenResponse = await fetchPage( tokenUrl, req );
let tokenizedUrl; let tokenizedUrl;
Log.debug( `m3u8`, chalk.yellow( `[tokenize]` ), chalk.white( `⚙️` ), Log.debug( `play`, chalk.yellow( `[tokenize]` ), chalk.white( `⚙️` ),
chalk.blueBright( `<msg>` ), chalk.gray( `Generating tokenized final stream URL` ), chalk.blueBright( `<msg>` ), chalk.gray( `Generating tokenized final stream URL` ),
chalk.blueBright( `<client>` ), chalk.gray( `${ clientIp( req ) }` ), chalk.blueBright( `<client>` ), chalk.gray( `${ clientIp( req ) }` ),
chalk.blueBright( `<channelUrl>` ), chalk.gray( `${ channelUrl }` ), chalk.blueBright( `<channelUrl>` ), chalk.gray( `${ channelUrl }` ),
@@ -972,7 +998,7 @@ async function getTokenizedUrl( channelUrl, req )
const json = JSON.parse( tokenResponse ); const json = JSON.parse( tokenResponse );
tokenizedUrl = json.url; tokenizedUrl = json.url;
Log.debug( `m3u8`, chalk.yellow( `[tokenize]` ), chalk.white( `⚙️` ), Log.debug( `play`, chalk.yellow( `[tokenize]` ), chalk.white( `⚙️` ),
chalk.blueBright( `<msg>` ), chalk.gray( `Returned token response in json format` ), chalk.blueBright( `<msg>` ), chalk.gray( `Returned token response in json format` ),
chalk.blueBright( `<client>` ), chalk.gray( `${ clientIp( req ) }` ), chalk.blueBright( `<client>` ), chalk.gray( `${ clientIp( req ) }` ),
chalk.blueBright( `<channelUrl>` ), chalk.gray( `${ channelUrl }` ), chalk.blueBright( `<channelUrl>` ), chalk.gray( `${ channelUrl }` ),
@@ -985,7 +1011,7 @@ async function getTokenizedUrl( channelUrl, req )
} }
catch ( err ) catch ( err )
{ {
Log.error( `m3u8`, chalk.redBright( `[tokenize]` ), chalk.white( `❌` ), Log.error( `play`, chalk.redBright( `[tokenize]` ), chalk.white( `❌` ),
chalk.redBright( `<msg>` ), chalk.gray( `Failed to parse token JSON for channel` ), chalk.redBright( `<msg>` ), chalk.gray( `Failed to parse token JSON for channel` ),
chalk.redBright( `<client>` ), chalk.gray( `${ clientIp( req ) }` ), chalk.redBright( `<client>` ), chalk.gray( `${ clientIp( req ) }` ),
chalk.redBright( `<channelUrl>` ), chalk.gray( `${ channelUrl }` ), chalk.redBright( `<channelUrl>` ), chalk.gray( `${ channelUrl }` ),
@@ -1000,7 +1026,7 @@ async function getTokenizedUrl( channelUrl, req )
if ( !tokenizedUrl ) if ( !tokenizedUrl )
{ {
Log.error( `m3u8`, chalk.redBright( `[tokenize]` ), chalk.white( `❌` ), Log.error( `play`, chalk.redBright( `[tokenize]` ), chalk.white( `❌` ),
chalk.redBright( `<msg>` ), chalk.gray( `No URL found in token JSON for channel` ), chalk.redBright( `<msg>` ), chalk.gray( `No URL found in token JSON for channel` ),
chalk.redBright( `<client>` ), chalk.gray( `${ clientIp( req ) }` ), chalk.redBright( `<client>` ), chalk.gray( `${ clientIp( req ) }` ),
chalk.redBright( `<channelUrl>` ), chalk.gray( `${ channelUrl }` ), chalk.redBright( `<channelUrl>` ), chalk.gray( `${ channelUrl }` ),
@@ -1013,7 +1039,7 @@ async function getTokenizedUrl( channelUrl, req )
return null; return null;
} }
Log.ok( `m3u8`, chalk.yellow( `[tokenize]` ), chalk.white( `✅` ), Log.ok( `play`, chalk.yellow( `[tokenize]` ), chalk.white( `✅` ),
chalk.greenBright( `<msg>` ), chalk.gray( `Successfully generated token for stream` ), chalk.greenBright( `<msg>` ), chalk.gray( `Successfully generated token for stream` ),
chalk.greenBright( `<client>` ), chalk.gray( `${ clientIp( req ) }` ), chalk.greenBright( `<client>` ), chalk.gray( `${ clientIp( req ) }` ),
chalk.greenBright( `<channelUrl>` ), chalk.gray( `${ channelUrl }` ), chalk.greenBright( `<channelUrl>` ), chalk.gray( `${ channelUrl }` ),
@@ -1028,7 +1054,7 @@ async function getTokenizedUrl( channelUrl, req )
} }
catch ( err ) catch ( err )
{ {
Log.error( `m3u8`, chalk.redBright( `[tokenize]` ), chalk.white( `❌` ), Log.error( `play`, chalk.redBright( `[tokenize]` ), chalk.white( `❌` ),
chalk.redBright( `<msg>` ), chalk.gray( `Fatal error fetching token` ), chalk.redBright( `<msg>` ), chalk.gray( `Fatal error fetching token` ),
chalk.redBright( `<client>` ), chalk.gray( `${ clientIp( req ) }` ), chalk.redBright( `<client>` ), chalk.gray( `${ clientIp( req ) }` ),
chalk.redBright( `<error>` ), chalk.gray( `${ err.message }` ), chalk.redBright( `<error>` ), chalk.gray( `${ err.message }` ),
@@ -1047,6 +1073,11 @@ async function serveM3UPlaylist( req, res )
await semaphore.acquire(); await semaphore.acquire();
try try
{ {
Log.debug( `plst`, chalk.yellow( `[requests]` ), chalk.white( `⚙️` ),
chalk.blueBright( `<msg>` ), chalk.gray( `Requesting to serve M3U playlist` ),
chalk.blueBright( `<client>` ), chalk.gray( `${ clientIp( req ) }` ),
chalk.blueBright( `<url>` ), chalk.gray( `${ req.url }` ) );
/* /*
paramUrl > decodedUrl > tokenizedUrl paramUrl > decodedUrl > tokenizedUrl
*/ */
@@ -1072,7 +1103,7 @@ async function serveM3UPlaylist( req, res )
'Content-Type': 'application/json' 'Content-Type': 'application/json'
}); });
Log.error( `m3u8`, chalk.redBright( `[response]` ), chalk.white( `❌` ), Log.error( `plst`, chalk.redBright( `[response]` ), chalk.white( `❌` ),
chalk.redBright( `<msg>` ), chalk.gray( `${ statusCheck.message }` ), chalk.redBright( `<msg>` ), chalk.gray( `${ statusCheck.message }` ),
chalk.redBright( `<cat>` ), chalk.gray( `serveM3UPlaylist` ), chalk.redBright( `<cat>` ), chalk.gray( `serveM3UPlaylist` ),
chalk.redBright( `<code>` ), chalk.gray( `${ statusCheck.code }` ), chalk.redBright( `<code>` ), chalk.gray( `${ statusCheck.code }` ),
@@ -1090,7 +1121,7 @@ async function serveM3UPlaylist( req, res )
Location: decodedUrl Location: decodedUrl
}); });
Log.notice( `m3u8`, chalk.yellow( `[response]` ), chalk.white( `📌` ), Log.notice( `plst`, chalk.yellow( `[response]` ), chalk.white( `📌` ),
chalk.yellowBright( `<msg>` ), chalk.gray( `decodedUrl ends with .ts script; (302) redirecting` ), chalk.yellowBright( `<msg>` ), chalk.gray( `decodedUrl ends with .ts script; (302) redirecting` ),
chalk.yellowBright( `<cat>` ), chalk.gray( `serveM3UPlaylist` ), chalk.yellowBright( `<cat>` ), chalk.gray( `serveM3UPlaylist` ),
chalk.yellowBright( `<code>` ), chalk.gray( `302` ), chalk.yellowBright( `<code>` ), chalk.gray( `302` ),
@@ -1112,8 +1143,8 @@ async function serveM3UPlaylist( req, res )
'Content-Disposition': 'inline; filename="' + envFileM3U 'Content-Disposition': 'inline; filename="' + envFileM3U
}); });
Log.debug( `m3u8`, chalk.yellow( `[response]` ), chalk.white( `⚙️` ), Log.debug( `plst`, chalk.yellow( `[response]` ), chalk.white( `⚙️` ),
chalk.blueBright( `<msg>` ), chalk.gray( `serving already cached m3u playlist to client` ), chalk.blueBright( `<msg>` ), chalk.gray( `serving cachedUrl m3u playlist to client` ),
chalk.blueBright( `<cat>` ), chalk.gray( `serveM3UPlaylist` ), chalk.blueBright( `<cat>` ), chalk.gray( `serveM3UPlaylist` ),
chalk.blueBright( `<code>` ), chalk.gray( `200` ), chalk.blueBright( `<code>` ), chalk.gray( `200` ),
chalk.blueBright( `<client>` ), chalk.gray( `${ clientIp( req ) }` ), chalk.blueBright( `<client>` ), chalk.gray( `${ clientIp( req ) }` ),
@@ -1125,7 +1156,8 @@ async function serveM3UPlaylist( req, res )
return; return;
} }
Log.info( `m3u8`, chalk.yellow( `[response]` ), chalk.white( `ℹ️` ), Log.info( `plst`, chalk.yellow( `[response]` ), chalk.white( `ℹ️` ),
chalk.blueBright( `<msg>` ), chalk.gray( `request not cached; generating new tokenizedUrl for m3u playlist to client` ),
chalk.blueBright( `<client>` ), chalk.gray( `${ clientIp( req ) }` ), chalk.blueBright( `<client>` ), chalk.gray( `${ clientIp( req ) }` ),
chalk.blueBright( `<cat>` ), chalk.gray( `serveM3UPlaylist` ), chalk.blueBright( `<cat>` ), chalk.gray( `serveM3UPlaylist` ),
chalk.blueBright( `<paramUrl>` ), chalk.gray( `${ paramUrl }` ), chalk.blueBright( `<paramUrl>` ), chalk.gray( `${ paramUrl }` ),
@@ -1157,7 +1189,7 @@ async function serveM3UPlaylist( req, res )
'Content-Type': 'application/json' 'Content-Type': 'application/json'
}); });
Log.error( `m3u8`, chalk.redBright( `[response]` ), chalk.white( `❌` ), Log.error( `plst`, chalk.redBright( `[response]` ), chalk.white( `❌` ),
chalk.redBright( `<msg>` ), chalk.gray( `${ statusCheck.message }` ), chalk.redBright( `<msg>` ), chalk.gray( `${ statusCheck.message }` ),
chalk.redBright( `<cat>` ), chalk.gray( `serveM3UPlaylist` ), chalk.redBright( `<cat>` ), chalk.gray( `serveM3UPlaylist` ),
chalk.redBright( `<code>` ), chalk.gray( `${ statusCheck.code }` ), chalk.redBright( `<code>` ), chalk.gray( `${ statusCheck.code }` ),
@@ -1166,7 +1198,6 @@ async function serveM3UPlaylist( req, res )
chalk.redBright( `<tokenizedUrl>` ), chalk.gray( `${ tokenizedUrl }` ) ); chalk.redBright( `<tokenizedUrl>` ), chalk.gray( `${ tokenizedUrl }` ) );
res.end( JSON.stringify( statusCheck ) ); res.end( JSON.stringify( statusCheck ) );
return; return;
} }
@@ -1179,18 +1210,17 @@ async function serveM3UPlaylist( req, res )
'Content-Disposition': 'inline; filename="' + envFileM3U 'Content-Disposition': 'inline; filename="' + envFileM3U
}); });
res.end( rewrittenPlaylist ); Log.ok( `plst`, chalk.yellow( `[response]` ), chalk.white( `✅` ),
chalk.greenBright( `<msg>` ), chalk.gray( `Serving new tokenizedUrl with m3u playlist to client` ),
Log.ok( `m3u8`, chalk.yellow( `[response]` ), chalk.white( `✅` ),
chalk.greenBright( `<msg>` ), chalk.gray( `Serving new playlist to client` ),
chalk.greenBright( `<cat>` ), chalk.gray( `serveM3UPlaylist` ), chalk.greenBright( `<cat>` ), chalk.gray( `serveM3UPlaylist` ),
chalk.greenBright( `<client>` ), chalk.gray( `${ clientIp( req ) }` ), chalk.greenBright( `<client>` ), chalk.gray( `${ clientIp( req ) }` ),
chalk.greenBright( `<code>` ), chalk.gray( `200` ), chalk.greenBright( `<code>` ), chalk.gray( `200` ),
chalk.greenBright( `<playlist>` ), chalk.gray( `${ envFileM3U }` ), chalk.greenBright( `<playlist>` ), chalk.gray( `${ envFileM3U }` ),
chalk.greenBright( `<paramUrl>` ), chalk.gray( `${ paramUrl }` ), chalk.greenBright( `<paramUrl>` ), chalk.gray( `${ paramUrl }` ),
chalk.greenBright( `<decodedUrl>` ), chalk.gray( `${ decodedUrl }` ), chalk.greenBright( `<decodedUrl>` ), chalk.gray( `${ decodedUrl }` ),
chalk.greenBright( `<tokenizedUrl>` ), chalk.gray( `${ tokenizedUrl }` ), chalk.greenBright( `<tokenizedUrl>` ), chalk.gray( `${ tokenizedUrl }` ) );
chalk.greenBright( `<hdUrl>` ), chalk.gray( `${ hdUrl }` ) );
res.end( rewrittenPlaylist );
} }
catch ( err ) catch ( err )
{ {
@@ -1215,7 +1245,7 @@ async function serveM3UPlaylist( req, res )
'Content-Type': 'application/json' 'Content-Type': 'application/json'
}); });
Log.error( `m3u8`, chalk.redBright( `[response]` ), chalk.white( `❌` ), Log.error( `plst`, chalk.redBright( `[response]` ), chalk.white( `❌` ),
chalk.redBright( `<msg>` ), chalk.gray( `Failed to serve m3u playlist` ), chalk.redBright( `<msg>` ), chalk.gray( `Failed to serve m3u playlist` ),
chalk.redBright( `<cat>` ), chalk.gray( `serveM3UPlaylist` ), chalk.redBright( `<cat>` ), chalk.gray( `serveM3UPlaylist` ),
chalk.redBright( `<error>` ), chalk.gray( `${ statusCheck.message }` ), chalk.redBright( `<error>` ), chalk.gray( `${ statusCheck.message }` ),
@@ -1261,10 +1291,10 @@ async function serveHealthCheck( req, res )
}); });
Log.ok( `/api`, chalk.yellow( `[health]` ), chalk.white( `✅` ), Log.ok( `/api`, chalk.yellow( `[health]` ), chalk.white( `✅` ),
chalk.greenBright( `<msg>` ), chalk.gray( `health check response` ), chalk.greenBright( `<msg>` ), chalk.gray( `response` ),
chalk.greenBright( `<client>` ), chalk.gray( `${ clientIp( req ) }` ), chalk.greenBright( `<client>` ), chalk.gray( `${ clientIp( req ) }` ),
chalk.greenBright( `<status>` ), chalk.gray( `${ statusCheck.status }` ),
chalk.greenBright( `<code>` ), chalk.gray( `${ statusCheck.code }` ), chalk.greenBright( `<code>` ), chalk.gray( `${ statusCheck.code }` ),
chalk.greenBright( `<status>` ), chalk.gray( `${ statusCheck.status }` ),
chalk.greenBright( `<uptime>` ), chalk.gray( `${ process.uptime() }` ) ); chalk.greenBright( `<uptime>` ), chalk.gray( `${ process.uptime() }` ) );
res.end( JSON.stringify( statusCheck ) ); res.end( JSON.stringify( statusCheck ) );
@@ -1295,8 +1325,8 @@ async function serveHealthCheck( req, res )
Log.error( `/api`, chalk.redBright( `[health]` ), chalk.white( `❌` ), Log.error( `/api`, chalk.redBright( `[health]` ), chalk.white( `❌` ),
chalk.redBright( `<msg>` ), chalk.gray( `${ statusCheck.message } response` ), chalk.redBright( `<msg>` ), chalk.gray( `${ statusCheck.message } response` ),
chalk.redBright( `<status>` ), chalk.gray( `${ statusCheck.status }` ),
chalk.redBright( `<code>` ), chalk.gray( `${ statusCheck.code }` ), chalk.redBright( `<code>` ), chalk.gray( `${ statusCheck.code }` ),
chalk.redBright( `<status>` ), chalk.gray( `${ statusCheck.status }` ),
chalk.redBright( `<client>` ), chalk.gray( `${ clientIp( req ) }` ), chalk.redBright( `<client>` ), chalk.gray( `${ clientIp( req ) }` ),
chalk.redBright( `<error>` ), chalk.gray( `${ err.message }` ), chalk.redBright( `<error>` ), chalk.gray( `${ err.message }` ),
chalk.redBright( `<uptime>` ), chalk.gray( `${ process.uptime() }` ) ); chalk.redBright( `<uptime>` ), chalk.gray( `${ process.uptime() }` ) );
@@ -1316,7 +1346,7 @@ async function serveHealthCheck( req, res )
async function rewriteM3U( originalUrl, req ) async function rewriteM3U( originalUrl, req )
{ {
const rawData = await fetchRemote( originalUrl ); const rawData = await fetchRemote( originalUrl, req );
const protocol = req.headers['x-forwarded-proto']?.split( ',' )[0] || ( req.socket.encrypted ? 'https' : 'http' ); const protocol = req.headers['x-forwarded-proto']?.split( ',' )[0] || ( req.socket.encrypted ? 'https' : 'http' );
const host = req.headers.host; const host = req.headers.host;
const baseUrl = `${ protocol }://${ host }`; const baseUrl = `${ protocol }://${ host }`;
@@ -1366,7 +1396,7 @@ async function serveM3U( res, req )
'Content-Disposition': 'inline; filename="' + envFileM3U 'Content-Disposition': 'inline; filename="' + envFileM3U
}); });
Log.ok( `m3u8`, chalk.yellow( `[response]` ), chalk.white( `✅` ), Log.ok( `.m3u`, chalk.yellow( `[response]` ), chalk.white( `✅` ),
chalk.greenBright( `<msg>` ), chalk.gray( `Successfully served m3u8 channel playlist data` ), chalk.greenBright( `<msg>` ), chalk.gray( `Successfully served m3u8 channel playlist data` ),
chalk.greenBright( `<cat>` ), chalk.gray( `serveM3U` ), chalk.greenBright( `<cat>` ), chalk.gray( `serveM3U` ),
chalk.greenBright( `<code>` ), chalk.gray( `200` ), chalk.greenBright( `<code>` ), chalk.gray( `200` ),
@@ -1398,7 +1428,7 @@ async function serveM3U( res, req )
'Content-Type': 'application/json' 'Content-Type': 'application/json'
}); });
Log.error( `m3u8`, chalk.yellow( `[response]` ), chalk.white( `❌` ), Log.error( `.m3u`, chalk.yellow( `[response]` ), chalk.white( `❌` ),
chalk.redBright( `<msg>` ), chalk.gray( `${ statusCheck.message }` ), chalk.redBright( `<msg>` ), chalk.gray( `${ statusCheck.message }` ),
chalk.redBright( `<cat>` ), chalk.gray( `serveM3U` ), chalk.redBright( `<cat>` ), chalk.gray( `serveM3U` ),
chalk.redBright( `<code>` ), chalk.gray( `${ statusCheck.code }` ), chalk.redBright( `<code>` ), chalk.gray( `${ statusCheck.code }` ),
@@ -1429,7 +1459,7 @@ async function serveXML( res, req )
'Content-Disposition': 'inline; filename="' + envFileXML 'Content-Disposition': 'inline; filename="' + envFileXML
}); });
Log.ok( `xml`, chalk.yellow( `[response]` ), chalk.white( `✅` ), Log.ok( `.xml`, chalk.yellow( `[response]` ), chalk.white( `✅` ),
chalk.greenBright( `<msg>` ), chalk.gray( `Successfully served uncompressed xml / epg guide data` ), chalk.greenBright( `<msg>` ), chalk.gray( `Successfully served uncompressed xml / epg guide data` ),
chalk.greenBright( `<cat>` ), chalk.gray( `serveXML` ), chalk.greenBright( `<cat>` ), chalk.gray( `serveXML` ),
chalk.greenBright( `<code>` ), chalk.gray( `200` ), chalk.greenBright( `<code>` ), chalk.gray( `200` ),
@@ -1461,7 +1491,7 @@ async function serveXML( res, req )
'Content-Type': 'text/plain' 'Content-Type': 'text/plain'
}); });
Log.error( `xml`, chalk.yellow( `[response]` ), chalk.white( `❌` ), Log.error( `.xml`, chalk.yellow( `[response]` ), chalk.white( `❌` ),
chalk.redBright( `<msg>` ), chalk.gray( `${ statusCheck.message }` ), chalk.redBright( `<msg>` ), chalk.gray( `${ statusCheck.message }` ),
chalk.redBright( `<cat>` ), chalk.gray( `serveXML` ), chalk.redBright( `<cat>` ), chalk.gray( `serveXML` ),
chalk.redBright( `<code>` ), chalk.gray( `${ statusCheck.code }` ), chalk.redBright( `<code>` ), chalk.gray( `${ statusCheck.code }` ),
@@ -1492,7 +1522,7 @@ async function serveGZP( res, req )
'Content-Disposition': 'inline; filename="' + envFileGZP 'Content-Disposition': 'inline; filename="' + envFileGZP
}); });
Log.ok( `gzip`, chalk.yellow( `[response]` ), chalk.white( `✅` ), Log.ok( `.gzp`, chalk.yellow( `[response]` ), chalk.white( `✅` ),
chalk.greenBright( `<msg>` ), chalk.gray( `Successfully served compressed gzip xml/epg guide data` ), chalk.greenBright( `<msg>` ), chalk.gray( `Successfully served compressed gzip xml/epg guide data` ),
chalk.greenBright( `<cat>` ), chalk.gray( `serveGZP` ), chalk.greenBright( `<cat>` ), chalk.gray( `serveGZP` ),
chalk.greenBright( `<code>` ), chalk.gray( `200` ), chalk.greenBright( `<code>` ), chalk.gray( `200` ),
@@ -1524,7 +1554,7 @@ async function serveGZP( res, req )
'Content-Type': 'text/plain' 'Content-Type': 'text/plain'
}); });
Log.error( `gzip`, chalk.yellow( `[response]` ), chalk.white( `❌` ), Log.error( `.gzp`, chalk.yellow( `[response]` ), chalk.white( `❌` ),
chalk.redBright( `<msg>` ), chalk.gray( `${ statusCheck.message }` ), chalk.redBright( `<msg>` ), chalk.gray( `${ statusCheck.message }` ),
chalk.redBright( `<cat>` ), chalk.gray( `serveGZP` ), chalk.redBright( `<cat>` ), chalk.gray( `serveGZP` ),
chalk.redBright( `<code>` ), chalk.gray( `${ statusCheck.code }` ), chalk.redBright( `<code>` ), chalk.gray( `${ statusCheck.code }` ),
@@ -1599,13 +1629,13 @@ async function initialize()
chalk.blueBright( `<containerIp>` ), chalk.gray( `${ envIpContainer }` ), chalk.blueBright( `<containerIp>` ), chalk.gray( `${ envIpContainer }` ),
chalk.blueBright( `<port>` ), chalk.gray( `${ envWebPort }` ) ); chalk.blueBright( `<port>` ), chalk.gray( `${ envWebPort }` ) );
Log.debug( `.env`, chalk.yellow( `[assigner]` ), chalk.white( `⚙️` ), /*
chalk.blueBright( `<variable>` ), chalk.gray( `FILE_URL` ), Debug > network
chalk.blueBright( `<value>` ), chalk.gray( `${ FILE_URL }` ) ); */
Log.debug( `.env`, chalk.yellow( `[assigner]` ), chalk.white( `⚙️` ), Log.debug( `.net`, chalk.yellow( `[assigner]` ), chalk.white( `⚙️` ), chalk.blueBright( `<name>` ), chalk.gray( `IP_CONTAINER` ), chalk.blueBright( `<value>` ), chalk.gray( `${ envIpContainer }` ) );
chalk.blueBright( `<variable>` ), chalk.gray( `FILE_M3U` ), Log.debug( `.net`, chalk.yellow( `[assigner]` ), chalk.white( `⚙️` ), chalk.blueBright( `<name>` ), chalk.gray( `IP_GATEWAY` ), chalk.blueBright( `<value>` ), chalk.gray( `${ envIpGateway }` ) );
chalk.blueBright( `<value>` ), chalk.gray( `${ FILE_M3U }` ) ); Log.debug( `.env`, chalk.yellow( `[assigner]` ), chalk.white( `⚙️` ), chalk.blueBright( `<name>` ), chalk.gray( `RELEASE` ), chalk.blueBright( `<value>` ), chalk.gray( `${ envAppRelease }` ) );
/* /*
Debug > Verbose > environment vars Debug > Verbose > environment vars
@@ -1617,6 +1647,51 @@ async function initialize()
Log.verbose( `.env`, chalk.yellow( `[assigner]` ), chalk.white( `📣` ), chalk.blueBright( `<name>` ), chalk.gray( `${ key }` ), chalk.blueBright( `<value>` ), chalk.gray( `${ env[key] }` ) ); Log.verbose( `.env`, chalk.yellow( `[assigner]` ), chalk.white( `📣` ), chalk.blueBright( `<name>` ), chalk.gray( `${ key }` ), chalk.blueBright( `<value>` ), chalk.gray( `${ env[key] }` ) );
}); });
/*
Debug > environment vars
we could just loop process.env; but that will show every container env var. We just want this app
*/
Log.debug( `.env`, chalk.yellow( `[assigner]` ), chalk.white( `⚙️` ), chalk.blueBright( `<name>` ), chalk.gray( `URL_REPO` ), chalk.blueBright( `<value>` ), chalk.gray( `${ envUrlRepo }` ) );
Log.debug( `.env`, chalk.yellow( `[assigner]` ), chalk.white( `⚙️` ), chalk.blueBright( `<name>` ), chalk.gray( `WEB_IP` ), chalk.blueBright( `<value>` ), chalk.gray( `${ envWebIP }` ) );
Log.debug( `.env`, chalk.yellow( `[assigner]` ), chalk.white( `⚙️` ), chalk.blueBright( `<name>` ), chalk.gray( `WEB_PORT` ), chalk.blueBright( `<value>` ), chalk.gray( `${ envWebPort }` ) );
Log.debug( `.env`, chalk.yellow( `[assigner]` ), chalk.white( `⚙️` ), chalk.blueBright( `<name>` ), chalk.gray( `WEB_FOLDER` ), chalk.blueBright( `<value>` ), chalk.gray( `${ envWebFolder }` ) );
Log.debug( `.env`, chalk.yellow( `[assigner]` ), chalk.white( `⚙️` ), chalk.blueBright( `<name>` ), chalk.gray( `WEB_ENCODING` ), chalk.blueBright( `<value>` ), chalk.gray( `${ envWebEncoding }` ) );
Log.debug( `.env`, chalk.yellow( `[assigner]` ), chalk.white( `⚙️` ), chalk.blueBright( `<name>` ), chalk.gray( `WEB_PROXY_HEADER` ), chalk.blueBright( `<value>` ), chalk.gray( `${ envProxyHeader }` ) );
Log.debug( `.env`, chalk.yellow( `[assigner]` ), chalk.white( `⚙️` ), chalk.blueBright( `<name>` ), chalk.gray( `STREAM_QUALITY` ), chalk.blueBright( `<value>` ), chalk.gray( `${ envStreamQuality }` ) );
Log.debug( `.env`, chalk.yellow( `[assigner]` ), chalk.white( `⚙️` ), chalk.blueBright( `<name>` ), chalk.gray( `API_KEY` ), chalk.blueBright( `<value>` ), chalk.gray( `${ envApiKey }` ) );
Log.debug( `.env`, chalk.yellow( `[assigner]` ), chalk.white( `⚙️` ), chalk.blueBright( `<name>` ), chalk.gray( `FILE_URL` ), chalk.blueBright( `<value>` ), chalk.gray( `${ envFileURL }` ) );
Log.debug( `.env`, chalk.yellow( `[assigner]` ), chalk.white( `⚙️` ), chalk.blueBright( `<name>` ), chalk.gray( `FILE_M3U` ), chalk.blueBright( `<value>` ), chalk.gray( `${ envFileM3U }` ) );
Log.debug( `.env`, chalk.yellow( `[assigner]` ), chalk.white( `⚙️` ), chalk.blueBright( `<name>` ), chalk.gray( `FILE_EPG` ), chalk.blueBright( `<value>` ), chalk.gray( `${ envFileXML }` ) );
Log.debug( `.env`, chalk.yellow( `[assigner]` ), chalk.white( `⚙️` ), chalk.blueBright( `<name>` ), chalk.gray( `FILE_GZP` ), chalk.blueBright( `<value>` ), chalk.gray( `${ envFileGZP }` ) );
Log.debug( `.env`, chalk.yellow( `[assigner]` ), chalk.white( `⚙️` ), chalk.blueBright( `<name>` ), chalk.gray( `HEALTH_TIMER` ), chalk.blueBright( `<value>` ), chalk.gray( `${ envHealthTimer }` ) );
Log.debug( `.env`, chalk.yellow( `[assigner]` ), chalk.white( `⚙️` ), chalk.blueBright( `<name>` ), chalk.gray( `LOG_LEVEL` ), chalk.blueBright( `<value>` ), chalk.gray( `${ LOG_LEVEL }` ) );
Log.debug( `.env`, chalk.yellow( `[assigner]` ), chalk.white( `⚙️` ), chalk.blueBright( `<name>` ), chalk.gray( `USERAGENT` ), chalk.blueBright( `<value>` ), chalk.gray( `${ USERAGENT }` ) );
/*
Debug > vars > external urls
*/
Log.debug( `.var`, chalk.yellow( `[assigner]` ), chalk.white( `⚙️` ), chalk.blueBright( `<name>` ), chalk.gray( `extURL` ), chalk.blueBright( `<value>` ), chalk.gray( `${ extURL }` ) );
Log.debug( `.var`, chalk.yellow( `[assigner]` ), chalk.white( `⚙️` ), chalk.blueBright( `<name>` ), chalk.gray( `extXML` ), chalk.blueBright( `<value>` ), chalk.gray( `${ extXML }` ) );
Log.debug( `.var`, chalk.yellow( `[assigner]` ), chalk.white( `⚙️` ), chalk.blueBright( `<name>` ), chalk.gray( `extM3U` ), chalk.blueBright( `<value>` ), chalk.gray( `${ extM3U }` ) );
/*
Debug > vars > subdomain keywords
*/
Log.debug( `.var`, chalk.yellow( `[assigner]` ), chalk.white( `⚙️` ), chalk.blueBright( `<name>` ), chalk.gray( `subdomainGZP` ), chalk.blueBright( `<value>` ), chalk.gray( `${ subdomainGZP.join() }` ) );
Log.debug( `.var`, chalk.yellow( `[assigner]` ), chalk.white( `⚙️` ), chalk.blueBright( `<name>` ), chalk.gray( `subdomainM3U` ), chalk.blueBright( `<value>` ), chalk.gray( `${ subdomainM3U.join() }` ) );
Log.debug( `.var`, chalk.yellow( `[assigner]` ), chalk.white( `⚙️` ), chalk.blueBright( `<name>` ), chalk.gray( `subdomainEPG` ), chalk.blueBright( `<value>` ), chalk.gray( `${ subdomainEPG.join() }` ) );
Log.debug( `.var`, chalk.yellow( `[assigner]` ), chalk.white( `⚙️` ), chalk.blueBright( `<name>` ), chalk.gray( `subdomainKey` ), chalk.blueBright( `<value>` ), chalk.gray( `${ subdomainKey.join() }` ) );
Log.debug( `.var`, chalk.yellow( `[assigner]` ), chalk.white( `⚙️` ), chalk.blueBright( `<name>` ), chalk.gray( `subdomainChan` ), chalk.blueBright( `<value>` ), chalk.gray( `${ subdomainChan.join() }` ) );
Log.debug( `.var`, chalk.yellow( `[assigner]` ), chalk.white( `⚙️` ), chalk.blueBright( `<name>` ), chalk.gray( `subdomainHealth` ), chalk.blueBright( `<value>` ), chalk.gray( `${ subdomainHealth.join() }` ) );
Log.debug( `.var`, chalk.yellow( `[assigner]` ), chalk.white( `⚙️` ), chalk.blueBright( `<name>` ), chalk.gray( `subdomainRestart` ), chalk.blueBright( `<value>` ), chalk.gray( `${ subdomainRestart.join() }` ) );
/*
get files
*/
await getFile( extURL, FILE_URL ); await getFile( extURL, FILE_URL );
await getFile( extXML, FILE_XML ); await getFile( extXML, FILE_XML );
@@ -2034,7 +2109,7 @@ const server = http.createServer( ( request, response ) =>
{ {
if ( !envApiKey ) if ( !envApiKey )
Log.warn( `/api`, chalk.yellow( `[callback]` ), chalk.white( `⚠️` ), Log.warn( `/api`, chalk.yellow( `[callback]` ), chalk.white( `⚠️` ),
chalk.blueBright( `<msg>` ), chalk.gray( `API_KEY environment variable not defined for api, leaving blank` ) ); chalk.yellowBright( `<msg>` ), chalk.gray( `API_KEY environment variable not defined for api, leaving blank` ) );
else else
Log.ok( `/api`, chalk.yellow( `[callback]` ), chalk.white( `✅` ), Log.ok( `/api`, chalk.yellow( `[callback]` ), chalk.white( `✅` ),
chalk.greenBright( `<msg>` ), chalk.gray( `API_KEY environment variable successfully assigned` ) ); chalk.greenBright( `<msg>` ), chalk.gray( `API_KEY environment variable successfully assigned` ) );