projects
/
akkoma
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
add Markers /api/v1/markers
[akkoma]
/
lib
/
pleroma
/
web
/
federator
/
publisher.ex
diff --git
a/lib/pleroma/web/federator/publisher.ex
b/lib/pleroma/web/federator/publisher.ex
index e8c1bf17f26c36e481c87bc8c8cee4b627edbd9c..937064638fc72ee9d8d1b21b80ac34656e17fc89 100644
(file)
--- a/
lib/pleroma/web/federator/publisher.ex
+++ b/
lib/pleroma/web/federator/publisher.ex
@@
-6,6
+6,7
@@
defmodule Pleroma.Web.Federator.Publisher do
alias Pleroma.Activity
alias Pleroma.Config
alias Pleroma.User
alias Pleroma.Activity
alias Pleroma.Config
alias Pleroma.User
+ alias Pleroma.Workers.PublisherWorker
require Logger
require Logger
@@
-30,9
+31,10
@@
defmodule Pleroma.Web.Federator.Publisher do
"""
@spec enqueue_one(module(), Map.t()) :: :ok
def enqueue_one(module, %{} = params) do
"""
@spec enqueue_one(module(), Map.t()) :: :ok
def enqueue_one(module, %{} = params) do
- %{module: to_string(module), params: params}
- |> Pleroma.Workers.Publisher.new()
- |> Pleroma.Repo.insert()
+ PublisherWorker.enqueue(
+ "publish_one",
+ %{"module" => to_string(module), "params" => params}
+ )
end
@doc """
end
@doc """