// Carlos Alberto Cortez <calberto.cortez@gmail.com>
// Gonzalo Paniagua Javier <gonzalo@novell.com>
//
-// Copyright (c) 2006 Novell, Inc. (http://www.novell.com)
+// Copyright (c) 2006,2007,2008 Novell, Inc. (http://www.novell.com)
//
-#if NET_2_0
using NUnit.Framework;
using System;
+using System.Collections.Generic;
using System.IO;
using System.Net;
using System.Net.Sockets;
{
FtpWebRequest defaultRequest;
+ private string _tempDirectory;
+ private string _tempFile;
+
+ [SetUp]
+ public void SetUp ()
+ {
+ _tempDirectory = Path.Combine (Path.GetTempPath (), "MonoTests.System.Net.FileWebRequestTest");
+ _tempFile = Path.Combine (_tempDirectory, "FtpWebRequestTest.tmp");
+ if (!Directory.Exists (_tempDirectory)) {
+ Directory.CreateDirectory (_tempDirectory);
+ } else {
+ // ensure no files are left over from previous runs
+ string [] files = Directory.GetFiles (_tempDirectory, "*");
+ foreach (string file in files)
+ File.Delete (file);
+ }
+ }
+
+ [TearDown]
+ public void TearDown ()
+ {
+ if (Directory.Exists (_tempDirectory))
+ Directory.Delete (_tempDirectory, true);
+ }
+
[TestFixtureSetUp]
public void Init ()
{
string uri = String.Format ("ftp://{0}:{1}/uploads/file.txt", sp.IPAddress, sp.Port);
try {
FtpWebRequest ftp = (FtpWebRequest) WebRequest.Create (uri);
+ ftp.KeepAlive = false;
ftp.Timeout = 5000;
ftp.Method = WebRequestMethods.Ftp.UploadFile;
- ftp.ContentLength = 1;
+ ftp.ContentLength = 10;
ftp.UseBinary = true;
Stream stream = ftp.GetRequestStream ();
- stream.WriteByte (0);
+ for (int i = 0; i < 10; i++)
+ stream.WriteByte ((byte)i);
stream.Close ();
FtpWebResponse response = (FtpWebResponse) ftp.GetResponse ();
- Assert.IsTrue ((int) response.StatusCode >= 200 && (int) response.StatusCode < 300, "#01");
+ Assert.IsTrue ((int) response.StatusCode >= 200 && (int) response.StatusCode < 300, "UP#01");
+ Assert.AreEqual (10, sp.result.Count, "UP#02");
+ response.Close ();
+ } catch (Exception) {
+ if (!String.IsNullOrEmpty (sp.Where))
+ throw new Exception (sp.Where);
+ throw;
+ } finally {
+ sp.Stop ();
+ }
+ }
+
+ [Test]
+ public void UploadFile_WebClient ()
+ {
+ ServerPut sp = new ServerPut ();
+ File.WriteAllText (_tempFile, "0123456789");
+ sp.Start ();
+
+ using (WebClient m_WebClient = new WebClient())
+ {
+ string uri = String.Format ("ftp://{0}:{1}/uploads/file.txt", sp.IPAddress, sp.Port);
+
+ m_WebClient.UploadFile(uri, _tempFile);
+ }
+ Assert.AreEqual (10, sp.result.Count, "WebClient/Ftp#01");
+
+ sp.Stop ();
+ }
+
+ [Test]
+ public void DownloadFile1 ()
+ {
+ DownloadFile (new ServerDownload ());
+ }
+
+ void DownloadFile (ServerDownload sp)
+ {
+ sp.Start ();
+ string uri = String.Format ("ftp://{0}:{1}/file.txt", sp.IPAddress, sp.Port);
+ try {
+ FtpWebRequest ftp = (FtpWebRequest) WebRequest.Create (uri);
+ ftp.KeepAlive = false;
+ ftp.Timeout = 5000;
+ ftp.Method = WebRequestMethods.Ftp.DownloadFile;
+ ftp.UseBinary = true;
+ FtpWebResponse response = (FtpWebResponse) ftp.GetResponse ();
+ Assert.IsTrue ((int) response.StatusCode >= 100 && (int) response.StatusCode < 200, "DL#01");
+ using (Stream st = response.GetResponseStream ()) {
+ }
+ // This should be "220 Bye" or similar (no KeepAlive)
+ Assert.IsTrue ((int) response.StatusCode >= 200 && (int) response.StatusCode < 300, "DL#02");
+ response.Close ();
+ } catch (Exception) {
+ if (!String.IsNullOrEmpty (sp.Where))
+ throw new Exception (sp.Where);
+ throw;
+ } finally {
+ sp.Stop ();
+ }
+ }
+
+ [Test]
+ public void DownloadFile2 ()
+ {
+ // Some embedded FTP servers in Industrial Automation Hardware report
+ // the PWD using backslashes, but allow forward slashes for CWD.
+ DownloadFile (new ServerDownload (@"\Users\someuser", "/Users/someuser/"));
+ }
+
+ [Test]
+ public void DeleteFile1 ()
+ {
+ ServerDeleteFile sp = new ServerDeleteFile ();
+ sp.Start ();
+ string uri = String.Format ("ftp://{0}:{1}/file.txt", sp.IPAddress, sp.Port);
+ try {
+ FtpWebRequest ftp = (FtpWebRequest) WebRequest.Create (uri);
+ Console.WriteLine (ftp.RequestUri);
+ ftp.KeepAlive = false;
+ ftp.Timeout = 5000;
+ ftp.Method = WebRequestMethods.Ftp.DeleteFile;
+ ftp.UseBinary = true;
+ FtpWebResponse response = (FtpWebResponse) ftp.GetResponse ();
+ Assert.IsTrue ((int) response.StatusCode >= 200 && (int) response.StatusCode < 300, "DF#01");
+ response.Close ();
} catch (Exception e) {
- throw new Exception (sp.Where);
+ Console.WriteLine (e);
+ if (!String.IsNullOrEmpty (sp.Where))
+ throw new Exception (sp.Where);
+ throw;
} finally {
sp.Stop ();
}
}
- class ServerPut : FtpServer {
- public string Where = "";
+ [Test]
+ public void ListDirectory1 ()
+ {
+ ServerListDirectory sp = new ServerListDirectory ();
+ sp.Start ();
+ string uri = String.Format ("ftp://{0}:{1}/somedir/", sp.IPAddress, sp.Port);
+ try {
+ FtpWebRequest ftp = (FtpWebRequest) WebRequest.Create (uri);
+ Console.WriteLine (ftp.RequestUri);
+ ftp.KeepAlive = false;
+ ftp.Timeout = 5000;
+ ftp.Method = WebRequestMethods.Ftp.ListDirectoryDetails;
+ ftp.UseBinary = true;
+ using (FtpWebResponse response = (FtpWebResponse) ftp.GetResponse ()) {
+ StreamReader reader = new StreamReader (response.GetResponseStream ());
+ string result = reader.ReadToEnd ();
+ Assert.IsTrue ((int) response.StatusCode >= 200 && (int) response.StatusCode < 300, "DF#01");
+ }
+ } catch (Exception e) {
+ Console.WriteLine (e);
+ if (!String.IsNullOrEmpty (sp.Where))
+ throw new Exception (sp.Where);
+ throw;
+ } finally {
+ sp.Stop ();
+ }
+ }
+ class ServerListDirectory : FtpServer {
protected override void Run ()
{
Socket client = control.Accept ();
NetworkStream ns = new NetworkStream (client, false);
StreamWriter writer = new StreamWriter (ns, Encoding.ASCII);
- writer.WriteLine ("220 Welcome to the jungle");
- writer.Flush ();
- StreamReader reader = new StreamReader (ns, Encoding.ASCII);
+ StreamReader reader = new StreamReader (ns, Encoding.UTF8);
+ if (!DoAnonymousLogin (writer, reader)) {
+ client.Close ();
+ return;
+ }
+
+ if (!DoInitialDialog (writer, reader, "/home/someuser", "/home/someuser/somedir/")) {
+ client.Close ();
+ return;
+ }
+
string str = reader.ReadLine ();
- if (!str.StartsWith ("USER ")) {
- Where = "USER";
+ if (str != "PASV") {
+ Where = "PASV";
client.Close ();
return;
}
- writer.WriteLine ("331 Say 'Mellon'");
+
+ IPEndPoint end_data = (IPEndPoint) data.LocalEndPoint;
+ byte [] addr_bytes = end_data.Address.GetAddressBytes ();
+ byte [] port = new byte [2];
+ port[0] = (byte) ((end_data.Port >> 8) & 255);
+ port[1] = (byte) (end_data.Port & 255);
+ StringBuilder sb = new StringBuilder ("227 Passive (");
+ foreach (byte b in addr_bytes) {
+ sb.AppendFormat ("{0},", b);
+ }
+ sb.AppendFormat ("{0},", port [0]);
+ sb.AppendFormat ("{0})", port [1]);
+ writer.WriteLine (sb.ToString ());
writer.Flush ();
+
str = reader.ReadLine ();
- if (!str.StartsWith ("PASS ")) {
- Where = "PASS";
+ if (str != "LIST") {
+ Where = "LIST - '" + str + "'";
client.Close ();
return;
}
- writer.WriteLine ("230 Logged in");
+ writer.WriteLine ("150 Here comes the directory listing");
writer.Flush ();
- str = reader.ReadLine ();
- if (!str.StartsWith ("PWD")) {
- Where = "PWD";
+
+ Socket data_cnc = data.Accept ();
+ byte [] dontcare = Encoding.ASCII.GetBytes ("drwxr-xr-x 2 ftp ftp 4096 Oct 27 20:17 tests");
+ data_cnc.Send (dontcare, 1, SocketFlags.None);
+ data_cnc.Close ();
+ writer.WriteLine ("226 Directory send Ok");
+ writer.Flush ();
+ if (!EndConversation (writer, reader)) {
client.Close ();
return;
}
- writer.WriteLine ("257 \"/home/someuser\"");
+ client.Close ();
+ }
+ }
+
+ class ServerDeleteFile : FtpServer {
+ protected override void Run ()
+ {
+ Socket client = control.Accept ();
+ NetworkStream ns = new NetworkStream (client, false);
+ StreamWriter writer = new StreamWriter (ns, Encoding.ASCII);
+ StreamReader reader = new StreamReader (ns, Encoding.UTF8);
+ if (!DoAnonymousLogin (writer, reader)) {
+ client.Close ();
+ return;
+ }
+
+ if (!DoInitialDialog (writer, reader, "/home/someuser", "/home/someuser/")) {
+ client.Close ();
+ return;
+ }
+
+ string str = reader.ReadLine ();
+ if (str.Trim () != "DELE file.txt") {
+ Where = "DELE - " + str;
+ client.Close ();
+ return;
+ }
+ writer.WriteLine ("250 Delete operation successful");
writer.Flush ();
- str = reader.ReadLine ();
- if (str != ("CWD /home/someuser/uploads/")) {
- Where = "CWD - " + str;
+ if (!EndConversation (writer, reader)) {
client.Close ();
return;
}
- writer.WriteLine ("250 Directory changed");
+ client.Close ();
+ }
+ }
+
+ class ServerDownload : FtpServer {
+
+ string Pwd, Cwd;
+
+ public ServerDownload ()
+ : this (null, null)
+ {
+ }
+
+ public ServerDownload (string pwd, string cwd)
+ {
+ Pwd = pwd ?? "/home/someuser";
+ Cwd = cwd ?? "/home/someuser/";
+ }
+
+ protected override void Run ()
+ {
+ Socket client = control.Accept ();
+ NetworkStream ns = new NetworkStream (client, false);
+ StreamWriter writer = new StreamWriter (ns, Encoding.ASCII);
+ StreamReader reader = new StreamReader (ns, Encoding.UTF8);
+ if (!DoAnonymousLogin (writer, reader)) {
+ client.Close ();
+ return;
+ }
+
+ if (!DoInitialDialog (writer, reader, Pwd, Cwd)) {
+ client.Close ();
+ return;
+ }
+
+ string str = reader.ReadLine ();
+ if (str != "PASV") {
+ Where = "PASV";
+ client.Close ();
+ return;
+ }
+
+ IPEndPoint end_data = (IPEndPoint) data.LocalEndPoint;
+ byte [] addr_bytes = end_data.Address.GetAddressBytes ();
+ byte [] port = new byte [2];
+ port[0] = (byte) ((end_data.Port >> 8) & 255);
+ port[1] = (byte) (end_data.Port & 255);
+ StringBuilder sb = new StringBuilder ("227 Passive (");
+ foreach (byte b in addr_bytes) {
+ sb.AppendFormat ("{0},", b);
+ }
+ sb.AppendFormat ("{0},", port [0]);
+ sb.AppendFormat ("{0})", port [1]);
+ writer.WriteLine (sb.ToString ());
writer.Flush ();
+
str = reader.ReadLine ();
- if (str != ("TYPE I")) {
- Where = "TYPE - " + str;
+ if (str != "RETR file.txt") {
+ Where = "RETR - " + str;
client.Close ();
return;
}
- writer.WriteLine ("200 Switching to binary mode");
+ writer.WriteLine ("150 Opening BINARY mode data connection for blah (n bytes)");
writer.Flush ();
- str = reader.ReadLine ();
+
+ Socket data_cnc = data.Accept ();
+ byte [] dontcare = new byte [1];
+ data_cnc.Receive (dontcare, 1, SocketFlags.None);
+ data_cnc.Close ();
+ writer.WriteLine ("226 File send Ok");
+ writer.Flush ();
+ if (!EndConversation (writer, reader)) {
+ client.Close ();
+ return;
+ }
+ client.Close ();
+ }
+ }
+
+ class ServerPut : FtpServer {
+ public List<byte> result = new List<byte> ();
+
+ protected override void Run ()
+ {
+ Socket client = control.Accept ();
+ NetworkStream ns = new NetworkStream (client, false);
+ StreamWriter writer = new StreamWriter (ns, Encoding.ASCII);
+ StreamReader reader = new StreamReader (ns, Encoding.UTF8);
+ if (!DoAnonymousLogin (writer, reader)) {
+ client.Close ();
+ return;
+ }
+
+ if (!DoInitialDialog (writer, reader, "/home/someuser", "/home/someuser/uploads/")) {
+ client.Close ();
+ return;
+ }
+
+ string str = reader.ReadLine ();
if (str != "PASV") {
Where = "PASV";
client.Close ();
writer.Flush ();
Socket data_cnc = data.Accept ();
- byte [] dontcare = new byte [1];
- data_cnc.Receive (dontcare, 1, SocketFlags.None);
+ var datastr = new NetworkStream (data_cnc, false);
+ int ch;
+ while ((ch = datastr.ReadByte ()) != -1){
+ result.Add ((byte)ch);
+
+ }
data_cnc.Close ();
writer.WriteLine ("226 File received Ok");
writer.Flush ();
- str = reader.ReadLine ();
- if (str != "QUIT") {
- Where = "QUIT";
+ if (!EndConversation (writer, reader)) {
client.Close ();
return;
}
- writer.WriteLine ("220 Bye");
- writer.Flush ();
- Thread.Sleep (250);
client.Close ();
}
}
- abstract class FtpServer
- {
+ abstract class FtpServer {
protected Socket control;
protected Socket data;
- protected Exception error;
protected ManualResetEvent evt;
+ public string Where = "";
public FtpServer ()
{
data.Close ();
control.Close ();
}
+
+ // PWD, CWD and TYPE I (type could be moved out of here)
+ protected bool DoInitialDialog (StreamWriter writer, StreamReader reader, string pwd, string cwd)
+ {
+ string str = reader.ReadLine ();
+ if (!str.StartsWith ("OPTS utf8 on")) {
+ Where = "OPTS utf8 - " + str;
+ return false;
+ }
+ writer.WriteLine ("200 Always in UTF8 mode"); // vsftpd
+ writer.Flush ();
+ str = reader.ReadLine ();
+ if (!str.StartsWith ("PWD")) {
+ Where = "PWD - " + str;
+ return false;
+ }
+ writer.WriteLine ("257 \"{0}\"", pwd);
+ writer.Flush ();
+ str = reader.ReadLine ();
+ if (str != ("CWD " + cwd)) {
+ Where = "CWD - " + str;
+ return false;
+ }
+ writer.WriteLine ("250 Directory changed");
+ writer.Flush ();
+ str = reader.ReadLine ();
+ if (str != ("TYPE I")) {
+ Where = "TYPE - " + str;
+ return false;
+ }
+ writer.WriteLine ("200 Switching to binary mode");
+ writer.Flush ();
+ return true;
+ }
+
+ protected bool EndConversation (StreamWriter writer, StreamReader reader)
+ {
+ string str = reader.ReadLine ();
+ if (str != "QUIT") {
+ Where = "QUIT";
+ return false;
+ }
+ writer.WriteLine ("220 Bye");
+ writer.Flush ();
+ Thread.Sleep (250);
+ return true;
+ }
+
+ protected bool DoAnonymousLogin (StreamWriter writer, StreamReader reader)
+ {
+ writer.WriteLine ("220 Welcome to the jungle");
+ writer.Flush ();
+ string str = reader.ReadLine ();
+ if (!str.StartsWith ("USER ")) {
+ Where = "USER";
+ return false;
+ }
+ writer.WriteLine ("331 Say 'Mellon'");
+ writer.Flush ();
+ str = reader.ReadLine ();
+ if (!str.StartsWith ("PASS ")) {
+ Where = "PASS";
+ return false;
+ }
+ writer.WriteLine ("230 Logged in");
+ writer.Flush ();
+ return true;
+ }
public IPAddress IPAddress {
get { return ((IPEndPoint) control.LocalEndPoint).Address; }
get { return ((IPEndPoint) control.LocalEndPoint).Port; }
}
- public Exception Error {
- get { return error; }
- }
-
protected abstract void Run ();
}
-
}
}
-#endif