Target Server : ${nomo_global.FIXER_SERVER.join(', ')}
Connected Server : ${e.data.fixed.CURRENT_SERVER}
connection attempts: ${e.data.fixed.FIXER_count} / ${nomo_global.FIXER_ATTEMPT_MAX}
${FIXED_FAILED ? "
SERVER FIX FAILED" : ''}
Loading...
`)
.prependTo($player_root);
// Show a failure message for 2 seconds and remove the DOM
if (FIXED_FAILED) {
clearTimeout(SETTIMEOUT_FIXED_FAILED);
SETTIMEOUT_FIXED_FAILED = setTimeout(function () {
$("#fixer_loader").remove();
}, 2000);
}
}
}
}
// else if(e.data.arg === undefined){
// NOMO_DEBUG("undefined case", e);
// } else if(e.data.arg.name !== "enqueue" && e.data.arg.name !== "remove"){NOMO_DEBUG(e.data);}
}
////////////////////////////////////////////////////////////////////////////////////
// Hijacking and Overriding Worker
////////////////////////////////////////////////////////////////////////////////////
var realWorker = unsafeWindow.Worker;
unsafeWindow.Worker = function (input) {
// Explicitly convert to a String
var newInput = String(input);
NOMO_DEBUG("newInput", newInput);
var myBlob = "importScripts('https://static.twitchcdn.net/assets/amazon-ivs-wasmworker.min-7da53ec1e6fb32a92d1d.js');";
var req = new XMLHttpRequest();
req.open('GET', newInput, false);
req.send();
var resText = req.responseText;
if(req.status == 200 || req.status == 201){
myBlob = resText;
}
// overriding blob
var workerBlob = new Blob(
[ /*javascript*/ `
// load global variables
const FIXER = ${nomo_global.FIXER};
const FIXER_SERVER = ${nomo_global.FIXER_SERVER.length > 0 ? '["'+(nomo_global.FIXER_SERVER).join('","')+'"]' : "[]"};
const FIXER_ATTEMPT_MAX = ${nomo_global.FIXER_ATTEMPT_MAX};
const FIXER_DELAY = ${FIXER_DELAY_MIN >= nomo_global.FIXER_DELAY ? nomo_global.FIXER_DELAY : FIXER_DELAY_MIN};
const DEBUG_WORKER = ${nomo_global.DEBUG};
const DEBUG_M3U8 = ${nomo_global.DEBUG_M3U8};
var FIXER_count = 1;
var FIXED = false;
var FIXED_SERVER = undefined;
// debug function in WORKER
var NOMO_DEBUG = function ( /**/ ) {
if (DEBUG_WORKER) {
var args = arguments,
args_length = args.length,
args_copy = args;
for (var i = args_length; i > 0; i--) {
args[i] = args_copy[i - 1];
}
args[0] = "[TSI] ";
args.length = args_length + 1;
console.log.apply(console, args);
}
};
// DEBUG:: check global variables
NOMO_DEBUG({"FIXER":FIXER, "FIXER_SERVER":FIXER_SERVER, "FIXER_ATTEMPT_MAX":FIXER_ATTEMPT_MAX, "FIXER_DELAY":FIXER_DELAY, "DEBUG_WORKER":DEBUG_WORKER, "DEBUG_M3U8":DEBUG_M3U8});
// Explicitly double-check types to prevent errors
if(typeof FIXER !== "boolean" || typeof FIXER_SERVER !== "object"){
FIXER = false;
NOMO_DEBUG("typeof FIXER is not boolean", FIXER, FIXER_SERVER);
}
if(typeof DEBUG_WORKER !== "boolean"){
DEBUG_WORKER = false;
NOMO_DEBUG("typeof DEBUG_WORKER is not boolean", DEBUG_WORKER);
}
if(typeof DEBUG_M3U8 !== "boolean"){
DEBUG_M3U8 = false;
NOMO_DEBUG("typeof DEBUG_M3U8 is not boolean", DEBUG_M3U8);
}
// sleep fuctnion
function sleep(ms) {
return new Promise(resolve => setTimeout(resolve, ms));
}
// Hijacking & overriding the fetch function inside a worker
const originalFetch = self.fetch;
self.fetch = async function(input, init){
// Fixed a conflict with TTV LOL PRO
let inputUrl = (input instanceof Request ? input.url : input.toString());
// Sending messages out of the worker
postMessage({"id":0,"type":"tsi","arg":inputUrl,"fixed":{"FIXED":FIXED,"FIXER_count":FIXER_count}});
// Server Fixer (Auto Reconnector)
if(FIXER
&& FIXER_SERVER !== undefined
&& FIXER_SERVER.length > 0
&& inputUrl.indexOf('usher.ttvnw.net/api/channel/hls') !== -1){
FIXED = false;
FIXER_count = 1;
NOMO_DEBUG("URL detected on first channel connection", inputUrl);
// start iteration
while(!FIXED && FIXER_count <= FIXER_ATTEMPT_MAX){
NOMO_DEBUG("Attempting to auto-select server...");
NOMO_DEBUG("Current Attempt Count", (FIXER_count) + " / " + FIXER_ATTEMPT_MAX);
var m3u8_fetch = await originalFetch.apply(this, arguments);
var m3u8_text = await m3u8_fetch.text();
// NOMO_DEBUG("m3u8_text", m3u8_text);
// check the error
if(m3u8_text.indexOf("error_code") !== -1 || m3u8_text.indexOf("Can not fi") !== -1){
NOMO_DEBUG("Error - Stop Server fixer", {m3u8_text});
break;
}
// check the cluster string
var cluster_str;
if((/CLUSTER=/).test(m3u8_text)){
cluster_str = m3u8_text.split("CLUSTER=")[1].split(",")[0].replace(/"/g,'');
NOMO_DEBUG("Cluster string exists", cluster_str);
for(var SN of FIXER_SERVER){
// If the desired server is found.
if(cluster_str.indexOf(SN) !== -1){
FIXED = true;
NOMO_DEBUG("Server Fixer Success", SN, cluster_str);
break;
}
}
}
// CLUSTER string does not exist, retry
else{
NOMO_DEBUG("CLUSTER string does not exist, retry");
cluster_str = "Server name not found.";
}
// Send a postMessage to display the loader
postMessage({"id":0,"type":"tsi_fixer","arg":"","fixed":{"FIXED":FIXED,"CURRENT_SERVER":cluster_str,"FIXER_count":FIXER_count}});
// When the desired server is found or the maximum count is reached
if(FIXED || FIXER_count === FIXER_ATTEMPT_MAX){
// return as blob
var m3u8_blob = new Blob([m3u8_text], {
type: 'text/plain'
});
var m3u8_blob_url = URL.createObjectURL(m3u8_blob);
var new_arg = arguments;
new_arg[0] = m3u8_blob_url;
NOMO_DEBUG("step2", m3u8_blob_url);
// revoke after 10s
setTimeout(function(){URL.revokeObjectURL(m3u8_blob_url)},10000);
return originalFetch.apply(this, new_arg);
}
else{
// If the desired server is not found
NOMO_DEBUG("The desired server was not found", FIXER_SERVER, cluster_str);
FIXER_count = FIXER_count + 1;
}
// Retry at FIXER_DELAY interval
await sleep(FIXER_DELAY);
} // end of while loop
} // end of if for iteration
// To debug M3U8
if(DEBUG_M3U8 && inputUrl.toLowerCase().indexOf(".m3u8") !== -1){
var m3u8_fetch = await originalFetch.apply(this, arguments);
var m3u8_text = await m3u8_fetch.text();
NOMO_DEBUG("\\n", inputUrl, "\\n", (new Date()), "\\n", m3u8_text);
// return as blob
var m3u8_blob = new Blob([m3u8_text], {
type: 'text/plain'
});
var m3u8_blob_url = URL.createObjectURL(m3u8_blob);
var new_arg = arguments;
new_arg[0] = m3u8_blob_url;
// NOMO_DEBUG("step2", m3u8_blob_url);
// Revoke after 10s
setTimeout(function(){URL.revokeObjectURL(m3u8_blob_url)},10000);
return originalFetch.apply(this, new_arg);
}
if(DEBUG_WORKER && inputUrl.toLowerCase().indexOf('usher.ttvnw.net/api/channel/hls') !== -1){
NOMO_DEBUG("master playlist m3u8 \\n" + inputUrl);
}
return originalFetch.apply(this, arguments);
};
${myBlob};
// override onmessage to debug
// setTimeout(function(){
// console.log(self);
// var old_onmessage = self.onmessage;
// self.onmessage = function(e){
// old_onmessage(e);
// console.log("self", e.data);
// };
// }, 1);
`], {
type: 'text/javascript'
}
);
// end of overriding of blob
var workerBlobUrl = URL.createObjectURL(workerBlob);
var workerBlobWrapper = new Blob(
[ /*javascript*/ `
importScripts('${workerBlobUrl}');
`], {
type: 'text/javascript'
});
var workerBlobWrapperUrl = URL.createObjectURL(workerBlobWrapper);
var my_worker = new realWorker(workerBlobWrapperUrl);
////////////////////////////////////////////////////////////////////////////////////
// Receiving postMessages and creating DOM outside of Worker
////////////////////////////////////////////////////////////////////////////////////
my_worker.onmessage = function (e) {
createTSILayout(e);
};
////////////////////////////////////////////////////////////////////////////////////
// modified Worker
////////////////////////////////////////////////////////////////////////////////////
NOMO_DEBUG("my_worker", my_worker);
// return to the original function that created the worker
return my_worker;
};
})();
}