Skip to content
Open
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 1 addition & 1 deletion Gemfile
Original file line number Diff line number Diff line change
@@ -1,3 +1,3 @@
source 'https://rubygems.org'
source "https://rubygems.org"

gemspec
4 changes: 2 additions & 2 deletions init.rb
Original file line number Diff line number Diff line change
@@ -1,3 +1,3 @@
require_relative 'load_path'
require_relative "load_path"

require 'message_store'
require "message_store"
50 changes: 25 additions & 25 deletions lib/message_store.rb
Original file line number Diff line number Diff line change
@@ -1,30 +1,30 @@
require 'pp'
require 'json'
require "pp"
require "json"

require 'casing'
require 'identifier/uuid'
require 'schema'
require 'initializer'
require 'transform'
require 'template_method'
require 'async_invocation'
require "casing"
require "identifier/uuid"
require "schema"
require "initializer"
require "transform"
require "template_method"
require "async_invocation"

require 'message_store/expected_version'
require 'message_store/no_stream'
require 'message_store/id'
require 'message_store/stream_name'
require "message_store/expected_version"
require "message_store/no_stream"
require "message_store/id"
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/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/log"

require 'message_store/get'
require 'message_store/get/substitute'
require 'message_store/get/stream/last'
require 'message_store/get/stream/last/substitute'
require 'message_store/read/iterator'
require 'message_store/read'
require 'message_store/write'
require "message_store/get"
require "message_store/get/substitute"
require "message_store/get/stream/last"
require "message_store/get/stream/last/substitute"
require "message_store/read/iterator"
require "message_store/read"
require "message_store/write"
34 changes: 17 additions & 17 deletions lib/message_store/controls.rb
Original file line number Diff line number Diff line change
@@ -1,19 +1,19 @@
require 'securerandom'
require "securerandom"

require 'clock/controls'
require 'identifier/uuid/controls'
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/read'
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/read'
require 'message_store/controls/write'
require 'message_store/controls/get'
require 'message_store/controls/get_last'
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/read"
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/read"
require "message_store/controls/write"
require "message_store/controls/get"
require "message_store/controls/get_last"
2 changes: 1 addition & 1 deletion lib/message_store/controls/category.rb
Original file line number Diff line number Diff line change
Expand Up @@ -10,7 +10,7 @@ def self.example(category: nil, type: nil, types: nil, randomize_category: nil)

randomize_category = true if randomize_category.nil?

category ||= 'test'
category ||= "test"

if randomize_category
category = "#{category}#{SecureRandom.hex(16)}XX"
Expand Down
4 changes: 2 additions & 2 deletions lib/message_store/controls/message_data.rb
Original file line number Diff line number Diff line change
Expand Up @@ -6,11 +6,11 @@ def self.id
end

def self.type
'SomeType'
"SomeType"
end

def self.other_type
'SomeOtherType'
"SomeOtherType"
end

def self.data
Expand Down
2 changes: 1 addition & 1 deletion lib/message_store/controls/message_data/hash.rb
Original file line number Diff line number Diff line change
Expand Up @@ -4,7 +4,7 @@ module MessageData
module Hash
def self.data
{
some_attribute: 'some value'
some_attribute: "some value"
}
end

Expand Down
2 changes: 1 addition & 1 deletion lib/message_store/controls/stream_name.rb
Original file line number Diff line number Diff line change
Expand Up @@ -18,7 +18,7 @@ def self.stream_name(category, id=nil, type: nil, types: nil)
types.unshift(type) unless type.nil?

type_list = nil
type_list = types.join('+') unless types.empty?
type_list = types.join("+") unless types.empty?

stream_name = category
stream_name = "#{stream_name}:#{type_list}" unless type_list.nil?
Expand Down
2 changes: 1 addition & 1 deletion lib/message_store/id.rb
Original file line number Diff line number Diff line change
Expand Up @@ -3,7 +3,7 @@ module ID
Error = Class.new(RuntimeError)

def self.compound_id_separator
'+'
"+"
end

def self.id(id)
Expand Down
6 changes: 3 additions & 3 deletions lib/message_store/stream_name.rb
Original file line number Diff line number Diff line change
Expand Up @@ -3,19 +3,19 @@ module StreamName
Error = Class.new(RuntimeError)

def self.id_separator
'-'
"-"
end

def self.compound_id_separator
ID.compound_id_separator
end

