aboutsummaryrefslogtreecommitdiff
path: root/tests/common/fragments.rs
diff options
context:
space:
mode:
authorQuentin Dufour <quentin@deuxfleurs.fr>2024-01-19 14:13:43 +0100
committerQuentin Dufour <quentin@deuxfleurs.fr>2024-01-19 14:13:43 +0100
commit23aa313e11f344da07143d60ce446b5f23d5f362 (patch)
tree7f6c4fec623d0d99d3f09e752a360ca0f806429e /tests/common/fragments.rs
parent2c5adc8f166c6117ece353376b9071f5e30857b1 (diff)
downloadaerogramme-23aa313e11f344da07143d60ce446b5f23d5f362.tar.gz
aerogramme-23aa313e11f344da07143d60ce446b5f23d5f362.zip
Testing idlefeat/idle
Diffstat (limited to 'tests/common/fragments.rs')
-rw-r--r--tests/common/fragments.rs18
1 files changed, 18 insertions, 0 deletions
diff --git a/tests/common/fragments.rs b/tests/common/fragments.rs
index 29d5d10..7f7967a 100644
--- a/tests/common/fragments.rs
+++ b/tests/common/fragments.rs
@@ -36,6 +36,7 @@ pub enum Extension {
Move,
Condstore,
LiteralPlus,
+ Idle,
}
pub enum Enable {
@@ -114,6 +115,7 @@ pub fn capability(imap: &mut TcpStream, ext: Extension) -> Result<()> {
Extension::Move => Some("MOVE"),
Extension::Condstore => Some("CONDSTORE"),
Extension::LiteralPlus => Some("LITERAL+"),
+ Extension::Idle => Some("IDLE"),
};
let mut buffer: [u8; 6000] = [0; 6000];
@@ -496,6 +498,22 @@ pub fn enable(imap: &mut TcpStream, ask: Enable, done: Option<Enable>) -> Result
Ok(())
}
+pub fn start_idle(imap: &mut TcpStream) -> Result<()> {
+ let mut buffer: [u8; 1500] = [0; 1500];
+ imap.write(&b"98 IDLE\r\n"[..])?;
+ let read = read_lines(imap, &mut buffer, None)?;
+ assert_eq!(read[0], b'+');
+ Ok(())
+}
+
+pub fn stop_idle(imap: &mut TcpStream) -> Result<String> {
+ let mut buffer: [u8; 16536] = [0; 16536];
+ imap.write(&b"DONE\r\n"[..])?;
+ let read = read_lines(imap, &mut buffer, Some(&b"98 OK"[..]))?;
+ let srv_msg = std::str::from_utf8(read)?;
+ Ok(srv_msg.to_string())
+}
+
pub fn logout(imap: &mut TcpStream) -> Result<()> {
imap.write(&b"99 logout\r\n"[..])?;
let mut buffer: [u8; 1500] = [0; 1500];