-
- defp get_all(query, max_id \\ nil) do
- params = %{limit: 20}
- params = if max_id == nil do
- params
- else
- Map.put(params, :max_id, max_id)
- end
-
- res = query
- |> Pagination.fetch_paginated(params)
-
- if res == [] do
- :ok
- else
- res
- |> Pleroma.Elasticsearch.bulk_post(:activities)
-
- get_all(query, List.last(res).id)
- end
- end
-