3 ա2^ @sddlmZddlmZmZmZddlmZmZmZmZddl m Z ddl m Z ddl Z ddlZddlZddlZddlZddlZeeddZd e_d ejd <eeZejd ZejZejZejjZe Ze e Zej!d ddZ"ej#dddZ$ej#dddZ%ej#dddZ&ej#dddZ'ej#dddZ(ej#ddd Z)ej#d!d"d#Z*ej#d$d%d&Z+ej#d'd(d'Z,ej#d)d*d)Z-ej#d+d,d+Z.ej#d-d.d/Z/ed0krej0d1d2dS)3)Flask)SocketIOemit join_room)rrender_templatesessionrequest)API) defaultdictNtemplate)Ztemplate_folderTZ nuttertoolsZ SECRET_KEYzmongodb://localhost:27017//cCstdS)Nz index.html)rr r +/home/codelabs/socketengine/socketengine.pychatsrtestcCstjj|dS)N)apploggerdebug)rr r rr!stypingcCstd||dddS)NZincoming_typingroom_id)room)r)datar r rreceive_typing%srZ stoptypingcCstd||dddS)NZincoming_stop_typingr)r)r)rr r rreceive_stop_typing+srZstart_broadcastc Cstjjdt|d}yXtjd|i}tjjdtjj|tjj|dtd||ddtjjdWntjjd YnXdS) Nzemit to broadcast_messageZ target_id_idz1****************** SID Found ********************uidZbroadcast_message)rz/****************** SID End ********************z(SID NOT FOUND WHEN INVITE OR CREATE ROOM)rrrintuserColfind_oner)rrdatafindr r rtest_broadcast1s    r Z start_connectc Csyrt|d}|tjd}tjd|i}|rHddtjii}tj||n tj|tjj t |dt tjWn YnXdS)Nid)rrrz$setrz Connection Established ) rrsidrrZ update_oneZ insert_onerrrstr)rrudatar new_valuesr r r on_start_roomMs   "r&rcCsH|d}|d}|dkr8tjjdt|dt|tt|dS)Nr author_idi@zreceive join data with room z author )rrrr#r)rrauthorr r r on_join_room^s  r)Z enter_roomcCstjj||d}|d}tjdt|i}|rtjj|ddt|ii}tj||td||dt j t|t|}tjj|tjj|ddt j n tjjd dS) Nrr'rz$setZ update_read)rz enter_room z with SID z not found) rrrrrrr#updaterapiZupdate_read_messagerr")rrr'rr%postr r r on_enter_roomgs    r-Z exit_roomcCsh|d}t|d}tjjdtjd|i}|rXtjj|dddii}tj||n tjjddS)Nrr'z5exit room ************************************#%@#%@#rz$unsetz not found)rrrrrrr*)rrr'rr%r r r on_exit_room{s    r/ change_topiccCsXtjjd|d}|d}|d}|d}|d}tj|||||}td||ddS) Nr0rroler'messagetyperoom_incoming_message)r)rrrr+ post_messager)rrr1r(r2type_mesr,r r rr0s  room_messagec Cstjj||d}|d}|d}|d}|d}|d}|d}|d}|d } |d } tj||||| } tjj| td ||d tj|d t|id} | r>tjjdtd||d tj ||} |d} | j d}t t d|}xL|D]D}t |}tj||||| ||| }tjjdt |tjj|qWnB|dkrtjjd|d}tjj|tjdt|i} | dk rd| krtd|| dd n|d} | j d}t t d|}x|D]}t |}tj||||| ||| }tjjdt |tjj|tjdt|i} tjjdtjj| tjjd| dk rd| krtd|| dd td|| dd qWdS)Nrr'namer1datetimekickr2r3categoryr4)rz$ne)rrz5******** ada user di dalam room yang sama ********** Zupdate_read_in_roomZ ListMember,zsend_notif to member id : Znonez#Kick---------------------------KickrrZ delete_roomz1****************** SID Found ********************z1****************** SID End ********************Znew_message_countZ alert_message)rrrr+r5rrrrZupdate_read_message_in_roomsplitlistfilterr#Z send_notif)rrr(Z author_namer1r9r:r;r2r6r<r,rZ list_memberZraw_listZ data_listxZ member_idZ post_notifr r rr7sb               connectcCs(tjjdttjtdddddS)NzMade Connection Z on_connectz You ConnectedT) broadcast)rrrr#rr"rr r r rrBsZ disconnectcCsbtjjttjdtjdtji}|rRtjj|ddddi}tj||n tjjddS)Nz Disconnectedrz$unsetr.)rrz not found) rrrr#rr"rrr*)rr%r r rtest_disconnects rD__main__z0.0.0.0)host)1ZflaskrZflask_socketiorrrrrrZapi.api_requestr collectionsr loggingdatetimejsonsysosZpymongo__name__rrconfigZsocketioZ MongoClientconnZsocketDBdbZusersrnowr+r?Zrouteronrrrr r&r)r-r/r0r7rBrDrunr r r rsF         ^