Packages
ash_admin
0.13.26
1.1.0
1.0.0-rc.0
0.14.0
0.13.26
0.13.25
0.13.24
0.13.23
0.13.22
0.13.21
0.13.20
0.13.19
0.13.18
0.13.17
0.13.16
0.13.15
0.13.14
0.13.13
0.13.12
0.13.11
0.13.10
0.13.9
0.13.8
0.13.7
0.13.6
0.13.5
0.13.4
0.13.3
0.13.2
0.13.1
0.13.0
0.12.6
0.12.5
0.12.4
0.12.3
0.12.2
0.12.1
0.12.0
0.11.11
0.11.10
0.11.9
0.11.8
0.11.7
0.11.6
0.11.5
0.11.4
0.11.3
0.11.2
0.11.1
0.11.0
0.10.12
0.10.11
0.10.10
retired
0.10.10-rc.1
0.10.10-rc.0
0.10.9
0.10.8
0.10.7
0.10.6
0.10.5
0.10.4
0.10.3
0.10.2
0.10.1
0.10.0
0.9.8
0.9.7
0.9.6
0.9.5
0.9.4
0.9.3
0.9.2
0.9.1
0.9.0
0.8.1
0.8.0
0.7.1
0.7.0
0.6.2
0.6.1
0.6.0-rc.2
0.6.0-rc.1
0.6.0-rc.0
0.5.2
0.5.1-rc.0
0.5.0
0.4.5-rc.0
0.4.4
0.4.2
0.4.0
0.3.0-rc.0
0.2.22
0.2.21
0.2.20
0.2.19
0.2.18
0.2.17
0.2.16-rc.1
0.2.16-rc.0
0.2.15
0.2.14
0.2.13
0.2.12
0.2.11
0.2.10
0.2.9
0.2.8
0.2.7
0.2.6
0.2.5
0.2.4
0.2.3
0.2.1
0.1.6
0.1.5
0.1.3
0.1.2
0.1.0
A super-admin UI for Ash Framework, built with Phoenix LiveView.
Current section
Files
Jump to
Current section
Files
lib/ash_admin/actor_plug/plug.ex
# SPDX-FileCopyrightText: 2020 Zach Daniel
# SPDX-FileCopyrightText: 2020 ash_admin contributors <https://github.com/ash-project/ash_admin/graphs.contributors>
#
# SPDX-License-Identifier: MIT
defmodule AshAdmin.ActorPlug.Plug do
@moduledoc false
@behaviour AshAdmin.ActorPlug
import AshAdmin.Helpers
require Ash.Query
@impl true
def actor_assigns(socket, session) do
otp_app = socket.endpoint.config(:otp_app)
domains = domains(otp_app)
session = Phoenix.LiveView.get_connect_params(socket) || session
[
actor: actor_from_session(socket.endpoint, session),
actor_domain: actor_domain_from_session(socket.endpoint, session),
actor_resources: actor_resources(domains),
actor_paused: session_bool(session["actor_paused"], true),
actor_tenant: session["actor_tenant"],
authorizing: session_bool(session["actor_authorizing"], false),
tenant: session["tenant"]
]
end
@impl true
def set_actor_session(conn) do
conn =
case conn.cookies do
%{"tenant" => tenant} when tenant != "undefined" ->
conn
|> Plug.Conn.put_session(:tenant, tenant)
|> Plug.Conn.assign(:tenant, tenant)
_ ->
conn
end
case conn.cookies do
session = %{
"actor_resource" => resource,
"actor_domain" => domain,
"actor_action" => action,
"actor_primary_key" => primary_key
}
when resource != "undefined" ->
actor = actor_from_session(conn.private.phoenix_endpoint, session)
authorizing = session_bool(session["actor_authorizing"], false)
actor_paused = session_bool(session["actor_paused"], true)
conn
|> Plug.Conn.put_session(:actor_resource, resource)
|> Plug.Conn.put_session(:actor_domain, domain)
|> Plug.Conn.put_session(:actor_action, action)
|> Plug.Conn.put_session(:actor_tenant, session["actor_tenant"])
|> Plug.Conn.put_session(:actor_primary_key, primary_key)
|> Plug.Conn.put_session(:actor_authorizing, authorizing)
|> Plug.Conn.put_session(:actor_paused, actor_paused)
|> Plug.Conn.assign(:actor, actor)
|> Plug.Conn.assign(:actor_tenant, session["actor_tenant"])
|> Plug.Conn.assign(:actor_paused, actor_paused)
|> Plug.Conn.assign(:authorizing, authorizing)
_ ->
conn
end
end
defp session_bool(value, default) do
case value do
"true" ->
true
"false" ->
false
"undefined" ->
false
boolean when is_boolean(boolean) ->
boolean
nil ->
default
end
end
defp actor_resources(domains) do
for domain <- domains,
resource <- AshAdmin.Domain.show_resources(domain),
AshAdmin.Helpers.primary_action(resource, :read) && AshAdmin.Resource.actor?(resource),
do: {domain, resource}
end
defp domains(otp_app) do
otp_app
|> Application.get_env(:ash_domains)
|> Enum.filter(&AshAdmin.Domain.show?/1)
end
defp actor_domain_from_session(endpoint, %{"actor_domain" => domain}) do
endpoint.config(:otp_app)
|> Application.get_env(:ash_domains)
|> Enum.find(&(AshAdmin.Domain.show?(&1) && AshAdmin.Domain.name(&1) == domain))
end
defp actor_domain_from_session(_, _), do: nil
defp actor_from_session(
endpoint,
session = %{
"actor_resource" => resource,
"actor_domain" => domain,
"actor_primary_key" => primary_key,
"actor_action" => action,
"actor_tenant" => tenant
}
)
when not is_nil(resource) and not is_nil(domain) do
domain = actor_domain_from_session(endpoint, session)
resource =
if domain do
domain
|> AshAdmin.Domain.show_resources()
|> Enum.find(&(AshAdmin.Resource.name(&1) == resource))
end
case resource && decode_primary_key(resource, primary_key) do
{:ok, filter} ->
action =
if action do
Ash.Resource.Info.action(resource, String.to_existing_atom(action), :read)
end
actor_load = AshAdmin.Resource.actor_load(resource)
resource
|> Ash.Query.filter(^filter)
|> Ash.Query.set_tenant(tenant)
|> Ash.Query.load(actor_load)
|> Ash.read_one!(action: action, authorize?: false, domain: domain)
_ ->
nil
end
end
defp actor_from_session(_, _), do: nil
end