aboutsummaryrefslogtreecommitdiff
path: root/lib
diff options
context:
space:
mode:
authorEgor Kislitsyn <egor@kislitsyn.com>2020-09-26 21:24:35 +0400
committerEgor Kislitsyn <egor@kislitsyn.com>2020-10-07 18:35:28 +0400
commitd7a5291b4fa3b7568674c0f7643fe287fcd21eff (patch)
treecb41f9dbe40ed10d9f94283f9d5bd274f730b1fa /lib
parent6d5f02a1da81ed7693c5ae364a25bc0b54ee1a38 (diff)
downloadpleroma-d7a5291b4fa3b7568674c0f7643fe287fcd21eff.tar.gz
Use `Jason.encode/1` for likes and bookmarks
Diffstat (limited to 'lib')
-rw-r--r--lib/pleroma/backup.ex9
1 files changed, 5 insertions, 4 deletions
diff --git a/lib/pleroma/backup.ex b/lib/pleroma/backup.ex
index e2673db80..b43dc94d6 100644
--- a/lib/pleroma/backup.ex
+++ b/lib/pleroma/backup.ex
@@ -194,7 +194,8 @@ defmodule Pleroma.Backup do
query
|> Pleroma.Repo.chunk_stream(100)
|> Enum.reduce(0, fn i, acc ->
- with {:ok, str} <- fun.(i),
+ with {:ok, data} <- fun.(i),
+ {:ok, str} <- Jason.encode(data),
:ok <- IO.write(file, str <> ",\n") do
acc + 1
else
@@ -213,7 +214,7 @@ defmodule Pleroma.Backup do
|> where(user_id: ^user_id)
|> join(:inner, [b], activity in assoc(b, :activity))
|> select([b, a], %{id: b.id, object: fragment("(?)->>'object'", a.data)})
- |> write(dir, "bookmarks", fn a -> {:ok, "\"#{a.object}\""} end)
+ |> write(dir, "bookmarks", fn a -> {:ok, a.object} end)
end
defp likes(dir, user) do
@@ -221,7 +222,7 @@ defmodule Pleroma.Backup do
|> Activity.Queries.by_actor()
|> Activity.Queries.by_type("Like")
|> select([like], %{id: like.id, object: fragment("(?)->>'object'", like.data)})
- |> write(dir, "likes", fn a -> {:ok, "\"#{a.object}\""} end)
+ |> write(dir, "likes", fn a -> {:ok, a.object} end)
end
defp statuses(dir, user) do
@@ -239,7 +240,7 @@ defmodule Pleroma.Backup do
|> ActivityPub.fetch_activities_query(opts)
|> write(dir, "outbox", fn a ->
with {:ok, activity} <- Transmogrifier.prepare_outgoing(a.data) do
- activity |> Map.delete("@context") |> Jason.encode()
+ {:ok, Map.delete(activity, "@context")}
end
end)
end