aboutsummaryrefslogtreecommitdiff
path: root/lib
diff options
context:
space:
mode:
authorRoger Braun <roger@rogerbraun.net>2017-03-23 17:56:49 +0100
committerRoger Braun <roger@rogerbraun.net>2017-03-23 17:56:49 +0100
commit1f0f79d95911769f1a99aebc5df47aa98b38c360 (patch)
tree7b2e7728e20b1ed8339c4eddaa136ba7024a68b8 /lib
parent9ad045fd587f83386d9582136c971dbcd4410b67 (diff)
downloadpleroma-1f0f79d95911769f1a99aebc5df47aa98b38c360.tar.gz
Generate ids for activities.
Diffstat (limited to 'lib')
-rw-r--r--lib/pleroma/web/activity_pub/activity_pub.ex10
1 files changed, 10 insertions, 0 deletions
diff --git a/lib/pleroma/web/activity_pub/activity_pub.ex b/lib/pleroma/web/activity_pub/activity_pub.ex
index 121c46c51..0f5a78e8a 100644
--- a/lib/pleroma/web/activity_pub/activity_pub.ex
+++ b/lib/pleroma/web/activity_pub/activity_pub.ex
@@ -4,9 +4,19 @@ defmodule Pleroma.Web.ActivityPub.ActivityPub do
import Ecto.Query
def insert(map) when is_map(map) do
+ map = Map.put_new_lazy(map, "id", &generate_activity_id/0)
+
Repo.insert(%Activity{data: map})
end
+ def generate_activity_id do
+ host =
+ Application.get_env(:pleroma, Pleroma.Web.Endpoint)
+ |> Keyword.fetch!(:url)
+ |> Keyword.fetch!(:host)
+ "https://#{host}/activities/#{Ecto.UUID.generate}"
+ end
+
def fetch_public_activities(opts \\ %{}) do
public = ["https://www.w3.org/ns/activitystreams#Public"]
fetch_activities(public, opts)