From 21f4046ae1bf51dfe00f6d481e323f06b4300071 Mon Sep 17 00:00:00 2001
From: BMatajsz <90217645+BMatajsz@users.noreply.github.com>
Date: Tue, 3 Dec 2024 12:19:32 -0500
Subject: ByzantineHandler

---
 src/main/java/derms/ReplicaManager.java | 7 ++++++-
 1 file changed, 6 insertions(+), 1 deletion(-)

diff --git a/src/main/java/derms/ReplicaManager.java b/src/main/java/derms/ReplicaManager.java
index 64ceb04..252953c 100644
--- a/src/main/java/derms/ReplicaManager.java
+++ b/src/main/java/derms/ReplicaManager.java
@@ -19,6 +19,7 @@ import java.net.NetworkInterface;
 import java.net.Socket;
 import java.io.ObjectOutputStream;
 import java.io.ObjectInputStream;
+import java.util.Objects;
 import java.util.logging.Logger;
 
 public class ReplicaManager {
@@ -92,7 +93,11 @@ public class ReplicaManager {
                     MessagePayload receivedPayload = multicastReceiver.receive();
                     Request request = (Request) receivedPayload;
                     log.info("Received request: " + request);
-                    replica.processRequest(request);
+                    if (Objects.equals(request.getMessageType(), "1" + replicaId)) {
+                        handleByzantineFailure();
+                    } else {
+                        replica.processRequest(request);
+                    }
                 } catch (InterruptedException e) {
                     log.severe("Failed to receive request: " + e.getMessage());
                     Thread.currentThread().interrupt();
-- 
cgit v1.2.3