From a11f3fa7440d9667656e92702dff6e18d623120a Mon Sep 17 00:00:00 2001
From: "Matthias P. Braendli" <matthias.braendli@mpb.li>
Date: Mon, 22 Dec 2025 17:01:16 +0100
Subject: Add http server with stats.json

---
 src/DabMux.cpp | 32 +++++++++++++++++++++++++++++++-
 1 file changed, 31 insertions(+), 1 deletion(-)

(limited to 'src/DabMux.cpp')

diff --git a/src/DabMux.cpp b/src/DabMux.cpp
index 7b5f5d6..14a7f8e 100644
--- a/src/DabMux.cpp
+++ b/src/DabMux.cpp
@@ -51,6 +51,7 @@
 #include "ManagementServer.h"
 #include "Log.h"
 #include "RemoteControl.h"
+#include "webserver.h"
 
 using namespace std;
 using boost::property_tree::ptree;
@@ -203,6 +204,30 @@ int main(int argc, char *argv[])
         /* Management: stats and config server */
         get_mgmt_server().open(mgmtserverport);
 
+        std::optional<WebServer> webserver;
+        auto http_listen_on = mux_conf.pt.get<string>("general.http-stats-listen-on", "127.0.0.1");
+        auto http_port = mux_conf.pt.get<int>("general.http-stats-port", 0);
+        if (http_port < 0 or http_port > 65535) {
+            etiLog.level(error) << "http-stats-port must be between o and 65535!";
+            return 1;
+        }
+
+        if (http_port) {
+            string index_text = "This is ODR-DabMux " VERSION;
+
+            char hostname[255];
+            if (gethostname(hostname, 255) == 0) {
+                index_text += " running on ";
+                index_text += hostname;
+            }
+            else {
+                etiLog.level(warn) << "Failed to get hostname " << strerror(errno);
+            }
+
+            etiLog.level(info) << "Starting webserver at " << http_listen_on << ":" << http_port;
+            webserver.emplace(http_listen_on, http_port, index_text);
+        }
+
         /************** READ REMOTE CONTROL PARAMETERS *************/
         int telnetport = mux_conf.pt.get<int>("remotecontrol.telnetport", 0);
         if (telnetport != 0) {
@@ -216,7 +241,8 @@ int main(int argc, char *argv[])
             rcs.add_controller(rc);
         }
 
-        DabMultiplexer mux(mux_conf);
+        ClockTAI clock_tai(mux_conf.pt.get("general.tai_clock_bulletins", ""));
+        DabMultiplexer mux(mux_conf, clock_tai);
 
         etiLog.level(info) <<
                 PACKAGE_NAME << " " <<
@@ -485,6 +511,10 @@ int main(int argc, char *argv[])
                 }
 
                 mgmt_server.update_ptree(mux_conf.pt);
+
+                if (webserver) {
+                    webserver->update_stats_json(mgmt_server.get_json_stats_for_http(clock_tai.expires_at()));
+                }
             }
         }
     }
-- 
cgit v1.2.3