Mike Swanson
020ae0cc1c
- Add DISCORD_CLAUDE.md as the Discord bot's dedicated system prompt, replacing the main CLAUDE.md for bot sessions. Covers: no-interactive rules, Discord user authorization, vault/remediation guidance, /save after every task, and formatting rules for Discord. - config.py: add discord_system_prompt field (default: projects/discord-bot/ DISCORD_CLAUDE.md, overridable via env var). - client.py: _load_system_prompt() now loads discord_system_prompt path with fallback to CLAUDE.md if file is missing. - message_handler.py: inject [DISCORD_CONTEXT] header into every agent message containing Discord username, display name, user ID, channel, and guild so the agent always knows who is asking. Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com>
104 lines
3.4 KiB
Python
104 lines
3.4 KiB
Python
"""Claude Agent SDK wrapper for per-thread Discord conversations."""
|
|
from __future__ import annotations
|
|
|
|
import logging
|
|
from pathlib import Path
|
|
from typing import AsyncIterator, Awaitable, Callable, Optional
|
|
|
|
from claude_agent_sdk import (
|
|
AssistantMessage,
|
|
ClaudeAgentOptions,
|
|
ClaudeSDKClient,
|
|
ResultMessage,
|
|
TextBlock,
|
|
ToolUseBlock,
|
|
)
|
|
|
|
from bot.config import settings
|
|
|
|
logger = logging.getLogger(__name__)
|
|
|
|
|
|
def _load_system_prompt() -> str:
|
|
prompt_path = settings.claudetools_root / settings.discord_system_prompt
|
|
if prompt_path.exists():
|
|
return prompt_path.read_text(encoding="utf-8")
|
|
logger.warning(
|
|
"[WARNING] Discord system prompt not found at %s — falling back to CLAUDE.md",
|
|
prompt_path,
|
|
)
|
|
return (settings.claudetools_root / ".claude" / "CLAUDE.md").read_text(encoding="utf-8")
|
|
|
|
|
|
class ThreadAgent:
|
|
"""One persistent Claude Code session bound to a Discord thread."""
|
|
|
|
def __init__(self, system_prompt: str, cwd: Path, model: str) -> None:
|
|
self._options = ClaudeAgentOptions(
|
|
system_prompt=system_prompt,
|
|
cwd=str(cwd),
|
|
model=model,
|
|
)
|
|
self._client: Optional[ClaudeSDKClient] = None
|
|
|
|
async def start(self) -> None:
|
|
self._client = ClaudeSDKClient(options=self._options)
|
|
await self._client.connect()
|
|
|
|
async def stop(self) -> None:
|
|
if self._client is not None:
|
|
await self._client.disconnect()
|
|
self._client = None
|
|
|
|
async def send(
|
|
self,
|
|
user_message: str,
|
|
on_text: Callable[[str], Awaitable[None]],
|
|
on_tool_use: Optional[Callable[[str], Awaitable[None]]] = None,
|
|
) -> str:
|
|
if self._client is None:
|
|
raise RuntimeError("ThreadAgent.send() called before start()")
|
|
|
|
await self._client.query(user_message)
|
|
|
|
full_text = ""
|
|
async for message in self._client.receive_response():
|
|
if isinstance(message, AssistantMessage):
|
|
for block in message.content:
|
|
if isinstance(block, TextBlock):
|
|
full_text += block.text
|
|
await on_text(block.text)
|
|
elif isinstance(block, ToolUseBlock) and on_tool_use is not None:
|
|
await on_tool_use(block.name)
|
|
elif isinstance(message, ResultMessage):
|
|
break
|
|
|
|
return full_text
|
|
|
|
|
|
class ClaudeAgentManager:
|
|
"""Owns one ThreadAgent per Discord thread id."""
|
|
|
|
def __init__(self) -> None:
|
|
self._system_prompt = _load_system_prompt()
|
|
self._cwd = settings.claudetools_root
|
|
self._model = settings.claude_model
|
|
self._agents: dict[int, ThreadAgent] = {}
|
|
|
|
async def get_or_create(self, thread_id: int) -> ThreadAgent:
|
|
agent = self._agents.get(thread_id)
|
|
if agent is None:
|
|
logger.info("[INFO] Starting new agent session for thread %d", thread_id)
|
|
agent = ThreadAgent(self._system_prompt, self._cwd, self._model)
|
|
await agent.start()
|
|
self._agents[thread_id] = agent
|
|
return agent
|
|
|
|
async def shutdown(self) -> None:
|
|
for thread_id, agent in list(self._agents.items()):
|
|
try:
|
|
await agent.stop()
|
|
except Exception as e:
|
|
logger.warning("[WARNING] Failed to stop agent %d: %s", thread_id, e)
|
|
self._agents.clear()
|