From d8ea8b378cf2ee9ff7644fdb6c5a33d05923a51d Mon Sep 17 00:00:00 2001
From: Jason Volk <jason@zemos.net>
Date: Sat, 15 Mar 2025 02:35:10 +0000
Subject: [PATCH] add Map::clear() to db interface

Signed-off-by: Jason Volk <jason@zemos.net>
---
 src/database/map.rs       |  1 +
 src/database/map/clear.rs | 30 ++++++++++++++++++++++++++++++
 2 files changed, 31 insertions(+)
 create mode 100644 src/database/map/clear.rs

diff --git a/src/database/map.rs b/src/database/map.rs
index c5a908ba..ed38e1fc 100644
--- a/src/database/map.rs
+++ b/src/database/map.rs
@@ -1,3 +1,4 @@
+mod clear;
 pub mod compact;
 mod contains;
 mod count;
diff --git a/src/database/map/clear.rs b/src/database/map/clear.rs
new file mode 100644
index 00000000..321ec79c
--- /dev/null
+++ b/src/database/map/clear.rs
@@ -0,0 +1,30 @@
+use std::sync::Arc;
+
+use conduwuit::{
+	Result, implement,
+	utils::stream::{ReadyExt, TryIgnore},
+};
+use futures::{Stream, TryStreamExt};
+
+use crate::keyval::Key;
+
+/// Delete all data stored in this map. !!! USE WITH CAUTION !!!
+///
+/// See for_clear() with additional details.
+#[implement(super::Map)]
+#[tracing::instrument(level = "trace")]
+pub async fn clear(self: &Arc<Self>) {
+	self.for_clear().ignore_err().ready_for_each(|_| ()).await;
+}
+
+/// Delete all data stored in this map. !!! USE WITH CAUTION !!!
+///
+/// Provides stream of keys undergoing deletion along with any errors.
+///
+/// Note this operation applies to a snapshot of the data when invoked.
+/// Additional data written during or after this call may be missed.
+#[implement(super::Map)]
+#[tracing::instrument(level = "trace")]
+pub fn for_clear(self: &Arc<Self>) -> impl Stream<Item = Result<Key<'_>>> + Send {
+	self.raw_keys().inspect_ok(|key| self.remove(key))
+}