use super::{GroupMessageUser, MessageAttachment, MessageReference};
use crate::models::{Snowflake, Timestamp};
use serde::{Deserialize, Serialize};
use crate::models::message::GroupMessageParams;
#[derive(Debug, Clone, PartialEq, Serialize, Deserialize)]
pub struct GroupMessage {
pub id: Option<Snowflake>,
pub content: Option<String>,
pub message_reference: Option<MessageReference>,
#[serde(default)]
pub mentions: Vec<GroupMessageUser>,
#[serde(default)]
pub attachments: Vec<MessageAttachment>,
pub msg_seq: Option<u64>,
pub timestamp: Option<Timestamp>,
pub author: Option<GroupMessageUser>,
pub group_openid: Option<String>,
#[serde(skip)]
pub event_id: Option<String>,
}
impl GroupMessage {
pub fn new() -> Self {
Self {
id: None,
content: None,
message_reference: None,
mentions: Vec::new(),
attachments: Vec::new(),
msg_seq: None,
timestamp: None,
author: None,
group_openid: None,
event_id: None,
}
}
pub fn from_data(_api: crate::api::BotApi, event_id: String, data: serde_json::Value) -> Self {
let mut message: Self = serde_json::from_value(data).unwrap_or_default();
message.event_id = Some(event_id);
message
}
pub async fn reply(
&self,
api: &crate::api::BotApi,
token: &crate::token::Token,
content: &str,
) -> Result<crate::models::api::MessageResponse, crate::error::BotError> {
if let (Some(group_openid), Some(msg_id)) = (&self.group_openid, &self.id) {
let params = GroupMessageParams {
msg_type: 0,
content: Some(content.to_string()),
msg_id: Some(msg_id.clone()),
event_id: self.event_id.clone(),
..Default::default()
};
api.post_group_message_with_params(token, group_openid, params)
.await
} else {
Err(crate::error::BotError::InvalidData(
"Missing group_openid or message_id for reply".to_string(),
))
}
}
}
impl Default for GroupMessage {
fn default() -> Self {
Self::new()
}
}