aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorAlex Gleason <alex@alexgleason.me>2021-07-18 10:49:35 -0500
committerAlex Gleason <alex@alexgleason.me>2021-07-18 11:10:22 -0500
commit6a6e42c9bfe7e381cb72d685bd982e55edcf5d38 (patch)
tree8e5e16f17cba9cda9bc4dc887b0b364d4d443628
parentcbd1a10c16db026fac96fa2ddcb05b4eb106d290 (diff)
downloadpleroma-6a6e42c9bfe7e381cb72d685bd982e55edcf5d38.tar.gz
PollWorker defensive checks
-rw-r--r--lib/pleroma/workers/poll_worker.ex6
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