hj/pleroma
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity

Add test to fetch and validate an activity that originally failed signature

Browse source
This commit is contained in:
Mark Felder 2024-07-25 14:33:51 -04:00
commit a964368e31
6 changed files with 492 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

6
lib/pleroma/web/federator.ex
View file

@ -35,10 +35,12 @@ defmodule Pleroma.Web.Federator do
end
# Client API
def incoming_ap_doc(%{params: params, req_headers: req_headers}) do
def incoming_ap_doc(%{params: _params, req_headers: _req_headers} = args) do
job_args = Enum.into(args, %{}, fn {k, v} -> {Atom.to_string(k), v} end)
ReceiverWorker.enqueue(
"incoming_ap_doc",
%{"req_headers" => req_headers, "params" => params, "timeout" => :timer.seconds(20)},
Map.put(job_args, "timeout", :timer.seconds(20)),
priority: 2
)
end

2
lib/pleroma/workers/receiver_worker.ex
View file

@ -25,7 +25,7 @@ defmodule Pleroma.Workers.ReceiverWorker do
# Revert it for the signature validation.
req_headers = Enum.into(req_headers, [], &List.to_tuple(&1))
conn_data = %{
conn_data = %Plug.Conn{
method: method,
params: params,
req_headers: req_headers,