From 9d0afcb3297117b2bd893cc7d0ebb4f50b03d7f6 Mon Sep 17 00:00:00 2001
From: SrGooglo <srgooglo@ragestudio.net>
Date: Wed, 5 Feb 2025 02:50:52 +0000
Subject: [PATCH] removed unnecessary redis

---
 .../server/services/files/file.service.js     | 20 ++++++++++++++-----
 1 file changed, 15 insertions(+), 5 deletions(-)

diff --git a/packages/server/services/files/file.service.js b/packages/server/services/files/file.service.js
index a57ab147..0ff411c0 100755
--- a/packages/server/services/files/file.service.js
+++ b/packages/server/services/files/file.service.js
@@ -5,18 +5,19 @@ import B2 from "backblaze-b2"
 import hePkg from "hyper-express/package.json"
 
 import DbManager from "@shared-classes/DbManager"
-import RedisClient from "@shared-classes/RedisClient"
 import StorageClient from "@shared-classes/StorageClient"
 import CacheService from "@shared-classes/CacheService"
-
+import SSEManager from "@shared-classes/SSEManager"
 import SharedMiddlewares from "@shared-middlewares"
 import LimitsClass from "@shared-classes/Limits"
+import TaskQueueManager from "@shared-classes/TaskQueueManager"
 
 class API extends Server {
     static refName = "files"
     static useEngine = "hyper-express"
     static routesPath = `${__dirname}/routes`
     static listen_port = process.env.HTTP_LISTEN_PORT ?? 3002
+    static enableWebsockets = true
 
     middlewares = {
         ...SharedMiddlewares
@@ -25,16 +26,20 @@ class API extends Server {
     contexts = {
         db: new DbManager(),
         cache: new CacheService(),
-        redis: RedisClient(),
         storage: StorageClient(),
         b2Storage: null,
+        SSEManager: new SSEManager(),
         limits: {},
     }
 
+    queuesManager = new TaskQueueManager({
+        workersPath: `${__dirname}/queues`,
+    })
+
     async onInitialize() {
         console.log(`Using HyperExpress v${hePkg.version}`)
 
-        global.storage = this.contexts.storage
+        global.sse = this.contexts.SSEManager
 
         if (process.env.B2_KEY_ID && process.env.B2_APP_KEY) {
             this.contexts.b2Storage = new B2({
@@ -49,10 +54,15 @@ class API extends Server {
             console.warn("B2 storage not configured on environment, skipping...")
         }
 
+        await this.queuesManager.initialize({
+            redisOptions: this.engine.ws.redis.options
+        })
         await this.contexts.db.initialize()
-        await this.contexts.redis.initialize()
         await this.contexts.storage.initialize()
 
+        global.storage = this.contexts.storage
+        global.queues = this.queuesManager
+
         this.contexts.limits = await LimitsClass.get()
     }
 }