[PORTAL-7] Rebase

This rebasing includes common libraries and common overlays projects
abstraction of components

Change-Id: I9a24a338665c7cd058978e8636bc412d9e2fdce8
Signed-off-by: st782s <statta@research.att.com>

2 files changed, 249 insertions, 0 deletions

diff --git a/ecomp-portal-FE-os/client/src/views/userbar/userbar.controller.js b/ecomp-portal-FE-os/client/src/views/userbar/userbar.controller.js
new file mode 100644
index 00000000..4e2b10b9
--- /dev/null
+++ b/ecomp-portal-FE-os/client/src/views/userbar/userbar.controller.js
@@ -0,0 +1,229 @@
+/*-
+ * ================================================================================
+ * eCOMP Portal
+ * ================================================================================
+ * Copyright (C) 2017 AT&T Intellectual Property
+ * ================================================================================
+ * 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.
+ * ================================================================================
+ */
+'use strict';
+
+(function () {
+	
+    class UserbarCtrl {
+        constructor(userProfileService,userbarUpdateService, $log, $rootScope , $interval,$scope,$timeout,dashboardService) {
+            this.$log = $log;
+            var debug = false;
+            this.userProfileService = userProfileService;
+            this.$rootScope = $rootScope;
+            $rootScope.isAdminPortalAdmin = false;
+            $scope.updateRate = 10000; //default online user bar refreshing rate
+            var intervalPromise = null;
+            $scope.myservice = userbarUpdateService;
+            $scope.userList=this.userLists;
+            var websocket = '';
+            var currentUser = '';
+            var remoteUser = '';
+            var f = '';
+           
+        	
+            function socketSetup(initialPageVisit,_currentUser, _remoteUser, _f) {
+            	
+
+
+            	if( true) {
+            		  
+            		var href = window.location.href;
+            	    var hostPatt = new RegExp(window.location.host +"/[^/]*");
+            	    var res = hostPatt.exec(href);
+            	    var protocol = window.location.protocol.replace("http","ws");
+            	      var signalingServerPath = protocol + "//" + res + "/opencontact";
+            		  var wsUri = signalingServerPath;
+            		  console.log("Connecting to " + wsUri);
+            		  websocket = new WebSocket(wsUri);
+            		  //localStorage.notifySocket = JSON.stringify(websocket);
+            		  //window.top.notifySocket = websocket;
+            		  
+            		  currentUser = _currentUser;
+            		  remoteUser = _remoteUser;
+            		  f = socketSend;
+            		 
+            		  
+            	}
+            	
+            	//var websocket = JSON.parse(localStorage.notifySocket || "{}") ;
+            	if( websocket != null) {
+            		websocket.onopen = function(evt) { onOpen(evt); };
+            		websocket.onmessage = function(evt) { onMessage(evt); };
+            		websocket.onerror = function(evt) { onError(evt); };
+            	
+            	}
+            	
+            	//if(f != undefined)
+            	 // f();
+            	
+            	//window.top.notifySocket.send("");
+            }
+            
+            function socketSend(currentUser, remoteUser) {
+            	
+
+
+           	 websocket.send(JSON.stringify({
+                    from: currentUser,
+                    to: remoteUser
+                }));
+           	
+           	//window.top.notifySocket.send("");
+           }
+
+
+
+
+           function onOpen(evt) {
+               console.log("onOpen");
+               //writeToScreen("CONNECTED");
+               
+               if(f != undefined)
+           		f(currentUser, remoteUser);
+               
+           }
+
+           function onMessage(evt) {
+               if (typeof evt.data == "string") {
+                   writeToScreen("RECEIVED (text): " + evt.data);
+                   var chatObject = JSON.parse(evt.data);
+                   if(confirm("User " + chatObject.from + " is requesting a chat session with you. Please click ok to accept")== true) {
+                	   
+                	   var url = userProfileService.getSortedUserIdCombination(chatObject.from, chatObject.to);
+                	   var win = window.open(url, '_blank');
+	              	   win.focus();
+                   } else {
+                	   //
+                   }
+                
+                   
+               } else {
+                   writeToScreen("RECEIVED (binary): " + evt.data);
+               }
+           }
+
+           function onError(evt) {
+               writeToScreen('<span style="color: red;">ERROR:</span> ' + evt.data);
+           }
+
+           function writeToScreen(message) {
+        	   console.log(message);
+           }
+            
+            function updateActiveUsers() {
+            	// $log.debug('UserbarCtrl::updateActiveUsers: intervalPromise is ' + intervalPromise);
+				// $log.info("UserbarCtrl:updateActiveUsers invoked.")
+            	// decrement the counter every time updateActiveUser is called;
+				userbarUpdateService.decrementRefreshCount();
+            	userProfileService.getActiveUser()
+                .then(res=> {
+                	if (debug)
+                		$log.debug('UserbarCtrl::updateActiveUsers: service returned ' + JSON.stringify(res));
+                	if (res==null) {
+                		$log.error('UserbarCtrl::updateActiveUsers: failed to get active user');
+                		$scope.stop();
+                	} else {
+                		$scope.userList = [];
+                		// defend against huge list that should never happen.
+                		var maxItems = 25;
+                		if (res.length < maxItems)
+                			maxItems = res.length;
+                		for (var i=0; i < maxItems; i++) {
+                			var data= {
+                					userId:res[i],
+                					linkQ:userProfileService.getSortedUserIdCombination(userProfileService.userProfile.orgUserId , res[i])
+                			}
+                			$scope.userList.push(data);
+                		}      		
+                		if (debug)
+                			$log.debug('UserbarCtrl::updateActiveUsers: user list ' + JSON.stringify($scope.userList));
+                	}   	
+                }).catch(err=> {
+                	$log.error('UserbarCtrl::updateActiveUsers: caught exception: ' + err);
+                	// Do not show stale result
+                	$scope.userList = [];
+                	$scope.stop(); 	
+                }).finally(() => {
+                   	var footerOff = $('#online-userbar').offset().top;
+            		var headOff = $('#footer').offset().top;
+            		var userbarHeight= parseInt($(".online-user-container").css('height'),10);
+            		var defaultOffSet = 45;
+            		$(".online-user-container").css({
+        				"height" : headOff - footerOff-defaultOffSet
+        			});
+                });      
+            }
+            
+			$scope.start = function(rate) {
+				// stops any running interval to avoid two intervals running at the same time
+				$scope.stop(); 	
+				// store the interval promise
+				intervalPromise = $interval(updateActiveUsers, rate);
+			};
+
+			$scope.stop = function() {
+				if (intervalPromise != null) {
+					$interval.cancel(intervalPromise);
+					intervalPromise = null;
+				}
+			};
+
+			$scope.$watch('myservice.getRefreshCount()', function (newVal,oldVal) {
+				//$log.info("refresh "+$scope.myservice.refreshCount + " more time(s)");
+				if (newVal<=0) {
+					// $log.info("UserbarCtrl: stopped refreshing online users");
+					$scope.stop();
+				} else if (newVal== $scope.myservice.maxCount){
+					// $log.info("UserbarCtrl: start refreshing online users at every "+($scope.updateRate/1000)+" sec");
+					// initial update of activate users
+					updateActiveUsers();
+					$scope.start($scope.updateRate);
+				}
+			});
+
+            // Load the active users.
+            //updateActiveUsers();
+            dashboardService.getOnlineUserUpdateRate().then(res=> {
+            	// $log.info('getting Online User Update Rate init***********************', res);
+            	if (res == null || res.response == null) {
+            		$log.error('UserbarCtlr: failed to get online user update rate or duration, check system.properties file.');
+            	} else {
+           			// $log.debug('UserbarCtlr: got online User Update Rate ' + res.response);            		
+            		var rate = parseInt(res.response.onlineUserUpdateRate);
+					// var updateRate = parseInt(res.response.onlineUserUpdateRate);
+					var duration = parseInt(res.response.onlineUserUpdateDuration);
+					userbarUpdateService.setMaxRefreshCount(parseInt(duration/rate)+1);
+					userbarUpdateService.setRefreshCount(userbarUpdateService.maxCount);
+					// $scope.refreshCount = userbarUpdateService.getRefreshCount();
+
+           			if (rate != NaN && duration != NaN) {
+           				// $log.debug('UserbarCtlr: scheduling function at interval ' + millis);
+						$scope.updateRate=rate;
+						$scope.start($scope.updateRate);
+           			}            			
+            	}
+            }).catch(err=> {
+            	$log.error('UserbarCtlr: getOnlineUserUpdateRate() failed: ' + err);
+            });
+        }
+    }
+    UserbarCtrl.$inject = ['userProfileService', 'userbarUpdateService', '$log', '$rootScope','$interval','$scope','$timeout','dashboardService'];
+    angular.module('ecompApp').controller('UserbarCtrl', UserbarCtrl);
+})();
diff --git a/ecomp-portal-FE-os/client/src/views/userbar/userbar.tpl.html b/ecomp-portal-FE-os/client/src/views/userbar/userbar.tpl.html
new file mode 100644
index 00000000..b40a1748
--- /dev/null
+++ b/ecomp-portal-FE-os/client/src/views/userbar/userbar.tpl.html
@@ -0,0 +1,20 @@
+<!--

+  ================================================================================

+  ECOMP Portal

+  ================================================================================

+  Copyright (C) 2017 AT&T Intellectual Property

+  ================================================================================

+  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.

+  ================================================================================

+  -->

+<right-menu id="userbar.userList" user-list="userList" class="w-ecomp-sidebar"></right-menu>