app.js

angular.module("fishmograph", ["ui.router", "ui-notification"])

// --- FISHMOGRAPH API ---
// Host address (debug)
//.constant("FH_HOST", "http://192.168.0.200")
// Host address (production)
.constant("FH_HOST", "")

// Login/Logout
.constant("FH_API_LOGIN", "/login")
.constant("FH_API_LOGOUT", "/logout")
.constant("FH_API_PASSWORD_UPDATE", "/password/update")
.constant("FH_API_STATUS", "/status")
.constant("FH_API_DATA", "/data")
.constant("FH_API_DATA_D7S", "/data/d7s")
.constant("FH_API_SETTINGS_INITIALIZE", "/settings/initialize")
.constant("FH_API_SETTINGS_SELFTEST", "/settings/selftest")
.constant("FH_API_SETTINGS_CLEAR_D7S", "/settings/clear/d7s")
.constant("FH_API_SETTINGS_CLEAR_DATA", "/settings/clear/data")
.constant("FH_API_RECIPIENT_LIST", "/recipient/list")
.constant("FH_API_RECIPIENT_DELETE", "/recipient/delete")
.constant("FH_API_RECIPIENT_NEW", "/recipient/new")


.config(function ($urlRouterProvider, $locationProvider, $urlMatcherFactoryProvider, $stateProvider, $httpProvider, NotificationProvider) {

	// --- ROUTES ---
	// ui-router non strict mode and case insensitive
	$urlMatcherFactoryProvider.caseInsensitive(true);
	$urlMatcherFactoryProvider.strictMode(false); 

	// Index state (redirect to earthquakes)
	$stateProvider.state("index", {
		redirectTo: "login",
		url: "/"
	});

	// Login state
	$stateProvider.state("login", {
		controller: "loginCtrl",
		templateUrl: "login.htm",
		url: "/login"
	});

	// Container logged area
	$stateProvider.state("page", {
		controller: "pageCtrl",
		templateUrl: "cntr.htm",
		data: {
			requireLogin: true // every child state require login
		},
		//redirectTo: "page.earthquakes"
	});

	// Earthquakes
	$stateProvider.state("page.earthquakes", {
		controller: "earthquakesCtrl",
		templateUrl: "earthqks.htm",
		url: "/earthquakes"
	});

	// D7S readings
	$stateProvider.state("page.d7s", {
		controller: "d7sCtrl",
		templateUrl: "d7s.htm",
		url: "/d7s"
	});

	// Alerts
	// Container
	$stateProvider.state("page.alerts", {
		controller: "alertsCtrl",
		template: "<ui-view></ui-view>",
		url: "/alerts"
	});
	$stateProvider.state("page.alerts.list", {
		controller: "alertsListCtrl",
		templateUrl: "alerts.htm",
		url: "/list"
	});
	$stateProvider.state("page.alerts.new", {
		controller: "alertsNewCtrl",
		templateUrl: "alert_nw.htm",
		url: "/new"
	});

	// Settings
	$stateProvider.state("page.settings", {
		controller: "settingsCtrl",
		templateUrl: "settings.htm",
		url: "/settings"
	});

	// Credits and license
	$stateProvider.state("page.credits", {
		controller: "creditsCtrl",
		templateUrl: "credits.htm",
		url: "/credits"
	});


	$urlRouterProvider.when("", function ($state) {
		$state.go("index");
	});

	//error404 main routes
	$urlRouterProvider.otherwise(function ($injector) {
		//getting $state service from $injector
		$state = $injector.get("$state");
		//transition to the default page
		$state.go("page.earthquakes");
	});

	// --- HTTP CONFIG ---
	$httpProvider.defaults.withCredentials = true;
	//$httpProvider.defaults.headers.common["Content-Type"] = "text/plain";

	// --- NOTIFICATIONS ---
	NotificationProvider.setOptions({
        delay: 10000,
        startTop: 20,
        startRight: 10,
        verticalSpacing: 10,
        horizontalSpacing: 10,
        positionX: 'center',
        positionY: 'top'
    });

})

