From bfcafb5eea5f9513ce85d526caa09e69f96d5997 Mon Sep 17 00:00:00 2001 From: Kroese Date: Mon, 9 Dec 2024 16:14:14 +0100 Subject: [PATCH 1/2] Update cmd_stream.cpp --- src/apps/mesh/cmd_stream.cpp | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/apps/mesh/cmd_stream.cpp b/src/apps/mesh/cmd_stream.cpp index 17c2d50..3db92c3 100644 --- a/src/apps/mesh/cmd_stream.cpp +++ b/src/apps/mesh/cmd_stream.cpp @@ -68,7 +68,7 @@ void cmd_stream(const std::vector &subArgs) { auto &evJson = origJson.at(2); std::string okMsg; - auto res = writePolicyPlugin.acceptEvent(cfg().relay__writePolicy__plugin, evJson, EventSourceType::Stream, ws.remoteAddr, okMsg); + auto res = writePolicyPlugin.acceptEvent(cfg().relay__writePolicy__plugin, evJson, EventSourceType::Stream, url, okMsg); if (res == PluginEventSifterResult::Accept) { downloadedIds.emplace(from_hex(evJson.at("id").get_string())); writer.write({ std::move(evJson), }); From 9ba0626993a0bf38eb87fc3f57a610083f6d478d Mon Sep 17 00:00:00 2001 From: Kroese Date: Mon, 9 Dec 2024 16:14:40 +0100 Subject: [PATCH 2/2] Update cmd_sync.cpp --- src/apps/mesh/cmd_sync.cpp | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/apps/mesh/cmd_sync.cpp b/src/apps/mesh/cmd_sync.cpp index 6a38ce8..9cdfe70 100644 --- a/src/apps/mesh/cmd_sync.cpp +++ b/src/apps/mesh/cmd_sync.cpp @@ -237,7 +237,7 @@ void cmd_sync(const std::vector &subArgs) { auto &evJson = msg.at(2); std::string okMsg; - auto res = writePolicyPlugin.acceptEvent(cfg().relay__writePolicy__plugin, evJson, EventSourceType::Sync, ws.remoteAddr, okMsg); + auto res = writePolicyPlugin.acceptEvent(cfg().relay__writePolicy__plugin, evJson, EventSourceType::Sync, url, okMsg); if (res == PluginEventSifterResult::Accept) { writer.write({ std::move(evJson), }); } else {