Module: MessageStore::EventStore::StreamName

Defined in:
lib/message_store/event_store/stream_name.rb,
lib/message_store/event_store/stream_name/pattern.rb

Defined Under Namespace

Modules: Pattern

Class Method Summary collapse

Class Method Details

.category?(stream_name) ⇒ Boolean

Returns:

  • (Boolean) 


23
24
25
26
 
# File 'lib/message_store/event_store/stream_name.rb', line 23

def self.category?(stream_name)
  match_data = parse(stream_name)
  match_data[:stream_id].nil?
end

.get_category(stream_name) ⇒ Object 



18
19
20
21
 
# File 'lib/message_store/event_store/stream_name.rb', line 18

def self.get_category(stream_name)
  match_data = parse(stream_name)
  match_data[:category]
end

.get_entity_name(stream_name) ⇒ Object 



41
42
43
44
 
# File 'lib/message_store/event_store/stream_name.rb', line 41

def self.get_entity_name(stream_name)
  match_data = parse(stream_name)
  match_data[:entity]
end

.get_id(stream_name) ⇒ Object 



13
14
15
16
 
# File 'lib/message_store/event_store/stream_name.rb', line 13

def self.get_id(stream_name)
  match_data = parse(stream_name)
  match_data[:stream_id]
end

.get_type_list(stream_name) ⇒ Object 



28
29
30
31
 
# File 'lib/message_store/event_store/stream_name.rb', line 28

def self.get_type_list(stream_name)
  match_data = parse(stream_name)
  match_data[:type_list]
end

.get_types(stream_name) ⇒ Object 



33
34
35
36
37
38
39
 
# File 'lib/message_store/event_store/stream_name.rb', line 33

def self.get_types(stream_name)
  type_list = get_type_list(stream_name)

  return [] if type_list.nil?

  type_list.split('+')
end

.parse(stream_name) ⇒ Object 



46
47
48
49
50
 
# File 'lib/message_store/event_store/stream_name.rb', line 46

def self.parse(stream_name)
  pattern = Pattern.get

  pattern.match(stream_name)
end

.stream_name(category_name, id = nil, type: nil, types: nil) ⇒ Object 



4
5
6
7
8
9
10
11
 
# File 'lib/message_store/event_store/stream_name.rb', line 4

def self.stream_name(category_name, id=nil, type: nil, types: nil)
  MessageStore::StreamName.stream_name(
    category_name,
    id,
    type: type,
    types: types
  )
end