Contents

require 'active_support/core_ext/string/inflections'

require 'cony'
require 'cony/amqp_connection_handler'

module Cony
  module ActiveRecord

    extend ActiveSupport::Concern

    included do
      after_create :cony_send_create_notify
      after_update :cony_send_update_notify
      after_destroy :cony_send_destroy_notify
    end

    def cony_send_create_notify
      publish(:created, cony_changes_created)
    end

    def cony_send_update_notify
      publish(:updated, cony_changes_updated)
    end

    def cony_send_destroy_notify
      publish(:destroyed, cony_changes_destroyed)
    end


    private
    def publish(type, cony_changes)
      return if Cony.config.test_mode
      amqp_connection.publish(
        {id: self.id, changes: cony_changes, model: self.class.name, event: type},
        "#{self.class.name.underscore}.mutation.#{type}")
    end

    def amqp_connection
      @amqp_connection ||= Cony::AMQPConnectionHandler.new(Cony.config.amqp)
    end

    def mapped_changes
      changes.map do |name, change|
        {name => {old: change.first, new: change.last}}
      end
    end

    def cony_changes_created
      mapped_changes
    end

    def cony_changes_updated
      mapped_changes
    end

    def cony_changes_destroyed
      attributes.map do |name, value|
        {name => {old: value, new: nil}}
      end
    end
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
cony-1.3.0	lib/cony/active_record.rb