Packages

gust

0.1.20
0.1.37 0.1.36 0.1.35 0.1.34 0.1.33 0.1.32 0.1.31 0.1.30 0.1.29 0.1.28 0.1.27 0.1.26 0.1.25 0.1.24 0.1.23 0.1.22 0.1.21 0.1.20 0.1.19 0.1.18 0.1.17 0.1.16 0.1.15 0.1.14 0.1.13 0.1.12 0.1.11 0.1.10 0.1.9 0.1.8 0.1.7 0.1.6 0.1.5 0.1.4 0.1.2 0.1.1 0.1.0

A DAG-Based Workflow Orchestration Engine for Elixir

HexDocs

Current section

Files

Jump to
Readme
37 Versions
9 Dependencies
Dependants
Files
Activity
gust lib gust dag logger database.ex
Raw

lib/gust/dag/logger/database.ex 

defmodule Gust.DAG.Logger.Database do

  @moduledoc false

  alias Gust.Flows

  @behaviour Gust.DAG.Logger

  @behaviour :gen_event



  def init(__MODULE__) do

    {:ok, %{}}

  end



  def handle_event(:flush, state), do: {:ok, state}



  def handle_event({level, _gl, {Logger, msg, _ts, md}}, state) do

    if md[:task_id] do

      Task.start(fn -> handle_log(level, msg, md) end)

    end



    {:ok, state}

  end



  def handle_call({:configure, opts}, state) do

    {:ok, :ok, Map.merge(state, Map.new(opts))}

  end



  def set_task(task_id, attempt) do

    Logger.metadata(task_id: task_id, attempt: attempt)

  end



  def unset do

    Logger.reset_metadata()

  end



  defp handle_log(_level, "", md),

    do: create_log(:error, "nil or empty was logged!", md)



  defp handle_log(level, msg, md) when is_list(msg),

    do: create_log(level, Enum.join(msg, "; "), md)



  defp handle_log(level, msg, md) when is_binary(msg),

    do: create_log(level, msg, md)



  defp create_log(level, msg, md) do

    {:ok, log} =

      Flows.create_log(%{

        task_id: md[:task_id],

        content: msg,

        attempt: md[:attempt],

        level: to_string(level)

      })



    Gust.PubSub.broadcast_log(md[:task_id], log.id)

  end

end