mirror of
https://github.com/Relintai/pandemonium_demo_projects.git
synced 2024-12-21 13:56:50 +01:00
85 lines
2.6 KiB
GDScript3
85 lines
2.6 KiB
GDScript3
|
extends Node
|
||
|
|
|
||
|
|
onready var _log_dest = get_parent().get_node("Panel/VBoxContainer/RichTextLabel")
|
||
|
|
|
||
|
|
var _client = WebSocketClient.new()
|
||
|
|
var _write_mode = WebSocketPeer.WRITE_MODE_BINARY
|
||
|
|
var _use_multiplayer = true
|
||
|
|
var last_connected_client = 0
|
||
|
|
|
||
|
|
func _init():
|
||
|
|
_client.connect("connection_established", self, "_client_connected")
|
||
|
|
_client.connect("connection_error", self, "_client_disconnected")
|
||
|
|
_client.connect("connection_closed", self, "_client_disconnected")
|
||
|
|
_client.connect("server_close_request", self, "_client_close_request")
|
||
|
|
_client.connect("data_received", self, "_client_received")
|
||
|
|
|
||
|
|
_client.connect("peer_packet", self, "_client_received")
|
||
|
|
_client.connect("peer_connected", self, "_peer_connected")
|
||
|
|
_client.connect("connection_succeeded", self, "_client_connected", ["multiplayer_protocol"])
|
||
|
|
_client.connect("connection_failed", self, "_client_disconnected")
|
||
|
|
|
||
|
|
|
||
|
|
func _client_close_request(code, reason):
|
||
|
|
Utils._log(_log_dest, "Close code: %d, reason: %s" % [code, reason])
|
||
|
|
|
||
|
|
|
||
|
|
func _peer_connected(id):
|
||
|
|
Utils._log(_log_dest, "%s: Client just connected" % id)
|
||
|
|
last_connected_client = id
|
||
|
|
|
||
|
|
|
||
|
|
func _exit_tree():
|
||
|
|
_client.disconnect_from_host(1001, "Bye bye!")
|
||
|
|
|
||
|
|
|
||
|
|
func _process(_delta):
|
||
|
|
if _client.get_connection_status() == WebSocketClient.CONNECTION_DISCONNECTED:
|
||
|
|
return
|
||
|
|
|
||
|
|
_client.poll()
|
||
|
|
|
||
|
|
|
||
|
|
func _client_connected(protocol):
|
||
|
|
Utils._log(_log_dest, "Client just connected with protocol: %s" % protocol)
|
||
|
|
_client.get_peer(1).set_write_mode(_write_mode)
|
||
|
|
|
||
|
|
|
||
|
|
func _client_disconnected(clean=true):
|
||
|
|
Utils._log(_log_dest, "Client just disconnected. Was clean: %s" % clean)
|
||
|
|
|
||
|
|
|
||
|
|
func _client_received(_p_id = 1):
|
||
|
|
if _use_multiplayer:
|
||
|
|
var peer_id = _client.get_packet_peer()
|
||
|
|
var packet = _client.get_packet()
|
||
|
|
Utils._log(_log_dest, "MPAPI: From %s Data: %s" % [str(peer_id), Utils.decode_data(packet, false)])
|
||
|
|
else:
|
||
|
|
var packet = _client.get_peer(1).get_packet()
|
||
|
|
var is_string = _client.get_peer(1).was_string_packet()
|
||
|
|
Utils._log(_log_dest, "Received data. BINARY: %s: %s" % [not is_string, Utils.decode_data(packet, is_string)])
|
||
|
|
|
||
|
|
|
||
|
|
func connect_to_url(host, protocols, multiplayer):
|
||
|
|
_use_multiplayer = multiplayer
|
||
|
|
if _use_multiplayer:
|
||
|
|
_write_mode = WebSocketPeer.WRITE_MODE_BINARY
|
||
|
|
return _client.connect_to_url(host, protocols, multiplayer)
|
||
|
|
|
||
|
|
|
||
|
|
func disconnect_from_host():
|
||
|
|
_client.disconnect_from_host(1000, "Bye bye!")
|
||
|
|
|
||
|
|
|
||
|
|
func send_data(data, dest):
|
||
|
|
_client.get_peer(1).set_write_mode(_write_mode)
|
||
|
|
if _use_multiplayer:
|
||
|
|
_client.set_target_peer(dest)
|
||
|
|
_client.put_packet(Utils.encode_data(data, _write_mode))
|
||
|
|
else:
|
||
|
|
_client.get_peer(1).put_packet(Utils.encode_data(data, _write_mode))
|
||
|
|
|
||
|
|
|
||
|
|
func set_write_mode(mode):
|
||
|
|
_write_mode = mode
|