8d2da86f1f
we rely on the event type for multicast logic, so remove raw since its not really needed anymore Signed-off-by: William Casarin <jb55@jb55.com>
71 lines
2.0 KiB
Rust
71 lines
2.0 KiB
Rust
use crate::Error;
|
|
use nostrdb::{Filter, Note};
|
|
use serde_json::json;
|
|
|
|
#[derive(Debug, Clone)]
|
|
pub struct EventClientMessage {
|
|
pub note_json: String,
|
|
}
|
|
|
|
impl EventClientMessage {
|
|
pub fn to_json(&self) -> String {
|
|
format!("[\"EVENT\", {}]", self.note_json)
|
|
}
|
|
}
|
|
|
|
/// Messages sent by clients, received by relays
|
|
#[derive(Debug, Clone)]
|
|
pub enum ClientMessage {
|
|
Event(EventClientMessage),
|
|
Req {
|
|
sub_id: String,
|
|
filters: Vec<Filter>,
|
|
},
|
|
Close {
|
|
sub_id: String,
|
|
},
|
|
Raw(String),
|
|
}
|
|
|
|
impl ClientMessage {
|
|
pub fn event(note: &Note) -> Result<Self, Error> {
|
|
Ok(ClientMessage::Event(EventClientMessage {
|
|
note_json: note.json()?,
|
|
}))
|
|
}
|
|
|
|
pub fn event_json(note_json: String) -> Result<Self, Error> {
|
|
Ok(ClientMessage::Event(EventClientMessage { note_json }))
|
|
}
|
|
|
|
pub fn req(sub_id: String, filters: Vec<Filter>) -> Self {
|
|
ClientMessage::Req { sub_id, filters }
|
|
}
|
|
|
|
pub fn close(sub_id: String) -> Self {
|
|
ClientMessage::Close { sub_id }
|
|
}
|
|
|
|
pub fn to_json(&self) -> Result<String, Error> {
|
|
Ok(match self {
|
|
Self::Event(ecm) => ecm.to_json(),
|
|
Self::Raw(raw) => raw.clone(),
|
|
Self::Req { sub_id, filters } => {
|
|
if filters.is_empty() {
|
|
format!("[\"REQ\",\"{sub_id}\",{{ }}]")
|
|
} else if filters.len() == 1 {
|
|
let filters_json_str = filters[0].json()?;
|
|
format!("[\"REQ\",\"{sub_id}\",{filters_json_str}]")
|
|
} else {
|
|
let filters_json_str: Result<Vec<String>, Error> = filters
|
|
.iter()
|
|
.map(|f| f.json().map_err(Into::<Error>::into))
|
|
.collect();
|
|
format!("[\"REQ\",\"{}\",{}]", sub_id, filters_json_str?.join(","))
|
|
}
|
|
}
|
|
Self::Close { sub_id } => json!(["CLOSE", sub_id]).to_string(),
|
|
})
|
|
}
|
|
}
|