fix integration test

Author: peterargue

integration/tests/access/cohort3/collection_indexing_test.go

@@ -3,6 +3,7 @@ package cohort3
 import (
 	"context"
 	"fmt"
+	"net/http"
 	"testing"
 	"time"
 
@@ -82,7 +83,7 @@ func (s *CollectionIndexingSuite) Test() {
 	// start the network with access_2 disconnected.
 	// this simulates it falling behind on syncing collections
 	access2 := s.net.ContainerByName("access_2")
-	s.Require().NoError(access2.Disconnect())
+	s.Require().NoError(access2.Pause())
 
 	// wait for access_1 to sync collections
 	targetBlockCount := uint64(50)
@@ -98,7 +99,10 @@ func (s *CollectionIndexingSuite) Test() {
 	s.Require().NoError(s.net.ContainerByName("collection_2").Pause())
 
 	// now start access_2, and wait for it to catch up with collections
-	s.Require().NoError(access2.Connect())
+	s.Require().NoError(access2.Start())
+
+	// wait for access_2 to complete startup
+	s.waitForMetricsAPI("access_2")
 
 	s.Eventually(func() bool {
 		value, err := s.getLastFullHeight("access_2")
@@ -118,3 +122,13 @@ func (s *CollectionIndexingSuite) getLastFullHeight(containerName string) (uint6
 
 	return uint64(values[0].GetGauge().GetValue()), nil
 }
+
+func (s *CollectionIndexingSuite) waitForMetricsAPI(containerName string) {
+	node := s.net.ContainerByName(containerName)
+	metricsURL := fmt.Sprintf("http://0.0.0.0:%s/metrics", node.Port(testnet.MetricsPort))
+
+	s.Require().Eventually(func() bool {
+		_, err := http.Get(metricsURL)
+		return err == nil
+	}, 60*time.Second, 1*time.Second)
+}