.run(function ($state, $transitions, LoginService) {
	// If the user is already logged in (session is valid) redirect him to the logged page (only performed once at app startup)
	// Check if the user is already logged in
	LoginService.login().then(function () {
		$state.go("page.earthquakes");
	}, function () {
		$state.go("login");
	}).finally(function () {
		// Check if the user is autenticated, otherwise redirect him to the login page
		$transitions.onStart({ }, function(transition) {
			//if the state require the login and the user is not logged
			if (transition.to().name != "login" && transition.to().data !== undefined && transition.to().data.requireLogin && !LoginService.isUserLogged()) {
				return transition.router.stateService.target('login');
			}
		});
	})
})

// --- SERVICES ---
// Login service
.factory("LoginService", function ($q, $http, FH_HOST, FH_API_LOGIN, FH_API_LOGOUT) {
	// User status
	var isLogged = false;

	// Function to log in a user
	function login(password) {
		var deferred = $q.defer();
		
		$http({
			method: 'POST',
			url: FH_HOST + FH_API_LOGIN,
			headers: {
   				'Content-Type': undefined
 			},
			data: {
				password: password
			}
		// Success
		}).then(function () {
			// Saving the success login status
			isLogged = true;
			// Resolving the promise
			deferred.resolve();
		// Error
		}, function () {
			// Resolving the promise
			deferred.reject();
		});

		return deferred.promise;
	}
		
	// Function to logout a user
	function logout(request = true) {
		// If the logout need to be sent to the server
		if (request) {
			var deferred = $q.defer();

			$http({
				method: 'POST',
				url: FH_HOST + FH_API_LOGOUT,
				headers: {
	   				'Content-Type': undefined
	 			}
			// Success
			}).then(function () {
				// Saving the success logout status
				isLogged = false;
				// Resolving the promise
				deferred.resolve();
			// Error
			}, function () {
				// Resolving the promise
				deferred.reject();
			});

			return deferred.promise;
		} else {
			isLogged = false;
		}
	}

	// Function to check if a user is logged
	function isUserLogged() {
		return isLogged;
	}

	// Return the service object
	return {
		login: login, //login function
		logout: logout, //logout function
		isUserLogged: isUserLogged, //check if the user is logged
	};

})

// Notification service
.factory("AlertService", function (Notification) {
	// Show a success alert
	function success(message) {
		Notification({templateUrl: "alert-success.html", message: message});
	}

	// Show a warning alert
	function warning(message) {
		Notification({templateUrl: "alert-warning.html", message: message});
	}

	// Show a danger alert
	function danger(message) {
		Notification({templateUrl: "alert-danger.html", message: message});
	}

	// Return the service object
	return {
		success: success, // Show a success alert
		warning: warning, // Show a warning alert
		danger: danger // Show a danger alert
	};
})

// Authorized http service
// It will send the request using $http service, if the response is 401 (Unauthorized) the user is redirected to login
.factory("AuthorizedHttp", function($http, $state, $q, LoginService, AlertService) {

	function request(request) {
		var deferred = $q.defer();
		
		$http(request).then(function (response) {
			// Resolving the promise
			deferred.resolve(response);
		// Error
		}, function (response) {
			// If the user is not autorized
			if (response.status == 401) {
				// Logout the user and redirect him to the login page
				LoginService.logout(false);
				$state.go("login");
				return;
			}
			// Resolving the promise
			deferred.reject(response);
		});

		return deferred.promise;
	}

	return {
		request: request
	};
})


// --- CONTROLLERS ---
// Earthquakes page controller
.controller("loginCtrl", function ($scope, $state, LoginService, AlertService) {
	// If the user is already logged in redirect him to the logged page
	// Check if the user is already logged in
	if (LoginService.isUserLogged()) {
		$state.go("page.earthquakes");
	}

	// Login the user
	$scope.login = function (password) {
		// If password is undefined put an empty string
		if (password == undefined) {
			password = "";
		}

		LoginService.login(password).then(function () {
			$state.go("page.earthquakes");
		}, function () {
			AlertService.danger("The password is wrong!");
		});
	}
})

