Packages

gust

0.1.1
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
36 Versions
9 Dependencies
Dependants
Files
Activity
gust lib gust dag compiler code.ex
Raw

lib/gust/dag/compiler/code.ex 

defmodule Gust.DAG.Compiler.Code do

  @behaviour Gust.DAG.Compiler



  def compile(dag_def) do

    {:ok, ast} = Code.string_to_quoted(File.read!(dag_def.file_path))



    runtime_mod = Module.concat(["Gust", "Runner", "#{dag_def.mod}_#{random_udid()}"])

    dag_ast = patch_module(ast, runtime_mod)



    {dag_module, _} = Code.compile_quoted(dag_ast) |> List.first()

    dag_module

  end



  def purge(mod) do

    :code.purge(mod)

    :code.delete(mod)

  end



  defp random_udid do

    timestamp = :os.system_time(:microsecond)

    random = :crypto.strong_rand_bytes(4) |> Base.encode16()

    "#{timestamp}-#{random}"

  end



  defp patch_module(ast, runtime_mod) do

    Macro.postwalk(ast, fn

      {:defmodule, meta, [_module_ast_node, block]} ->

        {:defmodule, meta, [Module.concat([runtime_mod]), block]}



      node ->

        node

    end)

  end

end