fix(backend/copilot): use backend.util.json in _append_gap_to_builder, drop inline import

autogpt_platform/backend/backend/copilot/baseline/service.py

@@ -26,6 +26,7 @@ from openai.types.chat import ChatCompletionMessageParam, ChatCompletionToolPara
 from opentelemetry import trace as otel_trace
 
 from backend.copilot.config import CopilotMode
+from backend.util import json as util_json
 from backend.copilot.context import get_workspace_manager, set_execution_context
 from backend.copilot.graphiti.config import is_enabled_for_user
 from backend.copilot.model import (
@@ -66,7 +67,6 @@ from backend.copilot.tracking import track_user_message
 from backend.copilot.transcript import (
     STOP_REASON_END_TURN,
     STOP_REASON_TOOL_USE,
-    TranscriptDownload,
     detect_gap,
     download_transcript,
     strip_for_upload,
@@ -723,8 +723,6 @@ def _append_gap_to_builder(
     Converts ChatMessage (OpenAI format) to TranscriptBuilder entries
     (Claude CLI JSONL format) so the uploaded transcript covers all turns.
     """
-    import orjson
-
     for msg in gap:
         if msg.role == "user":
             builder.append_user(msg.content or "")
@@ -735,16 +733,17 @@ def _append_gap_to_builder(
             if msg.tool_calls:
                 for tc in msg.tool_calls:
                     fn = tc.get("function", {}) if isinstance(tc, dict) else {}
-                    try:
-                        input_data = orjson.loads(fn.get("arguments", "{}"))
-                    except Exception:
-                        input_data = {}
-                    content_blocks.append({
-                        "type": "tool_use",
-                        "id": tc.get("id", "") if isinstance(tc, dict) else "",
-                        "name": fn.get("name", "unknown"),
-                        "input": input_data,
-                    })
+                    input_data = util_json.loads(
+                        fn.get("arguments", "{}"), fallback={}
+                    )
+                    content_blocks.append(
+                        {
+                            "type": "tool_use",
+                            "id": tc.get("id", "") if isinstance(tc, dict) else "",
+                            "name": fn.get("name", "unknown"),
+                            "input": input_data,
+                        }
+                    )
             if content_blocks:
                 builder.append_assistant(content_blocks=content_blocks)
         elif msg.role == "tool" and msg.tool_call_id:

autogpt_platform/backend/backend/copilot/service_test.py

@@ -65,14 +65,19 @@ async def test_sdk_resume_multi_turn(setup_test_user, test_user_id):
     for _ in range(10):
         await asyncio.sleep(0.5)
         cli_session = await download_transcript(test_user_id, session.session_id)
-        if cli_session:
+        # Wait until both the session bytes AND the message_count watermark are
+        # present — a session with message_count=0 means the .meta.json hasn't
+        # been uploaded yet, so --resume on the next turn would skip gap-fill.
+        if cli_session and cli_session.message_count > 0:
             break
     if not cli_session:
         return pytest.skip(
             "CLI did not produce a usable transcript — "
             "cannot test --resume round-trip in this environment"
         )
-    logger.info(f"Turn 1 CLI session uploaded: {len(cli_session.content)} bytes")
+    logger.info(
+        f"Turn 1 CLI session uploaded: {len(cli_session.content)} bytes, msg_count={cli_session.message_count}"
+    )
 
     # Reload session for turn 2
     session = await get_chat_session(session.session_id, test_user_id)