From 0106b2bfeaac293d607e2762e8d160f2418747b6 Mon Sep 17 00:00:00 2001
From: Pierre HUBERT <pierre.git@communiquons.org>
Date: Mon, 19 May 2025 21:39:29 +0200
Subject: [PATCH] Fix issue

---
 src/server/api/.ws.rs.swp | Bin 0 -> 16384 bytes
 src/server/api/ws.rs      |   2 +-
 src/sync_client.rs        |   4 ++--
 3 files changed, 3 insertions(+), 3 deletions(-)
 create mode 100644 src/server/api/.ws.rs.swp

diff --git a/src/server/api/.ws.rs.swp b/src/server/api/.ws.rs.swp
new file mode 100644
index 0000000000000000000000000000000000000000..6857da0e53fb96429c50e3d5ff8e5c4be1343b59
GIT binary patch
literal 16384
zcmeHNTZ|i58J;!;$|WQO@<5-?Zc8$zjyE)b(n)v2X0vIwWH(E8(|{0i#-3yEWXCh+
z%$fC?)dmzmf(i+>QjsVZwW8uJ5eNZ~h^h||gm?giPz4eKl?N^o;sK-<#P^?b#va>a
zCkh}TG$VZ;d(QR0p8x;HwWE(OEwkg5hb&zCE$gMvJh;*R=CwT^`jKU|eJ%v2hRIjZ
zjl#)2bn8_;;mql%p0s!<;~9~}vf38W6<)`$WmgJ+`%zc&j@zAyMSUjbVvCCzx9!h#
z;);lGXO*H)!GVGUBOFL%<H+&7*0G1)b(GrfpPpiGJ#cZPTk)XaK*5260|f^P4ip?H
zI8bn);6TBF|6dNs_TARULEhbl#G1L^HFV!&ey^B&eW>01EN%q{3Jw$;C^%4Xpx{8k
zfr0}C2MP`p94I(YaG>D8{~!lk&$1rGzJ5XpKi>bR`Tq<1Eb9}%GEf2D0{rI9mUR=j
z4m=H90~)~lfOh~70QUet-fLOk0iFXs2Rs3M7U%#CU=?^T@Xt3{)*pc<fz!YO@Q*iI
z)~mozfzJa0PzM-rAMkeI)i+qyE5I|rMPMB`3!DKKfiiF}@Y3ro>jmH$;0wSOkN{_a
z{lGrpZ}(c(Q^0$Gy}&E4v#ehLH-IOAIp8m^wX9zQzXHAwTm|NV{lM>D1G<0@0!M)Z
zz~AoyuYfNCmx1HJZ&5&b5%@B24G4fu;4tuK6kmP-+yJfvD9Km{0g{Q5%kAq8n{fFJ
z7I4WHg|K;v&9a!su^)vM$+xB5ikqd1+i`u#cC2xem>JG*s_tqE;qmH~I0_v{M%5Vq
z-w2!bp-b^H=60Lhan`zF-F_$E!rwhgr3q8d%&;{cdQ5I`*3yHSjMUE#uf<V)lS^p9
zm}_@z3k|48q4dLqpBUQ<geCZ|iSMzgS>`5kqe4H`M->nAIdV!wu2*+sIY8_pk!tJN
z%1jf^X6G<R?&{-rKE8!$stN9HvXv;DKo#{XjVGF#>6)$wQ4G1UOKYi4ut+n6?Px-r
zle^4~ncyEycr3X$ZK;uCK7y#}IDXiOrtGo(`W&DAcR0R)t@HUHxCn8rX?>0j^P%Fz
z^}IdqmUACd*U4O;-1^^;Nj>nPPd&Np_#VlkC!P_(lt<NfEUiQ@UAH4I>Ia$W?NneB
z5ZhSGFrCTUtVJzu>rv!$4k_a@MCA)-)U1?{7Zf9mjBVd5v3&WqTv^{>aA$cIx0`Pb
z<PvMCH9HRe^%e=oxxnjNXrZs?+-8$|b`>rRN|pMPd@Z`=WQrW@A2aneCV#G;r=25;
zM*9$liPTx9$?n8eO*u&*z0AW|CblaAG}%Lz5%U0lznjX~3Y>9g!>@0^dkF>?!+f%R
z*Xy!|FJft>Gov4TbWDERO}%!RMMAml4eknA<E~_WDDgi&H(=6lVM222etomdx;_s)
zay;bp(VlQ9c6M?)j$+opgxp6T!7hV3I%T-qx=izc9PV%N{_3nDqL!LZ>sVQR@5z?c
zH{3Affm(!^hnaAAfqy|1wNs5zTun0jhN>G9>`QCavy1Z=)=w?YuUD5=))y~4K7Y<Q
z*>qfhGojiif0iwUv2;V}IAPSW(OECw_mb1_yilqTVt{W&hxDXuVHaZCVNgY)Q#>+k
z9CKPH$f_JRzq+KYWF9|t15ME9nZw+=^tY>>*m2CEwWgTa?`(pCY)@lzWviXka0=i+
zXN{0StH4Vy;KH^n?H8e~g2yFIo>__497llixb1dAJ2S{ERL*Qq`>rx5E*XwO!PG$3
zivgHfl-XFEc~N*+G99+~vczJF7@%>aP}oX43S*<ZG7%y7nBQt~&&NMZgRYSRDZw@r
zKyFv!q!!nOU*kO)_5Ho_k;*Yl+0$oSKfq+E?ypH`It4oGZoGLW5_A|jY-e{G=f5Fj
zAodvvFe*5KL#(RBV4^JYBPvd#ox#NHVc8?N%2`++xnSIUys1n_3Cwt0?6}4mlu<y@
z`V1hkmD4jOD-m+peU;Iyw+|r<KyRfurIV>PgO5ZP1`Md7<B&yGP2^z49wN0|b-Muq
zD9527#>AeOjp4%X!NxjoBtg(+elv^&$x{U%tgXkfS{F_)OkC=M2v*QO;Y(-}I5GXY
zD-qnnaN$1S9Pu4ib!3j6m9l+-$4QU|x)SyU^>Uoku5=&ixe9O>OwThpV{@7TW~?Db
z3lKYX%sOhzBbH-ZGazx<^+SreM3hLL+K`Hu=|jbl&<HX*9wsf;3##F!?*A}U%;UCn
z$@fpoZktb+K7z;CF#Lpln%9yhNfezx7{?di4g8Ps-m|sz35Kc7=$Jd!-ke-COh{`D
zk|tP@j5hrUQ9fKa1$Ww`pU5_mqB%~6fvMM;)N8O!okaRkETI~DHRC?@^F{(w=5aNV
zen1vLXTjpO)Qx>zHSTTTF$sAGqAs&D(8&v0pUPQDAwD2lGrr5?TaII-s~hVA?gI`@
z{WaZj`ua4`Y&0?waJ8C^Rnkny8L*ClAvgilF@X^~IA#{kEiJCBSJ#)87tdc@FGEvu
zP9C#iv!@>Kt0sk_sfOJ~nf25QqbdJiMb7#>a#_m%S4^(?4dnYz0oy<gI14-qJPaHM
z_5m*=*MAalfct=NBd7l=@D*Se*aWTs3%~(j4{$f|OXT_A0utc;z+=Ec;7`cyzXyB?
z_%!e-;5=Xh2Z6T%zeisGGH?@k7H9$=09JtqfIlFo|2gn8;CbLGumLoIhXD(C5qbU%
z;5zV0;4$Fcz%k%1;Je8Ap97u+c7SzY9ykV+fN5X~_$zpJ6Zj$Ub%1#IHK4c(4ip?H
zI8bolKf?hXg=eZ1lrMRHJdiT!oC;BB6%mn1E-0>!Iig!i@=S=?i!fa&d8>_FAwryk
zZfOQaQDYO)q>esykesO-^iu+gR0n^lC;26YUX5@Cc_tO6Mn}?UgoR;rBx;{9QLkQ}
zTC!LESn8pe)Nw_KEG0y0p0wMMkSY%_RSO*!H-w82fl|%vyy^GeW*2njRE<IPLswjK
zhfLVgt+L^C)$F~ugVhKH<vU$@NE?t2qBvdaN+hYe)}2p2ZRD0Ye0I0#_x`S_46YZt
zBcAEHkk;G$J@%Gb$g21qEe4(Q1hi6zsfS}$^Fvo4yD}+(m6Dge_trn9I^VH~GDVPe
z#LVfUNT1`~TdF6Gu;Za}R=UfHg+OH|9%V@|6ck9X9(|rvYmN|{G5>USx>Mpx9Pd~0
zMn+OM@Ykf@mw0VWy~!}yGZH&5&BLi@_8M<c{pIpigJu~hSL~o}F_xLCK&xsELg@15
zj+Na<`h5}=R3y#!RBCop#Z+<vmvxey&YRvbzp3VVsS@a7UY}_u9Zg51_u(QamdMmH
zsTVy#iL_Tctc0XEdG0Ld%>YfGJyY7swx_4Zx)4yJN}~M=APpJiPrih+(zQ|&v-dGR
zo4Vjlj(S_Lfp;}wL~jl7>Y%?3lp7+d=#FNWQ2Y~_6BXOdf5VeGgRShI=sU_*gLTe|
zmmpQfaazUOr8>6<U22KVQA#_Q<qpY>rUf@KGtRO;9mLKVa^`)FA=L?G&@G#@Tvac0
zMU^T)G*Nn0srU?aNNX4s`kg96+KKL1xxZ%GTa~VdZFYB5xX>6n<i~i9e9_aQ<6Cas
SN<9V)f4EMWmX$Ka$$tUkR^L(p

literal 0
HcmV?d00001

diff --git a/src/server/api/ws.rs b/src/server/api/ws.rs
index 9975aa2..5501079 100644
--- a/src/server/api/ws.rs
+++ b/src/server/api/ws.rs
@@ -94,7 +94,7 @@ pub async fn ws_handler(
                         }
 
                         // Send the message to the websocket
-                        if let Ok(msg) = serde_json::to_string(&WsMessage::Sync(event)) {
+                        if let Ok(msg) = serde_json::to_string(&WsMessage::Sync(*event)) {
                             if let Err(e) = session.text(msg).await {
                                 log::error!("Failed to send SyncEvent: {}", e);
                             }
diff --git a/src/sync_client.rs b/src/sync_client.rs
index af40884..c8303b3 100644
--- a/src/sync_client.rs
+++ b/src/sync_client.rs
@@ -122,12 +122,12 @@ async fn sync_task(
                 match msg_stream {
                     Ok(Some(msg)) => {
                         log::debug!("Received new message from Matrix: {msg:#?}");
-                        if let Err(e) = tx.send(BroadcastMessage::SyncEvent(user_id.clone(), SyncEvent {
+                        if let Err(e) = tx.send(BroadcastMessage::SyncEvent(user_id.clone(), Box::new(SyncEvent {
                             rooms: msg.rooms,presence: msg.presence,
                             account_data: msg.account_data,
                             to_device: msg.to_device,
                             device_lists: msg.device_lists,
-                        })) {
+                        }))) {
                             log::error!("Failed to propagate event! {e}");
                         }
                     }