File manager - Edit - /opt/saltstack/salt/lib/python3.10/site-packages/salt/modules/inspectlib/__pycache__/fsdb.cpython-310.pyc
Back
o ;j.% � @ s` d Z ddlZddlZddlZddlZddlZddlZddlmZ G dd� d�Z G dd� d�Z dS )z+ :codeauthor: Bo Maryniuk <bo@suse.de> � N)� OrderedDictc @ s e Zd ZdZdd� ZdS )� CsvDBEntityz, Serializable object for the table. c s � fdd�|D �S )zm Serialize the object to a row for CSV according to the table description. :return: c s g | ]}t � |��qS � )�getattr)�.0�attr��selfr �P/opt/saltstack/salt/lib/python3.10/site-packages/salt/modules/inspectlib/fsdb.py� <listcomp>' s z*CsvDBEntity._serialize.<locals>.<listcomp>r )r � descriptionr r r � _serialize! s zCsvDBEntity._serializeN)�__name__� __module__� __qualname__�__doc__r r r r r r s r c @ s� e Zd ZdZdd� Zdd� Zdd� Zdd � Zd d � Zd d � Z dd� Z dd� Z dd� Z d,dd�Z dd� Zdd� Zdd � Zd-d d �Zd.d d!�Zd.d"d#�Zd$d%� Zd.d&d'�Zd.d(d)�Zd*d+� ZdS )/�CsvDBzr File-based CSV database. This database is in-memory operating relatively small plain text csv files. c C s& | � |� d| _d| _d| _i | _dS )zP Constructor to store the database files. :param path: FN)�_prepare�_opened�db_path�_tables�r �pathr r r �__init__0 s zCsvDB.__init__c C s( || _ tj �| j �st�| j � d S d S �N)r �os�exists�makedirsr r r r r < s �zCsvDB._preparec C s t j �� �d�S )zY Create label of the database, based on the date-time. :return: z %Y%m%d-%H%M%S)�datetime�utcnow�strftimer r r r �_labelA s z CsvDB._labelc C sF | � � }tj�| j|�| _tj�| j�st�| j� d| _| �� |S )zG Create a new database and opens it. :return: T) r! r r �joinr r r r � list_tables)r �dbnamer r r �newI s z CsvDB.newc C s2 t j�| j|�}t j�|�rtj|dd� dS dS )zL Purge the database. :param dbid: :return: T)� ignore_errorsF)r r r" r �shutil�rmtree)r Zdbidr r r r �purgeX s z CsvDB.purgec C s. t j�| j|�}t j�|�rt �|� dS dS )zF Flush table. :param table: :return: N)r r r" r r �unlink)r �tableZ table_pathr r r �flushe s �z CsvDB.flushc C s0 g }t �| j�D ]}|�|� qttt|���S )zM List all the databases on the given path. :return: )r �listdirr �append�list�reversed�sorted)r � databasesr$ r r r r/ p s z CsvDB.listc C s2 | j st�| j�D ] }| �|�| j |< q | j �� S )zP Load existing tables and their descriptions. :return: )r r r- r � _load_table�keys)r � table_namer r r r# { s zCsvDB.list_tablesc C sX t �tj�| j|�d��}tdd� tt� |��D ��W d � S 1 s%w Y d S )N�rtc S s g | ] }t |�d ���qS )�:)�tuple�split�r Zelmr r r r � s z%CsvDB._load_table.<locals>.<listcomp>) �gzip�openr r r" r r �next�csv�reader)r r5 r+ r r r r3 � s �$�zCsvDB._load_tableNc C sV | � � }| �� r'tj�| j|p|r|d p| �� �| _| js)| �� d| _dS dS dS )z� Open database from the path with the name or latest. If there are no yet databases, create a new implicitly. :return: r TN) r/ � is_closedr r r" r% r r r# )r r$ r2 r r r r< � s � �z CsvDB.openc C s d| _ dS )z7 Close the database. :return: FN�r r r r r �close� s z CsvDB.closec C s | j S )zE Return if the database is closed. :return: rA r r r r r@ � s zCsvDB.is_closedc s� dd� � t j�t j�| j|j��sNt�t j�| j|j�d�� }t� |�� � fdd�t |j � � �D �� W d � n1 s=w Y | �|j�| j|j< dS dS )z� Create a table from the object. NOTE: This method doesn't stores anything. :param obj: :return: c S s t t| ���d�d S )N�'� )�str�typer9 )�itemr r r �get_type� s z0CsvDB.create_table_from_object.<locals>.get_typeZwtc s& g | ]}|d � d� |d �� ��qS )r r7 rD r r: �rH r r r � s ��z2CsvDB.create_table_from_object.<locals>.<listcomp>N)r r r r" r �_TABLEr; r< r> �writer�writerowr8 �__dict__�itemsr3 r )r �objZ table_filer rI r �create_table_from_object� s �� ��z CsvDB.create_table_from_objectFc C s� |r&t t| j|j �� |�| j|j ���}| j|j|d�}|r&|r&td��t � t j � | j|j�d��}t�|��| �|�� W d � dS 1 sJw Y dS )z� Store an object in the table. :param obj: An object to store :param distinct: Store object only if there is none identical of such. If at least one field is different, store it. :return: )�eqz Object already in the database.ZatN)�dict�zipr rJ r4 r �get� __class__� Exceptionr; r< r r r" r r> rK rL �_validate_object)r rO Zdistinct�fieldsZdb_objr+ r r r �store� s �� "�z CsvDB.storec C sx d}t � }| �|j�D ]}| j|||||d�r |�|� d}q |�|� q | �|j� | �|� |D ]}| �|� q2|S )z� Update object(s) in the database. :param obj: :param matches: :param mt: :param lt: :param eq: :return: F��matches�mt�ltrQ T) r/ rT rU �_CsvDB__criteriar. r, rJ rP rY ) r rO r[ r\ r] rQ �updated�objects�_objr r r �update� s z CsvDB.updatec C sn d}t � }| �|�D ]}| j|||||d�s |�|� q d}q | �|j� | �|� � |D ]}| �|� q-|S )z� Delete object from the database. :param obj: :param matches: :param mt: :param lt: :param eq: :return: FrZ T)r/ rT r^ r. r, rJ rP rY ) r rO r[ r\ r] rQ Zdeletedr` ra r r r �delete� s z CsvDB.deletec C s: | j �|j�}|d u rtd|j� d���|�| j |j �S )NzTable z not found.)r rT rJ rV r )r rO Zdescrr r r rW s zCsvDB._validate_objectc C s� |pi � � D ]\}}t||�|kr dS q|pi � � D ]\}}t||�|kr) dS q|p-i � � D ]\}}t||�|kr> dS q0|pBi � � D ]\}}t�|tt||���sW dS qEdS )z� Returns True if object is aligned to the criteria. :param obj: :param matches: :param mt: :param lt: :param eq: :return: Boolean FT)rN r �re�searchrE )r rO r[ r\ r] rQ �field�valuer r r Z __criteria s" ����zCsvDB.__criteriac C s� g }t �tj�| j|j�d��E}d}t�|�D ]4} |s | }q|� } t || �D ]\} } | � d�\} } t | | | � | | �� q&| j | ||||d�rK|�| � qW d � |S 1 sWw Y |S )z� Get objects from the table. :param table_name: :param matches: Regexp. :param mt: More than. :param lt: Less than. :param eq: Equals. :return: r6 Nr7 rZ )r; r< r r r" r rJ r> r? rS r9 �setattr�_to_typer^ r. )r rO r[ r\ r] rQ r` r+ �header�datara Zt_attrZt_dataZt_typer r r rT 4 s& �� � � z CsvDB.getc C s4 |dv r t |�}|S |dkrt|�}|S t|�}|S )N)�intZlong�float)rl rm rE )r rk rF r r r ri N s ��zCsvDB._to_typer )F)NNNN)r r r r r r r! r% r) r, r/ r# r3 r< rB r@ rP rY rb rc rW r^ rT ri r r r r r * s, ! r ) r r> r r; r rd r' � collectionsr r r r r r r �<module> s
| ver. 1.4 |
Github
|
.
| PHP 8.2.30 | Generation time: 0 |
proxy
|
phpinfo
|
Settings