2024-12-06 14:45:14 +03:00
|
|
|
use leptos::*;
|
2024-12-10 18:35:39 +03:00
|
|
|
use leptos_meta::*;
|
2024-12-17 13:06:25 +03:00
|
|
|
use crate::components::{item_form::ItemForm, items_list::ItemsList};
|
2024-12-17 13:39:41 +03:00
|
|
|
use crate::models::item::{Item, ReviewWithRating};
|
2024-12-10 22:28:38 +03:00
|
|
|
use crate::nostr::NostrClient;
|
2024-12-13 13:56:55 +03:00
|
|
|
use tokio::sync::mpsc;
|
2024-12-09 14:58:05 +03:00
|
|
|
use uuid::Uuid;
|
2024-12-10 22:28:38 +03:00
|
|
|
use leptos::spawn_local;
|
2024-12-13 13:56:55 +03:00
|
|
|
use nostr_sdk::serde_json;
|
2024-12-06 14:45:14 +03:00
|
|
|
|
|
|
|
#[component]
|
|
|
|
pub fn App() -> impl IntoView {
|
2024-12-10 18:35:39 +03:00
|
|
|
provide_meta_context();
|
2024-12-16 22:16:55 +03:00
|
|
|
|
2024-12-17 13:06:25 +03:00
|
|
|
// Signal to manage the list of items
|
2024-12-09 13:56:39 +03:00
|
|
|
let (items_signal, set_items) = create_signal(Vec::<Item>::new());
|
2024-12-13 13:56:55 +03:00
|
|
|
let (tx, mut rx) = mpsc::channel::<String>(100);
|
2024-12-10 22:28:38 +03:00
|
|
|
|
2024-12-17 13:06:25 +03:00
|
|
|
// Nostr client subscription for items
|
2024-12-10 22:28:38 +03:00
|
|
|
spawn_local(async move {
|
2024-12-16 13:31:11 +03:00
|
|
|
let nostr_client = NostrClient::new("wss://relay.damus.io").await.unwrap();
|
2024-12-10 22:28:38 +03:00
|
|
|
nostr_client.subscribe_to_items(tx.clone()).await.unwrap();
|
|
|
|
|
2024-12-13 13:56:55 +03:00
|
|
|
while let Some(content) = rx.recv().await {
|
2024-12-10 22:28:38 +03:00
|
|
|
if let Ok(item) = serde_json::from_str::<Item>(&content) {
|
|
|
|
set_items.update(|items| items.push(item));
|
|
|
|
}
|
|
|
|
}
|
|
|
|
});
|
2024-12-16 22:16:55 +03:00
|
|
|
|
2024-12-17 13:06:25 +03:00
|
|
|
// Add a new item and review using the unified form
|
2024-12-17 13:39:41 +03:00
|
|
|
let add_item = move |name: String, description: String, tags: Vec<(String, String)>, review: String, rating: u8| {
|
|
|
|
let new_id = Uuid::new_v4().to_string();
|
|
|
|
|
2024-12-09 14:58:05 +03:00
|
|
|
set_items.update(|items| {
|
2024-12-10 22:28:38 +03:00
|
|
|
let item = Item {
|
2024-12-17 13:06:25 +03:00
|
|
|
id: new_id.clone(),
|
2024-12-17 13:39:41 +03:00
|
|
|
name,
|
|
|
|
description,
|
|
|
|
tags,
|
|
|
|
reviews: vec![ReviewWithRating { content: review.clone(), rating }],
|
2024-12-18 21:49:26 +03:00
|
|
|
wikidata_id: None,
|
2024-12-10 22:28:38 +03:00
|
|
|
};
|
|
|
|
items.push(item);
|
|
|
|
});
|
2024-12-17 13:39:41 +03:00
|
|
|
|
2024-12-10 22:28:38 +03:00
|
|
|
spawn_local(async move {
|
|
|
|
let nostr_client = NostrClient::new("wss://relay.example.com").await.unwrap();
|
2024-12-17 13:39:41 +03:00
|
|
|
nostr_client.publish_item("New item added!".to_string(), "".to_string(), vec![]).await.unwrap();
|
2024-12-06 14:45:14 +03:00
|
|
|
});
|
|
|
|
};
|
2024-12-17 13:39:41 +03:00
|
|
|
|
2024-12-06 14:45:14 +03:00
|
|
|
view! {
|
2024-12-17 13:06:25 +03:00
|
|
|
<Stylesheet href="/assets/style.css" />
|
|
|
|
<div>
|
|
|
|
<h1>{ "CompareWare" }</h1>
|
|
|
|
// Unified form for adding an item and its first review
|
|
|
|
<ItemForm on_submit=Box::new(add_item) />
|
|
|
|
// Display all items, including reviews
|
|
|
|
<ItemsList items=items_signal />
|
|
|
|
</div>
|
2024-12-06 14:45:14 +03:00
|
|
|
}
|
2024-12-17 13:06:25 +03:00
|
|
|
}
|