Module: Wakame::StatusDB::Model::ClassMethods

Defined in:

lib/wakame/status_db.rb

Instance Method Summary

• #_instance_cache ⇒ Object
• #delete(id) ⇒ Object
• #disable_cache ⇒ Object
• #enable_cache ⇒ Object
• #exists?(id) ⇒ Boolean
• #find(id) ⇒ Object
• #find_all ⇒ Object
• #property(key, opts = {}) ⇒ Object

  A helper method to define an accessor with persistent flag.

Instance Method Details

#_instance_cache ⇒ Object

# File 'lib/wakame/status_db.rb', line 172

def _instance_cache
  return {} unless @enable_cache

  @_instance_cache ||= {}
end

#delete(id) ⇒ Object

# File 'lib/wakame/status_db.rb', line 242

def delete(id)
  obj = find(id)
  if obj
    obj.on_before_delete
    StatusDB.barrier {
      StatusDB.adapter.delete(id)
    }
    _instance_cache.delete(id)

    obj.on_after_delete 
  end
end

#disable_cache ⇒ Object

# File 'lib/wakame/status_db.rb', line 165

def disable_cache
  if @enable_cache
    @enable_cache = false
    @_instance_cache = {}
  end
end

#enable_cache ⇒ Object

# File 'lib/wakame/status_db.rb', line 158

def enable_cache
  unless @enable_cache
    @enable_cache = true
    @_instance_cache = {}
  end
end

#exists?(id) ⇒ Boolean

Returns:

• (Boolean)

# File 'lib/wakame/status_db.rb', line 225

def exists?(id) 
  StatusDB.barrier {
    _instance_cache.has_key?(id) || StatusDB.adapter.exists?(id)
  }
end

#find(id) ⇒ Object

# File 'lib/wakame/status_db.rb', line 178

def find(id)
  raise "Can not retrieve the data with nil." if id.nil?
  obj = _instance_cache[id]
  return obj unless obj.nil?

  hash = StatusDB.barrier {
    StatusDB.adapter.find(id)
  }
  return nil unless hash

  if hash[AttributeHelper::CLASS_TYPE_KEY]
    klass_const = Util.build_const(hash[AttributeHelper::CLASS_TYPE_KEY])
  else
    klass_const = self
  end
  
  # klass_const class is equal to self class or child of self class
  if klass_const <= self
    obj = klass_const.new
  else
    raise "Can not instanciate the object #{klass_const.to_s} from #{self}"
  end
  
  obj.on_before_load
  
  obj.instance_variable_set(:@id, id)
  obj.instance_variable_set(:@load_at, Time.now)
  
  hash.each { |k,v|
    obj.instance_variable_set("@#{k}", v)
  }
  
  obj.on_after_load

  _instance_cache[id] = obj
  obj
end

#find_all ⇒ Object

# File 'lib/wakame/status_db.rb', line 217

def find_all
  StatusDB.barrier {
    StatusDB.adapter.find_all(self.to_s).map { |id|
      find(id)
    }
  }
end

#property(key, opts = {}) ⇒ Object

A helper method to define an accessor with persistent flag.

# File 'lib/wakame/status_db.rb', line 232

def property(key, opts={})
  case opts 
  when Hash
    opts.merge!({:persistent=>true})
  else
    opts = {:persistent=>true}
  end
  def_attribute(key.to_sym, opts)
end