Fix issues

.gitignore

@@ -31,4 +31,5 @@ bin/
 
 ###
 .idea
-StreamLet.iml
+StreamLet.iml
+output

config.txt

@@ -5,8 +5,11 @@ P2P=127.0.0.1:54582
 P2P=127.0.0.1:54583
 P2P=127.0.0.1:54584
 
+# Agreed time for every server to start protocol dd-MM-yyyy HH:mm:ss
+start=04-12-2025 08:36:00
+
 # NORMAL and DEBUG mode for logs
-logLevel=NORMAL
+logLevel=DEBUG
 
 # SIMULATION: transactions are generated randomly by the servers
 # CLIENT: waits for client to send transactions

makefile

@@ -15,3 +15,4 @@ compile: $(OUT_DIR)
 
 clean:
 	rm -rf out
+	rm -rf output

src/Streamlet.java

@@ -1,4 +1,4 @@
-import StreamletApp.StreamletNode;
+import app.StreamletNode;
 import utils.ConfigParser;
 import utils.communication.PeerInfo;
 import utils.logs.AppLogger;
@@ -14,14 +14,15 @@ void main(String[] args) throws IOException, InterruptedException {
 
     ConfigParser.ConfigData configData = ConfigParser.parseConfig();
 
-    List<PeerInfo> peerInfos = configData.peers;
-    AppLogger.updateLoggerLevel(configData.logLevel);
+    LocalDateTime start = configData.start();
+
+    List<PeerInfo> peerInfos = configData.peers();
+    AppLogger.updateLoggerLevel(configData.logLevel());
     PeerInfo localPeer = peerInfos.get(nodeId);
 
     List<PeerInfo> remotePeers = peerInfos.stream().filter(p -> p.id() != nodeId).toList();
     AppLogger.logDebug(remotePeers.toString());
 
-    AppLogger.logInfo("Waiting all peers to connect...");
-    StreamletNode node = new StreamletNode(localPeer, remotePeers, 1, configData.isClientGeneratingTransactions, configData.servers.get(nodeId));
+    StreamletNode node = new StreamletNode(localPeer, remotePeers, 1, start, configData.isClientGeneratingTransactions(), configData.servers().get(nodeId));
     node.startProtocol();
 }