1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
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
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
|
extends Node
var autotracker_port = 41253
var _server = WebSocketServer.new()
var _peers = []
func _ready():
_server.bind_ip = "127.0.0.1"
_server.connect("client_connected", self, "_connection_established")
_server.connect("client_disconnected", self, "_connection_dropped")
_server.connect("data_received", self, "_data_received")
_server.listen(autotracker_port)
func _process(_delta):
_server.poll()
func _connection_established(id, _protocol):
_peers.append(id)
var apclient = global.get_node("Archipelago")
var msg = {"cmd": "Connect", "slot": {"server": apclient.ap_server, "player": apclient.ap_user}}
var peer = _server.get_peer(id)
peer.set_write_mode(WebSocketPeer.WRITE_MODE_TEXT)
peer.put_packet(JSON.print(msg).to_utf8())
func _connection_dropped(id, _was_clean_close):
_peers.erase(id)
func _data_received(id):
var peer = _server.get_peer(id)
peer.set_write_mode(WebSocketPeer.WRITE_MODE_TEXT)
var packet_text = peer.get_packet().get_string_from_utf8()
global._print("Got data from tracker: " + packet_text)
var msg = JSON.parse(packet_text)
if msg.error != OK:
global._print("Error parsing packet from Tracker: " + msg.error_string)
return
var apclient = global.get_node("Archipelago")
if msg["cmd"] == "Sync":
var resp = {}
if apclient.track_player:
var player = get_tree().get_root().get_node("Spatial/player")
resp = {
"cmd": "UpdatePosition",
"position": {"x": int(player._oldpos_fine.x), "z": int(player._oldpos_fine.z)}
}
peer.put_packet(JSON.print(resp).to_utf8())
func _broadcast(msg):
var to_remove = []
var serialized = JSON.print(msg).to_utf8()
for peer_id in _peers:
if _server.has_peer(peer_id):
var peer = _server.get_peer(peer_id)
peer.set_write_mode(WebSocketPeer.WRITE_MODE_TEXT)
peer.put_packet(serialized)
else:
to_remove.append(peer_id)
for peer_id in to_remove:
_peers.erase(peer_id)
func has_connection():
return _peers.size() > 0
func update_position(x, z):
_broadcast({"cmd": "UpdatePosition", "position": {"x": x, "z": z}})
|
