projects
/
akkoma
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
Merge remote-tracking branch 'origin/develop' into benchmark-finishing
[akkoma]
/
lib
/
pleroma
/
web
/
oauth
/
token
/
clean_worker.ex
diff --git
a/lib/pleroma/web/oauth/token/clean_worker.ex
b/lib/pleroma/web/oauth/token/clean_worker.ex
index f50098302649b25873792a0dc885876c120951c7..f639f9c6fd202c38ea753c9336192700df93ddc2 100644
(file)
--- a/
lib/pleroma/web/oauth/token/clean_worker.ex
+++ b/
lib/pleroma/web/oauth/token/clean_worker.ex
@@
-1,5
+1,5
@@
# Pleroma: A lightweight social networking server
# Pleroma: A lightweight social networking server
-# Copyright © 2017-201
8
Pleroma Authors <https://pleroma.social/>
+# Copyright © 2017-201
9
Pleroma Authors <https://pleroma.social/>
# SPDX-License-Identifier: AGPL-3.0-only
defmodule Pleroma.Web.OAuth.Token.CleanWorker do
# SPDX-License-Identifier: AGPL-3.0-only
defmodule Pleroma.Web.OAuth.Token.CleanWorker do
@@
-17,6
+17,7
@@
defmodule Pleroma.Web.OAuth.Token.CleanWorker do
)
alias Pleroma.Web.OAuth.Token
)
alias Pleroma.Web.OAuth.Token
+ alias Pleroma.Workers.BackgroundWorker
def start_link(_), do: GenServer.start_link(__MODULE__, %{})
def start_link(_), do: GenServer.start_link(__MODULE__, %{})
@@
-27,9
+28,11
@@
defmodule Pleroma.Web.OAuth.Token.CleanWorker do
@doc false
def handle_info(:perform, state) do
@doc false
def handle_info(:perform, state) do
-
Token.delete_expired_tokens(
)
+
BackgroundWorker.enqueue("clean_expired_tokens", %{}
)
Process.send_after(self(), :perform, @interval)
{:noreply, state}
end
Process.send_after(self(), :perform, @interval)
{:noreply, state}
end
+
+ def perform(:clean), do: Token.delete_expired_tokens()
end
end