- """
- end
-
- defp task_flow_graph(assigns) do
- # Group subtasks by wave (dependency level)
- subtasks = assigns.subtasks || []
- waves = compute_waves(subtasks)
-
- ~H"""
-
- <%= for {wave_tasks, wave_num} <- Enum.with_index(waves) do %>
-
-
Wave <%= wave_num %>
-
- <%= for subtask <- wave_tasks do %>
- <.subtask_card subtask={subtask} />
+
-
- <% end %>
-
- """
- end
- defp subtask_card(assigns) do
- ~H"""
-
-
-
-
- <%= if @subtask["model"] do %>
-
- <%= @subtask["model"] %>
-
- <% end %>
-
-
- <%= if @subtask["status"] == "executing" do %>
-
-
- Executing...
-
- <% end %>
-
- <%= if @subtask["result"] do %>
-
- <%= String.slice(@subtask["result"], 0..60) %>
-
- <% end %>
-
-
- $<%= format_cost(@subtask["cost"]) %>
-
-
- """
- end
-
- defp subtask_detail(assigns) do
- ~H"""
-
-
-
-
- <%= @subtask["description"] %>
-
-
-
-
- Model: <%= @subtask["model"] %>
-
-
- Tier: <%= @subtask["tier_assigned"] %>
-
-
- Cost: $<%= format_cost(@subtask["cost"]) %>
-
-
-
- <%= if @subtask["started_at"] do %>
-
-
- Started: <%= format_datetime(@subtask["started_at"]) %>
-
- <%= if @subtask["completed_at"] do %>
-
- Completed: <%= format_datetime(@subtask["completed_at"]) %>
-
- <% end %>
-
- <% end %>
-
- <%= if @subtask["result"] do %>
-
-
Result:
-
<%= @subtask["result"] %>
-
- <% end %>
-
- <%= if @subtask["depends_on"] && length(@subtask["depends_on"]) > 0 do %>
-
- Depends on: <%= Enum.join(@subtask["depends_on"], ", ") %>
-
- <% end %>
-
- """
- end
-
- defp task_history(assigns) do
- ~H"""
-
-
-
- <%= if length(@history) == 0 do %>
-
-
No tasks yet. Create your first compound task above.
-
- <% else %>
-
- <%= for task <- @history do %>
-
-
-
- <%= String.slice(task["prompt"], 0..100) %>
-
-
- <%= task["subtask_count"] || length(task["subtasks"] || []) %> subtasks
-
- $<%= format_cost(task["total_cost"]) %>
-
-
+ <%= if @completion_summary do %>
+
+
Outcome
+
<%= @completion_summary %>
<% end %>
+
+
+
+ <%= if @loading do %>
+
Loading...
+ <% else %>
+ <%= if @logs == [] do %>
+
No log entries recorded for this session.
+ <% else %>
+
+ <%= for log <- @logs do %>
+
+ <%= fmt_time(gv(log, "timestamp", "")) %>
+ <%= gv(log, "entry", "") %>
+
+ <% end %>
+
+ <% end %>
+ <% end %>
+
- <% end %>
+
"""
end
- # -- Helpers --
+ # ── Data Fetching ──
- defp submit_compound_task(prompt) do
- case Req.post("#{symbiont_url()}/task/compound",
- json: %{"prompt" => prompt},
- headers: [{"authorization", "Bearer #{@auth_token}"}]
- ) do
- {:ok, response} ->
- case response.status do
- 200 -> {:ok, response.body}
- _ -> {:error, "HTTP #{response.status}"}
+ defp fetch_engram_data do
+ stats_task =
+ Task.async(fn ->
+ case Req.get("#{symbiont_url()}/engram/stats", receive_timeout: @http_timeout) do
+ {:ok, %{status: 200, body: body}} when is_map(body) -> body
+ _ -> %{}
end
-
- {:error, reason} ->
- {:error, reason}
- end
- end
-
- defp fetch_task_progress(task_id) do
- case Req.get("#{symbiont_url()}/task/#{task_id}/progress") do
- {:ok, response} ->
- case response.status do
- 200 -> {:ok, response.body}
- _ -> {:error, "HTTP #{response.status}"}
- end
-
- {:error, reason} ->
- {:error, reason}
- end
- end
-
- defp fetch_recent_tasks do
- case Req.get("#{symbiont_url()}/tasks/recent") do
- {:ok, response} ->
- case response.status do
- 200 ->
- case response.body do
- list when is_list(list) -> list
- _ -> []
- end
-
- _ ->
- []
- end
-
- {:error, _} ->
- []
- end
- end
-
- defp compute_waves(subtasks) do
- # Group subtasks by dependency level (wave)
- # Wave 0: no dependencies, Wave N: max(dep waves) + 1
- # Sort by index first to ensure deps are computed before dependents
- sorted = Enum.sort_by(subtasks, & &1["index"])
-
- wave_map =
- Enum.reduce(sorted, %{}, fn task, acc ->
- deps = task["depends_on"] || []
-
- wave =
- if Enum.empty?(deps) do
- 0
- else
- deps
- |> Enum.map(&Map.get(acc, &1, 0))
- |> Enum.max(fn -> 0 end)
- |> Kernel.+(1)
- end
-
- Map.put(acc, task["index"], wave)
end)
- subtasks
- |> Enum.group_by(&Map.get(wave_map, &1["index"], 0))
- |> Enum.sort_by(fn {wave, _} -> wave end)
- |> Enum.map(fn {_, tasks} -> Enum.sort_by(tasks, &(&1["index"])) end)
+ sessions_task =
+ Task.async(fn ->
+ case Req.get("#{symbiont_url()}/engram/sessions/recent?hours=8760",
+ receive_timeout: @http_timeout
+ ) do
+ {:ok, %{status: 200, body: %{"sessions" => s}}} when is_list(s) -> s
+ _ -> []
+ end
+ end)
+
+ stats = Task.await(stats_task, @http_timeout + 1_000)
+ sessions = Task.await(sessions_task, @http_timeout + 1_000)
+ {stats, sessions}
end
- defp format_cost(cost) when is_number(cost) do
- :io_lib.format("~.4f", [cost]) |> to_string()
- end
+ # ── Helpers ──
- defp format_cost(_), do: "0.0000"
+ defp gv(map, key, default \\ nil) when is_map(map), do: Map.get(map, key, default)
+ defp gv(_, _, default), do: default
- defp format_datetime(iso_string) when is_binary(iso_string) do
- case DateTime.from_iso8601(iso_string) do
- {:ok, dt, _} ->
- dt
- |> DateTime.to_naive()
- |> NaiveDateTime.to_string()
+ defp fmt_date(""), do: "\u2014"
- {:error, _} ->
- iso_string
+ defp fmt_date(iso) when is_binary(iso) do
+ case parse_dt(iso) do
+ {:ok, dt} ->
+ diff = DateTime.diff(DateTime.utc_now(), dt, :second)
+ days = div(diff, 86400)
+
+ cond do
+ days == 0 -> "today"
+ days == 1 -> "yesterday"
+ days < 7 -> "#{days}d ago"
+ true -> Calendar.strftime(dt, "%b %d")
+ end
+
+ _ ->
+ String.slice(iso, 0, 10)
end
end
- defp format_datetime(nil), do: "—"
-end
\ No newline at end of file
+ defp fmt_date(_), do: "\u2014"
+
+ defp fmt_full(nil), do: "\u2014"
+ defp fmt_full(""), do: "\u2014"
+
+ defp fmt_full(iso) when is_binary(iso) do
+ case parse_dt(iso) do
+ {:ok, dt} -> Calendar.strftime(dt, "%b %d, %Y at %H:%M UTC")
+ _ -> iso
+ end
+ end
+
+ defp fmt_full(_), do: "\u2014"
+
+ defp fmt_time(""), do: ""
+
+ defp fmt_time(iso) when is_binary(iso) do
+ case parse_dt(iso) do
+ {:ok, dt} -> Calendar.strftime(dt, "%H:%M")
+ _ -> ""
+ end
+ end
+
+ defp fmt_time(_), do: ""
+
+ defp parse_dt(iso) do
+ case DateTime.from_iso8601(iso) do
+ {:ok, dt, _} -> {:ok, dt}
+ _ ->
+ case NaiveDateTime.from_iso8601(iso) do
+ {:ok, ndt} -> {:ok, DateTime.from_naive!(ndt, "Etc/UTC")}
+ _ -> :error
+ end
+ end
+ end
+end