Refactor admin appservice

src/admin/appservice/commands.rs

@@ -1,10 +1,10 @@
-use futures::{FutureExt, StreamExt, TryFutureExt};
-use tuwunel_core::{Err, Result, checked};
+use futures::StreamExt;
+use tuwunel_core::{Err, Result, checked, err};
 
 use crate::admin_command;
 
 #[admin_command]
-pub(super) async fn register(&self) -> Result {
+pub(super) async fn appservice_register(&self) -> Result {
 	let body = &self.body;
 	let body_len = self.body.len();
 	if body_len < 2
@@ -17,64 +17,57 @@ pub(super) async fn register(&self) -> Result {
 	let range = 1..checked!(body_len - 1)?;
 	let appservice_config_body = body[range].join("\n");
 	let parsed_config = serde_yaml::from_str(&appservice_config_body);
-	match parsed_config {
-		| Err(e) => return Err!("Could not parse appservice config as YAML: {e}"),
-		| Ok(registration) => match self
-			.services
+
+	let registration =
+		parsed_config.map_err(|e| err!("Could not parse appservice config as YAML: {e}"))?;
+
+	self.services
 		.appservice
 		.register_appservice(&registration, &appservice_config_body)
 		.await
-			.map(|()| registration.id)
-		{
-			| Err(e) => return Err!("Failed to register appservice: {e}"),
-			| Ok(id) => write!(self, "Appservice registered with ID: {id}"),
-		},
-	}
+		.map_err(|e| err!("Failed to register appservice: {e}"))?;
+
+	self.write_str(&format!("Appservice registered with ID: {}", registration.id))
 		.await
 }
 
 #[admin_command]
-pub(super) async fn unregister(&self, appservice_identifier: String) -> Result {
-	match self
-		.services
+pub(super) async fn appservice_unregister(&self, appservice_identifier: String) -> Result {
+	self.services
 		.appservice
 		.unregister_appservice(&appservice_identifier)
 		.await
-	{
-		| Err(e) => return Err!("Failed to unregister appservice: {e}"),
-		| Ok(()) => write!(self, "Appservice unregistered."),
-	}
-	.await
+		.map_err(|e| err!("Failed to unregister appservice: {e}"))?;
+
+	self.write_str("Appservice unregistered.").await
 }
 
 #[admin_command]
-pub(super) async fn show_appservice_config(&self, appservice_identifier: String) -> Result {
-	match self
+pub(super) async fn appservice_show_config(&self, appservice_identifier: String) -> Result {
+	let config = self
 		.services
 		.appservice
 		.get_registration(&appservice_identifier)
 		.await
-	{
-		| None => return Err!("Appservice does not exist."),
-		| Some(config) => {
+		.ok_or(err!("Appservice does not exist."))?;
+
 	let config_str = serde_yaml::to_string(&config)?;
-			write!(self, "Config for {appservice_identifier}:\n\n```yaml\n{config_str}\n```")
-		},
-	}
+
+	self.write_str(&format!("Config for {appservice_identifier}:\n\n```yaml\n{config_str}\n```"))
 		.await
 }
 
 #[admin_command]
-pub(super) async fn list_registered(&self) -> Result {
-	self.services
+pub(super) async fn appservice_list(&self) -> Result {
+	let appservices: Vec<_> = self
+		.services
 		.appservice
 		.iter_ids()
 		.collect()
-		.map(Ok)
-		.and_then(|appservices: Vec<_>| {
+		.await;
+
 	let len = appservices.len();
 	let list = appservices.join(", ");
-			write!(self, "Appservices ({len}): {list}")
-		})
+	self.write_str(&format!("Appservices ({len}): {list}"))
 		.await
 }

src/admin/appservice/mod.rs

@@ -6,7 +6,7 @@ use tuwunel_core::Result;
 use crate::admin_command_dispatch;
 
 #[derive(Debug, Subcommand)]
-#[admin_command_dispatch]
+#[admin_command_dispatch(handler_prefix = "appservice")]
 pub(super) enum AppserviceCommand {
 	/// - Register an appservice using its registration YAML
 	///
@@ -29,12 +29,11 @@ pub(super) enum AppserviceCommand {
 	///
 	/// You can find the ID using the `list-appservices` command.
 	#[clap(alias("show"))]
-	ShowAppserviceConfig {
+	ShowConfig {
 		/// The appservice to show
 		appservice_identifier: String,
 	},
 
 	/// - List all the currently registered appservices
-	#[clap(alias("list"))]
-	ListRegistered,
+	List,
 }