]> matita.cs.unibo.it Git - logicplayer.git/blobdiff - server/com/company/guestServer.java
shuffling + libs imported
[logicplayer.git] / server / com / company / guestServer.java
diff --git a/server/com/company/guestServer.java b/server/com/company/guestServer.java
new file mode 100644 (file)
index 0000000..1fb6ce9
--- /dev/null
@@ -0,0 +1,80 @@
+package com.company;
+
+import java.io.*;
+
+import javax.net.ssl.*;
+
+class guestServer implements Runnable
+{
+       private SSLSocket socket;
+       
+       guestServer(SSLSocket client)
+       {
+               socket=client;
+       }
+       
+       public void run()
+       {
+               try
+        {
+
+                       //Reading the message from the client
+                       InputStream is = socket.getInputStream();
+                       InputStreamReader isr = new InputStreamReader(is);
+                       BufferedReader br = new BufferedReader(isr);
+                       String requestMessage = br.readLine();
+                       System.out.println("ho ricevuto: "+requestMessage);
+                       /*System.out.println("Message received from client is "+returnMessage);
+                       dbConnect request=new dbConnect();
+                       String returnQuery=request.dbQuery(returnMessage);
+                       OutputStream os = socket.getOutputStream();
+                       OutputStreamWriter osw = new OutputStreamWriter(os);
+                       BufferedWriter bw = new BufferedWriter(osw);
+                       System.out.println(returnQuery);
+                       bw.write(returnQuery+"\n");
+                       bw.flush();*/
+                       if(requestMessage!=null)
+                       {
+                               dbConnect request = new dbConnect();
+                               String returnQuery;
+                               if (    requestMessage.charAt(0) == '0' ||
+                                               requestMessage.charAt(0) == '1' ||
+                                               requestMessage.charAt(0) == '2' ||
+                                               (requestMessage.charAt(0) == 'a' && requestMessage.charAt(1) == '0')) {
+                                       returnQuery = request.dbQuery(requestMessage);
+                                       OutputStream os = socket.getOutputStream();
+                                       OutputStreamWriter osw = new OutputStreamWriter(os);
+                                       BufferedWriter bw = new BufferedWriter(osw);
+                                       bw.write(returnQuery + "\n");
+                                       bw.flush();
+                                       System.out.println("ho inviato: " + returnQuery);
+                               }
+                               else
+                               {
+                                       returnQuery = request.dbQuery("5/" + requestMessage);
+                                       if (returnQuery.contains("request-login") || returnQuery.contains("request-error"))
+                                       {
+                                               OutputStream os = socket.getOutputStream();
+                                               OutputStreamWriter osw = new OutputStreamWriter(os);
+                                               BufferedWriter bw = new BufferedWriter(osw);
+                                               bw.write(returnQuery + "\n");
+                                               bw.flush();
+                                               System.out.println("ho inviato: " + returnQuery);
+                                       }
+                                       else if (returnQuery.contains("loggato"))
+                                       {
+                                               personalServer nuovaConnessione = new personalServer(socket, requestMessage);
+                                               Thread t = new Thread(nuovaConnessione);
+                                               t.start();
+                                       }
+                               }
+                       }
+
+        }
+        catch (Exception e) 
+        {
+            e.printStackTrace();
+        }
+
+    }
+}