diff options
| author | Alon Levy <alon@pobox.com> | 2014-12-16 17:37:42 +0200 |
|---|---|---|
| committer | Alon Levy <alon@pobox.com> | 2014-12-16 17:37:42 +0200 |
| commit | ade19de410e0a789a921ec1666b278b2a64176d6 (patch) | |
| tree | c4c54b106de93609ca7bb70a20fd4be696715dbe /src/client/model/graph.js | |
| parent | c7d026b1d504323a8c61d51b726e5e8d2337fc4b (diff) | |
moving files around after repository merger
Diffstat (limited to 'src/client/model/graph.js')
| -rw-r--r-- | src/client/model/graph.js | 873 |
1 files changed, 873 insertions, 0 deletions
diff --git a/src/client/model/graph.js b/src/client/model/graph.js new file mode 100644 index 00000000..b3c8e33f --- /dev/null +++ b/src/client/model/graph.js @@ -0,0 +1,873 @@ +"use strict" + +define(['Bacon', 'consts', 'util', 'model/core', 'model/util', 'model/diff', 'rz_api_backend', 'rz_api_mesh', 'history', 'rz_bus', 'rz_config'], +function (Bacon, consts, util, model_core, model_util, model_diff, rz_api_backend, rz_api_mesh, history, rz_bus, rz_config) { + +var debug = false; + +function Graph() { + + var nodes = [], + id_to_node_map = {}, + links = [], + diffBus = new Bacon.Bus(); + + this.diffBus = diffBus; + + /** + * add node if no previous node is present whose id equals that of the node being added + * + * @return node if node was actually added + */ + this.addNode = function(spec) { + var node = this.__addNode(spec); + if (node) { + return node; + } + } + + /** + * Inner implementation + * + * @param notify whether or not a presenter notification will be sent, default = true + */ + function __addNode(spec, notify, peer_notify) { + var existing_node, + node; + + notify = undefined === notify ? true : notify; + peer_notify = undefined === peer_notify ? true : peer_notify; + + if (undefined == spec.id) { + existing_node = findNodeByName(spec.name) + if (existing_node){ + return existing_node; + } else { + node = model_core.create_node__set_random_id(spec); + if (debug) { + if ('bubble' != node.type){ + console.log('__addNode: stamping node id: ' + node.id + ', name: \'' + node.name + '\' (bubble)'); + }else { + console.log('__addNode: stamping node id: ' + node.id + ', name: \'' + node.name + '\''); + } + } + } + } else { + node = model_core.create_node_from_spec(spec); + } + + existing_node = find_node__by_id(node.id); + if (existing_node) { + console.log('__addNode: id collision: existing-node.id: \'' + existing_node.id + '\', ' + 'new-node.id: \'' + node.id + '\''); + return existing_node; + } + + util.assert(undefined != node.id, '__addNode: node id missing'); + nodes.push(node); + id_to_node_map[node.id] = node; + console.log('__addNode: node added: id: ' + node.id); + + if (rz_config.backend_enabled && peer_notify){ + var topo_diff = model_diff.new_topo_diff({ + node_set_add : [node].map(model_util.adapt_format_write_node), + }); + var on_success = function(){ + // FIXME: handle possible outcomes: + // - id merge: node already exists -> update id + // - link-merge: node already exists -> merge links, recurse? + }; + var on_error = function(){ + // TODO: add problem emblem to node + }; + rz_api_backend.commit_diff__topo(topo_diff, on_success, on_error); + } + + if (notify) { + diffBus.push({nodes: {add: [node]}}); + } + + return node; + } + this.__addNode = __addNode; + + this._remove_node_set = function(ns, peer_notify) { + + peer_notify = undefined === peer_notify ? true : peer_notify; + + var cascade_link_rm_set = []; // track cascading link removals + for (var j = 0; j < ns.length; j++) { + var n = ns[j]; + var i = 0; + while (i < links.length) { + var link = links[i]; + if ((link['__src'].equals(n)) || (link['__dst'].equals(n))) { // compare by id + links.splice(i, 1); + cascade_link_rm_set.push(link); + } + else { + i++; + } + } + var index = findNodeIndex(n.id, n.state); + if (index !== undefined) { + nodes.splice(index, 1); + + util.assert(undefined != n.id, '_remove_node_set: node id missing'); + delete id_to_node_map[n.id]; + } + } + + cascade_link_rm_set.forEach(function(n){ + console.log('_remove_node_set: removed node: id: ' + n.id); + }); + + if (rz_config.backend_enabled && peer_notify){ + var topo_diff = model_diff.new_topo_diff({ + node_set_rm : ns.map(function(n){ return n.id; }), + link_set_rm : cascade_link_rm_set.map(function(l){ return l.id; }), + }); + var on_success = function(){ + // FIXME: handle possible outcomes: + // - rm cascade of connected links + }; + var on_error = function(){ + // TODO: add problem emblem to node + }; + rz_api_backend.commit_diff__topo(topo_diff, on_success, on_error); + } + + if (ns.length > 0) { + diffBus.push({nodes: {removed: ns.map(function(n) { return n.id; })}}); + } + } + + this.removeNode = function(id) { + var n = find_node__by_id(id); + this._remove_node_set([n]); + } + + this.removeNodes = function(n_filer) { + var ns = find_node_set_by_filer(n_filer); + this._remove_node_set(ns); + } + + /** + * + * getConnectedNodesAndLinks + * + * @id + * @state - defines the starting node (must have id and state) + * @d - depth defining connected component. If -1 returns the entire connected component. (can be the whole graph) + * + * NOTE: chainlinks are treated specially, they don't count for distance. So all their decendants will be added. + * + * NOTE: temp state nodes (n.state === 'temp') are ignored. + * + * @return - { + * 'node': [node] + * 'link': [link] + * } + * + * TODO: rewrite using efficient data structure. Right now iterates over everything + * TODO: implement for d !== 1 + * + */ + this.getConnectedNodesAndLinks = function(chosen_nodes, d) { + var ret = {'nodes':[], 'links':[]}; + + function addNode(node) { + if (chosen_nodes.filter(function (n) { return n.id == node.id; }).length == 1) { + return; + } + ret.nodes.push(node); + } + function same(n1, n2) { + // XXX: using name comparison because one of the nodes might be stale + return compareNames(n1.name, n2.name); + } + + if (chosen_nodes === undefined) { + console.log('getConnectedNodesAndLinks: bug: called with undefined node'); + return; + } + if (d !== 1) { + console.log('getConnectedNodesAndLinks: bug: not implemented for d == ' + d); + } + d = d || 1; + + if (chosen_nodes.length === undefined) { + console.log('getConnectedNodesAndLinks: expected array'); + } + + links.forEach(function(link) { + chosen_nodes.forEach(function (n) { + var adjacentnode; + if (same(link.__src, n)) { + adjacentnode = find_node__by_id(link.__dst.id); + if (adjacentnode.state !== "temp") { + addNode({type: 'exit', node: adjacentnode}); + } + ret.links.push({type: 'exit', link: link}); + if (link.__dst.type === "chainlink") { + links.forEach(function(link2) { + if (link.__dst.id === link2.__dst.id && + link2.__dst.type === "chainlink" && + link2.__dst.state !== "temp") { + adjacentnode = find_node__by_id(link2.__src.id); + if (adjacentnode.state !== "temp") { + addNode({type: 'enter', node: adjacentnode}); + } + ret.links.push({type: 'enter', link: link2}); + } + }); + } + } + if (same(link.__dst, n)) { + adjacentnode = find_node__by_id(link.__src.id); + if (adjacentnode.state !== "temp") { + addNode({type: 'enter', node: adjacentnode}); + } + ret.links.push({type: 'enter', link: link}); + } + }); + }); + return ret; + } + + /* compareSubset: + * state: one of the optional states that defines a subgraph + * new_nodes: array of objects with name + * new_links: array of length two arrays [source_name, target_name] + * returns: true if current and new graph are homomorphic up to + * a single node id change. false otherwise + */ + this.compareSubset = function(state, new_nodes, new_links) { + // Note: the nodes include a state=='temp', type=='bubble' node + // but it's ok since it exists both in new_nodes and in state_nodes + var state_nodes = findNodes(null, state).filter(function (nd) { + return nd.type !== 'bubble'; + }); + var state_links = findLinks(state).map(function(link) { + return [link.__src.name, link.__dst.name]; + }).sort(); + var k; + var state_source, state_target, new_source, new_target; + var changed_nodes; + var verbose = false; // XXX should be global. + var set_old_name, set_new_name; + + new_nodes.map(function (f) { + if (!f.name) { + console.log('missing name on node. node follows'); + console.log(f); + } + }); + new_nodes.sort(); + new_links.sort(); + if (new_nodes.length != state_nodes.length || new_links.length != state_links.length) { + if (verbose) { + console.log('not same size: new/old ' + new_nodes.length + ' / ' + state_nodes.length + '; ' + + new_links.length + ' / ' + state_links.length); + } + return {graph_same: false}; + } + changed_nodes = util.set_diff(util.set_from_array(state_nodes.map(function(d) { return d.name; })), + util.set_from_array(new_nodes.map(function (f) { return f.name; }))); + // we allow any number of changed nodes as long as we it is 1 or 2 :) + if (changed_nodes.a_b.length > 2) { + if (verbose) { + console.log('changed too many nodes'); + console.log(changed_nodes); + } + return {graph_same: false}; + } + set_old_name = util.set_from_array(changed_nodes.a_b); + set_new_name = util.set_from_array(changed_nodes.b_a); + for (k = 0 ; k < state_links.length ; ++k) { + state_source = state_links[k][0]; + state_target = state_links[k][1]; + new_source = new_links[k][0]; + new_target = new_links[k][1]; + if ((state_source !== new_source && + !(state_source in set_old_name && new_source in set_new_name)) + || + (state_target !== new_target && + !(state_target in set_old_name && new_target in set_new_name))) { + if (verbose) { + console.log('not same link: ' + + state_source + '->' + state_target + ' != ' + + new_source + '->' + new_target); + console.log('state_source === new_source: ' + String(state_source === new_source)); + console.log('state_target === new_target: ' + String(state_target === new_target)); + console.log(set_old_name); + console.log(set_new_name); + } + return {graph_same: false}; + } + } + return {graph_same: true, old_name: changed_nodes.a_b, new_name: changed_nodes.b_a}; + } + + this.addLinkByName = function(src_name, dst_name, name, state, drop_conjugator_links) { + + var src = findNodeByName(src_name), + dst = findNodeByName(dst_name), + src_id = src ? src.id : null, + dst_id = dst ? dst.id : null; + + if (src_id === null || dst_id === null) { + console.log('error: link of missing nodes: ' + src_name + ' (' + src_id + ') -> ' + + dst_name + ' (' + dst_id + ')'); + return; + } + + var link = model_core.create_link__set_random_id(src, dst, { name: name, + state: state }); + this.addLink(link); + } + + function addLink(link, peer_notify) { + + util.assert(link instanceof model_core.Link); + + peer_notify = undefined === peer_notify ? true : peer_notify; + + var existing_link = findLink(link.__src.id, link.__dst.id, link.name); + + if (undefined == existing_link) { + + links.push(link); + + if (rz_config.backend_enabled && peer_notify){ + var topo_diff = model_diff.new_topo_diff({ + link_set_add : [link].map(model_util.adapt_format_write_link), + }); + var on_success = function(){ + // FIXME: handle possible outcomes: + // - id merge: link already exists -> update id + // - attr-merge: link already exists -> merge attrs + }; + var on_error = function(){ + // TODO: add problem emblem to node + }; + rz_api_backend.commit_diff__topo(topo_diff, on_success, on_error); + } + + diffBus.push({links: {add: [link]}}); + } else { + existing_link.name = link.name; + existing_link.state = link.state; + } + } + this.addLink = addLink; + + this.editLink = function(src_id, dst_id, newname, newstate) { + var link = findLink(src_id, dst_id, newname); + + if (link === undefined) { + return; + } + link.name = newname; + if (newstate !== undefined) { + link.state = newstate; + } + rz_bus.names.push([newname]); + } + + this.editLinkTarget = function(src_id, dst_id, new_dst_id) { + var link = findLink(src_id, dst_id, null); + if (link !== undefined) { + link.__dst = find_node__by_id(new_dst_id); + + } else { + + } + } + + this.update_node = function(node, new_node_spec, on_success, on_error) { + util.assert(node instanceof model_core.Node); + + if (rz_config.backend_enabled){ + + if (node.name != new_node_spec.name){ + /* + * handle name update collision: suggest removal first + */ + var n_eq_name = findNodeByName(new_node_spec.name); + if (undefined != n_eq_name) { + // delete colliding node on rename + console.warn('update_node: name collision blocked due to node rename'); + undefined != on_error && on_error(); + return; + } + + node['name'] = new_node_spec['name']; // [!] may still fail due to server NAK + } + + var attr_diff = model_diff.new_attr_diff(); + for (var key in new_node_spec){ + attr_diff.add_node_attr_write(node.id, key, new_node_spec[key]); + } + + var on_ajax_success = function(id_to_node_map){ + var node_id = node.id; // original node id + if (id_to_node_map[node_id].id != node_id){ + // TODO: handle incoming ID update + util.assert(false, 'update_node: id attr change'); + } + + var ret_node = id_to_node_map[node_id]; + for (var key in ret_node){ + if ('name' == key || 'id' == key){ + continue; + } + node[key] = ret_node[key]; + } + + // TODO: handle NAK: add problem emblem to node + on_success(); + }; + + var on_ajax_error = function(){ + }; + + rz_api_backend.commit_diff__attr(attr_diff, on_ajax_success, on_ajax_error); + } + } + + this.editNameByName = function(old_name, new_name) { + var node = findNodeByName(old_name); + + if (node === undefined) { + console.log('editNameByName: error: cannot find node with name ' + old_name); + return; + } + return this.editName(node.id, new_name); // TODO: introduce Node class (yes Amir, I'm now down with that). + } + + this.editName = function(id, new_name) { + var n_eq_name = findNodeByName(new_name); + var n_eq_id = find_node__by_id(id); + var acceptReplace=true; + + if (n_eq_id === undefined) { + return; + } + if (n_eq_id.name == new_name) { + return; + } + if (n_eq_name !== undefined && n_eq_id.state !== 'temp' && !compareNames(n_eq_id.name, new_name)) { + acceptReplace = confirm('"' + n_eq_name.name + '" will replace "' + n_eq_id.name + '", are you sure?'); + if (acceptReplace){ + for (var i = 0; i < links.length; i++) { + if (links[i].__src === n_eq_id) { + links[i].__src = n_eq_name; + } + if (links[i].__dst === n_eq_id) { + links[i].__dst = n_eq_name; + } + } + this.removeNode(n_eq_id.id); + } + } else { + n_eq_id.name = new_name; + } + } + + this.editDates = function(id, state, start, end) { + var n = find_node__by_id(id); + if (state != n.state){ + return; + } + if ((n !== undefined)) { + n.start = start; + n.end = end; + } + } + + /** + * editType: + * + * @return true if type changed + */ + this.editType = function(id, state, newtype) { + return this._editProperty(id, state, 'type', newtype); + } + + this.editURL = function(id, state, url) { + return this._editProperty(id, state, 'url', url); + } + + this._editProperty = function(id, state, prop, value) { + var n = find_node__by_id(id); + if (state != n.state){ + return false; + } + + if ((n === undefined)) { + return false; + } + n[prop] = value; + return true; + } + + this.editStatus = function(id, state, status) { + return this._editProperty(id, state, 'status', status); + } + + this.editState = function(id, state, newstate) { + return this._editProperty(id, state, 'state', newstate); + } + + this.findCoordinates = function(id) { + var n = find_node__by_id(id); + if ((index !== undefined)) { + $('.typeselection').css('top', n.y - 90); + $('.typeselection').css('left', n.x - 230); + } + } + + this.removeLink = function(link) { + var i; + + for (i = 0 ; i < links.length; ++i) { + if (link.id !== undefined) { + if (link.id === links[i].id) { + links.splice(i, 1); + return; + } + } else { + if (link.__src.id === links[i].__src.id && link.__dst.id === links[i].__dst.id) { + links.splice(i, 1); + return; + } + } + } + console.log('bug: attempt to remove non existant link'); + } + + this.removeLinks = function(state) { + var id = null; + var ls = findLinks(state); + for (var j = 0; j < ls.length; j++) { + var l = ls[j]; + var i = 0; + while (i < links.length) { + if (links[i] === l) links.splice(i, 1); + else i++; + } + } + } + + var findLink = function(src_id, dst_id, name) { + for (var i = 0; i < links.length; i++) { + if (links[i].__src.id === src_id && links[i].__dst.id === dst_id) { + return links[i]; + } + } + } + + var findLinks = function(state) { + var foundLinks = []; + for (var i = 0; i < links.length; i++) { + if (links[i].state == state) { + foundLinks.push(links[i]); + } + } + return foundLinks; + } + + var compareNames = function(name1, name2) { + return name1.toLowerCase() === name2.toLowerCase(); + }; + + var hasNodeByName = function(name, state) { + return nodes.filter(function (n) { + return compareNames(n.name, name) && n.state === state; + }).length > 0; + } + this.hasNodeByName = hasNodeByName; + + var hasNodeByNameAndNotState = function(name, state) { + return nodes.filter(function(n) { + return compareNames(n.name, name) && n.state !== state; + }).length > 0; + } + this.hasNodeByNameAndNotState = hasNodeByNameAndNotState; + + var hasNode = function(id, state) { + var i; + + for (i = 0 ; i < nodes.length; ++i) { + if (nodes[i].id === id && nodes[i].state === state) { + return true; + } + } + return false; + } + this.hasNode = hasNode; + + /** + * return node whose id matches the given id or undefined if no node was found + */ + var find_node__by_id = function(id) { + return id_to_node_map[id]; + } + + /** + * @param filer: must return true in order for node to be included in the returned set + */ + var find_node_set_by_filer = function(filter) { + var ret = []; + nodes.map(function(n){ + if (true == filter(n)){ + ret.push(n); + } + }); + return ret; + } + + var findNodeByName = function(name) { + for (var i = 0 ; i < nodes.length ; ++i) { + if (compareNames(nodes[i].name, name)) { + return nodes[i]; + } + } + } + + var findNodes = function(id, state) { + // id=id.toLowerCase(); + var foundNodes = []; + for (var i = 0; i < nodes.length; i++) { + if ((id && nodes[i].id === id) || (state && nodes[i].state === state)) + foundNodes.push(nodes[i]); + } + return foundNodes; + } + + var findNodeIndex = function(id, state) { + for (var i = 0; i < nodes.length; i++) { + if ((id && nodes[i].id === id) || (state && nodes[i].state === state)) + return i; + }; + } + + function clear() { + nodes.length = 0; + links.length = 0; + } + this.clear = clear; + + function empty() { + return nodes.length == 0 && links.length == 0; + } + this.empty = empty; + + // @ajax-trans + this.commit_diff_set = function (diff_set) { + + function on_success(data){ + console.log('commit_diff_set:on_success: TODO impl'); + } + + rz_api_mesh.broadcast_possible_next_diff_block(diff_set); + } + + /** + * perform initial DB load from backend + * + * @param on_success: should be used by MVP presentors to trigger UI update + */ + // @ajax-trans + function load_from_backend(on_success) { + + function on_success__ajax(data){ + var n_set = []; // added node set + var l_set = []; // added link set + var len; + + data['node_set'].map(function(n_spec) { + n_spec = model_util.adapt_format_read_node(n_spec); + + util.assert(undefined != n_spec.id, 'load_from_backend: n_spec missing id'); + + var n = __addNode(n_spec, false, false); + n_set.push(n); + }); + + data['link_set'].map(function(l_spec){ + var l_ptr = model_util.adapt_format_read_link_ptr(l_spec); + + util.assert(undefined != l_ptr.id, 'load_from_backend: l_ptr missing id'); + + // resolve link ptr + var src = find_node__by_id(l_ptr.__src_id), + dst = find_node__by_id(l_ptr.__dst_id); + + // cleanup & reuse as link_spec + delete l_ptr.__src_id; + delete l_ptr.__dst_id; + var link_spec = l_ptr; + var link = model_core.create_link_from_spec(src, dst, link_spec); + var l = addLink(link, false); + l_set.push(l); + }); + + undefined != on_success && on_success() + } + + rz_api_backend.clone(0, on_success__ajax); + } + this.load_from_backend = load_from_backend; + + this.load_from_json = function(json) { + var data = JSON.parse(json), + added_names, + that = this; + + clear(); + if (data == null) { + console.log('load callback: no data to load'); + return; + } + added_names = data.nodes.map(function(node) { + return that.__addNode({id:node.id, name:node.name ? node.name : node.id, + type:node.type,state:"perm", + start:new Date(node.start), + end:new Date(node.end), + status:node.status, + url:node.url, + x: node.x, + y: node.y, + }, false, false).name; + }); + data.links.forEach(function(link) { + that.addLink(link.__src, link.__dst, link.name, "perm"); + }); + this.clear_history(); + rz_bus.names.push(added_names); + } + + this.save_to_json = function() { + var d = {"nodes":[], "links":[]}; + for(var i = 0 ; i < nodes.length ; i++){ + var node = nodes[i]; + d['nodes'].push({ + "id": node.id, + "name": node.name, + "type":node.type, + "state":"perm", + "start":node.start, + "end":node.end, + "status": node.status, + "url": node.url, + "x": node.x, + "y": node.y, + }); + } + for(var j=0 ; j < links.length ; j++){ + var link = links[j]; + d['links'].push({ + "__src":link.__src.id, + "__dst":link.__dst.id, + "name":link.name + }); + } + return JSON.stringify(d); + } + + this.set_user = function(user) { + var elem = $('svg g.zoom')[0]; + this.user = user; + this.history = new history.History(this.user, this, elem); + } + + function clear_history() { + if (this.history !== undefined) { + this.history.clear(); + } + } + + this.clear_history = clear_history; + + var get_nodes = function() { + return nodes; + }; + this.nodes = get_nodes; + + var get_links = function() { return links; }; + this.links = get_links; + + function setRegularState() { + var x, node, link, s; + + for (x in nodes) { + node = nodes[x]; + s = node.state; + if (s === 'chosen' || s === 'enter' || s === 'exit') { + node.state = 'perm'; + } + } + for (x in links) { + link = links[x]; + s = link.state; + if (s === 'chosen' || s === 'enter' || s === 'exit') { + link.state = 'perm'; + } + } + } + this.setRegularState = setRegularState; + + this.findByVisitors = function(node_visitor, link_visitor) { + var n_length = nodes.length, + l_length = links.length, + selected = [], + i, + node, + link, + state; + + if (!node_visitor) { + return; + } + + for (i = 0 ; i < n_length; ++i) { + node = nodes[i]; + if (node.state == 'temp') { + continue; + } + if (node_visitor(node)) { + selected.push(node); + } + } + return selected; + } + + function markRelated(names) { + removeRelated(); + nodes.forEach(function (node) { + names.forEach(function (name) { + if (compareNames(node.name, name) && node.state != 'temp') { + node.state = 'related'; + } + }); + }); + } + this.markRelated = markRelated; + + function removeRelated() { + nodes.forEach(function (node) { + if (node.state == 'related') { + node.state = 'perm'; + } + }); + } + this.removeRelated = removeRelated; + +} + +return { + Graph: Graph, +}; + +}); |
