diff options
author | Alex Gleason <alex@alexgleason.me> | 2021-07-18 10:49:35 -0500 |
---|---|---|
committer | Alex Gleason <alex@alexgleason.me> | 2021-07-18 10:49:35 -0500 |
commit | 0a13ad421925a56e5a5ef05a6f8b0bda9cde4417 (patch) | |
tree | 1d28fe6ff241a97a2b0834c39411d1c6c920954a /lib | |
parent | f9eeae3b77e0403539cf7420970fbe728072ef74 (diff) | |
download | pleroma-0a13ad421925a56e5a5ef05a6f8b0bda9cde4417.tar.gz |
PollWorker defensive checks
Diffstat (limited to 'lib')
-rw-r--r-- | lib/pleroma/workers/poll_worker.ex | 6 |
1 files changed, 4 insertions, 2 deletions
diff --git a/lib/pleroma/workers/poll_worker.ex b/lib/pleroma/workers/poll_worker.ex index caec89cbe..3423cc889 100644 --- a/lib/pleroma/workers/poll_worker.ex +++ b/lib/pleroma/workers/poll_worker.ex @@ -26,8 +26,10 @@ defmodule Pleroma.Workers.PollWorker do end def schedule_poll_end(%Activity{data: %{"type" => "Create"}, id: activity_id} = activity) do - with %Object{data: %{"type" => "Question", "closed" => closed}} <- Object.normalize(activity), - {:ok, end_time} <- NaiveDateTime.from_iso8601(closed) do + with %Object{data: %{"type" => "Question", "closed" => closed}} when is_binary(closed) <- + Object.normalize(activity), + {:ok, end_time} <- NaiveDateTime.from_iso8601(closed), + :gt <- NaiveDateTime.compare(end_time, NaiveDateTime.utc_now()) do %{ op: "poll_end", activity_id: activity_id |