SafeWalkServerTest.jav

 /**
   * Project 5
   * @author Nathan Ohlson, nohlson, labsec
   * @author Jeremy Lehman, jlehman, labsec (can be omitted if working alone)
   */

import java.io.*;
import java.net.*;
import java.util.*;



public class SafeWalkServer extends Thread {

	//sets the scope of these objects to the entire class
	private ServerSocket serverSocket;
	private ArrayList<String> names;
	private ArrayList<String> from;
	private ArrayList<String> to;
	private ArrayList<Integer> type;
	private ArrayList<Integer> options;
	private ArrayList<DataOutputStream> userID;
	private int[] pair;
	private Socket serv;
	private ArrayList<Socket> sockets;
	

	/*public SafeWalkServer(int port) constructor takes an int arguement
	for the port number to bind the server to.
	*/
	public SafeWalkServer(int port) throws SocketException, IOException {
		//sets up the array lists for the pending entries in the server
		names = new ArrayList<String>();
		from = new ArrayList<String>();
		to = new ArrayList<String>();
		type = new ArrayList<Integer>();
		options = new ArrayList<Integer>();
		userID = new ArrayList<DataOutputStream>();
		sockets = new ArrayList<Socket>();
		
		serverSocket = new ServerSocket(port); //creates a new ServerSocket object at port port
		System.out.println("Server is bound to port " + port);
		serverSocket.setReuseAddress(true);
		serverSocket.setSoTimeout(30000);
	}

	public SafeWalkServer() throws SocketException, IOException {
		//sets up the array lists for the pending entries in the server
		names = new ArrayList<String>();
		from = new ArrayList<String>();
		to = new ArrayList<String>();
		type = new ArrayList<Integer>();
		options = new ArrayList<Integer>();
		userID = new ArrayList<DataOutputStream>();
		sockets = new ArrayList<Socket>();

		int range = (65535 - 1025) + 1;     
		int port = (int)(Math.random() * range) + 1025;
		
		serverSocket = new ServerSocket(port); //creates a new ServerSocket object at port port
		System.out.println("Server is bound to port " + port);
		serverSocket.setReuseAddress(true);
		serverSocket.setSoTimeout(30000);
	}

	public int getLocalPort() {
		return serverSocket.getLocalPort();
	}

	/* Public void analyzeRequests runs through all of the current requests
	and matches them to people leaving the same place and are either going
	to the same place or going to * location. it returns an int[] that has two fields
	that are two int that are the indexes that match. analyze Requests will return the 
	first match and only the first match.
	*/

	public int[] analyzeRequests() {
		String holderFrom = "";
		String holderTo = "";
		int [] holder = new int[2];
		holder[0] = 0;
		holder[1] = 0;

		/*iterate through the requests already in the server database
		and first checks to see if another request is departing the
		same location
		*/
		for (int i = 0; i < from.size(); i++) {
			options.clear();
			holderFrom = from.get(i);
			holderTo = to.get(i);
			for (int j = 0; j < from.size(); j++) {
				if (j != i) {
					if (from.get(j).equals(holderFrom)) {
						options.add(j);
					}
				}
			}
			/* After finding matches for requests with similar 
			departing location, analyzeRequests
			will test the requests for requests that match arrival location
			or * location.
			*/
			if (options.size() >= 1) {
				for (int m = 0; m < options.size(); m++) {
					if (to.get(options.get(m)).equals(holderTo) || to.get(options.get(m)).equals("*")) {
						holder[0] = options.get(m);               //sets the first field to first sampled index
						holder[1] = i;              //sets the second field to first match found
						
						return holder;
					}
				}
			}

			
		}
		return holder;
	}

