yumoqing/pipeline-sdlc
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

revert: cockpit_chat.dspy back to yield streaming version (6f5e989), remove request.read() raw body path

Browse Source
This commit is contained in:
ymq 2026-08-09 16:55:04 +08:00
parent 9a1d8083fd
commit d46ab14e12
1 changed files with 5 additions and 17 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

22
wwwroot/api/cockpit_chat.dspy
View File

@ -2,26 +2,14 @@
import aiohttp
action = (params_kw or {}).get('action', 'list_messages')
# AgentIO sends JSON body: {"params":{"prompt":"...","model_id":"..."},...}
# AgentIO sends JSON body without action field — detect from message_text presence
if action != 'send_message':
try: p = dict(params_kw) if params_kw else {}
except: p = {}
msg = p.get('message_text', '') or ''
p = params_kw or {}
msg = (p.get('message_text') or '').strip()
if not msg:
inner = p.get('params', None)
if inner is not None and isinstance(inner, dict):
inner = p.get('params', {})
if isinstance(inner, dict):
msg = (inner.get('prompt') or inner.get('message_text') or '').strip()
# bricks_fetch sends JSON body without Content-Type — read raw
if not msg:
try:
raw_body = await request.read()
if raw_body:
import json
body = json.loads(raw_body.decode('utf-8'))
inner2 = body.get('params', {})
if isinstance(inner2, dict):
msg = (inner2.get('prompt') or inner2.get('message_text') or '').strip()
except: pass
if msg:
action = 'send_message'
dbname = get_module_dbname('pipeline-sdlc')