xmpp-parsers: Convert bind to xso
This commit is contained in:
parent
2df243966f
commit
f37b7b4dfd
1 changed files with 18 additions and 83 deletions
|
|
@ -4,23 +4,24 @@
|
||||||
// License, v. 2.0. If a copy of the MPL was not distributed with this
|
// License, v. 2.0. If a copy of the MPL was not distributed with this
|
||||||
// file, You can obtain one at http://mozilla.org/MPL/2.0/.
|
// file, You can obtain one at http://mozilla.org/MPL/2.0/.
|
||||||
|
|
||||||
|
use xso::{AsXml, FromXml};
|
||||||
|
|
||||||
use crate::iq::{IqResultPayload, IqSetPayload};
|
use crate::iq::{IqResultPayload, IqSetPayload};
|
||||||
use crate::ns;
|
use crate::ns;
|
||||||
use jid::{FullJid, Jid};
|
use jid::{FullJid, Jid};
|
||||||
use minidom::Element;
|
|
||||||
use std::str::FromStr;
|
|
||||||
use xso::error::{Error, FromElementError};
|
|
||||||
|
|
||||||
/// The request for resource binding, which is the process by which a client
|
/// The request for resource binding, which is the process by which a client
|
||||||
/// can obtain a full JID and start exchanging on the XMPP network.
|
/// can obtain a full JID and start exchanging on the XMPP network.
|
||||||
///
|
///
|
||||||
/// See <https://xmpp.org/rfcs/rfc6120.html#bind>
|
/// See <https://xmpp.org/rfcs/rfc6120.html#bind>
|
||||||
#[derive(Debug, Clone, PartialEq)]
|
#[derive(FromXml, AsXml, Debug, Clone, PartialEq)]
|
||||||
|
#[xml(namespace = ns::BIND, name = "bind")]
|
||||||
pub struct BindQuery {
|
pub struct BindQuery {
|
||||||
/// Requests this resource, the server may associate another one though.
|
/// Requests this resource, the server may associate another one though.
|
||||||
///
|
///
|
||||||
/// If this is None, we request no particular resource, and a random one
|
/// If this is None, we request no particular resource, and a random one
|
||||||
/// will be affected by the server.
|
/// will be affected by the server.
|
||||||
|
#[xml(extract(default, fields(text(type_ = String))))]
|
||||||
resource: Option<String>,
|
resource: Option<String>,
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
@ -33,48 +34,14 @@ impl BindQuery {
|
||||||
|
|
||||||
impl IqSetPayload for BindQuery {}
|
impl IqSetPayload for BindQuery {}
|
||||||
|
|
||||||
impl TryFrom<Element> for BindQuery {
|
|
||||||
type Error = FromElementError;
|
|
||||||
|
|
||||||
fn try_from(elem: Element) -> Result<BindQuery, FromElementError> {
|
|
||||||
check_self!(elem, "bind", BIND);
|
|
||||||
check_no_attributes!(elem, "bind");
|
|
||||||
|
|
||||||
let mut resource = None;
|
|
||||||
for child in elem.children() {
|
|
||||||
if resource.is_some() {
|
|
||||||
return Err(Error::Other("Bind can only have one child.").into());
|
|
||||||
}
|
|
||||||
if child.is("resource", ns::BIND) {
|
|
||||||
check_no_attributes!(child, "resource");
|
|
||||||
check_no_children!(child, "resource");
|
|
||||||
resource = Some(child.text());
|
|
||||||
} else {
|
|
||||||
return Err(Error::Other("Unknown element in bind request.").into());
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
Ok(BindQuery { resource })
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
impl From<BindQuery> for Element {
|
|
||||||
fn from(bind: BindQuery) -> Element {
|
|
||||||
Element::builder("bind", ns::BIND)
|
|
||||||
.append_all(
|
|
||||||
bind.resource
|
|
||||||
.map(|resource| Element::builder("resource", ns::BIND).append(resource)),
|
|
||||||
)
|
|
||||||
.build()
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
/// The response for resource binding, containing the client’s full JID.
|
/// The response for resource binding, containing the client’s full JID.
|
||||||
///
|
///
|
||||||
/// See <https://xmpp.org/rfcs/rfc6120.html#bind>
|
/// See <https://xmpp.org/rfcs/rfc6120.html#bind>
|
||||||
#[derive(Debug, Clone, PartialEq)]
|
#[derive(FromXml, AsXml, Debug, Clone, PartialEq)]
|
||||||
|
#[xml(namespace = ns::BIND, name = "bind")]
|
||||||
pub struct BindResponse {
|
pub struct BindResponse {
|
||||||
/// The full JID returned by the server for this client.
|
/// The full JID returned by the server for this client.
|
||||||
|
#[xml(extract(fields(text(type_ = FullJid))))]
|
||||||
jid: FullJid,
|
jid: FullJid,
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
@ -92,49 +59,11 @@ impl From<BindResponse> for Jid {
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
impl TryFrom<Element> for BindResponse {
|
|
||||||
type Error = FromElementError;
|
|
||||||
|
|
||||||
fn try_from(elem: Element) -> Result<BindResponse, FromElementError> {
|
|
||||||
check_self!(elem, "bind", BIND);
|
|
||||||
check_no_attributes!(elem, "bind");
|
|
||||||
|
|
||||||
let mut jid = None;
|
|
||||||
for child in elem.children() {
|
|
||||||
if jid.is_some() {
|
|
||||||
return Err(Error::Other("Bind can only have one child.").into());
|
|
||||||
}
|
|
||||||
if child.is("jid", ns::BIND) {
|
|
||||||
check_no_attributes!(child, "jid");
|
|
||||||
check_no_children!(child, "jid");
|
|
||||||
jid = Some(FullJid::from_str(&child.text()).map_err(Error::text_parse_error)?);
|
|
||||||
} else {
|
|
||||||
return Err(Error::Other("Unknown element in bind response.").into());
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
Ok(BindResponse {
|
|
||||||
jid: match jid {
|
|
||||||
None => {
|
|
||||||
return Err(Error::Other("Bind response must contain a jid element.").into())
|
|
||||||
}
|
|
||||||
Some(jid) => jid,
|
|
||||||
},
|
|
||||||
})
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
impl From<BindResponse> for Element {
|
|
||||||
fn from(bind: BindResponse) -> Element {
|
|
||||||
Element::builder("bind", ns::BIND)
|
|
||||||
.append(Element::builder("jid", ns::BIND).append(bind.jid))
|
|
||||||
.build()
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
#[cfg(test)]
|
#[cfg(test)]
|
||||||
mod tests {
|
mod tests {
|
||||||
use super::*;
|
use super::*;
|
||||||
|
use minidom::Element;
|
||||||
|
use xso::error::{Error, FromElementError};
|
||||||
|
|
||||||
#[cfg(target_pointer_width = "32")]
|
#[cfg(target_pointer_width = "32")]
|
||||||
#[test]
|
#[test]
|
||||||
|
|
@ -188,7 +117,10 @@ mod tests {
|
||||||
FromElementError::Invalid(Error::Other(string)) => string,
|
FromElementError::Invalid(Error::Other(string)) => string,
|
||||||
_ => panic!(),
|
_ => panic!(),
|
||||||
};
|
};
|
||||||
assert_eq!(message, "Unknown attribute in resource element.");
|
assert_eq!(
|
||||||
|
message,
|
||||||
|
"Unknown attribute in extraction for field 'resource' in BindQuery element."
|
||||||
|
);
|
||||||
|
|
||||||
let elem: Element = "<bind xmlns='urn:ietf:params:xml:ns:xmpp-bind'><resource><hello-world/>resource</resource></bind>"
|
let elem: Element = "<bind xmlns='urn:ietf:params:xml:ns:xmpp-bind'><resource><hello-world/>resource</resource></bind>"
|
||||||
.parse()
|
.parse()
|
||||||
|
|
@ -198,6 +130,9 @@ mod tests {
|
||||||
FromElementError::Invalid(Error::Other(string)) => string,
|
FromElementError::Invalid(Error::Other(string)) => string,
|
||||||
_ => panic!(),
|
_ => panic!(),
|
||||||
};
|
};
|
||||||
assert_eq!(message, "Unknown child in resource element.");
|
assert_eq!(
|
||||||
|
message,
|
||||||
|
"Unknown child in extraction for field 'resource' in BindQuery element."
|
||||||
|
);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
|
||||||
Loading…
Reference in a new issue