summaryrefslogtreecommitdiff
path: root/restarter/lib/pleroma.ex
blob: d7817909d8cbdc586651d8b168bfdea75a3386c2 (plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
defmodule Restarter.Pleroma do
  use GenServer

  require Logger

  def start_link(_) do
    GenServer.start_link(__MODULE__, [], name: __MODULE__)
  end

  def init(_), do: {:ok, %{need_reboot?: false}}

  def need_reboot? do
    GenServer.call(__MODULE__, :need_reboot?)
  end

  def need_reboot do
    GenServer.cast(__MODULE__, :need_reboot)
  end

  def refresh do
    GenServer.cast(__MODULE__, :refresh)
  end

  def restart(env, delay) do
    GenServer.cast(__MODULE__, {:restart, env, delay})
  end

  def restart_after_boot(env) do
    GenServer.cast(__MODULE__, {:after_boot, env})
  end

  def handle_call(:need_reboot?, _from, state) do
    {:reply, state[:need_reboot?], state}
  end

  def handle_cast(:refresh, _state) do
    {:noreply, %{need_reboot?: false}}
  end

  def handle_cast(:need_reboot, %{need_reboot?: true} = state), do: {:noreply, state}

  def handle_cast(:need_reboot, state) do
    {:noreply, Map.put(state, :need_reboot?, true)}
  end

  def handle_cast({:restart, :test, _}, state) do
    Logger.warn("pleroma restarted")
    {:noreply, Map.put(state, :need_reboot?, false)}
  end

  def handle_cast({:restart, _, delay}, state) do
    Process.sleep(delay)
    do_restart(:pleroma)
    {:noreply, Map.put(state, :need_reboot?, false)}
  end

  def handle_cast({:after_boot, _}, %{after_boot: true} = state), do: {:noreply, state}

  def handle_cast({:after_boot, :test}, state) do
    Logger.warn("pleroma restarted")
    {:noreply, Map.put(state, :after_boot, true)}
  end

  def handle_cast({:after_boot, _}, state) do
    do_restart(:pleroma)
    {:noreply, Map.put(state, :after_boot, true)}
  end

  defp do_restart(app) do
    :ok = Application.ensure_started(app)
    :ok = Application.stop(app)
    :ok = Application.start(app)
  end
end