From db511d3fe50f05329615f718515fab1b80d9e06a Mon Sep 17 00:00:00 2001 From: metamuffin Date: Wed, 29 Jan 2025 18:03:06 +0100 Subject: no direct redb access --- server/src/routes/stream.rs | 20 ++++++++------------ 1 file changed, 8 insertions(+), 12 deletions(-) (limited to 'server/src/routes/stream.rs') diff --git a/server/src/routes/stream.rs b/server/src/routes/stream.rs index d057aa7..401faba 100644 --- a/server/src/routes/stream.rs +++ b/server/src/routes/stream.rs @@ -4,14 +4,9 @@ Copyright (C) 2025 metamuffin */ use super::ui::{account::session::Session, error::MyError}; -use crate::database::DataAcid; +use crate::database::Database; use anyhow::{anyhow, Result}; -use jellybase::{ - database::{TableExt, T_NODE}, - federation::Federation, - permission::{NodePermissionExt, PermissionSetExt}, - SECRETS, -}; +use jellybase::{federation::Federation, permission::PermissionSetExt, SECRETS}; use jellycommon::{ config::FederationAccount, stream::StreamSpec, @@ -48,15 +43,16 @@ pub async fn r_stream_head( pub async fn r_stream( session: Session, federation: &State, - db: &State, + db: &State, id: &str, range: Option, spec: StreamSpec, ) -> Result, MyError> { - let node = T_NODE - .get(db, id)? - .only_if_permitted(&session.user.permissions) + // TODO perm + let node = db + .get_node_slug(id)? .ok_or(anyhow!("node does not exist"))?; + let media = node .media .as_ref() @@ -71,7 +67,7 @@ pub async fn r_stream( .permissions .assert(&UserPermission::FederatedContent)?; - let track = &node.media.ok_or(anyhow!("no media"))?.tracks[ti]; + let track = &node.media.as_ref().ok_or(anyhow!("no media"))?.tracks[ti]; let host = track .federated .last() -- cgit v1.2.3-70-g09d2