+ def fetch_public_activities(opts \\ %{}) do
+ q = fetch_activities_query(["https://www.w3.org/ns/activitystreams#Public"], opts)
+
+ q
+ |> restrict_unlisted()
+ |> Repo.all()
+ |> Enum.reverse()
+ end
+
+ @valid_visibilities ~w[direct unlisted public private]
+
+ defp restrict_visibility(query, %{visibility: "direct"}) do
+ public = "https://www.w3.org/ns/activitystreams#Public"
+
+ from(
+ activity in query,
+ join: sender in User,
+ on: sender.ap_id == activity.actor,
+ # Are non-direct statuses with no to/cc possible?
+ where:
+ fragment("not coalesce(data->'to' \\? ?, false)", ^public) and
+ fragment("not coalesce(data->'cc' \\? ?, false)", ^public) and
+ fragment("not coalesce(data->'to' \\? ?, false)", sender.follower_address)
+ )
+ end
+
+ defp restrict_visibility(_query, %{visibility: visibility})
+ when visibility not in @valid_visibilities do
+ Logger.error("Could not restrict visibility to #{visibility}")
+ end
+
+ defp restrict_visibility(query, _visibility), do: query
+
+ def fetch_user_activities(user, reading_user, params \\ %{}) do
+ params =
+ params
+ |> Map.put("type", ["Create", "Announce"])
+ |> Map.put("actor_id", user.ap_id)
+ |> Map.put("whole_db", true)
+
+ recipients =
+ if reading_user do
+ ["https://www.w3.org/ns/activitystreams#Public"] ++
+ [reading_user.ap_id | reading_user.following]
+ else
+ ["https://www.w3.org/ns/activitystreams#Public"]
+ end
+
+ fetch_activities(recipients, params)
+ |> Enum.reverse()
+ end
+
+ 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"] || []
+
+ from(
+ activity in query,
+ where: fragment("not (? = ANY(?))", activity.actor, ^blocks),
+ where: fragment("not (?->'to' \\?| ?)", activity.data, ^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)
+ end
+
+ def fetch_activities(recipients, opts \\ %{}) do
+ fetch_activities_query(recipients, opts)
+ |> Repo.all()
+ |> Enum.reverse()
+ end
+
+ def upload(file) do