<?php
if ( ! defined( 'ABSPATH' ) ) exit;

/**
 * Bulk Generation AJAX Handlers
 * 
 * Handles all AJAX requests for bulk image generation
 *
 * @package All_Sources_Images
 * @since 6.1.7
 */

if ( ! defined( 'ABSPATH' ) ) {
    exit;
}

class ALLSI_Bulk_Generation_Ajax {

    /**
     * Constructor - register AJAX handlers
     */
    public function __construct() {
        // Load items for selection
        add_action( 'wp_ajax_allsi_bulk_load_items', array( $this, 'load_items' ) );
        
        // Job management
        add_action( 'wp_ajax_allsi_bulk_create_job', array( $this, 'create_job' ) );
        add_action( 'wp_ajax_allsi_bulk_create_job_from_ids', array( $this, 'create_job_from_ids' ) );
        add_action( 'wp_ajax_allsi_bulk_get_jobs', array( $this, 'get_jobs' ) );
        add_action( 'wp_ajax_allsi_bulk_get_job_details', array( $this, 'get_job_details' ) );
        add_action( 'wp_ajax_allsi_bulk_start_job', array( $this, 'start_job' ) );
        add_action( 'wp_ajax_allsi_bulk_pause_job', array( $this, 'pause_job' ) );
        add_action( 'wp_ajax_allsi_bulk_delete_job', array( $this, 'delete_job' ) );
    }

    /**
     * Verify nonce and capability
     */
    private function verify_request() {
        if ( ! check_ajax_referer( 'ALLSI_bulk_nonce', 'nonce', false ) ) {
            wp_send_json_error( array( 'message' => __( 'Security check failed', 'all-sources-images' ) ) );
        }

        if ( ! current_user_can( 'edit_posts' ) ) {
            wp_send_json_error( array( 'message' => __( 'Permission denied', 'all-sources-images' ) ) );
        }
    }

    /**
     * Recursively sanitize the selection array from JSON input
     *
     * @param mixed $data The data to sanitize (array or scalar).
     * @return mixed Sanitized data.
     */
    private function sanitize_selection_array( $data ) {
        if ( ! is_array( $data ) ) {
            if ( is_string( $data ) ) {
                return sanitize_text_field( $data );
            }
            if ( is_int( $data ) ) {
                return intval( $data );
            }
            if ( is_bool( $data ) ) {
                return (bool) $data;
            }
            return $data;
        }

        $sanitized = array();
        foreach ( $data as $key => $value ) {
            $clean_key = sanitize_key( $key );
            if ( is_array( $value ) ) {
                $sanitized[ $clean_key ] = $this->sanitize_selection_array( $value );
            } elseif ( $clean_key === 'ids' && is_array( $value ) ) {
                // IDs should be integers
                $sanitized[ $clean_key ] = array_map( 'absint', $value );
            } else {
                $sanitized[ $clean_key ] = $this->sanitize_selection_array( $value );
            }
        }
        return $sanitized;
    }

