bingo-soft / jabe

src/Impl/JobExecutor/ProcessEventJobHandler.php

<?php

namespace Jabe\Impl\JobExecutor;

use Jabe\Impl\Interceptor\CommandContext;
use Jabe\Impl\Persistence\Entity\{
    EventSubscriptionEntity,
    ExecutionEntity,
    JobEntity
};

class ProcessEventJobHandler implements JobHandlerInterface
{
    public const TYPE = "event";

    public function getType(): string
    {
        return self::TYPE;
    }

    public function execute(JobHandlerConfigurationInterface $configuration, ExecutionEntity $execution, CommandContext $commandContext, ?string $tenantId): void
    {
        // lookup subscription:
        $eventSubscriptionId = $configuration->getEventSubscriptionId();

The method getEventSubscriptionId() does not exist on Jabe\Impl\JobExecutor\JobHandlerConfigurationInterface. It seems like you code against a sub-type of Jabe\Impl\JobExecutor\JobHandlerConfigurationInterface such as Jabe\Impl\JobExecutor\EventSubscriptionJobConfiguration.

        $eventSubscription = $commandContext->getEventSubscriptionManager()
            ->findEventSubscriptionById($eventSubscriptionId);

        // if event subscription is null, ignore
        if ($eventSubscription !== null) {
            $eventSubscription->eventReceived(null, false);

The call to Jabe\Impl\Persistence\Entity\EventSubscriptionEntity::eventReceived() has too few arguments starting with businessKey.

        }
    }

    public function newConfiguration(string $canonicalString): JobHandlerConfigurationInterface
    {
        return new EventSubscriptionJobConfiguration($canonicalString);
    }

    public function onDelete(JobHandlerConfigurationInterface $configuration, JobEntity $jobEntity): void
    {
        // do nothing
    }
}