Vue, Laravel echo + socket.io + lumen(event, listener)

$ yarn add socket.io-client laravel-echo

  "dependencies": {
    "axios": "^0.18.0",
    "bootstrap": "^4.0.0-beta.2",
    "bootstrap-vue": "latest",
    "cropperjs": "^1.4.3",
    "jquery": "^3.3.1",
    "laravel-echo": "^1.4.0",
    "moment": "^2.22.2",
    "popper.js": "^1.12.9",
    "pusher-js": "^4.3.0",
    "socket.io-client": "^2.2.0",
    "style-loader": "^0.21.0",
    "sweetalert2": "^7.28.4",
    "vue": "^2.5.17",
    "vue-axios": "^2.1.4",
    "vue-loading-spinner": "^1.0.11",
    "vue-pdf": "^3.3.1",
    "vue-router": "^3.0.1",
    "vue-upload-component": "^2.8.14",
    "vuex": "^3.0.1"
  },

import Echo from 'laravel-echo'
window.io = require('socket.io-client')
 
window.Echo = new Echo({
  broadcaster: 'socket.io',
  host: '<a href="http://localhost:6001',
">http://localhost:6001',
</a>  auth: {headers: {Authorization: 'Bearer ' + localStorage.getItem('token')}}
})

  methods: {
    getEventsNoFromSocket () {
      let currentUser = JSON.parse(localStorage.getItem('user'))
      window.Echo.channel('parseNoti.' + currentUser.id)
      .listen('.App\\Events\\ParseFilesEvent', (e) => {
        this.messages.push(e)
      })
    },
  mounted () {
    this.getEventsNoFromSocket()
   }
 }

$ npm install -g laravel-echo-server
$ laravel-echo-server init //generate a laravel-echo-server.json file

{
	"authHost": "<a href="http://localhost:8000",
">http://localhost:8000",
</a>	"authEndpoint": "/broadcasting/auth",
	"clients": [],
	"database": "redis",
	"databaseConfig": {
		"redis": {},
		"sqlite": {
			"databasePath": "/database/laravel-echo-server.sqlite"
		}
	},
	"devMode": true,
	"host": null,
	"port": "6001",
	"protocol": "http",
	"socketio": {},
	"sslCertPath": "",
	"sslKeyPath": "",
	"sslCertChainPath": "",
	"sslPassphrase": "",
	"subscribers": {
		"http": true,
		"redis": true
	},
	"apiOriginAllow": {
		"allowCors": true,
		"allowOrigin": "*",
		"allowMethods": "",
		"allowHeaders": ""
	}
}

$ laravel-echo-server start

sudo apt-get install supervisor // install supervisor

[program:echo-server]
process_name=%(program_name)s_%(process_num)02d
command=/usr/bin/laravel-echo-server start --dir=/var/www/html/echo
autostart=true
autorestart=true
user=root
redirect_stderr=true
stdout_logfile=/home/echo-server.log

sudo supervisorctl reread
sudo supervisorctl update
sudo supervisorctl start echo-server:*

// event. channel, listener
namespace App\Events;
 
use Illuminate\Contracts\Broadcasting\ShouldBroadcast;
use Illuminate\Broadcasting\Channel;
use Illuminate\Broadcasting\PrivateChannel;
use Illuminate\Broadcasting\PresenceChannel;
use Illuminate\Broadcasting\InteractsWithSockets;
use Illuminate\Support\Carbon;
 
class ParseFilesEvent extends Event implements ShouldBroadcast
{
 
    public $message;
 
    public $user_id;
 
    public $noti_time;
 
    public $noti_type;
 
    /**
     * The name of the queue on which to place the event.
     *
     * @var string
     */
    // public $broadcastQueue = 'uploadResultNotification';
 
    /**
     * Create a new event instance.
     *
     * @return void
     */
    public function __construct($user_id, $message, $noti_type = 1 )
    {
        //
       $this->user_id = $user_id;
       $this->message = $message;
       $this->noti_type = $noti_type;
       $this->noti_time = Carbon::now()->format('Y-m-d H:i:s');
    }
 
    /**
     * Get the channels the event should broadcast on.
     *
     * @return array
     */
    public function broadcastOn()
    {
        return new Channel('parseNoti.' . $this->user_id);
    }
 
}
 
//Listener 
namespace App\Listeners;
 
use App\Events\ParseFilesEvent;
use Illuminate\Queue\InteractsWithQueue;
use Illuminate\Contracts\Queue\ShouldQueue;
use Log;
use Illuminate\Support\Facades\Notification;
use App\Notifications\ParseFilesNoti;
use App\User;
 
class ParseFilesListener
{
    /**
     * Create the event listener.
     *
     * @return void
     */
    public function __construct()
    {
        //
    }
 
    /**
     * Handle the event.
     *
     * @param  ExampleEvent  $event
     * @return void
     */
    public function handle(ParseFilesEvent $event)
    {
        //
        //Log::info('Event is happing: ' . $event->message);
        Notification::send(User::find($event->user_id), new ParseFilesNoti($event->message));
    }
}

// fire an event 
Event::dispatch(new ParseFilesEvent($this->current_user_id , $message ));

# /etc/supervisor/conf.d/laravel-worker.conf
[program:laravel-worker]
process_name=%(program_name)s_%(process_num)02d
#command=php /var/www/html/cats/cats-backend/artisan queue:work --timeout=30 --sleep=20 --tries=1
command=php /var/www/html/hydcats-backend/artisan queue:work --timeout=30 --sleep=20 --tries=1
autostart=true
autorestart=true
user=root
numprocs=8
redirect_stderr=true
stopasgroup=true
stopsignal=QUIT
stdout_logfile=/home/worker.log