Class: ORiN3BinaryConverter

Inherits:

Object

• Object
• ORiN3BinaryConverter

Defined in:

lib/grpc/orin3/provider/orin3_binary_converter.rb

Defined Under Namespace

Modules: DataType

Constant Summary

UINT8_MIN =

0

UINT8_MAX =

255

UINT16_MIN =

0

UINT16_MAX =

65535

UINT32_MIN =

0

UINT32_MAX =

4_294_967_295

UINT64_MIN =

0

UINT64_MAX =

18_446_744_073_709_551_615

INT8_MIN =

-128

INT8_MAX =

127

INT16_MIN =

-32768

INT16_MAX =

32767

INT32_MIN =

-2_147_483_648

INT32_MAX =

2_147_483_647

INT64_MIN =

-9_223_372_036_854_775_808

INT64_MAX =

9_223_372_036_854_775_807

FLOAT_MIN =

-3.40282347E+38

FLOAT_MAX =

3.40282347E+38

DOUBLE_MIN =

-1.7976931348623157e+308

DOUBLE_MAX =

1.7976931348623157e+308

Class Method Summary

• .deserialize(binary_data) ⇒ Object
• .from_dictionary_to_binary(data) ⇒ Object
• .serialize(data, type = nil) ⇒ Object

Class Method Details

.deserialize(binary_data) ⇒ Object

# File 'lib/grpc/orin3/provider/orin3_binary_converter.rb', line 124

