# frozen_string_literal: true

# ==========================================================
# adn/tools/bkps/lib/proc_dasuten.rb
# ==========================================================
# Procesador de Backups DASUTEN
# Integra pipeline de backups en bkps.rb
# ==========================================================

module ADN
  module BKPs
    module Procesador
      class Dasuten
        DRONES_DIR = File.join(
          File.dirname(File.dirname(File.dirname(File.expand_path(__FILE__)))),
          'cli', 'drones'
        )

        # Nodo y ámbito de REGISTRO en bitácora (lógico, no operacional)
        # El nodo operacional (srvv-fenix, srv-ns8, etc.) es interno al dron
        NODO_BITACORA   = 'dtic-BKPs'.freeze
        AMBITO_BITACORA = 'dtic-DIIAA'.freeze

        SCRIPTS = {
          'dasuten_export_full' => 'dasuten_exportar_srvv-fenix.rb',
          'dasuten_export_dif' => 'dasuten_exportar_diferencial_srvv-fenix.rb',
          'dasuten_transferir' => 'dasuten_transferir_srvv-fenix-srv-ns8.rb',
          'dasuten_upload' => 'dasuten_upload_srv-ns8-drive.rb',
          'dasuten_download' => 'dasuten_download_drive-dasu-sql4.rb',
          'dasuten_restaurar_full' => 'dasuten_restaurar_dasu-sql4.rb',
          'dasuten_restaurar_dif' => 'dasuten_restaurar_diferencial_dasu-sql4.rb',
          'dasuten_verificar' => 'dasuten_verificar-integridad_dasu-sql4.rb',
        }.freeze

        def initialize(logger)
          @logger = logger
          @dron_runner = File.join(
            File.dirname(File.dirname(File.dirname(File.expand_path(__FILE__)))),
            'run'
          )
        end

        def ejecutar(tarea)
          script_name = SCRIPTS[tarea[:id]]
          unless script_name
            @logger.error("Tarea DASUTEN desconocida: #{tarea[:id]}")
            return false
          end

          script_path = File.join(DRONES_DIR, script_name)
          unless File.exist?(script_path)
            @logger.error("Script no encontrado: #{script_path}")
            return false
          end

          nota             = tarea[:texto] || "DASUTEN: #{tarea[:id]}"
          nodo_bitacora    = NODO_BITACORA    # Registro lógico en bitácora
          ambito_bitacora  = AMBITO_BITACORA  # Ámbito de registro en bitácora

          # Lanzar dron con bitácora automática
          # --nodo y --ambito son para REGISTRO en bitácora, no el nodo operacional
          cmd = "#{@dron_runner} dron lanzar --nota #{Shellwords.escape(nota)} --nodo #{Shellwords.escape(nodo_bitacora)} --ambito #{Shellwords.escape(ambito_bitacora)} -- ruby #{script_path}"

          @logger.info("Ejecutando dron: #{nota}")
          @logger.debug("Comando: #{cmd}")

          exito = system(cmd)
          codigo = $?.exitstatus

          if exito
            @logger.info("✅ Dron completado (código: #{codigo})")
            true
          else
            @logger.error("❌ Dron fallido (código: #{codigo})")
            false
          end
        end

        # Para modo atómico (no aplica en DASUTEN - todos son pipelines)
        def ejecutar_uno(tarea, archivo)
          @logger.warn("Modo atómico no soportado para DASUTEN")
          ejecutar(tarea)
        end

        # Listar archivos pendientes (no aplica - pipeline fijo)
        def listar(tarea)
          []
        end

        private

        def detectar_nodo(tarea_id)
          case tarea_id
          when /export/ then 'srvv-fenix'
          when /transferir/, /upload/ then 'srv-ns8'
          when /download/, /restaurar/, /verificar/ then 'dasu-sql4'
          else 'srv-dasu'
          end
        end
      end
    end
  end
end