"use strict" define(['signal', 'consts', 'util', 'textanalysis', 'model/core', 'model/util', 'rz_api_backend', 'rz_api_mesh'], function (signal, consts, util, textanalysis, model_core, model_util, rz_api_backend, rz_api_mesh) { function Graph() { var nodes = [], links = []; /** * 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(node) { if (this.__addNode(node)) { return node; } } /** * Inner implementation * * @param notify whether or not a presenter notification will be sent, default = true */ this.__addNode = function(node, notify) { var existing_node; if (undefined == node.id) { existing_node = findNodeByName(node.name) if (existing_node){ // FIXME handle node-with-equal-name case console.debug('__addNode: name collision: existing-node.name: \'' + existing_node.name + '\'' + 'new-node.name: \'' + node.name + '\''); return; }else{ node = model_core.create_node__set_random_id(node); // TODO clean if ('bubble' == node.type){ console.debug('__addNode: stamping node id: ' + node.id + ', name: \'' + node.name + '\' (bubble)'); }else { console.debug('__addNode: stamping node id: ' + node.id + ', name: \'' + node.name + '\''); } } } existing_node = findNode(node.id, null); if (existing_node){ console.debug('__addNode: id collision: existing-node.id: \'' + existing_node.id + '\'' + 'new-node.id: \'' + node.id + '\''); return; } undefined === notify && (notify = true); // notify by default nodes.push(node); if (undefined == notify){ signal.signal(consts.APPLIED_GRAPH_DIFF, [{nodes: {add: [node]}}]); } return node; } this.removeNode = function(id, state) { var i = 0; var n = findNode(id, state); while (i < links.length) { if ((links[i]['__src'] === n) || (links[i]['__dst'] == n)) links.splice(i, 1); else i++; } var index = findNodeIndex(id, state); if (index !== undefined) { nodes.splice(index, 1); } signal.signal(consts.APPLIED_GRAPH_DIFF, [{nodes: {removed: [id]}}]); } this.removeNodes = function(state) { var id = null; var ns = findNodes(null, state); for (var j = 0; j < ns.length; j++) { var n = ns[j]; var i = 0; while (i < links.length) { if ((links[i]['__src'] === n) || (links[i]['__dst'] == n)) links.splice(i, 1); else i++; } var index = findNodeIndex(id, state); if (index !== undefined) { nodes.splice(index, 1); } } if (ns.length > 0) { signal.signal(consts.APPLIED_GRAPH_DIFF, [{nodes: {removed: ns.map(function(n) { return n.id; })}}]); } } /** * * 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(n, d) { var i = 0, j = 0, adjacentnode, link, link2, ret = {'nodes':[], 'links':[]}; $(".debug").html(n.state); if (n === 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; while (i < links.length) { link = links[i]; // XXX: using name comparison because n might be stale if (compareNames(link.__src.name, n.name)) { adjacentnode = findNode(link.__dst.id, null); if (adjacentnode.state !== "temp") { ret.nodes.push({type: 'exit', node: adjacentnode}); } ret.links.push({type: 'exit', link: link}); if (link.__dst.type === "chainlink") { while (j < links.length) { link2 = links[j]; if (link.__dst.id === link2.__dst.id && link2.__dst.type === "chainlink" && link2.__dst.state !== "temp") { adjacentnode = findNode(link2.__src.id, null); if (adjacentnode.state !== "temp") { ret.nodes.push({type: 'enter', node: adjacentnode}); } ret.links.push({type: 'enter', link: link2}); } j++; } } j=0; } if (compareNames(links[i].__dst.name, n.name)) { adjacentnode = findNode(links[i].__src.id, null); if (adjacentnode.state !== "temp") adjacentnode.state = "enter"; links[i].state = "enter"; } i++; } 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, null), dst = findNodeByName(dst_name, null), 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; } this.addLink(src_id, dst_id, name, state, drop_conjugator_links); } this.addLink = function(src_id, dst_id, name, state, drop_conjugator_links) { var src = findNode(src_id, null); var dst = findNode(dst_id, null); var found = findLink(src_id,dst_id,name); if (drop_conjugator_links && name && (name.replace(/ /g,"") === "and")) { state = "temp"; } if (undefined === src || undefined === dst) { console.log('addLink: undefined src / dst'); return; } if (!found) { var link = model_core.create_link__set_random_id(src, dst, { name: name, state: state }); links.push(link); signal.signal(consts.APPLIED_GRAPH_DIFF, [{links: {add: [link]}}]); } else { found.name = name; found.state = state; } } this.editLink = function(src_id, dst_id, newname, newstate) { var link = findLink(src_id, dst_id, newname); if (link !== undefined) { link.name = newname; if (newstate !== undefined) { link.state = newstate; } } } this.editLinkTarget = function(src_id, dst_id, newTarget) { var link = findLink(src_id, dst_id, null); if (link !== undefined) { link.__dst = findNode(newTarget, null); } else { } } this.editNameByName = function(old_name, new_name) { var node = findNodeByName(old_name, null); 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 index2 = findNodeByName(new_name, null); var index = findNode(id, null); var acceptReplace=true; if ((index !== undefined)) { if (index2 !== undefined) { acceptReplace = confirm('"' + index2.name + '" will replace "' + index.name + '", are you sure?'); if (acceptReplace){ for (var i = 0; i < links.length; i++) { if (links[i].__src === index) { links[i].__src = index2; } if (links[i].__dst === index) { links[i].__dst = index2; } } this.removeNode(index.id,null); } } else { index.name = new_name; } } } this.editDates = function(id, type, start, end) { var index = findNode(id, type); if ((index !== undefined)) { index.start = start; index.end = end; } } /** * editType: * * @return true if type changed */ this.editType = function(id, state, newtype) { var index = findNode(id, state); if ((index !== undefined)) { index.type = newtype; } } this.editURL = function(id, state, url) { var index = findNode(id, state); if ((index === undefined)) return; index.url = url; } this.editState = function(id, state, newstate) { var index = findNode(id, state); if ((index !== undefined)) { index.state = newstate; } } this.findCoordinates = function(id, type) { var index = findNode(id, type); if ((index !== undefined)) { $('.typeselection').css('top', index.y - 90); $('.typeselection').css('left', index.x - 230); } } this.removeLink = function(link) { var link, 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) { var i; for (i = 0 ; i < nodes.length; ++i) { if (compareNames(nodes[i].name, name) && nodes[i].state === state) { return true; } } return false; } this.hasNodeByName = hasNodeByName; 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; var findNode = function(id, state) { for (var i = 0; i < nodes.length; i++) { if (nodes[i].id === id || nodes[i].state === state) return nodes[i]; }; } var findNodeByName = function(name, state) { if (undefined == state){ state = null; } for (var i = 0 ; i < nodes.length ; ++i) { if (compareNames(nodes[i].name, name) || nodes[i].state === state) { 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){ // TODO impl } rz_api_mesh.broadcast_possible_next_diff_block(diff_set); } /** * perform initial DB load from backend */ // @ajax-trans function load_from_backend() { function on_success(data){ var n_set = []; var l_set = []; var len; len = data['node_set'].length; for (var i = 0; i < len; i++) { var n_raw = data['node_set'][i]; var n = model_util.adapt_format_read_node(n_raw); n_set.push(n); } len = data['link_set'].length; for (var i = 0; i < len; i++) { var l_raw = data['link_set'][i]; var l = model_util.adapt_format_read_link(l_raw); l_set.push(l); } len = n_set.length for (var i = 0; i < len; i++) { var n = n_set[i]; graph.addNode(n.id, n.type, n.state) } len = l_set.length for (var i = 0; i < len; i++) { var l = l_set[i]; graph.addLink_byIds(l.__src.id, l.__dst.id, l.name, "perm") } } rz_api_backend.clone(0, on_success); } this.load_from_json = function(json) { var data = JSON.parse(json); var i, node, link; clear(); if (data == null) { console.log('load callback: no data to load'); return; } for(i = 0; i < data["nodes"].length; i++){ node = data.nodes[i]; this.__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); textanalysis.autoSuggestAddName(node.name.toLowerCase()); } for(i = 0; i < data["links"].length; i++){ link = data.links[i]; this.addLink(link.__src, link.__dst, link.name, "perm"); } this.clear_history(); } 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) { this.user = user; this.history = new History(this.user, $('svg g.zoom')[0]); console.log('new user: ' + user); } 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; } return { Graph: Graph, }; });