o
1]Zg @ s d Z ddlZddlmZ ddlmZ ddlmZm Z ddl
m Z ddl
Z
ddlZddlZddlZddlZddlZddlZddlmZ ddlZddlmZmZmZ ddl Z dd l m Z dd
l m!Z!m"Z" dd l#m$Z$ dd l%m&Z& dd
l'm(Z) ddl*m+Z+ ddl,m-Z- ddl.m/Z/ ddl0m1Z1 ddl2m3Z3m4Z4m5Z5m6Z6m7Z7m8Z8m9Z9m:Z: e;e<Z=G dd de&j>Z?e-G dd de&j@ZAG dd de&j>ZBG dd de&j>ZCG dd d e&j>ZDe-G d d d e&j@Ze-G d d d e&j@ZEdS )!z8
Models declaration for application ``django_mailbox``.
N)
encode_base64)Message)
formatdate parseaddr)encode)NamedTemporaryFile)parse_qsunquoteurlparse)settings) ContentFileFile)
make_msgid)models)
ugettext_lazy)now)python_2_unicode_compatible)utils)message_received)
Pop3Transport
ImapTransportMaildirTransport
MboxTransportBabylTransport MHTransport
MMDFTransportGmailImapTransportc e Zd Z fddZ ZS )ActiveMailboxManagerc t t| jddS )NT)active)superr get_querysetfilterself __class__ G/var/www/html/env/lib/python3.10/site-packages/django_mailbox/models.pyr" + z!ActiveMailboxManager.get_queryset__name__
__module__ __qualname__r"
__classcell__r( r( r& r) r * r c @ s| e Zd ZejedddZejeddedddddZejed ded
ddddZej ed ed ddd
Z
ej ededdddZ e
Ze Zedd Zedd Zedd Zedd Zedd Zedd Zed d Zed d Zed!d" Zed#d$ Zed%d& Z ed'd( Z d)d* Z d+d, Z d-d. Z d/d0 Z!d1d2 Z"d3d4 Z#d;d5d6Z$d7d8 Z%G d9d: d:Z&dS )<MailboxName
max_lengthURIaI Example: imap+ssl://myusername:mypassword@someserver
Internet transports include 'imap' and 'pop3'; common local file transports include 'maildir', 'mbox', and less commonly 'babyl', 'mh', and 'mmdf'.
Be sure to urlencode your username and password should they contain illegal characters (like @, :, etc).TN)r5 help_textblanknulldefaultz
From emaila4 Example: MailBot <mailbot@yourdomain.com>
'From' header to set for outgoing email.
If you do not use this e-mail inbox for outgoing mail, this setting is unnecessary.
If you send e-mail without setting this, your 'From' header will'be set to match the setting `DEFAULT_FROM_EMAIL`.Activea Check this e-mail inbox for new e-mail messages during polling cycles. This checkbox does not have an effect upon whether mail is collected here when this mailbox receives mail from a pipe, and does not affect whether e-mail messages can be dispatched from this mailbox. )r7 r8 r: z Last pollingzThe time of last successful polling for messages.It is blank for new mailboxes and is not set for mailboxes that only receive messages via a pipe.)r7 r8 r9 c C s
t | jS N)r
urir$ r( r( r) _protocol_infot s
zMailbox._protocol_infoc C t | jjS r< )r r> queryr$ r( r( r)
_query_stringx s zMailbox._query_stringc C | j jS r< )r> hostnamer$ r( r( r) _domain| s zMailbox._domainc C rB )z.Returns the port to use for fetching messages.)r> portr$ r( r( r) rE s z Mailbox.portc C r? )z2Returns the username to use for fetching messages.)r r> usernamer$ r( r( r) rF zMailbox.usernamec C r? )z2Returns the password to use for fetching messages.)r r> passwordr$ r( r( r) rH rG zMailbox.passwordc C s | j r| j S d| jj S )z3Returns the location (domain and path) of messages. )rD r> pathr$ r( r( r) location s zMailbox.locationc C s& | j j }d|v r|dd S |S )z.Returns the 'transport' name for this mailbox.+r )r> schemelowersplit)r% rM r( r( r) type s z Mailbox.typec C d| j j v S )z:Returns whether or not this mailbox's connection uses SSL.z+sslr> rM rN r$ r( r( r) use_ssl zMailbox.use_sslc C rQ )z?Returns whether or not this mailbox's connection uses STARTTLS.z+tlsrR r$ r( r( r) use_tls rT zMailbox.use_tlsc C | j dd}|s dS |d S )z9Returns (if specified) the folder to archive messages to.archiveNr rA get)r% archive_folderr( r( r) rW zMailbox.archivec C rV )z5Returns (if specified) the folder to fetch mail from.folderNr rX )r% r\ r( r( r) r\ r[ zMailbox.folderc C sD | j sdS | jdkr)t| j| jr| jnd| j| j| j| jd}| | j
| j |S | jdkrHt | j| jr7| jndd| jd}| | j
| j |S | jdkrft
| j| jrV| jnd| jd}| | j
| j |S | jd krrt| j}|S | jd
kr~t| j}|S | jd krt| j}|S | jd krt| j}|S | jd
krt| j}|S )zReturns the transport instance for this mailbox.
These will always be instances of
`django_mailbox.transports.base.EmailTransport`.
Nimap)rE ssltlsrW r\ gmailT)rE r^ rW pop3)rE r^ maildirmboxbabylmhmmdf)r= rP r rK rE rS rU rW r\ connectrF rH r r r r r r r )r% connr( r( r) get_connection sZ
zMailbox.get_connectionc C s6 | |}|du r dS d|_| tj| |d |S )z+Process a message incoming to this mailbox.NF)sendermessage)_process_messageoutgoingsaver sendr% rk msgr( r( r) process_incoming_message s
z Mailbox.process_incoming_messagec C s( | |}|du r dS d|_| |S )z8Record an outgoing message associated with this mailbox.NT)rl rm rn rp r( r( r) record_outgoing_message s
z Mailbox.record_outgoing_messagec C s0 t }t }| r*| D ]\}}|||< q| D ] }|| || q |S |d rW| |d vrW| D ]\}}|||< q:|d= d| ||d < | d |S | |d vsgd|
d dv rd }| } | rtt | }|s~t
| }
ntj|\} }
|
sd
}
t } | jt j|
tt|jd d || _ | D ]\}
}|| |
< q| t }t | j ||d
< |}|S | }|sd}z |jd d | W n8 t!y t"#d| | |jd d dd Y n t$y t"#d| | |jd d dd Y nw |}|S )Nstrip_unallowed_mimetypesallowed_mimetypesContent-Transfer-Encodingz%Stripped; Content type %s not allowedaltered_message_headerrI text_stored_mimetypes
attachmentzContent-Dispositionz.binT)decode attachment_interpolation_headerasciiz+Unknown encoding %s; interpreting as ASCII!ignorez5Decoding error encountered; interpreting %s as ASCII!)%r get_settings EmailMessage is_multipartitems get_payloadattach_get_dehydrated_messageget_content_type set_payloadrY get_filenameconvert_header_to_unicode mimetypesguess_extensionosrJ splitextMessageAttachmentdocumentrn uuiduuid4hexr sixBytesIOgetvaluerk strpkget_content_charsetrz LookupErrorloggerwarning
ValueError)r% rq recordr newheadervaluepartfilename raw_filename extension_ry key placeholdercontent_charsetr( r( r) r s
W
F
! z Mailbox._get_dehydrated_messagec
C sV t }t }|d r| || | |_d|v r$t|d dd |_d|v r3|d dd |_d|v r?t|d |_ d|v rLt|d |_
n d|v rXt|d |_
| | ||}z|
}W n ty } z
td | W Y d }~d S d }~ww || |d
rzt jj|d
d d |_W n ty Y nw | |S ) Nstore_original_messagesubjectr r3 z
message-idfromtoz Delivered-TozFailed to parse message: %sz in-reply-to)
message_id)r r r~ _process_save_original_messagemailboxr r stripr from_header to_headerrn r as_stringKeyErrorr r set_bodyobjectsr# in_reply_to
IndexError)r% rk rq r bodyexcr( r( r) rl Z sP
zMailbox._process_messagec C s t }|d rQtdd:}tj|dd}|| d W d n1 s*w Y |jj dt
f t |dd W d d S 1 sJw Y d S |jj d
t
t
| dd d S ) Ncompress_original_messagez.eml.gz)suffixw)fileobjmodeutf-8z %s.eml.gzF)rn z%s.eml)r r~ r gzipGzipFilewriter r emlrn r r r
r )r% rk rq r fp_tmpfpr( r( r) r s" "
z&Mailbox._process_save_original_messagec C sp g }| }|s
|S ||D ]}| |}|dur || qt | _tjdkr2| jdgd |S | |S )z1Connect to this transport and fetch new messages.N) last_polling)
update_fields) ri get_messagerr appendr r djangoVERSIONrn )r% conditionnew_mail
connectionrk rq r( r( r) get_new_mail s
zMailbox.get_new_mailc C | j S r< )namer$ r( r( r) __str__ zMailbox.__str__c @ e Zd ZedZedZdS )z Mailbox.Metar1 MailboxesNr, r- r. r verbose_nameverbose_name_pluralr( r( r( r) Meta r r< )'r, r- r. r CharFieldr r r=
from_email BooleanFieldr
DateTimeFieldr Managerr r active_mailboxespropertyr> rA rD rE rF rH rK rP rS rU rW r\ ri rr rs r rl r r r r r( r( r( r) r1 1 s
. a)
r1 c r )IncomingMessageManagerc r )NFrm )r! r r" r# r$ r& r( r) r" r* z#IncomingMessageManager.get_querysetr+ r( r( r& r) r r0 r c r )OutgoingMessageManagerc r )NTr )r! r r" r# r$ r& r( r) r" r* z#OutgoingMessageManager.get_querysetr+ r( r( r& r) r r0 r c r )UnreadMessageManagerc s t t| jd dS )N)read)r! r r" r# r$ r& r( r) r" r* z!UnreadMessageManager.get_querysetr+ r( r( r& r) r r0 r c s e Zd ZejededejdZej edddZ
ej edddZ ejdd d
d
ed ejd Z ej ed
ddZ
eedZejeddd
dZeedZejeddeddZejedd
dZejeddd
d
dZejedd
ded d Ze Ze Z e Z e Z e!d d Z"e!d d! Z#e!d"d# Z$d$d% Z%e!d&d' Z&e!d(d) Z'd*d+ Z(d,d- Z)d.d/ Z*d0d1 Z+ fd2d3Z,d4d5 Z-G d6d7 d7Z. Z/S )8r messagesr1 ) related_namer on_deleteSubjectr3 r4 z
Message IDzdjango_mailbox.MessagerepliesTz In reply to)r r8 r9 r r z From headerz To headerOutgoingF)r: r8 BodyEncodedz)True if the e-mail body is Base64 encoded)r: r7 Processed) auto_now_addReadN)r: r8 r9 zRaw message contentsz Original full content of message)r9 upload_tor7 c C s g }| j | j }|S )a Property allowing one to get the relevant address(es).
In earlier versions of this library, the model had an `address` field
storing the e-mail address from which a message was received. During
later refactorings, it became clear that perhaps storing sent messages
would also be useful, so the address field was replaced with two
separate fields.
) to_addresses from_address)r% addressesr( r( r) address s zMessage.addressc C s | j r
t| j d gS g S )aV Returns the address (as a list) from which this message was received
.. note::
This was once (and probably should be) a string rather than a list,
but in a pull request received long, long ago it was changed;
presumably to make the interface identical to that of
`to_addresses`.
r )r r rN r$ r( r( r) r s zMessage.from_addressc C s4 g }| j dD ]}|r|t|d q|S )z;Returns a list of addresses to which this message was sent.,r )r rO r r rN )r% r r r( r( r) r 0 s zMessage.to_addressesc C sl |j s| jj r
| jj |_ ntj|_ t |jd< t |jd< | j |jd< | | j
t |
S )a* Sends a message as a reply to this message instance.
Although Django's e-mail processing will set both Message-ID
and Date upon generating the e-mail message, we will not be able
to retrieve that information through normal channels, so we must
pre-set it.
z
Message-IDDatez In-Reply-To)r r django_settingsDEFAULT_FROM_EMAILr
extra_headersr r r ro rs emailmessage_from_stringrk r )r% rk r( r( r) reply= s
z
Message.replyc C t | dddd S )zN
Returns the message body matching content type 'text/plain'.
textplainz=
rI r get_body_from_messageget_email_objectreplacer r$ r( r( r) r U
z Message.textc C r )zM
Returns the message body matching content type 'text/html'.
r html
rI r r$ r( r( r) r ^ r z Message.htmlc
C s t }t }| r)| D ]\}}|||< q| D ]
}|| | q |S |d | v rz`t j
j ||d d}| D ]\}}|||< qA|d }|r}| dkr}t
} tt
|j | ddd || dd |d= d|d< n||j |d= t| W |S W |S t jy d
||d ||d < |d Y |S w | D ]\}}|||< q|| |S )
Nr{ )r rv zquoted-printableTF) quotetabsr z=20z Missing; Attachment %s not foundrw rI )r r r~ r r r r
_rehydratekeysr r rY rN r r
encode_quoprir r r r rz r r DoesNotExist)
r% rq r r r r r ry encodingoutputr( r( r) r
g sn
/
zMessage._rehydratec C s$ | j r t| jdS | jdS )zReturns the `body` field of this record.
This will automatically base64-decode the message contents
if they are encoded as such.
r| r )encodedbase64 b64decoder r r$ r( r( r) get_body s zMessage.get_bodyc C s, t jr|d}d| _t|d| _dS )zSet the `body` field of this record.
This will automatically base64-encode the message contents to
circumvent a limitation in earlier versions of Django in which
no fields existed for storing arbitrary bytes.
r Tr| N)r PY3r r r b64encoderz r )r% r r( r( r) r s
zMessage.set_bodyc C sx | j r%| j jdrtj| j d }n| j | j j }| j n| }t
j r2t
|}nt |}| |S )a Returns an `email.message.Message` instance representing the
contents of this message and all attachments.
See [email.Message.Message]_ for more information as to what methods
and properties are available on `email.message.Message` instances.
.. note::
Depending upon the storage methods in use (specifically --
whether ``DJANGO_MAILBOX_STORE_ORIGINAL_MESSAGE`` is set
to ``True``, this may either create a "rehydrated" message
using stored attachments, or read the message contents stored
on-disk.
.. [email.Message.Message]: Python's `email.message.Message` docs
(https://docs.python.org/2/library/email.message.html)
z.gz)r )r r endswithr r r openfilecloser r r r message_from_bytesr r
)r% r flatr( r( r) r s
zMessage.get_email_objectc s. | j D ]}| qtt| j|i |S )z/Delete this message and all stored attachments.) attachmentsalldeleter! r )r% argskwargsry r& r( r) r! s
zMessage.deletec C r r< )r r$ r( r( r) r r zMessage.__str__c @ r )z Message.MetazE-mail messagezE-mail messagesNr r( r( r( r) r r r )0r, r- r. r
ForeignKeyr1 r CASCADEr r r r r r TextFieldr r rm r r r processedr FileFieldr r r r unread_messagesr incoming_messagesr outgoing_messagesr r r r r r r r
r r r r! r r r/ r( r( r& r) r s
9
"r c s e Zd ZejedddedejdZej eddddZ
ej ede j
dZ fd d
Zd d Zd
d Zdd Zdd Zdd Zdd Zdd Zdd ZG dd d Z ZS ) r r Tr )r r9 r8 r r Headers)r9 r8 Document)r c s | j tt| j|i |S )zDeletes the attachment.)r r! r! r )r% r" r# r& r( r) r! s
zMessageAttachment.deletec C sZ | j }|d u r
t S tjdk r(z|d}W n ty' |dd}Y nw t|S )N) r r ) headersr sys version_infor UnicodeDecodeErrorrz r r )r% r/ r( r( r) _get_rehydrated_headers s
z)MessageAttachment._get_rehydrated_headersc C s | | _d S r< )r r/ )r% email_objectr( r( r) _set_dehydrated_headers s z)MessageAttachment._set_dehydrated_headersc C s | }||= | | d S r< r3 r5 )r% r
rehydratedr( r( r) __delitem__ s z MessageAttachment.__delitem__c C s | }|||< | | d S r< r6 )r% r r r7 r( r( r) __setitem__ s z MessageAttachment.__setitem__c C s6 | }t|tjrt|}|du r|S |S dS )z1Returns the original filename of this attachment.N)r3 r
isinstancer string_typesr r )r% file_nameresultr( r( r) r s
z MessageAttachment.get_filenamec C s | S r< )r3 r r$ r( r( r) r ' s zMessageAttachment.itemsc C s$ | | }|d u rtd| |S )NzHeader %s does not exist)r3 r )r% r r r( r( r) __getitem__* s z MessageAttachment.__getitem__c C rB r< )r urlr$ r( r( r) r 0 s zMessageAttachment.__str__c @ r )zMessageAttachment.MetazMessage attachmentzMessage attachmentsNr r( r( r( r) r 3 r r )r, r- r. r r$ r r r% rk r& r/ r( r get_attachment_save_pathr r! r3 r5 r8 r9 r r r> r r r/ r( r( r& r) r s8 r )F__doc__r email.encodersr
email.messager r email.utilsr r quoprir r r r loggingr os.pathr r0 r tempfiler r six.moves.urllib.parser r r
r django.confr r django.core.files.baser r
django.core.mail.messager django.dbr django.utils.translationr r django.utils.timezoner django.utils.encodingr django_mailboxr django_mailbox.signalsr django_mailbox.transportsr r r r r r r r getLoggerr, r r r Modelr1 r r r r r( r( r( r) sT (
&