diff --git a/src/main/java/vslab1/src/Request/Data/OnlineStateNotificationRequest.java b/src/main/java/vslab1/src/Request/Data/OnlineStateNotificationRequest.java index 79405b7..96ce608 100644 --- a/src/main/java/vslab1/src/Request/Data/OnlineStateNotificationRequest.java +++ b/src/main/java/vslab1/src/Request/Data/OnlineStateNotificationRequest.java @@ -5,6 +5,7 @@ import vslab1.src.Peers.EOnlineState; import vslab1.src.Peers.Peer; import vslab1.src.Sending.SendingQueue; import vslab1.src.Sending.Data.EDataType; +import vslab1.src.Sending.Data.OnlineStateNotification; import vslab1.src.Timeout.JobList; public record OnlineStateNotificationRequest(Peer sender, Peer receiver, JobList jobList) implements Requestable { @@ -26,8 +27,8 @@ public record OnlineStateNotificationRequest(Peer sender, Peer receiver, JobList @Override public void execute(SendingQueue sendingQueue) { - FileReaderWriter.updatePeer(new Peer(sender.ipAddress(), sender.port(), null, EOnlineState.Online)); + sendingQueue.add(new OnlineStateNotification(receiver, sender)); } } diff --git a/src/main/java/vslab1/src/Request/Data/OnlineStateRequestRequest.java b/src/main/java/vslab1/src/Request/Data/OnlineStateRequestRequest.java index c1573f2..8b4ee3a 100644 --- a/src/main/java/vslab1/src/Request/Data/OnlineStateRequestRequest.java +++ b/src/main/java/vslab1/src/Request/Data/OnlineStateRequestRequest.java @@ -24,8 +24,7 @@ public record OnlineStateRequestRequest(Peer sender, Peer receiver) implements R @Override public void execute(SendingQueue sendingQueue) { - // This is receiver and wants to notify the sender about its online state. - sendingQueue.add(new OnlineStateNotification(receiver, sender)); + System.out.println("Peer @ " + sender.ipAddress() + ":" + sender.port() + " online"); } }