implement clientSession class
This commit is contained in:
@@ -12,7 +12,7 @@ import java.nio.file.Paths;
|
|||||||
import java.util.Scanner;
|
import java.util.Scanner;
|
||||||
|
|
||||||
public class chatClient {
|
public class chatClient {
|
||||||
public static void main() {
|
public static void main(String[] args) {
|
||||||
|
|
||||||
String host = "localhost";
|
String host = "localhost";
|
||||||
int port = 9000;
|
int port = 9000;
|
||||||
@@ -54,7 +54,7 @@ public class chatClient {
|
|||||||
System.out.println("Usage: /msg <user> <text>");
|
System.out.println("Usage: /msg <user> <text>");
|
||||||
continue;
|
continue;
|
||||||
}
|
}
|
||||||
String target = parts[1];
|
String target = parts[1];
|
||||||
String text = parts[2];
|
String text = parts[2];
|
||||||
out.writeObject(new ChatMessage(MessageType.PRIVATE_MESSAGE, username, target, text));
|
out.writeObject(new ChatMessage(MessageType.PRIVATE_MESSAGE, username, target, text));
|
||||||
out.flush();
|
out.flush();
|
||||||
|
|||||||
@@ -91,7 +91,7 @@ public class ClientSession implements Runnable {
|
|||||||
}
|
}
|
||||||
case PRIVATE_MESSAGE -> {
|
case PRIVATE_MESSAGE -> {
|
||||||
|
|
||||||
ClientSession receiver = userManager.getUser(msg.getSender());
|
ClientSession receiver = userManager.getUser(msg.getReceiver());
|
||||||
if (receiver != null) {
|
if (receiver != null) {
|
||||||
receiver.sendMessage(msg);
|
receiver.sendMessage(msg);
|
||||||
}
|
}
|
||||||
@@ -107,7 +107,7 @@ public class ClientSession implements Runnable {
|
|||||||
}
|
}
|
||||||
|
|
||||||
private void handleFileMessage(FileMessage fileMsg) throws IOException {
|
private void handleFileMessage(FileMessage fileMsg) throws IOException {
|
||||||
// Storing the file
|
|
||||||
var sentPath = FileManager.getSentPath(fileMsg.getSender(), fileMsg.getFilename());
|
var sentPath = FileManager.getSentPath(fileMsg.getSender(), fileMsg.getFilename());
|
||||||
var recvPath = FileManager.getReceivedPath(fileMsg.getReceiver(), fileMsg.getFilename());
|
var recvPath = FileManager.getReceivedPath(fileMsg.getReceiver(), fileMsg.getFilename());
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user