qbism/qb_akkoma
1
0
Fork 0
forked from AkkomaGang/akkoma
Code Issues Pull requests Projects Releases Packages Wiki Activity

PollWorker defensive checks

Browse source
This commit is contained in:
Alex Gleason 2021-07-18 10:49:35 -05:00
parent cbd1a10c16
commit 6a6e42c9bf
No known key found for this signature in database
GPG key ID: 7211D1F99744FBB7
1 changed files with 4 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
lib/pleroma/workers/poll_worker.ex
View file

@ -26,8 +26,10 @@ defp find_poll_activity(activity_id) do
end end
def schedule_poll_end(%Activity{data: %{"type" => "Create"}, id: activity_id} = activity) do def schedule_poll_end(%Activity{data: %{"type" => "Create"}, id: activity_id} = activity) do
with %Object{data: %{"type" => "Question", "closed" => closed}} <- Object.normalize(activity), with %Object{data: %{"type" => "Question", "closed" => closed}} when is_binary(closed) <-
{:ok, end_time} <- NaiveDateTime.from_iso8601(closed) do Object.normalize(activity),
{:ok, end_time} <- NaiveDateTime.from_iso8601(closed),
:gt <- NaiveDateTime.compare(end_time, NaiveDateTime.utc_now()) do
%{ %{
op: "poll_end", op: "poll_end",
activity_id: activity_id activity_id: activity_id