chk
/
AppFlowy-Cloud
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

fix: result return from put blob

This commit is contained in:
Fu Zi Xiang 2024-01-13 00:53:41 +08:00
parent 851cd6929e
commit 8ba4559cbd
No known key found for this signature in database
1 changed files with 2 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
src/api/file_storage.rs
View File

@ -13,7 +13,6 @@ use app_error::AppError;
use chrono::DateTime; use chrono::DateTime;
use database::file::{MAX_BLOB_SIZE, MAX_USAGE}; use database::file::{MAX_BLOB_SIZE, MAX_USAGE};
use database::resource_usage::{get_all_workspace_blob_metadata, get_workspace_usage_size}; use database::resource_usage::{get_all_workspace_blob_metadata, get_workspace_usage_size};
use database_entity::dto::AFBlobRecord;
use shared_entity::dto::workspace_dto::{BlobMetadata, RepeatedBlobMetaData, WorkspaceSpaceUsage}; use shared_entity::dto::workspace_dto::{BlobMetadata, RepeatedBlobMetaData, WorkspaceSpaceUsage};
use shared_entity::response::{AppResponse, AppResponseError, JsonAppResponse}; use shared_entity::response::{AppResponse, AppResponseError, JsonAppResponse};
use sqlx::types::Uuid; use sqlx::types::Uuid;
@ -53,7 +52,7 @@ async fn put_blob_handler(
content_type: web::Header<ContentType>, content_type: web::Header<ContentType>,
content_length: web::Header<ContentLength>, content_length: web::Header<ContentLength>,
payload: Payload, payload: Payload,
) -> Result<JsonAppResponse<AFBlobRecord>> { ) -> Result<JsonAppResponse<()>> {
let (workspace_id, file_id) = path.into_inner(); let (workspace_id, file_id) = path.into_inner();
let content_length = content_length.into_inner().into_inner(); let content_length = content_length.into_inner().into_inner();
let content_type = content_type.into_inner().to_string(); let content_type = content_type.into_inner().to_string();
@ -103,9 +102,7 @@ async fn put_blob_handler(
.await .await
.map_err(AppResponseError::from)?; .map_err(AppResponseError::from)?;
let record = AFBlobRecord::new(file_id); Ok(AppResponse::Ok().into())
event!(tracing::Level::TRACE, "did put blob: {:?}", record);
Ok(Json(AppResponse::Ok().with_data(record)))
} }
#[instrument(level = "debug", skip(state), err)] #[instrument(level = "debug", skip(state), err)]