diff options
Diffstat (limited to 'cache/src')
| -rw-r--r-- | cache/src/bin/cache_fs_to_rocksdb.rs | 38 | ||||
| -rw-r--r-- | cache/src/bin/cache_rocksdb_delete_prefix.rs | 25 | ||||
| -rw-r--r-- | cache/src/lib.rs | 8 |
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) } |