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
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
|
/*
This file is part of rhizi, a collaborative knowledge graph editor.
Copyright (C) 2014-2015 Rhizi
This program is free software: you can redistribute it and/or modify
it under the terms of the GNU Affero General Public License as published
by the Free Software Foundation, either version 3 of the License, or
(at your option) any later version.
This program is distributed in the hope that it will be useful,
but WITHOUT ANY WARRANTY; without even the implied warranty of
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
GNU Affero General Public License for more details.
You should have received a copy of the GNU Affero General Public License
along with this program. If not, see <http://www.gnu.org/licenses/>.
*/
"use strict"
/**
* Manage backend websocket connection
*/
define([ 'util', 'model/diff', 'model/util', 'socketio', 'view/activity'],
function( util, model_diff, model_util, io, activity) {
var ws_server_url = document.location.origin + '/graph'; // socketio namespace
var socket;
var rz_mesh_graph_ref;
/**
* [!] caller is responsible of calling destroy()
*
* @param init_spec: expected to contain a graph:graph mapping
*/
function init(init_spec) {
socket = io.connect(ws_server_url, {
'reconnectionDelay': 30000,
});
util.assert(undefined != init_spec.graph, 'unable to init ws connection, graph undefined');
rz_mesh_graph_ref = init_spec.graph;
// wire up event handlers
socket.on('connect', on_connect);
socket.on('disconnect', on_disconnect);
socket.on('error', on_error);
socket.on('diff_commit__topo', ws_diff_merge__topo);
socket.on('diff_commit__attr', ws_diff_merge__attr);
}
function destroy(init_spec) {
socket.disconnect();
console.log('ws: connection closed on \'beforeunload\' event'); // no one will ever see this but still
}
function on_connect() {
console.log('ws: connection established: endpoint: ' + ws_server_url);
}
function on_disconnect() {
console.log('ws: connection closed on peer disconnect, endpoint: ' + ws_server_url);
}
function on_error(err) {
console.log('ws: error: ' + err);
}
/**
* Handle websocket incoming Topo_Diffs
*
* @param topo_diff_cr: Topo_Diff commit result object
*/
function ws_diff_merge__topo(topo_diff_spec_raw, topo_diff_cr) {
// adapt from wire format, no need to do the same for id_sets
var node_set_add = topo_diff_spec_raw.node_set_add.map(model_util.adapt_format_read_node)
var link_ptr_set = topo_diff_spec_raw.link_set_add.map(model_util.adapt_format_read_link_ptr)
var topo_diff_spec = { node_set_add: node_set_add,
link_set_add: link_ptr_set,
node_id_set_rm: topo_diff_spec_raw.node_id_set_rm,
link_id_set_rm: topo_diff_spec_raw.link_id_set_rm,
meta: topo_diff_spec_raw.meta };
// [!] note: this is not a pure Topo_Diff object in the sense it contain a link_ptr_set,
// not a resolved link object set
var topo_diff = model_diff.new_topo_diff(topo_diff_spec); // run through validation
console.log('ws: rx: ws_diff_merge__topo, committing wire-adapted topo_diff:', topo_diff);
activity.incomingActivityBus.push(topo_diff_spec);
rz_mesh_graph_ref.commit_diff__topo(topo_diff);
}
/**
* Handle websocket incoming Attr_Diffs
*
* @param attr_diff_cr: Attr_Diff commit result object
*/
function ws_diff_merge__attr(attr_diff_spec, attr_diff_cr) {
var attr_diff = model_diff.new_attr_diff_from_spec(attr_diff_spec); // run through validation
console.log('ws: rx: ws_diff_merge__attr, committing wire-adapted topo_diff:', attr_diff);
activity.incomingActivityBus.push(attr_diff_spec);
rz_mesh_graph_ref.commit_diff__attr(attr_diff);
}
function emit__rzdoc_subscribe(rzdoc_name) {
var callback = function(data) {
console.log('ws: rzdoc subscription acked: rzdoc name: \'' + rzdoc_name + '\'');
};
socket.emit('rzdoc_subscribe', { rzdoc_name: rzdoc_name}, callback);
}
function emit__rzdoc_unsubscribe(rzdoc_name) {
var callback = function(data) {
console.log('ws: rzdoc un-subscription acked: rzdoc name: \'' + rzdoc_name + '\'');
};
socket.emit('rzdoc_unsubscribe', { rzdoc_name: rzdoc_name}, callback);
}
return {
init : init,
destroy: destroy,
emit__rzdoc_subscribe: emit__rzdoc_subscribe,
emit__rzdoc_unsubscribe: emit__rzdoc_unsubscribe,
};
});
|
