class Ruian
not a really queue
Constants
- VERSION
Attributes
logger[RW]
fetcher[RW]
importer[RW]
queue[RW]
Public Class Methods
load_tasks()
click to toggle source
# File lib/ruian.rb, line 22 def self.load_tasks Dir[File.join(File.dirname(__FILE__),'tasks/*.rake')].each { |f| load f } end
new(importer = Ruian::Importer.new)
click to toggle source
# File lib/ruian.rb, line 30 def initialize(importer = Ruian::Importer.new) self.fetcher = Ruian::Fetcher.new self.importer = importer self.queue = Ruian::Queue.new(importer) end
root()
click to toggle source
# File lib/ruian.rb, line 26 def self.root Pathname.new(File.expand_path('../', File.dirname(__FILE__))) end
Public Instance Methods
all()
click to toggle source
# File lib/ruian.rb, line 77 def all fetch_rows fetch_regions fetch_counties fetch_integrate_counties fetch_integrate_regions self.importer.finalize! end
fetch_counties()
click to toggle source
# File lib/ruian.rb, line 53 def fetch_counties bar = ProgressBar.create(total: 1, title: 'Importing 1 county file.', format: "%a |%b>>%i| %c/%C %p%% %t") self.fetcher.parse_counties(self.queue) { bar.increment } end
fetch_integrate_counties()
click to toggle source
# File lib/ruian.rb, line 61 def fetch_integrate_counties bar = ProgressBar.create(total: 1, title: 'Importing 1 county integration file.', format: "%a |%b>>%i| %c/%C %p%% %t") self.fetcher.parse_counties_integration(self.queue) { bar.increment } end
fetch_integrate_regions()
click to toggle source
# File lib/ruian.rb, line 69 def fetch_integrate_regions bar = ProgressBar.create(total: 1, title: 'Importing 1 region integration file.', format: "%a |%b>>%i| %c/%C %p%% %t") self.fetcher.parse_regions_integration(self.queue) { bar.increment } end
fetch_regions()
click to toggle source
# File lib/ruian.rb, line 45 def fetch_regions bar = ProgressBar.create(total: 1, title: 'Importing 1 region file.', format: "%a |%b>>%i| %c/%C %p%% %t") self.fetcher.parse_regions(self.queue) { bar.increment } end
fetch_rows()
click to toggle source
# File lib/ruian.rb, line 36 def fetch_rows count = fetcher.row_files.count bar = ProgressBar.create(total: count, title: "Importing #{count} row files.", format: "%a |%b>>%i| %c/%C %p%% %t") self.fetcher.parse_rows(self.queue) { bar.increment } end