diff options
Diffstat (limited to 'gui/src/app/mod.rs')
| -rw-r--r-- | gui/src/app/mod.rs | 157 |
1 files changed, 5 insertions, 152 deletions
diff --git a/gui/src/app/mod.rs b/gui/src/app/mod.rs index ac9e43d..f66bd7c 100644 --- a/gui/src/app/mod.rs +++ b/gui/src/app/mod.rs @@ -19,10 +19,13 @@ use crate::timeline::PostLoadingRecipe; mod message; pub use message::Message; +mod handler; + + use crate::gossip::GossipRecipe; #[derive(Debug)] -enum Distrox { +pub(crate) enum Distrox { Loading { gossip_subscription_recv: RwLock<tokio::sync::oneshot::Receiver<GossipRecipe>>, }, @@ -86,157 +89,7 @@ impl Application for Distrox { } fn update(&mut self, message: Self::Message) -> iced::Command<Self::Message> { - log::trace!("Received message: {}", message.description()); - match self { - Distrox::Loading { gossip_subscription_recv } => { - if let Message::Loaded(profile) = message { - *self = Distrox::Loaded { - profile, - - // Don't even try to think what hoops I am jumping through here... - gossip_subscription_recv: std::mem::replace(gossip_subscription_recv, RwLock::new(tokio::sync::oneshot::channel().1)), - scroll: scrollable::State::default(), - input: text_input::State::default(), - input_value: String::default(), - timeline: Timeline::new(), - log_visible: false, - log: std::collections::VecDeque::with_capacity(1000), - }; - - - } - iced::Command::none() - }, - - Distrox::Loaded { profile, ref mut input_value, timeline, log_visible, log, .. } => { - match message { - Message::InputChanged(input) => { - *input_value = input; - iced::Command::none() - } - - Message::CreatePost => { - if !input_value.is_empty() { - let input = input_value.clone(); - let profile = profile.clone(); - log::trace!("Posting..."); - iced::Command::perform(async move { - log::trace!("Posting: '{}'", input); - profile.write().await.post_text(input).await - }, - |res| match res { - Ok(cid) => Message::PostCreated(cid), - Err(e) => Message::PostCreationFailed(e.to_string()) - }) - } else { - iced::Command::none() - } - } - - Message::PostCreated(cid) => { - *input_value = String::new(); - log::info!("Post created: {}", cid); - - let profile = profile.clone(); - iced::Command::perform(async move { - if let Err(e) = profile.read().await.save().await { - Message::ProfileStateSavingFailed(e.to_string()) - } else { - Message::ProfileStateSaved - } - }, |m: Message| -> Message { m }) - } - - Message::ProfileStateSaved => { - log::info!("Profile state saved"); - iced::Command::none() - }, - - Message::ProfileStateSavingFailed(e) => { - log::error!("Saving profile failed: {}", e); - iced::Command::none() - }, - - Message::PostCreationFailed(err) => { - log::error!("Post creation failed: {}", err); - iced::Command::none() - } - - Message::PostLoaded((payload, content)) => { - timeline.push(payload, content); - iced::Command::none() - } - - Message::PostLoadingFailed => { - log::error!("Failed to load some post, TODO: Better error logging"); - iced::Command::none() - } - - Message::TimelineScrolled(f) => { - log::trace!("Timeline scrolled: {}", f); - iced::Command::none() - } - - Message::ToggleLog => { - log::trace!("Log toggled"); - *log_visible = !*log_visible; - iced::Command::none() - } - - Message::GossipMessage(source, msg) => { - log::trace!("Received Gossip from {}: {:?}", source, msg); - iced::Command::perform(async { - Message::GossipHandled(msg) - }, |m: Message| -> Message { m }) - } - - Message::GossipHandled(msg) => { - use distrox_lib::gossip::GossipMessage; - - log::trace!("Gossip handled, adding to log: {:?}", msg); - let msg = match msg { - GossipMessage::CurrentProfileState { peer_id, cid } => { - format!("Peer {:?} is at {:?}", peer_id, cid) - } - }; - log.push_back(msg); - while log.len() > 1000 { - let _ = log.pop_front(); - } - iced::Command::none() - } - - Message::PublishGossipAboutMe => { - let profile = profile.clone(); - iced::Command::perform(async move { - if let Err(e) = profile.read().await.gossip_own_state("distrox".to_string()).await { - Message::GossippingFailed(e.to_string()) - } else { - Message::OwnStateGossipped - } - }, |m: Message| -> Message { m }) - } - - Message::OwnStateGossipped => { - log::trace!("Gossipped own state"); - log.push_back("Gossipped own state".to_string()); - iced::Command::none() - } - - Message::GossippingFailed(e) => { - log::trace!("Gossipped failed: {}", e); - log.push_back(format!("Gossipped failed: {}", e)); - iced::Command::none() - } - - _ => iced::Command::none(), - } - } - - Distrox::FailedToStart => { - unimplemented!() - } - } + handler::handle_message(self, message) } fn view(&mut self) -> iced::Element<Self::Message> { |