cb79743f740eb48d19ddd359895d190f8ec3563bEugen Kuksarequire 'fileutils'

cb79743f740eb48d19ddd359895d190f8ec3563bEugen Kuksarequire File.expand_path('../../../lib/environment_light_with_hets.rb', __FILE__)

cb79743f740eb48d19ddd359895d190f8ec3563bEugen Kuksarequire File.expand_path('../eye_methods.rb', __FILE__)

cb79743f740eb48d19ddd359895d190f8ec3563bEugen Kuksa

cb79743f740eb48d19ddd359895d190f8ec3563bEugen KuksaEye.config do

cb79743f740eb48d19ddd359895d190f8ec3563bEugen Kuksa logger "#{Rails.root}/log/eye.log"

cb79743f740eb48d19ddd359895d190f8ec3563bEugen Kuksaend

cb79743f740eb48d19ddd359895d190f8ec3563bEugen Kuksa

cb79743f740eb48d19ddd359895d190f8ec3563bEugen KuksaEye.application :ontohub do

cb79743f740eb48d19ddd359895d190f8ec3563bEugen Kuksa working_dir Rails.root.to_s

cb79743f740eb48d19ddd359895d190f8ec3563bEugen Kuksa env 'RAILS_ENV' => Rails.env

cb79743f740eb48d19ddd359895d190f8ec3563bEugen Kuksa env 'PID_DIR' => Rails.root.join('tmp', 'pids').to_s

cb79743f740eb48d19ddd359895d190f8ec3563bEugen Kuksa

cb79743f740eb48d19ddd359895d190f8ec3563bEugen Kuksa # Create PID dir

cb79743f740eb48d19ddd359895d190f8ec3563bEugen Kuksa FileUtils.mkdir_p(env['PID_DIR'])

cb79743f740eb48d19ddd359895d190f8ec3563bEugen Kuksa

cb79743f740eb48d19ddd359895d190f8ec3563bEugen Kuksa group :sidekiq do

cb79743f740eb48d19ddd359895d190f8ec3563bEugen Kuksa # one worker per configured hets instance

cb79743f740eb48d19ddd359895d190f8ec3563bEugen Kuksa Settings.hets.instance_urls.each_with_index do |_url, index|

cb79743f740eb48d19ddd359895d190f8ec3563bEugen Kuksa sidekiq_process self, :"sidekiq-hets-#{index}", 'hets', 1

cb79743f740eb48d19ddd359895d190f8ec3563bEugen Kuksa end

cb79743f740eb48d19ddd359895d190f8ec3563bEugen Kuksa

cb79743f740eb48d19ddd359895d190f8ec3563bEugen Kuksa # one worker for hets load balancing

cb79743f740eb48d19ddd359895d190f8ec3563bEugen Kuksa sidekiq_process self, :'sidekiq-hets-load-balancing', 'hets_load_balancing', 1

cb79743f740eb48d19ddd359895d190f8ec3563bEugen Kuksa

cb79743f740eb48d19ddd359895d190f8ec3563bEugen Kuksa # one worker for the default queue

cb79743f740eb48d19ddd359895d190f8ec3563bEugen Kuksa sidekiq_process self, :'sidekiq-default', 'default', 5

cb79743f740eb48d19ddd359895d190f8ec3563bEugen Kuksa

cb79743f740eb48d19ddd359895d190f8ec3563bEugen Kuksa # one worker for the sequential queue

cb79743f740eb48d19ddd359895d190f8ec3563bEugen Kuksa sidekiq_process self, :'sidekiq-sequential', 'sequential', 1

cb79743f740eb48d19ddd359895d190f8ec3563bEugen Kuksa

cb79743f740eb48d19ddd359895d190f8ec3563bEugen Kuksa sidekiq_process self, :'sidekiq-priority_push', 'priority_push', 1

cb79743f740eb48d19ddd359895d190f8ec3563bEugen Kuksa end

cb79743f740eb48d19ddd359895d190f8ec3563bEugen Kuksa

cb79743f740eb48d19ddd359895d190f8ec3563bEugen Kuksa group :hets do

cb79743f740eb48d19ddd359895d190f8ec3563bEugen Kuksa Settings.hets.instance_urls.each do |url|

cb79743f740eb48d19ddd359895d190f8ec3563bEugen Kuksa if url.match(%r{\Ahttps?://(localhost|127.0.0.1|0.0.0.0|::1)})

cb79743f740eb48d19ddd359895d190f8ec3563bEugen Kuksa hets_process self, URI(url).port

cb79743f740eb48d19ddd359895d190f8ec3563bEugen Kuksa end

cb79743f740eb48d19ddd359895d190f8ec3563bEugen Kuksa end

cb79743f740eb48d19ddd359895d190f8ec3563bEugen Kuksa end

cb79743f740eb48d19ddd359895d190f8ec3563bEugen Kuksaend