my git push failed and I didn’t notice. Try again
zachdaniel
Creator of Ash
drikanius
Real-time support 
✗ mix compile
==> ash_postgres
Compiling 45 files (.ex)
error: undefined variable "keys"
│
2145 │ Ecto.Changeset.unique_constraint(changeset, keys, opts)
│ ^^^^
│
└─ lib/data_layer.ex:2145:53: AshPostgres.DataLayer.add_unique_indexes/3
== Compilation error in file lib/data_layer.ex ==
** (CompileError) lib/data_layer.ex: cannot compile module AshPostgres.DataLayer (errors have been logged)
could not compile dependency :ash_postgres, "mix compile" failed. Errors may have been logged above. You can recompile this dependency with "mix deps.compile ash_postgres --force", update it with "mix deps.update ash_postgres" or clean it with "mix deps.clean ash_postgres"
0
zachdaniel
Creator of Ash
drikanius
Yay! At least now the error has changed (printing debug just because):
[debug] QUERY OK source="transactions" db=2.1ms
INSERT INTO "carbonite_default"."transactions" ("meta","inserted_at") VALUES ($1,$2) ON CONFLICT ("id") DO UPDATE SET "id" = EXCLUDED."id" RETURNING "inserted_at","meta","xact_id","id" [%{type: "update_view_count", actor: nil}, ~U[2024-02-01 20:22:04.037630Z]]
[debug] QUERY OK db=0.2ms
rollback []
** (Ash.Error.Unknown) Unknown Error
* ** (KeyError) key :resource not found in: #Ecto.Changeset<
action: nil,
changes: %{updated_at: ~U[2024-02-01 20:22:04.040457Z], view_count: 1},
errors: [],
data: #Marketplace.Markets.Property<>,
valid?: true
>
(ash_postgres 1.4.0) lib/data_layer.ex:2120: AshPostgres.DataLayer.add_unique_indexes/3
(ash_postgres 1.4.0) lib/data_layer.ex:1736: AshPostgres.DataLayer.ecto_changeset/5
(ash_postgres 1.4.0) lib/data_layer.ex:2330: AshPostgres.DataLayer.update/2
(ash 2.18.1) lib/ash/actions/update/update.ex:366: anonymous fn/5 in Ash.Actions.Update.commit/3
(ash 2.18.1) lib/ash/changeset/changeset.ex:2823: Ash.Changeset.run_around_actions/2
(ash 2.18.1) lib/ash/changeset/changeset.ex:2406: anonymous fn/3 in Ash.Changeset.with_hooks/3
(ecto_sql 3.11.1) lib/ecto/adapters/sql.ex:1358: anonymous fn/3 in Ecto.Adapters.SQL.checkout_or_transaction/4
(db_connection 2.6.0) lib/db_connection.ex:1710: DBConnection.run_transaction/4
(ash 2.18.1) lib/ash/changeset/changeset.ex:2404: anonymous fn/3 in Ash.Changeset.with_hooks/3
(ash 2.18.1) lib/ash/changeset/changeset.ex:2543: anonymous fn/2 in Ash.Changeset.transaction_hooks/2
(ash 2.18.1) lib/ash/changeset/changeset.ex:2385: Ash.Changeset.with_hooks/3
(ash 2.18.1) lib/ash/actions/update/update.ex:289: Ash.Actions.Update.commit/3
(ash 2.18.1) lib/ash/actions/update/update.ex:176: Ash.Actions.Update.do_run/4
(ash 2.18.1) lib/ash/actions/update/update.ex:135: Ash.Actions.Update.run/4
(marketplace 1.19.0) lib/marketplace/markets.ex:1: Marketplace.Markets.update/2
(stdlib 5.0.2) erl_eval.erl:746: :erl_eval.do_apply/7
(elixir 1.16.0) src/elixir.erl:378: :elixir.eval_forms/4
(elixir 1.16.0) lib/module/parallel_checker.ex:112: Module.ParallelChecker.verify/1
(iex 1.16.0) lib/iex/evaluator.ex:331: IEx.Evaluator.eval_and_inspect/3
(iex 1.16.0) lib/iex/evaluator.ex:305: IEx.Evaluator.eval_and_inspect_parsed/3
(iex 1.16.0) lib/iex/evaluator.ex:294: IEx.Evaluator.parse_eval_inspect/4
(iex 1.16.0) lib/iex/evaluator.ex:187: IEx.Evaluator.loop/1
(iex 1.16.0) lib/iex/evaluator.ex:32: IEx.Evaluator.init/5
(stdlib 5.0.2) proc_lib.erl:241: :proc_lib.init_p_do_apply/3
(ash_postgres 1.4.0) lib/data_layer.ex:2120: AshPostgres.DataLayer.add_unique_indexes/3
(ash_postgres 1.4.0) lib/data_layer.ex:1736: AshPostgres.DataLayer.ecto_changeset/5
(ash_postgres 1.4.0) lib/data_layer.ex:2330: AshPostgres.DataLayer.update/2
(ash 2.18.1) lib/ash/actions/update/update.ex:366: anonymous fn/5 in Ash.Actions.Update.commit/3
(ash 2.18.1) lib/ash/changeset/changeset.ex:2823: Ash.Changeset.run_around_actions/2
(ash 2.18.1) lib/ash/changeset/changeset.ex:2406: anonymous fn/3 in Ash.Changeset.with_hooks/3
(ecto_sql 3.11.1) lib/ecto/adapters/sql.ex:1358: anonymous fn/3 in Ecto.Adapters.SQL.checkout_or_transaction/4
(db_connection 2.6.0) lib/db_connection.ex:1710: DBConnection.run_transaction/4
(ash 2.18.1) lib/ash/changeset/changeset.ex:2404: anonymous fn/3 in Ash.Changeset.with_hooks/3
(ash 2.18.1) lib/ash/changeset/changeset.ex:2543: anonymous fn/2 in Ash.Changeset.transaction_hooks/2
(ash 2.18.1) lib/ash/changeset/changeset.ex:2385: Ash.Changeset.with_hooks/3
(ash 2.18.1) lib/ash/actions/update/update.ex:289: Ash.Actions.Update.commit/3
(ash 2.18.1) lib/ash/actions/update/update.ex:176: Ash.Actions.Update.do_run/4
(ash 2.18.1) lib/ash/actions/update/update.ex:135: Ash.Actions.Update.run/4
(marketplace 1.19.0) lib/marketplace/markets.ex:1: Marketplace.Markets.update/2
0
zachdaniel
Creator of Ash
zachdaniel
Creator of Ash
Not normally this all over the place, but I’m presently working on about 6 different things. Sorry bout that 
0
drikanius
No problem sr. If I’m bothering you, I can go back to the stable version. I’m only using main because I had the problem with 2 databases and migration was crazy.
But I think now we get back to the prevous error:
** (Ash.Error.Unknown) Unknown Error
* ** (FunctionClauseError) no function clause matching in Ecto.Changeset.unique_constraint/3
(ecto 3.11.1) Ecto.Changeset.unique_constraint(#Ecto.Changeset<action: nil, changes: %{updated_at: ~U[2024-02-01 20:31:08.375531Z], view_count: 1}, errors: [], data: #Marketplace.Markets.Property<>, valid?: true>, [], [name: "properties_normalized_full_address_gin_trgm_ops"])
(elixir 1.16.0) lib/enum.ex:2528: Enum."-reduce/3-lists^foldl/2-0-"/3
(ash_postgres 1.4.0) lib/data_layer.ex:2152: AshPostgres.DataLayer.add_unique_indexes/3
(ash_postgres 1.4.0) lib/data_layer.ex:1736: AshPostgres.DataLayer.ecto_changeset/5
(ash_postgres 1.4.0) lib/data_layer.ex:2330: AshPostgres.DataLayer.update/2
(ash 2.18.1) lib/ash/actions/update/update.ex:366: anonymous fn/5 in Ash.Actions.Update.commit/3
(ash 2.18.1) lib/ash/changeset/changeset.ex:2823: Ash.Changeset.run_around_actions/2
(ash 2.18.1) lib/ash/changeset/changeset.ex:2406: anonymous fn/3 in Ash.Changeset.with_hooks/3
(ecto_sql 3.11.1) lib/ecto/adapters/sql.ex:1358: anonymous fn/3 in Ecto.Adapters.SQL.checkout_or_transaction/4
(db_connection 2.6.0) lib/db_connection.ex:1710: DBConnection.run_transaction/4
(ash 2.18.1) lib/ash/changeset/changeset.ex:2404: anonymous fn/3 in Ash.Changeset.with_hooks/3
(ash 2.18.1) lib/ash/changeset/changeset.ex:2543: anonymous fn/2 in Ash.Changeset.transaction_hooks/2
(ash 2.18.1) lib/ash/changeset/changeset.ex:2385: Ash.Changeset.with_hooks/3
(ash 2.18.1) lib/ash/actions/update/update.ex:289: Ash.Actions.Update.commit/3
(ash 2.18.1) lib/ash/actions/update/update.ex:176: Ash.Actions.Update.do_run/4
(ash 2.18.1) lib/ash/actions/update/update.ex:135: Ash.Actions.Update.run/4
(marketplace 1.19.0) lib/marketplace/markets.ex:1: Marketplace.Markets.update/2
(stdlib 5.0.2) erl_eval.erl:746: :erl_eval.do_apply/7
(elixir 1.16.0) src/elixir.erl:378: :elixir.eval_forms/4
(elixir 1.16.0) lib/module/parallel_checker.ex:112: Module.ParallelChecker.verify/1
(iex 1.16.0) lib/iex/evaluator.ex:331: IEx.Evaluator.eval_and_inspect/3
(iex 1.16.0) lib/iex/evaluator.ex:305: IEx.Evaluator.eval_and_inspect_parsed/3
(iex 1.16.0) lib/iex/evaluator.ex:294: IEx.Evaluator.parse_eval_inspect/4
(iex 1.16.0) lib/iex/evaluator.ex:187: IEx.Evaluator.loop/1
(iex 1.16.0) lib/iex/evaluator.ex:32: IEx.Evaluator.init/5
(stdlib 5.0.2) proc_lib.erl:241: :proc_lib.init_p_do_apply/3
(ecto 3.11.1) Ecto.Changeset.unique_constraint(#Ecto.Changeset<action: nil, changes: %{updated_at: ~U[2024-02-01 20:31:08.375531Z], view_count: 1}, errors: [], data: #Marketplace.Markets.Property<>, valid?: true>, [], [name: "properties_normalized_full_address_gin_trgm_ops"])
(elixir 1.16.0) lib/enum.ex:2528: Enum."-reduce/3-lists^foldl/2-0-"/3
(ash_postgres 1.4.0) lib/data_layer.ex:2152: AshPostgres.DataLayer.add_unique_indexes/3
(ash_postgres 1.4.0) lib/data_layer.ex:1736: AshPostgres.DataLayer.ecto_changeset/5
(ash_postgres 1.4.0) lib/data_layer.ex:2330: AshPostgres.DataLayer.update/2
(ash 2.18.1) lib/ash/actions/update/update.ex:366: anonymous fn/5 in Ash.Actions.Update.commit/3
(ash 2.18.1) lib/ash/changeset/changeset.ex:2823: Ash.Changeset.run_around_actions/2
(ash 2.18.1) lib/ash/changeset/changeset.ex:2406: anonymous fn/3 in Ash.Changeset.with_hooks/3
(ecto_sql 3.11.1) lib/ecto/adapters/sql.ex:1358: anonymous fn/3 in Ecto.Adapters.SQL.checkout_or_transaction/4
(db_connection 2.6.0) lib/db_connection.ex:1710: DBConnection.run_transaction/4
(ash 2.18.1) lib/ash/changeset/changeset.ex:2404: anonymous fn/3 in Ash.Changeset.with_hooks/3
(ash 2.18.1) lib/ash/changeset/changeset.ex:2543: anonymous fn/2 in Ash.Changeset.transaction_hooks/2
(ash 2.18.1) lib/ash/changeset/changeset.ex:2385: Ash.Changeset.with_hooks/3
(ash 2.18.1) lib/ash/actions/update/update.ex:289: Ash.Actions.Update.commit/3
(ash 2.18.1) lib/ash/actions/update/update.ex:176: Ash.Actions.Update.do_run/4
(ash 2.18.1) lib/ash/actions/update/update.ex:135: Ash.Actions.Update.run/4
(marketplace 1.19.0) lib/marketplace/markets.ex:1: Marketplace.Markets.update/2
0
zachdaniel
Creator of Ash
zachdaniel
Creator of Ash
Where does this: properties_normalized_full_address_gin_trgm_ops come from? I’m assuming thats something you’ve added manually?
0
drikanius
Well I was removing part of the code and miss-click, but yeah, properties_normalized_full_address_gin_trm_ops is a custom index
defmodule Marketplace.Markets.Property do
@moduledoc false
# alias ...
use Ash.Resource,
data_layer: AshPostgres.DataLayer,
authorizers: [Ash.Policy.Authorizer],
extensions: [AshGraphql.Resource, AshRbac],
notifiers: [Ash.Notifier.PubSub]
require Ash.Query
code_interface do
define_for Marketplace.Markets
# define ...
end
attributes do
alias Marketplace.Ash.Types.Currency
uuid_primary_key :id
attribute :street, :string, allow_nil?: false
attribute :house_number, :string, allow_nil?: false
attribute :city, :string, allow_nil?: false
attribute :county, :string, allow_nil?: false
attribute :state, :string do
allow_nil? false
constraints max_length: 2, min_length: 2
end
attribute :zip, :string, allow_nil?: false
attribute :country, :string do
allow_nil? false
default "USA"
end
attribute :normalized_full_address, :string, allow_nil?: false, generated?: true
attribute :view_count, :integer, default: 0
attribute :showing, Showing, allow_nil?: false, default: %{}
attribute :over_under_paid, Currency
attribute :adj_mao, Currency
attribute :opened_at, :utc_datetime, default: &DateTime.utc_now/0
timestamps(private?: false)
end
calculations do
alias Markets.Offer
calculate :full_address,
:string,
expr(
house_number <> " " <> street <> " - " <> city <> ", " <> state <> " - " <> zip
)
calculate :offeror_current_offer, Offer, Calculations.GetCurrentOfferor
calculate :favorite?,
:boolean,
expr(
exists(property_user_activities, user_id == ^actor(:id) and favorited? == true)
)
calculate :total_unique_offers, Offer, Calculations.TotalUniqueOffers
end
preparations do
prepare build(load: [:full_address, :favorite?])
end
aggregates do
first :last_offer, :offers, :updated_at do
sort updated_at: :desc
end
count :total_valid_offer, :offers do
filter expr(status in [:submitted, :evaluating, :accepted])
end
count :favorite_count, :user_activities
count :total_offers, :offers do
filter expr(status in [:submitted, :evaluating, :accepted])
end
max :max_offer, :offers, :price do
filter expr(status in [:submitted, :evaluating, :accepted])
end
end
relationships do
alias Markets.{Offer, Organization, PropertyUserActivity, User}
has_many :offers, Offer
belongs_to :disposition_agent, User do
allow_nil? true
attribute_writable? true
end
belongs_to :organization, Organization do
allow_nil? false
attribute_writable? true
end
many_to_many :user_activities, User do
through PropertyUserActivity
join_relationship :property_user_activities
source_attribute_on_join_resource :property_id
destination_attribute_on_join_resource :user_id
end
end
rbac do
#...
end
policies do
#...
end
changes do
alias Marketplace.Common.Property.Actions.Changes
change {Marketplace.Ash.Changes.Audit, meta: %{actor: actor(:id)}},
on: [:create, :update, :destroy]
change Actions.Common.Changes.SendTelemetryEvent,
on: [:create, :update, :destroy]
change Changes.CalculateOverUnderPaid, on: [:create, :update, :destroy]
end
graphql do
type :property
field_names favorite?: :is_favorite
queries do
get :get_valid_property, :get_valid
list :list_valid_properties, :read_valids
list :list_favorites, :list_user_favorites
end
mutations do
update :set_as_favorite, :set_as_favorite
update :remove_from_favorite, :remove_from_favorite
end
end
pub_sub do
module MarketplaceWeb.Endpoint
prefix "property"
publish :update, [:id], event: "property_updated"
publish :update_images, [:id], event: "property_updated"
end
postgres do
table "properties"
repo Marketplace.Repo
migration_defaults images: "[]", metadata: "%{}", showing: "%{}"
migration_ignore_attributes [:normalized_full_address]
custom_indexes do
index ["normalized_full_address gin_trgm_ops"],
using: "gin",
name: "properties_normalized_full_address_gin_trgm_ops"
index [:view_count]
end
custom_statements do
statement :create_normalized_full_address_field do
up """
alter table properties add column normalized_full_address varchar (255) generated always as
(
lower(
btrim(
regexp_replace(
coalesce(house_number, '') || ' ' ||
coalesce(street, '') || ' ' ||
coalesce(city, '') || ' ' ||
coalesce(county, '') || ' ' ||
state || ' ' ||
country || ' ' ||
coalesce(zip, ''),
'\\s+', ' ', 'g'
)
)
)
)
stored;
"""
down "alter table properties drop column normalized_full_address;"
end
end
end
actions do
alias Marketplace.Markets.Common.Changelog
defaults [:read]
create :create do
alias Actions.Create.Changes
primary? true
argument :uploaded_images, {:array, :map}, allow_nil?: false
argument :removed_images, {:array, :map}, allow_nil?: false
argument :disposition_agent, :uuid, allow_nil?: false
change Changes.MaybeCreateProcessImagesJob
change Changes.MaybeIgnoreOffMarket
change Changes.AddOrganizationFromActor
change Changes.AddDispositionAgent
change load([:full_address, :last_offer, :total_valid_offer])
end
update :update do
alias Actions.Update.{Changes, Validations}
primary? true
argument :uploaded_images, {:array, :map}, allow_nil?: false, default: []
argument :removed_images, {:array, :map}, allow_nil?: false, default: []
argument :disposition_agent, :uuid, allow_nil?: true
validate Validations.IsNotProcessing
change Changes.MaybeCreateProcessImagesJob
change Changes.MaybeIgnoreOffMarket
change Changes.MaybeUpdateProForma
change Changes.MaybeUpdateOverUnderPaid
change Changes.AddDispositionAgent
change load([:full_address, :last_offer, :total_valid_offer])
end
update :update_view_count do
argument :view_count, :integer, allow_nil?: false
change set_attribute(:view_count, arg(:view_count))
end
end
end
0