eventide-project · aaronjensen · May 5, 2025
diff --git a/Gemfile b/Gemfile
@@ -1,7 +1,7 @@
-source 'https://rubygems.org'
+source "https://rubygems.org"
 
-gem 'evt-entity_store'
-gem 'evt-messaging-postgres'
-gem 'evt-entity_snapshot-postgres'
+gem "evt-entity_store"
+gem "evt-messaging-postgres"
+gem "evt-entity_snapshot-postgres"
 
-gem 'test_bench'
+gem "test_bench"
diff --git a/init.rb b/init.rb
@@ -1,3 +1,3 @@
-require_relative './load_path'
+require_relative "./load_path"
 
-require 'entity_store/postgres'
+require "entity_store/postgres"
diff --git a/lib/entity_store/postgres.rb b/lib/entity_store/postgres.rb
@@ -1,3 +1,3 @@
-require 'messaging/postgres'
-require 'entity_store'
-require 'entity_snapshot/postgres'
+require "messaging/postgres"
+require "entity_store"
+require "entity_snapshot/postgres"
diff --git a/lib/entity_store/postgres/controls.rb b/lib/entity_store/postgres/controls.rb
@@ -1,14 +1,14 @@
-require 'entity_store/controls'
+require "entity_store/controls"
 
-require 'entity_store/postgres/controls/time'
-require 'entity_store/postgres/controls/id'
-require 'entity_store/postgres/controls/stream_name'
-require 'entity_store/postgres/controls/category'
-require 'entity_store/postgres/controls/version'
-require 'entity_store/postgres/controls/message'
-require 'entity_store/postgres/controls/batch'
-require 'entity_store/postgres/controls/entity'
-require 'entity_store/postgres/controls/projection'
-require 'entity_store/postgres/controls/snapshot'
-require 'entity_store/postgres/controls/write'
-require 'entity_store/postgres/controls/entity_store'
+require "entity_store/postgres/controls/time"
+require "entity_store/postgres/controls/id"
+require "entity_store/postgres/controls/stream_name"
+require "entity_store/postgres/controls/category"
+require "entity_store/postgres/controls/version"
+require "entity_store/postgres/controls/message"
+require "entity_store/postgres/controls/batch"
+require "entity_store/post
8000
gres/controls/entity"
+require "entity_store/postgres/controls/projection"
+require "entity_store/postgres/controls/snapshot"
+require "entity_store/postgres/controls/write"
+require "entity_store/postgres/controls/entity_store"
diff --git a/lib/entity_store/postgres/controls/snapshot.rb b/lib/entity_store/postgres/controls/snapshot.rb
@@ -8,7 +8,7 @@ module Write
           def self.call(category: nil, id: nil, message_data: nil)
             message_data ||= MessageData.example
 
-            stream_name = Controls::StreamName.example(category: category, id: id, type: 'snapshot')
+            stream_name = Controls::StreamName.example(category: category, id: id, type: "snapshot")
 
             write = ::MessageStore::Postgres::Write.build
 
@@ -34,7 +34,7 @@ def self.example(sum: nil, version: nil, time: nil)
               message_data = MessageStore::MessageData::Write.build
 
               message_data.data = data
-              message_data.type = 'Recorded'
+              message_data.type = "Recorded"
 
               message_data
             end

diff --git a/lib/entity_store/postgres/controls/snapshot_record.rb b/lib/entity_store/postgres/controls/snapshot_record.rb
@@ -8,7 +8,7 @@
 #           def self.call(category: nil, id: nil, message_data: nil)
 #             message_data ||= MessageData.example
 
-#             stream_name = Controls::StreamName.example(category: category, id: id, type: 'snapshot')
+#             stream_name = Controls::StreamName.example(category: category, id: id, type: "snapshot")
 
 #             write = ::MessageStore::Postgres::Write.build
 
@@ -35,7 +35,7 @@
 #             message_data = MessageStore::MessageData::Write.build
 
 #             message_data.data = data
-#             message_data.type = 'Recorded'
+#             message_data.type = "Recorded"
 
 #             message_data
 #           end

diff --git a/load_path.rb b/load_path.rb
@@ -1,4 +1,4 @@
-bundler_standalone_loader = 'gems/bundler/setup'
+bundler_standalone_loader = "gems/bundler/setup"
 
 begin
   require_relative bundler_standalone_loader
@@ -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)

diff --git a/test.rb b/test.rb
@@ -1 +1 @@
-load './test/automated.rb'
+load "./test/automated.rb"
diff --git a/test/automated.rb b/test/automated.rb
@@ -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)
diff --git a/test/automated/automated_init.rb b/test/automated/automated_init.rb
@@ -1 +1 @@
-require_relative '../test_init'
+require_relative "../test_init"
diff --git a/test/automated/fetch/fetch.rb b/test/automated/fetch/fetch.rb
@@ -1,11 +1,11 @@
-require_relative '../automated_init'
+require_relative "../automated_init"
 
 context "Fetch" do
   context "Entity" do
     stream_name = Controls::Write.batch
 
