Added new battery history chart gadget.

components/device-types/androidsense-plugin/org.wso2.carbon.device.mgt.iot.androidsense.analytics/src/main/resources/carbonapps/androidsense/android_battery_history_chart_gadget/Android_Battery_History_Chart/conf.json

@@ -1,17 +1,19 @@
 {
   "provider-conf": {
-    "streamName": "org.wso2.iot.android.battery:1.0.0",
+    "tableName": "ORG_WSO2_IOT_ANDROID_BATTERY_STATS",
-    "provider-name": "realtime"
+    "query": "",
+    "limit": "",
+    "provider-name": "batch"
   },
   "chart-conf": {
-    "x": "TIMESTAMP",
+    "x": "meta_timestamp",
     "xType": "time",
     "y": "level",
     "yType": "number",
     "color": "None",
     "mode": "stack",
     "maxLength": "30",
-    "gadget-name": "Android Battery Level Chart",
+    "gadget-name": "Battery History",
     "chart-name": "area-chart"
   }
 }

components/device-types/androidsense-plugin/org.wso2.carbon.device.mgt.iot.androidsense.analytics/src/main/resources/carbonapps/androidsense/android_battery_history_chart_gadget/Android_Battery_History_Chart/gadget.json

@@ -0,0 +1,9 @@
+{
+    "id": "Android_Battery_History_Chart",
+    "title": "Battery History",
+    "type": "gadget",
+    "thumbnail": "gadget/Android_Battery_History_Chart/thumbnail.png",
+    "data": {
+        "url": "gadget/Android_Battery_History_Chart/gadget.xml"
+    }
+}

components/device-types/androidsense-plugin/org.wso2.carbon.device.mgt.iot.androidsense.analytics/src/main/resources/carbonapps/androidsense/android_battery_history_chart_gadget/Android_Battery_History_Chart/gadget.xml

@@ -1,13 +1,13 @@
 <?xml version="1.0" encoding="UTF-8" ?>
 <Module>
-    <ModulePrefs title="Android Battery Level Chart" description="This is a template gadget">
+    <ModulePrefs title="Battery History" description="This is a template gadget">
         <Require feature="dynamic-height"/>
         <Require feature="wso2-gadgets-identity"/>
     </ModulePrefs>
     
