Unlock 30% off on Manual Testing Annual Plans this Holiday Season.

Copied to Clipboard!

How to use createDir method of com.consol.citrus.ftp.client.SftpClient class

Best Citrus code snippet using com.consol.citrus.ftp.client.SftpClient.createDir

Source:SftpClient.java

...62    }63    @Override64    protected FtpMessage executeCommand(CommandType ftpCommand, TestContext context) {65        if (ftpCommand.getSignal().equals(FTPCmd.MKD.getCommand())) {66            return createDir(ftpCommand);67        } else if (ftpCommand.getSignal().equals(FTPCmd.LIST.getCommand())) {68            return listFiles(FtpMessage.list(ftpCommand.getArguments()).getPayload(ListCommand.class), context);69        } else if (ftpCommand.getSignal().equals(FTPCmd.DELE.getCommand())) {70            return deleteFile(FtpMessage.delete(ftpCommand.getArguments()).getPayload(DeleteCommand.class), context);71        } else if (ftpCommand.getSignal().equals(FTPCmd.STOR.getCommand())) {72            return storeFile(FtpMessage.put(ftpCommand.getArguments()).getPayload(PutCommand.class), context);73        } else if (ftpCommand.getSignal().equals(FTPCmd.RETR.getCommand())) {74            return retrieveFile(FtpMessage.get(ftpCommand.getArguments()).getPayload(GetCommand.class), context);75        } else {76            throw new CitrusRuntimeException(String.format("Unsupported ftp command '%s'", ftpCommand.getSignal()));77        }78    }79    /**80     * Execute mkDir command and create new directory.81     * @param ftpCommand82     * @return83     */84    protected FtpMessage createDir(CommandType ftpCommand) {85        try {86            sftp.mkdir(ftpCommand.getArguments());87            return FtpMessage.result(FTPReply.PATHNAME_CREATED, "Pathname created", true);88        } catch (SftpException e) {89            throw new CitrusRuntimeException("Failed to execute ftp command", e);90        }91    }92    @Override93    protected FtpMessage listFiles(ListCommand list, TestContext context) {94        String remoteFilePath = Optional.ofNullable(list.getTarget())95                                        .map(ListCommand.Target::getPath)96                                        .map(context::replaceDynamicContentInString)97                                        .orElse("");98        try {99            List<String> fileNames = new ArrayList<>();100            Vector<ChannelSftp.LsEntry> entries = sftp.ls(remoteFilePath);101            for (ChannelSftp.LsEntry entry : entries) {102                fileNames.add(entry.getFilename());103            }104            return FtpMessage.result(FTPReply.FILE_STATUS_OK, "List files complete", fileNames);105        } catch (SftpException e) {106            throw new CitrusRuntimeException(String.format("Failed to list files in path '%s'", remoteFilePath), e);107        }108    }109    @Override110    protected FtpMessage deleteFile(DeleteCommand delete, TestContext context) {111        String remoteFilePath = context.replaceDynamicContentInString(delete.getTarget().getPath());112        try {113            if (!StringUtils.hasText(remoteFilePath)) {114                return null;115            }116            if (isDirectory(remoteFilePath)) {117                sftp.cd(remoteFilePath);118                if (delete.isRecursive()) {119                    Vector<ChannelSftp.LsEntry> entries = sftp.ls(".");120                    List<String> excludedDirs = Arrays.asList(".", "..");121                    for (ChannelSftp.LsEntry entry : entries) {122                        if (!excludedDirs.contains(entry.getFilename())) {123                            DeleteCommand recursiveDelete = new DeleteCommand();124                            DeleteCommand.Target target = new DeleteCommand.Target();125                            target.setPath(remoteFilePath + "/" + entry.getFilename());126                            recursiveDelete.setTarget(target);127                            recursiveDelete.setIncludeCurrent(true);128                            deleteFile(recursiveDelete, context);129                        }130                    }131                }132                if (delete.isIncludeCurrent()) {133                    // we cannot delete the current working directory, so go to root directory and delete from there134                    sftp.cd("..");135                    sftp.rmdir(remoteFilePath);136                }137            } else {138                sftp.rm(remoteFilePath);139            }140        } catch (SftpException e) {141            throw new CitrusRuntimeException("Failed to delete file from FTP server", e);142        }143        return FtpMessage.deleteResult(FTPReply.FILE_ACTION_OK, "Delete file complete", true);144    }145    @Override146    protected boolean isDirectory(String remoteFilePath) {147        try {148            return !remoteFilePath.contains("*") && sftp.stat(remoteFilePath).isDir();149        } catch (SftpException e) {150            throw new CitrusRuntimeException("Failed to check file state", e);151        }152    }153    @Override154    protected FtpMessage storeFile(PutCommand command, TestContext context) {155        try {156            String localFilePath = context.replaceDynamicContentInString(command.getFile().getPath());157            String remoteFilePath = addFileNameToTargetPath(localFilePath, context.replaceDynamicContentInString(command.getTarget().getPath()));158            String dataType = context.replaceDynamicContentInString(Optional.ofNullable(command.getFile().getType()).orElse(DataType.BINARY.name()));159            try (InputStream localFileInputStream = getLocalFileInputStream(command.getFile().getPath(), dataType, context)) {160                sftp.put(localFileInputStream, remoteFilePath);161            }162        } catch (IOException | SftpException e) {163            throw new CitrusRuntimeException("Failed to put file to FTP server", e);164        }165        return FtpMessage.putResult(FTPReply.CLOSING_DATA_CONNECTION, "Transfer complete", true);166    }167    @Override168    protected FtpMessage retrieveFile(GetCommand command, TestContext context) {169        try {170            String remoteFilePath = context.replaceDynamicContentInString(command.getFile().getPath());171            String localFilePath = addFileNameToTargetPath(remoteFilePath, context.replaceDynamicContentInString(command.getTarget().getPath()));172            try (InputStream inputStream = sftp.get(remoteFilePath)) {173                byte[] bytes = FileCopyUtils.copyToByteArray(inputStream);174                // create intermediate directories if necessary175                Path localFilePathObj = Paths.get(localFilePath);176                Files.createDirectories(localFilePathObj.getParent());177                Files.write(localFilePathObj, bytes);178            } catch (SftpException e) {179                throw new CitrusRuntimeException(String.format("Failed to get file from FTP server. Remote path: %s. Local file path: %s. Error: %s",180                        remoteFilePath, localFilePath, e.getMessage()));181            }182            if (getEndpointConfiguration().isAutoReadFiles()) {183                String fileContent;184                if (command.getFile().getType().equals(DataType.BINARY.name())) {185                    fileContent = Base64.encodeBase64String(FileCopyUtils.copyToByteArray(FileUtils.getFileResource(localFilePath).getInputStream()));186                } else {187                    fileContent = FileUtils.readToString(FileUtils.getFileResource(localFilePath));188                }189                return FtpMessage.result(FTPReply.CLOSING_DATA_CONNECTION, "Transfer complete", localFilePath, fileContent);190            } else {...

Source:ScpClient.java

...57    public ScpEndpointConfiguration getEndpointConfiguration() {58        return (ScpEndpointConfiguration) super.getEndpointConfiguration();59    }60    @Override61    protected FtpMessage createDir(CommandType ftpCommand) {62        throw new UnsupportedOperationException("SCP client does not support create directory operation - please use sftp client");63    }64    @Override65    protected FtpMessage listFiles(ListCommand list, TestContext context) {66        throw new UnsupportedOperationException("SCP client does not support list files operation - please use sftp client");67    }68    @Override69    protected FtpMessage deleteFile(DeleteCommand delete, TestContext context) {70        throw new UnsupportedOperationException("SCP client does not support delete file operation - please use sftp client");71    }72    @Override73    protected FtpMessage storeFile(PutCommand command, TestContext context) {74        try {75            scpClient.upload(FileUtils.getFileResource(command.getFile().getPath(), context).getFile().getAbsolutePath(), command.getTarget().getPath());...

createDir

Using AI Code Generation

1package com.consol.citrus.ftp.client;2import com.consol.citrus.annotations.CitrusTest;3import com.consol.citrus.dsl.junit.JUnit4CitrusTestDesigner;4import com.consol.citrus.testng.CitrusParameters;5import org.springframework.beans.factory.annotation.Autowired;6import org.springframework.core.io.ClassPathResource;7import org.testng.annotations.Test;8public class SftpClientIT extends JUnit4CitrusTestDesigner {9    private SftpClient sftpClient;10    @CitrusParameters({"remotePath"})11    public void createDir(String remotePath) {12        sftpClient.createDir(remotePath);13    }14}15package com.consol.citrus.ftp.client;16import com.consol.citrus.annotations.CitrusTest;17import com.consol.citrus.dsl.junit.JUnit4CitrusTestDesigner;18import com.consol.citrus.testng.CitrusParameters;19import org.springframework.beans.factory.annotation.Autowired;20import org.springframework.core.io.ClassPathResource;21import org.testng.annotations.Test;22public class SftpClientIT extends JUnit4CitrusTestDesigner {23    private SftpClient sftpClient;24    @CitrusParameters({"remotePath"})25    public void deleteDir(String remotePath) {26        sftpClient.deleteDir(remotePath);27    }28}29package com.consol.citrus.ftp.client;30import com.consol.citrus.annotations.CitrusTest;31import com.consol.citrus.dsl.junit.JUnit4CitrusTestDesigner;32import com.consol.citrus.testng.CitrusParameters;33import org.springframework.beans.factory.annotation.Autowired;34import org.springframework.core.io.ClassPathResource;35import org.testng.annotations.Test;36public class SftpClientIT extends JUnit4CitrusTestDesigner {37    private SftpClient sftpClient;38    @CitrusParameters({"remotePath"})39    public void deleteFile(String remotePath) {40        sftpClient.deleteFile(remotePath);41    }42}

createDir

Using AI Code Generation

1package com.consol.citrus.ftp.client;2import com.consol.citrus.testng.CitrusParameters;3import org.testng.annotations.Test;4import static com.consol.citrus.actions.CreateVariablesAction.Builder.createVariable;5import static com.consol.citrus.container.Parallel.Builder.parallel;6import static com.consol.citrus.container.Sequence.Builder.sequential;7import static com.consol.citrus.dsl.testng.TestNGCitrusTestDesigner.*;8public class CreateDirIT extends AbstractSftpClientIT {9    @CitrusParameters({"remoteDir", "localDir"})10    public void createDirTest(String remoteDir, String localDir) {11        variable("remoteDir", remoteDir);12        variable("localDir", localDir);13        parallel().actions(14                sequential().actions(15                        create().directory("${remoteDir}"),16                        createVariable("remoteFile").value("${remoteDir}/file.txt"),17                        create().file("${remoteFile}").content("Hello World!"),18                        receive().message("Hello World!").from("${remoteFile}"),19                        send().message("Bye World!").to("${remoteFile}"),20                        delete().file("${remoteFile}")21                sequential().actions(22                        create().directory("${localDir}"),23                        createVariable("localFile").value("${localDir}/file.txt"),24                        create().file("${localFile}").content("Hello World!"),25                        receive().message("Hello World!").from("${localFile}"),26                        send().message("Bye World!").to("${localFile}"),27                        delete().file("${localFile}")28        ).run();29    }30}31package com.consol.citrus.ftp.client;32import com.consol.citrus.annotations.CitrusResource;33import com.consol.citrus.dsl.junit.JUnit4CitrusTestDesigner;34import com.consol.citrus.dsl.runner.TestRunner;35import com.consol.citrus.ftp.message.FtpMessageHeaders;36import com.consol.citrus.testng.CitrusParameters;37import org.testng.annotations.Test;38import static com.consol.citrus.actions.CreateVariablesAction.Builder.createVariable;39import static com.consol.citrus.container.Parallel.Builder.parallel;40import static com.consol.citrus.container.Sequence.Builder.sequential;41public class CreateDirIT extends AbstractSftpClientIT {42    @CitrusParameters({"remoteDir",

createDir

Using AI Code Generation

1import com.consol.citrus.ftp.client.SftpClient;2public class 3 {3    public static void main(String args[]) {4        SftpClient sftpClient = new SftpClient();5        sftpClient.createDir("test");6    }7}8import com.consol.citrus.ftp.client.SftpClient;9public class 4 {10    public static void main(String args[]) {11        SftpClient sftpClient = new SftpClient();12        sftpClient.createDir("test", "test");13    }14}15import com.consol.citrus.ftp.client.SftpClient;16public class 5 {17    public static void main(String args[]) {18        SftpClient sftpClient = new SftpClient();19        sftpClient.createDir("test", "test", "test");20    }21}22import com.consol.citrus.ftp.client.SftpClient;23public class 6 {24    public static void main(String args[]) {25        SftpClient sftpClient = new SftpClient();26        sftpClient.createDir("test", "test", "test", "test");27    }28}29import com.consol.citrus.ftp.client.SftpClient;30public class 7 {31    public static void main(String args[]) {32        SftpClient sftpClient = new SftpClient();33        sftpClient.createDir("test", "test", "test", "test", "test");34    }35}36import com.consol.citrus.ftp.client.SftpClient;37public class 8 {38    public static void main(String args[]) {39        SftpClient sftpClient = new SftpClient();40        sftpClient.createDir("test", "test", "test", "test

createDir

Using AI Code Generation

1import com.consol.citrus.ftp.client.SftpClient;2import com.consol.citrus.ftp.message.FtpMessage;3import com.consol.citrus.ftp.server.SftpServer;4public class 3 {5    public static void main(String[] args) {6        SftpClient sftpClient = new SftpClient();7        SftpServer sftpServer = new SftpServer();8        sftpServer.setPort(2222);9        sftpServer.setHost("localhost");10        sftpServer.setUser("user");11        sftpServer.setPassword("password");12        sftpServer.setHomeDirectory("/home/user");13        sftpServer.start();14        sftpClient.setServer(sftpServer);15        FtpMessage ftpMessage = new FtpMessage();16        ftpMessage.setDirectory("/home/user");17        ftpMessage.setFileName("test.txt");18        ftpMessage.setFileContent("test");19        sftpClient.createDir(ftpMessage);20        sftpServer.stop();21    }22}

createDir

Using AI Code Generation

1package com.consol.citrus.samples;2import com.consol.citrus.annotations.CitrusTest;3import com.consol.citrus.dsl.testng.TestNGCitrusTestDesigner;4import com.consol.citrus.testng.CitrusParameters;5import org.springframework.beans.factory.annotation.Autowired;6import org.springframework.core.io.ClassPathResource;7import org.springframework.ftp.core.FtpOperations;8import org.springframework.ftp.core.FtpTemplate;9import org.springframework.test.context.ContextConfiguration;10import org.springframework.test.context.TestPropertySource;11import org.testng.annotations.Test;12@ContextConfiguration(classes = {FtpClientConfig.class})13@TestPropertySource(properties = "ftp.client.port=2222")14public class FtpSampleIT extends TestNGCitrusTestDesigner {15    private FtpOperations ftpOperations;16    @CitrusParameters({"createDir"})17    public void createDirTest(String createDir) {18        given(ftp(ftpOperations)19                .client("ftpClient")20                .send()21                .message(createDir)22                .extractFromHeader("ftpReplyCode", "ftpReplyCode")23                .extractFromHeader("ftpReplyText", "ftpReplyText"));24        then(ftp(ftpOperations)25                .client("ftpClient")26                .receive()27                .message("250 Directory created"));28    }29}

createDir

Using AI Code Generation

1import org.springframework.context.support.ClassPathXmlApplicationContext;2import com.consol.citrus.ftp.client.SftpClient;3public class 3 {4    public static void main(String[] args) {5        ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext("applicationContext.xml");6        SftpClient sftpClient = context.getBean(SftpClient.class);7        sftpClient.createDir("mydir");8        context.close();9    }10}

createDir

Using AI Code Generation

1import org.springframework.context.support.ClassPathXmlApplicationContext;2import org.springframework.context.ApplicationContext;3import com.consol.citrus.ftp.client.SftpClient;4public class 3 {5	public static void main(String[] args) {6		ApplicationContext context = new ClassPathXmlApplicationContext("classpath:3.xml");7		SftpClient sftpClient = (SftpClient) context.getBean("sftpClient");8		sftpClient.createDir("test");9	}10}

createDir

Using AI Code Generation

1import org.springframework.context.support.ClassPathXmlApplicationContext;2import com.consol.citrus.ftp.client.SftpClient;3public class 3 {4    public static void main(String[] args) {5        ClassPathXmlApplicnit;6import or

createDir

Using AI Code Generation

1package com.consol.citrus.samples.ftp;2import org.springframework.context.annotation.Bean;3import org.springframework.context.annotation.Configuration;4import org.springframework.context.annotation.Import;5import com.consol.citrus.dsl.endpoint.CitrusEndpoints;6import com.consol.citrus.ftp.client.SftpClient;7import com.consol.citrus.ftp.server.SftpServer;8import com.consol.citrus.ftp.server.SftpServerConfiguration;9import com.consol.citrus.message.MessageType;10@Import(SftpServerConfiguration.class)11public class SftpTestConfig {12    public SftpClient sftpClient() {13        return CitrusEndpoints.sftp()14                .client()15                .autoLogin(true)16                .autoReadFiles(true)17                .port(2222)18                .build();19    }20    public SftpServer sftpServer() {21        return CitrusEndpoints.sftp()22                .server()23                .port(2222)24                .autoStart(true)25                .build();26    }27}28        <create-directory path="${remoteDir}"/>29        <delete-directory path="${remoteDir}"/>30        <send message="${localFile}" type="FILE">

createDir

Using AI Code Generation

1package com.consol.citrus.samples.ftp;2import org.sprtngframework.coniext.annotation.BeanonContext context = new ClassPathXmlApplicationContext("applicationContext.xml");3org.springframework.context.annotatin.Configuation;4import org.springframework.context.annotation.Import;5import com.consol.citrus.dsl.endpoint.CitrusEndpoints;6import com.consol.citrus.ftp.client.SftpClient;7import com.consol.citrus.ftp.server.SftpServer;8import com.consol.citrus.ftp.server.SftpServerConfiguration;9import com.consol.citrus.message.MessageType;10@Import(SftpServerConfiguration.class)11public class SftpTestConfig {12    public SftpClient sftpClient() {13        return CitrusEndpoints.sftp()14                .client()15                .autoLogin(true)16                .autoReadFiles(true)17                .port(2222)18                .build();19    }20    public SftpServer sftpServer() {21        return CitrusEndpoints.sftp()22                .server()23                .port(2222)24                .autoStart(true)25                .build();26    }27}28        <create-directory path="${remoteDir}"/>29        <delete-directory path="${remoteDir}"/>30        <send message="${localFile}" type="FILE">31        SftpClient sftpClient = context.getBean(SftpClient.class);32        sftpClient.createDir("mydir");33        context.close();34    }35}

createDir

Using AI Code Generation

1import org.springframework.context.support.ClassPathXmlApplicationContext;2import org.springframework.context.ApplicationContext;3import com.consol.citrus.ftp.client.SftpClient;4public class 3 {5	public static void main(String[] args) {6		ApplicationContext context = new ClassPathXmlApplicationContext("classpath:3.xml");7		SftpClient sftpClient = (SftpClient) context.getBean("sftpClient");8		sftpClient.createDir("test");9	}10}

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.