eagle-server/src/main/webapp/app/dev/public/js/ctrls/alertEditCtrl.js - eagle - Git at Google

 /*
  * Licensed to the Apache Software Foundation (ASF) under one
  * or more contributor license agreements.  See the NOTICE file
  * distributed with this work for additional information
  * regarding copyright ownership.  The ASF licenses this file
  * to you 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.
  */

 (function() {
 	'use strict';

 	var eagleControllers = angular.module('eagleControllers');

 	// ======================================================================================
 	// =                                    Policy Create                                   =
 	// ======================================================================================
 	function connectPolicyEditController(entity, args) {
 		var newArgs = [entity];
 		Array.prototype.push.apply(newArgs, args);
 		/* jshint validthis: true */
 		policyEditController.apply(this, newArgs);
 	}

 	eagleControllers.controller('policyCreateCtrl', function ($scope, $q, $wrapState, $timeout, PageConfig, Entity, Policy) {
 		PageConfig.title = "Define Policy";
 		connectPolicyEditController({}, arguments);
 	});
 	eagleControllers.controller('policyEditCtrl', function ($scope, $q, $wrapState, $timeout, PageConfig, Entity, Policy) {
 		PageConfig.title = "Edit Policy";
 		var args = arguments;

 		$scope.policyList = Entity.queryMetadata("policies/" + encodeURIComponent($wrapState.param.name));
 		$scope.policyList._promise.then(function () {
 			var policy = $scope.policyList[0];

 			if(policy) {
 				connectPolicyEditController(policy, args);
 			} else {
 				$.dialog({
 					title: "OPS",
 					content: "Policy '" + $wrapState.param.name + "' not found!"
 				}, function () {
 					$wrapState.go("policyList");
 				});
 			}
 		});
 	});

 	function policyEditController(policy, $scope, $q, $wrapState, $timeout, PageConfig, Entity, Policy) {
 		$scope.policy = policy;
 		$scope.policy = common.merge({
 			name: "",
 			description: "",
 			inputStreams: [],
 			outputStreams: [],
 			definition: {
 				type: "siddhi",
 				value: ""
 			},
 			alertDefinition: {
 				subject: "",
 				body: "",
 				severity: "WARNING",
 				category: "DEFAULT"
 			},
 			partitionSpec: [],
 			parallelismHint: 5
 		}, $scope.policy);
 		console.log("[Policy]", $scope.policy);

 		var cacheSearchType;
 		var cacheSearchSourceKey;
 		var searchApplications;

 		$scope.searchType = "app";
 		$scope.searchSourceKey = "";
 		$scope.applications = {};
 		$scope.newPolicy = !$scope.policy.name;
 		$scope.autoPolicyDescription = $scope.newPolicy && !$scope.policy.description;

 		PageConfig.navPath = [
 			{title: "Policy List", path: "/policies"},
 			{title: ($scope.newPolicy ? "Define" : "Update") + " Policy"}
 		];

 		// ==============================================================
 		// =                             UI                             =
 		// ==============================================================
 		$scope.sourceTab = "all";
 		$scope.setSourceTab = function (tab) {
 			$scope.sourceTab = tab;
 		};

 		// ==============================================================
 		// =                        Input Stream                        =
 		// ==============================================================
 		$scope.getSearchApplication = function() {
 			if(cacheSearchSourceKey !== $scope.searchSourceKey.toUpperCase() || cacheSearchType !== $scope.searchType) {
 				var match = false;
 				cacheSearchSourceKey = $scope.searchSourceKey.toUpperCase();
 				cacheSearchType = $scope.searchType;

 				searchApplications = {};
 				$.each($scope.applications, function (appName, streams) {
 					$.each(streams, function (i, stream) {
 						var groupName = cacheSearchType === "app" ? stream.dataSource : stream.siteId;
 						if(
 							groupName.toUpperCase().indexOf(cacheSearchSourceKey) >= 0 ||
 							stream.streamId.toUpperCase().indexOf(cacheSearchSourceKey) >= 0
 						) {
 							match = true;
 							var group = searchApplications[groupName] = searchApplications[groupName] || [];
 							group.push(stream);
 						}
 					});
 				});

 				if(!match) {
 					searchApplications = null;
 				}
 			}
 			return searchApplications;
 		};

 		$scope.streams = {};
 		$scope.streamList = Entity.queryMetadata("streams");
 		$scope.streamList._then(function () {
 			$scope.applications = {};
 			cacheSearchSourceKey = null;

 			$.each($scope.streamList, function (i, stream) {
 				var list = $scope.applications[stream.dataSource] = $scope.applications[stream.dataSource] || [];
 				list.push(stream);
 				$scope.streams[stream.streamId] = stream;
 			});
 		});

 		$scope.isInputStreamSelected = function (streamId) {
 			return $.inArray(streamId, $scope.policy.inputStreams) >= 0;
 		};

 		/*$scope.checkInputStream = function (streamId) {
 			if($scope.isInputStreamSelected(streamId)) {
 				$scope.policy.inputStreams = common.array.remove(streamId, $scope.policy.inputStreams);
 			} else {
 				$scope.policy.inputStreams.push(streamId);
 			}
 		};*/

 		// ==============================================================
 		// =                         Definition                         =
 		// ==============================================================
 		function autoDescription() {
 			if(!$scope.autoPolicyDescription) return;

 			$scope.policy.description = "Policy for " + $scope.policy.outputStreams.join(", ");
 		}

 		var checkPromise;
 		$scope.definitionMessage = "";
 		$scope.checkDefinition = function () {
 			$timeout.cancel(checkPromise);
 			checkPromise = $timeout(function () {
 				Entity.post("metadata/policies/parse", $scope.policy.definition.value)._then(function (res) {
 					var data = res.data;
 					console.log(data);
 					if(data.success) {
 						$scope.definitionMessage = "";
 						if(data.policyExecutionPlan) {
 							// Input streams
 							$scope.policy.inputStreams = $.map(data.policyExecutionPlan.inputStreams, function (value, stream) {
 								return stream;
 							});

 							// Output streams
 							var outputStreams= $.map(data.policyExecutionPlan.outputStreams, function (value, stream) {
 								return stream;
 							});
 							$scope.policy.outputStreams = outputStreams.concat();
 							$scope.outputStreams = outputStreams;
 							autoDescription();

 							// Partition
 							$scope.policy.partitionSpec = data.policyExecutionPlan.streamPartitions;
 						}
 					} else {
 						$scope.definitionMessage = data.message;
 					}
 				});
 			}, 350);
 		};

 		// ==============================================================
 		// =                        Output Stream                       =
 		// ==============================================================
 		$scope.outputStreams = ($scope.policy.outputStreams || []).concat();

 		$scope.isOutputStreamSelected = function (streamId) {
 			return $.inArray(streamId, $scope.policy.outputStreams) >= 0;
 		};

 		$scope.checkOutputStream = function (streamId) {
 			if($scope.isOutputStreamSelected(streamId)) {
 				$scope.policy.outputStreams = common.array.remove(streamId, $scope.policy.outputStreams);
 			} else {
 				$scope.policy.outputStreams.push(streamId);
 			}
 			autoDescription();
 		};

 		// ==============================================================
 		// =                         Partition                          =
 		// ==============================================================
 		$scope.partition = {};

 		$scope.addPartition = function () {
 			$scope.partition = {
 				streamId: $scope.policy.inputStreams[0],
 				type: "GROUPBY",
 				columns: []
 			};
 			$(".modal[data-id='partitionMDL']").modal();
 		};

 		$scope.newPartitionCheckColumn = function (column) {
 			return $.inArray(column, $scope.partition.columns) >= 0;
 		};

 		$scope.newPartitionClickColumn = function (column) {
 			if($scope.newPartitionCheckColumn(column)) {
 				$scope.partition.columns = common.array.remove(column, $scope.partition.columns);
 			} else {
 				$scope.partition.columns.push(column);
 			}
 		};

 		$scope.addPartitionConfirm = function () {
 			$scope.policy.partitionSpec.push($scope.partition);
 		};

 		$scope.removePartition = function (partition) {
 			$scope.policy.partitionSpec = common.array.remove(partition, $scope.policy.partitionSpec);
 		};

 		// ==============================================================
 		// =                         Publisher                          =
 		// ==============================================================
 		$scope.publisherList = Entity.queryMetadata("publishments");
 		$scope.addPublisherType = "";
 		$scope.policyPublisherList = [];
 		$scope.publisher = {};

 		if(!$scope.newPolicy) {
 			Entity.queryMetadata("policies/" + $scope.policy.name + "/publishments/")._then(function (res) {
 				$scope.policyPublisherList = $.map(res.data, function (publisher) {
 					return $.extend({
 						_exist: true
 					}, publisher);
 				});
 			});
 		}

 		$scope.addPublisher = function () {
 			$scope.publisher = {
 				existPublisher: $scope.publisherList[0],
 				type: "org.apache.eagle.alert.engine.publisher.impl.AlertEmailPublisher",
 				dedupIntervalMin: "PT1M",
 				serializer : "org.apache.eagle.alert.engine.publisher.impl.StringEventSerializer",
 				properties: {}
 			};
 			if($scope.publisherList.length) {
 				$scope.addPublisherType = "exist";
 			} else {
 				$scope.addPublisherType = "new";
 			}

 			$.each(Policy.publisherTypeList, function (i, publisherType) {
 				$.each(publisherType.fields, function (j, field) {
 					if(field.value) $scope.publisher.properties[field.name] = field.value;
 				});
 			});

 			$(".modal[data-id='publisherMDL']").modal();
 		};

 		$scope.removePublisher = function (publisher) {
 			$scope.policyPublisherList = common.array.remove(publisher, $scope.policyPublisherList);
 		};

 		$scope.checkPublisherName = function () {
 			if(common.array.find($scope.publisher.name, $scope.publisherList.concat($scope.policyPublisherList), ["name"])) {
 				return "'" + $scope.publisher.name + "' already exist";
 			}
 			return false;
 		};


 		$scope.checkPolicyName = function () {
 			if($scope.policy.name.length > 50) {
 				return "length should less than 50";
 			}
 			return false;
 		};


 		$scope.addPublisherConfirm = function () {
 			if($scope.addPublisherType === "exist") {
 				$scope.publisher = $.extend({
 					_exist: true
 				}, $scope.publisher.existPublisher);
 			}
 			var properties = {};
 			$.each(Policy.publisherTypes[$scope.publisher.type].fields, function (i, field) {
 				properties[field.name] = $scope.publisher.properties[field.name] || "";
 			});
 			$scope.policyPublisherList.push($.extend({}, $scope.publisher, {properties: properties}));
 		};

 		// ==============================================================
 		// =                            Save                            =
 		// ==============================================================
 		$scope.saveLock = false;
 		$scope.saveCheck = function () {
 			return (
 				!$scope.saveLock &&
 				$scope.policy.name &&
 				!$scope.checkPolicyName() &&
 				common.number.parse($scope.policy.parallelismHint) > 0 &&
 				$scope.policy.definition.value &&
 				$scope.policy.outputStreams.length &&
 				$scope.policyPublisherList.length
 			);
 		};

 		$scope.saveConfirm = function () {
 			$scope.saveLock = true;

 			// Check policy
 			Entity.post("metadata/policies/validate", $scope.policy)._then(function (res) {
 				var validate = res.data;
 				console.log(validate);
 				if(!validate.success) {
 					$.dialog({
 						title: "OPS",
 						content: validate.message
 					});
 					$scope.saveLock = false;
 					return;
 				}

 				// Create publisher
 				var publisherPromiseList = $.map($scope.policyPublisherList, function (publisher) {
 					if(publisher._exist) return;

 					return Entity.create("metadata/publishments", publisher)._promise;
 				});
 				if(publisherPromiseList.length) console.log("Creating publishers...", $scope.policyPublisherList);

 				$q.all(publisherPromiseList).then(function () {
 					console.log("Create publishers success...");

 					// Create policy
 					Entity.create("metadata/policies", $scope.policy)._then(function () {
 						console.log("Create policy success...");
 						// Link with publisher
 						Entity.post("metadata/policies/" + $scope.policy.name + "/publishments/", $.map($scope.policyPublisherList, function (publisher) {
 							return publisher.name;
 						}))._then(function () {
 							// Link Success
 							$.dialog({
 								title: "Done",
 								content: "Close dialog to go to the policy detail page."
 							}, function () {
 								$wrapState.go("policyDetail", {name: $scope.policy.name});
 							});
 						}, function (res) {
 							// Link Failed
 							$.dialog({
 								title: "OPS",
 								content: "Link publishers failed:" + res.data.message
 							});
 						}).finally(function () {
 							$scope.policyLock = false;
 						});
 					}, function (res) {
 						var errormsg = "";
 						if(typeof res.data.message !== 'undefined') {
 							errormsg = res.data.message;
 						} else {
 							errormsg = res.data.errors;
 						}
 						$.dialog({
 							title: "OPS",
 							content: "Create policy failed: " + errormsg
 						});
 						$scope.policyLock = false;
 					});
 				}, function (args) {
 					$.dialog({
 						title: "OPS",
 						content: "Create publisher failed. More detail please check output in 'console'."
 					});
 					console.log("Create publishers failed:", args);
 					$scope.policyLock = false;
 				});
 			}, function () {
 				$scope.saveLock = false;
 			});
 		};
 	}
 })();
	/*
	* Licensed to the Apache Software Foundation (ASF) under one
	* or more contributor license agreements. See the NOTICE file
	* distributed with this work for additional information
	* regarding copyright ownership. The ASF licenses this file
	* to you 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.
	*/

	(function() {
	'use strict';

	var eagleControllers = angular.module('eagleControllers');

	// ======================================================================================
	// = Policy Create =
	// ======================================================================================
	function connectPolicyEditController(entity, args) {
	var newArgs = [entity];
	Array.prototype.push.apply(newArgs, args);
	/* jshint validthis: true */
	policyEditController.apply(this, newArgs);
	}

	eagleControllers.controller('policyCreateCtrl', function ($scope, $q, $wrapState, $timeout, PageConfig, Entity, Policy) {
	PageConfig.title = "Define Policy";
	connectPolicyEditController({}, arguments);
	});
	eagleControllers.controller('policyEditCtrl', function ($scope, $q, $wrapState, $timeout, PageConfig, Entity, Policy) {
	PageConfig.title = "Edit Policy";
	var args = arguments;

	$scope.policyList = Entity.queryMetadata("policies/" + encodeURIComponent($wrapState.param.name));
	$scope.policyList._promise.then(function () {
	var policy = $scope.policyList[0];

	if(policy) {
	connectPolicyEditController(policy, args);
	} else {
	$.dialog({
	title: "OPS",
	content: "Policy '" + $wrapState.param.name + "' not found!"
	}, function () {
	$wrapState.go("policyList");
	});
	}
	});
	});

	function policyEditController(policy, $scope, $q, $wrapState, $timeout, PageConfig, Entity, Policy) {
	$scope.policy = policy;
	$scope.policy = common.merge({
	name: "",
	description: "",
	inputStreams: [],
	outputStreams: [],
	definition: {
	type: "siddhi",
	value: ""
	},
	alertDefinition: {
	subject: "",
	body: "",
	severity: "WARNING",
	category: "DEFAULT"
	},
	partitionSpec: [],
	parallelismHint: 5
	}, $scope.policy);
	console.log("[Policy]", $scope.policy);

	var cacheSearchType;
	var cacheSearchSourceKey;
	var searchApplications;

	$scope.searchType = "app";
	$scope.searchSourceKey = "";
	$scope.applications = {};
	$scope.newPolicy = !$scope.policy.name;
	$scope.autoPolicyDescription = $scope.newPolicy && !$scope.policy.description;

	PageConfig.navPath = [
	{title: "Policy List", path: "/policies"},
	{title: ($scope.newPolicy ? "Define" : "Update") + " Policy"}
	];

	// ==============================================================
	// = UI =
	// ==============================================================
	$scope.sourceTab = "all";
	$scope.setSourceTab = function (tab) {
	$scope.sourceTab = tab;
	};

	// ==============================================================
	// = Input Stream =
	// ==============================================================
	$scope.getSearchApplication = function() {
	if(cacheSearchSourceKey !== $scope.searchSourceKey.toUpperCase() \|\| cacheSearchType !== $scope.searchType) {
	var match = false;
	cacheSearchSourceKey = $scope.searchSourceKey.toUpperCase();
	cacheSearchType = $scope.searchType;

	searchApplications = {};
	$.each($scope.applications, function (appName, streams) {
	$.each(streams, function (i, stream) {
	var groupName = cacheSearchType === "app" ? stream.dataSource : stream.siteId;
	if(
	groupName.toUpperCase().indexOf(cacheSearchSourceKey) >= 0 \|\|
	stream.streamId.toUpperCase().indexOf(cacheSearchSourceKey) >= 0
	) {
	match = true;
	var group = searchApplications[groupName] = searchApplications[groupName] \|\| [];
	group.push(stream);
	}
	});
	});

	if(!match) {
	searchApplications = null;
	}
	}
	return searchApplications;
	};

	$scope.streams = {};
	$scope.streamList = Entity.queryMetadata("streams");
	$scope.streamList._then(function () {
	$scope.applications = {};
	cacheSearchSourceKey = null;

	$.each($scope.streamList, function (i, stream) {
	var list = $scope.applications[stream.dataSource] = $scope.applications[stream.dataSource] \|\| [];
	list.push(stream);
	$scope.streams[stream.streamId] = stream;
	});
	});

	$scope.isInputStreamSelected = function (streamId) {
	return $.inArray(streamId, $scope.policy.inputStreams) >= 0;
	};

	/*$scope.checkInputStream = function (streamId) {
	if($scope.isInputStreamSelected(streamId)) {
	$scope.policy.inputStreams = common.array.remove(streamId, $scope.policy.inputStreams);
	} else {
	$scope.policy.inputStreams.push(streamId);
	}
	};*/

	// ==============================================================
	// = Definition =
	// ==============================================================
	function autoDescription() {
	if(!$scope.autoPolicyDescription) return;

	$scope.policy.description = "Policy for " + $scope.policy.outputStreams.join(", ");
	}

	var checkPromise;
	$scope.definitionMessage = "";
	$scope.checkDefinition = function () {
	$timeout.cancel(checkPromise);
	checkPromise = $timeout(function () {
	Entity.post("metadata/policies/parse", $scope.policy.definition.value)._then(function (res) {
	var data = res.data;
	console.log(data);
	if(data.success) {
	$scope.definitionMessage = "";
	if(data.policyExecutionPlan) {
	// Input streams
	$scope.policy.inputStreams = $.map(data.policyExecutionPlan.inputStreams, function (value, stream) {
	return stream;
	});

	// Output streams
	var outputStreams= $.map(data.policyExecutionPlan.outputStreams, function (value, stream) {
	return stream;
	});
	$scope.policy.outputStreams = outputStreams.concat();
	$scope.outputStreams = outputStreams;
	autoDescription();

	// Partition
	$scope.policy.partitionSpec = data.policyExecutionPlan.streamPartitions;
	}
	} else {
	$scope.definitionMessage = data.message;
	}
	});
	}, 350);
	};

	// ==============================================================
	// = Output Stream =
	// ==============================================================
	$scope.outputStreams = ($scope.policy.outputStreams \|\| []).concat();

	$scope.isOutputStreamSelected = function (streamId) {
	return $.inArray(streamId, $scope.policy.outputStreams) >= 0;
	};

	$scope.checkOutputStream = function (streamId) {
	if($scope.isOutputStreamSelected(streamId)) {
	$scope.policy.outputStreams = common.array.remove(streamId, $scope.policy.outputStreams);
	} else {
	$scope.policy.outputStreams.push(streamId);
	}
	autoDescription();
	};

	// ==============================================================
	// = Partition =
	// ==============================================================
	$scope.partition = {};

	$scope.addPartition = function () {
	$scope.partition = {
	streamId: $scope.policy.inputStreams[0],
	type: "GROUPBY",
	columns: []
	};
	$(".modal[data-id='partitionMDL']").modal();
	};

	$scope.newPartitionCheckColumn = function (column) {
	return $.inArray(column, $scope.partition.columns) >= 0;
	};

	$scope.newPartitionClickColumn = function (column) {
	if($scope.newPartitionCheckColumn(column)) {
	$scope.partition.columns = common.array.remove(column, $scope.partition.columns);
	} else {
	$scope.partition.columns.push(column);
	}
	};

	$scope.addPartitionConfirm = function () {
	$scope.policy.partitionSpec.push($scope.partition);
	};

	$scope.removePartition = function (partition) {
	$scope.policy.partitionSpec = common.array.remove(partition, $scope.policy.partitionSpec);
	};

	// ==============================================================
	// = Publisher =
	// ==============================================================
	$scope.publisherList = Entity.queryMetadata("publishments");
	$scope.addPublisherType = "";
	$scope.policyPublisherList = [];
	$scope.publisher = {};

	if(!$scope.newPolicy) {
	Entity.queryMetadata("policies/" + $scope.policy.name + "/publishments/")._then(function (res) {
	$scope.policyPublisherList = $.map(res.data, function (publisher) {
	return $.extend({
	_exist: true
	}, publisher);
	});
	});
	}

	$scope.addPublisher = function () {
	$scope.publisher = {
	existPublisher: $scope.publisherList[0],
	type: "org.apache.eagle.alert.engine.publisher.impl.AlertEmailPublisher",
	dedupIntervalMin: "PT1M",
	serializer : "org.apache.eagle.alert.engine.publisher.impl.StringEventSerializer",
	properties: {}
	};
	if($scope.publisherList.length) {
	$scope.addPublisherType = "exist";
	} else {
	$scope.addPublisherType = "new";
	}

	$.each(Policy.publisherTypeList, function (i, publisherType) {
	$.each(publisherType.fields, function (j, field) {
	if(field.value) $scope.publisher.properties[field.name] = field.value;
	});
	});

	$(".modal[data-id='publisherMDL']").modal();
	};

	$scope.removePublisher = function (publisher) {
	$scope.policyPublisherList = common.array.remove(publisher, $scope.policyPublisherList);
	};

	$scope.checkPublisherName = function () {
	if(common.array.find($scope.publisher.name, $scope.publisherList.concat($scope.policyPublisherList), ["name"])) {
	return "'" + $scope.publisher.name + "' already exist";
	}
	return false;
	};


	$scope.checkPolicyName = function () {
	if($scope.policy.name.length > 50) {
	return "length should less than 50";
	}
	return false;
	};


	$scope.addPublisherConfirm = function () {
	if($scope.addPublisherType === "exist") {
	$scope.publisher = $.extend({
	_exist: true
	}, $scope.publisher.existPublisher);
	}
	var properties = {};
	$.each(Policy.publisherTypes[$scope.publisher.type].fields, function (i, field) {
	properties[field.name] = $scope.publisher.properties[field.name] \|\| "";
	});
	$scope.policyPublisherList.push($.extend({}, $scope.publisher, {properties: properties}));
	};

	// ==============================================================
	// = Save =
	// ==============================================================
	$scope.saveLock = false;
	$scope.saveCheck = function () {
	return (
	!$scope.saveLock &&
	$scope.policy.name &&
	!$scope.checkPolicyName() &&
	common.number.parse($scope.policy.parallelismHint) > 0 &&
	$scope.policy.definition.value &&
	$scope.policy.outputStreams.length &&
	$scope.policyPublisherList.length
	);
	};

	$scope.saveConfirm = function () {
	$scope.saveLock = true;

	// Check policy
	Entity.post("metadata/policies/validate", $scope.policy)._then(function (res) {
	var validate = res.data;
	console.log(validate);
	if(!validate.success) {
	$.dialog({
	title: "OPS",
	content: validate.message
	});
	$scope.saveLock = false;
	return;
	}

	// Create publisher
	var publisherPromiseList = $.map($scope.policyPublisherList, function (publisher) {
	if(publisher._exist) return;

	return Entity.create("metadata/publishments", publisher)._promise;
	});
	if(publisherPromiseList.length) console.log("Creating publishers...", $scope.policyPublisherList);

	$q.all(publisherPromiseList).then(function () {
	console.log("Create publishers success...");

	// Create policy
	Entity.create("metadata/policies", $scope.policy)._then(function () {
	console.log("Create policy success...");
	// Link with publisher
	Entity.post("metadata/policies/" + $scope.policy.name + "/publishments/", $.map($scope.policyPublisherList, function (publisher) {
	return publisher.name;
	}))._then(function () {
	// Link Success
	$.dialog({
	title: "Done",
	content: "Close dialog to go to the policy detail page."
	}, function () {
	$wrapState.go("policyDetail", {name: $scope.policy.name});
	});
	}, function (res) {
	// Link Failed
	$.dialog({
	title: "OPS",
	content: "Link publishers failed:" + res.data.message
	});
	}).finally(function () {
	$scope.policyLock = false;
	});
	}, function (res) {
	var errormsg = "";
	if(typeof res.data.message !== 'undefined') {
	errormsg = res.data.message;
	} else {
	errormsg = res.data.errors;
	}
	$.dialog({
	title: "OPS",
	content: "Create policy failed: " + errormsg
	});
	$scope.policyLock = false;
	});
	}, function (args) {
	$.dialog({
	title: "OPS",
	content: "Create publisher failed. More detail please check output in 'console'."
	});
	console.log("Create publishers failed:", args);
	$scope.policyLock = false;
	});
	}, function () {
	$scope.saveLock = false;
	});
	};
	}
	})();