vid-app-common/src/main/java/org/onap/vid/mso/rest/MsoRestClientNew.java

   1 package org.onap.vid.mso.rest;
   2
   3 import org.openecomp.portalsdk.core.logging.logic.EELFLoggerDelegate;
   4 import org.onap.vid.changeManagement.MsoRequestDetails;
   5 import org.onap.vid.changeManagement.RequestDetailsWrapper;
   6 import org.onap.vid.model.RequestReferencesContainer;
   7 import org.onap.vid.mso.*;
   8
   9 import java.text.DateFormat;
  10 import java.text.SimpleDateFormat;
  11 import java.util.Date;
  12
  13
  14 /**
  15  * Created by pickjonathan on 21/06/2017.
  16  */
  17 public class MsoRestClientNew extends RestMsoImplementation implements MsoInterface {
  18
  19     /**
  20      * The Constant dateFormat.
  21      */
  22     final static DateFormat dateFormat = new SimpleDateFormat("HH:mm:ss:SSSS");
  23     private final String ORIGINAL_REQUEST_ID = "originalRequestId";
  24     /**
  25      * The logger.
  26      */
  27     EELFLoggerDelegate logger = EELFLoggerDelegate.getLogger(MsoRestClientNew.class);
  28
  29     @Override
  30     public MsoResponseWrapper createSvcInstance(RequestDetails requestDetails, String endpoint) throws Exception {
  31         String methodName = "createSvcInstance ";
  32         logger.debug(EELFLoggerDelegate.debugLogger, dateFormat.format(new Date()) + "<== " + methodName + " start");
  33
  34         return createInstance(requestDetails, endpoint);
  35     }
  36
  37     @Override
  38     public MsoResponseWrapper createVnf(RequestDetails requestDetails, String endpoint) throws Exception {
  39
  40         String methodName = "createVnf";
  41         logger.debug(EELFLoggerDelegate.debugLogger, dateFormat.format(new Date()) + "<== " + methodName + " start");
  42
  43         return createInstance(requestDetails, endpoint);
  44     }
  45
  46     @Override
  47     public MsoResponseWrapper createNwInstance(RequestDetails requestDetails, String endpoint) throws Exception {
  48
  49         String methodName = "createNwInstance";
  50         logger.debug(EELFLoggerDelegate.debugLogger, dateFormat.format(new Date()) + "<== " + methodName + " start");
  51
  52         return createInstance(requestDetails, endpoint);
  53     }
  54
  55     @Override
  56     public MsoResponseWrapper createVolumeGroupInstance(RequestDetails requestDetails, String endpoint) throws Exception {
  57         String methodName = "createVolumeGroupInstance";
  58         logger.debug(EELFLoggerDelegate.debugLogger, dateFormat.format(new Date()) + "<== " + methodName + " start");
  59
  60         return createInstance(requestDetails, endpoint);
  61     }
  62
  63     @Override
  64     public MsoResponseWrapper createVfModuleInstance(RequestDetails requestDetails, String endpoint) throws Exception {
  65         String methodName = "createVfModuleInstance";
  66         logger.debug(EELFLoggerDelegate.debugLogger, dateFormat.format(new Date()) + "<== " + methodName + " start");
  67
  68         return createInstance(requestDetails, endpoint);
  69     }
  70
  71     @Override
  72     public MsoResponseWrapper createConfigurationInstance(RequestDetails requestDetails, String endpoint) throws Exception {
  73         String methodName = "createConfigurationInstance";
  74         logger.debug(EELFLoggerDelegate.debugLogger, dateFormat.format(new Date()) + "<== " + methodName + " start");
  75
  76         return createInstance(requestDetails, endpoint);
  77     }
  78
  79     @Override
  80     public MsoResponseWrapper deleteSvcInstance(RequestDetails requestDetails, String endpoint) throws Exception {
  81         String methodName = "deleteSvcInstance";
  82         logger.debug(EELFLoggerDelegate.debugLogger, dateFormat.format(new Date()) + "<== " + methodName + " start");
  83
  84         return deleteInstance(requestDetails, endpoint);
  85     }
  86
  87     @Override
  88     public MsoResponseWrapper deleteVnf(RequestDetails requestDetails, String endpoint) throws Exception {
  89         String methodName = "deleteVnf";
  90         logger.debug(EELFLoggerDelegate.debugLogger, dateFormat.format(new Date()) + "<== " + methodName + " start");
  91
  92         return deleteInstance(requestDetails, endpoint);
  93     }
  94
  95     @Override
  96     public MsoResponseWrapper deleteVfModule(RequestDetails requestDetails, String endpoint) throws Exception {
  97         String methodName = "deleteVfModule";
  98         logger.debug(EELFLoggerDelegate.debugLogger, dateFormat.format(new Date()) + "<== " + methodName + " start");
  99
 100         return deleteInstance(requestDetails, endpoint);
 101     }
 102
 103     @Override
 104     public MsoResponseWrapper deleteVolumeGroupInstance(RequestDetails requestDetails, String endpoint) throws Exception {
 105         String methodName = "deleteVolumeGroupInstance";
 106         logger.debug(EELFLoggerDelegate.debugLogger, dateFormat.format(new Date()) + "<== " + methodName + " start");
 107
 108         return deleteInstance(requestDetails, endpoint);
 109     }
 110
 111     @Override
 112     public MsoResponseWrapper deleteNwInstance(RequestDetails requestDetails, String endpoint) throws Exception {
 113         String methodName = "deleteNwInstance";
 114         logger.debug(EELFLoggerDelegate.debugLogger, dateFormat.format(new Date()) + "<== " + methodName + " start");
 115
 116         return deleteInstance(requestDetails, endpoint);
 117     }
 118
 119     @Override
 120     public void getOrchestrationRequest(String t, String sourceId, String endpoint, RestObject restObject) throws Exception {
 121         Get(t, sourceId, endpoint, restObject);
 122     }
 123
 124     public void getManualTasks(String t, String sourceId, String endpoint, RestObject restObject) throws Exception {
 125         Get(t, sourceId, endpoint, restObject);
 126     }
 127
 128
 129     public MsoResponseWrapper createInstance(RequestDetails request, String path) throws Exception {
 130         String methodName = "createInstance";
 131         logger.debug(dateFormat.format(new Date()) + "<== " + methodName + " start");
 132
 133         try {
 134             RestObject<String> restObjStr = new RestObject<String>();
 135
 136             String str = new String();
 137
 138             restObjStr.set(str);
 139
 140             Post(str, request, "", path, restObjStr);
 141             MsoResponseWrapper w = MsoUtil.wrapResponse(restObjStr);
 142
 143             return w;
 144         } catch (Exception e) {
 145             logger.error(EELFLoggerDelegate.errorLogger, dateFormat.format(new Date()) + "<== " + "." + methodName + e.toString());
 146             logger.debug(EELFLoggerDelegate.debugLogger, dateFormat.format(new Date()) + "<== " + "." + methodName + e.toString());
 147             throw e;
 148         }
 149     }
 150
 151
 152     /**
 153      * Delete instance.
 154      *
 155      * @param request the request
 156      * @param path    the path
 157      * @return the mso response wrapper
 158      * @throws Exception the exception
 159      */
 160     public MsoResponseWrapper deleteInstance(RequestDetails request, String path) throws Exception {
 161         String methodName = "deleteInstance";
 162         logger.debug(EELFLoggerDelegate.debugLogger, dateFormat.format(new Date()) + "<== " + methodName + " start");
 163
 164         try {
 165             logger.debug(EELFLoggerDelegate.debugLogger, dateFormat.format(new Date()) + "<== " + methodName + " calling Delete, path =[" + path + "]");
 166
 167             RestObject<String> restObjStr = new RestObject<String>();
 168             String str = new String();
 169             restObjStr.set(str);
 170             Delete(str, request, "", path, restObjStr);
 171             MsoResponseWrapper w = MsoUtil.wrapResponse(restObjStr);
 172
 173             logger.debug(EELFLoggerDelegate.debugLogger, dateFormat.format(new Date()) + "<== " + methodName + " w=" + w.getResponse());
 174             return w;
 175
 176         } catch (Exception e) {
 177             logger.error(EELFLoggerDelegate.errorLogger, dateFormat.format(new Date()) + "<== " + "." + methodName + e.toString());
 178             logger.debug(EELFLoggerDelegate.debugLogger, dateFormat.format(new Date()) + "<== " + "." + methodName + e.toString());
 179             throw e;
 180         }
 181
 182     }
 183
 184     public MsoResponseWrapper getOrchestrationRequestsForDashboard(String t, String sourceId, String endpoint, RestObject restObject) throws Exception {
 185         String methodName = "getOrchestrationRequestsForDashboard";
 186         logger.debug(dateFormat.format(new Date()) + "<== " + methodName + " start");
 187
 188         try {
 189             getOrchestrationRequest(t, sourceId, endpoint, restObject);
 190             MsoResponseWrapper w = MsoUtil.wrapResponse(restObject);
 191             logger.debug(EELFLoggerDelegate.debugLogger, dateFormat.format(new Date()) + "<== " + methodName + " w=" + w.getResponse());
 192
 193             return w;
 194
 195         } catch (Exception e) {
 196             logger.error(EELFLoggerDelegate.errorLogger, dateFormat.format(new Date()) + "<== " + "." + methodName + e.toString());
 197             logger.debug(EELFLoggerDelegate.debugLogger, dateFormat.format(new Date()) + "<== " + "." + methodName + e.toString());
 198             throw e;
 199         }
 200     }
 201
 202     public MsoResponseWrapper getManualTasksByRequestId(String t, String sourceId, String endpoint, RestObject restObject) throws Exception {
 203         String methodName = "getManualTasksByRequestId";
 204         logger.debug(dateFormat.format(new Date()) + "<== " + methodName + " start");
 205
 206         try {
 207             getManualTasks(t, sourceId, endpoint, restObject);
 208             MsoResponseWrapper w = MsoUtil.wrapResponse(restObject);
 209             logger.debug(EELFLoggerDelegate.debugLogger, dateFormat.format(new Date()) + "<== " + methodName + " w=" + w.getResponse());
 210
 211             return MsoUtil.wrapResponse(restObject);
 212
 213         } catch (Exception e) {
 214             logger.error(EELFLoggerDelegate.errorLogger, dateFormat.format(new Date()) + "<== " + "." + methodName + e.toString());
 215             logger.debug(EELFLoggerDelegate.debugLogger, dateFormat.format(new Date()) + "<== " + "." + methodName + e.toString());
 216             throw e;
 217         }
 218     }
 219
 220
 221     @Override
 222     public MsoResponseWrapper completeManualTask(RequestDetails requestDetails, String t, String sourceId, String endpoint, RestObject restObject) throws Exception {
 223         String methodName = "completeManualTask";
 224         logger.debug(EELFLoggerDelegate.debugLogger, dateFormat.format(new Date()) + "<== " + methodName + " calling Complete ");
 225         try {
 226
 227             Post(t, requestDetails, sourceId, endpoint, restObject);
 228             MsoResponseWrapper w = MsoUtil.wrapResponse(restObject);
 229
 230             logger.debug(EELFLoggerDelegate.debugLogger, dateFormat.format(new Date()) + "<== " + methodName + " w=" + w.getResponse());
 231             return w;
 232
 233         } catch (Exception e) {
 234             logger.error(EELFLoggerDelegate.errorLogger, dateFormat.format(new Date()) + "<== " + "." + methodName + e.toString());
 235             logger.debug(EELFLoggerDelegate.debugLogger, dateFormat.format(new Date()) + "<== " + "." + methodName + e.toString());
 236             throw e;
 237         }
 238     }
 239
 240     @Override
 241     public MsoResponseWrapper replaceVnf(org.onap.vid.changeManagement.RequestDetails requestDetails, String endpoint) throws Exception {
 242         String methodName = "replaceVnf";
 243         logger.debug(EELFLoggerDelegate.debugLogger, dateFormat.format(new Date()) + "<== " + methodName + " start");
 244         return replaceInstance(requestDetails, endpoint);
 245     }
 246
 247     @Override
 248     public MsoResponseWrapper deleteConfiguration(RequestDetails requestDetails, String pmc_endpoint)
 249             throws Exception {
 250         String methodName = "deleteConfiguration";
 251         logger.debug(EELFLoggerDelegate.debugLogger,
 252                 dateFormat.format(new Date()) + "<== " + methodName + " start");
 253
 254         return deleteInstance(requestDetails, pmc_endpoint);
 255     }
 256
 257     @Override
 258     public MsoResponseWrapper setConfigurationActiveStatus(RequestDetails request, String path) throws Exception {
 259         String methodName = "setConfigurationActiveStatus";
 260         logger.debug(EELFLoggerDelegate.debugLogger, dateFormat.format(new Date()) + "<== " + methodName + " start");
 261
 262         try {
 263             logger.debug(EELFLoggerDelegate.debugLogger, dateFormat.format(new Date()) + "<== " + methodName + " calling change configuration active status, path =[" + path + "]");
 264
 265             RestObject<String> restObjStr = new RestObject<String>();
 266             String str = new String();
 267             restObjStr.set(str);
 268             Post(str, request, "", path, restObjStr);
 269             MsoResponseWrapper msoResponseWrapperObject = MsoUtil.wrapResponse(restObjStr);
 270
 271             return msoResponseWrapperObject;
 272         } catch (Exception e) {
 273             logger.info(EELFLoggerDelegate.errorLogger, dateFormat.format(new Date()) + "<== " + "." + methodName + e.toString());
 274             logger.debug(EELFLoggerDelegate.debugLogger, dateFormat.format(new Date()) + "<== " + "." + methodName + e.toString());
 275             throw e;
 276         }
 277     }
 278
 279     @Override
 280     public MsoResponseWrapper setPortOnConfigurationStatus(RequestDetails request, String path) throws Exception {
 281         String methodName = "setPortOnConfigurationStatus";
 282         logger.debug(EELFLoggerDelegate.debugLogger, dateFormat.format(new Date()) + "<== " + methodName + " start");
 283
 284         try {
 285             logger.debug(EELFLoggerDelegate.debugLogger, dateFormat.format(new Date()) + "<== " + methodName + " calling change port configuration status, path =[" + path + "]");
 286
 287             RestObject<String> restObjStr = new RestObject<String>();
 288             String str = new String();
 289             restObjStr.set(str);
 290             Post(str, request, "", path, restObjStr);
 291             MsoResponseWrapper msoResponseWrapperObject = MsoUtil.wrapResponse(restObjStr);
 292
 293             return msoResponseWrapperObject;
 294         } catch (Exception e) {
 295             logger.info(EELFLoggerDelegate.errorLogger, dateFormat.format(new Date()) + "<== " + "." + methodName + e.toString());
 296             logger.debug(EELFLoggerDelegate.debugLogger, dateFormat.format(new Date()) + "<== " + "." + methodName + e.toString());
 297             throw e;
 298         }
 299     }
 300
 301     @Override
 302     public MsoResponseWrapperInterface changeManagementUpdate(RequestDetailsWrapper requestDetails, String endpoint) throws Exception {
 303         RestObject<RequestReferencesContainer> msoResponse = PostForObject(requestDetails, "", endpoint, RequestReferencesContainer.class);
 304         return new MsoResponseWrapper2<>(msoResponse);
 305     }
 306
 307     public MsoResponseWrapper replaceInstance(org.onap.vid.changeManagement.RequestDetails request, String path) throws Exception {
 308         String methodName = "replaceInstance";
 309         logger.debug(EELFLoggerDelegate.debugLogger, dateFormat.format(new Date()) + "<== " + methodName + " start");
 310
 311         try {
 312
 313
 314             logger.debug(EELFLoggerDelegate.debugLogger, dateFormat.format(new Date()) + "<== " + methodName + " calling Replace VNF, path =[" + path + "]");
 315             RestObject<String> restObjStr = new RestObject<String>();
 316             String str = new String();
 317             restObjStr.set(str);
 318             RequestDetailsWrapper requestDetailsWrapper = new RequestDetailsWrapper();
 319             requestDetailsWrapper.requestDetails = new MsoRequestDetails(request);
 320
 321             Post(str, requestDetailsWrapper, "", path, restObjStr);
 322             MsoResponseWrapper msoResponseWrapperObject = MsoUtil.wrapResponse(restObjStr);
 323             int status = msoResponseWrapperObject.getStatus();
 324             if (status == 202) {
 325                 logger.debug(EELFLoggerDelegate.debugLogger, dateFormat.format(new Date()) + "<== " + methodName +
 326                         ",post succeeded, msoResponseWrapperObject response:" + msoResponseWrapperObject.getResponse());
 327             } else {
 328                 logger.error(EELFLoggerDelegate.debugLogger, dateFormat.format(new Date()) + "<== " + methodName +
 329                         ": post failed, msoResponseWrapperObject status" + status + ", response:" + msoResponseWrapperObject.getResponse());
 330
 331                 // TODO
 332             }
 333             return msoResponseWrapperObject;
 334
 335         } catch (Exception e) {
 336             logger.info(EELFLoggerDelegate.errorLogger, dateFormat.format(new Date()) + "<== " + "." + methodName + e.toString());
 337             logger.debug(EELFLoggerDelegate.debugLogger, dateFormat.format(new Date()) + "<== " + "." + methodName + e.toString());
 338             throw e;
 339         }
 340
 341     }
 342
 343     @Override
 344     public MsoResponseWrapper updateVnf(org.onap.vid.changeManagement.RequestDetails requestDetails, String endpoint) throws Exception {
 345         String methodName = "updateVnf";
 346         logger.debug(EELFLoggerDelegate.debugLogger, dateFormat.format(new Date()) + "<== " + methodName + " start");
 347         RequestDetailsWrapper wrapper = new RequestDetailsWrapper();
 348         wrapper.requestDetails = new MsoRequestDetails(requestDetails);
 349         return updateInstance(requestDetails, endpoint);
 350     }
 351
 352     public MsoResponseWrapper updateInstance(org.onap.vid.changeManagement.RequestDetails request, String path) throws Exception {
 353         String methodName = "updateInstance";
 354         logger.debug(EELFLoggerDelegate.debugLogger, dateFormat.format(new Date()) + "<== " + methodName + " start");
 355
 356         try {
 357             logger.debug(EELFLoggerDelegate.debugLogger, dateFormat.format(new Date()) + "<== " + methodName + " calling Delete, path =[" + path + "]");
 358             RestObject<String> restObjStr = new RestObject<String>();
 359             String str = new String();
 360             restObjStr.set(str);
 361             RequestDetailsWrapper requestDetailsWrapper = new RequestDetailsWrapper();
 362             requestDetailsWrapper.requestDetails = new MsoRequestDetails(request);
 363             Put(str, requestDetailsWrapper, "", path, restObjStr);
 364             MsoResponseWrapper w = MsoUtil.wrapResponse(restObjStr);
 365
 366             logger.debug(EELFLoggerDelegate.debugLogger, dateFormat.format(new Date()) + "<== " + methodName + " w=" + w.getResponse());
 367             return w;
 368
 369         } catch (Exception e) {
 370             logger.info(EELFLoggerDelegate.errorLogger, dateFormat.format(new Date()) + "<== " + "." + methodName + e.toString());
 371             logger.debug(EELFLoggerDelegate.debugLogger, dateFormat.format(new Date()) + "<== " + "." + methodName + e.toString());
 372             throw e;
 373         }
 374
 375     }
 376
 377     public void setServiceInstanceStatus(RequestDetails requestDetails, String t, String sourceId, String endpoint, RestObject<String> restObject) throws Exception {
 378         String methodName = "activateServiceInstance";
 379         logger.debug(EELFLoggerDelegate.debugLogger, dateFormat.format(new Date()) + "<== " + methodName + " start ");
 380         try {
 381
 382             Post(t, requestDetails, sourceId, endpoint, restObject);
 383             MsoResponseWrapper w = MsoUtil.wrapResponse(restObject);
 384
 385             logger.debug(EELFLoggerDelegate.debugLogger, dateFormat.format(new Date()) + "<== " + methodName + " w =" + w.getResponse());
 386
 387         } catch (Exception e) {
 388             logger.error(EELFLoggerDelegate.errorLogger, dateFormat.format(new Date()) + "<== " + "." + methodName + e.toString());
 389             logger.debug(EELFLoggerDelegate.debugLogger, dateFormat.format(new Date()) + "<== " + "." + methodName + e.toString());
 390             throw e;
 391         }
 392     }
 393
 394     @Override
 395     public MsoResponseWrapper removeRelationshipFromServiceInstance(RequestDetails requestDetails, String endpoint) throws Exception {
 396         String methodName = "removeRelationshipFromServiceInstance";
 397         logger.debug(EELFLoggerDelegate.debugLogger, dateFormat.format(new Date()) + "<== " + methodName + " start");
 398
 399         try {
 400             logger.debug(EELFLoggerDelegate.debugLogger, dateFormat.format(new Date()) + "<== " + methodName + " calling Remove relationship from service instance, path =[" + endpoint + "]");
 401
 402             RestObject<String> restObjStr = new RestObject<String>();
 403             String str = "";
 404             restObjStr.set(str);
 405             Post(str, requestDetails, "", endpoint, restObjStr);
 406
 407             return MsoUtil.wrapResponse(restObjStr);
 408         } catch (Exception e) {
 409             logger.info(EELFLoggerDelegate.errorLogger, dateFormat.format(new Date()) + "<== " + "." + methodName + e.toString());
 410             logger.debug(EELFLoggerDelegate.debugLogger, dateFormat.format(new Date()) + "<== " + "." + methodName + e.toString());
 411             throw e;
 412         }
 413     }
 414
 415     @Override
 416     public MsoResponseWrapper addRelationshipToServiceInstance(RequestDetails requestDetails, String addRelationshipsPath) throws Exception {
 417         String methodName = "addRelationshipToServiceInstance";
 418         logger.debug(EELFLoggerDelegate.debugLogger, dateFormat.format(new Date()) + "<== " + methodName + " start");
 419
 420         try {
 421             logger.debug(EELFLoggerDelegate.debugLogger, dateFormat.format(new Date()) + "<== " + methodName + " calling Add relationship to service instance, path =[" + addRelationshipsPath + "]");
 422
 423             RestObject<String> restObjStr = new RestObject<>();
 424             restObjStr.set("");
 425             Post("", requestDetails, "", addRelationshipsPath, restObjStr);
 426
 427             return MsoUtil.wrapResponse(restObjStr);
 428         } catch (Exception e) {
 429             logger.info(EELFLoggerDelegate.errorLogger, dateFormat.format(new Date()) + "<== " + "." + methodName + e.toString());
 430             logger.debug(EELFLoggerDelegate.debugLogger, dateFormat.format(new Date()) + "<== " + "." + methodName + e.toString());
 431             throw e;
 432         }
 433     }
 434
 435 }