summaryrefslogtreecommitdiff
path: root/shared/src/store.rs
diff options
context:
space:
mode:
authormetamuffin <metamuffin@disroot.org>2025-01-04 22:52:42 +0100
committermetamuffin <metamuffin@disroot.org>2025-01-04 22:52:42 +0100
commit2707f03617478e2a5e521961c46c9c6511d5088d (patch)
treea3516660f36614b006ea44eecf92bb4ff709fa3b /shared/src/store.rs
parent2c1d8fdfd65ceb9361114f0105c23ff6a94bac2e (diff)
downloadweareserver-2707f03617478e2a5e521961c46c9c6511d5088d.tar
weareserver-2707f03617478e2a5e521961c46c9c6511d5088d.tar.bz2
weareserver-2707f03617478e2a5e521961c46c9c6511d5088d.tar.zst
a
Diffstat (limited to 'shared/src/store.rs')
-rw-r--r--shared/src/store.rs33
1 files changed, 33 insertions, 0 deletions
diff --git a/shared/src/store.rs b/shared/src/store.rs
new file mode 100644
index 0000000..83f1a25
--- /dev/null
+++ b/shared/src/store.rs
@@ -0,0 +1,33 @@
+use crate::packets::Resource;
+use anyhow::Result;
+use redb::{Database, TableDefinition};
+use std::path::Path;
+
+const T_ENTRIES: TableDefinition<u128, &[u8]> = TableDefinition::new("e");
+
+pub struct ResourceStore {
+ db: Database,
+}
+impl ResourceStore {
+ pub fn new(path: &Path) -> Result<Self> {
+ Ok(Self {
+ db: Database::create(path)?,
+ })
+ }
+ pub fn get(&self, key: Resource) -> Result<Option<Vec<u8>>> {
+ let txn = self.db.begin_read()?;
+ let ent = txn.open_table(T_ENTRIES)?;
+ match ent.get(key.0)? {
+ Some(x) => Ok(Some(x.value().to_vec())),
+ None => Ok(None),
+ }
+ }
+ pub fn set(&self, key: Resource, value: &[u8]) -> Result<()> {
+ let txn = self.db.begin_write()?;
+ let mut ent = txn.open_table(T_ENTRIES)?;
+ ent.insert(key.0, value)?;
+ drop(ent);
+ txn.commit()?;
+ Ok(())
+ }
+}