Refactor common functions to common.ex

This commit is contained in:
Rin Toshaka 2018-12-06 18:00:24 +01:00
parent 3a84511df1
commit 4a2a7ce636
3 changed files with 21 additions and 35 deletions

View file

@ -1,6 +1,7 @@
defmodule Mix.Tasks.Pleroma.Instance do defmodule Mix.Tasks.Pleroma.Instance do
use Mix.Task use Mix.Task
alias Pleroma.{Repo, User} alias Pleroma.{Repo, User}
alias Mix.Tasks.Pleroma.Common
@shortdoc "Manages Pleroma instance" @shortdoc "Manages Pleroma instance"
@moduledoc """ @moduledoc """
@ -59,23 +60,23 @@ def run(["gen" | rest]) do
unless not proceed? do unless not proceed? do
domain = domain =
get_option( Common.get_option(
options, options,
:domain, :domain,
"What domain will your instance use? (e.g pleroma.soykaf.com)" "What domain will your instance use? (e.g pleroma.soykaf.com)"
) )
name = name =
get_option(options, :name, "What is the name of your instance? (e.g. Pleroma/Soykaf)") Common.get_option(options, :name, "What is the name of your instance? (e.g. Pleroma/Soykaf)")
email = get_option(options, :admin_email, "What is your admin email address?") email = Common.get_option(options, :admin_email, "What is your admin email address?")
dbhost = get_option(options, :dbhost, "What is the hostname of your database?", "localhost") dbhost = Common.get_option(options, :dbhost, "What is the hostname of your database?", "localhost")
dbname = get_option(options, :dbname, "What is the name of your database?", "pleroma_dev") dbname = Common.get_option(options, :dbname, "What is the name of your database?", "pleroma_dev")
dbuser = dbuser =
get_option( Common.get_option(
options, options,
:dbuser, :dbuser,
"What is the user used to connect to your database?", "What is the user used to connect to your database?",
@ -83,7 +84,7 @@ def run(["gen" | rest]) do
) )
dbpass = dbpass =
get_option( Common.get_option(
options, options,
:dbpass, :dbpass,
"What is the password used to connect to your database?", "What is the password used to connect to your database?",
@ -128,12 +129,12 @@ def run(["gen" | rest]) do
""" """
To get started: To get started:
1. Verify the contents of the generated files. 1. Verify the contents of the generated files.
2. Run `sudo -u postgres psql -f #{escape_sh_path(psql_path)}`. 2. Run `sudo -u postgres psql -f #{Common.escape_sh_path(psql_path)}`.
""" <> """ <>
if config_path in ["config/dev.secret.exs", "config/prod.secret.exs"] do if config_path in ["config/dev.secret.exs", "config/prod.secret.exs"] do
"" ""
else else
"3. Run `mv #{escape_sh_path(config_path)} 'config/prod.secret.exs'`." "3. Run `mv #{Common.escape_sh_path(config_path)} 'config/prod.secret.exs'`."
end end
) )
else else
@ -145,21 +146,6 @@ def run(["gen" | rest]) do
end end
end end
defp escape_sh_path(path) do
~S(') <> String.replace(path, ~S('), ~S(\')) <> ~S(')
end
defp get_option(options, opt, prompt, def \\ nil, defname \\ nil) do
Keyword.get(options, opt) ||
case Mix.shell().prompt("#{prompt} [#{defname || def}]") do
"\n" ->
case def do
nil -> get_option(options, opt, prompt, def)
def -> def
end
opt ->
opt |> String.trim()
end
end
end end

View file

@ -1,6 +1,7 @@
defmodule Mix.Tasks.Pleroma.Relay do defmodule Mix.Tasks.Pleroma.Relay do
use Mix.Task use Mix.Task
alias Pleroma.Web.ActivityPub.Relay alias Pleroma.Web.ActivityPub.Relay
alias Mix.Tasks.Pleroma.Common
@shortdoc "Manages remote relays" @shortdoc "Manages remote relays"
@moduledoc """ @moduledoc """
@ -19,8 +20,7 @@ defmodule Mix.Tasks.Pleroma.Relay do
Example: ``mix pleroma.relay unfollow https://example.org/relay`` Example: ``mix pleroma.relay unfollow https://example.org/relay``
""" """
def run(["follow", target]) do def run(["follow", target]) do
Mix.Task.run("app.start") Common.start_pleroma
with {:ok, activity} <- Relay.follow(target) do with {:ok, activity} <- Relay.follow(target) do
# put this task to sleep to allow the genserver to push out the messages # put this task to sleep to allow the genserver to push out the messages
:timer.sleep(500) :timer.sleep(500)
@ -30,7 +30,7 @@ def run(["follow", target]) do
end end
def run(["unfollow", target]) do def run(["unfollow", target]) do
Mix.Task.run("app.start") Common.start_pleroma
with {:ok, activity} <- Relay.follow(target) do with {:ok, activity} <- Relay.follow(target) do
# put this task to sleep to allow the genserver to push out the messages # put this task to sleep to allow the genserver to push out the messages

