Postgres

.gitignore

@@ -3,8 +3,9 @@ Gemfile.lock
 *.log
 *.gem
 gems
-
-lib/message_store/event_store
-lib/message_store/event_store.rb
-lib/message_store/postgres
-lib/message_store/postgres.rb
+*scratch*
+*notes*
+loader.rb
+/test/package/installed
+/test/benchmark/tmp/**/*
+_sketch.rb

CHANGES.md

@@ -0,0 +1,7 @@
+# Changes
+
+## 2.4.0.1
+
+Thu Dec 19 2019
+
+- Vestigial logging of correlation in Get::Stream is removed (It no longer has correlation handling as of v2)

MIT-License.txt

@@ -1,4 +1,4 @@
-Copyright (c) 2016 Scott Bellware
+Copyright (c) 2015-present Scott Bellware
 
 Permission is hereby granted, free of charge, to any person obtaining
 a copy of this software and associated documentation files (the

README.md

@@ -1,11 +1,11 @@
-# message_store
+# message_store-postgres
 
-Common primitives for platform-specific message store implementations.
+Message store implementation for PostgreSQL.
 
 ## Documentation
 
 See the [Eventide documentation site](http://docs.eventide-project.org) for more information, examples, and user guides.
 
 ## License
 
-The `event_stream-postgres` library is released under the [MIT License](https://github.com/eventide-project/event-stream-postgres/blob/master/MIT-License.txt).
+The `message_store-postgres` library is released under the [MIT License](https://github.com/eventide-project/message-store-postgres/blob/master/MIT-License.txt).

lib/message_store.rb

@@ -1,5 +1,4 @@
-require 'pp'
-require 'json'
+require 'pg'
 
 require 'casing'
 require 'identifier/uuid'
@@ -9,9 +8,12 @@
 require 'virtual'
 require 'async_invocation'
 
+require 'log'
+require 'settings'
+
 require 'message_store/expected_version'
-require 'message_store/no_stream'
 require 'message_store/id'
+require 'message_store/no_stream'
 require 'message_store/stream_name'
 
 require 'message_store/message_data'
@@ -21,10 +23,20 @@
 
 require 'message_store/log'
 
+require 'message_store/settings'
+require 'message_store/session'
+
+require 'message_store/put'
+require 'message_store/write'
+
 require 'message_store/get'
 require 'message_store/get/substitute'
+require 'message_store/get/condition'
+require 'message_store/get/stream'
 require 'message_store/get/stream/last'
 require 'message_store/get/stream/last/substitute'
+require 'message_store/get/category'
+require 'message_store/get/category/correlation'
+require 'message_store/get/category/consumer_group'
 require 'message_store/read/iterator'
 require 'message_store/read'
-require 'message_store/write'

lib/message_store/controls.rb

@@ -9,11 +9,11 @@
 require 'message_store/controls/category'
 require 'message_store/controls/stream_name'
 require 'message_store/controls/read'
+require 'message_store/controls/position'
 require 'message_store/controls/message_data'
-require 'message_store/controls/message_data/hash'
 require 'message_store/controls/message_data/metadata'
-require 'message_store/controls/message_data/write'
+require 'message_store/controls/message_data/hash'
 require 'message_store/controls/message_data/read'
-require 'message_store/controls/write'
+require 'message_store/controls/message_data/write'
+require 'message_store/controls/put'
 require 'message_store/controls/get'
-require 'message_store/controls/get_last'

lib/message_store/controls/message_data/write.rb

@@ -48,6 +48,26 @@ def self.data
         def self.metadata
           MessageData::Metadata.data
         end
+
+        module List
+          Entry = Struct.new(:stream_name, :category, :message_data)
+
+          def self.get(instances: nil, stream_name: nil, category: nil)
+            instances ||= 1
+
+            list = []
+            instances.times do
+              instance_stream_name = stream_name || StreamName.example(category: category)
+              instance_category = MessageStore::StreamName.get_category(instance_stream_name)
+
+              write_message = Controls::MessageData::Write.example
+
+              list << Entry.new(instance_stream_name, instance_category, write_message)
+            end
+
+            list
+          end
+        end
       end
     end
   end

lib/message_store/controls/position.rb

@@ -0,0 +1,13 @@
+module MessageStore
+  module Controls
+    module Position
+      def self.example
+        1
+      end
+
+      def self.max
+        (2 ** 63) - 1
+      end
+    end
+  end
+end

lib/message_store/controls/put.rb

@@ -0,0 +1,26 @@
+module MessageStore
+  module Controls
+    module Put
+      def self.call(instances: nil, stream_name: nil, message_data: nil, message: nil, category: nil, type: nil)
+        instances ||= 1
+        stream_name ||= StreamName.example(category: category)
+        message_data ||= message
+
+        message_specified = !message_data.nil?
+
+        message_data ||= MessageData::Write.example(type: type)
+
+        position = nil
+        instances.times do
+          position = MessageStore::Put.(message_data, stream_name)
+
+          unless message_specified
+            message_data.id = MessageData::Write.id
+          end
+        end
+
+        [stream_name, position]
+      end
+    end
+  end
+end

lib/message_store/controls/read.rb

@@ -4,19 +4,10 @@ module Read
       def self.example(stream_name: nil)
         stream_name ||= StreamName.example
 
-        read = Example.build(stream_name)
-
-        get = Get.example(stream_name: stream_name)
-        read.iterator.get = get
+        read = MessageStore::Read.build(stream_name)
 
         read
       end
-
-      class Example
-        include MessageStore::Read
-
-        def configure(*); end
-      end
     end
   end
 end