Compare commits

..

2 commits

Author SHA1 Message Date
Funky Waddle af5f5feb33 update phpunit cache
Some checks failed
CI / test (8.2) (push) Has been cancelled
CI / test (8.3) (push) Has been cancelled
2025-12-15 16:42:04 -06:00
Funky Waddle 45b9987764 code standards tightening 2025-12-15 13:29:43 -06:00
5 changed files with 143 additions and 18 deletions

View file

@ -11,7 +11,7 @@ jobs:
runs-on: ubuntu-latest runs-on: ubuntu-latest
strategy: strategy:
matrix: matrix:
php: [ '8.1', '8.2', '8.3' ] php: [ '8.2', '8.3' ]
services: services:
mysql: mysql:
image: mysql:8 image: mysql:8

2
.gitignore vendored
View file

@ -48,3 +48,5 @@ com_crashlytics_export_strings.xml
crashlytics.properties crashlytics.properties
crashlytics-build.properties crashlytics-build.properties
fabric.properties fabric.properties
.junie.json

View file

@ -15,7 +15,7 @@ MIT
## Installation ## Installation
- Requirements: PHP >= 8.1, PDO extension for your database(s) - Requirements: PHP >= 8.2, PDO extension for your database(s)
- Install via Composer: - Install via Composer:
``` ```

View file

@ -38,7 +38,7 @@
"source": "https://github.com/getphred/pairity" "source": "https://github.com/getphred/pairity"
}, },
"require": { "require": {
"php": ">=8.1", "php": "^8.2",
"ext-mongodb": "*", "ext-mongodb": "*",
"mongodb/mongodb": "^2.0" "mongodb/mongodb": "^2.0"
}, },

View file

