Sha256: 61c30e0dd271e7449d263bf89e6753be3eb6f6671efab87670440dfc1a49d9d6
Contents?: true
Size: 1.82 KB
Versions: 8
Compression:
Stored size: 1.82 KB
Contents
require 'optparse'
require 'ostruct'
module SongkickQueue
class CLI
attr_reader :options
# @param argv [Array<String>] of command line arguments
def initialize(argv)
@options = OpenStruct.new(
libraries: [],
consumers: [],
process_name: 'songkick_queue',
)
parse_options(argv)
end
# Parse the command line arguments using OptionParser
#
# @param argv [Array<String>] of command line arguments
def parse_options(argv)
option_parser = OptionParser.new do |opts|
opts.banner = 'Usage: songkick_queue [options]'
opts.on('-r', '--require LIBRARY',
'Path to require LIBRARY. Usually this will be a file that ',
'requires some consumers') do |lib|
options.libraries << lib
end
opts.on('-c', '--consumer CLASS_NAME',
'Register consumer with CLASS_NAME') do |class_name|
options.consumers << class_name
end
opts.on('-n', '--name NAME',
'Set the process name to NAME') do |name|
options.process_name = name
end
opts.on_tail("-h", "--help", "Show this message") do
puts opts
exit
end
end
option_parser.parse!(argv)
end
# Instantiates and runs a new Worker for the parsed options. Calling this
# method blocks the main Thread. See Worker#run for more info
#
def run
options.libraries.each do |lib|
require lib
end
if options.consumers.empty?
puts 'No consumers provided, exiting. Run `songkick_queue --help` for more info.'
exit 1
end
consumers = options.consumers.map do |class_name|
Object.const_get(class_name)
end
Worker.new(options.process_name, consumers).run
end
end
end
Version data entries
8 entries across 8 versions & 1 rubygems