<?php
/**
 * Main class.
 *
 * @package mihdan-index-now
 */

namespace Mihdan\IndexNow;

use Mihdan\IndexNow\Logger\Logger;
use Mihdan\IndexNow\Views\WPOSA;
use WP;
use WP_Post;

abstract class IndexNowAbstract implements SearchEngineInterface
{
	/**
	 * API key.
	 *
	 * @var string $api_key
	 */
	private $api_key;

	/**
	 * Logger instance.
	 *
	 * @var Logger $logger
	 */
	private $logger;

	/**
	 * WPOSA instance.
	 *
	 * @var WPOSA $wposa
	 */
	private $wposa;

	/**
	 * Post types.
	 *
	 * @var array[]
	 */
	private $post_types;

	/**
	 * Taxonomies.
	 *
	 * @var array[]
	 */
	private $taxonomies;

	/**
	 * IndexNowAbstract constructor.
	 *
	 * @param Logger $logger Logger instance.
	 */
	public function __construct(Logger $logger, WPOSA $wposa)
	{
		$this->logger     = $logger;
		$this->wposa      = $wposa;
		$this->post_types = apply_filters('crawlwp/post_types', (array)$this->wposa->get_option('post_types', 'general', []));
		$this->taxonomies = apply_filters('crawlwp/taxonomies', (array)$this->wposa->get_option('taxonomies', 'general', []));
		$this->api_key    = $this->wposa->get_option('api_key', 'index_now', Utils::generate_key());
	}

	public function setup_hooks()
	{
		if ( ! $this->is_enabled()) {
			return false;
		}

		add_action('parse_request', [$this, 'set_virtual_key_file']);
		add_action('crawlwp/post_added', [$this, 'ping_on_post_update'], 10, 2);
		add_action('crawlwp/post_updated', [$this, 'ping_on_post_update'], 10, 2);

		if ($this->is_ping_on_term()) {
			add_action('crawlwp/term_updated', [$this, 'ping_on_insert_term'], 10, 2);
		}
	}

	abstract protected function get_api_url(): string;

	abstract protected function get_bot_useragent(): string;

	public function is_enabled(): bool
	{
		return $this->wposa->get_option('enable', 'index_now', 'on') === 'on';
	}

	private function is_ping_on_term(): bool
	{
		return $this->wposa->get_option('ping_on_term', 'general', 'off') === 'on';
	}

	private function is_key_logging_enabled(): bool
	{
		return $this->wposa->get_option('key_logging', 'logs', 'on') === 'on';
	}

	private function get_current_search_engine(): string
	{
		return $this->wposa->get_option('search_engine', 'index_now', 'yandex-index-now');
	}

	private function rate_limit_db_key()
	{
		return sprintf('crawlwp_indexnow_%s_rate_limit_expiration', $this->get_current_search_engine());
	}

	/**
	 * Fires actions related to the transitioning of a post's status.
	 *
	 * @param int $post_id Post ID.
	 * @param WP_Post $post Post data.
	 *
	 * @link https://yandex.com/dev/webmaster/doc/dg/reference/host-recrawl-post.html
	 */
	public function ping_on_post_update(int $post_id, WP_Post $post)
	{
		$this->maybe_do_ping_post($post_id);
	}

	public function ping_on_insert_term(int $term_id, string $taxonomy)
	{
		$this->maybe_do_ping_term($term_id, $taxonomy);
	}

	private function maybe_do_ping_post(int $post_id)
	{
		if ($this->get_current_search_engine() === $this->get_slug()) {
			$this->push([Utils::normalized_get_permalink($post_id)]);

			do_action('crawlwp/index_pinged', 'post', $post_id);
		}
	}

	private function maybe_do_ping_term(int $term_id, string $taxonomy)
	{
		if ( ! in_array($taxonomy, $this->get_taxonomies(), true)) {
			return;
		}

		if ($this->get_current_search_engine() === $this->get_slug()) {
			$this->push([Utils::normalized_get_term_link($term_id, $taxonomy)]);

			do_action('crawlwp/index_pinged', 'taxonomy', $term_id);
		}
	}

	public function set_api_url(string $url): bool
	{
		$this->api_url = $url;

		return true;
	}

	private function get_post_types(): array
	{
		return $this->post_types;
	}

	private function get_taxonomies(): array
	{
		return $this->taxonomies;
	}

	/**
	 * Get host name.
	 *
	 * @return string
	 */
	private function get_host()
	{
		return apply_filters('crawlwp/host', wp_parse_url(Utils::normalized_home_url(), PHP_URL_HOST));
	}

	public function push(array $url_list): bool
	{
		if (time() < (int)get_option($this->rate_limit_db_key(), 0)) return false;

		$args = [
			'timeout' => 30,
			'body'    => wp_json_encode(
				[
					'host'        => $this->get_host(),
					'key'         => $this->get_api_key(),
					'keyLocation' => $this->get_api_key_location(),
					'urlList'     => $url_list,
				]
			),
			'headers' => [
				'Content-Type' => 'application/json',
			],
		];

		$response = wp_remote_post($this->get_api_url(), $args);

		$body             = wp_remote_retrieve_body($response);
		$status_code      = wp_remote_retrieve_response_code($response);
		$response_message = wp_remote_retrieve_response_message($response);

		if (Utils::is_json($body)) {
			$body = json_decode($body, true);
		}

		$data = [
			'status_code'   => $status_code,
			'search_engine' => $this->get_current_search_engine(),
		];

		if ($status_code >= 400 && $status_code < 500) {
			update_option($this->rate_limit_db_key(), time() + (3 * HOUR_IN_SECONDS));
		}

		if (Utils::is_response_code_success($status_code)) {
			foreach ($url_list as $url) {
				$message = sprintf('<a href="%s" target="_blank">%s</a> - OK', $url, $url);
				$this->logger->info($message, $data);
			}
		} else {

			if ( ! empty($body['message'])) {
				$message = $body['message'];
			} elseif ( ! empty($body)) {
				$message = print_r($body, 1); // phpcs:ignore WordPress.PHP.DevelopmentFunctions.error_log_print_r
			} elseif ( ! empty($response_message)) {
				$message = $response_message;
			} else {
				$message = '';
			}

			$this->logger->error($message, $data);
		}

		return true;
	}

	/**
	 * Get API key.
	 *
	 * @return string
	 */
	private function get_api_key()
	{
		return $this->api_key;
	}

	/**
	 * Get virtual API key location.
	 *
	 * @return string
	 */
	private function get_api_key_location(): string
	{
		return trailingslashit(Utils::normalized_home_url()) . $this->get_api_key() . '.txt';
	}

	/**
	 * Set virtual key file.
	 *
	 * @param WP $wp WP instance.
	 */
	public function set_virtual_key_file(WP $wp)
	{
		if ( ! get_option('permalink_structure')) {
			return;
		}

		$api_key = $this->get_api_key();

		if ($wp->request !== $api_key . '.txt') {
			return;
		}

		// Exclude key file from cache.
		if ( ! defined('DONOTCACHEPAGE')) {
			define('DONOTCACHEPAGE', true);
		}

		if ($this->is_key_logging_enabled()) {
			$data = [
				'search_engine' => $this->get_current_search_engine(),
				'direction'     => 'incoming',
			];

			$this->logger->info(__('Bot checked the key file', 'mihdan-index-now'), $data);
		}

		header('Content-Type: text/plain');
		header('X-Robots-Tag: noindex');
		status_header(200);
		echo esc_html($api_key);
		die;
	}
}