set expiry when parsing onclusive events

CPCN-825

server/planning/feed_parsers/onclusive.py

@@ -75,6 +75,7 @@ def parse(self, content, provider=None):
                 self.parse_event_details(event, item)
                 self.parse_category(event, item)
                 self.parse_contact_info(event, item)
+                self.set_expiry(item, provider)
                 all_events.append(item)
             except EmbargoedException:
                 logger.info("Ignoring embargoed event %s", event["itemId"])
@@ -303,3 +304,11 @@ def parse_contact_info(self, event, item):
                 existing_contact_id = bson.ObjectId(existing_contact["_id"])
                 get_resource_service("contacts").patch(existing_contact_id, data)
                 item["event_contact_info"].append(existing_contact_id)
+
+    def set_expiry(self, event, provider) -> None:
+        expiry_minutes = (
+            int(provider.get("content_expiry") if provider else 0)
+            or int(app.config.get("INGEST_EXPIRY_MINUTES"))
+            or (60 * 24)
+        )
+        event["expiry"] = event["dates"]["end"] + datetime.timedelta(minutes=(expiry_minutes))

server/planning/feed_parsers/onclusive_tests.py

@@ -112,6 +112,8 @@ def test_content(self):
         item = OnclusiveFeedParser().parse([data])[0]
         self.assertEqual(item["occur_status"]["qcode"], "eocstat:eos3")
 
+        self.assertGreater(item["expiry"], item["dates"]["end"])
+
     def test_content_no_time(self):
         data = self.data.copy()
         data["time"] = ""