,je#SrSSKJrJrJr SSKJr SSKJrJ r SSK J r SSK J r Sr"SS 5r"S S 5r"S S 5r"SS5rSr"SS\\\5rg)z8Contains implementations of database retrieveing objects)join LazyMixin hex_to_bin) force_text) BadObjectAmbiguousObjectName)chain)reduce) ObjectDBR ObjectDBW FileDBBase CompoundDB CachingDBc<\rSrSrSrSrSrSrSrSr Sr S r g ) r zgDefines an interface for object database lookup. Objects are identified either by their 20 byte bin shacUR$N)has_objselfshas ڛC:\Users\johnn\AppData\Local\Packages\PythonSoftwareFoundation.Python.3.13_qbz5n2kfra8p0\LocalCache\local-packages\Python313\site-packages\gitdb/db/base.py __contains__ObjectDBR.__contains__s ||c[S5e)z Whether the object identified by the given 20 bytes binary sha is contained in the database :return: True if the object identified by the given 20 bytes binary sha is contained in the databaseTo be implemented in subclassNotImplementedErrorrs r has_objectObjectDBR.has_object"s""ABBrc[S5e)zF:return: OInfo instance :param sha: bytes binary sha :raise BadObject:rrrs rinfoObjectDBR.info+""ABBrc[S5e)zK:return: OStream instance :param sha: 20 bytes binary sha :raise BadObject:rrrs rstreamObjectDBR.stream1r%rc[5e)z+:return: amount of objects in this databaserrs rsizeObjectDBR.size7 !##rc[5e)zGReturn iterator yielding 20 byte shas for all objects in this data baserr*s rsha_iterObjectDBR.sha_iter;r-rN) __name__ __module__ __qualname____firstlineno____doc__rr r#r'r+r/__static_attributes__r1rrr r s(>CC C $$rr c0\rSrSrSrSrSrSrSrSr g) r Bz6Defines an interface to create objects in the databasecSUlgr_ostream)rargskwargss r__init__ObjectDBW.__init__Fs  rc*URnXlU$)a: Adjusts the stream to which all data should be sent when storing new objects :param stream: if not None, the stream to use, if None the default stream will be used. :return: previously installed stream, or None if there was no override :raise TypeError: if the stream doesn't have the supported functionalityr;)rr'cstreams r set_ostreamObjectDBW.set_ostreamJs-- rcUR$)z Return the output stream :return: overridden output stream this instance will write to, or None if it will write to the default streamr;r*s rostreamObjectDBW.ostreamVs }}rc[S5e)a Create a new object in the database :return: the input istream object with its sha set to its corresponding value :param istream: IStream compatible instance. If its sha is already set to a value, the object will just be stored in the our database format, in which case the input stream is expected to be in object format ( header + contents ). :raise IOError: if data could not be writtenrr)ristreams rstoreObjectDBW.store^s""ABBrr;N) r2r3r4r5r6r?rCrFrJr7r1rrr r Bs@  Crr c8^\rSrSrSrU4SjrSrSrSrU=r $)r lzyProvides basic facilities to retrieve files of interest, including caching facilities to help mapping hexsha's to objectsc.>[TU]5 Xlg)a1Initialize this instance to look for its files at the given root path All subsequent operations will be relative to this path :raise InvalidDBRoot: **Note:** The base will not perform any accessablity checking as the base might not yet be accessible, but become accessible before the first access.N)superr? _root_path)r root_path __class__s rr?FileDBBase.__init__qs #rcUR$)z':return: path at which this db operatesrPr*s rrQFileDBBase.root_path|s rc@[UR[U55$)zn :return: the given relative path relative to our database root, allowing to pontentially access datafiles)rrPr)r rela_paths rdb_pathFileDBBase.db_pathsDOOZ %:;;rrU) r2r3r4r5r6r?rQrYr7 __classcell__rRs@rr r ls>$<'_databases_recursive..sI3RjZ.Hbb3( (c3T# UHn[U[5(dMUv M g7frrfrhs rrkrlsC2 2z(BBBrmN)rgr databasesextend_databases_recursiveappend)databaseoutputdbscdbs rrqrqsW(J''  " I3IICCC  -D  hrcf^\rSrSrSrU4SjrSrSrSrSr Sr S r S r SS jr S rS rU=r$)rzA database which delegates calls to sub-databases. Databases are stored in the lazy-loaded _dbs attribute. Define _set_cache_ to update it with your databasesc|>US:Xa[5UlgUS:Xa[5Ulg[TU]U5 g)N_dbs _db_cache)listrzdictr{rO _set_cache_)rattrrRs rr~CompoundDB._set_cache_s1 6>DI [ !VDN G  %rcURU$![a Of=fURH+nURU5(dMX RU'Us $ [ U5e)zD:return: database containing the given 20 byte sha :raise BadObject:)r{KeyErrorrzr r)rrrjs r _db_queryCompoundDB._db_querysd  >>#& &   ))B}}S!!&(s#  ns  cHURU5 g![a gf=f)NTF)rrrs rr CompoundDB.has_objects(  NN3   s  !!cBURU5RU5$r)rr#rs rr#CompoundDB.infos~~c"'',,rcBURU5RU5$r)rr'rs rr'CompoundDB.streams~~c"))#..rc@[SSUR5S5$)z.:return: total size of all contained databasesc X-$rr1)xys r!CompoundDB.size..s15rc3@# UHoR5v M g7fr)r+rhs rrk"CompoundDB.size..s*Iy7799yr)r rzr*s rr+CompoundDB.sizes(*Ityy*I1MMrc4[SUR56$)Nc3@# UHoR5v M g7fr)r/rhs rrk&CompoundDB.sha_iter..s9y{{}}yr)r rzr*s rr/CompoundDB.sha_iters9tyy9::rc,[UR5$)z7:return: tuple of database instances we use for lookups)tuplerzr*s rroCompoundDB.databasessTYYrcURR5 SnURH-n[U[5(dMX#R U5-nM/ U$)NF)r{clearrzrgrra)rr`statrjs rraCompoundDB.update_cachesJ ))B"i((..  rc[5n[X5 [U5n[U5nUS-S:wa[ US-5nO [ U5nSnUH]nSn[ US5(aUR U5nOURXC5nU(dMDU(aXW:wa [U5eUnM_ U(d [U5eU$![a Mf=f)z :return: 20 byte binary sha1 from the given less-than-40 byte hexsha (bytes or str) :param partial_hexsha: hexsha with less than 40 byte :raise AmbiguousObjectName: r0Npartial_to_complete_sha_hex) r|rqrlenrhasattrrpartial_to_complete_sharr)rpartial_hexsharolen_partial_hexshapartial_binsha candidaterj full_bin_shas rr&CompoundDB.partial_to_complete_sha_hexs F T-#N3 0  !Q &'(<=N'7N BL 2<==#%#A#A.#QL#%#=#=n#aL |!:-n==( "N+ +  s"C<C CC)r{rzrc)r2r3r4r5r6r~rr r#r'r+r/rorarr7r[r\s@rrrs@; &(-/N;  ##rrN)r6 gitdb.utilrrrgitdb.utils.encodingr gitdb.excrr itertoolsr functoolsr __all__r r r rrqrr1rrrss ? ,  N$$$$R%C%CT<<8 O O"  nIynr