class_name KeetRoom
extends Node
## Room management for keet-daemon.
## List, join, leave, create, and configure rooms.
signal rooms_loaded(rooms: Array)
signal room_joined(room_id: String)
signal room_left(room_id: String)
signal room_created(room_id: String)
signal members_loaded(room_id: String, members: Array)
signal invite_created(room_id: String, invite: String)
signal error_occurred(message: String)
@export var client: KeetClient
## List all rooms.
func list_rooms(callback: Callable = Callable()) -> void:
_require_client()
client.rpc("rooms", {}, func(result, err):
if err != null:
error_occurred.emit("list_rooms: %s" % str(err))
return
var rooms: Array = result if result is Array else []
rooms_loaded.emit(rooms)
if callback.is_valid():
callback.call(rooms)
)
## Get info for a specific room.
func get_room(room_id: String, callback: Callable = Callable()) -> void:
_require_client()
client.rpc("room", {"roomId": room_id}, func(result, err):
if err != null:
error_occurred.emit("get_room: %s" % str(err))
return
if callback.is_valid():
callback.call(result)
)
## Create a new room.
func create_room(title: String, callback: Callable = Callable()) -> void:
_require_client()
client.rpc("room.create", {"title": title}, func(result, err):
if err != null:
error_occurred.emit("create_room: %s" % str(err))
return
var rid: String = result.get("roomId", "") if result is Dictionary else ""
room_created.emit(rid)
if callback.is_valid():
callback.call(result)
)
## Join a room by invite link or token.
func join_room(invite: String, callback: Callable = Callable()) -> void:
_require_client()
client.rpc("room.join", {"invite": invite}, func(result, err):
if err != null:
error_occurred.emit("join_room: %s" % str(err))
return
var rid: String = result.get("roomId", "") if result is Dictionary else ""
room_joined.emit(rid)
if callback.is_valid():
callback.call(result)
)
## Leave a room.
func leave_room(room_id: String, callback: Callable = Callable()) -> void:
_require_client()
client.rpc("room.leave", {"roomId": room_id}, func(result, err):
if err != null:
error_occurred.emit("leave_room: %s" % str(err))
return
room_left.emit(room_id)
if callback.is_valid():
callback.call(result)
)
## Get an invite token for a room.
func create_invite(room_id: String, callback: Callable = Callable()) -> void:
_require_client()
client.rpc("room.invite", {"roomId": room_id}, func(result, err):
if err != null:
error_occurred.emit("create_invite: %s" % str(err))
return
var token: String = ""
if result is Dictionary:
token = result.get("token", result.get("invite", ""))
elif result is String:
token = result
invite_created.emit(room_id, token)
if callback.is_valid():
callback.call(token)
)
## List members of a room.
func list_members(room_id: String, callback: Callable = Callable()) -> void:
_require_client()
client.rpc("members", {"roomId": room_id}, func(result, err):
if err != null:
error_occurred.emit("list_members: %s" % str(err))
return
var members: Array = result if result is Array else []
members_loaded.emit(room_id, members)
if callback.is_valid():
callback.call(members)
)
## Set room configuration (title, description, etc).
func set_config(room_id: String, key: String, value: Variant, callback: Callable = Callable()) -> void:
_require_client()
client.rpc("room.config.set", {"roomId": room_id, "key": key, "value": value}, func(result, err):
if err != null:
error_occurred.emit("set_config: %s" % str(err))
return
if callback.is_valid():
callback.call(result)
)
func _require_client() -> void:
if client == null:
push_error("KeetRoom: client not set. Assign a KeetClient node.")