1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94
| while(socketLocal.isConnected()){
try {
message=fluxEntree.readLine();
if (message!=null) {
if (message.equals("SERVER_PASSWORD")) {
client.setAvancement(20 ,"Set server password",1);
log.info("Server ask for id");
fluxSortie.println(PropertiesManager.getExpansionKey("server_pwd"));
}
if (message.equals("WRONG_SERVER_PASSWORD")) {
client.setAvancement(10 ,LanguageManager.getAnInternationalizeString("faux_pwd"),1);
log.info("The server password is wrong");
client.setClientDisable();
}
if (message.equals("WRONG_CLIENT_VERSION")) {
client.setAvancement(20 ,"Your client version is not supported",1);
log.info("The client version is not supported");
client.setClientDisable();
}
if (message.equals("CLIENT_VERSION")) {
client.setAvancement(20 ,"Set client version",1);
log.info("Server ask for version");
fluxSortie.println("0.1");
}
if (message.equals("PING")) {
log.info("Server ping me");
fluxSortie.println("PONG");
}
if (message.equals("LOGIN")) {
fluxSortie.println(PropertiesManager.getExpansionKey("login")+":"+PropertiesManager.getExpansionKey("login_pwd")+":"+PropertiesManager.getExpansionKey("univer"));
client.setAvancement(0 ,"OK!",1);
client.setAvancement(50 ,"Send login/password",2);
log.info("Server ask for login");
}
if (message.equals("OK")) {
client.setAvancement(50 ,LanguageManager.getAnInternationalizeString("bienvenue"),2);
log.info("ok, waiting for univer...");
}
if (message.equals("WRONG_PASSWORD")) {
client.setAvancement(40 ,LanguageManager.getAnInternationalizeString("faux_pwd"),2);
log.info("The login password is wrong");
client.setClientDisable();
}
if (message.equals("WRONG_UNIVERS")) {
client.setAvancement(40 ,LanguageManager.getAnInternationalizeString("faux_univers"),2);
log.info("The univers is wrong");
client.setClientDisable();
}
if (message.equals("NULL")) {
client.setAvancement(0 ,"Login/password can not be null",2);
log.info("The login/password is null");
client.setClientDisable();
}
if (message.equals("UNIVERS")) {
client.setAvancement(10 ,"Loading Univers...",3);
log.info("Loading Univers...");
//recuperation de l'univers
InputStream is = socketLocal.getInputStream();
client.setAvancement(10 ,"Loading Univers...",3);
ObjectInputStream ois = new ObjectInputStream(is);
//BufferedInputStream fis=new BufferedInputStream(is);
client.setAvancement(10 ,"Loading Univers...",3);
try {
log.info("Univers Object incomming...");
Object temp= ois.readObject();
//Object temp=((ObjectInput) fis).readObject();
client.setAvancement(50 ,"Loading Univers...",3);
client.setClientEnable();
Univers mainUniver=(Univers) temp;
System.out.println(mainUniver.getName());
} catch (ClassNotFoundException e) {
e.printStackTrace();
}
log.info("Reday to play");
client.setClientEnable();
}
message="";
}
} catch (IOException e) {
e.printStackTrace();
log.error("Error between Client and Server");
log.info("Deconnected from server");
client.setClientDisable();
return;
} |