gistfile1.txt

require 'concurrent'
require 'pry'
#require_relative '../lib/mirror_rsync'
require_relative '../lib/beaneater_config'
require_relative '../lib/mirror_observer'
require_relative '../lib/rise_mirror_app'
require_relative '../lib/rise_exceptions'
require_relative '../lib/mirror_status'
require_relative '../lib/mirror'
require_relative '../lib/mirrorsync'

class Sync
	include RiseMirrorApp
	include Mirror
	include MirrorSync
	Concurrent.use_stdlib_logger(Logger::DEBUG)

	def self.run
		Sync.new.run
	end

	def initialize
	  @mirrors = Mirror::Strategies::MirrorIniFileLoader.retrieve_upstream_mirror_configuration
	  @pool = Concurrent::FixedThreadPool.new(10, max_queue: 20) #Given a fileserver only syncs for a maximum of 30 mirrors
	  @mirror_observer = MirrorObserver.new
	end

	def run
	  puts 'running'
      @mirrors.each do |mirror|
      	future = Concurrent::Future.new(executor: @pool) {
      		@mirror_observer.mirror_rsync_start(Time.now, mirror[:name])
      		MirrorSync::Strategies::MirrorRsync.sync(mirror)
      	}
        
      	future.add_observer(@mirror_observer, :mirror_rsync_end)

      	future.execute 
      	sleep 60
        #binding.pry
      end
    end
end

Sync.run