Sha256: 2e755984157159fe9f461c03d8e2075a87489f310017a4bdbf6ee5d4f3ebc636
Contents?: true
Size: 1.39 KB
Versions: 13
Compression:
Stored size: 1.39 KB
Contents
module Workarea
module DataFile
class Json < Format
def import!
index = 1
file_stream = File.open(file.path, 'r')
streamer = ::Json::Streamer.parser(file_io: file_stream)
streamer.get(nesting_level: 1) do |attrs|
instance = find_updated_model_for(attrs)
assign_password(instance, attrs['password'])
instance.save
log(index, instance)
index += 1
end
end
def export!
tempfile.write("[\n")
models.each_with_index do |model, i|
tempfile.write(JSON.pretty_generate(serialize_model(model)))
tempfile.write(',') unless i == models.count - 1
tempfile.write("\n")
end
tempfile.write("]\n")
end
def serialize_model(model)
clean_ignored_fields(
model.as_json.reverse_merge(
_type: model.class.name
)
)
end
private
def find_updated_model_for(attrs)
id = attrs['_id'].presence || attrs['id'].presence || attrs[:_id].presence || attrs[:id]
model_class = model_class_for(attrs)
attributes = attrs.except('_type', :_type)
if id.present?
result = model_class.find_or_initialize_by(id: id)
result.attributes = attributes
result
else
model_class.new(attributes)
end
end
end
end
end
Version data entries
13 entries across 13 versions & 1 rubygems