Nj-lddZddlZddlZddlZddlZddlZddlZddlZddlZddl Z ddl Z ddl m Z ddl mZmZddlmZmZmZmZe ejjZejdeeddlmZmZmZddl m!Z!ddl"m#Z#m$Z$m%Z%m&Z&m'Z'dd l(m)Z)dd l*m+Z+m,Z,dd l-m.Z.m/Z/ed z d z dz edz d z d z dz ed z dz gZ0de fdZ1e1Z2e2jdz Z3dZ4de defdZ5de6fdZ7GddZ8dZ9e:dkr e9dSdS)u AutoPOE2 - Process Supervisor Engine & Shadow Binary Controller ================================================================ Điều phối sinh tử tiến trình tự hành, cách ly nhị phân chạy ngầm (Shadow Binary), triệt tiêu xung đột build LNK1104, và cung cấp Control Plane thời gian thực qua Shared Memory. Kiến trúc: 1. Shadow Binary Execution: Tự động copy AutoPOE2_Core.exe -> AutoPOE2_Core_Runtime.exe để tiến trình C++ Core chạy độc lập, giải phóng hoàn toàn file gốc cho Dev/AI build liên tục. 2. SSoT Telemetry: Đọc trực tiếp từ Local\POE2_Auto_SharedMem_v1 (Zero file I/O, Zero Hallucination). 3. Hot-Swap Engine: Tự động nhận diện bản build mới đã qua kiểm thử, chuyển giao an toàn tại Hideout. 4. Local Control Plane: Cung cấp REST/JSON endpoint (mặc định port 8088) phục vụ truy vấn & điều khiển. N)Path) HTTPServerBaseHTTPRequestHandler)OptionalDictAnyList)is_poe2_runningfind_process_by_namePOE2_PROCESS_NAMES)find_poe2_window)get_virtual_monitoris_virtual_display_activemove_window_to_virtual_displayis_window_on_virtual_displaycapture_virtual_display_jpeg)Poe2ClientLauncher) CoreShmBridgeCharacterLifecycleState)Poe2GraphicsOptimizerPROFILESbinReleasezAutoPOE2_Core.exebuildreturnc`tD]}|r|cStdS)Nr)CANDIDATE_SOURCE_BINSexists)ps -C:\Projects\AutoPOE2\tools\poe2_supervisor.pyfind_default_source_binr!4s: " 88:: HHH   ##zAutoPOE2_Core_Runtime.exeifilepathcR|sdStj}t|d5}|dx}r,|||dx},dddn #1swxYwY|S)u.Tính mã băm SHA256 của tệp nhị phân.rbiN)rhashlibsha256openreadupdate hexdigest)r#hfchunks r calculate_sha256r0?s ??  rA h  vve}}$e  HHUOOOvve}}$e  ;;==sAB  BBcH ddlm}m}ddl}|ddd}||}|dd d |}||d d | S#t$rYdSwxYw)uETạo frame JPEG standby khi game client offline hoặc chưa render.r)Image ImageDrawNRGB)ii))color)iiTz3AutoPOE2 Standby (Game Client Offline / Background)))fillJPEGFformatqualityr") PILr2r3ionewDrawtextBytesIOsavegetvalue Exception)r2r3rCimgdrawbufs r get_standby_jpeg_framerNJs (((((((( ii{,i??~~c"" *SZi jjjjjll VR000||~~ sssBB B! B!c eZdZdZeeeddfdededede de f dZ dd e d e fd Z d e fd Z d e efd Zd e fdZddee ed e fdZdded e fdZd e fdZd eeeffdZd efdZdZdZdZdZdS)Poe2Supervisoru:Bộ điều phối và giám sát tiến trình AutoPOE2.F source_bin runtime_bin http_portauto_launch_gameuse_virtual_displaycFt||_t||_||_||_||_t |_d|_d|_ d|_ d|_ d|_ d|_ tj|_d|_d|_dS)NFr%)rrQrRrSrTrUr shm_bridge runtime_proc_running_watchdog_thread _http_server _http_thread_paused threadingLock_lock_last_source_hash_game_detected_time)selfrQrRrSrTrUs r __init__zPoe2Supervisor.__init__\sz** ,," 0#6 '//8< <@268< ^%% !#48   r"forcercH|jsdSt|j}|s<|jr#t|j}||kr ||_dS|r|tdD]|} |jj ddtj |j|j||_dS#t$rtjdYmt$rYnwxYwdS)u Sao chép AutoPOE2_Core.exe sang AutoPOE2_Core_Runtime.exe. Giải phóng file gốc để trình biên dịch MSVC/CMake có thể build bất kỳ lúc nào. FT)parentsexist_okg?)rQrr0rRrais_runtime_running stop_runtimerangeparentmkdirshutilcopy2PermissionErrortimesleeprJ)rcre source_hash runtime_hashattempts r prepare_shadow_binaryz$Poe2Supervisor.prepare_shadow_binaryvsG %%'' 5&t77  )0022 +D,<==Ll**)4&t  " " $ $      Qxx  G  '--dT-JJJ T_d.>???)4&tt"    3    us(AC22D DDctS)uRKiểm tra xem client Path of Exile 2 có đang chạy thật trên OS hay không.)r rcs r is_game_runningzPoe2Supervisor.is_game_runnings   r"cg}tD]$}|t|%tt |S)u.Lấy danh sách PID thật của client POE2.)r extendr listset)rcpidsnames r get_game_pidszPoe2Supervisor.get_game_pidssF& 4 4D KK,T22 3 3 3 3CIIr"cJ|jdS|jduS)uDKiểm tra xem tiến trình Shadow Runtime có đang chạy không.NF)rXpollrys r rjz!Poe2Supervisor.is_runtime_runnings*   $5 %%''4//r"N extra_argsc>|j5|r ddddS|s ddddSt|jg}|r|| d}t jdkr tj }tj |t|jj |tj tj |_ ddddS#t$rd|_ YddddSwxYw#1swxYwYdS)uCKhởi chạy Shadow Binary AutoPOE2_Core_Runtime.exe độc lập.NTFrwin32)cwd creationflagsstdoutstderr)r`rjrwstrrRr|sysplatform subprocessCREATE_NEW_PROCESS_GROUPPopenrmDEVNULLrXrJ)rcrcmdcreation_flagss r start_runtimezPoe2Supervisor.start_runtimes Z  &&((         --//          t'(()C ' :&&& !"<7**%/%HN$.$4D,344"0%-%- %%%!/        0   $(!5        0 1          s;DD ,D:A'C//DDDDDD@ timeout_secc|j5|sd|_ ddddS|j}| ddddS |||n\#t j$r? ||dn#t$rYnwxYwYnt$rYnwxYwd|_n #d|_wxYw ddddS#1swxYwYdS)u8Dừng tiến trình Shadow Runtime một cách êm ái.NTtimeout?) r`rjrX terminatewaitrTimeoutExpiredkillrJ)rcrprocs r rkzPoe2Supervisor.stop_runtimes Z  **,, $(!         $D|         )    + ....,   IIKKKIIcI**** D    %)!!D!((((/                  s|C3 C3 *A54C5C*B0/C0 B=:C<B==CC C C CCC3 C""C33C7:C7cv|jsdSt|j}|jrt|jnd}||kr|rdS||dsdS|S)u Thực hiện hoán đổi binary nóng: 1. Kiểm tra xem có bản build mới của AutoPOE2_Core.exe không. 2. Dừng runtime hiện tại. 3. Copy shadow binary mới. 4. Khởi động lại runtime. Fr%T)re)rQrr0rRrjrkrwr)rcnew_hashcur_hashs r hot_swap_runtimezPoe2Supervisor.hot_swap_runtimes%%'' 5#DO449=9I9P9P9R9RZ#D$4555XZ x  D$;$;$=$= 4 )))55 5!!###r"c |}t|dk}|}|r|jr |jjnd}|j}t}|rtnd}|r|rt||nd}|j |j |j tjdtjd||||r d|ddndd |du|r"|jd |jd |jd |jdnd|r|j|j|j|jgnd|d ||t)|j|jt)|j|j|jrC|jr*t1|jt1|jkndd|dS)uMLấy toàn bộ trạng thái thực tế của hệ thống (Ground Truth).rNFz%Y-%m-%dT%H:%M:%SZ)activepausedrS timestamp_isoz ONLINE (PID )OFFLINE)runningrhwnd status_strxz at (z, )rmonitorrectgame_on_virtual_display)rpid source_binary source_existsruntime_binaryruntime_exists binary_synced) supervisor game_clientvirtual_displayshadow_runtime telemetry)rlenrjrXrrWget_status_dictrr rrYr]rSrrstrftimegmtimewidthheightlefttoprrQrrRr0) rc game_pids game_activeruntime_active runtime_pid shm_statusvm game_hwnd game_on_vds r get_statuszPoe2Supervisor.get_statussZ&&(( )nnq( 0022/=]$BS]d'++Y] _4466 " "*5<$&&&1 EGaIa1)R@@@\a -,!^!%/CT[]]!S!S '!!@KZ>$+5   *"!$T_!5!5!%!7!7!9!9"%d&6"7"7"&"2"9"9";";lpl{mCmCmEmE"nJNJZJaJaJcJc"n!1$/!B!BFVW[WgFhFh!h!hin$9   r"cdS)uJTạo giao diện HTML Picture-in-Picture Mini Streamer cho Headless Mode.a AutoPOE2 - Live Background Headless Stream

