From a65f15869becc52eb3ac44297310f00e1676b0c2 Mon Sep 17 00:00:00 2001
From: Jakob Ketterl <jakob.ketterl@gmx.de>
Date: Fri, 15 Jan 2021 00:11:20 +0100
Subject: [PATCH] add wsprnet metrics

---
 owrx/wsprnet.py | 8 ++++++++
 1 file changed, 8 insertions(+)

diff --git a/owrx/wsprnet.py b/owrx/wsprnet.py
index 5ba8535..b1b8cd5 100644
--- a/owrx/wsprnet.py
+++ b/owrx/wsprnet.py
@@ -2,6 +2,7 @@ from owrx.reporting import Reporter
 from owrx.version import openwebrx_version
 from owrx.config import Config
 from owrx.locator import Locator
+from owrx.metrics import Metrics, CounterMetric
 from queue import Queue, Full
 from urllib import request, parse
 import threading
@@ -10,6 +11,7 @@ from datetime import datetime, timezone
 
 logger = logging.getLogger(__name__)
 
+
 class Worker(threading.Thread):
     def __init__(self, queue: Queue):
         self.queue = queue
@@ -62,12 +64,18 @@ class WsprnetReporter(Reporter):
         # single worker
         Worker(self.queue).start()
 
+        # metrics
+        metrics = Metrics.getSharedInstance()
+        self.spotCounter = CounterMetric()
+        metrics.addMetric("wsprnet.spots", self.spotCounter)
+
     def stop(self):
         pass
 
     def spot(self, spot):
         try:
             self.queue.put(spot, block=False)
+            self.spotCounter.inc()
         except Full:
             logger.warning("WSPRNet Queue overflow, one spot lost")