nabilhassen/larasense

use App\Models\Source;
use Illuminate\Contracts\Queue\ShouldQueue;
use Illuminate\Foundation\Queue\Queueable;
use Illuminate\Support\Carbon;
use willvincent\Feeds\Facades\FeedsFacade;
 
class SyncSourceFeed implements ShouldQueue
{
    use Queueable;
 
    public function __construct(public Source $source) {}
 
    public function handle(): void
    {
        $feed = FeedsFacade::make([$this->source->url], 20, true);
 
        if (filled($feed->error())) {
            $feed = FeedsFacade::make([$this->source->url], 20);
        }
 
        $latestMaterial = $this->source->latestMaterial;
 
        foreach ($feed->get_items() as $item) {
            $itemPublishedAt = Carbon::parse($item->get_date())->timezone(config('app.timezone'));
 
            if (filled($latestMaterial) && $latestMaterial->published_at->greaterThanOrEqualTo($itemPublishedAt)) {
                break;
            }
 
            ProcessFeedItem::dispatch($this->source, $item);
        }
 
        $this->source->updateLastCheckedAt();
    }
}

use App\Actions\CreateMaterial;
use App\Data\MaterialData;
use App\Models\Source;
use Illuminate\Contracts\Queue\ShouldQueue;
use Illuminate\Foundation\Queue\Queueable;
use SimplePie\Item;
 
class ProcessFeedItem implements ShouldQueue
{
    use Queueable;
 
    public function __construct(
        public Source $source,
        public Item $item
    ) {}
 
    public function handle(CreateMaterial $createMaterial): void
    {
        $createMaterial->handle(
            $this->source,
            MaterialData::create($this->source->type, $this->item),
        );
    }
}