mirrors/pleroma
1
0
Fork 0
mirror of https://git.pleroma.social/pleroma/pleroma.git synced 2024-12-22 16:16:34 +00:00
Code Issues Projects Releases Wiki Activity

Rename assignment for consistency

Browse source
This commit is contained in:
Mark Felder 2024-09-30 14:23:04 -04:00
parent 47ce3a4a96
commit a2e7db43aa
1 changed files with 2 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

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

@ -36,8 +36,8 @@ defmodule Pleroma.Workers.PollWorker do
def perform(%Job{args: %{"op" => "refresh", "activity_id" => activity_id}}) do def perform(%Job{args: %{"op" => "refresh", "activity_id" => activity_id}}) do
with {_, %Activity{object: object}} <- with {_, %Activity{object: object}} <-
{:activity, Activity.get_by_id_with_object(activity_id)}, {:activity, Activity.get_by_id_with_object(activity_id)},
{:ok, naive_closed} <- NaiveDateTime.from_iso8601(object.data["closed"]), {:ok, end_time} <- NaiveDateTime.from_iso8601(object.data["closed"]),
{_, :lt} <- {:closed_compare, NaiveDateTime.compare(object.updated_at, naive_closed)}, {_, :lt} <- {:closed_compare, NaiveDateTime.compare(object.updated_at, end_time)},
{_, {:ok, _object}} <- {:refetch, Fetcher.refetch_object(object)} do {_, {:ok, _object}} <- {:refetch, Fetcher.refetch_object(object)} do
stream_update(activity_id) stream_update(activity_id)