Module: TableSync::ORMAdapter::ActiveRecord

Defined in:
lib/table_sync/orm_adapter/active_record.rb

Class Method Summary collapse

Class Method Details

.attributes(object) ⇒ Object 



19
20
21
 
# File 'lib/table_sync/orm_adapter/active_record.rb', line 19

def attributes(object)
  object.attributes
end

.find(dataset, conditions) ⇒ Object 



15
16
17
 
# File 'lib/table_sync/orm_adapter/active_record.rb', line 15

def find(dataset, conditions)
  dataset.find_by(conditions)
end

.model ⇒ Object 



7
8
9
 
# File 'lib/table_sync/orm_adapter/active_record.rb', line 7

def model
  ::TableSync::Model::ActiveRecord
end

.model_naming(object) ⇒ Object 



11
12
13
 
# File 'lib/table_sync/orm_adapter/active_record.rb', line 11

def model_naming(object)
  ::TableSync::NamingResolver::ActiveRecord.new(table_name: object.table_name)
end

.setup_sync(klass, **opts) ⇒ Object 



23
24
25
26
27
28
29
30
31
32
33
34
 
# File 'lib/table_sync/orm_adapter/active_record.rb', line 23

def setup_sync(klass, **opts)
  debounce_time = opts.delete(:debounce_time)

  klass.instance_exec do
    { create: :created, update: :updated, destroy: :destroyed }.each do |event, state|
      after_commit(on: event, **opts) do
        TableSync::Publisher.new(self.class.name, attributes,
                                 state: state, debounce_time: debounce_time).publish
      end
    end
  end
end