Add support for testing with metrics (#327)

Signed-off-by: Richard Bair <rbair23@users.noreply.github.com>

pbj-core/pbj-grpc-helidon/build.gradle.kts

@@ -33,6 +33,7 @@ testModuleInfo {
     requires("io.helidon.webclient")
     requires("io.helidon.webserver")
     requires("io.helidon.webserver.http2")
+    requires("io.helidon.webserver.observe.metrics")
     requires("io.helidon.webclient.http2")
     requires("com.google.protobuf.util")
     requires("io.grpc.protobuf")

pbj-core/pbj-grpc-helidon/src/test/java/com/hedera/pbj/grpc/helidon/PbjProtocolHandlerTest.java

@@ -18,6 +18,7 @@
 
 import static org.assertj.core.api.Assertions.assertThat;
 import static org.assertj.core.api.Assertions.entry;
+import static org.assertj.core.api.Assumptions.assumeThat;
 
 import com.hedera.pbj.grpc.helidon.config.PbjConfig;
 import com.hedera.pbj.runtime.grpc.GrpcStatus;
@@ -69,11 +70,10 @@ void setUp() {
         route = new PbjMethodRoute(new GreeterServiceImpl(), GreeterService.GreeterMethod.sayHello);
         deadlineDetector = new DeadlineDetectorStub();
 
-        // FUTURE: We need an easy way to test counters. When we have them, we can test this.
-//        assumeThat(route.requestCounter().count()).isEqualTo(0);
-//        assumeThat(route.failedGrpcRequestCounter().count()).isEqualTo(0);
-//        assumeThat(route.failedHttpRequestCounter().count()).isEqualTo(0);
-//        assumeThat(route.failedUnknownRequestCounter().count()).isEqualTo(0);
+        assumeThat(route.requestCounter().count()).isEqualTo(0);
+        assumeThat(route.failedGrpcRequestCounter().count()).isEqualTo(0);
+        assumeThat(route.failedHttpRequestCounter().count()).isEqualTo(0);
+        assumeThat(route.failedUnknownRequestCounter().count()).isEqualTo(0);
     }
 
     /**
@@ -90,11 +90,11 @@ void unsupportedContentType(String contentType) {
         final var handler = new PbjProtocolHandler(headers, streamWriter, streamId, flowControl, currentStreamState, config, route, deadlineDetector);
         handler.init();
         // Even though the request failed, it was made, and should be counted
-//        assertThat(route.requestCounter().count()).isEqualTo(1);
+        assertThat(route.requestCounter().count()).isEqualTo(1);
         // And since it failed the failed counter should be incremented
-//        assertThat(route.failedGrpcRequestCounter().count()).isEqualTo(0);
-//        assertThat(route.failedHttpRequestCounter().count()).isEqualTo(1);
-//        assertThat(route.failedUnknownRequestCounter().count()).isEqualTo(0);
+        assertThat(route.failedGrpcRequestCounter().count()).isEqualTo(0);
+        assertThat(route.failedHttpRequestCounter().count()).isEqualTo(1);
+        assertThat(route.failedUnknownRequestCounter().count()).isEqualTo(0);
 
         // Check the HTTP2 response header frame was error 415
         assertThat(streamWriter.writtenHeaders).hasSize(1);

pbj-core/pbj-grpc-helidon/src/test/java/com/hedera/pbj/grpc/helidon/PbjTest.java

@@ -57,7 +57,6 @@
 import java.util.concurrent.CountDownLatch;
 import java.util.concurrent.ExecutorService;
 import java.util.concurrent.Executors;
-import java.util.concurrent.Flow;
 import java.util.concurrent.LinkedBlockingDeque;
 import java.util.concurrent.TimeUnit;
 import java.util.concurrent.atomic.AtomicInteger;

pbj-core/settings.gradle.kts

@@ -49,6 +49,7 @@ dependencyResolutionManagement {
             // which will have the set of these dependencies that are required.
             version("io.helidon.webserver", helidonVersion)
             version("io.helidon.webserver.http2", helidonVersion)
+            version("io.helidon.webserver.observe.metrics", helidonVersion)
             version("io.helidon.metrics.api", helidonVersion)
             version("io.helidon.common.features.api", helidonVersion)
             version("io.helidon.common.features.processor", helidonVersion) // annotation processing