1 files changed, 78 insertions, 8 deletions

diff --git a/gui/src/timeline.rs b/gui/src/timeline.rs
index 82c8da1..8a13d5d 100644
--- a/gui/src/timeline.rs
+++ b/gui/src/timeline.rs
@@ -1,26 +1,96 @@
-use crate::timeline_post::TimelinePost;
+use anyhow::Result;
+use chrono::DateTime;
+use chrono::Utc;
+use futures::StreamExt;
+
+use iced_native::widget::scrollable::State as ScrollableState;
+
+use crate::app::Message;
+use crate::post::Post;
+use distrox_lib::client::Client;
+use distrox_lib::stream::NodeStreamBuilder;
+use distrox_lib::types::Payload;
 
 #[derive(Debug)]
 pub struct Timeline {
-    posts: Vec<TimelinePost>
+    posts: Vec<Post>,
+    scrollable: ScrollableState,
 }
 
 impl Timeline {
     pub fn new() -> Self {
         Self {
-            posts: Vec::with_capacity(100),
+            posts: Vec::new(),
+            scrollable: ScrollableState::new(),
         }
     }
 
-    pub fn update(&mut self) {
-        self.posts.iter_mut().for_each(|mut post| post.update());
+    pub fn push(&mut self, payload: Payload, content: String) {
+        self.posts.push(Post::new(payload, content));
     }
 
-    pub fn view(&self) -> iced::Column<crate::app::Message> {
+    pub fn view(&mut self) -> iced::Element<Message> {
+        let scrollable = iced::Scrollable::new(&mut self.scrollable)
+            .padding(10)
+            .spacing(20)
+            .width(iced::Length::Fill)
+            .height(iced::Length::Fill)
+            .on_scroll(move |offset| {
+                Message::TimelineScrolled(offset)
+            });
+
         self.posts
             .iter()
-            .fold(iced::Column::new(), |c, post| {
-                c.push(post.view())
+            .fold(scrollable, |scrollable, post| {
+                scrollable.push(post.view())
             })
+            .into()
+    }
+}
+
+pub struct PostLoadingRecipe {
+    client: Client,
+    head: cid::Cid,
+}
+
+impl PostLoadingRecipe {
+    pub fn new(client: Client, head: cid::Cid) -> Self {
+        Self { client, head }
+    }
+}
+
+// Make sure iced can use our download stream
+impl<H, I> iced_native::subscription::Recipe<H, I> for PostLoadingRecipe
+where
+    H: std::hash::Hasher,
+{
+    type Output = Message;
+
+    fn hash(&self, state: &mut H) {
+        use std::hash::Hash;
+        self.head.to_bytes().hash(state);
+    }
+
+    fn stream(self: Box<Self>, _input: futures::stream::BoxStream<'static, I>) -> futures::stream::BoxStream<'static, Self::Output>
+    {
+        log::debug!("Streaming posts starting at HEAD = {:?}", self.head);
+        Box::pin({
+            NodeStreamBuilder::starting_from(self.head.clone())
+                .into_stream(self.client.clone())
+                .then(move |node| {
+                    let client = self.client.clone();
+
+                    async move {
+                        let payload = client.get_payload(node?.payload()).await?;
+                        let content = client.get_content_text(payload.content()).await?;
+
+                        Ok((payload, content))
+                    }
+                })
+                .map(|res: Result<_>| match res {
+                    Err(_) => Message::PostLoadingFailed,
+                    Ok(p) => Message::PostLoaded(p),
+                })
+        })
     }
 }