Skip to content

Commit

Permalink
fix: Set tenant for managed relationship changeset (#1044)
Browse files Browse the repository at this point in the history
  • Loading branch information
@jechol
jechol authored Apr 23, 2024
1 parent 18af9d7 commit 184dfb3
Showing 1 changed file with 12 additions and 12 deletions.
24 changes: 12 additions & 12 deletions lib/ash/actions/managed_relationships.ex
View file
Original file line number Diff line number Diff line change
Expand Up @@ -462,12 +462,12 @@ defmodule Ash.Actions.ManagedRelationships do
|> Ash.Changeset.for_create(action_name, input,
require?: false,
actor: actor,
tenant: changeset.tenant,
authorize?: opts[:authorize?],
skip_unknown_inputs: Map.keys(input),
domain: domain(changeset, relationship)
)
|> Ash.Changeset.set_context(relationship.context)
|> Ash.Changeset.set_tenant(changeset.tenant)
|> Ash.create(return_notifications?: true)
|> case do
{:ok, created, notifications} ->
Expand Down Expand Up @@ -961,6 +961,7 @@ defmodule Ash.Actions.ManagedRelationships do
})
|> Ash.Changeset.for_create(create_or_update, join_input,
actor: actor,
tenant: changeset.tenant,
authorize?: opts[:authorize?],
require?: false,
skip_unknown_inputs: Map.keys(join_input),
Expand All @@ -977,7 +978,6 @@ defmodule Ash.Actions.ManagedRelationships do
Map.get(found, relationship.destination_attribute)
)
|> Ash.Changeset.set_context(join_relationship.context)
|> Ash.Changeset.set_tenant(changeset.tenant)
|> Ash.create(return_notifications?: true)
|> case do
{:ok, _created, notifications} ->
Expand Down Expand Up @@ -1036,6 +1036,7 @@ defmodule Ash.Actions.ManagedRelationships do
})
|> Ash.Changeset.for_update(create_or_update, input,
actor: actor,
tenant: changeset.tenant,
authorize?: opts[:authorize?],
skip_unknown_inputs: Map.keys(input),
domain: domain(changeset, relationship)
Expand All @@ -1046,7 +1047,6 @@ defmodule Ash.Actions.ManagedRelationships do
Map.get(record, relationship.source_attribute)
)
|> Ash.Changeset.set_context(relationship.context)
|> Ash.Changeset.set_tenant(changeset.tenant)
|> Ash.update(return_notifications?: true)
|> case do
{:ok, updated, notifications} ->
Expand Down Expand Up @@ -1108,6 +1108,7 @@ defmodule Ash.Actions.ManagedRelationships do
|> Ash.Changeset.for_create(action_name, input,
require?: false,
actor: actor,
tenant: changeset.tenant,
authorize?: opts[:authorize?],
skip_unknown_inputs: Map.keys(input),
domain: domain(changeset, relationship)
Expand All @@ -1118,7 +1119,6 @@ defmodule Ash.Actions.ManagedRelationships do
Map.get(record, relationship.source_attribute)
)
|> Ash.Changeset.set_context(relationship.context)
|> Ash.Changeset.set_tenant(changeset.tenant)
|> Ash.create(return_notifications?: true)
end

Expand Down Expand Up @@ -1172,11 +1172,11 @@ defmodule Ash.Actions.ManagedRelationships do
require?: false,
authorize?: opts[:authorize?],
actor: actor,
tenant: changeset.tenant,
skip_unknown_inputs: Map.keys(regular_params),
domain: domain(changeset, relationship)
)
|> Ash.Changeset.set_context(relationship.context)
|> Ash.Changeset.set_tenant(changeset.tenant)
|> Ash.create(return_notifications?: true)
end

