first upload ALPHA STATUS !

Author: BusTaR

bin/application/ApplicationFtpClient.class

@@ -0,0 +1,7 @@
+14.3.2009 - status
+- anonymous login possible 	to any server 
+- passiv mode supported
+- userinterface implements (rfc)
+	- download to application root
+	- list
+	- change directory

bin/debugging/Debug.class

@@ -0,0 +1 @@
+1. time to set

bin/documentation/milestones

@@ -0,0 +1,70 @@
+rfc-modell: http://www.ietf.org/rfc/rfc959.txt
+
+RFC 959                                                     October 1985
+File Transfer Protocol
+
+
+   2.3.  THE FTP MODEL
+
+
+
+                                            -------------
+                                            |/---------\|
+                                            ||   User  ||    --------
+                                            ||Interface|<--->| User |
+                                            |\----^----/|    --------
+                  ----------                |     |     |
+                  |/------\|  FTP Commands  |/----V----\|
+                  ||Server|<---------------->|   User  ||
+                  ||  PI  ||   FTP Replies  ||    PI   ||
+                  |\--^---/|                |\----^----/|
+                  |   |    |                |     |     |
+      --------    |/--V---\|      Data      |/----V----\|    --------
+      | File |<--->|Server|<---------------->|  User   |<--->| File |
+      |System|    || DTP  ||   Connection   ||   DTP   ||    |System|
+      --------    |\------/|                |\---------/|    --------
+                  ----------                -------------
+
+                  Server-FTP                   USER-FTP
+
+      NOTES: 1. The data connection may be used in either direction.
+             2. The data connection need not exist all of the time.
+
+                      Figure 1  Model for FTP Use
+
+ 			PI: The protocol interpreter.  The user and server sides of the
+         		protocol have distinct roles implemented in a user-PI and a
+         		server-PI.
+         		
+         	DTP: The data transfer process establishes and manages the data
+         		 connection.  The DTP can be passive or active.
+         		
+ 			
+
+
+Postel & Reynolds                                               [Page 8]
+
+
+Tobias Letschka: Interpretation and implementation
+
+
+
+                                            -------------
+                                            |/---------\|
+                                            ||   User  ||    --------
+                                            ||Interface|<--->| User |
+                                            |\----^----/|    --------
+                  ----------                |     |     |
+                  |/------\|  FTP Commands  |/----V----\|
+                  ||Server|<---------------->|	 Ftp   ||	
+                  							|| Message ||
+                  ||  PI  ||   FTP Replies  ||  Socket ||
+                  |\--^---/|                |\----^----/|
+                  |   |    |                |     |     |
+      --------    |/--V---\|      Data      |/----V----\|    --------
+      | File |<--->|Server|<---------------->| FtpData |<--->| File |
+      |System|    || DTP  ||   Connection   ||  Socket ||    |System|
+      --------    |\------/|                |\---------/|    --------
+                  ----------                -------------
+
+                  Server-FTP                   USER-FTP

bin/documentation/roadmap

@@ -0,0 +1,36 @@
+package application;
+
+import inputAndOutput.FtpServerAnswerMessages;
+import ftpClient.AnonymousSession;
+import ftpClient.UserPasswordSession;
+
+public class ApplicationFtpClient {
+
+
+	static UserPasswordSession userpass = new UserPasswordSession();
+	static Thread userpassThread = new Thread(userpass);
+	
+	public static FtpServerAnswerMessages ftpAnswere = new FtpServerAnswerMessages();
+	public static Thread ftpAnswereThread = new Thread(ftpAnswere);
+	
+
+	
+
+	public static void main(String[] args) {
+
+		
+		userpassThread.start();
+	
+	//	client.killClientThread(false);
+
+		//	ftpClientThread.join();    // auf ende warten
+
+    	
+	}
+	void testForServerWithAnonyoumsAccount() {
+		 AnonymousSession anonymous = new AnonymousSession();  // get Socket 						
+		 Thread anonymousThread = new Thread(anonymous);  // establish a server connection
+		//anonymousThread.start(); 	// start Thread
+	}
+
+}

bin/fileSystem/CreateFile.class

@@ -0,0 +1,17 @@
+/** 
+ * Variables to set Debugging-Mode into Application 
+ */
+package debugging;
+
+/**
+ * @author iron
+ *
+ */
+
+
+public final class Debug {
+	
+	// if it true all debugging routines will be announced
+	public static final boolean global = false;
+
+}

bin/fileSystem/DeleteFile.class

@@ -0,0 +1,7 @@
+14.3.2009 - status
+- anonymous login possible 	to any server 
+- passiv mode supported
+- userinterface implements (rfc)
+	- download to application root
+	- list
+	- change directory

