Contents

require 'active_support/core_ext/string/inflections'

require 'cony'
require 'cony/amqp_connection_handler'

module Cony
  ##
  # Usage:
  # <code>
  # class FooBar < ActiveRecord::Base
  #   include Cony::ActiveRecord
  #   # your things here
  # end
  # </code>
  #
  module ActiveRecord
    extend ActiveSupport::Concern

    included do
      after_create :cony_save_create_notify_data
      after_update :cony_save_update_notify_data
      after_touch  :cony_save_update_notify_data if respond_to?(:after_touch)
      after_destroy :cony_save_destroy_notify_data
      after_commit :cony_publish
    end

    def cony_save_create_notify_data
      cony_prepare_notify :created, cony_changes_created
    end

    def cony_save_update_notify_data
      cony_prepare_notify :updated, cony_changes_updated
    end

    def cony_save_destroy_notify_data
      cony_prepare_notify :destroyed, cony_changes_destroyed
    end

    def cony_publish
      return if Cony.config.test_mode
      return if @cony_notify.nil?
      cony_amqp_connection.publish(cony_notify_hash, cony_notify_routing_key)
    end

    private

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

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

    def cony_changes_created
      cony_mapped_changes
    end

    def cony_changes_updated
      cony_mapped_changes
    end

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

    def cony_notify_hash
      { id: id, changes: @cony_notify[:changes], model: self.class.name, event: @cony_notify[:event] }
    end

    def cony_notify_routing_key
      "#{self.class.name.underscore}.mutation.#{@cony_notify[:event]}"
    end

    def cony_prepare_notify(event, changes)
      @cony_notify = { event: event, changes: changes }
    end
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

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