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 "    before_validation do\n      \#{adapter_name}.try_nullify||\#{adapter_name}.try_commit\n      \#{adapter_name}.target_process_do\n    end\n\n    before_save do\n      \#{adapter_name}.update_target_if_changed!\n    end\n\n    after_save do\n      \#{adapter_name}.try_destroy_backup\n      \#{adapter_name}.clear!\n    end\n\n    after_destroy do\n      \#{adapter_name}.try_destroy\n    end\n\n    def \#{adapter_name}\n      @\#{adapter_name} ||= ActiveTools::ActiveRecord::AdaptiveBelongsTo::Adapter.new(self, :\#{assoc_name}, adaptive_options[:\#{assoc_name}])\n    end\n  EOV\n\n  attr_map.each do |remote_attribute, local_attribute|\n    if Rails.version >= \"5.0\"\n      attribute local_attribute, reflection.klass.attribute_types[remote_attribute].dup\n      after_initialize do\n        self[local_attribute] = send(local_attribute)\n      end\n    end\n    relation_options_under(local_attribute, assoc_name => remote_attribute)\n    class_eval do\n      define_method local_attribute do\n        send(adapter_name).read(remote_attribute)\n      end\n      define_method \"\#{local_attribute}=\" do |value|\n        if Rails.version >= \"5.0\"\n          super send(adapter_name).write(remote_attribute, value)\n        else\n          send(adapter_name).write(remote_attribute, value)\n        end\n      end\n    end\n  end\n\nend\n"

#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