respond with eyes

Author: anthony-nhs

packages/slackBotFunction/app/slack/slack_handlers.py

@@ -5,7 +5,7 @@
 from functools import lru_cache
 from slack_bolt import App
 from app.core.config import get_bot_token, get_logger
-from app.utils.handler_utils import is_duplicate_event, trigger_async_processing
+from app.utils.handler_utils import is_duplicate_event, trigger_async_processing, respond_with_eyes
 
 logger = get_logger()
 
@@ -30,6 +30,7 @@ def mention_handler(event, ack, body):
     logger.info("Processing @mention from user", extra={"user_id": user_id, "event_id": event_id})
 
     bot_token = get_bot_token()
+    respond_with_eyes(bot_token, event)
     trigger_async_processing({"event": event, "event_id": event_id, "bot_token": bot_token})
 
 
@@ -53,6 +54,7 @@ def dm_message_handler(event, ack, body):
     logger.info("Processing DM from user", extra={"user_id": user_id, "event_id": event_id})
 
     bot_token = get_bot_token()
+    respond_with_eyes(bot_token, event)
     trigger_async_processing({"event": event, "event_id": event_id, "bot_token": bot_token})
 
 

packages/slackBotFunction/app/utils/handler_utils.py

@@ -7,6 +7,7 @@
 import traceback
 import boto3
 from botocore.exceptions import ClientError
+from slack_sdk import WebClient
 from app.core.config import get_slack_bot_state_table, get_logger
 import os
 
@@ -54,3 +55,10 @@ def trigger_async_processing(event_data):
         logger.info("Async processing triggered successfully")
     except Exception:
         logger.error("Failed to trigger async processing", extra={"error": traceback.format_exc()})
+
+
+def respond_with_eyes(bot_token, event):
+    client = WebClient(token=bot_token)
+    channel = event["channel"]
+    ts = event["ts"]
+    client.reactions_add(channel=channel, timestamp=ts, name="eyes")

packages/slackBotFunction/tests/test_middleware.py

@@ -4,8 +4,15 @@
 
 @patch("app.utils.handler_utils.is_duplicate_event")
 @patch("app.utils.handler_utils.trigger_async_processing")
+@patch("app.utils.handler_utils.respond_with_eyes")
 def test_app_mention_handler_execution_simple(
-    mock_trigger_async_processing, mock_is_duplicate_event, mock_slack_app, mock_env, mock_get_parameter, lambda_context
+    mock_respond_with_eyes,
+    mock_trigger_async_processing,
+    mock_is_duplicate_event,
+    mock_slack_app,
+    mock_env,
+    mock_get_parameter,
+    lambda_context,
 ):
     """Test app mention handler execution by simulating the handler registration process"""
     # Create a mock app that captures the registered handlers
@@ -43,12 +50,20 @@ def decorator(func):
     mock_ack.assert_called()
     mock_trigger_async_processing.assert_called_once()
     mock_is_duplicate_event.assert_called()
+    mock_respond_with_eyes.assert_called()
 
 
 @patch("app.utils.handler_utils.is_duplicate_event")
 @patch("app.utils.handler_utils.trigger_async_processing")
+@patch("app.utils.handler_utils.respond_with_eyes")
 def test_direct_message_handler_execution_simple(
-    mock_trigger_async_processing, mock_is_duplicate_event, mock_slack_app, mock_env, mock_get_parameter, lambda_context
+    mock_respond_with_eyes,
+    mock_trigger_async_processing,
+    mock_is_duplicate_event,
+    mock_slack_app,
+    mock_env,
+    mock_get_parameter,
+    lambda_context,
 ):
     """Test direct message handler execution by simulating the handler registration process"""
     # Create a mock app that captures the registered handlers
@@ -85,12 +100,20 @@ def decorator(func):
     mock_ack.assert_called()
     mock_trigger_async_processing.assert_called_once()
     mock_is_duplicate_event.assert_called()
+    mock_respond_with_eyes.assert_called()
 
 
 @patch("app.utils.handler_utils.is_duplicate_event")
 @patch("app.utils.handler_utils.trigger_async_processing")
+@patch("app.utils.handler_utils.respond_with_eyes")
 def test_app_mention_handler_duplicate_event(
-    mock_trigger_async_processing, mock_is_duplicate_event, mock_slack_app, mock_env, mock_get_parameter, lambda_context
+    mock_respond_with_eyes,
+    mock_trigger_async_processing,
+    mock_is_duplicate_event,
+    mock_slack_app,
+    mock_env,
+    mock_get_parameter,
+    lambda_context,
 ):
     """Test app mention handler with duplicate event"""
     registered_handlers = {}
