From b8531560b2b776231a3285500ccca3ce3be4e233 Mon Sep 17 00:00:00 2001
From: Torsten Dittmann <torsten.dittmann@googlemail.com>
Date: Thu, 11 Mar 2021 17:28:03 +0100
Subject: [PATCH] fix connection pool on spike loads

---
 app/controllers/shared/api.php | 15 ++++++++-------
 app/init.php                   |  4 ++--
 2 files changed, 10 insertions(+), 9 deletions(-)

diff --git a/app/controllers/shared/api.php b/app/controllers/shared/api.php
index 69ffdf4f2f..f165b4b349 100644
--- a/app/controllers/shared/api.php
+++ b/app/controllers/shared/api.php
@@ -140,13 +140,14 @@ App::shutdown(function ($utopia, $request, $response, $project, $events, $audits
             ->setQueue('v1-functions')
             ->setClass('FunctionsV1')
             ->trigger();
-        
-        $realtime
-            ->setEvent($events->getParam('event'))
-            ->setProject($project->getId())
-            ->setPayload($response->getPayload())
-            ->trigger();
-        
+
+        if ($project->getId() !== 'console') {
+            $realtime
+                ->setEvent($events->getParam('event'))
+                ->setProject($project->getId())
+                ->setPayload($response->getPayload())
+                ->trigger();
+        }
     }
     
     if (!empty($audits->getParam('event'))) {
diff --git a/app/init.php b/app/init.php
index 20a711e7af..806bc1a718 100644
--- a/app/init.php
+++ b/app/init.php
@@ -165,7 +165,7 @@ $register->set('dbPool', function () { // Register DB connection
             PDONative::ATTR_ERRMODE => PDONative::ERRMODE_EXCEPTION,
         ]);
 
-    $pool = new PDOPool($config);
+    $pool = new PDOPool($config, 4096); // TODO: Investigate pool size
 
     return $pool;
 });
@@ -226,7 +226,7 @@ $register->set('redisPool', function () {
         ->withReadTimeout(0)
         ->withRetryInterval(0);
 
-    $pool = new RedisPool($config);
+    $pool = new RedisPool($config, 4096); // TODO: Investigate pool size
 
     return $pool;
 });