From 2bc50b2cee50d32d2a4feeea88e529e4b41f83b5 Mon Sep 17 00:00:00 2001 From: Khushboo Verma <43381712+vermakhushboo@users.noreply.github.com> Date: Tue, 16 Jan 2024 19:09:33 +0530 Subject: [PATCH] Send email to all members of the org --- ...webhook.phtml => email-webhook-failed.tpl} | 10 ++--- src/Appwrite/Platform/Workers/Webhooks.php | 45 ++++++++++--------- 2 files changed, 28 insertions(+), 27 deletions(-) rename app/config/locale/templates/{email-webhook.phtml => email-webhook-failed.tpl} (55%) diff --git a/app/config/locale/templates/email-webhook.phtml b/app/config/locale/templates/email-webhook-failed.tpl similarity index 55% rename from app/config/locale/templates/email-webhook.phtml rename to app/config/locale/templates/email-webhook-failed.tpl index 14d879fef0..4c2fe45b11 100644 --- a/app/config/locale/templates/email-webhook.phtml +++ b/app/config/locale/templates/email-webhook-failed.tpl @@ -11,11 +11,11 @@ - Hi getParam('user') ?>, + Hi {{user}},

- Your webhook getParam('webhook') ?> on project getParam('project') ?> has been paused after getParam('attempts') ?> consecutive failures.
-

Webhook Endpoint: getParam('url') ?>

-

Error: getParam('error') ?>


To restore your webhook's functionality and reset attempts, we suggest to follow the below steps:
+ Your webhook {{webhook}} on project {{project}} has been paused after {{attempts}} consecutive failures.
+

Webhook Endpoint: {{url}}

+

Error: {{error}}


To restore your webhook's functionality and reset attempts, we suggest to follow the below steps:
  1. Examine the logs of both Appwrite Console and your webhook server to identify the issue.
  2. Investigate potential network issues and use webhook testing tools to verify expected behaviour.
    3. @@ -28,7 +28,7 @@
    - Webhook settings + Webhook settings
    diff --git a/src/Appwrite/Platform/Workers/Webhooks.php b/src/Appwrite/Platform/Workers/Webhooks.php index 950dd078b1..61305fbcb3 100644 --- a/src/Appwrite/Platform/Workers/Webhooks.php +++ b/src/Appwrite/Platform/Workers/Webhooks.php @@ -9,6 +9,7 @@ use Exception; use Utopia\App; use Utopia\Database\Document; use Utopia\Database\Database; +use Utopia\Database\Query; use Utopia\Logger\Log; use Utopia\Platform\Action; use Utopia\Queue\Message; @@ -158,36 +159,34 @@ class Webhooks extends Action if ($attempts >= self::MAX_FAILED_ATTEMPTS) { $webhook->setAttribute('enabled', false); - - $teamId = $project->getAttribute('teamId'); - // Find all 'userId' for this teamId from memberships collection by using query in find method - $users = $dbForConsole->find('users'); - $userDetails = array_map(function ($user) { - return [ - 'name' => $user->getAttribute('name'), - 'email' => $user->getAttribute('email') - ]; - }, $users); + $memberships = $dbForConsole->find('memberships', [ + Query::equal('teamInternalId', [$project->getAttribute('teamInternalId')]), + Query::limit(APP_LIMIT_SUBQUERY) + ]); + + $userIds = array_column(\array_map(fn ($membership) => $membership->getArrayCopy(), $memberships), 'userId'); + + $users = $dbForConsole->find('users', [ + Query::equal('$id', $userIds), + ]); $protocol = App::getEnv('_APP_OPTIONS_FORCE_HTTPS') == 'disabled' ? 'http' : 'https'; $hostname = App::getEnv('_APP_DOMAIN'); $projectId = $project->getId(); $webhookId = $webhook->getId(); - $template = __DIR__ . '/../../../../app/config/locale/templates/email-webhook.phtml'; - $template = new View($template); + $template = Template::fromFile(__DIR__ . '/../../../../app/config/locale/templates/email-webhook-failed.tpl'); - // $template->setParam('user', $user->getAttribute('name')); - $template->setParam('webhook', $webhook->getAttribute('name')); - $template->setParam('project', $project->getAttribute('name')); - $template->setParam('url', $webhook->getAttribute('url')); - $template->setParam('error', $curlError ?? 'The server returned ' . $statusCode . ' status code'); - $template->setParam('redirect', $protocol . '://' . $hostname . "/console/project-$projectId/settings/webhooks/$webhookId"); - $template->setParam('attempts', $attempts); + $template->setParam('{{webhook}}', $webhook->getAttribute('name')); + $template->setParam('{{project}}', $project->getAttribute('name')); + $template->setParam('{{url}}', $webhook->getAttribute('url')); + $template->setParam('{{error}}', $curlError ?? 'The server returned ' . $statusCode . ' status code'); + $template->setParam('{{redirect}}', $protocol . '://' . $hostname . "/console/project-$projectId/settings/webhooks/$webhookId"); + $template->setParam('{{attempts}}', $attempts); $subject = 'Webhook deliveries have been paused'; - $body = Template::fromFile(__DIR__ . '/../../../../app/config/locale/templates/email-base-branded.tpl'); + $body = Template::fromFile(__DIR__ . '/../../../../app/config/locale/templates/email-base-styled.tpl'); $body ->setParam('{{subject}}', $subject) @@ -198,9 +197,11 @@ class Webhooks extends Action ->setSubject($subject) ->setBody($body->render()); - foreach ($userEmails as $userEmail) { + foreach ($users as $user) { $queueForMails - ->setRecipient($userEmail) + ->setVariables(['user' => $user->getAttribute('name', '')]) + ->setName($user->getAttribute('name', '')) + ->setRecipient($user->getAttribute('email')) ->trigger(); } }