Allow custom action broadcasts and add view method (alias for partial…

…) to pending broadcasts

src/Broadcasting/PendingBroadcast.php

@@ -134,7 +134,12 @@ public function toOthers(bool $toOthers = true): self
 
     public function partial(?string $partial, array $data = []): self
     {
-        return $this->rendering(new Rendering($partial, $data));
+        return $this->view($partial, $data);
+    }
+
+    public function view(?string $view, array $data = []): self
+    {
+        return $this->rendering(new Rendering($view, $data));
     }
 
     public function content($content)

src/Models/Broadcasts.php

@@ -92,7 +92,7 @@ public function broadcastInsert(): PendingBroadcast
         return $this->broadcastActionTo(
             $this->broadcastDefaultStreamables(inserting: true),
             $action,
-            Rendering::forModel($this),
+            rendering: Rendering::forModel($this),
         );
     }
 
@@ -126,58 +126,60 @@ public function broadcastRefresh(): PendingBroadcast
 
     public function broadcastAppendTo($streamable): PendingBroadcast
     {
-        return $this->broadcastActionTo($streamable, 'append', Rendering::forModel($this));
+        return $this->broadcastActionTo($streamable, 'append', rendering: Rendering::forModel($this));
     }
 
     public function broadcastPrependTo($streamable): PendingBroadcast
     {
-        return $this->broadcastActionTo($streamable, 'prepend', Rendering::forModel($this));
+        return $this->broadcastActionTo($streamable, 'prepend', rendering: Rendering::forModel($this));
     }
 
     public function broadcastBeforeTo($streamable, string $target): PendingBroadcast
     {
-        return $this->broadcastActionTo($streamable, 'before', Rendering::forModel($this), $target);
+        return $this->broadcastActionTo($streamable, 'before', $target, rendering: Rendering::forModel($this));
     }
 
     public function broadcastAfterTo($streamable, string $target): PendingBroadcast
     {
-        return $this->broadcastActionTo($streamable, 'after', Rendering::forModel($this), $target);
+        return $this->broadcastActionTo($streamable, 'after', $target, rendering: Rendering::forModel($this));
     }
 
     public function broadcastReplaceTo($streamable): PendingBroadcast
     {
-        return $this->broadcastActionTo($streamable, 'replace', Rendering::forModel($this));
+        return $this->broadcastActionTo($streamable, 'replace', rendering: Rendering::forModel($this));
     }
 
     public function broadcastUpdateTo($streamable): PendingBroadcast
     {
-        return $this->broadcastActionTo($streamable, 'update', Rendering::forModel($this));
+        return $this->broadcastActionTo($streamable, 'update', rendering: Rendering::forModel($this));
     }
 
     public function broadcastRemoveTo($streamable): PendingBroadcast
     {
-        return $this->broadcastActionTo($streamable, 'remove', Rendering::empty());
+        return $this->broadcastActionTo($streamable, 'remove', rendering: Rendering::empty());
     }
 
     public function broadcastRefreshTo($streamable): PendingBroadcast
     {
-        return TurboStream::broadcastRefresh($this->toChannels(Collection::wrap($streamable)))
-            ->cancelIf(fn () => static::isIgnoringTurboStreamBroadcasts());
+        return TurboStream::broadcastRefresh(
+            $this->toChannels(Collection::wrap($streamable))
+        )->cancelIf(fn () => static::isIgnoringTurboStreamBroadcasts());
     }
 
     public function asTurboStreamBroadcastingChannel()
     {
         return $this->toChannels(Collection::wrap($this->broadcastDefaultStreamables($this->wasRecentlyCreated)));
     }
 
-    protected function broadcastActionTo($streamables, string $action, Rendering $rendering, ?string $target = null): PendingBroadcast
+    public function broadcastActionTo($streamables, string $action, ?string $target = null, array $attributes = [], ?Rendering $rendering = null): PendingBroadcast
     {
         return TurboStream::broadcastAction(
             action: $action,
             target: $target ?: $this->broadcastDefaultTarget($action),
             targets: null,
             channel: $this->toChannels(Collection::wrap($streamables)),
-            content: $rendering,
+            attributes: $attributes,
+            content: $rendering ?? Rendering::empty(),
         )->cancelIf(static::isIgnoringTurboStreamBroadcasts());
     }
 

tests/Models/BroadcastsModelTest.php

@@ -718,4 +718,53 @@ public function can_disable_auto_broadcasts()
             return true;
         }, times: 1);
     }
+
+    /** @test */
+    public function broadcasts_with_extra_attributes_to_turbo_stream()
+    {
+        TurboStream::fake();
+
+        /** @var Board $board */
+        $board = Board::withoutTurboStreamBroadcasts(fn () => Board::create(['name' => 'Hello World']));
+
+        $board->broadcastActionTo(
+            $channel = 'messages',
+            $action = 'test',
+            attributes: $attributes = ['data-foo' => 'bar'],
+        );
+
+        TurboStream::assertBroadcasted(function (PendingBroadcast $turboStream) use ($channel, $action, $attributes) {
+            $this->assertEquals("private-{$channel}", $turboStream->channels[0]->name);
+            $this->assertEquals($action, $turboStream->action);
+            $this->assertEquals($attributes, $turboStream->attributes);
+
+            return true;
+        });
+    }
+
+    /** @test */
+    public function broadcasts_with_extra_attributes_to_turbo_stream_with_rendering()
+    {
+        TurboStream::fake();
+
+        /** @var Board $board */
+        $board = Board::withoutTurboStreamBroadcasts(fn () => Board::create(['name' => 'Hello World']));
+
+        $board->broadcastActionTo(
+            $channel = 'messages',
+            $action = 'test',
+            attributes: $attributes = ['data-foo' => 'bar'],
+        )->view('boards.partials.board', [
+            'board' => $board,
+        ]);
+
+        TurboStream::assertBroadcasted(function (PendingBroadcast $turboStream) use ($channel, $action, $attributes) {
+            $this->assertEquals("private-{$channel}", $turboStream->channels[0]->name);
+            $this->assertEquals($action, $turboStream->action);
+            $this->assertEquals($attributes, $turboStream->attributes);
+            $this->assertStringContainsString('Hello World', $turboStream->render());
+
+            return true;
+        });
+    }
 }

workbench/resources/views/boards/partials/board.blade.php

@@ -0,0 +1 @@
+<div id="@domid($board)">{{ $board->name }}</div>