diff --git a/README.md b/README.md index 3f0ec49..2c6043d 100644 --- a/README.md +++ b/README.md @@ -9,7 +9,7 @@ DCB-compatible event store library in Ruby with support for PostgreSQL. ```ruby store = En57::EventStore.new( - En57::PgRepository.new( + En57::Repository.new( En57::PgAdapter.new("postgres://localhost:5432/en57"), En57::JsonSerializer.new, ), diff --git a/lib/en57.rb b/lib/en57.rb index f21b649..5b1a9e1 100644 --- a/lib/en57.rb +++ b/lib/en57.rb @@ -6,7 +6,7 @@ require_relative "en57/json_serializer" require_relative "en57/query" require_relative "en57/scope" require_relative "en57/pg_adapter" -require_relative "en57/pg_repository" +require_relative "en57/repository" require_relative "en57/event_store" module En57 diff --git a/lib/en57/pg_repository.rb b/lib/en57/repository.rb similarity index 98% rename from lib/en57/pg_repository.rb rename to lib/en57/repository.rb index ca5eaa4..553091b 100644 --- a/lib/en57/pg_repository.rb +++ b/lib/en57/repository.rb @@ -3,7 +3,7 @@ require "pg" module En57 - class PgRepository + class Repository def initialize(adapter, serializer) @adapter = adapter @serializer = serializer diff --git a/test/test_integration.rb b/test/test_integration.rb index e50b681..cd12708 100644 --- a/test/test_integration.rb +++ b/test/test_integration.rb @@ -210,7 +210,7 @@ module En57 def with_event_store = yield( EventStore.new( - PgRepository.new(PgAdapter.new(SERVER.url), JsonSerializer.new), + Repository.new(PgAdapter.new(SERVER.url), JsonSerializer.new), ) ) end diff --git a/test/test_pg_repository.rb b/test/test_repository.rb similarity index 96% rename from test/test_pg_repository.rb rename to test/test_repository.rb index 33e7930..9474c4b 100644 --- a/test/test_pg_repository.rb +++ b/test/test_repository.rb @@ -3,8 +3,8 @@ require "test_helper" module En57 - class TestPgRepository < Minitest::Test - cover PgRepository + class TestRepository < Minitest::Test + cover Repository def test_append_wraps_write_in_serializable_transaction expected_events = @@ -42,7 +42,7 @@ module En57 ) connection.expect(:exec, nil, ["COMMIT"]) - PgRepository.new( + Repository.new( PgAdapter.new(connection_uri), JsonSerializer.new, ).append( @@ -85,7 +85,7 @@ module En57 ) connection.expect(:exec, nil, ["COMMIT"]) - PgRepository.new( + Repository.new( PgAdapter.new(connection_uri), JsonSerializer.new, ).append( @@ -118,7 +118,7 @@ module En57 end assert_raises(PG::Error) do - PgRepository.new( + Repository.new( PgAdapter.new(connection_uri), JsonSerializer.new, ).append([], fail_if: Query.all) @@ -135,7 +135,7 @@ module En57 end assert_raises(AppendConditionViolated) do - PgRepository.new( + Repository.new( PgAdapter.new(connection_uri), JsonSerializer.new, ).append([], fail_if: Query.all) @@ -152,7 +152,7 @@ module En57 end assert_raises(AppendConditionViolated) do - PgRepository.new( + Repository.new( PgAdapter.new(connection_uri), JsonSerializer.new, ).append([], fail_if: Query.all) @@ -169,7 +169,7 @@ module En57 end assert_raises(PG::Error) do - PgRepository.new( + Repository.new( PgAdapter.new(connection_uri), JsonSerializer.new, ).append([], fail_if: Query.all) @@ -184,7 +184,7 @@ module En57 connection.expect(:exec_params, nil) { raise RuntimeError, "boom" } assert_raises(RuntimeError) do - PgRepository.new( + Repository.new( PgAdapter.new(connection_uri), JsonSerializer.new, ).append([], fail_if: Query.all) @@ -237,7 +237,7 @@ module En57 tags: ["order_id:234"], ), ], - PgRepository.new( + Repository.new( PgAdapter.new(connection_uri), JsonSerializer.new, ).read(Query.all), @@ -279,7 +279,7 @@ module En57 tags: ["order_id:123"], ), ], - PgRepository.new( + Repository.new( PgAdapter.new(connection_uri), JsonSerializer.new, ).read(query), @@ -318,7 +318,7 @@ module En57 tags: ["order_id:123"], ), ], - PgRepository.new( + Repository.new( PgAdapter.new(connection_uri), JsonSerializer.new, ).read(query), @@ -367,7 +367,7 @@ module En57 tags: ["order_id:123"], ), ], - PgRepository.new( + Repository.new( PgAdapter.new(connection_uri), JsonSerializer.new, ).read(query), @@ -392,7 +392,7 @@ module En57 assert_equal( [], - PgRepository.new( + Repository.new( PgAdapter.new(connection_uri), JsonSerializer.new, ).read(query), @@ -434,7 +434,7 @@ module En57 tags: [], ), ], - PgRepository.new( + Repository.new( PgAdapter.new(connection_uri), JsonSerializer.new, ).read(query), diff --git a/test/test_stress.rb b/test/test_stress.rb index efa78f3..c5068e5 100644 --- a/test/test_stress.rb +++ b/test/test_stress.rb @@ -58,7 +58,7 @@ module En57 def with_event_store = yield( EventStore.new( - PgRepository.new(PgAdapter.new(SERVER.url), JsonSerializer.new), + Repository.new(PgAdapter.new(SERVER.url), JsonSerializer.new), ) )