From 1bdfb112b659a6e4447ae8ed02c452bf12d8700a Mon Sep 17 00:00:00 2001
From: Star Rauchenberger <fefferburbia@gmail.com>
Date: Tue, 17 Dec 2024 16:01:19 -0500
Subject: Add position tracking via IPC

---
 Archipelago/tracker.gd | 84 ++++++++++++++++++++++++++++++++++++++++++++++++++
 1 file changed, 84 insertions(+)
 create mode 100644 Archipelago/tracker.gd

(limited to 'Archipelago/tracker.gd')

diff --git a/Archipelago/tracker.gd b/Archipelago/tracker.gd
new file mode 100644
index 0000000..798721d
--- /dev/null
+++ b/Archipelago/tracker.gd
@@ -0,0 +1,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}})
-- 
cgit 1.4.1