bpmn/MSOCommonBPMN/src/test/java/org/openecomp/mso/bpmn/mock/SDNCAdapterNetworkTopologyMockTransformer.java

   1 /*
   2  * ============LICENSE_START=======================================================
   3  * ONAP - SO
   4  * ================================================================================
   5  * Licensed under the Apache License, Version 2.0 (the "License");
   6  * you may not use this file except in compliance with the License.
   7  * You may obtain a copy of the License at
   8  *
   9  *      http://www.apache.org/licenses/LICENSE-2.0
  10  *
  11  * Unless required by applicable law or agreed to in writing, software
  12  * distributed under the License is distributed on an "AS IS" BASIS,
  13  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  14  * See the License for the specific language governing permissions and
  15  * limitations under the License.
  16  * ============LICENSE_END=========================================================
  17  */
  18
  19 package org.openecomp.mso.bpmn.mock;
  20
  21 import org.jboss.resteasy.client.ClientRequest;
  22 import org.jboss.resteasy.client.ClientResponse;
  23
  24 import com.github.tomakehurst.wiremock.client.ResponseDefinitionBuilder;
  25 import com.github.tomakehurst.wiremock.common.FileSource;
  26 import com.github.tomakehurst.wiremock.extension.ResponseTransformer;
  27 import com.github.tomakehurst.wiremock.http.Request;
  28 import com.github.tomakehurst.wiremock.http.ResponseDefinition;
  29
  30 import org.openecomp.mso.logger.MsoLogger;
  31
  32 public class SDNCAdapterNetworkTopologyMockTransformer extends ResponseTransformer {
  33
  34         private static final MsoLogger LOGGER = MsoLogger.getMsoLogger(MsoLogger.Catalog.BPEL);
  35
  36         private String callbackResponse;
  37         private String requestId;
  38
  39         public SDNCAdapterNetworkTopologyMockTransformer() {
  40                 callbackResponse = ""; // FileUtil.readResourceFile("__files/sdncDeleteNetworkTopologySimResponse.xml");
  41         }
  42
  43         public SDNCAdapterNetworkTopologyMockTransformer(String requestId) {
  44                 this.requestId = requestId;
  45         }
  46
  47         public String name() {
  48                 return "network-topology-operation-transformer";
  49         }
  50
  51         @Override
  52         public ResponseDefinition transform(Request request, ResponseDefinition responseDefinition, FileSource fileSource) {
  53                 String requestBody = request.getBodyAsString();
  54
  55                 String callbackUrl = requestBody.substring(requestBody.indexOf("<sdncadapter:CallbackUrl>")+25, requestBody.indexOf("</sdncadapter:CallbackUrl>"));
  56                 String requestId = requestBody.substring(requestBody.indexOf("<sdncadapter:RequestId>")+23, requestBody.indexOf("</sdncadapter:RequestId>"));
  57                 System.out.println("request callbackUrl : " + callbackUrl);
  58                 System.out.println("request requestId : " + requestId);
  59
  60                 System.out.println("file path/name : " + responseDefinition.getBodyFileName());
  61                 callbackResponse = FileUtil.readResourceFile("__files/" + responseDefinition.getBodyFileName());
  62                 // extract Response responseRequestId
  63                 String responseRequestId = callbackResponse.substring(callbackResponse.indexOf("<RequestId>")+11, callbackResponse.indexOf("</RequestId>"));
  64                 System.out.println("response requestId: " + responseRequestId);
  65                 System.out.println("callbackResponse (before): " + callbackResponse);
  66                 callbackResponse = callbackResponse.replace(responseRequestId, requestId);
  67                 if (this.requestId != null) {
  68                         callbackResponse = callbackResponse.replace(this.requestId, requestId);
  69                 } else {
  70                         callbackResponse = callbackResponse.replace(responseRequestId, requestId);
  71                 }
  72                 System.out.println("callbackResponse (after):" + callbackResponse);
  73
  74                 Object sdncDelay = MockResource.getMockProperties().get("sdnc_delay");
  75                 int delay = 300;
  76                 if (sdncDelay != null) {
  77                         delay = Integer.parseInt(sdncDelay.toString());
  78                 }
  79
  80                 //Kick off callback thread
  81                 System.out.println("(NetworkTopologyMockTransformer) callback Url:" + callbackUrl + ":delay:" + delay);
  82                 CallbackResponseThread calbackResponseThread = new CallbackResponseThread(callbackUrl,callbackResponse, delay);
  83                 calbackResponseThread.start();
  84
  85                 //return 200 OK with body
  86                 return ResponseDefinitionBuilder
  87                 .like(responseDefinition).but()
  88                 .withStatus(200).withBody(callbackResponse).withHeader("Content-Type", "text/xml")
  89                 .build();
  90         }
  91
  92         @Override
  93         public boolean applyGlobally() {
  94             return false;
  95         }
  96
  97         private class CallbackResponseThread extends Thread {
  98
  99                 private String callbackUrl;
 100                 private String payLoad;
 101                 private int delay;
 102
 103                 public CallbackResponseThread(String callbackUrl, String payLoad, int delay) {
 104                         this.callbackUrl = callbackUrl;
 105                         this.payLoad = payLoad;
 106                         this.delay = delay;
 107                 }
 108
 109                 public void run () {
 110                         try {
 111                                 //Delay sending callback response
 112                                 sleep(delay);
 113                         } catch (InterruptedException e1) {
 114                                 // TODO Auto-generated catch block
 115                                 LOGGER.debug("Exception :",e1);
 116                         }
 117                         LOGGER.debug("Sending callback response to url: " + callbackUrl);
 118                         ClientRequest request = new ClientRequest(callbackUrl);
 119                         request.body("text/xml", payLoad);
 120                         //System.err.println(payLoad);
 121                         try {
 122                                 ClientResponse result = request.post();
 123                                 LOGGER.debug("Successfully posted callback? Status: " + result.getStatus());
 124                         } catch (Exception e) {
 125                                 // TODO Auto-generated catch block
 126                             LOGGER.debug("catch error in - request.post() ");
 127                                 LOGGER.debug("Exception :",e);
 128                         }
 129                 }
 130
 131         }
 132 }