<?php

declare(strict_types=1);

namespace Jve\JveTemplate\Upgrades;

use TYPO3\CMS\Core\Configuration\FlexForm\FlexFormTools;
use TYPO3\CMS\Core\Database\ConnectionPool;
use TYPO3\CMS\Core\Database\Query\Restriction\DeletedRestriction;
use TYPO3\CMS\Core\Service\FlexFormService;
use TYPO3\CMS\Core\Utility\GeneralUtility;
use TYPO3\CMS\Install\Attribute\UpgradeWizard;
use TYPO3\CMS\Install\Updates\UpgradeWizardInterface;

#[UpgradeWizard('jveTemplate_upgradeImagesWizard')]
final class UpgradeImagesWizard implements UpgradeWizardInterface
{

    public int $verboseLevel = 0 ;
    /**
     * Return the speaking name of this wizard
     */
    public function getTitle(): string
    {
        return 'Fix sys_file_references of content elements';
    }

    /**
     * Return the description for this wizard
     */
    public function getDescription(): string
    {
        return 'Content elements like image slider had no complete sys_file_reference and direct UID (list) of such records.';
    }

    /**
     * Execute the update
     *
     * Called when a wizard reports that an update is necessary
     */
    public function executeUpdate(): bool
    {
        if ( isset( $_SERVER['argv'][3]) ) {
            if (  $_SERVER['argv'][3] =="-v" ) {
                $this->verboseLevel = 16 ;
            }
            if (  $_SERVER['argv'][3] =="-vv" ) {
                $this->verboseLevel = 64 ;
            }
            if (  $_SERVER['argv'][3] =="-vvv" ) {
                $this->verboseLevel = 128 ;
            }
        };
        $elements = [
            "jvetemplate_ce_imageSlider" => [ 'section' => 'elements' , 'field' => 'images' ] ,
            "jvetemplate_ce_imageLink" => [ 'section' => 'main' , 'field' => 'images' ] ,
            "jvetemplate_ce_countdown" => [ 'section' => 'main' , 'field' => 'image' ]
        ] ;
        $result = true;
        foreach ( $elements as $ctype => $elementField ) {
            $objCount = 0 ;
            $objects = $this->getContentElements( $ctype ) ;
            while ( $object = $objects->fetchAssociative() ) {
                try {
                    $this->checkContentElement( $object , $elementField ) ;
                    $objCount ++ ;
                } catch ( \Exception $e )  {
                    $this->debugOutput( 0 ,  $e->getFile() . " - Line: " .  $e->getLine() .   $e->getMessage() ) ;
                    $result = false ;
                }
            }
            $this->debugOutput( 15 ,  "Found " . $objCount . " of " . $ctype ) ;
        }
        $this->debugOutput( 0 ,  "" ) ;
        return $result ;
    }



    private function getContentElements($ctype) {
        /** @var ConnectionPool $connectionPool */
        $connectionPool = GeneralUtility::makeInstance( "TYPO3\\CMS\\Core\\Database\\ConnectionPool");
        $queryBuilder = $connectionPool->getConnectionForTable('tt_content')->createQueryBuilder();
        $queryBuilder->getRestrictions()->removeAll()->add( GeneralUtility::makeInstance(DeletedRestriction::class));
        $queryBuilder->select('uid','header','pi_flexform' , 'CType' ) ->from('tt_content') ;
        $expr = $queryBuilder->expr();
        $queryBuilder->where( $expr->eq('CType', $queryBuilder->createNamedParameter( $ctype )) ) ;
        return $queryBuilder->executeQuery() ;
    }

