<?php

namespace WCML\Attributes;

use Automattic\WooCommerce\Internal\ProductAttributesLookup\LookupDataStore as ProductAttributesLookupDataStore;
use WCML\Terms\SuspendWpmlFiltersFactory;
use WPML\Convert\Ids;
use WPML\FP\Obj;
use WPML\LIB\WP\Hooks;
use function WPML\FP\spreadArgs;
use WPML\FP\Fns;

class LookupTable implements \IWPML_Action {

	/** @var \SitePress $sitepress */
	private $sitepress;

	/**
	 * @param \SitePress $sitepress
	 */
	public function __construct( \SitePress $sitepress ) {
		$this->sitepress = $sitepress;
	}

	public function add_hooks() {
		Hooks::onAction( 'save_post' )
			->then( spreadArgs( [ $this, 'triggerUpdateForTranslations' ] ) );

		// For defered updates, we adjust terms filter just before the action scheduler.
		Hooks::onAction( 'woocommerce_run_product_attribute_lookup_update_callback', 5 )
			->then( [ $this, 'adjustTermsFilters' ] );

		// When regenerating the table we need all products and all terms.
		Hooks::onFilter( 'woocommerce_attribute_lookup_regeneration_step_size' )
			->then( spreadArgs( Fns::tap( [ $this, 'regenerateTable' ] ) ) );
	}

	/**
	 * @param int $productId
	 */
	public function triggerUpdateForTranslations( $productId ) {
		if (
			'product' === get_post_type( $productId )
			&& 'publish' === get_post_status( $productId )
			&& ! $this->sitepress->is_original_content_filter( false, $productId, 'post_product' )
		) {
			$savedOnBlogId = get_current_blog_id();

			Hooks::onAction( 'shutdown' )
				->then( function() use ( $productId, $savedOnBlogId ) {
					$savedOnAnotherBlog = get_current_blog_id() !== $savedOnBlogId;

					if ( $savedOnAnotherBlog ) {
						switch_to_blog( $savedOnBlogId );
					}

					// For direct updates, we adjust terms filters just before triggering the update.
					$hasTermsClausesFilter = $this->adjustTermsFilters();

					wc_get_container()->get( ProductAttributesLookupDataStore::class )->on_product_changed( $productId );

					$this->restoreTermsFilters( $hasTermsClausesFilter );

					if ( $savedOnAnotherBlog ) {
						restore_current_blog();
					}
				} );
		}
	}

	/**
	 * @return \WCML\Utilities\Suspend\Suspend
	 */
	public function adjustTermsFilters() {
		add_filter( 'woocommerce_product_get_attributes', [ $this, 'translateAttributeOptions' ], 10, 2 );
		add_filter( 'woocommerce_product_variation_get_attributes', [ $this, 'translateVariationTerms' ], 10, 2 );

		return SuspendWpmlFiltersFactory::create();
	}

	/**
	 * @param \WCML\Utilities\Suspend\Suspend $filtersSuspend
	 */
	private function restoreTermsFilters( $filtersSuspend ) {
		$filtersSuspend->resume();

		remove_filter( 'woocommerce_product_get_attributes', [ $this, 'translateAttributeOptions' ] );
		remove_filter( 'woocommerce_product_variation_get_attributes', [ $this, 'translateVariationTerms' ] );
	}

	/**
	 * @param \WC_Product_Attribute[] $attributes
	 * @param \WC_Product             $product
	 *
	 * @return \WC_Product_Attribute[]
	 */
	public function translateAttributeOptions( $attributes, $product ) {
		$language = $this->sitepress->get_language_for_element(
			$product->get_id(),
			'post_product'
		);

		if ( $language ) {
			// $getTranslatedOptions :: string -> string|null
			$getTranslatedOptions = function( $attribute, $taxonomy ) use ( $language ) {
				$attribute->set_options( Ids::convert( $attribute->get_options(), $taxonomy, true, $language ) );

				return $attribute;
			};

			$attributes = wpml_collect( $attributes )
				->map( $getTranslatedOptions )
				->toArray();
		}

		return $attributes;
	}

	/**
	 * @param array                 $attributes
	 * @param \WC_Product_Variation $product
	 *
	 * @return array
	 */
	public function translateVariationTerms( $attributes, $product ) {
		$language = $this->sitepress->get_language_for_element(
			$product->get_id(),
			'post_product_variation'
		);

		if ( $language ) {
			// $getTranslatedSlug :: string -> string|null
			$getTranslatedSlug = function( $slug, $taxonomy ) use ( $language ) {
				$term = get_term_by( 'slug', $slug, $taxonomy );
				if ( false === $term ) {
					return $slug;
				}
				$termId         = Ids::convert( $term->term_id, $taxonomy, true, $language );
				$translatedTerm = get_term( $termId, $taxonomy );

				return Obj::prop( 'slug', $translatedTerm );
			};

			$attributes = wpml_collect( $attributes )
				->map( $getTranslatedSlug )
				->toArray();
		}

		return $attributes;
	}

	public function regenerateTable() {
		$this->adjustTermsFilters();

		add_filter( 'woocommerce_product_object_query_args', Obj::assoc( 'suppress_filters', true ) );
	}

}