<?php
/**
 * Gateway blacklist into the opt-out list.
 *
 * @package Rahkar\WP
 */

declare( strict_types = 1 );

namespace Rahkar\WP\Notifications;

use Rahkar\WP\Contracts\ReportingDriver;
use Rahkar\WP\Queue\Queue;
use Rahkar\WP\Support\Hooks;

defined( 'ABSPATH' ) || exit;

/**
 * After a promotional message is accepted, reads the gateway's report for it
 * and puts a blacklisted recipient on the opt-out list (source `provider`).
 *
 * The gateway itself honours a reply of "11": it blacklists the number and
 * drops later messages to it. Without this check the plugin would never know,
 * and would keep entering that customer into flows, spending their weekly cap
 * and issuing coupons nobody receives. Once on the list, the send rules keep
 * them out like any other opt-out (DATA-MODEL.md §4-15 in rahkar-foroosh).
 *
 * The report is final only once the operator has answered, so the check comes
 * back a few times: 15 minutes after the send, then an hour, six and a day.
 */
final class BlacklistCheck {

	/**
	 * Delay before each try, in seconds.
	 */
	private const DELAYS = [ 900, 3600, 21600, 86400 ];

	/**
	 * Queue the first check of one send.
	 *
	 * @param string $gateway           Driver id.
	 * @param string $providerMessageId Id the gateway returned.
	 */
	public static function schedule( string $gateway, string $providerMessageId ): void {
		Queue::push( Hooks::BLACKLIST_CHECK, [ 'gateway' => $gateway, 'id' => $providerMessageId, 'try' => 0 ], self::DELAYS[0], 40 );
	}

	/**
	 * One check.
	 *
	 * @param array<string, mixed> $payload Job payload.
	 *
	 * @internal Hooked to the check job.
	 */
	public function run( array $payload ): void {
		$driver = DriverRegistry::get( DriverRegistry::CHANNEL_SMS, (string) ( $payload['gateway'] ?? '' ) );
		$id     = (string) ( $payload['id'] ?? '' );
		$try    = (int) ( $payload['try'] ?? 0 );

		if ( ! $driver instanceof ReportingDriver || '' === $id ) {
			return;
		}

		$listed = $driver->blacklisted( $id );

		if ( null === $listed ) {
			$next = $try + 1;

			// Still not final after a day: the operator never answered, and there is
			// nothing more to learn.
			if ( isset( self::DELAYS[ $next ] ) ) {
				Queue::push( Hooks::BLACKLIST_CHECK, [ 'gateway' => $payload['gateway'], 'id' => $id, 'try' => $next ], self::DELAYS[ $next ], 40 );
			}

			return;
		}

		// A number already on the list stays as it is: the insert ignores repeats.
		foreach ( $listed as $phone ) {
			Optouts::add( $phone, 'provider' );
		}
	}
}