Class: Hypertube::Core::Protocol::CommandDeserializer

Inherits:
Object
  • Object
show all
Defined in:
lib/hypertube-ruby-sdk/core/protocol/command_deserializer.rb

Instance Method Summary collapse

Constructor Details

#initialize(buffer) ⇒ CommandDeserializer

Returns a new instance of CommandDeserializer.



12
13
14
15
16
17
 
# File 'lib/hypertube-ruby-sdk/core/protocol/command_deserializer.rb', line 12

def initialize(buffer)
  @buffer = buffer
  @buffer_len = buffer.length
  @command = Hypertube::Utils::Command.new(buffer[0], buffer[10], [])
  @position = 11
end

Instance Method Details

#deserialize ⇒ Object 



23
24
25
26
27
28
 
# File 'lib/hypertube-ruby-sdk/core/protocol/command_deserializer.rb', line 23

def deserialize
  until is_at_end
    @command = @command.add_arg_to_payload(read_object(@buffer[@position]))
  end
  @command
end

#is_at_end ⇒ Object 



19
20
21
 
# File 'lib/hypertube-ruby-sdk/core/protocol/command_deserializer.rb', line 19

def is_at_end
  @position == @buffer_len
end

#read_bool ⇒ Object 



118
119
120
121
122
123
124
 
# File 'lib/hypertube-ruby-sdk/core/protocol/command_deserializer.rb', line 118

def read_bool
  size = 1
  @position += 2
  p = @position
  @position += size
  Hypertube::Core::Protocol::TypeDeserializer.deserialize_bool(@buffer[p...p + size])
end

#read_byte ⇒ Object 



134
135
136
137
138
139
140
 
# File 'lib/hypertube-ruby-sdk/core/protocol/command_deserializer.rb', line 134

def read_byte
  size = 1
  @position += 2
  p = @position
  @position += size
  Hypertube::Core::Protocol::TypeDeserializer.deserialize_byte(@buffer[p...p + size])
end

#read_char ⇒ Object 



142
143
144
145
146
147
148
 
# File 'lib/hypertube-ruby-sdk/core/protocol/command_deserializer.rb', line 142

def read_char
  size = 1
  @position += 2
  p = @position
  @position += size
  Hypertube::Core::Protocol::TypeDeserializer.deserialize_char(@buffer[p...p + size])
end

#read_command ⇒ Object 



63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
 
# File 'lib/hypertube-ruby-sdk/core/protocol/command_deserializer.rb', line 63

def read_command
  p = @position
  number_of_elements_in_payload = Hypertube::Core::Protocol::TypeDeserializer.deserialize_int(@buffer[p + 1..p + 4])
  runtime = @buffer[p + 5]
  command_type = @buffer[p + 6]
  @position += 7

  payload = []
  i = 0
  while i < number_of_elements_in_payload
    payload << read_object(@buffer[@position])
    i += 1
  end
  Hypertube::Utils::Command.new(runtime, command_type, payload)
end

#read_double ⇒ Object 



158
159
160
161
162
163
164
 
# File 'lib/hypertube-ruby-sdk/core/protocol/command_deserializer.rb', line 158

def read_double
  size = 8
  @position += 2
  p = @position
  @position += size
  Hypertube::Core::Protocol::TypeDeserializer.deserialize_double(@buffer[p...p + size])
end

#read_float ⇒ Object 



126
127
128
129
130
131
132
 
# File 'lib/hypertube-ruby-sdk/core/protocol/command_deserializer.rb', line 126

def read_float
  size = 4
  @position += 2
  p = @position
  @position += size
  Hypertube::Core::Protocol::TypeDeserializer.deserialize_float(@buffer[p...p + size])
end

#read_int ⇒ Object 



110
111
112
113
114
115
116
 
# File 'lib/hypertube-ruby-sdk/core/protocol/command_deserializer.rb', line 110

def read_int
  size = 4
  @position += 2
  p = @position
  @position += size
  Hypertube::Core::Protocol::TypeDeserializer.deserialize_int(@buffer[p...p + size])
end

#read_longlong ⇒ Object 



150
151
152
153
154
155
156
 
# File 'lib/hypertube-ruby-sdk/core/protocol/command_deserializer.rb', line 150

def read_longlong
  size = 8
  @position += 2
  p = @position
  @position += size
  Hypertube::Core::Protocol::TypeDeserializer.deserialize_longlong(@buffer[p...p + size])
