CodeMirror/appwrite
1
0
Fork 0
mirror of synced 2024-09-28 23:41:23 +12:00
Code Issues Projects Releases Wiki Activity

fix test cases and bug fix in messaging worker

Browse source
This commit is contained in:
Prateek Banga 2023-09-20 20:51:03 +05:30
parent 3456ad4e8c
commit 975b444761
2 changed files with 19 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

22
app/controllers/api/account.php
View file

@ -1330,15 +1330,22 @@ App::post('/v1/account/sessions/phone')
$message = $message->setParam('{{token}}', $secret);
$message = $message->render();
$target = $dbForProject->createDocument('targets', new Document([
'userId' => $user->getId(),
'userInternalId' => $user->getInternalId(),
'providerId' => $provider->getId(),
'providerInternalId' => $provider->getInternalId(),
'identifier' => $phone,
]));
$messageDoc = $dbForProject->createDocument('messages', new Document([
'to' => [$phone],
'to' => [$target->getId()],
'data' => [
'content' => $message,
'from' => $from,
],
'providerId' => $provider->getId(),
'providerInternalId' => $provider->getInternalId(),
'deliveryTime' => Datetime::now(),
]));
$messaging
@ -2952,15 +2959,22 @@ App::post('/v1/account/verification/phone')
$message = $message->setParam('{{token}}', $secret);
$message = $message->render();
$target = $dbForProject->createDocument('targets', new Document([
'userId' => $user->getId(),
'userInternalId' => $user->getInternalId(),
'providerId' => $provider->getId(),
'providerInternalId' => $provider->getInternalId(),
'identifier' => $user->getAttribute('phone'),
]));
$messageDoc = $dbForProject->createDocument('messages', new Document([
'to' => [$user->getAttribute('phone')],
'to' => [$target->getId()],
'data' => [
'content' => $message,
'from' => $from,
],
'providerId' => $provider->getId(),
'providerInternalId' => $provider->getInternalId(),
'deliveryTime' => Datetime::now(),
]));
$messaging

2
app/workers/messaging.php
View file

@ -127,7 +127,7 @@ class MessagingV1 extends Worker
}
$targets = $this->dbForProject->find('targets', [Query::equal('$id', $recipientsId)]);
\array_merge($recipients, $targets);
$recipients = \array_merge($recipients, $targets);
$identifiers = \array_map(function (Document $recipient) {
return $recipient->getAttribute('identifier');