git.squeep.com Git - akkoma/blob - lib/pleroma/workers/cron/scheduled_activity_worker.ex

   1 # Pleroma: A lightweight social networking server
   2 # Copyright © 2017-2019 Pleroma Authors <https://pleroma.social/>
   3 # SPDX-License-Identifier: AGPL-3.0-only
   4
   5 defmodule Pleroma.Workers.Cron.ScheduledActivityWorker do
   6   @moduledoc """
   7   The worker to post scheduled actvities.
   8   """
   9
  10   use Oban.Worker, queue: "scheduled_activities"
  11   alias Pleroma.Config
  12   alias Pleroma.ScheduledActivity
  13   alias Pleroma.User
  14   alias Pleroma.Web.CommonAPI
  15
  16   require Logger
  17
  18   @schedule_interval :timer.minutes(1)
  19
  20   @impl Oban.Worker
  21   def perform(_opts, _job) do
  22     if Config.get([ScheduledActivity, :enabled]) do
  23       @schedule_interval
  24       |> ScheduledActivity.due_activities()
  25       |> Enum.each(&post_activity/1)
  26     end
  27   end
  28
  29   def post_activity(scheduled_activity) do
  30     try do
  31       {:ok, scheduled_activity} = ScheduledActivity.delete(scheduled_activity)
  32       %User{} = user = User.get_cached_by_id(scheduled_activity.user_id)
  33       {:ok, _result} = CommonAPI.post(user, scheduled_activity.params)
  34     rescue
  35       error ->
  36         Logger.error(
  37           "#{__MODULE__} Couldn't create a status from the scheduled activity: #{inspect(error)}"
  38         )
  39     end
  40   end
  41 end