o
    .˜Žj#	  ã                   @   sR   d dl Z d dlZd dlZd dlmZ ddlmZ e  e¡Z	dZ
G dd„ deƒZdS )é    N)ÚPathé   )ÚSQLiteStoragez…
CREATE TABLE update_state
(
    id   INTEGER PRIMARY KEY,
    pts  INTEGER,
    qts  INTEGER,
    date INTEGER,
    seq  INTEGER
);
c                       sB   e Zd ZdZdedef‡ fdd„Zdd„ Zdd	„ Zd
d„ Z	‡  Z
S )ÚFileStoragez.sessionÚnameÚworkdirc                    s"   t ƒ  |¡ || j| j  | _d S ©N)ÚsuperÚ__init__r   ÚFILE_EXTENSIONÚdatabase)Úselfr   r   ©Ú	__class__© úZ/var/www/kodo/Anonymous/send/lib/python3.10/site-packages/pyrogram/storage/file_storage.pyr
   -   s   zFileStorage.__init__c                 C   sÜ   |   ¡ }|dkr%| j� | j d¡ W d   ƒ n1 sw   Y  |d7 }|dkrF| j� | j d¡ W d   ƒ n1 s=w   Y  |d7 }|dkrg| j� | j t¡ W d   ƒ n1 s^w   Y  |d7 }|   |¡ d S )Nr   zDELETE FROM peersé   z'ALTER TABLE sessions ADD api_id INTEGERé   )ÚversionÚconnÚexecuteÚexecutescriptÚUPDATE_STATE_SCHEMA)r   r   r   r   r   Úupdate2   s"   ÿÿÿzFileStorage.updatec                 Ã   st   �| j }| ¡ }tjt|ƒddd�| _|s|  ¡  n|  ¡  | j� | j d¡ W d   ƒ d S 1 s3w   Y  d S )Nr   F)ÚtimeoutÚcheck_same_threadÚVACUUM)	r   Úis_fileÚsqlite3ÚconnectÚstrr   Úcreater   r   )r   ÚpathÚfile_existsr   r   r   ÚopenI   s   €
"ÿzFileStorage.openc                 Ã   s   �t  | j¡ d S r   )ÚosÚremover   )r   r   r   r   ÚdeleteW   s   €zFileStorage.delete)Ú__name__Ú
__module__Ú__qualname__r   r    r   r
   r   r$   r'   Ú__classcell__r   r   r   r   r   *   s    r   )Úloggingr%   r   Úpathlibr   Úsqlite_storager   Ú	getLoggerr(   Úlogr   r   r   r   r   r   Ú<module>   s   
