36 lines
952 B
PHP
36 lines
952 B
PHP
<?php
|
|
|
|
namespace App\Jobs;
|
|
|
|
use App\Exceptions\PublishException;
|
|
use App\Models\Article;
|
|
use App\Services\Article\ArticleFetcher;
|
|
use App\Services\Publishing\ArticlePublishingService;
|
|
use Illuminate\Contracts\Queue\ShouldQueue;
|
|
use Illuminate\Foundation\Queue\Queueable;
|
|
use RuntimeException;
|
|
|
|
class PublishToLemmyJob implements ShouldQueue
|
|
{
|
|
use Queueable;
|
|
|
|
public function __construct(
|
|
private readonly Article $article
|
|
) {
|
|
$this->onQueue('lemmy-posts');
|
|
}
|
|
|
|
public function handle(): void
|
|
{
|
|
$extractedData = ArticleFetcher::fetchArticleData($this->article);
|
|
|
|
/** @var ArticlePublishingService $publishingService */
|
|
$publishingService = resolve(ArticlePublishingService::class);
|
|
|
|
try {
|
|
$publishingService->publishToRoutedChannels($this->article, $extractedData);
|
|
} catch (PublishException|RuntimeException $e) {
|
|
$this->fail($e);
|
|
}
|
|
}
|
|
}
|