<?php
/**
 * Manager opt-in, recovery controls and local WordPress scheduling.
 *
 * @package Abientot
 */

namespace Abientot\Reminders;

use Abientot\Admin\RedirectNotice;
use Abientot\Support\Input;
use Abientot\Support\Request;

if ( ! defined( 'ABSPATH' ) ) {
	exit;
}

require_once __DIR__ . '/Service.php';

final class Module {
	public const HOOK     = 'abientot_reminders_tick';
	public const SCHEDULE = 'abientot_reminders_five_minutes';
	public const LAST_RUN = 'abientot_reminders_last_run';
	public const RETRY    = 'abientot_reminders_schema_retry';
	private const ACTION  = 'abientot_reminders_manage';

	private Repository $repository;
	private Service $service;
	private bool $ready = false;

	public function __construct( ?Repository $repository = null, ?Service $service = null ) {
		$this->repository = $repository ?? new Repository();
		$this->service    = $service ?? new Service( $this->repository );
	}

	/** Ordinary requests trust the stored schema version (no SHOW queries); the worker, settings page and setup verify the table. A failed creation is retried at most hourly. */
	public function register(): void {
		if ( get_option( Migrator::OPTION, '' ) === '' && ! get_transient( self::RETRY ) && ! Migrator::ensure() ) {
			set_transient( self::RETRY, 1, HOUR_IN_SECONDS );
		}
		$this->ready = get_option( Migrator::OPTION, '' ) === Migrator::VERSION;
		add_filter( 'cron_schedules', array( $this, 'schedules' ) );
		add_filter( 'abientot_register_admin_modules', array( $this, 'modules' ) );
		add_filter( 'abientot_render_admin_module', array( $this, 'render' ), 10, 2 );
		add_action( 'admin_post_' . self::ACTION, array( $this, 'manage' ) );
		add_action( self::HOOK, array( $this, 'tick' ) );
		add_action( 'abientot_booking_committed', array( $this, 'booking_committed' ), 10, 4 );
	}

	/** Explicit activation/setup recovery; ordinary views remain read-only. */
	public static function restore_schedule(): bool {
		$module        = new self();
		$module->ready = get_option( Migrator::OPTION, '' ) === Migrator::VERSION && Migrator::verified();
		if ( ! $module->ready ) {
			return false;
		}
		add_filter( 'cron_schedules', array( $module, 'schedules' ) );
		try {
			$module->schedule();
			return true;
		} finally {
			remove_filter( 'cron_schedules', array( $module, 'schedules' ) );
		}
	}

	public function schedules( array $schedules ): array {
		$schedules[ self::SCHEDULE ] = array(
			'interval' => 300,
			'display'  => __( 'Every five minutes', 'abientot' ),
		);
		return $schedules;
	}

	public function schedule(): void {
		$enabled = $this->ready && $this->repository->settings()['enabled'];
		if ( ! $enabled ) {
			$result = wp_clear_scheduled_hook( self::HOOK, array(), true );
			if ( is_wp_error( $result ) || $result === false ) {
				throw new \RuntimeException( 'reminder_unschedule' );
			}
			return;
		}
		if ( ! wp_next_scheduled( self::HOOK ) ) {
			$result = wp_schedule_event( time() + 60, self::SCHEDULE, self::HOOK, array(), true );
			if ( is_wp_error( $result ) || $result === false ) {
				throw new \RuntimeException( 'reminder_schedule' );
			}
		}
	}

	/** Observable worker progress; read-only pages never update this checkpoint. */
	public function tick(): void {
		if ( ! $this->ready || ! Migrator::verified() ) {
			return;
		}
		$health = array(
			'at'       => time(),
			'state'    => 'finished',
			'accepted' => 0,
		);
		try {
			$health['accepted'] = $this->service->run();
		} catch ( \Throwable $error ) {
			$health['state'] = 'failed';
		}
		try {
			update_option( self::LAST_RUN, $health, false );
		} catch ( \Throwable $error ) {
			unset( $error ); // The queue remains the durable record if health storage fails.
		}
	}

	public function health(): array {
		$last = get_option( self::LAST_RUN, array() );
		$last = is_array( $last ) && isset( $last['at'], $last['state'] ) && is_int( $last['at'] ) && $last['at'] > 0 && in_array( $last['state'], array( 'finished', 'failed' ), true ) ? $last : null;
		$next = wp_next_scheduled( self::HOOK );
		return array(
			'last'    => $last,
			'next'    => $next ? $next : null,
			'overdue' => $next && $next < time() - 10 * MINUTE_IN_SECONDS,
		);
	}

