feat: implement chat action feedback in messaging service (#78)

* feat: implement chat action feedback in messaging service

* fix: simplify send_chat_action call in handle_reply function

* feat: add AddSummary struct

Author: isSerge

src/bot_handler/callbacks/view_labels.rs

@@ -10,6 +10,7 @@ pub async fn handle(
     repo_id: &str,
     page: usize,
     from_page: usize,
+    _query_id: &str,
 ) -> BotHandlerResult<()> {
     let chat_id = ctx.message.chat.id;
 

src/bot_handler/callbacks/view_repo.rs

@@ -5,7 +5,12 @@ use crate::{
     storage::RepoEntity,
 };
 
-pub async fn handle(ctx: Context<'_>, repo_id: &str, from_page: usize) -> BotHandlerResult<()> {
+pub async fn handle(
+    ctx: Context<'_>,
+    repo_id: &str,
+    from_page: usize,
+    _query_id: &str,
+) -> BotHandlerResult<()> {
     let chat_id = ctx.message.chat.id;
 
     // Extract repository name with owner

src/bot_handler/commands/add.rs

@@ -1,12 +1,28 @@
 use std::collections::HashSet;
 
 use futures::{StreamExt, stream};
+use teloxide::types::ChatAction;
 
 use crate::{
     bot_handler::{BotHandlerError, BotHandlerResult, CommandState, commands::Context},
     storage::RepoEntity,
 };
 
+/// A struct to hold the summary of the add operation.
+#[derive(Default, Debug, Clone, PartialEq, Eq)]
+pub struct AddSummary {
+    /// Repositories that were successfully added.
+    pub successfully_added: HashSet<String>,
+    /// Repositories that were already tracked.
+    pub already_tracked: HashSet<String>,
+    /// Repositories that were not found on GitHub.
+    pub not_found: HashSet<String>,
+    /// URLs that were invalid.
+    pub invalid_urls: HashSet<String>,
+    /// Repositories that failed to be added due to an error.
+    pub errors: HashSet<(String, String)>,
+}
+
 pub async fn handle(ctx: Context<'_>) -> BotHandlerResult<()> {
     ctx.handler.messaging_service.prompt_for_repo_input(ctx.message.chat.id).await?;
     ctx.dialogue
@@ -25,16 +41,6 @@ enum AddRepoResult {
     Error(String, String),
 }
 
-// A struct to hold the summary of the add operation.
-#[derive(Default)]
-struct AddSummary {
-    successfully_added: HashSet<String>,
-    already_tracked: HashSet<String>,
-    not_found: HashSet<String>,
-    invalid_urls: HashSet<String>,
-    errors: HashSet<(String, String)>,
-}
-
 /// Handle the reply message when we're waiting for repository input.
 /// It processes the input, checks each URL, and adds the repositories
 /// accordingly.
@@ -54,6 +60,14 @@ pub async fn handle_reply(ctx: Context<'_>, text: &str) -> BotHandlerResult<()>
         return Ok(());
     }
 
+    ctx.handler.messaging_service.send_chat_action(ctx.message.chat.id, ChatAction::Typing).await?;
+
+    let status_msg = ctx
+        .handler
+        .messaging_service
+        .send_text_message(ctx.message.chat.id, "Processing... ⏳")
+        .await?;
+
     let summary = stream::iter(urls)
         .map(|url| async move {
             let repo = match RepoEntity::from_url(&url) {
@@ -101,14 +115,7 @@ pub async fn handle_reply(ctx: Context<'_>, text: &str) -> BotHandlerResult<()>
 
     ctx.handler
         .messaging_service
-        .send_add_summary_msg(
-            ctx.message.chat.id,
-            summary.successfully_added,
-            summary.already_tracked,
-            summary.not_found,
-            summary.invalid_urls,
-            summary.errors,
-        )
+        .edit_add_summary_msg(ctx.message.chat.id, status_msg.id, &summary)
         .await?;
 
     Ok(())

src/bot_handler/mod.rs

@@ -186,6 +186,11 @@ impl BotHandler {
 
             // Answer the callback query to clear the spinner.
             self.messaging_service.answer_callback_query(&query_id, &None).await?;
+            if let Some(message) = query.message.as_ref() {
+                self.messaging_service
+                    .send_chat_action(message.chat().id, teloxide::types::ChatAction::Typing)
+                    .await?;
+            }
 
             let ctx = Context {
                 handler: self,
@@ -198,13 +203,14 @@ impl BotHandler {
 
             match action {
                 CallbackAction::ViewRepoDetails(repo_id, from_page) => {
-                    callbacks::view_repo::handle(ctx, repo_id, from_page).await?;
+                    callbacks::view_repo::handle(ctx, repo_id, from_page, &query_id).await?;
                 }
                 CallbackAction::BackToRepoDetails(repo_id, from_page) => {
-                    callbacks::view_repo::handle(ctx, repo_id, from_page).await?;
+                    callbacks::view_repo::handle(ctx, repo_id, from_page, &query_id).await?;
                 }
                 CallbackAction::ViewRepoLabels(repo_id, page, from_page) => {
-                    callbacks::view_labels::handle(ctx, repo_id, page, from_page).await?;
+                    callbacks::view_labels::handle(ctx, repo_id, page, from_page, &query_id)
+                        .await?;
                 }
                 CallbackAction::RemoveRepoPrompt(repo_id) => {
                     callbacks::remove::handle(ctx, repo_id, 1).await?;