add SlackNotifier to notifier module

Author: ks6088ts

.env.template

@@ -69,3 +69,7 @@ SCRAPER_TYPE="mock" # Options: "mock", "httpx", "youtube_transcript"
 
 ## Summarizer Settings
 SUMMARIZER_TYPE="mock" # Options: "mock", "llm"
+
+## Notifier Settings
+NOTIFIER_TYPE="mock" # Options: "mock", "slack"
+NOTIFIER_SLACK_WEBHOOK_URL="https://hooks.slack.com/services/xxx"

template_langgraph/agents/news_summarizer_agent/agent.py

@@ -114,11 +114,12 @@ def summarize_web_content(self, state: SummarizeWebContentState):
     def notify(self, state: AgentState) -> AgentState:
         """Send notifications to the user."""
         logger.info(f"Sending notifications with state: {state}")
-        # Simulate sending notifications
-        # convert list of articles to a dictionary for notification
         summary = {}
         for i, article in enumerate(state.articles):
-            summary[i] = article.model_dump()
+            summary[i] = {
+                "url": article.url,
+                "structured_article": article.structured_article.model_dump(),
+            }
         self.notifier.notify(
             text=summary.__str__(),
         )

template_langgraph/internals/notifiers.py

@@ -11,6 +11,7 @@
 from enum import Enum
 from functools import lru_cache
 
+import httpx
 from pydantic_settings import BaseSettings, SettingsConfigDict
 
 from template_langgraph.loggers import get_logger
@@ -20,10 +21,12 @@
 
 class NotifierType(str, Enum):
     MOCK = "mock"
+    SLACK = "slack"
 
 
 class Settings(BaseSettings):
     notifier_type: NotifierType = NotifierType.MOCK
+    notifier_slack_webhook_url: str = "https://hooks.slack.com/services/Txxx/Bxxx/xxx"
 
     model_config = SettingsConfigDict(
         env_file=".env",
@@ -59,11 +62,30 @@ def notify(self, text: str):
         logger.info(f"Mock notify with text: {text}")
 
 
+class SlackNotifier(BaseNotifier):
+    """Slack notifier for sending notifications to a Slack channel."""
+
+    def __init__(self, settings=get_notifier_settings()):
+        self.webhook_url = settings.notifier_slack_webhook_url
+
+    def notify(self, text: str):
+        logger.info(f"Slack notify with text: {text}")
+        with httpx.Client() as client:
+            client.post(
+                self.webhook_url,
+                json={
+                    "text": text,
+                },
+            )
+
+
 def get_notifier(settings: Settings = None) -> BaseNotifier:
     if settings is None:
         settings = get_notifier_settings()
 
     if settings.notifier_type == NotifierType.MOCK:
         return MockNotifier()
+    elif settings.notifier_type == NotifierType.SLACK:
+        return SlackNotifier(settings)
     else:
         raise ValueError(f"Unknown notifier type: {settings.notifier_type}")