    /**
     * Load items for selection tabs
     */
    public function load_items() {
        $this->verify_request();

        // phpcs:ignore WordPress.Security.NonceVerification.Missing -- Nonce verified in verify_request().
        $post_type = isset( $_POST['post_type'] ) ? sanitize_text_field( wp_unslash( $_POST['post_type'] ) ) : 'post';
        // phpcs:ignore WordPress.Security.NonceVerification.Missing -- Nonce verified in verify_request().
        $tab       = isset( $_POST['tab'] ) ? sanitize_text_field( wp_unslash( $_POST['tab'] ) ) : 'recent';
        // phpcs:ignore WordPress.Security.NonceVerification.Missing -- Nonce verified in verify_request().
        $search    = isset( $_POST['search'] ) ? sanitize_text_field( wp_unslash( $_POST['search'] ) ) : '';
        // phpcs:ignore WordPress.Security.NonceVerification.Missing -- Nonce verified in verify_request().
        $paged     = isset( $_POST['paged'] ) ? absint( $_POST['paged'] ) : 1;
        // phpcs:ignore WordPress.Security.NonceVerification.Missing -- Nonce verified in verify_request().
        $category  = isset( $_POST['category'] ) ? absint( $_POST['category'] ) : 0;
        // phpcs:ignore WordPress.Security.NonceVerification.Missing -- Nonce verified in verify_request().
        $include_drafts = isset( $_POST['include_drafts'] ) ? absint( $_POST['include_drafts'] ) : 1;
        
        $per_page = 20;
        
        // Build post_status array based on include_drafts setting
        $post_status = array( 'publish' );
        if ( $include_drafts ) {
            $post_status[] = 'draft';
            $post_status[] = 'pending';
        }

        $args = array(
            'post_type'      => $post_type,
            'post_status'    => $post_status,
            'posts_per_page' => $per_page,
            'paged'          => $paged,
            'orderby'        => 'date',
            'order'          => 'DESC',
        );

        // Tab-specific modifications
        switch ( $tab ) {
            case 'recent':
                $args['posts_per_page'] = 10;
                break;

            case 'all':
                // Default args
                break;

            case 'search':
                if ( ! empty( $search ) ) {
                    $args['s'] = $search;
                }
                break;

            case 'category':
                if ( $category > 0 ) {
                    if ( $post_type === 'product' ) {
                        $args['tax_query'] = array(
                            array(
                                'taxonomy' => 'product_cat',
                                'field'    => 'term_id',
                                'terms'    => $category,
                            ),
                        );
                    } else {
                        $args['cat'] = $category;
                    }
                }
                break;
        }

        $query = new WP_Query( $args );
        $posts = $query->posts;

        // Build HTML
        $html = '';
        if ( empty( $posts ) ) {
            $html = '<p class="text-muted p-2">' . __( 'No items found.', 'all-sources-images' ) . '</p>';
        } else {
            foreach ( $posts as $post ) {
                $has_featured = has_post_thumbnail( $post->ID );
                $class = $has_featured ? 'has-featured' : 'no-featured';
                $badge_class = $has_featured ? 'has' : 'no';
                $badge_text = $has_featured ? __( 'Has image', 'all-sources-images' ) : __( 'No image', 'all-sources-images' );
                
                // Add status badge for non-published posts
                $status_badge = '';
                if ( $post->post_status !== 'publish' ) {
                    $status_label = '';
                    $status_class = '';
                    switch ( $post->post_status ) {
                        case 'draft':
                            $status_label = __( 'Draft', 'all-sources-images' );
                            $status_class = 'draft';
                            break;
                        case 'pending':
                            $status_label = __( 'Pending', 'all-sources-images' );
                            $status_class = 'pending';
                            break;
                        default:
                            $status_label = ucfirst( $post->post_status );
                            $status_class = 'other';
                            break;
                    }
                    $status_badge = sprintf(
                        ' <span class="status-badge %s">%s</span>',
                        esc_attr( $status_class ),
                        esc_html( $status_label )
                    );
                }
                
                $html .= sprintf(
                    '<label class="%s"><input type="checkbox" value="%d"> %s%s <span class="featured-badge %s">%s</span></label>',
                    esc_attr( $class ),
                    esc_attr( $post->ID ),
                    esc_html( $post->post_title ),
                    $status_badge,
                    esc_attr( $badge_class ),
                    esc_html( $badge_text )
                );
            }
        }

        wp_send_json_success( array(
            'html'         => $html,
            'total'        => $query->found_posts,
            'max_pages'    => $query->max_num_pages,
            'current_page' => $paged,
        ) );
    }

