use std::sync::Mutex;
use actix_web::{error::ErrorBadRequest, web, Responder, ResponseError};
use serde::Deserialize;
use teloxide::{
types::{BusinessConnectionId, LinkPreviewOptions, MessageEntity, ParseMode, ReplyMarkup},
ApiError,
};
use super::{BodyChatId, BotApiError};
use crate::{
server::{routes::make_telegram_result, EditedMessageText},
state::State,
};
#[derive(Debug, Deserialize, Clone)]
pub struct EditMessageTextBody {
pub chat_id: Option<BodyChatId>,
pub message_id: Option<i32>,
pub inline_message_id: Option<String>,
pub text: String,
pub parse_mode: Option<ParseMode>,
pub entities: Option<Vec<MessageEntity>>,
pub link_preview_options: Option<LinkPreviewOptions>,
pub reply_markup: Option<ReplyMarkup>,
pub business_connection_id: Option<BusinessConnectionId>,
}
pub async fn edit_message_text(
body: web::Json<EditMessageTextBody>,
state: web::Data<Mutex<State>>,
) -> impl Responder {
match (
body.chat_id.clone(),
body.message_id,
body.inline_message_id.clone(),
) {
(Some(_), Some(message_id), None) => {
let mut lock = state.lock().unwrap();
let Some(old_message) = lock.messages.get_message(message_id) else {
return BotApiError::new(ApiError::MessageToEditNotFound).error_response();
};
let old_reply_markup = old_message
.reply_markup()
.map(|kb| ReplyMarkup::InlineKeyboard(kb.clone()));
if old_message.text() == Some(&body.text) && old_reply_markup == body.reply_markup {
return BotApiError::new(ApiError::MessageNotModified).error_response();
}
lock.messages
.edit_message_field(message_id, "text", body.text.clone());
lock.messages.edit_message_field(
message_id,
"entities",
body.entities.clone().unwrap_or(vec![]),
);
let message = lock
.messages
.edit_message_reply_markup(message_id, body.reply_markup.clone())
.unwrap();
lock.responses.edited_messages_text.push(EditedMessageText {
message: message.clone(),
bot_request: body.into_inner(),
});
make_telegram_result(message)
}
(None, None, Some(_)) => make_telegram_result(true),
_ => ErrorBadRequest("No message_id or inline_message_id were provided").into(),
}
}