1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
|
use std::process::Command;
use std::net::{Shutdown, TcpStream};
use std::{thread, time};
use anyhow::Result;
use std::io::{Write, Read};
static ONE_SEC: time::Duration = time::Duration::from_secs(1);
fn main() {
let mut daemon = Command::new(env!("CARGO_BIN_EXE_aerogramme"))
.arg("--dev")
.arg("provider")
.arg("daemon")
.spawn()
.expect("daemon should be started");
let mut max_retry = 10;
let mut imap_socket = loop {
max_retry -= 1;
match (TcpStream::connect("[::1]:1143"), max_retry) {
(Err(e), 0) => panic!("no more retry, last error is: {}", e),
(Err(e), _) => {
println!("unable to connect: {} ; will retry in 1 sec", e);
},
(Ok(v), _) => break v,
}
thread::sleep(ONE_SEC);
};
let mut lmtp_socket = TcpStream::connect("[::1]:1025").expect("lmtp socket must be connected");
println!("-- ready to test imap features --");
login(&mut imap_socket).expect("login test");
select_inbox(&mut imap_socket).expect("select inbox");
inject_email(&mut lmtp_socket).expect("inject email");
println!("-- test teardown --");
imap_socket.shutdown(Shutdown::Both).expect("closing imap socket at the end of the test");
lmtp_socket.shutdown(Shutdown::Both).expect("closing lmtp socket at the end of the test");
daemon.kill().expect("daemon should be killed");
}
fn login(imap: &mut TcpStream) -> Result<()> {
let mut buffer: [u8; 1500] = [0; 1500];
let mut nbytes = 0;
loop {
nbytes += imap.read(&mut buffer)?;
if buffer[..nbytes].windows(2).any(|w| w == &b"\r\n"[..]) {
break
}
}
println!("read: {}", std::str::from_utf8(&buffer[..nbytes])?);
assert_eq!(&buffer[..4], &b"* OK"[..]);
assert_eq!(&buffer[nbytes-2..nbytes], &b"\r\n"[..]);
imap.write(&b"10 login alice hunter2\r\n"[..])?;
let mut nbytes = 0;
loop {
nbytes += imap.read(&mut buffer)?;
if &buffer[nbytes-2..nbytes] == &b"\r\n"[..] {
break
}
}
println!("read: {}", std::str::from_utf8(&buffer[..nbytes])?);
assert_eq!(&buffer[..5], &b"10 OK"[..]);
Ok(())
}
fn select_inbox(imap: &mut TcpStream) -> Result<()> {
let mut buffer: [u8; 6000] = [0; 6000];
imap.write(&b"20 select inbox\r\n"[..])?;
let mut nbytes = 0;
loop {
nbytes += imap.read(&mut buffer)?;
if buffer[..nbytes].windows(5).any(|w| w == &b"20 OK"[..]) && &buffer[nbytes-2..nbytes] == &b"\r\n"[..] {
break
}
}
println!("read: {}", std::str::from_utf8(&buffer[..nbytes])?);
Ok(())
}
fn inject_email(lmtp: &mut TcpStream) -> Result<()> {
Ok(())
}
|
