X-Git-Url: https://gerrit.onap.org/r/gitweb?a=blobdiff_plain;f=nokia%2Fvnfmdriver%2Fvfcadaptorservice%2Fvfcadaptor%2Fsrc%2Fmain%2Fjava%2Forg%2Fonap%2Fvfc%2Fnfvo%2Fdriver%2Fvnfm%2Fsvnfm%2Fcbam%2Fimpl%2FCbamMgmrImpl.java;h=dc6a6189e42ba12473e319aa1f4e2af79b703f74;hb=c8ef1d3751ec0893a4e7a138b653693abf2045d1;hp=6afa6c8d99a562e3f8ca35a7115b9700d4bdf7ac;hpb=e4c82a3e7eb32ff4a754648292ce080caf870d6b;p=vfc%2Fnfvo%2Fdriver%2Fvnfm%2Fsvnfm.git diff --git a/nokia/vnfmdriver/vfcadaptorservice/vfcadaptor/src/main/java/org/onap/vfc/nfvo/driver/vnfm/svnfm/cbam/impl/CbamMgmrImpl.java b/nokia/vnfmdriver/vfcadaptorservice/vfcadaptor/src/main/java/org/onap/vfc/nfvo/driver/vnfm/svnfm/cbam/impl/CbamMgmrImpl.java index 6afa6c8d..dc6a6189 100644 --- a/nokia/vnfmdriver/vfcadaptorservice/vfcadaptor/src/main/java/org/onap/vfc/nfvo/driver/vnfm/svnfm/cbam/impl/CbamMgmrImpl.java +++ b/nokia/vnfmdriver/vfcadaptorservice/vfcadaptor/src/main/java/org/onap/vfc/nfvo/driver/vnfm/svnfm/cbam/impl/CbamMgmrImpl.java @@ -59,14 +59,17 @@ public class CbamMgmrImpl implements CbamMgmrInf { @Autowired HttpClientProcessorInf httpClientProcessor; - private String retrieveToken() throws ClientProtocolException, IOException, JSONException { + public String retrieveToken() throws ClientProtocolException, IOException, JSONException { String result = null; String url= adaptorEnv.getCbamApiUriFront() + CommonConstants.CbamRetrieveTokenPath; HashMap map = new HashMap<>(); map.put(CommonConstants.ACCEPT, "*/*"); map.put(CommonConstants.CONTENT_TYPE, MediaType.APPLICATION_FORM_URLENCODED_VALUE); - String bodyPostStr = String.format(CommonConstants.CbamRetrieveTokenPostStr, adaptorEnv.getGrantType(), adaptorEnv.getClientId(), adaptorEnv.getClientSecret(), adaptorEnv.getCbamUserName(), adaptorEnv.getCbamPassword()); + String bodyPostStr = String.format(CommonConstants.CbamRetrieveTokenPostStr, adaptorEnv.getClientId(), adaptorEnv.getClientSecret(), adaptorEnv.getCbamUserName(), adaptorEnv.getCbamPassword()); + + logger.debug("CbamMgmrImpl -> retrieveToken, url is " + url); + logger.debug("CbamMgmrImpl -> retrieveToken, bodyPostStr is " + bodyPostStr); String responseStr = httpClientProcessor.process(url, RequestMethod.POST, map, bodyPostStr).getContent(); @@ -262,7 +265,7 @@ public class CbamMgmrImpl implements CbamMgmrInf { HttpResult httpResult = operateCbamHttpUploadTask(cbamPackageFilePath, httpPath, method); String responseStr = httpResult.getContent(); - logger.info("CbamMgmrImpl -> uploadVnfPackage, responseStr is " + responseStr); + logger.info("CbamMgmrImpl -> uploadVnfPackage, statusCode is " + httpResult.getStatusCode() + ", cause is " + httpResult.getStatusCause() + ". responseStr is " + responseStr); int code = httpResult.getStatusCode(); if(code == 200) { @@ -273,7 +276,7 @@ public class CbamMgmrImpl implements CbamMgmrInf { } } - private HttpResult operateCbamHttpUploadTask(String filePath, String httpPath, RequestMethod method) throws ClientProtocolException, IOException { + public HttpResult operateCbamHttpUploadTask(String filePath, String httpPath, RequestMethod method) throws ClientProtocolException, IOException { String token = null; try { token = retrieveToken(); @@ -287,6 +290,18 @@ public class CbamMgmrImpl implements CbamMgmrInf { map.put(CommonConstants.AUTHORIZATION, "bearer " + token); map.put(CommonConstants.CONTENT_TYPE, "multipart/form-data, boundary=--fsgdsfgjgjdsgdfjgjgj"); byte[] fileBytes = CommonUtil.getBytes(filePath); + logger.info("CbamMgmrImpl -> operateCbamHttpUploadTask, url is " + url); + logger.info("CbamMgmrImpl -> operateCbamHttpUploadTask, token is " + token); + logger.info("CbamMgmrImpl -> operateCbamHttpUploadTask, bodyPostStr byte lenth is " + fileBytes.length); + return httpClientProcessor.processBytes(url, method, map, fileBytes); } + + public HttpClientProcessorInf getHttpClientProcessor() { + return httpClientProcessor; + } + + public void setHttpClientProcessor(HttpClientProcessorInf httpClientProcessor) { + this.httpClientProcessor = httpClientProcessor; + } }