    private function checkContentElement($ttContent , $structure ) {
        $settingsField = $structure['field'] ;
        $flexFormService = GeneralUtility::makeInstance(FlexFormService::class ) ;

        $data = [ 'tablenames' => 'tt_content' , 'fieldname' => 'settings.' . $settingsField , 'uid_foreign' => $ttContent['uid']] ;
        $settings = $flexFormService->convertFlexFormContentToArray( $ttContent['pi_flexform'] );

        $this->debugOutput( 63 , $ttContent['uid']   . "-". $ttContent['CType']   . ":". $settingsField ) ;

        if( isset( $settings['settings'][$settingsField] ) && !isset($settings['settings']['imagesrepaired'])) {
            $references = GeneralUtility::trimExplode("," , $settings['settings'][$settingsField] );

            if( count( $references) > 0 ) {
                foreach ($references as $refUid ) {
                    $updateCount = $this->updateSysfile( $refUid , $data ) ;
                    $this->debugOutput( 123 ,  "Reference " . $refUid . " updated: "  . $updateCount ) ;
                }
                if( $flexFormString = $this->repairFlexForm($ttContent['pi_flexform'] , count( $references) , $structure )) {
                    $updateCount = $this->updateContentElement($ttContent['uid'] , $flexFormString  ) ;
                     $this->debugOutput( 123 ,  "Flexform of tt_content : " . $ttContent['uid'] . " updated: "  . $updateCount ) ;
                }
            }
        }
    }
    private function updateContentElement($uid , $data) {
        /** @var ConnectionPool $connectionPool */
        $connectionPool = GeneralUtility::makeInstance( "TYPO3\\CMS\\Core\\Database\\ConnectionPool");
        $queryBuilder = $connectionPool->getConnectionForTable('tt_content')->createQueryBuilder();
        $queryBuilder->getRestrictions()->removeAll()->add( GeneralUtility::makeInstance(DeletedRestriction::class));
        $queryBuilder->update('tt_content')
            ->set( "pi_flexform", $data ) ;

        $expr = $queryBuilder->expr();
        $queryBuilder->where( $expr->eq('uid', $uid ) ) ;
        return $queryBuilder->executeStatement() ;
    }


    private function updateSysfile($uid , $data ) {
        /** @var ConnectionPool $connectionPool */
        $connectionPool = GeneralUtility::makeInstance( "TYPO3\\CMS\\Core\\Database\\ConnectionPool");
        $queryBuilder = $connectionPool->getConnectionForTable('sys_file_reference')->createQueryBuilder();
        $queryBuilder->getRestrictions()->removeAll()->add( GeneralUtility::makeInstance(DeletedRestriction::class));
        $queryBuilder->update('sys_file_reference')
            ->set( "tablenames" ,  $data['tablenames'])
            ->set( "fieldname" ,  $data['fieldname'])
            ->set( "table_local" ,  'sys_file')
            ->set( "uid_foreign" , intval( $data['uid_foreign']))
        ;

        $expr = $queryBuilder->expr();
        $queryBuilder->where( $expr->eq('uid', $uid )) ;
        return $queryBuilder->executeStatement() ;
    }

    /**
     * @param string $flexString
     * @param int $count
     * @param array  $settingsField
     * @return false|string
     */
    private function repairFlexForm(string $flexString , int $count, array $structure): bool|string
    {
        $settingsField = $structure['field'] ;
        $section = $structure['section'] ;
        $flexFormArray = GeneralUtility::xml2array( $flexString );
        if ( isset( $flexFormArray['data'][$section] )) {
            $imageRepaired = $flexFormArray['data'][$section] ;
            $flexFormArray['data'][$section]['lDEF']['settings.upgradeImagesWizardBack']['vDEF'] = $flexFormArray['data'][$section]['lDEF']['settings.' . $settingsField]['vDEF'] ;
            $flexFormArray['data'][$section]['lDEF']['settings.' . $settingsField]['vDEF'] = $count ;
            $flexFormArray['data'][$section]['lDEF']['settings.imagesrepaired']['vDEF'] = 1 ;
            $flexFormTools = new FlexFormTools();

            return $flexFormTools->flexArray2Xml($flexFormArray, addPrologue: true);
        }
        return false ;

    }

    private function debugOutput( $minVerbosity , $text ) {
        if ( $this->verboseLevel > $minVerbosity  ) {
            echo "\n" . $text ;
        }
    }


    /**
     * Is an update necessary?
     *
     * Is used to determine whether a wizard needs to be run.
     * Check if data for migration exists.
     *
     * @return bool Whether an update is required (TRUE) or not (FALSE)
     */
    public function updateNecessary(): bool
    {
        return true;
    }

    /**
     * Returns an array of class names of prerequisite classes
     *
     * This way a wizard can define dependencies like "database up-to-date" or
     * "reference index updated"
     *
     * @return string[]
     */
    public function getPrerequisites(): array
    {
        return ['database up-to-date' , 'reference index updated'] ;
    }


}