
    nf                     6    d dl Z d dlmZ  G d de          ZdS )    N)AsyncWebsocketConsumerc                       e Zd Zd Zd ZdS )NotificationConsumerc                 >  K   | j         d         d         d         | _        t          | j                   d| j        z  | _        t          | j                   | j                            | j        | j                   d {V  |                                  d {V  d S )N	url_routekwargs	room_nameznotification_%s)scoper	   printroom_group_namechannel_layer	group_addchannel_nameaccept)selfs    KC:\Users\shree\Desktop\projects\HRMS-project\HRMS\notification\consumers.pyconnectzNotificationConsumer.connect   s      K0:;Gdn04>Ad"### ** 
 
 	
 	
 	
 	
 	
 	
 	

 kkmm    c                    K   t          |           |d         }t          |           |                     t          j        d|i                     d {V  d S )Nmessage)	text_data)r   sendjsondumps)r   eventr   s      r   send_notificationz&NotificationConsumer.send_notification   sa      e	"gii$*i-@"A"AiBBBBBBBBBBBr   N)__name__
__module____qualname__r   r    r   r   r   r      s7          .C C C C Cr   r   )r   channels.generic.websocketr   r   r    r   r   <module>r"      s_     = = = = = =C C C C C1 C C C C Cr   