<?php

namespace WPML\Infrastructure\WordPress\Component\StringPackage\Application\Query;

use WPML\Core\Component\StringPackage\Application\Query\PackageDefinitionQueryInterface;
use WPML\Core\Port\Persistence\Exception\DatabaseErrorException;
use WPML\Core\Port\Persistence\QueryHandlerInterface;
use WPML\Core\Port\Persistence\QueryPrepareInterface;
use WPML\Core\SharedKernel\Component\Item\Application\Query\Dto\UntranslatedTypeCountDto;
use WPML\Core\SharedKernel\Component\Item\Application\Query\UntranslatedTypesCountQueryInterface;
use WPML\Core\SharedKernel\Component\Language\Application\Query\Dto\LanguageDto;
use WPML\Core\SharedKernel\Component\Language\Application\Query\LanguagesQueryInterface;
use WPML\Core\SharedKernel\Component\Translation\Domain\TranslationStatus;

/**
 * @phpstan-type UntranslatedCountRow array{
 *   kind: string,
 *   kind_slug: string,
 *   count: int,
 * }
 */
class UntranslatedTypesCountQuery implements UntranslatedTypesCountQueryInterface {

  /** @phpstan-var  QueryHandlerInterface<int, UntranslatedCountRow> $queryHandler */
  private $queryHandler;

  /** @var QueryPrepareInterface */
  private $queryPrepare;

  /** @var LanguagesQueryInterface */
  private $languagesQuery;

  /** @var PackageDefinitionQueryInterface */
  private $packageDefinitionRepository;


  /**
   * @param QueryHandlerInterface<int, UntranslatedCountRow> $queryHandler
   * @param QueryPrepareInterface $queryPrepare
   * @param LanguagesQueryInterface $languagesQuery
   * @param PackageDefinitionQueryInterface $packageDefinitionRepository
   */
  public function __construct(
    QueryHandlerInterface $queryHandler,
    QueryPrepareInterface $queryPrepare,
    LanguagesQueryInterface $languagesQuery,
    PackageDefinitionQueryInterface $packageDefinitionRepository
  ) {
    $this->queryHandler                = $queryHandler;
    $this->queryPrepare                = $queryPrepare;
    $this->languagesQuery              = $languagesQuery;
    $this->packageDefinitionRepository = $packageDefinitionRepository;
  }


  /** @return UntranslatedTypeCountDto[] */
  public function get( array $queryData = [] ): array {
    $languageCrossJoin = $this->buildLanguageCrossJoin();

    $packageInfo = $this->packageDefinitionRepository->getInfoList();

    $translatablePackages = $this->buildTranslatablePackagesCondition(
      array_keys( $packageInfo )
    );

    $sql = "
      SELECT package.kind, package.kind_slug, COUNT( DISTINCT package.ID ) as count
      FROM {$this->queryPrepare->prefix()}icl_string_packages package
      LEFT JOIN {$this->queryPrepare->prefix()}icl_translations original_translation 
        ON original_translation.element_id = package.ID AND original_translation.element_type LIKE 'package_%'
      {$languageCrossJoin}
      LEFT JOIN {$this->queryPrepare->prefix()}icl_translations translations 
        ON translations.trid = original_translation.trid AND translations.language_code = langs.code
      LEFT JOIN {$this->queryPrepare->prefix()}icl_translation_status translation_status
        ON translation_status.translation_id = translations.translation_id
      WHERE package.kind_slug IN ({$translatablePackages}) 
            AND ( translation_status.status IS NULL OR translation_status.status = %d )  
            AND original_translation.language_code = %s
      GROUP BY package.kind
    ";

    $sql = $this->queryPrepare->prepare(
      $sql,
      TranslationStatus::NOT_TRANSLATED,
      $this->languagesQuery->getDefaultCode()
    );

    try {
      $rowResult = $this->queryHandler->query( $sql )->getResults();

      return array_map(
        function ( $row ) use ( $packageInfo ) {
          $info = $packageInfo[ $row['kind_slug'] ] ?? null;

          $pluralName   = $info ? $info->getPlural() : $row['kind'];
          $singularName = $info ? $info->getTitle() : $row['kind'];

          return new UntranslatedTypeCountDto(
            $pluralName,
            $singularName,
            $row['count']
          );
        },
        $rowResult
      );
    } catch ( DatabaseErrorException $e ) {
      return [];
    }
  }


  private function buildLanguageCrossJoin(): string {
    $languageSelect = array_map(
      function ( LanguageDto $language ) {
        return "SELECT '{$language->getCode()}' AS code";
      },
      $this->languagesQuery->getSecondary()
    );

    $languageSelect    = implode( ' UNION ALL ', $languageSelect );
    $languageCrossJoin = "
			CROSS JOIN (
				$languageSelect	
			) as langs
		";

    return $languageCrossJoin;
  }


  /**
   * @param string[] $slugs
   *
   * @return string
   */
  private function buildTranslatablePackagesCondition( array $slugs ): string {
    $translatablePackages = array_map(
      function ( string $packageName ): string {
        return $this->queryPrepare->prepare( '%s', $packageName );
      },
      $slugs
    );

    return implode( ',', $translatablePackages );
  }


}
