+ defp restrict_since(query, %{"since_id" => since_id}) do
+ from(activity in query, where: activity.id > ^since_id)
+ end
+
+ defp restrict_since(query, _), do: query
+
+ defp restrict_tag(query, %{"tag" => tag}) do
+ from(
+ activity in query,
+ where: fragment("? <@ (? #> '{\"object\",\"tag\"}')", ^tag, activity.data)
+ )
+ end
+
+ defp restrict_tag(query, _), do: query
+
+ defp restrict_recipients(query, [], _user), do: query
+
+ defp restrict_recipients(query, recipients, nil) do
+ from(activity in query, where: fragment("? && ?", ^recipients, activity.recipients))
+ end
+
+ defp restrict_recipients(query, recipients, user) do
+ from(
+ activity in query,
+ where: fragment("? && ?", ^recipients, activity.recipients),
+ or_where: activity.actor == ^user.ap_id
+ )
+ end
+
+ defp restrict_limit(query, %{"limit" => limit}) do
+ from(activity in query, limit: ^limit)
+ end
+
+ defp restrict_limit(query, _), do: query
+
+ defp restrict_local(query, %{"local_only" => true}) do
+ from(activity in query, where: activity.local == true)
+ end
+
+ defp restrict_local(query, _), do: query
+
+ defp restrict_max(query, %{"max_id" => max_id}) do
+ from(activity in query, where: activity.id < ^max_id)
+ end
+
+ defp restrict_max(query, _), do: query
+
+ defp restrict_actor(query, %{"actor_id" => actor_id}) do
+ from(activity in query, where: activity.actor == ^actor_id)
+ end
+
+ defp restrict_actor(query, _), do: query
+
+ defp restrict_type(query, %{"type" => type}) when is_binary(type) do
+ restrict_type(query, %{"type" => [type]})
+ end
+
+ defp restrict_type(query, %{"type" => type}) do
+ from(activity in query, where: fragment("?->>'type' = ANY(?)", activity.data, ^type))
+ end
+
+ defp restrict_type(query, _), do: query
+
+ defp restrict_favorited_by(query, %{"favorited_by" => ap_id}) do
+ from(
+ activity in query,
+ where: fragment("? <@ (? #> '{\"object\",\"likes\"}')", ^ap_id, activity.data)
+ )
+ end
+
+ defp restrict_favorited_by(query, _), do: query
+
+ defp restrict_media(query, %{"only_media" => val}) when val == "true" or val == "1" do
+ from(
+ activity in query,
+ where: fragment("not (? #> '{\"object\",\"attachment\"}' = ?)", activity.data, ^[])
+ )
+ end
+
+ defp restrict_media(query, _), do: query
+
+ # Only search through last 100_000 activities by default
+ defp restrict_recent(query, %{"whole_db" => true}), do: query
+
+ defp restrict_recent(query, _) do
+ since = (Repo.aggregate(Activity, :max, :id) || 0) - 100_000
+
+ from(activity in query, where: activity.id > ^since)
+ end
+
+ defp restrict_blocked(query, %{"blocking_user" => %User{info: info}}) do
+ blocks = info["blocks"] || []
+ domain_blocks = info["domain_blocks"] || []
+
+ from(
+ activity in query,
+ where: fragment("not (? = ANY(?))", activity.actor, ^blocks),
+ where: fragment("not (?->'to' \\?| ?)", activity.data, ^blocks),
+ where: fragment("not (split_part(?, '/', 3) = ANY(?))", activity.actor, ^domain_blocks)
+ )
+ end
+
+ defp restrict_blocked(query, _), do: query
+
+ defp restrict_unlisted(query) do
+ from(
+ activity in query,
+ where:
+ fragment(
+ "not (coalesce(?->'cc', '{}'::jsonb) \\?| ?)",
+ activity.data,
+ ^["https://www.w3.org/ns/activitystreams#Public"]
+ )
+ )
+ end
+
+ def fetch_activities_query(recipients, opts \\ %{}) do
+ base_query =
+ from(
+ activity in Activity,
+ limit: 20,
+ order_by: [fragment("? desc nulls last", activity.id)]
+ )
+
+ base_query
+ |> restrict_recipients(recipients, opts["user"])
+ |> restrict_tag(opts)
+ |> restrict_since(opts)
+ |> restrict_local(opts)
+ |> restrict_limit(opts)
+ |> restrict_max(opts)
+ |> restrict_actor(opts)
+ |> restrict_type(opts)
+ |> restrict_favorited_by(opts)
+ |> restrict_recent(opts)
+ |> restrict_blocked(opts)
+ |> restrict_media(opts)
+ |> restrict_visibility(opts)