class Aspera::PersistencyActionOnce
Persist data on file system
Public Class Methods
new(options)
click to toggle source
@param :manager Mandatory Database @param :data Mandatory object to persist, must be same object from begin to end (assume array by default) @param :ids Mandatory identifiers @param :delete Optional delete persistency condition @param :parse Optional parse method (default to JSON) @param :format Optional dump method (default to JSON) @param :merge Optional merge data from file to current data
# File lib/aspera/persistency_action_once.rb, line 14 def initialize(options) Log.log.debug("persistency: #{options}") raise "options shall be Hash" unless options.is_a?(Hash) raise "mandatory :manager" if options[:manager].nil? raise "mandatory :data" if options[:data].nil? raise "mandatory :ids (Array)" unless options[:ids].is_a?(Array) raise "mandatory 1 element in :ids" unless options[:ids].length >= 1 @manager=options[:manager] @persisted_object=options[:data] @object_ids=options[:ids] # by default , at save time, file is deleted if data is nil @delete_condition=options[:delete] || lambda{|d|d.empty?} @persist_format=options[:format] || lambda {|h| JSON.generate(h)} persist_parse=options[:parse] || lambda {|t| JSON.parse(t)} persist_merge=options[:merge] || lambda {|current,file| current.concat(file).uniq rescue current} value=@manager.get(@object_ids) persist_merge.call(@persisted_object,persist_parse.call(value)) unless value.nil? end
Public Instance Methods
save()
click to toggle source
# File lib/aspera/persistency_action_once.rb, line 33 def save if @delete_condition.call(@persisted_object) @manager.delete(@object_ids) else @manager.put(@object_ids,@persist_format.call(@persisted_object)) end end