@ -143,7 +143,15 @@ abstract class AbstractDao implements DaoInterface
public function findOneBy(array $criteria): ?AbstractDto public function findOneBy(array $criteria): ?AbstractDto
{ {
// Events: dao.beforeFind (criteria may be mutated) // Events: dao.beforeFind (criteria may be mutated)
try { $ev = ['dao' => $this, 'table' => $this->getTable(), 'criteria' => &$criteria]; Events::dispatcher()->dispatch('dao.beforeFind', $ev); } catch (\Throwable) {} try {
$ev = [
'dao' => $this,
'table' => $this->getTable(),
'criteria' => &$criteria,
];
Events::dispatcher()->dispatch('dao.beforeFind', $ev);
} catch (\Throwable) {
}
$criteria = $this->applyDefaultScopes($criteria); $criteria = $this->applyDefaultScopes($criteria);
$this->applyRuntimeScopesToCriteria($criteria); $this->applyRuntimeScopesToCriteria($criteria);
[$where, $bindings] = $this->buildWhere($criteria); [$where, $bindings] = $this->buildWhere($criteria);
@ -167,7 +175,15 @@ abstract class AbstractDao implements DaoInterface
$this->eagerStrategy = null; // reset $this->eagerStrategy = null; // reset
$this->withStrategies = []; $this->withStrategies = [];
// Events: dao.afterFind // Events: dao.afterFind
try { $payload = ['dao' => $this, 'table' => $this->getTable(), 'dto' => $dto]; Events::dispatcher()->dispatch('dao.afterFind', $payload); } catch (\Throwable) {} try {
$payload = [
'dao' => $this,
'table' => $this->getTable(),
'dto' => $dto,
];
Events::dispatcher()->dispatch('dao.afterFind', $payload);
} catch (\Throwable) {
}
return $dto; return $dto;
} }
@ -190,7 +206,15 @@ abstract class AbstractDao implements DaoInterface
public function findAllBy(array $criteria = []): array public function findAllBy(array $criteria = []): array
{ {
// Events: dao.beforeFind (criteria may be mutated) // Events: dao.beforeFind (criteria may be mutated)
try { $ev = ['dao' => $this, 'table' => $this->getTable(), 'criteria' => &$criteria]; Events::dispatcher()->dispatch('dao.beforeFind', $ev); } catch (\Throwable) {} try {
$ev = [
'dao' => $this,
'table' => $this->getTable(),
'criteria' => &$criteria,
];
Events::dispatcher()->dispatch('dao.beforeFind', $ev);
} catch (\Throwable) {
}
$criteria = $this->applyDefaultScopes($criteria); $criteria = $this->applyDefaultScopes($criteria);
$this->applyRuntimeScopesToCriteria($criteria); $this->applyRuntimeScopesToCriteria($criteria);
[$where, $bindings] = $this->buildWhere($criteria); [$where, $bindings] = $this->buildWhere($criteria);
@ -212,7 +236,15 @@ abstract class AbstractDao implements DaoInterface
$this->eagerStrategy = null; // reset $this->eagerStrategy = null; // reset
$this->withStrategies = []; $this->withStrategies = [];
// Events: dao.afterFind (list) // Events: dao.afterFind (list)
try { $payload = ['dao' => $this, 'table' => $this->getTable(), 'dtos' => $dtos]; Events::dispatcher()->dispatch('dao.afterFind', $payload); } catch (\Throwable) {} try {
$payload = [
'dao' => $this,
'table' => $this->getTable(),
'dtos' => $dtos,
];
Events::dispatcher()->dispatch('dao.afterFind', $payload);
} catch (\Throwable) {
}
return $dtos; return $dtos;
} }
@ -300,7 +332,15 @@ abstract class AbstractDao implements DaoInterface
throw new \InvalidArgumentException('insert() requires non-empty data'); throw new \InvalidArgumentException('insert() requires non-empty data');
} }
// Events: dao.beforeInsert (allow mutation of $data) // Events: dao.beforeInsert (allow mutation of $data)
try { $ev = ['dao' => $this, 'table' => $this->getTable(), 'data' => &$data]; Events::dispatcher()->dispatch('dao.beforeInsert', $ev); } catch (\Throwable) {} try {
$ev = [
'dao' => $this,
'table' => $this->getTable(),
'data' => &$data,
];
Events::dispatcher()->dispatch('dao.beforeInsert', $ev);
} catch (\Throwable) {
}
$data = $this->prepareForInsert($data); $data = $this->prepareForInsert($data);
$cols = array_keys($data); $cols = array_keys($data);
$placeholders = array_map(fn($c) => ':' . $c, $cols); $placeholders = array_map(fn($c) => ':' . $c, $cols);
@ -310,12 +350,28 @@ abstract class AbstractDao implements DaoInterface
$pk = $this->getPrimaryKey(); $pk = $this->getPrimaryKey();
if ($id !== null) { if ($id !== null) {
$dto = $this->findById($id) ?? $this->hydrate(array_merge($data, [$pk => $id])); $dto = $this->findById($id) ?? $this->hydrate(array_merge($data, [$pk => $id]));
try { $payload = ['dao' => $this, 'table' => $this->getTable(), 'dto' => $dto]; Events::dispatcher()->dispatch('dao.afterInsert', $payload); } catch (\Throwable) {} try {
$payload = [
'dao' => $this,
'table' => $this->getTable(),
'dto' => $dto,
];
Events::dispatcher()->dispatch('dao.afterInsert', $payload);
} catch (\Throwable) {
}
return $dto; return $dto;
} }
// Fallback when lastInsertId is unavailable: return hydrated DTO from provided data // Fallback when lastInsertId is unavailable: return hydrated DTO from provided data
$dto = $this->hydrate($this->castRowFromStorage($data)); $dto = $this->hydrate($this->castRowFromStorage($data));
try { $payload = ['dao' => $this, 'table' => $this->getTable(), 'dto' => $dto]; Events::dispatcher()->dispatch('dao.afterInsert', $payload); } catch (\Throwable) {} try {
$payload = [
'dao' => $this,
'table' => $this->getTable(),
'dto' => $dto,
];
Events::dispatcher()->dispatch('dao.afterInsert', $payload);
} catch (\Throwable) {
}
return $dto; return $dto;
} }
@ -330,7 +386,16 @@ abstract class AbstractDao implements DaoInterface
throw new \InvalidArgumentException('No data provided to update and record not found'); throw new \InvalidArgumentException('No data provided to update and record not found');
} }
// Events: dao.beforeUpdate (mutate $data) // Events: dao.beforeUpdate (mutate $data)
try { $ev = ['dao' => $this, 'table' => $this->getTable(), 'id' => $id, 'data' => &$data]; Events::dispatcher()->dispatch('dao.beforeUpdate', $ev); } catch (\Throwable) {} try {
$ev = [
'dao' => $this,
'table' => $this->getTable(),
'id' => $id,
'data' => &$data,
];
Events::dispatcher()->dispatch('dao.beforeUpdate', $ev);
} catch (\Throwable) {
}
$toStore = $this->prepareForUpdate($data); $toStore = $this->prepareForUpdate($data);
$self = $this; $self = $this;
$conn = $this->connection; $conn = $this->connection;
@ -349,7 +414,15 @@ abstract class AbstractDao implements DaoInterface
$pk = $this->getPrimaryKey(); $pk = $this->getPrimaryKey();
$result = array_merge($base, $data, [$pk => $id]); $result = array_merge($base, $data, [$pk => $id]);
$dto = $this->hydrate($this->castRowFromStorage($result)); $dto = $this->hydrate($this->castRowFromStorage($result));
try { $payload = ['dao' => $this, 'table' => $this->getTable(), 'dto' => $dto]; Events::dispatcher()->dispatch('dao.afterUpdate', $payload); } catch (\Throwable) {} try {
$payload = [
'dao' => $this,
'table' => $this->getTable(),
'dto' => $dto,
];
Events::dispatcher()->dispatch('dao.afterUpdate', $payload);
} catch (\Throwable) {
}
return $dto; return $dto;
} }
@ -359,17 +432,42 @@ abstract class AbstractDao implements DaoInterface
throw new \InvalidArgumentException('No data provided to update and record not found'); throw new \InvalidArgumentException('No data provided to update and record not found');
} }
// Events: dao.beforeUpdate // Events: dao.beforeUpdate
try { $ev = ['dao' => $this, 'table' => $this->getTable(), 'id' => $id, 'data' => &$data]; Events::dispatcher()->dispatch('dao.beforeUpdate', $ev); } catch (\Throwable) {} try {
$ev = [
'dao' => $this,
'table' => $this->getTable(),
'id' => $id,
'data' => &$data,
];
Events::dispatcher()->dispatch('dao.beforeUpdate', $ev);
} catch (\Throwable) {
}
$data = $this->prepareForUpdate($data); $data = $this->prepareForUpdate($data);
$this->doImmediateUpdateWithLock($id, $data); $this->doImmediateUpdateWithLock($id, $data);
$updated = $this->findById($id); $updated = $this->findById($id);
if ($updated === null) { if ($updated === null) {
$pk = $this->getPrimaryKey(); $pk = $this->getPrimaryKey();
$dto = $this->hydrate($this->castRowFromStorage(array_merge($data, [$pk => $id]))); $dto = $this->hydrate($this->castRowFromStorage(array_merge($data, [$pk => $id])));
try { $payload = ['dao' => $this, 'table' => $this->getTable(), 'dto' => $dto]; Events::dispatcher()->dispatch('dao.afterUpdate', $payload); } catch (\Throwable) {} try {
$payload = [
'dao' => $this,
'table' => $this->getTable(),
'dto' => $dto,
];
Events::dispatcher()->dispatch('dao.afterUpdate', $payload);
} catch (\Throwable) {
}
return $dto; return $dto;
} }
try { $payload = ['dao' => $this, 'table' => $this->getTable(), 'dto' => $updated]; Events::dispatcher()->dispatch('dao.afterUpdate', $payload); } catch (\Throwable) {} try {
$payload = [
'dao' => $this,
'table' => $this->getTable(),
'dto' => $updated,
];
Events::dispatcher()->dispatch('dao.afterUpdate', $payload);
} catch (\Throwable) {
}
return $updated; return $updated;
} }
@ -378,7 +476,15 @@ abstract class AbstractDao implements DaoInterface
$uow = UnitOfWork::current(); $uow = UnitOfWork::current();
if ($uow && !UnitOfWork::isSuspended()) { if ($uow && !UnitOfWork::isSuspended()) {
$self = $this; $conn = $this->connection; $theId = $id; $self = $this; $conn = $this->connection; $theId = $id;
try { $ev = ['dao' => $this, 'table' => $this->getTable(), 'id' => $id]; Events::dispatcher()->dispatch('dao.beforeDelete', $ev); } catch (\Throwable) {} try {
$ev = [
'dao' => $this,
'table' => $this->getTable(),
'id' => $id,
];
Events::dispatcher()->dispatch('dao.beforeDelete', $ev);
} catch (\Throwable) {
}
$uow->enqueueWithMeta($conn, [ $uow->enqueueWithMeta($conn, [
'type' => 'delete', 'type' => 'delete',
'mode' => 'byId', 'mode' => 'byId',
@ -390,7 +496,15 @@ abstract class AbstractDao implements DaoInterface
// deferred; immediate affected count unknown // deferred; immediate affected count unknown
return 0; return 0;
} }
try { $ev = ['dao' => $this, 'table' => $this->getTable(), 'id' => $id]; Events::dispatcher()->dispatch('dao.beforeDelete', $ev); } catch (\Throwable) {} try {
$ev = [
'dao' => $this,
'table' => $this->getTable(),
'id' => $id,
];
Events::dispatcher()->dispatch('dao.beforeDelete', $ev);
} catch (\Throwable) {
}
if ($this->hasSoftDeletes()) { if ($this->hasSoftDeletes()) {
$columns = $this->softDeleteConfig(); $columns = $this->softDeleteConfig();
$deletedAt = $columns['deletedAt'] ?? 'deleted_at'; $deletedAt = $columns['deletedAt'] ?? 'deleted_at';
@ -400,7 +514,16 @@ abstract class AbstractDao implements DaoInterface
} }
$sql = 'DELETE FROM ' . $this->getTable() . ' WHERE ' . $this->getPrimaryKey() . ' = :pk'; $sql = 'DELETE FROM ' . $this->getTable() . ' WHERE ' . $this->getPrimaryKey() . ' = :pk';
$affected = $this->connection->execute($sql, ['pk' => $id]); $affected = $this->connection->execute($sql, ['pk' => $id]);
try { $payload = ['dao' => $this, 'table' => $this->getTable(), 'id' => $id, 'affected' => $affected]; Events::dispatcher()->dispatch('dao.afterDelete', $payload); } catch (\Throwable) {} try {
$payload = [
'dao' => $this,
'table' => $this->getTable(),
'id' => $id,
'affected' => $affected,
];
Events::dispatcher()->dispatch('dao.afterDelete', $payload);
} catch (\Throwable) {
}
return $affected; return $affected;
} }