2025-06-27 17:55:19 +02:00
|
|
|
extends Node
|
|
|
|
|
|
|
|
class_name VRPN
|
2025-06-27 22:09:32 +02:00
|
|
|
|
2025-06-27 17:55:19 +02:00
|
|
|
static func marshal(data : PackedByteArray):
|
|
|
|
|
2025-06-27 22:09:32 +02:00
|
|
|
# need to fix that
|
2025-06-27 17:55:19 +02:00
|
|
|
var block_offset : int = 0
|
|
|
|
var header_size = aligned_size(20) # kinda redundant as we take the seq number as well
|
|
|
|
|
2025-06-27 22:09:32 +02:00
|
|
|
# reader for stream
|
|
|
|
var header := StreamPeerBuffer.new()
|
|
|
|
# get block addresses
|
|
|
|
header.data_array = data.slice(block_offset,block_offset+header_size)
|
|
|
|
# make sure we read as big endian
|
|
|
|
header.big_endian = true
|
2025-06-27 17:55:19 +02:00
|
|
|
|
2025-06-27 22:09:32 +02:00
|
|
|
# read header
|
|
|
|
var length := header.get_32() as int # length of message
|
|
|
|
var time_sec := header.get_32() as int # time sec
|
|
|
|
var time_msec := header.get_32() as int # time micro sec
|
|
|
|
var sender_id := header.get_32() as int # sender id
|
|
|
|
var message_type := header.get_32() as int # type of message (payload)
|
|
|
|
var sequence_num := header.get_32() as int # inofficial sequence number (padding)
|
|
|
|
|
|
|
|
if false:
|
|
|
|
print("length '%d'" % length)
|
|
|
|
print("time_sec '%d'" % time_sec)
|
|
|
|
print("time_msec '%d'" % time_msec)
|
|
|
|
print("sender_id '%d'" % sender_id)
|
|
|
|
print("message_type '%d'" % message_type)
|
|
|
|
print("sequence_num '%d'" % sequence_num)
|
|
|
|
|
|
|
|
# print out
|
|
|
|
print("block_offset:{0} header_size:{1} length:{2}".format([block_offset,header_size,length]))
|
|
|
|
|
|
|
|
# sender description
|
|
|
|
match message_type:
|
|
|
|
-1:
|
2025-06-27 17:55:19 +02:00
|
|
|
var body := StreamPeerBuffer.new()
|
2025-06-27 22:09:32 +02:00
|
|
|
body.data_array = data.slice(block_offset+header_size)
|
2025-06-27 17:55:19 +02:00
|
|
|
body.big_endian = true
|
2025-06-27 22:09:32 +02:00
|
|
|
# get length of string
|
2025-06-27 17:55:19 +02:00
|
|
|
var body_length = body.get_32()
|
2025-06-27 22:09:32 +02:00
|
|
|
# get string
|
2025-06-27 17:55:19 +02:00
|
|
|
var sender_name = body.get_string(body_length)
|
|
|
|
print("sender id {0} is '{1}'".format([sender_id,sender_name]))
|
|
|
|
|
2025-06-27 22:09:32 +02:00
|
|
|
4: # quat pos
|
|
|
|
# set body
|
2025-06-27 17:55:19 +02:00
|
|
|
var body := StreamPeerBuffer.new()
|
2025-06-27 22:09:32 +02:00
|
|
|
# set header size
|
|
|
|
body.data_array = data.slice(block_offset+header_size,block_offset+header_size+length)
|
2025-06-27 17:55:19 +02:00
|
|
|
body.big_endian = true
|
2025-06-27 22:09:32 +02:00
|
|
|
# get id
|
2025-06-27 17:55:19 +02:00
|
|
|
var sensor_id = body.get_32()
|
|
|
|
var padding = body.get_32()
|
2025-06-27 22:09:32 +02:00
|
|
|
var pos = Vector3(body.get_double(),body.get_double(),body.get_double())
|
|
|
|
# VRPN quaternions are w,xyz
|
|
|
|
var quat_w = body.get_double()
|
|
|
|
var quat_x = body.get_double()
|
|
|
|
var quat_y = body.get_double()
|
|
|
|
var quat_z = body.get_double()
|
2025-06-27 17:55:19 +02:00
|
|
|
var quat = Quaternion(quat_x,quat_y,quat_z,quat_w)
|
2025-06-27 22:09:32 +02:00
|
|
|
|
2025-06-27 17:55:19 +02:00
|
|
|
|
|
|
|
static func aligned_size(actual_size : int,alignment : int = 8) -> int:
|
|
|
|
return (actual_size + alignment - 1) & ~(alignment - 1)
|