How to use setProxy method of org.cerberus.service.ftp.impl.FtpService class

Best Cerberus-source code snippet using org.cerberus.service.ftp.impl.FtpService.setProxy

Source:FtpService.java

...106        }107        return map;108    }109    @Override110    public void setProxy(FTPClient client, String system, AppService myResponse) {111        String proxyHost = parameterService.getParameterStringByKey("cerberus_proxy_host", "",112                DEFAULT_PROXY_HOST);113        int proxyPort = parameterService.getParameterIntegerByKey("cerberus_proxy_port", "",114                DEFAULT_PROXY_PORT);115        myResponse.setProxy(true);116        myResponse.setProxyHost(proxyHost);117        myResponse.setProxyPort(proxyPort);118        SocketAddress proxyAddr = new InetSocketAddress(proxyHost, proxyPort);119        Proxy proxy = new Proxy(Proxy.Type.HTTP, proxyAddr);120        if (parameterService.getParameterBooleanByKey("cerberus_proxyauthentification_active", system,121                DEFAULT_PROXYAUTHENT_ACTIVATE)) {122            Authenticator.setDefault(123                    new Authenticator() {124                public PasswordAuthentication getPasswordAuthentication() {125                    String proxyUser = parameterService.getParameterStringByKey("cerberus_proxyauthentification_user", "", DEFAULT_PROXYAUTHENT_USER);126                    String proxyPassword = parameterService.getParameterStringByKey("cerberus_proxyauthentification_password", "", DEFAULT_PROXYAUTHENT_PASSWORD);127                    myResponse.setProxyWithCredential(true);128                    myResponse.setProxyUser(proxyUser);129                    return new PasswordAuthentication(130                            proxyUser, proxyPassword.toCharArray()131                    );132                }133            }134            );135        }136        client.setProxy(proxy);137    }138    public AnswerItem<AppService> callFTP(String chain, String system, String content, String method, String filePath, String service) {139        MessageEvent message = null;140        AnswerItem<AppService> result = new AnswerItem<>();141        HashMap<String, String> informations = this.fromFtpStringToHashMap(chain);142        if (informations.size() <= 4) {143            message = new MessageEvent(MessageEventEnum.ACTION_FAILED_CALLSERVICE);144            message.setDescription(message.getDescription().replace("%SERVICE%", chain));145            message.setDescription(146                    message.getDescription().replace("%DESCRIPTION%", "Ftp url bad format! you missed something. please modify ftp url with correct syntax"));147            result.setResultMessage(message);148            return result;149        }150        FTPClient ftp = new FTPClient();151        AppService myResponse = factoryAppService.create(service, AppService.TYPE_FTP,152                method, "", "", content, "", "", "", "", "", informations.get("path"), "", "", "", null, "", null, filePath);153        try {154            if (proxyService.useProxy(StringUtil.getURLFromString(informations.get("host"), "", "", "ftp://"), system)) {155                this.setProxy(ftp, system, myResponse);156            }157            ftp.connect(informations.get("host"), Integer.valueOf(informations.get("port")));158            boolean logged = ftp.login(informations.get("pseudo"), informations.get("password"));159            if (!logged) {160                LOG.error("Exception when logging to ftp server.");161                message = new MessageEvent(MessageEventEnum.ACTION_FAILED_CALLSERVICE);162                message.setDescription(message.getDescription().replace("%SERVICE%", informations.get("path")));163                message.setDescription(164                        message.getDescription().replace("%DESCRIPTION%", "Error on logging to FTP Server"));165                result.setResultMessage(message);166                return result;167            } else {168                LOG.info("Successfully logged to the ftp server");169            }...

setProxy

Using AI Code Generation

1package org.cerberus.service.ftp.impl;2import org.apache.commons.net.ftp.FTPClient;3import org.apache.commons.net.ftp.FTPClientConfig;4import org.apache.commons.net.ftp.FTPReply;5import org.apache.commons.net.ftp.parser.FTPFileEntryParserFactory;6import org.apache.logging.log4j.LogManager;7import org.apache.logging.log4j.Logger;8import org.cerberus.crud.entity.Application;9import org.cerberus.crud.entity.CountryEnvironmentDatabase;10import org.cerberus.crud.entity.CountryEnvironmentParameters;11import org.cerberus.crud.entity.Ftp;12import org.cerberus.crud.entity.MessageEvent;13import org.cerberus.crud.entity.MessageGeneral;14import org.cerberus.crud.entity.MessageGeneralEnum;15import org.cerberus.crud.factory.IFactoryFtp;16import org.cerberus.crud.service.IApplicationService;17import org.cerberus.crud.service.ICountryEnvironmentDatabaseService;18import org.cerberus.crud.service.ICountryEnvironmentParametersService;19import org.cerberus.crud.service.IFtpService;20import org.cerberus.crud.service.IMessageGeneralService;21import org.cerberus.crud.service.impl.ApplicationService;22import org.cerberus.crud.service.impl.CountryEnvironmentDatabaseService;23import org.cerberus.crud.service.impl.CountryEnvironmentParametersService;24import org.cerberus.crud.service.impl.FtpService;25import org.cerberus.crud.service.impl.MessageGeneralService;26import org.cerberus.crud.service.impl.TestCaseExecutionFileService;27import org.cerberus.engine.entity.MessageEventEnum;28import org.cerberus.engine.entity.Session;29import org.cerberus.enums.MessageEventEnum;30import org.cerberus.exception.CerberusException;31import org.cerberus.service.ftp.IFtpService;32import org.cerberus.util.answer.Answer;33import org.cerberus.util.answer.AnswerItem;34import org.cerberus.util.answer.AnswerList;35import org.springframework.beans.factory.annotation.Autowired;36import org.springframework.stereotype.Service;37import java.io.IOException;38import java.util.ArrayList;39import java.util.List;40import java.util.stream.Collectors;41public class FtpService implements IFtpService {42    private IFactoryFtp factoryFtp;

setProxy

Using AI Code Generation

1import org.cerberus.service.ftp.impl.FtpService;2import org.cerberus.service.proxy.impl.ProxyService;3def ftp = new FtpService();4def proxy = new ProxyService();5proxy.setProxy("proxy.server.com", 8080);6ftp.connect("ftp.server.com", "myLogin", "myPassword");7ftp.setProxyService(proxy);8ftp.getDirectoryListing("/");9ftp.disconnect();10proxy.removeProxy();11ftp.connect("ftp.server.com", "myLogin", "myPassword");12ftp.getDirectoryListing("/");13ftp.disconnect();

Automation Testing Tutorials

Learn to execute automation testing from scratch with LambdaTest Learning Hub. Right from setting up the prerequisites to run your first automation test, to following best practices and diving deeper into advanced test scenarios. LambdaTest Learning Hubs compile a list of step-by-step guides to help you be proficient with different test automation frameworks i.e. Selenium, Cypress, TestNG etc.