Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/pyroute2/nftables/__pycache__/main.cpython-39.pyc
Ðазад
a ]�h�1 � @ s� d Z ddlmZ ddlmZmZmZmZmZm Z m Z m Z m Z m Z mZmZmZmZmZmZmZmZmZmZmZmZmZ G dd� d�ZG dd� d�Z G dd � d e�Z d S ) � � )� nfgen_msg)�DATA_TYPE_ID_TO_NAME�DATA_TYPE_NAME_TO_INFO�NFT_MSG_DELCHAIN�NFT_MSG_DELRULE�NFT_MSG_DELSET�NFT_MSG_DELSETELEM�NFT_MSG_DELTABLE�NFT_MSG_GETCHAIN�NFT_MSG_GETRULE�NFT_MSG_GETSET�NFT_MSG_GETSETELEM�NFT_MSG_GETTABLE�NFT_MSG_NEWCHAIN�NFT_MSG_NEWRULE�NFT_MSG_NEWSET�NFT_MSG_NEWSETELEM�NFT_MSG_NEWTABLE� NFTSocket� nft_chain_msg� nft_rule_msg�nft_set_elem_list_msg� nft_set_msg� nft_table_msgc @ sH e Zd ZdZdd� Zdd� Zedd� �Zedd � �Zd d � Z d d � Z dS )�NFTSet��table�name�key_type�timeout�counter�commentc K sJ || _ || _| jD ]2}||v r0t| ||| � q|dvrt| |d � qd S )N�r r )r r � __slots__�setattr)�selfr r �kwargs�attrname� r) ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/pyroute2/nftables/main.py�__init__# s zNFTSet.__init__c C s� | j | jd�}t� }| jd ur@t�| j�\}}}||d< ||d< | jd ur^|�d� | j|d< | jdu rvddgi|d < | j d ur�d | j fg|d < d |d < ||d< |S )N)�NFTA_SET_TABLE� NFTA_SET_NAME�NFTA_SET_KEY_TYPEZNFTA_SET_KEY_LENZNFT_SET_TIMEOUT�NFTA_SET_TIMEOUTT�attrs)�NFTA_EXPR_NAMEr! � NFTA_SET_EXPR�NFTNL_UDATA_SET_COMMENT�NFTA_SET_USERDATA� Z NFTA_SET_IDZNFTA_SET_FLAGS) r r �setr r �getr �addr! r" )r& r0 Z set_flagsr Zkey_len�_r) r) r* � as_netlink- s" �zNFTSet.as_netlinkc C s� t �|�d�|�d��}d}|�d�}|rD|�d�}|rDd|v rDd}d }|�d�}|rt|D ]\}}|dkrZ|} qtqZ| |�d �|�d �||�d �||d �S ) Nr. Fr2 r1 r! Tr4 r3 r, r- r/ r )r r7 �get_attrZ get_attrs) �cls�msgZdata_type_namer! �exprr" �udata�key�valuer) r) r* � from_netlinkG s2 � �zNFTSet.from_netlinkc s � f i � fdd�|� � D ���S )Nc s i | ]\}}|� j v r||�qS r) �r$ ��.0r rA �r< r) r* � <dictcomp>i s �z$NFTSet.from_dict.<locals>.<dictcomp>��items�r< �dr) rF r* � from_dictf s ��zNFTSet.from_dictc s � fdd�� j D �S )Nc s i | ]}|t � |��qS r) ��getattr�rE r �r& r) r* rG q � z"NFTSet.as_dict.<locals>.<dictcomp>rC rP r) rP r* �as_dictp s zNFTSet.as_dictc C s t | �� �S �N��strrR rP r) r) r* �__repr__s s zNFTSet.__repr__N) �__name__� __module__� __qualname__r$ r+ r: � classmethodrB rL rR rV r) r) r) r* r s r c @ sH e Zd ZdZdd� Zedd� �Zdd� Zedd � �Zd d � Z d d � Z dS )� NFTSetElem)rA r � expiration� counter_bytes�counter_packetsr" c K sD || _ | jD ]2}||v r*t| ||| � q |dkr t| |d � q d S )NrA )rA r$ r% )r& rA r' r r) r) r* r+ � s zNFTSetElem.__init__c C s� |� d�� d�}|d ur<||_dt|j� |_|�� |j}|� d�|� d�d�}|� d�}|r�|� d�d kr�|� d �}|�|� d �|� d �d �� |� d�}|r�|D ]\}}|dkr�||d< q�| f d|i|��S )N�NFTA_SET_ELEM_KEY�NFTA_DATA_VALUE� �NFTA_SET_ELEM_EXPIRATION�NFTA_SET_ELEM_TIMEOUT)r\ r ZNFTA_SET_ELEM_EXPRr1 r! ZNFTA_EXPR_DATAZNFTA_COUNTER_BYTESZNFTA_COUNTER_PACKETS)r] r^ �NFTA_SET_ELEM_USERDATA� NFTNL_UDATA_SET_ELEM_COMMENTr" rA )r; �data�len�length�decoderA �update) r< r= �modifierrA �kwargZ elem_exprr? � type_namerf r) r) r* rB � s8 � ���� zNFTSetElem.from_netlinkc C s� |d ur"| j |_ |�� |d }n| j }ddd|fgigg}| jd urV|�d| jg� | jd urp|�d| jg� | jd ur�|�dd| jfgg� d|iS ) NrA r_ r0 r` rc rb rd re )rA �encoder �appendr\ r" )r& rk rA r0 r) r) r* r: � s$ � ��zNFTSetElem.as_netlinkc s � f i � fdd�|� � D ���S )Nc s i | ]\}}|� j v r||�qS r) rC rD rF r) r* rG � s �z(NFTSetElem.from_dict.<locals>.<dictcomp>rH rJ r) rF r* rL � s ��zNFTSetElem.from_dictc s � fdd�� j D �S )Nc s i | ]}|t � |��qS r) rM rO rP r) r* rG � rQ z&NFTSetElem.as_dict.<locals>.<dictcomp>rC rP r) rP r* rR � s zNFTSetElem.as_dictc C s t | �� �S rS rT rP r) r) r* rV � s zNFTSetElem.__repr__N) rW rX rY r$ r+ rZ rB r: rL rR rV r) r) r) r* r[ w s % r[ c @ sT e Zd Zdd� Zdd� Zdd� Zdd� Zd d � Zd d � Zd d� Z dd� Z dd� Z dS )�NFTablesc C s | � t� t�S rS )� request_getr r rP r) r) r* � get_tables� s zNFTables.get_tablesc C s | � t� t�S rS )rq r r rP r) r) r* � get_chains� s zNFTables.get_chainsc C s | � t� t�S rS )rq r r rP r) r) r* � get_rules� s zNFTables.get_rulesc C s | � t� t�S rS )rq r r rP r) r) r* �get_sets� s zNFTables.get_setsc K s t t ttd�}| �t|||�S )zG Example:: nft.table('add', name='test0') �r8 �create�delr7 )r r r �_commandr )r& �cmdrl �commandsr) r) r* r � s �zNFTables.tablec K sn t t ttd�}dddddd�}d|v rNd d ||d gd |�d d�ggi|d< d |vr^d|d < | �t|||�S )a; Example:: # # default policy 'drop' for input # nft.chain('add', table='test0', name='test_chain0', hook='input', type='filter', policy=0) rv r r5 � � ra )Z prerouting�input�forward�outputZ postrouting�hookr0 ZNFTA_HOOK_HOOKNUMZNFTA_HOOK_PRIORITY�priority�type�filter)r r r �popry r )r& rz rl r{ �hooksr) r) r* �chain s( ����zNFTables.chainc K sN t t t t ttd�}d|v r>g }|d D ]}|�|� q&||d< | �t|||�S )a� Example:: from pyroute2.nftables.expressions import ipv4addr, verdict # # allow all traffic from 192.168.0.0/24 # nft.rule('add', table='test0', chain='test_chain0', expressions=(ipv4addr(src='192.168.0.0/24'), verdict(code=1))) )r8 rw �insert�replacerx r7 � expressions)r r r �extendry r )r& rz rl r{ r� �expr) r) r* �rule( s � z NFTables.rulec K s\ t ttd�}d|v r |�d�}ntf i |��}|�� }| �t|||�}|dkrXt�|�S |S )a� Example:: nft.sets("add", table="filter", name="test0", key_type="ipv4_addr", timeout=10000, counter=True, comment="my comment max 252 bytes") nft.sets("get", table="filter", name="test0") nft.sets("del", table="filter", name="test0") my_set = nft.sets("add", set=NFTSet(table="filter", name="test1", key_type="ipv4_addr") nft.sets("del", set=my_set) �r8 r7 rx r6 r7 ) r r r r� r r: ry r rB )r& rz rl r{ �nft_setr= r) r) r* �setsF s � z NFTables.setsc K sN t ttd�}t|d t�r:|�d�}|j|d< |j|d< n| jd|d |d d�}t � |j �}|rz|\}}}|� }d|_ nd}|dkr�t � }d|d gd|d gg|d < | �|t�d }t� } |�d �D ]} | �t�| |�� q�| S g } |�d �D ]B} t| t��rt�| �} nt| t��s$t| d �} | �| �|�� q�| |d < | �t |||�S )a� Example:: nft.set_elems("add", table="filter", set="test0", elements={"10.2.3.4", "10.4.3.2"}) nft.set_elems("add", set=NFTSet(table="filter", name="test0"), elements=[{"value": "10.2.3.4", "timeout": 10000}]) nft.set_elems("add", table="filter", set="test0", elements=[NFTSetElem(value="10.2.3.4", timeout=10000, comment="hello world")]) nft.set_elems("get", table="filter", set="test0") nft.set_elems("del", table="filter", set="test0", elements=["10.2.3.4"]) r� r6 r r7 r# NZNFTA_SET_ELEM_LIST_TABLEZNFTA_SET_ELEM_LIST_SETr0 r ZNFTA_SET_ELEM_LIST_ELEMENTS�elements)rA )r r r � isinstancer r� r r r� r r7 r �headerr rq r6 r; r8 r[ rB �dictrL ro r: ry ) r& rz rl r{ r� �foundr9 rk r= r� �elemr) r) r* � set_elemsb sD � � zNFTables.set_elemsN) rW rX rY rr rs rt ru r r� r� r� r� r) r) r) r* rp � s ' rp N) �__doc__Zpyroute2.netlink.nfnetlinkr Z$pyroute2.netlink.nfnetlink.nftsocketr r r r r r r r r r r r r r r r r r r r r r r r r[ rp r) r) r) r* �<module> s dWe
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка