use actix_web::{HttpResponse, web}; use serde::Deserialize; use utoipa::IntoParams; use crate::api::response::{ApiErrorResponse, ApiResponse}; use crate::error::AppError; use crate::models::base_info::resolve_users; use crate::models::channels::ChannelDetail; use crate::service::AppService; use crate::service::im::ImSession; use crate::service::im::channels::UpdateChannelParams; use crate::session::Session; #[derive(Debug, Deserialize, IntoParams)] pub struct PathParams { pub workspace_name: String, pub channel_id: uuid::Uuid, } /// Update a channel #[utoipa::path( put, path = "/api/v1/im/workspaces/{workspace_name}/channels/{channel_id}", tag = "IM", operation_id = "imChannelUpdate", params(PathParams), request_body( content = UpdateChannelParams, description = "Channel update parameters", content_type = "application/json" ), responses( (status = 200, description = "Channel updated successfully", body = ApiResponse), (status = 400, description = "Invalid parameters", body = ApiErrorResponse), (status = 401, description = "Authentication required", body = ApiErrorResponse), (status = 404, description = "Workspace or channel not found", body = ApiErrorResponse), (status = 500, description = "Internal server error", body = ApiErrorResponse), ), security(("session_cookie" = [])) )] pub async fn channel_update( service: web::Data, session: Session, path: web::Path, params: web::Json, ) -> Result { let user_id = session.user().ok_or(AppError::Unauthorized)?; let im_session = ImSession::new(user_id); let request_id = uuid::Uuid::now_v7(); let channel = service .im .channel_update( &im_session, &path.workspace_name, path.channel_id, params.into_inner(), request_id, ) .await?; let db = &service.ctx.db; let users = resolve_users(db, &[channel.created_by]).await?; let creator = users.get(&channel.created_by).cloned().unwrap_or_default(); let detail = channel.into_detail(creator); Ok(HttpResponse::Ok().json(ApiResponse::new(detail))) }