* See the License for the specific language governing permissions and
* limitations under the License.
*/
+
package org.onap.vnfsdk.marketplace.wrapper;
import java.io.BufferedInputStream;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
-import net.sf.json.JSONObject;
-
public class PackageWrapper {
+
private static PackageWrapper packageWrapper;
+
private static final Logger LOG = LoggerFactory.getLogger(PackageWrapper.class);
/**
* get PackageWrapper instance.
+ *
* @return package wrapper instance
*/
public static PackageWrapper getInstance() {
- if (packageWrapper == null) {
+ if(packageWrapper == null) {
packageWrapper = new PackageWrapper();
}
return packageWrapper;
}
- public Response updateValidateStatus(InputStream inputStream) throws IOException
- {
+ public Response updateValidateStatus(InputStream inputStream) throws IOException {
String reqParam = IOUtils.toString(inputStream);
- LOG.info("updateValidateStatus request param:"+reqParam);
+ LOG.info("updateValidateStatus request param:" + reqParam);
if(StringUtils.isBlank(reqParam)) {
LOG.error("The updateValidateStatus request params can't be null");
return Response.status(Status.EXPECTATION_FAILED).build();
}
- ValidateLifecycleTestResponse lyfValidateResp = JsonUtil.fromJson(reqParam, ValidateLifecycleTestResponse.class);
- if(!checkOperationSucess(lyfValidateResp))
- {
+ ValidateLifecycleTestResponse lyfValidateResp =
+ JsonUtil.fromJson(reqParam, ValidateLifecycleTestResponse.class);
+ if(!checkOperationSucess(lyfValidateResp)) {
return Response.status(Status.EXPECTATION_FAILED).build();
}
String funcTestResponse = FunctionTestExceutor.executeFunctionTest(reqParam);
- if(null == funcTestResponse)
- {
+ if(null == funcTestResponse) {
return Response.status(Status.EXPECTATION_FAILED).build();
}
- JSONObject funcTestRspObject = JSONObject.fromObject(funcTestResponse);
- if(!funcTestRspObject.get("status").equals(CommonConstant.SUCCESS_STR))
- {
+ if(!funcTestResponse.contains(CommonConstant.SUCCESS_STR)) {
return Response.status(Status.EXPECTATION_FAILED).build();
}
- JSONObject result = new JSONObject();
- result.put("msg","SUCCESS");
- return Response.ok(ToolUtil.objectToString(result), MediaType.APPLICATION_JSON).build();
+ return Response.ok().build();
}
- private boolean checkOperationSucess(ValidateLifecycleTestResponse lyfValidateResp)
- {
+ private boolean checkOperationSucess(ValidateLifecycleTestResponse lyfValidateResp) {
boolean bOperStatus = false;
- if(null == lyfValidateResp)
- {
+ if(null == lyfValidateResp) {
LOG.error("ValidateLifecycleTestResponse is NUll !!!");
return bOperStatus;
}
if(lyfValidateResp.getLifecycle_status().equalsIgnoreCase(CommonConstant.SUCCESS_STR)
- && lyfValidateResp.getValidate_status().equalsIgnoreCase(CommonConstant.SUCCESS_STR))
- {
- LOG.error("Lifecycle/Validation Response failed :" + lyfValidateResp.getLifecycle_status() + File.separator + lyfValidateResp.getValidate_status());
- bOperStatus = true;
+ && lyfValidateResp.getValidate_status().equalsIgnoreCase(CommonConstant.SUCCESS_STR)) {
+ LOG.error("Lifecycle/Validation Response failed :" + lyfValidateResp.getLifecycle_status() + File.separator
+ + lyfValidateResp.getValidate_status());
+ bOperStatus = true;
}
return bOperStatus;
}
/**
* query package list by condition.
+ *
* @param name package name
* @param provider package provider
* @param version package version
* @param type package type
* @return Response
*/
- public Response queryPackageListByCond(String name, String provider, String version,
- String deletionPending, String type) {
+ public Response queryPackageListByCond(String name, String provider, String version, String deletionPending,
+ String type) {
List<PackageData> dbresult = new ArrayList<>();
List<PackageMeta> result = new ArrayList<>();
- LOG.info("query package info.name:" + name + " provider:" + provider + " version" + version
- + " deletionPending" + deletionPending + " type:" + type);
+ LOG.info("query package info.name:" + name + " provider:" + provider + " version" + version + " deletionPending"
+ + deletionPending + " type:" + type);
try {
- dbresult =
- PackageManager.getInstance().queryPackage(name, provider, version, deletionPending, type);
+ dbresult = PackageManager.getInstance().queryPackage(name, provider, version, deletionPending, type);
result = PackageWrapperUtil.packageDataList2PackageMetaList(dbresult);
return Response.ok(ToolUtil.objectToString(result)).build();
- } catch (MarketplaceResourceException e1) {
+ } catch(MarketplaceResourceException e1) {
LOG.error("query package by csarId from db error ! ", e1);
return RestUtil.getRestException(e1.getMessage());
}
/**
* query package by id.
+ *
* @param csarId package id
* @return Response
*/
/**
* upload package.
+ *
* @param uploadedInputStream inputStream
* @param fileDetail package detail
* @param head http header
* @return Response
* @throws Exception e
*/
- public Response uploadPackage(InputStream uploadedInputStream,
- FormDataContentDisposition fileDetail, String details, HttpHeaders head) throws MarketplaceResourceException
- {
+ public Response uploadPackage(InputStream uploadedInputStream, FormDataContentDisposition fileDetail,
+ String details, HttpHeaders head) throws MarketplaceResourceException {
LOG.info("Upload/Reupload request Received !!!!");
try {
String packageId = MarketplaceDbUtil.generateId();
- return handlePackageUpload(packageId,uploadedInputStream, fileDetail, details, head);
- } catch (IOException e) {
+ return handlePackageUpload(packageId, uploadedInputStream, fileDetail, details, head);
+ } catch(IOException e) {
LOG.error("can't get package id", e);
}
return Response.status(Status.INTERNAL_SERVER_ERROR).build();
}
- private UploadPackageResponse manageUpload(String packageId, String fileName, String fileLocation,
- String details, String contentRange) throws IOException, MarketplaceResourceException
- {
+ private UploadPackageResponse manageUpload(String packageId, String fileName, String fileLocation, String details,
+ String contentRange) throws IOException, MarketplaceResourceException {
String localDirName = ToolUtil.getTempDir(CommonConstant.CATALOG_CSAR_DIR_NAME, fileName);
PackageBasicInfo basicInfo = PackageWrapperUtil.getPacageBasicInfo(fileLocation);
UploadPackageResponse result = new UploadPackageResponse();
Boolean isEnd = PackageWrapperUtil.isUploadEnd(contentRange);
- if (isEnd)
- {
- PackageMeta packageMeta = PackageWrapperUtil.getPackageMeta(packageId, fileName, fileLocation, basicInfo, details);
+ if(isEnd) {
+ PackageMeta packageMeta =
+ PackageWrapperUtil.getPackageMeta(packageId, fileName, fileLocation, basicInfo, details);
try {
- String path = basicInfo.getType().toString() + File.separator + basicInfo.getProvider() + File.separator + packageMeta.getCsarId() + File.separator + fileName.replace(".csar", "") + File.separator + basicInfo.getVersion();
+ String path = basicInfo.getType().toString() + File.separator + basicInfo.getProvider() + File.separator
+ + packageMeta.getCsarId() + File.separator + fileName.replace(".csar", "") + File.separator
+ + basicInfo.getVersion();
String dowloadUri = File.separator + path + File.separator;
packageMeta.setDownloadUri(dowloadUri);
String destPath = File.separator + path + File.separator + File.separator;
boolean uploadResult = FileManagerFactory.createFileManager().upload(localDirName, destPath);
- if (uploadResult)
- {
+ if(uploadResult) {
OnBoradingRequest oOnboradingRequest = new OnBoradingRequest();
oOnboradingRequest.setCsarId(packageId);
oOnboradingRequest.setPackageName(fileName);
packageData.setDownloadCount(-1);
PackageData packateDbData = PackageManager.getInstance().addPackage(packageData);
- LOG.info("Store package data to database succed ! packateDbData = " + ToolUtil.objectToString(packateDbData));
+ LOG.info("Store package data to database succed ! packateDbData = "
+ + ToolUtil.objectToString(packateDbData));
LOG.info("upload package file end, fileName:" + fileName);
result.setCsarId(packateDbData.getCsarId());
addOnBoardingRequest(oOnboradingRequest);
- LOG.info("OnboradingRequest Data : " + ToolUtil.objectToString(oOnboradingRequest));
+ LOG.info("OnboradingRequest Data : " + ToolUtil.objectToString(oOnboradingRequest));
}
- } catch (NullPointerException e) {
+ } catch(NullPointerException e) {
LOG.error("Package basicInfo is incorrect ! basicIonfo = " + ToolUtil.objectToString(basicInfo), e);
return null;
}
/**
* Interface for Uploading package
+ *
* @param packageId
* @param uploadedInputStream
* @param fileDetail
* @throws IOException
* @throws MarketplaceResourceException
*/
- private Response handlePackageUpload(String packageId,InputStream uploadedInputStream, FormDataContentDisposition fileDetail,
- String details, HttpHeaders head) throws IOException, MarketplaceResourceException
- {
- boolean bResult = handleDataValidate(packageId,uploadedInputStream,fileDetail);
- if(!bResult)
- {
+ private Response handlePackageUpload(String packageId, InputStream uploadedInputStream,
+ FormDataContentDisposition fileDetail, String details, HttpHeaders head)
+ throws IOException, MarketplaceResourceException {
+ boolean bResult = handleDataValidate(packageId, uploadedInputStream, fileDetail);
+ if(!bResult) {
LOG.error("Validation of Input received for Package Upload failed !!!");
return Response.status(Status.EXPECTATION_FAILED).build();
}
- String fileName = "temp_"+ packageId + ".csar";
- if (null != fileDetail)
- {
+ String fileName = "temp_" + packageId + ".csar";
+ if(null != fileDetail) {
LOG.info("the fileDetail = " + ToolUtil.objectToString(fileDetail));
fileName = ToolUtil.processFileName(fileDetail.getFileName());
String localDirName = ToolUtil.getTempDir(CommonConstant.CATALOG_CSAR_DIR_NAME, fileName);
String contentRange = null;
- if (head != null)
- {
+ if(head != null) {
contentRange = head.getHeaderString(CommonConstant.HTTP_HEADER_CONTENT_RANGE);
}
LOG.info("store package chunk file, fileName:" + fileName + ",contentRange:" + contentRange);
- if (ToolUtil.isEmptyString(contentRange))
- {
+ if(ToolUtil.isEmptyString(contentRange)) {
int fileSize = uploadedInputStream.available();
contentRange = "0-" + fileSize + "/" + fileSize;
}
try {
CsarValidator cv = new CsarValidator(packageId, fileLocation);
- if (!cv.validateCsar()) {
+ if(!cv.validateCsar()) {
LOG.error("Could not validate failed");
return Response.status(Status.EXPECTATION_FAILED).build();
}
- } catch (Exception e) {
+ } catch(Exception e) {
LOG.error("CSAR validation panicked", e);
return Response.status(Status.EXPECTATION_FAILED).build();
}
UploadPackageResponse result = manageUpload(packageId, fileName, fileLocation, details, contentRange);
- if (null != result)
- {
+ if(null != result) {
return Response.ok(ToolUtil.objectToString(result), MediaType.APPLICATION_JSON).build();
} else {
return Response.serverError().build();
/**
* Execute OnBarding request
+ *
* @param oOnboradingRequest
*/
- private void addOnBoardingRequest(final OnBoradingRequest oOnboradingRequest)
- {
+ private void addOnBoardingRequest(final OnBoradingRequest oOnboradingRequest) {
ExecutorService es = Executors.newFixedThreadPool(CommonConstant.ONBOARDING_THREAD_COUNT);
Callable<Integer> callableInteger = () -> {
new OnBoardingHandler().handleOnBoardingReq(oOnboradingRequest);
/**
* delete package by package id.
+ *
* @param csarId package id
* @return Response
*/
public Response delPackage(String csarId) {
LOG.info("delete package info.csarId:" + csarId);
- if (ToolUtil.isEmptyString(csarId)) {
+ if(ToolUtil.isEmptyString(csarId)) {
LOG.error("delete package fail, csarid is null");
return Response.serverError().build();
}
/**
* Delete Package by CSAR ID
+ *
* @param csarId
*/
- private void deletePackageDataById(String csarId) {
+ private void deletePackageDataById(String csarId) {
String packagePath = PackageWrapperUtil.getPackagePath(csarId);
- if (packagePath == null) {
+ if(packagePath == null) {
LOG.error("package path is null! ");
}
- //Delete Package
+ // Delete Package
FileManagerFactory.createFileManager().delete(packagePath);
- //Delete Results Data
+ // Delete Results Data
FileManagerFactory.createFileManager().delete(File.separator + csarId);
-
- //delete package data from database
+ // delete package data from database
try {
PackageManager.getInstance().deletePackage(csarId);
- } catch (MarketplaceResourceException e1) {
+ } catch(MarketplaceResourceException e1) {
LOG.error("delete package by csarId from db error ! " + e1.getMessage(), e1);
}
}
/**
* download package by package id.
+ *
* @param csarId package id
* @return Response
*/
PackageData packageData = PackageWrapperUtil.getPackageInfoById(csarId);
String packageName = packageData.getName();
- String path = org.onap.vnfsdk.marketplace.filemanage.http.ToolUtil.getHttpServerAbsolutePath() +File.separatorChar+packageData.getType()+File.separatorChar+
- packageData.getProvider()+File.separatorChar+ packageData.getCsarId() +File.separator +packageName+File.separatorChar+packageData.getVersion()
- +File.separator + packageName + ".csar";
+ String path = org.onap.vnfsdk.marketplace.filemanage.http.ToolUtil.getHttpServerAbsolutePath()
+ + File.separatorChar + packageData.getType() + File.separatorChar + packageData.getProvider()
+ + File.separatorChar + packageData.getCsarId() + File.separator + packageName + File.separatorChar
+ + packageData.getVersion() + File.separator + packageName + ".csar";
LOG.info("downloadCsarPackagesById path is : " + path);
File csarFile = new File(path);
- if (!csarFile.exists()) {
+ if(!csarFile.exists()) {
return Response.status(Status.INTERNAL_SERVER_ERROR).build();
}
LOG.info("downloadCsarPackagesById ABS path is : " + csarFile.getAbsolutePath());
- try
- {
+ try {
InputStream fis = new BufferedInputStream(new FileInputStream(csarFile.getAbsolutePath()));
- return Response.ok(fis)
- .header("Content-Disposition", "attachment; filename=\"" + csarFile.getName() + "\"")
+ return Response.ok(fis).header("Content-Disposition", "attachment; filename=\"" + csarFile.getName() + "\"")
.build();
- }
- catch (Exception e1)
- {
+ } catch(Exception e1) {
LOG.error("download vnf package fail.", e1);
return RestUtil.getRestException(e1.getMessage());
}
/**
* get package file uri.
+ *
* @param csarId package id
* @param relativePath file relative path
* @return Response
/**
* Interface to Update Download count for CSAR ID
+ *
* @param csarId
* @return
*/
public Response updateDwonloadCount(String csarId) {
- return handleDownladCountUpdate(csarId) ?
- Response.ok().build() :
- Response.status(Status.EXPECTATION_FAILED).build();
+ return handleDownladCountUpdate(csarId) ? Response.ok().build()
+ : Response.status(Status.EXPECTATION_FAILED).build();
}
/**
* Handle downlowa count update
+ *
* @param csarId
* @return
*/
private boolean handleDownladCountUpdate(String csarId) {
boolean bupdateSucess = false;
- try
- {
+ try {
PackageManager.getInstance().updateDownloadCount(csarId);
bupdateSucess = true;
- }
- catch (Exception exp)
- {
+ } catch(Exception exp) {
LOG.error("Updating Donwload count failed for Package with ID !!! : " + exp.getMessage(), exp);
}
return bupdateSucess;
/**
* Interface to Re upload Package
+ *
* @param csarId
* @param uploadedInputStream
* @param fileDetail
* @return
* @throws Exception
*/
- public Response reUploadPackage(String csarId,
- InputStream uploadedInputStream,
- FormDataContentDisposition fileDetail,
- String details,
- HttpHeaders head) throws MarketplaceResourceException
- {
+ public Response reUploadPackage(String csarId, InputStream uploadedInputStream,
+ FormDataContentDisposition fileDetail, String details, HttpHeaders head)
+ throws MarketplaceResourceException {
LOG.info("Reupload request Received !!!!");
- //STEP 1: Validate Input Data
- //----------------------------
- boolean bResult = handleDataValidate(csarId,uploadedInputStream,fileDetail);
- if(!bResult)
- {
+ // STEP 1: Validate Input Data
+ // ----------------------------
+ boolean bResult = handleDataValidate(csarId, uploadedInputStream, fileDetail);
+ if(!bResult) {
LOG.error("Validation of Input received for Package Upload failed during Reload!!!");
return Response.status(Status.EXPECTATION_FAILED).build();
}
try {
- //STEP 2: Delete All Package Data based on package id
- //----------------------------------------------------
+ // STEP 2: Delete All Package Data based on package id
+ // ----------------------------------------------------
deletePackageDataById(csarId);
- //STEP 3: upload package with same package id
- //-------------------------------------------
- return handlePackageUpload(csarId,uploadedInputStream, fileDetail, details, head);
- } catch (IOException e) {
+ // STEP 3: upload package with same package id
+ // -------------------------------------------
+ return handlePackageUpload(csarId, uploadedInputStream, fileDetail, details, head);
+ } catch(IOException e) {
LOG.error("delete package failed", e);
}
return Response.status(Status.INTERNAL_SERVER_ERROR).build();
/**
* Interface to get OnBoarding Result by Operation Type
+ *
* @param csarId
* @param operTypeId
* @param operId
* @return
*/
- public Response getOnBoardingResult(String csarId, String operTypeId, String operId)
- {
+ public Response getOnBoardingResult(String csarId, String operTypeId, String operId) {
LOG.info("getOnBoardingResult request : csarId:" + csarId + " operTypeId:" + operTypeId + " operId:" + operId);
try {
PackageData packageData = PackageWrapperUtil.getPackageInfoById(csarId);
- if (null == packageData) {
+ if(null == packageData) {
return Response.status(Response.Status.PRECONDITION_FAILED).build();
}
handleDelayExec(operId);
OnBoardingResult oOnBoardingResult = FunctionTestHook.getOnBoardingResult(packageData);
- if (null == oOnBoardingResult) {
+ if(null == oOnBoardingResult) {
return Response.status(Response.Status.PRECONDITION_FAILED).build();
}
filterOnBoardingResultByOperId(oOnBoardingResult, operId);
String strResult = ToolUtil.objectToString(oOnBoardingResult);
LOG.info("getOnBoardingResult response : " + strResult);
return Response.ok(strResult, "application/json").build();
- } catch (NullPointerException e) {
+ } catch(NullPointerException e) {
LOG.error("Null param in getOnBoardingResult", e);
return Response.status(Response.Status.BAD_REQUEST).build();
}
}
-
- private void filterOnBoardingResultByOperId(OnBoardingResult oOnBoardingResult, String operId)
- {
- if (0 == operId.compareToIgnoreCase("all")) {
+ private void filterOnBoardingResultByOperId(OnBoardingResult oOnBoardingResult, String operId) {
+ if(0 == operId.compareToIgnoreCase("all")) {
return;
}
- if (0 == operId.compareToIgnoreCase("download"))
- {
+ if(0 == operId.compareToIgnoreCase("download")) {
List<OnBoardingOperResult> operResultListTemp = new ArrayList<>();
OnBoardingOperResult operResultListTmp = new OnBoardingOperResult();
operResultListTmp.setOperId("download");
}
List<OnBoardingOperResult> operResultListOut = new ArrayList<>();
List<OnBoardingOperResult> operResultList = oOnBoardingResult.getOperResult();
- for (OnBoardingOperResult operResult : operResultList) {
- if (0 == operResult.getOperId().compareToIgnoreCase(operId)) {
+ for(OnBoardingOperResult operResult : operResultList) {
+ if(0 == operResult.getOperId().compareToIgnoreCase(operId)) {
operResultListOut.add(operResult);
}
}
/**
* Interface to get OnBoarding Status by Operation ID
+ *
* @param csarId
* @param operTypeId
* @return
*/
- public Response getOperResultByOperTypeId(String csarId, String operTypeId)
- {
- LOG.error("getOnBoardingResult request : csarId:"+ csarId + " operTypeId:"+operTypeId);
- if(null == csarId || null == operTypeId || csarId.isEmpty() || operTypeId.isEmpty())
- {
+ public Response getOperResultByOperTypeId(String csarId, String operTypeId) {
+ LOG.error("getOnBoardingResult request : csarId:" + csarId + " operTypeId:" + operTypeId);
+ if(null == csarId || null == operTypeId || csarId.isEmpty() || operTypeId.isEmpty()) {
return Response.status(Status.BAD_REQUEST).build();
}
PackageData packageData = PackageWrapperUtil.getPackageInfoById(csarId);
- if(null == packageData)
- {
- LOG.error("Failed to find package for PackageID:"+ csarId);
+ if(null == packageData) {
+ LOG.error("Failed to find package for PackageID:" + csarId);
return Response.status(Status.PRECONDITION_FAILED).build();
}
- //Get result key to fetch Function Test Results
- //---------------------------------------------
+ // Get result key to fetch Function Test Results
+ // ---------------------------------------------
String strResult = FunctionTestHook.getFuncTestResults(packageData);
- if(null == strResult)
- {
- LOG.error("NULL reponse for getOperResultByOperTypeId response :"+ strResult);
+ if(null == strResult) {
+ LOG.error("NULL reponse for getOperResultByOperTypeId response :" + strResult);
return Response.status(Status.INTERNAL_SERVER_ERROR).build();
}
- LOG.info("getOperResultByOperTypeId response :"+ strResult);
+ LOG.info("getOperResultByOperTypeId response :" + strResult);
return Response.ok(strResult, MediaType.APPLICATION_JSON).build();
}
- private boolean handleDataValidate(String packageId,InputStream uploadedInputStream, FormDataContentDisposition fileDetail)
- {
+ private boolean handleDataValidate(String packageId, InputStream uploadedInputStream,
+ FormDataContentDisposition fileDetail) {
boolean bvalidateOk = false;
- if ((null != uploadedInputStream) && (fileDetail != null) && !ToolUtil.isEmptyString(packageId))
- {
+ if((null != uploadedInputStream) && (fileDetail != null) && !ToolUtil.isEmptyString(packageId)) {
bvalidateOk = true;
}
return bvalidateOk;
/**
* Interface to get OnBoarding Steps
+ *
* @return
*/
- public Response getOnBoardingSteps()
- {
+ public Response getOnBoardingSteps() {
LOG.info("Get OnBoarding Steps request Received !!!");
- String filePath = org.onap.vnfsdk.marketplace.filemanage.http.ToolUtil.getAppDeployPath() + File.separator +"generalconfig/OnBoardingSteps.json";
+ String filePath = org.onap.vnfsdk.marketplace.filemanage.http.ToolUtil.getAppDeployPath() + File.separator
+ + "generalconfig/OnBoardingSteps.json";
LOG.info("Onboarding Steps Json file Path :" + filePath);
- OnBoardingSteps oOnBoardingSteps = (OnBoardingSteps)FileUtil.readJsonDatafFromFile(filePath, OnBoardingSteps.class);
- if (null == oOnBoardingSteps) {
+ OnBoardingSteps oOnBoardingSteps =
+ (OnBoardingSteps)FileUtil.readJsonDatafFromFile(filePath, OnBoardingSteps.class);
+ if(null == oOnBoardingSteps) {
return Response.status(Response.Status.INTERNAL_SERVER_ERROR).build();
}
String strResult = ToolUtil.objectToString(oOnBoardingSteps);
return Response.ok(strResult, MediaType.APPLICATION_JSON).build();
}
- private void handleDelayExec(String operId)
- {
- if (0 == operId.compareToIgnoreCase(CommonConstant.functionTest.FUNCTEST_EXEC))
- {
- try
- {
+ private void handleDelayExec(String operId) {
+ if(0 == operId.compareToIgnoreCase(CommonConstant.functionTest.FUNCTEST_EXEC)) {
+ try {
Thread.sleep(8000);
- }
- catch (InterruptedException e)
- {
+ } catch(InterruptedException e) {
LOG.info("handleDelayExex response : ", e);
Thread.currentThread().interrupt();
}
}
}
}
-
Code Review / vnfsdk / refrepo.git / commitdiff