<?php
/**
 * POST /storebridge/v1/connection: connection state pushed by Storebridge Cloud.
 *
 * @package Storebridge
 */

declare( strict_types=1 );

namespace Storebridge\Inbound;

defined( 'ABSPATH' ) || exit;

use Storebridge\Contract\ConnectionUpdate;
use Storebridge\Settings;
use WP_Error;
use WP_REST_Request;
use WP_REST_Response;

/**
 * Stores connection updates (connected, reauth_required, suspended) sent by the cloud.
 */
final class ConnectionController {

	public const NAMESPACE = 'storebridge/v1';
	public const ROUTE     = '/connection';

	/**
	 * Constructor.
	 *
	 * @param Settings        $settings Plugin settings.
	 * @param RequestVerifier $verifier Signature verifier.
	 */
	public function __construct(
		private readonly Settings $settings,
		private readonly RequestVerifier $verifier
	) {}

	/**
	 * Register the route (on rest_api_init).
	 */
	public function register_routes(): void {
		register_rest_route(
			self::NAMESPACE,
			self::ROUTE,
			array(
				'methods'             => 'POST',
				'callback'            => array( $this, 'handle' ),
				'permission_callback' => array( $this->verifier, 'verify' ),
			)
		);
	}

	/**
	 * Store the update.
	 *
	 * @param WP_REST_Request $request Signed request from the cloud.
	 * @return WP_REST_Response|WP_Error
	 */
	public function handle( WP_REST_Request $request ) {
		$data = json_decode( $request->get_body(), true );
		try {
			$update = ConnectionUpdate::from_array( is_array( $data ) ? $data : array() );
		} catch ( \Throwable $e ) {
			return new WP_Error( 'storebridge_invalid_body', 'The connection update is invalid.', array( 'status' => 400 ) );
		}

		$this->settings->save_connection(
			array(
				'status' => $update->status->value,
				'tiktok' => $update->tiktok?->to_array(),
				'reason' => $update->reason?->to_array(),
			),
			$update->occurred_at
		);

		return new WP_REST_Response( null, 204 );
	}
}