B

��f�	�@s�dd
lm
Z

ddlmZ
ddlmZ
ddlmZ
e���	dddd	d
ddd
ddddddddddddddddd�Z
de
gg
degg
edg
i
d �ZGd!d"�d"e�Zd#S)$�)
�OrderedDict)
�get_address_family)
�fibmsg�)
�RTNL_Object�familyZdst_lenZsrc_lenZtos�action�flagsZFRA_DSTZFRA_SRCZFRA_IIFNAMEZFRA_GOTOZFRA_PRIORITYZ
FRA_FWMARKZFRA_FLOWZ
FRA_TUN_IDZFRA_SUPPRESS_IFGROUPZFRA_SUPPRESS_PREFIXLENZ	FRA_TABLEZ
FRA_FWMASKZFRA_OIFNAMEZ
FRA_L3MDEVZ
FRA_UID_RANGEZFRA_PROTOCOLZFRA_IP_PROTOZFRA_SPORT_RANGEZFRA_DPORT_RANGE�rules)�specs�classes�	event_mapcsDeZ
dZd
ZeZdZdZedd��
Z	�f
dd�Z
�f
dd	�Z�ZS)
�Ruler
ZruleTccs,d
}dV
x|
jj
�|�
D]
}|V
qWdS)Nz�
              SELECT
                f_target, f_tflags, f_family,
                f_FRA_PRIORITY, f_action, f_FRA_TABLE
              FROM
                rules
              )�targetZtflagsr�priorityr�table)ZndbZtask_managerZdb_fetch)�cls�view�req�record�r�J/opt/alt/python37/lib/python3.7/site-packages/pyroute2/ndb/objects/rule.py�summary1s


zRule.summaryc
s�t|d
<dd�tj
D�
|_tdi
|_|
d}tdd�|�d�
|�d�
fD�
�
}t|�
dkrdtd	�
�
nt|�
dkr||��|d
<t	t
|�j|
|�

dS)NZiclassc
Ssg|]}
|
d�qS)
r
r)�.0�
xrrr�
<listcomp>@sz!Rule.__init__.<locals>.<listcomp>Zload_rtnlmsg�
c
Ss$g|]}
|
dkr|
d
k	rt|
�
�qS)�N)
r)rrrrrrEs

�src�dstz)src and dst must be of the same IP familyr)r�fields�_fieldsr
�set�get�len�	TypeError�pop�superr�__init__)�self�argv�kwarg�keyZfamilies)
�	__class__rrr(>s











z
Rule.__init__c
s�tt
|�j|
|�
}|dkrdSt�}xPt|j|j|�D]<\}}}||jkrR|||<||jkr6|d
kr6t	�
||d�
q6W||_|S)N)r
r)r'r�load_sqlr�zip�names�specZkspecr!�dict�__setitem__�_key)r)r*r+r1ZnkeyZ	name_normZname_raw�value)
r-rrr.Ps











z
Rule.load_sql)
�__name__�
__module__�__qualname__rrZ	msg_class�apiZ_replace_on_key_change�classmethodrr(r.�
__classcell__rr)
r-rr+s




rN)
�collectionsrZpyroute2.commonrZpyroute2.netlink.rtnl.fibmsgrZobjectsrZ
sql_schemaZunique_indexZschema�initrrrrr�<module>
sB