end

#read_nil ⇒ Object 



182
183
184
185
186
187
188
 
# File 'lib/hypertube-ruby-sdk/core/protocol/command_deserializer.rb', line 182

def read_nil
  size = 1
  @position += 2
  p = @position
  @position += size
  Hypertube::Core::Protocol::TypeDeserializer.deserialize_nil(@buffer[p...p + size])
end

#read_object(type_num) ⇒ Object 



30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
 
# File 'lib/hypertube-ruby-sdk/core/protocol/command_deserializer.rb', line 30

def read_object(type_num)
  case type_num
  when Hypertube::Utils::Type::COMMAND
    return self.read_command
  when Hypertube::Utils::Type::HT__STRING
    return self.read_string
  when Hypertube::Utils::Type::HT__INTEGER
    return self.read_int
  when Hypertube::Utils::Type::HT__BOOLEAN
    return self.read_bool
  when Hypertube::Utils::Type::HT__FLOAT
    return self.read_float
  when Hypertube::Utils::Type::HT__BYTE
    return self.read_byte
  when Hypertube::Utils::Type::HT__CHAR
    return self.read_char
  when Hypertube::Utils::Type::HT__LONG_LONG
    return self.read_longlong
  when Hypertube::Utils::Type::HT__DOUBLE
    return self.read_double
  when Hypertube::Utils::Type::HT__UNSIGNED_LONG_LONG
    return self.read_ullong
  when Hypertube::Utils::Type::HT__UNSIGNED_INTEGER
    return self.read_uint
  when Hypertube::Utils::Type::HT__NULL
    return self.read_nil
  when Hypertube::Utils::Type::HT__UNDEFINED
    return self.read_undefined
  else
    raise Exception.new("Hypertube::Utils::Type #{type_num} not supported in command deserializer")
  end
end

#read_string ⇒ Object

old implementation

def read_command
  p = @position
  number_of_elements_in_payload = Hypertube::Core::Protocol::TypeDeserializer.deserialize_int(@buffer[p + 1..p + 4])
  runtime = @buffer[p + 5]
  command_type = @buffer[p + 6]
  @position += 7
  return_command = Hypertube::Utils::Command.new(runtime, command_type, [])
  read_command_recursively(number_of_elements_in_payload, return_command)
end

def read_command_recursively(number_of_elements_in_payload_left, cmd)
  if number_of_elements_in_payload_left == 0
    cmd
  else
    p = @position
    cmd = cmd.add_arg_to_payload(self.read_object(@buffer[p]))
    read_command_recursively(number_of_elements_in_payload_left - 1, cmd)
  end
end



100
101
102
103
104
105
106
107
108
 
# File 'lib/hypertube-ruby-sdk/core/protocol/command_deserializer.rb', line 100

def read_string
  p = @position
  string_encoding_mode = @buffer[p + 1]
  size = Hypertube::Core::Protocol::TypeDeserializer.deserialize_int(@buffer[p + 2..p + 5])
  @position += 6
  p = @position
  @position += size
  Hypertube::Core::Protocol::TypeDeserializer.deserialize_string(string_encoding_mode, @buffer[p...p + size])
end

#read_uint ⇒ Object 



174
175
176
177
178
179
180
 
# File 'lib/hypertube-ruby-sdk/core/protocol/command_deserializer.rb', line 174

def read_uint
  size = 4
  @position += 2
  p = @position
  @position += size
  Hypertube::Core::Protocol::TypeDeserializer.deserialize_uint(@buffer[p...p + size])
end

#read_ullong ⇒ Object 



166
167
168
169
170
171
172
 
# File 'lib/hypertube-ruby-sdk/core/protocol/command_deserializer.rb', line 166

def read_ullong
  size = 8
  @position += 2
  p = @position
  @position += size
  Hypertube::Core::Protocol::TypeDeserializer.deserialize_ullong(@buffer[p...p + size])
end

#read_undefined ⇒ Object 



190
191
192
193
194
195
196
 
# File 'lib/hypertube-ruby-sdk/core/protocol/command_deserializer.rb', line 190

def read_undefined
  size = 1
  @position += 2
  p = @position
  @position += size
  Hypertube::Core::Protocol::TypeDeserializer.deserialize_undefined(@buffer[p...p + size])
end