+j !^SSKJr SSKrSSKrSSKJr SSKJr SSKJrJ r J r SSK J r SSK JrJrJrJrJrJrJrJrJr SSKJr \(aSS KJr "S S \ 5r"S S \ 5r"SS\ 5r"SS\ 5r"SS\ 5r\"SS55r SSSjjr!SSjr"g)) annotationsN) dataclass)datetime) TYPE_CHECKINGAny TypedDict)Session) bulk_insert_assets'bulk_insert_references_ignore_conflictsbulk_insert_tags_and_metadelete_assets_by_idsget_existing_asset_idsget_reference_ids_by_ids%get_references_by_paths_and_asset_ids#get_unreferenced_unhashed_asset_idsrestore_references_by_paths) get_utc_now)ExtractedMetadatac~\rSrSr%SrS\S'S\S'S\S'S\S'S \S 'S\S 'S \S 'S\S'S\S'S\S'Srg) SeedAssetSpecz*Spec for seeding an asset from filesystem.strabs_pathint size_bytesmtime_ns info_namez list[str]tagsfnamezExtractedMetadata | Nonemetadata str | Nonehash mime_typejob_idN__name__ __module__ __qualname____firstlineno____doc____annotations____static_attributes__r%?/home/wildlama/comfy/ComfyUI/app/assets/services/bulk_ingest.pyrrs;4MOMN O J&&  r.rcL\rSrSr%SrS\S'S\S'S\S'S\S 'S \S 'S rg )AssetRow+z Row data for inserting an Asset.ridr!r"rrr#r created_atr%Nr&r%r.r/r1r1+s!* G Or.r1c\rSrSr%SrS\S'S\S'S\S'S\S'S\S 'S\S 'S \S 'S \S'S \S'S\S'S\S'S\S'Srg) ReferenceRow5z)Row data for inserting an AssetReference.rr3asset_id file_pathrrowner_idnamer! preview_iddict[str, Any] | None user_metadatar$rr4 updated_atlast_access_timer%Nr&r%r.r/r6r65sG3 GMNMM I(( r.r6cB\rSrSr%SrS\S'S\S'S\S'S\S'S rg ) TagRowFzRow data for inserting a Tag.rasset_reference_idtag_nameoriginradded_atr%Nr&r%r.r/rBrBFs'M Kr.rBc`\rSrSr%SrS\S'S\S'S\S'S\S 'S \S 'S \S 'S\S'Srg) MetadataRowOz&Row data for inserting asset metadata.rrDkeyrordinalr!val_strz float | Noneval_numz bool | Noneval_boolr=val_jsonr%Nr&r%r.r/rIrIOs-0 H L  ##r.rIc8\rSrSr%SrS\S'S\S'S\S'Srg) BulkInsertResult[zResult of bulk asset insertion.r inserted_refs won_paths lost_pathsr%Nr&r%r.r/rRrR[s)NOr.rRcU(d [SSSS9$[5n/n/n0n0n/nUGH0n [RR U S5n [ [ R"55n [ [ R"55n URU 5 XU 'U RS5n URU U RS5U SU US.5 U RS5nU(aUR5nOU S (aS U S 0nOS nURU U U U S UU S S UU RS5UUUS. 5 U U SU S US.X{'GM3 [X5 [XVs/sHnUSPM sn5nUVs/sHnUSU;dMUPM nn[X5 [X5 [X5nUVs1sHnUUU;dMUiM nnUU- nUVs/sHnUUPM nnU(a [!UU5 U(d[SS[#U5S9$UVs/sH nXvUSPM nn[%UU5n/n/nU(aUHnUUn X{nUSnUU;aMUSHnURUUSUS.5 M URS5nU(a"UR'UR)U55 MuUS (dMURUS SUS S S S S.5 M [+UUUS9 [[#U5[#U5[#U5S9$s snfs snfs snfs snfs snf)aOSeed assets from filesystem specs in batch. Each spec is a dict with keys: - abs_path: str - size_bytes: int - mtime_ns: int - info_name: str - tags: list[str] - fname: Optional[str] This function orchestrates: 1. Insert seed Assets (hash=NULL) 2. Claim references with ON CONFLICT DO NOTHING on file_path 3. Query to find winners (paths where our asset_id was inserted) 4. Delete Assets for losers (path already claimed by another asset) 5. Insert tags and metadata for successfully inserted references Returns: BulkInsertResult with inserted_refs, won_paths, lost_paths r)rTrUrVrr#r"r)r3r"rr#r4r rfilenameNrrr$) r3r8r9rr:r;r<r>r$r4r?r@r) reference_idrrXextracted_metadatar8rY automatic)rDrErFrGrZ)rDrKrLrMrNrOrP)tag_rows meta_rows)rRrospathabspathruuiduuid4appendgetto_user_metadatar rr rrr lenrextend to_meta_rowsr )sessionspecsr: current_time asset_rowsreference_rowspath_to_asset_idasset_id_to_ref_dataabsolute_path_listspec absolute_pathr8rYr#rZr>rinserted_asset_ids winning_pathsr_inserted_paths losing_pathslost_asset_idswinning_ref_idsinserted_ref_idsr\ metadata_rowsref_dataref_idtags r/batch_insert_seed_assetsrds2 a1KK=L!#J)+N'),.$&Z(89 tzz|$4::<( !!-0*2'HH[) ("<0&*   "XXj1 3E3V3V3XM ']'g7M M"$* ,$[)"!.((8,**$0  $)LW "4 * &Yfw+08A!J-8"0WA1Z=DV3VaNW+GD<9'TM'&D D !%7 7 & "M1L9EF&t,NFWn5 <(  "!D d34^D!0IH')M!D'-H+5Hn-F--'.4$'"-$0 ("*.B!C !$$%7%D%DV%LM*%%$$.4)#$#+J#7#'$($( 1"HgMR *+m$|$ W9W  Gs*2L0 L5L5 L:L:,L?/Mc.[U5n[X5$)zHard-delete unhashed assets with no active references. This is a destructive operation intended for explicit cleanup. Only deletes assets where hash=None and all references are missing. Returns: Number of assets deleted )rr )riunreferenced_idss r/cleanup_unreferenced_assetsrs;7C  ::r.))rir rjzlist[SeedAssetSpec]r:rreturnrR)rir rr)# __future__rr^ra dataclassesrrtypingrrrsqlalchemy.ormr app.assets.database.queriesr r r r rrrrrapp.assets.helpersr$app.assets.services.metadata_extractrrr1r6rBrIrRrrr%r.r/rs" !00"   +F I y9"Y $) $  j j jj jZ ;r.