forked from AkkomaGang/akkoma
Correct active state websub name.
This commit is contained in:
parent
05f2cd0d93
commit
153995f832
2 changed files with 3 additions and 3 deletions
|
@ -211,7 +211,7 @@ def refresh_subscriptions(delta \\ 60 * 60 * 24) do
|
|||
cut_off = NaiveDateTime.add(NaiveDateTime.utc_now, delta)
|
||||
|
||||
query = from sub in WebsubClientSubscription,
|
||||
where: sub.valid_until < ^cut_off and sub.state == "active"
|
||||
where: sub.valid_until < ^cut_off and sub.state == "accepted"
|
||||
|
||||
subs = Repo.all(query)
|
||||
|
||||
|
|
|
@ -179,8 +179,8 @@ test "sign a text" do
|
|||
test "it renews subscriptions that have less than a day of time left" do
|
||||
day = 60 * 60 * 24
|
||||
now = NaiveDateTime.utc_now
|
||||
still_good = insert(:websub_client_subscription, %{valid_until: NaiveDateTime.add(now, 2 * day), topic: "http://example.org/still_good", state: "active"})
|
||||
needs_refresh = insert(:websub_client_subscription, %{valid_until: NaiveDateTime.add(now, day - 100), topic: "http://example.org/needs_refresh", state: "active"})
|
||||
still_good = insert(:websub_client_subscription, %{valid_until: NaiveDateTime.add(now, 2 * day), topic: "http://example.org/still_good", state: "accepted"})
|
||||
needs_refresh = insert(:websub_client_subscription, %{valid_until: NaiveDateTime.add(now, day - 100), topic: "http://example.org/needs_refresh", state: "accepted"})
|
||||
|
||||
refresh = Websub.refresh_subscriptions()
|
||||
|
||||
|
|
Loading…
Reference in a new issue