- |> Stream.map(fn objects ->
- Enum.map(objects, fn object ->
- data = object.data
-
- {:ok, published, _} = DateTime.from_iso8601(data["published"])
-
- %{
- id: object.id,
- source: data["source"],
- ap: data["id"],
- published: published |> DateTime.to_unix()
- }
- end)
- end)