feat: introduce Markdown conversion for Slack and Lark adapters, improving message formatting.

Author: ikkz

Cargo.lock

@@ -9,6 +9,12 @@ This project is currently **work in progress**. Core routing is being built; the
 - Normalizes content to Markdown with minimal metadata.
 - Forwards to one or more downstream webhook targets.
 
+## Markdown Compatibility
+The system ensures your messages look great on any platform by automatically converting standard Markdown:
+- **Slack**: Converts standard Markdown (e.g., `**bold**`, `[link](url)`) to Slack's native `mrkdwn` syntax.
+- **Lark / Feishu**: Transforms Markdown into Lark's JSON "Post" (Rich Text) format to support native styling.
+- **WeCom / DingTalk**: Optimizes formatting for their respective Markdown subsets.
+
 ## Status
 - Backend routing: in active development.
 - Console UI: in progress.

README.md

@@ -20,6 +20,7 @@ uuid = { version = "1", features = ["v4", "serde"] }
 markdown = "1.0.0"
 utoipa = { version = "5", features = ["axum_extras"] }
 utoipa-swagger-ui = { version = "8", features = ["axum"] }
+pulldown-cmark = "0.13.0"
 
 
 # See more keys and their definitions at https://doc.rust-lang.org/cargo/reference/manifest.html

apps/webhook_router/Cargo.toml

@@ -3,6 +3,7 @@ use uuid::Uuid;
 
 use crate::adapters::{AdapterError, WebhookAdapter};
 use crate::models::{OutgoingPayload, UemEvent};
+use crate::utils::markdown::LarkConverter;
 
 #[derive(Debug)]
 pub struct LarkAdapter;
@@ -57,10 +58,11 @@ impl WebhookAdapter for LarkAdapter {
     }
 
     fn uem_to_egress(&self, event: &UemEvent) -> Result<OutgoingPayload, AdapterError> {
+        let post_content = LarkConverter::convert(&event.markdown);
         Ok(OutgoingPayload {
             body: json!({
-                "msg_type": "text",
-                "content": { "text": event.markdown }
+                "msg_type": "post",
+                "content": { "post": post_content }
             }),
             content_type: "application/json",
         })
@@ -116,7 +118,10 @@ mod tests {
             meta: json!({}),
         };
         let payload = adapter.uem_to_egress(&event).expect("payload");
-        assert_eq!(payload.body["msg_type"], "text");
-        assert_eq!(payload.body["content"]["text"], "hello");
+        assert_eq!(payload.body["msg_type"], "post");
+        // Verify post content structure exists
+        assert!(payload.body["content"]["post"]["zh_cn"]["content"].is_array());
+        let content_text = &payload.body["content"]["post"]["zh_cn"]["content"][0][0]["text"];
+        assert_eq!(content_text, "hello");
     }
 }

apps/webhook_router/src/adapters/lark.rs

@@ -3,6 +3,7 @@ use uuid::Uuid;
 
 use crate::adapters::{AdapterError, WebhookAdapter};
 use crate::models::{OutgoingPayload, UemEvent};
+use crate::utils::markdown::SlackConverter;
 
 #[derive(Debug)]
 pub struct SlackAdapter;
@@ -48,8 +49,9 @@ impl WebhookAdapter for SlackAdapter {
     }
 
     fn uem_to_egress(&self, event: &UemEvent) -> Result<OutgoingPayload, AdapterError> {
+        let mrkdwn = SlackConverter::convert(&event.markdown);
         Ok(OutgoingPayload {
-            body: json!({ "text": event.markdown }),
+            body: json!({ "text": mrkdwn }),
             content_type: "application/json",
         })
     }
@@ -95,11 +97,11 @@ mod tests {
             source: "slack".to_string(),
             timestamp: 1,
             title: None,
-            markdown: "hello".to_string(),
+            markdown: "**bold**".to_string(),
             raw: json!({}),
             meta: json!({}),
         };
         let payload = adapter.uem_to_egress(&event).expect("payload");
-        assert_eq!(payload.body["text"], "hello");
+        assert_eq!(payload.body["text"], "*bold*");
     }
 }

apps/webhook_router/src/adapters/slack.rs

@@ -10,6 +10,7 @@ mod adapters;
 mod db;
 mod handlers;
 mod models;
+mod utils;
 
 use handlers::{api_router, basic_auth, healthz, ingress, AppState, ApiDoc};
 use models::BasicAuth;