From 12f7efed326d4a5ab5356906ce1b425dc09d245a Mon Sep 17 00:00:00 2001
From: AlexandreRouma <alexandre.rouma@gmail.com>
Date: Thu, 4 Apr 2024 19:25:02 +0200
Subject: [PATCH] Switch spectran http source module to use the remoteconfig
 endpoint as per #1354

---
 .../spectran_http_source/src/main.cpp         | 10 ++++++---
 .../src/spectran_http_client.cpp              | 22 ++++++++++++++-----
 2 files changed, 24 insertions(+), 8 deletions(-)

diff --git a/source_modules/spectran_http_source/src/main.cpp b/source_modules/spectran_http_source/src/main.cpp
index 8ec621311..b9b7212f2 100644
--- a/source_modules/spectran_http_source/src/main.cpp
+++ b/source_modules/spectran_http_source/src/main.cpp
@@ -144,9 +144,7 @@ class SpectranHTTPSourceModule : public ModuleManager::Instance {
             _this->tryConnect();
         }
         else if (connected && SmGui::Button("Disconnect##spectran_http_source")) {
-            _this->client->onCenterFrequencyChanged.unbind(_this->onFreqChangedId);
-            _this->client->onCenterFrequencyChanged.unbind(_this->onSamplerateChangedId);
-            _this->client->close();
+            _this->disconnect();
         }
         if (_this->running) { style::endDisabled(); }
 
@@ -173,6 +171,12 @@ class SpectranHTTPSourceModule : public ModuleManager::Instance {
         }
     }
 
+    void disconnect() {
+        client->onCenterFrequencyChanged.unbind(onFreqChangedId);
+        client->onSamplerateChanged.unbind(onSamplerateChangedId);
+        client->close();
+    }
+
     void onFreqChanged(double newFreq) {
         if (lastReportedFreq == newFreq) { return; }
         lastReportedFreq = newFreq;
diff --git a/source_modules/spectran_http_source/src/spectran_http_client.cpp b/source_modules/spectran_http_source/src/spectran_http_client.cpp
index 3b51f2d01..323336ada 100644
--- a/source_modules/spectran_http_source/src/spectran_http_client.cpp
+++ b/source_modules/spectran_http_source/src/spectran_http_client.cpp
@@ -11,12 +11,15 @@ SpectranHTTPClient::SpectranHTTPClient(std::string host, int port, dsp::stream<d
     sock = net::connect(host, port);
     http = net::http::Client(sock);
 
-    // Make request
+    // Send sttream request
     net::http::RequestHeader rqhdr(net::http::METHOD_GET, "/stream?format=float32", host);
     http.sendRequestHeader(rqhdr);
+
+    // Receive for response
     net::http::ResponseHeader rshdr;
     http.recvResponseHeader(rshdr, 5000);
 
+    // Check the status
     if (rshdr.getStatusCode() != net::http::STATUS_CODE_OK) {
         flog::error("HTTP request did not return ok: {}", rshdr.getStatusString());
         throw std::runtime_error("HTTP request did not return ok");
@@ -48,20 +51,29 @@ void SpectranHTTPClient::setCenterFrequency(uint64_t freq) {
     auto controlSock = net::connect(host, port);
     auto controlHttp = net::http::Client(controlSock);
 
-    // Make request
-    net::http::RequestHeader rqhdr(net::http::METHOD_PUT, "/control", host);
+    // Encode request body
+    net::http::RequestHeader rqhdr(net::http::METHOD_PUT, "/remoteconfig", host);
     char buf[1024];
-    sprintf(buf, "{\"frequencyCenter\":%" PRIu64 ",\"frequencySpan\":%" PRIu64 ",\"type\":\"capture\"}", freq, _samplerate);
+    sprintf(buf, "{\"receiverName\": \"Block_IQDemodulator_0\", \"simpleconfig\": {\"main\": {\"centerfreq\": %" PRIu64 ", \"samplerate\": %" PRIu64 ", \"spanfreq\": %" PRIu64 "}}}", freq, _samplerate, _samplerate);
     std::string data = buf;
     char lenBuf[16];
     sprintf(lenBuf, "%" PRIu64, (uint64_t)data.size());
+
+    // Setup request headers
     rqhdr.setField("Content-Length", lenBuf);
+
+    // Send request
     controlHttp.sendRequestHeader(rqhdr);
     controlSock->sendstr(data);
+
+    // Receive response
     net::http::ResponseHeader rshdr;
     controlHttp.recvResponseHeader(rshdr, 5000);
 
-    flog::debug("Response: {}", rshdr.getStatusString());
+    // Log error if there is one
+    if (rshdr.getStatusCode() < 200 || rshdr.getStatusCode() >= 300) {
+        flog::debug("Response: {}", rshdr.getStatusString());
+    }
 }
 
 void SpectranHTTPClient::worker() {