зеркало из https://github.com/mozilla/pjs.git
473 строки
13 KiB
JavaScript
473 строки
13 KiB
JavaScript
/* 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/. */
|
|
|
|
const Cu = Components.utils;
|
|
const Cc = Components.classes;
|
|
const Ci = Components.interfaces;
|
|
|
|
let EXPORTED_SYMBOLS = ["DOMApplicationRegistry", "DOMApplicationManifest"];
|
|
|
|
Cu.import("resource://gre/modules/XPCOMUtils.jsm");
|
|
Cu.import("resource://gre/modules/Services.jsm");
|
|
Cu.import("resource://gre/modules/FileUtils.jsm");
|
|
|
|
XPCOMUtils.defineLazyGetter(this, "NetUtil", function() {
|
|
Cu.import("resource://gre/modules/NetUtil.jsm");
|
|
return NetUtil;
|
|
});
|
|
|
|
XPCOMUtils.defineLazyGetter(this, "ppmm", function() {
|
|
return Cc["@mozilla.org/parentprocessmessagemanager;1"].getService(Ci.nsIFrameMessageManager);
|
|
});
|
|
|
|
#ifdef MOZ_WIDGET_GONK
|
|
const DIRECTORY_NAME = "webappsDir";
|
|
#else
|
|
const DIRECTORY_NAME = "ProfD";
|
|
#endif
|
|
|
|
let DOMApplicationRegistry = {
|
|
appsFile: null,
|
|
webapps: { },
|
|
|
|
init: function() {
|
|
this.messages = ["Webapps:Install", "Webapps:Uninstall",
|
|
"Webapps:GetSelf", "Webapps:GetInstalled",
|
|
"Webapps:Launch", "Webapps:GetAll"];
|
|
|
|
this.messages.forEach((function(msgName) {
|
|
ppmm.addMessageListener(msgName, this);
|
|
}).bind(this));
|
|
|
|
Services.obs.addObserver(this, "xpcom-shutdown", false);
|
|
|
|
let appsDir = FileUtils.getDir(DIRECTORY_NAME, ["webapps"], true, true);
|
|
this.appsFile = FileUtils.getFile(DIRECTORY_NAME, ["webapps", "webapps.json"], true);
|
|
|
|
if (!this.appsFile.exists())
|
|
return;
|
|
|
|
this._loadJSONAsync(this.appsFile, (function(aData) { this.webapps = aData; }).bind(this));
|
|
|
|
try {
|
|
let hosts = Services.prefs.getCharPref("dom.mozApps.whitelist")
|
|
hosts.split(",").forEach(function(aHost) {
|
|
Services.perms.add(Services.io.newURI(aHost, null, null), "webapps-manage",
|
|
Ci.nsIPermissionManager.ALLOW_ACTION);
|
|
});
|
|
} catch(e) { }
|
|
},
|
|
|
|
observe: function(aSubject, aTopic, aData) {
|
|
if (aTopic == "xpcom-shutdown") {
|
|
this.messages.forEach((function(msgName) {
|
|
ppmm.removeMessageListener(msgName, this);
|
|
}).bind(this));
|
|
Services.obs.removeObserver(this, "xpcom-shutdown");
|
|
ppmm = null;
|
|
}
|
|
},
|
|
|
|
_loadJSONAsync: function(aFile, aCallback) {
|
|
try {
|
|
let channel = NetUtil.newChannel(aFile);
|
|
channel.contentType = "application/json";
|
|
NetUtil.asyncFetch(channel, function(aStream, aResult) {
|
|
if (!Components.isSuccessCode(aResult)) {
|
|
Cu.reportError("DOMApplicationRegistry: Could not read from json file " + aFile.path);
|
|
if (aCallback)
|
|
aCallback(null);
|
|
return;
|
|
}
|
|
|
|
// Read json file into a string
|
|
let data = null;
|
|
try {
|
|
data = JSON.parse(NetUtil.readInputStreamToString(aStream, aStream.available()) || "");
|
|
aStream.close();
|
|
if (aCallback)
|
|
aCallback(data);
|
|
} catch (ex) {
|
|
Cu.reportError("DOMApplicationRegistry: Could not parse JSON: " + ex);
|
|
if (aCallback)
|
|
aCallback(null);
|
|
}
|
|
});
|
|
} catch (ex) {
|
|
Cu.reportError("DOMApplicationRegistry: Could not read from " + aFile.path + " : " + ex);
|
|
if (aCallback)
|
|
aCallback(null);
|
|
}
|
|
},
|
|
|
|
receiveMessage: function(aMessage) {
|
|
let msg = aMessage.json;
|
|
|
|
switch (aMessage.name) {
|
|
case "Webapps:Install":
|
|
// always ask for UI to install
|
|
Services.obs.notifyObservers(this, "webapps-ask-install", JSON.stringify(msg));
|
|
break;
|
|
case "Webapps:GetSelf":
|
|
this.getSelf(msg);
|
|
break;
|
|
case "Webapps:Uninstall":
|
|
this.uninstall(msg);
|
|
break;
|
|
case "Webapps:Launch":
|
|
Services.obs.notifyObservers(this, "webapps-launch", JSON.stringify(msg));
|
|
break;
|
|
case "Webapps:GetInstalled":
|
|
this.getInstalled(msg);
|
|
break;
|
|
case "Webapps:GetAll":
|
|
if (msg.hasPrivileges)
|
|
this.getAll(msg);
|
|
else
|
|
ppmm.sendAsyncMessage("Webapps:GetAll:Return:KO", msg);
|
|
break;
|
|
}
|
|
},
|
|
|
|
_writeFile: function ss_writeFile(aFile, aData, aCallbak) {
|
|
// Initialize the file output stream.
|
|
let ostream = FileUtils.openSafeFileOutputStream(aFile);
|
|
|
|
// Obtain a converter to convert our data to a UTF-8 encoded input stream.
|
|
let converter = Cc["@mozilla.org/intl/scriptableunicodeconverter"].createInstance(Ci.nsIScriptableUnicodeConverter);
|
|
converter.charset = "UTF-8";
|
|
|
|
// Asynchronously copy the data to the file.
|
|
let istream = converter.convertToInputStream(aData);
|
|
NetUtil.asyncCopy(istream, ostream, function(rc) {
|
|
if (aCallbak)
|
|
aCallbak();
|
|
});
|
|
},
|
|
|
|
// clones a app object, without the manifest
|
|
_cloneAppObject: function(aApp) {
|
|
let clone = {
|
|
installOrigin: aApp.installOrigin,
|
|
origin: aApp.origin,
|
|
receipts: aApp.receipts,
|
|
installTime: aApp.installTime,
|
|
manifestURL: aApp.manifestURL
|
|
};
|
|
return clone;
|
|
},
|
|
|
|
denyInstall: function(aData) {
|
|
ppmm.sendAsyncMessage("Webapps:Install:Return:KO", aData);
|
|
},
|
|
|
|
confirmInstall: function(aData, aFromSync) {
|
|
let app = aData.app;
|
|
let id = app.syncId || this._appId(app.origin);
|
|
|
|
// install an application again is considered as an update
|
|
if (id) {
|
|
let dir = FileUtils.getDir(DIRECTORY_NAME, ["webapps", id], true, true);
|
|
try {
|
|
dir.remove(true);
|
|
} catch(e) {
|
|
}
|
|
}
|
|
else {
|
|
let uuidGenerator = Cc["@mozilla.org/uuid-generator;1"].getService(Ci.nsIUUIDGenerator);
|
|
id = uuidGenerator.generateUUID().toString();
|
|
}
|
|
|
|
let dir = FileUtils.getDir(DIRECTORY_NAME, ["webapps", id], true, true);
|
|
|
|
let manFile = dir.clone();
|
|
manFile.append("manifest.json");
|
|
this._writeFile(manFile, JSON.stringify(app.manifest));
|
|
|
|
this.webapps[id] = this._cloneAppObject(app);
|
|
delete this.webapps[id].manifest;
|
|
this.webapps[id].installTime = (new Date()).getTime()
|
|
|
|
|
|
if (!aFromSync)
|
|
this._saveApps((function() {
|
|
ppmm.sendAsyncMessage("Webapps:Install:Return:OK", aData);
|
|
Services.obs.notifyObservers(this, "webapps-sync-install", id);
|
|
}).bind(this));
|
|
},
|
|
|
|
_appId: function(aURI) {
|
|
for (let id in this.webapps) {
|
|
if (this.webapps[id].origin == aURI)
|
|
return id;
|
|
}
|
|
return null;
|
|
},
|
|
|
|
_saveApps: function(aCallback) {
|
|
this._writeFile(this.appsFile, JSON.stringify(this.webapps), function() {
|
|
if (aCallback)
|
|
aCallback();
|
|
});
|
|
},
|
|
|
|
/**
|
|
* Asynchronously reads a list of manifests
|
|
*/
|
|
_readManifests: function(aData, aFinalCallback, aIndex) {
|
|
if (!aData.length) {
|
|
aFinalCallback(aData);
|
|
return;
|
|
}
|
|
|
|
let index = aIndex || 0;
|
|
let id = aData[index].id;
|
|
let file = FileUtils.getFile(DIRECTORY_NAME, ["webapps", id, "manifest.json"], true);
|
|
this._loadJSONAsync(file, (function(aJSON) {
|
|
aData[index].manifest = aJSON;
|
|
if (index == aData.length - 1)
|
|
aFinalCallback(aData);
|
|
else
|
|
this._readManifests(aData, aFinalCallback, index + 1);
|
|
}).bind(this));
|
|
},
|
|
|
|
uninstall: function(aData) {
|
|
let found = false;
|
|
for (let id in this.webapps) {
|
|
let app = this.webapps[id];
|
|
if (app.origin == aData.origin) {
|
|
found = true;
|
|
delete this.webapps[id];
|
|
let dir = FileUtils.getDir(DIRECTORY_NAME, ["webapps", id], true, true);
|
|
try {
|
|
dir.remove(true);
|
|
} catch (e) {
|
|
}
|
|
this._saveApps((function() {
|
|
ppmm.sendAsyncMessage("Webapps:Uninstall:Return:OK", aData);
|
|
Services.obs.notifyObservers(this, "webapps-sync-uninstall", id);
|
|
}).bind(this));
|
|
}
|
|
}
|
|
if (!found)
|
|
ppmm.sendAsyncMessage("Webapps:Uninstall:Return:KO", aData);
|
|
},
|
|
|
|
getSelf: function(aData) {
|
|
aData.apps = [];
|
|
let tmp = [];
|
|
let id = this._appId(aData.origin);
|
|
|
|
if (id) {
|
|
let app = this._cloneAppObject(this.webapps[id]);
|
|
aData.apps.push(app);
|
|
tmp.push({ id: id });
|
|
}
|
|
|
|
this._readManifests(tmp, (function(aResult) {
|
|
for (let i = 0; i < aResult.length; i++)
|
|
aData.apps[i].manifest = aResult[i].manifest;
|
|
ppmm.sendAsyncMessage("Webapps:GetSelf:Return:OK", aData);
|
|
}).bind(this));
|
|
},
|
|
|
|
getInstalled: function(aData) {
|
|
aData.apps = [];
|
|
let tmp = [];
|
|
let id = this._appId(aData.origin);
|
|
|
|
for (id in this.webapps) {
|
|
if (this.webapps[id].installOrigin == aData.origin) {
|
|
aData.apps.push(this._cloneAppObject(this.webapps[id]));
|
|
tmp.push({ id: id });
|
|
}
|
|
}
|
|
|
|
this._readManifests(tmp, (function(aResult) {
|
|
for (let i = 0; i < aResult.length; i++)
|
|
aData.apps[i].manifest = aResult[i].manifest;
|
|
ppmm.sendAsyncMessage("Webapps:GetInstalled:Return:OK", aData);
|
|
}).bind(this));
|
|
},
|
|
|
|
getAll: function(aData) {
|
|
aData.apps = [];
|
|
let tmp = [];
|
|
|
|
for (id in this.webapps) {
|
|
let app = this._cloneAppObject(this.webapps[id]);
|
|
aData.apps.push(app);
|
|
tmp.push({ id: id });
|
|
}
|
|
|
|
this._readManifests(tmp, (function(aResult) {
|
|
for (let i = 0; i < aResult.length; i++)
|
|
aData.apps[i].manifest = aResult[i].manifest;
|
|
ppmm.sendAsyncMessage("Webapps:GetAll:Return:OK", aData);
|
|
}).bind(this));
|
|
},
|
|
|
|
getManifestFor: function(aOrigin, aCallback) {
|
|
if (!aCallback)
|
|
return;
|
|
|
|
let id = this._appId(aOrigin);
|
|
if (!id) {
|
|
aCallback(null);
|
|
return;
|
|
}
|
|
|
|
this._readManifests([{ id: id }], function(aResult) {
|
|
aCallback(aResult[0].manifest);
|
|
});
|
|
},
|
|
|
|
/** added to support the sync engine */
|
|
|
|
getAppById: function(aId) {
|
|
if (!this.webapps[aId])
|
|
return null;
|
|
|
|
let app = this._cloneAppObject(this.webapps[aId]);
|
|
return app;
|
|
},
|
|
|
|
itemExists: function(aId) {
|
|
return !!this.webapps[aId];
|
|
},
|
|
|
|
updateApps: function(aRecords, aCallback) {
|
|
for (let i = 0; i < aRecords.length; i++) {
|
|
let record = aRecords[i];
|
|
if (record.deleted) {
|
|
if (!this.webapps[record.id])
|
|
continue;
|
|
let origin = this.webapps[record.id].origin;
|
|
delete this.webapps[record.id];
|
|
let dir = FileUtils.getDir(DIRECTORY_NAME, ["webapps", record.id], true, true);
|
|
try {
|
|
dir.remove(true);
|
|
} catch (e) {
|
|
}
|
|
ppmm.sendAsyncMessage("Webapps:Uninstall:Return:OK", { origin: origin });
|
|
} else {
|
|
if (!!this.webapps[record.id]) {
|
|
this.webapps[record.id] = record.value;
|
|
delete this.webapps[record.id].manifest;
|
|
}
|
|
else {
|
|
let data = { app: record.value };
|
|
this.confirmInstall(data, true);
|
|
ppmm.sendAsyncMessage("Webapps:Install:Return:OK", data);
|
|
}
|
|
}
|
|
}
|
|
this._saveApps(aCallback);
|
|
},
|
|
|
|
/*
|
|
* May be removed once sync API change
|
|
*/
|
|
getAllIDs: function() {
|
|
let apps = {};
|
|
for (let id in this.webapps) {
|
|
// only sync http and https apps
|
|
if (this.webapps[id].origin.indexOf("http") == 0)
|
|
apps[id] = true;
|
|
}
|
|
return apps;
|
|
},
|
|
|
|
wipe: function(aCallback) {
|
|
let ids = this.getAllIDs();
|
|
for (let id in ids) {
|
|
delete this.webapps[id];
|
|
let dir = FileUtils.getDir(DIRECTORY_NAME, ["webapps", id], true, true);
|
|
try {
|
|
dir.remove(true);
|
|
} catch (e) {
|
|
}
|
|
}
|
|
this._saveApps(aCallback);
|
|
}
|
|
};
|
|
|
|
/**
|
|
* Helper object to access manifest information with locale support
|
|
*/
|
|
DOMApplicationManifest = function(aManifest, aOrigin) {
|
|
this._origin = Services.io.newURI(aOrigin, null, null);
|
|
this._manifest = aManifest;
|
|
let chrome = Cc["@mozilla.org/chrome/chrome-registry;1"].getService(Ci.nsIXULChromeRegistry)
|
|
.QueryInterface(Ci.nsIToolkitChromeRegistry);
|
|
let locale = chrome.getSelectedLocale("browser").toLowerCase();
|
|
this._localeRoot = this._manifest;
|
|
|
|
if (this._manifest.locales && this._manifest.locales[locale]) {
|
|
this._localeRoot = this._manifest.locales[locale];
|
|
}
|
|
else if (this._manifest.locales) {
|
|
// try with the language part of the locale ("en" for en-GB) only
|
|
let lang = locale.split('-')[0];
|
|
if (lang != locale && this._manifest.locales[lang])
|
|
this._localeRoot = this._manifest.locales[lang];
|
|
}
|
|
}
|
|
|
|
DOMApplicationManifest.prototype = {
|
|
_localeProp: function(aProp) {
|
|
if (this._localeRoot[aProp] != undefined)
|
|
return this._localeRoot[aProp];
|
|
return this._manifest[aProp];
|
|
},
|
|
|
|
get name() {
|
|
return this._localeProp("name");
|
|
},
|
|
|
|
get description() {
|
|
return this._localeProp("description");
|
|
},
|
|
|
|
get version() {
|
|
return this._localeProp("version");
|
|
},
|
|
|
|
get launch_path() {
|
|
return this._localeProp("launch_path");
|
|
},
|
|
|
|
get developer() {
|
|
return this._localeProp("developer");
|
|
},
|
|
|
|
get icons() {
|
|
return this._localeProp("icons");
|
|
},
|
|
|
|
iconURLForSize: function(aSize) {
|
|
let icons = this._localeProp("icons");
|
|
if (!icons)
|
|
return null;
|
|
let dist = 100000;
|
|
let icon = null;
|
|
for (let size in icons) {
|
|
let iSize = parseInt(size);
|
|
if (Math.abs(iSize - aSize) < dist) {
|
|
icon = this._origin.resolve(icons[size]);
|
|
dist = Math.abs(iSize - aSize);
|
|
}
|
|
}
|
|
return icon;
|
|
},
|
|
|
|
fullLaunchPath: function() {
|
|
let launchPath = this._localeProp("launch_path");
|
|
return this._origin.resolve(launchPath ? launchPath : "");
|
|
}
|
|
}
|
|
|
|
DOMApplicationRegistry.init();
|