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