diff options
Diffstat (limited to 'toolkit/modules/secondscreen/RokuApp.jsm')
-rw-r--r-- | toolkit/modules/secondscreen/RokuApp.jsm | 230 |
1 files changed, 0 insertions, 230 deletions
diff --git a/toolkit/modules/secondscreen/RokuApp.jsm b/toolkit/modules/secondscreen/RokuApp.jsm deleted file mode 100644 index b37a688cd..000000000 --- a/toolkit/modules/secondscreen/RokuApp.jsm +++ /dev/null @@ -1,230 +0,0 @@ -// -*- indent-tabs-mode: nil; js-indent-level: 2 -*- -/* This Source Code Form is subject to the terms of the Mozilla Public - * License, v. 2.0. If a copy of the MPL was not distributed with this file, - * You can obtain one at http://mozilla.org/MPL/2.0/. */ - -"use strict"; - -this.EXPORTED_SYMBOLS = ["RokuApp"]; - -const { classes: Cc, interfaces: Ci, utils: Cu } = Components; - -Cu.import("resource://gre/modules/Services.jsm"); -Cu.import("resource://gre/modules/AppConstants.jsm"); - -function log(msg) { - // Services.console.logStringMessage(msg); -} - -const PROTOCOL_VERSION = 1; - -/* RokuApp is a wrapper for interacting with a Roku channel. - * The basic interactions all use a REST API. - * spec: http://sdkdocs.roku.com/display/sdkdoc/External+Control+Guide - */ -function RokuApp(service) { - this.service = service; - this.resourceURL = this.service.location; - this.app = AppConstants.RELEASE_OR_BETA ? "Firefox" : "Firefox Nightly"; - this.mediaAppID = -1; -} - -RokuApp.prototype = { - status: function status(callback) { - // We have no way to know if the app is running, so just return "unknown" - // but we use this call to fetch the mediaAppID for the given app name - let url = this.resourceURL + "query/apps"; - let xhr = Cc["@mozilla.org/xmlextras/xmlhttprequest;1"].createInstance(Ci.nsIXMLHttpRequest); - xhr.open("GET", url, true); - xhr.channel.loadFlags |= Ci.nsIRequest.INHIBIT_CACHING; - xhr.overrideMimeType("text/xml"); - - xhr.addEventListener("load", (function() { - if (xhr.status == 200) { - let doc = xhr.responseXML; - let apps = doc.querySelectorAll("app"); - for (let app of apps) { - if (app.textContent == this.app) { - this.mediaAppID = app.id; - } - } - } - - // Since ECP has no way of telling us if an app is running, we always return "unknown" - if (callback) { - callback({ state: "unknown" }); - } - }).bind(this), false); - - xhr.addEventListener("error", (function() { - if (callback) { - callback({ state: "unknown" }); - } - }).bind(this), false); - - xhr.send(null); - }, - - start: function start(callback) { - // We need to make sure we have cached the mediaAppID - if (this.mediaAppID == -1) { - this.status(function() { - // If we found the mediaAppID, use it to make a new start call - if (this.mediaAppID != -1) { - this.start(callback); - } else { - // We failed to start the app, so let the caller know - callback(false); - } - }.bind(this)); - return; - } - - // Start a given app with any extra query data. Each app uses it's own data scheme. - // NOTE: Roku will also pass "source=external-control" as a param - let url = this.resourceURL + "launch/" + this.mediaAppID + "?version=" + parseInt(PROTOCOL_VERSION); - let xhr = Cc["@mozilla.org/xmlextras/xmlhttprequest;1"].createInstance(Ci.nsIXMLHttpRequest); - xhr.open("POST", url, true); - xhr.overrideMimeType("text/plain"); - - xhr.addEventListener("load", (function() { - if (callback) { - callback(xhr.status === 200); - } - }).bind(this), false); - - xhr.addEventListener("error", (function() { - if (callback) { - callback(false); - } - }).bind(this), false); - - xhr.send(null); - }, - - stop: function stop(callback) { - // Roku doesn't seem to support stopping an app, so let's just go back to - // the Home screen - let url = this.resourceURL + "keypress/Home"; - let xhr = Cc["@mozilla.org/xmlextras/xmlhttprequest;1"].createInstance(Ci.nsIXMLHttpRequest); - xhr.open("POST", url, true); - xhr.overrideMimeType("text/plain"); - - xhr.addEventListener("load", (function() { - if (callback) { - callback(xhr.status === 200); - } - }).bind(this), false); - - xhr.addEventListener("error", (function() { - if (callback) { - callback(false); - } - }).bind(this), false); - - xhr.send(null); - }, - - remoteMedia: function remoteMedia(callback, listener) { - if (this.mediaAppID != -1) { - if (callback) { - callback(new RemoteMedia(this.resourceURL, listener)); - } - } else if (callback) { - callback(); - } - } -} - -/* RemoteMedia provides a wrapper for using TCP socket to control Roku apps. - * The server implementation must be built into the Roku receiver app. - */ -function RemoteMedia(url, listener) { - this._url = url; - this._listener = listener; - this._status = "uninitialized"; - - let serverURI = Services.io.newURI(this._url, null, null); - this._socket = Cc["@mozilla.org/network/socket-transport-service;1"].getService(Ci.nsISocketTransportService).createTransport(null, 0, serverURI.host, 9191, null); - this._outputStream = this._socket.openOutputStream(0, 0, 0); - - this._scriptableStream = Cc["@mozilla.org/scriptableinputstream;1"].createInstance(Ci.nsIScriptableInputStream); - - this._inputStream = this._socket.openInputStream(0, 0, 0); - this._pump = Cc["@mozilla.org/network/input-stream-pump;1"].createInstance(Ci.nsIInputStreamPump); - this._pump.init(this._inputStream, -1, -1, 0, 0, true); - this._pump.asyncRead(this, null); -} - -RemoteMedia.prototype = { - onStartRequest: function(request, context) { - }, - - onDataAvailable: function(request, context, stream, offset, count) { - this._scriptableStream.init(stream); - let data = this._scriptableStream.read(count); - if (!data) { - return; - } - - let msg = JSON.parse(data); - if (this._status === msg._s) { - return; - } - - this._status = msg._s; - - if (this._listener) { - // Check to see if we are getting the initial "connected" message - if (this._status == "connected" && "onRemoteMediaStart" in this._listener) { - this._listener.onRemoteMediaStart(this); - } - - if ("onRemoteMediaStatus" in this._listener) { - this._listener.onRemoteMediaStatus(this); - } - } - }, - - onStopRequest: function(request, context, result) { - if (this._listener && "onRemoteMediaStop" in this._listener) - this._listener.onRemoteMediaStop(this); - }, - - _sendMsg: function _sendMsg(data) { - if (!data) - return; - - // Add the protocol version - data["_v"] = PROTOCOL_VERSION; - - let raw = JSON.stringify(data); - this._outputStream.write(raw, raw.length); - }, - - shutdown: function shutdown() { - this._outputStream.close(); - this._inputStream.close(); - }, - - get active() { - return (this._socket && this._socket.isAlive()); - }, - - play: function play() { - // TODO: add position support - this._sendMsg({ type: "PLAY" }); - }, - - pause: function pause() { - this._sendMsg({ type: "STOP" }); - }, - - load: function load(data) { - this._sendMsg({ type: "LOAD", title: data.title, source: data.source, poster: data.poster }); - }, - - get status() { - return this._status; - } -} |