diff --git a/app/Jobs/PublishPostJob.php b/app/Jobs/PublishPostJob.php index 0172eef..8221846 100644 --- a/app/Jobs/PublishPostJob.php +++ b/app/Jobs/PublishPostJob.php @@ -27,6 +27,13 @@ class PublishPostJob implements ShouldQueue return; } + // A duplicate/stale job for a post already resolved by an earlier + // run of this same job (e.g. a double-dispatch while no worker was + // running) — skip it rather than risk publishing twice. + if ($post->status !== 'publishing') { + return; + } + $publisher = $publishers->resolve($post); if (! $publisher) { diff --git a/tests/Feature/Jobs/PublishPostJobTest.php b/tests/Feature/Jobs/PublishPostJobTest.php index 293a400..d86b806 100644 --- a/tests/Feature/Jobs/PublishPostJobTest.php +++ b/tests/Feature/Jobs/PublishPostJobTest.php @@ -60,6 +60,20 @@ test('it reverts to draft when no publisher supports the post type', function () ->publish_error->toContain('No publisher available'); }); +test('it skips a duplicate job for a post no longer in publishing state', function () { + Http::fake([ + '*/wp-json/wp/v2/posts' => Http::response(['link' => 'https://wp.example.com/post'], 201), + ]); + + $site = Site::factory()->wordpress()->create(); + $post = Post::factory()->create(['site_id' => $site->id, 'type' => 'blog', 'title' => 'Hi', 'status' => 'published', 'published_url' => 'https://wp.example.com/already-there']); + + (new PublishPostJob($post->id))->handle(app(PublisherManager::class)); + + Http::assertNothingSent(); + expect($post->fresh()->published_url)->toBe('https://wp.example.com/already-there'); +}); + test('it publishes a reddit post via the sidecar', function () { Process::fake([ '*' => Process::result(output: json_encode(['success' => true, 'url' => 'https://reddit.com/r/test/comments/abc'])),