temp disable deduping

Author: aracho1

football/src/main/scala/com/gu/mobile/notifications/football/lib/EventFilter.scala

@@ -37,6 +37,8 @@ class EventFilter[A <: Payload, D](distinctCheck: DynamoDistinctCheck[A, D]) ext
   }
 
   def filterDynamoEvents(dynamoEvents: List[A])(implicit ec: ExecutionContext): Future[List[A]] = {
-    Future.traverse(dynamoEvents)(filterDynamoEvent).map(_.flatten)
+    // TODO: re-enable dedup
+    Future.successful(dynamoEvents)
+    // Future.traverse(dynamoEvents)(filterDynamoEvent).map(_.flatten)
   }
 }

notification/app/notification/controllers/Main.scala

@@ -109,12 +109,8 @@ final class Main(
   }
 
   private def pushWithDuplicateProtection(notification: Notification, notificationReceivedTime: Instant): Future[Result] = {
-    val isDuplicate = notificationReportRepository.getByUuid(notification.id).map(_.isRight)
-
-    isDuplicate.flatMap {
-      case true => Future.successful(BadRequest(s"${notification.id} has been sent before - refusing to resend"))
-      case false => pushGeneric(notification, notificationReceivedTime)
-    }
+    // TODO: re-enable duplicate protection
+    pushGeneric(notification, notificationReceivedTime)
   }
 
   private def pushGeneric(notification: Notification, notificationReceivedTime: Instant) = {

notification/test/notification/controllers/MainSpec.scala

@@ -38,13 +38,13 @@ class MainSpec(implicit ec: ExecutionEnv) extends PlaySpecification with Mockito
 
       status(response) must equalTo(UNAUTHORIZED)
     }
-    "refuse a notification that is sent twice" in new MainScope {
-      val request = requestWithValidTopics
-      val firstResponse = main.pushTopics()(request)
-      status(firstResponse) must equalTo(CREATED)
-      val secondResponse = main.pushTopics()(request)
-      status(secondResponse) must equalTo(BAD_REQUEST)
-    }
+    // "refuse a notification that is sent twice" in new MainScope {
+    //   val request = requestWithValidTopics
+    //   val firstResponse = main.pushTopics()(request)
+    //   status(firstResponse) must equalTo(CREATED)
+    //   val secondResponse = main.pushTopics()(request)
+    //   status(secondResponse) must equalTo(BAD_REQUEST)
+    // }
     "refuse a notification without a topic" in new MainScope {
       val request = authenticatedRequest.withBody(breakingNewsNotification(List()))
       status(main.pushTopics()(request)) must equalTo(BAD_REQUEST)