The Tor Browser: toolkit/devtools/apps/app-actor-front.js@b8a032363ba2 (annotated)

toolkit/devtools/apps/app-actor-front.js@b8a032363ba2 (annotated)

toolkit/devtools/apps/app-actor-front.js

Thu, 22 Jan 2015 13:21:57 +0100

author: Michael Schloh von Bennewitz <michael@schloh.com>
date: Thu, 22 Jan 2015 13:21:57 +0100
branch: TOR_BUG_9701
changeset 15: b8a032363ba2
permissions: -rw-r--r--

Incorporate requested changes from Mozilla in review:
https://bugzilla.mozilla.org/show_bug.cgi?id=1123480#c6

 const {Ci, Cc, Cu, Cr} = require("chrome");
 Cu.import("resource://gre/modules/osfile.jsm");
 const {Services} = Cu.import("resource://gre/modules/Services.jsm");
 const {FileUtils} = Cu.import("resource://gre/modules/FileUtils.jsm");
 const {devtools} = Cu.import("resource://gre/modules/devtools/Loader.jsm", {});
 const {Promise: promise} = Cu.import("resource://gre/modules/Promise.jsm", {});
 // XXX: bug 912476 make this module a real protocol.js front
 // by converting webapps actor to protocol.js
 const PR_USEC_PER_MSEC = 1000;
 const PR_RDWR = 0x04;
 const PR_CREATE_FILE = 0x08;
 const PR_TRUNCATE = 0x20;
 const CHUNK_SIZE = 10000;
 const appTargets = new Map();
 function addDirToZip(writer, dir, basePath) {
   let files = dir.directoryEntries;
   while (files.hasMoreElements()) {
     let file = files.getNext().QueryInterface(Ci.nsIFile);
     if (file.isHidden() ||
         file.isSpecial() ||
         file.equals(writer.file))
     {
       continue;
     }
     if (file.isDirectory()) {
       writer.addEntryDirectory(basePath + file.leafName + "/",
                                file.lastModifiedTime * PR_USEC_PER_MSEC,
                                true);
       addDirToZip(writer, file, basePath + file.leafName + "/");
     } else {
       writer.addEntryFile(basePath + file.leafName,
                           Ci.nsIZipWriter.COMPRESSION_DEFAULT,
                           file,
                           true);
     }
   }
 }
 /**
  * Convert an XPConnect result code to its name and message.
  * We have to extract them from an exception per bug 637307 comment 5.
  */
 function getResultTest(code) {
   let regexp =
     /^\[Exception... "(.*)"  nsresult: "0x[0-9a-fA-F]* \((.*)\)"  location: ".*"  data: .*\]$/;
   let ex = Cc["@mozilla.org/js/xpc/Exception;1"].
            createInstance(Ci.nsIXPCException);
   ex.initialize(null, code, null, null, null, null);
   let [, message, name] = regexp.exec(ex.toString());
   return { name: name, message: message };
 }
 function zipDirectory(zipFile, dirToArchive) {
   let deferred = promise.defer();
   let writer = Cc["@mozilla.org/zipwriter;1"].createInstance(Ci.nsIZipWriter);
   writer.open(zipFile, PR_RDWR | PR_CREATE_FILE | PR_TRUNCATE);
   this.addDirToZip(writer, dirToArchive, "");
   writer.processQueue({
     onStartRequest: function onStartRequest(request, context) {},
     onStopRequest: (request, context, status) => {
       if (status == Cr.NS_OK) {
         writer.close();
         deferred.resolve(zipFile);
       }
       else {
         let { name, message } = getResultText(status);
         deferred.reject(name + ": " + message);
       }
     }
   }, null);
   return deferred.promise;
 }
 function uploadPackage(client, webappsActor, packageFile) {
   let deferred = promise.defer();
   let request = {
     to: webappsActor,
     type: "uploadPackage"
   };
   client.request(request, (res) => {
     openFile(res.actor);
   });
   function openFile(actor) {
     OS.File.open(packageFile.path)
       .then(function (file) {
         uploadChunk(actor, file);
       });
   }
   function uploadChunk(actor, file) {
     file.read(CHUNK_SIZE)
         .then(function (bytes) {
           // To work around the fact that JSON.stringify translates the typed
           // array to object, we are encoding the typed array here into a string
           let chunk = String.fromCharCode.apply(null, bytes);
           let request = {
             to: actor,
             type: "chunk",
             chunk: chunk
           };
           client.request(request, (res) => {
             if (bytes.length == CHUNK_SIZE) {
               uploadChunk(actor, file);
             } else {
               file.close().then(function () {
                 endsUpload(actor);
               });
             }
           });
         });
   }
   function endsUpload(actor) {
     let request = {
       to: actor,
       type: "done"
     };
     client.request(request, (res) => {
       deferred.resolve(actor);
     });
   }
   return deferred.promise;
 }
 function removeServerTemporaryFile(client, fileActor) {
   let request = {
     to: fileActor,
     type: "remove"
   };
   client.request(request);
 }
 function installPackaged(client, webappsActor, packagePath, appId) {
   let deferred = promise.defer();
   let file = FileUtils.File(packagePath);
   let packagePromise;
   if (file.isDirectory()) {
     let tmpZipFile = FileUtils.getDir("TmpD", [], true);
     tmpZipFile.append("application.zip");
     tmpZipFile.createUnique(Ci.nsIFile.NORMAL_FILE_TYPE, parseInt("666", 8));
     packagePromise = zipDirectory(tmpZipFile, file)
   } else {
     packagePromise = promise.resolve(file);
   }
   packagePromise.then((zipFile) => {
     uploadPackage(client, webappsActor, zipFile)
         .then((fileActor) => {
           let request = {
             to: webappsActor,
             type: "install",
             appId: appId,
             upload: fileActor
           };
           client.request(request, (res) => {
             // If the install method immediatly fails,
             // reject immediatly the installPackaged promise.
             // Otherwise, wait for webappsEvent for completion
             if (res.error) {
               deferred.reject(res);
             }
             if ("error" in res)
               deferred.reject({error: res.error, message: res.message});
             else
               deferred.resolve({appId: res.appId});
           });
           // Ensure deleting the temporary package file, but only if that a temporary
           // package created when we pass a directory as `packagePath`
           if (zipFile != file)
             zipFile.remove(false);
           // In case of success or error, ensure deleting the temporary package file
           // also created on the device, but only once install request is done
           deferred.promise.then(
             () => removeServerTemporaryFile(client, fileActor),
             () => removeServerTemporaryFile(client, fileActor));
         });
   });
   return deferred.promise;
 }
 exports.installPackaged = installPackaged;
 function installHosted(client, webappsActor, appId, metadata, manifest) {
   let deferred = promise.defer();
   let request = {
     to: webappsActor,
     type: "install",
     appId: appId,
     metadata: metadata,
     manifest: manifest
   };
   client.request(request, (res) => {
     if (res.error) {
       deferred.reject(res);
     }
     if ("error" in res)
       deferred.reject({error: res.error, message: res.message});
     else
       deferred.resolve({appId: res.appId});
   });
   return deferred.promise;
 }
 exports.installHosted = installHosted;
 function getTargetForApp(client, webappsActor, manifestURL) {
   // Ensure always returning the exact same JS object for a target
   // of the same app in order to show only one toolbox per app and
   // avoid re-creating lot of objects twice.
   let existingTarget = appTargets.get(manifestURL);
   if (existingTarget)
     return promise.resolve(existingTarget);
   let deferred = promise.defer();
   let request = {
     to: webappsActor,
     type: "getAppActor",
     manifestURL: manifestURL,
   }
   client.request(request, (res) => {
     if (res.error) {
       deferred.reject(res.error);
     } else {
       let options = {
         form: res.actor,
         client: client,
         chrome: false
       };
       devtools.TargetFactory.forRemoteTab(options).then((target) => {
         target.isApp = true;
         appTargets.set(manifestURL, target);
         target.on("close", () => {
           appTargets.delete(manifestURL);
         });
         deferred.resolve(target)
       }, (error) => {
         deferred.reject(error);
       });
     }
   });
   return deferred.promise;
 }
 exports.getTargetForApp = getTargetForApp;
 function reloadApp(client, webappsActor, manifestURL) {
   let deferred = promise.defer();
   getTargetForApp(client,
                   webappsActor,
                   manifestURL).
     then((target) => {
       // Request the ContentActor to reload the app
       let request = {
         to: target.form.actor,
         type: "reload",
         manifestURL: manifestURL
       };
       client.request(request, (res) => {
         deferred.resolve();
       });
     }, () => {
      deferred.reject("Not running");
     });
   return deferred.promise;
 }
 exports.reloadApp = reloadApp;
 function launchApp(client, webappsActor, manifestURL) {
   let deferred = promise.defer();
   let request = {
     to: webappsActor,
     type: "launch",
     manifestURL: manifestURL
   };
   client.request(request, (res) => {
     if (res.error) {
       deferred.reject(res.error);
     } else {
       deferred.resolve(res);
     }
   });
   return deferred.promise;
 }
 exports.launchApp = launchApp;
 function closeApp(client, webappsActor, manifestURL) {
   let deferred = promise.defer();
   let request = {
     to: webappsActor,
     type: "close",
     manifestURL: manifestURL
   };
   client.request(request, (res) => {
     if (res.error) {
       deferred.reject(res.error);
     } else {
       deferred.resolve(res);
     }
   });
   return deferred.promise;
 }
 exports.closeApp = closeApp;