WIP

expose/api/src/Consumer/Handler/DownloadRequestHandler.php

@@ -5,7 +5,7 @@
 namespace App\Consumer\Handler;
 
 use Alchemy\CoreBundle\Util\DoctrineUtil;
-use Alchemy\NotifyBundle\src\NotifierInterface;
+use Alchemy\NotifyBundle\Notification\NotifierInterface;
 use App\Entity\DownloadRequest;
 use App\Security\Authentication\JWTManager;
 use Doctrine\ORM\EntityManagerInterface;
@@ -44,10 +44,10 @@ public function __invoke(DownloadRequest $message): void
 
         $this->notifier->sendEmail(
             $downloadRequest->getEmail(),
-            'expose/download_link',
-            $downloadRequest->getLocale(),
+            'expose-download-link',
             [
-                'download_url' => $downloadUrl,
+                'locale' => $downloadRequest->getLocale(),
+                'downloadUrl' => $downloadUrl,
             ]
         );
     }

lib/php/notify-bundle/src/Notification/NotifierInterface.php

@@ -11,4 +11,10 @@ public function notifyUser(
         string $notificationId,
         array $parameters = [],
     ): void;
+
+    public function sendEmail(
+        string $email,
+        string $notificationId,
+        array $parameters = [],
+    ): void;
 }

lib/php/notify-bundle/src/Notification/SymfonyNotifier.php

@@ -20,17 +20,27 @@ public function __construct(
     }
 
     public function notifyUser(string $userId, string $notificationId, array $parameters = []): void
+    {
+        $recipient = new NovuSubscriberRecipient($userId);
+        $this->sendNotification($recipient, $notificationId, $parameters, 'user');
+    }
+
+    public function sendEmail(string $email, string $notificationId, array $parameters = []): void
+    {
+        $recipient = new NovuSubscriberRecipient($email, email: $email);
+        $this->sendNotification($recipient, $notificationId, $parameters);
+    }
+
+    private function sendNotification(NovuSubscriberRecipient $recipient, string $notificationId, array $parameters): void
     {
         $content = json_encode($parameters, JSON_THROW_ON_ERROR);
-        $this->logger->debug(sprintf('Send notification to user "%s" with template "%s"', $userId, $notificationId), [
+        $this->logger->debug(sprintf('Send notification "%s" with template "%s"', $recipient->getSubscriberId(), $notificationId), [
             'content' => $content,
         ]);
 
         $notification = new NovuNotification($notificationId);
         $notification->content($content);
 
-        $recipient = new NovuSubscriberRecipient($userId);
-
         $this->notifier->send($notification, $recipient);
     }
 }

novu/bridge/app/novu/workflows/expose/download-link.ts

@@ -0,0 +1,24 @@
+import {workflow} from "@novu/framework";
+import {z} from "zod";
+
+export const exposeDownloadLink = workflow(
+    "expose-download-link",
+    async ({step, payload}) => {
+        await step.email("Email", async () => {
+            return {
+                subject: `Your download link is ready!`,
+                body: `You can download your file from the following link: ${payload.downloadUrl}`,
+            };
+        });
+    },
+    {
+        payloadSchema: z.object({
+            downloadUrl: z
+                .string()
+                .describe("The URL link to download the file"),
+            locale: z
+                .string()
+                .describe("The user's locale"),
+        })
+    },
+);

novu/bridge/app/novu/workflows/index.ts

@@ -1,2 +1,3 @@
 export * from "./welcome-onboarding-email";
 export * from "./uploader/commit-acknowledged";
+export * from "./expose/download-link";