forked from AkkomaGang/akkoma
Fix tests
This commit is contained in:
parent
63c493cd53
commit
768c1a5de1
1 changed files with 6 additions and 2 deletions
|
@ -486,8 +486,12 @@ def maybe_notify_subscribers(recipients, %Activity{
|
||||||
recipients
|
recipients
|
||||||
end
|
end
|
||||||
|
|
||||||
def maybe_notify_subscribers(recipients, %Activity{data: %{"type" => "Create"}} = activity) do
|
def maybe_notify_subscribers(
|
||||||
with %User{} = user <- User.get_cached_by_ap_id(activity.actor) do
|
recipients,
|
||||||
|
%Activity{data: %{"actor" => actor, "type" => type}} = activity
|
||||||
|
)
|
||||||
|
when type == "Create" do
|
||||||
|
with %User{} = user <- User.get_cached_by_ap_id(actor) do
|
||||||
subscriber_ids =
|
subscriber_ids =
|
||||||
user
|
user
|
||||||
|> User.subscribers()
|
|> User.subscribers()
|
||||||
|
|
Loading…
Reference in a new issue