src/main.rs

@@ -15,7 +15,6 @@ use event::{GitlabEvent, GitlabEventExt};
 use http::StatusCode;
 use matrix_sdk::{
     config::SyncSettings,
-    room::Joined,
     ruma::{events::room::message::RoomMessageEventContent, OwnedRoomOrAliasId},
     BaseRoom, Client,
 };
@@ -55,7 +54,29 @@ async fn matrix_connect(config: &config::Config) -> anyhow::Result<Client> {
     Ok(client)
 }
 
-async fn ensure_matrix_room_joined(matrix_client: &Client, room_id: &OwnedRoomOrAliasId) -> anyhow::Result<Joined> {
+fn build_gitlab_message(event: &GitlabEvent) -> String {
+    let project = event.project();
+    let refname = event
+        .r#ref()
+        .split('/')
+        .last()
+        .unwrap_or_else(|| event.r#ref())
+        .to_string();
+    format!(
+        "*{}* {} **{}** [{}]({})",
+        project.path_with_namespace,
+        refname,
+        event.user(),
+        event.title(),
+        event.url()
+    )
+}
+
+async fn handle_gitlab_event(
+    event: GitlabEvent,
+    room_id: &OwnedRoomOrAliasId,
+    matrix_client: &Client,
+) -> anyhow::Result<()> {
     fn room_matches(a_room: &BaseRoom, our_room: &OwnedRoomOrAliasId) -> bool {
         let our_room_str = our_room.as_str();
         a_room.room_id().as_str() == our_room_str
@@ -95,38 +116,15 @@ async fn ensure_matrix_room_joined(matrix_client: &Client, room_id: &OwnedRoomOr
             .map(|room| room.clone());
     }
 
-    room.ok_or_else(|| anyhow!("Unable to join room {}", room_id))
-}
-
-fn build_gitlab_message(event: &GitlabEvent) -> String {
-    let project = event.project();
-    let refname = event
-        .r#ref()
-        .split('/')
-        .last()
-        .unwrap_or_else(|| event.r#ref())
-        .to_string();
-    format!(
-        "*{}* {} **{}** [{}]({})",
-        project.path_with_namespace,
-        refname,
-        event.user(),
-        event.title(),
-        event.url()
-    )
-}
-
-async fn handle_gitlab_event(
-    event: GitlabEvent,
-    room_id: &OwnedRoomOrAliasId,
-    matrix_client: &Client,
-) -> anyhow::Result<()> {
-    let room = ensure_matrix_room_joined(matrix_client, room_id).await?;
-    let msg = build_gitlab_message(&event);
-    debug!("Sending message to {}: {}", room_id, msg);
-    let msg_content = RoomMessageEventContent::text_markdown(&msg);
-    room.send(msg_content, None).await?;
-    Ok(())
+    if let Some(room) = room {
+        let msg = build_gitlab_message(&event);
+        debug!("Sending message to {}: {}", room_id, msg);
+        let msg_content = RoomMessageEventContent::text_markdown(&msg);
+        room.send(msg_content, None).await?;
+        Ok(())
+    } else {
+        Err(anyhow!("Unable to join room {}", room_id))
+    }
 }
 
 #[tokio::main]