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

updated examples

Browse Source
This commit is contained in:
Kevin Jahns
2015-04-30 14:15:48 +02:00
parent 8a5b69e86c
commit 4d926cf841
18 changed files with 256 additions and 205 deletions
Download Patch File Download Diff File Expand all files Collapse all files

48
build/node/ConnectorClass.js
View File

@@ -38,10 +38,12 @@ module.exports = {
this.connections = {};
this.current_sync_target = null;
this.sent_hb_to_all_users = false;
this.is_initialized = true;
return this.connections_listeners = [];
return this.is_initialized = true;
},
onUserEvent: function(f) {
if (this.connections_listeners == null) {
this.connections_listeners = [];
}
return this.connections_listeners.push(f);
},
isRoleMaster: function() {
@@ -72,16 +74,18 @@ module.exports = {
var f, i, len, ref, results;
delete this.connections[user];
this.findNewSyncTarget();
ref = this.connections_listeners;
results = [];
for (i = 0, len = ref.length; i < len; i++) {
f = ref[i];
results.push(f({
action: "userLeft",
user: user
}));
if (this.connections_listeners != null) {
ref = this.connections_listeners;
results = [];
for (i = 0, len = ref.length; i < len; i++) {
f = ref[i];
results.push(f({
action: "userLeft",
user: user
}));
}
return results;
}
return results;
},
userJoined: function(user, role) {
var base, f, i, len, ref, results;
@@ -99,17 +103,19 @@ module.exports = {
this.performSyncWithMaster(user);
}
}
ref = this.connections_listeners;
results = [];
for (i = 0, len = ref.length; i < len; i++) {
f = ref[i];
results.push(f({
action: "userJoined",
user: user,
role: role
}));
if (this.connections_listeners != null) {
ref = this.connections_listeners;
results = [];
for (i = 0, len = ref.length; i < len; i++) {
f = ref[i];
results.push(f({
action: "userJoined",
user: user,
role: role
}));
}
return results;
}
return results;
},
whenSynced: function(args) {
if (args.constructore === Function) {