Skip to content

Commit 54da4a7

Browse files
authored
Merge pull request #131 from opslag/master
feat: Make relay URL available in plugin
2 parents baf3ec5 + 9ba0626 commit 54da4a7

File tree

2 files changed

+2
-2
lines changed

2 files changed

+2
-2
lines changed

src/apps/mesh/cmd_stream.cpp

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -68,7 +68,7 @@ void cmd_stream(const std::vector<std::string> &subArgs) {
6868
auto &evJson = origJson.at(2);
6969

7070
std::string okMsg;
71-
auto res = writePolicyPlugin.acceptEvent(cfg().relay__writePolicy__plugin, evJson, EventSourceType::Stream, ws.remoteAddr, okMsg);
71+
auto res = writePolicyPlugin.acceptEvent(cfg().relay__writePolicy__plugin, evJson, EventSourceType::Stream, url, okMsg);
7272
if (res == PluginEventSifterResult::Accept) {
7373
downloadedIds.emplace(from_hex(evJson.at("id").get_string()));
7474
writer.write({ std::move(evJson), });

src/apps/mesh/cmd_sync.cpp

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -237,7 +237,7 @@ void cmd_sync(const std::vector<std::string> &subArgs) {
237237
auto &evJson = msg.at(2);
238238

239239
std::string okMsg;
240-
auto res = writePolicyPlugin.acceptEvent(cfg().relay__writePolicy__plugin, evJson, EventSourceType::Sync, ws.remoteAddr, okMsg);
240+
auto res = writePolicyPlugin.acceptEvent(cfg().relay__writePolicy__plugin, evJson, EventSourceType::Sync, url, okMsg);
241241
if (res == PluginEventSifterResult::Accept) {
242242
writer.write({ std::move(evJson), });
243243
} else {

0 commit comments

Comments
 (0)