web/cryptpad
2
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

Refactor sframe-cpnf-inner to export chainpad

Browse Source
This commit is contained in:
Caleb James DeLisle 2017-09-25 15:44:03 +02:00
parent 44018ee7e1
commit ae54cbca33
1 changed files with 22 additions and 20 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

42
www/common/sframe-chainpad-netflux-inner.js
View File

@ -46,7 +46,21 @@ define([
var metadataMgr = config.metadataMgr; var metadataMgr = config.metadataMgr;
config = undefined; config = undefined;
var chainpad; var chainpad = ChainPad.create({
userName: userName,
initialState: initialState,
transformFunction: transformFunction,
validateContent: validateContent,
avgSyncMilliseconds: avgSyncMilliseconds,
logLevel: logLevel
});
chainpad.onMessage(function(message, cb) {
sframeChan.query('Q_RT_MESSAGE', message, cb);
});
chainpad.onPatch(function () {
onRemote({ realtime: chainpad });
});
var myID; var myID;
var isReady = false; var isReady = false;
var evConnected = Util.mkEvent(true); var evConnected = Util.mkEvent(true);
@ -67,33 +81,20 @@ define([
sframeChan.on('EV_RT_DISCONNECT', function () { sframeChan.on('EV_RT_DISCONNECT', function () {
isReady = false; isReady = false;
if (chainpad) { chainpad.abort(); } chainpad.abort();
onConnectionChange({ state: false }); onConnectionChange({ state: false });
}); });
sframeChan.on('EV_RT_CONNECT', function (content) { sframeChan.on('EV_RT_CONNECT', function (content) {
//content.members.forEach(userList.onJoin); //content.members.forEach(userList.onJoin);
myID = content.myID;
isReady = false; isReady = false;
if (chainpad) { if (myID) {
// it's a reconnect // it's a reconnect
if (chainpad) { chainpad.start(); } myID = content.myID;
chainpad.start();
onConnectionChange({ state: true, myId: myID }); onConnectionChange({ state: true, myId: myID });
return; return;
} }
chainpad = ChainPad.create({ myID = content.myID;
userName: userName,
initialState: initialState,
transformFunction: transformFunction,
validateContent: validateContent,
avgSyncMilliseconds: avgSyncMilliseconds,
logLevel: logLevel
});
chainpad.onMessage(function(message, cb) {
sframeChan.query('Q_RT_MESSAGE', message, cb);
});
chainpad.onPatch(function () {
onRemote({ realtime: chainpad });
});
onInit({ onInit({
myID: myID, myID: myID,
realtime: chainpad, realtime: chainpad,
@ -130,7 +131,8 @@ define([
getMyID: function () { return myID; }, getMyID: function () { return myID; },
metadataMgr: metadataMgr, metadataMgr: metadataMgr,
whenRealtimeSyncs: whenRealtimeSyncs, whenRealtimeSyncs: whenRealtimeSyncs,
onInfiniteSpinner: evInfiniteSpinner.reg onInfiniteSpinner: evInfiniteSpinner.reg,
chainpad: chainpad,
}); });
}; };
return Object.freeze(module.exports); return Object.freeze(module.exports);