flow-loader.js

var statusStringMap = {
	"FAILED": "Failed",
	"SUCCEEDED": "Success",
	"FAILED_FINISHING": "Running w/Failure",
	"RUNNING": "Running",
	"WAITING": "Waiting",
	"KILLED": "Killed",
	"DISABLED": "Disabled",
	"READY": "Ready",
	"UNKNOWN": "Unknown",
	"QUEUED": "Queued",
	"SKIPPED": "Skipped"
};

var extendedViewPanels = {};
var extendedDataModels = {};
var openJobDisplayCallback = function(nodeId, flowId, evt) {
	console.log("Open up data");

	/*
	$("#flowInfoBase").before(cloneStuff);
	var requestURL = contextURL + "/manager";
	
	$.get(
      requestURL,
      {"project": projectName, "ajax":"fetchflownodedata", "flow":flowId, "node": nodeId},
      function(data) {
  		var graphModel = new azkaban.GraphModel();
  		graphModel.set({id: data.id, flow: data.flowData, type: data.type, props: data.props});

  		var flowData = data.flowData;
  		if (flowData) {
  			createModelFromAjaxCall(flowData, graphModel);
  		}
  		
  		var backboneView = new azkaban.FlowExtendedViewPanel({el:cloneStuff, model: graphModel});
  		extendedViewPanels[nodeInfoPanelID] = backboneView;
  		extendedDataModels[nodeInfoPanelID] = graphModel;
  		backboneView.showExtendedView(evt);
      },
      "json"
    );
    */
}

var createNewPanel = function(node, model, evt) {
	var parentPath = node.parentPath;
	
	var nodeInfoPanelID = parentPath ? parentPath + ":" + node.id + "-info" : node.id + "-info";
	var cloneStuff = $("#flowInfoBase").clone();
	cloneStuff.data = node;
	$(cloneStuff).attr("id", nodeInfoPanelID);
	$("#flowInfoBase").before(cloneStuff);
	
	var backboneView = new azkaban.FlowExtendedViewPanel({el:cloneStuff, model: model});
	node.panel = backboneView;
	backboneView.showExtendedView(evt);
}

/**
 * Processes the flow data from Javascript
 */
var processFlowData = function(data) {
	var nodes = {};
	var edges = new Array();

	//Create a node map
	for (var i=0; i < data.nodes.length; ++i) {
		var node = data.nodes[i];
		nodes[node.id] = node;
		if (!node.status) {
			node.status = "READY";
		}
	}

	// Create each node in and out nodes. Create an edge list.
	for (var i=0; i < data.nodes.length; ++i) {
		var node = data.nodes[i];
		if (node.in) {
			for (var j=0; j < node.in.length; ++j) {
				var fromNode = nodes[node.in[j]];
				if (!fromNode.outNodes) {
					fromNode.outNodes = {};
				}
				if (!node.inNodes) {
					node.inNodes = {};
				}
				
				fromNode.outNodes[node.id] = node;
				node.inNodes[fromNode.id] = fromNode;
				edges.push({to: node.id, from: fromNode.id});
			}
		}
	}

	// Iterate over the nodes again. Parse the data if they're embedded flow data.
	// Assign each nodes to the parent flow data.
	for (var key in nodes) {
		var node = nodes[key];
		node.parent = data;
		if (node.type == "flow") {
			processFlowData(node);
		}
	}
	
	// Assign the node map and the edge list
	data.nodeMap = nodes;
	data.edges = edges;
}

var closeAllSubDisplays = function() {
	$(".flowExtendedView").hide();
}

var nodeClickCallback = function(event, model, node) {
	console.log("Node clicked callback");

	var target = event.currentTarget;
	var type = node.type;
	var flowId = node.parent.flow;
	var jobId = node.id;
	
	var requestURL = contextURL + "/manager?project=" + projectName + "&flow=" + flowId + "&job=" + jobId;
	var menu = [];

	if (type == "flow") {
		var flowRequestURL = contextURL + "/manager?project=" + projectName + "&flow=" + node.flowId;
		if (node.expanded) {
			menu = [{title: "Collapse Flow...", callback: function() {model.trigger("collapseFlow", node);}}];
		}
		else {
			menu = [{title: "Expand Flow...", callback: function() {model.trigger("expandFlow", node);}}];
		}

		$.merge(menu, [
		//		{title: "View Properties...", callback: function() {openJobDisplayCallback(jobId, flowId, event)}},
				{break: 1},
				{title: "Open Flow...", callback: function() {window.location.href=flowRequestURL;}},
				{title: "Open Flow in New Window...", callback: function() {window.open(flowRequestURL);}},
				{break: 1},
				{title: "Open Properties...", callback: function() {window.location.href=requestURL;}},
				{title: "Open Properties in New Window...", callback: function() {window.open(requestURL);}},
				{break: 1},
				{title: "Center Flow", callback: function() {model.trigger("centerNode", node);}}
		]);
	}
	else {
		menu = [
		//		{title: "View Properties...", callback: function() {openJobDisplayCallback(jobId, flowId, event)}},
		//		{break: 1},
				{title: "Open Job...", callback: function() {window.location.href=requestURL;}},
				{title: "Open Job in New Window...", callback: function() {window.open(requestURL);}},
				{break: 1},
				{title: "Center Job", callback: function() {model.trigger("centerNode", node)}}
		];
	}
	contextMenuView.show(event, menu);
}

var jobClickCallback = function(event, model, node) {
	console.log("Node clicked callback");
	var target = event.currentTarget;
	var type = node.type;
	var flowId = node.parent.flow;
	var jobId = node.id;

	var requestURL = contextURL + "/manager?project=" + projectName + "&flow=" + flowId + "&job=" + node.id;

	var menu;
	if (type == "flow") {
		var flowRequestURL = contextURL + "/manager?project=" + projectName + "&flow=" + node.flowId;
		menu = [
		//		{title: "View Properties...", callback: function() {openJobDisplayCallback(jobId, flowId, event)}},
		//		{break: 1},
				{title: "Open Flow...", callback: function() {window.location.href=flowRequestURL;}},
				{title: "Open Flow in New Window...", callback: function() {window.open(flowRequestURL);}},
				{break: 1},
				{title: "Open Properties...", callback: function() {window.location.href=requestURL;}},
				{title: "Open Properties in New Window...", callback: function() {window.open(requestURL);}},
				{break: 1},
				{title: "Center Flow", callback: function() {model.trigger("centerNode", node)}}
		];
	}
	else {
		menu = [
		//		{title: "View Job...", callback: function() {openJobDisplayCallback(jobId, flowId, event)}},
		//		{break: 1},
				{title: "Open Job...", callback: function() {window.location.href=requestURL;}},
				{title: "Open Job in New Window...", callback: function() {window.open(requestURL);}},
				{break: 1},
				{title: "Center Job", callback: function() {graphModel.trigger("centerNode", node)}}
		];
	}
	contextMenuView.show(event, menu);
}

var edgeClickCallback = function(event, model) {
	console.log("Edge clicked callback");
}

var graphClickCallback = function(event, model) {
	console.log("Graph clicked callback");

	var jobId = event.currentTarget.jobid;
	var flowId = model.get("flowId");
	var requestURL = contextURL + "/manager?project=" + projectName + "&flow=" + flowId;

	var menu = [	
		{title: "Open Flow...", callback: function() {window.location.href=requestURL;}},
		{title: "Open Flow in New Window...", callback: function() {window.open(requestURL);}},
		{break: 1},
		{title: "Center Graph", callback: function() {model.trigger("resetPanZoom");}}
	];
	
	contextMenuView.show(event, menu);
}