From dbda539022c5f4789364eb70ac56be4a84858e86 Mon Sep 17 00:00:00 2001
From: Bjorn Twachtmann <BjornTwachtmann@users.noreply.github.com>
Date: Wed, 18 Apr 2018 15:03:02 +0100
Subject: [PATCH] Programmes 6323 deal with parents in other partner pids
 (#245)

* Add new entity to track changes skipped due to parents in another partner_pid
---
 .../Entity/PipsAutoSkippedChange.php          | 43 +++++++++++++++++++
 .../PipsAutoSkippedChangeRepository.php       | 25 +++++++++++
 2 files changed, 68 insertions(+)
 create mode 100644 src/Data/ProgrammesDb/Entity/PipsAutoSkippedChange.php
 create mode 100644 src/Data/ProgrammesDb/EntityRepository/PipsAutoSkippedChangeRepository.php

diff --git a/src/Data/ProgrammesDb/Entity/PipsAutoSkippedChange.php b/src/Data/ProgrammesDb/Entity/PipsAutoSkippedChange.php
new file mode 100644
index 00000000..41be5c16
--- /dev/null
+++ b/src/Data/ProgrammesDb/Entity/PipsAutoSkippedChange.php
@@ -0,0 +1,43 @@
+<?php
+
+namespace BBC\ProgrammesPagesService\Data\ProgrammesDb\Entity;
+
+use Doctrine\ORM\Mapping as ORM;
+
+/**
+ * This table lists all changes relating to our desired partner_pids that have been skipped due to having a parent in
+ * another partner_pid we do not ingest.
+ * It's here so we have a permanent record of when that happens and can re-ingest if necessary.
+ *
+ * We do this because there's really no sane way to deal with that case other than "ingest everything in all
+ * partner_pids", which would require a massive rewrite of our queries and reingest of all data.
+ *
+ * @ORM\Table()
+ * @ORM\Entity(repositoryClass="BBC\ProgrammesPagesService\Data\ProgrammesDb\EntityRepository\PipsAutoSkippedChangeRepository")
+ */
+class PipsAutoSkippedChange extends PipsChangeBase
+{
+    /**
+     * The ID of the parent entity that caused this (otherwise valid) change event to be auto-skipped.
+     * @var string
+     *
+     * @ORM\Column(type="string", length=255, nullable=false)
+     */
+    private $triggeringEntityId;
+
+    /**
+     * @return string
+     */
+    public function getTriggeringEntityId(): string
+    {
+        return $this->triggeringEntityId;
+    }
+
+    /**
+     * @param string $triggeringEntityId
+     */
+    public function setTriggeringEntityId(string $triggeringEntityId)
+    {
+        $this->triggeringEntityId = $triggeringEntityId;
+    }
+}
diff --git a/src/Data/ProgrammesDb/EntityRepository/PipsAutoSkippedChangeRepository.php b/src/Data/ProgrammesDb/EntityRepository/PipsAutoSkippedChangeRepository.php
new file mode 100644
index 00000000..a3247e0c
--- /dev/null
+++ b/src/Data/ProgrammesDb/EntityRepository/PipsAutoSkippedChangeRepository.php
@@ -0,0 +1,25 @@
+<?php
+
+namespace BBC\ProgrammesPagesService\Data\ProgrammesDb\EntityRepository;
+
+use BBC\ProgrammesPagesService\Data\ProgrammesDb\Entity\PipsAutoSkippedChange;
+use Doctrine\ORM\EntityRepository;
+
+class PipsAutoSkippedChangeRepository extends EntityRepository
+{
+    public function addSkippedEntity(PipsAutoSkippedChange $pipsSkippedEntity)
+    {
+        $em = $this->getEntityManager();
+        $em->persist($pipsSkippedEntity);
+        $em->flush();
+    }
+
+    /**
+     * @param mixed $cid
+     * @return null|PipsAutoSkippedChange
+     */
+    public function findById($cid)
+    {
+        return $this->find($cid);
+    }
+}