Working in sled

crates/storage/Cargo.toml

@@ -10,3 +10,4 @@ thiserror = "1.0.40"
 rocksdb = { version = "0.20.1", features = ["multi-threaded-cf", "serde", "snappy"] }
 rand = "0.8.5"
 chrono = "0.4.26"
+sled = "0.34.7"

crates/storage/src/lib.rs

@@ -11,6 +11,7 @@ mod error;
 mod event_filter;
 mod rocksdb;
 mod secondary_index;
+mod sled;
 mod storage;
 
 pub use crate::{error::Error, rocksdb::RocksDb, storage::Storage};

crates/storage/src/rocksdb/mod.rs

@@ -1,5 +1,5 @@
 //! Rocks DB implementation of the storage layer
-use self::iterators::WrapperIterator;
+use self::iterator::WrapperIterator;
 use crate::{secondary_index::SecondaryIndex, Error, Storage};
 use nostr_rs_types::types::{Event, Filter, Tag};
 use rocksdb::{
@@ -8,7 +8,7 @@ use rocksdb::{
 };
 use std::{collections::VecDeque, ops::Deref, path::Path, sync::Arc};
 
-mod iterators;
+mod iterator;
 
 #[derive(Debug, Clone, Copy, PartialEq, Eq, PartialOrd, Ord, Hash)]
 enum ReferenceType {

crates/storage/src/sled/iterator.rs

@@ -0,0 +1,3 @@
+pub struct WrapperIterator {}
+
+impl Iterator for WrapperIterator {}

crates/storage/src/sled/mod.rs

@@ -0,0 +1,25 @@
+use self::iterator::WrapperIterator;
+use crate::Storage;
+
+mod iterator;
+
+pub struct Sled {
+    db: sled::Db,
+}
+
+impl Sled {
+    pub fn new() -> Self {
+        Self {
+            db: sled::open("my_db").unwrap(),
+        }
+    }
+}
+
+impl<'a> Storage<'a, WrapperIterator<'a>> for Sled {
+    fn get_by_filter(
+        &'a self,
+        query: nostr_rs_types::types::Filter,
+    ) -> Result<WrapperIterator<'a>, crate::Error> {
+        Ok(WrapperIterator::new(self, query))
+    }
+}