deltachat/imap/
select_folder.rs

1//! # IMAP folder selection module.
2
3use anyhow::Context as _;
4
5use super::session::Session as ImapSession;
6use super::{get_uid_next, get_uidvalidity, set_modseq, set_uid_next, set_uidvalidity};
7use crate::context::Context;
8use crate::ensure_and_debug_assert;
9use crate::log::warn;
10
11type Result<T> = std::result::Result<T, Error>;
12
13#[derive(Debug, thiserror::Error)]
14pub enum Error {
15    #[error(
16        "Got a NO response when trying to select {0}, usually this means that it doesn't exist: {1}"
17    )]
18    NoFolder(String, String),
19
20    #[error("IMAP other error: {0}")]
21    Other(String),
22}
23
24impl From<anyhow::Error> for Error {
25    fn from(err: anyhow::Error) -> Error {
26        Error::Other(format!("{err:#}"))
27    }
28}
29
30impl ImapSession {
31    /// Issues a CLOSE command if selected folder needs expunge,
32    /// i.e. if Delta Chat marked a message there as deleted previously.
33    ///
34    /// CLOSE is considerably faster than an EXPUNGE
35    /// because no EXPUNGE responses are sent, see
36    /// <https://tools.ietf.org/html/rfc3501#section-6.4.2>
37    pub(super) async fn maybe_close_folder(&mut self, context: &Context) -> anyhow::Result<()> {
38        if let Some(folder) = &self.selected_folder
39            && self.selected_folder_needs_expunge
40        {
41            info!(context, "Expunge messages in {folder:?}.");
42
43            self.close().await.context("IMAP close/expunge failed")?;
44            info!(context, "Close/expunge succeeded.");
45            self.selected_folder = None;
46            self.selected_folder_needs_expunge = false;
47            self.new_mail = false;
48        }
49        Ok(())
50    }
51
52    /// Selects a folder, possibly updating uid_validity and, if needed,
53    /// expunging the folder to remove delete-marked messages.
54    /// Returns whether a new folder was selected.
55    async fn select_folder(&mut self, context: &Context, folder: &str) -> Result<NewlySelected> {
56        // if there is a new folder and the new folder is equal to the selected one, there's nothing to do.
57        // if there is _no_ new folder, we continue as we might want to expunge below.
58        if let Some(selected_folder) = &self.selected_folder
59            && folder == selected_folder
60        {
61            return Ok(NewlySelected::No);
62        }
63
64        // deselect existing folder, if needed (it's also done implicitly by SELECT, however, without EXPUNGE then)
65        self.maybe_close_folder(context).await?;
66
67        // select new folder
68        let res = if self.can_condstore() {
69            self.select_condstore(folder).await
70        } else {
71            self.select(folder).await
72        };
73
74        let transport_id = self.transport_id();
75
76        // <https://tools.ietf.org/html/rfc3501#section-6.3.1>
77        // says that if the server reports select failure we are in
78        // authenticated (not-select) state.
79
80        match res {
81            Ok(mailbox) => {
82                info!(
83                    context,
84                    "Transport {transport_id}: Selected folder {folder:?}."
85                );
86                self.selected_folder = Some(folder.to_string());
87                self.selected_mailbox = Some(mailbox);
88                Ok(NewlySelected::Yes)
89            }
90            Err(async_imap::error::Error::No(response)) => {
91                Err(Error::NoFolder(folder.to_string(), response))
92            }
93            Err(err) => Err(Error::Other(err.to_string())),
94        }
95    }
96
97    /// Selects a folder optionally creating it and takes care of UIDVALIDITY changes. Returns false
98    /// iff `folder` doesn't exist.
99    ///
100    /// When selecting a folder for the first time, sets the uid_next to the current
101    /// mailbox.uid_next so that no old emails are fetched.
102    ///
103    /// Updates `self.new_mail` if folder was previously unselected
104    /// and new mails are detected after selecting,
105    /// i.e. UIDNEXT advanced while the folder was closed.
106    pub(crate) async fn select_with_uidvalidity(
107        &mut self,
108        context: &Context,
109        folder: &str,
110    ) -> anyhow::Result<bool> {
111        let newly_selected = match self.select_folder(context, folder).await {
112            Ok(newly_selected) => newly_selected,
113            Err(err) => match err {
114                Error::NoFolder(..) => return Ok(false),
115                _ => {
116                    return Err(err)
117                        .with_context(|| format!("Failed to select folder {folder:?}"))?;
118                }
119            },
120        };
121        let transport_id = self.transport_id();
122
123        // Folders should not be selected when transport_id is not assigned yet
124        // because we cannot save UID validity then.
125        ensure_and_debug_assert!(
126            transport_id > 0,
127            "Cannot select folder when transport ID is unknown"
128        );
129
130        let mailbox = self
131            .selected_mailbox
132            .as_mut()
133            .with_context(|| format!("No mailbox selected, folder: {folder:?}"))?;
134
135        let old_uid_validity = get_uidvalidity(context, transport_id, folder)
136            .await
137            .with_context(|| format!("Failed to get old UID validity for folder {folder:?}"))?;
138        let old_uid_next = get_uid_next(context, transport_id, folder)
139            .await
140            .with_context(|| format!("Failed to get old UID NEXT for folder {folder:?}"))?;
141
142        let new_uid_validity = mailbox
143            .uid_validity
144            .with_context(|| format!("No UIDVALIDITY for folder {folder}"))?;
145        let new_uid_next = if let Some(uid_next) = mailbox.uid_next {
146            Some(uid_next)
147        } else {
148            warn!(
149                context,
150                "SELECT response for IMAP folder {folder:?} has no UIDNEXT, fall back to STATUS command."
151            );
152
153            // RFC 3501 says STATUS command SHOULD NOT be used
154            // on the currently selected mailbox because the same
155            // information can be obtained by other means,
156            // such as reading SELECT response.
157            //
158            // However, it also says that UIDNEXT is REQUIRED
159            // in the SELECT response and if we are here,
160            // it is actually not returned.
161            //
162            // In particular, Winmail Pro Mail Server 5.1.0616
163            // never returns UIDNEXT in SELECT response,
164            // but responds to "STATUS INBOX (UIDNEXT)" command.
165            let status = self
166                .inner
167                .status(folder, "(UIDNEXT)")
168                .await
169                .with_context(|| format!("STATUS (UIDNEXT) error for {folder:?}"))?;
170
171            if status.uid_next.is_none() {
172                // This happens with mail.163.com as of 2023-11-26.
173                // It does not return UIDNEXT on SELECT and returns invalid
174                // `* STATUS "INBOX" ()` response on explicit request for UIDNEXT.
175                warn!(context, "STATUS {folder} (UIDNEXT) did not return UIDNEXT.");
176            }
177            status.uid_next
178        };
179        mailbox.uid_next = new_uid_next;
180
181        if new_uid_validity == old_uid_validity {
182            if newly_selected == NewlySelected::Yes {
183                if let Some(new_uid_next) = new_uid_next {
184                    if new_uid_next < old_uid_next {
185                        warn!(
186                            context,
187                            "The server illegally decreased the uid_next of folder {folder:?} from {old_uid_next} to {new_uid_next} without changing validity ({new_uid_validity}), resyncing UIDs...",
188                        );
189                        set_uid_next(context, transport_id, folder, new_uid_next).await?;
190                        self.resync_request_sender.try_send(()).ok();
191                    }
192
193                    // If UIDNEXT changed, there are new emails.
194                    self.new_mail |= new_uid_next != old_uid_next;
195                } else {
196                    warn!(
197                        context,
198                        "Folder {folder} was just selected but we failed to determine UIDNEXT, assume that it has new mail."
199                    );
200                    self.new_mail = true;
201                }
202            }
203
204            return Ok(true);
205        }
206
207        // UIDVALIDITY is modified, reset highest seen MODSEQ.
208        set_modseq(context, transport_id, folder, 0).await?;
209
210        // ==============  uid_validity has changed or is being set the first time.  ==============
211
212        let new_uid_next = new_uid_next.unwrap_or_default();
213        set_uid_next(context, transport_id, folder, new_uid_next).await?;
214        set_uidvalidity(context, transport_id, folder, new_uid_validity).await?;
215        self.new_mail = true;
216
217        // Collect garbage entries in `imap` table.
218        context
219            .sql
220            .execute(
221                "DELETE FROM imap WHERE transport_id=? AND folder=? AND uidvalidity!=?",
222                (transport_id, &folder, new_uid_validity),
223            )
224            .await?;
225
226        if old_uid_validity != 0 || old_uid_next != 0 {
227            self.resync_request_sender.try_send(()).ok();
228        }
229        info!(
230            context,
231            "transport {transport_id}: UID validity for folder {folder} changed from {old_uid_validity}/{old_uid_next} to {new_uid_validity}/{new_uid_next}.",
232        );
233        Ok(true)
234    }
235}
236
237#[derive(PartialEq, Debug, Copy, Clone, Eq)]
238pub(crate) enum NewlySelected {
239    /// The folder was newly selected during this call to select_folder().
240    Yes,
241    /// No SELECT command was run because the folder already was selected
242    /// and self.config.selected_mailbox was not updated (so, e.g. it may contain an outdated uid_next)
243    No,
244}
deltachat/imap/select_folder.rs

deltachat/imap/
select_folder.rs
