Merge branch 'main' of https://git.ngb.schule/Tim/wordle

src/Game.java

@@ -1,20 +1,65 @@
 public class Game {
-    // Instanzvariablen - ersetzen Sie das folgende Beispiel mit Ihren Variablen
-    WordleServer wordleServer;
-    User user;
-    DatabaseConnector databaseConnector;// Datenbankverbindung aufstellen
-    private String wordle;
-    private String[] words;
-    private int count;
-    
-    public Game(WordleServer wordleServer) {
-        
-        this.wordleServer = wordleServer;
-        
-        user = new User();
-    }
-    
-    public void processMessage(String msg) {
-        System.out.println(msg);
-    }
+	// Instanzvariablen - ersetzen Sie das folgende Beispiel mit Ihren Variablen
+	WordleServer wordleServer;
+	User user;
+	static DatabaseConnector databaseConnector;// Datenbankverbindung aufstellen
+	
+	private String ip;
+	private int port;
+	
+	private String wordle;
+	private String[] words;
+	private int count;
+	private int phase;
+	
+	public Game(WordleServer wordleServer, String pClientIP, int pClientPort) {
+		
+		this.wordleServer = wordleServer;
+		this.ip = pClientIP;
+		this.port = pClientPort;
+		
+		user = new User();
+		
+		send("+OK Hello there");
+	}
+	
+	public void processMessage(String msg) {
+		
+		if (msg.equals("quit")) {
+			send("+OK bye");
+			wordleServer.closeConnection(ip, port);
+		}
+		
+		switch (phase) {
+		case 0:
+			
+			break;
+		case 1:
+			
+			break;
+		case 2:
+			
+			break;
+		}
+	}
+	
+	private void send(String msg) {
+		wordleServer.send(ip, port, msg);
+	}
+	
+	public String getIp() {
+		return ip;
+	}
+
+	public void setIp(String ip) {
+		this.ip = ip;
+	}
+
+	public int getPort() {
+		return port;
+	}
+
+	public void setPort(int port) {
+		this.port = port;
+	}
 }

src/WordleServer.java

@@ -29,18 +29,28 @@ public class WordleServer extends Server {
 
     @Override
     public void processNewConnection( String pClientIP, int pClientPort ) {
-        games.append(new Game(this));
+        games.append(new Game(this, pClientIP, pClientPort));
     }
 
     @Override
     public void processClosingConnection( String pClientIP, int pClientPort ) {
-        System.out.println("Closed connection: " + pClientPort);
+    	find(pClientIP, pClientPort);
+    	games.remove();
     }
 
     @Override
     public void processMessage( String pClientIP, int pClientPort, String pMessage ) {
-        games.toFirst();
-        games.getContent().processMessage(pMessage);
+        find(pClientIP, pClientPort).processMessage(pMessage);
     }
 
+    private Game find(String ip, int port) {
+    	games.toFirst();
+    	while (games.hasAccess()) {
+    		Game g = games.getContent();
+    		if (g.getIp().equals(ip) && g.getPort() == port) {
+    			return g;
+    		}
+    	}
+    	return null;
+    }
 }