Test fix for producer idempotence

Signed-off-by: Nithin <[email protected]>
hyperledger-labs · May 30, 2024 · 5a30880 · 5a30880
1 parent b063d47
commit 5a30880
Show file tree

Hide file tree

Showing 4 changed files with 17 additions and 5 deletions.
diff --git a/src/test/java/hlf/java/rest/client/service/impl/TransactionFulfillmentImplTest.java b/src/test/java/hlf/java/rest/client/service/impl/TransactionFulfillmentImplTest.java
@@ -69,6 +69,7 @@ public void writeTransactionToLedgerTest()
     Mockito.when(gatewayConnetion.getNetwork(Mockito.anyString())).thenReturn(network);
     Mockito.when(network.getContract(Mockito.anyString())).thenReturn(contract);
     Mockito.when(contract.createTransaction(Mockito.anyString())).thenReturn(transaction);
+    Mockito.when(transaction.getTransactionId()).thenReturn(Mockito.anyString());
     Mockito.when(transaction.submit(Mockito.<String>any())).thenReturn(byteArrayResponse);
     /*
      * Mockito.when(contract.submitTransaction(Mockito.anyString(),
@@ -92,6 +93,7 @@ public void writeTransactionToLedgerContractExceptionTest()
     Mockito.when(gatewayConnetion.getNetwork(Mockito.anyString())).thenReturn(network);
     Mockito.when(network.getContract(Mockito.anyString())).thenReturn(contract);
     Mockito.when(contract.createTransaction(Mockito.anyString())).thenReturn(transaction);
+    Mockito.when(transaction.getTransactionId()).thenReturn(Mockito.anyString());
     Mockito.when(transaction.submit(Mockito.<String>any())).thenThrow(new ContractException(""));
     /*
      * Mockito.when(contract.submitTransaction(Mockito.anyString(),
@@ -115,6 +117,7 @@ public void writeTransactionToLedgerTimeoutExceptionTest()
     Mockito.when(gatewayConnetion.getNetwork(Mockito.anyString())).thenReturn(network);
     Mockito.when(network.getContract(Mockito.anyString())).thenReturn(contract);
     Mockito.when(contract.createTransaction(Mockito.anyString())).thenReturn(transaction);
+    Mockito.when(transaction.getTransactionId()).thenReturn(Mockito.anyString());
     Mockito.when(transaction.submit(Mockito.<String>any())).thenThrow(new TimeoutException());
     /*
      * Mockito.when(contract.submitTransaction(Mockito.anyString(),
@@ -138,6 +141,7 @@ public void writeTransactionToLedgerInterruptExceptionTest()
     Mockito.when(gatewayConnetion.getNetwork(Mockito.anyString())).thenReturn(network);
     Mockito.when(network.getContract(Mockito.anyString())).thenReturn(contract);
     Mockito.when(contract.createTransaction(Mockito.anyString())).thenReturn(transaction);
+    Mockito.when(transaction.getTransactionId()).thenReturn(Mockito.anyString());
     Mockito.when(transaction.submit(Mockito.<String>any())).thenThrow(new InterruptedException());
     /*
      * Mockito.when(contract.submitTransaction(Mockito.anyString(),

diff --git a/src/test/resources/application-default-consumer.yml b/src/test/resources/application-default-consumer.yml
@@ -29,7 +29,8 @@ kafka:
   event-listener:
     ssl-enabled: false
     brokerHost: localhost:9092
-    topic: test-publisher-event-topic
+    topic: test-publisher-event-topice
+    enable-idempotence: true
 management:
   endpoints:
     web:
@@ -57,10 +58,12 @@ management:
         http.server.requests: 1s
     custom:
       kafka:
-        enabled: true
+        enabled: false
 server:
   config:
     location: /Users/n0p0328/work/hlf-connector/src/main/resources/config/
   servlet:
     context-path: /hlf-rest-client
   port: 8282
+dedupe:
+  enable: true
diff --git a/src/test/resources/application-per-partition-consumer.yml b/src/test/resources/application-per-partition-consumer.yml
@@ -31,10 +31,12 @@ kafka:
     ssl-enabled: false
     brokerHost: localhost:9092
     topic: test-publisher-event-topic
+    enable-idempotence: true
   failed-message-listener:
     brokerHost: localhost:9092
     topic: test-consumer-dlt
     ssl-enabled: false
+    enable-idempotence: true
 management:
   endpoints:
     web:
@@ -62,10 +64,12 @@ management:
         http.server.requests: 1s
     custom:
       kafka:
-        enabled: true
+        enabled: false
 server:
   config:
     location: /Users/n0p0328/work/hlf-connector/src/main/resources/config/
   servlet:
     context-path: /hlf-rest-client
   port: 8282
+dedupe:
+  enable: true
diff --git a/src/test/resources/application.yml b/src/test/resources/application.yml
@@ -46,8 +46,9 @@ kafka:
   event-listener:
     brokerHost: localhost:9093
     topic: hlf-offchain-topic
-
-
+    enable-idempotence: true
+dedupe:
+  enable: false
 ---
 spring:
   profiles: intg