mirrors/akkoma
1
0
Fork 1
mirror of https://akkoma.dev/AkkomaGang/akkoma.git synced 2024-11-10 03:17:51 +00:00
Code Issues Projects Releases Packages Wiki Activity

enforce visibility

Browse source
This commit is contained in:
sadposter 2021-12-12 18:25:20 +00:00
parent fdeef7d4df
commit 23c758bbe7
2 changed files with 11 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

10
lib/mix/tasks/pleroma/search.ex
View file

@ -15,13 +15,15 @@ defmodule Mix.Tasks.Pleroma.Search do
start_pleroma()
from(a in Activity, where: not ilike(a.actor, "%/relay"))
|> where([a], fragment("(? ->> 'type'::text) = 'Create'", a.data))
|> Activity.with_preloaded_object()
|> Activity.with_preloaded_user_actor()
|> get_all
end
defp get_all(query, max_id \\ nil) do
params = %{limit: 20}
IO.puts(max_id)
params = %{limit: 2000}
params =
if max_id == nil do
@ -38,6 +40,12 @@ defmodule Mix.Tasks.Pleroma.Search do
:ok
else
res
|> Enum.filter(fn x ->
t = x.object
|> Map.get(:data, %{})
|> Map.get("type", "")
t == "Note"
end)
|> Pleroma.Elasticsearch.bulk_post(:activities)
get_all(query, List.last(res).id)

2
lib/pleroma/search/elasticsearch.ex
View file

@ -2,6 +2,7 @@ defmodule Pleroma.Search.Elasticsearch do
@behaviour Pleroma.Search
alias Pleroma.Web.MastodonAPI.StatusView
alias Pleroma.Web.ActivityPub.Visibility
defp to_es(term) when is_binary(term) do
%{
@ -62,6 +63,7 @@ defmodule Pleroma.Search.Elasticsearch do
|> Map.get("hits", [])
|> Enum.map(fn result -> result["_id"] end)
|> Pleroma.Activity.all_by_ids_with_object()
|> Enum.filter(fn x -> Visibility.visible_for_user?(x, user) end)
%{
"accounts" => [],