def self.deserialize(binary_data)
  type_indicator = binary_data[0].ord

  case type_indicator
  when ORiN3BinaryConverter::DataType::Nil
    return nil
  when ORiN3BinaryConverter::DataType::Bool
    return binary_data[1].ord == 1
  when ORiN3BinaryConverter::DataType::UInt8
    return binary_data[1].unpack('C').first
  when ORiN3BinaryConverter::DataType::Int8
    return binary_data[1].unpack('c').first
  when ORiN3BinaryConverter::DataType::UInt16
    return binary_data[1..2].unpack('S').first
  when ORiN3BinaryConverter::DataType::Int16
    return binary_data[1..2].unpack('s').first
  when ORiN3BinaryConverter::DataType::UInt32
    return binary_data[1..4].unpack('L').first
  when ORiN3BinaryConverter::DataType::Int32
    return binary_data[1..4].unpack('l').first
  when ORiN3BinaryConverter::DataType::UInt64
    return binary_data[1..8].unpack('Q').first
  when ORiN3BinaryConverter::DataType::Int64
    return binary_data[1..8].unpack('q').first
  when ORiN3BinaryConverter::DataType::Float
    return binary_data[1..4].unpack('e').first
  when ORiN3BinaryConverter::DataType::Double
    return binary_data[1..8].unpack('E').first
  when ORiN3BinaryConverter::DataType::String
    length = binary_data[1..4].unpack('L').first
    string_data = binary_data[5, length].force_encoding('UTF-8')
    return string_data
  when ORiN3BinaryConverter::DataType::DateTime
    timestamp = binary_data[1..8].unpack('q<').first
    return Grpc::ORiN3::Provider::DateTimeConverter::from_int64(timestamp)
  when ORiN3BinaryConverter::DataType::BoolArray
    length = binary_data[1..4].unpack('L').first
    result = Array.new(length, nil)
    length.times do |i|
      result[i] = binary_data[5 + i].ord == 1
    end
    return result
  when ORiN3BinaryConverter::DataType::UInt8Array
    length = binary_data[1..4].unpack('L').first
    result = Array.new(length, nil)
    length.times do |i|
      result[i] = binary_data[5 + i].unpack('C').first
    end
    return result
  when ORiN3BinaryConverter::DataType::Int8Array
    length = binary_data[1..4].unpack('L').first
    result = Array.new(length, nil)
    length.times do |i|
      result[i] = binary_data[5 + i].unpack('c').first
    end
    return result
  when ORiN3BinaryConverter::DataType::UInt16Array
    length = binary_data[1..4].unpack('L').first
    result = Array.new(length, nil)
    length.times do |i|
      result[i] = binary_data[5 + i * 2, 2].unpack('S<').first
    end
    return result
  when ORiN3BinaryConverter::DataType::Int16Array
    length = binary_data[1..4].unpack('L').first
    result = Array.new(length, nil)
    length.times do |i|
      result[i] = binary_data[5 + i * 2, 2].unpack('s<').first
    end
    return result
  when ORiN3BinaryConverter::DataType::UInt32Array
    length = binary_data[1..4].unpack('L').first
    result = Array.new(length, nil)
    length.times do |i|
      result[i] = binary_data[5 + i * 4, 4].unpack('L<').first
    end
    return result
  when ORiN3BinaryConverter::DataType::Int32Array
    length = binary_data[1..4].unpack('L').first
    result = Array.new(length, nil)
    length.times do |i|
      result[i] = binary_data[5 + i * 4, 4].unpack('l<').first
    end
    return result
  when ORiN3BinaryConverter::DataType::UInt64Array
    length = binary_data[1..4].unpack('L').first
    result = Array.new(length, nil)
    length.times do |i|
      result[i] = binary_data[5 + i * 8, 8].unpack('Q<').first
    end
    return result
  when ORiN3BinaryConverter::DataType::Int64Array
    length = binary_data[1..4].unpack('L').first
    result = Array.new(length, nil)
    length.times do |i|
      result[i] = binary_data[5 + i * 8, 8].unpack('q<').first
    end
    return result
  when ORiN3BinaryConverter::DataType::FloatArray
    length = binary_data[1..4].unpack('L').first
    result = Array.new(length, nil)
    length.times do |i|
      result[i] = binary_data[5 + i * 4, 4].unpack('e').first
    end
    return result
  when ORiN3BinaryConverter::DataType::DoubleArray
    length = binary_data[1..4].unpack('L').first
    result = Array.new(length, nil)
    length.times do |i|
      result[i] = binary_data[5 + i * 8, 8].unpack('E').first
    end
    return result
  when ORiN3BinaryConverter::DataType::StringArray
    length = binary_data[1..4].unpack('L').first
    result = Array.new(length, nil)
    index = 5
    length.times do |i|
      if binary_data[index]
        string_length = binary_data[index + 1, 4].unpack('L').first
        result[i] = binary_data[index + 5, string_length].force_encoding('UTF-8')
        index += string_length + 5
      else
        result[i] = nil
        index += 5
      end
    end
    return result
  when ORiN3BinaryConverter::DataType::DateTimeArray
    length = binary_data[1..4].unpack('L').first
    result = Array.new(length, nil)
    length.times do |i|
      timestamp = binary_data[5 + i * 8, 8].unpack('q<').first
      result[i] = Grpc::ORiN3::Provider::DateTimeConverter::from_int64(timestamp)
    end
    return result
  when ORiN3BinaryConverter::DataType::NullableBoolArray
    length = binary_data[1..4].unpack('L').first
    result = Array.new(length, nil)
    length.times do |i|
      index = 5 + i
      if (binary_data[index].ord == 2)
        result[i] = nil
      else
        result[i] = binary_data[index].ord == 1
      end
    end
    return result
  when ORiN3BinaryConverter::DataType::NullableUInt8Array
    length = binary_data[1..4].unpack('L').first
    result = Array.new(length, nil)
    length.times do |i|
      index = 5 + (i * 2)
      if (binary_data[index].ord == 1)
        result[i] = binary_data[index + 1].unpack('C').first
      end
    end
    return result
  when ORiN3BinaryConverter::DataType::NullableInt8Array
    length = binary_data[1..4].unpack('L<').first
    result = Array.new(length, nil)
    length.times do |i|
      index = 5 + (i * 2)
      if binary_data[index].ord == 1
        result[i] = binary_data[index + 1].unpack('c').first
      end
    end
    return result
  when ORiN3BinaryConverter::DataType::NullableUInt16Array
    length = binary_data[1..4].unpack('L<').first
    result = Array.new(length, nil)
    length.times do |i|
      index = 5 + (i * 3)
      if binary_data[index].ord == 1
        result[i] = binary_data[index + 1, 2].unpack('S<').first
      end
    end
    return result
  when ORiN3BinaryConverter::DataType::NullableInt16Array
    length = binary_data[1..4].unpack('L<').first
    result = Array.new(length, nil)
    length.times do |i|
      index = 5 + (i * 3)
      if binary_data[index].ord == 1
        result[i] = binary_data[index + 1, 2].unpack('s<').first
      end
    end
    return result
  when ORiN3BinaryConverter::DataType::NullableUInt32Array
    length = binary_data[1..4].unpack('L<').first
    result = Array.new(length, nil)
    length.times do |i|
      index = 5 + (i * 5)
      if binary_data[index].ord == 1
        result[i] = binary_data[index + 1, 4].unpack('L<').first
      end
    end
    return result
  when ORiN3BinaryConverter::DataType::NullableInt32Array
    length = binary_data[1..4].unpack('L<').first
    result = Array.new(length, nil)
    length.times do |i|
      index = 5 + (i * 5)
      if binary_data[index].ord == 1
        result[i] = binary_data[index + 1, 4].unpack('l<').first
      end
    end
    return result
  when ORiN3BinaryConverter::DataType::NullableUInt64Array
    length = binary_data[1..4].unpack('L<').first
    result = Array.new(length, nil)
    length.times do |i|
      index = 5 + (i * 9)
      if binary_data[index].ord == 1
        result[i] = binary_data[index + 1, 8].unpack('Q<').first
      end
    end
    return result
  when ORiN3BinaryConverter::DataType::NullableInt64Array
    length = binary_data[1..4].unpack('L<').first
    result = Array.new(length, nil)
    length.times do |i|
      index = 5 + (i * 9)
      if binary_data[index].ord == 1
        result[i] = binary_data[index + 1, 8].unpack('q<').first
      end
    end
    return result
  when ORiN3BinaryConverter::DataType::NullableFloatArray
    length = binary_data[1..4].unpack('L<').first
    result = Array.new(length, nil)
    length.times do |i|
      index = 5 + (i * 5)
      if binary_data[index].ord == 1
        result[i] = binary_data[index + 1, 4].unpack('e').first
      end
    end
    return result
  when ORiN3BinaryConverter::DataType::NullableDoubleArray
    length = binary_data[1..4].unpack('L<').first
    result = Array.new(length, nil)
    length.times do |i|
      index = 5 + (i * 9)
      if binary_data[index].ord == 1
        result[i] = binary_data[index + 1, 8].unpack('E').first
      end
    end
    return result
  when ORiN3BinaryConverter::DataType::NullableDateTimeArray
    length = binary_data[1..4].unpack('L').first
    result = Array.new(length, nil)
    length.times do |i|
      index = 5 + (i * 9)
      if binary_data[index].ord == 1
        timestamp = binary_data[index + 1, 8].unpack('q<').first
        result[i] = Grpc::ORiN3::Provider::DateTimeConverter::from_int64(timestamp)
      end
    end
    return result
  else
    raise ArgumentError, "Unsupported data type: #{type_indicator}. Binary data: #{binary_data.inspect}"
  end
