q%j0mUdZddlmZddlZddlZddlZddlZddlZddlm Z ddl m Z ddl m Z ejdZdaded <dad ed <dd Zd ZddZddZGddZeZy)uW階段 10-B:Cooper 全域 ClaudeSDKClient 管理器(暖機 + 常駐 + 序列化)。 設計重點: - uvicorn 啟動時 connect 一次(10s),user 看不到 - 每個 LINE 訊息用 session_id 區分群組(line:) - asyncio.Lock 序列化 query — 同一個 client 一次只跑一個,避免狀態錯亂 - 工具 wrapper 用 ContextVar 取得 requester_id(取代 closure) - 9 個 Cooper MCP 工具在 client connect 時就註冊好(不再每次 LINE 訊息重建) 使用方式: # uvicorn lifespan startup await cooper_client_manager.startup() # LINE 訊息進來 response_text, rate_info, tools_called = await cooper_client_manager.respond( prompt_text="...", session_id="line:", requester_id=user_id, ) # uvicorn lifespan shutdown await cooper_client_manager.shutdown() ) annotationsN)Any)UUID)settingszcoba.cooper_clientz UUID | None_current_requester_idlist[dict] | None_current_tool_callsc |a|ayNrr ) requester_idtool_calls_buckets >/volume1/homes/robertsu/coba/app/app/services/cooper_client.py_set_request_contextr7s(+c dadayr r rr_clear_request_contextr=s rc0t tdtS)Nu4Cooper tool 在沒有 requester context 時被呼叫)r RuntimeErrorrrr_get_requester_idrCs$QRR  rcrt1tj||t|jdyy)N)nameinput result_keys)r appendlistkeys)rargsresults r_record_tool_callr!Is4&"" .$  'rcFeZdZdZdZdZdZdZ d d dZy) CooperClientManageruA單例 — 包住 ClaudeSDKClient + lock + 暖機/關閉邏輯。cd|_tj|_d|_d|_tj |_y)NF)_clientasyncioLock_lock_started _mcp_serverEvent _ready_eventselfs r__init__zCooperClientManager.__init__Xs3  \\^  $#MMOrcddlmddlm}m}m}m}m}m}m }m }m } m } m } m} m} m}m}m}m}m}m}m}ddddddddddddd dkfd }||d d d d ddd ddd ddd gdddd iddgd||ddd d gdddd idd iddidd||ddd d d ddd id gd!dd"d#gd||d$d%d dd idd idd idd id d&dd gddd d'dd(d||d)d*d dd idd idd id+d,gd||d-d.d dd idd id/d||d0d1d d2dd iid||d3d4d id|| d5d6d d7ddiid|| d8d9d id|| d:d;d d dd?gd|| d@dAd dBddCdid|| dDdEd dd id dFddGd||dHdId dd idd id dJddd idd idKd||dLdMd dd idd id dNddd id ddd gdddd idOdPddQdgd||dRdSd dd id dTddUdd idVdUdd idWdXdUdd idYdXdZdgd||d[d\d d]dd^did||d_d`d dd idd idad||dbdcd dd idd idad||ddded d dfdd gdgddd id dhddd ididjgdgS)lNrtool)tool_create_tasktool_list_taskstool_update_task_statustool_update_tasktool_reassign_tasktool_delete_tasktool_share_dashboard_linktool_get_team_memberstool_list_assignment_statustool_get_team_completion_ratetool_save_reflectiontool_list_recent_reflectionstool_delete_reflectiontool_update_reflectiontool_convert_reflection_to_tasktool_add_team_membertool_record_meetingtool_list_meetingstool_get_meeting_detailtool_delete_meetingtasks reflectionsmeetingsusers) create_task update_taskupdate_task_status reassign_task delete_tasksave_reflectiondelete_reflectionupdate_reflectionconvert_reflection_to_taskrecord_meetingdelete_meetingadd_team_memberc6||dfd }|S)NcKt} |xsi|d{}t ||d|vrCj}|r0ddlm } ||d{dk(r|dd{d tj|d d gd|vdS7x#t$r<}tjddt |j d|i}Yd}~d}~wwxYw77p#t$rtjd YwxYww)Nztool %s failederror: r)_broadcast_data_changedr1rSrGzbroadcast after tool=%s failedtextF) ensure_asciityper\)contentis_error) r Exceptionlogger exceptionr___name__r!getapp.services.coba_toolsr[jsondumps) rr r eentityr[TOOL_BROADCAST_ENTITYrtool_fns r_wrappedzACooperClientManager._build_tools.._wrap.._wrappeds'02 C#*4:2|#DDF"$f5&(266t._wraps% $ V , - 4OrrKuW建立一個新任務在團隊的行程規畫系統。當使用者明確命令時用。objectstringu 任務標題)r_rqu負責人 display_namez YYYY-MM-DD)lowmediumhighurgent)r_enumr_)title assignee_namedue_datepriorityrqr{)r_ propertiesrequired list_tasksu<查任務(可帶 status / assignee_name / keyword 條件)。)pending in_progress completed cancelledallinteger)statusr|keywordlimit)r_rrMuM改任務狀態。用 task_id_prefix(前 8 碼)或 title_keyword 找任務。utask UUID 前 8 字元)todorreviewdoner)task_id_prefix title_keyword new_statusrrLu全功能改任務:可改 title / description / due_date / priority / assignee。不改 status(用 update_task_status)。用 task_id_prefix(前 8 碼)或 title_keyword 鎖定任務。把 new_due_date 設成 'null' 可清除截止日;new_assignee_name 設成 'null' 取消指派。uYYYY-MM-DD,或 'null' 清除u1新負責人 display_name,或 'null' 取消指派)rr new_titlenew_description new_due_date new_prioritynew_assignee_namerNuW把任務轉指派給另一個成員。是 update_task 的 sugar 版,只動 assignee。)rrrrrOu軟刪任務(set deleted_at)。)rrshare_dashboard_linkuE給對方一鍵登入 dashboard 的 magic link(只在 1 對 1 用)。target_user_nameget_team_membersu0取得團隊成員清單(display_name + role)。list_assignment_statusu>列最近自動建任務的認領狀態(誰接 / 誰沒接)。daysget_team_completion_rateu列每人本週完成率 KPI。rPuP把使用者的覆盤 / 體悟 / 反省內容存進體悟紀錄(不建任務)。u體悟內容原文u可選:類別標籤)r`tagr`list_recent_reflectionsuq列最近群組分享的覆盤 / 體悟記錄。回傳含 id_short 讓你後續能 update / delete / 轉任務。hoursu預設 168(一週)rQuu軟刪一筆覆盤。用 reflection_id_prefix(前 8 碼,從 list_recent_reflections 拿)或 content_keyword 鎖定。u覆盤內容關鍵字)reflection_id_prefixcontent_keywordrRum改一筆覆盤的內容 / 摘要 / 標籤。至少要給 new_content / new_summary / new_tag 其中一個。u新覆盤完整內容)rr new_content new_summarynew_tagrSu誤分類修正:某筆覆盤其實是任務 → 升級成任務,自動軟刪原覆盤。必填 title。可選 assignee_name / due_date / priority / description / mark_done(已完成的事直接 done)。u新任務標題,動詞開頭booleanu;true=立刻標 done(用於『我已經完成 X』類報告))rrr{r|r}r~rq mark_donerTuE從文字直接記錄一場會議。使用者說「庫柏 記下這次會議:標題 / 結論 / action items」就用這個。必填 title。可選:executive_summary、key_topics、decisions(list[str|dict])、action_items(list[str|dict{description,assignee_name,due_date}])。建好後 status='completed',不走錄音流程。u2-4 句濃縮摘要array)r_itemsu重要決策清單)r_rrquA待辦事項清單(可帶 - 阿綠週五前 X 之類自然語言))r{executive_summary key_topics decisions action_items list_meetingsu=列最近會議。回傳含 id_short 給後續查詳細用。ru 預設 10get_meeting_detailur看一場會議完整內容(摘要 + 決策 + action items)。用 meeting_id_prefix(8 碼)或 title_keyword 找。)meeting_id_prefixrrUu軟刪會議。rVu新增團隊成員到行程規畫系統。必填 display_name;可選 role(owner/manager/member,預設 member)、email、line_user_id、job_title。成功會回 user_id_short + 預設密碼提示給對方第一次登入用。u!對方在系統內的顯示名稱)ownermanagermemberuLINE 個人 ID,Uxxxxx 格式) display_nameroleemail line_user_id job_titler)rstrrqrrrro)claude_agent_sdkr2rgr3r4r5r6r7r8r9r:r;r<r=r>r?r@rArBrCrDrErF)r.r3r4r5r6r7r8r9r:r;r<r=r>r?r@rArBrCrDrErFrsrlr2s @@r _build_toolsz CooperClientManager._build_toolscs6)      4#"")$",!.!.*7((& !  > "Mi$*2>!R2:Kc)d-5l$S-5?b$c(.'9 #")    /<N$+3=x"y*0();$*H#5"()!4 #  )+?_$3;Ld*e*0();/7Aw&x# ".  "Mt %+18*<*0();&,h%7,2H+=19Jh(i19Cf(g6>PC.D#   $ $oi$+18*<*0();.4h-?# "5 5  "M1$+18*<*0();#  +-CW!2DvxFX1YZ  ');B!4  -/GP!&69:M1NO  /1K1!4  &(9b$,4EY#Z(0AVW#"+   .0ID!'I^r;s1tu  (*=s%170B4Od-e/6&(AS&T$+&,h%7+?& %,&,h%7+n)#") #  4 $oO$#*Y{,["\  )+?G%.4h-?*0();#  %'7!$.4h-?*0();#  &(9`%19Jm(n)1;Y Z"((!319Jh(i&,h%7 #"0 0   ]^ ^ rcK|jrytjstj dyddlm}m}m}|dd|j|_ gd}ddl m }|d |g|d|jid d d gd dtjd }d}tddD]w}td|dd |||_ |jj!d{d |_|j"j%td|dd y|r|y7>#t&$r} | }t)| dd} td|dt+| j,d| d  |jr#|jj/d{7n#t&$rYnwxYwd|_|dkrt1j2dd{7Yd} ~ 3d} ~ wwxYww)Nu:CLAUDE_CODE_OAUTH_TOKEN 沒設,Cooper SDK client 不啟動r)ClaudeSDKClientClaudeAgentOptionscreate_sdk_mcp_servercooperz1.0.0)rversiontools)mcp__cooper__create_taskmcp__cooper__list_tasksmcp__cooper__update_task_statusmcp__cooper__update_taskmcp__cooper__reassign_taskmcp__cooper__delete_task!mcp__cooper__share_dashboard_linkmcp__cooper__get_team_members#mcp__cooper__list_assignment_status%mcp__cooper__get_team_completion_ratemcp__cooper__save_reflection$mcp__cooper__list_recent_reflectionsmcp__cooper__delete_reflectionmcp__cooper__update_reflection'mcp__cooper__convert_reflection_to_taskmcp__cooper__add_team_membermcp__cooper__record_meetingmcp__cooper__list_meetingsmcp__cooper__get_meeting_detailmcp__cooper__delete_meeting)COBA_BASE_PROMPTzclaude-sonnet-4-5TbypassPermissionsz/tmp)ANTHROPIC_API_KEYCLAUDE_CODE_OAUTH_TOKEN) model system_promptr allowed_tools mcp_serversstrict_mcp_config max_turnspermission_modesetting_sourcescwdenvz+[COOPER_CLIENT_STARTUP] connecting attempt=z...flush)optionsu/[COOPER_CLIENT_STARTUP] ✓ connected (attempt=)z&[COOPER_CLIENT_STARTUP_RETRY] attempt=z fail: rZ)r)rrrcwarningrrrrrr*app.services.coba_chatrrangeprintr%connectr,setrbrr_re disconnectr&sleep) r.rrrallowedrrlast_errattemptrjerr_msgs rstartupzCooperClientManager.startups == // NNW X   1##%   2 <$%*!!4#3#34"/%'+3+K+K &&*Q{G ?yLTX Y*7;DL +ll**,,, $ !!%%'GyPQRZ^_#. N '-  +a&#,>wiwtTUwO_O_N``bcjbkltxy||"ll55777 # Q;!--*** +s~CG! D'&D%'6D'G!%D'' G09G*)FFFG F&#G%F&&'G GGG!GG!cK|jrI|jr= tdd|jjd{tddd|_d|_y7 #t$rt j dY1wxYww)Nz)[COOPER_CLIENT_SHUTDOWN] disconnecting...Tru)[COOPER_CLIENT_SHUTDOWN] ✓ disconnecteduCooper client disconnect 失敗F)r%r)rrrbrcrdr-s rshutdownzCooperClientManager.shutdownsy <"}} u,[COOPER_QUERY_WAIT_READY] 等暖機完成...Tr<)timeoutNuCooper client 暖機 60s 超時uCooper client 未啟動r)AssistantMessage TextBlock ResultMessageRateLimitEventz[COOPER_QUERY] session=z prompt_len=z images=z (multimodal)r\r^c(Kdddddyw)Nuser)rr`)r_messageparent_tool_use_id session_idr)content_blocksrsr_msg_genz-CooperClientManager.respond.._msg_gen,s"$*06>'R26*4 s)rgz[COOPER_RESULT] duration_ms=z cost=z.5fz stop=z tools=z[COOPER_RATE_LIMIT] type=z status=z overage= c3^K|]%}|js|j'ywr )strip).0ps r z.CooperClientManager.respond..Ys)V[AGGI!'')[s--u(庫柏沒說話)) response_textrate_limit_typerate_limit_statustotal_cost_usd tool_calls)"r,is_setrr&wait_forwait TimeoutErrorrr)r%rrrrrr(rlenqueryreceive_messages isinstancer`rr\r duration_ms stop_reasonrate_limit_inforroverage_statusjoinr r)r. prompt_textrr image_blocksrrrrrr  text_piecesobserved_rate_typeobserved_rate_statusrmsgblockinforr s ` @rrespondzCooperClientManager.responds?"  '') @ M P&&t'8'8'='='?LLL}}DLL89 9  )+G %zzz$\3DE 1*\#kJZI[\""%l"3!4MC" 06{&K%L|%[N,,,,XZJ,OOO1*\#kJZI[\",,,,[Z,PPP)+ 15"37$!$"&!>!>!@#!#'78%([[E)%; + 2 25:: >&1$C7),););)Bs:3??:KL$$23#7vcoo=NO%%():%;$<>#'  #C8"22-1-A-A*/3{{,78L8L7MN&&*kk])Dr:s0#     / 0&*{))-&-,  !  O%O%f,-r