\j$UdZddlmZddlZddlZddlmZmZmZm Z m Z m Z m Z ddl mZejeZdZded<d Zded <d Zded <d ZdZdZdZdZdZdZdZdZdZdZ dZ!e"ddhZ#e e$e$fZ%dd d=dZ&ddd d>dZ'dd  d?d!Z(ddd" d@d#Z) dAd$Z*ddd% dBd&Z+ dCd'Z,d(Z-ded)<e-d* dDd+Z.dEd,Z/dFd-Z0 dGd.Z1dd/ dHd0Z2 dId1Z3d2d3 dJd4Z4ejjd5Z6dKd6Z7dLd7Z8ejjd8Z9dKd9Z: dMd:Z;ddd; dNd<Zz!detect_d_seeds..s, ##)C)G)GSU)S"SAs!,,c3RK|]}j|tvsd ywrPr2_CLOSE_FRAMING_SCALES)rQrRrKs rHrTz!detect_d_seeds..s( #/"5"5c":>S"SAs'' ) prop_short_id member_shotsscorec|d |dfS)Nr\rZss rHz detect_d_seeds..sqzk1_+=>rJrR) itemssortedr1r2r8 setdefaultr5lensumlistsort) ve_by_shotr:prop_short_idsrKrLr[siselectedshirRpresentr;shotsrequired_count close_countrSs `` @rHdetect_d_seedsrss&&+O!;!Ar-/L$**, H(#Cs)C #G!~~c2.4"4.(KK$5255c35A.(KK$B''R077<$-#%El#|C() u:>          278%3T#Y%8#b(;?:SZG  $  JJ>J? L 9s<F character) entity_typecB i d fd d fd }|xsgD]}t|tst|jdxsd|k7r6t|jdxsdj }t|jdxsdj }|r|r||k(r|||i} D]1}|j  |t j|3i}|jD]} | D]}t | ||<|S) uentity_relation 체크포인트 relations → short_id identity-family 맵 (union-find). 변형 EntityCanon(예: 같은 인물의 환영/시신 외형)은 base 와 동일 인물이라는 데이터 계약(base_short_id ↔ variant_short_id)을 short-id 공간의 등가집합으로 노출한다. VE/staging 이 서로 다른 variant 표기를 쓸 때 exact-ID 게이트가 같은 인물을 놓치는 것을 막는 SOT (2026-07-02, S12 시신 seed 전멸 수정). - ``entity_type`` 정확 일치(enum 비교) 항목만 결합 — prop/location 미적용. - 반환: 모든 family 멤버 sid → 그 family 의 전체 sid set(자기 포함). 관계가 없거나 입력이 비면 빈 dict (게이트는 기존 exact 동작으로 환원). cJ||k7r||<|}||k7r|SNr^)xparents rH_findz+build_identity_family_by_sid.._finds=Qi1nvay)F1Iq AQi1nrJcj||j||||}}||k7r||<yyrx)re)abrarbr{rzs rH_unionz,build_identity_family_by_sid.._unionsI!Q!Qq58B 8F2J rJru base_short_idvariant_short_id)rystrreturnr)r}rr~rrNone) r3dictrr2striprer1r8values) relationsrurrbasevariantrootsrSoutmembersr{rzs @@rHbuild_identity_family_by_sidrs  F _"_!T"  quu]#)r *k 9 155)/R0668aee./526<<>7dgo tW"$E sSU+//4!C<<>C7|CH" JrJ)rKidentity_family_by_sidc  xsii}g}|jD]\}t|D]} | f} |j| } | st|j| gxsg} | jdxsgD]V} | jd}t |xsds%| jddxsd}|j|xs t}t |dk7r&|j dd| d|xsd |rd nd d tt|}|| vr|xsij|xs t}t|| z}|s1dd| d|d d }|rt||d<|j ||j dd| d|d|dt|d|j|fgj | |dYg}t|jD]\\}}i}|D]}|j|d|dt |dkr9t|j}t |dkDr%|j dd|dt|dt|}tfd|D}|j |tt||D cgc]} | gc} |dzt |zd|jd||fScc} w)uimmobilized 인물의 씬 내 다중 샷 연속성 seed (Codex 합의 P8 v1 gate). gate (전부 구조 신호 — 글자/시나리오 판정 0): - shot_staging ``character_angles[*].subject_state`` 가 IMMOBILIZED_STATES (``is_immobilized_state``) 인 인물. - 그 인물 이름(``character``) → short_id 를 ``name_to_sids`` exact 조인. 모호(2+)/미상(0) 이름은 seed 제외 + diagnostic (substring 매칭 금지 — entity catalog display-name exact equality 만, 기존 state/ref 흐름과 동일). - 그 short_id 가 그 샷의 ``visible_entity_ids`` 에 실재해야 멤버 (VE 누락 샷 억지 포함 금지 — producer 오류 은폐 방지, Codex 세부의견). ★identity-variant aware (2026-07-02): subject sid 가 VE 에 없어도 ``identity_family_by_sid``(entity_relation 데이터 계약, character 한정)의 같은 family 멤버가 VE 에 실재하면 같은 인물로 보고 멤버 인정 — 매칭 내역은 skipped 채널에 ``subject_matched_via_identity_variant`` 진단으로 기록(subject/ve_member/family 감사 가능). - 같은 ``scene_index`` 의 같은 short_id 가 ≥2 selected shots 에 등장 → seed. shot_index 인접 조건 없음 (insert/cutaway 건너뛰는 연속성, Codex Q2). - 한 그룹의 멤버 subject_state 가 섞이면(예: dead + unconscious) ``mixed_immobilized_states`` diagnostic + v1 skip (Codex 보수안). score (cap 선별용, deterministic): close/insert framing 가중 + 멤버수. Returns: (seeds, skipped). seed 항목: {character_short_id, scene_index, subject_state, member_shots: [[si, shi], ...], score} character_angles subject_staterrtr r'r(:zambiguous_subject_nameunknown_subject_namer+subject_not_in_visible_entitiesidentity_family$subject_matched_via_identity_variantr)r,r- ve_memberr)r$rr$rNmixed_immobilized_states)r,r-statesc3TK|]}j|ftvrd!ywrPrV)rQrnrKrls rHrTz3detect_immobilized_subject_seeds..js0 #""B9-1FF s%(rY)character_short_idr#rr[r\c |d |d|dfS)Nr\r#rr^r_s rHraz2detect_immobilized_subject_seeds..usqzk1]+;Q?S=TUrJrb) rcrdr2r1r rfr5nextiterrerrgri)staging_by_shotrjr: name_to_sidsrKrgroupedr<rmrnrRstagingvecastatenamesidsrSfamfam_hitentryr;rby_shimrrprrrls ` @rH detect_immobilized_subject_seedsrs?F&+O;=G$&G$**, H(#Cs)C%))#.GZ^^C,23Bkk"45;;/+EKR8vvk2.4"#''-6t9>NN"#B4r#a0A /B C?C#;(>$ 4:&b=17R< 9s Lct|d}tt||}|d|}||dDcgc]#}d|dd|dd|jdd %}}||fScc}w) uimmobilized seed 를 자체 cap 으로 선별 (printed_prop cap 과 독립 — Codex ⑧). 초과분은 silent drop 금지 — skipped(reason="immobilized_cap") + score 기록.rNz immobilized:Sr#rrimmobilized_capr\r,r-r\)maxminrfr2)r;captakermr`r<s rH!select_immobilized_seeds_with_caprys c1+C s5z3 DUd|HtuA!=!1 2!A6J4K3LM$quuW~ ?  W  s(A)rKrelated_zoom_group_idsc <|xsi}|d}|d}g}i}d|dDD]P\}} |j|| ftvrtnt} |j || | dddi|t || <Rd|dDD chc]\} } |  } } } i} |jd xsgD]w}t |ts|jd }t|jd xsd j}t |tsb|| vsg|sj|| t|<yd |d|jdt||jdxsg||dt|jdxsd j| dt|xsg|dScc} } w)uP8 seed + LLM 추출 → immobilized_subject group. member role 은 framing_scale structured enum 으로만 분류 (close/insert → close_insert, 그 외 → environment) — 의미 추론 없음. subject_anchor 는 그룹 전체 공유 SOT (locked_elements = evidence-backed 공유 시각 사실) + per-shot visible focus (insert 샷에 wide body 강요 방지). zoom 그룹은 SOT 가 아니라 참고 링크(related_zoom_group_ids) 로만 남긴다 (Codex Q1).rr#c32K|]}t|ywrxtuplerQrs rHrTz2build_immobilized_subject_group..s=(<1eAh(<r[r#r$roleenforce_state_continuityTc32K|]}t|ywrxrrs rHrTz2build_immobilized_subject_group..s'O:NQa:Nrper_shot_visible_focusr$ visible_focusrvca-s-z -immobilizedlocked_elementsrshared_state_contract)rrrr)group_id anchor_typerrsubject_anchorrper_shot_consumption_hints)r2rWROLE_CLOSE_INSERTROLE_ENVIRONMENTr5 shot_hint_keyr3rrrr lowerANCHOR_TYPE_IMMOBILIZEDrh)r, llm_resultrKrrSrlrhintsmsimshir_ member_shis focus_by_shotrf_shif_texts rHbuild_immobilized_subject_grouprs&+O # $C m B$&G')E=^(<= T""C;/3HH ! s$MN+Et*LmC&'>(P$~:N'OP'OGAt4'OKP$&M 89?R?%&  ,'UYY/526<<> eS !e{&:v(.M#e* % @B4q \:.%>>*;<B"%!/2%(67=2&??Duw&3  #''='C"D&+ Qs Fc 4i}t|jD]}|j|xsg}g}t}|D]}|jd|jd}}t |t rt |t sF||f} | |vrO|j | |j| t|jdxsdf|jdd} |D])\} } | | | k7r| |vr | |td|| <| tk(s(| } +|S) uA5 (2026-07-02) — immobilized 그룹 prev 완성프레임 chaining 계획 (pure). star-to-environment (Codex 합의): 각 멤버 샷을 (scene_index, shot_index) 순으로 정렬해, 자신보다 **앞선 가장 가까운 role=environment 멤버**를 anchor_source 로 매핑한다. immobilized state 는 정의상 불변이라 환경(wide) 프레임이 room state· 지지면·소품 연속성의 가장 안정적인 SOT — close/insert 프레임은 앵커로 쓰지 않는다(직전-멤버 체인은 insert 가 끼면 정보가 줄고 오류 전파가 큼). - 선행 env 멤버가 없는 멤버(그룹 첫 env 이전 샷 포함)는 엔트리 없음 → 소비자 no-op. env 멤버 자기 자신(anchor==target)은 제외. - 한 샷이 여러 그룹 멤버면 group_id 정렬 순 첫 매핑 유지 (결정론). - role 은 manifest 의 structured enum 만 조인 — 의미 추론 0. r#r$rrc |dS)Nrr^)es rHraz3build_immobilized_prev_frame_plan..s1Q4rJrbN) anchor_sourcer anchor_role) rdkeysr2r1r3r r8r5rrir) members_by_groupplangidrorderedseenrrrrRlast_envrs rH!build_immobilized_prev_frame_planrs +-D&++-."&&s+1r-/ UAm,aeeL.ACsC(Zc-B;Cd{ HHSM NNCQUU6]%8b!9: ;   (&* IC#xCtO%- ##3S ''!!/2 KrJrNDEFAULT_D_RESERVED_SLOTS) d_reservedc t|d}tt|dt||}tt|||z }tt|||z }|d|Dcgc] }t|f c}|d|Dcgc] }t|f c}z}||dDcgc]}t t|ddc}||dDcgc]%}t t|d|j dd'c}z}||fScc}wcc}wcc}wcc}w)u,cap 안에서 (anchor_type, seed) 선별 — type 별 공정성 장치 포함. Codex W_A_STAGE_REVIEW (2026-06-12): C 가 많은 에피소드에서 1차 production 핵심인 D 가 cap 에 밀리지 않도록 D(printed_prop) 에 최소 예약 슬롯을 둔다. 1. D 가 먼저 min(d_reserved, len(d_seeds), cap) 슬롯 확보 (score 순) 2. 남은 슬롯을 C 가 채움 (dep 순) 3. 그래도 남으면 D 추가분 (score 순) 초과분은 skipped(reason="cap_after_priority_score") + score 기록 — silent drop 금지.rNcap_after_priority_scorer+r\r)rrrfANCHOR_TYPE_ZOOMANCHOR_TYPE_PROP _seed_labelr2) c_seedsd_seedsrrd_takec_taker`rmr<s rHselect_seeds_with_caprs7 c1+C Z#S\3 7F WsV| ,F WsV| ,F)0(89(81 A (89*1'6*: ;*:Q a *: ; < !!A-q1=WX! ! "A-q1-g H! G W  : ; s$C-<C2C7:*C<c|tk(r"|jdddg}d|dd|dSd|jddS) Nr?zzoom:Srr(r zprop:rZ)rr2)rr,zs rHrrsS&& HHVc3Z (!vR!v&& 488OS12 33rJc|d|S)Nrr^)r#r$s rHrr&s]!J< ((rJc V|d}|d}|jdxst}d|dd|t|d|dtd|d|dtdg|jd xsg|jd xsg||jd d t |d dit |d|tk(iidS)uC seed + LLM 추출 결과 → zoom_continuity group. hint 는 deterministic: source_wide → include_in_wide / zoom → crop_from_source (camera_relation 이 punch-in 일 때만 — Cinematography 축. 부재(legacy/stub)는 punch-in 취급 = 기존 동작 보존).r)rcamera_relationrrz-zoom-r rrwide_shot_contractcamera_relation_evidencerinclude_in_wideTcrop_from_source)rrrrrrrr)r2CAMERA_RELATION_PUNCH_INrROLE_SOURCE_WIDE ROLE_ZOOMr)r,rordinalsrcrrelations rHbuild_zoom_groupr *s x.C >*;<B(nn-ABHb#$.NN3Mr$R 3 "3T!: 4 "H0H$H#'  rJ)rKc |xsi}|d}g}i}d|dDD]P\}}|j||ftvrtnt}|j |||dddi|t ||<Rd|j dt||jd xsg||jd d|jd d |jd d |jdd |jdd d|dS)uD seed + LLM 추출 결과 → printed_prop group. member role 은 framing_scale structured enum 으로만 분류 (close/insert → close_insert, 그 외 → environment) — 의미 추론 없음.rZc32K|]}t|ywrxrrs rHrTz#build_prop_group..Ws;&:E!H&:rr[rkeep_real_scaleTzvca-z-proprcarries_printed_contentapplicability_evidencerprinted_content physical_formscale_contract)rZr rrrr)rrrr prop_anchorr)r2rWrrr5rrr) r,rrKrSrrrlrnrs rHbuild_prop_grouprJs&+O  C$&G')E;d>&:;C""B9-1FF ! rdKL):D(AmB$%<399;-u-'%>>*;<B (2~~6OQU'V&0nn5Mr&R)~~.?D'^^OR@(nn-=rB  ',! rJct||dS)N)schema_versiongroups diagnostics)r)rrs rHbuild_manifestrss )" rJT)include_framingcL|jdddur|xsdjSg}|r|jd|jdr+|jt|dj|jdr.|jdt|djz|jd r+|jt|d jd j |}|xsdj}|r|d |zz }|S) u0printed_prop anchor → reference image generation prompt overlay (deterministic). Codex 판정 (W_A_STAGE_REVIEW / 설계 D-①): anchor 의 printed_content / physical_form / scale_contract 가 **우선**하되 기존 canon t2i 를 버리지 않고 스타일/맥락 source 로 뒤에 보존한다. canon 자체(EntityCanon.t2i_prompt / entity_t2i cp)는 절대 변경하지 않는다 — 그것이 provenance. include_framing=False 는 description 슬롯용 — ref_image_pipeline 의 prop 템플릿이 product-photo framing 을 이미 제공하므로 (entity_description 으로 조립, t2i_prompt 는 템플릿 부재시 fallback — 2026-06-12 실측) framing 상수를 중복하지 않는다. LLM 재호출 0 — 스파이크2 ref_prompt 패턴의 문자열 조립만. r TFrz_Photorealistic product photo of a single physical prop, isolated on a plain neutral background.rrz%The content printed/displayed on it: r uy Original canon description (style and context reference — where it conflicts with the anchor above, the anchor wins): )r2rr5rjoin)r canon_t2irpartsoverlays rHbuild_prop_ref_prompt_overlayr s20$75@R&&(( E  ( ' S_56<<>?() 3+/01779 : '( S%567==?@hhuoGb'')I BDM N  NrJz[CLP]\d{2,3}(?:O\d{2,3})?cFttj|xsdS)Nr)r1_ENTITY_TOKEN_REfindall)texts rHextract_entity_tokensr%s '' 3 44rJc0t|t|z S)urevised 가 original 에 없던 entity ID 토큰을 도입했으면 그 집합 반환. 비어있지 않으면 audit 위반 — caller 는 revised 를 폐기(substitution 미적용) 하고 diagnostic 으로 기록한다 (비차단).)r%)originalreviseds rHrevised_prompt_new_tokensr)s ! ),A(,K KKrJz ^C\d{2,3}ct}t|D]:}tj|}|s|j |j d<|S)uP인물(C) entity ID 토큰의 base 집합 — C08O06 → C08. L/P 토큰 제외.r)r1r% _CHAR_BASE_REmatchr8group)r$basestokrs rHchar_token_basesr0sFeE$T*    $ IIaggaj !+ LrJclt}|xsgD]}|t|z}|t|xsdz S)uWzoom 멤버 프롬프트들의 인물 토큰 base 중 source 프롬프트에 없는 것. 비어있지 않으면 그 source variation 은 zoom 의 피사체를 담을 수 없다 — caller 는 해당 variation 재작문을 skip 하고, 전 variation 이 그러면 seed 자체를 skip(reason="zoom_subject_absent_in_source") 한다.r)r1r0) zoom_prompts source_prompt zoom_charsps rHzoom_subject_missing_charsr6sC5J  R &q))  ()<"= ==rJ)extra_known_shotsknown_char_short_idsc fg}|xs t}|jd}t|tsdgSt}|D]}|jdxsd} | |vr|j | d|j | |jd} | t ttfvr|j | d| }|jdxsg} t| d kr|j | d g} | D]} | jd | jd }}| j | jd d||f}t|tr2t|tr"||j|tvs||vs|j | d|d|d|jdxsgD]@}t|jddjr-|j | dB|jdxsi}| t k(rpt| vst| vr|j | d|jD]7\}}|jdst| vs!|j | d|d9F| tk(rB|jdxsijd}||vsy|j | d||jdxsijd}|s|j | d|||vs|j | d ||S)!uschema parse + 조인 무결성만 — 의미 게이트 없음 (Codex 가이드 5). Returns: violation 문자열 목록 (빈 목록 = 통과). rzgroups must be a listrz z: duplicate group_idrz: invalid anchor_type rrNz: needs >=2 membersr#r$rrz : member Sr(z not a known selected shotrevidence_quotez': locked_element without evidence_quoterz+: zoom group needs source_wide + zoom rolesrz(: crop_from_source without source_wide ()rrZz: unknown prop_short_id rrz.: immobilized group missing character_short_idz: unknown character_short_id )r1r2r3rhr5r8rrrrfr rrrrrc)manifestr:known_prop_short_idsr7r8 violationsrseen_group_idsgratyperrolesrrlrnrRlerkey_shintrScsids rHvalidate_anchor_manifestrGs,J)2SU \\( #F fd #'(("uN eeJ.; .   %9: ;3m$ )+;=TU U   %;E9E F %% "(b wX"YZ%%)*0b0Brvv.34::<!!SE)P"QR1239r $ $u, 0F!!SE)T"UV${{} t88./4DE4Q%%-UV[U\\]&^_ -& &55'-222?CC..!!SE)A#"IJEE*+1r667KLD!!SE)W"XY%1dBV6V!!SE)Fth"OP]` rJ)r9List[Dict[str, Any]]r:Dict[int, Set[int]]r!z$Optional[Callable[[int, int], bool]]rzGTuple[List[Dict[str, Any]], List[Dict[str, Any]], List[Dict[str, Any]]]) rjDict[ShotKey, List[str]]r:rIrkSet[str]rKOptional[Dict[ShotKey, str]]rLz!Optional[Dict[ShotKey, Set[str]]]rrH)rrHrurrDict[str, Set[str]])rDict[ShotKey, Dict[str, Any]]rjrJr:rIrrMrKrLrzOptional[Dict[str, Set[str]]]r1Tuple[List[Dict[str, Any]], List[Dict[str, Any]]])r;rHrr rrO) r,Dict[str, Any]rrPrKrLrzOptional[List[str]]rrP)rzDict[str, List[Dict[str, Any]]]rrN) rrHrrHrr rr rz=Tuple[List[Tuple[str, Dict[str, Any]]], List[Dict[str, Any]]])rrr,rPrr)r#r r$r rr)r,rPrrPrr rrP)r,rPrrPrKrLrrP)rrHrrPrrP)rrPrrrr7rr)r$rrrK)r'rr(rrrK)r2 List[str]r3rrrK) r<rPr:rIr=rKr7zOptional[Set[ShotKey]]r8zOptional[Set[str]]rrQ)=__doc__ __future__rloggingretypingrrrrrr r app.core.subject_stater getLogger__name__loggerr__annotations__rrrrrr6r4rrrrrCAMERA_RELATION_DIFFERENTCAMERA_RELATION_UNCERTAIN frozensetrWr ShotKeyrIrsrrrrrrrrrr rrr compiler"r%r)r+r0r6rGr^rJrHras,# BBB7   8 $3 ! $! 0!'   " 0:'"7H"56 S/AE G,&G,%G,> G, M G,d59DH 6(6%66 2 6 !B 66~#1#11 1t59<@q2q(q&q& q 2 q:q7qh  7,5926 7 772 7 0 7  7t*5*"*`!"#!/ ! !! !! !  ! C !H4)  H59 & &&2 &  &R $! 111 1  1t2:::;5L$ <(  > >,/ >  >,15/3 CC%C#C . C - CCrJ