require 'uri/ssh_git'
require 'net/ssh'
require 'net/sftp'

require 'pathname'
require 'logging'
require 'pp'
require 'securerandom'
require 'rexml/document'
require 'dbus'
require 'date'
require 'concurrent'

require "snapsync/version"
require "snapsync/util"
require "snapsync/exceptions"
require 'snapsync/btrfs'
require 'snapsync/btrfs_subvolume'
require "snapsync/snapper_config"
require "snapsync/snapshot"
require "snapsync/sync_target"
require "snapsync/snapshot_transfer"
require 'snapsync/cleanup'

require 'snapsync/remote_pathname'
require 'snapsync/ssh_popen'
require 'snapsync/ssh_popen_exe'

require 'snapsync/default_sync_policy'
require 'snapsync/timeline_sync_policy'
require 'snapsync/sync_last_policy'

require 'snapsync/partitions_monitor'
require 'snapsync/sync'
require 'snapsync/sync_all'


module Logging
    module Installer
        def logger
            @logger ||= Logging.logger[self]
        end
    end

    module Forwarder
        ::Logging::LEVELS.each do |name, _|
            puts name
            define_method name do |*args, &block|
                logger.send(name, *args, &block)
            end
        end
    end
end

class Module
    def install_root_logging(level: 'INFO', forward: true, &block)
        extend Logging::Installer
        if block_given?
            yield(logger)
        else
            logger.add_appenders Logging.appenders.stdout
        end

        if forward
            singleton_class.class_eval do
                install_logging_forwarder
            end
        end
        logger.level = level
    end

    def install_logging_forwarder
        ::Logging::LEVELS.each do |name, _|
            define_method name do |*args, &block|
                logger.send(name, *args, &block)
            end
        end
    end

    def install_logging(forward: true, &block)
        extend Logging::Installer
        if forward
            singleton_class.class_eval do
                install_logging_forwarder
            end
        end
    end
end

class Class
    def install_logging(forward: true, on_instance: false)
        super(forward: forward)
        if on_instance
            include Logging::Installer
            if forward
                install_logging_forwarder
            end
        end
    end
end

module Snapsync
    install_root_logging(forward: true)

    class << self
        attr_accessor :SSH_DEBUG
        attr_accessor :SYSTEMD
        attr_accessor :NOTIFY
    end
    Snapsync.SSH_DEBUG = false
    Snapsync.SYSTEMD   = false
    Snapsync.NOTIFY    = false

    # @param [String] dir
    # @return [AgnosticPath]
    def self.path(dir)
        raise "Nil dir" if dir.nil?
        if dir.instance_of? RemotePathname or dir.include? ':'
            begin
                RemotePathname.new(dir)
            rescue URI::InvalidComponentError
                LocalPathname.new(dir)
            end
        else
            LocalPathname.new dir
        end
    end
end