malice

public

Star0

Fork 0

Watch0

29 commits 2 branches 0 tags 0 releases4.4 MiB

Commit `77eddb6b710f`

tarball

atagen <boss@atagen.co>2026-10-24 10:05 UTC

3 files changed+66-0

core: expose the pinned timeline over the wire

Pinned items travel as their own Pinned and PinnedClosed events instead of riding the room Timeline events, so the frontend never mixes pins into the room timeline.

Modified file: crates/malice-core/src/feed.rs+34 additions@@ -14,6 +14,7 @@ pub enum WireEvent {
     Snapshot {
         rooms: Vec<RoomSummary>,
         timelines: HashMap<String, Vector<TimelineItem>>,
+        pinned: HashMap<String, Vector<TimelineItem>>,
         connection: String,
         encryption: Option<EncryptionState>,
         verification: Option<VerificationState>,
@@ -32,6 +33,13 @@ pub enum WireEvent {
     TimelineClosed {
         room_id: String,
     },
+    Pinned {
+        room_id: String,
+        items: Vector<TimelineItem>,
+    },
+    PinnedClosed {
+        room_id: String,
+    },
     Connection {
         state: String,
     },
@@ -84,9 +92,20 @@ pub fn snapshot_event(state: &State) -> WireEvent {
             _ => None,
         })
         .collect();
+    let pinned = state
+        .timelines
+        .iter()
+        .filter_map(|(timeline_id, timeline)| match timeline_id {
+            TimelineId::Pinned(room_id) => {
+                Some((room_id.as_str().to_owned(), timeline.items.clone()))
+            }
+            _ => None,
+        })
+        .collect();
     WireEvent::Snapshot {
         rooms: state.rooms.iter().cloned().collect(),
         timelines,
+        pinned,
         connection: connection_label(&state.connection),
         encryption: state.encryption.clone(),
         verification: state.verification.clone(),
@@ -129,6 +148,21 @@ pub fn wire_events(change: &StateChange) -> Vec<WireEvent> {
             }],
             _ => vec![],
         },
+        StateChange::Timeline {
+            timeline_id: TimelineId::Pinned(room_id),
+            change,
+        } => match change {
+            TimelineChange::Reset { items } | TimelineChange::Changed { items, .. } => {
+                vec![WireEvent::Pinned {
+                    room_id: room_id.as_str().to_owned(),
+                    items: items.clone(),
+                }]
+            }
+            TimelineChange::Closed => vec![WireEvent::PinnedClosed {
+                room_id: room_id.as_str().to_owned(),
+            }],
+            _ => vec![],
+        },
         StateChange::Timeline { .. } => vec![],
         StateChange::Connection(state) => vec![WireEvent::Connection {
             state: connection_label(state),

Modified file: crates/malice-core/src/request.rs+29 additions@@ -227,6 +227,17 @@ pub enum Request {
     PowerLevels {
         room_id: String,
     },
+    OpenPinned {
+        room_id: String,
+    },
+    ClosePinned {
+        room_id: String,
+    },
+    SetPinned {
+        room_id: String,
+        event_id: String,
+        pinned: bool,
+    },
     UploadMedia {
         #[serde(skip)]
         bytes: Vec<u8>,
@@ -988,6 +999,24 @@ pub async fn dispatch(
                 .await?;
             Ok(Reply::Json(json!({ "skipped": skipped })))
         }
+        Request::OpenPinned { room_id } => {
+            handle.open_pinned(parse_room_id(&room_id)?).await?;
+            Ok(Reply::Done)
+        }
+        Request::ClosePinned { room_id } => {
+            handle.close_pinned(parse_room_id(&room_id)?).await?;
+            Ok(Reply::Done)
+        }
+        Request::SetPinned {
+            room_id,
+            event_id,
+            pinned,
+        } => {
+            handle
+                .set_pinned(parse_room_id(&room_id)?, parse_event_id(&event_id)?, pinned)
+                .await?;
+            Ok(Reply::Done)
+        }
         Request::PowerLevels { room_id } => {
             let levels = handle.room_power_levels(&parse_room_id(&room_id)?).await?;
             let value = serde_json::to_value(levels)

Modified file: crates/malice-server/src/routes.rs+3 additions@@ -549,6 +549,9 @@ async fn post_command(
             | Request::Ignore { .. }
             | Request::Unignore { .. }
             | Request::PowerLevels { .. }
+            | Request::OpenPinned { .. }
+            | Request::ClosePinned { .. }
+            | Request::SetPinned { .. }
             | Request::SendSticker { .. }
             | Request::CreateRoomPack { .. }
             | Request::DeletePack { .. }

malice

Commit 77eddb6b710f

Commit `77eddb6b710f`