✨ mis en place des queues

Author: mckenziearts

app/Console/Commands/SendWelcomeMailToUsers.php

@@ -0,0 +1,21 @@
+<?php
+
+namespace App\Console\Commands;
+
+use App\Models\User;
+use Illuminate\Console\Command;
+use Illuminate\Support\Facades\Mail;
+
+class SendWelcomeMailToUsers extends Command
+{
+    protected $signature = 'lcm:send-welcome-mails';
+
+    protected $description = 'Send mails to new registered users.';
+
+    public function handle(): void
+    {
+        foreach (User::all() as $user) {
+            Mail::to($user)->queue(new \App\Mail\Welcome($user));
+        }
+    }
+}

app/Console/Kernel.php

@@ -26,7 +26,7 @@ protected function schedule(Schedule $schedule)
     {
         // $schedule->command('media-library:delete-old-temporary-uploads')->daily();
         $schedule->command('lcm:delete-old-unverified-users')->daily();
-        $schedule->command('lcm:post-article-to-twitter')->twiceDaily(12, 16);
+        $schedule->command('lcm:post-article-to-twitter')->everyFourHours();
         $schedule->command('lcm:post-article-to-telegram')->everyFourHours();
         $schedule->command('lcm:send-unverified-mails')->weeklyOn(1, '8:00');
         $schedule->command('sitemap:generate')->daily();

app/Listeners/SendNewReplyNotification.php

@@ -5,9 +5,13 @@
 use App\Events\ReplyWasCreated;
 use App\Models\User;
 use App\Notifications\NewReplyNotification;
+use Illuminate\Contracts\Queue\ShouldQueue;
+use Illuminate\Queue\InteractsWithQueue;
 
-class SendNewReplyNotification
+class SendNewReplyNotification implements ShouldQueue
 {
+    use InteractsWithQueue;
+
     public function handle(ReplyWasCreated $event)
     {
         /** @var \App\Models\Thread $thread */

app/Listeners/SendWelcomeMailNotification.php

@@ -0,0 +1,28 @@
+<?php
+
+namespace App\Listeners;
+
+use App\Models\User;
+use Illuminate\Auth\Events\Registered;
+use Illuminate\Contracts\Queue\ShouldQueue;
+use Illuminate\Queue\InteractsWithQueue;
+use Illuminate\Support\Facades\Mail;
+
+class SendWelcomeMailNotification implements ShouldQueue
+{
+    use InteractsWithQueue;
+
+    /**
+     * Handle the event.
+     *
+     * @param  Registered  $event
+     * @return void
+     */
+    public function handle(Registered $event)
+    {
+        /** @var User $user */
+        $user = $event->user;
+
+        Mail::to($user)->queue(new \App\Mail\Welcome($user));
+    }
+}

app/Mail/NewReplyEmail.php

@@ -4,10 +4,14 @@
 
 use App\Models\Reply;
 use App\Models\Subscribe;
+use Illuminate\Bus\Queueable;
+use Illuminate\Contracts\Queue\ShouldQueue;
 use Illuminate\Mail\Mailable;
 
-class NewReplyEmail extends Mailable
+class NewReplyEmail extends Mailable implements ShouldQueue
 {
+    use Queueable;
+
     /**
      * Create a new message instance.
      *

app/Mail/SendMailToUnVerifiedUsers.php

@@ -4,10 +4,11 @@
 
 use App\Models\User;
 use Illuminate\Bus\Queueable;
+use Illuminate\Contracts\Queue\ShouldQueue;
 use Illuminate\Mail\Mailable;
 use Illuminate\Queue\SerializesModels;
 
-class SendMailToUnVerifiedUsers extends Mailable
+class SendMailToUnVerifiedUsers extends Mailable implements ShouldQueue
 {
     use Queueable, SerializesModels;
 

app/Mail/Welcome.php

@@ -8,18 +8,12 @@
 use Illuminate\Mail\Mailable;
 use Illuminate\Queue\SerializesModels;
 
-class Welcome extends Mailable
+class Welcome extends Mailable implements ShouldQueue
 {
     use Queueable, SerializesModels;
 
-    /**
-     * Create a new message instance.
-     *
-     * @return void
-     */
     public function __construct(public User $user)
     {
-        //
     }
 
     /**
@@ -30,7 +24,7 @@ public function __construct(public User $user)
     public function build()
     {
         return $this->from('arthur@laravel.cm', 'Arthur Monney')
-            ->subject(__('Bienvenue sur Laravel Cameroun'))
+            ->subject(__('Bienvenue sur Laravel Cameroun ✨'))
             ->markdown('emails.welcome');
     }
 }

app/Notifications/NewCommentNotification.php

@@ -6,10 +6,11 @@
 use App\Models\Reply;
 use App\Models\Subscribe;
 use Illuminate\Bus\Queueable;
+use Illuminate\Contracts\Queue\ShouldQueue;
 use Illuminate\Notifications\Messages\MailMessage;
 use Illuminate\Notifications\Notification;
 
-class NewCommentNotification extends Notification
+class NewCommentNotification extends Notification implements ShouldQueue
 {
     use Queueable;
 

app/Notifications/NewReplyNotification.php

@@ -6,9 +6,10 @@
 use App\Models\Reply;
 use App\Models\Subscribe;
 use Illuminate\Bus\Queueable;
+use Illuminate\Contracts\Queue\ShouldQueue;
 use Illuminate\Notifications\Notification;
 
-class NewReplyNotification extends Notification
+class NewReplyNotification extends Notification implements ShouldQueue
 {
     use Queueable;
 

app/Notifications/SendApprovedArticle.php

@@ -4,10 +4,11 @@
 
 use App\Models\Article;
 use Illuminate\Bus\Queueable;
+use Illuminate\Contracts\Queue\ShouldQueue;
 use Illuminate\Notifications\Messages\MailMessage;
 use Illuminate\Notifications\Notification;
 
-class SendApprovedArticle extends Notification
+class SendApprovedArticle extends Notification implements ShouldQueue
 {
     use Queueable;
 

app/Notifications/YouWereMentioned.php

@@ -3,11 +3,15 @@
 namespace App\Notifications;
 
 use App\Models\Reply;
+use Illuminate\Bus\Queueable;
+use Illuminate\Contracts\Queue\ShouldQueue;
 use Illuminate\Notifications\Messages\MailMessage;
 use Illuminate\Notifications\Notification;
 
-class YouWereMentioned extends Notification
+class YouWereMentioned extends Notification implements ShouldQueue
 {
+    use Queueable;
+
     public function __construct(public Reply $reply)
     {
     }

app/Providers/EventServiceProvider.php

@@ -12,6 +12,7 @@
 use App\Listeners\SendNewCommentNotification;
 use App\Listeners\SendNewReplyNotification;
 use App\Listeners\SendNewThreadNotification;
+use App\Listeners\SendWelcomeMailNotification;
 use Illuminate\Auth\Events\Registered;
 use Illuminate\Auth\Listeners\SendEmailVerificationNotification;
 use Illuminate\Foundation\Support\Providers\EventServiceProvider as ServiceProvider;
@@ -26,6 +27,7 @@ class EventServiceProvider extends ServiceProvider
     protected $listen = [
         Registered::class => [
             SendEmailVerificationNotification::class,
+            SendWelcomeMailNotification::class,
         ],
         ReplyWasCreated::class => [
             SendNewReplyNotification::class,

database/migrations/2022_07_29_010135_create_jobs_table.php

@@ -0,0 +1,36 @@
+<?php
+
+use Illuminate\Database\Migrations\Migration;
+use Illuminate\Database\Schema\Blueprint;
+use Illuminate\Support\Facades\Schema;
+
+return new class extends Migration
+{
+    /**
+     * Run the migrations.
+     *
+     * @return void
+     */
+    public function up()
+    {
+        Schema::create('jobs', function (Blueprint $table) {
+            $table->bigIncrements('id');
+            $table->string('queue')->index();
+            $table->longText('payload');
+            $table->unsignedTinyInteger('attempts');
+            $table->unsignedInteger('reserved_at')->nullable();
+            $table->unsignedInteger('available_at');
+            $table->unsignedInteger('created_at');
+        });
+    }
+
+    /**
+     * Reverse the migrations.
+     *
+     * @return void
+     */
+    public function down()
+    {
+        Schema::dropIfExists('jobs');
+    }
+};