use serde::{Deserialize, Serialize};
use crate::event::{context::EventHeader, dispatcher::EventHandler};
#[derive(Debug, Serialize, Deserialize)]
pub struct P2ImChatCreatedV1 {
pub schema: String,
pub header: EventHeader,
pub event: P2ImChatCreatedV1Data,
}
pub(crate) struct P2ImChatCreatedV1ProcessorImpl<F>
where
F: Fn(P2ImChatCreatedV1) + 'static,
{
f: F,
}
impl<F> EventHandler for P2ImChatCreatedV1ProcessorImpl<F>
where
F: Fn(P2ImChatCreatedV1) + 'static + Sync + Send,
{
fn handle(&self, payload: &[u8]) -> anyhow::Result<()> {
let message: P2ImChatCreatedV1 = serde_json::from_slice(payload)?;
(self.f)(message);
Ok(())
}
}
impl<F> P2ImChatCreatedV1ProcessorImpl<F>
where
F: Fn(P2ImChatCreatedV1) + 'static,
{
pub(crate) fn new(f: F) -> Self {
P2ImChatCreatedV1ProcessorImpl { f }
}
}
#[derive(Debug, Serialize, Deserialize)]
pub struct P2ImChatCreatedV1Data {
pub chat_id: String,
pub chat_type: String,
pub creator: EventUser,
#[serde(skip_serializing_if = "Option::is_none")]
pub name: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub description: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub avatar: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub chat_settings: Option<ChatSettings>,
#[serde(skip_serializing_if = "Option::is_none")]
pub members: Option<Vec<ChatMember>>,
pub create_time: String,
}
#[derive(Debug, Serialize, Deserialize)]
pub struct EventUser {
pub user_id: UserId,
#[serde(skip_serializing_if = "Option::is_none")]
pub name: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub user_type: Option<String>,
}
#[derive(Debug, Serialize, Deserialize)]
pub struct ChatSettings {
#[serde(skip_serializing_if = "Option::is_none")]
pub at_all_permission: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub add_member_permission: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub only_owner_add: Option<bool>,
#[serde(skip_serializing_if = "Option::is_none")]
pub share_allowed: Option<bool>,
}
#[derive(Debug, Serialize, Deserialize)]
pub struct ChatMember {
pub user_id: UserId,
#[serde(skip_serializing_if = "Option::is_none")]
pub member_type: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub role: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub join_time: Option<String>,
}
#[derive(Debug, Serialize, Deserialize)]
pub struct UserId {
#[serde(skip_serializing_if = "Option::is_none")]
pub union_id: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub user_id: Option<String>,
pub open_id: String,
}