Change-Id: I85f94687262107337dc4894d3e29ead4380e4aba
Issue-ID: VFC-544
Signed-off-by: yufei_zhou <yufei.zhou@nokia-sbell.com>
# Config mysql credentials
# Initialize MySQL schema
# Config mysql credentials
# Initialize MySQL schema
+# /usr/bin/mysqld_safe &
cd bin
./init_db.sh root rootpass 127.0.0.1 3306
cd bin
./init_db.sh root rootpass 127.0.0.1 3306
import org.onap.vfc.nfvo.driver.vnfm.svnfm.nslcm.bo.entity.AccessInfo;
import org.onap.vfc.nfvo.driver.vnfm.svnfm.nslcm.bo.entity.GrantInfo;
import org.onap.vfc.nfvo.driver.vnfm.svnfm.nslcm.bo.entity.NslcmVimInfo;
import org.onap.vfc.nfvo.driver.vnfm.svnfm.nslcm.bo.entity.AccessInfo;
import org.onap.vfc.nfvo.driver.vnfm.svnfm.nslcm.bo.entity.GrantInfo;
import org.onap.vfc.nfvo.driver.vnfm.svnfm.nslcm.bo.entity.NslcmVimInfo;
-import org.onap.vfc.nfvo.driver.vnfm.svnfm.nslcm.bo.entity.VimAssets;
import org.onap.vfc.nfvo.driver.vnfm.svnfm.nslcm.bo.entity.VimComputeResourceFlavour;
import org.onap.vfc.nfvo.driver.vnfm.svnfm.vnfmdriver.bo.HealVnfRequest;
import org.onap.vfc.nfvo.driver.vnfm.svnfm.vnfmdriver.bo.InstantiateVnfRequest;
import org.onap.vfc.nfvo.driver.vnfm.svnfm.nslcm.bo.entity.VimComputeResourceFlavour;
import org.onap.vfc.nfvo.driver.vnfm.svnfm.vnfmdriver.bo.HealVnfRequest;
import org.onap.vfc.nfvo.driver.vnfm.svnfm.vnfmdriver.bo.InstantiateVnfRequest;
NslcmGrantVnfRequest grantRequest = buildNslcmGrantVnfRequest();
NslcmGrantVnfResponse grantResponse = nslcmMgmr.grantVnf(grantRequest);
NslcmGrantVnfRequest grantRequest = buildNslcmGrantVnfRequest();
NslcmGrantVnfResponse grantResponse = nslcmMgmr.grantVnf(grantRequest);
- handleNslcmGrantResponse(grantResponse);
-
//step 5: instantiate vnf
CBAMInstantiateVnfRequest instantiateReq = requestConverter.InstantiateReqConvert(driverRequest, grantResponse, null, null);
//step 5: instantiate vnf
CBAMInstantiateVnfRequest instantiateReq = requestConverter.InstantiateReqConvert(driverRequest, grantResponse, null, null);
String packageUrl = vnfPackageInfo.getDownloadUri();
String saveDir = "/service/vnfPackage";
String packageFileName = packageUrl.substring(packageUrl.lastIndexOf("/"));
String packageUrl = vnfPackageInfo.getDownloadUri();
String saveDir = "/service/vnfPackage";
String packageFileName = packageUrl.substring(packageUrl.lastIndexOf("/"));
- Process process = Runtime.getRuntime().exec("mkdir " + saveDir);
+ Process process = Runtime.getRuntime().exec("mkdir -p " + saveDir);
process.waitFor();
if (HttpClientProcessorImpl.downLoadFromUrl(packageUrl, packageFileName, saveDir)) {
process.waitFor();
if (HttpClientProcessorImpl.downLoadFromUrl(packageUrl, packageFileName, saveDir)) {
+ File csarFile = new File(saveDir + "/" + packageFileName);
- ZipUtil.unpack(new File(saveDir + "/" + packageFileName), new File(saveDir));
- //upload package
- String cbamPackageDirName = saveDir + "/"
- + packageFileName.substring(0, packageFileName.length() - 4) + "/Artifacts";
+ ZipUtil.explode(csarFile);
+ csarFile.delete();
+ String cbamPackageDirName = saveDir + "/" + packageFileName + "/Artifacts";
String cbamPackageName = new File(cbamPackageDirName).list()[0];
cbamMgmr.uploadVnfPackage(cbamPackageName);
}
String cbamPackageName = new File(cbamPackageDirName).list()[0];
cbamMgmr.uploadVnfPackage(cbamPackageName);
}
jobDbMgmr.save(jobInfo);
}
jobDbMgmr.save(jobInfo);
}
- private void handleNslcmGrantResponse(NslcmGrantVnfResponse grantResponse) {
- // TODO Auto-generated method stub
+ public static void main(String[] argv) {
+ String saveDir = "D:/tmp/20170926/data";
+ String packageFileName = "vCSCF_v3.0.csar";
+ File csarFile = new File(saveDir + "/" + packageFileName);
+ ZipUtil.explode(csarFile);
+ csarFile.delete();
+ String cbamPackageDirName = saveDir + "/" + packageFileName + "/Artifacts";
+ String cbamPackageName = new File(cbamPackageDirName).list()[0];
+ System.out.println(cbamPackageName);
@Autowired
HttpClientProcessorInf httpClientProcessor;
@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<String, String> map = new HashMap<>();
map.put(CommonConstants.ACCEPT, "*/*");
map.put(CommonConstants.CONTENT_TYPE, MediaType.APPLICATION_FORM_URLENCODED_VALUE);
String result = null;
String url= adaptorEnv.getCbamApiUriFront() + CommonConstants.CbamRetrieveTokenPath;
HashMap<String, String> 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();
String responseStr = httpClientProcessor.process(url, RequestMethod.POST, map, bodyPostStr).getContent();
HttpResult httpResult = operateCbamHttpUploadTask(cbamPackageFilePath, httpPath, method);
String responseStr = httpResult.getContent();
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) {
int code = httpResult.getStatusCode();
if(code == 200) {
- 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();
String token = null;
try {
token = retrieveToken();
map.put(CommonConstants.AUTHORIZATION, "bearer " + token);
map.put(CommonConstants.CONTENT_TYPE, "multipart/form-data, boundary=--fsgdsfgjgjdsgdfjgjgj");
byte[] fileBytes = CommonUtil.getBytes(filePath);
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);
}
return httpClientProcessor.processBytes(url, method, map, fileBytes);
}
+
+ public HttpClientProcessorInf getHttpClientProcessor() {
+ return httpClientProcessor;
+ }
+
+ public void setHttpClientProcessor(HttpClientProcessorInf httpClientProcessor) {
+ this.httpClientProcessor = httpClientProcessor;
+ }
public static final String CbamScaleVnfPath = "/vnfs/%s/scale";
public static final String CbamHealVnfPath="/vnfs/%s/heal";
public static final String CbamScaleVnfPath = "/vnfs/%s/scale";
public static final String CbamHealVnfPath="/vnfs/%s/heal";
- public static final String CbamUploadVnfPackagePath="/api/catalog/vnfpackages";
+ public static final String CbamUploadVnfPackagePath="/api/catalog/adapter/vnfpackages";
public static final String NSLCM_OPERATION_INSTANTIATE = "Instantiate";
public static final String NSLCM_OPERATION_INSTANTIATE = "Instantiate";
{
URL url = new URL(urlStr);
HttpURLConnection conn = (HttpURLConnection)url.openConnection();
{
URL url = new URL(urlStr);
HttpURLConnection conn = (HttpURLConnection)url.openConnection();
- conn.setConnectTimeout(10*1000);
+ conn.setConnectTimeout(20*1000);
conn.setRequestProperty("User-Agent", "Mozilla/4.0 (compatible; MSIE 5.0; Windows NT; DigExt)");
InputStream inputStream = conn.getInputStream();
byte[] getData = readInputStream(inputStream);
conn.setRequestProperty("User-Agent", "Mozilla/4.0 (compatible; MSIE 5.0; Windows NT; DigExt)");
InputStream inputStream = conn.getInputStream();
byte[] getData = readInputStream(inputStream);
.register("https", sslSocketFactory)
.build();
.register("https", sslSocketFactory)
.build();
- PoolingHttpClientConnectionManager connMgr = new PoolingHttpClientConnectionManager( socketFactoryRegistry);
+ PoolingHttpClientConnectionManager connMgr = new PoolingHttpClientConnectionManager(socketFactoryRegistry);
connMgr.setMaxTotal(200);
connMgr.setDefaultMaxPerRoute(50);
httpClientBuilder.setConnectionManager(connMgr);
connMgr.setMaxTotal(200);
connMgr.setDefaultMaxPerRoute(50);
httpClientBuilder.setConnectionManager(connMgr);
return httpClientBuilder;
}
return httpClientBuilder;
}
import org.apache.http.client.ClientProtocolException;
import org.apache.http.client.methods.HttpPost;
import org.apache.http.client.methods.HttpRequestBase;
import org.apache.http.client.ClientProtocolException;
import org.apache.http.client.methods.HttpPost;
import org.apache.http.client.methods.HttpRequestBase;
-import org.apache.http.entity.StringEntity;
import org.apache.http.entity.ByteArrayEntity;
import org.apache.http.entity.ByteArrayEntity;
+import org.apache.http.entity.StringEntity;
import org.apache.http.impl.client.CloseableHttpClient;
import org.apache.http.impl.client.HttpClientBuilder;
import org.apache.http.util.EntityUtils;
import org.apache.http.impl.client.CloseableHttpClient;
import org.apache.http.impl.client.HttpClientBuilder;
import org.apache.http.util.EntityUtils;
httpRequest.setURI(URI.create(url));
HttpResponse response = httpClient.execute(httpRequest);
httpRequest.setURI(URI.create(url));
HttpResponse response = httpClient.execute(httpRequest);
HttpResult httpResult = buildHttpResult(response);
return httpResult;
HttpResult httpResult = buildHttpResult(response);
return httpResult;