diff --git a/Gemfile b/Gemfile index fa75df1..b4e2a20 100644 --- a/Gemfile +++ b/Gemfile @@ -1,3 +1,3 @@ -source 'https://rubygems.org' +source "https://rubygems.org" gemspec diff --git a/init.rb b/init.rb index 9fbcbef..b184338 100644 --- a/init.rb +++ b/init.rb @@ -1,3 +1,3 @@ -require_relative 'load_path' +require_relative "load_path" -require 'message_store/postgres' +require "message_store/postgres" diff --git a/lib/message_store/postgres.rb b/lib/message_store/postgres.rb index fef1e16..03163c1 100644 --- a/lib/message_store/postgres.rb +++ b/lib/message_store/postgres.rb @@ -1,24 +1,24 @@ -require 'pg' +require "pg" -require 'message_store' +require "message_store" -require 'log' -require 'telemetry' -require 'settings' +require "log" +require "telemetry" +require "settings" -require 'message_store/postgres/log' +require "message_store/postgres/log" -require 'message_store/postgres/settings' -require 'message_store/postgres/session' +require "message_store/postgres/settings" +require "message_store/postgres/session" -require 'message_store/postgres/put' -require 'message_store/postgres/write' +require "message_store/postgres/put" +require "message_store/postgres/write" -require 'message_store/postgres/get' -require 'message_store/postgres/get/condition' -require 'message_store/postgres/get/stream' -require 'message_store/postgres/get/stream/last' -require 'message_store/postgres/get/category' -require 'message_store/postgres/get/category/correlation' -require 'message_store/postgres/get/category/consumer_group' -require 'message_store/postgres/read' +require "message_store/postgres/get" +require "message_store/postgres/get/condition" +require "message_store/postgres/get/stream" +require "message_store/postgres/get/stream/last" +require "message_store/postgres/get/category" +require "message_store/postgres/get/category/correlation" +require "message_store/postgres/get/category/consumer_group" +require "message_store/postgres/read" diff --git a/lib/message_store/postgres/controls.rb b/lib/message_store/postgres/controls.rb index 3560cdc..a55bf86 100644 --- a/lib/message_store/postgres/controls.rb +++ b/lib/message_store/postgres/controls.rb @@ -1,8 +1,8 @@ -require 'message_store/controls' +require "message_store/controls" -require 'message_store/postgres/controls/time' -require 'message_store/postgres/controls/position' -require 'message_store/postgres/controls/category' -require 'message_store/postgres/controls/stream_name' -require 'message_store/postgres/controls/message_data' -require 'message_store/postgres/controls/put' +require "message_store/postgres/controls/time" +require "message_store/postgres/controls/position" +require "message_store/postgres/controls/category" +require "message_store/postgres/controls/stream_name" +require "message_store/postgres/controls/message_data" +require "message_store/postgres/controls/put" diff --git a/lib/message_store/postgres/get.rb b/lib/message_store/postgres/get.rb index a69f12b..0a840a3 100644 --- a/lib/message_store/postgres/get.rb +++ b/lib/message_store/postgres/get.rb @@ -101,9 +101,9 @@ def convert(result) end def self.message_data(record) - record['data'] = Get::Deserialize.data(record['data']) - record['metadata'] = Get::Deserialize.metadata(record['metadata']) - record['time'] = Get::Time.utc_coerced(record['time']) + record["data"] = Get::Deserialize.data(record["data"]) + record["metadata"] = Get::Deserialize.metadata(record["metadata"]) + record["time"] = Get::Time.utc_coerced(record["time"]) MessageData::Read.build(record) end @@ -126,7 +126,7 @@ def raise_error(pg_error) end def self.error_message(pg_error) - pg_error.message.gsub('ERROR:', '').strip + pg_error.message.gsub("ERROR:", "").strip end def self.specialization(stream_name) diff --git a/lib/message_store/postgres/get/category.rb b/lib/message_store/postgres/get/category.rb index d226735..2a5ebd5 100644 --- a/lib/message_store/postgres/get/category.rb +++ b/lib/message_store/postgres/get/category.rb @@ -31,7 +31,7 @@ def sql_command end def parameters - '$1::varchar, $2::bigint, $3::bigint, $4::varchar, $5::bigint, $6::bigint, $7::varchar' + "$1::varchar, $2::bigint, $3::bigint, $4::varchar, $5::bigint, $6::bigint, $7::varchar" end def parameter_values(category, position) diff --git a/lib/message_store/postgres/get/category/consumer_group.rb b/lib/message_store/postgres/get/category/consumer_group.rb index fc5bd0b..2452e37 100644 --- a/lib/message_store/postgres/get/category/consumer_group.rb +++ b/lib/message_store/postgres/get/category/consumer_group.rb @@ -6,10 +6,10 @@ module ConsumerGroup Error = Class.new(RuntimeError) def self.error(error_message) - if error_message.start_with?('Consumer group size must not be less than 1') || - error_message.start_with?('Consumer group member must be less than the group size') || - error_message.start_with?('Consumer group member must not be less than 0') || - error_message.start_with?('Consumer group member and size must be specified') + if error_message.start_with?("Consumer group size must not be less than 1") || + error_message.start_with?("Consumer group member must be less than the group size") || + error_message.start_with?("Consumer group member must not be less than 0") || + error_message.start_with?("Consumer group member and size must be specified") Error.new(error_message) end end diff --git a/lib/message_store/postgres/get/category/correlation.rb b/lib/message_store/postgres/get/category/correlation.rb index c857077..efb066f 100644 --- a/lib/message_store/postgres/get/category/correlation.rb +++ b/lib/message_store/postgres/get/category/correlation.rb @@ -6,7 +6,7 @@ module Correlation Error = Class.new(RuntimeError) def self.error(error_message) - if error_message.start_with?('Correlation must be a category') + if error_message.start_with?("Correlation must be a category") Error.new(error_message) end end diff --git a/lib/message_store/postgres/get/condition.rb b/lib/message_store/postgres/get/condition.rb index 7e0cb99..9f3957f 100644 --- a/lib/message_store/postgres/get/condition.rb +++ b/lib/message_store/postgres/get/condition.rb @@ -5,7 +5,7 @@ module Condition Error = Class.new(RuntimeError) def self.error(error_message) - if error_message.start_with?('Retrieval with SQL condition is not activated') + if error_message.start_with?("Retrieval with SQL condition is not activated") Get::Condition::Error.new(error_message) end end diff --git a/lib/message_store/postgres/get/stream.rb b/lib/message_store/postgres/get/stream.rb index f769e9b..14a8bbd 100644 --- a/lib/message_store/postgres/get/stream.rb +++ b/lib/message_store/postgres/get/stream.rb @@ -30,7 +30,7 @@ def sql_command end def parameters - '$1::varchar, $2::bigint, $3::bigint, $4::varchar' + "$1::varchar, $2::bigint, $3::bigint, $4::varchar" end def parameter_values(stream_name, position) diff --git a/lib/message_store/postgres/put.rb b/lib/message_store/postgres/put.rb index 55005f6..a2b405c 100644 --- a/lib/message_store/postgres/put.rb +++ b/lib/message_store/postgres/put.rb @@ -134,8 +134,8 @@ def position(records) def raise_error(pg_error) error_message = pg_error.message - if error_message.include? 'Wrong expected version' - error_message.gsub!('ERROR:', '').strip! + if error_message.include? "Wrong expected version" + error_message.gsub!("ERROR:", "").strip! logger.error { error_message } raise ExpectedVersion::Error, error_message end diff --git a/lib/message_store/postgres/session.rb b/lib/message_store/postgres/session.rb index 8d89d6b..7f0fb1d 100644 --- a/lib/message_store/postgres/session.rb +++ b/lib/message_store/postgres/session.rb @@ -165,7 +165,7 @@ def self.settings(settings) s = settings.dup if s.has_key?(:password) - s[:password] = '*' * 8 + s[:password] = "*" * 8 end s diff --git a/lib/message_store/postgres/settings.rb b/lib/message_store/postgres/settings.rb index b9222d9..5c98380 100644 --- a/lib/message_store/postgres/settings.rb +++ b/lib/message_store/postgres/settings.rb @@ -54,7 +54,7 @@ def self.names class Defaults def self.data_source - ENV['MESSAGE_STORE_SETTINGS_PATH'] || 'settings/message_store_postgres.json' + ENV["MESSAGE_STORE_SETTINGS_PATH"] || "settings/message_store_postgres.json" end end end diff --git a/lib/message_store/postgres/write.rb b/lib/message_store/postgres/write.rb index 7b707f6..893fd9c 100644 --- a/lib/message_store/postgres/write.rb +++ b/lib/message_store/postgres/write.rb @@ -11,7 +11,7 @@ def configure(session: nil) def write(batch, stream_name, expected_version: nil) 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 batch (Stream Name: #{stream_name}, Types: #{message_types}, Number of Messages: #{batch.length}, Expected Version: #{expected_version.inspect})" end @@ -31,7 +31,7 @@ def write(batch, stream_name, expected_version: nil) end logger.debug(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 batch (Stream Name: #{stream_name}, Types: #{message_types}, Number of Messages: #{batch.length}, Expected Version: #{expected_version.inspect})" end diff --git a/load_path.rb b/load_path.rb index 4f7ebf2..69ebac3 100644 --- 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/message_store-postgres.gemspec b/message_store-postgres.gemspec index 190cf94..72d748f 100644 --- a/message_store-postgres.gemspec +++ b/message_store-postgres.gemspec @@ -1,31 +1,31 @@ # -*- encoding: utf-8 -*- Gem::Specification.new do |s| - s.name = 'evt-message_store-postgres' - s.version = '2.5.1.1' - s.summary = 'Message store implementation for PostgreSQL' - s.description = ' ' + s.name = "evt-message_store-postgres" + s.version = "2.5.1.1" + s.summary = "Message store implementation for PostgreSQL" + s.description = " " - s.authors = ['The Eventide Project'] - s.email = 'opensource@eventide-project.org' - s.homepage = 'https://github.com/eventide-project/message-store-postgres' - s.licenses = ['MIT'] + s.authors = ["The Eventide Project"] + s.email = "opensource@eventide-project.org" + s.homepage = "https://github.com/eventide-project/message-store-postgres" + s.licenses = ["MIT"] - s.require_paths = ['lib'] - s.files = Dir.glob('{lib,database}/**/*') + s.require_paths = ["lib"] + s.files = Dir.glob("{lib,database}/**/*") s.platform = Gem::Platform::RUBY - s.required_ruby_version = '>= 2.4.0' + s.required_ruby_version = ">= 2.4.0" - s.executables = Dir.glob('scripts/evt-*').map(&File.method(:basename)) - s.bindir = 'scripts' + s.executables = Dir.glob("scripts/evt-*").map(&File.method(:basename)) + s.bindir = "scripts" - s.add_runtime_dependency 'evt-message_store' - s.add_runtime_dependency 'evt-log' - s.add_runtime_dependency 'evt-settings' + s.add_runtime_dependency "evt-message_store" + s.add_runtime_dependency "evt-log" + s.add_runtime_dependency "evt-settings" - s.add_runtime_dependency 'message-db' - s.add_runtime_dependency 'pg' + s.add_runtime_dependency "message-db" + s.add_runtime_dependency "pg" - s.add_development_dependency 'test_bench' - s.add_development_dependency 'evt-diagnostics-sample' - s.add_development_dependency 'ntl-actor' + s.add_development_dependency "test_bench" + s.add_development_dependency "evt-diagnostics-sample" + s.add_development_dependency "ntl-actor" end diff --git a/test.rb b/test.rb index d92b472..7172472 100644 --- a/test.rb +++ b/test.rb @@ -1 +1 @@ -require_relative 'test/automated' +require_relative "test/automated" diff --git a/test/automated.rb b/test/automated.rb index 9a08835..94c1b1e 100644 --- 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 index faa8577..f9272a5 100644 --- 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/get/category/generalized/get_messages.rb b/test/automated/get/category/generalized/get_messages.rb index 9e08b35..78cf35d 100644 --- a/test/automated/get/category/generalized/get_messages.rb +++ b/test/automated/get/category/generalized/get_messages.rb @@ -1,4 +1,4 @@ -require_relative '../../../automated_init' +require_relative "../../../automated_init" context "Get" do context "Category" do diff --git a/test/automated/get/category/generalized/specialization.rb b/test/automated/get/category/generalized/specialization.rb index 7c37ea4..394c1d2 100644 --- a/test/automated/get/category/generalized/specialization.rb +++ b/test/automated/get/category/generalized/specialization.rb @@ -1,4 +1,4 @@ -require_relative '../../../automated_init' +require_relative "../../../automated_init" context "Get" do context "Category" do @@ -6,10 +6,10 @@ context "Specialization" do category = Controls::Category.example batch_size = 1 - correlation = 'someCorrelation' + correlation = "someCorrelation" consumer_group_member = 0 consumer_group_size = 1 - condition = 'global_position >= 1' + condition = "global_position >= 1" session = Session.build get = Get.build(category, batch_size: batch_size, correlation: correlation, consumer_group_member: consumer_group_member, consumer_group_size: consumer_group_size, condition: condition, session: session) diff --git a/test/automated/get/category/specialized/batch_size.rb b/test/automated/get/category/specialized/batch_size.rb index 2d4de98..94d33aa 100644 --- a/test/automated/get/category/specialized/batch_size.rb +++ b/test/automated/get/category/specialized/batch_size.rb @@ -1,4 +1,4 @@ -require_relative '../../../automated_init' +require_relative "../../../automated_init" context "Get" do context "Category" do diff --git a/test/automated/get/category/specialized/condition/condition.rb b/test/automated/get/category/specialized/condition/condition.rb index b6664bc..1c473e9 100644 --- a/test/automated/get/category/specialized/condition/condition.rb +++ b/test/automated/get/category/specialized/condition/condition.rb @@ -1,4 +1,4 @@ -require_relative '../../../../automated_init' +require_relative "../../../../automated_init" context "Get" do context "Category" do @@ -8,12 +8,12 @@ stream_name, _ = Controls::Put.(instances: 3, category: category) - condition = 'position = 0 OR position = 2' + condition = "position = 0 OR position = 2" settings = Postgres::Settings.build session = Session.new settings.set(session) - session.options = '-c message_store.sql_condition=on' + session.options = "-c message_store.sql_condition=on" messages = Get::Category.(category, batch_size: 3, condition: condition, session: session) diff --git a/test/automated/get/category/specialized/condition/not_activated_error.rb b/test/automated/get/category/specialized/condition/not_activated_error.rb index 41dd97b..6f1b323 100644 --- a/test/automated/get/category/specialized/condition/not_activated_error.rb +++ b/test/automated/get/category/specialized/condition/not_activated_error.rb @@ -1,4 +1,4 @@ -require_relative '../../../../automated_init' +require_relative "../../../../automated_init" context "Get" do context "Category" do @@ -7,7 +7,7 @@ context "Condition Is Not Activated" do category = Controls::Category.example - condition = 'some condition' + condition = "some condition" settings = Postgres::Settings.build session = Session.new diff --git a/test/automated/get/category/specialized/consumer_groups/consumer_groups.rb b/test/automated/get/category/specialized/consumer_groups/consumer_groups.rb index 2d80f59..8e5800d 100644 --- a/test/automated/get/category/specialized/consumer_groups/consumer_groups.rb +++ b/test/automated/get/category/specialized/consumer_groups/consumer_groups.rb @@ -1,4 +1,4 @@ -require_relative '../../../../automated_init' +require_relative "../../../../automated_init" context "Get" do context "Category" do diff --git a/test/automated/get/category/specialized/consumer_groups/error.rb b/test/automated/get/category/specialized/consumer_groups/error.rb index 46ae2b2..1ab6ed6 100644 --- a/test/automated/get/category/specialized/consumer_groups/error.rb +++ b/test/automated/get/category/specialized/consumer_groups/error.rb @@ -1,4 +1,4 @@ -require_relative '../../../../automated_init' +require_relative "../../../../automated_init" context "Get" do context "Category" do @@ -8,7 +8,7 @@ context "Consumer Group Size Is Less than 1" do test "Is an error" do assert_raises(MessageStore::Postgres::Get::Category::ConsumerGroup::Error) do - Get::Category.('someCategory', consumer_group_member: 0, consumer_group_size: 0) + Get::Category.("someCategory", consumer_group_member: 0, consumer_group_size: 0) end end end @@ -16,7 +16,7 @@ context "Consumer Group Member Is Greater than the Consumer Group Size" do test "Is an error" do assert_raises(MessageStore::Postgres::Get::Category::ConsumerGroup::Error) do - Get::Category.('someCategory', consumer_group_member: 2, consumer_group_size: 1) + Get::Category.("someCategory", consumer_group_member: 2, consumer_group_size: 1) end end end @@ -24,7 +24,7 @@ context "Consumer Group Member Is Less than 0" do test "Is an error" do assert_raises(MessageStore::Postgres::Get::Category::ConsumerGroup::Error) do - Get::Category.('someCategory', consumer_group_member: -1, consumer_group_size: 1) + Get::Category.("someCategory", consumer_group_member: -1, consumer_group_size: 1) end end end @@ -32,7 +32,7 @@ context "Consumer Group Size is Missing" do test "Is an error" do assert_raises(MessageStore::Postgres::Get::Category::ConsumerGroup::Error) do - Get::Category.('someCategory', consumer_group_member: 0) + Get::Category.("someCategory", consumer_group_member: 0) end end end @@ -40,7 +40,7 @@ context "Consumer Group Member is Missing" do test "Is an error" do assert_raises(MessageStore::Postgres::Get::Category::ConsumerGroup::Error) do - Get::Category.('someCategory', consumer_group_size: 1) + Get::Category.("someCategory", consumer_group_size: 1) end end end diff --git a/test/automated/get/category/specialized/correlation/correlation.rb b/test/automated/get/category/specialized/correlation/correlation.rb index 69d131a..35a8eb8 100644 --- a/test/automated/get/category/specialized/correlation/correlation.rb +++ b/test/automated/get/category/specialized/correlation/correlation.rb @@ -1,4 +1,4 @@ -require_relative '../../../../automated_init' +require_relative "../../../../automated_init" context "Get" do context "Category" do diff --git a/test/automated/get/category/specialized/correlation/error.rb b/test/automated/get/category/specialized/correlation/error.rb index 178adff..11166c7 100644 --- a/test/automated/get/category/specialized/correlation/error.rb +++ b/test/automated/get/category/specialized/correlation/error.rb @@ -1,4 +1,4 @@ -require_relative '../../../../automated_init' +require_relative "../../../../automated_init" context "Get" do context "Category" do diff --git a/test/automated/get/category/specialized/dependency.rb b/test/automated/get/category/specialized/dependency.rb index 5b7170e..ae86ffb 100644 --- a/test/automated/get/category/specialized/dependency.rb +++ b/test/automated/get/category/specialized/dependency.rb @@ -1,4 +1,4 @@ -require_relative '../../../automated_init' +require_relative "../../../automated_init" context "Get" do context "Category" do diff --git a/test/automated/get/category/specialized/get_messages.rb b/test/automated/get/category/specialized/get_messages.rb index a353950..ce5140b 100644 --- a/test/automated/get/category/specialized/get_messages.rb +++ b/test/automated/get/category/specialized/get_messages.rb @@ -1,4 +1,4 @@ -require_relative '../../../automated_init' +require_relative "../../../automated_init" context "Get" do context "Category" do diff --git a/test/automated/get/category/specialized/no_messages.rb b/test/automated/get/category/specialized/no_messages.rb index 422dabd..87be060 100644 --- a/test/automated/get/category/specialized/no_messages.rb +++ b/test/automated/get/category/specialized/no_messages.rb @@ -1,4 +1,4 @@ -require_relative '../../../automated_init' +require_relative "../../../automated_init" context "Get" do context "Category" do diff --git a/test/automated/get/category/specialized/position.rb b/test/automated/get/category/specialized/position.rb index eaec3eb..3748a41 100644 --- a/test/automated/get/category/specialized/position.rb +++ b/test/automated/get/category/specialized/position.rb @@ -1,4 +1,4 @@ -require_relative '../../../automated_init' +require_relative "../../../automated_init" context "Get" do context "Category" do diff --git a/test/automated/get/category/specialized/stream_name_error.rb b/test/automated/get/category/specialized/stream_name_error.rb index e8a521d..7a364c2 100644 --- a/test/automated/get/category/specialized/stream_name_error.rb +++ b/test/automated/get/category/specialized/stream_name_error.rb @@ -1,4 +1,4 @@ -require_relative '../../../automated_init' +require_relative "../../../automated_init" context "Get" do context "Category" do diff --git a/test/automated/get/stream/generalized/get_messages.rb b/test/automated/get/stream/generalized/get_messages.rb index 4fc5745..554ead4 100644 --- a/test/automated/get/stream/generalized/get_messages.rb +++ b/test/automated/get/stream/generalized/get_messages.rb @@ -1,4 +1,4 @@ -require_relative '../../../automated_init' +require_relative "../../../automated_init" context "Get" do context "Stream" do diff --git a/test/automated/get/stream/generalized/specialization.rb b/test/automated/get/stream/generalized/specialization.rb index 30c6972..a97ca48 100644 --- a/test/automated/get/stream/generalized/specialization.rb +++ b/test/automated/get/stream/generalized/specialization.rb @@ -1,4 +1,4 @@ -require_relative '../../../automated_init' +require_relative "../../../automated_init" context "Get" do context "Stream" do @@ -9,7 +9,7 @@ batch_size = 1 consumer_group_member = 0 consumer_group_size = 1 - condition = 'global_position >= 1' + condition = "global_position >= 1" session = Session.build get = Get.build(stream_name, batch_size: batch_size, condition: condition, session: session) diff --git a/test/automated/get/stream/get_last/get_last.rb b/test/automated/get/stream/get_last/get_last.rb index fc7defc..bd1796d 100644 --- a/test/automated/get/stream/get_last/get_last.rb +++ b/test/automated/get/stream/get_last/get_last.rb @@ -1,4 +1,4 @@ -require_relative '../../../automated_init' +require_relative "../../../automated_init" context "Get" do context "Stream" do diff --git a/test/automated/get/stream/get_last/no_messages.rb b/test/automated/get/stream/get_last/no_messages.rb index 998d03d..429d9db 100644 --- a/test/automated/get/stream/get_last/no_messages.rb +++ b/test/automated/get/stream/get_last/no_messages.rb @@ -1,4 +1,4 @@ -require_relative '../../../automated_init' +require_relative "../../../automated_init" context "Get" do context "Stream" do diff --git a/test/automated/get/stream/get_last/type.rb b/test/automated/get/stream/get_last/type.rb index 97ba970..36c7897 100644 --- a/test/automated/get/stream/get_last/type.rb +++ b/test/automated/get/stream/get_last/type.rb @@ -1,4 +1,4 @@ -require_relative '../../../automated_init' +require_relative "../../../automated_init" context "Get" do context "Stream" do diff --git a/test/automated/get/stream/specialized/batch_size.rb b/test/automated/get/stream/specialized/batch_size.rb index bbec381..7382902 100644 --- a/test/automated/get/stream/specialized/batch_size.rb +++ b/test/automated/get/stream/specialized/batch_size.rb @@ -1,4 +1,4 @@ -require_relative '../../../automated_init' +require_relative "../../../automated_init" context "Get" do context "Stream" do diff --git a/test/automated/get/stream/specialized/condition/condition.rb b/test/automated/get/stream/specialized/condition/condition.rb index e0f6be7..d005c06 100644 --- a/test/automated/get/stream/specialized/condition/condition.rb +++ b/test/automated/get/stream/specialized/condition/condition.rb @@ -1,4 +1,4 @@ -require_relative '../../../../automated_init' +require_relative "../../../../automated_init" context "Get" do context "Stream" do @@ -6,12 +6,12 @@ context "Condition" do stream_name, _ = Controls::Put.(instances: 3) - condition = 'position = 0 OR position = 2' + condition = "position = 0 OR position = 2" settings = Postgres::Settings.build session = Session.new settings.set(session) - session.options = '-c message_store.sql_condition=on' + session.options = "-c message_store.sql_condition=on" messages = Get.(stream_name, batch_size: 3, condition: condition, session: session) diff --git a/test/automated/get/stream/specialized/condition/not_activated.rb b/test/automated/get/stream/specialized/condition/not_activated.rb index 0a34e4f..e1edb68 100644 --- a/test/automated/get/stream/specialized/condition/not_activated.rb +++ b/test/automated/get/stream/specialized/condition/not_activated.rb @@ -1,4 +1,4 @@ -require_relative '../../../../automated_init' +require_relative "../../../../automated_init" context "Get" do context "Category" do @@ -7,7 +7,7 @@ context "Not Activated" do stream_name = Controls::StreamName.example - condition = 'some condition' + condition = "some condition" settings = Postgres::Settings.build session = Session.new diff --git a/test/automated/get/stream/specialized/dependency.rb b/test/automated/get/stream/specialized/dependency.rb index 4f2c297..9313f0c 100644 --- a/test/automated/get/stream/specialized/dependency.rb +++ b/test/automated/get/stream/specialized/dependency.rb @@ -1,4 +1,4 @@ -require_relative '../../../automated_init' +require_relative "../../../automated_init" context "Get" do context "Stream" do diff --git a/test/automated/get/stream/specialized/get_messages.rb b/test/automated/get/stream/specialized/get_messages.rb index dcc2c89..29fd444 100644 --- a/test/automated/get/stream/specialized/get_messages.rb +++ b/test/automated/get/stream/specialized/get_messages.rb @@ -1,4 +1,4 @@ -require_relative '../../../automated_init' +require_relative "../../../automated_init" context "Get" do context "Stream" do diff --git a/test/automated/get/stream/specialized/no_messages.rb b/test/automated/get/stream/specialized/no_messages.rb index e275cca..78dd937 100644 --- a/test/automated/get/stream/specialized/no_messages.rb +++ b/test/automated/get/stream/specialized/no_messages.rb @@ -1,4 +1,4 @@ -require_relative '../../../automated_init' +require_relative "../../../automated_init" context "Get" do context "Stream" do diff --git a/test/automated/get/stream/specialized/position.rb b/test/automated/get/stream/specialized/position.rb index 389490a..3e37117 100644 --- a/test/automated/get/stream/specialized/position.rb +++ b/test/automated/get/stream/specialized/position.rb @@ -1,4 +1,4 @@ -require_relative '../../../automated_init' +require_relative "../../../automated_init" context "Get" do context "Stream" do diff --git a/test/automated/get/stream/specialized/stream_name_error.rb b/test/automated/get/stream/specialized/stream_name_error.rb index a06ca92..ae868c9 100644 --- a/test/automated/get/stream/specialized/stream_name_error.rb +++ b/test/automated/get/stream/specialized/stream_name_error.rb @@ -1,4 +1,4 @@ -require_relative '../../../automated_init' +require_relative "../../../automated_init" context "Get" do context "Stream" do diff --git a/test/automated/iterator/category/next.rb b/test/automated/iterator/category/next.rb index ef470e1..fc3bbd6 100644 --- a/test/automated/iterator/category/next.rb +++ b/test/automated/iterator/category/next.rb @@ -1,4 +1,4 @@ -require_relative '../../automated_init' +require_relative "../../automated_init" context "Iterator" do context "Category" do diff --git a/test/automated/iterator/category/no_further_message_data.rb b/test/automated/iterator/category/no_further_message_data.rb index 1ae7b32..3437f0b 100644 --- a/test/automated/iterator/category/no_further_message_data.rb +++ b/test/automated/iterator/category/no_further_message_data.rb @@ -1,4 +1,4 @@ -require_relative '../../automated_init' +require_relative "../../automated_init" context "Iterator" do context "Category" do diff --git a/test/automated/iterator/stream/next.rb b/test/automated/iterator/stream/next.rb index 74c44b5..86dae2b 100644 --- a/test/automated/iterator/stream/next.rb +++ b/test/automated/iterator/stream/next.rb @@ -1,4 +1,4 @@ -require_relative '../../automated_init' +require_relative "../../automated_init" context "Iterator" do context "Stream" do diff --git a/test/automated/iterator/stream/no_further_message_data.rb b/test/automated/iterator/stream/no_further_message_data.rb index 99ffa10..b232a3c 100644 --- a/test/automated/iterator/stream/no_further_message_data.rb +++ b/test/automated/iterator/stream/no_further_message_data.rb @@ -1,4 +1,4 @@ -require_relative '../../automated_init' +require_relative "../../automated_init" context "Iterator" do context "Stream" do diff --git a/test/automated/put/category_as_stream_name.rb b/test/automated/put/category_as_stream_name.rb index 8144dba..5990ea5 100644 --- a/test/automated/put/category_as_stream_name.rb +++ b/test/automated/put/category_as_stream_name.rb @@ -1,4 +1,4 @@ -require_relative '../automated_init' +require_relative "../automated_init" context "Put" do context "Category as Stream Name" do diff --git a/test/automated/put/data/empty.rb b/test/automated/put/data/empty.rb index 717c4e5..7c93579 100644 --- a/test/automated/put/data/empty.rb +++ b/test/automated/put/data/empty.rb @@ -1,4 +1,4 @@ -require_relative '../../automated_init' +require_relative "../../automated_init" context "Put" do context "Metadata" do diff --git a/test/automated/put/data/nil.rb b/test/automated/put/data/nil.rb index b9c89e6..4e17179 100644 --- a/test/automated/put/data/nil.rb +++ b/test/automated/put/data/nil.rb @@ -1,4 +1,4 @@ -require_relative '../../automated_init' +require_relative "../../automated_init" context "Put" do context "Data" do diff --git a/test/automated/put/expected_version/error.rb b/test/automated/put/expected_version/error.rb index 2a257d0..5eb18cb 100644 --- a/test/automated/put/expected_version/error.rb +++ b/test/automated/put/expected_version/error.rb @@ -1,4 +1,4 @@ -require_relative '../../automated_init' +require_relative "../../automated_init" context "Put" do context "Expected Version" do diff --git a/test/automated/put/expected_version/expected_version.rb b/test/automated/put/expected_version/expected_version.rb index 9d96c6d..16b830a 100644 --- a/test/automated/put/expected_version/expected_version.rb +++ b/test/automated/put/expected_version/expected_version.rb @@ -1,4 +1,4 @@ -require_relative '../../automated_init' +require_relative "../../automated_init" context "Put" do context "Message" do diff --git a/test/automated/put/metadata/empty.rb b/test/automated/put/metadata/empty.rb index d83e903..e9bd745 100644 --- a/test/automated/put/metadata/empty.rb +++ b/test/automated/put/metadata/empty.rb @@ -1,4 +1,4 @@ -require_relative '../../automated_init' +require_relative "../../automated_init" context "Put" do context "Metadata" do diff --git a/test/automated/put/metadata/nil.rb b/test/automated/put/metadata/nil.rb index 9069e1d..31e3de5 100644 --- a/test/automated/put/metadata/nil.rb +++ b/test/automated/put/metadata/nil.rb @@ -1,4 +1,4 @@ -require_relative '../../automated_init' +require_relative "../../automated_init" context "Put" do context "Metadata" do diff --git a/test/automated/put/missing_id.rb b/test/automated/put/missing_id.rb index d99e41c..d50632a 100644 --- a/test/automated/put/missing_id.rb +++ b/test/automated/put/missing_id.rb @@ -1,4 +1,4 @@ -require_relative '../automated_init' +require_relative "../automated_init" context "Put" do context "Missing ID" do diff --git a/test/automated/put/no_stream/existing_stream.rb b/test/automated/put/no_stream/existing_stream.rb index a2989a2..4b785c7 100644 --- a/test/automated/put/no_stream/existing_stream.rb +++ b/test/automated/put/no_stream/existing_stream.rb @@ -1,4 +1,4 @@ -require_relative '../../automated_init' +require_relative "../../automated_init" context "Put" do context "No Stream" do diff --git a/test/automated/put/no_stream/no_stream.rb b/test/automated/put/no_stream/no_stream.rb index 6b47a07..b658f9e 100644 --- a/test/automated/put/no_stream/no_stream.rb +++ b/test/automated/put/no_stream/no_stream.rb @@ -1,4 +1,4 @@ -require_relative '../../automated_init' +require_relative "../../automated_init" context "Put" do context "No Stream" do diff --git a/test/automated/put/put.rb b/test/automated/put/put.rb index 4bdcbbf..5542b91 100644 --- a/test/automated/put/put.rb +++ b/test/automated/put/put.rb @@ -1,4 +1,4 @@ -require_relative '../automated_init' +require_relative "../automated_init" context "Put and Get" do stream_name = Controls::StreamName.example diff --git a/test/automated/put/returns_stream_position.rb b/test/automated/put/returns_stream_position.rb index 1cff268..4342b26 100644 --- a/test/automated/put/returns_stream_position.rb +++ b/test/automated/put/returns_stream_position.rb @@ -1,4 +1,4 @@ -require_relative '../automated_init' +require_relative "../automated_init" context "Put" do context "Returns Stream Position" do diff --git a/test/automated/put/stream_position_increases.rb b/test/automated/put/stream_position_increases.rb index 0c45bcf..758bf23 100644 --- a/test/automated/put/stream_position_increases.rb +++ b/test/automated/put/stream_position_increases.rb @@ -1,4 +1,4 @@ -require_relative '../automated_init' +require_relative "../automated_init" context "Put" do context "Stream Position Increases with Subsequent Writes" do diff --git a/test/automated/put_and_get.rb b/test/automated/put_and_get.rb index 9f3fdc0..db64ea4 100644 --- a/test/automated/put_and_get.rb +++ b/test/automated/put_and_get.rb @@ -1,4 +1,4 @@ -require_relative 'automated_init' +require_relative "automated_init" context "Put and Get" do stream_name = Controls::StreamName.example diff --git a/test/automated/read/condition.rb b/test/automated/read/condition.rb index 9113e67..5f30c3d 100644 --- a/test/automated/read/condition.rb +++ b/test/automated/read/condition.rb @@ -1,17 +1,17 @@ -require_relative '../automated_init' +require_relative "../automated_init" context "Read" do context "Condition" do stream_name, _ = Controls::Put.(instances: 3) - condition = 'position = 0' + condition = "position = 0" message_count = 0 settings = Postgres::Settings.build session = Session.new settings.set(session) - session.options = '-c message_store.sql_condition=on' + session.options = "-c message_store.sql_condition=on" Read.(stream_name, condition: condition, session: session) do message_count += 1 diff --git a/test/automated/read/default_batch_size.rb b/test/automated/read/default_batch_size.rb index 821299f..52e8d3b 100644 --- a/test/automated/read/default_batch_size.rb +++ b/test/automated/read/default_batch_size.rb @@ -1,4 +1,4 @@ -require_relative '../automated_init' +require_relative "../automated_init" context "Read" do context "Default batch Size" do diff --git a/test/automated/read/position.rb b/test/automated/read/position.rb index c27ad82..d38ba40 100644 --- a/test/automated/read/position.rb +++ b/test/automated/read/position.rb @@ -1,4 +1,4 @@ -require_relative '../automated_init' +require_relative "../automated_init" context "Read" do context "Position" do diff --git a/test/automated/read/read.rb b/test/automated/read/read.rb index 6bf03c9..e0122fd 100644 --- a/test/automated/read/read.rb +++ b/test/automated/read/read.rb @@ -1,4 +1,4 @@ -require_relative '../automated_init' +require_relative "../automated_init" context "Read" do stream_name, _ = Controls::Put.(instances: 2) diff --git a/test/automated/session/build.rb b/test/automated/session/build.rb index 888136d..e62758a 100644 --- a/test/automated/session/build.rb +++ b/test/automated/session/build.rb @@ -1,4 +1,4 @@ -require_relative '../automated_init' +require_relative "../automated_init" context "Session" do context "Build" do diff --git a/test/automated/session/configure.rb b/test/automated/session/configure.rb index 1e748cf..a8e7a33 100644 --- a/test/automated/session/configure.rb +++ b/test/automated/session/configure.rb @@ -1,4 +1,4 @@ -require_relative '../automated_init' +require_relative "../automated_init" context "Session" do context "Configure" do @@ -28,7 +28,7 @@ Session.configure(receiver, settings: settings) test "Session is built from settings" do - assert(receiver.session.user == settings.get('user')) + assert(receiver.session.user == settings.get("user")) end end diff --git a/test/automated/session/connect_on_first_use.rb b/test/automated/session/connect_on_first_use.rb index 4e6db9b..652722f 100644 --- a/test/automated/session/connect_on_first_use.rb +++ b/test/automated/session/connect_on_first_use.rb @@ -1,4 +1,4 @@ -require_relative '../automated_init' +require_relative "../automated_init" context "Session" do test "On First Use" do @@ -8,7 +8,7 @@ test "Connects" do refute_raises do - session.execute(';') + session.execute(";") end end end diff --git a/test/automated/session/connection_executed_time.rb b/test/automated/session/connection_executed_time.rb index ec0e5f9..a1d3d5a 100644 --- a/test/automated/session/connection_executed_time.rb +++ b/test/automated/session/connection_executed_time.rb @@ -1,4 +1,4 @@ -require_relative '../automated_init' +require_relative "../automated_init" context "Session" do context "Connection Executed Time" do @@ -17,7 +17,7 @@ time = Controls::Time::Raw.example session.clock.now = time - session.execute(';') + session.execute(";") test "Executed time is set to the clock time" do assert(session.executed_time == time) diff --git a/test/automated/session/connection_executed_time_elapsed_milliseconds.rb b/test/automated/session/connection_executed_time_elapsed_milliseconds.rb index e996241..5aa3e64 100644 --- a/test/automated/session/connection_executed_time_elapsed_milliseconds.rb +++ b/test/automated/session/connection_executed_time_elapsed_milliseconds.rb @@ -1,4 +1,4 @@ -require_relative '../automated_init' +require_relative "../automated_init" context "Session" do context "Connection Executed Time Elapsed Milliseconds" do diff --git a/test/automated/session/escape.rb b/test/automated/session/escape.rb index d632637..c8a9f4d 100644 --- a/test/automated/session/escape.rb +++ b/test/automated/session/escape.rb @@ -1,4 +1,4 @@ -require_relative '../automated_init' +require_relative "../automated_init" context "Session" do context "Escape" do diff --git a/test/automated/session/initial_state_is_not_connected.rb b/test/automated/session/initial_state_is_not_connected.rb index 01cd50d..b1f499e 100644 --- a/test/automated/session/initial_state_is_not_connected.rb +++ b/test/automated/session/initial_state_is_not_connected.rb @@ -1,4 +1,4 @@ -require_relative '../automated_init' +require_relative "../automated_init" context "Session" do test "Initial State" do diff --git a/test/automated/session/settings.rb b/test/automated/session/settings.rb index deb2fde..1c1d517 100644 --- a/test/automated/session/settings.rb +++ b/test/automated/session/settings.rb @@ -1,4 +1,4 @@ -require_relative '../automated_init' +require_relative "../automated_init" context "Session" do context "Settings" do diff --git a/test/automated/settings.rb b/test/automated/settings.rb index fa0a521..410ce7a 100644 --- a/test/automated/settings.rb +++ b/test/automated/settings.rb @@ -1,4 +1,4 @@ -require_relative 'automated_init' +require_relative "automated_init" context "Settings" do settings = Postgres::Settings.build diff --git a/test/automated/settings/default_path.rb b/test/automated/settings/default_path.rb index 46ada36..1400f92 100644 --- a/test/automated/settings/default_path.rb +++ b/test/automated/settings/default_path.rb @@ -1,11 +1,11 @@ -require_relative '../automated_init' +require_relative "../automated_init" context "Settings" do context "Default Path" do - prior_default_settings_path = ENV['MESSAGE_STORE_SETTINGS_PATH'] + prior_default_settings_path = ENV["MESSAGE_STORE_SETTINGS_PATH"] - overridden_path = 'some_path' - ENV['MESSAGE_STORE_SETTINGS_PATH'] = overridden_path + overridden_path = "some_path" + ENV["MESSAGE_STORE_SETTINGS_PATH"] = overridden_path settings_path = Postgres::Settings.data_source @@ -13,6 +13,6 @@ assert(settings_path == overridden_path) end - ENV['MESSAGE_STORE_SETTINGS_PATH'] = prior_default_settings_path + ENV["MESSAGE_STORE_SETTINGS_PATH"] = prior_default_settings_path end end diff --git a/test/automated/write/batch/expected_version/error.rb b/test/automated/write/batch/expected_version/error.rb index adca25a..149c4db 100644 --- a/test/automated/write/batch/expected_version/error.rb +++ b/test/automated/write/batch/expected_version/error.rb @@ -1,4 +1,4 @@ -require_relative '../../../automated_init' +require_relative "../../../automated_init" context "Write" do context "Batch" do diff --git a/test/automated/write/batch/expected_version/expected_version.rb b/test/automated/write/batch/expected_version/expected_version.rb index de922b2..fb8b332 100644 --- a/test/automated/write/batch/expected_version/expected_version.rb +++ b/test/automated/write/batch/expected_version/expected_version.rb @@ -1,4 +1,4 @@ -require_relative '../../../automated_init' +require_relative "../../../automated_init" context "Write" do context "Batch" do diff --git a/test/automated/write/batch/write.rb b/test/automated/write/batch/write.rb index d053b5f..33d1834 100644 --- a/test/automated/write/batch/write.rb +++ b/test/automated/write/batch/write.rb @@ -1,4 +1,4 @@ -require_relative '../../automated_init' +require_relative "../../automated_init" context "Write" do context "Batch" do diff --git a/test/automated/write/message/expected_version/error.rb b/test/automated/write/message/expected_version/error.rb index 54603d6..a9a1a6f 100644 --- a/test/automated/write/message/expected_version/error.rb +++ b/test/automated/write/message/expected_version/error.rb @@ -1,4 +1,4 @@ -require_relative '../../../automated_init' +require_relative "../../../automated_init" context "Write" do context "Message" do diff --git a/test/automated/write/message/expected_version/expected_version.rb b/test/automated/write/message/expected_version/expected_version.rb index a353879..99e4c8d 100644 --- a/test/automated/write/message/expected_version/expected_version.rb +++ b/test/automated/write/message/expected_version/expected_version.rb @@ -1,4 +1,4 @@ -require_relative '../../../automated_init' +require_relative "../../../automated_init" context "Write" do context "Message" do diff --git a/test/automated/write/message/write.rb b/test/automated/write/message/write.rb index ea43ff3..b9785f4 100644 --- a/test/automated/write/message/write.rb +++ b/test/automated/write/message/write.rb @@ -1,4 +1,4 @@ -require_relative '../../automated_init' +require_relative "../../automated_init" context "Write" do context "Message" do diff --git a/test/benchmark/benchmark_init.rb b/test/benchmark/benchmark_init.rb index 27195c8..3b132ec 100644 --- a/test/benchmark/benchmark_init.rb +++ b/test/benchmark/benchmark_init.rb @@ -1,11 +1,11 @@ -require_relative '../test_init' +require_relative "../test_init" Dependency.activate Initializer.activate -require 'diagnostics/sample' -require 'fileutils' -require 'pathname' +require "diagnostics/sample" +require "fileutils" +require "pathname" -require_relative 'defaults' -require_relative 'record_result' +require_relative "defaults" +require_relative "record_result" diff --git a/test/benchmark/defaults.rb b/test/benchmark/defaults.rb index cc0e0ad..d30c6d8 100644 --- a/test/benchmark/defaults.rb +++ b/test/benchmark/defaults.rb @@ -21,24 +21,24 @@ def self.build end def self.cycles - Integer(ENV['CYCLES'] || 100_000) + Integer(ENV["CYCLES"] || 100_000) end def self.warmup_cycles - Integer(ENV['WARMUP_CYCLES'] || 10) + Integer(ENV["WARMUP_CYCLES"] || 10) end def self.gc - ['on', 'true'].include?(ENV['GC']) ? true : false + ["on", "true"].include?(ENV["GC"]) ? true : false end def self.verbose - ['on', 'true'].include?(ENV['VERBOSE']) ? true : false + ["on", "true"].include?(ENV["VERBOSE"]) ? true : false end def self.stream_name -## ENV['STREAM_NAME'] || Controls::StreamName.example - ENV['STREAM_NAME'] +## ENV["STREAM_NAME"] || Controls::StreamName.example + ENV["STREAM_NAME"] end end end diff --git a/test/benchmark/get_category.rb b/test/benchmark/get_category.rb index d137f6b..5363872 100644 --- a/test/benchmark/get_category.rb +++ b/test/benchmark/get_category.rb @@ -1,4 +1,4 @@ -require_relative 'benchmark_init' +require_relative "benchmark_init" defaults = Test::Benchmark::Defaults.build @@ -27,7 +27,7 @@ end puts "» constructing Get::Category" -get = Get::Category.build('', batch_size: 1) +get = Get::Category.build("", batch_size: 1) puts "» executing and sampling #{total_cycles} cycles" result = Diagnostics::Sample.(defaults.cycles, warmup_cycles: defaults.warmup_cycles, gc: defaults.gc) do |i| @@ -41,7 +41,7 @@ end puts -filename = Benchmark::RecordResult.('Get Category Benchmark', result) +filename = Benchmark::RecordResult.("Get Category Benchmark", result) puts puts filename puts diff --git a/test/benchmark/get_stream.rb b/test/benchmark/get_stream.rb index 486332d..6742c64 100644 --- a/test/benchmark/get_stream.rb +++ b/test/benchmark/get_stream.rb @@ -1,4 +1,4 @@ -require_relative 'benchmark_init' +require_relative "benchmark_init" defaults = Test::Benchmark::Defaults.build @@ -27,7 +27,7 @@ end puts "» constructing Get::Stream" -get = Get::Stream.build('-', batch_size: 1) +get = Get::Stream.build("-", batch_size: 1) puts "» executing and sampling #{total_cycles} cycles" result = Diagnostics::Sample.(defaults.cycles, warmup_cycles: defaults.warmup_cycles, gc: defaults.gc) do |i| @@ -41,7 +41,7 @@ end puts -filename = Benchmark::RecordResult.('Get Stream Benchmark', result) +filename = Benchmark::RecordResult.("Get Stream Benchmark", result) puts puts filename puts diff --git a/test/benchmark/put.rb b/test/benchmark/put.rb index d42b806..f417c40 100644 --- a/test/benchmark/put.rb +++ b/test/benchmark/put.rb @@ -1,4 +1,4 @@ -require_relative 'benchmark_init' +require_relative "benchmark_init" defaults = Test::Benchmark::Defaults.build @@ -30,7 +30,7 @@ end puts -filename = Benchmark::RecordResult.('Put Benchmark', result) +filename = Benchmark::RecordResult.("Put Benchmark", result) puts puts filename puts diff --git a/test/benchmark/record_result.rb b/test/benchmark/record_result.rb index ca0335c..7d3f8ce 100644 --- a/test/benchmark/record_result.rb +++ b/test/benchmark/record_result.rb @@ -35,8 +35,8 @@ def write_result_file end def filename - time = clock.iso8601.gsub(':','-') - directory = Pathname.new('test/benchmark/tmp') + time = clock.iso8601.gsub(":","-") + directory = Pathname.new("test/benchmark/tmp") filename = directory.join("#{name} - #{time} - #{RUBY_DESCRIPTION}.txt") filename diff --git a/test/interactive/concurrency/concurrency_init.rb b/test/interactive/concurrency/concurrency_init.rb index 89303b6..9be3198 100644 --- a/test/interactive/concurrency/concurrency_init.rb +++ b/test/interactive/concurrency/concurrency_init.rb @@ -1,5 +1,5 @@ -ENV['LOG_TAGS'] ||= 'actor' +ENV["LOG_TAGS"] ||= "actor" -require_relative '../interactive_init' +require_relative "../interactive_init" -require_relative 'defaults' +require_relative "defaults" diff --git a/test/interactive/concurrency/defaults.rb b/test/interactive/concurrency/defaults.rb index 6e6e9dd..1bffb13 100644 --- a/test/interactive/concurrency/defaults.rb +++ b/test/interactive/concurrency/defaults.rb @@ -3,7 +3,7 @@ module Interactive module Concurrency class Defaults def self.actors - Integer(ENV['ACTORS'] || 2) + Integer(ENV["ACTORS"] || 2) end end end diff --git a/test/interactive/concurrency/write_to_single_stream.rb b/test/interactive/concurrency/write_to_single_stream.rb index 5f91f08..98e650f 100644 --- a/test/interactive/concurrency/write_to_single_stream.rb +++ b/test/interactive/concurrency/write_to_single_stream.rb @@ -1,6 +1,6 @@ -require_relative 'concurrency_init' +require_relative "concurrency_init" -require 'actor' +require "actor" module Test module Interactive diff --git a/test/interactive/interactive_init.rb b/test/interactive/interactive_init.rb index 0893a61..40e535c 100644 --- a/test/interactive/interactive_init.rb +++ b/test/interactive/interactive_init.rb @@ -1,4 +1,4 @@ -ENV['LOG_LEVEL'] ||= 'info' -ENV['LOG_TAGS'] ||= '_untagged,message_store_postgres,-data' +ENV["LOG_LEVEL"] ||= "info" +ENV["LOG_TAGS"] ||= "_untagged,message_store_postgres,-data" -require_relative '../test_init' +require_relative "../test_init" diff --git a/test/test_init.rb b/test/test_init.rb index 1cefd49..db166d9 100644 --- a/test/test_init.rb +++ b/test/test_init.rb @@ -1,12 +1,12 @@ -ENV['CONSOLE_DEVICE'] ||= 'stdout' -ENV['LOG_LEVEL'] ||= '_min' +ENV["CONSOLE_DEVICE"] ||= "stdout" +ENV["LOG_LEVEL"] ||= "_min" puts RUBY_DESCRIPTION -require_relative '../init' -require 'message_store/postgres/controls' +require_relative "../init" +require "message_store/postgres/controls" -require 'test_bench'; TestBench.activate +require "test_bench"; TestBench.activate include MessageStore include MessageStore::Postgres diff --git a/tools/write_message.rb b/tools/write_message.rb index 4e3ce48..90fe124 100755 --- a/tools/write_message.rb +++ b/tools/write_message.rb @@ -1,19 +1,19 @@ #!/usr/bin/env ruby -ENV['CONSOLE_DEVICE'] ||= 'stdout' -ENV['LOG_LEVEL'] ||= '_min' +ENV["CONSOLE_DEVICE"] ||= "stdout" +ENV["LOG_LEVEL"] ||= "_min" puts RUBY_DESCRIPTION -require_relative '../init' +require_relative "../init" -require 'message_store/postgres/controls' +require "message_store/postgres/controls" include MessageStore include MessageStore::Postgres -instances = Integer(ENV['INSTANCES'] || 1) -stream_name = ENV['STREAM_NAME'] +instances = Integer(ENV["INSTANCES"] || 1) +stream_name = ENV["STREAM_NAME"] puts puts "Writing #{instances} messages"