From f3b177918e0345fdb281e7dcd3d08b7bfae72e57 Mon Sep 17 00:00:00 2001
From: AbdelrahmanElawady <abdoelawady125@gmail.com>
Date: Thu, 21 Mar 2024 15:51:52 +0200
Subject: [PATCH] Listen to chain events and update twin on requests

---
 Cargo.lock              |   1 +
 Cargo.toml              |   3 ++-
 _tests/e2e_tests.rs     |   3 +++
 artifacts/network.scale | Bin 0 -> 83925 bytes
 proto/types.proto       |   2 ++
 src/bins/rmb-peer.rs    |  11 ++++-------
 src/bins/rmb-relay.rs   |  24 ++++++++++++++++--------
 src/cache/redis.rs      |  37 +++++++++++++++++++------------------
 src/events/events.rs    |  40 ++++++++++++++++++++++++++++++++++++++++
 src/events/mod.rs       |   3 +++
 src/lib.rs              |   2 ++
 src/relay/api.rs        |  40 +++++++++++++++++++++++++++++++++++++++-
 src/relay/mod.rs        |   3 +++
 src/tfchain/mod.rs      |   6 ++++++
 src/twin/mod.rs         |  17 +++++++++++++++++
 src/twin/substrate.rs   |   5 +++++
 src/types/mod.rs        |   3 +++
 17 files changed, 165 insertions(+), 35 deletions(-)
 create mode 100644 artifacts/network.scale
 create mode 100644 src/events/events.rs
 create mode 100644 src/events/mod.rs
 create mode 100644 src/tfchain/mod.rs

