Merge pull request #33 from ks6088ts-labs/copilot/fix-32

Add LangGraph-based Agent API with modular architecture and CLI tool

Author: ks6088ts

docs/index.md

@@ -204,17 +204,69 @@ az resource update \
 
 ```bash
 # エージェントを作成
-python scripts/agents.py create-agent "研究アシスタント" --description "研究をサポートするAIアシスタント" --instructions "あなたは研究者をサポートするAIアシスタントです。質問に対して詳細で正確な回答を提供してください。"
+uv run python scripts/agents_azure_ai_foundry.py create-agent "研究アシスタント" --description "研究をサポートするAIアシスタント" --instructions "あなたは研究者をサポートするAIアシスタントです。質問に対して詳細で正確な回答を提供してください。"
 
 # エージェント一覧を取得
-python scripts/agents.py list-agents
+uv run python scripts/agents_azure_ai_foundry.py list-agents
 
 # エージェントの詳細を取得
-python scripts/agents.py get-agent <agent_id>
+uv run python scripts/agents_azure_ai_foundry.py get-agent <agent_id>
 
 # エージェントとチャット
-python scripts/agents.py chat <agent_id> "機械学習の最新トレンドについて教えてください"
+uv run python scripts/agents_azure_ai_foundry.py chat <agent_id> "機械学習の最新トレンドについて教えてください"
 
 # エージェントを削除
-python scripts/agents.py delete-agent <agent_id>
+uv run python scripts/agents_azure_ai_foundry.py delete-agent <agent_id>
+```
+
+### LangGraph Agent
+
+LangGraph ベースのエージェント API を使用した対話型 AI アシスタント。ツール呼び出し機能を持つシンプルなエージェントワークフローを実装しています。
+
+#### CLI 実行例
+
+```bash
+# ヘルプ
+uv run python scripts/agents_langgraph.py --help
+
+# エージェントとチャット
+uv run python scripts/agents_langgraph.py chat "こんにちは！今何時ですか？"
+
+# スレッドIDを指定してチャット（会話の継続）
+uv run python scripts/agents_langgraph.py chat "前回の続きを教えてください" --thread-id "12345-67890-abcdef"
+
+# 詳細情報付きでチャット
+uv run python scripts/agents_langgraph.py chat "2 + 2 × 3 を計算してください" --verbose
+
+# 対話モード
+uv run python scripts/agents_langgraph.py interactive
+
+# 利用可能なツール一覧
+uv run python scripts/agents_langgraph.py tools
+
+# デモモード（サンプル質問のテスト）
+uv run python scripts/agents_langgraph.py demo
+```
+
+#### API エンドポイント
+
+```bash
+# FastAPIサーバーを起動
+make dev
+
+# LangGraphエージェントとチャット
+curl -X POST "http://localhost:8000/agents/langgraph/chat" \
+  -H "Content-Type: application/json" \
+  -d '{"message": "こんにちは！"}'
+
+# ストリーミングチャット
+curl -X POST "http://localhost:8000/agents/langgraph/chat/stream" \
+  -H "Content-Type: application/json" \
+  -d '{"message": "長い回答をお願いします"}'
+
+# 利用可能なツール一覧
+curl -X GET "http://localhost:8000/agents/langgraph/tools"
+
+# ヘルスチェック
+curl -X GET "http://localhost:8000/agents/langgraph/health"
 ```

pyproject.toml

