HEX
Server: Apache
System: Linux pdx1-shared-a1-38 6.6.104-grsec-jammy+ #3 SMP Tue Sep 16 00:28:11 UTC 2025 x86_64
User: mmickelson (3396398)
PHP: 8.1.31
Disabled: NONE
$ pwd: /usr/lib/python3/dist-packages/hgext/__pycache__/
Upload Files
File: //usr/lib/python3/dist-packages/hgext/__pycache__/sqlitestore.cpython-310.pyc
o

�]Lb���	@sldZddlmZddlZddlZddlZddlZddlmZddl	m
Z
mZmZddl
mZddlmZmZmZmZmZmZmZmZmZmZmZmZddlmZmZdd	lm Z m!Z!zdd
lm"Z"e"j#Wne$ypdZ"YnwiZ%e�&e%�Z&e&dde"rd
nddd�dZ'dZ(dZ)dZ*dZ+dZ,dZ-dZ.dZ/dZ0dZ1dZ2dZ3dddddd d!d"e-gZ4dGd#d$�Z5d%d&�Z6Gd'd(�d(ej7�Z8ej9Gd)d*�d*e:��Z;e�<ej=�ej9dd+�Gd,d-�d-e:���Z>e�<ej?�ej9dd.�Gd/d0�d0e:���Z@e�<ejA�Gd1d2�d2e:��ZBGd3d4�d4ejC�ZDd5d6�ZEd7d8�ZFd9d:�ZGe�<ejH�Gd;d<�d<e:��ZId=d>�ZJd?d@�ZKdAdB�ZLdCdD�ZMdEdF�ZNdS)Hamstore repository data in SQLite (EXPERIMENTAL)

The sqlitestore extension enables the storage of repository data in SQLite.

This extension is HIGHLY EXPERIMENTAL. There are NO BACKWARDS COMPATIBILITY
GUARANTEES. This means that repositories created with this extension may
only be usable with the exact version of this extension/Mercurial that was
used. The extension attempts to enforce this in order to prevent repository
corruption.

In addition, several features are not yet supported or have known bugs:

* Only some data is stored in SQLite. Changeset, manifest, and other repository
  data is not yet stored in SQLite.
* Transactions are not robust. If the process is aborted at the right time
  during transaction close/rollback, the repository could be in an inconsistent
  state. This problem will diminish once all repository data is tracked by
  SQLite.
* Bundle repositories do not work (the ability to use e.g.
  `hg -R <bundle-file> log` to automatically overlay a bundle on top of the
  existing repository).
* Various other features don't work.

This extension should work for basic clone/pull, update, and commit workflows.
Some history rewriting operations may fail due to lack of support for bundle
repositories.

