Skip to content

Commit 2d7b7c6

Browse files
committed
EventClassRemapping superseded by upcasting
1 parent d04b4d5 commit 2d7b7c6

File tree

6 files changed

+4
-122
lines changed

6 files changed

+4
-122
lines changed

ruby_event_store/lib/ruby_event_store.rb

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -23,7 +23,6 @@
2323
require_relative "ruby_event_store/mappers/in_memory_encryption_key_repository"
2424
require_relative "ruby_event_store/mappers/transformation/domain_event"
2525
require_relative "ruby_event_store/mappers/transformation/encryption"
26-
require_relative "ruby_event_store/mappers/transformation/event_class_remapper"
2726
require_relative "ruby_event_store/mappers/transformation/upcast"
2827
require_relative "ruby_event_store/mappers/transformation/stringify_metadata_keys"
2928
require_relative "ruby_event_store/mappers/transformation/symbolize_metadata_keys"

ruby_event_store/lib/ruby_event_store/mappers/default.rb

Lines changed: 4 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -3,13 +3,10 @@
33
module RubyEventStore
44
module Mappers
55
class Default < PipelineMapper
6-
def initialize(events_class_remapping: {})
7-
super(
8-
Pipeline.new(
9-
Transformation::EventClassRemapper.new(events_class_remapping),
10-
Transformation::SymbolizeMetadataKeys.new
11-
)
12-
)
6+
def initialize
7+
super(Pipeline.new(
8+
Transformation::SymbolizeMetadataKeys.new,
9+
))
1310
end
1411
end
1512
end

ruby_event_store/lib/ruby_event_store/mappers/transformation/event_class_remapper.rb

Lines changed: 0 additions & 32 deletions
This file was deleted.

ruby_event_store/spec/mappers/default_spec.rb

Lines changed: 0 additions & 19 deletions
Original file line numberDiff line numberDiff line change
@@ -55,25 +55,6 @@ module Mappers
5555
expect(event.metadata[:valid_at]).to eq(time)
5656
end
5757

58-
specify "#record_to_event its using events class remapping" do
59-
subject = Default.new(events_class_remapping: { "EventNameBeforeRefactor" => "SomethingHappened" })
60-
record =
61-
Record.new(
62-
event_id: event.event_id,
63-
data: {
64-
some_attribute: 5
65-
},
66-
metadata: {
67-
some_meta: 1
68-
},
69-
event_type: "EventNameBeforeRefactor",
70-
timestamp: time,
71-
valid_at: time
72-
)
73-
event = subject.record_to_event(record)
74-
expect(event).to eq(event)
75-
end
76-
7758
specify "metadata keys are symbolized" do
7859
record =
7960
Record.new(

ruby_event_store/spec/mappers/transformation/event_class_remapper_spec.rb

Lines changed: 0 additions & 39 deletions
This file was deleted.

ruby_event_store/spec/projection_spec.rb

Lines changed: 0 additions & 24 deletions
Original file line numberDiff line numberDiff line change
@@ -309,29 +309,5 @@ module RubyEventStore
309309

310310
expect(state).to eq({})
311311
end
312-
313-
specify "supports event class remapping" do
314-
event_store =
315-
Client.new(
316-
mapper: Mappers::Default.new(events_class_remapping: { MoneyInvested.to_s => MoneyLost.to_s })
317-
)
318-
event_store.append(MoneyInvested.new(data: { amount: 1 }))
319-
320-
balance =
321-
Projection
322-
.from_all_streams
323-
.init(-> { { total: 0 } })
324-
.when(MoneyLost, ->(state, event) { state[:total] -= event.data[:amount] })
325-
.run(event_store)
326-
expect(balance).to eq(total: 0)
327-
328-
balance =
329-
Projection
330-
.from_all_streams
331-
.init(-> { { total: 0 } })
332-
.when([MoneyLost, MoneyInvested], ->(state, event) { state[:total] -= event.data[:amount] })
333-
.run(event_store)
334-
expect(balance).to eq(total: -1)
335-
end
336312
end
337313
end

0 commit comments

Comments
 (0)