aboutsummaryrefslogtreecommitdiffstats
path: root/vnfmarket-be/vnf-sdk-marketplace/src/main/java/org/onap/vnfsdk/marketplace/onboarding/onboardmanager/OnBoardingHandler.java
diff options
context:
space:
mode:
Diffstat (limited to 'vnfmarket-be/vnf-sdk-marketplace/src/main/java/org/onap/vnfsdk/marketplace/onboarding/onboardmanager/OnBoardingHandler.java')
-rw-r--r--vnfmarket-be/vnf-sdk-marketplace/src/main/java/org/onap/vnfsdk/marketplace/onboarding/onboardmanager/OnBoardingHandler.java86
1 files changed, 51 insertions, 35 deletions
diff --git a/vnfmarket-be/vnf-sdk-marketplace/src/main/java/org/onap/vnfsdk/marketplace/onboarding/onboardmanager/OnBoardingHandler.java b/vnfmarket-be/vnf-sdk-marketplace/src/main/java/org/onap/vnfsdk/marketplace/onboarding/onboardmanager/OnBoardingHandler.java
index 90514eea..b7cfdc1c 100644
--- a/vnfmarket-be/vnf-sdk-marketplace/src/main/java/org/onap/vnfsdk/marketplace/onboarding/onboardmanager/OnBoardingHandler.java
+++ b/vnfmarket-be/vnf-sdk-marketplace/src/main/java/org/onap/vnfsdk/marketplace/onboarding/onboardmanager/OnBoardingHandler.java
@@ -24,40 +24,56 @@ import org.onap.vnfsdk.marketplace.onboarding.hooks.validatelifecycle.LifecycleT
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
-public final class OnBoardingHandler
-{
- private static final Logger logger = LoggerFactory.getLogger(OnBoardingHandler.class);
-
- public void handleOnBoardingReq(OnBoradingRequest onBoradingReq)
- {
- //Handle Package Life cycle/Validation
- //------------------------------------
- LifecycleTestHook oLifecycleTestHook = new LifecycleTestHook();
- int iLifeCycleResponse = oLifecycleTestHook.exec(onBoradingReq);
- if(EnumResult.SUCCESS.getIndex() != iLifeCycleResponse)
- {
- logger.error("Onboarding falied for Package Id during Lifecycle Test:" + onBoradingReq.getCsarId());
- }
-
- //Handle Package FunctionTest
- //-------------------------
- FunctionTestHook oFunctionTestHook = new FunctionTestHook();
- int iFuncTestResponse = oFunctionTestHook.exec(onBoradingReq);
- if(EnumResult.SUCCESS.getIndex() != iFuncTestResponse)
- {
- logger.error("Onboarding falied for Package Id during Function Test:" + onBoradingReq.getCsarId());
- return;
- }
-
- FileUtil.deleteDirectory(onBoradingReq.getPackagePath());
- try
- {
- PackageManager.getInstance().updateDwonloadCount(onBoradingReq.getCsarId());
- }
- catch (Exception e)
- {
- logger.error("Download count udate failed for Package:" + onBoradingReq.getPackagePath() ,e);
- }
- }
+/* Call Flow: PackageWrapper(package upload) --> OnBoardingHandler (package on boarding) */
+public final class OnBoardingHandler {
+
+ private static final Logger logger = LoggerFactory.getLogger(OnBoardingHandler.class);
+
+ public void handleOnBoardingReq(OnBoradingRequest onBoardingReq) {
+
+ // Step 0: Input validation
+ // ------------------------------
+ if (null == onBoardingReq) {
+ logger.error("Invalid input:Onboarding request is null");
+ return;
+ }
+
+ if ((null == onBoardingReq.getPackagePath()) || (null == onBoardingReq.getPackageName())) {
+ logger.error("Package path or name is invalid");
+ return;
+ }
+
+ if (null == onBoardingReq.getCsarId()) {
+ logger.error("CsarId is invalid - null");
+ return;
+ }
+
+ // Step 1:Handle Package Life cycle/Validation
+ // ------------------------------------
+ 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());
+ // Note: We need to continue even if life cycle test fails as this
+ // test is not mandatory
+ }
+
+ // Step 2: Handle Package FunctionTest
+ // -------------------------
+ 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());
+ // Note: We need to continue even if function test fails as this
+ // test is not mandatory
+ }
+
+ FileUtil.deleteDirectory(onBoardingReq.getPackagePath());
+ try {
+ PackageManager.getInstance().updateDownloadCount(onBoardingReq.getCsarId());
+ } catch (Exception e) {
+ logger.error("Download count update failed for Package:" + onBoardingReq.getPackagePath(), e);
+ }
+ }
}