aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorlain <lain@soykaf.club>2020-03-26 15:16:54 +0100
committerlain <lain@soykaf.club>2020-03-26 15:16:54 +0100
commit4cf1007a7d478a54a759d018dd7ce958a45f3977 (patch)
treec8d382d982fae215e5ba008f407c282372a7406f
parentf31688246470273cc35588d0f1c2187edc6084c7 (diff)
downloadpleroma-4cf1007a7d478a54a759d018dd7ce958a45f3977.tar.gz
ActivityPub: Small refactor.
-rw-r--r--lib/pleroma/web/activity_pub/activity_pub.ex23
1 files changed, 11 insertions, 12 deletions
diff --git a/lib/pleroma/web/activity_pub/activity_pub.ex b/lib/pleroma/web/activity_pub/activity_pub.ex
index dd4b04185..35c2eb133 100644
--- a/lib/pleroma/web/activity_pub/activity_pub.ex
+++ b/lib/pleroma/web/activity_pub/activity_pub.ex
@@ -129,18 +129,17 @@ defmodule Pleroma.Web.ActivityPub.ActivityPub do
# TODO rewrite in with style
@spec persist(map(), keyword()) :: {:ok, Activity.t() | Object.t()}
def persist(object, meta) do
- local = Keyword.fetch!(meta, :local)
- {recipients, _, _} = get_recipients(object)
-
- {:ok, activity} =
- Repo.insert(%Activity{
- data: object,
- local: local,
- recipients: recipients,
- actor: object["actor"]
- })
-
- {:ok, activity, meta}
+ with local <- Keyword.fetch!(meta, :local),
+ {recipients, _, _} <- get_recipients(object),
+ {:ok, activity} <-
+ Repo.insert(%Activity{
+ data: object,
+ local: local,
+ recipients: recipients,
+ actor: object["actor"]
+ }) do
+ {:ok, activity, meta}
+ end
end
def insert(map, local \\ true, fake \\ false, bypass_actor_check \\ false) when is_map(map) do