MessageStore, rather than MessageStore::Postgres

init.rb

@@ -1,3 +1,3 @@
 require_relative 'load_path'
 
-require 'message_store/postgres'
+require 'message_store'

lib/message_store.rb

@@ -0,0 +1,42 @@
+require 'pg'
+
+require 'casing'
+require 'identifier/uuid'
+require 'schema'
+require 'initializer'
+require 'transform'
+require 'virtual'
+require 'async_invocation'
+
+require 'log'
+require 'settings'
+
+require 'message_store/expected_version'
+require 'message_store/id'
+require 'message_store/no_stream'
+require 'message_store/stream_name'
+
+require 'message_store/message_data'
+require 'message_store/message_data/hash/transform'
+require 'message_store/message_data/write'
+require 'message_store/message_data/read'
+
+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'

lib/message_store/controls.rb

@@ -0,0 +1,16 @@
+require 'securerandom'
+
+require 'clock/controls'
+require 'identifier/uuid/controls'
+
+require 'message_store/controls/random_value'
+require 'message_store/controls/time'
+require 'message_store/controls/id'
+require 'message_store/controls/category'
+require 'message_store/controls/stream_name'
+require 'message_store/controls/position'
+require 'message_store/controls/message_data'
+require 'message_store/controls/message_data/metadata'
+require 'message_store/controls/message_data/read'
+require 'message_store/controls/message_data/write'
+require 'message_store/controls/put'

lib/message_store/controls/category.rb

@@ -0,0 +1,25 @@
+module MessageStore
+  module Controls
+    module Category
+      def self.example(category: nil, type: nil, types: nil, randomize_category: nil)
+        if randomize_category.nil?
+          if !category.nil?
+            randomize_category = false
+          end
+        end
+
+        randomize_category = true if randomize_category.nil?
+
+        category ||= 'test'
+
+        if randomize_category
+          category = "#{category}#{SecureRandom.hex(16)}XX"
+        end
+
+        category = Controls::StreamName.stream_name(category, type: type, types: types)
+
+        category
+      end
+    end
+  end
+end

lib/message_store/controls/id.rb

@@ -0,0 +1,11 @@
+module MessageStore
+  module Controls
+    module ID
+      def self.example(i=nil, increment: nil, sample: nil)
+        Identifier::UUID::Controls::Incrementing.example(i=nil, increment: nil, sample: nil)
+      end
+
+      Random = Identifier::UUID::Controls::Random
+    end
+  end
+end

lib/message_store/controls/message_data.rb

@@ -0,0 +1,21 @@
+module MessageStore
+  module Controls
+    module MessageData
+      def self.id
+        ID::Random.example
+      end
+
+      def self.type
+        'SomeType'
+      end
+
+      def self.other_type
+        'SomeOtherType'
+      end
+
+      def self.data
+        { :attribute => RandomValue.example }
+      end
+    end
+  end
+end

lib/message_store/controls/message_data/metadata.rb

@@ -0,0 +1,24 @@
+module MessageStore
+  module Controls
+    module MessageData
+      module Metadata
+        def self.data
+          {
+            meta_attribute: RandomValue.example
+          }
+        end
+
+        module JSON
+          def self.data(id=nil)
+            data = Metadata.data
+            Casing::Camel.(data, symbol_to_string: true)
+          end
+
+          def self.text
+            data.to_json
+          end
+        end
+      end
+    end
+  end
+end

lib/message_store/controls/message_data/read.rb

@@ -0,0 +1,74 @@
+module MessageStore
+  module Controls
+    module MessageData
+      module Read
+        def self.example(id: nil, type: nil, data: nil, metadata: nil)
+          if id == :none
+            id = nil
+          else
+            id ||= self.id
+          end
+
+          type ||= self.type
+
+          if data == :none
+            data = nil
+          else
+            data ||= self.data
+          end
+
+          if metadata == :none
+            metadata = nil
+          else
+            metadata ||= self.metadata
+          end
+
+          message_data = MessageStore::MessageData::Read.build
+
+          message_data.id = id
+          message_data.type = type
+          message_data.data = data
+          message_data.metadata = metadata
+          message_data.position = position
+          message_data.global_position = global_position
+          message_data.time = time
+          message_data.stream_name = stream_name
+
+          message_data
+        end
+
+        def self.id
+          MessageData.id
+        end
+
+        def self.type
+          MessageData.type
+        end
+
+        def self.data
+          MessageData.data
+        end
+
+        def self.metadata
+          MessageData::Metadata.data
+        end
+
+        def self.position
+          1
+        end
+
+        def self.global_position
+          111
+        end
+
+        def self.time
+          Time::Raw.example
+        end
+
+        def self.stream_name
+          StreamName.example
+        end
+      end
+    end
+  end
+end

lib/message_store/controls/message_data/write.rb

@@ -0,0 +1,74 @@
+module MessageStore
+  module Controls
+    module MessageData
+      module Write
+        def self.example(id: nil, type: nil, data: nil, metadata: nil)
+          if id == :none
+            id = nil
+          else
+            id ||= self.id
+          end
+
+          type ||= self.type
+
+          if data == :none
+            data = nil
+          else
+            data ||= self.data
+          end
+
+          if metadata == :none
+            metadata = nil
+          else
+            metadata ||= self.metadata
+          end
+
+          message_data = MessageStore::MessageData::Write.build
+
+          message_data.id = id
+          message_data.type = type
+          message_data.data = data
+          message_data.metadata = metadata
+
+          message_data
+        end
+
+        def self.id
+          MessageData.id
+        end
+
+        def self.type
+          MessageData.type
+        end
+
+        def self.data
+          MessageData.data
+        end
+
+        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
+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/random_value.rb

@@ -0,0 +1,9 @@
+module MessageStore
+  module Controls
+    module RandomValue
+      def self.example
+        SecureRandom.hex
+      end
+    end
+  end
+end

lib/message_store/controls/stream_name.rb

@@ -0,0 +1,35 @@
+module MessageStore
+  module Controls
+    module StreamName
+      def self.example(category: nil, id: nil, type: nil, types: nil, randomize_category: nil)
+        if id == :none
+          id = nil
+        else
+          id ||= Identifier::UUID.random
+        end
+
+        category = Category.example(category: category, randomize_category: randomize_category)
+
+        stream_name(category, id, type: type, types: types)
+      end
+
+      def self.stream_name(category, id=nil, type: nil, types: nil)
+        types = Array(types)
+        types.unshift(type) unless type.nil?
+
+        type_list = nil
+        type_list = types.join('+') unless types.empty?
+
+        stream_name = category
+        stream_name = "#{stream_name}:#{type_list}" unless type_list.nil?
+
+        if not id.nil?
+          composed_id = MessageStore::ID.id(id)
+          stream_name = "#{stream_name}-#{composed_id}"
+        end
+
+        stream_name
+      end
+    end
+  end
+end