diff options
Diffstat (limited to 'www/js/NVR.js')
| -rw-r--r-- | www/js/NVR.js | 3095 |
1 files changed, 3095 insertions, 0 deletions
diff --git a/www/js/NVR.js b/www/js/NVR.js new file mode 100644 index 00000000..94aeae51 --- /dev/null +++ b/www/js/NVR.js @@ -0,0 +1,3095 @@ +/* jshint -W041 */ + +/* jslint browser: true*/ +/* global cordova,StatusBar,angular,console, URI, moment, localforage, CryptoJS, Connection */ + +// This is my central data respository and common functions +// that many other controllers use +// It's grown over time. I guess I may have to split this into multiple services in the future + +angular.module('zmApp.controllers') + + .service('NVR', ['$ionicPlatform', '$http', '$q', '$ionicLoading', '$ionicBackdrop', '$fileLogger', 'zm', '$rootScope', '$ionicContentBanner', '$timeout', '$cordovaPinDialog', '$ionicPopup', '$localstorage', '$state', '$translate', '$cordovaSQLite', + function ($ionicPlatform, $http, $q, $ionicLoading, $ionicBackdrop, $fileLogger, + zm, $rootScope, $ionicContentBanner, $timeout, $cordovaPinDialog, + $ionicPopup, $localstorage, $state, $translate) { + + var currentServerMultiPortSupported = false; + + /* + DO NOT TOUCH zmAppVersion + It is changed by sync_version.sh + */ + var zmAppVersion = "1.3.040"; + var isBackground = false; + var justResumed = false; + var timeSinceResumed = -1; + var monitorsLoaded = 0; + var snapshotFrame = 1; // will be 'snapshot' + // if ZM >= 1.31 + + + + var monitors = []; + var multiservers = []; + + var migrationComplete = false; + + var tz = ""; + var isTzSupported = false; + + var languages = [{ + text: 'English', + value: 'en' + }, + { + text: 'العربية', + value: 'ar' + }, + { + text: 'Bosnian', + value: 'ba' + }, + { + text: 'Deutsch', + value: 'de' + }, + { + text: 'Español', + value: 'es' + }, + + { + text: 'Français', + value: 'fr' + }, + + { + text: 'Italiano', + value: 'it' + }, + { + text: 'Magyar', + value: 'hu' + }, + { + text: 'Nederlands', + value: 'nl' + }, + { + text: 'Polski', + value: 'pl' + }, + { + text: 'Portugese', + value: 'pt' + }, + { + text: 'Русский', + value: 'ru' + }, + + ]; + + var serverGroupList = {}; + var defaultLang = 'en'; + var isFirstUse = true; + var lastUpdateCheck = null; + var latestBlogPostChecked = null; + var loginData = { + 'serverName': '', + 'username': '', + 'password': '', + 'fallbackConfiguration': '', + 'url': '', // This is the ZM portal path + 'apiurl': '', // This is the API path + 'eventServer': '', //experimental Event server address + 'maxMontage': "100", //total # of monitors to display in montage + 'streamingurl': "", + 'maxFPS': "3", // image streaming FPS + 'montageQuality': "50", // montage streaming quality in % + 'singleImageQuality': "100", // event single streaming quality in % + 'monSingleImageQuality': "100", // live view quality + 'montageHistoryQuality': "50", + 'useSSL': false, // "1" if HTTPS --> not used #589 + 'keepAwake': true, // don't dim/dim during live view + 'isUseAuth': true, // true if user wants ZM auth + 'isUseBasicAuth': false, + 'basicAuthUser': '', + 'basicAuthPassword': '', + 'isUseEventServer': false, // true if you configure the websocket event server + 'disablePush': false, // true if only websocket mode is desired + 'eventServerMonitors': '', // list of monitors to notify from ES + 'eventServerInterval': '', // list of intervals for all monitors + 'refreshSec': '2', // timer value for frame change in sec + 'refreshSecLowBW': 8, + 'enableLogs': true, + 'enableDebug': true, // if enabled with log messages with "debug" + 'usePin': false, + 'pinCode': '', + 'canSwipeMonitors': true, + 'persistMontageOrder': false, + 'onTapScreen': "", + 'enableh264': true, + 'gapless': false, + 'montageOrder': '', + 'montageHiddenOrder': '', + 'montageArraySize': '0', + 'showMontageSubMenu': false, + 'graphSize': 2000, + 'enableAlarmCount': true, + 'minAlarmCount': 1, + 'montageSize': '3', + 'useNphZms': true, + 'useNphZmsForEvents': true, + 'packMontage': false, + 'exitOnSleep': false, + 'forceNetworkStop': false, + 'defaultPushSound': false, + 'enableBlog': true, + 'use24hr': false, + 'packeryPositions': '', + 'currentMontageProfile': '', + 'packeryPositionsArray': {}, + 'EHpackeryPositions': '', + 'packerySizes': '', + 'timelineModalGraphType': 'all', + 'resumeDelay': 0, + 'language': 'en', + 'reachability': true, + 'forceImageModePath': false, + 'vibrateOnPush': true, + 'soundOnPush': true, + 'cycleMonitors': false, + 'cycleMontage': false, + 'cycleMontageInterval': 10, // 10sec + 'cycleMonitorsInterval': 10, // 10sec + 'enableLowBandwidth': false, + 'autoSwitchBandwidth': false, + 'disableAlarmCheckMontage': false, + 'useLocalTimeZone': true, + 'fastLogin': true, + 'followTimeLine': false, + 'timelineScale': -1, + 'hideArchived': false, + 'videoPlaybackSpeed': 2, + 'enableThumbs': true, + 'enableStrictSSL': false, + 'enableSlowLoading': false, + 'isFullScreen': false, + 'reloadInMontage': false, + 'momentGridSize': 40, + 'momentMonitorFilter': [], + 'enableMomentSubMenu': true, + 'momentArrangeBy': 'StartTime', + 'showLiveForInProgressEvents': true, + 'disableSimulStreaming': false, + 'insertBasicAuthToken': false, + 'loginAPISupported': false, + 'montageResizeSteps': 5, + 'currentServerVersion': '', + 'saveToCloud': true, + 'montageReviewCollapse': true, + 'objectDetectionFilter': false, + + + }; + + var defaultLoginData = angular.copy(loginData); + + var configParams = { + 'ZM_EVENT_IMAGE_DIGITS': '-1', + 'ZM_PATH_ZMS': '', + 'ZM_MIN_STREAMING_PORT': '-1' + }; + + + /** + * Allows/Disallows self signed certs + * + * @returns + */ + function setCordovaHttpOptions() { + if (loginData.isUseBasicAuth) { + debug("Cordova HTTP: configuring basic auth"); + cordova.plugin.http.useBasicAuth(loginData.basicAuthUser, loginData.basicAuthPassword); + } + + if (!loginData.enableStrictSSL) { + + //alert("Enabling insecure SSL"); + log(">>>> Disabling strict SSL checking (turn off in Dev Options if you can't connect)"); + cordova.plugin.http.setSSLCertMode('nocheck', function () { + debug('--> SSL is permissive, will allow any certs. Use at your own risk.'); + }, function () { + console.log('-->Error setting SSL permissive'); + }); + + if ($rootScope.platformOS == 'android') { + log (">>> Android: enabling inline image view for self signed certs"); + cordova.plugins.certificates.trustUnsecureCerts(true); + } + + } else { + + log(">>>> Enabling strict SSL checking (turn off in Dev Options if you can't connect)"); + + } + } + + + /** + * Checks if a complex object is empty + * + * @param {any} obj + * @returns + */ + function isEmpty(obj) { + + // null and undefined are "empty" + if (obj == null) return true; + + // Assume if it has a length property with a non-zero value + // that that property is correct. + if (obj.length > 0) return false; + if (obj.length === 0) return true; + + // Otherwise, does it have any properties of its own? + // Note that this doesn't handle + // toString and valueOf enumeration bugs in IE < 9 + for (var key in obj) { + if (hasOwnProperty.call(obj, key)) return false; + } + + return true; + } + + function getBandwidth() { + // if mode is not on always return high + if (loginData.enableLowBandwidth == false) { + return "highbw"; + } + // if mode is force on, return low + if (loginData.enableLowBandwidth == true && loginData.autoSwitchBandwidth != true) { + return "lowbw"; + } + if (loginData.enableLowBandwidth == true && loginData.autoSwitchBandwidth == true && $rootScope.platformOS == 'desktop') { + return "highbw"; + } + // else return real state + + var networkState = navigator.connection.type; + var strState; + switch (networkState) { + + case Connection.WIFI: + strState = "highbw"; + break; + case Connection.ETHERNET: + strState = "highbw"; + break; + default: + strState = "lowbw"; + break; + + } + return strState; + } + + //-------------------------------------------------------------------------- + // uses fileLogger to write logs to file for later investigation + //-------------------------------------------------------------------------- + + // separate out a debug so we don't do this if comparison for normal logs + function debug(val) { + if (loginData.enableDebug && loginData.enableLogs) { + if (val !== undefined) { + var regex1 = /"password":".*?"/g; + var regex2 = /&pass=.*?(?=["&]|$)/g; + + //console.log ("VAL IS " + val); + val = val.replace(regex1, "<password removed>"); + val = val.replace(regex2, "<password removed>"); + } + + $ionicPlatform.ready(function () { + $fileLogger.debug(val); + }); + //console.log (val); + } + } + + + + + function getZmsMultiPortSupport(forceReload) { + var d = $q.defer(); + if (configParams.ZM_MIN_STREAMING_PORT == -1 || forceReload) { + log("Checking value of ZM_MIN_STREAMING_PORT for the first time"); + var apiurl = loginData.apiurl; + var myurl = apiurl + '/configs/viewByName/ZM_MIN_STREAMING_PORT.json'; + $http.get(myurl) + .then(function (data) { + data = data.data; + //console.log ("GOT " + JSON.stringify(data)); + + if (data.config && data.config.Value) { + configParams.ZM_MIN_STREAMING_PORT = data.config.Value; + setCurrentServerMultiPortSupported(true); + log("Got min streaming port value of: " + configParams.ZM_MIN_STREAMING_PORT); + } else { + setCurrentServerMultiPortSupported(false); + log("ZM_MIN_STREAMING_PORT not configure, disabling"); + configParams.ZM_MIN_STREAMING_PORT = 0; + } + + + d.resolve(configParams.ZM_MIN_STREAMING_PORT); + return (d.promise); + }, + function (err) { + configParams.ZM_MIN_STREAMING_PORT = 0; + log("ZM_MIN_STREAMING_PORT not supported"); + setCurrentServerMultiPortSupported(false); + d.resolve(configParams.ZM_MIN_STREAMING_PORT); + return (d.promise); + }); + } else { + log("sending Cached ZM_MIN_STREAMING_PORT " + + configParams.ZM_MIN_STREAMING_PORT); + d.resolve(configParams.ZM_MIN_STREAMING_PORT); + return (d.promise); + + } + return (d.promise); + + } + + + function getAuthKey(mid, ck) { + + var d = $q.defer(); + var myurl; + + if (!loginData.isUseAuth) { + $rootScope.authSession = ""; + d.resolve($rootScope.authSession); + return d.promise; + } + + if (loginData.currentServerVersion && (versionCompare(loginData.currentServerVersion, zm.versionWithLoginAPI) != -1 || loginData.loginAPISupported)) { + + myurl = loginData.apiurl + '/host/getCredentials.json'; + debug("Server version " + loginData.currentServerVersion + " > 1.31.41, so using getCredentials API:" + myurl); + $http.get(myurl) + .then(function (s) { + + debug("Credentials API returned: " + JSON.stringify(s)); + if (!s.data || !s.data.credentials) { + $rootScope.authSession = "undefined"; + d.resolve($rootScope.authSession); + debug("getCredentials() API Succeded, but did NOT return credentials key: " + JSON.stringify(s)); + return d.promise; + + } else { + $rootScope.authSession = "&" + s.data.credentials; + if (s.data.append_password == '1') { + $rootScope.authSession = $rootScope.authSession + + loginData.password; + } + d.resolve($rootScope.authSession); + return d.promise; + } + + }, + function (e) { + $rootScope.authSession = "undefined"; + d.resolve($rootScope.authSession); + debug("AuthHash API Error: " + JSON.stringify(e)); + return d.promise; + + } + ); + return d.promise; + + } + //old way without login API + + var as = 'undefined'; + + if (!mid && monitors && monitors.length > 0) { + mid = monitors[0].Monitor.Id; + } + + if (!mid) { + log("Deferring auth key, as monitorId unknown"); + d.resolve("undefined"); + $rootScope.authSession = as; + return (d.promise); + } + + // Skipping monitor number as I only need an auth key + // so no need to generate an image + myurl = loginData.url + "/index.php?view=watch&mid=" + mid; + debug("NVR: Getting auth from " + myurl + " with mid=" + mid); + $http.get(myurl) + .then(function (success) { + //console.log ("**** RESULT IS " + JSON.stringify(success)); + // Look for auth= + var auth = success.data.match("auth=(.*?)&"); + if (auth && (auth[1] != null)) { + log("NVR: Extracted a stream authentication key of: " + auth[1]); + as = "&auth=" + auth[1]; + $rootScope.authSession = as; + d.resolve(as); + } else { + log("NVR: Did not find a stream auth key, looking for user="); + auth = success.data.match("user=(.*?)&"); + if (auth && (auth[1] != null)) { + log("NVR: Found simple stream auth mode (user=)"); + as = "&user=" + loginData.username + "&pass=" + loginData.password; + $rootScope.authSession = as; + d.resolve(as); + } else { + log("Data Model: Did not find any stream mode of auth"); + as = ""; + $rootScope.authSession = ""; + d.resolve(as); + return d.promise; + } + + return (d.promise); + } + + }, + function (error) { + log("NVR: Error resolving auth key " + JSON.stringify(error)); + d.resolve("undefined"); + return (d.promise); + }); + return (d.promise); + + } + + function log(val, logtype) { + + + if (loginData.enableLogs) { + if (val !== undefined) { + var regex1 = /"password":".*?"/g; + var regex2 = /&pass=.*?(?=["&]|$)/g; + + //console.log ("VAL IS " + val); + val = val.replace(regex1, "<password removed>"); + val = val.replace(regex2, "<password removed>"); + + } + // make sure password is removed + //"username":"zmninja","password":"xyz", + //val = val.replace(/\"password:\", + $ionicPlatform.ready(function () { + $fileLogger.log(logtype, val); + }); + // console.log (val); + } + } + + function reloadMonitorDisplayStatus() { + debug("Loading hidden/unhidden status for profile:" + loginData.currentMontageProfile); + + var positionsStr = loginData.packeryPositions; + //console.log ("positionStr="+positionsStr); + var positions = {}; + if (loginData.packeryPositions != '' && loginData.packeryPositions != undefined) { + // console.log("positions=" + loginData.packeryPositions); + + + positions = JSON.parse(positionsStr); + for (var m = 0; m < monitors.length; m++) { + var positionFound = false; + for (var p = 0; p < positions.length; p++) { + if (monitors[m].Monitor.Id == positions[p].attr) { + monitors[m].Monitor.listDisplay = positions[p].display; + positionFound = true; + //debug("NVR: Setting MID:" + monitors[m].Monitor.Id + " to " + monitors[m].Monitor.listDisplay); + } + + } + if (!positionFound) { + if (loginData.currentMontageProfile != $translate.instant('kMontageDefaultProfile')) { + monitors[m].Monitor.listDisplay = 'noshow'; + //console.log("*************DISABLE NEW MONITOR"); + } else // make sure we add it because its show all view + { + monitors[m].Monitor.listDisplay = 'show'; + //console.log("*************ENABLE NEW MONITOR"); + } + + + } + + } + + } else // if there are no packery positions, make sure all are displayed! + { + debug("no packery profile, making sure monitors are show"); + for (var m1 = 0; m1 < monitors.length; m1++) { + monitors[m1].Monitor.listDisplay = 'show'; + + } + + + } + } + + function setLogin(newLogin) { + //var d = $q.defer(); + + // if we are here, we should remove cache + + + loginData = angular.copy(newLogin); + serverGroupList[loginData.serverName] = angular.copy(loginData); + + var ct = CryptoJS.AES.encrypt(JSON.stringify(serverGroupList), zm.cipherKey).toString(); + + //debug ("Crypto is: " + ct); + + return localforage.setItem("serverGroupList", ct) + .then(function () { + + return localforage.setItem("defaultServerName", loginData.serverName); + }) + .then(function () { + //debug("saving defaultServerName worked"); + return localforage.removeItem("settings-temp-data"); + }) + + .catch(function (err) { + log("SetLogin localforage store error " + JSON.stringify(err)); + }); + + + + + + } + + //credit: https://gist.github.com/alexey-bass/1115557 + function versionCompare(left, right) { + if (typeof left + typeof right != 'stringstring') + return false; + + var a = left.split('.'); + var b = right.split('.'); + var i = 0; + var len = Math.max(a.length, b.length); + + for (; i < len; i++) { + if ((a[i] && !b[i] && parseInt(a[i]) > 0) || (parseInt(a[i]) > parseInt(b[i]))) { + return 1; + } else if ((b[i] && !a[i] && parseInt(b[i]) > 0) || (parseInt(a[i]) < parseInt(b[i]))) { + return -1; + } + } + + return 0; + } + + //-------------------------------------------------------------------------- + // Banner display of messages + //-------------------------------------------------------------------------- + function displayBanner(mytype, mytext, myinterval, mytimer) { + + var contentBannerInstance = + $ionicContentBanner.show({ + text: mytext || 'no text', + interval: myinterval || 2000, + //autoClose: mytimer || 6000, + type: mytype || 'info', + transition: 'vertical', + //cancelOnStateChange: false + }); + + $timeout(function () { + contentBannerInstance(); + }, mytimer || 6000); + } + + function setCurrentServerMultiPortSupported(val) { + debug("Setting multi-port to:" + val); + currentServerMultiPortSupported = val; + } + + function setCurrentServerVersion(val) { + loginData.currentServerVersion = val; + setLogin(loginData); + debug("Setting server version to:" + val); + } + + + return { + + + insertBasicAuthToken: function () { + + return loginData.insertBasicAuthToken && $rootScope.basicAuthToken ? "&basicauth=" + $rootScope.basicAuthToken : ""; + + }, + + setCurrentServerMultiPortSupported: function (val) { + setCurrentServerMultiPortSupported(val); + }, + + setCurrentServerVersion: function (val) { + setCurrentServerVersion(val); + }, + + + getCurrentServerMultiPortSupported: function () { + return (currentServerMultiPortSupported); + }, + + isMultiPortDisabled: function () { + return loginData.disableSimulStreaming; + }, + + getCurrentServerVersion: function () { + return (loginData.currentServerVersion); + }, + + + //------------------------------------------------------------- + // used by various controllers to log messages to file + //------------------------------------------------------------- + + migrationComplete: function () { + migrationComplete = true; + }, + + isEmpty: function (obj) { + return isEmpty(obj); + }, + + log: function (val, type) { + var logtype = 'info'; + if (type != undefined) + logtype = type; + log(val, logtype); + + }, + + debug: function (val) { + + debug(val); + }, + + evaluateTappedNotification: function() { + + var state = ""; + var stateParams1 = {}; + var stateParams2 = {}; + + debug ("Inside evaluateNotifications"); + + if ($rootScope.tappedNotification == 2) { // url launch + debug("Came via app url launch with mid=" + $rootScope.tappedMid); + debug("Came via app url launch with eid=" + $rootScope.tappedEid); + + + if (parseInt($rootScope.tappedMid) > 0) { + debug("Going to live view "); + state = "app.monitors"; + + } else if (parseInt($rootScope.tappedEid) > 0) { + debug("Going to events with EID=" + $rootScope.tappedEid); + state = "app.events"; + stateParams1 = { + "id": 0, + "playEvent": true + }; + stateParams2 = { + reload: true + }; + + } + + + } // 2 + else if ($rootScope.tappedNotification == 1) // push + { + + + debug("Came via push tap. onTapScreen=" + loginData.onTapScreen); + if (loginData.onTapScreen == $translate.instant('kTapMontage')) { + debug("Going to montage"); + state = "app.montage"; + + + } else if (loginData.onTapScreen == $translate.instant('kTapEvents')) { + debug("Going to events"); + state = "app.events"; + stateParams1 = { + "id": 0, + "playEvent": true + }; + + } else // we go to live + { + debug("Going to live view "); + state = "app.monitors"; + + } + } + $rootScope.tappedNotification = 0; + return [state, stateParams1, stateParams2]; + }, + + setLastUpdateCheck: function (val) { + lastUpdateCheck = val; + localforage.setItem("lastUpdateCheck", lastUpdateCheck); + }, + + getLastUpdateCheck: function () { + return lastUpdateCheck; + }, + + setLatestBlogPostChecked: function (val) { + //console.log(">>>>>>>>>>>> Setting blog date: " + val); + latestBlogPostChecked = val; + localforage.setItem("latestBlogPostChecked", latestBlogPostChecked); + }, + + getLatestBlogPostChecked: function () { + return latestBlogPostChecked; + }, + + // This function is called when the app is ready to run + // sets up various variables + // including persistent login data for the ZM apis and portal + // The reason I need both is because as of today, there is no way + // to access images using the API and they are authenticated via + // the ZM portal authentication, which is pretty messy. But unless + // the ZM authors fix this and streamline the access of images + // from APIs, I don't have an option + + + + // used when an empty server profile is created + getDefaultLoginObject: function () { + return angular.copy(defaultLoginData); + }, + + getReachableConfig: function (skipFirst) { + var d = $q.defer(); + if (loginData.serverName == "") { + log("Reachable: No server name configured, likely first use?"); + d.reject("No servers"); + return d.promise; + } + + var chainURLs = []; + var savedLoginData = angular.copy(loginData); + + //log ("Making sure " + loginData.serverName + " is reachable..."); + var tLd = serverGroupList[loginData.serverName]; + if (skipFirst && tLd.fallbackConfiguration) { + tLd = serverGroupList[tLd.fallbackConfiguration]; + if (!tLd) { + d.reject("No available severs"); + loginData = savedLoginData; + return d.promise; + + } + } + + var keepBuilding = true; + while (keepBuilding == true && tLd) { + if (arrayObjectIndexOf(chainURLs, tLd.url + "/index.php?view=console", "url") == -1 && tLd.url !== undefined && tLd.url != '') // no loop + { + log("Adding to chain stack: " + tLd.serverName + ">" + tLd.url); + chainURLs.push({ + url: tLd.url + "/index.php?view=console", + server: tLd.serverName + }); + log("Fallback of " + tLd.serverName + " is " + tLd.fallbackConfiguration); + if (tLd.fallbackConfiguration) { + tLd = serverGroupList[tLd.fallbackConfiguration]; + if (tLd === undefined) { + // This can happen if the fallback profile was deleted + log("Looks like a server object was deleted, but is still in fallback"); + keepBuilding = false; + } + } else { + log("reached end of chain loop"); + } + } else { + log("detected loop when " + tLd.serverName + " fallsback to " + tLd.fallbackConfiguration); + keepBuilding = false; + } + } + + //contactedServers.push(loginData.serverName); + findFirstReachableUrl(chainURLs).then(function (firstReachableUrl) { + d.resolve(firstReachableUrl); + // also make sure loginData points to this now + + loginData = angular.copy(serverGroupList[firstReachableUrl.server]); + + setLogin(loginData); + //$localstorage.set("defaultServerName",firstReachableUrl.server); + + log("Based on reachability, first serverName will be " + firstReachableUrl.server); + //console.log("set login Data to " + JSON.stringify(loginData)); + + return d.promise; + // OK: do something with firstReachableUrl + }, function () { + d.reject("No servers reachable"); + loginData = savedLoginData; + return d.promise; + // KO: no url could be reached + }); + + function arrayObjectIndexOf(myArray, searchTerm, property) { + for (var i = 0, len = myArray.length; i < len; i++) { + if (myArray[i][property] === searchTerm) + return i; + } + return -1; + } + + function findFirstReachableUrl(urls) { + if (urls.length > 0 && $rootScope.userCancelledAuth != true) { + $ionicLoading.show({ + template: $translate.instant('kTrying') + ' ' + urls[0].server + }); + log("Reachability test.." + urls[0].url); + + if (loginData.reachability) { + + //console.log ("************* AUGH"); + var hDelay = loginData.enableSlowLoading ? zm.largeHttpTimeout : zm.httpTimeout; + return $http({ + method: 'GET', + timeout: hDelay, + url: urls[0].url + }).then(function () { + log("Success: reachability on " + urls[0].url); + $ionicLoading.hide(); + return urls[0]; + }, function (err) { + log("Failed reachability on " + urls[0].url + " with error " + JSON.stringify(err)); + return findFirstReachableUrl(urls.slice(1)); + }); + } else { + log("Reachability is disabled in config, faking this test and returning success on " + urls[0]); + return urls[0]; + } + } else { + $ionicLoading.hide(); + return $q.reject("No reachable URL"); + + } + + } + + return d.promise; + + }, + + cloudSync: function () { + + var d = $q.defer(); + if (!window.cordova) { + log("Cloud settings plugin not found, skipping cloud sync..."); + d.resolve(true); + return d.promise; + } + + /* window.cordova.plugin.cloudsettings.enableDebug(function(){ + console.log("Debug mode enabled"); + });*/ + + log("CloudSync: Syncing with cloud if enabled..."); + + var sgl = ""; + var decodedSgl = ""; + var dsn = ""; + + localforage.getItem("serverGroupList") + .then(function (_sgl) { + sgl = _sgl; + return localforage.getItem("defaultServerName"); + }) + .then(function (_dsn) { + dsn = _dsn; + return true; + }) + .then(function () { + if (sgl && dsn) { + + if (typeof sgl == 'string') { + log("user profile encrypted, decoding..."); + var bytes = CryptoJS.AES.decrypt(sgl.toString(), zm.cipherKey); + decodedSgl = JSON.parse(bytes.toString(CryptoJS.enc.Utf8)); + + } else { + decodedSgl = sgl; + } + + + var loadedData = decodedSgl[dsn]; + + if (!isEmpty(loadedData)) { + + if (!loadedData.saveToCloud) { + log("Cloud sync is disabled, exiting..."); + d.resolve(true); + return d.promise; + } + } + log("Found valid local configuration, overwriting cloud settings..."); + //console.log (">>>>>>>>>>>>>>SAVING: " + sgl + dsn); + window.cordova.plugin.cloudsettings.save({ + 'serverGroupList': sgl, + 'defaultServerName': dsn + }, + function () { + log("local data synced with cloud..."); + d.resolve(true); + return d.promise; + }, + function (err) { + log("error syncing cloud data..." + err); + d.resolve(true); + return d.promise; + }, true); + + } + // bad or missing local config + else { + log("Did not find a valid local configuration, trying cloud..."); + + window.cordova.plugin.cloudsettings.exists(function (exists) { + + if (exists) { + log("A cloud configuration has been found"); + window.cordova.plugin.cloudsettings.load(function (cloudData) { + //console.log("CLOUD DATA FOUND" + JSON.stringify(cloudData)); + // debug("Cloud data retrieved is:" + JSON.stringify(cloudData)); + if (cloudData && cloudData.defaultServerName && cloudData.serverGroupList) { + log("retrieved a valid cloud config with a defaultServerName of:" + cloudData.defaultServerName); + log("replacing local DB with cloud..."); + localforage.setItem('isFirstUse', false) + .then(function () { + log("cleared first use"); + return localforage.setItem("defaultServerName", cloudData.defaultServerName); + }) + .then(function () { + log("saved defaultServerName"); + return localforage.setItem("serverGroupList", cloudData.serverGroupList); + }) + .then(function () { + log("saved serverGroupList, returning from cloudSync()"); + d.resolve(true); + return d.promise; + }); + + + } + // cloud did not have (useable)data + else { + log("Did not find a valid cloud config"); + d.resolve(true); + return d.promise; + } + + }); + } else { + log("Cloud data does not exist"); + d.resolve(true); + return d.promise; + } + }); + + } + }); + + + return d.promise; + + }, + + init: function () { + + + log("ZMData init: checking for stored variables & setting up log file"); + + localforage.getItem("latestBlogPostChecked") + .then(function (val) { + latestBlogPostChecked = val; + }, + function (err) { + latestBlogPostChecked = null; + }); + + + $ionicLoading.show({ + template: $translate.instant('kRetrievingProfileData'), + }); + + localforage.getItem("serverGroupList").then(function (val) { + // decrypt it now + + var decodedVal; + + if (typeof val == 'string') { + log("user profile encrypted, decoding..."); + var bytes = CryptoJS.AES.decrypt(val.toString(), zm.cipherKey); + decodedVal = JSON.parse(bytes.toString(CryptoJS.enc.Utf8)); + + } else { + log("user profile not encrypted"); + decodedVal = val; + } + + //decodedVal = val; + + // debug("user profile retrieved:" + JSON.stringify(decodedVal)); + + $ionicLoading.hide(); + serverGroupList = decodedVal; + + var sname; + $ionicLoading.show({ + template: $translate.instant('kRetrievingProfileData'), + }); + localforage.getItem("defaultServerName") + .then(function (val) { + $ionicLoading.hide(); + //console.log ("!!!!!!!!!!!!!!!!!!default server name is " + sname); + sname = val; + // console.log("!!!!!!!!!!!!!!!!!!!Got VAL " + sname); + var loadedData = serverGroupList[sname]; + // console.log(">>>>>>>>>>> loadedData is: " + JSON.stringify(loadedData)); + if (!isEmpty(loadedData)) { + loginData = loadedData; + + // old version hacks for new variables + + // always true Oct 27 2016 + loginData.persistMontageOrder = true; + loginData.enableh264 = true; + + if (typeof loginData.isUseBasicAuth === 'undefined') { + loginData.isUseBasicAuth = false; + loginData.basicAuthUser = ''; + loginData.basicAuthPassword = ''; + $rootScope.basicAuthHeader = ''; + $rootScope.basicAuthToken = ''; + } + + if (loginData.url.indexOf('@') != -1) { + log(">> " + loginData.url); + log(">>User/Password detected in URL, changing to new auth handling..."); + loginData.isUseBasicAuth = true; + + var components = URI.parse(loginData.url); + loginData.url = components.scheme + "://" + components.host; + if (components.port) loginData.url = loginData.url + ":" + components.port; + if (components.path) loginData.url = loginData.url + components.path; + + components = URI.parse(loginData.streamingurl); + loginData.streamingurl = components.scheme + "://" + components.host; + if (components.port) loginData.streamingurl = loginData.streamingurl + ":" + components.port; + if (components.path) loginData.streamingurl = loginData.streamingurl + components.path; + + + components = URI.parse(loginData.apiurl); + loginData.apiurl = components.scheme + "://" + components.host; + if (components.port) loginData.apiurl = loginData.apiurl + ":" + components.port; + if (components.path) loginData.apiurl = loginData.apiurl + components.path; + + $rootScope.basicAuthToken = btoa(components.userinfo); + $rootScope.basicAuthHeader = 'Basic ' + $rootScope.basicAuthToken; + //console.log (">>>> SET BASIC AUTH TO " + $rootScope.basicAuthHeader); + + var up = components.userinfo.split(':'); + loginData.basicAuthPassword = up[1]; + loginData.basicAuthUser = up[0]; + //console.log ("SETTING "+loginData.basicAuthUser+" "+loginData.basicAuthPassword); + + } + + if (loginData.isUseBasicAuth) { + $rootScope.basicAuthToken = btoa(loginData.basicAuthUser + ':' + loginData.basicAuthPassword); + $rootScope.basicAuthHeader = 'Basic ' + $rootScope.basicAuthToken; + debug("Basic authentication detected, constructing Authorization Header"); + + // console.log ("BASIC AUTH SET TO:"+$rootScope.basicAuthHeader); + + } + + + if (typeof loginData.enableAlarmCount === 'undefined') { + debug("enableAlarmCount does not exist, setting to true"); + loginData.enableAlarmCount = true; + } + + if (typeof loginData.onTapScreen == 'undefined') { + loginData.onTapScreen = $translate.instant('kTapMontage'); + } + + if (loginData.onTapScreen != $translate.instant('kTapMontage') && + loginData.onTapScreen != $translate.instant('kTapEvents') && + loginData.onTapScreen != $translate.instant('kTapLiveMonitor')) { + log("Invalid onTap setting found, resetting. I got " + loginData.onTapScreen); + loginData.onTapScreen = $translate.instant('kMontage'); + } + + if (typeof loginData.minAlarmCount === 'undefined') { + debug("minAlarmCount does not exist, setting to true"); + loginData.minAlarmCount = 1; + } + + if (typeof loginData.montageSize == 'undefined') { + debug("montageSize does not exist, setting to 2 (2 per col)"); + loginData.montageSize = 2; + } + + if (typeof loginData.useNphZms == 'undefined') { + debug("useNphZms does not exist. Setting to true"); + loginData.useNphZms = true; + } + + if (typeof loginData.useNphZmsForEvents == 'undefined') { + debug("useNphZmsForEvents does not exist. Setting to true"); + loginData.useNphZmsForEvents = true; + } + + if (typeof loginData.forceImageModePath == 'undefined') { + debug("forceImageModePath does not exist. Setting to false"); + loginData.forceImageModePath = false; + } + + if (typeof loginData.reachability == 'undefined') { + debug("reachability does not exist. Setting to true"); + loginData.reachability = true; + } + + + // force it - this may not be the problem + loginData.reachability = true; + + // and now, force enable it + loginData.useNphZms = true; + loginData.useNphZmsForEvents = true; + + if (typeof loginData.packMontage == 'undefined') { + debug("packMontage does not exist. Setting to false"); + loginData.packMontage = false; + } + + if (typeof loginData.forceNetworkStop == 'undefined') { + debug("forceNetwork does not exist. Setting to false"); + loginData.forceNetworkStop = false; + } + + if (typeof loginData.enableLogs == 'undefined') { + debug("enableLogs does not exist. Setting to true"); + loginData.enableLogs = true; + } + + if (typeof loginData.defaultPushSound == 'undefined') { + debug("defaultPushSound does not exist. Setting to false"); + loginData.defaultPushSound = false; + } + + + //console.log("INIT SIMUL=" + loginData.disableSimulStreaming); + //console.log("INIT PLATFORM IS=" + $rootScope.platformOS); + if (typeof loginData.disableSimulStreaming == 'undefined') { + + + loginData.disableSimulStreaming = false; + //console.log("INIT DISABLING SIMUL:" + loginData.disableSimulStreaming); + } + + + if (typeof loginData.exitOnSleep == 'undefined') { + debug("exitOnSleep does not exist. Setting to false"); + loginData.exitOnSleep = false; + } + + if (typeof loginData.enableBlog == 'undefined') { + debug("enableBlog does not exist. Setting to true"); + loginData.enableBlog = true; + + } + + if (typeof loginData.packeryPositionsArray == 'undefined') { + debug("packeryPositionsArray does not exist. Setting to empty"); + loginData.packeryPositionsArray = {}; + + } + + + if (typeof loginData.packeryPositions == 'undefined') { + debug("packeryPositions does not exist. Setting to empty"); + loginData.packeryPositions = ""; + + } + + if (typeof loginData.EHpackeryPositions == 'undefined') { + debug("EHpackeryPositions does not exist. Setting to empty"); + loginData.EHpackeryPositions = ""; + + } + + if (typeof loginData.packerySizes == 'undefined') { + debug("packerySizes does not exist. Setting to empty"); + loginData.packerySizes = ""; + + } + + if (typeof loginData.use24hr == 'undefined') { + debug("use24hr does not exist. Setting to false"); + loginData.use24hr = false; + + } + + if (typeof timelineModalGraphType == 'undefined') { + debug("timeline graph type not set. Setting to all"); + loginData.timelineModalGraphType = $translate.instant('kGraphAll'); + //console.log(">>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>" + loginData.timelineModalGraphType); + } + + if (typeof loginData.resumeDelay == 'undefined') { + debug("resumeDelay does not exist. Setting to 0"); + loginData.resumeDelay = 0; + + } + // override resumeDelay - it was developed on a wrong assumption + loginData.resumeDelay = 0; + + if (typeof loginData.montageHistoryQuality == 'undefined') { + debug("montageHistoryQuality does not exist. Setting to 50"); + loginData.montageHistoryQuality = "50"; + + } + + + + if (typeof loginData.vibrateOnPush == 'undefined') { + debug("vibrate on push not found, setting to true"); + loginData.vibrateOnPush = true; + + } + + if (typeof loginData.isFullScreen == 'undefined') { + + loginData.isFullScreen = false; + + } + + if (typeof loginData.reloadInMontage == 'undefined') { + + loginData.reloadInMontage = false; + + } + + if (typeof loginData.soundOnPush == 'undefined') { + debug("sound on push not found, setting to true"); + loginData.soundOnPush = true; + + } + + if (typeof loginData.cycleMonitors == 'undefined') { + + loginData.cycleMonitors = false; + + } + + if (typeof loginData.cycleMonitorsInterval == 'undefined') { + + loginData.cycleMonitorsInterval = 10; + + } + + if (typeof loginData.cycleMontage == 'undefined') { + + loginData.cycleMontage = false; + + } + + if (typeof loginData.cycleMontageInterval == 'undefined') { + + loginData.cycleMontageInterval = 10; + + } + + if (typeof loginData.enableLowBandwidth == 'undefined') { + + loginData.enableLowBandwidth = false; + + } + // wtf is wrong with this ternary? + //$rootScope.runMode = (loginData.enableLowBandwith==true)? "low": "normal"; + + if (typeof loginData.autoSwitchBandwidth == 'undefined') { + + loginData.autoSwitchBandwidth = false; + + } + + $rootScope.runMode = getBandwidth(); + log("Setting NVR init bandwidth to: " + $rootScope.runMode); + + if (typeof loginData.refreshSecLowBW == 'undefined') { + + loginData.refreshSecLowBW = 8; + + } + + if (typeof loginData.disableAlarmCheckMontage == 'undefined') { + + loginData.disableAlarmCheckMontage = false; + + } + + if (typeof loginData.useLocalTimeZone == 'undefined') { + + loginData.useLocalTimeZone = true; + + } + + if (typeof loginData.fastLogin == 'undefined') { + + loginData.fastLogin = true; + + } + + if (typeof loginData.currentMontageProfile == 'undefined') { + + loginData.currentMontageProfile = ''; + + } + + if (typeof loginData.followTimeLine == 'undefined') { + + loginData.followTimeLine = false; + + } + + if (typeof loginData.timelineScale == 'undefined') { + + loginData.timelineScale = -1; + + } + + + if (typeof loginData.showMontageSubMenu == 'undefined') { + + loginData.showMontageSubMenu = false; + + } + + + + if (typeof loginData.monSingleImageQuality == 'undefined') { + + loginData.monSingleImageQuality = 100; + + } + + if (typeof loginData.hideArchived == 'undefined') { + + loginData.hideArchived = false; + + } + + if (typeof loginData.videoPlaybackSpeed == 'undefined') { + + loginData.videoPlaybackSpeed = 2; + + } + + + + if (typeof loginData.enableThumbs == 'undefined') { + + loginData.enableThumbs = true; + + } + + if (typeof loginData.enableSlowLoading == 'undefined') { + + loginData.enableSlowLoading = false; + + } + + + if (typeof loginData.enableStrictSSL == 'undefined') { + + loginData.enableStrictSSL = false; + + } + + if (typeof loginData.momentGridSize == 'undefined') { + + loginData.momentGridSize = 40; + + } + + if (typeof loginData.enableMomentSubMenu == 'undefined') { + + loginData.enableMomentSubMenu = true; + + } + + if (typeof loginData.momentMonitorFilter == 'undefined') { + + loginData.momentMonitorFilter = JSON.stringify([]); + + } + + + if (typeof loginData.momentArrangeBy == 'undefined') { + + loginData.momentArrangeBy = "StartTime"; + + } + + if (typeof loginData.insertBasicAuthToken == 'undefined') { + + loginData.insertBasicAuthToken = false; + + } + + + if (typeof loginData.showLiveForInProgressEvents == 'undefined') { + + loginData.showLiveForInProgressEvents = true; + + } + + + if (typeof loginData.loginAPISupported == 'undefined') { + + loginData.loginAPISupported = false; + + } + + if (typeof loginData.montageResizeSteps == 'undefined') { + + loginData.montageResizeSteps = 5; + + } + + if (typeof loginData.saveToCloud == 'undefined') { + + loginData.saveToCloud = true; + + } + + + + if (typeof loginData.montageReviewCollapse == 'undefined') { + + loginData.montageReviewCollapse = true; + + } + + if (typeof loginData.objectDetectionFilter == 'undefined') { + + loginData.objectDetectionFilter = false; + + } + + + loginData.canSwipeMonitors = true; + loginData.forceImageModePath = false; + loginData.enableBlog = true; + + log("NVR init retrieved store loginData"); + } else { + log("defaultServer configuration NOT found. Keeping login at defaults"); + } + + + // from local forage + if (window.cordova) setCordovaHttpOptions(); + + + + $rootScope.$broadcast('init-complete'); + }); + + monitorsLoaded = 0; + //console.log("Getting out of NVR init"); + $rootScope.showBlog = loginData.enableBlog; + //debug("loginData structure values: " + JSON.stringify(loginData)); + + }); + + }, + + isForceNetworkStop: function () { + return loginData.forceNetworkStop; + }, + + setJustResumed: function (val) { + justResumed = val; + if (val) { + timeSinceResumed = moment(); + } + }, + + getTimeSinceResumed: function () { + // will be -1 if never resumed + return timeSinceResumed; + }, + + stopNetwork: function (str) { + var d = $q.defer(); + var s = ""; + if (str) s = str + ":"; + if (justResumed) { + // we don't call stop as we did stop on pause + log(s + " Not calling window stop as we just resumed"); + d.resolve(true); + return (d.promise); + + } else { + log(s + " stopNework: Calling window.stop()"); + $timeout(function () { + window.stop(); + d.resolve(true); + return (d.promise); + }); + + } + return d.promise; + }, + + hasLoginInfo: function () { + + if ((loginData.username != "" && loginData.password != "" && loginData.url != "" && + loginData.apiurl != "") || (loginData.isUseAuth != '1')) { + return 1; + } else { + + return 0; + + } + }, + + getLanguages: function () { + return languages; + }, + + setDefaultLanguage: function (l, permanent) { + + if (!l) l = 'en'; + defaultLang = l; + var d = $q.defer(); + if (permanent) { + //window.localStorage.setItem("defaultLang", l); + + //console.log("setting default lang"); + localforage.setItem("defaultLang", l) + .then(function (val) { + log("Set language in localforage to: " + val); + }); + } + + //console.log("invoking translate use with " + l); + $translate.use(l).then(function (data) { + log("Device Language is:" + data); + moment.locale(data); + $translate.fallbackLanguage('en'); + d.resolve(data); + return d.promise; + }, function (error) { + log("Device Language error: " + error); + $translate.use('en'); + moment.locale('en'); + d.resolve('en'); + return d.promise; + }); + return d.promise; + }, + + getDefaultLanguage: function () { + return defaultLang; + //return window.localStorage.getItem("defaultLang"); + + }, + + reloadMonitorDisplayStatus: function () { + return reloadMonitorDisplayStatus(); + }, + + getLogin: function () { + + return angular.copy(loginData); + }, + + getServerGroups: function () { + return angular.copy(serverGroupList); + }, + + setServerGroups: function (sg) { + serverGroupList = angular.copy(sg); + }, + + getKeepAwake: function () { + return (loginData.keepAwake == '1') ? true : false; + }, + + setAppVersion: function (ver) { + zmAppVersion = ver; + }, + + getAppVersion: function () { + return (zmAppVersion); + }, + + setBackground: function (val) { + isBackground = val; + }, + + isBackground: function () { + return isBackground; + }, + + isFirstUse: function () { + // console.log("isFirstUse is " + isFirstUse); + return isFirstUse; + // return ((window.localStorage.getItem("isFirstUse") == undefined) ? true : false); + + }, + + updateHrsSinceChecked: function (key) { + var tnow = moment(); + debug("Updating " + key + " to " + JSON.stringify(tnow)); + localforage.setItem(key, JSON.stringify(tnow)); + }, + + hrsSinceChecked: function (key) { + var tnow = moment(); + var d = $q.defer(); + + localforage.getItem(key) + .then(function (val) { + if (val == null) { + // doesn't exist + localforage.setItem(key, JSON.stringify(tnow)); + debug(key + " doesn't exist, storing it as:" + tnow); + d.resolve(365 * 12 * 24); + return (d.promise); + } else { + val = JSON.parse(val); + var duration = moment.duration(tnow.diff(val)).asHours().toFixed(1); + debug("It has been " + duration + " hours since " + key + " was checked"); + d.resolve(duration); + return (d.promise); + } + return (d.promise); + + }, + function (err) { + debug("Hmm? hrsSinceCheck failed"); + d.resolve(365 * 12 * 24); + return d.promise; + } + ); + return d.promise; + + }, + + versionCompare: function (l, r) { + return versionCompare(l, r); + }, + + //----------------------------------------------------------------- + // Allow the option to reset first use if I need it in future + //----------------------------------------------------------------- + setFirstUse: function (val) { + //window.localStorage.setItem("isFirstUse", val ? "1" : "0"); + //localforage.setItem("isFirstUse", val, + // function(err) {if (err) log ("localforage error, //storing isFirstUse: " + JSON.stringify(err));}); + isFirstUse = val; + debug("Setting isFirstUse to:" + val); + localforage.setItem("isFirstUse", val) + .then(function (succ) { + debug("Saved isFirstUse ok"); + }) + .catch(function (err) { + debug("Error Saving isFirstUse:" + JSON.stringify(err)); + }); + //console.log (">>>>>>setting isFirstUse to " + val); + + }, + + getTimeFormat: function () { + return (loginData.use24hr ? "HH:mm" : "hh:mm a"); + }, + + getTimeFormatSec: function () { + return (loginData.use24hr ? "HH:mm:ss" : "hh:mm:ss a"); + }, + + //------------------------------------------------------------------ + // switches screen to 'always on' or 'auto' + //------------------------------------------------------------------ + setAwake: function (val) { + + //console.log ("**** setAwake called with:" + val); + // log("Switching screen always on to " + val); + if (val) { + + if (window.cordova != undefined) { + window.plugins.insomnia.keepAwake(); + } else { + //console.log ("Skipping insomnia, cordova does not exist"); + } + } else { + if (window.cordova != undefined) { + window.plugins.insomnia.allowSleepAgain(); + } else { + //console.log ("Skipping insomnia, cordova does not exist"); + } + + } + + }, + + //-------------------------------------------------------------------------- + // writes all params to local storage. FIXME: Move all of this into a JSON + // object + //-------------------------------------------------------------------------- + setLogin: function (newLogin) { + + $rootScope.showBlog = newLogin.enableBlog; + return setLogin(newLogin); + + + }, + + //------------------------------------------------------- + // returns API version or none + //------------------------------------------------------- + getAPIversion: function () { + + var d = $q.defer(); + var apiurl = loginData.apiurl + '/host/getVersion.json'; + debug("getAPIversion called with " + apiurl); + $http.get(apiurl) + .then(function (success) { + if (success.data.version) { + console.log ("API VERSION RETURNED: " + JSON.stringify(success)); + $rootScope.apiValid = true; + + if (versionCompare(success.data.version, '1.31.0') != -1 ) { + debug ("snapshot supported in image.php"); + snapshotFrame = 'snapshot'; + } + else { + debug ("snapshot NOT supported in image.php"); + snapshotFrame = 1; + } + setCurrentServerVersion(success.data.version); + debug("getAPI version succeeded with " + success.data.version); + d.resolve(success.data.version); + } else { + debug("Setting APIValid to false as API version was not retrieved"); + $rootScope.apiValid = false; + setCurrentServerVersion(""); + d.reject("-1.-1.-1"); + } + return (d.promise); + + }, + function (error) { + debug("getAPIversion error handler " + JSON.stringify(error)); + d.reject("-1.-1.-1"); + setCurrentServerVersion(""); + $rootScope.apiValid = false; + return (d.promise); + }); + return (d.promise); + + }, + + displayBanner: function (mytype, mytext, myinterval, mytimer) { + displayBanner(mytype, mytext, myinterval, mytimer); + }, + + isReCaptcha: function () { + // always resolves + var d = $q.defer(); + + var myurl = loginData.url; + log("Checking if reCaptcha is enabled in ZM..."); + // console.log ("Recaptcha: "+myurl); + $http.get(myurl) + .then(function (success) { + // console.log ("Inside recaptcha success"); + if (success.data.search("g-recaptcha") != -1) { + // recaptcha enable. zmNinja won't work + log("ZM has recaptcha enabled", "error"); + displayBanner('error', ['Recaptcha must be disabled in Zoneminder', $rootScope.appName + ' will not work with recaptcha'], "", 8000); + d.resolve(true); + return (d.promise); + + } else { + d.resolve(false); + log("ZM has recaptcha disabled - good"); + return (d.promise); + } + }, + function (err) { + // for whatever reason recaptcha check failed + // console.log ("Inside recaptcha fail"); + d.resolve(false); + log("Recaptcha failed, but assuming ZM has recaptcha disabled"); + return (d.promise); + }); + return (d.promise); + }, + + //----------------------------------------------------------------------------- + // Grabs the computed auth key for streaming + // FIXME: Currently a hack - does a screen parse - convert to API based support + //----------------------------------------------------------------------------- + + // need a mid as restricted users won't be able to get + // auth with just &watch + getAuthKey: function (mid, ck) { + return getAuthKey(mid, ck); + }, + + //----------------------------------------------------------------------------- + // This function tells is if this ZM version has ZMS multiport support + //----------------------------------------------------------------------------- + + clearZmsMultiPortSupport: function () { + debug("Clearing Multiport..."); + configParams.ZM_MIN_STREAMING_PORT = -1; + }, + + getZmsMultiPortSupport: function () { + // 0 => not supported + // >=1 => supported + // -1 => haven't checked - should never be returned + + return getZmsMultiPortSupport(); + + }, + + + //----------------------------------------------------------------------------- + // This function returns the numdigits for padding capture images + //----------------------------------------------------------------------------- + + + getAuthHashLogin: function () { + + return $http.get(loginData.apiurl + '/configs/viewByName/ZM_AUTH_HASH_LOGINS.json'); + + }, + + getKeyConfigParams: function (forceReload) { + + var d = $q.defer(); + + if (forceReload == 1 || configParams.ZM_EVENT_IMAGE_DIGITS == '-1') { + var apiurl = loginData.apiurl; + var myurl = apiurl + '/configs/viewByName/ZM_EVENT_IMAGE_DIGITS.json'; + //debug("Config URL for digits is:" + myurl); + $http.get(myurl) + .then(function (data) { + data = data.data; + log("ZM_EVENT_IMAGE_DIGITS is " + data.config.Value); + configParams.ZM_EVENT_IMAGE_DIGITS = data.config.Value; + d.resolve(configParams.ZM_EVENT_IMAGE_DIGITS); + return (d.promise); + + }, function (err) { + log("Error retrieving ZM_EVENT_IMAGE_DIGITS" + JSON.stringify(err), "error"); + log("Taking a guess, setting ZM_EVENT_IMAGE_DIGITS to 5"); + // FIXME: take a plunge and keep it at 5? + configParams.ZM_EVENT_IMAGE_DIGITS = 5; + d.resolve(configParams.ZM_EVENT_IMAGE_DIGITS); + return (d.promise); + }); + } else { + // log("ZM_EVENT_IMAGE_DIGITS is already configured for " + + // configParams.ZM_EVENT_IMAGE_DIGITS); + d.resolve(configParams.ZM_EVENT_IMAGE_DIGITS); + return (d.promise); + } + return (d.promise); + + }, + + //-------------------------------------------------------------------------- + // Useful to know what ZMS is using as its cgi-bin. If people misconfigure + // the setting in the app, they can check their logs + //-------------------------------------------------------------------------- + getPathZms: function () { + var d = $q.defer(); + + + var apiurl = loginData.apiurl; + var myurl = apiurl + '/configs/viewByName/ZM_PATH_ZMS.json'; + debug("Config URL for ZMS PATH is:" + myurl); + $http.get(myurl) + .then(function (data) { + + data = data.data; + //console.log (">>>> GOT: "+JSON.stringify(data)); + configParams.ZM_PATH_ZMS = data.config.Value; + d.resolve(configParams.ZM_PATH_ZMS); + return (d.promise); + }, + function (error) { + log("Can't retrieving ZM_PATH_ZMS: " + JSON.stringify(error)); + d.resolve(""); + return (d.promise); + }); + return (d.promise); + + }, + //-------------------------------------------------------------------------- + // returns high or low BW mode + //-------------------------------------------------------------------------- + getBandwidth: function () { + return getBandwidth(); + }, + + getSnapshotFrame: function () { + return snapshotFrame; + }, + + //----------------------------------------------------------------------------- + // This function returns a list of monitors + // if forceReload == 1 then it will force an HTTP API request to get a list of monitors + // if 0. then it will return back the previously loaded monitor list if one exists, else + // will issue a new HTTP API to get it + + // I've wrapped this function in my own promise even though http returns a promise. + //----------------------------------------------------------------------------- + // + + // returns a non promise version + // so if monitors is null, it will return null + // As of now, this is only used by EventServer.js to + // send the right list of monitors after registration + // token + getMonitorsNow: function () { + return monitors; + }, + + pauseLiveStream: function (ck, url, name) { + if (!url) url = loginData.url; + + var myauthtoken = $rootScope.authSession.replace("&auth=", ""); + var req = url + '/index.php'; + req = req + "?view=request&request=stream"; + req = req + "&connkey=" + ck; + req = req + "&auth=" + myauthtoken; + // req = req + "&command=17"; + + debug("NVR: Pausing live stream ck:" + ck + " for " + name + " url:" + url); + return $http.get(req + "&command=1") + .then( + function (s) { + // debug("pause success for ck:" + ck ); + + }, + function (e) { + // debug("pause error for ck:" + ck + " with:" + JSON.stringify(e)); + } + ); + + }, + + resumeLiveStream: function (ck, url, name) { + if (!url) url = loginData.url; + + var myauthtoken = $rootScope.authSession.replace("&auth=", ""); + var req = url + '/index.php'; + req = req + "?view=request&request=stream"; + req = req + "&connkey=" + ck; + req = req + "&auth=" + myauthtoken; + // req = req + "&command=17"; + + debug("NVR: Resuming live stream ck:" + ck + " for " + name); + return $http.get(req + "&command=2") + .then( + function (s) { + // debug("play success for ck:" + ck + " with:" + JSON.stringify(s)); + + }, + function (e) { + // debug("play error for ck:" + ck + " with:" + JSON.stringify(e)); + } + ); + + }, + + killLiveStream: function (ck, url, name) { + + if (!url) url = loginData.url; + + var myauthtoken = $rootScope.authSession.replace("&auth=", ""); + var req = url + '/index.php'; + req = req + "?view=request&request=stream"; + req = req + "&connkey=" + ck; + req = req + "&auth=" + myauthtoken; + // req = req + "&command=17"; + if (name == undefined) name = ""; + debug("NVR: killing " + name + " live stream ck:" + ck); + return $http.get(req + "&command=17") + .then( + function (s) { + // debug ("kill success for ck:"+ck+" with:"+JSON.stringify(s)); + + }, + function (e) { //debug ("kill success for ck:"+ck+" with:"+JSON.stringify(e)); + } + ); + }, + + /*killStream: function (ck) { + debug ("Killing connKey: "+ck); + var myauthtoken = $rootScope.authSession.replace("&auth=", ""); + var req = $http( + { + method: 'POST', + + url: loginData.url + '/index.php', + headers: + { + 'Content-Type': 'application/x-www-form-urlencoded', + , + }, + transformRequest: function(obj) + { + var str = []; + for (var p in obj) + str.push(encodeURIComponent(p) + "=" + + encodeURIComponent(obj[p])); + var foo = str.join("&"); + //console.log("****RETURNING " + foo); + return foo; + }, + + data: + { + view: "request", + request: "stream", + connkey: ck, + command: 3, + auth: myauthtoken, + + } + }) + .then (function (succ) { + console.log ("STOP/KILL OK WITH: " + JSON.stringify(succ)); + }, + function (err) { + console.log ("KILL ERROR WITH: " + JSON.stringify(err)); + }); + + + },*/ + + getMultiServersCached: function () { + return multiservers; + }, + + // use non cached for daemon status + getMultiServers: function () { + return $http.get (loginData.apiurl+'/servers.json'); + + }, + + getMultiServer: function (id) { + + var ndx = -1; + for (var i=0; i < multiservers.length; i++) { + if (multiservers[i].Server.Id == id) { + ndx = i; + break; + } + } + return ndx == -1 ? {}:multiservers[ndx]; + + }, + + regenConnKeys: function () { + + debug("NVR: Regenerating connkeys..."); + for (var i = 0; i < monitors.length; i++) { + monitors[i].Monitor.connKey = (Math.floor((Math.random() * 999999) + 1)).toString(); + monitors[i].Monitor.rndKey = (Math.floor((Math.random() * 999999) + 1)).toString(); + } + }, + + getMonitors: function (forceReload) { + //console.log("** Inside ZMData getMonitors with forceReload=" + forceReload); + + $ionicLoading.show({ + template: $translate.instant('kLoadingMonitors'), + animation: 'fade-in', + showBackdrop: false, + duration: zm.loadingTimeout, + maxWidth: 200, + showDelay: 0 + }); + + var d = $q.defer(); + if ((monitorsLoaded == 0) || (forceReload == 1)) // monitors are empty or force reload + { + //console.log("NVR: Invoking HTTP get to load monitors"); + log((forceReload == 1) ? "getMonitors:Force reloading all monitors" : "getMonitors:Loading all monitors"); + var apiurl = loginData.apiurl; + var myurl = apiurl + "/monitors"; + myurl += "/index/Type !=:WebSite.json"; + + getZmsMultiPortSupport() + .then(function (zmsPort) { + + var controlURL = ""; + + debug("ZMS Multiport reported: " + zmsPort); + debug("Monitor URL to fetch is:" + myurl); + $http.get(myurl /*,{timeout:15000}*/ ) + .then(function (data) { + // console.log("HTTP success got " + JSON.stringify(data.monitors)); + data = data.data; + if (data.monitors) monitors = data.monitors; + + + if ($rootScope.authSession == 'undefined') { + log("Now that we have monitors, lets get AuthKey..."); + getAuthKey(monitors[0].Monitor.Id, (Math.floor((Math.random() * 999999) + 1)).toString()); + } + monitors.sort(function (a, b) { + return parseInt(a.Monitor.Sequence) - parseInt(b.Monitor.Sequence); + }); + //console.log("promise resolved inside HTTP success"); + monitorsLoaded = 1; + + reloadMonitorDisplayStatus(); + + debug("Inside getMonitors, will also regen connkeys"); + debug("Now trying to get multi-server data, if present"); + $http.get(apiurl + "/servers.json") + .then(function (data) { + data = data.data; + // We found a server list API, so lets make sure + // we get the hostname as it will be needed for playback + log("multi server list loaded:" + JSON.stringify(data)); + multiservers = data.servers; + + var multiserver_scheme = "http://"; + //console.log ("PORTAL URL IS:"+loginData.url); + if (loginData.url && (loginData.url.toLowerCase().indexOf("https://") != -1)) { + debug("Portal scheme is https, will use https for any multi-server"); + multiserver_scheme = "https://"; + } + debug("multi-server protocol will be:" + multiserver_scheme); + + for (var i = 0; i < monitors.length; i++) { + + // make them all show for now + + var recordingType = ''; + if (monitors[i].Monitor.SaveJPEGs>0) { + recordingType = $translate.instant('kImages'); + } + if (monitors[i].Monitor.VideoWriter > 0) { + if (recordingType.length) recordingType +=" + "; + recordingType = recordingType + $translate.instant('kVideo') + " ("; + recordingType = recordingType + ( monitors[i].Monitor.VideoWriter == 1 ? $translate.instant('kMonitorVideoEncode'): $translate.instant('kMonitorVideoPassThru')) + ")"; + } + + // in 1.30.4 these fields did not exist + + monitors[i].Monitor.recordingType = recordingType ? recordingType : $translate.instant ('kImages'); + monitors[i].Monitor.listDisplay = 'show'; + monitors[i].Monitor.isAlarmed = false; + monitors[i].Monitor.connKey = (Math.floor((Math.random() * 999999) + 1)).toString(); + monitors[i].Monitor.rndKey = (Math.floor((Math.random() * 999999) + 1)).toString(); + + var serverFound = false; + for (var j = 0; j < multiservers.length; j++) { + //console.log ("Comparing " + multiservers[j].Server.Id + " AND " + monitors[i].Monitor.ServerId); + if (multiservers[j].Server.Id == monitors[i].Monitor.ServerId) { + //console.log ("Found match"); + serverFound = true; + break; + } + + } + if (serverFound) { + if (!/^https?:\/\//i.test(multiservers[j].Server.Hostname)) { + multiservers[j].Server.Hostname = multiserver_scheme + multiservers[j].Server.Hostname; + } + + // debug("Monitor " + monitors[i].Monitor.Id + " has a recording server hostname of " + multiservers[j].Server.Hostname); + + + + // Now here is the logic, I need to retrieve serverhostname, + // and slap on the host protocol and path. Meh. + + var s = URI.parse(loginData.streamingurl); + var m = URI.parse(multiservers[j].Server.Hostname); + var p = URI.parse(loginData.url); + + /* if (!p.port && !isNaN(p.path)) { + debug ("Portal: port path reversed?"); + var tp = p.port; + p.port = p.path; + p.path = tp; + } + + if (!s.port && !isNaN(s.path)) { + debug ("Recording: port path reversed?"); + var tp = s.port; + s.port = s.path; + s.path = tp; + } +*/ + + debug("recording server reported is " + JSON.stringify(m)); + debug("portal parsed is " + JSON.stringify(p)); + debug("streaming url parsed is " + JSON.stringify(s)); + debug ("multi-port is:"+zmsPort); + + var st = ""; + var baseurl = ""; + var streamingurl = ""; + + + st += (m.scheme ? m.scheme : p.scheme) + "://"; // server scheme overrides + + + + // if server doesn't have a protocol, what we want is in path + if (!m.host) { + m.host = m.path; + m.path = undefined; + } + + st += m.host; + + //console.log ("STEP 1: ST="+st); + + if (zmsPort <= 0 || loginData.disableSimulStreaming) { + if (p.port || m.port) { + st += (m.port ? ":" + m.port : ":" + p.port); + streamingurl = st; + //console.log ("STEP 2 no ZMS: ST="+st); + + } + + } else { + var sport = parseInt(zmsPort) + parseInt(monitors[i].Monitor.Id); + st = st + ':' + sport; + + if (p.port || m.port) + st += (m.port ? ":" + m.port : ":" + p.port); + //console.log ("STEP 2: ST="+st); + + } + + + baseurl = st; + + controlURL = st; + controlURL += (p.path ? p.path:''); + + st += (s.path ? s.path : p.path); + streamingurl += (s.path ? s.path : p.path); + + //console.log ("STEP 3: ST="+st); + + + //console.log ("----------STREAMING URL PARSED AS " + st); + + monitors[i].Monitor.streamingURL = st; + monitors[i].Monitor.baseURL = baseurl; + monitors[i].Monitor.controlURL = controlURL; + + + debug ("Storing baseurl="+baseurl+" streamingURL="+st+" recordingURL="+controlURL); + //console.log ("** Streaming="+st+" **base="+baseurl); + // starting 1.30 we have fid=xxx mode to return images + monitors[i].Monitor.imageMode = (versionCompare($rootScope.apiVersion, "1.30") == -1) ? "path" : "fid"; + // debug("API " + $rootScope.apiVersion + ": Monitor " + monitors[i].Monitor.Id + " will use " + monitors[i].Monitor.imageMode + " for direct image access"); + + //debug ("Streaming URL for Monitor " + monitors[i].Monitor.Id + " is " + monitors[i].Monitor.streamingURL ); + //debug ("Base URL for Monitor " + monitors[i].Monitor.Id + " is " + monitors[i].Monitor.baseURL ); + + } else { + //monitors[i].Monitor.listDisplay = 'show'; + debug ("No servers matched, filling defaults..."); + monitors[i].Monitor.isAlarmed = false; + monitors[i].Monitor.connKey = (Math.floor((Math.random() * 999999) + 1)).toString(); + monitors[i].Monitor.rndKey = (Math.floor((Math.random() * 999999) + 1)).toString(); + + var st2 = loginData.streamingurl; + controlURL = loginData.url; + + if (zmsPort > 0 && !loginData.disableSimulStreaming) { + // we need to insert minport + st2 = ""; + var p2 = URI.parse(loginData.streamingurl); + var p3 = URI.parse(loginData.url); + st2 += p2.scheme + "://"; + if (!p2.host) { + p2.host = p2.path; + p2.path = undefined; + } + st2 += p2.host; + var sport2 = parseInt(zmsPort) + parseInt(monitors[i].Monitor.Id); + st2 = st2 + ':' + sport2; + + controlURL = st2; + + if (p2.path) st2 += p2.path; + if (p3.path) controlURL += p3.path; + } + + debug ("Storing streaming="+st2+" recording="+controlURL); + + monitors[i].Monitor.streamingURL = st2; + monitors[i].Monitor.controlURL = controlURL; + //debug ("Streaming URL for Monitor " + monitors[i].Monitor.Id + " is " + monitors[i].Monitor.streamingURL ); + //console.log ("NO SERVER MATCH CONSTRUCTED STREAMING PATH="+st2); + monitors[i].Monitor.baseURL = loginData.url; + monitors[i].Monitor.imageMode = (versionCompare($rootScope.apiVersion, "1.30") == -1) ? "path" : "fid"; + + + } + } + // now get packery hide if applicable + reloadMonitorDisplayStatus(); + d.resolve(monitors); + }, + function (err) { + log("multi server list loading error"); + multiservers = []; + + for (var i = 0; i < monitors.length; i++) { + //monitors[i].Monitor.listDisplay = 'show'; + monitors[i].Monitor.isAlarmed = false; + monitors[i].Monitor.connKey = (Math.floor((Math.random() * 999999) + 1)).toString(); + monitors[i].Monitor.rndKey = (Math.floor((Math.random() * 999999) + 1)).toString(); + var st = loginData.streamingurl; + if (zmsPort > 0) { + // we need to insert minport + st = ""; + var p = URI.parse(loginData.streamingurl); + st += p.scheme + "://"; + if (!p.host) { + p.host = p.path; + p.path = undefined; + } + st += p.host; + var sport = parseInt(zmsPort) + parseInt(monitors[i].Monitor.Id); + st = st + ':' + sport; + if (p.path) st += p.path; + + + + } + + monitors[i].Monitor.streamingURL = st; + // console.log ("CONSTRUCTED STREAMING PATH="+st); + monitors[i].Monitor.baseURL = loginData.url; + + monitors[i].Monitor.imageMode = (versionCompare($rootScope.apiVersion, "1.30") == -1) ? "path" : "fid"; + //debug("API " + $rootScope.apiVersion + ": Monitor " + monitors[i].Monitor.Id + " will use " + monitors[i].Monitor.imageMode + " for direct image access"); + + } + d.resolve(monitors); + + }); + + $ionicLoading.hide(); + log("Monitor load was successful, loaded " + monitors.length + " monitors"); + + }, + function (err) { + //console.log("HTTP Error " + err); + log("Monitor load failed " + JSON.stringify(err), "error"); + // To keep it simple for now, I'm translating an error + // to imply no monitors could be loaded. FIXME: conver to proper error + monitors = []; + //console.log("promise resolved inside HTTP fail"); + displayBanner('error', ['error retrieving monitor list', 'please try again']); + d.resolve(monitors); + $ionicLoading.hide(); + monitorsLoaded = 0; + }); + }); + + return d.promise; + + } else // monitors are loaded + { + //console.log("Returning pre-loaded list of " + monitors.length + " monitors"); + log("Returning pre-loaded list of " + monitors.length + " monitors"); + d.resolve(monitors); + //console.log ("Returning"+JSON.stringify(monitors)); + $ionicLoading.hide(); + return d.promise; + } + + }, + + zmPrivacyProcessed: function () { + var apiurl = loginData.apiurl; + var myurl = apiurl + '/configs/viewByName/ZM_SHOW_PRIVACY.json'; + var d = $q.defer(); + + $http({ + url: myurl, + method: 'GET', + transformResponse: undefined, + responseType: 'text', + }) + // $http.get(myurl) + .then(function (textsucc) { + + var succ; + try { + //console.log(textsucc); + succ = JSON.parse(textsucc.data); + if (succ.data) succ = succ.data; + if (succ.config) { + if (succ.config.Value == '1') { + debug("Real value of PRIVACY is:" + succ.config.Value); + d.resolve(false); + } else { + debug("Real value of PRIVACY is:" + succ.config.Value); + d.resolve(true); + } + return d.promise; + } else { + debug("ZM_SHOW_PRIVACY likely does not exist"); + d.resolve(true); + return d.promise; + } + + } catch (e) { + debug("ZM_SHOW_PRIVACY parsing error, assuming it doesn't exist"); + d.resolve(true); + return d.promise; + } + + }, + function (err) { + debug("ZM_SHOW_PRIVACY returned an error, it likely doesn't exist"); + d.resolve(true); + return d.promise; + + }); + return d.promise; + }, + + //----------------------------------------------------------------------------- + // + //----------------------------------------------------------------------------- + setMonitors: function (mon) { + //console.log("ZMData setMonitors called with " + mon.length + " monitors"); + monitors = mon; + }, + + processFastLogin: function () { + var d = $q.defer(); + if (1) { + d.reject("not implemented"); + return d.promise; + } + // console.log("inside processFastLogin"); + if (!loginData.fastLogin) { + //console.log("Fast login not set"); + d.reject("fast login not enabled"); + debug("fast login not enabled"); + return d.promise; + + } else //fastlogin is on + { + localforage.getItem("lastLogin") + .then(function (succ) { + //console.log("fast login DB found"); + var dt = moment(succ); + + if (dt.isValid()) { + debug("Got last login as " + dt.toString()); + if (moment.duration(moment().diff(dt)).asHours() >= 2) { + d.reject("duration since last login >=2hrs, need to relogin"); + return d.promise; + } else { + d.resolve("fast login is valid, less then 2 hrs"); + return d.promise; + } + } else { + //console.log("Invalid date found"); + d.reject("last-login invalid"); + return d.promise; + + } + }, + function (e) { + //console.log("fastlogin DB not found"); + d.reject("last-login not found, fastlogin rejected"); + return d.promise; + }); + + } + return d.promise; + }, + + // returns if this mid is hidden or not + isNotHidden: function (mid) { + var notHidden = true; + for (var i = 0; i < monitors.length; i++) { + if (monitors[i].Monitor.Id == mid) { + notHidden = (monitors[i].Monitor.listDisplay == 'show') ? true : false; + break; + } + + } + return notHidden; + + }, + + getLocalTimeZoneNow: function () { + return moment.tz.guess(); + }, + //returns TZ value immediately (sync) + + getTimeZoneNow: function () { + // console.log ("getTimeZoneNow: " + tz ? tz : moment.tz.guess()); + return tz ? tz : moment.tz.guess(); + }, + + // returns server timezone, failing which local timezone + // always resolves true + + isTzSupported: function () { + return isTzSupported; + }, + + getTimeZone: function (isForce) { + + var d = $q.defer(); + if (!tz || isForce) { + + log("First invocation of TimeZone, asking server"); + var apiurl = loginData.apiurl + '/host/getTimeZone.json'; + $http.get(apiurl) + .then(function (success) { + tz = success.data.tz; + d.resolve(tz); + debug("Timezone API response is:" + success.data.tz); + if (success.data.tz !== undefined) + isTzSupported = true; + else + isTzSupported = false; + $rootScope.$broadcast('tz-updated'); + return (d.promise); + + }, + function (error) { + tz = moment.tz.guess(); + debug("Timezone API error handler, guessing local:" + tz); + d.resolve(tz); + isTzSupported = false; + return (d.promise); + }); + + } else { + d.resolve(tz); + return d.promise; + } + + return d.promise; + }, + + //----------------------------------------------------------------------------- + // When I display events in the event controller, this is the first function I call + // This returns the total number of pages + // I then proceed to display pages in reverse order to display the latest events first + // I also reverse sort them in NVR to sort by date + // All this effort because the ZM APIs return events in sorted order, oldest first. Yeesh. + //----------------------------------------------------------------------------- + + getEventsPages: function (monitorId, startTime, endTime) { + //console.log("********** INSIDE EVENTS PAGES "); + + var d = $q.defer(); + + + + var apiurl = loginData.apiurl; + + var myurl = apiurl + "/events/index"; + if (monitorId != 0) + myurl = myurl + "/MonitorId:" + monitorId; + if (startTime) + myurl = myurl + "/StartTime >=:" + startTime; + if (endTime) + myurl = myurl + "/EndTime <=:" + endTime; + + myurl = myurl + "/AlarmFrames >=:" + (loginData.enableAlarmCount ? loginData.minAlarmCount : 0); + + //https:///zm/api/events/index/Notes%20REGEXP:detected%3A.json + if (loginData.objectDetectionFilter) { + myurl = myurl + '/Notes%20REGEXP:detected%3A'; + } + + + myurl = myurl + ".json"; + //console.log (">>>>>Constructed URL " + myurl); + + $ionicLoading.show({ + template: $translate.instant('kCalcEventSize') + '...', + animation: 'fade-in', + showBackdrop: false, + duration: zm.loadingTimeout, + maxWidth: 200, + showDelay: 0 + }); + + //var myurl = (monitorId == 0) ? apiurl + "/events.json?page=1" : apiurl + "/events/index/MonitorId:" + monitorId + ".json?page=1"; + + $http.get(myurl) + .then(function (data) { + data = data.data; + $ionicLoading.hide(); + //console.log ("**** EVENTS PAGES I GOT "+JSON.stringify(data)); + //console.log("**** PAGE COUNT IS " + data.pagination.pageCount); + d.resolve(data.pagination); + return d.promise; + }, + function (error) { + $ionicLoading.hide(); + // console.log("*** ERROR GETTING TOTAL PAGES ***"); + log("Error retrieving page count of events " + JSON.stringify(error), "error"); + displayBanner('error', ['error retrieving event page count', 'please try again']); + + d.reject(error); + return d.promise; + }); + return d.promise; + + }, + + //----------------------------------------------------------------------------- + // This function returns events for specific monitor or all monitors + // You get here by tapping on events in the monitor screen or from + // the menu events option + // monitorId == 0 means all monitors (ZM starts from 1) + //----------------------------------------------------------------------------- + + // new reminder + // + //https:///zm/api/events.json?&sort=StartTime&direction=desc&page=1 + getEvents: function (monitorId, pageId, loadingStr, startTime, endTime, noObjectFilter) { + + + + if (!pageId) pageId = 1; + //console.log("ZMData getEvents called with ID=" + monitorId + "and Page=" + pageId); + + if (!loadingStr) { + loadingStr = $translate.instant('kLoadingEvents') + "..."; + } + //if (loadingStr) loa + + if (loadingStr != 'none') { + $ionicLoading.show({ + template: loadingStr, + animation: 'fade-in', + showBackdrop: false, + maxWidth: 200, + showDelay: 0, + duration: zm.loadingTimeout, //specifically for Android - http seems to get stuck at times + }); + } + + var d = $q.defer(); + var myevents = []; + var apiurl = loginData.apiurl; + + var myurl = apiurl + "/events/index"; + if (monitorId != 0) + myurl = myurl + "/MonitorId:" + monitorId; + if (startTime) + myurl = myurl + "/StartTime >=:" + startTime; + if (endTime) + myurl = myurl + "/EndTime <=:" + endTime; + + myurl = myurl + "/AlarmFrames >=:" + (loginData.enableAlarmCount ? loginData.minAlarmCount : 0); + + //https:///zm/api/events/index/Notes%20REGEXP: detected%3A.json + if (loginData.objectDetectionFilter && !noObjectFilter) { + myurl = myurl + '/Notes REGEXP:detected:'; + } + + myurl = myurl + ".json?&sort=StartTime&direction=desc&page=" + pageId; + + + debug("getEvents:" + myurl); + // Simulated data + + // myurl = "https://api.myjson.com/bins/4jx44.json"; + + //console.log (">>>>>Constructed URL " + myurl); + + $http.get(myurl /*,{timeout:15000}*/ ) + .then(function (data) { + data = data.data; + if (loadingStr != 'none') $ionicLoading.hide(); + //myevents = data.events; + myevents = data; + + + d.resolve(myevents); + return d.promise; + + }, + function (err) { + if (loadingStr != 'none') $ionicLoading.hide(); + displayBanner('error', ['error retrieving event list', 'please try again']); + //console.log("HTTP Events error " + err); + log("Error fetching events for page " + pageId + " Err: " + JSON.stringify(err), "error"); + // I need to reject this as I have infinite scrolling + // implemented in EventCtrl.js --> and if it does not know + // it got an error going to the next page, it will get into + // an infinite loop as we are at the bottom of the list always + + d.reject(myevents); + + + return d.promise; + }); + return d.promise; + }, + + //----------------------------------------------------------------------------- + // + //----------------------------------------------------------------------------- + getMontageSize: function () { + return loginData.montageSize; + }, + + //----------------------------------------------------------------------------- + // + //----------------------------------------------------------------------------- + setMontageSize: function (montage) { + loginData.montageSize = montage; + }, + + //----------------------------------------------------------------------------- + // + //----------------------------------------------------------------------------- + getMonitorsLoaded: function () { + // console.log("**** Inside promise function "); + var deferred = $q.defer(); + if (monitorsLoaded != 0) { + deferred.resolve(monitorsLoaded); + } + + return deferred.promise; + }, + + //----------------------------------------------------------------------------- + // + //----------------------------------------------------------------------------- + setMonitorsLoaded: function (loaded) { + // console.log("ZMData.setMonitorsLoaded=" + loaded); + monitorsLoaded = loaded; + }, + + //----------------------------------------------------------------------------- + // returns the next monitor ID in the list + // used for swipe next + //----------------------------------------------------------------------------- + getNextMonitor: function (monitorId, direction) { + var id = parseInt(monitorId); + var foundIndex = -1; + for (var i = 0; i < monitors.length; i++) { + if (parseInt(monitors[i].Monitor.Id) == id) { + foundIndex = i; + break; + } + } + if (foundIndex != -1) { + foundIndex = foundIndex + direction; + // wrap around if needed + if (foundIndex < 0) foundIndex = monitors.length - 1; + if (foundIndex >= monitors.length) foundIndex = 0; + return (monitors[foundIndex].Monitor.Id); + } else { + log("getNextMonitor could not find monitor " + monitorId); + return (monitorId); + } + + }, + + //----------------------------------------------------------------------------- + // Given a monitor Id it returns the monitor name + // FIXME: Can I do a better job with associative arrays? + //----------------------------------------------------------------------------- + getMonitorName: function (id) { + var idnum = parseInt(id); + for (var i = 0; i < monitors.length; i++) { + if (parseInt(monitors[i].Monitor.Id) == idnum) { + // console.log ("Matched, exiting getMonitorname"); + return monitors[i].Monitor.Name; + } + + } + return "(Unknown)"; + }, + + getMonitorObject: function (id) { + var idnum = parseInt(id); + for (var i = 0; i < monitors.length; i++) { + if (parseInt(monitors[i].Monitor.Id) == idnum) { + // console.log ("Matched, exiting getMonitorname"); + return monitors[i]; + } + + } + return undefined; + }, + + getImageMode: function (id) { + var idnum = parseInt(id); + for (var i = 0; i < monitors.length; i++) { + if (parseInt(monitors[i].Monitor.Id) == idnum) { + // console.log ("Matched, exiting getMonitorname"); + return monitors[i].Monitor.imageMode; + } + + } + return "(Unknown)"; + }, + + getStreamingURL: function (id) { + var idnum = parseInt(id); + for (var i = 0; i < monitors.length; i++) { + // console.log ("Matched, exiting getMonitorname"); + if (parseInt(monitors[i].Monitor.Id) == idnum) { + return monitors[i].Monitor.streamingURL; + } + + } + return "(Unknown)"; + }, + + // tries to set up a DB + // set/get a value and if it fails + // goes back to localstorage + // needed for some old Android phones where index setting works, but actually fails + + configureStorageDB: function () { + + debug("Inside configureStorageDB"); + var d = $q.defer(); + localforage.config({ + name: zm.dbName + + }); + + if ($rootScope.platformOS == 'ios') { + order = [window.cordovaSQLiteDriver._driver, + localforage.INDEXEDDB, + localforage.LOCALSTORAGE + ]; + } else { + // don't do SQL for Android + // large keys hang on some devices + // see https://github.com/litehelpers/Cordova-sqlite-storage/issues/533 + order = [ + localforage.INDEXEDDB, + localforage.LOCALSTORAGE, + ]; + } + + debug("configureStorageDB: trying order:" + JSON.stringify(order)); + + localforage.defineDriver(window.cordovaSQLiteDriver).then(function () { + return localforage.setDriver( + // Try setting cordovaSQLiteDriver if available, + // for desktops, it will pick the next one + order + ); + }) + .then(function (succ) { + log("configureStorageDB:localforage driver for storage:" + localforage.driver()); + debug("configureStorageDB:Making sure this storage driver works..."); + return localforage.setItem('testPromiseKey', 'testPromiseValue'); + }) + .then(function (succ) { + return localforage.getItem('testPromiseKey'); + }) + .then(function (succ) { + if (succ != 'testPromiseValue') { + log("configureStorageDB:this driver could not restore a test val, reverting to localstorage and hoping for the best..."); + return forceLocalStorage(); + } else { + debug("configureStorageDB:test get/set worked, this driver is ok..."); + d.resolve(true); + return d.promise; + } + }) + .catch(function (err) { + log("configureStorageDB:this driver errored, reverting to localstorage and hoping for the best...: " + JSON.stringify(err)); + return forceLocalStorage(); + }); + + return d.promise; + + function forceLocalStorage() { + + // var d = $q.defer(); + localforage.setDriver(localforage.LOCALSTORAGE) + .then(function (succ) { + log("configureStorageDB:localforage forced setting to localstorage returned a driver of: " + localforage.driver()); + d.resolve(true); + return d.promise; + }, + function (err) { + log("*** configureStorageDB: Error setting localStorage too, zmNinja WILL NOT SAVE ***"); + log("*** configureStorageDB: Dance, rejoice, keep re-configuring everytime you run ***"); + d.resolve(true); + return d.promise; + }); + return d.promise; + + } + + }, + + + getRecordingURL: function (id) { + var idnum = parseInt(id); + for (var i = 0; i < monitors.length; i++) { + if (parseInt(monitors[i].Monitor.Id) == idnum) { + // console.log ("Matched, exiting getMonitorname"); + //console.log ("!!!"+monitors[i].Monitor.controlURL); + return monitors[i].Monitor.controlURL; + } + + } + return "(Unknown)"; + }, + + getBaseURL: function (id) { + var idnum = parseInt(id); + for (var i = 0; i < monitors.length; i++) { + if (parseInt(monitors[i].Monitor.Id) == idnum) { + // console.log ("Matched, exiting getMonitorname"); + return monitors[i].Monitor.baseURL; + } + + } + return "(Unknown)"; + }, + + logout: function () { + + // always resolves + + $ionicLoading.show({ + template: $translate.instant('kCleaningUp'), + noBackdrop: true, + + }); + + var d = $q.defer(); + log(loginData.url + "=>Logging out of any existing ZM sessions..."); + $rootScope.authSession = "undefined"; + + + // console.log("CURRENT SERVER: " + loginData.currentServerVersion); + + if (loginData.currentServerVersion && (versionCompare(loginData.currentServerVersion, zm.versionWithLoginAPI) != -1 || loginData.loginAPISupported)) { + + debug("Logging out using API method"); + $http.get(loginData.apiurl + '/host/logout.json', { + timeout: 7000, + transformResponse: undefined, + // responseType:'text', + }) + .then(function (s) { + debug("Logout returned... "); + d.resolve(true); + $ionicLoading.hide(); + return d.promise; + }, + function (e) { + debug("Logout errored but really don't worry, your ZM version may not support it"); + $ionicLoading.hide(); + d.resolve(true); + return d.promise; + } + ); + return d.promise; + } + + + // old logout mode + debug("Logging out using Web method"); + $http({ + method: 'POST', + timeout: 7000, + //withCredentials: true, + url: loginData.url + '/index.php?view=console', + headers: { + 'Content-Type': 'application/x-www-form-urlencoded', + 'Accept': 'application/json', + }, + transformRequest: function (obj) { + var str = []; + for (var p in obj) + str.push(encodeURIComponent(p) + "=" + + encodeURIComponent(obj[p])); + var params = str.join("&"); + return params; + }, + + data: { + action: "logout", + view: "login" + } + }) + .then(function (succ) { + $ionicLoading.hide(); + d.resolve(true); + return d.promise; + }, + function (err) { + $ionicLoading.hide(); + d.resolve(true); + return d.promise; + }); + return d.promise; + } + }; + } + ]); |