pushmi_pullyu.rb

# require 'pushmi_pullyu/version' must be first as it declares the PushmiPullyu
# module. (This fixes a weird NameError bug when using the nested compact syntax
# for defining modules/classes like `module PushmiPullyu::Logging`)

require 'pushmi_pullyu/version'
require 'pushmi_pullyu/logging'
require 'pushmi_pullyu/aip'
require 'pushmi_pullyu/aip/creator'
require 'pushmi_pullyu/aip/downloader'
require 'pushmi_pullyu/cli'
require 'pushmi_pullyu/preservation_queue'
require 'pushmi_pullyu/swift_depositer'
require 'active_support'
require 'active_support/core_ext'

# PushmiPullyu main module
module PushmiPullyu
  DEFAULTS = {
    aip_version: 'lightaip-2.0',
    daemonize: false,
    debug: false,
    logdir: 'log',
    minimum_age: 0,
    monitor: false,
    piddir: 'tmp/pids',
    workdir: 'tmp/work',
    process_name: 'pushmi_pullyu',
    queue_name: 'dev:pmpy_queue',
    ingestion_prefix: 'prod:pmpy_ingest_attempt:',
    ingestion_attempts: 15,
    first_failed_wait: 10,
    redis: {
      url: 'redis://localhost:6379'
    },
    swift: {
      tenant: 'tester',
      username: 'test:tester',
      password: 'testing',
      auth_url: 'http://localhost:8080/auth/v1.0',
      project_name: 'demo',
      project_domain_name: 'default',
      container: 'era',
      auth_version: 'v3',
      user_domain: 'default'
    },
    rollbar: {},
    # rubocop disable: Style/FetchEnvVar
    jupiter: {
      user: ENV.fetch('JUPITER_USER', nil),
      api_key: ENV.fetch('JUPITER_API_KEY', nil),
      jupiter_url: ENV.fetch('JUPITER_URL', nil) || 'http://era.lvh.me:3000/',
      aip_api_path: ENV.fetch('JUPITER_AIP_API_PATH', nil) || 'aip/v1'
    }
    # rubocop enable: Style/FetchEnvVar
  }.freeze

  def self.options
    @options ||= DEFAULTS.dup
  end

  def self.options=(opts)
    options.deep_merge!(opts)
  end

  def self.override_options(opts)
    @options = opts
  end

  def self.application_log_file
    "#{options[:logdir]}/#{options[:process_name]}.log"
  end

  def self.logger
    PushmiPullyu::Logging.logger
  end

  def self.logger=(log)
    PushmiPullyu::Logging.logger = log
  end

  def self.server_running=(status)
    @server_running = status
  end

  def self.reset_logger=(status)
    @reset_logger = status
  end

  def self.server_running?
    @server_running
  end

  def self.continue_polling?
    server_running? && !reset_logger?
  end

  def self.reset_logger?
    @reset_logger
  end
end