main
use ::session::AuthedUser;
use actix_web::http::header::CONTENT_TYPE;
use api::http::{Bytes, HeaderMap, State};
use api::rest::{AppResponseData, NoData};
use crate::errors::ApiError;
use crate::services::avatar::AvatarDto;
use crate::services::service::UserService;
#[utoipa::path(
put,
path = "/me/avatar",
tag = "user",
description = "上传原始图片字节作为当前用户头像。",
request_body(
content = Vec<u8>,
description = "raw image bytes (image/jpeg, image/png, image/webp, image/gif)",
content_type = "image/png"
),
responses(
(status = 200, description = "avatar uploaded", body = AppResponseData<AvatarDto>),
(status = 400, description = "bad request", body = AppResponseData<NoData>),
(status = 401, description = "authentication required", body = AppResponseData<NoData>)
)
)]
pub async fn upload_avatar(
State(service): State<UserService>,
AuthedUser(uid): AuthedUser,
headers: HeaderMap,
body: Bytes,
) -> Result<AppResponseData<AvatarDto>, ApiError> {
let content_type = headers
.get(CONTENT_TYPE)
.and_then(|v| v.to_str().ok())
.unwrap_or("application/octet-stream")
.to_string();
let dto = service
.avatars
.upload_avatar_stream(uid, &content_type, &body)
.await?;
Ok(AppResponseData::ok(dto))
}