Omocueno ukolko igrac izadje iz aplikacije u toku igre da se igra prekine i drugi korisnik se obavesti o tome.

1 files changed, 42 insertions, 0 deletions

diff --git a/src/main/java/pokemon/Server.java b/src/main/java/pokemon/Server.java
index 77b7fad..09ced57 100644
--- a/src/main/java/pokemon/Server.java
+++ b/src/main/java/pokemon/Server.java
@@ -89,6 +89,46 @@ public class Server implements Runnable {
 		}
 		
 	}
+	private void leftGame(SocketChannel sc)throws Exception {
+		long id=players.get(sc);
+		Game game=null;
+		for(Game tempGame :games) {
+			if(tempGame.player1Id==id || tempGame.player2Id==id) {
+				game=tempGame;
+				break;
+			}
+		}
+		if(game==null)
+			return;
+		long notifyId=-1;
+		if(game.player1Id==id)
+			notifyId=game.player2Id;
+		else if(game.player2Id==id)
+			notifyId=game.player1Id;
+		
+		if(notifyId==-1)
+			return;
+		
+		SocketChannel notifySocket=null;
+		for(Entry<SocketChannel, Long> player : players.entrySet()) {
+			if(player.getValue()==notifyId) {
+				notifySocket=player.getKey();
+				break;
+			}
+		}
+		if(notifySocket==null)
+			return;
+		
+		inGame.remove(sc);
+		inGame.remove(notifySocket);
+		games.remove(game);
+		ByteBuffer buff = ByteBuffer.wrap("OPPONENTLEFT".getBytes());
+		notifySocket.write(buff);
+		
+		
+		
+		
+	}
 	private void readMessage(SelectionKey key)throws Exception {
 		SocketChannel sc = (SocketChannel) key.channel();
 		StringBuilder sb = new StringBuilder();
@@ -105,6 +145,7 @@ public class Server implements Runnable {
 			
 		} catch (Exception e) {
 			Long closedId=players.get(sc);
+			leftGame(sc);
 			players.remove(sc);
 			System.out.println("Client dissconnected: "+closedId );
 			System.out.println("Remaining clients: "+players.size() );
@@ -115,6 +156,7 @@ public class Server implements Runnable {
 		if(read==-1)
 		{
 			Long closedId=players.get(sc);
+			leftGame(sc);
 			players.remove(sc);
 			System.out.println("Client dissconnected: "+closedId );
 			System.out.println("Remaining clients: "+players.size() );