<?php
/**
 * This code is licensed under AGPLv3 license or Afterlogic Software License
 * if commercial version of the product was purchased.
 * For full statements of the licenses see LICENSE-AFTERLOGIC and LICENSE-AGPL3 files.
 */

namespace Aurora\Modules\Contacts\Classes\Csv;

use Aurora\Modules\Contacts\Enums\StorageType;

/**
 * @license https://www.gnu.org/licenses/agpl-3.0.html AGPL-3.0
 * @license https://afterlogic.com/products/common-licensing Afterlogic Software License
 * @copyright Copyright (c) 2023, Afterlogic Corp.
 *
 * @internal
 *
 * @package Contacts
 * @subpackage Helpers
 */
class Sync
{
    /**
     * @var \Aurora\Modules\Contacts\Classes\Csv\Formatter
     */
    protected $oFormatter;

    /**
     * @var \Aurora\Modules\Contacts\Classes\Csv\Parser
     */
    protected $oParser;

    public function __construct()
    {
        $this->oFormatter = new Formatter();
        $this->oParser = new Parser();
    }

    /**
     * @param array $aContacts
     *
     * @return string
     */
    public function Export($aContacts)
    {
        $sResult = '';

        foreach ($aContacts as $oContact) {
            if ($oContact) {
                $this->oFormatter->setContainer($oContact);
                $this->oFormatter->form();
                $sResult .= $this->oFormatter->getValue();
            }
        }

        return $sResult;
    }

    /**
     *
     * @param int $iUserId
     * @param string $sTempFilePath
     * @param string|null $sGroupUUID
     * @return boolean
     */
    public function Import($iUserId, $sTempFilePath, $sGroupUUID, $sStorage = null)
    {
        $iCount = -1;
        $iParsedCount = 0;
        if (file_exists($sTempFilePath)) {
            $aCsv = $this->csvToArray($sTempFilePath);
            if (is_array($aCsv)) {
                $iCount = 0;
                foreach ($aCsv as $aCsvItem) {
                    set_time_limit(30);

                    $this->oParser->reset();
                    $this->oParser->setContainer($aCsvItem);
                    $aContactData = $this->oParser->getParameters();

                    if (!isset($aContactData['FullName']) || empty($aContactData['FullName'])) {
                        $aFullName = [];
                        if (isset($aContactData['FirstName']) &&  trim($aContactData['FirstName']) != false) {
                            $aFullName[] = trim($aContactData['FirstName']);
                        }
                        if (isset($aContactData['LastName']) && trim($aContactData['LastName']) != false) {
                            $aFullName[] = trim($aContactData['LastName']);
                        }
                        if (count($aFullName) > 0) {
                            $aContactData['FullName'] = join(' ', $aFullName);
                        }
                    }

                    if (isset($aContactData['PersonalEmail']) && !empty($aContactData['PersonalEmail'])) {
                        $aContactData['PrimaryEmail'] = \Aurora\Modules\Contacts\Enums\PrimaryEmail::Personal;
                    } elseif (isset($aContactData['BusinessEmail']) && !empty($aContactData['BusinessEmail'])) {
                        $aContactData['PrimaryEmail'] = \Aurora\Modules\Contacts\Enums\PrimaryEmail::Business;
                    } elseif (isset($aContactData['OtherEmail']) && !empty($aContactData['OtherEmail'])) {
                        $aContactData['PrimaryEmail'] = \Aurora\Modules\Contacts\Enums\PrimaryEmail::Other;
                    }

                    if (isset($aContactData['BirthYear'])) {
                        if (strlen($aContactData['BirthYear']) === 2) {
                            $oDt = \DateTime::createFromFormat('y', $aContactData['BirthYear']);
                            $aContactData['BirthYear'] = $oDt->format('Y');
                        }
                        $aContactData['BirthYear'] = (int) $aContactData['BirthYear'];
                    }

                    if (!empty($sGroupUUID)) {
                        $aContactData['GroupUUIDs'] = [$sGroupUUID];
                    }

                    $iParsedCount++;

                    if (isset($sStorage)) {
                        $aContactData['Storage'] = $sStorage;
                    }

                    $oContactsDecorator = \Aurora\Modules\Contacts\Module::Decorator();
                    if ($oContactsDecorator && $oContactsDecorator->CreateContact($aContactData, $iUserId)) {
                        $iCount++;
                    }

                    unset($aContactData, $aCsvItem);
                }
            }
        }

        if ($iCount > -1) {
            return array(
                'ParsedCount' => $iParsedCount,
                'ImportedCount' => $iCount,
            );
        }
        return false;
    }

    /**
     * @return string $sFileName
     * @return string
     */
    private static function csvToArray($sFileName)
    {
        if (!file_exists($sFileName) || !is_readable($sFileName)) {
            return false;
        }

        $aHeaders = null;
        $aData = array();

        @setlocale(LC_CTYPE, 'en_US.UTF-8');
        // TODO: check if this is needed. It throws deprecation warning in PHP 8.1
        // \ini_set('auto_detect_line_endings', true);

        if (false !== ($rHandle = @fopen($sFileName, 'rb'))) {
            $sDelimiterSearchString = @fread($rHandle, 2000);
            rewind($rHandle);

            $sDelimiter = (
                (int) substr_count($sDelimiterSearchString, ',') > (int) substr_count($sDelimiterSearchString, ';')
            )
                    ? ',' : ';';

            while (false !== ($mRow = fgetcsv($rHandle, 5000, $sDelimiter, '"'))) {
                $mRow = preg_replace('/[\r\n]+/', "\n", $mRow);
                if (!is_array($mRow) || count($mRow) === 0 || count($mRow) === 1 && empty($mRow[0])) {
                    continue;
                }
                if (null === $aHeaders) {
                    if (3 >= count($mRow)) {
                        \Aurora\System\Api::Log('Invalid csv headers');
                        \Aurora\System\Api::LogObject($mRow);
                        fclose($rHandle);
                        return $aData;
                    }

                    $aHeaders = $mRow;
                } else {
                    $aNewItem = array();
                    foreach ($aHeaders as $iIndex => $sHeaderValue) {
                        $aNewItem[@iconv('utf-8', 'utf-8//IGNORE', $sHeaderValue)] =
                            isset($mRow[$iIndex]) ? $mRow[$iIndex] : '';
                    }

                    $aData[] = $aNewItem;
                }
            }

            fclose($rHandle);
        }

        // TODO: check if this is needed. It throws deprecation warning in PHP 8.1
        // ini_set('auto_detect_line_endings', false);

        return $aData;
    }
}

• [F] Formatter.php
  Delete
• [F] Parser.php
  Delete
• [F] Sync.php
  Delete