o h@sddlZddlmZddlmZddlmZddlmZddlm Z dd l m Z dd l m Z m Z mZmZmZmZGd d d eZGd ddeZGdddeZdS)N) b64decode)datetime)utc)AnymailBaseWebhookView)AnymailConfigurationError)AnymailInboundMessage)inboundtrackingAnymailInboundEventAnymailTrackingEvent EventType RejectReasonc@s,eZdZdZdZddZddZddZd S) SparkPostBaseWebhookViewz&Base view class for SparkPost webhooks SparkPostcs6t|jd}fdd|D}fdd|DS)Nutf-8csg|]}|qS) unwrap_event).0 raw_eventselfrL/var/www/html/env/lib/python3.10/site-packages/anymail/webhooks/sparkpost.py sz9SparkPostBaseWebhookView.parse_events..cs(g|]\}}}|dur|||qSN)esp_to_anymail_event)r event_classeventrrrrrs  )jsonloadsbodydecode)rrequest raw_eventsunwrapped_eventsrrr parse_eventss  z%SparkPostBaseWebhookView.parse_eventscCsb|d}z |\}|d|}Wnty+t|dkr#d}}ntd|Ynw|||fS)zUnwraps SparkPost event structure, and returns event_class, event, raw_event raw_event is of form {'msys': {event_class: {...event...}}} Can return None, None, raw_event for SparkPost "ping" raw_event={'msys': {}} msysrNz>Invalid SparkPost webhook event has multiple event classes: %r)keys ValueErrorlen TypeError)rr event_classesrrrrrrs      z%SparkPostBaseWebhookView.unwrap_eventcCstr)NotImplementedError)rrrrrrrr.sz-SparkPostBaseWebhookView.esp_to_anymail_eventN)__name__ __module__ __qualname____doc__esp_namer&rrrrrrr s  rc@s eZdZdZeZejejej ej ejej ej ej ejejej ejejd Zidejdejdejdejdejdejd ejd ejd ejd ejd ejdejdejdejdejdejejfdejejejfejejfejejfdZddZdS)SparkPostTrackingWebhookViewzHHandler for SparkPost message, engagement, and generation event webhooks) bouncedelivery injectionspam_complaint out_of_bandpolicy_rejectiondelayclickopengeneration_failuregeneration_rejectionlist_unsubscribelink_unsubscribe110202122232425304050515253546070)8090100c Cs:|dkrtd|j|dtj}z tjt|dtd}Wnt t t fy-d}Ynwz |d}|r8|gnd}Wn t yFg}Ynwz|j |dt j}z|\}}Wn t yaYnwWn t ynd}Ynwt|||dd|d d|d d||d d||d dpi|d d|dd|d S)N relay_messagezkYou seem to have set SparkPost's *inbound* relay webhook URL to Anymail's SparkPost *tracking* webhook URL.type timestamp)tz campaign_id bounce_classtransmission_idevent_id raw_rcpt_to raw_reason rcpt_metatarget_link_url user_agent) event_typerW message_idr\ recipient reject_reason mta_responsetagsmetadata click_urlra esp_event)r event_typesgetrUNKNOWNr fromtimestampintrKeyErrorr+r)reject_reasonsrOTHERr ) rrrrrbrWtagrgrerrrrbsR          z1SparkPostTrackingWebhookView.esp_to_anymail_eventN)r.r/r0r1r signalrBOUNCED DELIVEREDQUEUED COMPLAINEDREJECTEDDEFERREDCLICKEDOPENEDFAILED UNSUBSCRIBEDrkrrrINVALID TIMED_OUTBLOCKEDSPAM AUTORESPONDED SUBSCRIBEDrqrrrrrr32sr          r3c@seZdZdZeZddZdS)SparkPostInboundWebhookViewz+Handler for SparkPost inbound relay webhookcCs|dkrtd|ddkrtdj|dd|dd}|dd r+t|d }t|}|d d|_|d d|_t t j dd||d S)NrUzkYou seem to have set SparkPost's *tracking* webhook URL to Anymail's SparkPost *inbound* relay webhook URL.protocolsmtpzsYou cannot use Anymail's webhooks for SparkPost '{protocol}' relay events. Anymail only handles the 'smtp' protocol)rcontent email_rfc822email_rfc822_is_base64rmsg_fromrcpt_to)rbrWr\rjmessage) rformatrr"r parse_raw_mimerlenvelope_senderenvelope_recipientr rINBOUND)rrrrraw_mimerrrrrs.    z0SparkPostInboundWebhookView.esp_to_anymail_eventN)r.r/r0r1r rtrrrrrrs r)rbase64rrdjango.utils.timezonerbaser exceptionsrr r signalsr r r rrrr3rrrrrs       %]