rt

servertask.java (6936B)

---

 package space.nocebo;
 
 import java.io.*;
 import java.net.*;
 import java.lang.Math;
 import java.util.concurrent.locks.*;
 
 public class servertask implements Runnable {
 	private Socket connection;
 	private acc player;
 	private group pgroup;
 	private script pscript;
 	private int loggedin = 0; // status var
 	private static String[][] chars = new String[3][2];
 	private static int roundAvg = 0;
 	private String lastMsg = "";
 	private String mainMenu = "";
 	private	Lock lock = new ReentrantLock();
 	private game pgame;
 
 	private void printfdbg(String m) {
 		String dbg = "dbg " + player.getUname() + " " + m;
 		System.out.println(dbg);
 	}
 
 	private int login(String m) {
 		String[] inp = m.split(" ", 2);
 		for (acc c : server.Accounts)
 			if (((inp[0].compareTo(c.getUname())) == 0) &&
 			    ((inp[1].compareTo(c.getPass())) == 0)) {
 				if (c.getOnline() == true)
 					return -1;
 				player = c;
 				player.setOnline();
 				return 1;
 			}
 		return 0;
 	}
 
 	private void register(String m) {
 		String[] inp = m.split(" ", 2);
 		player = new acc(inp[0], inp[1], util.getRandomScore());
 		server.Accounts.add(player);
 	}
 
 	private void notifyClient(DataOutputStream str, String m) {
 		try {
 			str.writeUTF(m + "\n");
 			str.flush();
 		} catch (IOException ex) {
 			System.out.println("Connection error: " + ex);
 			System.exit(1);
 		}
 	}
 
 	private synchronized boolean selChar(DataInputStream inputStr, DataOutputStream outputStr, int timeout) {
 		String message = "";
 		int val = 0;
 		if (timeout == 0) {
 			try {
 				if (inputStr.available() > 0) {
 					message = inputStr.readUTF();
 					if (util.isNumeric(message)) {
 						val = Integer.parseInt(message);
 						if (val < 4 && val > 0) {
 							if (pscript.assignUser(val,player,lock) == true) {
 								return true;
 							}
 							else
 								notifyClient(outputStr,
 									     "Character already assigned\n" +
 									     "Try again");
 						}
 						else if (val == 4) {
 							notifyClient(outputStr,pscript.getAssignedUsers(lock));
 						}
 					} else {
 						notifyClient(outputStr,
 							     "Invalid input\n" +
 							     "Try again\n");
 					}
 				}
 			} catch (IOException ex) {
 				System.out.println("IOException " + ex);
 			}
 		} else if (timeout == 1) {
 			pscript.assignUser(0,player,lock);
 			return true;
 		}
 		return false;
 	}
 
 	private String[][] getChar(group g) {
 		roundAvg = Math.round(g.getAvgscr());
 		for (script s : server.Scripts) {
 			if (roundAvg == s.getDlevel()) {
 				pgame = server.getGame(s,g);
 				pscript = pgame.getScript();
 				return pscript.getRoles();
 			}
 		}
 
 		return chars;
 	}
 
 	private void initGame() {
 		int gf = 0;
 		for (group g : server.Groups) {
 			if (g.add(player) == 1) {
 				pgroup = g;
 				gf = 1;
 				break;
 			}
 		}
 		if (gf == 0) {
 			System.out.println("Group created");
 			server.Groups.add(new group());
 			for (group g : server.Groups) {
 				if (g.add(player) == 1) {
 					pgroup = g;
 					gf = 1;
 					break;
 				}
 			}
 		}
 		while (true) {
 			if (pgroup.getNumMem() == 3) {
 				chars = getChar(pgroup);
 				break;
 			}
 			try {
 				Thread.yield();
 				Thread.sleep(2000);
 			} catch (InterruptedException ex) {
 				System.out.println("InterruptedException " + ex);
 			}
 		}
 	}
 
 	public servertask(Socket s) {
 		connection = s;
 	}
 
 	@Override
 	public void run() {
 		try {
 			DataInputStream inputStr = new DataInputStream(
 				new BufferedInputStream(connection.getInputStream()));
 			DataOutputStream outputStr = new DataOutputStream(
 				new BufferedOutputStream(connection.getOutputStream()));
 
 			mainMenu = "Welcome to RT\nSelect one:\n1 Signup\n2 Login\nq Quit";
 			notifyClient(outputStr,
 					  mainMenu);
 
 			String message = inputStr.readUTF();
 			int val = 0;
 			int lres;
 			while (message.compareTo("q") != 0) { // use 'q' to quit
 				if (util.isNumeric(message) && (val = Integer.parseInt(message)) > 0 && val < 3) {
 					if (val == 1 && loggedin == 0) {
 						outputStr.writeUTF("Enter your username and password" +
 								   " in the format:" +
 								   " username password\n");
 						outputStr.flush();
 						message = inputStr.readUTF();
 						if (util.isValidCred(message)) {
 							register(message);
 							notifyClient(outputStr,
 									  "Registration Successful\n" +
 									  "Please press 2 to login");
 						} else
 							notifyClient(outputStr, "Invalid Input\nTry again\n" + mainMenu);
 					}
 					if (val == 2 && loggedin == 0) {
 						outputStr.writeUTF("Kindly enter your" +
 								   " username and password" +
 								   " in the format: username password\n");
 						outputStr.flush();
 						message = inputStr.readUTF();
 						if (util.isValidCred(message)) {
 							lres = login(message);
 							if (lres == 1) {
 								loggedin = 1;
 								notifyClient(outputStr, "Login Successful\n" +
 									     "Please wait.\n" +
 									     "Initializing game world...\n");
 								initGame();
 								lastMsg = "Please select a character " +
 									"in 60 seconds :"   + "\n" +
 									"1 " +  chars[0][0] + "\n" +
 									"2 " +  chars[1][0] + "\n" +
 									"3 " +  chars[2][0] + "\n" +
 									"4 " +  "View user selection";
 								notifyClient(outputStr, lastMsg);
 								int t = 0;
 								boolean assigned = false;
 								String as;
 								while (t < 120) {
 									t++;
 									if (selChar(inputStr,outputStr,0) == true) {
 										notifyClient(outputStr,
 											     pscript.getAssignedUsers(lock));
 										assigned = true;
 										break;
 									}
 									try {
 										Thread.yield();
 										Thread.sleep(1000);
 									} catch (InterruptedException ex) {
 										System.out.println("InterruptedException " + ex);
 									}
 								}
 								if (assigned == false) {
 									selChar(inputStr,outputStr,1);
 								}
 								as = pscript.getResult(lock,player);
 								notifyClient(outputStr,as);
 								player.setOffline();
 								notifyClient(outputStr,"Game Over.\n" +
 									     "You have been logged out\n" +
 									     "Play again? (Please press 2)");
 							} else if (lres == 0) {
 								System.out.println("dbg lres == 0");
 								notifyClient(outputStr, "Login Failed\n" +
 									     "Please try again\n" +
 									     mainMenu);
 							}
 							else if (lres == -1) {
 								System.out.println("dbg lres = -1");
 								notifyClient(outputStr, "Cheating detected.\n" +
 									     "This incident will be reported.\n" + 
 									     "Please try again\n" +
 									     mainMenu);
 							}
 						} else
 							notifyClient(outputStr, "Invalid format\n" +
 								     "Please try again\n" +
 								     mainMenu);
 					}
 				} else
 					notifyClient(outputStr, "Invalid Input\n" +
 						     "Please try again\n" +
 						     mainMenu);
 				loggedin = 0;
 				message = inputStr.readUTF();
 			}
 			server.Groups.remove(pgroup);
 			inputStr.close();
 			outputStr.close();
 			connection.close();
 		} catch (IOException ex) {
 			System.out.println("Couldn't establish connection: " + ex);
 		}
 	}
 }