panel/app/models/deploy_rsync.rb

# frozen_string_literal: true

# Sincroniza sitios a servidores remotos usando Rsync.  El servidor
# remoto tiene que tener rsync instalado.
class DeployRsync < Deploy
  store :values, accessors: %i[flags destination host_keys], coder: JSON

  def deploy
    ssh? && rsync
  end

  # No se ocupa espacio local
  #
  # @return [Integer]
  def size
    0
  end

  # Devolver el destino o lanzar un error si no está configurado
  def destination
    values[:destination].tap do |d|
      raise(ArgumentError, 'destination no está configurado') if d.blank?
    end
  end

  private

  # Verificar la conexión SSH implementando Trust On First Use
  #
  # TODO: Medir el tiempo que tarda en iniciarse la conexión
  #
  # @return [Boolean]
  def ssh?
    user, host = user_host
    ssh_available = false

    Net::SSH.start(host, user, verify_host_key: tofu, timeout: 5) do |ssh|
      if values[:host_keys].blank?
        # Guardar las llaves que se encontraron en la primera conexión
        values[:host_keys] = ssh.transport.host_keys.map do |host_key|
          "#{host_key.ssh_type} #{host_key.fingerprint}"
        end

        ssh_available = save
      else
        ssh_available = true
      end
    end

    ssh_available
  rescue Exception => e
    ExceptionNotifier.notify_exception(e, data: { site: site.id, hostname: host, user: user })

    false
  end

  def env
    {
      'HOME' => home_dir,
      'PATH' => '/usr/bin',
      'LANG' => ENV['LANG']
    }
  end

  # Confiar en la primera llave que encontremos, fallar si cambian
  #
  # @return [Symbol]
  def tofu
    values[:host_keys].present? ? :always : :accept_new
  end

  # Devuelve el par user host
  #
  # @return [Array]
  def user_host
    destination.split(':', 2).first.split('@', 2).tap do |d|
      next unless d.size == 1

      d.insert(0, nil)
    end
  end

  # Sincroniza hacia el directorio remoto, usando las flags opcionales.
  #
  # @return [Boolean]
  def rsync
    run %(rsync -av --timeout=5 #{flags ? Shellwords.escape(flags) : ''} #{Shellwords.escape source}/ #{Shellwords.escape destination}/)
  end

  # El origen es el destino de la compilación
  #
  # @return [String]
  def source
    site.deploys.find_by(type: 'DeployLocal').destination
  end
end