06e72831f6
Adds a private workspace channel (WorkspaceChannel, authorised by
membership) so list views can subscribe once and receive events for
every post in the workspace, instead of opening N per-post channels.
New events:
- PostCreated (broadcast on workspace.{id})
- PostDeleted (broadcast on workspace.{id}; carries primitive ids so
it fires after \$post->delete())
- PostPlatformStatusUpdated now broadcasts on both post.{id} and
workspace.{id} so focused views and lists share the same trigger.
All broadcast events migrated to the namespaced 'entity.action'
convention from Laravel's broadcasting docs and switched from
ShouldBroadcastNow to ShouldBroadcast on a dedicated 'broadcasts'
queue (added to the supervisor-1 list in config/horizon.php) to keep
HTTP responses fast:
PostCreated -> post.created
PostDeleted -> post.deleted
PostPlatformStatusUpdated -> post.platform.status.updated
PostCommentCreated -> post.comment.created
NotificationCreated -> notification.created
PostCreationReady -> ai.creation.completed
Drops the SubscriptionCreated event — it was broadcast on
users.{owner_id} but had no listeners (frontend or backend) and the
billing/PostHog flow already handles plan-change tracking elsewhere.
PostPlatformStatusUpdated payload trimmed to {post_id} since every
consumer (Show, Edit, Index) does router.reload({ only: [...] }) and
ignored the rich shape.
52 lines
1.8 KiB
PHP
52 lines
1.8 KiB
PHP
<?php
|
|
|
|
declare(strict_types=1);
|
|
|
|
use App\Enums\Post\Status as PostStatus;
|
|
use App\Events\PostPlatformStatusUpdated;
|
|
use App\Models\Post;
|
|
use App\Models\PostPlatform;
|
|
use App\Models\SocialAccount;
|
|
use App\Models\User;
|
|
use App\Models\Workspace;
|
|
use Illuminate\Broadcasting\PrivateChannel;
|
|
|
|
beforeEach(function () {
|
|
$this->user = User::factory()->create();
|
|
$this->workspace = Workspace::factory()->create(['user_id' => $this->user->id]);
|
|
$this->socialAccount = SocialAccount::factory()->linkedin()->create([
|
|
'workspace_id' => $this->workspace->id,
|
|
]);
|
|
$this->post = Post::factory()->create([
|
|
'workspace_id' => $this->workspace->id,
|
|
'user_id' => $this->user->id,
|
|
'status' => PostStatus::Scheduled,
|
|
]);
|
|
$this->postPlatform = PostPlatform::factory()->linkedin()->create([
|
|
'post_id' => $this->post->id,
|
|
'social_account_id' => $this->socialAccount->id,
|
|
]);
|
|
});
|
|
|
|
test('event broadcasts on the per-post and per-workspace channels', function () {
|
|
$event = new PostPlatformStatusUpdated($this->postPlatform);
|
|
$channels = $event->broadcastOn();
|
|
|
|
expect($channels)->toHaveCount(2);
|
|
expect($channels[0])->toBeInstanceOf(PrivateChannel::class);
|
|
expect($channels[0]->name)->toBe('private-post.'.$this->post->id);
|
|
expect($channels[1])->toBeInstanceOf(PrivateChannel::class);
|
|
expect($channels[1]->name)->toBe('private-workspace.'.$this->workspace->id);
|
|
});
|
|
|
|
test('event broadcasts with the post id', function () {
|
|
$event = new PostPlatformStatusUpdated($this->postPlatform);
|
|
|
|
expect($event->broadcastWith())->toBe(['post_id' => $this->post->id]);
|
|
});
|
|
|
|
test('event broadcasts as a stable name', function () {
|
|
$event = new PostPlatformStatusUpdated($this->postPlatform);
|
|
|
|
expect($event->broadcastAs())->toBe('post.platform.status.updated');
|
|
});
|