	public function booking_committed( string $operation, int $id, ?array $before = null, array $after = array() ): void {
		if ( ! $this->ready ) {
			return;
		}
		global $wpdb;
		$suppressed = $wpdb->suppress_errors( true );
		try {
			if ( ! $this->repository->settings()['enabled'] ) {
				return;
			}
			$this->repository->sync( $id, time() );
		} catch ( \Throwable $error ) {
			unset( $error ); // Bounded reconciliation recovers missed lifecycle events without corrupting booking responses.
		} finally {
			$wpdb->suppress_errors( $suppressed );
		}
	}

	public function modules( array $modules ): array {
		$modules['reminders'] = array(
			'title'       => __( 'Email reminders', 'abientot' ),
			'menu_title'  => __( 'Email reminders', 'abientot' ),
			'capability'  => 'abientot_manage_settings',
			'description' => __( 'Enable booking reminders and review delivery attempts.', 'abientot' ),
		);
		return $modules;
	}

	public function render( bool $rendered, string $module ): bool {
		if ( $module !== 'reminders' ) {
			return $rendered;
		}
		$this->page();
		return true;
	}

	public function manage(): void {
		$input = Input::post( self::ACTION );
		if ( ! current_user_can( 'abientot_manage_settings' ) ) {
			wp_die( esc_html__( 'You do not have permission to manage settings.', 'abientot' ), '', array( 'response' => 403 ) );
		}
		if ( ! Request::is_post() ) {
			wp_die( esc_html__( 'Invalid request.', 'abientot' ), '', array( 'response' => 405 ) );
		}
		$code = 'saved';
		try {
			$this->ready = Migrator::ensure();
			if ( ! $this->ready ) {
				throw new \RuntimeException( 'reminder_schema' );
			}
			$operation = $input->key( 'operation' );
			if ( $operation === 'save' ) {
				$lead    = $input->has( 'lead_hours' ) ? filter_var( $input->text( 'lead_hours' ), FILTER_VALIDATE_INT ) : false;
				$subject = $input->text( 'subject' );
				$body    = $input->html( 'body' );
				if ( $lead === false || $lead < 1 || $lead > 168 || trim( $subject ) === '' || trim( $body ) === '' ) {
					throw new \DomainException( 'reminder_input' );
				}
				$this->repository->configure(
					array(
						'enabled'    => '1' === $input->key( 'enabled' ),
						'lead_hours' => $lead,
						'subject'    => $subject,
						'body'       => $body,
					),
					time()
				);
				$this->schedule();
			} elseif ( in_array( $operation, array( 'retry', 'dismiss' ), true ) ) {
				$id = $input->has( 'job_id' ) ? filter_var( $input->text( 'job_id' ), FILTER_VALIDATE_INT ) : false;
				if ( ! $id || $id < 1 ) {
					throw new \DomainException( 'reminder_input' );
				}
				$this->repository->intervene( $id, $operation, '1' === $input->key( 'acknowledge' ), time() );
			} else {
				throw new \DomainException( 'reminder_input' );
			}
		} catch ( \Throwable $error ) {
			$code = 'failed';
		}
		wp_safe_redirect( RedirectNotice::url( admin_url( 'admin.php?page=abientot-settings&tab=communication' ), array( 'reminder_result' => $code ) ) );
		exit;
	}

	private function hidden( string $operation ): void {
		wp_nonce_field( self::ACTION );
		echo '<input type="hidden" name="action" value="' . esc_attr( self::ACTION ) . '"><input type="hidden" name="operation" value="' . esc_attr( $operation ) . '">';
	}

