#region Namespaces
using System;
using System.Data;
using Microsoft.SqlServer.Dts.Runtime;
using System.Windows.Forms;
using WinSCP;
using System.Collections.Generic;
#endregion
 
namespace ST_331963c4d11c478fb003abcd00418809
{
    [Microsoft.SqlServer.Dts.Tasks.ScriptTask.SSISScriptTaskEntryPointAttribute]
    public partial class ScriptMain : Microsoft.SqlServer.Dts.Tasks.ScriptTask.VSTARTScriptObjectModelBase
    {
        static ScriptMain() // code responsible for GAC
        {
            AppDomain.CurrentDomain.AssemblyResolve += new ResolveEventHandler(CurrentDomain_AssemblyResolve);
        }
        static System.Reflection.Assembly CurrentDomain_AssemblyResolve(object sender, ResolveEventArgs args)
        {
            if (args.Name.Contains("WinSCPnet"))
            { 
                string path = @"\\server\WinSCP\";
                return System.Reflection.Assembly.LoadFile(System.IO.Path.Combine(path, "WinSCPnet.dll"));
            }
 
            return null;
        }
        public void Main()
        {
            try
            {
                SessionOptions sessionOptions = new SessionOptions
                {
                    Protocol = Protocol.Sftp,
                    HostName = "hostnem",
                    UserName = "username",
                    Password = "password",
                    SshHostKeyFingerprint = "fingerprint",
                };
 
                sessionOptions.AddRawSettings("ProxyMethod", "2");
                sessionOptions.AddRawSettings("ProxyHost", "someproxy");
                sessionOptions.AddRawSettings("ProxyPort", "someport");
                sessionOptions.AddRawSettings("ProxyUsername", "someusername");
                sessionOptions.AddRawSettings("ProxyPassword", "Somepw");
          
                using (Session session = new Session())
                {
                    session.Open(sessionOptions);
 
                    TransferOptions transferOptions = new TransferOptions();
                    transferOptions.TransferMode = TransferMode.Binary;
 
                    TransferOperationResult transferResult = session.GetFiles(
                        "/*.csv", @"\\server\folder\", false, transferOptions);
 
                    transferResult.Check();
 
                    bool fireAgain = false;
                    foreach (TransferEventArgs transfer in transferResult.Transfers)
                    {
                        Dts.Events.FireInformation(0, null,
                            string.Format("Upload of {0} succeeded", transfer.FileName),
                            null, 0, ref fireAgain);
 
                        session.MoveFile(transfer.FileName, "/Archive/*");
                    }
                }
 
                Dts.TaskResult = (int)DTSE xecResult.Success;
            }
            catch (Exception e)
            {
                Variables exceptionVariable = null;
                Dts.VariableDispenser.LockOneForWrite("User::problemvar", ref exceptionVariable);
 
                exceptionVariable["User::problemvar"].Value = e.Message;
                exceptionVariable.Unlock();
 
                Dts.Events.FireError(0, null,
                    string.Format("Error when using WinSCP to upload files: {0}", e),
                    null, 0);
 
                Dts.TaskResult = (int)DTS ExecResult.Failure;
            }
        }
    }
}