From 483f0a9c865f7f1fd2d16c3d5b24e73a3e2c2088 Mon Sep 17 00:00:00 2001
From: Jason Volk <jason@zemos.net>
Date: Sun, 16 Jun 2024 02:10:47 +0000
Subject: [PATCH] add admin command for admin room notices

Signed-off-by: Jason Volk <jason@zemos.net>
---
 src/admin/server/mod.rs             | 8 ++++++++
 src/admin/server/server_commands.rs | 7 +++++++
 src/service/admin/mod.rs            | 2 +-
 3 files changed, 16 insertions(+), 1 deletion(-)

diff --git a/src/admin/server/mod.rs b/src/admin/server/mod.rs
index 254735a3..584d3234 100644
--- a/src/admin/server/mod.rs
+++ b/src/admin/server/mod.rs
@@ -40,6 +40,11 @@ pub(crate) enum ServerCommand {
 	/// - List database files
 	ListDatabaseFiles,
 
+	/// - Send a message to the admin room.
+	AdminNotice {
+		message: Vec<String>,
+	},
+
 	#[cfg(conduit_mods)]
 	/// - Hot-reload the server
 	Reload,
@@ -62,6 +67,9 @@ pub(crate) async fn process(command: ServerCommand, body: Vec<&str>) -> Result<R
 		ServerCommand::ListBackups => list_backups(body).await?,
 		ServerCommand::BackupDatabase => backup_database(body).await?,
 		ServerCommand::ListDatabaseFiles => list_database_files(body).await?,
+		ServerCommand::AdminNotice {
+			message,
+		} => admin_notice(body, message).await?,
 		#[cfg(conduit_mods)]
 		ServerCommand::Reload => reload(body).await?,
 		ServerCommand::Shutdown => shutdown(body).await?,
diff --git a/src/admin/server/server_commands.rs b/src/admin/server/server_commands.rs
index c9daedc4..79e02e17 100644
--- a/src/admin/server/server_commands.rs
+++ b/src/admin/server/server_commands.rs
@@ -98,6 +98,13 @@ pub(crate) async fn list_database_files(_body: Vec<&str>) -> Result<RoomMessageE
 	Ok(RoomMessageEventContent::notice_html(String::new(), result))
 }
 
+pub(crate) async fn admin_notice(_body: Vec<&str>, message: Vec<String>) -> Result<RoomMessageEventContent> {
+	let message = message.join(" ");
+	services().admin.send_text(&message).await;
+
+	Ok(RoomMessageEventContent::notice_plain("Notice was sent to #admins"))
+}
+
 #[cfg(conduit_mods)]
 pub(crate) async fn reload(_body: Vec<&str>) -> Result<RoomMessageEventContent> {
 	services().server.reload()?;
diff --git a/src/service/admin/mod.rs b/src/service/admin/mod.rs
index ddc3606f..0c949937 100644
--- a/src/service/admin/mod.rs
+++ b/src/service/admin/mod.rs
@@ -92,7 +92,7 @@ impl Service {
 	}
 
 	pub async fn send_text(&self, body: &str) {
-		self.send_message(RoomMessageEventContent::text_plain(body))
+		self.send_message(RoomMessageEventContent::text_markdown(body))
 			.await;
 	}