participation_recipient_ship.ex
No OneTemporary
Actions

Size

975 B

Referenced Files

None

Subscribers

None

participation_recipient_ship.ex
View Options

	# Pleroma: A lightweight social networking server
	# Copyright © 2017-2019 Pleroma Authors <https://pleroma.social/>
	# SPDX-License-Identifier: AGPL-3.0-only

	defmodule Pleroma.Conversation.Participation.RecipientShip do
	use Ecto.Schema

	alias Pleroma.Conversation.Participation
	alias Pleroma.Repo
	alias Pleroma.User

	import Ecto.Changeset

	schema "conversation_participation_recipient_ships" do
	belongs_to(:user, User, type: FlakeId.Ecto.CompatType)
	belongs_to(:participation, Participation)
	end

	def creation_cng(struct, params) do
	struct
	\|> cast(params, [:user_id, :participation_id])
	\|> validate_required([:user_id, :participation_id])
	end

	def create(%User{} = user, participation), do: create([user], participation)

	def create(users, participation) do
	Enum.each(users, fn user ->
	%__MODULE__{}
	\|> creation_cng(%{user_id: user.id, participation_id: participation.id})
	\|> Repo.insert!()
	end)
	end
	end