projects
/
akkoma
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
Readd threshold is not 0 check, optmization?
[akkoma]
/
lib
/
pleroma
/
web
/
federator
/
federator.ex
diff --git
a/lib/pleroma/web/federator/federator.ex
b/lib/pleroma/web/federator/federator.ex
index 46f7a497341a143c12a7b527f05ab800eee8cd18..468959a65f34883b55d07593d149b043374195eb 100644
(file)
--- a/
lib/pleroma/web/federator/federator.ex
+++ b/
lib/pleroma/web/federator/federator.ex
@@
-4,15
+4,19
@@
defmodule Pleroma.Web.Federator do
use GenServer
defmodule Pleroma.Web.Federator do
use GenServer
- alias Pleroma.User
+
alias Pleroma.Activity
alias Pleroma.Activity
- alias Pleroma.Web.{WebFinger, Websub, Salmon}
- alias Pleroma.Web.Federator.RetryQueue
+ alias Pleroma.User
+ alias Pleroma.Web.WebFinger
+ alias Pleroma.Web.Websub
+ alias Pleroma.Web.Salmon
alias Pleroma.Web.ActivityPub.ActivityPub
alias Pleroma.Web.ActivityPub.Relay
alias Pleroma.Web.ActivityPub.Transmogrifier
alias Pleroma.Web.ActivityPub.Utils
alias Pleroma.Web.ActivityPub.ActivityPub
alias Pleroma.Web.ActivityPub.Relay
alias Pleroma.Web.ActivityPub.Transmogrifier
alias Pleroma.Web.ActivityPub.Utils
+ alias Pleroma.Web.Federator.RetryQueue
alias Pleroma.Web.OStatus
alias Pleroma.Web.OStatus
+
require Logger
@websub Application.get_env(:pleroma, :websub)
require Logger
@websub Application.get_env(:pleroma, :websub)
@@
-25,7
+29,7
@@
defmodule Pleroma.Web.Federator do
def start_link do
spawn(fn ->
# 1 minute
def start_link do
spawn(fn ->
# 1 minute
- Process.sleep(1000 * 60
* 1
)
+ Process.sleep(1000 * 60)
enqueue(:refresh_subscriptions, nil)
end)
enqueue(:refresh_subscriptions, nil)
end)
@@
-124,8
+128,8
@@
defmodule Pleroma.Web.Federator do
end
end
end
end
- def handle(:publish_single_salmon,
{user_or_url, feed, poster}
) do
- Salmon.send_to_user(
user_or_url, feed, poster
)
+ def handle(:publish_single_salmon,
params
) do
+ Salmon.send_to_user(
params
)
end
def handle(:publish_single_ap, params) do
end
def handle(:publish_single_ap, params) do
@@
-196,8
+200,7
@@
defmodule Pleroma.Web.Federator do
{:noreply, %{in: {i_running_jobs, i_queue}, out: {o_running_jobs, o_queue}}}
end
{:noreply, %{in: {i_running_jobs, i_queue}, out: {o_running_jobs, o_queue}}}
end
- def handle_cast(m, state) do
- IO.inspect("Unknown: #{inspect(m)}, #{inspect(state)}")
+ def handle_cast(_, state) do
{:noreply, state}
end
{:noreply, state}
end