iJxdZddlmZddlZddlZddlmZmZddlmZddl m Z ddl Z ddl m Z ddlmZdd lmZdd lmZmZdd lmZdd lmZej2d Zd"dZd#dZd$dZd%dZdddddddZd&dZ d'dZ! d(dZ"d&dZ#d&dZ$d&dZ%d&dZ& d)d Z'd*d+d!Z(y),u LINE 事件 ↔ Cooper 內部頻道/訊息系統的橋接層(階段 6)。 職責: 1. 每個 LINE source(group / room / 1對1)對應一個 Cooper Channel - 第一次看到時自動建一個 channel_type='line_' 的 Channel 2. 每個 LINE userId 對應一個 Cooper User - 沒綁定的會建立「影子帳號」(password_hash=""),日後可由 owner 合併到實體帳號 3. message 事件 → 存成 Channel 的 Message → 觸發 tagging / index / Cooper 回應 4. follow / join / leave 事件 → 維護 Channel 的存在 / 軟刪 5. Cooper 回應一律用 push_text(LLM 跑完通常超過 reply token 的 1 分鐘 TTL) 設計原則:整段都是 best-effort,單一事件失敗只 log,不要把整批 events 拖垮。 ) annotationsN)datetimetimezone)Any)UUID)select)settings)AsyncSessionLocal)ChannelMessage)User) line_clientzcoba.line.bridgec|jd}|dk(rd|jdfS|dk(rd|jdfS|dk(rd|jdfSy) u+source dict → (source_type, source_id)。typegroupgroupIdroomroomIduseruserIdNN)get)srcstypes Q>QRV>WX  }&)WWV_%?swwy!TH++L8LLGMr&&}5S5bqAQ@R9SLm  .F l^=1! ! AFF1I hhj H? M   kkm:: 4L  t00L@ A       H  suA#F<%D8&AF<=D:>AF<D>1D<2D>6F<:F<<D>>F9EAF9!F$"F95F<8F99F<cK|jd}|jdxsi} |dk(rt||d{y|dk(rt||d{y|dk(rt||d{y|dk(rt ||d{y|dk(rt ||d{yy7n7V7>7&7#t $rtjd |YywxYww) u(LINE webhook 拋進來的單一事件。rsourcemessageNfollowunfollowjoinleaveuLINE 事件處理失敗 type=%s) r_handle_message_handle_follow_handle_unfollow _handle_join _handle_leaverClogger exception)eventetypers r handle_eventrYs IIf E ))H  #C C I !%- - - h  , , , j "5#. . . f_uc* * * g s+ + + . , . * + C:EBCs'CB7B-B7CB7B/B7CB72B13B77C8B7 B3 B7CB7&B5'B7+C-B7/B71B73B75B77CCCCu[圖片]u[語音]u[影片]u[檔案]u[貼圖]u[位置])imageaudiovideofilestickerlocationc K|jdxsi}|jdd}|jd}|jd}|jd}t4d{}t||d{}| dddd{yt|||d{} |dk(r|jdd} d} nR|tvrBt|} d} |dk(rd |jd d} | | j } |d vr|nd} nd |d } d} t |j| r | jnd| | |}|j||jd{|j}|j}|j}dddd{ ddl m }ddl m}||| r | jnd tj t"j$j'd dk(r r| jr ddlm}|| dk(r ddlm}||dvr2|r0t7j8t;|| r | jnd| dk(r4|r2ddlm}| }|r"t7j8tA|||y| dk(r?ddl!m"}m#}| r/t7j8tI r | jnd|y| dk7ry|jddk(}ddl%m&}|rd}nEt4d{}|  r | jnd|d{}dddd{s!dd l!m'}t7j8||syt7j8tQ|y7.77 77@7#1d{7swY xYw#t($rt*j-dYwxYw#t($rt*j-dYwxYw#t($rt*j-dYwxYw777#1d{7swYxYww)!NrKrtextidr replyTokenr9r] fileName)rZr[r]u[未支援訊息:]) channel_iduser_idcontent message_typeline_message_idr)trigger_tagging) trigger_index) message_idrgrhricreated_at_isotagsuLINE message 背景索引失敗)trigger_acceptanceutrigger_acceptance 失敗) trigger_ackutrigger_ack 失敗rZr[r\r])rg sender_id)parse_bind_command)is_cancel_commandcancel_last_auto_taskr)detect_coba_mentionT)rgrhr0)trigger_task_extract))rr r3rH_TEXT_PREFIX_MAPstripr rbr.commitr&app.services.coba_taggerrlapp.services.coba_memoryrmrnowrutc isoformatrCrUrVapp.services.task_acceptancerqapp.services.coba_acknowledgerrasyncio create_task_download_mediaapp.services.line_bindingru_handle_bind_commandapp.services.task_extractorrvrw_handle_cancel_commandapp.services.coba_chatrxry_cooper_respond_to_line)rWrmsg_objmtyperkr@ reply_tokenr0r2senderrirjprefixextramsgmsg_idch_idch_line_source_idrlrmrqrrru bind_codervrwis_dmrxshould_respond _detect_dbrys rrPrPs ii "(bG KK 'Ekk$'O778$L))L)K ""b)"c2 2 : #""+2|SAA F?kk&"-G!L & &%e,FEGKK B789(..0G$)-G$G5VL)%2G!Luu!'FIIT%+   s iik--?#"D <<:!'FIIT#<< 5??A  v&VYY : G v & v 3 A    33O U#)fiit  v,@&w/     4<):K!  vX W %    6# /@+!  v GGFOv %E: %&&*#6 %+  $N'& D089  /v?PR]^_o# 2#B0 9#"""\ <:;< :   8 9 : 3   1 2 3N''&&&s`A)Q +N,Q /N+?NN+ Q NQ N+(N")BQ O& Q &P 4C&Q P0Q P7<P3=P7 Q  P5 A Q N+Q "N+%N+(Q +N>1N4 2N>9Q O#Q "O##Q &PQ PQ  P-)Q ,P--Q 3P75Q 7Q =Q >Q Q cKddlm}|y|||d{}|rDd}|rtj||d{}|stj||d{yyy7K7)7 w)u5處理「@庫柏 取消最後一個任務」指令。r)rwNF)rrwr reply_text push_text)rhr&rrwrasents rrr#sw B&w? ?D $// TBBD''= = =  @C =s1A*A$#A*A&A*A(A*&A*(A*cKddlm}m}ddlm}t 4d{} ||||d{}|j d{d|jd|jd} dddd{|rDd } |rtj | d{} | stj"| d{yyy777|#|$r} d| } Yd} ~ ld} ~ w|$r|jd{7d } Yt$rP} |jd{7tjd d t| j} Yd} ~ d} ~ wwxYw7#1d{7swYxYw77w) u跑 LINE 綁定 + 回 LINE。r) BindingError redeem_code)IntegrityErrorNuc✓ 綁定成功! 你的 LINE 現在連到「山水話菁英團隊」行程規畫系統的帳號「(u8)」。 之後我用 LINE 找你都會用這個身份。u⚠ u>⚠ 綁定遇到資料衝突,請稍後再試或聯絡管理員u綁定 redeem 失敗u⚠ 綁定失敗:F)rrrsqlalchemy.excrr r|r=r?rDrCrUrVr__name__rrr) coder@r&rrrrr0web_userraers rrr5snD- ""b :(T<@@H))+  ddldydyczz{}E}J}J|KKCD  #"& $// TBBD''= = = '#@   !:D T++-  SD :++-     3 4&tAw'7'7&89D :#""",C =sE3CE3E C CC  C !C , E37E8#E3E/E3;E1<E3C C  ECEE3C64E;E=EED2E EEEE3E, E# !E,(E31E3cK|jd}|jd}|syd}|rtj||d{ytj||d{y7$7w)u4使用者把 Cooper 加為好友 → 發歡迎詞。rrcNu嗨,我是庫柏(Cooper)——「山水話菁英團隊」的 AI 同事。 我駐紮在團隊的「行程規畫系統」裡。 把我拉進團隊的 LINE 群組,我會默默讀訊息、在 @ 我的時候回應, 也會處理會議錄音、每天 9 點推送個人簡報。 現在你可以: • 直接傳訊息給我(我會用 Sonnet 回) • 邀我進群組 • 到網頁版產生綁定碼,把 LINE 帳號連到行程規畫系統)rrrr)rWrr@rwelcomes rrQrQ\sm778$L))L)K  R $$[':::##L'::: ;:s$AA.A*A.$A,%A.,A.cVKtjd|jdyw)u9使用者封鎖 / 移除 Cooper。先不做事,只 log。zLINE unfollow: userId=%srN)rUinfor)rWrs rrRrRrs KK*CGGH,=>s')cK|jd}t4d{}t||d{}|jd{|r |jnd}dddd{d}|rt j ||d{yrt j||d{yy777m7O#1d{7swY_xYw7D7%w)uMCooper 被拉進群 / 多人聊天室 → 預先建 Channel + 自我介紹。rcNu嗨大家好,我是庫柏(Cooper),「山水話菁英團隊」的 AI 同事。 在這個群裡 @ 我或開頭叫「庫柏」我就會回應。 我會默默讀訊息建立記憶,需要時再叫我。)rr r3r|r&rrr)rWrrr0r2rintros rrSrSws))L)K ""b)"c2 2iik13B--#"  B $$[%888 ##$5u=== # 2#""" 9=s CB8CCB:CB<C# C.B>/!CC C1C2C:C<C>CCC CCCc jKt|\}}|syt4d{}|jttj tj |k(tjjdd{j}| dddd{ytjtj|_|jd{dddd{tj!d|y777p717##1d{7swY3xYww)uFCooper 被踢出群 → 軟刪 Channel(訊息保留供日後 audit)。Nu'LINE leave: source=%s 已軟刪 channel)rr r)rr r*r&r+r,r-rrrrr|rUr)rWr_r1r0r2s rrTrTs S !FAs  ""bJJ 7O ! !&&#-""&&t,      : #""! X\\2 iik#" KK93?# # #"""s D3DD3A DDD D3'D(D3-;D(D)D- D38D9D3DD3DD3D0$D' %D0,D3c Ktjs&tjstj dy|syddlm} |||d{t4d{}|jttjtjjdtj |k(tj"jdj%tj&j)j+dd{j-j/}|r |j0nd}dddd{d}|rt3j4|d{}|st3j6|d{yy7T#t$rtjdYswxYw7i77u#1d{7swYxYw7j7Lw) uLINE 路徑的 Cooper 回應 → 全程走 coba_chat.coba_respond_to_mention(含 tool use 工具) 跑完後把產出的 Cooper 訊息推回 LINE 群。 uPANTHROPIC_API_KEY 跟 CLAUDE_CODE_OAUTH_TOKEN 都沒設,LINE Cooper 回應跳過Nr)coba_respond_to_mentionuCooper 回應(LINE)失敗u(庫柏沒回應)F)r ANTHROPIC_API_KEYCLAUDE_CODE_OAUTH_TOKENrUwarningrrrCrVr r)rr r*rhr,rgr+order_by created_atdesclimitscalarsfirstrirrr) rgtriggered_msg_idr&rrr0lastrars rrrs~  & &(*J*Jij ?6%j2BCCC !""bjj 7O U7??&&t,g.@.@J.NPWPbPbPfPfgkPl m Xg((--/ 0 U1X   79UUW $t||)<#" D ++K>> ##ND999 ' D 6456 # #"""?9sAG+ F&F#F&G+"G #G+&B8GG0G G+G!G+<G'=G+G)G+#F&&GG+GG+GG+G$G G$ G+)G+c Kddl}ddlm}tj|d{}|sy|t j }|jdddddd d j|d }|||z } | j|tjd || t||d vr^|rZ|rV ddlm} ddlm} ddlm} t)4d{} d| j*j-d}| ||t/| | j0|d}| j3|| j5d{| j7|d{|j8}| j;t=t>jAt>j8|k(d{jC}|r |jDnd}dddd{| rtjF|dd{yyyyy7#t$rtjd | YywxYw7`7777b#1d{7swYrxYw7Q#t$rtjdYywxYww)u下載 LINE 上傳的 image / audio / video / file 到本機 LINE_MEDIA_DIR。 階段 8:audio/video → 自動建 Meeting + 觸發轉錄/摘要/action_item → Task pipeline。 rN)PathT)parentsexist_okz.jpgz.m4az.mp4z.binrsu!LINE 媒體下載 %s → %s (%dB)uLINE 媒體寫檔失敗 %s)r[r\)r)Meeting)trigger_meeting_processingu LINE 錄音 z %m/%d %H:%Mpending)titlerg audio_pathaudio_filename uploaded_bystatusu`📥 收到錄音了,庫柏在處理中... 約 1-3 分鐘後我會把摘要 + 任務丟回來。u&LINE audio → meeting pipeline 失敗)$ospathlibrrget_message_contentr LINE_MEDIA_DIRmkdirr write_bytesrUrlenrCrVrapp.models.meetingrapp.services.meeting_processorrr rstrftimestrr!r.r|refreshrbr)rr r*r-r&r)rkrrgrtrrdata media_dirextoutrrrr0rm meeting_id ch_line_ids rrrsJ 00A AD X,,-I OOD4O0Vff M Q QRWY_ `C )#/ /C  7#sSWyY  ""zi G ) 2 Q(**b&|x||~'>'>}'M&NO)"3x#&88 )$ q iik!!jjm##TT $&JJ7O))'** *BC%%%';EZ66$ #+*( 'z 2!++w77@z" B 5s;+"#+***. G   E F Gs#I;H AI;72H) I;5 IH5IA)IH8IH:AI-H<."I IH>'IIII;H2/I;1H22I;5I8I:I<I>III III85I;7I88I;)rdict[str, Any]returnztuple[str | None, str | None])rrrzChannel | None)r@ str | Nonerrrz User | None)rWrrNone)rWrrrrr)rh UUID | Noner&rrrrr) rrr@rr&rrrrr) rgrrrr&rrrrrr) rkrrrrgrrtrrr))__doc__ __future__rrloggingrrtypingruuidr anthropic sqlalchemyr app.configr app.databaser app.models.channelr r app.models.userr app.servicesr getLoggerrUrr3rHrYrzrPrrrQrRrSrTrrrrrs/ #'*/ $   - . D" TC.    ~`B> >>> >$!> !>!>!> !>  !>N;,? >&@0':':':': ':  ':^8Gr