diff options
Diffstat (limited to 'datafile-dmaap-client')
6 files changed, 34 insertions, 6 deletions
diff --git a/datafile-dmaap-client/pom.xml b/datafile-dmaap-client/pom.xml index 9eb232ba..5006b002 100644 --- a/datafile-dmaap-client/pom.xml +++ b/datafile-dmaap-client/pom.xml @@ -24,7 +24,7 @@ <parent> <groupId>org.onap.dcaegen2.collectors</groupId> <artifactId>datafile</artifactId> - <version>1.0.2-SNAPSHOT</version> + <version>1.0.3-SNAPSHOT</version> </parent> <groupId>org.onap.dcaegen2.collectors.datafile</groupId> diff --git a/datafile-dmaap-client/src/main/java/org/onap/dcaegen2/collectors/datafile/ftp/FTPSClientWrapper.java b/datafile-dmaap-client/src/main/java/org/onap/dcaegen2/collectors/datafile/ftp/FTPSClientWrapper.java index 77048042..2ccf1bab 100644 --- a/datafile-dmaap-client/src/main/java/org/onap/dcaegen2/collectors/datafile/ftp/FTPSClientWrapper.java +++ b/datafile-dmaap-client/src/main/java/org/onap/dcaegen2/collectors/datafile/ftp/FTPSClientWrapper.java @@ -89,4 +89,8 @@ public class FTPSClientWrapper implements IFTPSClient { return ftpsClient.retrieveFile(remote, local); } + @Override + public void setTimeout(Integer t) { + this.ftpsClient.setDefaultTimeout(t); + } } diff --git a/datafile-dmaap-client/src/main/java/org/onap/dcaegen2/collectors/datafile/ftp/FileCollectResult.java b/datafile-dmaap-client/src/main/java/org/onap/dcaegen2/collectors/datafile/ftp/FileCollectResult.java index 6cd048ac..c5962172 100644 --- a/datafile-dmaap-client/src/main/java/org/onap/dcaegen2/collectors/datafile/ftp/FileCollectResult.java +++ b/datafile-dmaap-client/src/main/java/org/onap/dcaegen2/collectors/datafile/ftp/FileCollectResult.java @@ -36,7 +36,10 @@ public class FileCollectResult { } public String getErrorData() { - return errorData.toString(); + if (errorData != null) { + return errorData.toString(); + } + return ""; } @Override diff --git a/datafile-dmaap-client/src/main/java/org/onap/dcaegen2/collectors/datafile/ftp/FtpsClient.java b/datafile-dmaap-client/src/main/java/org/onap/dcaegen2/collectors/datafile/ftp/FtpsClient.java index a88072c7..120868c6 100644 --- a/datafile-dmaap-client/src/main/java/org/onap/dcaegen2/collectors/datafile/ftp/FtpsClient.java +++ b/datafile-dmaap-client/src/main/java/org/onap/dcaegen2/collectors/datafile/ftp/FtpsClient.java @@ -57,6 +57,8 @@ public class FtpsClient extends FileCollectClient { private IFile lf; private IFileSystemResource fileResource; private IOutputStream os; + private boolean keyManagerSet = false; + private boolean trustManagerSet = false; @Override public FileCollectResult retryCollectFile() { @@ -84,19 +86,27 @@ public class FtpsClient extends FileCollectClient { private boolean setUpKeyManager(IFTPSClient ftps) { boolean result = true; + if (keyManagerSet) { + return result; + } try { IKeyManagerUtils keyManagerUtils = getKeyManagerUtils(); keyManagerUtils.setCredentials(keyCertPath, keyCertPassword); ftps.setKeyManager(keyManagerUtils.getClientKeyManager()); + keyManagerSet = true; } catch (GeneralSecurityException | IOException e) { addError("Unable to use own key store " + keyCertPath, e); result = false; } + logger.trace("complete setUpKeyManager"); return result; } private boolean setUpTrustedCA(IFTPSClient ftps) { boolean result = true; + if (trustManagerSet) { + return result; + } try { IFileSystemResource fileSystemResource = getFileSystemResource(); fileSystemResource.setPath(trustedCAPath); @@ -107,11 +117,13 @@ public class FtpsClient extends FileCollectClient { ITrustManagerFactory tmf = getTrustManagerFactory(); tmf.init(ks.getKeyStore()); ftps.setTrustManager(tmf.getTrustManagers()[0]); + trustManagerSet = true; } catch (Exception e) { addError("Unable to trust xNF's CA, " + trustedCAPath, e); result = false; } + logger.trace("complete setUpTrustedCA"); return result; } @@ -119,7 +131,7 @@ public class FtpsClient extends FileCollectClient { boolean result = true; try { ftps.connect(fileServerData.serverAddress(), fileServerData.port()); - + logger.trace("after ftp connect"); boolean loginSuccesful = ftps.login(fileServerData.userId(), fileServerData.password()); if (!loginSuccesful) { ftps.logout(); @@ -135,7 +147,8 @@ public class FtpsClient extends FileCollectClient { ftps.execPROT("P"); } else { ftps.disconnect(); - addError("Unable to connect to xNF. " + fileServerData + "xNF reply code: " + ftps.getReplyCode(), null); + addError("Unable to connect to xNF. " + fileServerData + " xNF reply code: " + ftps.getReplyCode(), + null); result = false; } } catch (Exception ex) { @@ -157,8 +170,13 @@ public class FtpsClient extends FileCollectClient { IOutputStream outputStream = getOutputStream(); OutputStream output = outputStream.getOutputStream(outfile.getFile()); - ftps.retrieveFile(remoteFile, output); - + result = ftps.retrieveFile(remoteFile, output); + if (!result) { + output.close(); + logger.debug("Unable to retrieve file from xNF. Cause unknown!"); + addError("Unable to retrieve file from xNF. Cause unknown!", null); + return result; + } output.close(); logger.debug("File {} Download Successfull from xNF", localFile); } catch (IOException ex) { diff --git a/datafile-dmaap-client/src/main/java/org/onap/dcaegen2/collectors/datafile/ftp/IFTPSClient.java b/datafile-dmaap-client/src/main/java/org/onap/dcaegen2/collectors/datafile/ftp/IFTPSClient.java index 2f370b98..b1472026 100644 --- a/datafile-dmaap-client/src/main/java/org/onap/dcaegen2/collectors/datafile/ftp/IFTPSClient.java +++ b/datafile-dmaap-client/src/main/java/org/onap/dcaegen2/collectors/datafile/ftp/IFTPSClient.java @@ -48,4 +48,6 @@ public interface IFTPSClient { public void execPROT(String prot) throws IOException; public boolean retrieveFile(String remote, OutputStream local) throws IOException; + + void setTimeout(Integer t); } diff --git a/datafile-dmaap-client/src/test/java/org/onap/dcaegen2/collectors/datafile/ftp/FtpsClientTest.java b/datafile-dmaap-client/src/test/java/org/onap/dcaegen2/collectors/datafile/ftp/FtpsClientTest.java index e9e00c38..e5693d50 100644 --- a/datafile-dmaap-client/src/test/java/org/onap/dcaegen2/collectors/datafile/ftp/FtpsClientTest.java +++ b/datafile-dmaap-client/src/test/java/org/onap/dcaegen2/collectors/datafile/ftp/FtpsClientTest.java @@ -102,6 +102,7 @@ public class FtpsClientTest { when(localFileMock.getFile()).thenReturn(fileMock); OutputStream osMock = mock(OutputStream.class); when(outputStreamMock.getOutputStream(fileMock)).thenReturn(osMock); + when(ftpsClientMock.retrieveFile(REMOTE_FILE_PATH, osMock)).thenReturn(true); ImmutableFileServerData fileServerData = ImmutableFileServerData.builder().serverAddress(XNF_ADDRESS) .userId(USERNAME).password(PASSWORD).port(PORT).build(); |