Class: Horza::Adapters::ActiveRecord

Inherits:
AbstractAdapter show all
Defined in:
lib/horza/adapters/active_record.rb

Constant Summary collapse

INVALID_ANCESTRY_MSG = 
'Invalid relation. Ensure that the plurality of your associations is correct.'
CONTEXT_NAMESPACE = 
::ActiveRecord::Base

Instance Attribute Summary

Attributes inherited from AbstractAdapter

#context

Class Method Summary collapse

Instance Method Summary collapse

Methods included from ClassMethods

#context_for_entity, #expected_errors, #expected_horza_errors, #horza_error_from_orm_error, #lazy_load_model, #not_implemented_error

Methods included from InstanceMethods

#create, #create_as_child, #delete, #find_first, #get, #initialize, #update

Class Method Details

.entity_context_map ⇒ Object 



8
9
10
11
12
 
# File 'lib/horza/adapters/active_record.rb', line 8

def entity_context_map
  # Rails doesn't preload classes in development mode, caching doesn't make sense
  return ::Horza.descendants_map(CONTEXT_NAMESPACE) if ::Horza.configuration.development_mode
  @map ||= ::Horza.descendants_map(CONTEXT_NAMESPACE)
end

.expected_errors_map ⇒ Object 



14
15
16
17
18
19
20
 
# File 'lib/horza/adapters/active_record.rb', line 14

def expected_errors_map
  {
    ::ActiveRecord::RecordNotFound => Horza::Errors::RecordNotFound,
    ::ActiveRecord::RecordInvalid => Horza::Errors::RecordInvalid,
    ::ActiveRecord::UnknownAttributeError => Horza::Errors::UnknownAttributeError
  }
end

Instance Method Details

#association(options = {}) ⇒ Object 



67
68
69
70
71
72
73
74
75
76
77
78
79
80
 
# File 'lib/horza/adapters/active_record.rb', line 67

def association(options = {})
  run_and_convert_exceptions do
    options = Options.new(options)

    base = @context
    base = base.includes(options.eager_args) if options.eager_load?
    base = base.find(options.id)

    result = walk_family_tree(base, options)
    return nil unless result

    collection?(result) ? entity_class(query(options, result)) : entity_class(result.attributes)
  end
end

#create!(options = {}) ⇒ Object 



35
36
37
38
39
40
41
 
# File 'lib/horza/adapters/active_record.rb', line 35

def create!(options = {})
  run_and_convert_exceptions do
    record = @context.new(options)
    record.save!
    entity_class(record.attributes)
  end
end

#create_as_child!(parent_args, options = {}) ⇒ Object 



43
44
45
46
47
48
 
# File 'lib/horza/adapters/active_record.rb', line 43

def create_as_child!(parent_args, options = {})
  run_and_convert_exceptions do
    parent = Horza.adapter.context_for_entity(parent_args[:klass]).find(parent_args[:id])
    create!(options.merge(parent_args[:klass] => parent))
  end
end

#delete!(id) ⇒ Object 



59
60
61
62
63
64
65
 
# File 'lib/horza/adapters/active_record.rb', line 59

def delete!(id)
  run_and_convert_exceptions do
    record = @context.find(id)
    record.destroy
    true
  end
end

#find_all(options = {}) ⇒ Object 



31
32
33
 
# File 'lib/horza/adapters/active_record.rb', line 31

def find_all(options = {})
  run_and_convert_exceptions { entity_class(query(options)) }
end

#find_first!(options = {}) ⇒ Object 



27
28
29
 
# File 'lib/horza/adapters/active_record.rb', line 27

def find_first!(options = {})
  run_and_convert_exceptions { entity_class(query(options).first!.attributes) }
end

#get!(id) ⇒ Object 



23
24
25
 
# File 'lib/horza/adapters/active_record.rb', line 23

def get!(id)
  run_and_convert_exceptions { entity_class(@context.find(id).attributes) }
end

#to_hash ⇒ Object

Raises:



82
83
84
85
86
 
# File 'lib/horza/adapters/active_record.rb', line 82

def to_hash
  raise ::Horza::Errors::CannotGetHashFromCollection.new if collection?
  raise ::Horza::Errors::QueryNotYetPerformed.new unless @context.respond_to?(:attributes)
  @context.attributes
end

#update!(id, options = {}) ⇒ Object 



50
51
52
53
54
55
56
57
 
# File 'lib/horza/adapters/active_record.rb', line 50

def update!(id, options = {})
  run_and_convert_exceptions do
    record = @context.find(id)
    record.assign_attributes(options)
    record.save!
    entity_class(record.attributes)
  end
end