OjdZddlmZddlZddlZddlZddlmZddlm Z m Z m Z m Z ddl mZddlmZddlmZgd Zej(eZdd Z dd Z dd Zej4d Z ddZ ddZ ddZ ddZ ddZ ddZ!y)uScene image pipeline checkpoint loaders — module-level stateless helpers. W5 F22 Phase B.11 (2026-04-22): scene_image_service.generate_images()의 checkpoint 로딩 블록(shot_staging / shot_dependency)을 이관. 모든 loader는 stateless 순수 함수로, 체크포인트 JSON을 파싱하여 generate_images 파이프라인이 쓰는 key-to-data map 형태로 정규화한다. 파일이 없거나 파싱에 실패하면 빈 dict를 반환한다 (failure non-fatal). ) annotationsNPath)AnyDictListOptional)AppError)validate_keep_elements)_normalize_evidence_fields)load_shot_staging_mapload_shot_dependency_mapload_shot_t2i_variationsload_background_chain_bg_mapload_space_set_bg_mapload_outdoor_direct_contextc<t||z dz dz |z |z dz S)N checkpointsepisodesz manifest.jsonr) projects_dir project_id episode_id step_names [/Users/manta/Documents/Projects/TheRoad-I1/backend/app/services/scene_checkpoint_loaders.py_ep_checkpoint_pathr$s< \Z'  $ %'1 2  % &ci}t|||d}|js|S tj|j d}|j d|j dgD],}|j dd|j d}|||<. |S#t $r!}tjd |Yd }~|Sd }~wwxYw) zLoad shot_staging checkpoint and index by 'scene_index_shot_index' key. Used to resolve character/gaze/camera metadata per shot. Returns empty dict on missing file or parse failure (non-fatal). shot_stagingutf-8encodingdatashots scene_index_ shot_indexu>shot_staging checkpoint load failed: %s — staging_map 비움N rexistsjsonloads read_textget Exceptionloggerwarning) rrr staging_mapcp_pathrawstkeyexcs rr r ,s.0K!, JWG >> ^jj**G*<=''&#&**7B7BVVM*+1RVVL-A,BCC!K 8  ^WY\]] ^sA6B C&CCc i}t|||d}t|||d}|jr|n|}|js|S tj|j d}|j d|j dgD]}|j dd|j d } |j d gd d D]} d | vr"||urt jd| i| d gi} d | vr!tdd|jd| d| d| d } t| d|jd| ddd| j dd| j d| j dd| | j d| j d ||ud|| < |S#t$rt$r!} t jd| Yd } ~ |Sd } ~ wwxYw)uLoad shot_dependency_t2i (preferred) or shot_dependency checkpoint. Returns {'scene_index_shot_index': {ref_usage, ignore_elements, keep_elements: list[{label, kind}]}} using the first location_ref per shot. ignore_elements falls back to legacy 'removal_instruction' key. Empty dict on JSON parse failure (warning log). Area D-next-min — keep_elements entry validation (L2 intermediate fail-fast): - entry must be dict with required keys 'label' and 'kind'. - kind must be in KEEP_ELEMENT_KINDS (environment / static_prop only — person/character 묘사 금지, character state 는 별도 layer 책임). - legacy List[str] cp (v5) → AppError fail-fast (운영자 force 의무). - legacy v6 cp (kind=immobilized_character) → AppError fail-fast (운영자 force 의무 — Area D-next-min 에서 enum 폐기). - broad except 가 shape validation AppError 를 absorb 안 함 (`except AppError: raise` 분기, silent fallback 0). shot_dependency_t2ishot_dependencyrr r" dependenciesr$r%r& location_refsN keep_elementsuqshot_dependency base cp dep[%s]: keep_elements 없음 — t2i 주석 전 기본 CP 라 빈 목록으로 읽는다z9step.scene_checkpoint_loaders.keep_elements_entry_invalidzshot_dependency cp z: dep[uO] location_ref missing 'keep_elements' key — schema v7 required field. value=i)codemessage status_code]z6step.scene_checkpoint_loaders.keep_elements_legacy_str) label_sourceerror_code_entryerror_code_legacy_str ref_usageignore_elementsremoval_instruction)rDrFr<dep_scene_indexdep_shot_index t2i_annotatedz.Failed to parse shot_dependency checkpoint: %s) rr(r)r*r+r,r.infor namer r-r/) rrrdep_mapt2i_path base_pathsourcer2depr4refraw_keepr5s rrrBs(*,G"<ZI^_H#L*jJ[\I!*X F ==?<Njj))7);<7763'++NB?CWW]+,Acggl.C-DECww3BQ7##-&I2EKKCDGI7S6/26C"#-"X1&++fSEJ88;w@%(/&#6v{{m6#a!P%`*b "%b!9'*ww/@#''J_acBd'e%-(+ww}'=&)ggl&;&,x%7!  A8@v N   NGMM NNsEF""G4GGz^S(\d+)_Shot(\d+)$c ,d}|xsijdxsi}t|ts|S|jD]#\}}t|ts|jddk7r-|jdxsd}|sEt |}|j sa|jdd} |jdxsg} t| t s |j} | D]u} tjt| }|s$t|jd d t|jd }||vr`| d|d| d|| d||<|d z }w&|S#t$r#} tjd ||| Yd } ~ Pd } ~ wwxYw)uPhase 7 / Phase 5 공통 shape: data.groups[bg_id].{status, png_path, shot_ids, location_id}. 각 'ok' 그룹의 shot_ids("Sxx_Shotyy")를 'xx_yy' key로 펼침. 첫 매칭 보존. Returns 추가된 매핑 수. rgroupsstatusokpng_pathrE location_idshot_idsu/%s: %s vanished after exists check — skip: %sNr;r%background chain ref ( for ') — match wall/floor/ceiling/lighting image_byteslabelbg_idrY)r, isinstancedictitemsrr(list read_bytesOSErrorr.r/ _SHOT_ID_REmatchstrintgroup)bg_mapr" source_labeladdedrUrbgresrXploc_idrZr`io_excsidmr4s r_ingest_phase7_groups_shaperws Ejb  h ' -2F fd # ||~ t$%  88H  % 88J'-2  Nxxz -,88J'-2(D)  ,,.K C!!#c(+A_%Qs1771:&78Cf}*,UG5A89 % F3K QJE%/&T L1  NNAt|}|j sZ|d|}||vrf |j!}|jdd}|d|d| d|| d||< t%|||}|r0|j'|tjdt)|t+|||}|rg}g}|jD]b\}}|j|}||jddk(r.|dk(r||j-|G||j-|dd|d ||<d|s|r=tjd!t)|t/|t)|t/||S#t$r!}tjd|Yd }~d }~wwxYw#t"$r"}tjd||Yd }~d }~wwxYw#t$r!}tjd|Yd }~d }~wwxYw)"u)Load background_render(Phase 7) / background_chain_render(Phase 5/4) checkpoint and map shot → background image_bytes. on_demand step이라 체크포인트가 없을 수 있다. 이 경우 빈 dict 반환 (set_design 시절과 동일한 optional fallback 패턴). P0-2 (2026-04-29): settings.background_chain_enabled=False면 체크포인트가 있어도 무조건 빈 dict 반환. 토글 off 시 stale 체크포인트가 inject되어 회귀를 일으키는 것을 차단 (Codex H1). 지원 shape: - Phase 7: background_render — data.groups[bg_id].{status, png_path, shot_ids[], ...} - Phase 5: background_chain_render — 동일 shape - Phase 4 LEGACY: background_chain_render — data.locations[loc_id].shot_backgrounds[] Phase 7 우선, Phase 5/4 fallback. _ingest_phase7_groups_shape는 중복 key 첫 번째 보존이라 자연스럽게 Phase 7 우선이 된다. Returns {'scene_index_shot_index': {image_bytes, label}}. Failed nodes / missing PNGs / 잘못된 shot_id 형식은 skip. rsettingsbackground_renderrr r"z5background_render: loaded %d shot background mappingsuHbackground_render checkpoint load failed: %s — Phase 5 fallback 시도Nbackground_chain_renderzEbackground_chain_render (Phase 5): loaded %d shot background mappings locationsshot_backgroundsr$r& image_pathrEr%uDbackground_chain_render: %s vanished after exists check — skip: %snode_idr\r]r^r_uQbackground_chain_render checkpoint load failed: %s — bg_map 일부만 채워짐uGspace_set_bg: %d shot background mappings overlaid (space plate 우선)rP space_set_bg unassignedspace_set_bg_no_plateT)rPsuppress_background_requiredreasonzjspace_set_bg diagnostics: %d legacy chain bg suppressed %s / %d kept (unassigned + legacy env-identity) %s)app.core.configrzbackground_chain_enabledrr(r)r*r+r,rwr.rKr-r/rerrgrhrupdatelenload_space_set_bg_no_plate_keysappendsorted)rrrrnrz cp_p7_pathdata_p7nr5 cp_p5_pathdata_p5n_p5r}rsloc_datasbsishiimg_pathrrr4r`rtr space_map no_plate_keys suppressed kept_legacykrexistings rrrs0)+F(  , , %j*.AJ jj!5!5w!5!GHLLVUWXG+FG=PQA SUVW%j*.GJ. jj!5!5w!5!GHLLVUWXG.vw@YZD []a K4:I$-OO$5 ",,'92>D"DB .B&&.C!vvlB7HzS[ XA88: D#-Cf} !&'lln !ffY3G'24WIU6(K@A ")'- #F3K+E%6T&lJ KI i  U  N 4L*jYM  &,,.IAvzz!}H# X(>.(P%(*>""1%#!!!$ 204 F1I/$  KK@J !3K &"5   Mi  NNZ\_   F#!bv! !$  NNceh   s[AK50DM3L"'M5 L>LL" M +MMM  M M:M55M:ci}ddlm}tt|dds|St |||d}|j s|S t j|jdjdixsi}|jd xsijD]\}}t|ts|jd xsgD]p} t| ts| jd d vr(| jd | jd} } | | Ot| jd || d| <r |S#t$r"} tj!d| icYd} ~ Sd} ~ wwxYw)ugspace_set_bg shot_assign_diagnostics 에서 'plate 없음/불확실' 판정 shot 맵. W1 (2026-06-11): reason ∈ {unassigned, connector_no_plate, plate_action_no_plate} 인 shot 의 `{scene}_{shot}` → reason 맵. plate_action_no_plate (Phase 3) = 배정 LLM 의 명시적 'plate 참조 부적합' 정책 판정 — connector 와 같은 suppression 계열 (Codex 리뷰 BLOCKING 1: 빠지면 legacy chain bg 가 도로 붙어 W1-B 억제 정책과 충돌). 소비처는 load_background_chain_bg_map — 이 key 들의 legacy chain bg fallback 을 sentinel 로 대체 (space policy 우선) 하고, sentinel 이 required background waiver 신호를 coordinator 에 전달 (Codex 합의: validator 는 pure checker 유지, explicit signal 만). flag OFF / checkpoint 부재 / 진단 부재 시 빈 dict (기존 동작 보존). rryspace_set_bg_enabledFrrr r"rUshot_assign_diagnosticsr)rconnector_no_plateplate_action_no_platesceneshotNr%u>space_set_bg no-plate diagnostics load failed: %s — 빈 dict)rrzboolgetattrrr(r)r*r+r,rercrdrkr-r.r/) rrrkeysrzr1r"_gidrqdiagscshr5s rrrwsd D( "8%@ A !, JWG >>  zz'++W+=>BB62NTRT88H-3:::` — 실 catalog bg_id 를 가장하지 않는다 (provenance/freshness 계약 오염 방지, Codex C 반려 사유). - status!="ok" 그룹 / 누락 PNG 는 skip (해당 shot 은 기존 경로 유지). Returns {'scene_index_shot_index': {image_bytes, label, bg_id, source, group_id, space}}. rryrFrrr r"rUrVrW assets_dirrEshot_plate_map plate_pngu9space_set_bg: %s vanished after exists check — skip: %sNspacezspace set background ref (z, u$) — match layout/material/lightingz space_set_bg:: plate_key)r`rarbrPgroup_idru<space_set_bg checkpoint load failed: %s — space map 비움)rrzrrrr(r)r*r+r,rercrdrrgrhr.r/r-)rrrrrzr1r"gidrqrr4entrypng_namerrr`rtrr5s rrrs$,.I( "8%@ A!, JWG >> $\zz'++W+=>BB62NTRT((8,299;ICdD)TXXh-?4-G,/52J#xx(89?RFFH U!%. 99[17Rz$x/xxz"#,,.K '2.#.4UG2cUC9: -SE599["3M2NO, #" " #%I >  jj!2!2G!2!DEII&RTU *{Iooh+ 66- I -   !bff]&;&Gvvm$ 2FF#3R8 $C.#F%! /4I *B! %,& I1 A3G s#5E E2E-'E2-E2c4 i}ddlm}t|dds|Sd/fd }|djdixsi}|djdixsi}|d jdixsi}|r|r|s|S|d } i} i} | jd gxsgD]} | jd } | | jdxsd| t | <| jdgxsgD]c}|jd}||jdxsd|jdxsgDcgc]}|st |c}d| | d|<eddlm}m}m }d} ||}d}|jD]\}}t|trd|vr|j|xsijdxsi}|j|xsi}|r|jddk7rp t!|jdxsdj#}t!|jdxsdj#}|jdgxsgDcgc]%}|jd r|jd d'}}|jdxsijD]\} }!t|!tr|!jddk7r,|!jd!xsi}"|"jd"r|"jd#stjd$| z| j| xsi}#|#jdstjd%|  t | j'dd} ||||"|| j| d|#d|#jdxsg|"jd&xsd|"jd"xsd|"jd#xsd|"jd'xsdd(|d|d) }$|$||||jd+xsd|jd,xsd|d-|| <|rtj-d.t/||Scc}w#t$r"}tjd||cYd }~Sd }~wwxYw#t$$r"}tjd||Yd }~Kd }~wwxYwcc}w#t(t*f$rY:wxYw#t$r"}tjd*| |Yd }~dd }~wwxYw)0utW22 야외 직행 합성 컨텍스트 — shot 별 캐논 refs + 9절 프롬프트. Returns {"_": { "prompt": , "master_bytes": bytes, "map_bytes": bytes, "master_asset_id": str, "map_asset_id": str, "place_id": , }} flag OFF / cp 부재 / 그룹·샷 결측 / 조립 실패 = 해당 키 없음 → 소비자는 기존 5a~5e 경로로 자연 fallback. flag OFF 면 무조건 빈 dict — load_background_chain_bg_map 의 stale 차단 패턴과 동일. rryoutdoor_direct_compose_enabledFct|}|jr: tj|j dj dixsiSiS#t $r"}tjd||Yd}~iSd}~wwxYw)Nrr r"u$outdoor_direct: %s 로드 실패: %sr')step_idrrr5rrrs r _load_dataz/load_outdoor_direct_context.._load_data?s  j*g N 88: Uzz!++w+"?@DDVRPVTVV  UEwPSTT  Us8A B%BBoutdoor_place_specrUoutdoor_place_canonoutdoor_shot_groundingshot_validatorrr$N scene_headingrEr#r& description characters)rrr%)build_direct_promptbuild_place_desc load_blocks3uGoutdoor_direct: 프롬프트 팩 로드 실패 — 직행 비활성: %sspecrVrWmaster_png_path map_png_pathu8outdoor_direct: group=%s 캐논 read 실패 — skip: %srer=groundcamera_position_enlook_direction_enugoutdoor_direct: %s grounded camera 필드 결손 — direct 제외(fail-closed, 기존 경로 fallback)u-outdoor_direct: %s 샷 원문 없음 — skipmoment_context_en in_frame_en)rrr) place_descrshot_descriptioncharacter_namesrcamera_guidanceworld_facts_block style_context spec_codesinclude_ref_noteu:outdoor_direct: %s 프롬프트 조립 실패 — skip: %smaster_asset_id map_asset_id)promptprompt_version master_bytes map_bytesrrplace_idu.outdoor_direct: %d shots direct-compose 활성)rrkreturnDict[str, Any])rrzrr,rlrk+app.modules.pipeline.outdoor_direct_composerrrr-r.r/rercrdrrgrhsplit ValueError IndexErrorrKr)%rrroutrzr spec_groups canon_groups ground_groups validatorheading_by_scene shot_inforrrrcrrrDIRECT_PROMPT_VERSIONblocksr5 world_factsrg_entryrcanonrritcodesr4sh_entryrrKrs%``` rrr)s, &(C( 8=u E 1266xDJK34882FL"L78<)D")D )D2vvf~ FF62 )D  &kk'28b??AMCh-h1G41O\\(+1rFJJ34 #67BCF==%+D88M*CS 3*+ ,/="2"6"6r2">%)-%8$(HH\$:$@b&,jj1D&E&K#JJ';<B"JJ':;Ar'-zz-'@'FB %'2"$$%*)8!"7 ,&#(99->#?#E2 % . 9 ?RCHkB'.d  Dc#hO JY `bef (  NNJCQT      6 +  2 PRUWZ  st1Q0 9 Q0 $Q5/AR#*S&SBS,5 R >RR R # S,S  SS)(S), T5TT) rrkrrkrrkrrkrr)rrkrrkrrkrDict[str, Dict[str, Any]])rnrr"rrorkrrl)rrkrrkrrkrzDict[str, str])rrkrrkrrkrz Optional[str]r$ Optional[int]rrr&rrzList[Dict[str, Any]])"__doc__ __future__rr)loggingrepathlibrtypingrrrr app.core.errorsr app.core.keep_elementsr app.core.steps._evidence_helpersr __all__ getLogger__name__r.rr rcompilerirwrrrrrrrrs#  ,,$H    8 $#&47,WW#&W47WWtbjj./ 6 %6-;6KN66r\\#&\47\\~,,#&,47,,^@@#&@47@@F====  =  ====@``#&`47``r