def self.category_type_separator
':'
":"
end

def self.compound_type_separator
'+'
"+"
end

def self.stream_name(category, stream_id=nil, cardinal_id: nil, id: nil, ids: nil, type: nil, types: nil)
Expand Down
4 changes: 2 additions & 2 deletions lib/message_store/write.rb
Original file line number Diff line number Diff line change
Expand Up @@ -45,7 +45,7 @@ def call(message_data, stream_name, expected_version: nil)
batch = Array(message_data)

logger.trace(tag: :write) do
message_types = batch.map {|message_data| message_data.type }.uniq.join(', ')
message_types = batch.map {|message_data| message_data.type }.uniq.join(", ")
"Writing message data (Types: #{message_types}, Stream Name: #{stream_name}, Expected Version: #{expected_version.inspect}, Number of Messages: #{batch.length})"
end
logger.trace(tags: [:data, :message_data]) { batch.pretty_inspect }
Expand All @@ -55,7 +55,7 @@ def call(message_data, stream_name, expected_version: nil)
position = write(batch, stream_name, expected_version: expected_version)

logger.info(tag: :write) do
message_types = batch.map {|message_data| message_data.type }.uniq.join(', ')
message_types = batch.map {|message_data| message_data.type }.uniq.join(", ")
"Wrote message data (Types: #{message_types}, Stream Name: #{stream_name}, Expected Version: #{expected_version.inspect}, Number of Messages: #{batch.length})"
end
logger.info(tags: [:data, :message_data]) { batch.pretty_inspect }
Expand Down
6 changes: 3 additions & 3 deletions load_path.rb
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
bundler_standalone_loader = 'gems/bundler/setup'
bundler_standalone_loader = "gems/bundler/setup"

begin
require_relative bundler_standalone_loader
Expand All @@ -8,10 +8,10 @@
Bundler.require
end

lib_dir = File.expand_path('lib', __dir__)
lib_dir = File.expand_path("lib", __dir__)
$LOAD_PATH.unshift(lib_dir) unless $LOAD_PATH.include?(lib_dir)

libraries_dir = ENV['LIBRARIES_HOME']
libraries_dir = ENV["LIBRARIES_HOME"]
unless libraries_dir.nil?
libraries_dir = File.expand_path(libraries_dir)
$LOAD_PATH.unshift libraries_dir unless $LOAD_PATH.include?(libraries_dir)
Expand Down
38 changes: 19 additions & 19 deletions message_store.gemspec
Original file line number Diff line number Diff line change
@@ -1,27 +1,27 @@
# -*- encoding: utf-8 -*-
Gem::Specification.new do |s|
s.name = 'evt-message_store'
s.version = '2.4.0.1'
s.summary = 'Common primitives for platform-specific message store implementations'
s.description = ' '
s.name = "evt-message_store"
s.version = "2.4.0.1"
s.summary = "Common primitives for platform-specific message store implementations"
s.description = " "

s.authors = ['The Eventide Project']
s.email = 'opensource@eventide-project.org'
s.homepage = 'https://github.com/eventide-project/message-store'
s.licenses = ['MIT']
s.authors = ["The Eventide Project"]
s.email = "opensource@eventide-project.org"
s.homepage = "https://github.com/eventide-project/message-store"
s.licenses = ["MIT"]

s.require_paths = ['lib']
s.files = Dir.glob('{lib}/**/*')
s.require_paths = ["lib"]
s.files = Dir.glob("{lib}/**/*")
s.platform = Gem::Platform::RUBY
s.required_ruby_version = '>= 2.4.0'
s.required_ruby_version = ">= 2.4.0"

s.add_runtime_dependency 'evt-casing'
s.add_runtime_dependency 'evt-schema'
s.add_runtime_dependency 'evt-initializer'
s.add_runtime_dependency 'evt-identifier-uuid'
s.add_runtime_dependency 'evt-transform'
s.add_runtime_dependency 'evt-template_method'
s.add_runtime_dependency 'evt-async_invocation'
s.add_runtime_dependency "evt-casing"
s.add_runtime_dependency "evt-schema"
s.add_runtime_dependency "evt-initializer"
s.add_runtime_dependency "evt-identifier-uuid"
s.add_runtime_dependency "evt-transform"
s.add_runtime_dependency "evt-template_method"
s.add_runtime_dependency "evt-async_invocation"