	public function page(): void {
		if ( ! current_user_can( 'abientot_manage_settings' ) ) {
			wp_die( esc_html__( 'You do not have permission to manage settings.', 'abientot' ) );
		}
		echo '<div class="wrap abientot-commercial-section"><h1>' . esc_html__( 'Email reminders', 'abientot' ) . '</h1>';
		if ( ! $this->ready || ! Migrator::verified() ) {
			echo '<p>' . esc_html__( 'Reminder storage is unavailable. No reminder will be sent.', 'abientot' ) . '</p></div>';
			return;
		}
		try {
			$settings = $this->repository->settings();
			$page     = $this->repository->page( max( 1, (int) Request::view( 'reminder_page', 'int' ) ) );
		} catch ( \Throwable $error ) {
			echo '<p>' . esc_html__( 'Reminder storage is unavailable. No reminder will be sent.', 'abientot' ) . '</p></div>';
			return;
		}
		$notice = RedirectNotice::get( 'reminder_result' );
		if ( in_array( $notice, array( 'saved', 'failed' ), true ) ) {
			echo '<div class="notice ' . ( $notice === 'saved' ? 'notice-success' : 'notice-error' ) . '"><p>' . esc_html( $notice === 'saved' ? __( 'Reminder settings or queue updated.', 'abientot' ) : __( 'The reminder action could not be completed. Review the settings and delivery state before trying again.', 'abientot' ) ) . '</p></div>';
		}
		$health = $this->health();
		?>
	<p><?php esc_html_e( 'Send customers an email before their appointment. Choose when to send it below.', 'abientot' ); ?></p>
	<form method="post" action="<?php echo esc_url( admin_url( 'admin-post.php' ) ); ?>">
		<?php $this->hidden( 'save' ); ?>
		<table class="form-table">
			<tr>
				<th><?php esc_html_e( 'Enable reminders', 'abientot' ); ?></th>
				<td><label><input type="checkbox" name="enabled" value="1" <?php checked( $settings['enabled'] ); ?>> <?php esc_html_e( 'Send email reminders for future active bookings', 'abientot' ); ?></label></td>
			</tr>
			<tr>
				<th><label for="reminder-lead"><?php esc_html_e( 'Send how many hours before?', 'abientot' ); ?></label></th>
				<td><input id="reminder-lead" type="number" name="lead_hours" min="1" max="168" required value="<?php echo esc_attr( $settings['lead_hours'] ); ?>"><p><?php esc_html_e( 'A future booking already inside this interval may receive its reminder on the next run.', 'abientot' ); ?></p></td>
			</tr>
			<tr>
				<th><label for="reminder-subject"><?php esc_html_e( 'Reminder subject', 'abientot' ); ?></label></th>
				<td><input class="large-text" id="reminder-subject" name="subject" required value="<?php echo esc_attr( $settings['subject'] ); ?>"></td>
			</tr>
			<tr>
				<th><label for="reminder-body"><?php esc_html_e( 'Reminder message', 'abientot' ); ?></label></th>
				<td>
					<textarea class="large-text" rows="8" id="reminder-body" name="body" required><?php echo esc_textarea( $settings['body'] ); ?></textarea>
					<details><summary><?php esc_html_e( 'Message variables', 'abientot' ); ?></summary><p><?php esc_html_e( 'Available placeholders: {business_name}, {customer_name}, {service_name}, {staff_name}, {location_name}, {start}, {status}. Basic HTML is allowed.', 'abientot' ); ?></p></details>
				</td>
			</tr>
		</table>
		<button class="button button-primary"><?php esc_html_e( 'Save reminder settings', 'abientot' ); ?></button>
	</form>
	<details <?php echo ( $settings['enabled'] && ( $health['overdue'] || ! wp_next_scheduled( self::HOOK ) || ( $health['last']['state'] ?? '' ) === 'failed' ) ) ? 'open' : ''; ?>>
		<summary><?php esc_html_e( 'Automatic sending', 'abientot' ); ?></summary>
		<p>
		<?php
		if ( $health['last'] ) {
			/* translators: %s: localized date and time of the worker run. */
			echo esc_html( sprintf( __( 'Last scheduled run: %s', 'abientot' ), \Abientot\Support\Locale::date( \Abientot\Support\DateTimeHelper::datetime_display_format(), $health['last']['at'] ) ) );
			echo ' ' . esc_html( $health['last']['state'] === 'failed' ? __( 'The last check failed. Review the email results below.', 'abientot' ) : __( 'The last check finished. See the email results below.', 'abientot' ) );
		} else {
			esc_html_e( 'No scheduled run has been recorded yet.', 'abientot' );
		}
		?>
		</p>
		<?php if ( $settings['enabled'] && $health['overdue'] ) : ?>
			<p role="alert"><?php esc_html_e( 'Automatic sending is delayed. Ask your website administrator to check scheduled tasks.', 'abientot' ); ?></p>
		<?php endif; ?>
	</details>
	<h2><?php esc_html_e( 'Reminder activity', 'abientot' ); ?></h2>
	<p>
		<?php
		if ( ! $settings['enabled'] ) {
			esc_html_e( 'Automatic reminders are disabled.', 'abientot' );
		} elseif ( wp_next_scheduled( self::HOOK ) ) {
			esc_html_e( 'Automatic reminders are scheduled.', 'abientot' );
		} else {
			esc_html_e( 'Reminders are enabled but no automatic run is scheduled. Save settings again to retry scheduling.', 'abientot' );
		}
		?>
	</p>
	<p><?php esc_html_e( 'Email marked as sent was passed to your email service. Check with the customer before sending again.', 'abientot' ); ?></p>
	<table class="widefat striped">
		<thead><tr>
		<?php
		foreach ( array( __( 'Booking', 'abientot' ), __( 'State', 'abientot' ), __( 'Due', 'abientot' ), __( 'Attempts', 'abientot' ), __( 'Last result', 'abientot' ), __( 'Actions', 'abientot' ) ) as $label ) {
			echo '<th>' . esc_html( $label ) . '</th>';
		}
		?>
		</tr></thead>
		<tbody>
		<?php foreach ( $page['rows'] as $row ) : ?>
			<tr>
				<td><?php echo wp_kses_post( \Abientot\Admin\RecordPicker::summary( (int) $row['appointment_id'], 'finance' ) ); ?></td>
				<td><?php echo esc_html( self::state_label( $row['state'] ) ); ?></td>
				<td><?php echo esc_html( \Abientot\Support\DateTimeHelper::format_utc_datetime( $row['due_at'] ) ); ?></td>
				<td><?php echo esc_html( $row['attempts'] ); ?></td>
				<td><?php echo esc_html( self::result_label( $row['last_code'] ?? '' ) ); ?></td>
				<td>
				<?php if ( in_array( $row['state'], array( 'failed', 'uncertain' ), true ) ) : ?>
					<form method="post" action="<?php echo esc_url( admin_url( 'admin-post.php' ) ); ?>">
						<?php wp_nonce_field( self::ACTION ); ?>
						<input type="hidden" name="action" value="<?php echo esc_attr( self::ACTION ); ?>">
						<input type="hidden" name="job_id" value="<?php echo esc_attr( $row['id'] ); ?>">
						<label><input type="checkbox" name="acknowledge" value="1"> <?php esc_html_e( 'I checked this attempt and accept the risk of a duplicate message.', 'abientot' ); ?></label>
						<button class="button" name="operation" value="retry"><?php esc_html_e( 'Retry reminder', 'abientot' ); ?></button>
						<button class="button" name="operation" value="dismiss"><?php esc_html_e( 'Dismiss', 'abientot' ); ?></button>
					</form>
				<?php endif; ?>
				</td>
			</tr>
		<?php endforeach; ?>
		<?php if ( ! $page['rows'] ) : ?>
			<tr><td colspan="6"><?php esc_html_e( 'No reminders in the queue.', 'abientot' ); ?></td></tr>
		<?php endif; ?>
		</tbody>
	</table>
	<p>
		<?php
		/* translators: 1: current page number, 2: number of pages, 3: number of reminders in the queue. */
		echo esc_html( sprintf( __( 'Page %1$d of %2$d (%3$d reminders)', 'abientot' ), $page['page'], $page['pages'], $page['total'] ) );
		for ( $number = 1; $number <= $page['pages']; ++$number ) {
			if ( abs( $number - $page['page'] ) <= 2 ) {
				echo ' <a href="' . esc_url(
					add_query_arg(
						array(
							'page'          => 'abientot-settings',
							'tab'           => 'communication',
							'reminder_page' => $number,
						),
						admin_url( 'admin.php' )
					)
				) . '">' . esc_html( $number ) . '</a>';
			}
		}
		?>
	</p>
	</div>
		<?php
	}