-    <UserPref name="windowSize"
+    <UserPref name="refreshInterval"
-              display_name="Window Size"
+              display_name="Refresh Interval"
-              default_value="10"/>
+              default_value="1000000"/>
      
     <Content type="html">
         <![CDATA[
@@ -25,15 +25,13 @@
             <script src="/portal/libs/jquery_1.11.0/jquery-1.11.3.min.js"></script>
             <!-- provider libs -->
             
-            <script src="js/provider-libs/ws-client.js"></script>
-            
             <!-- shared libs -->
             
             <script src="/portal/libs/analytics-wso2-2.0.0/d3.min.js"></script>
             
             <script src="/portal/libs/analytics-wso2-2.0.0/vega.js"></script>
             
-            <script src="/portal/libs/analytics-wso2-2.0.0/VizGrammar_2.js"></script>
+            <script src="/portal/libs/analytics-wso2-2.0.0/VizGrammar.min.js"></script>
             
             <script src="/portal/libs/analytics-wso2-2.0.0/wso2gadgets.js"></script>
             
@@ -45,8 +43,6 @@
             
             <!--scripts copied by framework -->
             
-            <script src="js/core/provider-client.js"></script>
-            
             <script src="js/core/gadget-util.js"></script>
             <script src="js/core/area-chart-api.js"></script>
             <script src="js/core/gadget-core.js"></script>

components/device-types/androidsense-plugin/org.wso2.carbon.device.mgt.iot.androidsense.analytics/src/main/resources/carbonapps/androidsense/android_battery_history_chart_gadget/Android_Battery_History_Chart/js/core/batch-provider-api.js

@@ -0,0 +1,190 @@
+/*
+ * Copyright (c) 2016, WSO2 Inc. (http://www.wso2.org) All Rights Reserved.
+ *
+ * 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.
+ */
+var getConfig, validate, getMode, getSchema, getData, registerCallBackforPush;
+
+(function() {
+
+    var PROVIDERS_LOCATION = '/extensions/providers/';
+
+    var PROVIDER_NAME = 'batch';
+    var TYPE = "type";
+    var TABLE_NAME = "tableName";
+    var HTTPS_TRANSPORT = "https";
+    var CONTENT_TYPE_JSON = "application/json";
+    var AUTHORIZATION_HEADER = "Authorization";
+    var USER_TOKEN = "user";
+    var TENANT_DOMAIN = "domain";
+    var CONST_AT = "@";
+    var USERNAME = "username";
+    var HTTP_USER_NOT_AUTHENTICATED = 403;
+    var JS_MAX_VALUE = "9007199254740992";
+    var JS_MIN_VALUE = "-9007199254740992";
+
+    var typeMap = {
+        "bool" : "string",
+        "boolean" : "string",
+        "string" : "string",
+        "int" : "number",
+        "integer" : "number",
+        "long" : "number",
+        "double" : "number",
+        "float" : "number",
+        "time": "time"
+    };
+
+    var log = new Log();
+    var carbon = require('carbon');
+    var configs = require('/configs/designer.json');
+    var utils = require('/modules/utils.js');
+    var JSUtils = Packages.org.wso2.carbon.analytics.jsservice.Utils;
+    var AnalyticsCachedJSServiceConnector = Packages.org.wso2.carbon.analytics.jsservice.AnalyticsCachedJSServiceConnector;
+    var AnalyticsCache = Packages.org.wso2.carbon.analytics.jsservice.AnalyticsCachedJSServiceConnector.AnalyticsCache;
+    var cacheTimeoutSeconds = 5;
+    var loggedInUser = null;
+
+    if (configs.cacheTimeoutSeconds) {
+        cacheTimeoutSeconds = parseInt(configs.cacheTimeoutSeconds);
+    }
+    var cacheSizeBytes = 1024 * 1024 * 1024; // 1GB
+    if (configs.cacheSizeBytes) {
+        cacheSizeBytes = parseInt(configs.cacheSizeBytes);
+    }
+    response.contentType = CONTENT_TYPE_JSON;
+
+    var authParam = request.getHeader(AUTHORIZATION_HEADER);
+    if (authParam != null) {
+        credentials = JSUtils.authenticate(authParam);
+        loggedInUser = credentials[0];
+    } else {
+        var token = session.get(USER_TOKEN);
+        if (token != null) {
+            loggedInUser = token[USERNAME] + CONST_AT + token[TENANT_DOMAIN];
+        } else {
+            log.error("user is not authenticated!");
+            response.status = HTTP_USER_NOT_AUTHENTICATED;
+            print('{ "status": "Failed", "message": "User is not authenticated." }');
+            return;
+        }
+    }
+
+    var cache = application.get("AnalyticsWebServiceCache");
+    if (cache == null) {
+        cache = new AnalyticsCache(cacheTimeoutSeconds, cacheSizeBytes);
+        application.put("AnalyticsWebServiceCache", cache);
+    }
+    var connector = new AnalyticsCachedJSServiceConnector(cache);
+
+    /**
+     * require the existing config.json and push any dynamic fields that needs to be populated in the UI
+     */
+    getConfig = function() {
+        var formConfig = require(PROVIDERS_LOCATION + '/' + PROVIDER_NAME + '/config.json');
+        var tables;
+        try {
+            tables = JSON.parse(connector.getTableList(loggedInUser).getMessage());
+        } catch (e) {
+            log.error(e);
+        }
+        var configs = formConfig.config;
+        configs.forEach(function(config) {
+            if (config.fieldName === TABLE_NAME) {
+                config.valueSet = tables;
+            }
+        });
+        return formConfig;
+    }
+
+    /**
+     * validate the user input of provider configuration
+     * @param providerConfig
+     */
+    validate = function(providerConfig) {
+        /*
+        validate the form and return
+
+        */
+        return true;
+    }
+
+    /**
+     * returns the data mode either push or pull
+     */
+    getMode = function() {
+        return "PULL";
+    }
+
+    /**
+     * returns an array of column names & types
+     * @param providerConfig
+     */
+    getSchema = function(providerConfig) {
+        var schema = [];
+        var tableName = providerConfig["tableName"];
+        var result = connector.getTableSchema(loggedInUser, tableName).getMessage();
+        result = JSON.parse(result);
+
+        var columns = result.columns;
+        Object.getOwnPropertyNames(columns).forEach(function(name, idx, array) {
+            var type = "ordinal";
+            if(columns[name]['type']) {
+              type = columns[name]['type'];
+            }
+            schema.push({
+                fieldName: name,
+                fieldType: typeMap[type.toLowerCase()]
+            });
+        });
+        // log.info(schema);
+        return schema;
+    };
+
+    /**
+     * returns the actual data
+     * @param providerConfig
+     * @param limit
+     */
+    getData = function(providerConfig, limit) {
+        var tableName = providerConfig.tableName;
+        var query = providerConfig.query;
+        var limit = 100;
+        if (providerConfig.limit) {
+            limit = providerConfig.limit;
+        }
+        var result;
+        //if there's a filter present, we should perform a Lucene search instead of reading the table
+        if (query) {
+            var filter = {
+                "query": query,
+                "start": 0,
+                "count": limit
+            };
+            result = connector.search(loggedInUser, tableName, stringify(filter)).getMessage();
+        } else {
+            var from = JS_MIN_VALUE;
+            var to = JS_MAX_VALUE;
+            result = connector.getRecordsByRange(loggedInUser, tableName, from, to, 0, limit, null).getMessage();
+
+        }
+        result = JSON.parse(result);
+        var data = [];
+        for (var i = 0; i < result.length; i++) {
+            var values = result[i].values;
+            data.push(values);
+        }
+        return data;
+    };
+
+}());

components/device-types/androidsense-plugin/org.wso2.carbon.device.mgt.iot.androidsense.analytics/src/main/resources/carbonapps/androidsense/android_battery_history_chart_gadget/Android_Battery_History_Chart/js/core/gadget-core.js

@@ -19,9 +19,14 @@ $(function () {
     var schema;
     var pref = new gadgets.Prefs();
     
+    var refreshInterval;
+    var providerData;
+    
     var CHART_CONF = 'chart-conf';
     var PROVIDER_CONF = 'provider-conf';
     
+    var REFRESH_INTERVAL = 'refreshInterval';
+    
 var init = function () {
     $.ajax({
         url: gadgetLocation + '/conf.json',
@@ -41,17 +46,33 @@ var init = function () {
                 }
             });
             
+            getProviderData();
+            
            }
        });
 };
 
+var getProviderData = function (){
+    $.ajax({
+        url: gadgetLocation + '/gadget-controller.jag?action=getData',
+        method: "POST",
+        data: JSON.stringify(conf),
+        contentType: "application/json",
+        async: false,
+        success: function (data) {
+        providerData = data;
+        }
+    });
+ return providerData;
+};
+
 
 var drawGadget = function (){
     
-        draw('#canvas', conf[CHART_CONF], schema, null);
+    draw('#canvas', conf[CHART_CONF], schema, providerData);
-        registerCallBackforPush(conf[PROVIDER_CONF], schema, function(providerData) {
+    setInterval(function() {
-            update(providerData);
+        draw('#canvas', conf[CHART_CONF], schema, getProviderData());
-        });
+    },pref.getInt(REFRESH_INTERVAL));
     
 };
 

components/device-types/androidsense-plugin/org.wso2.carbon.device.mgt.iot.androidsense.analytics/src/main/resources/carbonapps/androidsense/android_battery_history_chart_gadget/Android_Battery_History_Chart/js/core/gadget-util.js

@@ -14,7 +14,7 @@
  * limitations under the License.
  */
 var getGadgetLocation = function (callback) {
-    var gadgetLocation = "/portal/store/carbon.super/fs/gadget/Android_Battery_Level_Chart";
+    var gadgetLocation = "/portal/store/carbon.super/fs/gadget/Android_Battery_History_Chart";
 	var PATH_SEPERATOR = "/";
     if (gadgetLocation.search("store") != -1) {
         wso2.gadgets.identity.getTenantDomain(function (tenantDomain) {

components/device-types/androidsense-plugin/org.wso2.carbon.device.mgt.iot.androidsense.analytics/src/main/resources/carbonapps/androidsense/android_battery_history_chart_gadget/artifact.xml

@@ -0,0 +1,23 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!--
+  ~ Copyright (c) 2016, WSO2 Inc. (http://www.wso2.org) All Rights Reserved.
+  ~
+  ~ WSO2 Inc. licenses this file to you under the Apache License,
+  ~ Version 2.0 (the "License"); you may not use this file except
+  ~ in compliance with the License.
+  ~ You may obtain a copy of the License at
+  ~
+  ~ http://www.apache.org/licenses/LICENSE-2.0
+  ~
+  ~ Unless required by applicable law or agreed to in writing,
+  ~ software distributed under the License is distributed on an
+  ~ "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+  ~ KIND, either express or implied. See the License for the
+  ~ specific language governing permissions and limitations
+  ~ under the License.
+  -->
+
+<artifact name= "android_battery_history_chart_gadget" version="1.0.0" type="dashboards/gadget"
+          serverRole="DataAnalyticsServer">
+    <file>Android_Battery_History_Chart</file>
+</artifact>

components/device-types/androidsense-plugin/org.wso2.carbon.device.mgt.iot.androidsense.analytics/src/main/resources/carbonapps/androidsense/android_battery_level_chart_gadget/Android_Battery_Level_Chart/gadget.json

@@ -1,9 +0,0 @@
-{
-    "id": "Android_Battery_Level_Chart",
-    "title": "Android Battery Level Chart",
-    "type": "gadget",
-    "thumbnail": "gadget/Android_Battery_Level_Chart/thumbnail.png",
-    "data": {
-        "url": "gadget/Android_Battery_Level_Chart/gadget.xml"
-    }
-}

components/device-types/androidsense-plugin/org.wso2.carbon.device.mgt.iot.androidsense.analytics/src/main/resources/carbonapps/androidsense/android_battery_level_chart_gadget/Android_Battery_Level_Chart/js/core/provider-client.js

@@ -1,51 +0,0 @@
-/*
- * Copyright (c) 2016, WSO2 Inc. (http://www.wso2.org) All Rights Reserved.
- *
- * 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.
- */
-// var registerCallBackforPush;
-
-(function() {
-
-    var callback;
-
-    /**
-     * TODO Need to read hostname,port, and tenantId from providerConfig
-     * @param providerConfig
-     * @param schema
-     */
-    registerCallBackforPush = function(providerConfig, schema, _callback) {
-        var streamId = providerConfig['streamName'];
-        var hostname = window.parent.location.hostname;
-        var port = window.parent.location.port;
-
-        subscribe(streamId.split(":")[0], streamId.split(":")[1],
-            '10',
-            onData, onError,
-            hostname,
-            port,
-            'WEBSOCKET'
-        );
-        callback = _callback;
-    };
-
-    function onData(streamId, data) {
-        callback(data);
-    };
-
-    function onError(error) {
-        console.error(error);
-    };
-
-}());
-

components/device-types/androidsense-plugin/org.wso2.carbon.device.mgt.iot.androidsense.analytics/src/main/resources/carbonapps/androidsense/android_battery_level_chart_gadget/Android_Battery_Level_Chart/js/core/realtime-provider-api.js

@@ -1,154 +0,0 @@
-/*
- * Copyright (c) 2016, WSO2 Inc. (http://www.wso2.org) All Rights Reserved.
- *
- * 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.
- */
-var getConfig, validate, getMode, getSchema, getData, registerCallBackforPush;
-
-(function() {
-
-    var PROVIDERS_LOCATION = '/extensions/providers/';
-    var PROVIDER_NAME = 'realtime';
-
-    var log = new Log();
-    var utils = require('/modules/utils.js');
-    var carbon = require("carbon");
-    var EventPublisherConstants = Packages.org.wso2.carbon.event.publisher.core.config.EventPublisherConstants;
-    var eventPublisherService = carbon.server.osgiService('org.wso2.carbon.event.publisher.core.EventPublisherService');
-    var eventStreamService = carbon.server.osgiService('org.wso2.carbon.event.stream.core.EventStreamService');
-
-    var typeMap = {
-        "bool": "string",
-        "boolean": "string",
-        "string": "string",
-        "int": "number",
-        "integer": "number",
-        "long": "number",
-        "double": "number",
-        "float": "number",
-        "time": "time"
-    };
-
-    getConfig = function() {
-        var formConfig = require(PROVIDERS_LOCATION + '/' + PROVIDER_NAME + '/config.json');
-        var datasources = [];
-        try {
-            var eventPublisherConfigurationList = eventPublisherService.getAllActiveEventPublisherConfigurations();
-            for (var i = 0; i < eventPublisherConfigurationList.size(); i++) {
-                var eventPublisherConfiguration = eventPublisherService.getActiveEventPublisherConfiguration(
-                    eventPublisherConfigurationList.get(i).getEventPublisherName());;
-
-                var mappingTypeIsWso2 = eventPublisherConfiguration.getOutputMapping()
-                    .getMappingType().equals(EventPublisherConstants.EF_WSO2EVENT_MAPPING_TYPE);
-
-                var adapterType = null;
-                if (eventPublisherConfiguration.getToAdapterConfiguration() != null) {
-                    adapterType = eventPublisherConfiguration.getToAdapterConfiguration().getType();
-                }
-                if (mappingTypeIsWso2 && adapterType.trim() == "ui") {
-                    var streamName = eventPublisherConfiguration.getFromStreamName();
-                    var streamVersion = eventPublisherConfiguration.getFromStreamVersion();
-                    var streamId = streamName + ":" + streamVersion;
-                    datasources.push(streamId);
-                }
-            }
-            var datasourceCfg = {
-                "fieldLabel": "Event Stream",
-                "fieldName": "streamName",
-                "fieldType": "dropDown"
-            };
-            datasourceCfg['valueSet'] = datasources;
-        } catch (e) {
-            log.error(e);
-        }
-        formConfig.config.push(datasourceCfg);
-        return formConfig;
-    };
-
-    /**
-     * validate the user input of provider configuration
-     * @param providerConfig
-     */
-    validate = function(providerConfig) {
-        /*
-         validate the form and return
-
-         */
-        return true;
-    };
-
-    /**
-     * returns the data mode either push or pull
-     */
-    getMode = function() {
-        return 'push';
-    };
-
-    /**
-     * returns an array of column names & types
-     * @param providerConfig
-     */
-    getSchema = function(providerConfig) {
-        var streamId = providerConfig["streamName"];
-        var output = [];
-
-        output.push({
-            fieldName: "TIMESTAMP",
-            fieldType: "time"
-        });
-
-        if (eventStreamService != null) {
-            var eventStreamConfiguration = eventStreamService.getEventStreamConfiguration(streamId);
-            if (eventStreamConfiguration != null) {
-                var metaData = eventStreamConfiguration.getStreamDefinition().getMetaData();
-                var correlationData = eventStreamConfiguration.getStreamDefinition().getCorrelationData();
-                var payloadData = eventStreamConfiguration.getStreamDefinition().getPayloadData();
-                if (metaData != null) {
-                    for (var i = 0; i < metaData.size(); i++) {
-                        var type = metaData.get(i).getType().toString().toLowerCase();
-                        output.push({
-                            fieldName: metaData.get(i).getName(),
-                            fieldType: typeMap[type.toLowerCase()]
-                        });
-                    }
-                }
-                if (correlationData != null) {
-                    for (var i = 0; i < correlationData.size(); i++) {
-                        var type = correlationData.get(i).getType().toString().toLowerCase();
-                        output.push({
-                            fieldName: correlationData.get(i).getName(),
-                            fieldType: typeMap[type.toLowerCase()]
-                        });
-                    }
-                }
-                if (payloadData != null) {
-                    for (var i = 0; i < payloadData.size(); i++) {
-                        var type = payloadData.get(i).getType().toString().toLowerCase();
-                        output.push({
-                            fieldName: payloadData.get(i).getName(),
-                            fieldType: typeMap[type.toLowerCase()]
-                        });
-                    }
-                }
-            }
-        }
-        return output;
-    };
-
-    getData = function(providerConfig,limit) {
-      var data = [];
-      return data;
-    };
-
-
-}());

components/device-types/androidsense-plugin/org.wso2.carbon.device.mgt.iot.androidsense.analytics/src/main/resources/carbonapps/androidsense/android_battery_level_chart_gadget/Android_Battery_Level_Chart/js/provider-libs/ws-client.js

@@ -1,290 +0,0 @@
-/*
- *  Copyright (c) 2015, WSO2 Inc. (http://www.wso2.org) All Rights Reserved.
- *
- *  WSO2 Inc. licenses this file to you under the Apache License,
- *  Version 2.0 (the "License"); you may not use this file except
- *  in compliance with the License.
- *  You may obtain a copy of the License at
- *
- *  http://www.apache.org/licenses/LICENSE-2.0
- *
- *  Unless required by applicable law or agreed to in writing,
- *  software distributed under the License is distributed on an
- *  "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- *  KIND, either express or implied.  See the License for the
- *  specific language governing permissions and limitations
- *  under the License.
- */
-
-var CONSTANTS = {
-    urlSeperator: '/',
-    queryParamStreamName : '?streamname=',
-    queryParamStreamVersion : '&version=',
-    queryParamLastUpdatedTime : '&lastUpdatedTime=',
-    urlSecureTransportWebsocket : 'wss://',
-    urlSecureTransportHttp : 'https://',
-    colon : ':',
-    defaultIntervalTime : 10 * 1000,
-    defaultHostName : 'localhost',
-    defaultSecurePortNumber : '9443',
-    defaultMode : 'AUTO',
-    processModeHTTP : 'HTTP',
-    processModeWebSocket : 'WEBSOCKET',
-    processModeAuto : 'AUTO',
-    numThousand : 1000,
-    websocketTimeAppender : 400,
-    websocketSubscriptionEndpoint : 'portal/uipublisher/websocketSubscriptionEndpoint.jag',
-    httpEventRetrievalEndpoint : 'portal/uipublisher/httpEventRetrievalEndpoint.jag'
-};
-
-
-var websocket = null;
-var webSocketUrl;
-var httpUrl;
-var cepHostName;
-var cepPortNumber;
-var isErrorOccured = false;
-var lastUpdatedtime = -1;
-var polingInterval;
-var stream;
-var streamVersion;
-var firstPollingAttempt;
-var processMode;
-var onSuccessFunction;
-var onErrorFunction;
-var terminateWebsocketInstance = false;
-var pollingContinue = true;
-
-function subscribe(streamName,version,intervalTime,
-                   listeningFuncSuccessData,listeningFuncErrorData,cepHost,cepPort,mode){
-    stopPollingProcesses();
-    stream = streamName;
-    streamVersion = version;
-    onSuccessFunction = listeningFuncSuccessData;
-    onErrorFunction = listeningFuncErrorData;
-
-    if(intervalTime == null || intervalTime == ""){
-        polingInterval = CONSTANTS.defaultIntervalTime;
-    } else{
-        polingInterval = intervalTime * CONSTANTS.numThousand;
-    }
-
-    if(cepHost == null || cepHost == ""){
-        cepHostName = CONSTANTS.defaultHostName;
-    } else{
-        cepHostName = cepHost;
-    }
-
-    if(cepPort == null || cepPort == ""){
-        cepPortNumber = CONSTANTS.defaultSecurePortNumber;
-    } else{
-        cepPortNumber = cepPort;
-    }
-
-    if(mode == null || mode == ""){
-        processMode = CONSTANTS.defaultMode;
-    } else{
-        processMode = mode;
-    }
-
-    webSocketUrl = CONSTANTS.urlSecureTransportWebsocket + cepHostName + CONSTANTS.colon + cepPortNumber +
-        CONSTANTS.urlSeperator + CONSTANTS.websocketSubscriptionEndpoint;
-
-    if(processMode == CONSTANTS.processModeHTTP){
-        firstPollingAttempt = true;
-        pollingContinue = true;
-        startPoll();
-    } else{
-        initializeWebSocket(webSocketUrl);
-    }
-}
-
-
-/**
- * Initializing Web Socket
- */
-function initializeWebSocket(webSocketUrl){
-    websocket = new WebSocket(webSocketUrl);
-    websocket.onopen = webSocketOnOpen;
-    websocket.onmessage = webSocketOnMessage;
-    websocket.onclose = webSocketOnClose;
-    websocket.onerror = webSocketOnError;
-}
-
-function getWebsocketSubscriptionMessage(streamName, streamVersion, streamProperties, streamValues) {
-    if (streamProperties.length === streamValues.length) {
-        var message = {};
-        message.streamName = streamName;
-        message.streamVersion = streamVersion;
-        var i;
-        for (i = 0; i < streamProperties.length; i++) {
-            message.filterProps = [];
-            message.filterProps.push({
-                'name': streamProperties[i],
-                'value': streamValues[i]
-            });
-        }
-        return JSON.stringify(message);
-    } else {
-        console.log('stream properties and values are not in equal size');
-    }
-}
-
-/**
- * Get the parameters as query parameters.
- * This method parses those parameters and returns.
- * */
-function getAllQueryParamsFromURL() {
-    var queryParamList = {}, qParam;
-    var urlQueryString = decodeURIComponent(window.top.location.search.substring(1));
-
-    if (urlQueryString) {
-        var queryStringPairs = urlQueryString.split('&');
-        for (var i = 0; i < queryStringPairs.length; i++) {
-            qParam = queryStringPairs[i].split('=');
-            queryParamList[qParam[0]] = qParam[1];
-        }
-        return queryParamList;
-
-    } else {
-        return null;
-    }
-}
-
-/**
- * Web socket On Open
- */
-var webSocketOnOpen = function () {
-    var params = getAllQueryParamsFromURL();
-    var deviceId;
-    var owner;
-    if (params != null) {
-        owner = params["owner"];
-        deviceId = params["deviceId"];
-
-    }
-    var filterPropNames = ["meta_owner", "meta_deviceId"];
-    var filterPropVals = [owner, deviceId];
-    var data = getWebsocketSubscriptionMessage(stream, streamVersion, filterPropNames, filterPropVals);
-    websocket.send(data);
-};
-
-
-/**
- * On server sends a message
- */
-var webSocketOnMessage = function (evt) {
-    var event = evt.data;
-    var array = JSON.parse(event);
-    constructPayload(array);
-};
-
-/**
- * On server close
- */
-var webSocketOnClose =function (e) {
-
-    if(isErrorOccured){
-        if(processMode != CONSTANTS.processModeWebSocket){
-            firstPollingAttempt = true;
-            pollingContinue = true;
-            startPoll();
-        }
-    } else{
-        if(!terminateWebsocketInstance){
-            waitForSocketConnection(websocket);
-        } else{
-            terminateWebsocketInstance = false;
-        }
-
-    }
-};
-
-/**
- * On server Error
- */
-var webSocketOnError = function (err) {
-    var error = "Error: Cannot connect to Websocket URL:" + webSocketUrl + " .Hence closing the connection!";
-
-    onErrorFunction(error);
-    isErrorOccured = true;
-
-};
-
-/**
- * Gracefully increments the connection retry
- */
-var waitTime = CONSTANTS.numThousand;
-function waitForSocketConnection(socket, callback){
-    setTimeout(
-        function () {
-            if (socket.readyState === 1) {
-                initializeWebSocket(webSocketUrl);
-                console.log("Connection is made");
-                if(callback != null){
-                    callback();
-                }
-                return;
-            } else {
-                websocket = new WebSocket(webSocketUrl);
-                waitTime += CONSTANTS.websocketTimeAppender;
-                waitForSocketConnection(websocket, callback);
-            }
-        }, waitTime);
-}
-
-/**
- * Polling to retrieve events from http request periodically
- */
-function startPoll(){
-
-    (function poll(){
-        setTimeout(function(){
-            httpUrl = CONSTANTS.urlSecureTransportHttp + cepHostName + CONSTANTS.colon + cepPortNumber +
-                      CONSTANTS.urlSeperator + CONSTANTS.httpEventRetrievalEndpoint + CONSTANTS.queryParamStreamName + stream +
-                      CONSTANTS.queryParamStreamVersion + streamVersion + CONSTANTS.queryParamLastUpdatedTime + lastUpdatedtime;;
-            $.getJSON(httpUrl, function(responseText) {
-                if(firstPollingAttempt){
-                    /*var data = $("textarea#idConsole").val();
-                     $("textarea#idConsole").val(data + "Successfully connected to HTTP.");*/
-                    firstPollingAttempt = false;
-                }
-                var eventList = $.parseJSON(responseText.events);
-                if(eventList.length != 0){
-                    lastUpdatedtime = responseText.lastEventTime;
-                    for(var i=0;i<eventList.length;i++){
-                        var arr = eventList[i];
-                        constructPayload(arr);
-                    }
-                }
-                if(pollingContinue){
-                    startPoll();
-                }
-            })
-                .fail(function(errorData) {
-                    var errorData = JSON.parse(errorData.responseText);
-                    onErrorFunction(errorData.error);
-                });
-        }, polingInterval);
-    })()
-}
-
-function stopPollingProcesses(){
-
-    //stopping the Websocket
-    if(websocket != null){
-        terminateWebsocketInstance = true;
-        websocket.close();
-    }
-    //stopping the HTTPS Request
-    pollingContinue = false;
-
-}
-
-function constructPayload(eventsArray){
-
-    var streamId = stream + CONSTANTS.colon + streamVersion;
-    var twoDimentionalArray = [eventsArray];
-    onSuccessFunction(streamId,twoDimentionalArray);
-
-}