feat: add Database::deleteUserSessions

Author: rancoud

src/Database.php

@@ -57,6 +57,20 @@ public function getLengthSessionID(): int
         return $this->lengthSessionID;
     }
 
+    /** @throws SessionException */
+    public function deleteUserSessions(int $userID): bool
+    {
+        try {
+            $sql = 'DELETE FROM sessions WHERE id_user = :id_user';
+            $params = ['id_user' => $userID];
+            $this->db->delete($sql, $params);
+
+            return true;
+        } catch (DatabaseException $e) {
+            throw new SessionException('could not delete sessions: ' . $e->getMessage(), $e->getCode(), $e->getPrevious());
+        }
+    }
+
     public function open(string $path, string $name): bool
     {
         return true;

tests/DatabaseTest.php

@@ -450,4 +450,65 @@ public function testLengthSessionIDSessionException(): void
         $database = new Database();
         $database->setLengthSessionID(1);
     }
-}
+
+    /**
+     * @throws DatabaseException
+     * @throws SessionException
+     */
+    public function testDeleteUserSessions(): void
+    {
+        $database = new Database();
+        $database->setCurrentDatabase(static::$db);
+
+        $data = 'azerty';
+
+        $database->setUserId(10);
+
+        static::assertTrue($database->write('session_id_10', $data));
+        static::assertTrue($database->write('session_id_20', $data));
+        static::assertTrue($database->write('session_id_30', $data));
+
+        $database->setUserId(20);
+
+        static::assertTrue($database->write('session_id_40', $data));
+        static::assertTrue($database->write('session_id_50', $data));
+        static::assertTrue($database->write('session_id_60', $data));
+
+        $sql = 'SELECT id FROM sessions WHERE id_user = :id_user';
+        $params = ['id_user' => 10];
+        $sessionsFromDatabase = static::$db->selectCol($sql, $params);
+        static::assertSame(['session_id_10', 'session_id_20', 'session_id_30'], $sessionsFromDatabase);
+
+        $sql = 'SELECT id FROM sessions WHERE id_user = :id_user';
+        $params = ['id_user' => 20];
+        $sessionsFromDatabase = static::$db->selectCol($sql, $params);
+        static::assertSame(['session_id_40', 'session_id_50', 'session_id_60'], $sessionsFromDatabase);
+
+        $database->deleteUserSessions(10);
+
+        $sql = 'SELECT id FROM sessions';
+        $sessionsFromDatabase = static::$db->selectCol($sql);
+        static::assertSame(['session_id_40', 'session_id_50', 'session_id_60'], $sessionsFromDatabase);
+    }
+
+    /**
+     * @throws DatabaseException
+     * @throws SessionException
+     */
+    public function testDeleteUserSessionsSessionException(): void
+    {
+        $this->expectException(SessionException::class);
+        $this->expectExceptionMessage('could not delete sessions: Error Connecting Database');
+
+        $database = new Database();
+        $database->setNewDatabase([
+            'driver'   => 'mysql',
+            'host'     => 'mariadb',
+            'user'     => 'invalid',
+            'password' => '',
+            'database' => 'test_database'
+        ]);
+
+        $database->deleteUserSessions(1);
+    }
+}