<?php

namespace TFGraphics\SmartImport\Import;

use TFGraphics\SmartImport\Domain\Contracts\ImportDispatcherInterface;
use TFGraphics\SmartImport\Import\Exceptions\ImportJobException;

final class ImportJobDispatcher implements ImportDispatcherInterface
{
    public function dispatch(ImportJobQueue $queue, ImportJobResult $initialResult): ImportJobResult
    {
        if ($queue->isEmpty()) {
            throw new ImportJobException('Import job queue is empty.');
        }

        $result = $initialResult;

        foreach ($queue->getJobs() as $job) {
            if (! $job instanceof \TFGraphics\SmartImport\Domain\Contracts\ImportJobInterface) {
                throw new ImportJobException('Queue contains invalid job object.');
            }

            $result = $job->execute($result);

            if ($result->getStatus()->isFailed()) {
                break;
            }
        }

        return $result;
    }
}