b50b0457a877df548c88159850782a4435a8ff9f
[dcaegen2/collectors/datafile.git] /
1 /*
2  * ============LICENSE_START======================================================================
3  * Copyright (C) 2018 Nordix Foundation. All rights reserved.
4  * ===============================================================================================
5  * Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except
6  * in compliance with the License. You may obtain a copy of the License at
7  *
8  * http://www.apache.org/licenses/LICENSE-2.0
9  *
10  * Unless required by applicable law or agreed to in writing, software distributed under the License
11  * is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express
12  * or implied. See the License for the specific language governing permissions and limitations under
13  * the License.
14  * ============LICENSE_END========================================================================
15  */
16
17 package org.onap.dcaegen2.collectors.datafile.ftp;
18
19 import org.slf4j.Logger;
20 import org.slf4j.LoggerFactory;
21
22 /**
23  * @author
24  *
25  */
26 public abstract class FileCollectClient {
27     protected static final Logger logger = LoggerFactory.getLogger(FtpsClient.class);
28
29     protected FileServerData fileServerData;
30     protected String remoteFile;
31     protected String localFile;
32     protected ErrorData errorData;
33
34     public FileCollectResult collectFile(FileServerData fileServerData, String remoteFile, String localFile) {
35         logger.trace("collectFile called with fileServerData: {}, remoteFile: {}, localFile: {}", fileServerData,
36                 remoteFile, localFile);
37
38         this.fileServerData = fileServerData;
39         this.remoteFile = remoteFile;
40         this.localFile = localFile;
41
42         return retryCollectFile();
43     }
44
45     public abstract FileCollectResult retryCollectFile();
46
47     protected void addError(String errorMessage, Throwable errorCause) {
48         if (errorData == null) {
49             errorData = new ErrorData();
50         }
51         errorData.addError(errorMessage, errorCause);
52     }
53 }