From 90b143e1c57c6561998176878b2cc586b2d89c80 Mon Sep 17 00:00:00 2001
From: Alex Auvolat <alex@adnab.me>
Date: Wed, 29 Jun 2022 12:50:44 +0200
Subject: Refactor to allow mutability

---
 src/imap/session.rs | 41 +++++++++++++++++++++++++++--------------
 1 file changed, 27 insertions(+), 14 deletions(-)

(limited to 'src/imap/session.rs')

diff --git a/src/imap/session.rs b/src/imap/session.rs
index 30885d1..72dd9d8 100644
--- a/src/imap/session.rs
+++ b/src/imap/session.rs
@@ -102,23 +102,36 @@ impl Instance {
         tracing::debug!("starting runner");
 
         while let Some(msg) = self.rx.recv().await {
-            let ctx = InnerContext {
-                req: &msg.req,
-                state: &self.state,
-                login: &self.login_provider,
-            };
-
             // Command behavior is modulated by the state.
             // To prevent state error, we handle the same command in separate code paths.
-            let ctrl = match &self.state {
-                flow::State::NotAuthenticated => anonymous::dispatch(ctx).await,
-                flow::State::Authenticated(user) => authenticated::dispatch(ctx, user).await,
-                flow::State::Selected(user, mailbox) => {
-                    selected::dispatch(ctx, user, mailbox).await
+            let ctrl = match &mut self.state {
+                flow::State::NotAuthenticated => {
+                    let ctx = anonymous::AnonymousContext {
+                        req: &msg.req,
+                        login_provider: Some(&self.login_provider),
+                    };
+                    anonymous::dispatch(ctx).await
+                }
+                flow::State::Authenticated(ref user) => {
+                    let ctx = authenticated::AuthenticatedContext {
+                        req: &msg.req,
+                        user,
+                    };
+                    authenticated::dispatch(ctx).await
+                }
+                flow::State::Selected(ref user, ref mut mailbox) => {
+                    let ctx = selected::SelectedContext {
+                        req: &msg.req,
+                        user,
+                        mailbox,
+                    };
+                    selected::dispatch(ctx).await
+                }
+                flow::State::Logout => {
+                    Response::bad("No commands are allowed in the LOGOUT state.")
+                        .map(|r| (r, flow::Transition::None))
+                        .map_err(Error::msg)
                 }
-                _ => Response::bad("No commands are allowed in the LOGOUT state.")
-                    .map(|r| (r, flow::Transition::No))
-                    .map_err(Error::msg),
             };
 
             // Process result
-- 
cgit v1.2.3