From 12d9e5955092b282a96add03ddfc148f01f3a3e8 Mon Sep 17 00:00:00 2001 From: cel 🌸 Date: Sun, 1 Jun 2025 21:32:13 +0100 Subject: WIP: fix untracked state --- src/message.rs | 34 ++++++++++++++++------------------ 1 file changed, 16 insertions(+), 18 deletions(-) (limited to 'src/message.rs') diff --git a/src/message.rs b/src/message.rs index a47c75f..2a5fe18 100644 --- a/src/message.rs +++ b/src/message.rs @@ -8,14 +8,19 @@ use leptos::prelude::*; use crate::{client::Client, user::MacawUser}; +#[derive(Clone)] +pub struct GotMessage(Message); + async fn get_message(id: Uuid) -> ArcStore { - let client: Client = use_context().expect("no client in context"); - ArcStore::new(client.get_message(id).await.unwrap()) + // let client: Client = use_context().expect("no client in context"); + // ArcStore::new(client.get_message(id).await.unwrap()) + let GotMessage(message) = use_context().expect("no message in context"); + ArcStore::new(message) } -#[derive(Clone)] +#[derive(Clone, Copy)] pub struct MacawMessage { - pub message: ArcStore, + pub message: LocalResource>, pub user: MacawUser, } @@ -24,25 +29,18 @@ impl MacawMessage { let query_client: QueryClient = expect_context(); let id = message.id; - let message_store = query_client.subscribe_value_local(get_message, move || id); - if let Some(message_store) = message_store.get() { - message_store.set(message); - let user = MacawUser::got_user(user); - Self { message: message_store, user } - } else { - let message_store = ArcStore::new(message); - query_client.set_query_local(get_message, id, message_store.clone()); - let user = MacawUser::got_user(user); - Self { - message: message_store, - user, - } + provide_context(GotMessage(message)); + let message = query_client.local_resource(get_message, move || id); + let user = MacawUser::got_user(user); + Self { + message, + user, } } } impl Deref for MacawMessage { - type Target = ArcStore; + type Target = LocalResource>; fn deref(&self) -> &Self::Target { &self.message -- cgit