yonote/yjs
14
0
Fork 0
Code Pull Requests 1 Releases Activity

sync speedup

Browse Source
This commit is contained in:
Kevin Jahns
2014-08-14 20:22:07 +02:00
parent 089ae137dc
commit a637633a1c
13 changed files with 375 additions and 252 deletions
Download Patch File Download Diff File Expand all files Collapse all files

36
build/browser/Connectors/IwcConnector.js
View File

@@ -2,7 +2,7 @@
var createIwcConnector;
createIwcConnector = function(callback, initial_user_id) {
var IwcConnector, duiClient, get_HB_intent, init, iwcHandler, received_HB, send_get_HB_intent;
var IwcConnector, duiClient, init, iwcHandler, received_HB;
iwcHandler = {};
duiClient = new DUIClient();
duiClient.connect(function(intent) {
@@ -26,22 +26,31 @@ createIwcConnector = function(callback, initial_user_id) {
this.iwcHandler = iwcHandler;
send_ = (function(_this) {
return function(o) {
return _this.send(o);
if (Object.getOwnPropertyNames(_this.initialized).length !== 0) {
return _this.send(o);
}
};
})(this);
this.execution_listener.push(send_);
this.initialized = {};
receiveHB = (function(_this) {
return function(json) {
HB = json != null ? json.extras.HB : void 0;
return _this.engine.applyOpsCheckDouble(HB);
var him;
HB = json.extras.HB;
him = json.extras.user;
_this.engine.applyOpsCheckDouble(HB);
return _this.initialized[him] = true;
};
})(this);
iwcHandler["Yatta_push_HB_element"] = [receiveHB];
this.sendIwcIntent("Yatta_get_HB_element", {});
receive_ = (function(_this) {
return function(intent) {
var o;
o = intent.extras;
return _this.receive(o);
if (_this.initialized[o.uid.creator] != null) {
return _this.receive(o);
}
};
})(this);
this.iwcHandler["Yatta_new_operation"] = [receive_];
@@ -52,7 +61,8 @@ createIwcConnector = function(callback, initial_user_id) {
return function() {
var json;
json = {
HB: _this.yatta.getHistoryBuffer()._encode()
HB: _this.yatta.getHistoryBuffer()._encode(),
user: _this.yatta.getUserId()
};
return _this.sendIwcIntent("Yatta_push_HB_element", json);
};
@@ -88,20 +98,8 @@ createIwcConnector = function(callback, initial_user_id) {
return IwcConnector;
})();
get_HB_intent = {
action: "Yatta_get_HB_element",
component: "",
data: "",
dataType: "",
flags: ["PUBLISH_GLOBAL"],
extras: {}
};
send_get_HB_intent = function() {
return duiClient.sendIntent(get_HB_intent);
};
init = function() {
var proposed_user_id;
setTimeout(send_get_HB_intent, 1000);
proposed_user_id = null;
if (initial_user_id != null) {
proposed_user_id = initial_user_id;
@@ -110,7 +108,7 @@ createIwcConnector = function(callback, initial_user_id) {
}
return callback(IwcConnector, proposed_user_id);
};
setTimeout(init, 1000.);
setTimeout(init, 5000);
return void 0;
};

2
build/browser/Connectors/IwcConnector.min.js vendored
View File

@@ -1 +1 @@
!function t(n,e,r){function i(u,a){if(!e[u]){if(!n[u]){var c="function"==typeof require&&require;if(!a&&c)return c(u,!0);if(o)return o(u,!0);throw new Error("Cannot find module '"+u+"'")}var s=e[u]={exports:{}};n[u][0].call(s.exports,function(t){var e=n[u][1][t];return i(e?e:t)},s,s.exports,t,n,e,r)}return e[u].exports}for(var o="function"==typeof require&&require,u=0;u<r.length;u++)i(r[u]);return i}({1:[function(t,n){var e;e=function(t,n){var e,r,i,o,u,a,c;return u={},r=new DUIClient,r.connect(function(t){var n;return null!=(n=u[t.action])?n.map(function(n){return setTimeout(function(){return n(t)},0)}):void 0}),r.initOK(),a=null,e=function(){function t(t,n,e,i){var o,c,s,f;this.engine=t,this.HB=n,this.execution_listener=e,this.yatta=i,this.duiClient=r,this.iwcHandler=u,f=function(t){return function(n){return t.send(n)}}(this),this.execution_listener.push(f),o=function(t){return function(e){return n=null!=e?e.extras.HB:void 0,t.engine.applyOpsCheckDouble(n)}}(this),u.Yatta_push_HB_element=[o],c=function(t){return function(n){var e;return e=n.extras,t.receive(e)}}(this),this.iwcHandler.Yatta_new_operation=[c],null!=a&&this.engine.applyOpsCheckDouble(a),s=function(t){return function(){var n;return n={HB:t.yatta.getHistoryBuffer()._encode()},t.sendIwcIntent("Yatta_push_HB_element",n)}}(this),this.iwcHandler.Yatta_get_HB_element=[s]}return t.prototype.send=function(t){return t.uid.creator===this.HB.getUserId()&&"string"!=typeof t.uid.op_number?this.sendIwcIntent("Yatta_new_operation",t):void 0},t.prototype.receive=function(t){return t.uid.creator!==this.HB.getUserId()?this.engine.applyOp(t):void 0},t.prototype.sendIwcIntent=function(t,n){var e;return e={action:t,component:"",data:"",dataType:"",flags:["PUBLISH_GLOBAL"],extras:n},this.duiClient.sendIntent(e)},t}(),i={action:"Yatta_get_HB_element",component:"",data:"",dataType:"",flags:["PUBLISH_GLOBAL"],extras:{}},c=function(){return r.sendIntent(i)},o=function(){var r;return setTimeout(c,1e3),r=null,r=null!=n?n:Math.floor(1e6*Math.random()),t(e,r)},void setTimeout(o,1e3)},n.exports=e,"undefined"!=typeof window&&null!==window&&(window.createIwcConnector=e)},{}]},{},[1]);
!function t(e,n,i){function r(u,a){if(!n[u]){if(!e[u]){var s="function"==typeof require&&require;if(!a&&s)return s(u,!0);if(o)return o(u,!0);throw new Error("Cannot find module '"+u+"'")}var c=n[u]={exports:{}};e[u][0].call(c.exports,function(t){var n=e[u][1][t];return r(n?n:t)},c,c.exports,t,e,n,i)}return n[u].exports}for(var o="function"==typeof require&&require,u=0;u<i.length;u++)r(i[u]);return r}({1:[function(t,e){var n;n=function(t,e){var n,i,r,o,u;return o={},i=new DUIClient,i.connect(function(t){var e;return null!=(e=o[t.action])?e.map(function(e){return setTimeout(function(){return e(t)},0)}):void 0}),i.initOK(),u=null,n=function(){function t(t,e,n,r){var a,s,c,l;this.engine=t,this.HB=e,this.execution_listener=n,this.yatta=r,this.duiClient=i,this.iwcHandler=o,l=function(t){return function(e){return 0!==Object.getOwnPropertyNames(t.initialized).length?t.send(e):void 0}}(this),this.execution_listener.push(l),this.initialized={},a=function(t){return function(n){var i;return e=n.extras.HB,i=n.extras.user,t.engine.applyOpsCheckDouble(e),t.initialized[i]=!0}}(this),o.Yatta_push_HB_element=[a],this.sendIwcIntent("Yatta_get_HB_element",{}),s=function(t){return function(e){var n;return n=e.extras,null!=t.initialized[n.uid.creator]?t.receive(n):void 0}}(this),this.iwcHandler.Yatta_new_operation=[s],null!=u&&this.engine.applyOpsCheckDouble(u),c=function(t){return function(){var e;return e={HB:t.yatta.getHistoryBuffer()._encode(),user:t.yatta.getUserId()},t.sendIwcIntent("Yatta_push_HB_element",e)}}(this),this.iwcHandler.Yatta_get_HB_element=[c]}return t.prototype.send=function(t){return t.uid.creator===this.HB.getUserId()&&"string"!=typeof t.uid.op_number?this.sendIwcIntent("Yatta_new_operation",t):void 0},t.prototype.receive=function(t){return t.uid.creator!==this.HB.getUserId()?this.engine.applyOp(t):void 0},t.prototype.sendIwcIntent=function(t,e){var n;return n={action:t,component:"",data:"",dataType:"",flags:["PUBLISH_GLOBAL"],extras:e},this.duiClient.sendIntent(n)},t}(),r=function(){var i;return i=null,i=null!=e?e:Math.floor(1e6*Math.random()),t(n,i)},void setTimeout(r,5e3)},e.exports=n,"undefined"!=typeof window&&null!==window&&(window.createIwcConnector=n)},{}]},{},[1]);

36
build/browser/index.js
View File

@@ -2,7 +2,7 @@
var createIwcConnector;
createIwcConnector = function(callback, initial_user_id) {
var IwcConnector, duiClient, get_HB_intent, init, iwcHandler, received_HB, send_get_HB_intent;
var IwcConnector, duiClient, init, iwcHandler, received_HB;
iwcHandler = {};
duiClient = new DUIClient();
duiClient.connect(function(intent) {
@@ -26,22 +26,31 @@ createIwcConnector = function(callback, initial_user_id) {
this.iwcHandler = iwcHandler;
send_ = (function(_this) {
return function(o) {
return _this.send(o);
if (Object.getOwnPropertyNames(_this.initialized).length !== 0) {
return _this.send(o);
}
};
})(this);
this.execution_listener.push(send_);
this.initialized = {};
receiveHB = (function(_this) {
return function(json) {
HB = json != null ? json.extras.HB : void 0;
return _this.engine.applyOpsCheckDouble(HB);
var him;
HB = json.extras.HB;
him = json.extras.user;
_this.engine.applyOpsCheckDouble(HB);
return _this.initialized[him] = true;
};
})(this);
iwcHandler["Yatta_push_HB_element"] = [receiveHB];
this.sendIwcIntent("Yatta_get_HB_element", {});
receive_ = (function(_this) {
return function(intent) {
var o;
o = intent.extras;
return _this.receive(o);
if (_this.initialized[o.uid.creator] != null) {
return _this.receive(o);
}
};
})(this);
this.iwcHandler["Yatta_new_operation"] = [receive_];
@@ -52,7 +61,8 @@ createIwcConnector = function(callback, initial_user_id) {
return function() {
var json;
json = {
HB: _this.yatta.getHistoryBuffer()._encode()
HB: _this.yatta.getHistoryBuffer()._encode(),
user: _this.yatta.getUserId()
};
return _this.sendIwcIntent("Yatta_push_HB_element", json);
};
@@ -88,20 +98,8 @@ createIwcConnector = function(callback, initial_user_id) {
return IwcConnector;
})();
get_HB_intent = {
action: "Yatta_get_HB_element",
component: "",
data: "",
dataType: "",
flags: ["PUBLISH_GLOBAL"],
extras: {}
};
send_get_HB_intent = function() {
return duiClient.sendIntent(get_HB_intent);
};
init = function() {
var proposed_user_id;
setTimeout(send_get_HB_intent, 1000);
proposed_user_id = null;
if (initial_user_id != null) {
proposed_user_id = initial_user_id;
@@ -110,7 +108,7 @@ createIwcConnector = function(callback, initial_user_id) {
}
return callback(IwcConnector, proposed_user_id);
};
setTimeout(init, 1000.);
setTimeout(init, 5000);
return void 0;
};

4
build/browser/index.min.js vendored
View File

File diff suppressed because one or more lines are too long