forked from AkkomaGang/akkoma
Notification: Small refactor.
This commit is contained in:
parent
f0fefc4f5c
commit
d91c4feebe
2 changed files with 3 additions and 3 deletions
|
@ -649,8 +649,8 @@ def for_user_and_activity(user, activity) do
|
|||
|> Repo.one()
|
||||
end
|
||||
|
||||
@spec mark_as_read(User.t(), Activity.t()) :: {integer(), nil | [term()]}
|
||||
def mark_as_read(%User{id: id}, %Activity{data: %{"context" => context}}) do
|
||||
@spec mark_context_as_read(User.t(), String.t()) :: {integer(), nil | [term()]}
|
||||
def mark_context_as_read(%User{id: id}, context) do
|
||||
from(
|
||||
n in Notification,
|
||||
join: a in assoc(n, :activity),
|
||||
|
|
|
@ -453,7 +453,7 @@ def unpin(id, user) do
|
|||
|
||||
def add_mute(user, activity) do
|
||||
with {:ok, _} <- ThreadMute.add_mute(user.id, activity.data["context"]),
|
||||
_ <- Pleroma.Notification.mark_as_read(user, activity) do
|
||||
_ <- Pleroma.Notification.mark_context_as_read(user, activity.data["context"]) do
|
||||
{:ok, activity}
|
||||
else
|
||||
{:error, _} -> {:error, dgettext("errors", "conversation is already muted")}
|
||||
|
|
Loading…
Reference in a new issue