From fa3d60443dc020ffcdb700855c7cc6ed4636747d Mon Sep 17 00:00:00 2001
From: emile <e.emile@ositcom.netm>
Date: Fri, 12 Jul 2024 10:33:12 +0300
Subject: [PATCH] new

---
 .../__pycache__/consumers.cpython-310.pyc     | Bin 4995 -> 7463 bytes
 osinaweb/support/consumers.py                 | 126 +++++++++++++++++-
 2 files changed, 125 insertions(+), 1 deletion(-)

diff --git a/osinaweb/support/__pycache__/consumers.cpython-310.pyc b/osinaweb/support/__pycache__/consumers.cpython-310.pyc
index c5d5339f1bfcbc62cb1b61724be4a7c6b9190d5b..39ccef5230d3f8ee2e9f157b7118171b58fb7066 100644
GIT binary patch
delta 3497
zcmaJ@&5s;M74NF<>F(+2`PdJ#yRm~mvFQ*yunCS6CB~2_L`bYZb`#J-G8#{{cW1ow
z;p!g8UV0cL=Yo_~BDKWHhgqR0vN$12ToCXFzzw*xkPs)12)Lox=J%>*W_N<w8TG4I
zRj*!Ey^r6kyQe>WrPL`FJp;effBE?OPl8{TE-|*2zQ@iyC%g}gbw?D0kJc4MQ9_#+
zWl=%vi5W4AwjkzKjbQ%4N9=c2+ARA6AF6D8uj7lp$P6PkhAd&btj`lZ<bpUeF$KTD
z<#AyqM$;75k|A>Uc;AXG^m9%7E<@`i)?LmFVXPXEw;_K{IKpkPgX9Jx55eyzTzE@H
zKZmw}))szZC%MUH#e3EPO1LOtjf1siv~KJ+^Gy$H3yA~j$Hif3*ASH*tDjHYH;i}v
zz89C1d;**740ykg6o!>ugBdrwVm8S)XT;n=cMIlMGB3Opw&QAiryFKAXrsN6m2_L(
zthL2fC}kc74R~gekm_WGDDHG=5ya(-n9k;+!QRk#<$Af-6}335%CJ_C8=ZFMPPqJN
zsv)w<cyPQfu#{4H9-8G#MCb@vL4;9VHo98V^~P3sxfX8*R_4}(2nV8i?T&nfq{~F+
zKyd0}+^F9O<Eq{+%hR%I7wfXp=meu{27GVRU^cUw5zd?2>eNJ(nHym&=SizW<Tyy?
zZOBfqTaCiDkWXP?kojwBtGCsi<swNQB0`7PXF5#WGay+-%YHMCYxT_*T##8&?N%sD
zm<)V*nq=~Ecss7bfVK6~gssxK<kx6Er+lXkblw<X#JbiIcQS8s$0+ml_4QTd1zI*U
zvPf;Rw+t|@$+INk$gmzZZiQb*C;B0X$2{h8&Ru3d@+_OVk6qK^)??4qyvtlRz&zt%
z?9V(~4O`%ug)s}Q{h4diJXb0>$Jj{K_S4!HS38~7>z#JgYlZUc=md3+-N!#l?n#1w
z2c3iohCJc1(PYiETF9SFbXuD_?1hzBBDceljY#g;9y$WKnEuU~Ur?b{gbuj<3>xL6
z?d9}&|InZvzJEsB=u9h&qS{7yb~A2m-DjCo@3hGiYRP@B-C*fS`EAnX$~Q=xa{jl*
zdL^A24yI7KNNi5@THPqHm7nEXB&QCfPGVo8{+0BKH#hhO*c<pF3O<*Wm^PemyULW6
zN887qV7%$Tp0c3@Jrf&J<_bV0SrOm{I|@LhFkvyWBa4smAutjc2#nli!royT6$58Q
z8|*9@?6L-eDPzeM=$6YwE)%&5a^F&hkgGIsk;s}JrD)ey*mw08Fu08`qLgqEY`%Hm
zrKdq_>e3WMIee-zJPihyGh#+HLGT9Z0<Jv1nYE(4Do;@Gt78Y|=T3}}(I-|eItRHA
z@I_=+7qMP?ynX5kPT2>UW1O2hq>JSaK6S`nff+|PT8=0uj~J*OtjU|E@)GOkVrzhI
z4h6;%)(#)qyHs+hgxK;zVxy9oC`!*J_Ryue(0(SirsUPA8p}h6snW&lJMH}cj$wN*
zE)0DNk;IW#6Q}94nHU(tzGuRO&cuZ7%0A>C<=AVuQ0CTqumaK>CZz!lUEc$T0fMxB
z>nLD?qQ=hYl*;C{bv4cou8wMpTp|TWh^Uf5e%AOq9dAg{y?9euH>ofxt+Sc%b|Z>W
z+4jno4@j8wrqOa>$d|FxPw_<*?gWK4EAe?mg2g=Uv3Y=`Mn3nU?Tj$+p+-ZWRUU4i
zctW&%z9iQ1o|*h8(kPKBR0h#CP=$aTE;1>kk-uyMxR@}!5i0cPX<7&pqP9@jhzAiK
zIlBn@n?)qJ(X<dzxqBue%0&;a4)qW!B)RcJD6m)75csOJR<I*VE9#7lX5wnQ)(W%y
zRxQ$O`fK~plCGt?Yy&jgp{oB;;HMwwmO}XhXpmG{GP~C85-w8ctHLVjR;r?o@$o$j
ztj~7ZTa9*D-KQ+`_B!k3JzkYe`4(m8(NkFa3w#lk-dT7A-r=Z5k9>=ps7-0Z`EY?Y
zP?3fUPWbH?2;0)r?&1jrX6uDs6v}E8*WzBZ2Ws+dTKo=emU|cMZ`0qnZ!$l%^3R|A
zE=>`HO9C@VNTGs7(y1g#%YYUhqueK$(=bmlblCOWb8Z<l=N|Xxe!iJ!><?+fYp{*<
zkKQu-(*wKk342i`%@tBauU`#UCHV#7CnYFzHfs@zy?)5acKTQU%cnXdLYem@NS>rf
zx?FsDT#jxQPqHliS@E4CHCjedC+kGMLgcGN2(I;w7DBMU$M<i#noBoweOrcUGk=&%
zk*=1`v+L=Hr7zi=w59<oEEN7lY!hVrNc!CDV(R1;7ff_jKu{G7_=@b4&{lf1e7Nu*
zVp|~F$4UM{wfquWm9Ju8Z459f04*ewkd!d8O+?+jOPnMU5m9Pm;uP>awZDv~Y-W9<
zM{{cVE#lrMa<CB#`*7yRB>ox^l|af_cd2`u$Q>e=h+Ii;7U$AG&n$9-rT>`e{(oCj
z$<ekhCt&|c-5(K2(&6lz>|*-&*_8r$LDDoNp?KMSwbc>5t?&Y&Npuv%H+-ao%ly%Q
N%vZQEs9cyo^<Tx85hMTr

delta 1156
zcmZ{i%TE(Q7{GV7+ji-LXJyMn4@7|#4I(B23IalX@=yu_3Y(Q(9<{X1>?}$G_J9`?
zHR@cA!Gkd#4F`^L@#Y_3#*>~+Jb3ls_YE~s6Wh#hznSlwZ@$-?o~@Shd^{de;Mer|
z>Eb8jUHKRx$M`%su1zRrWM`MW*Z4<LSL_E9resJ)-B2<ChdAnEb(1&&*l8@dLAFD$
zlr7?DF9Mq?3&W|NDcd6Ojclk}Dp4E-`~^qTrb;Wo6|Dpa!}nZjE#z}KcY&?sbJnt*
zbFwZq143i#1(%kgRTK=0B@54tQUmWN5p@XZP8w?26_1I~nw|AskA_j%1Q3xWn)eHq
z=jI$*3kPO^wxF^Tl|gsS%`s}?fy7aingOR_c^GFkQ8iT~5q`1iQ5-MHxFC~G{-vsS
z(Ig@aAu{(Kn~lnhJZ3ZBGgT3h&MnMEXv=Ih`<93@G_)L>*``KA;7w>4nb0y`J|}{X
zzgqA>BO}BRXcwY~4^-C#J3t)dGu0^)=G)cnAq<mt@I510r-N7y%foK!ica)KJr;{n
zoqsnP`EbowGR|8QD<s9ACr*;-oezoE<Wx7_??J>6X8>k7J%BP6SOk__Cc?|MXER1+
z)^vowtZi)@MXkQzdn~`|Qke$r#cO?ta{yB>rNF<{c85wiv>AuVJRdiv>if}d05OPY
zL!3a|#B7Wq5XWHsz_esGdMreTAeV#WJdY>4$S_YOkB|$zKc0->?KN2R5`U8HtGNuK
zsgBZlJi3Bt$LjIDgciDw+p9Z2lW9^Ey6rfwW8Gd)!^Fke%EBF&S$+X}QyM*uy0$|#
zyfcEpv?<0#uOY4@<SP>>$@0~TSXw%o-1mcZq-lg4RBVx`luz;9`c!ceHPZJKN;eSl
zm1&f4JpQd~^pDZ7P;VoobJ@ft+|D3o5&M-#>F*I2M$Wx!@r{NW^?|~lH5C5el4Wd3
z#T@wX(a$Z!93N~<kv{&gaWsU@f`dK7=n(qZ)x6_p-97?`-XTCti4mAa5-a_G%av;7
HK%)5<uPgt&

diff --git a/osinaweb/support/consumers.py b/osinaweb/support/consumers.py
index f146a2ce..dfda7ed2 100644
--- a/osinaweb/support/consumers.py
+++ b/osinaweb/support/consumers.py
@@ -50,14 +50,138 @@ class TicketRoomConsumer(WebsocketConsumer):
         )
         self.modify_online_user()
 
+    def receive(self, text_data): 
+        text_data_json = json.loads(text_data)
+        event_type = text_data_json.get('event_type')
+        
+        if event_type == 'typing':
+            event = {
+                'type': 'typing_handler',
+                'user': self.scope['user']
+            }
+            async_to_sync(self.channel_layer.group_send)(
+                self.ticket_number, event
+            )
+        elif event_type == 'stop_typing':
+            event = {
+                'type': 'stop_typing_handler',
+            }
+            async_to_sync(self.channel_layer.group_send)(
+                self.ticket_number, event
+            )
+        elif event_type == 'update_reaction':
+            reaction = text_data_json['reaction']
+            update_id = text_data_json['update_id']
+            event = {
+                'type': 'reaction_handler',
+                'update_id': update_id,
+                'reaction': reaction,
+                'user': self.scope['user']
+            }
+            async_to_sync(self.channel_layer.group_send)(
+                self.ticket_number, event
+            )
+        else:
+            body = text_data_json['description']
+            file_paths = text_data_json['filePath']
+            ticketupdate = TicketUpdate.objects.create(
+                added_by=self.user,
+                description=body,
+                ticket=self.ticket,
+                date_added=datetime.now()
+            )
+            for file_path in file_paths:
+                ticket_attachment = TicketAttachment(
+                    ticket_update=ticketupdate,
+                    file_path=file_path  
+                )
+                ticket_attachment.save()
+            event = {
+                'type': 'update_handler',
+                'update_id': ticketupdate.id
+            }
+            async_to_sync(self.channel_layer.group_send)(
+                self.ticket_number, event
+            )
+
+    def update_handler(self, event):
+        update_id = event['update_id']
+        update = TicketUpdate.objects.get(id=update_id)
+        context = { 
+            'update': update,
+            'user': self.user
+        }
 
 
+        html = render_to_string("details_templates/partials/new-ticket-message.html", context=context)
+        self.send(text_data=json.dumps({
+            'event_type': 'update',
+            'html': html
+        }))
+
+    def typing_handler(self, event):
+        context = {
+            'user': event['user']
+        }
+        html = render_to_string("details_templates/partials/typing-message.html", context=context)
+        self.send(text_data=json.dumps({
+            'event_type': 'typing',
+            'html': html
+        }))
+
+    def stop_typing_handler(self, event):
+        self.send(text_data=json.dumps({
+            'event_type': 'stop_typing'
+        }))
+
+    def reaction_handler(self, event):
+        update_id = event['update_id']
+        reaction = event['reaction']
+        user = self.user
+        
+        update = TicketUpdate.objects.get(id=update_id)
+        existing_reaction = TicketUpdateReaction.objects.filter(ticket_update=update, customer=user).first()
+        new_reaction = None
+        if existing_reaction:
+            # If the existing reaction type is equal to the new reaction, delete it
+            if existing_reaction.reaction == reaction:
+                existing_reaction.delete()
+            else:
+                # If not, delete all previous reactions and add a new one
+                TicketUpdateReaction.objects.filter(ticket_update=update, customer=user).delete()
+                new_reaction = TicketUpdateReaction.objects.create(
+                    ticket_update=update, 
+                    reaction=reaction,
+                    customer=user
+                )
+        else:
+            # If there's no existing reaction, simply add the new one
+            new_reaction = TicketUpdateReaction.objects.create(
+                ticket_update=update, 
+                reaction=reaction,
+                customer=user
+            )
+    
+        self.send(text_data=json.dumps({
+            'event_type': 'reaction',
+            'update_id': update_id,
+            'reaction': new_reaction.reaction if new_reaction else None
+        }))
+
     def modify_online_user(self):
         connections = TicketConnection.objects.filter(ticket=self.ticket, terminated_at__isnull=True)
+        online_connections = []
+        for connection in connections:
+            connection_data = {
+                'first_name': connection.user.first_name,
+                'last_name': connection.user.last_name,
+            }
+            online_connections.append(connection_data)
+
         event = {
             'type': 'user_connection_handler',
             'user': self.user,
-            'connections': list(connections.values()),
+            'connections': online_connections,
         }
         async_to_sync(self.channel_layer.group_send)(
             self.ticket_number, event