flow-loader.js

/*
 * Copyright 2014 LinkedIn Corp.
 * 
 * Licensed under the Apache License, Version 2.0 (the "License"); you may not
 * use this file except in compliance with the License. You may obtain a copy of
 * the License at
 * 
 * http://www.apache.org/licenses/LICENSE-2.0
 * 
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
 * WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
 * License for the specific language governing permissions and limitations under
 * the License.
 */

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);
}

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);
}