- def insert(map) when is_map(map) do
- map = Map.put_new_lazy(map, "id", &generate_activity_id/0)
+ def insert(map, local \\ true) when is_map(map) do
+ with nil <- Activity.get_by_ap_id(map["id"]),
+ map <- lazy_put_activity_defaults(map),
+ :ok <- insert_full_object(map) do
+ Repo.insert(%Activity{data: map, local: local})
+ else
+ %Activity{} = activity -> {:ok, activity}
+ error -> {:error, error}
+ end
+ end
+
+ def create(to, actor, context, object, additional \\ %{}, published \\ nil, local \\ true) do
+ with create_data <- make_create_data(%{to: to, actor: actor, published: published, context: context, object: object}, additional),
+ {:ok, activity} <- insert(create_data, local),
+ :ok <- maybe_federate(activity) do
+ {:ok, activity}
+ end
+ end