Sha256: 86c6d83e8274dddaa4b0ac94f254130bc161234b8054d87d29724d43536ac423
Contents?: true
Size: 1.7 KB
Versions: 8
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
8 entries across 8 versions & 1 rubygems