1 # Pleroma: A lightweight social networking server
2 # Copyright © 2017-2020 Pleroma Authors <https://pleroma.social/>
3 # SPDX-License-Identifier: AGPL-3.0-only
5 defmodule Pleroma.Workers.BackupWorker do
6 use Oban.Worker, queue: :backup, max_attempts: 1
11 def process(backup) do
12 %{"op" => "process", "backup_id" => backup.id}
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)
22 %{"op" => "delete", "backup_id" => backup.id}
23 |> new(scheduled_at: scheduled_at)
28 %{"op" => "delete", "backup_id" => backup.id}
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) do
42 def perform(%Job{args: %{"op" => "delete", "backup_id" => backup_id}}) do
43 case Backup.get(backup_id) do
44 %Backup{} = backup -> Backup.delete(backup)