specific metrics for unknown messages

Signed-off-by: Bob Claerhout <claerhout.bob@gmail.com>

Author: BobClaerhout

adapters/http-base/src/main/java/org/eclipse/hono/adapter/http/AbstractVertxBasedHttpProtocolAdapter.java

@@ -85,7 +85,7 @@ public abstract class AbstractVertxBasedHttpProtocolAdapter<T extends HttpProtoc
 
     private static final String KEY_MATCH_ALL_ROUTE_APPLIED = "matchAllRouteApplied";
 
-    private HttpAdapterMetrics metrics = HttpAdapterMetrics.NOOP;
+    protected HttpAdapterMetrics metrics = HttpAdapterMetrics.NOOP;
     private HttpServer server;
     private HttpServer insecureServer;
 

adapters/lora/src/main/java/org/eclipse/hono/adapter/lora/LoraProtocolAdapter.java

@@ -269,6 +269,17 @@ void handleProviderRoute(final HttpContext ctx, final LoraProvider provider) {
                 currentSpan.finish();
                 // discard the message but return 202 to not cause errors on the LoRa provider side
                 handle202(ctx.getRoutingContext());
+
+                //TODO: add metrics
+                metrics.reportTelemetry(
+                    endpoint,
+                    tenant,
+                    tenantTracker.result(),
+                    MetricsTags.ProcessingOutcome.FORWARDED,
+                    qos,
+                    payloadSize,
+                    ctx.getTtdStatus(),
+                    getMicrometerSample(ctx.getRoutingContext()));
             }
         } catch (final LoraProviderMalformedPayloadException e) {
             LOG.debug("error processing request from provider [name: {}]", provider.getProviderName(), e);

adapters/lora/src/main/java/org/eclipse/hono/adapter/lora/UnknownLoraMessage.java

@@ -0,0 +1,60 @@
+/**
+ * Copyright (c) 2023 Contributors to the Eclipse Foundation
+ *
+ * See the NOTICE file(s) distributed with this work for additional
+ * information regarding copyright ownership.
+ *
+ * This program and the accompanying materials are made available under the
+ * terms of the Eclipse Public License 2.0 which is available at
+ * http://www.eclipse.org/legal/epl-2.0
+ *
+ * SPDX-License-Identifier: EPL-2.0
+ */
+
+
+package org.eclipse.hono.adapter.lora;
+
+import com.google.common.io.BaseEncoding;
+import io.vertx.core.buffer.Buffer;
+import io.vertx.core.json.JsonObject;
+import java.util.Objects;
+
+
+/**
+ * A Lora message that contains unknown data sent from an end-device to a Network Server.
+ *
+ */
+public class UnknownLoraMessage implements LoraMessage {
+
+    /**
+     * {@inheritDoc}
+     */
+    @Override
+    public final byte[] getDevEUI() {
+        return new byte[0];
+    }
+
+    /**
+     * {@inheritDoc}
+     */
+    @Override
+    public final String getDevEUIAsString() {
+        return "";
+    }
+
+    /**
+     * {@inheritDoc}
+     */
+    @Override
+    public final LoraMessageType getType() {
+        return LoraMessageType.UNKNOWN;
+    }
+
+    /**
+     * {@inheritDoc}
+     */
+    @Override
+    public final Buffer getPayload() {
+        return Buffer.buffer();
+    }
+}

adapters/lora/src/main/java/org/eclipse/hono/adapter/lora/providers/JsonBasedLoraProvider.java

@@ -20,6 +20,7 @@
 import org.eclipse.hono.adapter.lora.LoraMessage;
 import org.eclipse.hono.adapter.lora.LoraMessageType;
 import org.eclipse.hono.adapter.lora.LoraMetaData;
+import org.eclipse.hono.adapter.lora.UnknownLoraMessage;
 import org.eclipse.hono.adapter.lora.UplinkLoraMessage;
 import org.eclipse.hono.util.CommandEndpoint;
 import org.eclipse.hono.util.Strings;
@@ -51,7 +52,7 @@ public LoraMessage getMessage(final RoutingContext ctx) {
             case UPLINK:
                 return createUplinkMessage(ctx.request(), message);
             default:
-                throw new LoraProviderMalformedPayloadException(String.format("unsupported message type [%s]", type));
+                return createUnknownMessage(ctx.request(), message);
             }
         } catch (final RuntimeException e) {
             // catch generic exception in order to also cover any (runtime) exceptions
@@ -184,4 +185,26 @@ protected UplinkLoraMessage createUplinkMessage(final HttpServerRequest request,
         message.setAdditionalData(getAdditionalData(requestBody));
         return message;
     }
+
+    /**
+     * Creates an object representation of a Lora unknown message.
+     * <p>
+     * This method uses the {@link #getDevEui(JsonObject)}
+     * method to extract relevant information from the request body to add
+     * to the returned message.
+     *
+     * @param request The request sent by the provider's Network Server.
+     * @param requestBody The JSON object contained in the request's body.
+     * @return The message.
+     * @throws RuntimeException if the message cannot be parsed.
+     */
+    protected UnknownLoraMessage createUnknownMessage(final HttpServerRequest request, final JsonObject requestBody) {
+
+        Objects.requireNonNull(requestBody);
+
+        final UnknownLoraMessage message = new UnknownLoraMessage();
+        return message;
+    }
+
+
 }

