Module: ActiveTools::ActiveRecord::AdaptiveBelongsTo::ClassMethods

Defined in:
lib/active_tools/active_record/adaptive_belongs_to.rb

Instance Method Summary collapse

Instance Method Details

#adaptive_belongs_to(*args) ⇒ Object

Raises:

  • (TypeError) 


48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
 
# File 'lib/active_tools/active_record/adaptive_belongs_to.rb', line 48

def adaptive_belongs_to(*args)
  options = args.extract_options!
  assoc_name = args.first
  unless reflection = reflections.with_indifferent_access[assoc_name]
    raise(ArgumentError, ":#{assoc_name} method doesn't look like an association accessor!")
  end
  adapter_name = "#{assoc_name}_adaptive"

  raise(TypeError, "Option :attributes must be a Hash. #{options[:attributes].class} passed!") unless options[:attributes].is_a?(Hash)
  attr_map = HashWithIndifferentAccess.new(options.delete(:attributes))
  valid_options = Hash(options.delete(:valid_with)).symbolize_keys
  valid_with assoc_name, valid_options.merge(:attributes => attr_map) #, :fit => true

  class_attribute :adaptive_options unless defined?(adaptive_options)
  self.adaptive_options ||= {}
  self.adaptive_options[assoc_name.to_sym] = options.merge(:attr_map => attr_map)

  class_eval <<-EOV
    before_validation do
      #{adapter_name}.try_nullify||#{adapter_name}.try_commit
      #{adapter_name}.target_process_do
    end

    before_save do
      #{adapter_name}.update_target_if_changed!
    end

    after_save do
      #{adapter_name}.try_destroy_backup
      #{adapter_name}.clear!
    end

    after_destroy do
      #{adapter_name}.try_destroy
    end

    def #{adapter_name}
      @#{adapter_name} ||= ActiveTools::ActiveRecord::AdaptiveBelongsTo::Adapter.new(self, :#{assoc_name}, adaptive_options[:#{assoc_name}])
    end
  EOV

  attr_map.each do |remote_attribute, local_attribute|
    if Rails.version >= "5.0"
      attribute local_attribute, reflection.klass.attribute_types[remote_attribute].dup
      after_initialize do
        self[local_attribute] = send(local_attribute)
      end
    end
    relation_options_under(local_attribute, assoc_name => remote_attribute)
    class_eval do
      define_method local_attribute do
        send(adapter_name).read(remote_attribute)
      end
      define_method "#{local_attribute}=" do |value|
        if Rails.version >= "5.0"
          super send(adapter_name).write(remote_attribute, value)
        else
          send(adapter_name).write(remote_attribute, value)
        end
      end
    end
  end

end

#relation_options_under(*args) ⇒ Object 



13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
 
# File 'lib/active_tools/active_record/adaptive_belongs_to.rb', line 13

def relation_options_under(*args)
  path = args.extract_options!
  local_attribute = args.first
  local_method = "#{local_attribute}_relation_options"

  define_singleton_method local_method do |instance = nil|
    outer_values = {}
    where_values = {}
    path.each do |assoc_name, remote_attributes|
      reflection = reflections.with_indifferent_access[assoc_name]
      target = instance.try(reflection.name)
      outer_values[reflection.name] = {}
      Array(remote_attributes).each do |remote_attribute|
        remote_method = "#{remote_attribute}_relation_options"
        if reflection.klass.respond_to?(remote_method)
          deeper = reflection.klass.send(remote_method, target)
          outer_values[reflection.name].merge!(deeper[:outer_values])
          where_values.merge!(deeper[:where_values])
        else
          where_values[reflection.table_name] ||= {}.with_indifferent_access
          where_values[reflection.table_name][remote_attribute] = target.try(remote_attribute)
        end
      end
    end
    {:outer_values => outer_values, :where_values => where_values}
  end

  class_eval do
    define_method local_method do
      self.class.send(local_method, self)
    end
  end

end