bin/ftpClient/AnonymousSession.class

@@ -0,0 +1 @@
+1. time to set

bin/ftpClient/ThreadControll.class

@@ -0,0 +1,5 @@
+package fileSystem;
+
+public class CreateFile {
+
+}

bin/ftpClient/UserPasswordSession.class

@@ -0,0 +1,5 @@
+package fileSystem;
+
+public class DeleteFile {
+
+}

bin/ftpClient/documentation

@@ -0,0 +1,110 @@
+package ftpClient;
+
+import inputAndOutput.FtpDataSocket;
+import inputAndOutput.FtpMessageSocket;
+import inputAndOutput.FtpServerAnswerMessages;
+import inputAndOutput.FtpServerDataMessages;
+
+import java.io.*;
+import java.net.*;
+import java.nio.channels.SocketChannel;
+
+
+
+import rfc.AccessControlCommands;
+import rfc.FtpServiceCommands;
+import rfc.OptionalCommands;
+import rfc.TransferParameterCommands;
+import trash.FG_FtpServer;
+import userInterface.UserInterface;
+
+// FuckingGeniusFtpClient; FGFtpClient
+
+public class AnonymousSession implements Runnable {
+	
+	
+	// Class variable
+	public final static int DEFAULT_DATA_PORT = 20;  // for active mode
+	public final static int DEFAULT_PORT = 21;
+	public final static String DEFAULT_ADDRESS = "ftp2.de.debian.org";
+	public final static String DEFAULT_PATH = "/debian";
+	public final static String DEFAULT_USER = "anonymous";
+	public final static String DEFAULT_PASSWORD = "anonymous@anonymous.de";
+
+	private static FtpServerAnswerMessages messages = new FtpServerAnswerMessages();
+	private static Thread ftpServerMSGThread = new Thread(messages);
+	private static FtpMessageSocket client = new FtpMessageSocket();
+	private static FtpDataSocket data = new FtpDataSocket();
+    private ThreadControll controll = new ThreadControll();  // Semaphore
+    private static boolean threadRunning = true;
+
+    
+    
+    
+
+    
+    // MasterThread 
+    public void run () {
+    	
+    	anonymousSession();
+    	
+    }
+    private static void anonymousSession() {
+
+    	UserInterface userInterface = new UserInterface();
+    	AccessControlCommands access = new AccessControlCommands();
+    	TransferParameterCommands transfer = new TransferParameterCommands();
+    	OptionalCommands optional = new OptionalCommands();
+    	FtpServiceCommands service = new FtpServiceCommands();
+    	client.startMessageSocket(DEFAULT_ADDRESS, DEFAULT_PORT);
+    	//SocketChannel neu = client.startMessageSocket().getChannel();
+    	
+    	access.sendUserName();
+    	inputAndOutput.FtpServerAnswerMessages.readInputStream();
+    	access.sendPassword();
+    	try {
+			Thread.sleep(1000);  // wait for server answere
+		} catch (InterruptedException e1) {
+			// TODO Auto-generated catch block
+			e1.printStackTrace();
+		}
+      	inputAndOutput.FtpServerAnswerMessages.readInputStream();
+      	service.sendSystem();
+    	inputAndOutput.FtpServerAnswerMessages.readInputStream();
+    	FtpServiceCommands.sendFEAT();
+    	try {
+			Thread.sleep(1000);  // wait for server answere
+		} catch (InterruptedException e1) {
+			// TODO Auto-generated catch block
+			e1.printStackTrace();
+		}
+    	inputAndOutput.FtpServerAnswerMessages.readInputStream();
+    	service.sendPrintWorkingdirectory();
+    	inputAndOutput.FtpServerAnswerMessages.readInputStream();
+    	transfer.sendPASV();
+    	inputAndOutput.FtpServerAnswerMessages.readInputStream();
+    	FtpDataSocket data = new FtpDataSocket();
+    	data.startDataSocket(FtpServerAnswerMessages.getRETURN_IP(), 
+    							FtpServerAnswerMessages.getRETURN_PORT());
+    	
+    	service.sendLIST();  // server sends a port
+    	inputAndOutput.FtpServerAnswerMessages.readInputStream();
+    	FtpServerDataMessages dataMsg = new FtpServerDataMessages();
+    	dataMsg.awaitsLISTanswer();
+    	inputAndOutput.FtpServerAnswerMessages.readInputStream();
+    	data.closeDataSocket();
+    	userInterface.Interface();
+    	System.out.println("Client: Closing Connection");
+    	AnonymousSession.killClientThread();
+    	FtpMessageSocket.closeMessageSocket();
+    	
+    }
+ 
+	public static void killClientThread() {  // stopping thread
+		threadRunning = false;
+	} 
+  
+ 
+  
+}
+

