From f6ff20eb0e21f15181a0f45f8a6b611a2deb6342 Mon Sep 17 00:00:00 2001 From: Abdul Rabbani Date: Fri, 25 Mar 2022 09:54:36 -0400 Subject: [PATCH] Handle All Gaps within Geth Including an updated doc which keeps track of events in this PR. --- statediff/docs/KnownGaps.md | 18 +++ statediff/docs/README.md | 3 + statediff/docs/diagrams/KnownGapsProcess.png | Bin 0 -> 53660 bytes statediff/indexer/database/dump/indexer.go | 3 + statediff/indexer/database/file/indexer.go | 4 + statediff/indexer/database/sql/indexer.go | 21 ++- .../sql/mainnet_tests/indexer_test.go | 28 ---- statediff/indexer/interfaces/interfaces.go | 1 + statediff/service.go | 125 +++++++++++++++ statediff/service_public_test.go | 143 ++++++++++++++++++ 10 files changed, 313 insertions(+), 33 deletions(-) create mode 100644 statediff/docs/KnownGaps.md create mode 100644 statediff/docs/README.md create mode 100644 statediff/docs/diagrams/KnownGapsProcess.png create mode 100644 statediff/service_public_test.go diff --git a/statediff/docs/KnownGaps.md b/statediff/docs/KnownGaps.md new file mode 100644 index 000000000000..51f0694023df --- /dev/null +++ b/statediff/docs/KnownGaps.md @@ -0,0 +1,18 @@ +# Overview + +This document will provide some insight into the `known_gaps` table, their use cases, and implementation. Please refer to the [following PR](https://github.com/vulcanize/go-ethereum/pull/217) and the [following epic](https://github.com/vulcanize/ops/issues/143) to grasp their inception. + +![known gaps](diagrams/KnownGapsProcess.png) + +# Use Cases + +The known gaps table is updated when the following events occur: + +1. At start up we check the latest block from the `eth.headers_cid` table. We compare the first block that we are processing with the latest block from the DB. If they are not one unit of expectedDifference away from each other, add the gap between the two blocks. +2. If there is any error in processing a block (db connection, deadlock, etc), add that block to the knownErrorBlocks slice, when the next block is successfully written, write this slice into the DB. +3. If the last processed block is not one unit of expectedDifference away from the current block being processed. This can be due to any unknown or unhandled errors in geth. + +# Glossary + +1. `expectedDifference (number)` - This number indicates what the difference between two blocks should be. If we are capturing all events on a geth node then this number would be `1`. But once we scale nodes, the `expectedDifference` might be `2` or greater. +2. `processingKey (number)` - This number can be used to keep track of different geth nodes and their specific `expectedDifference`. diff --git a/statediff/docs/README.md b/statediff/docs/README.md new file mode 100644 index 000000000000..51b63e20747a --- /dev/null +++ b/statediff/docs/README.md @@ -0,0 +1,3 @@ +# Overview + +This folder keeps tracks of random documents as they relate to the `statediff` service. diff --git a/statediff/docs/diagrams/KnownGapsProcess.png b/statediff/docs/diagrams/KnownGapsProcess.png new file mode 100644 index 0000000000000000000000000000000000000000..1da3fa68d18f40123d7151618b02fdbcfd4c002b GIT binary patch literal 53660 zcmd42gwcej8bA>Gm;-62Zeh0pi? z?!EuP<#~AE%scPYnVB-4Fzy1~NQ@q?YKl!AtxvuAEWDKt33*~3@g^n-H%{)A0+u#DBk@H;{X5r;gujPP=wav>KmiM1&mcsYOt{=;VVjvE*-WxH~<0w zYn=5q=yh%{X$wCjuC(I8kzRbY+c!JlEoa&^_g(ET zWB|ZK1#Rq>*wG9KfRt*uwYU-3tIiJgk-&Z0#G)0OwTIjJKVs5xwFr^8%r#8sZ~|ea zN}|6LLkKVc0DMVz{iZchstg?f07j|z9#&l~Wo85b$VMwFx)5`r005!6!`}ju)P;b6 zHAag!!kOJFVgLYTIBzy!0i?tV#|$km+@%*?hAWFLr6nhUuiOj*0AwT>+uR7Ux(h|k zUqFSeE0EL8-?&U#r7()D=U)IU6jaOf0!N&hXwqq{X(yN)#e!}c0qvQpNo1b2*NU2@ zQ7e0ISc%h36M(YmTP`Ip!lTanUm5iMu~JzjhBgJFY01Tnd~X*%4yf!lT9}vt!3^;6$VlPQ)NP5FUk?=zB2@Z-N0aL)omxS+RWL^nJrI%8VV?$ z*mEg1>LmwPggOB1dH!1G2TkN{oZFU^s1rJXPMH|_0Ak@JcFtZI=Wzg(4QIui4H#JW zvoKoWNT7`XSU|9m4`eMI#cKJ!rDA{qd$53RK|->n*gHeWzic4D`gy#!8cT&KVMT=q zfJo#!RL4l2Uz?MdR+EL&Ai(ekDawQ5Ztmv?CEINoBtS625{mM?Cx9F?%vQYy@IS!c z`}ucVJ&Fn9AQ*8tMR{-BpZj@L!AsVu2?Q9aHAVR*9Pl+zQLkY9yS(8nP4fbm+wAXw zS}-vnJg%`@@P*te4m+Cnlp=-r$(5RC{=I>|4x}ewKdWz@2`KKX5Aai-L_UD#`-mwn zXCHsD9pG_dO3%rS*j z<{B2Ed0*{m?De3&d&m`6D9PLWFfOPlSMJK8@Uh2AB-!kN|NF}U)gLQSNynRN5T(H1 zH1$y)+QBPQ`X9P7NpSNTzHWz99L~-WLfhr$O{n5sPh>I#*GKCAW z2_ze+ZsRzpB(Z2Jz*XWeulpNqQ@+?~uUx2=i934eVcOKs6mjrry3}?r&ysCVO6WY< zJ|()Ej<#q)n|HEbec0w5Tb{#`n6LhHz6&e3oVpHrXrU(pNRO-R7JN0h5=*-cv3gTM zA4~0;Nc!>8H$ozEmoWmgf$81*K+m;Z_-FOcWu~QqpG}7KTtw2~cp*~k`;79&dLmyo z`FDCfGK_lzdDrSKM#>70Nv-*&t_%IiSAJt`N0l2%OVcjE{Oi4C50SpP(|xSQ zmM^_FS2Ag%EVcY-KO>xsi)2A)HvaydA6q<#Yl;@rTwg5&%&95G;ytIc(^)#ry{|-- zU~+^cRQ%T%pWtL*qoePWsitD@t>HX^Ks&M;c2n7GQY50kkA|Djzdx>r1 zlN&*p+0ywX*G0KIet%YlfUxd~Zt&kaQaY`E&EhHA{$ji@{o#+mOdd6$h!a**e3#sg zd@UHLhb0d2q6ucB(EK6pN+d`WFT{5-<0_=CjV_nNjSA=jYX-S#;CE0*()!sZS?8w} znN)vC%%|reJ7xr{2_bhypAKGjYhB_OcXC{_OtHmdjJ7a+~DV z`2nXl!KNprB@m@a%A>!VY^cJAXu*lhh2?{~=&WrTy|-N@I5VDHw=PD3kcyOl?nOgl z4i=rgwy1w?ihDl<3k@c~fNIN4nNX$Bo&2yV7C=P}51yl#clq->>{q7d7nGCF;!7@6a%qkrmJV z2S{QH!mfl35B*Q6bXcHHE!9N>rJKXzif&-R!cubfB0a>ppj{3_wJ~gn^R@Z4Hx%??cT?gJz*S+ zUEkG#`!^ARGKZe`$x@0{Z~oAJkFtsb1=8(*SbCwl4AFZ=w0eek4qxtX^hvwJmj)0I3Rj%kM>zaim4S$-yMGr@qZ_1`qU5rPA z5XBO{LNn;^aDSb@-#FAxsy_CSE!Bm{&jxaO z3n}#I%0=@#d`^$$r8bk1Jals2IbEJ{|*V0G{oq& zDr{zW{2aKc?fw)7kBkbDb8c9vbg{NGaJ(YjVgiTCdc{1M?>ie1&66gWSh^a)WIPYs zx=C3&Y}dUwq87&<#TjQ;;7wCwWXdTcKvU7NyN%{rYRQT|8e*( z^ZMD$TGsvyj-^ty!paU!Rj6D;k7dCaYgt*Obe1chl2TlA|8!?t5r=EulBd)O)~#zU zRPhBNXZFg`Z4Lb<-Vl2Z+<7>h^dbCMnOb_2d==Dj<({e3|11=Aewyb=_oMYrecHW? z=-L&ZX9Sx9W=JYG17`Yyx8EPr3Ne_X58h^6Q5X6BjJ;1Sjn<4&>MU)s zljDr!>?+c7J}{PNnX!H*O^U54w`1WKbou&PQI-ABi4a$-z@(Q#etP*w$7b+rPd&&Vq7f-xkJ91pM4L&BurGISWNKU0i*dABs&t zDb>XmP-*!J`~I#AP=?<@ktZe)daqvBxd;$?qIs-+QP={q_hQ_=<=A zR2@O73_*+r%s@_5BuDEKr_uGRT5zXN#`EgZ0X6I-vmx@L!$qt!r0c-H*#F#xVM&0x zzmz;G5OB&ZhAMl)@Zq1P8CEm@<<}2u{FN-pEsX-_b7&~{#QO5DbI65`+|V62{7@EW z`J>8HddZ4R21Ywh>M({ChO1v7;0@bpTV0hyaVygBgF|PCkG!|wn#wBR4HUHU`o43q zk6FD)ThAW-jdR6d9VV)h+kN~xlMS%aejo4rFs-dt3AJ&}RpKg-0c@k_#lY2+ zF`8@>G46Gf+s1;CSh){^+r^}%O~4fHeU}{TtHXqWuFl^>-b277>~6eI29RWPFwMwb z2~kqZB@fnx3Z!gXWu^d%>4f>+f97A<((8T`B^vXIEAdNR*&#V#F3jM!8f4>Bf1l-B zfqns|=@77u!Grxorwuv6zkio`P)GS!Zm+NDOK2Z{wu0{qr# z^-g-IvT~L}(xy(#4vjsXKTEkK z+^O9ne<9h0`9ywBxam7nkE}q?@Hn(It0+a=emJXXCu6-dFEKR3JE`!G0D|%38rO&A zS5zoTEf0Z=A87dtR`l%}g$->aCmIO@W-kPW#Rr(kqZjAIoNwSok-XbVnG10J*Q)lB z89M0vO59Zpm>}ldS?h>JM{ilA6IE5ez8tj6n2dq_jR1r{Wq*M)(nUEd+Uen?%6-Mn zw#XXq5- z5oY@OlU8Ywq5!>jO1t%5h3e(oaQ4fuaMDQ+W?fPwf`fI|b+#GGnj4_DTyZMzUL*m=0jhPwUq#(%xW1>H;(B8fr(Pu@eW4!{G9sR|5z3jQ)?wC+b zC2E*zDPBg|TAq{1%n!>&22Z$T3{R55OIF`{&5Fd@P3}JhZjaU)M-Lx;Tgl|5%*DLy z&&}UnK9fRyB6Z>C!^^p5kf>1UoR!J?9>45JM){pT`;=DNH9UC-h6=O6OLc1QIzH>Z z(AZl!YsE_=(5dJttVpW#I&ab1X;C>#yA+Pv6aYt6>!8l2uvtlr4MEBGf(t|OB+SCC zs_oYI8^$9Ugv5jnxD7C#Y;b)4ciOcL>)$Eipz8@ezyXBgsh969CYp3={#G<2pMKdJ z?OXb{w^_t!t2nnMWQ+PVqQbp&>u{*|6O?H+c8pGBH7b^&RQVrVBH|~BhORe-uI#${ z8A|6XW&aO!@_JMM%Fe@?OKufzKj4$nw|+h)okx6s6^Ry!te>EO|2MP;s`TqgdFYe! zUDT^34!2068h!3k8*u1q(375B)W&eAXD3$){S{oKs&2SQC9APj(@pon#;ID_H*iOo zdvb)WlOKHhi+&lgnl*-TcW`La6ZG=r2MHXS#!*15^az(;;YoVr>z9v{U}M1`%wu{$ z7XsWK@cxCU{^}nLpR#r{BRe zuFSxOpM~M-A8&EM{{g{tHSBJbNDpQHnvrt(>6={7dmRu%=^K_?k#OSdd>0**f`g&Z z<*8%(mI+Z(F0$;=M!1dCYaozs4-2Xx$9MlEV$S%^qAh}{*UARLG+>j*FRg=aD>%S`eM&Y^#<$;3WQZCF5HsL41!9dy)&pSky@(b%2~ z5fQ4WVsk)D86!&VpZ;U|UON^A2n3UW!K<&@ZW>o#GzLHcFbrH+)yu@?RVrwfEEC7A<%Yz(LN4B3IajcArM}glu59D zJ;DDyO1NoECsYmokC)v*Zs!p%*Z%~epn2nH=9d1&`G17MFyVx_r~k)CKhDQ@kwdG- z5cnV8^teyHiz9_X5)i-u66$~@ozbd$T`&tSF2ETGs-=>fYr40A``iD8|3>n;@TZ3V&(ny#RzxC;MJ@6FST%lWRba34 zp0WGI5%`}T(bnmLHT!B(%eHB|c>mK>rmRr5KlXiu<$>bG|AY|H)Gd>KC7!qM{4s_6 zKVEbJjIQ{EXg{MvpDE$ONdLnH;UoM<2Vw?!=87td`JY*U;r}xLm=g>JY=ICF>5%`U z1^q6o3Sq9f!pxk*)gMDg5<&ri@L!4mYt%~Y59okZ<4p8Nv)VX^WT>dJQPYU|M;h7R z5bx)3JN9|sMWg+}f>V+<198!PaeO2ztyHQ%q@M@k!X>gslP$ZkP^0e(*(16Euf2sp zAZB#*;6k|)9uC^{pFFs97*DUNf#N?*-0aNPe;1kOd3uitO}5~0_T48Gt@k2P2$M)p z($E9R(kt{&U!*y~gTWW>QQ>hgC~A`3-LaDLvm$iT5+K?sYxGgXeAFkZf}q;G>pxVP z=(1=}V!I;dD-_aq$-sNHfJ3||hy|jBc8!8iI0M3yVZ!60pxkX~A`>TcUoq+6(@Q7K z45}@|Mr{SJy?hp&7F@^c2YF2tpkt+JPAREXpt>mb&IZuj0Si@34|VU zZ@XE=4Vrj^!C+1`Tv$iGlNgHia<_K?6h2Q7h;68?Lt`8J|dM#p-=p!)mbiFrEu08Pjjj~A~1olo=8UkGxJ0?+xPFb8ow&0b9blrk3~ zkRA0C#S^wZ`hY6F@1cM$#@|;@V+!;EQ#Gs?+mhX(PkPU*Kw=UO@A$3IMbV##xr3a) zUY{dmGXJG}RupX@4!!fZ;RDBC_GjK`136|1=h1v+mq9I{V82@?8xav&tvno$Kqz!; zUJ(+*BSbqv#!->T>%;oq+YT$|1-G7F$Gx0d-HvkU@=m+wvpFje^ZC_Kf?L6Tv+tTi z5<`3|E;|7|nRAT61pIR=y;(9wic}~AHD85kS9&F8AsKTYU#|V}V8|S;5@SKTAYWnyE zDL;+PkH{nM1a-i*J<_2PEe!8yuladSUV^RDrefpsEzmXpl&*((0LL`y3(NJ2ILkq+Hn>~g$0KRaB?FD-Hq6soXK zs`bN^ED@iS@D^l#HYDl*5biMv7J43Y2%HTkG}TZIi^IV{9ESCWiPm$_M%1UNxl$LA zph;a1kq$Gmj%IADsrt!794F-C)?1<#yH^^%T=tpGW?xm`?YZk} zi$jo&ND=ehZ-38H5k9%!J4CwG;#p&u*-|Y5E%BBuh9vR znS}2uf0wEqIri3i)H-N<_heahndFVCQNJ?xkQk0oT-L|^CMp6qBp3AZa15-VP6$Vg1p8VQnQsIC-@Tdw41J#2X zm3&YKRkp77Bme^#XR1!#T-+;f1yXAr)5DUEw*O&BYHC&JhKSWwW|VRFMP@e*5m($k*Rtd{Ej zmbQtq$g?s9;Dji#f-&mA;FVkP&P173JhcrOc6+|2A8v=ouNl>%-JhS`nn^nWPf}eY z(REy(Zf1Gm;>IJrki?{eQyckW>evfED4wf3GkX?O8&L1SA__! zIQUM3S>e$TU4M~6Yg#{hWI`PGeqLMOyz-_usW0UZM%k49zUlKuy71l5W|sIwc68L(s^Q*!6hy@Q z{wAa?6YHfhIqr&E{EJ>xH@B410M^0t7gv$lD@r~e zk5-UA9{|c@ObqK?9P4G-<$yw;t*s3)5v9qga^VNo^riMgbyftY zUUVK1rnRr!L5T~`xZnSlLi36HTG2vd%#p_+6I1@hUH2FHG*21FmtfZN8C_Nt-XP$-_v-r$l|=%!1Z@M#`*?z$BuRss-1G+iWcaRuMeiHiP}C0wR|ZXF zqYXIsrD}mLAbY$(4gSS1dEUE2>4Ht#zqA zKBpWC6@ID%`?V3bQj0Y!jvI^V54cg!22DL1-RyE2h*bH4)jVeXBYtkCIiQDap*d=6 z5&E$m`-(%dke|GV1$3@BzW)wb(wsk@xSsR4wB+9C#zk4gzE|x)4Eu?Y?mvMLR~i@7 ze;>4=r~FiKoM8bynWJyt0Viw&>TNPSnFrfRvTa;&aph2K63LZMNMP+#t&e7ylA~y# zIKo4wXU%EA%D=JOnZV|_xLxw}n%5<~@IFgpmByC6R}*wAQ~k`tv>nkvNBMc)k$|4; z-YwcF>QT|;Y_a&HY!q`uuZy&1OB38@zXarp>odJ$k{R0HF|uo0!Ldv?8k*=@$8b&# z9@BC!Wzm0hD@vQ>i*C$+iK}@s`$Ph7${Z=7i8^V{#ClVl0r z)i`BUnS3UOKAH`kgWy0Q4k(j!V=57mi;>R7*nsQ_YW4d<_YoL)xhV zJ6?EA$k9+I-!|qKB0RgidBHBYpD=Y zgT-A>!YdoYONe|I`$>!%k{U>y05QLGMtzgK#a-NzI#ESibhPzrRRupsFjN@rX;ycT zwg$P6%dy!OH*<0x^?1*f@FM+5UTD>S|9>oJjzxGVYO zT}1M75Wi$twr!FX<@f_V)w?UABY3fNOrK`(9-fs+Dz9niQ1DyWqp)JQ^;TV#Z!TTl z9UT7{2$whh$G_^}WY_0uT1ZuW1bqsucBn9!?e~2!_w8r8@PKXX-jcKgCMlp(NQY_L z=u4XQkvTVhMT58Q1qYme1sJ0VFx@>Tf@5aKK4ZHGwI??hC=p6`6<~uT?uqaje<5KE z?0QQrU2`sR3WWE&i7(wKiM28?1i?K3&xhj4;ISA3byHM@$5Ql&Rwza6l9<{NAhlt? z#L>pNESLb}C}C2W zvCcfD$FtPgv$0E4tw9{muH^*ubZ-nI!KK-Gtz0Unamz%l3hB9ws!8i2oW2P2=XLRM zXu>3GxIFow?B|P*OdyJ+e9t6_+@wIFwdg|q`HD7qfbQ59A;l*?;o4`EL8i^juVw^K<2>go~X^(I=Bz z3)p(eYu)snyYlt0aucXoDQT2Mm^ct6OLn}$sYPxm#?KMj3p)29mTDZzY}$0L9k&}J zzPH6)euIXpAm8RFnW7x8|eH?Sf9PT zOnTHA|26z=>MNfY8#wvSTpVJ-UtGx1%<}R!LZ7#ICzKmjL@JE^wFV zZ|k{*Pgfbyb5VYlsMPU!t>hv+8%d_HpHI&Cyk4jRJ?Uk62op;qKEEk$kRnQn*l*vS zHW)5xaMx4A;`OtWq}i@=Gw8#-(Aagao@sYi*vpC<`^PQg-502qw75JyhPxh?gIDoM zG?By*_Z0lJXk-(@iYA+>Q{XxHe_Z5%gFM=6P2Fyw*yr>u4jkmw|JT(0`TvZ&Bd_w- zr+Zw567f zLFcX(Ds0?}M~U;4F`f{5)ciTX2G_}+#e9;V(WtcggHKn9aDzpH+MY#{gsk8tk(c>| zCBIotGgT^PDd#X^VSbENUS-i!O3}x9c=zxV-ie*MvGeKiXd^;HUQ{#BKW3 zgP^4u>8qXLH78uE;sIHD(+n@`==x<4x2P^Q+M$FRl*_)9MP5`%9FsXETx?x+e5IS_ zrIT_1?LRQ?s@vQTsG146A?^D2%2jbLAjDA_g4b&s9K(icD2 zrV?e_@&kH2&v!7iot_VjCd&w6Ct^{PS;iij87&zyc|TvN&wz%IQb3RPbz_@|WyB0K z|M&8l=u)M8UAZlLp_CJ5{u$Av93(?8nkYr`x6x5FJ>TD?=h}BOvbc!C0KK-efZwq7@o=Y z?q2V~wQ5ut4Z1+OaV>1FH7wnI^P+IjAXG(H@?sK3!}n}+R+v<$YqS-Yk) z7lVvWbf{ew%`(XhBT)3GUfYoOp@N)wk!cI1=#Xz*JBOPan21IK^Mm%sRjo^e>cd#J zSE7x#LKhCs+3++FKsDdko>JN`<8<%FLJTaXm4vj6!0bTp4{TsnjpFMZ#qPKG2-brH zph+a)UKOgWV}K{{Y)8T{-G&YP?x;;FCdVPsYfSDI@&-@|U)M?|9(ng>+eD`cP20EIvm-|(%s^M0M z`IsWeY9$!Jl25C2;0e3Fve?eyiI!Jqo!*+-3~vb6VGeO4IK-sLLI4mbzL!7UV1Mpk zY-GOr{_2D8*Vl`D)n8C*3308qZzC*E;y|Qng-*FdHsnK|29OMCSttB>8KGGaZG`kp z(HdU@_g5q97-RzBlkv${Q^L3mUFDP&USqp`Co=ipvf!;ML_EERz(=Kuzse4!Cr2ZK zGK1_$-+g-t9&JSBcU~6PD?>lM0+;cxG(b<)nm8RqFl4``zQS+hq5k=CVmC&wOgBTX z58?Fy`J@(SNS@PC<6bCZe=;-xS_ZVGC@uKzd zbt&~Un8|a-g)SVM#~YOyCCLq?1z%zbr&@+5LNfnuPPtw=O204K_xqx6W<8waaZVF? zt#JXxz*vI!5#2+LN`LIx1?`fZb*ib5N}@EuBXT)Mn^R{LwUZ(D3dS8uV0?;+i(4&J zuQx_#JG1EQO^Ib7=tzKyI#0FXGfrteX#AVX`m{SH0BRvc|I3)|(b+`}m=tHUMdjA~ zWEVPdyt-AaUpF`vv)a-UCz|Z{vhSxXu&)J2n%ywYEhJG8mk>emh@7d{CF-UdTAn;9 zc!*m(u;e>>$AxcHV6dFY+lZIUmOK7+%QN97xG)lNy>snvnh5aRK_^ahzNV|GoXU15 zTdm`H;@cn5_pNsWYeJ)mwG~exR;TSIl;m-myN-POi?%*hrJmh!xatnO&D1&G!{)&P?FIlqR9?)ta5V&SJxdiMrQ7bBB~pY zs~bdhm2=FKAYjzrZ6p87q4-TW4 zR60C&to+=dAI`gz^q~pqgeIqm<>(VFjimfN502T~H$(iJaBA{wVNL#nrMh=JYB*RV z*`)gmf2^%i%2eD29RJyJ@YriIDM^>8NSN@2W9E1~( zx$zgb(dr~GO_YYD(fKg+#?ChPHk>(rK5+b^-sfo{2SI%Qxd1`Sfm!bC#boBhc=D1M zrW{e(@W;luW|Kdd%@~MucslgO`Hl1+N4;o!2E1A{kg~{rDnzX<%m!*jzo#V@fvM28 zo$H@z8+}1v>J#=mmZHn`70v zj*Uj;1~>JbU>QikAyZ^{{Y!JIIvHx!c}5YKG~H>3tx=hwzH zJUh~4S^MNJB(FX#8!`BS0#P!gcfQ#g7YV&#QX)zWP1au-!h6Sb@(wuhN6eaHEo&vpqH+FYQkBkUdy<(a2E=dfycCj zxSMRtRz|4;@7`O=y)PrfYLG3BSq;UY-AKlA-ai=qCH_6V%PAnPkaDIYTduofW@D3v zR!7qc#806Zg6EUU&!ZoNB90q6w@nYj6RnxL_fuLN+u?h2k4z{Vg4(| z-SW=X5;0Dwpvk|(!o^jDOjX33%YZvnL^`4Y>vg*z4Vo7bLGPIu-N{D{&{6eC-sTY| zzw|>IJB|e5|0E4PBfmZu{CsAFj`~j&3C z0MbeDg*<4dIlZu`=GDRD`hiU^ZIxAj%wYz3QFTaPr6eKjFYj6A{H|+Imbe-O5}$LX z%D;m1;vFpB{AkmuH&++J%>4Z*KgXl0svS#nJIfn`Bnu}g<#R8XX?opwi>3$8{m+u(OK=qN5Q;fIm&nD1S!!>o@z7i&D=bAG@L`#oDEueQZN z&r+gL^IASg`Td5mrvL+b`UMMU<4vY3#z$&n4~3>oN+qeHOL>S+{Qe}ndTN;ZIp{p8 z{@5$Vh5!S278&@sX8;M)`mCFI>@rhh$vKOVe3UNWOe4oUR>RNwJ*v<%D>;P_p?w% z#DQ;&WHvC+hWaL_tB~l}nTc1}SPD{kZ5fKpj^5<5{eX1NWxgf%c-rhZ(siEN+u2ZG znlM?N>p_%ERZkG=KdB0htlEBPA40LXMYPf+Kn&J`tyC=xjVa^GpdbpvPq8Q?IP%@* z6x-2$ATO{}J$=W9ZtCNmYkxp^~jQYtqyE^&fbBi2m8 z;58i|^N_dtm%qQgr06LMEh)6+t~egf)nla%dH*6+Vk)DjkyW7l9qKP>b#BS`!z+H> zjW45xK9R!j3J`zUa71y1eA|RyGU%4&sqm%+!=HfQPe=#ecoV=4rVKy6ltFlPjttX& zsuWHEM_Gl*-EuAn{C~f_fxm@-+E9do)caj55EtPT+`IaS_xHBiO&_xH)3mq^5Kt-> z0G~SXQh^SJl^@@7AS7ET<3J$JMRuOw-A;u*=vWo4B6P^#MtKITB#{yIwbGpDgPp)Z zC0eAg#FvEe&!-fc_GosidKKnIMlU6QUJ0G7`V%{0UAyVboUCFxr7k8_{B6S&uZ=nI zp_#y#$LKTe@Vg`GV^Oy{)nz>lCooA&{G!R!ZOzt0OHNEI&n|Dt!ozK_GdeE)lEIy) z^U`qhsxUo5Avp8YY9#w3r*D35$k6Aj*9A+bZSj9FN_a#8lSoELDM-RfNI0|FB}Ui| zIq2$X%)@$cqFZw^6Hs zJzeE^>7;8do~WSOAiL3xIy6VajVGzI;$ww?b@?h0(dvjA1Xg{=+|0a&_HcP~wljOg zkE(ay*I7t2Nz%YJ=zIWE;z;api)3E$7(p5&LH?HV){W|O8egud`T8vbQHo&765l#G zq3L7VpA&-cY_B3!nnh!#NI6J;Ri=@uwY_heegf5}xlRx}`lpZ$oXJ?RweB12(fNm* z2etO`)lKJ3+ZO#_kyoqH57h3uP6f0%$#1{ru-h~G{U{URao_Lai%Oy?Op5W*vrH=;^fv&6pC=LDOXAtFRi!VDIM7gnS6}|UX6gOro9@CDV2;9SCc#EdRW-Cj1IGr z#pz;W5`@uSFczsMF@hPoD5&TMtJp31nV_Bh=Vh-r_>ZTFIJyiEu!y% zWw}n5YMI$_pn8^UKI04__I15Y;qGT&ZW6aKkSX~6 zk9GrIWhi;*?p00iJ`lc!f9h4V=Bf9o`uM!@5Ib#V^Q7wg*&icsK^H;z#~CD=@UuUX znIl%Pok(<&vi_vK{9_HLh3tn2+Tj@M4_vwE>R4ll-%m=1J#eY4m$jc#QGoxylnQ;A z@V;S7L?*OdFyWN@(r`*&$&$ztLxC)RHOBBwEp2(EyDWW3=brqpfguy-=;VgOAel}gEJ?i=DEQv}o>zsPrb6zpJj@w@(oXICP+ z8$O@|Ih45`TUa{~J;~9|$FXoE>r^^xtkFFE7=k0XQAY&R@>vpjDYd?eBodFoweM;@0bXLDj&pfA5#E;au}$x`S|Lto>9GA zIrE|XkwV7()|!$3zEp@zf7$PLVWy4TAcjCD;e9pILJ(D96c1WaM9@JbH=9S9%e(B>88)Yesl&sM3?L z>CeKVzEmKH#F-7MT6D^lQ%KR4nReGRnr?5W1zP)3^-jr5_2%~nZ0g|kwPWGJ>Y>or zGa5oe8bxy8OCq2yJ5GJQp1~Y4jR5iwEDI^z3*P@U(=G0kfRsv*kmP7ufqEKphCG)n z4&MBu|3E^V3_Ll)z@v{v_jiy{RnwYuqU6gdds z#U?Sl^!SMVUJd6}N(u1ETT%b=Y|G{i`MQ7`6#wJ)?L2@{`;EM5?>{>){beBrETdff;*f7e3;raCRInpmRMf|h=}lUW7a$V@ zWiw$B7O-YTYd^-oH?Fm=POGglX`UMPU?)R7mr@_9@Q??VjEH)%7yrybv{kNfc;2|5b5|^1 z=O-B+)?wXZV!gij6UbtGVch!SJ1e-UO;+OSRob@Enf^RPibk(sm)~A@5Q%}9q8v%G znYdnxY;=G}R{z&)doy2zXx!duHBQ7Iq=uFA3$H(~)}9xzDQVOMa>QjKeLtEu9_KxT zU$9x}8-2=BX6Oc}10{LRB5Ey4K^qf@66Xm6NW|pFYJZ0?c*qtSFS0nek~;Z&H~PTn z1K(yBF~Y8HDdC-%*tq%{U|~82zs3e3lH`{u35dOnkw)*v^2*LtO#mm1_CD6Hk{zuhq!Q&5*HHE27Jf7dzI&YgAEl63Wp|-p+<}9HG7+mUj^I z=R0H&$`@KbFSm$V_7p(5Er^$e>h`@}+#jJ>fvqdzrN4T=c)L4TBF4Q`L8{4zI$Wz> z+CTYY0aY3p2mcm^s$}*pBg@>>L(3r}pGgU|X34R&bN z7wyoT)G;*KSm;q+%}0VZ7tf!cF@SisJNeX1yMwIGb9wZUjCb0X6It_12gP_vu2st` z=;RB^hPYM=4YQ-9w{xBjyt*&BOJc=HeScGoXOqC%Xu+ecb2a{_1Xl2^v-;!#Rp#im zFb3)sI=Zv}XZy(HUOkBPF$7JmGhR%qUiIYGBCu8evo`Xt_#5t`DL0_CZg2_d!Hr)# z)zsRxJGXo0)54ZuLIc(qv?C=-=h{QTX;tw}6XxvhC%b013u1f!a^a`6u@^$C3Hni* zomCjjOoX}TYuF;g!p?))Z5b#xpS?;_y@FR?Z#ZylgA7=5H@9?DZB=$A*pOW)RdCYd zr+;085en{_HXGIlZ8YY@s8SF6_$xw&M7p8_4-WZ9uK=n;x{hT1!{!9t%%y8N48zT+ z^pmB@h%(XwJSE;QEG|7y`{q#3AxeJy)wv&d z655p$aC~K12mLZ$;VA)W9fzzE9ry%)Q-hRBF{Y&bu=voA(LJT|VfZz^zXF6+!Hw$r zng+MN^9xo)Nd^P{*Om{m1Gxb~GDZW~?c!*lE#O>>$Syv%O@6{$2Fx=aw9Xil*WH(=4p?hm{LJ3WtlC*|N_aaT)x++lzB zC4HSg5J~8xz1-XOc8$K`O3d7;zc^y!I zebbGUKWbEmb$r!cyV(eJrE&hh*!!!fxSFN`7!3phgrGr!55YaS!$1Ur2Dbn~65QPf zg1cLg;KAK3xFxu|yE}vZdmzvIt#vN`b?(o(o9SI$U0q#m)g=MDvaBJVuY~jU-V1vu zX`LJxPD4#!==)bqU$SEA;koBdh5}OTzHvV8-NhSRt;~v|gcBP1v^DnKQATVKV2Ou_ z`&<((!*%sZ^U%m|v6o$7^^2ofy~Q(z=g1Z#NhsnwiZ=UCjm{#r2xEjWWS{tb$+_xx za8@U<)&Pr!8%b7G9Al>?lbE;h*E7vTZDx>Gq+fK_rPRkoVVO6Oe=YCvBW~4jvpbFg z)xhnU9_aD+BkCg`kLD8X&wT{rQO~K}4IeV%xK!D%@F}_?U$g+Lo}|#LpwI=&PwtTK z=O&x^^QiJ|$sFUfZ{LcJ#Iim2S6PurM)ALPAHuqx1UYNOH7}rahq^W89h?+cuU0`6 zSKEtw6Q%QPv&)aq9Wq%l*uz5=E9vtT-V-kF8mY`m2X`|M0?2l#{it&xa+RvQhQ2mbE89n}WYc0tFDnd12 zNYnzJMwFQvzNG#@@*17+(~mQnJ7T11GXu_r1GkDtJZni%N_Wz#)BwRhQ`ma6amnZG zIfj`B4Myl&wo_Td<5ma)9AA>Hsh27Hk>SuV#HvV?sv9PoBIzexswr#VHYdO?~ zpH=5vKYQ3)zo5WZ2<#S>Ub)v1bM^0t1>EShCX>QE!}t3GuUk%`B)%e{-K1?X=R}`l zNrt{KMZHbV_Lhy#_}D8%`J2r-n)SWnkYw%(CUnwgajt6fN2w};`zAzN;WBMMEz_-Y zrS7)E=4o))@R^yvRQ=Lk2yO4so#Tg-Z)3~l16z}QgM;NGoE_rihGS(hLJl!jA$t-F zlzLw+LJnzGn#kM^kB=#|nTdP{C8sW#+Nf#x>)KBCuY`|YI|S`&k>OxUy%(nBPkK|j zvc)vz8R-3kB9rs1}|8Vw#J0Af~gOp5Plwe0Gq2K1#9=mMp zlKsE)fD5w*=(QF?laXG;IIvmEs46>;O7k?fqSftrGIhlW-9Avz{C0vK`Zli zOZ1rx!|6KeBLM~_d6%~`RaszU3+sPKkqe;(HjsEN9dzgaiUQM$?5ePJZ8a&pxCI|j zS@Q*m9K`DM(Y~ht#duxF(!y{mKjzF`zIE}AOL+}MtOfQ>$?H78%i4Bt!#85zJkr}Z z7rv7nD7X<8D&LXAm^x2BmnKzS<01YGHqFqrTTIs7{Y6-B#~|e8_APo|$Q>$f$F1$y+b@j5aN%* z_PHPr`m+H5^F|xPTktTIRlYS3Is>R{IE;i|JS!SH!_FYQ-{u9$l$=&xb0k&*OF1y! zPA(9{c?hJTR2-9G&}_gy4lA!gh!w%--=r}d`|p=eSHi@)I1Rs^v4rgt!bdXGX~a-i zOTn>fmeXiJH`TZS`>|L`k=wO|n6V5Y0c7zyN>e5D9&$u|hZQ)CvK*^ak8d9@s|}Rh z9siI3)wk4R^sL{(@#eYjN{HNbn6&EUHnsMKK}$fOt;hl;URp7n@Vj47k>|q}bKVzk z96x@-Knw1QAxq|l2YRbt*ek;O6GE&ie4YWiC#76U>mjlFdUg=DM-1T3RgcNA7J%C# zBbA(^DxCK5y3rW*7K3-ni6J9q1Fl$->B?&*#4=!LMjTzG%ct-jy0h-NBo+5TKNu%D z3VW?0Qp>47&TqHvbP3^Prcy2m3zQ#In52S0bb3358c$+J&-LnMBtqjy){9K^Y0Wj0{F-`D_9#(asrJy2lfO2 zUm6LZgB*kPpD>ZTu~_XKHfiId4eO!bjZ=~!yDeAu)b^}62yncVF^XlQUu+~CD1_7o zIXU4x-5Dppdx62|flO55kYV>zE*ff(OM>VHwf&o9YI^7vP1S#j$%o!XL7_ zzje>Z8-_0O5A$mn<^YB8!XJk)zk&xSU&yMk_I}$ce;YveF(Ss4U?e8yW|wA}5+*Wo zH@<-Wg*f1Q8=YDk*3HpJ`5yrwkV`l3H6q(zg%|%iGJ`6Pa_jgazZXCb{||X-Eo3*- zdWXCFSpFXgUE}bPS#q<1#4LFKP?<7$ z;fBLOj~E*XtIS(%{xP#F7Cv%swT7w3Y?$glRJ5SMu()n15x{st`!IY?j~`A1?i9Z# zUyAQP2x<^-4(&p0gZ#ojZg&B01tP*)opj=rc0{CrMcreA*x?O*73R`1Dj5Gts<6V7 z7{3JS+ur_%{3TpZFH#icmE#lgf6bx7^_bxBNS6hO0E_5DSAgXldi2biE(-l0mxz$X zzp*dLQ$;z&|Krh-8{CzgFny!dH?2Ys(u7i|`IP3Kql1~2B>%0B8tMN8MH@dnwH)sG zS>KFOZ-O6JNkiWF_7P23H#qb^{#J#<>nBd%7xjyzXu)A;@w*jZhK--b#JrnPbdvNg9O8i@vJ& zQ$24P%r#?(%a;CQR~+K1GTbRQvN+4@u;hkqL(REgiK2<_OrX;Ri9Eht!(Ur^vrUI+ z8tpOx9o9SV3XEOM{p&HmQY8+i*4int(f*GU3%KDwIMoIa+x?Bi)3KL3+au^z*BCy` zd;j%bNHbIksyH^#zT&>81?~0zNiEvF&J(>_uXj_{5i|d>m6XV^OsPZ=_hb4XRb^*P zT>C69!Qr|WQ5tyqco12@vVE4zp(Vbq`fyxL+WtORKx^23_Zwk%Q)C)kG8Z6qNSal+W>9&lL1`{N3 zr7~UmPJ2lPvsVdM`~)1^=U=58{x{KFWx?%@;pA*d%1##{2l9>+@~@=uMx{X-?#A0* z)_2 zZA#GqTr(Ajnskd1t|tK^&i8``vAw=A67WKNn6XXNpo^SF-ZtJ}hkPWq-hUj4{;*<5 zhnYKNb;eetS*2s`2^OzFX|1Y!(7f7$yh3qwqy?F*8?n`EZ8X1cw$gv+8*FCkixJB! zLmgiTm^Ca8-dey8SC$}L9jr77UNS5&u1vCeK9-t-A6}7j{@-ku|16HFML&E$Dqb#h)V$dIPTz= z-DqWLZV3*VjValPQ0LZEg$pde4w4zLcAB|-D!>H#_X z8djktG@5pCHVdlLX4gdgZv#0%?ta_T)#IadWwi}Fqp0D|$BfY`*bL|`CedP`_#fW4 zdxioJ!EsPlOj1@WdaCaQj!7l)T1>t1w(iGEUSbHDi$iyPAC9q!gvNDjntzBPP%a@{ z{kQ1g!m(oD79-24-jFt7hAYJD8B8U`Nhpws{EDO~CB+XPto%YyhZ*ka!dvkRImq$% z>;=k;+cr5>lC!Wp9i9#gm04^|4erhZ`#FmQ1bxC=-lKP->b0(4UN71D)bkA;!)#k& zyBW;+pybJpGif&?NPTQNsQ@E`P;rlhpOfgm3$fkWbsyaFdjnoql$fP(%T^>%VeCXX zF-pIb{Ne;`_=@tyHpc8zHR{7g0-v$mGCrlXE8FmoU}y(10S$G?Pp7ao=W2_Z&IQ0a z^-<(Nps;B!3n?@tekMfk>=RCoxg@j7V|S{pjJ&`~2;+)lhM9Txkc|?zyXZ9|DB?qV z@~78r%)yq5wyWw_bmWN`InSW76t}0X3@=eOsQtI1R(bt7{L6MB1+f!-9N`=$WufHF z7~ha3mHyk&R!-oLE#XebbGR&wAiSA^EKUVehkp*|XS#-qzupp>#V2-oFpbpC)bL-J zy&@eXp#m9gP&mPDWu6i!w2B~ZeR{RRrI!Jio2f6~5&X@4m25|b%5JuN6zgs-%I}uW zg|5zJr&c)Npw2uVu!%b1Tf`AGH%~Lfw)G!>t>8X7x?bRa=FeK7etGBV=kViOg6)5c zZVjYcaJx&X3J)^}M1)h*3|PWGE=B5K`IMFOZ@MD64%YQQM?0ob@M?YjZIKwL-JYj< z%tqHA%wsDWDMkL1NDPg8cQViI;ivaDaHk~cBnL7khDJHE1*uvIwpUW$fnAsm*y1yk zEKceS&*I8&KJo2It+=!|HNHHR%)UAc10KFVdiw1$AF%Tf;{fKF^qhM32&dQc$nz~f zQ;u{*!C-mdNEYP2jqmOvo8l2d$Tlzg6M0^S+kDOoalKXqX59Q7IQ?vGbB8GWIjQ^Z zE3nr1#9}!lL%sO}$6o~ng?}V;Md$6D5nUdPMS74)4aXeY2YtHVaG3qe{YfGf_t@$Y zO3-WYnB)e70Z#6I>;9N)W71&2-GFT(?|w(ae1pi5j}{Hkdc$K(;i~~QHmc6gSXIq> z)LzsxX700^c47!3AW$Nbma(L(Y%jff`KO@N7kk;B>hJhT!Uzjtfkpii6oKqb!Y~LL z1sslmZe71tPwqGhT+P8c@5MMiPbzC{#0ftFR4-eCU*7gp$O5B@7Ib>=D$B(gd!xk^9;nA2K9_? z5rS%cqb&_~@A4}6#dTKTTdsKsG(s&>xw5~q1 zS8E76M%lI=fXM@FNM?@h5Yt3`TDbz(ML(f{)yfhMpn-TjBK-B{hMZdO`qm}N(p8cT zWwYfn3|;af%@OvBUSp_``}R+WCLw0hiwhZM)!7TiXF=kpdqM^)q5E$>twRCZcOy?f zQ@y6ohDwg9(IZdzahuUzvpQby;~9+;;BgsjC<)?~>XZMtPRp$w2U&CwDK)tkUFS9P zB;8xs@Fgq5r`MM8kICMD(~VHXy}OD6Wk;B?khpZkwc&S&1GL*n;q z8^}?B%LXtPOkJ9`;^Ic6I?d$+K&WiN_LkhDDN}YN-d^LTM1(BbsNL;Q%W4El`IM%1 z(!c>=j{`(W62e07uefp?mIb+)e5%7IY)S6)o^*RtMKFBF?+1eSfCUq1pT# z;aHP3=Bh-w3z%^b7?bu6)Q9qYE8o&@ZFruhmuac5JAvGL#qAQkDvalb-@O#Z$Q=3* zye&CjFBJBt3$RLsWCEQ;K9_uso&BRcOFPUn>F>LXw>Sb{`mGu&;KEw`wllw%cP{N$i?^)|Rj1_KF&G1T zXVyaj$F-8Yot*TAoP{)fp7)p))Wyb?!6#@NpH*!+)C*Q1wVPrZO62&l`*Y?^WA`Ns zwKb{0%>`IL)Yv8)U)7#Y4rBq#D~wR|YgU_p(hO9T-tvh7<2Pem@q|2_Mt|v(g4y&;^Uk_x7Ixp$3M5f5zgp z-PeXY2Y3QEJpT~t;eXV7Nqzxe75A@`=(OGSld0~&KXpK!!fsHDvs*}uDIO;X!c@lE zwNQOS;J@1Ky8{=;c2X(_hlGzyv}7cS^Fi|;8L`O6l{D+&{u<7GJqmO0Ko!srD61y0 z)c#g{!V28OfIT7WInFBnu9EOM3*f%58d`v>GFKxi=%`ydyiTNsGZW3~X0EerM-^G2sbGiduVXk9i&=b{@3L zlXHZH@DBHGB@5CmCL55oA_ixqU3F_*Z9!ce34q}g&{vy_hDKkHg;5}j7mD7TWkE(U zQX*@ZK*cJrzCYr6Wv>`?=CTV-Cjoh7R5}y3gwRt@Jo42!zn21c zu<+X=O0|2(7%x;wP9GyG3@V8U65fDIC+80m`+KK>IhtxT*sWx_33J-Gk_uyvEtn$0 z>5yNY%1w4%lzo1?;=7LE%a^-?hl`l-y2e$9jG#M;GpxKUi0atjL}U3qSHrzSIinQ3 zs9TuGSkc6%vZz2|7Q}al?upKnXIpa@85gNawgO>idTeGx&Tw050P;iEg-8b%aX=o> z-w!myA7ZxkpRK%tUtaSnOT&wLCSi_ueKM<8&w@F zE|4p{p6P;cvf>4=76j=oa~-t3^03tz+Rz!g=6$6mq~E1m9ko0^a7Uv}`WD>1vf2dv%#Vw>y4&~5+c&nWnL>oIVIZ!D%rlG>8 zyJcVyCC2~~_U0!Dqs-%$ClGR2^F4`=gvKHdA6}jXF*71%YhU}h_!#Y2Pgyf2=CM=g z=*ebM=;?0sbC+_PAC8$xonKYe>MT|9FqK~d55g$l*|soB>tTcD58+wSCc+NqivMP_ z-Wpk6Y~7HwZ$$?hzmVPafqbgYC^BOCM#&kU&6>h#vWh4pXu4-$kbDLXg`)mFCg&&Q zmzKW!h8_WbPYZ8ttT^y}v*l+HI~>aLpfQObpR&r9DEI@}q}|k0UOS1w8mBbh#Aj^F zl+mak4ivsWHgjd4WtL_4wr z`3P`E^yYIqK`i=L;Ur<2u?B7oNVTGVSeV<4;g!_nLv`n`hv;${7BJG(w(MVIf3~X% zZwhNslsI#y0?AnRisbd@wu7%3@jV;n?{Tax2^@ZDZGN+lsFikMu-&_U%R#yjuGQ`Y zGS?{#B{E3`MhJ|qOQyX}JF&q7FB+SaV?H_(ZNqh*pRgH{6?S_yYn39?6xvGYbU8Cf z>bf{yVZKLW)%_-P$bQG4+5S`Mr*_TK%y)2f+cmrKFp4Ae91XSB-Uu}TOB9wI68+MS z=c_ckKh4au4j&vIjY`|XIqFy zsaKmznk`2plif;J74kmR=#RpB1Bipgz)@Wz zU9V_acyyu0{|#x`pGk*~@f_aiHDE_#8Zz!_zOf1NW8@C~#%5t%69fm>gITF?_vyYG z*njMa{}|Z>t?-_LKm=tOM5Vi)Hyw$Z$ul}U<0VIE=&$6Tz+HKY$ZlbUkaY2M&fqnU zZlqPkj4Ql~pq;Z$nf*zjkt)$E1%F&TK7h=5~@l7hf6k;!Iy{@+tm+ir zE2zlOmg9bW<<#&Uk$1qInc#DUl+|-7fIVb>y3hN*Z^UEYG!ne^%Gru-wNvUuUbC0HU-W^H|><5+t(*! zKNTkuj|2$DDM5vaVk7FLg2m9yb9f9ZpzC481yazo=RdXK;H`b=;Nv=Zw!g~1lPK71 zQbo7v?l`uFGX6?U-$vJIkhPBYGp#13&$(J+pLz=}D!~aCDJCzjF&wGOeUrm^=;1}753J30$VBUo6@eQ z>zp;D;*EUFk5fdcTuMIj0icndLs_7X(T+VNWNZ6xEA6{EGq-a!;4a+r=_clMrTFkQ zaZ=N~B~N|fb>RSzCjnSx=^aZTE@7X3_*$X*aL0E6`a|2xsMD2!LJc^sth_!mqEF+F zK2ET!I#OVp=!@}|h`*g}li5zKw4@|Jq2F`Tg0}L~r$LaHJ22e{`JFe?&Z6o5@7Ig% z&ahg@w_Rk;J6sT^saenWzXQ(R0OVs9%8QHJ>SJ4e!Lrm91e`Q7+ZXPtfXo=aluHj4 zfu}0*05+_r@Lc35NO*8Gm^?-P7Z{_mW ze{2=E*b(|f7ZpbYKTrhRAY4S~L%0_x->A3TA3g8kDM98bB?TVzUUIa?4W}s~e{fIn zCRRmAQU%6n3JF(AS;Fv7jz?nVLm39F?5Vko{4bpyJbf{FbVhiY0wf4z_q)M9#ial? zNh{6AKd@feks)^r0XMYw0oO;wJ-o0+_ThoLfbrt*TgS-N2W$?Wklm-R3ScFn2qdsJ zf$QggC4rO=B@X{@CBE+-V5QSJVIE#>#) ziUKp-?aB8Tyc)7F`AluUpFS^l#6Y0yC(js|EQLuk^Vr4tbC=qoK%`tDNQ(sOY#0*E z(b5rtr_>$bD#n+RVfc#`RKS&Jx{}A)9Zom-pA^i^x7Xcq^Wc&XQO%D;V>i2Qc2KB(az0tbR zqEBIJ+yDT;*zc5R%5-~SeFY6F-4)KOBx4Qc@9-)zK5Gk`&)rhrNkv{zkht&sW^*g_ z|Ms()-c3%?t%m8-uvxux11T=%KO6>VvFi(|d0B1-f^th2d5K;NBbm@EgMzWILDIsF z_{u&mVg+K*2o;?i6|Pqwniu0Ne0&RrzU~xp9?5|~)t8k|^Bo30utx6_Y|Ux6t=Wvv zaVYOc5RNYhFoG;~3xR%o-$2Zal`r#sF<|C|dchvuG94xDArGGZAPv7PWZy4ftCRER zy~j@wBI6v^&cf}lId|X6_unC|k=pzvNlz{XgJ&ZK;|8Y81TnWiw~*oigpUI=wdDkU znY$#!S&v8Rl7LWyq3nDBrF&6}CIh1SUU(!gZK5&NV~YN3B;YzO~f85uKN*7~m} zXK+X)m7SjkT}bS?VsF*v79097({ev83!!ArW#vNeX1ej$LPG0U<&H@XszwaC3Gd`c zvxVFugVK`nxM3Fih3T?IWF`Mf0`9$TxkLMWiM zPFQ13(yUFQaBSM8CYb3fL4#)YpgKlSSourSvNOT^*6$Ex!O*BUb(}g?jxU3J)9!mv zQ8_SS^Vg5}{#hjW3M=AYz04J@act4YtV0|@P{S25h3NfL*Y6Ay_U5s%c~SLa*UU9>%g`CElW_cWXQd)bq$GR}50vo}2nsY+pj z3-Og@W^B7=G(>8X2gf$TJ5;R6@|x~UyqV+R(d~5nGx_E2^QhIAj%tg@`rH$d`z_Jy z=VPv??z^$uy1{#iPx~0WT>kK}AiK%cUdu`5Y^}E7j4GHfr^k~0wZ^mc*r=H>e(p|u z``yrZEJ1%xoK1G{0?@YtH1x#;b{$(Ddh@cEK7(nkupcUw@9=5w8o=w4_Y_2A6x8v*j_Fc)m5B zW05B_*0Jb5*a|bs{i9|{RbOKGHw|;FZjNSNxLKp9`i$S+tkU*pU}okx6WNH`3kOme zxMU`_euT=HEZ;yaJJHYhm_)0k3Inx! zPHS!v-u;OssAeW@;awmy`^2V*3^3t6#!%0%OQ?IpKwtIxedRRQw0m1|{IpucR=m%_ zTLSeFC_AY$5lg2MoK=0vo%lebohTT7Hb>LgzxJDTdH_u_-clt7x@zE+-nGydPKX{?}CvhpkkqmkrvPheblQwjqmduLXz0DQYuRNqog`=iQ=E&l2 zggRdGb73-{@YCeuPSdsmE*+|;dL5%BO@hZBeup6irq`5?-@LS9;@JW|h{ z3bD=dg0kss5(@0O=ytOkNG#$xTa zNu}Ulx29UVgDEH$NSd=;8Dm@9c<6{GMtZb+qI+%8gL}@iL3z2OF&sLoD3Q=)Yfspek%$# zOgOzg&=7g4*L?O>+Ed<{;qVP+xUG}m^PnT;^9|B&=L0436_%#5+t-=acLbq#ocjex z@+>YOiQXXQZqq%^5a(h*wML<2`k}R|@xXJk#*)h01jQIt_(d}|rVEf`At6#;@W<#X zE?k;w_2ug(qC5V|Wnr|H%6i%{C;w4f;q>RUEFjnB`b%Oa1pUKCnNrN~W16{(pf=>s z<#?FKfU3-K{?#er{U;6W37ncgARE9~r>@~WSXmGB_0>~?_LukZPu zFF$ijhceb#HZP-$qQmW(RCMA2in`Sm!R z_57V{Jk!E*tgy1Y&(FNTdr6g1+vJ}u4O6onYGhOg9@ydi{6cM*330`pT1G{#j`Mt~ zkf2!R1FZ1FDwRuG#;U}|)as6)z9vE3NbNiCm*Fk-vH1+}!)2TXF9#i;YDH$DTg9N& zSFLtPg{pz4J3yVpg!bc_5%dVF7)yp(3-ZjZjT~p7O}#ETRd;;1ErdTb&K2bl#|{o- zDD`Iw2gH=r!utk@qHKuRx9?iHT>+n?RL0Xy^@n3`3X)L#wMW~nn49^&*3ktCQPx|9 z`Bv?tI~4JMt~dANIweeFNKrSe#JE;%LhPVjsIx_NnRtoSI>29W-4YAvpyfYsPrPj; zv^YGGA@ny`W2T8ha<7i$#6Eo?!#Yr4#S*|jz=66>>FJv;YSK@K` z$;&8N_UpFNxUOz-BGaXc0W>6oO`>uP<$U@rvcDwzhDfN=$?QjKo%!{v^7ux>DrQIG{ zlm}!L$w~6KSM+o)(mM`do1xphF-(O$MorZtOr<53I>Qz2^ufIf1+!vQA6K?)B1gbx z^thl!eLb2_+9{J3e>|zW7w4Ae{eg*^uePppfi=UTq2ef(dQwfIz(WSLTAe zO_zBP$Isyr@mb<|tcw*O>VXT31evAF{C-t*V~YE+*SX-HI zp!q|B19NVkdt?7(DQ`bT3gAg8OJ1jfJ^vQ$-pQdRTyUJ*WAkO5C(IFeq7r%m>!PzaG-{42?OH}j%ZOdO`0_-4|+hMJAwhSXriF;cq=}`k9$%qK6TnT&tCMa5$ zbNdOPHvwD%>o7r|CG^sN12BIE%+15XBVa@=*tClY0KuDq&Nv+wuv@{Po}pj)8~lTc2!KI3 zSpE?cz<7iTmV%Mc_+3wE+3AslwvA*@7*w_8pqK#aBUJQ@2PnS`p=I7js0{tZcCV*9 zg2ZQ71CQ>MDLg0b$uL|2Z9>Zgk5DU=`!Fa?;tMQUvImbv(k|PN!VP8LVO9TEnDSG4 zDnRL%{SNi6&r{*$9w62XzzgvGO)&vL zJpt=#p#DR{5pRW;10L(zP;SE-PA0y_k_Gk%zyLpmQX0nogVn__$KeO|A5(sW4U#hh zl1F>gGhlF!r+N&;@WXK)ki}&PFaOV&xd#oM1%&bd&En_L{xVysZCv^Zd)r78;2CKR z8=m<;OJqmUbS9La#h;zHLMf5OjUS59NRPZ(fptXu^^3EUt7dXgE-$Q2ZpU_o&fq)( z&dH=wxs{Vf5oB@Q2Y7VSqY9%l+LrZTC~n_VI9{qXSU+wTv5-SE>+48cnn0wA8XWuzrc zCa@0uzXOq4dHGOa$e=G^$UGs$DSNQ4yFC+FUK{}|rw7(yBncsqS{(w>Z^08k2oLdq zhCCk{Lguj>$ia3Y%l3S_^Y#%tyiE2EmqIvGSfj%uez+WkdNt#%H1ju4j_Ljtp)1fE zHG8NsChqIyJLK#(cm8}oL;j=%9l~R#;`E2$3~yO2k*gt&Y(8Be_o|=^nfBq(tFg{VzHH2>UJ5^1u!RNb>*hAu?^WLxm+hI7f$Z zOq~j_&<5PGf6v2M(mxqr_@e{`c=v$~S(x5-5s)ZY15i7;v!wrCCE5wXIvDEJ66Gt@Q15w6~ zF^~iJ5E~etzAi&u`R*p#^q;EG60{;mtEkpvK2mfLMC@29luP3H}tRq*njh`Vh z6S!+g1C|i5O7>x;A@XxTVgFXN@osUi50JV9z|lQVuw5rxW~(|g(M&H6pn{>f2Ik|< zn9H3QkxJgtS*OS&WK%>Xka(gR^K55;3`RPjU`cF}8Ft|u8E3)o0FtTz#D)v9|H`~3 z^LDI#4McK&fO(}5r@_4>^!0Z64U8wSYVoBX?QdK=IaW-F{!!shaQsW<#+aS_fqeby zh8yF1Gp$|Pe@&Y^Iaw~vH1H_?BhY2->@d6dM7;!-GzEq++LTzeT~Y=Jf)3-y6x~-% zvpMgsTrDdg(dR=qg^ZMdp-4&lG%yhF_eiSS@K<~7uNS94WJDNy%Oq`O&>7S7&dPs0 zvbUSmXl!KN(d2aGe|RZac)YnbjB<$nH5;zto5{VgrQ`9hT{4znn#|wjD?qHs2b99r zwqLMh`AQ#0Mc)BuOC_Q%)UiJR5n%M&_J#YSFb~^%jEmG}17oY-xMjay+a+%d3&WU# znL*9=appNGD2QHu!igF1sz!h?T}h6HHJi?1A9AtLe!pXv{fg-e^o8m{m)=cphF#;6 zdkuIr5J72@RAD4!1`3A%8PDY zq`1GN=o?*FjGXQLdH+Xm%Nr&DQu)>ef(S*2uF{kGP6e-l1O$-6tC@u=b2vxT1Z9A@ zw;8;!-ev#cy5LrgFu~2;5m*idBBw{c5hV-1hiX@wx8V8jZpjHff_kqJ$S?X@I?(_=o19~zy zdV2ZSOL6e}*#A3Hc>R_wI{$DhjSMR6Q3P-bZdYguJFguR_Qr~nIhLr9E%dnUWAHbV zy=r05+F#4kL4q}xqX$SyZV6_%=uF>Qc6b>E>Z#2N)$!f7j&MtnUy44rD1K~6WnY0L!I5E)y}rq)|G7|XV0T!@u%k#k`e;;-lQP(Q zdD4|#`}N4t{N)bY{!FsD%}&x^NBaPaii|zQ*_cA57o24yo<+w$TMyoY%UA&Utp45y ztVy`(tOUkN+KKE2B@#N*=?X0GB1sf1>Kx6$`~py#Zq3*9eK0^vXW>H*&Nu zsec#sBsy;>-SATOBaMh+!&#VC=Gytv^8I9}mpPKQP#Yn$?u@gD^YQm3fmq1yxaa#> zTR;lI^zZbR8Fz4P#(j#X)eGGV#*`S0#+}%x;f#t43cVngN=X6x6MY_s>nay^-%7KL z4B(EaYg80Z&G<&n^=0gdo@R7vq4jTt>io%zdXcS8B=8p5J_DJkfwLyhT2+IV#?$qivJ5^Y;i41=-a;hn2xR&&KkN3VDFfwVk zeppEk&DJP;eBw^qCRf82jc|t>W#g>e zclRyWUg7;VU$wj|jD?KBJ-9YpMV}=_z~Vw)L_WmY{hvd8#o+n2@cs&-R9R-*2VynZ zk88x5pB=YjQ_iS?Crj$%%!@Dv_$O zIKAcv-~V;l>URcd3XBAXf~)M^Uh52Mj*SFpjNMoU(61rBD`1`qQRyn*Lxn2*a-uYB z+^57$J1e4D=B!L>j)NEV+TB;eFS>Nqy4ZK>+|3CbwKJzA@P$AW0gJVM(Q%tWz*u-~ z{#sfra*;97Mc5uMKa=w#MPSFPCmK8l?1VTSeZdXSRjjd1@MASbO9@PU1J7v?FUS}z zES#!Op|aYqv?{-lFSelcUE8D4_mtWDj{P2HCYlaPM9jn%WH~a}hQ8V_-~8nn^l~Xy zO=y&^s_=dZ`${;uF2;_g?b?#H?{7?gR!@z$>(AhW>AzvNO3{3MX<@GYI0r# zi^0}_cW*x3!58^5x{Q$yc&`6GBFdwBLsf=X+q-R zGie!We#8>{^2)F5K*}Z?({Li;aM9v(;PQ?XEQIKTY);KK8+qR4>$KaEdwy_^8}M;J z!Ycjj`GVRnS0ryD^_>2`urZbdn~B`g+k@uwJY!wl~y`&GUqwerO$ z?F@SLuKRFY@>Z2g$1WhRKlNu+Xly+nW0=w@yJq8bDi$UQ-lxU!xJrRMjX;D5-*O@ymF4R@{ z8MZ;>W(_t*vn>3wK|=6%izgaBzeM&M6UT#^Pwhz=23v4!XW8j5{nX<-f`dC^JFH)1 z4&Qk8+di+M%Afg*H|3_Cuk>OK1OD|m8~fILgYyeq)uIz}xQL}|t9_?YVOjhhZEz79 z>&}eIh@YqJsh7yWNmt~XXK+h{`%ULdgYVLC8}#OGni$QV2qDv0`Ja`JXoRTnq7 z0|g3tB8|@u^67K&2UD3l!Lew7*(cPfms>W1X6`3dQQSM07+(VeglwiWW6WgtDIi;= z8j8O<5)D_lG|pE%5T=J0?E-Y1#1||I~+!)aN11E%W(ffQ??@m~3ShY;`wB?dJHN zaVRHm0RK9Uxd1g4zHqC69!*)XTz)Y4VmliG=wiO@wW^arTAlZ1!Thz>qECG+CMCd* zFr>XDaVHHPp|~56(94Ks z^Qrr7GQ{WCpQP)tF@>==QtionNb7`>dcja~4!-@4Yvhx+W^}Mk{0ES4JKoe^&zTv4 z@-oSGqU#8iv`?tR%r>~U?1ufc*o>IZP7>_926Emc;;`oFaEFs!IuW*KyHUEC9EzQ9 zg_32TZIob#huXIy<*^_Q*>QKi)QI0SzcZ4J`xUS9iZX1&4|yr)*$@E*_4HXCK0J13 z5;J^bLGxt{pKx*gg@9~eKFc28DxzU;*}4NJA?--fz|1Ra&2#kv1n(6p+U)SP_vdNl z;%N}KzgSo}6NOpaS0OV@ZsxaGr<*HK!(l9GZfqe}bqS@^3$T57}+=qNXqh*yYI87^r8D%Os2DBg+1g70-lz^ zZPNm7{H{&(p#83Gt-n$&^~1!`y=irK6bZ5~BZF!@c5_b-Y?B@0Vc@5<4!znU#!H81aQpfS9e9-y z8?i!#OnQDLuDxp=MCK)l*(grE*=_01DM{B7mX#n@^{Fenu;Fohop!*8cFMfPwb!~~ zo+4gj`*Q0I+>mU|%lwxp`@ZjWOC|-?KBwE))>omQkk&4YrqX;3@L!|SNYX zsd3!MD{54+D$jj4`;)o zjcXvA5^TfFNh_vVIKYMDEuE>>@9Vh|tFzu~<*U>`nVoTyEzhA#NGm^2^3YH2rQ~?6 z$|WP7epAE~ENQ*iq?1~)y0H2?SL#CxnF+L8yZQucGC}jA&$OX(cjgK(!TRG+O6!s) z9AT-e%WAx$Y1}8t;pZ|GihyG9hvsIaepLfuRgud!?^|6%g#48vHU5U(O3FsBY=Uvy zSOINg(~Dx{5st|oVcY|a4hwSfZZ4Tq{Jwm`DE+cm5i|_mKQBhas@Hz!561pIZTkXe zWJoQ(a=n%h_ZI3fC2ey`k=UOhr`_EjV;%}i1MACIysLTkfTN%}A@gG#F zPlnphAF(+t>h{&=;^WuXl$N=I*4epAKamy5v2vaiB;L~NeRVl$Kf%LPxc_42)?D_P zw*D+(Xg$rCWS&BzPvep$M~-1Q>iwoj`Sv&HscD7#SceYOr!I(RUAeFm{EoeYxbyc5 ziRxNco1Z_MiJZ2s83ta$q;9@*m0$6!t!H;GZy`@kt|19d_`qfUK68*<1WooVUbN-f z_i4jG7g!()62CRzOgg(A{n=Ngn%Ijp`{j@rDGNgzy%LUpIV~e;qaIv<&e$#Bj=TOk z(_%eQ3vfZ8Up13zdY6`nRF5m~R`}ul{c%KD(}u80#ITTYm{|RfG4JGMF*x%2x&9H; z_Ofa^7UJNb(&vFJ0YYzNM{9lz<^t9Nm0^jX57GPe`&~%8fn7jqE_rejy<<+& z0$ifV57{#P7dIbp>0o(RY{>>012MIkJa91YXim|1*z$v;)Wir?mOED4%-qU|B}@j@ zwRs>PIz^qi^!{eTlCMyO*q1;~M?lV46t#|I74CL=IIC>mem_ueD%B*GPxdlgRCs%5 zIx^|tDuiuwnr6Y4I$1vESNvqu_i|aG^8-<^SL&s<`?Bz{c{_DYa zNrNOzZ@W1Ha7?~ueX{Jo6F?PLDr=WwJs>vGET86h>T`cyz2W(0L#}V{{-*Re`H8^C z{!WC351kjEXMer!*j|JpqoL7pjH0w_9kgY-@1jPQiwB;(fuW zN0f*#KCxGD2#RAw@PU&}##ZchZhX3e^g_zBkGWSyep^tUmUd39 z_&amIZ*vEKaP*I}e$O(axwPyZ>s$8Wo%!R~HCF_7zCuE@gV7wc7;@8wm|^Zu(o6G9 zC`1+;L^>a?Y0p(qfiD-pmzO&RLqO)yr&}Pn z6gFz*`P4{F>y}@LdryhnA{QY|q0tUB`3e%xU7T4yAK8{OMCL;_R|x;Aw!}RH!@m+o zLU}_FRb{$txESbJCKKjdMCI-mME7#pGh~0)Dj8$D6z$i!-CEeaJa0|y6{|~3iZYj; z01aD-QAr-a3{fn2ZA2l9TJ@2?hxGF{qE%b z>fW!WYW~dBRNbkW^Ji$8|0dU&`o1r)d_3W_n4CZb{E z>J#mkA_}tCn@ao_#st`3-(YiOoh^=9m9{=xD&Bu~=sUPOn9|XgL-P7SM@U-cDX1QZ z&py<^_L0w4K(4mFRQxb^!`^@X`ATv7M!grN94-V|L@n6KHY?`MhQZ=?UXyrzF|AA_ zvz~3YLNPK0Ib)&tMpCz%$c*&__L^T#PoGi+pxvz!!}c1<(n0jPzmoYZZQiO&mU#*-aLBzGPNXDs$ydT8#r8&+AZl zSl7q&H(t7Au_M+{w3EZ}=Of$VA+Zb-%u&SO zLcw<=%aF~ft>tCCL)w%?$dZ!W5-pR?-utR6D&=)uTLl!T<~p0+wq;ntWD(Af#5yzY z#o{IpZYf_4PxhZw$$8>HRD%ze-Wm#ye2g9C>c=sG`85d_87;a|0@==Afy_sPg&6PkuSxVR9@+_>mD$b;i1a!sh)V zf6Zzsc9xl3d%!sIB&_cNPrf~$(cpz|U{OA6qHcEGX^d6FZ8b-xr{F%DSozaX=T&=> zNRs}a4-UbfOD9Ky_dFP$jZAOUm>xRqKDvYH>5Zm&itm&>f&A?yn6PNCV?0 z4f-yA(G!^E>D)c-i}a=y{go4sJn%ezG^Vo3_wp|2OqA`VNPY|%Y+Dv1?aiadJoZ)2 z_B6DlZK1r|Q!n(_q$Oi9R~^rYiy%kgGpSRmAG zZitS_vCtSnyODzE8BsulAKa0 zycP|$?nSzUawYEBCDtdT573Z(wktp%6^z&?Wc7_mSW`R zT@~x#>GsdJsb79wk7o;UU2Ft%k!Nu0Ok-3urGf7j!*j3`9===aiA@gohGrpziSyqkb}@t&zhRMh&UXo5Q})p`=oX1CgZ9R#Rp(`{BPpLBfX(>)aL z?)^%A@*Zlki=%Rf3M#+*ugA79zT!g4T+MdEPv@G4o?TCxDeg z(ICf(wY2NjT=X4zh4OFSw^|e7|Tp8tzO?#IDwBt{24sxzz0Qmxb230duh{h zeZ*gLRt>Q%zNc42O9i&)xCVw!C<3W}zQx z>CEiA0E5Q|)s`u7c87}IV@$;z)WJ{aKJUI>HR#{2oZg<}Yz8;XtA_%TdJDcKbWMa28c!2m*ouLNHlt2) zU&z-iSrqbqF{aZZ4ZP!}>-PdaQ!SJf-7a4U;-+e@uB@xY>*=JJyYrkqvXKl8>olXO z)-T%Vj_m;eV@mtMC=c>bEb5o;DLP^9dYO-6ix-XnwHdWZsqx$wu%Pa zEs0A~BWu5MztqWOtA&3FeWQi=4@*^qi<$%6j@zf z5RDYc>E>(y?3~bwB;g*PHGMYZfCnO{BudoLcQt68^FI`Izw*^vyyg*lkeKKr@RJw~ zXjqla818e^8rlEhF89XwOgL)79hR$n_A>q<3>;Ap4r#vhIIzvEz|UtX43HK7gg&L< zCvJm`^pO%P^#CJ!I4JAawCV119;kb}uz`!} z&zF7~e*KlXRnF^=-|#|XF(!5We28=mvBt~Skh3$*r~?BjDIh6VdUFuQ{dHyGSb6sjoc!qgt1o+t;LIaF0-|9WEq+uKKctjl5Vt^t|Q}z@?rKWN9Ny z*|~}O6F(975uFdHirbJqGbM?VJGbzBal-mmYlTWHo8LGWN^a8Jrc)49hf>+s09~Vo z(c-m1dUai7m>3@ZBz%IuFn*3Q#~YGcUJzW>k^|dV^Ar#YO z`&7&8`A@iK%O*$9n<#5L1>aZefs<}#cH=5#QDxkNY8-?=hp=9^w=rd1L)@dP_xqfRS1Z+f4kpgUij;)j z85Lc;Ri*tEr@wnyFxKiBqx1MN+;K@|mIJj&W#~D=dR|sqBI!gfnQ3umlom=`@B0T+ zKAbteihz}&ZI9KMTXm1D+oaHyl#FSaiPszjfAGmA;R~4$)@~DG;A{RI9Dc%gtkEk~ z*zndhh#+??MwD(}s^N_od?(#rM5pPGHEPzpbs^(s6zqO6ld|s-wd$J%n)(DLn&7xA4LR3Pg?PjPZ45JJ3X%Lx4-Coc z6+QbH1cKA3?jP%xAV0ukfYdAGYQ?lWh4##`*KN#Hl!_e6yC-sc%5^qcaukTrjvCGX zx!Ys3t`Rb~wczvdugM<}HBZr$B3ZNs`5hw{{G>}%s0Q;}vhc@ulukxLZhy=6msv7N zZ>@{>3Otl*w^>@QRyQ(Y?{Q~;ZoUh?SeQ8Y$dY)tMu3^K&aZ~tw9$pFikot+d;X;W zN&KYk^fOh(!Kd2!Q?%biuH)hmF|iY)9aPQJAJ;+c#LgaLrEiP);d@ui=>G|2NIwvV zT4PV+%(^bt*lr(1n6Sq6XQohqx6$7h7>0?2R*48gnDD=`62&kp>k`5gxEOayXeB86 z^6*JP7q&pOdAG|3@2gRe8DNJI-*(#Emdb37l@7R<^~zo0F!ukM)4_j}VrkqK9TYdO zib?6zD$EQ=HU2nAyTLWWdE1-(yi3{8!&UKUdeBS6yI0epYqSff#XlLh{KrZk;s$3# zVAOM?zg@}PNvb82nG+i9hR%j{ZeRx{-#l(zr@~bq)d>^kN$7iLPVDl!%IYUlcbA4`(>D-^_@P9%B^L}k+hhj~5 z6c+uex?9nW4rU%)`3Bw{e9k7f(z*{A0D*LC*k}Ot0An({AEkWfXO{X{$qu-nxuU5V z$JwmsiqTpVN^$00uFPrLSIe*sw)+}af`rW&lx5OWU|ltj9ZMK4)J@aiIQu_k%>n(HL1nN?%S@Ok>{N$@Se+uedqU0B0?L5#U(2PSp2)s@!(Pcft>mf zGdCRfbphWzk$3LWbmax*e-e$ze~Go>yT2bF`eu-gkYsM7MDrS1ThmN zw!+^76%n#ERe6XTILH_sjC!5D+mL^!d-T~>!gGiPhJbTdl#x?@s$KK7H67)rMk%^{ z$-{P-vx!r&(@ZAb(OC&&62r5dsSf7skBJsn1!RLKW>v_W2!#BcfQmKP^Oa;7iTj<};(ykk43_)xJpF35S8Hp`Y`)+% zQmp8lsxaqeBy#I8pa5$&r(6*pp$dOr%R{5y&QL`tiw_$unr4ZQ86W}4CP;{iqL17j z+XP%#s0lTqhnFkqcG^8Z6bH3qCVVjLRcY+DH*AK>qbS!#lB$j9+K9ZaU*kfIn9F5v z_`+r89m`=x3%$|O)#`2%xtzo9gy}}|`_EdQHcCWRUuprySM$Ts?Y77GxS%IGifXju zg;fbO0HDyr{akV_bEl9*wm+5(X4(m=0@oR2GSrj7?C-j#tIi&M5L4i|BtGXHF>t_| z=l}IBgdRJfuRm$RDf`=~%G>4!*WQwHCSncF0H&B*6A7}Zxa9I{J*4UI^9Q!F0&v-E z-ET(lg+fa*Sc!;0)JS^$*IU%5H>7YOB-G6Af<9}9^lCeuCo6~p4z6fqG`ds+Sw?c1 zWL)j&!Fv-?jW%(xCH`$H`d1yAMpgkK73#veevqx5GNBI~6Hd^~x8y4{9ZgGkPc97a znPKC_2R=|u%ZM$L7tkCU*h09=6-$#hB)hc5dR*jfDz;Tk=azKDie*Ze-04?33v!bM z4i!eYmoyXt)l66V7Zno;C6#wi_!nZqN8C&IK^HT@!)Z0=7fzqL3j}_EuTTup0xiyq z+po9XB4t=xP;1wuiy6r)b<4e*XNS&Hnw+X3IluPeTNTniygH#B0d=1{YRiFK3Dn?Y zo=Dv*LA^{lN=ckd(}`NPJ3O;{F}%$39;Y6C67xu}xS<;i6MvEG>xmE#fBEQUT<@9{ zr!*yjt9G}bxnEq?a9jfpCnw#-a&g|?y!Pz%_O71~a39}>xP23!3L4Y-c>QTnD>(lG zLAQcXCR!~Z78s=nY}@G&Ih_1$8(n&_e(|KVdbF3VT9A{~zJppY@12vFIfC=9eP?=s z<#qx?HaBYhsi>}d;`2(}5ty`w*7O1i2#HoJ>NzH|;$oC@^!uA12vKU|$l<4VQ4rMs zJaKR|447Qv4@CMC;+!Eqw(MFMCZ23%bNU6XRI{2wlNnpy`e}OGdS;uxIf~5!?g9C> z?h48XH66l!F$zB#`38PGI?g_&yS}eboen0g;WdRmscrQYIqHq9&%lBDv<_!llTN-G zMP-mS>pJ^O-h-CH*V}nbSreHgB$=JQ!d$3Mr!p|hlHWx$rFDENN1d_=l_H7r+@fmR z#alPdr&=|aJi@ju_3W0CVQI)^UR`NV{f3r8kWgTL!U&xYQPz}0Z^-M-<^1Rq5IKm~ zoWIOZdH&3TZ~DN(ZP3J9xe^CoMY*&$ebQj%7XWjLovBT4mmPQkyfc5vwj$HQ^cxw= z4X7EWr@WuB$kD19jx0Pip>k?b_yxP3arREdVplImy$ycACcWi_> zmXIYz==U4!ArIAf_f450Rn;D0%_$Iv048f$L>3C!VnKz2+HLcBjC~+rhFLk0c1>+L z<=QM8d4xudklv=7{0!+Fre1}1pH4`usKKFt2-j_Q%B;Zc?m75%4~Ts}jk8G6}#74K?GOQYLur8yLq-m|(JuzW4&pK1x0 zf3pa%pA9gYtwdz(n^Cx~iL}JvMVC)MJu{}H_NE&QXW}Qg%AXNHaPkGX!;v%VD~)E# z=JAT~viRM7;UTuNlk66HsZKf2U%m0WvbIBD5yTZu(XxQpJn8mzH$R|_L;R>rj|mb+ zIw&a$vp2AFa1#Ffva!98)kBsVF}=(O4Q(_!*dKawKd3iLwPeq3Wi^wI>nt+k8aQfM zvmmT51yPs%kk}ue%l!sA{1hVBXWH;WX-vWf~;C%d+jg3i6B1w9BtRiM&bWUP)1p6JWW~0O0(nXpX)%J}Fc*38D%V2FP zJDhKP>@dVRODk`su>ddB!HQKN1nW$i7sA5PpjNbkEH$g}eVNqh&v#f;Y<&q!QE^L6 z1O}DWgo*Oc#&`x|Z7R!{n7XWec(c&h2;GXBskfuQb9Q$05F;XtjW0nlj}UYpOwSLx zinc1dgBMN;-VkDJT+V9&t7o1vK9mUh?mA3Ds!Lq1$eps{mf`vJDov?&m zHueb!WtLNlZW-B@@&_AEq=B<OigmvhXCKygVm%(raV?lBiTR z+`_ruZec^dYUZ67ic*pEsFeOi)n^bZO&j46mIXKg$oS7O}h=2j3o%Qwj zq$NPK&ATU6aUB#LZ;dgtEN_xM;U^wz`R2mm^3!76wu!gPZZqi)XDI|?9WjdP!PC*= zZgUoK2R7TqK1RU zc>GtNUYN7i!&X0{PgEp#3p!dILdBNV0fk#r$yD19SWP>(&Io6xO<>(9#d>Z=LEA6UW(xPu&|>k2C3 zpWnI2i*4M6>GM4hlixyGbhz!jtP2eq)1`_D(2I;8%2Ls54(+vAPFdSD7@_J_qM#GGe`{J`O8dw{3j`mQq}ahKZ2Yl)r(=YFTOWS6h$Juv?(Q*?qQ$1 zYk?(HmWnOJp)~!q%cCP_k0^wn!xgcEtzfX3qyd{N~ZXzMo z+%hA`%fnIbCtPdi?!p$$Fwf&VQ1%Kjj?=G~Q*WAu3C>Yb3{Y*LDfB4+PvNm2BC4Z! zRUirjHXy8po$7Dg)$8B4X86+UY8^kJV5y>!tF`C;z=09_%pmQ~*19d1Z9yjbZ=I5t z%|^?$dT>=ezTh1q;AhmE|2UW!E9davB)XDfHGEk$P=niU`np~9TJ;+SaX@-*ka(9T z^$QUwfa*=+IzXaJRyk~X$bpkosL#xV?u>Fhas+%Q?3${Y>#Ohs;L`AS;vE zq8Z*JQMS@)Y#dX~1yp3|R1->#n|h)JOHO;uI9t=*?n--Y%#VO^M@!kW9s(BT?awA+ zI^V1}!s?2ntr#d`6mM`!1h8QkC_3I(c}O|3Qm1bHsJ3sIy&|R~$HMG9)YUE>gUwfs zHW(aC#kwlboz>~I%(WOJLW-EfI4~Xm;=_Hh=cncB1mR48t(ktaSdfUf$T}x-I_fJO zJU5)}L+WtZ_pHoaC)?StaYNWCM)px`Pv0<}gZ*QcMJFP7Hw{*D<}32&oObP6QW^}5 zXRMyQtNI~tiSr16b?)ik{jMFT>tjkSxMv+53;&LX*VS~T#eN)Tf9ZEXgSY&#j=sv2 zHv!DG)BCpMO!FXk-2&_UupXScQ-JExK z<^IGl{E|=@-U*V_e0`>ABh&3x;CxJ(-|pHAEmS1FFmeR>S<2>O;GW=%s+h`y&sJxY*962;Ncr&_Xa^@C<4T=QN!xyZ)|>gQtCAjuCQv z4I`Xzf7-OCfsudU^?jS`Fqn@ZfzOD&0yaNKPpcMC{z#ImPEN(GyA3J|z*o_97B6{f zB=rSA1nrQpI^3P)OE-ysg@-j&@isLqQTHJu^1tbZ7FxwL*z-m;^YcQbI%-kp<#?6L zsJ{$}dDBrk!)59z3_m%dk?E&S(gOsRnz543bvsSp@}Y!rY{JECRT6y3yL4{nkds16 z)TN;o^t|2%qR4>G@Y~o+Y#iUA)HC!>DK@lH*phuL_cr=|hOYs@{(r~kj1Tn1YV?fs z_39|dqAJ?td|ZR$WhHs213o>@?D3V^&{GIlVR|YsP!so#oTk1L5QtF0*(yKYLkSd) zxvirYU6okDRlZndOm-y``d25p=Bk6df-3K?5qxizMuKXdzI>F_$$tE0I1NaYk5X>V zmZ|i)HI&H0w_Jl8S*&uHOV&M8#ho?bBnv**&yMmH82R(UNwDG^UC&mi5zF0TAosF~ zFIYk}_ji1(nZH|iZv1p20(>>wK}*qy$h)l`F0g?B%*uGAiKdofDt+ii17+nZ@ll>P z(9j?+l!DP*?jszKBB$+u_ z!_Wv$AA|vLH`96VF!owhkR;FqQ|WIrO|+uNys0UQWEA$PypetRxJD#hZBwS?+20U&0|!Wy0E!nM(FrP z@?JWMDB`&SPjx#n95ENSn)@aJ1Lg z6b)wkgi?r;rRIc#)hJ-a#`NB`-)C5m5Qy9X{MSZuC$;GOqvXr3pr5*6_GS#=ET{rx z>Ov0uH6T5xzAX`Nj5Nc~zUV;1u+iLNz1`Ff*8C}q0BVDKleii5U+4Q_Zb|-0i$gf! z2i~!t-$*e2OC(=G_y2#6GN8iN8k0wTTsWW#_~p<@Pp**1_P3-x;bi7Ri(dw6z; zi?k?C;}aRbr>RKOyuEj`hA* zNsRNmPy&2xem)XDd~`R@tCk?ftov~oeaiohVeXwVsdH8q2K~RL#agUUmgl!yi8;pl zKwf8>*xksrykRcc)~bmJ^bmeg4SQ-UOa3!Iy~1qhvW^`x_g6cpeU9c!%-7}#0S7mb zh?M!K0yAeZON}8?3~h8IGrQ2F&}{TkXZ;JyVi{59X<5#~OB9uYw(Q`jvt1tK|XG%j3E2l9`bFuq@LVm1`8cOc<=2( z*;`h!@v#231)`k{pNk?(MQuDX&J0S2fqT~63Bn#GY%Wa(? z=WkBW1B5V14^QCA5nHz)4YeOauDQItep~M8WQ<0y)N0w1r&+2cI%ohxls@-xiWCn? z!1LUqLzh!#wJf7~*uxh{`NRg(zQ)+BzO$HPy)fnBpWdH6QhXZmM0MaR;tCRrQ#1G= z@+IJj8r8SlA?EsYCFUh_$nNy7P;AK0Y3Gf3))b=_s@aRCw1oqZMUqR}OscCSx)UH- z4@+Yx45D?F!#v`1Jr5_(8knEb&pu2iSlf3E9$+6O0VS|gy_+Vs7SZ1jRJvcqurAI{2W-J*H2^h60;*z#wML4RR>J8GsEFu*E+^J-2sp(QEF`2x zE5Yyv>a}80Oz_rjI!eVL$cJ%S-+L_Li5+fBl8D1$1?VOQ(z}s?P6E6Jkmf-Dao_}j zSpT;<0OAROKtCA=Tn_O;Kw+`D?N*?H9sWG^dcgM-1TvE-bNw z_Gh&q;Mf3gqXqrPbM=3t1MRTR*G=-*JHr=Ez^M{Lw-F8m68orTlegHy3>4aBW2~4w z&|w7|*w!u!vO4Mndi;6mHy z7l{(ltJ!j3KY^4Ph%^bH1VJDQ(U-z$z(et0+tI(?{a6NkfPvP_4@E!$8dmlR?VtEc zrLJJ0M1Syru;sw!v92Krh|`6F1q<2=rBD7^08gwcQy^1&Jq4tVH*F!3M#RZ27NkQ2 zQIP*8ic2)Jvh4xNRFkW|7f2-;w9f>YYvD_=<8D^U+3GaepXrldntvVWM2E6X?RuOy>-ZVugyV@a z`#@73y4yCn&t=@b0Y(}z9wFPRx{K+D+a1r3J?$xFfQ?+l7a6$wlHYyDMVEnTtNsoT zL)X!97<11mNb<)XE(-#GhXhPuwW;2Xk5QlC)HW0+p-NLdD;qx{=*SBbvoYG)4I+N= z@uuB15I6NvNx$+_W7Cs*EsE!SecXF75U79M8|s`mLV+7dipYAQfLz>pmI>A>aKlab zT+q$MM5M!=fdDjk@#QZ^{TP0APtn)dVR!* zS$nN}enY?o9C)Gt!rxZgPhT~kl`3Hb`74|p4%R6^ zPnMqG!iK=}M0~j&491ryCT62E-|Q>rmxt!4SD6ZIu|3}T!QB6$t05q^Ap`zX7rV8w zos)0+#~>CGkK>00KhM!9ixKl3ruUW-amSi`e2dX`$)E z7d)M*zA4*lCsi@M%i~B=|FI9H|7n0WFxR4T7-HccRAk4induJ^jF0hlDa5CL-sXG4 zkMyt^%xHJ&O=;TAX(#nHcdy@Ar@KCDp+p?+Ag)G#ZD2?*pk=K1^{WFyKVr>H5xxG{ z3((0{_fk|Gdxq`#0k|JEc>`*8S^NqH2s9s~xf^un9E6fFhvMMOyR zV!ZyKO+xytKXj0`o+6WlyGUAWUZIw5<}xDuFvcxaSwR*G%h-M&VPaG3fzW<}*We`u zdSfhHn=hwj+j|@@Az=AA1$@`dbNM3TDhdJ_aT**2MHnTvpU3vCYU_-gEBlk++{y*-g(37)`zB2LMTClY!3o~VFn7?a9gD{29-d#a^$dIrprn{F5iO0! zYSBp=&>-9bO8n@$!v>0{x8p56G)Q=T?m7b<%5AolQb?WQF+m2c~H% zilS^kkz9nXx4rEdp>+HxOYza53Uk3H^gLgtkH)d0EniUM3qtID*I=rh*JTjrSU4q! zOn|Qwd^nhgJwMvmbGM5QORqGNrh6gTc5I+OO#qZjfuSR0%#@;h)(mZ|@zipu(sFH* zi9#PYVGqByPNV7%mwK?-FRopMGHJ0bA$upp=e&pED9v{xtf;o}iB{9m>Gse` zRSi6-?n>z>$|5(@z)hqLu|Bh8jz?YC`e<-aAfW+YSjn1C;T9Gdd=K(GhOkS^@d}zm zJhffrd4fD6$9Pa!LWsXCgkq9z%}Q35gvw>Ipvmn^0}wauQ(cFiwIZ~x7=%oZ@^RY+ z;!{wz?L|ok##5qA!>l;o`8pG2bU6wjMZ_<2{KaVfP~kqX=AZXL?csV8@?SYCd3;#9 zi;GZ$&>E_5!{mk;=NpKtm%3Pm_aSgxpO`kf7+2#Is9wssrR$nR_hq~;mK#y;CpwB% zzd0^MTcKPDeDYzEWS{lpDz&j;y%n>k z5S+O7KNNqkJzNOgmbBeEp3xDb)0z(e0(ocMnD_w`mx@a=D1L2G^^8`y0C-P%oekQ8 z$6HUqF-Z*N*4johjVGp31lUprTND$ z8}o}SJogzwdeMaIs8r`~8=8mr$saoho52Z!$D6mC&(j`%r(GQD+QIe1^zP{wQp*0Z zE>Y|3!6)I?&j#U|I`8UYN}J++u+CMTi;NkNuxn)NKa`kuF*S~1LJJj?VXG3qH5RQ# z*tliWv-MP$I~+GGu$9vaR>&6?EEJ8uzxrLRRXFD2%ZMQ0aYqv%+>vnP=?nFxb4Upl z#D~5_T(58=Sc8yyuB_fuarn zZZcvK3C{lgU8r^ChIy?84g{71H%mnypZ4DXlO!|f;SW0h?bb1`Ga{Yq8 zv=)C1FrNotzeU&0zXaH=L4(9-e(L4-{;%BLGB+0v{`HugOXFCVx{6Vu(($Z37#QTq3d(qSwJ9cN zGkk$Kw;*shyZ&Ev60W-?Fw6X_rt%f4$$W-Yf-D;V^nVc8(yAOD$tcl@<~=Yxg4$sJ zX$7)k|Np`N?KY@I4SekveL3%Zsyq=5ByVs4-UV<>@w8<9U-~&{t0xDboG-Uf1N$|3 zcR(Cq^4?iyKqpAR`#-7m2)NM;?m1i~aPL2ggrLqrP@Qfg zFq;<(c#<#av|oV-ZY5NCIseq`P7LgtNugi>uQfRJj`%;CNp8qL9fPs%udttrfKCBw z6SJnQ1d$M`GEmE+{hUftDVel;hJ^t&bh&Y>z)yh_q5LiOh z34KAh!-J#w4eXaKw!l$%{(Uq-VEJ)Cvji`HIWvZGlFP=z%d!YImcegZ$FKGa(){=&RzGG`L)o{UXP)(-pQQ`1 zWO`w&_3tJ>>kIlyoNFvvdibk~JvpoAd)thS{ed$UNT7mwDg&cJ zcn)RNxC1=xmURbnK6M!IjyAXWL^_(-7W6z#Oq5qFF=~c<819%jg@uCp^Sy^WFjvjr zdZkRIMOeKdV|X5C8Nig-=cu$hC5`f+lMDQ!qX-p@BgJdnmxf~JZmcNYm7Ojf)zEkl z%?h|G-&So(Zk?N*V>xFYmh$}2^D#zZdr|3ZU+Y(!lQ@L;Mpy`V&Cz9^&Px{!*h^y% z?$;pbBAGw0pOnhA{DqMQHVzpUh45f|fSBD*6t@$1`udHr@4xj{Y*^O5_&C>Ti#;_8 zKYrUtYdMBQzXQwyoQz6ZB8VFT0+Ut38mz2XLz%qhRuofpMwdh*l(G(2?otp=zpZr# z>tj^6P_FA8YZC_yT&oLLDEwD3h7NxFHghHzr$}uJi>8~4x1vjI5+GibdSQ(pscQ3m zYy&Hue&80?rI(G%@!>MoX9prufM)DSPy*Ij=5^n-(X+(-kQz59)J zIjkk=o1XcWjQLQQ3aQR=03UPxeIeF%7jnSU4(}pKVeM7ij`g8c#PWE&IK|7lUfn( zxxOy?LPKXl&m#dB9ygM5QRLj9yUZIfvHKL2Fj+r-q}ff0!tKQFeE*l@zx50{9Y3)nCviiguUY8DDNzy=jR) zJUpD6a>O4`b`f0m2e~u6xf%EVT1r<|m_EuyqMOjmw1bnIvY4?Fv21OK2R>1YVa5V(=q<-Z6p;q}gr;f15fIMLk4W42)Rn zAWinW2cDd`9#SYuQ9lAxwP0{nV$|^#fGt^Iyji=wROq7cp{|>KVmWNsfA495oglSO zsTk;a z%w2@84cc33#EF%hu*hOPyiE zi8m2?d^g@&so{2jeTft+D3<_-J7QM5Z7h0*0?ISCZ7Bl5&-Q@o`jTNP#fKl>#EuV3 zdZ;~@R&k+Avzs)^$ND-DFwOBTWqPkkgPuHG+OHJUJM)qSzM@p4n9PcAEZe@}(jPf% z2g2dr8?eBcv6EeHal(T5u>Vp@WCu#2ITrLwT9nKNMh&ew#)M|xm02Sr!yhOD1co8_ zq+HVA)Sx>N0E^d6IZw2h4IS~6ZamQL_7z*J$v7o=ueQ^$XMzYj!GW3rqOBi!2%RUv zH(w{@A-ps5T-7(Z^=gCK<91MX)fXCVjRlPlXQqcVa90eLn>%l|LVk zSC?B&Y)D$QHW+-|F~Cds@J-`Q29i#rld*pDVrK+k)Wax2w)qh4P_pNL2LVi#Iw&dp zV7$Yk+uhMMN09-v9(yxAg-bdrrT^X(;D5QgHy-VTWpGEJI%g$M9B#d`D|07~a1gtU zok01G^=3T00)>Al-G~Ljm80w8lTSOoh%y13CE72gh7GQL`9}N%hbTVCb2h(2Sw!ts zx|d1x0?8cwM5?jQuNZ{uhu22W%4q8@Bam3>+qZwVpL0C6^1jzHGu!K@y1opn!@W=R z+gijx&FgGMr&s=F2+v?Yu5s`u8X4UH3e;G6@*?N>K6c)C+gjVtzD zDIR)YXEGAIu(uCy?omkgfCXIV>{w!7+~2jl#4UuxWeh$BK)8gvdXZSk5I6$=&I~nv_3Ue1G~>ND8nNLsKE@rkcLS6T7gu~>k}2iQ z*F~p00e=>zSYq@B*&v8WsIx4WZom~_)iP+J8{J@%HR)i2E@ZW|w|{THc( zPv}(S!{{fO%GN>8h5q~@6I<8xYG=8G=QZ|S7-R?ub?x>!jf2Rg04+tk7Q@}ohqQm> zQGWS1Rh!+$P;M{QY-&Ge8%cK&Z{mtqcihRQKtd`{e!0l@bzo}9R*3s%1(Ua$sZTTy zFBDbTNe5YRfIVYkC{%v){ezF{jJwQ^eU7%&)IQ0Y*6rNdG8Y(Cx*UQ4m5*kNgJExT z-t+h-z>$1FLd-ga;6*y#|8W%|EXvy;%gwd;=KNQ~=Ap;q3om*0cCy5pz)HM&=a+%! z;bYN`@%@T1JC~Pu)X=p+zW@$cOuD45*N%ql_JyY#&c{{Owia&~yfrDZ&+qA(1xG(%WeWCYXb^_o2=cwT_#jLaJcBO3W*>H;zkT#}rfr%@# zZb|Qrh+J@1nnvU%aBSTozp?=DORb=#P2@lFdk8!XcWoTc^%Z-_m5)}i}A8=C$Ks{hSK7S zfd!Z5QCv$X54D6Va`gE{6dQF&Rg?X!O#w#K9WjyZF?C@k4O+6uwSQLXiwYd(ANLY{ zm!{b)b-OgC3a=Mud!hlp7>sj%GgMK>9Diq7clz&keO{CK_|vojCD4d$iW%8Gjttoc z#19{`-`>i_N)R?{2)`g$`wqQfe6-y(!$}mTRY9isNxKzg$w?@b?NRsoh?ZoZ&B9Id zU16m3v*6+4G+#4M+XhV6Lo6l(7&PRLA+Tr~E0h&`HNBeS6xzS+?n?OL(3fz2=v&yK z*QP%=IwVrp|B`;h3}$8=C+dTM|YBu)O!*64*PMSzCDjpC{N>q09YSOz95_ Kk`?cbKK~D~S!BEb literal 0 HcmV?d00001 diff --git a/statediff/indexer/database/dump/indexer.go b/statediff/indexer/database/dump/indexer.go index 29c51efd9287..6689621a898a 100644 --- a/statediff/indexer/database/dump/indexer.go +++ b/statediff/indexer/database/dump/indexer.go @@ -500,3 +500,6 @@ func (sdi *StateDiffIndexer) Close() error { func (sdi *StateDiffIndexer) FindAndUpdateGaps(latestBlockOnChain *big.Int, expectedDifference *big.Int, processingKey int64) error { return nil } +func (sdi *StateDiffIndexer) PushKnownGaps(startingBlockNumber *big.Int, endingBlockNumber *big.Int, checkedOut bool, processingKey int64) error { + return nil +} diff --git a/statediff/indexer/database/file/indexer.go b/statediff/indexer/database/file/indexer.go index 8df695f81b59..0bcd864d11ea 100644 --- a/statediff/indexer/database/file/indexer.go +++ b/statediff/indexer/database/file/indexer.go @@ -482,3 +482,7 @@ func (sdi *StateDiffIndexer) Close() error { func (sdi *StateDiffIndexer) FindAndUpdateGaps(latestBlockOnChain *big.Int, expectedDifference *big.Int, processingKey int64) error { return nil } + +func (sdi *StateDiffIndexer) PushKnownGaps(startingBlockNumber *big.Int, endingBlockNumber *big.Int, checkedOut bool, processingKey int64) error { + return nil +} diff --git a/statediff/indexer/database/sql/indexer.go b/statediff/indexer/database/sql/indexer.go index dc07bf843f9d..c8a0e64c75ac 100644 --- a/statediff/indexer/database/sql/indexer.go +++ b/statediff/indexer/database/sql/indexer.go @@ -555,7 +555,10 @@ func (sdi *StateDiffIndexer) Close() error { } // Update the known gaps table with the gap information. -func (sdi *StateDiffIndexer) pushKnownGaps(startingBlockNumber *big.Int, endingBlockNumber *big.Int, checkedOut bool, processingKey int64) error { +func (sdi *StateDiffIndexer) PushKnownGaps(startingBlockNumber *big.Int, endingBlockNumber *big.Int, checkedOut bool, processingKey int64) error { + if startingBlockNumber.Cmp(endingBlockNumber) != -1 { + return fmt.Errorf("Starting Block %d, is greater than ending block %d", startingBlockNumber, endingBlockNumber) + } knownGap := models.KnownGapsModel{ StartingBlockNumber: startingBlockNumber.String(), EndingBlockNumber: endingBlockNumber.String(), @@ -573,7 +576,7 @@ func (sdi *StateDiffIndexer) QueryDb(queryString string) (string, error) { var ret string err := sdi.dbWriter.db.QueryRow(context.Background(), queryString).Scan(&ret) if err != nil { - log.Error("Can't properly query the DB for query: ", queryString) + log.Error(fmt.Sprint("Can't properly query the DB for query: ", queryString)) return "", err } return ret, nil @@ -589,7 +592,7 @@ func (sdi *StateDiffIndexer) QueryDbToBigInt(queryString string) (*big.Int, erro } ret, ok := ret.SetString(res, 10) if !ok { - log.Error("Can't turn the res ", res, "into a bigInt") + log.Error(fmt.Sprint("Can't turn the res ", res, "into a bigInt")) return ret, fmt.Errorf("Can't turn %s into a bigInt", res) } return ret, nil @@ -611,6 +614,9 @@ func isGap(latestBlockInDb *big.Int, latestBlockOnChain *big.Int, expectedDiffer // This function will check for Gaps and update the DB if gaps are found. // The processingKey will currently be set to 0, but as we start to leverage horizontal scaling // It might be a useful parameter to update depending on the geth node. +// TODO: +// REmove the return value +// Write to file if err in writing to DB func (sdi *StateDiffIndexer) FindAndUpdateGaps(latestBlockOnChain *big.Int, expectedDifference *big.Int, processingKey int64) error { dbQueryString := "SELECT MAX(block_number) FROM eth.header_cids" latestBlockInDb, err := sdi.QueryDbToBigInt(dbQueryString) @@ -625,8 +631,13 @@ func (sdi *StateDiffIndexer) FindAndUpdateGaps(latestBlockOnChain *big.Int, expe startBlock.Add(latestBlockInDb, expectedDifference) endBlock.Sub(latestBlockOnChain, expectedDifference) - log.Warn("Found Gaps starting at, ", startBlock, " and ending at, ", endBlock) - sdi.pushKnownGaps(startBlock, endBlock, false, processingKey) + log.Warn(fmt.Sprint("Found Gaps starting at, ", startBlock, " and ending at, ", endBlock)) + err := sdi.PushKnownGaps(startBlock, endBlock, false, processingKey) + if err != nil { + // Write to file SQL file instead!!! + // If write to SQL file fails, write to disk. Handle this within the write to SQL file function! + return err + } } return nil diff --git a/statediff/indexer/database/sql/mainnet_tests/indexer_test.go b/statediff/indexer/database/sql/mainnet_tests/indexer_test.go index bb7001d25f7c..5c30b0d6aed3 100644 --- a/statediff/indexer/database/sql/mainnet_tests/indexer_test.go +++ b/statediff/indexer/database/sql/mainnet_tests/indexer_test.go @@ -116,31 +116,3 @@ func tearDown(t *testing.T) { err = ind.Close() require.NoError(t, err) } - -//func TestKnownGapsUpsert(t *testing.T) { -// var startBlockNumber int64 = 111 -// var endBlockNumber int64 = 121 -// ind, err := setupDb(t) -// if err != nil { -// t.Fatal(err) -// } -// require.NoError(t, err) -// -// testKnownGapsUpsert(t, startBlockNumber, endBlockNumber, ind) -// //str, err := ind.QueryDb("SELECT MAX(block_number) FROM eth.header_cids") // Figure out the string. -// queryString := fmt.Sprintf("SELECT starting_block_number from eth.known_gaps WHERE starting_block_number = %d AND ending_block_number = %d", startBlockNumber, endBlockNumber) -// _, queryErr := ind.QueryDb(queryString) // Figure out the string. -// require.NoError(t, queryErr) -// -//} -//func testKnownGapsUpsert(t *testing.T, startBlockNumber int64, endBlockNumber int64, ind interfaces.StateDiffIndexer) { -// startBlock := big.NewInt(startBlockNumber) -// endBlock := big.NewInt(endBlockNumber) -// -// processGapError := ind.PushKnownGaps(startBlock, endBlock, false, 1) -// if processGapError != nil { -// t.Fatal(processGapError) -// } -// require.NoError(t, processGapError) -//} -// diff --git a/statediff/indexer/interfaces/interfaces.go b/statediff/indexer/interfaces/interfaces.go index 7d58c510cd12..36d3eb32bf54 100644 --- a/statediff/indexer/interfaces/interfaces.go +++ b/statediff/indexer/interfaces/interfaces.go @@ -33,6 +33,7 @@ type StateDiffIndexer interface { PushCodeAndCodeHash(tx Batch, codeAndCodeHash sdtypes.CodeAndCodeHash) error ReportDBMetrics(delay time.Duration, quit <-chan bool) FindAndUpdateGaps(latestBlockOnChain *big.Int, expectedDifference *big.Int, processingKey int64) error + PushKnownGaps(startingBlockNumber *big.Int, endingBlockNumber *big.Int, checkedOut bool, processingKey int64) error io.Closer } diff --git a/statediff/service.go b/statediff/service.go index 8c932ff541e5..7f3c6dda4e76 100644 --- a/statediff/service.go +++ b/statediff/service.go @@ -18,6 +18,7 @@ package statediff import ( "bytes" + "fmt" "math/big" "strconv" "strings" @@ -123,6 +124,8 @@ type Service struct { BackendAPI ethapi.Backend // Should the statediff service wait for geth to sync to head? WaitForSync bool + // Used to signal if we should check for KnownGaps + KnownGaps KnownGaps // Whether or not we have any subscribers; only if we do, do we processes state diffs subscribers int32 // Interface for publishing statediffs as PG-IPLD objects @@ -135,6 +138,91 @@ type Service struct { maxRetry uint } +type KnownGaps struct { + // Should we check for gaps by looking at the DB and comparing the latest block with head + checkForGaps bool + // Arbitrary processingKey that can be used down the line to differentiate different geth nodes. + processingKey int64 + // This number indicates the expected difference between blocks. + // Currently, this is 1 since the geth node processes each block. But down the road this can be used in + // Tandom with the processingKey to differentiate block processing logic. + expectedDifference *big.Int + // Indicates if Geth is in an error state + // This is used to indicate the right time to upserts + errorState bool + // This array keeps track of errorBlocks as they occur. + // When the errorState is false again, we can process these blocks. + // Do we need a list, can we have /KnownStartErrorBlock and knownEndErrorBlock ints instead? + knownErrorBlocks []*big.Int + // The last processed block keeps track of the last processed block. + // Its used to make sure we didn't skip over any block! + lastProcessedBlock *big.Int +} + +// This function will capture any missed blocks that were not captured in sds.KnownGaps.knownErrorBlocks. +// It is invoked when the sds.KnownGaps.lastProcessed block is not one unit +// away from sds.KnownGaps.expectedDifference +// Essentially, if geth ever misses blocks but doesn't output an error, we are covered. +func (sds *Service) capturedMissedBlocks(currentBlock *big.Int, knownErrorBlocks []*big.Int, lastProcessedBlock *big.Int) { + // last processed: 110 + // current block: 125 + if len(knownErrorBlocks) > 0 { + // 115 + startErrorBlock := new(big.Int).Set(knownErrorBlocks[0]) + // 120 + endErrorBlock := new(big.Int).Set(knownErrorBlocks[len(knownErrorBlocks)-1]) + + // 111 + expectedStartErrorBlock := big.NewInt(0).Add(lastProcessedBlock, sds.KnownGaps.expectedDifference) + // 124 + expectedEndErrorBlock := big.NewInt(0).Sub(currentBlock, sds.KnownGaps.expectedDifference) + + if (expectedStartErrorBlock == startErrorBlock) && + (expectedEndErrorBlock == endErrorBlock) { + log.Info("All Gaps already captured in knownErrorBlocks") + } + + if expectedEndErrorBlock.Cmp(endErrorBlock) == 1 { + log.Warn(fmt.Sprint("There are gaps in the knownErrorBlocks list: ", knownErrorBlocks)) + log.Warn("But there are gaps that were also not added there.") + log.Warn(fmt.Sprint("Last Block in knownErrorBlocks: ", endErrorBlock)) + log.Warn(fmt.Sprint("Last processed Block: ", lastProcessedBlock)) + log.Warn(fmt.Sprint("Current Block: ", currentBlock)) + //120 + 1 == 121 + startBlock := big.NewInt(0).Add(endErrorBlock, sds.KnownGaps.expectedDifference) + // 121 to 124 + log.Warn(fmt.Sprintf("Adding the following block range to known_gaps table: %d - %d", startBlock, expectedEndErrorBlock)) + sds.indexer.PushKnownGaps(startBlock, expectedEndErrorBlock, false, sds.KnownGaps.processingKey) + } + + if expectedStartErrorBlock.Cmp(startErrorBlock) == -1 { + log.Warn(fmt.Sprint("There are gaps in the knownErrorBlocks list: ", knownErrorBlocks)) + log.Warn("But there are gaps that were also not added there.") + log.Warn(fmt.Sprint("First Block in knownErrorBlocks: ", startErrorBlock)) + log.Warn(fmt.Sprint("Last processed Block: ", lastProcessedBlock)) + // 115 - 1 == 114 + endBlock := big.NewInt(0).Sub(startErrorBlock, sds.KnownGaps.expectedDifference) + // 111 to 114 + log.Warn(fmt.Sprintf("Adding the following block range to known_gaps table: %d - %d", expectedStartErrorBlock, endBlock)) + sds.indexer.PushKnownGaps(expectedStartErrorBlock, endBlock, false, sds.KnownGaps.processingKey) + } + + log.Warn(fmt.Sprint("The following Gaps were found: ", knownErrorBlocks)) + log.Warn(fmt.Sprint("Updating known Gaps table from ", startErrorBlock, " to ", endErrorBlock, " with processing key, ", sds.KnownGaps.processingKey)) + sds.indexer.PushKnownGaps(startErrorBlock, endErrorBlock, false, sds.KnownGaps.processingKey) + + } else { + log.Warn("We missed blocks without any errors.") + // 110 + 1 == 111 + startBlock := big.NewInt(0).Add(lastProcessedBlock, sds.KnownGaps.expectedDifference) + // 125 - 1 == 124 + endBlock := big.NewInt(0).Sub(currentBlock, sds.KnownGaps.expectedDifference) + log.Warn(fmt.Sprint("Missed blocks starting from: ", startBlock)) + log.Warn(fmt.Sprint("Missed blocks ending at: ", endBlock)) + sds.indexer.PushKnownGaps(startBlock, endBlock, false, sds.KnownGaps.processingKey) + } +} + // BlockCache caches the last block for safe access from different service loops type BlockCache struct { sync.Mutex @@ -174,6 +262,14 @@ func New(stack *node.Node, ethServ *eth.Ethereum, cfg *ethconfig.Config, params if workers == 0 { workers = 1 } + // If we ever have multiple processingKeys we can update them here + // along with the expectedDifference + knownGaps := &KnownGaps{ + checkForGaps: true, + processingKey: 0, + expectedDifference: big.NewInt(1), + errorState: false, + } sds := &Service{ Mutex: sync.Mutex{}, BlockChain: blockChain, @@ -184,6 +280,7 @@ func New(stack *node.Node, ethServ *eth.Ethereum, cfg *ethconfig.Config, params BlockCache: NewBlockCache(workers), BackendAPI: backend, WaitForSync: params.WaitForSync, + KnownGaps: *knownGaps, indexer: indexer, enableWriteLoop: params.EnableWriteLoop, numWorkers: workers, @@ -308,12 +405,40 @@ func (sds *Service) writeLoopWorker(params workerParams) { sds.writeGenesisStateDiff(parentBlock, params.id) } + // If for any reason we need to check for gaps, + // Check and update the gaps table. + if sds.KnownGaps.checkForGaps && !sds.KnownGaps.errorState { + log.Info("Checking for Gaps at current block: ", currentBlock.Number()) + go sds.indexer.FindAndUpdateGaps(currentBlock.Number(), sds.KnownGaps.expectedDifference, sds.KnownGaps.processingKey) + sds.KnownGaps.checkForGaps = false + } + log.Info("Writing state diff", "block height", currentBlock.Number().Uint64(), "worker", params.id) err := sds.writeStateDiffWithRetry(currentBlock, parentBlock.Root(), writeLoopParams) if err != nil { log.Error("statediff.Service.WriteLoop: processing error", "block height", currentBlock.Number().Uint64(), "error", err.Error(), "worker", params.id) + sds.KnownGaps.errorState = true + sds.KnownGaps.knownErrorBlocks = append(sds.KnownGaps.knownErrorBlocks, currentBlock.Number()) + log.Warn("Updating the following block to knownErrorBlocks to be inserted into knownGaps table: ", currentBlock.Number()) + // Write object to startdiff continue } + sds.KnownGaps.errorState = false + // Understand what the last block that should have been processed is + previousExpectedBlock := big.NewInt(0).Sub(currentBlock.Number(), sds.KnownGaps.expectedDifference) + // If we last block which should have been processed is not + // the actual lastProcessedBlock, add it to known gaps table. + if previousExpectedBlock != sds.KnownGaps.lastProcessedBlock && sds.KnownGaps.lastProcessedBlock != nil { + // We must pass in parameters by VALUE not reference. + // If we pass them in my reference, the references can change before the computation is complete! + staticKnownErrorBlocks := make([]*big.Int, len(sds.KnownGaps.knownErrorBlocks)) + copy(staticKnownErrorBlocks, sds.KnownGaps.knownErrorBlocks) + staticLastProcessedBlock := new(big.Int).Set(sds.KnownGaps.lastProcessedBlock) + go sds.capturedMissedBlocks(currentBlock.Number(), staticKnownErrorBlocks, staticLastProcessedBlock) + sds.KnownGaps.knownErrorBlocks = nil + } + sds.KnownGaps.lastProcessedBlock = currentBlock.Number() + // TODO: how to handle with concurrent workers statediffMetrics.lastStatediffHeight.Update(int64(currentBlock.Number().Uint64())) case <-sds.QuitChan: diff --git a/statediff/service_public_test.go b/statediff/service_public_test.go new file mode 100644 index 000000000000..05e7cb52eff6 --- /dev/null +++ b/statediff/service_public_test.go @@ -0,0 +1,143 @@ +package statediff + +import ( + "context" + "fmt" + "math/big" + "testing" + + "github.com/ethereum/go-ethereum/params" + "github.com/ethereum/go-ethereum/statediff/indexer/database/sql" + "github.com/ethereum/go-ethereum/statediff/indexer/database/sql/postgres" + "github.com/ethereum/go-ethereum/statediff/indexer/interfaces" + "github.com/stretchr/testify/require" +) + +var ( + db sql.Database + err error + indexer interfaces.StateDiffIndexer + chainConf = params.MainnetChainConfig +) + +func TestKnownGaps(t *testing.T) { + type gapValues struct { + lastProcessedBlock int64 + currentBlock int64 + knownErrorBlocksStart int64 + knownErrorBlocksEnd int64 + expectedDif int64 + } + + tests := []gapValues{ + // Unprocessed gaps before and after knownErrorBlock + {lastProcessedBlock: 110, knownErrorBlocksStart: 115, knownErrorBlocksEnd: 120, currentBlock: 125, expectedDif: 1}, + // No knownErrorBlocks + {lastProcessedBlock: 130, knownErrorBlocksStart: 0, knownErrorBlocksEnd: 0, currentBlock: 140, expectedDif: 1}, + // No gaps before or after knownErrorBlocks + {lastProcessedBlock: 150, knownErrorBlocksStart: 151, knownErrorBlocksEnd: 159, currentBlock: 160, expectedDif: 1}, + // gaps before knownErrorBlocks but not after + {lastProcessedBlock: 170, knownErrorBlocksStart: 180, knownErrorBlocksEnd: 189, currentBlock: 190, expectedDif: 1}, + // gaps after knownErrorBlocks but not before + {lastProcessedBlock: 200, knownErrorBlocksStart: 201, knownErrorBlocksEnd: 205, currentBlock: 210, expectedDif: 1}, + /// Same tests as above with a new expected DIF + // Unprocessed gaps before and after knownErrorBlock + {lastProcessedBlock: 1100, knownErrorBlocksStart: 1150, knownErrorBlocksEnd: 1200, currentBlock: 1250, expectedDif: 2}, + // No knownErrorBlocks + {lastProcessedBlock: 1300, knownErrorBlocksStart: 0, knownErrorBlocksEnd: 0, currentBlock: 1400, expectedDif: 2}, + // No gaps before or after knownErrorBlocks + {lastProcessedBlock: 1500, knownErrorBlocksStart: 1502, knownErrorBlocksEnd: 1598, currentBlock: 1600, expectedDif: 2}, + // gaps before knownErrorBlocks but not after + {lastProcessedBlock: 1700, knownErrorBlocksStart: 1800, knownErrorBlocksEnd: 1898, currentBlock: 1900, expectedDif: 2}, + // gaps after knownErrorBlocks but not before + {lastProcessedBlock: 2000, knownErrorBlocksStart: 2002, knownErrorBlocksEnd: 2050, currentBlock: 2100, expectedDif: 2}, + } + for _, tc := range tests { + // Reuse processing key from expecteDiff + testCaptureMissedBlocks(t, tc.lastProcessedBlock, tc.currentBlock, tc.knownErrorBlocksStart, tc.knownErrorBlocksEnd, tc.expectedDif, tc.expectedDif) + } +} + +// It also makes sure we properly calculate any missed gaps not in the known gaps lists +// either before or after the list. +func testCaptureMissedBlocks(t *testing.T, lastBlockProcessed int64, currentBlockNum int64, knownErrorBlocksStart int64, knownErrorBlocksEnd int64, expectedDif int64, processingKey int64) { + + lastProcessedBlock := big.NewInt(lastBlockProcessed) + currentBlock := big.NewInt(currentBlockNum) + knownErrorBlocks := (make([]*big.Int, 0)) + + checkGaps := knownErrorBlocksStart != 0 && knownErrorBlocksEnd != 0 + if checkGaps { + for i := knownErrorBlocksStart; i <= knownErrorBlocksEnd; i++ { + knownErrorBlocks = append(knownErrorBlocks, big.NewInt(i)) + } + } + + // Comment out values which should not be used + knownGaps := KnownGaps{ + processingKey: processingKey, + expectedDifference: big.NewInt(expectedDif), + } + stateDiff, err := setupDb(t) + if err != nil { + t.Fatal(err) + } + + service := &Service{ + KnownGaps: knownGaps, + indexer: stateDiff, + } + service.capturedMissedBlocks(currentBlock, knownErrorBlocks, lastProcessedBlock) + + if checkGaps { + + if lastBlockProcessed+expectedDif == knownErrorBlocksStart && knownErrorBlocksEnd+expectedDif == currentBlockNum { + validateUpsert(t, stateDiff, knownErrorBlocksStart, knownErrorBlocksEnd) + + } else if lastBlockProcessed+expectedDif == knownErrorBlocksStart { + validateUpsert(t, stateDiff, knownErrorBlocksStart, knownErrorBlocksEnd) + validateUpsert(t, stateDiff, knownErrorBlocksEnd+expectedDif, currentBlockNum-expectedDif) + + } else if knownErrorBlocksEnd+expectedDif == currentBlockNum { + validateUpsert(t, stateDiff, lastBlockProcessed+expectedDif, knownErrorBlocksStart-expectedDif) + validateUpsert(t, stateDiff, knownErrorBlocksStart, knownErrorBlocksEnd) + + } else { + validateUpsert(t, stateDiff, lastBlockProcessed+expectedDif, knownErrorBlocksStart-expectedDif) + validateUpsert(t, stateDiff, knownErrorBlocksStart, knownErrorBlocksEnd) + validateUpsert(t, stateDiff, knownErrorBlocksEnd+expectedDif, currentBlockNum-expectedDif) + + } + } else { + validateUpsert(t, stateDiff, lastBlockProcessed+expectedDif, currentBlockNum-expectedDif) + } + + tearDown(t, stateDiff) +} + +func validateUpsert(t *testing.T, stateDiff *sql.StateDiffIndexer, startingBlock int64, endingBlock int64) { + t.Logf("Starting to query blocks: %d - %d", startingBlock, endingBlock) + queryString := fmt.Sprintf("SELECT starting_block_number from eth.known_gaps WHERE starting_block_number = %d AND ending_block_number = %d", startingBlock, endingBlock) + + _, queryErr := stateDiff.QueryDb(queryString) // Figure out the string. + t.Logf("Updated Known Gaps table starting from, %d, and ending at, %d", startingBlock, endingBlock) + require.NoError(t, queryErr) +} + +// Create a DB object to use +func setupDb(t *testing.T) (*sql.StateDiffIndexer, error) { + db, err = postgres.SetupSQLXDB() + if err != nil { + t.Fatal(err) + } + stateDiff, err := sql.NewStateDiffIndexer(context.Background(), chainConf, db) + return stateDiff, err +} + +// Teardown the DB +func tearDown(t *testing.T, stateDiff *sql.StateDiffIndexer) { + t.Log("Starting tearDown") + sql.TearDownDB(t, db) + err := stateDiff.Close() + require.NoError(t, err) +}