end

.from_dictionary_to_binary(data) ⇒ Object

# File 'lib/grpc/orin3/provider/orin3_binary_converter.rb', line 387

def self.from_dictionary_to_binary(data)
  length_data = data.map do |key, value|
    5 + key.bytes.length + value.length
  end
  length = length_data.sum
  byte_array = Array.new(length + 4, 0)
  byte_array[0..3] = [data.keys.length].pack('l<').bytes
  index = 4
  data.each do |key, value|
    string_bytes = key.bytes
    byte_array[index] = ORiN3BinaryConverter::DataType::String
    byte_array[(index + 1)..(index + 4)] = [string_bytes.length].pack('L').bytes
    
    # キーのバイト配列を追加
    byte_array[(index + 5)..(index + 5 + string_bytes.length - 1)] = string_bytes
    
    index += 5 + string_bytes.length
    # 値がバイナリデータの場合、バイト配列として追加する
    if value.is_a?(String)
      byte_array[index..(index + value.bytes.length - 1)] = value.bytes
      index += value.bytes.length
    else
      raise ArgumentError, "Value is not a valid binary string."
    end
  end
  return byte_array.pack('C*')
end

.serialize(data, type = nil) ⇒ Object

# File 'lib/grpc/orin3/provider/orin3_binary_converter.rb', line 83

def self.serialize(data, type = nil)
  if (!type.nil?)
    return self.serialize_core(data, type)
  else
    case data
    when nil
      return self.serialize_core(data, ORiN3BinaryConverter::DataType::Nil)
    when Integer
      return self.serialize_core(data, ORiN3BinaryConverter::DataType::Int64)
    when TrueClass, FalseClass
      return self.serialize_core(data, ORiN3BinaryConverter::DataType::Bool)
    when String
      return self.serialize_core(data, ORiN3BinaryConverter::DataType::String)
    when Time
      return self.serialize_core(data, ORiN3BinaryConverter::DataType::DateTime)
    when Array
      if data.all? { |item| item.is_a?(TrueClass) || item.is_a?(FalseClass) }
        return self.serialize_core(data, ORiN3BinaryConverter::DataType::BoolArray)
      elsif data.all? { |item| item.nil? || item.is_a?(TrueClass) || item.is_a?(FalseClass) }
        return self.serialize_core(data, ORiN3BinaryConverter::DataType::NullableBoolArray)
      elsif data.all? { |item| item.is_a?(Integer) }
        return self.serialize_core(data, ORiN3BinaryConverter::DataType::Int64Array)
      elsif data.all? { |item| item.nil? || item.is_a?(Integer) }
        return self.serialize_core(data, ORiN3BinaryConverter::DataType::NullableInt64Array)
      elsif data.all? { |item| item.nil? || item.is_a?(String) }
        return self.serialize_core(data, ORiN3BinaryConverter::DataType::StringArray)
      elsif data.all? { |item| item.is_a?(DateTime) }
        return self.serialize_core(data, ORiN3BinaryConverter::DataType::DateTimeArray)
      elsif data.all? { |item| item.nil? || item.is_a?(DateTime) }
        return self.serialize_core(data, ORiN3BinaryConverter::DataType::NullableDateTimeArray)
      else
        raise ArgumentError, "Unsupported data type"
      end
    when Hash
      return self.serialize_core(data, ORiN3BinaryConverter::DataType::Dictionary)
    else
      raise ArgumentError, "Unsupported data type"
    end
  end
end