s.add_development_dependency 'test_bench'
s.add_development_dependency "test_bench"
end
2 changes: 1 addition & 1 deletion test.rb
Original file line number Diff line number Diff line change
@@ -1 +1 @@
require_relative 'test/automated'
require_relative "test/automated"
6 changes: 3 additions & 3 deletions test/automated.rb
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
require_relative './test_init'
require_relative "./test_init"

TestBench::Run.(
'test/automated',
exclude: '{_*,*sketch*,*_init,*_tests}.rb'
"test/automated",
exclude: "{_*,*sketch*,*_init,*_tests}.rb"
) or exit(false)
2 changes: 1 addition & 1 deletion test/automated/automated_init.rb
Original file line number Diff line number Diff line change
@@ -1 +1 @@
require_relative '../test_init'
require_relative "../test_init"
2 changes: 1 addition & 1 deletion test/automated/get_last/call.rb
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
require_relative '../automated_init'
require_relative "../automated_init"

context "Get Last" do
context "Call" do
Expand Down
2 changes: 1 addition & 1 deletion test/automated/get_last/configure.rb
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
require_relative '../automated_init'
require_relative "../automated_init"

context "Get Last" do
context "Configure" do
Expand Down
2 changes: 1 addition & 1 deletion test/automated/get_last/substitute.rb
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
require_relative '../automated_init'
require_relative "../automated_init"

context "Get Last" do
context "Substitute" do
Expand Down
10 changes: 5 additions & 5 deletions test/automated/id/compose.rb
Original file line number Diff line number Diff line change
@@ -1,10 +1,10 @@
require_relative '../automated_init'
require_relative "../automated_init"

context "ID" do
context "Compose" do
context "Singular ID" do
context "Not Nil" do
id = 'some_id'
id = "some_id"

compound_id = MessageStore::ID.id(id)

Expand All @@ -26,12 +26,12 @@

context "List of IDs" do
context "Not Empty" do
id = ['some_id', 'some_other_id']
id = ["some_id", "some_other_id"]

compound_id = MessageStore::ID.id(id)

test "Composed ID is the concatenation of the list of IDs delimited by the '+'' sign" do
assert(compound_id == 'some_id+some_other_id')
test "Composed ID is the concatenation of the list of IDs delimited by the \"+\" sign" do
assert(compound_id == "some_id+some_other_id")
end
end

Expand Down
10 changes: 5 additions & 5 deletions test/automated/id/get_cardinal_id.rb
Original file line number Diff line number Diff line change
@@ -1,23 +1,23 @@
require_relative '../automated_init'
require_relative "../automated_init"

context "Get Cardinal ID" do
context "Singular ID" do
id = 'some_id'
id = "some_id"

cardinal_id = ID.get_cardinal_id(id)

test "Cardinal ID is the ID" do
assert(cardinal_id == 'some_id')
assert(cardinal_id == "some_id")
end
end

context "Compound ID" do
id = 'some_id+some_other_id'
id = "some_id+some_other_id"

cardinal_id = ID.get_cardinal_id(id)

test "ID is the first ID" do
assert(cardinal_id == 'some_id')
assert(cardinal_id == "some_id")
end
end

Expand Down
10 changes: 5 additions & 5 deletions test/automated/id/parse.rb
Original file line number Diff line number Diff line change
@@ -1,23 +1,23 @@
require_relative '../automated_init'
require_relative "../automated_init"

context "Parse" do
context "Singular ID" do
id = 'some_id'
id = "some_id"

parsed_id = ID.parse(id)

test "Parsed IDis a list containing the ID" do
assert(parsed_id == ['some_id'])
assert(parsed_id == ["some_id"])
end
end

context "Compound ID" do
id = 'some_id+some_other_id'
id = "some_id+some_other_id"

parsed_id = ID.parse(id)

test "Parsed IDis a list containing the individual IDs" do
assert(parsed_id == ['some_id', 'some_other_id'])
assert(parsed_id == ["some_id", "some_other_id"])
end
end

Expand Down
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
require_relative '../../../automated_init'
require_relative "../../../automated_init"

context "Iterator" do
context "Batch Depletion" do
Expand Down
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
require_relative '../../../automated_init'
require_relative "../../../automated_init"

context "Iterator" do
context "Batch Depletion" do
Expand Down
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
require_relative '../../../automated_init'
require_relative "../../../automated_init"

context "Iterator" do
context "Batch Depletion" do
Expand Down
Loading