remove handleClientRequest from Replica interface

Author: joaomlneto

simulator/src/main/java/byzzbench/simulator/Replica.java

@@ -161,16 +161,6 @@ public void initialize() {
         // do nothing by default
     }
 
-    /**
-     * Handle a request received from a client.
-     *
-     * @param clientId  the ID of the client
-     * @param request   the request payload
-     * @param timestamp the time the request was created/sent
-     * @throws Exception if an error occurs while handling the request
-     */
-    public abstract void handleClientRequest(String clientId, long timestamp, Serializable request) throws Exception;
-
     /**
      * Send a reply to a client.
      *

simulator/src/main/java/byzzbench/simulator/protocols/XRPL/XRPLReplica.java

@@ -54,8 +54,7 @@ protected XRPLReplica(String nodeId, Scenario scenario, List<String> UNL, XRPLLe
         }
     }
 
-    @Override
-    public void handleClientRequest(String clientId, long timestamp, Serializable request) throws Exception {
+    public void handleClientRequest(String clientId, Serializable request) throws Exception {
         String tx = request.toString();
         XRPLTxMessage txmsg = new XRPLTxMessage(tx, clientId);
         this.handleMessage(clientId, txmsg);

simulator/src/main/java/byzzbench/simulator/protocols/dummy/DummyReplica.java

@@ -1,7 +1,5 @@
 package byzzbench.simulator.protocols.dummy;
 
-import java.io.Serializable;
-
 import byzzbench.simulator.Replica;
 import byzzbench.simulator.Scenario;
 import byzzbench.simulator.state.SerializableLogEntry;
@@ -23,11 +21,6 @@ public void initialize() {
         // nothing to do
     }
 
-    @Override
-    public void handleClientRequest(String clientId, long timestamp, Serializable request) {
-        throw new UnsupportedOperationException("Unsupported operation: handleClientRequest");
-    }
-
     @Override
     public void handleMessage(String sender, MessagePayload m) {
         if (m instanceof DefaultClientRequestPayload clientRequestMessage) {

simulator/src/main/java/byzzbench/simulator/protocols/fasthotstuff/FastHotStuffReplica.java

@@ -8,7 +8,6 @@
 import lombok.Getter;
 import lombok.extern.java.Log;
 
-import java.io.Serializable;
 import java.time.Duration;
 import java.util.*;
 import java.util.concurrent.atomic.AtomicLong;
@@ -50,11 +49,6 @@ public void initialize() {
         this.resetTimeout();
     }
 
-    @Override
-    public void handleClientRequest(String clientId, long timestamp, Serializable request) throws Exception {
-        throw new UnsupportedOperationException("Client requests not supported in FastHotStuff");
-    }
-
     private void createGenesisBlocks() {
         List<String> nodeIds = this.getNodeIds().stream().sorted().toList();
 

simulator/src/main/java/byzzbench/simulator/protocols/hbft/HbftJavaReplica.java

@@ -1195,23 +1195,20 @@ public Serializable compute(long sequenceNumber, LogEntry operation) {
         return operation;
     }
 
-    @Override
-    public void handleClientRequest(String clientId, long timestamp, Serializable request) {
+    public void handleClientRequest(String clientId, ClientRequestMessage clientRequestMessage) {
         // timestamp should be the time of the creation of the request
-        RequestMessage m = new RequestMessage(request, timestamp, clientId);
+        RequestMessage m = new RequestMessage(clientRequestMessage.getOperation(), clientRequestMessage.getTimestamp(), clientId);
         //System.out.println(m);
         this.recvRequest(m);
     }
 
     @Override
     public void handleMessage(String sender, MessagePayload m) {
         if (m instanceof RequestMessage request) {
-            //System.out.println(request);
             recvRequest(request);
             return;
         } else if (m instanceof ClientRequestMessage clientRequest) {
-            //System.out.println(clientRequest);
-            handleClientRequest(sender, clientRequest.getTimestamp(), clientRequest.getOperation());
+            handleClientRequest(sender, clientRequest);
             return;
         } else if (m instanceof PrepareMessage prepare) {
             recvPrepare(prepare);

simulator/src/main/java/byzzbench/simulator/protocols/pbft/PbftReplica.java

@@ -10,7 +10,6 @@
 import lombok.Getter;
 import lombok.extern.java.Log;
 
-import java.io.Serializable;
 import java.time.Duration;
 import java.time.Instant;
 import java.util.*;
@@ -440,17 +439,6 @@ public String primary(long vi) {
         return (vi == v) ? this.cur_primary : replicaIds[(int) (vi % replicaIds.length)];
     }
 
-    
-    @Override
-    public void handleClientRequest(String clientId, long timestamp, Serializable request) throws Exception {
-        if (request instanceof RequestMessage) {
-            this.handleMessage(clientId, (RequestMessage) request);
-        } else {
-            throw new UnsupportedOperationException("Unknown request type: " + request.getClass().getName());
-        }
-    }
-
-
     @Override
     public void handleMessage(String sender, MessagePayload message) throws Exception {
         // for some reason the original code does this before receiving a message.

simulator/src/main/java/byzzbench/simulator/protocols/pbft_java/PbftJavaReplica.java

@@ -720,8 +720,7 @@ public Serializable compute(long sequenceNumber, LogEntry operation) {
         return operation;
     }
 
-    @Override
-    public void handleClientRequest(String clientId, long timestamp, Serializable request) {
+    public void handleClientRequest(String clientId, Serializable request) {
         // FIXME: should not get timestamp from system time
         RequestMessage m = new RequestMessage(request, System.currentTimeMillis(), clientId);
         this.recvRequest(m);
@@ -730,7 +729,7 @@ public void handleClientRequest(String clientId, long timestamp, Serializable re
     @Override
     public void handleMessage(String sender, MessagePayload m) {
         switch (m) {
-            case DefaultClientRequestPayload clientRequest -> handleClientRequest(sender, 0L, clientRequest.getOperation());
+            case DefaultClientRequestPayload clientRequest -> handleClientRequest(sender, clientRequest.getOperation());
             case RequestMessage request -> recvRequest(request);
             case PrePrepareMessage prePrepare -> recvPrePrepare(prePrepare);
             case PrepareMessage prepare -> recvPrepare(prepare);

simulator/src/main/java/byzzbench/simulator/scheduler/twins/TwinsReplica.java

@@ -8,7 +8,6 @@
 import lombok.Getter;
 import lombok.extern.java.Log;
 
-import java.io.Serializable;
 import java.util.ArrayList;
 import java.util.List;
 import java.util.Random;
@@ -129,11 +128,6 @@ private Replica getInternalReplicaFromId(String id) {
         return replicas.get(index);
     }
 
-    @Override
-    public void handleClientRequest(String clientId, long timestamp, Serializable request) {
-        throw new UnsupportedOperationException("Not implemented");
-    }
-
     /**
      * Get the internal replicas that should handle the given message.
      *