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(replication): bug fixes

Browse source
This commit is contained in:
khtsly 2026-02-16 17:42:28 +07:00
parent 71c66b6d23
commit 5e6433e892
1 changed files with 24 additions and 25 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

49
src/Replication/init.luau
View file

@ -12,7 +12,30 @@ local identifiers_schema = Buffer.Schema.string
local writer: Buffer.Writer = Buffer.createWriter() local writer: Buffer.Writer = Buffer.createWriter()
local warp_identifier_registry = shared.__warp_identifier_registry local warp_identifier_registry = shared.__warp_identifier_registry
if RunService:IsServer() and not RunService:IsStudio() then if RunService:IsClient() or RunService:IsRunMode() then
if RunService:IsClient() then
_repl.OnClientEvent:Connect(function(b: buffer)
if type(b) ~= "buffer" then
return
end
local contents = Buffer.readRepl(b, identifiers_schema)
if #contents == 0 then return end
for _, content in contents do
local id, remote = content[1], content[2]
warp_identifier_registry.cache[remote] = id
warp_identifier_registry.name[id] = remote
end
end)
_repl:FireServer()
end
Replication.get_id = function(name: string): number
return warp_identifier_registry.cache[name]
end
Replication.get_name = function(name: string): number
return warp_identifier_registry.name[name]
end
else
local replication_ready: { Player } = {} local replication_ready: { Player } = {}
local replication_id: number = Identifier.get_id("id_replication") or 1 local replication_id: number = Identifier.get_id("id_replication") or 1
@ -53,30 +76,6 @@ if RunService:IsServer() and not RunService:IsStudio() then
Replication.remove = function(player: Player) Replication.remove = function(player: Player)
table.remove(replication_ready, table.find(replication_ready, player)) table.remove(replication_ready, table.find(replication_ready, player))
end end
else
if RunService:IsClient() then
_repl.OnClientEvent:Connect(function(b: buffer)
if type(b) ~= "buffer" then
return
end
local contents = Buffer.readRepl(b, identifiers_schema)
if #contents == 0 then return end
for _, content in contents do
local id, remote = content[1], content[2]
warp_identifier_registry.cache[remote] = id
warp_identifier_registry.name[id] = remote
end
end)
_repl:FireServer()
end
Replication.get_id = function(name: string): number
return warp_identifier_registry.cache[name]
end
Replication.get_name = function(name: string): number
return warp_identifier_registry.name[name]
end
end end
return Replication :: typeof(Replication) return Replication :: typeof(Replication)