flibusta-apps/telegram_files_server
1
0
Fork 0
mirror of https://github.com/flibusta-apps/telegram_files_server.git synced 2025-12-06 12:35:39 +01:00
Code Issues Actions Packages Projects Releases Wiki Activity

Fix

Browse Source
This commit is contained in:
Bulat Kurbanov
2024-05-06 22:21:25 +02:00
parent 6f073eb304
commit e6e3b0aa6a
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
src/core/views.rs
View File

@@ -44,7 +44,7 @@ pub async fn get_router() -> Router {
let (prometheus_layer, metric_handle) = PrometheusMetricLayer::pair(); let (prometheus_layer, metric_handle) = PrometheusMetricLayer::pair();
let app_router = Router::new() let app_router = Router::new()
.route("/upload", post(upload)) .route("/upload/", post(upload))
.route("/download_by_message/:chat_id/:message_id", get(download)) .route("/download_by_message/:chat_id/:message_id", get(download))
.layer(DefaultBodyLimit::max(BODY_LIMIT)) .layer(DefaultBodyLimit::max(BODY_LIMIT))
.layer(middleware::from_fn(auth)) .layer(middleware::from_fn(auth))
@@ -90,7 +90,7 @@ async fn upload(data: TypedMultipart<UploadFileRequest>) -> impl IntoResponse {
async fn download(Path(chat_id): Path<i64>, Path(message_id): Path<i32>) -> impl IntoResponse { async fn download(Path(chat_id): Path<i64>, Path(message_id): Path<i32>) -> impl IntoResponse {
let downloader = download_file(chat_id, message_id).await; let downloader = download_file(chat_id, message_id).await;
let data = match downloader { let data = match downloader {
Some(v) => v.get_async_read(), Some(v) => v.get_async_read(),
@@ -98,6 +98,6 @@ async fn download(Path(chat_id): Path<i64>, Path(message_id): Path<i32>) -> impl
}; };
let reader = ReaderStream::new(data); let reader = ReaderStream::new(data);
axum::body::Body::from_stream(reader).into_response() axum::body::Body::from_stream(reader).into_response()
} }