module Lanes::API::Updates
Public Class Methods
relay!()
click to toggle source
# File lib/lanes/api/updates.rb, line 16 def self.relay! if @relaying_messages raise "Already relaying messages, calling relay! twice will lead to message duplication" end @relaying_messages = true Lanes::Model.observe(:save) do |model| if model.changes.any? path = "/#{model.class.api_path(with_module: true)}/#{model.id}" Lanes::API::PubSub.publish(path, { by: self.user_info_for_change(model), update: model.changes }) end end end
user_info_for_change(model)
click to toggle source
# File lib/lanes/api/updates.rb, line 8 def self.user_info_for_change(model) if model.has_attribute?(:updated_by_id) model.updated_by.as_json(only:[:id,:name,:email]) else {} end end