View file

@ -2,6 +2,7 @@ defmodule Mix.Tasks.Pleroma.User do
use Mix.Task use Mix.Task
import Ecto.Changeset import Ecto.Changeset
alias Pleroma.{Repo, User} alias Pleroma.{Repo, User}
alias Mix.Tasks.Pleroma.Common
@shortdoc "Manages Pleroma users" @shortdoc "Manages Pleroma users"
@moduledoc """ @moduledoc """
@ -43,7 +44,6 @@ defmodule Mix.Tasks.Pleroma.User do
- `--moderator`/`--no-moderator` - whether the user is a moderator - `--moderator`/`--no-moderator` - whether the user is a moderator
- `--admin`/`--no-admin` - whether the user is an admin - `--admin`/`--no-admin` - whether the user is an admin
""" """
def run(["new", nickname, email | rest]) do def run(["new", nickname, email | rest]) do
{options, [], []} = {options, [], []} =
OptionParser.parse( OptionParser.parse(
@ -88,7 +88,7 @@ def run(["new", nickname, email | rest]) do
proceed? = Mix.shell().yes?("Continue?") proceed? = Mix.shell().yes?("Continue?")
unless not proceed? do unless not proceed? do
Mix.Task.run("app.start") Common.start_pleroma()
params = params =
%{ %{
@ -123,7 +123,7 @@ def run(["new", nickname, email | rest]) do
end end
def run(["rm", nickname]) do def run(["rm", nickname]) do
Mix.Task.run("app.start") Common.start_pleroma()
with %User{local: true} = user <- User.get_by_nickname(nickname) do with %User{local: true} = user <- User.get_by_nickname(nickname) do
User.delete(user) User.delete(user)
@ -135,7 +135,7 @@ def run(["rm", nickname]) do
end end
def run(["toggle_activated", nickname]) do def run(["toggle_activated", nickname]) do
Mix.Task.run("app.start") Common.start_pleroma()
with %User{} = user <- User.get_by_nickname(nickname) do with %User{} = user <- User.get_by_nickname(nickname) do
User.deactivate(user, !user.info["deactivated"]) User.deactivate(user, !user.info["deactivated"])
@ -147,7 +147,7 @@ def run(["toggle_activated", nickname]) do
end end
def run(["reset_password", nickname]) do def run(["reset_password", nickname]) do
Mix.Task.run("app.start") Common.start_pleroma()
with %User{local: true} = user <- User.get_by_nickname(nickname), with %User{local: true} = user <- User.get_by_nickname(nickname),
{:ok, token} <- Pleroma.PasswordResetToken.create_token(user) do {:ok, token} <- Pleroma.PasswordResetToken.create_token(user) do
@ -169,7 +169,7 @@ def run(["reset_password", nickname]) do
end end
def run(["unsubscribe", nickname]) do def run(["unsubscribe", nickname]) do
Mix.Task.run("app.start") Common.start_pleroma()
with %User{} = user <- User.get_by_nickname(nickname) do with %User{} = user <- User.get_by_nickname(nickname) do
Mix.shell().info("Deactivating #{user.nickname}") Mix.shell().info("Deactivating #{user.nickname}")
@ -198,7 +198,7 @@ def run(["unsubscribe", nickname]) do
end end
def run(["set", nickname | rest]) do def run(["set", nickname | rest]) do
Mix.Task.run("app.start") Common.start_pleroma()
{options, [], []} = {options, [], []} =
OptionParser.parse( OptionParser.parse(
@ -280,7 +280,7 @@ defp set_locked(user, value) do
end end
def run(["invite"]) do def run(["invite"]) do
Mix.Task.run("app.start") Common.start_pleroma()
with {:ok, token} <- Pleroma.UserInviteToken.create_token() do with {:ok, token} <- Pleroma.UserInviteToken.create_token() do
Mix.shell().info("Generated user invite token") Mix.shell().info("Generated user invite token")