Class: EventStoreClient::Client

Inherits:
Object
  • Object
show all
Includes:
Configuration
Defined in:
lib/event_store_client/client.rb

Constant Summary collapse

NoCallMethodOnSubscriber = 
Class.new(StandardError)
WrongExpectedEventVersion = 
Class.new(StandardError)

Instance Attribute Summary collapse

Instance Method Summary collapse

Methods included from Configuration

#config

Instance Attribute Details

#connection ⇒ Object

rubocop:enable Metrics/CyclomaticComplexity



57
58
59
 
# File 'lib/event_store_client/client.rb', line 57

def connection
  @connection
end

Instance Method Details

rubocop:disable Metrics/CyclomaticComplexity

Raises:

  • (ArgumentError) 


47
48
49
50
51
52
53
54
 
# File 'lib/event_store_client/client.rb', line 47

def link_to(stream:, events:, options: {})
  raise ArgumentError if !stream || stream == ''
  raise ArgumentError if events.nil? || (events.is_a?(Array) && events.empty?)
  res = connection.link_to(stream, events, options: options)
  raise WrongExpectedEventVersion.new(e.message) if res.failure?

  res.success?
end

#listen(wait: false) ⇒ Object 



42
43
44
 
# File 'lib/event_store_client/client.rb', line 42

def listen(wait: false)
  broker.call(@subscriptions, wait: wait)
end

#publish(stream:, events:, options: {}) ⇒ Object

Raises:



12
13
14
15
 
# File 'lib/event_store_client/client.rb', line 12

def publish(stream:, events:, options: {})
  res = connection.append_to_stream(stream, events, options: options)
  raise WrongExpectedEventVersion.new(e.message) if res.failure?
end

#read(stream, options: {}) ⇒ Object 



17
18
19
20
21
22
23
 
# File 'lib/event_store_client/client.rb', line 17

def read(stream, options: {})
  if options[:all]
    connection.read_all_from_stream(stream, options: options)
  else
    connection.read(stream, options: options)
  end
end

#reset_subscriptions ⇒ Object 



36
37
38
39
40
 
# File 'lib/event_store_client/client.rb', line 36

def reset_subscriptions
  return unless @subscriptions.respond_to?(:reset)

  @subscriptions.reset
end

#subscribe(subscriber, to: [], options: {}) ⇒ Object

Raises:



25
26
27
28
 
# File 'lib/event_store_client/client.rb', line 25

def subscribe(subscriber, to: [], options: {})
  raise NoCallMethodOnSubscriber unless subscriber.respond_to?(:call)
  @subscriptions.create(subscriber, to, options: options)
end

#subscribe_to_all(subscriber, filter = nil) ⇒ Object

Raises:



30
31
32
33
34
 
# File 'lib/event_store_client/client.rb', line 30

def subscribe_to_all(subscriber, filter=nil)
  raise NoCallMethodOnSubscriber unless subscriber.respond_to?(:call)

  @subscriptions.create_or_load(subscriber, filter: filter)
end