reya/coop
1
0
Fork 0
Code Issues Pull Requests 1 Releases 3 Activity

update api

Browse Source
This commit is contained in:
reya
2026-09-15 19:33:30 +07:00
parent 37d3380c55
commit 2d7881e574
1 changed files with 7 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files
crates/chat/src/lib.rs
+7 -7
View File
@@ -630,7 +630,7 @@ impl ChatRegistry {
/// Load all rooms from the database. /// Load all rooms from the database.
pub fn get_rooms(&mut self, cx: &mut Context<Self>) { pub fn get_rooms(&mut self, cx: &mut Context<Self>) {
let task = self.get_rooms_task(cx); let task = self.query_chat_rooms(cx);
self.tasks.push(cx.spawn(async move |this, cx| { self.tasks.push(cx.spawn(async move |this, cx| {
match task.await { match task.await {
@@ -651,8 +651,8 @@ impl ChatRegistry {
})); }));
} }
/// Create a task to load rooms from the database /// Query the chat rooms from the database
fn get_rooms_task(&self, cx: &App) -> Task<Result<HashSet<Room>, Error>> { fn query_chat_rooms(&self, cx: &App) -> Task<Result<HashSet<Room>, Error>> {
let nostr = NostrRegistry::global(cx); let nostr = NostrRegistry::global(cx);
let client = nostr.read(cx).client(); let client = nostr.read(cx).client();
let signer = nostr.read(cx).signer(); let signer = nostr.read(cx).signer();
@@ -678,7 +678,7 @@ impl ChatRegistry {
let filter = Filter::new() let filter = Filter::new()
.kind(Kind::ApplicationSpecificData) .kind(Kind::ApplicationSpecificData)
.custom_tag(SingleLetterTag::LOWERCASE_K, "14"); .custom_tags(SingleLetterTag::LOWERCASE_K, ["7", "14", "15"]);
let events = client.database().query(filter).await?; let events = client.database().query(filter).await?;
let mut grouped: HashMap<u64, Vec<UnsignedEvent>> = HashMap::new(); let mut grouped: HashMap<u64, Vec<UnsignedEvent>> = HashMap::new();
@@ -720,8 +720,8 @@ impl ChatRegistry {
/// Parse a nostr event into a message and push it to the belonging room /// Parse a nostr event into a message and push it to the belonging room
/// ///
/// If the room doesn't exist, it will be created. /// - If the room doesn't exist, it will be created.
/// Updates room ordering based on the most recent messages. /// - Updates room ordering based on the most recent messages.
pub fn new_message(&mut self, message: NewMessage, cx: &mut Context<Self>) { pub fn new_message(&mut self, message: NewMessage, cx: &mut Context<Self>) {
let nostr = NostrRegistry::global(cx); let nostr = NostrRegistry::global(cx);
@@ -824,7 +824,7 @@ async fn set_rumor(client: &Client, id: EventId, rumor: &UnsignedEvent) -> Resul
Tag::identifier(id), Tag::identifier(id),
Tag::public_key(rumor.pubkey), Tag::public_key(rumor.pubkey),
Tag::custom("r", [room_id]), Tag::custom("r", [room_id]),
Tag::custom("k", ["14"]), Tag::custom("k", [rumor.kind.to_string()]),
]; ];
let event = EventBuilder::new(Kind::ApplicationSpecificData, rumor.as_json()) let event = EventBuilder::new(Kind::ApplicationSpecificData, rumor.as_json())