ash-project/ash
1
0
Fork 0
mirror of https://github.com/ash-project/ash.git synced 2024-09-20 13:33:20 +12:00
Code Issues Projects Releases Packages Wiki Activity

improvement: always update the join relationship

Browse source
This commit is contained in:
Zach Daniel 2023-12-28 15:04:00 -05:00
parent 40aa17eab8
commit c3e192c6d8
1 changed files with 27 additions and 31 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

58
lib/ash/actions/managed_relationships.ex
View file

@ -1350,39 +1350,35 @@ defmodule Ash.Actions.ManagedRelationships do
) )
|> case do |> case do
{:ok, result} -> {:ok, result} ->
if join_params == %{} do join_relationship =
{:ok, [updated | current_value], update_notifications, [match]} Ash.Resource.Info.relationship(
else relationship.source,
join_relationship = relationship.join_relationship
Ash.Resource.Info.relationship(
relationship.source,
relationship.join_relationship
)
result
|> Ash.Changeset.new()
|> Ash.Changeset.set_context(%{
accessing_from: %{
source: join_relationship.source,
name: join_relationship.name
}
})
|> Ash.Changeset.for_update(join_action_name, join_params,
actor: actor,
authorize?: opts[:authorize?]
) )
|> Ash.Changeset.set_context(join_relationship.context)
|> Ash.Changeset.set_tenant(changeset.tenant)
|> api(changeset, join_relationship).update(return_notifications?: true)
# credo:disable-for-next-line Credo.Check.Refactor.Nesting
|> case do
{:ok, _updated_join, join_update_notifications} ->
{:ok, [updated | current_value],
update_notifications ++ join_update_notifications, [updated]}
{:error, error} -> result
{:error, error} |> Ash.Changeset.new()
end |> Ash.Changeset.set_context(%{
accessing_from: %{
source: join_relationship.source,
name: join_relationship.name
}
})
|> Ash.Changeset.for_update(join_action_name, join_params,
actor: actor,
authorize?: opts[:authorize?]
)
|> Ash.Changeset.set_context(join_relationship.context)
|> Ash.Changeset.set_tenant(changeset.tenant)
|> api(changeset, join_relationship).update(return_notifications?: true)
# credo:disable-for-next-line Credo.Check.Refactor.Nesting
|> case do
{:ok, _updated_join, join_update_notifications} ->
{:ok, [updated | current_value],
update_notifications ++ join_update_notifications, [updated]}
{:error, error} ->
{:error, error}
end end
{:error, error} -> {:error, error} ->