<?php

namespace Aikanen\Modules\CategoryExport;

defined('ABSPATH') || exit;

use Aikanen\ApiClient;
use Aikanen\Modules\BaseModule;
use Aikanen\SyncState;

// Export categories from WooCommerce to Aikanen (service groups)
class CategoryExportModule extends BaseModule
{
   private static array $queued = [];

   public function __construct(
      private ApiClient $api,
      private CategoryExportMapper $categoryMapper,
   ) {}

   protected function key(): string
   {
      return 'category_export';
   }

   public function getName(): string
   {
      return __('Category export', 'aikanen');
   }

   public function getDescription(): string
   {
      return __('Export categories from WooCommerce to Aikanen', 'aikanen');
   }

   public function register(): void
   {
      // Auto-sync on category save
      add_action('edited_product_cat', [$this, 'onCategorySaved'], 10, 1);
      add_action('created_product_cat', [$this, 'onCategorySaved'], 10, 1);

      // Bulk export from category list
      add_filter('bulk_actions-edit-product_cat', [$this, 'addBulkAction']);
      add_filter('handle_bulk_actions-edit-product_cat', [$this, 'handleBulkExport'], 10, 3);

      // Desync
      add_action('admin_post_aikanen_desync_category', [$this, 'handleDesync']);

      // Action Scheduler callback
      add_action('aikanen_export_category', [$this, 'exportCategory']);
   }

   public function onCategorySaved(int $termId): void
   {
      if ( // Skip if 
         SyncState::$suppressOutbound || // ...save initiated from Aikanen
         !get_option('aikanen_auto_export_category', false) || // ...or auto-sync not enabled
         isset(self::$queued[$termId]) // ...or category already queued on this request
      ) {
         return;
      }

      self::$queued[$termId] = true; // Mark as queued for this request

      // Cancel any pending job for this category and enqueue a fresh one with latest changes
      as_unschedule_action('aikanen_export_category', ['term_id' => $termId]);
      as_enqueue_async_action('aikanen_export_category', ['term_id' => $termId]);
   }

   // Export a category to Aikanen as service group
   public function exportCategory(int $termId): void
   {
      $term = get_term($termId, 'product_cat');

      if (!$term || is_wp_error($term)) { // Product (no longer) found on WooCommerce
         return;
      }

      $aikanenId = $this->categoryMapper->getAikanenId($term);
      $payload = $this->categoryMapper->toAikanen($term);

      if ($aikanenId) { // Update if category already exists in Aikanen
         $this->api->put("/service_groups/{$aikanenId}", $payload);
      } else { // Create as new if doesn't exist in Aikanen
         $response = $this->api->post('/service_groups', $payload);
         $this->categoryMapper->setAikanenId($term, $response['data']['id']);
      }
   }

   // Export categories to Aikanen in bulk
   public function handleBulkExport(string $redirectTo, string $action, array $termIds): string
   {
      if ($action !== 'export_to_aikanen') {
         return $redirectTo;
      }

      foreach ($termIds as $termId) {
         as_enqueue_async_action('aikanen_export_category', ['term_id' => (int) $termId]);
      }

      return add_query_arg('aikanen_exported_categories', count($termIds), $redirectTo);
   }

   public function addBulkAction(array $actions): array
   {
      $actions['export_to_aikanen'] = __('Export to Aikanen', 'aikanen');
      return $actions;
   }

   // Remove sync from category
   public function handleDesync(): void
   {
      $termId = absint(wp_unslash($_GET['term_id'] ?? 0));

      if (
         !$termId ||
         !current_user_can('manage_woocommerce') ||
         !check_admin_referer('aikanen_desync_category_' . $termId)
      ) {
         wp_die('Unauthorized.');
      }

      $term = get_term($termId, 'product_cat');

      if (!$term || is_wp_error($term)) {
         wp_die('Category not found.');
      }

      $this->categoryMapper->clearAikanenId($term);

      wp_safe_redirect(admin_url('edit-tags.php?taxonomy=product_cat&post_type=product'));
      exit;
   }
}