check session validity by DatabaseSessionHandler
This commit is contained in:
parent
0da1d00c3d
commit
824ee0cd1f
@ -13,14 +13,17 @@ class DatabaseSessionHandler implements ISessionHandler
|
||||
|
||||
private string $table;
|
||||
|
||||
private DateTime $shouldBeNewerThan;
|
||||
|
||||
private bool $exists = 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->table = $table;
|
||||
$this->shouldBeNewerThan = $shouldBeNewerThan;
|
||||
}
|
||||
|
||||
public function open($savePath, $sessionName): bool
|
||||
@ -36,14 +39,17 @@ class DatabaseSessionHandler implements ISessionHandler
|
||||
public function read($id): string
|
||||
{
|
||||
$select = new Select($this->dbConnection, $this->table);
|
||||
$select->columns(['data']);
|
||||
$select->columns(['data', 'updated']);
|
||||
$select->whereId(substr($id, 0, 32));
|
||||
|
||||
$result = $select->execute()->fetch(IResultSet::FETCH_ASSOC);
|
||||
|
||||
if ($result === null) {
|
||||
return '';
|
||||
}
|
||||
if (new DateTime($result['updated']) < $this->shouldBeNewerThan) {
|
||||
$this->destroy($id);
|
||||
return '';
|
||||
}
|
||||
|
||||
$this->exists = true;
|
||||
|
||||
|
Loading…
Reference in New Issue
Block a user