-    id = stream_name.partition('-').last
-    category_name = stream_name.split('-').first
+    id = stream_name.partition("-").last
+    category_name = stream_name.split("-").first
 
     store = Controls::EntityStore.example(category: category_name)
 

diff --git a/test/automated/fetch/includes.rb b/test/automated/fetch/includes.rb
@@ -1,8 +1,8 @@
-require_relative '../automated_init'
+require_relative "../automated_init"
 
 context "Fetch" do
   context "Includes" do
-    stream_name = Controls::Write.batch(category: 'testFetchWithIncludes')
+    stream_name = Controls::Write.batch(category: "testFetchWithIncludes")
 
     id = Messaging::StreamName.get_id stream_name
     category_name = Messaging::StreamName.get_category stream_name
@@ -39,7 +39,7 @@
           permutations = includes.permutation(n).to_a
 
           permutations.each do |includes|
-            context "#{includes.join(', ')}" do
+            context "#{includes.join(", ")}" do
               results = store.fetch id, include: includes
 
               includes.each_with_index do |include, i|

diff --git a/test/automated/fetch/includes_when_stream_does_not_exist.rb b/test/automated/fetch/includes_when_stream_does_not_exist.rb
@@ -1,4 +1,4 @@
-require_relative '../automated_init'
+require_relative "../automated_init"
 
 context "Fetch" do
   context "Includes" do

diff --git a/test/automated/fetch/stream_does_not_exist.rb b/test/automated/fetch/stream_does_not_exist.rb
@@ -1,4 +1,4 @@
-require_relative '../automated_init'
+require_relative "../automated_init"
 
 context "Fetch" do
   context "Stream Does Not Exist" do

diff --git a/test/automated/get/entity.rb b/test/automated/get/entity.rb
@@ -1,4 +1,4 @@
-require_relative '../automated_init'
+require_relative "../automated_init"
 
 context "Get" do
   context "Entity" do

diff --git a/test/automated/get/entity_compound_id.rb b/test/automated/get/entity_compound_id.rb
@@ -1,4 +1,4 @@
-require_relative '../automated_init'
+require_relative "../automated_init"
 
 context "Get" do
   context "Entity" do

diff --git a/test/automated/get/get_version.rb b/test/automated/get/get_version.rb
@@ -1,4 +1,4 @@
-require_relative '../automated_init'
+require_relative "../automated_init"
 
 context "Get" do
   context "Version" do

diff --git a/test/automated/get/includes.rb b/test/automated/get/includes.rb
@@ -1,8 +1,8 @@
-require_relative '../automated_init'
+require_relative "../automated_init"
 
 context "Get" do
   context "Includes" do
-    stream_name = Controls::Write.batch(category: 'testEntityStoreGet')
+    stream_name = Controls::Write.batch(category: "testEntityStoreGet")
 
     id = Messaging::StreamName.get_id stream_name
     category_name = Messaging::StreamName.get_category stream_name
@@ -39,7 +39,7 @@
           permutations = includes.permutation(n).to_a
 
           permutations.each do |includes|
-            context "#{includes.join(', ')}" do
+            context "#{includes.join(", ")}" do
               results = store.get id, include: includes
 
               includes.each_with_index do |include, i|

diff --git a/test/automated/get/includes_when_stream_does_not_exist.rb b/test/automated/get/includes_when_stream_does_not_exist.rb
@@ -1,4 +1,4 @@
-require_relative '../automated_init'
+require_relative "../automated_init"
 
 context "Get" do
   context "Includes" do

diff --git a/test/automated/get/stream_does_not_exist.rb b/test/automated/get/stream_does_not_exist.rb
@@ -1,4 +1,4 @@
-require_relative '../automated_init'
+require_relative "../automated_init"
 
 context "Get" do
   context "Stream does not exist" do

diff --git a/test/automated/refreshing/entity_is_cached.rb b/test/automated/refreshing/entity_is_cached.rb
@@ -1,8 +1,8 @@
-require_relative '../automated_init'
+require_relative "../automated_init"
 
 context "Refreshing" do
   context "Entity is Cached" do
-    stream_name = Controls::Write.batch(category: 'testRefreshingEntityCached')
+    stream_name = Controls::Write.batch(category: "testRefreshingEntityCached")
 
     id = Messaging::StreamName.get_id stream_name
     category_name = Messaging::StreamName.get_category stream_name

diff --git a/test/automated/refreshing/entity_is_not_cached.rb b/test/automated/refreshing/entity_is_not_cached.rb
@@ -1,8 +1,8 @@
-require_relative '../automated_init'
+require_relative "../automated_init"
 
 context "Refreshing" do
   context "Entity is Not Cached" do
-    stream_name = Controls::Write.batch(category: 'testEntityStoreGet')
+    stream_name = Controls::Write.batch(category: "testEntityStoreGet")
 
     id = Messaging::StreamName.get_id stream_name
     category_name = Messaging::StreamName.get_category stream_name

