diff --git a/SocketClient.gd b/SocketClient.gd index d0b4924..27cbf20 100644 --- a/SocketClient.gd +++ b/SocketClient.gd @@ -31,7 +31,6 @@ func _process(delta: float) -> void: if new_status == _stream.STATUS_CONNECTED: var available_bytes: int = _stream.get_available_bytes() if available_bytes > 0: - #print("available bytes: ", available_bytes) var res = _stream.get_partial_data(available_bytes) if res[0] != OK: emit_signal("error") @@ -61,17 +60,32 @@ func _on_data(data : Array): # Cookie Hack! if as_cookie.begins_with("vrpn: ver."): - #print("VRPN magic cookie '{0}'".format([as_cookie])) # kaboom we just send back the same cookie :) self.send(bytes) else: # non-cookie messages - var header_bytes = bytes.slice(0,24) - var header_i32 = header_bytes.to_int32_array() - #var vrpn_h = VRPN_Header.new(header_bytes) - #print(header_i32) - #print(header_bytes) - print(bytes) + var peer := StreamPeerBuffer.new() + peer.data_array = bytes.slice(0,24) + peer.big_endian = true + + var length = peer.get_32() # length of message + var time_sec = peer.get_32() # time sec + var time_msec = peer.get_32() # time millisec + var sender_id = peer.get_32() # sender id + var message_type = peer.get_32() # type of message (payload) + var sequence_num = peer.get_32() # inofficial + + 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) + + if message_type == 4: + + + func _on_connected(s : StreamPeerTCP): print("Connected to",s.get_connected_host()) # Replace with function body.