diff options
Diffstat (limited to 'lib')
| -rw-r--r-- | lib/pleroma/web/websub/websub.ex | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/lib/pleroma/web/websub/websub.ex b/lib/pleroma/web/websub/websub.ex index 47a01849d..fa3ab7214 100644 --- a/lib/pleroma/web/websub/websub.ex +++ b/lib/pleroma/web/websub/websub.ex @@ -49,7 +49,8 @@ defmodule Pleroma.Web.Websub do def publish(topic, user, %{data: %{"type" => type}} = activity) when type in @supported_activities do # TODO: Only send to still valid subscriptions. query = from sub in WebsubServerSubscription, - where: sub.topic == ^topic and sub.state == "active" + where: sub.topic == ^topic and sub.state == "active", + where: fragment("? > NOW()", sub.valid_until) subscriptions = Repo.all(query) Enum.each(subscriptions, fn(sub) -> response = user |