From b7c51b4b21edf1952258b014281b94cfcddcc954 Mon Sep 17 00:00:00 2001 From: WickedJack99 Date: Mon, 22 Apr 2024 21:58:22 +0200 Subject: [PATCH] Removed some Method chaining. --- .../java/vslab1/src/Request/RequestExecuterThread.java | 9 ++++++--- 1 file changed, 6 insertions(+), 3 deletions(-) diff --git a/src/main/java/vslab1/src/Request/RequestExecuterThread.java b/src/main/java/vslab1/src/Request/RequestExecuterThread.java index 6dbca7d..138d739 100644 --- a/src/main/java/vslab1/src/Request/RequestExecuterThread.java +++ b/src/main/java/vslab1/src/Request/RequestExecuterThread.java @@ -85,14 +85,17 @@ public class RequestExecuterThread extends Thread implements Terminatable { } } if (receivedData.has("join")) { - return new ReceivedJoinRequest(parseIPPortField(receivedData), FileReaderWriter.getThisPeer(EUpdateFlag.Update)); + Peer sender = parseIPPortField(receivedData); + return new ReceivedJoinRequest(sender, FileReaderWriter.getThisPeer(EUpdateFlag.Update)); } if (receivedData.has("peerJoined")) { - return new ReceivedPeerJoinedNotification(parseIPPortField(receivedData), FileReaderWriter.getThisPeer(EUpdateFlag.Update)); + Peer sender = parseIPPortField(receivedData); + return new ReceivedPeerJoinedNotification(sender, FileReaderWriter.getThisPeer(EUpdateFlag.Update)); } if (receivedData.has("peer")) { + Peer sender = parseIPPortField(receivedData); JSONArray files = receivedData.getJSONArray("files"); - return new ReceivedPeerNotification(parseIPPortField(receivedData), FileReaderWriter.getThisPeer(EUpdateFlag.DoNotUpdate), files); + return new ReceivedPeerNotification(sender, FileReaderWriter.getThisPeer(EUpdateFlag.Update), files); } if (receivedData.has("leave")) { return new ReceivedLeaveNotification(parseIPPortField(receivedData), FileReaderWriter.getThisPeer(EUpdateFlag.DoNotUpdate));