<?php
/**
 * The status panel's numbers.
 *
 * @package CortexCommerce
 */

namespace CortexCommerce\Sync;

use CortexCommerce\Settings\Options;
use CortexCommerce\Support\Log;
use CortexCommerce\Support\SignedClient;

defined( 'ABSPATH' ) || exit;

/**
 * POST /webhooks/woo/stats: what CortexCommerce did for this store. Short timeout, because an admin page waits for it;
 * a good answer is cached for five minutes, a failure for one minute (as a marker, never as numbers).
 */
final class StatsApi {

	const PATH    = '/webhooks/woo/stats';
	const TTL     = 300;
	const TIMEOUT = 5;

	/**
	 * After a failure the panel shows dashes for this long without calling the backend, so a hanging backend costs one
	 * 5 s wait a minute, not one per page load.
	 */
	const FAILURE_TTL = 60;

	const COUNTS = array( 'products_synced', 'products_enriched', 'products_live', 'awaiting_review' );

	/**
	 * @return array{products_synced: int, products_enriched: int, products_live: int, awaiting_review: int, store_blocked: bool}|null
	 */
	public static function fetch(): ?array {
		if ( ! Options::is_connected() ) {
			return null;
		}
		$cached = self::parse( get_transient( Options::STATS_TRANSIENT ) );
		if ( null !== $cached ) {
			return $cached;
		}
		if ( false !== get_transient( Options::STATS_FAILED_TRANSIENT ) ) {
			return null;
		}
		$response = SignedClient::post( self::PATH, SignedClient::body( array() ), self::TIMEOUT );
		if ( ! $response->ok() ) {
			Log::warning( sprintf( 'Status panel: CortexCommerce did not give the numbers (%s).', $response->describe() ) );
			set_transient( Options::STATS_FAILED_TRANSIENT, 1, self::FAILURE_TTL );
			return null;
		}
		$stats = self::parse( $response->json );
		if ( null === $stats ) {
			Log::error( 'Status panel: CortexCommerce answered the numbers request with an unexpected body.' );
			set_transient( Options::STATS_FAILED_TRANSIENT, 1, self::FAILURE_TTL );
			return null;
		}
		set_transient( Options::STATS_TRANSIENT, $stats, self::TTL );
		return $stats;
	}

	/**
	 * @param mixed $raw Decoded body or cached value.
	 * @return array{products_synced: int, products_enriched: int, products_live: int, awaiting_review: int, store_blocked: bool}|null
	 */
	private static function parse( $raw ): ?array {
		if ( ! is_array( $raw ) || ! isset( $raw['store_blocked'] ) || ! is_bool( $raw['store_blocked'] ) ) {
			return null;
		}
		foreach ( self::COUNTS as $key ) {
			if ( ! isset( $raw[ $key ] ) || ! is_int( $raw[ $key ] ) || $raw[ $key ] < 0 ) {
				return null;
			}
		}
		return array(
			'products_synced'   => $raw['products_synced'],
			'products_enriched' => $raw['products_enriched'],
			'products_live'     => $raw['products_live'],
			'awaiting_review'   => $raw['awaiting_review'],
			'store_blocked'     => $raw['store_blocked'],
		);
	}
}