Sha256: 06d18154df63b7aff41fdcc44365a380a7fc4d1d8dd01026039eeb5de7cc382b
Contents?: true
Size: 1.7 KB
Versions: 19
Compression:
Stored size: 1.7 KB
Contents
# frozen_string_literal: true
require 'ostruct'
require 'pathname'
module Quby
module Answers
module Repos
class DiskRepo < Base
class Record < OpenStruct
end
attr_reader :path
def initialize(path)
@path = Pathname.new(path).expand_path
end
def find_completed_after(time, answer_ids)
records = storage.map { |filename| load_file(filename) }.select do |record|
answer_ids.include?(record._id) && record.completed_at.present? && record.completed_at > time
end
records.map { |record| entity(record) }
end
private
def all_records(questionnaire_key)
storage.map { |filename| load_file(filename) }
.select { |record| record.questionnaire_key == questionnaire_key }
end
def find_record(id)
load_file(path.join("answer-#{id}.yml"))
rescue StandardError
nil
end
def load_file(filename)
File.open(filename, 'r') do |file|
record = YAML.load(file.read)
record.created_at ||= File.ctime(filename)
record
end
end
def build_record
Record.new(_id: SecureRandom.uuid)
end
def store_record(record)
filename = path.join("answer-#{record[:_id]}.yml")
File.open(filename, 'w') do |file|
file.write YAML.dump(record)
end
record.created_at ||= File.ctime(filename)
end
def storage
Dir[path.join("*.yml")]
end
def entity(record)
entity_class.new(record.to_h).tap(&:enhance_by_dsl)
end
end
end
end
end
Version data entries
19 entries across 19 versions & 1 rubygems