From 2aacdb2e34938840aca14820dd746f456d8d24dc Mon Sep 17 00:00:00 2001
From: miguelreiswildlife <miguel.reis@wildlifestudios.com>
Date: Mon, 17 Jun 2024 10:43:07 -0300
Subject: [PATCH] Tweak timeouts

---
 e2e/apns_e2e_test.go | 12 ++++++------
 e2e/utils_test.go    |  2 +-
 2 files changed, 7 insertions(+), 7 deletions(-)

diff --git a/e2e/apns_e2e_test.go b/e2e/apns_e2e_test.go
index ecc25d2..565bb7f 100644
--- a/e2e/apns_e2e_test.go
+++ b/e2e/apns_e2e_test.go
@@ -78,7 +78,7 @@ func (s *ApnsE2ETestSuite) setupApnsPusher() (
 func (s *ApnsE2ETestSuite) TestSimpleNotification() {
 	p, mockApnsClient, statsdClientMock, responsesChannel := s.setupApnsPusher()
 	go p.Start(context.Background())
-	time.Sleep(wait * 3)
+	time.Sleep(wait * 2)
 
 	producer, err := kafka.NewProducer(&kafka.ConfigMap{
 		"bootstrap.servers": s.config.Queue.Brokers,
@@ -148,7 +148,7 @@ func (s *ApnsE2ETestSuite) TestSimpleNotification() {
 func (s *ApnsE2ETestSuite) TestNotificationRetry() {
 	p, mockApnsClient, statsdClientMock, responsesChannel := s.setupApnsPusher()
 	go p.Start(context.Background())
-	time.Sleep(wait * 3)
+	time.Sleep(wait * 2)
 
 	producer, err := kafka.NewProducer(&kafka.ConfigMap{
 		"bootstrap.servers": s.config.Queue.Brokers,
@@ -238,7 +238,7 @@ func (s *ApnsE2ETestSuite) TestNotificationRetry() {
 func (s *ApnsE2ETestSuite) TestRetryLimit() {
 	p, mockApnsClient, statsdClientMock, responsesChannel := s.setupApnsPusher()
 	go p.Start(context.Background())
-	time.Sleep(wait * 3)
+	time.Sleep(wait * 2)
 
 	producer, err := kafka.NewProducer(&kafka.ConfigMap{
 		"bootstrap.servers": s.config.Queue.Brokers,
@@ -311,7 +311,7 @@ func (s *ApnsE2ETestSuite) TestRetryLimit() {
 func (s *ApnsE2ETestSuite) TestMultipleNotifications() {
 	p, mockApnsClient, statsdClientMock, responsesChannel := s.setupApnsPusher()
 	go p.Start(context.Background())
-	time.Sleep(wait * 3)
+	time.Sleep(wait * 2)
 
 	notificationsToSend := 10
 	producer, err := kafka.NewProducer(&kafka.ConfigMap{
@@ -394,7 +394,7 @@ func (s *ApnsE2ETestSuite) TestConsumeMessagesBeforeExiting() {
 	ctx := context.Background()
 	ctx, cancel := context.WithCancel(ctx)
 	go p.Start(ctx)
-	time.Sleep(wait * 3)
+	time.Sleep(wait * 2)
 
 	notificationsToSend := 3
 	producer, err := kafka.NewProducer(&kafka.ConfigMap{
@@ -485,7 +485,7 @@ func (s *ApnsE2ETestSuite) TestConsumeMessagesBeforeExitingWithRetries() {
 	ctx := context.Background()
 	ctx, cancel := context.WithCancel(ctx)
 	go p.Start(ctx)
-	time.Sleep(wait * 3)
+	time.Sleep(wait * 2)
 
 	producer, err := kafka.NewProducer(&kafka.ConfigMap{
 		"bootstrap.servers": s.config.Queue.Brokers,
diff --git a/e2e/utils_test.go b/e2e/utils_test.go
index 80967b4..4112c2d 100644
--- a/e2e/utils_test.go
+++ b/e2e/utils_test.go
@@ -3,7 +3,7 @@ package e2e
 import "time"
 
 const (
-	wait              = 10 * time.Second
+	wait              = 15 * time.Second
 	timeout           = 1 * time.Minute
 	apnsTopicTemplate = "push-%s_apns-single"
 	gcmTopicTemplate  = "push-%s_gcm-single"