defmodule Mobilizon.Events do @moduledoc """ The Events context. """ import Geo.PostGIS import Ecto.Query import EctoEnum import Mobilizon.Service.Guards import Mobilizon.Storage.Ecto import Mobilizon.Events.Utils, only: [calculate_notification_time: 1] alias Ecto.{Changeset, Multi} alias Mobilizon.Actors.{Actor, Follower} alias Mobilizon.Addresses.Address alias Mobilizon.Events.{ Event, EventParticipantStats, FeedToken, Participant, Session, Tag, TagRelation, Track } alias Mobilizon.Federation.ActivityPub.Relay alias Mobilizon.Service.Export.Cachable alias Mobilizon.Service.Workers.BuildSearch alias Mobilizon.Service.Workers.EventDelayedNotificationWorker alias Mobilizon.Share alias Mobilizon.Storage.{Page, Repo} alias Mobilizon.Users.{Setting, User} defenum(EventVisibility, :event_visibility, [ :public, :unlisted, :restricted, :private ]) defenum(JoinOptions, :join_options, [ :free, :restricted, :invite ]) defenum(EventStatus, :event_status, [ :tentative, :confirmed, :cancelled ]) defenum(ParticipantRole, :participant_role, [ :not_approved, :not_confirmed, :rejected, :participant, :moderator, :administrator, :creator ]) @public_visibility [:public, :unlisted] @event_preloads [ :organizer_actor, :attributed_to, :mentions, :sessions, :tracks, :tags, :comments, :participants, :physical_address, :picture, :contacts, :media ] @participant_preloads [:event, :actor] @doc """ Gets a single event. """ @spec get_event(integer | String.t()) :: {:ok, Event.t()} | {:error, :event_not_found} def get_event(id) do case Repo.get(Event, id) do %Event{} = event -> {:ok, event} nil -> {:error, :event_not_found} end end @doc """ Gets a single event. Raises `Ecto.NoResultsError` if the event does not exist. """ @spec get_event!(integer | String.t()) :: Event.t() def get_event!(id), do: Repo.get!(Event, id) @doc """ Gets a single event, with all associations loaded. """ @spec get_event_with_preload(integer | String.t()) :: {:ok, Event.t()} | {:error, :event_not_found} def get_event_with_preload(id) do case Repo.get(Event, id) do %Event{} = event -> {:ok, Repo.preload(event, @event_preloads)} nil -> {:error, :event_not_found} end end @doc """ Gets a single event, with all associations loaded. Raises `Ecto.NoResultsError` if the event does not exist. """ @spec get_event_with_preload!(integer | String.t()) :: Event.t() def get_event_with_preload!(id) do Event |> Repo.get!(id) |> Repo.preload(@event_preloads) end @doc """ Gets an event by its URL. """ @spec get_event_by_url(String.t()) :: Event.t() | nil def get_event_by_url(url) do url |> event_by_url_query() |> Repo.one() end @doc """ Gets an event by its URL. Raises `Ecto.NoResultsError` if the event does not exist. """ @spec get_event_by_url!(String.t()) :: Event.t() def get_event_by_url!(url) do url |> event_by_url_query() |> preload_for_event() |> Repo.one!() end @doc """ Gets an event by its URL, with all associations loaded. Raises `Ecto.NoResultsError` if the event does not exist. """ @spec get_public_event_by_url_with_preload!(String.t()) :: Event.t() def get_public_event_by_url_with_preload!(url) do url |> event_by_url_query() |> filter_unlisted_and_public_visibility() |> filter_draft() |> preload_for_event() |> Repo.one!() end @doc """ Gets a public event by its UUID, with all associations loaded. """ @spec get_public_event_by_uuid_with_preload(String.t()) :: Event.t() | nil def get_public_event_by_uuid_with_preload(uuid) do uuid |> event_by_uuid_query() |> filter_unlisted_and_public_visibility() |> filter_draft() |> preload_for_event() |> Repo.one() end @spec check_if_event_has_instance_follow(String.t(), integer()) :: boolean() def check_if_event_has_instance_follow(event_uri, follower_actor_id) do Share |> join(:inner, [s], f in Follower, on: f.target_actor_id == s.actor_id) |> where([s, f], f.actor_id == ^follower_actor_id and s.uri == ^event_uri) |> Repo.exists?() end @doc """ Gets an event by its UUID, with all associations loaded. """ @spec get_event_by_uuid_with_preload(String.t()) :: Event.t() | nil def get_event_by_uuid_with_preload(uuid) do uuid |> event_by_uuid_query() |> preload_for_event() |> Repo.one() end @doc """ Gets an actor's eventual upcoming public event. """ @spec get_upcoming_public_event_for_actor(Actor.t(), String.t() | nil) :: Event.t() | nil def get_upcoming_public_event_for_actor(%Actor{id: actor_id}, not_event_uuid \\ nil) do actor_id |> upcoming_public_event_for_actor_query() |> filter_public_visibility() |> filter_not_event_uuid(not_event_uuid) |> filter_draft() |> Repo.one() end @doc """ Creates an event. """ @spec create_event(map) :: {:ok, Event.t()} | {:error, Changeset.t()} | {:error, :update | :write, Changeset.t(), map()} def create_event(attrs \\ %{}) do with {:ok, %{insert: %Event{} = event}} <- do_create_event(attrs), %Event{} = event <- Repo.preload(event, @event_preloads) do unless event.draft do BuildSearch.enqueue(:insert_search_event, %{"event_id" => event.id}) end {:ok, event} else err -> err end end # We start by inserting the event and then insert a first participant if the event is not a draft @spec do_create_event(map) :: {:ok, %{insert: Event.t(), write: Participant.t() | nil}} | {:error, Changeset.t()} | {:error, :update | :write, Changeset.t(), map()} defp do_create_event(attrs) do Multi.new() |> Multi.insert(:insert, Event.changeset(%Event{}, attrs)) |> Multi.run(:write, fn _repo, %{insert: %Event{draft: draft} = event} -> with {:is_draft, false} <- {:is_draft, draft}, {:ok, %Participant{} = participant} <- create_participant( %{ event_id: event.id, role: :creator, actor_id: event.organizer_actor_id }, false ) do {:ok, participant} else {:is_draft, true} -> {:ok, nil} err -> err end end) |> Repo.transaction() end @doc """ Updates an event. We start by updating the event and then insert a first participant if the event is not a draft anymore """ @spec update_event(Event.t(), map) :: {:ok, Event.t()} | {:error, Changeset.t()} | {:error, :update | :write, Changeset.t(), map()} def update_event(%Event{draft: old_draft} = old_event, attrs) do with %Event{} = old_event <- Repo.preload(old_event, @event_preloads), %Changeset{changes: changes} = changeset <- Event.update_changeset(old_event, attrs), {:ok, %{update: %Event{} = new_event}} <- Multi.new() |> Multi.update(:update, changeset) |> Multi.run(:write, fn _repo, %{update: %Event{draft: draft} = event} -> with {:was_draft, true} <- {:was_draft, old_draft == true && draft == false}, {:ok, %Participant{} = participant} <- create_participant( %{ event_id: event.id, role: :creator, actor_id: event.organizer_actor_id }, false ) do {:ok, participant} else {:was_draft, false} -> {:ok, nil} err -> err end end) |> Repo.transaction(), %Event{} = new_event <- Repo.preload(new_event, @event_preloads, force: true) do Cachable.clear_all_caches(new_event) unless new_event.draft do %{ action: :notify_of_event_update, event_uuid: new_event.uuid, old_event: old_event |> Map.from_struct() |> Map.take(Event.__schema__(:fields)), changes: build_changes(changes) } |> EventDelayedNotificationWorker.new( scheduled_at: calculate_notification_time(new_event.begins_on), replace: [:scheduled_at, :args], unique: [period: 1, keys: [:event_uuid, :action]] ) |> Oban.insert() BuildSearch.enqueue(:update_search_event, %{"event_id" => new_event.id}) end {:ok, new_event} end end @spec build_changes(map()) :: map() defp build_changes(changes) do changes |> maybe_add_field(:physical_address) |> maybe_add_field(:options) |> maybe_add_field(:metadata) |> Map.drop(Event.__schema__(:associations) -- [:physical_address, :options, :metadata]) end @spec maybe_add_field(map(), atom()) :: map() defp maybe_add_field(changes, field) do case Map.get(changes, field) do %Ecto.Changeset{} = changeset -> Map.put( changes, field, changeset |> Ecto.Changeset.apply_changes() |> Map.from_struct() |> Map.take(Address.__schema__(:fields)) ) _ -> Map.drop(changes, [field]) end end @doc """ Deletes an event. """ @spec delete_event(Event.t()) :: {:ok, Event.t()} | {:error, Changeset.t()} def delete_event(%Event{} = event) do Cachable.clear_all_caches(event) Repo.delete(event) end @doc """ Returns the list of events. """ @spec list_events(integer | nil, integer | nil, atom, atom, boolean) :: Page.t(Event.t()) def list_events( page \\ nil, limit \\ nil, sort \\ :begins_on, direction \\ :asc, is_future \\ true ) do Event |> distinct([e], [{^direction, ^sort}, asc: e.id]) |> preload([:organizer_actor, :participants]) |> sort(sort, direction) |> filter_future_events(is_future) |> filter_public_visibility() |> filter_draft() |> filter_cancelled_events() |> filter_local_or_from_followed_instances_events() |> Page.build_page(page, limit) end @spec stream_events_for_sitemap :: Enum.t() def stream_events_for_sitemap do Event |> filter_public_visibility() |> filter_draft() |> filter_local() |> Repo.stream() end @spec list_public_local_events(integer | nil, integer | nil) :: Page.t(Event.t()) def list_public_local_events(page \\ nil, limit \\ nil) do Event |> filter_public_visibility() |> filter_draft() |> filter_local() |> preload_for_event() |> Page.build_page(page, limit) end @doc """ Returns the list of events with the same tags. """ @spec list_events_by_tags([Tag.t()], integer) :: [Event.t()] def list_events_by_tags(tags, limit \\ 2) do tags |> Enum.map(& &1.id) |> events_by_tags_query(limit) |> filter_draft() |> Repo.all() end @doc """ Lists public events for the actor, with all associations loaded. """ @spec list_public_events_for_actor(Actor.t(), integer | nil, integer | nil) :: Page.t(Event.t()) def list_public_events_for_actor(actor, page \\ nil, limit \\ nil) def list_public_events_for_actor(%Actor{type: :Group} = group, page, limit), do: list_organized_events_for_group(group, :public, nil, nil, nil, nil, page, limit) def list_public_events_for_actor(%Actor{id: actor_id}, page, limit) do actor_id |> do_list_public_events_for_actor() |> Page.build_page(page, limit) end @doc """ Lists public upcoming events for the actor, with all associations loaded. """ @spec list_public_upcoming_events_for_actor(Actor.t(), integer | nil, integer | nil) :: Page.t(Event.t()) def list_public_upcoming_events_for_actor(actor, page \\ nil, limit \\ nil) def list_public_upcoming_events_for_actor(%Actor{type: :Group} = group, page, limit), do: list_organized_events_for_group( group, :public, DateTime.utc_now(), nil, nil, nil, page, limit ) def list_public_upcoming_events_for_actor(%Actor{id: actor_id}, page, limit) do actor_id |> do_list_public_events_for_actor() |> event_filter_begins_on(DateTime.utc_now(), nil) |> Page.build_page(page, limit) end @spec do_list_public_events_for_actor(integer()) :: Ecto.Query.t() defp do_list_public_events_for_actor(actor_id) do actor_id |> event_for_actor_query() |> filter_public_visibility() |> filter_draft() |> preload_for_event() end @spec list_organized_events_for_actor(Actor.t(), integer | nil, integer | nil) :: Page.t(Event.t()) def list_organized_events_for_actor(%Actor{id: actor_id}, page \\ nil, limit \\ nil) do actor_id |> event_for_actor_query(desc: :begins_on) |> preload_for_event() |> Page.build_page(page, limit) end @spec list_simple_organized_events_for_group(Actor.t(), integer | nil, integer | nil) :: Page.t(Event.t()) def list_simple_organized_events_for_group(%Actor{} = actor, page \\ nil, limit \\ nil) do list_organized_events_for_group(actor, :all, nil, nil, nil, nil, page, limit) end @spec list_organized_events_for_group( Actor.t(), :public | :all, DateTime.t() | nil, DateTime.t() | nil, atom() | nil, atom() | nil, integer | nil, integer | nil ) :: Page.t(Event.t()) def list_organized_events_for_group( %Actor{id: group_id}, visibility \\ :public, after_datetime \\ nil, before_datetime \\ nil, order_by \\ nil, order_direction \\ nil, page \\ nil, limit \\ nil ) do group_id |> event_for_group_query() |> event_filter_visibility(visibility) |> event_filter_begins_on(after_datetime, before_datetime) |> event_order_by(order_by, order_direction) |> preload_for_event() |> Page.build_page(page, limit) end @spec list_drafts_for_user(integer, integer | nil, integer | nil) :: Page.t(Event.t()) def list_drafts_for_user(user_id, page \\ nil, limit \\ nil) do Event |> user_events_query(user_id) |> filter_draft(true) |> order_by(desc: :updated_at) |> Page.build_page(page, limit) end @spec is_user_moderator_for_event?(integer | String.t(), integer | String.t()) :: boolean def is_user_moderator_for_event?(user_id, event_id) do Participant |> join(:inner, [p], a in Actor, on: p.actor_id == a.id) |> where([p, _a], p.event_id == ^event_id) |> where([_p, a], a.user_id == ^user_id) |> where([p, _a], p.role == ^:creator) |> Repo.exists?() end @doc """ Finds close events to coordinates. Radius is in meters and defaults to 50km. """ @spec find_close_events(float(), float(), non_neg_integer()) :: [Event.t()] def find_close_events(lon, lat, radius \\ 50_000) do "SRID=#{4326};POINT(#{lon} #{lat})" |> Geo.WKT.decode!() |> close_events_query(radius) |> filter_draft() |> Repo.all() end @doc """ Counts local events. """ @spec count_local_events :: integer def count_local_events do count_local_events_query() |> filter_unlisted_and_public_visibility() |> filter_draft() |> Repo.one() end @doc """ Counts all events. """ @spec count_events :: integer def count_events do count_events_query() |> filter_unlisted_and_public_visibility() |> filter_draft() |> Repo.one() end @doc """ Builds a page struct for events by their name. """ @spec build_events_for_search(map(), integer | nil, integer | nil) :: Page.t(Event.t()) def build_events_for_search(%{term: term} = args, page \\ nil, limit \\ nil) do search_string = normalize_search_string(term) search_string |> events_for_search_query() |> events_for_begins_on(Map.get(args, :begins_on, DateTime.utc_now())) |> events_for_ends_on(Map.get(args, :ends_on)) |> events_for_category(args) |> events_for_categories(args) |> events_for_languages(args) |> events_for_statuses(args) |> events_for_tags(args) |> maybe_join_address(args) |> events_for_location(args) |> events_for_bounding_box(args) |> filter_online(args) |> filter_draft() |> filter_local_or_from_followed_instances_events() |> filter_public_visibility() |> event_order(Map.get(args, :sort_by, :match_desc), search_string) |> Page.build_page(page, limit, :begins_on) end @doc """ Gets a single tag. """ @spec get_tag(integer | String.t()) :: Tag.t() | nil def get_tag(id), do: Repo.get(Tag, id) @doc """ Gets a single tag. Raises `Ecto.NoResultsError` if the tag does not exist. """ @spec get_tag!(integer | String.t()) :: Tag.t() def get_tag!(id), do: Repo.get!(Tag, id) @doc """ Gets a tag by its slug. """ @spec get_tag_by_slug(String.t()) :: Tag.t() | nil def get_tag_by_slug(slug) do slug |> tag_by_slug_query() |> Repo.one() end @doc """ Gets a tag by its title. """ @spec get_tag_by_title(String.t()) :: Tag.t() | nil def get_tag_by_title(slug) do slug |> tag_by_title_query() |> Repo.one() end @doc """ Creates a tag. """ @spec create_tag(map) :: {:ok, Tag.t()} | {:error, Changeset.t()} def create_tag(attrs \\ %{}) do %Tag{} |> Tag.changeset(attrs) |> Repo.insert() end @doc """ Updates a tag. """ @spec update_tag(Tag.t(), map) :: {:ok, Tag.t()} | {:error, Changeset.t()} def update_tag(%Tag{} = tag, attrs) do tag |> Tag.changeset(attrs) |> Repo.update() end @doc """ Deletes a tag. """ @spec delete_tag(Tag.t()) :: {:ok, Tag.t()} | {:error, Changeset.t()} def delete_tag(%Tag{} = tag), do: Repo.delete(tag) @doc """ Returns the list of tags. """ @spec list_tags(String.t() | nil, integer | nil, integer | nil) :: Page.t(Tag.t()) def list_tags(filter \\ nil, page \\ nil, limit \\ nil) do Tag |> tag_filter(filter) |> Page.paginate(page, limit) |> Repo.all() end @doc """ Returns the list of tags for the event. """ @spec list_tags_for_event(integer | String.t(), integer | nil, integer | nil) :: [Tag.t()] def list_tags_for_event(event_id, page \\ nil, limit \\ nil) do event_id |> tags_for_event_query() |> Page.paginate(page, limit) |> Repo.all() end @doc """ Checks whether two tags are linked or not. """ @spec are_tags_linked?(Tag.t(), Tag.t()) :: boolean def are_tags_linked?(%Tag{id: tag1_id}, %Tag{id: tag2_id}) do tag_relation = tag1_id |> tags_linked_query(tag2_id) |> Repo.one() !!tag_relation end @doc """ Creates a relation between two tags. """ @spec create_tag_relation(map) :: {:ok, TagRelation.t()} | {:error, Changeset.t()} def create_tag_relation(attrs) do %TagRelation{} |> TagRelation.changeset(attrs) |> Repo.insert( conflict_target: [:tag_id, :link_id], on_conflict: [inc: [weight: 1]] ) end @doc """ Removes a tag relation. """ @spec delete_tag_relation(TagRelation.t()) :: {:ok, TagRelation.t()} | {:error, Changeset.t()} def delete_tag_relation(%TagRelation{} = tag_relation) do Repo.delete(tag_relation) end @doc """ Returns the tags neighbors for a given tag We can't rely on the single many_to_many relation since we also want tags that link to our tag, not just tags linked by this one. The SQL query looks like this: ```sql SELECT * FROM tags t RIGHT JOIN ( SELECT weight, link_id AS id FROM tag_relations t2 WHERE tag_id = 1 UNION ALL SELECT tag_id AS id, weight FROM tag_relations t2 WHERE link_id = 1 ) tr ON t.id = tr.id ORDER BY tr.weight DESC; ``` """ @spec list_tag_neighbors(Tag.t(), integer, integer) :: [Tag.t()] def list_tag_neighbors(%Tag{id: tag_id}, relation_minimum \\ 1, limit \\ 10) do tag_id |> tag_relation_subquery() |> tag_relation_union_subquery(tag_id) |> tag_neighbors_query(relation_minimum, limit) |> Repo.all() end @doc """ Gets a single participant. ## Examples iex> get_participant(123) %Participant{} iex> get_participant(456) nil """ @spec get_participant(integer) :: Participant.t() | nil @spec get_participant(integer | String.t(), integer | String.t(), map()) :: {:ok, Participant.t()} | {:error, :participant_not_found} def get_participant(participant_id) do Participant |> where([p], p.id == ^participant_id) |> preload([p], ^@participant_preloads) |> Repo.one() end @doc """ Gets a single participation for an event and actor. """ def get_participant(event_id, actor_id, params \\ %{}) # This one if to check someone doesn't go to the same event twice def get_participant(event_id, actor_id, %{email: email}) do case Participant |> where([p], event_id: ^event_id, actor_id: ^actor_id) |> where([p], fragment("? ->>'email' = ?", p.metadata, ^email)) |> preload([p], ^@participant_preloads) |> Repo.one() do %Participant{} = participant -> {:ok, participant} nil -> {:error, :participant_not_found} end end # This one if for finding participants by their cancellation token when wanting to cancel a participation def get_participant(event_id, actor_id, %{cancellation_token: cancellation_token}) do case Participant |> where([p], event_id: ^event_id, actor_id: ^actor_id) |> where([p], fragment("? ->>'cancellation_token' = ?", p.metadata, ^cancellation_token)) |> preload([p], ^@participant_preloads) |> Repo.one() do %Participant{} = participant -> {:ok, participant} nil -> {:error, :participant_not_found} end end def get_participant(event_id, actor_id, %{}) do case Participant |> Repo.get_by(event_id: event_id, actor_id: actor_id) |> Repo.preload(@participant_preloads) do %Participant{} = participant -> {:ok, participant} nil -> {:error, :participant_not_found} end end @spec get_participant_by_confirmation_token(String.t()) :: Participant.t() | nil def get_participant_by_confirmation_token(confirmation_token) do Participant |> where([p], fragment("? ->>'confirmation_token' = ?", p.metadata, ^confirmation_token)) |> preload([p], ^@participant_preloads) |> Repo.one() end @spec get_participant!(integer | String.t()) :: Participant.t() def get_participant!(participant_id) do Repo.get_by!(Participant, id: participant_id) end @doc """ Gets a single participation for an event and actor. Raises `Ecto.NoResultsError` if the Participant does not exist. ## Examples iex> get_participant!(123, 19) %Participant{} iex> get_participant!(456, 5) ** (Ecto.NoResultsError) """ @spec get_participant!(integer | String.t(), integer | String.t()) :: Participant.t() def get_participant!(event_id, actor_id) do Repo.get_by!(Participant, event_id: event_id, actor_id: actor_id) end @doc """ Gets a participant by its URL. """ @spec get_participant_by_url(String.t()) :: Participant.t() | nil def get_participant_by_url(url) do url |> participant_by_url_query() |> Repo.one() end @doc """ Returns the number of participations for all local events """ @spec count_confirmed_participants_for_local_events :: integer() def count_confirmed_participants_for_local_events do count_confirmed_participants_for_local_events_query() |> Repo.one() end @doc """ Returns the list of participants for an event. Default behaviour is to not return :not_approved or :not_confirmed participants """ @spec list_participants_for_event(String.t(), list(atom()), integer | nil, integer | nil) :: Page.t(Participant.t()) def list_participants_for_event( id, roles \\ [], page \\ nil, limit \\ nil ) do id |> participants_for_event_query(roles) |> preload([:actor, :event]) |> Page.build_page(page, limit) end @spec list_actors_participants_for_event(String.t()) :: [Actor.t()] def list_actors_participants_for_event(id) do id |> list_participant_actors_for_event_query |> Repo.all() end @doc """ Returns the list of participations for an actor. Default behaviour is to not return :not_approved participants ## Examples iex> list_event_participations_for_user(5) [%Participant{}, ...] """ @spec list_participations_for_user( integer, DateTime.t() | nil, DateTime.t() | nil, integer | nil, integer | nil ) :: Page.t(Participant.t()) def list_participations_for_user(user_id, after_datetime, before_datetime, page, limit) do user_id |> list_participations_for_user_query() |> participation_filter_begins_on(after_datetime, before_datetime) |> Page.build_page(page, limit) end @doc """ Returns the list of organizers participants for an event. ## Examples iex> list_organizers_participants_for_event(id) [%Participant{role: :creator}, ...] """ @spec list_organizers_participants_for_event( integer | String.t(), integer | nil, integer | nil ) :: [Participant.t()] def list_organizers_participants_for_event(event_id, page \\ nil, limit \\ nil) do event_id |> organizers_participants_for_event() |> Page.paginate(page, limit) |> Repo.all() end @doc """ Returns the list of event participation requests for an actor. """ @spec list_requests_for_actor(Actor.t()) :: [Participant.t()] def list_requests_for_actor(%Actor{id: actor_id}) do actor_id |> requests_for_actor_query() |> Repo.all() end @doc """ Returns the list of participations for an actor. """ @spec list_event_participations_for_actor(Actor.t(), integer | nil, integer | nil) :: Page.t(Participant.t()) def list_event_participations_for_actor(%Actor{id: actor_id}, page \\ nil, limit \\ nil) do actor_id |> event_participations_for_actor_query() |> Page.build_page(page, limit) end @doc """ Returns the list of upcoming participations for an actor. """ @spec list_upcoming_event_participations_for_actor(Actor.t(), integer | nil, integer | nil) :: Page.t(Participant.t()) def list_upcoming_event_participations_for_actor( %Actor{id: actor_id}, page \\ nil, limit \\ nil ) do actor_id |> event_participations_for_actor_query(DateTime.utc_now()) |> Page.build_page(page, limit) end @doc """ Counts participant participants (participants with no extra role) """ @spec count_participant_participants(integer | String.t()) :: integer def count_participant_participants(event_id) do event_id |> count_participants_query() |> filter_participant_role() |> Repo.aggregate(:count, :id) end @doc """ Gets the default participant role depending on the event join options. """ @spec get_default_participant_role(Event.t()) :: :participant | :not_approved def get_default_participant_role(%Event{join_options: :free}), do: :participant def get_default_participant_role(%Event{join_options: _}), do: :not_approved @doc """ Creates a participant. """ @spec create_participant(map) :: {:ok, Participant.t()} | {:error, :participant | :update_event_participation_stats, Changeset.t(), map()} def create_participant(attrs \\ %{}, update_event_participation_stats \\ true) do with {:ok, %{participant: %Participant{} = participant}} <- Multi.new() |> Multi.insert(:participant, Participant.changeset(%Participant{}, attrs)) |> Multi.run(:update_event_participation_stats, fn _repo, %{ participant: %Participant{role: new_role} = participant } -> update_participant_stats( participant, nil, new_role, update_event_participation_stats ) end) |> Repo.transaction() do {:ok, Repo.preload(participant, [:event, :actor])} end end @doc """ Updates a participant. """ @spec update_participant(Participant.t(), map) :: {:ok, Participant.t()} | {:error, :participant | :update_event_participation_stats, Changeset.t(), map()} def update_participant(%Participant{role: old_role} = participant, attrs) do with {:ok, %{participant: %Participant{} = participant}} <- Multi.new() |> Multi.update(:participant, Participant.changeset(participant, attrs)) |> Multi.run(:update_event_participation_stats, fn _repo, %{ participant: %Participant{role: new_role} = participant } -> update_participant_stats(participant, old_role, new_role) end) |> Repo.transaction() do {:ok, Repo.preload(participant, [:event, :actor])} end end @doc """ Deletes a participant. """ @spec delete_participant(Participant.t()) :: {:ok, %{participant: Participant.t()}} | {:error, :participant | :update_event_participation_stats, Changeset.t(), map()} def delete_participant(%Participant{role: old_role} = participant) do Multi.new() |> Multi.delete(:participant, participant) |> Multi.run(:update_event_participation_stats, fn _repo, %{ participant: %Participant{} = participant } -> update_participant_stats(participant, old_role, nil) end) |> Repo.transaction() end defp update_participant_stats( %Participant{ event_id: event_id } = _participant, old_role, new_role, update_event_participation_stats \\ true ) do with {:update_event_participation_stats, true} <- {:update_event_participation_stats, update_event_participation_stats}, {:ok, %Event{} = event} <- get_event_with_preload(event_id), %EventParticipantStats{} = participant_stats <- Map.get(event, :participant_stats), %EventParticipantStats{} = participant_stats <- do_update_participant_stats(participant_stats, old_role, new_role), {:ok, %Event{} = event} <- event |> Event.update_changeset(%{ participant_stats: Map.from_struct(participant_stats) }) |> Repo.update() do {:ok, event} else {:update_event_participation_stats, false} -> {:ok, nil} {:error, :event_not_found} -> {:error, :event_not_found} err -> {:error, err} end end defp do_update_participant_stats(participant_stats, old_role, new_role) do participant_stats |> decrease_participant_stats(old_role) |> increase_participant_stats(new_role) end defp increase_participant_stats(participant_stats, nil), do: participant_stats defp increase_participant_stats(participant_stats, role), do: Map.update(participant_stats, role, 0, &(&1 + 1)) defp decrease_participant_stats(participant_stats, nil), do: participant_stats defp decrease_participant_stats(participant_stats, role), do: Map.update(participant_stats, role, 0, &(&1 - 1)) @doc """ Gets a single session. Raises `Ecto.NoResultsError` if the session does not exist. """ @spec get_session!(integer | String.t()) :: Session.t() def get_session!(id), do: Repo.get!(Session, id) @doc """ Creates a session. """ @spec create_session(map) :: {:ok, Session.t()} | {:error, Changeset.t()} def create_session(attrs \\ %{}) do %Session{} |> Session.changeset(attrs) |> Repo.insert() end @doc """ Updates a session. """ @spec update_session(Session.t(), map) :: {:ok, Session.t()} | {:error, Changeset.t()} def update_session(%Session{} = session, attrs) do session |> Session.changeset(attrs) |> Repo.update() end @doc """ Deletes a session. """ @spec delete_session(Session.t()) :: {:ok, Session.t()} | {:error, Changeset.t()} def delete_session(%Session{} = session), do: Repo.delete(session) @doc """ Returns the list of sessions. """ @spec list_sessions :: [Session.t()] def list_sessions, do: Repo.all(Session) @doc """ Returns the list of sessions for the event. """ @spec list_sessions_for_event(Event.t()) :: [Session.t()] def list_sessions_for_event(%Event{id: event_id}) do event_id |> sessions_for_event_query() |> Repo.all() end @doc """ Gets a single track. Raises `Ecto.NoResultsError` if the track does not exist. """ @spec get_track!(integer | String.t()) :: Track.t() def get_track!(id), do: Repo.get!(Track, id) @doc """ Creates a track. """ @spec create_track(map) :: {:ok, Track.t()} | {:error, Changeset.t()} def create_track(attrs \\ %{}) do %Track{} |> Track.changeset(attrs) |> Repo.insert() end @doc """ Updates a track. """ @spec update_track(Track.t(), map) :: {:ok, Track.t()} | {:error, Changeset.t()} def update_track(%Track{} = track, attrs) do track |> Track.changeset(attrs) |> Repo.update() end @doc """ Deletes a track. """ @spec delete_track(Track.t()) :: {:ok, Track.t()} | {:error, Changeset.t()} def delete_track(%Track{} = track), do: Repo.delete(track) @doc """ Returns the list of tracks. """ @spec list_tracks :: [Track.t()] def list_tracks, do: Repo.all(Track) @doc """ Returns the list of sessions for the track. """ @spec list_sessions_for_track(Track.t()) :: [Session.t()] def list_sessions_for_track(%Track{id: track_id}) do track_id |> sessions_for_track_query() |> Repo.all() end @doc """ Gets a single feed token. """ @spec get_feed_token(String.t()) :: FeedToken.t() | nil def get_feed_token(token) do token |> feed_token_query() |> Repo.one() end @doc """ Creates a feed token. """ @spec create_feed_token(map) :: {:ok, FeedToken.t()} | {:error, Changeset.t()} def create_feed_token(attrs \\ %{}) do attrs = Map.put(attrs, :token, Ecto.UUID.generate()) %FeedToken{} |> FeedToken.changeset(attrs) |> Repo.insert() end @doc """ Deletes a feed token. """ @spec delete_feed_token(FeedToken.t()) :: {:ok, FeedToken.t()} | {:error, Changeset.t()} def delete_feed_token(%FeedToken{} = feed_token), do: Repo.delete(feed_token) @doc """ Returns the list of feed tokens for an user. """ @spec list_feed_tokens_for_user(User.t()) :: [FeedTokens.t()] def list_feed_tokens_for_user(%User{id: user_id}) do user_id |> feed_token_for_user_query() |> Repo.all() end @doc """ Returns the list of feed tokens for an actor. """ @spec list_feed_tokens_for_actor(Actor.t()) :: [FeedTokens.t()] def list_feed_tokens_for_actor(%Actor{id: actor_id, domain: nil}) do actor_id |> feed_token_for_actor_query() |> Repo.all() end @spec event_by_url_query(String.t()) :: Ecto.Query.t() defp event_by_url_query(url) do from(e in Event, where: e.url == ^url) end @spec event_by_uuid_query(String.t()) :: Ecto.Query.t() defp event_by_uuid_query(uuid) do from(e in Event, where: e.uuid == ^uuid) end @spec event_for_actor_query(integer | String.t()) :: Ecto.Query.t() defp event_for_actor_query(actor_id, order_by \\ [desc: :id]) do Event |> where([e], e.organizer_actor_id == ^actor_id) |> order_by([e], ^order_by) end @spec event_for_group_query(integer | String.t()) :: Ecto.Query.t() defp event_for_group_query(group_id) do where(Event, [e], e.attributed_to_id == ^group_id) end @spec upcoming_public_event_for_actor_query(integer | String.t()) :: Ecto.Query.t() defp upcoming_public_event_for_actor_query(actor_id) do from( e in Event, where: e.organizer_actor_id == ^actor_id and e.begins_on > ^DateTime.utc_now(), order_by: [asc: :begins_on], limit: 1, preload: [ :organizer_actor, :tags, :participants, :physical_address ] ) end @spec close_events_query(Geo.geometry(), number) :: Ecto.Query.t() defp close_events_query(point, radius) do from( e in Event, join: a in Address, on: a.id == e.physical_address_id, where: e.visibility == ^:public and st_dwithin_in_meters(^point, a.geom, ^radius), preload: :organizer_actor ) end @spec user_events_query(Ecto.Queryable.t(), number()) :: Ecto.Query.t() defp user_events_query(query, user_id) do from( e in query, join: a in Actor, on: a.id == e.organizer_actor_id, where: a.user_id == ^user_id ) end defmacro matching_event_ids_and_ranks(search_string) do quote do fragment( """ SELECT event_search.id AS id, ts_rank( event_search.document, plainto_tsquery(unaccent(?)) ) AS rank FROM event_search WHERE event_search.document @@ plainto_tsquery(unaccent(?)) OR event_search.title ILIKE ? """, ^unquote(search_string), ^unquote(search_string), ^"%#{unquote(search_string)}%" ) end end defp events_for_search_query(""), do: Event defp events_for_search_query(search_string) do join(Event, :inner, [e], id_and_rank in matching_event_ids_and_ranks(search_string), on: id_and_rank.id == e.id ) end @spec events_for_begins_on(Ecto.Queryable.t(), DateTime.t() | nil) :: Ecto.Query.t() defp events_for_begins_on(query, begins_on) do if is_nil(begins_on) do query else where( query, [q], (not is_nil(q.ends_on) and q.ends_on > ^begins_on) or (is_nil(q.ends_on) and q.begins_on >= ^begins_on) ) end end @spec events_for_ends_on(Ecto.Queryable.t(), DateTime.t() | nil) :: Ecto.Query.t() defp events_for_ends_on(query, ends_on) do if is_nil(ends_on) do query else where( query, [q], (is_nil(q.ends_on) and q.begins_on <= ^ends_on) or q.ends_on <= ^ends_on ) end end @spec events_for_category(Ecto.Queryable.t(), map()) :: Ecto.Query.t() defp events_for_category(query, %{category: category}) when is_valid_string(category) do where(query, [q], q.category == ^category) end defp events_for_category(query, _args), do: query @spec events_for_categories(Ecto.Queryable.t(), map()) :: Ecto.Query.t() defp events_for_categories(query, %{category_one_of: category_one_of}) when length(category_one_of) > 0 do where(query, [q], q.category in ^category_one_of) end defp events_for_categories(query, _args), do: query defp events_for_languages(query, %{language_one_of: language_one_of}) when length(language_one_of) > 0 do where(query, [q], q.language in ^language_one_of) end defp events_for_languages(query, _args), do: query defp events_for_statuses(query, %{status_one_of: status_one_of}) when length(status_one_of) > 0 do where(query, [q], q.status in ^status_one_of) end defp events_for_statuses(query, _args), do: query @spec events_for_tags(Ecto.Queryable.t(), map()) :: Ecto.Query.t() defp events_for_tags(query, %{tags: tags}) when is_valid_string(tags) do query |> join(:inner, [q], te in "events_tags", on: q.id == te.event_id) |> join(:inner, [q, ..., te], t in Tag, on: te.tag_id == t.id) |> where([q, ..., t], t.title in ^String.split(tags, ",", trim: true)) end defp events_for_tags(query, _args), do: query # We add the inner join on address only if we're going to use it in # events_for_location or events_for_bounding_box # So we're sure it's only being added once defp maybe_join_address(query, %{location: location, radius: radius}) when is_valid_string(location) and not is_nil(radius) do join(query, :inner, [q], a in Address, on: a.id == q.physical_address_id, as: :address) end defp maybe_join_address(query, %{bbox: bbox}) when is_valid_string(bbox) do join(query, :inner, [q], a in Address, on: a.id == q.physical_address_id, as: :address) end defp maybe_join_address(query, _), do: query @spec events_for_location(Ecto.Queryable.t(), map()) :: Ecto.Query.t() defp events_for_location(query, %{radius: radius}) when is_nil(radius), do: query defp events_for_location(query, %{location: location, radius: radius}) when is_valid_string(location) and not is_nil(radius) do with {lon, lat} <- Geohax.decode(location), point <- Geo.WKT.decode!("SRID=4326;POINT(#{lon} #{lat})"), {{x_min, y_min}, {x_max, y_max}} <- search_box({lon, lat}, radius) do where( query, [q, ..., a], st_x(a.geom) > ^x_min and st_x(a.geom) < ^x_max and st_y(a.geom) > ^y_min and st_y(a.geom) < ^y_max and st_dwithin_in_meters(^point, a.geom, ^(radius * 1000)) ) else _ -> query end end defp events_for_location(query, _args), do: query defp events_for_bounding_box(query, %{bbox: bbox}) when is_valid_string(bbox) do [top_left, bottom_right] = String.split(bbox, ":") [ymax, xmin] = String.split(top_left, ",") [ymin, xmax] = String.split(bottom_right, ",") where( query, [q, ..., a], fragment( "? @ ST_MakeEnvelope(?,?,?,?,?)", a.geom, ^sanitize_bounding_box_params(xmin), ^sanitize_bounding_box_params(ymin), ^sanitize_bounding_box_params(xmax), ^sanitize_bounding_box_params(ymax), "4326" ) ) end defp events_for_bounding_box(query, _args), do: query @spec sanitize_bounding_box_params(String.t()) :: float() defp sanitize_bounding_box_params(param) do param |> String.trim() |> String.to_float() |> Float.floor(10) end @spec search_box({float(), float()}, float()) :: {{float, float}, {float, float}} defp search_box({lon0, lat0}, radius) do km_per_lat_deg = 111.195 lat_amp = radius / km_per_lat_deg km_per_lon_deg_at_lat = Haversine.distance({0.0, lat0}, {1.0, lat0}) / 1000 lon_amp = radius / km_per_lon_deg_at_lat {{lon0 - lon_amp, lat0 - lat_amp}, {lon0 + lon_amp, lat0 + lat_amp}} end @spec filter_online(Ecto.Query.t(), map()) :: Ecto.Query.t() defp filter_online(query, %{type: :online}), do: is_online_fragment(query, true) defp filter_online(query, %{type: :in_person}), do: is_online_fragment(query, false) defp filter_online(query, _), do: query @spec is_online_fragment(Ecto.Query.t(), boolean()) :: Ecto.Query.t() defp is_online_fragment(query, value) do where(query, [q], fragment("(?->>'is_online')::bool = ?", q.options, ^value)) end @spec normalize_search_string(String.t()) :: String.t() defp normalize_search_string(search_string) do search_string |> String.downcase() |> String.replace(~r/\n/, " ") |> String.replace(~r/\t/, " ") |> String.replace(~r/\s{2,}/, " ") |> String.trim() end @spec events_by_tags_query([integer], integer) :: Ecto.Query.t() def events_by_tags_query(tags_ids, limit) do from( e in Event, distinct: e.uuid, join: te in "events_tags", on: e.id == te.event_id, where: e.begins_on > ^DateTime.utc_now(), where: e.visibility == ^:public, where: te.tag_id in ^tags_ids, order_by: [asc: e.begins_on], limit: ^limit ) end @spec count_local_events_query :: Ecto.Query.t() defp count_local_events_query do from(e in Event, select: count(e.id), where: e.local == ^true) end @spec count_events_query :: Ecto.Query.t() defp count_events_query do from(e in Event, select: count(e.id)) end @spec tag_by_slug_query(String.t()) :: Ecto.Query.t() defp tag_by_slug_query(slug) do from(t in Tag, where: t.slug == ^slug) end @spec tag_by_title_query(String.t()) :: Ecto.Query.t() defp tag_by_title_query(title) do from(t in Tag, where: t.title == ^title, limit: 1) end @spec tag_filter(Ecto.Queryable.t(), String.t() | nil) :: Ecto.Query.t() defp tag_filter(query, nil), do: query defp tag_filter(query, ""), do: query defp tag_filter(query, filter) when is_binary(filter) do query |> where([q], ilike(q.slug, ^"%#{filter}%")) |> or_where([q], ilike(q.title, ^"%#{filter}%")) end @spec tags_for_event_query(integer) :: Ecto.Query.t() defp tags_for_event_query(event_id) do from( t in Tag, join: e in "events_tags", on: t.id == e.tag_id, where: e.event_id == ^event_id ) end @spec tags_linked_query(integer, integer) :: Ecto.Query.t() defp tags_linked_query(tag1_id, tag2_id) do from( tr in TagRelation, where: tr.tag_id == ^min(tag1_id, tag2_id) and tr.link_id == ^max(tag1_id, tag2_id) ) end @spec tag_relation_subquery(integer) :: Ecto.Query.t() defp tag_relation_subquery(tag_id) do from( tr in TagRelation, select: %{id: tr.tag_id, weight: tr.weight}, where: tr.link_id == ^tag_id ) end @spec tag_relation_union_subquery(Ecto.Queryable.t(), integer) :: Ecto.Query.t() defp tag_relation_union_subquery(subquery, tag_id) do from( tr in TagRelation, select: %{id: tr.link_id, weight: tr.weight}, union_all: ^subquery, where: tr.tag_id == ^tag_id ) end @spec tag_neighbors_query(Ecto.Queryable.t(), integer, integer) :: Ecto.Query.t() defp tag_neighbors_query(subquery, relation_minimum, limit) do from( t in Tag, right_join: q in subquery(subquery), on: [id: t.id], where: q.weight >= ^relation_minimum, limit: ^limit, order_by: [desc: q.weight] ) end @spec participant_by_url_query(String.t()) :: Ecto.Query.t() defp participant_by_url_query(url) do from( p in Participant, where: p.url == ^url, preload: [:actor, :event] ) end defp organizers_participants_for_event(event_id) do from( p in Participant, where: p.event_id == ^event_id and p.role == ^:creator, preload: [:actor] ) end @spec requests_for_actor_query(integer) :: Ecto.Query.t() defp requests_for_actor_query(actor_id) do from(p in Participant, where: p.actor_id == ^actor_id and p.role == ^:not_approved) end @spec count_participants_query(integer) :: Ecto.Query.t() def count_participants_query(event_id) do from(p in Participant, where: p.event_id == ^event_id) end @spec event_participations_for_actor_query(integer, DateTime.t() | nil) :: Ecto.Query.t() defp event_participations_for_actor_query(actor_id, after_date \\ nil) defp event_participations_for_actor_query(actor_id, nil) do do_event_participations_for_actor_query(actor_id) end defp event_participations_for_actor_query(actor_id, %DateTime{} = after_date) do actor_id |> do_event_participations_for_actor_query() |> where([_p, e], e.begins_on > ^after_date) end defp do_event_participations_for_actor_query(actor_id) do Participant |> join(:inner, [p], e in Event, on: p.event_id == e.id) |> where([p], p.actor_id == ^actor_id and p.role != ^:not_approved) |> order_by([_p, e], desc: e.begins_on) end @spec sessions_for_event_query(integer) :: Ecto.Query.t() defp sessions_for_event_query(event_id) do from( s in Session, join: e in Event, on: s.event_id == e.id, where: e.id == ^event_id ) end @spec sessions_for_track_query(integer) :: Ecto.Query.t() defp sessions_for_track_query(track_id) do from(s in Session, where: s.track_id == ^track_id) end @spec count_confirmed_participants_for_local_events_query :: Ecto.Query.t() defp count_confirmed_participants_for_local_events_query do Participant |> join(:inner, [p], e in Event, on: p.event_id == e.id) |> where([p, e], e.local and p.role not in [^:not_approved, ^:not_confirmed, ^:rejected]) |> select([p], count(p.id)) end @spec list_participants_for_event_query(String.t()) :: Ecto.Query.t() defp list_participants_for_event_query(event_id) do Participant |> where([p], p.event_id == ^event_id) end @spec list_participant_actors_for_event_query(String.t()) :: Ecto.Query.t() defp list_participant_actors_for_event_query(event_id) do from( a in Actor, join: p in Participant, on: p.actor_id == a.id, where: p.event_id == ^event_id ) end @spec participants_for_event_query(String.t(), list(atom())) :: Ecto.Query.t() def participants_for_event_query(id, roles \\ []) do id |> list_participants_for_event_query() |> filter_role(roles) |> order_by(asc: :role) end def participant_for_event_export_query(id, roles) do id |> participants_for_event_query(roles) |> join(:inner, [p], a in Actor, on: p.actor_id == a.id) |> select([p, a], {p, a}) end @doc """ List emails for local users (including anonymous ones) participating to an event Returns {participation, actor, user, user_settings} """ @spec list_local_emails_user_participants_for_event_query(String.t()) :: Ecto.Query.t() def list_local_emails_user_participants_for_event_query(event_id) do Participant |> join(:inner, [p], a in Actor, on: p.actor_id == a.id and is_nil(a.domain)) |> join(:left, [_p, a], u in User, on: a.user_id == u.id) |> join(:left, [_p, _a, u], s in Setting, on: s.user_id == u.id) |> where( [p], p.event_id == ^event_id and p.role not in [^:not_approved, ^:not_confirmed, ^:rejected] ) |> select([p, a, u, s], {p, a, u, s}) end @doc """ List anonymous participations to an event """ @spec list_anonymous_participants_for_event(String.t()) :: [Participant.t()] def list_anonymous_participants_for_event(event_id) do Participant |> where( [p], p.event_id == ^event_id and p.role not in [^:not_approved, ^:not_confirmed, ^:rejected] ) |> Repo.all() end @spec category_statistics :: [{String.t(), non_neg_integer()}] def category_statistics do Event |> filter_future_events(true) |> filter_public_visibility() |> filter_draft() |> filter_cancelled_events() |> filter_local_or_from_followed_instances_events() |> group_by([e], e.category) |> select([e], {e.category, count(e.id)}) |> Repo.all() end @threshold_related_value 7 @spec related_events(Event.t()) :: list(Event.t()) def related_events(%Event{ id: event_id, tags: tags, physical_address: physical_address, organizer_actor: %Actor{id: organizer_actor_id}, attributed_to: attributed_to, category: category, language: language }) do event_tags_ids = Enum.map(tags, & &1.id) geom = if is_nil(physical_address), do: nil, else: physical_address.geom group_id = if is_nil(attributed_to), do: nil, else: attributed_to.id Event |> distinct([e], e.id) |> join(:left, [e], et in "events_tags", on: e.id == et.event_id) |> join(:left, [e], a in Address, on: e.physical_address_id == a.id) |> filter_draft() |> filter_local_or_from_followed_instances_events() |> filter_public_visibility() |> where( [e, et, a], fragment( "(? = ?)::int * 5 + (? = ALL(?))::int * 2 + (? = ?)::int + (? = ?)::int * 2 + (?::int is null or ? = ?)::int * 2 + (?::geography is null or ST_DWithin(?::geography, ?::geography, ?::float))::int * 2 > ?", e.language, ^language, et.tag_id, ^event_tags_ids, e.category, ^category, e.organizer_actor_id, ^organizer_actor_id, ^group_id, e.attributed_to_id, ^group_id, ^geom, ^geom, a.geom, 5000, @threshold_related_value ) ) |> where([e], e.id != ^event_id) |> order_by( [e, et, a], fragment( "(? = ?)::int * 5 + (? = ALL(?))::int * 2 + (? = ?)::int + (? = ?)::int * 2 + (?::int is null or ? = ?)::int * 2 + (?::geography is null or ST_DWithin(?::geography, ?::geography, ?::float))::int * 2 DESC", e.language, ^language, et.tag_id, ^event_tags_ids, e.category, ^category, e.organizer_actor_id, ^organizer_actor_id, ^group_id, e.attributed_to_id, ^group_id, ^geom, ^geom, a.geom, 5000 ) ) |> Repo.all() end @spec list_participations_for_user_query(integer()) :: Ecto.Query.t() defp list_participations_for_user_query(user_id) do Participant |> join(:inner, [p], e in Event, on: p.event_id == e.id) |> join(:inner, [p], a in Actor, on: p.actor_id == a.id) |> where([p, _e, a], a.user_id == ^user_id and p.role != ^:not_approved) |> preload([:event, :actor]) end @spec feed_token_query(String.t()) :: Ecto.Query.t() defp feed_token_query(token) do from(ftk in FeedToken, where: ftk.token == ^token, preload: [:actor, :user]) end @spec feed_token_for_user_query(integer) :: Ecto.Query.t() defp feed_token_for_user_query(user_id) do from(tk in FeedToken, where: tk.user_id == ^user_id, preload: [:actor, :user]) end @spec feed_token_for_actor_query(integer) :: Ecto.Query.t() defp feed_token_for_actor_query(actor_id) do from(tk in FeedToken, where: tk.actor_id == ^actor_id, preload: [:actor, :user]) end @spec filter_public_visibility(Ecto.Queryable.t()) :: Ecto.Query.t() defp filter_public_visibility(query) do from(e in query, where: e.visibility == ^:public) end @spec filter_unlisted_and_public_visibility(Ecto.Queryable.t()) :: Ecto.Query.t() defp filter_unlisted_and_public_visibility(query) do from(q in query, where: q.visibility in ^@public_visibility) end @spec filter_not_event_uuid(Ecto.Queryable.t(), String.t() | nil) :: Ecto.Query.t() defp filter_not_event_uuid(query, nil), do: query defp filter_not_event_uuid(query, not_event_uuid) do from(e in query, where: e.uuid != ^not_event_uuid) end @spec filter_draft(Ecto.Queryable.t(), boolean) :: Ecto.Query.t() defp filter_draft(query, is_draft \\ false) do from(e in query, where: e.draft == ^is_draft) end @spec filter_cancelled_events(Ecto.Queryable.t()) :: Ecto.Query.t() defp filter_cancelled_events(query) do from(e in query, where: e.status != ^:cancelled) end @spec filter_future_events(Ecto.Queryable.t(), boolean) :: Ecto.Query.t() defp filter_future_events(query, true) do from(q in query, where: coalesce(q.ends_on, q.begins_on) > ^DateTime.utc_now() ) end defp filter_future_events(query, false), do: query @spec filter_local(Ecto.Queryable.t()) :: Ecto.Query.t() defp filter_local(query) do filter_local(query, true) end @spec filter_local(Ecto.Queryable.t(), boolean() | nil) :: Ecto.Query.t() defp filter_local(query, nil), do: query defp filter_local(query, value) when is_boolean(value) do where(query, [q], q.local == ^value) end @spec filter_local_or_from_followed_instances_events(Ecto.Queryable.t()) :: Ecto.Query.t() defp filter_local_or_from_followed_instances_events(query) do %Actor{id: follower_actor_id} = Relay.get_actor() query |> join(:left, [q], s in Share, on: s.uri == q.url) |> join(:left, [_q, ..., s], f in Follower, on: f.target_actor_id == s.actor_id) |> where( [q, ..., s, f], q.local == true or (f.actor_id == ^follower_actor_id and not is_nil(s.uri)) ) end @spec filter_participant_role(Ecto.Queryable.t()) :: Ecto.Query.t() defp filter_participant_role(query) do filter_role(query, :participant) end @spec filter_role(Ecto.Queryable.t(), list(atom()) | atom()) :: Ecto.Query.t() def filter_role(query, []), do: query def filter_role(query, roles) when is_list(roles) do where(query, [p], p.role in ^roles) end def filter_role(query, role) when is_atom(role) do from(p in query, where: p.role == ^role) end @spec event_filter_visibility(Ecto.Queryable.t(), :public | :all) :: Ecto.Queryable.t() | Ecto.Query.t() defp event_filter_visibility(query, :all), do: query defp event_filter_visibility(query, :public) do where(query, visibility: ^:public, draft: false) end defp event_filter_begins_on(query, nil, nil), do: query defp event_filter_begins_on(query, %DateTime{} = after_datetime, nil) do where(query, [e], e.begins_on > ^after_datetime) end defp event_filter_begins_on(query, nil, %DateTime{} = before_datetime) do where(query, [e], e.begins_on < ^before_datetime) end defp event_filter_begins_on( query, %DateTime{} = after_datetime, %DateTime{} = before_datetime ) do query |> where([e], e.begins_on < ^before_datetime) |> where([e], e.begins_on > ^after_datetime) end defp event_order_by(query, order_by, direction) when order_by in [:begins_on, :inserted_at, :updated_at] and direction in [:asc, :desc] do order_by_instruction = Keyword.new([{direction, order_by}]) order_by(query, [e], ^order_by_instruction) end defp event_order_by(query, _order_by, _direction), do: event_order_by(query, :begins_on, :asc) defp event_order(query, :match_desc, "") do query |> distinct([e], desc: e.begins_on, asc: e.id) |> order_by([e], desc: e.begins_on) end defp event_order(query, :match_desc, _) do query |> distinct([e, f], desc: f.rank, asc: e.begins_on, asc: e.id) |> order_by([e, f], desc: f.rank, asc: e.begins_on) end defp event_order(query, :start_time_desc, _) do query |> distinct([e], desc: e.begins_on, asc: e.id) |> order_by([e], desc: e.begins_on) end defp event_order(query, :start_time_asc, _) do query |> distinct([e], asc: e.begins_on, asc: e.id) |> order_by([e], asc: e.begins_on) end defp event_order(query, :created_at_desc, _) do query |> distinct([e], desc: e.publish_at, asc: e.id) |> order_by([e], desc: e.publish_at) end defp event_order(query, :created_at_asc, _) do query |> distinct([e], asc: e.publish_at, asc: e.id) |> order_by([e], asc: e.publish_at) end defp event_order(query, :participant_count_desc, _) do query |> distinct(:id) |> order_by([e], fragment("participant_stats->>'participant' DESC")) end defp event_order(query, _, _), do: query defp participation_filter_begins_on(query, nil, nil), do: participation_order_begins_on_desc(query) defp participation_filter_begins_on(query, %DateTime{} = after_datetime, nil) do query |> where([_p, e, _a], e.begins_on > ^after_datetime) |> participation_order_begins_on_asc() end defp participation_filter_begins_on(query, nil, %DateTime{} = before_datetime) do query |> where([_p, e, _a], e.begins_on < ^before_datetime) |> participation_order_begins_on_desc() end defp participation_filter_begins_on( query, %DateTime{} = after_datetime, %DateTime{} = before_datetime ) do query |> where([_p, e, _a], e.begins_on < ^before_datetime) |> where([_p, e, _a], e.begins_on > ^after_datetime) |> participation_order_begins_on_asc() end defp participation_order_begins_on_asc(query), do: order_by(query, [_p, e, _a], asc: e.begins_on) defp participation_order_begins_on_desc(query), do: order_by(query, [_p, e, _a], desc: e.begins_on) @spec preload_for_event(Ecto.Queryable.t()) :: Ecto.Query.t() defp preload_for_event(query), do: preload(query, ^@event_preloads) @spec stream_events(boolean() | nil, integer()) :: Enum.t() def stream_events(local \\ true, chunk_size \\ 500) do Event |> filter_draft() |> filter_local(local) |> preload_for_event() |> Page.chunk(chunk_size) end end