feat: add world WebSocket methods (#6)

* feat: sync API surface with asobi backend

* feat: add world list/create/join/find_or_create via WebSocket

Author: Taure

asobi/api/dm.lua

@@ -0,0 +1,13 @@
+local http_mod = require("asobi.http")
+
+local M = {}
+
+function M.send(client, recipient_id, content, callback)
+	http_mod.post(client, "/api/v1/dm", {recipient_id = recipient_id, content = content}, callback)
+end
+
+function M.history(client, player_id, callback)
+	http_mod.get(client, "/api/v1/dm/" .. player_id .. "/history", nil, callback)
+end
+
+return M

asobi/api/worlds.lua

@@ -0,0 +1,19 @@
+local http_mod = require("asobi.http")
+
+local M = {}
+
+function M.list(client, mode, callback)
+	local query = nil
+	if mode then query = {mode = mode} end
+	http_mod.get(client, "/api/v1/worlds", query, callback)
+end
+
+function M.get(client, world_id, callback)
+	http_mod.get(client, "/api/v1/worlds/" .. world_id, nil, callback)
+end
+
+function M.create(client, mode, callback)
+	http_mod.post(client, "/api/v1/worlds", {mode = mode}, callback)
+end
+
+return M

asobi/client.lua

@@ -13,6 +13,8 @@ local notifications = require("asobi.api.notifications")
 local storage = require("asobi.api.storage")
 local iap = require("asobi.api.iap")
 local votes = require("asobi.api.votes")
+local worlds = require("asobi.api.worlds")
+local dm = require("asobi.api.dm")
 
 local M = {}
 
@@ -48,6 +50,8 @@ function M.create(host, port, use_ssl)
 	client.storage = storage
 	client.iap = iap
 	client.votes = votes
+	client.worlds = worlds
+	client.dm = dm
 
 	realtime_mod.init(client)
 

asobi/realtime.lua

@@ -3,6 +3,7 @@ local M = {}
 M._client = nil
 M._connection = nil
 M._cid_counter = 0
+M._pending = {}
 M._callbacks = {
 	on_connected = nil,
 	on_disconnected = nil,
@@ -17,6 +18,9 @@ M._callbacks = {
 	on_notification = nil,
 	on_matchmaker_matched = nil,
 	on_presence_changed = nil,
+	on_dm_message = nil,
+	on_world_list = nil,
+	on_world_joined = nil,
 	on_error = nil,
 }
 
@@ -92,6 +96,10 @@ function M.cast_veto(vote_id)
 	M._send("vote.veto", {vote_id = vote_id})
 end
 
+function M.send_dm(recipient_id, content)
+	M._send("dm.send", {recipient_id = recipient_id, content = content})
+end
+
 function M.update_presence(status)
 	M._send("presence.update", {status = status or "online"})
 end
@@ -100,6 +108,32 @@ function M.send_heartbeat()
 	M._send_fire_and_forget("session.heartbeat", {})
 end
 
+function M.list_worlds(mode, callback)
+	local payload = {}
+	if mode then payload.mode = mode end
+	M._send_with_callback("world.list", payload, callback)
+end
+
+function M.create_world(mode, callback)
+	M._send_with_callback("world.create", {mode = mode}, callback)
+end
+
+function M.join_world(world_id, callback)
+	M._send_with_callback("world.join", {world_id = world_id}, callback)
+end
+
+function M.find_or_create_world(mode, callback)
+	M._send_with_callback("world.find_or_create", {mode = mode}, callback)
+end
+
+function M.send_world_input(input)
+	M._send_fire_and_forget("world.input", input)
+end
+
+function M.leave_world()
+	M._send("world.leave", {})
+end
+
 function M.on(event, callback)
 	M._callbacks["on_" .. event] = callback
 end
@@ -111,6 +145,20 @@ function M._send(msg_type, payload)
 	websocket.send(M._connection, msg, {type = websocket.DATA_TYPE_TEXT})
 end
 
+function M._send_with_callback(msg_type, payload, callback)
+	if not M._connection then
+		if callback then callback(nil, "not connected") end
+		return
+	end
+	M._cid_counter = M._cid_counter + 1
+	local cid = tostring(M._cid_counter)
+	if callback then
+		M._pending[cid] = callback
+	end
+	local msg = json.encode({type = msg_type, payload = payload, cid = cid})
+	websocket.send(M._connection, msg, {type = websocket.DATA_TYPE_TEXT})
+end
+
 function M._send_fire_and_forget(msg_type, payload)
 	if not M._connection then return end
 	local msg = json.encode({type = msg_type, payload = payload})
@@ -123,6 +171,19 @@ function M._handle_message(raw)
 
 	local msg_type = msg.type or ""
 	local payload = msg.payload or {}
+	local cid = msg.cid
+
+	-- Check for pending request-response callbacks
+	if cid and M._pending[cid] then
+		local cb = M._pending[cid]
+		M._pending[cid] = nil
+		if msg_type == "error" then
+			cb(nil, payload.reason or "unknown error")
+		else
+			cb(payload, nil)
+		end
+		return
+	end
 
 	local handlers = {
 		["session.connected"] = "on_connected",
@@ -137,6 +198,10 @@ function M._handle_message(raw)
 		["notification.new"] = "on_notification",
 		["match.matched"] = "on_matchmaker_matched",
 		["presence.changed"] = "on_presence_changed",
+		["dm.message"] = "on_dm_message",
+		["world.list"] = "on_world_list",
+		["world.joined"] = "on_world_joined",
+		["world.tick"] = "on_match_state",
 		["error"] = "on_error",
 	}