Add ConnectionCount and DriverTitle for monitoring commands (#3072)

mongodb · Aug 26, 2024 · f24b464 · f24b464
1 parent 59e16b9
commit f24b464
Show file tree

Hide file tree

Showing 2 changed files with 25 additions and 0 deletions.
diff --git a/src/Connection.php b/src/Connection.php
@@ -294,6 +294,12 @@ public function getDriverName()
         return 'mongodb';
     }
 
+    /** @inheritdoc */
+    public function getDriverTitle()
+    {
+        return 'MongoDB';
+    }
+
     /** @inheritdoc */
     protected function getDefaultPostProcessor()
     {
@@ -320,6 +326,14 @@ public function setDatabase(Database $db)
         $this->db = $db;
     }
 
+    /** @inheritdoc  */
+    public function threadCount()
+    {
+        $status = $this->db->command(['serverStatus' => 1])->toArray();
+
+        return $status[0]['connections']['current'];
+    }
+
     /**
      * Dynamically pass methods to the connection.
      *

diff --git a/tests/ConnectionTest.php b/tests/ConnectionTest.php
@@ -25,6 +25,9 @@ public function testConnection()
     {
         $connection = DB::connection('mongodb');
         $this->assertInstanceOf(Connection::class, $connection);
+
+        $this->assertSame('mongodb', $connection->getDriverName());
+        $this->assertSame('MongoDB', $connection->getDriverTitle());
     }
 
     public function testReconnect()
@@ -305,4 +308,12 @@ public function testServerVersion()
         $version = DB::connection('mongodb')->getServerVersion();
         $this->assertIsString($version);
     }
+
+    public function testThreadsCount()
+    {
+        $threads = DB::connection('mongodb')->threadCount();
+
+        $this->assertIsInt($threads);
+        $this->assertGreaterThanOrEqual(1, $threads);
+    }
 }