/* 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';

function debug(s) {
  //dump('DEBUG RequestSyncManager: ' + s + '\n');
}

const {classes: Cc, interfaces: Ci, utils: Cu, results: Cr} = Components;

Cu.import("resource://gre/modules/DOMRequestHelper.jsm");
Cu.import('resource://gre/modules/XPCOMUtils.jsm');
Cu.import('resource://gre/modules/RequestSyncApp.jsm');
Cu.import('resource://gre/modules/RequestSyncTask.jsm');

XPCOMUtils.defineLazyServiceGetter(this, "cpmm",
                                   "@mozilla.org/childprocessmessagemanager;1",
                                   "nsIMessageSender");

function RequestSyncManager() {
  debug('created');
}

RequestSyncManager.prototype = {
  __proto__: DOMRequestIpcHelper.prototype,

  classDescription: 'RequestSyncManager XPCOM Component',
  classID: Components.ID('{e6f55080-e549-4e30-9d00-15f240fb763c}'),
  contractID: '@mozilla.org/dom/request-sync-manager;1',
  QueryInterface: XPCOMUtils.generateQI([Ci.nsISupportsWeakReference,
                                         Ci.nsIObserver,
                                         Ci.nsIDOMGlobalPropertyInitializer]),

  _messages: [ "RequestSyncManager:Registrations:Return",
               "RequestSyncManager:SetPolicy:Return",
               "RequestSyncManager:RunTask:Return" ],

  init: function(aWindow) {
    debug("init");

    // DOMRequestIpcHelper.initHelper sets this._window
    this.initDOMRequestHelper(aWindow, this._messages);
  },

  sendMessage: function(aMsg, aObj) {
    let self = this;
    return this.createPromiseWithId(function(aResolverId) {
      aObj.requestID = aResolverId;
      cpmm.sendAsyncMessage(aMsg, aObj, null,
                            self._window.document.nodePrincipal);
    });
  },

  registrations: function() {
    debug('registrations');
    return this.sendMessage("RequestSyncManager:Registrations", {});
  },

  setPolicy: function(aTask, aOrigin, aManifestURL, aIsInBrowserElement,
                      aState, aOverwrittenMinInterval) {
    debug('setPolicy');

    return this.sendMessage("RequestSyncManager:SetPolicy",
      { task: aTask,
        origin: aOrigin,
        manifestURL: aManifestURL,
        isInBrowserElement: aIsInBrowserElement,
        state: aState,
        overwrittenMinInterval: aOverwrittenMinInterval });
  },

  runTask: function(aTask, aOrigin, aManifestURL, aIsInBrowserElement) {
    debug('runTask');

    return this.sendMessage("RequestSyncManager:RunTask",
      { task: aTask,
        origin: aOrigin,
        manifestURL: aManifestURL,
        isInBrowserElement: aIsInBrowserElement });
  },

  registrationsResult: function(aData) {
    debug("registrationsResult");

    let results = new this._window.Array();
    for (let i = 0; i < aData.length; ++i) {
      if (!("app" in aData[i])) {
        dump("ERROR - Serialization error in RequestSyncManager.\n");
        continue;
      }

      let app = new RequestSyncApp(aData[i].app);
      let exposedApp =
        this._window.RequestSyncApp._create(this._window, app);

      let task = new RequestSyncTask(this, this._window, exposedApp, aData[i]);
      let exposedTask =
        this._window.RequestSyncTask._create(this._window, task);

      results.push(exposedTask);
    }
    return results;
  },

  receiveMessage: function(aMessage) {
    debug('receiveMessage');

    let req = this.getPromiseResolver(aMessage.data.requestID);
    if (!req) {
      return;
    }

    if ('error' in aMessage.data) {
      req.reject(Cu.cloneInto(aMessage.data.error, this._window));
      return;
    }

    if (aMessage.name == 'RequestSyncManager:Registrations:Return') {
      req.resolve(this.registrationsResult(aMessage.data.results));
      return;
    }

    if ('results' in aMessage.data) {
      req.resolve(Cu.cloneInto(aMessage.data.results, this._window));
      return;
    }

    req.resolve();
  }
};

this.NSGetFactory = XPCOMUtils.generateNSGetFactory([RequestSyncManager]);