    /**
     * Create a new bulk generation job
     */
    public function create_job() {
        $this->verify_request();

        // phpcs:ignore WordPress.Security.NonceVerification.Missing -- Nonce verified in verify_request().
        $job_name        = isset( $_POST['job_name'] ) ? sanitize_text_field( wp_unslash( $_POST['job_name'] ) ) : '';
        // phpcs:ignore WordPress.Security.NonceVerification.Missing -- Nonce verified in verify_request().
        $images_per_post = isset( $_POST['images_per_post'] ) ? absint( $_POST['images_per_post'] ) : 1;

        $selection_raw = filter_input( INPUT_POST, 'selection', FILTER_UNSAFE_RAW );
        $selection_raw = is_string( $selection_raw ) ? $selection_raw : '{}';
        $selection       = json_decode( $selection_raw, true );
        $selection       = $this->sanitize_selection_array( $selection );
        // phpcs:ignore WordPress.Security.NonceVerification.Missing -- Nonce verified in verify_request().
        $start_immediately = isset( $_POST['start_immediately'] ) ? absint( $_POST['start_immediately'] ) : 0;

        if ( empty( $job_name ) ) {
            /* translators: %s: Date and time when the job was created. */
            $job_name = sprintf( __( 'Bulk Job %s', 'all-sources-images' ), current_time( 'Y-m-d H:i' ) );
        }

        // Collect all post IDs based on selection
        $post_ids = array();
        $post_types_selected = array();

        foreach ( array( 'posts' => 'post', 'pages' => 'page', 'products' => 'product' ) as $key => $post_type ) {
            if ( empty( $selection[ $key ] ) ) {
                continue;
            }

            $mode = $selection[ $key ]['mode'] ?? '';
            $ids  = $selection[ $key ]['ids'] ?? array();

            if ( $mode === 'all' ) {
                $all_ids = get_posts( array(
                    'post_type'      => $post_type,
                    'post_status'    => 'publish',
                    'posts_per_page' => -1,
                    'fields'         => 'ids',
                ) );
                $post_ids = array_merge( $post_ids, $all_ids );
                $post_types_selected[] = $post_type;
            } elseif ( $mode === 'no_featured' ) {
                $no_featured_ids = get_posts( array(
                    'post_type'      => $post_type,
                    'post_status'    => 'publish',
                    'posts_per_page' => -1,
                    'fields'         => 'ids',
                    'meta_query'     => array(
                        array(
                            'key'     => '_thumbnail_id',
                            'compare' => 'NOT EXISTS',
                        ),
                    ),
                ) );
                $post_ids = array_merge( $post_ids, $no_featured_ids );
                $post_types_selected[] = $post_type;
            } elseif ( $mode === 'custom' && ! empty( $ids ) ) {
                $post_ids = array_merge( $post_ids, array_map( 'absint', $ids ) );
                $post_types_selected[] = $post_type;
            }
        }

        // Remove duplicates
        $post_ids = array_unique( $post_ids );

        if ( empty( $post_ids ) ) {
            wp_send_json_error( array( 'message' => __( 'No posts selected', 'all-sources-images' ) ) );
        }

        // Create job
        $job_id = ALLSI_Bulk_Generation_DB::create_job( array(
            'job_name'        => $job_name,
            'job_status'      => 'pending',
            'total_posts'     => count( $post_ids ),
            'images_per_post' => $images_per_post,
            'selection_mode'  => 'mixed',
            'post_types'      => $post_types_selected,
            'settings'        => array(
                'selection' => $selection,
            ),
        ) );

        if ( ! $job_id ) {
            wp_send_json_error( array( 'message' => __( 'Failed to create job', 'all-sources-images' ) ) );
        }

        // Add posts to job
        $added = ALLSI_Bulk_Generation_DB::add_posts_to_job( $job_id, $post_ids );

        // Update total with actual added count
        ALLSI_Bulk_Generation_DB::update_job( $job_id, array( 'total_posts' => $added ) );

        // Start immediately if requested
        if ( $start_immediately ) {
            ALLSI_Bulk_Generation_DB::update_job_status( $job_id, 'processing' );
            // Schedule cron event
            if ( ! wp_next_scheduled( 'ALLSI_bulk_process_job', array( $job_id ) ) ) {
                wp_schedule_single_event( time(), 'ALLSI_bulk_process_job', array( $job_id ) );
            }
        }

        wp_send_json_success( array(
            /* translators: %d: Number of posts added to the bulk job. */
            'message' => sprintf( __( 'Job created with %d posts', 'all-sources-images' ), $added ),
            'job_id'  => $job_id,
        ) );
    }

