defmodule Eventos.Actors.Actor.TitleSlug do @moduledoc """ Slug generation for groups """ alias Eventos.Actors.Actor import Ecto.Query alias Eventos.Repo use EctoAutoslugField.Slug, from: :title, to: :slug def build_slug(sources, changeset) do slug = super(sources, changeset) build_unique_slug(slug, changeset) end defp build_unique_slug(slug, changeset) do query = from a in Actor, where: a.slug == ^slug case Repo.one(query) do nil -> slug _story -> slug |> Eventos.Slug.increment_slug() |> build_unique_slug(changeset) end end end import EctoEnum defenum Eventos.Actors.ActorTypeEnum, :actor_type, [:Person, :Application, :Group, :Organization, :Service] defmodule Eventos.Actors.Actor do @moduledoc """ Represents an actor (local and remote actors) """ use Ecto.Schema import Ecto.Changeset alias Eventos.Actors alias Eventos.Actors.{Actor, User, Follower, Member} alias Eventos.Events.Event alias Eventos.Service.ActivityPub import Ecto.Query alias Eventos.Repo import Logger # @type t :: %Actor{description: String.t, id: integer(), inserted_at: DateTime.t, updated_at: DateTime.t, display_name: String.t, domain: String.t, private_key: String.t, public_key: String.t, suspended: boolean(), url: String.t, username: String.t, organized_events: list(), groups: list(), group_request: list(), user: User.t, field: ActorTypeEnum.t} schema "actors" do field :url, :string field :outbox_url, :string field :inbox_url, :string field :following_url, :string field :followers_url, :string field :shared_inbox_url, :string field :type, Eventos.Actors.ActorTypeEnum field :name, :string field :domain, :string field :summary, :string field :preferred_username, :string field :public_key, :string field :private_key, :string field :manually_approves_followers, :boolean, default: false field :suspended, :boolean, default: false field :avatar_url, :string field :banner_url, :string many_to_many :followers, Actor, join_through: Follower has_many :organized_events, Event, [foreign_key: :organizer_actor_id] many_to_many :memberships, Actor, join_through: Member has_one :user, User timestamps() end @doc false def changeset(%Actor{} = actor, attrs) do actor |> Ecto.Changeset.cast(attrs, [:url, :outbox_url, :inbox_url, :shared_inbox_url, :following_url, :followers_url, :type, :name, :domain, :summary, :preferred_username, :public_key, :private_key, :manually_approves_followers, :suspended, :avatar_url, :banner_url]) |> validate_required([:preferred_username, :public_key, :suspended, :url]) |> unique_constraint(:prefered_username, name: :actors_preferred_username_domain_index) end def registration_changeset(%Actor{} = actor, attrs) do actor |> Ecto.Changeset.cast(attrs, [:preferred_username, :domain, :name, :summary, :private_key, :public_key, :suspended, :url, :type]) |> validate_required([:preferred_username, :public_key, :suspended, :url, :type]) |> unique_constraint(:prefered_username, name: :actors_preferred_username_domain_index) end @email_regex ~r/^[a-zA-Z0-9.!#$%&'*+\/=?^_`{|}~-]+@[a-zA-Z0-9](?:[a-zA-Z0-9-]{0,61}[a-zA-Z0-9])?(?:\.[a-zA-Z0-9](?:[a-zA-Z0-9-]{0,61}[a-zA-Z0-9])?)*$/ def remote_actor_creation(params) do changes = %Actor{} |> Ecto.Changeset.cast(params, [:url, :outbox_url, :inbox_url, :shared_inbox_url, :following_url, :followers_url, :type, :name, :domain, :summary, :preferred_username, :public_key, :manually_approves_followers, :avatar_url, :banner_url]) |> validate_required([:url, :outbox_url, :inbox_url, :type, :name, :domain, :preferred_username, :public_key]) |> unique_constraint(:preferred_username, name: :actors_preferred_username_domain_index) |> validate_length(:summary, max: 5000) |> validate_length(:preferred_username, max: 100) |> put_change(:local, false) Logger.debug("Remote actor creation") Logger.debug(inspect changes) changes end def group_creation(%Actor{} = actor, params) do actor |> Ecto.Changeset.cast(params, [:url, :outbox_url, :inbox_url, :shared_inbox_url, :type, :name, :domain, :summary, :preferred_username, :avatar_url, :banner_url]) |> put_change(:outbox_url, "#{EventosWeb.Endpoint.url()}/@#{params["prefered_username"]}/outbox") |> put_change(:inbox_url, "#{EventosWeb.Endpoint.url()}/@#{params["prefered_username"]}/inbox") |> put_change(:shared_inbox_url, "#{EventosWeb.Endpoint.url()}/inbox") |> put_change(:url, "#{EventosWeb.Endpoint.url()}/@#{params["prefered_username"]}") |> put_change(:domain, nil) |> put_change(:type, "Group") |> validate_required([:url, :outbox_url, :inbox_url, :type, :name, :preferred_username]) |> validate_length(:summary, max: 5000) |> validate_length(:preferred_username, max: 100) |> put_change(:local, true) end def get_or_fetch_by_url(url) do if user = Actors.get_actor_by_url(url) do user else case ActivityPub.make_actor_from_url(url) do {:ok, user} -> user _ -> {:error, "Could not fetch by AP id"} end end end #@spec get_public_key_for_url(Actor.t) :: {:ok, String.t} def get_public_key_for_url(url) do with %Actor{} = actor <- get_or_fetch_by_url(url) do get_public_key_for_actor(actor) else _ -> :error end end #@spec get_public_key_for_actor(Actor.t) :: {:ok, String.t} def get_public_key_for_actor(%Actor{} = actor) do {:ok, actor.public_key} end #@spec get_private_key_for_actor(Actor.t) :: {:ok, String.t} def get_private_key_for_actor(%Actor{} = actor) do actor.private_key end def get_followers(%Actor{id: actor_id} = actor) do Repo.all( from a in Actor, join: f in Follower, on: a.id == f.actor_id, where: f.target_actor_id == ^actor_id ) end def get_followings(%Actor{id: actor_id} = actor) do Repo.all( from a in Actor, join: f in Follower, on: a.id == f.target_actor_id, where: f.actor_id == ^actor_id ) end end