PHP 8.5 compatibility - closes #5568,#5567
This commit is contained in:
@@ -306,6 +306,8 @@
|
||||
"vendor/laravel/framework/src/Illuminate/Session/FileSessionHandler.php",
|
||||
"vendor/laravel/framework/src/Illuminate/Session/NullSessionHandler.php",
|
||||
"vendor/laravel/framework/src/Illuminate/Session/CacheBasedSessionHandler.php",
|
||||
"vendor/laravel/framework/src/Illuminate/Session/CookieSessionHandler.php",
|
||||
"vendor/laravel/framework/src/Illuminate/Session/DatabaseSessionHandler.php",
|
||||
"vendor/laravel/framework/src/Illuminate/Session/Middleware/StartSession.php",
|
||||
"vendor/laravel/framework/src/Illuminate/Queue/Listener.php",
|
||||
"vendor/laravel/framework/src/Illuminate/Queue/SerializesModels.php",
|
||||
|
||||
@@ -0,0 +1,123 @@
|
||||
<?php
|
||||
|
||||
namespace Illuminate\Session;
|
||||
|
||||
use SessionHandlerInterface;
|
||||
use Illuminate\Support\InteractsWithTime;
|
||||
use Symfony\Component\HttpFoundation\Request;
|
||||
use Illuminate\Contracts\Cookie\QueueingFactory as CookieJar;
|
||||
|
||||
class CookieSessionHandler implements SessionHandlerInterface
|
||||
{
|
||||
use InteractsWithTime;
|
||||
|
||||
/**
|
||||
* The cookie jar instance.
|
||||
*
|
||||
* @var \Illuminate\Contracts\Cookie\Factory
|
||||
*/
|
||||
protected $cookie;
|
||||
|
||||
/**
|
||||
* The request instance.
|
||||
*
|
||||
* @var \Symfony\Component\HttpFoundation\Request
|
||||
*/
|
||||
protected $request;
|
||||
|
||||
/**
|
||||
* The number of minutes the session should be valid.
|
||||
*
|
||||
* @var int
|
||||
*/
|
||||
protected $minutes;
|
||||
|
||||
/**
|
||||
* Create a new cookie driven handler instance.
|
||||
*
|
||||
* @param \Illuminate\Contracts\Cookie\QueueingFactory $cookie
|
||||
* @param int $minutes
|
||||
* @return void
|
||||
*/
|
||||
public function __construct(CookieJar $cookie, $minutes)
|
||||
{
|
||||
$this->cookie = $cookie;
|
||||
$this->minutes = $minutes;
|
||||
}
|
||||
|
||||
/**
|
||||
* {@inheritdoc}
|
||||
*/
|
||||
public function open($savePath, $sessionName): bool
|
||||
{
|
||||
return true;
|
||||
}
|
||||
|
||||
/**
|
||||
* {@inheritdoc}
|
||||
*/
|
||||
public function close(): bool
|
||||
{
|
||||
return true;
|
||||
}
|
||||
|
||||
/**
|
||||
* {@inheritdoc}
|
||||
* #[\\ReturnTypeWillChange]
|
||||
*/
|
||||
public function read($sessionId)
|
||||
{
|
||||
$value = $this->request->cookies->get($sessionId) ?: '';
|
||||
|
||||
if (! is_null($decoded = json_decode($value, true)) && is_array($decoded)) {
|
||||
if (isset($decoded['expires']) && $this->currentTime() <= $decoded['expires']) {
|
||||
return $decoded['data'];
|
||||
}
|
||||
}
|
||||
|
||||
return '';
|
||||
}
|
||||
|
||||
/**
|
||||
* {@inheritdoc}
|
||||
*/
|
||||
public function write($sessionId, $data): bool
|
||||
{
|
||||
$this->cookie->queue($sessionId, json_encode([
|
||||
'data' => $data,
|
||||
'expires' => $this->availableAt($this->minutes * 60),
|
||||
]), $this->minutes);
|
||||
|
||||
return true;
|
||||
}
|
||||
|
||||
/**
|
||||
* {@inheritdoc}
|
||||
*/
|
||||
public function destroy($sessionId): bool
|
||||
{
|
||||
$this->cookie->queue($this->cookie->forget($sessionId));
|
||||
|
||||
return true;
|
||||
}
|
||||
|
||||
/**
|
||||
* {@inheritdoc}
|
||||
* #[\\ReturnTypeWillChange]
|
||||
*/
|
||||
public function gc($lifetime)
|
||||
{
|
||||
return true;
|
||||
}
|
||||
|
||||
/**
|
||||
* Set the request instance.
|
||||
*
|
||||
* @param \Symfony\Component\HttpFoundation\Request $request
|
||||
* @return void
|
||||
*/
|
||||
public function setRequest(Request $request)
|
||||
{
|
||||
$this->request = $request;
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,294 @@
|
||||
<?php
|
||||
|
||||
namespace Illuminate\Session;
|
||||
|
||||
use Illuminate\Support\Arr;
|
||||
use SessionHandlerInterface;
|
||||
use Illuminate\Support\Carbon;
|
||||
use Illuminate\Contracts\Auth\Guard;
|
||||
use Illuminate\Database\QueryException;
|
||||
use Illuminate\Support\InteractsWithTime;
|
||||
use Illuminate\Database\ConnectionInterface;
|
||||
use Illuminate\Contracts\Container\Container;
|
||||
|
||||
class DatabaseSessionHandler implements SessionHandlerInterface, ExistenceAwareInterface
|
||||
{
|
||||
use InteractsWithTime;
|
||||
|
||||
/**
|
||||
* The database connection instance.
|
||||
*
|
||||
* @var \Illuminate\Database\ConnectionInterface
|
||||
*/
|
||||
protected $connection;
|
||||
|
||||
/**
|
||||
* The name of the session table.
|
||||
*
|
||||
* @var string
|
||||
*/
|
||||
protected $table;
|
||||
|
||||
/**
|
||||
* The number of minutes the session should be valid.
|
||||
*
|
||||
* @var int
|
||||
*/
|
||||
protected $minutes;
|
||||
|
||||
/**
|
||||
* The container instance.
|
||||
*
|
||||
* @var \Illuminate\Contracts\Container\Container
|
||||
*/
|
||||
protected $container;
|
||||
|
||||
/**
|
||||
* The existence state of the session.
|
||||
*
|
||||
* @var bool
|
||||
*/
|
||||
protected $exists;
|
||||
|
||||
/**
|
||||
* Create a new database session handler instance.
|
||||
*
|
||||
* @param \Illuminate\Database\ConnectionInterface $connection
|
||||
* @param string $table
|
||||
* @param int $minutes
|
||||
* @param \Illuminate\Contracts\Container\Container|null $container
|
||||
* @return void
|
||||
*/
|
||||
public function __construct(ConnectionInterface $connection, $table, $minutes, ?Container $container = null)
|
||||
{
|
||||
$this->table = $table;
|
||||
$this->minutes = $minutes;
|
||||
$this->container = $container;
|
||||
$this->connection = $connection;
|
||||
}
|
||||
|
||||
/**
|
||||
* {@inheritdoc}
|
||||
*/
|
||||
public function open($savePath, $sessionName)
|
||||
{
|
||||
return true;
|
||||
}
|
||||
|
||||
/**
|
||||
* {@inheritdoc}
|
||||
*/
|
||||
public function close()
|
||||
{
|
||||
return true;
|
||||
}
|
||||
|
||||
/**
|
||||
* {@inheritdoc}
|
||||
*/
|
||||
public function read($sessionId)
|
||||
{
|
||||
$session = (object) $this->getQuery()->find($sessionId);
|
||||
|
||||
if ($this->expired($session)) {
|
||||
$this->exists = true;
|
||||
|
||||
return '';
|
||||
}
|
||||
|
||||
if (isset($session->payload)) {
|
||||
$this->exists = true;
|
||||
|
||||
return base64_decode($session->payload);
|
||||
}
|
||||
|
||||
return '';
|
||||
}
|
||||
|
||||
/**
|
||||
* Determine if the session is expired.
|
||||
*
|
||||
* @param \stdClass $session
|
||||
* @return bool
|
||||
*/
|
||||
protected function expired($session)
|
||||
{
|
||||
return isset($session->last_activity) &&
|
||||
$session->last_activity < Carbon::now()->subMinutes($this->minutes)->getTimestamp();
|
||||
}
|
||||
|
||||
/**
|
||||
* {@inheritdoc}
|
||||
*/
|
||||
public function write($sessionId, $data)
|
||||
{
|
||||
$payload = $this->getDefaultPayload($data);
|
||||
|
||||
if (! $this->exists) {
|
||||
$this->read($sessionId);
|
||||
}
|
||||
|
||||
if ($this->exists) {
|
||||
$this->performUpdate($sessionId, $payload);
|
||||
} else {
|
||||
$this->performInsert($sessionId, $payload);
|
||||
}
|
||||
|
||||
return $this->exists = true;
|
||||
}
|
||||
|
||||
/**
|
||||
* Perform an insert operation on the session ID.
|
||||
*
|
||||
* @param string $sessionId
|
||||
* @param string $payload
|
||||
* @return bool|null
|
||||
*/
|
||||
protected function performInsert($sessionId, $payload)
|
||||
{
|
||||
try {
|
||||
return $this->getQuery()->insert(Arr::set($payload, 'id', $sessionId));
|
||||
} catch (QueryException $e) {
|
||||
$this->performUpdate($sessionId, $payload);
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* Perform an update operation on the session ID.
|
||||
*
|
||||
* @param string $sessionId
|
||||
* @param string $payload
|
||||
* @return int
|
||||
*/
|
||||
protected function performUpdate($sessionId, $payload)
|
||||
{
|
||||
return $this->getQuery()->where('id', $sessionId)->update($payload);
|
||||
}
|
||||
|
||||
/**
|
||||
* Get the default payload for the session.
|
||||
*
|
||||
* @param string $data
|
||||
* @return array
|
||||
*/
|
||||
protected function getDefaultPayload($data)
|
||||
{
|
||||
$payload = [
|
||||
'payload' => base64_encode($data),
|
||||
'last_activity' => $this->currentTime(),
|
||||
];
|
||||
|
||||
if (! $this->container) {
|
||||
return $payload;
|
||||
}
|
||||
|
||||
return tap($payload, function (&$payload) {
|
||||
$this->addUserInformation($payload)
|
||||
->addRequestInformation($payload);
|
||||
});
|
||||
}
|
||||
|
||||
/**
|
||||
* Add the user information to the session payload.
|
||||
*
|
||||
* @param array $payload
|
||||
* @return $this
|
||||
*/
|
||||
protected function addUserInformation(&$payload)
|
||||
{
|
||||
if ($this->container->bound(Guard::class)) {
|
||||
$payload['user_id'] = $this->userId();
|
||||
}
|
||||
|
||||
return $this;
|
||||
}
|
||||
|
||||
/**
|
||||
* Get the currently authenticated user's ID.
|
||||
*
|
||||
* @return mixed
|
||||
*/
|
||||
protected function userId()
|
||||
{
|
||||
return $this->container->make(Guard::class)->id();
|
||||
}
|
||||
|
||||
/**
|
||||
* Add the request information to the session payload.
|
||||
*
|
||||
* @param array $payload
|
||||
* @return $this
|
||||
*/
|
||||
protected function addRequestInformation(&$payload)
|
||||
{
|
||||
if ($this->container->bound('request')) {
|
||||
$payload = array_merge($payload, [
|
||||
'ip_address' => $this->ipAddress(),
|
||||
'user_agent' => $this->userAgent(),
|
||||
]);
|
||||
}
|
||||
|
||||
return $this;
|
||||
}
|
||||
|
||||
/**
|
||||
* Get the IP address for the current request.
|
||||
*
|
||||
* @return string
|
||||
*/
|
||||
protected function ipAddress()
|
||||
{
|
||||
return $this->container->make('request')->ip();
|
||||
}
|
||||
|
||||
/**
|
||||
* Get the user agent for the current request.
|
||||
*
|
||||
* @return string
|
||||
*/
|
||||
protected function userAgent()
|
||||
{
|
||||
return substr((string) $this->container->make('request')->header('User-Agent'), 0, 500);
|
||||
}
|
||||
|
||||
/**
|
||||
* {@inheritdoc}
|
||||
*/
|
||||
public function destroy($sessionId)
|
||||
{
|
||||
$this->getQuery()->where('id', $sessionId)->delete();
|
||||
|
||||
return true;
|
||||
}
|
||||
|
||||
/**
|
||||
* {@inheritdoc}
|
||||
*/
|
||||
public function gc($lifetime)
|
||||
{
|
||||
$this->getQuery()->where('last_activity', '<=', $this->currentTime() - $lifetime)->delete();
|
||||
}
|
||||
|
||||
/**
|
||||
* Get a fresh query builder instance for the table.
|
||||
*
|
||||
* @return \Illuminate\Database\Query\Builder
|
||||
*/
|
||||
protected function getQuery()
|
||||
{
|
||||
return $this->connection->table($this->table);
|
||||
}
|
||||
|
||||
/**
|
||||
* Set the existence state for the session.
|
||||
*
|
||||
* @param bool $value
|
||||
* @return $this
|
||||
*/
|
||||
public function setExists($value)
|
||||
{
|
||||
$this->exists = $value;
|
||||
|
||||
return $this;
|
||||
}
|
||||
}
|
||||
Reference in New Issue
Block a user