Connect SFTP server using x++

 Connect SFTP server using x++.

For this, we need to create a C# project and we need to write code in C#. After that DLL file, I need to add it as a reference for my D365 project.

We need to download Renci.ssh.Net from the NuGet package.

We can download SSH from the below link:

https://github.com/sshnet/SSH.NET/releases/tag/2020.0.1

or

https://www.dllme.com./dll/files/renci_sshnet

Please follow this blog for Renci. Link

C# Code:

using System;
using System.Collections.Generic;
using System.IO;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using Renci.SshNet;
namespace SFTPConnect
{
    public class sftpConnection
    {
        public SftpClient sftpClient;
 
        public SftpClient OpenSFTPConnection(string host, int port, string username, string password)
        {
            if (this.sftpClient == null)
            {
                this.sftpClient = new Renci.SshNet.SftpClient(host, port, username, password);
				
		--------------or-------------------------
		List<AuthenticationMethod> 	methods = new List<AuthenticationMethod>
		{
		    new PasswordAuthenticationMethod(username, password)
		};

		var connectionInfo = new ConnectionInfo(host, port, username, methods.ToArray());
						
		this.sftpClient = new SftpClient(connectionInfo);
            }
 
            if (!this.sftpClient.IsConnected)
            {
                this.sftpClient.Connect();
            }
 
            return this.sftpClient;
        }
 
        public List<string> GetDirectories(SftpClient _SftpClient, string path)
        {
            return _SftpClient.ListDirectory(path)/*.Where(n => n.IsDirectory)*/.Select(n => n.Name).ToList();
        }
 
        public void MoveFile(SftpClient _SftpClient, string sourcePath, string destinationPath, bool isPosix)
        {
            _SftpClient.RenameFile(sourcePath, destinationPath, isPosix);
        }
 
        public Stream DownloadFile(SftpClient _SftpClient, string sourcePath)
        {
            var memoryStream = new MemoryStream();
 
            _SftpClient.DownloadFile(sourcePath, memoryStream);
 
            memoryStream.Position = 0;
 
            return memoryStream;
        }
	public void upLoadFile(SftpClient _SftpClient, System.IO.Stream _sourceFile, string _fileName)
	{
	    _sourceFile.Position = 0;
	    _SftpClient.BufferSize = 8 * 1024;
	    _SftpClient.UploadFile(_sourceFile, _fileName);
	}
    }
}

X++ Code:

    public void sFTPConnection()
    {	
        str                       	sftpFile;
        ClrObject                 	list = new ClrObject("System.Collections.Generic.List`1[System.String]");
        SFTPConnect.sftpConnection	sftp = new SFTPConnect.sftpConnection();

        using (var sftpConnection = sftp.OpenSFTPConnection(host, port, username, password)) // Connect
        {
            try
            {
                int totalFiles = 0;
				
                sftpConnection.ChangeDirectory('/Upload');//Import Path

                list  = (sftp.GetDirectories(sftpConnection, '/Upload/'));// Files List
				
                ClrObject enumerator = list.getEnumerator();
                 
                while (enumerator.movenext())
                {
                    totalFiles ++;

                    sftpFile = enumerator.get_Current();
 
                    if(sftpFile != ".." && sftpFile !=null && sftpFile != ".")
                    {
		        System.IO.Stream Stream = sftp.DownloadFile(sftpConnection, '/Upload' + '/'+ sftpFile);
						
			this.ReadCSVFile(Stream,sftpFile);

			sftp.MoveFile(sftpConnection, 
					'Import Path'+ '/'+sftpFile, 
					'destination path'+ '/'+ sftpFile,
					false);					                      
                    }
                }
            }
	    catch
	    {
		throw error(infolog.text());
	    }
            finally
            {
                if(sftpConnection.IsConnected)
                    sftpConnection.Disconnect();
            }
        }             
              
    }
    
    public boolean ReadCSVFile(System.IO.Stream  stream, str fileName)
    {
	AsciiStreamIo    file;
	container        record;

	file = AsciiStreamIo::constructForRead(stream);
	if (file)
	{
	  if (file.status())
	  {
                throw error("@SYS52680");
	  }
	  file.inFieldDelimiter(',');
	  file.inRecordDelimiter('\r\n');

	  while (!file.status())
	  {
	        record = file.read();
		recordCount++;

		if (conLen(record) && recordCount !=1)
		{  
		    conPeek(record,2));
		}
	   }
	}
	
	return true;
}