malice

public

Star0

Fork 0

Watch0

56 commits 2 branches 0 tags 0 releases4.4 MiB

Commit `ed3363baaf01`

tarball

atagen <boss@atagen.co>2026-10-25 03:13 UTC

2 files changed+66-7

mentions: expose persistent inbox commands

Modified file: crates/malice-core/src/request.rs+59 additions−6 deletions@@ -1,8 +1,8 @@
 use macltok::ruma::{events::GlobalAccountDataEventType, serde::Raw};
 use macltok::{
     AttachmentUpload, ClientHandle, CreateRoomOptions, ImagePackSource, MediaId, MediaSize,
-    MemberFilter, MessageContent, MessageEditContent, MirrorHandle, PackImageInfo, PackUsage,
-    Patch, RichText, TimelineId, VerificationAction, VerificationTarget,
+    MemberFilter, MentionKey, MentionsBoundary, MessageContent, MessageEditContent, MirrorHandle,
+    PackImageInfo, PackUsage, Patch, RichText, TimelineId, VerificationAction, VerificationTarget,
 };
 use serde::Deserialize;
 use serde_json::json;
@@ -103,6 +103,28 @@ pub enum Request {
         #[serde(default)]
         limit: u32,
     },
+    MentionsPage {
+        #[serde(default)]
+        cursor: Option<String>,
+        #[serde(default)]
+        limit: u32,
+    },
+    MentionContext {
+        room_id: String,
+        event_id: String,
+    },
+    RetryMentionContext {
+        room_id: String,
+        event_id: String,
+    },
+    SetMentionsRead {
+        keys: Vec<MentionKey>,
+        read: bool,
+    },
+    MarkMentionsReadThrough {
+        boundary: MentionsBoundary,
+    },
+    RecoverMentions,
     Join {
         #[serde(default)]
         room: String,
@@ -526,9 +548,7 @@ pub async fn dispatch(
             limit,
         } => {
             let room_id = parse_room_id(&room_id)?;
-            let page = handle
-                .event_context_before(&room_id, &token, limit)
-                .await?;
+            let page = handle.event_context_before(&room_id, &token, limit).await?;
             Ok(Reply::Json(json!(page)))
         }
         Request::EventContextAfter {
@@ -537,11 +557,44 @@ pub async fn dispatch(
             limit,
         } => {
             let room_id = parse_room_id(&room_id)?;
+            let page = handle.event_context_after(&room_id, &token, limit).await?;
+            Ok(Reply::Json(json!(page)))
+        }
+        Request::MentionsPage { cursor, limit } => {
             let page = handle
-                .event_context_after(&room_id, &token, limit)
+                .mentions_page(cursor, if limit == 0 { 50 } else { limit.clamp(1, 50) })
                 .await?;
             Ok(Reply::Json(json!(page)))
         }
+        Request::MentionContext { room_id, event_id } => {
+            let context = handle
+                .mention_context(&parse_room_id(&room_id)?, &parse_event_id(&event_id)?)
+                .await?;
+            Ok(Reply::Json(json!(context)))
+        }
+        Request::RetryMentionContext { room_id, event_id } => {
+            let context = handle
+                .retry_mention_context(&parse_room_id(&room_id)?, &parse_event_id(&event_id)?)
+                .await?;
+            Ok(Reply::Json(json!(context)))
+        }
+        Request::SetMentionsRead { keys, read } => {
+            if keys.len() > 5000 {
+                return Err(CoreError::bad_request(
+                    "at most 5000 mention keys are allowed",
+                ));
+            }
+            handle.set_mentions_read(keys, read).await?;
+            Ok(Reply::Done)
+        }
+        Request::MarkMentionsReadThrough { boundary } => {
+            handle.mark_mentions_read_through(boundary).await?;
+            Ok(Reply::Done)
+        }
+        Request::RecoverMentions => {
+            handle.recover_mentions().await?;
+            Ok(Reply::Done)
+        }
         Request::Join { room } => {
             let room = parse_room_or_alias(&room)?;
             let room_id = handle.join_room(room, Vec::new()).await?;

Modified file: crates/malice-server/src/routes.rs+7 additions−1 deletions@@ -554,7 +554,13 @@ async fn post_command(
     let request = body.0;
     if !matches!(
         request,
-        Request::Kick { .. }
+        Request::MentionsPage { .. }
+            | Request::MentionContext { .. }
+            | Request::RetryMentionContext { .. }
+            | Request::SetMentionsRead { .. }
+            | Request::MarkMentionsReadThrough { .. }
+            | Request::RecoverMentions
+            | Request::Kick { .. }
             | Request::Ban { .. }
             | Request::Unban { .. }
             | Request::SetPowerLevel { .. }

malice

Commit ed3363baaf01

Commit `ed3363baaf01`