aboutsummaryrefslogtreecommitdiff
path: root/cache/src
diff options
context:
space:
mode:
Diffstat (limited to 'cache/src')
-rw-r--r--cache/src/bin/cache_fs_to_rocksdb.rs38
-rw-r--r--cache/src/bin/cache_rocksdb_delete_prefix.rs25
-rw-r--r--cache/src/lib.rs8
3 files changed, 2 insertions, 69 deletions
diff --git a/cache/src/bin/cache_fs_to_rocksdb.rs b/cache/src/bin/cache_fs_to_rocksdb.rs
deleted file mode 100644
index d283dcb..0000000
--- a/cache/src/bin/cache_fs_to_rocksdb.rs
+++ /dev/null
@@ -1,38 +0,0 @@
-/*
- This file is part of jellything (https://codeberg.org/metamuffin/jellything)
- which is licensed under the GNU Affero General Public License (version 3); see /COPYING.
- Copyright (C) 2026 metamuffin <metamuffin.org>
-*/
-
-use anyhow::{Result, bail};
-use rocksdb::DB;
-use std::{env::args, fs::File, io::Read, path::Path};
-
-fn main() -> Result<()> {
- let in_path = args().nth(1).unwrap();
- let out_path = args().nth(2).unwrap();
- let db = DB::open_default(out_path)?;
- if !in_path.ends_with("/") {
- bail!("path needs to end with /")
- }
- traverse(&db, &in_path, in_path.as_ref())?;
- db.flush()?;
- Ok(())
-}
-
-fn traverse(db: &DB, prefix: &str, path: &Path) -> Result<()> {
- if path.is_dir() {
- for e in path.read_dir()? {
- traverse(db, prefix, &e?.path())?;
- }
- }
- if path.is_file() {
- let key = path.to_string_lossy();
- let key = key.strip_prefix(prefix).unwrap();
- let mut value = Vec::new();
- File::open(path)?.read_to_end(&mut value)?;
- println!("{key}");
- db.put(key, value)?;
- }
- Ok(())
-}
diff --git a/cache/src/bin/cache_rocksdb_delete_prefix.rs b/cache/src/bin/cache_rocksdb_delete_prefix.rs
deleted file mode 100644
index e09ce61..0000000
--- a/cache/src/bin/cache_rocksdb_delete_prefix.rs
+++ /dev/null
@@ -1,25 +0,0 @@
-/*
- This file is part of jellything (https://codeberg.org/metamuffin/jellything)
- which is licensed under the GNU Affero General Public License (version 3); see /COPYING.
- Copyright (C) 2026 metamuffin <metamuffin.org>
-*/
-
-use anyhow::Result;
-use rocksdb::DB;
-use std::env::args;
-
-fn main() -> Result<()> {
- let db = DB::open_default(args().nth(1).unwrap())?;
- let prefix = args().nth(2).unwrap();
- for r in db.prefix_iterator(&prefix) {
- let key = r?.0;
- let key_s = String::from_utf8_lossy(&key);
- if !key_s.starts_with(&prefix) {
- break;
- }
- println!("{key_s}");
- db.delete(key)?;
- }
- db.flush()?;
- Ok(())
-}
diff --git a/cache/src/lib.rs b/cache/src/lib.rs
index be2b331..4d6bbcf 100644
--- a/cache/src/lib.rs
+++ b/cache/src/lib.rs
@@ -81,14 +81,10 @@ impl Cache {
Ok(out)
}
- pub fn cache_read(&self, key: &str) -> Result<Option<Vec<u8>>> {
+ pub fn read(&self, key: &str) -> Result<Option<Vec<u8>>> {
self.storage.read(key)
}
- pub fn cache_store(
- &self,
- key: String,
- generate: impl FnOnce() -> Result<Vec<u8>>,
- ) -> Result<String> {
+ pub fn store(&self, key: String, generate: impl FnOnce() -> Result<Vec<u8>>) -> Result<String> {
self.cache(&key, generate)?;
Ok(key)
}