To use, activate the extension and set the ``storage.new-repo-backend`` config
option to ``sqlite`` to enable new repositories to use SQLite for storage.
�)�absolute_importN��_)�nullrev�sha1nodeconstants�short)�attr)�ancestor�dagop�encoding�error�
extensions�	localrepo�mdiff�pycompat�	registrar�requirements�util�verify)�
repositoryr)�hashutil�storageutil)�zstd�storage�sqlite.compression�zstd�zlibT)�default�experimentalsships-with-hg-coresexp-sqlite-001sexp-sqlite-comp-001=zstdsexp-sqlite-comp-001=zlibsexp-sqlite-comp-001=nonesexp-sqlite-shallow-files����z�CREATE TABLE delta (    id INTEGER PRIMARY KEY,     compression INTEGER NOT NULL,     hash BLOB UNIQUE ON CONFLICT ABORT,     delta BLOB NOT NULL )zKCREATE TABLE filepath (    id INTEGER PRIMARY KEY,     path BLOB NOT NULL )z4CREATE UNIQUE INDEX filepath_path ON filepath (path)acCREATE TABLE fileindex (    id INTEGER PRIMARY KEY,     pathid INTEGER REFERENCES filepath(id),     revnum INTEGER NOT NULL,     p1rev INTEGER NOT NULL,     p2rev INTEGER NOT NULL,     linkrev INTEGER NOT NULL,     flags INTEGER NOT NULL,     deltaid INTEGER REFERENCES delta(id),     deltabaseid INTEGER REFERENCES fileindex(id),     node BLOB NOT NULL )zJCREATE UNIQUE INDEX fileindex_pathrevnum     ON fileindex (pathid, revnum)zBCREATE UNIQUE INDEX fileindex_pathnode ON fileindex (pathid, node)a�CREATE VIEW filedata AS SELECT     fileindex.id AS id,     filepath.id AS pathid,     filepath.path AS path,     fileindex.revnum AS revnum,     fileindex.node AS node,     fileindex.p1rev AS p1rev,     fileindex.p2rev AS p2rev,     fileindex.linkrev AS linkrev,     fileindex.flags AS flags,     fileindex.deltaid AS deltaid,     fileindex.deltabaseid AS deltabaseid FROM filepath, fileindex WHERE fileindex.pathid=filepath.idzPRAGMA user_version=%dcCs�|�djd�dgt|��d�t||gt|�����}g}d}|D]-\}	}
}|	}|
tkr3|�|�}n|
t	kr:|}n|
t
krDt�|�}ntd|
��|�
|�q"||vr[|||}n|��}|��t�||�}
t|
t�srt|�}
|
S)z&Resolve a delta chain for a file node.aWITH RECURSIVE     deltachain(deltaid, baseid) AS (        SELECT deltaid, deltabaseid FROM fileindex             WHERE pathid=? AND node=?         UNION ALL         SELECT fileindex.deltaid, deltabaseid             FROM fileindex, deltachain             WHERE                 fileindex.id=deltachain.baseid                 AND deltachain.baseid IS NOT NULL                 AND fileindex.id NOT IN ({stops})     ) SELECT deltachain.baseid, compression, delta FROM deltachain, delta WHERE delta.id=deltachain.deltaid�,�?)�stopsNsunhandled compression type: %d)�execute�format�join�len�tuple�list�keys�COMPRESSION_ZSTD�
decompress�COMPRESSION_NONE�COMPRESSION_ZLIB�zlib�SQLiteStoreError�append�pop�reverser�patches�
isinstance�bytes)�db�pathid�node�
revisioncache�stoprids�zstddctx�res�deltas�lastdeltabaseid�deltabaseid�compression�delta�basetext�fulltext�rG�3/usr/lib/python3/dist-packages/hgext/sqlitestore.py�resolvedeltachain�s:���
rIcCsBz|�d|||f�jWStjy |�d|f���dYSw)Nz=INSERT INTO delta (compression, hash, delta) VALUES (?, ?, ?)z!SELECT id FROM delta WHERE hash=?r)r&�	lastrowid�sqlite3�IntegrityError�fetchone)r9rC�hashrDrGrGrH�insertdelta�s�����rOc@seZdZdS)r2N)�__name__�
__module__�__qualname__rGrGrGrHr2sr2c@sTeZdZe��Ze��Ze��Ze��Ze��Z	e��Z
e��Ze��Ze��Z
dS)�
revisionentryN)rPrQrRr�ib�rid�revr;�p1rev�p2rev�p1node�p2node�linkrev�flagsrGrGrGrHrSsrS)�slotsc@sheZdZe��Ze��Ze��Ze��Ze��Z	e��Z
e��Ze��Ze��Z
e��Zejdd�ZdS)�sqliterevisiondeltaN�r)rPrQrRrrTr;rYrZ�basenoder\�baserevisionsize�revisionrD�sidedata�protocol_flags�linknoderGrGrGrHr^sr^)�frozenc@s0eZdZejdd�Zejdd�Zejdd�ZdS)�
sqliteproblemNr_)rPrQrRrrT�warningrr;rGrGrGrHrg(srgc@sleZdZdZdd�Zdd�Zdd�Zdd	�Zd
d�ZdOdd�Z	dd�Z
dd�Zdd�Zdd�Z
dd�Zdd�Zdd�Zdd�Zd d!�ZdPd"d#�Zd$d%�Zd&d'�ZdQd*d+�Zd,d-�Zd.d/�Zd0d1�Zd2d3�Zd
d(d(ejd
fd4d5�Zd6d7�Z	
		
dRd8d9�Z	
	
	(dSd:d;�Z dTd=d>�Z!d?d@�Z"dAdB�Z#dCdD�Z$dUdEdF�Z%	(	(	(	(	(dVdGdH�Z&dIdJ�Z'dPdKdL�Z(	
	dWdMdN�Z)d
S)X�sqlitefilestorez2Implements storage for an individual tracked path.cCsxtj|_||_||_d|_i|_i|_i|_t�	d�|_
||_|dkr0tj
dd�|_t��|_nd|_d|_|��dS)N�
rr!)�level)r�nullid�_db�_path�_pathid�
_revtonode�
_nodetorev�
_revisionsr�lrucachedict�_revisioncache�_compenginer�ZstdCompressor�_cctx�ZstdDecompressor�_dctx�
_refreshindex)�selfr9�pathrCrGrGrH�__init__4szsqlitefilestore.__init__cCs�i|_i|_i|_t|j�d|jf��}|sd|_dS|dd|_|j�d|jf�}t|�D]M\}}|\}}}}}}	}
||krFt	t
d���|tkrNtj
}n|j|}|tkr[tj
}n|j|}t||||||||	|
d�	}
||j|<||j|<|
|j|<q/dS)Nz$SELECT id FROM filepath WHERE path=?rzgSELECT id, revnum, node, p1rev, p2rev, linkrev, flags FROM fileindex WHERE pathid=? ORDER BY revnum ASCs1sqlite database has inconsistent revision numbers�	rUrVr;rWrXrYrZr[r\)rprqrrr+rmr&rnro�	enumerater2rrrrlrS)r{r?�i�rowrUrVr;rWrXr[r\rYrZ�entryrGrGrHrzOsV����

�

�zsqlitefilestore._refreshindexcCs
t|j�S�N)r)rr�r{rGrGrH�__len__�s
zsqlitefilestore.__len__cCstt�t|j���Sr�)�iterr�xranger)rrr�rGrGrH�__iter__�szsqlitefilestore.__iter__cCs|tjkrdS||jvS�NF)rrlrq�r{r;rGrGrH�hasnode�s

zsqlitefilestore.hasnoderNcCstjt|j�||d�S)N)�start�stop)r�iterrevsr)rr)r{r�r�rGrGrH�revs�s�zsqlitefilestore.revscCsJ|tjkrtjtjfS||jvrt�||jtd���|j|}|j|jfS�N�no node)	rrlrrr�LookupErrorrnrrYrZ)r{r;r�rGrGrH�parents�s


zsqlitefilestore.parentscCs>|tkrttfS||jvrt|��|j|j|}|j|jfSr�)rrp�
IndexErrorrrrWrX�r{rVr�rGrGrH�
parentrevs�s
zsqlitefilestore.parentrevscCs6|tjkrtS||jvrt�||jtd���|j|Sr�)rrlrrqrr�rnrr�rGrGrHrV�s



