Packages

condukt

0.16.2
1.7.0 1.6.3 1.6.2 1.6.1 1.6.0 1.5.1 1.5.0 1.4.1 1.4.0 1.3.0 1.2.1 1.2.0 1.1.0 1.0.0 0.21.0 0.20.0 0.19.0 0.18.0 0.17.0 0.16.6 0.16.5 0.16.4 0.16.3 0.16.2 0.16.1 0.16.0 0.15.1 0.15.0 0.14.2 0.14.1 0.14.0 0.13.1 0.13.0 0.12.0 0.11.0 0.10.0 0.9.0 0.8.0 0.7.2 0.7.1 0.7.0 0.6.1 0.6.0 0.5.0

A framework for building AI agents in Elixir

HexDocs

Current section

Files

Jump to
Readme
44 Versions
10 Dependencies
Dependants
Files
Activity
condukt lib mix tasks condukt.workflows.helpers.ex
Raw

lib/mix/tasks/condukt.workflows.helpers.ex 

defmodule Mix.Tasks.Condukt.Workflows.Helpers do

  @moduledoc false



  alias Condukt.Workflows



  def parse!(args, switches) do

    case OptionParser.parse(args, strict: switches) do

      {opts, rest, []} -> {opts, rest}

      {_opts, _rest, invalid} -> Mix.raise("Invalid options: #{inspect(invalid)}")

    end

  end



  def root(opts) do

    opts

    |> Keyword.get(:root, File.cwd!())

    |> Path.expand()

  end



  def load_project!(root) do

    case Workflows.load_project(root) do

      {:ok, project} -> project

      {:error, reason} -> Mix.raise("Could not load workflow project: #{inspect(reason)}")

    end

  end



  def decode_input!(nil), do: %{}



  def decode_input!(encoded) do

    case JSON.decode(encoded) do

      {:ok, input} when is_map(input) -> input

      {:ok, _other} -> Mix.raise("--input must decode to a JSON object")

      {:error, reason} -> Mix.raise("Invalid --input JSON: #{inspect(reason)}")

    end

  end



  def format_result(result) when is_binary(result), do: result

  def format_result(result), do: JSON.encode!(result)

end