+ |> add_link_headers(chat_message_refs)
+ |> put_view(MessageReferenceView)
+ |> render("index.json", chat_message_references: chat_message_refs)
+ end
+ end
+
+ def index(%{assigns: %{user: %{id: user_id} = user}} = conn, params) do
+ exclude_users =
+ User.cached_blocked_users_ap_ids(user) ++
+ if params[:with_muted], do: [], else: User.cached_muted_users_ap_ids(user)
+
+ chats =
+ user_id
+ |> Chat.for_user_query()
+ |> where([c], c.recipient not in ^exclude_users)
+ |> Repo.all()
+
+ render(conn, "index.json", chats: chats)
+ end
+
+ def create(%{assigns: %{user: user}} = conn, %{id: id}) do
+ with %User{ap_id: recipient} <- User.get_cached_by_id(id),
+ {:ok, %Chat{} = chat} <- Chat.get_or_create(user.id, recipient) do
+ render(conn, "show.json", chat: chat)
+ end
+ end
+
+ def show(%{assigns: %{user: user}} = conn, %{id: id}) do
+ with {:ok, chat} <- Chat.get_by_user_and_id(user, id) do
+ render(conn, "show.json", chat: chat)
+ end
+ end
+
+ defp idempotency_key(conn) do
+ case get_req_header(conn, "idempotency-key") do
+ [key] -> key
+ _ -> nil