main
mod common;
mod gitdata;
mod kenshell;
mod platform_events;
mod properties;
pub use common::{EventContext, action};
pub use properties::EventProperties;
use serde_json::Value;
use crate::EventKind;
use crate::gateway::Subscription;
/// 网关支持订阅的 (项目前缀, area, tag) 全集：本仓库事件来自 `EventKind`，
/// kenshell 事件由对端仓库产生，这里是唯一的外来清单。
const KENSHELL: &[(&str, &str)] = &[
("repo", "create"),
("repo", "update"),
("repo", "delete"),
("repo", "placement-change"),
("repo", "language-update"),
("ref", "create-branch"),
("ref", "update-branch"),
("ref", "delete-branch"),
("ref", "rename-branch"),
("ref", "set-default-branch"),
("ref", "create-tag"),
("ref", "delete-tag"),
("ref", "create-protection"),
("ref", "delete-protection"),
("commit", "sync"),
("commit", "set-status"),
("commit", "comment-create"),
("commit", "comment-update"),
("commit", "comment-delete"),
("lfs", "upload"),
("lfs", "unreference"),
("lfs", "purge"),
("archive", "create"),
("job", "enqueue"),
("job", "claim"),
("job", "progress"),
("job", "heartbeat"),
("job", "cancel"),
("job", "retry"),
("job", "finish"),
("node", "create"),
("node", "update"),
("node", "delete"),
("node", "probe"),
("volume", "create"),
("volume", "update"),
("volume", "delete"),
("volume", "mount"),
("volume", "unmount"),
("volume", "probe"),
];
pub(crate) fn catalog() -> impl Iterator<Item = (&'static str, &'static str, &'static str)> {
EventKind::ALL
.iter()
.flat_map(|kind| {
kind.tags()
.iter()
.map(move |tag| ("gitdata", kind.topic(), *tag))
})
.chain(KENSHELL.iter().map(|(area, tag)| ("kenshell", *area, *tag)))
}
pub(crate) fn split_topic(topic: &str) -> Option<(&str, &str)> {
config::event::consumer::DEFAULT_TOPIC_PREFIXES
.iter()
.find_map(|prefix| {
topic
.strip_prefix(prefix)
.and_then(|rest| rest.strip_prefix('-'))
.map(|area| (*prefix, area))
})
}
pub(crate) fn identity_area(area: &str) -> bool {
EventKind::ALL
.iter()
.any(|kind| kind.topic() == area && kind.identity())
}
pub(crate) fn personal(area: &str, tag: &str) -> bool {
EventKind::ALL
.iter()
.any(|kind| kind.topic() == area && kind.personal() && kind.tags().contains(&tag))
}
/// 与 MQ 扇出一致的下行 payload 形状（可选附带命中的订阅列表）。
pub fn common_payload(
topic: &str,
tag: &str,
event_user_id: Option<i64>,
recipient_user_id: i64,
properties: &EventProperties,
body: &Value,
destinations: Option<Vec<Subscription>>,
) -> Value {
let mut value = serde_json::json!({
"topic": topic,
"tag": tag,
"user_id": event_user_id,
"recipient_user_id": recipient_user_id,
"properties": properties,
"body": body,
});
if let Some(destinations) = destinations {
if let Ok(value_destinations) = serde_json::to_value(destinations) {
value["destinations"] = value_destinations;
}
}
value
}
/// topic/tag 是否属于本网关支持的事件族（平台定向投递与订阅校验共用）。
pub fn is_supported(topic: &str, tag: &str) -> bool {
gitdata::is_supported(topic, tag)
|| kenshell::is_supported(topic, tag)
|| platform_events::is_supported(topic, tag)
}
pub fn is_personal_topic(topic: &str, tag: &str) -> bool {
crate::gateway::is_personal(topic, tag)
}