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=49a51f3aadef6368d773a5625181c8e35551932c;hb=029a1743a0e3e5c81a232c2153ea9d1b808ba7b6;hp=dc6a6189e42ba12473e319aa1f4e2af79b703f74;hpb=98b79d96202bc04aec130bf7df6cfc3c78b58ec9;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 dc6a6189..49a51f3a 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
@@ -16,7 +16,10 @@
 
 package org.onap.vfc.nfvo.driver.vnfm.svnfm.cbam.impl;
 
+import java.io.BufferedReader;
 import java.io.IOException;
+import java.io.InputStream;
+import java.io.InputStreamReader;
 import java.util.HashMap;
 
 import org.apache.http.client.ClientProtocolException;
@@ -37,7 +40,6 @@ import org.onap.vfc.nfvo.driver.vnfm.svnfm.cbam.bo.CBAMTerminateVnfRequest;
 import org.onap.vfc.nfvo.driver.vnfm.svnfm.cbam.bo.CBAMTerminateVnfResponse;
 import org.onap.vfc.nfvo.driver.vnfm.svnfm.cbam.inf.CbamMgmrInf;
 import org.onap.vfc.nfvo.driver.vnfm.svnfm.common.bo.AdaptorEnv;
-import org.onap.vfc.nfvo.driver.vnfm.svnfm.common.util.CommonUtil;
 import org.onap.vfc.nfvo.driver.vnfm.svnfm.constant.CommonConstants;
 import org.onap.vfc.nfvo.driver.vnfm.svnfm.http.client.HttpClientProcessorInf;
 import org.onap.vfc.nfvo.driver.vnfm.svnfm.http.client.HttpResult;
@@ -283,19 +285,93 @@ public class CbamMgmrImpl implements CbamMgmrInf {
 		} catch (JSONException e) {
 			logger.error("retrieveTokenError ", e);
 		}
-	
 		String url = adaptorEnv.getCbamApiUriFront() + httpPath;
+		String command =  "curl --insecure -X POST -H \"Authorization: bearer " + token + "\" --form content=@" + filePath + " " + url;
+		StringBuffer respStr = new StringBuffer();
+		try {
+			logger.info("start to upload file.");
+			String os = System.getProperty("os.name"); 
+			String[] cmd = {"cmd", "/C", command};
+			if(!os.toLowerCase().startsWith("win")){
+				cmd = new String[]{"/bin/sh"," -c ", command};
+			}  
+			Process process = Runtime.getRuntime().exec(cmd);
+             InputStream fis=process.getInputStream();    
+             InputStreamReader isr=new InputStreamReader(fis);    
+             BufferedReader br=new BufferedReader(isr);    
+             String line=null;    
+            while((line = br.readLine())!=null)    
+             {    
+            	respStr.append(line);    
+             }    
+			
+		} catch (Exception e) {
+			logger.error("operateCbamHttpUploadTask error", e);
+		}
 		
-		HashMap<String, String> map = new HashMap<>();
-		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);
+//		HashMap<String, String> map = new HashMap<>();
+//		map.put(CommonConstants.AUTHORIZATION, "bearer " + token);
+//		map.put(CommonConstants.CONTENT_TYPE, "multipart/form-data, boundary=---CFSGSSGGSGdssdfsdhd---");
+//		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);
+		
+		HttpResult hResult = new HttpResult();
+		hResult.setContent(respStr.toString());
+		hResult.setStatusCode(200);
+		return hResult;
+		
+//		String charset = "UTF-8";
+//        File uploadFile1 = new File(filePath);
+//        String requestURL = url;
+//        HttpResult result = new HttpResult();
+// 
+//        try {
+//            MultipartUtility multipart = new MultipartUtility(requestURL, charset);
+//             
+//            multipart.addHeaderField("User-Agent", "CodeJava");
+//            multipart.addHeaderField(CommonConstants.AUTHORIZATION, "bearer " + token);
+//             
+//            multipart.addFilePart("fileUpload", uploadFile1);
+// 
+//            List<String> response = multipart.finish();
+//             
+//            result.setContent(Arrays.deepToString(response.toArray(new String[0])));
+//            result.setStatusCode(200);
+//        } catch (Exception ex) {
+//        	logger.error("CbamMgmrImpl -> operateCbamHttpUploadTask, error ", ex);
+//            result.setStatusCode(500);
+//        }
+//        
+//        return result;
 	}
+	
+//	public static String postByHttps(String url, String body, Object contentType) {
+//	    String result = "";
+//	    Protocol https = new Protocol("https", new HTTPSSecureProtocolSocketFactory(), 443);
+//	    Protocol.registerProtocol("https", https);
+//	    PostMethod post = new PostMethod(url);
+//	    HttpClient client = new HttpClient();
+//	    try {
+//	        post.setRequestHeader("Content-Type", contentType);
+//	        post.setRequestBody(body);
+//	        client.executeMethod(post);
+//	        result = post.getResponseBodyAsString();
+//	        Protocol.unregisterProtocol("https");
+//	        return result;
+//	    } catch (HttpException e) {
+//	        e.printStackTrace();
+//	    } catch (IOException e) {
+//	        e.printStackTrace();
+//	    } catch(Exception e) {
+//	        e.printStackTrace();
+//	    }
+//	 
+//	    return "error";
+//	}
 
 	public HttpClientProcessorInf getHttpClientProcessor() {
 		return httpClientProcessor;