jcoffey-dev
6a53d47106
The AGPL asks a modified version to carry prominent notices saying it was modified, and giving a date. Publishing the source is the conveyance that asks for it, so it wants doing before the repository is public rather than at the release. Every upstream file the fork changed now says so in its header, beneath the notice it came with: 164 files, found by diffing against the upstream snapshot branch rather than by guessing, so the list is what actually differs. Files the fork wrote itself already carry their own copyright and need nothing. Upstream's notices are untouched, which its licence requires and which was already true. The README says the same thing in prose, since the obligation is on the work as a whole and not only its Rust files. Builds unchanged: the server and the test binary both compile.
89 lines
2.0 KiB
Rust
89 lines
2.0 KiB
Rust
/*
|
|
* SPDX-FileCopyrightText: 2020 Stalwart Labs LLC <[email protected]>
|
|
*
|
|
* SPDX-License-Identifier: AGPL-3.0-only OR LicenseRef-SEL
|
|
*
|
|
* Modified by Coffey Labs in 2026 for INBUXA.
|
|
*/
|
|
|
|
// inbuxa: composite stores (sharded members, read replicas) nest store
|
|
// futures deeply enough to pass rustc's default query depth
|
|
#![recursion_limit = "512"]
|
|
|
|
#![warn(clippy::large_futures)]
|
|
|
|
use std::{net::IpAddr, sync::Arc};
|
|
|
|
use common::{
|
|
Inner, Server,
|
|
auth::AccessToken,
|
|
network::{ServerInstance, SessionStream, limiter::InFlight},
|
|
};
|
|
use mailbox::Mailbox;
|
|
use protocol::request::Parser;
|
|
|
|
pub mod client;
|
|
pub mod mailbox;
|
|
pub mod op;
|
|
pub mod protocol;
|
|
pub mod session;
|
|
|
|
static SERVER_GREETING: &str = concat!("+OK ", types::brand!(), " POP3 at your service.\r\n");
|
|
|
|
#[derive(Clone)]
|
|
pub struct Pop3SessionManager {
|
|
pub inner: Arc<Inner>,
|
|
}
|
|
|
|
impl Pop3SessionManager {
|
|
pub fn new(inner: Arc<Inner>) -> Self {
|
|
Self { inner }
|
|
}
|
|
}
|
|
|
|
pub struct Session<T: SessionStream> {
|
|
pub server: Server,
|
|
pub instance: Arc<ServerInstance>,
|
|
pub receiver: Parser,
|
|
pub state: State,
|
|
pub stream: T,
|
|
pub in_flight: InFlight,
|
|
pub remote_addr: IpAddr,
|
|
pub session_id: u64,
|
|
}
|
|
|
|
pub enum State {
|
|
NotAuthenticated {
|
|
auth_failures: u32,
|
|
username: Option<String>,
|
|
},
|
|
Authenticated {
|
|
mailbox: Mailbox,
|
|
in_flight: Option<InFlight>,
|
|
access_token: AccessToken,
|
|
},
|
|
}
|
|
|
|
impl State {
|
|
pub fn mailbox(&self) -> &Mailbox {
|
|
match self {
|
|
State::Authenticated { mailbox, .. } => mailbox,
|
|
_ => unreachable!(),
|
|
}
|
|
}
|
|
|
|
pub fn mailbox_mut(&mut self) -> &mut Mailbox {
|
|
match self {
|
|
State::Authenticated { mailbox, .. } => mailbox,
|
|
_ => unreachable!(),
|
|
}
|
|
}
|
|
|
|
pub fn access_token(&self) -> &AccessToken {
|
|
match self {
|
|
State::Authenticated { access_token, .. } => access_token,
|
|
_ => unreachable!(),
|
|
}
|
|
}
|
|
}
|