diff --git a/src/handlers/proxy.rs b/src/handlers/proxy.rs index 34bb0fa..98c1c3f 100644 --- a/src/handlers/proxy.rs +++ b/src/handlers/proxy.rs @@ -104,14 +104,18 @@ pub async fn proxy_handler( { Ok(filedata) => { warn!("download stored_path from aws: {:?}", stored_path); - let _ = upload_to_s3( + if let Err(e) = upload_to_s3( &state.storj_client, &state.bucket, &filekey, filedata.clone(), content_type, ) - .await; + .await { + warn!("cannot upload to storj: {}", e); + } else { + warn!("file {} uploaded to storj", filekey); + } thumbdata_save(filedata.clone(), &state, &filekey, content_type.to_string()) .await; diff --git a/src/handlers/upload.rs b/src/handlers/upload.rs index 5de3eaf..7edfb59 100644 --- a/src/handlers/upload.rs +++ b/src/handlers/upload.rs @@ -1,5 +1,6 @@ use actix_multipart::Multipart; use actix_web::{web, HttpRequest, HttpResponse, Result}; +use log::warn; use crate::app_state::AppState; use crate::auth::{get_id_by_token, user_added_file}; @@ -60,14 +61,18 @@ pub async fn upload_handler( body = generate_key_with_extension(name, content_type.to_owned()); // Загружаем файл в S3 - upload_to_s3( + if let Err(e) = upload_to_s3( &state.storj_client, &state.bucket, &body, file_bytes, &content_type, ) - .await?; + .await { + warn!("cannot upload to storj: {}", e); + } else { + warn!("file {} uploaded to storj", body); + } // Сохраняем информацию о загруженном файле для пользователя user_added_file(&mut state.redis.clone(), &user_id, &body).await?;