1
0
mirror of https://github.com/pixeltris/TwitchAdSolutions.git synced 2024-11-22 10:22:51 +01:00

Add "notify-swap" #59 and "vaft" #61

- Added "notify-swap" #59 which swaps the entire stream during ads instead of stripping ad segments. This should fix freezing issues on firefox.
- Added "vaft" #61 which is "Video Ad-Block, for Twitch" (fork) as a script.
- Removed "proxy" as there is a better open source alternative https://github.com/arthurbolsoni/Purple-adblock/
- Unlist "bypass" as it's built into ublock origin and doesn't really work anymore (though may reduce prerolls).
- Updated misc links in full-list.md
This commit is contained in:
pixeltris 2022-03-31 16:33:10 +01:00
parent d5bb05df2a
commit bd96135e24
14 changed files with 2815 additions and 1775 deletions

View File

@ -13,9 +13,9 @@ Proxies are the most reliable way of avoiding ads ([buffering / downtime info](f
Alternatively: Alternatively:
- `Video Ad-Block, for Twitch` (forked) - [chrome (manual install)](https://github.com/cleanlock/VideoAdBlockForTwitch#installation-steps) / [code](https://github.com/cleanlock/VideoAdBlockForTwitch) - `Video Ad-Block, for Twitch` (fork) - [chrome (manual install)](https://github.com/cleanlock/VideoAdBlockForTwitch#installation-steps) / [code](https://github.com/cleanlock/VideoAdBlockForTwitch)
- `Alternate Player for Twitch.tv` - [chrome](https://chrome.google.com/webstore/detail/alternate-player-for-twit/bhplkbgoehhhddaoolmakpocnenplmhf) / [firefox](https://addons.mozilla.org/en-US/firefox/addon/twitch_5/) - `Alternate Player for Twitch.tv` - [chrome](https://chrome.google.com/webstore/detail/alternate-player-for-twit/bhplkbgoehhhddaoolmakpocnenplmhf) / [firefox](https://addons.mozilla.org/en-US/firefox/addon/twitch_5/)
- `notify-strip` - see below - `notify-strip` / `notify-swap` / `vaft` - see below
[Read this for a full list and descriptions.](full-list.md) [Read this for a full list and descriptions.](full-list.md)
@ -27,15 +27,14 @@ Alternatively:
- Ad segments are replaced by low resolution stream segments. - Ad segments are replaced by low resolution stream segments.
- Notifies Twitch that ads were "watched" (reduces preroll ad frequency). - Notifies Twitch that ads were "watched" (reduces preroll ad frequency).
- *You may experience a small jump in time when the regular stream kicks in*. - *You may experience a small jump in time when the regular stream kicks in*.
- notify-reload ([ublock](https://github.com/pixeltris/TwitchAdSolutions/raw/master/notify-reload/notify-reload-ublock-origin.js) / [userscript](https://github.com/pixeltris/TwitchAdSolutions/raw/master/notify-reload/notify-reload.user.js)) - notify-swap ([ublock](https://github.com/pixeltris/TwitchAdSolutions/raw/master/notify-swap/notify-swap-ublock-origin.js) / [userscript](https://github.com/pixeltris/TwitchAdSolutions/raw/master/notify-swap/notify-swap.user.js))
- Notifies that ads were watched, then reloads the player (preroll only, falls back to `notify-strip` on midroll). - The same as `notify-strip` with a slightly different method to fix freezing issues (especially on Firefox).
- Repeats this until no ads **(which may never happen ~ infinite reload)**. - *Has a longer jump in time compared to `notify-strip`*.
- You should expect 3-10 player reloads (give or take). Once successful you shouldn't see preroll ads for a while on any stream (10+ minutes?). - vaft ([ublock](https://github.com/pixeltris/TwitchAdSolutions/raw/master/vaft/vaft-ublock-origin.js) / [userscript](https://github.com/pixeltris/TwitchAdSolutions/raw/master/vaft/vaft.user.js))
- `Video Ad-Block, for Twitch` (fork) as a script.
- low-res ([ublock](https://github.com/pixeltris/TwitchAdSolutions/raw/master/low-res/low-res-ublock-origin.js) / [userscript](https://github.com/pixeltris/TwitchAdSolutions/raw/master/low-res/low-res.user.js)) - low-res ([ublock](https://github.com/pixeltris/TwitchAdSolutions/raw/master/low-res/low-res-ublock-origin.js) / [userscript](https://github.com/pixeltris/TwitchAdSolutions/raw/master/low-res/low-res.user.js))
- No ads. - No ads.
- The stream is 480p for the duration of the stream. - The stream is 480p for the duration of the stream.
- bypass ([ublock](https://github.com/pixeltris/TwitchAdSolutions/raw/master/bypass/bypass-ublock-origin.js) / [userscript](https://github.com/pixeltris/TwitchAdSolutions/raw/master/bypass/bypass.user.js))
- No ads *(no longer works for many people)*.
## Applying a script (uBlock Origin) ## Applying a script (uBlock Origin)

View File

@ -4,7 +4,7 @@
- Uses a proxy on the main m3u8 file to get a stream without ads. - Uses a proxy on the main m3u8 file to get a stream without ads.
- `Purple AdBlock` - [chrome](https://chrome.google.com/webstore/detail/purple-adblock/lkgcfobnmghhbhgekffaadadhmeoindg) / [firefox](https://addons.mozilla.org/en-US/firefox/addon/purpleadblock/) / [code](https://github.com/arthurbolsoni/Purple-adblock/) - `Purple AdBlock` - [chrome](https://chrome.google.com/webstore/detail/purple-adblock/lkgcfobnmghhbhgekffaadadhmeoindg) / [firefox](https://addons.mozilla.org/en-US/firefox/addon/purpleadblock/) / [code](https://github.com/arthurbolsoni/Purple-adblock/)
- Uses a proxy on the main m3u8 file to get a stream without ads. - Uses a proxy on the main m3u8 file to get a stream without ads.
- `Video Ad-Block, for Twitch` (forked) - [chrome (manual install)](https://github.com/cleanlock/VideoAdBlockForTwitch#installation-steps) / [code](https://github.com/cleanlock/VideoAdBlockForTwitch) - `Video Ad-Block, for Twitch` (fork) - [chrome (manual install)](https://github.com/cleanlock/VideoAdBlockForTwitch#installation-steps) / [code](https://github.com/cleanlock/VideoAdBlockForTwitch)
- Replaces ad segments with ad-free segments (480p resolution). Afterwards it invokes a pause/play to resync the player which then continues normally (normal resolution). - Replaces ad segments with ad-free segments (480p resolution). Afterwards it invokes a pause/play to resync the player which then continues normally (normal resolution).
- `Alternate Player for Twitch.tv` - [chrome](https://chrome.google.com/webstore/detail/alternate-player-for-twit/bhplkbgoehhhddaoolmakpocnenplmhf) / [firefox](https://addons.mozilla.org/en-US/firefox/addon/twitch_5/) - `Alternate Player for Twitch.tv` - [chrome](https://chrome.google.com/webstore/detail/alternate-player-for-twit/bhplkbgoehhhddaoolmakpocnenplmhf) / [firefox](https://addons.mozilla.org/en-US/firefox/addon/twitch_5/)
- Removes ad segments (no playback until ad-free stream). - Removes ad segments (no playback until ad-free stream).
@ -21,7 +21,7 @@
*Compile from source* *Compile from source*
- `city17` - [server code](https://github.com/AlyoshaVasilieva/city17) / [extension code](https://github.com/AlyoshaVasilieva/city17-ext) - `luminous-ttv` - [server code](https://github.com/AlyoshaVasilieva/luminous-ttv) / [extension code](https://github.com/AlyoshaVasilieva/luminous-ttv-ext)
- Uses a proxy on the main m3u8 file to get a stream without ads. - Uses a proxy on the main m3u8 file to get a stream without ads.
## Web browser scripts (uBlock Origin / userscript) ## Web browser scripts (uBlock Origin / userscript)
@ -40,17 +40,13 @@
## Applications / third party websites ## Applications / third party websites
- `streamlink` - [code](https://github.com/streamlink/streamlink) / [website](https://streamlink.github.io/streamlink-twitch-gui/) - `streamlink` - [code](https://github.com/streamlink/streamlink) / [website](https://streamlink.github.io/streamlink-twitch-gui/)
- Removes ad segments (no playback until ad-free stream). - Removes ad segments (no playback until ad-free stream).
- `multiChat for Twitch` - [android](https://play.google.com/store/apps/details?id=org.mchatty) - `Xtra for Twitch` (fork) - [apks](https://github.com/crackededed/Xtra/releases) [code](https://github.com/crackededed/Xtra)
- Unsure how this one blocks ads, but it claims that it does. - Android app. I think this blocks ads, but I'm not 100% sure. If not maybe try [Twire](https://github.com/twireapp/Twire).
- https://twitchls.com/ - https://twitchls.com/
- Uses the `embed` player. Purple screen may display every 10-15 mins. - Uses the `embed` player. Purple screen may display every 10-15 mins.
- https://reddit.com/r/Twitch/comments/kisdsy/i_did_a_little_test_regarding_ads_on_twitch_and/ - https://reddit.com/r/Twitch/comments/kisdsy/i_did_a_little_test_regarding_ads_on_twitch_and/
- Some countries don't get ads. A simple VPN/VPS could be used to block ads by proxying the m3u8 without having to proxy all your traffic (just the initial m3u8). - Some countries don't get ads. A simple VPN/VPS could be used to block ads by proxying the m3u8 without having to proxy all your traffic (just the initial m3u8).
## Additional lists
- https://github.com/saucettv/WorkingTwitchAdBlockers
## Proxy issues ## Proxy issues
Proxy solutions can have downtime and you'll either see ads or error 2000. This isn't Twitch retaliating. Proxy solutions can have downtime and you'll either see ads or error 2000. This isn't Twitch retaliating.

View File

@ -0,0 +1,664 @@
twitch-videoad.js application/javascript
(function() {
if ( /(^|\.)twitch\.tv$/.test(document.location.hostname) === false ) { return; }
function declareOptions(scope) {
// Options / globals
scope.OPT_ROLLING_DEVICE_ID = true;
scope.OPT_MODE_STRIP_AD_SEGMENTS = true;
scope.OPT_MODE_NOTIFY_ADS_WATCHED = true;
scope.OPT_MODE_NOTIFY_ADS_WATCHED_MIN_REQUESTS = false;
scope.OPT_BACKUP_PLAYER_TYPE = 'thunderdome';//'picture-by-picture';'thunderdome';
scope.OPT_REGULAR_PLAYER_TYPE = 'site';
scope.OPT_INITIAL_M3U8_ATTEMPTS = 1;
scope.OPT_ACCESS_TOKEN_PLAYER_TYPE = 'site';
scope.AD_SIGNIFIER = 'stitched-ad';
scope.LIVE_SIGNIFIER = ',live';
scope.CLIENT_ID = 'kimne78kx3ncx6brgo4mv6wki5h1ko';
// These are only really for Worker scope...
scope.StreamInfos = [];
scope.StreamInfosByUrl = [];
scope.CurrentChannelNameFromM3U8 = null;
// Need this in both scopes. Window scope needs to update this to worker scope.
scope.gql_device_id = null;
scope.gql_device_id_rolling = '';
// Rolling device id crap... TODO: improve this
var charTable = []; for (var i = 97; i <= 122; i++) { charTable.push(String.fromCharCode(i)); } for (var i = 65; i <= 90; i++) { charTable.push(String.fromCharCode(i)); } for (var i = 48; i <= 57; i++) { charTable.push(String.fromCharCode(i)); }
var bs = 'eVI6jx47kJvCFfFowK86eVI6jx47kJvC';
var di = (new Date()).getUTCFullYear() + (new Date()).getUTCMonth() + ((new Date()).getUTCDate() / 7) | 0;
for (var i = 0; i < bs.length; i++) {
scope.gql_device_id_rolling += charTable[(bs.charCodeAt(i) ^ di) % charTable.length];
}
}
declareOptions(window);
var twitchMainWorker = null;
const oldWorker = window.Worker;
window.Worker = class Worker extends oldWorker {
constructor(twitchBlobUrl) {
if (twitchMainWorker) {
super(twitchBlobUrl);
return;
}
var jsURL = getWasmWorkerUrl(twitchBlobUrl);
if (typeof jsURL !== 'string') {
super(twitchBlobUrl);
return;
}
var newBlobStr = `
${processM3U8.toString()}
${hookWorkerFetch.toString()}
${declareOptions.toString()}
${getAccessToken.toString()}
${gqlRequest.toString()}
${makeGraphQlPacket.toString()}
${tryNotifyAdsWatchedM3U8.toString()}
${parseAttributes.toString()}
declareOptions(self);
self.addEventListener('message', function(e) {
if (e.data.key == 'UboUpdateDeviceId') {
gql_device_id = e.data.value;
}
});
hookWorkerFetch();
importScripts('${jsURL}');
`
super(URL.createObjectURL(new Blob([newBlobStr])));
twitchMainWorker = this;
this.onmessage = function(e) {
// NOTE: Removed adDiv caching as '.video-player' can change between streams?
if (e.data.key == 'UboShowAdBanner') {
var adDiv = getAdDiv();
if (adDiv != null) {
adDiv.P.textContent = 'Blocking' + (e.data.isMidroll ? ' midroll' : '') + ' ads...';
adDiv.style.display = 'block';
}
}
else if (e.data.key == 'UboHideAdBanner') {
var adDiv = getAdDiv();
if (adDiv != null) {
adDiv.style.display = 'none';
}
}
else if (e.data.key == 'UboChannelNameM3U8Changed') {
//console.log('M3U8 channel name changed to ' + e.data.value);
}
else if (e.data.key == 'UboReloadPlayer') {
reloadTwitchPlayer();
}
else if (e.data.key == 'UboPauseResumePlayer') {
reloadTwitchPlayer(false, true);
}
else if (e.data.key == 'UboSeekPlayer') {
reloadTwitchPlayer(true);
}
}
function getAdDiv() {
var playerRootDiv = document.querySelector('.video-player');
var adDiv = null;
if (playerRootDiv != null) {
adDiv = playerRootDiv.querySelector('.ubo-overlay');
if (adDiv == null) {
adDiv = document.createElement('div');
adDiv.className = 'ubo-overlay';
adDiv.innerHTML = '<div class="player-ad-notice" style="color: white; background-color: rgba(0, 0, 0, 0.8); position: absolute; top: 0px; left: 0px; padding: 5px;"><p></p></div>';
adDiv.style.display = 'none';
adDiv.P = adDiv.querySelector('p');
playerRootDiv.appendChild(adDiv);
}
}
return adDiv;
}
}
}
function getWasmWorkerUrl(twitchBlobUrl) {
var req = new XMLHttpRequest();
req.open('GET', twitchBlobUrl, false);
req.send();
return req.responseText.split("'")[1];
}
async function processM3U8(url, textStr, realFetch) {
var streamInfo = StreamInfosByUrl[url];
if (streamInfo == null) {
console.log('Unknown stream url ' + url);
//postMessage({key:'UboHideAdBanner'});
return textStr;
}
if (!OPT_MODE_STRIP_AD_SEGMENTS) {
return textStr;
}
var haveAdTags = textStr.includes(AD_SIGNIFIER);
if (streamInfo.IsLowResNoAds) {
var wasBackupNull = streamInfo.BackupUrl == null;
for (var i = 0; i < 2; i++) {
try {
if (i != 0 && streamInfo.IsMidroll) {
// Doesn't work well with midrolls (often wont see the ad until a few requests in, which creates a reload loop)
continue;
}
let index = i;
var targetUrl = index == 0 ? streamInfo.BackupUrl : null;
if (index != 0 || (streamInfo.BackupUrl == null && !streamInfo.IsRequestingBackup)) {
// NOTE: We currently don't fetch the oauth_token. You wont be able to access private streams like this.
if (index == 0) {
streamInfo.IsRequestingBackup = true;
}
var accessTokenResponse = await getAccessToken(streamInfo.ChannelName, OPT_REGULAR_PLAYER_TYPE);
if (accessTokenResponse.status === 200) {
var accessToken = await accessTokenResponse.json();
var urlInfo = new URL('https://usher.ttvnw.net/api/channel/hls/' + streamInfo.ChannelName + '.m3u8' + streamInfo.RootM3U8Params);
urlInfo.searchParams.set('sig', accessToken.data.streamPlaybackAccessToken.signature);
urlInfo.searchParams.set('token', accessToken.data.streamPlaybackAccessToken.value);
var encodingsM3u8Response = await realFetch(urlInfo.href);
if (encodingsM3u8Response.status === 200) {
// TODO: Maybe look for the most optimal m3u8
var encodingsM3u8 = await encodingsM3u8Response.text();
var streamM3u8Url = encodingsM3u8.match(/^https:.*\.m3u8$/m)[0];
// Maybe this request is a bit unnecessary
var streamM3u8Response = await realFetch(streamM3u8Url);
if (streamM3u8Response.status == 200) {
targetUrl = streamM3u8Url;
streamInfo.BackupEncodings[index] = encodingsM3u8;
if (index == 0) {
streamInfo.BackupUrl = streamM3u8Url;
streamInfo.IsRequestingBackup = false;
console.log('Fetched backup url: ' + streamInfo.BackupUrl);
}
} else {
console.log('Backup url request (streamM3u8) failed with ' + streamM3u8Response.status);
}
} else {
console.log('Backup url request (encodingsM3u8) failed with ' + encodingsM3u8Response.status);
}
} else {
console.log('Backup url request (accessToken) failed with ' + accessTokenResponse.status);
}
}
if (targetUrl != null) {
var backupM3u8 = null;
var backupM3u8Response = await realFetch(targetUrl);
if (backupM3u8Response.status == 200) {
backupM3u8 = await backupM3u8Response.text();
}
if (backupM3u8 != null && !backupM3u8.includes(AD_SIGNIFIER)) {
if (streamInfo.LastBackupRequestWithoutAds[index] < Date.now() - 1333) {
streamInfo.LastBackupRequestWithoutAds[index] = Date.now();
streamInfo.NumBackupRequestWithoutAds[index]++;
}
} else {
// TODO: Throttle this. Currently this sends way too many requests.
if (index == 0 && !streamInfo.IsMidroll) {
/*await */tryNotifyAdsWatchedM3U8(backupM3u8);
}
streamInfo.NumBackupRequestWithoutAds[index] = 0;
}
}
} catch (err) {
console.log('Fetching backup m3u8 failed');
console.log(err);
}
if (wasBackupNull) {
continue;
}
}
if (streamInfo.NumBackupRequestWithoutAds[0] >= 3 || streamInfo.NumBackupRequestWithoutAds[1] >= 4) {
console.log('No more ads ' + streamInfo.NumBackupRequestWithoutAds[0] + ' ' + streamInfo.NumBackupRequestWithoutAds[1]);
postMessage({key:'UboHideAdBanner'});
streamInfo.SwappedEncodings = streamInfo.BackupEncodings[streamInfo.NumBackupRequestWithoutAds[0] >= 3 ? 0 : 1];
streamInfo.SwappedEncodingsTime = Date.now();
streamInfo.IsLowResNoAds = false;
postMessage({key:'UboReloadPlayer'});
}
if (haveAdTags) {
console.log('Double dipping ads?');
return '';
}
} else if (haveAdTags) {
console.log('Found ads, switch to low res');
streamInfo.IsLowResNoAds = true;
streamInfo.IsMidroll = textStr.includes('"MIDROLL"') || textStr.includes('"midroll"');
postMessage({key:'UboReloadPlayer'});
return '';
} else {
postMessage({key:'UboHideAdBanner'});
}
return textStr;
}
function hookWorkerFetch() {
console.log('hookWorkerFetch');
var realFetch = fetch;
fetch = async function(url, options) {
if (typeof url === 'string') {
url = url.trimEnd();
if (url.endsWith('m3u8')) {
return new Promise(function(resolve, reject) {
var processAfter = async function(response) {
var str = await processM3U8(url, await response.text(), realFetch);
resolve(new Response(str));
};
var send = function() {
return realFetch(url, options).then(function(response) {
processAfter(response);
})['catch'](function(err) {
console.log('fetch hook err ' + err);
reject(err);
});
};
send();
});
}
else if (url.includes('/api/channel/hls/') && !url.includes('picture-by-picture')) {
var channelName = (new URL(url)).pathname.match(/([^\/]+)(?=\.\w+$)/)[0];
if (CurrentChannelNameFromM3U8 != channelName) {
postMessage({
key: 'UboChannelNameM3U8Changed',
value: channelName
});
}
CurrentChannelNameFromM3U8 = channelName;
if (OPT_MODE_STRIP_AD_SEGMENTS) {
return new Promise(async function(resolve, reject) {
// - First m3u8 request is the m3u8 with the video encodings (360p,480p,720p,etc).
// - Second m3u8 request is the m3u8 for the given encoding obtained in the first request. At this point we will know if there's ads.
var maxAttempts = OPT_INITIAL_M3U8_ATTEMPTS <= 0 ? 1 : OPT_INITIAL_M3U8_ATTEMPTS;
var attempts = 0;
while(true) {
var encodingsM3u8Response = await realFetch(url, options);
if (encodingsM3u8Response != null && encodingsM3u8Response.status === 200) {
var encodingsM3u8 = await encodingsM3u8Response.text();
var streamM3u8Url = encodingsM3u8.match(/^https:.*\.m3u8$/m)[0];
var streamM3u8Response = await realFetch(streamM3u8Url);
var streamM3u8 = await streamM3u8Response.text();
if (!streamM3u8.includes(AD_SIGNIFIER) || ++attempts >= maxAttempts) {
if (maxAttempts > 1 && attempts >= maxAttempts) {
console.log('max skip ad attempts reached (attempt #' + attempts + ')');
}
var hasSwappedEncodings = false;
var streamInfo = StreamInfos[channelName];
if (streamInfo == null) {
StreamInfos[channelName] = streamInfo = {};
} else if (streamInfo.SwappedEncodings != null && streamInfo.SwappedEncodingsTime >= Date.now() - 10000) {
encodingsM3u8 = streamInfo.SwappedEncodings;
hasSwappedEncodings = true;
}
var forcedLowRes = false;
var existingStreamInfo = StreamInfos[channelName];
if (existingStreamInfo.IsLowResNoAds || (!hasSwappedEncodings && streamM3u8.includes(AD_SIGNIFIER))) {
var accessTokenResponse = await getAccessToken(channelName, OPT_BACKUP_PLAYER_TYPE);
if (accessTokenResponse.status === 200) {
var accessToken = await accessTokenResponse.json();
var urlInfo = new URL('https://usher.ttvnw.net/api/channel/hls/' + channelName + '.m3u8' + (new URL(url)).search);
urlInfo.searchParams.set('sig', accessToken.data.streamPlaybackAccessToken.signature);
urlInfo.searchParams.set('token', accessToken.data.streamPlaybackAccessToken.value);
var lowResEncodingsM3u8Response = await realFetch(urlInfo.href);
if (lowResEncodingsM3u8Response != null && lowResEncodingsM3u8Response.status === 200) {
var lowResEncodingsM3u8 = await lowResEncodingsM3u8Response.text();
var lowResLines = lowResEncodingsM3u8.replace('\r', '').split('\n');
var lowResBestUrl = null;
for (var i = 0; i < lowResLines.length; i++) {
if (lowResLines[i].startsWith('#EXT-X-STREAM-INF')) {
var res = parseAttributes(lowResLines[i])['RESOLUTION'];
if (res && lowResLines[i + 1].endsWith('.m3u8')) {
// Assumes resolutions are correctly ordered
lowResBestUrl = lowResLines[i + 1];
break;
}
}
}
if (lowResBestUrl != null) {
var normalEncodingsM3u8 = encodingsM3u8;
var normalLines = normalEncodingsM3u8.replace('\r', '').split('\n');
for (var i = 0; i < normalLines.length - 1; i++) {
if (normalLines[i].startsWith('#EXT-X-STREAM-INF')) {
var res = parseAttributes(normalLines[i])['RESOLUTION'];
if (res) {
lowResBestUrl += ' ';// The stream doesn't load unless each url line is unique
normalLines[i + 1] = lowResBestUrl;
}
}
}
encodingsM3u8 = normalLines.join('\r\n');
} else {
encodingsM3u8 = lowResEncodingsM3u8;
}
forcedLowRes = true;
postMessage({key:'UboShowAdBanner',isMidroll:streamInfo.IsMidroll});
}
}
}
// This might potentially backfire... maybe just add the new urls
streamInfo.ChannelName = channelName;
streamInfo.RootM3U8Url = url;
streamInfo.RootM3U8Params = (new URL(url)).search;
streamInfo.BackupUrl = null;
streamInfo.BackupEncodings = [null,null];
streamInfo.IsRequestingBackup = false;
streamInfo.NumBackupRequestWithoutAds = [0,0];
streamInfo.LastBackupRequestWithoutAds = [0,0];
streamInfo.SwappedEncodings = null;
streamInfo.SwappedEncodingsTime = 0;
streamInfo.IsMidroll = !!streamInfo.IsMidroll;
streamInfo.IsLowResNoAds = forcedLowRes;
var lines = encodingsM3u8.replace('\r', '').split('\n');
for (var i = 0; i < lines.length; i++) {
if (!lines[i].startsWith('#') && lines[i].includes('.m3u8')) {
StreamInfosByUrl[lines[i].trimEnd()] = streamInfo;
}
}
resolve(new Response(encodingsM3u8));
break;
}
console.log('attempt to skip ad (attempt #' + attempts + ')');
} else {
// Stream is offline?
resolve(encodingsM3u8Response);
break;
}
}
});
}
}
}
return realFetch.apply(this, arguments);
}
}
function makeGraphQlPacket(event, radToken, payload) {
return [{
operationName: 'ClientSideAdEventHandling_RecordAdEvent',
variables: {
input: {
eventName: event,
eventPayload: JSON.stringify(payload),
radToken,
},
},
extensions: {
persistedQuery: {
version: 1,
sha256Hash: '7e6c69e6eb59f8ccb97ab73686f3d8b7d85a72a0298745ccd8bfc68e4054ca5b',
},
},
}];
}
function getAccessToken(channelName, playerType, realFetch) {
var body = null;
var templateQuery = 'query PlaybackAccessToken_Template($login: String!, $isLive: Boolean!, $vodID: ID!, $isVod: Boolean!, $playerType: String!) { streamPlaybackAccessToken(channelName: $login, params: {platform: "web", playerBackend: "mediaplayer", playerType: $playerType}) @include(if: $isLive) { value signature __typename } videoPlaybackAccessToken(id: $vodID, params: {platform: "web", playerBackend: "mediaplayer", playerType: $playerType}) @include(if: $isVod) { value signature __typename }}';
body = {
operationName: 'PlaybackAccessToken_Template',
query: templateQuery,
variables: {
'isLive': true,
'login': channelName,
'isVod': false,
'vodID': '',
'playerType': playerType
}
};
return gqlRequest(body, realFetch);
}
function gqlRequest(body, realFetch) {
var fetchFunc = realFetch ? realFetch : fetch;
return fetchFunc('https://gql.twitch.tv/gql', {
method: 'POST',
body: JSON.stringify(body),
headers: {
'client-id': CLIENT_ID,
'X-Device-Id': OPT_ROLLING_DEVICE_ID ? gql_device_id_rolling : gql_device_id
}
});
}
function parseAttributes(str) {
return Object.fromEntries(
str.split(/(?:^|,)((?:[^=]*)=(?:"[^"]*"|[^,]*))/)
.filter(Boolean)
.map(x => {
const idx = x.indexOf('=');
const key = x.substring(0, idx);
const value = x.substring(idx +1);
const num = Number(value);
return [key, Number.isNaN(num) ? value.startsWith('"') ? JSON.parse(value) : value : num]
}));
}
async function tryNotifyAdsWatchedM3U8(streamM3u8) {
try {
//console.log(streamM3u8);
if (!streamM3u8 || !streamM3u8.includes(AD_SIGNIFIER)) {
return 1;
}
var matches = streamM3u8.match(/#EXT-X-DATERANGE:(ID="stitched-ad-[^\n]+)\n/);
if (matches.length > 1) {
const attrString = matches[1];
const attr = parseAttributes(attrString);
var podLength = parseInt(attr['X-TV-TWITCH-AD-POD-LENGTH'] ? attr['X-TV-TWITCH-AD-POD-LENGTH'] : '1');
var podPosition = parseInt(attr['X-TV-TWITCH-AD-POD-POSITION'] ? attr['X-TV-TWITCH-AD-POD-POSITION'] : '0');
var radToken = attr['X-TV-TWITCH-AD-RADS-TOKEN'];
var lineItemId = attr['X-TV-TWITCH-AD-LINE-ITEM-ID'];
var orderId = attr['X-TV-TWITCH-AD-ORDER-ID'];
var creativeId = attr['X-TV-TWITCH-AD-CREATIVE-ID'];
var adId = attr['X-TV-TWITCH-AD-ADVERTISER-ID'];
var rollType = attr['X-TV-TWITCH-AD-ROLL-TYPE'].toLowerCase();
const baseData = {
stitched: true,
roll_type: rollType,
player_mute: false,
player_volume: 0.5,
visible: true,
};
for (let podPosition = 0; podPosition < podLength; podPosition++) {
if (OPT_MODE_NOTIFY_ADS_WATCHED_MIN_REQUESTS) {
// This is all that's actually required at the moment
await gqlRequest(makeGraphQlPacket('video_ad_pod_complete', radToken, baseData));
} else {
const extendedData = {
...baseData,
ad_id: adId,
ad_position: podPosition,
duration: 30,
creative_id: creativeId,
total_ads: podLength,
order_id: orderId,
line_item_id: lineItemId,
};
await gqlRequest(makeGraphQlPacket('video_ad_impression', radToken, extendedData));
for (let quartile = 0; quartile < 4; quartile++) {
await gqlRequest(
makeGraphQlPacket('video_ad_quartile_complete', radToken, {
...extendedData,
quartile: quartile + 1,
})
);
}
await gqlRequest(makeGraphQlPacket('video_ad_pod_complete', radToken, baseData));
}
}
}
return 0;
} catch (err) {
console.log(err);
return 0;
}
}
function hookFetch() {
var realFetch = window.fetch;
window.fetch = function(url, init, ...args) {
if (typeof url === 'string') {
if (url.includes('gql')) {
var deviceId = init.headers['X-Device-Id'];
if (typeof deviceId !== 'string') {
deviceId = init.headers['Device-ID'];
}
if (typeof deviceId === 'string') {
gql_device_id = deviceId;
}
if (gql_device_id && twitchMainWorker) {
twitchMainWorker.postMessage({
key: 'UboUpdateDeviceId',
value: gql_device_id
});
}
if (typeof init.body === 'string' && init.body.includes('PlaybackAccessToken')) {
if (OPT_ACCESS_TOKEN_PLAYER_TYPE) {
const newBody = JSON.parse(init.body);
newBody.variables.playerType = OPT_ACCESS_TOKEN_PLAYER_TYPE;
init.body = JSON.stringify(newBody);
}
if (OPT_ROLLING_DEVICE_ID) {
if (typeof init.headers['X-Device-Id'] === 'string') {
init.headers['X-Device-Id'] = gql_device_id_rolling;
}
if (typeof init.headers['Device-ID'] === 'string') {
init.headers['Device-ID'] = gql_device_id_rolling;
}
}
}
}
}
return realFetch.apply(this, arguments);
};
}
function reloadTwitchPlayer(isSeek, isPausePlay) {
// Taken from ttv-tools / ffz
// https://github.com/Nerixyz/ttv-tools/blob/master/src/context/twitch-player.ts
// https://github.com/FrankerFaceZ/FrankerFaceZ/blob/master/src/sites/twitch-twilight/modules/player.jsx
function findReactNode(root, constraint) {
if (root.stateNode && constraint(root.stateNode)) {
return root.stateNode;
}
let node = root.child;
while (node) {
const result = findReactNode(node, constraint);
if (result) {
return result;
}
node = node.sibling;
}
return null;
}
var reactRootNode = null;
var rootNode = document.querySelector('#root');
if (rootNode && rootNode._reactRootContainer && rootNode._reactRootContainer._internalRoot && rootNode._reactRootContainer._internalRoot.current) {
reactRootNode = rootNode._reactRootContainer._internalRoot.current;
}
if (!reactRootNode) {
console.log('Could not find react root');
return;
}
var player = findReactNode(reactRootNode, node => node.setPlayerActive && node.props && node.props.mediaPlayerInstance);
player = player && player.props && player.props.mediaPlayerInstance ? player.props.mediaPlayerInstance : null;
var playerState = findReactNode(reactRootNode, node => node.setSrc && node.setInitialPlaybackSettings);
if (!player) {
console.log('Could not find player');
return;
}
if (!playerState) {
console.log('Could not find player state');
return;
}
if (player.paused) {
return;
}
if (isSeek) {
console.log('Force seek to reset player (hopefully fixing any audio desync) pos:' + player.getPosition() + ' range:' + JSON.stringify(player.getBuffered()));
var pos = player.getPosition();
player.seekTo(0);
player.seekTo(pos);
return;
}
if (isPausePlay) {
player.pause();
player.play();
return;
}
const sink = player.mediaSinkManager || (player.core ? player.core.mediaSinkManager : null);
if (sink && sink.video && sink.video._ffz_compressor) {
const video = sink.video;
const volume = video.volume ? video.volume : player.getVolume();
const muted = player.isMuted();
const newVideo = document.createElement('video');
newVideo.volume = muted ? 0 : volume;
newVideo.playsInline = true;
video.replaceWith(newVideo);
player.attachHTMLVideoElement(newVideo);
setImmediate(() => {
player.setVolume(volume);
player.setMuted(muted);
});
}
playerState.setSrc({ isNewMediaPlayerInstance: true, refreshAccessToken: true });// ffz sets this false
}
window.reloadTwitchPlayer = reloadTwitchPlayer;
hookFetch();
function onContentLoaded() {
// This stops Twitch from pausing the player when in another tab and an ad shows.
// Taken from https://github.com/saucettv/VideoAdBlockForTwitch/blob/cefce9d2b565769c77e3666ac8234c3acfe20d83/chrome/content.js#L30
try {
Object.defineProperty(document, 'visibilityState', {
get() {
return 'visible';
}
});
}catch{}
try {
Object.defineProperty(document, 'hidden', {
get() {
return false;
}
});
}catch{}
var block = e => {
e.preventDefault();
e.stopPropagation();
e.stopImmediatePropagation();
};
document.addEventListener('visibilitychange', block, true);
document.addEventListener('webkitvisibilitychange', block, true);
document.addEventListener('mozvisibilitychange', block, true);
document.addEventListener('hasFocus', block, true);
try {
if (/Firefox/.test(navigator.userAgent)) {
Object.defineProperty(document, 'mozHidden', {
get() {
return false;
}
});
} else {
Object.defineProperty(document, 'webkitHidden', {
get() {
return false;
}
});
}
}catch{}
// Hooks for preserving volume / resolution
var keysToCache = [
'video-quality',
'video-muted',
'volume',
'lowLatencyModeEnabled',// Low Latency
'persistenceEnabled',// Mini Player
];
var cachedValues = new Map();
for (var i = 0; i < keysToCache.length; i++) {
cachedValues.set(keysToCache[i], localStorage.getItem(keysToCache[i]));
}
var realSetItem = localStorage.setItem;
localStorage.setItem = function(key, value) {
if (cachedValues.has(key)) {
cachedValues.set(key, value);
}
realSetItem.apply(this, arguments);
};
var realGetItem = localStorage.getItem;
localStorage.getItem = function(key) {
if (cachedValues.has(key)) {
return cachedValues.get(key);
}
return realGetItem.apply(this, arguments);
};
}
if (document.readyState === "complete" || document.readyState === "loaded" || document.readyState === "interactive") {
onContentLoaded();
} else {
window.addEventListener("DOMContentLoaded", function() {
onContentLoaded();
});
}
})();

View File

@ -0,0 +1,675 @@
// ==UserScript==
// @name TwitchAdSolutions (notify-swap)
// @namespace https://github.com/pixeltris/TwitchAdSolutions
// @version 1.13
// @updateURL https://github.com/pixeltris/TwitchAdSolutions/raw/master/notify-swap/notify-notify-swap.user.js
// @downloadURL https://github.com/pixeltris/TwitchAdSolutions/raw/master/notify-swap/notify-notify-swap.user.js
// @description Multiple solutions for blocking Twitch ads (notify-swap)
// @author pixeltris
// @match *://*.twitch.tv/*
// @run-at document-start
// @grant none
// ==/UserScript==
(function() {
'use strict';
function declareOptions(scope) {
// Options / globals
scope.OPT_ROLLING_DEVICE_ID = true;
scope.OPT_MODE_STRIP_AD_SEGMENTS = true;
scope.OPT_MODE_NOTIFY_ADS_WATCHED = true;
scope.OPT_MODE_NOTIFY_ADS_WATCHED_MIN_REQUESTS = false;
scope.OPT_BACKUP_PLAYER_TYPE = 'thunderdome';//'picture-by-picture';'thunderdome';
scope.OPT_REGULAR_PLAYER_TYPE = 'site';
scope.OPT_INITIAL_M3U8_ATTEMPTS = 1;
scope.OPT_ACCESS_TOKEN_PLAYER_TYPE = 'site';
scope.AD_SIGNIFIER = 'stitched-ad';
scope.LIVE_SIGNIFIER = ',live';
scope.CLIENT_ID = 'kimne78kx3ncx6brgo4mv6wki5h1ko';
// These are only really for Worker scope...
scope.StreamInfos = [];
scope.StreamInfosByUrl = [];
scope.CurrentChannelNameFromM3U8 = null;
// Need this in both scopes. Window scope needs to update this to worker scope.
scope.gql_device_id = null;
scope.gql_device_id_rolling = '';
// Rolling device id crap... TODO: improve this
var charTable = []; for (var i = 97; i <= 122; i++) { charTable.push(String.fromCharCode(i)); } for (var i = 65; i <= 90; i++) { charTable.push(String.fromCharCode(i)); } for (var i = 48; i <= 57; i++) { charTable.push(String.fromCharCode(i)); }
var bs = 'eVI6jx47kJvCFfFowK86eVI6jx47kJvC';
var di = (new Date()).getUTCFullYear() + (new Date()).getUTCMonth() + ((new Date()).getUTCDate() / 7) | 0;
for (var i = 0; i < bs.length; i++) {
scope.gql_device_id_rolling += charTable[(bs.charCodeAt(i) ^ di) % charTable.length];
}
}
declareOptions(window);
var twitchMainWorker = null;
const oldWorker = window.Worker;
window.Worker = class Worker extends oldWorker {
constructor(twitchBlobUrl) {
if (twitchMainWorker) {
super(twitchBlobUrl);
return;
}
var jsURL = getWasmWorkerUrl(twitchBlobUrl);
if (typeof jsURL !== 'string') {
super(twitchBlobUrl);
return;
}
var newBlobStr = `
${processM3U8.toString()}
${hookWorkerFetch.toString()}
${declareOptions.toString()}
${getAccessToken.toString()}
${gqlRequest.toString()}
${makeGraphQlPacket.toString()}
${tryNotifyAdsWatchedM3U8.toString()}
${parseAttributes.toString()}
declareOptions(self);
self.addEventListener('message', function(e) {
if (e.data.key == 'UboUpdateDeviceId') {
gql_device_id = e.data.value;
}
});
hookWorkerFetch();
importScripts('${jsURL}');
`
super(URL.createObjectURL(new Blob([newBlobStr])));
twitchMainWorker = this;
this.onmessage = function(e) {
// NOTE: Removed adDiv caching as '.video-player' can change between streams?
if (e.data.key == 'UboShowAdBanner') {
var adDiv = getAdDiv();
if (adDiv != null) {
adDiv.P.textContent = 'Blocking' + (e.data.isMidroll ? ' midroll' : '') + ' ads...';
adDiv.style.display = 'block';
}
}
else if (e.data.key == 'UboHideAdBanner') {
var adDiv = getAdDiv();
if (adDiv != null) {
adDiv.style.display = 'none';
}
}
else if (e.data.key == 'UboChannelNameM3U8Changed') {
//console.log('M3U8 channel name changed to ' + e.data.value);
}
else if (e.data.key == 'UboReloadPlayer') {
reloadTwitchPlayer();
}
else if (e.data.key == 'UboPauseResumePlayer') {
reloadTwitchPlayer(false, true);
}
else if (e.data.key == 'UboSeekPlayer') {
reloadTwitchPlayer(true);
}
}
function getAdDiv() {
var playerRootDiv = document.querySelector('.video-player');
var adDiv = null;
if (playerRootDiv != null) {
adDiv = playerRootDiv.querySelector('.ubo-overlay');
if (adDiv == null) {
adDiv = document.createElement('div');
adDiv.className = 'ubo-overlay';
adDiv.innerHTML = '<div class="player-ad-notice" style="color: white; background-color: rgba(0, 0, 0, 0.8); position: absolute; top: 0px; left: 0px; padding: 5px;"><p></p></div>';
adDiv.style.display = 'none';
adDiv.P = adDiv.querySelector('p');
playerRootDiv.appendChild(adDiv);
}
}
return adDiv;
}
}
}
function getWasmWorkerUrl(twitchBlobUrl) {
var req = new XMLHttpRequest();
req.open('GET', twitchBlobUrl, false);
req.send();
return req.responseText.split("'")[1];
}
async function processM3U8(url, textStr, realFetch) {
var streamInfo = StreamInfosByUrl[url];
if (streamInfo == null) {
console.log('Unknown stream url ' + url);
//postMessage({key:'UboHideAdBanner'});
return textStr;
}
if (!OPT_MODE_STRIP_AD_SEGMENTS) {
return textStr;
}
var haveAdTags = textStr.includes(AD_SIGNIFIER);
if (streamInfo.IsLowResNoAds) {
var wasBackupNull = streamInfo.BackupUrl == null;
for (var i = 0; i < 2; i++) {
try {
if (i != 0 && streamInfo.IsMidroll) {
// Doesn't work well with midrolls (often wont see the ad until a few requests in, which creates a reload loop)
continue;
}
let index = i;
var targetUrl = index == 0 ? streamInfo.BackupUrl : null;
if (index != 0 || (streamInfo.BackupUrl == null && !streamInfo.IsRequestingBackup)) {
// NOTE: We currently don't fetch the oauth_token. You wont be able to access private streams like this.
if (index == 0) {
streamInfo.IsRequestingBackup = true;
}
var accessTokenResponse = await getAccessToken(streamInfo.ChannelName, OPT_REGULAR_PLAYER_TYPE);
if (accessTokenResponse.status === 200) {
var accessToken = await accessTokenResponse.json();
var urlInfo = new URL('https://usher.ttvnw.net/api/channel/hls/' + streamInfo.ChannelName + '.m3u8' + streamInfo.RootM3U8Params);
urlInfo.searchParams.set('sig', accessToken.data.streamPlaybackAccessToken.signature);
urlInfo.searchParams.set('token', accessToken.data.streamPlaybackAccessToken.value);
var encodingsM3u8Response = await realFetch(urlInfo.href);
if (encodingsM3u8Response.status === 200) {
// TODO: Maybe look for the most optimal m3u8
var encodingsM3u8 = await encodingsM3u8Response.text();
var streamM3u8Url = encodingsM3u8.match(/^https:.*\.m3u8$/m)[0];
// Maybe this request is a bit unnecessary
var streamM3u8Response = await realFetch(streamM3u8Url);
if (streamM3u8Response.status == 200) {
targetUrl = streamM3u8Url;
streamInfo.BackupEncodings[index] = encodingsM3u8;
if (index == 0) {
streamInfo.BackupUrl = streamM3u8Url;
streamInfo.IsRequestingBackup = false;
console.log('Fetched backup url: ' + streamInfo.BackupUrl);
}
} else {
console.log('Backup url request (streamM3u8) failed with ' + streamM3u8Response.status);
}
} else {
console.log('Backup url request (encodingsM3u8) failed with ' + encodingsM3u8Response.status);
}
} else {
console.log('Backup url request (accessToken) failed with ' + accessTokenResponse.status);
}
}
if (targetUrl != null) {
var backupM3u8 = null;
var backupM3u8Response = await realFetch(targetUrl);
if (backupM3u8Response.status == 200) {
backupM3u8 = await backupM3u8Response.text();
}
if (backupM3u8 != null && !backupM3u8.includes(AD_SIGNIFIER)) {
if (streamInfo.LastBackupRequestWithoutAds[index] < Date.now() - 1333) {
streamInfo.LastBackupRequestWithoutAds[index] = Date.now();
streamInfo.NumBackupRequestWithoutAds[index]++;
}
} else {
// TODO: Throttle this. Currently this sends way too many requests.
if (index == 0 && !streamInfo.IsMidroll) {
/*await */tryNotifyAdsWatchedM3U8(backupM3u8);
}
streamInfo.NumBackupRequestWithoutAds[index] = 0;
}
}
} catch (err) {
console.log('Fetching backup m3u8 failed');
console.log(err);
}
if (wasBackupNull) {
continue;
}
}
if (streamInfo.NumBackupRequestWithoutAds[0] >= 3 || streamInfo.NumBackupRequestWithoutAds[1] >= 4) {
console.log('No more ads ' + streamInfo.NumBackupRequestWithoutAds[0] + ' ' + streamInfo.NumBackupRequestWithoutAds[1]);
postMessage({key:'UboHideAdBanner'});
streamInfo.SwappedEncodings = streamInfo.BackupEncodings[streamInfo.NumBackupRequestWithoutAds[0] >= 3 ? 0 : 1];
streamInfo.SwappedEncodingsTime = Date.now();
streamInfo.IsLowResNoAds = false;
postMessage({key:'UboReloadPlayer'});
}
if (haveAdTags) {
console.log('Double dipping ads?');
return '';
}
} else if (haveAdTags) {
console.log('Found ads, switch to low res');
streamInfo.IsLowResNoAds = true;
streamInfo.IsMidroll = textStr.includes('"MIDROLL"') || textStr.includes('"midroll"');
postMessage({key:'UboReloadPlayer'});
return '';
} else {
postMessage({key:'UboHideAdBanner'});
}
return textStr;
}
function hookWorkerFetch() {
console.log('hookWorkerFetch');
var realFetch = fetch;
fetch = async function(url, options) {
if (typeof url === 'string') {
url = url.trimEnd();
if (url.endsWith('m3u8')) {
return new Promise(function(resolve, reject) {
var processAfter = async function(response) {
var str = await processM3U8(url, await response.text(), realFetch);
resolve(new Response(str));
};
var send = function() {
return realFetch(url, options).then(function(response) {
processAfter(response);
})['catch'](function(err) {
console.log('fetch hook err ' + err);
reject(err);
});
};
send();
});
}
else if (url.includes('/api/channel/hls/') && !url.includes('picture-by-picture')) {
var channelName = (new URL(url)).pathname.match(/([^\/]+)(?=\.\w+$)/)[0];
if (CurrentChannelNameFromM3U8 != channelName) {
postMessage({
key: 'UboChannelNameM3U8Changed',
value: channelName
});
}
CurrentChannelNameFromM3U8 = channelName;
if (OPT_MODE_STRIP_AD_SEGMENTS) {
return new Promise(async function(resolve, reject) {
// - First m3u8 request is the m3u8 with the video encodings (360p,480p,720p,etc).
// - Second m3u8 request is the m3u8 for the given encoding obtained in the first request. At this point we will know if there's ads.
var maxAttempts = OPT_INITIAL_M3U8_ATTEMPTS <= 0 ? 1 : OPT_INITIAL_M3U8_ATTEMPTS;
var attempts = 0;
while(true) {
var encodingsM3u8Response = await realFetch(url, options);
if (encodingsM3u8Response != null && encodingsM3u8Response.status === 200) {
var encodingsM3u8 = await encodingsM3u8Response.text();
var streamM3u8Url = encodingsM3u8.match(/^https:.*\.m3u8$/m)[0];
var streamM3u8Response = await realFetch(streamM3u8Url);
var streamM3u8 = await streamM3u8Response.text();
if (!streamM3u8.includes(AD_SIGNIFIER) || ++attempts >= maxAttempts) {
if (maxAttempts > 1 && attempts >= maxAttempts) {
console.log('max skip ad attempts reached (attempt #' + attempts + ')');
}
var hasSwappedEncodings = false;
var streamInfo = StreamInfos[channelName];
if (streamInfo == null) {
StreamInfos[channelName] = streamInfo = {};
} else if (streamInfo.SwappedEncodings != null && streamInfo.SwappedEncodingsTime >= Date.now() - 10000) {
encodingsM3u8 = streamInfo.SwappedEncodings;
hasSwappedEncodings = true;
}
var forcedLowRes = false;
var existingStreamInfo = StreamInfos[channelName];
if (existingStreamInfo.IsLowResNoAds || (!hasSwappedEncodings && streamM3u8.includes(AD_SIGNIFIER))) {
var accessTokenResponse = await getAccessToken(channelName, OPT_BACKUP_PLAYER_TYPE);
if (accessTokenResponse.status === 200) {
var accessToken = await accessTokenResponse.json();
var urlInfo = new URL('https://usher.ttvnw.net/api/channel/hls/' + channelName + '.m3u8' + (new URL(url)).search);
urlInfo.searchParams.set('sig', accessToken.data.streamPlaybackAccessToken.signature);
urlInfo.searchParams.set('token', accessToken.data.streamPlaybackAccessToken.value);
var lowResEncodingsM3u8Response = await realFetch(urlInfo.href);
if (lowResEncodingsM3u8Response != null && lowResEncodingsM3u8Response.status === 200) {
var lowResEncodingsM3u8 = await lowResEncodingsM3u8Response.text();
var lowResLines = lowResEncodingsM3u8.replace('\r', '').split('\n');
var lowResBestUrl = null;
for (var i = 0; i < lowResLines.length; i++) {
if (lowResLines[i].startsWith('#EXT-X-STREAM-INF')) {
var res = parseAttributes(lowResLines[i])['RESOLUTION'];
if (res && lowResLines[i + 1].endsWith('.m3u8')) {
// Assumes resolutions are correctly ordered
lowResBestUrl = lowResLines[i + 1];
break;
}
}
}
if (lowResBestUrl != null) {
var normalEncodingsM3u8 = encodingsM3u8;
var normalLines = normalEncodingsM3u8.replace('\r', '').split('\n');
for (var i = 0; i < normalLines.length - 1; i++) {
if (normalLines[i].startsWith('#EXT-X-STREAM-INF')) {
var res = parseAttributes(normalLines[i])['RESOLUTION'];
if (res) {
lowResBestUrl += ' ';// The stream doesn't load unless each url line is unique
normalLines[i + 1] = lowResBestUrl;
}
}
}
encodingsM3u8 = normalLines.join('\r\n');
} else {
encodingsM3u8 = lowResEncodingsM3u8;
}
forcedLowRes = true;
postMessage({key:'UboShowAdBanner',isMidroll:streamInfo.IsMidroll});
}
}
}
// This might potentially backfire... maybe just add the new urls
streamInfo.ChannelName = channelName;
streamInfo.RootM3U8Url = url;
streamInfo.RootM3U8Params = (new URL(url)).search;
streamInfo.BackupUrl = null;
streamInfo.BackupEncodings = [null,null];
streamInfo.IsRequestingBackup = false;
streamInfo.NumBackupRequestWithoutAds = [0,0];
streamInfo.LastBackupRequestWithoutAds = [0,0];
streamInfo.SwappedEncodings = null;
streamInfo.SwappedEncodingsTime = 0;
streamInfo.IsMidroll = !!streamInfo.IsMidroll;
streamInfo.IsLowResNoAds = forcedLowRes;
var lines = encodingsM3u8.replace('\r', '').split('\n');
for (var i = 0; i < lines.length; i++) {
if (!lines[i].startsWith('#') && lines[i].includes('.m3u8')) {
StreamInfosByUrl[lines[i].trimEnd()] = streamInfo;
}
}
resolve(new Response(encodingsM3u8));
break;
}
console.log('attempt to skip ad (attempt #' + attempts + ')');
} else {
// Stream is offline?
resolve(encodingsM3u8Response);
break;
}
}
});
}
}
}
return realFetch.apply(this, arguments);
}
}
function makeGraphQlPacket(event, radToken, payload) {
return [{
operationName: 'ClientSideAdEventHandling_RecordAdEvent',
variables: {
input: {
eventName: event,
eventPayload: JSON.stringify(payload),
radToken,
},
},
extensions: {
persistedQuery: {
version: 1,
sha256Hash: '7e6c69e6eb59f8ccb97ab73686f3d8b7d85a72a0298745ccd8bfc68e4054ca5b',
},
},
}];
}
function getAccessToken(channelName, playerType, realFetch) {
var body = null;
var templateQuery = 'query PlaybackAccessToken_Template($login: String!, $isLive: Boolean!, $vodID: ID!, $isVod: Boolean!, $playerType: String!) { streamPlaybackAccessToken(channelName: $login, params: {platform: "web", playerBackend: "mediaplayer", playerType: $playerType}) @include(if: $isLive) { value signature __typename } videoPlaybackAccessToken(id: $vodID, params: {platform: "web", playerBackend: "mediaplayer", playerType: $playerType}) @include(if: $isVod) { value signature __typename }}';
body = {
operationName: 'PlaybackAccessToken_Template',
query: templateQuery,
variables: {
'isLive': true,
'login': channelName,
'isVod': false,
'vodID': '',
'playerType': playerType
}
};
return gqlRequest(body, realFetch);
}
function gqlRequest(body, realFetch) {
var fetchFunc = realFetch ? realFetch : fetch;
return fetchFunc('https://gql.twitch.tv/gql', {
method: 'POST',
body: JSON.stringify(body),
headers: {
'client-id': CLIENT_ID,
'X-Device-Id': OPT_ROLLING_DEVICE_ID ? gql_device_id_rolling : gql_device_id
}
});
}
function parseAttributes(str) {
return Object.fromEntries(
str.split(/(?:^|,)((?:[^=]*)=(?:"[^"]*"|[^,]*))/)
.filter(Boolean)
.map(x => {
const idx = x.indexOf('=');
const key = x.substring(0, idx);
const value = x.substring(idx +1);
const num = Number(value);
return [key, Number.isNaN(num) ? value.startsWith('"') ? JSON.parse(value) : value : num]
}));
}
async function tryNotifyAdsWatchedM3U8(streamM3u8) {
try {
//console.log(streamM3u8);
if (!streamM3u8 || !streamM3u8.includes(AD_SIGNIFIER)) {
return 1;
}
var matches = streamM3u8.match(/#EXT-X-DATERANGE:(ID="stitched-ad-[^\n]+)\n/);
if (matches.length > 1) {
const attrString = matches[1];
const attr = parseAttributes(attrString);
var podLength = parseInt(attr['X-TV-TWITCH-AD-POD-LENGTH'] ? attr['X-TV-TWITCH-AD-POD-LENGTH'] : '1');
var podPosition = parseInt(attr['X-TV-TWITCH-AD-POD-POSITION'] ? attr['X-TV-TWITCH-AD-POD-POSITION'] : '0');
var radToken = attr['X-TV-TWITCH-AD-RADS-TOKEN'];
var lineItemId = attr['X-TV-TWITCH-AD-LINE-ITEM-ID'];
var orderId = attr['X-TV-TWITCH-AD-ORDER-ID'];
var creativeId = attr['X-TV-TWITCH-AD-CREATIVE-ID'];
var adId = attr['X-TV-TWITCH-AD-ADVERTISER-ID'];
var rollType = attr['X-TV-TWITCH-AD-ROLL-TYPE'].toLowerCase();
const baseData = {
stitched: true,
roll_type: rollType,
player_mute: false,
player_volume: 0.5,
visible: true,
};
for (let podPosition = 0; podPosition < podLength; podPosition++) {
if (OPT_MODE_NOTIFY_ADS_WATCHED_MIN_REQUESTS) {
// This is all that's actually required at the moment
await gqlRequest(makeGraphQlPacket('video_ad_pod_complete', radToken, baseData));
} else {
const extendedData = {
...baseData,
ad_id: adId,
ad_position: podPosition,
duration: 30,
creative_id: creativeId,
total_ads: podLength,
order_id: orderId,
line_item_id: lineItemId,
};
await gqlRequest(makeGraphQlPacket('video_ad_impression', radToken, extendedData));
for (let quartile = 0; quartile < 4; quartile++) {
await gqlRequest(
makeGraphQlPacket('video_ad_quartile_complete', radToken, {
...extendedData,
quartile: quartile + 1,
})
);
}
await gqlRequest(makeGraphQlPacket('video_ad_pod_complete', radToken, baseData));
}
}
}
return 0;
} catch (err) {
console.log(err);
return 0;
}
}
function hookFetch() {
var realFetch = window.fetch;
window.fetch = function(url, init, ...args) {
if (typeof url === 'string') {
if (url.includes('gql')) {
var deviceId = init.headers['X-Device-Id'];
if (typeof deviceId !== 'string') {
deviceId = init.headers['Device-ID'];
}
if (typeof deviceId === 'string') {
gql_device_id = deviceId;
}
if (gql_device_id && twitchMainWorker) {
twitchMainWorker.postMessage({
key: 'UboUpdateDeviceId',
value: gql_device_id
});
}
if (typeof init.body === 'string' && init.body.includes('PlaybackAccessToken')) {
if (OPT_ACCESS_TOKEN_PLAYER_TYPE) {
const newBody = JSON.parse(init.body);
newBody.variables.playerType = OPT_ACCESS_TOKEN_PLAYER_TYPE;
init.body = JSON.stringify(newBody);
}
if (OPT_ROLLING_DEVICE_ID) {
if (typeof init.headers['X-Device-Id'] === 'string') {
init.headers['X-Device-Id'] = gql_device_id_rolling;
}
if (typeof init.headers['Device-ID'] === 'string') {
init.headers['Device-ID'] = gql_device_id_rolling;
}
}
}
}
}
return realFetch.apply(this, arguments);
};
}
function reloadTwitchPlayer(isSeek, isPausePlay) {
// Taken from ttv-tools / ffz
// https://github.com/Nerixyz/ttv-tools/blob/master/src/context/twitch-player.ts
// https://github.com/FrankerFaceZ/FrankerFaceZ/blob/master/src/sites/twitch-twilight/modules/player.jsx
function findReactNode(root, constraint) {
if (root.stateNode && constraint(root.stateNode)) {
return root.stateNode;
}
let node = root.child;
while (node) {
const result = findReactNode(node, constraint);
if (result) {
return result;
}
node = node.sibling;
}
return null;
}
var reactRootNode = null;
var rootNode = document.querySelector('#root');
if (rootNode && rootNode._reactRootContainer && rootNode._reactRootContainer._internalRoot && rootNode._reactRootContainer._internalRoot.current) {
reactRootNode = rootNode._reactRootContainer._internalRoot.current;
}
if (!reactRootNode) {
console.log('Could not find react root');
return;
}
var player = findReactNode(reactRootNode, node => node.setPlayerActive && node.props && node.props.mediaPlayerInstance);
player = player && player.props && player.props.mediaPlayerInstance ? player.props.mediaPlayerInstance : null;
var playerState = findReactNode(reactRootNode, node => node.setSrc && node.setInitialPlaybackSettings);
if (!player) {
console.log('Could not find player');
return;
}
if (!playerState) {
console.log('Could not find player state');
return;
}
if (player.paused) {
return;
}
if (isSeek) {
console.log('Force seek to reset player (hopefully fixing any audio desync) pos:' + player.getPosition() + ' range:' + JSON.stringify(player.getBuffered()));
var pos = player.getPosition();
player.seekTo(0);
player.seekTo(pos);
return;
}
if (isPausePlay) {
player.pause();
player.play();
return;
}
const sink = player.mediaSinkManager || (player.core ? player.core.mediaSinkManager : null);
if (sink && sink.video && sink.video._ffz_compressor) {
const video = sink.video;
const volume = video.volume ? video.volume : player.getVolume();
const muted = player.isMuted();
const newVideo = document.createElement('video');
newVideo.volume = muted ? 0 : volume;
newVideo.playsInline = true;
video.replaceWith(newVideo);
player.attachHTMLVideoElement(newVideo);
setImmediate(() => {
player.setVolume(volume);
player.setMuted(muted);
});
}
playerState.setSrc({ isNewMediaPlayerInstance: true, refreshAccessToken: true });// ffz sets this false
}
window.reloadTwitchPlayer = reloadTwitchPlayer;
hookFetch();
function onContentLoaded() {
// This stops Twitch from pausing the player when in another tab and an ad shows.
// Taken from https://github.com/saucettv/VideoAdBlockForTwitch/blob/cefce9d2b565769c77e3666ac8234c3acfe20d83/chrome/content.js#L30
try {
Object.defineProperty(document, 'visibilityState', {
get() {
return 'visible';
}
});
}catch{}
try {
Object.defineProperty(document, 'hidden', {
get() {
return false;
}
});
}catch{}
var block = e => {
e.preventDefault();
e.stopPropagation();
e.stopImmediatePropagation();
};
document.addEventListener('visibilitychange', block, true);
document.addEventListener('webkitvisibilitychange', block, true);
document.addEventListener('mozvisibilitychange', block, true);
document.addEventListener('hasFocus', block, true);
try {
if (/Firefox/.test(navigator.userAgent)) {
Object.defineProperty(document, 'mozHidden', {
get() {
return false;
}
});
} else {
Object.defineProperty(document, 'webkitHidden', {
get() {
return false;
}
});
}
}catch{}
// Hooks for preserving volume / resolution
var keysToCache = [
'video-quality',
'video-muted',
'volume',
'lowLatencyModeEnabled',// Low Latency
'persistenceEnabled',// Mini Player
];
var cachedValues = new Map();
for (var i = 0; i < keysToCache.length; i++) {
cachedValues.set(keysToCache[i], localStorage.getItem(keysToCache[i]));
}
var realSetItem = localStorage.setItem;
localStorage.setItem = function(key, value) {
if (cachedValues.has(key)) {
cachedValues.set(key, value);
}
realSetItem.apply(this, arguments);
};
var realGetItem = localStorage.getItem;
localStorage.getItem = function(key) {
if (cachedValues.has(key)) {
return cachedValues.get(key);
}
return realGetItem.apply(this, arguments);
};
}
if (document.readyState === "complete" || document.readyState === "loaded" || document.readyState === "interactive") {
onContentLoaded();
} else {
window.addEventListener("DOMContentLoaded", function() {
onContentLoaded();
});
}
})();

View File

@ -1,37 +0,0 @@
This gives an overview of using proxies to avoid Twitch ads (without having to proxy all of your traffic ~ just the initial m3u8 per-stream).
`proxy-server` fetches the m3u8 (hopefully ad-free). `extension` contains a Chrome / Firefox compatible extension for sending the m3u8 request. `proxy-m3u8` (uBlock Origin / userscript) scripts also work as an alternative to the extension.
## Socks5
- Put your socks5 proxy info into `proxy-server-info.txt` and run `proxy-server.exe` (install `Mono` if using Linux/Mac and run via `mono proxy-server.exe`).
- Load the `extension` folder as an unpacked extension in your browser. Alternatively use `proxy-m3u8` `uBlock Origin` / `userscript` scripts ([ublock](https://github.com/pixeltris/TwitchAdSolutions/raw/master/proxy-m3u8/proxy-m3u8-ublock-origin.js) / [userscript](https://github.com/pixeltris/TwitchAdSolutions/raw/master/proxy-m3u8/proxy-m3u8.user.js)). (TODO: more helpful info).
## VPN + VMWare
- Set up `VMWare Workstation` with `Windows` and your desired VPN.
- In your VM `Settings` under the `Hardware` tab select `Network Adapter` and change the `Network connection` to `Bridged`. This is to simplify connecting to `proxy-server` from your host. You can do it without bridged but it requires additional VMWare network configuration.
- Add `proxy-server.exe` to your Windows VM Firewall (or disable your Windows Firewall in the VM) and then run `proxy-server.exe`.
- Modify `extension/background.js` and change the IP to your VM IP (obtained via `ipconfig` inside your VM). If you're using `proxy-m3u8` change the IP there.
NOTE: See "mixed-content" below.
## VPS
- Run `proxy-server.exe` on your VPS which is hosted in an ad-free country (install `Mono` if using Linux and run via `mono proxy-server.exe`).
- Modify the url in `extension/background.js` to point to your VPS and load the `extension` folder as an unpacked extension. If using `proxy-m3u8` scripts find the equivalent urls there and modify them where applicable (you'll likely need to fork to do this).
NOTE: See "mixed-content" below.
## Notes
- Running the `HttpListener` on https has many convoluted steps. On localhost (127.0.0.1) Chrome / Firefox allow mixed content requests so there aren't any issues there. For other IPs (i.e. in the VPS/VPN example) you'll need to enable "mixed-content" (also known as "Insecure content") for twitch.tv or otherwise you'll get CORS errors.
- `proxy-server.exe` needs to be ran as Admin to listen on the desired IP/Port.
- Disable other Twitch ad blocking extensions / scripts as they may interfere.
- You will likely have to try multiple locations until you find something that works.
- If you're having problems use Wireshark (or similar) to make sure the m3u8 is being re-routed.
- To build `proxy-server.cs` yourself run `proxy-server-build.bat`. If you're on Mac/Linux build it with `msbuild` which should come with `Mono` or `.NET Core` (TODO: more helpful info).
- `proxy-server` should be visible over LAN/WAN assuming correct firewall settings, however if you wish to connect to it from another machine you'll need to edit the IP in `extension/background.js`.
- TODO: Provide an authenticated option to allow Twitch Turbo to be used to provide streams to non-Turbo users.
I would only really recommend using the info + code here as a starting point for building a more robust solution.

View File

@ -1,3 +0,0 @@
This folder contains an extension which can be used with both Chrome and Firefox to proxy twitch.tv m3u8 stream requests.
The target url is set to `http://127.0.0.1/`, you'll want to modify that based on your requirements.

View File

@ -1,20 +0,0 @@
var isChrome = typeof chrome !== "undefined" && typeof browser === "undefined";
var extensionAPI = isChrome ? chrome : browser;
function onBeforeRequest(details) {
const match = /hls\/(\w+)\.m3u8/gim.exec(details.url);
if (match !== null && match.length > 1) {
return {
redirectUrl: `http://127.0.0.1/twitch-m3u8/${match[1]}`
};
} else {
return {
redirectUrl: details.url
};
}
}
extensionAPI.webRequest.onBeforeRequest.addListener(
onBeforeRequest, {
urls: ["https://usher.ttvnw.net/api/channel/hls/*"]
},
["blocking"]
);

View File

@ -1,16 +0,0 @@
{
"name": "Twitch M3U8 Proxy",
"description": "Twitch M3U8 Proxy",
"version": "1.0",
"manifest_version": 2,
"background": {
"scripts": ["background.js"],
"persistent": true
},
"permissions": [
"webRequest",
"webRequestBlocking",
"*://*.twitch.tv/*",
"*://*.ttvnw.net/*"
]
}

View File

@ -1 +0,0 @@
call %WINDIR%\Microsoft.NET\Framework\v4.0.30319\csc.exe -debug proxy-server.cs

View File

@ -1,31 +0,0 @@
- If you want to use a socks5 proxy:
The first line MUST be the IP of the socks proxy
The second line MUST be the port of the socks proxy
- If you need a user / pass:
The third line MUST be the username
The fourth line MUST be the password
- If you DON'T need a user / pass then the third / fourth line MUST be empty.
- If you DON'T want to use a socks proxy then leave all four lines empty, or delete this file.
----------------------------
Example (with user/pass)
----------------------------
10.1.1.49
1080
myusername
mypassword
----------------------------
Example (without user/pass)
----------------------------
10.2.2.66
1080

File diff suppressed because it is too large Load Diff

Binary file not shown.

727
vaft/vaft-ublock-origin.js Normal file
View File

@ -0,0 +1,727 @@
// This code is directly copied from https://github.com/cleanlock/VideoAdBlockForTwitch (only change is whitespace is removed for the ublock origin script - also indented)
twitch-videoad.js application/javascript
(function() {
if ( /(^|\.)twitch\.tv$/.test(document.location.hostname) === false ) { return; }
//This stops Twitch from pausing the player when in another tab and an ad shows.
try {
Object.defineProperty(document, 'visibilityState', {
get() {
return 'visible';
}
});
Object.defineProperty(document, 'hidden', {
get() {
return false;
}
});
const block = e => {
e.preventDefault();
e.stopPropagation();
e.stopImmediatePropagation();
};
const process = e => {
e.preventDefault();
e.stopPropagation();
e.stopImmediatePropagation();
//This corrects the background tab buffer bug when switching to the background tab for the first time after an extended period.
doTwitchPlayerTask(false, false, true, false, false);
};
document.addEventListener('visibilitychange', process, true);
document.addEventListener('webkitvisibilitychange', block, true);
document.addEventListener('mozvisibilitychange', block, true);
document.addEventListener('hasFocus', block, true);
if (/Firefox/.test(navigator.userAgent)) {
Object.defineProperty(document, 'mozHidden', {
get() {
return false;
}
});
} else {
Object.defineProperty(document, 'webkitHidden', {
get() {
return false;
}
});
}
} catch (err) {}
//Send settings updates to worker.
window.addEventListener("message", (event) => {
if (event.source != window)
return;
if (event.data.type && (event.data.type == "SetHideBlockingMessage")) {
if (twitchMainWorker) {
twitchMainWorker.postMessage({
key: 'SetHideBlockingMessage',
value: event.data.value
});
}
}
}, false);
function declareOptions(scope) {
scope.AdSignifier = 'stitched';
scope.ClientID = 'kimne78kx3ncx6brgo4mv6wki5h1ko';
scope.ClientVersion = 'null';
scope.ClientSession = 'null';
scope.PlayerType1 = 'site'; //Source
scope.PlayerType2 = 'thunderdome'; //480p
scope.PlayerType3 = 'pop_tart'; //480p
scope.PlayerType4 = 'picture-by-picture'; //360p
scope.CurrentChannelName = null;
scope.UsherParams = null;
scope.WasShowingAd = false;
scope.GQLDeviceID = null;
scope.HideBlockingMessage = false;
scope.IsSquadStream = false;
}
declareOptions(window);
var twitchMainWorker = null;
var adBlockDiv = null;
var OriginalVideoPlayerQuality = null;
var IsPlayerAutoQuality = null;
const oldWorker = window.Worker;
window.Worker = class Worker extends oldWorker {
constructor(twitchBlobUrl) {
if (twitchMainWorker) {
super(twitchBlobUrl);
return;
}
var jsURL = getWasmWorkerUrl(twitchBlobUrl);
if (typeof jsURL !== 'string') {
super(twitchBlobUrl);
return;
}
var newBlobStr = `
${getNewUsher.toString()}
${processM3U8.toString()}
${hookWorkerFetch.toString()}
${declareOptions.toString()}
${getAccessToken.toString()}
${gqlRequest.toString()}
${adRecordgqlPacket.toString()}
${tryNotifyTwitch.toString()}
${parseAttributes.toString()}
declareOptions(self);
self.addEventListener('message', function(e) {
if (e.data.key == 'UpdateIsSquadStream') {
IsSquadStream = e.data.value;
} else if (e.data.key == 'UpdateClientVersion') {
ClientVersion = e.data.value;
} else if (e.data.key == 'UpdateClientSession') {
ClientSession = e.data.value;
} else if (e.data.key == 'UpdateClientId') {
ClientID = e.data.value;
} else if (e.data.key == 'UpdateDeviceId') {
GQLDeviceID = e.data.value;
} else if (e.data.key == 'SetHideBlockingMessage') {
if (e.data.value == "true") {
HideBlockingMessage = true;
} else if (e.data.value == "false") {
HideBlockingMessage = false;
}
}
});
hookWorkerFetch();
importScripts('${jsURL}');
`;
super(URL.createObjectURL(new Blob([newBlobStr])));
twitchMainWorker = this;
this.onmessage = function(e) {
if (e.data.key == 'ShowAdBlockBanner') {
if (adBlockDiv == null) {
adBlockDiv = getAdBlockDiv();
}
adBlockDiv.P.textContent = 'Blocking ads...';
adBlockDiv.style.display = 'block';
} else if (e.data.key == 'HideAdBlockBanner') {
if (adBlockDiv == null) {
adBlockDiv = getAdBlockDiv();
}
adBlockDiv.style.display = 'none';
} else if (e.data.key == 'PauseResumePlayer') {
doTwitchPlayerTask(true, false, false, false, false);
} else if (e.data.key == 'ForceChangeQuality') {
//This is used to fix the bug where the video would freeze.
try {
var autoQuality = doTwitchPlayerTask(false, false, false, true, false);
var currentQuality = doTwitchPlayerTask(false, true, false, false, false);
if (IsPlayerAutoQuality == null) {
IsPlayerAutoQuality = autoQuality;
}
if (OriginalVideoPlayerQuality == null) {
OriginalVideoPlayerQuality = currentQuality;
}
if (!currentQuality.includes('480') || e.data.value != null) {
if (!OriginalVideoPlayerQuality.includes('480')) {
var settingsMenu = document.querySelector('div[data-a-target="player-settings-menu"]');
if (settingsMenu == null) {
var settingsCog = document.querySelector('button[data-a-target="player-settings-button"]');
if (settingsCog) {
settingsCog.click();
var qualityMenu = document.querySelector('button[data-a-target="player-settings-menu-item-quality"]');
if (qualityMenu) {
qualityMenu.click();
}
var lowQuality = document.querySelectorAll('input[data-a-target="tw-radio"');
if (lowQuality) {
var qualityToSelect = lowQuality.length - 3;
if (e.data.value != null) {
if (e.data.value.includes('original')) {
e.data.value = OriginalVideoPlayerQuality;
if (IsPlayerAutoQuality) {
e.data.value = 'auto';
}
}
if (e.data.value.includes('160p')) {
qualityToSelect = 5;
}
if (e.data.value.includes('360p')) {
qualityToSelect = 4;
}
if (e.data.value.includes('480p')) {
qualityToSelect = 3;
}
if (e.data.value.includes('720p')) {
qualityToSelect = 2;
}
if (e.data.value.includes('822p')) {
qualityToSelect = 2;
}
if (e.data.value.includes('864p')) {
qualityToSelect = 2;
}
if (e.data.value.includes('900p')) {
qualityToSelect = 2;
}
if (e.data.value.includes('936p')) {
qualityToSelect = 2;
}
if (e.data.value.includes('960p')) {
qualityToSelect = 2;
}
if (e.data.value.includes('1080p')) {
qualityToSelect = 2;
}
if (e.data.value.includes('source')) {
qualityToSelect = 1;
}
if (e.data.value.includes('auto')) {
qualityToSelect = 0;
}
}
lowQuality[qualityToSelect].click();
var originalQuality = JSON.parse(OriginalVideoPlayerQuality);
window.localStorage.setItem('video-quality', '{"default":"'+originalQuality.group+'"}');
if (e.data.value != null) {
OriginalVideoPlayerQuality = null;
IsPlayerAutoQuality = null;
doTwitchPlayerTask(false, false, false, true, true);
}
}
}
}
}
}
} catch (err) {
OriginalVideoPlayerQuality = null;
IsPlayerAutoQuality = null;
}
}
};
function getAdBlockDiv() {
//To display a notification to the user, that an ad is being blocked.
var playerRootDiv = document.querySelector('.video-player');
var adBlockDiv = null;
if (playerRootDiv != null) {
adBlockDiv = playerRootDiv.querySelector('.adblock-overlay');
if (adBlockDiv == null) {
adBlockDiv = document.createElement('div');
adBlockDiv.className = 'adblock-overlay';
adBlockDiv.innerHTML = '<div class="player-adblock-notice" style="color: white; background-color: rgba(0, 0, 0, 0.8); position: absolute; top: 0px; left: 0px; padding: 5px;"><p></p></div>';
adBlockDiv.style.display = 'none';
adBlockDiv.P = adBlockDiv.querySelector('p');
playerRootDiv.appendChild(adBlockDiv);
}
}
return adBlockDiv;
}
}
};
function getWasmWorkerUrl(twitchBlobUrl) {
var req = new XMLHttpRequest();
req.open('GET', twitchBlobUrl, false);
req.send();
return req.responseText.split("'")[1];
}
function hookWorkerFetch() {
var realFetch = fetch;
fetch = async function(url, options) {
if (typeof url === 'string') {
if (url.includes('video-weaver')) {
return new Promise(function(resolve, reject) {
var processAfter = async function(response) {
//Here we check the m3u8 for any ads and also try fallback player types if needed.
var responseText = await response.text();
var weaverText = null;
weaverText = await processM3U8(url, responseText, realFetch, PlayerType2);
if (weaverText.includes(AdSignifier)) {
weaverText = await processM3U8(url, responseText, realFetch, PlayerType3);
}
if (weaverText.includes(AdSignifier)) {
weaverText = await processM3U8(url, responseText, realFetch, PlayerType4);
}
resolve(new Response(weaverText));
};
var send = function() {
return realFetch(url, options).then(function(response) {
processAfter(response);
})['catch'](function(err) {
reject(err);
});
};
send();
});
} else if (url.includes('/api/channel/hls/')) {
var channelName = (new URL(url)).pathname.match(/([^\/]+)(?=\.\w+$)/)[0];
UsherParams = (new URL(url)).search;
CurrentChannelName = channelName;
//To prevent pause/resume loop for mid-rolls.
var isPBYPRequest = url.includes('picture-by-picture');
if (isPBYPRequest) {
url = '';
}
//Make new Usher request if needed to create fallback if UBlock bypass method fails.
var useNewUsher = false;
if (url.includes('subscriber%22%3Afalse') && url.includes('hide_ads%22%3Afalse') && url.includes('show_ads%22%3Atrue')) {
useNewUsher = true;
}
if (url.includes('subscriber%22%3Atrue') && url.includes('hide_ads%22%3Afalse') && url.includes('show_ads%22%3Atrue')) {
useNewUsher = true;
}
if (useNewUsher == true) {
return new Promise(function(resolve, reject) {
var processAfter = async function(response) {
encodingsM3u8 = await getNewUsher(realFetch, response, channelName);
if (encodingsM3u8.length > 1) {
resolve(new Response(encodingsM3u8));
} else {
postMessage({
key: 'HideAdBlockBanner'
});
resolve(encodingsM3u8);
}
};
var send = function() {
return realFetch(url, options).then(function(response) {
processAfter(response);
})['catch'](function(err) {
reject(err);
});
};
send();
});
}
}
}
return realFetch.apply(this, arguments);
};
}
//Added as fallback for when UBlock method fails.
async function getNewUsher(realFetch, originalResponse, channelName) {
var accessTokenResponse = await getAccessToken(channelName, PlayerType1);
var encodingsM3u8 = '';
if (accessTokenResponse.status === 200) {
var accessToken = await accessTokenResponse.json();
try {
var urlInfo = new URL('https://usher.ttvnw.net/api/channel/hls/' + channelName + '.m3u8' + UsherParams);
urlInfo.searchParams.set('sig', accessToken.data.streamPlaybackAccessToken.signature);
urlInfo.searchParams.set('token', accessToken.data.streamPlaybackAccessToken.value);
var encodingsM3u8Response = await realFetch(urlInfo.href);
if (encodingsM3u8Response.status === 200) {
encodingsM3u8 = await encodingsM3u8Response.text();
return encodingsM3u8;
} else {
return originalResponse;
}
} catch (err) {}
return originalResponse;
} else {
return originalResponse;
}
}
async function processM3U8(url, textStr, realFetch, playerType) {
//Checks the m3u8 for ads and if it finds one, instead returns an ad-free stream.
//Ad blocking for squad streams is disabled due to the way multiple weaver urls are used. No workaround so far.
if (IsSquadStream == true) {
return textStr;
}
if (!textStr) {
return textStr;
}
//Some live streams use mp4.
if (!textStr.includes(".ts") && !textStr.includes(".mp4")) {
return textStr;
}
var haveAdTags = textStr.includes(AdSignifier);
if (haveAdTags) {
//Reduces ad frequency.
try {
tryNotifyTwitch(textStr);
} catch (err) {}
var accessTokenResponse = await getAccessToken(CurrentChannelName, playerType);
if (accessTokenResponse.status === 200) {
var accessToken = await accessTokenResponse.json();
try {
var urlInfo = new URL('https://usher.ttvnw.net/api/channel/hls/' + CurrentChannelName + '.m3u8' + UsherParams);
urlInfo.searchParams.set('sig', accessToken.data.streamPlaybackAccessToken.signature);
urlInfo.searchParams.set('token', accessToken.data.streamPlaybackAccessToken.value);
var encodingsM3u8Response = await realFetch(urlInfo.href);
if (encodingsM3u8Response.status === 200) {
var encodingsM3u8 = await encodingsM3u8Response.text();
streamM3u8Url = encodingsM3u8.match(/^https:.*\.m3u8$/mg)[0];
var streamM3u8Response = await realFetch(streamM3u8Url);
if (streamM3u8Response.status == 200) {
var m3u8Text = await streamM3u8Response.text();
WasShowingAd = true;
if (HideBlockingMessage == false) {
postMessage({
key: 'ShowAdBlockBanner'
});
} else if (HideBlockingMessage == true) {
postMessage({
key: 'HideAdBlockBanner'
});
}
postMessage({
key: 'ForceChangeQuality'
});
return m3u8Text;
} else {
return textStr;
}
} else {
return textStr;
}
} catch (err) {}
return textStr;
} else {
return textStr;
}
} else {
if (WasShowingAd) {
WasShowingAd = false;
//Here we put player back to original quality and remove the blocking message.
postMessage({
key: 'ForceChangeQuality',
value: 'original'
});
postMessage({
key: 'PauseResumePlayer'
});
postMessage({
key: 'HideAdBlockBanner'
});
}
return textStr;
}
return textStr;
}
function parseAttributes(str) {
return Object.fromEntries(
str.split(/(?:^|,)((?:[^=]*)=(?:"[^"]*"|[^,]*))/)
.filter(Boolean)
.map(x => {
const idx = x.indexOf('=');
const key = x.substring(0, idx);
const value = x.substring(idx + 1);
const num = Number(value);
return [key, Number.isNaN(num) ? value.startsWith('"') ? JSON.parse(value) : value : num];
}));
}
async function tryNotifyTwitch(streamM3u8) {
//We notify that an ad was requested but was not visible and was also muted.
var matches = streamM3u8.match(/#EXT-X-DATERANGE:(ID="stitched-ad-[^\n]+)\n/);
if (matches.length > 1) {
const attrString = matches[1];
const attr = parseAttributes(attrString);
var podLength = parseInt(attr['X-TV-TWITCH-AD-POD-LENGTH'] ? attr['X-TV-TWITCH-AD-POD-LENGTH'] : '1');
var podPosition = parseInt(attr['X-TV-TWITCH-AD-POD-POSITION'] ? attr['X-TV-TWITCH-AD-POD-POSITION'] : '0');
var radToken = attr['X-TV-TWITCH-AD-RADS-TOKEN'];
var lineItemId = attr['X-TV-TWITCH-AD-LINE-ITEM-ID'];
var orderId = attr['X-TV-TWITCH-AD-ORDER-ID'];
var creativeId = attr['X-TV-TWITCH-AD-CREATIVE-ID'];
var adId = attr['X-TV-TWITCH-AD-ADVERTISER-ID'];
var rollType = attr['X-TV-TWITCH-AD-ROLL-TYPE'].toLowerCase();
const baseData = {
stitched: true,
roll_type: rollType,
player_mute: true,
player_volume: 0.0,
visible: false,
};
for (let podPosition = 0; podPosition < podLength; podPosition++) {
const extendedData = {
...baseData,
ad_id: adId,
ad_position: podPosition,
duration: 0,
creative_id: creativeId,
total_ads: podLength,
order_id: orderId,
line_item_id: lineItemId,
};
await gqlRequest(adRecordgqlPacket('video_ad_impression', radToken, extendedData));
for (let quartile = 0; quartile < 4; quartile++) {
await gqlRequest(
adRecordgqlPacket('video_ad_quartile_complete', radToken, {
...extendedData,
quartile: quartile + 1,
})
);
}
await gqlRequest(adRecordgqlPacket('video_ad_pod_complete', radToken, baseData));
}
}
}
function adRecordgqlPacket(event, radToken, payload) {
return [{
operationName: 'ClientSideAdEventHandling_RecordAdEvent',
variables: {
input: {
eventName: event,
eventPayload: JSON.stringify(payload),
radToken,
},
},
extensions: {
persistedQuery: {
version: 1,
sha256Hash: '7e6c69e6eb59f8ccb97ab73686f3d8b7d85a72a0298745ccd8bfc68e4054ca5b',
},
},
}];
}
function getAccessToken(channelName, playerType, realFetch) {
var body = null;
var templateQuery = 'query PlaybackAccessToken_Template($login: String!, $isLive: Boolean!, $vodID: ID!, $isVod: Boolean!, $playerType: String!) { streamPlaybackAccessToken(channelName: $login, params: {platform: "web", playerBackend: "mediaplayer", playerType: $playerType}) @include(if: $isLive) { value signature __typename } videoPlaybackAccessToken(id: $vodID, params: {platform: "web", playerBackend: "mediaplayer", playerType: $playerType}) @include(if: $isVod) { value signature __typename }}';
body = {
operationName: 'PlaybackAccessToken_Template',
query: templateQuery,
variables: {
'isLive': true,
'login': channelName,
'isVod': false,
'vodID': '',
'playerType': playerType
}
};
return gqlRequest(body, realFetch);
}
function gqlRequest(body, realFetch) {
var fetchFunc = realFetch ? realFetch : fetch;
if (!GQLDeviceID) {
var dcharacters = 'abcdefghijklmnopqrstuvwxyz0123456789';
var dcharactersLength = dcharacters.length;
for (var i = 0; i < 32; i++) {
GQLDeviceID += dcharacters.charAt(Math.floor(Math.random() * dcharactersLength));
}
}
return fetchFunc('https://gql.twitch.tv/gql', {
method: 'POST',
body: JSON.stringify(body),
headers: {
'Client-ID': ClientID,
'Device-ID': GQLDeviceID,
'X-Device-Id': GQLDeviceID,
'Client-Version': ClientVersion,
'Client-Session-Id': ClientSession
}
});
}
function doTwitchPlayerTask(isPausePlay, isCheckQuality, isCorrectBuffer, isAutoQuality, setAutoQuality) {
//This will do an instant pause/play to return to original quality once the ad is finished.
//We also use this function to get the current video player quality set by the user.
//We also use this function to quickly pause/play the player when switching tabs to stop delays.
try {
var videoController = null;
var videoPlayer = null;
function findReactNode(root, constraint) {
if (root.stateNode && constraint(root.stateNode)) {
return root.stateNode;
}
let node = root.child;
while (node) {
const result = findReactNode(node, constraint);
if (result) {
return result;
}
node = node.sibling;
}
return null;
}
var reactRootNode = null;
var rootNode = document.querySelector('#root');
if (rootNode && rootNode._reactRootContainer && rootNode._reactRootContainer._internalRoot && rootNode._reactRootContainer._internalRoot.current) {
reactRootNode = rootNode._reactRootContainer._internalRoot.current;
}
videoPlayer = findReactNode(reactRootNode, node => node.setPlayerActive && node.props && node.props.mediaPlayerInstance);
videoPlayer = videoPlayer && videoPlayer.props && videoPlayer.props.mediaPlayerInstance ? videoPlayer.props.mediaPlayerInstance : null;
if (isPausePlay) {
videoPlayer.pause();
videoPlayer.play();
return;
}
if (isCheckQuality) {
if (typeof videoPlayer.getQuality() == 'undefined') {
return;
}
var playerQuality = JSON.stringify(videoPlayer.getQuality());
if (playerQuality) {
return playerQuality;
} else {
return;
}
}
if (isAutoQuality) {
if (typeof videoPlayer.isAutoQualityMode() == 'undefined') {
return false;
}
var autoQuality = videoPlayer.isAutoQualityMode();
if (autoQuality) {
videoPlayer.setAutoQualityMode(false);
return autoQuality;
} else {
return false;
}
}
if (setAutoQuality) {
videoPlayer.setAutoQualityMode(true);
return;
}
//This only happens when switching tabs and is to correct the high latency caused when opening background tabs and going to them at a later time.
//We check that this is a live stream by the page URL, to prevent vod/clip pause/plays.
try {
var currentPageURL = document.URL;
var isLive = true;
if (currentPageURL.includes('videos/') || currentPageURL.includes('clip/')) {
isLive = false;
}
if (isCorrectBuffer && isLive) {
//A timer is needed due to the player not resuming without it.
setTimeout(function() {
//If latency to broadcaster is above 5 or 15 seconds upon switching tabs, we pause and play the player to reset the latency.
//If latency is between 0-6, user can manually pause and resume to reset latency further.
if (videoPlayer.isLiveLowLatency() && videoPlayer.getLiveLatency() > 5) {
videoPlayer.pause();
videoPlayer.play();
} else if (videoPlayer.getLiveLatency() > 15) {
videoPlayer.pause();
videoPlayer.play();
}
}, 3000);
}
} catch (err) {}
} catch (err) {}
}
var localDeviceID = null;
localDeviceID = window.localStorage.getItem('local_copy_unique_id');
function hookFetch() {
var realFetch = window.fetch;
window.fetch = function(url, init, ...args) {
if (typeof url === 'string') {
//Check if squad stream.
if (window.location.pathname.includes('/squad')) {
if (twitchMainWorker) {
twitchMainWorker.postMessage({
key: 'UpdateIsSquadStream',
value: true
});
}
} else {
if (twitchMainWorker) {
twitchMainWorker.postMessage({
key: 'UpdateIsSquadStream',
value: false
});
}
}
if (url.includes('/access_token') || url.includes('gql')) {
//Device ID is used when notifying Twitch of ads.
var deviceId = init.headers['X-Device-Id'];
if (typeof deviceId !== 'string') {
deviceId = init.headers['Device-ID'];
}
//Added to prevent eventual UBlock conflicts.
if (typeof deviceId === 'string' && !deviceId.includes('twitch-web-wall-mason')) {
GQLDeviceID = deviceId;
} else if (localDeviceID) {
GQLDeviceID = localDeviceID.replace('"', '');
GQLDeviceID = GQLDeviceID.replace('"', '');
}
if (GQLDeviceID && twitchMainWorker) {
if (typeof init.headers['X-Device-Id'] === 'string') {
init.headers['X-Device-Id'] = GQLDeviceID;
}
if (typeof init.headers['Device-ID'] === 'string') {
init.headers['Device-ID'] = GQLDeviceID;
}
twitchMainWorker.postMessage({
key: 'UpdateDeviceId',
value: GQLDeviceID
});
}
//Client version is used in GQL requests.
var clientVersion = init.headers['Client-Version'];
if (clientVersion && typeof clientVersion == 'string') {
ClientVersion = clientVersion;
}
if (ClientVersion && twitchMainWorker) {
twitchMainWorker.postMessage({
key: 'UpdateClientVersion',
value: ClientVersion
});
}
//Client session is used in GQL requests.
var clientSession = init.headers['Client-Session-Id'];
if (clientSession && typeof clientSession == 'string') {
ClientSession = clientSession;
}
if (ClientSession && twitchMainWorker) {
twitchMainWorker.postMessage({
key: 'UpdateClientSession',
value: ClientSession
});
}
//Client ID is used in GQL requests.
if (url.includes('gql') && init && typeof init.body === 'string' && init.body.includes('PlaybackAccessToken')) {
var clientId = init.headers['Client-ID'];
if (clientId && typeof clientId == 'string') {
ClientID = clientId;
} else {
clientId = init.headers['Client-Id'];
if (clientId && typeof clientId == 'string') {
ClientID = clientId;
}
}
if (ClientID && twitchMainWorker) {
twitchMainWorker.postMessage({
key: 'UpdateClientId',
value: ClientID
});
}
}
//To prevent pause/resume loop for mid-rolls.
if (url.includes('gql') && init && typeof init.body === 'string' && init.body.includes('PlaybackAccessToken') && init.body.includes('picture-by-picture')) {
init.body = '';
}
var isPBYPRequest = url.includes('picture-by-picture');
if (isPBYPRequest) {
url = '';
}
}
}
return realFetch.apply(this, arguments);
};
}
hookFetch();
})();

738
vaft/vaft.user.js Normal file
View File

@ -0,0 +1,738 @@
// ==UserScript==
// @name TwitchAdSolutions (vaft)
// @namespace https://github.com/pixeltris/TwitchAdSolutions
// @version 5.3.5
// @description Multiple solutions for blocking Twitch ads (vaft)
// @updateURL https://github.com/pixeltris/TwitchAdSolutions/raw/master/vaft/vaft.user.js
// @downloadURL https://github.com/pixeltris/TwitchAdSolutions/raw/master/vaft/vaft.user.js
// @author https://github.com/cleanlock/VideoAdBlockForTwitch#credits
// @match *://*.twitch.tv/*
// @run-at document-start
// @grant none
// ==/UserScript==
// This code is directly copied from https://github.com/cleanlock/VideoAdBlockForTwitch (only change is whitespace is removed for the ublock origin script - also indented)
(function() {
'use strict';
//This stops Twitch from pausing the player when in another tab and an ad shows.
try {
Object.defineProperty(document, 'visibilityState', {
get() {
return 'visible';
}
});
Object.defineProperty(document, 'hidden', {
get() {
return false;
}
});
const block = e => {
e.preventDefault();
e.stopPropagation();
e.stopImmediatePropagation();
};
const process = e => {
e.preventDefault();
e.stopPropagation();
e.stopImmediatePropagation();
//This corrects the background tab buffer bug when switching to the background tab for the first time after an extended period.
doTwitchPlayerTask(false, false, true, false, false);
};
document.addEventListener('visibilitychange', process, true);
document.addEventListener('webkitvisibilitychange', block, true);
document.addEventListener('mozvisibilitychange', block, true);
document.addEventListener('hasFocus', block, true);
if (/Firefox/.test(navigator.userAgent)) {
Object.defineProperty(document, 'mozHidden', {
get() {
return false;
}
});
} else {
Object.defineProperty(document, 'webkitHidden', {
get() {
return false;
}
});
}
} catch (err) {}
//Send settings updates to worker.
window.addEventListener("message", (event) => {
if (event.source != window)
return;
if (event.data.type && (event.data.type == "SetHideBlockingMessage")) {
if (twitchMainWorker) {
twitchMainWorker.postMessage({
key: 'SetHideBlockingMessage',
value: event.data.value
});
}
}
}, false);
function declareOptions(scope) {
scope.AdSignifier = 'stitched';
scope.ClientID = 'kimne78kx3ncx6brgo4mv6wki5h1ko';
scope.ClientVersion = 'null';
scope.ClientSession = 'null';
scope.PlayerType1 = 'site'; //Source
scope.PlayerType2 = 'thunderdome'; //480p
scope.PlayerType3 = 'pop_tart'; //480p
scope.PlayerType4 = 'picture-by-picture'; //360p
scope.CurrentChannelName = null;
scope.UsherParams = null;
scope.WasShowingAd = false;
scope.GQLDeviceID = null;
scope.HideBlockingMessage = false;
scope.IsSquadStream = false;
}
declareOptions(window);
var twitchMainWorker = null;
var adBlockDiv = null;
var OriginalVideoPlayerQuality = null;
var IsPlayerAutoQuality = null;
const oldWorker = window.Worker;
window.Worker = class Worker extends oldWorker {
constructor(twitchBlobUrl) {
if (twitchMainWorker) {
super(twitchBlobUrl);
return;
}
var jsURL = getWasmWorkerUrl(twitchBlobUrl);
if (typeof jsURL !== 'string') {
super(twitchBlobUrl);
return;
}
var newBlobStr = `
${getNewUsher.toString()}
${processM3U8.toString()}
${hookWorkerFetch.toString()}
${declareOptions.toString()}
${getAccessToken.toString()}
${gqlRequest.toString()}
${adRecordgqlPacket.toString()}
${tryNotifyTwitch.toString()}
${parseAttributes.toString()}
declareOptions(self);
self.addEventListener('message', function(e) {
if (e.data.key == 'UpdateIsSquadStream') {
IsSquadStream = e.data.value;
} else if (e.data.key == 'UpdateClientVersion') {
ClientVersion = e.data.value;
} else if (e.data.key == 'UpdateClientSession') {
ClientSession = e.data.value;
} else if (e.data.key == 'UpdateClientId') {
ClientID = e.data.value;
} else if (e.data.key == 'UpdateDeviceId') {
GQLDeviceID = e.data.value;
} else if (e.data.key == 'SetHideBlockingMessage') {
if (e.data.value == "true") {
HideBlockingMessage = true;
} else if (e.data.value == "false") {
HideBlockingMessage = false;
}
}
});
hookWorkerFetch();
importScripts('${jsURL}');
`;
super(URL.createObjectURL(new Blob([newBlobStr])));
twitchMainWorker = this;
this.onmessage = function(e) {
if (e.data.key == 'ShowAdBlockBanner') {
if (adBlockDiv == null) {
adBlockDiv = getAdBlockDiv();
}
adBlockDiv.P.textContent = 'Blocking ads...';
adBlockDiv.style.display = 'block';
} else if (e.data.key == 'HideAdBlockBanner') {
if (adBlockDiv == null) {
adBlockDiv = getAdBlockDiv();
}
adBlockDiv.style.display = 'none';
} else if (e.data.key == 'PauseResumePlayer') {
doTwitchPlayerTask(true, false, false, false, false);
} else if (e.data.key == 'ForceChangeQuality') {
//This is used to fix the bug where the video would freeze.
try {
var autoQuality = doTwitchPlayerTask(false, false, false, true, false);
var currentQuality = doTwitchPlayerTask(false, true, false, false, false);
if (IsPlayerAutoQuality == null) {
IsPlayerAutoQuality = autoQuality;
}
if (OriginalVideoPlayerQuality == null) {
OriginalVideoPlayerQuality = currentQuality;
}
if (!currentQuality.includes('480') || e.data.value != null) {
if (!OriginalVideoPlayerQuality.includes('480')) {
var settingsMenu = document.querySelector('div[data-a-target="player-settings-menu"]');
if (settingsMenu == null) {
var settingsCog = document.querySelector('button[data-a-target="player-settings-button"]');
if (settingsCog) {
settingsCog.click();
var qualityMenu = document.querySelector('button[data-a-target="player-settings-menu-item-quality"]');
if (qualityMenu) {
qualityMenu.click();
}
var lowQuality = document.querySelectorAll('input[data-a-target="tw-radio"');
if (lowQuality) {
var qualityToSelect = lowQuality.length - 3;
if (e.data.value != null) {
if (e.data.value.includes('original')) {
e.data.value = OriginalVideoPlayerQuality;
if (IsPlayerAutoQuality) {
e.data.value = 'auto';
}
}
if (e.data.value.includes('160p')) {
qualityToSelect = 5;
}
if (e.data.value.includes('360p')) {
qualityToSelect = 4;
}
if (e.data.value.includes('480p')) {
qualityToSelect = 3;
}
if (e.data.value.includes('720p')) {
qualityToSelect = 2;
}
if (e.data.value.includes('822p')) {
qualityToSelect = 2;
}
if (e.data.value.includes('864p')) {
qualityToSelect = 2;
}
if (e.data.value.includes('900p')) {
qualityToSelect = 2;
}
if (e.data.value.includes('936p')) {
qualityToSelect = 2;
}
if (e.data.value.includes('960p')) {
qualityToSelect = 2;
}
if (e.data.value.includes('1080p')) {
qualityToSelect = 2;
}
if (e.data.value.includes('source')) {
qualityToSelect = 1;
}
if (e.data.value.includes('auto')) {
qualityToSelect = 0;
}
}
lowQuality[qualityToSelect].click();
var originalQuality = JSON.parse(OriginalVideoPlayerQuality);
window.localStorage.setItem('video-quality', '{"default":"'+originalQuality.group+'"}');
if (e.data.value != null) {
OriginalVideoPlayerQuality = null;
IsPlayerAutoQuality = null;
doTwitchPlayerTask(false, false, false, true, true);
}
}
}
}
}
}
} catch (err) {
OriginalVideoPlayerQuality = null;
IsPlayerAutoQuality = null;
}
}
};
function getAdBlockDiv() {
//To display a notification to the user, that an ad is being blocked.
var playerRootDiv = document.querySelector('.video-player');
var adBlockDiv = null;
if (playerRootDiv != null) {
adBlockDiv = playerRootDiv.querySelector('.adblock-overlay');
if (adBlockDiv == null) {
adBlockDiv = document.createElement('div');
adBlockDiv.className = 'adblock-overlay';
adBlockDiv.innerHTML = '<div class="player-adblock-notice" style="color: white; background-color: rgba(0, 0, 0, 0.8); position: absolute; top: 0px; left: 0px; padding: 5px;"><p></p></div>';
adBlockDiv.style.display = 'none';
adBlockDiv.P = adBlockDiv.querySelector('p');
playerRootDiv.appendChild(adBlockDiv);
}
}
return adBlockDiv;
}
}
};
function getWasmWorkerUrl(twitchBlobUrl) {
var req = new XMLHttpRequest();
req.open('GET', twitchBlobUrl, false);
req.send();
return req.responseText.split("'")[1];
}
function hookWorkerFetch() {
var realFetch = fetch;
fetch = async function(url, options) {
if (typeof url === 'string') {
if (url.includes('video-weaver')) {
return new Promise(function(resolve, reject) {
var processAfter = async function(response) {
//Here we check the m3u8 for any ads and also try fallback player types if needed.
var responseText = await response.text();
var weaverText = null;
weaverText = await processM3U8(url, responseText, realFetch, PlayerType2);
if (weaverText.includes(AdSignifier)) {
weaverText = await processM3U8(url, responseText, realFetch, PlayerType3);
}
if (weaverText.includes(AdSignifier)) {
weaverText = await processM3U8(url, responseText, realFetch, PlayerType4);
}
resolve(new Response(weaverText));
};
var send = function() {
return realFetch(url, options).then(function(response) {
processAfter(response);
})['catch'](function(err) {
reject(err);
});
};
send();
});
} else if (url.includes('/api/channel/hls/')) {
var channelName = (new URL(url)).pathname.match(/([^\/]+)(?=\.\w+$)/)[0];
UsherParams = (new URL(url)).search;
CurrentChannelName = channelName;
//To prevent pause/resume loop for mid-rolls.
var isPBYPRequest = url.includes('picture-by-picture');
if (isPBYPRequest) {
url = '';
}
//Make new Usher request if needed to create fallback if UBlock bypass method fails.
var useNewUsher = false;
if (url.includes('subscriber%22%3Afalse') && url.includes('hide_ads%22%3Afalse') && url.includes('show_ads%22%3Atrue')) {
useNewUsher = true;
}
if (url.includes('subscriber%22%3Atrue') && url.includes('hide_ads%22%3Afalse') && url.includes('show_ads%22%3Atrue')) {
useNewUsher = true;
}
if (useNewUsher == true) {
return new Promise(function(resolve, reject) {
var processAfter = async function(response) {
encodingsM3u8 = await getNewUsher(realFetch, response, channelName);
if (encodingsM3u8.length > 1) {
resolve(new Response(encodingsM3u8));
} else {
postMessage({
key: 'HideAdBlockBanner'
});
resolve(encodingsM3u8);
}
};
var send = function() {
return realFetch(url, options).then(function(response) {
processAfter(response);
})['catch'](function(err) {
reject(err);
});
};
send();
});
}
}
}
return realFetch.apply(this, arguments);
};
}
//Added as fallback for when UBlock method fails.
async function getNewUsher(realFetch, originalResponse, channelName) {
var accessTokenResponse = await getAccessToken(channelName, PlayerType1);
var encodingsM3u8 = '';
if (accessTokenResponse.status === 200) {
var accessToken = await accessTokenResponse.json();
try {
var urlInfo = new URL('https://usher.ttvnw.net/api/channel/hls/' + channelName + '.m3u8' + UsherParams);
urlInfo.searchParams.set('sig', accessToken.data.streamPlaybackAccessToken.signature);
urlInfo.searchParams.set('token', accessToken.data.streamPlaybackAccessToken.value);
var encodingsM3u8Response = await realFetch(urlInfo.href);
if (encodingsM3u8Response.status === 200) {
encodingsM3u8 = await encodingsM3u8Response.text();
return encodingsM3u8;
} else {
return originalResponse;
}
} catch (err) {}
return originalResponse;
} else {
return originalResponse;
}
}
async function processM3U8(url, textStr, realFetch, playerType) {
//Checks the m3u8 for ads and if it finds one, instead returns an ad-free stream.
//Ad blocking for squad streams is disabled due to the way multiple weaver urls are used. No workaround so far.
if (IsSquadStream == true) {
return textStr;
}
if (!textStr) {
return textStr;
}
//Some live streams use mp4.
if (!textStr.includes(".ts") && !textStr.includes(".mp4")) {
return textStr;
}
var haveAdTags = textStr.includes(AdSignifier);
if (haveAdTags) {
//Reduces ad frequency.
try {
tryNotifyTwitch(textStr);
} catch (err) {}
var accessTokenResponse = await getAccessToken(CurrentChannelName, playerType);
if (accessTokenResponse.status === 200) {
var accessToken = await accessTokenResponse.json();
try {
var urlInfo = new URL('https://usher.ttvnw.net/api/channel/hls/' + CurrentChannelName + '.m3u8' + UsherParams);
urlInfo.searchParams.set('sig', accessToken.data.streamPlaybackAccessToken.signature);
urlInfo.searchParams.set('token', accessToken.data.streamPlaybackAccessToken.value);
var encodingsM3u8Response = await realFetch(urlInfo.href);
if (encodingsM3u8Response.status === 200) {
var encodingsM3u8 = await encodingsM3u8Response.text();
streamM3u8Url = encodingsM3u8.match(/^https:.*\.m3u8$/mg)[0];
var streamM3u8Response = await realFetch(streamM3u8Url);
if (streamM3u8Response.status == 200) {
var m3u8Text = await streamM3u8Response.text();
WasShowingAd = true;
if (HideBlockingMessage == false) {
postMessage({
key: 'ShowAdBlockBanner'
});
} else if (HideBlockingMessage == true) {
postMessage({
key: 'HideAdBlockBanner'
});
}
postMessage({
key: 'ForceChangeQuality'
});
return m3u8Text;
} else {
return textStr;
}
} else {
return textStr;
}
} catch (err) {}
return textStr;
} else {
return textStr;
}
} else {
if (WasShowingAd) {
WasShowingAd = false;
//Here we put player back to original quality and remove the blocking message.
postMessage({
key: 'ForceChangeQuality',
value: 'original'
});
postMessage({
key: 'PauseResumePlayer'
});
postMessage({
key: 'HideAdBlockBanner'
});
}
return textStr;
}
return textStr;
}
function parseAttributes(str) {
return Object.fromEntries(
str.split(/(?:^|,)((?:[^=]*)=(?:"[^"]*"|[^,]*))/)
.filter(Boolean)
.map(x => {
const idx = x.indexOf('=');
const key = x.substring(0, idx);
const value = x.substring(idx + 1);
const num = Number(value);
return [key, Number.isNaN(num) ? value.startsWith('"') ? JSON.parse(value) : value : num];
}));
}
async function tryNotifyTwitch(streamM3u8) {
//We notify that an ad was requested but was not visible and was also muted.
var matches = streamM3u8.match(/#EXT-X-DATERANGE:(ID="stitched-ad-[^\n]+)\n/);
if (matches.length > 1) {
const attrString = matches[1];
const attr = parseAttributes(attrString);
var podLength = parseInt(attr['X-TV-TWITCH-AD-POD-LENGTH'] ? attr['X-TV-TWITCH-AD-POD-LENGTH'] : '1');
var podPosition = parseInt(attr['X-TV-TWITCH-AD-POD-POSITION'] ? attr['X-TV-TWITCH-AD-POD-POSITION'] : '0');
var radToken = attr['X-TV-TWITCH-AD-RADS-TOKEN'];
var lineItemId = attr['X-TV-TWITCH-AD-LINE-ITEM-ID'];
var orderId = attr['X-TV-TWITCH-AD-ORDER-ID'];
var creativeId = attr['X-TV-TWITCH-AD-CREATIVE-ID'];
var adId = attr['X-TV-TWITCH-AD-ADVERTISER-ID'];
var rollType = attr['X-TV-TWITCH-AD-ROLL-TYPE'].toLowerCase();
const baseData = {
stitched: true,
roll_type: rollType,
player_mute: true,
player_volume: 0.0,
visible: false,
};
for (let podPosition = 0; podPosition < podLength; podPosition++) {
const extendedData = {
...baseData,
ad_id: adId,
ad_position: podPosition,
duration: 0,
creative_id: creativeId,
total_ads: podLength,
order_id: orderId,
line_item_id: lineItemId,
};
await gqlRequest(adRecordgqlPacket('video_ad_impression', radToken, extendedData));
for (let quartile = 0; quartile < 4; quartile++) {
await gqlRequest(
adRecordgqlPacket('video_ad_quartile_complete', radToken, {
...extendedData,
quartile: quartile + 1,
})
);
}
await gqlRequest(adRecordgqlPacket('video_ad_pod_complete', radToken, baseData));
}
}
}
function adRecordgqlPacket(event, radToken, payload) {
return [{
operationName: 'ClientSideAdEventHandling_RecordAdEvent',
variables: {
input: {
eventName: event,
eventPayload: JSON.stringify(payload),
radToken,
},
},
extensions: {
persistedQuery: {
version: 1,
sha256Hash: '7e6c69e6eb59f8ccb97ab73686f3d8b7d85a72a0298745ccd8bfc68e4054ca5b',
},
},
}];
}
function getAccessToken(channelName, playerType, realFetch) {
var body = null;
var templateQuery = 'query PlaybackAccessToken_Template($login: String!, $isLive: Boolean!, $vodID: ID!, $isVod: Boolean!, $playerType: String!) { streamPlaybackAccessToken(channelName: $login, params: {platform: "web", playerBackend: "mediaplayer", playerType: $playerType}) @include(if: $isLive) { value signature __typename } videoPlaybackAccessToken(id: $vodID, params: {platform: "web", playerBackend: "mediaplayer", playerType: $playerType}) @include(if: $isVod) { value signature __typename }}';
body = {
operationName: 'PlaybackAccessToken_Template',
query: templateQuery,
variables: {
'isLive': true,
'login': channelName,
'isVod': false,
'vodID': '',
'playerType': playerType
}
};
return gqlRequest(body, realFetch);
}
function gqlRequest(body, realFetch) {
var fetchFunc = realFetch ? realFetch : fetch;
if (!GQLDeviceID) {
var dcharacters = 'abcdefghijklmnopqrstuvwxyz0123456789';
var dcharactersLength = dcharacters.length;
for (var i = 0; i < 32; i++) {
GQLDeviceID += dcharacters.charAt(Math.floor(Math.random() * dcharactersLength));
}
}
return fetchFunc('https://gql.twitch.tv/gql', {
method: 'POST',
body: JSON.stringify(body),
headers: {
'Client-ID': ClientID,
'Device-ID': GQLDeviceID,
'X-Device-Id': GQLDeviceID,
'Client-Version': ClientVersion,
'Client-Session-Id': ClientSession
}
});
}
function doTwitchPlayerTask(isPausePlay, isCheckQuality, isCorrectBuffer, isAutoQuality, setAutoQuality) {
//This will do an instant pause/play to return to original quality once the ad is finished.
//We also use this function to get the current video player quality set by the user.
//We also use this function to quickly pause/play the player when switching tabs to stop delays.
try {
var videoController = null;
var videoPlayer = null;
function findReactNode(root, constraint) {
if (root.stateNode && constraint(root.stateNode)) {
return root.stateNode;
}
let node = root.child;
while (node) {
const result = findReactNode(node, constraint);
if (result) {
return result;
}
node = node.sibling;
}
return null;
}
var reactRootNode = null;
var rootNode = document.querySelector('#root');
if (rootNode && rootNode._reactRootContainer && rootNode._reactRootContainer._internalRoot && rootNode._reactRootContainer._internalRoot.current) {
reactRootNode = rootNode._reactRootContainer._internalRoot.current;
}
videoPlayer = findReactNode(reactRootNode, node => node.setPlayerActive && node.props && node.props.mediaPlayerInstance);
videoPlayer = videoPlayer && videoPlayer.props && videoPlayer.props.mediaPlayerInstance ? videoPlayer.props.mediaPlayerInstance : null;
if (isPausePlay) {
videoPlayer.pause();
videoPlayer.play();
return;
}
if (isCheckQuality) {
if (typeof videoPlayer.getQuality() == 'undefined') {
return;
}
var playerQuality = JSON.stringify(videoPlayer.getQuality());
if (playerQuality) {
return playerQuality;
} else {
return;
}
}
if (isAutoQuality) {
if (typeof videoPlayer.isAutoQualityMode() == 'undefined') {
return false;
}
var autoQuality = videoPlayer.isAutoQualityMode();
if (autoQuality) {
videoPlayer.setAutoQualityMode(false);
return autoQuality;
} else {
return false;
}
}
if (setAutoQuality) {
videoPlayer.setAutoQualityMode(true);
return;
}
//This only happens when switching tabs and is to correct the high latency caused when opening background tabs and going to them at a later time.
//We check that this is a live stream by the page URL, to prevent vod/clip pause/plays.
try {
var currentPageURL = document.URL;
var isLive = true;
if (currentPageURL.includes('videos/') || currentPageURL.includes('clip/')) {
isLive = false;
}
if (isCorrectBuffer && isLive) {
//A timer is needed due to the player not resuming without it.
setTimeout(function() {
//If latency to broadcaster is above 5 or 15 seconds upon switching tabs, we pause and play the player to reset the latency.
//If latency is between 0-6, user can manually pause and resume to reset latency further.
if (videoPlayer.isLiveLowLatency() && videoPlayer.getLiveLatency() > 5) {
videoPlayer.pause();
videoPlayer.play();
} else if (videoPlayer.getLiveLatency() > 15) {
videoPlayer.pause();
videoPlayer.play();
}
}, 3000);
}
} catch (err) {}
} catch (err) {}
}
var localDeviceID = null;
localDeviceID = window.localStorage.getItem('local_copy_unique_id');
function hookFetch() {
var realFetch = window.fetch;
window.fetch = function(url, init, ...args) {
if (typeof url === 'string') {
//Check if squad stream.
if (window.location.pathname.includes('/squad')) {
if (twitchMainWorker) {
twitchMainWorker.postMessage({
key: 'UpdateIsSquadStream',
value: true
});
}
} else {
if (twitchMainWorker) {
twitchMainWorker.postMessage({
key: 'UpdateIsSquadStream',
value: false
});
}
}
if (url.includes('/access_token') || url.includes('gql')) {
//Device ID is used when notifying Twitch of ads.
var deviceId = init.headers['X-Device-Id'];
if (typeof deviceId !== 'string') {
deviceId = init.headers['Device-ID'];
}
//Added to prevent eventual UBlock conflicts.
if (typeof deviceId === 'string' && !deviceId.includes('twitch-web-wall-mason')) {
GQLDeviceID = deviceId;
} else if (localDeviceID) {
GQLDeviceID = localDeviceID.replace('"', '');
GQLDeviceID = GQLDeviceID.replace('"', '');
}
if (GQLDeviceID && twitchMainWorker) {
if (typeof init.headers['X-Device-Id'] === 'string') {
init.headers['X-Device-Id'] = GQLDeviceID;
}
if (typeof init.headers['Device-ID'] === 'string') {
init.headers['Device-ID'] = GQLDeviceID;
}
twitchMainWorker.postMessage({
key: 'UpdateDeviceId',
value: GQLDeviceID
});
}
//Client version is used in GQL requests.
var clientVersion = init.headers['Client-Version'];
if (clientVersion && typeof clientVersion == 'string') {
ClientVersion = clientVersion;
}
if (ClientVersion && twitchMainWorker) {
twitchMainWorker.postMessage({
key: 'UpdateClientVersion',
value: ClientVersion
});
}
//Client session is used in GQL requests.
var clientSession = init.headers['Client-Session-Id'];
if (clientSession && typeof clientSession == 'string') {
ClientSession = clientSession;
}
if (ClientSession && twitchMainWorker) {
twitchMainWorker.postMessage({
key: 'UpdateClientSession',
value: ClientSession
});
}
//Client ID is used in GQL requests.
if (url.includes('gql') && init && typeof init.body === 'string' && init.body.includes('PlaybackAccessToken')) {
var clientId = init.headers['Client-ID'];
if (clientId && typeof clientId == 'string') {
ClientID = clientId;
} else {
clientId = init.headers['Client-Id'];
if (clientId && typeof clientId == 'string') {
ClientID = clientId;
}
}
if (ClientID && twitchMainWorker) {
twitchMainWorker.postMessage({
key: 'UpdateClientId',
value: ClientID
});
}
}
//To prevent pause/resume loop for mid-rolls.
if (url.includes('gql') && init && typeof init.body === 'string' && init.body.includes('PlaybackAccessToken') && init.body.includes('picture-by-picture')) {
init.body = '';
}
var isPBYPRequest = url.includes('picture-by-picture');
if (isPBYPRequest) {
url = '';
}
}
}
return realFetch.apply(this, arguments);
};
}
hookFetch();
})();