Module: PushmiPullyu

Defined in:
lib/pushmi_pullyu.rb,
lib/pushmi_pullyu/version.rb

Overview

PushmiPullyu main module

Defined Under Namespace

Modules: AIP, Logging Classes: CLI, PreservationQueue, SwiftDepositer

Constant Summary collapse

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'
  },
  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
VERSION = 
'2.0.7'.freeze

Class Method Summary collapse

Class Method Details

.application_log_file ⇒ Object 



67
68
69
 
# File 'lib/pushmi_pullyu.rb', line 67

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

.continue_polling? ⇒ Boolean

Returns:

  • (Boolean) 


91
92
93
 
# File 'lib/pushmi_pullyu.rb', line 91

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

.logger ⇒ Object 



71
72
73
 
# File 'lib/pushmi_pullyu.rb', line 71

def self.logger
  PushmiPullyu::Logging.logger
end

.logger=(log) ⇒ Object 



75
76
77
 
# File 'lib/pushmi_pullyu.rb', line 75

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

.options ⇒ Object 



55
56
57
 
# File 'lib/pushmi_pullyu.rb', line 55

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

.options=(opts) ⇒ Object 



59
60
61
 
# File 'lib/pushmi_pullyu.rb', line 59

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

.override_options(opts) ⇒ Object 



63
64
65
 
# File 'lib/pushmi_pullyu.rb', line 63

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

.reset_logger=(status) ⇒ Object 



83
84
85
 
# File 'lib/pushmi_pullyu.rb', line 83

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

.reset_logger? ⇒ Boolean

Returns:

  • (Boolean) 


95
96
97
 
# File 'lib/pushmi_pullyu.rb', line 95

def self.reset_logger?
  @reset_logger
end

.server_running=(status) ⇒ Object 



79
80
81
 
# File 'lib/pushmi_pullyu.rb', line 79

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

.server_running? ⇒ Boolean

Returns:

  • (Boolean) 


87
88
89
 
# File 'lib/pushmi_pullyu.rb', line 87

def self.server_running?
  @server_running
end