10 Commits
Author SHA1 Message Date
bence e59d627080 Merge pull request 'feature/update-to-php81' (#29) from feature/update-to-php81 into master
soko-web/pipeline/head This commit looks good
Reviewed-on: #29
2023-09-27 22:11:05 +02:00
bence 3acca19d49 use new interface of TestCase
soko-web/pipeline/pr-master This commit looks good
2023-09-27 22:05:56 +02:00
bence 2226b88a88 adapt signature of DatabaseSessionHandler::gc to the parent class
soko-web/pipeline/pr-master There was a failure building this commit
2023-09-27 21:46:32 +02:00
bence 8e08b09ae8 generate composer.lock
soko-web/pipeline/pr-master There was a failure building this commit
2023-09-27 21:41:17 +02:00
bence a3bce1f2aa update composer packages 2023-09-27 21:38:59 +02:00
bence a84d3a3976 update to php 8.1 2023-09-27 21:35:44 +02:00
bence 7210b24aa3 Merge pull request 'log erros that were already caught' (#28) from feature/error-log into master
soko-web/pipeline/head This commit looks good
Reviewed-on: #28
2023-09-27 00:26:55 +02:00
bence 2d48f20aed log erros that were already caught
soko-web/pipeline/pr-master This commit looks good
2023-09-27 00:04:26 +02:00
bence ebe1fa2aa6 Merge pull request 'lazy create mysql connecion' (#27) from feature/lazy-create-mysql-connection into master
soko-web/pipeline/head This commit looks good
Reviewed-on: #27
2023-09-16 23:56:41 +02:00
bence bccee89c13 lazy create mysql connecion
soko-web/pipeline/pr-master This commit looks good
2023-09-16 13:18:42 +02:00
7 changed files with 420 additions and 602 deletions

No files matched your search

+1 -1
View File
@@ -1,4 +1,4 @@
FROM php:7.4.7-cli-buster FROM php:8.1-cli-bookworm
RUN apt-get update && apt-get install -y unzip RUN apt-get update && apt-get install -y unzip
RUN curl -sS https://getcomposer.org/installer | php -- --install-dir=/usr/local/bin --filename=composer RUN curl -sS https://getcomposer.org/installer | php -- --install-dir=/usr/local/bin --filename=composer
+3 -3
View File
@@ -5,12 +5,12 @@
"license": "GNU GPL 3.0", "license": "GNU GPL 3.0",
"require": { "require": {
"vlucas/phpdotenv": "^5.5", "vlucas/phpdotenv": "^5.5",
"symfony/console": "^5.4", "symfony/console": "^6.3",
"phpmailer/phpmailer": "^6.8", "phpmailer/phpmailer": "^6.8",
"cocur/slugify": "^4.3" "cocur/slugify": "^4.5"
}, },
"require-dev": { "require-dev": {
"phpunit/phpunit": "^9.6", "phpunit/phpunit": "^10.3",
"phpstan/phpstan": "^1.10" "phpstan/phpstan": "^1.10"
}, },
"autoload": { "autoload": {
Generated
+366 -568
View File
File diff suppressed because it is too large. Load diff
+44 -25
View File
@@ -7,48 +7,52 @@ use mysqli;
class Connection implements IConnection class Connection implements IConnection
{ {
private mysqli $connection; private string $host;
private string $user;
private string $password;
private string $db;
private int $port;
private string $socket;
private ?mysqli $connection = null;
public function __construct(string $host, string $user, string $password, string $db, int $port = -1, string $socket = null) public function __construct(string $host, string $user, string $password, string $db, int $port = -1, string $socket = null)
{ {
if ($port < 0) { $this->host = $host;
$port = (int) ini_get('mysqli.default_port'); $this->user = $user;
} $this->password = $password;
$this->db = $db;
if ($socket === null) { $this->port = $port < 0 ? (int) ini_get('mysqli.default_port') : $port;
$socket = (string) ini_get('mysqli.default_socket'); $this->socket = $socket === null ? (string) ini_get('mysqli.default_socket') : $socket;
}
mysqli_report(MYSQLI_REPORT_ERROR | MYSQLI_REPORT_STRICT);
$this->connection = new mysqli($host, $user, $password, $db, $port, $socket);
$this->connection->set_charset('utf8mb4');
} }
public function __destruct() public function __destruct()
{ {
if ($this->connection === null) {
return;
}
$this->connection->close(); $this->connection->close();
} }
public function startTransaction(): void public function startTransaction(): void
{ {
$this->connection->autocommit(false); $this->getConnection()->autocommit(false);
} }
public function commit(): void public function commit(): void
{ {
$this->connection->commit(); $this->getConnection()->commit();
$this->connection->autocommit(true); $this->getConnection()->autocommit(true);
} }
public function rollback(): void public function rollback(): void
{ {
$this->connection->rollback(); $this->getConnection()->rollback();
$this->connection->autocommit(true); $this->getConnection()->autocommit(true);
} }
public function query(string $query): ?IResultSet public function query(string $query): ?IResultSet
{ {
$result = $this->connection->query($query); $result = $this->getConnection()->query($query);
if ($result !== true) { if ($result !== true) {
return new ResultSet($result); return new ResultSet($result);
@@ -59,36 +63,51 @@ class Connection implements IConnection
public function multiQuery(string $query): array public function multiQuery(string $query): array
{ {
$this->connection->multi_query($query); $this->getConnection()->multi_query($query);
$ret = []; $ret = [];
do { do {
if ($result = $this->connection->store_result()) { if ($result = $this->getConnection()->store_result()) {
$ret[] = new ResultSet($result); $ret[] = new ResultSet($result);
} else { } else {
$ret[] = null; $ret[] = null;
} }
$this->connection->more_results(); $this->getConnection()->more_results();
} while ($this->connection->next_result()); } while ($this->getConnection()->next_result());
return $ret; return $ret;
} }
public function prepare(string $query): IStatement public function prepare(string $query): IStatement
{ {
$stmt = $this->connection->prepare($query); $stmt = $this->getConnection()->prepare($query);
return new Statement($stmt); return new Statement($stmt);
} }
public function lastId(): int public function lastId(): int
{ {
return $this->connection->insert_id; return $this->getConnection()->insert_id;
} }
public function getAffectedRows(): int public function getAffectedRows(): int
{ {
return $this->connection->affected_rows; return $this->getConnection()->affected_rows;
}
private function getConnection(): mysqli
{
if ($this->connection === null) {
$this->createConnection();
}
return $this->connection;
}
private function createConnection(): void
{
mysqli_report(MYSQLI_REPORT_ERROR | MYSQLI_REPORT_STRICT);
$this->connection = new mysqli($this->host, $this->user, $this->password, $this->db, $this->port, $this->socket);
$this->connection->set_charset('utf8mb4');
} }
} }
+1
View File
@@ -94,6 +94,7 @@ class HttpResponse
$response = call_user_func([$controller, $handler[1]]); $response = call_user_func([$controller, $handler[1]]);
} catch (Exception $exception) { } catch (Exception $exception) {
$this->dbConnection->rollback(); $this->dbConnection->rollback();
error_log($exception);
$this->render500($exception); $this->render500($exception);
return; return;
} }
+2 -2
View File
@@ -86,12 +86,12 @@ class DatabaseSessionHandler implements ISessionHandler
return true; return true;
} }
public function gc($maxlifetime): bool public function gc($maxlifetime): int|false
{ {
// empty on purpose // empty on purpose
// old sessions are deleted by MaintainDatabaseCommand // old sessions are deleted by MaintainDatabaseCommand
return true; return 1;
} }
public function create_sid(): string public function create_sid(): string
+3 -3
View File
@@ -17,7 +17,7 @@ final class GoogleOAuthTest extends TestCase
$redirectUrl = 'http://example.com/oauth'; $redirectUrl = 'http://example.com/oauth';
$requestMock = $this->getMockBuilder(IRequest::class) $requestMock = $this->getMockBuilder(IRequest::class)
->setMethods(['setUrl', 'setMethod', 'setQuery', 'setHeaders', 'send']) ->onlyMethods(['setUrl', 'setMethod', 'setQuery', 'setHeaders', 'send'])
->getMock(); ->getMock();
$googleOAuth = new GoogleOAuth($requestMock); $googleOAuth = new GoogleOAuth($requestMock);
@@ -48,10 +48,10 @@ final class GoogleOAuthTest extends TestCase
$redirectUrl = 'http://example.com/oauth'; $redirectUrl = 'http://example.com/oauth';
$requestMock = $this->getMockBuilder(IRequest::class) $requestMock = $this->getMockBuilder(IRequest::class)
->setMethods(['setUrl', 'setMethod', 'setQuery', 'setHeaders', 'send']) ->onlyMethods(['setUrl', 'setMethod', 'setQuery', 'setHeaders', 'send'])
->getMock(); ->getMock();
$responseMock = $this->getMockBuilder(IResponse::class) $responseMock = $this->getMockBuilder(IResponse::class)
->setMethods(['getBody', 'getHeaders']) ->onlyMethods(['getBody', 'getHeaders'])
->getMock(); ->getMock();
$googleOAuth = new GoogleOAuth($requestMock); $googleOAuth = new GoogleOAuth($requestMock);