From 87d7e5752b92d068f3d291771427bc1984f53325 Mon Sep 17 00:00:00 2001
From: Izan Gil <66965250+SrIzan10@users.noreply.github.com>
Date: Sat, 5 Apr 2025 14:05:32 +0200
Subject: [PATCH] feat: thumbnail poc

---
 apps/web/Dockerfile                           |   2 +-
 apps/web/package.json                         |   2 +
 apps/web/src/instrumentation.ts               |  22 +++++-
 .../src/lib/instrumentation/getLiveThumb.ts   |  21 ++++++
 apps/web/src/lib/srizan2.jpg                  | Bin 0 -> 24941 bytes
 apps/web/src/lib/workers/index.ts             |  22 +++++-
 apps/web/src/lib/workers/register.ts          |   2 +
 apps/web/src/lib/workers/worker/thumbnails.ts |  67 ++++++++++++++++++
 yarn.lock                                     |  17 +++++
 9 files changed, 149 insertions(+), 6 deletions(-)
 create mode 100644 apps/web/src/lib/instrumentation/getLiveThumb.ts
 create mode 100644 apps/web/src/lib/srizan2.jpg
 create mode 100644 apps/web/src/lib/workers/worker/thumbnails.ts

diff --git a/apps/web/Dockerfile b/apps/web/Dockerfile
index 5cc6bdb..e83b8c9 100644
--- a/apps/web/Dockerfile
+++ b/apps/web/Dockerfile
@@ -17,7 +17,7 @@ RUN turbo prune @hctv/web --docker
 # Add lockfile and package.json's of isolated subworkspace
 FROM base AS installer
 RUN apk update
-RUN apk add --no-cache libc6-compat
+RUN apk add --no-cache libc6-compat ffmpeg
 WORKDIR /app
  
 # First install the dependencies (as they change less often)
diff --git a/apps/web/package.json b/apps/web/package.json
index cba7519..ecd4998 100644
--- a/apps/web/package.json
+++ b/apps/web/package.json
@@ -47,6 +47,7 @@
     "media-chrome": "^4.8.0",
     "next": "^15.2.3",
     "next-themes": "^0.4.4",
+    "node-cron": "^3.0.3",
     "pg": "^8.14.1",
     "pg-boss": "^10.1.6",
     "react": "19",
