Packages
swoosh
1.25.3
1.26.3
1.26.2
1.26.1
1.26.0
1.25.3
1.25.2
1.25.1
1.25.0
1.24.0
1.23.1
1.23.0
1.22.1
1.22.0
1.21.0
1.20.1
1.20.0
1.19.9
1.19.8
1.19.7
1.19.6
1.19.5
1.19.4
1.19.3
1.19.2
1.19.1
1.19.0
1.18.4
1.18.3
1.18.2
1.18.1
1.18.0
1.17.10
1.17.9
1.17.8
retired
1.17.7
retired
1.17.6
1.17.5
1.17.4
retired
1.17.3
1.17.2
1.17.1
1.17.0
1.16.12
1.16.11
1.16.10
1.16.9
1.16.8
1.16.7
1.16.6
1.16.5
1.16.4
1.16.3
1.16.2
retired
1.16.1
retired
1.16.0
1.15.3
1.15.2
1.15.1
1.15.0
1.14.4
1.14.3
1.14.2
1.14.1
1.14.0
1.13.0
1.12.0
1.11.6
1.11.5
1.11.4
1.11.3
1.11.2
1.11.1
retired
1.11.0
1.10.3
1.10.2
1.10.1
1.10.0
1.9.1
1.9.0
1.8.3
1.8.2
1.8.1
1.8.0
1.7.5
1.7.4
1.7.3
1.7.2
1.7.1
1.7.0
1.6.6
1.6.5
1.6.4
1.6.3
1.6.2
1.6.1
1.6.0
1.5.2
1.5.1
1.5.0
1.4.0
1.3.11
1.3.10
1.3.9
1.3.8
retired
1.3.7
1.3.6
retired
1.3.5
1.3.4
1.3.3
1.3.2
1.3.1
1.3.0
1.2.2
1.2.1
1.2.0
1.1.2
1.1.1
1.1.0
1.0.9
1.0.8
retired
1.0.7
retired
1.0.6
1.0.5
1.0.4
1.0.3
1.0.2
1.0.1
1.0.0
0.25.6
0.25.5
0.25.4
0.25.3
retired
0.25.2
0.25.1
0.25.0
0.24.4
0.24.3
0.24.2
0.24.1
0.24.0
0.23.5
0.23.4
0.23.3
0.23.2
0.23.1
0.23.0
0.22.2
0.22.1
0.22.0
0.21.1
0.21.0
0.20.0
0.19.0
0.18.0
0.17.0
0.16.1
0.16.0
0.15.0
0.14.0
0.13.0
0.12.1
0.12.0
0.11.0
0.10.0
0.9.1
0.9.0
0.8.1
0.8.0
0.7.0
0.6.0
0.5.0
0.4.0
0.3.0
0.2.0
0.1.0
Compose, deliver and test your emails easily in Elixir. Supports SMTP, Sendgrid, Mandrill, Postmark, Mailgun and many more out of the box. Preview your emails in the browser. Test your email sending code.
Security advisory:
This version has known vulnerabilities.
View advisories
Current section
Files
Jump to
Current section
Files
lib/swoosh/adapters/sandbox/storage.ex
defmodule Swoosh.Adapters.Sandbox.Storage do
@moduledoc false
use GenServer
@table :swoosh_sandbox_emails
# Public API
def start_link(opts \\ []) do
GenServer.start_link(__MODULE__, opts, name: __MODULE__)
end
def checkout do
GenServer.call(__MODULE__, {:checkout, self()})
end
def checkin do
GenServer.call(__MODULE__, {:checkin, self()})
end
def allow(owner_pid, allowed_pid) do
GenServer.call(__MODULE__, {:allow, owner_pid, allowed_pid})
end
def set_shared(pid) do
GenServer.call(__MODULE__, {:set_shared, pid})
end
def get_shared do
GenServer.call(__MODULE__, :get_shared)
end
def find_owner(callers) do
GenServer.call(__MODULE__, {:find_owner, callers})
end
def push(owner_pid, email) do
GenServer.call(__MODULE__, {:push, owner_pid, email})
end
def push_many(owner_pid, emails) do
GenServer.call(__MODULE__, {:push_many, owner_pid, emails})
end
def all(owner_pid) do
case :ets.lookup(@table, owner_pid) do
[{^owner_pid, emails}] -> emails
[] -> []
end
end
def flush(owner_pid) do
GenServer.call(__MODULE__, {:flush, owner_pid})
end
# GenServer callbacks
@impl true
def init(_opts) do
:ets.new(@table, [:set, :named_table, :public, {:read_concurrency, true}])
{:ok, %{owners: MapSet.new(), allowed: %{}, shared: nil, monitors: %{}}}
end
@impl true
def handle_call({:checkout, pid}, _from, state) do
if MapSet.member?(state.owners, pid) do
{:reply, {:error, :already_checked_out}, state}
else
ref = Process.monitor(pid)
:ets.insert(@table, {pid, []})
new_state = %{
state
| owners: MapSet.put(state.owners, pid),
monitors: Map.put(state.monitors, ref, pid)
}
{:reply, :ok, new_state}
end
end
def handle_call({:checkin, pid}, _from, state) do
{:reply, :ok, do_checkin(pid, state)}
end
def handle_call({:allow, owner_pid, allowed_pid}, _from, state) do
if MapSet.member?(state.owners, owner_pid) do
{:reply, :ok, %{state | allowed: Map.put(state.allowed, allowed_pid, owner_pid)}}
else
{:reply, {:error, :not_checked_out}, state}
end
end
def handle_call({:set_shared, pid}, _from, state) do
{:reply, :ok, %{state | shared: pid}}
end
def handle_call(:get_shared, _from, state) do
{:reply, state.shared, state}
end
def handle_call({:find_owner, callers}, _from, state) do
result =
Enum.find_value(callers, fn pid ->
cond do
MapSet.member?(state.owners, pid) -> {:ok, pid}
owner = Map.get(state.allowed, pid) -> {:ok, owner}
true -> nil
end
end)
{:reply, result || :no_owner, state}
end
def handle_call({:push, owner_pid, email}, _from, state) do
existing =
case :ets.lookup(@table, owner_pid) do
[{^owner_pid, emails}] -> emails
[] -> []
end
:ets.insert(@table, {owner_pid, [email | existing]})
send(owner_pid, {:email, email})
{:reply, :ok, state}
end
def handle_call({:push_many, owner_pid, emails}, _from, state) do
existing =
case :ets.lookup(@table, owner_pid) do
[{^owner_pid, existing}] -> existing
[] -> []
end
:ets.insert(@table, {owner_pid, Enum.reverse(emails) ++ existing})
send(owner_pid, {:emails, emails})
{:reply, :ok, state}
end
def handle_call({:flush, owner_pid}, _from, state) do
emails =
case :ets.lookup(@table, owner_pid) do
[{^owner_pid, emails}] -> emails
[] -> []
end
:ets.insert(@table, {owner_pid, []})
{:reply, emails, state}
end
@impl true
def handle_info({:DOWN, ref, :process, pid, _}, state) do
if Map.has_key?(state.monitors, ref) do
{:noreply, do_checkin(pid, state)}
else
{:noreply, state}
end
end
# Internal helpers
defp do_checkin(pid, state) do
:ets.delete(@table, pid)
{to_demonitor, monitors} =
Enum.split_with(state.monitors, fn {_ref, p} -> p == pid end)
Enum.each(to_demonitor, fn {ref, _} -> Process.demonitor(ref, [:flush]) end)
allowed =
state.allowed
|> Enum.reject(fn {allowed_pid, owner_pid} ->
owner_pid == pid or allowed_pid == pid
end)
|> Map.new()
%{
state
| owners: MapSet.delete(state.owners, pid),
allowed: allowed,
shared: if(state.shared == pid, do: nil, else: state.shared),
monitors: Map.new(monitors)
}
end
end