adapters/lora/src/main/java/org/eclipse/hono/adapter/lora/providers/KerlinkProvider.java

@@ -79,7 +79,10 @@ public Set<String> pathPrefixes() {
      */
     @Override
     public LoraMessageType getMessageType(final JsonObject loraMessage) {
-        return LoraMessageType.UPLINK;
+        if (loraMessage.containsKey(FIELD_KERLINK_PAYLOAD)){
+            return LoraMessageType.UPLINK;
+        }
+        return LoraMessageType.UNKNOWN;
     }
 
     @Override

adapters/lora/src/main/java/org/eclipse/hono/adapter/lora/providers/KerlinkProviderCustomContentType.java

@@ -57,7 +57,11 @@ public Set<String> pathPrefixes() {
      */
     @Override
     public LoraMessageType getMessageType(final JsonObject loraMessage) {
-        return LoraMessageType.UPLINK;
+        if (loraMessage.containsKey(FIELD_UPLINK_PAYLOAD))
+        {
+            return LoraMessageType.UPLINK;
+        }
+        return LoraMessageType.UNKNOWN;
     }
 
     /**

adapters/lora/src/main/java/org/eclipse/hono/adapter/lora/providers/OrbiwiseProvider.java

@@ -82,7 +82,10 @@ protected Buffer getPayload(final JsonObject loraMessage) {
     protected LoraMessageType getMessageType(final JsonObject loraMessage) {
 
         Objects.requireNonNull(loraMessage);
-        return LoraMessageType.UPLINK;
+        if (loraMessage.containsKey(FIELD_ORBIWISE_PAYLOAD)){
+            return LoraMessageType.UPLINK;
+        }
+        return LoraMessageType.UNKNOWN;
     }
 
     @Override

adapters/lora/src/main/java/org/eclipse/hono/adapter/lora/providers/ProximusProvider.java

@@ -66,7 +66,11 @@ public Set<String> pathPrefixes() {
      */
     @Override
     protected LoraMessageType getMessageType(final JsonObject loraMessage) {
-        return LoraMessageType.UPLINK;
+
+        if (loraMessage.containsKey(FIELD_PROXIMUS_PAYLOAD)){
+            return LoraMessageType.UPLINK;
+        }
+        return LoraMessageType.UNKNOWN;
     }
 
     @Override

adapters/lora/src/main/java/org/eclipse/hono/adapter/lora/providers/ThingsNetworkProvider.java

@@ -76,7 +76,10 @@ public Set<String> pathPrefixes() {
      */
     @Override
     protected LoraMessageType getMessageType(final JsonObject loraMessage) {
-        return LoraMessageType.UPLINK;
+        if (loraMessage.containsKey(FIELD_TTN_PAYLOAD_RAW)){
+            return LoraMessageType.UPLINK;
+        }
+        return LoraMessageType.UNKNOWN;
     }
 
     @Override

adapters/lora/src/test/java/org/eclipse/hono/adapter/lora/providers/LoraProviderTestBase.java

@@ -24,6 +24,7 @@
 
 import org.eclipse.hono.adapter.lora.LoraCommand;
 import org.eclipse.hono.adapter.lora.LoraMessageType;
+import org.eclipse.hono.adapter.lora.UnknownLoraMessage;
 import org.eclipse.hono.adapter.lora.UplinkLoraMessage;
 import org.eclipse.hono.util.CommandEndpoint;
 import org.junit.jupiter.api.BeforeEach;
@@ -65,7 +66,7 @@ public abstract class LoraProviderTestBase<T extends LoraProvider> {
      */
     protected final RoutingContext getRequestContext(final LoraMessageType type, final String... classifiers) throws IOException {
 
-        final Buffer message = LoraTestUtil.loadTestFile(provider.getProviderName(), LoraMessageType.UPLINK, classifiers);
+        final Buffer message = LoraTestUtil.loadTestFile(provider.getProviderName(), type, classifiers);
         final HttpServerRequest request = mock(HttpServerRequest.class);
         final RoutingContext routingContext = mock(RoutingContext.class);
         when(routingContext.request()).thenReturn(request);
@@ -99,6 +100,19 @@ public void testGetMessageSucceedsForUplinkMessage() throws IOException {
         assertMetaDataForUplinkMessage(loraMessage);
     }
 
+    /**
+     * Verifies that uplink messages are parsed correctly.
+     *
+     * @throws IOException If the file containing the example message could not be loaded.
+     */
+    @Test
+    public void testGetMessageSucceedsForUnknownMessage() throws IOException {
+
+        final RoutingContext request = getRequestContext(LoraMessageType.UNKNOWN);
+        final UnknownLoraMessage loraMessage = (UnknownLoraMessage) provider.getMessage(request);
+        assertThat(loraMessage.getType()).isEqualTo(LoraMessageType.UNKNOWN);
+    }
+
     /**
      * Asserts presence of common properties in an uplink message.
      *