ruby-on-rails - 在 RailsEventStore 中删除订阅

Question

我正在尝试使用 RailsEventStore 在事件源/CQRS 和受 DDD 启发的 Rails 5.2.x 应用程序中构建事件流的持久关系投影。

让我的投影仪接收关于我正在使用的新事件的通知Client#subscribe，效果很好。我在 Rails 初始化文件中设置了我的投影仪订阅。

现在，当我运行测试时，大多数测试都不需要事件流的投影。因此，我希望仅在高度集成的测试中订阅。

因为我的初始化程序似乎只运行一次，所以在执行任何单独的测试之前，我需要在测试初始化​​中订阅/取消订阅投影仪。可悲的是，我没有找到任何Client#unsubscribe方法的痕迹。

有没有办法在我已经订阅后取消订阅事件流？或者在 RailsEventStore 中是否有更好的方法来处理这种情况？

标签： ruby-on-railsdomain-driven-designcqrsevent-sourcingrails-event-store

Answer 1

没有Client#unsubscribe办法。相反，每个订阅都会返回一个您调用以撤销订阅的 lambda：

irb(main):001:0> event_store
=> #<RailsEventStore::Client:0x83ea4880>
irb(main):002:0> my_handler = ->(event) { }
=> #<Proc:0x000000010d6f1720@(irb):2 (lambda)>
irb(main):003:0> revoke = event_store.subscribe(my_handler, to: [Ordering::OrderSubmitted])
=> #<Proc:0x000000010d6d3568@/Users/pawelpacana/.rubies/ruby-2.5.5/lib/ruby/gems/2.5.0/gems/ruby_event_store-0.40.1/lib/ruby_event_store/subscriptions.rb:53 (lambda)>
irb(main):004:0> revoke.call
=> [Ordering::OrderSubmitted]

https://github.com/RailsEventStore/rails_event_store/blob/cfc91c9cb367e514ba1c6de1a711a7610780b520/ruby_event_store/lib/ruby_event_store/spec/subscriptions_lint.rb#L60-L102

---

或者在 RailsEventStore 中是否有更好的方法来处理这种情况？

我的同事 Rafał 在https://blog.arkency.com/optimizing-test-suites-when-using-rails-event-store/中描述了如何根据测试用例启用或禁用特定订阅者。简而言之，这个想法是event_store为每个测试创建新实例，并根据测试元数据过滤订阅者列表。

每次测试都有新event_store实例（开始时没有订阅者），您不再需要取消订阅。然后，您可以例如显式订阅集成测试用例：

def integrate_with_read_model
  event_store.subscribe(::MenuOffer.method(:handle_menu_offer_chosen),   to: [MenuOfferAccepted])
  event_store.subscribe(::MenuOffer.method(:handle_menu_offer_rejected), to: to: [MenuOfferDeclined])
  event_store.subscribe(::MenuOffer.method(:handle_menu_offer_is_pending), to: [MenuOfferIsPending])
  event_store.subscribe(::MenuOffer.method(:handle_menu_offer_set), to: [MenuOfferSet])
end


before(:each) { integrate_with_read_model }