# v2 git bundle ed88069e60f7f2f352b1c66264f084a1e77bcd21 refs/heads/bundle ed88069e60f7f2f352b1c66264f084a1e77bcd21 HEAD PACKx7tree 333d6b534362bc8cc56b8d2ab8b3a8956d6a9385 parent 910d29d5b9cae2f1050f1aba99e9740f60dbb80b author MythEclipse 1779069264 +0700 committer MythEclipse 1779069264 +0700 fix: assert sendDocument with config.storageChatId to match dynamic mock env in CI cbx/tree f58a341962cd71da99af41a8e0e2a7ff419b0cfb parent c0827b09c5734f1a38bb3750bf896403379dd7bb author MythEclipse 1779069224 +0700 committer MythEclipse 1779069224 +0700 fix: upgrade Bun setup version to latest to support modern lockfile format NaDx=tree f07cdff798467b586c50c5891e1a6bb3fa0afc03 parent 7f1178d72b510522f79f99d630498b5b17426096 author MythEclipse 1779068569 +0700 committer MythEclipse 1779068569 +0700 fix: make DB tests more robust by checking definition rather than strict module identity e(xDtree 7dee9e60ce11d243d9ceebee9db7d455973836b8 parent 06a1b38c025ae868a2f1ada6858d1d8623d2770a parent 1fc408046627586e1906b9f2454c7f07e3f97805 author MythEclipse 1779068497 +0700 committer MythEclipse 1779068497 +0700 Merge branch 'worktree-agent-a7a26e7873ab5b94e' Taוxetree 633f9563e2e028939a3debfdbfca1573425d1e73 parent 2c1c5ad6383264c0ec97910b56e7a80ea3f19b62 author MythEclipse 1779068489 +0700 committer MythEclipse 1779068489 +0700 ci: add GitHub Actions pipeline for tests, Docker build, and deployment Co-Authored-By: Claude Opus 4.7 ;qxDtree 4ef940d99619d1e7e4e3eb84c0bf4df18dd2e1e0 parent e4c074c81f47bea51fc257596c5949db6b9e6905 parent b41fdb4a887e94217e674d40751f2f409a4d6d1f author MythEclipse 1779068460 +0700 committer MythEclipse 1779068460 +0700 Merge branch 'worktree-agent-aae37f6f3cccac163'  c=xtree ce8e68d24ba8fa90f5ffae02dcd480bf5a71d3b7 parent d7f5180eab08eefaa82377da156ff7e02da24541 author MythEclipse 1779068456 +0700 committer MythEclipse 1779068456 +0700 docs: add deployment design and implementation plan kYhxx-tree d3731c514bb8193f08d58f93f8fb65823b5fc23a-h397AF397 +0700 chore: add Dockerfile and dockerignore for production build+:s*xz-tree ec818722ada3fc406688496f7b7d24e7ef841ded-h442AD442 +0700 chore: add docker-compose.yml with Traefik configurations:*x tree 325913e92098ead18af34767e5b5836e27dd9f0a parent 91986d1d51c2411f144696fa016a0ec50507c872 author MythEclipse 1779067524 +0700 committer MythEclipse 1779067524 +0700 fix: add Bun database migration runner tQxtree 42d98de0973264cb6d213958261038d2cb55eeed parent 9aedc59b69772102cafb5b496747df09be8547dc author MythEclipse 1779067135 +0700 committer MythEclipse 1779067135 +0700 fix: upload binary files to Telegram with source payload Yxtree 1c38e45dc33cce54ef800aca2d3916b77f26d121 parent 6feca3564af2e2a58cdc567e601140c039ab81e8 author MythEclipse 1779064995 +0700 committer MythEclipse 1779064995 +0700 fix: refine Swagger docs headers and dynamic examples Y'xtree 68eb596a98a9ff83e3dc5f4c90e338f698690152 parent aae8ebfbcf74594ee2282b238f4de43386bc61ae author MythEclipse 1779064767 +0700 committer MythEclipse 1779064767 +0700 feat: add Swagger OpenAPI documentation endpoints iWx;tree abe8cb98ec8b13338f7630edc8d452ce7621caa0 parent 825a8f42cb36e64995cc441eb73f533fbf41d52f author MythEclipse 1779064247 +0700 committer MythEclipse 1779064247 +0700 chore: update bun.lock to include @biomejs/biome, typescript, and related CLI packages dxtree 6714e5c8786aaca5e43ffd78c28523aca8f0b70e parent cf79a1f1955f6a6eb4441fd4a9cc841a3528a1b1 author MythEclipse 1779064233 +0700 committer MythEclipse 1779064233 +0700 chore: add build script and target bun bundle output gXxtree 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 )W%x340031QKON-L/Je`<;5S/S˫ BV$2a4$->)U䏎:P5 19;1k:x,iXÅPuzŅ9 +]ﾴVT|vRL>Ff0g?PdE C%Ulon1њ⤋х,I.B:4ʩ! Oo衛yYLn5=Jc0q$vjboG8;2N͢*( BeMRC%}=XyYx$40000 workflows#Y4eHu`^(px&100644 deploy.yml;Tqh_y0?KZxW[s6~W;& 0K'h,2@+ +ɤ4#|dw҇b[;t]Ґ=,(F ) 0k -aKz5Ce*AuH"mhcȀHOI[~u%95QHT G[4rwAYw/^ti} FE4hJgomYi`e=ep[)ϻ%臻9|\0ԓ{C@=;m_N&'}љhnv_F}Bkn ` ' M2 0??`|5)%0_Kh~MR#88Q]tc M&-h  -:u[^<#1#oBgzRc? ]VRc$,( Ÿ^WdbKkS!k;K-PXvMZ̷$?lنS+GC/T2 \LhcQV  M%be DA`‰G+M}d qڳ6vuWa uX~D A?nr !%FIjogEק`HXpLCi]dpBJezDS}-&Pu{߈줶QJV_E;'0Mr]YD ,_gT72A.s%ep0R}q*M8_"H7y?9oyqC6 ^7֦e-i?z 9A_& xmP=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 6g"4 wP3(pg b5B#XKP3d$Tt5{XeApѢ>& ߭,UTU\}#Ǩ| m>EZYZVObt;7,3jYK-gc۲W I̸o[xeFUͅL0߱x=rFvLDƛ.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Ǻb?C7c=|{Uyg>EcAχz3ک 0/gGsO ' RC-usFo%7I^8hſWQq[oG֗={dDiwEuM%w~t (%wOT?yʿ^,G.`yP{Bp ?IO፯RjFsBjɚۃЙnRUdr>p7b&}&ȉY -pn_f6ROOޚȗGψlGb sKR~>K/v) ]*41ٰ]3, s: ZZ+~>Zrذxh4^@ 3YP ׂyF@..}/bDHiFQ>]@<[kIfE5[j; wZߍGrQjUDyr)]_8 K ᏮgYDp{Ob=]?Gl[h,C2oDh:+:0=[y"{{LUWDB' A8\얾gC-\UĬPEȽ;x$ZMyd?'kɻ*s~XjGj(;Gŧb5fC`:.Jk{`K &3T1`Ts. A}> =7 d|zPFdKw}EܥWD>ͻ:hPW"FA4urK嗉YBu elWF_y'Y ̍\p$v9 ՙB*ȦH7# ш…_Q"9#0߁r;.Ξ Ítj"Xss_YpDXP7NkVL  vUqHy?otNt/[񵑄۳tW>ʁoO|[ϻý,0\ؗ{eԭ|AÇOɛ9wqJۮG8{hSyyqi]zڬbiWA~D\ZCtVMt)#Xq͗CR>LP"b,>P6>Q"(:t݄*k qLw*;z'9a"k'Qc7h)O5}N*o2V.&~vvmS褶Z_[/Ť-vZRԓP2S-S_֏uu):;+ư StDp4)AqD/Cf)tl;rI\'c޵w;ƍ,o..-J0T 5{Zpc.= LϸpHUs,/?[hJwL{]e\MXܓeYBk(wl7~\e =B3jmt;2d f!][A)8[L8h8gLR oX7~s?S/E;EUh"욵Y)?ËÖ)6l%eJUۉ6zu34 !y.R1U?2>hcsWD)آaoª|i/,~#J8=ϩYj4k-?󟵕w'7A]ȦTv|02>ps[҅C2Vej 23UX*[ImG@賡d߬0KaEl 7N nWhӕA<> X."Plq rJh}}a76"XTdZ¬6nE5n1)1=4itO. *ϧ4Ȗ2*M֥ HHm*. V)LpdR@M歶o<Wa߾z »< ,"O_MeH9dc4k,#B VSJO:3p(kH_h83]4n՛2V&߮Cؘ "«䃶GDEtcʰr{Է?qb'?|&8iMms-ؑ7 lg v6tc ";Z/ EZOreÄ|[4aGl2)Z-dJuXqQӯSC_wH铧QOc5pv#+fk` G"~)NɸCE`x]1}-Dp)15M)^ކ1UGa8#lYpbP~8'n|~\),𭷔xA;IS BQ<&W׮+&~y|'2&q^cE}&ZiE *i ((,,J'^8mGP0O}קz<3 d1&JQYǚ)V<¢ W %򔂎px㴙0׋,&?8\C]aöOvGw-lXiƃ̤>dPܑhY#MTiC=f*]+6iKϯtz^||ҽ{B{80z~G9ͣeO~X٠rI韛 \m:`yLa+;[Pv 9bq֛`%YBxJo(y7ܫ֛_/^ wh~4A$`A#p[d~T_~Zt1u|2u5zNCPMem 5{|LcpIoۄ`֗. ]Q>OÇ ^^/%2<\~Ū'-g ?ͮS7w|ͧ/Z?8k 2?>mzr!y~SJW6ۜ97/lˏE o=ϋb2ez+OXWu c/6SRI4}*0^_R k+O%\~9{^hi?Oh?OU#~(g u&~ߕӺ wOh{ҦEzV0tIIjxm' pM FӁlΥP(90e\TGF-3se"5`22Ĭ~y|0 ZYI7d<,Oֆ* %10' UZ%!m2 S'@xńw2 $M~Eu9$;*? O>)mP_ ş@OD }B0ocf>!z Fʻ Rn?%껄oWl3_}!6<تe_^ OӨán/iq7)їP_am p͉Dnntۍ)hj-l *Pvb$\3y~O}pwDl/7fu% gLC\d;3(3J'!^F=2.?& [W1O#WOg&UCx¹ 1C3F«k0F9pfHagZ`̎g<V2%cuZD$cs5OX|y6Ԫj67Ï|>8j8u ƅ~q_sQ&CWdz3?d'Y\ch.!k*`,eIk5Ŷ'<)aEd8:\Mot14>{ֵ1e/ӽUCs}m^QA7\9[g&DO"뜊 y5FoBłC*D<83^^9HO"b3<X ![;L>+V́ιv^R!KlY^:A3G9M༨r_f :0Ok ֛vx^똼~yvC=ـcz.y||TZg: (KʇN;%[Ol{GDŽP?uq%쩝e/ &;ϔTv4yqK[` lmkx;/H-*fz-/E%z0?|BqX=R6KLs "M:m?Rkϭ\|yg)B ώP(y;#'o?ū&?v~tuz|M"xC?_j쯔WS9G+/S۽x_A@O @1̾7qeFt&$Ia|%0[RRK\ɯmlEkd+ VnsR0q@#SKJVj8ʳ,'3+!ݓapȸv}Í}itǁs`Ou`(xG蓸chF[^dle3L"]r/4˧~=a"5YayM.$eQ/+2Ժh xY|B~Rs7 qW^CW~$w۸v:J$3RķS J+p.[8lAGj9ZmѬJ ~1Gh'8 w{W'Esuʯ'wϴv;cn3.[ӀU3xOj_\:LJS`RYŴܯe(ZŮjR?(z zok.sw6PssGx 6[G"m#o>.?Uv8_cȉZ:;aHa[k9i}w\ibpbcЯ0oY/&:味Κn-\؉dVsLl@JiȋQ[N&}R*\XыE>goZ_{%ṩ^-`= Hs; 4eNࡉԃ^'Ba>U)&.iyse3I4c޸@B"V7/Vb<2}8cǥ:{ͨ+1]PfcmWؘ4f^۾Ph1x>J]*9 Hc]|#Ś@3NZ qexy5ԜuآcŸA:d emj:Oby: .Qd}*]0V eˌɰ`Bep2dimgew3޾/Ŷ|4&FA;V"p Z/)Cʖk8u4_\ U΢:ps9.]o 2* =;s~= h͎֪c8@m h':0q?o}n3egEp(p$B:G^sC޶қ!^Y: F )$a8!yIo`nցe5o2g 6h)`K`:a\9%ꉱ_Х縧9r._SBE<$`[&oX+m 3BuaǫtwC^a^l }ޜ\NìV?o?8;wZQJ?7tE Atan }k梅8]a\Z;EĹ} Fåz߫wϾV I6V>'"D%ȁp݁ad;s_gJ9t@3׵޺~_Py3& [";'Yv̓|E%`OԀy*4q ]GApLa& onF7I׳6U?-XD ޟM@H # -uCRl 3 d˲qyÊ*) t] bx9˃<Fw<_uus@A'OKR|z d`O9ܓ=q>4BQ~fܪy!ʐpA* $نV42$(v%v%vgI4.NR:7{~|h-tݎUs$`Iw#b@{{p2 Ni5:+^Juv#WDul\NjvSGVY@$wR0C9;H) pilRml xma*YPG1>!n,o]|c>q~f”Fr :"eR´lYٌQލ1ݸMd&NRqlHQ2ad{ݴu7/8A쮻y_ͿYxx|Xj$?ߴ?p4fںI57 Z3dcۋ?2gū1h R:2nG ug7ۿ~_%zvo^W@#DJ) %j>^؎b&W-- 522zx Hͦ<1PjMc'qw,*(t-FF3U$4l F'X#c|qUiCAasSսO~0G2Gg,FFNC'Sek`: %_rb)={df`@O>ei (K]n"]֜H/ߧzޭUN(Բ]lW+`9fDґg- Wǥ2]U7Z0fق-ޛsu)ï*iA_& I[󕥟ɲ?*0,Q@ְ!G@{԰ 7E͵I?>sv|mk~L4~L>COJ1'܄~BUB!? :#7\~D&#O*6=Ż$7 ~DnQA0VcViyX:6̬ӎhLcFb<ЬCA˞?C;|\ƽxh>.6/Jx|:>M}w/>0ٝ H>.^G4r/66}x}O|:m{I++mځ6Y`X%(dIu}`m-_b-F%ؠ{/jd>U߹FTk[|/M(*i 䶊م<;ҫ=(t'%)vZzɉkky 'WԅA{{fՂX]+;(EKqq F)Ngpw>VQRd>G]~':suNU+s߱oB=` 5$|Ny1^4(o ]6׌}F$a4+V'*qk=+K>.o:_$S7`aiVn*I dؘC5t nG-}¼%rXؒ;ak&&N! %řWMUfG6'>sM o o|w~pCZ"gauroM|^qdpư {#RɪH: ;v\:[Xߝž{"(VKF"v3.B","U’IyeF{H x$ J ^7~"6X(k;>W|ޡ;#@!XjqokWqBՆ[OrKk:@ˋE{NB?#\&N'[ WFMl0LpbR !XdE0-F9C%sΔ.aZBdH81Tj ۲z}(_o `o|@ ( .{Nt˹%:;f~nIAڰ)*N8+鸑kwӋXU\Yy|٬_ZἯ wa5I|*/}{zé1%o*NGBni+\cpVhfGqٮ(O K= sNa3}ywQ~}^~tۣ?Eh% f:D;(UX ([ZC>Y8llwA~u|x}SBvueyY!X,(IotiQ>1  ?k<.̯ϦL-7:ηp+DŽluI~,rn;p>\+*G*;3ݙ[">ѵS?ήw߾_nU" 2eN67 ag/Hy9 G^b}lQZIQ<%NQ<L8q4HRcj LcDĦY%2H~;sL\ M`?94j? ?bt ,vr`z/CU.%eh-GR Z ww 8R29;7gk[=o'lT^KI8p fiC*@;9'1]~a9JV^Mx3ǣe V T6%fhHWzf߰b$/KN5NZ^ɑi^n41&yf>$-ٝ(EewHɘ%TSІ.H:8#]X{U`uyBR!;=RIf>bo[fwwޑ4R,"~m{Ѥ{rν mI"H30eM-jz4kD mә!gYvN,4W}d'*IWrCŠ9بBq?4Na[32BD,Aۨޛm֫aОʰ5C%Ysۢ煨$Q4`kè4^pδRY>}WX߻j:i M4ƍتw&ۏ$UN|S=L `լ_gZR+!z/|+YN{{7 wQ8s~'C0drxb`LU4T1N#wc:ƨ@ *ތ|L4u^+V_\BV8##q|bt]l-WNc nF@`nCZCF--!HM鳙qh{@i#%TD!@Iz!w/׀ne[t]+Z hUܔ] 6V9A%IɲZu]} \zwnmoѓجS,> ~!:>Oաj'14E ;G\8kK2p Ŀ{[P P_YӒك$"+Îʜt L"xpptrs,a(^3s}O.'mk#) =ŴeHzV ȃ~KTq<-va*u/kΉйvQt9WXOTKx߹CܸbptMW\u^VLfɈPaFe,=ڞPez"ƅM rwkve9m0riɈVf`ݤf( 6%`0-(rd lanI nwA1A9yfcpl|[  jE@2O 0̭t. MN* C/%;˝\s -ss=KMJBrKý$47/Ź\)8ϣ/72Ŭ4"5(5#Ǡ)25 jj[ Zx"M,83?JAXB8,39؊KA!D)(d&NȢ5y1bQjqIbQBbNybe1XEj^YfQ~^nj^dAN9d'PU 5600Ci<nFE8rRs6Nȩ2 g Nv\%9Ŷ%EJ\wsjOĥ2M&/<(NĢ]0МnYԊԢ+nJx&40000 superpowers͌ s T x@40000 plansjbZRn!DZ40000 specsz|Uח7.6x}100644 2026-05-17-telegram-uploader-backend-plan.mdy GkLJ[κxw=100644 2026-05-18-deploy-plan.mdCM2Tg:nvii@i,֕ՍWhNt7QYAp+ڨCG X!EyO<+ |hYjc|S!$,cg<}xTh*Is<Ejxudbd@/Q̋,KLx18L;rre\'" Dy Š  =&9G8a"].J@$WXE 7`ϐcĠGPt wgCkx^-'}OdQZ^G|9˗+KaF˥)KK-pqMg$Ln#R&Qt Imit1U4M1&CS2- Mٹ 5VB(܅Seh0Ƈ%^lnnFl<HΌ'jV»Kщhcyv'J4 rY1xPȅh!g\z_^PmeI|g:ZNSiCCsgqໜ1]b2+d֓=x'`TD*- Љ8ikSКRie4F)}a۔tiHSDs5Ym.jwJ9kdޒ43-´ax)9zt'xTPtZ`}Aڃ<et%4D@,QU0E^W\qƈE$B1묛|8_]zztu1<8gGHxppx0J\<::%`6(/N}0=\:N,78zؔK4n0p_tΥU3sԽʄ||EM|3bLMYEd"|DK ` 'XabE]*AUhԿi? t [s;gq UGcw2Gg5xI"nYъvtt4'X5UWݪ6X3@HtzQuK3*[<@t[^cH̉uR3ȦzL!bF B L-m\J0UR8/J P@ wݮSH 5Bok^Ysֺb"L85RO =(d,-:cPGҭݽl qR^+9_Ϝ%H.3^zÛݝR rש;d _]FH,zP% ݪVy+ ֒A3h<^J kr7`(벿P<ﱡ+Єo̴DW.pwd|SokoTՃ߃S$ 6RWTh̉7|*ZJ(,ehtڌɔ-²Vv> 2:3&[pʌ/g㷃]Hocϡr!8/Oq#4CΚPeP>&/"p_Șf30^YiV8{)9f`݂;](_[w8qa>u_؁4Yݍ3q];cqZd\˺YA|X.若5;hЯlbrVuSYSi^+4i}g.JnEoY _PuO7XZl7a`O4ł{A*U#OS!zU'>OU0ԅs<nҔ]'&?^ۍ[fk置|ԃSӀ7Z7Cm8s^\7حnݑ[}oj(\d6@mUPHZjB 3Xb PSL,GSyg71iH,\ Rb2ߌ&J=||ݏl?~;9ӐY`kss^nm2S#^U26=#,cva/gO/}"_!l*َ3` ĄTB[Ax/%TӍ)"IYL1ћ2d<}N~/('bǒoml {t3T￶Rux~100644 2026-05-17-telegram-uploader-backend-design.md ,}+5s{jzc100644 2026-05-18-deploy-design.md.&1J~^0ݗэ/lxrHb*/; 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"~gKsrg-?g> XJcK輪б籁-Wʓ,;0Ht9dEXd9ĐÕ^*WII%B@ȅyA[tZ Surb;MB6 mkU_:56lf(f v`|Al4QZzcrP=A-3_jt kҲߒ!KԲc3nKJptFZڈ$:+/e]o(T2 c|JYMR=%w=xj엮*w>$bNώ&D].Pvt N:T^* J!%P|`6M٧2rGߊN@8*%ʈ}Pgp4tHRՇŕZ5x`AJ(#P,o ZY>7ZpAQ)(6M-2!F6uo?eYJcZrUB^dj<5b_K·''rR,IK ܸpEYRq.f?k߻a2ίn>LɈե׃`O`a2(NWzݍnB'S;W'[7rȻ4g rQㅷ{{-P؏|a;zuK|$YA}ܒэԒD˕8!&i{XaIC|~zTh=U/jh[ڇԤ.Ї{($]0C1- w['i~7ǿNQ,EA^F>!Z/wc/D<ɋmJc*5%a:%Y(!1VNU5͋Sf}jzaqSDӍ.{E>*z8E*PiG@/bn1$"C>eG8Fa;LZHj)4u5[2r>!>woPU@5 ๚–W1qDҦje?9+8S |<2 ?IkX V=Uͭhe6N`+1M8tcx;ŸE4Ë=1P~X5))I9:-@ڬA=t-H%e_-GEx}S_O0藺'4 7Ĥ$4=2}%^~rw{0(@r֢dI\aʊd ,\Pe+~r[CkM?#'*652gT|+2(l8kmCZR:H^S1xX,7fP 2l/"b~;> WkhXT!8iozZ6y8ON{JHŮB>wD~<ןk0U6bjbY.u̷؄&a$mGj׿nMP7xetHAURܝnʧޞLYDPZlMLbTYv2ae;L ]銐 Ϧ^*y ٽ)i8^&*lK.;tzĮqƳWɄ~)?LPfx"Bbun src/db/migrate.tsb1 /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|Hx340031QKI+)f8]Vu("3a+;&73($*ܱШͫM"'B?3RsA]jQ+౉;n̚>*5xMO;0&qc&Xi)i!v: !54JZ L BrJ$*ТdG.2}r|Eðȕ(SHAP)w1@c `ݘ cM9R1# Q۵ê4ĦO9 = 킿ޝtT%%B)nxmKn0 D>wBA i{`mJ#ѭwl Pt%!!&!f62=+΍wb\%J(|=.Cٺ|تE{f݅<_<~ex֑[ObXݶv*?1GrOt#p2jEZ٠ouxkd#^ rwI)t v]Rh,{@V(O9`H+ESI|\jйy(}XAxMo0 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{h[x}M0A${!ԮI~D {+c#$];H7fy=_UT J %+|\i2_qrƏȤ(XA}Wa+ y{șV1z.i~jÅ%x46}Rus΅k.i>ϥ凨0gMGSw݈.ڸQ)r!Vr !/]z+b Z>H!] Z5"Y͑7ӀS/ҮXM-eo{0fpex,]XFL23\кc[{ȃa><(>XTó;T4Scry\"2jV 6r";&Y?Ս2ZwbDjN<$;[DKM 0tϱ6opLT:掽w}sdUs0Z /3@|N?pi2[ -40*w+C /jmMf- x340031QHI-+)fx(hZ sh͛BZ59% E}q-wS_F9C'T^u ;fNz~; '?1]펒 =N|U:ö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>Ix#-import { config } from '../env'; const errorSchema = (example: string) => ({ type: 'object', properties: { error: { type: 'string', example }, }, }); const jsonContent = (schema: object) => ({ 'application/json': { schema }, }); export const handleSwaggerJson = async (): Promise => { const spec = { openapi: '3.0.0', info: { title: 'TeleUploader API', version: '1.0.0', description: 'Telegram-backed file uploader API with redirect-based downloads.', }, servers: [ { url: '/', description: 'Current environment', }, ], paths: { '/health': { get: { summary: 'Health Check', description: 'Checks database connectivity status.', responses: { '200': { description: 'Database is healthy', content: jsonContent({ type: 'object', properties: { status: { type: 'string', example: 'ok' }, }, }), }, '500': { description: 'Database or server is unhealthy', content: jsonContent({ type: 'object', properties: { status: { type: 'string', example: 'error' }, error: { type: 'string', example: 'DB Connection Failed' }, }, }), }, }, }, }, '/api/upload': { post: { summary: 'Upload File', description: 'Uploads a file to Telegram storage via multipart/form-data or JSON base64.', requestBody: { required: true, content: { 'multipart/form-data': { schema: { type: 'object', required: ['file'], properties: { file: { type: 'string', format: 'binary', description: 'File binary payload.', }, fileName: { type: 'string', description: 'Optional file name override.', }, }, }, }, 'application/json': { schema: { type: 'object', required: ['file'], properties: { file: { type: 'string', description: 'Base64 encoded file content.', }, fileName: { type: 'string', default: 'file', description: 'Optional file name.', }, }, }, }, }, }, responses: { '200': { description: 'Successful upload metadata.', content: jsonContent({ type: 'object', properties: { public_id: { type: 'string', example: 'xYz123' }, telegram_file_id: { type: 'string', example: 'BQACAgQAAxkBA...' }, telegram_file_unique_id: { type: 'string', example: 'AgAD8w...' }, storage_chat_id: { type: 'integer', example: -1001234567890 }, storage_message_id: { type: 'integer', example: 42 }, file_name: { type: 'string', example: 'document.pdf' }, mime_type: { type: 'string', example: 'application/pdf' }, size_bytes: { type: 'integer', example: 1048576 }, file_type: { type: 'string', example: 'document' }, uploader_id: { type: 'integer', example: 0 }, created_at: { type: 'string', format: 'date-time', example: '2026-05-18T10:00:00.000Z', }, download_url: { type: 'string', example: `${config.baseUrl}/f/xYz123`, }, }, }), }, '400': { description: 'Bad request.', content: jsonContent(errorSchema('No file provided')), }, '500': { description: 'Internal server error.', content: jsonContent(errorSchema('Upload failed')), }, }, }, }, '/f/{public_id}': { get: { summary: 'Redirect to Telegram File URL', description: 'Gets a fresh Telegram download URL and redirects with 302. Rate-limited by IP.', parameters: [ { name: 'public_id', in: 'path', required: true, description: 'Permanent public file ID.', schema: { type: 'string' }, }, ], responses: { '302': { description: 'Redirect to Telegram CDN URL.', headers: { Location: { schema: { type: 'string', example: 'https://api.telegram.org/file/botTOKEN/documents/file_0.pdf', }, }, }, }, '404': { description: 'File not found.', content: jsonContent(errorSchema('File not found')), }, '429': { description: 'Rate limit exceeded.', content: jsonContent(errorSchema('Rate limit exceeded')), }, '500': { description: 'Internal server error.', content: jsonContent(errorSchema('Server error')), }, }, }, }, '/file/{public_id}/info': { get: { summary: 'Get File Info', description: 'Gets saved file metadata by public ID.', parameters: [ { name: 'public_id', in: 'path', required: true, description: 'Permanent public file ID.', schema: { type: 'string' }, }, ], responses: { '200': { description: 'File metadata.', content: jsonContent({ type: 'object', properties: { public_id: { type: 'string', example: 'xYz123' }, file_name: { type: 'string', example: 'document.pdf' }, mime_type: { type: 'string', example: 'application/pdf' }, size_bytes: { type: 'integer', example: 1048576 }, file_type: { type: 'string', example: 'document' }, uploader_id: { type: 'integer', example: 0 }, created_at: { type: 'string', format: 'date-time', example: '2026-05-18T10:00:00.000Z', }, }, }), }, '400': { description: 'Missing public ID.', content: jsonContent(errorSchema('Missing file id')), }, '404': { description: 'File not found.', content: jsonContent(errorSchema('File not found')), }, '500': { description: 'Internal server error.', content: jsonContent(errorSchema('Server error')), }, }, }, }, }, }; return Response.json(spec, { status: 200, headers: { 'access-control-allow-origin': '*', }, }); }; export const handleSwaggerHtml = async (): Promise => { const html = ` TeleUploader API Documentation
`; return new Response(html, { status: 200, headers: { 'content-type': 'text/html; charset=utf-8', 'access-control-allow-origin': '*', 'x-content-type-options': 'nosniff', }, }); }; S{ZRxWo6_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ħ xh100644 file.ts.V/Ou`,C 100644 logger.ts fc{_5>r(100644 rateLimit.tsܴĒgh"100644 telegram.ts3?b9o)p: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ĶxVn6}WLܾ4[؋xf$bc*I5uz7/:ɲXm̙3CRVtGA)E |‚S.xɶK(-8s?<{JýаN`LѲOuuWoׯ7oަҺQlFT o_FHlqT$ZG"[V2َ(-GގJ I-U ?=I7 ॰QKV/zP(ֳ!:"<2X*]Q+q2BbjC}{&dNy[SnSdxؓ{ >4 nN/aO!D6lI;A 9-"eB tCi3^G¬"R/H7"H%f|f.+ŗkjcz]iNpҘڱ/8ePqdahZyG&@sS{YaVr62?B%gG:OuV6R b*V6S$1-9)Kdy<BmՕf`.s_Ñ>YY'<^J̈́.)o.d7'-&a oJ8腕c\S0=ck˾u(%sa:LqhܘubA|AybD) ;Kxm~YMW[S] U|u\QԻT*pbDipbf茠 ER{Vc'L,8 ttS?q!&Ӿ;ӻp?;=C6qPg:1*oط7%C\Ԟ5[w2LvY|qn8'BDx340031QH/).)J,+I-.+)f82U˩ܒ&^.nS\WAkSWB"ElRજ?Jptά:mԼ2pQnX!wiPei9puJS_^haG~ک*G}(gLtp@f&dUnءqg66R!>JCU%df"<ci%h~5^iSJCzz NyuWNV\y~BTiIjNjzQb.\ǖ ݚ9۴.+?*--OL♤z~5kř5t`x WoZ|=3IK*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 Qx̱cJ"B035YhxTn@`$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'+_WxTo0_q<9Z7`؇M@'{@!79ivE>YOCs&X Ĵ6o w=%^ߩ[ <Hg,j6ټА"pV I GǰGKG 0vh>\]@zwy=&"@)nr/urm'0XST=pȐ'}spBÀEi\Q$B9WnRf&:6K٢m)^@oKPNo7r("i34A'X+m }7[n=e y) F`1;b_O'_xy~ ٽ\q";ɬǓ/a{ʹxXn6}WCiAIh#чphibV+*"v~C?O"uߵ@ p̙ XwJ~0p}7( ,Lp(~P9o9j~7"\ATbu-J=vJSZaa`!pQ*EJ!YW2+ ,N LqUXA*LN%FDe7O @,2%)~}TE*QJ15K*20_ k -$fy"X|cSgHoV6(%[pV31O덞ǫTl PfCiכg#J3c}?T{E#L3D íIћ7FhB#|CV4[50m#<Ű(D1)gVKx߻p .)o({[VD-%ἤa h e^]v(1"+YaJ5KSÖ-#d7(s߾~Pl㝿^Џ1JY]]6ֹO)bz|Cj!aHؒTZ"zҡS2RNۨ=N0ȣkUvĝnN@2qzJu[D1Cl!ןg{'VkOhtS7#_B" ۄ&\5[k4F4C^;smDg; ym#ʠky7~kERmiM7˒ٮˑ+oܹ<[7q)@aHKjr+tW<'KŠrAXӈ.Q޶؛{3`Pߍ{A]ף=`p#jCrĽiLp(VIߩW_g 1I}kU3B.̧/Lw|:aI֙fp'o֨%m?;y93jGL`aqzy5!aJBhMgSG/0N)H?AKrܰtt?xßuTQ}XKwoM˒`^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/**/*"] } nxP_2zߥ;ؿaB06xs]LB_x<6 ^3 3,a"JnE=dV+)G `x7_!Z]6tdh8@B}s]]4erroPhGDpdCLx{OcB\|ƖfF&qUs x$40000 workflowsvppȐDYN$x&100644 deploy.yml 56Y "ljY q/x"Qz #f%K<20Qx tvNu[[.+)8x;|yBȖ] ~:_=K*ʿ V,xG)h40000 docsG#MnJN=\\^ZewtvNu[[.+)4x&40000 superpowers4inҴ~YNʠx@40000 plans^p@mU +Q40000 specsI*9йtBd;x}HH8exJJ)x#QstvNu[[.+)9Im x2!pbɍ(x <G#MnJN=\\^ZePƠ .x=)zh.100644 docker-compose.yml%}5 v=U[1f+kyx )z;9+x<)zɛuW*hl;ںx0S'?Q zoG9CH9!x+}Z'F̅T@T{ײ?" xI100644 index.tsvQfzZ x.v100644 schema.ts҄ @H\p,F)3Ox?Y3g~F*9d:i40000 testTc%8X g蓌)m>Rx@?64N wCf sxĐ &-aJk^%|J ; 7xPinput: any = forceDocument ? { document: fileChunk, caption } : { photo: [fileChunk], caption }; const result ainput)x-%94x F։E뽻*5H>x(! [E*0x YN1x͇*J5;dmH* xar~7}; ݊[[x\ J=҈--9QG/o% 4ExIGF" tele.asepharyana.tech/f/xYz123! % }, }); }; /xX )vwh|tq=V)03T@+iɨ΁xN40000 test'Qi?u=N6)(OlXx p"v x9100644 bot.ts^@;^ZJP_40000 db}Z'F̅T@T{ײ100644 env.ts#/|Z+<%$Y c100644 index.tsm{JͺcoŞ958,40000 routes/V7%kH\uN-6^40000 utils@?64N wCf5?Igkx ,=7hVxnPv k=x P{OI%x`}]"٣|-x̯ % T`7 Xx  "7_Xrgd)L=x! src/index.t+EV E]xVj}p}V e&13=R*ʄ e)M$xQ,&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+VxMimport { 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 / ix dOx[import { pgTable, text, bigind1*import type { InferSelectModel, InferInser*n{ x( 72K n! + '...' } }); [x\ $T(I&"&.${ handleFileRedirect, handleFileInfoS{ qxS msg.document?.fileName ||. = msg.voice?.fileName || msg.animation?.fileName || 'file'].% msg.audio?.mimeType || o; }; ~73x3,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"); }); }); *=$x-! 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<* Yx\"it, expect } from "bun:test">"../src/db/index"k'>"../src/db/schema"; describe("Database Layer", () => { it("""5"oi"%"T35y1xj! "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]fx(-,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"@CpyDx+ 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"""); }); }); ZY6Y^xn(describe, it, expect, beforeEach, afterEach, mock, spyOn } from "bun:test"; import logger from "../src/utils/logger"; import { config } from "../src/env"* "telegraf"[  { file_id: "photo_id_low", file_unique_id: "unique_id_low" }, { file_id: "photo_id_high", file_unique_id: "unique@_id_high" } ] })) }; } })"info"","error"); describe("Telegram API Utilities" , getFileInfo, getBot` "../src/utils/telegram""getBot", () => { it("l'", +_$"forwardToStorage", () => { it("C<"0"fake photo data""test_photo.jpg""photo_id_high",Q "unique_id_high" 123456"File forwarded to storage" , \ " )" 8 ="Telegram send failed" &"fake photo data""test_photo.jpg" P"Telegram send failed"*With(" !" error: "Telegram send failed" %"getFileInfo", () => { it("5&"url, $ "getFile"& *D"some_file_id" } }))# "getInfo"& *Jf  c"image/jpeg", file_path: "photos/file_0.jpg" } }))); } 9 "Unknown URL"U6 "some_file_id", "some_unique_id"/+%4"image/jpeg", file_path: "photos/file_0.jpg" \ "L&". ok: false, " " })))s#:"invalid_file_id", "invalid_unique_id")).rejects.toThrow(""@NxBdescribe, 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" ;^rVx?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+vxW1$kjj!jjjj/j/otstrap.test.js# } } Ox4рTa\;=WzOj;l83_s2 x11$?types/bun": "latest  } } kAx 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!0 Jx4̯types/bun": "latest, % bun": ["@types/bunq/#bun-types": "1.3.14" } }, "sha512-h1hFqFVcvAvD9j9K7ZW7vd82aSA+rTdznZa+5bwvCwqSB1jmmfLcbIWhOLx1/+boy/xmjgCs/OMUL8hRJSmnPw=="], )u5`7|C(xconsole.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@Psx?W3VN_y%ss/40000 test] Vd ta=r)Gmi1x aAh?x-rox?W3Dy& BC40000 test["U*|x\Z)j-x "?Ahx&100644 upload.js)Y  )ap5!k"x T#|Ux?W3(^yZ2 x%100644 logger.jsgT`x]ɲU:SEKd>xzMM@Oxo?;5n8.DQ#W7\b'>Fϓ'03)*WdZ@YUc-40000 testH_7VݰY쌈瓊)3Lx  sk8}, "peerltypescript": "^5. C'typescript": ["typescript@5.9.3", "", { "bin": { "tsc": "bin/tsc", "tsserver": "bin/tsserver" } }, "sha512-jl1vZzPDinLr9eUt3J/tB7V6FgNEw9QjvBPdysz9KfQDD41fQrC2Y4vKQdiaUpFT4bXlb1RHhLpp8wtm6M5TgSwW } } V%xJ-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%sxXwl a*t) x 40000 utilsze1SvߕQ{>yZ2 ~kNx M)Hgx8(\6sɭyg-Q{' 5H RK) @x# teleuploader To install dependencies: ```bash bun install ``` To run: ```bash bun run index.ts ``` This project was created using `bun init` in bun v1.3.14. [Bun](https://bun.com) is a fast all-in-one JavaScript runtime. Mm x8{ "name": "teleuploader", "module": "index.ts", "type": "module", "private": true, "devDependencies": { "@types/bun": "latest" }, "peerDependencies": { "typescript": "^5" } } 4B:x(100644 .gitignore-'NW|ݟ0ad/ [100644 CLAUDE.mdvLٝi~~r( 100644 README.md6sɭyg-Q100644 bun.lock?;5n8.DQ#40000 docs?6'x3H۟100644 index.ts{,dTώsx 6Ѧ100644 package.json' 5H RK100644 tsconfig.jsonI}rR%~wڦx&40000 superpowersJJ5&(zx 40000 specsI*9йt菿 ix uz_;f UZ >