AutoPOE2 Virtual Screen (Headless Background Stream)

Stream: Active
Background Game Stream
Mode: Headless IPC | Status: Connecting...
rys r get_pip_htmlzPoe2Supervisor.get_pip_html!s ? ? r"c |jr` |}|r |jtj|_nd|_|jr|st j|jr|r|jrtj|jz nd}|dkrt}|rtj dkrtj j nd}|r||nd}|sht}|rXt!||sHt#d|dd|d |jd d t'||d d }t#d|d |rr|jsk|sW|jrtj|jz nd}|dkr-t#d|ddd |dg|jrFt3|j}|r0||jkr%t#dd |n+#t8$r} t#d| d Yd} ~ nd} ~ wwxYwtjd|j^dSdS)u'Vòng lặp giám sát sinh tử nền.Ngg4@rFu([Supervisor Watchdog] Game ổn định z.1fus -> Dời cửa sổ HWND  sang ...T)flush borderless keep_sizeu4[Supervisor Watchdog] Kết quả dời cửa sổ: g6@u/s -> Khởi chạy AutoPOE2_Core_Runtime.exe...z --user-mode)ruT[Supervisor Watchdog] Phát hiện binary mới -> Thực hiện Hot Swap Runtime...z[Supervisor Watchdog Error] g@)rYrzrbrrrTr launch_clientrUr rrctypeswindlluser32IsHungAppWindowrrprintdevicerr]rjrrQrr0rarrJrs) rc game_runninguptimerris_hungrokcurrent_source_hashes r _watchdog_loopzPoe2Supervisor._watchdog_loopdsvm/ , F#3355 4/7379;;0/3D,(77&4666+ s sGKG_hTY[[4+CCCehF~~$4$6$6 $s=@\W=T=TV]%9%9Z^FKQ&\f&<&.SupervisorHandlercdSNr)rcr@argss r log_messagezHPoe2Supervisor._start_http_server..SupervisorHandler.log_messagesr" status_codedatactj|dd}|||dd|dt t ||dd||j |dS) Nindentutf-8 Content-Typezapplication/json; charset=utf-8Content-LengthAccess-Control-Allow-Origin*) jsondumpsencode send_response send_headerrr end_headerswfilewrite)rcrrbodys r _send_jsonzGPoe2Supervisor._start_http_server..SupervisorHandler._send_jsonsz$q11188AA"";///  1RSSS  !13s4yy>>BBB  !>DDD  """   &&&&&r"cp|jdvr, }|d|dS|jdvr }|d}|d|dd|dtt|| |j |dS|j drd}t}|rm d d lm}d dl}||d }|r@|} || d d| }n#t($rd}YnwxYw|s+ jr$ t-d}n#t($rd}YnwxYw|st/}|r|d|dd|dtt||dd|dd| |j |dS|dddidS|dddidS)N)z/status/)z/previewz/piprrztext/html; charset=utf-8rz /preview.jpgr)capture_window_bitbltT) client_onlyr=r>r?)rAz image/jpegz Cache-Controlz#no-cache, no-store, must-revalidaterrierrorzGame screen capture unavailablez Not Found)pathrr rrrrrrrr r  startswithr src.common.screen_capturerrCrGrHrIrJrUrrN) rcstatushtmlr  jpeg_datarrrCrKrMsupervisor_refs r do_GETzCPoe2Supervisor._start_http_server..SupervisorHandler.do_GETs9 000+6688FOOC00000Y"666)6688D;;w//D&&s+++$$^5OPPP$$%5s3t99~~FFF$$&&&J$$T*****Y)).99&A $I 0 2 2I - -WWWWWW%III"7"7 t"T"T"TC";&(jjll #VR H H H,/LLNN (---(,III-%-)K--(DR(P(P(PII(---(,III-%=$:$<$<  [**3///((FFF(()93s9~~;N;NOOO((:_```(()FLLL((*** ((33333g7X-YZZZZZOOC';)?@@@@@s%"AE<< F  F F)) F87F8cT|jdkr6d_|dddddS|jdkr6d_|dddddS|jdkr/}|d|dddS|jd krG|dddd t jj  dS|d d didS)Nz/pauseTr)successrz/resumeF/swap)rswapped/stop)rstopping)rrrzEndpoint not found) rr]rkr rrr^rrr)rcrrs r do_POSTzDPoe2Supervisor._start_http_server..SupervisorHandler.do_POSTsG9((-1N*"//111OOCTT)J)JKKKKKY)++-2N*"00222OOCTU)K)KLLLLLY')),==??GOOCW)N)NOOOOOY'))OOCTt)L)LMMM$N,?@@@FFHHHHHOOC'3G)HIIIIIr"N) __name__ __module__ __qualname__rintrrrr rr")rsr SupervisorHandlerrs    'c 'c3h ' ' ' '2 A2 A2 A2 A2 Ah J J J J J J Jr"r'z 127.0.0.1TPoe2SupervisorHttpru8[Supervisor] Không thể mở HTTP server tại cổng z: file) rrrSr[r^r serve_foreverr\rrJrrr)rcr'rrs @r rz!Poe2Supervisor._start_http_serversQ JQ JQ JQ JQ JQ JQ J 6Q JQ JQ Jf u *K+HJ[ \ \D  ) 08I8W`dk!A!A!AD    # # % % % % % u u u bT^bb_`bbilis t t t t t t t t t t usAA77 B2&B--B2)Fr)r)r#r$r%__doc__DEFAULT_SOURCE_BINDEFAULT_RUNTIME_BINDEFAULT_HTTP_PORTrr&boolrdrwrzr rrjrrrfloatrkrrrrrrrrrrr"r rPrPYsDD./*!&$) 9999 9  9 " 999944D@!!!!!tCy0D0000 c(;t<6$$$$$$,) DcN) ) ) ) VA cA A A A F111f " " " % % %[u[u[u[u[ur"rPc tjd}|ddd|ddd|d dd |d dd |d ttdtd|ddd|dddd|ddd|dt t tjdgzdd| }|j dkr td|j dtj |j }tdt|d n5#t$r(}td!|t j"Yd}~nd}~wwxYw|j}t'|j|j|#}|jrt/}|s/td$t j"t!jd%t3}|s/td&t j"t!jd%t5||dd'(}td)|d*|jd+|jd,|jd-|jd.|jd/|rd0nd1t!j|rd2nd%|j rK|!} ttEj#| d34t!jd2|j$rd2dl%} | j&'d5|jd6d7d8d9i:} | j&(| d;<5} t| )*d=dddn #1swxYwYnI#t$r<}td>|t j"t!jd%Yd}~nd}~wwxYwt!jd2|j+rd2dl%} | j&'d5|jd?d7d8d9i:} | j&(| d;<5} t| )*d=dddn #1swxYwYnI#t$r<}td@|t j"t!jd%Yd}~nd}~wwxYwt!jd2|j,rtdA|jdB|, t[j.dC#t^$r5tdD|+tdEYnwxYwt!jd2|!} ttEj#| d34dS)FNz6AutoPOE2 Process Supervisor & Shadow Binary Controller) descriptionz--probe store_trueuFKiểm tra trạng thái hiện trường (Single-shot) và in ra JSON)actionhelpz--startuKhởi chạy Supervisor Daemonz--stopu*Gửi lệnh tắt Supervisor đang chạyz--swapu-Gửi lệnh hoán đổi Shadow Binary mớiz--portu*Cổng HTTP Control Plane (mặc định: r)typedefaultr6z --auto-launchu9Tự động mở PathOfExile.exe nếu game chưa chạyz--virtual-displayFuiKích hoạt tính năng cách ly sang màn hình ảo phụ (mặc định: False - dùng Headless Mode))r5r8r6z--move-game-to-vdu?Dời ngay cửa sổ game Path of Exile 2 sang màn hình ảoz--optimize-graphicsnoneuZTối ưu đồ họa game trước khi vận hành (ultra_low, low_1080p, balanced_1080p))r7choicesr8r6uD[Supervisor] Đang tối ưu cấu hình đồ họa với profile 'z'...u1[Supervisor] Tối ưu đồ họa thành công (u thông số đã cập nhật).u=[Supervisor Cảnh báo] Không thể tối ưu đồ họa: r))rSrTrUuS[Supervisor Error] Không tìm thấy cửa sổ game Path of Exile 2 đang chạy.uH[Supervisor Error] Không tìm thấy màn hình ảo phụ (Monitor 2).Tru([Supervisor] Dời cửa sổ game HWND rz (ru tại ,z): u THÀNH CÔNGu THẤT BÀIrrrzhttp://127.0.0.1:rs{}rzapplication/json)rheadersrru!Lỗi gửi lệnh hoán đổi: r uLỗi gửi lệnh dừng: uG[Supervisor] Khởi động AutoPOE2 Supervisor tại http://127.0.0.1:rru+ [Supervisor] Đang dừng tiến trình...u"[Supervisor] Đã dừng an toàn.)0argparseArgumentParser add_argumentr&r/rr}rkeys parse_argsoptimize_graphicsrr apply_profilerrJrrrrPport auto_launchmove_game_to_vdr exitrrrrrrrproberrrswapurllib.requestrequestRequesturlopenr*decoderrrrrsKeyboardInterrupt) parserrchangesruse_vdrrrrrurllibreqresps r mainrXs  $1i j j jF  ,>FGGG  ,=^___  O OOOO P 2PP?AS5S8 SSS S S T2TT!U77ris    ::::::::,,,,,,,,,,,,h''))0733~&&'''^^^^^^^^^^444444BAAAAAUUUUUUUUQQQQQQQQUY&)<<Wu$y03FFU00 $$$$$ -,..(/2MMt     uuuuuuuuuuuuuuuuv R(R(R(j zDFFFFFr"