*/
public static boolean createDirectory(String dir) {
File folder = new File(dir);
- if (!folder.exists() && !folder.mkdirs()) {
- return false;
- } else {
- return true;
- }
+ return folder.exists() || folder.mkdirs();
}
/**
gson.toJson(obj, writer);
bResult = true;
} catch (Exception e) { //NOSONAR
- logger.info("Exception: writeJsonDatatoFile-->" + fileAbsPath, e);
+ logger.info("Exception: writeJsonDatatoFile-->{} {}" , fileAbsPath, e);
}
return bResult;
}
try(JsonReader jsonReader = new JsonReader(new FileReader(fileAbsPath))) {
obj = gson.fromJson(jsonReader, clazz);
} catch (Exception e1) { //NOSONAR
- logger.info("IOException Exception: writeJsonDatatoFile-->" + fileAbsPath, e1);
+ logger.info("IOException Exception: writeJsonDatatoFile-->{} {}" , fileAbsPath, e1);
}
return obj;
}
import org.slf4j.LoggerFactory;
public class HttpServerPathConfig {
- public static final Logger logger = LoggerFactory.getLogger(FileUtil.class);
+ public static final Logger logger = LoggerFactory.getLogger(HttpServerPathConfig.class);
protected static String httpServerPath;
public static String storeChunkFileInLocal(String dirName, String fileName, InputStream uploadedInputStream)
throws IOException {
File tmpDir = new File(dirName);
- LOG.info("tmpdir = " + File.separator + dirName);
+ dirName = File.separator + dirName;
+ LOG.info("tmpdir = {}" , dirName);
if(!tmpDir.exists()) {
tmpDir.mkdirs();
}
if(null == sqlSessionFactory) {
LOGGER.error("begin generate");
sqlSessionFactory = new SqlSessionFactoryBuilder().build(inputStream);
- LOGGER.error("end generate = " + sqlSessionFactory);
+ LOGGER.error("end generate = {}" , sqlSessionFactory);
}
} catch(FileNotFoundException ex) {
LOGGER.error("File Not Found Exception caught", ex);
private final int errorCode;
- public ErrorCodeException(Throwable source, int category, int code, String debugMessage, String[] arguments) {
+ public ErrorCodeException(Throwable source, int category, int code, String debugMessage, String[] arguments) { //NOSONAR
super(debugMessage, source);
this.errorCode = code;
}
mapper.deletePackageData(csarId);
session.commit();
} catch(PersistenceException e) {
- LOGGER.error(EXCEPTION, e);;
+ LOGGER.error(EXCEPTION, e);
} finally {
session.close();
}
* @throws MarketplaceResourceException e
*/
public PackageData addPackage(PackageData packageData) throws MarketplaceResourceException {
- LOGGER.info("start add package info to db.info:" + MarketplaceDbUtil.objectToString(packageData));
+ String jsonPackageData = MarketplaceDbUtil.objectToString(packageData);
+ LOGGER.info("start add package info to db.info:{}" , jsonPackageData);
PackageData data = handler.create(packageData);
- LOGGER.info(" package info to db end.info:" + MarketplaceDbUtil.objectToString(data));
+ String jsonData = MarketplaceDbUtil.objectToString(data);
+ LOGGER.info(" package info to db end.info:{}" , jsonData);
return data;
}
*/
public List<PackageData> queryPackageByCsarId(String csarId)
throws MarketplaceResourceException {
- LOGGER.info("start query package info by csarid." + csarId);
+ LOGGER.info("start query package info by csarid.{}" , csarId);
List<PackageData> data = handler.queryByID(csarId);
- LOGGER.info("query package info end.size:" + data.size() + "detail:"
- + MarketplaceDbUtil.objectToString(data));
+ String jsonData = MarketplaceDbUtil.objectToString(data);
+ LOGGER.info("query package info end.size:{} detail:{}", data.size(), jsonData);
return data;
}
*/
public List<PackageData> queryPackage(String name, String provider, String version,
String deletionPending, String type) throws MarketplaceResourceException {
- LOGGER.info("start query package info.name:" + name + " provider:" + provider + " version:"
- + version + " type:" + type);
+ LOGGER.info("start query package info.name:{} provider:{} version:{} type:{}", name , provider , version, type);
Map<String, String> queryParam = new HashMap<>();
if (MarketplaceDbUtil.isNotEmpty(name)) {
queryParam.put(Parameters.NAME.name(), name);
queryParam.put(Parameters.PROVIDER.name(), provider);
}
List<PackageData> data = handler.query(queryParam);
- LOGGER.info("query package info end.size:" + data.size() + "detail:"
- + MarketplaceDbUtil.objectToString(data));
+ String jsonData = MarketplaceDbUtil.objectToString(data);
+ LOGGER.info("query package info end.size:{} detail:{}", data.size(), jsonData);
return data;
}
* @throws MarketplaceResourceException e
*/
public void deletePackage(String packageId) throws MarketplaceResourceException {
- LOGGER.info("start delete package info by id." + packageId);
+ LOGGER.info("start delete package info by id.{}" , packageId);
handler.delete(packageId);
- LOGGER.info(" delete package info end id." + packageId);
+ LOGGER.info(" delete package info end id.{}" , packageId);
}
/**
*/
public void updateDownloadCount(String packageId) throws MarketplaceResourceException
{
- LOGGER.info("Request received for Updating down load count for ID:" + packageId);
+ LOGGER.info("Request received for Updating down load count for ID:{}" , packageId);
//STEP 1: Get the Existing download count from DB
//-------------------------------------------------
List<PackageData> data = handler.queryByID(packageId);
if(data.isEmpty())
{
- LOGGER.info("Package Info not foun for ID:" + packageId);
+ LOGGER.info("Package Info not foun for ID:{}" , packageId);
return;
}
handler.update(oPackageData);
- LOGGER.info("Download count updated to :" + idownloadcount);
+ LOGGER.info("Download count updated to :{}" , idownloadcount);
}
}
@SuppressWarnings({"unchecked", "rawtypes"})
public PackageData create(PackageData data, String resouceType) throws MarketplaceResourceException {
PackageData rtnData = null;
- logger.info("BaseHandler:start create data.info:" + MarketplaceDbUtil.objectToString(data));
+ String jsonData = MarketplaceDbUtil.objectToString(data);
+ logger.info("BaseHandler:start create data.info:{}" , jsonData);
try {
IMarketplaceDao dao = new MarketplaceDaoImpl();
dao.savePackageData(data);
rtnData = data;
} catch (Exception e1) {
- logger.error("BaseHandler:error while creating " + resouceType, e1);
+ logger.error("BaseHandler:error while creating {} {}" , resouceType, e1);
}
- logger.info("BaseHandler:create data end.info:" + MarketplaceDbUtil.objectToString(data));
+ logger.info("BaseHandler:create data end.info:{}" , jsonData);
return rtnData;
}
*/
@SuppressWarnings({"rawtypes", "unchecked"})
public void delete(T data) throws MarketplaceResourceException {
- logger.info("BaseHandler:start delete data.info:" + MarketplaceDbUtil.objectToString(data));
+ String jsonData = MarketplaceDbUtil.objectToString(data);
+ logger.info("BaseHandler:start delete data.info:{}" , jsonData);
IMarketplaceDao dao = new MarketplaceDaoImpl();
dao.deletePackageData(((PackageData)data).getCsarId());
logger.info("BaseHandler:delete data end");
@SuppressWarnings({"rawtypes", "unchecked"})
public List<PackageData> query(Map<String, String> queryParam)
throws MarketplaceResourceException {
- logger.info("BaseHandler:start query data .info:" + MarketplaceDbUtil.objectToString(queryParam));
+ String jsonQueryParam = MarketplaceDbUtil.objectToString(queryParam);
+ logger.info("BaseHandler:start query data .info:{}" , jsonQueryParam);
IMarketplaceDao dao = new MarketplaceDaoImpl();
List<PackageData> datas = dao.getPackageDataSubset(queryParam);
- logger.info("BaseHandler: query data end .info:" + MarketplaceDbUtil.objectToString(datas));
+ String jsonData = MarketplaceDbUtil.objectToString(datas);
+ logger.info("BaseHandler: query data end .info:{}" , jsonData);
return datas;
}
@SuppressWarnings({"rawtypes", "unchecked"})
- public void update(T data) throws MarketplaceResourceException {
- logger.info("BaseHandler:start update data.info:" + MarketplaceDbUtil.objectToString(data));
+ public void update(T data) {
+ String jsonData = MarketplaceDbUtil.objectToString(data);
+ logger.info("BaseHandler:start update data.info:{}" , jsonData);
IMarketplaceDao dao = new MarketplaceDaoImpl();
dao.updatePackageData((PackageData)data);
logger.info("update data end");
throws MarketplaceResourceException {
logger.info("packageHandler:start query package info.");
List<PackageData> data = new ArrayList<>();
- logger.info("packageHandler:start query data .info:" + csarID);
+ logger.info("packageHandler:start query data .info:{}" , csarID);
IMarketplaceDao dao = new MarketplaceDaoImpl();
Object result = dao.getPackageData(csarID);
if (result != null) {
} else {
logger.info("packageHandler: query package info is null.");
}
- logger.info("packageHandler: query data end .info:" + MarketplaceDbUtil.objectToString(data));
+ String jsonData = MarketplaceDbUtil.objectToString(data);
+ logger.info("packageHandler: query data end .info:{}" , jsonData);
return data;
}
private static FileManagerType getType() {
String type = System.getenv("useFtp");
- logger.info("read environment varibale uesFtp:" + type);
+ logger.info("read environment varibale uesFtp:{}" , type);
if ((type != null) && "true".equals(type)) {
return FileManagerType.FTP;
} else {
@Override
public boolean upload(String srcPath, String dstPath) {
boolean flag = true;
- LOGGER.info("start upload file.srcPath:" + srcPath + " dstPath" + dstPath);
+ LOGGER.info("start upload file.srcPath:{} dstPath{}" , srcPath , dstPath);
File srcFile = new File(srcPath);
if (!srcFile.exists()) {
LOGGER.error("src file not exist!");
@Override
public boolean delete(String srcPath) {
- LOGGER.info("start delete file from http server.srcPath:" + srcPath);
+ LOGGER.info("start delete file from http server.srcPath:{}" , srcPath);
boolean flag = ToolUtil.deleteDir(new File(ToolUtil.getHttpServerAbsolutePath() + srcPath));
- LOGGER.info("delete file from http server end.flag:" + flag);
+ LOGGER.info("delete file from http server end.flag:{}" , flag);
return flag;
}
String funcTestId = null;
String packagePath = onBoradFuncTestReq.getPackagePath() + File.separator + onBoradFuncTestReq.getPackageName();
- logger.info("Package file path Function test:" + packagePath);
+ logger.info("Package file path Function test:{}" , packagePath);
// Validate package path
if (!FileUtil.validatePath(packagePath)) {
}
funcTestId = rsp.getResult();
- logger.info("Response for Function Test :", funcTestId);
+ logger.info("Response for Function Test :{}", funcTestId);
return funcTestId.replaceAll("\"", "");
} catch (NumberFormatException e) {
- logger.error("Invalid port number :", oMsbDetails.getDefaultServer().getPort());
+ logger.error("Invalid port number :{}", oMsbDetails.getDefaultServer().getPort());
} catch (FileNotFoundException exp) {
- logger.error("File not found Exception for file:", onBoradFuncTestReq.getPackagePath());
+ logger.error("File not found Exception for file:{}", onBoradFuncTestReq.getPackagePath());
logger.error("File not found Exception for :", exp);
} catch (IOException e) {
logger.error("IOException:", e);
return result;
}
- logger.info("GetTestResultsByFuncTestKey for Function Test Results for :" + key);
+ logger.info("GetTestResultsByFuncTestKey for Function Test Results for :{}" , key);
RestResponse rspGet = RestfulClient.get(oMsbDetails.getDefaultServer().getHost(),
Integer.parseInt(oMsbDetails.getDefaultServer().getPort()),
CommonConstant.FunctionTest.FUNCTEST_RESULT_URL + key);
if (!checkValidResponse(rspGet)) {
- logger.error("Failed to convert String Json Response to TestResults list:" + rspGet.getResult());
+ logger.error("Failed to convert String Json Response to TestResults list:{}" , rspGet.getResult());
return result;
}
result = rspGet.getResult();
- logger.info("Function Test Results for Key:" + key + "Response:" + rspGet.getResult());
+ logger.info("Function Test Results for Key:{} Response:{}" , key , rspGet.getResult());
return result;
}
return result;
}
- logger.info("ExecuteFunctionTest Test request Received:" + strJsonRequest);
+ logger.info("ExecuteFunctionTest Test request Received:{}" , strJsonRequest);
MsbDetails oMsbDetails = MsbDetailsHolder.getMsbDetails();
if (null == oMsbDetails) {
return result;
}
- logger.info("GetTestResultsByFuncTestKey for Function Test Results for :" + strJsonRequest);
+ logger.info("GetTestResultsByFuncTestKey for Function Test Results for :{}" , strJsonRequest);
RestResponse rspGet = RestfulClient.sendPostRequest(oMsbDetails.getDefaultServer().getHost(),
oMsbDetails.getDefaultServer().getPort(), CommonConstant.FunctionTest.FUNCTEST_RESULT_URL,
strJsonRequest);
if (!checkValidResponse(rspGet)) {
- logger.error("Failed to convert String Json Response to TestResults list:" + rspGet.getResult());
+ logger.error("Failed to convert String Json Response to TestResults list:{}" , rspGet.getResult());
return result;
}
result = rspGet.getResult();
- logger.info("ExecuteFunctionTest Function Test Result: " + rspGet.getResult());
+ logger.info("ExecuteFunctionTest Function Test Result: {}" , rspGet.getResult());
return result;
}
*/
public int exec(OnBoradingRequest onBoradingReq) {
- logger.info("OnboradingRequest received for Package:" + onBoradingReq.getCsarId() + " Path:"
- + onBoradingReq.getPackagePath());
+ logger.info("OnboradingRequest received for Package:{} Path:{}", onBoradingReq.getCsarId()
+ , onBoradingReq.getPackagePath());
buildResultPath(onBoradingReq);
// STEP 1:Check Package Exists
// ---------------------------
if (!FileUtil.checkFileExists(onBoradingReq.getPackagePath())) {
- logger.error("Package Not Found at Path:" + onBoradingReq.getPackagePath() + ", Package Id:"
- + onBoradingReq.getCsarId());
+ logger.error("Package Not Found at Path:{} Package Id:{}" , onBoradingReq.getPackagePath()
+ , onBoradingReq.getCsarId());
oFuncTestResult.setOperFinished(true);
oFuncTestResult.setOperStatus(EnumResult.FAIL.getIndex());
buildFuncTestResponse(oFuncTestResult, CommonConstant.FunctionTest.FUNCTEST_PACKAGE_EXISTS,
return null;
}
- logger.info("Function Test results request for Package:" + packageData.getCsarId());
+ logger.info("Function Test results request for Package:{}" , packageData.getCsarId());
ResultKey keydata = getFuncTestResultKey(packageData);
if ((null == keydata) || (keydata.getKey().isEmpty())) {
- logger.error("Function Test key Not Found for Package Id:", packageData.getCsarId());
+ logger.error("Function Test key Not Found for Package Id:{}", packageData.getCsarId());
return null;
}
return FunctionTestExceutor.getTestResultsByFuncTestKey(keydata.getKey());
filePath.append(File.separator);
filePath.append("functestResultKey.json");
- logger.debug("Function test Results Key for Package Id:" + onBoradingReq.getCsarId() + ", Key:" + resultKey
- + " Path" + filePath.toString());
+ logger.debug("Function test Results Key for Package Id:{} Key:{} Path{}" , onBoradingReq.getCsarId(), resultKey
+ , filePath);
ResultKey oResultKey = new ResultKey();
oResultKey.setCsarId(onBoradingReq.getCsarId());
// STore Results to DB(Currently we will make JSON and Store JSON to
// Package Path)
// -------------------------------------------------------------------------------
- logger.debug("Function test Status for Package Id:" + oFuncTestResult.getCsarId() + ", Result:"
- + ToolUtil.objectToString(oFuncTestResult));
+ String jsonoFuncTestResult = ToolUtil.objectToString(oFuncTestResult);
+ logger.debug("Function test Status for Package Id:{} Result:{}" ,oFuncTestResult.getCsarId()
+ , jsonoFuncTestResult);
StringBuilder filePath = new StringBuilder(getResultStorePath());
filePath.append(File.separator);
filePath.append(File.separator);
filePath.append("functionTest.json");
- logger.info("On Boarding Status for Package Id:" + packageData.getCsarId() + ", Result Path:" + filePath);
+ logger.info("On Boarding Status for Package Id:{} Result Path:{}" ,packageData.getCsarId(), filePath);
return (OnBoardingResult) FileUtil.readJsonDatafFromFile(filePath.toString(), OnBoardingResult.class);
}
fileName.append(File.separator);
fileName.append("functestResultKey.json");
- logger.info("Func Test Result key for Package Id:" + packageData.getCsarId() + ", Result Path:" + fileName);
+ logger.info("Func Test Result key for Package Id:{} Result Path:{}" , packageData.getCsarId(),fileName);
return (ResultKey) FileUtil.readJsonDatafFromFile(fileName.toString(), ResultKey.class);
}
package org.onap.vnfsdk.marketplace.onboarding.hooks.validatelifecycle;
import java.io.File;
-import java.io.IOException;
import java.util.Map;
import org.apache.http.entity.ContentType;
@SuppressWarnings("unchecked")
public static String uploadPackageToCatalouge(OnBoradingRequest onBoradFuncTestReq) {
String packagePath = onBoradFuncTestReq.getPackagePath() + File.separator + onBoradFuncTestReq.getPackageName();
- logger.info("Package file path uploadPackageToCatalouge:" + packagePath);
+ logger.info("Package file path uploadPackageToCatalouge:{}" , packagePath);
String catalougeCsarId = null;
Integer.parseInt(oMsbDetails.getDefaultServer().getPort()), CommonConstant.CATALOUGE_UPLOAD_URL,
builder.build());
if (!checkValidResponse(rsp)) {
- logger.error("Failed to upload package to catalouge:" + rsp.getStatusCode());
+ logger.error("Failed to upload package to catalouge:{}" , rsp.getStatusCode());
return catalougeCsarId;
}
- logger.info("Response for uploadPackageToCatalouge :" + rsp.getResult());
+ logger.info("Response for uploadPackageToCatalouge :{}" , rsp.getResult());
catalougeCsarId = getCsarIdValue(rsp.getResult());
- logger.info("CSARID for uploadPackageToCatalouge :" + catalougeCsarId);
+ logger.info("CSARID for uploadPackageToCatalouge :{}" , catalougeCsarId);
return catalougeCsarId;
}
* oLifeCycleTestReq
* @return result of the test or null (in case of failure)
*/
- public static String execlifecycleTest(OnBoradingRequest onBoradFuncTestReq, LifeCycleTestReq oLifeCycleTestReq) {
+ public static String execlifecycleTest(OnBoradingRequest onBoradFuncTestReq, LifeCycleTestReq oLifeCycleTestReq) { //NOSONAR
String result = null;
if ((null == onBoradFuncTestReq.getPackagePath()) || (null == onBoradFuncTestReq.getPackageName())) {
}
String packagePath = onBoradFuncTestReq.getPackagePath() + File.separator + onBoradFuncTestReq.getPackageName();
- logger.info("Package file path Function test:" + packagePath);
+ logger.info("Package file path Function test:{}" , packagePath);
// Validate package path
if (!FileUtil.validatePath(packagePath)) {
oMsbDetails.getDefaultServer().getPort(), CommonConstant.LifeCycleTest.LIFECYCLE_TEST_URL, rawDataJson);
if (!checkValidResponse(oResponse)) {
- logger.error("execlifecycleTest response is faliure :" + oResponse.getStatusCode());
+ logger.error("execlifecycleTest response is faliure :{}" , oResponse.getStatusCode());
return result;
}
result = oResponse.getResult();
- logger.info("Response execlifecycleTest :" + oResponse.getResult());
+ logger.info("Response execlifecycleTest :{}" , oResponse.getResult());
return result;
}
* @return
*/
public int exec(OnBoradingRequest onBoradingReq) {
- logger.info("OnboardingRequest Lifecycle Request received for Package:" + onBoradingReq.getCsarId() + " Path:"
- + onBoradingReq.getPackagePath());
+ logger.info("OnboardingRequest Lifecycle Request received for Package:{} Path:{}" , onBoradingReq.getCsarId()
+ , onBoradingReq.getPackagePath());
// STEP 1: Validate Input and Build result
// ---------------------------------------------------------
// STore Results to DB(Currently we will make JSON and Store JSON to
// Package Path)
// -------------------------------------------------------------------------------
- logger.info("Lifecycle test Status for Package Id:" + oFuncTestResult.getCsarId() + ", Result:"
- + ToolUtil.objectToString(oFuncTestResult));
+ String jsonoFuncTestResult = ToolUtil.objectToString(oFuncTestResult);
+ logger.info("Lifecycle test Status for Package Id:{} Result:{}" , oFuncTestResult.getCsarId()
+ , jsonoFuncTestResult);
String filePath = getResultStorePath() + File.separator + oFuncTestResult.getCsarId() + File.separator
+ "lifecycleTest.json";
FileUtil.writeJsonDatatoFile(filePath, oFuncTestResult);
String filePath = getResultStorePath() + File.separator + onBoradingReq.getCsarId() + File.separator
+ "lifecycleTestResultKey.json";
- logger.debug("Function test Results Key for Package Id:" + onBoradingReq.getCsarId() + ", Key:" + resultKey
- + " Path" + filePath);
+ logger.debug("Function test Results Key for Package Id:{} Key:{} Path{}" , onBoradingReq.getCsarId(), resultKey
+ , filePath);
ResultKey oResultKey = new ResultKey();
oResultKey.setCsarId(onBoradingReq.getCsarId());
LifecycleTestHook oLifecycleTestHook = new LifecycleTestHook();
int iLifeCycleResponse = oLifecycleTestHook.exec(onBoardingReq);
if (EnumResult.SUCCESS.getIndex() != iLifeCycleResponse) {
- logger.error("Onboarding failed for Package Id during Lifecycle Test:" + onBoardingReq.getCsarId());
+ logger.error("Onboarding failed for Package Id during Lifecycle Test:{}" , onBoardingReq.getCsarId());
// Note: We need to continue even if life cycle test fails as this
// test is not mandatory
}
FunctionTestHook oFunctionTestHook = new FunctionTestHook();
int iFuncTestResponse = oFunctionTestHook.exec(onBoardingReq);
if (EnumResult.SUCCESS.getIndex() != iFuncTestResponse) {
- logger.error("Onboarding failed for Package Id during Function Test:" + onBoardingReq.getCsarId());
+ logger.error("Onboarding failed for Package Id during Function Test:{}" , onBoardingReq.getCsarId());
// Note: We need to continue even if function test fails as this
// test is not mandatory
}
try {
PackageManager.getInstance().updateDownloadCount(onBoardingReq.getCsarId());
} catch (Exception e) {
- logger.error("Download count update failed for Package:" + onBoardingReq.getPackagePath(), e);
+ logger.error("Download count update failed for Package:{}" , onBoardingReq.getPackagePath(), e);
}
}
try
{
String urlPost = "http://" + ip + ":" + port + url;
- logger.info("URL formed for Post, URL :" + urlPost);
- logger.info("URL formed for Post, JSON :" + strJson);
+ logger.info("URL formed for Post, URL :{}" , urlPost);
+ logger.info("URL formed for Post, JSON :{}" , strJson);
HttpPost request = new HttpPost(urlPost);
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();
}
if(lyfValidateResp.getLifecycleStatus().equalsIgnoreCase(CommonConstant.SUCCESS_STR)
&& lyfValidateResp.getValidateStatus().equalsIgnoreCase(CommonConstant.SUCCESS_STR)) {
- LOG.error("Lifecycle/Validation Response failed :" + lyfValidateResp.getLifecycleStatus() + File.separator
- + lyfValidateResp.getValidateStatus());
+ String lyfValidateResponse = lyfValidateResp.getLifecycleStatus() + File.separator+lyfValidateResp.getValidateStatus();
+ LOG.error("Lifecycle/Validation Response failed :{}" , lyfValidateResponse);
bOperStatus = true;
}
return bOperStatus;
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:{} provider:{} version{} deletionPending{} type:{}" , name , provider , version
+ , deletionPending , type);
try {
dbresult = PackageManager.getInstance().queryPackage(name, provider, version, deletionPending, type);
result = PackageWrapperUtil.packageDataList2PackageMetaList(dbresult);
PackageBasicInfo basicInfo = PackageWrapperUtil.getPacageBasicInfo(fileLocation);
UploadPackageResponse result = new UploadPackageResponse();
Boolean isEnd = PackageWrapperUtil.isUploadEnd(contentRange);
- if(isEnd) {
+ if(Boolean.TRUE.equals(isEnd)) {
PackageMeta packageMeta =
PackageWrapperUtil.getPackageMeta(packageId, fileName, fileLocation, basicInfo, details);
try {
String dowloadUri = File.separator + path + File.separator;
packageMeta.setDownloadUri(dowloadUri);
- LOG.info("dest path is : " + path);
- LOG.info("packageMeta = " + ToolUtil.objectToString(packageMeta));
+ String jsonPackageMeta = ToolUtil.objectToString(packageMeta);
+ LOG.info("dest path is : {}" , path);
+ LOG.info("packageMeta = {}" , jsonPackageMeta);
PackageData packageData = PackageWrapperUtil.getPackageData(packageMeta);
packageData.setDownloadCount(-1);
PackageData packateDbData = PackageManager.getInstance().addPackage(packageData);
- LOG.info("Store package data to database succed ! packateDbData = "
- + ToolUtil.objectToString(packateDbData));
- LOG.info("upload package file end, fileName:" + fileName);
+ String jsonPackageDbData = ToolUtil.objectToString(packateDbData);
+ LOG.info("Store package data to database succed ! packateDbData = {}"
+ , jsonPackageDbData);
+ LOG.info("upload package file end, fileName:{}" , fileName);
result.setCsarId(packateDbData.getCsarId());
addOnBoardingRequest(oOnboradingRequest);
- LOG.info("OnboradingRequest Data : " + ToolUtil.objectToString(oOnboradingRequest));
+ String jsonoOnboradingRequest = ToolUtil.objectToString(oOnboradingRequest);
+ LOG.info("OnboradingRequest Data : {}" , jsonoOnboradingRequest);
}
} catch(NullPointerException e) {
- LOG.error("Package basicInfo is incorrect ! basicIonfo = " + ToolUtil.objectToString(basicInfo), e);
+ String jsonBasicInfo = ToolUtil.objectToString(basicInfo);
+ LOG.error("Package basicInfo is incorrect ! basicIonfo = {} {}" , jsonBasicInfo, e);
return null;
}
}
String fileName = "temp_" + packageId + FILE_FORMAT;
if(null != fileDetail) {
- LOG.info("the fileDetail = " + ToolUtil.objectToString(fileDetail));
+ String jsonFileDetail = ToolUtil.objectToString(fileDetail);
+ LOG.info("the fileDetail = {}" , jsonFileDetail);
fileName = ToolUtil.processFileName(fileDetail.getFileName());
}
if(head != null) {
contentRange = head.getHeaderString(CommonConstant.HTTP_HEADER_CONTENT_RANGE);
}
- LOG.info("store package chunk file, fileName:" + fileName + ",contentRange:" + contentRange);
+ LOG.info("store package chunk file, fileName:{} contentRange:{}", fileName , contentRange);
if(ToolUtil.isEmptyString(contentRange)) {
int fileSize = uploadedInputStream.available();
contentRange = "0-" + fileSize + "/" + fileSize;
}
String fileLocation = ToolUtil.storeChunkFileInLocal(localDirName, fileName, uploadedInputStream);
- LOG.info("the fileLocation when upload package is :" + fileLocation);
+ LOG.info("the fileLocation when upload package is :{}" , fileLocation);
uploadedInputStream.close();
if (!DISABLE_VALIDATION) {
try {
- Result result = OpenRemoteCli.run("localhost", 50051, null, Arrays.asList(new String[] { "--product", "onap-vtp", "csar-validate", "--csar", fileLocation, "--format", "json" }));
- LOG.info("CSAR validation is successful" + result.getOutput());
+ Result result = OpenRemoteCli.run("localhost", 50051, null, Arrays.asList( "--product", "onap-vtp", "csar-validate", "--csar", fileLocation, "--format", "json" ));
+ LOG.info("CSAR validation is successful{}" , result.getOutput());
int exitCode = result.getExitCode();
String output = result.getOutput();
* @return Response
*/
public Response delPackage(String csarId) {
- LOG.info("delete package info.csarId:" + csarId);
+ LOG.info("delete package info.csarId:{}" , csarId);
if(ToolUtil.isEmptyString(csarId)) {
LOG.error("delete package fail, csarid is null");
return Response.serverError().build();
try {
PackageManager.getInstance().deletePackage(csarId);
} catch(MarketplaceResourceException e1) {
- LOG.error("delete package by csarId from db error ! " + e1.getMessage(), e1);
+ String message = e1.getMessage();
+ LOG.error("delete package by csarId from db error ! {} {}" , message, e1);
}
}
+ File.separatorChar + packageData.getCsarId() + File.separator + packageName + File.separatorChar
+ packageData.getVersion() + File.separator + packageName + FILE_FORMAT;
- LOG.info("downloadCsarPackagesById path is : " + path);
+ LOG.info("downloadCsarPackagesById path is : {}" , path);
File csarFile = new File(path);
if(!csarFile.exists()) {
return Response.status(Status.INTERNAL_SERVER_ERROR).build();
}
- LOG.info("downloadCsarPackagesById ABS path is : " + csarFile.getAbsolutePath());
+ LOG.info("downloadCsarPackagesById ABS path is : {}" , csarFile.getAbsolutePath());
try {
InputStream fis = new BufferedInputStream(new FileInputStream(csarFile.getAbsolutePath()));
PackageManager.getInstance().updateDownloadCount(csarId);
bupdateSucess = true;
} catch(Exception exp) {
- LOG.error("Updating Donwload count failed for Package with ID !!! : " + exp.getMessage(), exp);
+ LOG.error("Updating Donwload count failed for Package with ID !!! : {} {}" , exp.getMessage(), exp);
}
return bupdateSucess;
}
* @return
*/
public Response getOnBoardingResult(String csarId, String operTypeId, String operId) {
- LOG.info("getOnBoardingResult request : csarId:" + csarId + " operTypeId:" + operTypeId + " operId:" + operId);
+ LOG.info("getOnBoardingResult request csarId:{} operTypeId:{} operId:{}", csarId , operTypeId , operId);
try {
PackageData packageData = PackageWrapperUtil.getPackageInfoById(csarId);
if(null == packageData) {
filterOnBoardingResultByOperId(oOnBoardingResult, operId);
String strResult = ToolUtil.objectToString(oOnBoardingResult);
- LOG.info("getOnBoardingResult response : " + strResult);
+ LOG.info("getOnBoardingResult response : {}" , strResult);
return Response.ok(strResult, "application/json").build();
} catch(NullPointerException e) {
LOG.error("Null param in getOnBoardingResult", e);
* @return
*/
public Response getOperResultByOperTypeId(String csarId, String operTypeId) {
- LOG.error("getOnBoardingResult request : csarId:" + csarId + " operTypeId:" + operTypeId);
+ LOG.error("getOnBoardingResult request : csarId:{} operTypeId:{}" , csarId , 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);
+ LOG.error("Failed to find package for PackageID:{}" , csarId);
return Response.status(Status.PRECONDITION_FAILED).build();
}
// ---------------------------------------------
String strResult = FunctionTestHook.getFuncTestResults(packageData);
if(null == strResult) {
- LOG.error("NULL reponse for getOperResultByOperTypeId response :" + 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();
}
String filePath = org.onap.vnfsdk.marketplace.filemanage.http.ToolUtil.getAppDeployPath() + File.separator
+ "generalconfig/OnBoardingSteps.json";
- LOG.info("Onboarding Steps Json file Path :" + filePath);
+ LOG.info("Onboarding Steps Json file Path :{}" , filePath);
OnBoardingSteps oOnBoardingSteps =
(OnBoardingSteps)FileUtil.readJsonDatafFromFile(filePath, OnBoardingSteps.class);
return Response.status(Response.Status.INTERNAL_SERVER_ERROR).build();
}
String strResult = ToolUtil.objectToString(oOnBoardingSteps);
- LOG.info("getOnBoardingSteps response :" + strResult);
+ LOG.info("getOnBoardingSteps response :{}" , strResult);
return Response.ok(strResult, MediaType.APPLICATION_JSON).build();
}
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
-import com.google.common.reflect.TypeToken;
import com.google.gson.Gson;
import com.google.gson.internal.LinkedTreeMap;
result = packageDataList.get(0);
}
} catch(MarketplaceResourceException e1) {
- LOG.error("query package by csarId from db error ! " + e1.getMessage(), e1);
+ LOG.error("query package by csarId from db error ! {} {}" , e1.getMessage(), e1);
}
return result;
}
packageList = PackageManager.getInstance().queryPackageByCsarId(csarId);
downloadUri = packageList.get(0).getDownloadUri();
} catch(MarketplaceResourceException e1) {
- LOG.error("Query CSAR package by ID failed ! csarId = " + csarId, e1);
+ LOG.error("Query CSAR package by ID failed ! csarId = {} {}" , csarId, e1);
}
return downloadUri;
}
}
}
} catch(IOException e1) {
- LOG.error("judge package type error ! " + e1.getMessage(), e1);
+ LOG.error("judge package type error ! {} {}" , e1.getMessage(), e1);
}
if(isXmlCsar) {
basicInfo.setFormat(CommonConstant.PACKAGE_XML_FORMAT);
}
}
- reader.close();
} catch(IOException e) {
- LOG.error("Exception while parsing manifest file" + e, e);
+ LOG.error("Exception while parsing manifest file {}", e);
}
return basicInfo;
}
}
- reader.close();
} catch(IOException e) {
- LOG.error("Exception while parsing manifest file" + e, e);
+ LOG.error("Exception while parsing manifest file {}", e);
}
return basicInfo;
return this.makeRpcAndGetJson(args, VTP_EXECUTION_GRPC_TIMEOUT);
}
- protected JsonElement makeRpcAndGetJson(List<String> args, int timeout) throws VTPException, IOException {
+ protected JsonElement makeRpcAndGetJson(List<String> args, int timeout) throws VTPException {
Result result = this.makeRpc(args, timeout);
JsonParser jsonParser = new JsonParser();
return jsonParser.parse(result.getOutput());
package org.onap.vtp.execution;
-import java.io.EOFException;
import java.io.File;
import java.io.IOException;
import java.nio.file.StandardCopyOption;
import java.util.List;
import java.util.Map;
import java.util.UUID;
-import java.util.logging.Logger;
import javax.ws.rs.Consumes;
import javax.ws.rs.DefaultValue;
private Map<String, String> storeTestCaseInputFiles(List<FormDataBodyPart> bodyParts) throws IOException {
Map<String, String> map = new HashMap<>();
- if (bodyParts != null)
- for (FormDataBodyPart part: bodyParts) {
- String name = part.getContentDisposition().getFileName();
- String path = VTP_EXECUTION_TEMP_STORE + "/" + name;
-
- File f = new File(path);
- if (f.exists()) {
- FileUtils.forceDelete(f);
- }
- FileUtils.forceMkdir(f.getParentFile());
+ if (bodyParts != null) {
+ for (FormDataBodyPart part: bodyParts) {
+ String name = part.getContentDisposition().getFileName();
+ String path = VTP_EXECUTION_TEMP_STORE + "/" + name; //NOSONAR
+
+ File f = new File(path);
+ if (f.exists()) {
+ FileUtils.forceDelete(f);
+ }
+ FileUtils.forceMkdir(f.getParentFile());
- BodyPartEntity fileEntity = (BodyPartEntity) part.getEntity();
- java.nio.file.Files.copy(
- fileEntity.getInputStream(),
- f.toPath(),
- StandardCopyOption.REPLACE_EXISTING);
+ BodyPartEntity fileEntity = (BodyPartEntity) part.getEntity();
+ java.nio.file.Files.copy(
+ fileEntity.getInputStream(),
+ f.toPath(),
+ StandardCopyOption.REPLACE_EXISTING);
- IOUtils.closeQuietly(fileEntity.getInputStream());
+ IOUtils.closeQuietly(fileEntity.getInputStream());
+
+ map.put(name, path);
+ }
- map.put(name, path);
}
return map;
LOG.error("IOException occurs",e);
}
- for (Map.Entry<String, String> entry: map.entrySet()) {
- if (executionsJson.contains(FILE + entry.getKey())) {
- executionsJson = executionsJson.replaceAll(FILE + entry.getKey(), entry.getValue());
+ if (map != null) {
+ for (Map.Entry<String, String> entry: map.entrySet()) {
+ if (executionsJson.contains(FILE + entry.getKey())) {
+ executionsJson = executionsJson.replaceAll(FILE + entry.getKey(), entry.getValue());
+ }
}
}
executions = this.executeHandler(executions, requestId);
- for (Map.Entry<String, String> entry: map.entrySet()) {
- try {
- FileUtils.forceDelete(new File(entry.getValue()));
- } catch (IOException e) {
- LOG.error("IOException occurs",e);
+ if (map != null) {
+ for (Map.Entry<String, String> entry: map.entrySet()) {
+ try {
+ FileUtils.forceDelete(new File(entry.getValue()));
+ } catch (IOException e) {
+ LOG.error("IOException occurs",e);
+ }
}
}
String scenario,
String testSuiteName,
String testCaseName,
- String profile,
+ String profile, //NOSONAR
String startTime,
- String endTime) throws Exception{
+ String endTime) throws VTPException, IOException {
List<String> args = new ArrayList<>();
- args.addAll(Arrays.asList(new String[] {
+ args.addAll(Arrays.asList(
PRODUCT_ARG, OPEN_CLI, "execution-list", FORMAT, "json"
- }));
+ ));
if (startTime != null && !startTime.isEmpty()) {
args.add("--start-time");
@ApiParam("Test profile name") @QueryParam("profileName") String profileName,
@ApiParam("Test execution start time") @QueryParam("startTime") String startTime,
@ApiParam("Test execution end time") @QueryParam("endTime") String endTime
- ) throws Exception {
+ ) throws VTPException, IOException {
return Response.ok(this.listTestExecutionsHandler(
requestId, scenario, testsuiteName, testcaseName, profileName, startTime, endTime).getExecutions().toString(), MediaType.APPLICATION_JSON).build();
}
public VTPTestExecution getTestExecutionHandler(
- String executionId) throws Exception{
+ String executionId) throws VTPException, IOException {
List<String> args = new ArrayList<>();
- args.addAll(Arrays.asList(new String[] {
+ args.addAll(Arrays.asList(
PRODUCT_ARG, OPEN_CLI, "execution-show", "--execution-id", executionId, FORMAT, "json"
- }));
+ ));
JsonElement result = this.makeRpcAndGetJson(args);
response = VTPError.class) })
public Response getTestExecution(
@ApiParam("Test execution Id") @PathParam("executionId") String executionId
- ) throws Exception {
+ ) throws VTPException, IOException {
return Response.ok(this.getTestExecutionHandler(executionId).toString(), MediaType.APPLICATION_JSON).build();
}
public String getTestExecutionLogsHandler(
String executionId, String action) throws VTPException {
List<String> args = new ArrayList<>();
- args.addAll(Arrays.asList(new String[] {
+ args.addAll(Arrays.asList(
PRODUCT_ARG, OPEN_CLI, "execution-show-" + action, "--execution-id", executionId, FORMAT, "text"
- }));
+ ));
Result result = this.makeRpc(args);
public VTPTestScenarioList listTestScenariosHandler() throws VTPException {
List<String> args = new ArrayList<>();
- args.addAll(Arrays.asList(new String[] {
+ args.addAll(Arrays.asList(
PRODUCT_ARG, OPEN_CLI, "product-list", FORMAT, "json"
- }));
+ ));
+
JsonElement results = null;
try {
public VTPTestSuiteList listTestSutiesHandler(String scenario) throws VTPException {
List<String> args = new ArrayList<>();
- args.addAll(Arrays.asList(new String[] {
+ args.addAll(Arrays.asList(
PRODUCT_ARG, OPEN_CLI, "service-list", PRODUCT_ARG, scenario, FORMAT, "json"
- }));
+ ));
JsonElement results = null;
try {
public VTPTestCaseList listTestcasesHandler(String testSuiteName, String scenario) throws VTPException {
List<String> args = new ArrayList<>();
- args.addAll(Arrays.asList(new String[] {
+ args.addAll(Arrays.asList(
PRODUCT_ARG, OPEN_CLI, "schema-list", PRODUCT_ARG, scenario, FORMAT, "json"
- }));
+ ));
if (testSuiteName != null) {
args.add("--service");
args.add(testSuiteName);
public VTPTestCase getTestcaseHandler(String scenario, String testSuiteName, String testCaseName) throws VTPException {
List<String> args = new ArrayList<>();
- args.addAll(Arrays.asList(new String[] {
+ args.addAll(Arrays.asList(
PRODUCT_ARG, OPEN_CLI, "schema-show", PRODUCT_ARG, scenario, "--service", testSuiteName, "--command", testCaseName , FORMAT, "json"
- }));
+ ));
JsonElement results = null;
try {
results = this.makeRpcAndGetJson(args);
public class MarketplaceResourceTypeTest {
@Test
public void testEnum() {
- MarketplaceResourceType.getType("SERVICETEMPLATE");
+ assertNotNull(MarketplaceResourceType.getType("SERVICETEMPLATE"));
}
}
\ No newline at end of file
public void testConstructor() {
ErrorCodeException e2 = new ErrorCodeException(0, null);
+ assertNotNull(e2);
}
@Test
public void testGet() {
- e1.getErrorCode();
+ assertEquals(0, e1.getErrorCode());
}
}
\ No newline at end of file
@Test
public void testGetter()
{
- marketplaceResourceException.getErrcode();
+ assertEquals(0, marketplaceResourceException.getErrcode());
}
}
\ No newline at end of file
@Test
public void testGetDefaultServer()
{
- msbDetails.getDefaultServer();
+ assertNull(msbDetails.getDefaultServer());
}
}
\ No newline at end of file
import org.onap.vnfsdk.marketplace.rest.RestfulClient;
import static org.mockito.Mockito.mock;
+import static org.junit.Assert.assertNotNull;
public class LifecycleTestExceutorTest {
private LifecycleTestExceutor lifecycleTestExceutor;
onBoradingRequest.setPackagePath("");
onBoradingRequest.setPackageName("huawei");
onBoradingRequest.setCsarIdCatalouge("catalog");
- LifecycleTestExceutor.uploadPackageToCatalouge(onBoradingRequest);
+ assertNotNull(LifecycleTestExceutor.uploadPackageToCatalouge(onBoradingRequest));
}
public void testExeclifecycleTest()
{
lifecycleTestHook= new LifecycleTestHook();
onBoradingRequest = mock(OnBoradingRequest.class);
}
- @Test
+
+ @Test(expected = NullPointerException.class)
public void testExec()
{
- // lifecycleTestHook.exec(onBoradingRequest);
+ lifecycleTestHook.exec(onBoradingRequest);
}
}
\ No newline at end of file
onboardinghandler = new OnBoardingHandler();
}
@Test
- public void testhandleOnBoardingReq() {
+ public void testhandleOnBoardingReq() { //NOSONAR
onboardinghandler.handleOnBoardingReq(null);
onboardinghandler.handleOnBoardingReq(onBoardingReq);
when(onBoardingReq.getPackageName()).thenReturn("abc");
try {
response = PackageWrapper.getInstance().getOperResultByOperTypeId(csarID, operTypeId);
+ assertNotNull(response);
} catch(Exception e) {
e.printStackTrace();
}
public void testGetOOprStatusSuccess() {
try {
response = packageResource.getOperStatus(null, null);
+ assertNotNull(response);
} catch(Exception e) {
e.printStackTrace();
}
};
try {
response = packageResource.updateValidateStatus(request, null);
+ assertNotNull(response);
} catch(Exception e) {
e.printStackTrace();
}
@Test
public void testGet() {
- RestfulClient.get("172.11.10.22,1212", 1211, "http://localhost");
+ assertNotNull(RestfulClient.get("172.11.10.22,1212", 1211, "http://localhost"));
}
@Test
public void testPost() {
- RestfulClient.post("172.11.10.22,1212", 1211, "http://localhost", null);
+ assertNotNull(RestfulClient.post("172.11.10.22,1212", 1211, "http://localhost", null));
}
@Test
public void testDelete() {
- RestfulClient.delete("172.11.10.22,1212", 1211, "http://localhost");
+ assertNotNull(RestfulClient.delete("172.11.10.22,1212", 1211, "http://localhost"));
}
@Test
@Test
public void testExecuteHttp() throws Exception{
- RestfulClient.executeHttp(PUT, "172.11.10.22,1212", 1211, "http://localhost", null);
+ assertNotNull(RestfulClient.executeHttp(PUT, "172.11.10.22,1212", 1211, "http://localhost", null));
/*HttpResponse httpResponse = mock(HttpResponse.class);
CloseableHttpClient httpclient= mock(CloseableHttpClient.class);
HttpEntity httpEntity= mock(HttpEntity.class);
bodyParts.add(formDataBodyPart);
vtpExecutionResource.executeTestcases(requestId,bodyParts,"exeJson") ;
}
+
+ @Test(expected = Exception.class)
+ public void testGetTestExecutionLogsHandler() throws Exception {
+ assertNotNull(vtpExecutionResource.getTestExecutionLogsHandler("1234", "action"));
+ }
}
\ No newline at end of file
vtpExecutionResource = new VTPExecutionResource();
String execJson = "[{\"scenario\":\"tutorial\",\"testCaseName\":\"list-users\",\"testSuiteName\":\"ut\"," +
"\"requestId\":\"1234567890\",\"executionId\":\"123\",\"profile\":\"http\"}]";
- vtpExecutionResource.executeTestcases(requestId,null,"exeJson") ;
+ assertEquals(200, vtpExecutionResource.executeTestcases(requestId,null,"exeJson").getStatus());
}
}
import java.util.List;
import static org.junit.Assert.*;
+import org.onap.vtp.scenario.model.VTPTestCase;
public class VTPScenarioResourceTest {
}
};
- vtpScenarioResource.listTestcasesHandler("testsuite", "open-cli");
+ VTPTestCase vtpTestCases = vtpScenarioResource.listTestcasesHandler("testsuite", "open-cli").getTestCases().get(0);
+ assertEquals("list-users", vtpTestCases.getTestCaseName());
}
public void testListTestcases() throws Exception {
Code Review / vnfsdk / refrepo.git / commitdiff