check session validity by DatabaseSessionHandler
All checks were successful
soko-web/pipeline/pr-master This commit looks good

This commit is contained in:
Bence Pőcze 2023-05-02 12:21:05 +02:00
parent 0da1d00c3d
commit 72fc78220f
Signed by: bence
GPG Key ID: DC5BD6E95A333E6D

View File

@ -13,14 +13,17 @@ class DatabaseSessionHandler implements ISessionHandler
private string $table; private string $table;
private DateTime $shouldBeNewerThan;
private bool $exists = false; private bool $exists = false;
private bool $written = false; private bool $written = false;
public function __construct(IConnection $dbConnection, string $table) public function __construct(IConnection $dbConnection, string $table, DateTime $shouldBeNewerThan)
{ {
$this->dbConnection = $dbConnection; $this->dbConnection = $dbConnection;
$this->table = $table; $this->table = $table;
$this->shouldBeNewerThan = $shouldBeNewerThan;
} }
public function open($savePath, $sessionName): bool public function open($savePath, $sessionName): bool
@ -36,17 +39,20 @@ class DatabaseSessionHandler implements ISessionHandler
public function read($id): string public function read($id): string
{ {
$select = new Select($this->dbConnection, $this->table); $select = new Select($this->dbConnection, $this->table);
$select->columns(['data']); $select->columns(['data', 'updated']);
$select->whereId(substr($id, 0, 32)); $select->whereId(substr($id, 0, 32));
$result = $select->execute()->fetch(IResultSet::FETCH_ASSOC); $result = $select->execute()->fetch(IResultSet::FETCH_ASSOC);
if ($result === null) { if ($result === null) {
return ''; return '';
} }
$this->exists = true; $this->exists = true;
if (new DateTime($result['updated']) < $this->shouldBeNewerThan) {
return '';
}
return $result['data']; return $result['data'];
} }