sda-php
/
nur-sery
11
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

modifs.mineures sans commentaires

This commit is contained in:
Jephté Clain 2024-06-18 17:10:40 +04:00
parent 111a87bc3b
commit 057f3316ac
3 changed files with 39 additions and 20 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/db/Capacitor.php
View File

@ -50,8 +50,8 @@ class Capacitor {
$this->storage->_reset($this->channel, $recreate);
}
function charge($item, $func=null, ?array $args=null): int {
return $this->storage->_charge($this->channel, $item, $func, $args);
function charge($item, $func=null, ?array $args=null, ?array &$values=null): int {
return $this->storage->_charge($this->channel, $item, $func, $args, $values);
}
function discharge(bool $reset=true): iterable {

2
src/db/CapacitorChannel.php
View File

@ -248,7 +248,7 @@ class CapacitorChannel {
* Si $item est modifié dans cette méthode, il est possible de le retourner
* avec la clé "item" pour mettre à jour la ligne correspondante.
*/
function onCreate($item, array $rowValues): ?array {
function onCreate($item, array $rowValues, ?array $alwaysNull): ?array {
return null;
}

53
src/db/CapacitorStorage.php
View File

@ -178,7 +178,7 @@ EOT;
$this->_reset($this->getChannel($channel), $recreate);
}
function _charge(CapacitorChannel $channel, $item, $func, ?array $args): int {
function _charge(CapacitorChannel $channel, $item, $func, ?array $args, ?array &$values=null): int {
$this->_create($channel);
$tableName = $channel->getTableName();
$now = date("Y-m-d H:i:s");
@ -204,10 +204,11 @@ EOT;
"modified_" => $now,
]);
$insert = true;
if ($func === null) $func = "->onCreate";
func::ensure_func($func, $channel, $args);
$initFunc = [$channel, "onCreate"];
$initArgs = $args;
func::ensure_func($initFunc, null, $initArgs);
$values = $this->unserialize($channel, $row);
$args = [$item, $values, ...$args];
$pvalues = null;
} else {
# modification
if ($channel->_wasSumModified("item", $row, $prow)) {
@ -216,22 +217,36 @@ EOT;
"modified_" => $now,
]);
}
if ($func === null) $func = "->onUpdate";
func::ensure_func($func, $channel, $args);
$initFunc = [$channel, "onUpdate"];
$initArgs = $args;
func::ensure_func($initFunc, null, $initArgs);
$values = $this->unserialize($channel, $row);
$pvalues = $this->unserialize($channel, $prow);
$args = [$item, $values, $pvalues, ...$args];
}
$updates = func::call($func, ...$args);
$updates = func::call($initFunc, $item, $values, $pvalues, ...$initArgs);
if (is_array($updates) && $updates) {
if ($insert === null) $insert = false;
if (!array_key_exists("modified_", $updates)) {
$updates["modified_"] = $now;
}
$values = cl::merge($values, $updates);
$row = cl::merge($row, $this->serialize($channel, $updates));
}
if ($func !== null) {
func::ensure_func($func, $channel, $args);
$updates = func::call($func, $item, $values, $pvalues, ...$args);
if (is_array($updates) && $updates) {
if ($insert === null) $insert = false;
if (!array_key_exists("modified_", $updates)) {
$updates["modified_"] = $now;
}
$values = cl::merge($values, $updates);
$row = cl::merge($row, $this->serialize($channel, $updates));
}
}
if ($insert === null) {
# aucune modification
return 0;
@ -255,20 +270,24 @@ EOT;
/**
* charger une valeur dans le canal
*
* Si $func!==null, après avoir calculé les valeurs des clés supplémentaires
* avec {@link CapacitorChannel::getItemValues()}, la fonction est appelée
* avec la signature de {@link CapacitorChannel::onCreate()} ou
* {@link CapacitorChannel::onUpdate()} en fonction du type d'opération:
* création ou mise à jour
* Après avoir calculé les valeurs des clés supplémentaires
* avec {@link CapacitorChannel::getItemValues()}, l'une des deux fonctions
* {@link CapacitorChannel::onCreate()} ou {@link CapacitorChannel::onUpdate()}
* est appelée en fonction du type d'opération: création ou mise à jour
*
* Si la fonction retourne un tableau, il est utilisé pour modifier les valeurs
* insérées/mises à jour
* Ensuite, si $func !== null, la fonction est appelée avec la signature de
* {@link CapacitorChannel::onCreate()} ou {@link CapacitorChannel::onUpdate()}
* en fonction du type d'opération: création ou mise à jour
*
* Dans les deux cas, si la fonction retourne un tableau, il est utilisé pour
* modifier les valeurs insérées/mises à jour. De plus, $values obtient la
* valeur finale des données insérées/mises à jour
*
* @return int 1 si l'objet a été chargé ou mis à jour, 0 s'il existait
* déjà à l'identique dans le canal
*/
function charge(?string $channel, $item, $func=null, ?array $args=null): int {
return $this->_charge($this->getChannel($channel), $item, $func, $args);
function charge(?string $channel, $item, $func=null, ?array $args=null, ?array &$values=null): int {
return $this->_charge($this->getChannel($channel), $item, $func, $args, $values);
}
function _discharge(CapacitorChannel $channel, bool $reset=true): iterable {