Phase C5: ContentDeliveryManager and the control-layer facade

packages/streamr-dht/modules/dht/DhtNode.cppm

@@ -803,6 +803,18 @@ public:
         co_return co_await rpcRemote.storeData(key, data);
     }
 
+    // TS deleteDataFromDht: a DELETE_DATA recursive operation.
+    folly::coro::Task<void> deleteDataFromDht(
+        DhtAddress key, bool waitForCompletion) {
+        if (!this->abortController.getSignal().aborted) {
+            co_await this->recursiveOperationManager->execute(
+                std::move(key),
+                RecursiveOperation::DELETE_DATA,
+                std::nullopt,
+                waitForCompletion);
+        }
+    }
+
     folly::coro::Task<std::vector<DataEntry>> fetchDataFromDht(
         const DhtAddress& key) {
         co_return co_await this

packages/streamr-trackerless-network/CMakeLists.txt

@@ -183,6 +183,7 @@ if(NOT IOS AND STREAMR_MODULES_SUPPORTED)
         test/unit/NeighborUpdateRpcLocalTest.cpp
         test/unit/NeighborUpdateRpcRemoteTest.cpp
         test/unit/ContentDeliveryLayerNodeTest.cpp
+        test/unit/ContentDeliveryManagerTest.cpp
         test/unit/ContentDeliveryLayerNodeLayer1Test.cpp
         test/unit/PropagationScaleTest.cpp
     )

packages/streamr-trackerless-network/lint.sh

@@ -38,8 +38,12 @@ fi
 # ContentDeliveryLayerNodeTest.cpp (phase C3) trips the std-type
 # unification false positive on its own std::string locals; the
 # compiler builds and runs it.
+# ContentDeliveryManagerTest.cpp (phase C5) trips the same std-type
+# unification false positive inside the generated protobuf setter
+# (set_content -> ArenaStringPtr::SetBytes); the compiler builds and
+# runs it.
 TESTFILES=$(find test -type f \( -name "*.hpp" -o -name "*.cpp" \) -not -path '*/ts-integration/*' | sort | uniq | tr '\n' ' ')
-TIDY_TESTFILES=$(echo "$TESTFILES" | tr ' ' '\n' | grep -v 'test/unit/ContentDeliveryRpcRemoteTest.cpp' | grep -v 'test/unit/TemporaryConnectionRpcLocalTest.cpp' | grep -v 'test/unit/HandshakerTest.cpp' | grep -v 'test/unit/ContentDeliveryLayerNodeTest.cpp' | tr '\n' ' ')
+TIDY_TESTFILES=$(echo "$TESTFILES" | tr ' ' '\n' | grep -v 'test/unit/ContentDeliveryRpcRemoteTest.cpp' | grep -v 'test/unit/TemporaryConnectionRpcLocalTest.cpp' | grep -v 'test/unit/HandshakerTest.cpp' | grep -v 'test/unit/ContentDeliveryLayerNodeTest.cpp' | grep -v 'test/unit/ContentDeliveryManagerTest.cpp' | tr '\n' ' ')
 echo "Running clangd-tidy on $TIDY_TESTFILES"
 
 clangd-tidy -p "$COMPILE_DB" $TIDY_TESTFILES < /dev/null