-ǚjFdZddlmZddlZddlZddlZddlZddlmZmZddl m Z ddl m Z m Z mZmZmZddlmZddlmZdd lmZdd lmZdd lmZdd lmZdd lmZ ddl!m"Z"m#Z#m$Z$m%Z%m&Z&m'Z'm(Z(ddl)m*Z*ddl+m,Z,ddl-m.Z.dgZ/ej`e1Z2GddZ3y)u Scene persistence service — scene_image_service에서 분리된 DB 저장 전용. W5 F22 Phase B.9.1~B.19 (2026-04-22): scene_image_service.generate_images()의 ImageAsset 저장/복원 + WorldGuide 해소 로직을 점진 이관. ## 공개 API | 메서드 | 역할 | |--------|------| | `save_scene_variations(var_results_list, scene_lineage)` | N variation ImageAsset bulk 저장 + commit | | `set_primary_asset(asset_id)` | 단일 asset을 is_primary=1로 업데이트 + commit | | `save_single_scene_asset(scene_result, lineage)` | 단일 scene asset 저장 + auto_set_primary + commit | | `save_fal_angle_asset(...)` | fal.ai angle-edited asset 저장 + commit | | `build_resume_state(stills, already_done_stills, entity_lookup)` | resume 모드에서 기존 scene asset들을 읽어 scene_paths/scene_paths_by_id/scene_results/location_history 4-map 복원 | | `resolve_world_guide(...)` | WorldGuide 해소 (hash 재사용 또는 재생성) + project style 주입 | | `load_episode_entity_dicts(episode_id)` | 에피소드에 연결된 EntityCanon을 dict 리스트로 로드 | | `load_episode_still_dicts(episode_id)` | 에피소드의 선택된 SceneStill을 dict 리스트 + ORM 리스트 tuple로 로드 | | `validate_episode_ready(episode_id)` | pipeline_gate + scene_count>0 검증 (AppError raise) | | `fetch_still_for_generation(still_id)` | still 조회 + pipeline_gate + gemini_key 검증 (single scene 생성용) | | `mark_asset_as_original(asset_id)` | 지정 asset의 variant_type='original' 마킹 + flush | 각 save/update 메서드는 self._db.commit()을 포함한다 (호출자 commit 불필요). build_resume_state는 read-only. resolve_world_guide는 재생성 시 self._db.flush()만 수행 (commit은 상위 호출자 책임 — 기존 generate_images 흐름 보존). ) annotationsN)datetimetimezone)Path)AnyDictListOptionalTuple)Session)settings)AppError)to_relative_image_path)annotate_generated_asset)t) key_count) EntityCanonEntityEpisodeLink ImageAsset LLMCallLogProjectSettings SceneStill WorldGuide) OpenAIClient)WorldGuideGenerator)auto_set_primaryScenePersistenceServicec~eZdZdZddZ ddZ ddZ d ddZ ddZddZ d dZ d d Z d!d Z d"d Z d#d Zd$d Zd%dZ d&dZ d' d(dZ d)dZ d*dZd#dZd!dZd+dZd,dZ d-dZy).ru>씬 이미지 persistence 전담 서비스 (W5 F22 Phase B.9).c ||_||_yN)_db _project_id)selfdb project_ids \/Users/manta/Documents/Projects/TheRoad-I1/backend/app/services/scene_persistence_service.py__init__z ScenePersistenceService.__init__As%c g}g}|D]c}tdid|dd|jd|dd|dd|dd|ddt|dd|dd |d d |d d |d d |d d |d d|jdd|jdd|jddd|jdd|dd|dd|dd|dddd|d}|jj ||j ||jdd\}}} |r||_t|dd|xsd| |j|d|jt|df|jj||fS) a}Save N variation ImageAssets for a scene (bulk insert + commit). Each var_result must include the keys populated by the scene generation pipeline (id, asset_type, entity_id, still_id, episode_id, file_path, prompt_used, generation_model, width, height, status, review_notes, created_at) plus optional (validation_score, validation_result, variant_type, theme_label, sanitization_strategy, sanitization_note). `scene_lineage` must provide prompt_type, code_version, prompt_file_version, reference_image_ids. Returns (saved_asset_ids, saved_paths) in input order. idr% asset_type entity_idstill_id episode_id file_path prompt_usedgeneration_modelwidthheightstatus review_notesvalidation_scorevalidation_result variant_typebase theme_label prompt_type code_versionprompt_file_versionreference_image_ids is_primaryr created_atscene_image_gen scene_still scene_imageN pipeline_rolestageinput_image_idspipeline_metadata) rr"rgetr!add_build_lineage_annotationgeneration_call_idrappendrcommit) r#var_results_list scene_lineagesaved_asset_ids saved_pathsvrasset _input_ids _gen_call_id_metas r&save_scene_variationsz-ScenePersistenceService.save_scene_variationsEs3$&("$ "Bd8++l+[/  J  l+ 1KA}-"$$6!7k(|(| /"$(:!;#%&&)<"=  VVNF;!"FF=1#$*-8%&+>:'(%22G$H)*%22G$H+,-.l+/E2 HHLL /3.L.LBFF<(*;/ +J e+7( $]-!+!3t"'   " "2d8 ,   tB{O4 5[#\  ++r(c(t|jdxsg}|jdxsg}g}|xs|D]}|s||vs |j|t|jdxsg}t|jdxsg} |j| |\} } } | D]} | |vs|j| |j | |j | |\}}} |D]}||vs|j||j |d|vr|jd}n#|j |jd||}d|| d }|jd r|d |d <|jd r|d |d <|||fS) uP0: var_result/scene_result 에서 실제 첨부 UUID lineage annotation 구성. 배치(save_scene_variations)/단건(save_single_scene_asset) 공유 — 동일 정책. actual_attached_image_ids 우선(없으면 legacy pose_guide_asset_ids) + unresolved 중 registered_pose_guide post-hoc resolve(구조키) 병합 + generation_call_id. Returns (input_image_ids, generation_call_id, pipeline_metadata). actual_attached_image_idspose_guide_asset_idsactual_attached_refsunresolved_attached_refsrMr-)operation_typeinput_image_ids_actual_attached)reference_lineage_sourcer]r^prev_frame_chain shot_run_uid)listrJrN#_resolve_registered_guide_asset_idsextend_resolve_prev_frame_asset_ids_resolve_generation_call_id)r#sourcer.r_ _actual_ids _fallback_idsrV_gid _actual_refs _unresolved_r_ids_r_refs _remaining_rid_p_ids_p_refs_pidrWmetas r&rLz1ScenePersistenceService._build_lineage_annotations6::&ABHbI  #9:@b "  1M1DJ.!!$'2FJJ'=>D"E 6::&@AGRH &*&N&N ' #D:%!!$' G$'+&H&H  ' #D:%!!$' G$ 6 )!::&:;L;; :& -<L )J$0(2   ::( )'-.@'AD# $ ::n %#).#9D <--r(c  |sy |jjtjj tj |j k(tj|k(tjdk(tjjd|d}|rt|j tjjd|djtjjj}|r|dSdS|jtjjj}|r|dSdS#t$r!}t j#d||Yd}~yd}~wwxYw)uP0 best-effort: 이 still 의 image_gen llm_call_log 감사 링크 회수. 구조키(metadata_json 의 still_id UUID) 로만 매칭 — 라벨/프롬프트 파싱 아님. 한 still 에 variation 별 call 이 여럿이면 최신 success 1개(감사 수준 링크, variation 단위 정합은 v1 미보장·문서화). still_id 부재 시 None. operation_type: 배치="scene_image_gen", 단건="single_scene_image_gen". multiroll_tag(Codex 8e70d4c0 HIGH-2 재리뷰): selected roll/fix 의 exact 호출 태그 — 지정 시 exact 매칭만 허용하고 miss 는 None (broad still_id fallback 은 패자 branch/다른 롤을 거짓 링크할 수 있어 금지). legacy fallback 은 multiroll_tag 미지정 호출에만. Nsuccessz%"still_id": ""%z%"multiroll_tag": "ru.generation_call_id resolve 실패 still=%s: %s)r!queryrr*filterr%r"r_r4 metadata_jsonlikeorder_byr@descfirst Exceptionloggerwarning) r#r-r.r_ multiroll_tagr9exactqexcs r&rhz3ScenePersistenceService._resolve_generation_call_idsG" z}}-))T-=-==--?%%2,,11N8*B2OP  KK"00551-CEXj3388:;UW $)uQx2d2 j3388:;AACA1Q4 &$ &  NNKXWZ [ s+D EEAEE F!E==Fc|sy |jjtjtjtj j tj|k(j}|sytj|dxsd}|jd}|syt||d|ddS#t$r!}tjd||Yd}~yd}~wwxYw) u(Codex safety-ladder BLOCK-2) fallback 성공 자산의 provenance SOT. 해당 호출의 metadata_json 에 safety_ladder(비 primary 단계명)가 있을 때만 {stage, model_name, user_prompt} 를 돌려준다 — 사다리 미발화·플래그 OFF 호출은 키 자체가 없어 None(기존 경로 byte-identical). 소비자는 이것으로 자산의 generation_model· prompt_used 를 실제 성공 호출과 정렬한다(설정 플래그 추정 금지). N{} safety_ladderr)rF model_name user_promptu2safety_ladder provenance 조회 실패 call=%s: %s)r!rzrrrr|r{r*rjsonloadsrJstrrrr)r#call_idrowrvrFrs r&safety_ladder_call_provenancez5ScenePersistenceService.safety_ladder_call_provenances )):+A+A,,. 01 ::c!fn-DHH_-EU!!f"1v    NND   s$A7C=/C-C C, C''C,cd|sy |jjtjj tj |k(j }|r%|dr t|djxsdSdS#t$r!}tjd||Yd}~yd}~wwxYw)u그 호출이 **실제로 쓴 모델** — 없으면 None (2026-08-26 감사 0-B). ★설정값으로 내려가지 않는다. 제공자를 모를 때 설정값을 적으면 빈 칸 보다 **더 확정적인 거짓 기록**이 된다(Codex BLOCK-3). 변환 자산의 `generation_model` 은 이 호출 기록이 SOT 이고, backfill 스크립트도 같은 값을 쓴다. Nru'호출 모델 조회 실패 call=%s: %s) r!rzrrr{r*rrstriprrr)r#rrrs r&call_model_namez'ScenePersistenceService.call_model_name$s z445 01  58CFCAK%%'/4 L L  NN97C I sA=BB B/B**B/c g}g}g}|D]}t|tr|jddk7r|j|:|jd}|jd}|jd} d} d} |jj t jjt j|jk(t j|k(t jdk(t jjd} |r|r| r| jt jj!d |d t jj!d |d t jj!d | d j#} t%| d k(r| dd} | |r|r| jt jj!d |d t jj!d |d j#} t%| d k(r | dd} nt%| d kDrd} | rP| |vr|j| |j| |jdxsd|jddddt|}| rd|d<|j||||fS#t&$r3}t(j+d|||j|Yd}~d}~wwxYw)uP0 (2026-07-01, Codex 합의): unresolved 중 registered_pose_guide 를 구조키(group_id+bg_key+guide_hash)로 post-hoc resolve. attach_registered_pose_guide_ref 는 worker-thread(DB접근0) 라 asset_id 를 못 실어 unresolved 로 떨어진다. 여기서 저장 시점(DB session 有)에 라벨없이 구조키로 실제 registered_pose_guide ImageAsset UUID 를 붙인다. 우선순위: (group_id,bg_key,guide_hash) exact → 1개면 resolve / fallback (group_id,bg_key) → 정확히 1개면 resolve, 2+ 면 ambiguous(unresolved 유지 + reason) / still_id fallback 은 그룹캐시 cache_hit 시 still 이 다를 수 있어 여기선 안 씀(coordinator 가 이미 shot 매핑). resolve 실패는 그대로 unresolved. Returns: (resolved_ids, resolved_refs[resolved_from_unresolved 마커], remaining_unresolved). rEregistered_pose_guidegroup_idbg_key guide_hashNFTz%"group_id": "ryz %"bg_key": "z%"guide_hash": "rru1registered_pose_guide resolve 실패 group=%s: %sroleimmobilized_pose_guidelabel)asset_idrrresolved_from_unresolved$registered_pose_guide_ambiguous_pairreason) isinstancedictrJrNr!rzrr*r{r%r"r.rEis_intermediateis_pipeline_metadata_jsonr}alllenrrr)r# unresolvedr. resolved_ids resolved_refs remainingugidrghrid ambiguousr9rowsr_us r&rez;ScenePersistenceService._resolve_registered_guide_asset_ids:s$#% .0 *, Aa&!%%*@D[*[  #%% #CUU8_F|$B!%CI xx~~jmm4;;))T-=-==))Z7,,0GG..2248  6b;;"99>>PSuTV?WX"99>>fXUW?XY"99>>AQRTQUUW?XYce  4yA~"1gaj;36;;"99>>PSuTV?WX"99>>fXUW?XYce4yA~"1gajTQ$( l* '',$$ #EE&ME-EUU7B/04 &!W#IBxL  $ef]I55% RTWY\]  # s;GJ<< K8(K33K8c g}g}g}|D]}t|tr|jddvr|j|9|jd}d}|r |jj t jjt j|jk(t j|k(t j|k(t jdk(t jdk(jt j j#j%} | r| dnd}|r`||vr|j||j||jd xsd |jd d |jdd dt|} |sd| d<n d| vrd| d<|j| |||fS#t&$r3} t(j+d|| |j|Yd} ~ d} ~ wwxYw)uA5 (2026-07-02): unresolved 중 immobilized_prev_frame 을 구조키 ``source_still_id`` 로 post-hoc resolve (registered_pose_guide 패턴). attach_immobilized_prev_frame_ref 는 worker-thread(DB 접근 0) 라 anchor 프레임의 asset UUID 를 못 싣는다 — 저장 시점에 anchor still 의 **scene primary** ImageAsset UUID 를 라벨 파싱 없이 붙인다. primary 마킹이 아직 없거나(동일 batch 내 예외 경로) 조회 실패면 그대로 unresolved 유지 (비치명 — bytes ref 는 이미 첨부됨, lineage 만 부분). Returns: (resolved_ids, resolved_refs[resolved_from_unresolved 마커], remaining_unresolved). rE)immobilized_prev_framescene_prev_framesource_still_idNscenerru9immobilized_prev_frame resolve 실패 source_still=%s: %srprevious_shot_same_roomrrT)rrrrEr"prev_frame_source_still_id_missingrprev_frame_primary_not_found)rrrJrNr!rzrr*r{r%r"r.r-r+r?r~r@rrrrr) r#rr.rrrrsrc_sidrrrrs r&rgz5ScenePersistenceService._resolve_prev_frame_asset_idss#% .0 *, Aa&!%%*@IB+B  #ee-.G!%Cz}}5&11T5E5EE&11Z?&//7:&11W<&11Q6 "*"7"7"<"<">?%(#a&TCl* '',$$ #EE&MF-FUU7B/%&UU?%;04 &!W#GBxLR'#ABxL  $]^]I55/!NNS&$$Q' sCG  H(HHc|jjtjtj|k(j ddi|jj y)z;Mark a single ImageAsset as is_primary=1 (commit included).r?rN)r!rzrr{r*updaterO)r#rs r&set_primary_assetz)ScenePersistenceService.set_primary_assetsF z")) MMX % &," # r(ct}|jjtjj tj |jk(tj|k(tjdk(jj}|D]}|d}|s |jjtj tj |jk(tj|k(tjdk(tjdk(j}|st|jj!s|j#||j%D]n}|j&j)dij)|i} | j)dd} | sDt| j!s^|j#|p|S)uScan DB + checkpoint to determine already-completed still_ids (resume mode). W5 F22 Phase B.15: generate_images의 resume 스캔 루프 이관. 하나의 still은 다음 중 하나를 만족하면 "완료"로 간주한다: 1) DB에 해당 still의 scene primary ImageAsset이 있고 file_path가 디스크에 실제 존재 2) scene_cp.get_completed_ids()에 등록되어 있고 primary_path가 디스크에 존재 scene_cp은 ImageCheckpointManager 인터페이스 (`get_completed_ids()` + `_data["completed"][cp_id]["primary_path"]` 접근)로 쓰인다. rrr completed primary_pathr)setr!rzrr-r{r%r"r.r+distinctrr?rrr/existsrKget_completed_ids_datarJ) r#r.scene_cpdoneexisting_stillsrsidprimarycp_idcp_datacp_paths r&scan_completed_scene_stillsz3ScenePersistenceService.scan_completed_scene_stillssE HHNN:.. / V%%)9)99%%3%%0 XZ SU !AA$ChhnnZ077%%)9)99##s*%%0%%*  eg  4 1 1299; !//1Enn((b9==eRHGkk."5G4=//1 2  r(ctd)u,Hard-fenced: 씬 이미지 일괄 DELETE 절대 금지. 절대 규칙 (feedback_never_delete_images): 이미지 step 재실행 시 기존 이미지 절대 삭제 금지 — 이전/새 이미지 비교 필수. 대안: - mode='resume' + force: UPDATE is_primary=0 으로 row 보존, 새 row 가 is_primary=1. PNG 파일도 그대로 유지. Orphan 정리는 별도 메서드 ``delete_orphan_scene_assets`` 사용 (scene_still 부모 row 가 사라진 경우만 — 분석 단계 재실행 시). zdelete_existing_scene_assets is hard-fenced (feedback_never_delete_images). Image step re-run MUST preserve existing rows via is_primary=0 pattern. For analysis-step orphan cleanup, use delete_orphan_scene_assets().) RuntimeError)r#r.s r&delete_existing_scene_assetsz4ScenePersistenceService.delete_existing_scene_assetss R  r(c rddlm}|tjj tj |k(}|j jtjtj|jk(tj |k(tjdk(tjjdtjj|}|j!d}|j j#|r"t$j'd||j||S)uOrphan 정리: scene_still 부모 row 가 없는 image_asset 만 삭제. 분석 step 재실행 (scene_save/shot_extract/entity_merge 등) 으로 scene_still 의 still_id 가 reshuffle 되어 image_asset.still_id 가 존재하지 않는 still 을 가리키게 된 경우 호출. 부모 still 이 살아 있는 image_asset 은 절대 건드리지 않음. Returns: 삭제된 orphan row 수. rselectrNfetchsynchronize_sessionzJdelete_orphan_scene_assets: removed %d orphan rows (project=%s episode=%s)) sqlalchemyrrr*wherer.r!rzrr{r%r"r+r-isnotin_deleterOrinfo)r#r.rvalid_still_idsorphan_qcounts r&delete_orphan_scene_assetsz2ScenePersistenceService.delete_orphan_scene_assets s & /55  ! !Z / 88>>*-44  ! !T%5%5 5  ! !Z /  ! !W ,    % %d +  $ $_ 5 5  G<   KK\t''  r(cxddlm}ddlm}||jj |j |jk(}|jjtjtj |jk(tjjddgtjjdtjj|}|j!d}|jj#|r!t$j'd ||j|S) uOrphan 정리: entity_canon 부모 row 가 없는 reference/composite 자산 삭제. Entity 분석 step 재실행 (entity_extract/entity_merge 등) 으로 entity_id 가 reshuffle 되어 image_asset.entity_id 가 존재하지 않는 entity 를 가리키는 경우 호출. 부모 entity 가 살아있는 image_asset 은 보존. 프로젝트 범위 (episode 무관) — entity 는 프로젝트 전체에서 공유. Returns: 삭제된 orphan row 수. rr)r reference compositeNrrz@delete_orphan_entity_assets: removed %d orphan rows (project=%s))rrapp.models.projectrr*rr%r"r!rzrr{r+rr,rrrOrr)r#rrvalid_entity_idsrrs r&delete_orphan_entity_assetsz3ScenePersistenceService.delete_orphan_entity_assets+s &2!+..177  " "d&6&6 6 88>>*-44  ! !T%5%5 5  ! ! % %{K&@ A  & &t ,  ! ! % %&6 7 7   G<   KKRt''  r(c tdid|dd|jd|dd|dd|dd|ddt|dd|dd |d d |d d |d d |d d |d d|jdd|jdd|jdd|dd|dd|dd|dd|d}|jj ||j ||jdd\}}}|r||_t|dd|xsd|t|j|j||jj|S)aSave a single scene ImageAsset (used by generate_single_scene_image). scene_result fields: id, asset_type, entity_id, still_id, episode_id, file_path, prompt_used, generation_model, width, height, status, review_notes, created_at, plus optional (sanitization_strategy, sanitization_note, original_prompt). lineage fields: prompt_type, code_version, prompt_file_version, reference_image_ids. `auto_set_primary` promotes this asset to is_primary=1 if no other primary exists for the same still. Commit is included. Returns the saved ImageAsset so caller can call image_to_dict(). r*r%r+r,r-r.r/r0r1r2r3r4r5sanitization_strategyoriginal_promptsanitization_noter;r<r=r>r@single_scene_image_genrBrCNrDrI) rr"rrJr!rKrLrMrrrO)r# scene_resultlineagerUrVrWrXs r&save_single_scene_assetz/ScenePersistenceService.save_single_scene_assetJs$ D! '' $L1 #;/  "*-  $L1  -\+-FG %]3 **<= w'  )  ) &n5 #/"2"23J"K ),,->? +../BC! " .# $!0% &!((= >' (!((= >) *$L1+ .  U+/*H*H ,**<8:R+ ' L% '3E $ m'/4# 4#3#3U;  r(NcXi}i}i}i}|s||||dSt|D]\} } | jd} | |vr|jjtj tj |jk(tj| k(tjdk(tjdk(jtjjj} | s|jjtj tj |jk(tj| k(tjdk(jtjjj} | sddlm} | | j"}|r|j%s||| <||| <| j&| j"| j(xsd| j*| j,xsdd|| < t/j0| jd d }d }|D]l}t5|t6s|jdxs|jd d}||vs>||jd dk(sV|j9| f||<d}n| jd}|r|st5|t:s|j|}|s|j9| f||<||||dS#t.j2$rg}YwxYw)u;Restore per-still resume state from existing scene ImageAssets. W5 F22 Phase B.13 (2026-04-22): scene_image_service.generate_images의 resume 복원 루프를 이관. 각 already_done still에 대해 primary asset (없으면 최신) 조회 + 파일 존재 확인 후 path map들과 location history map을 populate한다. 2026-04-27: sd_shot_path_map 반환 제거 (downstream 미사용). Returns a dict with 4 populated maps: - scene_paths_by_index: {scene_index → Path} - scene_paths_by_index_by_id: {still_id → Path} - scene_results_by_index: {scene_index → dict(id/file_path/...)} - location_scene_history: {location_id → (bytes, still_data)} already_done_stills가 비어 있으면 4개 빈 dict를 반환. )scene_paths_by_indexscene_paths_by_index_by_idscene_results_by_indexlocation_scene_historyr*rrr)resolve_image_pathr)r*r/r0r4r5visible_entities_json[]Fr, entity_typelocationT scene_index) enumeraterJr!rzrr{r%r"r-r+r?r~r@rrapp.core.file_pathsrr/rr*r0r4r5rrJSONDecodeErrorrr read_bytesint)r#stillsalready_done_stills entity_lookupfallback_location_uuid_by_scenerrrrsi still_datar-existing_assetrfpvis_ids _loc_recordedveid_fb_si_fb_us r&build_resume_statez*ScenePersistenceService.build_resume_states.1368"<>13"(<.H*@*@  (/NB !~~d+H22z*))T-=-==''83))W4))Q.  *//4467 "HHNN:.V"--1A1AA"++x7"--8 Xj3388:;UW" ?#N$<$<=BRYY[')  $35 &x 0$''+55-99?R(// . ; ; Ar * "2 & **Z^^4KT%RS"Ma&%%+?{B)?Cm+ c0B0F0F}0UYc0c79}} 6S.s3(,  ^^M2F!&E"63/7;;FC57]]_j4Q*51I0N%9*D&<&<   )''  s%LL)(L)ct||jd||t||dddd|| }|jj ||jj y)zSave a fal.ai angle-edited scene asset (single insert + commit). asset_type/generation_model/variant_type/status/is_primary are fixed to the fal.ai angle pipeline contract. rz+fal-ai/qwen-image-edit-2511-multiple-angles generatedr angle_fal) r*r%r+r-r.r/r0r1r4r?r8source_image_idr@N)rr"rr!rKrO) r#rr/r-r.r0rr@rUs r&save_fal_angle_assetz,ScenePersistenceService.save_fal_angle_assets` ''!,Y7#J$+!   U r(c |jxsd}tj|dddt|dt|j j } d} |dk7r|j jtjtj|jk(tj|k(jtjjj!} | r0| j"| k(r!t%j&| j(} nvt+} t-| } |j/dd| 5}|j1t|jt|t|d | j3|j||j4xsd || } |j7d t| j9ddidddtt;t=j>|j|t%j@ d| tCjDtFjHjK}|j jM||j jO|j jtPjtPj|jk(j!}|rj|jRr^t%j&|jR}| j9di}tU|tVr|j9dr|| d<| S|| d<| S#1swY~xYw)uResolve world guide: hash-based reuse or regenerate + save. W5 F22 Phase B.19 (2026-04-22): scene_image_service.generate_images의 WorldGuide 블록을 이관. 처리: 1. fulltext[:500] + len(entities) + len(stills) 해시 계산 2. mode != "full"이면 기존 WorldGuide 조회, source_hash 일치 시 재사용 3. 불일치/없음/force 이면 OpenAIClient + WorldGuideGenerator로 재생성 후 DB 저장 (flush만) 4. ProjectSettings.style_rules_json이 있으면 world_guide에 주입 - WorldGuide의 style_rules.must_maintain이 있으면 project_style로 추가 - 없으면 style_rules 자리에 그대로 삽입 commit은 하지 않음 (caller의 후속 DB 작업과 함께 flush). rNi:full) llm_clientimage_generationworld_guide_generator)r.)fulltext_charsentitiesrepisode)fulltextlanguage source_filer!rworld_setting_summary_lenworld_setting_summaryF) ensure_ascii)r*r%r. guide_json source_hashr@ style_rules must_maintain project_style),r#hashlibmd5rencode hexdigestr!rzrr{r%r"r.r~r@rrr*rrr)rrstart_operation set_inputgeneratesource_filename set_outputrJruuiduuid4dumpsrnowrutc isoformatrKflushrstyle_rules_jsonrr)r#r.r"r!rmode provenancer$r#wg_hash existing_wg world_guide openai_clientwg_genop wg_record proj_settings proj_style existing_srs r&resolve_world_guidez+ScenePersistenceService.resolve_world_guides.##)r++~aH aF } = D D F )+  6>z*))T-=-==))Z7*//4467  ;22g=**[%;%;=0+status!=stale) 3. scene_count == 0이면 image.no_scenes AppError (status 400) 예외 메시지는 원본 리터럴 '씬이 없습니다. 분석을 먼저 완료하세요.' 보존 (i18n 미적용 블록). rcheck_scene_images_readyTstalezimage.no_scenesu6씬이 없습니다. 분석을 먼저 완료하세요.codemessage status_codeN)app.core.pipeline_gaterNr!r"rzrr{r%r. is_selected still_indexr4rr)r#r.rN scene_counts r&validate_episode_readyz.ScenePersistenceService.validate_episode_readyss D 4+;+;ZHhhnnZ077  ! !T%5%5 5  ! !Z /  " "d *  " "a '    (  %'  ! &P  r(c|jjtjtj|k(j }|r"d|_|jjyy)u ImageAsset.variant_type='original'로 마킹 + flush. W5 F22 Phase B.24.3 (2026-04-23): scene_image_service.generate_scene_with_variations의 original asset 마킹 블록(~9 LOC)을 이관. 처리: 1. ImageAsset.id == asset_id 조회 (project_id 필터 없음 — 원본 유지) 2. 있으면 variant_type='original' + self._db.flush() 3. 없으면 no-op (원본도 동일) commit은 호출자 책임 (원본은 자체 commit 없이 flush만 — 이후 caller가 commit). originalN)r!rzrr{r*rr8r=)r#rrUs r&mark_asset_as_originalz.ScenePersistenceService.mark_asset_as_originalsS HHNN: & VJMMX- . UW  !+E  HHNN  r(c|jjtjtj|k(tj |j k(j}|r.ddlm }||j|j |jtjs$tdk(rtdtdd|jjtjtj|k(tj |j k(j}|stdtdd|S)usingle scene 생성을 위한 still 조회 + 파이프라인 준비성 검증. W5 F22 Phase B.23.1 (2026-04-23): scene_image_service.generate_single_scene_image의 입력 검증 블록(~28 LOC)을 이관. 처리 순서 (리터럴 보존): 1. still_check 쿼리 (project_id + still_id) 2. still_check가 있으면 check_scene_images_ready 호출 (pipeline_gate) 3. gemini_api_key 또는 key_pool.count가 없으면 image.gemini_key_missing AppError 4. 본 still 쿼리 재실행 (원본 중복 유지 — literal lift) 5. still 없으면 still.not_found AppError (status 404) 원본 중복 쿼리 패턴은 변경하지 않음 (검증 경로와 사용 경로가 별개로 실행). rrMzimage.gemini_key_missingrPrQzstill.not_foundi)r!rzrr{r*r%r"rrUrNr.r gemini_api_keygemini_key_countrr)r#r- still_checkrNstills r&fetch_still_for_generationz2ScenePersistenceService.fetch_still_for_generations HHNN: & VJMMX-z/D/DHXHX/X Y UW   G $TXXt/?/?AWAW X&&+;+=+B/45  HHNN: & VJMMX-z/D/DHXHX/X Y UW  &+,   r(c ddlm}||j|j|}|rY|jj t j t jj|jng}|Dcgc]b}|j|j|jxsd|j|jxsd|jxsd|jxsdddc}Scc}w)u에피소드에 연결된 EntityCanon을 dict 리스트로 로드. W5 F22 Phase B.22.10 (2026-04-23): scene_image_service.generate_images의 entity ORM → dict 변환 블록(~28 LOC)을 이관. 처리: 1. EntityEpisodeLink 조회 (project_id + episode_id) 2. canon_ids 수집. 빈 리스트면 entities_orm=[] (2차 쿼리 스킵) 3. EntityCanon.id.in_(canon_ids) 로드 4. dict 변환: id/name/short_id/entity_type/description/stable_traits/t2i_prompt - short_id/description/t2i_prompt: None → "" fallback - stable_traits: None → "{}" fallback r)active_episode_canon_idsrr)r*nameshort_idr description stable_traits t2i_prompt)app.core.entity_identityrdr!r"rzrr{r*rrrerfrrgrhri)r#r.rd canon_ids entities_ormes r&load_episode_entity_dictsz1ScenePersistenceService.load_episode_entity_dictss F, HHd&& 4  HHNN; ' VKNN&&y1 2 SU  "  "ddJJ," }} }}2!"!8Dll0b "   sA'C0c|jjtjtj|j k(tj |k(tjdk(tjdk\tjdk7jtjj}|Dcgc]}|j|j|j|j|jxsd|j xsd|j"xsd|j$xsd|j&xsd|j(xsd|j*d }}||fScc}w)u&에피소드의 선택된 SceneStill을 dict + ORM tuple로 로드. W5 F22 Phase B.22.10 (2026-04-23): scene_image_service.generate_images의 still ORM → dict 변환 블록(~29 LOC)을 이관. 필터: - project_id + episode_id - is_selected == True (shot-more: 선택된 샷만) - still_index >= 0 - status != "stale" 정렬: still_index ASC dict 변환 키: id / still_index / scene_index / shot_index / screenplay_scene_heading / beat_title / still_frame_prompt / camera_json / lighting_json / visible_entities_json / dependent_scene_id None fallback: - screenplay_scene_heading / beat_title / still_frame_prompt: "" - camera_json / lighting_json: "{}" - visible_entities_json: "[]" - dependent_scene_id: None 그대로 Returns: (stills_dict_list, stills_orm_list) — populate_t2i_prompts가 ORM 리스트 입력을 요구하므로 tuple로 반환. TrrOrrr) r*rWr shot_indexscreenplay_scene_heading beat_titlestill_frame_prompt camera_json lighting_jsonrdependent_scene_id)r!rzrr{r%r"r.rVrWr4r~rr*rrprqrrrsrtrurrv)r#r. stills_ormsrs r&load_episode_still_dictsz0ScenePersistenceService.load_episode_still_dictss5> HHNN: & V%%)9)99%%3&&$.&&!+!!W, Xj,, - SU 4   dd }} }}ll,-,F,F,L"ll0b&'&:&:&@b }}4!"!8D)*)@)@)HD&'&:&:    z!!! sBE")r$ OrmSessionr%rreturnNone)rPList[Dict[str, Any]]rQDict[str, Any]r{zTuple[List[str], List[Path]])rir~r.rr_rr{z/Tuple[List[str], Optional[str], Dict[str, Any]])rAr) r-rr.rr_rrrr{z str | None)rrr{zOptional[Dict[str, Any]])rrr{z Optional[str])rr}r.rr{zsRH&C,.C,&C, & C,JE.$E.25E.GJE. 8E.R0++),+++  +Z$$ !$L,H6.H68$8 8  8~EI o $o !o 1 o *B o  o b            DZZZ' Z % Z  ZZZ Zx>,*X$ L:":" 6:"r()4r __future__rr.rloggingr7rrpathlibrtypingrrr r r sqlalchemy.ormr rzapp.core.configr app.core.errorsrrr#app.services.image_capture.annotaterapp.i18n.loaderrapp.modules.llm.gemini_key_poolrr_rrrrrrrrapp.modules.llm.openai_clientr!app.modules.world_guide_generatorr"app.services.image_service_helpersr__all__ getLoggerrrrrIr(r&rs|2#  '330$$6HI7A? $ %   8 $v"v"r(