127 lines
5.0 KiB
Ruby
127 lines
5.0 KiB
Ruby
# frozen_string_literal: true
|
|
|
|
# ==========================================================
|
|
# dtic-BKPs - Automatic Backup Processor
|
|
# ----------------------------------------------------------
|
|
# APP: dtic-BKPs
|
|
# FILE: fxs/proc_syncXEN.rb
|
|
# VERSION: v5.5.1
|
|
# AUTHOR: Ricardo MONLA (rmonla@)
|
|
# LICENSE: MIT License
|
|
# ==========================================================
|
|
|
|
# --- Función Principal del Procesador XVA ---
|
|
def procesar_backups_xva(tarea_cfg)
|
|
system 'clear' or system 'cls'
|
|
# 1. --- Extraer configuración y inicializar variables ---
|
|
dir_origen = tarea_cfg[:origen]
|
|
dir_destino_base = tarea_cfg[:destino]
|
|
eliminar_original = tarea_cfg[:eliminar_origen]
|
|
sobrescribir_destino = tarea_cfg[:sobrescribir_destino]
|
|
archivos_procesados_llamada = 0
|
|
|
|
puts "\n#{NEGRITA}#{CIAN}--- #{tarea_cfg[:menu_texto]} ---#{RESET}"
|
|
log :info, "#{tarea_cfg[:id]}: Iniciado desde #{dir_origen}. Eliminar: #{eliminar_original}, Sobrescribir: #{sobrescribir_destino}"
|
|
|
|
@pv_disponible ||= !`which pv`.to_s.strip.empty?
|
|
unless @pv_disponible
|
|
if @pv_notificado.nil?
|
|
msg = "#{tarea_cfg[:id]}: Comando 'pv' no encontrado. Compresión sin barra de progreso."
|
|
log :warn, msg
|
|
puts "#{ICONO_WARN} #{msg}"
|
|
@pv_notificado = true
|
|
end
|
|
end
|
|
|
|
# 2. --- Buscar archivos a procesar ---
|
|
archivos_disponibles = Dir.glob(File.join(dir_origen, '*.xva'))
|
|
|
|
if archivos_disponibles.empty?
|
|
msg = "#{tarea_cfg[:id]}: No hay archivos .xva en '#{dir_origen}'."
|
|
log :warn, msg
|
|
puts "#{ICONO_WARN} #{msg}"
|
|
$estadisticas_ejecucion[:tareas_completadas][tarea_cfg[:id]] = { archivos: 0, estado: "OK (Sin archivos)" }
|
|
return
|
|
end
|
|
|
|
puts "#{ICONO_INFO} Encontrados #{archivos_disponibles.length} archivo(s) .xva a procesar."
|
|
|
|
# 3. --- Iterar y procesar cada archivo ---
|
|
archivos_disponibles.each do |ruta_completa_xva_origen|
|
|
nombre_base_xva = File.basename(ruta_completa_xva_origen)
|
|
nombre_vm = nombre_base_xva.split('_').first
|
|
dir_dest_especifico_vm = File.join(dir_destino_base, nombre_vm)
|
|
|
|
begin
|
|
FileUtils.mkdir_p(dir_dest_especifico_vm)
|
|
rescue StandardError => e
|
|
log :error, "#{tarea_cfg[:id]}: Error creando dir '#{dir_dest_especifico_vm}': #{e.message}"
|
|
next
|
|
end
|
|
|
|
nombre_sin_ext = File.basename(nombre_base_xva, '.xva')
|
|
ruta_salida_comp = File.join(dir_dest_especifico_vm, "#{nombre_sin_ext}.tar.gz")
|
|
|
|
if File.exist?(ruta_salida_comp)
|
|
if sobrescribir_destino
|
|
msg = "#{tarea_cfg[:id]}: Destino '#{File.basename(ruta_salida_comp)}' existe. Se sobrescribirá."
|
|
log :info, msg
|
|
puts "#{ICONO_WARN} #{msg}"
|
|
else
|
|
msg = "#{tarea_cfg[:id]}: Destino '#{File.basename(ruta_salida_comp)}' existe. No se sobrescribe. Saltando."
|
|
log :warn, msg
|
|
puts "#{ICONO_WARN} #{msg}"
|
|
next
|
|
end
|
|
end
|
|
|
|
# 4. --- Realizar la compresión ---
|
|
puts "#{CIAN}→ Comprimiendo #{NEGRITA}#{nombre_base_xva}#{RESET} a #{File.basename(ruta_salida_comp)}..."
|
|
log :info, "#{tarea_cfg[:id]}: Comprimiendo XVA #{nombre_base_xva} → #{File.basename(ruta_salida_comp)}"
|
|
|
|
begin
|
|
if @pv_disponible
|
|
cmd_tar = ['tar', '-czf', '-', '-C', dir_origen, nombre_base_xva]
|
|
cmd_pv = ['pv', '-s', File.size(ruta_completa_xva_origen).to_s]
|
|
|
|
File.open(ruta_salida_comp, 'wb') do |f_out|
|
|
Open3.pipeline(cmd_tar, cmd_pv, out: f_out).each_with_index do |status, i|
|
|
unless status.success?
|
|
cmd_name = i == 0 ? 'tar' : 'pv'
|
|
raise "Error en compresión (falló #{cmd_name} con código: #{status.exitstatus})"
|
|
end
|
|
end
|
|
end
|
|
else
|
|
cmd_tar_directo = "tar -czf #{Shellwords.escape(ruta_salida_comp)} -C #{Shellwords.escape(dir_origen)} #{Shellwords.escape(nombre_base_xva)}"
|
|
system(cmd_tar_directo)
|
|
raise "Error en compresión (falló tar con código: #{$?.exitstatus})" unless $?.success?
|
|
end
|
|
|
|
# 5. --- Finalizar y limpiar ---
|
|
log :info, "#{tarea_cfg[:id]}: Compresión OK → #{ruta_salida_comp}"
|
|
puts "\n#{ICONO_OK} Compresión OK: #{File.basename(ruta_salida_comp)}"
|
|
|
|
if eliminar_original
|
|
log :info, "#{tarea_cfg[:id]}: Eliminando XVA original #{nombre_base_xva}"
|
|
FileUtils.rm_f(ruta_completa_xva_origen)
|
|
end
|
|
|
|
archivos_procesados_llamada += 1
|
|
|
|
rescue StandardError => e
|
|
err_msg = "#{tarea_cfg[:id]}: Error al comprimir #{nombre_base_xva}: #{e.message}"
|
|
log :error, err_msg
|
|
puts "\n#{ICONO_ERROR} #{err_msg}"
|
|
FileUtils.rm_f(ruta_salida_comp)
|
|
next
|
|
end
|
|
end
|
|
|
|
# 6. --- Reportar estadísticas finales ---
|
|
$estadisticas_ejecucion[:tareas_completadas][tarea_cfg[:id]] = { archivos: archivos_procesados_llamada, estado: "OK" }
|
|
log :info, "#{tarea_cfg[:id]}: #{archivos_procesados_llamada} archivos .xva procesados"
|
|
puts "#{ICONO_OK} Tarea '#{tarea_cfg[:menu_texto]}' completada. Procesados: #{archivos_procesados_llamada}."
|
|
sleep 1.5
|
|
end
|