module Syncromesh

Constants

VERSION

Public Class Methods

after_change(model) click to toggle source
# File lib/syncromesh.rb, line 78
def self.after_change(model)
  if transport == :pusher
    pusher.trigger(Syncromesh.channel, 'change', klass: model.class.name, record: model.react_serializer)
  elsif transport == :simple_poller
    SimplePoller.write('change', {klass: model.class.name, record: model.react_serializer})
  elsif transport != :none
    raise "Unknown transport #{Syncromesh.transport} - not supported"
  end
end
after_destroy(model) click to toggle source
# File lib/syncromesh.rb, line 88
def self.after_destroy(model)
  if transport == :pusher
    pusher.trigger(Syncromesh.channel, 'destroy', klass: model.class.name, record: model.react_serializer)
  elsif transport == :simple_poller
    SimplePoller.write('destroy', {klass: model.class.name, record: model.react_serializer})
  elsif transport != :none
    raise "Unknown transport #{Syncromesh.transport} - not supported"
  end
end
channel() click to toggle source
# File lib/syncromesh.rb, line 74
def self.channel
  "#{channel_prefix}"
end
pusher() click to toggle source
# File lib/syncromesh.rb, line 61
def self.pusher
  unless channel_prefix
    transport = nil
    raise "******** NO CHANNEL PREFIX SET ***************"
  end
  @pusher ||= Pusher::Client.new(
    app_id: app_id,
    key: key,
    secret: secret,
    encrypted: encrypted
  )
end