Basic app message with auto broadcasting working.

.env.testing

@@ -9,7 +9,7 @@ LOG_CHANNEL=stack
 DB_CONNECTION=sqlite
 DB_DATABASE=:memory:
 
-BROADCAST_DRIVER=redis
+BROADCAST_DRIVER=log
 QUEUE_DRIVER=redis
 QUEUE_CONNECTION=sync
 SESSION_DRIVER=file

app/Chat.php

@@ -2,6 +2,7 @@
 
 namespace App;
 
+use App\Events\MessageSent;
 use Illuminate\Database\Eloquent\Model;
 
 class Chat extends Model
@@ -33,4 +34,10 @@ public function addUser($user){
         $this->users()->syncWithoutDetaching(User::find($user));
     }
 
+    public function sendMessage($body, $user_id){
+        $message = Message::create(['body'=>$body, 'chat_id'=>$this->id, 'user_id'=>$user_id]);
+        broadcast( new MessageSent($message) );
+        return $message;
+    }
+
 }

app/Events/MessageSent.php

@@ -43,4 +43,24 @@ public function broadcastOn()
     {
         return new PrivateChannel('chat.'.$this->message->chat->id);
     }
+
+    /**
+     * Get the data to broadcast.
+     *
+     * @return array
+     */
+    public function broadcastWith()
+    {
+        return [$this->message];
+    }
+
+    /**
+     * The event's broadcast name.
+     *
+     * @return string
+     */
+    public function broadcastAs()
+    {
+        return 'message.sent';
+    }
 }

app/Http/Controllers/MessagesController.php

@@ -10,27 +10,36 @@
 
 class MessagesController extends Controller
 {
-    protected function validateRequest()
+    protected $rules = [
+        'body' => 'required',
+    ];
+
+    protected function validateRequest($key)
     {
-        return request()->validate([
-            'body' => 'required',
-        ]);
+        if ($key)
+        {
+            return request()->validate($this->rules)[$key];
+        }
+        return request()->validate($this->rules);
     }
 
     public function store(Chat $chat)
     {
         $user = Auth::user();
 
-        if($chat->users->contains($user))
+        if ($chat->users->contains($user))
         {
-            $message = Message::create(array_merge($this->validateRequest(), ['user_id'=> $user->id, 'chat_id'=>$chat->id]));
-            event( new MessageSent($message) );
-
+            $chat->sendMessage($this->validateRequest('body'), $user->id);
             return $this->getMessages($chat);
-
         }
     }
 
+    /**
+     * Return messages with user object
+     *
+     * @param Chat $chat
+     * @return string
+     */
     public function getMessages(Chat $chat){
         return $chat->messages()->with('user')
             ->get()

config/app.php

@@ -174,7 +174,6 @@
         App\Providers\BroadcastServiceProvider::class,
         App\Providers\EventServiceProvider::class,
         App\Providers\RouteServiceProvider::class,
-
     ],
 
     /*

database/migrations/2019_12_10_221452_create_failed_jobs_table.php

@@ -0,0 +1,35 @@
+<?php
+
+use Illuminate\Database\Migrations\Migration;
+use Illuminate\Database\Schema\Blueprint;
+use Illuminate\Support\Facades\Schema;
+
+class CreateFailedJobsTable extends Migration
+{
+    /**
+     * Run the migrations.
+     *
+     * @return void
+     */
+    public function up()
+    {
+        Schema::create('failed_jobs', function (Blueprint $table) {
+            $table->bigIncrements('id');
+            $table->text('connection');
+            $table->text('queue');
+            $table->longText('payload');
+            $table->longText('exception');
+            $table->timestamp('failed_at')->useCurrent();
+        });
+    }
+
+    /**
+     * Reverse the migrations.
+     *
+     * @return void
+     */
+    public function down()
+    {
+        Schema::dropIfExists('failed_jobs');
+    }
+}

laravel-echo-server.lock

@@ -1,3 +1,3 @@
 {
-	"process": 7237
+	"process": 2910
 }

public/js/app.js

