Elgato_dark/appwrite
1
0
Fork 0
mirror of https://github.com/appwrite/appwrite synced 2026-05-06 06:48:22 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 3

chore: updated naming for subscribers

Browse source
This commit is contained in:
Chirag Aggarwal 2025-02-27 07:23:13 +00:00
parent 28896081d7
commit 388affa3d0
7 changed files with 21 additions and 21 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
app/controllers/api/functions.php
View file

@ -411,7 +411,7 @@ App::post('/v1/functions')
/** Trigger Realtime Events */
$queueForRealtime
->from($ruleCreate)
->setTargets(['console', $project->getId()])
->setSubscribers(['console', $project->getId()])
->trigger();
}

20
src/Appwrite/Event/Realtime.php
View file

@ -7,7 +7,7 @@ use Utopia\Database\Document;
class Realtime extends Event
{
protected array $targets = [];
protected array $subscribers = [];
public function __construct()
{
@ -32,25 +32,25 @@ class Realtime extends Event
}
/**
* Set targets for this realtime event.
* Set subscribers for this realtime event.
*
* @param array $targets
* @param array $subscribers
* @return array
*/
public function setTargets(array $targets): self
public function setSubscribers(array $subscribers): self
{
$this->targets = $targets;
$this->subscribers = $subscribers;
return $this;
}
/**
* Get targets for this realtime event.
* Get subscribers for this realtime event.
*
* @return array
*/
public function getTargets(): array
public function getSubscribers(): array
{
return $this->targets;
return $this->subscribers;
}
/**
@ -82,8 +82,8 @@ class Realtime extends Event
bucket: $bucket,
);
$projectIds = !empty($this->getTargets())
? $this->getTargets()
$projectIds = !empty($this->getSubscribers())
? $this->getSubscribers()
: [$target['projectId'] ?? $this->getProject()->getId()];
foreach ($projectIds as $projectId) {

8
src/Appwrite/Platform/Workers/Builds.php
View file

@ -383,7 +383,7 @@ class Builds extends Action
*/
$queueForRealtime
->setProject($project)
->setTargets(['console'])
->setSubscribers(['console'])
->setEvent($event)
->setParam('functionId', $function->getId())
->setParam('deploymentId', $deployment->getId())
@ -457,7 +457,7 @@ class Builds extends Action
/** Trigger Realtime Event */
$queueForRealtime
->setProject($project)
->setTargets(['console'])
->setSubscribers(['console'])
->setEvent($event)
->setParam('functionId', $function->getId())
->setParam('deploymentId', $deployment->getId())
@ -589,7 +589,7 @@ class Builds extends Action
*/
$queueForRealtime
->setProject($project)
->setTargets(['console'])
->setSubscribers(['console'])
->setEvent($event)
->setParam('functionId', $function->getId())
->setParam('deploymentId', $deployment->getId())
@ -686,7 +686,7 @@ class Builds extends Action
*/
$queueForRealtime
->setProject($project)
->setTargets(['console'])
->setSubscribers(['console'])
->setEvent($event)
->setParam('functionId', $function->getId())
->setParam('deploymentId', $deployment->getId())

2
src/Appwrite/Platform/Workers/Certificates.php
View file

@ -394,7 +394,7 @@ class Certificates extends Action
/** Trigger Realtime Events */
$queueForRealtime
->from($queueForEvents)
->setTargets(['console', $projectId])
->setSubscribers(['console', $projectId])
->trigger();
}
}

6
src/Appwrite/Platform/Workers/Databases.php
View file

@ -601,17 +601,17 @@ class Databases extends Action
): void {
$queueForRealtime
->setProject($project)
->setTargets(['console'])
->setSubscribers(['console'])
->setEvent($event)
->setParam('databaseId', $database->getId())
->setParam('collectionId', $collection->getId());
if ($attribute !== null) {
if ($attribute !== null && !empty($attribute)) {
$queueForRealtime
->setParam('attributeId', $attribute->getId())
->setPayload($attribute->getArrayCopy());
}
if ($index !== null) {
if ($index !== null && !empty($index)) {
$queueForRealtime
->setParam('indexId', $index->getId())
->setPayload($index->getArrayCopy());

2
src/Appwrite/Platform/Workers/Functions.php
View file

@ -600,7 +600,7 @@ class Functions extends Action
/** Trigger Realtime Events */
$queueForRealtime
->from($queueForEvents)
->setTargets(['console', $project->getId()])
->setSubscribers(['console', $project->getId()])
->trigger();
if (!empty($error)) {

2
src/Appwrite/Platform/Workers/Migrations.php
View file

@ -160,7 +160,7 @@ class Migrations extends Action
/** Trigger Realtime Events */
$queueForRealtime
->setProject($project)
->setTargets(['console', $project->getId()])
->setSubscribers(['console', $project->getId()])
->setEvent('migrations.[migrationId].update')
->setParam('migrationId', $migration->getId())
->setPayload($migration->getArrayCopy())