From e2816f6bd5fcd52a1d3b9f2606dabb686292f9cb Mon Sep 17 00:00:00 2001
From: Doug Hoyte <doug@hcsw.org>
Date: Mon, 5 Jun 2023 11:36:31 -0400
Subject: [PATCH] foreachByFilter feature

---
 src/DBQuery.h | 9 +++++++++
 1 file changed, 9 insertions(+)

diff --git a/src/DBQuery.h b/src/DBQuery.h
index 6a76d03..e4cbdfe 100644
--- a/src/DBQuery.h
+++ b/src/DBQuery.h
@@ -382,3 +382,12 @@ struct DBQuery : NonCopyable {
         return true;
     }
 };
+
+
+inline void foreachByFilter(lmdb::txn &txn, const tao::json::value &filter, std::function<void(uint64_t, std::string_view)> cb) {
+    DBQuery query(filter);
+
+    query.process(txn, [&](const auto &, uint64_t levId, std::string_view eventPayload){
+        cb(levId, eventPayload);
+    });
+}