From 743bf39206ba8d51d1c60928ea49b5daf8970444 Mon Sep 17 00:00:00 2001
From: cirakg <ciraboxkg@gmail.com>
Date: Mon, 2 Jan 2023 14:33:47 +0100
Subject: Implementiran chat izmedju korisnika.

---
 src/main/java/pokemon/Server.java | 35 +++++++++++++++++++++++++++++++++--
 1 file changed, 33 insertions(+), 2 deletions(-)

(limited to 'src/main/java/pokemon')

diff --git a/src/main/java/pokemon/Server.java b/src/main/java/pokemon/Server.java
index 6a555f2..9d56a27 100644
--- a/src/main/java/pokemon/Server.java
+++ b/src/main/java/pokemon/Server.java
@@ -234,9 +234,10 @@ public class Server implements Runnable {
 			long opponentId=Long.parseLong(msg[1]);
 			Game game=null;
 			for(Game tempGame :games) {
-				if(tempGame.player1Id==opponentId)
+				if(tempGame.player1Id==opponentId) {
 					game=tempGame;
-				break;
+					break;
+				}
 			}
 			SocketChannel opponentSocket=null;
 			for(Entry<SocketChannel, Long> player : players.entrySet()) {
@@ -257,6 +258,36 @@ public class Server implements Runnable {
 			
 			
 			
+		}
+		else if(msg[0].equals("CHATMESSAGE")) {
+			long myId=players.get(sc);
+			long opponentId=Long.parseLong(msg[1]);
+			User myUser=s.getUserById(myId);
+			User opponentUser=s.getUserById(opponentId);
+			
+			String message=msg[2];
+			Game game=null;
+			for(Game tempGame :games) {
+				if(tempGame.player1Id==opponentId || tempGame.player2Id==opponentId) {
+					game=tempGame;
+					break;
+				}
+			}
+			SocketChannel opponentSocket=null;
+			for(Entry<SocketChannel, Long> player : players.entrySet()) {
+				if(player.getValue()==opponentId) {
+					opponentSocket=player.getKey();
+					break;
+				}
+			}
+			String myMsg="MESSAGE:"+myUser.username+":"+message;
+			ByteBuffer buff = ByteBuffer.wrap(myMsg.getBytes());
+			opponentSocket.write(buff);
+			ByteBuffer buff1 = ByteBuffer.wrap(myMsg.getBytes());
+			sc.write(buff1);
+			
+			
+			
 		}
 		
 		
-- 
cgit v1.2.3