diff -r 000000000000 -r 6474c204b198 dom/wappush/src/gonk/WapPushManager.js
--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/dom/wappush/src/gonk/WapPushManager.js	Wed Dec 31 06:09:35 2014 +0100
@@ -0,0 +1,182 @@
+/* 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";
+
+const {classes: Cc, interfaces: Ci, utils: Cu, results: Cr} = Components;
+
+Cu.import("resource://gre/modules/XPCOMUtils.jsm");
+Cu.import("resource://gre/modules/Services.jsm");
+Cu.import("resource://gre/modules/PhoneNumberUtils.jsm");
+Cu.import("resource://gre/modules/WspPduHelper.jsm", this);
+
+const DEBUG = false; // set to true to see debug messages
+
+/**
+ * WAP Push decoders
+ */
+XPCOMUtils.defineLazyGetter(this, "SI", function () {
+  let SI = {};
+  Cu.import("resource://gre/modules/SiPduHelper.jsm", SI);
+  return SI;
+});
+
+XPCOMUtils.defineLazyGetter(this, "SL", function () {
+  let SL = {};
+  Cu.import("resource://gre/modules/SlPduHelper.jsm", SL);
+  return SL;
+});
+
+XPCOMUtils.defineLazyGetter(this, "CP", function () {
+  let CP = {};
+  Cu.import("resource://gre/modules/CpPduHelper.jsm", CP);
+  return CP;
+});
+
+XPCOMUtils.defineLazyServiceGetter(this, "gSystemMessenger",
+                                   "@mozilla.org/system-message-internal;1",
+                                   "nsISystemMessagesInternal");
+XPCOMUtils.defineLazyServiceGetter(this, "gRIL",
+                                   "@mozilla.org/ril;1",
+                                   "nsIRadioInterfaceLayer");
+
+/**
+ * Helpers for WAP PDU processing.
+ */
+this.WapPushManager = {
+
+  /**
+   * Parse raw PDU data and deliver to a proper target.
+   *
+   * @param data
+   *        A wrapped object containing raw PDU data.
+   * @param options
+   *        Extra context for decoding.
+   */
+  processMessage: function processMessage(data, options) {
+    try {
+      PduHelper.parse(data, true, options);
+      debug("options: " + JSON.stringify(options));
+    } catch (ex) {
+      debug("Failed to parse sessionless WSP PDU: " + ex.message);
+      return;
+    }
+
+    let appid = options.headers["x-wap-application-id"];
+    if (!appid) {
+      // Assume message without applicatioin ID is WAP Push
+      debug("Push message doesn't contains X-Wap-Application-Id.");
+    }
+
+    // MMS
+    if (appid == "x-wap-application:mms.ua") {
+      let mmsService = Cc["@mozilla.org/mms/rilmmsservice;1"]
+                       .getService(Ci.nsIMmsService);
+      mmsService.QueryInterface(Ci.nsIWapPushApplication)
+                .receiveWapPush(data.array, data.array.length, data.offset, options);
+      return;
+    }
+
+    /**
+    * Non-MMS, handled according to content type
+    *
+    * WAP Type            content-type                              x-wap-application-id
+    * MMS                 "application/vnd.wap.mms-message"         "x-wap-application:mms.ua"
+    * SI                  "text/vnd.wap.si"                         "x-wap-application:wml.ua"
+    * SI(WBXML)           "application/vnd.wap.sic"                 "x-wap-application:wml.ua"
+    * SL                  "text/vnd.wap.sl"                         "x-wap-application:wml.ua"
+    * SL(WBXML)           "application/vnd.wap.slc"                 "x-wap-application:wml.ua"
+    * Provisioning        "text/vnd.wap.connectivity-xml"           "x-wap-application:wml.ua"
+    * Provisioning(WBXML) "application/vnd.wap.connectivity-wbxml"  "x-wap-application:wml.ua"
+    *
+    * @see http://technical.openmobilealliance.org/tech/omna/omna-wsp-content-type.aspx
+    */
+    let contentType = options.headers["content-type"].media;
+    let msg;
+    let authInfo = null;
+
+    if (contentType === "text/vnd.wap.si" ||
+        contentType === "application/vnd.wap.sic") {
+      msg = SI.PduHelper.parse(data, contentType);
+    } else if (contentType === "text/vnd.wap.sl" ||
+               contentType === "application/vnd.wap.slc") {
+      msg = SL.PduHelper.parse(data, contentType);
+    } else if (contentType === "text/vnd.wap.connectivity-xml" ||
+               contentType === "application/vnd.wap.connectivity-wbxml") {
+      // Apply HMAC authentication on WBXML encoded CP message.
+      if (contentType === "application/vnd.wap.connectivity-wbxml") {
+        let params = options.headers["content-type"].params;
+        let sec = params && params.sec;
+        let mac = params && params.mac;
+        authInfo = CP.Authenticator.check(data.array.subarray(data.offset),
+                                          sec, mac, function getNetworkPin() {
+          let imsi = gRIL.getRadioInterface(options.serviceId).rilContext.imsi;
+          return CP.Authenticator.formatImsi(imsi);
+        });
+      }
+
+      msg = CP.PduHelper.parse(data, contentType);
+    } else {
+      // Unsupported type, provide raw data.
+      msg = {
+        contentType: contentType,
+        content: data.array
+      };
+      msg.content.length = data.array.length;
+    }
+
+    let sender = PhoneNumberUtils.normalize(options.sourceAddress, false);
+    let parsedSender = PhoneNumberUtils.parse(sender);
+    if (parsedSender && parsedSender.internationalNumber) {
+      sender = parsedSender.internationalNumber;
+    }
+
+    gSystemMessenger.broadcastMessage("wappush-received", {
+      sender:         sender,
+      contentType:    msg.contentType,
+      content:        msg.content,
+      authInfo:       authInfo,
+      serviceId:      options.serviceId
+    });
+  },
+
+  /**
+   * @param array
+   *        A Uint8Array or an octet array representing raw PDU data.
+   * @param length
+   *        Length of the array.
+   * @param offset
+   *        Offset of the array that a raw PDU data begins.
+   * @param options
+   *        WDP bearer information.
+   */
+  receiveWdpPDU: function receiveWdpPDU(array, length, offset, options) {
+    if ((options.bearer == null) || !options.sourceAddress
+        || (options.sourcePort == null) || !array) {
+      debug("Incomplete WDP PDU");
+      return;
+    }
+
+    if (options.destinationPort != WDP_PORT_PUSH) {
+      debug("Not WAP Push port: " + options.destinationPort);
+      return;
+    }
+
+    this.processMessage({array: array, offset: offset}, options);
+  },
+};
+
+let debug;
+if (DEBUG) {
+  debug = function (s) {
+    dump("-*- WapPushManager: " + s + "\n");
+  };
+} else {
+  debug = function (s) {};
+}
+
+this.EXPORTED_SYMBOLS = ALL_CONST_SYMBOLS.concat([
+  "WapPushManager",
+]);
+