mirror of
https://github.com/ash-project/ash_postgres.git
synced 2024-09-20 05:23:18 +12:00
WIP
This commit is contained in:
Zach Daniel
parent
a9aca443a0
commit
a0bea56093
4 changed files with 137 additions and 0 deletions
|
|
@ -401,6 +401,8 @@ defmodule AshPostgres.DataLayer do
|
|||
A postgres data layer that leverages Ecto's postgres capabilities.
|
||||
"""
|
||||
|
||||
require Igniter.Common
|
||||
|
||||
use Spark.Dsl.Extension,
|
||||
sections: @sections,
|
||||
verifiers: [
|
||||
|
|
@ -2943,6 +2945,24 @@ defmodule AshPostgres.DataLayer do
|
|||
end
|
||||
end
|
||||
|
||||
if Code.ensure_loaded?(Igniter) do
|
||||
def install(igniter, module, Ash.Resource, path, _argv) do
|
||||
table_name =
|
||||
module
|
||||
|> Module.split()
|
||||
|> List.last()
|
||||
|> Macro.underscore()
|
||||
|
||||
repo = Igniter.Module.module_name(Repo)
|
||||
|
||||
igniter
|
||||
|> Spark.Igniter.set_option(Ash.Resource, path, [:postgres, :table], table_name, & &1)
|
||||
|> Spark.Igniter.set_option(Ash.Resource, path, [:postgres, :repo], repo, & &1)
|
||||
end
|
||||
|
||||
def install(igniter, _, _, _), do: igniter
|
||||
end
|
||||
|
||||
@impl true
|
||||
def rollback(resource, term) do
|
||||
AshPostgres.DataLayer.Info.repo(resource, :mutate).rollback(term)
|
||||
|
|
|
|||
105
lib/mix/tasks/ash_postgres.install.ex
Normal file
105
lib/mix/tasks/ash_postgres.install.ex
Normal file
|
|
@ -0,0 +1,105 @@
|
|||
defmodule Mix.Tasks.AshPostgres.Install do
|
||||
require Igniter.Common
|
||||
use Igniter.Mix.Task
|
||||
|
||||
def igniter(igniter, argv) do
|
||||
repo = Igniter.Module.module_name("Repo")
|
||||
otp_app = Igniter.Application.app_name()
|
||||
|
||||
igniter
|
||||
|> Igniter.Formatter.import_dep(:ash_postgres)
|
||||
|> setup_repo_module(otp_app, repo)
|
||||
|> Igniter.Config.configure("config.exs", :ash_postgres, [repo, :username], "postgres")
|
||||
end
|
||||
|
||||
defp setup_repo_module(igniter, otp_app, repo) do
|
||||
path = Igniter.Module.proper_location(repo)
|
||||
|
||||
default_repo_contents =
|
||||
"""
|
||||
defmodule #{inspect(repo)} do
|
||||
use AshPostgres.Repo, otp_app: #{inspect(otp_app)}
|
||||
|
||||
def installed_extensions do
|
||||
# Add extensions here, and the migration generator will install them.
|
||||
["ash-functions"]
|
||||
end
|
||||
end
|
||||
"""
|
||||
|
||||
igniter
|
||||
|> Igniter.create_or_update_elixir_file(path, default_repo_contents, fn zipper ->
|
||||
zipper
|
||||
|> set_otp_app(otp_app)
|
||||
|> Sourceror.Zipper.top()
|
||||
|> use_ash_postgres_instead_of_ecto()
|
||||
|> Sourceror.Zipper.top()
|
||||
|> add_installed_extensions_function()
|
||||
|> Sourceror.Zipper.top()
|
||||
|> remove_adapter_option()
|
||||
end)
|
||||
|> Igniter.add_task("ash.codegen")
|
||||
end
|
||||
|
||||
defp use_ash_postgres_instead_of_ecto(zipper) do
|
||||
with {:ok, zipper} <- Igniter.Common.move_to_module_using(zipper, Ecto.Repo),
|
||||
{:ok, zipper} <- Igniter.Common.move_to_use(zipper, Ecto.Repo),
|
||||
{:ok, zipper} <-
|
||||
Igniter.Common.update_nth_argument(zipper, 0, fn _ ->
|
||||
AshPostgres.Repo
|
||||
end) do
|
||||
zipper
|
||||
else
|
||||
_ ->
|
||||
zipper
|
||||
end
|
||||
end
|
||||
|
||||
defp remove_adapter_option(zipper) do
|
||||
with {:ok, zipper} <- Igniter.Common.move_to_module_using(zipper, Ecto.Repo),
|
||||
{:ok, zipper} <- Igniter.Common.move_to_use(zipper, Ecto.Repo),
|
||||
{:ok, zipper} <-
|
||||
Igniter.Common.update_nth_argument(zipper, 1, fn values_zipper ->
|
||||
values_zipper
|
||||
|> Igniter.Common.remove_keyword_key(:adapter)
|
||||
end) do
|
||||
zipper
|
||||
else
|
||||
_ ->
|
||||
zipper
|
||||
end
|
||||
end
|
||||
|
||||
defp set_otp_app(zipper, otp_app) do
|
||||
with {:ok, zipper} <- Igniter.Common.move_to_module_using(zipper, Ecto.Repo),
|
||||
{:ok, zipper} <- Igniter.Common.move_to_use(zipper, Ecto.Repo),
|
||||
{:ok, zipper} <-
|
||||
Igniter.Common.update_nth_argument(zipper, 0, fn _ ->
|
||||
AshPostgres.Repo
|
||||
end),
|
||||
{:ok, zipper} <-
|
||||
Igniter.Common.update_nth_argument(zipper, 1, fn values_zipper ->
|
||||
values_zipper
|
||||
|> Igniter.Common.set_keyword_key(:otp_app, otp_app, fn x -> x end)
|
||||
end) do
|
||||
zipper
|
||||
else
|
||||
_ ->
|
||||
zipper
|
||||
end
|
||||
end
|
||||
|
||||
defp add_installed_extensions_function(zipper) do
|
||||
with {:ok, zipper} <- Igniter.Common.move_to_module_using(zipper, Ecto.Repo) do
|
||||
Igniter.Common.add_code(zipper, """
|
||||
def installed_extensions do
|
||||
# Add extensions here, and the migration generator will install them.
|
||||
["ash-functions"]
|
||||
end
|
||||
""")
|
||||
else
|
||||
_ ->
|
||||
zipper
|
||||
end
|
||||
end
|
||||
end
|
||||
2
mix.exs
2
mix.exs
|
|
@ -164,10 +164,12 @@ defmodule AshPostgres.MixProject do
|
|||
[
|
||||
{:ash, ash_version("~> 3.0 and >= 3.0.7")},
|
||||
{:ash_sql, ash_sql_version("~> 0.2 and >= 0.2.3")},
|
||||
{:igniter, path: "../igniter", optional: true},
|
||||
{:ecto_sql, "~> 3.9"},
|
||||
{:ecto, "~> 3.9"},
|
||||
{:jason, "~> 1.0"},
|
||||
{:postgrex, ">= 0.0.0"},
|
||||
{:spark, path: "../spark", override: true},
|
||||
# dev/test dependencies
|
||||
{:simple_sat, "~> 0.1", only: [:dev, :test]},
|
||||
{:benchee, "~> 1.1", only: [:dev, :test]},
|
||||
|
|
|
|||
10
mix.lock
10
mix.lock
|
|
@ -3,6 +3,7 @@
|
|||
"ash_sql": {:hex, :ash_sql, "0.2.3", "ff2b5e61438f133cc895ed81c1fb76eac05059cd709cb307b9c9a4c9f11ffb5f", [:mix], [{:ash, "~> 3.0", [hex: :ash, repo: "hexpm", optional: false]}, {:ecto, "~> 3.9", [hex: :ecto, repo: "hexpm", optional: false]}, {:ecto_sql, "~> 3.9", [hex: :ecto_sql, repo: "hexpm", optional: false]}], "hexpm", "becbd5e527e33ed49bae7c78513e0136c5a050c143da299b8c0c735e22410c4a"},
|
||||
"benchee": {:hex, :benchee, "1.3.1", "c786e6a76321121a44229dde3988fc772bca73ea75170a73fd5f4ddf1af95ccf", [:mix], [{:deep_merge, "~> 1.0", [hex: :deep_merge, repo: "hexpm", optional: false]}, {:statistex, "~> 1.0", [hex: :statistex, repo: "hexpm", optional: false]}, {:table, "~> 0.1.0", [hex: :table, repo: "hexpm", optional: true]}], "hexpm", "76224c58ea1d0391c8309a8ecbfe27d71062878f59bd41a390266bf4ac1cc56d"},
|
||||
"bunt": {:hex, :bunt, "1.0.0", "081c2c665f086849e6d57900292b3a161727ab40431219529f13c4ddcf3e7a44", [:mix], [], "hexpm", "dc5f86aa08a5f6fa6b8096f0735c4e76d54ae5c9fa2c143e5a1fc7c1cd9bb6b5"},
|
||||
"castore": {:hex, :castore, "1.0.7", "b651241514e5f6956028147fe6637f7ac13802537e895a724f90bf3e36ddd1dd", [:mix], [], "hexpm", "da7785a4b0d2a021cd1292a60875a784b6caef71e76bf4917bdee1f390455cf5"},
|
||||
"comparable": {:hex, :comparable, "1.0.0", "bb669e91cedd14ae9937053e5bcbc3c52bb2f22422611f43b6e38367d94a495f", [:mix], [{:typable, "~> 0.1", [hex: :typable, repo: "hexpm", optional: false]}], "hexpm", "277c11eeb1cd726e7cd41c6c199e7e52fa16ee6830b45ad4cdc62e51f62eb60c"},
|
||||
"credo": {:hex, :credo, "1.7.6", "b8f14011a5443f2839b04def0b252300842ce7388f3af177157c86da18dfbeea", [:mix], [{:bunt, "~> 0.2.1 or ~> 1.0", [hex: :bunt, repo: "hexpm", optional: false]}, {:file_system, "~> 0.2 or ~> 1.0", [hex: :file_system, repo: "hexpm", optional: false]}, {:jason, "~> 1.0", [hex: :jason, repo: "hexpm", optional: false]}], "hexpm", "146f347fb9f8cbc5f7e39e3f22f70acbef51d441baa6d10169dd604bfbc55296"},
|
||||
"db_connection": {:hex, :db_connection, "2.6.0", "77d835c472b5b67fc4f29556dee74bf511bbafecdcaf98c27d27fa5918152086", [:mix], [{:telemetry, "~> 0.4 or ~> 1.0", [hex: :telemetry, repo: "hexpm", optional: false]}], "hexpm", "c2f992d15725e721ec7fbc1189d4ecdb8afef76648c746a8e1cad35e3b8a35f3"},
|
||||
|
|
@ -17,17 +18,26 @@
|
|||
"ex_check": {:hex, :ex_check, "0.16.0", "07615bef493c5b8d12d5119de3914274277299c6483989e52b0f6b8358a26b5f", [:mix], [], "hexpm", "4d809b72a18d405514dda4809257d8e665ae7cf37a7aee3be6b74a34dec310f5"},
|
||||
"ex_doc": {:git, "https://github.com/elixir-lang/ex_doc.git", "a663c13478a49d29ae0267b6e45badb803267cf0", []},
|
||||
"file_system": {:hex, :file_system, "1.0.0", "b689cc7dcee665f774de94b5a832e578bd7963c8e637ef940cd44327db7de2cd", [:mix], [], "hexpm", "6752092d66aec5a10e662aefeed8ddb9531d79db0bc145bb8c40325ca1d8536d"},
|
||||
"finch": {:hex, :finch, "0.18.0", "944ac7d34d0bd2ac8998f79f7a811b21d87d911e77a786bc5810adb75632ada4", [:mix], [{:castore, "~> 0.1 or ~> 1.0", [hex: :castore, repo: "hexpm", optional: false]}, {:mime, "~> 1.0 or ~> 2.0", [hex: :mime, repo: "hexpm", optional: false]}, {:mint, "~> 1.3", [hex: :mint, repo: "hexpm", optional: false]}, {:nimble_options, "~> 0.4 or ~> 1.0", [hex: :nimble_options, repo: "hexpm", optional: false]}, {:nimble_pool, "~> 0.2.6 or ~> 1.0", [hex: :nimble_pool, repo: "hexpm", optional: false]}, {:telemetry, "~> 0.4 or ~> 1.0", [hex: :telemetry, repo: "hexpm", optional: false]}], "hexpm", "69f5045b042e531e53edc2574f15e25e735b522c37e2ddb766e15b979e03aa65"},
|
||||
"git_cli": {:hex, :git_cli, "0.3.0", "a5422f9b95c99483385b976f5d43f7e8233283a47cda13533d7c16131cb14df5", [:mix], [], "hexpm", "78cb952f4c86a41f4d3511f1d3ecb28edb268e3a7df278de2faa1bd4672eaf9b"},
|
||||
"git_ops": {:hex, :git_ops, "2.6.1", "cc7799a68c26cf814d6d1a5121415b4f5bf813de200908f930b27a2f1fe9dad5", [:mix], [{:git_cli, "~> 0.2", [hex: :git_cli, repo: "hexpm", optional: false]}, {:nimble_parsec, "~> 1.0", [hex: :nimble_parsec, repo: "hexpm", optional: false]}], "hexpm", "ce62d07e41fe993ec22c35d5edb11cf333a21ddaead6f5d9868fcb607d42039e"},
|
||||
"glob_ex": {:hex, :glob_ex, "0.1.7", "eae6b6377147fb712ac45b360e6dbba00346689a87f996672fe07e97d70597b1", [:mix], [], "hexpm", "decc1c21c0c73df3c9c994412716345c1692477b9470e337f628a7e08da0da6a"},
|
||||
"hpax": {:hex, :hpax, "0.2.0", "5a58219adcb75977b2edce5eb22051de9362f08236220c9e859a47111c194ff5", [:mix], [], "hexpm", "bea06558cdae85bed075e6c036993d43cd54d447f76d8190a8db0dc5893fa2f1"},
|
||||
"jason": {:hex, :jason, "1.4.1", "af1504e35f629ddcdd6addb3513c3853991f694921b1b9368b0bd32beb9f1b63", [:mix], [{:decimal, "~> 1.0 or ~> 2.0", [hex: :decimal, repo: "hexpm", optional: true]}], "hexpm", "fbb01ecdfd565b56261302f7e1fcc27c4fb8f32d56eab74db621fc154604a7a1"},
|
||||
"libgraph": {:hex, :libgraph, "0.16.0", "3936f3eca6ef826e08880230f806bfea13193e49bf153f93edcf0239d4fd1d07", [:mix], [], "hexpm", "41ca92240e8a4138c30a7e06466acc709b0cbb795c643e9e17174a178982d6bf"},
|
||||
"makeup": {:hex, :makeup, "1.1.0", "6b67c8bc2882a6b6a445859952a602afc1a41c2e08379ca057c0f525366fc3ca", [:mix], [{:nimble_parsec, "~> 1.2.2 or ~> 1.3", [hex: :nimble_parsec, repo: "hexpm", optional: false]}], "hexpm", "0a45ed501f4a8897f580eabf99a2e5234ea3e75a4373c8a52824f6e873be57a6"},
|
||||
"makeup_elixir": {:hex, :makeup_elixir, "0.16.1", "cc9e3ca312f1cfeccc572b37a09980287e243648108384b97ff2b76e505c3555", [:mix], [{:makeup, "~> 1.0", [hex: :makeup, repo: "hexpm", optional: false]}, {:nimble_parsec, "~> 1.2.3 or ~> 1.3", [hex: :nimble_parsec, repo: "hexpm", optional: false]}], "hexpm", "e127a341ad1b209bd80f7bd1620a15693a9908ed780c3b763bccf7d200c767c6"},
|
||||
"makeup_erlang": {:hex, :makeup_erlang, "0.1.2", "ad87296a092a46e03b7e9b0be7631ddcf64c790fa68a9ef5323b6cbb36affc72", [:mix], [{:makeup, "~> 1.0", [hex: :makeup, repo: "hexpm", optional: false]}], "hexpm", "f3f5a1ca93ce6e092d92b6d9c049bcda58a3b617a8d888f8e7231c85630e8108"},
|
||||
"mime": {:hex, :mime, "2.0.5", "dc34c8efd439abe6ae0343edbb8556f4d63f178594894720607772a041b04b02", [:mix], [], "hexpm", "da0d64a365c45bc9935cc5c8a7fc5e49a0e0f9932a761c55d6c52b142780a05c"},
|
||||
"mint": {:hex, :mint, "1.6.0", "88a4f91cd690508a04ff1c3e28952f322528934be541844d54e0ceb765f01d5e", [:mix], [{:castore, "~> 0.1.0 or ~> 1.0", [hex: :castore, repo: "hexpm", optional: true]}, {:hpax, "~> 0.1.1 or ~> 0.2.0", [hex: :hpax, repo: "hexpm", optional: false]}], "hexpm", "3c5ae85d90a5aca0a49c0d8b67360bbe407f3b54f1030a111047ff988e8fefaa"},
|
||||
"mix_audit": {:hex, :mix_audit, "2.1.3", "c70983d5cab5dca923f9a6efe559abfb4ec3f8e87762f02bab00fa4106d17eda", [:make, :mix], [{:jason, "~> 1.1", [hex: :jason, repo: "hexpm", optional: false]}, {:yaml_elixir, "~> 2.9", [hex: :yaml_elixir, repo: "hexpm", optional: false]}], "hexpm", "8c3987100b23099aea2f2df0af4d296701efd031affb08d0746b2be9e35988ec"},
|
||||
"nimble_options": {:hex, :nimble_options, "1.1.1", "e3a492d54d85fc3fd7c5baf411d9d2852922f66e69476317787a7b2bb000a61b", [:mix], [], "hexpm", "821b2470ca9442c4b6984882fe9bb0389371b8ddec4d45a9504f00a66f650b44"},
|
||||
"nimble_parsec": {:hex, :nimble_parsec, "1.4.0", "51f9b613ea62cfa97b25ccc2c1b4216e81df970acd8e16e8d1bdc58fef21370d", [:mix], [], "hexpm", "9c565862810fb383e9838c1dd2d7d2c437b3d13b267414ba6af33e50d2d1cf28"},
|
||||
"nimble_pool": {:hex, :nimble_pool, "1.1.0", "bf9c29fbdcba3564a8b800d1eeb5a3c58f36e1e11d7b7fb2e084a643f645f06b", [:mix], [], "hexpm", "af2e4e6b34197db81f7aad230c1118eac993acc0dae6bc83bac0126d4ae0813a"},
|
||||
"postgrex": {:hex, :postgrex, "0.18.0", "f34664101eaca11ff24481ed4c378492fed2ff416cd9b06c399e90f321867d7e", [:mix], [{:db_connection, "~> 2.1", [hex: :db_connection, repo: "hexpm", optional: false]}, {:decimal, "~> 1.5 or ~> 2.0", [hex: :decimal, repo: "hexpm", optional: false]}, {:jason, "~> 1.0", [hex: :jason, repo: "hexpm", optional: true]}, {:table, "~> 0.1.0", [hex: :table, repo: "hexpm", optional: true]}], "hexpm", "a042989ba1bc1cca7383ebb9e461398e3f89f868c92ce6671feb7ef132a252d1"},
|
||||
"reactor": {:hex, :reactor, "0.8.4", "344d02ba4a0010763851f4e4aa0ff190ebe7e392e3c27c6cd143dde077b986e7", [:mix], [{:libgraph, "~> 0.16", [hex: :libgraph, repo: "hexpm", optional: false]}, {:spark, "~> 2.0", [hex: :spark, repo: "hexpm", optional: false]}, {:splode, "~> 0.2", [hex: :splode, repo: "hexpm", optional: false]}, {:telemetry, "~> 1.2", [hex: :telemetry, repo: "hexpm", optional: false]}], "hexpm", "49c1fd3c786603cec8140ce941c41c7ea72cc4411860ccdee9876c4ca2204f81"},
|
||||
"req": {:hex, :req, "0.5.0", "6d8a77c25cfc03e06a439fb12ffb51beade53e3fe0e2c5e362899a18b50298b3", [:mix], [{:brotli, "~> 0.3.1", [hex: :brotli, repo: "hexpm", optional: true]}, {:ezstd, "~> 1.0", [hex: :ezstd, repo: "hexpm", optional: true]}, {:finch, "~> 0.17", [hex: :finch, repo: "hexpm", optional: false]}, {:jason, "~> 1.0", [hex: :jason, repo: "hexpm", optional: false]}, {:mime, "~> 1.6 or ~> 2.0", [hex: :mime, repo: "hexpm", optional: false]}, {:nimble_csv, "~> 1.0", [hex: :nimble_csv, repo: "hexpm", optional: true]}, {:plug, "~> 1.0", [hex: :plug, repo: "hexpm", optional: true]}], "hexpm", "dda04878c1396eebbfdec6db6f3d4ca609e5c8846b7ee88cc56eb9891406f7a3"},
|
||||
"rewrite": {:hex, :rewrite, "0.10.4", "09e3a18e7e2d2ad0875afa9d27d9b60efd156c0f2f9f0ef2ff585504bc378efb", [:mix], [{:glob_ex, "~> 0.1", [hex: :glob_ex, repo: "hexpm", optional: false]}, {:sourceror, "~> 1.0", [hex: :sourceror, repo: "hexpm", optional: false]}], "hexpm", "93cd0ab5441d77413d569567f7430844e2d10484b139aa5326786ad4d0481ef0"},
|
||||
"simple_sat": {:hex, :simple_sat, "0.1.3", "f650fc3c184a5fe741868b5ac56dc77fdbb428468f6dbf1978e14d0334497578", [:mix], [], "hexpm", "a54305066a356b7194dc81db2a89232bacdc0b3edaef68ed9aba28dcbc34887b"},
|
||||
"sobelow": {:hex, :sobelow, "0.13.0", "218afe9075904793f5c64b8837cc356e493d88fddde126a463839351870b8d1e", [:mix], [{:jason, "~> 1.0", [hex: :jason, repo: "hexpm", optional: false]}], "hexpm", "cd6e9026b85fc35d7529da14f95e85a078d9dd1907a9097b3ba6ac7ebbe34a0d"},
|
||||
"sourceror": {:hex, :sourceror, "1.2.1", "b415255ad8bd05f0e859bb3d7ea617f6c2a4a405f2a534a231f229bd99b89f8b", [:mix], [], "hexpm", "e4d97087e67584a7585b5fe3d5a71bf8e7332f795dd1a44983d750003d5e750c"},
|
||||
|
|
|
|||
Loading…
Reference in a new issue