Class: RSMP::Message

Inherits:
Object
  • Object
show all
Defined in:
lib/rsmp/message.rb

Overview

Base RSMP message class used to represent parsed and built messages.

Instance Attribute Summary collapse

Class Method Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(attributes = {}) ⇒ Message

Returns a new instance of Message.



150
151
152
153
154
155
156
157
 
# File 'lib/rsmp/message.rb', line 150

def initialize(attributes = {})
  @timestamp = Time.now # this timestamp is for internal use, and does not use the clock
  # in the node, which can be set by an rsmp supervisor

  @attributes = { 'mType' => 'rSMsg' }.merge attributes

  ensure_message_id
end

Instance Attribute Details

#attributes ⇒ Object (readonly)

this is an internal timestamp recording when we receive/send



5
6
7
 
# File 'lib/rsmp/message.rb', line 5

def attributes
  @attributes
end

#direction ⇒ Object

Returns the value of attribute direction.



6
7
8
 
# File 'lib/rsmp/message.rb', line 6

def direction
  @direction
end

#json ⇒ Object

Returns the value of attribute json.



6
7
8
 
# File 'lib/rsmp/message.rb', line 6

def json
  @json
end

#now ⇒ Object (readonly)

this is an internal timestamp recording when we receive/send



5
6
7
 
# File 'lib/rsmp/message.rb', line 5

def now
  @now
end

#out ⇒ Object (readonly)

this is an internal timestamp recording when we receive/send



5
6
7
 
# File 'lib/rsmp/message.rb', line 5

def out
  @out
end

#timestamp ⇒ Object (readonly)

this is an internal timestamp recording when we receive/send



5
6
7
 
# File 'lib/rsmp/message.rb', line 5

def timestamp
  @timestamp
end

Class Method Details

.bin_to_chars(str) ⇒ Object 



115
116
117
118
119
120
121
122
123
124
125
 
# File 'lib/rsmp/message.rb', line 115

def self.bin_to_chars(str)
  out = str.gsub(/[^[:print:]]/i, '.')
  max = 120
  if out.size <= max
    out
  else
    mid = ' ... '
    length = ((max - mid.size) / 2) - 1
    "#{out[0..length]} ... #{out[(-length - 1)..]}"
  end
end

.build(attributes, json) ⇒ Object 



20
21
22
23
24
25
26
 
# File 'lib/rsmp/message.rb', line 20

def self.build(attributes, json)
  validate_message_type attributes
  message = create_message_instance(attributes)
  message.json = json
  message.direction = :in
  message
end

.build_alarm(attributes) ⇒ Object 



55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
 
# File 'lib/rsmp/message.rb', line 55

def self.build_alarm(attributes)
  case attributes['aSp']
  when /^Issue$/i
    AlarmIssue.new attributes
  when /^Request$/i
    AlarmRequest.new attributes
  when /^Acknowledge$/i
    if attributes['ack'] =~ /^acknowledged$/i
      AlarmAcknowledged.new attributes
    else
      AlarmAcknowledge.new attributes
    end
  when /^Suspend$/i
    if attributes['sS'] =~ /^suspended$/i
      AlarmSuspended.new attributes
    elsif attributes['sS'] =~ /^notSuspended$/i
      AlarmResumed.new attributes
    else
      AlarmSuspend.new attributes
    end
  when /^Resume$/i
    AlarmResume.new attributes
  else
    Alarm.new attributes
  end
end

.create_message_instance(attributes) ⇒ Object 



47
48
49
50
51
52
53
 
# File 'lib/rsmp/message.rb', line 47

def self.create_message_instance(attributes)
  type = attributes['type']
  return build_alarm(attributes) if type == 'Alarm'

  klass = message_types[type] || Unknown
  klass.new(attributes)
end

.make_m_id ⇒ Object 



8
9
10
 
# File 'lib/rsmp/message.rb', line 8

def self.make_m_id
  SecureRandom.uuid
end

.message_types ⇒ Object 



28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
 
# File 'lib/rsmp/message.rb', line 28

def self.message_types
  {
    'MessageAck' => MessageAck,
    'MessageNotAck' => MessageNotAck,
    'Version' => Version,
    'ComponentList' => ComponentList,
    'AggregatedStatus' => AggregatedStatus,
    'AggregatedStatusRequest' => AggregatedStatusRequest,
    'Watchdog' => Watchdog,
    'CommandRequest' => CommandRequest,
    'CommandResponse' => CommandResponse,
    'StatusRequest' => StatusRequest,
    'StatusResponse' => StatusResponse,
    'StatusSubscribe' => StatusSubscribe,
    'StatusUnsubscribe' => StatusUnsubscribe,
    'StatusUpdate' => StatusUpdate
  }
end

.parse_attributes(json) ⇒ Object 



12
13
14
15
16
17
18
 
# File 'lib/rsmp/message.rb', line 12

def self.parse_attributes(json)
  raise ArgumentError unless json

  JSON.parse json
