diff options
author | Roman Chvanikov <chvanikoff@pm.me> | 2020-09-08 13:26:44 +0300 |
---|---|---|
committer | Roman Chvanikov <chvanikoff@pm.me> | 2020-09-08 13:26:44 +0300 |
commit | c56e3d4f3bfb090d19bdbe93dac6cede7616cc4d (patch) | |
tree | a7bd7e51ff5a7802199f5be95879ce824f9a2078 /lib/pleroma/workers | |
parent | d5c286b80225b51dabf4eb63ad8ab818ea534851 (diff) | |
download | pleroma-c56e3d4f3bfb090d19bdbe93dac6cede7616cc4d.tar.gz |
Add expires_in param for account mutes
Diffstat (limited to 'lib/pleroma/workers')
-rw-r--r-- | lib/pleroma/workers/mute_expire_worker.ex | 22 |
1 files changed, 22 insertions, 0 deletions
diff --git a/lib/pleroma/workers/mute_expire_worker.ex b/lib/pleroma/workers/mute_expire_worker.ex new file mode 100644 index 000000000..b8ec939a9 --- /dev/null +++ b/lib/pleroma/workers/mute_expire_worker.ex @@ -0,0 +1,22 @@ +# Pleroma: A lightweight social networking server +# Copyright © 2017-2020 Pleroma Authors <https://pleroma.social/> +# SPDX-License-Identifier: AGPL-3.0-only + +defmodule Pleroma.Workers.MuteExpireWorker do + use Pleroma.Workers.WorkerHelper, queue: "mute_expire" + + require Logger + + @impl Oban.Worker + def perform(%Job{args: %{"op" => "unmute", "muter" => muter_id, "mutee" => mutee_id}}) do + muter = Pleroma.User.get_by_id(muter_id) + mutee = Pleroma.User.get_by_id(mutee_id) + Pleroma.User.unmute(muter, mutee) + :ok + end + + def perform(any) do + Logger.error("Got call to perform(#{inspect(any)})") + :ok + end +end |