macltok

public

Star0

Fork 0

Watch0

91 commits 3 branches 0 tags 0 releases3.0 MiB

Commit `fbeaaa098107`

tarball

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

5 files changed+33-20

style: run rustfmt over the review fixes

Modified file: src/engine/context.rs+18 additions−14 deletions@@ -130,9 +130,9 @@ impl Sessions {
             let mut open = self.open.lock().await;
             let mut kept = VecDeque::with_capacity(open.len());
             for session in open.drain(..) {
-                let left = client.get_room(&session.room_id).is_none_or(|room| {
-                    matches!(room.state(), RoomState::Left | RoomState::Banned)
-                });
+                let left = client
+                    .get_room(&session.room_id)
+                    .is_none_or(|room| matches!(room.state(), RoomState::Left | RoomState::Banned));
                 if left {
                     media.release(&session.scope).await;
                     closed.push(session.id);
@@ -272,7 +272,15 @@ pub(crate) async fn capture(
     before_limit: u16,
     after_limit: u16,
 ) -> Result<(EventContext, Vec<MediaRegistration>, Vec<Value>), Error> {
-    capture_in(room, current_user_id, event_id, before_limit, after_limit, "").await
+    capture_in(
+        room,
+        current_user_id,
+        event_id,
+        before_limit,
+        after_limit,
+        "",
+    )
+    .await
 }
 
 async fn capture_in(
@@ -419,13 +427,7 @@ impl Assembly {
         keep: Option<usize>,
         media_prefix: &str,
     ) -> Self {
-        let page = normalise_context(
-            values,
-            keep,
-            current_user_id,
-            room.room_id(),
-            media_prefix,
-        );
+        let page = normalise_context(values, keep, current_user_id, room.room_id(), media_prefix);
         let mut items = page.items;
         for (index, item) in &mut items {
             if let TimelineItem::Event(event) = item {
@@ -524,9 +526,11 @@ async fn profiles<'a>(
     let mut unique: Vec<&OwnedUserId> = user_ids.collect();
     unique.sort();
     unique.dedup();
-    join_all(unique.into_iter().map(|user_id| async move {
-        Some((user_id.clone(), member_sender(room, user_id).await?))
-    }))
+    join_all(
+        unique.into_iter().map(|user_id| async move {
+            Some((user_id.clone(), member_sender(room, user_id).await?))
+        }),
+    )
     .await
     .into_iter()
     .flatten()

Modified file: src/engine/packs.rs+7 additions−1 deletions@@ -396,7 +396,13 @@ async fn send_sticker(
             .load_or_fetch_event(root, None)
             .await
             .ok()
-            .and_then(|event| event.raw().get_field::<JsonValue>("unsigned").ok().flatten())
+            .and_then(|event| {
+                event
+                    .raw()
+                    .get_field::<JsonValue>("unsigned")
+                    .ok()
+                    .flatten()
+            })
             .and_then(|unsigned| {
                 unsigned
                     .pointer("/m.relations/m.thread/latest_event/event_id")

Modified file: src/normalise/context.rs+7 additions−1 deletions@@ -239,7 +239,13 @@ mod tests {
                 "content": {},
             }),
         ];
-        let page = normalise_context(&values, None, Some(user_id!("@a:x")), room_id!("!room:x"), "");
+        let page = normalise_context(
+            &values,
+            None,
+            Some(user_id!("@a:x")),
+            room_id!("!room:x"),
+            "",
+        );
         assert_eq!(page.items.len(), 1);
         let TimelineItem::Event(event) = &page.items[0].1 else {
             panic!("expected an event");

Modified file: src/normalise/timeline.rs−1

@@ -471,4 +471,3 @@ pub(super) fn formatted_body(message: &MessageType) -> Option<String> {

471471 }?;

472472 (formatted.format == MessageFormat::Html).then(|| formatted.body.clone())

473473 }

474-

Modified file: tests/mentions_inbox.rs+1 additions−3 deletions@@ -954,9 +954,7 @@ async fn a_quiet_keyword_rule_only_gains_the_highlight() {
         .and(path(
             "/_matrix/client/v3/pushrules/global/content/deploy/actions",
         ))
-        .and(actions_are(
-            json!([{"set_tweak": "highlight"}]),
-        ))
+        .and(actions_are(json!([{"set_tweak": "highlight"}])))
         .respond_with(ResponseTemplate::new(200).set_body_json(json!({})))
         .expect(1)
         .mount(server.server())

macltok

Commit fbeaaa098107

Commit `fbeaaa098107`