File size: 8,845 Bytes
33516f7
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
"""React Agent CLI - Simple terminal chat interface.

Purpose:
    Interactive chat loop for testing the react agent.
    
Features:
    - Colored output (ANSI codes)
    - Streams tool calls and final responses
    - Conversation memory via LangGraph SQLite checkpointer (survives restart)
    - Type 'exit' or Ctrl+C to quit
    
Usage:
    uv run python -m src.react_agent.chat_cli
    uv run python -m src.react_agent.chat_cli --thread-id <id>
"""

import argparse
import sys
import asyncio
import os
import uuid
from typing import Any, Optional, Sequence, Union

from dotenv import load_dotenv
from langchain.messages import HumanMessage, AIMessage, ToolMessage
from langchain_core.messages import BaseMessage
from langgraph.errors import GraphRecursionError
from langchain_core.runnables import RunnableConfig

from src.llm.content import format_message_content
from src.react_agent.graph import react_agent
from src.react_agent.configuration import Configuration

# Simple ANSI colors with auto-disable if not a TTY
SUPPORTS_COLOR = sys.stdout.isatty()
COLOR_RESET = "\033[0m" if SUPPORTS_COLOR else ""
COLOR_INFO = "\033[36m" if SUPPORTS_COLOR else ""       # cyan
COLOR_TOOL = "\033[33m" if SUPPORTS_COLOR else ""       # yellow
COLOR_SUCCESS = "\033[32m" if SUPPORTS_COLOR else ""    # green
COLOR_PROMPT = "\033[94m" if SUPPORTS_COLOR else ""     # blue
COLOR_DIM = "\033[90m" if SUPPORTS_COLOR else ""        # gray
COLOR_BOLD = "\033[1m" if SUPPORTS_COLOR else ""        # bold


def _truncate(text: str, limit: int = 600) -> str:
    """Truncate long tool outputs for terminal readability."""
    if len(text) <= limit:
        return text
    return text[:limit] + " ...[truncated]..."

_format_ai_content = format_message_content


def _first_unseen_index(messages: Sequence[BaseMessage]) -> int:
    """Index of the first message produced by the current turn.

    Everything up to and including this turn's HumanMessage is either restored
    checkpoint history or the prompt the user just typed, so none of it should
    be re-printed as agent output.
    """
    for i in range(len(messages) - 1, -1, -1):
        if isinstance(messages[i], HumanMessage):
            return i + 1
    return 0


def _get_stream_mode() -> Union[str, Sequence[str]]:
    """Parse REACT_AGENT_STREAM_MODE env var."""
    value = os.environ.get("REACT_AGENT_STREAM_MODE")
    if not value:
        return ("updates", "values")
    raw = value.strip()
    if "," not in raw:
        return raw
    parts = [p.strip() for p in raw.split(",") if p.strip()]
    return tuple(parts) if parts else ("updates", "values")


def _normalize_stream_item(chunk: Any) -> tuple[str | None, Any]:
    """LangGraph yields `(mode, data)` when stream_mode is a sequence."""
    if isinstance(chunk, tuple) and len(chunk) == 2 and isinstance(chunk[0], str):
        return chunk[0], chunk[1]
    return None, chunk


def _values_messages(chunk: Any) -> list[BaseMessage] | None:
    """Return the messages list from a values payload, or None to skip."""
    mode, data = _normalize_stream_item(chunk)
    if mode == "updates":
        return None
    if isinstance(data, dict) and "messages" in data:
        return list(data.get("messages") or [])
    return None


