Godot Engine

extends Node
 
var client: ColyseusClient
var room: ColyseusRoom
var callbacks: ColyseusCallbacks
 
func _ready():
	# Create and connect client
	client = Colyseus.create_client()
	client.set_endpoint("ws://localhost:2567")
 
	print("Connecting to: ", client.get_endpoint())
 
	# Join or create a room
	room = client.join_or_create("test_room")
 
	# Connect signals
	if room:
		room.joined.connect(_on_room_joined)
		room.state_changed.connect(_on_state_changed)
		room.message_received.connect(_on_message_received)
		room.error.connect(_on_room_error)
		room.left.connect(_on_room_left)
 
func _process(delta):
	# Poll the client for messages
	# (Only required for web builds)
	ColyseusClient.poll()
 
func _on_room_joined():
	print("✓ Joined room: ", room.get_id())
	print("  Session ID: ", room.get_session_id())
	print("  Room name: ", room.get_name())
 
	# Get callbacks container for the room
	callbacks = Colyseus.callbacks(room)
 
	# Listen to root state property changes
	callbacks.listen("currentTurn", _on_turn_change)
 
	# Listen to collection additions/removals
	callbacks.on_add("players", _on_player_add)
	callbacks.on_remove("players", _on_player_remove)
 
	# Send a message
	var message = "Hello from Godot!".to_utf8_buffer()
	room.send_message("add_item", {"name": "MY NEW ITEM"})
 
func _on_turn_change(current_value, previous_value):
	print("↻ Turn changed: ", previous_value, " -> ", current_value)
 
func _on_player_add(player: Dictionary, key: String):
	print("+ Player joined: ", key)
	# Listen to nested schema properties
	callbacks.listen(player, "hp", _on_player_hp_change)
	# Listen to nested collections
	callbacks.on_add(player, "items", _on_item_add)
 
func _on_player_remove(player: Dictionary, key: String):
	print("- Player left: ", key)
 
func _on_player_hp_change(current_hp, previous_hp):
	print("  HP changed: ", previous_hp, " -> ", current_hp)
 
func _on_item_add(item: Dictionary, index: int):
	print("  Item added at index: ", index, " -> ", item)
 
	callbacks.listen(item, "name", func(name, _prev):
		print("  Item name: ", name))
 
func _on_state_changed():
	print("↻ Room state changed")
	# Access state as Dictionary
	var state = room.get_state()
	if state:
		print("  State: ", state)
 
func _on_message_received(type: Variant, data: Variant):
	# type is the message type (String or int for numeric types)
	print("✉ Message received - type: ", type, " data: ", data)
 
func _on_room_error(code: int, message: String):
	printerr("✗ Room error [", code, "]: ", message)
 
func _on_room_left(code: int, reason: String):
	print("← Left room [", code, "]: ", reason)
 
func _exit_tree():
	# Clean up when node is removed
	if room and room.has_joined():
		room.leave()

npx schema-codegen src/rooms/schema/* --gdscript --bundle --output ../colyseus/schema/