mirror of
https://github.com/moonlight-stream/moonlight-chrome.git
synced 2025-08-17 16:46:31 +00:00
Fixed indentation usign atom-beautify
This commit is contained in:
Jorys_Paulin
parent
49bdfcc33d
commit
28a76fa965
@ -1,33 +1,35 @@
|
|||||||
function createWindow(state) {
|
function createWindow(state) {
|
||||||
chrome.app.window.create('index.html', {
|
chrome.app.window.create('index.html', {
|
||||||
state: state,
|
state: state,
|
||||||
bounds: {
|
bounds: {
|
||||||
width: 960,
|
width: 960,
|
||||||
height: 540
|
height: 540
|
||||||
}
|
}
|
||||||
}, function(window) {
|
}, function(window) {
|
||||||
// workaround:
|
// workaround:
|
||||||
// state = 'normal' in some cases not work (e.g. starting app from 'chrome://extensions' always open window in fullscreen mode)
|
// state = 'normal' in some cases not work (e.g. starting app from 'chrome://extensions' always open window in fullscreen mode)
|
||||||
// it requires manually restoring window state to 'normal'
|
// it requires manually restoring window state to 'normal'
|
||||||
if (state == 'normal') {
|
if (state == 'normal') {
|
||||||
setTimeout(function() { window.restore(); }, 1000);
|
setTimeout(function() {
|
||||||
}
|
window.restore();
|
||||||
});
|
}, 1000);
|
||||||
|
}
|
||||||
|
});
|
||||||
}
|
}
|
||||||
|
|
||||||
chrome.app.runtime.onLaunched.addListener(function() {
|
chrome.app.runtime.onLaunched.addListener(function() {
|
||||||
console.log('Chrome app runtime launched.');
|
console.log('Chrome app runtime launched.');
|
||||||
var windowState = 'normal';
|
var windowState = 'normal';
|
||||||
|
|
||||||
if (chrome.storage) {
|
if (chrome.storage) {
|
||||||
// load stored window state
|
// load stored window state
|
||||||
chrome.storage.sync.get('windowState', function(item) {
|
chrome.storage.sync.get('windowState', function(item) {
|
||||||
windowState = (item && item.windowState)
|
windowState = (item && item.windowState) ?
|
||||||
? item.windowState
|
item.windowState :
|
||||||
: windowState;
|
windowState;
|
||||||
createWindow(windowState);
|
createWindow(windowState);
|
||||||
});
|
});
|
||||||
} else {
|
} else {
|
||||||
createWindow(windowState);
|
createWindow(windowState);
|
||||||
}
|
}
|
||||||
});
|
});
|
||||||
|
|||||||
@ -35,7 +35,7 @@ var common = (function() {
|
|||||||
} else if (tool == 'pnacl') {
|
} else if (tool == 'pnacl') {
|
||||||
mimetype = 'application/x-pnacl';
|
mimetype = 'application/x-pnacl';
|
||||||
}
|
}
|
||||||
console.log('%c[updateStatus, common.js]', 'color: gray;', 'mimetype: ' + mimetype);
|
console.log('%c[updateStatus, common.js]', 'color: gray;', 'mimetype: ' + mimetype);
|
||||||
return mimetype;
|
return mimetype;
|
||||||
}
|
}
|
||||||
|
|
||||||
@ -72,7 +72,7 @@ var common = (function() {
|
|||||||
*/
|
*/
|
||||||
function createNaClModule(name, tool, path, width, height, attrs) {
|
function createNaClModule(name, tool, path, width, height, attrs) {
|
||||||
console.log('%c[createNaClModule, common.js]', 'color: gray;', "name: " + name + ", tool: " + tool + ", path: " + path + ", width: " + width +
|
console.log('%c[createNaClModule, common.js]', 'color: gray;', "name: " + name + ", tool: " + tool + ", path: " + path + ", width: " + width +
|
||||||
", height: " + height + ", attrs: " + JSON.stringify(attrs));
|
", height: " + height + ", attrs: " + JSON.stringify(attrs));
|
||||||
var moduleEl = document.createElement('embed');
|
var moduleEl = document.createElement('embed');
|
||||||
moduleEl.setAttribute('name', 'nacl_module');
|
moduleEl.setAttribute('name', 'nacl_module');
|
||||||
moduleEl.setAttribute('id', 'nacl_module');
|
moduleEl.setAttribute('id', 'nacl_module');
|
||||||
@ -115,7 +115,7 @@ var common = (function() {
|
|||||||
moduleEl.readyState = 4;
|
moduleEl.readyState = 4;
|
||||||
moduleEl.dispatchEvent(new CustomEvent('load'));
|
moduleEl.dispatchEvent(new CustomEvent('load'));
|
||||||
moduleEl.dispatchEvent(new CustomEvent('loadend'));
|
moduleEl.dispatchEvent(new CustomEvent('loadend'));
|
||||||
}, 100); // 100 ms
|
}, 100); // 100 ms
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
@ -158,7 +158,7 @@ var common = (function() {
|
|||||||
* This event listener is registered in attachDefaultListeners above.
|
* This event listener is registered in attachDefaultListeners above.
|
||||||
*/
|
*/
|
||||||
function handleCrash(event) {
|
function handleCrash(event) {
|
||||||
console.log('%c[handleCrash, common.js]', 'color: red;', event);
|
console.log('%c[handleCrash, common.js]', 'color: red;', event);
|
||||||
if (common.naclModule.exitStatus == -1) {
|
if (common.naclModule.exitStatus == -1) {
|
||||||
updateStatus('CRASHED');
|
updateStatus('CRASHED');
|
||||||
} else {
|
} else {
|
||||||
@ -373,7 +373,7 @@ document.addEventListener('DOMContentLoaded', function() {
|
|||||||
for (var key_ix = 0; key_ix < pairs.length; key_ix++) {
|
for (var key_ix = 0; key_ix < pairs.length; key_ix++) {
|
||||||
var keyValue = pairs[key_ix].split('=');
|
var keyValue = pairs[key_ix].split('=');
|
||||||
searchVars[unescape(keyValue[0])] =
|
searchVars[unescape(keyValue[0])] =
|
||||||
keyValue.length > 1 ? unescape(keyValue[1]) : '';
|
keyValue.length > 1 ? unescape(keyValue[1]) : '';
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
@ -393,7 +393,7 @@ document.addEventListener('DOMContentLoaded', function() {
|
|||||||
}
|
}
|
||||||
|
|
||||||
var tc = toolchains.indexOf(searchVars.tc) !== -1 ?
|
var tc = toolchains.indexOf(searchVars.tc) !== -1 ?
|
||||||
searchVars.tc : toolchains[0];
|
searchVars.tc : toolchains[0];
|
||||||
|
|
||||||
// If the config value is included in the search vars, use that.
|
// If the config value is included in the search vars, use that.
|
||||||
// Otherwise default to Release if it is valid, or the first value if
|
// Otherwise default to Release if it is valid, or the first value if
|
||||||
@ -411,7 +411,7 @@ document.addEventListener('DOMContentLoaded', function() {
|
|||||||
isRelease = path.toLowerCase().indexOf('release') != -1;
|
isRelease = path.toLowerCase().indexOf('release') != -1;
|
||||||
|
|
||||||
loadFunction(body.dataset.name, tc, path, body.dataset.width,
|
loadFunction(body.dataset.name, tc, path, body.dataset.width,
|
||||||
body.dataset.height, attrs);
|
body.dataset.height, attrs);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
});
|
});
|
||||||
|
|||||||
1349
static/js/index.js
1349
static/js/index.js
File diff suppressed because it is too large
Load Diff
@ -9,66 +9,69 @@ var callbacks_ids = 1;
|
|||||||
* @return {void} The NaCl module calls back trought the handleMessage method
|
* @return {void} The NaCl module calls back trought the handleMessage method
|
||||||
*/
|
*/
|
||||||
var sendMessage = function(method, params) {
|
var sendMessage = function(method, params) {
|
||||||
return new Promise(function(resolve, reject) {
|
return new Promise(function(resolve, reject) {
|
||||||
var id = callbacks_ids++;
|
var id = callbacks_ids++;
|
||||||
callbacks[id] = {'resolve': resolve, 'reject': reject};
|
callbacks[id] = {
|
||||||
|
'resolve': resolve,
|
||||||
|
'reject': reject
|
||||||
|
};
|
||||||
|
|
||||||
common.naclModule.postMessage({
|
common.naclModule.postMessage({
|
||||||
'callbackId': id,
|
'callbackId': id,
|
||||||
'method': method,
|
'method': method,
|
||||||
'params': params
|
'params': params
|
||||||
});
|
|
||||||
});
|
});
|
||||||
|
});
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* handleMessage - Handles messages from the NaCl module
|
* handleMessage - Handles messages from the NaCl module
|
||||||
*
|
*
|
||||||
* @param {Object} msg An object given by the NaCl module
|
* @param {Object} msg An object given by the NaCl module
|
||||||
* @return {void}
|
* @return {void}
|
||||||
*/
|
*/
|
||||||
function handleMessage(msg) {
|
function handleMessage(msg) {
|
||||||
if (msg.data.callbackId && callbacks[msg.data.callbackId]) { // if it's a callback, treat it as such
|
if (msg.data.callbackId && callbacks[msg.data.callbackId]) { // if it's a callback, treat it as such
|
||||||
callbacks[msg.data.callbackId][msg.data.type](msg.data.ret);
|
callbacks[msg.data.callbackId][msg.data.type](msg.data.ret);
|
||||||
delete callbacks[msg.data.callbackId]
|
delete callbacks[msg.data.callbackId]
|
||||||
} else { // else, it's just info, or an event
|
} else { // else, it's just info, or an event
|
||||||
console.log('%c[messages.js, handleMessage]', 'color:gray;', 'Message data: ', msg.data)
|
console.log('%c[messages.js, handleMessage]', 'color:gray;', 'Message data: ', msg.data)
|
||||||
if(msg.data === 'streamTerminated') { // if it's a recognized event, notify the appropriate function
|
if (msg.data === 'streamTerminated') { // if it's a recognized event, notify the appropriate function
|
||||||
$('#loadingSpinner').css('display', 'none'); // This is a fallback for RTSP handshake failing, which immediately terminates the stream.
|
$('#loadingSpinner').css('display', 'none'); // This is a fallback for RTSP handshake failing, which immediately terminates the stream.
|
||||||
$('body').css('backgroundColor', '#282C38');
|
$('body').css('backgroundColor', '#282C38');
|
||||||
|
|
||||||
// Release our keep awake request
|
// Release our keep awake request
|
||||||
chrome.power.releaseKeepAwake();
|
chrome.power.releaseKeepAwake();
|
||||||
|
|
||||||
api.refreshServerInfo().then(function (ret) { // refresh the serverinfo to acknowledge the currently running app
|
api.refreshServerInfo().then(function(ret) { // refresh the serverinfo to acknowledge the currently running app
|
||||||
api.getAppList().then(function (appList) {
|
api.getAppList().then(function(appList) {
|
||||||
appList.forEach(function (app) {
|
appList.forEach(function(app) {
|
||||||
stylizeBoxArt(api, app.id); // and reapply stylization to indicate what's currently running
|
stylizeBoxArt(api, app.id); // and reapply stylization to indicate what's currently running
|
||||||
});
|
});
|
||||||
});
|
});
|
||||||
showApps(api);
|
showApps(api);
|
||||||
|
|
||||||
isInGame = false;
|
isInGame = false;
|
||||||
|
|
||||||
// restore main window from 'fullscreen' to 'normal' mode (if required)
|
// restore main window from 'fullscreen' to 'normal' mode (if required)
|
||||||
(windowState == 'normal') && chrome.app.window.current().restore();
|
(windowState == 'normal') && chrome.app.window.current().restore();
|
||||||
});
|
});
|
||||||
|
|
||||||
} else if(msg.data === 'Connection Established') {
|
} else if (msg.data === 'Connection Established') {
|
||||||
$('#loadingSpinner').css('display', 'none');
|
$('#loadingSpinner').css('display', 'none');
|
||||||
$('body').css('backgroundColor', 'black');
|
$('body').css('backgroundColor', 'black');
|
||||||
|
|
||||||
// Keep the display awake while streaming
|
// Keep the display awake while streaming
|
||||||
chrome.power.requestKeepAwake("display");
|
chrome.power.requestKeepAwake("display");
|
||||||
} else if(msg.data.indexOf('ProgressMsg: ') === 0) {
|
} else if (msg.data.indexOf('ProgressMsg: ') === 0) {
|
||||||
$('#loadingMessage').text(msg.data.replace('ProgressMsg: ', ''));
|
$('#loadingMessage').text(msg.data.replace('ProgressMsg: ', ''));
|
||||||
} else if(msg.data.indexOf('TransientMsg: ') === 0) {
|
} else if (msg.data.indexOf('TransientMsg: ') === 0) {
|
||||||
snackbarLog(msg.data.replace('TransientMsg: ', ''));
|
snackbarLog(msg.data.replace('TransientMsg: ', ''));
|
||||||
} else if(msg.data.indexOf('DialogMsg: ') === 0) {
|
} else if (msg.data.indexOf('DialogMsg: ') === 0) {
|
||||||
// FIXME: Really use a dialog
|
// FIXME: Really use a dialog
|
||||||
snackbarLogLong(msg.data.replace('DialogMsg: ', ''));
|
snackbarLogLong(msg.data.replace('DialogMsg: ', ''));
|
||||||
} else if(msg.data === 'displayVideo') {
|
} else if (msg.data === 'displayVideo') {
|
||||||
$("#listener").addClass("fullscreen");
|
$("#listener").addClass("fullscreen");
|
||||||
}
|
|
||||||
}
|
}
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
@ -1,468 +1,471 @@
|
|||||||
function guuid() {
|
function guuid() {
|
||||||
return 'xxxxxxxx-xxxx-4xxx-yxxx-xxxxxxxxxxxx'.replace(/[xy]/g, function(c) {
|
return 'xxxxxxxx-xxxx-4xxx-yxxx-xxxxxxxxxxxx'.replace(/[xy]/g, function(c) {
|
||||||
var r = Math.random()*16|0, v = c == 'x' ? r : (r&0x3|0x8);
|
var r = Math.random() * 16 | 0,
|
||||||
return v.toString(16);
|
v = c == 'x' ? r : (r & 0x3 | 0x8);
|
||||||
});
|
return v.toString(16);
|
||||||
|
});
|
||||||
}
|
}
|
||||||
|
|
||||||
function uniqueid() {
|
function uniqueid() {
|
||||||
return 'xxxxxxxxxxxxxxxx'.replace(/[x]/g, function(c) {
|
return 'xxxxxxxxxxxxxxxx'.replace(/[x]/g, function(c) {
|
||||||
var r = Math.random()*16|0;
|
var r = Math.random() * 16 | 0;
|
||||||
return r.toString(16);
|
return r.toString(16);
|
||||||
});
|
});
|
||||||
}
|
}
|
||||||
|
|
||||||
function generateRemoteInputKey() {
|
function generateRemoteInputKey() {
|
||||||
return 'xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxx'.replace(/[x]/g, function(c) {
|
return 'xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxx'.replace(/[x]/g, function(c) {
|
||||||
var r = Math.random()*16|0;
|
var r = Math.random() * 16 | 0;
|
||||||
return r.toString(16);
|
return r.toString(16);
|
||||||
});
|
});
|
||||||
}
|
}
|
||||||
|
|
||||||
function generateRemoteInputKeyId() {
|
function generateRemoteInputKeyId() {
|
||||||
return ((Math.random()-0.5) * 0x7FFFFFFF)|0;
|
return ((Math.random() - 0.5) * 0x7FFFFFFF) | 0;
|
||||||
}
|
}
|
||||||
|
|
||||||
function getConnectedGamepadMask() {
|
function getConnectedGamepadMask() {
|
||||||
var count = 0;
|
var count = 0;
|
||||||
var mask = 0;
|
var mask = 0;
|
||||||
var gamepads = navigator.getGamepads ? navigator.getGamepads() : [];
|
var gamepads = navigator.getGamepads ? navigator.getGamepads() : [];
|
||||||
|
|
||||||
for (var i = 0; i < gamepads.length; i++) {
|
for (var i = 0; i < gamepads.length; i++) {
|
||||||
var gamepad = gamepads[i];
|
var gamepad = gamepads[i];
|
||||||
if (gamepad) {
|
if (gamepad) {
|
||||||
// See logic in gamepad.cpp
|
// See logic in gamepad.cpp
|
||||||
// These must stay in sync!
|
// These must stay in sync!
|
||||||
|
|
||||||
if (!gamepad.connected) {
|
if (!gamepad.connected) {
|
||||||
// Not connected
|
// Not connected
|
||||||
continue;
|
continue;
|
||||||
}
|
}
|
||||||
|
|
||||||
if (gamepad.timestamp == 0) {
|
if (gamepad.timestamp == 0) {
|
||||||
// On some platforms, Chrome returns "connected" pads that
|
// On some platforms, Chrome returns "connected" pads that
|
||||||
// really aren't, so timestamp stays at zero. To work around this,
|
// really aren't, so timestamp stays at zero. To work around this,
|
||||||
// we'll only count gamepads that have a non-zero timestamp in our
|
// we'll only count gamepads that have a non-zero timestamp in our
|
||||||
// controller index.
|
// controller index.
|
||||||
continue;
|
continue;
|
||||||
}
|
}
|
||||||
|
|
||||||
mask |= 1 << count++;
|
mask |= 1 << count++;
|
||||||
}
|
|
||||||
}
|
}
|
||||||
|
}
|
||||||
|
|
||||||
console.log('%c[utils.js, getConnectedGamepadMask]', 'color:gray;', 'Detected '+count+' gamepads');
|
console.log('%c[utils.js, getConnectedGamepadMask]', 'color:gray;', 'Detected ' + count + ' gamepads');
|
||||||
return mask;
|
return mask;
|
||||||
}
|
}
|
||||||
|
|
||||||
String.prototype.toHex = function() {
|
String.prototype.toHex = function() {
|
||||||
var hex = '';
|
var hex = '';
|
||||||
for(var i = 0; i < this.length; i++) {
|
for (var i = 0; i < this.length; i++) {
|
||||||
hex += '' + this.charCodeAt(i).toString(16);
|
hex += '' + this.charCodeAt(i).toString(16);
|
||||||
}
|
}
|
||||||
return hex;
|
return hex;
|
||||||
}
|
}
|
||||||
|
|
||||||
function NvHTTP(address, clientUid, userEnteredAddress = '') {
|
function NvHTTP(address, clientUid, userEnteredAddress = '') {
|
||||||
console.log('%c[utils.js, NvHTTP Object]', 'color: gray;', this);
|
console.log('%c[utils.js, NvHTTP Object]', 'color: gray;', this);
|
||||||
this.address = address;
|
this.address = address;
|
||||||
this.paired = false;
|
this.paired = false;
|
||||||
this.currentGame = 0;
|
this.currentGame = 0;
|
||||||
this.serverMajorVersion = 0;
|
this.serverMajorVersion = 0;
|
||||||
this.appVersion = '';
|
this.appVersion = '';
|
||||||
this.clientUid = clientUid;
|
this.clientUid = clientUid;
|
||||||
this._pollCount = 0;
|
this._pollCount = 0;
|
||||||
this._consecutivePollFailures = 0;
|
this._consecutivePollFailures = 0;
|
||||||
this.online = false;
|
this.online = false;
|
||||||
|
|
||||||
this.userEnteredAddress = userEnteredAddress; // if the user entered an address, we keep it on hand to try when polling
|
this.userEnteredAddress = userEnteredAddress; // if the user entered an address, we keep it on hand to try when polling
|
||||||
this.serverUid = '';
|
this.serverUid = '';
|
||||||
this.GfeVersion = '';
|
this.GfeVersion = '';
|
||||||
this.supportedDisplayModes = {}; // key: y-resolution:x-resolution, value: array of supported framerates (only ever seen 30 or 60, here)
|
this.supportedDisplayModes = {}; // key: y-resolution:x-resolution, value: array of supported framerates (only ever seen 30 or 60, here)
|
||||||
this.gputype = '';
|
this.gputype = '';
|
||||||
this.numofapps = 0;
|
this.numofapps = 0;
|
||||||
this.hostname = address;
|
this.hostname = address;
|
||||||
this.externalIP = '';
|
this.externalIP = '';
|
||||||
this._pollCompletionCallbacks = [];
|
this._pollCompletionCallbacks = [];
|
||||||
|
|
||||||
_self = this;
|
_self = this;
|
||||||
};
|
};
|
||||||
|
|
||||||
function _arrayBufferToBase64( buffer ) {
|
function _arrayBufferToBase64(buffer) {
|
||||||
var binary = '';
|
var binary = '';
|
||||||
var bytes = new Uint8Array( buffer );
|
var bytes = new Uint8Array(buffer);
|
||||||
var len = bytes.byteLength;
|
var len = bytes.byteLength;
|
||||||
for (var i = 0; i < len; i++) {
|
for (var i = 0; i < len; i++) {
|
||||||
binary += String.fromCharCode( bytes[ i ] );
|
binary += String.fromCharCode(bytes[i]);
|
||||||
}
|
}
|
||||||
return window.btoa( binary );
|
return window.btoa(binary);
|
||||||
}
|
}
|
||||||
|
|
||||||
function _base64ToArrayBuffer(base64) {
|
function _base64ToArrayBuffer(base64) {
|
||||||
var binary_string = window.atob(base64);
|
var binary_string = window.atob(base64);
|
||||||
var len = binary_string.length;
|
var len = binary_string.length;
|
||||||
var bytes = new Uint8Array( len );
|
var bytes = new Uint8Array(len);
|
||||||
for (var i = 0; i < len; i++) {
|
for (var i = 0; i < len; i++) {
|
||||||
bytes[i] = binary_string.charCodeAt(i);
|
bytes[i] = binary_string.charCodeAt(i);
|
||||||
}
|
}
|
||||||
return bytes.buffer;
|
return bytes.buffer;
|
||||||
}
|
}
|
||||||
|
|
||||||
NvHTTP.prototype = {
|
NvHTTP.prototype = {
|
||||||
refreshServerInfo: function () {
|
refreshServerInfo: function() {
|
||||||
// try HTTPS first
|
// try HTTPS first
|
||||||
return sendMessage('openUrl', [ this._baseUrlHttps + '/serverinfo?' + this._buildUidStr(), false]).then(function(ret) {
|
return sendMessage('openUrl', [this._baseUrlHttps + '/serverinfo?' + this._buildUidStr(), false]).then(function(ret) {
|
||||||
if (!this._parseServerInfo(ret)) { // if that fails
|
if (!this._parseServerInfo(ret)) { // if that fails
|
||||||
// try HTTP as a failover. Useful to clients who aren't paired yet
|
// try HTTP as a failover. Useful to clients who aren't paired yet
|
||||||
return sendMessage('openUrl', [ this._baseUrlHttp + '/serverinfo?' + this._buildUidStr(), false]).then(function(retHttp) {
|
return sendMessage('openUrl', [this._baseUrlHttp + '/serverinfo?' + this._buildUidStr(), false]).then(function(retHttp) {
|
||||||
this._parseServerInfo(retHttp);
|
this._parseServerInfo(retHttp);
|
||||||
}.bind(this));
|
|
||||||
}
|
|
||||||
}.bind(this));
|
}.bind(this));
|
||||||
},
|
}
|
||||||
|
}.bind(this));
|
||||||
|
},
|
||||||
|
|
||||||
// refreshes the server info using a given address. This is useful for testing whether we can successfully ping a host at a given address
|
// refreshes the server info using a given address. This is useful for testing whether we can successfully ping a host at a given address
|
||||||
refreshServerInfoAtAddress: function(givenAddress) {
|
refreshServerInfoAtAddress: function(givenAddress) {
|
||||||
// try HTTPS first
|
// try HTTPS first
|
||||||
return sendMessage('openUrl', [ 'https://' + givenAddress + ':47984' + '/serverinfo?' + this._buildUidStr(), false]).then(function(ret) {
|
return sendMessage('openUrl', ['https://' + givenAddress + ':47984' + '/serverinfo?' + this._buildUidStr(), false]).then(function(ret) {
|
||||||
if (!this._parseServerInfo(ret)) { // if that fails
|
if (!this._parseServerInfo(ret)) { // if that fails
|
||||||
console.log('%c[utils.js, utils.js, refreshServerInfoAtAddress]', 'color: gray;', 'Failed to parse serverinfo from HTTPS, falling back to HTTP');
|
console.log('%c[utils.js, utils.js, refreshServerInfoAtAddress]', 'color: gray;', 'Failed to parse serverinfo from HTTPS, falling back to HTTP');
|
||||||
// try HTTP as a failover. Useful to clients who aren't paired yet
|
// try HTTP as a failover. Useful to clients who aren't paired yet
|
||||||
return sendMessage('openUrl', [ 'http://' + givenAddress + ':47989' + '/serverinfo?' + this._buildUidStr(), false]).then(function(retHttp) {
|
return sendMessage('openUrl', ['http://' + givenAddress + ':47989' + '/serverinfo?' + this._buildUidStr(), false]).then(function(retHttp) {
|
||||||
return this._parseServerInfo(retHttp);
|
return this._parseServerInfo(retHttp);
|
||||||
}.bind(this));
|
|
||||||
}
|
|
||||||
}.bind(this));
|
}.bind(this));
|
||||||
},
|
}
|
||||||
|
}.bind(this));
|
||||||
|
},
|
||||||
|
|
||||||
// called every few seconds to poll the server for updated info
|
// called every few seconds to poll the server for updated info
|
||||||
pollServer: function(onComplete) {
|
pollServer: function(onComplete) {
|
||||||
// Pend this callback on completion
|
// Pend this callback on completion
|
||||||
this._pollCompletionCallbacks.push(onComplete);
|
this._pollCompletionCallbacks.push(onComplete);
|
||||||
|
|
||||||
// Check if a poll was already in progress
|
// Check if a poll was already in progress
|
||||||
if (this._pollCompletionCallbacks.length > 1) {
|
if (this._pollCompletionCallbacks.length > 1) {
|
||||||
// Don't start another. The one in progress will
|
// Don't start another. The one in progress will
|
||||||
// alert our caller too.
|
// alert our caller too.
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
|
this.selectServerAddress(function(successfulAddress) {
|
||||||
|
// Successfully determined server address. Update base URL.
|
||||||
|
this.address = successfulAddress;
|
||||||
|
this._baseUrlHttps = 'https://' + successfulAddress + ':47984';
|
||||||
|
this._baseUrlHttp = 'http://' + successfulAddress + ':47989';
|
||||||
|
|
||||||
|
// Poll for the app list every 10 successful serverinfo polls.
|
||||||
|
// Not including the first one to avoid PCs taking a while to show
|
||||||
|
// as online initially
|
||||||
|
if (this._pollCount++ % 10 == 1) {
|
||||||
|
this.getAppListWithCacheFlush();
|
||||||
|
}
|
||||||
|
|
||||||
|
this._consecutivePollFailures = 0;
|
||||||
|
this.online = true;
|
||||||
|
|
||||||
|
// Call all pending completion callbacks
|
||||||
|
var completion;
|
||||||
|
while ((completion = this._pollCompletionCallbacks.pop())) {
|
||||||
|
completion(this);
|
||||||
|
}
|
||||||
|
}.bind(this), function() {
|
||||||
|
if (++this._consecutivePollFailures >= 2) {
|
||||||
|
this.online = false;
|
||||||
|
}
|
||||||
|
|
||||||
|
// Call all pending completion callbacks
|
||||||
|
var completion;
|
||||||
|
while ((completion = this._pollCompletionCallbacks.pop())) {
|
||||||
|
completion(this);
|
||||||
|
}
|
||||||
|
}.bind(this));
|
||||||
|
},
|
||||||
|
|
||||||
|
// initially pings the server to try and figure out if it's routable by any means.
|
||||||
|
selectServerAddress: function(onSuccess, onFailure) {
|
||||||
|
// TODO: Deduplicate the addresses
|
||||||
|
this.refreshServerInfoAtAddress(this.address).then(function(successPrevAddr) {
|
||||||
|
onSuccess(this.address);
|
||||||
|
}.bind(this), function(successPrevAddr) {
|
||||||
|
this.refreshServerInfoAtAddress(this.hostname + '.local').then(function(successLocal) {
|
||||||
|
onSuccess(this.hostname + '.local');
|
||||||
|
}.bind(this), function(failureLocal) {
|
||||||
|
this.refreshServerInfoAtAddress(this.externalIP).then(function(successExternal) {
|
||||||
|
onSuccess(this.externalIP);
|
||||||
|
}.bind(this), function(failureExternal) {
|
||||||
|
this.refreshServerInfoAtAddress(this.userEnteredAddress).then(function(successUserEntered) {
|
||||||
|
onSuccess(this.userEnteredAddress);
|
||||||
|
}.bind(this), function(failureUserEntered) {
|
||||||
|
console.warn('%c[utils.js, utils.js, selectServerAddress]', 'color: gray;', 'Failed to contact host ' + this.hostname, this);
|
||||||
|
onFailure();
|
||||||
|
}.bind(this));
|
||||||
|
}.bind(this));
|
||||||
|
}.bind(this));
|
||||||
|
}.bind(this));
|
||||||
|
},
|
||||||
|
|
||||||
|
toString: function() {
|
||||||
|
var string = '';
|
||||||
|
string += 'server address: ' + this.address + '\r\n';
|
||||||
|
string += 'server UID: ' + this.serverUid + '\r\n';
|
||||||
|
string += 'is paired: ' + this.paired + '\r\n';
|
||||||
|
string += 'current game: ' + this.currentGame + '\r\n';
|
||||||
|
string += 'server major version: ' + this.serverMajorVersion + '\r\n';
|
||||||
|
string += 'appversion: ' + this.appVersion + '\r\n';
|
||||||
|
string += 'GFE version: ' + this.GfeVersion + '\r\n';
|
||||||
|
string += 'gpu type: ' + this.gputype + '\r\n';
|
||||||
|
string += 'number of apps: ' + this.numofapps + '\r\n';
|
||||||
|
string += 'supported display modes: ' + '\r\n';
|
||||||
|
for (var displayMode in this.supportedDisplayModes) {
|
||||||
|
string += '\t' + displayMode + ': ' + this.supportedDisplayModes[displayMode] + '\r\n';
|
||||||
|
}
|
||||||
|
return string;
|
||||||
|
},
|
||||||
|
|
||||||
|
_parseServerInfo: function(xmlStr) {
|
||||||
|
$xml = this._parseXML(xmlStr);
|
||||||
|
$root = $xml.find('root');
|
||||||
|
|
||||||
|
if ($root.attr("status_code") != 200) {
|
||||||
|
return false;
|
||||||
|
}
|
||||||
|
|
||||||
|
if (this.serverUid != $root.find('uniqueid').text().trim() && this.serverUid != "") {
|
||||||
|
// if we received a UID that isn't the one we expected, fail.
|
||||||
|
return false;
|
||||||
|
}
|
||||||
|
|
||||||
|
console.log('%c[utils.js, _parseServerInfo]', 'color:gray;', 'Parsing server info:', $root);
|
||||||
|
|
||||||
|
this.paired = $root.find("PairStatus").text().trim() == 1;
|
||||||
|
this.currentGame = parseInt($root.find("currentgame").text().trim(), 10);
|
||||||
|
this.appVersion = $root.find("appversion").text().trim();
|
||||||
|
this.serverMajorVersion = parseInt(this.appVersion.substring(0, 1), 10);
|
||||||
|
this.serverUid = $root.find('uniqueid').text().trim();
|
||||||
|
this.hostname = $root.find('hostname').text().trim();
|
||||||
|
this.externalIP = $root.find('ExternalIP').text().trim();
|
||||||
|
try { // these aren't critical for functionality, and don't necessarily exist in older GFE versions.
|
||||||
|
this.GfeVersion = $root.find('GfeVersion').text().trim();
|
||||||
|
this.gputype = $root.find('gputype').text().trim();
|
||||||
|
this.numofapps = $root.find('numofapps').text().trim();
|
||||||
|
// now for the hard part: parsing the supported streaming
|
||||||
|
$root.find('DisplayMode').each(function(index, value) { // for each resolution:FPS object
|
||||||
|
var yres = parseInt($(value).find('Height').text());
|
||||||
|
var xres = parseInt($(value).find('Width').text());
|
||||||
|
var fps = parseInt($(value).find('RefreshRate').text());
|
||||||
|
if (!this.supportedDisplayModes[yres + ':' + xres]) {
|
||||||
|
this.supportedDisplayModes[yres + ':' + xres] = [];
|
||||||
|
}
|
||||||
|
if (!this.supportedDisplayModes[yres + ':' + xres].includes(fps)) {
|
||||||
|
this.supportedDisplayModes[yres + ':' + xres].push(fps);
|
||||||
|
}
|
||||||
|
}.bind(this));
|
||||||
|
} catch (err) {
|
||||||
|
// we don't need this data, so no error handling necessary
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
|
// GFE 2.8 started keeping currentgame set to the last game played. As a result, it no longer
|
||||||
|
// has the semantics that its name would indicate. To contain the effects of this change as much
|
||||||
|
// as possible, we'll force the current game to zero if the server isn't in a streaming session.
|
||||||
|
if (!$root.find("state").text().trim().endsWith("_SERVER_BUSY")) {
|
||||||
|
this.currentGame = 0;
|
||||||
|
}
|
||||||
|
|
||||||
|
return true;
|
||||||
|
},
|
||||||
|
|
||||||
|
getAppById: function(appId) {
|
||||||
|
return this.getAppList().then(function(list) {
|
||||||
|
var retApp = null;
|
||||||
|
|
||||||
|
list.some(function(app) {
|
||||||
|
if (app.id == appId) {
|
||||||
|
retApp = app;
|
||||||
|
return true;
|
||||||
|
}
|
||||||
|
|
||||||
|
return false;
|
||||||
|
});
|
||||||
|
|
||||||
|
return retApp;
|
||||||
|
});
|
||||||
|
},
|
||||||
|
|
||||||
|
getAppByName: function(appName) {
|
||||||
|
return this.getAppList().then(function(list) {
|
||||||
|
var retApp = null;
|
||||||
|
|
||||||
|
list.some(function(app) {
|
||||||
|
if (app.title == appName) {
|
||||||
|
retApp = app;
|
||||||
|
return true;
|
||||||
|
}
|
||||||
|
|
||||||
|
return false;
|
||||||
|
});
|
||||||
|
|
||||||
|
return retApp;
|
||||||
|
});
|
||||||
|
},
|
||||||
|
|
||||||
|
getAppListWithCacheFlush: function() {
|
||||||
|
return sendMessage('openUrl', [this._baseUrlHttps + '/applist?' + this._buildUidStr(), false]).then(function(ret) {
|
||||||
|
$xml = this._parseXML(ret);
|
||||||
|
$root = $xml.find("root");
|
||||||
|
|
||||||
|
if ($root.attr("status_code") != 200) {
|
||||||
|
// TODO: Bubble up an error here
|
||||||
|
console.error('%c[utils.js, utils.js, getAppListWithCacheFlush]', 'color: gray;', 'Applist request failed', $root.attr("status_code"));
|
||||||
|
return [];
|
||||||
|
}
|
||||||
|
|
||||||
|
var rootElement = $xml.find("root")[0];
|
||||||
|
var appElements = rootElement.getElementsByTagName("App");
|
||||||
|
var appList = [];
|
||||||
|
|
||||||
|
for (var i = 0, len = appElements.length; i < len; i++) {
|
||||||
|
appList.push({
|
||||||
|
title: appElements[i].getElementsByTagName("AppTitle")[0].innerHTML.trim(),
|
||||||
|
id: parseInt(appElements[i].getElementsByTagName("ID")[0].innerHTML.trim(), 10)
|
||||||
|
});
|
||||||
|
}
|
||||||
|
|
||||||
|
this._memCachedApplist = appList;
|
||||||
|
|
||||||
|
return appList;
|
||||||
|
}.bind(this));
|
||||||
|
},
|
||||||
|
|
||||||
|
getAppList: function() {
|
||||||
|
if (this._memCachedApplist) {
|
||||||
|
return new Promise(function(resolve, reject) {
|
||||||
|
console.log('%c[utils.js, utils.js]', 'color: gray;', 'Returning memory-cached apps list');
|
||||||
|
resolve(this._memCachedApplist);
|
||||||
|
return;
|
||||||
|
}.bind(this));
|
||||||
|
}
|
||||||
|
|
||||||
|
return this.getAppListWithCacheFlush();
|
||||||
|
},
|
||||||
|
|
||||||
|
// returns the box art of the given appID.
|
||||||
|
// three layers of response time are possible: memory cached (in javascript), storage cached (in chrome.storage.local), and streamed (host sends binary over the network)
|
||||||
|
getBoxArt: function(appId) {
|
||||||
|
if (chrome.storage) {
|
||||||
|
// This may be bad practice to push/pull this much data through local storage?
|
||||||
|
return new Promise(function(resolve, reject) {
|
||||||
|
chrome.storage.local.get('boxart-' + appId, function(storageData) {
|
||||||
|
// if we already have it, load it.
|
||||||
|
if (storageData !== undefined && Object.keys(storageData).length !== 0 && storageData['boxart-' + appId].constructor !== Object) {
|
||||||
|
console.log('%c[utils.js, getBoxArt]', 'color: gray;', 'Returning storage-cached box art for app: ', appId);
|
||||||
|
resolve(storageData['boxart-' + appId]);
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
|
|
||||||
this.selectServerAddress(function(successfulAddress) {
|
// otherwise, put it in our cache, then return it
|
||||||
// Successfully determined server address. Update base URL.
|
sendMessage('openUrl', [
|
||||||
this.address = successfulAddress;
|
|
||||||
this._baseUrlHttps = 'https://' + successfulAddress + ':47984';
|
|
||||||
this._baseUrlHttp = 'http://' + successfulAddress + ':47989';
|
|
||||||
|
|
||||||
// Poll for the app list every 10 successful serverinfo polls.
|
|
||||||
// Not including the first one to avoid PCs taking a while to show
|
|
||||||
// as online initially
|
|
||||||
if (this._pollCount++ % 10 == 1) {
|
|
||||||
this.getAppListWithCacheFlush();
|
|
||||||
}
|
|
||||||
|
|
||||||
this._consecutivePollFailures = 0;
|
|
||||||
this.online = true;
|
|
||||||
|
|
||||||
// Call all pending completion callbacks
|
|
||||||
var completion;
|
|
||||||
while ((completion = this._pollCompletionCallbacks.pop())) {
|
|
||||||
completion(this);
|
|
||||||
}
|
|
||||||
}.bind(this), function() {
|
|
||||||
if (++this._consecutivePollFailures >= 2) {
|
|
||||||
this.online = false;
|
|
||||||
}
|
|
||||||
|
|
||||||
// Call all pending completion callbacks
|
|
||||||
var completion;
|
|
||||||
while ((completion = this._pollCompletionCallbacks.pop())) {
|
|
||||||
completion(this);
|
|
||||||
}
|
|
||||||
}.bind(this));
|
|
||||||
},
|
|
||||||
|
|
||||||
// initially pings the server to try and figure out if it's routable by any means.
|
|
||||||
selectServerAddress: function(onSuccess, onFailure) {
|
|
||||||
// TODO: Deduplicate the addresses
|
|
||||||
this.refreshServerInfoAtAddress(this.address).then(function(successPrevAddr) {
|
|
||||||
onSuccess(this.address);
|
|
||||||
}.bind(this), function(successPrevAddr) {
|
|
||||||
this.refreshServerInfoAtAddress(this.hostname + '.local').then(function(successLocal) {
|
|
||||||
onSuccess(this.hostname + '.local');
|
|
||||||
}.bind(this), function(failureLocal) {
|
|
||||||
this.refreshServerInfoAtAddress(this.externalIP).then(function(successExternal) {
|
|
||||||
onSuccess(this.externalIP);
|
|
||||||
}.bind(this), function(failureExternal) {
|
|
||||||
this.refreshServerInfoAtAddress(this.userEnteredAddress).then(function(successUserEntered) {
|
|
||||||
onSuccess(this.userEnteredAddress);
|
|
||||||
}.bind(this), function(failureUserEntered) {
|
|
||||||
console.warn('%c[utils.js, utils.js, selectServerAddress]', 'color: gray;', 'Failed to contact host ' + this.hostname, this);
|
|
||||||
onFailure();
|
|
||||||
}.bind(this));
|
|
||||||
}.bind(this));
|
|
||||||
}.bind(this));
|
|
||||||
}.bind(this));
|
|
||||||
},
|
|
||||||
|
|
||||||
toString: function() {
|
|
||||||
var string = '';
|
|
||||||
string += 'server address: ' + this.address + '\r\n';
|
|
||||||
string += 'server UID: ' + this.serverUid + '\r\n';
|
|
||||||
string += 'is paired: ' + this.paired + '\r\n';
|
|
||||||
string += 'current game: ' + this.currentGame + '\r\n';
|
|
||||||
string += 'server major version: ' + this.serverMajorVersion + '\r\n';
|
|
||||||
string += 'appversion: ' + this.appVersion + '\r\n';
|
|
||||||
string += 'GFE version: ' + this.GfeVersion + '\r\n';
|
|
||||||
string += 'gpu type: ' + this.gputype + '\r\n';
|
|
||||||
string += 'number of apps: ' + this.numofapps + '\r\n';
|
|
||||||
string += 'supported display modes: ' + '\r\n';
|
|
||||||
for(var displayMode in this.supportedDisplayModes) {
|
|
||||||
string += '\t' + displayMode + ': ' + this.supportedDisplayModes[displayMode] + '\r\n';
|
|
||||||
}
|
|
||||||
return string;
|
|
||||||
},
|
|
||||||
|
|
||||||
_parseServerInfo: function(xmlStr) {
|
|
||||||
$xml = this._parseXML(xmlStr);
|
|
||||||
$root = $xml.find('root');
|
|
||||||
|
|
||||||
if($root.attr("status_code") != 200) {
|
|
||||||
return false;
|
|
||||||
}
|
|
||||||
|
|
||||||
if(this.serverUid != $root.find('uniqueid').text().trim() && this.serverUid != "") {
|
|
||||||
// if we received a UID that isn't the one we expected, fail.
|
|
||||||
return false;
|
|
||||||
}
|
|
||||||
|
|
||||||
console.log('%c[utils.js, _parseServerInfo]', 'color:gray;', 'Parsing server info:', $root);
|
|
||||||
|
|
||||||
this.paired = $root.find("PairStatus").text().trim() == 1;
|
|
||||||
this.currentGame = parseInt($root.find("currentgame").text().trim(), 10);
|
|
||||||
this.appVersion = $root.find("appversion").text().trim();
|
|
||||||
this.serverMajorVersion = parseInt(this.appVersion.substring(0, 1), 10);
|
|
||||||
this.serverUid = $root.find('uniqueid').text().trim();
|
|
||||||
this.hostname = $root.find('hostname').text().trim();
|
|
||||||
this.externalIP = $root.find('ExternalIP').text().trim();
|
|
||||||
try { // these aren't critical for functionality, and don't necessarily exist in older GFE versions.
|
|
||||||
this.GfeVersion = $root.find('GfeVersion').text().trim();
|
|
||||||
this.gputype = $root.find('gputype').text().trim();
|
|
||||||
this.numofapps = $root.find('numofapps').text().trim();
|
|
||||||
// now for the hard part: parsing the supported streaming
|
|
||||||
$root.find('DisplayMode').each(function(index, value) { // for each resolution:FPS object
|
|
||||||
var yres = parseInt($(value).find('Height').text());
|
|
||||||
var xres = parseInt($(value).find('Width').text());
|
|
||||||
var fps = parseInt($(value).find('RefreshRate').text());
|
|
||||||
if(!this.supportedDisplayModes[yres + ':' + xres]) {
|
|
||||||
this.supportedDisplayModes[yres + ':' + xres] = [];
|
|
||||||
}
|
|
||||||
if(!this.supportedDisplayModes[yres + ':' + xres].includes(fps)) {
|
|
||||||
this.supportedDisplayModes[yres + ':' + xres].push(fps);
|
|
||||||
}
|
|
||||||
}.bind(this));
|
|
||||||
} catch (err) {
|
|
||||||
// we don't need this data, so no error handling necessary
|
|
||||||
}
|
|
||||||
|
|
||||||
|
|
||||||
// GFE 2.8 started keeping currentgame set to the last game played. As a result, it no longer
|
|
||||||
// has the semantics that its name would indicate. To contain the effects of this change as much
|
|
||||||
// as possible, we'll force the current game to zero if the server isn't in a streaming session.
|
|
||||||
if (!$root.find("state").text().trim().endsWith("_SERVER_BUSY")) {
|
|
||||||
this.currentGame = 0;
|
|
||||||
}
|
|
||||||
|
|
||||||
return true;
|
|
||||||
},
|
|
||||||
|
|
||||||
getAppById: function (appId) {
|
|
||||||
return this.getAppList().then(function (list) {
|
|
||||||
var retApp = null;
|
|
||||||
|
|
||||||
list.some(function (app) {
|
|
||||||
if (app.id == appId) {
|
|
||||||
retApp = app;
|
|
||||||
return true;
|
|
||||||
}
|
|
||||||
|
|
||||||
return false;
|
|
||||||
});
|
|
||||||
|
|
||||||
return retApp;
|
|
||||||
});
|
|
||||||
},
|
|
||||||
|
|
||||||
getAppByName: function (appName) {
|
|
||||||
return this.getAppList().then(function (list) {
|
|
||||||
var retApp = null;
|
|
||||||
|
|
||||||
list.some(function (app) {
|
|
||||||
if (app.title == appName) {
|
|
||||||
retApp = app;
|
|
||||||
return true;
|
|
||||||
}
|
|
||||||
|
|
||||||
return false;
|
|
||||||
});
|
|
||||||
|
|
||||||
return retApp;
|
|
||||||
});
|
|
||||||
},
|
|
||||||
|
|
||||||
getAppListWithCacheFlush: function () {
|
|
||||||
return sendMessage('openUrl', [this._baseUrlHttps + '/applist?' + this._buildUidStr(), false]).then(function (ret) {
|
|
||||||
$xml = this._parseXML(ret);
|
|
||||||
$root = $xml.find("root");
|
|
||||||
|
|
||||||
if ($root.attr("status_code") != 200) {
|
|
||||||
// TODO: Bubble up an error here
|
|
||||||
console.error('%c[utils.js, utils.js, getAppListWithCacheFlush]', 'color: gray;', 'Applist request failed', $root.attr("status_code"));
|
|
||||||
return [];
|
|
||||||
}
|
|
||||||
|
|
||||||
var rootElement = $xml.find("root")[0];
|
|
||||||
var appElements = rootElement.getElementsByTagName("App");
|
|
||||||
var appList = [];
|
|
||||||
|
|
||||||
for (var i = 0, len = appElements.length; i < len; i++) {
|
|
||||||
appList.push({
|
|
||||||
title: appElements[i].getElementsByTagName("AppTitle")[0].innerHTML.trim(),
|
|
||||||
id: parseInt(appElements[i].getElementsByTagName("ID")[0].innerHTML.trim(), 10)
|
|
||||||
});
|
|
||||||
}
|
|
||||||
|
|
||||||
this._memCachedApplist = appList;
|
|
||||||
|
|
||||||
return appList;
|
|
||||||
}.bind(this));
|
|
||||||
},
|
|
||||||
|
|
||||||
getAppList: function () {
|
|
||||||
if (this._memCachedApplist) {
|
|
||||||
return new Promise(function (resolve, reject) {
|
|
||||||
console.log('%c[utils.js, utils.js]', 'color: gray;', 'Returning memory-cached apps list');
|
|
||||||
resolve(this._memCachedApplist);
|
|
||||||
return;
|
|
||||||
}.bind(this));
|
|
||||||
}
|
|
||||||
|
|
||||||
return this.getAppListWithCacheFlush();
|
|
||||||
},
|
|
||||||
|
|
||||||
// returns the box art of the given appID.
|
|
||||||
// three layers of response time are possible: memory cached (in javascript), storage cached (in chrome.storage.local), and streamed (host sends binary over the network)
|
|
||||||
getBoxArt: function (appId) {
|
|
||||||
if (chrome.storage) {
|
|
||||||
// This may be bad practice to push/pull this much data through local storage?
|
|
||||||
return new Promise(function (resolve, reject) {
|
|
||||||
chrome.storage.local.get('boxart-'+appId, function(storageData) {
|
|
||||||
// if we already have it, load it.
|
|
||||||
if (storageData !== undefined && Object.keys(storageData).length !== 0 && storageData['boxart-'+appId].constructor !== Object) {
|
|
||||||
console.log('%c[utils.js, getBoxArt]', 'color: gray;', 'Returning storage-cached box art for app: ', appId);
|
|
||||||
resolve(storageData['boxart-'+appId]);
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
|
|
||||||
// otherwise, put it in our cache, then return it
|
|
||||||
sendMessage('openUrl', [
|
|
||||||
this._baseUrlHttps +
|
|
||||||
'/appasset?'+this._buildUidStr() +
|
|
||||||
'&appid=' + appId +
|
|
||||||
'&AssetType=2&AssetIdx=0',
|
|
||||||
true
|
|
||||||
]).then(function(boxArtBuffer) {
|
|
||||||
var reader = new FileReader();
|
|
||||||
reader.onloadend = function() {
|
|
||||||
var obj = {};
|
|
||||||
obj['boxart-'+appId] = this.result;
|
|
||||||
chrome.storage.local.set(obj, function(onSuccess) {});
|
|
||||||
console.log('%c[utils.js, utils.js, getBoxArt]', 'color: gray;', 'Returning network-fetched box art');
|
|
||||||
resolve(this.result);
|
|
||||||
}
|
|
||||||
reader.readAsDataURL(new Blob([boxArtBuffer], {type: "image/png"}));
|
|
||||||
}.bind(this), function(error) {
|
|
||||||
console.error('%c[utils.js, utils.js, getBoxArt]', 'color: gray;', 'Box-art request failed!', error);
|
|
||||||
reject(error);
|
|
||||||
return;
|
|
||||||
}.bind(this));
|
|
||||||
}.bind(this));
|
|
||||||
}.bind(this));
|
|
||||||
|
|
||||||
} else { // shouldn't run because we always have chrome.storage, but I'm not going to antagonize other browsers
|
|
||||||
console.warn('%c[utils.js, utils.js, getBoxArt]', 'color: gray;', 'chrome.storage not detected! Box art will not be saved!');
|
|
||||||
return sendMessage('openUrl', [
|
|
||||||
this._baseUrlHttps +
|
|
||||||
'/appasset?'+this._buildUidStr() +
|
|
||||||
'&appid=' + appId +
|
|
||||||
'&AssetType=2&AssetIdx=0',
|
|
||||||
true
|
|
||||||
]);
|
|
||||||
}
|
|
||||||
},
|
|
||||||
|
|
||||||
launchApp: function (appId, mode, sops, rikey, rikeyid, localAudio, surroundAudioInfo, gamepadMask) {
|
|
||||||
return sendMessage('openUrl', [
|
|
||||||
this._baseUrlHttps +
|
this._baseUrlHttps +
|
||||||
'/launch?' + this._buildUidStr() +
|
'/appasset?' + this._buildUidStr() +
|
||||||
'&appid=' + appId +
|
'&appid=' + appId +
|
||||||
'&mode=' + mode +
|
'&AssetType=2&AssetIdx=0',
|
||||||
'&additionalStates=1&sops=' + sops +
|
true
|
||||||
'&rikey=' + rikey +
|
]).then(function(boxArtBuffer) {
|
||||||
'&rikeyid=' + rikeyid +
|
var reader = new FileReader();
|
||||||
'&localAudioPlayMode=' + localAudio +
|
reader.onloadend = function() {
|
||||||
'&surroundAudioInfo=' + surroundAudioInfo +
|
var obj = {};
|
||||||
'&remoteControllersBitmap=' + gamepadMask +
|
obj['boxart-' + appId] = this.result;
|
||||||
'&gcmap=' + gamepadMask,
|
chrome.storage.local.set(obj, function(onSuccess) {});
|
||||||
false
|
console.log('%c[utils.js, utils.js, getBoxArt]', 'color: gray;', 'Returning network-fetched box art');
|
||||||
]).then(function (ret) {
|
resolve(this.result);
|
||||||
return true;
|
}
|
||||||
});
|
reader.readAsDataURL(new Blob([boxArtBuffer], {
|
||||||
},
|
type: "image/png"
|
||||||
|
}));
|
||||||
resumeApp: function (rikey, rikeyid, surroundAudioInfo) {
|
}.bind(this), function(error) {
|
||||||
return sendMessage('openUrl', [
|
console.error('%c[utils.js, utils.js, getBoxArt]', 'color: gray;', 'Box-art request failed!', error);
|
||||||
this._baseUrlHttps +
|
reject(error);
|
||||||
'/resume?' + this._buildUidStr() +
|
return;
|
||||||
'&rikey=' + rikey +
|
}.bind(this));
|
||||||
'&rikeyid=' + rikeyid +
|
|
||||||
'&surroundAudioInfo=' + surroundAudioInfo,
|
|
||||||
false
|
|
||||||
]).then(function (ret) {
|
|
||||||
return true;
|
|
||||||
});
|
|
||||||
},
|
|
||||||
|
|
||||||
quitApp: function () {
|
|
||||||
return sendMessage('openUrl', [this._baseUrlHttps + '/cancel?' + this._buildUidStr(), false])
|
|
||||||
// Refresh server info after quitting because it may silently fail if the
|
|
||||||
// session belongs to a different client.
|
|
||||||
// TODO: We should probably bubble this up to our caller.
|
|
||||||
.then(this.refreshServerInfo());
|
|
||||||
},
|
|
||||||
|
|
||||||
pair: function(randomNumber) {
|
|
||||||
return this.refreshServerInfo().then(function () {
|
|
||||||
if (this.paired)
|
|
||||||
return true;
|
|
||||||
|
|
||||||
if (this.currentGame != 0)
|
|
||||||
return false;
|
|
||||||
|
|
||||||
return sendMessage('pair', [this.serverMajorVersion.toString(), this.address, randomNumber]).then(function (pairStatus) {
|
|
||||||
return sendMessage('openUrl', [this._baseUrlHttps + '/pair?uniqueid=' + this.clientUid + '&devicename=roth&updateState=1&phrase=pairchallenge', false]).then(function (ret) {
|
|
||||||
$xml = this._parseXML(ret);
|
|
||||||
this.paired = $xml.find('paired').html() == "1";
|
|
||||||
return this.paired;
|
|
||||||
}.bind(this));
|
|
||||||
}.bind(this));
|
|
||||||
}.bind(this));
|
}.bind(this));
|
||||||
},
|
}.bind(this));
|
||||||
|
|
||||||
_buildUidStr: function () {
|
} else { // shouldn't run because we always have chrome.storage, but I'm not going to antagonize other browsers
|
||||||
return 'uniqueid=' + this.clientUid + '&uuid=' + guuid();
|
console.warn('%c[utils.js, utils.js, getBoxArt]', 'color: gray;', 'chrome.storage not detected! Box art will not be saved!');
|
||||||
},
|
return sendMessage('openUrl', [
|
||||||
|
this._baseUrlHttps +
|
||||||
|
'/appasset?' + this._buildUidStr() +
|
||||||
|
'&appid=' + appId +
|
||||||
|
'&AssetType=2&AssetIdx=0',
|
||||||
|
true
|
||||||
|
]);
|
||||||
|
}
|
||||||
|
},
|
||||||
|
|
||||||
_parseXML: function (xmlData) {
|
launchApp: function(appId, mode, sops, rikey, rikeyid, localAudio, surroundAudioInfo, gamepadMask) {
|
||||||
return $($.parseXML(xmlData.toString()));
|
return sendMessage('openUrl', [
|
||||||
},
|
this._baseUrlHttps +
|
||||||
|
'/launch?' + this._buildUidStr() +
|
||||||
|
'&appid=' + appId +
|
||||||
|
'&mode=' + mode +
|
||||||
|
'&additionalStates=1&sops=' + sops +
|
||||||
|
'&rikey=' + rikey +
|
||||||
|
'&rikeyid=' + rikeyid +
|
||||||
|
'&localAudioPlayMode=' + localAudio +
|
||||||
|
'&surroundAudioInfo=' + surroundAudioInfo +
|
||||||
|
'&remoteControllersBitmap=' + gamepadMask +
|
||||||
|
'&gcmap=' + gamepadMask,
|
||||||
|
false
|
||||||
|
]).then(function(ret) {
|
||||||
|
return true;
|
||||||
|
});
|
||||||
|
},
|
||||||
|
|
||||||
|
resumeApp: function(rikey, rikeyid, surroundAudioInfo) {
|
||||||
|
return sendMessage('openUrl', [
|
||||||
|
this._baseUrlHttps +
|
||||||
|
'/resume?' + this._buildUidStr() +
|
||||||
|
'&rikey=' + rikey +
|
||||||
|
'&rikeyid=' + rikeyid +
|
||||||
|
'&surroundAudioInfo=' + surroundAudioInfo,
|
||||||
|
false
|
||||||
|
]).then(function(ret) {
|
||||||
|
return true;
|
||||||
|
});
|
||||||
|
},
|
||||||
|
|
||||||
|
quitApp: function() {
|
||||||
|
return sendMessage('openUrl', [this._baseUrlHttps + '/cancel?' + this._buildUidStr(), false])
|
||||||
|
// Refresh server info after quitting because it may silently fail if the
|
||||||
|
// session belongs to a different client.
|
||||||
|
// TODO: We should probably bubble this up to our caller.
|
||||||
|
.then(this.refreshServerInfo());
|
||||||
|
},
|
||||||
|
|
||||||
|
pair: function(randomNumber) {
|
||||||
|
return this.refreshServerInfo().then(function() {
|
||||||
|
if (this.paired)
|
||||||
|
return true;
|
||||||
|
|
||||||
|
if (this.currentGame != 0)
|
||||||
|
return false;
|
||||||
|
|
||||||
|
return sendMessage('pair', [this.serverMajorVersion.toString(), this.address, randomNumber]).then(function(pairStatus) {
|
||||||
|
return sendMessage('openUrl', [this._baseUrlHttps + '/pair?uniqueid=' + this.clientUid + '&devicename=roth&updateState=1&phrase=pairchallenge', false]).then(function(ret) {
|
||||||
|
$xml = this._parseXML(ret);
|
||||||
|
this.paired = $xml.find('paired').html() == "1";
|
||||||
|
return this.paired;
|
||||||
|
}.bind(this));
|
||||||
|
}.bind(this));
|
||||||
|
}.bind(this));
|
||||||
|
},
|
||||||
|
|
||||||
|
_buildUidStr: function() {
|
||||||
|
return 'uniqueid=' + this.clientUid + '&uuid=' + guuid();
|
||||||
|
},
|
||||||
|
|
||||||
|
_parseXML: function(xmlData) {
|
||||||
|
return $($.parseXML(xmlData.toString()));
|
||||||
|
},
|
||||||
};
|
};
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user