Method run_command

src/email.rs:505–547

(&mut self, command: &str)

    }

    fn run_command(&mut self, command: &str) -> Result<ImapCommandOutput, EmailServiceError> {
        let tag = format!("A{:04}", self.next_tag);
        self.next_tag = self.next_tag.saturating_add(1);

        let command_line = format!("{tag} {command}\r\n");
        self.stream
            .get_mut()
            .write_all(command_line.as_bytes())
            .map_err(|e| EmailServiceError::Api(format!("failed to write IMAP command: {e}")))?;
        self.stream
            .get_mut()
            .flush()
            .map_err(|e| EmailServiceError::Api(format!("failed to flush IMAP command: {e}")))?;

        let mut lines = Vec::new();
        let mut literals = Vec::new();

        loop {
            let line = self.read_line()?;
            let literal_size = parse_literal_size(&line);
            lines.push(line.clone());

            if let Some(size) = literal_size {
                let mut literal = vec![0u8; size];
                self.stream.read_exact(&mut literal).map_err(|e| {
                    EmailServiceError::Api(format!("failed to read IMAP literal: {e}"))
                })?;
                literals.push(literal);
            }

            if line.starts_with(&tag) {
                let upper = line.to_ascii_uppercase();
                if !upper.contains(" OK") {
                    return Err(EmailServiceError::Api(format!(
                        "IMAP command '{command}' failed: {line}"
                    )));
                }
                break;
            }
        }

        Ok(ImapCommandOutput { lines, literals })
    }

    fn read_line(&mut self) -> Result<String, EmailServiceError> {
        let mut line = String::new();