cache as object

1 files changed, 26 insertions, 25 deletions

diff --git a/transcoder/src/thumbnail.rs b/transcoder/src/thumbnail.rs
index 85cb356..9207c30 100644
--- a/transcoder/src/thumbnail.rs
+++ b/transcoder/src/thumbnail.rs
@@ -1,5 +1,5 @@
 use anyhow::{Context, Result};
-use jellycache::{cache_store, HashKey};
+use jellycache::{Cache, HashKey};
 use log::info;
 use std::{
     io::Read,
@@ -7,31 +7,32 @@ use std::{
     process::{Command, Stdio},
 };
 
-pub fn create_thumbnail(path: &Path, time: f64) -> Result<String> {
-    cache_store(
-        format!("media/thumbnail/{}-{}.image", HashKey(path), time as i64),
-        move || {
-            info!("creating thumbnail of {path:?} at {time}s",);
+pub fn create_thumbnail(cache: &Cache, path: &Path, time: f64) -> Result<String> {
+    cache
+        .store(
+            format!("media/thumbnail/{}-{}.image", HashKey(path), time as i64),
+            move || {
+                info!("creating thumbnail of {path:?} at {time}s",);
 
-            let mut proc = Command::new("ffmpeg")
-                .stdout(Stdio::piped())
-                .args(["-ss", &format!("{time}")])
-                .args(["-f", "matroska", "-i", path.to_str().unwrap()])
-                .args(["-frames:v", "1"])
-                .args(["-c:v", "qoi"])
-                .args(["-f", "image2"])
-                .args(["-update", "1"])
-                .arg("pipe:1")
-                .spawn()?;
+                let mut proc = Command::new("ffmpeg")
+                    .stdout(Stdio::piped())
+                    .args(["-ss", &format!("{time}")])
+                    .args(["-f", "matroska", "-i", path.to_str().unwrap()])
+                    .args(["-frames:v", "1"])
+                    .args(["-c:v", "qoi"])
+                    .args(["-f", "image2"])
+                    .args(["-update", "1"])
+                    .arg("pipe:1")
+                    .spawn()?;
 
-            let mut stdout = proc.stdout.take().unwrap();
-            let mut output = Vec::new();
-            stdout.read_to_end(&mut output)?;
+                let mut stdout = proc.stdout.take().unwrap();
+                let mut output = Vec::new();
+                stdout.read_to_end(&mut output)?;
 
-            proc.wait().unwrap().exit_ok()?;
-            info!("done");
-            Ok(output)
-        },
-    )
-    .context("creating thumbnail")
+                proc.wait().unwrap().exit_ok()?;
+                info!("done");
+                Ok(output)
+            },
+        )
+        .context("creating thumbnail")
 }