properly refresh timelines with no WS streaming support, closes #77

Author: aryanchoudharypro

src/commands.rs

@@ -144,6 +144,7 @@ pub enum UiCommand {
 	AppClosing,
 	ExitApp,
 	RecoverDraft,
+	PollNonStreaming,
 }
 
 /// Refreshes the current timeline by re-fetching from the network.
@@ -162,6 +163,19 @@ pub fn refresh_timeline(state: &AppState, live_region: &crate::ui::timeline_list
 	}
 }
 
+pub fn poll_non_streaming_timelines(state: &AppState) {
+	let Some(handle) = &state.network_handle else { return };
+	for timeline in state.timeline_manager.timelines() {
+		if timeline.stream_handle.is_none() && timeline.timeline_type.stream_params().is_some() {
+			handle.send(NetworkCommand::FetchTimeline {
+				timeline_type: timeline.timeline_type.clone(),
+				limit: Some(40),
+				max_id: None,
+			});
+		}
+	}
+}
+
 /// Handles a UI command, updating state and UI as needed.
 pub struct UiCommandContext<'a> {
 	pub state: &'a mut AppState,
@@ -524,6 +538,9 @@ pub fn handle_ui_command(cmd: UiCommand, ctx: &mut UiCommandContext<'_>) {
 		UiCommand::Refresh => {
 			refresh_timeline(state, live_region);
 		}
+		UiCommand::PollNonStreaming => {
+			poll_non_streaming_timelines(state);
+		}
 		UiCommand::OpenTimeline(timeline_type) => {
 			open_timeline(
 				state,

src/main.rs

@@ -338,9 +338,9 @@ fn main() {
 		});
 
 		let refresh_timer = Rc::new(Timer::new(&frame));
-		let refresh_waker = ui_waker.clone();
+		let ui_tx_timer_poll = ui_tx.clone();
 		refresh_timer.on_tick(move |_| {
-			refresh_waker.wake();
+			let _ = ui_tx_timer_poll.send(UiCommand::PollNonStreaming);
 		});
 		refresh_timer.start(60_000, false);
 		let refresh_timer_keepalive = refresh_timer;

src/timeline.rs

@@ -468,6 +468,10 @@ impl TimelineManager {
 		self.timelines.iter().position(|t| t.timeline_type == *timeline_type)
 	}
 
+	pub fn timelines(&self) -> &[Timeline] {
+		&self.timelines
+	}
+
 	pub fn iter_mut(&mut self) -> impl Iterator<Item = &mut Timeline> {
 		self.timelines.iter_mut()
 	}