Add a stubbed getFeeEstimate gRPC API

grpc/src/main/java/org/hiero/mirror/grpc/controller/NetworkController.java

@@ -4,6 +4,12 @@
 
 import com.google.protobuf.ByteString;
 import com.hedera.mirror.api.proto.AddressBookQuery;
+import com.hedera.mirror.api.proto.Fee.EstimateMode;
+import com.hedera.mirror.api.proto.Fee.FeeEstimate;
+import com.hedera.mirror.api.proto.Fee.FeeEstimateQuery;
+import com.hedera.mirror.api.proto.Fee.FeeEstimateResponse;
+import com.hedera.mirror.api.proto.Fee.FeeExtra;
+import com.hedera.mirror.api.proto.Fee.NetworkFee;
 import com.hedera.mirror.api.proto.ReactorNetworkServiceGrpc;
 import com.hederahashgraph.api.proto.java.NodeAddress;
 import com.hederahashgraph.api.proto.java.ServiceEndpoint;
@@ -26,8 +32,34 @@
 @RequiredArgsConstructor
 public class NetworkController extends ReactorNetworkServiceGrpc.NetworkServiceImplBase {
 
+    static final FeeEstimateResponse STUB_RESPONSE = stubResponse();
+
     private final NetworkService networkService;
 
+    private static FeeEstimateResponse stubResponse() {
+        final var feeExtra = FeeExtra.newBuilder()
+                .setCharged(0)
+                .setCount(1)
+                .setFeePerUnit(0L)
+                .setIncluded(1)
+                .setName("Test data")
+                .setSubtotal(0L);
+        final var feeEstimate = FeeEstimate.newBuilder().setBase(0L).addExtras(feeExtra);
+        return FeeEstimateResponse.newBuilder()
+                .addNotes("This API is not yet implemented and only returns stubbed test data")
+                .setMode(EstimateMode.STATE)
+                .setNetwork(NetworkFee.newBuilder().setMultiplier(1).setSubtotal(0L))
+                .setNode(feeEstimate)
+                .setService(feeEstimate)
+                .setTotal(0)
+                .build();
+    }
+
+    @Override
+    public Mono<FeeEstimateResponse> getFeeEstimate(FeeEstimateQuery request) {
+        return Mono.just(STUB_RESPONSE);
+    }
+
     @Override
     public Flux<NodeAddress> getNodes(Mono<AddressBookQuery> request) {
         return request.map(this::toFilter)

grpc/src/test/java/org/hiero/mirror/grpc/controller/NetworkControllerTest.java

@@ -6,17 +6,17 @@
 
 import com.google.protobuf.ByteString;
 import com.hedera.mirror.api.proto.AddressBookQuery;
+import com.hedera.mirror.api.proto.Fee.FeeEstimateQuery;
 import com.hedera.mirror.api.proto.ReactorNetworkServiceGrpc;
 import com.hederahashgraph.api.proto.java.FileID;
 import com.hederahashgraph.api.proto.java.NodeAddress;
 import com.hederahashgraph.api.proto.java.ServiceEndpoint;
 import io.grpc.Status;
 import io.grpc.StatusRuntimeException;
-import jakarta.annotation.Resource;
 import java.net.InetAddress;
 import java.time.Duration;
 import java.util.HashSet;
-import lombok.CustomLog;
+import lombok.RequiredArgsConstructor;
 import net.devh.boot.grpc.client.inject.GrpcClient;
 import org.apache.commons.lang3.StringUtils;
 import org.hiero.mirror.common.domain.DomainBuilder;
@@ -31,33 +31,40 @@
 import reactor.core.publisher.Mono;
 import reactor.test.StepVerifier;
 
-@CustomLog
-class NetworkControllerTest extends GrpcIntegrationTest {
+@RequiredArgsConstructor
+final class NetworkControllerTest extends GrpcIntegrationTest {
 
     private static final Duration WAIT = Duration.ofSeconds(10L);
     private static final long CONSENSUS_TIMESTAMP = 1L;
 
+    private final DomainBuilder domainBuilder;
+    private final SystemEntity systemEntity;
+
     @GrpcClient("local")
     private ReactorNetworkServiceGrpc.ReactorNetworkServiceStub reactiveService;
 
-    @Resource
-    private DomainBuilder domainBuilder;
-
-    @Resource
-    private SystemEntity systemEntity;
+    @Test
+    void getFeeEstimate() {
+        final var query = FeeEstimateQuery.newBuilder().build();
+        StepVerifier.withVirtualTime(() -> reactiveService.getFeeEstimate(Mono.just(query)))
+                .thenAwait(WAIT)
+                .consumeNextWith(n -> assertThat(n).isEqualTo(NetworkController.STUB_RESPONSE))
+                .expectComplete()
+                .verify(WAIT);
+    }
 
     @Test
-    void missingFileId() {
-        AddressBookQuery query = AddressBookQuery.newBuilder().build();
+    void getNodesMissingFileId() {
+        final var query = AddressBookQuery.newBuilder().build();
         StepVerifier.withVirtualTime(() -> reactiveService.getNodes(Mono.just(query)))
                 .thenAwait(WAIT)
                 .expectErrorSatisfies(t -> assertException(t, Status.Code.INVALID_ARGUMENT, "fileId: must not be null"))
                 .verify(WAIT);
     }
 
     @Test
-    void invalidFileId() {
-        AddressBookQuery query = AddressBookQuery.newBuilder()
+    void getNodesInvalidFileId() {
+        final var query = AddressBookQuery.newBuilder()
                 .setFileId(FileID.newBuilder().setFileNum(-1).build())
                 .build();
         StepVerifier.withVirtualTime(() -> reactiveService.getNodes(Mono.just(query)))
@@ -67,8 +74,8 @@
     }
 
     @Test
-    void invalidLimit() {
-        AddressBookQuery query = AddressBookQuery.newBuilder()
+    void getNodesInvalidLimit() {
+        final var query = AddressBookQuery.newBuilder()
                 .setFileId(FileID.newBuilder().build())
                 .setLimit(-1)
                 .build();
@@ -81,8 +88,8 @@
     }
 
     @Test
-    void notFound() {
-        AddressBookQuery query = AddressBookQuery.newBuilder()
+    void getNodesNotFound() {
+        final var query = AddressBookQuery.newBuilder()
                 .setFileId(systemEntity.addressBookFile102().toFileID())
                 .build();
 
@@ -93,11 +100,11 @@
     }
 
     @Test
-    void noLimit() {
-        AddressBook addressBook = addressBook();
-        AddressBookEntry addressBookEntry1 = addressBookEntry();
-        AddressBookEntry addressBookEntry2 = addressBookEntry();
-        AddressBookQuery query = AddressBookQuery.newBuilder()
+    void getNodesNoLimit() {
+        final var addressBook = addressBook();
+        final var addressBookEntry1 = addressBookEntry();
+        final var addressBookEntry2 = addressBookEntry();
+        final var query = AddressBookQuery.newBuilder()
                 .setFileId(addressBook.getFileId().toFileID())
                 .build();
 
@@ -110,11 +117,10 @@
     }
 
     @Test
-    void noLimitServiceEndpointWithDomainName() {
-        var addressBook = addressBook();
-        var addressBookEntry1 = addressBookEntryCustomized("www.example-node.com", "", 5000);
-
-        var query = AddressBookQuery.newBuilder()
+    void getNodesNoLimitServiceEndpointWithDomainName() {
+        final var addressBook = addressBook();
+        final var addressBookEntry1 = addressBookEntryCustomized("www.example-node.com", "", 5000);
+        final var query = AddressBookQuery.newBuilder()
                 .setFileId(addressBook.getFileId().toFileID())
                 .build();
 
@@ -126,11 +132,10 @@
     }
 
     @Test
-    void testWithEmptyDomainNameAndIpAddress() {
-        var addressBook = addressBook();
-        var addressBookEntry1 = addressBookEntryCustomized("", "", 0);
-
-        var query = AddressBookQuery.newBuilder()
+    void getNodesTestWithEmptyDomainNameAndIpAddress() {
+        final var addressBook = addressBook();
+        final var addressBookEntry1 = addressBookEntryCustomized("", "", 0);
+        final var query = AddressBookQuery.newBuilder()
                 .setFileId(addressBook.getFileId().toFileID())
                 .build();
 
@@ -142,11 +147,11 @@
     }
 
     @Test
-    void limitReached() {
-        AddressBook addressBook = addressBook();
-        AddressBookEntry addressBookEntry1 = addressBookEntry();
+    void getNodesLmitReached() {
+        final var addressBook = addressBook();
+        final var addressBookEntry1 = addressBookEntry();
         addressBookEntry();
-        AddressBookQuery query = AddressBookQuery.newBuilder()
+        final var query = AddressBookQuery.newBuilder()
                 .setFileId(addressBook.getFileId().toFileID())
                 .setLimit(1)
                 .build();
@@ -160,9 +165,9 @@
 
     @SuppressWarnings("deprecation")
     @Test
-    void nullFields() {
-        AddressBook addressBook = addressBook();
-        AddressBookEntry addressBookEntry = domainBuilder
+    void getNodesNullFields() {
+        final var addressBook = addressBook();
+        final var addressBookEntry = domainBuilder
                 .addressBookEntry()
                 .customize(a -> a.consensusTimestamp(CONSENSUS_TIMESTAMP)
                         .description(null)
@@ -171,7 +176,7 @@
                         .publicKey(null)
                         .stake(null))
                 .persist();
-        AddressBookQuery query = AddressBookQuery.newBuilder()
+        final var query = AddressBookQuery.newBuilder()
                 .setFileId(addressBook.getFileId().toFileID())
                 .build();
 
@@ -205,8 +210,8 @@
     }
 
     private AddressBookEntry addressBookEntryCustomized(String domainName, String ipAddress, int port) {
-        var serviceEndpoints = new HashSet<AddressBookServiceEndpoint>();
-        var endpoint = domainBuilder
+        final var serviceEndpoints = new HashSet<AddressBookServiceEndpoint>();
+        final var endpoint = domainBuilder
                 .addressBookServiceEndpoint()
                 .customize(a -> a.domainName(domainName).ipAddressV4(ipAddress).port(port))
                 .get();
@@ -253,7 +258,7 @@
     private void assertException(Throwable t, Status.Code status, String message) {
         assertThat(t).isNotNull().isInstanceOf(StatusRuntimeException.class).hasMessageContaining(message);
 
-        StatusRuntimeException statusRuntimeException = (StatusRuntimeException) t;
+        final var statusRuntimeException = (StatusRuntimeException) t;
         assertThat(statusRuntimeException.getStatus().getCode()).isEqualTo(status);
     }
 }