<?php
declare(strict_types=1);

namespace Firebear\ImportExport\Setup\Operations;

use Firebear\ImportExport\Model\ResourceModel\FieldEncryptor;
use Magento\Framework\Serialize\SerializerInterface;
use Magento\Framework\Setup\ModuleDataSetupInterface;
use Magento\Framework\DB\AggregatedFieldDataConverter;
use Magento\Framework\DB\DataConverter\DataConversionException;
use Magento\Framework\DB\DataConverter\DataConverterInterface;
use Magento\Framework\DB\FieldToConvert;

/**
* Encrypt operation
*/
class EncryptPasswordFields implements DataConverterInterface
{
/**
* Field data converter
*
* @var \Magento\Framework\DB\AggregatedFieldDataConverter
*/
private $aggregatedFieldConverter;

/**
* @var FieldEncryptor
*/
private $encryptor;

/**
* @var SerializerInterface
*/
private $serializer;

/**
* Initialize operation
*
* @param FieldEncryptor $encryptor
* @param SerializerInterface $serializer
* @param AggregatedFieldDataConverter $aggregatedFieldConverter
*/
public function __construct(
FieldEncryptor $encryptor,
SerializerInterface $serializer,
AggregatedFieldDataConverter $aggregatedFieldConverter
) {
$this->encryptor = $encryptor;
$this->serializer = $serializer;
$this->aggregatedFieldConverter = $aggregatedFieldConverter;
}

/**
* Convert data
*
* @param string $value
* @return string
* @throws DataConversionException
*/
public function convert($value)
{
if (empty($value)) {
return $value;
}

$data = $this->serializer->unserialize($value);
$data = $this->encryptor->encrypt($data);
return $this->serializer->serialize($data);
}

/**
* @param ModuleDataSetupInterface $setup
* @return void
*/
public function execute($setup)
{
$this->aggregatedFieldConverter->convert(
[
new FieldToConvert(
self::class,
$setup->getTable('firebear_export_jobs'),
'entity_id',
'export_source'
),
],
$setup->getConnection()
);

$this->aggregatedFieldConverter->convert(
[
new FieldToConvert(
self::class,
$setup->getTable('firebear_import_jobs'),
'entity_id',
'source_data'
),
],
$setup->getConnection()
);
}
}