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

   1 # Pleroma: A lightweight social networking server
   2 # Copyright © 2017-2020 Pleroma Authors <https://pleroma.social/>
   3 # SPDX-License-Identifier: AGPL-3.0-only
   4
   5 defmodule Pleroma.Workers.BackupWorker do
   6   use Oban.Worker, queue: :backup, max_attempts: 1
   7
   8   alias Oban.Job
   9   alias Pleroma.Backup
  10
  11   def process(backup) do
  12     %{"op" => "process", "backup_id" => backup.id}
  13     |> new()
  14     |> Oban.insert()
  15   end
  16
  17   def schedule_deletion(backup) do
  18     days = Pleroma.Config.get([Pleroma.Backup, :purge_after_days])
  19     time = 60 * 60 * 24 * days
  20     scheduled_at = Calendar.NaiveDateTime.add!(backup.inserted_at, time)
  21
  22     %{"op" => "delete", "backup_id" => backup.id}
  23     |> new(scheduled_at: scheduled_at)
  24     |> Oban.insert()
  25   end
  26
  27   def delete(backup) do
  28     %{"op" => "delete", "backup_id" => backup.id}
  29     |> new()
  30     |> Oban.insert()
  31   end
  32
  33   def perform(%Job{args: %{"op" => "process", "backup_id" => backup_id}}) do
  34     with {:ok, %Backup{} = backup} <-
  35            backup_id |> Backup.get() |> Backup.process(),
  36          {:ok, _job} <- schedule_deletion(backup),
  37          :ok <- Backup.remove_outdated(backup),
  38          {:ok, _} <-
  39            backup
  40            |> Pleroma.Emails.UserEmail.backup_is_ready_email()
  41            |> Pleroma.Emails.Mailer.deliver() do
  42       {:ok, backup}
  43     end
  44   end
  45
  46   def perform(%Job{args: %{"op" => "delete", "backup_id" => backup_id}}) do
  47     case Backup.get(backup_id) do
  48       %Backup{} = backup -> Backup.delete(backup)
  49       nil -> :ok
  50     end
  51   end
  52 end