Here is my server.js file:
var app = require('express')(); var http = require('http').Server(app); var io = require('socket.io')(http); var Redis = require('ioredis'); var redis = new Redis(); http.listen(3000, function(){ console.log('Listening on Port 3000'); }); redis.psubscribe('*', function(err, count) { console.log(err, count); }); redis.on('pmessage', function(subscribed, channel, message) { message = JSON.parse(message); io.emit(message.event, channel, message.data); });
And a simple event:
class FieldWasUpdated implements ShouldBroadcast { use InteractsWithSockets, SerializesModels; public $instance; public $key; public $value; public function __construct($instance, $key, $value) { $this->instance = $instance; $this->key = $key; $this->value = $value; } public function broadcastOn() { return new PrivateChannel("model." . $this->instance->getModelType() . "." . $this->instance->id); } }
The client connects to socket.io:
Echo = new Echo({ broadcaster: 'socket.io', host: window.location.hostname + ':3000' });
And then it listens for events (inside the Blade template):
var channel = "model.{{ $instance->getModelType() }}.{{ $instance->id }}"; Echo.private(channel) .listen("FieldWasUpdated", function(e) { window.VueBus.$emit("updated", channel, e.key, e.value); }) .listen("FieldBecameDisabled", function(e) { window.VueBus.$emit("disabled", channel, e.key); });
The problem is that authentication is not processed, any user can subscribe to these channels.
Broadcast::channel("model.announcement.*", function($user, $id) { return false;
Here is an example from the Chrome Developer Console (WebSocket):
[ "App\\Events\\FieldWasUpdated", "private-model.announcement.2", { "instance": { "type":"ANN_TYPE_MISSED_CALL", "status":"ANN_STATUS_CANCELLED", "name":"1233421", "phone":"+7(222)222-3322", "email":" sdgsg@mail.com ", "message":"sdgdsgsdgdfdg", "requirement":null, "web_type":"ANN_WEB_TYPE_UNKNOWN", "url":null, "responsible_id":19, "recommender_id":18 }, "key":"message", "value":"sdgdsgsdgdfdg" } ]
There is also no URL /broadcast/auth , but the BroadcastServiceProvider has a call to Broadcast::routes(); , and when the browser loads, calls to /broadcast/auth not made.