<?php
// SPDX-License-Identifier: GPL-3.0-or-later
declare(strict_types=1);

namespace Aiwend\Knowledge;

use Aiwend\Queue\Job;
use Aiwend\Queue\PermanentJobFailure;
use Aiwend\Queue\Worker;

/**
 * Registers the generation job handlers on a queue worker, guarded: with no GenerationJobs (execution not available in this
 * environment) a job of these types is dead-lettered with a fixed message instead of running, so nothing can start semantic
 * indexing by enqueueing a job. Registering is cheap and adds no recurring work: the types only matter when a job exists.
 */
final class GenerationRuntime
{
    public function __construct(private ?GenerationJobs $jobs)
    {
    }

    public function register(Worker $worker): void
    {
        $worker->handle(GenerationJobs::BUILD, function (Job $job): void {
            $this->jobs !== null ? $this->jobs->runBuild($job) : throw new PermanentJobFailure('Semantic indexing is not enabled in this environment.');
        });
        $worker->handle(GenerationJobs::SYNC, function (Job $job): void {
            $this->jobs !== null ? $this->jobs->runSync($job) : throw new PermanentJobFailure('Semantic indexing is not enabled in this environment.');
        });
    }
}