[Feature] introduce openai to message event and change folder name to bot

README.md

@@ -30,6 +30,6 @@ pip install -r requirements.txt
 
 4. Run the FastAPI server with Uvicorn
 ```bash
-uvicorn app.main:app --reload --host 0.0.0.0 --port 8001 # dev
-uvicorn app.main:app --host 0.0.0.0 --port 8001 --workers 4 # production
+uvicorn bot.main:app --reload --host 0.0.0.0 --port 8001 # dev
+uvicorn bot.main:app --host 0.0.0.0 --port 8001 --workers 4 # production
 ```

app/handlers/event_handler.py → bot/handlers/event_handler.py

@@ -2,7 +2,8 @@
 
 from fastapi.responses import JSONResponse
 
-from app.services.post_message import post_message_to_channel, post_message_to_user
+from bot.services.openai_client import get_openai_response
+from bot.services.post_message import post_message_to_channel, post_message_to_user
 
 
 class BotStatus(str, Enum):
@@ -28,17 +29,16 @@ async def process_event(data: dict) -> JSONResponse:
     if event_type == "message":
         content = data.get("content", {})
         text = content.get("text", "")
-        if not text.startswith("/"):
-            return JSONResponse(status_code=200, content={"status": BotStatus.IGNORED})
-
+        response = await get_openai_response(
+            prompt="You are a helpful assistant.",
+            input=text,
+        )
         if channel_id:
-            await post_message_to_channel(
-                channel_id=channel_id, message=f"Pong! {text}"
-            )
+            await post_message_to_channel(channel_id=channel_id, message=response)
             return JSONResponse(status_code=200, content={"status": BotStatus.OK})
 
         if user_id:
-            await post_message_to_user(user_id=user_id, message=f"Pong! {text}")
+            await post_message_to_user(user_id=user_id, message=response)
             return JSONResponse(status_code=200, content={"status": BotStatus.OK})
 
     return JSONResponse(status_code=200, content={"status": BotStatus.IGNORED})

app/main.py → bot/main.py

@@ -4,9 +4,9 @@
 from fastapi.responses import JSONResponse
 from uvicorn.config import LOGGING_CONFIG
 
-from app.config.settings import settings
-from app.handlers.event_handler import process_event
-from app.utils.signature import verify_signature
+from bot.config.settings import settings
+from bot.handlers.event_handler import process_event
+from bot.utils.signature import verify_signature
 
 app = FastAPI()
 logger = logging.getLogger(__name__)

app/services/access_token.py → bot/services/access_token.py

@@ -6,7 +6,7 @@
 from cryptography.hazmat.primitives import serialization
 from logger import logger
 
-from app.config.settings import settings
+from bot.config.settings import settings
 
 
 class TokenManager:

bot/services/openai_client.py

@@ -0,0 +1,24 @@
+from logger import logger
+from openai import APIConnectionError, AsyncOpenAI
+from retry import retry
+
+from bot.config.settings import settings
+
+client = AsyncOpenAI(api_key=settings.openai_api_key)
+
+
+@retry(tries=3, delay=1, backoff=2, exceptions=APIConnectionError)
+async def get_openai_response(
+    prompt: str,
+    input: str,
+) -> str:
+    try:
+        response = await client.responses.create(
+            model="gpt-4o",
+            instructions=prompt,
+            input=input,
+        )
+        return response.output_text.strip()
+    except APIConnectionError as e:
+        logger.error(e)
+        raise

app/services/post_message.py → bot/services/post_message.py

@@ -1,10 +1,9 @@
-### app/services/post_message.py
 import httpx
 from retry import retry
 
-from app.config.settings import settings
-from app.logger import logger
-from app.services.access_token import token_manager
+from bot.config.settings import settings
+from bot.logger import logger
+from bot.services.access_token import token_manager
 
 CHANNEL_MESSAGE_URL = (
     "https://www.worksapis.com/v1.0/bots/{bot_id}/channels/{channel_id}/messages"

pyproject.toml

@@ -15,6 +15,7 @@ requests = "^2.32.3"
 httpx = "^0.28.1"
 retry = "^0.9.2"
 pydantic-settings = "^2.9.1"
+openai = "^1.77.0"
 
 
 [tool.poetry.group.dev.dependencies]