1 # Pleroma: A lightweight social networking server
2 # Copyright © 2017-2019 Pleroma Authors <https://pleroma.social/>
3 # SPDX-License-Identifier: AGPL-3.0-only
5 defmodule Pleroma.Conversation.Participation do
7 alias Pleroma.Conversation
8 alias Pleroma.Conversation.Participation.RecipientShip
11 alias Pleroma.Web.ActivityPub.ActivityPub
15 schema "conversation_participations" do
16 belongs_to(:user, User, type: Pleroma.FlakeId)
17 belongs_to(:conversation, Conversation)
18 field(:read, :boolean, default: false)
19 field(:last_activity_id, Pleroma.FlakeId, virtual: true)
21 has_many(:recipient_ships, RecipientShip)
22 has_many(:recipients, through: [:recipient_ships, :user])
27 def creation_cng(struct, params) do
29 |> cast(params, [:user_id, :conversation_id, :read])
30 |> validate_required([:user_id, :conversation_id])
33 def create_for_user_and_conversation(user, conversation, opts \\ []) do
37 |> creation_cng(%{user_id: user.id, conversation_id: conversation.id, read: read})
39 on_conflict: [set: [read: read, updated_at: NaiveDateTime.utc_now()]],
41 conflict_target: [:user_id, :conversation_id]
45 def read_cng(struct, params) do
47 |> cast(params, [:read])
48 |> validate_required([:read])
51 def mark_as_read(participation) do
53 |> read_cng(%{read: true})
57 def mark_as_unread(participation) do
59 |> read_cng(%{read: false})
63 def for_user(user, params \\ %{}) do
65 where: p.user_id == ^user.id,
66 order_by: [desc: p.updated_at],
67 preload: [conversation: [:users]]
69 |> Pleroma.Pagination.fetch_paginated(params)
73 def for_user_and_conversation(user, conversation) do
75 where: p.user_id == ^user.id,
76 where: p.conversation_id == ^conversation.id
81 def for_user_with_last_activity_id(user, params \\ %{}) do
82 for_user(user, params)
83 |> Enum.map(fn participation ->
85 ActivityPub.fetch_latest_activity_id_for_context(participation.conversation.ap_id, %{
87 "blocking_user" => user
92 | last_activity_id: activity_id
95 |> Enum.filter(& &1.last_activity_id)
99 def get(nil, _), do: nil
101 def get(id, params) do
103 if preload = params[:preload] do
104 from(p in __MODULE__,
114 def set_recipients(participation, user_ids) do
116 [participation.user_id | user_ids]
119 Repo.transaction(fn ->
121 from(r in RecipientShip,
122 where: r.participation_id == ^participation.id
125 Repo.delete_all(query)
129 where: u.id in ^user_ids
133 RecipientShip.create(users, participation)
137 {:ok, Repo.preload(participation, :recipients, force: true)}