projects
/
akkoma
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
Merge branch 'develop' of https://git.pleroma.social/pleroma/pleroma into develop
[akkoma]
/
lib
/
pleroma
/
web
/
push
/
impl.ex
diff --git
a/lib/pleroma/web/push/impl.ex
b/lib/pleroma/web/push/impl.ex
index 4d65ca5d546a9803c78b97fde1b3e0b85eefbc32..8635731852b9921b61093d1b5c5e432af17d99fa 100644
(file)
--- a/
lib/pleroma/web/push/impl.ex
+++ b/
lib/pleroma/web/push/impl.ex
@@
-5,13
+5,13
@@
defmodule Pleroma.Web.Push.Impl do
@moduledoc "The module represents implementation push web notification"
defmodule Pleroma.Web.Push.Impl do
@moduledoc "The module represents implementation push web notification"
- alias Pleroma.Repo
- alias Pleroma.User
alias Pleroma.Activity
alias Pleroma.Activity
+ alias Pleroma.Notification
alias Pleroma.Object
alias Pleroma.Object
- alias Pleroma.Web.Push.Subscription
+ alias Pleroma.Repo
+ alias Pleroma.User
alias Pleroma.Web.Metadata.Utils
alias Pleroma.Web.Metadata.Utils
- alias Pleroma.
Notifica
tion
+ alias Pleroma.
Web.Push.Subscrip
tion
require Logger
import Ecto.Query
require Logger
import Ecto.Query
@@
-20,7
+20,10
@@
defmodule Pleroma.Web.Push.Impl do
@doc "Performs sending notifications for user subscriptions"
@spec perform_send(Notification.t()) :: list(any)
@doc "Performs sending notifications for user subscriptions"
@spec perform_send(Notification.t()) :: list(any)
- def perform_send(%{activity: %{data: %{"type" => activity_type}, id: activity_id}, user_id: user_id} = notif)
+ def perform_send(
+ %{activity: %{data: %{"type" => activity_type}, id: activity_id}, user_id: user_id} =
+ notif
+ )
when activity_type in @types do
actor = User.get_cached_by_ap_id(notif.activity.data["actor"])
when activity_type in @types do
actor = User.get_cached_by_ap_id(notif.activity.data["actor"])