X-Git-Url: https://gerrit.onap.org/r/gitweb?a=blobdiff_plain;f=appc-inbound%2Fappc-artifact-handler%2Fprovider%2Fsrc%2Fmain%2Fjava%2Forg%2Fonap%2Fappc%2Fartifact%2Fhandler%2FArtifactHandlerProvider.java;h=9ca1f44a4d62d53381c99a04199b47f0b348708b;hb=27543757355a584901f8d2cb5ca0b2dffe31a628;hp=5bfdf96b8167e4d155d174120049fda7f75388a3;hpb=1f28945a3c5d1a4ffc74edc815cf502d715e33ac;p=appc.git diff --git a/appc-inbound/appc-artifact-handler/provider/src/main/java/org/onap/appc/artifact/handler/ArtifactHandlerProvider.java b/appc-inbound/appc-artifact-handler/provider/src/main/java/org/onap/appc/artifact/handler/ArtifactHandlerProvider.java index 5bfdf96b8..9ca1f44a4 100644 --- a/appc-inbound/appc-artifact-handler/provider/src/main/java/org/onap/appc/artifact/handler/ArtifactHandlerProvider.java +++ b/appc-inbound/appc-artifact-handler/provider/src/main/java/org/onap/appc/artifact/handler/ArtifactHandlerProvider.java @@ -5,6 +5,8 @@ * Copyright (C) 2017-2018 AT&T Intellectual Property. All rights reserved. * ================================================================================ * Copyright (C) 2017 Amdocs + * ================================================================================ + * Modifications Copyright (C) 2019 Ericsson * ============================================================================= * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. @@ -145,19 +147,19 @@ public class ArtifactHandlerProvider implements AutoCloseable, ArtifactHandlerSe String finalInd) { UploadartifactOutputBuilder responseBuilder = new UploadartifactOutputBuilder(); - ConfigDocumentResponseBuilder configResponseBuilder=new ConfigDocumentResponseBuilder(); - configResponseBuilder.setRequestId(svcRequestId); - configResponseBuilder.setStatus(code); - configResponseBuilder.setErrorReason(message); + ConfigDocumentResponseBuilder configResponseBuilder=new ConfigDocumentResponseBuilder(); + configResponseBuilder.setRequestId(svcRequestId); + configResponseBuilder.setStatus(code); + configResponseBuilder.setErrorReason(message); RpcResult rpcResult = RpcResultBuilder. status(true) .withResult(responseBuilder.build()).build(); - return rpcResult; + return rpcResult; } @Override public Future> uploadartifact(UploadartifactInput input) { - if (input == null || input.getDocumentParameters() == null || input.getDocumentParameters().getArtifactContents() == null ) { + if (input == null || input.getDocumentParameters() == null || input.getDocumentParameters().getArtifactContents() == null ) { RpcResult rpcResult = buildResponse1("N/A", "N/A", "INVALID_INPUT", "Invalid input, null or empty document information" , "Y"); return Futures.immediateFuture(rpcResult); @@ -166,10 +168,9 @@ public class ArtifactHandlerProvider implements AutoCloseable, ArtifactHandlerSe ConfigDocumentResponseBuilder configResponseBuilder = new ConfigDocumentResponseBuilder(); UploadartifactOutputBuilder responseBuilder = new UploadartifactOutputBuilder(); log.info("Received input = " + input ); - ArtifactHandlerProviderUtil designUtil = new ArtifactHandlerProviderUtil(input); + ArtifactHandlerProviderUtil designUtil = getArtifactHandlerProviderUtil(input); configResponseBuilder.setRequestId(input.getRequestInformation().getRequestId()); try{ - if(input.getRequestInformation().getSource() !=null){ if(input.getRequestInformation().getSource().equalsIgnoreCase(SdcArtifactHandlerConstants.DESIGN_TOOL)){ designUtil.processTemplate(designUtil.createDummyRequestData()); @@ -178,27 +179,29 @@ public class ArtifactHandlerProvider implements AutoCloseable, ArtifactHandlerSe else { designUtil.processTemplate(designUtil.createRequestData()); - configResponseBuilder.setStatus(ArtifactHandlerProviderUtil.DistributionStatusEnum.DEPLOY_OK.toString()); + configResponseBuilder.setStatus(ArtifactHandlerProviderUtil.DistributionStatusEnum.DEPLOY_OK.toString()); } } else { - throw new Exception("No Tempalte data found"); + throw new Exception("No Template data found"); } - - } catch (Exception e) { - configResponseBuilder.setErrorReason(e.getMessage()); + configResponseBuilder.setErrorReason(e.getMessage()); configResponseBuilder.setStatus(ArtifactHandlerProviderUtil.DistributionStatusEnum.DEPLOY_ERROR.toString()); log.error("Caught exception looking for Artifact Handler", e); log.info("Caught exception looking for Artifact Handler: "); } - + responseBuilder.setConfigDocumentResponse(configResponseBuilder.build()); RpcResult rpcResult = RpcResultBuilder. status(true).withResult(responseBuilder.build()).build(); return Futures.immediateFuture(rpcResult); } + + protected ArtifactHandlerProviderUtil getArtifactHandlerProviderUtil(UploadartifactInput input) { + return new ArtifactHandlerProviderUtil(input); + } }