@@ -31236,7 +31236,7 @@ var render = function() {
             _c("strong", { staticClass: "primary-font" }, [
               _vm._v(
                 "\n                    " +
-                  _vm._s(message.user) +
+                  _vm._s(message.user.name) +
                   "\n                "
               )
             ])
@@ -43812,9 +43812,6 @@ __webpack_require__.r(__webpack_exports__);
 __webpack_require__(/*! ./bootstrap */ "./resources/js/bootstrap.js");
 
 window.Vue = __webpack_require__(/*! vue */ "./node_modules/vue/dist/vue.common.js");
-Echo["private"]("chat.".concat(window.location.pathname.split("/").pop())).listen('MessageSent', function (e) {
-  console.log('Info ' + e.update);
-});
 
 
 
@@ -43827,20 +43824,26 @@ var app = new Vue({
     messages: []
   },
   created: function created() {
+    var _this = this;
+
     this.fetchMessages();
+    Echo["private"]("chat.".concat(window.location.pathname.split("/").pop())).listen('.message.sent', function () {
+      _this.fetchMessages();
+    });
   },
   methods: {
     fetchMessages: function fetchMessages() {
-      var _this = this;
+      var _this2 = this;
 
       axios.get(window.location.pathname + '/messages').then(function (response) {
-        _this.messages = response.data;
+        _this2.messages = response.data;
       });
     },
     addMessage: function addMessage(message) {
-      this.messages.push(message);
+      var _this3 = this;
+
       axios.post(window.location.pathname + '/messages', message).then(function (response) {
-        console.log(response.data);
+        _this3.fetchMessages();
       });
     },
     createChat: function createChat() {}

public/mix-manifest.json

@@ -1,4 +1,4 @@
 {
-    "/js/app.js": "/js/app.js?id=7eec61c90ca0f66bdf69",
+    "/js/app.js": "/js/app.js?id=771cdedd70192729788a",
     "/css/app.css": "/css/app.css?id=2a4461fc35df4e8d0a06"
 }

resources/js/Components/ChatMessages.vue

@@ -4,7 +4,7 @@
             <div class="chat-body clearfix">
                 <div class="header">
                     <strong class="primary-font">
-                        {{ message.user }}
+                        {{ message.user.name }}
                     </strong>
                 </div>
                 <p>

resources/js/app.js

@@ -2,11 +2,6 @@ require('./bootstrap');
 
 window.Vue = require("vue");
 
-Echo.private(`chat.${window.location.pathname.split("/").pop()}`)
-    .listen('MessageSent', (e) => {
-        console.log('Info ' + e.update);
-    });
-
 import ChatMessages from "./Components/ChatMessages";
 import ChatForm from "./Components/SendMessage";
 import CreateChat from "./Components/CreateChat";
@@ -15,16 +10,21 @@ Vue.component('chat-messages', ChatMessages);
 Vue.component('chat-form', ChatForm);
 Vue.component('create-chat', CreateChat);
 
+
 const app = new Vue({
     el: '#app',
 
     data: {
         messages: []
-
     },
 
     created() {
         this.fetchMessages();
+
+        Echo.private(`chat.${window.location.pathname.split("/").pop()}`)
+            .listen('.message.sent', () => {
+                this.fetchMessages();
+            });
     },
 
     methods: {
@@ -35,10 +35,8 @@ const app = new Vue({
         },
 
         addMessage(message) {
-            this.messages.push(message);
-
             axios.post(window.location.pathname+'/messages', message).then(response => {
-                console.log(response.data);
+                this.fetchMessages();
             });
         },
 
@@ -47,3 +45,6 @@ const app = new Vue({
         }
     }
 });
+
+
+

routes/channels.php

@@ -11,11 +11,10 @@
 |
 */
 
-Broadcast::channel('App.User.{id}', function ($user, $id) {
-    return (int) $user->id === (int) $id;
-});
+use App\Chat;
+use Illuminate\Support\Facades\Auth;
 
-Broadcast::channel('chat.{chatId}', function ($chatId) {
-    return Chat::get($chatId)->contains(Auth::user);
+Broadcast::channel('chat.{chat}', function ($user, Chat $chat) {
+    return $chat->users->contains(Auth::user());
 });
 

tests/Feature/ChatManagingTests.php

@@ -41,6 +41,7 @@ public function only_a_logged_in_user_can_create_chats(){
      * @test
      */
     public function a_user_can_send_another_user_a_message(){
+        $this->withoutExceptionHandling();
         $this->actingAs($user = factory('App\User')->create())
             ->post('/chats', ['title'=>'Chat da empresa', 'users'=>[$user2 = factory('App\User')->create()]]);
 

tests/Unit/MessageTest.php

@@ -2,13 +2,17 @@
 
 namespace Tests\Unit;
 
+use App\Chat;
 use App\Events\MessageSent;
 use Illuminate\Foundation\Testing\RefreshDatabase;
 use Illuminate\Foundation\Testing\WithFaker;
+use Illuminate\Foundation\Testing\WithoutEvents;
+use Illuminate\Support\Facades\Event;
 use Tests\TestCase;
 
 class MessageTest extends TestCase
 {
+    use RefreshDatabase;
     /**
      * A message must belongs to an user
      *
@@ -27,10 +31,15 @@ public function it_belongs_to_an_user()
      */
     public function event_is_broadcasted_when_message_is_sent()
     {
-        broadcast(new MessageSent($message));
-        $this->assertEventIsBroadcasted(
-            MessageSent::class,
-            'private-notification.' . $notification->id
-        );
+        Event::fake();
+
+        /** @var Chat $chat */
+        $chat = factory('App\Chat')->create();
+
+        $chat->addUser($user = factory('App\User')->create());
+        $this->actingAs($user);
+        $chat->sendMessage('hello', $user->id);
+
+        Event::assertDispatched(MessageSent::class);
     }
 }