re-enable deactivated check
This commit is contained in:
parent
b63dd6a5a2
commit
6a6260f64e
|
@ -462,9 +462,9 @@ def run(["timeline_query", nickname]) do
|
||||||
|> Map.put(:user, user)
|
|> Map.put(:user, user)
|
||||||
|> Map.put(:local_only, params[:local])
|
|> Map.put(:local_only, params[:local])
|
||||||
|> Map.delete(:local)
|
|> Map.delete(:local)
|
||||||
activities =
|
_activities =
|
||||||
[user.ap_id | User.following(user)]
|
[user.ap_id | User.following(user)]
|
||||||
|> ActivityPub.fetch_activities_secret(params)
|
|> ActivityPub.fetch_activities(params)
|
||||||
end
|
end
|
||||||
end
|
end
|
||||||
|
|
||||||
|
|
|
@ -362,11 +362,10 @@ def following_requests_for_actor(%User{ap_id: ap_id}) do
|
||||||
end
|
end
|
||||||
|
|
||||||
def restrict_deactivated_users(query) do
|
def restrict_deactivated_users(query) do
|
||||||
deactivated_users =
|
deactivated_users_query =
|
||||||
from(u in User.Query.build(%{deactivated: true}), select: u.ap_id)
|
from(u in User.Query.build(%{deactivated: true}), select: u.ap_id)
|
||||||
|> Repo.all()
|
|
||||||
|
|
||||||
Activity.Queries.exclude_authors(query, deactivated_users)
|
from(activity in query, where: activity.actor not in subquery(deactivated_users_query))
|
||||||
end
|
end
|
||||||
|
|
||||||
defdelegate search(user, query, options \\ []), to: Pleroma.Activity.Search
|
defdelegate search(user, query, options \\ []), to: Pleroma.Activity.Search
|
||||||
|
|
|
@ -494,15 +494,6 @@ def fetch_activities(recipients, opts \\ %{}, pagination \\ :keyset) do
|
||||||
|> maybe_update_cc(list_memberships, opts[:user])
|
|> maybe_update_cc(list_memberships, opts[:user])
|
||||||
end
|
end
|
||||||
|
|
||||||
def fetch_activities_secret(recipients, opts \\ %{}, pagination \\ :keyset) do
|
|
||||||
list_memberships = Pleroma.List.memberships(opts[:user])
|
|
||||||
|
|
||||||
fetch_activities_query_secret(recipients ++ list_memberships, opts)
|
|
||||||
|> fetch_paginated_optimized(opts, pagination)
|
|
||||||
|> Enum.reverse()
|
|
||||||
end
|
|
||||||
|
|
||||||
|
|
||||||
@spec fetch_public_or_unlisted_activities(map(), Pagination.type()) :: [Activity.t()]
|
@spec fetch_public_or_unlisted_activities(map(), Pagination.type()) :: [Activity.t()]
|
||||||
def fetch_public_or_unlisted_activities(opts \\ %{}, pagination \\ :keyset) do
|
def fetch_public_or_unlisted_activities(opts \\ %{}, pagination \\ :keyset) do
|
||||||
opts = Map.delete(opts, :user)
|
opts = Map.delete(opts, :user)
|
||||||
|
@ -1318,63 +1309,6 @@ defp fetch_activities_query_ap_ids_ops(opts) do
|
||||||
{restrict_blocked_opts, restrict_muted_opts, restrict_muted_reblogs_opts}
|
{restrict_blocked_opts, restrict_muted_opts, restrict_muted_reblogs_opts}
|
||||||
end
|
end
|
||||||
|
|
||||||
def fetch_activities_query_secret(recipients, opts \\ %{}) do
|
|
||||||
opts = normalize_fetch_activities_query_opts(opts)
|
|
||||||
|
|
||||||
{restrict_blocked_opts, restrict_muted_opts, restrict_muted_reblogs_opts} =
|
|
||||||
fetch_activities_query_ap_ids_ops(opts)
|
|
||||||
|
|
||||||
config = %{
|
|
||||||
skip_thread_containment: true
|
|
||||||
}
|
|
||||||
|
|
||||||
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)
|
|
||||||
|> 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
|
|
||||||
|
|
||||||
def fetch_activities_query(recipients, opts \\ %{}) do
|
def fetch_activities_query(recipients, opts \\ %{}) do
|
||||||
opts = normalize_fetch_activities_query_opts(opts)
|
opts = normalize_fetch_activities_query_opts(opts)
|
||||||
|
|
||||||
|
@ -1414,6 +1348,7 @@ def fetch_activities_query(recipients, opts \\ %{}) do
|
||||||
|> restrict_instance(opts)
|
|> restrict_instance(opts)
|
||||||
|> restrict_announce_object_actor(opts)
|
|> restrict_announce_object_actor(opts)
|
||||||
|> restrict_filtered(opts)
|
|> restrict_filtered(opts)
|
||||||
|
|> Activity.restrict_deactivated_users()
|
||||||
|> exclude_poll_votes(opts)
|
|> exclude_poll_votes(opts)
|
||||||
|> exclude_chat_messages(opts)
|
|> exclude_chat_messages(opts)
|
||||||
|> exclude_invisible_actors(opts)
|
|> exclude_invisible_actors(opts)
|
||||||
|
|
Loading…
Reference in a new issue