    /**
     * Create a job directly from post IDs (used by bulk action from posts list)
     */
    public function create_job_from_ids() {
        $this->verify_request();

        // phpcs:ignore WordPress.Security.NonceVerification.Missing -- Nonce verified in verify_request().
        $post_ids_raw = isset( $_POST['post_ids'] ) ? sanitize_text_field( wp_unslash( $_POST['post_ids'] ) ) : '';
        
        if ( empty( $post_ids_raw ) ) {
            wp_send_json_error( array( 'message' => __( 'No posts provided', 'all-sources-images' ) ) );
        }

        // Parse IDs
        $post_ids = array_filter( array_map( 'absint', explode( ',', $post_ids_raw ) ) );
        
        if ( empty( $post_ids ) ) {
            wp_send_json_error( array( 'message' => __( 'No valid posts provided', 'all-sources-images' ) ) );
        }

        // Get images per post from settings
        $options = get_option( 'ALLSI_plugin_main_settings', array() );
        $image_blocks = isset( $options['image_block'] ) ? $options['image_block'] : array();
        $images_per_post = max( 1, count( $image_blocks ) );

        // Generate job name
        $job_name = sprintf(
            /* translators: 1: Number of posts in the quick job. 2: Date and time when the job was created. */
            __( 'Quick Job - %1$d posts (%2$s)', 'all-sources-images' ),
            count( $post_ids ),
            current_time( 'Y-m-d H:i' )
        );

        // Determine post types from the IDs
        $post_types_selected = array();
        foreach ( $post_ids as $post_id ) {
            $post_type = get_post_type( $post_id );
            if ( $post_type && ! in_array( $post_type, $post_types_selected ) ) {
                $post_types_selected[] = $post_type;
            }
        }

        // Create job
        $job_id = ALLSI_Bulk_Generation_DB::create_job( array(
            'job_name'        => $job_name,
            'job_status'      => 'pending',
            'total_posts'     => count( $post_ids ),
            'images_per_post' => $images_per_post,
            'selection_mode'  => 'direct_ids',
            'post_types'      => $post_types_selected,
            'settings'        => array(
                'source' => 'bulk_action',
                'original_ids' => $post_ids,
            ),
        ) );

        if ( ! $job_id ) {
            wp_send_json_error( array( 'message' => __( 'Failed to create job', 'all-sources-images' ) ) );
        }

        // Add posts to job
        $added = ALLSI_Bulk_Generation_DB::add_posts_to_job( $job_id, $post_ids );

        // Update total with actual added count
        ALLSI_Bulk_Generation_DB::update_job( $job_id, array( 'total_posts' => $added ) );

        // Start job immediately
        ALLSI_Bulk_Generation_DB::update_job_status( $job_id, 'processing' );
        
        // Schedule cron event
        if ( ! wp_next_scheduled( 'ALLSI_bulk_process_job', array( $job_id ) ) ) {
            wp_schedule_single_event( time(), 'ALLSI_bulk_process_job', array( $job_id ) );
        }

        wp_send_json_success( array(
            /* translators: %d: Number of posts added to the bulk job. */
            'message' => sprintf( __( 'Job created and started with %d posts', 'all-sources-images' ), $added ),
            'job_id'  => $job_id,
            'total_posts' => $added,
        ) );
    }

