update_and_set_cache(cs)
end
- def get_notified_from_activity_query(to, false) do
+ def get_users_from_set_query(ap_ids, false) do
from(
u in User,
- where: u.ap_id in ^to
+ where: u.ap_id in ^ap_ids
)
end
- def get_notified_from_activity_query(to, true) do
- query = get_notified_from_activity_query(to, false)
+ def get_users_from_set_query(ap_ids, true) do
+ query = get_users_from_set_query(ap_ids, false)
from(
u in query,
)
end
- def get_notified_from_activity(activity, local_only \\ true)
-
- def get_notified_from_activity(
- %Activity{data: %{"type" => "Announce", "to" => to} = data},
- local_only
- ) do
- object = Object.normalize(data["object"])
- actor = User.get_cached_by_ap_id(data["actor"])
-
- # ensure that the actor who published the announced object appears only once
- to =
- if actor.nickname != nil do
- to ++ [object.data["actor"]]
- else
- to
- end
- |> Enum.uniq()
-
- query = get_notified_from_activity_query(to, local_only)
-
- Repo.all(query)
- end
-
- def get_notified_from_activity(%Activity{data: %{"to" => to}}, local_only) do
- query = get_notified_from_activity_query(to, local_only)
-
- Repo.all(query)
+ def get_users_from_set(ap_ids, local_only \\ true) do
+ get_users_from_set_query(ap_ids, local_only)
+ |> Repo.all()
end
- def get_notified_from_activity(_, _), do: []
-
def get_recipients_from_activity(%Activity{recipients: to}) do
query =
from(