469 lines
16 KiB
JavaScript
469 lines
16 KiB
JavaScript
if(Debug.debug){
|
|
console.log("Loading Comms.js");
|
|
}
|
|
|
|
class CommsClient {
|
|
constructor(name, settings) {
|
|
if (BrowserDetect.firefox) {
|
|
this.port = browser.runtime.connect({name: name});
|
|
} else if (BrowserDetect.chrome) {
|
|
this.port = chrome.runtime.connect({name: name});
|
|
} else if (BrowserDetect.edge) {
|
|
this.port = browser.runtime.connect({name: name})
|
|
}
|
|
|
|
var ths = this;
|
|
this._listener = m => ths.processReceivedMessage(m);
|
|
this.port.onMessage.addListener(this._listener);
|
|
|
|
this.settings = settings;
|
|
this.pageInfo = undefined;
|
|
this.commsId = (Math.random() * 20).toFixed(0);
|
|
}
|
|
|
|
destroy() {
|
|
this.pageInfo = null;
|
|
this.settings = null;
|
|
if (!BrowserDetect.edge) { // edge is a very special browser made by outright morons.
|
|
this.port.onMessage.removeListener(this._listener);
|
|
}
|
|
}
|
|
|
|
setPageInfo(pageInfo){
|
|
|
|
this.pageInfo = pageInfo;
|
|
|
|
if(Debug.debug) {
|
|
console.log(`[CommsClient::setPageInfo] <${this.commsId}>`, "SETTING PAGEINFO —", this.pageInfo, this)
|
|
}
|
|
|
|
var ths = this;
|
|
this._listener = m => ths.processReceivedMessage(m);
|
|
if (!BrowserDetect.edge) {
|
|
this.port.onMessage.removeListener(this._listener);
|
|
}
|
|
this.port.onMessage.addListener(this._listener);
|
|
|
|
}
|
|
|
|
processReceivedMessage(message){
|
|
if(Debug.debug && Debug.comms){
|
|
console.log(`[CommsClient.js::processMessage] <${this.commsId}> Received message from background script!`, message);
|
|
}
|
|
|
|
if (!this.pageInfo || !this.settings.active) {
|
|
if(Debug.debug && Debug.comms){
|
|
console.log(`[CommsClient.js::processMessage] <${this.commsId}> this.pageInfo (or settings) not defined. Extension is probably disabled for this site.\npageInfo:`, this.pageInfo,
|
|
"\nsettings.active:", this.settings.active,
|
|
"\nnobj:", this
|
|
);
|
|
}
|
|
return;
|
|
}
|
|
|
|
if (message.cmd === 'get-current-zoom') {
|
|
this.pageInfo.requestCurrentZoom();
|
|
}
|
|
|
|
if (message.cmd === "set-ar") {
|
|
this.pageInfo.setAr(message.arg, message.playing);
|
|
} else if (message.cmd === 'set-alignment') {
|
|
this.pageInfo.setVideoFloat(message.arg, message.playing);
|
|
this.pageInfo.restoreAr();
|
|
} else if (message.cmd === "set-stretch") {
|
|
this.pageInfo.setStretchMode(message.arg, message.playing);
|
|
} else if (message.cmd === "autoar-start") {
|
|
if (message.enabled !== false) {
|
|
this.pageInfo.initArDetection(message.playing);
|
|
this.pageInfo.startArDetection(message.playing);
|
|
} else {
|
|
this.pageInfo.stopArDetection(message.playing);
|
|
}
|
|
} else if (message.cmd === "pause-processing") {
|
|
this.pageInfo.pauseProcessing(message.playing);
|
|
} else if (message.cmd === "resume-processing") {
|
|
// todo: autoArStatus
|
|
this.pageInfo.resumeProcessing(message.autoArStatus, message.playing);
|
|
} else if (message.cmd === 'set-zoom') {
|
|
this.pageInfo.setZoom(message.zoom, true, message.playing);
|
|
} else if (message.cmd === 'mark-player') {
|
|
this.pageInfo.markPlayer(message.name, message.color);
|
|
} else if (message.cmd === 'unmark-player') {
|
|
this.pageInfo.unmarkPlayer();
|
|
}
|
|
}
|
|
|
|
async sleep(n){
|
|
return new Promise( (resolve, reject) => setTimeout(resolve, n) );
|
|
}
|
|
|
|
async sendMessage_nonpersistent(message){
|
|
if(BrowserDetect.firefox){
|
|
return browser.runtime.sendMessage(message)
|
|
} else {
|
|
return new Promise((resolve, reject) => {
|
|
try{
|
|
if(BrowserDetect.edge){
|
|
browser.runtime.sendMessage(message, function(response){
|
|
var r = response;
|
|
resolve(r);
|
|
});
|
|
} else {
|
|
chrome.runtime.sendMessage(message, function(response){
|
|
// Chrome/js shittiness mitigation — remove this line and an empty array will be returned
|
|
var r = response;
|
|
resolve(r);
|
|
});
|
|
}
|
|
}
|
|
catch(e){
|
|
reject(e);
|
|
}
|
|
});
|
|
}
|
|
}
|
|
|
|
async requestSettings(){
|
|
if(Debug.debug){
|
|
console.log("%c[CommsClient::requestSettings] sending request for congif!", "background: #11D; color: #aad");
|
|
}
|
|
var response = await this.sendMessage_nonpersistent({cmd: 'get-config'});
|
|
if(Debug.debug){
|
|
console.log("%c[CommsClient::requestSettings] received settings response!", "background: #11D; color: #aad", response);
|
|
}
|
|
|
|
if(! response || response.extensionConf){
|
|
return Promise.resolve(false);
|
|
}
|
|
|
|
this.settings.active = JSON.parse(response.extensionConf);
|
|
return Promise.resolve(true);
|
|
}
|
|
|
|
registerVideo(){
|
|
if (Debug.debug && Debug.comms) {
|
|
console.log(`[CommsClient::registerVideo] <${this.commsId}>`, "Registering video for current page.");
|
|
}
|
|
if (this.pageInfo.videos.length) {
|
|
this.port.postMessage({cmd: "has-video"});
|
|
}
|
|
}
|
|
|
|
unregisterVideo(){
|
|
if (Debug.debug && Debug.comms) {
|
|
console.log(`[CommsClient::unregisterVideo] <${this.commsId}>`, "Unregistering video for current page.");
|
|
}
|
|
this.port.postMessage({cmd: "noVideo"}); // ayymd
|
|
}
|
|
|
|
announceZoom(scale){
|
|
this.port.postMessage({cmd: "announce-zoom", zoom: scale});
|
|
this.registerVideo()
|
|
}
|
|
|
|
}
|
|
|
|
class CommsServer {
|
|
constructor(server) {
|
|
this.server = server;
|
|
this.settings = server.settings;
|
|
this.ports = [];
|
|
|
|
var ths = this;
|
|
|
|
if (BrowserDetect.firefox) {
|
|
browser.runtime.onConnect.addListener(p => ths.onConnect(p));
|
|
browser.runtime.onMessage.addListener(m => ths.processReceivedMessage_nonpersistent_ff(m));
|
|
} else {
|
|
chrome.runtime.onConnect.addListener(p => ths.onConnect(p));
|
|
chrome.runtime.onMessage.addListener((msg, sender, callback) => ths.processReceivedMessage_nonpersistent_chrome(m, sender, callback));
|
|
}
|
|
}
|
|
|
|
async getCurrentTabHostname() {
|
|
const activeTab = await this._getActiveTab();
|
|
|
|
const url = activeTab[0].url;
|
|
|
|
var hostname;
|
|
|
|
if (url.indexOf("://") > -1) { //find & remove protocol (http, ftp, etc.) and get hostname
|
|
hostname = url.split('/')[2];
|
|
}
|
|
else {
|
|
hostname = url.split('/')[0];
|
|
}
|
|
|
|
hostname = hostname.split(':')[0]; //find & remove port number
|
|
hostname = hostname.split('?')[0]; //find & remove "?"
|
|
|
|
return hostname;
|
|
}
|
|
|
|
sendToAll(message){
|
|
for(var p of this.ports){
|
|
for(var frame in p){
|
|
p[frame].postMessage(message);
|
|
}
|
|
}
|
|
}
|
|
|
|
async _getActiveTab() {
|
|
if (BrowserDetect.firefox) {
|
|
return await browser.tabs.query({currentWindow: true, active: true});
|
|
} else {
|
|
return await new Promise( (resolve, reject) => {
|
|
chrome.tabs.query({lastFocusedWindow: true, active: true}, function (res) {
|
|
resolve(res);
|
|
});
|
|
});
|
|
}
|
|
}
|
|
|
|
async sendToFrame(message, tab, frame) {
|
|
|
|
if(Debug.debug && Debug.comms){
|
|
console.log(`%c[CommsServer::sendToFrame] attempting to send message to tab ${tab}, frame ${frame}`, "background: #dda; color: #11D", message);
|
|
}
|
|
|
|
if (isNaN(tab)) {
|
|
if (tab === '__playing') {
|
|
message['playing'] = true;
|
|
this.sendToAll(message);
|
|
return;
|
|
} else if (tab === '__all') {
|
|
this.sendToAll(message);
|
|
return;
|
|
}
|
|
[tab, frame] = tab.split('-')
|
|
}
|
|
|
|
if(Debug.debug && Debug.comms){
|
|
console.log(`%c[CommsServer::sendToFrame] attempting to send message to tab ${tab}, frame ${frame}`, "background: #dda; color: #11D", message);
|
|
}
|
|
|
|
try {
|
|
this.ports[tab][frame].postMessage(message);
|
|
} catch (e) {
|
|
if(Debug.debug && Debug.comms){
|
|
console.log(`%c[CommsServer::sendToFrame] Sending message failed. Reason:`, "background: #dda; color: #11D", e);
|
|
}
|
|
}
|
|
}
|
|
|
|
async sendToActive(message) {
|
|
if(Debug.debug && Debug.comms){
|
|
console.log("%c[CommsServer::sendToActive] trying to send a message to active tab. Message:", "background: #dda; color: #11D", message);
|
|
}
|
|
|
|
var tabs = await this._getActiveTab();
|
|
|
|
if(Debug.debug && Debug.comms){
|
|
console.log("[CommsServer::_sendToActive_ff] currently active tab(s)?", tabs);
|
|
for (var key in this.ports[tabs[0].id]) {
|
|
console.log("key?", key, this.ports[tabs[0].id]);
|
|
// this.ports[tabs[0].id][key].postMessage(message);
|
|
}
|
|
}
|
|
|
|
for (var key in this.ports[tabs[0].id]) {
|
|
this.ports[tabs[0].id][key].postMessage(message);
|
|
}
|
|
}
|
|
|
|
onConnect(port){
|
|
var ths = this;
|
|
|
|
// poseben primer | special case
|
|
if (port.name === 'popup-port') {
|
|
this.popupPort = port;
|
|
this.popupPort.onMessage.addListener( (m,p) => ths.processReceivedMessage(m,p));
|
|
return;
|
|
}
|
|
|
|
var tabId = port.sender.tab.id;
|
|
var frameId = port.sender.frameId;
|
|
if(! this.ports[tabId]){
|
|
this.ports[tabId] = {};
|
|
}
|
|
this.ports[tabId][frameId] = port;
|
|
this.ports[tabId][frameId].onMessage.addListener( (m,p) => ths.processReceivedMessage(m, p));
|
|
this.ports[tabId][frameId].onDisconnect.addListener( (p) => {
|
|
delete ths.ports[p.sender.tab.id][p.sender.frameId];
|
|
if(Object.keys(ths.ports[p.sender.tab.id]).length === 0){
|
|
ths.ports[tabId] = undefined;
|
|
}
|
|
});
|
|
}
|
|
|
|
async processReceivedMessage(message, port){
|
|
if (Debug.debug && Debug.comms) {
|
|
console.log("[CommsServer.js::processMessage] Received message from background script!", message, "port", port, "\nsettings and server:", this.settings,this.server);
|
|
}
|
|
|
|
if (message.cmd === 'announce-zoom') {
|
|
// forward off to the popup, no use for this here
|
|
try {
|
|
this.popupPort.postMessage({cmd: 'set-current-zoom', zoom: message.zoom});
|
|
} catch (e) {
|
|
// can't forward stuff to popup if it isn't open
|
|
}
|
|
} else if (message.cmd === 'get-current-zoom') {
|
|
this.sendToActive(message);
|
|
}
|
|
|
|
if (message.cmd === 'get-current-site') {
|
|
port.postMessage({cmd: 'set-current-site', site: this.server.getVideoTab(), tabHostname: await this.getCurrentTabHostname()});
|
|
}
|
|
if (message.cmd === 'popup-set-selected-tab') {
|
|
this.server.setSelectedTab(message.selectedMenu, message.selectedSubitem);
|
|
}
|
|
|
|
if (message.cmd === 'get-config') {
|
|
if(Debug.debug) {
|
|
console.log("CommsServer: received get-config. Active settings?", this.settings.active, "\n(settings:", this.settings, ")")
|
|
}
|
|
port.postMessage({cmd: "set-config", conf: this.settings.active, site: this.server.currentSite})
|
|
} else if (message.cmd === 'set-stretch') {
|
|
this.sendToFrame(message, message.targetFrame);
|
|
} else if (message.cmd === 'set-ar') {
|
|
this.sendToFrame(message, message.targetFrame);
|
|
} else if (message.cmd === 'set-custom-ar') {
|
|
this.settings.active.keyboard.shortcuts.q.arg = message.arg;
|
|
this.settings.save();
|
|
} else if (message.cmd === 'set-alignment') {
|
|
this.sendToFrame(message, message.targetFrame);
|
|
} else if (message.cmd === 'autoar-start') {
|
|
this.sendToFrame(message, message.targetFrame);
|
|
} else if (message.cmd === "autoar-disable") { // LEGACY - can be removed prolly
|
|
this.settings.active.arDetect.mode = "disabled";
|
|
if(message.reason){
|
|
this.settings.active.arDetect.disabledReason = message.reason;
|
|
} else {
|
|
this.settings.active.arDetect.disabledReason = 'User disabled';
|
|
}
|
|
this.settings.save();
|
|
} else if (message.cmd === 'set-zoom') {
|
|
this.sendToFrame(message, message.targetFrame);
|
|
} else if (message.cmd === 'has-video') {
|
|
this.server.registerVideo(port.sender);
|
|
} else if (message.cmd === 'noVideo') {
|
|
this.server.unregisterVideo(port.sender);
|
|
} else if (message.cmd === 'mark-player') {
|
|
this.sendToFrame(message, message.targetTab, message.targetFrame);
|
|
} else if (message.cmd === 'unmark-player') {
|
|
this.sendToAll(message);
|
|
}
|
|
}
|
|
|
|
processReceivedMessage_nonpersistent_ff(message, sender){
|
|
if (Debug.debug && Debug.comms) {
|
|
console.log("%c[CommsServer.js::processMessage_nonpersistent_ff] Received message from background script!", "background-color: #11D; color: #aad", message, sender);
|
|
}
|
|
|
|
if (message.cmd === 'get-config') {
|
|
var ret = {extensionConf: JSON.stringify(this.settings.active)};
|
|
if (Debug.debug && Debug.comms) {
|
|
console.log("%c[CommsServer.js::processMessage_nonpersistent_ff] Returning this:", "background-color: #11D; color: #aad", ret);
|
|
}
|
|
Promise.resolve(ret);
|
|
} else if (message.cmd === "autoar-enable") {
|
|
this.settings.active.arDetect.mode = "blacklist";
|
|
this.settings.save();
|
|
this.sendToAll({cmd: "reload-settings", sender: "uwbg"})
|
|
if(Debug.debug){
|
|
console.log("[uw-bg] autoar set to enabled (blacklist). evidenz:", this.settings.active);
|
|
}
|
|
} else if (message.cmd === "autoar-disable") {
|
|
this.settings.active.arDetect.mode = "disabled";
|
|
if(message.reason){
|
|
this.settings.active.arDetect.disabledReason = message.reason;
|
|
} else {
|
|
this.settings.active.arDetect.disabledReason = 'User disabled';
|
|
}
|
|
this.settings.save();
|
|
this.sendToAll({cmd: 'reload-settings', newConf: this.settings.active});
|
|
if(Debug.debug){
|
|
console.log("[uw-bg] autoar set to disabled. evidenz:", this.settings.active);
|
|
}
|
|
} else if (message.cmd === "autoar-set-interval") {
|
|
if(Debug.debug)
|
|
console.log("[uw-bg] trying to set new interval for autoAr. New interval is",message.timeout,"ms");
|
|
|
|
// set fairly liberal limit
|
|
var timeout = message.timeout < 4 ? 4 : message.timeout;
|
|
this.settings.active.arDetect.timer_playing = timeout;
|
|
this.settings.save();
|
|
this.sendToAll({cmd: 'reload-settings', newConf: this.settings.active});
|
|
}
|
|
}
|
|
|
|
processReceivedMessage_nonpersistent_chrome(message, sender, sendResponse){
|
|
if (Debug.debug && Debug.comms) {
|
|
console.log("[CommsServer.js::processMessage_nonpersistent_chrome] Received message from background script!", message);
|
|
}
|
|
|
|
if(message.cmd === 'get-config') {
|
|
sendResponse({extensionConf: JSON.stringify(this.settings.active), site: this.getCurrentTabHostname()});
|
|
// return true;
|
|
} else if (message.cmd === "autoar-enable") {
|
|
this.settings.active.arDetect.mode = "blacklist";
|
|
this.settings.save();
|
|
this.sendToAll({cmd: "reload-settings", sender: "uwbg"})
|
|
if(Debug.debug){
|
|
console.log("[uw-bg] autoar set to enabled (blacklist). evidenz:", this.settings.active);
|
|
}
|
|
} else if (message.cmd === "autoar-disable") {
|
|
this.settings.active.arDetect.mode = "disabled";
|
|
if(message.reason){
|
|
this.settings.active.arDetect.disabledReason = message.reason;
|
|
} else {
|
|
this.settings.active.arDetect.disabledReason = 'User disabled';
|
|
}
|
|
this.settings.save();
|
|
this.sendToAll({cmd: 'reload-settings', newConf: this.settings.active});
|
|
if(Debug.debug){
|
|
console.log("[uw-bg] autoar set to disabled. evidenz:", this.settings.active);
|
|
}
|
|
} else if (message.cmd === "autoar-set-interval") {
|
|
if(Debug.debug)
|
|
console.log("[uw-bg] trying to set new interval for autoAr. New interval is",message.timeout,"ms");
|
|
|
|
// set fairly liberal limit
|
|
var timeout = message.timeout < 4 ? 4 : message.timeout;
|
|
this.settings.active.arDetect.timer_playing = timeout;
|
|
this.settings.save();
|
|
this.sendToAll({cmd: 'reload-settings', newConf: this.settings.active});
|
|
}
|
|
}
|
|
}
|
|
|
|
class Comms {
|
|
static async sendMessage(message){
|
|
if(BrowserDetect.firefox){
|
|
return browser.runtime.sendMessage(message)
|
|
} else {
|
|
return new Promise((resolve, reject) => {
|
|
try{
|
|
if(BrowserDetect.edge){
|
|
browser.runtime.sendMessage(message, function(response){
|
|
var r = response;
|
|
resolve(r);
|
|
});
|
|
} else {
|
|
chrome.runtime.sendMessage(message, function(response){
|
|
// Chrome/js shittiness mitigation — remove this line and an empty array will be returned
|
|
var r = response;
|
|
resolve(r);
|
|
});
|
|
}
|
|
}
|
|
catch(e){
|
|
reject(e);
|
|
}
|
|
});
|
|
}
|
|
}
|
|
|
|
}
|