mirror of
https://github.com/imezx/Warp.git
synced 2025-04-24 23:20:02 +00:00
92 lines
No EOL
2.3 KiB
Lua
92 lines
No EOL
2.3 KiB
Lua
--!strict
|
|
--!native
|
|
--!optimize 2
|
|
local Client = {}
|
|
Client.__index = Client
|
|
|
|
local Players = game:GetService("Players")
|
|
local Util = script.Parent.Parent.Util
|
|
|
|
local Type = require(script.Parent.Parent.Type)
|
|
local ClientProcess = require(script.Parent.ClientProcess)
|
|
local Assert = require(Util.Assert)
|
|
local Key = require(Util.Key)
|
|
local Serdes = require(Util.Serdes)
|
|
local Buffer = require(Util.Buffer)
|
|
|
|
function Client.new(Identifier: string, conf: Type.ClientConf?)
|
|
local self = setmetatable({}, Client)
|
|
|
|
self._buffer = Buffer.new()
|
|
self._buffer:wu8(Serdes(Identifier, conf and conf.yieldWait))
|
|
self.id = Buffer.convert(self._buffer:build())
|
|
self.fn = {}
|
|
self._conf = table.freeze(conf or {})
|
|
self.IsConnected = false
|
|
|
|
ClientProcess.add(self.id, Identifier, conf or { yieldWait = 10, logging = { store = false, opt = false } })
|
|
self._buffer:remove()
|
|
|
|
return self
|
|
end
|
|
|
|
function Client:logs()
|
|
Assert(self._conf.logging, "[Client]: Event is not configured with logging.")
|
|
return ClientProcess.getlogs(self.id)
|
|
end
|
|
|
|
function Client:Fire(reliable: boolean,...: any)
|
|
ClientProcess.insertQueue(self.id, reliable, ...)
|
|
end
|
|
|
|
function Client:Invoke(timeout: number, ...: any): any
|
|
return ClientProcess.insertRequest(self.id, timeout, ...)
|
|
end
|
|
|
|
function Client:Connect(callback: (args: any) -> ()): string
|
|
local key = tostring(Key())
|
|
table.insert(self.fn, key)
|
|
self.IsConnected = #self.fn > 0
|
|
ClientProcess.addCallback(self.id, key, callback)
|
|
return key
|
|
end
|
|
|
|
function Client:Once(callback: (args: any) -> ()): string
|
|
local key = tostring(Key())
|
|
table.insert(self.fn, key)
|
|
self.IsConnected = #self.fn > 0
|
|
ClientProcess.addCallback(self.id, key, function(...)
|
|
self:Disconnect(key)
|
|
task.spawn(callback, ...)
|
|
end)
|
|
return key
|
|
end
|
|
|
|
function Client:Wait()
|
|
local thread: thread, t = coroutine.running(), os.clock()
|
|
self:Once(function()
|
|
task.spawn(thread, os.clock()-t)
|
|
end)
|
|
return coroutine.yield()
|
|
end
|
|
|
|
function Client:DisconnectAll()
|
|
for _, key: string in self.fn do
|
|
self:Disconnect(key)
|
|
end
|
|
end
|
|
|
|
function Client:Disconnect(key: string): boolean
|
|
Assert(typeof(key) == "string", "Key must be a string type.")
|
|
ClientProcess.removeCallback(self.id, key)
|
|
table.remove(self.fn, table.find(self.fn, key))
|
|
self.IsConnected = #self.fn > 0
|
|
return table.find(self.fn, key) == nil
|
|
end
|
|
|
|
function Client:Destroy()
|
|
self:DisconnectAll()
|
|
setmetatable(self, nil)
|
|
end
|
|
|
|
return Client.new |