From ecb49bf88a5cc220d64965e96c5adec0ddd71d7b Mon Sep 17 00:00:00 2001 From: Tony Klink Date: Thu, 25 Jan 2024 22:09:46 -0600 Subject: [PATCH] Send EOSE as the last relay message --- src/noose/sqlite.rs | 9 ++++++++- 1 file changed, 8 insertions(+), 1 deletion(-) diff --git a/src/noose/sqlite.rs b/src/noose/sqlite.rs index 7262227..9e49340 100644 --- a/src/noose/sqlite.rs +++ b/src/noose/sqlite.rs @@ -1257,10 +1257,17 @@ impl Noose for NostrSqlite { ) -> Result, Error> { match self.query(subscription.filters, Order::Desc).await { Ok(events) => { - let relay_messages = events + + let relay_messages: Vec = events .into_iter() .map(|event| nostr::RelayMessage::event(subscription.id.clone(), event)) .collect(); + + if relay_messages.is_empty() { + let eose = RelayMessage::eose(subscription.id.clone()); + return Ok(vec![eose]); + } + Ok(relay_messages) } Err(err) => Err(Error::bad_request(err.to_string())),