src/Entity/Chat/Conversation.php line 31

Open in your IDE?
  1. <?php
  3. namespace App\Entity\Chat;
  5. use App\Entity\Account\User;
  6. use App\Entity\Channel\Channel;
  7. use App\Repository\Chat\ConversationRepository;
  8. use Doctrine\Common\Collections\ArrayCollection;
  9. use Doctrine\Common\Collections\Collection;
  10. use Doctrine\ORM\Mapping as ORM;
  11. use Doctrine\ORM\Mapping\DiscriminatorColumn;
  12. use Doctrine\ORM\Mapping\DiscriminatorMap;
  13. use Doctrine\ORM\Mapping\InheritanceType;
  14. use DrosalysWeb\ObjectExtensions\Blame\Model\BlameInterface;
  15. use DrosalysWeb\ObjectExtensions\Blame\Model\BlameTrait;
  16. use DrosalysWeb\ObjectExtensions\Timestamp\Model\TimestampInterface;
  17. use DrosalysWeb\ObjectExtensions\Timestamp\Model\TimestampTrait;
  18. use Symfony\Component\Validator\Constraints as Assert;
  19. use Symfony\Component\Serializer\Annotation as Serial;
  21. #[ORM\Entity(repositoryClass: ConversationRepository::class)]
  22. #[ORM\Table(name: 'chat_conversations')]
  23. #[InheritanceType('JOINED')]
  24. #[DiscriminatorColumn(name: 'dtype', type: 'string')]
  25. #[DiscriminatorMap([
  26.     'conversation' => Conversation::class,
  27.     'service_conversation' => ServiceConversation::class,
  28.     'canal' => Canal::class,
  29.     'temporary_canal' => TemporaryCanal::class
  30. ])]
  31. class Conversation implements TimestampInterface, BlameInterface
  32. {
  33.     use TimestampTrait;
  34.     use BlameTrait;
  36.     #[ORM\Id]
  37.     #[ORM\GeneratedValue]
  38.     #[ORM\Column(type: 'integer')]
  39.     #[Serial\Groups(groups: ['Conversation', 'Identifier'])]
  40.     private ?int $id = null;
  42.     #[ORM\ManyToOne(targetEntity: Channel::class)]
  43.     #[ORM\JoinColumn(nullable: false, onDelete: 'CASCADE')]
  44.     private ?Channel $channel = null;
  46.     #[ORM\Column(type: 'integer')]
  47.     #[
  48.         Assert\NotBlank(message: 'entity.tchat.canal.type.NotBlank'),
  49.         Assert\Type(
  50.             type: "integer"
  51.         )
  52.     ]
  53.     #[Serial\Groups(groups: ['Conversation', 'PostCanal', 'Identifier'])]
  54.     private ?int $type = null;
  56.     #[ORM\OneToMany(mappedBy: 'conversation', targetEntity: ConversationUser::class, cascade: ['persist', 'remove'], orphanRemoval: true)]
  57.     #[Serial\Groups(['PostCanal'])]
  58.     private ?Collection $conversationUsers;
  60.     #[ORM\OneToMany(mappedBy: 'conversation', targetEntity: Message::class, cascade: ['persist', 'remove'], fetch: 'EXTRA_LAZY', orphanRemoval: true)]
  61.     private ?Collection $messages;
  63.     public function __construct()
  64.     {
  65.         $this->conversationUsers = new ArrayCollection();
  66.         $this->messages = new ArrayCollection();
  67.     }
  69.     public function hasConversationUser(User $user): bool
  70.     {
  71.         $userAlreadyIn = $this->getConversationUsers()->filter(function(ConversationUser $conversationUser) use ($user) {
  72.             return $conversationUser->getUser()->getId() === $user->getId();
  73.         })->first();
  75.         return $userAlreadyIn !== false;
  76.     }
  78.     #[Serial\Groups(groups: ['Conversation'])]
  79.     public function getCountConversationUsers(): int
  80.     {
  81.         return $this->conversationUsers->count();
  82.     }
  84.     public function getId(): ?int
  85.     {
  86.         return $this->id;
  87.     }
  89.     public function getType(): ?int
  90.     {
  91.         return $this->type;
  92.     }
  94.     public function setType(int $type): self
  95.     {
  96.         $this->type = $type;
  98.         return $this;
  99.     }
  101.     /**
  102.      * @return Collection<int, ConversationUser>
  103.      */
  104.     public function getConversationUsers(): Collection
  105.     {
  106.         return $this->conversationUsers;
  107.     }
  109.     public function getConversationUserIds(): array
  110.     {
  111.         return array_map(function(ConversationUser $conversationUser) {
  112.             return $conversationUser->getUser()->getId();
  113.         }, $this->conversationUsers->toArray());
  114.     }
  116.     public function addConversationUser(ConversationUser $conversationUser): self
  117.     {
  118.         if (!$this->conversationUsers->contains($conversationUser)) {
  119.             $this->conversationUsers[] = $conversationUser;
  120.             $conversationUser->setConversation($this);
  121.         }
  123.         return $this;
  124.     }
  126.     public function removeConversationUser(ConversationUser $conversationUser): self
  127.     {
  128.         if ($this->conversationUsers->removeElement($conversationUser)) {
  129.             // set the owning side to null (unless already changed)
  130.             if ($conversationUser->getConversation() === $this) {
  131.                 $conversationUser->setConversation(null);
  132.             }
  133.         }
  135.         return $this;
  136.     }
  138.     public function getConversationUserByUser(User $user): ?ConversationUser
  139.     {
  140.         $conversationUsersToRemove = $this->conversationUsers->filter(function(ConversationUser $conversationUser) use ($user) {
  141.             return $conversationUser->getUser()->getId() === $user->getId();
  142.         })->first();
  143.         if ($conversationUsersToRemove) {
  144.             return $conversationUsersToRemove;
  145.         }
  147.         return null;
  148.     }
  150.     public function getMessages(): ?Collection
  151.     {
  152.         return $this->messages;
  153.     }
  155.     public function setMessages(?Collection $messages): Conversation
  156.     {
  157.         $this->messages = $messages;
  158.         return $this;
  159.     }
  161.     public function getChannel(): ?Channel
  162.     {
  163.         return $this->channel;
  164.     }
  166.     public function setChannel(?Channel $channel): Conversation
  167.     {
  168.         $this->channel = $channel;
  169.         return $this;
  170.     }
  171. }