+
+ def update_note_count(%User{} = user) do
+ note_count_query = from a in Object,
+ where: fragment("? @> ?", a.data, ^%{actor: user.ap_id, type: "Note"}),
+ select: count(a.id)
+
+ note_count = Repo.one(note_count_query)
+
+ new_info = Map.put(user.info, "note_count", note_count)
+
+ cs = info_changeset(user, %{info: new_info})
+
+ Repo.update(cs)
+ end
+
+ def update_follower_count(%User{} = user) do
+ follower_count_query = from u in User,
+ where: fragment("? @> ?", u.following, ^user.follower_address),
+ select: count(u.id)
+
+ follower_count = Repo.one(follower_count_query)
+
+ new_info = Map.put(user.info, "follower_count", follower_count)
+
+ cs = info_changeset(user, %{info: new_info})
+
+ Repo.update(cs)
+ end
+
+ def get_notified_from_activity(%Activity{data: %{"to" => to}} = activity) do
+ query = from u in User,
+ where: u.ap_id in ^to,
+ where: u.local == true
+
+ Repo.all(query)
+ end