- {:ok, activity} = insert(data)
- like_count = (object.data["like_count"] || 0) + 1
- new_data = object.data |> Map.put("like_count", like_count)
- changeset = Ecto.Changeset.change(object, data: new_data)
- {:ok, object} = Repo.update(changeset)
+ with {:ok, activity} <- insert(activity) do
+ if actor.local do
+ Pleroma.Web.Federator.enqueue(:publish, activity)
+ end
+
+ {:ok, activity}
+ end
+ end
+
+ def like(%User{ap_id: ap_id} = user, %Object{data: %{ "id" => id}} = object) do
+ cond do
+ # There's already a like here, so return the original activity.
+ ap_id in (object.data["likes"] || []) ->
+ query = from activity in Activity,
+ where: fragment("? @> ?", activity.data, ^%{actor: ap_id, object: id, type: "Like"})
+
+ activity = Repo.one(query)
+ {:ok, activity, object}
+ true ->
+ data = %{
+ "type" => "Like",
+ "actor" => ap_id,
+ "object" => id,
+ "to" => [User.ap_followers(user), object.data["actor"]]
+ }
+
+ {:ok, activity} = insert(data)
+
+ likes = [ap_id | (object.data["likes"] || [])] |> Enum.uniq
+
+ new_data = object.data
+ |> Map.put("like_count", length(likes))
+ |> Map.put("likes", likes)