Packages
ash_authentication_phoenix
3.0.0-rc.6
3.0.0-rc.9
3.0.0-rc.8
3.0.0-rc.7
3.0.0-rc.6
3.0.0-rc.4
3.0.0-rc.3
3.0.0-rc.2
3.0.0-rc.1
3.0.0-rc.0
2.17.2
2.17.1
2.17.0
2.16.0
2.15.0
2.14.1
2.14.0
2.13.1
2.13.0
2.12.2
2.12.1
2.12.0
2.11.0
2.10.5
2.10.4
2.10.3
2.10.2
2.10.1
2.10.0
2.9.0
2.8.0
2.7.0
2.6.3
2.6.2
2.6.1
2.6.0
2.5.4
2.5.3
2.5.2
2.5.1
2.5.0
2.4.8
2.4.7
2.4.6
2.4.5
2.4.4
2.4.3
2.4.2
2.4.1
2.4.0
2.3.0
2.2.1
2.2.0
2.1.11
2.1.10
2.1.9
2.1.8
2.1.7
2.1.6
2.1.5
2.1.4
2.1.3
2.1.2
2.1.1
2.1.0
2.0.2
2.0.1
2.0.0
2.0.0-rc.2
2.0.0-rc.1
2.0.0-rc.0
1.9.4
1.9.3
1.9.2
1.9.1
1.9.0
1.8.7
1.8.6
1.8.5
1.8.4
1.8.3
1.8.2
1.8.1
1.8.0
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.1
1.5.0
1.4.8
1.4.7
1.4.6
1.4.5
1.4.4
1.4.3
1.4.2
1.4.1
1.4.0
1.3.1
1.3.0
1.2.0
1.1.0
1.0.1
1.0.0
Phoenix integration for Ash Authentication
Current section
Files
Jump to
Current section
Files
lib/ash_authentication_phoenix/token_revocation_notifier.ex
# SPDX-FileCopyrightText: 2025 Alembic Pty Ltd
#
# SPDX-License-Identifier: MIT
defmodule AshAuthentication.Phoenix.TokenRevocationNotifier do
@moduledoc """
An Ash notifier that broadcasts LiveView disconnect messages when tokens are revoked.
When a user signs out, this notifier broadcasts a "disconnect" message to all
configured Phoenix endpoints, causing any LiveView sessions using that token's
JTI to be disconnected.
## Configuration
To use this notifier, add it to your token resource and configure the required
DSL options:
defmodule MyApp.Accounts.Token do
use Ash.Resource,
extensions: [AshAuthentication.TokenResource],
simple_notifiers: [AshAuthentication.Phoenix.TokenRevocationNotifier]
token do
endpoints [MyAppWeb.Endpoint]
live_socket_id_template &("users_sessions:\#{&1["jti"]}")
end
end
Then in your auth controller, call `set_live_socket_id/2` on sign-in to set
the socket ID in the session:
def success(conn, _activity, user, token) do
conn
|> store_in_session(user)
|> set_live_socket_id(token)
|> redirect(to: ~p"/")
end
"""
use Ash.Notifier
alias AshAuthentication.TokenResource.Info
@doc false
@spec notify(Ash.Notifier.Notification.t()) :: :ok
def notify(%Ash.Notifier.Notification{
data: %{subject: "user"}
}),
do: :ok
def notify(%Ash.Notifier.Notification{
data: data,
resource: token_resource
}) do
with {:ok, template_fn} <- Info.token_live_socket_id_template(token_resource),
socket_id <- template_fn.(Map.delete(data, :__struct__)),
{:ok, endpoints} when endpoints != [] <- Info.token_endpoints(token_resource) do
Enum.each(endpoints, fn endpoint ->
endpoint.broadcast(socket_id, "disconnect", %{})
end)
end
:ok
end
end