Merge branch 'release/0.1.6'

Author: zacksiri

lib/tama_ex/perception.ex

@@ -46,4 +46,27 @@ defmodule TamaEx.Perception do
       |> TamaEx.handle_response(Chain)
     end
   end
+
+  alias __MODULE__.Concept
+
+  def list_concepts(client, entity_id, options \\ []) do
+    with {:ok, validated_client} <- TamaEx.validate_client(client, ["perception"]) do
+      url = "/entities/#{entity_id}/concepts"
+
+      query = Keyword.get(options, :query, [])
+
+      req_options = [url: url, params: query]
+
+      req_options =
+        if Keyword.has_key?(options, :retry) do
+          Keyword.put(req_options, :retry, Keyword.get(options, :retry))
+        else
+          req_options
+        end
+
+      validated_client
+      |> Req.get(req_options)
+      |> TamaEx.handle_response(Concept)
+    end
+  end
 end

lib/tama_ex/perception/concept.ex

@@ -0,0 +1,56 @@
+defmodule TamaEx.Perception.Concept do
+  use Ecto.Schema
+  import Ecto.Changeset
+
+  @primary_key false
+  embedded_schema do
+    field :id, :binary_id
+    field :relation, :string
+    field :content, :map
+  end
+
+  def changeset(concept, attrs) do
+    concept
+    |> cast(attrs, [:id, :relation, :content])
+    |> validate_required([:id, :relation, :content])
+  end
+
+  @doc """
+  Parses API response data into Concept struct(s).
+
+  Handles both individual concept maps and lists of concepts.
+  """
+  def parse(attrs) when is_list(attrs) do
+    Enum.map(attrs, &parse/1)
+  end
+
+  def parse(attrs) when is_map(attrs) do
+    %__MODULE__{}
+    |> changeset(attrs)
+    |> case do
+      %Ecto.Changeset{valid?: true} = changeset ->
+        Ecto.Changeset.apply_changes(changeset)
+
+      %Ecto.Changeset{valid?: false} ->
+        %__MODULE__{}
+    end
+  end
+
+  def parse(attrs) when is_binary(attrs) do
+    case Jason.decode(attrs) do
+      {:ok, decoded} -> parse(decoded)
+      {:error, _} -> %__MODULE__{}
+    end
+  end
+
+  def parse(_), do: %__MODULE__{}
+
+  @doc """
+  Parses API response data into a Concept struct, raising on error.
+  """
+  def parse!(attrs) do
+    %__MODULE__{}
+    |> changeset(attrs)
+    |> apply_action!(:insert)
+  end
+end

mix.exs

@@ -4,7 +4,7 @@ defmodule TamaEx.MixProject do
   def project do
     [
       app: :tama_ex,
-      version: "0.1.5",
+      version: "0.1.6",
       elixir: "~> 1.18",
       start_permanent: Mix.env() == :prod,
       deps: deps(),