<?php
if ( ! defined( 'ABSPATH' ) ) {
    exit;
}
if ( ! class_exists( 'ACHP_Admin' ) ) {
    class ACHP_Admin {

        const TOKEN_REFRESH_HOOK = 'achp_create_new_token';
        const POLL_NOW_NONCE     = 'achp_run_poll_now';
        const PURGE_NONCE        = 'achp_purge_schedules';

        public function __construct() {
            add_action( 'init', [ $this, 'intilize_cron_task' ] );
            add_action( self::TOKEN_REFRESH_HOOK, [ $this, 'refresh_token' ] );
            add_action( 'add_option_woocommerce_ach_processing_settings', [ $this, 'refresh_token' ], 10, 0 );
            add_action( 'update_option_woocommerce_ach_processing_settings', [ $this, 'refresh_token' ], 10, 0 );
            add_action( 'admin_notices', [ $this, 'add_token_notice' ] );
            add_action( 'woocommerce_api_ach_processing', [ $this, 'webhook_callback' ] );
            add_action( 'wp_ajax_achp_run_poll_now', [ $this, 'ajax_run_poll_now' ] );
            add_action( 'wp_ajax_achp_purge_schedules', [ $this, 'ajax_purge_schedules' ] );
        }

        /**
         * Manual trigger for ACHP_Status_Poller::purge_all_scheduled(), fired
         * by the "Purge Stale Schedules" button on the gateway settings
         * screen. Use this to force cleanup on demand rather than waiting
         * for the version-gated migration to run on the next page load.
         */
        public function ajax_purge_schedules() {
            if ( ! current_user_can( 'manage_woocommerce' ) ) {
                wp_send_json_error(
                    [ 'message' => __( 'You do not have permission to do this.', ACHP_TEXT_DOMAIN ) ],
                    403
                );
            }
            check_ajax_referer( self::PURGE_NONCE, 'nonce' );

            if ( ! class_exists( 'ACHP_Status_Poller' ) ) {
                wp_send_json_error(
                    [ 'message' => __( 'Status poller is not available.', ACHP_TEXT_DOMAIN ) ],
                    500
                );
            }

            try {
                $cancelled = ACHP_Status_Poller::purge_all_scheduled();
            } catch ( \Throwable $e ) {
                wc_get_logger()->error(
                    sprintf( 'Manual schedule purge failed: %s', $e->getMessage() ),
                    [ 'source' => 'ach-processing' ]
                );
                wp_send_json_error(
                    [ 'message' => __( 'Purge failed. See WooCommerce → Status → Logs (ach-processing) for details.', ACHP_TEXT_DOMAIN ) ],
                    500
                );
            }

            $summary = sprintf(
                /* translators: %d: number of stale scheduled actions removed. */
                _n(
                    'Purge complete. Removed %d stale scheduled action.',
                    'Purge complete. Removed %d stale scheduled actions.',
                    (int) $cancelled,
                    ACHP_TEXT_DOMAIN
                ),
                (int) $cancelled
            );

            wp_send_json_success( [
                'message'   => $summary,
                'cancelled' => (int) $cancelled,
            ] );
        }

        /**
         * Manual trigger for the status poller, fired by the "Check Status"
         * button on the gateway settings screen.
         */
        public function ajax_run_poll_now() {
            if ( ! current_user_can( 'manage_woocommerce' ) ) {
                wp_send_json_error(
                    [ 'message' => __( 'You do not have permission to run the status check.', ACHP_TEXT_DOMAIN ) ],
                    403
                );
            }
            check_ajax_referer( self::POLL_NOW_NONCE, 'nonce' );

            if ( ! class_exists( 'ACHP_Status_Poller' ) ) {
                wp_send_json_error(
                    [ 'message' => __( 'Status poller is not available.', ACHP_TEXT_DOMAIN ) ],
                    500
                );
            }

            try {
                $stats = ACHP_Status_Poller::run( true ); // Manual trigger bypasses the scheduling floor.
            } catch ( \Throwable $e ) {
                wc_get_logger()->error(
                    sprintf( 'Manual status poll failed: %s', $e->getMessage() ),
                    [ 'source' => 'ach-processing' ]
                );
                wp_send_json_error(
                    [ 'message' => __( 'Status check failed. See WooCommerce → Status → Logs (ach-processing) for details.', ACHP_TEXT_DOMAIN ) ],
                    500
                );
            }

            $stats   = is_array( $stats ) ? $stats : [];
            $updated = (int) ( $stats['updated'] ?? 0 );
            $summary = sprintf(
                /* translators: %d: number of orders whose status was updated. */
                _n(
                    'Status check complete. %d order updated.',
                    'Status check complete. %d orders updated.',
                    $updated,
                    ACHP_TEXT_DOMAIN
                ),
                $updated
            );

            wp_send_json_success( [
                'message' => $summary,
                'stats'   => $stats,
            ] );
        }

        public function webhook_callback() {
            $request_body = file_get_contents( 'php://input' );
            wc_get_logger()->debug( print_r( $request_body, true ), [ 'source' => 'ach-processing-webhook' ] );
        }

        public function add_token_notice() {
            // Only surface this on the WooCommerce settings screen to avoid
            // polluting every admin page.
            $screen = function_exists( 'get_current_screen' ) ? get_current_screen() : null;
            if ( ! $screen || 'woocommerce_page_wc-settings' !== $screen->id ) {
                return;
            }

            $token  = get_option( 'achp_access_token' );
            $expiry = (int) get_option( 'achp_access_token_expiry' );
            $now    = time();

            $missing = empty( $token ) || 0 === $expiry;
            $expired = ! $missing && $now > $expiry;

            if ( ! $missing && ! $expired ) {
                return;
            }

            $message = $missing
                ? __( 'ACH Processing access token is missing. Verify API credentials and save settings to generate one.', ACHP_TEXT_DOMAIN )
                : __( 'ACH Processing access token has expired. It will be refreshed automatically on the next scheduled run.', ACHP_TEXT_DOMAIN );
            ?>
            <div class="notice notice-error">
                <p><?php echo esc_html( $message ); ?></p>
            </div>
            <?php
        }

        /**
         * Refresh the API token via ACHP_Main_Class. Wired to settings-save
         * hooks and to the recurring Action Scheduler job.
         */
        public function refresh_token() {
            ACHP_Main_Class::refreshAccessToken();
        }

        public function intilize_cron_task() {
            if ( ! function_exists( 'as_next_scheduled_action' ) ) {
                return;
            }
            if ( false === as_next_scheduled_action( self::TOKEN_REFRESH_HOOK ) ) {
                // Run the first refresh almost immediately so fresh
                // installs/activations don't spend the initial 2h window
                // without a valid token.
                as_schedule_recurring_action(
                    time() + MINUTE_IN_SECONDS,
                    2 * HOUR_IN_SECONDS,
                    self::TOKEN_REFRESH_HOOK,
                    [],
                    __( 'ACH Processing token refresh', ACHP_TEXT_DOMAIN )
                );
            }
        }
    }
    new ACHP_Admin();
}