Packages
phoenix_ecto
4.2.0
4.7.0
4.6.6
4.6.5
4.6.4
4.6.3
4.6.2
4.6.1
4.6.0
4.5.1
4.5.0
4.4.3
4.4.2
4.4.1
4.4.0
4.3.0
4.2.1
4.2.0
4.1.0
4.0.0
3.6.0
3.5.0
retired
3.4.0
3.3.0
3.2.3
3.2.2
3.2.1
3.2.0
3.1.0
3.1.0-rc.0
3.0.1
3.0.0
3.0.0-rc.0
3.0.0-beta.2
3.0.0-beta.1
3.0.0-beta.0
2.0.3
2.0.2
2.0.1
2.0.0
1.2.0
1.1.0
1.0.0
0.9.0
0.8.1
0.8.0
0.7.0
0.6.0
0.5.0
0.4.0
0.3.2
0.3.1
0.3.0
0.2.0
0.1.0
Integration between Phoenix & Ecto
Current section
Files
Jump to
Current section
Files
lib/phoenix_ecto/check_repo_status.ex
defmodule Phoenix.Ecto.CheckRepoStatus do
@moduledoc """
A plug that does some checks on your application repos.
Checks if the storage is up (database is created) or if there are any pending migrations.
Both checks can raise an error if the conditions are not met.
## Plug options
* `:otp_app` - name of the application which the repos are fetched from
"""
@behaviour Plug
alias Plug.Conn
def init(opts) do
Keyword.fetch!(opts, :otp_app)
opts
end
def call(%Conn{} = conn, opts) do
repos = Application.get_env(opts[:otp_app], :ecto_repos, [])
for repo <- repos, Process.whereis(repo) do
check_storage_up!(repo)
check_pending_migrations!(repo, opts)
end
conn
end
defp check_storage_up!(repo) do
try do
adapter = repo.__adapter__()
if Code.ensure_loaded?(adapter) && function_exported?(adapter, :storage_status, 1) do
adapter.storage_status(repo.config())
end
rescue
_ -> :ok
else
:down -> raise Phoenix.Ecto.StorageNotCreatedError, repo: repo
_ -> :ok
end
end
defp check_pending_migrations!(repo, opts) do
try do
# If the dependency `ecto_sql` is not loaded we can't check if
# there are pending migrations so we try to fail gracefully here
fallback_get_migrations =
if Code.ensure_loaded?(Ecto.Migrator),
do: &Ecto.Migrator.migrations/1,
else: fn _repo -> [] end
get_migrations = Keyword.get(opts, :get_migrations_function, fallback_get_migrations)
repo
|> get_migrations.()
|> Enum.any?(fn {status, _version, _migration} -> status == :down end)
rescue
_ -> :ok
else
true -> raise Phoenix.Ecto.PendingMigrationError, repo: repo
false -> :ok
end
end
end