module Neo4j
module Rails
# This module handles the getting, setting and updating of attributes or properties
# in a Railsy way. This typically means not writing anything to the DB until the
# object is saved (after validation).
#
# Externally, when we talk about properties (e.g. #property?, #property_names, #properties),
# we mean all of the stored properties for this object include the 'hidden' props
# with underscores at the beginning such as _neo_id and _classname. When we talk
# about attributes, we mean all the properties apart from those hidden ones.
module Attributes
extend ActiveSupport::Concern
included do
include ActiveModel::Dirty # track changes to attributes
include ActiveModel::MassAssignmentSecurity # handle attribute hash assignment
class_inheritable_hash :attribute_defaults
self.attribute_defaults ||= {}
# save the original [] and []= to use as read/write to Neo4j
alias_method :read_attribute, :[]
alias_method :write_attribute, :[]=
# wrap the read/write in type conversion
alias_method_chain :read_local_property, :type_conversion
alias_method_chain :write_local_property, :type_conversion
# whenever we refer to [] or []=. use our local properties store
alias_method :[], :read_local_property
alias_method :[]=, :write_local_property
end
# The behaviour of []= changes with a Rails Model, where nothing gets written
# to Neo4j until the object is saved, during which time all the validations
# and callbacks are run to ensure correctness
def write_local_property(key, value)
key_s = key.to_s
if @properties[key_s] != value
attribute_will_change!(key_s)
@properties[key_s] = value
end
value
end
# Returns the locally stored value for the key or retrieves the value from
# the DB if we don't have one
def read_local_property(key)
key = key.to_s
if @properties.has_key?(key)
@properties[key]
else
@properties[key] = (persisted? && _java_entity.has_property?(key)) ? read_attribute(key) : attribute_defaults[key]
end
end
# Mass-assign attributes. Stops any protected attributes from being assigned.
def attributes=(attributes, guard_protected_attributes = true)
attributes = sanitize_for_mass_assignment(attributes) if guard_protected_attributes
multi_parameter_attributes = []
attributes.each do |k, v|
if k.to_s.include?("(")
multi_parameter_attributes << [ k, v ]
else
respond_to?("#{k}=") ? send("#{k}=", v) : self[k] = v
end
end
assign_multiparameter_attributes(multi_parameter_attributes)
end
# Instantiates objects for all attribute classes that needs more than one constructor parameter. This is done
# by calling new on the column type or aggregation type (through composed_of) object with these parameters.
# So having the pairs written_on(1) = "2004", written_on(2) = "6", written_on(3) = "24", will instantiate
# written_on (a date type) with Date.new("2004", "6", "24"). You can also specify a typecast character in the
# parentheses to have the parameters typecasted before they're used in the constructor. Use i for Fixnum,
# f for Float, s for String, and a for Array. If all the values for a given attribute are empty, the
# attribute will be set to nil.
def assign_multiparameter_attributes(pairs)
execute_callstack_for_multiparameter_attributes(
extract_callstack_for_multiparameter_attributes(pairs)
)
end
def execute_callstack_for_multiparameter_attributes(callstack)
errors = []
callstack.each do |name, values_with_empty_parameters|
begin
# (self.class.reflect_on_aggregation(name.to_sym) || column_for_attribute(name)).klass
decl_type = self.class._decl_props[name.to_sym][:type]
raise "Not a multiparameter attribute, missing :type on property #{name} for #{self.class}" unless decl_type
# in order to allow a date to be set without a year, we must keep the empty values.
values = values_with_empty_parameters.reject { |v| v.nil? }
if values.empty?
send(name + "=", nil)
else
value = if :time == decl_type
instantiate_time_object(name, values)
elsif :date == decl_type
begin
values = values_with_empty_parameters.collect do |v| v.nil? ? 1 : v end
Date.new(*values)
rescue ArgumentError => ex # if Date.new raises an exception on an invalid date
instantiate_time_object(name, values).to_date # we instantiate Time object and convert it back to a date thus using Time's logic in handling invalid dates
end
elsif :datetime == decl_type
DateTime.new(*values)
else
raise "Unknown type #{decl_type}"
end
send(name + "=", value)
end
rescue Exception => ex
raise "error on assignment #{values.inspect} to #{name}, ex: #{ex}"
end
end
unless errors.empty?
raise MultiparameterAssignmentErrors.new(errors), "#{errors.size} error(s) on assignment of multiparameter attributes"
end
end
def instantiate_time_object(name, values)
# if self.class.send(:create_time_zone_conversion_attribute?, name, column_for_attribute(name))
# Time.zone.local(*values)
# else
Time.time_with_datetime_fallback(self.class.default_timezone, *values)
# end
end
def extract_callstack_for_multiparameter_attributes(pairs)
attributes = { }
for pair in pairs
multiparameter_name, value = pair
attribute_name = multiparameter_name.split("(").first
attributes[attribute_name] = [] unless attributes.include?(attribute_name)
parameter_value = value.empty? ? nil : type_cast_attribute_value(multiparameter_name, value)
attributes[attribute_name] << [ find_parameter_position(multiparameter_name), parameter_value ]
end
attributes.each { |name, values| attributes[name] = values.sort_by{ |v| v.first }.collect { |v| v.last } }
end
def type_cast_attribute_value(multiparameter_name, value)
multiparameter_name =~ /\([0-9]*([if])\)/ ? value.send("to_" + $1) : value
end
def find_parameter_position(multiparameter_name)
multiparameter_name.scan(/\(([0-9]*).*\)/).first.first
end
# Tracks the current changes and clears the changed attributes hash. Called
# after saving the object.
def clear_changes
@previously_changed = changes
@changed_attributes.clear
end
# Return the properties from the Neo4j Node, merged with those that haven't
# yet been saved
def props
ret = {}
property_names.each do |property_name|
ret[property_name] = respond_to?(property_name) ? send(property_name) : send(:[], property_name)
end
ret
end
# Return all the attributes for this model as a hash attr => value. Doesn't
# include properties that start with _.
def attributes
ret = {}
attribute_names.each do |attribute_name|
ret[attribute_name] = respond_to?(attribute_name) ? send(attribute_name) : send(:[], attribute_name)
end
ret
end
# Known properties are either in the @properties, the declared
# attributes or the property keys for the persisted node.
def property_names
keys = @properties.keys + self.class._decl_props.keys.map { |k| k.to_s }
keys += _java_entity.property_keys.to_a if persisted?
keys.flatten.uniq
end
# Known attributes are either in the @properties, the declared
# attributes or the property keys for the persisted node. Any attributes
# that start with _ are rejected
def attribute_names
property_names.reject { |property_name| property_name[0] == ?_ }
end
# Known properties are either in the @properties, the declared
# properties or the property keys for the persisted node
def property?(name)
@properties.keys.include?(name) ||
self.class._decl_props.map { |k| k.to_s }.include?(name) ||
begin
persisted? && super
rescue org.neo4j.graphdb.NotFoundException
set_deleted_properties
nil
end
end
# Return true if method_name is the name of an appropriate attribute
# method
def attribute?(name)
name[0] != ?_ && property?(name)
end
# To get ActiveModel::Dirty to work, we need to be able to call undeclared
# properties as though they have get methods
def method_missing(method_id, *args, &block)
method_name = method_id.to_s
if property?(method_name)
self[method_name]
else
super
end
end
def respond_to?(method_id, include_private = false)
method_name = method_id.to_s
if property?(method_name)
true
else
super
end
end
# Wrap the getter in a conversion from Java to Ruby
def read_local_property_with_type_conversion(property)
Neo4j::TypeConverters.to_ruby(self.class, property, read_local_property_without_type_conversion(property))
end
# Wrap the setter in a conversion from Ruby to Java
def write_local_property_with_type_conversion(property, value)
write_local_property_without_type_conversion(property, Neo4j::TypeConverters.to_java(self.class, property, value))
end
end
end
end