From 727470d9ed2566910bf0f08c84a24b6efd287f21 Mon Sep 17 00:00:00 2001
From: yflory <yann.flory@xwiki.com>
Date: Mon, 27 May 2019 14:59:08 +0200
Subject: [PATCH] Add missing file

---
 www/common/outer/profile.js | 157 ++++++++++++++++++++++++++++++++++++
 1 file changed, 157 insertions(+)
 create mode 100644 www/common/outer/profile.js

diff --git a/www/common/outer/profile.js b/www/common/outer/profile.js
new file mode 100644
index 000000000..ff57917d8
--- /dev/null
+++ b/www/common/outer/profile.js
@@ -0,0 +1,157 @@
+define([
+    '/common/common-util.js',
+    '/common/common-hash.js',
+    '/common/common-constants.js',
+    '/common/common-realtime.js',
+    '/bower_components/chainpad-listmap/chainpad-listmap.js',
+    '/bower_components/chainpad-crypto/crypto.js',
+    '/bower_components/chainpad/chainpad.dist.js',
+], function (Util, Hash, Constants, Realtime, Listmap, Crypto, ChainPad) {
+    var Profile = {};
+
+    var initializeProfile = function (ctx, cb) {
+        var profile = ctx.profile;
+        if (!profile.edit || !profile.view) {
+            var hash = Hash.createRandomHash('profile');
+            var secret = Hash.getSecrets('profile', hash);
+            ctx.pinPads([secret.channel], function (res) {
+                if (res.error) {
+                    return void cb(res.error);
+                }
+                profile.edit = Hash.getEditHashFromKeys(secret);
+                profile.view = Hash.getViewHashFromKeys(secret);
+                cb();
+            });
+            return;
+        }
+        cb();
+    };
+
+    var openChannel = function (ctx) {
+        var profile = ctx.profile;
+        var secret = Hash.getSecrets('profile', profile.edit);
+        var crypto = Crypto.createEncryptor(secret.keys);
+
+        var cfg = {
+            data: {},
+            network: ctx.store.network,
+            channel: secret.channel,
+            crypto: crypto,
+            owners: [ctx.store.proxy.edPublic],
+            ChainPad: ChainPad,
+            validateKey: secret.keys.validateKey || undefined,
+            userName: 'profile',
+            classic: true
+        };
+        var lm = Listmap.create(cfg);
+        lm.proxy.on('create', function () {
+        }).on('ready', function () {
+            lm.proxy.name = ctx.store.proxy[Constants.displayNameKey] || "";
+            ctx.listmap = lm;
+            if (!lm.proxy.curvePublic) {
+                lm.proxy.curvePublic = ctx.store.proxy.curvePublic;
+            }
+            if (!lm.proxy.notifications) {
+                lm.proxy.notifications = Util.find(ctx.store.proxy, ['mailboxes', 'notifications', 'channel']);
+            }
+            if (ctx.onReadyHandlers.length) {
+                ctx.onReadyHandlers.forEach(function (f) {
+                    try {
+                        f(lm.proxy);
+                    } catch (e) { console.error(e); }
+                });
+                ctx.onReadyHandlers = [];
+            }
+        }).on('change', [], function () {
+            ctx.emit('UPDATE', lm.proxy, ctx.clients);
+        });
+    };
+
+    var setName = function (ctx, value, cb) {
+        cb = cb || function () {};
+        ctx.profile.name = value;
+        Realtime.whenRealtimeSyncs(ctx.listmap.realtime, function () {
+            if (!ctx.listmap) { return; }
+            ctx.emit('UPDATE', ctx.listmap.proxy, ctx.clients);
+        });
+    };
+
+    var subscribe = function (ctx, data, cId, cb) {
+        // Subscribe to new notifications
+        var idx = ctx.clients.indexOf(cId);
+        if (idx === -1) {
+            ctx.clients.push(cId);
+        }
+        if (ctx.listmap) {
+            return void cb(ctx.listmap.proxy);
+        }
+        ctx.onReadyHandlers.push(function (proxy) {
+            cb(proxy);
+        });
+    };
+
+    var setValue = function (ctx, data, cId, cb) {
+        var key = data.key;
+        var value = data.value;
+        if (!key) { return; }
+        ctx.listmap.proxy[key] = value;
+        Realtime.whenRealtimeSyncs(ctx.listmap.realtime, function () {
+            ctx.emit('UPDATE', ctx.listmap.proxy, ctx.clients.filter(function (clientId) {
+                return clientId !== cId;
+            }));
+            cb(ctx.listmap.proxy);
+        });
+    };
+
+    var removeClient = function (ctx, cId) {
+        var idx = ctx.clients.indexOf(cId);
+        ctx.clients.splice(idx, 1);
+    };
+
+    Profile.init = function (cfg, waitFor, emit) {
+        var profile = {};
+        var store = cfg.store;
+        if (!store.loggedIn || !store.proxy.edPublic) { return; }
+        var ctx = {
+            store: store,
+            pinPads: cfg.pinPads,
+            updateMetadata: cfg.updateMetadata,
+            emit: emit,
+            onReadyHandlers: [],
+            clients: [],
+        };
+
+        ctx.profile = store.proxy.profile = store.proxy.profile || {};
+
+        console.log(ctx.profile);
+
+        initializeProfile(ctx, waitFor(function (err) {
+            if (err) { return; }
+            openChannel(ctx);
+        }));
+
+        profile.setName = function (value) {
+            setName(ctx, value);
+        };
+        profile.removeClient = function (clientId) {
+            removeClient(ctx, clientId);
+        };
+        profile.execCommand = function (clientId, obj, cb) {
+            console.log(obj);
+            var cmd = obj.cmd;
+            var data = obj.data;
+            if (cmd === 'SUBSCRIBE') {
+                return void subscribe(ctx, data, clientId, cb);
+            }
+            if (cmd === 'SET') {
+                return void setValue(ctx, data, clientId, cb);
+            }
+        };
+
+        return profile;
+    };
+
+    return Profile;
+});
+
+