Lines
29.63 %
Functions
4.55 %
Branches
0 %
/*
* This file is part of mailpot
*
* Copyright 2020 - Manos Pitsidianakis
* This program is free software: you can redistribute it and/or modify
* it under the terms of the GNU Affero General Public License as
* published by the Free Software Foundation, either version 3 of the
* License, or (at your option) any later version.
* This program is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
* GNU Affero General Public License for more details.
* You should have received a copy of the GNU Affero General Public License
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
use mailpot::models::{
changesets::{AccountChangeset, ListSubscriptionChangeset},
ListSubscription,
};
use super::*;
pub async fn settings(
_: SettingsPath,
mut session: WritableSession,
Extension(user): Extension<User>,
state: Arc<AppState>,
) -> Result<Html<String>, ResponseError> {
let crumbs = vec![
Crumb {
label: "Home".into(),
url: "/".into(),
},
label: "Settings".into(),
url: SettingsPath.to_crumb(),
];
let db = Connection::open_db(state.conf.clone())?;
let acc = db
.account_by_address(&user.address)
.with_status(StatusCode::BAD_REQUEST)?
.ok_or_else(|| {
ResponseError::new("Account not found".to_string(), StatusCode::BAD_REQUEST)
})?;
let subscriptions = db
.account_subscriptions(acc.pk())
.into_iter()
.filter_map(|s| match db.list(s.list) {
Err(err) => Some(Err(err)),
Ok(Some(list)) => Some(Ok((s, list))),
Ok(None) => None,
})
.collect::<Result<
Vec<(
DbVal<mailpot::models::ListSubscription>,
DbVal<mailpot::models::MailingList>,
)>,
mailpot::Error,
>>()?;
let context = minijinja::context! {
page_title => "Account settings",
user => user,
subscriptions => subscriptions,
current_user => user,
messages => session.drain_messages(),
crumbs => crumbs,
Ok(Html(
TEMPLATES.get_template("settings.html")?.render(context)?,
))
}
#[derive(serde::Serialize, serde::Deserialize, Debug, Clone)]
#[serde(tag = "type", rename_all = "kebab-case")]
pub enum ChangeSetting {
Subscribe { list_pk: IntPOST },
Unsubscribe { list_pk: IntPOST },
ChangePassword { new: String },
ChangePublicKey { new: String },
// RemovePassword,
RemovePublicKey,
ChangeName { new: String },
#[allow(non_snake_case)]
pub async fn settings_POST(
Form(payload): Form<ChangeSetting>,
) -> Result<Redirect, ResponseError> {
match payload {
ChangeSetting::Subscribe {
list_pk: IntPOST(list_pk),
} => {
.with_status(StatusCode::BAD_REQUEST)?;
if subscriptions.iter().any(|s| s.list == list_pk) {
session.add_message(Message {
message: "You are already subscribed to this list.".into(),
level: Level::Info,
} else {
db.add_subscription(
list_pk,
ListSubscription {
pk: 0,
list: list_pk,
account: Some(acc.pk()),
address: acc.address.clone(),
name: acc.name.clone(),
digest: false,
enabled: true,
verified: true,
hide_address: false,
receive_duplicates: false,
receive_own_posts: false,
receive_confirmation: false,
)?;
message: "You have subscribed to this list.".into(),
level: Level::Success,
ChangeSetting::Unsubscribe {
if !subscriptions.iter().any(|s| s.list == list_pk) {
message: "You are already not subscribed to this list.".into(),
let db = db.trusted();
db.remove_subscription(list_pk, &acc.address)?;
message: "You have unsubscribed from this list.".into(),
ChangeSetting::ChangePassword { new } => {
db.update_account(AccountChangeset {
name: None,
public_key: None,
password: Some(new.clone()),
enabled: None,
message: "You have successfully updated your SSH public key.".into(),
let mut user = user.clone();
user.password = new;
state.insert_user(acc.pk(), user).await;
ChangeSetting::ChangePublicKey { new } => {
public_key: Some(Some(new.clone())),
password: None,
message: "You have successfully updated your PGP public key.".into(),
user.public_key = Some(new);
ChangeSetting::RemovePublicKey => {
public_key: Some(None),
message: "You have successfully removed your PGP public key.".into(),
user.public_key = None;
ChangeSetting::ChangeName { new } => {
let new = if new.trim().is_empty() {
None
Some(new)
name: Some(new.clone()),
message: "You have successfully updated your name.".into(),
user.name = new.clone();
Ok(Redirect::to(&format!(
"{}{}",
&state.root_url_prefix,
SettingsPath.to_uri()
)))
pub async fn user_list_subscription(
ListSettingsPath(id): ListSettingsPath,
State(state): State<Arc<AppState>>,
let Some(list) = (match id {
ListPathIdentifier::Pk(id) => db.list(id)?,
ListPathIdentifier::Id(id) => db.list_by_id(id)?,
}) else {
return Err(ResponseError::new(
"List not found".to_string(),
StatusCode::NOT_FOUND,
));
let acc = match db.account_by_address(&user.address)? {
Some(v) => v,
None => {
"Account not found".to_string(),
StatusCode::BAD_REQUEST,
let mut subscriptions = db
subscriptions.retain(|s| s.list == list.pk());
let subscription = db
.list_subscription(
list.pk(),
subscriptions
.first()
ResponseError::new(
"Subscription not found".to_string(),
)
})?
.pk(),
label: "List Subscription".into(),
url: ListSettingsPath(list.pk().into()).to_crumb(),
let list_owners = db.list_owners(list.pk)?;
let mut list = crate::minijinja_utils::MailingList::from(list);
list.set_safety(list_owners.as_slice(), &state.conf.administrators);
page_title => "Subscription settings",
list => list,
subscription => subscription,
TEMPLATES
.get_template("settings_subscription.html")?
.render(context)?,
#[derive(serde::Serialize, serde::Deserialize, Debug, Clone, Default)]
pub struct SubscriptionFormPayload {
#[serde(default)]
pub digest: bool,
pub hide_address: bool,
pub receive_duplicates: bool,
pub receive_own_posts: bool,
pub receive_confirmation: bool,
pub async fn user_list_subscription_POST(
Form(payload): Form<SubscriptionFormPayload>,
"Account with this address was not found".to_string(),
let mut s = db
.list_subscription(list.pk(), subscriptions[0].pk())
let SubscriptionFormPayload {
digest,
hide_address,
receive_duplicates,
receive_own_posts,
receive_confirmation,
} = payload;
let cset = ListSubscriptionChangeset {
list: s.list,
address: std::mem::take(&mut s.address),
account: None,
digest: Some(digest),
hide_address: Some(hide_address),
receive_duplicates: Some(receive_duplicates),
receive_own_posts: Some(receive_own_posts),
receive_confirmation: Some(receive_confirmation),
verified: None,
db.update_subscription(cset)
message: "Settings saved successfully.".into(),
ListSettingsPath(list.id.clone().into()).to_uri()