<?php

namespace App\MessageHandler;

use App\Entity\Prospect\Problem;
use App\Message\MailgunEventMessage;
use App\Service\NegotiationMessageService;
use App\Service\Prospect\ProblemService;
use Doctrine\ORM\EntityNotFoundException;
use Symfony\Component\Messenger\Handler\MessageHandlerInterface;

class ProspectMailgunEventMessageHandler implements MessageHandlerInterface
{
    /**
     * @var ProblemService
     */
    private $problemService;
    /**
     * @var NegotiationMessageService
     */
    private $negotiationMessageService;

    public function __construct(NegotiationMessageService $negotiationMessageServicem, ProblemService $problemService)
    {
        $this->problemService = $problemService;
        $this->negotiationMessageService = $negotiationMessageServicem;
    }

    public function __invoke(MailgunEventMessage $message)
    {
        try {
            $negotiationMessage = $this->negotiationMessageService->get($message->getMessageId());
        } catch (EntityNotFoundException $e) {
            return;
        }

        $problem = (new Problem())
            ->setProspect($negotiationMessage->getProspect())
            ->setSource('email')
            ->setDescription($message->getEvent());

        $this->problemService->save($problem);
    }
}