sdnr/wireless-transport/code-Carbon-SR1/ux/onapSo/onapSo-module/src/main/resources/onapSo/onapSo.services.js

   1 /*
   2  * Copyright (c) 2017 highstreet technologies GmbH and others.  All rights reserved.
   3  *
   4  * This program and the accompanying materials are made available under the
   5  * terms of the Eclipse Public License v1.0 which accompanies this distribution,
   6  * and is available at http://www.eclipse.org/legal/epl-v10.html
   7  */
   8
   9 define(['app/onapSo/onapSo.module', 'app/mwtnCommons/mwtnCommons.services'], function (onapSoApp) {
  10
  11   onapSoApp.register.factory('$onapSo', function ($q, $http, Base64, $mwtnCommons, $mwtnDatabase, $mwtnLog, Device) {
  12
  13     var service = {};
  14
  15     var functionId = "mwtn";
  16     var docType = "device";
  17     var from = 0;
  18     var size = 9999;
  19     var sort = undefined;
  20     var deviceLookup = {};
  21     $mwtnDatabase.getAllData(functionId, docType, from, size, sort).then(
  22       function successCallback(response) {
  23         response.data.hits.hits.map(function(device){
  24           deviceLookup[device._id] = new Device(device._source);
  25         });
  26       }, function errorCallback(response) {
  27         deviceLookup = {};
  28       });
  29
  30     service.checkModules = $mwtnCommons.checkModules;
  31     service.getMwtnWebSocketUrl = $mwtnCommons.getMwtnWebSocketUrl;
  32     service.gridOptions = $mwtnCommons.gridOptions;
  33     service.formatData = $mwtnCommons.formatData;
  34     service.formatTimeStamp = $mwtnCommons.formatTimeStamp;
  35     service.deleteDocType = $mwtnDatabase.deleteDocType;
  36
  37
  38     var transactionId = 1;
  39     var getHeaders = function () {
  40       return {
  41         'Accept': 'application/json',
  42         'Content-Type': 'application/json',
  43         'X-TransactionId': transactionId++
  44       }
  45     };
  46
  47     // create or modify a pnf in aai
  48     service.createPnf = function (pnf) {
  49       var base = window.location.origin;
  50       var request = {
  51         method: 'PUT',
  52         url: base + '/aai/network/pnfs/pnf/' + pnf['pnf-name'],
  53         // withCredentials: true,
  54         headers: getHeaders(),
  55         data: pnf
  56       };
  57       var deferred = $q.defer();
  58       $http(request).then(function successCallback(response) {
  59         deferred.resolve(response);
  60       }, function errorCallback(response) {
  61         deferred.reject(response);
  62       });
  63
  64       return deferred.promise;
  65     };
  66
  67     service.deletePnf = function (pnf) {
  68       // 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'
  69       var base = window.location.origin;
  70       var request = {
  71         method: 'DELETE',
  72         url: base + '/aai/network/pnfs/pnf/' + pnf['pnf-name'] + '/?resource-version=' + pnf['resource-version'],
  73         // withCredentials: true,
  74         headers: getHeaders()
  75       };
  76       var deferred = $q.defer();
  77       $http(request).then(function successCallback(response) {
  78         deferred.resolve(response);
  79       }, function errorCallback(response) {
  80         deferred.reject(response);
  81       });
  82
  83       return deferred.promise;
  84     };
  85
  86     service.getPnf = function (pnf) {
  87
  88       console.log('get', JSON.stringify(pnf));
  89       var base = window.location.origin;
  90       var request = {
  91         method: 'GET',
  92         url: base + '/aai/network/pnfs/pnf/' + pnf['pnf-name'],
  93         // withCredentials: true,
  94         headers: getHeaders()
  95       };
  96       var deferred = $q.defer();
  97       $http(request).then(function successCallback(response) {
  98         deferred.resolve(response);
  99       }, function errorCallback(response) {
 100         deferred.reject(response);
 101       });
 102
 103       return deferred.promise;
 104     };
 105
 106     service.getAaiPnfs = function () {
 107       // 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'
 108
 109       var base = window.location.origin;
 110       var request = {
 111         method: 'GET',
 112         url: base + '/aai/network/pnfs', // to es config
 113         // withCredentials: true,
 114         headers: getHeaders(),
 115       };
 116
 117       var deferred = $q.defer();
 118       $http(request).then(function successCallback(response) {
 119         deferred.resolve(response);
 120       }, function errorCallback(response) {
 121         deferred.reject(response);
 122       });
 123
 124       return deferred.promise;
 125     };
 126
 127     return service;
 128   });
 129
 130   // Class Device
 131   onapSoApp.register.factory('Device', function () {
 132     var Device = function (data) {
 133       if (!data) {
 134         data = {id:new Date(), type: 'unknown', name:'unknonw', model: 'unkonwn', vendor:'unknonw', version:'unkonwn'};
 135       }
 136       this.data = data;
 137       this.getData = function () {
 138         return this.data;
 139       };
 140       this.getId = function () {
 141         return this.getData().id;
 142       };
 143       this.getType = function () {
 144         return this.getData().type;
 145       };
 146       this.getName = function () {
 147         return this.getData().name;
 148       };
 149       this.getModel = function () {
 150         return this.getData().model;
 151       };
 152       this.getVendor = function () {
 153         return this.getData().vendor;
 154       };
 155       this.getVersion = function () {
 156         return this.getData().version;
 157       };
 158     };
 159     return Device;
 160   });
 161
 162 });