lib/parsley-store.rb
require 'redis'
require 'biodiversity'
require_relative 'parsley-store/version'
if RUBY_VERSION < '1.9.1'
raise 'IMPORTANT: Parsley-store gem requires ruby >= 1.9.1'
end
class ParsleyStore
#database numbers for Redis
LOCAL = 1
SLAVE = 2
def initialize(local_db = LOCAL, slave_db = SLAVE, opts = {})
redis_host = opts[:redis_host] || "0.0.0.0"
@parser = ScientificNameParser.new
@local = Redis.new(host: redis_host)
@local.select(local_db)
end
def parse(scientific_name, opts = {})
@canonical_only = !!opts[:canonical_only]
@scientific_name = scientific_name
parsed_data = get_redis_data
return parsed_data if parsed_data
cache_parsed_data(parse_scientific_name)
end
private
def get_redis_data
if @canonical_only
begin
stored = @local.hget(@scientific_name, 'canonical')
rescue RuntimeError
@local.flushdb
stored = nil
end
return stored if stored
else
stored = @local.get(@scientific_name)
return JSON.parse(stored, symbolize_names: true) if stored
end
end
def parse_scientific_name
begin
@parser.parse(@scientific_name)
rescue
@parser = ScientificNameParser.new
@parser.parse(@scientific_name) rescue {
scientificName: {parsed: false,
parser_version: ScientificNameParser::VERSION,
anonical: nil,
verbatim: @scientific_name}}
end
end
def cache_parsed_data(parsed_data)
if @canonical_only
@local.hset(@scientific_name,
'parsed',
parsed_data[:scientificName][:parsed])
@local.hset(@scientific_name,
'parser_version',
parsed_data[:scientificName][:parser_version])
@local.hset(@scientific_name,
'canonical', parsed_data[:scientificName][:canonical])
parsed_data[:scientificName][:canonical]
else
serialized = parsed_data.to_json
@local.set @scientific_name, serialized
parsed_data
end
end
end