module GtfsReader

This default config file creates a [FeedDefinition] that matches the one specified by Google. You can use this definition in most cases. A custom definition will only be required if you need to parse a feed that differs in some critical way (Remember that these feeds are not always created by technically-proficient people). See developers.google.com/transit/gtfs/reference

Constants

CSV_OPTIONS

Public Instance Methods

config(*args, &blk) click to toggle source

@override config(*args, &blk)

@param args [Array] an array or arguments to pass to the given block
@param blk [Proc] a block to to call in the context of the configuration
  object. Subsequent calls will use the same configuration for additional
  modification.
@return [Configuration] the configuration object

@override config

@return [Configuration] the configuration object

# File lib/gtfs_reader/core.rb, line 18
def config(*args, &blk)
  @cfg ||= create_config

  if block_given?
    @cfg.instance_exec(*args.unshift(@cfg), &blk)
  elsif args.any?
    raise ArgumentError, 'arguments given without a block'
  end
  @cfg
end

create_config() click to toggle source

# File lib/gtfs_reader/core.rb, line 66
def create_config
  Configuration.new.tap do |cfg|
    cfg.instance_exec do
      parameter(:verbose)
      parameter(:skip_parsing)
      parameter(:return_hashes)
      block_parameter(:sources, Config::Sources)
      block_parameter(:feed_definition, Config::FeedDefinition)
    end
  end
end

update(name) click to toggle source

# File lib/gtfs_reader/core.rb, line 33
def update(name)
  if config.verbose
    update_verbosely(name)
  else
    Log.quiet { update_verbosely(name) }
  end
end

update_all!() click to toggle source

# File lib/gtfs_reader/core.rb, line 29
def update_all!
  config.sources.each { |name, _| update(name) }
end

update_verbosely(name) click to toggle source

# File lib/gtfs_reader/core.rb, line 41
def update_verbosely(name)
  source = config.sources[name]
  raise UnknownSourceError, "No source named '#{name}'" if source.nil?

  updater = SourceUpdater.new(name, source)
  begin
    updater.instance_exec do
      Log.info { "Updating #{name.to_s.green}".underline }
      before_callbacks
      download_source
      check_files
      check_columns
      process_files
      Log.info { "Finished updating #{name.to_s.green}" }
    end
  rescue SkipSourceError => e
    Log.warn do
      msg = e.message ? ": #{e.message}" : ''
      "#{'Skipping'.red} #{source.name.to_s.yellow}" + msg
    end
  ensure
    updater.close
  end
end