File: //usr/lib/python3/dist-packages/boto/mturk/__pycache__/notification.cpython-310.pyc
o
ckF[b � @ sl d Z ddlZzddlmZ W n
ey ddlZY nw ddlZddlZG dd� de�Z G dd� de�Z
dS )z�
Provides NotificationMessage and Event classes, with utility methods, for
implementations of the Mechanical Turk Notification API.
� N)�sha1c @ s: e Zd ZdZdZdZdZdZe� e�Z
dd� Z dd � Z d
S ) �NotificationMessagezlhttp://mechanicalturk.amazonaws.com/AWSMechanicalTurk/2006-05-05/AWSMechanicalTurkRequesterNotification.wsdlz
2006-05-05�&AWSMechanicalTurkRequesterNotification�Notifyz!Event\.(?P<n>\d+)\.(?P<param>\w+)c C s� |d | _ |d | _|d | _|d tjks J dtj ��g | _i }d|v r+|d }n0|D ]-}|| }|�d�rZtj�|�� � }t
|d �}t |d �}||vrTi ||< ||| |< q-|D ] }| j� t
|| �� q]d
S ) z
Constructor; expects parameter d to be a dict of string parameters from a REST transport notification message
� Signature� Timestamp�Version�methodzMethod should be '%s'�EventzEvent.�n�paramN)� signature� timestamp�versionr �OPERATION_NAME�events�
startswith�EVENT_RE�search� groupdict�int�str�appendr
)�self�d� events_dict�k�v�edr r � r �9/usr/lib/python3/dist-packages/boto/mturk/notification.py�__init__. s*
��z NotificationMessage.__init__c C sJ t j}|t j7 }|| j7 }tj|td�}|�|� t� |�
� �}| j |kS )a
Verifies the authenticity of a notification message.
TODO: This is doing a form of authentication and
this functionality should really be merged
with the pluggable authentication mechanism
at some point.
)�key� digestmod) r � SERVICE_NAMEr r �hmac�new�sha�update�base64� b64encode�digestr
)r �
secret_key�verification_input�h�signature_calcr r r �verifyJ s
zNotificationMessage.verifyN)
�__name__�
__module__� __qualname__�NOTIFICATION_WSDL�NOTIFICATION_VERSIONr$ r �
EVENT_PATTERN�re�compiler r! r0 r r r r r # s
r c @ s e Zd Zdd� Zdd� ZdS )r
c C sB |d | _ |d | _|d | _|d | _d|v r |d | _d S d S )N� EventType� EventTime� HITTypeId�HITId� AssignmentId)�
event_type�event_time_str�hit_type�hit_id�
assignment_id)r r r r r r! \ s
�zEvent.__init__c C s d| j | jf S )Nz0<boto.mturk.notification.Event: %s for HIT # %s>)r> rA )r r r r �__repr__f s zEvent.__repr__N)r1 r2 r3 r! rC r r r r r
[ s
r
) �__doc__r% �hashlibr r' � ImportErrorr) r7 �objectr r
r r r r �<module> s �8