nrd.li/akkoma
1
0
Fork 0
Code Issues Pull requests Projects Releases Wiki Activity

Flake: random worker id

Browse source
This commit is contained in:
href 2019-01-27 16:04:36 +01:00
parent 6383fa3a5d
commit e0e0cc5ab0
No known key found for this signature in database
GPG key ID: EE8296C1A152C325
1 changed files with 3 additions and 18 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

21
lib/pleroma/flake_id.ex
View file

@ -90,7 +90,7 @@ def start_link do
@impl GenServer
def init([]) do
{:ok, %FlakeId{node: mac(), time: time()}}
{:ok, %FlakeId{node: worker_id(), time: time()}}
end
@impl GenServer
@ -161,23 +161,8 @@ defp time do
1_000_000_000 * mega_seconds + seconds * 1000 + :erlang.trunc(micro_seconds / 1000)
end
def mac do
{:ok, addresses} = :inet.getifaddrs()
macids =
Enum.reduce(addresses, [], fn {_iface, attrs}, acc ->
case attrs[:hwaddr] do
[0, 0, 0 | _] -> acc
mac when is_list(mac) -> [mac_to_worker_id(mac) | acc]
_ -> acc
end
end)
List.first(macids)
end
def mac_to_worker_id(mac) do
<<worker::integer-size(48)>> = :binary.list_to_bin(mac)
defp worker_id() do
<<worker::integer-size(48)>> = :crypto.strong_rand_bytes(6)
worker
end
end