⚝
One Hat Cyber Team
⚝
Your IP:
216.73.216.23
Server IP:
178.33.27.10
Server:
Linux cpanel.dev-unit.com 3.10.0-1160.108.1.el7.x86_64 #1 SMP Thu Jan 25 16:17:31 UTC 2024 x86_64
Server Software:
Apache/2.4.57 (Unix) OpenSSL/1.0.2k-fips
PHP Version:
8.2.11
Buat File
|
Buat Folder
Eksekusi
Dir :
~
/
lib
/
python2.7
/
site-packages
/
offlineimap
/
folder
/
View File Name :
LocalStatusSQLite.pyc
� ��Vc @ sp d d l Z d d l m Z d d l m Z y d d l Z Wn n Xd d l m Z d e f d � � YZ d S( i����N( t exc_info( t Locki ( t BaseFoldert LocalStatusSQLiteFolderc B s e Z d Z d Z d � Z d � Z d � Z d � Z d � Z d e d � Z d � Z d � Z d � Z d � Z d � Z d � Z d � Z d � Z d e � d � Z d � Z d � Z d d � Z d � Z d � Z d � Z d � Z d � Z d � Z d � Z d � Z RS( sn LocalStatus backend implemented with an SQLite database As python-sqlite currently does not allow to access the same sqlite objects from various threads, we need to open get and close a db connection and cursor for all operations. This is a big disadvantage and we might want to investigate if we cannot hold an object open for a thread somehow.i c C s� d | _ t t | � j | | � | j | _ t j j | j � | j � � | _ i | _ t | _ t j j | j � } t j j | � s� t j | � n t j j | � s� t d | � � n t � | _ y t j | j d t �| _ Wnl t k r t d | j � d t � d � n< t j k rY} t d | j | f � d t � d � n Xt j d k sut d � � y | j j d � } Wn t j k r�| j � n6 Xt! | j" � d � } | t j# k r�| j$ | � n d S( Nt .s- SQLite database path '%s' is not a directory.t check_same_threadsm SQLite backend chosen, but cannot connect with available bindings to '%s'. Is the sqlite3 package installed?.i s� cannot open database file '%s': %s. You might want to check the rights to that file and if it cleanly opens with the 'sqlite<3>' command.i s' Your sqlite is not multithreading safe.s1 SELECT value from metadata WHERE key='db_version'i (% t sept superR t __init__t roott ost patht joint getroott getfolderbasenamet filenamet messagelistt Falset _newfoldert dirnamet existst makedirst isdirt UserWarningR t _dblockt sqlitet connectt connectiont NameErrort NoneR t OperationalErrort threadsafetyt AssertionErrort executet DatabaseErrort# _LocalStatusSQLiteFolder__create_dbt intt fetchonet cur_versiont$ _LocalStatusSQLiteFolder__upgrade_db( t selft namet repositoryR t et cursort version( ( sH /usr/lib/python2.7/site-packages/offlineimap/folder/LocalStatusSQLite.pyR . s< $ $ c C s t S( N( R ( R( ( ( sH /usr/lib/python2.7/site-packages/offlineimap/folder/LocalStatusSQLite.pyt storesmessagesa s c C s | j S( N( R ( R( ( ( sH /usr/lib/python2.7/site-packages/offlineimap/folder/LocalStatusSQLite.pyt getfullnamed s c C s | j S( N( R ( R( ( ( sH /usr/lib/python2.7/site-packages/offlineimap/folder/LocalStatusSQLite.pyt isnewfolderh s c C s | j d � d S( s Delete all messages in the db.s DELETE FROM statusN( t# _LocalStatusSQLiteFolder__sql_write( R( ( ( sH /usr/lib/python2.7/site-packages/offlineimap/folder/LocalStatusSQLite.pyt deletemessagelistm s c C s t } x| s| j j � z� y� | d k r^ | rI | j j | � } q� | j j | � } n3 | r| | j j | | � } n | j j | | � } t } | j j � Wn^ t j k r} | j d d k r� q| j d d k r� | j j d d � t } q� n XWd | j j � Xq W| S( s� Execute some SQL, retrying if the db was locked. :param sql: the SQL string passed to execute() :param vars: the variable values to `sql`. E.g. (1,2) or {uid:1, flags:'T'}. See sqlite docs for possibilities. :param executemany: bool indicating whether we want to perform conn.executemany() or conn.execute(). :returns: the Cursor() or raises an Exceptioni s( cannot commit - no transaction is actives database is lockedt s! Locked sqlite database, retrying.N( R R t acquireR R t executemanyR! t Truet commitR R t argst uit debugt release( R( t sqlt varsR5 t successR, R+ ( ( sH /usr/lib/python2.7/site-packages/offlineimap/folder/LocalStatusSQLite.pyt __sql_writes s. c C s� t | d � r | j j � n t j | j d t �| _ | d k r� | j j d | j | f � | j j d � | j j � n d S( s< Upgrade the sqlite format from version 'from_ver' to currentR R i sA Upgrading LocalStatus cache from version 1 to version 2 for %s:%ss! ALTER TABLE status ADD mtime INTEGER DEFAULT 0; ALTER TABLE status ADD labels VARCHAR(256) DEFAULT ''; UPDATE metadata SET value='2' WHERE key='db_version'; N( t hasattrR t closeR R R R R9 t _msgR* t executescriptR7 ( R( t from_ver( ( sH /usr/lib/python2.7/site-packages/offlineimap/folder/LocalStatusSQLite.pyt __upgrade_db� s c C sG | j j d | j | f � | j j d � | j j � t | _ d S( su Create a new db file. self.connection must point to the opened and valid SQlite database connection.s& Creating new Local Status db for %s:%ss� CREATE TABLE metadata (key VARCHAR(50) PRIMARY KEY, value VARCHAR(128)); INSERT INTO metadata VALUES('db_version', '2'); CREATE TABLE status (id INTEGER PRIMARY KEY, flags VARCHAR(50), mtime INTEGER, labels VARCHAR(256)); N( R9 RB R* R RC R7 R6 R ( R( ( ( sH /usr/lib/python2.7/site-packages/offlineimap/folder/LocalStatusSQLite.pyt __create_db� s c C s- i | d 6t � d 6t � d 6d d 6d d 6S( Nt uidt flagst labelsi t timet mtime( t set( R( RG ( ( sH /usr/lib/python2.7/site-packages/offlineimap/folder/LocalStatusSQLite.pyt msglist_item_initializer� s c C s i | _ | j j d � } x� | D]� } | d } | j | � | j | <t | d � } yN t g | d j d � D]* } t | j � � d k rr | j � ^ qr � } Wn t k r� t � } n X| | j | d <| | j | d <| d | j | d <q" Wd S( Ns( SELECT id,flags,mtime,labels from statusi i i t ,RH RI i RK ( R R R! RM RL t splitt lent stript AttributeError( R( R, t rowRG RH t lbRI ( ( sH /usr/lib/python2.7/site-packages/offlineimap/folder/LocalStatusSQLite.pyt cachemessagelist� s H c C s i | _ d S( N( R ( R( ( ( sH /usr/lib/python2.7/site-packages/offlineimap/folder/LocalStatusSQLite.pyt dropmessagelistcache� s c C s d S( N( ( R( ( ( sH /usr/lib/python2.7/site-packages/offlineimap/folder/LocalStatusSQLite.pyt save� s c C s� g } xr | j j � D]a \ } } | d } d j t | d � � } d j t | d � � } | j | | | | f � q W| j d | d t �d S( s- Saves the entire messagelist to the database.RK R3 RH s , RI sF INSERT OR REPLACE INTO status (id,flags,mtime,labels) VALUES (?,?,?,?)R5 N( R t itemsR t sortedt appendR1 R6 ( R( t dataRG t msgRK RH RI ( ( sH /usr/lib/python2.7/site-packages/offlineimap/folder/LocalStatusSQLite.pyt saveall� s c C s | j S( N( R ( R( ( ( sH /usr/lib/python2.7/site-packages/offlineimap/folder/LocalStatusSQLite.pyt getmessagelist s i c C s� | d k r | S| j | � r3 | j | | � | S| j | � | j | <i | d 6| d 6| d 6| d 6| d 6| j | <d j t | � � } d j t | � � } | j d | | | | f � | S( s� Writes a new message, with the specified uid. See folder/Base for detail. Note that savemessage() does not check against dryrun settings, so you need to ensure that savemessage is never called in a dryrun mode.i RG RH RJ RK RI R3 s , s; INSERT INTO status (id,flags,mtime,labels) VALUES (?,?,?,?)( t uidexistst savemessageflagsRM R R RY R1 ( R( RG t contentRH t rtimeRK RI ( ( sH /usr/lib/python2.7/site-packages/offlineimap/folder/LocalStatusSQLite.pyt savemessage# s 0 c C sU | j | � s t � | | j | d <d j t | � � } | j d | | f � d S( NRH R3 s$ UPDATE status SET flags=? WHERE id=?( R_ R R R RY R1 ( R( RG RH ( ( sH /usr/lib/python2.7/site-packages/offlineimap/folder/LocalStatusSQLite.pyR` < s c C s | j | d S( NRH ( R ( R( RG ( ( sH /usr/lib/python2.7/site-packages/offlineimap/folder/LocalStatusSQLite.pyt getmessageflagsC s c C s| | | j | d <| r+ | | j | d <n d j t | � � } | rb | j d | | | f � n | j d | | f � d S( NRI RK s , s. UPDATE status SET labels=?, mtime=? WHERE id=?s% UPDATE status SET labels=? WHERE id=?( R R RY R1 ( R( RG RI RK ( ( sH /usr/lib/python2.7/site-packages/offlineimap/folder/LocalStatusSQLite.pyt savemessagelabelsG s c C s� g | j � D]' \ } } d j t | � � | f ^ q } | j d | d t �x+ | j � D] \ } } | | j | d <q] Wd S( sY Saves labels from a dictionary in a single database operation. s , s% UPDATE status SET labels=? WHERE id=?R5 RI N( RX R RY R1 R6 R ( R( RI RG t lR[ ( ( sH /usr/lib/python2.7/site-packages/offlineimap/folder/LocalStatusSQLite.pyt savemessageslabelsbulkR s :c C s� g } xE | D]= } | j | d | B} | j d j t | � � | f � q W| j d | d t �x. | D]& } | j | d | B| j | d <qk Wd S( NRI s , s% UPDATE status SET labels=? WHERE id=?R5 ( R RZ R RY R1 R6 ( R( t uidsRI R[ RG t newlabels( ( sH /usr/lib/python2.7/site-packages/offlineimap/folder/LocalStatusSQLite.pyt addmessageslabels] s & c C s� g } xE | D]= } | j | d | } | j d j t | � � | f � q W| j d | d t �x. | D]& } | j | d | | j | d <qk Wd S( NRI s , s% UPDATE status SET labels=? WHERE id=?R5 ( R RZ R RY R1 R6 ( R( Rh RI R[ RG Ri ( ( sH /usr/lib/python2.7/site-packages/offlineimap/folder/LocalStatusSQLite.pyt deletemessageslabelsg s & c C s | j | d S( NRI ( R ( R( RG ( ( sH /usr/lib/python2.7/site-packages/offlineimap/folder/LocalStatusSQLite.pyt getmessagelabelsq s c C ss g | j � D] \ } } | | f ^ q } | j d | d t �x+ | j � D] \ } } | | j | d <qN Wd S( sG Saves mtimes from the mtimes dictionary in a single database operation.s$ UPDATE status SET mtime=? WHERE id=?R5 RK N( RX R1 R6 R ( R( t mtimesRG t mtR[ ( ( sH /usr/lib/python2.7/site-packages/offlineimap/folder/LocalStatusSQLite.pyt savemessagesmtimebulku s +c C s | j | d S( NRK ( R ( R( RG ( ( sH /usr/lib/python2.7/site-packages/offlineimap/folder/LocalStatusSQLite.pyt getmessagemtime~ s c C s4 | | j k r d S| j d | f � | j | =d S( Ns DELETE FROM status WHERE id=?( R R1 ( R( RG ( ( sH /usr/lib/python2.7/site-packages/offlineimap/folder/LocalStatusSQLite.pyt deletemessage� s c C sp g | D] } | | j k r | ^ q } t | � s8 d S| j d t | � t � x | D] } | j | =qX Wd S( s� Delete list of UIDs from status cache This function uses sqlites executemany() function which is much faster than iterating through deletemessage() when we have many messages to delete.Ns DELETE FROM status WHERE id=?( R RP R1 t zipR6 ( R( t uidlistRG ( ( sH /usr/lib/python2.7/site-packages/offlineimap/folder/LocalStatusSQLite.pyt deletemessages� s ( N(! t __name__t __module__t __doc__R& R R. R/ R0 R2 R R R1 R' R# RM RU RV RW R] R^ RL Rc R` Rd Re Rg Rj Rk Rl Ro Rp Rq Rt ( ( ( sH /usr/lib/python2.7/site-packages/offlineimap/folder/LocalStatusSQLite.pyR s8 3 & 5 ( R t sysR t threadingR t sqlite3R t BaseR R ( ( ( sH /usr/lib/python2.7/site-packages/offlineimap/folder/LocalStatusSQLite.pyt <module> s