Expand All @@ -1194,6 +1194,7 @@ defmodule Ash.Actions.ManagedRelationships do
require?: false,
authorize?: opts[:authorize?],
actor: actor,
tenant: changeset.tenant,
skip_unknown_inputs: Map.keys(join_params),
domain: domain(changeset, join_relationship)
)
Expand All @@ -1208,7 +1209,6 @@ defmodule Ash.Actions.ManagedRelationships do
Map.get(created, relationship.destination_attribute)
)
|> Ash.Changeset.set_context(join_relationship.context)
|> Ash.Changeset.set_tenant(changeset.tenant)
|> Ash.create(return_notifications?: true)
|> case do
{:ok, _join_row, notifications} ->
Expand Down Expand Up @@ -1319,12 +1319,12 @@ defmodule Ash.Actions.ManagedRelationships do
})
|> Ash.Changeset.for_update(action_name, input,
actor: actor,
tenant: changeset.tenant,
authorize?: opts[:authorize?],
domain: domain,
skip_unknown_inputs: Map.keys(input)
)
|> Ash.Changeset.set_context(relationship.context)
|> Ash.Changeset.set_tenant(changeset.tenant)
|> Ash.update(return_notifications?: true)
|> case do
{:ok, updated, update_notifications} ->
Expand Down Expand Up @@ -1367,12 +1367,12 @@ defmodule Ash.Actions.ManagedRelationships do
})
|> Ash.Changeset.for_update(action_name, regular_params,
actor: actor,
tenant: changeset.tenant,
authorize?: opts[:authorize?],
domain: domain,
skip_unknown_inputs: Map.keys(regular_params)
)
|> Ash.Changeset.set_context(relationship.context)
|> Ash.Changeset.set_tenant(changeset.tenant)
|> Ash.update(return_notifications?: true)
else
{:ok, match, []}
Expand Down Expand Up @@ -1421,12 +1421,12 @@ defmodule Ash.Actions.ManagedRelationships do
})
|> Ash.Changeset.for_update(join_action_name, join_params,
actor: actor,
tenant: changeset.tenant,
authorize?: opts[:authorize?],
skip_unknown_inputs: Map.keys(join_params),
domain: domain(changeset, join_relationship)
)
|> Ash.Changeset.set_context(join_relationship.context)
|> Ash.Changeset.set_tenant(changeset.tenant)
|> Ash.update(return_notifications?: true)
# credo:disable-for-next-line Credo.Check.Refactor.Nesting
|> case do
Expand Down Expand Up @@ -1595,11 +1595,11 @@ defmodule Ash.Actions.ManagedRelationships do
join_action_name,
%{},
actor: actor,
tenant: changeset.tenant,
authorize?: opts[:authorize?],
domain: domain(changeset, join_relationship)
)
|> Ash.Changeset.set_context(join_relationship.context)
|> Ash.Changeset.set_tenant(changeset.tenant)
|> Ash.destroy(return_notifications?: true)
|> case do
{:ok, join_notifications} ->
Expand All @@ -1612,11 +1612,11 @@ defmodule Ash.Actions.ManagedRelationships do
})
|> Ash.Changeset.for_destroy(action_name, %{},
actor: actor,
tenant: changeset.tenant,
authorize?: opts[:authorize?],
domain: domain
)
|> Ash.Changeset.set_context(relationship.context)
|> Ash.Changeset.set_tenant(changeset.tenant)
|> Ash.destroy(return_notifications?: true)
# credo:disable-for-next-line Credo.Check.Refactor.Nesting
|> case do
Expand Down Expand Up @@ -1646,11 +1646,11 @@ defmodule Ash.Actions.ManagedRelationships do
})
|> Ash.Changeset.for_destroy(action_name, %{},
actor: actor,
tenant: changeset.tenant,
authorize?: opts[:authorize?],
domain: domain
)
|> Ash.Changeset.set_context(relationship.context)
|> Ash.Changeset.set_tenant(changeset.tenant)
|> Ash.destroy(return_notifications?: true)
|> case do
{:ok, notifications} ->
Expand Down

0 comments on commit 184dfb3

Please sign in to comment.