fix: realtime channels; update: row model.

This commit is contained in:
Darshan 2025-05-06 11:31:05 +05:30
parent 253c428ca2
commit 3a8f097c17
2 changed files with 8 additions and 3 deletions

View file

@ -312,8 +312,8 @@ class Realtime extends Adapter
}
$channels[] = 'rows';
$channels[] = 'databases.' . $database->getId() . '.tables.' . $payload->getAttribute('$collectionId') . '.rows';
$channels[] = 'databases.' . $database->getId() . '.tables.' . $payload->getAttribute('$collectionId') . '.rows.' . $payload->getId();
$channels[] = 'databases.' . $database->getId() . '.tables.' . $payload->getAttribute('$tableId') . '.rows';
$channels[] = 'databases.' . $database->getId() . '.tables.' . $payload->getAttribute('$tableId') . '.rows.' . $payload->getId();
$roles = $table->getAttribute('documentSecurity', false)
? \array_merge($table->getRead(), $payload->getRead())

View file

@ -36,7 +36,7 @@ class Row extends Any
'default' => '',
'example' => '5e5ea5c16897e',
])
->addRule('$collectionId', [
->addRule('$tableId', [
'type' => self::TYPE_STRING,
'description' => 'Table ID.',
'default' => '',
@ -75,6 +75,11 @@ class Row extends Any
$document->removeAttribute('$collection');
$document->removeAttribute('$tenant');
$collectionId = $document->getAttribute('$collectionId');
$document
->removeAttribute('$collectionId')
->setAttribute('$tableId', $collectionId);
foreach ($document->getAttributes() as $column) {
if (\is_array($column)) {
foreach ($column as $subAttribute) {