Module: GHTorrent::Settings

Includes:
Utils
Included in:
GHTDataRetrieval, GHTLoad, GHTMirrorEvents, GHTMoreCommitsRetriever, GHTRepoRetriever, GHTRetrieveDependents, GHTRetrieveOne, GHTRetrieveRepo, GHTUpdateRepo, APIClient, Command, Logging, Mirror, MongoPersister, Retriever, MultiprocessQueueClient
Defined in:
lib/ghtorrent/settings.rb

Constant Summary collapse

CONFIGKEYS = 
{
    :amqp_host => 'amqp.host',
    :amqp_port => 'amqp.port',
    :amqp_username => 'amqp.username',
    :amqp_password => 'amqp.password',
    :amqp_exchange => 'amqp.exchange',
    :amqp_prefetch  => 'amqp.prefetch',

    :sql_url => 'sql.url',

    :mirror_urlbase => 'mirror.urlbase',
    :mirror_persister => 'mirror.persister',
    :mirror_history_pages_back => 'mirror.history_pages_back',
    :uniq_id => 'mirror.uniq_id',
    :user_agent => 'mirror.user_agent',

    :github_username => 'mirror.username',
    :github_passwd => 'mirror.passwd',
    :github_token => 'mirror.token',

    :attach_ip => 'mirror.attach_ip',

    :rescue_loops => 'mirror.rescue_loops',
    :req_limit => 'mirror.req_limit',

    :logging_level => 'logging.level',
    :logging_uniq => 'logging.uniq',
    :logging_file => 'logging.file'
}
DEFAULTS = 
{
    :amqp_host => 'localhost',
    :amqp_port => 5672,
    :amqp_username => 'github',
    :amqp_password => 'github',
    :amqp_exchange => 'github',
    :amqp_prefetch  => 1,

    :sql_url => 'sqlite://github.db',

    :mirror_urlbase => 'https://api.github.com/',
    :mirror_persister => 'noop',
    :mirror_history_pages_back => 1,
    :user_agent => 'ghtorrent',

    :github_username => 'foo',
    :github_passwd => 'bar',
    :github_token => '',

    :attach_ip => '0.0.0.0',

    :rescue_loops => 'true',
    :req_limit => 4998,

    :logging_level => 'info',
    :logging_uniq => '',
    :logging_file => 'stdout'
}

Instance Method Summary collapse

Methods included from Utils

included, #read_value, #user_type, #write_value

Instance Method Details

#config(key, use_default = true) ⇒ Object 



70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
 
# File 'lib/ghtorrent/settings.rb', line 70

def config(key, use_default = true)
  begin
    a = read_value(settings, CONFIGKEYS[key])
    if a.nil? && use_default
      DEFAULTS[key]
    else
      a
    end
  rescue StandardError => e
    if use_default
      DEFAULTS[key]
    else
      raise e
    end
  end
end

#merge(more_keys) ⇒ Object 



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

def merge(more_keys)
  more_keys.each {|k,v| CONFIGKEYS[k] = v}
end

#merge_config_values(config, values) ⇒ Object 



91
92
93
94
95
 
# File 'lib/ghtorrent/settings.rb', line 91

def merge_config_values(config, values)
  values.reduce(config) {|acc, k|
    acc.merge_recursive write_value(config, CONFIGKEYS[k[0]], k[1])
  }
end

#override_config(config_file, setting, new_value) ⇒ Object 



97
98
99
 
# File 'lib/ghtorrent/settings.rb', line 97

def override_config(config_file, setting, new_value)
  merge_config_values(config_file, {setting => new_value})
end

#settings ⇒ Object

Raises:

  • (StandardError) 


101
102
103
 
# File 'lib/ghtorrent/settings.rb', line 101

def settings
  raise StandardError.new('Unimplemented')
end