web/ons-demo/js/model.js

/*global async, d3*/

function toD3(results) {
	var model = {
		edgeSwitches: [],
		aggregationSwitches: [],
		coreSwitches: [],
		flows: results.flows,
		controllers: results.controllers,
		links: results.links
	}

	// sort the switches
	results.switches.sort(function (a, b) {
		var aA = a.dpid.split(':');
		var bB = b.dpid.split(':');
		for (var i=0; i<aA.length; i+=1) {
			if (aA[i] != bB[i]) {
				return aA[i] - bB[i];
			}
		}
		return 0;
	});

	// identify switch types
	var coreSwitchDPIDs = {};
	results.configuration.core.forEach(function (dpid) {
		coreSwitchDPIDs[dpid] = true;
	});

	var aggregationSwitchDPIDs = {};
	results.configuration.aggregation.forEach(function (dpid) {
		aggregationSwitchDPIDs[dpid] = true;
	});

	results.switches.forEach(function (s) {
		s.controller = results.mapping[s.dpid][0].controllerId;

		if (coreSwitchDPIDs[s.dpid]) {
			model.coreSwitches.push(s);
		} else if (aggregationSwitchDPIDs[s.dpid]) {
			model.aggregationSwitches.push(s);
		} else {
			model.edgeSwitches.push(s);
		}
	});

	return model;
}

function updateModel(cb) {
	async.parallel({
	    links: function(cb) {
			d3.json('data/wm_core_topology_links_json.json', function (error, result) {
				cb(error, result);
			});
	    },
	    switches: function(cb) {
			d3.json('data/wm_core_topology_switches_all_json.json', function (error, result) {
				cb(error, result);
			});
	    },
	    flows: function(cb) {
			d3.json('data/wm_flow_getall_json.json', function (error, result) {
				cb(error, result);
			});
	    },
	    controllers: function(cb) {
			d3.json('data/wm_registry_controllers_json.json', function (error, result) {
				cb(error, result);
			});
	    },
	    mapping: function(cb) {
			d3.json('data/wm_registry_switches_json.json', function (error, result) {
				cb(error, result);
			});
	    },
	    configuration: function(cb) {
			d3.json('data/configuration.json', function (error, result) {
				cb(error, result);
			});
	    },
	},
	function(err, results) {
		var model = toD3(results);
		model.timestamp = new Date();
		cb(model);
	});
}