rescue JSON::ParserError
  raise InvalidPacket, bin_to_chars(json)
end

.shorten_m_id(m_id, length = 4) ⇒ Object 



94
95
96
97
98
 
# File 'lib/rsmp/message.rb', line 94

def self.shorten_m_id(m_id, length = 4)
  return nil unless m_id

  m_id[0..(length - 1)]
end

.validate_attributes_structure(attributes) ⇒ Object

Raises:



133
134
135
 
# File 'lib/rsmp/message.rb', line 133

def self.validate_attributes_structure(attributes)
  raise MalformedMessage, "JSON must be a Hash, got #{attributes.class} " unless attributes.is_a?(Hash)
end

.validate_message_type(attributes) ⇒ Object 



127
128
129
130
131
 
# File 'lib/rsmp/message.rb', line 127

def self.validate_message_type(attributes)
  validate_attributes_structure(attributes)
  validate_mtype_field(attributes)
  validate_type_field(attributes)
end

.validate_mtype_field(attributes) ⇒ Object

Raises:



137
138
139
140
141
142
 
# File 'lib/rsmp/message.rb', line 137

def self.validate_mtype_field(attributes)
  mtype = attributes['mType']
  raise MalformedMessage, "'mType' is missing" unless mtype
  raise MalformedMessage, "'mType' must be a String, got #{mtype.class}" unless mtype.is_a?(String)
  raise MalformedMessage, "'mType' must be 'rSMsg', got '#{mtype}'" unless mtype == 'rSMsg'
end

.validate_type_field(attributes) ⇒ Object

Raises:



144
145
146
147
148
 
# File 'lib/rsmp/message.rb', line 144

def self.validate_type_field(attributes)
  type = attributes['type']
  raise MalformedMessage, "'type' is missing" unless type
  raise MalformedMessage, "'type' must be a String, got #{type.class}" unless type.is_a?(String)
end

Instance Method Details

#attribute(key) ⇒ Object 



104
105
106
107
108
109
110
111
112
113
 
# File 'lib/rsmp/message.rb', line 104

def attribute(key)
  unless @attributes.key? key # NOTE: that this is not the same as @attributes[key] when
    maybe = @attributes.find { |k, _v| k.downcase == key.downcase }
    raise MissingAttribute, "attribute '#{maybe.first}' should be named '#{key}'" if maybe

    raise MissingAttribute, "missing attribute '#{key}'"

  end
  @attributes[key]
end

#ensure_message_id ⇒ Object 



159
160
161
162
 
# File 'lib/rsmp/message.rb', line 159

def ensure_message_id
  # if message id is empty, generate a new one
  @attributes['mId'] ||= Message.make_m_id
end

#generate_json ⇒ Object 



186
187
188
189
190
191
192
193
194
195
 
# File 'lib/rsmp/message.rb', line 186

def generate_json
  # ensure compact format on all platforms
  options = {
    array_nl: nil,
    object_nl: nil,
    space_before: nil,
    space: nil
  }
  @json = JSON.generate @attributes, options
end

#inspect ⇒ Object 



82
83
84
 
# File 'lib/rsmp/message.rb', line 82

def inspect
  "#<#{self.class.name}:#{object_id} m_id: #{m_id_short}>"
end

#m_id ⇒ Object 



90
91
92
 
# File 'lib/rsmp/message.rb', line 90

def m_id
  @attributes['mId']
end

#m_id_short ⇒ Object 



100
101
102
 
# File 'lib/rsmp/message.rb', line 100

def m_id_short
  Message.shorten_m_id @attributes['mId']
end

#type ⇒ Object 



86
87
88
 
# File 'lib/rsmp/message.rb', line 86

def type
  @attributes['type']
end

#valid? ⇒ Boolean

Returns:

  • (Boolean) 


182
183
184
 
# File 'lib/rsmp/message.rb', line 182

def valid?
  true
end

#validate(schemas) ⇒ Object 



164
165
166
167
168
169
170
171
172
 
# File 'lib/rsmp/message.rb', line 164

def validate(schemas)
  errors = RSMP::Schema.validate attributes, schemas
  return unless errors

  error_string = errors.map { |item| item.reject { |e| e == '' } }.compact.join(', ').strip
  err = SchemaError.new error_string.to_s
  err.schemas = schemas
  raise err
end

#validate_id? ⇒ Boolean

Returns:

  • (Boolean) 


178
179
180
 
# File 'lib/rsmp/message.rb', line 178

def validate_id?
  !(@attributes['mId'] =~ /[a-f0-9]{8}-[a-f0-9]{4}-4[a-f0-9]{3}-[89ab][a-f0-9]{3}-[a-f0-9]{12}/i).nil?
end

#validate_type? ⇒ Boolean

Returns:

  • (Boolean) 


174
175
176
 
# File 'lib/rsmp/message.rb', line 174

def validate_type?
  @attributes['mType'] == 'rSMsg'
end