# v2 git bundle d915814277e4c30f21a14c8f52a9e8fbdd84e0d7 refs/heads/bundle d915814277e4c30f21a14c8f52a9e8fbdd84e0d7 HEAD PACKSxNtree 6cb43165ebf341a863b3ebea00aaee39d8de54e3 parent d7b8e9dd086517865ef64ae09610549bf1e9ca68 author MythEclipse 1779062969 +0700 committer MythEclipse 1779062969 +0700 feat: add file routes (download redirect & info) Co-Authored-By: Claude Opus 4.7 jxOtree 8afb941670dbeb0ec568031a6d04cdfc453d72b5 parent 1e29433d5d6ccf3f3982dce5862b10fa9833bb88 author MythEclipse 1779062893 +0700 committer MythEclipse 1779062893 +0700 feat: add upload API handler (multipart & base64) Co-Authored-By: Claude Opus 4.7 icx>tree 5b604121a90eed6694ec3b040754e9a197aca9d4 parent b621a73ca9a0548043082f989f4486b0f84d20f7 author MythEclipse 1779062781 +0700 committer MythEclipse 1779062781 +0700 feat: add Telegram API utilities Co-Authored-By: Claude Opus 4.7 bxAtree e972b38fb43515d4af00a7adb7bc18ed6d2df791 parent db71f2928831867a7ebfed3063cb04791a92318c author MythEclipse 1779062534 +0700 committer MythEclipse 1779062534 +0700 feat: add file validation utilities Co-Authored-By: Claude Opus 4.7 ReӞx>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/SqPqQ2Þ7,faG֑{Ȗ0̖OW^{ B89?/-3M=k;VlYq l`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;l#zQTg JK2sigw8kk$C2ũxI100644 index.jsA0q+I, WXVe100644 schema.js">chF}$མӿ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) + '...' } }); xI100644 files.jsw,#Sh>x&100644 upload.js)Y  )ap5!x6 import logger from '../utils/logger.js'; import { db, files as fileSchema } from '../db/index.js'; import { checkRateLimit } from '../utils/rateLimit.js'; import { eq } from 'drizzle-orm'; export const handleFileRedirect = async (req, ctx) => { const public_id = ctx?.params?.public_id; try { const ip = req.headers.get('x-forwarded-for') || '127.0.0.1'; if (!public_id || !checkRateLimit(ip)) { return Response.json({ error: 'Rate limit exceeded' }, { status: 429 }); } const result = await db.select().from(fileSchema).where(eq(fileSchema.publicId, public_id)).limit(1); if (!result.length) { logger.warn('File not found', { public_id }); return Response.json({ error: 'File not found' }, { status: 404 }); } const file = result[0]; const { getBot } = await import('../utils/telegram.js'); const bot = getBot(); const fileInfo = await bot.api.getFile(file.telegramFileId); const redirectUrl = `https://api.telegram.org/file/bot${process.env.BOT_TOKEN}/${fileInfo.file_path}`; return new Response(null, { status: 302, headers: { 'Location': redirectUrl } }); } catch (error) { logger.error('File redirect error', { public_id, error: error.message }); return Response.json({ error: 'Server error' }, { status: 500 }); } }; export const handleFileInfo = async (req, ctx) => { const public_id = ctx?.params?.public_id; try { if (!public_id) { return Response.json({ error: 'Missing file id' }, { status: 400 }); } const result = await db.select().from(fileSchema).where(eq(fileSchema.publicId, public_id)).limit(1); if (!result.length) { logger.warn('File not found', { public_id }); return Response.json({ error: 'File not found' }, { status: 404 }); } const file = result[0]; return Response.json({ public_id: file.publicId, file_name: file.fileName, mime_type: file.mimeType, size_bytes: file.sizeBytes, file_type: file.fileType, uploader_id: file.uploaderId, created_at: file.createdAt.toISOString ? file.createdAt.toISOString() : file.createdAt }, { status: 200 }); } catch (error) { logger.error('File info error', { public_id, error: error.message }); return Response.json({ error: 'Server error' }, { status: 500 }); } }; xoimport logger from '../utils/logger.js'; import { db, files as fileSchema } from '../db/index.js'; import { nanoid } from 'nanoid'; import { forwardToStorage, getBot } from '../utils/telegram.js'; import { getFileType, checkFileSize, extractFileName, extractMimeType } from '../utils/file.js'; import { config } from '../env.js'; export const handleUpload = async (req) => { try { const contentType = req.headers.get('content-type') || ''; if (contentType.includes('multipart/form-data')) { return handleMultipartUpload(req); } else if (contentType.includes('application/json')) { return handleJSONUpload(req); } return Response.json( { error: 'Unsupported content type. Use multipart/form-data or application/json' }, { status: 400 } ); } catch (error) { logger.error('Upload error', { error: error.message }); return Response.json({ error: error.message }, { status: 500 }); } }; const handleMultipartUpload = async (req) => { try { const formData = await req.formData(); const file = formData.get('file'); const fileName = formData.get('fileName') || (file instanceof File ? file.name : null) || 'file'; if (!file || !(file instanceof File)) { return Response.json({ error: 'No file provided' }, { status: 400 }); } const fileBytes = await file.arrayBuffer(); const fileBuffer = Buffer.from(fileBytes); const mimeType = file.type || extractMimeType({}, req) || 'application/octet-stream'; const fileType = getFileType(mimeType, fileName); if (!checkFileSize(fileBuffer.byteLength, fileType)) { return Response.json({ error: `File size exceeds ${fileType} limit` }, { status: 400 }); } const isDocument = fileName.endsWith('.pdf') || fileName.endsWith('.txt') || !['photo', 'video', 'audio', 'voice', 'animation'].includes(fileType); const result = await forwardToStorage(fileBuffer, fileName, isDocument); const bot = getBot(); const fileInfo = await bot.api.getFile(result.telegramFileId); const uploaded = { publicId: nanoid(), telegramFileId: result.telegramFileId, telegramFileUniqueId: result.telegramFileUniqueId, storageChatId: config.storageChatId, storageMessageId: result.storageMessageId, fileName: fileName, mimeType: fileInfo.mime_type || mimeType || 'application/octet-stream', sizeBytes: fileInfo.file_size || fileBuffer.byteLength, fileType: fileType, uploaderId: 0, createdAt: new Date(), updatedAt: new Date() }; await db.insert(fileSchema).values(uploaded); // Prepare response matching original snake_case fields as expected in task description const responsePayload = { public_id: uploaded.publicId, telegram_file_id: uploaded.telegramFileId, telegram_file_unique_id: uploaded.telegramFileUniqueId, storage_chat_id: uploaded.storageChatId, storage_message_id: uploaded.storageMessageId, file_name: uploaded.fileName, mime_type: uploaded.mimeType, size_bytes: uploaded.sizeBytes, file_type: uploaded.fileType, uploader_id: uploaded.uploaderId, created_at: uploaded.createdAt.toISOString(), download_url: `${config.baseUrl}/f/${uploaded.publicId}` }; return Response.json(responsePayload, { status: 200 }); } catch (error) { logger.error('Multipart upload error', { error: error.message }); return Response.json({ error: error.message }, { status: 500 }); } }; const handleJSONUpload = async (req) => { try { const { file, fileName = 'file' } = await req.json(); if (!file || typeof file !== 'string') { return Response.json( { error: 'Invalid JSON. Must include "file" (base64) and optional "fileName"' }, { status: 400 } ); } const fileBytes = Buffer.from(file, 'base64'); const mimeType = 'application/octet-stream'; const fileType = getFileType(mimeType, fileName) === 'application' ? 'document' : getFileType(mimeType, fileName); if (!checkFileSize(fileBytes.byteLength, fileType)) { return Response.json({ error: `File size exceeds ${fileType} limit` }, { status: 400 }); } const isDocument = fileName.endsWith('.pdf') || fileName.endsWith('.txt') || !['photo', 'video', 'audio', 'voice', 'animation'].includes(fileType); const result = await forwardToStorage(fileBytes, fileName, isDocument); const bot = getBot(); const fileInfo = await bot.api.getFile(result.telegramFileId); const uploaded = { publicId: nanoid(), telegramFileId: result.telegramFileId, telegramFileUniqueId: result.telegramFileUniqueId, storageChatId: config.storageChatId, storageMessageId: result.storageMessageId, fileName: fileName, mimeType: fileInfo.mime_type || mimeType || 'application/octet-stream', sizeBytes: fileInfo.file_size || fileBytes.byteLength, fileType: fileType, uploaderId: 0, createdAt: new Date(), updatedAt: new Date() }; await db.insert(fileSchema).values(uploaded); // Prepare response matching original snake_case fields as expected in task description const responsePayload = { public_id: uploaded.publicId, telegram_file_id: uploaded.telegramFileId, telegram_file_unique_id: uploaded.telegramFileUniqueId, storage_chat_id: uploaded.storageChatId, storage_message_id: uploaded.storageMessageId, file_name: uploaded.fileName, mime_type: uploaded.mimeType, size_bytes: uploaded.sizeBytes, file_type: uploaded.fileType, uploader_id: uploaded.uploaderId, created_at: uploaded.createdAt.toISOString(), download_url: `${config.baseUrl}/f/${uploaded.publicId}` }; return Response.json(responsePayload, { status: 200 }); } catch (error) { logger.error('JSON upload error', { error: error.message }); return Response.json({ error: error.message }, { status: 500 }); } }; Dt xh100644 file.js.%L$PESO ~100644 logger.jsgT`x]ɲU:SE100644 rateLimit.js ŵ_}gM4100644 telegram.js3:ߎْZ I ;ްcx0const FILE_TYPES = { document: 2 * 1024 * 1024 * 1024, // 2GB photo: 10 * 1024 * 1024, // 10MB video: 2 * 1024 * 1024 * 1024, // 2GB audio: 200 * 1024 * 1024, // 200MB voice: 200 * 1024 * 1024, // 200MB animation: 2 * 1024 * 1024 * 1024 // 2GB }; export const getFileType = (mime, caption) => { const mimeUpper = mime?.split('/')[0]?.toLowerCase(); const captionLower = caption?.toLowerCase(); if (mimeUpper === 'video') return 'video'; if (mimeUpper === 'audio') return 'audio'; if (mimeUpper === 'document') return 'document'; if (mimeUpper === 'image') return captionLower?.includes('gif') ? 'animation' : 'photo'; if (captionLower?.includes('voice')) return 'voice'; if (captionLower?.includes('animation')) return 'animation'; return mimeUpper || 'document'; }; export const checkFileSize = (sizeBytes, fileType) => { const limit = FILE_TYPES[fileType] || FILE_TYPES.document; return sizeBytes <= limit; }; export const extractFileName = (msg, request) => { if (request?.headers?.['x-file-name']) { return request.headers['x-file-name']; } return msg.document?.fileName || msg.photo?.slice(-1)[0]?.fileName || msg.audio?.fileName || msg.voice?.fileName || msg.animation?.fileName || 'file'; }; export const extractMimeType = (msg, request) => { if (request?.headers?.['x-mime-type']) { return request.headers['x-mime-type']; } return msg.document?.mimeType || msg.photo?.slice(-1)[0]?.mimeType || msg.audio?.mimeType || msg.voice?.mimeType || msg.animation?.mimeType || 'application/octet-stream'; }; <1xSMO0 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!}x$import { Telegraf } from 'telegraf'; import logger from './logger.js'; import { config } from '../env.js'; const bot = new Telegraf(config.botToken); const TELEGRAM_API_URL = `https://api.telegram.org/bot${config.botToken}/`; export const forwardToStorage = async (fileChunk, fileName, forceDocument = false) => { try { const caption = forceDocument ? `📁 ${fileName}` : fileName; const input = forceDocument ? { document: fileChunk, caption } : { photo: [fileChunk], caption }; const result = await bot.api.sendPhoto(config.storageChatId, input); logger.info('File forwarded to storage', { fileName, message: result.message_id }); return { telegramFileId: result.photo?.slice(-1)[0]?.file_id, telegramFileUniqueId: result.photo?.slice(-1)[0]?.file_unique_id, storageMessageId: result.message_id }; } catch (error) { logger.error('Failed to forward file to storage', { fileName, error: error.message }); throw error; } }; export const getFileInfo = async (telegramFileId, telegramFileUniqueId) => { try { const result = await fetch(`${TELEGRAM_API_URL}getFile`); const data = await result.json(); if (!data.ok) { throw new Error(data.description || 'Telegram API error'); } const fileId = data.result.file_id === telegramFileId ? telegramFileId : telegramFileUniqueId; const fileResult = await fetch(`${TELEGRAM_API_URL}getInfo`, { method: 'POST', headers: { 'Content-Type': 'application/json' }, body: JSON.stringify({ file_id: fileId }) }); const fileInfo = await fileResult.json(); if (!fileInfo.ok) { throw new Error(fileInfo.description || 'Telegram info error'); } return { file_size: fileInfo.result.file_size, mime_type: fileInfo.result.mime_type, file_path: fileInfo.result.file_path }; } catch (error) { logger.error('Failed to get file info', { error: error.message }); throw error; } }; export const getBot = () => bot; [(x340031QHI+I-.*fuGX7kqs_fQWWS1z.T*KIb2u{_҂dtzy}iu.O rDxJimport { describe, it, expect } from "bun:test"; import { db, files } from "../src/db/index.js"; import { files as schemaFiles } from "../src/db/schema.js"; describe("Database Layer", () => { 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); }); }); )AxVimport { describe, it, expect } from "bun:test"; import { getFileType, checkFileSize, extractFileName, extractMimeType } from "../src/utils/file.js"; describe("File Utilities", () => { describe("getFileType", () => { it("should classify video mime types as video", () => { expect(getFileType("video/mp4", "")).toBe("video"); expect(getFileType("video/quicktime", "")).toBe("video"); }); it("should classify audio mime types as audio", () => { expect(getFileType("audio/mpeg", "")).toBe("audio"); expect(getFileType("audio/ogg", "")).toBe("audio"); }); it("should classify image mime types based on caption", () => { expect(getFileType("image/jpeg", "my photo")).toBe("photo"); expect(getFileType("image/png", "cool image.png")).toBe("photo"); expect(getFileType("image/gif", "funny.gif")).toBe("animation"); expect(getFileType("image/png", "funny gif")).toBe("animation"); }); it("should classify voice and animation based on caption", () => { expect(getFileType("application/octet-stream", "this is a voice note")).toBe("voice"); expect(getFileType("application/octet-stream", "cool animation")).toBe("animation"); }); it("should default to mime first segment or document", () => { expect(getFileType("application/pdf", "")).toBe("application"); expect(getFileType(null, "")).toBe("document"); }); }); describe("checkFileSize", () => { it("should allow files under the size limit", () => { expect(checkFileSize(5 * 1024 * 1024, "photo")).toBe(true); // Photo limit is 10MB expect(checkFileSize(1 * 1024 * 1024 * 1024, "video")).toBe(true); // Video limit is 2GB }); it("should block files exceeding the size limit", () => { expect(checkFileSize(15 * 1024 * 1024, "photo")).toBe(false); // Photo limit is 10MB expect(checkFileSize(3 * 1024 * 1024 * 1024, "video")).toBe(false); // Video limit is 2GB }); it("should fall back to document limit if fileType is unknown", () => { expect(checkFileSize(1 * 1024 * 1024 * 1024, "unknown")).toBe(true); // Document limit is 2GB expect(checkFileSize(3 * 1024 * 1024 * 1024, "unknown")).toBe(false); }); }); describe("extractFileName", () => { it("should extract file name from headers if present", () => { const req = { headers: { "x-file-name": "custom.txt" } }; expect(extractFileName({}, req)).toBe("custom.txt"); }); it("should extract file name from various message attachment types", () => { expect(extractFileName({ document: { fileName: "doc.pdf" } }, null)).toBe("doc.pdf"); expect(extractFileName({ photo: [{ fileName: "low.jpg" }, { fileName: "high.jpg" }] }, null)).toBe("high.jpg"); expect(extractFileName({ audio: { fileName: "song.mp3" } }, null)).toBe("song.mp3"); expect(extractFileName({ voice: { fileName: "voice.ogg" } }, null)).toBe("voice.ogg"); expect(extractFileName({ animation: { fileName: "anim.gif" } }, null)).toBe("anim.gif"); }); it("should return default filename if not found", () => { expect(extractFileName({}, null)).toBe("file"); }); }); describe("extractMimeType", () => { it("should extract mime type from headers if present", () => { const req = { headers: { "x-mime-type": "text/plain" } }; expect(extractMimeType({}, req)).toBe("text/plain"); }); it("should extract mime type from various message attachment types", () => { expect(extractMimeType({ document: { mimeType: "application/pdf" } }, null)).toBe("application/pdf"); expect(extractMimeType({ photo: [{ mimeType: "image/jpeg" }, { mimeType: "image/png" }] }, null)).toBe("image/png"); expect(extractMimeType({ audio: { mimeType: "audio/mpeg" } }, null)).toBe("audio/mpeg"); expect(extractMimeType({ voice: { mimeType: "audio/ogg" } }, null)).toBe("audio/ogg"); expect(extractMimeType({ animation: { mimeType: "video/mp4" } }, null)).toBe("video/mp4"); }); it("should return default mime type if not found", () => { expect(extractMimeType({}, null)).toBe("application/octet-stream"); }); }); }); PcxXmo6_A 8$E!$uɐӆF"UJ;z[5 "xûSX I@ŒMOCLķ}% L3ɒLȈ7)Pw{YJlAd*tB0$?mPM'TI^,vkHrlo|G'kO MBR1F@Y好ofMHI&! |2Ikd2$nOe"1V}b< MQѴ4L"<'QTkcBV3I3bo!DU@9nυ*C>l:.k@"IY7l;D[ SR M~[!@,`5ᆭJߪ{+Qh ?R d ̭h^A¤=wͳs>hNOՂ-+ųz>RJ7 1tub}U'Zw"wf|s쟞J;.C8L !W;DH#ttS& @Z._]gܶmfmrnB\iB$Brr8xMr W'pk&γ< ~c(bxV 0t.DQNCSYU9nL:-CENl2V1U6=,k\+*PDz#'"Y{KzUCF+), yW 5eކE&G &;\ 3Exݕvuڶn@UZ{\ ommY-esS_y*>$V:ɻQ-&jiRȴMg9SQK@{i3'yUL87pl5/h9;6tTߖ Tw 6́&88{t0U<5( GnNp}4|;""*GD5H=4+YNϥ:3}tDNhMt#OTA+qMB5 G`o{#fP~w}y~L&eӝM"XFg|g,kaW0Zh:=_u͖lyl)Tkzm~Q, ϰo|o ^GG/^DH_p5ݞ q)/*(ęoӮ#]Fnn'۸ZFVf)Ra;K[}fgAԿk.0?GpǴx 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:Hxvimport { describe, it, expect, beforeEach, afterEach, mock, spyOn } from "bun:test"; import logger from "../src/utils/logger.js"; import { config } from "../src/env.js"; // Mock Telegraf and fetch mock.module("telegraf", () => { return { Telegraf: class { constructor(token) { this.token = token; this.api = { sendPhoto: mock(() => Promise.resolve({ message_id: 12345, photo: [ { file_id: "photo_id_low", file_unique_id: "unique_id_low" }, { file_id: "photo_id_high", file_unique_id: "unique_id_high" } ] })) }; } } }; }); const infoSpy = spyOn(logger, "info"); const errorSpy = spyOn(logger, "error"); describe("Telegram API Utilities", () => { let forwardToStorage, getFileInfo, getBot; beforeEach(async () => { infoSpy.mockClear(); errorSpy.mockClear(); global.fetch = mock(() => Promise.resolve(new Response(JSON.stringify({ ok: true })))); // Import dynamically so mocking is applied first const telegramUtils = await import("../src/utils/telegram.js"); forwardToStorage = telegramUtils.forwardToStorage; getFileInfo = telegramUtils.getFileInfo; getBot = telegramUtils.getBot; }); afterEach(() => { delete global.fetch; }); describe("getBot", () => { it("should return the telegraf bot instance", () => { const bot = getBot(); expect(bot).toBeDefined(); expect(bot.api).toBeDefined(); }); }); describe("forwardToStorage", () => { it("should forward photo to storage chat and return file details", async () => { const chunk = Buffer.from("fake photo data"); const fileName = "test_photo.jpg"; const result = await forwardToStorage(chunk, fileName, false); expect(result).toEqual({ telegramFileId: "photo_id_high", telegramFileUniqueId: "unique_id_high", storageMessageId: 12345 }); expect(infoSpy).toHaveBeenCalledWith("File forwarded to storage", { fileName, message: 12345 }); }); it("should handle error when forwarding fails", async () => { const bot = getBot(); bot.api.sendPhoto = mock(() => Promise.reject(new Error("Telegram send failed"))); const chunk = Buffer.from("fake photo data"); const fileName = "test_photo.jpg"; await expect(forwardToStorage(chunk, fileName, false)).rejects.toThrow("Telegram send failed"); expect(errorSpy).toHaveBeenCalledWith("Failed to forward file to storage", { fileName, error: "Telegram send failed" }); }); }); describe("getFileInfo", () => { it("should fetch file details successfully", async () => { global.fetch = mock((url, init) => { if (url.endsWith("getFile")) { return Promise.resolve(new Response(JSON.stringify({ ok: true, result: { file_id: "some_file_id" } }))); } else if (url.endsWith("getInfo")) { return Promise.resolve(new Response(JSON.stringify({ ok: true, result: { file_size: 98765, mime_type: "image/jpeg", file_path: "photos/file_0.jpg" } }))); } return Promise.reject(new Error("Unknown URL")); }); const result = await getFileInfo("some_file_id", "some_unique_id"); expect(result).toEqual({ file_size: 98765, mime_type: "image/jpeg", file_path: "photos/file_0.jpg" }); }); it("should handle error when getFile fails", async () => { global.fetch = mock(() => Promise.resolve(new Response(JSON.stringify({ ok: false, description: "Bad Request: file_id invalid" })))); await expect(getFileInfo("invalid_file_id", "invalid_unique_id")).rejects.toThrow("Bad Request: file_id invalid"); expect(errorSpy).toHaveBeenCalled(); }); }); }); x import { describe, it, expect, mock, spyOn, beforeEach, afterEach } from "bun:test"; import logger from "../src/utils/logger.js"; // Mock db const mockInsert = mock(() => ({ values: mock(() => Promise.resolve()) })); mock.module("../src/db/index.js", () => ({ db: { insert: mockInsert }, files: {} })); // Mock nanoid mock.module("nanoid", () => ({ nanoid: () => "mocked-nanoid-id" })); // Mock telegram utils mock.module("../src/utils/telegram.js", () => ({ forwardToStorage: mock(() => Promise.resolve({ telegramFileId: "tg-file-id-123", telegramFileUniqueId: "tg-unique-id-abc", storageMessageId: 98765 })), getBot: () => ({ api: { getFile: mock(() => Promise.resolve({ file_id: "tg-file-id-123", file_size: 1000, mime_type: "image/jpeg" })) } }) })); describe("Upload Route Handler", () => { let handleUpload; beforeEach(async () => { mockInsert.mockClear(); const uploadRoute = await import("../src/routes/upload.js"); handleUpload = uploadRoute.handleUpload; }); it("should reject unsupported content types with 400 status", async () => { const req = new Request("http://localhost:3000/api/upload", { method: "POST", headers: { "content-type": "text/plain" }, body: "plain text data" }); const res = await handleUpload(req); expect(res.status).toBe(400); const body = await res.json(); expect(body.error).toContain("Unsupported content type"); }); it("should process JSON upload (base64) successfully", async () => { const req = new Request("http://localhost:3000/api/upload", { method: "POST", headers: { "content-type": "application/json" }, body: JSON.stringify({ file: Buffer.from("hello world").toString("base64"), fileName: "test.txt" }) }); const res = await handleUpload(req); expect(res.status).toBe(200); const body = await res.json(); expect(body.public_id).toBe("mocked-nanoid-id"); expect(body.telegram_file_id).toBe("tg-file-id-123"); expect(body.telegram_file_unique_id).toBe("tg-unique-id-abc"); expect(body.file_name).toBe("test.txt"); expect(body.file_type).toBe("document"); }); it("should reject JSON upload without file key", async () => { const req = new Request("http://localhost:3000/api/upload", { method: "POST", headers: { "content-type": "application/json" }, body: JSON.stringify({ fileName: "test.txt" }) }); const res = await handleUpload(req); expect(res.status).toBe(400); const body = await res.json(); expect(body.error).toContain("Invalid JSON"); }); it("should process multipart upload successfully", async () => { const formData = new FormData(); const fileBlob = new Blob([Buffer.from("multipart hello")], { type: "text/plain" }); formData.append("file", fileBlob, "test_multi.txt"); const req = new Request("http://localhost:3000/api/upload", { method: "POST", body: formData }); const res = await handleUpload(req); expect(res.status).toBe(200); const body = await res.json(); expect(body.public_id).toBe("mocked-nanoid-id"); expect(body.file_name).toBe("test_multi.txt"); }); }); IU*-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̼yC8q6ݵ3_2On P(I-.abW]|Gdr&bpxk`l`#ms4x_p>VjW_f(0;u~L NWfd Ũ ux__Kze1SvߕQ{>yZ2 x%100644 logger.jsgT`x]ɲU:SEKd=xzMM@xo?;5n8.DQ#W7\b'>Fϓ'03)*WdZ@YUc-40000 testH_7VݰY쌈瓊)3x  sk8}, "peerltypescript": "^5. C'typescript": ["typescript@5.9.3", "", { "bin": { "tsc": "bin/tsc", "tsserver": "bin/tsserver" } }, "sha512-jl1vZzPDinLr9eUt3J/tB7V6FgNEw9QjvBPdysz9KfQDD41fQrC2Y4vKQdiaUpFT4bXlb1RHhLpp8wtm6M5TgSwW } } V3xJ-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%vxXwl a*t) x 40000 utilsze1SvߕQ{>yZ2 ~kQx M)Hjx8(\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 uz7;)q,}04*