	private static function state_label( string $state ): string {
		$labels = array(
			'pending'   => __( 'Pending', 'abientot' ),
			'leased'    => __( 'Preparing delivery', 'abientot' ),
			'sending'   => __( 'Sending', 'abientot' ),
			'retry'     => __( 'Retry scheduled', 'abientot' ),
			'sent'      => __( 'Sent', 'abientot' ),
			'cancelled' => __( 'Cancelled', 'abientot' ),
			'expired'   => __( 'Expired', 'abientot' ),
			'uncertain' => __( 'Uncertain — review required', 'abientot' ),
			'failed'    => __( 'Failed — review required', 'abientot' ),
		);
		return $labels[ $state ] ?? __( 'Unknown', 'abientot' );
	}

	private static function result_label( string $code ): string {
		$labels = array(
			''                    => __( 'No delivery attempt', 'abientot' ),
			'sent'                => __( 'Mail transport accepted the message', 'abientot' ),
			'transport_false'     => __( 'Mail transport rejected the message', 'abientot' ),
			'transport_exception' => __( 'Delivery interrupted; outcome unknown', 'abientot' ),
			'lease_expired'       => __( 'Worker stopped before completing the attempt', 'abientot' ),
			'disabled'            => __( 'Reminders disabled', 'abientot' ),
			'booking_changed'     => __( 'Booking changed', 'abientot' ),
			'booking_unavailable' => __( 'Booking is no longer eligible', 'abientot' ),
			'not_deliverable'     => __( 'Current booking or recipient is not eligible', 'abientot' ),
			'manager_retry'       => __( 'Manager requested a retry', 'abientot' ),
			'manager_dismissed'   => __( 'Manager dismissed this reminder', 'abientot' ),
		);
		return $labels[ $code ] ?? __( 'Review required', 'abientot' );
	}
}