src/JanusHercules/ContentDistributionFeedCreation/Domain/Entity/WorkOnRecurrentJobResult.php line 17

Open in your IDE?
  1. <?php
  3. namespace JanusHercules\ContentDistributionFeedCreation\Domain\Entity;
  5. use App\Entity\ContentDistribution\ContentDistributorFeed;
  6. use App\Entity\RecurrentJob;
  7. use App\Utility\DatabaseIdGenerator;
  8. use Doctrine\DBAL\Types\Types;
  9. use Doctrine\ORM\Mapping as ORM;
  10. use Doctrine\ORM\Mapping\Column;
  11. use JanusHercules\HighVolumeProcess\Domain\Entity\HighVolumeProcessTask;
  12. use JanusHercules\HighVolumeProcess\Domain\Entity\HighVolumeProcessTaskResultInterface;
  13. use ValueError;
  15. #[ORM\Entity]
  16. #[ORM\Table(name: 'work_on_recurrent_job_results')]
  17. class WorkOnRecurrentJobResult implements HighVolumeProcessTaskResultInterface
  18. {
  19. public const MAX_XML_SECTION_LENGTH = 65536;
  21. #[ORM\Id]
  22. #[ORM\GeneratedValue(strategy: 'CUSTOM')]
  23. #[ORM\CustomIdGenerator(class: DatabaseIdGenerator::class)]
  24. #[Column(
  25. type : Types::GUID,
  26. unique: true
  27. )]
  28. private ?string $id = null;
  30. public function getId(): ?string
  31. {
  32. return $this->id;
  33. }
  35. #[ORM\ManyToOne(targetEntity: RecurrentJob::class)]
  36. #[ORM\JoinColumn(
  37. name : 'recurrent_jobs_id',
  38. referencedColumnName: 'id',
  39. nullable : false,
  40. onDelete : 'CASCADE'
  41. )]
  42. private RecurrentJob $recurrentJob;
  44. public function getRecurrentJob(): RecurrentJob
  45. {
  46. return $this->recurrentJob;
  47. }
  49. public function setRecurrentJob(RecurrentJob $recurrentJob): void
  50. {
  51. $this->recurrentJob = $recurrentJob;
  52. }
  54. #[Column(
  55. type: Types::TEXT,
  56. )]
  57. private string $xmlSection;
  59. public function getXMLSection(): string
  60. {
  61. return $this->xmlSection;
  62. }
  64. public function setXMLSection(string $xmlSection): void
  65. {
  66. if (mb_strlen($xmlSection) > self::MAX_XML_SECTION_LENGTH) {
  67. throw new ValueError('The XML section cannot exceed ' . self::MAX_XML_SECTION_LENGTH . ' characters.');
  68. }
  70. // Ensure proper UTF-8 handling for regex
  71. mb_regex_encoding('UTF-8');
  73. // Extract first XML tag - using /u modifier for UTF-8 support
  74. if (!preg_match('/<([a-zA-Z][a-zA-Z0-9_:-]*)[^>]*>/u', $xmlSection, $openingTagMatch)) {
  75. throw new ValueError('Invalid XML: No opening tag found.');
  76. }
  77. $tagName = $openingTagMatch[1];
  79. // Check if it properly closes - using mb_ereg_replace for multibyte safety
  80. $expectedClosingTag = "</{$tagName}>";
  81. $trimmedXml = mb_ereg_replace('^\s+|\s+$', '', $xmlSection);
  82. if (!is_string($trimmedXml) || !str_ends_with($trimmedXml, $expectedClosingTag)) {
  83. throw new ValueError("Invalid XML: Opening tag <{$tagName}> does not have a matching closing tag.");
  84. }
  86. $this->xmlSection = $xmlSection;
  87. }
  89. #[ORM\ManyToOne(
  90. targetEntity: HighVolumeProcessTask::class,
  91. )]
  92. #[ORM\JoinColumn(
  93. name : 'high_volume_process_tasks_id',
  94. referencedColumnName: 'id',
  95. nullable : false,
  96. onDelete : 'CASCADE'
  97. )]
  98. private HighVolumeProcessTask $task;
  100. public function getTask(): HighVolumeProcessTask
  101. {
  102. return $this->task;
  103. }
  105. public function setTask(HighVolumeProcessTask $task): void
  106. {
  107. $this->task = $task;
  108. }
  110. #[ORM\ManyToOne(targetEntity: ContentDistributorFeed::class)]
  111. #[ORM\JoinColumn(
  112. name : 'content_distributor_feeds_id',
  113. referencedColumnName: 'id',
  114. nullable : false,
  115. onDelete : 'CASCADE'
  116. )]
  117. private ContentDistributorFeed $contentDistributorFeed;
  119. public function getContentDistributorFeed(): ContentDistributorFeed
  120. {
  121. return $this->contentDistributorFeed;
  122. }
  124. public function setContentDistributorFeed(ContentDistributorFeed $contentDistributorFeed): void
  125. {
  126. $this->contentDistributorFeed = $contentDistributorFeed;
  127. }
  128. }