src/Entity/Chat/ChatPendingMember.php line 32

Open in your IDE?
  1. <?php
  3. namespace App\Entity\Chat;
  5. use App\Repository\Chat\ChatPendingMemberRepository;
  6. use Doctrine\ORM\Mapping as ORM;
  8. /**
  9. * Persistencia local de miembros pendientes de incorporacion a chats Hermes.
  10. *
  11. * Trazabilidad:
  12. * - HU-389v2-01 (data-model chat_pending_members)
  13. * - ADR-002 persistencia local
  14. * - ADR-004 idempotencia via (status, attempts)
  15. * - ADR-006 soft-delete via purged_at
  16. *
  17. * Diagrama de estados:
  18. * PENDING -> PROCESSING -> DONE (terminal)
  19. * PROCESSING -> FAILED -> PROCESSING (retry, attempts++)
  20. * * -> purged (soft-delete TTL)
  21. *
  22. * @ORM\Entity(repositoryClass=ChatPendingMemberRepository::class)
  23. * @ORM\Table(
  24. * name="chat_pending_members",
  25. * indexes={
  26. * @ORM\Index(name="idx_pcid_status", columns={"propietario_contenido_id","status"}),
  27. * @ORM\Index(name="idx_chat_uuid", columns={"chat_uuid"}),
  28. * @ORM\Index(name="idx_purge", columns={"created_at"})
  29. * }
  30. * )
  31. */
  32. class ChatPendingMember
  33. {
  34. public const STATUS_PENDING = 'PENDING';
  35. public const STATUS_PROCESSING = 'PROCESSING';
  36. public const STATUS_DONE = 'DONE';
  37. public const STATUS_FAILED = 'FAILED';
  38. public const STATUS_FAILED_PERMANENT = 'FAILED_PERMANENT';
  40. public const PURGE_TTL = 'ttl';
  41. public const PURGE_CHAT_DELETED = 'chat_deleted';
  43. /**
  44. * @ORM\Id
  45. * @ORM\Column(type="bigint")
  46. * @ORM\GeneratedValue(strategy="AUTO")
  47. */
  48. private $id;
  50. /**
  51. * @ORM\Column(type="string", length=36, name="chat_uuid")
  52. */
  53. private string $chatUuid;
  55. /**
  56. * @ORM\Column(type="integer", name="propietario_contenido_id")
  57. */
  58. private int $propietarioContenidoId;
  60. /**
  61. * @ORM\Column(type="integer", name="grupo_id")
  62. */
  63. private int $grupoId;
  65. /**
  66. * @ORM\Column(type="integer", name="created_by")
  67. */
  68. private int $createdBy;
  70. /**
  71. * @ORM\Column(type="string", length=16, options={"default":"PENDING"})
  72. */
  73. private string $status = self::STATUS_PENDING;
  75. /**
  76. * @ORM\Column(type="integer", options={"default":0})
  77. */
  78. private int $attempts = 0;
  80. /**
  81. * @ORM\Column(type="text", nullable=true, name="last_error")
  82. */
  83. private ?string $lastError = null;
  85. /**
  86. * @ORM\Column(type="datetime_immutable", name="created_at")
  87. */
  88. private \DateTimeImmutable $createdAt;
  90. /**
  91. * @ORM\Column(type="datetime_immutable", nullable=true, name="processed_at")
  92. */
  93. private ?\DateTimeImmutable $processedAt = null;
  95. /**
  96. * @ORM\Column(type="datetime_immutable", nullable=true, name="purged_at")
  97. */
  98. private ?\DateTimeImmutable $purgedAt = null;
  100. /**
  101. * @ORM\Column(type="string", length=32, nullable=true, name="purge_reason")
  102. */
  103. private ?string $purgeReason = null;
  105. public function __construct(
  106. string $chatUuid,
  107. int $propietarioContenidoId,
  108. int $grupoId,
  109. int $createdBy
  110. ) {
  111. $this->chatUuid = $chatUuid;
  112. $this->propietarioContenidoId = $propietarioContenidoId;
  113. $this->grupoId = $grupoId;
  114. $this->createdBy = $createdBy;
  115. $this->status = self::STATUS_PENDING;
  116. $this->attempts = 0;
  117. $this->createdAt = new \DateTimeImmutable();
  118. }
  120. public function getId(): ?int
  121. {
  122. return $this->id !== null ? (int) $this->id : null;
  123. }
  125. public function getChatUuid(): string
  126. {
  127. return $this->chatUuid;
  128. }
  130. public function getPropietarioContenidoId(): int
  131. {
  132. return $this->propietarioContenidoId;
  133. }
  135. public function getGrupoId(): int
  136. {
  137. return $this->grupoId;
  138. }
  140. public function getCreatedBy(): int
  141. {
  142. return $this->createdBy;
  143. }
  145. public function getStatus(): string
  146. {
  147. return $this->status;
  148. }
  150. public function getAttempts(): int
  151. {
  152. return $this->attempts;
  153. }
  155. public function getLastError(): ?string
  156. {
  157. return $this->lastError;
  158. }
  160. public function getCreatedAt(): \DateTimeImmutable
  161. {
  162. return $this->createdAt;
  163. }
  165. public function getProcessedAt(): ?\DateTimeImmutable
  166. {
  167. return $this->processedAt;
  168. }
  170. public function getPurgedAt(): ?\DateTimeImmutable
  171. {
  172. return $this->purgedAt;
  173. }
  175. /**
  176. * Transicion PENDING|FAILED -> PROCESSING. Incrementa attempts.
  177. * No permitida desde DONE / FAILED_PERMANENT (terminales).
  178. */
  179. public function markProcessing(): void
  180. {
  181. if (in_array($this->status, [self::STATUS_DONE, self::STATUS_FAILED_PERMANENT], true)) {
  182. throw new \LogicException(sprintf(
  183. 'No se puede transitar a PROCESSING desde estado terminal "%s"',
  184. $this->status
  185. ));
  186. }
  187. $this->status = self::STATUS_PROCESSING;
  188. $this->attempts++;
  189. }
  191. /**
  192. * Transicion PROCESSING -> DONE (terminal). Asigna processed_at.
  193. */
  194. public function markDone(): void
  195. {
  196. $this->status = self::STATUS_DONE;
  197. $this->processedAt = new \DateTimeImmutable();
  198. }
  200. /**
  201. * Transicion PROCESSING -> FAILED. NO incrementa attempts (se incrementa en re-markProcessing).
  202. */
  203. public function markFailed(string $errorMessage): void
  204. {
  205. $this->status = self::STATUS_FAILED;
  206. $this->lastError = $errorMessage;
  207. }
  209. public function getPurgeReason(): ?string
  210. {
  211. return $this->purgeReason;
  212. }
  214. /**
  215. * Soft-delete (ADR-006). Asigna purged_at + razon (ttl|chat_deleted).
  216. */
  217. public function markPurged(string $reason = self::PURGE_TTL): void
  218. {
  219. $this->purgedAt = new \DateTimeImmutable();
  220. $this->purgeReason = $reason;
  221. }
  222. }