refactor: use let else

Author: vohoanglong0107

src/bors/handlers/mod.rs

@@ -48,77 +48,80 @@ pub async fn handle_bors_repository_event<Client: RepositoryClient>(
     ctx: Arc<BorsContext>,
 ) -> anyhow::Result<()> {
     let db = Arc::clone(&ctx.db);
-    if let Some(repo) = get_repo_state(state, &event.repository()) {
-        match event {
-            BorsRepositoryEvent::Comment(comment) => {
-                // We want to ignore comments made by this bot
-                if repo.client.is_comment_internal(&comment).await? {
-                    tracing::trace!(
-                        "Ignoring comment {comment:?} because it was authored by this bot"
-                    );
-                    return Ok(());
-                }
+    let Some(repo) = get_repo_state(state, event.repository()) else {
+        return Err(anyhow::anyhow!(
+            "Repository {} not found in the bot state",
+            event.repository()
+        ));
+    };
 
-                let span = tracing::info_span!(
-                    "Comment",
-                    pr = format!("{}#{}", comment.repository, comment.pr_number),
-                    author = comment.author.username
-                );
-                let pr_number = comment.pr_number;
-                if let Err(error) = handle_comment(Arc::clone(&repo), db, ctx, comment)
-                    .instrument(span.clone())
-                    .await
-                {
-                    span.log_error(error);
-                    repo.client
-                        .post_comment(
-                            pr_number,
-                            Comment::new(
-                                ":x: Encountered an error while executing command".to_string(),
-                            ),
-                        )
-                        .await
-                        .context("Cannot send comment reacting to an error")?;
-                }
+    match event {
+        BorsRepositoryEvent::Comment(comment) => {
+            // We want to ignore comments made by this bot
+            if repo.client.is_comment_internal(&comment).await? {
+                tracing::trace!("Ignoring comment {comment:?} because it was authored by this bot");
+                return Ok(());
             }
 
-            BorsRepositoryEvent::WorkflowStarted(payload) => {
-                let span = tracing::info_span!(
-                    "Workflow started",
-                    repo = payload.repository.to_string(),
-                    id = payload.run_id.into_inner()
-                );
-                if let Err(error) = handle_workflow_started(db, payload)
-                    .instrument(span.clone())
+            let span = tracing::info_span!(
+                "Comment",
+                pr = format!("{}#{}", comment.repository, comment.pr_number),
+                author = comment.author.username
+            );
+            let pr_number = comment.pr_number;
+            if let Err(error) = handle_comment(Arc::clone(&repo), db, ctx, comment)
+                .instrument(span.clone())
+                .await
+            {
+                span.log_error(error);
+                repo.client
+                    .post_comment(
+                        pr_number,
+                        Comment::new(
+                            ":x: Encountered an error while executing command".to_string(),
+                        ),
+                    )
                     .await
-                {
-                    span.log_error(error);
-                }
+                    .context("Cannot send comment reacting to an error")?;
             }
-            BorsRepositoryEvent::WorkflowCompleted(payload) => {
-                let span = tracing::info_span!(
-                    "Workflow completed",
-                    repo = payload.repository.to_string(),
-                    id = payload.run_id.into_inner()
-                );
-                if let Err(error) = handle_workflow_completed(repo, db, payload)
-                    .instrument(span.clone())
-                    .await
-                {
-                    span.log_error(error);
-                }
+        }
+
+        BorsRepositoryEvent::WorkflowStarted(payload) => {
+            let span = tracing::info_span!(
+                "Workflow started",
+                repo = payload.repository.to_string(),
+                id = payload.run_id.into_inner()
+            );
+            if let Err(error) = handle_workflow_started(db, payload)
+                .instrument(span.clone())
+                .await
+            {
+                span.log_error(error);
             }
-            BorsRepositoryEvent::CheckSuiteCompleted(payload) => {
-                let span = tracing::info_span!(
-                    "Check suite completed",
-                    repo = payload.repository.to_string(),
-                );
-                if let Err(error) = handle_check_suite_completed(repo, db, payload)
-                    .instrument(span.clone())
-                    .await
-                {
-                    span.log_error(error);
-                }
+        }
+        BorsRepositoryEvent::WorkflowCompleted(payload) => {
+            let span = tracing::info_span!(
+                "Workflow completed",
+                repo = payload.repository.to_string(),
+                id = payload.run_id.into_inner()
+            );
+            if let Err(error) = handle_workflow_completed(repo, db, payload)
+                .instrument(span.clone())
+                .await
+            {
+                span.log_error(error);
+            }
+        }
+        BorsRepositoryEvent::CheckSuiteCompleted(payload) => {
+            let span = tracing::info_span!(
+                "Check suite completed",
+                repo = payload.repository.to_string(),
+            );
+            if let Err(error) = handle_check_suite_completed(repo, db, payload)
+                .instrument(span.clone())
+                .await
+            {
+                span.log_error(error);
             }
         }
     }