diff --git a/Cargo.lock b/Cargo.lock
index f9116da..6e790fc 100644
--- a/Cargo.lock
+++ b/Cargo.lock
@@ -3850,6 +3850,7 @@ dependencies = [
  "mpart-async",
  "nix",
  "openssl",
+ "parity-scale-codec",
  "prometheus",
  "protobuf 3.3.0",
  "protobuf-codegen",
diff --git a/Cargo.toml b/Cargo.toml
index 41cb188..adf8287 100644
--- a/Cargo.toml
+++ b/Cargo.toml
@@ -38,7 +38,8 @@ url = "2.3.1"
 tokio-tungstenite = { version = "0.20", features = ["native-tls"] }
 futures-util = "0.3.25"
 jwt = "0.16"
-subxt = "0.28.0"
+subxt = { version = "0.28.0", features = ["substrate-compat"]}
+codec = { package = "parity-scale-codec", version = "3.0.0", default-features = false, features = ["derive", "full", "bit-vec"] }
 itertools = "0.11"
 
 # for static build
diff --git a/_tests/e2e_tests.rs b/_tests/e2e_tests.rs
index 90eecf5..685aa0f 100644
--- a/_tests/e2e_tests.rs
+++ b/_tests/e2e_tests.rs
@@ -44,6 +44,9 @@ impl TwinDB for InMemoryDB {
     ) -> anyhow::Result<Option<u32>> {
         unimplemented!()
     }
+    async fn set_twin(&self, twin: Twin) -> anyhow::Result<()> {
+        unimplemented!()
+    }
 }
 
 fn new_message(
diff --git a/artifacts/network.scale b/artifacts/network.scale
new file mode 100644
index 0000000000000000000000000000000000000000..d9891b778d01d6838efeae1f3c01a2ce92144421
GIT binary patch
literal 83925
zcmeFa51iyjl^<5s{o7Tq)RKD9h#SEOe&R;QEZ5sNyP6fFy^(HacV;zn%<hhMW>+g%
zT~AN<Z)Te9>2CF}dv^y5XGugX<wPtTDJR)dENpQB8ztaCB4UWaK?%f=2nP~Kju_&@
zh8P@3jvORl`}^uu)$ec5%u1_^?T>}fbk(ow)vH%kuU@@+_1=cpt=#Z=N92e6cDdT>
zc!Sl>X1m)ePF1U|Ub8z_yW^k`j&P*=p5FLxyLTLXkdh+n3L$d%pV*ZZ`P}Ggr?TOd
z{Y}5?ZP>ca)mCocM5|f#WWi)kSGpBBAO_?>lRgwA7Z7r|+G_f}4X@)Dq<hL+Jxa|Z
zyWMGBsMq4zMZdSYTCdi<W;a^CP(uR)GTfXH1)#Z04CE);l}5wsmRBl`3L5tZx|?m!
z50`a@j_@}*C<?N$+VQ+WY4U`0JD%@#E_k(Y=HP0l^**l|&Kg*4RMz|<IWlvp+o>F*
zgb;(k;u<m32a8BiM-0kB@4&%vA>90!CT_3YZgskDt?sug-Rk<}g4dbWzmGO5zVA3o
za#-Z$V6)ZPs5FM9vm|7()%H4-ZoSnsIl~*3CWzGPY^oAsI6s21zv$K1*1P^N|1DoQ
zIC#Ix!6;L&SIgb{hBqSfy*tN*9KoQpR?B|<eI`qc2(h~;is<5QF`Aobcj_DUZvBE+
zRwORW9z1ksVjhhNk;#ei0=3`4XrqOpHLvM)>eazoea-W`gVX8{YRW>RwdPOAi8Eex
zf^+9E*X|Kw0#GK!<Q7myg7QKRj4X7#Q`}lkOv~w`n0Fqgo<GxEt2e#5nh;}hh??n*
z-y?R5VOwAa#T`*t^eT-Vl*D{I*<JTKPPjE8Y8thf=7oBv)!e`YKi$S~c{N&W(^z>}
zefT+xUeAm9*vgx^fbyq2EaY0wnUM>a5u=z91MT&S@6BZ7zykdM5j-lmAe|W@2fM9y
zz3R_p<REo=2_#*}O>|eQ>y>)bjLWD&i|PqEJGiKpx+9ikJG}M}A66(#=;DAShE8|u
zje2*}5trnWUVuH$(xpXK3@=vKy;`q9^ms&G*2R32nE>mE(KD4sUCrY~uj_~><g<Qn
z#m8#vdgTk|Q`z^riMrQ{p+(R4u_PSvq(#Z+EQ8W@V(8uu7D~I~h^K9#HO?}Ht{1Lm
z7rrAtAs>#hmqg10Vs;4-{7RJ;<U(bWhSw3FmLJnKfxh`#Zu92^kekKm(&}2LUOV0*
zf;r+P*)`Qwexk-LVt#R>(&=I%qk(GIRQ!mPPZ~<ocWeM$AOYb`Vq)po(h)Se=9$_u
zBOkHtf~TsFiJET~<EXiSC2cF-ny~}iUG0{^Dym+h-jEnO((5$q%{9~BZ5eq<x3|Jy
z5|wTh!%N5Bb!HLF4RpCZsBr#*PkD(7ZxKVZ&s6ITN9@bUUuyW(7PbkD(S>-8qMK4;
zuIYDaJ2`L<xFFbxf_L28Siz>XUT-^Me*k&IX2)=`ki#WHkoSrFbfx8p0~xulai~>V
zF(CJd-xR}kT{z;dfYNqJB&uM4U&==|@Ih{1KrLnLD&P^5w2{@De!aTbt77N$9XVz;
zqH-M@{aHC`HlsNt!Lgs1YPz1O<yKo8ZEU?>&Gi|;YOm4QEKOLr$13%PSIfz93)bs&
zz{lj6fjdKKu}!<uS%|c|s=$_tM_V<|Fw%^(uza|RjAi#?#dmwmUrQq=yo*}wapX{i
z1t1|umkuAc(h%71`jp%BF1q@=f>7;v#Gy-L@2X?s)V2lUIA?)m7y<ya0RVyz7UFrL
z!yq;#h&}Q4WdR&~eN+wst6BUKyPWpPrrT=nSNs}VH34wfEA2LR(pt%Bt5I}UTOAkM
zjmvynPvg?re!@j;Fd<a1U@$C=Tp$OkBy^k$#zzSuLIU=tUtaaRWmy1=gWz+nUn_QK
zb=Caf2_?E<*C?J0<Q5^t@Npxwh>Q@+{Qz=<GM9hAL%Sk(qJ_GmmJ3N3woN^q#(5h?
z>CvN=X0z3uZ?(?%+SKNeO6_E)4xs>T4jMMJE{pt=>t|`jv*1c&S0|1I0l9dhwO|BS
zu}e%YwOZ)GrYY(}t{7Nqo%gT>HROo;#qh2XBU7DvcYVX_)~k+a%ZVV#C30dcw24%}
zxw<mEtyCIZZjTtAxwKyCK_st<YsJXXR;SZz)5asN6UEcb$^|Tq%1Xl%c`<&f)#{#T
zb*CDQ)<qP*UWoND(IQ=jL^x2#+`N>Nx!yPl6SOd=<>TsvaD3`)`S{7{)AKXsnNz1u
zo+{6rIC^q=X1csM_wE@S9vWe|;hxKp$z#1{%@1RSK{?rMY#LHxP)3h<K=C-}ywTgh
zxadJUs#YKbiP6)|^Uc=9=9G`E9|JLXObO>019aJE5gHxbEhc%ix#DcAQ4`mQF_2*9
z5*AKP(IqE_jx<_TEJv|Nh<0uaa%#m6PGVqWe)u#k*;OEj>Excgpnpp-K3%_1CyC?8
z=DWR4i{@}QOoz1bley7(5~5Fe6%vC0ap**AzOqR?L5NHFalH*_St`P`iDMt3L&99M
zi_yWb6HDPyD?o_Hp-vB5g1?H~X{oBZtyO#0@O=ENxmX>Rk-N;m-8q^GRCcxA@w+bZ
zTPy)v(_O<Z+AO*ifA*r+XyC76Lu$&D##KW{&DJ2K^X0UrgS|tw>0ZS804^>AS&jm^
zA0KCELi!@(e0pneE4?l_rO$x;(ioj60&KF*t#Zos(VK?n*6~R-TnFQZ)Cbze2t<Ga
zOrtoC5M<uroPLCNoV~BHIi`nY-Pnk*O%LM8+G}(lmY9Qla6F|luyLH7a;rEHt1Zmz
zy0m3Hyo8NnS?wFkuGj2sP*1z-bzg5A4?BYlBZu?FWt=l=GM77f-Vv8ENktyicLe4u
zW+^fpAs)$3>bYtK`p9f$5yKt<FjET`*S%&zPOIg2qDP|Cu~vu9CecYOoCR}mfMC(u
z@Z4_2KVNdOwyT~JCw2-+I`gJd2oO$=Of#>Rmj#0TsJyg<KU1|D=;}`-5Cn#~dhKyJ
zc~Y_32`YR7x)J2}9f^#y6toj+ec~uaC&Ugxm)C|u*4Za%Y}Ke6i9jn@YP1s8)m)%u
zz6vpxNUByVwW=1%isxbauRslfc`^<KM7>q3SB>cQ8nJVnyA^hdW2k{t*z}sjjNNX_
zUGX5^K=vXbvW@{(xK*Grs8w7{PGSyjrHfqrXN4GdX$dGo-GNh9W0Tl13o);mj=P+n
z5E(;=Rx3?Ng=m40^e%bT9w?--tak~!mTkV|jH<N-P6+i==~1kaT%jNycLsURkRHd8
zxdJq29@bM~5%U@vIJKaj$e-(T%uTMS+`2sqV7fvZ(`wE&@rOiJf)*8Qh4UlGzpgze
zxD{Q;#a_#mO76_+DxZsx>HhhHu0AyTrJ8LDQcw#(wrEK@-?F7iUZvtYYGhl+^rYPs
zHDVE>V0$4E-<<vBm@b6#3%0O=9Mxacjt1fJE=dH@h1B%7Qnd>~fu^6DZJt}{tU+_x
zRO3uSwyC247uB|j>}S=Sbiq%-&df$gQ^4II-5U-@Yoznqp8q~=yQ%dNv2Nzaf%sIf
zyWWDZQupYrR?(?V(uh1O$IREw`MTf51bm#jY73zQyfN~6Z?_wDtoOkM2$K**r1SLA
zUI#0&+pk7j6)X+WF0p|c8Ryw;YJizi$?g08Ec9N_i|1+0yigP`<QJ6QT5IsinjU$a
zeg+qMD~)=UHlUBm39okW(4hl&9X@PwKV~)FL;72&f)mzue<Go<jgT9Apm64dTpF5b
z)<}5H^*uXEoU%R7XrBim_a8p2^+!PSrPz^BA1YbeQF|NJcD3%h<W57fpKtlyE!rEb
zY=Dh-qb<qY-7?mcT7=+N7uQ?9Z9#7Z&He9##Oji$v_hh{J97zB27_O(G^V|F%ddBf
zmuUDJU6T7qJi>9b2W<h(=|;=<ORhSvta=^nq0p6Y#95Ebb#YFMvLl&_d&ZeJuvm}a
z)i7yBG!Yj)5F?LHB!Hn=QsjpTt`72=n5wHZ=T|meXtuj_4re`oA9$(AInH;9Rhtn~
zKtULFU*L{_&4I$yef$UGi2clb+*cYo-86|SX>phHgG7rx3n|j30Z;8x`}<0>rx>?W
z9<CEQYFAJ<9<OD5<ZKNbtlm@?4rQptx;_7sa&S@o5W927Wdh$2U5IsRJXzxO^r6CN
zN`O1FS12lLMt@TJ)-g1Qo!>IyCS($9a(vPVA!J8J?Yl#I_Ff6WuW`PmI>75njc|?E
z0LFI2E3K7S(GsX}T_{5QeI=KUCACiF;+3?P!vQ4T9Gxo&PLrn+k;71DtM-Q$p{&6v
z@=BWD<H$twhEu3{oZk3G-Cyz6D;Mgm&c4zhPU`CHnYt`fm(jJ(v++)EC?Mc1m;m4|
zy2GVG(hy%+pRP*+CuOo(nIYiAi#?w-0ape;@7$cA8LpNX5D!_<hC2e$kR(SX*eVTm
z&23=jf^fuvNM(IRBX+&>LY#D1PYO(ec<$*oc1v{6NoAQgILlL((rTjjbotWYobUIj
zUh44O=<JtEtuBdlC`RWnRU7g;R5TDDh{rDT`dKczYLlaVqe4F+q-r@|Gv-=p7<8zT
z9M!MAf^&OXdo^#n_G;crqP4+!rS7?sRkGJvRx}T9C9E_mxu=`_>q_9g!C6nh>uES8
zt<Aa;csHfsht-P<>(b!TdPNB=J71gwDbOGW1IqTI+b0L2H`#-@jH-8i+&@AO>KDK_
zs$*s+=M4jgpkvspa0s#+GHDe)oi|q?fDpegiwI{*v*3iaYsWlqp;E_bKDEyyxE<?N
z8l=4*l%pD%ldDScknh&p@l26>06Lox7R2r`y)6_>ap+DiuGgV1S_S~Valp|E3qkK@
zU~Z(#!~(50dZZ&H7{zm>PEz7`8|bP<1Hoo_dn&(_AJfW~uDT6O(&OQgW0lUvqGAh<
z_?#T0BwgBYN1=PC41HOWQb2NnX((9KNm45mGh*Zf?o<riKapd6O-Y$Vz$_`n?InyO
z5(SjjyynH>?h><HkL&{=tSIF}9@ZI3jVX$3lVJYt7H6q6i}_Huuh!QXqnxcVC1qP{
zXP8pvRKUgWfg*Tx2J&rp)AVIS$_efa=Tmo}hUbJOR9dM$rc}IFP{=P`tT#;y4@p^5
zmJ){#Q}#so&gmY~*Hf--Y3tH?TsNR}xC;Tf4B0{^4%dt6pu9T1W7o0N(iLuC6yn{u
z5jWasYl<(+j*!wQTsba?7sNbW1%u%)v~W1H1pc6ukLvD6zQ^dWSIpDYOjQ4{l+Wtw
zk?(2hxi^R|mBGyv4k>32YDL~DZ;ehhwBOpEhe&jjSfWbD)!p2bKaHJ=BuuDLG<k5d
zkJ-~C<p?hJ=|&re5&QLKu|SjZsMqP%VYQ^BV>+yu+QO4^I#EKrk!QZH=5>H8H5n)B
zuSKAH9X*7}f`eiqLLNJxu7rNKh{*_$NI(8quIrT*DWmQ&?h$X|_WP6J%W|6PMGA;F
zi|Kc_{4=;r2Wc(Jp}`pvvkN$Qcb0Gh@VZCWE6p`h*AA@$RJmT$BP55K7=loGv`v-D
zT~+HD3ELP-i(8#fE<)@hITQLk=s3Wp)d{$T^F+(VEi1s|I>2}7c;ij0T6DnicHDB2
zTUPa-ld>CtNSm;45!>p$K9{%lI{J!>E!zr2O{YNmXZZy&EQg?jBq|z`KvQjg7MdvZ
z1*yskIn>3X4$*3wj5M(9%5Al5Ltn<K;Ypo3fG`(Rs+e-U?SEB1u9*bc8ZnoiTPV6%
zJbw4|9S0|1Cw32X<>Q#?yu`{hjNg@ol~$_(EeoYWh&1Si%-?$2i7&*q!~y|vi8e$T
zk`bUJ`jUJigjsLA=z<3yuUs<4=Dp@xcO3>zU&_y~FrS0H4BLqS`J&0Y;8jNgKy*Wr
za~7$AvB19S%YDWxW%lD15V}Ug0&1iWzLzd5AqIW*N)dU55&5G4kyrX4;+m1cbq?+`
z+TW1R2YrHFTxh`PzISe6tUNz+;@+iM8oQx2EQX7f&2Md8>E8Rpm5NnudxW`Vw)AgY
zX$O;({?=;;@kh`&z9PO0%SIvoIIN@pK|)9W1Er(?K_8;d(p0j0m*R;q3YF6|8$(k%
zSd+PG??)1b5VWUE!0-~Z&H0I}Jh)Z7*ofkF%7XVN0faja0>UhR3a?tTy2Ovd-76-#
z2kTBuyPt#$6%vJDYl}jE(uW4P)TnuR7so8M3Cf@6=2qoiQoTb1)!>^xc}R+ht$0;}
zv&XpAFb=(~UI%7McS}hJNKOa|btJd@b7@h4L6K%pn1PTMAssGglJg<}YeF{7Yjs%l
z%=Fx1;6_Ma(OInkgNkHZ(z#VYh%(FcO<xv$+#YqHCWa!?jEpS88k9~Zu(+++Ok7|P
z)yjOMP!A9fQxnZjqGwt(VQV|h^u^EPjFIMsrHo>XPzhEc3I9?SkKzyUOLZ6;Qgf@b
zxl77%vUuxuf^Ve4sCRoc?|Laey%pP-pIVw*Iz2rT;vK_{7OZe}<(IaseDcJ-vD)I7
zsr@mCYep}n+!FB7xuplnC#H^v&=OL<c0RI8reO!eG)p~=;2tTzv{lcKo;-bG=~M#8
zJy!w8>#qWgy|T~RAD%O-BF`ep%`$(yQkA#L{9N0Yw@d6bN({MK8aX7tQK{Yv;-i?5
zdB_j9BZ0y~pl<Y>J8ak7m~AJtz2CCUsL!2PIu;-GTdo2%(7Aqij#@m?Jw5ifZGk3G
zoH=!D>gY`Q_|(y0&4}Bs0-Cp9F^qkZrHKPF5GVHa?`+X_cCM}ax__H_9`tu^A=KUd
zSBz>>EI5EIDzi_DLve%)!~r9_kw*3|DZjkcqFkIgH8(Y1K5_c^k(pB=Z11`X*xsF7
zQNb1$+TZ9nx!&n%@k!?W(C=#K_lEr~ret_GpOJ~}d<K-lzcWb`_=qtY-Xuv{#3~(|
zqgA?qhayPad0bivWNzV3Y)6B&78y!DDCKwcM!OYZr%xWAnmZ9)nvlZh`XQtmhKb^p
zO0BuIi&rABisKQ=-It`?eN4Igwm=k5VicmM<<_Dy=oU;V2}~c@roz4VhboBES78o5
za1~%Y7$F%}RNThpE+$z8e=>U|v?6_Wk`!GDY<{Qfn>Zc~2WKUKsYjYTlxz~RCe81S
zI3wWMJ;+M5{IFJV&DEqRkUSxOsU8kM?2)@9g!t`F)**F;gpyfFPdMoa89*ihlVt%2
zRR+2+;+JYwh=<bgERYh;31Fc|17wG0PWOGA9O!tB%4QGDZ3j#7)Xe<U19l=}CBrxn
zk{&Ef-Y?}O9q5@{FxPF7xSMOA$0GmS4j?bQD+E^bB7?S>9JEayw9Tt9C*KcHnGZ<u
zfpo$aLp`F!I;?uU8B%}@`}H;4cSB+ijj{M(I=Hcjb~8F)u<74MJrinx4uX$i=Vdi2
zNL`I4n~@~ga3o#qHR})cyfW#0!cdCLnG^Z5${LU__4VY9&fIfa3*^<xex>30<<wGL
z7@6|ShwWimYj|+BEz_p!vo*PRES++ur(}E%d$Ar~j<OkZ0e$Iy2omFI{1xIu>DBqG
z92hvV3Bv$l6L_l8T2TplUEr-%IFS*<_ts4!3ne{_YV{{5R6m>!UEQGAlf6?6S%u1i
z7{9WCt@cdUFvj+0)BY^f+ZV=6{x~!Tbv*VglV$&g_Y^kX-hn%zKhugjePk`jFirv*
zIo9JrbrAnFT;JH}b;;z?o->DP-f9K*JvJjnhv21Zu;nZ%H_Cc;@Yy?6M<|}cI^5-m
zXZo>xt(}FT@#!{(uP_Z8e`4Iv^{X%vXjL8Oh=igdRFgFG&Jn8r5t&~y#>tU4aLIeK
z+5}Vqxa+HSkE+)OP{n^#%2|E!V7}4uSSZtKUD#bCt9h<rAy_?j9|$r6A@oX#FA@wM
z+RQmGQ`Bb(g?CJ;n{gUbuw%r5AL;?sEizMuIfAmBUZAs+>C;i2>7=!jRd7%`6;5$(
z!G{J$8A0XJs)x11pO2mhj1scwLJv!r8hp$LAH=>#IL@PU3yR9n`>?eYYz!)~z5x%q
zONKo~8m&Sq>Q{%vF6Uv51X)+93)>h5lLmX(9W`2;bkk%Mo$(u;-OeNmbv!H>fKt~G
zHPnWQq|ycQB`BWxdU#ubS@`wHEHtIWHAyJY)$mXsQ4iG|@l7e`V-uJ@;dXOWJxcP8
ziA@^Oto=vyrhJd{RXi+!f)PT#t1YGI0fD;aSL38jZqz7MHAV}1Nt}j_h*jA+;yY3<
z#}Kq%#kI~Q(;+e(V>O>@p~r9f+9x`_EeQ8LDVH?xXhCtE^U?{gd$EP5bOGRwx_m|k
z6JD8mS@cgqGBC(&xnA;4qXKgV+$@>8;dQreVB8Bv<FSQ3ZkNd59-P|L2$ba8t#Uc4
ztd6ygP*1q)@i>#NTzJ*P3<yR#cy0${enN#zH`nMYblDUM;W9%PyswJi+~7RYuTkP}
z*owT`xy4ok@0sWdmAyV#PWyelRn|ilFB7{YzEQv+Ckkb%O^+PHE6!|X1#uS2(hIn+
zHGQ=${#44drp0IxvDfKNxw>9-6q(Jh$6y|Zmkshuq3(pYfcpmL(G<9N3aDz+*!W&I
zjxa1*{OthW<UE`L7<MK;%qGcRy?ZW(vLTrxw!nA5xs(DHXu|$l5j+mnER39-_nD^l
z&3R}_4^+v1{6#58&B~{=xVc|zRlPke#rnWZE-xqJZEevdTr`6J{YuL9^s!gmF|d4#
za=te@?R0t&Ow4Yo3^5V=5Tx&BbyMFM!|;WTSbj}R&^E_TLp(AefN?ho$Kmq^y{WE{
zg_5o`xc&X`NBapme9E<~K<T=YhuHyjQ~hx%$IK#8_uV3$AH^<X#;TgnC{G}tf+dXs
zGL03XE)y1fy<TxU!OI@~ja_Mpk8j<FIBNMJy^tX+!qQipDq&6y995G^ieiYX(FjB&
zWIWJ(aq9*Rocy?%)JHb4cXiO-$jM&!<f?ki3K4T5_<q#-6`&WOpW3>C(J-B8WMm#!
z!GRFuh|hqS;T$D;iqWv-=7=v+p^z-6C@x0B+m$1}hP4*XA@n}84SM00)x;S{%+(1P
zM?=)1r!i%EU501%v)-jydbTdZ--tJUR?3gX^nj51SXLqcG+X!%UI~3+vC$lcCfe4{
zpxl5t&#RN<#AmO9TH*6o3?q3t|HbVFAT+A1rRM9Cmm$-^b|F0I^jnCR`vDvycOsS(
zPsVF9aPbu>KN%Y#Hj#*zx26(bxne3LRrO!%hcxr9=(L5Opcub|aNOsB$MtdlX60&d
zid2?1Oh;?*z>T(MxiTMCr-#+-VfA~UW|#S9pmP7_)(F{UuXY-oQ`3aLBu3;mgLNwn
zoEIA32D8SSQk64L8Mu6AQM}B1k@YY2?XA&?Lm9vgzIv7jrmB<z;BbRS;Hl_+9+<}9
zV!Z(+7HmD)N(CyD?`#d9yeB9zG?40{;z{ds0Wv`C?#P9{_}<pQ$753cj;T2abt)cn
z+2IZi-}kp}axyM^MwNU6GIg^v4F%rLeu#6AGLh0d;)K;elZj0c`m$=Lu1<qttzZG-
z#rbfCmBfs|D}G1{&mT+i<E{JQ8VNj#zp*?IRLz1OC7<`S_U@-!L!F38XxJ;almsV?
z<Q5YuCaY@IlKEcLPz_Ifd@m#%$<Yh&*g)E>aHeZS>Yr_6p>TX=X=-|EY07G+g`9_K
z(<6Th<rR8Nsm>0DxN;%<(coym4&x0D93?>rG~>;Z)h}SV5hDx>SmI|_fr0*F>mf;R
zS%&4O@u@ZFG-wk(<yC5%Sn=cLcyMI%NUOU};=-@CZe~8#LFR6GIbp|#*^{A6Yz5j8
zyMCK{*dufE^X25Q37N@HTf2DUttzSGn>cqIb_7eovjQvwym7>lH|nM>_FB;h@Nk_L
ztA7R$g`uJeuSqdRWvrixoY<9-Ux-zUoN0@0NTJMr5TIiWfy{`rvHI|0QpX8CinXRK
zF1(^|Ewkb*sd+-Z*0OUU=vS;txOG#=5$9rH0^*sbLr9xyyF@ouZPDDQD1+xfO|~Z^
zCl|Z$B2wwtBJkw05UZ{xsXbF&BbH;|ffaeMqG7onl#hMgp7OZ_xiqx{a_!AnBeJL^
ze;VEPh-LV@gynp40HWiULcD9m!-=}~LQ0b_TrHJ^*NL+UAexAwx_PmlC>0{*EgAVl
z;(MAs^Ytm+O`Wcxw#{6*Vf(Z0uC#^Dvfe~&k>rA149CIH8pEYc!JP3eLt;bm=)Ko~
zQm)0XPzEkw(Zek%KTz4zAED%IrYlA}ejx(L3A|3AiC@MUr+nVq41L2aPT_63%dy$L
zRhI{4dUv#%*AjyDteE1{`eru}O<>%?WD21tM{I}un=^8Wq?-6DhDd|0UMWRzE2$hL
z7>=<w6Sh#nO{Wn+wO<UJw;|Eoj2$SmCnIj@Pm1Zp?2KR3?UVq?E)I1ssRQoS>-Mb~
z>omtYNlb2614VvoqTh0vDJRaJTxI{A_d|p2b!N0flH`*RDQ2f2u)~Q;8la45gul-D
zQ!7xT;#jT<2hUe@yV-bg<EtyZIDDFH=V|D+jCFOf!ag69G;sQEUh#bnb{bKA9aedY
zi=haQ-X6!>101!R$s~?>cLt}NO(^v8iQPBSTxbFb@-&DuPe-{Pfr^&izSlcsbJ5vk
zc=xuh03Much2TL^jTeXkz@ppm@MfDlIKYib6OUV3G%H3F-b)bhn>)um<9uVwmeeD1
z-IRJrt{dBSI_wKpw|RPT!HZDac;gtN^NSMP3jN)2jJH)8+@32(Ed>el45~!lYv2)v
zEW=F!(q4s}F3REVI_`zm@e%{fpM8BECF32~h|J+d=the!G29XM5JZ*t1^$y5C@%I!
zZ~?|8aBQI3``Fn>1p}j@YY-F5p*EKHl?IepIncjr{V`XYQ(!}$-=v)?(gm4owh~#p
zw(Aw`c{TW<q^GKpPT84tvqZ<>(Q4BjL8GqPB=O9O+{)<$*F)Fa>}3c=aWfR_yKBxK
zaBI_Vd@{}#>>$wPlDUr{<j89QDd0&y4hUT;LS15tZ2>v!yb^&-zOqcUEuh0|3j2i0
z^+&qDgD}UrEg-+TEYr|_n{FpznSpr&-&b%Wuzd3TvRhxJMcnaVlti8l$YliHI%;=$
z<2;jI6F$2fn&jFu9y_d6{sDb*e**gm%>7q^+2B!li=oTKzQZbaHd}W)r-7cC8_NAa
zRe=VD)YX!Dz89=9qA2(wd0BMfCbhDP#~Z3ht;ep@wf}?dA7Aee7!;F*8~~>>s6oBt
zl#C98k?$^HTJrqY1Xc5vUVQ#G?&sLo85Cvaxx2c2#*6UM7>}oZ^a<xoKS+h7c<y$v
z^xW_lFJel2<hSWtOBY)>dn;eYE}lo?u8_ZNjnpV3r7S<X@R@tFB&0MPkVFv_Q`hTm
z2}iBfrgFkXzO_mt@AAx@8LU1YIob4#pBN4L?Jh)P7_smh(9*zkZ)0N<c0~>NJ%{s<
z4UGa^azQ8Bq1|-{ehUs{@*`Sx0GG>=(Nxzm?$zeTY}lr_FdrerpW$w%8~?M|#r_Q^
zhuOoc=j57S4s6RWc}Qu~)nOjYQ7)Kba=6)we%$5MLrheiZmuFHonT&n1Rjx<yY#KL
z#eoZ6x8)zgd6SNgQGLqpn8WomD7qD_G_N1mY%k*<qT{82KXrR3gAFQ2A4u|pp}`|?
zPnGskAFi;i=fhKU-1UtqA!0kkHEegoeZ96pu$5xHmtxs|((tCV<%J`5P(LGPZT%_o
zcTe_aJF1x#leVVyH?V^i9rjgV>skwlc=vb33fe~E1$S>hdUvM`8>>f#Eh5otjzM|$
zf*D|Cot$paJcdg_e?9$Mzbl%t?ke51(tAu;IfTx8vOs?H!x?-#Fhx2OgNz<!eLXPM
zw_|;3MAZ70{X&5<qFcbJj3)X_CK_18#0|-l;=i$Jo%UM~7eb6GFKqSqDJyZhB47`o
zc(KYkfI3I3XjB}hKaYz0Vr`tA$L)xY8=`$vaU_A99Hj$6SzE`S&d7Ok-d{a@m~`k6
zHz(lF8XBZwRjP@r?guim7Q~b}d{{$Wq!0#cLYxKyy9?q0{MnTe4`x!M9~8*>F7NMf
z+)GaNl`m!b5gH@mz{JUO-?O}c(iCfii!MJ{8i#OGUWZ$M1oD7ePq=+ne+}z(9*)+F
zmPUOt%ECmcc?f+&e?pCBoLaK7if8a(>71!n)?$AdVr}(2+K)rYI?ty=iPZ!yc#_<O
zH$SBjKu5?IwqMD}G2+J%$uM_%aB%E6?Ib{53qVHC<BSqODUhUA&q!ATxd&oeH(Ebj
zfv`|%n8mKv;d*|Me~igIFu>axxWy%iS{1cBj!UR6Kuz;7sh*Z03L**%oxWm&dyVsG
z6rn^dfO4*vbcGFDR~$3pJ{Px*FztjjrFDU>+!vG8mWrPNnO1p?g_Rr&m82LbRcK9k
z8G(P{*>r47)G1?3Y{VxgJG>ZG%4&|#gx3stIil`8l{R`f2+=USQMpu3WCFLcirw%K
zBDlc96bD}wP)Y@1n9x9xuhO_^dMMK`+(K#ys$K^8=onPJOd<%C&H`#W3KeIFUV2aC
z_z39i##Lu6MME7PqYm2-n;AK-Rn*)oViHuMOaAH7zS40TSGry;<)he)XrhM`n&@Gr
ziGF{2KlplqEn_gm5-*!CeE^(2L4U=|#0Rd7=7oUdc-R0_v2fTg&It&v(&B>|6@Y*}
zV*4gw)AR~cirzXENJnV+)xbsg5;i7>;xVqQIr6yXuV>i1j1X>=7mr2xuf!9RHoO)v
zqmF-^)?SF=Y(|6EOFFs>*h~d0R<clO*ZmJ=<j@rUg1_L_K6G@B!=+uEf<`g++K}Nx
z87F_VbrBnY{BQ=|Tksz||Di?sR7T)mtkP#P1@R1iWg)!5VE(!I!1MARP{9b)Mlv`t
z*StVG`69M6GMYlQz3OC4w4kFb?O@hJlv`^-O-2f)4Ha%+1qSKlf1MOq@DR}f*K#}1
z8p1effz)V}PlsilS6ZiL^q8E$n*@KUHK)BW;u>X2H5_eFlYk73m0pXZfsorH<4zG8
zlq*95&bBD7&r*wI2JF?bsglY6hzn37v~W>Gbwqc<H7Hq!qv0NkJ#q%hE$~|MXipkt
zn5@HfhOV?s+8kgGANBMp+VrvtRe|&WJPew&EfdKT<j~lI%Ho%cJ-9rg*D<uSlW$~A
zdabKf`dq{?+^-);!46zkcFCNv1k21O#rnXl6KjSY=Ma$`Diku127$F_W$b6jBtMx-
z2MoQH+K>ok8d1}nBEX7A+3g-2UDZmXB%vIuH<a5l?4GXxI(ke2Yv4DRvJET+i26ZP
zhL#YvVv6IF_JgCvu-jVHkHiQ1NFZNY6F7a|3B)5O59t654N+G{<S<zTLJLTmaKvVa
zh(;)O)%MGe2A3|;_$L8gg99tHY#^^t&;5^Q<ijLtOe~R38Cy0vb+Mu$ky5?eilVF_
z0O_%ckN1ilIw0Z6jftdUU)vR^g%{Dlk=CUx8<5VWXaf<rXlPiqSO&N&!8_yN#X(pK
zwNL=EXhyqS!5hnAw8(Shp{!gYd@*7yy!ssM2%F@N`;(1}S)sP5X}t5SlEd>W9EXG?
z8G=J#Nwn443T#t5CVnD@6=G*a=@tTvcCL<S_i@@ZUd)IWGl{5*Ma`0E_F<2*K@}g&
z$QPyWHC7KFrjSGJdU?GLO)xyNk&jT={?Q2%u?~AULuy8O_;9qy;lpMquEjYC@JR}#
zzhpnei@fOS<}vZb@RG4{b;L(9^0TjJ^R}rF1~L>U@}n8~sn@gp(;R&=)Os`k<)>cf
z{+p0Boe&0zfR>-l$d_MFBIpButF!2JLwJOPV}Aa19*0E^xfyCb9Ch<+uXF2o{z2hA
zL#;=`dCIK(%<D=2BRU3gsQrO>WY3$kukRcP#}N(T(Jx-;R91fP^(0A3kkSxVX)#ET
zXXV#lPmE$gPea(G#5KJyE5G(SBclvyIQ(D;mt?He(^>hI*Ao@8DuX1Nz$6-g^?~f`
zypNbzuOV8z1+fhIOr&*)j(G5O9+zl)Aza=XiY{BpzP@{!zDEhQo*s+V%gS%Ro-;$^
zq3?fj)f>Xd#IUVr<wssm91tis)M_*&?#AmpC+)Tx!r&m@`UNMccnrMIiN!VF;B~Qo
z1ibN$%I1n!h8j;rU;9i(enM-xOm#@~>SK!eEu?##3K5$FPK<JLHdI4rUV-#45_)JI
zuN$)SAV125c;3Gw(Rh?`O*#VrsBwd&QW@2hV<ShpOFFV15boc^zcjSUBozLdR@^Cc
zbCf&GX~ci4BjQES$!uIX9xfdrk}_W@$N~K~#lTViOG6c>FI5!w=+{DY@XIPcIR*Ze
z=<P1&$>?!2t#9b_)j4;5CZeu>G@-6W+(8&le>SsSM8SYR<;N<uT3Kl@E4U1D=y8?4
z1;<rp{9;xlbRFT!=;kD@Q(#WKV}R0mBuc(`eZZWLU|6oK;a+ANJTuM{QLrf>uG*k{
zKG0j~Ab|;eT29^k(OnjpC;j;%6xmSH;F`-v_*0m*wN^uyfk`HeyE>`{oZ;05nnIO=
zVOS&D&EVTr>)jVKfx|wnml$ldD=>5@>a(8e1l=uEU|RQbMt*5x3O`6AH(Z6Sori#U
zFbILVSPNCSZf0jcP}T7d@-NOOw-@9q6Z#N$MF7OhnZk4=Y#<>s<abnvz#>fF%KCRG
zB;Z#vc%i^0EGFVBnIMW_vI^L@iimy3L4>{jS}^b${lviM=h?wbnT%5}XiwGHqr*w^
zkkDHFdWM{lUYeK*6<nYXq|Bq|^=U80u=7t~UX<ZD3m1S2&ad#Gif7hI%2Xhrw~eib
z6s#~~pr)o!ED>bOy(Yc&ASX+I)>upD)6wa@6?#B_6c-#GMW`d?J`}n&@`ITA96&Z!
zV5d`Fr66<Uew!~;^(&Rs8kzWB9d7HYEw-;`a;d>DrxUXx=gi7c=LB9g;o6+8^2x>i
z0Q5d{#I(cH>zf%l8?HVvTXauAJ^0N&ZH<Nt+h$~LXaScPAh098osoA*J>w4_4j0GD
z=Ln^nbG4#ti|Cr%a`9SQXwf_hRN6|E!hH*3KfpgtMowL63tV@rHn25*JCmE_QSWY=
z$fA)B=X3A}`hs&tekbEB%I{@xH9guP_7#1?Bwbu1sdz#!NYnriSE15>oRNbgXNvCP
zKD?TO&v)32g|ftVQd&1;wUowy7Wp-jGSC~9&MaOn=p24Wh1=c}LVPdNKT_(jB`wyz
z_&%n9jg}hv^8FC6)8C^Nf0)ty?#?mryC2fU=%l(B{V{$zx$k5^pr596DxIW1do?8e
zMUteUEb+6H)`#s(x^klaLUrtC)UjV>azkoM>3D@REfR(xU1j@4j#VO+d8#tJpzfw|
z2}svIt&6y5s&v<}MMBTt-IbLK_IcfWt98ED*5Sz53+CRe3<ot8aS1aGG&s;%;sPtI
zfkb<4?P@NsqN4S0ldhM`<lipVtQ^Hdn6j~*h<`-L#mMDUdfUKioUeHd&afikr-uCz
zdNnjkoW!E70uMG8paD7WdANURs5`$`(^fXVmzutXAfv%in~fQ;?Z}S=SbbN=#c|?0
zP8c8>nBYFz*s$!zp+8-%XTR{|+T~o14rB}{+L_crB8^ET%+AQ-_E5U*Zd{&^R|Y_i
zt%sr5mMW?1;hMOH!q5evry2dwY}}42{ic5|ZYP$2jOMP+p>9_;KN46rj&4xYWt>;A
z^!(A|l$hc~<el%R;UM&?O<tA**o7SMr{MWB`1F8!^X7;>Ss5u0PL@Aax#)zSDZ)vv
zZs(4Jc*Pl#b8(TTzZ@LJ^ZKm*ba3=RY%PEd!^_La#@;ZX_J+NbGbnD(#-b!7gySdS
zFwWW_8Uqh_`_ZNzx8O3{IBa7(#WThjDZT_#;9z))RaiSgA|!vcm}_K^^ChVwospr=
zT(jNlD$iLVN1?ZZH}jcfu1#UogF^9Z<q&LYik(yHrsBbD`Zk@3Lk)oe)HbF8<XQbl
zTt&AlUpR<Nnj3H<ryTJH9>MK<a$O>HqRhrc>8&86Wwn_k{ro1|jE28S^#kmrZ5Bz`
zL`A}iJJn7GdsE*3-8qCJppk>Q6M6S{@4cwgiHrXbFu)$yngtC$*^?Of-ElQmv_4_0
zrvN$g8%hjD5X}MpjmA$IPo^4o8@1^6tQ<3ulk~Sxq@jITIUNMquoD)xyRRyo(1VCb
zsnyDG-C~0?sdf?lGCmnY{iE*cxk=r1<1V@WHR%4Hc=tp7MfcT;puR^vUniY8?%0tw
z1;tJXQOOq2_Lx5SvO{o~HS-T`$9Y{`DHkbCsMAVNfZ=EYAv(#@1eQ|C6&CZehDS)@
z@>4-DDrS+|;7a7<9Z7GG<`9nL2r#RVNw{^pK0W}U!bAi;9r@TbV7yYqRg}!<L#)q+
zVAz9z2Fh%Y<67y}rb1y!@`I^kVd?x-mmN36Ngct7kkpfgk<_t|UNbT`#+!|_Ld|MY
zakHWjFCY0#<Dl^-Pg_uwn1B%@r$}R>3BZvah8E6qdT)GmLLdmDM(GM5z99}V1OgBz
zXcj3~V1}46XXiT&+;CG|#*G0+TeF%#q2{o#RVvtC6LBI2oX4XJI0*%?mo%YpLl+9S
zIg*^G9R6WUi#*XN5Q$tB3?iPZV?xBUW1%4upQ8~X;-6CkMMRxV$^Nk-Vg+{+F5->O
z(^0af5|AjXCrp&GMcF^HsS?D(%kkgPoNeQOEl%@P(uQU;iBYf?(ZOSjsk7PG^COUn
z{dt8kFCsxL(yl%K{|Rj|7$=vWqEV`VT;n~wJ)x5`+zXbwRXk&@wW>YkJeS-$-VOO~
zT4&57tyynSh}?|8J)SK@7Xe)8mbiQxZ3%5pYIdY{e!?uV<Gv|=T94NNlvz4kDWMt9
zUpahlQg$A;-;DO+&2iqC1Owpne5xiblWwHmPC}1K=0ow*UkVVwULcr|bRtnQVS!ED
z!bF<6HLhDrt3yPv5{(IpgPYP}`#Ua!yd~cGWOV>t(kF_r$meYd_pR}1mkNPE>*X7r
zkKl~a3|tzRg_*_~&9~Qc{r(xmp>g9>OC=6bt<vqnV~7ce-EH+b&JXS+LiKI&R#Sna
zRX9oOmfzR%0|iJilnQNDZ;Q(@v5J5-%U&|j0}6w#-asL~ODOe>jfwv2@j05T3V`#G
zT)u=z9(nqNT_27w)D&Q7V|oSGBrNIahcRGOQQ7PExHc|P1#n<{pl&bua0EpOZpI=9
zB{^<iyukRr+12N#--vU;I2^#fI-0&);wrHLCG3qaM%7z#+C6gs51a86017qt%t8HI
z;`bf;cLu-5^zSTwAJV@a{JvBF-i6=q)W3J*H`-A!ufgxT^zWP)K67AHC-zXnw0tck
zOw-p<!nB>IglYVGN|@GfpoD4uMoO6W5kmUb?3D)GozwA1Z_5VpNN<C7F*7H{?di0P
zDpLv^*e{5^C-+Eq9uIyf8nL`y4$qs=#7N+(&m0ChGGF-Q7zFPNheEcnpm+^OIS$|o
zvG0nzy+7+L(zV@Pp>FTT#Z#C4|CRk-n<hF>o<s!RTQ~ymZ5)C3Ko-wP6?4BO5`p(N
z8H&JrAgd$r9=LK`^$;Bj;d+RMXukyh^fxQ+zGA3Jm+@2CJ}%!ATIHn$EsXKLs$G!}
zBs5mxU<D**f$3}&$lz==Y=IKO;@V@gVW#>6j|abqiymoMgYzut-73<X^k6+#t4DFn
z(l7vK6WUx6G8V32s(3G$;^I9M-?U<tsE4NKP|B0Qrh&yJ5+{yUS~WsT30s{W?k;JS
z;JRu^|C-6lb$TwSPuNjM^5m-^b{7@{1lUl#t1ZT0N%x~1p~{i7$;`Q|?1maVs{3Y@
z!S{&W&c~u>-M$Tk2t}`iEuoUT@lIynHGPN~0gWb?HIWn1TrdN1m%Sr@^$`d7kA~<0
z+oTIHqv%9E;E*Evg(y+_AweSo(=G~2R8C-++uAMvkgjMBEPLW3(HAgUJx31T?GTi4
z0AUNF)Fp7O^L(^BeJT@N@>GE1NdTI=o+DSf{6&jM@gs)}+~@Zxaa|k@1JTY~ZVPC1
z6Q4-bG!FK+4)kQbx`!m!yz^3&0$akTQB5sCv90o3#unI7sDSI^Bi*+#V6vR}sON>V
z6(TppXK+6#sbk*p-V0AcTQ+dxwu8w)QsFZT-V%OcTlfqF@Rt&Oqxrq{IQ5GVkT!Yt
z#t%}d?a@%_;{`QOswo(?a7Zp3)$MOB^S>cJK>g|hZbP5k5*!A{=k%~9sT^3he3SFZ
z=vvqUIvQ`&%Cp)PzQs{K6)5&alJ^hWZ@RgG_{Hy5@X+3RY<~tPf;A=i5rfmBl>Pl?
z=M&NH^sf)-SLYZtLvrQ!q?n_>-;v^YHpN$ZLM|*W(0;yxs7NrMwnpx_Oyg5+oS`Pn
zuF`6wOXsu>X2*bKd};Lo0N6@3fN?gaH+_*!NLe(>p^AVtNm=w3zSgP0;LF2sMxDTC
z<Hz851%nW5%gCWd8Vn~cLh)>~<rN4x8-=$XW7m*FM8*m%+Q|@v4IMyeh*f@Q|1g-w
zeSIe+HgaSdf{o@bLpnh79vmc;$$GU6tu-{Ufzwq8GNDwY(e#O7kkJclxAUdw0@$uW
zAoaK@Lk`fx$Pkt^&tP#q2yI1xr84i$_wF1^^~N6^$SaRF(9co-HO?#PecJ+WbPwVK
zED_^fGhQ*BJ{`*?g@i4jpqVGMSO{k;WS<+RR+x-we*9A+8oXXK+~a&BO2eICjov*>
zL`>;gK*p4gUF&=y+SoQg(9YFi$@gWg7tMHRgV0-}5kg1l-(kHJQN%|>+NN6Ii}+)g
z02sP4O)0GHvTZ)5>d(Ygh=~do3V9P-)riKRWK*GpD_k{_p3e4(lMoQpae0-kBBrP{
z?~H~+kV6P_=fhiJh_fZ07a1s54fh8E+@tXm0^D=tVhGlmc)k)sO|r>nD5sChp+UZ?
zf-PzcK>W!mm%C~`doY_n%TB<ImzJ_NaZLyu&KB+-6GK3=QM-G*IxDgg2t|Pi7sk=p
zst>}Nj1G6oA2@bHvIp0xbQ@o_ayPua{o*0XVX_=oj;~@N2SnWBBh)fRXh`$696e{|
zpbcpbm?q}#p_gO21fD>RHoWE<ya%n&JB`yBj?p8X<tQuEz^NU*{pLd<A5bkCFySho
zkcp$9+XV^*l11`CKf`e-_z5)-iifU<t1Pn4QnZT%6u{@<Cdg<n3?a7&f3PclO_Nd`
zPzRL1eFW4nAocSUddEoD(s%=-LT;oWzGSPgYeF8W;lQb7>Im+35EeV^0ZSnOOs>uX
z@qz`Sr#n0wq%Dx45faI`4BNi<HL_3aQ9(`M4KqIVICe*%5^lvJl>x1&gk6RO_RpXD
zVkYxIrSI2-9dZaZBOY3*P^fBx9ZG!zkd0fP@%6s018^hyuno>lKIXiOeerVQdwx(8
zaE1vfh!Yz)%g~dAzF>AaF<)x7BGIvmC^__a5^$i8ZO7-F{fM$xXXe#m@UQofAoxJA
zGZqYg8i?{IcKJRCO*>+7fHAgHJku=%Tye+xS=WTb_=&X+R<3AIsF+>H;9G17@kzzD
z%q(t>-k(v#85!K0MyakDS%JL7Z^5}TiFzoHVPaObmCyKCn4l!j%D%qLXCsi8ttukS
zd)T+A(Z1UvI1nfg^8@{Tna2$7$PsGToq6nYze%!lkLDtwN#jQs37j!5=V<PdL;67f
zqBL4~$R1OX_bCV%a64FOhBY{>6SI~B>m<LZ%d!B2J{s{%{KUB>XtZ4*vjb=oEo5+<
z$LaQhU-8k4^+oudtyeh>DP>XJ4#D+kY=RRY0Gu}4w1w!%Y5Uu#eRkT46F;0JprgqY
z4-K!r#a(fok=~?i7tr9<;h7I*6P^}F*|#M*Kty<InIH5wp+eelL=V?)s~x&c<ebBY
zxukK3Os|dAeSWpxaKvU7*58^P2a<BUPEmXI4(US=AD)B5#tOW=9=J!02=zwP!K+cZ
zSH4z1kLtN;MxZDC+;k7){TBBs66HYV3#VEwG8;kIZhEyJdlLpD2l%k1u-@o*&P2}*
zx*dRxyf$;@K;NO`d`6%cfe~3bkrsnoG|{+Q)<Js+f%gZ8#Hhd5kb7lkbg9)kUTJR9
zD8nnda}H_vPHt{0AHF^=e83RM=j~<kl)J1PGcO~aUT=fL2w9ixr4L-O6~YI#9ma=4
zwhhP|<R>)bM*6XA!UfA?P)g&W@MGEBq@Gm9BTQ#_QTqp~A>ulwr*zb&FF%xx1}Ys}
zpefzezFXx(+2BzhAP-3NpPWV2YmduO{hWuu?bHp_hq6+&D^h$0J-Gv~QxvRx5YDFH
zllURLUWy<q#D}tlF}?WMOl1&?xq8>fEwESLps)!;${h%%CI|>ICO<gutyQWJ1q)<`
zF)9n{G=UjB*Tg*z{0-cN*BQDFXMw<j%wqAZFI-9HaTL^67?@!nrVD}(X2ny%Zfgfa
z@3x`2Hh`yr?AO|i6XshjaAj?(x)n9|+!L+tF*<Q#_j>qfrAgkk;aY%wcAK&_RkU<&
zNvXI)V%1!80iiJvjq8PbakT;m;HrSD9Q(Wc%Ab5n!|gLUjBcZBX%=<^dIFtj9aXy^
zHkO|Rx!U`6C?Z<mZk)F^>x>LoLfkD4(7dT3%EK#DU9iqJ{B*Y{f)=_+zO0+{)rEFd
ziJTM&5cw((LdE$Vthr~h+j$}i(Z8^OwLRauc*Zy&Qjc{o20vozxiALzyZhA^Q)%o&
zTn6o^NITgExmG+pwpSE`DzLuM+b9iB_u6>!1epWF^f3!s`Ri_wGyF|M;{Y5^2c-pD
z6vI5F1MpzDq9AC@^(G5C!83Ws+mCZroh0<q@R3T5Su}>}M<<(zd`M#%w1cZM7o{mI
z9sB}=l~vE{Ky~nCK~BM2Y60wk&d<?A|43HgU$|uuU(AS)Qcgj9TxGnN9TP8RtzVnL
zYG<?EZ4JN6+g#dgdvIR?W3y>Fq&(Y@qlZrgoH^>zC^T9FquTL3jvTF3Kv>pkS2?4h
zAbF%hX|0ydooG$@eydu?Ak-{b$!Ui3?1>hHCi5*snz?C3PA#~V#_TB8fHa1ocFJ4B
z^ISMtui^NjN0<V|l?G3=P{aqxUjT6Az%e`gvxi!tOE8QCd2Htpouy%5$Um_ZZjq=@
zs=F=?fi7a)=abujqU*OXW^c#pB=7Kk9bTAe-Pk5nt0kwaHY4kWT~kua5v9*u@pkkw
z+-J~8eKxcmeU^s#<&5}zHa8n_f8;k>UB9r1|56owS0%of&5i3_NjqmLlI^KiBeB(U
z$e)ZX6z0)MND!k7UX#4+FI2!0C}5A-y~>rY@<3ue?7$ldII=2-0E1#oR|IFmQ-|$p
zq6aT0(3)qoG$3YnIYMt>z77vDg50ufjn8BgSK(zHc%obP{I6tXL+>Ki0S!Izo=^~J
zPgCy*YCn;~W>bZr_?7fwn!M;$&a)Z|-h(c9)$#k0p~1t%3CdOZJP+5if$i$of^`*j
z7!_JqL%62~y?NU~Fo|6<#F}w02#-bXy{D#5OfO7fDiN;^q8J$GJ2ZPSW1Da9x-?;5
z81Xowf-2APFg5RM^AIzneWg(zGTpdDB#Zuychu-^-8wh;ylJ11QPDVKtuv^7r7<38
zJ?dEIKj`1Q-q6%yhD7UDqA*KC*i05%ttJ@3=k)HZsmH^t14`0b_EAhT-Ue;7hLeF0
zC?8tH%b3eK&H*_^%RA2Gh}DrTTaC_u?MkOh(kIwEj_cO#7d8hn9^`FZ?E<!?un#3}
zX&1E=tFPGUt8D44<)8>7PLU~2DP*AVx*0v<Af<hfRjA^o30s|^F+4%lTRk5;8uw{O
z0{GWo{Zjg-mc+jkVtwCCy5eDr=%RMRjc4`eogtl&gRp~!|IKF*KZrieDfdmQbvilP
zt20v={^%eY`0&U7?W`O+#XsRZs$Yw?h|K4YdBi&l$LoF-Off%&C;*T|ze9Zbn_2O_
zbQ%;_NRVVsG7{w?-`8FLVW{ih?}tbc>z863O(R-KZdxaTuF7XJri-8lUj8Y1B+I3d
zMEsDt@cpd#@fCOBr@9M23w7bA{kq`J)uuK;jc$%Sab1q%dzsyBC5KG>jPUzuR{SCf
zIU?(ud#{o4GjPU){Y}ph?32&x9Ef5KI@e=YZ@KIBHHZt~5@3}iq4d1c(tI838e-li
zNQ@X@N<4-mM?_<1F#>E?7r+7uN?`4(I4~-FGuh!(8l`zC5qhhucpD6>UV}=;xukz8
z6qHaK!C-dg5{W<XKvrqMFrDmiNXUeA)nlx66*e}oQcO*KMNl4F8L@O!?b6uHCE5%s
zu%1J|AO}6MMCK=O)AL*H$|k*7bT77gjhahQ*9^eYIfVy^s42IoWds;ge{~9heiVW2
zslzf5g@CU`qmUq0oQ6bhM6un@<43$EBEvy)>>z5mChbPgM=Ul7+6qW%0(_nn1bVXj
z;u_~A)?5<{=F<wsfK~-XX00M<5~7b+E}8PnC8J`P#kHjm<Kstz>J$t<QcIOtE{*F(
zkHK%&`#fLlah?t;kuxo1h8xr6mUke^{|YJ}NOFid*IkFjZM|AVXgqL+b_<3}!^i0N
z=>rGHNva!^g`WB;o!q(>>%vwrX58?qA1n-L${b$gOf}V11Cz>~IY_FCT~O0x_P|S!
z6LZ)z0{MDF#U-iDF451aW(_v%e7x~VMGY}*M2`#95x9wkE>sU6$@jzdy_FU~lh0q_
z^HOm>G7ImG7b%F3-#vZD!HMHjXUo$kkDfk0b7HAHKX>9?<@uQt_b$zn_95{;c4ts#
zrxs@eDB^mj-;<gXaPzT1Pv{)yi1M&F06kyVdk%UCm93=Zi6bO4^0_^DRwwqxsTg5C
zO0WMli33N|Q;QYDFrlA+orK?`RjgZ#$s|iGN0lm_upz0M{^BsIRvgYZ98C3oOp_&e
zahR*=e8*ItR<1Tw<y``2u$pIbx?28)<4dudKb>wPz!gCceY!@B9K)+&4L2voC>0>E
zN7TYt(#QKdcuqywh-=M91|0o(T@*$7DDtAq&=^To0bSF+m==6-y?7+80QJkq@lq)}
z#SNy}5EP5kjRMYtbZ-ixIM)vPvR5q3C~uBLPST0!Vs8*<gM8ou$xnZ|NlfsU0LXx7
za29D^E8Skln?|rVd_PV)N^!He9Kf<grdXuXP~RwKxsyybE-!w~<Z`cc?x0w=P&fwR
zoR3&=Ed-InyTMz;2n~dW`zA3)sQ}kEiv`M{?nb&bWQK;Po*K(r#q#N<K1gB8EVURp
z_3bU<9Q|da)lx=4I;GAKZx!<k?DB$LS!h&TaW;}2;B=dKH1dUzo32AzrAH}te!oqe
zJL+}1Hlp59OaKk~*Tp)`8#=PKp!3;`(so!pLSGk@8?7m2VyX)Sx&(2%Xj35s(Bz?;
ztz7VCnyud2`Z2I6U;Ku+d>VVnbiD?=iTp{vDBdm})iAayH6rG@6aa-5-9BLg3es1a
zisBt&QX{H64w>~g#VG0p=^`!TE`&{REsPL<*i?&uzc@>vELBiW)2k%Ll*1P~DXrsV
zB7RHY00<8-$e@RjVpJF<kIEJYg!P_g>l_pl22)e*4%-K_e8rfUG{0@lLt-M7ry9Id
zOy3JWbP-NyNEygjy;DqvGgZNHtlxz(TjVY=!b$b<Fj5?p5t-t*Me*MIgQ62+gp;c1
z-L@z)#XSV|P7C#S2r4C2(MekrnPQ5d21Sn$R9p0@Es9JrEykx?8*o}~0ndmro1<VK
z6L4at&RLu<?iI7gJ-E`X&G``Tv@1_BE0(M`Fq#?`;G9^9e^79Lm+}?d$Y=4cQ2FDP
zs)aKzAdX_!U#(O<&R1ZL3wR+@V30Y*=Go#zsO((Zf;cH=EeMsZAS_UB6p^_Fai4|z
z?iONtc6_K!#VN56nXiyb>(Ee%MLVlzPn~8T7)v&5(PW*rSw~IQ8Jl(7WZf^8%qw68
z$zp$2EW|%3{2#D{jC>aF7H8?ZdQTjM^d2-3|Dr&hqd`=ph<+CjiusUxDvQ$Zf&0^W
zh`m-JTR|yXf`&edWw3AU#>&>Oh>1|1s=Q(;V!nu~IIFSJ@aW4zrQQ)Wv9K6&7H8pl
zVm_9yV6W1&P~8iE6>FlFaCBlpt&8Qfj|yI07<Ejdh<I-Rl<th818_b78vdw&HWEN>
z5wT%Az}yKEDV(K=rg%8I3u;{ziHUqaAzI=raa@3!B0C2UH6e~yyS`{!n2M2_CG?P;
zRW^LyY#m`XJ7W9m%$uD)529HKvThnb!mpty?0N?=XK95&6S6=jQBvW+t+jqA>)E)#
zqof6cSu2TzHglq)PUUb1Pw%U2zPJUa2Pao>#I1CUD2m&*#%t8zrL;4+B2fqJldI52
zz_d`e(SU-+s}0KFGa@PS%cd<#j8e5Y+Jn_i*mwCRtf#nrYxEMX7>c<w2kcQPcjgWV
z;<+<pkiK(g4&exvJ9DSlh5x=2f^_c8xVQ%Yy$gYZ^Khyl_RyaLkcGv*eyt`C2d~5=
zH4zv5Wn2)?2wYNjHZbjIYgfXG*;nb9fM~saKGLZaeV8`ap87}(#=MI*b-oLwLUWM6
zcZ+E=bb$nMjd+B_KN3Ay_Z*TBO=(agtq?@Us@JfE_J~Jl?ZhBq?`yO+ZJ}$$<&;84
z5u~@*H44q^`pTDi;;+0S=ZI9Nn^4ktI9PN|wmQG)1%vzLwsN0~L&ZqwNN^)0FKoT2
ze}?WKMZqp@1BLF?#9lFrKyxI|@;Oi41&KF^WmM!b0=4<+_({+YC%l`)qbZ$ZHLWcx
z22ursoBMK}Hwwf;Ry^qxq-cX89Vuv9C^}3VzfNM1(Bnb4fZ?a`qDw6v0~{zWhmR%(
z(p>XiusBbhh{c;k5o!>7j(xLOhq4)p`g)T@WeBF17zCxnkZ8oeYB6^an2KA)v+>U-
zu=Q0d4Xt39GAN3-0BsD3K`9~`y%mCS@|)TOT!8^rI~7#!>LEHHfYl>#h+>ns5m6U=
z)%C?z0|qLsrYR=gCK~ZPnz-hc_}9gBVpWJ?0ef`ygxlh21@YU(Be8Gl_=P43EDQBG
zdOR5`giw9<7!)e__5?J>tkMV-8WE4ipq)~$j-zev6L3))L0YelP<M}P9%*&gaZ15M
z(6pjwpvt0|#9CeK`Lj@{;s6tGpCCi#tx%+Glu|=f6o{=H0U9r{U%**lqy$jo1*T4H
zOD!Du2(&1PWz4>lxP~_o)4|&KfiMm}lWHkUH8mfD26R-6D}E5<91u^Zi2(7b0L|Ay
zQHz#b^l<2cFhI8hckEzy-|wV6Y3<`JC>P$M#DTP$$!%t7La{H3`J_*SLd@DMq9N&s
zp)wTfN)Jp1nXRTRpuc8BH|=XsJu8-uL!t>4(ls4%DfYph*5TV2atHRH<yeUT>~67i
z1n&!zV6PF&u@6C|oS3I?R%xO!*+Xg@I^jn?`U@Q>jlqYm6-x;Bj>CVv-gV+qtf_bp
z@?xE<hVTr~xn5jOe2qi6LD<bAf`Y~FM&ePrjFzRAT8nrEi+!oVD{ju8#|y9}*b9+D
zg>D^a67Ci2@y}rNbdNw^-yqJZxxY{$GfEr?(IDS%Vw*Z=<a>Uv%d!UUO0hR>FSZ_1
z;^I^CDYyr6`o0+q-G{rA*gB7S(4dh9gZ5L1V@vU^fwxyFmV!M3##tR2GgO1n*44X4
zVp%fCtXRjLfckxeY=|)PRD$6;_^LCeR^V*J6y>kGQkci?1oOCN2gJFXMCd6;OgZtV
zf4uYyG~x1LYrsH4mV;3vLWtA$WqVK~bh8&!#mgOKcLuZ0kcAp9K~tU%&LmJv@)jp$
zP7>xAxa}v%oSGm|7#$B<ioPKXO^!U2;^0X=$RA|I0{EXMGf-_M@72hbt>doaPQD3C
zEngLKD}0ORZhGA@Oxro1b{jIk1G6Kp*z-bJnH`{fpL3;-%|_WYWDc=y=;C7uh9;+-
z6m#5xGkDSEM@(_ULxj7D0sZO<hbJsiEZ|CmrPk2fk(jwI0<~>=KHl!&0<=0|uWN9d
z0hddgsUPyV8H~*i@j$TA1op#`$zX3<hry%RA{ZldPPb@Gsw!~$L2nPIt%ZW=2rg6~
zwwYx2pt{Fn2@6?LbxxSFxNrB>N_U`j=7O%eDfDO`8&TYh36pguQ5Z*Ix~hcnAL3^O
z=4C{0+<gYt5-vSOaluAte$8tBJlBMUAEbY}K!FbeZ5PdUX4*so=7*-pZ7wF*Or_J<
zgtdi~G(pu%Hnt+Yh{?H8flK`^?waw|sIggu86yts$U#ZEbjCfVG8}BtZFOl9(CEU`
zbdzp8e+i(dP=&=wi|h<n$bxgDa*0eJsXASF+Vab|N+tC~K+)1Xb9+s=`#nf#UEGAe
zLb$SR2tV9&m7Rh$X=@uwQzr<2j7ba@-%Q|cF$Aljo@?#|*7oe;!7E;Sg4Z7Azg>Hk
zU@G%mB#WQashl6vQ@~E=X`Mj?SM#_On(fj7gM!_R`DE^m^^Adq(=<jCBL#bQ-SQ5u
zh&?C#e#{PI5iyd@Ad`+~K+WwWW9awhr$8Qw!!NJv>Fu~^hxt;J7X`ZvE|mxSHb2~5
zhiFAN>&9K4;z#gKJVE@3AoBz?3@P<X3P-}*aXkM@<6i=gLPX{vM?93?qmiId+=?e+
zSq$>zH%64b2$0A$QP;cEm;hVe?#3=sGhz~xgw(EhkD}*QRz#PiUPe&XScYhadKVq>
zBMKPm4iq*C=7<~J5F^Bmt_7xQ><MRpl#qR+SZKy@od`HuUQCkiQrS?#P>OgeUDcj!
zuEAbmjljZa0G^K3fG>7&5L0_W7h08ZtC%9CgD-BhlBMa|v^k0wcCZU?2IAxeV;P<t
zoKc89#wuH+5FXk!y`Yc4(gB^x2<QZ%Tn5@Y2P!p{!$}gV6;bWk2r4ywGfpMw`yzyB
zz3bsvGaFFd;7QswTOTd)yMk*(x)pjZu8LObW+-bd2&f*{Z9@ORaOj?4T+iCCXe}rp
zuG;~j-|rMc@v4T_V50-Ed>+$x-6OqinKZR^L=COZo;G=O_*GejA+7wDyR!WH<;6@8
zb5MT38BphB`C$iS91}u(z{!PL8&?6b>`{zfCC$`SjMx5A4#m(S2YGeG2jQmCMtluH
z5d$;TnqP6mV~(8k=qH};VbfQ)_?QByXszc>P}u-$2sMa}7><<qSWtXGfr}RYkYfrT
zg0=mJz?`yE=xR=&*TQk1a-MOXb3WpH)OpeQl=B%!JmnNd!w=d<Kw%FAhONw!B03&C
zHp}nxI`FClfx+v{9;KlG8+teLpiV;;u_pZUOn*>t9*s(6zwK3xFX~AJXAwF2c1}Zi
zu0NDXhSI%cV2mpmOP8V$KGGk;7(<|W<=6dDRsCL0=;lA#zw!iE-oSM>7FTzZTR(1+
z3V<U%jtAp2or=JZw7H!3Iu-R@O2?hsU|=BL5W_hDy+1wj(n*9%Lo#EMcc^66B*#?J
zF-e?%QFxb0-l>wiP4b;8d5uYqt7Oh3?^4M<!qsRX8XI6;YtxJuxU>Gwh~;gXF}vQT
z8MPa1nsI}fjIPhf6>OTZ+iTN|-WzP1@w>^SDOw!x8?b4{?`E53{N8BOjNh->G~+jD
z(~RFOHqH3G$)*{<H`_GhH)PX{->oKn2jlk^n`ZppYSWCLYtxM1Z8pvLz0IZ>zhAd$
z#&6iB8Nb_Yn(_M$n`ZppZqj3n--t~!e*0{i@q33&Gk(8m(~MuyrWwEeHqH2zY?|@=
zEt_WiMs1q$J7Cg>7{7xy&G_A6(~RGkO*4LnY?|@A)211}ciJ@LH*V96-(5D%_#L)s
z#_zXH`cB4g!loI&yKS2ByT_&(zu&QG#&6Q58NVr;X8exWG~;*FrWwC!n`ZoGO!}RS
z-!YqJ{O+}B#&6c98NWH3X8eBFrWwC?*)-!fZ_|w5ahqoRPS`Z#chaQC8NUUaX8i86
zX~yrAO*4LrHqH1g*)-#K+NK%5Gd9im-EY&3-&vbx{2nmryBNQB+ce|%9-C(T&e=5M
z_n=KPe!pkaj9=NN8NX$lX8bBP&G@a@G~-tl!-hXIg0&!nG4z5AMsYRBU>w(i3`TN2
z$Y3n%K?bAw-XMeVJRf8*qKzPfG2O5k2N=_4kinR?f(*vA9b_=34+R;FX(z~FO#L8(
zG3^E!jA<{(U`#Ir8I0*go1r(AOF;%>x*23Jrtb?f7}Gx&WH6==2N{g%`-2R|^v?$w
zjOo7>WH6?egAB&>12#i%FaLIs!I=I#K?Y;`NRYvpelW;jO#j^=gE9RJK?Y;`Xpq5}
zJ{Dv!rvF}$!I=KO&Cnao<3R>v`k^3$G5z<0494^?1{sX$6F~-J`r#mhG5t$H24ngk
z1R0F!lR*Y!`jpMkTh4zNWH6?G5M(f>PX`%{=`%qFWBQka494`Y1R0F!vq1)9`dpB~
znEppW24nhHZHC@_o)0n@(~krhjOkwsG8ogp9%L}4F9aEk=|_VM#`F(^494_74l)?i
zj|CZw>Bnt`-iH20kinS#%^-s@{X~$#n7$ZfFsA=WkinS#r$Gi|`pF=JG5u7K!I=K7
zAcHae&uoU?kUkw`Fs7dgG8ohUJjh^7|BE1lF?}h>U`#(7WH6@xWst#`{_P-xG5uVS
z!I*yDX6UWyzX~!K)4vmBFs5G!G8oe@1{sX$-wiSt)BifiU`)RhWH6>L2N{g%e-mUd
zrvI(UI5^6j|I0xJWBQdKgE9T@f(*v=?*$o*=~sgc#`J4J24ni)2N{g%{}5y_rmqAU
zjOo{HhTfz8evrYK{*OThWBQFCgE9SPkinS#PeBG_`acI5jOn+6494`^K?Y;`zXTbK
z>Hlgo^d9v`K?Y;`ogjlT{ojHN#`GTq8I0+7gAB&>dqD<c`o9MmjOjlNG8of84l)?i
z@7oN$NByH9gE9TbK?Y;`gCK)3{b7*7nEoF@24nh9f(*v=M?nT-`r{yjG5x1O24nhv
z+6=u%{Upd>On(|=FsA=kkinS#-$4dr`X@mKWBRiogE9Sof(*v=PlF7`^yfhaWBLo5
zq4%i&H^^X2|GyxEG5uwb!I=Ik$Y4zWS&+e){&OK-?63PMvhD-ApsF{b)F#jXRq?DJ
znjc5N$C-=gSt<)I9{PhBWiVRlt>CcYS8HEBv*l~EW!S~yE;VHG00SI)KB&>yi&*s5
z>Qmi(e%492b{aYbgJ<%`hkwouE-JrHQvaPC(yCM`oeUn>;<DkY{&U&+flK#ZtG(cz
zBd!Up`7Ar8P>;Op)n230u`d(nrc2{i(W%U+@jwoG%$J}phc*fi0<{v<*B(m%Q{C(#
zm^Zy~Vec;`zExq8OW_W3@0>>!R;DPAj=hOf_xB~d6KPlkVD^C<cWQqM1FsNh@WmSf
zjJqqFxLDrDeL+7%sKJ&JcX?}gec*M9wgJ;FH#Ds51juF@gRrYGdU?AMaGrLLSK4$H
zsQ_pXH*{&JGjK=0?)mfzRnv%`Fe~6#3eMfqwI6(!EX2|gb4NBRZTR)T!+8UT+;q?#
zFEs^6E2{E7cnML?4dD(8fyuBs5EhKaJkm?!hG)ft>YQ%bs<5NMOLrH>T%e!3tUbzd
z=$GZv2&`o=ii#>?2PA2`RMgz=8iQ;-2?nR@aFx`R0{q7LiOVTdHiBjmuWI4Mz&IVi
zuo;r#Ev?rn4bH&7P}i4Y7D~wHT~3*2zqkQUpM>I8>7F>bG;>(dr4HvnbYBnSZ+fl?
z0@qyJ=+JXunkIZ*-Nf7G4qZLt)gmsfo8)1k-YmW1&UI<Nqb%$Mz0SqDj|=tYD#B{;
z7575xjO*hroqAW%-52{Y;tFqAZ(N|;Y%H`js<$8aq%AxLrWz#|E-?9;oXcX2o49XX
zYq_mncYkYD7yhODUV1c)X<x-VSonL`@W^F^PuEcjTTH}t^l-J)+E8z^wcDi*bD`3R
zLPf1;J7ch@LFuNNMua&!4=Pg|00l>6Dhd9!jJM$MDN$4zORaXj>J#G{J)UvI$nBDr
zMVsc=ir2m9!4Xsi6BUKr5qMT$6EutwW}Ei1yHC*`CM<a52kwD})$I2CCsUA^uvi#0
z#C_5QlhAE25T8k0BRj7R*e!r8Rb?v!XI;3_uPSR;EF8}`3&GG*9~GV@kfH9+NK8Up
z{`=@GOb7N?8}yo8E$;>h(;-My1v3J^8<F3s6Zu>G0S3h9i3A%SeTQuZ_3@AGaG{T;
z-YVIFDM&=rP>&TIfIpT@Nj$)d`GR^355~gS!YbQc9#M>o7ymKk*|f;>Y>s%uzGVzU
zRXJ6uueujKG9RLu42ueyK*yzm#AB-}EK^3)Vv0(ZFv{wPQa&#KF#qwaiYTIKN6u+@
zs!NF}OS9IR@?r*Jgs_f4rL{Hmi56LpdjVo%pV%NGQ;7x~VwGm+@mxc1n5WxtECXY5
zaUZ6ab6UE}FpBFghi`UZ1cEipSxsQLOvJRFWat5it7pHf{hOmhZOi~Lz$M)Z9vb4M
zHjEhc%J?pt1dWzDJuFm3KecvseQ=BxI#TJn%M^gkHT9N>u`KuQIJjJLkAanW?nupB
zt@Ik*eFO!RDJ=&LE_Led25kL9ZRQ@_L7T?R3H!Jj3~(l*3LZDODjXbjf7yUFn9L?o
z!3IzEsknNBCqo~Eo*_c>-pu;}KDllBMj&Yd@Rlhb%*ds|Q8oW~Z}&GczmS>ty!Aoc
zy1Kvn@vqC9{<;3=?>_(WTZO#tmGWQx!;-vdmH+ued7XIrPw#oq7W+Gpd`!uI{L{i;
zw<Z4(N=5<7Ys90c-rK!NZ_|^i8tr?pxC$ZnH-Zh*$Hb@k<sXI{4D>=RBid7ISlsZv
z<ZA(iO%mRp8N~~BfLc)hcRr@rqA@+v0tX188M_<E9;I>BH0^<E{uBz!dw>z<ER2<u
z;Znd{6$uTqjmQkJol*P~gGt`LytX?6%M!2wY}h?aR=DKr_}zUacY1}X{=v-T<fZqs
z(D=Qd?IMbp-CxU8z}8HCk~9<%T5T{f8g*Vu<~tc&)teVu=e^R9zTbQ-^OelJ-&=v#
z4{UJz)f8I=N@;n7#Z&k{{T=xS@BMr0&s?+oS8xR^-uVyz;Fk}7_-B8Nn`bfk&klb>
z{`{%Gyc@s&{^y?lgMa$UU%WYs-+%i1Z~y)8|IW-jmHEy?A3FE)!If_ipuah>tF!N|
z|K#`S_m7`>`4fNZ_kK*SQN-t-d+dpm@A*r=L;3Ig^54E`;p2bpW7HPa7tSN@y^v~X
zx~g3pQj-xfz`p6Gxiqr4cxW6}(Qrrcl+3+D4De8c*6N}hq^1HOJC)$MkA<zEmEgir
z?GxB++YLMyVJg1O_YaMO3&R%gZOV!X@47d!&s4G31DxJU6$F=fR|!0Wyz+oy93WN<
zRze7y!O#N9`6gTdRv@SFSB(#VwK@=oXqs$P&MVeVNY-JU<+m}rU3hQ8nS(q6nT5-^
z%jYs;*uKw`!OvX&MC+myMVAOj|2R*$N3|qRhnGH*)i559^9y<@h+}>l!W}z}q)L9b
zve9-SeS_^{_8BsOl4=e7j{FELQpaG8Oe<soh8L|`(S7MUMxa347ZjmgoGkw^Y4P2P
z77Bt7p$QMHJG3Dy0s=Jt#Y+-?Xio$ps=mX6KbR^Icn8?424qRj>k%Sx4Ka#|;b9TN
zRJ@B_3Yqkl2F*Nx=S>)Y1Yd&Og_Q$~1$<|hylRgFU}Zc4(P0zLWjg1T?1k2W53n!-
z2}yrcS^3%HmWfg&*DI}I%YYO#1v{Z44W-^WpNHSep7P2^pfvKpQtvCqxu0Kxjq_;;
zfv^)0@}n7f$(h&wWXpJG)bPuS;S~yh;~f}Wp6)8g?&4PZ)76wor(crq&t|Q&*NzN+
z=JB{6z8$fHb-l$p&gSZXCI+WKhZ-MuK9J>IbPgi7A_KO0ebB&2v#_TGLK-BdhUSxI
zbRZkEXdbEwj7!>Os=$fOdDIbwpS#*^wGw;Tv!@yT2w-CUs$sJ*l=n{(vxxW??r`_t
z<6an3vj(fpcm~sF1)9NXWswg)Wg>f|f%SKA|G`6dl8i(~xESnJumJ_(!q{l2LP>rq
zBOl3)=`Dd-`0(U);&SsZbmdK7)&DsA^u*UYhvwvpB5;;VqLTF%Nb^Ax4vk{vgXPry
zHrWHyGbO*YfX0j;quPSkIYRGB3x$JNV*@x9sRfqUp#tz~<{0LM_eBtfR697aG}quM
zQjxYK2KjgedHgqByu2VA9Y}WU#m9d;Fox;WMx}Ee*1<~JBb#=-gU4DRhg9eS&qM-E
zGeP^S<ily@OVL8)VW;CRYeu<0fW7RlddkMBB%jJUqt+-4CtMjx<wxu{oForH<`J_~
z`n_A?%QRkRkmugS2l?5Id_u@)veynR;w%luA<d7WL<7#liqvKsLI-L3T`(qderZ%Q
zTP2CxbJ-=!gCkQ`d*3XL-A5x*JE{&MHN}B*v^i;+l}M?m)!3vHi3h#~SFF|0j3obs
zJiYkThG!|vy#vf%P_jR!6V5tz8&fkuIS{LZuLB4=R2pGy@CpG`eGV%>cQ;QkT^jyo
zjF&8&HR;S?`r+PB2M<CwoQ-J%ugrdtK0tJ%>fbd?kq<KwzDm_C+Su|naQ0t1JB=tZ
zSP+5BR^a$i;5cyE1<COc2d9};T05##00?YV_X6ij+FL3OIP~xV75;^NSYm-F<|u$O
z7RgY`Z!%6FKnN>Ro19zB00RJRLp@qZ?n=E$Ucr2r%vaY-q+`IQ33-Epd7uGxlv##V
zobFQ@3k=nkA%Va%Pt%7E1C+Z+qd>g~SX9Y90Xox&5Tk@EU9jV4)l7^K+K!BRO~ON3
za#2lrjHIe?y^E?^v7~(BQbQFYE*+ZH=n!>i5SCGqUGXl19Z(LIKa67GZ4IU6=QHw2
zAwQM9u0T7TRR7Ht&BH|SRVhA0+eRa@Vk%*GprxW-E#wkb!e6Y*A_EM?FGp&T<5)se
z?ZTQ@J&6*))SOF+W{{_dy1_Gt<q`qR58*j*v(~Oi^J8#8y$zP|Jqrw<z=4$XKB@tX
zy%v|Es2cyVyhzDCENXtqUEm?q%7DY}h!Q+8LETChK6#<FuJtIz3vXX(ga-0ht5by)
zuhN5lj@L?LZ^JwRQ#I3&3S)>ELTL!NlB)wDuw4T6<u14cj;rcuOA?euAJPlNHY#a(
z(xL~CMPb=c9a1r_!I_2|@!gRXsKwNNK`z#aG8l6{Z>4b}s5sgXrs^vswqWS@eaY-K
zZ^O8}jq2+m2(3ugY-x+i(x}32kvT9;)nWm<C~W6b<}{_t^H8ca0*B06FpRL(cWgid
zfi+dd=JgKCKWJ0BxL${<2FJy9^RfX{2F)z~4X-3-h}&Ui;a{a?QTi6Dt=GQd!C@Dw
zkS<%RkS(WDU8B;2ABe!DY*FWXwb=H@{88)On4h(1?w}YZ4leZS26LfFP68_~xR&a4
z-2<LRC2l&&BV;`BswGha<E@t<m>LkEnC^&{wnNNfN&-Hw{t$CutS|vU4`2{Ok_54f
z=Gdbj@leYc9Kc$lKt4n<CHCl^l>`)(_n$nwpOv}GYUq{9g%qVM7^p{bM6^z;QIcQF
z$ftATkby${rBJ{kz|$={nnT)#V<NaGBzX>O0JYDO#6&Y*&#4)J!q?zrG^oyhIG7~l
zCd?ZuN_1AIcYWw%dQz_L2U;Q}zCP`j1P*{ofM)g?ZhV;v?RZAf2-JOuj~FOOYFcvc
zzzY^>r}-$fLOu^cR}&|R)))-~X*Ox)E9Ip=*VO$(61y-JSCe@J+yWvd6cBUJ5r?NT
z#Df~7q%}g7#=>jzJ__zn8#{6pN@Hq+gaAwC-58zh^&_*;ePRG0Xeu6l!w8QEJzA2X
z-_9WC)5sx^fgU$P-mqQG-cjI2SKrC`(*7EP(=4#HIp6P*uMT+lo>c9H{)1~B+R3`=
zcBzLaZ?u$s$XA9ZF;z;Fb4{METLRO2Wf&Te#X%l4)+2xyCLBQsM<DH^)yx=mNmz<p
z4h~3CcD$B<E-!1O40*JKjw2b)>5%4upc)Ld>>%80q>v4<rot{uOJc<RbzESn8e+^{
zUS4jt=oknOE1z`9i+n?aE$jOJ;loFjFABx1PVqH_`{!=SxcEnDPqjW%sdwGGm6{hy
zc3dVbuGcpv77<Utdg8QUZ*ZFziHftJ-Cl$W7&R%5nh_Y&P=rlr8r*YF-gVz!pl*np
zB^~qC6jirSL<{0|eJEk3#WG*%F6(YzH3D_}kw;CA0BxMQjwt;QRv88Y{O2N`=|JHQ
z-Fa(u6`acqsvbf!u!`eR_w;h-^O`E{`5V$*4pVrUZz?Md_yO}FVJf;9fTUVfJ5`6o
zSYmXvrZJ670W%de&A_6T^#J&WZbiMzg419-a+hf~@GQW^1Vgj~p|4G8n=N7Q;q4%~
z`RdiA?#Z-50W{Lx#4p9v60l1H@XT^vU2KW3Lt4wdgdKVlM^xhlnU2uv@`LW)5?w6a
zZV*~z&4qo$TID-e^b<@Gn*zOnEwX&3XoU@N6*_$No9?R4la3H?zTxawnFoB2M8_9g
zasg8#(L;Tqy)_+=0p;IU)%-ElY`7{zZN}RDuo;%p5P3#|pWmSLqb_GDL{x9%V_A|i
zD?c%i;=Orr@=s#C%Ec%Vb2ZAmit@jOPAENqQktk8GvG5WwA9U#d;IjjsO@@UqbkDq
zo9+~A0?Cq;q*c&YQj#q$%R+i6P?B!ll5K1u(uIJ5uv_-EUEKb0+k$&A_Tr6;2W}oD
zk?4hk5sfAuHSyrlqb6KTJZi$lgNeW2H#2YNy=_GgHb&mgdo%BwZ@zEl`!nx13)OIX
z2B!qfl&UkA!)m2;F??(0@}&`mY_JS<ps~l1q(#{6xUqE*I>VUSMJ6u~&@D4dl8CL1
z6NELmmq>uLBlEdY)IbOULdS4yEGGqU?H(6L(^3PHh|@8)*eqhJ_twI8bMx)9riS<w
zq#N;0i12Ft4y?cO`hrbx7D%y8+mdWaD6Jwl#4He+-G;#~HnR;o@&p!%W1`r+o#7vu
znk1$QAI?NI@1wV93=n8-8uV<NHiz^AtdPYv_#OG>tu5q)8O=BgvZM=gSPM2F)bFw~
zZ88ZcGm?z+77(F^|Fjm3&{h(yFrlM?XJ#~eEFhyA#%43pFQ2T7%ypNLpTmo=5e$?#
z{EdkFQQ+9%TXD=|qLeh7ZQKh{WE{1`z-%E8Dx5|bLU1129+WT-=xK?NBx1l%=u`Bt
zccL411I6%OjjjlU_CK{nwlNAPLERkMwTfk1hHQx%^e_$<VH2U|ZS1V!9Dof39xL~t
zJMk{{XJ)X{yHQE)QZ`T)XEKW9`$L>J6SY<FS7s^*8lQgg)zbs9je(CvWe&F4AO-hI
z<EDC|YnKpsltHPtfU(kTXh8Q@A?78-;-Kx@aO<RfS^E7-IM&Q<Y7u*x76g!T!lQSa
z?JaTvN^w;5c%4oeR;ea5u(p950Ic;+Etn@Kp{2&u#f4L(IG$WXAg12B1wv#2Szn|d
z1+`4Qf-VTE(?)JT3+oLADxfrVQo!{T4l0A0sM?N}Ws6jo3WmtJZAy}91(1Zu&1wXs
zc@RuN2mwKcj8F>%5PzQb9;Ry!C&JWgIR0sy1Z^S{i7Zj8bAtOokjVC!Tf@W|b1KZq
z%8nE}Xd8pN@Vuwnt!**r4Z(&T%a{<+9a3T9Y93b$!6dDnHr&g+fr6L{Po9+Mx1;tx
zG@m&~!)sV%?vj~=+d01cTu_Z``Q#o{QrEuk7I}D{c~Vfx5GhB4K_Rpd9uK{W2_ZW7
z-E#>*Bi=j4&KV01rVwTp+9u#WB5MeMz<tGx0$aut1};Qq+GT<a=^m&6BYO<w880aw
zYEW9csW6>F1dLgQ%HCiiM!lXFmq(WQ29TC1to|dC0ISD5#3YBL7!$Ebl5is8<5-D2
z4%N&|2-1Znn%d1JbKn;2Ye*3-bx;PHg?16xgw#y<1R#cas90TEZZ{i1SwmO}(DvT1
z)*!!KXN0gX`z`cau-P}KJA$cKrbUotq%<f>L1Vf@1BAunW>O1Uyn&68aBi-iwqHai
zs*j`gp!qJItv$of3I3c#V+5C*HE*%ah48q=As32P6`r1xq7I)g8PjF9%)5+)1ryzy
zY03uKy6M?FY)7E%c5g)>#0B&_Y9!u)&-Jk>fB;G`%mj-Y!Xl)7z$OJ2(cKXW(?ke3
zp?d;#;nxULKU5#ZGwpLOZd`$}w^{8uwm^8$&q=vjG8i&sYmB6gGbSawF$w=`4f#(f
zAo~ID*Rp!Zj&b~3Mx`9zH$&0E_{2}x@p8WtjPV~7AZ^!c|AswdF<w)KGddgOx|qoT
zEkJ(&J7JG45MCX?L2y`j4rSEWgJrI&kT~+$?Ayp@b7bI@y<q`EH#X5rZU~q|c?{#s
zoutcKE7>fNOu;t)*6c>|W~J(K*cHIOmD|lFgl4%tME=x4Jv_I7tX2#}X_afY!pbOy
z0MiEXb0N3+M--iRU75up^k8kL$uT~7NZ0K9djF})VB2<K7a0Rms{Nuq?tOlb5*~vg
zq|KJ0+f>VPX|2JnEJ_XZ^$qKM7}uODF=PS2P)M2UkPOff3SkVY3KS~#sk9};$h`zs
zt`v{x&*FBUf3e}-CsbnS4bZ(YLfGE-%A*r1Ogep-&<pErk}aB>2eG+sgMMr~D5oJ1
z&4~TV5v!!{Q8T>Pre*t>)-MKAc6eb4A``ZDyTdBiD46`4T1X;3nz#KSvsLO=>Sfi}
zO~PTmiEVP!ZAAEi`vs^Ym*jDwF(h5h6HJToA%u1%l2^DE<E4@}n=`P<2<s?A>h(*N
zGU}n)-+;DI>m28N4V+?UZr}j}vC2*IjI%gx6Gg1Cz9%|qMO9<^rAZ*oPGhA){Ku?S
z>4IWUaur8=L@^`@<Aaz9k~odR)bW01dTVCSTh!S5k*O3Eq8X9{iQ0QVQn@S$i`A~d
zCtmgVaNiBGXt%!=N7H|=T22v?l94<STP#dsLQ->GfW$<3T7pkduho1;slGs+(l1Xq
zAYeN>so#gg>e5znjVW?R=QO<;1h(UKWU>U88j{%a_@pZ_f#D8C@d3_p6u#xBak^C0
zzRYAaGWS?G_?O2}x?1rI=qvUVsy8$02s&~`A08*;us+#-B!B8b-o^5HUb=rJqef6`
zMjsiiUU=gwy`l(vr`)CPUdoI)tGR-y>lt+nwdVCJ6E^5+cYX%yW(H)x>W=MJ?qX;Z
zQA~pir-C=}YUJtYF3Qdli44$I#3GUeJj=OSmzFTQ?JGWJn)k;LQy?8F1QVpmM5>4_
z$|N91f7*GXFa(GrutXZU!q-0u33_CrKQ@2knzOY{ZbI;p3NdJ3a&vhlbo62N!RDBH
zyWmdWHoGtM8TxW@1~N{u(a2@-I<k?{XQrCrs^LGz7vU+{1bj|*#KRjB?`Nzq2nm$$
zZP10tw7tO++p=*FR-zUR=<dEOzRK;Xx=Sa*##9heu`wIQ!58TXSbtB|GinT|XOJ}4
zL%XME@`WJ#=%?S@9@zIaVuI}9s`dMAXoC&L`*r9`!tJH!LI-itLE53449mD}Qw4Qh
z=djRv09%qP=`9-Qa``3)^M~D-j5Ldh5A!ul1Dc(M_yzp31S3C5RQLHQqQGwuB-Vo+
zV^Kz(faKTp*nYsPDgJM$=vXv|_=^f=DWm^Ny1P0da)~d%0{zrvcMZ2BnMVIj^hA7j
zhME#e60R@afehiZ7OM@Ossz5+H~&wu&(Ul(B7$jcU)En?n;CTqJloc<jb3%zf>ies
zhn=}nu%SOV&(&zif_Slj%br@zs55A!qffu5b+`*~(gVHI1A_z<r4+0Y5s~CmIg3>E
hP#06sLyvUP`zY_R-pPBP)_tyb_WW?}OTF`r{u|cah8+L^

literal 0
HcmV?d00001

diff --git a/proto/types.proto b/proto/types.proto
index 8e9cedb..e7ba3bf 100644
--- a/proto/types.proto
+++ b/proto/types.proto
@@ -71,4 +71,6 @@ message Envelope {
     bytes plain = 13;
     bytes cipher = 14;
   }
+
+  optional string relays = 17;
 }
diff --git a/src/bins/rmb-peer.rs b/src/bins/rmb-peer.rs
index c62c4dc..8c39e06 100644
--- a/src/bins/rmb-peer.rs
+++ b/src/bins/rmb-peer.rs
@@ -1,6 +1,5 @@
 use std::path::PathBuf;
 use std::str::FromStr;
-use std::time::Duration;
 
 use anyhow::{Context, Result};
 use clap::{builder::ArgAction, Args, Parser};
@@ -151,12 +150,10 @@ async fn app(args: Params) -> Result<()> {
 
     // cache is a little bit tricky because while it improves performance it
     // makes changes to twin data takes at least 5 min before they are detected
-    let db = SubstrateTwinDB::<RedisCache>::new(
-        args.substrate,
-        RedisCache::new(pool.clone(), "twin", Duration::from_secs(60)),
-    )
-    .await
-    .context("cannot create substrate twin db object")?;
+    let db =
+        SubstrateTwinDB::<RedisCache>::new(args.substrate, RedisCache::new(pool.clone(), "twin"))
+            .await
+            .context("cannot create substrate twin db object")?;
 
     let id = db
         .get_twin_with_account(signer.account())
diff --git a/src/bins/rmb-relay.rs b/src/bins/rmb-relay.rs
index 1732bed..a00230c 100644
--- a/src/bins/rmb-relay.rs
+++ b/src/bins/rmb-relay.rs
@@ -4,6 +4,7 @@ use std::time::Duration;
 use anyhow::{Context, Result};
 use clap::{builder::ArgAction, Parser};
 use rmb::cache::RedisCache;
+use rmb::events;
 use rmb::redis;
 use rmb::relay::{
     self,
@@ -142,14 +143,13 @@ async fn app(args: Args) -> Result<()> {
         .await
         .context("failed to initialize redis pool")?;
 
-    // we use 6 hours cache for twin information because twin id will not change anyway
-    // and we only need twin public key for validation only.
-    let twins = SubstrateTwinDB::<RedisCache>::new(
-        args.substrate,
-        RedisCache::new(pool.clone(), "twin", Duration::from_secs(args.cache * 60)),
-    )
-    .await
-    .context("cannot create substrate twin db object")?;
+    let redis_cache = RedisCache::new(pool.clone(), "twin");
+
+    redis_cache.flush().await?;
+
+    let twins = SubstrateTwinDB::<RedisCache>::new(args.substrate.clone(), redis_cache.clone())
+        .await
+        .context("cannot create substrate twin db object")?;
 
     let max_users = args.workers as usize * args.user_per_worker as usize;
     let opt = relay::SwitchOptions::new(pool.clone())
@@ -175,6 +175,14 @@ async fn app(args: Args) -> Result<()> {
     let r = relay::Relay::new(&args.domain, twins, opt, federation, limiter, ranker)
         .await
         .unwrap();
+
+    let l = events::Listener::new(args.substrate[0].as_str(), redis_cache).await?;
+    tokio::spawn(async move {
+        if let Err(e) = l.listen().await {
+            log::error!("failed to listen to events: {:#}", e);
+        }
+    });
+
     r.start(&args.listen).await.unwrap();
     Ok(())
 }
diff --git a/src/cache/redis.rs b/src/cache/redis.rs
index 13320f2..b303256 100644
--- a/src/cache/redis.rs
+++ b/src/cache/redis.rs
@@ -1,5 +1,3 @@
-use std::time::Duration;
-
 use super::Cache;
 
 use anyhow::{Context, Result};
@@ -22,19 +20,13 @@ use serde::{de::DeserializeOwned, Serialize};
 pub struct RedisCache {
     pool: Pool<RedisConnectionManager>,
     prefix: String,
-    ttl: Duration,
 }
 
 impl RedisCache {
-    pub fn new<P: Into<String>>(
-        pool: Pool<RedisConnectionManager>,
-        prefix: P,
-        ttl: Duration,
-    ) -> Self {
+    pub fn new<P: Into<String>>(pool: Pool<RedisConnectionManager>, prefix: P) -> Self {
         Self {
             pool,
             prefix: prefix.into(),
-            ttl,
         }
     }
 
@@ -47,6 +39,15 @@ impl RedisCache {
 
         Ok(conn)
     }
+    pub async fn flush(&self) -> Result<()> {
+        let mut conn = self.get_connection().await?;
+        cmd("DEL")
+            .arg(&self.prefix)
+            .query_async(&mut *conn)
+            .await?;
+
+        Ok(())
+    }
 }
 
 #[async_trait]
@@ -57,12 +58,10 @@ where
     async fn set<S: ToString + Send + Sync>(&self, key: S, obj: T) -> Result<()> {
         let mut conn = self.get_connection().await?;
         let obj = serde_json::to_vec(&obj).context("unable to serialize twin object for redis")?;
-        let key = format!("{}.{}", self.prefix, key.to_string());
-        cmd("SET")
-            .arg(key)
+        cmd("HSET")
+            .arg(&self.prefix)
+            .arg(key.to_string())
             .arg(obj)
-            .arg("EX")
-            .arg(self.ttl.as_secs())
             .query_async(&mut *conn)
             .await?;
 
@@ -70,9 +69,12 @@ where
     }
     async fn get<S: ToString + Send + Sync>(&self, key: S) -> Result<Option<T>> {
         let mut conn = self.get_connection().await?;
-        let key = format!("{}.{}", self.prefix, key.to_string());
 
-        let ret: Option<Vec<u8>> = cmd("GET").arg(key).query_async(&mut *conn).await?;
+        let ret: Option<Vec<u8>> = cmd("HGET")
+            .arg(&self.prefix)
+            .arg(key.to_string())
+            .query_async(&mut *conn)
+            .await?;
 
         match ret {
             Some(val) => {
@@ -93,7 +95,6 @@ mod tests {
     use super::*;
 
     const PREFIX: &str = "twin";
-    const TTL: u64 = 20;
 
     async fn create_redis_cache() -> RedisCache {
         let manager = RedisConnectionManager::new("redis://127.0.0.1/")
@@ -105,7 +106,7 @@ mod tests {
             .context("unable to build pool or redis connection manager")
             .unwrap();
 
-        RedisCache::new(pool, PREFIX, Duration::from_secs(TTL))
+        RedisCache::new(pool, PREFIX)
     }
 
     #[tokio::test]
diff --git a/src/events/events.rs b/src/events/events.rs
new file mode 100644
index 0000000..fb2c1f1
--- /dev/null
+++ b/src/events/events.rs
@@ -0,0 +1,40 @@
+use crate::{cache::Cache, tfchain::tfchain, twin::Twin};
+use anyhow::Result;
+use futures::StreamExt;
+use log;
+use subxt::{OnlineClient, PolkadotConfig};
+
+#[derive(Clone)]
+pub struct Listener<C>
+where
+    C: Cache<Twin>,
+{
+    cache: C,
+    api: OnlineClient<PolkadotConfig>,
+}
+
+impl<C> Listener<C>
+where
+    C: Cache<Twin> + Clone,
+{
+    pub async fn new(url: &str, cache: C) -> Result<Self> {
+        let api = OnlineClient::<PolkadotConfig>::from_url(url).await?;
+        Ok(Listener { api, cache })
+    }
+    pub async fn listen(&self) -> Result<()> {
+        log::info!("started chain events listener");
+        let mut blocks_sub = self.api.blocks().subscribe_finalized().await?;
+        while let Some(block) = blocks_sub.next().await {
+            let events = block?.events().await?;
+            for evt in events.iter() {
+                let evt = evt?;
+                if let Ok(Some(twin)) = evt.as_event::<tfchain::tfgrid_module::events::TwinStored>() {
+                    self.cache.set(twin.0.id, twin.0.into()).await?;
+                } else if let Ok(Some(twin)) = evt.as_event::<tfchain::tfgrid_module::events::TwinUpdated>() {
+                    self.cache.set(twin.0.id, twin.0.into()).await?;
+                }
+            }
+        }
+        Ok(())
+    }
+}
diff --git a/src/events/mod.rs b/src/events/mod.rs
new file mode 100644
index 0000000..3a34494
--- /dev/null
+++ b/src/events/mod.rs
@@ -0,0 +1,3 @@
+mod events;
+
+pub use events::Listener;
diff --git a/src/lib.rs b/src/lib.rs
index 71e0a38..e3e063e 100644
--- a/src/lib.rs
+++ b/src/lib.rs
@@ -3,10 +3,12 @@ extern crate anyhow;
 extern crate mime;
 
 pub mod cache;
+pub mod events;
 pub mod identity;
 pub mod peer;
 pub mod redis;
 pub mod relay;
+pub mod tfchain;
 pub mod token;
 pub mod twin;
 pub mod types;
diff --git a/src/relay/api.rs b/src/relay/api.rs
index 0c86fbd..c699bd6 100644
--- a/src/relay/api.rs
+++ b/src/relay/api.rs
@@ -1,5 +1,5 @@
 use crate::token::{self, Claims};
-use crate::twin::TwinDB;
+use crate::twin::{RelayDomains, TwinDB};
 use crate::types::{Envelope, EnvelopeExt, Pong};
 use anyhow::{Context, Result};
 use futures::stream::SplitSink;
@@ -17,6 +17,7 @@ use prometheus::TextEncoder;
 use protobuf::Message as ProtoMessage;
 use std::fmt::Display;
 use std::pin::Pin;
+use std::str::FromStr;
 use std::sync::Arc;
 use tokio::sync::Mutex;
 
@@ -203,6 +204,24 @@ async fn federation<D: TwinDB, R: RateLimiter>(
     let envelope =
         Envelope::parse_from_bytes(&body).map_err(|err| HttpError::BadRequest(err.to_string()))?;
 
+        
+    if let Some(relays) = &envelope.relays {
+        let mut twin = data
+            .twins
+            .get_twin(envelope.source.twin)
+            .await.map_err(|err| HttpError::FailedToGetTwin(err.to_string()))?
+            .ok_or_else(|| HttpError::TwinNotFound(envelope.source.twin))?;
+        let envelope_relays = match RelayDomains::from_str(relays) {
+            Ok(r) => r,
+            Err(_) => return Err(HttpError::BadRequest("invalid relays".to_string())),
+        };
+        if let Some(twin_relays) = twin.relay {
+            if twin_relays != envelope_relays {
+                twin.relay = Some(envelope_relays);
+                data.twins.set_twin(twin).await.map_err(|err| HttpError::FailedToSetTwin(err.to_string()))?;
+            }
+        }
+    }
     let dst: StreamID = (&envelope.destination).into();
     data.switch.send(&dst, &body).await?;
 
@@ -309,6 +328,25 @@ impl<M: Metrics, D: TwinDB> Stream<M, D> {
             .await?
             .ok_or_else(|| anyhow::Error::msg("unknown twin destination"))?;
 
+        if let Some(relays) = &envelope.relays {
+            let mut twin = self
+            .twins
+            .get_twin(envelope.source.twin)
+            .await?
+            .ok_or_else(|| anyhow::Error::msg("unknown twin source"))?;
+
+            let envelope_relays = match RelayDomains::from_str(relays) {
+                Ok(r) => r,
+                Err(_) => anyhow::bail!("invalid relays"),
+            };
+            if let Some(twin_relays) = twin.relay {
+                if twin_relays != envelope_relays {
+                    twin.relay = Some(envelope_relays);
+                    self.twins.set_twin(twin.clone()).await?;
+                }
+            }
+        }
+
         if !twin
             .relay
             .ok_or_else(|| anyhow::Error::msg("relay info is not set for this twin"))?
diff --git a/src/relay/mod.rs b/src/relay/mod.rs
index df6532b..15db835 100644
--- a/src/relay/mod.rs
+++ b/src/relay/mod.rs
@@ -87,6 +87,8 @@ pub enum HttpError {
     InvalidJWT(#[from] token::Error),
     #[error("failed to get twin: {0}")]
     FailedToGetTwin(String),
+    #[error("failed to set twin: {0}")]
+    FailedToSetTwin(String),
     #[error("twin not found {0}")]
     TwinNotFound(u32),
     #[error("{0}")]
@@ -109,6 +111,7 @@ impl HttpError {
             Self::MissingJWT => Codes::BAD_REQUEST,
             Self::InvalidJWT(_) => Codes::UNAUTHORIZED,
             Self::FailedToGetTwin(_) => Codes::INTERNAL_SERVER_ERROR,
+            Self::FailedToSetTwin(_) => Codes::INTERNAL_SERVER_ERROR,
             Self::TwinNotFound(_) => Codes::UNAUTHORIZED,
             Self::WebsocketError(_) => Codes::INTERNAL_SERVER_ERROR,
             Self::NotFound => Codes::NOT_FOUND,
diff --git a/src/tfchain/mod.rs b/src/tfchain/mod.rs
new file mode 100644
index 0000000..0832754
--- /dev/null
+++ b/src/tfchain/mod.rs
@@ -0,0 +1,6 @@
+#[subxt::subxt(runtime_metadata_path = "artifacts/network.scale")]
+mod tfchain {}
+
+use subxt::utils::AccountId32;
+pub use tfchain::runtime_types::pallet_tfgrid::types::Twin as TwinData;
+pub type Twin = TwinData<AccountId32>;
diff --git a/src/twin/mod.rs b/src/twin/mod.rs
index 17f2e63..a91edf1 100644
--- a/src/twin/mod.rs
+++ b/src/twin/mod.rs
@@ -15,10 +15,13 @@ use subxt::utils::AccountId32;
 pub trait TwinDB: Send + Sync + Clone + 'static {
     async fn get_twin(&self, twin_id: u32) -> Result<Option<Twin>>;
     async fn get_twin_with_account(&self, account_id: AccountId32) -> Result<Option<u32>>;
+    async fn set_twin(&self, twin: Twin) -> Result<()>;
 }
 
 use tfchain_client::client::Twin as TwinData;
 
+use crate::tfchain;
+
 #[derive(Serialize, Deserialize, Debug, Clone, Eq, PartialEq)]
 pub struct Twin {
     pub id: u32,
@@ -41,6 +44,20 @@ impl From<TwinData> for Twin {
     }
 }
 
+impl From<tfchain::Twin> for Twin {
+    fn from(twin: tfchain::Twin) -> Self {
+        Twin {
+            id: twin.id,
+            account: twin.account_id,
+            relay: twin.relay.map(|v| {
+                let string: String = String::from_utf8_lossy(&v.0).into();
+                RelayDomains::from_str(&string).unwrap_or_default()
+            }),
+            pk: twin.pk.map(|v| v.0),
+        }
+    }
+}
+
 #[derive(Debug, Clone, Serialize, Deserialize, PartialEq, Default, Eq)]
 pub struct RelayDomains(HashSet<String>);
 
diff --git a/src/twin/substrate.rs b/src/twin/substrate.rs
index cf7b018..7ac9d21 100644
--- a/src/twin/substrate.rs
+++ b/src/twin/substrate.rs
@@ -78,6 +78,11 @@ where
 
         Ok(id)
     }
+
+    async fn set_twin(&self, twin: Twin) -> Result<()> {
+        self.cache.set(twin.id, twin).await?;
+        Ok(())
+    }
 }
 
 /// ClientWrapper is basically a substrate client.
diff --git a/src/types/mod.rs b/src/types/mod.rs
index ab26689..71dc005 100644
--- a/src/types/mod.rs
+++ b/src/types/mod.rs
@@ -338,6 +338,9 @@ impl Challengeable for Envelope {
                 hash.write_all(data)?;
             }
         }
+        if let Some(ref relays) = self.relays {
+            write!(hash, "{}", relays)?;
+        }
 
         Ok(())
     }