	public void run() {
		while (true) {
			try {
				//set up new server with serverSocket.accept()
				int[] match = new int[2];
				String request = "";
				System.out.println("Waiting for client...");
				serv = serverSocket.accept();
				sockets.add(serv);
				

				System.out.println("Connected to " + serv.getRemoteSocketAddress());

				/*takes the input and output stream of the serv and creates a 
				buffered reader and a data output stream to manage the input
				and output of the serv
				*/
				BufferedReader in =
		          new BufferedReader(new InputStreamReader(serv.getInputStream()));
	            DataOutputStream out =
                 new DataOutputStream(serv.getOutputStream());

                //new server has been created
                out.writeUTF("Welcome to the SafeWalkServer");
                try {
	            	request = in.readLine(); //takes the request
	            	String[] parts = request.split(", "); //splits the request into parts
	            	String nothing = parts[2];
	            	names.add(parts[0]); //the first entry in the request is name
	            	from.add(parts[1]); //the second entry in the request is from
	            	to.add(parts[2]); //the third entry in the request is destination
	            	type.add(Integer.parseInt(parts[3])); //the fourth entry in the request is priority
	            	userID.add(out);
	            	match = analyzeRequests();
	            	if (match[0] != 0 || match[1] != 0) {
	            		System.out.println("Match found");
	            		System.out.println(match[0]);
	            		System.out.println(match[1]);
	            		userID.get(match[0]).writeUTF("RESPONSE: " + names.get(match[1]) + ", " + from.get(match[1]) + ", " +  to.get(match[1]) + "\n");
	            		userID.get(match[1]).writeUTF("RESPONSE: " + names.get(match[0]) + ", " +  from.get(match[0]) + ", " +  to.get(match[0]) + "\n");

	        
	            		names.remove(match[0]);
	            		from.remove(match[0]);
	            		to.remove(match[0]);
	            		type.remove(match[0]);
	            		userID.remove(match[0]);
	            		sockets.remove(match[0]);

	            		names.remove(match[1]);
	            		from.remove(match[1]);
	            		to.remove(match[1]);
	            		type.remove(match[1]);
	            		userID.remove(match[1]);
	            		sockets.remove(match[1]);




	            	}

	            } catch (IndexOutOfBoundsException ie) { //assuming the request is actually a server command
	            	if (request.charAt(0) == ':') {
					    if ( request.equals(":LIST_PENDING_REQUESTS")) {
					    	System.out.println("Here");
							if (names.get(0) == null) {
							    out.writeUTF("");
							    out.flush();
							} else {
								for(int i = 0; i < names.size(); i ++) {
								    out.writeUTF(names.get(i) + ", " + from.get(i) + ", " + to.get(i) + ", " + Integer.toString(type.get(i))+"\n");
								    out.flush();
								}
						    }
						}
						

						else if (request.equals(":SHUTDOWN")) {
						    for( int i = 0; i < sockets.size(); i++) {
								userID.get(i).writeUTF("ERROR: connection shutdown");
								userID.get(i).flush();
								sockets.get(i).close();
						    }
						    break;
						}
						else if (request.equals(":RESET")) {
						    for ( int i = 0; i < sockets.size() - 1; i++) {
						    	System.out.println("HEre");
								userID.get(i).writeUTF("ERROR: connection reset");
								userID.get(i).flush();
								sockets.get(i).close();
						    }
						    userID.get(sockets.size()).writeUTF("RESPONSE: success");
						    userID.get(sockets.size()).flush();
						    sockets.get(sockets.size()).close();
						    sockets.clear();
						    names.clear();
						    from.clear();
						    to.clear();
						    userID.clear();
						} else {
							userID.get(sockets.size()).writeUTF("ERROR: invalid request");
						}
					}      
				}
				

			} catch (SocketTimeoutException ste) {
				System.out.println("The socket timed out."); 
				break;
			} catch (IOException ioe) {
				ioe.printStackTrace();
				break;
			}
		}
	}

	public static void main(String[] args) {
		int portNum;
		Thread t;
		try {
		if (args.length >= 1) {
			portNum = Integer.parseInt(args[0]);
			t = new SafeWalkServer(portNum);
		} else {
			t = new SafeWalkServer();
		}
			t.start();
		} catch (Exception se) {
			se.printStackTrace();
		}
	}
}