Module: CachedAt::BelongsToAssociation

Defined in:
lib/cached_at/associations/belongs_to_association.rb

Instance Method Summary collapse

Instance Method Details

#replace(record) ⇒ Object 



52
53
54
55
56
57
58
59
60
61
62
 
# File 'lib/cached_at/associations/belongs_to_association.rb', line 52

def replace(record)
  if options[:cached_at] && options[:inverse_of]
    timestamp = Time.now
    cache_column = "#{options[:inverse_of]}_cached_at"
    if loaded? && target
      target.raw_write_attribute(cache_column, timestamp)
    end
  end
  
  super
end

#touch_cached_at(timestamp, method) ⇒ Object 



4
5
6
7
8
9
10
11
12
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
47
48
49
50
 
# File 'lib/cached_at/associations/belongs_to_association.rb', line 4

def touch_cached_at(timestamp, method)
  return unless options[:cached_at]

  if !options[:inverse_of]
    puts "WARNING: cannot updated cached at for relationship: #{owner.class.name}.#{name}, inverse_of not set"
    return
  end
  
  types = {}

  cache_column = "#{options[:inverse_of]}_cached_at"
  if options[:polymorphic]
    oldtype = owner.send("#{reflection.foreign_type}_was")
    oldid = owner.send("#{reflection.foreign_key}_was")
    newtype = owner.send(reflection.foreign_type)
    newid = owner.send(reflection.foreign_key)
    if !oldtype.nil? && oldtype == newtype
      model_klass = oldtype.constantize
      query = model_klass.where({ (options[:primary_key] || 'id') => [oldid, newid] })
      query.update_all({ cache_column => timestamp })
      traverse_relationships(model_klass, options[:cached_at], query, cache_column, timestamp)
    else
      if oldtype
        model_klass = oldtype.constantize
        query = model_klass.where({ (options[:primary_key] || 'id') => oldid })
        query.update_all({ cache_column => timestamp })
        traverse_relationships(model_klass, options[:cached_at], query, cache_column, timestamp)
      end
      
      if newtype
        model_klass = newtype.constantize
        query = model_klass.where({ (options[:primary_key] || 'id') => newid })
        query.update_all({ cache_column => timestamp })
        traverse_relationships(model_klass, options[:cached_at], query, cache_column, timestamp)
      end
    end
  else
    ids = [owner.send(reflection.foreign_key), owner.send("#{reflection.foreign_key}_was")].compact.uniq
    query = klass.where({ reflection.association_primary_key => ids })
    query.update_all({ cache_column => timestamp })
    traverse_relationships(klass, options[:cached_at], query, cache_column, timestamp)
  end
  
  if loaded? && target
    target.raw_write_attribute(cache_column, timestamp)
  end
end