X-Git-Url: https://git.squeep.com/?a=blobdiff_plain;f=lib%2Fpleroma%2Fpagination.ex;h=9d279fba7939f12256d57cf41261f0e506fba562;hb=724f611b0edf3d7fd819ee748df2f6b00d211fa2;hp=d21ecf628400bb83913d6f1577655b0b775834ea;hpb=a4c5f71e933c905433b80c90bcd626e7da703669;p=akkoma diff --git a/lib/pleroma/pagination.ex b/lib/pleroma/pagination.ex index d21ecf628..9d279fba7 100644 --- a/lib/pleroma/pagination.ex +++ b/lib/pleroma/pagination.ex @@ -16,33 +16,41 @@ defmodule Pleroma.Pagination do def fetch_paginated(query, params, type \\ :keyset) - def fetch_paginated(query, params, :keyset) do - options = cast_params(params) + def fetch_paginated(query, %{"total" => true} = params, :keyset) do total = Repo.aggregate(query, :count, :id) %{ total: total, - items: - query - |> paginate(options, :keyset) - |> Repo.all() - |> enforce_order(options) + items: fetch_paginated(query, Map.drop(params, ["total"]), :keyset) } end - def fetch_paginated(query, params, :offset) do + def fetch_paginated(query, params, :keyset) do options = cast_params(params) + + query + |> paginate(options, :keyset) + |> Repo.all() + |> enforce_order(options) + end + + def fetch_paginated(query, %{"total" => true} = params, :offset) do total = Repo.aggregate(query, :count, :id) %{ total: total, - items: - query - |> paginate(options, :offset) - |> Repo.all() + items: fetch_paginated(query, Map.drop(params, ["total"]), :offset) } end + def fetch_paginated(query, params, :offset) do + options = cast_params(params) + + query + |> paginate(options, :offset) + |> Repo.all() + end + def paginate(query, options, method \\ :keyset) def paginate(query, options, :keyset) do @@ -56,6 +64,7 @@ defmodule Pleroma.Pagination do def paginate(query, options, :offset) do query + |> restrict(:order, options) |> restrict(:offset, options) |> restrict(:limit, options) end