mostlyobvious
commented
6 years ago Could you please post snippet of Rails config with event store?
This is my result for following one:
module Issue331
class Application < Rails::Application
# Settings in config/environments/* take precedence over those specified here.
# Application configuration should go into files in config/initializers
# -- all .rb files in that directory are automatically loaded.
# Set Time.zone default to the specified zone and make Active Record auto-convert to this zone.
# Run "rake -D time" for a list of tasks for finding time zone names. Default is UTC.
# config.time_zone = 'Central Time (US & Canada)'
# The default locale is :en and all translations from config/locales/*.rb,yml are auto loaded.
# config.i18n.load_path += Dir[Rails.root.join('my', 'locales', '*.{rb,yml}').to_s]
# config.i18n.default_locale = :de
# Do not swallow errors in after_commit/after_rollback callbacks.
config.active_record.raise_in_transactional_callbacks = true
config.to_prepare do
Rails.configuration.event_store = RailsEventStore::Client.new
end
end
end C/issue-331 $ ./bin/rails c %3 2 39s 849ms
Running via Spring preloader in process 12063
Loading development environment (Rails 4.2.10)
irb(main):001:0> event_store = Rails.configuration.event_store
=> #<RailsEventStore::Client:0x00007ff63aa7db80 @repository=#<RailsEventStoreActiveRecord::EventRepository:0x00007ff63aa7d9a0 @repo_reader=#<RailsEventStoreActiveRecord::EventRepositoryReader:0x00007ff63aa7d7c0>>, @mapper=#<RubyEventStore::Mappers::Default:0x00007ff63aa7d720 @serializer=Psych, @events_class_remapping={}>, @event_broker=#<RubyEventStore::PubSub::Broker:0x00007ff63aa7d310 @subscribers={}, @global_subscribers=[], @thread_global_subscribers=#<Concurrent::ThreadLocalVar:0x00007ff63aa7c618 @default_block=nil, @default=[], @index=0>, @thread_subscribers=#<Concurrent::ThreadLocalVar:0x00007ff63aa6fe68 @default_block=#<Proc:0x00007ff63aa6fdf0@/Users/pawelpacana/.rubies/ruby-2.4.2/lib/ruby/gems/2.4.0/gems/ruby_event_store-0.28.0/lib/ruby_event_store/pub_sub/broker.rb:13>, @default=nil, @index=1>, @dispatcher=#<RailsEventStore::ActiveJobDispatcher:0x00007ff63aa7d478 @async_proxy_strategy=#<RailsEventStore::AsyncProxyStrategy::Inline:0x00007ff63aa7d450>>>, @page_size=100, @metadata_proc=#<Proc:0x00007ff63aa6dfa0@/Users/pawelpacana/.rubies/ruby-2.4.2/lib/ruby/gems/2.4.0/gems/rails_event_store-0.28.0/lib/rails_event_store/client.rb:7 (lambda)>, @clock=#<Proc:0x00007ff63aa6d820@/Users/pawelpacana/.rubies/ruby-2.4.2/lib/ruby/gems/2.4.0/gems/ruby_event_store-0.28.0/lib/ruby_event_store/client.rb:8 (lambda)>>
irb(main):002:0> stream_name = "order_1"
=> "order_1"
irb(main):003:0> event = OrderPlaced.new(data: {
irb(main):004:2* order_id: 1,
irb(main):005:2* order_data: "sample",
irb(main):006:2* festival_id: "b2d506fd-409d-4ec7-b02f-c6d2295c7edd"
irb(main):007:2> })
NameError: uninitialized constant OrderPlaced
from (irb):3
from /Users/pawelpacana/.rubies/ruby-2.4.2/lib/ruby/gems/2.4.0/gems/railties-4.2.10/lib/rails/commands/console.rb:110:in `start'
from /Users/pawelpacana/.rubies/ruby-2.4.2/lib/ruby/gems/2.4.0/gems/railties-4.2.10/lib/rails/commands/console.rb:9:in `start'
from /Users/pawelpacana/.rubies/ruby-2.4.2/lib/ruby/gems/2.4.0/gems/railties-4.2.10/lib/rails/commands/commands_tasks.rb:68:in `console'
from /Users/pawelpacana/.rubies/ruby-2.4.2/lib/ruby/gems/2.4.0/gems/railties-4.2.10/lib/rails/commands/commands_tasks.rb:39:in `run_command!'
from /Users/pawelpacana/.rubies/ruby-2.4.2/lib/ruby/gems/2.4.0/gems/railties-4.2.10/lib/rails/commands.rb:17:in `<top (required)>'
from /Users/pawelpacana/Code/issue-331/bin/rails:9:in `<top (required)>'
from /Users/pawelpacana/.rubies/ruby-2.4.2/lib/ruby/site_ruby/2.4.0/rubygems/core_ext/kernel_require.rb:59:in `require'
from /Users/pawelpacana/.rubies/ruby-2.4.2/lib/ruby/site_ruby/2.4.0/rubygems/core_ext/kernel_require.rb:59:in `require'
from -e:1:in `<main>'
irb(main):008:0> OrderPlaced = Class.new(RailsEventStore::Event)
=> OrderPlaced
irb(main):009:0> event = OrderPlaced.new(data: {
irb(main):010:2* order_id: 1,
irb(main):011:2* order_data: "sample",
irb(main):012:2* festival_id: "b2d506fd-409d-4ec7-b02f-c6d2295c7edd"
irb(main):013:2> })
=> #<OrderPlaced:0x00007ff63ab551e8 @event_id="5980d171-f084-44c5-813c-d3e26959e76e", @metadata=#<RubyEventStore::Metadata:0x00007ff63ab54e00 @h={}>, @data={:order_id=>1, :order_data=>"sample", :festival_id=>"b2d506fd-409d-4ec7-b02f-c6d2295c7edd"}>
irb(main):014:0> event_store.publish_event(event, stream_name: stream_name)
(0.3ms) begin transaction
SQL (0.3ms) INSERT INTO "event_store_events" ("id", "data", "metadata", "event_type", "created_at") VALUES (?, ?, ?, ?, ?) [["id", "5980d171-f084-44c5-813c-d3e26959e76e"], ["data", "---\n:order_id: 1\n:order_data: sample\n:festival_id: b2d506fd-409d-4ec7-b02f-c6d2295c7edd\n"], ["metadata", "---\n:timestamp: 2018-05-03 16:07:10.167190000 Z\n"], ["event_type", "OrderPlaced"], ["created_at", "2018-05-03 16:07:10.178810"]]
(0.0ms) select sqlite_version(*)
(0.0ms) SAVEPOINT active_record_1
RailsEventStoreActiveRecord::EventInStream Create Many Without Validations Or Callbacks (0.2ms) INSERT INTO "event_store_events_in_streams" ("stream","position","event_id","created_at") VALUES ('order_1',NULL,'5980d171-f084-44c5-813c-d3e26959e76e','2018-05-03 16:07:10.182602'),('all',NULL,'5980d171-f084-44c5-813c-d3e26959e76e','2018-05-03 16:07:10.182602')
(0.0ms) RELEASE SAVEPOINT active_record_1
(0.7ms) commit transaction
=> :ok
irb(main):015:0>
C/issue-331 $ ruby -v %3 2 1m 5s 356ms
ruby 2.4.2p198 (2017-09-14 revision 59899) [x86_64-darwin17]
IanVaughan
DEVELOPMENT [2] pry(main)> OrderPlaced = Class.new(RailsEventStore::Event) => OrderPlaced
DEVELOPMENT [3] pry(main)> stream_name = "order_1" => "order_1"
DEVELOPMENT [4] pry(main)> event = OrderPlaced.new(data: { order_id: 1, order_data: "sample", festival_id: "b2d506fd-409d-4ec7-b02f-c6d2295c7edd" }) => #<OrderPlaced:0x00007fc707b99a80 @data={:order_id=>1, :order_data=>"sample", :festival_id=>"b2d506fd-409d-4ec7-b02f-c6d2295c7edd"}, @event_id="b802cf73-a3f4-4cb1-978a-eea68cf908ce", @metadata=#<RubyEventStore::Metadata:0x00007fc707b99580 @h={}>>
DEVELOPMENT [5] pry(main)> event_store.publish_event(event, stream_name: stream_name) (1.0ms) BEGIN SQL (4.4ms) INSERT INTO "event_store_events" ("id", "data", "metadata", "event_type", "created_at") VALUES ($1, $2, $3, $4, $5) RETURNING "id" [["id", "b802cf73-a3f4-4cb1-978a-eea68cf908ce"], ["data", "---\n:order_id: 1\n:order_data: sample\n:festival_id: b2d506fd-409d-4ec7-b02f-c6d2295c7edd\n"], ["metadata", "---\n:timestamp: 2018-05-03 15:40:04.155937000 Z\n"], ["event_type", "OrderPlaced"], ["created_at", "2018-05-03 15:40:04.295499"]] RailsEventStoreActiveRecord::EventInStream Create Many Without Validations Or Callbacks (4.7ms) INSERT INTO "event_store_events_in_streams" ("stream","position","event_id","created_at") VALUES ('order_1',NULL,'b802cf73-a3f4-4cb1-978a-eea68cf908ce','2018-05-03 15:40:04.336671'),('all',NULL,'b802cf73-a3f4-4cb1-978a-eea68cf908ce','2018-05-03 15:40:04.336671') RETURNING "id" (2.8ms) COMMIT NoMethodError: undefined method
[]' for nil:NilClass from /Users/ian/.asdf/installs/ruby/2.4.2/lib/ruby/gems/2.4.0/gems/ruby_event_store-0.28.0/lib/ruby_event_store/pub_sub/broker.rb:68:inall_subscribers_for'