From b4f018b918c7b1bc5d18a6be1577aba6e0fa5b75 Mon Sep 17 00:00:00 2001 From: Grant Limberg Date: Wed, 1 Oct 2025 09:07:08 -0700 Subject: [PATCH] debug output from parsing pubsub messages --- nonfree/controller/PubSubListener.cpp | 12 +++++++++--- 1 file changed, 9 insertions(+), 3 deletions(-) diff --git a/nonfree/controller/PubSubListener.cpp b/nonfree/controller/PubSubListener.cpp index dde85c740..2a7402a60 100644 --- a/nonfree/controller/PubSubListener.cpp +++ b/nonfree/controller/PubSubListener.cpp @@ -133,7 +133,7 @@ void PubSubNetworkListener::onNotification(const std::string& payload) span->SetStatus(opentelemetry::trace::StatusCode::kError, "Failed to parse protobuf"); return; } - + fprintf(stderr, "PubSubNetworkListener: parsed protobuf message. %s\n", nc.DebugString().c_str()); fprintf(stderr, "Network notification received\n"); try { @@ -212,7 +212,7 @@ void PubSubMemberListener::onNotification(const std::string& payload) span->SetStatus(opentelemetry::trace::StatusCode::kError, "Failed to parse protobuf"); return; } - + fprintf(stderr, "PubSubMemberListener: parsed protobuf message. %s\n", mc.DebugString().c_str()); fprintf(stderr, "Member notification received"); try { @@ -318,7 +318,10 @@ nlohmann::json toJson(const pbmessages::NetworkChange_Network& nc, pbmessages::N pool["ipRangeEnd"] = p.end_ip(); pools.push_back(pool); } - out["assignmentPools"] = pools; + out["ipAssignmentPools"] = pools; + } + else { + out["ipAssignmentPools"] = nlohmann::json::array(); } if (nc.routes_size() > 0) { @@ -343,6 +346,9 @@ nlohmann::json toJson(const pbmessages::NetworkChange_Network& nc, pbmessages::N } dns["servers"] = servers; } + else { + dns["servers"] = nlohmann::json::array(); + } dns["domain"] = nc.dns().domain(); out["dns"] = dns;