X-Git-Url: http://git.squeep.com/?a=blobdiff_plain;f=lib%2Fpleroma%2Fstats.ex;h=8478fe4ced6565642c864b0a2b88bededfb7882f;hb=1afd6d37bd2febb58ee09d273b9c7d690022d3c3;hp=0484f1a2d5c7bcfbeb2a39c0e86e545aca82c61b;hpb=ad0ab3a57bc5591806cae0201d8077ffb10b6634;p=akkoma diff --git a/lib/pleroma/stats.ex b/lib/pleroma/stats.ex index 0484f1a2d..8478fe4ce 100644 --- a/lib/pleroma/stats.ex +++ b/lib/pleroma/stats.ex @@ -1,7 +1,6 @@ defmodule Pleroma.Stats do - use Agent import Ecto.Query - alias Pleroma.{User, Repo, Activity} + alias Pleroma.{User, Repo} def start_link do agent = Agent.start_link(fn -> {[], %{}} end, name: __MODULE__) @@ -19,22 +18,31 @@ defmodule Pleroma.Stats do def schedule_update do spawn(fn -> - Process.sleep(1000 * 60 * 60 * 1) # 1 hour + # 1 hour + Process.sleep(1000 * 60 * 60 * 1) schedule_update() end) + update_stats() end def update_stats do - peers = from(u in Pleroma.User, - select: fragment("distinct ?->'host'", u.info), - where: u.local != ^true) - |> Repo.all() + peers = + from( + u in Pleroma.User, + select: fragment("distinct ?->'host'", u.info), + where: u.local != ^true + ) + |> Repo.all() + domain_count = Enum.count(peers) - status_query = from(u in User.local_user_query, - select: fragment("sum((?->>'note_count')::int)", u.info)) - status_count = Repo.one(status_query) |> IO.inspect - user_count = Repo.aggregate(User.local_user_query, :count, :id) + + status_query = + from(u in User.local_user_query(), select: fragment("sum((?->>'note_count')::int)", u.info)) + + status_count = Repo.one(status_query) + user_count = Repo.aggregate(User.local_user_query(), :count, :id) + Agent.update(__MODULE__, fn _ -> {peers, %{domain_count: domain_count, status_count: status_count, user_count: user_count}} end)