comsave/safe-salesforce-saver-bundle

<?php

namespace Comsave\SafeSalesforceSaverBundle\Services\SalesforceSaver;

use Comsave\SafeSalesforceSaverBundle\Factory\ExceptionMessageFactory;
use Comsave\SafeSalesforceSaverBundle\Producer\AsyncSfSaverProducer;
use Comsave\SafeSalesforceSaverBundle\Services\ModelSerializer;
use Psr\Log\LoggerInterface;

class AsyncSalesforceSaver
{
    /** @var AsyncSfSaverProducer */
    private $aSyncSaverProducer;

    /** @var ModelSerializer */
    private $modelSerializer;

    /** @var LoggerInterface */
    private $logger;

    /**
     * @codeCoverageIgnore
     */
    public function __construct(
        AsyncSfSaverProducer $aSyncSaver,
        ModelSerializer $modelSerializer,
        LoggerInterface $logger
    ) {
        $this->aSyncSaverProducer = $aSyncSaver;
        $this->modelSerializer = $modelSerializer;
        $this->logger = $logger;
    }

    public function save($models): void
    {
        $serializedModels = $this->modelSerializer->serialize($models);

        $this->logger->debug(ExceptionMessageFactory::build($this, [
            'Scheduling for saving',
            $serializedModels
        ]));

        $this->aSyncSaverProducer->publish($serializedModels);

        $this->logger->debug(ExceptionMessageFactory::build($this, [
            'Scheduled for saving successfully',
            $serializedModels
        ]));
    }
}