Class: Aspera::PersistencyActionOnce

Inherits:

Object

• Object
• Aspera::PersistencyActionOnce

Defined in:

lib/aspera/persistency_action_once.rb

Overview

Persist data on file system

Instance Method Summary

• #data ⇒ Object
• #initialize(options) ⇒ PersistencyActionOnce constructor

  A new instance of PersistencyActionOnce.

• #save ⇒ Object

Constructor Details

#initialize(options) ⇒ PersistencyActionOnce

# File 'lib/aspera/persistency_action_once.rb', line 16

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 :id (String)' unless options[:id].is_a?(String)
  raise 'mandatory 1 element in :id' unless options[:id].length >= 1
  @manager = options[:manager]
  @persisted_object = options[:data]
  @object_id = options[:id]
  # 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_id)
  persist_merge.call(@persisted_object, persist_parse.call(value)) unless value.nil?
end

Instance Method Details

#data ⇒ Object

# File 'lib/aspera/persistency_action_once.rb', line 43

def data
  return @persisted_object
end

#save ⇒ Object

# File 'lib/aspera/persistency_action_once.rb', line 35

def save
  if @delete_condition.call(@persisted_object)
    @manager.delete(@object_id)
  else
    @manager.put(@object_id, @persist_format.call(@persisted_object))
  end
end