Update connection opening failed metric when @onopen throws

Fixes: #47409

Author: geoand

extensions/websockets-next/deployment/src/test/java/io/quarkus/websockets/next/test/telemetry/MetricsAsserter.java

@@ -7,6 +7,7 @@
 import static io.quarkus.websockets.next.runtime.telemetry.TelemetryConstants.CLIENT_ENDPOINT_COUNT_ERRORS;
 import static io.quarkus.websockets.next.runtime.telemetry.TelemetryConstants.SERVER_BYTES;
 import static io.quarkus.websockets.next.runtime.telemetry.TelemetryConstants.SERVER_CONNECTION_CLOSED;
+import static io.quarkus.websockets.next.runtime.telemetry.TelemetryConstants.SERVER_CONNECTION_ON_OPEN_ERROR;
 import static io.quarkus.websockets.next.runtime.telemetry.TelemetryConstants.SERVER_CONNECTION_OPENED;
 import static io.quarkus.websockets.next.runtime.telemetry.TelemetryConstants.SERVER_CONNECTION_OPENED_ERROR;
 import static io.quarkus.websockets.next.runtime.telemetry.TelemetryConstants.SERVER_COUNT;
@@ -120,7 +121,7 @@ static Matcher<String> assertClientErrorTotal(String path, int clientErrorCount)
     }
 
     static Matcher<String> assertServerConnectionOpeningFailedTotal(String path, int serverConnectionOpeningFailedCount) {
-        return assertTotal(SERVER_CONNECTION_OPENED_ERROR, serverConnectionOpeningFailedCount, path, null);
+        return assertTotal(SERVER_CONNECTION_ON_OPEN_ERROR, serverConnectionOpeningFailedCount, path, null);
     }
 
     static Matcher<String> assertServerConnectionOpenedTotal(int serverConnectionOpenedCount) {

extensions/websockets-next/runtime/src/main/java/io/quarkus/websockets/next/runtime/Endpoints.java

@@ -113,6 +113,9 @@ public void handle(Void event) {
                             });
                         }
                     } else {
+                        if (telemetrySupport != null) {
+                            telemetrySupport.connectionOpeningFailed(r.cause());
+                        }
                         handleFailure(unhandledFailureStrategy, r.cause(), "Unable to complete @OnOpen callback", connection);
                     }
                 });

extensions/websockets-next/runtime/src/main/java/io/quarkus/websockets/next/runtime/telemetry/MetricsBuilderCustomizer.java

@@ -6,8 +6,8 @@
 import static io.quarkus.websockets.next.runtime.telemetry.TelemetryConstants.CLIENT_ENDPOINT_COUNT_ERRORS;
 import static io.quarkus.websockets.next.runtime.telemetry.TelemetryConstants.DIRECTION_TAG_KEY;
 import static io.quarkus.websockets.next.runtime.telemetry.TelemetryConstants.SERVER_CONNECTION_CLOSED;
+import static io.quarkus.websockets.next.runtime.telemetry.TelemetryConstants.SERVER_CONNECTION_ON_OPEN_ERROR;
 import static io.quarkus.websockets.next.runtime.telemetry.TelemetryConstants.SERVER_CONNECTION_OPENED;
-import static io.quarkus.websockets.next.runtime.telemetry.TelemetryConstants.SERVER_CONNECTION_OPENED_ERROR;
 import static io.quarkus.websockets.next.runtime.telemetry.TelemetryConstants.SERVER_ENDPOINT_COUNT_ERRORS;
 import static io.quarkus.websockets.next.runtime.telemetry.TelemetryConstants.Direction.INBOUND;
 import static io.quarkus.websockets.next.runtime.telemetry.TelemetryConstants.Direction.OUTBOUND;
@@ -98,7 +98,7 @@ public ErrorInterceptor apply(String path) {
                     .withRegistry(meterRegistry);
 
             private final Meter.MeterProvider<Counter> connectionOpeningFailedCounter = Counter
-                    .builder(SERVER_CONNECTION_OPENED_ERROR)
+                    .builder(SERVER_CONNECTION_ON_OPEN_ERROR)
                     .description("Number of failures occurred when opening server connection failed.")
                     .withRegistry(meterRegistry);
 

extensions/websockets-next/runtime/src/main/java/io/quarkus/websockets/next/runtime/telemetry/MetricsConnectionInterceptor.java

@@ -7,11 +7,11 @@
 final class MetricsConnectionInterceptor implements ConnectionInterceptor {
 
     private final Counter connectionOpenCounter;
-    private final Counter connectionOpeninigFailedCounter;
+    private final Counter connectionOnOpenErrorsCounter;
 
     MetricsConnectionInterceptor(Counter connectionOpenCounter, Counter connectionOpeninigFailedCounter) {
         this.connectionOpenCounter = connectionOpenCounter;
-        this.connectionOpeninigFailedCounter = connectionOpeninigFailedCounter;
+        this.connectionOnOpenErrorsCounter = connectionOpeninigFailedCounter;
     }
 
     @Override
@@ -21,7 +21,7 @@ public void connectionOpened() {
 
     @Override
     public void connectionOpeningFailed(Throwable cause) {
-        connectionOpeninigFailedCounter.increment();
+        connectionOnOpenErrorsCounter.increment();
     }
 
     @Override

extensions/websockets-next/runtime/src/main/java/io/quarkus/websockets/next/runtime/telemetry/TelemetryConstants.java

@@ -26,7 +26,7 @@ private TelemetryConstants() {
     /**
      * Counts number of times that opening of a WebSocket server connection resulted in error.
      */
-    public static final String SERVER_CONNECTION_OPENED_ERROR = "quarkus.websockets.server.connections.opened.errors";
+    public static final String SERVER_CONNECTION_ON_OPEN_ERROR = "quarkus.websockets.server.connections.onopen.errors";
 
     /**
      * Counts number of times that opening of a WebSocket client connection resulted in error.