%>$// *  T__d.>.>?  ''HVD H 2sW5 3 B .3IIdBU1EHHJHHRYY[)KKEMM2 3 JJx 1  KKEMM2 3 3   (#      ss+*F0G %G.A F:$G(G  FF&F==GG G G<G,+G<, G85G<7G88G<cd}|jdg|jdgz}|D]<}|jdd}|jds' t|dd}||kDr|}>d|d zd S#t$rYSwxYw) uKqueue + processed 전체에서 최대 시퀀스 번호를 찾아 +1 반환.rrridzevt-N03d)get startswithint ValueError)r r2max_seq all_eventsevteidseqs r_next_event_idzEventQueue._next_event_idgsXXgr*TXXk2-FF  C''$#C~~f%c!"g,CW}"%  gk#&''"sA22 A>=A> event_typetask_idteam_id report_pathc tjtjj|jd|jdz}t |dd5}t j|t j |j}|j|}|||||dtjtjjdd } |d j!| |j#|t j|t j$ d d d | S#t j|t j$wxYw#1swY SxYw) uJ이벤트를 큐에 추가하고 추가된 이벤트 dict를 반환한다.Tr.lockr9r r!pending%Y-%m-%dT%H:%M:%S+00:00)rPtyper`teamreportstatus created_atrN)rrrrrr#r$r%rCr5r^rnowrutcstrftimeappendrr*) r r_r`rarb lock_pathlock_fr2event_idevents renqueuezEventQueue.enqueuezs BGGOODOO4tDOOg- )S7 3 3v KK . 3(..t4"&&#)'"*,,x||"<"E"E1# W $$U+  & FEMM2' 3*  FEMM2' 3* s%%EBD1$E1&EEE$ch|j}|dD]}|jddk(s|cSy)uGpending 상태인 첫 번째 이벤트를 반환한다. 없으면 None.rrjreN)r5rU)r r2r[s rpeekzEventQueue.peeks< = Cwwx I-  rrrc|jdz}t|dd5}tj|tj |j }d}g}|dD]*}|j d|k(r|}|j|,|. tj|tjdddyd|d <tjtjjd |d <||d<|dj||j|tj|tj ddd|S#tj|tjwxYw#1swYSxYw) uIevent_id 이벤트를 queue에서 제거하고 processed로 이동한다.rdr9r r!NrrPrrjrf processed_at)rr#r$r%rCr5rUror*rrlrrmrnr)r rrrprqr2target new_queuer[s rdequeuezEventQueue.dequeuesLOOg- )S7 3 3v KK . 3( =.Cwwt}0!$!((- . > FEMM2/ 3 3$/x )1hll)C)L)L-*~&!*W [!((0  & FEMM2/ 32  FEMM2/ 32 s1%E6AE  $E6:A$E $E6 &E33E66Finclude_processedcJ|j}|r |d|ddSd|diS)u!이벤트 목록을 반환한다.rrr)r5)r r|r2s r list_eventszEventQueue.list_eventss;  g!+. g''rcL|j}td|dDS)u&pending 이벤트 수를 반환한다.c3JK|]}|jddk(sdyw)rjrerSN)rU).0r[s r z#EventQueue.count..s% #''(*;y*HA s##r)r5sum)r r2s rcountzEventQueue.counts,  g   r)N)F)__name__ __module__ __qualname__strrr dictr5rr^rtrrvr{boolr~rWrrrrrs"3"= D>B (4 (C (&!!! !  !  !Fhtn<(T(d( s rrrctjdd}|jdd}|jdd }|j d d d d |j dd d|j dd d|j dd d|j ddd|jdd }|j dd|jdd }|j dd |j dd|jd d! }|j }|j d"d#d d$%|j d&d'd#d()|j dd|jd*d+ }|j dd|S),Nzevent-queue.pyzFIFO Event Queue Manager)prog descriptioncommandCOMMAND)destmetavarrtu 이벤트를 큐에 추가한다)helpz--typer_Tu%이벤트 타입 (예: task_complete))rrequiredrz --task-idu태스크 ID (예: task-42))rrz--teamu팀 ID (예: dev1-team)z--reportu리포트 파일 경로z --queue-fileu+큐 파일 경로 (기본값 사용 가능))defaultrrvu;다음 처리할 이벤트를 조회한다 (제거 안 함))rr{u&이벤트를 processed로 이동한다rru이벤트 ID (예: evt-001)listu큐 상태를 조회한다z --pending store_trueu pending 이벤트만 (기본값))actionrrz--allrZuqueue + processed 모두)rrrru%pending 이벤트 수를 출력한다)argparseArgumentParseradd_subparsers add_parser add_argumentadd_mutually_exclusive_group)parser subparsersp_enqp_peekp_deqp_listgroupp_cnts r build_parserrs  $ $ .F&&Iy&IJ  ! !)2T ! UE xlTHop {T8UV x$5NO zD7PQ ~t:gh " "60m " nF 5  ! !)2Z ! [E z(EF ~t4 " "60L " MF  / / 1E {<Lno w\,Mgh 5  ! !'0W ! XE ~t4 Mrct}|j}|j%|jt j dt |dd}t|}|jdk(r_|j|j|j|j|j}ttj|ddy|jd k(rX|j!}|$ttjd d iddyttj|ddy|jd k(r|j#|j$}|Fttjd d|j$iddt j dyttj|ddy|jdk(rAt |dd}|j'|}ttj|ddy|jdk(rt|j)y|jt j dy)Nrr)rrt)r_r`rarbFr:r;rvrjemptyr{erroru&이벤트를 찾을 수 없습니다: rSrrZ)r|r)r parse_argsr print_helpsysexitgetattrrrtr_r`rhriprintr(dumpsrvr{rrr~r)rargsreqresultr|s rmainrs ^F    D ||  |T2J z *B ||y LLII   djjeA>?   > $**h0uQO P $**V%B C  "DMM* >   Ft}}oVW!&  HHQK $**V%B C  #D,>2CD djjeA>?   bhhj   r__main__)__doc__rr$r(rr>rr@rrtypingrr rrrrrrrrrsg 'I{ { D#h--#L3l zFr