use anyhow::Context as _;
use async_graphql::{Context, Description, Enum, InputObject, Object, ID};
use crate::graphql::{
model::{NodeType, User},
state::ContextExt,
UserId,
};
#[derive(Default)]
pub struct MatrixMutations {
_private: (),
}
#[derive(InputObject)]
struct SetDisplayNameInput {
user_id: ID,
display_name: Option<String>,
}
#[derive(Enum, Copy, Clone, Eq, PartialEq)]
pub enum SetDisplayNameStatus {
Set,
Invalid,
}
#[derive(Description)]
enum SetDisplayNamePayload {
Set(User),
Invalid,
}
#[Object(use_type_description)]
impl SetDisplayNamePayload {
async fn status(&self) -> SetDisplayNameStatus {
match self {
SetDisplayNamePayload::Set(_) => SetDisplayNameStatus::Set,
SetDisplayNamePayload::Invalid => SetDisplayNameStatus::Invalid,
}
}
async fn user(&self) -> Option<&User> {
match self {
SetDisplayNamePayload::Set(user) => Some(user),
SetDisplayNamePayload::Invalid => None,
}
}
}
#[Object]
impl MatrixMutations {
async fn set_display_name(
&self,
ctx: &Context<'_>,
input: SetDisplayNameInput,
) -> Result<SetDisplayNamePayload, async_graphql::Error> {
let state = ctx.state();
let id = NodeType::User.extract_ulid(&input.user_id)?;
let requester = ctx.requester();
if !requester.is_owner_or_admin(&UserId(id)) {
return Err(async_graphql::Error::new("Unauthorized"));
}
if !requester.is_admin() && !state.site_config().displayname_change_allowed {
return Err(async_graphql::Error::new("Unauthorized"));
}
let mut repo = state.repository().await?;
let user = repo
.user()
.lookup(id)
.await?
.context("Failed to lookup user")?;
repo.cancel().await?;
let conn = state.homeserver_connection();
let mxid = conn.mxid(&user.username);
if let Some(display_name) = &input.display_name {
if display_name.len() > 256 {
return Ok(SetDisplayNamePayload::Invalid);
}
if display_name.is_empty() {
return Ok(SetDisplayNamePayload::Invalid);
}
conn.set_displayname(&mxid, display_name)
.await
.context("Failed to set display name")?;
} else {
conn.unset_displayname(&mxid)
.await
.context("Failed to unset display name")?;
}
Ok(SetDisplayNamePayload::Set(User(user.clone())))
}
}