@@ -63,6 +64,7 @@
   },
   "devDependencies": {
     "@types/node": "^20",
+    "@types/node-cron": "^3.0.11",
     "@types/react": "^18",
     "@types/react-dom": "^18",
     "@types/ws": "^8.18.0",
diff --git a/apps/web/src/instrumentation.ts b/apps/web/src/instrumentation.ts
index c9d2219..b2d18f1 100644
--- a/apps/web/src/instrumentation.ts
+++ b/apps/web/src/instrumentation.ts
@@ -2,11 +2,29 @@ export async function register() {
   if (process.env.NEXT_RUNTIME === 'nodejs') {
     await (await import('@/lib/instrumentation/streamInfo')).default();
   }
+  
   if (process.env.NEXT_RUNTIME === 'nodejs') {
     const { registerWorkers } = await import('@/lib/workers/register');
-
     await registerWorkers();
-
     console.log('bullmq workers registered');
   }
+
+  if (process.env.NEXT_RUNTIME === 'nodejs') {
+    const cron = (await import('node-cron')).default;
+
+    const getLiveThumb = (await import('@/lib/instrumentation/getLiveThumb')).default;
+
+    if (process.env.NODE_ENV === 'production') {
+      console.log('running production cron job scheduling')
+      cron.schedule('*/3 * * * *', async () => {
+        await getLiveThumb();
+      });
+    } else {
+      console.log('running local cron job scheduling')
+      setInterval(async () => {
+        await getLiveThumb();
+      }, 5000);
+    }
+    console.log('cron stuff registered');
+  }
 }
diff --git a/apps/web/src/lib/instrumentation/getLiveThumb.ts b/apps/web/src/lib/instrumentation/getLiveThumb.ts
new file mode 100644
index 0000000..8677f02
--- /dev/null
+++ b/apps/web/src/lib/instrumentation/getLiveThumb.ts
@@ -0,0 +1,21 @@
+import { prisma } from "@hctv/db";
+import { getThumbnailQueue } from "../workers";
+
+export default async function getLiveThumb() {
+  const liveChannels = await prisma.streamInfo.findMany({
+    where: {
+      isLive: true,
+    },
+    include: {
+      channel: true,
+    }
+  });
+  const liveChannelNames = liveChannels.map((channel) => channel.channel.name);
+
+  const thumbQueue = getThumbnailQueue();
+  for (const channel of liveChannelNames) {
+    await thumbQueue.add("getLiveThumb", {
+      name: channel,
+    });
+  }
+}
\ No newline at end of file
diff --git a/apps/web/src/lib/srizan2.jpg b/apps/web/src/lib/srizan2.jpg
new file mode 100644
index 0000000000000000000000000000000000000000..67a527b3eeaf43ffe9ef500bdd8c75e4eaba5e8e
GIT binary patch
literal 24941
zcmeHu2UHYE*JvXuMiek0Q9<BCvgFLJNRR<mQF0Ja(l8)7NLmvhNkpQ|;7U>$KqP08
z0mK1D7#Sod3F8nY=T|-G?*8HX-+Slty>q^EEa;l<>Raj7ty?$s_NVPZ=;$RiO*M#S
z7X;COKWKXkI*PFLw3ZSR7Lyeg6BUKFd!P%@zTI%zLrr`Cp6KZ4_U+pT^1XYhcl-A5
z-wz7F&w&F64jnppke;5Nf#KLT4vL0os0sQj(e9$zP4{0)A-MP`4YZ4fX7>S_-MeT3
z1gJx^i<aTCm<!`C(Yu+hi2r{6jO8EszaHb7t!=Y%og2Et04hMVbhNazyZ@?ip20=z
z3=`w;mo1}zxg!3@ulZcHR=a11+KzF%&TYSe820U!p$np=;evKCK(q|db~kj07PP|v
z?v<gnpd-dAe+~BM-A@es#K2Ds{KUXd4E)5vPYnFTz)uYPn_$30R=Sb1>{Dn;D6f@t
z^MzFQMM<(lNqUJU(QYN4YXMCPR&n|8Z!(u}!(=O>n9a|>3Q6omGSp}U3q34e8yt7B
zIJPJ&JN}$)<~1rZV^~aK0-g7Ju9@eBss_AAzJu}8k&fK8ZOBYp%{wJbeYJLAE4oJ0
z4RO$kRIuX3p3$*7NM!K4+NT^y7pNVxVuKVH7h~)-&o>M$bokV4o7pSL#8mF#inJS`
zug^x2LZN>nq|r3Tea>rGT?w|5MDI@sNlba*I=Wf3_~dtu5bPOb>siWa`cjA<N0!Sm
zxtMB5ymQ#PM5sFRc6@IB7ZUp#ihQmGiCVl<^swR41g4-2#l>gFZE>3ZU!a**M2xmX
zTjbU{_siaGsH8(uz<8l?pBCeCShFhm@bYpOyLzC1^v5?d7yT|I<2SDi1fm{!Ep;8D
zyXYs|j9Ys;GxeH&tLIG6MBd%R&_$uhdGEM{$@TQYnKWZ}6MCCl!?xi;G86y80RN||
zvf{`4$8SeD4}HS6PCT~BueOpZ6z?DD_9|W4Iy+Gk>Xw^w^)_76vm)PnJCN>TrDmsY
zR`t}OWdK0G%rQ{g=FI3p{E}C3L2+8K=5AGE$*j8x4(+~{J^g_I8XlZ+nc84KF~?`7
zl(qiP8e$(yn=WLRniHlN_1R&jg9f2pM&s+`*T>aG5``>nCL1KSp~D4-f}X3ubE)Dp
zRxNK85mq$5)RperT9o_lU!q@K<*7w&1a;-?;~47K;~<Ym5VYr(6GkZiuKOHHU_AC!
zb)O2G9o+YiPc-5EgsZVFlZ%=Ng_qWwtsfxbpPkUx=dflN=h{bXLxQ_;TKPydvUzcs
zI_}FC25}?OiN?q0)w{jwh~WakVJC+a_?A5c+tOFw<{IbQwVS4w-|Qjgmiuj-mW*K|
zj{BX*A`r-Z&Dyq_L#JtjAX-B*!TCkM6Bn<o#;SgFx&Wun9dWtVJhdd%KfC|)Mm&yq
z3D=0o9I!z8Z06VVhz`qLX?S{Z1<|-~6<OUhEI*0iRV$1-v}p0Aq{3`k_ZS*nuUXXZ
zW({0jFY5n1rwJ~tGil!63I^=^2awdqZRqMc-fU_KJ+%bjL*#PC`lq}~de+#dmbStl
zL=UxA`0Fo&E{a~X1inPLWfaWO*UxZfT@9ZjvTKtTipi7}6*+<Y7Y&up?dHF;j1~oq
zSQS=Ucy5N9&?CR}i3tR-X4XAB|Ig0^z7%)f4F3;F2|j1ooXeb-2Wc`?An15)xry~&
z^8e4ZM~?~ymUTlc*Z;&iw2RluBZ%%fUlNyfn(pqIysS`jIopdAr!3t1lpBxFOR+C^
zKaA#I8PF^0HWzqngsXcx7cp@_*S16zSJr!DjpCeDZ5diu8IXA0xwNL!<nkSEzc1R^
zpTh+;SBMTCY5f6mOG3u=+!~%-ToNH4td_rg%HUwri(G|nKKpAB-|qH`-&VY0AYIVG
zBl<NxYFS=|7V$S2)d{FtUQJ^?V)_p)*KWQX_c;NgynbDcnfFY@;Gx35LH>tZOkmHK
zq{MB=Im<!sEO!`2h2;h?k0ChARA&Q5nQ+a;oIR2ML-qgA*8lxOgR^bcrLiU7v<wc7
z=}4&nu=7rXR)l&-)+w%?4`&>n6fJWJ$=EM*U@i7!SBx)mb)-DL<!lk*DN2hC0+6(Z
znTSWPk1eY+n-7rqzA)EEpbiY`&Xqjl8L*g`$t!BTR;AqEsD!D0AF|xp?bXGXHfloL
zoSfW-qIIX2wxQU2xA9XOzw}!;53_&nX>0XY4D6@uTL$DWZyNtpRl7)5Z;albZ}=L`
zgEtTz9}o9(V2Ks47xFBbb&MMcgde58nU~8S0lzH+Oqqo(OyA3x-POvn&q@W1Z4Hu)
zO8r~@42&51C)`Hf*m(U8m#x>yz3WdmJ<4Qe*!Sj-_J^sH<5bwF)g1M5xG6)&Z|N>#
z1c%jUop-rcV=P}WU4>u%H;G1J{SQg;>3bcyhUzC3mUcL*C|J|l^(VR~<vtm4m(mJB
z2%LM6EEXjhkr6ZKe)xL3pXQsx$YSu%p47~y@P_5h;D6KfzfyF_W~uR5Y|B(6KY#FJ
z`P7J%LfXi}cVHp&t7UTUIY$cQhgBbY(|3LEF<nV3ULkhnEC-lAa`=qj%H*eirXi_7
z5PM!rYPe9~LyJ4!)+UsEt#zT=aLp|by#o?;CAlx4?(3kr!sW)3?3vXvF%^BE23Rd`
z@ml3$Q>%PdnTzeB9&T(di220?u%2=%z069imadoatw477jJ`oBiPwZc^rWR+@~wS|
z5xvJVyi-C~)+e0WHgAqQB=Xj<A8O@n<~MZ?bL@yQ>QTJjZc|X~+hXgu7=)xKjs5L@
z+M!>>?>tGwFAz;{A~+dukEzh7;dui=r&>k{%oiQ|P3P`it$QD*1k*e~=&n-5;*tFV
zcRfnWLLc9jyqnVZiqR-JVYp44VSerT!mlS*3g`6bi3&`Oxk<)KUZu2}K@fCcuutKN
z$uWB!Wx?T_&U+=R-^Ic7EZ>XalNBFh8SlhlxxcY~&88GlH_C9}!F|h#3Rk?q<!ak3
zOUNWTFPFbn9Me5k@_<y>S|C3Ac?h9aUSw+A-NwMwXnh^<?Oo!xDb=PkBExa3dSlGn
zP@C?F4dFBW7WI5Sfya^)=Q(3iEHdyRUh&|J0fp!MY6*G7n>cy=N_wS!QBGQG4ddsb
zX0`IzhMWxU4DT1TLO~FxV~?b@7hz&j-_}Lkcm~bFSd8qU+!YrWQaiTs-YtrgA**kc
zds#gbFP@a*`e;VDI#)+=i;MefUZC0I4v~`)zv=DXX!b30&=(MASoJz`g6JLk8=x7b
z32g+Rdt@9#17Q-PoTlOk79xr<ygnuer#{k&1YFu|omsWvvT=8?;o`j+-np6oCFXfi
zWJ24)Zf7}s<lS84X=reQ<z4YP*M@?c1?v-vfrV@58hEz2%S$DQtGd_svVsNsfyq|+
zwaoL}z?<G_Ip>$3<QFXc-l%Q}+V`xU7&%xu<yEF|rG+BZRw<~Frc=ITgx5w^Tb`;K
z&oFfrt;82>sfR2hg>`(^Zm@=gM4XXLOoaCcq<2D5xo}N=-PMLm((}pF)<^wvUkzr`
zYF_uUyY}O6>F}ATuH|IJwkw^1j>GVtn3ds?(#^$T9kQo%!zT;Fki;j>K9!s97mRY&
ztvjSdU#2<qOD<v(rl}hY)PNk|j7s8%ioyms$1lX;<$1bob31}GZ$Z#rHy^hK1{3Lc
z1<T{`ft6ASNxT6Sa*v=&-)avx8LLuqmqnN)6CS+E;94VOrLu2YyKBW@e7Vkq)K$Ke
zDRr4&xnd*0^8N${iJ0Og6|Z(QP;~CiiOFqAgizU8$Vc`ZpPZvLbu#28PL$Yfq#bcs
z|83?)@0s}Iy=|bYW3|=2%H0m0f$p=et2ePCWoB8><2TTJ>+1diE`oA%5Ck0_Twc>U
zyc8(jZdz^hiNwj;>G16AtCp{%6xUWn)$zqAJ-M9C>wKYMnFrRXJR)9gnNM826147o
zi2PV-i<!$k;jy)00{BTWc(&X8fxOz6G+3M|Y}z-xiTC_2$`;rU_MPJk#TdL@ciCFy
z(}=ivuqVj_DWzjS8u6j-Y90b9KdNA|s1sejBY+^;d6$Se?@1`RUpuh+5)Yi65*Cs4
zXg%z76h5DUQ-${x7{ZTCVkuqb`~q+WbLMownPvVaV9?_bt&fIFzmoDZg_G&U*tiXl
z4B`#$NDk(_mg<|&3rw667z>*T$Da!rZpqiU;MaxTnz?S_Z^d)_p@IYWtXp>xWWZ=U
zY_(K3U(*)IHRFS*gQvY5Ip20BjZnv}$HY3KrUDnTBab8=Dhh7C<E7JxOscTF&R`0T
z&19Hm>QlKVET)f7(f>_Mha@%92utW)+*i0za;grw3NE^dtLO?A>=o`cJHFe^vylfa
zhw8lvr#2vQ)^4A1ztYK>_>(?w*dUq?(c77KP=m|5bRu!aZ`WhHU+fozjwsB;@9!6$
z-*^WEb-Df{?z5Ja9OS{#udNNQsz*JuFpeq3ih)BFJ&(&57EZUa2O1Q3cM?|`y&%+S
zcnT2R^O&4-6lOl-W~tZ_txF4Nd!q$ir7vl@{vRGcY1%*H-vrqQQFWXGBWFB|+Umvy
z=A7d>83BofEty8vnI_FESDcCW4I}3BY*d`|Ah4m1*Xi~trF<RD%#idfdaCn?B<L5t
zto-12*~G#xm8z=t(7&QWQwRN@vxY!N7fsWxPs5KBe7MVHy4EiQNr1EZdy+4^WRuc2
zzuf*vC#IS`C&y?=1OYT0PGO5KC&pM2iIm&~eH)=j8#ybzBHjWHN&WaR+$u3#VelVM
z8iD{`cao%WOQyz6M}|4^iP21rM9)}C;e~7I_7wr0zwjrbDUI|DZ?uG!EE4+G&LP}X
z8#?Ws5*Joo7sDDb1knS}KpT=&-Xk<Le;Q59?;gwjWVqV^6x&icPXWw?^bT?vuEK+V
z1IoW8c_z_5H)H9I45qZ1V5EI6*;hc!j>Pj(z#dCEFw%5#gm}o}fVEX&eb_99X+2eb
zw9(eDwEHv!(ZB54B-TpJ-rnTFe~zP4!!9j|wnd3N%ruSRno*cRKLaa4@m3_(KA3Hd
zvG1a{5G)GDWFXy4bV63NyH?}bL)y963Mt~S76{Q7nR*pZtaSGaT9o%c>c{pl=^X77
z^%!yD2yNI;#-x@;ogDfFbMxt_<;q4u6kEIPxS93TGgp*U|D>wE#J&0HdmjnqOnOJo
z2G;NcvbseFA05=hl4G;fez;-TMGq6;rM8%iy@*VcLr--mg|(xP6URT(#H)OR{9!-L
z1R&W7r1Y>|F*qWKQfF1RyG3UNT0b`J>hF=yIuh0<-;1m4)Ru5Q5bf`wRob*j`aIOc
ze(;bRYNC@DlP4c_G5bV>(7yf{&9?G>p`x&%7DdZP>_8`hoY@z`44zvV?vKz&3?=<F
zVw#Ryx(f;Gnw8R{C9UKY*S4ISSb6t;#aJ4iJ8G^yaWTaKXFf&P>_>Ci;?Bswxi$`}
zdSK007B^2JPgWmvLPvH=dcJ+bRSKj=*~+q!eIifs7|}ZkMvRSwZ_41FTlP6s`_X{s
znZIn4=0I~>ra4+aofzN>$g68sWQt;2@Zj;&(@j`?knJ6Zy6-SIz!6RrK4>qC9}1!b
zfgX1yC=fKY5lk5xLgk+F!EYD4U+l|;j!3L$hUk`ihgHs3dj<gp*<pKW;GX*EqkdKL
zY5I52AVll^vL*1vYTWV3^&ADZngjS!mz*ILMwlUf7x3$vIA`7)4!D}q{D~EV-3<lo
z;>4}T`y*c@covfr;?rE?$MbrfJx)dNU0e(eN%#wYKk9C;_&Rsg+C|5$cOzTTfE>NF
zIHx^>_QE}RN;fk5a(EB0Sx#7=Tv*nlbq^AK1~V6w!u%Y=7ZQiJ8`IgeT_OK@D75Y^
zk}D|*8!!9Y1HFuCV=fU=uhm!i>2!=s3UG3EUn$C%$Ce()8o2mrSp*gY$-%q{h~1*#
zVggu3EcP6P9u7j#p|P*y;is#eg}vV%u)Lwgs(hU~tmC!orN3Sp-0VGrAB}qz@cAFR
zw01Y-KcgksjTSaEve&ds)z_!GpK&A>tI&NP8aU=3Npd746sk6AM9R1DIl8~ie;l_u
zM$!40(ARJx<E*(fS-9YF?-O*v-0sh5YAcxi=JP(A>~(3)bCG*_&+1Er4!=9#5Yiza
zjXo1QYjDXQA6J5q3^p%Q>qsKtqb^cTVjJ}cVq$VyPfD&bC-^f>P$>z5`0sQZTRYgy
zz`}-S0nrX#(y&GfeJX&xw81MG1kqrYc;^iJN|5<Rk8K31jR@;k43wudFWtQ7QvG=e
zLh7p=R-yfkwNb~nTgDEz!9vMPEns3``V4ivq5Tc|=un(wVrXHQ5E>beu9R-~v31W6
zGqX1A??1eNN$gX;ucH0icP#v<-~U20>L-=$Ap1vPzerb!h*y&4bWP$jO$@yrBC!Zc
z>W6@%V<iuLdsor(f?xgcek&{39LJ8_nJMLaC~<p|DNBx3MNHM$`eqP2I4{2?PbC|f
z(kcJ8h9h^RYwbo8BO-+`DdjSkgjE++wTkn!GoZf#1KHzbHOv?G_sO$o_)gsqx(HgL
zin2#7-~(lk=xd&clvh;A=)mA+f2gF^SL9r7t}!oCjDDzDf9`x~O5iqR(X<if_(0av
z;A!xf{}WqYjWj>!O(vk@Wa=C$G8I<1`PBMWd-XKbe*OC}cYf&`n{g;#X+NGj<pXA6
zI!j`<L#F$-#D&G<lH0J(4;~<$5}lAILPLG-^BpeBRCA8}sL#u@KRtEm(GG=%CZMf{
zjK@>@ShgXw=5CycpS($TMY_}0Q^C*UUFK!m(7i@k_t_bFrq=s;Nax3VnxS23rSfS`
zwnm8^j$7T&Gc-Go^GNfv7*rO8$@N%hd>3C!{=lSED<W9awYfY(tx&|!-1_HL-o_}O
zU}vNB3^r$9aTa(6yH@fDW_*4D#y%8qjvmC-Kj&q}<tAIZelqxy3xouk2SGa%{ZTm$
zrfn+nA0plU`SoCF)ZO#vmv(s0pB;E$J;o9-A)#>w8A=GZVk-|<QoB@9u=&e{ND&$O
z*8oo5!rdj9J+EA*c22lqrF%ga;iAsN8?*SKaE6zwE$yv)4Ps5m*P{_Id&!t%#A&J5
zX$YOqHoOICL9ob0Ta=!se87TDk8NsY)fL4c=T~v85J$kBrOgFz4_htQ30W=I%4b>^
z63kwe0<I51tuQM(I0|#6+!N;Hz-ZW-hXpVGN>fOJ-CY+3>_n~{@?qd)-1r{~3++C|
z`N5$%nVqf)h3(Oq<RSh)bup;KHi~k-N5&d~;tNgmy&1IEY=4B6wH?D-b<9GNiTa5t
z28E(0`k|zwRlX>y+(GRMxhb*!k$MNL?XgU?<yUo?&aW6*SDdnMG4r)Nna)-?T3p3Q
zI$on&!2EIZa$gV&Y;;5(U$xcj6TF8**b9?v3b2aY%+6TX)|I~6!W<@}HivE@mN&GK
zLDYtSR3-+bipwU-#Xwd5ZY+fL`|pXq-iDZ_mPI@w0`w8Qu|QRKJE?DaOfazA|5!@W
zJ3gsIv_32VarfQmTD@D|G_>)y&XnT)z~}h9a@3l7c~ikWokxuA*a>=%%3t2)C2j<^
zD>mq+mNw;IA2-3VJzPy`+~n^4{Aub|KQFKQK+$hwJs&<3Khiwt>qMTY({kFXNxhJ7
zAAti~&LQ@dxzdWbWMM$p7gGnZOq>?e??!#%M`Y8BwLTz)=WB{uRsAjQA%l6!C5HQM
zk)$_@#T`v_Lq2ufdI?OMPZJ2vA$i&Qh5C|DQ1(R`wrO>_1$n_@dFj4>Tg_At46V2S
zR=7adNS{)q36L!tW}g9_1(21+pJbH*$jaJw3OX$M9YNq1*cj*M=#C_Q7!glXd#wsI
zx@tKumu30)*15`M-4x~ov?;gObS?*{?x}(G-8ck7S3|V>WLkT-ZfaOJ@Mr|C#F8aa
za<bYtO_eU=>c|+@8XGEu0BzGf$C!D`jVhGSdI;FWKd*R3^9DM+zV#bE(q7r@V8PRI
zwl!%jd(<f$R@-AX=<xHMVbRQ=K43uCxP)feQuNd7p!YDqn^vr-8muhN>0aLOUCDeg
zrbih3Jh1uXeqa>v$Z|I3J@k#dsjx+_y$y9~=&j5RV=@DyIQZqVKLe=v+e#Fv7XBtC
z7D~2ezei!VMpC;ZTagbXQ!h1IPA7N9XN;Hc7vxY*rkT52Y2L%D;g`r&{I!*reyyta
zyW(|xPOI|0&*nBnZiSmyH31+x!`1w5Pj!_;Wu>>Fn~W!>1%_kbVwA$xS$JH}ZTJk$
zOU84n{EWaWOeQj_0&Ue@cKb?OO_;X_E^RK7@xvjhzb(QKxNSh$<fpl(<54jm7g+Gu
zaO4OHn@^W-BeU3wyA;)higmB7HDN1SQx1LQe$Q4sOSp`8KC~!;O=@ag*hmhU7f}|f
z6#wYjQ>Un__8Q42=O_Oz>iqmy@T?BMSU~c=cFU{<Wx?RFgO6uJ{9`p04(x&_vd%-8
z)W=(=EQ};$&`R_d177;9SFGI3rSJvkTp!mBkv%@ouXb>uS$*_Ht;V{etBZ(IWCJ_*
zNN)s}L{!izI|zc!0^H##jMI<pMU*9r2}Uib0@48Add>d%5nL6EW?JP2sYlTke$%uy
zQ%i_CqLVVd$_p+LX^AOJ0kFH;3Va-I41VUbh<@#6;+UMLm%^z#I>B74-0oeXd>q5r
z+^Ai6h0hqb=J3Q5IO}k_LoZr1d-gqS5m4UOAT%;=mZxeSQ~qJ5;S<H@fsfdj@%T36
zc)LnmGGhK{OF?@@P02)%+Hvc^lYAV+axV6wDIb#Q-UTb08_)+x0y<1Hk?v#9@Fnh?
zo5>fYn>J#oa{27v&6cL1{l#E)!7l6%sbXC&!|NXMkVI(YxD)kVMAxQr%N0h5c#A`_
zc(X?{a@9Oh8}p0mg_R?1;MukFhI~t2sPa6agQI;uN?pkF7f|Yk9M=5?L`-vxOdYx5
zA=?^7|5dqM5o1YSnXR20x{KzZS6@~yXjW9TxSKue<`13%IQ;o;Bm+{=Rhg0h@Hx<H
zXkVjGpOL4ixfl5$y^dtHM6mU)6mh8yG1FtY+fdw=oYLu2PZ2W?Tmt11up^gCQi(6{
zy-$W!TUxUpUyFZ1r%>ks8_A9^>v|h&%~+AU8C6%3aX7NrAB4bTi%n96Gl_A}g;>Y+
zg(T2zV(T*Bd^2sjH@)S?l#>kZzK)&OYBSn`o&2(a!e;x>XE9=;^Yq=aHkS1mpCLI&
z{uyKkO>yxqhTe)4e>SO)Dwi}CYnRq%-w>DSKcle?akf;&<k^-?uQ(OuSZf5U3Eei?
zdYU6();92&rcvbw?5Y2u2`0jA5)~7`yse08IM$5Bia8o$o9z`ie&?9y0|M!I%|ji;
z>fIC$9vAxCD`~Kh+WP$&iNX{l_1I!R6B1<Sh7FFwu%ObP@XO#HzF>F@#?s*1G4*`#
z#S7cfLrpJKH4VoA2X9P_(sf|a&*f%+z76S3eDn-K&t)Eo=Q}VvY1Qt3j4g+ZYNv=Z
zv37@s_TeBpk;xJ|Q`p#>YuB@T8XYBbP+<_BV(}3Xl5tIg{4KX5@oYEnqdjf>BcXlX
zL-#qiextei9SIJ=iuMbG6q-xYfJ3H{)y6k)=&7*)N6wWPp9Rk+4-GUH-5C=}9wzQ~
z@|heN&U2ByN5_i0C=Ln!F1grYtBbr`)&{AX5>I4vihWxF0!n=JMqB*@5|=GBCE`<H
zY{1~MdY{KT$thj{^1m(ovwA_SlFm+Ts{G$kAK*)tAHrK|Tbp@!CKOeYE08Kw2eZAP
zZDL3SpK2NCw<q`HRb=*whKH>&j0^U>kLTx292b*e&H|W6=YL`}?-ykk=S0;0&XHWJ
zbo~9a+R~D=2rz>Jd}a}5G!~2t^wvw)NH!92BjLZAW%_&Ten~>7`g`-{xV~jhaeV_~
zU#O{?Q&<L%xSm25du^h{bbb*J9V!PeFb+tzwl6Wnnqj?ZE-z!tOBN3vV|b6XWOPKV
zw;wA$*f0|(1Y1JOpBpB1R}8&jzvac5XfDht`gt1Yp7CiHDgiBEw)m}Mlq}8tyki?v
zz=Q0}4t+F+`qKSxp7*+#Bt;iX7dAJ<q`JuAbYaC|cV1jC5ih4I)_-G8%jLc}>!)M~
z+;sdib+|A1+M&Iz6GvxUz0=?eCg#OC<@-3`YvPA5;BTV$_tPD6q5lu`%(P+(4>;Ck
z-WAtvW8+!osFXmmVb48l?yXt~{Et60@pLP;)k=!5r`|yt2y%yFRH$~NZ(ZyqCv^<W
zAKDu&KVo1-!cv%0+f4N5uz_=(m;#5^{MjmzQ{3j5Cv&1}-VLL-=Hym%mZ|#(c9z&k
zH;^*jCw<-+jl-?&nOpS`Uk!LQr5HPC9_`(JC3MS|5Ie?uYauFWV*a7d{)vP|8y9oA
zV`2IMSCZu$$#LpFD0ZfgBUrK$-zP{Sg>i3;a6L+qk^Zon0O5j5*HX{RrYh^v7j=~z
zXVXQyd$u7gzp;Mxr$vu2t4*b;&RyIR>#}f|fLE%4h;O@+?YNae6LR*`=PR8fO4B`z
zg+nX%xdlylqbr<9(RE|Kmm1DqwAGlkG)9@(;u96J6=p7OR47ahO{1|RV-Z1zdEr^m
z78a7aOIdDlxuea|b4=`9-XiO^#I0j$ZA3W{lZ)Am(8x0=#jeksU#Qz!BkLUTEKkJp
zS(*&EF3m*aXy@Hr>#vmBkErUvO|7<5$b8|pY9_rxXV~L>foa;1rW1zr%r}fc<!&nN
z;<{PebCI_VPb~SPH(DcMv~%QkQbp!|uie`aN(wvQ?t@}n5DR1T(A(>g`{uic&E}I!
zv!5T2pFzgTO3%ThjUrQ{D1GPqT26!WhsV;c46vr(w+`pABcmaz`b&e58m;-bac(|O
z%dMR+N5Ns^<?pCP_r1s1nw*TA*Dk!YDUmGfS_8^ocEGfGpG1lsV$W}hJNgezrTciv
zN5A*2)|ou+WU_~#mdB-q%!~d3DyQ7xiTtocBe+fhR63Kln*?0*ObR<@t3R9X5NSgB
zcENEc!D%(|PK*t#NFC0@z@om7oIb2*9)iiDkVU?8^K@}Ci*{gpY?X6`MZ{X=mnG+c
zx6HU4Uyn9~pqBRY*U$F9U{Tqd+3@a*l9c+@LnhKf8L}S4nQf>Md7^ljl;cHaPimLC
z@LT*>WeU4fAXguQ;YP*#%57-V4IRv>d|&q}pRgwR3os6N#VVg~22m3nyq@pplVaBg
z>kEu~s+m|G>MKch*XQRsYX=>+!vnSC@oO14^X{q;`kk|`BL3@C?YOVVXwTi&=@aIY
zRPv*e5ClykaJW1ZH&vZZU~U>MMl-Dy_%0fdSZiyv3(@Vb_Me0HFQuTo)AH<>Iv-vd
zx)C`sV!K2&4ndHw*sA*=<q4Jkl05Nkr>w2aQvG-{?FRN|o4$I$*ZYd9eAAPxlz1gW
zZ|y^~w4+Z@yy8SyDD$jia{kP0ZMiRIC)<7bEO3iL54wpu2`dX~e9wK?EVH_i3dA;r
zf@OMR$vZI&C~J2tu<!3ATG{-TRKtiqP7Ot2Z7b_BE|U!2aEpW4k$EyXv+7eRs!y@F
zX`POw8OY-e*d>UQuoZ3V<<sO!54A{=uMH1*UqX?Ub()&D@MsR+=!x{pZlUrjdx2nW
zZVP^E6BBz7`$X+YZ;vF#exkR<3MF<F_;ys)FUS<PORUDtBC(V~8XlFM;rytaM!0P{
za{o&z`^=7Gz!6SU?IJV`SR5p<5x5?3WMr~rsI}Y&8525mCVQkvdb;OO#ak~IS1Y6(
z!VUt4Yv5=HZq|klp~;f{T1RTyua>;-<x$XKj_xuQDVYvBa25vHg-%)a4J`Z!!fz^w
zn`M5lNhf>rJXF-Yu+Xkk3V7iMy60O4XVBr+qY>C|k%lDBz_i>4aE6g`dOvt$dQ4ZC
zAh)VeaeA8Gd^#{XNeYtsZp;>WxUsk%F?A+#Bd#+w-94Y5s1#<|lU1ExNfVba#nC<Y
zM1P9o{oF-U!RS6Vi!#L^IMxY*IKl&9&DF2GJfc9S%a>cwQA-&(RKTTQW(nX>&#2e{
zkka1mLd$lWl2#yi;JzDfLsfMOBMjme|KX6o;W*8TG?NO5NPkcqhRkfd^l}(?vDEKn
zu(;&NE1I|<xFe7*oVC9#JcjV7^sh72Z#TkaUh`BKJV!Nr3)~qfd8rA!6jsL*vAD(y
zK6z~U48*VX<eZTXgn~A|+!neCL6HlB!&?CNHq4*z(TVu#6l}#yOyj?koZmu}FO}NY
z-KUo|$6$<8p$&q;eqh=;UFFrwE18TF1@iww%wOg+d33~F(FDyNoSWWbz?*NZs|FgT
z6u-*UvL8)0B*iGnr0seU1ctOLfqQ-JQpu9;)=eb>CzE^tE09!q1T}%;Jz30VA3QxD
zlyw>&x<FS6A#+_*hfv*nCK>UV#Mzq#yz|fzC5!XD=D{f<iB3X*UP4DkBXXhV*Wnud
zN6w#6Kaxlm;EPCk{pr;0vUq$vdICR+Z=I$$>L#q7O1(}CJ6@@&_~5*{;7mj>gJ*$c
zLV|0@mk1W@f-zs;#6GHh|6xBfOfTDzMozb4?C`@<ANlvdkN7R_j+Uz4i~<?pi&TsJ
zP2bUoNAY&^ir@&my$LAiT$~7CLfD<I`0o^8b=3*O$1lZ&yR6rA>bW<a?4&&Ojs-6B
zx1T)o5C)^qnC<oonYM}JbJ6sqDhs(2TgpuGtnI25lSM0N#p_$D3naO|&jam7V?!Iw
zjW^Y}3k_~GzT9}|STZ<jQCH<1sCPpR>$T7&9LOanp!C{xW^l}M^OBwY*Z8j@+mLzc
z>M5mi^r%+y7vC%~_EeN_a(FK(gy{1geRj-pmgF^kxjDuzty%7Z<d9rZwS>=u*TlyI
zW`}Z^unzZdxQU%DzJoQ|wui}2*3snanG*9l6Px-S;mCl5>D)c;TY8^pq~7cR{kWWQ
zieq9BNZ5UBOeRNoJh{V`g$k)*V08A=k)lIPX}HP5#3P8%K(2LxkDtez6y<K|h@vJ6
zNAx<ooI?iWxS#SVkXci|Hh0_lHJ5gX4kvr%hlX{qsM>QrqPl_hg(kM|c}0w0*Vzi@
z^|dxY8dVi8I|<+oBO*<JBbySpWU>vNk1Hp5Y{>_zC-1=kj{xv!POeW)B%xFMtJtdb
zUu}(Eqd6V~T>um*@JD=e$%$F7R@^r94$o>tqxuGb(^PWY5R3%GsmrQ-^VRufTaox1
zC-EQ{aq$<dU{zOrOV8FDs%aH&8$LORYXqI?bCraPA_OyEU&H#`n2zb(!;6tAHuCDP
zWzup3Z@6go3Wi&a0~_CYxXwW$K67s}ESJ6Lk(i2qE~Dyr&ux8^*;%=!?Y{lv3OKI1
z`<pLG{`kX<o)@9*O5=dKJLM!?J>so37UOMf8Y(NIoH;+_ZhFeObapQ3i>uWrqArq^
z8RROb8yg7*oZHZ;<Z~saNJZ8Wy{mIKK5rG1H~xXnCMp+r6dEhLS_xH4s`K(^Hv7G;
zE5aqkr8}44n+4)ePUm6IrrQXyF($R}-GX-oN%?%G5fW%NXGhVG)f}eozxibX1k_S8
zbuY9oq+^nFC7j}BbJqM58glbHI9Z7_szLB1;k1j(#)>=5V2`r<8k18(qG!>U!e3*t
zSMm*M_78v4y><Y9OwRqZkB!+`x?D!I=)4-vMf~0OO-*fH65(07;gOBFmf2f|tT)bJ
z&mnUd)d%Z7_5C#{Hb)A5)0iZ{qGHk$z<6S5;9eQ)(7;-J!k+&BBNB4cX;6OG#2T1-
z`X7(r&ZO@)-;b^x`?YDrb~2Y<XL9Uo<_7uR$(B*wRpLI$`|%YCW$WsTkiF>liPK;W
zK9_u)xxp81_Yuj&#Cgy&>W0h3vKlENK0kzS9lgFpgyPMfX5;Qg5Kt8a*8*~t#~>wP
z16XlcZP2ePogzZUmmBx85@sR~2_RxW#a537QMD>M<aFejuOsDTPS&NOxa7DsbTdQ4
znU^G9YtOp{^3pPgqFM0yV&aPobDZO&@0JM6i=LQixyGR;2PJNNm}QNEJ#k;OI1^Uh
zVeyw>pPV9JTklqdXzwoNY>j4ZuN<ZhmN%bC#Sy%c?ykJo)p=zzW)gtKE1_+?$_FJ{
zB$Br~{}xcx#vza2u>m)|U&G|22}hreMF1CzFcX7Avj*_vCN<+qi(!Skt?KymzTYBw
zd~J23f~XM*@NDVq&2QT+_}R6xxON&12=RnDy<E8eDw}9w^xwr_!!`b;qz-oCgL$we
zjT5=8WD?={M4Ggqy^kRl4aolcttOLL#ZdWprSn#=AzMP|06ng|qUb(3u6PaonAqH}
zK(q*5jlzouXIR|ikH|ZCYtb+TRmvbHhV`q9Tk5%&|8=0z9#&M_RcJM#!)GChXmEP=
zhraAu?rFo1B9Ba8`;Ea6+I@aCZn*rEAKt~8PGZuU^(^Yf9!7X_duLZMj|*q0N2t!i
zT)~n79iOM0kKUI1+k-pw#_|^5*KE3(x)vls6})Kul7_<6)yikDhjw&@M$Wx}2LHm6
zA~Q@%?{5nLJu%7i{UV<Aj4*M`_g4qc6!CT@eOQjrg$1m#Z+MvU?--$Hn9gJ7b1Q0L
zwVY_u@lN>S(~o&lK-3(IL{DDtSy<<f(6-KQSa^dv^Jxo6J>|;1rIW4s3<Z}z4Gz-Y
z(|I^TXbUL3V<lA8-SSd_BcX?rH%igj!6_Em%@x2aq4P<PH8$M1b&Ij*6dCJgKhL@%
zeKM!Ss86bZrQJ9I1aK?-A^+KEoTYKhAWX=5UZB3|PrAwlVk&==^UL0fM1F#qoG(jV
ziFR>Wm`>JOBeTz&Ydh1Xsk{mlNzsKXm9fN}WG(kjl1XjmwW>2882>b{{e_=@`3{Kg
zGYj`VPI0VkL(RN7=MAj%*W<e(QU=vE33a-~y!Dcm;%sb|Cpu>su_Sv%^$0%QGDTYt
zQoE+X`T$3#{18&7utaw;(dT2mKhnWpC%nIW8xmoW3`Q;XJiopZ^L2O-Es{anhdwMB
zde=<IXm)|j{iM=dlHzeHG_?KNkQi`Z&Ubqh61uxkO}b?(zaW^~dHwRk<eyPL=Ku$w
z(hXlMd;(gtD%;GudVv$rSrr_CJ#BQiUN768l)k<<86MM~*;SW@D|j6(e|LdkeB}8X
znTqb@2`eFDs1mP9l80qyv-)lb6+|6AHS^`4%%d~Sd|k<YsVmd*C2Q&po^Az#hPF-{
zOlU+NPrg7vVlb$@uD^F(B(aa}I=X%QOLm)lQ%FJr=CN1Ew9$BxO@WxO5GJ`}EMjhr
ztI#Ct6`De{kGf9t2Cm6IUa6McKFEOe14ow#d~}_p9$oirBC>-XK7*kBwiz)k?D8ua
z#eue2=SUvd+dQERC(%mYL2_{YT?zboODPu(>qgh`_QQylQG`rLy8GM<THzr0^$$)!
zR0rpJ0>Hpb)W%zfP9aYo=Q96i^g%$fV0|l{vb*Xu*NaiI$xIYF_a35Q*n4JpzP~`r
zUU}2Ssg0AwH=}wjr#zeS2}!^{1cI#}?AWi}Ja6{*%iFbk<8)0xJ8+spNun){$I?qc
zyh9rUUSFstFdli^z<tSAc5Wp#=c!GOe@*x0Q{m^<@OlyUeQEMY?M$OvtXACK)apPR
z>{B?dThLgadG8+>L5hzvy+oQ9HEeIsJP6x6iaf~YCFTbF`H3(*l`f2Jf!X?IS{|n7
zYR09>dplfVL(dmwX01u~nKH`B;QIq1;Gvcx+8`uRa@8rN4;WCXy@8CzFW~*GeKMR0
zfWs}_wc*{LEcpsxMPdGU)Q;lbeLFQ=W=gTGVSgWAGs+jbc==EvI7v6&P6KMRp>BM{
zl<VS`JgiG_@*bvd9nkcGqo{Ox=O|)J?&w~C9=-w5N4878&#7cV6!Fnng^y_1Isic?
zbnz4rn~q<MYp?d{PCsvO{YU%E;a(t!J7r*^&Sw*Nj7^I^p{qxWgX9K5@sw9xFoKgx
z3x|4y_=(s_pi6o&iLu$Z+ZG~RNlJ^FJ;o?G{6l>?<k2UDYZ)r+aBDP`MO%d>q;N$h
z9Y?>K%bDyPUZUfMDVko4<vP_?{~?$L2KQq3nPDIy(=_LgR?CbwGEhhp+~U|T*jw$?
zFCl*MgTs1{y>03XH{JZsDjbzeUE;cGM;lMs3nG@Nm}&5JGf0wd*g9OUZ&Q$6z+jgU
z{{$%{E3_z|s4vs-5@Ao>W^jj)NK}{kVR1O)0ij!0a}B%pjn6Bdc`(0<dGz*4lUcZh
z;&%*y6=w6qOpHKarJg}?zV-@j#F~fB2%Ir*LHm4nfl&hH{;esj{ZP0D8Ex&pHT_L~
zhG<JS-p{$f>m3v4DZ7?k%n<}mRq$=k7U8NsVRG@JsX}zIUUfj*rpgZeoutktnFCDh
z@&D7s-r;?fTefMUg*S3>Q%NdxFj8o8=g$U^<(o15HzcBtj&q7nPj-_A#D$>=_$>sf
zBE>kZy}3=J7r!FY5J^Zej%=P34k}B_vS(sqj1?lvt!LX&B7o-+n=sC{>8^EdCc^rm
z-dlI7Y`W75$WPSj7*piO7p&=(>`7kgqc&oE79&hW*mD6dC!spW@g-g6U;MV3M)vXF
zk16*qt5BiUf$Q#CQOGm0Pv$V#hCUX?@!m%1r#L;Mr>AZ=ue$Fl0ea(VZ3!9EY^4_6
z!B8Z+W4{5lPc}~G?M;NU$Hn$N=L`fL?^UQLl7UGJJ_w9qJYafM;C{e26~lu^H1@Tw
z8Vo{v#feF><<^0F8$n#v$Am8+uIj;SV7kyNiw)qi6qak&eFN74A31QsEdL0V<wpi&
z0d3{tbs#H=uPcIxl!A`qx4x=%{e5R!z+5Ur)W@a4<kIT6Lu`{-5dB{SN^SDTWKqE4
zaOS}}nCl@S)7Y;4JrX<T{$H&ZANbm7R`cAOEM1Id7np2IM%uG0O<5X5UEOekv`gRs
zr&K@Bv`zO*<D*&T$b39Wgsfz4X__Es-?0ttM<8?_r=w2v@pto94F1_FomGK-JNIuc
zm4-IkkocTMN7i-X*nqOx0f&}3_aO_<m-pwLtu>;8m>eNy0{p$x_Z6>TE`#kSL7=5w
zpA>40P~jW|Bh>dzP8%6%%+)5QDEwe(yinW5%9qVRQ8LnQVxX1>2|l^ZbXd^A{N-O$
zzUeK=+66Cqs;@q<z+3_r7=RDkd!hr>9Q(Irhd3TFrclm-5L;SVeu7aXdiHL6oS$Do
zOUa_%-fbweE7_Q`@rNkOb$E(&E<Ul~TNtpzh2nblwXm88F#yqxCbDfZYLlzPZb^MB
z+Th4p)RQTUrwY}~49}%>1ZL%t=erFEs4N2^Pw4;22jjaGQ=1nauugG+?Oo(*aD&gW
z{qLq3IK-!AT*EUV$N9y&aZwI8@SIbma1SY&r#utfP#dSyxuVm2TRVS|McZDJ0iO&2
zLt>0^j~{ZaoMnQ~iNIOx&l6@{<wY`J4M(bN3AP@$^`cAgwJA(o4T-y*?ADf<UD>_y
z<?|2$_jXrby(d0}8jk~FVc13oaJSQhHhk3)DUBIjUWvNOcb{)@4{R}<m=@byEMm@Y
zoN{|=afRPmH*m$LJ6AAng7|PvRV~R*R;Kz)Kf<r|Wut9WpWNoJ(F_b}sw(2}_joUI
zkmV2?5I}Z5{s5XTf%zAN0(w-zwC@>BCcIWOjvN-*j@Q3#n&>hq7H0=Pu7FMfGpmrS
zNT&L)@M$eUj%cwQ$nY!+HGk1nHojwx`EK+bQx@Kl8nanbt$gzPJ4xL7^2yblZ7whB
z6G9@m?=sy#k%+!YKQ3~=e}uRGZi@3!SL>EX)2@>nbyW@8(WF;yITNngl<6p!7z%d!
zyuSyQjj|^HJ}<A_q7lTl2eR^Y8voH+^T+$lyi(f3V7&B*i_fim%?`f>!DYDxaQyqL
z0lEJ0um7nHU$(5Z^;Gx^V)^hCGbEi{fAG2L>WO7w#A_V^ZPvnVf?nWOO6(sjRwBrA
zOE27Vl=i*F>Qwr_VYd5Duz_j7==}~@dDeE$q+*{gXval;@cP%0@ZyFez)fv$Wn0`K
z0B{E*`-dkQ!H-pWShf5#@!rwdTxn(^SYdIQYl)o?*-5&G(BR5tTlc;jYjJ*l*+=2L
z7q}Mal=@GP8Z`gWH&7?+YEkEu`OGUt=}fD3Kz0B}fYyrbi_bL=d@(`egb=S7i!6T(
zC_{au0{+owIz|YV6<gFTROpSL?SUct;6Nwg`SIHKQQ|8;Wgvtp(??{eM6V6RL=jTx
z&M6Rv#>0L1mhhMF3NF~a8sF(W)4WAdDoTwK`D9{s-5o?SDGOZ`;M{TJ|5qfn8a};Z
zB~97yC99zPeB>G~sUi7PF`Kyu`nT!V-Z!RSuiSL$_piK=oG||nFIm6yUZ<qgjfV&&
zAzonK!QaUzmyJSQ`t%LI6f@ho*Zv+^fS_PvD2R-?M3!@&uww>+7Y^JSAK(!%H9fHD
z?$kvChYBa4in_~T-Vrk5G9HPYQRT{10^}5aM=|t52VRJ^uy7BIiofBJ(ujX8N22%G
zq`&6x-v-lcZSRe3C~t?RGV^LSxOY1Lx<k!y=VgYY=~iAixkCubKlj<w%D$Ass-ilS
z#(6=X4y6T#?Wc;kh}bVtZZS7J(5>)xnfXS@V7vfGISRZ0J7$O4H~gM*W4Dz4zN_ZG
zIz|?(tO88cwwAyIUm=q%kr7j4WOoY2f{dzq5LLSQudDI1<R=DxV&EqReq!J!27Y4T
dCkB3E;3o!tV&EqReq!J!2L8P<5V+m-zW~=V+u#5I

literal 0
HcmV?d00001

diff --git a/apps/web/src/lib/workers/index.ts b/apps/web/src/lib/workers/index.ts
index 06ea381..64d2865 100644
--- a/apps/web/src/lib/workers/index.ts
+++ b/apps/web/src/lib/workers/index.ts
@@ -1,19 +1,19 @@
 import { Queue, Worker } from 'bullmq';
 import { getRedisConnection } from '@/lib/services/redis';
 
-// Singleton instances for notifier
 const globalForNotifier = global as unknown as { 
   notificationQueue: Queue | null;
   notificationWorker: Worker | null;
+
+  thumbnailQueue: Queue | null;
+  thumbnailWorker: Worker | null;
 };
 
-// Initialize if they don't exist
 if (!globalForNotifier.notificationQueue) {
   globalForNotifier.notificationQueue = null;
   globalForNotifier.notificationWorker = null;
 }
 
-// Get or create the notification queue
 export function getNotificationQueue(): Queue {
   if (!globalForNotifier.notificationQueue) {
     globalForNotifier.notificationQueue = new Queue('notifications', {
@@ -28,4 +28,20 @@ export function getNotificationQueue(): Queue {
     });
   }
   return globalForNotifier.notificationQueue;
+}
+
+export function getThumbnailQueue(): Queue {
+  if (!globalForNotifier.thumbnailQueue) {
+    globalForNotifier.thumbnailQueue = new Queue('thumbnails', {
+      connection: getRedisConnection(),
+      defaultJobOptions: {
+        attempts: 3,
+        backoff: {
+          type: 'exponential',
+          delay: 5000,
+        },
+      }
+    });
+  }
+  return globalForNotifier.thumbnailQueue;
 }
\ No newline at end of file
diff --git a/apps/web/src/lib/workers/register.ts b/apps/web/src/lib/workers/register.ts
index fc64759..7df4438 100644
--- a/apps/web/src/lib/workers/register.ts
+++ b/apps/web/src/lib/workers/register.ts
@@ -1,6 +1,8 @@
 import { registerNotificationWorker } from './worker/notification';
+import { registerThumbnailWorker } from './worker/thumbnails';
 
 export async function registerWorkers(): Promise<void> {
   await registerNotificationWorker();
+  await registerThumbnailWorker();
   console.log('All workers registered successfully');
 }
\ No newline at end of file
diff --git a/apps/web/src/lib/workers/worker/thumbnails.ts b/apps/web/src/lib/workers/worker/thumbnails.ts
new file mode 100644
index 0000000..b7c3988
--- /dev/null
+++ b/apps/web/src/lib/workers/worker/thumbnails.ts
@@ -0,0 +1,67 @@
+import { Worker } from 'bullmq';
+import { getRedisConnection } from '@/lib/services/redis';
+import { exec } from 'node:child_process';
+import { existsSync } from 'node:fs';
+
+const globalForWorker = global as unknown as {
+  thumbnailWorker: Worker | null;
+};
+
+if (!globalForWorker.thumbnailWorker) {
+  globalForWorker.thumbnailWorker = null;
+}
+
+export async function registerThumbnailWorker(): Promise<void> {
+  if (globalForWorker.thumbnailWorker) {
+    console.log('Notification worker already registered');
+    return;
+  }
+
+  console.log('Registering notification worker...');
+
+  const worker = new Worker(
+    'thumbnails',
+    async (job) => {
+      try {
+        // this is totally unnecessary, but i'll keep it for security purposes.
+        const name = job.data.name.replace(/[^a-zA-Z0-9]/g, '_');
+        const m3u8location = `/dev/shm/hls/${name}.m3u8`;
+        if (!existsSync(m3u8location)) return;
+
+        exec(
+          `/usr/bin/ffmpeg -i ${m3u8location} -vframes 1 -an -y -f image2 /home/srizan/Documents/Development/hclive/apps/web/src/lib/${name}.jpg`,
+          (error) => {
+            if (error) {
+              console.error(`Error: ${error.message}`);
+              return { success: false, error: error.message };
+            }
+          }
+        );
+
+        return { success: true };
+      } catch (e) {
+        console.error('Slack notification failed:', e);
+        // @ts-ignore e is unknown
+        return { success: false, error: e.message };
+      }
+    },
+    {
+      connection: getRedisConnection(),
+      concurrency: 3,
+      limiter: {
+        max: 50,
+        duration: 30000,
+      },
+    }
+  );
+
+  globalForWorker.thumbnailWorker = worker;
+}
+
+// Close the worker
+export async function closeThumbnailWorker(): Promise<void> {
+  if (globalForWorker.thumbnailWorker) {
+    await globalForWorker.thumbnailWorker.close();
+    globalForWorker.thumbnailWorker = null;
+  }
+}
diff --git a/yarn.lock b/yarn.lock
index 925cd01..2508deb 100644
--- a/yarn.lock
+++ b/yarn.lock
@@ -1661,6 +1661,11 @@
   resolved "https://registry.yarnpkg.com/@types/json5/-/json5-0.0.29.tgz#ee28707ae94e11d2b827bcbe5270bcea7f3e71ee"
   integrity sha512-dRLjCWHYg4oaA77cxO64oO+7JwCwnIzkZPdrrC71jQmQtlhM556pwKo5bUzqvZndkVbeFLIIi+9TC40JNF5hNQ==
 
+"@types/node-cron@^3.0.11":
+  version "3.0.11"
+  resolved "https://registry.yarnpkg.com/@types/node-cron/-/node-cron-3.0.11.tgz#70b7131f65038ae63cfe841354c8aba363632344"
+  integrity sha512-0ikrnug3/IyneSHqCBeslAhlK2aBfYek1fGo4bP4QnZPmiqSGRK+Oy7ZMisLWkesffJvQ1cqAcBnJC+8+nxIAg==
+
 "@types/node@*":
   version "22.13.11"
   resolved "https://registry.yarnpkg.com/@types/node/-/node-22.13.11.tgz#f0ed6b302dcf0f4229d44ea707e77484ad46d234"
@@ -4278,6 +4283,13 @@ node-abort-controller@^3.1.1:
   resolved "https://registry.yarnpkg.com/node-abort-controller/-/node-abort-controller-3.1.1.tgz#a94377e964a9a37ac3976d848cb5c765833b8548"
   integrity sha512-AGK2yQKIjRuqnc6VkX2Xj5d+QW8xZ87pa1UK6yA6ouUyuxfHuMP6umE5QK7UmTeOAymo+Zx1Fxiuw9rVx8taHQ==
 
+node-cron@^3.0.3:
+  version "3.0.3"
+  resolved "https://registry.yarnpkg.com/node-cron/-/node-cron-3.0.3.tgz#c4bc7173dd96d96c50bdb51122c64415458caff2"
+  integrity sha512-dOal67//nohNgYWb+nWmg5dkFdIwDm8EpeGYMekPMrngV3637lqnX0lbUcCtgibHTz6SEz7DAIjKvKDFYCnO1A==
+  dependencies:
+    uuid "8.3.2"
+
 node-domexception@^1.0.0:
   version "1.0.0"
   resolved "https://registry.yarnpkg.com/node-domexception/-/node-domexception-1.0.0.tgz#6888db46a1f71c0b76b3f7555016b63fe64766e5"
@@ -5928,6 +5940,11 @@ util-utils@^1.0.3:
   resolved "https://registry.yarnpkg.com/util-utils/-/util-utils-1.0.3.tgz#abde6c79d373eb7fae42f28933273eab6d895dd3"
   integrity sha512-KXQzb5Y1cmQOubnYn2TMSJDwX+cLrFNi3CRp0bm+yTUdR4tV4LDkk2RAzGSweucwvTdhuoDdZrY67ds7QDRYXQ==
 
+uuid@8.3.2:
+  version "8.3.2"
+  resolved "https://registry.yarnpkg.com/uuid/-/uuid-8.3.2.tgz#80d5b5ced271bb9af6c445f21a1a04c606cefbe2"
+  integrity sha512-+NYs2QeMWy+GWFOEm9xnn6HCDp0l7QBD7ml8zLUmJ+93Q5NF0NocErnwkTkXVFNiX3/fpC6afS8Dhb/gz7R7eg==
+
 uuid@^9.0.0:
   version "9.0.1"
   resolved "https://registry.yarnpkg.com/uuid/-/uuid-9.0.1.tgz#e188d4c8853cc722220392c424cd637f32293f30"