Deprecating operation.js module from UI

This commit is contained in:
dilanua 2016-08-01 22:45:30 +05:30
parent e125871de0
commit c7f4bba8bf

View File

@ -16,119 +16,123 @@
* under the License. * under the License.
*/ */
var operationModule = function () { /*
var log = new Log("/app/modules/business-controllers/operation.js"); @Deprecated New
var utility = require('/app/modules/utility.js').utility;
var constants = require('/app/modules/constants.js');
var devicemgtProps = require("/app/modules/conf-reader/main.js")["conf"];
var serviceInvokers = require("/app/modules/oauth/token-protected-service-invokers.js")["invokers"];
var publicMethods = {};
var privateMethods = {};
/**
* This method reads the token from the Token client and return the access token.
* If the token pair s not set in the session this will send a redirect to the login page.
*/ */
function getAccessToken(deviceType, owner, deviceId) {
var TokenClient = Packages.org.wso2.carbon.device.mgt.iot.apimgt.TokenClient;
var accessTokenClient = new TokenClient(deviceType);
var accessTokenInfo = accessTokenClient.getAccessToken(owner, deviceId);
return accessTokenInfo.getAccess_token();
}
privateMethods.getOperationsFromFeatures = function (deviceType, operationType) { //var operationModule = function () {
var url = devicemgtProps["httpsURL"] + constants.ADMIN_SERVICE_CONTEXT + "/features/" + deviceType; // var log = new Log("/app/modules/business-controllers/operation.js");
var featuresList = serviceInvokers.XMLHttp.get(url, function (responsePayload) { // var utility = require('/app/modules/utility.js').utility;
var features = responsePayload; // var constants = require('/app/modules/constants.js');
var featureList = []; // var devicemgtProps = require("/app/modules/conf-reader/main.js")["conf"];
var feature; // var serviceInvokers = require("/app/modules/oauth/token-protected-service-invokers.js")["invokers"];
for (var i = 0; i < features.length; i++) { //
feature = {}; // var publicMethods = {};
var analyticStreams = utility.getDeviceTypeConfig(deviceType)["analyticStreams"]; // var privateMethods = {};
if (analyticStreams) { //
for (var stream in analyticStreams) { // /**
if (analyticStreams[stream].name == features[i].name) { // * This method reads the token from the Token client and return the access token.
feature.ui_unit = analyticStreams[stream].ui_unit; // * If the token pair s not set in the session this will send a redirect to the login page.
break; // */
} // function getAccessToken(deviceType, owner, deviceId) {
} // var TokenClient = Packages.org.wso2.carbon.device.mgt.iot.apimgt.TokenClient;
} // var accessTokenClient = new TokenClient(deviceType);
// var accessTokenInfo = accessTokenClient.getAccessToken(owner, deviceId);
feature["operation"] = features[i].code; // return accessTokenInfo.getAccess_token();
feature["name"] = features[i].name; // }
feature["description"] = features[i].description; //
feature["deviceType"] = deviceType; // privateMethods.getOperationsFromFeatures = function (deviceType, operationType) {
feature["params"] = []; // var url = devicemgtProps["httpsURL"] + constants.ADMIN_SERVICE_CONTEXT + "/features/" + deviceType;
var metaData = features[i].metadataEntries; // var featuresList = serviceInvokers.XMLHttp.get(url, function (responsePayload) {
if (metaData) { // var features = responsePayload;
for (var j = 0; j < metaData.length; j++) { // var featureList = [];
feature["params"].push(metaData[j].value); // var feature;
} // for (var i = 0; i < features.length; i++) {
featureList.push(feature); // feature = {};
} // var analyticStreams = utility.getDeviceTypeConfig(deviceType)["analyticStreams"];
} // if (analyticStreams) {
return featureList; // for (var stream in analyticStreams) {
}, function (responsePayload) { // if (analyticStreams[stream].name == features[i].name) {
var response = {}; // feature.ui_unit = analyticStreams[stream].ui_unit;
response["status"] = "error"; // break;
return response; // }
} // }
); // }
return featuresList; //
}; // feature["operation"] = features[i].code;
// feature["name"] = features[i].name;
publicMethods.getControlOperations = function (deviceType) { // feature["description"] = features[i].description;
var operations = privateMethods.getOperationsFromFeatures(deviceType, "operation"); // feature["deviceType"] = deviceType;
for (var op in operations) { // feature["params"] = [];
var iconPath = utility.getOperationIcon(deviceType, operations[op].operation); // var metaData = features[i].metadataEntries;
if (iconPath) { // if (metaData) {
operations[op]["icon"] = iconPath; // for (var j = 0; j < metaData.length; j++) {
} // feature["params"].push(metaData[j].value);
} // }
return operations; // featureList.push(feature);
}; // }
// }
publicMethods.getMonitorOperations = function (deviceType) { // return featureList;
return privateMethods.getOperationsFromFeatures(deviceType, "monitor"); // }, function (responsePayload) {
}; // var response = {};
// response["status"] = "error";
publicMethods.handlePOSTOperation = function (deviceType, operation, deviceId, params) { // return response;
var user = session.get(constants.USER_SESSION_KEY); // }
var endPoint = devicemgtProps["httpsURL"] + '/' + deviceType + "/controller/" + operation; // );
var header = '{"owner":"' + user.username + '","deviceId":"' + deviceId + // return featuresList;
'","protocol":"mqtt", "sessionId":"' + session.getId() + '", "' + // };
constants.AUTHORIZATION_HEADER + '":"' + constants.BEARER_PREFIX + //
getAccessToken(deviceType, user.username, deviceId) + '"}'; // publicMethods.getControlOperations = function (deviceType) {
return post(endPoint, params, JSON.parse(header), "json"); // var operations = privateMethods.getOperationsFromFeatures(deviceType, "operation");
}; // for (var op in operations) {
// var iconPath = utility.getOperationIcon(deviceType, operations[op].operation);
publicMethods.handleGETOperation = function (deviceType, operation, operationName, deviceId) { // if (iconPath) {
var user = session.get(constants.USER_SESSION_KEY); // operations[op]["icon"] = iconPath;
var endPoint = devicemgtProps["httpsURL"] + '/' + deviceType + "/controller/" + operation; // }
var header = '{"owner":"' + user.username + '","deviceId":"' + deviceId + // }
'","protocol":"mqtt", "' + constants.AUTHORIZATION_HEADER + '":"' + // return operations;
constants.BEARER_PREFIX + getAccessToken(deviceType, user.username, deviceId) + // };
'"}'; //
var result = get(endPoint, {}, JSON.parse(header), "json"); // publicMethods.getMonitorOperations = function (deviceType) {
if (result.data) { // return privateMethods.getOperationsFromFeatures(deviceType, "monitor");
var values = result.data.sensorValue.split(','); // };
if (operationName == 'gps') { //
result.data.map = { // publicMethods.handlePOSTOperation = function (deviceType, operation, deviceId, params) {
lat: parseFloat(values[0]), // var user = session.get(constants.USER_SESSION_KEY);
lng: parseFloat(values[1]) // var endPoint = devicemgtProps["httpsURL"] + '/' + deviceType + "/controller/" + operation;
} // var header = '{"owner":"' + user.username + '","deviceId":"' + deviceId +
} else { // '","protocol":"mqtt", "sessionId":"' + session.getId() + '", "' +
var sqSum = 0; // constants.AUTHORIZATION_HEADER + '":"' + constants.BEARER_PREFIX +
for (var v in values) { // getAccessToken(deviceType, user.username, deviceId) + '"}';
sqSum += Math.pow(values[v], 2); // return post(endPoint, params, JSON.parse(header), "json");
} // };
result.data[operationName] = Math.sqrt(sqSum); //
} // publicMethods.handleGETOperation = function (deviceType, operation, operationName, deviceId) {
delete result.data['sensorValue']; // var user = session.get(constants.USER_SESSION_KEY);
} // var endPoint = devicemgtProps["httpsURL"] + '/' + deviceType + "/controller/" + operation;
return result; // var header = '{"owner":"' + user.username + '","deviceId":"' + deviceId +
}; // '","protocol":"mqtt", "' + constants.AUTHORIZATION_HEADER + '":"' +
// constants.BEARER_PREFIX + getAccessToken(deviceType, user.username, deviceId) +
return publicMethods; // '"}';
}(); // var result = get(endPoint, {}, JSON.parse(header), "json");
// if (result.data) {
// var values = result.data.sensorValue.split(',');
// if (operationName == 'gps') {
// result.data.map = {
// lat: parseFloat(values[0]),
// lng: parseFloat(values[1])
// }
// } else {
// var sqSum = 0;
// for (var v in values) {
// sqSum += Math.pow(values[v], 2);
// }
// result.data[operationName] = Math.sqrt(sqSum);
// }
// delete result.data['sensorValue'];
// }
// return result;
// };
//
// return publicMethods;
//}();