summaryrefslogtreecommitdiffstats
path: root/ui-ci/src/main/java/org/openecomp/sdc/ci/tests/execute/setup/AttFtpClient.java
diff options
context:
space:
mode:
Diffstat (limited to 'ui-ci/src/main/java/org/openecomp/sdc/ci/tests/execute/setup/AttFtpClient.java')
-rw-r--r--ui-ci/src/main/java/org/openecomp/sdc/ci/tests/execute/setup/AttFtpClient.java308
1 files changed, 155 insertions, 153 deletions
diff --git a/ui-ci/src/main/java/org/openecomp/sdc/ci/tests/execute/setup/AttFtpClient.java b/ui-ci/src/main/java/org/openecomp/sdc/ci/tests/execute/setup/AttFtpClient.java
index f34ada6a70..37e8855800 100644
--- a/ui-ci/src/main/java/org/openecomp/sdc/ci/tests/execute/setup/AttFtpClient.java
+++ b/ui-ci/src/main/java/org/openecomp/sdc/ci/tests/execute/setup/AttFtpClient.java
@@ -7,9 +7,9 @@
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
- *
+ *
* http://www.apache.org/licenses/LICENSE-2.0
- *
+ *
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
@@ -24,84 +24,86 @@ import org.apache.commons.net.ftp.FTPClient;
import org.apache.commons.net.ftp.FTPFile;
import org.apache.commons.net.ftp.FTPReply;
-import java.io.*;
+import java.io.BufferedOutputStream;
+import java.io.File;
+import java.io.FileOutputStream;
+import java.io.IOException;
+import java.io.OutputStream;
import java.text.DateFormat;
import java.text.SimpleDateFormat;
-import java.util.*;
+import java.util.Arrays;
+import java.util.Collections;
+import java.util.Comparator;
+import java.util.Date;
+import java.util.List;
import java.util.stream.Collectors;
public class AttFtpClient {
- private static final AttFtpClient instance = new AttFtpClient();
+ private static final AttFtpClient FTP_CLIENT = new AttFtpClient();
- public static AttFtpClient getInstance() {
- return instance;
- }
+ public static AttFtpClient getFtpClient() {
+ return FTP_CLIENT;
+ }
- private FTPClient apacheFtpClient;
+ private FTPClient apacheFtpClient;
- private AttFtpClient() {
- apacheFtpClient = new FTPClient();
- };
+ private AttFtpClient() {
+ apacheFtpClient = new FTPClient();
+ }
- public void init(String server, int port, String user, String pass) {
+ public void init(String server, int port, String user, String pass) {
- try {
- apacheFtpClient.connect(server, port);
- showServerReply(apacheFtpClient);
-
-
- int replyCode = apacheFtpClient.getReplyCode();
- if (!FTPReply.isPositiveCompletion(replyCode)) {
- System.out.println("Connect failed");
- return;
- }
+ try {
+ apacheFtpClient.connect(server, port);
+ showServerReply(apacheFtpClient);
- boolean success = apacheFtpClient.login(user, pass);
- showServerReply(apacheFtpClient);
- if (!success) {
- System.out.println("Could not login to the server");
- return;
- }
-
-// else{
-// apacheFtpClient.enterLocalPassiveMode();
-// apacheFtpClient.setFileType(FTP.BINARY_FILE_TYPE);
-// }
- } catch (IOException ex) {
- System.out.println("Oops! Something wrong happened");
- ex.printStackTrace();
- }
+ int replyCode = apacheFtpClient.getReplyCode();
+ if (!FTPReply.isPositiveCompletion(replyCode)) {
+ System.out.println("Connect failed");
+ return;
+ }
- }
+ boolean success = apacheFtpClient.login(user, pass);
+ showServerReply(apacheFtpClient);
- public File retrieveLastModifiedFileFromFTP() throws IOException {
- FTPFile[] files1 = retrieveListOfFile();
+ if (!success) {
+ System.out.println("Could not login to the server");
+ return;
+ }
+ } catch (IOException ex) {
+ System.out.println("Oops! Something wrong happened");
+ ex.printStackTrace();
+ }
+ }
+
+ public File retrieveLastModifiedFileFromFTP() throws IOException {
+ FTPFile[] files1 = retrieveListOfFile();
+
+ // sort list by TimeStamp
+ List<FTPFile> sorted = Arrays.asList(files1).stream()
+ .sorted(Comparator.comparing(FTPFile::getTimestamp)).collect(Collectors.toList());
+ printFileDetailsList(sorted);
+
+ // retrieve file from FTP
+ FTPFile ftpFile = sorted.get(sorted.size() - 1);
- // sort list by TimeStamp
- List<FTPFile> sorted = Arrays.asList(files1).stream()
- .sorted((e1, e2) -> e1.getTimestamp().compareTo(e2.getTimestamp())).collect(Collectors.toList());
- printFileDetailsList(sorted);
+ return retrieveFileFromFTP(ftpFile);
- // retrieve file from FTP
- FTPFile ftpFile = sorted.get(sorted.size() - 1);
+ }
- return retrieveFileFromFTP(ftpFile);
+ public FTPFile[] retrieveListOfFile() throws IOException {
+ // Lists files and directories
+ FTPFile[] files = apacheFtpClient.listFiles("");
- }
+ printNames(files);
+ return files;
+ }
- public FTPFile[] retrieveListOfFile() throws IOException {
- // Lists files and directories
- FTPFile[] files = apacheFtpClient.listFiles("");
-
- printNames(files);
- return files;
- }
+ public File retrieveFileFromFTP(FTPFile ftpFile) throws IOException {
- public File retrieveFileFromFTP(FTPFile ftpFile) throws IOException {
-
File downloadFile1 = new File("tmp");
OutputStream outputStream1 = new BufferedOutputStream(new FileOutputStream(downloadFile1));
boolean success = apacheFtpClient.retrieveFile(ftpFile.getName(), outputStream1);
@@ -110,100 +112,100 @@ public class AttFtpClient {
if (success) {
System.out.println("File #1 has been downloaded successfully.");
}
-
-
- return downloadFile1;
-
- }
-
- public void deleteFilesFromFTPserver() throws IOException {
- FTPFile[] files = retrieveListOfFile();
- deleteFiles(files);
- }
-
- public void terminateClient() throws IOException {
-
- String status = apacheFtpClient.getStatus();
-
- // logs out and disconnects from server
- try {
- if (apacheFtpClient.isConnected()) {
- apacheFtpClient.logout();
- apacheFtpClient.disconnect();
- }
- } catch (IOException ex) {
- ex.printStackTrace();
- }
- }
-
- private void printFileDetailsList(List<FTPFile> list) {
- DateFormat dateFormater = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
-
- for (FTPFile ftpFile : list) {
-
- String details = ftpFile.getName();
- if (ftpFile.isDirectory()) {
- details = "[" + details + "]";
- }
- details += "\t\t" + ftpFile.getSize();
- details += "\t\t" + dateFormater.format(ftpFile.getTimestamp().getTime());
-
- System.out.println(details);
- }
- }
-
- private void printNames(FTPFile[] files) {
- if (files != null && files.length > 0) {
- for (FTPFile aFile : files) {
- System.out.println(aFile);
- }
- }
- }
-
- private void showServerReply(FTPClient ftpClient) {
- String[] replies = ftpClient.getReplyStrings();
- if (replies != null && replies.length > 0) {
- for (String aReply : replies) {
- System.out.println("SERVER: " + aReply);
- }
- }
- }
-
- public class LastModifiedComparator implements Comparator<FTPFile> {
-
- public int compare(FTPFile f1, FTPFile f2) {
- return f1.getTimestamp().compareTo(f2.getTimestamp());
- }
- }
-
- public FTPFile getMaxLastModified(FTPFile[] ftpFiles) {
- return Collections.max(Arrays.asList(ftpFiles), new LastModifiedComparator());
- }
-
- public static void displayFiles(File[] files) {
- for (File file : files) {
- System.out.printf("File: %-20s Last Modified:" + new Date(file.lastModified()) + "\n", file.getName());
- }
- }
-
- public void deleteFiles(FTPFile[] files) {
-
- for (FTPFile file : files) {
-
- boolean deleted = false;
- try {
- deleted = apacheFtpClient.deleteFile(file.getName());
- } catch (IOException e) {
- e.printStackTrace();
- }
-
- if (deleted) {
- System.out.println("The file was deleted successfully.");
- } else {
- System.out.println("Could not delete the  file, it may not exist.");
- }
- }
-
- }
+
+
+ return downloadFile1;
+
+ }
+
+ public void deleteFilesFromFTPserver() throws IOException {
+ FTPFile[] files = retrieveListOfFile();
+ deleteFiles(files);
+ }
+
+ public void terminateClient() throws IOException {
+
+ String status = apacheFtpClient.getStatus();
+
+ // logs out and disconnects from server
+ try {
+ if (apacheFtpClient.isConnected()) {
+ apacheFtpClient.logout();
+ apacheFtpClient.disconnect();
+ }
+ } catch (IOException ex) {
+ ex.printStackTrace();
+ }
+ }
+
+ private void printFileDetailsList(List<FTPFile> list) {
+ DateFormat dateFormater = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
+
+ for (FTPFile ftpFile : list) {
+
+ String details = ftpFile.getName();
+ if (ftpFile.isDirectory()) {
+ details = "[" + details + "]";
+ }
+ details += "\t\t" + ftpFile.getSize();
+ details += "\t\t" + dateFormater.format(ftpFile.getTimestamp().getTime());
+
+ System.out.println(details);
+ }
+ }
+
+ private void printNames(FTPFile[] files) {
+ if (files != null && files.length > 0) {
+ for (FTPFile aFile : files) {
+ System.out.println(aFile);
+ }
+ }
+ }
+
+ private void showServerReply(FTPClient ftpClient) {
+ String[] replies = ftpClient.getReplyStrings();
+ if (replies != null && replies.length > 0) {
+ for (String aReply : replies) {
+ System.out.println("SERVER: " + aReply);
+ }
+ }
+ }
+
+ public class LastModifiedComparator implements Comparator<FTPFile> {
+
+ public int compare(FTPFile f1, FTPFile f2) {
+ return f1.getTimestamp().compareTo(f2.getTimestamp());
+ }
+ }
+
+ public FTPFile getMaxLastModified(FTPFile[] ftpFiles) {
+ return Collections.max(Arrays.asList(ftpFiles), new LastModifiedComparator());
+ }
+
+ public static void displayFiles(File[] files) {
+ for (File file : files) {
+ System.out.printf("File: %-20s Last Modified:" + new Date(file.lastModified()) + "\n", file.getName());
+ }
+ }
+
+ public void deleteFiles(FTPFile[] files) {
+
+ for (FTPFile file : files) {
+
+ boolean deleted = false;
+ try {
+ deleted = apacheFtpClient.deleteFile(file.getName());
+ } catch (IOException e) {
+ e.printStackTrace();
+ }
+
+ if (deleted) {
+ System.out.println("The file was deleted successfully.");
+ } else {
+ System.out.println("Could not delete the  file, it may not exist.");
+ }
+ }
+
+ }
}