From d4937ca0ec2cdf08bcfc212e121a8d44b0dbf3ba Mon Sep 17 00:00:00 2001 From: Diego Imbert Date: Wed, 6 Aug 2025 13:02:52 +0200 Subject: [PATCH] nit --- backend/windmill-api/src/s3_proxy.rs | 20 +++----------------- 1 file changed, 3 insertions(+), 17 deletions(-) diff --git a/backend/windmill-api/src/s3_proxy.rs b/backend/windmill-api/src/s3_proxy.rs index 91f6a20d14..90de126187 100644 --- a/backend/windmill-api/src/s3_proxy.rs +++ b/backend/windmill-api/src/s3_proxy.rs @@ -21,11 +21,8 @@ pub fn workspaced_unauthed_service() -> Router { } async fn get_object( - // authed: ApiAuthed, Extension(db): Extension, - // Extension(user_db): Extension, Path((w_id, storage, file_key)): Path<(String, String, String)>, - // Tokened { token }: Tokened, ) -> Result { let storage = if storage.is_empty() { None @@ -37,31 +34,20 @@ async fn get_object( let Tokened { token } = Tokened { token: "".to_string() }; let user_db: Option = None; let authed = ApiAuthed { - email: "backend".to_string(), - username: "backend".to_string(), + email: "s3_proxy".to_string(), + username: "s3_proxy".to_string(), is_admin: true, - is_operator: false, - groups: vec![], - folders: vec![], - scopes: None, - username_override: None, - token_prefix: None, + ..Default::default() }; let (_, s3_resource) = get_workspace_s3_resource(&authed, &db, user_db, &token, &w_id, storage).await?; - let s3_resource = s3_resource.ok_or(Error::InternalErr( "No files storage resource defined at the workspace level".to_string(), ))?; - let s3_client = build_object_store_client(&s3_resource).await?; - let result = read_object_streamable(s3_client, &file_key).await?; - let stream = result.into_stream(); - let stream_body = axum::body::Body::from_stream(stream); - Ok(stream_body.into_response()) }