use alloc::string::{String, ToString};
use alloc::vec;
use alloc::vec::Vec;
use core::fmt;
use super::nip01::Coordinate;
use super::util::take_string;
use crate::event::tag::{Tag, TagCodec, TagCodecError, impl_tag_codec_conversions};
use crate::types::url::RelayUrl;
const CLIENT: &str = "client";
#[derive(Debug, PartialEq)]
pub enum Error {
Codec(TagCodecError),
}
impl core::error::Error for Error {}
impl fmt::Display for Error {
fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result {
match self {
Self::Codec(e) => e.fmt(f),
}
}
}
impl From<TagCodecError> for Error {
fn from(e: TagCodecError) -> Self {
Self::Codec(e)
}
}
#[derive(Debug, Clone, PartialEq, Eq, PartialOrd, Ord, Hash)]
pub enum Nip89Tag {
Client {
name: String,
address: Option<(Coordinate, Option<RelayUrl>)>,
},
}
impl TagCodec for Nip89Tag {
type Error = Error;
fn parse<I, S>(tag: I) -> Result<Self, Self::Error>
where
I: IntoIterator<Item = S>,
S: AsRef<str>,
{
let mut iter = tag.into_iter();
let kind: S = iter.next().ok_or(TagCodecError::missing_tag_kind())?;
match kind.as_ref() {
CLIENT => {
let (name, address) = parse_client_tag(iter)?;
Ok(Self::Client { name, address })
}
_ => Err(TagCodecError::Unknown.into()),
}
}
fn to_tag(&self) -> Tag {
match self {
Self::Client { name, address } => {
let mut tag: Vec<String> = vec![CLIENT.to_string(), name.clone()];
match address {
Some((coordinate, Some(hint))) => {
tag.reserve_exact(2);
tag.push(coordinate.to_string());
tag.push(hint.to_string());
}
Some((coordinate, None)) => {
tag.push(coordinate.to_string());
}
_ => {}
}
Tag::new(tag)
}
}
}
}
impl_tag_codec_conversions!(Nip89Tag);
#[allow(clippy::type_complexity)]
fn parse_client_tag<T, S>(
mut iter: T,
) -> Result<(String, Option<(Coordinate, Option<RelayUrl>)>), Error>
where
T: Iterator<Item = S>,
S: AsRef<str>,
{
let name: String = take_string(&mut iter, "client name")?;
let coordinate: Option<S> = iter.next();
let address: Option<(Coordinate, Option<RelayUrl>)> = match coordinate {
Some(coordinate) => match Coordinate::parse(coordinate.as_ref()) {
Ok(coordinate) => {
let relay_url: Option<S> = iter.next();
let relay_url: Option<RelayUrl> =
relay_url.and_then(|url| RelayUrl::parse(url.as_ref()).ok());
Some((coordinate, relay_url))
}
Err(..) => None,
},
None => None,
};
Ok((name, address))
}
#[cfg(test)]
mod tests {
use super::*;
#[test]
fn test_client_tag() {
let tag = vec!["client", "voyage"];
let parsed = Nip89Tag::parse(&tag).unwrap();
assert_eq!(
parsed,
Nip89Tag::Client {
name: String::from("voyage"),
address: None
}
);
assert_eq!(parsed.to_tag(), Tag::parse(tag).unwrap());
}
#[test]
fn test_client_tag_with_coordinate() {
let tag = vec![
"client",
"voyage",
"30023:a695f6b60119d9521934a691347d9f78e8770b56da16bb255ee286ddf9fda919:ipsum",
];
let parsed = Nip89Tag::parse(&tag).unwrap();
assert_eq!(parsed, Nip89Tag::Client {name: String::from("voyage"), address: Some((Coordinate::parse("30023:a695f6b60119d9521934a691347d9f78e8770b56da16bb255ee286ddf9fda919:ipsum").unwrap(), None))});
assert_eq!(parsed.to_tag(), Tag::parse(tag).unwrap());
}
#[test]
fn test_client_tag_with_coordinate_and_relay_hint() {
let tag = vec![
"client",
"voyage",
"30023:a695f6b60119d9521934a691347d9f78e8770b56da16bb255ee286ddf9fda919:ipsum",
"wss://relay.damus.io",
];
let parsed = Nip89Tag::parse(&tag).unwrap();
assert_eq!(parsed, Nip89Tag::Client {name: String::from("voyage"), address: Some((Coordinate::parse("30023:a695f6b60119d9521934a691347d9f78e8770b56da16bb255ee286ddf9fda919:ipsum").unwrap(), Some(RelayUrl::parse("wss://relay.damus.io").unwrap())))});
assert_eq!(parsed.to_tag(), Tag::parse(tag).unwrap());
}
#[test]
fn test_client_tag_with_coordinate_and_empty_relay_hint() {
let tag = vec![
"client",
"voyage",
"30023:a695f6b60119d9521934a691347d9f78e8770b56da16bb255ee286ddf9fda919:ipsum",
"",
];
let parsed = Nip89Tag::parse(&tag).unwrap();
assert_eq!(parsed, Nip89Tag::Client {name: String::from("voyage"), address: Some((Coordinate::parse("30023:a695f6b60119d9521934a691347d9f78e8770b56da16bb255ee286ddf9fda919:ipsum").unwrap(), None))});
assert_eq!(
parsed.to_tag(),
Tag::parse(tag[..=2].iter().copied()).unwrap()
); }
}