Merge pull request #832 from MasoniteFramework/fix/802

Fixed missing queable notification feature

src/masonite/notification/Notifiable.py

@@ -6,24 +6,28 @@
 
 
 class Notifiable:
-    """Notifiable mixin allowing to send notification to a model. It's often used with the
+    """Notifiable mixin allowing to send
+    notification to a model. It's often used with the
     User model.
 
     Usage:
         user.notify(WelcomeNotification())
     """
-
     def notify(self, notification, drivers=[], dry=False, fail_silently=False):
         """Send the given notification."""
         from wsgi import application
 
+        if hasattr(notification, "send"):
+            notification.send(notification, drivers, dry, fail_silently)
+
         return application.make("notification").send(
             self, notification, drivers, dry, fail_silently
         )
 
     def route_notification_for(self, driver):
-        """Get the notification routing information for the given driver. If method has not been
-        defined on the model: for mail driver try to use 'email' field of model."""
+        """Get the notification routing information for the given driver.
+        If method has not been defined on the model:
+        for mail driver try to use 'email' field of model."""
         # check if routing has been specified on the model
         method_name = "route_notification_for_{0}".format(driver)
 
@@ -39,7 +43,8 @@ def route_notification_for(self, driver):
                 return self.email
             else:
                 raise NotificationException(
-                    "Notifiable model does not implement {}".format(method_name)
+                    "Notifiable model "
+                    "does not implement {}".format(method_name)
                 )
 
     @has_many("id", "notifiable_id")

src/masonite/queues/Queueable.py

@@ -7,6 +7,9 @@ class Queueable:
     run_again_on_fail = True
     run_times = 3
 
+    def queue(self):
+        return "default"
+
     def handle(self):
         pass
 
@@ -15,3 +18,8 @@ def failed(self, obj, e):
 
     def __repr__(self):
         return self.__class__.__name__
+
+    def send(self, notification, driver="", dry=False, fail_silently=False):
+        from ..facades.Queue import Queue
+        Queue.push(notification, queue=self.queue())
+        print('Sending to queue', notification)

tests/integrations/notifications/OneTimePassword.py

@@ -1,9 +1,10 @@
 from src.masonite.notification import Notification, Textable
 from src.masonite.mail import Mailable
 from src.masonite.mail import Mailable
+from src.masonite.queues.Queueable import Queueable
 
 
-class OneTimePassword(Notification, Mailable, Textable):
+class OneTimePassword(Notification, Mailable, Textable, Queueable):
     def to_mail(self, notifiable):
         return (
             self.to(notifiable.email)
@@ -16,4 +17,4 @@ def to_vonage(self, notifiable):
         return self.text_message("Welcome !").to("6314870798").from_("33123456789")
 
     def via(self, notifiable):
-        return ["vonage"]
+        return ["mail"]