75 lines
1.7 KiB
Elixir
75 lines
1.7 KiB
Elixir
|
# Portions of this file are derived from Pleroma:
|
||
|
|
# Pleroma: A lightweight social networking server
|
||
|
|
# Copyright © 2017-2020 Pleroma Authors <https://pleroma.social/>
|
||
|
|
# SPDX-License-Identifier: AGPL-3.0-only
|
||
|
|
|
||
|
|
defmodule Mix.Tasks.Mobilizon.Ecto.Rollback do
|
||
|
|
use Mix.Task
|
||
|
|
import Mix.Tasks.Mobilizon.Common
|
||
|
|
alias Mix.Tasks.Mobilizon.Ecto, as: EctoTask
|
||
|
|
require Logger
|
||
|
|
@shortdoc "Wrapper on `ecto.rollback` task"
|
||
|
|
|
||
|
|
@aliases [
|
||
|
|
n: :step,
|
||
|
|
v: :to
|
||
|
|
]
|
||
|
|
|
||
|
|
@switches [
|
||
|
|
all: :boolean,
|
||
|
|
step: :integer,
|
||
|
|
to: :integer,
|
||
|
|
start: :boolean,
|
||
|
|
quiet: :boolean,
|
||
|
|
log_sql: :boolean,
|
||
|
|
migrations_path: :string
|
||
|
|
]
|
||
|
|
|
||
|
|
@repo Mobilizon.Storage.Repo
|
||
|
|
|
||
|
|
@moduledoc """
|
||
|
|
Changes `Logger` level to `:info` before start rollback.
|
||
|
|
Changes level back when rollback ends.
|
||
|
|
|
||
|
|
## Start rollback
|
||
|
|
|
||
|
|
mix mobilizon.ecto.rollback
|
||
|
|
|
||
|
|
Options:
|
||
|
|
- see https://hexdocs.pm/ecto/2.0.0/Mix.Tasks.Ecto.Rollback.html
|
||
|
|
"""
|
||
|
|
|
||
|
|
@impl true
|
||
|
|
def run(args \\ []) do
|
||
|
|
start_mobilizon()
|
||
|
|
{opts, _} = OptionParser.parse!(args, strict: @switches, aliases: @aliases)
|
||
|
|
|
||
|
|
if Application.get_env(:mobilizon, @repo)[:ssl] do
|
||
|
|
Application.ensure_all_started(:ssl)
|
||
|
|
end
|
||
|
|
|
||
|
|
opts =
|
||
|
|
if opts[:to] || opts[:step] || opts[:all],
|
||
|
|
do: opts,
|
||
|
|
else: Keyword.put(opts, :step, 1)
|
||
|
|
|
||
|
|
opts =
|
||
|
|
if opts[:quiet],
|
||
|
|
do: Keyword.merge(opts, log: false, log_sql: false),
|
||
|
|
else: opts
|
||
|
|
|
||
|
|
path = EctoTask.ensure_migrations_path(@repo, opts)
|
||
|
|
|
||
|
|
level = Logger.level()
|
||
|
|
Logger.configure(level: :info)
|
||
|
|
|
||
|
|
if Mobilizon.Config.get(:env) == :test do
|
||
|
|
Logger.info("Rollback succesfully")
|
||
|
|
else
|
||
|
|
{:ok, _, _} = Ecto.Migrator.with_repo(@repo, &Ecto.Migrator.run(&1, path, :down, opts))
|
||
|
|
end
|
||
|
|
|
||
|
|
Logger.configure(level: level)
|
||
|
|
end
|
||
|
|
end
|