# v2 git bundle cf79a1f1955f6a6eb4441fd4a9cc841a3528a1b1 refs/heads/bundle cf79a1f1955f6a6eb4441fd4a9cc841a3528a1b1 HEAD PACKxtree 1d1c4f213a385bfc81f9f19184966923a26c5be4 parent 3f4e697733039b9b4383d098d97da9a79c8141e8 author MythEclipse 1779064141 +0700 committer MythEclipse 1779064141 +0700 style: format and lint codebase using Biome v2 `T͐xtree a4dcfd12d72020fb50f9c15fc26853cb845dc75e parent 9c5a855f7d21d97ef83d8acd063a02aafbb5fea8 author MythEclipse 1779064026 +0700 committer MythEclipse 1779064026 +0700 feat: migrate entire codebase to TypeScript BVxtree 452583dcb0bb3ec8615c0c32d4950456b31849ab parent 252b2e4a1f7783c7a6789aa5d4c086ab1d500a44 author MythEclipse 1779063802 +0700 committer MythEclipse 1779063802 +0700 chore: configure typescript, biome, and package scripts mYx tree a4cdd6c1e107eebe38d3711d658c0767bc3dc301 parent 434905313c1986ec37652a09f31aabca0b2aaa8e author MythEclipse 1779063390 +0700 committer MythEclipse 1779063390 +0700 test: isolate module mocking and add sequential test script `[x^tree 6d3325bbc2799882aeca9668583b01e0efd79e48 parent 99b820709d01052527a3ce4734ff212c200bb67d author MythEclipse 1779063305 +0700 committer MythEclipse 1779063305 +0700 refactor: replace TypeScript with ESM JavaScript Remove index.ts and tsconfig.json, update package.json, and install dependencies. Co-Authored-By: Claude Opus 4.7 Ӧ4x_tree d83fa65f7a2c7ebc08af96039beb97a10d75a504 parent 4996d7548a1b932d1fb8d01d46db3bf1f8973800 author MythEclipse 1779063275 +0700 committer MythEclipse 1779063275 +0700 feat: setup HTTP server and bootstrap application Setup HTTP server with Bun.serve and bootstrap Telegram bot and other services. Co-Authored-By: Claude Opus 4.7 ˛xdtree 69ed9ba9274b53a95e804df5690a8d8245e6f6d1 parent be93a06918531e07905dc3d61a685c7ca99ebc99 author MythEclipse 1779063197 +0700 committer MythEclipse 1779063197 +0700 feat: add Telegram bot handler Implement Telegraf bot instance with file upload/forward handlers and mock test verification. Co-Authored-By: Claude Opus 4.7 o+x}tree b804e9db8018d05f26a686c154070ea10e0234d1 parent d915814277e4c30f21a14c8f52a9e8fbdd84e0d7 author MythEclipse 1779063055 +0700 committer MythEclipse 1779063055 +0700 feat: add health check route Implement handleHealth endpoint for Bun.serve to verify DB connection. Co-Authored-By: Claude Opus 4.7 {xNtree 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,TQRf~n^Vq~ëOD.W4'=ܝrw//LUi^N~r6t̫O%kc~UnU%L @!%?]w]^l܏*5 19;1jUs(Q2Q}Zs'Sꊓ3Rs sWH }iEyJ %3}šM;s5VL -I-.aԡ`Ol7.Xog89?/-3ܕЗ[g I;Ec*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  #n'xu{ "$schema": "https://biomejs.dev/schemas/2.4.15/schema.json", "assist": { "actions": { "source": { "organizeImports": "on" } } }, "linter": { "enabled": true, "rules": { "recommended": true, "style": { "noNonNullAssertion": "off" }, "suspicious": { "noExplicitAny": "off" } } }, "formatter": { "enabled": true, "formatWithErrors": false, "indentStyle": "space", "indentWidth": 2, "lineWidth": 100 }, "javascript": { "formatter": { "quoteStyle": "single", "semicolons": "always" } } } ƭhxͽٲ̒.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{1cӆ6c7RTU7x&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"~gKsr⿶@_lNȈAj=0f{*I#}Y/>צW/a"g|HM^{o+/xOO0|9BE{BFָ O(KM<5y FGÛ)t`2Dg$AOG"JRfTT b#bmg8PǣB*lCWwj;[*2}Wvl|URueWJ4ܬw;l\ltVjeu&N|(Y1L;lH3&XF񍳒h&xF8Ka_w>c9S@%نh ٚpN q5*!7$kT)O2ad:WA  _a@9kR;l˘7d;(u`$0ZI<_)11dkc jAx?DMQd4XLAx\O>Cmg~}")%1CpC0# 윍ua +s@ZRpt 3KDk# Vx4jȏVX]@jlkbDvߠ4`!uC~^ g$uB*$7||8F|to\Wd%gwo*OG!cTHynV޹ܦr@M[~]S{FF2VΒl!(`|s _gcB+wohhN>Ę14\>xkpJc @R]K޻mb64WxQB4o_Q2=OmeTՅ]y0dOHrs(NFQWVfUWuI ߬r!*9K Cu&赝H0;mcd n9䮱Étk\$LSDiI;; rx( MS,2ti5ɱ%M@|2 N )jbϦQI6-$Q,rx9̟<okh{_>GnnB'v*DJCSx P s};qdԆFQbsSN4deJ)dۯ)Xquc'bMĴ̺Cϼ\RF'|GV@cݦi P3fiϥԊƦ! :Hmu t=R"lCJn?c-uuPԽ@{m/I 51=ج9YBNJ4Mm\uOB!X|HxI100644 index.tsvQfzZ x.v100644 schema.ts҄ @H\p,F)3ѶxMO;0&qc&Xi)i!v: !54JZ L BrJ$*ТdG.2}r|Eðȕ(SHAP)w1@c `ݘ cM9R1# Q۵ê4ĦO9 = 킿ޝtT%%B)nAxMo0 v9lِ-$dŋ:CN^yIJz:=M~mzl2+Pa8@&XBf=ԲJp @$5ĵ+!)\\wXm]cMOJ=|- 6@X0)y>X lyPau,uj%uR^j`#g,mRX{~AOܨV)_~uƢ'y?pJl~؂媉z3?f38;=ceL+Rq,hD%vx1jj;%'EvmJHCJsSW+oжynlmJMF gYxTao0_J QI(hcuHN&B‘N) sZ}#wޝ )+%*z 圕6 Z^P FJ":*ZJ*XQm{mZl'hC3 =?a˪˴R)SVPwN}FgpθmM<[ZH-C8⫦q. }m7r;G6Mw5:ݵlf9S+jO4g[j~*NܷVR.`Loi︦cQO82Q#OuRJi}k΄NNFLU{I$మ!4g5ìfAp<x:nmq|Kf5soԔm wHf)hIR! zm'6{U@{5_I7b{hPx}SMo0 Wf0v[ѥ4PlH$+Q*q6 ||A+,# jZ|1qߔ|\(yQJw.p-kEOXqemT5eTp)|ŧg-j4#u\<&d=+D9 ܆C>޻([$9|ul~oـY9e=Η ^zidJE-m\UJ_Di>DV6J2ZLh#;fJ5Xbo]^kd dĵp̗r_Wwp{ vѪ; &XąPcQl˒ :+-ŵ'(F:x ^#>=: |mT.w N0$zU<<ҹwĜDEZe"e醞55]a渒`Z)M-}TL19Įx340031QHI-+)fx(hZ sh͛BZ59% E}q-wS_F9C'QW^:ٟlj54 _*ԶxV import { eq } from 'drizzle-orm'; import { db, files as fileSchema } from '../db'; import logger from '../utils/logger'; import { checkRateLimit } from '../utils/rateLimit'; type RequestWithParams = Request & { params?: { public_id?: string; }; }; export const handleFileRedirect = async (req: RequestWithParams): Promise => { const public_id = req.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'); const bot = getBot(); const fileInfo = await bot.telegram.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: any) { logger.error('File redirect error', { public_id, error: error.message }); return Response.json({ error: 'Server error' }, { status: 500 }); } }; export const handleFileInfo = async (req: RequestWithParams): Promise => { const public_id = req.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: typeof file.createdAt === 'string' ? file.createdAt : (file.createdAt as Date).toISOString(), }, { status: 200 }, ); } catch (error: any) { logger.error('File info error', { public_id, error: error.message }); return Response.json({ error: 'Server error' }, { status: 500 }); } }; < dx= import { sql "B7Health = async (_req: RequestA+try { await db.execute(sql`SELECT 1`); status: 'ok' }, { status: 200 0Health check failed', { 5status: 'error' ; O>IxWo6_q H\=8Kuŀ KZ4 0 .-67TI*Kv膾%ɻ}VBjX'\60LΎX(fc* ~Η"FX!|==%Xb1{-I/YE?jVR%KA 8dx&~jң CcLSU} /a}~5xh%[RRP2t,MS 1}64˦*MԬ&RbӂhFYGt#2ȺL3+Z*zR%ˉf/oͻ(`Sf BN ᪩M h2&%ܠ;!a?،[Jݨ <,[6R4CSf/JƝ#R/hwOg<;`c j`4{c0xQl? 'ĮH>鶆GlTQZ20O mS13 5qcq)K~}qlxm)Lr%\Eү:-_4ːJ8^79tdf xgkz;5-g5O1N#r4~Ӫʡb8ݽIvd3tWz9nMq?ښ+4 b7"o*38C$edu1cױIZ H D̝S{YeSэ6#q$Un+nWq_LhWIqۈsש{ e2_yӞbdGYN!jPorӋt&pvK3k{TePT.g?-6dӁ‘xIWe&93GХm1Ŀ9ejMnƗKP%Ɗ;AM5urTJvvm]GˇM `G-c sӮ #]Gȴsx]bqh& .cR;Q1JJwi8H7cݫ>Row3 6W~wp&G?18;} #{[@#a߈0ħ x340031QHI+)f;]L tpB䧧MMK:H%Lťi@%dfԵ컳Ȥ;?msBԜ\LhXCM7Tvܚw;mxT]o0}ϯaJȇD"jI4Eknk-Yk$D'{}|l.\w?|{72 rd'I@vMfGH(yC|2!x4L> 4]K%}v ƣG #BP"7hI&s )!]ߦlR)F+P"m (*E}YpkWRi H(;-O[N뺊v;#^, .Fl T%v=}lMס%x +hHxT;t% =7J|BjSmΕ5ZM[Mv{{>2_$*ɲrW>@hې1!PRQ-挀[A]^N9r> gO6/8567ѭ D@}gH >NWcw: Hc(); export const checkRateLimit = (key: string): boolean => { 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 = (): void => { const now = Date.now(); const keysToDelete: string[] = []; for (const [key, record] of rateLimitMap.entries()) { if (now > record.reset) { keysToDelete.push(key); } } for (const key of keysToDelete) { rateLimitMap.delete(key); } }; ܥlĺxVKnHI2[j#81leRlݜf+p1gr!? vUzHVB*ÂnZZ( P Mw/غsI){XƩ}E5 n9pz -`<9󿯞Z>XzVRuNfKJ\O~NWqEeA2 /#2vL< y g#[ݎ+46nMa0/Z˲ai b]]MQgMT"ٶ\SMCI%sOaԲ'w .Ԋ Oad+HTf2ɎQ rw]9XBun~}\i{#ti^ F?+csl' 栄o |1TRFޗ,K;wi*>M hݓ" >7OaqWum-B*FU3$`LCcѐ0<|hCL_OC4Ă"Qd?ކKv ''N%V@H&6[Wa8$#ua \p &a@\RAz(/Y_]U@7׋KJr*<3k \:y 3_.߼N؅1Fnq!:Ch~Ӄ-uTѲ|:С|ƾ)Q\mەK5W_&p1 x340031QH/).)J,+I-.+)f82U˩ܒ&^.nS\WAkSWB"ElRશjS5 z= _*Լ2pQnX!wiPei9puJS_^haG~ک*G}(gLtp@f&dUnءqg66R!>JCU%df"<ci%h~5^iKRsRӋsj]~kzwBՖ'UFVLRe|ncN@"bxTۊ0}W̛p>'l&le>RdyHBtCȿWizم8u4gHs\ޚ7BSJj ' E}y6RBj4T sg hrbmt$T c#p,2iC ` "q]Ky'{0cZw䫰r$(@j჈ &^Czk;O/"ᶽV."C,ggI9%0Y8z$ \ i)BuYGK4&[P'r1DfԴQmRQ Q40D~fsxLvewy6*#"ξ^̀G37`]*F_|=>|bglvLeǒ k̰H4=AęT&Tqѯ*/銸Qc)2jK1#JҠx\uPy!AT!YE)R2E).\,TBopyyi2 ;QQ /j1ύ`3l& !y]2IV[q+D3`Je1ycnÆb>ic.`k^68a<F8D$i f4v-la([iYp(LX.}wzmы=:>>F6ûfA km9"d4*­2-k~+k ɨ)$|͔-O9S@ǖsSho{e6>T)DZ40p qPRi϶2uJacI0Bb*HMr4Q ryh{Eь:i]#dRVE۟}i hxTn@`$j"ШU E **;U̎&{װ&`lyޛy|敢x]K3@ v2;„4!ѴEc 6&$ {F=TW*l6RZkɣJVb]:=<kVV|sQ@"1^zvBKES>,";;Ts٤X|cqtڰy!7,U$ЍauJ n-NZR 1níۥK>߃݇hVp5/ϣ.r # n+ *p񄐃 j"k Heqz|v;4Z hf3HHuvtus\{,E߇ۆ""M U}V+mMHC[;|?ZԲ_鐔RCD1ޖ*i.M#G'M){^ƶIWVQi\(? x< "Nexpect, it } from 'bun:test'; import { config } from '../src/env'; describe('{ ', () => { it('&' 'botToken'=%'storageChatId'=% 'baseUrl'=% 'databaseUrl'=%'port'=% 'nodeEnv'=% 'logLevel'=%'rateLimitWindowMs'=%&'rateLimitMaxRequests'); }); it('8'O'1H'"'number'd'5'port).toBe('number'P'test', 'development'x'info'); }); it('}<'\ #'<'\*{+xWMo6WMŮb#A`)E=%1HE{9\V!͛p6IV{!ijhx)[P3w5@yl{Y 2׀]h:eUJ5)5 h2y 1>/- ;क}.U Hx50*]4,ncWhr RD_\O/~9=G;//_ǃwNSDfDCB(F(6u@SNi躿pvWwncdo-ϬM(a;$X\GED%'7M-ARD*m Y%T3/x%XLW p{%,hd.AO}S,vje3R!}Y& Sef=UpM.BE!)KzcpU+EQG% doi/[W:}%Sp9di<5]'uw36Z4&I<!KG@֩"'~ma,`Ew4#M])6U*s윦PȺruVr΄`Ig4Æ)~9rR ;ۣxBlC_? Vr}D4-IȤixR8`9c9BbO+ #95}8M&rMMt7&\ϸZ41'WqX6ٝZ=t^M&e)\VwŊ67ugfkN%ThcjD { 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) }); }); ف xSafterEach, beforeEach, describe, expect, it, spyOn } from 'bun:test'; import logger from '../src/utils/logger'; import { checkRs''../src/utils/rateLimit'7!'warn'); describe('Rate Limiter'4'100'<'3' '%''user-1''PXP $';''user-2''PXP'Rate limit exceeded'k6'2' = 'user-3''PXP,'|/'!)'cleanup-1'; const key2 = 'cleanup-2'+_xWn6}W̛d{xEM 6 P#,2n"ex 9rΜ9C/Vgo.'`59c*KlTqqWVƛ9bN@ i)WbQwK7E UƋJ\-X, 9[q]H Egfh+*0n>C8@*})Fb).X2rbN茫ȎK/s-MV(u&\Z,B{<5EF%*?bԛآRl+,Ͽh1Ufa`qAc'*?Tn}P79-;k1gu;/3MpʛbO[ e3,KYNcx9>?^_Qkǩ5wLn $VF3!rE8\Jm_hTN^# a^p֠cϬsyExڈ^wUA`ͻ5OB{T*P`[<߃vZ \+#U$/}Y Ywaֽibk -8(VtZc˔ iYs`S2ů2Y剗'?G P[i&bۓ7=oH3K S.02hEkҲM3DxXβ(MP.qƴoA3ž܍+GgP̗UbAbt{$L Yce[C5u7 rrtgh7 }6n ?T,GRpBF' ﬒^MWFQSƜ4&sևO%}HMC;:ՑkT!֨J, KTbD9DGJ{LgLt \Υan(Y)wax|n (3r_۶tf|Pih 鱍+8&5#Ua=[.3Qһ:vזwa]|_1Z.oJnq^'nfX2! Q0iHRo|l%/ \S]t]-Ч+=ء݉;w fz(iשϙPۏh~~'f~0ՇzTplCBjIg4?UJ;xWYo6~_1oM \Nr N ]T쭱3aG@ؕ89RrB֍@=ڟJ()TJ+ L/,} )akkjV<:=_,^*vH.C'pW OBVdR:,:>a$b$dAYmVaeYlWE.uQ Uy5"=bWj[{VRx7zTKL'H8wG-zoNbӪ\oV~_Ro7KNb\>z$J}c;xQ#uqB7x5lrlhT[i}.5p*3y '$Zxw "YS&Yv @aчFQ;z_ڱB۰AW Ldt9Q {3}Pؘ\em09>q!ncܲ,tyzi081MEC!PIִg4ծmVGB-<=8 :*ܺ-~$/9z߬\Rq~F)#uj[ xع- f@Ƿ" ^QBQm?$HP /ߡŔX_n|҂˺r$7GS}fd-F9dhl%E1D l)io'o^=M% ׭R`D(Y /ιBs[7rLu6Gz6ヌG \hPaOZu%tZ(|/uCSRG*x-> 0O:ޘ_쎍QrP̈\&1YS󐢁Z ?Ghǚ^e2[e#p~&{ڗ )S  kaDz_,&L 4wQ{QWq>(U54vƎGCd{1v$WsLn|WNzxD/֦ xr{ "compilerOptions": { "lib": ["ESNext"], "module": "ESNext", "target": "ESNext", "moduleResolution": "Bundler", "moduleDetection": "force", "strict": true, "skipLibCheck": true, "allowSyntheticDefaultImports": true, "forceConsistentCasingInFileNames": true, "types": ["bun-types"] }, "include": ["src/**/*", "test/**/*"] } nhxVj}p}V e&13=R*ʄ e)M$mxQ,&1.8.3/schema.json", "organizeImportsd, 0 RD } } } .g x9100644 bot.ts7->{س|40000 db iNnٟMA|100644 env.tsv[#[u '100644 index.tsoNwJ% ֮40000 routesN֪8TcOd840000 utils="~ǽCkQ+qxMimport { Telegraf, type Context@'[2 !T(Nw)>mtry { ^ .message.document ? 'document' :!photo ? 'photo' :! ? 'video' :! ? 'audio' :!6oice ? 'voice' : 'animation'; const fileObj =kX;const fileName =0.Z..0. ..9const maxSize = fileType === 'photo' ? 10 * 1024 * 1024 :!i ? 200 * 1024 * 1024 :!ivoice' ? 200 * 1024 * 1024$>%eR B $0 O o 1 = / 5I i =  # !2  }; Y ? 7 P% 8 a x &= publicId, fileType, fileName, uploader: ctx.from.id }); @7 e F} } OL y !e! + '...'*gxI100644 index.ts֗`zh @6~T100644 schema.ts%Sao/^9eR / i:x d x[import { pgTable, text, bigind1*import type { InferSelectModel, InferInser*n{ Yx( 72K n! + '...' } }); xk9Ae27DOjJT+d$䤺ed& yO l8ciFL= Hnncexn100644 files.tsGˁ-AL8Q=100644 health.tsA n=@6wu6[100644 upload.ts|;krs'c\utuCx[*3uxS/+/.".select().from(fileSchema)*0˳N'Location': redirectUrl }.select().from(fileSchema)*0{ &C e " $ created_at: # ? file.createdAtT ) }, { status: 200 5 xJGx?&##en88 Sxj../*1 !5import { getFileType,{ Y$co@B } <  ? 'document'ۓ@wyB }몃4l xh100644 file.ts(gB"Q&cc!100644 logger.tsgT`x]ɲU:SE100644 rateLimit.tsܴĒgh"100644 telegram.tsi3ō,W,jP`i/9> ZxS msg.document?.fileName ||. = msg.voice?.fileName || msg.animation?.fileName || 'file'].% msg.audio?.mimeType || o; }; ~7Sx3,M%!e#=Xl1wx`100644 bootstrap.test.tsIɛxqb֦F0lpq4100644 bot.test.tsQKe-AeLfNuO100644 db.test.ts'fOj^"ygg>100644 env.test.ts$$poWS{&h100644 file.test.ts'Qρ9&z:100644 files.test.ts\Yqc>G0xOW100644 health.test.ts2ыJٵcH1100644 rateLimit.test.ts W 2!n 10u100644 telegram.test.ts* ˵䍣F&4G100644 upload.test.ts }H?Sr?U(Q%] x Bdescribe, it, expect, mock, beforeEach, afterAll } from "bun:test"Zxc@ Promise.resolve({ stop: mock() })); mock.module("../src/bot"#) })); mock.module("../src/routes/upload"( })); mock.module("../src/routes/files").) })); mock.module("../src/routes/health"!+ })); mock.module("../src/utils/rateLimit"*" })); describe("Bootstrap Server""-"!"../src/index""port""routes"3 "/api/upload"3"/f/:public_id"3""3"/health"); }); }); *=yx-! Idescribe, it, expect, mock, spyOn, beforeEach, afterAll } from "bun:test"a"../src/utils/logger"/"."#"-1003996572954""7"U "telegraf"d# })); mock.module("../src/db/index"q) }, files: {}G<&{ telegramFileId: "stored_file_id", 1"stored_unique_id", _ })); mock.module(""3%"info""*"error"); describe("Telegram Bot Handler"P "[$"6 "../src/bot"r"start";I;"document", "photo", "video", "audio", "voice", "animation"g"should handle /start command"6 "../src/bot" $+call => call[0] === "start" c1  V"Halo")); }); it(" ."6 "../src/bot" Ó(  "doc_123"P "doc_uniq_123"z 2"application/pdf" "cv.pdf" }y' 1 ["doc_123", "cv.pdf" YK="File berhasil diupload"), expect.any(Object)); }); it("` ."6 "../src/bot" { file_id: "photo_123"P "photo_uniq_123", LI "image/jpeg" }]y' 1 F[ "exceeds"l<* -x\"it, expect } from "bun:test">"../src/db/index"k'>"../src/db/schema"; describe("Database Layer", () => { it("""5"oi"%"T35y!xj! "3it, expect } from "bun:test"; import { getFileType,H0k } from "../src/utils/file"; describe("File Utilities", () => { describe("getFileType", () => { it(")" "video/mp4", "")).toBe("video");8"video/quicktime", "")).toBe("video"); }); it(")" !"audio/mpeg", "")).toBe("audio");2"audio/ogg", "")).toBe("audio"); }); it("i1" )"image/jpeg", "my photo")).toBe("photo");."image/png", "cool image.png")).toBe("photo");-"image/gif", "funny.gif")).toBe("animation");?"image/png", "funny gif")).toBe("animation"); }); it("4" C"application/octet-stream", "this is a voice note")).toBe("voice");S"application/octet-stream", "cool animation")).toBe("animation"); }); it("0" ,"application/pdf", "")).toBe("application");null, "")).toBe("document"!"checkFileSize", () => { it("'"6"photo".Y"video"5"+"%"photo".Z"video"6"9"%o "unknown"F[ "unknown"*#"extractFileName", () => { it("  " )"x-file-name": "custom.txt"0   "custom.txt"); }); it(" >"  & $"doc.pdf" } }, null)).toBe("doc.pdf" @"low.jpg" }, { fileName: "high.jpg" }] }, null)).toBe("high.jpg" &"song.mp3" } }, null)).toBe("song.mp3" d ("voice.ogg" } }, null)).toBe("voice.ogg" :"anim.gif" } }, null)).toBe("anim.gif"); }); it(" +"  f "file"#"extractMimeType", () => { it(" 0" )"x-mime-type": "text/plain"0 2 "text/plain"); }); it("  " ?4"application/pdf" } }, null)).toBe("application/pdf""pE"image/jpeg" }, { mimeType: "image/png" }] }, null)).toBe("image/png"5*"audio/mpeg" } }, null)).toBe("audio/mpeg""R("audio/ogg" } }, null)).toBe("audio/ogg"#<"video/mp4" } }, null)).toBe("video/mp4"); }); it("," (W"application/octet-stream"vP]Ux(-,Bdescribe, it, expect, mock, beforeEach, afterAll } from "bun:test"Z })) }))"../src/db/index"%)OA!"equals", value: val }) } }Z<"photos/file_0.jpg" })); mock.module("../src/utils/telegram"JH } })R"../src/utils/rateLimit" /% })); describe("File Route Handlers"_", handleFileInfo"123456:ABC-DEF"\'"../src/routes/files"}&"handleFileRedirect", () => { it(";+"}R" "!# "test-id" )"Rate limit exceeded"); }); it("J2"} }) })i+"""!# "missing-id"a S I$"File not found"); }); it(" 5"}C{ id: "uuid-123", publicId: "test-id", P "tg-file-id", 2"test.jpg" }]) }) })i+" "!# "test-id"a S #"Location")).toBe(" A"); }); it("{0"}>"DB Connection Error"," "!# "test-id"a "Server error"@ ""handleFileInfo", () => { it("J2"} }) })i+"y"!# "missing-id"a &) I$"File not found"); }); it("x-"9G"test-id", fileName: "image.png", mimeType: "image/png"&-"photo"Z9"2026-05-18T00:00:00.000Z") }) })i+"]"!# "test-id"a &)8[I"test-id", file_name: "image.png", mime_type: "image/png"/"photo"2"2026-05-18T00:00:00.000Z"_"{0"}>"DB Connection Error","]"!# "test-id"a &r"Server error"@Cpy2x+ 8describe, it, expect, mock, beforeEach } from "bun:test"PZ"../src/db/index"+F } })); describe("Health Route Handler", () => { let handleHealth3`"../src/routes/health"<"2"-""+IL"ok"=":E"V""!""+"error"""); }); }); ZY6XxTOANv8bDD@ iviwN)J^=x<&Fx4141b4zQz?t--)^Λͷޛ}3x@E!v׉t&!] ^'*92bՖ$dn_5Q5^/IFlSnPjtYHY 9Ņ@g>xݙ%RV2vR3 ۾VA[H\-V5߮A WG$@ /_{ѰمzU|5px $ ߴ]0/D b4 ߼I( /}!OAa iw[G:иC| !ױnpǡ/,[>vٚq,j <ƫfΤ%^kxܸ1l{ENH _@撼yHvG9VpOx_-9GI_}kO(-vѕEK1SsN7xBdescribe, it, expect, mock, beforeEach, afterAll } from "bun:test"ZV"../src/db/index") }, files: {}""nanoid";"mocked-nanoid-id"i*"../src/utils/telegram"){ telegramFileId: "tg-file-id-123", telegramFileUniqueId: "tg-unique-id-abc", storageMessageId: 98765 })), getBt6%{ file_id: "tg-file-id-123", !Rmime_type: "image/jpeg" })) } }) })); describe("Upload Route Handler"o_""<"B7" ,"a ", { method: "POST"C"content-type": "text/plain" }, body: "plain text data"@"UQ"); }); it("0" ,"a ", { method: "POST"""content-type": "application/json"AH"hello world").toString("base64"), fileName: "test.txt" })@Oz )!"mocked-nanoid-id"*"tg-file-id-123"!i"tg-unique-id-abc"# "test.txt"#"document"); }); it("*" ,"a ", { method: "POST"""content-type": "application/json"3Name: "test.txt" })@"Invalid JSON"); }); it(" ,"  F)"multipart hello")], { type: "text/plain" %"file", fileBlob, "test_multi.txt"); / "a /", { method: "POST", body: formData@Oz I"mocked-nanoid-id"#"test_multi.txt" ;^r/x?Y3rv'1aZ^40000 testl>8g]d7YI)b+ x9100644 bot.jsrP&8y\IJ_*m40000 db|Qc[ /100644 env.jsM g` '~06~>100644 index.js[J&(:J󛢳ИGx40000 routesjt \ }[Y cx40000 utilsQI>4jM&NnFLx Dimport { Telegraf } from 'telegraf'; import logger from './utils/logger.js'; import { config } from './env.js'; import { db, files as fileSchema } from './db/index.js'; import { nanoid } from 'nanoid'; import { forwardToStorage } from './utils/telegram.js'; export const startBot = async () => { try { const bot = new Telegraf(config.botToken); bot.command('start', async (ctx) => { await ctx.reply( `👋 Halo! Kirimkan file (document, photo, video, audio, voice, animation) ke bot ini. ` + `File akan disimpan di private channel dan kamu dapat download link permanen.` ); }); bot.on(['document', 'photo', 'video', 'audio', 'voice', 'animation'], async (ctx) => { try { const fileType = ctx.message.document ? 'document' : ctx.message.photo ? 'photo' : ctx.message.video ? 'video' : ctx.message.audio ? 'audio' : ctx.message.voice ? 'voice' : 'animation'; const fileObj = fileType === 'photo' ? ctx.message.photo.slice(-1)[0] : ctx.message[fileType]; const { file_id, file_unique_id, file_size, mime_type } = fileObj; const fileName = ctx.message.document?.file_name || ctx.message.photo?.slice(-1)[0]?.file_name || ctx.message.video?.file_name || ctx.message.audio?.file_name || ctx.message.voice?.file_name || 'file'; const maxSize = fileType === 'photo' ? 10 * 1024 * 1024 : fileType === 'audio' ? 200 * 1024 * 1024 : fileType === 'voice' ? 200 * 1024 * 1024 : 2 * 1024 * 1024 * 1024; if (file_size > maxSize) { return ctx.reply(`File size exceeds ${maxSize / (1024 * 1024)}MB limit`); } const result = await forwardToStorage(file_id, fileName); const publicId = nanoid(); const uploaded = { public_id: publicId, telegram_file_id: result.telegramFileId, telegram_file_unique_id: result.telegramFileUniqueId, storage_chat_id: config.storageChatId, storage_message_id: result.storageMessageId, file_name: fileName, mime_type: mime_type, size_bytes: file_size, file_type: fileType, uploader_id: ctx.from.id, created_at: new Date().toISOString(), updated_at: new Date().toISOString() }; await db.insert(fileSchema).values(uploaded); const url = `${config.baseUrl}/f/${publicId}`; await ctx.reply(`File berhasil diupload! 📎\n\nDownload: ${url}`, { reply_parameters: { message_id: ctx.message.message_id } }); logger.info('File uploaded via bot', { publicId, fileType, fileName, uploader: ctx.from.id }); } catch (error) { logger.error('Bot file handler error', { error: error.message, chat_id: ctx.chat?.id }); await ctx.reply('❌ Gagal mengupload file. Coba lagi nanti.'); } }); bot.use((ctx, next) => { logger.info('Telegram event received', { type: ctx.update.type, chat_id: ctx.chat?.id }); return next(); }); await bot.launch(); logger.info('Telegram bot started', { botToken: config.botToken?.substring(0, 10) + '...' }); return bot; } catch (error) { logger.error('Failed to start bot', { error: error.message }); throw error; } }; 3SxI100644 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) + '...' } }); Oximport { serve } from 'bun'; import logger from './utils/logger.js'; import { config } from './env.js'; import { startBot } from './bot.js'; import { handleUpload } from './routes/upload.js'; import { handleFileRedirect, handleFileInfo } from './routes/files.js'; import { handleHealth } from './routes/health.js'; import { cleanupRateLimitCache } from './utils/rateLimit.js'; const server = serve({ port: config.port, routes: { '/api/upload': { POST: handleUpload }, '/f/:public_id': { GET: handleFileRedirect }, '/file/:public_id/info': { GET: handleFileInfo }, '/health': { GET: handleHealth } } }); const bot = await startBot(); logger.info('Server started', { port: config.port, url: config.baseUrl }); const gracefulShutdown = async (signal) => { logger.info('Graceful shutdown signal received', { signal }); logger.info('Closing HTTP server'); server.stop(); logger.info('Stopping Telegram bot'); await bot.stop(); logger.info('Server shutdown complete'); process.exit(0); }; process.on('SIGTERM', () => gracefulShutdown('SIGTERM')); process.on('SIGINT', () => gracefulShutdown('SIGINT')); setInterval(cleanupRateLimitCache, 60000); logger.info('Application running successfully'); Eekxn100644 files.jsw,#Sh>x&100644 health.jsTBus { 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 }); } }; Dxa4I#sql+DHealth = async (req) => { try { await db.execute(sql`SELECT 1` status: 'ok'u<Health check failed', {5status: 'error'"" 3xoimport 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'; }; { 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; [(x`100644 bootstrap.test.js'sRݵaX3.8100644 bot.test.js'y { return { port: options.port, routes: options.routes, stop: mock() }; }); const originalServe = Bun.serve; Bun.serve = mockServe; const mockStartBot = mock(() => Promise.resolve({ stop: mock() })); mock.module("../src/bot.js", () => ({ startBot: mockStartBot })); mock.module("../src/routes/upload.js", () => ({ handleUpload: mock() })); mock.module("../src/routes/files.js", () => ({ handleFileRedirect: mock(), handleFileInfo: mock() })); mock.module("../src/routes/health.js", () => ({ handleHealth: mock() })); mock.module("../src/utils/rateLimit.js", () => ({ cleanupRateLimitCache: mock() })); describe("Bootstrap Server", () => { beforeEach(() => { mockServe.mockClear(); mockStartBot.mockClear(); }); afterAll(() => { Bun.serve = originalServe; }); it("should bootstrap the application successfully", async () => { await import("../src/index.js"); expect(mockServe).toHaveBeenCalled(); expect(mockStartBot).toHaveBeenCalled(); const serveCallArgs = mockServe.mock.calls[0][0]; expect(serveCallArgs).toHaveProperty("port"); expect(serveCallArgs).toHaveProperty("routes"); expect(serveCallArgs.routes).toHaveProperty("/api/upload"); expect(serveCallArgs.routes).toHaveProperty("/f/:public_id"); expect(serveCallArgs.routes).toHaveProperty("/file/:public_id/info"); expect(serveCallArgs.routes).toHaveProperty("/health"); }); }); ¾x^import { describe, it, expect, mock, spyOn, beforeEach, afterAll } from "bun:test"; import logger from "../src/utils/logger.js"; // Mock environment process.env.BOT_TOKEN = "8605908810:AAFpUzlIBktfd_7wpEj7zMJob2CFxvG-ZGY"; process.env.STORAGE_CHANNEL_ID = "-1003996572954"; process.env.BASE_URL = "https://tele.asepharyana.tech"; // Mock Telegraf const mockLaunch = mock(() => Promise.resolve()); const mockCommand = mock(); const mockOn = mock(); const mockUse = mock(); mock.module("telegraf", () => { return { Telegraf: class { constructor(token) { this.token = token; this.launch = mockLaunch; this.command = mockCommand; this.on = mockOn; this.use = mockUse; } } }; }); // Mock database const mockInsert = mock(() => ({ values: mock(() => Promise.resolve()) })); mock.module("../src/db/index.js", () => ({ db: { insert: mockInsert }, files: {} })); // Mock forwardToStorage const mockForwardToStorage = mock(() => Promise.resolve({ telegramFileId: "stored_file_id", telegramFileUniqueId: "stored_unique_id", storageMessageId: 9999 })); mock.module("../src/utils/telegram.js", () => ({ forwardToStorage: mockForwardToStorage })); const infoSpy = spyOn(logger, "info"); const errorSpy = spyOn(logger, "error"); describe("Telegram Bot Handler", () => { beforeEach(() => { mockLaunch.mockClear(); mockCommand.mockClear(); mockOn.mockClear(); mockUse.mockClear(); mockInsert.mockClear(); mockForwardToStorage.mockClear(); infoSpy.mockClear(); errorSpy.mockClear(); }); it("should initialize and launch the bot", async () => { const { startBot } = await import("../src/bot.js"); const bot = await startBot(); expect(bot).toBeDefined(); expect(mockCommand).toHaveBeenCalledWith("start", expect.any(Function)); expect(mockOn).toHaveBeenCalledWith( ["document", "photo", "video", "audio", "voice", "animation"], expect.any(Function) ); expect(mockUse).toHaveBeenCalled(); expect(mockLaunch).toHaveBeenCalled(); }); it("should handle /start command", async () => { const { startBot } = await import("../src/bot.js"); await startBot(); const startHandler = mockCommand.mock.calls.find(call => call[0] === "start")[1]; const replyMock = mock(() => Promise.resolve()); const ctx = { reply: replyMock }; await startHandler(ctx); expect(replyMock).toHaveBeenCalledWith(expect.stringContaining("Halo")); }); it("should process document uploads and save to db", async () => { const { startBot } = await import("../src/bot.js"); await startBot(); const fileHandler = mockOn.mock.calls[0][1]; const replyMock = mock(() => Promise.resolve()); const ctx = { message: { message_id: 42, document: { file_id: "doc_123", file_unique_id: "doc_uniq_123", file_size: 1024, mime_type: "application/pdf", file_name: "cv.pdf" } }, from: { id: 999 }, reply: replyMock }; await fileHandler(ctx); expect(mockForwardToStorage).toHaveBeenCalledWith("doc_123", "cv.pdf"); expect(mockInsert).toHaveBeenCalled(); expect(replyMock).toHaveBeenCalledWith(expect.stringContaining("File berhasil diupload"), expect.any(Object)); }); it("should reject uploads exceeding max size limit", async () => { const { startBot } = await import("../src/bot.js"); await startBot(); const fileHandler = mockOn.mock.calls[0][1]; const replyMock = mock(() => Promise.resolve()); const ctx = { message: { message_id: 42, photo: [{ file_id: "photo_123", file_unique_id: "photo_uniq_123", file_size: 20 * 1024 * 1024, // 20MB exceeds 10MB limit mime_type: "image/jpeg" }] }, from: { id: 999 }, reply: replyMock }; await fileHandler(ctx); expect(mockForwardToStorage).not.toHaveBeenCalled(); expect(replyMock).toHaveBeenCalledWith(expect.stringContaining("exceeds")); }); afterAll(() => { mock.restore(); }); }); g yDxJimport { 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"); }); }); }); Pcx-import { describe, it, expect, mock, beforeEach, afterAll } from "bun:test"; // Mock database layer const mockSelect = mock(() => ({ from: mock(() => ({ where: mock(() => ({ limit: mock(() => Promise.resolve([])) })) })) })); mock.module("../src/db/index.js", () => ({ db: { select: mockSelect }, files: { publicId: { equals: (val) => ({ type: "equals", value: val }) } } })); // Mock telegram utils const mockGetFile = mock(() => Promise.resolve({ file_path: "photos/file_0.jpg" })); mock.module("../src/utils/telegram.js", () => ({ getBot: () => ({ api: { getFile: mockGetFile } }) })); // Mock rateLimit const mockCheckRateLimit = mock(() => true); mock.module("../src/utils/rateLimit.js", () => ({ checkRateLimit: mockCheckRateLimit })); describe("File Route Handlers", () => { let handleFileRedirect, handleFileInfo; beforeEach(async () => { mockSelect.mockClear(); mockGetFile.mockClear(); mockCheckRateLimit.mockClear(); // Set up mock token process.env.BOT_TOKEN = "123456:ABC-DEF"; const filesRoute = await import("../src/routes/files.js"); handleFileRedirect = filesRoute.handleFileRedirect; handleFileInfo = filesRoute.handleFileInfo; }); describe("handleFileRedirect", () => { it("should return 429 if rate limit is exceeded", async () => { mockCheckRateLimit.mockImplementationOnce(() => false); const req = new Request("http://localhost:3000/f/test-id"); const res = await handleFileRedirect(req, { params: { public_id: "test-id" } }); expect(res.status).toBe(429); const body = await res.json(); expect(body.error).toBe("Rate limit exceeded"); }); it("should return 404 if file is not found in database", async () => { mockSelect.mockImplementationOnce(() => ({ from: () => ({ where: () => ({ limit: () => Promise.resolve([]) }) }) })); const req = new Request("http://localhost:3000/f/missing-id"); const res = await handleFileRedirect(req, { params: { public_id: "missing-id" } }); expect(res.status).toBe(404); const body = await res.json(); expect(body.error).toBe("File not found"); }); it("should redirect to telegram file url if file is found", async () => { mockSelect.mockImplementationOnce(() => ({ from: () => ({ where: () => ({ limit: () => Promise.resolve([{ id: "uuid-123", publicId: "test-id", telegramFileId: "tg-file-id", fileName: "test.jpg" }]) }) }) })); const req = new Request("http://localhost:3000/f/test-id"); const res = await handleFileRedirect(req, { params: { public_id: "test-id" } }); expect(res.status).toBe(302); expect(res.headers.get("Location")).toBe("https://api.telegram.org/file/bot123456:ABC-DEF/photos/file_0.jpg"); }); it("should return 500 on database or external errors", async () => { mockSelect.mockImplementationOnce(() => { throw new Error("DB Connection Error"); }); const req = new Request("http://localhost:3000/f/test-id"); const res = await handleFileRedirect(req, { params: { public_id: "test-id" } }); expect(res.status).toBe(500); const body = await res.json(); expect(body.error).toBe("Server error"); }); }); describe("handleFileInfo", () => { it("should return 404 if file is not found in database", async () => { mockSelect.mockImplementationOnce(() => ({ from: () => ({ where: () => ({ limit: () => Promise.resolve([]) }) }) })); const req = new Request("http://localhost:3000/file/missing-id/info"); const res = await handleFileInfo(req, { params: { public_id: "missing-id" } }); expect(res.status).toBe(404); const body = await res.json(); expect(body.error).toBe("File not found"); }); it("should return file info JSON if file is found", async () => { const dbFile = { publicId: "test-id", fileName: "image.png", mimeType: "image/png", sizeBytes: 2048, fileType: "photo", uploaderId: 99999, createdAt: new Date("2026-05-18T00:00:00.000Z") }; mockSelect.mockImplementationOnce(() => ({ from: () => ({ where: () => ({ limit: () => Promise.resolve([dbFile]) }) }) })); const req = new Request("http://localhost:3000/file/test-id/info"); const res = await handleFileInfo(req, { params: { public_id: "test-id" } }); expect(res.status).toBe(200); const body = await res.json(); expect(body).toEqual({ public_id: "test-id", file_name: "image.png", mime_type: "image/png", size_bytes: 2048, file_type: "photo", uploader_id: 99999, created_at: "2026-05-18T00:00:00.000Z" }); }); it("should return 500 on database or external errors", async () => { mockSelect.mockImplementationOnce(() => { throw new Error("DB Connection Error"); }); const req = new Request("http://localhost:3000/file/test-id/info"); const res = await handleFileInfo(req, { params: { public_id: "test-id" } }); expect(res.status).toBe(500); const body = await res.json(); expect(body.error).toBe("Server error"); }); }); afterAll(() => { mock.restore(); }); }); benOx import { describe, it, expect, mock, beforeEach } from "bun:test"; // Mock database layer const mockExecute = mock(() => Promise.resolve()); mock.module("../src/db/index.js", () => ({ db: { execute: mockExecute } })); describe("Health Route Handler", () => { let handleHealth; beforeEach(async () => { mockExecute.mockClear(); const healthRoute = await import("../src/routes/health.js"); handleHealth = healthRoute.handleHealth; }); it("should return status 200 and ok when DB is healthy", async () => { const req = new Request("http://localhost:3000/health"); const res = await handleHealth(req); expect(res.status).toBe(200); const body = await res.json(); expect(body).toEqual({ status: "ok" }); expect(mockExecute).toHaveBeenCalled(); }); it("should return status 500 and error details when DB health check fails", async () => { mockExecute.mockImplementationOnce(() => Promise.reject(new Error("DB Connection Failed"))); const req = new Request("http://localhost:3000/health"); const res = await handleHealth(req); expect(res.status).toBe(500); const body = await res.json(); expect(body.status).toBe("error"); expect(body.error).toBe("DB Connection Failed"); }); }); RŴ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*xU%beforeEach, afterAllAz 2 afterAll(() => { mock.restore(); }); }); 1 >x`un.lock1%K{a58黑&index.ts{,dTώsx 6ѦS=e$r9 JP)O=j;l83_100644 tsconfig.jsonI}rR%FS/xY`}]"&!package.jsonwv[j'Ol>8g]d7YId+ xm<̼ +{)Y2sRJRK@|E(oiAN~b B\I7#51$I+)+_R\RX,mVf v.ZZ.<6\x4рTa\;=WzOj;l83_s27xedb%IyJV J9%%J:UJ k2x ~xJ@QLߛR!׳8vTIA6 Bv _#=IB(k,U&#o x 6@}); 3f{x_++%OspyOn, beforeEach } from "bun:test"; import logger from "../src/utils/logger.jsJV}); tl!0xconsole.log("Hello via Bun!"); -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?W3VN_y%ss/40000 test] Vd ta=r)GmiTx aAhdx-rx?W3Dy& BC40000 test["U*|x\Z)jPx "?AhaxTK8x?W3$Y6ͼݹ40000 test\^؈OfK}?)m}xLewbiH[za#`  SxI100644 files.jsw,#Sh>x&100644 upload.js)Y  )ap5!kGx T#|xx?W3(^x?W3@eU1tb.j40000 testr<O+PÊ)h,x_Ef f}x '5x?W3.os\K2 \:40000 test;V1ЌH6Atē)Jwx__KpZ})9 aexpp fx (Rx?W3( y:kv/j40000 test667UwkC4"Γ)sx__K ruo4R*/i# FxM100644 logger.jsgT`x]ɲU:SE100644 rateLimit.js ŵ_}gM4h}xzT|&8x?W36J ءd %꺎imG40000 testEnǵ]N5#U)zx__Kze1SvߕQ{>yZ2 x%100644 logger.jsgT`x]ɲU:SEKd>xzMM@rxo?;5n8.DQ#W7\b'>Fϓ'03)*WdZ@YUc-40000 testH_7VݰY쌈瓊)3bx  sk8}, "peerltypescript": "^5. C'typescript": ["typescript@5.9.3", "", { "bin": { "tsc": "bin/tsc", "tsserver": "bin/tsserver" } }, "sha512-jl1vZzPDinLr9eUt3J/tB7V6FgNEw9QjvBPdysz9KfQDD41fQrC2Y4vKQdiaUpFT4bXlb1RHhLpp8wtm6M5TgSwW } } V40000 utilsze1SvߕQ{>yZ2B1x'100644 env.test.jsg3S.s(D_ B%txXwl a*t) x 40000 utilsze1SvߕQ{>yZ2 ~kOx M)Hhx8(\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 uzP&1hƯGҥK