flow-job.js

/*
 * Copyright 2012 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.
 */

azkaban.JobListView = Backbone.View.extend({
	events: {
		"keyup input": "filterJobs",
		"click .job": "handleJobClick",
		"click .resetPanZoomBtn": "handleResetPanZoom",
		"contextmenu li": "handleContextMenuClick"
	},
	
	initialize: function(settings) {
		this.model.bind('change:selected', this.handleSelectionChange, this);
		this.model.bind('change:disabled', this.handleDisabledChange, this);
		this.model.bind('change:graph', this.render, this);
		this.model.bind('change:update', this.handleStatusUpdate, this);
		
		this.filterInput = $(this.el).find("#filter");
		this.list = $(this.el).find("#list");
		this.contextMenu = settings.contextMenuCallback;
		this.listNodes = {};
	},
	
	filterJobs: function(self) {
		var filter = this.filterInput.val();
		if (filter && filter.trim() != "") {
			filter = filter.trim();
			if (filter == "") {
				if (this.filter) {
					this.jobs.children().each(function(){
						var a = $(this).find("a");
						$(a).html(this.jobid);
						$(this).show();
					});
				}
				this.filter = null;
				return;
			}
		}
		else {
			if (this.filter) {
				this.jobs.children().each(function(){
					var a = $(this).find("a");
					$(a).html(this.jobid);
					$(this).show();
				});
			}
				
			this.filter = null;
			return;
		}
		
		this.jobs.children().each(function() {
			var jobid = this.jobid;
			var index = jobid.indexOf(filter);
			if (index != -1) {
				var a = $(this).find("a");
				var endIndex = index + filter.length;
				var newHTML = jobid.substring(0, index) + "<span>" + 
						jobid.substring(index, endIndex) + "</span>" + 
						jobid.substring(endIndex, jobid.length);
				
				$(a).html(newHTML);
				$(this).show();
			}
			else {
				$(this).hide();
			}
		});
			
		this.filter = filter;
	},
	
	handleStatusUpdate: function(evt) {
		var updateData = this.model.get("update");
		if (updateData.nodes) {
			for (var i = 0; i < updateData.nodes.length; ++i) {
				var updateNode = updateData.nodes[i];
				var job = this.listNodes[updateNode.id];
				$(job).removeClass();
				$(job).addClass("list-group-item");
				$(job).addClass(updateNode.status);
			}
		}
	},
	
	assignInitialStatus: function(evt) {
		var data = this.model.get("data");
		for (var i = 0; i < data.nodes.length; ++i) {
			var updateNode = data.nodes[i];
			var job = this.listNodes[updateNode.id];
      if (!$(job).hasClass("list-group-item")) {
        $(job).addClass("list-group-item");
      }
			$(job).addClass(updateNode.status);
		}
	},
	
	render: function(self) {
		var data = this.model.get("data");
		var nodes = data.nodes;
		var edges = data.edges;
		
		this.listNodes = {}; 
		if (nodes.length == 0) {
			console.log("No results");
			return;
		};
	
		var nodeArray = nodes.slice(0);
		nodeArray.sort(function(a, b) {
			var diff = a.y - b.y;
			if (diff == 0) {
				return a.x - b.x;
			}
			else {
				return diff;
			}
		});
		
		var list = this.list;
		this.jobs = $(list);
		for (var i = 0; i < nodeArray.length; ++i) {
			var a = document.createElement("a");
			$(a).addClass('list-group-item').addClass('job');
      $(a).attr('href', '#');
      
      var iconDiv = document.createElement('div');
      $(iconDiv).addClass('icon');
      $(a).append(iconDiv);
			$(a).append(nodeArray[i].id);
			$(list).append(a);
			a.jobid = nodeArray[i].id;
			this.listNodes[nodeArray[i].id] = a;
		}
		
		this.assignInitialStatus(self);
		this.handleDisabledChange(self);
	},
	
	handleContextMenuClick: function(evt) {
		if (this.contextMenu) {
			this.contextMenu(evt);
			return false;
		}
	},
	
	handleJobClick: function(evt) {
		var jobid = evt.currentTarget.jobid;
		if (!evt.currentTarget.jobid) {
			return;
		}
		
		if (this.model.has("selected")) {
			var selected = this.model.get("selected");
			if (selected == jobid) {
				this.model.unset("selected");
			}
			else {
				this.model.set({"selected": jobid});
			}
		}
		else {
			this.model.set({"selected": jobid});
		}
	},
	
	handleDisabledChange: function(evt) {
		var disabledMap = this.model.get("disabled");
		var nodes = this.model.get("nodes");
		
		for(var id in nodes) {
			if (disabledMap[id]) {
				$(this.listNodes[id]).addClass("nodedisabled");
			}
			else {
				$(this.listNodes[id]).removeClass("nodedisabled");
			}
		}
	},
	
	handleSelectionChange: function(evt) {
		if (!this.model.hasChanged("selected")) {
			return;
		}
		
		var previous = this.model.previous("selected");
		var current = this.model.get("selected");
		
		if (previous) {
			$(this.listNodes[previous]).removeClass("active");
		}
		
		if (current) {
			$(this.listNodes[current]).addClass("active");
		}
	},
	
	handleResetPanZoom: function(evt) {
		this.model.trigger("resetPanZoom");
	}
});