// Menu controller
.controller("pageCtrl", function ($scope, $state, $interval, $filter, LoginService, AlertService, AuthorizedHttp, FH_HOST, FH_API_STATUS) {
	var pageTitle = "";
	var menuItemHighlighted = -1;
	var checkingStatus = false;
	
	// Set the page title
	$scope.setPageTitle = function (title) {
		pageTitle = title;
	};
	// Set the menu item to highlight
	$scope.setMenuItemHighlighted = function (item) {
		menuItemHighlighted = item;
	};

	// Get the page title
	$scope.getPageTitle = function (item) {
		return pageTitle;
	};

	// Check if the current menu item is active
	$scope.isMenuItemHighlighted = function (item) {
		return item == menuItemHighlighted;
	};

	// Logout
	$scope.logout = function () {
		LoginService.logout(true).then(function () {
			$state.go("login");
		}, function () {
			AlertService.danger("The server has encountered some problems. Try again later!");
		});
	}

	//status check every 5 seconds
	function checkStatus() {
		if (checkingStatus) {
			return;
		}

		checkingStatus = true;

		if (LoginService.isUserLogged()) {
			AuthorizedHttp.request({
				method: 'GET',
				url: FH_HOST + FH_API_STATUS,
				headers: {
			   		'Content-Type': undefined
			 	}
			// Success
			}).then(function (response) {

				if (response.data.status == 2) {
					AlertService.warning("Earthquake started on " + $filter('date')(response.data.timestamp*1000, 'dd/MM/yyyy at HH:mm:ss'));
				} else if (response.data.status == 3) {
					AlertService.warning("Earthquake ended on " + $filter('date')(response.data.timestamp*1000, 'dd/MM/yyyy at HH:mm:ss'));
				} else if (response.data.status == 4) {
					AlertService.danger("Shutoff signal generated on " + $filter('date')(response.data.timestamp*1000, 'dd/MM/yyyy at HH:mm:ss'));
				} else if (response.data.status == 3) {
					AlertService.danger("Collapse signal generated on " + $filter('date')(response.data.timestamp*1000, 'dd/MM/yyyy at HH:mm:ss'));
				}

			// Error
			}, function () {
				// Alert that the server encountered some problems
				AlertService.danger("The server has encountered some problems. Try again later!");

			// Finally
			}).finally(function () {
				checkingStatus = false;
			});
		}
	}

	//register event
	$interval(checkStatus, 5000);
})

// Earthquakes page controller
.controller("earthquakesCtrl", function ($scope, AlertService, AuthorizedHttp, FH_HOST, FH_API_DATA) {
	// Set page title and highlight the menu item
	$scope.setPageTitle("Earthquakes Registered");
	$scope.setMenuItemHighlighted(0);

	// Show the loader gear
	$scope.loader = true;
	// Prepare the data
	$scope.data = {};

	AuthorizedHttp.request({
		method: 'GET',
		url: FH_HOST + FH_API_DATA,
		headers: {
	   		'Content-Type': undefined
	 	}
	// Success
	}).then(function (response) {
		// Clear old data
		$scope.data = {};

		// If the data are valid
		if (angular.isArray(response.data) && response.data.length != 0) {
			$scope.data.items = response.data;
		}

	// Error
	}, function () {
		// Clear the data
		$scope.data = {};
		// Alert that the server encountered some problems
		AlertService.danger("The server has encountered some problems. Try again later!");
	
	// Finally
	}).finally(function () {
		// Hide the loader gear
		$scope.loader = false;
	});
})

// D7S Readings page controller
.controller("d7sCtrl", function ($scope, AlertService, AuthorizedHttp, FH_HOST, FH_API_DATA_D7S) {
	// Set page title and highlight the menu item
	$scope.setPageTitle("D7S Readings");
	$scope.setMenuItemHighlighted(1);

	// Show the loader gear
	$scope.loader = true;
	// Prepare the data
	$scope.data = {};

	AuthorizedHttp.request({
		method: 'GET',
		url: FH_HOST + FH_API_DATA_D7S,
		headers: {
	   		'Content-Type': undefined
	 	}
	// Success
	}).then(function (response) {
		// Prepare the data
		$scope.data = {};

		//prepare data
		var lastest = [];
		var ranked = [];
		//lastest data
		for (i = 0; i < 5; i++) {
			if (response.data[0][i].si != 0 || response.data[0][i].pga != 0) {
				lastest.push(response.data[0][i]);
			}
		}
		if (lastest.length != 0) {
			$scope.data.lastest = lastest;
		}
		//ranked data
		for (i = 0; i < 5; i++) {
			if (response.data[1][i].si != 0 || response.data[1][i].pga != 0) {
				ranked.push(response.data[1][i]);
			}
		}
		if (ranked.length != 0) {
			$scope.data.ranked = ranked;
		}

	// Error
	}, function () {
		// Clear the data
		$scope.data = {};
		// Alert that the server encountered some problems
		AlertService.danger("The server has encountered some problems. Try again later!");
	
	// Finally
	}).finally(function () {
		// Hide the loader gear
		$scope.loader = false;
	});
})

