1 files changed, 162 insertions, 0 deletions
diff --git a/sdnr/wireless-transport/code-Carbon-SR1/ux/onapSo/onapSo-module/src/main/resources/onapSo/onapSo.services.js b/sdnr/wireless-transport/code-Carbon-SR1/ux/onapSo/onapSo-module/src/main/resources/onapSo/onapSo.services.js
new file mode 100644
index 00000000..3e14e7c2
--- /dev/null
+++ b/sdnr/wireless-transport/code-Carbon-SR1/ux/onapSo/onapSo-module/src/main/resources/onapSo/onapSo.services.js
@@ -0,0 +1,162 @@
+/*
+ * Copyright (c) 2017 highstreet technologies GmbH and others.  All rights reserved.
+ *
+ * This program and the accompanying materials are made available under the
+ * terms of the Eclipse Public License v1.0 which accompanies this distribution,
+ * and is available at http://www.eclipse.org/legal/epl-v10.html
+ */
+
+define(['app/onapSo/onapSo.module', 'app/mwtnCommons/mwtnCommons.services'], function (onapSoApp) {
+
+  onapSoApp.register.factory('$onapSo', function ($q, $http, Base64, $mwtnCommons, $mwtnDatabase, $mwtnLog, Device) {
+
+    var service = {};
+
+    var functionId = "mwtn";
+    var docType = "device";
+    var from = 0;
+    var size = 9999;
+    var sort = undefined;
+    var deviceLookup = {};
+    $mwtnDatabase.getAllData(functionId, docType, from, size, sort).then(
+      function successCallback(response) {
+        response.data.hits.hits.map(function(device){
+          deviceLookup[device._id] = new Device(device._source);
+        });
+      }, function errorCallback(response) {
+        deviceLookup = {};
+      });
+
+    service.checkModules = $mwtnCommons.checkModules;
+    service.getMwtnWebSocketUrl = $mwtnCommons.getMwtnWebSocketUrl;
+    service.gridOptions = $mwtnCommons.gridOptions;
+    service.formatData = $mwtnCommons.formatData;
+    service.formatTimeStamp = $mwtnCommons.formatTimeStamp;
+    service.deleteDocType = $mwtnDatabase.deleteDocType;
+    
+
+    var transactionId = 1;
+    var getHeaders = function () {
+      return {
+        'Accept': 'application/json',
+        'Content-Type': 'application/json',
+        'X-TransactionId': transactionId++
+      }
+    };
+
+    // create or modify a pnf in aai
+    service.createPnf = function (pnf) {
+      var base = window.location.origin;
+      var request = {
+        method: 'PUT',
+        url: base + '/aai/network/pnfs/pnf/' + pnf['pnf-name'],
+        // withCredentials: true,
+        headers: getHeaders(),
+        data: pnf
+      };
+      var deferred = $q.defer();
+      $http(request).then(function successCallback(response) {
+        deferred.resolve(response);
+      }, function errorCallback(response) {
+        deferred.reject(response);
+      });
+
+      return deferred.promise;
+    };
+
+    service.deletePnf = function (pnf) {
+      // curl -X DELETE http://localhost:8282/aai/network/pnfs/pnf/Ericsson-A1 --insecure -v -u AAI:AAI -H 'Content-Type: application/json' -H 'Accept: application/json' -H 'X-FromAppId: SDNR' -H 'X-TransactionId: 9999'
+      var base = window.location.origin;
+      var request = {
+        method: 'DELETE',
+        url: base + '/aai/network/pnfs/pnf/' + pnf['pnf-name'] + '/?resource-version=' + pnf['resource-version'], 
+        // withCredentials: true,
+        headers: getHeaders()
+      };
+      var deferred = $q.defer();
+      $http(request).then(function successCallback(response) {
+        deferred.resolve(response);
+      }, function errorCallback(response) {
+        deferred.reject(response);
+      });
+
+      return deferred.promise;
+    };
+
+    service.getPnf = function (pnf) {
+      
+      console.log('get', JSON.stringify(pnf));
+      var base = window.location.origin;
+      var request = {
+        method: 'GET',
+        url: base + '/aai/network/pnfs/pnf/' + pnf['pnf-name'],
+        // withCredentials: true,
+        headers: getHeaders()
+      };
+      var deferred = $q.defer();
+      $http(request).then(function successCallback(response) {
+        deferred.resolve(response);
+      }, function errorCallback(response) {
+        deferred.reject(response);
+      });
+
+      return deferred.promise;
+    };
+
+    service.getAaiPnfs = function () {
+      // curl https://10.31.1.55:8443/network/pnfs -k -v -u abc:def -H 'Content-Type: application/json' -H 'Accept: application/json' -H 'X-FromAppId: SDNR' -H 'X-TransactionId: 9999'
+
+      var base = window.location.origin;
+      var request = {
+        method: 'GET',
+        url: base + '/aai/network/pnfs', // to es config
+        // withCredentials: true,
+        headers: getHeaders(),
+      };
+
+      var deferred = $q.defer();
+      $http(request).then(function successCallback(response) {
+        deferred.resolve(response);
+      }, function errorCallback(response) {
+        deferred.reject(response);
+      });
+
+      return deferred.promise;
+    };
+
+    return service;
+  });
+
+  // Class Device
+  onapSoApp.register.factory('Device', function () {
+    var Device = function (data) {
+      if (!data) {
+        data = {id:new Date(), type: 'unknown', name:'unknonw', model: 'unkonwn', vendor:'unknonw', version:'unkonwn'};
+      }
+      this.data = data;
+      this.getData = function () {
+        return this.data;
+      };
+      this.getId = function () {
+        return this.getData().id;
+      };
+      this.getType = function () {
+        return this.getData().type;
+      };
+      this.getName = function () {
+        return this.getData().name;
+      };
+      this.getModel = function () {
+        return this.getData().model;
+      };
+      this.getVendor = function () {
+        return this.getData().vendor;
+      };
+      this.getVersion = function () {
+        return this.getData().version;
+      };
+    };
+    return Device;
+  });
+
+});