<?php
/**
 * Hub directives.
 *
 * @package Rahkar\WP
 */

declare( strict_types = 1 );

namespace Rahkar\WP\Modules\HubConnector;

use Rahkar\WP\Queue\Queue;
use Rahkar\WP\Support\Hooks;
use Rahkar\WP\Support\Logger;

defined( 'ABSPATH' ) || exit;

/**
 * What the hub asks of this site in its answers (EVENTS-v1.md §3-6).
 *
 * Every directive only makes the plugin send data again, or send it more slowly.
 * None changes anything in the store or sends a message, and an unknown one is
 * ignored. That is the whole of the hub's say over the site.
 */
final class Directives {

	/**
	 * Apply the directives of one answer.
	 *
	 * @param mixed $directives The `directives` list.
	 */
	public static function apply( $directives ): void {
		if ( ! is_array( $directives ) ) {
			return;
		}

		foreach ( $directives as $directive ) {
			if ( ! is_array( $directive ) ) {
				continue;
			}

			$type   = (string) ( $directive['type'] ?? '' );
			$entity = (string) ( $directive['entity'] ?? '' );

			if ( 'backfill' === $type && in_array( $entity, Backfill::ENTITIES, true ) ) {
				Backfill::start( $entity );
			} elseif ( 'resync' === $type && in_array( $entity, Backfill::ENTITIES, true ) ) {
				$since = strtotime( (string) ( $directive['since'] ?? '' ) );

				Queue::push(
					Hooks::HUB_RECONCILE,
					[
						'entity' => $entity,
						'since'  => false === $since ? time() - DAY_IN_SECONDS : $since,
					],
					5,
					30,
					'hub:resync'
				);
			} elseif ( 'throttle' === $type ) {
				( new State() )->update( [ 'min_interval' => max( 0, min( DAY_IN_SECONDS, (int) ( $directive['min_interval'] ?? 0 ) ) ) ] );
			} else {
				continue;
			}

			Logger::info( 'hub', 'Applied a hub directive.', [ 'directive' => $directive ] );
		}
	}
}