<?php
namespace ElementorPro\Modules\Forms\Submissions\Database\Migrations;

use ElementorPro\Core\Utils\Collection;

if ( ! defined( 'ABSPATH' ) ) {
	exit; // Exit if accessed directly.
}

class Fix_Indexes extends Base_Migration {
	/**
	 * In the previous migrations some databases had problems with the indexes.
	 * this migration checks if user's tables are filled with required indexes, if not it creates them.
	 */
	public function run() {
		$indexes = $this->get_indexes();

		foreach ( $indexes as $table => $table_indexes ) {
			$existing_indexes = $this->get_existed_indexes_of( $table );

			// Protect from database errors (for example: table do not exists somehow).
			if ( null === $existing_indexes ) {
				continue;
			}

			$indexes_query = $table_indexes->except( $existing_indexes )->implode( ',' );

			$this->wpdb->query( "ALTER TABLE `{$table}` {$indexes_query};" ); // phpcs:ignore
		}
	}

	/**
	 * Get the user exited indexes
	 *
	 * @param $table_name
	 *
	 * @return array|null
	 */
	private function get_existed_indexes_of( $table_name ) {
		$result = $this->wpdb->get_results( "SHOW INDEX FROM {$table_name};", ARRAY_A ); // phpcs:ignore

		if ( false === $result ) {
			return null;
		}

		return ( new Collection( $result ) )
			->map( function ( $row ) {
				if ( ! isset( $row['Key_name'] ) ) {
					return null;
				}

				return $row['Key_name'];
			} )
			->filter()
			->values();
	}

	/**
	 * Get all the database indexes.
	 *
	 * @return Collection[]
	 */
	private function get_indexes() {
		$max_index_length = static::MAX_INDEX_LENGTH;

		return [
			$this->query->get_table_submissions() => new Collection( [
				'main_meta_id_index' => 'ADD INDEX `main_meta_id_index` (`main_meta_id`)',
				'hash_id_unique_index' => "ADD UNIQUE INDEX `hash_id_unique_index` (`hash_id` ({$max_index_length}))",
				'hash_id_index' => "ADD INDEX `hash_id_index` (`hash_id` ({$max_index_length}))",
				'type_index' => "ADD INDEX `type_index` (`type` ({$max_index_length}))",
				'post_id_index' => 'ADD INDEX `post_id_index` (`post_id`)',
				'element_id_index' => "ADD INDEX `element_id_index` (`element_id` ({$max_index_length}))",
				'campaign_id_index' => 'ADD INDEX `campaign_id_index` (`campaign_id`)',
				'user_id_index' => 'ADD INDEX `user_id_index` (`user_id`)',
				'user_ip_index' => 'ADD INDEX `user_ip_index` (`user_ip`)',
				'status_index' => 'ADD INDEX `status_index` (`status`)',
				'is_read_index' => 'ADD INDEX `is_read_index` (`is_read`)',
				'created_at_gmt_index' => 'ADD INDEX `created_at_gmt_index` (`created_at_gmt`)',
				'updated_at_gmt_index' => 'ADD INDEX `updated_at_gmt_index` (`updated_at_gmt`)',
				'created_at_index' => 'ADD INDEX `created_at_index` (`created_at`)',
				'updated_at_index' => 'ADD INDEX `updated_at_index` (`updated_at`)',
				'referer_index' => "ADD INDEX `referer_index` (`referer` ({$max_index_length}))",
				'referer_title_index' => "ADD INDEX `referer_title_index` (`referer_title` ({$max_index_length}))",
			] ),
			$this->query->get_table_submissions_values() => new Collection( [
				'submission_id_index' => 'ADD INDEX `submission_id_index` (`submission_id`)',
				'key_index' => "ADD INDEX `key_index` (`key` ({$max_index_length}))",
			] ),
			$this->query->get_table_form_actions_log() => new Collection( [
				'submission_id_index' => 'ADD INDEX `submission_id_index` (`submission_id`)',
				'action_name_index' => "ADD INDEX `action_name_index` (`action_name` ({$max_index_length}))",
				'status_index' => 'ADD INDEX `status_index` (`status`)',
				'created_at_gmt_index' => 'ADD INDEX `created_at_gmt_index` (`created_at_gmt`)',
				'updated_at_gmt_index' => 'ADD INDEX `updated_at_gmt_index` (`updated_at_gmt`)',
				'created_at_index' => 'ADD INDEX `created_at_index` (`created_at`)',
				'updated_at_index' => 'ADD INDEX `updated_at_index` (`updated_at`)',
			] ),
		];
	}
}