// Alerts container page controller
.controller("alertsCtrl", function ($scope) {
	// Set page title and highlight the menu item
	$scope.setPageTitle("Email Alerts");
	$scope.setMenuItemHighlighted(2);
})

// Alerts list page controller
.controller("alertsListCtrl", function ($scope, $state, AlertService, AuthorizedHttp, FH_HOST, FH_API_RECIPIENT_LIST, FH_API_RECIPIENT_DELETE) {
	// Show the loader gear
	$scope.loader = true;
	// Prepare the data
	$scope.data = {
		items: {}
	};

	AuthorizedHttp.request({
		method: 'GET',
		url: FH_HOST + FH_API_RECIPIENT_LIST,
		headers: {
	   		'Content-Type': undefined
	 	}
	// Success
	}).then(function (response) {
		// Clear old data
		$scope.data = {
			items: {}
		};

		// If the data are valid
		if (angular.isArray(response.data) && response.data.length != 0) {
			$scope.data.items = response.data;
		}

	// Error
	}, function () {
		// Clear the data
		$scope.data = {
			items: {}
		};
		// Alert that the server encountered some problems
		AlertService.danger("The server has encountered some problems. Try again later!");
	
	// Finally
	}).finally(function () {
		// Hide the loader gear
		$scope.loader = false;
	});

	$scope.addRecipient = function () {
		if ($scope.data.items.length == 5) {
			AlertService.warning("You can only set 5 recipients!");
		} else {
			$state.go("page.alerts.new");
		}
	}

	$scope.deleteRecipient = function (index) {
		AuthorizedHttp.request({
			method: 'POST',
			url: FH_HOST + FH_API_RECIPIENT_DELETE,
			headers: {
		   		'Content-Type': undefined
		 	},
		 	data: {
				index: index
			}
		// Success
		}).then(function () {
			// remove the element from the array
			$scope.data.items.splice(index, 1);

		// Error
		}, function () {
			// Alert that the server encountered some problems
			AlertService.danger("The server has encountered some problems. Try again later!");
		});
	}
})

// New alert page controller
.controller("alertsNewCtrl", function ($scope, $state, AlertService, AuthorizedHttp, FH_HOST, FH_API_RECIPIENT_NEW) {

	$scope.newRecipient = function (name, email) {
		AuthorizedHttp.request({
			method: 'POST',
			url: FH_HOST + FH_API_RECIPIENT_NEW,
			headers: {
		   		'Content-Type': undefined
		 	},
		 	data: {
				name: name,
				email: email
			}
		// Success
		}).then(function () {
			AlertService.success("The new recipient has been added!");
			// Transit to the list page
			$state.go("page.alerts.list");

		// Error
		}, function () {
			// Alert that the server encountered some problems
			AlertService.danger("The server has encountered some problems. Try again later!");
		});
	}
	
})

