Green-Sky/solanaceae_zox
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

dont sync messages not witnessed by self

Browse Source
This commit is contained in:
Green Sky 2023-12-02 18:55:11 +01:00
parent c9c3c1ff7f
commit 5759c15716
No known key found for this signature in database
1 changed files with 20 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

21
solanaceae/zox/ngc_hs.cpp
View File

@ -12,6 +12,7 @@
#include <iostream> #include <iostream>
#include <variant> #include <variant>
#include <vector> #include <vector>
#include <algorithm>
void ZoxNGCHistorySync::subscribeToEvents(void) { void ZoxNGCHistorySync::subscribeToEvents(void) {
_zngcepi.subscribe(this, ZoxNGC_Event::ngch_request); _zngcepi.subscribe(this, ZoxNGC_Event::ngch_request);
@ -265,9 +266,27 @@ bool ZoxNGCHistorySync::onEvent(const Events::ZoxNGC_ngch_request& e) {
} }
if (ts.ts < ts_start) { if (ts.ts < ts_start) {
std::cout << "---- " << ts.ts << " < " << ts_start << " -> too old\n"; //std::cout << "---- " << ts.ts << " < " << ts_start << " -> too old\n";
return; return;
} }
if (reg.all_of<Message::Components::SyncedBy>(e)) {
const auto& list = reg.get<Message::Components::SyncedBy>(e).list;
if (
std::find_if(
list.cbegin(), list.cend(),
[this](const auto& it) {
// TODO: add weak self
return _cr.all_of<Contact::Components::TagSelfStrong>(it);
}
) == list.cend()
) {
// self not found
// TODO: config for self only
return;
}
}
std::cout << "---- " << ts.ts << " >= " << ts_start << " -> selected\n"; std::cout << "---- " << ts.ts << " >= " << ts_start << " -> selected\n";
msg_send_queue.push(e); msg_send_queue.push(e);