projects
/
akkoma
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
make 2fa UI less awful
[akkoma]
/
lib
/
pleroma
/
web
/
federator.ex
diff --git
a/lib/pleroma/web/federator.ex
b/lib/pleroma/web/federator.ex
index 770044de26bbe38566053df5dd99886c3c28bd9b..3a00424c67b72ec848e5a49cc4578e8cbf64ffe4 100644
(file)
--- a/
lib/pleroma/web/federator.ex
+++ b/
lib/pleroma/web/federator.ex
@@
-48,7
+48,9
@@
defmodule Pleroma.Web.Federator do
@impl true
def publish(%{data: %{"object" => object}} = activity) when is_binary(object) do
@impl true
def publish(%{data: %{"object" => object}} = activity) when is_binary(object) do
- PublisherWorker.enqueue("publish", %{"activity_id" => activity.id, "object_data" => nil})
+ PublisherWorker.enqueue("publish", %{"activity_id" => activity.id, "object_data" => nil},
+ priority: publish_priority(activity)
+ )
end
@impl true
end
@impl true
@@
-63,7
+65,7
@@
defmodule Pleroma.Web.Federator do
)
end
)
end
- defp publish_priority(%{
type: "Delete"
}), do: 3
+ defp publish_priority(%{
data: %{"type" => "Delete"}
}), do: 3
defp publish_priority(_), do: 0
# Job Worker Callbacks
defp publish_priority(_), do: 0
# Job Worker Callbacks