    /**
     * Get jobs list
     */
    public function get_jobs() {
        $this->verify_request();

        // phpcs:ignore WordPress.Security.NonceVerification.Missing -- Nonce verified in verify_request().
        $page = isset( $_POST['page'] ) ? absint( $_POST['page'] ) : 1;
        // phpcs:ignore WordPress.Security.NonceVerification.Missing -- Nonce verified in verify_request().
        $status = isset( $_POST['status'] ) ? sanitize_text_field( wp_unslash( $_POST['status'] ) ) : '';

        $result = ALLSI_Bulk_Generation_DB::get_jobs( array(
            'page'   => $page,
            'status' => $status,
        ) );

        wp_send_json_success( $result );
    }

    /**
     * Get job details with posts
     */
    public function get_job_details() {
        $this->verify_request();

        // phpcs:ignore WordPress.Security.NonceVerification.Missing -- Nonce verified in verify_request().
        $job_id     = isset( $_POST['job_id'] ) ? absint( $_POST['job_id'] ) : 0;
        // phpcs:ignore WordPress.Security.NonceVerification.Missing -- Nonce verified in verify_request().
        $posts_page = isset( $_POST['posts_page'] ) ? absint( $_POST['posts_page'] ) : 1;

        if ( ! $job_id ) {
            wp_send_json_error( array( 'message' => __( 'Invalid job ID', 'all-sources-images' ) ) );
        }

        $job = ALLSI_Bulk_Generation_DB::get_job( $job_id );
        if ( ! $job ) {
            wp_send_json_error( array( 'message' => __( 'Job not found', 'all-sources-images' ) ) );
        }

        $stats = ALLSI_Bulk_Generation_DB::get_job_stats( $job_id );
        $posts = ALLSI_Bulk_Generation_DB::get_job_posts( $job_id, array( 'page' => $posts_page ) );
        
        // Add thumbnail URLs to posts (all images generated for this post)
        if ( ! empty( $posts['posts'] ) ) {
            foreach ( $posts['posts'] as &$post ) {
                $post->image_urls = array();
                $post->thumbnail_url = ''; // Keep for backward compatibility
                
                // First, check if we have additional_images stored in the database
                $additional_images = isset( $post->additional_images ) ? maybe_unserialize( $post->additional_images ) : array();
                
                if ( ! empty( $additional_images ) && is_array( $additional_images ) ) {
                    // Use the stored image IDs from bulk generation
                    foreach ( $additional_images as $image_id ) {
                        $thumb = wp_get_attachment_image_src( $image_id, 'thumbnail' );
                        if ( $thumb && ! in_array( $thumb[0], $post->image_urls, true ) ) {
                            $post->image_urls[] = $thumb[0];
                            // Set first image as thumbnail for backward compatibility
                            if ( empty( $post->thumbnail_url ) ) {
                                $post->thumbnail_url = $thumb[0];
                            }
                        }
                    }
                }
                
                // If no additional_images stored, fallback to checking featured image and attachments
                if ( empty( $post->image_urls ) ) {
                    // Get featured image if exists
                    if ( has_post_thumbnail( $post->post_id ) ) {
                        $thumb_id = get_post_thumbnail_id( $post->post_id );
                        $thumb = wp_get_attachment_image_src( $thumb_id, 'thumbnail' );
                        if ( $thumb ) {
                            $post->thumbnail_url = $thumb[0];
                            $post->image_urls[] = $thumb[0];
                            if ( empty( $post->featured_image_id ) ) {
                                $post->featured_image_id = $thumb_id;
                            }
                        }
                    }
                    
                    // Get images attached to this post (uploaded during bulk generation)
                    $attached_images = get_posts( array(
                        'post_type'      => 'attachment',
                        'post_mime_type' => 'image',
                        'post_parent'    => $post->post_id,
                        'posts_per_page' => 10,
                        'orderby'        => 'date',
                        'order'          => 'DESC',
                        'exclude'        => has_post_thumbnail( $post->post_id ) ? array( get_post_thumbnail_id( $post->post_id ) ) : array(),
                    ) );
                    
                    foreach ( $attached_images as $image ) {
                        $thumb = wp_get_attachment_image_src( $image->ID, 'thumbnail' );
                        if ( $thumb && ! in_array( $thumb[0], $post->image_urls, true ) ) {
                            $post->image_urls[] = $thumb[0];
                        }
                    }
                }
            }
        }

        wp_send_json_success( array(
            'job'   => $job,
            'stats' => $stats,
            'posts' => $posts,
        ) );
    }

