From: Alex Gleason <alex@alexgleason.me>
Date: Thu, 29 Apr 2021 16:14:32 +0000 (-0500)
Subject: Merge remote-tracking branch 'upstream/develop' into block-behavior
X-Git-Url: https://git.squeep.com/?a=commitdiff_plain;h=762be6ce10d2145e8e31d42c5d1a0bab93dbe7b0;p=akkoma

Merge remote-tracking branch 'upstream/develop' into block-behavior
---

762be6ce10d2145e8e31d42c5d1a0bab93dbe7b0
diff --cc lib/pleroma/notification.ex
index e9c9b3ea2,7efbdc49a..4cc9a5669
--- a/lib/pleroma/notification.ex
+++ b/lib/pleroma/notification.ex
@@@ -129,10 -122,11 +122,12 @@@ defmodule Pleroma.Notification d
            a.data
          )
      )
+     |> join(:inner, [_n, a], u in User, on: u.ap_id == a.actor, as: :user_actor)
      |> preload([n, a, o], activity: {a, object: o})
+     |> where([user_actor: user_actor], user_actor.is_active)
      |> exclude_notification_muted(user, exclude_notification_muted_opts)
      |> exclude_blocked(user, exclude_blocked_opts)
 +    |> exclude_blockers(user)
      |> exclude_filtered(user)
      |> exclude_visibility(opts)
    end
diff --cc lib/pleroma/web/activity_pub/activity_pub.ex
index 0923e19e4,d0051d1cb..a35ba1fad
--- a/lib/pleroma/web/activity_pub/activity_pub.ex
+++ b/lib/pleroma/web/activity_pub/activity_pub.ex
@@@ -1137,50 -1270,51 +1309,52 @@@ defmodule Pleroma.Web.ActivityPub.Activ
        skip_thread_containment: Config.get([:instance, :skip_thread_containment])
      }
  
-     Activity
-     |> maybe_preload_objects(opts)
-     |> maybe_preload_bookmarks(opts)
-     |> maybe_preload_report_notes(opts)
-     |> maybe_set_thread_muted_field(opts)
-     |> maybe_order(opts)
-     |> restrict_recipients(recipients, opts[:user])
-     |> restrict_replies(opts)
-     |> restrict_tag(opts)
-     |> restrict_tag_reject(opts)
-     |> restrict_tag_all(opts)
-     |> restrict_since(opts)
-     |> restrict_local(opts)
-     |> restrict_actor(opts)
-     |> restrict_type(opts)
-     |> restrict_state(opts)
-     |> restrict_favorited_by(opts)
-     |> restrict_blocked(restrict_blocked_opts)
-     |> restrict_blockers_visibility(opts)
-     |> restrict_muted(restrict_muted_opts)
-     |> restrict_filtered(opts)
-     |> restrict_media(opts)
-     |> restrict_visibility(opts)
-     |> restrict_thread_visibility(opts, config)
-     |> restrict_reblogs(opts)
-     |> restrict_pinned(opts)
-     |> restrict_muted_reblogs(restrict_muted_reblogs_opts)
-     |> restrict_instance(opts)
-     |> restrict_announce_object_actor(opts)
-     |> restrict_filtered(opts)
-     |> Activity.restrict_deactivated_users()
-     |> exclude_poll_votes(opts)
-     |> exclude_chat_messages(opts)
-     |> exclude_invisible_actors(opts)
-     |> exclude_visibility(opts)
-   end
- 
-   def fetch_activities(recipients, opts \\ %{}, pagination \\ :keyset) do
-     list_memberships = Pleroma.List.memberships(opts[:user])
- 
-     fetch_activities_query(recipients ++ list_memberships, opts)
-     |> Pagination.fetch_paginated(opts, pagination)
-     |> Enum.reverse()
-     |> maybe_update_cc(list_memberships, opts[:user])
+     query =
+       Activity
+       |> maybe_preload_objects(opts)
+       |> maybe_preload_bookmarks(opts)
+       |> maybe_preload_report_notes(opts)
+       |> maybe_set_thread_muted_field(opts)
+       |> maybe_order(opts)
+       |> restrict_recipients(recipients, opts[:user])
+       |> restrict_replies(opts)
+       |> restrict_since(opts)
+       |> restrict_local(opts)
+       |> restrict_remote(opts)
+       |> restrict_actor(opts)
+       |> restrict_type(opts)
+       |> restrict_state(opts)
+       |> restrict_favorited_by(opts)
+       |> restrict_blocked(restrict_blocked_opts)
++      |> restrict_blockers_visibility(opts)
+       |> restrict_muted(restrict_muted_opts)
+       |> restrict_filtered(opts)
+       |> restrict_media(opts)
+       |> restrict_visibility(opts)
+       |> restrict_thread_visibility(opts, config)
+       |> restrict_reblogs(opts)
+       |> restrict_pinned(opts)
+       |> restrict_muted_reblogs(restrict_muted_reblogs_opts)
+       |> restrict_instance(opts)
+       |> restrict_announce_object_actor(opts)
+       |> restrict_filtered(opts)
+       |> Activity.restrict_deactivated_users()
+       |> exclude_poll_votes(opts)
+       |> exclude_chat_messages(opts)
+       |> exclude_invisible_actors(opts)
+       |> exclude_visibility(opts)
+ 
+     if Config.feature_enabled?(:improved_hashtag_timeline) do
+       query
+       |> restrict_hashtag_any(opts)
+       |> restrict_hashtag_all(opts)
+       |> restrict_hashtag_reject_any(opts)
+     else
+       query
+       |> restrict_embedded_tag_any(opts)
+       |> restrict_embedded_tag_all(opts)
+       |> restrict_embedded_tag_reject_any(opts)
+     end
    end
  
    @doc """