mirror of
https://github.com/chatmail/core.git
synced 2026-05-02 12:56:30 +03:00
Add an error type to configure::auto_outlook module
This commit is contained in:
@@ -1,14 +1,29 @@
|
|||||||
|
//! Outlook's Autodiscover
|
||||||
|
|
||||||
|
use failure::Fail;
|
||||||
|
|
||||||
use quick_xml;
|
use quick_xml;
|
||||||
use quick_xml::events::BytesEnd;
|
use quick_xml::events::BytesEnd;
|
||||||
|
|
||||||
use crate::constants::*;
|
use crate::constants::*;
|
||||||
use crate::context::Context;
|
use crate::context::Context;
|
||||||
use crate::error::Error;
|
|
||||||
use crate::login_param::LoginParam;
|
use crate::login_param::LoginParam;
|
||||||
|
|
||||||
use super::read_autoconf_file;
|
use super::read_autoconf_file;
|
||||||
|
|
||||||
/// Outlook's Autodiscover
|
#[derive(Debug, Fail)]
|
||||||
|
enum Error {
|
||||||
|
#[fail(display = "XML error at position {}", position)]
|
||||||
|
InvalidXml {
|
||||||
|
position: usize,
|
||||||
|
#[cause]
|
||||||
|
error: quick_xml::Error,
|
||||||
|
},
|
||||||
|
|
||||||
|
#[fail(display = "Bad or incomplete autoconfig")]
|
||||||
|
IncompleteAutoconfig(LoginParam),
|
||||||
|
}
|
||||||
|
|
||||||
struct OutlookAutodiscover {
|
struct OutlookAutodiscover {
|
||||||
pub out: LoginParam,
|
pub out: LoginParam,
|
||||||
pub out_imap_set: bool,
|
pub out_imap_set: bool,
|
||||||
@@ -25,7 +40,7 @@ enum ParsingResult {
|
|||||||
RedirectUrl(String),
|
RedirectUrl(String),
|
||||||
}
|
}
|
||||||
|
|
||||||
fn outlk_parse_xml(xml_raw: &str) -> Result<ParsingResult, Error> {
|
fn parse_xml(xml_raw: &str) -> Result<ParsingResult, Error> {
|
||||||
let mut outlk_ad = OutlookAutodiscover {
|
let mut outlk_ad = OutlookAutodiscover {
|
||||||
out: LoginParam::new(),
|
out: LoginParam::new(),
|
||||||
out_imap_set: false,
|
out_imap_set: false,
|
||||||
@@ -45,8 +60,15 @@ fn outlk_parse_xml(xml_raw: &str) -> Result<ParsingResult, Error> {
|
|||||||
let mut current_tag: Option<String> = None;
|
let mut current_tag: Option<String> = None;
|
||||||
|
|
||||||
loop {
|
loop {
|
||||||
match reader.read_event(&mut buf) {
|
let event = reader
|
||||||
Ok(quick_xml::events::Event::Start(ref e)) => {
|
.read_event(&mut buf)
|
||||||
|
.map_err(|error| Error::InvalidXml {
|
||||||
|
position: reader.buffer_position(),
|
||||||
|
error,
|
||||||
|
})?;
|
||||||
|
|
||||||
|
match event {
|
||||||
|
quick_xml::events::Event::Start(ref e) => {
|
||||||
let tag = String::from_utf8_lossy(e.name()).trim().to_lowercase();
|
let tag = String::from_utf8_lossy(e.name()).trim().to_lowercase();
|
||||||
|
|
||||||
if tag == "protocol" {
|
if tag == "protocol" {
|
||||||
@@ -61,11 +83,11 @@ fn outlk_parse_xml(xml_raw: &str) -> Result<ParsingResult, Error> {
|
|||||||
current_tag = Some(tag);
|
current_tag = Some(tag);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
Ok(quick_xml::events::Event::End(ref e)) => {
|
quick_xml::events::Event::End(ref e) => {
|
||||||
outlk_autodiscover_endtag_cb(e, &mut outlk_ad);
|
outlk_autodiscover_endtag_cb(e, &mut outlk_ad);
|
||||||
current_tag = None;
|
current_tag = None;
|
||||||
}
|
}
|
||||||
Ok(quick_xml::events::Event::Text(ref e)) => {
|
quick_xml::events::Event::Text(ref e) => {
|
||||||
let val = e.unescape_and_decode(&reader).unwrap_or_default();
|
let val = e.unescape_and_decode(&reader).unwrap_or_default();
|
||||||
|
|
||||||
if let Some(ref tag) = current_tag {
|
if let Some(ref tag) = current_tag {
|
||||||
@@ -81,21 +103,14 @@ fn outlk_parse_xml(xml_raw: &str) -> Result<ParsingResult, Error> {
|
|||||||
};
|
};
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
Err(e) => {
|
quick_xml::events::Event::Eof => break,
|
||||||
bail!(
|
|
||||||
"Configure xml: Error at position {}: {:?}",
|
|
||||||
reader.buffer_position(),
|
|
||||||
e
|
|
||||||
);
|
|
||||||
}
|
|
||||||
Ok(quick_xml::events::Event::Eof) => break,
|
|
||||||
_ => (),
|
_ => (),
|
||||||
}
|
}
|
||||||
buf.clear();
|
buf.clear();
|
||||||
}
|
}
|
||||||
|
|
||||||
// XML redirect via redirecturl
|
// XML redirect via redirecturl
|
||||||
if outlk_ad.config_redirecturl.is_none()
|
let res = if outlk_ad.config_redirecturl.is_none()
|
||||||
|| outlk_ad.config_redirecturl.as_ref().unwrap().is_empty()
|
|| outlk_ad.config_redirecturl.as_ref().unwrap().is_empty()
|
||||||
{
|
{
|
||||||
if outlk_ad.out.mail_server.is_empty()
|
if outlk_ad.out.mail_server.is_empty()
|
||||||
@@ -103,15 +118,13 @@ fn outlk_parse_xml(xml_raw: &str) -> Result<ParsingResult, Error> {
|
|||||||
|| outlk_ad.out.send_server.is_empty()
|
|| outlk_ad.out.send_server.is_empty()
|
||||||
|| outlk_ad.out.send_port == 0
|
|| outlk_ad.out.send_port == 0
|
||||||
{
|
{
|
||||||
let r = outlk_ad.out.to_string();
|
return Err(Error::IncompleteAutoconfig(outlk_ad.out));
|
||||||
bail!("Bad or incomplete autoconfig: {}", r,);
|
|
||||||
}
|
}
|
||||||
Ok(ParsingResult::LoginParam(outlk_ad.out))
|
ParsingResult::LoginParam(outlk_ad.out)
|
||||||
} else {
|
} else {
|
||||||
Ok(ParsingResult::RedirectUrl(
|
ParsingResult::RedirectUrl(outlk_ad.config_redirecturl.unwrap())
|
||||||
outlk_ad.config_redirecturl.unwrap(),
|
};
|
||||||
))
|
Ok(res)
|
||||||
}
|
|
||||||
}
|
}
|
||||||
|
|
||||||
pub fn outlk_autodiscover(
|
pub fn outlk_autodiscover(
|
||||||
@@ -123,7 +136,7 @@ pub fn outlk_autodiscover(
|
|||||||
/* Follow up to 10 xml-redirects (http-redirects are followed in read_autoconf_file() */
|
/* Follow up to 10 xml-redirects (http-redirects are followed in read_autoconf_file() */
|
||||||
for _i in 0..10 {
|
for _i in 0..10 {
|
||||||
if let Some(xml_raw) = read_autoconf_file(context, &url) {
|
if let Some(xml_raw) = read_autoconf_file(context, &url) {
|
||||||
match outlk_parse_xml(&xml_raw) {
|
match parse_xml(&xml_raw) {
|
||||||
Err(err) => {
|
Err(err) => {
|
||||||
warn!(context, "{}", err);
|
warn!(context, "{}", err);
|
||||||
return None;
|
return None;
|
||||||
@@ -179,7 +192,7 @@ mod tests {
|
|||||||
|
|
||||||
#[test]
|
#[test]
|
||||||
fn test_parse_redirect() {
|
fn test_parse_redirect() {
|
||||||
let res = outlk_parse_xml("
|
let res = parse_xml("
|
||||||
<?xml version=\"1.0\" encoding=\"utf-8\"?>
|
<?xml version=\"1.0\" encoding=\"utf-8\"?>
|
||||||
<Autodiscover xmlns=\"http://schemas.microsoft.com/exchange/autodiscover/responseschema/2006\">
|
<Autodiscover xmlns=\"http://schemas.microsoft.com/exchange/autodiscover/responseschema/2006\">
|
||||||
<Response xmlns=\"http://schemas.microsoft.com/exchange/autodiscover/outlook/responseschema/2006a\">
|
<Response xmlns=\"http://schemas.microsoft.com/exchange/autodiscover/outlook/responseschema/2006a\">
|
||||||
@@ -206,7 +219,7 @@ mod tests {
|
|||||||
|
|
||||||
#[test]
|
#[test]
|
||||||
fn test_parse_loginparam() {
|
fn test_parse_loginparam() {
|
||||||
let res = outlk_parse_xml(
|
let res = parse_xml(
|
||||||
"\
|
"\
|
||||||
<?xml version=\"1.0\" encoding=\"utf-8\"?>
|
<?xml version=\"1.0\" encoding=\"utf-8\"?>
|
||||||
<Autodiscover xmlns=\"http://schemas.microsoft.com/exchange/autodiscover/responseschema/2006\">
|
<Autodiscover xmlns=\"http://schemas.microsoft.com/exchange/autodiscover/responseschema/2006\">
|
||||||
|
|||||||
Reference in New Issue
Block a user