Packages
igniter
0.6.15
0.8.2
0.8.1
0.8.0
0.7.9
0.7.8
0.7.7
0.7.6
0.7.5
0.7.4
0.7.3
0.7.2
0.7.1
0.7.0
0.6.30
0.6.29
0.6.28
0.6.27
0.6.26
0.6.25
0.6.24
0.6.23
0.6.22
0.6.21
0.6.20
0.6.19
0.6.18
0.6.17
0.6.16
0.6.15
0.6.14
0.6.13
0.6.12
0.6.11
0.6.10
0.6.9
0.6.8
0.6.7
0.6.6
0.6.5
0.6.4
0.6.3
0.6.2
0.6.1
0.6.0
0.5.52
0.5.51
0.5.50
0.5.49
0.5.48
0.5.47
0.5.46
0.5.45
0.5.44
0.5.43
0.5.42
0.5.41
0.5.40
0.5.39
0.5.38
0.5.37
0.5.36
0.5.35
0.5.34
0.5.33
0.5.32
0.5.31
0.5.30
0.5.29
0.5.28
0.5.27
0.5.26
0.5.25
0.5.24
0.5.23
0.5.22
0.5.21
0.5.20
0.5.19
0.5.18
0.5.17
0.5.16
0.5.15
0.5.14
0.5.13
0.5.12
0.5.11
0.5.10
0.5.9
0.5.8
0.5.7
0.5.6
0.5.5
0.5.4
0.5.3
0.5.2
0.5.1
0.5.0
0.4.8
0.4.7
0.4.6
0.4.5
0.4.4
0.4.3
0.4.2
0.4.1
0.4.0
0.3.78
0.3.77
0.3.76
0.3.75
0.3.74
0.3.73
0.3.72
0.3.71
0.3.70
0.3.69
0.3.68
0.3.67
0.3.66
0.3.65
0.3.64
0.3.63
0.3.62
0.3.61
0.3.60
0.3.59
0.3.58
0.3.57
0.3.56
0.3.55
0.3.54
0.3.53
0.3.52
0.3.51
0.3.50
0.3.49
0.3.48
0.3.47
0.3.46
0.3.45
0.3.44
0.3.43
0.3.42
0.3.41
0.3.40
0.3.39
0.3.38
0.3.37
0.3.36
0.3.35
0.3.34
0.3.33
0.3.32
0.3.31
0.3.30
0.3.29
0.3.28
0.3.27
0.3.26
0.3.25
0.3.24
0.3.23
0.3.22
0.3.21
0.3.20
0.3.19
0.3.18
0.3.17
0.3.16
0.3.15
0.3.14
0.3.13
0.3.12
0.3.11
0.3.10
0.3.9
0.3.8
0.3.7
0.3.6
0.3.5
0.3.4
0.3.3
0.3.2
0.3.1
0.3.0
0.2.13
0.2.12
0.2.11
0.2.10
0.2.9
0.2.8
0.2.7
0.2.6
0.2.5
0.2.4
0.2.3
0.2.2
0.2.1
0.2.0
0.1.8
0.1.7
0.1.6
0.1.5
0.1.4
0.1.3
0.1.2
0.1.1
0.1.0
A code generation and project patching framework
Current section
Files
Jump to
Current section
Files
lib/igniter/util/loading.ex
defmodule Igniter.Util.Loading do
@moduledoc """
Utilities for doing operations with loading spinners.
"""
@spinners "⠁⠂⠄⡀⡁⡂⡄⡅⡇⡏⡗⡧⣇⣏⣗⣧⣯⣷⣿⢿⣻⢻⢽⣹⢹⢸⠸⢘⠘⠨⢈⠈⠐⠠⢀" |> String.graphemes()
@doc """
Runs the function with a loading spinner, suppressing all output.
"""
def with_spinner(name, fun, opts \\ []) do
if opts[:verbose?] do
Mix.shell().info(name <> ":")
result = fun.()
Mix.shell().info(name <> ": " <> "#{IO.ANSI.green()}✔#{IO.ANSI.reset()}")
result
else
shell = Mix.shell()
# I don't understand why I have to do this
if !Code.ensure_loaded?(Mix.Shell.ActuallyQuiet) do
Code.eval_quoted(
quote do
defmodule Mix.Shell.ActuallyQuiet do
@moduledoc false
@behaviour Mix.Shell
def print_app, do: :ok
def info(_message), do: :ok
def error(message) do
# Instead of discarding, send to stderr so it gets captured
IO.puts(:stderr, message)
:ok
end
def prompt(_message), do: :ok
def yes?(_message, _options \\ []), do: :ok
def cmd(command, opts \\ []) do
Mix.Shell.cmd(command, opts, fn data -> data end)
end
end
end
)
end
{:ok, _} = Igniter.CaptureServer.start_link([])
loader =
if shell == Mix.Shell.IO do
spawn_loader(name)
end
try do
Mix.shell(Mix.Shell.ActuallyQuiet)
{:ok, ref} =
Igniter.CaptureServer.device_capture_on(:standard_error, :unicode, "")
try do
with_log(fn ->
do_with_io(self(), [], fn ->
fun.()
end)
|> elem(0)
end)
|> elem(0)
rescue
e ->
Process.put(:spinner_error, true)
Mix.shell(shell)
Mix.shell().info(Igniter.CaptureServer.device_output(:standard_error, ref))
reraise e, __STACKTRACE__
catch
kind, reason ->
File.write("catch_output", inspect({kind, reason}))
Process.put(:spinner_error, true)
Mix.shell(shell)
Mix.shell().info(Igniter.CaptureServer.device_output(:standard_error, ref))
:erlang.raise(kind, reason, __STACKTRACE__)
after
Mix.shell(shell)
Igniter.CaptureServer.device_capture_off(ref)
GenServer.stop(Igniter.CaptureServer)
end
after
if shell == Mix.Shell.IO do
loader_ref = make_ref()
error_occurred = Process.get(:spinner_error, false)
stop_message =
if error_occurred,
do: {:stop_error, self(), loader_ref},
else: {:stop_success, self(), loader_ref}
send(loader, stop_message)
receive do
{:loader_stopped, ^loader_ref} ->
nil
after
500 ->
:ok
end
end
end
end
end
defp do_with_io(pid, options, fun) when is_pid(pid) do
prompt_config = Keyword.get(options, :capture_prompt, true)
encoding = Keyword.get(options, :encoding, :unicode)
input = Keyword.get(options, :input, "")
{:group_leader, original_gl} =
Process.info(pid, :group_leader) || {:group_leader, Process.group_leader()}
{:ok, capture_gl} = StringIO.open(input, capture_prompt: prompt_config, encoding: encoding)
try do
Process.group_leader(pid, capture_gl)
do_capture_gl(capture_gl, fun)
after
Process.group_leader(pid, original_gl)
end
end
defp do_capture_gl(string_io, fun) do
fun.()
catch
kind, reason ->
_ = StringIO.close(string_io)
:erlang.raise(kind, reason, __STACKTRACE__)
else
result ->
{:ok, {_input, output}} = StringIO.close(string_io)
{result, output}
end
def spawn_loader(task_name) do
spawn_link(fn ->
@spinners
|> Stream.cycle()
|> Stream.map(fn next ->
receive do
{:stop_success, pid, ref} ->
IO.puts("\r\e[K" <> task_name <> " " <> "#{IO.ANSI.green()}✔#{IO.ANSI.reset()}")
send(pid, {:loader_stopped, ref})
exit(:normal)
{:stop_error, pid, ref} ->
IO.puts("\r\e[K" <> task_name <> " " <> "#{IO.ANSI.red()}✗#{IO.ANSI.reset()}")
send(pid, {:loader_stopped, ref})
exit(:normal)
after
0 ->
IO.write("\r\e[K" <> task_name <> " " <> next)
:timer.sleep(50)
end
end)
|> Stream.run()
end)
end
def with_log(opts \\ [], fun) when is_list(opts) do
opts =
if opts[:level] == :warn do
IO.warn("level: :warn is deprecated, please use :warning instead")
Keyword.put(opts, :level, :warning)
else
opts
end
{:ok, string_io} = StringIO.open("")
try do
ref = Igniter.CaptureServer.log_capture_on(self(), string_io, opts)
try do
fun.()
after
:ok = Logger.flush()
:ok = Igniter.CaptureServer.log_capture_off(ref)
end
catch
kind, reason ->
_ = StringIO.close(string_io)
:erlang.raise(kind, reason, __STACKTRACE__)
else
result ->
{:ok, {_input, output}} = StringIO.close(string_io)
{result, output}
end
end
end