Contents

require 'asir'

module ASIR
  class Transport
    # Transport that stores to any model class that responds to:
    #
    # obj.save!
    # obj.database_id
    #
    # See Coder::Database
    #
    class Database < self
      attr_accessor :before_message_save, :after_message_save
      attr_accessor :before_result_save, :after_result_save

      def initialize *args
        super
        self.coder_needs_result_message = true
        self.needs_message_identifier = true
      end

      def _send_message state
        if @before_message_save
          @before_message_save.call(self, state)
        end
        state.message_payload.save!
        # message[:database_id] ||= message_payload.database_id
        if @after_message_save
          @after_message_save.call(self, state)
        end
      end

      def _send_result state
        return if one_way? or state.message.one_way?
        if @before_result_save
          @before_result_save.call(self, state)
        end
        state.result_payload.save!
        result[:database_id] = result_payload.database_id
        if @after_result_save
          @after_result_save.call(self, state)
        end
      end
    end
  end
end

Version data entries

11 entries across 11 versions & 1 rubygems

Version	Path
asir-1.2.11	lib/asir/transport/database.rb
asir-1.2.10	lib/asir/transport/database.rb
asir-1.2.9	lib/asir/transport/database.rb
asir-1.2.8	lib/asir/transport/database.rb
asir-1.2.7	lib/asir/transport/database.rb
asir-1.2.6	lib/asir/transport/database.rb
asir-1.2.5	lib/asir/transport/database.rb
asir-1.2.3	lib/asir/transport/database.rb
asir-1.2.2	lib/asir/transport/database.rb
asir-1.2.1	lib/asir/transport/database.rb
asir-1.2.0	lib/asir/transport/database.rb