ʼnN d Z ddlmZmZmZ ddlmZ ddlmZm Z ddl
m Z ddl m
Z
dZ G d d Z G d
d Z G d d
Z G d d Zd Z G d deee ZdS )z8Contains implementations of database retrieveing objects )join LazyMixin
hex_to_bin)
force_text) BadObjectAmbiguousObjectName)chain)reduce) ObjectDBR ObjectDBW
FileDBBase
CompoundDB CachingDBc 6 e Zd ZdZd Zd Zd Zd Zd Zd Z dS ) r zkDefines an interface for object database lookup.
Objects are identified either by their 20 byte bin shac | j S N)has_objselfshas _/builddir/build/BUILD/cloudlinux-venv-1.0.10/venv/lib/python3.11/site-packages/gitdb/db/base.py __contains__zObjectDBR.__contains__ s
| c t d )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 database To be implemented in subclassNotImplementedErrorr s r
has_objectzObjectDBR.has_object" s ""ABBBr c t d )zW :return: OInfo instance
:param sha: bytes binary sha
:raise BadObject:r r r s r infozObjectDBR.info+ ""ABBBr c t d )z[:return: OStream instance
:param sha: 20 bytes binary sha
:raise BadObject:r r r s r streamzObjectDBR.stream1 r! r c t )z+:return: amount of objects in this databaser r s r sizezObjectDBR.size7 !###r c t )zGReturn iterator yielding 20 byte shas for all objects in this data baser r% s r sha_iterzObjectDBR.sha_iter; r' r N)
__name__
__module__ __qualname____doc__r r r r# r& r) r r r r s > > C C CC C C C C C $ $ $$ $ $ $ $r r c * e Zd ZdZd Zd Zd Zd ZdS )r z6Defines an interface to create objects in the databasec d | _ d S r _ostream)r argskwargss r __init__zObjectDBW.__init__F s
r c " | j }|| _ |S )ab
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 functionalityr1 )r r# cstreams r set_ostreamzObjectDBW.set_ostreamJ s -
r c | j S )z
Return the output stream
:return: overridden output stream this instance will write to, or None
if it will write to the default streamr1 r% s r ostreamzObjectDBW.ostreamV s } r c t d )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 writtenr r )r istreams r storezObjectDBW.store^ s ""ABBBr N)r* r+ r, r- r5 r8 r: r= r. r r r r B s[ @@
C C C C Cr r c . e Zd ZdZ fdZd Zd Z xZS )r
z}Provides basic facilities to retrieve files of interest, including
caching facilities to help mapping hexsha's to objectsc V t || _ dS )aY Initialize 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)superr5
_root_path)r root_path __class__s r r5 zFileDBBase.__init__q s& #r c | j S )z':return: path at which this db operates)rA r% s r rB zFileDBBase.root_path| s
r c F t | j t | S )z~
:return: the given relative path relative to our database root, allowing
to pontentially access datafiles)r rA r )r rela_paths r db_pathzFileDBBase.db_path s DOZ %:%:;;;r )r* r+ r, r- r5 rB rG
__classcell__rC s @r r
r
l s` > >$ $ $ $ $ < < < < < < z'_databases_recursive.. s1 IIRjZ.H.HIbIIIIIIr c 3 D K | ]}t |t |V d S r rQ rS s r rV z'_databases_recursive.. s1 CC2
2z(B(BCBCCCCCCr N)rR r databasesextend_databases_recursiveappend)databaseoutputdbscdbs r rZ rZ s (J'' ""
II3IIIIIICCCCC . .C f - - - - . .
h r c Z e Zd ZdZ fdZd Zd Zd Zd Zd Z d Z
d Z d
d Z d Z
xZS )r zA 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 |dk rt | _ d S |dk rt | _ d S t | d S )N_dbs _db_cache)listrb dictrc r@ _set_cache_)r attrrC s r rf zCompoundDB._set_cache_ sS 6>> DIII
[
!VVDNNN GG % % % % %r c | j | S # t $ r Y nw xY w| j D ]%}| | r|| j |< |c S &t | )zL:return: database containing the given 20 byte sha
:raise BadObject:)rc KeyErrorrb r r )r r rU s r _db_queryzCompoundDB._db_query s
>#& & D ) B}}S!!
&(s#
nn s
c T | | dS # t $ r Y dS w xY w)NTF)rj r r s r r zCompoundDB.has_object s@ NN3 4 55 s
''c R | | | S r )rj r r s r r zCompoundDB.info s" ~~c""'',,,r c R | | | S r )rj r# r s r r# zCompoundDB.stream s" ~~c""))#...r c D t d d | j D d S )z.:return: total size of all contained databasesc | |z S r r. )xys r z!CompoundDB.size.. s
1q5 r c 3 > K | ]}| V d S r )r& rS s r rV z"CompoundDB.size.. s* *I*I27799*I*I*I*I*I*Ir r )r
rb r% s r r& zCompoundDB.size s) ((*I*Ity*I*I*I1MMMr c 2 t d | j D S )Nc 3 > K | ]}| V d S r )r) rS s r rV z&CompoundDB.sha_iter.. s* 99r{{}}999999r )r rb r% s r r) zCompoundDB.sha_iter s 99ty999::r c * t | j S )z7:return: tuple of database instances we use for lookups)tuplerb r% s r rX zCompoundDB.databases s TY r Fc | j d}| j D ]/}t |t r|| | z }0|S )NF)rc clearrb rR r rM )r rL statrU s r rM zCompoundDB.update_cache s\ ) / /B"i((
/... r c t }t | | t | }t | }|dz dk rt |dz }nt | }d}|D ]m}d} t |d r| | }n| || }n# t $ r Y Nw xY w|r|r||k rt | |}n|st | |S )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: r 0Npartial_to_complete_sha_hex)
rd rZ r lenr hasattrr~ partial_to_complete_shar r )r partial_hexsharX len_partial_hexshapartial_binsha candidaterU full_bin_shas r r~ z&CompoundDB.partial_to_complete_sha_hex s7
FF T9---#N33 0 0 !Q & & '(< = =NN ' 7 7N ) )B L
2 <== b#%#A#A.#Q#QLL#%#=#=nN`#a#aL
) >l!:!:-n=== ( ,N++ +s 1r s
? > , + + + + +
N$$ $$ $$ $$ $$ $$ $$ $$R%C %C %C %C %C %C %C %CT< < < < < < < <8 O O O O O O O O" n n n n nIy n n n n nr