ó rÁìVc@sùddlZddlmZddlmZddlmZddlmZ ddl m Z ddl m Z mZdd lmZdd lmZmZmZmZdd lmZmZmZmZdd lmZmZmZmZmZdd lm Z yddl!m"Z"e"j#Z#Wn)e$k rFddl%Z%e%j%j#Z#nXe dƒZ&ddddddddddde(e)dd„Z*ddddddddddde(de)ddddd„Z+d„Z,d„Z-ddd„Z.e)dd„Z/dS(iÿÿÿÿN(tPool(tsettings(tValidationError(t connection(tQ(tContexttTemplatei(t connections(tEmailt EmailTemplatetPRIORITYtSTATUS(tget_available_backendstget_batch_sizet get_log_leveltget_sending_order(tget_email_templatet parse_emailstparse_priorityt split_emailstcreate_attachments(tsetup_loghandlers(ttimezonetINFOtcCs¯t| ƒ} | tjkr!dntj}|dkr?g}n|dkrTg}n|dkrig}n|dkr~d}n| rÒtd|d|d|d|d|d| d| d |d |d | d |ƒ }nÆ| rö| j}| j}| j }nt |piƒ}t |ƒj |ƒ}t |ƒj |ƒ}t |ƒj |ƒ}td|d|d|d|d |d|d|d|d| d| d |d |ƒ }| r«|j ƒn|S(s• Creates an email from supplied keyword arguments. If template is specified, email subject and content will be rendered during delivery. Rt from_emailttotcctbcctscheduled_timetheaderstprioritytstatustcontextttemplatet backend_aliastsubjecttmessaget html_messageN(RR tnowtNoneR tqueuedRR$tcontentt html_contentRRtrendertsave(tsendert recipientsRRR$R%R&R!RRR"Rtrender_on_deliverytcommittbackendR temailt_context((si/opt/seafile/seafile-server-5.1.3/seahub/thirdpart/django_post_office-2.0.6-py2.7.egg/post_office/mail.pytcreatesR              cCswyt|ƒ}Wn&tk r8}td|jƒ‚nXyt|ƒ}Wn&tk rq}td|jƒ‚nXyt|ƒ}Wn&tk rª}td|jƒ‚nX|dkrÃtj}nt| ƒ} | dkrçtƒ} n| s#| tj kr t dƒ‚n| r#t dƒ‚q#n|rÂ|r>t dƒ‚n|rSt dƒ‚n|rht dƒ‚nt |t ƒr°|}|r¿|j |kr­|jjd |ƒ}q­q¿qÂt||ƒ}n|rð|tƒjƒkrðt d |ƒ‚nt|||||||||||| | d | d |ƒ }| rQt| ƒ} |jj| Œn| tj krs|jd | ƒn|S(Nsrecipients: %ssc: %ssbcc: %ss/send_many() can't be used with priority = 'now's&Can't add attachments with send_many()s9You can't specify both "template" and "subject" argumentss9You can't specify both "template" and "message" argumentss>You can't specify both "template" and "html_message" argumentstlanguages%s is not a valid backend aliasR1R2t log_level(RRR%R(RtDEFAULT_FROM_EMAILRRR R't ValueErrort isinstanceR R6ttranslated_templatestgetRR tkeysR5Rt attachmentstaddtdispatch(R/R.R"R!R$R%R&RRRR>R0R7R1RRR6R2teR3((si/opt/seafile/seafile-server-5.1.3/seahub/thirdpart/django_post_office-2.0.6-py2.7.egg/post_office/mail.pytsend^s\      cCsDg}x'|D]}|jtdt|ƒq Wtjj|ƒdS(sè Similar to mail.send(), but this function accepts a list of kwargs. Internally, it uses Django's bulk_create command for efficiency reasons. Currently send_many() can't be used to send emails with priority = 'now'. R1N(tappendRBtFalseRtobjectst bulk_create(t kwargs_listtemailstkwargs((si/opt/seafile/seafile-server-5.1.3/seahub/thirdpart/django_post_office-2.0.6-py2.7.egg/post_office/mail.pyt send_many¤s cCs]tjjdtjƒjdƒjtdtƒƒtddƒBƒj t ƒŒj dƒt ƒ S(s Returns a list of emails that should be sent: - Status is queued - Has scheduled_time lower than the current time or None R R"tscheduled_time__lteRR>N( RREtfilterR R)tselect_relatedRR'R(torder_byRtprefetch_relatedR (((si/opt/seafile/seafile-server-5.1.3/seahub/thirdpart/django_post_office-2.0.6-py2.7.egg/post_office/mail.pyt get_queued°s "c Cs8tƒ}d\}}t|ƒ}tjd||fƒ|dkrPtƒ}n|r||krk|}n|dkr˜t|dtd|ƒ\}}qt||ƒ}t |ƒ}|j t|ƒ}t g|D]} | d^qσ}t g|D]} | d^qòƒ}nd|||f} tj| ƒ||fS( sR Sends out all queued mails that has scheduled_time less than now or None is,Started sending %s emails with %s processes.ituses_multiprocessingR7s'%s emails attempted, %s sent, %s failed(iiN( RPtlentloggertinfoR(Rt _send_bulkRDRRtmaptsum( t processesR7t queued_emailst total_sentt total_failedt total_emailt email_liststpooltresultstresultR%((si/opt/seafile/seafile-server-5.1.3/seahub/thirdpart/django_post_office-2.0.6-py2.7.egg/post_office/mail.pyt send_queued¼s2           #&  c Cs9|rtjƒn|dkr+tƒ}nd \}}t|ƒ}tjd|ƒy{xt|D]l}|jd|dtƒ}|t j kr¬|d7}tj d|j ƒq^|d7}tj d|j ƒq^WWn9t k r }tj|dtjƒd id d 6ƒnXtjƒtjd |||fƒ||fS(Nis"Process started, sending %s emailsR7tdisconnect_after_deliveryisSuccessfully sent email #%dsFailed to send email #%dtexc_infotextraiôt status_codes2Process finished, %s attempted, %s sent, %s failed(ii(t db_connectiontcloseR(RRRRSRTR@RDR tsenttdebugtidt ExceptionterrortsysRcR( RHRQR7t sent_countt failed_countt email_countR3R RA((si/opt/seafile/seafile-server-5.1.3/seahub/thirdpart/django_post_office-2.0.6-py2.7.egg/post_office/mail.pyRUãs,         *  (0RmtmultiprocessingRt django.confRtdjango.core.exceptionsRt django.dbRRftdjango.db.modelsRtdjango.templateRRRtmodelsRR R R R R RRtutilsRRRRRtlogutilsRt django.utilsRR't ImportErrortdatetimeRSR(RDtTrueR5RBRJRPRaRU(((si/opt/seafile/seafile-server-5.1.3/seahub/thirdpart/django_post_office-2.0.6-py2.7.egg/post_office/mail.pyts> ""(       =   B '