From f914d5704226a02d11ea20cf5e68ce5f33413896 Mon Sep 17 00:00:00 2001
From: Nafies Luthfi <nafiesl@gmail.com>
Date: Sat, 31 Oct 2020 11:31:13 +0800
Subject: [PATCH] Add long private job notifer

---
 app/Events/LongRunPrivateJobDone.php  | 39 +++++++++++++++++++++++++++++++++++
 app/Jobs/LongRunPrivateJob.php        | 35 +++++++++++++++++++++++++++++++
 config/app.php                        |  2 +-
 resources/views/home.blade.php        |  3 ++-
 resources/views/layouts/app.blade.php |  9 ++++++++
 routes/channels.php                   |  4 ----
 routes/web.php                        |  8 +++++++
 7 files changed, 94 insertions(+), 6 deletions(-)
 create mode 100644 app/Events/LongRunPrivateJobDone.php
 create mode 100644 app/Jobs/LongRunPrivateJob.php

diff --git a/app/Events/LongRunPrivateJobDone.php b/app/Events/LongRunPrivateJobDone.php
new file mode 100644
index 0000000..f52c355
--- /dev/null
+++ b/app/Events/LongRunPrivateJobDone.php
@@ -0,0 +1,39 @@
+<?php
+
+namespace App\Events;
+
+use Illuminate\Broadcasting\Channel;
+use Illuminate\Broadcasting\InteractsWithSockets;
+use Illuminate\Broadcasting\PrivateChannel;
+use Illuminate\Contracts\Broadcasting\ShouldBroadcast;
+use Illuminate\Foundation\Events\Dispatchable;
+use Illuminate\Queue\SerializesModels;
+
+class LongRunPrivateJobDone implements ShouldBroadcast
+{
+    use Dispatchable, InteractsWithSockets, SerializesModels;
+
+    public $id;
+    public $message;
+
+    /**
+     * Create a new event instance.
+     *
+     * @return void
+     */
+    public function __construct($id, $message)
+    {
+        $this->id = $id;
+        $this->message = $message;
+    }
+
+    /**
+     * Get the channels the event should broadcast on.
+     *
+     * @return \Illuminate\Broadcasting\Channel|array
+     */
+    public function broadcastOn()
+    {
+        return new PrivateChannel('App.User.'.$this->id);
+    }
+}
diff --git a/app/Jobs/LongRunPrivateJob.php b/app/Jobs/LongRunPrivateJob.php
new file mode 100644
index 0000000..6517ad7
--- /dev/null
+++ b/app/Jobs/LongRunPrivateJob.php
@@ -0,0 +1,35 @@
+<?php
+
+namespace App\Jobs;
+
+use App\Events\LongRunPrivateJobDone;
+use Illuminate\Bus\Queueable;
+use Illuminate\Contracts\Queue\ShouldQueue;
+use Illuminate\Foundation\Bus\Dispatchable;
+use Illuminate\Queue\InteractsWithQueue;
+use Illuminate\Queue\SerializesModels;
+
+class LongRunPrivateJob implements ShouldQueue
+{
+    use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;
+
+    public $id;
+
+    public function __construct($id)
+    {
+        $this->id = $id;
+    }
+
+    public function handle()
+    {
+        $seconds = 5;
+        sleep($seconds);
+
+        $link = '<a href="'.route('home').'">here</a>';
+        event(new LongRunPrivateJobDone(
+            $this->id,
+            'Long run private job (for '.$this->id.') done after '.$seconds.' seconds. Please check '.$link.'.')
+        );
+        info('Long run private job (for '.$this->id.') done after '.$seconds.' seconds. Please check '.$link.'.');
+    }
+}
diff --git a/config/app.php b/config/app.php
index 8409e00..33aa202 100644
--- a/config/app.php
+++ b/config/app.php
@@ -171,7 +171,7 @@ return [
          */
         App\Providers\AppServiceProvider::class,
         App\Providers\AuthServiceProvider::class,
-        // App\Providers\BroadcastServiceProvider::class,
+        App\Providers\BroadcastServiceProvider::class,
         App\Providers\EventServiceProvider::class,
         App\Providers\RouteServiceProvider::class,
 
diff --git a/resources/views/home.blade.php b/resources/views/home.blade.php
index c5b0647..1045e71 100644
--- a/resources/views/home.blade.php
+++ b/resources/views/home.blade.php
@@ -5,7 +5,7 @@
     <div class="row justify-content-center">
         <div class="col-md-8">
             <div class="card">
-                <div class="card-header">{{ __('Dashboard') }}</div>
+                <div class="card-header">{{ __('Dashboard') }} auth user: {{ auth()->id() }}</div>
 
                 <div class="card-body">
                     @if (session('status'))
@@ -17,6 +17,7 @@
                     {{ __('You are logged in!') }}
                     <hr>
                     <a href="{{ route('long-run-job') }}" class="btn btn-success">Run a long job</a>
+                    <a href="{{ route('private-long-run-job') }}" class="btn btn-success">Run a long private job</a>
                 </div>
             </div>
         </div>
diff --git a/resources/views/layouts/app.blade.php b/resources/views/layouts/app.blade.php
index 6a6a401..dadd082 100644
--- a/resources/views/layouts/app.blade.php
+++ b/resources/views/layouts/app.blade.php
@@ -93,6 +93,15 @@
                     timeout: false
                 });
             });
+        Echo.private('App.User.{{ auth()->id() }}')
+            .listen('LongRunPrivateJobDone', (e) => {
+                noty({
+                    type: 'success',
+                    layout: 'bottomRight',
+                    text: e.message,
+                    timeout: false
+                });
+            });
     </script>
     @if (Session::has('flash_notification.message'))
     <script>
diff --git a/routes/channels.php b/routes/channels.php
index 3d07c13..963b0d2 100644
--- a/routes/channels.php
+++ b/routes/channels.php
@@ -16,7 +16,3 @@ use Illuminate\Support\Facades\Broadcast;
 Broadcast::channel('App.User.{id}', function ($user, $id) {
     return (int) $user->id === (int) $id;
 });
-
-Broadcast::channel('queue-notifier', function ($user, $id) {
-    return true;
-});
diff --git a/routes/web.php b/routes/web.php
index 404f3b8..4f1fb5c 100644
--- a/routes/web.php
+++ b/routes/web.php
@@ -1,6 +1,7 @@
 <?php
 
 use App\Jobs\LongRunJob;
+use App\Jobs\LongRunPrivateJob;
 use Illuminate\Support\Facades\Route;
 
 /*
@@ -29,6 +30,13 @@ Route::get('/long-run-job', function () {
     return redirect()->home();
 })->name('long-run-job');
 
+Route::get('/private-long-run-job', function () {
+    dispatch(new LongRunPrivateJob(auth()->id()));
+
+    flash('Please wait, your request is processing...');
+    return redirect()->home();
+})->name('private-long-run-job');
+
 Auth::routes();
 
 Route::get('/home', 'HomeController@index')->name('home');