aboutsummaryrefslogtreecommitdiff
path: root/server
diff options
context:
space:
mode:
authormetamuffin <metamuffin@disroot.org>2023-01-11 23:35:26 +0100
committermetamuffin <metamuffin@disroot.org>2023-01-11 23:35:26 +0100
commit047cb61bcf0ca61c58566ef5ca5d236234e46b21 (patch)
tree120e5097422900a9834422353fd115ef573c5073 /server
parentc52ee8ef7391a11ddbe64dacc37666eca9128deb (diff)
downloadjellything-047cb61bcf0ca61c58566ef5ca5d236234e46b21.tar
jellything-047cb61bcf0ca61c58566ef5ca5d236234e46b21.tar.bz2
jellything-047cb61bcf0ca61c58566ef5ca5d236234e46b21.tar.zst
it works!
Diffstat (limited to 'server')
-rw-r--r--server/src/main.rs8
1 files changed, 7 insertions, 1 deletions
diff --git a/server/src/main.rs b/server/src/main.rs
index 5a9c6cf..2fc6406 100644
--- a/server/src/main.rs
+++ b/server/src/main.rs
@@ -1,6 +1,7 @@
#![feature(box_syntax)]
use crate::frontend::{pages::MyError, style::CSS_BUNDLE};
+use anyhow::anyhow;
use database::Database;
use frontend::pages::{home::page_home, node::page_library_node};
use jellyremuxer::{RemuxerContext, SendWriter};
@@ -44,6 +45,11 @@ fn stream(
let (a, b) = duplex(8196);
let item = state.library.nested("mili-bento-box-bivouac")?.get_item()?;
let remuxer = state.remuxer.clone();
+ let selection = selection
+ .split(",")
+ .map(|e| e.parse().map_err(|_| anyhow!("invalid number")))
+ .into_iter()
+ .collect::<Result<Vec<_>, _>>()?;
let b = SyncIoBridge::new(b);
tokio::task::spawn_blocking(move || {
@@ -51,7 +57,7 @@ fn stream(
b,
item.fs_path.parent().unwrap().to_path_buf(),
item.data.clone(),
- selection.split(",").map(|e| e.parse().unwrap()).collect(),
+ selection,
) {
warn!("stream stopped: {e}")
}