|
|
@@ -19,7 +19,7 @@ msgGroups: Dict[str, List[Dict[str, Any]]] = {}
|
|
|
|
|
|
|
|
|
def generate_trace_list(
|
|
|
- base_url: str = "http://localhost:8000",
|
|
|
+ base_url: str = "http://43.106.118.91:8000",
|
|
|
status: Optional[str] = None,
|
|
|
mode: Optional[str] = None,
|
|
|
limit: int = 20,
|
|
|
@@ -36,7 +36,7 @@ def generate_trace_list(
|
|
|
|
|
|
|
|
|
def generate_goal_list(
|
|
|
- trace_id: str = "trace_001", base_url: str = "http://localhost:8000"
|
|
|
+ trace_id: str = "trace_001", base_url: str = "http://43.106.118.91:8000"
|
|
|
) -> Dict[str, Any]:
|
|
|
url = f"{base_url.rstrip('/')}/api/traces/{trace_id}"
|
|
|
response = httpx.get(url, timeout=10.0)
|
|
|
@@ -45,7 +45,7 @@ def generate_goal_list(
|
|
|
|
|
|
|
|
|
def generate_subgoal_list(
|
|
|
- sub_trace_id: str, base_url: str = "http://localhost:8000"
|
|
|
+ sub_trace_id: str, base_url: str = "http://43.106.118.91:8000"
|
|
|
) -> Dict[str, Any]:
|
|
|
url = f"{base_url.rstrip('/')}/api/traces/{sub_trace_id}"
|
|
|
response = httpx.get(url, timeout=10.0)
|
|
|
@@ -54,7 +54,7 @@ def generate_subgoal_list(
|
|
|
|
|
|
|
|
|
def generate_messages_list(
|
|
|
- trace_id: str, goal_id: Optional[str] = None, base_url: str = "http://localhost:8000"
|
|
|
+ trace_id: str, goal_id: Optional[str] = None, base_url: str = "http://43.106.118.91:8000"
|
|
|
) -> Dict[str, Any]:
|
|
|
url = f"{base_url.rstrip('/')}/api/traces/{trace_id}/messages"
|
|
|
params = {}
|
|
|
@@ -154,7 +154,7 @@ def generate_mock_branch_detail(trace_id: str = "trace_001", branch_id: str = "b
|
|
|
|
|
|
|
|
|
async def _fetch_ws_connected_event(trace_id: str, since_event_id: int = 0, ws_url: Optional[str] = None) -> Dict[str, Any]:
|
|
|
- url = ws_url or f"ws://localhost:8000/api/traces/{trace_id}/watch?since_event_id={since_event_id}"
|
|
|
+ url = ws_url or f"ws://43.106.118.91:8000/api/traces/{trace_id}/watch?since_event_id={since_event_id}"
|
|
|
async with websockets.connect(url) as ws:
|
|
|
while True:
|
|
|
raw_message = await ws.recv()
|
|
|
@@ -234,7 +234,7 @@ def _append_event_jsonl(event_data: Dict[str, Any], mock_dir: str):
|
|
|
|
|
|
|
|
|
async def _watch_ws_events(trace_id: str, since_event_id: int = 0, ws_url: Optional[str] = None):
|
|
|
- url = ws_url or f"ws://localhost:8000/api/traces/{trace_id}/watch?since_event_id={since_event_id}"
|
|
|
+ url = ws_url or f"ws://43.106.118.91:8000/api/traces/{trace_id}/watch?since_event_id={since_event_id}"
|
|
|
mock_dir = os.path.join(os.path.dirname(__file__), "ws_data")
|
|
|
os.makedirs(mock_dir, exist_ok=True)
|
|
|
while True:
|