async def run_turn(user_input: str, thread_id: str) -> None:
    """Run one turn through the agent.
    
    The checkpointer automatically retrieves and stores conversation history
    based on the thread_id, so we only need to send the new user message.
    """
    stream_mode = _get_stream_mode()
    final_response: Any = None
    cfg = Configuration()
    
    # Include thread_id in configurable for checkpointer to manage history
    run_config = RunnableConfig(
        recursion_limit=cfg.max_iterations,
        configurable={"thread_id": thread_id},
    )

    # Track messages we've already displayed in this turn. On a resumed thread the
    # first `values` chunk replays the whole checkpointed history, so start printing
    # after this turn's HumanMessage rather than from index 0.
    last_seen: int | None = None
    latest_messages: list[BaseMessage] = []
    
    try:
        async for chunk in react_agent.astream(
            {"messages": [HumanMessage(content=user_input)]},
            config=run_config,
            stream_mode=stream_mode,
        ):
            chunk_messages = _values_messages(chunk)
            if chunk_messages is None:
                continue
            latest_messages = chunk_messages

            if last_seen is None:
                last_seen = _first_unseen_index(chunk_messages)

            # Only process new messages appended since last chunk
            for msg in chunk_messages[last_seen:]:
                if isinstance(msg, ToolMessage):
                    print(f"{COLOR_DIM}  └─ Result ({msg.name}): {_truncate(str(msg.content), 200)}{COLOR_RESET}")
                elif isinstance(msg, AIMessage):
                    if getattr(msg, "tool_calls", None):
                        for tc in msg.tool_calls:
                            name = tc.get("name", "unknown")
                            args = tc.get("args", {})
                            print(f"{COLOR_TOOL}  ┌─ Call: {name}{COLOR_RESET}{COLOR_DIM}({args}){COLOR_RESET}")
                    elif msg.content:
                        final_response = msg.content
                        print(f"\n{COLOR_SUCCESS}=== Agent Response ==={COLOR_RESET}")
                        print(_format_ai_content(final_response))
                        print(f"{COLOR_SUCCESS}======================{COLOR_RESET}\n")

            last_seen = len(chunk_messages)
                
    except GraphRecursionError as e:
        print(
            f"{COLOR_INFO}Error: {e}{COLOR_RESET}\n"
            f"{COLOR_INFO}Tip: The agent hit its iteration limit. Try rephrasing, or increase REACT_AGENT_MAX_ITERATIONS.{COLOR_RESET}"
        )
        return
    
    # If we never printed a final response but we do have messages, try to print the last AI output.
    if final_response is None and latest_messages:
        for msg in reversed(latest_messages):
            if isinstance(msg, AIMessage) and not getattr(msg, "tool_calls", None) and msg.content:
                final_response = msg.content
                print(f"\n{COLOR_SUCCESS}=== Agent Response ==={COLOR_RESET}")
                print(_format_ai_content(final_response))
                print(f"{COLOR_SUCCESS}======================{COLOR_RESET}\n")
                break


THREAD_ID_ENV = "REACT_AGENT_THREAD_ID"


def build_parser() -> argparse.ArgumentParser:
    """CLI flags. Stdin (`input()`) is still used for the chat loop."""
    parser = argparse.ArgumentParser(
        description="Interactive chat for the react agent.",
    )
    parser.add_argument(
        "--thread-id",
        dest="thread_id",
        default=None,
        help=(
            "Resume a conversation by thread_id. "
            f"Overrides ${THREAD_ID_ENV}. If omitted, a new id is generated."
        ),
    )
    return parser


def resolve_thread_id(cli_thread_id: Optional[str] = None) -> str:
    """Resolve thread_id: --thread-id > REACT_AGENT_THREAD_ID > new uuid."""
    if cli_thread_id and cli_thread_id.strip():
        return cli_thread_id.strip()
    env = os.environ.get(THREAD_ID_ENV, "").strip()
    if env:
        return env
    return str(uuid.uuid4())


async def run_chat(thread_id: str) -> None:
    """Main chat loop. `input()` stays the turn prompt."""
    print(f"{COLOR_BOLD}React Agent Chat{COLOR_RESET} (type 'exit' to quit)")
    print(f"{COLOR_DIM}thread_id: {thread_id}{COLOR_RESET}")
    print(
        f"{COLOR_DIM}Replay: uv run python -m src.react_agent.chat_cli "
        f"--thread-id {thread_id}{COLOR_RESET}"
    )
    print(f"{COLOR_DIM}{'-'*50}{COLOR_RESET}")
    print()
    
    try:
        while True:
            # Get user input
            user_input = input(f"{COLOR_PROMPT}You{COLOR_RESET}: ").strip()
            
            if not user_input or user_input.lower() == "exit":
                print("Goodbye!")
                break
            
            # Run agent turn - checkpointer handles message history automatically
            await run_turn(user_input, thread_id)
            
            print(f"{COLOR_DIM}{'-'*80}{COLOR_RESET}")
            print()
            
    except KeyboardInterrupt:
        print("\n\nGoodbye!")
    except Exception as e:
        print(f"\n{COLOR_INFO}Error: {e}{COLOR_RESET}")
        import traceback
        traceback.print_exc()


def main(argv: Optional[list[str]] = None) -> None:
    """Parse flags, then run the stdin chat loop."""
    load_dotenv()
    args = build_parser().parse_args(argv)
    thread_id = resolve_thread_id(args.thread_id)
    asyncio.run(run_chat(thread_id))


if __name__ == "__main__":
    main()