From 420a6910e9f3215da5e41b29d3f2d70226a12a0f Mon Sep 17 00:00:00 2001
From: fiatjaf <fiatjaf@gmail.com>
Date: Sun, 17 Dec 2023 00:27:03 -0300
Subject: [PATCH] fix Queue, tweaks on relay.ts and make relay.test.ts pass.

---
 bun.lockb     | Bin 137037 -> 129997 bytes
 nip42.test.ts |   7 +-
 package.json  |   3 +-
 pool.test.ts  |   1 -
 relay.test.ts | 173 +++++++++++++++++++----------------------------
 relay.ts      | 184 +++++++++++++++++++++++++++++---------------------
 utils.test.ts |  15 ++--
 utils.ts      |  26 +++++--
 8 files changed, 207 insertions(+), 202 deletions(-)

diff --git a/bun.lockb b/bun.lockb
index 0bf875779f64e80cdf1dd5c1257d2f88b909ca6c..4fdf93f191ef8cd59cb2a49d98353593d5acd41b 100755
GIT binary patch
delta 23942
zcmeI4d0<Uf_xH~^a>+%^G7wXZ35hv_a0#m7qUO+2l88zwL}FGF9Sx=0je{bFB2se)
zV_Th3TH0!<p*l-SOJ|*)-)Efx?W29)KYs6DZ%=*C+TXp`9@g4x?{n_G={~wO@aRuv
z7Dh)Hy94GgdGOnDTT@kJ$-(}&Pu~0X#!n9=ocnxK#dUi-t(?~3S6!3q_Q#Uz<SD;R
ztQ@VJrsY>4qdf8_vV@l)gOG-kf7aoybj#l+zXE#H(aItx<c=hzX$7V1b}k^j<maTP
zjEu^@=WdJVk+CGeuF%z^X_euPk+qQNIXUBUqSB|tm$n-ScFNO6r;NFWh8vf$I~<*o
z8#QW7%H37r)u<PUl!12)v<JQbDFb?)b}Av`7=;WZm|Na0B=Q+RFmfPT;mEVd>d5}I
zA{DwKD<Y4RFP_Ow&zh8;qiH$mx#Px6O4kmPS%>@sNa<)NQar)H#!VipX#o)NU<`%Q
zP8$7*ful0URvZ~MF<V>YxG1usT5dGT`-D!VAJ=0i;8H&)ePsIB37U2ZFG+cP6}!Ll
za4FAs>~P07sH$z~)RZw}GIA$qZvU^*p4fFy#@LZj<3?%2@S3!jl9Q7$YO2;n+eN7u
zP>7TPXQgCEjZ4kcR>8%<g--cUye6J>%lkWgRwZ>`sYZDVLhRxtp?0-1NKsGCNl8o3
z)wKR$cK$M?boUif%IBdc6PS@3b@!NYsoL5aw%&B|={bK?O74X51VB#u#9SG0<C>a=
zsreU>Vn-V$kzwcM-{VvmnUQ0+gx95m`x%&YFay7n%nzw;H}KbpDo4IFIEdL5yH_}}
zBU0+MK}tK>V<r*~nzo^?9l;v)%4vCoU_Cn|-H`pe(7epR#Inzj(xE%^AHZd13+ihc
zlb!!KQutT~E)$cTlRjZWMtaU`bS?v|+t8MykX7=?n2^&ZMn;xCiO9j_+eu4k&ue6l
zJfX2|$;(KwWN@Ty!81td;B*r^|L$?wBc+}Ba2dcmNb%$-S)nOuqm2k#uaI^me_b>D
zFLSaNMP?yCAj<YcN4TuDB&UP)XnR0EBBf$$8WQ;hTs(3DDVxF(r~D423^bPd;*s{~
zS3uT<%anK>`BMb`7lpGZ5I^}l7@0Jb3YP|6L(0ImBgG?YkYX`Gmy>>X`jmxm(a*?b
zS)@$Wrom<4U$n9F6WiJbWsxr)8Gw|5^gxzH){4OYQXz;8vE(}}mkz!_N`*&a?YZ6#
zmkP@r&rCv!C3ho5KOo+2cpzL1YJeor^UEW}fELcwx%;YYEnf1o^JHysz17ZcU~z(7
z;O@88+S?7xCEtqTjFA&^($lrZ&KxFoum`XnDFZZ-Vqs0nB}gkd9Zw#ekv5usGIG<W
zq$9WZ?0R|QJKC0Jr%V_fbx-=#u^DOUQ4?~eP9yllwJTAU7)j3^lOg+BMrXUD;f@UL
zVtZ~(`lPX_Y8BuzkguHbACPPr`6JWQv!gO{wLWn1SXU$i%*(Gsf|Zb;nHx1VC2Ne9
zl5=-<N=|NiW%9+6(nzuV_e9$>vfHGL$<^HD=Wax7)Yd*7N$ZxUqQ;C%OPN5gV=}Tb
zCTMqdxAQO2j!gAMcv+rB`8gR`IVqzw&DzGWU`>+R8Q3UqNs_IPPbP_B34WXN6q_(1
zeWZ4dcEphM+=&x17*Bfc_=)K`Q?)TYZ3m?1vhZ>Bo9KxHzaU?xJSA;hj(F-t@@0mC
zdfWN#lX2v@v<W#GV^y-Za*e;vo;z#fJF5G<jq(olvBP^CQkG94O-fYGMY6l)k3&in
zmh`iqndxwun}JAi!O8yi(2gKwC=U&=<y53Zf3<=3(AuLfb66WG?H=r8^_!RfFm}lD
z$wgK}rst+k%osCL`);tk49+9P_9I9s-|OUWaJX{HXF2&<PJS{{+U?@-W=JtC*vT)2
ztSWo=H_3LxXOXh*4mtd3q%^P^DFc{?lnrFEQ=a0K_i}h92FT>}MT(`>M%Zr)Cx_e1
z?=rFh`3Whuhjzp3GP(IJsZbZ$C)HMb6)CQ3jjV;F%vweTX?6!!kTL~X8CmI3BU80c
z;1Wg8vU5wcr{qo@n|4pe1O{tG@sxBmw_NY1v&&B@tJhG)!5#JfDk7w#K38Rgbo9KY
zYg)X@3P~{j&{au@Pmfm-p&j)JDkHR`cblPU><0OoY8e`9{A{SAT0Wy=DOFO-=PfFw
zY3u;`Wz?0LvBs5BDzmoF+cZGa;>h$^6;=nR5;8v|lRe1E9OzM*b$s3ekEUT@zM-!4
zjtk(GEly>HCV0D&l2$c!B{<f&ue8dn>oeXjt%~aUylu;9T35TB`f>7zm7YqemJMT#
z9c5HzJ)c((v}>2LYWECOC1froQ@YnxO9uL0pvt_(=S^g)*e~+~tm@Ofs)Wo>$RuuM
zOm$<8@nuzJeV_MRd`<Avk=U75PL<U68Jo+g$Oe?LOLVfz@Q=4W3!n|mqjsP<y}T-E
z;4_NLtH_2v<MtqxiI^9piW>U7$CzKyG_2k$S5T3Sd`ABYDig7+f+}j{^M21%#-I|Q
zu7t#T+cLr87HhcPT!-Q1hOyoqF!6+?=_!WAsHg@B-a4$$R(2;0t}m<w%xiV|btP5Q
z#Ah_GtV){ryqWCMohh?S^lpa9;4II2ufiM?8^(INutM6aC|~<P5>mw;&`U6J91RdB
zw^UU{kv{KmR*ks0v^C0QFxws(^V_g)R&}widNoaBD|KwmfQe>lY0Ogq>!dD)BzQg|
z)ka;anc%HTXiFe4Pa(0MWLP&9g~m!!F{0slmlWd+O)x43tD-2MH=U(y&o{H^Er2<L
zX%Oo@;gsRdUU7PeDvI`bdxvORTe>J`x!;6|EA3!A6rwVl`@FxC*@jH2(MZcsyMt0{
zJl<Xnlb8!o<LkwGKX=LuH9jQPs1v4&TKK%f*d#=S^%E5r2(d$3hW9;823yARTyzb4
z?&+sdtal8|9y;FfZiY!C1QIP@sG%}j`HXfoRZ%OSH;a8+G<7w;eyn#L>{eT|My%(1
zSSQOrUBXpSYoB*cxTf(Kry&{eL70S;9S~l2AsLQ6*Ii%|ik9=evtWa)GMS3V+M3qe
z3ce|%#2`#ynEPSUp54OtFbSyuwWD>ccSIfAgwkq9|F}Shcx178KY>Z(b|l8twL1>9
zyfO(U@oYD_3)aKZWaWDGdhTjrP~QHqK9sSgz}CTJDyfGzPh8WKIjnk%9n_e{0v>pa
zDv9$MkKLjo<9*)Kl-Yx3evO*-RZ+ap7*t=CAa>MOk?nk*pX&37S6THEj5`~sqIN#-
z<_4}CnH}$EFng}XV_RfHo7ro43XF%l?QqYluomhP+u`@5B*yRn<7?8$-inyfuvqUq
zFrRG+Gun^0v_UGWMuKs)v5M^AGcqDoW(S|=l}KxKG)(Y%o7(!iwXSZ1(Fdz(GO5nA
zqpKZJvEDr}nQXLr#RWoS-ZZtNR;<yqnTqV_^JFwbL(KF%M~dlY<%LFR+F)ztWs~Y-
z<sBe3K=i!TqV3gA4=rN7(_sDV{$T%s+5Hivp7`cg+YJ*uxum+QEK>VO^-xib61*NJ
z{F<(}BTVeKTb%(D4_eV~9BQFTI{Q2oc(&pc8X0*lwU<;+E3Y(hFx2WIl~fOPDLBEi
znUv2OehI0;R%z$f3|M8gO7JcsCEFIAq{an6;?$+M1Wy&Fi0b%qC@EQU)-p04Z=)i+
z`Mf_#v6V?!c?Pnr^if+{CwSMB62}vYHDbMA!fv(N-oXahj8-IAY~x1523%wNVX|Es
z;!aOMtW5Bh775-Sr0j{5@K_3yfVG$ZNtoRp+lHqalR7|rV2qAanMpp+3uJV&98e{m
zg=@{)AX4H{s~hiH*j?@rJTeV~r2+3?QuZv2uN~`M0+WETSL_)W{~Q*aV6RxatQ)K=
zW%l}A1-q_!5+;MS%bJlK46|HeJkVa1^z?a;lPQkYWJ~py;U&eX-YC}S(?J#W@_DzB
zDXp;XS#Mv#q(9rC%^9*d$F4pOCN`9o&Cl}&$yV}4<h?2>@~y|Trz!g*&zaB!&rDLC
zE$a`E5__#3!}GH+%XckkT&A3b6HUa!dc!={{$JclmGtp>bD1i8c(OxoyT-1t|2FC3
z&alj6HjL<&!8VUIR(Da6{d}G?WVV+XGeWznqJBPaD%RN^xe~|h!|X_H*)P^O*HvZq
z_jzg)UpZEst|BGM_S?mKuxnO$%TtfqvKKM1J}~hOUZmLtFmW{RQZ#$8n~EIhGql@O
z=0Kk};WpQcvdX8zqz8L{+jgx?p8l6$(w|+{kXRN?`eQ0b!JPhJPr@YBc^6;~e<Ud`
zBZAn2TP0b~(NRgZcgk2#lN~UrzyNE<1v*96XuT0k2rJQvfMGD(W_da;c9^xZdXB=_
z1c>f(e!FoVRgtmYZZH{}{aAbeW{-PElUUDQ7}3EVAd5!wi3$7{<1qG9o=lTqVgZ&n
zh&6WhRGD}BjBk3XqC0)w4!vyO5+zu-yqAg`>hm5YQvwz1*qnojB5^+pgU3N1SRb3=
z)YULC$XZ^;$=)h+n9p1Gc1>$WCK1fjE(Rv!=aqwzEr8k4E%S8%CIMr`y0<j#5|MUe
z-tI7`Y2GsO`>4p_KJQsF#htw3G>`RG?t9IhOj{C6MrK8<cNuJ`)%2Abae)xJViv|X
zhzsbaX#*u7jb;5*$q1jfbbn1l!Cp^Ba(`>3JVK`U0EZHSU%_NCVJAJsvn@&)439kS
zFl*!RyaVfOg?p`m?*2fC8OZ}xWSY;rnoRl^XZDNr1`TqDEDhZaqc(5L5|jI`mC1*a
z;AE9K(&zCEu{O$)37#ZU-BcE-M@jL}BK5(w(wcX;d1<83%V-}!f;|?sOV<k9-YJhI
z$(u#WZsZWD-s;lm_5rxhE=(h3w?V?zx<blst?e*3Zw4v5!XZ-j;40oFPbukP2r0Yn
z8dA32B{$D#J6uI(`i$)1Dl^mP=`zB4if1NxOj5K&>MW_dB;~y=#dg2_PVq2okgaho
zH8a(zWgJgcnPYsO@@ew?lV*mJ>Y}!UCwL1<wX>&!4|Bh!smv^&5jRp5W%<10M$!Of
zEaF;m0g$e;GCgI|2{;wiFTv=Tu8PL`j0e(H$=G&zA)56$Uo((lK&~5QDR?;0K`lqt
zM#^<FS(^L?K<YIHa)}H8O@(lY6y99ZB85xBx<pDxEo^E@85qk>E2S=ttCJ_CJen;n
zmY8*kl<s&6TGx$Iy5T8fnV0CuE|wO)yg^DY?CRDfQrcr*w5}Uus?{;uq$Sz*tm|e{
z8f5dbE|D^D_9jcR94*PZwl0z70pY7@>b2}T5u#0iS=WtH%t-}Oo+eU7jStC?!Hx!U
z{gae2Wm;N)mQp{<$^R!=S`8atr?LmlDL`7ACbiVc@gYevq8Y-tL<*nj$ULN6BBj<W
zAm#S~xkO6-13*_nIU(^<`Vf%oMi~fS07QEs5WUBMTp~-Uteg<5yTw+Xrim1-B@P!U
zwU;_vr10fH^qz3!3Zz^&N-1Ay<=Rr}6*&9`Y4!i70#RH8M6Pox+)T>!ZUkPi9mvEy
z4P*g*2*mXt0U5}7AlG>y{9_>XKeya$CG3JPNXsQs8Y~8)cnL_wuYu%W0dk3y@*jY7
z_zMudUmf|IBY#JVLH}{Mr9@hjMJf%JLQ2H|Zqkq!DGdi9rM!|Ot2#0mDVIno4|8O=
zBkLfg!+J<*ry)`<k)q$kk?Pol0Ba7KI*QF5MUj$h;mDRwzDQ}HjU!_n*$&A+ErFYK
z+yN;aCn80^E0TZOtq$*wECat?XAY!7UnzB@R2Tr4tbtCxNNI40!$nHHI~{&ADMdpa
zy}KN}|CZP<E>A;2bVfRgA|;vb@S8~~8pTZpG8)+kxxmpESsK2`;UYzE2~x65C*QO-
z>KilMf}2RmTI%HglN6O@j-E(KF6Sl#SmE%Mj?7!-BnpsniIn7OZZZ|?9R4IyEGm*h
zM@sT3hu<irqb*LpNJ(yW_+MmcyFksK6p|<1?R3;cO7dxki<D-cb@HEc@<mE=mm_yO
z`68vgeNO&<M?UYA-zX)rUXoChvX>o&{~IYCyyocNC}mrE%gGlh13%_)k&-;_@avLL
z6vcO)0+Et@&*372;Uy0LUzctu{;xND!+<4%F2lvpZ=HORvK!=GB_Vmga1({!kU>Z<
zL>_3BCDW0zXoKOB70OMfq9#)6hfAg-h1YWUjZ*S!JNcr^>s_AQtOjp<uaiRI(!u}3
z_d8l|{O|i6UikO@?%(%2>sh~%VEFg_PPUyeHY;oUabz8&Y+e7p-~Ic3_wW0i{mlRO
z{qFzx+V=nP``sTE|IoFkZ+oy&DfPnwzuG-JNcDQuua{HH9!*xG=LD(WVL>WsVX_LH
z8>F@@^y?MXRoFq;u*dv*Wwq(CWHp69vj}?JuUAz=9#2+H9tl#<!>TK<N>(RfS^PD0
zh}r|2JwHg*TIAQmRK}uY6}KQr9fj3YVT+U11=x(me!Z4D1Y7!OkcwL3*XyXMOOjRh
zg+b~pte%Q6lhx0#`KDj5uTH@V9}7|)miqOEYR=MRHTdx$bqUs3#V<=%fhtI?T;|s!
zR55Hftk-hC-c&7Hj(v-;4;H18p1{7v*!P5AZ?3Mw4#I}5@arwrrWM$?q=KrjvWMPU
z4OxkOCiboL>ur^H752fhR{8Z<wFfqPDfSik`J<kU0_<CceXs--wi^3jGgkZc4(bqW
z>2mB_<JUW?scW$B3G9O<s))7N2b;gvuXj<WV1+BNZ=GMiRn1w4eJimKcAJWS68lzR
z-;;hlNfpC(!+Ndv>wdLtJ@yq~AFP*3+JJqlv2TN4zg=C09fS?r=-2zIO&hUq4f9v%
z=kJt;6k^|6?1K$d-c8sC%i84Elhq#B>~+{z<kyF&j3VrN68m6xs<5Z94>sc|zdlSI
zf-PN-eVhIIa5Z%^_HDpESc;0+f_<?0Tl{*OIt44-h<#iAdb*mk75fUY4|cbT--dmg
zuy31R&rrp%-LPKU{rWv>*>>zJ!ai7*O4@;aPhsB<zdlY~g&l+q+v(TGt4%wxZ!`8i
z?bmbFkf*V43--Y#D(^Gc2g`cKuTNHcV6(Sk-?M&ws>*m4`?g^pY`O}24*Os;p7ZN7
z)FIf??bx@=uji?$yRdHu_Q7VUh~3x+o4?zy->*)=3U^}P9>4yenzIM{p2j}d!zz9+
z_C14rd;R(xRSeq=>$T6X&r{3xVc)aZ2b-^w_G903*tg%WKdP?64#I{#@7Etwo1VwM
zUD)@6Usr0#3)r_C`(TTe_eJc3WxeRvO|=I$dk^*<@axM|#sTcxi+!*sRM<<{2b=Md
zUtg&X!ItjBzL))aftva<_U*?$*cuh_3iiR~zv9=|sZ+4R=dtfqzrJ40c@_I!z&_YU
z75^Icy@-9U`Snez7`7YM>vg~Wlv?&W_8q`J*cO%a2KK##eQ)^nZR#rQAZ*w{zrI6l
zI*5HQW8Wda{<Io$2>V{aKG?I$dl>s*S%>}lF0}_X`&I0F)35JQ8E<0WYuE?dr^1e4
zA8f`Ezy7>B1Y7z#_8s->FRH0WvF{D+gT168-oifE{I~r2E9w-i@F4cR?blyZbKb_j
zL)Zs<L&YD%zQfpe%&#9(#jxG5UdR3Vn`+r{?0XaYU`JKbJJ@#w``+>EZ>y`YgRo)m
z`t{>#)4SMr6#L%u>+h-|?_u9t*athIyeF^^mUY6ff1vijX1|Sn@B8&rD&u|ZJBEF*
z(<<x(?1Rntz^|WGhhR&OW8X=?{*jt`68ql4KG?@9;uQA5=AZKGpQ=-^!gsOnL%;sH
zn)4y{y@!3UFID_$>^p&dr~P`dDu(Tb^*ZC%zf#N2VBh=LcgAmA(o~PLgH-4T7<kri
ze50vfpa-GD&iRcinkqUsNKHA3i68lm?=*GCM}t(8Q`iXoK~rVV4^k(gS?B%6Pny~b
zo&6zJe(X1{YAW;NK`QPvW<r0}RE<vtsSD5<pZJa6HFX%e^bCf6>NozQscD}MQr*vD
z>8E~OR}r6KDQx~{e!Y}B1uHy<rJwtCkDBv2mVSh#urezC3oJd4rC<1UuPTP^hV}Z=
zdJ=w#r5|G{EJ!6?U?xAo&<oa+5OxqYtk`-I7BiEdVrGf;BrIVjKf_8`b>;nvnS^D1
zWjzUDvp>hii`J9yA~X2~Cc<i}uuIG&Y{n()NeEl|B?f+NJqf>NCNE$gte%Sa2K!+1
zzp<W#u)<>OyKFrPFDL7b)W_T#tN1I)dK2{+_Xt(YJyIopn=H>j?#<K{?ole~yJS6D
zt>NBWUFF_F_5D6so_^e0DgB3JdG>K{qjqp_tGquZ>oF>Yd#u{SJx*2rDOsL++}o*_
zxF@KvpOf|WYCQK2>JWFIs&_S6o_E|kspH%eRm3mJdS^9@dlz+zdso%+*JOFpaqp%+
z=6;)s|1DYXt{&r_q>8!sP>H`M%QKF9Pj!WRFO~EM^YSzE^2bkRU0n}Q6Y5v8z7});
zZ>ctXP%O7A(W93$%s!>`@?ov`LZz(6kKBA<bpMB=Z1OCneY&M&RIj?r=h1%*P|q~7
zn{)rikQEL1`N5>Q=~j1opt@4K`L68h`jh&NcU37gP@NABFn_D42YOy<&mRn1l_W37
z{rmp?K6;hxM<u(g`&avCI+^tSiKUw9{Gt8ATWLY8sHsc-uC7(}Y~Ax%FTN4D)<Dn%
zehw7NW+E$z@;*yB=wU47i_-jIgD4mE5NX5g6vEKTB|DZ+FSYAn4gH&rW!WsyN4>W>
z@-Dq&-XH(5FUfO%|EMB_%jM$B>Q;`X$!{Xkf_y-K(#dN@hH&{}xt^2P*3pwMF6%pa
zF^-;mD=J@iP$y4|cNEKzQD|ps@&k)>D&K-`a`M`fCmqOlBwK)7ot(P3MH4s3B|pOO
zPyS?E8!H)Hot-@SvTdA|!>_zn9$!MsSFZg1f_1sS+*E)O3f6BWw>p(8!W%ky-N=&x
zRsu0VERtV&_$Pm3E`QKrea9<5e@dQsG=+p1)WgZEO1iK6Aw_0I6sv)LB*e;|NZ0i}
z;4-M*j-Gro-UP^?_*u!)ldp4o0+}lLg^7Rif4p4#d0pC-Jo$Rp{UtrGzmr*m%$7hZ
z3?NVDvnGfKQX$#NlkbG(XLr%R!>L<~v{)>8^3xRmtiJ&eJ!wO}wvfC!K=dSUn4Q;J
zs|yhqO2hJdl_=J8@@gZ8J9*p1bgmWy%mpd>EiyiHTZ%p;Prl|30l!iHJK&>__8-wD
zPX`7l1p<Hvlm=f>ei6uz3@5<*-~(_HoB|($)8Gs^3(kR$z<Ka7_yl|kKGXT({Bsgt
zfG@!XPz>Y;vP^If7z47vSTGJ`gYh5-OaK$XBrq9F0aL*=Fdf_rW`LO>&s>wL*Uy_r
z@)0l}$nSCMFjZD!0T73Ym+OLh;1*CH$WI1gpav)l$^rQaDV4Ir$fH1h0b)65`QQc8
zFM<O=ehFU&<R_**^0U!i5>JC?z&5ZQ6oBPmDUhG{P2?i57)VGw3Kjwd7ExXVHUnA7
zTfsK42CM}S0a?v+z+5m7JObu}EE%FKYgxwQK@PYb^Z|WAKfqr$$zL650|6VL{MDm&
z2aq31<VTY<((*gi+u%OZ_k&sBCHQjWLa?9oKCl|B0c*huFf@;w1n*ryR+%iI?NrzS
zb^`fB023?*kAcU*WRMB&0b@Wq7zOSIcY)y`1>6aSg2o^M9HZ?AkWT>lVNrgZ%v;HA
zAV>y-0Z$+6H~cS=7eH0=s)6c2{z%{%@GRH`c7r`&AJ`9`2QPvH;3e=fcm=!)UIVX#
zH^4z~2ppCWd6UFZ@D_L*90SL}JK$aL9ykHs2Oofw;1rkwrh<;36Bq`Xf@UBJL<9NR
zbv@Vs3c)6@3fuv@QGT1ue>aG1>9U1)0`gpG3>tv4;9C^G2h%`TkO*3U=3q1BKOlbu
zKY{6>H;4o6z`a2BvoNp`6oO4)2xtHr(!cf7x9nN1K^rifMn`}YkP2j{T|xeXU?Ru>
zJ%H@kksubd1tZZL1QJMh06l@5?nSyKhzG5J+gJ3BL<S)Zxl$Syj2J+xTqlQGn`NS;
z<vHJrY}b43rDGsos}J5s=N9A%qy(L;3Ncoeb6K<aZapDy21$uqahTXG4lM^{=7K<Z
zATwD9R0I`3HBbdq29-cn5DuyXadIdK1|gsZs0m~nlX95|iH=5qM{k~1mxRnhJy0Lq
z;-p2&f)NMH;t?lHXt}d4j&%Jdj!gpHfrQkpAQ7|&VvIzB_|WyKOo&WEJMl&*64H^(
zR$br&9UUp5)&+D1()evaX4DU4_R~Qc=m+|OKHzqc3Wfp+G0E!>27&=#5J(1t!5uOi
zcY@(y7?7<)DvtmuU?h;3p8|5hWH26#1DW7%AfY(gkz<ir;2tmrWCN*}1112`n+PU>
zsUYuOZqq?NkZ`&WISaf8B-X_%ULf--^LG>+0SCbw;6?BPcnB;6>%ha{d9WWW0+PQE
z>;b#MBVZSJPUe3eiO0cwFc-)?KLefykAj_`5bOX;!78vFYy(e%t>7uJ32X!#z<RJ2
ztO2V*0aytZgW13x)B>4*8NeJMoy*9Yf*S`TgOEHadkiQiE%jvJk}q(%Si1s9drQC*
zU^!R@!~hdWne;h_{w?<ikxEi|0T3(yJW_j5lJDxsAYCp4aMSJ-$UtR);w7o$=HHmk
z6C#zx#gdkRxOp<lB8N-m%|II60;FNLA<=U?kvzA)3`p9J1kc`(FH<M&p_gYVxD83*
zNaN!2y+B+g1CmBWN<$J@H|k57#EQg+<V*TxPzM|UFM-#=t4{hAWEJolI3)A`CW*t~
zUGNTQ2#$fbz}w(BkX2Amw>Q+f$T}blgo0oo59Xoh$V0j!$R#b0tw2x)lm-Dn2O9VT
z@jLiU=KmW|0*b+x;0w?fd=BmapMg)n$KXS79vlQ8fs^1K@Bugj&VjSwG!WfWK=Or)
z{1jXO((YFvuQ|7i;1c*6Tn4{_tKbUw7W@o;0zU%j_<Qgj_`ykw{0006l)^d#h^3PD
z0Ld4K#qyVd6+n4VPF_95#X*qYkn)~W1yll+K?o2RN~hvhNsIf$OX8uLq{TB*UW0Tk
z5Dsbs8NmDG3)+#62XP=4$lFC*&_>VWDNLdjXbD<?<{%nGfo7m7hy)R!36R&4MxY@`
z1U}FabO16y=}_`y03zM|-sFqhC6+po?-ji~M?nHg8oL#Aaq^@wHx@p+p`twHrIWhI
z>Bz3gKMjODDVIS>ThfknD0%X>a2x0edVm_;xg`NV=nVpgapS7CXxH3q{WCqJ0?&qK
zr{h!8OA?C=y+w4Z=oS>8H4Ad|u(lGmK`6w${9^d&GQZqs=q;mLN4F$b;-wrVAGC{X
zHuH#Ysg&>^xrTX(sx_@3Kw;*EQ{DT%F)3IST3HGuX1!cJjBgmt_PKg!O$le|W6Sfy
zFU`2MV7;Nwl%^Pkr5Nm?QCIix$5UcHFO7~ZWkyfZLyZ}w%<hx)p2nh5=7DMOf>P#o
z;TKAoe^4Id9#He`y<0lH*w=W-(C=y$-9|di53s+R`L+LDVW-Z`J!h4)m69a^X3xob
zXt;ZJ!b?>Wei+{K@i)<E5gj8M!5%Yzvfe7(J>Mr`?%Ff0>Ro-wYNNGiboH2TNgM8o
zKR=FLa$mKw8|qtaSnhefv}sJC4fi0G-pyZL8+Q1WYG|~!9ay!D*=GtiH7;XjqG@yt
zG*`jH-BW;$4=y^E^nJnS_LQ{7y}@4d9cj}&7wAIa+=}nNUpkvMv026yQ`W3IRqtB%
z*0R<s9|r}QW2e%ldmzxXPE9{)9W|hwH43Z7*|O$kG>oq0%>AP29wpT1%?5j3Jb&Td
z|I&>4dkyzEp>>&)CQkk1&RW#P7viu3<xQW=-{JD+;Az+zP{Euzm)_iSDhBm^vv*3R
zXWpO&b0n77Gd?P2Rwe6&Ha|PQ;JxV$R_sMX0uT-NY@aa!ue|@!*8O8CiJ_zwPuNQ4
z(CM`9o(lBr@h^XWeZ++rtF9H2yDFIr(TI7C*7=v;euH*=`<LAwGxRog%-$@1Fhu&b
zW3amU-E_THxO?JJ+M8u|mkJv9J6$+xglMyS8N?^FU!E>H+<k21y$@$LK%<o`&(_-c
z%H{|(V%$@bMxA?Q&d!}ht**D>o|`nL{Jx3Xx*t1i8Q@OzR_Yo%%bN%9#i7nb8-uEv
z!872<9wLWTGiQp#B|Am-4>rF*hPwwM_5HMOURUq#UuaoEh&6hDh}mW)nhQeA(KGc?
z#yz3tv6<N6o@w-AvnM`G7#P~a8jF~r%?mXH@~E*S)Ql5(Ce$30M-BJXqz>O5*m1a0
z+tJjBwfk5WX0ArV_$tiYD>c^EFuxYwxTYDHulEdhk3*U_a?y_cA0GP1(3$b*wk&}Q
zHO=gNeCC{-l%G(i`(4u>@8New!{p0H7xwJ@t!MUKte4xYhGQ8M_dzZ51?n1~)iO`!
z)9dA0X8Bogt+v@{7CvzgQTlz1zCHVvt{+-8txyZ8ZB9T#mTIBMHg(K1)C_lzSK2(T
z<uhZxPFqC{XZ8oxF)Q7NhI<gx9r}vX-F_;Nr78iApEuMsyWXd_is@L-`lOaWe#2R9
zQsXf366F$TH`zLz=wuw5rFHk<u+;GlI&>;mF^;<8C|X|-Xr4zS=BArmD|Ua)J)y~W
zm$Co7ZvydgB+iqopuQP>KYpp((CmIcvtgalgh!u@JU4G*QiROBW976)=62DX*T_7K
zrV&`i41ECqRBCMYe1P$}2k<m(eXdGD@_O0)TG$Vs#*NMV2dL4avH6y0y2m?x-KW9x
z!(JaR^Xc?a*x0PA=wnA?^N)qdmm8bsA4QgLV)l6u3mY`CKDp*!&VRE{WTUIgsfqVw
z8*oo>8n^6$3s2TQ@Uc@u7|~|_W7Ks|Dyq<FNlDG={RgAr`0s97t%%K+Mt)ZO<Lv1@
zt-996KB<X$k$%J71Ewx+>#(NUvjdwr8uYuoiCOm{M!3C++3q2{vA2miR`@$j%uWlC
zr<<59<`Qr2`ASXu?J4NfXj;<s@qO3CyiAR7_pqvRr@mi2__=c9ojziD(ngpK9;WSD
z5oU$OXu79SReSG|E-!3&^ODmRn(ZUZK9B3cwOeWKflsGG%;+llqds$V81aAz^T5N5
zEH%P>3%`WBM@7Z-oYpkD;G1YPCGy(vA(#GU<2m=xsVPxSzq&WF#s#M>B5zHE?YZge
zZtsz@^@zl?%m?wjJ;EGH-SF4Y2*tPAo$h_=Kwd%xM}x7RjW8EV>zs*Yon-TF$>fut
z*0_D!^)}p7v#KSw?L6`2w@+U$sT*mYle+GCTb?QtcCUV-n;Q>|-95?ca`}+V(eM1y
z%c+a~gCouC`S_^yKgZ07IYjI;k>=`0uFYcgI#j=DD99SqoafwsP5n(L_D?nDH!*w9
z!&&Q^Szp}bU*0u);j+NbWr;g)XaP~?5uTxjt$8iX{vj~`qG>owE8IP*OpE`1(%ReR
zO~39KJ5)ns+{4eRFPKvAk5fnGZOU0>?r~=&DO)`qCTuw2ln@9fqRrYkD#kq^t<=ED
zbH7*;{-dM8g#1m=vOs@~HZLo^x(659L#Xb-&#voT>23`U|2sPvi=%1opRd<2>=jYn
z6Yowu8!5{@n2@~bRw3JuUDI8`b_=1d1OKtmnV(Rn+iR8nYeQo`E6K*@ZWqpCbUXPk
zeb@TGZj5d|vt4Z=TZGI1>NO|AWINh^qn^`VxO;xw_HrL)O?mLScbPZY99hWjNE6$d
zJ=rd<jhLQfTMc(lu<QP6hv42hy_2mOw>D2Fp4^S*+SuGNI`Z#gn7&=tGy2TOvF?#r
zbJgRFftoDO>UB`L>2kE52<&qgQNH;At>yQR1F$|AxkLS{+g)cE5$1jZCOm-fk`HC!
z-DXX?aMGxAePP(a9qR5Re`oCVfHwy%B5a)p-Zh{7bpY;sIu8%`(Qr-Q&aW<?!`^CV
z4wa`y{>?rl@$rP0fLi9l#XO_jBlqHZ9R9l16E&t_g**w+;A7M|G>pXwW|bvqx`*@)
z&F*%w$JUPTU$-~0gE?Xey}8HoCHH-=*RXF7xzA%}Y<&lF(GuP@xA@H8maxZ;?`ZZg
zY5QO&b0#vpcB1vobbjvsflqBUDqgWhVZE8PPc)C1v^@}wN_abcX7S{lAs=r<gMgDK
zR(j%+rR+lEP^gJQhu+y!Yd!dKdlYz4Vn$ofbsBHi(m$ZatdBNdANcf8vp02(!bEfQ
zQijEA&2z|b_msK?YjzI&ea71Zt>IWJ<Hba?_A+X`nP|o>!=Q7C=4#=W63xBKFo;*>
zuSNczXb#$_H}_zB>CWb$<z!XvY|a%~r?dG2GTb>EFn{dT_@8@a_N!@i!Ur6_*=TH*
ze*&A`Qv|D5+Ocoiqhps^1Ghf>4)1JsLc?(1Lf!KU2cG)4X_Y$uX=pm%5Pa3yT<`?F
zxhE9v?o{xWU)%qK)t2>kU!jY61`Q*$i&<#}ZQ3<L!`(9u<Ca7%s`pBjLww$EVSn^S
z<E|Cd;1kf}$eVr0<72jLBz(v_zXHeJ+1-p@N!u5@o84FH`NonY^YBXYu{3lQEv-p1
zd#=()g}cWOW<}IaEn1X%yP?ZVA_2{TgXUXkhJVr1e*0g#sMD+O?H(M89c_8z#A{4R
zc!3^Sc5*N4*A9*xH2W0bMfa$}dpazdJ^tM@_D4`FwrKN#0y`=%7BKDZDUoH1lWTQc
z{m3u0?YyJf(`+rRZGFtKt1;zJA9MC<OepDRzP}n1>=)kZW}P+qgT|5m=7u$PrZto9
z8HBfQIX?N)2VrfkmaW}p>HxFCTEf>omGI)vsb_~*4Qzvk^O4^@pYW^lb;HWt*YJi<
zk61i(tsZH7JJ6iHR<9f5p7VFGOdqq`g{+qY_?oC?Of>tHdlFzj-?66QwJLACUNSk^
zJSY9TX9upT*<$az#c6k3*Kki4Y|(l7@Li=V8rMsnPBxpZ!^7@*gfDAf-`1$u=yYA<
zY_d55jTrX?!_)VV>eh0}hc8{%C^guA{aL$dX6Dy{4d1z55<J-4Ds|ms5s$B_RO{6y
z#kXJA=tA9UEcwVPO<L>oK3#LYBzds;n~cmoYB4qVH*du{)qcFLF>A2d;z?R}4`-Ym
zuzB?G%I&6H*Vy2+t`aWR&z!$}_VtpzgUy*z*FEs@;E(xr?tOBgx~}0K2^m<~*L1hO
z=*abw?*^Mks2gsbt;pEN*8c9r6DJ$Q8+uH1OKWYP9KK{d@pXB)xu6hPZG?Gjz23?k
zwO+4Mw)F^m7j$&&kPkH+YOCfO2`T0a8+oP4+`v=iPi3Jo?b!^&==bB<rzh;_eK^pH
zv$nFt{(eNQQ_Zh8FlP7o$1=UAPtK0`y7TohJA-t#y;epa_PUM4zde%32BTB$*Dv=k
zwe}3ipT4b9;m?(H*P_~qW_ipFch46-Slnjw#O>!UGCu1&g;v_Dsb(k9`1^7G$#Y$=
zIm`8ApH%b5!fS&HH9K$8s~D|En1eRyb&Y~FbIK+PKS?t;Z^G?Y(#+T4KKIDVYEx#`
zY_R(L3hP@>Yj2YiX61Vy@3{7_m-Jn}kCL|0tzvj2jgUXj;Oey4j49GPn<tC(7RE)x
zEc=vR+i2Cmj1<|mf!Rakl164GGNG`M{gLQk(dA!f1kGOPo{Ky!I^mbkDnI?@UdrV|
s)iZj`=A@*(d$SkYowWT`H(z;5|9;n@&3Y}v?07<NysOkRdXKdK0jkqH3jhEB

delta 28162
zcmeHwcU)9S)9#$nSs4{G2m%6TlmQ76WdIZ6C}zQciZBEP$toBIGnlp21LiDdOsinT
zh&cz$Ijwnhcg1v{Iziceb^o~c_kH)D_v}8Wx~i+YtE$tPIYWEu&vK_W8qIL98#>Q!
zVXFhJ`*2TBwdfjm_vF**<+e|F*)#Qyp-1Ke)2qw(m?{-?4VW2hZRpjP6BzMUL7~X7
zfuJI&8kG1?$T9}4A<17!yiDc%yO39c-WkwppzX>i6l&14Fnvl4Wb46GzEfF|W`nO`
zfWSm0HlR;#rqK^eQEUNE1#>~mgOZG{l(Ymr(FnTXlKBPDBZDLK15%?Pk4qM^71PiF
zl}|}di6se~k$AC&)kX@1fjoST1T~nX4~x(w42qKZMG#U2?QyFL>IiBDs!vLaPlBob
zC`{#ROZnl^VX=eIh$E~aPou+<HIcDlQ5N89fUg2d`T+<hMRcyQ!XPwo8qz8d_@NXT
zQX8}mXeJm_(9p^Xg(c`iP!rJJP$vEMxIvUrj2r6CNY=*<(I+VsN&4jY*dcnwd01@?
zc@Zc%QUEF$7C&?_%2aP8TB1b-RM8+bNFGMU435yGCMXslGGwuH4W?8!Fg!!!)Q%jW
zo8ZZjBz=T_FgocyjHP`4nqqrTz*D~LhiqS8GkIvl#>OP4DCFi(p+53!5H%kksnDB?
z^@SxR#YCnlS}OKIfgH#KC41w-5;XAx1}av8CkL~o{0IxN0Xe_7#AlhXXYgY#f=O{+
z1YfDx15n}zB!z|RF?xE}7UfGpskz@lDW5@)!V#0KiHeOMpjeCGQu(ovliiVF$tj5#
z07?4PWHQ*%Mxm$<`D;*$OLJSnY(qw}R3IWINvO#Py-f{FhGEpec*Gqs%&@L2R`Aae
zRULAwux~xlfE5xA0Ht!xL8+dE*i;M$g<@lUaReKoTm=lejDQB>kd%k)4~C}T*<Ub>
zJbMmWy610$r=DGn0YsC1o-~k#z;NoAgd}}RN{l|~FdC-_HEJx<!JyUH)Up-^)<iV1
zrM+nKaZob3zoTgCZcwV}zDATs#V16ND|5h8%hy0DWRWx#!@{G>JBWIDsE6e1oW#%_
zfF6chMnz}Q;{fm&mWGVZQUh@=;-vZlN(H@95z&|6$@QC{m^T?0rThV)WT-F7lk2UZ
zUkS7kc#3^hiGGEg@*jfM0?mhERL?;0LLZz$f-Kt!igBB<2DCCLMpu$PN<S<cJQavZ
z#`q6QQ;Y#mtHDc8Q6A_edXx$|MWhdCCD1OQ6!ZF^q;CRBj(mjYRR2p*V_JA;Hy1l~
zCj?Yr87LJP1xlX8gHnNtTCw6#@Z^y_C?-@!4N!8xL+Uzt{gg*@0?h$jmwm<Z3;o2%
z(z<G(1}*)?3T7cg7_Ko9DM@<0!cpqOz!stb8$d~aF(`Rh7x@)I&7_8hM#qFlqoJ5&
z{V>`hwzm|^rL__xlMt2?tr?_G8ypj^*Q6w+jcI~8K%rd-<?5jN<k%Qmz!C$*hN2{D
z(^d>!tbWK~s47gslOexL`JX|tMq%sGCum}l6(Qg$V(mf6z=oihdKm+gHECgSv5K&y
zsD!YjWW9L+;!mDbf&zK20;NGm%Su>mvO->A<rPO>ke#uQ2$9mn#)pTcpw-xzxR?}0
zcn4AbzKv+`JMd&^QcPS@SfoNBELU(~O^}!$&uopX4U520Z3xW}a<644k;kT$lA@1L
zJVI^cjy^dxB?eaMlM_?*Nok6d&SLHQWXy8}`~vhSj4vT4FT%p(lPF$CA*V2ybQR_D
zMi>zvo{|(ZxCyq6zi-+9?9lHW$(|WCFr4cyj`$s*G^O%TKMmAbpje_ahJw<-d>bt8
zmvP`J3ZbAh1MY-~c3uP}yQcLN>1a@6@Rq$qJ6l1Yy0rl))qA$J&@P*<HaC0>6(_+H
zQ1baAC~fWsB>6^(pD*QSN%B-l-Vc-}nNH$eLCJ^OlDq;a)%#~3vEGNEH0jQXydh&3
z5>!DhC@C^fT0RV-LPm^~-(BJdq9dqN&^Llpmgq2R@OQAB((L^Uv>s^7NHG}u!P|g$
zf<DoZC{gbusIj6w7Dyzlkbz8L60OG6qXs^JQnce@;`Ew`0g7kfY4q%g5yyI1a@yeV
zK`|*XRv2{|1KHd1L573H7KJYS?5-#0rgnaDVoYxL;r)I&-@*9S*=9Am^}O+}T;0o)
z3YV@JF;qL!*z|tVj*i9Gf}-zNvm3kr*9SKhPSqYNZq9d!O9(&zY?bSTBSzDoTzzNL
zw)o?+^-+&{nQo41-F0hJ)QYd`lP}8rZDqMT`2(xZoi<kCdbieb^CK&^9lEsr%JjC;
z$s50xR9+Wz-J$TqnNHVwZ}qD%tUPDW@=bg>J^O(B0_JJztGdD|6rRk-)LU6a$qG!h
zoQ{1k_2nio&zipKLZw3C1E&>?tLd)(0<OKljjrcjwQCuL!W$gQ3s)VMXws17nHZ@H
zkmD@sxw#uZ2Zs@tp&~8jAKHX;j7OJMC|W@ZqA14-O$Dj?Fj&mmj55q$<F2lQB3L6c
zIOcERUNr)o2RNz*9iz~GYi}2FuzQeRFApOy&BZD#-PKONC=?E2Rx@{XKX6UKDOq7{
zclC5|jm11OcU3;+vCpR7>ZeHg30iPdWmgW)u+Nd+>fT7%3v!sFo(PWGDa*KMk1Aj=
z!ZHvb1=?2_i?+2=b4IM7rdAnX#7b&v)mw~UHq^>7|1KWLN;lK0T`<_lEfs}WnX6_c
z5Z;53Di?*J<ypG9R=pZt51>Yvzp1-Qjit_m`PB4Qw?~R<Rj@)6cjcrCEWMUid8+~|
z0P(5FN<c<eWL_3pWqw7LZlP7Hu{uzJGD3lF#;gQ+ON^P9rB->vn5A24)q$17kd~#;
zE5}x1B@jM?u$y22XW_wBX6aU1bqVG~7ojeHGk4{nDy+mxtK3$FdDTW9Rw)W(88*6?
z2UnF9)YdA;R%Io~dQ(-Qh(wmqwaVaXEZthGWYt)KwN`x<3xuoC47F`uoq5@4mA$L8
zbdaUhS%HmK{RvBj8&t|-<hZMSuws!vg0br15~m{5)%oBkyn?3c4LCREQ`=kJ5c8JC
zs8Sf&J;BkyPz&z<VZsXPXqE1!tfY=sorLA71@bT^F-*3Bb7ejj-YO33oFApsI;5z#
z;EWjt1~}3eLwBquORuL@Ha24g^|b0JEKxL4e-Uh33QqKbEWHA*jZlt!vcihp_8XT7
zjx>K^G$dDp^J9B3R39Vd3c1*_1$L2E;4r)~K>C4e!#<mMt5+gLr3Ee3b#TpTpet)y
zu!4qKbsRPsFJxmRH}Nn6BiV#0a#PAeEKS{&H7!{|BdxlJr9#mR`W1v`7K3x9FeuMi
zvUEGGT7}h=Y(g2-;0cZ@NA$3Q<btC}m1U#h@e3(W7|_awwOK)9tx8{;%=0nxR&PRz
z+(AVM>nCtj5#|nxx?#<yE=Qh?yE+A&Xf(p3-Uf~uLD$0Q*VZiEUaM?j!wT%R>Qoy!
z6r-)&mFsMnmqx4l1fic05uGh7&}h{&Z50Y%p$0PZEI1lM!T?ZLts_T^?9hQDJA{y{
zv%vKLCk{5}x(Y>*FxWDXB2UT*gY6JFs!trQpTN;1K^ZK0(e*^zF+kw+Mu`(5pn3+b
zhcMv$>Wi%!39%Rjjs~w--#&2dz?ESf>{B<8rv?qG-rzbR4=V+@b>L_Upd4a&^P47h
zn?*x$5Tk1_twS5K5@)S4ry=ul(W>twPqY|as;t|H6}V`XeH*b7ko-o>%T=rT+6a3C
z8;L;?ZpR8-wd!qlatx_Yp4&06W?Ho~R$uBUxCc`+z|rm^hWR8oa!NrXUi}FijVa{S
zc2_oS!qVNe>T6A8-)OVwg{7Hd4;78O@{&FCa@Q&o9a*}&R(--zoLa(aqppg2sn0lJ
zGIa!pb-!+NBP3b~;=+dR>Oycd+{Bsn5gc_H0tc5}oS2uVR+Weq-;117?L{g`m})i%
zXoy@)H4I!QlB<f4>PEV1OBdOe!p83EG2pt0je;u&AH_y7I#vF}v60r^s^Lhr6;cP0
zYR7zRyw%2-g5Px20pLWRsMhh|D3tIJqx@VmR?=LnHpL8~0Et0}{Tp`xoLB%op{nGr
zQ1lU+8;Ddpwg(PuLrN>S@)oHOA-5eu(uIw*_f{`Js*PN?>K-@`_SxB6UCUD(jA9fc
zz@Z^bmeE+)=Xo+OKdt(!q#}$oRVZBQ#P(>s)f<qa?!f3o@4f=pT4<oq+Fk96=MEY;
z93yWNz;*k^9Rf!SCuU@0cU48GwPAZ2d#k!2)q;(5^HwiGipH-H9rYb>_@6ioG)o`3
zE(AiE;KR~eYE?%dL?wtqEyTE$(2aeOqKFC2sMmt)D^x-T8DZ^^1_8!(e{jgA1~8Qt
z`O;3TdH|u9u#MD)DNTi09fVXXC<^mfwF;b|p}vC@St!nLSAV&3G^L#4&q~^8)x{7}
zWHDPBc^DyVG%_#~Y}}P0Em%Q-R=op4sstn0L(rg>#Q3?l6yt%1Gpq_j!I8PxYGC{s
za2UFzY3^Z!GQ^;(FiKp&VSm9cGyy484<*ReMc^<1NDKQV^_qteF%P8LK@JNVVc>%c
z0*ASe1>sF=R?<$Z9v&bYiDx18j_(|v<eH*W#eN;_=B^%wB<3VJY=@_&w#=(Nf(l`C
z>L;a5AS-CERSyi5!@{|^tCxV225EbD<)c8B-a)Hw0F#nX5o~YjVFZT4C_Yx)0QcRI
z8akot>v^j~kfI3Tp%}H!1xL|F1*r9`j(K&|DvjE+^p09}ON<aPmNYCzgQMEvvXh6=
zw=9a;dvMg0xDsmcahDYFe1;Ag3{Gs0xb@&D4B`gy1swG%7JIBqUO}{jss|&k6dOEN
zW9H<8qXOa-<T{FZg0*TVa9B`~NA~H#iT={+vyeDpzFb0z3_ux}TD_B417d{v5(JL&
z#6^1wILYuj?&<^JDBj3J{~2`_^Dy~QPAhSouuF{sM{dA<Ebj%KS$cP^^3Tq!pu1Mx
z8p|Wa7kO}TSr_KjL#w_7A!Y@+h_$+QS5XBM1Y1`KIJ7KI7iDf&;mP+-SC$^ERae70
zVUIkFO>B8uaAbTr!KAt1#L-Q`C;~^ui(|b~cUnB~kfZK|6a@(p$GFYx&b)eR)ej+b
zg%FQ5cJ6BP9&#KpwAG!#kvYOhRWAkCN2nH^srn4AqcDZq2P+h)MC>Ky(qLB7ORKIF
zqEH|*;!INZ3lZkXYzWD9Jl$aQ{SJ<%kzkJ6zo(doh$9g5Bu-p6u7Q&#DV{9q_mbBL
z*rDv#i+P1=)wvKNuoSuW?rM|Xvf)%&JUD~|Psk{sKKLz<K62FV!_xa|RmOdV8PeBV
z)fuTaY$Q@VQrNkWy8SJ;Za-Nz2q{r-Gg4Ssq4)k<u1|j~v4SiMDY2GwNCgQp>o7TY
z5K>YtNQrtMkP_?j86eBXBPG^%4yiWGC#-qdaN6If*)XKqvd{elk*M`v5Fu0P6T!S9
zw8~)-EImT2(&>f0Ji=SG7%8-j)I+5DQcB%1QtSg^KT%Bw*F)6!mYNVHl~NW*vGho-
zszx+zdMK=nh-M{`T6G=-H0Fh#Q<jNg=}}sxUkob%85+Y%qVPx)0|%iZOiESdfizit
z+IuSl2C{-^t#ZmhRub)HFjENMb|{pfwE((G(=y=k5U${W+7h(}rK>ch^0vS)0G|GY
zizt<AB(ee}9#4A01=>zQ4Pe3v7g4In0U$+3fG(mWcOnKCQ7VTSCFnH+Rj`{e)&^=G
z>x7W&OHy1!%K|Nl!9|pKY#zc@no_G+3x$g)wTeYvs1GZt&>CiwaFwQ14vV0dpn%CN
zTtvxCEH}bcnvwyS(Lw{5cM2uDInWy0k3ta&P^ta^UHyf-NU51Hfam~8{v)bn3sY;F
zlNQF5pdBS?6RpUshFIH@YpGK15Gl7bEz3F#sfoo!p%@`)jRYmjG61?Vg!_*v)jmeb
zFHOs^4MS?O-9wBB{?uKQC9NM(74l{PRNE{`k0^P@h_cV9ZGEhf9Z7hAE}~Q-2O#-8
zfG(m+_9C{Xfw+YL<t`!yS7~YleicBq<N~C(2B3>5MPWTa@(lo8KcbYsQOFf3)t85t
z0fGn#p@A)+q_|b0+d%0mO(}o7AQdT9v_s<mjgnqIKy;U+ze{Srlt7#i`=Fo(iU9KP
z1kez83s6t|36LRw0dx^1{sTbc`7=NlQIdZl1{YDPkAsl(R0bqS;TPN}gI>MUMU)hb
zL8-xNpp;czqV!6hcoW>nqnZ+LMnYUfsXhxyZV5{D*n(2M^`(4flvc4SDLOzv7tu1z
zC#|M|s`ZrAeWYBXr0plsmXe$(RU07jL@C);qJff}D3xz7(T)=B0*e0?U2&s!yL0Fn
zs<5Y|&__}TmH7Uk<&Yl*N(Ev-=^{!E#DbD2PLdO)`Vu9cD3wc=`2VCBnUt3zDGreo
ze?%#;!;w!aBP2bdlpHDXKcbX13O6z&1GE9?DoKA8^)M|8>m>nEC9_Htr|c$4`frp}
z@+7@~qolG~(j!XAEx3_c+a!LwM1SS*N`e%2&`qKo8ws<>*aMQ3C?yX{d}&J69+u=p
zDS1TV|BaH$QAv*|b@OqF2Q>&4osa}Xsi9M#Bswk0iBj^6M9)fcqEz7pNq$kHm!$mC
zl*Uo9lz&aizs89xnc}+uTDVH{)WA)tKxs-V%_B)plnj3&@kA;4RN_lh()&%4|0b^_
z&m{p-Qz$4&>wke7{wEruF=Ye?$cOThBSdNHR|O?stAXNwgQ5oR#t_hcPTQ6pC|yKp
ziaLOjs3~sL6)vDufh!3mN_;bkFHK4ACdo<nKOYv+|No0mi-H4xdsy^<RsVfjL=gG|
zboCeRBBkyN1Becg<UgYSeOjb3{@<rXVV(Hz)8c=h7R9yVzfX%|9Ox;MmeBt`E&lgu
zQ5+Hfw-0^)zn>Nd{LeovZZ#j}TE=fh=!1a6wU(~i_4;_X?BL&H$0hdl?U+{nz|KF{
zm<46kIr_X|iEmc=yBEgG{B9f%Z1B);p(<0qQn%6g-kdJ;@9(I@rj9l<_*8kme9$lZ
z`>t@=+v#|V+IeQn?dtbQtG(PYY`1Hq^E&-+buP5H`o)mDH#p78^GUSdU%PkJD~zwd
zukG#7RrNot6~Ev4Quzz!ZUwR5gnL=%ceTELos>9Z_KX@u6)rz?xikCS!U?Azy#4jy
z?8470v#!T8>yj~vcIKBV9NRZa^T(gz<9aR~^kH`9+3W6p@3QACEMPuk%nVVhT}~G4
z+;#MfxBc)ALHy0@7xlfLG>Gle@}A|!p7Szt2k_=$krg{OS(4vi)q{gw%5(|q>hjp-
zz2fnLZLcf){xKT1a0<~ndVH6!vW2eeqF&YCT%*^GsYl<WmpnXwxt(HDc+4=x(`&<4
zcPw+U@N;BEpA|REH@W}0Vff*tz3(@=6t&B5K~MX%du#WYt>`v@y?}M6uJ7)1u$A$%
zc6Qc$|A+g#ee6-7sehtn+%gmU<jS*imfqtcK26x3x^drE>y@L<dLO&-pxJxJ;qOk>
zkKS?RZT{|Jm?K+PSvC!{Y_g5#Gn*-vMrrCB_v=mAIWRNu*!}HcyDLmi>T{blXdSd>
zS%GTG=p6G??O(2lp4t4#o!XVVI=pm0T#(Q=Xvodqof@%)W6ca@lb$UOtUs<@l*fv7
zrwv!O`pmYCulu2J)$;SY)BCurHfw^5Iy&ASKi78P^zxq<sdi0`iaPRTk@u?;>ly|2
z$ZayElyy~0Tc;k{Et6k0_+WUxSCxIHTYP4Y?2#MyvS!|vPrv3poHt_Ez2f!ObA2Pt
zJsjp+W_q5VbmjG!_>fgTh2wlrTCG@C=J_1fVVs%4by4=>#KD#93ZrZE;7juRee{?$
zF5s7)<(03tm`%$vs<~`e`ntp|VTC>u(yR}K2EUzS-h9YxlLliBnO58D{Nla%rL@?y
z)k|CV%(8F&36rmc)_T9UYn9o{&zG-Tl%mKsUNDiZ|5$HKrg10piv@pfzib}fD|ySd
z<++u075!~etdAd`RX<>H=Y(Ao!`Ww8H`FtJc5&Pj)y3z2T}I8YPj1-hrK+%m9m)G}
zyTOo{%=7-0v_;Vi&dxRsF+W%5u6026pZ@#wk3tq@cez%5P<|xM1i5ETN?SL7!>n;F
z=eIPp81?JQNu8^-aVl9-M&nvP_0WQGM`t~4J>JCquH&Tamgb`ad}|Ji3d<`qukF;W
z8?SyGv2tGLT@J(d)?gdPn;Aalym+8!IBA`7(TfFD%UZ2&nlW+YgJA21=X$BK&aWvK
z+`U_#@uz<CM|WN8F>l&}z~3e;{I&R)|D%Pkx^((-NzrgrDeG#Mw(d-&Y5`s~X5L=F
zKZ>s2*YA(1(f+rGoHc!yd9QtoR<``GQ^_5!t_j(1K5p>y#IG$Lten~PUFwZzw;!Kz
zFmlMhKF{?U3!PwQh;=wLcSm4!&Y9RUUoN)O3@FLjyysR@--O9a`b}OE*df4pdHM9D
zk9K3*UOAo8wUNi8PeJ>KaQ@xzRPJ`LPoqKQnwGN8ytH*e^U}|L$?P=a!p>*=9xk>V
za?GW{liLSYpAKsGx~|bj+iKNTrKuNcXPFl*s%-S(i1X<13RgnMuSv7(Vz#Zq$d~ph
z518>pGs9i&&|PD1jye3yZkgo{Zba7mhpk;7Re3uiv*l%zb2)pCe%!p<Z28i5HClfj
zcENA4Q_tt^k8#Ea>fhg>uHv!YYq)PI>nuuJH}OWTqQt{>7jId6yUxHDj=6^PM3=DP
z9z8$x^qsK9YUPJI&MzL0E&kp7`0v(R=N6@oO114%?7ie=O2N_@`+n=5-t`&VGtrE7
z7_H;1SkCBRHZ0SaeFkUE0>=ciMp?#e!x$ZB%RYd+3NCc4j;qVoj16X)lZ=`1I2~7?
z^&A(>JSH2nJ>VKL_4r`+1YF#B9cRb#!DUY|W>yn)ToV>EA(*wDYRpc7(=hXi!R#+^
zBPZ%OM|KQc?lfbj$<%R9EG;vbg-ox+Ze_OPT$o)}Ff*EA%%*1PxMr*v+)i*llXRRr
z%bFC-qGuYj7vMaZ=j32!Hp`eToUG%#*;8;u;5tmvaXu_(3jAa651cOxoC^PD!@sFI
z&Yyh%cNJXdG#%HHt(gY@=D@${I<7VAIUWAZg@51zn0f~M0~a?##|5%{aM?Wko2kQ3
zXJcl<zijvit^+fl1^>W}oTcMBvSZ+KbKoD-ah+KjgMagk*-da=ncZyoHy{4Z)^Xig
zF}R)JeCFu5V3sup{w;ui;CeF8x$tix{F|%edb6kCiokW?bzCUR;o;vR_y?{Z3(SUp
zi{W3kjtgTSz+D9wnxo^w*_s^qho5{J&(q=8z&+=|zoqaGTohB!hkxMW=Igi^mJcp_
z8T?zI;|8&q1@Lb<`~w%q%ooBxa3dG$xOjF9T<!|^w@Ak&vb06;ZzcQ#m(1)I!@pJV
zZ?TR`WyRojg7aCT<A$=VCGc-G`~#Q9Jn{0|EEoPQ)p5hwQ*cG#IxN$1BU#Qe__qfB
zfitkc<?wGU{9CT$Mzas#u7V3)q2tD~H7nrXI{3Fz$Bkz_SHi#b@DJQXrd|dAz{Rc7
zaak-MT=oX|w_3+dW-+Vb-$wWcZYnd+g@52i=IXfV>=?M*P4I7xj+@ES*1*3!_y>+L
zyS4CdGyGet<L0npa67^ItkZEk%UTEjw!lAdIm~lC{M!ou*6X<W>?yb+a2+=2xP>fd
z1N_?t|G+I~fg9o9cKEkZ$1P<az+D9wx=F_^XKOaWzhB{Bo{n3|dgj5u9q<p_YNp-{
z|G>p<)^TfCKDg|i@NbKbTgPIyz`uO>2W|s1-wOZ0johl^HnC&iatq+!HXXN_rEP<M
zyWk(Vt;}va{M!xxw(Gd<tQg!*a6Z54xE(C(SNOLF{(;M9o;%>*Uih~|$L(TI!4-k)
zuv5qFVL3bD-#+*UZXXNGhkyIwU%rkjWFNp?1s7VN;|{Vl1@NyB{_WCnhgr{E@b3Wp
z19z0Ecf&t$al3WgF_sT5`yl+=qvKAnm_6|C5c~soika_)f8a*$)p2LoF>twu;om+T
zcaEj)gMUZhAGiz5Za@4x3jg-&xJ#@U+)i*lg*xsE%PNF_Meq+?G4nhC|Bk`G13K<H
zdkU@yT!(`??k3AQ2>*`5KXA8M;34>T0{$J+ad+7Va96>F9@cU9*_y-f?<D*?qT?R2
zo=4!{DfkEOF;gFff8gSd>bR#YA6)in_*bOkeq%93@b3)#1NVZNAA^73Mjq2~uh=ng
zxo6?uaUJ)Dr5%TV=inc>-<jPB_;()uozQXbSuwbs;CxQ%xIbCeN%(gG{(<|zJWs*D
zi}3H1j{C@-f-3^o;k1tX%yLe{zf15B+*cNO2L4@!e`j<`j$<Wfda$ctL(l4zWjMC>
zY!8-s1s<N$DODWnb*=~VxC$4+mg89Y^F7!TuyN;gN;Ss{z-AZ2$qPDV1&$58(1W$T
z1~0)HbF9|I9_%l$BQNTdl{t1CZ0>dVc}b_N%CYoIJy-~Swtn-Hj;qe>F2m8AaP+c{
zGhxNxc7pS{qT_0^tSfNz790g<&OEQe(c5tJs*bZ@Pr(&|>rgCggvD_54jct%%>u8%
z(YtW;ny?Xqy9zG!y08&mM@Qa+n>U1w@J2A#fNjRTAyeNB<{Ggu-0fIC?u}X1Tfwvi
z;%?6han~^O+rgXzOT^ug9mBmTv%M2cn;-7Z>>Tbc%<gV5=gLOo-i#IF?#7(%1=F^N
zy9c|AyC?I!AIy2NnYeqir?@v~{ttp_!^2(6-r(-b0v`r*erzf3{_F$pEm-GA!L-%k
z-imRLgK49~y$#!pdjL~E3Fg|eFx&%KKJM*U)u+L<#o^wb72@83nLon-e2t!YCTwue
zg1Ju2_P1c#-f-{2&f(sb**y>Dy0Ou?cW1@8_h3#hf@x#JJ%ruGy(ja08O-%!GjZ?D
zp5oqz`M(OLEe-d+><#YySm5hmu0LCfd)U?wuQA5@zv;w2y)j~$ZjIR4kDpZZ7V8(r
zy|qv_H`-eJZ7rp#7d}Ch$D2s{3RwO-;$c;{2E9AZsjTqA!+5Lh+X~99XFonr3Z=`l
zsvj+sE9{uV$1z-`t(!kOs#GWZ@fSbL_U&-|;Y!)^@?Ym2YRM1gxJAkbt@%ny?xixj
z-HtCxZkAG&(*>`(`9#bJ;}PA&)+c~g+1mNtKCb*k7=l+=8T#J*mvUSKW%WKVv=Uj6
zz_GSwjgTm-`hUE+Da$XB{t$j#7>~W#*P!_FRlMlY(GQ=Q@jv~&m2k;C1&Lm-(d94c
z&`YJ=f&@PwgN%3zv!^6$E$PwAC~ryDM$)4<T{eOYFOmW!MS9J(51@+LNiuq~wO^9y
zAR|NQ1!AEj>i`)wik?&)2I%T6m8Fk7iv<aOye7#if}bGC==HnsB9lIcQ}pTTCMi}z
z8b6&9F1()?qC%gD=|@K7Q4dL01!*5i77Q5~NS{sX0OTdT(#QYwr)~6eJmFnlFG)sG
zHnhi$yzDIrYapG5G<hli4uC$e#ZWD{LM1)wj)6#%=hUUtFnx3y0Fa^mB|Um~=Le9X
zVUiwwh=~B8Z%~9wiu69OB|uk%B%{w08bP8^=p~sY__mTPQj%GL4+N+V`jG;4VQqkZ
zMnw8#D9NmWb^z(qj}+)dw!#JsMS+Ba1)=zpGE$^U;w2e{l=MiJAj#??O<|>q>3eJZ
zPk-bm$ZSEABv~H0j%x&2hpT+^R2OHhjjIix6U0^L^Mbe#14WPCf;s~9cGU!+BP419
zW`H?R3$Oqz0V|+3PzERq&^zcCz)Rp2@EUjnyaj#--U07{KY%}hzkm-w3Gk6q@Rd7q
z=3EB<rXyF^FbT3Lz*JxwFddiy%miiu444hf0p<ccFb|jyEC3b)i-5(z5@0E?99RLY
z1V#b$yC9mtI{-Jp9iaEBn7{`5k)beaDX=yGy+(EdoPjz(U4VX8kdC~2pbr6h`_F^V
z1}-Cg1-J^(51uvyXOTV!oCoM93nu~kZ9@^T1K0xO0dp1T)=fyP2Q~o7z-k~DSO=^}
zWe51gE?o8c`A8N3i-5(zQeYXd99RLY1jh4kI&swvQAkDuF#t{NK|m}J2gCyjKoVdJ
z(72*;R3B&n&|7nQgFYN-`q9E;U>?%*fgFH-A+ZHC7r2P@1z;zT4-^2~Xr!kgkqQg}
zXgUu9icsJfa2%i?dTjzW0BeA?z;s{?FcugGj08pjm^X?cz)&C!NCr{>U%($|2G{|O
zfhIsBDnUQ5SO8`#a2V-bz;=M9Vmy!lU_%mqxb+p3rc)EZ9?$?MAUX-00?q(ufpfqG
z;39AdxB^@Sih*mub>IeYlPtak+y?FdcY%Arec&PR2zU%U0iFWSfZu@Uzzg6d@CtYh
zya8qaGl5_r1V{y10<D17KpVgb&;Yw(ykQS+dx8BxA@D1Z1oVYMKY&)zUI4AcAwUq|
z3p5An0Of&-z%1zY0eS*$fdHT>a0q$EKqa6uz#xkRIssj%$7Ul@8>j{B1NH-jKqAl_
z@By?y9e@@!9nc;aipquov@N6qw3=>%d?7Fu7!3>n{D2mKE6@?>0E~d{V4y3R+#P}l
zpesOWJrD>u0G)w$fZS;5G#Nvc$&@N5<VK-pTp0=cq#&-2KRrnFho~pe9q0&96x{(g
zfV#CAD0ML{6mtQJCUqmN{+9g0Zk)Hl0?G0K#mNk)0#pJj0u=ybpfXSss0LI8On~Y@
z4S@7%dn6g9Nyi+Zax(y$FJS<69L0<J#2>H$tf`~?kZ=a-0JcCwfK~!p5ol#-05}4T
z0DGVbAWt?8(iBf8fbyFHzJMp-0k{C}0Cf_ry3M3CQ5po^G*P{fkVgZJX|l5Pxb6?0
zhG1`ih9QmrZUA)(c|)B@9Y~!^LzFs>MiO-*bv`xJ2_R#r<GV<d=28!|FN_YVycf_9
z=nI4b!vI=#XynjH3I_%NsX#ms3y_S)eKZgS!~g?<K|mZZ7)SyVfJA`GCIczJP{1%1
zx5>Z+U=lD67z2z1(t#1caEXov%>YILWcXNs%8dsm0;HD-WC2rv>A*CA0W@6afX)UU
z1K9wgVh|o#s9&l7?f|!e>%cYOJa7)k0hR;50`q{gz!_jQK=RYTN#F#q7&s0b0~P@*
zfhE8~fV%l8a0FNe940q*A#n&;2W$oo0tbK{Kq0Uf*bNi_`M^$KJFpGd3Ty%LfLvfc
zARDz5X)<5|K#h}OT3`tv8?y}U3qs0V0jvTjEn80M(mZ*)37`tr02_e~z<PijSPM`d
zHA*0TqEv>`WE43m8)}e+OQeh+@nirMqCB|^$WRI`MX9v>pJ^&f5hl585Xs2MJ=Fhl
zfqf8ArTYP@SeBEb+z81CvOz?BfTB`z>N+w~)|2a@akC$wem@0Jq!v*BQzc{>RYU`;
zbOFjc0?_y%Ii)WF&cFrWB2Wxmk<ynz>jPJT8^A5#Ch!P&2zUVZfxEyx-~rkf76(^O
zT(Mn1odJ3Zpr-*lpb-!cy@sH)H%>s>3e*Cq1(*Xhff_({pej%WpnXvZe1`rfpal2;
zL;!yQv_2UA#O*!s4tN3l4qOM`0>1&HfM>uf;0^E^cnOg1bAaT;6a54D2vEgefEK`4
zfF5l)pbS78Hf`)>0Tn%{RX~Dvdo@4}mjnF;Fajt|ly>@RfGJ=Ckf)S314vFFk1YXP
zz#6CxP>5|nDH08U`aoTv9?%%DppT@~D20{6N#Ua~QHUInrpQn}J&-j8904bQ40sAT
zp##$G0Ugi|2n5;!0YDp|HP8xZ3A6zG0Y88qceDoFd;ogx@dmsAPrw7{26P6x0G$9b
zkQyWz89-E)he1wZ?*w#(+)~n`d}n~_qUWq0fLw;gf`L4xzLpEpV+1uq192K?FzDY5
zfsFFWD5{K%q6SIUACw;I`T?OpZ=erA4|`!iUIK2o?AMC4eDmHre(S?s=bWlxW0B8n
zG2;3*b!h6~BF>UZ$g#ifIY9r+f31>h>fr3q6g9l!Z}!CpxKI4uew?`l4V?<myW-W@
ze$+{Awvuylz<<!I!8aiV8Uq!fFzQKh+s;Ran396Cpzw+B2Zd(;S;Hu*0!`7lHb&76
zd-}Z?*?RFxB`4<yMNMm?nV**y4HWG(;j8rL%C?nH4wO%XQF49ZlY=`3PZ{Bxhz$AA
z8sxwP2WO9Orw+=e$sos-KRbytH#my{k&ii)&#!?(QwOJ}4$YbhCnCar`J@}<xWKb!
z*fP)@MOQu(2RY5CIXtsTrz^^*<_NVlb#TMjFDsUj&(AR+%hkb!0wtfgC?BPR9I_rc
z@>z=VAvwq)kI}*MX^iqQJIEp9kRzYhC?CWl)FyNY4OqH_BX|rrgGXuz{U9IeD4*6N
z6@o|dv5ryF`8~*Sc5o+Oe;&CXlp%-E&UX_G;xRxNPohyjt<I&{Pkco|`D{t~%pfI4
z;h|yv&v3(RDcaJRcqSPQ#``vVFl|Cxj7wK|<cg;;Bfe>WuDx=B5kIOwXQo_j#Ak!I
zl#l-^tmgf`U;9}nP+3z45AtV_dTtnJ<|d!0__1qW^Ws~RZV5rckigT3TKJHV5#6lc
zDo6VlbC5$r1v#&c_#l*3)-KOShjGqI$MXCF@RsuNmg(26tDFqiq@e^&C=4P03jA3r
zak>Kkj7n6gICn4#$j5k1Te_wD=aFZ+3k5KMvF29fyA0r*E#(s~2PD?>@vBhTL(uRf
zBjy_OO9qe;mG}Z^D*Y<)FNxPy=8eL+R`ohm7CxJNJMwb=>+0(c-pDaV4H&u<f#S-1
zLO4PoABO3*seS0<4*n^U2HKF1#VqF=JE_2CZv=9%f>7(dtMGeK*7E0NB@JakRlZ^b
zH07f+$L8tJH1_P6FL)v>0q3joei87sVs&xVnV)mKR$|=F3W5gKEG*_V_-Uv^?p=O=
z1Q(>t!rG#T`SMYfv1JclzP)kxU=(x10)b-kVV1|-zAkl$&^Hq*6xPx_6TUB%m5;#;
z*^&0!+v+bJp&>aapP<=%mEv69<2EyuoU7=$B2&$;M_C$TNA#Stn|yX>_=$2m%NWOh
zMjaGjVVsC-+usJClLxY%neYygXkR|pbBCtP%F1UBzC~GAv8;RoXymPfSzETOb^czf
ze@%V_%38{2efDZt=r(#rxARh2bSy%i7m0w%r=9+1*Y`E!zd%DNQZv3?6jw{BH|Hax
zAY5g_&m-E~f<FyvDW3t_`F>|ZEA`Hj?+s11<SnD2IoFc!6wO7t$)|Bnj+ni9_qAiU
zp-HnET_GRrxzB$7HSg|b?T|ye5f(jW#XqMy7FqE&F=*|9l^C?{{hxm=nGyDfPzM%B
zjJewU;21c*w6?e&mkn|5cIub4hoM0e6B@tQ=9f_&@^PZ&7v8-#uH1bWp$=hlbhP1L
z$6%dEw&Jw|(E+b*#7%NyIlDz2mTy@t*yZHliH8$g;X8l~Z|k;w(`U8Adq%-x_+nIt
zpMtWM^3k0ihK+r5zy2a~Xkc}9aB@*Rufy*j2s`9MKYN}S|Gwl^xBXJ>nBPWq`AUPJ
zA)i0`IhM;ysMG2iG+f2q&AKk%2O3JO1T#oeK8f^sM6d2Qo9}N0O^hTOW&!p1TZ7<>
ze1@r2ox64StLxAVa}(pTqMo>v_2L#>Z}aEk1ms8&+gP8sk3}m14fy`Cs6#%!G|2J5
zGV|jHYY6rTGhRM9we`X9@KX(cPeP8nI3og#`HfT-r|=3dyv~KJJsbFL@k8mU0ju*5
zS7B$`^X4_;KcTGUYJ3u|hJCr{sq6aGyj#zeTw`f-Y1Ei+8iyVm+?XE~2TdF~DIAu!
z+kNLz)5kB3U<W-QA*QSezlAh~#nstTJ_51RsMy^%Hg8=IMG6NL>)P`{Sbmj`_I&hU
zY!dRZo8=v97}^GQ9RW?O+BBeA+Vf{gGtZuHnhu(8&-YIQJ#Nn@jD*Yb!JVxRfAaJ_
zkvK^xDRhc_wCC%L6P+42_%Kh(!SD&t@D9n}>NHWopim9JBp%ht=Y+n9c<}U(%;D{Y
zLc%kfe3EG2pgUckc5dV^<Oo~K91Wk5!kJj3=4Be;YpIONWf$G+=WLnr-I|>mzD@$V
z`GAHG8jiNFY50T$(EA!bFPSsp7bkF5%9k2`F9|<t_#2}TY55@73dQf{g#20|QL+XP
zZ6*$U#Y9wB-+}i_gr<DbYmJLjTJBwS;)T>OG+R0FGlp@dWt|mW9QbLZD<7`fI<3XL
zU4^Y_Kf=tU2|mz)x2NEyI`B70Q$D7(uAz<H@6T;$EaDlCx+U9zuabm#$p^g-U*54@
z*v6C5QoEQF@=>t4Z--3`$+6ub<TyLvqv$CIzAu%PPm?uk@Ywd&jCpmXvane`Z}!5o
zp;zzM>bU89tyLZQ^(bp8pHMq`#ldRV%1&+mUBlOrzeBalXX3uDSaV?X`H~Kj20BST
zmN#U5pSQNLUBo9jioiby1|OQtxm(Jo_jV1hbh*ibzM><-2ow9xOo;*T31Rz}?emAd
zUEYCjpYpH8#F1s@CLaL&dPnAr9HWQgGl;O7%0~fTvfO{8>$XEH1TTdgsVpCqij74c
zb)wKjg(&<mU!G+HT=>^RI6+Supw`$Z<l}`+rVX?GQhbV@)acO^m0fh<pQpkV`GDaH
z_q?C!*i30?(GvO6g|``kZu!YT#T1keEnbpS-px9H$}6dMv@6Bg?dLu5^Bl>ef9XZh
z*KaEfUvU@$Ce9iYYivV58!k@&7%paFNx7@V8var3Pcmr)VF@vln*CPjpR1ka54&5~
zc;z0Jr?A|U|5z`7wvK+2!xD^TXPN((xXCTZw#zHohIFiCa;Dt;OV7Dj_1u1LzkC98
z(wB85m+wufFZ90fcp`fyRw=C3Vyz}BEJRYPDh!i<x-Q!wQ_)Zp6-J}nIg*Hv8o^mv
z%4bL$oBq}7^^`j!r2&ZD6E!Ru0rTYpyPt3JSz2Rz_eS3*zz^3{;Zp)^eTlMiL@a+;
zhcIJhJLQ<kTink>^TYkYi9U^0)be|2d;H0y!j%2_l#$~kDDe$O;nC;kyX;Sl{x+he
ztxVpi<S@9&CwRxr+ig2DZ0`YtQu<INAF&-c$z)o^G5ZwAk)Fu$+~3!LP~!1#m;qyS
zmLI>K_(f{|2=NR3_!6R){=7p5oR`ns?z!)!YQe1+Vs|;wcOLTT+rgbLb_jiY?5@<2
z7#SN{@FOy~NagmH{DTZU%A~d8okye2v#t3^P`3tcgx4<_$-BF++o-JkMzBu!L?fTH
zd^huY%I2Ws^jPF7KEs5z;ZKi-J@OgOrmCJ+K~`grDLD^^W_TjPI}y}sfrl@jpoBE5
z@ds!-!>pz~X;vHFatv11pFF-}JI!mucNzmr&FuL_L@g@v&#8obV)gu-dV4#t)$dRz
zJshJ~FSOxp#&VICkI*VUqh^>F%~anUpSKPg()S?m+wjZA!fSjqxJ*<Pz-wo6jx=>D
zAvq2r^8h}HXu|-06{w|rPWa#to_}>1*u_F}AI&-1&&?F~l8^wt(s%?SDnNWrwHeYb
zFR4a5dMa<~;7OlFe*OfV7{K>IS>^8m{E+czPd=}Fr{Ch!I>qkys6+ZZW7?KK1PwQv
zw&LgSVfpXfRbGMQ9(@+VmjUvb=Ua~%X0?b~FE2J&PEgi<g4jx%3GfbIG^7*7=iiMa
zm%iQL?@ZuaE#;HS9an4jKN>%P77X+n_2;_|eA9_shH_C5zhxr&L<oVia!nBLnu)>H
zvJ<}`6Sbvu=6}tEFY;mI*|Yr)UECRBhKicu>#c8HWx|_haVGT)U4$2=-_9TpJ79Y_
zAlsZ=m%g7tg|S&;#h}6{zL<sQYx(r}@=t@Ue3wk250KI)<VS7z=94g5<a5Z!`ChbW
zceW@18Wb$}a;`g{FbO`q4d(YwLMZUe{&o^KPkAwfpEg<G<?g)`!rz#Ty5uv+*V%?F
zD;fW_9_pg!1k^RHCtqa>H00CCf2(L?USUlAQlG6cHd{^M8Y@eB@d;Bn8%z1<@1k;@
z_%=`C4wS{0u}*IE@i3+jzn<!n4+}RdDRJs@+)e*ogZ1I>K*LQwUc70GdHr_$Qd#+3
zLq34qxMr)Ti#859`aS1dAKqaq%F1V!$K*H9b^Rso(RU5`RP*a&BilI5y;k@=r$Q({
z0%a}bbI{kdi3v^eZMfjOhHEIFN43i*r#G(F$c3AHf9ZD(`E2#r{>#2zo|*6eJtsAk
z|3YQu)7T%+O?kW2_m5rQHRSW!Gs~`z?pM`o*!P@`p?v#ku<Ssn_+hW`;mq9XH3R<q
zu5mGx&wz%Td?vh6Rc(`<-0YLzHRMy{-P)i0b?K~a>ECnqNARanR(U6aUo;)9$j7m-
zvAS7wX-jK-k${hMSj+LAK+juF=USEb){9eADxnltCShZjMWU)R|7<$GacUXKd(FU@
z`+KID<qy|h;e*P4(I!jzr1zOS4jzoD<COW`mXIj^^$b`oH6*Qd&Pr*q;wR0-^B@{t
zHIr+sO^6ad;K~2WLVmZ5;hU=D{#AvOUHRb#AvnFd5npK*!XlnNkAJdd$Zk!{d6oD%
z9^VGwMd9BAsQfE}A2JKyB+7OFJfM;j{2#MKW2-UDA#XjeWt@$2bu{0fVVRLnvF|vv
z@#1FZHsKem!o0*D@*$evNE-6__BDo$vZ%M@&H~{J1Yzc84CFsC&aC_}=_Sg}b$spF
zT#Nqy{H}OF%wUIs$#{#n`P%gcSGYO8`0BnU_LyZ?wpZDF!E#g&@buDT=Jot}mJ70K
zgn_RP{>3_@YKd_VKc;}E7axzi96vhnx_T(ze>T_D@UEQrCDAyKW+%B}mA<4ThYMd$
z?EhF}WfK0_)5}gA&+aQ*y9Q)+oRpHBtWUzf9~64QW^|WG-CymIPgczLwf;TVXudWn
zb+9IZzUiKM<Z6<&>dYd1rBMy}y2Oab{Fj=hln*Bq*GH=F4><F+c}||BP_*{-$C1XF
zGvt5rCEdZh<U!S~j}IW<3>9qS+|~yM78E>LC%$XiZmQ&UbGUcahUy0-$A=Hnr)U!5
zW78sIVq<ss&c%Z=e{?Np;rXArjvB}R6l%~F*cVcw(&apU^l8pgCvz!(D@ALriz{gl
zNR5otC(%EAL2nl#gnxrYlM=6y<&hc>&5*Fzn24|xK5PkRSzUM)gUSRdwCct?@tn0G
zHKmlU9vXiaXoN4dno^sC<0JH%sI&w$5)&KocTN+ZkP;I=I4oAC7&8CRNYN*!2qiU?
zLVk2gN<uOpu$!yNClqjHYk#X6M*O2J-bnCw_j9)Vt0SDs=O5le{YOF2(34LyG93SA
z&36SpEQhnO`kM$9{Eg=m?{M{-OD}YgDWwoKya{u2rYiNxZkm`BeNtFTJbs7nrb$kV
z8xS8m7%z@ADKX)Lc&A*>vWCo&KXRI1%yacEz84Xym&=pM{AT!R40Xyub$Ghv3)gbC
zmB|Ijh-mQ6i9dUbvsFbv62bSo&DH-~KAxL|LRO{il$w&w);RN<_H%Ws2>;9pRYU*W
z32Ns3UU7BG#U(=&m(0(+$kn%!M^#KLgx?trJ;i$n!^o80Mk134>cB!R3~GK~KG$%^
K*ley{`2PV|0n<AG

diff --git a/nip42.test.ts b/nip42.test.ts
index 794bc5f..ff1f277 100644
--- a/nip42.test.ts
+++ b/nip42.test.ts
@@ -1,15 +1,14 @@
 import { test, expect } from 'bun:test'
-import 'websocket-polyfill'
 
 import { makeAuthEvent } from './nip42.ts'
-import { relayInit } from './relay.ts'
+import { relayConnect } from './relay.ts'
 
 test('auth flow', () => {
-  const relay = relayInit('wss://nostr.wine')
+  const relay = relayConnect('wss://nostr.wine')
 
   const auth = makeAuthEvent(relay.url, 'chachacha')
   expect(auth.tags).toHaveLength(2)
-  expect(auth.tags[0]).toEqual(['relay', 'wss://nostr.wine'])
+  expect(auth.tags[0]).toEqual(['relay', 'wss://nostr.wine/'])
   expect(auth.tags[1]).toEqual(['challenge', 'chachacha'])
   expect(auth.kind).toEqual(22242)
 })
diff --git a/package.json b/package.json
index ffd426f..d1ef8ed 100644
--- a/package.json
+++ b/package.json
@@ -185,7 +185,6 @@
     "node-fetch": "^2.6.9",
     "prettier": "^3.0.3",
     "tsd": "^0.22.0",
-    "typescript": "^5.0.4",
-    "websocket-polyfill": "^0.0.3"
+    "typescript": "^5.0.4"
   }
 }
diff --git a/pool.test.ts b/pool.test.ts
index e89b50b..176fb66 100644
--- a/pool.test.ts
+++ b/pool.test.ts
@@ -1,5 +1,4 @@
 import { test, expect } from 'bun:test'
-import 'websocket-polyfill'
 
 import { finishEvent, type Event } from './event.ts'
 import { generatePrivateKey, getPublicKey } from './keys.ts'
diff --git a/relay.test.ts b/relay.test.ts
index 32033ad..7e01a82 100644
--- a/relay.test.ts
+++ b/relay.test.ts
@@ -1,125 +1,99 @@
-import { test, expect } from 'bun:test'
-import 'websocket-polyfill'
+import { test, expect, afterEach, beforeEach } from 'bun:test'
 
 import { finishEvent } from './event.ts'
 import { generatePrivateKey, getPublicKey } from './keys.ts'
-import { relayInit } from './relay.ts'
+import { Relay } from './relay.ts'
 
-let relay = relayInit('wss://relay.damus.io/')
+let relay = new Relay('wss://public.relaying.io')
 
-beforeAll(() => {
+beforeEach(() => {
   relay.connect()
 })
 
-afterAll(() => {
+afterEach(() => {
   relay.close()
 })
 
-test('connectivity', () => {
-  return expect(
-    new Promise(resolve => {
-      relay.on('connect', () => {
-        resolve(true)
-      })
-      relay.on('error', () => {
-        resolve(false)
-      })
-    }),
-  ).resolves.toBe(true)
+test('connectivity', async () => {
+  await relay.connect()
+  expect(relay.connected).toBeTrue()
 })
 
 test('querying', async () => {
-  var resolve1: (value: boolean) => void
-  var resolve2: (value: boolean) => void
+  let resolve1: () => void
+  let resolve2: () => void
 
-  let sub = relay.sub([
-    {
-      ids: ['d7dd5eb3ab747e16f8d0212d53032ea2a7cadef53837e5a6c66d42849fcb9027'],
-    },
-  ])
-  sub.on('event', event => {
-    expect(event).toHaveProperty('id', 'd7dd5eb3ab747e16f8d0212d53032ea2a7cadef53837e5a6c66d42849fcb9027')
-    resolve1(true)
-  })
-  sub.on('eose', () => {
-    resolve2(true)
-  })
-
-  let [t1, t2] = await Promise.all([
-    new Promise<boolean>(resolve => {
+  let waiting = Promise.all([
+    new Promise<void>(resolve => {
       resolve1 = resolve
     }),
-    new Promise<boolean>(resolve => {
+    new Promise<void>(resolve => {
       resolve2 = resolve
     }),
   ])
 
-  expect(t1).toEqual(true)
-  expect(t2).toEqual(true)
+  relay.subscribe(
+    [
+      {
+        ids: ['3abc6cbb215af0412ab2c9c8895d96a084297890fd0b4018f8427453350ca2e4'],
+      },
+    ],
+    {
+      onevent(event) {
+        expect(event).toHaveProperty('id', '3abc6cbb215af0412ab2c9c8895d96a084297890fd0b4018f8427453350ca2e4')
+        expect(event).toHaveProperty('content', '+')
+        expect(event).toHaveProperty('kind', 7)
+        resolve1()
+      },
+      oneose() {
+        resolve2()
+      },
+    },
+  )
+
+  let [t1, t2] = await waiting
+  expect(t1).toBeUndefined()
+  expect(t2).toBeUndefined()
 }, 10000)
 
-test('async iterator', async () => {
-  let sub = relay.sub([
-    {
-      ids: ['d7dd5eb3ab747e16f8d0212d53032ea2a7cadef53837e5a6c66d42849fcb9027'],
-    },
-  ])
-
-  for await (const event of sub.events) {
-    expect(event).toHaveProperty('id', 'd7dd5eb3ab747e16f8d0212d53032ea2a7cadef53837e5a6c66d42849fcb9027')
-    break
-  }
-})
-
-test('get()', async () => {
-  let event = await relay.get({
-    ids: ['d7dd5eb3ab747e16f8d0212d53032ea2a7cadef53837e5a6c66d42849fcb9027'],
-  })
-
-  expect(event).toHaveProperty('id', 'd7dd5eb3ab747e16f8d0212d53032ea2a7cadef53837e5a6c66d42849fcb9027')
-})
-
-test('list()', async () => {
-  let events = await relay.list([
-    {
-      authors: ['3bf0c63fcb93463407af97a5e5ee64fa883d107ef9e558472c4eb9aaaefa459d'],
-      kinds: [1],
-      limit: 2,
-    },
-  ])
-
-  expect(events.length).toEqual(2)
-})
-
-test('listening (twice) and publishing', async () => {
+test('listening and publishing and closing', async () => {
   let sk = generatePrivateKey()
   let pk = getPublicKey(sk)
-  var resolve1: (value: boolean) => void
-  var resolve2: (value: boolean) => void
+  var resolve1: (_: void) => void
+  var resolve2: (_: void) => void
 
-  let sub = relay.sub([
-    {
-      kinds: [27572],
-      authors: [pk],
-    },
+  let waiting = Promise.all([
+    new Promise(resolve => {
+      resolve1 = resolve
+    }),
+    new Promise(resolve => {
+      resolve2 = resolve
+    }),
   ])
 
-  sub.on('event', event => {
-    expect(event).toHaveProperty('pubkey', pk)
-    expect(event).toHaveProperty('kind', 27572)
-    expect(event).toHaveProperty('content', 'nostr-tools test suite')
-    resolve1(true)
-  })
-  sub.on('event', event => {
-    expect(event).toHaveProperty('pubkey', pk)
-    expect(event).toHaveProperty('kind', 27572)
-    expect(event).toHaveProperty('content', 'nostr-tools test suite')
-    resolve2(true)
-  })
+  let sub = await relay.subscribe(
+    [
+      {
+        kinds: [23571],
+        authors: [pk],
+      },
+    ],
+    {
+      onevent(event) {
+        expect(event).toHaveProperty('pubkey', pk)
+        expect(event).toHaveProperty('kind', 23571)
+        expect(event).toHaveProperty('content', 'nostr-tools test suite')
+        resolve1()
+      },
+      onclose() {
+        resolve2()
+      },
+    },
+  )
 
   let event = finishEvent(
     {
-      kind: 27572,
+      kind: 23571,
       created_at: Math.floor(Date.now() / 1000),
       tags: [],
       content: 'nostr-tools test suite',
@@ -127,15 +101,10 @@ test('listening (twice) and publishing', async () => {
     sk,
   )
 
-  relay.publish(event)
-  return expect(
-    Promise.all([
-      new Promise(resolve => {
-        resolve1 = resolve
-      }),
-      new Promise(resolve => {
-        resolve2 = resolve
-      }),
-    ]),
-  ).resolves.toEqual([true, true])
+  await relay.publish(event)
+  sub.close()
+
+  let [t1, t2] = await waiting
+  expect(t1).toBeUndefined()
+  expect(t2).toBeUndefined()
 })
diff --git a/relay.ts b/relay.ts
index 0011a98..82df7da 100644
--- a/relay.ts
+++ b/relay.ts
@@ -12,68 +12,13 @@ export function relayConnect(url: string) {
   return relay
 }
 
-class Subscription {
-  public readonly relay: Relay
-  public readonly id: string
-  public closed: boolean = false
-  public eosed: boolean = false
-
-  public alreadyHaveEvent: ((id: string) => boolean) | null = null
-  public receivedEvent: ((id: string) => boolean) | null = null
-  public readonly filters: Filter[]
-
-  public onevent: (evt: Event) => void
-  public oneose: (() => void) | null = null
-  public onclose: ((reason: string) => void) | null = null
-
-  constructor(relay: Relay, filters: Filter[], params: SubscriptionParams) {
-    this.relay = relay
-    this.filters = filters
-    this.id = params.id
-    this.onevent = params.onevent
-    this.oneose = params.oneose || null
-    this.onclose = params.onclose || null
-    this.alreadyHaveEvent = params.alreadyHaveEvent || null
-    this.receivedEvent = params.receivedEvent || null
-  }
-
-  public close(reason: string) {
-    if (!this.closed) {
-      // if the connection was closed by the user calling .close() we will send a CLOSE message
-      // otherwise this._open will be already set to false so we will skip this
-      this.relay.send('["CLOSE",' + JSON.stringify(this.id) + ']')
-      this.closed = true
-    }
-    this.onclose?.(reason)
-  }
-}
-
-type SubscriptionParams = {
-  id: string
-  onevent: (evt: Event) => void
-  oneose?: () => void
-  onclose?: (reason: string) => void
-  alreadyHaveEvent: ((id: string) => boolean) | null
-  receivedEvent: ((id: string) => boolean) | null
-}
-
-type CountResolver = {
-  resolve: (count: number) => void
-  reject: (err: Error) => void
-}
-
-type EventPublishResolver = {
-  resolve: (reason: string) => void
-  reject: (err: Error) => void
-}
-
-class Relay {
+export class Relay {
   public readonly url: string
   private _connected: boolean = false
 
   public trusted: boolean = false
   public onclose: (() => void) | null = null
-  public onnotice: (msg: string) => void = console.log
+  public onnotice: (msg: string) => void = msg => console.log(`NOTICE from ${this.url}: ${msg}`)
 
   private connectionPromise: Promise<void> | undefined
   private openSubs = new Map<string, Subscription>()
@@ -81,7 +26,7 @@ class Relay {
   private openEventPublishes = new Map<string, EventPublishResolver>()
   private ws: WebSocket | undefined
   private incomingMessageQueue = new Queue<string>()
-  private handleNextInterval: ReturnType<typeof setInterval> | null = null
+  private queueRunning = false
   private challenge: string | undefined
   private serial: number = 0
 
@@ -112,6 +57,8 @@ class Relay {
 
   public async connect(): Promise<void> {
     if (this.connectionPromise) return this.connectionPromise
+
+    this.challenge = undefined
     this.connectionPromise = new Promise((resolve, reject) => {
       try {
         this.ws = new WebSocket(this.url)
@@ -125,8 +72,8 @@ class Relay {
         resolve()
       }
 
-      this.ws.onerror = () => {
-        reject()
+      this.ws.onerror = ev => {
+        reject((ev as any).message)
         if (this._connected) {
           this.onclose?.()
           this.closeAllSubscriptions('relay connection errored')
@@ -143,19 +90,30 @@ class Relay {
 
       this.ws.onmessage = ev => {
         this.incomingMessageQueue.enqueue(ev.data as string)
-        if (!this.handleNextInterval) {
-          this.handleNextInterval = setInterval(this.handleNext.bind(this), 0)
+        if (!this.queueRunning) {
+          this.runQueue()
         }
       }
     })
+
+    return this.connectionPromise
   }
 
-  private handleNext() {
+  private async runQueue() {
+    this.queueRunning = true
+    while (true) {
+      if (false === this.handleNext()) {
+        break
+      }
+      await Promise.resolve()
+    }
+    this.queueRunning = false
+  }
+
+  private handleNext(): undefined | false {
     const json = this.incomingMessageQueue.dequeue()
     if (!json) {
-      clearInterval(this.handleNextInterval as ReturnType<typeof setInterval>)
-      this.handleNextInterval = null
-      return
+      return false
     }
 
     const subid = getSubscriptionId(json)
@@ -249,36 +207,106 @@ class Relay {
     if (!this.challenge) throw new Error("can't perform auth, no challenge was received")
     const evt = nip42.makeAuthEvent(this.url, this.challenge)
     await Promise.all([signAuthEvent(evt), this.connect()])
-    this.ws?.send('["AUTH",' + JSON.stringify(evt) + ']')
+    this.send('["AUTH",' + JSON.stringify(evt) + ']')
   }
 
-  public async publish(event: Event) {
+  public async publish(event: Event): Promise<string> {
     await this.connect()
-    const ret = new Promise((resolve, reject) => {
+    const ret = new Promise<string>((resolve, reject) => {
       this.openEventPublishes.set(event.id, { resolve, reject })
     })
-    this.ws?.send('["EVENT",' + JSON.stringify(event) + ']')
+    this.send('["EVENT",' + JSON.stringify(event) + ']')
     return ret
   }
 
-  public async count(filters: Filter[], params: { id?: string | null }) {
+  public async count(filters: Filter[], params: { id?: string | null }): Promise<number> {
     await this.connect()
     this.serial++
     const id = params?.id || 'count:' + this.serial
-    const ret = new Promise((resolve, reject) => {
+    const ret = new Promise<number>((resolve, reject) => {
       this.openCountRequests.set(id, { resolve, reject })
     })
-    this.ws?.send('["COUNT","' + id + '"' + JSON.stringify(filters) + ']')
+    this.send('["COUNT","' + id + '",' + JSON.stringify(filters) + ']')
     return ret
   }
 
-  public async subscribe(filters: Filter[], params: SubscriptionParams & { id: string | undefined }) {
+  public async subscribe(filters: Filter[], params: Partial<SubscriptionParams>) {
     await this.connect()
     this.serial++
-    params.id = params.id || 'sub:' + this.serial
-    const subscription = new Subscription(this, filters, params)
-    this.openSubs.set(params.id, subscription)
-    this.ws?.send('["REQ","' + params.id + '"' + JSON.stringify(filters) + ']')
+    const id = params.id || 'sub:' + this.serial
+    const subscription = new Subscription(this, filters, {
+      onevent: event => {
+        console.warn(
+          `onevent() callback not defined for subscription '${id}' in relay ${this.url}. event received:`,
+          event,
+        )
+      },
+      ...params,
+      id,
+    })
+    this.openSubs.set(id, subscription)
+    this.send('["REQ","' + id + '",' + JSON.stringify(filters).substring(1))
     return subscription
   }
+
+  public close() {
+    this.closeAllSubscriptions('relay connection closed by us')
+    this._connected = false
+    this.ws?.close()
+  }
+}
+
+export class Subscription {
+  public readonly relay: Relay
+  public readonly id: string
+  public closed: boolean = false
+  public eosed: boolean = false
+
+  public alreadyHaveEvent: ((id: string) => boolean) | undefined
+  public receivedEvent: ((id: string) => boolean) | undefined
+  public readonly filters: Filter[]
+
+  public onevent: (evt: Event) => void
+  public oneose: (() => void) | undefined
+  public onclose: ((reason: string) => void) | undefined
+
+  constructor(relay: Relay, filters: Filter[], params: SubscriptionParams) {
+    this.relay = relay
+    this.filters = filters
+    this.id = params.id
+    this.onevent = params.onevent
+    this.oneose = params.oneose
+    this.onclose = params.onclose
+    this.alreadyHaveEvent = params.alreadyHaveEvent
+    this.receivedEvent = params.receivedEvent
+  }
+
+  public close(reason: string = 'closed by caller') {
+    if (!this.closed) {
+      // if the connection was closed by the user calling .close() we will send a CLOSE message
+      // otherwise this._open will be already set to false so we will skip this
+      this.relay.send('["CLOSE",' + JSON.stringify(this.id) + ']')
+      this.closed = true
+    }
+    this.onclose?.(reason)
+  }
+}
+
+export type SubscriptionParams = {
+  id: string
+  onevent: (evt: Event) => void
+  oneose?: () => void
+  onclose?: (reason: string) => void
+  alreadyHaveEvent?: (id: string) => boolean
+  receivedEvent?: (id: string) => boolean
+}
+
+export type CountResolver = {
+  resolve: (count: number) => void
+  reject: (err: Error) => void
+}
+
+export type EventPublishResolver = {
+  resolve: (reason: string) => void
+  reject: (err: Error) => void
 }
diff --git a/utils.test.ts b/utils.test.ts
index 4335c13..4a3d141 100644
--- a/utils.test.ts
+++ b/utils.test.ts
@@ -1,6 +1,6 @@
 import { describe, test, expect } from 'bun:test'
 import { buildEvent } from './test-helpers.ts'
-import { MessageQueue, insertEventIntoAscendingList, insertEventIntoDescendingList } from './utils.ts'
+import { Queue, insertEventIntoAscendingList, insertEventIntoDescendingList } from './utils.ts'
 
 import type { Event } from './event.ts'
 
@@ -216,27 +216,25 @@ describe('inserting into a asc sorted list of events', () => {
 
 describe('enque a message into MessageQueue', () => {
   test('enque into an empty queue', () => {
-    const queue = new MessageQueue()
+    const queue = new Queue()
     queue.enqueue('node1')
     expect(queue.first!.value).toBe('node1')
   })
   test('enque into a non-empty queue', () => {
-    const queue = new MessageQueue()
+    const queue = new Queue()
     queue.enqueue('node1')
     queue.enqueue('node3')
     queue.enqueue('node2')
     expect(queue.first!.value).toBe('node1')
     expect(queue.last!.value).toBe('node2')
-    expect(queue.size).toBe(3)
   })
   test('dequeue from an empty queue', () => {
-    const queue = new MessageQueue()
+    const queue = new Queue()
     const item1 = queue.dequeue()
     expect(item1).toBe(null)
-    expect(queue.size).toBe(0)
   })
   test('dequeue from a non-empty queue', () => {
-    const queue = new MessageQueue()
+    const queue = new Queue()
     queue.enqueue('node1')
     queue.enqueue('node3')
     queue.enqueue('node2')
@@ -246,14 +244,13 @@ describe('enque a message into MessageQueue', () => {
     expect(item2).toBe('node3')
   })
   test('dequeue more than in queue', () => {
-    const queue = new MessageQueue()
+    const queue = new Queue()
     queue.enqueue('node1')
     queue.enqueue('node3')
     const item1 = queue.dequeue()
     expect(item1).toBe('node1')
     const item2 = queue.dequeue()
     expect(item2).toBe('node3')
-    expect(queue.size).toBe(0)
     const item3 = queue.dequeue()
     expect(item3).toBe(null)
   })
diff --git a/utils.ts b/utils.ts
index cce4f6b..ab6ddd4 100644
--- a/utils.ts
+++ b/utils.ts
@@ -94,11 +94,11 @@ export function insertEventIntoAscendingList(sortedArray: Event[], event: Event)
 
 export class QueueNode<V> {
   public value: V
-  public next: QueueNode<V> | null
+  public next: QueueNode<V> | null = null
+  public prev: QueueNode<V> | null = null
 
   constructor(message: V) {
     this.value = message
-    this.next = null
   }
 }
 
@@ -114,9 +114,17 @@ export class Queue<V> {
   enqueue(value: V): boolean {
     const newNode = new QueueNode(value)
     if (!this.last) {
+      // list is empty
       this.first = newNode
       this.last = newNode
+    } else if (this.last === this.first) {
+      // list has a single element
+      this.last = newNode
+      this.last.prev = this.first
+      this.first.next = newNode
     } else {
+      // list has elements, add as last
+      newNode.prev = this.last
       this.last.next = newNode
       this.last = newNode
     }
@@ -126,10 +134,16 @@ export class Queue<V> {
   dequeue(): V | null {
     if (!this.first) return null
 
-    let prev = this.first
-    this.first = prev.next
-    prev.next = null
+    if (this.first === this.last) {
+      const target = this.first
+      this.first = null
+      this.last = null
+      return target.value
+    }
 
-    return prev.value
+    const target = this.first
+    this.first = target.next
+
+    return target.value
   }
 }