prototype users

customize.dist/user.js

@@ -0,0 +1,174 @@
+define([
+    '/api/config?cb=' + Math.random().toString().slice(2),
+    '/customize/messages.js',
+    '/bower_components/chainpad-listmap/chainpad-listmap.js',
+    '/bower_components/chainpad-crypto/crypto.js',
+    '/bower_components/scrypt-async/scrypt-async.min.js',
+    '/bower_components/tweetnacl/nacl-fast.min.js',
+], function (Config, Messages, Listmap, Crypto) {
+    var Scrypt = window.scrypt;
+    var Nacl = window.nacl;
+
+    var localKey = 'cryptpad_user_session';
+
+    var User = {};
+
+    var isArray = function (o) { return Object.prototype.toString.call(o) === '[object Array]'; };
+
+    var session = User.session = function (secret) {
+        // TODO use store.js, not localStorage?
+        if (secret) {
+            localStorage.setItem(localKey, JSON.stringify(secret));
+            return;
+        }
+        if (secret === null) {
+            localStorage.removeItem(localKey);
+            return;
+        }
+        var temp = localStorage.getItem(localKey);
+        try {
+            return JSON.parse(temp);
+        } catch (err) {
+            return null;
+        }
+    };
+
+    /*  64 uint8s symmetric keys
+          32 b64 channel
+            16 b64 key
+            16 b64 junk
+        32 uint8s ed signing key
+        32 uint8s curve public key */
+    var parse128 = function (A) {
+        if (A.length !== 128) {
+            throw new Error("Expected 128 uint8s!");
+        }
+        var symmetric = Nacl.util.encodeBase64(A.slice(0, 36));
+        return {
+            ed: A.slice(96),
+            curve: A.slice(64, 96),
+            channel: symmetric.slice(0, 32),
+            key: symmetric.slice(32),
+            extra: A.slice(36, 64),
+        };
+    };
+
+    var initialize = User.initialize = function (proxy, secret, cb) {
+        proxy.on('ready', function (info) {
+            var now = ''+new Date();
+            // old atime
+            var otime = proxy.atime;
+
+            var atime = proxy.atime = now;
+
+            // creation time
+            proxy.ctime = proxy.ctime || now;
+
+            proxy.username = proxy.username || secret.username;
+            proxy.schema = proxy.schema || 'login_data-v0';
+
+            proxy.documents = proxy.documents || [];
+            cb(void 0, proxy);
+        });
+    };
+
+    /*
+        cb(proxy);
+    */
+    var connect = User.connect = function (secret, cb) {
+        if (!secret) {
+            // FIXME
+            return;
+        }
+        var config = {
+            websocketURL: Config.websocketURL,
+            channel: secret.channel,
+            data: {},
+            crypto: Crypto.createEncryptor(secret.key),
+            logLevel: 0,
+        };
+        var rt = Listmap.create(config);
+        initialize(rt.proxy, secret, cb);
+    };
+
+    /*  Asynchronously derive 128 random uint8s given a uname and password
+
+        cb(proxy, secret)
+    */
+    var login = User.login = function (uname, pw, cb) {
+        Scrypt(pw,
+            uname,
+            15, // memory cost parameter
+            8, // block size parameter
+            128, // derived key length
+            200, // interruptStep
+            function (bytes) {
+                var secret = parse128(bytes);
+                secret.username = uname;
+                session(secret);
+                connect(secret, cb);
+        });
+    };
+
+    var prepareStore = User.prepareStore = function (proxy) {
+        var store = {};
+
+        var ps = proxy.store = proxy.store || {};
+
+        var set = store.set = function (key, val, cb) {
+            ps[key] = val;
+            cb();
+        };
+
+        var batchset = store.setBatch = function (map, cb) {
+            if (isArray(map) || typeof(map) !== 'object') {
+                cb('[setBatch.TypeError] expected key-value pairs to set');
+                return;
+            }
+            Object.keys(map).forEach(function (k) {
+                ps[k] = map[k];
+            });
+            cb();
+        };
+
+        var get = store.get = function (key, cb) {
+            cb(void 0, ps[key]);
+        };
+
+        var batchget = store.getBatch = function (keys, cb) {
+            if (!isArray(keys)) {
+                cb('[getBatch.TypeError] expected array of keys to return');
+                return;
+            }
+            var map = {};
+            keys.forEach(function (k) {
+                map[k] = ps[k];
+            });
+            cb(void 0, map);
+        };
+
+        var remove = store.remove = function (key, cb) {
+            ps[key] = undefined;
+            cb();
+        };
+
+        var batchremove = store.removeBatch = function (keys, cb) {
+            if (!isArray(keys)) {
+                cb('[batchremove.TypeError] expected array of keys to remove');
+                return;
+            }
+            keys.forEach(function (k) {
+                ps[k] = undefined;
+            });
+            cb();
+        };
+
+        var keys = store.keys = function (cb) {
+            cb(void 0, Object.keys(ps));
+        };
+
+        return store;
+    };
+
+    return User;
+});