Contents

module MessageStore
  module Postgres
    class Write
      include MessageStore::Write

      dependency :put

      def configure(session: nil)
        Put.configure(self, session: session)
      end

      def write(batch, stream_name, expected_version: nil)
        logger.trace(tag: :write) { "Writing batch (Stream Name: #{stream_name}, Number of Messages: #{batch.length}, Expected Version: #{expected_version.inspect})" }

        unless expected_version.nil?
          expected_version = ExpectedVersion.canonize(expected_version)
        end

        last_position = nil
        put.session.transaction do
          batch.each do |message_data|
            last_position = write_message_data(message_data, stream_name, expected_version: expected_version)

            unless expected_version.nil?
              expected_version += 1
            end
          end
        end

        logger.debug(tag: :write) { "Wrote batch (Stream Name: #{stream_name}, Number of Messages: #{batch.length}, Expected Version: #{expected_version.inspect})" }

        last_position
      end

      def write_message_data(message_data, stream_name, expected_version: nil)
        logger.trace(tag: :write) { "Writing message data (Stream Name: #{stream_name}, Type: #{message_data.type}, Expected Version: #{expected_version.inspect})" }
        logger.trace(tags: [:data, :message_data, :write]) { message_data.pretty_inspect }

        put.(message_data, stream_name, expected_version: expected_version).tap do
          logger.debug(tag: :write) { "Wrote message data (Stream Name: #{stream_name}, Type: #{message_data.type}, Expected Version: #{expected_version.inspect})" }
          logger.debug(tags: [:data, :message_data, :write]) { message_data.pretty_inspect }
        end
      end
    end
  end
end

Version data entries

22 entries across 22 versions & 1 rubygems

Version	Path
evt-message_store-postgres-0.10.2.0	lib/message_store/postgres/write.rb
evt-message_store-postgres-0.10.1.0	lib/message_store/postgres/write.rb
evt-message_store-postgres-0.10.0.1	lib/message_store/postgres/write.rb
evt-message_store-postgres-0.10.0.0	lib/message_store/postgres/write.rb
evt-message_store-postgres-0.9.0.0	lib/message_store/postgres/write.rb
evt-message_store-postgres-0.8.0.0	lib/message_store/postgres/write.rb
evt-message_store-postgres-0.7.0.2	lib/message_store/postgres/write.rb
evt-message_store-postgres-0.7.0.1	lib/message_store/postgres/write.rb
evt-message_store-postgres-0.7.0.0	lib/message_store/postgres/write.rb
evt-message_store-postgres-0.6.0.2	lib/message_store/postgres/write.rb
evt-message_store-postgres-0.6.0.1	lib/message_store/postgres/write.rb
evt-message_store-postgres-0.6.0.0	lib/message_store/postgres/write.rb
evt-message_store-postgres-0.4.2.0	lib/message_store/postgres/write.rb
evt-message_store-postgres-0.4.1.0	lib/message_store/postgres/write.rb
evt-message_store-postgres-0.4.0.1	lib/message_store/postgres/write.rb
evt-message_store-postgres-0.4.0.0	lib/message_store/postgres/write.rb
evt-message_store-postgres-0.3.0.3	lib/message_store/postgres/write.rb
evt-message_store-postgres-0.3.0.2	lib/message_store/postgres/write.rb
evt-message_store-postgres-0.3.0.1	lib/message_store/postgres/write.rb
evt-message_store-postgres-0.3.0.0	lib/message_store/postgres/write.rb