fix(step-probe): ensure fast AI responses and tool calls are captured by real-time block

This commit is contained in:
Variet Worker
2026-04-10 17:12:21 +09:00
parent 300338d5d3
commit 488b36f192
12 changed files with 352 additions and 32 deletions

36
scratch_diag2.py Normal file
View File

@@ -0,0 +1,36 @@
import urllib.request
import json
def fetch_ls(port, csrf, method, args):
url = f"http://127.0.0.1:{port}/exa.language_server_pb.LanguageServerService/{method}"
req = urllib.request.Request(url, data=json.dumps(args).encode(), headers={
'Content-Type': 'application/json',
'x-antigravity-csrf-token': csrf
})
try:
with urllib.request.urlopen(req) as response:
return json.loads(response.read().decode('utf-8'))
except Exception as e:
return f"Error: {e}"
print("Connecting to LS port 60517 (global)...")
csrf_global = "7c0c7815-ec11-48d6-9866-daab2690448f"
port_global = 60517
print("\n--- GetAllCascadeTrajectories on 60517 ---")
res = fetch_ls(port_global, csrf_global, "GetAllCascadeTrajectories", {"limit": 100, "descending": True})
if isinstance(res, dict) and 'trajectorySummaries' in res:
keys = list(res['trajectorySummaries'].keys())
print(f"Total entries: {len(keys)}")
for k in keys[:5]: print(f" - {k}")
if "370d1a09-1fa8-4aed-90d7-4024e36b3a2d" in keys:
print("YES! 370d1a09 found on 60517!")
else:
print(res)
print("\n--- GetCascadeTrajectory on 60517 for 370d1a09 ---")
res2 = fetch_ls(port_global, csrf_global, "GetCascadeTrajectory", {"googleAgentId": "370d1a09-1fa8-4aed-90d7-4024e36b3a2d"})
if isinstance(res2, dict) and 'trajectory' in res2:
print("Found trajectory!")
else:
print(res2)