1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
|
/*global ot, $ */
ot.AjaxAdapter = (function () {
'use strict';
function AjaxAdapter (path, ownUserName, revision) {
if (path[path.length - 1] !== '/') { path += '/'; }
this.path = path;
this.ownUserName = ownUserName;
this.majorRevision = revision.major || 0;
this.minorRevision = revision.minor || 0;
this.poll();
}
AjaxAdapter.prototype.renderRevisionPath = function () {
return 'revision/' + this.majorRevision + '-' + this.minorRevision;
};
AjaxAdapter.prototype.handleResponse = function (data) {
var i;
var operations = data.operations;
for (i = 0; i < operations.length; i++) {
if (operations[i].user === this.ownUserName) {
this.trigger('ack');
} else {
this.trigger('operation', operations[i].operation);
}
}
if (operations.length > 0) {
this.majorRevision += operations.length;
this.minorRevision = 0;
}
var events = data.events;
if (events) {
for (i = 0; i < events.length; i++) {
var user = events[i].user;
if (user === this.ownUserName) { continue; }
switch (events[i].event) {
case 'joined': this.trigger('set_name', user, user); break;
case 'left': this.trigger('client_left', user); break;
case 'selection': this.trigger('selection', user, events[i].selection); break;
}
}
this.minorRevision += events.length;
}
var users = data.users;
if (users) {
delete users[this.ownUserName];
this.trigger('clients', users);
}
if (data.revision) {
this.majorRevision = data.revision.major;
this.minorRevision = data.revision.minor;
}
};
AjaxAdapter.prototype.poll = function () {
var self = this;
$.ajax({
url: this.path + this.renderRevisionPath(),
type: 'GET',
dataType: 'json',
timeout: 5000,
success: function (data) {
self.handleResponse(data);
self.poll();
},
error: function () {
setTimeout(function () { self.poll(); }, 500);
}
});
};
AjaxAdapter.prototype.sendOperation = function (revision, operation, selection) {
if (revision !== this.majorRevision) { throw new Error("Revision numbers out of sync"); }
var self = this;
$.ajax({
url: this.path + this.renderRevisionPath(),
type: 'POST',
data: JSON.stringify({ operation: operation, selection: selection }),
contentType: 'application/json',
processData: false,
success: function (data) {},
error: function () {
setTimeout(function () { self.sendOperation(revision, operation, selection); }, 500);
}
});
};
AjaxAdapter.prototype.sendSelection = function (obj) {
$.ajax({
url: this.path + this.renderRevisionPath() + '/selection',
type: 'POST',
data: JSON.stringify(obj),
contentType: 'application/json',
processData: false,
timeout: 1000
});
};
AjaxAdapter.prototype.registerCallbacks = function (cb) {
this.callbacks = cb;
};
AjaxAdapter.prototype.trigger = function (event) {
var args = Array.prototype.slice.call(arguments, 1);
var action = this.callbacks && this.callbacks[event];
if (action) { action.apply(this, args); }
};
return AjaxAdapter;
})();
|