@@ -124,12 +147,20 @@ def decorator(func):
     mock_ack.assert_called()
     mock_is_duplicate_event.assert_called()
     mock_trigger_async_processing.assert_not_called()
+    mock_respond_with_eyes.assert_not_called()
 
 
 @patch("app.utils.handler_utils.is_duplicate_event")
 @patch("app.utils.handler_utils.trigger_async_processing")
+@patch("app.utils.handler_utils.respond_with_eyes")
 def test_app_mention_handler_missing_event_id(
-    mock_trigger_async_processing, mock_is_duplicate_event, mock_slack_app, mock_env, mock_get_parameter, lambda_context
+    mock_respond_with_eyes,
+    mock_trigger_async_processing,
+    mock_is_duplicate_event,
+    mock_slack_app,
+    mock_env,
+    mock_get_parameter,
+    lambda_context,
 ):
     """Test app mention handler with missing event ID"""
     # Create a mock app that captures the registered handlers
@@ -163,12 +194,20 @@ def decorator(func):
     mock_ack.assert_called()
     mock_trigger_async_processing.put_item.assert_not_called()
     mock_is_duplicate_event.invoke.assert_not_called()
+    mock_respond_with_eyes.assert_not_called()
 
 
 @patch("app.utils.handler_utils.is_duplicate_event")
 @patch("app.utils.handler_utils.trigger_async_processing")
+@patch("app.utils.handler_utils.respond_with_eyes")
 def test_direct_message_handler_duplicate_event(
-    mock_trigger_async_processing, mock_is_duplicate_event, mock_slack_app, mock_env, mock_get_parameter, lambda_context
+    mock_respond_with_eyes,
+    mock_trigger_async_processing,
+    mock_is_duplicate_event,
+    mock_slack_app,
+    mock_env,
+    mock_get_parameter,
+    lambda_context,
 ):
     """Test direct message handler with duplicate event"""
     registered_handlers = {}
@@ -202,12 +241,20 @@ def decorator(func):
     mock_ack.assert_called()
     mock_is_duplicate_event.assert_called()
     mock_trigger_async_processing.assert_called()
+    mock_respond_with_eyes.assert_called()
 
 
 @patch("app.utils.handler_utils.is_duplicate_event")
 @patch("app.utils.handler_utils.trigger_async_processing")
+@patch("app.utils.handler_utils.respond_with_eyes")
 def test_direct_message_handler_missing_event_id(
-    mock_trigger_async_processing, mock_is_duplicate_event, mock_slack_app, mock_env, mock_get_parameter, lambda_context
+    mock_respond_with_eyes,
+    mock_trigger_async_processing,
+    mock_is_duplicate_event,
+    mock_slack_app,
+    mock_env,
+    mock_get_parameter,
+    lambda_context,
 ):
     """Test direct message handler with missing event ID"""
     # Create a mock app that captures the registered handlers
@@ -242,12 +289,20 @@ def decorator(func):
     # No DynamoDB or Lambda calls should be made
     mock_is_duplicate_event.assert_not_called()
     mock_trigger_async_processing.assert_not_called()
+    mock_respond_with_eyes.assert_not_called()
 
 
 @patch("app.utils.handler_utils.is_duplicate_event")
 @patch("app.utils.handler_utils.trigger_async_processing")
+@patch("app.utils.handler_utils.respond_with_eyes")
 def test_direct_message_handler_non_dm_channel(
-    mock_trigger_async_processing, mock_is_duplicate_event, mock_slack_app, mock_env, mock_get_parameter, lambda_context
+    mock_respond_with_eyes,
+    mock_trigger_async_processing,
+    mock_is_duplicate_event,
+    mock_slack_app,
+    mock_env,
+    mock_get_parameter,
+    lambda_context,
 ):
     """Test direct message handler ignores non-DM channels"""
     # Create a mock app that captures the registered handlers
@@ -284,3 +339,4 @@ def decorator(func):
     # No DynamoDB or Lambda calls should be made for non-DM messages
     mock_is_duplicate_event.assert_not_called()
     mock_trigger_async_processing.assert_not_called()
+    mock_respond_with_eyes.assert_not_called()