bin/inputAndOutput/FtpDataSocket.class

@@ -0,0 +1,44 @@
+package ftpClient;
+
+import java.util.concurrent.Semaphore;
+
+public class ThreadControll {
+
+	
+	private static final int MAX_AVAILABLE_PERMITS = 1;
+	private Semaphore sem1 = new Semaphore(MAX_AVAILABLE_PERMITS);  // default: semaphore = 1 
+	
+	public boolean running()  {
+		
+		// reducing the number of available permits by one
+		try {
+			sem1.acquire();
+		} catch (InterruptedException e) {
+			// TODO Auto-generated catch block
+			e.printStackTrace();
+		} 
+		int counter;
+		if((counter = sem1.availablePermits()) == 0) {
+			return true;
+		}
+		else {
+			return false;
+		}
+	}
+	public boolean waiting() {
+		
+		// increasing Semaphore -> sem1+1
+		sem1.release(1);  
+		 
+		int counter;
+		if((counter = sem1.availablePermits()) != 1) {
+			return true;
+		}
+		else {
+			return false;
+		}
+	}
+	
+
+	
+}

bin/inputAndOutput/FtpMessageSocket.class

@@ -0,0 +1,79 @@
+package ftpClient;
+
+import inputAndOutput.FtpDataSocket;
+import inputAndOutput.FtpMessageSocket;
+import inputAndOutput.FtpServerAnswerMessages;
+import inputAndOutput.FtpServerDataMessages;
+import rfc.AccessControlCommands;
+import rfc.FtpServiceCommands;
+import rfc.OptionalCommands;
+import rfc.TransferParameterCommands;
+import userInterface.UserInterface;
+
+public class UserPasswordSession implements Runnable {
+	private static boolean threadRunning = true;
+	private static FtpMessageSocket message = new FtpMessageSocket();
+
+	@Override
+	public void run() {
+		loginSession("pr0-talk.de",21,"web16","XGT3GEmY");
+		
+		
+	}
+	   private static void loginSession(String address, int port, String username, String password) {
+
+	    	UserInterface userInterface = new UserInterface();
+	    	AccessControlCommands access = new AccessControlCommands();
+	    	TransferParameterCommands transfer = new TransferParameterCommands();
+	    	OptionalCommands optional = new OptionalCommands();
+	    	FtpServiceCommands service = new FtpServiceCommands();
+	    	message.startMessageSocket(address, port);
+	    	
+	    	
+	    	access.sendUserName(username);
+	    	inputAndOutput.FtpServerAnswerMessages.readInputStream();
+	    	access.sendPassword(password);
+	    	try {
+				Thread.sleep(1000);  // wait for server answere
+			} catch (InterruptedException e1) {
+				// TODO Auto-generated catch block
+				e1.printStackTrace();
+			}
+	      	inputAndOutput.FtpServerAnswerMessages.readInputStream();
+	      	service.sendSystem();
+	    	inputAndOutput.FtpServerAnswerMessages.readInputStream();
+	    	FtpServiceCommands.sendFEAT();
+	    	try {
+				Thread.sleep(1000);  // wait for server answere
+			} catch (InterruptedException e1) {
+				// TODO Auto-generated catch block
+				e1.printStackTrace();
+			}
+	    	inputAndOutput.FtpServerAnswerMessages.readInputStream();
+	    	service.sendPrintWorkingdirectory();
+	    	inputAndOutput.FtpServerAnswerMessages.readInputStream();
+	    	transfer.sendPASV();
+	    	inputAndOutput.FtpServerAnswerMessages.readInputStream();
+	    	FtpDataSocket data = new FtpDataSocket();
+	    	data.startDataSocket(FtpServerAnswerMessages.getRETURN_IP(), 
+	    							FtpServerAnswerMessages.getRETURN_PORT());
+	    	
+	    	service.sendLIST();  // server sends a port
+	    	inputAndOutput.FtpServerAnswerMessages.readInputStream();
+	    	FtpServerDataMessages dataMsg = new FtpServerDataMessages();
+	    	dataMsg.awaitsLISTanswer();
+	    	inputAndOutput.FtpServerAnswerMessages.readInputStream();
+	    	data.closeDataSocket();
+	    	userInterface.Interface();
+	    	System.out.println("Client: Closing Connection");
+	    	AnonymousSession.killClientThread();
+	    	FtpMessageSocket.closeMessageSocket();
+	    	killClientThread();
+	    	
+	    }
+		public static void killClientThread() {  // stopping thread
+			threadRunning = false;
+		} 
+	
+
+}