    /**
     * Start or resume a job
     */
    public function start_job() {
        $this->verify_request();

        // phpcs:ignore WordPress.Security.NonceVerification.Missing -- Nonce verified in verify_request().
        $job_id = isset( $_POST['job_id'] ) ? absint( $_POST['job_id'] ) : 0;

        if ( ! $job_id ) {
            wp_send_json_error( array( 'message' => __( 'Invalid job ID', 'all-sources-images' ) ) );
        }

        $job = ALLSI_Bulk_Generation_DB::get_job( $job_id );
        if ( ! $job ) {
            wp_send_json_error( array( 'message' => __( 'Job not found', 'all-sources-images' ) ) );
        }

        if ( ! in_array( $job->job_status, array( 'pending', 'paused' ) ) ) {
            wp_send_json_error( array( 'message' => __( 'Job cannot be started', 'all-sources-images' ) ) );
        }

        ALLSI_Bulk_Generation_DB::update_job_status( $job_id, 'processing' );

        // Schedule cron event
        if ( ! wp_next_scheduled( 'ALLSI_bulk_process_job', array( $job_id ) ) ) {
            wp_schedule_single_event( time(), 'ALLSI_bulk_process_job', array( $job_id ) );
        }

        wp_send_json_success( array( 'message' => __( 'Job started', 'all-sources-images' ) ) );
    }

    /**
     * Pause a job
     */
    public function pause_job() {
        $this->verify_request();

        // phpcs:ignore WordPress.Security.NonceVerification.Missing -- Nonce verified in verify_request().
        $job_id = isset( $_POST['job_id'] ) ? absint( $_POST['job_id'] ) : 0;

        if ( ! $job_id ) {
            wp_send_json_error( array( 'message' => __( 'Invalid job ID', 'all-sources-images' ) ) );
        }

        ALLSI_Bulk_Generation_DB::update_job_status( $job_id, 'paused' );

        // Clear scheduled cron
        wp_clear_scheduled_hook( 'ALLSI_bulk_process_job', array( $job_id ) );

        wp_send_json_success( array( 'message' => __( 'Job paused', 'all-sources-images' ) ) );
    }

    /**
     * Delete a job
     */
    public function delete_job() {
        $this->verify_request();

        // phpcs:ignore WordPress.Security.NonceVerification.Missing -- Nonce verified in verify_request().
        $job_id = isset( $_POST['job_id'] ) ? absint( $_POST['job_id'] ) : 0;

        if ( ! $job_id ) {
            wp_send_json_error( __( 'Invalid job ID.', 'all-sources-images' ) );
        }

        // Clear all scheduled cron events for this job
        wp_clear_scheduled_hook( 'ALLSI_bulk_process_job', array( $job_id ) );
        wp_clear_scheduled_hook( 'ALLSI_bulk_process_batch', array( $job_id ) );

        $deleted = ALLSI_Bulk_Generation_DB::delete_job( $job_id );

        if ( $deleted ) {
            // translators: %d is the job ID.
            $message = sprintf( __( 'Job %d has been successfully deleted.', 'all-sources-images' ), $job_id );
            wp_send_json_success( array( 'message' => $message ) );
        } else {
            wp_send_json_error( array( 'message' => __( 'Failed to delete job', 'all-sources-images' ) ) );
        }
    }
}

// Initialize
new ALLSI_Bulk_Generation_Ajax();