diff --git a/test/automated/refreshing/probe.rb b/test/automated/refreshing/probe.rb
@@ -1,8 +1,8 @@
-require_relative '../automated_init'
+require_relative "../automated_init"
 
 context "Refreshing" do
   context "Entity is Cached" do
-    stream_name = Controls::Write.batch(category: 'testRefreshingEntityCached')
+    stream_name = Controls::Write.batch(category: "testRefreshingEntityCached")
 
     id = Messaging::StreamName.get_id stream_name
     category_name = Messaging::StreamName.get_category stream_name

diff --git a/test/automated/refreshing/stream_does_not_exist.rb b/test/automated/refreshing/stream_does_not_exist.rb
@@ -1,4 +1,4 @@
-require_relative '../automated_init'
+require_relative "../automated_init"
 
 context "Refreshing" do
   context "Stream Does Not Exist" do

diff --git a/test/automated/snapshot/read_only.rb b/test/automated/snapshot/read_only.rb
@@ -1,10 +1,10 @@
-require_relative '../automated_init'
+require_relative "../automated_init"
 
 context "Snapshot" do
   context "Rea
D96B
d Only" do
     snapshot_class = EntitySnapshot::Postgres::ReadOnly
 
-    category = 'example'
+    category = "example"
     id = Controls::ID::Random.example
 
     batch = Controls::Batch.example

diff --git a/test/automated/snapshot/read_write.rb b/test/automated/snapshot/read_write.rb
@@ -1,11 +1,11 @@
-require_relative '../automated_init'
+require_relative "../automated_init"
 
 context "Snapshot" do
   context "Read-Write" do
     snapshot_class = EntitySnapshot::Postgres
 
-    category = 'example'
-    specifier = 'SomeSpecifier'
+    category = "example"
+    specifier = "SomeSpecifier"
     id = Controls::ID::Random.example
 
     batch = Controls::Batch.example

diff --git a/test/interactive.rb b/test/interactive.rb
@@ -1,6 +1,6 @@
-require_relative 'test_init'
+require_relative "test_init"
 
 TestBench::Runner.(
-  'interactive/**/*.rb',
+  "interactive/**/*.rb",
   exclude_pattern: %r{\/_|sketch|(_init\.rb|_tests\.rb)\z}
 ) or exit 1
diff --git a/test/interactive/interactive_init.rb b/test/interactive/interactive_init.rb
diff --git a/test/interactive/performance.rb b/test/interactive/performance.rb
@@ -1,8 +1,8 @@
-require_relative 'interactive_init'
+require_relative "interactive_init"
 
-iterations = ENV.fetch('ITERATIONS') { '10' }.to_i
+iterations = ENV.fetch("ITERATIONS") { "10" }.to_i
 
-stream_name = Controls::Write.batch(category: 'testFetch')
+stream_name = Controls::Write.batch(category: "testFetch")
 
 id = Messaging::StreamName.get_id stream_name
 category_name = Messaging::StreamName.get_category stream_name
@@ -18,7 +18,7 @@
 
 finish_time = Time.now
 
-puts "Iterations: #{iterations}, StartTime: #{start_time.strftime '%H:%M:%S.3%N'}, FinishTime: #{finish_time.strftime '%H:%M:%S.%3N'}"
+puts "Iterations: #{iterations}, StartTime: #{start_time.strftime "%H:%M:%S.3%N"}, FinishTime: #{finish_time.strftime "%H:%M:%S.%3N"}"
 
 average_time_ms = Rational (finish_time - start_time) * 1000, iterations
 ips = Rational iterations, finish_time - start_time

diff --git a/test/interactive/reader_batch_size.rb b/test/interactive/reader_batch_size.rb
@@ -1,7 +1,7 @@
-ENV['LOG_TAGS'] ||= '_untagged,message_store,-data'
-ENV['LOG_LEVEL'] ||= 'debug'
+ENV["LOG_TAGS"] ||= "_untagged,message_store,-data"
+ENV["LOG_LEVEL"] ||= "debug"
 
-require_relative './interactive_init'
+require_relative "./interactive_init"
 
 batch_size = 2
 

diff --git a/test/test_init.rb b/test/test_init.rb
@@ -1,13 +1,13 @@
-ENV['CONSOLE_DEVICE'] ||= 'stdout'
-ENV['LOG_LEVEL'] ||= '_min'
+ENV["CONSOLE_DEVICE"] ||= "stdout"
+ENV["LOG_LEVEL"] ||= "_min"
 
 puts RUBY_DESCRIPTION
 
-require_relative '../init.rb'
+require_relative "../init.rb"
 
-require 'test_bench'; TestBench.activate
+require "test_bench"; TestBench.activate
 
-require 'securerandom'
+require "securerandom"
 
-require 'entity_store/postgres/controls'
+require "entity_store/postgres/controls"
 Controls = ::EntityStore::Postgres::Controls
Original file line number	Diff line number	Diff line change
		@@ -1 +1 @@
		load './test/automated.rb'
		load "./test/automated.rb"
Original file line number	Diff line number	Diff line change
		@@ -1 +1 @@
		require_relative '../test_init'
		require_relative "../test_init"