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

Added functionality to read content from file and send it to queue for sending to the peer that requested it.

Browse Source
This commit is contained in:
WickedJack99
2024-04-06 20:59:35 +02:00
parent 7a71004e22
commit 564d9c8e96
1 changed files with 35 additions and 11 deletions
Download Patch File Download Diff File Expand all files Collapse all files

46
src/main/java/vslab1/src/Request/Data/PullFileRequestRequest.java
View File

@@ -1,10 +1,20 @@
package vslab1.src.Request.Data;
import java.io.BufferedReader;
import java.io.File;
import java.io.FileNotFoundException;
import java.io.FileReader;
import java.io.IOException;
import java.nio.file.Files;
import java.nio.file.Path;
import java.nio.file.Paths;
import vslab1.src.FileReaderWriter.FileReaderWriter;
import vslab1.src.FileReaderWriter.FileReaderWriter.EUpdateFlag;
import vslab1.src.Peers.Peer;
import vslab1.src.Sending.SendingQueue;
import vslab1.src.Sending.Data.EDataType;
import vslab1.src.Sending.Data.SendFileReply;
public record PullFileRequestRequest(Peer sender, Peer receiver, String fileName) implements Requestable {
@@ -25,16 +35,30 @@ public record PullFileRequestRequest(Peer sender, Peer receiver, String fileName
@Override
public void execute(SendingQueue sendingQueue) {
// TODO read filelist with paths and read file at path.
// Write content to String and send data via sendingqueue to requesting peer
// StringBuilder stringBuilder = new StringBuilder();
// try (BufferedReader reader = new BufferedReader(new FileReader())) {
// String line;
// while ((line = reader.readLine()) != null) {
// stringBuilder.append(line).append("\n");
// }
// }
// return stringBuilder.toString();
Peer thisPeer = FileReaderWriter.getThisPeer(EUpdateFlag.Update);
// fileName is key to filePath
String filePath = thisPeer.filesMap().get(fileName);
Path path = Paths.get(filePath);
if (!Files.exists(path)) {
System.err.println("File path doesn't exist.");
} else {
try {
//Write content to String and send data via sendingqueue to requesting peer
StringBuilder stringBuilder = new StringBuilder();
BufferedReader reader = new BufferedReader(new FileReader(new File(filePath)));
String line;
while ((line = reader.readLine()) != null) {
stringBuilder.append(line).append("\n");
}
reader.close();
String fileContent = stringBuilder.toString();
sendingQueue.add(new SendFileReply(thisPeer, sender, fileContent, fileName));
} catch (FileNotFoundException e) {
e.printStackTrace();
} catch (IOException e) {
e.printStackTrace();
}
}
}
}