diff --git a/src/apps/mesh/cmd_sync.cpp b/src/apps/mesh/cmd_sync.cpp index a677eb6..9b017cb 100644 --- a/src/apps/mesh/cmd_sync.cpp +++ b/src/apps/mesh/cmd_sync.cpp @@ -76,7 +76,8 @@ void cmd_sync(const std::vector &subArgs) { for (auto levId : levIds) { auto ev = lookupEventByLevId(txn, levId); - storageVector.insert(packed.created_at(), packed.id().substr(0, ne.idSize)); + PackedEventView packed(ev.buf); + storageVector.insert(packed.created_at(), packed.id()); } LI << "Filter matches " << numEvents << " events"; diff --git a/src/apps/relay/RelayNegentropy.cpp b/src/apps/relay/RelayNegentropy.cpp index 23cf2d1..12d198e 100644 --- a/src/apps/relay/RelayNegentropy.cpp +++ b/src/apps/relay/RelayNegentropy.cpp @@ -161,7 +161,8 @@ void RelayServer::runNegentropy(ThreadPool::Thread &thr) { for (auto levId : view->levIds) { try { auto ev = lookupEventByLevId(txn, levId); - view->storageVector.insert(packed.created_at(), packed.id().substr(0, view->ne.idSize)); + PackedEventView packed(ev.buf); + view->storageVector.insert(packed.created_at(), packed.id()); } catch (std::exception &) { // levId was deleted when query was paused } diff --git a/src/events.cpp b/src/events.cpp index ee64ee2..893ac26 100644 --- a/src/events.cpp +++ b/src/events.cpp @@ -231,9 +231,9 @@ std::string_view getEventJson(lmdb::txn &txn, Decompressor &decomp, uint64_t lev bool deleteEvent(lmdb::txn &txn, uint64_t levId, negentropy::storage::BTreeLMDB &negentropyStorage) { auto view = env.lookup_Event(txn, levId); if (!view) return false; - auto *flat = view->flat_nested(); + PackedEventView packed(view->buf); - negentropyStorage.erase(flat->created_at(), sv(flat->id())); + negentropyStorage.erase(packed.created_at(), packed.id()); bool deleted = env.dbi_EventPayload.del(txn, lmdb::to_sv(levId)); env.delete_Event(txn, levId);