# v2 git bundle db71f2928831867a7ebfed3063cb04791a92318c refs/heads/bundle db71f2928831867a7ebfed3063cb04791a92318c HEAD PACK7x>tree 96ea07962b9f8e5ae7c158b61e48ca87eae76c7b parent 281329a1afad5d87ef17215963272e4c0a814787 author MythEclipse 1779062492 +0700 committer MythEclipse 1779062492 +0700 feat: add in-memory rate limiter Co-Authored-By: Claude Opus 4.7 [cxBtree 97422055f2943fe49f550c3429e829885216f7ed parent f9c0bc076893eb040fdc59e95a9cbd7c08df5da8 author MythEclipse 1779062446 +0700 committer MythEclipse 1779062446 +0700 feat: add Drizzle ORM database layer Co-Authored-By: Claude Opus 4.7 eexHtree b96e8a268e19ef296429991b1ab4c70f424ed5c2 parent 77032538e8bffb263f793c974ead979ca771ccdf author MythEclipse 1779062335 +0700 committer MythEclipse 1779062335 +0700 feat: add environment variables validation Co-Authored-By: Claude Opus 4.7 "hx<tree 17dbff3e388f7c293abd61d88d72696d099169f5 parent 25c82bcf0b70907221eb56fb34a6631603c02388 author MythEclipse 1779062013 +0700 committer MythEclipse 1779062013 +0700 feat: add Winston logger setup Co-Authored-By: Claude Opus 4.7 0bxGtree ab5243c311cad0d5e631c4d9e27357f09d491d01 parent f423e1f25df3d165e3635c6992010fc84e6585b6 author MythEclipse 1779061866 +0700 committer MythEclipse 1779061866 +0700 chore: add dependencies and configuration Co-Authored-By: Claude Opus 4.7 g@xtree 67be35fa7bfe978a8a536d17f5da9e981a86ce70 parent 3fb3dc3d40c8351efd488bf094049b42df93f831 author MythEclipse 1779061733 +0700 committer MythEclipse 1779061733 +0700 docs: add telegram uploader backend implementation plan Ztxtree a2975f17297ac440fabe924e3efc6c05cb73c6bb parent cf55f6dee8872e65c63e2772754dc2ae03c0e3f9 author MythEclipse 1779061362 +0700 committer MythEclipse 1779061362 +0700 docs: add telegram uploader backend design spec D!WPx tree 8d70b092d2c44596b3bb7f248945874a29f1c862 author MythEclipse 1779060842 +0700 committer MythEclipse 1779060842 +0700 Initialize TeleUploader project with Bun, including configuration files and basic setup )Wx340031QK+KH-Iexd s)Qh>c'doUY_ʠ^swoMSSrE/U⪗P#{s̽f)j^YS(jPkڸ~go,TQRi^N~r6'; Uyz XłM @!%?]w]^l܏*5"3/%B[NJȻ}_-㿸 19;1=U/8?aQf*b}E۸}UWW\/B*_(KkOU/SqPqQ2k0VgbT[? "[Z\`kPߝgw+:89?/-3M=k;VlYq lQƵxMN0F.nlSII3U6T%Ʒ]h>|vRL>Ff0g?PdE C%Ulon1њ⤋х,I.B:4ʩ! Oo衛yYLn5=Jc0q$vjboG8;2N͢*( BeMRC%}=XyYxmP=k0 + t~-\tXJpl%UIV2NzOӗ.ጒP"aqaGR,0@4aӴ0Š$*goWK*f&r\9xX}8k6vE&GYbn FjmC WdaϹT~GwN ck[62,ĉdԦ!3=!Lzy0kwrrsHKwOoxmVmo6_qS)l žu]]q%:f" I6=GJ$@"~]Ob6%1ME2V9-}UL3J6/dȗT` JSbl6ر{aGCM#v,s'k73ĕiv G 9-TWz3T9)&ӲiĘګ~\9ЂJoŒ*˴_{ ZicUZ#* EzQ'GT~pGFG1H4u5]lV*LzYM IES3Z c!y(P鄶|Ga3cȥR8ʓ{n{e>mZ>,8ٙF{zVho|gϷ&97Q+F(|~L 38,y_ЍAp3hS^'mv&\"~CSГcBi-2KϴժSτCwDQ(+]&tZȪ3~ayxU_[6v7F(uxld+T6+ib튵I}ކŞ" _82Ϲ(ù1<&<~m=}A?WbM*#&W}('O$9:ii"5<{1JUa.?owۛo{|^s?jp6 ekӈ`YP%r( UؕzNV7Պ,B<=}|8lj!DaJh4-K.5` p`ι/ J?(YǨ7Y+Yi6vp߯ȳp DʏKb~9"Ƌ'@X˰TyS.mۓp-c9ܧv'0!ak?HV; ~s]3fJ?|2XMxf*㬐< [%spwy?EK$WY8p 6LDƛ.3?ub#eY|I~ʰeNzٙv6e^%0{Itìqg-nt%0dhn4?~9])x{&/8w[J]ٜK'EleM5ɾ;=} [m.JY~s,J+m@3qRentbK)ѶL~C_-C;+L&Џ n:ߞY C+K2ȜЋipI[D-KcD7.K "N `H"̱0B'|#kM?Nh|9{leɒhFL 4ލS2 Fa;I&r]x[9v^|ijBq$.JC/𪪹+']/4wE Tm)pL6hG$ ؇dvA$̀¢X8b*]Ox(8hX{$$Zf^ʉ"o{IOiLҮ^D _5޽],\?)id:ktH`incOΒ:$j@$&3Q&Ke$Ҡ DkDT %h\طD@ X֓h ~ߵ1,Z9†8SB2ҟQPN{G{Et0-Zݲw=Zj>f}6"/F-N}&-Qxϖ  2JAf^MzfI{BIA ¡*dC>зBgmΫT[mEXm/up5] <^I#4{0P\|pnC";/b"`thp~vr:Lo Vbz DǞ CIUOg 7÷o? wIOGo!Qust4]'ZQ90@ Άhw)(<`hN2쇽`bgC=eg؂k0¼V,4WCQ_*YuN\[ږkq|Ԑ5s#轣wj.NNǰd oнF!m[b|zg1KZ Vir ) (4h Z(upK\?_52A 8Ktckf `1DW WHdldm A;cF7wm@eh1 +q-г~!JӼcxjg#΀"ҥ7ْB{0mǍz >sF`>gto r,&\/㢧p5.[18~ƤEdO[)5ltWcqF<ã'A1!iя.[)赏YG%9 5dEԀHC`)hcwwy01_x!0ƹL.ʈ?c b.Ð>**W0K>V1 @osU BҌ&2t%F+̀KqrX•P4@D Lfqݜ_~k EhSjulk:Xnؐ[U8AB  q "wDL")~56lW\q-t2\X}ԽS:S?5Qdv@ɦo8g"PX;z/I$>*^k[UZJS5G ,K 5{ߕ"@I]c'C- 󤀔RʤZ<]`ԫFû AP[)e\qGɭGP:1ʧbIv jC FUڤJh$4qDפX6S}5[qnIrq)DSL6n ]su4tϒ^"g_*  's "oTV4FYRÍͮʤҀx(*hH# cH"VsP%4 QHl۶!Ė/t9Ia3;m dʀt.M]n{#^@ ;tn+S:Re((;6WFlȌ(+d,spzgk-"֌s.) QMh L04vYg :ቷ]aI(jSGVw-P{jُ:,ҷ6"0gP5'hؠ5pA/x,Ns [2{& *sjr}1@2\.&'WtSU&!aq0<J N+Lt$=tc'M\0rj%RI{btH5Rqt]', te-2ĒD*e#vBl>%#i"}]#JܹTjkX^t(P˟ V9s@VʷUZL{GCj]R9 vM f,ZP۽,N t(8aq P8y}pDE12r'u۵v0Jhꭧi4Uv󙴛'(.|?̉\טPF7Uqb/4i;i#x EUzmks0NЮv0<a>>3`ϝ;JcyK̈kƃp_ah쫆"W%.Лkq[l)joMM+Jxu ?Xg/G"[krQv!I 9QGw3<6'r$q> 2 م"D y}E0p+!w@(Q.bHO0,M"Ա8{b%72V~Y?;^s!9X,-`!rݻeXPg٘*\*M2gЇݲːt[}ES||=<`$n4]Mfimy<"۽#]/ڠ)g׫j Jyce9!ߺ^eE)NSKqA)K;cJ0Vl}xig!8jZYOfKE501k<496уJh z ii2pIrTu4͖1b* Mwe (\4x k*@)I K؟.eφPMUPPLIl1h#Mgm,=TqIe/Q~߼ E>hLx ^O32AenX#{Vg/"Ih b=M~|EU)Xv$ C,3ײLkYV,3+YVB,3N JlJ5hyY',fVUvtx]QJUegnj7КX薑ތAq0D^{ c#tӤ w؈\vͩkrIx s=:-P)> )6dBHW dl,]~Rl:g8oځ~M0v%jE @?X\+eJ9fi`%?k!DeG:*qĜTN* 3HQc 4cKPЯd؋B'NϸF?O5( ˽~;f[=d8&{g=ޖq+|㖅`NJyX㐢GV1kz)CR9}@#@&VI&~VUvc'״U]0| WO_߯Ȯ Opr ɭ^ίs}?[oPYވZHc`NO-NJbcdML!?s[-wU̘*#oýv1jR' &P̼<\PfޑMD5.J6E5F( l*6bi\OyuP7[ZC >rMD7pM_%E\*>rAo;2z-vh2F{qk kTNVij PWƑʙL~϶,JTɅUAie⬏6 AP% ~5 P+qOY̭M5%'gfLn;IܾZ^\xI16K5TkPI^Y96䔕qI{reLA }wORac+W3etи6>w i} !lln5ؽrVUd͖GܤX'#C1p򾰜’sf|mvO-aªBhR´Je+$a>y_g,ގ8c] >,/GW݋rWcz!\%xg=LI9gh=÷ͬmȵr QK;~-תO\P:iG$h3ec6W;)0=1?1F!&gVިy6zIb>c|=)y* u uA,wI~ JNM25%_eH9Դ6=<؇%[uhm#+5#  a z%Qb+moÌZ6uom,P'=܁;W"ZF<^8onH 88崍 Vy^C/*x/U9[}ל|"8]S<"^¹g,ӵ;\^w|B^?`ٴ!^-|b c%`9ЖU ube[,l $ V-/$ei+Ud+mޛz nޱɚJZ wl//l?G6R͛@"򀤶!Y3?>%>8ߊsJ_x8j ͣ'[(FjzSrzssk$(#;HLOI=l__gpf\ZjC2qX|+o75ejzDm,x = =J[| q\L?, ]~˧s sBM=芟Gt{R}%68<XI% mWQ˜x]8o (7߱A~CIi F(wU7(6M-5$SVvDnQW~_ dL"s(L,AyQqm~1@2/5 ɿ_|JCsUc|'Ő>0wFi#dL=Tf#eFW)xER:йpa:EPt3f>YlULjhUx-`W p|wtgVߊАQ7#OY!Wsx|W瀇.U*9LЃX*ċi?x 9>Odg_n[B[zK.fSup?>MLM goE[U!G~鈌>*-ĩe߃ Gwy7%ߪɶr@b5UH'{zc_BwZ=:DB+/X/o_ְ4 Oz; y`@|< WY B/%2IWϺd#_tb/iꉃX?~qOW +1~897-APa2~9ɄuSBc[T~HQss aR~%{/O)5l-wk>(d}ܶ'۫NNM9c_t5бɍ㵟]Ozܼ{nx +ɔ=bH_!k#$B:ԈJІwj;, )O VyRӘ}ژ:o)?"I1%Ger0 FA^n6oҰ1ت$^gZI;.LS^ꋧŵq[=l#ioCK[u%q-xƉ7ԇ&'獵X S;*cq vwz:_uVQGJLGH =Wz O1ywt4r9Ǐa=ALY]4g=e|)՘xٵxݡzbHL z s)a9Ǐ(lZx  #nxͽٲ̒.x_O:)&f%?[z1$nT\ݖB.%_8|KGψ.x]X^>jC[CYg} {( x+̱ o=q1`׸pZÆ>x\6!B Z `˃I^n95%W.rPwRQTH'+,٬vKo?c~VY6qVG%e{S %81R|+©z [OA /=܄?.ɞeu==炍<`[GWUټ(e7"j5*%͐/]E Crnlw _<#!7C02p{O_."Bџֽ&*+ܾLk-~)8>N&ʿV"v4"pCΓD*rN*;f؉6kǽT5e}PfmS.:δ,C؄)WUay&T(_ B9U{\@]YaKʍ^̲18n0| n4n5Ҏ]Q Pnbr[~;oV6桵NiB'm1p·%T2Imft-8.'>̒@<|b3&5ɔygq\觠j9|3ԂbNNJ iұSBxśƍ,Ho..#+0\  |͚ H=%rܬy~9WJ2X1|v[L"p<coQ@Rj]m6xHhA[ Z3ŴPnS^哥 'jU7jNOfeYD\],EYWXbwMgj{'37yZq̋ gBf1 ӍP K- p 0b8O&fkVnNx+" eoS^a@\G95 L htdu?#blw)0v ;㛊x?.pf=n\3zeL;d!]IXxĢޖ-ۚ]fgxӑw9y, 1vK&QQOODީzc\@WU!y&T$0 KJ֔n-݊SL#s |Y7IVF'\Ɍt E@iX"m uzLT|ʭ\6d[ßuEz4$I[>Ӏj?ި+5|MBV#gMD)LQebH6W{49tطeͩ yA*^1`L ?5u-ϕAbҧ贰rfwz.2/h^?HXЁ3vM~kT^iL@ѭF)pi Ȫ=dnP-{d+ ZJZ1 /RE MG0I>&!0jRV=]Z-JMt";ի [bǥHF#CRv'u(ޠQ4x0޹|ZyN %IF'cg9rIbfb_߯pǻE ķC$8*qy};z-.[r3zƩucð'?B YQI rRb먬;*lC6ViiWu0ky(>zmɯw :z8U ^%B^cÅ&gL܇(2&zP\ 1|ٟ߷e 7M8n= ~>KdA>H-0XP.Q"Dz~o;xj{0WԞ̧mBQg/0%.2AZ#,]Ͳct@}މf]^lL.ʿ>D_~nњmG&# _ݓ!D$ n i ɖLIG]Z(n<5`Hu03A3zWknn; 4dY}z%ۇLBX'cph6i!fV٪s>; h!Bcմ׋7[{>#+L&wo%ARYnؔzݶg3rnet㱿q>o?. kS.Z/% 틤0wtMRe/t?2=yY2Lisk& ![oc|h.: 'DŽ^  ]1/{*rymV,i}-C51i4:c(k4ףdKTD X:ł؎`^OJ{Se 'V AL bAv S&6Uy*'C%t^8 Fr*vѡ3 K.INYGϯt:_)Yt/9'=`Ɵܬ7)z7zs>, |bO$^[ 8`-Ei%/K("C#=jֳT^lj]ܶB]K"+U _띟U;֑{Z|%s0ln3t/6HK=8mM}rU痟}p&r/n5Y_3 WxO6GRe!؆ea۾+pC0rWg˟0}* te~Oс-®,_/Z ${ڧEXu-)mɅM+}vnw"i_BV5?)~蟗8x3)oeWY >cU^)LFK7WԆO7O>&@_3: ?в꒲p3"GjLa?UNCRwZ^)zTWtH5揮<)[oykDEnvt 1S%(TszFK}j\Tq#%J9PO/$ XWN柜/Ͽ(K2u6'!6*o-S䐵9]M.V7͐Qrg>כ>H3vƏInN?$O>imR_ şDOdP}B0os~>!zIλIVn>%ow\Bj\;o|KzxzFMxiG-NL5u(Y)殕)[N)͐ haWPRKk&jq/}c˜~`'FҞ576K3"03[Ѫ^ 6G;XaC?vz|?+7"XIL1 ^f[ʻ}zd57s|j Avb6,db-+'X|]>?"HĊm`8Q-{W3ʃv-l2pA=1xc7QJOeB߮2ܯ2KhGyqt)p|U޺bP_,fSan>}Up⃫٢9QU퇡gV_Du$'JVY>?_Y|z_yP^c|'oB1O^DP>L>kVNv^1ΌKz1WO3YWYe[F#_x{x~=s C}H+2NOjbl@i#lE9RF^vyH(ƜQo&/[ k/?O!)o4vuF]tlHVs!ic%G,+Lm(i'(dKPcoI3at/[5|3x}_q98G8ˆ8/TG>8p87LɣSbrY/ǘf7eIhan 2?vmg~y|G#zU(iG^:oGGwu`®.,l{'ڤYbjlbf@܍_Of^j,g=`l։[A[VY7~79 5WKm"(}mK }d'? __~=~5΢u@C#ztb[ڀ̀~{Xp1h("#lf\a;6"5r zAϙ:5NIMK+ M/kϗMe~&8Ax7U1?. 5l ~v`[$Ls@Y|+!ƮK_0 f^CؾJ:tJ '`1hXlHd64&SD|QCdBuGd yE.4 Ę 6ȱI@hx !$>IJ#ݝ/:mwoS}8h6nR;+NuI\ܲ"2maݲZm1ݐp):xG$xV3VO@W Wv__??ay89jts˳~\tqP' ~.>x!ŷ?OnTskѷGYf3VNQR)}_* 'Zz% xP[ifXٮeFn9j] ˩Xfz߯/z }b$I0n;U:^5˩ۨ\ilhZw]O\Gܽ7m_"3Qil[F[ Y9giD!6 Ii4>KYȕUC/j _n>;'slJ4C.x(+kдLޥJ0ٌ maW2YP`#8O_鈐qq711JmM>PY\#5m6)aZm(DŽܮ]&s8[X0r jq^k}輸__Mpf+{ Bbů뮞+vӀZ2b䅻\Fn]nafY9 !+V1\ hfvIq\8Bci=E/Hu ֡K1];F-ݸ3 +l\|_zI=g?|u,*Йt9Ie3P z~t-LSVF#Ov/$ {_[g71;nx]~ jgl<Ÿ eV9]ዢƔ8ŁLj$clцHnS s焂AD97vuKVޒ*cz`^Ŀ_"u9iyLK}s>]P~3_z,_i?gJ|ڷ z9?_'Ez,sN6%Eѯx3wdf`Qd|g89ci(#[n"S%kLïx#+^~/'R9hs2h6"v\7!6 8k,!$틂czb9eg-hgs.M\9s^<~a2Y:XpB٢mE],-fOͷc/Ò$dN]c kjdI̙-wZ n B[ܘS O)}=of6YD$3F?;}M'_'{#я3F?z1UGDo2F?"nASK|Or]G$I&ooa=a`5;ŋ± %38O/[?$mKVn?7 $'L~RӼ Oq 6eDy+ronSogߧDʷ+͜mX;Ц9oגlG"@E 2TVv oiM6, 3}TÜ /7Ϧ?Nd09I☖Hm$Q1^ F"`j?uh9Ȱx1߁׀Y]ДR\Vq{{L5ۭn$Kq Fi;09s5at>E}qY1Kz6Ju#| T6c,Dd9s<N%D&0g]р$#` w|@v,F 8")Yyav:YK[x_w~{o=JiNdY:RApV~acj, "E/xC9Q]=|< ;9y\'ǑgQO [SCbRcic*Zfwy2%XsvT[~¶|x6;Ʊ0VV̠ct׼}Z ]L60qVV`{Wt<̿gy7ʵ6@vv=wqEMj#g]@40 2^{vn"g=~ :{=>^ER7-2]l1!GB4It]6=% ggst3F<0od_0N0l&6tKsYMUG$L1zZ|֝oo|wh~ CZoa/ՒX)ļ{#a IoXF.ɪ)& ;n\o-^/=YԴ٨+kvX;XnlI# TkqA'Ԇ<:!\2OҎ]!O:Jל{Tnt`gζ4K4wӻYuRyҮWm/vA/Op7;`npt>F]~㾻xlgC\kN `E[yN+вB QhzGKI),u\ RMF{NL6AoGxm)@фF m0[Qždc&?9Ӆ@*Qfqo7WͧtnVC/1|\;lrs,Lyސg rGcP!8rBwJΘo.%èP8q]i48ryܙY *q'eT׎NjO:[0y~bK'iPi,fU37g2ΘptLa%5Gі䥼CNawP~z0X38꾑ǭeOBܳ(=74g]- iM0\F~%LYZXC ܂7 oA߸Dz)Y[Lث3lVk$N"x0p +` 3-Uԛ#L66^ p9qG"r./CCC\ϖ%>.E$1M7 H!u QƫFjPYߐпpwqH ςU kQWA;޴ CDE'RoF%XA5gKZWfGffMGbŐLEfw/5{߻~]fcP LA6 aάƫ/ˍs=\(YA j,sK=;]tdC8/9)OCr؇ sl)l7 ^.i E-c/.$yeHp&h$pGM+3(SGTVsԡ4M9Ld݈dLJ,>}iт8 먇=[bݛ>}0`:+$ZC1 Kz9W 2hXb^Kxp-S4Pc #{"aH@h_^-TTguw^ZӂOƒɤPϫ_C. ~+VJTĠTL6BZqJv#Π,L"8/ r.1>T K=]{YN΍vxٯS,3/K/};p NtU;N݂0 f^i/"J;@Wl9f}=$E 7 z 6߂a10Ae(F/I 0P@HlZD`[!{P0PȕXZ ]& Dy&$,$g_(0=J Yo IP5IցEtĦ|u,?;>Wpޥ;2Sיy#28J .5}(-JRӔDJOVqHoY,`Ǧx&40000 superpowers4inҴ~YNʠx@40000 plans^p@mU +Q40000 specsI*9йtBx340031Q02025054-IIM/J--OLI-MJLNK-IMaq>>4)vUJ84x340031Q02025054-IIM/J--OLI-MJLNKMI-LMa⾤S;I{Y_%JH۳xrHb*/; o6.p{`Xh6ڪ{{{HwJik[/TDb$"YO=S98`ãׇ~` ^ORfI՝ߞeqX6ص2JɇA5l4jO26ؘJ% }'Ž]kfA*U|l˗iv[a)^.xcf<_H*4~O׬{ݯ7X"&q@W%ZKDZ,ZR =\p}L\T ^8afM[Wknx&Q17H @hPd 44Tc=ێɔ*%(r$72d|tKֿ)ŗLPjFU@sirÖZmJ s=!BNŹ:-j .́!OL|ko^4HĂP<@Zh-KE$ ,o>CLz|jf]%CAEe9NBKހ>+  ۀ[Zu'CZ< %V2-N_G`|H%DNȯ)ْ Q%Lpb5aZ7b ̏rz0{miD,4=/<?A4PҪF$BK""v|Z(h%Ys1oB[oϟ490dp=Lu-ȖueN*m( )Ss9!g3M~W̓"~PjgzWԝii*Y?MF\=g8Oyh(¥?e`NERMZ"up҂<+RYCĽ3MK^6#fvŔ*kF+K)?"hluBGKxp&zxٹ9T\e:_q\Klm흍O x,U"ћLG?Fq8~]>Bw֝3^NY¼^{Ydxtn̽?"(;OۭB2xzz z~ͮ&orte6aDL'@Чyˮhyuvzp`H܉teq\D"[j}B5Q֩VnXS=dU678LXK]Lfe`nTSPk۬Q@$Ks6u "g[[6U]xO+*a}hC54nE<հn8ZJ O2 0 Z,@E} WZ36t:v ;g8l!S1sW u칣Z \lB 2DܯQ,R8{Lі.^xdحwV ocq_ȋKO\";0PvRZ1G jp@Tv 3b!LTDQn O$KS뒔}w t@!脿ꄿg\w[xz^ u&YpHn_kd`Ǐȧ8"7x8iu-8w"Lt)=T |y6}!̇ߢ3Bw]JtPv ?.`( k_mC|K+L> |v`OW+_e|4`m˓}V*-!EI %*R1$% \<(WSfR+)mp22eiTF,dž[x!r iLQd慀H\F>Ed؅.dKHr ǯ<'E6|KVI T$`ڢo&=z2ɚnMJUUJ#EdR&v lper"~gKsrJl *n?v!;fޛ顃P&l2+BdׁفL@{ `+ôkՆbPkڀI~u\!rHX2>g݅V<_+?m G #t1k p K]󷹸\/&q:]<|lA2/:6 ?dm f2-6a=\.e%H |e:bC\'+MK|2.սLIͤuS&ڝEMOv}}A}W]0Hc,To/xOO0|9BE{BFָ O(KM<5y FGÛ)t`2Dg$AOG"JRfTT b#bmg8PǣB*lCWwj;[*2}Wvl|URueWJ4ܬw;l\ltVjeu&N|(Y1L;lchF}$མӿxoimport { drizzle } from 'drizzle-orm/postgres-js'; import postgres from 'postgres'; import logger from '../utils/logger.js'; import { files } from './schema.js'; const client = postgres(process.env.DATABASE_URL, { max: 10, idle_timeout: 20, connect_timeout: 10 }); export const db = drizzle(client, { schema: { files } }); export { files }; export default db;}t6xfimport { pgTable, text, bigint, timestamp, uuid } from 'drizzle-orm/pg-core'; export const files = pgTable('files', { id: uuid('id').primaryKey().defaultRandom(), publicId: text('public_id').unique().notNull(), telegramFileId: text('telegram_file_id').notNull(), telegramFileUniqueId: text('telegram_file_unique_id').notNull(), storageChatId: bigint('storage_chat_id', { mode: 'number' }).notNull(), storageMessageId: bigint('storage_message_id', { mode: 'number' }).notNull(), fileName: text('file_name').notNull(), mimeType: text('mime_type').notNull(), sizeBytes: bigint('size_bytes', { mode: 'number' }).notNull(), fileType: text('file_type').notNull(), uploaderId: bigint('uploader_id', { mode: 'number' }).notNull(), createdAt: timestamp('created_at').defaultNow().notNull(), updatedAt: timestamp('updated_at').defaultNow().notNull() });!'dJx[import logger from './utils/logger.js'; const requiredEnv = { BOT_TOKEN: process.env.BOT_TOKEN, STORAGE_CHANNEL_ID: process.env.STORAGE_CHANNEL_ID, BASE_URL: process.env.BASE_URL, DATABASE_URL: process.env.DATABASE_URL, PORT: process.env.PORT }; const missing = Object.entries(requiredEnv) .filter(([_, value]) => value === undefined || value === '') .map(([key]) => key); if (missing.length > 0) { logger.error('Missing required environment variables:', missing); throw new Error(`Missing environment variables: ${missing.join(', ')}`); } export const config = { botToken: process.env.BOT_TOKEN, storageChatId: parseInt(process.env.STORAGE_CHANNEL_ID, 10), baseUrl: process.env.BASE_URL, databaseUrl: process.env.DATABASE_URL, port: parseInt(process.env.PORT, 10) || 3000, nodeEnv: process.env.NODE_ENV || 'development', logLevel: process.env.LOG_LEVEL || 'info', rateLimitWindowMs: parseInt(process.env.RATE_LIMIT_WINDOW_MS, 10) || 60000, rateLimitMaxRequests: parseInt(process.env.RATE_LIMIT_MAX_REQUESTS, 10) || 30 }; logger.info('Environment variables loaded', { config: { ...config, botToken: config.botToken?.substring(0, 10) + '...' } }); xM100644 logger.jsgT`x]ɲU:SE100644 rateLimit.js ŵ_}gM41xSMO0 WSZiv)H*I7d 6$Tg#`dqԂ$ V`Ǖʡ 8O=0FSAH%u9Zg>>@hې1!PRQ-挀[A]^N9r> gO6/8567ѭ D@}gH >NWcw: Hc { const now = Date.now(); const windowMs = parseInt(process.env.RATE_LIMIT_WINDOW_MS, 10) || 60000; const maxRequests = parseInt(process.env.RATE_LIMIT_MAX_REQUESTS, 10) || 30; if (!rateLimitMap.has(key)) { rateLimitMap.set(key, { count: 0, reset: now + windowMs }); } const record = rateLimitMap.get(key); if (now > record.reset) { record.count = 0; record.reset = now + windowMs; } if (record.count >= maxRequests) { logger.warn('Rate limit exceeded', { key, count: record.count, reset: record.reset }); return false; } record.count++; return true; }; export const cleanupRateLimitCache = () => { const now = Date.now(); const windowMs = parseInt(process.env.RATE_LIMIT_WINDOW_MS, 10) || 60000; const keysToDelete = []; for (const [key, record] of rateLimitMap.entries()) { if (now > record.reset) { keysToDelete.push(key); } } keysToDelete.forEach(key => rateLimitMap.delete(key)); }; AW!x340031QHI+I-.*fuGX7kqs_fQWWS1z.T*+J,I,+c~k8oqW5ܱ01 { it("should export db instance", () => { expect(db).toBeDefined(); }); it("should export files schema from both index and schema", () => { expect(files).toBeDefined(); expect(schemaFiles).toBeDefined(); expect(files).toBe(schemaFiles); }); it("should have correct schema properties", () => { expect(files.id).toBeDefined(); expect(files.publicId).toBeDefined(); expect(files.telegramFileId).toBeDefined(); expect(files.telegramFileUniqueId).toBeDefined(); expect(files.storageChatId).toBeDefined(); expect(files.storageMessageId).toBeDefined(); expect(files.fileName).toBeDefined(); expect(files.mimeType).toBeDefined(); expect(files.sizeBytes).toBeDefined(); expect(files.fileType).toBeDefined(); expect(files.uploaderId).toBeDefined(); expect(files.createdAt).toBeDefined(); expect(files.updatedAt).toBeDefined(); }); }); f#gxzimport { describe, it, expect, beforeAll } from "bun:test"; import { config } from "../src/env.js"; describe("Environment Variables Validation", () => { it("config should have all required fields", () => { expect(config).toHaveProperty("botToken"); expect(config).toHaveProperty("storageChatId"); expect(config).toHaveProperty("baseUrl"); expect(config).toHaveProperty("databaseUrl"); expect(config).toHaveProperty("port"); expect(config).toHaveProperty("nodeEnv"); expect(config).toHaveProperty("logLevel"); expect(config).toHaveProperty("rateLimitWindowMs"); expect(config).toHaveProperty("rateLimitMaxRequests"); }); it("config.botToken should return BOT_TOKEN from process.env", () => { expect(config.botToken).toBe(process.env.BOT_TOKEN); }); it("config.storageChatId should be parsed as integer from STORAGE_CHANNEL_ID", () => { expect(typeof config.storageChatId).toBe("number"); expect(config.storageChatId).toBe(parseInt(process.env.STORAGE_CHANNEL_ID, 10)); }); it("config.port should default to 3000 when not specified", () => { expect(typeof config.port).toBe("number"); }); it("nodeEnv should be 'test' or 'development'", () => { expect(["test", "development"]).toContain(config.nodeEnv); }); it("logLevel should default to 'info'", () => { expect(config.logLevel).toBe("info"); }); it("rateLimitWindowMs should default to 60000 when not specified", () => { expect(config.rateLimitWindowMs).toBe(60000); }); it("rateLimitMaxRequests should default to 30 when not specified", () => { expect(config.rateLimitMaxRequests).toBe(30); }); }); )Ax import { describe, it, expect, beforeEach, afterEach, mock, spyOn } from "bun:test"; import { checkRateLimit, cleanupRateLimitCache } from "../src/utils/rateLimit.js"; import logger from "../src/utils/logger.js"; // Spy on logger.warn const warnSpy = spyOn(logger, "warn"); describe("Rate Limiter", () => { beforeEach(() => { warnSpy.mockClear(); // Set custom env variables for predictable tests process.env.RATE_LIMIT_WINDOW_MS = "100"; // 100ms window process.env.RATE_LIMIT_MAX_REQUESTS = "3"; // max 3 requests }); afterEach(() => { delete process.env.RATE_LIMIT_WINDOW_MS; delete process.env.RATE_LIMIT_MAX_REQUESTS; }); it("should allow requests under the limit", () => { const key = "user-1"; expect(checkRateLimit(key)).toBe(true); expect(checkRateLimit(key)).toBe(true); expect(checkRateLimit(key)).toBe(true); expect(warnSpy).not.toHaveBeenCalled(); }); it("should block requests exceeding the limit and log a warning", () => { const key = "user-2"; expect(checkRateLimit(key)).toBe(true); expect(checkRateLimit(key)).toBe(true); expect(checkRateLimit(key)).toBe(true); // 4th request exceeds limit of 3 expect(checkRateLimit(key)).toBe(false); expect(warnSpy).toHaveBeenCalled(); const callArgs = warnSpy.mock.calls[0]; expect(callArgs[0]).toBe("Rate limit exceeded"); expect(callArgs[1].key).toBe(key); }); it("should reset request count after the window passes", async () => { const key = "user-3"; expect(checkRateLimit(key)).toBe(true); expect(checkRateLimit(key)).toBe(true); expect(checkRateLimit(key)).toBe(true); expect(checkRateLimit(key)).toBe(false); // blocked // Wait for window to expire (100ms) await new Promise((resolve) => setTimeout(resolve, 110)); // Should be allowed again expect(checkRateLimit(key)).toBe(true); }); it("should cleanup rate limit cache of expired keys", async () => { const key1 = "cleanup-1"; const key2 = "cleanup-2"; // Populate keys expect(checkRateLimit(key1)).toBe(true); expect(checkRateLimit(key2)).toBe(true); // Run cleanup immediately (none should be expired yet as 100ms hasn't passed) cleanupRateLimitCache(); // Verify still tracked (counts shouldn't reset, e.g., if we consume remaining limits) expect(checkRateLimit(key1)).toBe(true); // request 2 expect(checkRateLimit(key1)).toBe(true); // request 3 expect(checkRateLimit(key1)).toBe(false); // request 4 (blocked) // Wait for window to expire await new Promise((resolve) => setTimeout(resolve, 110)); // Run cleanup cleanupRateLimitCache(); // Since they were deleted from the map, they should be initialized as new records // If they were cleaned up, we should be able to do 3 requests again expect(checkRateLimit(key1)).toBe(true); // 1 expect(checkRateLimit(key1)).toBe(true); // 2 expect(checkRateLimit(key1)).toBe(true); // 3 expect(checkRateLimit(key1)).toBe(false); // 4 (blocked) }); }); e:H-x { "compilerOptions": { // Environment setup & latest features "lib": ["ESNext"], "target": "ESNext", "module": "Preserve", "moduleDetection": "force", "jsx": "react-jsx", "allowJs": true, "types": ["bun"], // Bundler mode "moduleResolution": "bundler", "allowImportingTsExtensions": true, "verbatimModuleSyntax": true, "noEmit": true, // Best practices "strict": true, "skipLibCheck": true, "noFallthroughCasesInSwitch": true, "noUncheckedIndexedAccess": true, "noImplicitOverride": true, // Some stricter flags (disabled by default) "noUnusedLocals": false, "noUnusedParameters": false, "noPropertyAccessFromIndexSignature": false } } v@Px̼yC8\3A/ R>p>VjW_f(0;u~L NWfd Ũ x-R*w0*7 x%100644 logger.jsgT`x]ɲU:SEKdaxzMM@9xo?;5n8.DQ#W7\b'>Fϓ'03)*WdZ@YUc-40000 testH_7VݰY쌈瓊)3Tx  sk8}, "peerltypescript": "^5. C'typescript": ["typescript@5.9.3", "", { "bin": { "tsc": "bin/tsc", "tsserver": "bin/tsserver" } }, "sha512-jl1vZzPDinLr9eUt3J/tB7V6FgNEw9QjvBPdysz9KfQDD41fQrC2Y4vKQdiaUpFT4bXlb1RHhLpp8wtm6M5TgSwW } } VlxJ-drizzle-orm": "^0.29.06, "nanoid": "^5.0.48 } } ;FxB100644 env.jsM g` '~06~>40000 utilsze1SvߕQ{>yZ2B1x'100644 env.test.jsg3S.s(D_ B%uxXwl a*t) x 40000 utilsze1SvߕQ{>yZ2 ~kPx M)Hix8(\6sɭyg-Q{' 5H RK) @x# teleuploader To install dependencies: ```bash bun install ``` To run: ```bash bun run index.ts ``` This project was created using `bun init` in bun v1.3.14. [Bun](https://bun.com) is a fast all-in-one JavaScript runtime. Mm x8{ "name": "teleuploader", "module": "index.ts", "type": "module", "private": true, "devDependencies": { "@types/bun": "latest" }, "peerDependencies": { "typescript": "^5" } } 4B:x(100644 .gitignore-'NW|ݟ0ad/ [100644 CLAUDE.mdvLٝi~~r( 100644 README.md6sɭyg-Q100644 bun.lock?;5n8.DQ#40000 docs?6'x3H۟100644 index.ts{,dTώsx 6Ѧ100644 package.json' 5H RK100644 tsconfig.jsonI}rR%~wڦx&40000 superpowersJJ5&(zx 40000 specsI*9йt菿 ix uz^i u=-