tuwunel_service/admin/

grant.rs

use futures::{FutureExt, future::join3};
use ruma::{
	Int, OwnedUserId, RoomId, UserId,
	events::{
		StateEventType,
		room::{
			member::{MembershipState, RoomMemberEventContent},
			message::RoomMessageEventContent,
			power_levels::{RoomPowerLevelsEventContent, UserPowerLevel},
		},
	},
};
use tuwunel_core::{
	Err, Result, debug_info, debug_warn, error, implement, matrix::pdu::PduBuilder,
	utils::stream::ReadyExt,
};

use crate::rooms::state::RoomMutexGuard;

/// Invite the user to the tuwunel admin room.
///
/// This is equivalent to granting server admin privileges.
#[implement(super::Service)]
pub async fn make_user_admin(&self, user_id: &UserId) -> Result {
	let Ok(room_id) = self.get_admin_room().await else {
		debug_warn!(
			"make_user_admin was called without an admin room being available or created"
		);
		return Ok(());
	};

	let state_lock = self.services.state.mutex.lock(&room_id).await;

	let is_joined = self
		.services
		.state_cache
		.is_joined(user_id, &room_id)
		.await;

	let is_invited = self
		.services
		.state_cache
		.is_invited(user_id, &room_id)
		.await;

	let already_member = is_joined || is_invited;

	if !already_member {
		self.invite_new_admin(user_id, &room_id, &state_lock)
			.await?;
	}

	let server_user: &UserId = self.services.globals.server_user.as_ref();

	let mut room_power_levels = self
		.services
		.state_accessor
		.room_state_get_content::<RoomPowerLevelsEventContent>(
			&room_id,
			&StateEventType::RoomPowerLevels,
			"",
		)
		.await
		.unwrap_or_default();

	let server_level = 69420.into();
	let admin_level = 100.into();
	let already_granted = room_power_levels.users.get(server_user) == Some(&server_level)
		&& room_power_levels.users.get(user_id) == Some(&admin_level);

	if !already_granted {
		room_power_levels
			.users
			.insert(server_user.into(), server_level);
		room_power_levels
			.users
			.insert(user_id.into(), admin_level);

		self.services
			.timeline
			.build_and_append_pdu(
				PduBuilder::state(String::new(), &room_power_levels),
				server_user,
				&room_id,
				&state_lock,
			)
			.await?;
	}

	// Set room tag
	let room_tag = self
		.services
		.server
		.config
		.admin_room_tag
		.as_str();

	if !already_granted
		&& !room_tag.is_empty()
		&& let Err(e) = self
			.services
			.account_data
			.set_room_tag(user_id, &room_id, room_tag.into(), None)
			.await
	{
		error!(?room_id, ?user_id, ?room_tag, "Failed to set tag for admin grant: {e}");
	}

	if !already_member && self.services.server.config.admin_room_notices {
		let welcome_message = String::from(
			"## Thank you for trying out tuwunel!\n\nTuwunel is a continuation of conduwuit which was technically a hard fork of Conduit.\n\nHelpful links:\n> GitHub Repo: https://github.com/matrix-construct/tuwunel\n> Documentation: https://matrix-construct.github.io/tuwunel\n> Report issues: https://github.com/matrix-construct/tuwunel/issues\n\nFor a list of available commands, send the following message in this room: `!admin --help`",
		);

		// Send welcome message
		self.services
			.timeline
			.build_and_append_pdu(
				PduBuilder::timeline(&RoomMessageEventContent::text_markdown(welcome_message)),
				server_user,
				&room_id,
				&state_lock,
			)
			.await?;
	}

	Ok(())
}

