Sovereignty/Warp
1
0
Fork 0
mirror of https://github.com/imezx/Warp.git synced 2026-03-18 00:44:16 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

chore(repl): debloated prev changes made

Browse source
This commit is contained in:
Khietsly Tristan 2026-02-25 10:47:37 +07:00
parent 4f92248187
commit b26d06fa3d
1 changed files with 5 additions and 52 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

57
src/Replication/init.luau
View file

@ -23,7 +23,7 @@ if RunService:IsClient() or RunService:IsRunMode() then
local contents = Buffer.readRepl(b, identifiers_schema) local contents = Buffer.readRepl(b, identifiers_schema)
if #contents == 0 then return end if #contents == 0 then return end
for _, content in contents do for _, content in contents do
local id, remote = content[1], content[2] local id: number, remote: string = content[1], content[2]
warp_identifier_registry.cache[remote] = id warp_identifier_registry.cache[remote] = id
warp_identifier_registry.name[id] = remote warp_identifier_registry.name[id] = remote
@ -61,59 +61,12 @@ if RunService:IsClient() or RunService:IsRunMode() then
coroutine.yield() coroutine.yield()
end end
--@name string Replication.get_id = function(name: string): number
--@timeout number (default: 0) return warp_identifier_registry.cache[name]
Replication.get_id = function(name: string, timeout: number?): number
local cached = warp_identifier_registry.cache[name]
if cached or type(timeout) ~= "number" then return cached end
local thread = coroutine.running()
if not pending_id_yields[name] then pending_id_yields[name] = {} end
table.insert(pending_id_yields[name], thread)
task.delay(timeout, function()
if pending_id_yields[name] then
local idx = table.find(pending_id_yields[name], thread)
if idx then
table.remove(pending_id_yields[name], idx)
task.spawn(thread, nil)
end
end
end)
local obj: number = coroutine.yield()
if not obj then
warn(`[Replication] timeout: could not find identifier '{name}' after {timeout}s.`)
end
return obj
end end
--@name string Replication.get_name = function(id: number): string
--@timeout number (default: 0) return warp_identifier_registry.name[id]
Replication.get_name = function(id: number, timeout: number?): string
local cached = warp_identifier_registry.name[id]
if cached or type(timeout) ~= "number" then return cached end
local thread = coroutine.running()
if not pending_name_yields[id] then pending_name_yields[id] = {} end
table.insert(pending_name_yields[id], thread)
task.delay(timeout, function()
if pending_name_yields[id] then
local idx = table.find(pending_name_yields[id], thread)
if idx then
table.remove(pending_name_yields[id], idx)
task.spawn(thread, nil)
end
end
end)
local obj: string = coroutine.yield()
if not id then
warn(`[Replication] timeout: could not find identifier '{id}' after {timeout}s.`)
end
return obj
end end
else else
local replication_ready: { Player }, pending_replications = {}, {} local replication_ready: { Player }, pending_replications = {}, {}