updated time limit key, cached resource

ArnabChatterjee20k · ArnabChatterjee20k · commit da1285bb22ff · 2025-12-05T09:25:34.000+05:30
diff --git a/app/realtime.php b/app/realtime.php
@@ -55,8 +55,8 @@ function getConsoleDB(): Database
     {
         $ctx = Coroutine::getContext();
 
-        if (isset($ctx['consoleDB'])) {
-            return $ctx['consoleDB'];
+        if (isset($ctx['dbForPlatform'])) {
+            return $ctx['dbForPlatform'];
         }
 
         global $register;
@@ -71,7 +71,7 @@ function getConsoleDB(): Database
             ->setMetadata('host', \gethostname())
             ->setMetadata('project', '_console');
         $database->setDocumentType('users', User::class);
-        return $ctx['consoleDB'] = $database;
+        return $ctx['dbForPlatform'] = $database;
     }
 }
 
@@ -81,12 +81,12 @@ function getProjectDB(Document $project): Database
     {
         $ctx = Coroutine::getContext();
 
-        if (!isset($ctx['getProjectDB'])) {
-            $ctx['getProjectDB'] = [];
+        if (!isset($ctx['dbForProject'])) {
+            $ctx['dbForProject'] = [];
         }
 
-        if (isset($ctx['getProjectDB'][$project->getSequence()])) {
-            return $ctx['getProjectDB'][$project->getSequence()];
+        if (isset($ctx['dbForProject'][$project->getSequence()])) {
+            return $ctx['dbForProject'][$project->getSequence()];
         }
 
         global $register;
@@ -128,7 +128,7 @@ function getProjectDB(Document $project): Database
 
         $database->setDocumentType('users', User::class);
 
-        return $ctx['getProjectDB'][$project->getSequence()] = $database;
+        return $ctx['dbForProject'][$project->getSequence()] = $database;
     }
 }
 
@@ -138,8 +138,8 @@ function getCache(): Cache
     {
         $ctx = Coroutine::getContext();
 
-        if (isset($ctx['getCache'])) {
-            return $ctx['getCache'];
+        if (isset($ctx['cache'])) {
+            return $ctx['cache'];
         }
 
         global $register;
@@ -153,7 +153,7 @@ function getCache(): Cache
             $adapters[] = new CachePool($pools->get($value));
         }
 
-        return $ctx['getCache'] = new Cache(new Sharding($adapters));
+        return $ctx['cache'] = new Cache(new Sharding($adapters));
     }
 }
 