@@ -15,6 +15,7 @@ dependencies = [
     "fastapi[standard]>=0.115.12",
     "langchain-community>=0.3.27",
     "langchain-openai>=0.3.27",
+    "langgraph>=0.2.90",
     "msgraph-sdk>=1.37.0",
     "opentelemetry-instrumentation-fastapi>=0.52b1",
     "pydantic-settings>=2.10.1",

scripts/agents.py renamed to scripts/agents_azure_ai_foundry.py

@@ -1,6 +1,3 @@
-#!/usr/bin/env python
-# filepath: /home/runner/work/template-fastapi/template-fastapi/scripts/agents.py
-
 import json
 
 import typer

scripts/agents_langgraph.py

@@ -0,0 +1,203 @@
+"""LangGraph Agent CLI tool."""
+
+import typer
+from rich.console import Console
+from rich.markdown import Markdown
+from rich.panel import Panel
+
+from template_fastapi.internals.langgraph.agents import LangGraphAgent
+from template_fastapi.internals.langgraph.tools import get_tools
+
+app = typer.Typer()
+console = Console()
+
+
+@app.command()
+def chat(
+    message: str = typer.Argument(..., help="メッセージ"),
+    thread_id: str | None = typer.Option(None, "--thread-id", "-t", help="スレッドID（会話の継続用）"),
+    verbose: bool = typer.Option(False, "--verbose", "-v", help="詳細な情報を表示"),
+):
+    """LangGraphエージェントとチャットする"""
+    console.print("[bold green]LangGraphエージェントとチャットします[/bold green]")
+    console.print(f"メッセージ: {message}")
+
+    if thread_id:
+        console.print(f"スレッドID: {thread_id}")
+    else:
+        console.print("新しいスレッドを作成します")
+
+    try:
+        # Initialize the LangGraph agent
+        agent = LangGraphAgent()
+
+        # Show loading message
+        with console.status("[bold green]エージェントが応答を生成中...", spinner="dots"):
+            result = agent.chat(message=message, thread_id=thread_id)
+
+        # Display results
+        console.print("\n" + "=" * 50)
+        console.print("[bold blue]チャット結果[/bold blue]")
+        console.print("=" * 50)
+
+        # Display user message
+        user_panel = Panel(message, title="[bold cyan]あなた[/bold cyan]", border_style="cyan")
+        console.print(user_panel)
+
+        # Display agent response with markdown rendering
+        response_content = result["response"]
+        if response_content:
+            try:
+                # Try to render as markdown for better formatting
+                markdown = Markdown(response_content)
+                agent_panel = Panel(
+                    markdown, title="[bold green]LangGraphエージェント[/bold green]", border_style="green"
+                )
+            except Exception:
+                # Fallback to plain text
+                agent_panel = Panel(
+                    response_content, title="[bold green]LangGraphエージェント[/bold green]", border_style="green"
+                )
+            console.print(agent_panel)
+
+        # Display metadata
+        if verbose:
+            console.print("\n[bold yellow]メタデータ[/bold yellow]:")
+            console.print(f"スレッドID: {result['thread_id']}")
+            console.print(f"作成日時: {result['created_at']}")
+            console.print(f"ステップ数: {result.get('step_count', 0)}")
+
+            if result.get("tools_used"):
+                console.print(f"使用ツール: {', '.join(result['tools_used'])}")
+            else:
+                console.print("使用ツール: なし")
+        else:
+            console.print(f"\n[dim]スレッドID: {result['thread_id']}[/dim]")
+            if result.get("tools_used"):
+                console.print(f"[dim]使用ツール: {', '.join(result['tools_used'])}[/dim]")
+
+    except Exception as e:
+        console.print(f"❌ [bold red]エラー[/bold red]: {str(e)}")
+
+
+@app.command()
+def interactive():
+    """対話モードでLangGraphエージェントとチャットする"""
+    console.print("[bold green]LangGraphエージェント対話モード[/bold green]")
+    console.print("終了するには 'exit', 'quit', または 'bye' と入力してください\n")
+
+    agent = LangGraphAgent()
+    thread_id = None
+
+    while True:
+        try:
+            # Get user input
+            user_input = typer.prompt("あなた")
+
+            # Check for exit commands
+            if user_input.lower() in ["exit", "quit", "bye", "終了"]:
+                console.print("[yellow]対話を終了します。ありがとうございました！[/yellow]")
+                break
+
+            # Process the message
+            with console.status("[bold green]応答を生成中...", spinner="dots"):
+                result = agent.chat(message=user_input, thread_id=thread_id)
+
+            # Update thread_id for conversation continuity
+            thread_id = result["thread_id"]
+
+            # Display agent response
+            response_panel = Panel(
+                Markdown(result["response"]) if result["response"] else "応答がありません",
+                title="[bold green]エージェント[/bold green]",
+                border_style="green",
+            )
+            console.print(response_panel)
+
+            # Show tools used if any
+            if result.get("tools_used"):
+                console.print(f"[dim]使用ツール: {', '.join(result['tools_used'])}[/dim]")
+
+            console.print()  # Add spacing
+
+        except KeyboardInterrupt:
+            console.print("\n[yellow]対話を終了します[/yellow]")
+            break
+        except Exception as e:
+            console.print(f"❌ [bold red]エラー[/bold red]: {str(e)}")
+
+
+@app.command()
+def tools():
+    """利用可能なツールの一覧を表示する"""
+    console.print("[bold green]利用可能なツール一覧[/bold green]")
+
+    try:
+        available_tools = get_tools()
+
+        if not available_tools:
+            console.print("[yellow]利用可能なツールがありません[/yellow]")
+            return
+
+        console.print(f"\n[bold blue]合計 {len(available_tools)} 個のツールが利用可能です[/bold blue]\n")
+
+        for i, tool in enumerate(available_tools, 1):
+            tool_info = f"""
+**名前:** {tool.name}
+**説明:** {tool.description}
+"""
+            if hasattr(tool, "args_schema") and tool.args_schema:
+                try:
+                    schema = tool.args_schema.model_json_schema()
+                    if "properties" in schema:
+                        tool_info += f"**パラメータ:** {', '.join(schema['properties'].keys())}"
+                except Exception:
+                    pass
+
+            panel = Panel(Markdown(tool_info), title=f"[bold cyan]ツール {i}[/bold cyan]", border_style="cyan")
+            console.print(panel)
+
+    except Exception as e:
+        console.print(f"❌ [bold red]エラー[/bold red]: {str(e)}")
+
+
+@app.command()
+def demo():
+    """デモンストレーション用のサンプルチャット"""
+    console.print("[bold green]LangGraphエージェント デモモード[/bold green]")
+    console.print("いくつかのサンプル質問でエージェントをテストします\n")
+
+    sample_queries = [
+        "こんにちは！今何時ですか？",
+        "2 + 2 × 3 を計算してください",
+        "Pythonについて検索してください",
+    ]
+
+    agent = LangGraphAgent()
+
+    for i, query in enumerate(sample_queries, 1):
+        console.print(f"[bold yellow]サンプル質問 {i}:[/bold yellow] {query}")
+
+        try:
+            with console.status(f"[bold green]質問 {i} を処理中...", spinner="dots"):
+                result = agent.chat(message=query)
+
+            response_panel = Panel(
+                Markdown(result["response"]) if result["response"] else "応答がありません",
+                title="[bold green]エージェントの応答[/bold green]",
+                border_style="green",
+            )
+            console.print(response_panel)
+
+            if result.get("tools_used"):
+                console.print(f"[dim]使用ツール: {', '.join(result['tools_used'])}[/dim]")
+
+            console.print()  # Add spacing
+
+        except Exception as e:
+            console.print(f"❌ [bold red]エラー[/bold red]: {str(e)}")
+            console.print()
+
+
+if __name__ == "__main__":
+    app()

template_fastapi/internals/__init__.py

@@ -0,0 +1 @@
+"""Core module for template_fastapi."""

template_fastapi/internals/langgraph/__init__.py

@@ -0,0 +1 @@
+"""LangGraph components for agent implementation."""

template_fastapi/internals/langgraph/agents.py

@@ -0,0 +1,84 @@
+"""Main LangGraph agent interface."""
+
+import uuid
+from datetime import datetime
+from typing import Any
+
+from langchain_core.messages import HumanMessage
+
+from .graphs import get_compiled_graph
+from .states import AgentState
+
+
+class LangGraphAgent:
+    """Main interface for LangGraph agent operations."""
+
+    def __init__(self):
+        self.graph = get_compiled_graph()
+
+    def chat(self, message: str, thread_id: str | None = None) -> dict[str, Any]:
+        """
+        Chat with the LangGraph agent.
+
+        Args:
+            message: User message
+            thread_id: Optional thread ID for conversation continuity
+
+        Returns:
+            Chat response with metadata
+        """
+        # Generate thread ID if not provided
+        if thread_id is None:
+            thread_id = str(uuid.uuid4())
+
+        # Create initial state
+        initial_state = AgentState(
+            messages=[HumanMessage(content=message)],
+            thread_id=thread_id,
+            tools_used=[],
+            step_count=0,
+        )
+
+        # Run the graph
+        config = {"configurable": {"thread_id": thread_id}}
+        result = self.graph.invoke(initial_state, config=config)
+
+        # Extract the final response
+        final_message = result["messages"][-1]
+        response_content = final_message.content if hasattr(final_message, "content") else str(final_message)
+
+        return {
+            "message": message,
+            "response": response_content,
+            "thread_id": thread_id,
+            "tools_used": result.get("tools_used", []),
+            "created_at": datetime.now().isoformat(),
+            "step_count": result.get("step_count", 0),
+        }
+
+    def stream_chat(self, message: str, thread_id: str | None = None):
+        """
+        Stream chat with the LangGraph agent.
+
+        Args:
+            message: User message
+            thread_id: Optional thread ID for conversation continuity
+
+        Yields:
+            Streaming responses from the agent
+        """
+        # Generate thread ID if not provided
+        if thread_id is None:
+            thread_id = str(uuid.uuid4())
+
+        # Create initial state
+        initial_state = AgentState(
+            messages=[HumanMessage(content=message)],
+            thread_id=thread_id,
+            tools_used=[],
+            step_count=0,
+        )
+
+        # Stream the graph execution
+        config = {"configurable": {"thread_id": thread_id}}
+        yield from self.graph.stream(initial_state, config=config)