Studium_Angewandte_Informatik_Bachelor/verteilte_systeme_lab01_filesharing_peer
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Replaced code since there is now a method updatePeer to add information to peer.

Browse Source
This commit is contained in:
WickedJack99
2024-04-07 12:00:38 +02:00
parent c00982c17c
commit b603f297f7
1 changed files with 9 additions and 23 deletions
Download Patch File Download Diff File Expand all files Collapse all files

32
src/main/java/vslab1/src/Request/Data/PublishFileNameNotificationRequest.java
View File

@@ -3,8 +3,12 @@ package vslab1.src.Request.Data;
import java.io.File;
import java.io.FileReader;
import java.io.FileWriter;
import java.util.HashMap;
import java.util.Map;
import vslab1.src.Constants;
import vslab1.src.FileReaderWriter.FileReaderWriter;
import vslab1.src.Peers.EOnlineState;
import vslab1.src.Peers.Peer;
import vslab1.src.Sending.SendingQueue;
import vslab1.src.Sending.Data.EDataType;
@@ -32,29 +36,11 @@ public record PublishFileNameNotificationRequest(Peer sender, Peer receiver, Str
@Override
public void execute(SendingQueue sendingQueue) {
String senderIpPort = sender.ipAddress() + ":" + sender.port();
try {
FileReader reader = new FileReader(Constants.PEERCONFIGFILEPATH + File.separator + Constants.PEERCONFIGFILENAME);
// Parse JSON file into a JSONObject
JSONObject peerFileAsJSONObject = new JSONObject(new JSONTokener(reader));
reader.close();
JSONArray peers = peerFileAsJSONObject.getJSONArray("peers");
// Goes through json array and inserts new file at element that matches ip and port.
peers.forEach((peer) -> {
JSONObject peerAsJSONObject = (JSONObject)peer;
if ((peerAsJSONObject).getString("ipPort").equals(senderIpPort)) {
peerAsJSONObject.append("files", fileName);
}
});
FileWriter writer = new FileWriter(Constants.PEERCONFIGFILEPATH + File.separator + Constants.PEERCONFIGFILENAME);
// Writes the modified object back to the file.
writer.write(peerFileAsJSONObject.toString());
writer.close();
} catch (Exception e) {
e.printStackTrace();
}
Map<String, String> fileToAdd = new HashMap<String, String>();
// Filepath is empty since this peer doesn't know paths only file names of other peers.
fileToAdd.put(fileName, "");
Peer peerToUpdate = new Peer(sender.ipAddress(), sender.port(), fileToAdd, EOnlineState.Online);
FileReaderWriter.updatePeer(peerToUpdate);
}
}