1.1 --- /dev/null Thu Jan 01 00:00:00 1970 +0000
1.2 +++ b/mobile/android/modules/ContactService.jsm Wed Dec 31 06:09:35 2014 +0100
1.3 @@ -0,0 +1,262 @@
1.4 +/* This Source Code Form is subject to the terms of the Mozilla Public
1.5 + * License, v. 2.0. If a copy of the MPL was not distributed with this file,
1.6 + * You can obtain one at http://mozilla.org/MPL/2.0/. */
1.7 +
1.8 +"use strict";
1.9 +
1.10 +const DEBUG = false;
1.11 +function debug(s) { dump("-*- Android ContactService component: " + s + "\n"); }
1.12 +
1.13 +const Cu = Components.utils;
1.14 +const Cc = Components.classes;
1.15 +const Ci = Components.interfaces;
1.16 +
1.17 +this.EXPORTED_SYMBOLS = [];
1.18 +
1.19 +Cu.import("resource://gre/modules/XPCOMUtils.jsm");
1.20 +Cu.import("resource://gre/modules/Services.jsm");
1.21 +Cu.import("resource://gre/modules/PhoneNumberUtils.jsm");
1.22 +
1.23 +XPCOMUtils.defineLazyServiceGetter(this, "ppmm", "@mozilla.org/parentprocessmessagemanager;1",
1.24 + "nsIMessageListenerManager");
1.25 +
1.26 +let ContactService = {
1.27 + init: function() {
1.28 + if (DEBUG) debug("Init");
1.29 + this._requestMessages = {};
1.30 +
1.31 + // Add listeners for all messages from ContactManager.js
1.32 + let messages = ["Contacts:Clear", "Contacts:Find", "Contacts:GetAll",
1.33 + "Contacts:GetAll:SendNow", "Contacts:GetCount", "Contacts:GetRevision",
1.34 + "Contact:Remove", "Contact:Save",];
1.35 + messages.forEach(function(msgName) {
1.36 + ppmm.addMessageListener(msgName, this);
1.37 + }.bind(this));
1.38 +
1.39 + // Add listeners for all messages from ContactService.java
1.40 + let returnMessages = ["Android:Contacts:Count",
1.41 + "Android:Contacts:Clear:Return:OK", "Android:Contacts:Clear:Return:KO",
1.42 + "Android:Contacts:Find:Return:OK", "Android:Contacts:Find:Return:KO",
1.43 + "Android:Contacts:GetAll:Next", "Android:Contacts:RegisterForMessages",
1.44 + "Android:Contact:Remove:Return:OK", "Android:Contact:Remove:Return:KO",
1.45 + "Android:Contact:Save:Return:OK", "Android:Contact:Save:Return:KO",];
1.46 +
1.47 + returnMessages.forEach(function(msgName) {
1.48 + Services.obs.addObserver(this, msgName, false);
1.49 + }.bind(this));
1.50 + },
1.51 +
1.52 + _sendMessageToJava: function(aMsg) {
1.53 + Services.androidBridge.handleGeckoMessage(aMsg);
1.54 + },
1.55 +
1.56 + _sendReturnMessage: function(aTopic, aRequestID, aResult) {
1.57 + this._requestMessages[aRequestID].target.sendAsyncMessage(aTopic, aResult);
1.58 + },
1.59 +
1.60 + _sendAndDeleteReturnMessage: function(aTopic, aRequestID, aResult) {
1.61 + this._sendReturnMessage(aTopic, aRequestID, aResult)
1.62 + delete this._requestMessages[aRequestID];
1.63 + },
1.64 +
1.65 + observe: function(aSubject, aTopic, aData) {
1.66 + if (DEBUG) {
1.67 + debug("observe: subject: " + aSubject + " topic: " + aTopic + " data: " + aData);
1.68 + }
1.69 +
1.70 + let message = JSON.parse(aData, function date_reviver(k, v) {
1.71 + // The Java service sends dates as strings, so convert them to Dates before
1.72 + // sending them back to the child.
1.73 + if (v != null && v != "null" &&
1.74 + ["updated", "published", "anniversary", "bday"].indexOf(k) != -1) {
1.75 + return new Date(v);
1.76 + }
1.77 + return v;
1.78 + });
1.79 + let requestID = message.requestID;
1.80 +
1.81 + // The return message topic is the same as the current topic, but without the "Android:" prefix
1.82 + let returnMessageTopic = aTopic.substring(8);
1.83 +
1.84 + switch (aTopic) {
1.85 + case "Android:Contacts:Find:Return:OK":
1.86 + this._sendAndDeleteReturnMessage(returnMessageTopic, requestID, {requestID: requestID, contacts: message.contacts});
1.87 + break;
1.88 +
1.89 + case "Android:Contacts:Find:Return:KO":
1.90 + this._sendAndDeleteReturnMessage(returnMessageTopic, requestID, {requestID: requestID});
1.91 + break;
1.92 +
1.93 + case "Android:Contact:Save:Return:OK":
1.94 + this._sendReturnMessage(returnMessageTopic, requestID, {requestID: requestID, contactID: message.contactID});
1.95 + this._sendAndDeleteReturnMessage("Contact:Changed", requestID, {contactID: message.contactID, reason: message.reason});
1.96 + break;
1.97 +
1.98 + case "Android:Contact:Save:Return:KO":
1.99 + this._sendAndDeleteReturnMessage(returnMessageTopic, requestID, {requestID: requestID});
1.100 + break;
1.101 +
1.102 + case "Android:Contact:Remove:Return:OK":
1.103 + this._sendReturnMessage(returnMessageTopic, requestID, {requestID: requestID, contactID: message.contactID});
1.104 + this._sendAndDeleteReturnMessage("Contact:Changed", requestID, {contactID: message.contactID, reason: "remove"});
1.105 + break;
1.106 +
1.107 + case "Android:Contact:Remove:Return:KO":
1.108 + this._sendAndDeleteReturnMessage(returnMessageTopic, requestID, {requestID: requestID});
1.109 + break;
1.110 +
1.111 + case "Android:Contacts:Clear:Return:OK":
1.112 + this._sendReturnMessage(returnMessageTopic, requestID, {requestID: requestID});
1.113 + this._sendAndDeleteReturnMessage("Contact:Changed", requestID, {reason: "remove"});
1.114 + break;
1.115 +
1.116 + case "Android:Contact:Clear:Return:KO":
1.117 + this._sendAndDeleteReturnMessage(returnMessageTopic, requestID, {requestID: requestID});
1.118 + break;
1.119 +
1.120 + case "Android:Contacts:GetAll:Next":
1.121 + // GetAll uses a cursor ID instead of a request ID. Translate the request ID back to the cursor ID
1.122 + this._sendReturnMessage(returnMessageTopic, requestID, {cursorId: requestID, contacts: message.contacts});
1.123 +
1.124 + // Send a message with no contacts to denote the end of contacts returned by the query
1.125 + this._sendAndDeleteReturnMessage(returnMessageTopic, requestID, {cursorId: requestID});
1.126 + break;
1.127 +
1.128 + case "Android:Contacts:Count":
1.129 + this._sendAndDeleteReturnMessage(returnMessageTopic, requestID, {requestID: requestID, count: message.count});
1.130 + break;
1.131 +
1.132 + default:
1.133 + throw "Wrong message received: " + aTopic;
1.134 + }
1.135 + },
1.136 +
1.137 + assertPermission: function(aMessage, aPerm) {
1.138 + if (!aMessage.target.assertPermission(aPerm)) {
1.139 + Cu.reportError("Contacts message " + aMessage.name +
1.140 + " from a content process with no" + aPerm + " privileges.");
1.141 + return false;
1.142 + }
1.143 + return true;
1.144 + },
1.145 +
1.146 + receiveMessage: function(aMessage) {
1.147 + if (DEBUG) debug("receiveMessage " + aMessage.name);
1.148 +
1.149 + // GetAll uses a cursor ID instead of a request ID, but they can be treated the same from here
1.150 + if (!aMessage.data.requestID && aMessage.data.cursorId) {
1.151 + aMessage.data.requestID = aMessage.data.cursorId;
1.152 + }
1.153 + let requestID = aMessage.data.requestID;
1.154 +
1.155 + // Store the message so it the request callback can be called when the Java side is finished
1.156 + this._requestMessages[requestID] = aMessage;
1.157 +
1.158 + switch (aMessage.name) {
1.159 + case "Contacts:Find":
1.160 + this.findContacts(aMessage);
1.161 + break;
1.162 +
1.163 + case "Contacts:GetAll":
1.164 + this.getAllContacts(aMessage);
1.165 + break;
1.166 +
1.167 + case "Contacts:GetAll:SendNow":
1.168 + // Send an empty message to denote there are no most contacts for the getAll query
1.169 + this._sendAndDeleteReturnMessage("Contacts:GetAll:Next", requestID, {cursorId: requestID});
1.170 + break;
1.171 +
1.172 + case "Contact:Save":
1.173 + this.saveContact(aMessage);
1.174 + break;
1.175 +
1.176 + case "Contact:Remove":
1.177 + this.removeContact(aMessage);
1.178 + break;
1.179 +
1.180 + case "Contacts:Clear":
1.181 + this.clearContacts(aMessage);
1.182 + break;
1.183 +
1.184 + case "Contacts:GetCount":
1.185 + this.getContactsCount(aMessage);
1.186 + break;
1.187 +
1.188 + case "Contacts:GetRevision":
1.189 + // Android does not support the get revision function
1.190 + this._sendAndDeleteReturnMessage("Contacts:GetRevision:Return:KO", requestID, {requestID: requestID,
1.191 + errorMsg: "Android does not support the revision function."});
1.192 + break;
1.193 +
1.194 + case "Contacts:RegisterForMessages":
1.195 + delete this._requestMessages[requestID];
1.196 + break;
1.197 +
1.198 + default:
1.199 + delete this._requestMessages[requestID];
1.200 + throw "Wrong message received: " + aMessage.name;
1.201 + }
1.202 + },
1.203 +
1.204 + findContacts: function(aMessage) {
1.205 + if (!this.assertPermission(aMessage, "contacts-read")) {
1.206 + return;
1.207 + }
1.208 +
1.209 + let countryName = PhoneNumberUtils.getCountryName();
1.210 + let substringmatchingPref = "dom.phonenumber.substringmatching." + countryName;
1.211 + let substringmatchingValue = 0;
1.212 + if (Services.prefs.getPrefType(substringmatchingPref) == Ci.nsIPrefBranch.PREF_INT) {
1.213 + substringmatchingValue = Services.prefs.getIntPref(substringmatchingPref);
1.214 + }
1.215 +
1.216 + // Add the substring matching value to the find options JSON
1.217 + aMessage.data.options.findOptions.substringMatching = substringmatchingValue;
1.218 +
1.219 + this._sendMessageToJava({type: "Android:Contacts:Find", data: aMessage.data});
1.220 + },
1.221 +
1.222 + getAllContacts: function(aMessage) {
1.223 + if (!this.assertPermission(aMessage, "contacts-read")) {
1.224 + return;
1.225 + }
1.226 +
1.227 + this._sendMessageToJava({type: "Android:Contacts:GetAll", data: aMessage.data});
1.228 + },
1.229 +
1.230 + saveContact: function(aMessage) {
1.231 + if ((aMessage.data.options.reason === "create" &&
1.232 + !this.assertPermission(aMessage, "contacts-create")) ||
1.233 + !this.assertPermission(aMessage, "contacts-write")) {
1.234 + return;
1.235 + }
1.236 +
1.237 + this._sendMessageToJava({type: "Android:Contact:Save", data: aMessage.data});
1.238 + },
1.239 +
1.240 + removeContact: function(aMessage) {
1.241 + if (!this.assertPermission(aMessage, "contacts-write")) {
1.242 + return;
1.243 + }
1.244 +
1.245 + this._sendMessageToJava({type: "Android:Contact:Remove", data: aMessage.data});
1.246 + },
1.247 +
1.248 + clearContacts: function(aMessage) {
1.249 + if (!this.assertPermission(aMessage, "contacts-write")) {
1.250 + return;
1.251 + }
1.252 +
1.253 + this._sendMessageToJava({type: "Android:Contacts:Clear", data: aMessage.data});
1.254 + },
1.255 +
1.256 + getContactsCount: function(aMessage) {
1.257 + if (!this.assertPermission(aMessage, "contacts-read")) {
1.258 + return;
1.259 + }
1.260 +
1.261 + this._sendMessageToJava({type: "Android:Contacts:GetCount", data: aMessage.data});
1.262 + },
1.263 +}
1.264 +
1.265 +ContactService.init();
