cf-mini-chat 0.1.31

Mini-chat module: multi-tenant AI chat
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35

use std::sync::Arc;

use axum::Extension;
use axum::extract::Path;
use modkit::api::prelude::*;
use modkit_security::SecurityContext;

use crate::api::rest::dto::{ReactionDto, SetReactionReq};
use crate::module::AppServices;

/// PUT /mini-chat/v1/chats/{id}/messages/{msg_id}/reaction
#[tracing::instrument(skip(svc, ctx, req_body), fields(chat_id = %chat_id, msg_id = %msg_id))]
pub(crate) async fn put_reaction(
    Extension(ctx): Extension<SecurityContext>,
    Extension(svc): Extension<Arc<AppServices>>,
    Path((chat_id, msg_id)): Path<(uuid::Uuid, uuid::Uuid)>,
    Json(req_body): Json<SetReactionReq>,
) -> ApiResult<JsonBody<ReactionDto>> {
    let result = svc
        .reactions
        .set_reaction(&ctx, chat_id, msg_id, &req_body.reaction)
        .await?;
    Ok(Json(ReactionDto::from(result)))
}

/// DELETE /mini-chat/v1/chats/{id}/messages/{msg_id}/reaction
#[tracing::instrument(skip(svc, ctx), fields(chat_id = %chat_id, msg_id = %msg_id))]
pub(crate) async fn delete_reaction(
    Extension(ctx): Extension<SecurityContext>,
    Extension(svc): Extension<Arc<AppServices>>,
    Path((chat_id, msg_id)): Path<(uuid::Uuid, uuid::Uuid)>,
) -> ApiResult<impl IntoResponse> {
    svc.reactions.delete_reaction(&ctx, chat_id, msg_id).await?;
    Ok(no_content().into_response())
}