/// Grant room admin powers to a target by impersonating the highest-powered
/// local member.
///
/// The target is granted the impersonated member's power level (100 when that
/// member is a room-version 12 creator with infinite power), sent as a new
/// `m.room.power_levels` from that member. When the room is non-public and the
/// target is neither joined nor invited, the target is invited first.
#[implement(super::Service)]
pub async fn make_room_admin(&self, room_id: &RoomId, target: &UserId) -> Result {
	let state_lock = self.services.state.mutex.lock(room_id).await;

	let power_levels = self
		.services
		.state_accessor
		.get_power_levels(room_id)
		.await?;

	let sender = self
		.services
		.state_cache
		.local_users_in_room(room_id)
		.ready_fold(None, |best: Option<(OwnedUserId, UserPowerLevel)>, user| {
			let level = power_levels.for_user(user);
			match best {
				| Some((_, best_level)) if best_level >= level => best,
				| _ => Some((user.to_owned(), level)),
			}
		})
		.await;

	let Some((sender, sender_level)) = sender else {
		return Err!(Request(InvalidParam("Server not in room")));
	};

	if !power_levels.user_can_send_state(&sender, StateEventType::RoomPowerLevels) {
		return Err!(Request(InvalidParam(
			"No local admin in room with power to update power levels"
		)));
	}

	let grant_level: Int = match sender_level {
		| UserPowerLevel::Infinite => 100.into(),
		| UserPowerLevel::Int(level) => level,
	};

	let is_joined = self
		.services
		.state_cache
		.is_joined(target, room_id);

	let is_invited = self
		.services
		.state_cache
		.is_invited(target, room_id);

	let is_public = self.services.metadata.is_public(room_id);
	let (is_joined, is_invited, is_public) = join3(is_joined, is_invited, is_public).await;

	if !is_joined && !is_invited && !is_public {
		self.services
			.membership
			.invite(&sender, target, room_id, None, false)
			.await?;
	}

	let mut content = self
		.services
		.state_accessor
		.room_state_get_content::<RoomPowerLevelsEventContent>(
			room_id,
			&StateEventType::RoomPowerLevels,
			"",
		)
		.await
		.unwrap_or_default();

	content.users.insert(target.into(), grant_level);

	self.services
		.timeline
		.build_and_append_pdu(
			PduBuilder::state(String::new(), &content),
			&sender,
			room_id,
			&state_lock,
		)
		.await
		.map(|_| ())
}

#[implement(super::Service)]
async fn invite_new_admin(
	&self,
	user_id: &UserId,
	room_id: &RoomId,
	state_lock: &RoomMutexGuard,
) -> Result {
	let server_user = self.services.globals.server_user.as_ref();

	// if this is our local user, just forcefully join them in the room. otherwise,
	// invite the remote user.
	if self.services.globals.user_is_local(user_id) {
		debug_info!("Inviting local user {user_id} to admin room {room_id}");
		self.services
			.timeline
			.build_and_append_pdu(
				PduBuilder::state(
					String::from(user_id),
					&RoomMemberEventContent::new(MembershipState::Invite),
				),
				server_user,
				room_id,
				state_lock,
			)
			.await?;

		debug_info!("Force joining local user {user_id} to admin room {room_id}");
		self.services
			.timeline
			.build_and_append_pdu(
				PduBuilder::state(
					String::from(user_id),
					&RoomMemberEventContent::new(MembershipState::Join),
				),
				user_id,
				room_id,
				state_lock,
			)
			.await?;
	} else {
		debug_info!("Inviting remote user {user_id} to admin room {room_id}");
		self.services
			.timeline
			.build_and_append_pdu(
				PduBuilder::state(
					user_id.to_string(),
					&RoomMemberEventContent::new(MembershipState::Invite),
				),
				server_user,
				room_id,
				state_lock,
			)
			.await?;
	}

	Ok(())
}

/// Demote an admin, removing its rights.
#[implement(super::Service)]
pub async fn revoke_admin(&self, user_id: &UserId) -> Result {
	use MembershipState::{Invite, Join, Knock, Leave};

	let Ok(room_id) = self.get_admin_room().await else {
		return Err!(error!("No admin room available or created."));
	};

	let state_lock = self.services.state.mutex.lock(&room_id).await;

	let event = match self
		.services
		.state_accessor
		.get_member(&room_id, user_id)
		.await
	{
		| Err(e) if e.is_not_found() => return Err!("{user_id} was never an admin."),

		| Err(e) => return Err!(error!(?e, "Failure occurred while attempting revoke.")),

		| Ok(event) if !matches!(event.membership, Invite | Knock | Join) => {
			return Err!("Cannot revoke {user_id} in membership state {:?}.", event.membership);
		},

		| Ok(event) => {
			assert!(
				matches!(event.membership, Invite | Knock | Join),
				"Incorrect membership state to remove user."
			);

			event
		},
	};

	self.services
		.timeline
		.build_and_append_pdu(
			PduBuilder::state(user_id.to_string(), &RoomMemberEventContent {
				membership: Leave,
				reason: Some("Admin Revoked".into()),
				is_direct: false,
				join_authorized_via_users_server: None,
				third_party_invite: None,
				..event
			}),
			self.services.globals.server_user.as_ref(),
			&room_id,
			&state_lock,
		)
		.boxed()
		.await
		.map(|_| ())
}