From c8f65ca4c73d27455817be1512a2da3277c7efc0 Mon Sep 17 00:00:00 2001
From: Samuel <34555296+Flam3rboy@users.noreply.github.com>
Date: Thu, 30 Mar 2023 18:26:19 +0200
Subject: fix: disable cache if multi threaded

---
 src/util/cache/EntityCache.ts | 6 ++++--
 1 file changed, 4 insertions(+), 2 deletions(-)

diff --git a/src/util/cache/EntityCache.ts b/src/util/cache/EntityCache.ts
index 9135fef3..ba1e5bd8 100644
--- a/src/util/cache/EntityCache.ts
+++ b/src/util/cache/EntityCache.ts
@@ -24,7 +24,7 @@ import {
 } from "typeorm";
 import { QueryDeepPartialEntity } from "typeorm/query-builder/QueryPartialEntity";
 import { BaseClassWithId } from "../entities/BaseClass";
-import { Config, getDatabase } from "../util";
+import { Config, getDatabase, RabbitMQ } from "../util";
 import { CacheManager } from "./Cache";
 
 function getObjectKeysAsArray(obj?: Record<string, any>) {
@@ -52,7 +52,9 @@ class BaseEntityCache extends BaseClassWithId {
 
 	static useDataSource(dataSource: DataSource | null) {
 		super.useDataSource(dataSource);
-		this.cacheEnabled = Config.get().cache.enabled ?? true;
+		const isMultiThreaded =
+			process.env.EVENT_TRANSMISSION === "process" || RabbitMQ.connection;
+		this.cacheEnabled = Config.get().cache.enabled ?? !isMultiThreaded;
 		if (Config.get().cache.redis) return; // TODO: Redis cache
 		if (!this.cacheEnabled) return;
 		this.cache = new CacheManager();
-- 
cgit 1.4.1