X-Git-Url: http://git.squeep.com/?a=blobdiff_plain;f=lib%2Fpleroma%2Factivity%2Fpruner.ex;h=7f561ebae5e41bd6676d7004dceb26918400f12a;hb=6b882a2c0b98bdf94bc557f86c2d16460d90f44e;hp=054ee514ae5313cbb3ba7949f07d6e05052227b3;hpb=0c2c057c75e21ec411599016b705801f98565cf8;p=akkoma

diff --git a/lib/pleroma/activity/pruner.ex b/lib/pleroma/activity/pruner.ex
index 054ee514a..7f561ebae 100644
--- a/lib/pleroma/activity/pruner.ex
+++ b/lib/pleroma/activity/pruner.ex
@@ -35,6 +35,17 @@ defmodule Pleroma.Activity.Pruner do
     |> Repo.delete_all(timeout: :infinity)
   end
 
+  def prune_stale_follow_requests do
+    before_time = cutoff()
+
+    from(a in Activity,
+      where:
+        fragment("?->>'type' = ?", a.data, "Follow") and a.inserted_at < ^before_time and
+          fragment("?->>'state' = ?", a.data, "reject")
+    )
+    |> Repo.delete_all(timeout: :infinity)
+  end
+
   defp cutoff do
     DateTime.utc_now() |> Timex.shift(days: -@cutoff)
   end