Bug fixes

src/ctp_slack_bot/api/main.py

@@ -39,8 +39,10 @@ async def main() -> None:
     @bolt_app.event("message")
     async def handle_message(body: Dict[str, Any]) -> None:
         logger.debug("Ignored regular message: {}", body.get("event").get("text"))
+        #await slack_service.process_message(body)
     @bolt_app.event("app_mention")
     async def handle_app_mention(body: Dict[str, Any]) -> None:
+        #logger.debug("Ignored app mention: {}", body.get("event").get("text"))
         await slack_service.process_message(body)
 
     # Start Socket Mode handler in a background thread

src/ctp_slack_bot/models/__init__.py

@@ -1,3 +1,2 @@
-from ctp_slack_bot.models.base import Chunk, Content, VectorizedChunk
+from ctp_slack_bot.models.base import Chunk, Content, VectorizedChunk, VectorQuery
 from ctp_slack_bot.models.slack import SlackEventPayload, SlackMessage, SlackReaction, SlackResponse, SlackUserTimestampPair
-from ctp_slack_bot.models.vector_query import VectorQuery

src/ctp_slack_bot/services/context_retrieval_service.py

@@ -14,7 +14,7 @@ class ContextRetrievalService(BaseModel):
 
     settings: Settings
     vectorization_service: VectorizationService
-    vector_db_service: VectorDatabaseService
+    vector_database_service: VectorDatabaseService
 
     # Should not allow initialization calls to bubble up all the way to the surface ― sequester in `post_init` or the class on which it depends.
     @model_validator(mode='after')
@@ -54,7 +54,7 @@ class ContextRetrievalService(BaseModel):
         # Perform similarity search
         try:
             results = await self.vector_db_service.search_by_similarity(query)
-            logger.info(f"Retrieved {len(results)} context chunks for query")
+            #logger.info(f"Retrieved {len(results)} context chunks for query")
             return results
         except Exception as e:
             logger.error(f"Error retrieving context: {str(e)}")

src/ctp_slack_bot/services/question_dispatch_service.py

@@ -30,5 +30,5 @@ class QuestionDispatchService(BaseModel):
     async def __process_incoming_slack_message(self: Self, message: SlackMessage) -> None:
         if message.subtype != 'bot_message':
             logger.debug("Question dispatch service received an answerable question: {}", message.text)
-            context = self.context_retrieval_service.get_context(message)
+            context = await self.context_retrieval_service.get_context(message)
             await self.answer_retrieval_service.push(message, context)