@@ -163,8 +163,8 @@ function getRedis(): \Redis
     {
         $ctx = Coroutine::getContext();
 
-        if (isset($ctx['getRedis'])) {
-            return $ctx['getRedis'];
+        if (isset($ctx['redis'])) {
+            return $ctx['redis'];
         }
 
         $host = System::getEnv('_APP_REDIS_HOST', 'localhost');
@@ -178,20 +178,20 @@ function getRedis(): \Redis
         }
         $redis->setOption(\Redis::OPT_READ_TIMEOUT, -1);
 
-        return $ctx['getRedis'] = $redis;
+        return $ctx['redis'] = $redis;
     }
 }
 
 if (!function_exists('getTimelimit')) {
-    function getTimelimit(): TimeLimitRedis
+    function getTimelimit(string $key = "", int $limit = 0, int $seconds = 1): TimeLimitRedis
     {
         $ctx = Coroutine::getContext();
 
-        if (isset($ctx['getTimelimit'])) {
-            return $ctx['getTimelimit'];
+        if (isset($ctx['timelimit'])) {
+            return $ctx['timelimit'];
         }
 
-        return $ctx['getTimelimit'] = new TimeLimitRedis("", 0, 1, getRedis());
+        return $ctx['timelimit'] = new TimeLimitRedis($key, $limit, $seconds, getRedis());
     }
 }
 
@@ -200,24 +200,24 @@ function getRealtime(): Realtime
     {
         $ctx = Coroutine::getContext();
 
-        if (isset($ctx['getRealtime'])) {
-            return $ctx['getRealtime'];
+        if (isset($ctx['realtime'])) {
+            return $ctx['realtime'];
         }
 
-        return $ctx['getRealtime'] = new Realtime();
+        return $ctx['realtime'] = new Realtime();
     }
 }
 
 if (!function_exists('getTelemetry')) {
     function getTelemetry(int $workerId): Utopia\Telemetry\Adapter
     {
-        static $telemetry = null;
+        $ctx = Coroutine::getContext();
 
-        if ($telemetry !== null) {
-            return $telemetry;
+        if (isset($ctx['telemetry'])) {
+            return $ctx['telemetry'];
         }
 
-        return $telemetry = new NoTelemetry();
+        return $ctx['telemetry'] = new NoTelemetry();
     }
 }
 

Original file line number	Diff line number	Diff line change
`@@ -55,8 +55,8 @@ function getConsoleDB(): Database`
`55`	`55`	`{`
`56`	`56`	`$ctx = Coroutine::getContext();`
`57`	`57`
`58`		`- if (isset($ctx['consoleDB'])) {`
`59`		`- return $ctx['consoleDB'];`
	`58`	`+ if (isset($ctx['dbForPlatform'])) {`
	`59`	`+ return $ctx['dbForPlatform'];`
`60`	`60`	`}`
`61`	`61`
`62`	`62`	`global $register;`
`@@ -71,7 +71,7 @@ function getConsoleDB(): Database`
`71`	`71`	`->setMetadata('host', \gethostname())`
`72`	`72`	`->setMetadata('project', '_console');`
`73`	`73`	`$database->setDocumentType('users', User::class);`
`74`		`- return $ctx['consoleDB'] = $database;`
	`74`	`+ return $ctx['dbForPlatform'] = $database;`
`75`	`75`	`}`
`76`	`76`	`}`
`77`	`77`
`@@ -81,12 +81,12 @@ function getProjectDB(Document $project): Database`
`81`	`81`	`{`
`82`	`82`	`$ctx = Coroutine::getContext();`
`83`	`83`
`84`		`- if (!isset($ctx['getProjectDB'])) {`
`85`		`- $ctx['getProjectDB'] = [];`
	`84`	`+ if (!isset($ctx['dbForProject'])) {`
	`85`	`+ $ctx['dbForProject'] = [];`
`86`	`86`	`}`
`87`	`87`
`88`		`- if (isset($ctx['getProjectDB'][$project->getSequence()])) {`
`89`		`- return $ctx['getProjectDB'][$project->getSequence()];`
	`88`	`+ if (isset($ctx['dbForProject'][$project->getSequence()])) {`
	`89`	`+ return $ctx['dbForProject'][$project->getSequence()];`
`90`	`90`	`}`
`91`	`91`
`92`	`92`	`global $register;`
`@@ -128,7 +128,7 @@ function getProjectDB(Document $project): Database`
`128`	`128`
`129`	`129`	`$database->setDocumentType('users', User::class);`
`130`	`130`
`131`		`- return $ctx['getProjectDB'][$project->getSequence()] = $database;`
	`131`	`+ return $ctx['dbForProject'][$project->getSequence()] = $database;`
`132`	`132`	`}`
`133`	`133`	`}`
`134`	`134`
`@@ -138,8 +138,8 @@ function getCache(): Cache`
`138`	`138`	`{`
`139`	`139`	`$ctx = Coroutine::getContext();`
`140`	`140`
`141`		`- if (isset($ctx['getCache'])) {`
`142`		`- return $ctx['getCache'];`
	`141`	`+ if (isset($ctx['cache'])) {`
	`142`	`+ return $ctx['cache'];`
`143`	`143`	`}`
`144`	`144`
`145`	`145`	`global $register;`
`@@ -153,7 +153,7 @@ function getCache(): Cache`
`153`	`153`	`$adapters[] = new CachePool($pools->get($value));`
`154`	`154`	`}`
`155`	`155`
`156`		`- return $ctx['getCache'] = new Cache(new Sharding($adapters));`
	`156`	`+ return $ctx['cache'] = new Cache(new Sharding($adapters));`
`157`	`157`	`}`
`158`	`158`	`}`
`159`	`159`
`@@ -163,8 +163,8 @@ function getRedis(): \Redis`
`163`	`163`	`{`
`164`	`164`	`$ctx = Coroutine::getContext();`
`165`	`165`
`166`		`- if (isset($ctx['getRedis'])) {`
`167`		`- return $ctx['getRedis'];`
	`166`	`+ if (isset($ctx['redis'])) {`
	`167`	`+ return $ctx['redis'];`
`168`	`168`	`}`
`169`	`169`
`170`	`170`	`$host = System::getEnv('_APP_REDIS_HOST', 'localhost');`
`@@ -178,20 +178,20 @@ function getRedis(): \Redis`
`178`	`178`	`}`
`179`	`179`	`$redis->setOption(\Redis::OPT_READ_TIMEOUT, -1);`
`180`	`180`
`181`		`- return $ctx['getRedis'] = $redis;`
	`181`	`+ return $ctx['redis'] = $redis;`
`182`	`182`	`}`
`183`	`183`	`}`
`184`	`184`
`185`	`185`	`if (!function_exists('getTimelimit')) {`
`186`		`- function getTimelimit(): TimeLimitRedis`
	`186`	`+ function getTimelimit(string $key = "", int $limit = 0, int $seconds = 1): TimeLimitRedis`
`187`	`187`	`{`
`188`	`188`	`$ctx = Coroutine::getContext();`
`189`	`189`
`190`		`- if (isset($ctx['getTimelimit'])) {`
`191`		`- return $ctx['getTimelimit'];`
	`190`	`+ if (isset($ctx['timelimit'])) {`
	`191`	`+ return $ctx['timelimit'];`
`192`	`192`	`}`
`193`	`193`
`194`		`- return $ctx['getTimelimit'] = new TimeLimitRedis("", 0, 1, getRedis());`
	`194`	`+ return $ctx['timelimit'] = new TimeLimitRedis($key, $limit, $seconds, getRedis());`
`195`	`195`	`}`
`196`	`196`	`}`
`197`	`197`
`@@ -200,24 +200,24 @@ function getRealtime(): Realtime`
`200`	`200`	`{`
`201`	`201`	`$ctx = Coroutine::getContext();`
`202`	`202`
`203`		`- if (isset($ctx['getRealtime'])) {`
`204`		`- return $ctx['getRealtime'];`
	`203`	`+ if (isset($ctx['realtime'])) {`
	`204`	`+ return $ctx['realtime'];`
`205`	`205`	`}`
`206`	`206`
`207`		`- return $ctx['getRealtime'] = new Realtime();`
	`207`	`+ return $ctx['realtime'] = new Realtime();`
`208`	`208`	`}`
`209`	`209`	`}`
`210`	`210`
`211`	`211`	`if (!function_exists('getTelemetry')) {`
`212`	`212`	`function getTelemetry(int $workerId): Utopia\Telemetry\Adapter`
`213`	`213`	`{`
`214`		`- static $telemetry = null;`
	`214`	`+ $ctx = Coroutine::getContext();`
`215`	`215`
`216`		`- if ($telemetry !== null) {`
`217`		`- return $telemetry;`
	`216`	`+ if (isset($ctx['telemetry'])) {`
	`217`	`+ return $ctx['telemetry'];`
`218`	`218`	`}`
`219`	`219`
`220`		`- return $telemetry = new NoTelemetry();`
	`220`	`+ return $ctx['telemetry'] = new NoTelemetry();`
`221`	`221`	`}`
`222`	`222`	`}`
`223`	`223`