nekojanai/akkoma
1
0
Fork 0
forked from AkkomaGang/akkoma
Code Issues Pull requests Projects Releases Packages Wiki Activity

Merge branch 'flake-random-worker-id' into 'develop'

Browse source 
Flake: random worker id

See merge request pleroma/pleroma!721
This commit is contained in:
kaniini 2019-01-27 15:16:06 +00:00
commit 9af798ad40
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

@ -94,7 +94,7 @@ def start_link do
@impl GenServer @impl GenServer
def init([]) do def init([]) do
{:ok, %FlakeId{node: mac(), time: time()}} {:ok, %FlakeId{node: worker_id(), time: time()}}
end end
@impl GenServer @impl GenServer
@ -165,23 +165,8 @@ defp time do
1_000_000_000 * mega_seconds + seconds * 1000 + :erlang.trunc(micro_seconds / 1000) 1_000_000_000 * mega_seconds + seconds * 1000 + :erlang.trunc(micro_seconds / 1000)
end end
def mac do defp worker_id() do
{:ok, addresses} = :inet.getifaddrs() <<worker::integer-size(48)>> = :crypto.strong_rand_bytes(6)
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)
worker worker
end end
end end