Contents

module Lanes

    module API

        module Updates
            @relaying_messages = false

            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

            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

        end


    end
end

Version data entries

10 entries across 10 versions & 1 rubygems

Version	Path
lanes-0.8.3	lib/lanes/api/updates.rb
lanes-0.8.2	lib/lanes/api/updates.rb
lanes-0.8.1	lib/lanes/api/updates.rb
lanes-0.8.0	lib/lanes/api/updates.rb
lanes-0.7.0	lib/lanes/api/updates.rb
lanes-0.6.1	lib/lanes/api/updates.rb
lanes-0.6.0	lib/lanes/api/updates.rb
lanes-0.5.6	lib/lanes/api/updates.rb
lanes-0.5.5	lib/lanes/api/updates.rb
lanes-0.5.0	lib/lanes/api/updates.rb