180 lines
4.4 KiB
Elixir
180 lines
4.4 KiB
Elixir
defmodule Mobilizon.Activities do
|
|
@moduledoc """
|
|
The Activities context.
|
|
"""
|
|
|
|
import Ecto.Query, warn: false
|
|
import EctoEnum
|
|
alias Mobilizon.Activities.Activity
|
|
alias Mobilizon.Actors.Member
|
|
alias Mobilizon.Storage.{Page, Repo}
|
|
|
|
defenum(Priority,
|
|
very_low: 10,
|
|
low: 20,
|
|
medium: 30,
|
|
high: 40,
|
|
very_high: 50
|
|
)
|
|
|
|
@activity_types ["event", "post", "discussion", "resource", "group", "member"]
|
|
@event_activity_subjects ["event_created", "event_updated", "event_deleted", "comment_posted"]
|
|
@post_activity_subjects ["post_created", "post_updated", "post_deleted"]
|
|
@discussion_activity_subjects [
|
|
"discussion_created",
|
|
"discussion_replied",
|
|
"discussion_renamed",
|
|
"discussion_archived",
|
|
"discussion_deleted"
|
|
]
|
|
@resource_activity_subjects [
|
|
"resource_created",
|
|
"resource_renamed",
|
|
"resource_moved",
|
|
"resource_deleted"
|
|
]
|
|
@member_activity_subjects [
|
|
"member_request",
|
|
"member_invited",
|
|
"member_accepted_invitation",
|
|
"member_rejected_invitation",
|
|
"member_added",
|
|
"member_joined",
|
|
"member_approved",
|
|
"member_updated",
|
|
"member_removed",
|
|
"member_quit"
|
|
]
|
|
@settings_activity_subjects ["group_created", "group_updated"]
|
|
|
|
@subjects @event_activity_subjects ++
|
|
@post_activity_subjects ++
|
|
@discussion_activity_subjects ++
|
|
@resource_activity_subjects ++
|
|
@member_activity_subjects ++ @settings_activity_subjects
|
|
|
|
@object_type ["event", "actor", "post", "discussion", "resource", "member", "group", "comment"]
|
|
|
|
defenum(Type, @activity_types)
|
|
defenum(Subject, @subjects)
|
|
defenum(ObjectType, @object_type)
|
|
|
|
@doc """
|
|
Returns the list of activities.
|
|
|
|
## Examples
|
|
|
|
iex> list_activities()
|
|
[%Activity{}, ...]
|
|
|
|
"""
|
|
def list_activities do
|
|
Repo.all(Activity)
|
|
end
|
|
|
|
@spec list_group_activities_for_member(
|
|
integer() | String.t(),
|
|
integer() | String.t(),
|
|
Keyword.t(),
|
|
integer() | nil,
|
|
integer() | nil
|
|
) :: Page.t()
|
|
def list_group_activities_for_member(
|
|
group_id,
|
|
actor_asking_id,
|
|
filters \\ [],
|
|
page \\ nil,
|
|
limit \\ nil
|
|
) do
|
|
Activity
|
|
|> where([a], a.group_id == ^group_id)
|
|
|> join(:inner, [a], m in Member,
|
|
on: m.parent_id == a.group_id and m.actor_id == ^actor_asking_id
|
|
)
|
|
|> where([a, m], a.inserted_at >= m.member_since)
|
|
|> filter_object_type(Keyword.get(filters, :type))
|
|
|> filter_author(Keyword.get(filters, :author), actor_asking_id)
|
|
|> order_by(desc: :inserted_at)
|
|
|> preload([:author, :group])
|
|
|> Page.build_page(page, limit)
|
|
end
|
|
|
|
@spec list_group_activities(
|
|
integer() | String.t(),
|
|
Keyword.t(),
|
|
integer() | nil,
|
|
integer() | nil
|
|
) :: Page.t()
|
|
def list_group_activities(
|
|
group_id,
|
|
filters \\ [],
|
|
page \\ nil,
|
|
limit \\ nil
|
|
) do
|
|
Activity
|
|
|> where([a], a.group_id == ^group_id)
|
|
|> filter_object_type(Keyword.get(filters, :type))
|
|
|> order_by(desc: :inserted_at)
|
|
|> preload([:author, :group])
|
|
|> Page.build_page(page, limit)
|
|
end
|
|
|
|
@doc """
|
|
Gets a single activity.
|
|
|
|
Raises `Ecto.NoResultsError` if the Activity does not exist.
|
|
|
|
## Examples
|
|
|
|
iex> get_activity!(123)
|
|
%Activity{}
|
|
|
|
iex> get_activity!(456)
|
|
** (Ecto.NoResultsError)
|
|
|
|
"""
|
|
def get_activity!(id), do: Repo.get!(Activity, id)
|
|
|
|
@doc """
|
|
Creates a activity.
|
|
|
|
## Examples
|
|
|
|
iex> create_activity(%{field: value})
|
|
{:ok, %Activity{}}
|
|
|
|
iex> create_activity(%{field: bad_value})
|
|
{:error, %Ecto.Changeset{}}
|
|
|
|
"""
|
|
def create_activity(attrs \\ %{}) do
|
|
%Activity{}
|
|
|> Activity.changeset(attrs)
|
|
|> Repo.insert()
|
|
end
|
|
|
|
def object_types, do: @object_type
|
|
|
|
def subjects, do: @subjects
|
|
|
|
def activity_types, do: @activity_types
|
|
|
|
@spec filter_object_type(Query.t(), atom() | nil) :: Query.t()
|
|
defp filter_object_type(query, nil), do: query
|
|
|
|
defp filter_object_type(query, type) do
|
|
where(query, [q], q.type == ^type)
|
|
end
|
|
|
|
@spec filter_author(Query.t(), atom() | nil, integer() | String.t()) :: Query.t()
|
|
defp filter_author(query, nil, _), do: query
|
|
|
|
defp filter_author(query, :self, actor_asking_id) do
|
|
where(query, [q], q.author_id == ^actor_asking_id)
|
|
end
|
|
|
|
defp filter_author(query, :by, actor_asking_id) do
|
|
where(query, [q], q.author_id != ^actor_asking_id)
|
|
end
|
|
end
|