zsqlitefilestore.revcCs*|tkrtjS||jvrt|��|j|Sr�)rrrlrpr��r{rVrGrGrHr;�s


zsqlitefilestore.nodecCst�|||j�Sr�)r�fileidlookuprnr�rGrGrH�lookup��zsqlitefilestore.lookupcCs4|tkrtS||jvrt|��|j|j|}|jSr�)rrpr�rrr[r�rGrGrHr[�s
zsqlitefilestore.linkrevcCs4|tkrdS||jvrt|��|j|j|jt@Sr�)rrpr�rrr\�
FLAG_CENSOREDr�rGrGrH�
iscensored�s

zsqlitefilestore.iscensoredcCs2|�|�}|�|�}t�|j||�}t�|j|�Sr�)rVr	�commonancestorsheadsr�r�maplistr;)r{�node1�node2�rev1�rev2�	ancestorsrGrGrHr��s

z$sqlitefilestore.commonancestorsheadscCst�||j|j�Sr�)r
�descendantrevsr�r�)r{r�rGrGrH�descendants�szsqlitefilestore.descendantscst|dur|durt��stjgS|dur��|�nt}�fdd�|p#gD�}tj�j�j||d�}�fdd�|D�S)Ncsh|]}��|��qSrG�rV��.0�nr�rGrH�	<setcomp>��z(sqlitefilestore.heads.<locals>.<setcomp>)�startrev�stoprevsc�g|]}��|��qSrG)r;)r�rVr�rGrH�
<listcomp>�r�z)sqlitefilestore.heads.<locals>.<listcomp>)	r)rrlrVrr
�headrevssubsetr�r�)r{r�r�r�r�r�rGr�rH�heads�s�zsqlitefilestore.headscCs.|�|�}|j�d|j||f�}dd�|D�S)NzZSELECT  node   FROM filedata   WHERE path=? AND (p1rev=? OR p2rev=?)   ORDER BY revnum ASCcSsg|]}|d�qS)rrG)r�r�rGrGrHr��sz,sqlitefilestore.children.<locals>.<listcomp>)rVrmr&rn)r{r;rVr?rGrGrH�children�s

�	zsqlitefilestore.childrencCsN|tkrdS||jvrt|��|j|}|�|�r t|�|��St|�|��S�Nr)rrpr��renamedr)�readrb)r{rVr;rGrGrH�sizes


zsqlitefilestore.sizeFTcs�|tjtfvr	dSt|t�r��|�}|�jvr"t�|�j	t
d���|�jvr,�j|S�fdd��jD�}|s<d|d<t�j
�j|�j|�jd�}�j|jttB@rVd}|rc��||�|�j|<|S)N�r�csi|]	}�j|j|�qSrG)rrrUr�r�rGrH�
<dictcomp>$�z,sqlitefilestore.revision.<locals>.<dictcomp>����r>F)rrlrr7�intr;rqrr�rnrrtrIrmroryrrr\�FLAG_MISSING_P1�FLAG_MISSING_P2�
_checkhash)r{r;�raw�_verifyhashr=rFrGr�rHrbs2




�
zsqlitefilestore.revisioncOs|j|i|��Sr�)rb)r{�args�kwargsrGrGrH�rawdata=r�zsqlitefilestore.rawdatacCst�|�|��Sr�)r�filtermetadatarbr�rGrGrHr�@r�zsqlitefilestore.readcCst�||�Sr�)r�filerevisioncopiedr�rGrGrHr�Cszsqlitefilestore.renamedcCst�|||�Sr�)r�filedataequivalent)r{r;rFrGrGrH�cmpFr�zsqlitefilestore.cmpccs��|dvrt�d|��dd�|D�}|sdS|j�dd�dgt|��t|jg|��}i}|D]\}	}
|j�d|j|
f�}|��d	||	<q2t	j
|||t|j||||d
�	D]}|VqXdS)N)snodesrslinearNs"unhandled value for nodesorder: %scSsg|]	}|tjkr|�qSrG)rrlr�rGrGrHr�Wr�z1sqlitefilestore.emitrevisions.<locals>.<listcomp>zISELECT revnum, deltaid FROM fileindex WHERE pathid=?     AND node in (%s)r#r$z9SELECT revnum from fileindex WHERE pathid=? AND deltaid=?r)�
deltaparentfn�revisiondata�assumehaveparentrevisions�	deltamode�sidedata_helpers)
r�ProgrammingErrorrmr&r(r)r*rorMr�
emitrevisionsr^�__getitem__)r{�nodes�
nodesorderr�r�r�r�r?�
deltabasesrV�deltaidrDrGrGrHr�IsD�	����
��zsqlitefilestore.emitrevisionscCs6|s|�d�r
t�||�}|�|||||�}|�|�S)Ns
)�
startswithr�packmeta�addrevisionr;)r{�filedata�meta�transactionr[�p1�p2rVrGrGrH�add�s
zsqlitefilestore.addc	Csx|rttd���|du}	|pt�|||�}|	r|�||||�|j�|�}
|
dur+|
S|�||||||�}
||j|<|
S)Ns flags not supported on revisions)	r2rr�hashrevisionsha1r�rq�get�_addrawrevisionrt)r{r�r�r[r�r�r;r\�
cachedelta�validatehashrVrGrGrHr��s�
zsqlitefilestore.addrevisioncs^d}|D�]&\}}	}
}}}
}}d}|tj@r|tO}|tj@r$td��|rH|	tjkr7��|	�s7tj}	|tO}|
tjkrH��|
�sHtj}
|tO}��	|�}|t
kr}��|�r}t�
d�}t�j|dd��}t|
�|}|
d|�t�||�kr}t��j|��|t@s�t�|
|�fdd��r�|tO}||�}|�jvr��j|}|jt@r�|	tjkr�|	|_�j|	|_|jtM_�j�d	�j|	|j|jf�|jt@r�|
tjkr�|
|_�j|
|_ |jtM_�j�d
�j|	|j|jf�|r�|���	|��d}q|tjk�rt�!d|
�}d}nd}||
f}�j"|||||	|
||d�}|�r)|�|�d}q|S)
NTrsunhandled revision flags>lllF)r�cst��|��Sr�)r)r�)�xr�rGrH�<lambda>�sz*sqlitefilestore.addgroup.<locals>.<lambda>z0UPDATE fileindex SET p1rev=?, flags=? WHERE id=?z0UPDATE fileindex SET p2rev=?, flags=? WHERE id=?r�)�
storedeltar\)#r�REVISION_FLAG_CENSOREDr�r2rrlr�r�r�rVrr��struct�calcsizer)r�r�replacediffheaderr�CensoredBaseErrorrnr�deltaiscensoredrrr\rYrqrWrmr&rUrZrX�patchr�)r{r@�
linkmapperr��
addrevisioncb�duplicaterevisioncb�maybemissingparents�emptyr;r�r�re�	deltabaserD�	wireflagsrc�
storeflags�baserev�hlen�oldlen�newlenr[r��textr�rVrGr�rH�addgroup�s�	�


�

�
��
��
zsqlitefilestore.addgroupr�c	Cs�t�d|id�}t|�t|�|��krt�td���|j�d|j	|j
f���d}t|j�d||f��}|D]f}|\}}}	t
|j||	iddi|jd�}
t�|
���}|jd	kra|j�|
�}t}
n|jd
krnt�|
�}t}
n|jdkrx|
}t}
nt�d|j��t|�t|
�kr�|
}t}
t|j|
||�}|j�d
||f�q7t�|���}t|jt||�}|j	|j}|tO}|j�d|||j|f�|j�d|f�|��|j� �dS)Nscensoredr�s5censor tombstone must be no longer than censored dataz(SELECT deltaid FROM fileindex WHERE id=?rzGSELECT id, pathid, node FROM fileindex WHERE deltabaseid=? OR deltaid=?r�r�rr�none� unhandled compression engine: %sz;UPDATE fileindex SET deltaid=?, deltabaseid=NULL WHERE id=?zSUPDATE fileindex SET flags=?, deltaid=?, deltabaseid=NULL WHERE pathid=? AND node=?zDELETE FROM delta WHERE id=?)!rr�r)r�r�Abortrrmr&rrrUrMr+rIryr�sha1�digestrurw�compressr-r1r0r/r�rOr\r�rorzrt�clear)r{�tr�
censornode�	tombstone�censoreddeltaid�rowsr�rUr:r;rF�	deltahash�	deltablobrCr��tombstonedeltaidr\rGrGrH�censorrevisionsp�����
�



��
��zsqlitefilestore.censorrevisioncs0t�|t��d�fdd����D��j�j�S)Nrcr�rGr�r�r�rGrHr�{r�z1sqlitefilestore.getstrippoint.<locals>.<listcomp>)r�resolvestripinfor)r�r[r�)r{�minlinkrGr�rH�
getstrippointws
�zsqlitefilestore.getstrippointcCs`t|�sdS|�|�\}}|t|�krdS|�|�D]}|j�d|j|�|�f�q|��dS)Nz/DELETE FROM fileindex WHERE pathid=? AND node=?)r)r
r�rmr&ror;rz)r{rr�rV�_ignoredrGrGrH�strip�s�zsqlitefilestore.stripcCsgSr�rGr�rGrGrH�files��zsqlitefilestore.filescCsiSr�rG)r{�	nodeorrev�_dfrGrGrHrc�szsqlitefilestore.sidedatacs\i}|rg|d<|rg|d<|rt��|d<|r&t�fdd��jD��|d<|r,d|d<|S)Nsexclusivefilesssharedfilessrevisionscountc3s�|]
}t��|��VqdSr�)r)rb)r�r;r�rGrH�	<genexpr>�s�
�z.sqlitefilestore.storageinfo.<locals>.<genexpr>strackedsizes
storedsize)r)�sumrq)r{�exclusivefiles�sharedfiles�revisionscount�trackedsize�
storedsize�drGr�rH�storageinfo�s�zsqlitefilestore.storageinfoccs��t�|d<|D]6}|�|�}z|�|�Wqty>}zttd�t|�|f|d�V|d�|�WYd}~qd}~wwdS)Nsskipreadsunpacking %s: %s)rr;)�setr;rb�	Exceptionrgrrr�)r{�staterVr;�erGrGrH�verifyintegrity�s�

����zsqlitefilestore.verifyintegritycCs�|dur|dur|�|�\}}|t�|||�krdSz|j|=Wn	ty)Ynwt�|�r7t�|j||��t	t
d�|j��)Nsintegrity check failed on %s)r�rr�rt�KeyError�iscensoredtextr�CensoredNodeErrorrnr2r)r{rFr;r�r�rGrGrHr��s�
zsqlitefilestore._checkhashc	Cs�|jdur|j�d|jf�}	|	j|_|r#|\}
}t|
t�r"|�|
�}
n|dus)J�|}
|
tj	kr3|}nt
�|�|�
|
��|�}|
tj	krGd}n|j|
j}t�|���}
|jdkrb|j�|�}t}n|jdkrot�|�}t}n|jdkry|}t}nt�d|j��t|�t|�kr�|}t}t|j||
|�}t|�}|tj	kr�t}n|j|}|tj	kr�t}n|j|}|j�d|j||||||||f	�j}t |||||||||d�	}||j|<||j!|<||j|<|S)Nz&INSERT INTO filepath (path) VALUES (?)rrr�r�z�INSERT INTO fileindex (    pathid, revnum, node, p1rev, p2rev, linkrev, flags,     deltaid, deltabaseid)     VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?)r~)"rormr&rnrJr7r�r;rrlr�textdiffrbrVrrrUrr�r�rurwrr-r1r0r/rr�r)rOrrqrSrp)r{r;r�r�r[r�r�r�r\r?r�rD�baseidrrrCr�rVrWrXrUr�rGrGrHr��s�
�

�
�




�



����


zsqlitefilestore._addrawrevision)rN)NN)FT)NrN)NNF)r�r�)FFFFFr�)*rPrQrR�__doc__r}rzr�r�r�r�r�r�rVr;r�r[r�r�r�r�r�r�rbr�r�r�r�r�CG_DELTAMODE_STDr�r�r�r�r
r
rrrcrr!r�r�rGrGrGrHri0sp=


		
	

*
�7
�$
�
t]	

�
�rics0eZdZdd�Z�fdd�Zedd��Z�ZS)�sqliterepositorycCsdSr�rGr�rGrGrH�cancopyXrzsqliterepository.cancopycsN���}tt��j|i|��}|r|S�j�d��fdd�}|�d|�|S)NzBEGIN TRANSACTIONcs�j��dSr�)�_dbconn�commitrr�rGrH�committransactionesz7sqliterepository.transaction.<locals>.committransactionssqlitestore)�currenttransaction�superr)r�r+r&�addfinalize)r{r�r��currentrr-��	__class__r�rHr�[szsqliterepository.transactioncCsFt��j}|jr|jd|kr|jdSt|j�d��}||f|_|S)Nrrs	db.sqlite)�	threading�current_thread�identrm�makedb�svfsr()r{�tidr9rGrGrHr+ls


zsqliterepository._dbconn)rPrQrRr*r��propertyr+�
__classcell__rGrGr2rHr)Ws
r)cCstt�t�|��}t|_|�d���d}|dkr'tD]}|�|�q|�	�n|t
kr,nt�t
d���|�d�|S)z3Construct a database handle for a database at path.zPRAGMA user_versionrs(sqlite database has unrecognized versionzPRAGMA journal_mode=WAL)rK�connectr�strfromlocalr8�text_factoryr&rM�
CREATE_SCHEMAr,�CURRENT_SCHEMA_VERSIONrr�r)r|r9r?�	statementrGrGrHr7}s

r7cCsF|�t�tr|�t�|�t�|�t�|�t�|�tj�dSr�)	r��REQUIREMENTr�REQUIREMENT_ZSTD�REQUIREMENT_ZLIB�REQUIREMENT_NONE�REQUIREMENT_SHALLOW_FILESr�NARROW_REQUIREMENT)�ui�	supportedrGrGrH�featuresetup�s




rJcCs|ddkr|||�Sd|vrt�td���hd�}t|�|}|r0t�td�d�t|����d|d<|||�}|�t�|�d	d
�}|dkrQt	sQt�td���|dkr[|�t
�n|d
kre|�t�n|dkro|�t�n	t�td�|��|�
d�r�|�t�|S)N�backendssqlites
sharedrepos3shared repositories not supported with SQLite store>�narrowfilesrK�shallowfilestores6SQLite store does not support repo creation option: %ss, srevlogv1rrrsjstorage.sqlite.compression set to "zstd" but zstandard compression not available to this Mercurial installrr�sDunknown compression engine defined in storage.sqlite.compression: %srM)rr�rrr(�sortedr�rB�configrrCrDrEr�rF)�origrH�
createopts�known�unsupportedrrCrGrGrH�newreporequirements�sP
���

�����

rTc@seZdZdZdd�ZdS)�sqlitefilestoragez)Repository file storage backed by SQLite.cCsd|ddkr|dd�}t|jvrd}nt|jvrd}nt|jvr$d}nt�td���t|j||�S)Nr�/rrrr�sEunable to determine what compression engine to use for SQLite storage)	rCrrDrErr�rrir+)r{r|rCrGrGrH�file�s


��zsqlitefilestorage.fileN)rPrQrRr'rWrGrGrGrHrU�srUcKs4t|vrt|vr|�tj�tS|d||d�|��S)z=Produce a type conforming to ``ilocalrepositoryfilestorage``.)r�featuresNrG)rBrFr�r�!REPO_FEATURE_SHALLOW_FILE_STORAGErU)rPrrXr�rGrGrH�makefilestorage�s
rZcKs8t|vrt|vrtst�td���tS|dd|i|��S)NsWrepository uses zstandard compression, which is not available to this Mercurial installrrG)rBrCrrr�rr))rPrHrr�rGrGrH�makemains��r[cOs ||g|�Ri|��d|_dSr�)�warnorphanstorefiles)rPr{r�r�rGrGrH�verifierinits
r]cCsJtj�t�t�tdt�t�tdt�t�tdt�t�t	j
dt�dS)Nsnewreporequirementssmakefilestoragesmakemains__init__)r�featuresetupfuncsr�rJr
�wrapfunctionrTrZr[r�verifierr])rHrGrGrH�extsetups�racCst|t�r
d|_dSdSr�)r7r)rm)rH�reporGrGrH�	reposetup)s

�rcr�)Or'�
__future__rrKr�r4r1�mercurial.i18nr�mercurial.noderrr�mercurial.thirdpartyr�	mercurialr	r
rrr
rrrrrrr�mercurial.interfacesr�
interfaceutil�mercurial.utilsrrr�__version__�ImportError�configtable�
configitem�
testedwithrBrCrDrErFr@r/r-r0r�r�r�r?rIrO�StorageErrorr2�s�objectrS�implementer�irevisiondeltar^�iverifyproblemrg�ifilestorageri�localrepositoryr)r7rJrT�ilocalrepositoryfilestoragerUrZr[r]rarcrGrGrGrH�<module>s�&8
�

��
?A




,&
A
@ Telegram