sander/rust-imap
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Support for UID FETCH & tests

Browse source
This commit is contained in:
Miquel Ruiz 2016-07-11 22:48:03 +01:00
parent 2f1af34b2d
commit eb0b4d9b50
1 changed files with 20 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

22
src/client.rs
View file

@ -132,6 +132,10 @@ impl<T: Read+Write> Client<T> {
self.run_command_and_read_response(&format!("FETCH {} {}", sequence_set, query).to_string()) self.run_command_and_read_response(&format!("FETCH {} {}", sequence_set, query).to_string())
} }
pub fn uid_fetch(&mut self, uid_set: &str, query: &str) -> Result<Vec<String>> {
self.run_command_and_read_response(&format!("UID FETCH {} {}", uid_set, query).to_string())
}
/// Noop always succeeds, and it does nothing. /// Noop always succeeds, and it does nothing.
pub fn noop(&mut self) -> Result<()> { pub fn noop(&mut self) -> Result<()> {
self.run_command_and_check_ok("NOOP") self.run_command_and_check_ok("NOOP")
@ -388,13 +392,27 @@ mod tests {
#[test] #[test]
fn fetch() { fn fetch() {
generic_fetch(false)
}
#[test]
fn uid_fetch() {
generic_fetch(true)
}
fn generic_fetch(uid: bool) {
let response = b"a1 OK FETCH completed\r\n".to_vec(); let response = b"a1 OK FETCH completed\r\n".to_vec();
let sequence_set = "1"; let sequence_set = "1";
let query = "BODY[]"; let query = "BODY[]";
let command = format!("a1 FETCH {} {}\r\n", sequence_set, query); let uid_cmd = if uid { " UID " } else { " " };
let command = format!("a1{}FETCH {} {}\r\n", uid_cmd, sequence_set, query);
let mock_stream = MockStream::new(response); let mock_stream = MockStream::new(response);
let mut client = Client::new(mock_stream); let mut client = Client::new(mock_stream);
client.fetch(sequence_set, query).unwrap(); if uid {
client.uid_fetch(sequence_set, query).unwrap();
} else {
client.fetch(sequence_set, query).unwrap();
}
assert!(client.stream.written_buf == command.as_bytes().to_vec(), "Invalid fetch command"); assert!(client.stream.written_buf == command.as_bytes().to_vec(), "Invalid fetch command");
} }