-- PlaywaveService (ModuleScript)
-- Place under ServerScriptService/Script
local Players = game:GetService("Players")
local HttpService = game:GetService("HttpService")
local API_URL = "https://wave-api.playwave.dev/v1"
local API_KEY = "your-api-key-here"
local HEARTBEAT_INTERVAL = 120 -- 2 minutes
local activeSessions = {}
local PlaywaveService = {}
local function apiRequest(method, path, body)
local requestInfo = {
Url = API_URL .. path,
Method = method,
Headers = {
["X-Api-Key"] = API_KEY,
["Content-Type"] = "application/json",
},
}
if body then
requestInfo.Body = HttpService:JSONEncode(body)
end
local success, response = pcall(function()
return HttpService:RequestAsync(requestInfo)
end)
if not success then
warn("[Playwave] HTTP failed:", response)
return nil, "NETWORK_ERROR"
end
if response.StatusCode >= 400 then
local errorBody = nil
pcall(function() errorBody = HttpService:JSONDecode(response.Body) end)
return errorBody, "HTTP_" .. tostring(response.StatusCode)
end
local ok, decoded = pcall(function() return HttpService:JSONDecode(response.Body) end)
if not ok then
warn("[Playwave] JSON decode failed")
return nil, "DECODE_ERROR"
end
return decoded, nil
end
local function startHeartbeatLoop(userId, gameSessionId, providerUserId)
return task.spawn(function()
while activeSessions[userId] do
task.wait(HEARTBEAT_INTERVAL)
if not activeSessions[userId] then break end
local result, err = apiRequest("PATCH", "/game/session/heartbeat", {
game_session_id = gameSessionId,
provider_user_id = providerUserId,
})
if err then
if err == "HTTP_404" or err == "HTTP_410" or string.sub(err, 1, 7) == "HTTP_5" then
warn("[Playwave] Session lost for UserId", userId, ":", err)
activeSessions[userId] = nil
local player = Players:GetPlayerByUserId(userId)
if player then player:Kick("PlayWave session expired") end
break
end
warn("[Playwave] Heartbeat error:", err)
continue
end
if result and result.data and result.data.result == "CHARGE_EXHAUSTED" then
local player = Players:GetPlayerByUserId(userId)
if player then warn("[Playwave] Charge exhausted for", player.Name) end
end
end
end)
end
local function endPlayerSession(userId)
local session = activeSessions[userId]
if not session then return end
activeSessions[userId] = nil
if session.heartbeatThread then task.cancel(session.heartbeatThread) end
local clientPlayDuration = math.floor(os.clock() - session.startTime)
local _, err = apiRequest("DELETE", "/game/session/end", {
game_session_id = session.gameSessionId,
play_duration_sec = clientPlayDuration,
})
if err and err ~= "HTTP_404" and err ~= "HTTP_409" then
warn("[Playwave] End session failed for UserId", userId, ":", err)
end
end
function PlaywaveService.init(clientReadyEvent, onPcCafe)
clientReadyEvent.OnServerEvent:Connect(function(player)
local joinData = player:GetJoinData()
local ott = joinData.LaunchData
if not ott or ott == "" then
return
end
local result, err = apiRequest("POST", "/game/session/verify", {
ott = ott,
provider_user_id = tostring(player.UserId),
})
if err then
warn("[Playwave] Verify error:", err)
return
end
if result and result.success and result.data and result.data.is_valid then
local data = result.data
activeSessions[player.UserId] = {
gameSessionId = data.game_session_id,
startTime = os.clock(),
heartbeatThread = nil,
}
activeSessions[player.UserId].heartbeatThread = startHeartbeatLoop(
player.UserId,
data.game_session_id,
tostring(player.UserId)
)
if data.is_pc_cafe and onPcCafe then
onPcCafe(player)
end
else
if result and result.data then
warn("[Playwave] Verify failed:", player.Name, result.data.reason)
end
end
end)
Players.PlayerRemoving:Connect(function(player)
endPlayerSession(player.UserId)
end)
game:BindToClose(function()
for userId in pairs(activeSessions) do
endPlayerSession(userId)
end
end)
end
return PlaywaveService
