From c61617411a19502650d47179df2587db6534d713 Mon Sep 17 00:00:00 2001
From: yflory <yann.flory@xwiki.com>
Date: Wed, 15 May 2019 14:49:35 +0200
Subject: [PATCH] Add mailbox module

---
 www/common/outer/async-store.js | 25 +++++++++++++++++++++++--
 1 file changed, 23 insertions(+), 2 deletions(-)

diff --git a/www/common/outer/async-store.js b/www/common/outer/async-store.js
index efa05d85d..72166095c 100644
--- a/www/common/outer/async-store.js
+++ b/www/common/outer/async-store.js
@@ -12,6 +12,7 @@ define([
     '/common/common-messenger.js',
     '/common/outer/cursor.js',
     '/common/outer/onlyoffice.js',
+    '/common/outer/mailbox.js',
     '/common/outer/chainpad-netflux-worker.js',
     '/common/outer/network-config.js',
     '/customize/application_config.js',
@@ -22,7 +23,7 @@ define([
     '/bower_components/nthen/index.js',
     '/bower_components/saferphore/index.js',
 ], function (Sortify, UserObject, ProxyManager, Migrate, Hash, Util, Constants, Feedback, Realtime, Messaging, Messenger,
-             Cursor, OnlyOffice, CpNfWorker, NetConfig, AppConfig,
+             Cursor, OnlyOffice, Mailbox, CpNfWorker, NetConfig, AppConfig,
              Crypto, ChainPad, Listmap, nThen, Saferphore) {
 
     var create = function () {
@@ -939,7 +940,6 @@ define([
         };
 
         // Cursor
-
         Store.cursor = {
             execCommand: function (clientId, data, cb) {
                 if (!store.cursor) { return void cb ({error: 'Cursor channel is disabled'}); }
@@ -947,6 +947,14 @@ define([
             }
         };
 
+        // Mailbox
+        Store.mailbox = {
+            execCommand: function (clientId, data, cb) {
+                if (!store.mailbox) { return void cb ({error: 'Mailbox is disabled'}); }
+                store.mailbox.execCommand(clientId, data, cb);
+            }
+        };
+
         // Admin
         Store.adminRpc = function (clientId, data, cb) {
             store.rpc.adminRpc(data, function (err, res) {
@@ -1291,6 +1299,7 @@ define([
             if (messengerIdx !== -1) {
                 messengerEventClients.splice(messengerIdx, 1);
             }
+            // TODO mailbox events
             try {
                 store.cursor.removeClient(clientId);
             } catch (e) { console.error(e); }
@@ -1392,6 +1401,17 @@ define([
             });
         };
 
+        var loadMailbox = function (waitFor) {
+            store.mailbox = Mailbox.init(store, waitFor, function (ev, data, clients) {
+                clients.forEach(function (cId) {
+                    postMessage(cId, 'MAILBOX_EVENT', {
+                        ev: ev,
+                        data: data
+                    });
+                });
+            });
+        };
+
         //////////////////////////////////////////////////////////////////
         /////////////////////// Init /////////////////////////////////////
         //////////////////////////////////////////////////////////////////
@@ -1486,6 +1506,7 @@ define([
                 loadMessenger();
                 loadCursor();
                 loadOnlyOffice();
+                loadMailbox(waitFor);
             }).nThen(function () {
                 var requestLogin = function () {
                     broadcast([], "REQUEST_LOGIN");