// Settings page controller
.controller("settingsCtrl", function ($scope, AlertService, AuthorizedHttp, FH_HOST, FH_API_SETTINGS_INITIALIZE, FH_API_SETTINGS_SELFTEST, FH_API_SETTINGS_CLEAR_DATA, FH_API_SETTINGS_CLEAR_D7S, FH_API_PASSWORD_UPDATE) {
	var activePanel = 0;

	// Set page title and highlight the menu item
	$scope.setPageTitle("Fishmograph Settings");
	$scope.setMenuItemHighlighted(3);

	// Set the active panel
	$scope.setActivePanel = function (item) {
		activePanel = item;
	};

	// Check if the current panel is active
	$scope.isPanelActive = function (item) {
		return item == activePanel;
	};

	//only one request at a time
	var requestOutgoing = false;

	$scope.initialize = function () {
		if (requestOutgoing) {
			AlertService.warning("Too many commands! You can send one command at a time!");
			return;
		}

		// We are making a request
		requestOutgoing = true;

		// Alert the user for the action
		AlertService.warning("The sensor will be initialized!");

		AuthorizedHttp.request({
			method: 'POST',
			url: FH_HOST + FH_API_SETTINGS_INITIALIZE,
			headers: {
		   		'Content-Type': undefined
		 	}
		// Success
		}).then(function (response) { //success promises
			if (response.data.status == 1) {
				AlertService.success("Sensor succesfully initialized!");
			} else if (response.data.status == 2) {
				AlertService.warning("Sensor cannot be initialized beacuse an earthquake is occuring!");
			}
		// Error
		}, function () {
			AlertService.danger("The server has encountered some problems. Try again later!");
		// Finally
		}).finally(function () {
			requestOutgoing = false;
		});
	};

	$scope.selftest = function () {
		if (requestOutgoing) {
			AlertService.warning("Too many commands! You can send one command at a time.");
			return;
		}

		// We are making a request
		requestOutgoing = true;

		// Alert the user for the action
		AlertService.warning("The selftest procedure is started!");

		AuthorizedHttp.request({
			method: 'POST',
			url: FH_HOST + FH_API_SETTINGS_SELFTEST,
			headers: {
		   		'Content-Type': undefined
		 	}
		// Success
		}).then(function (response) { //success promises
			if (response.data.status == 1) {
				AlertService.success("Selftest completed successfully!");
			} else if (response.data.status == -1) {
				AlertService.danger("Selftest ended with errors!");
			} else if (response.data.status == 2) {
				AlertService.warning("Selftest cannot be performed beacuse an earthquake is occuring!");
			}
		// Error
		}, function () {
			AlertService.danger("The server has encountered some problems. Try again later!");
		// Finally
		}).finally(function () {
			requestOutgoing = false;
		});
	};

	$scope.clearMemory = function () {
		if (requestOutgoing) {
			AlertService.warning("Too many commands! You can send one command at a time.");
			return;
		}

		// We are making a request
		requestOutgoing = true;

		AuthorizedHttp.request({
			method: 'POST',
			url: FH_HOST + FH_API_SETTINGS_CLEAR_D7S,
			headers: {
		   		'Content-Type': undefined
		 	}
		// Success
		}).then(function (response) { //success promises
			AlertService.success("Sensor memory successfully cleared!");
		// Error
		}, function () {
			AlertService.danger("The server has encountered some problems. Try again later!");
		// Finally
		}).finally(function () {
			requestOutgoing = false;
		});
	};

	$scope.clearData = function () {
		if (requestOutgoing) {
			AlertService.warning("Too many commands! You can send one command at a time.");
			return;
		}

		// We are making a request
		requestOutgoing = true;

		AuthorizedHttp.request({
			method: 'POST',
			url: FH_HOST + FH_API_SETTINGS_CLEAR_DATA,
			headers: {
		   		'Content-Type': undefined
		 	}
		// Success
		}).then(function (response) { //success promises
			AlertService.success("Earthquake data has been successfully cleared!");
		// Error
		}, function () {
			AlertService.danger("The server has encountered some problems. Try again later!");
		// Finally
		}).finally(function () {
			requestOutgoing = false;
		});
	};

	$scope.changePassword = function (password, confirmPassword) {
		if (password != confirmPassword) {
			AlertService.danger("Password mismatch!");
			return;
		}

		AuthorizedHttp.request({
			method: 'POST',
			url: FH_HOST + FH_API_PASSWORD_UPDATE,
			headers: {
		   		'Content-Type': undefined
		 	},
		 	data: {
		 		password: password
		 	}
		// Success
		}).then(function () { //success promises
			AlertService.success("Password succesfully updated!");
		// Error
		}, function () {
			AlertService.danger("The server has encountered some problems. Try again later!");
		// Finally
		});
	};
})

// Credits page controller
.controller("creditsCtrl", function ($scope) {
	var activePanel = 0;

	// Set page title and highlight the menu item
	$scope.setPageTitle("Credits & License");
	$scope.setMenuItemHighlighted(4);

	// Set the active panel
	$scope.setActivePanel = function (item) {
		activePanel = item;
	};

	// Check if the current panel is active
	$scope.isPanelActive = function (item) {
		return item == activePanel;
	};
});