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

feat: project-scoped conversation history via iteration_id=project_id

Browse Source
This commit is contained in:
ymq 2026-08-09 23:32:29 +08:00
parent b3a24a1250
commit e14db2cde7
1 changed files with 10 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
wwwroot/api/cockpit_chat.dspy
View File

@ -475,17 +475,21 @@ if action == 'send_message':
env_text = f"【当前项目: {ctx['pname'] or '未选择'}】— 所有操作在当前项目内完成\n工作空间: {ctx['ws'] or '未设置'} | 仓库: {repos_str}" env_text = f"【当前项目: {ctx['pname'] or '未选择'}】— 所有操作在当前项目内完成\n工作空间: {ctx['ws'] or '未设置'} | 仓库: {repos_str}"
system = AGENT_PROMPT.replace('__TOOLS__',TOOLS_TEXT).replace('__ENV__',env_text) system = AGENT_PROMPT.replace('__TOOLS__',TOOLS_TEXT).replace('__ENV__',env_text)
msgs = [{"role":"system","content":system}] msgs = [{"role":"system","content":system}]
for h in (await sor.sqlExe("SELECT role,content FROM pipeline_conversations WHERE created_by=${u}$ ORDER BY created_at ASC LIMIT 20",{"u":uid}) or []): # Load history scoped to current project (via iteration_id = project_id)
sql = "SELECT role,content FROM pipeline_conversations WHERE created_by=${u}$ ORDER BY created_at ASC LIMIT 20"
params = {"u":uid}
if ctx['pid']:
sql = "SELECT role,content FROM pipeline_conversations WHERE created_by=${u}$ AND iteration_id=${p}$ ORDER BY created_at ASC LIMIT 20"
params = {"u":uid,"p":ctx['pid']}
for h in (await sor.sqlExe(sql, params) or []):
c = getattr(h,'content','') or '' c = getattr(h,'content','') or ''
r = getattr(h,'role','') or '' r = getattr(h,'role','') or ''
# Skip raw tool_call JSON and contaminated old messages # Skip raw tool_call JSON — prevents LLM from mimicking old tool calls
if c.startswith('{"action":"tool_call"') or c.startswith('{"action": "tool_call"'): if c.startswith('{"action":"tool_call"') or c.startswith('{"action": "tool_call"'):
continue continue
if 'tetris' in c.lower() or '俄罗斯方块' in c:
continue
msgs.append({"role":'user' if r=='user' else 'assistant',"content":c}) msgs.append({"role":'user' if r=='user' else 'assistant',"content":c})
msgs.append({"role":"user","content":message_text}) msgs.append({"role":"user","content":message_text})
await sor.C('pipeline_conversations',{'id':getID(),'role':'user','content':message_text,'msg_type':'text','org_id':org_id,'created_by':uid}) await sor.C('pipeline_conversations',{'id':getID(),'role':'user','content':message_text,'msg_type':'text','org_id':org_id,'created_by':uid,'iteration_id':ctx['pid'] or ''})
agent_reply = '' agent_reply = ''
for turn in range(10): for turn in range(10):
@ -521,7 +525,7 @@ if action == 'send_message':
d = json.dumps(_w_text(agent_reply), ensure_ascii=False)+'\n' d = json.dumps(_w_text(agent_reply), ensure_ascii=False)+'\n'
debug(f"YIELD final: {d[:60]}") debug(f"YIELD final: {d[:60]}")
yield d yield d
await sor.C('pipeline_conversations',{'id':getID(),'role':'agent','content':agent_reply,'msg_type':'text','org_id':org_id,'created_by':'system'}) await sor.C('pipeline_conversations',{'id':getID(),'role':'agent','content':agent_reply,'msg_type':'text','org_id':org_id,'created_by':'system','iteration_id':ctx['pid'] or ''})
return await stream_response(request, agent_stream, 'text/plain; charset=utf-8') return await stream_response(request, agent_stream, 'text/plain; charset=utf-8')