CloudSlang/cs-actions

/*
 * Copyright 2021-2024 Open Text
 * This program and the accompanying materials
 * are made available under the terms of the Apache License v2.0 which accompany this distribution.
 *
 * The Apache License is available 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.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 */




package io.cloudslang.content.rft.services;



import io.cloudslang.content.constants.OutputNames;
import io.cloudslang.content.constants.ReturnCodes;
import io.cloudslang.content.rft.entities.*;
import io.cloudslang.content.rft.utils.Constants;
import io.cloudslang.content.rft.utils.StringUtils;

import java.util.HashMap;
import java.util.Map;

/**
 * Date: 7/21/2015
 *
 * @author lesant
 */
public class RemoteSecureCopyService {

    public Map<String, String> execute(RemoteSecureCopyInputs remoteSecureCopyInputs){

        Map<String, String> returnResult = new HashMap<>();
        String resultMessage, errorMessage, returnCode;

        try {

            SCPCopier copier = new SCPCopier(remoteSecureCopyInputs);

            boolean successfullyCopied = false;
            boolean srcHostEmpty = StringUtils.isEmpty(remoteSecureCopyInputs.getSrcHost());
            boolean destHostEmpty = StringUtils.isEmpty(remoteSecureCopyInputs.getDestHost());
            if (srcHostEmpty && !destHostEmpty){
                successfullyCopied = copier.copyFromLocalToRemote();
            } else if (!srcHostEmpty && destHostEmpty) {
                successfullyCopied = copier.copyFromRemoteToLocal();
            } else if (!srcHostEmpty && !destHostEmpty) {
                successfullyCopied = copier.copyFromRemoteToRemote();
            }
            if (successfullyCopied) {
                resultMessage = "File " + remoteSecureCopyInputs.getSrcPath() + " successfully copied to path " +
                        remoteSecureCopyInputs.getDestPath() + " on " + remoteSecureCopyInputs.getDestHost();
                errorMessage = Constants.EMPTY_STRING;
                returnCode = ReturnCodes.SUCCESS;

            } else {
                resultMessage = Constants.NO_ACK_RECEIVED;
                errorMessage = Constants.NO_ACK_RECEIVED;
                returnCode = ReturnCodes.FAILURE;
            }
            populateResult(returnResult, resultMessage, errorMessage, returnCode);

        } catch (Exception e) {
            populateResult(returnResult, e.getMessage(), StringUtils.getStackTraceAsString(e), ReturnCodes.FAILURE);
        }
        return returnResult;
    }

    private void populateResult(Map<String, String> returnResult, String resultMessage, String errorMessage, String returnCode){
        returnResult.put(OutputNames.RETURN_RESULT, resultMessage);
        returnResult.put(OutputNames.EXCEPTION, errorMessage);
        returnResult.put(OutputNames.RETURN_CODE, returnCode);
    }

}