30 lines
724 B
Elixir
30 lines
724 B
Elixir
defmodule BDS.AI.InFlight do
|
|
@moduledoc false
|
|
|
|
@table :bds_ai_in_flight
|
|
|
|
def register(conversation_id, pid) when is_binary(conversation_id) and is_pid(pid) do
|
|
:ets.insert(table(), {conversation_id, pid})
|
|
:ok
|
|
end
|
|
|
|
def unregister(conversation_id) when is_binary(conversation_id) do
|
|
:ets.delete(table(), conversation_id)
|
|
:ok
|
|
end
|
|
|
|
def lookup(conversation_id) when is_binary(conversation_id) do
|
|
case :ets.lookup(table(), conversation_id) do
|
|
[{^conversation_id, pid}] -> pid
|
|
_other -> nil
|
|
end
|
|
end
|
|
|
|
defp table do
|
|
case :ets.whereis(@table) do
|
|
:undefined -> :ets.new(@table, [:named_table, :public, :set, read_concurrency: true])
|
|
table -> table
|
|
end
|
|
end
|
|
end
|