From 7361c7056b596c51d87b0166e6488a5d326d21c2 Mon Sep 17 00:00:00 2001
From: Ajay <dev@ajay.app>
Date: Sat, 4 Feb 2023 15:12:22 -0500
Subject: [PATCH] Print active db requests in redis errors

---
 src/utils/redis.ts | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git a/src/utils/redis.ts b/src/utils/redis.ts
index 269429f..f8be2c7 100644
--- a/src/utils/redis.ts
+++ b/src/utils/redis.ts
@@ -4,6 +4,8 @@ import { createClient } from "redis";
 import { RedisCommandArgument, RedisCommandArguments, RedisCommandRawReply } from "@redis/client/dist/lib/commands";
 import { RedisClientOptions } from "@redis/client/dist/lib/client";
 import { RedisReply } from "rate-limit-redis";
+import { db } from "../databases/databases";
+import { Postgres } from "../databases/Postgres";
 
 export interface RedisStats {
     activeRequests: number;
@@ -99,7 +101,7 @@ if (config.redis?.enabled) {
             if ((config.redis.maxWriteConnections && activeRequests > config.redis.maxWriteConnections)
                 || (config.redis.responseTimePause
                         && Date.now() - lastResponseTimeLimit < config.redis.responseTimePause)) {
-                reject(`Too many active requests to write due to ${activeRequests} requests and ${Date.now() - lastResponseTimeLimit}ms since last response time limit`);
+                reject(`Too many active requests to write due to ${activeRequests} requests and ${Date.now() - lastResponseTimeLimit}ms since last limit. ${(db as Postgres)?.getStats?.()?.activeRequests} active db requests with ${(db as Postgres)?.getStats?.()?.avgReadTime}ms`);
                 return;
             }