test

testing/integration/saga/suite/mysqlsuite.go

@@ -8,6 +8,9 @@ import (
 	"sync"
 	"time"
 
+	"github.com/testcontainers/testcontainers-go"
+	"github.com/testcontainers/testcontainers-go/wait"
+
 	driverSql "github.com/go-sql-driver/mysql"
 	"github.com/stretchr/testify/require"
 	"github.com/stretchr/testify/suite"
@@ -49,6 +52,10 @@ func (t *MysqlSuite) SetupSuite() {
 		mysql.WithDatabase(dbCreds.dbName),
 		mysql.WithUsername(dbCreds.user),
 		mysql.WithPassword(dbCreds.password),
+		testcontainers.WithWaitStrategy(
+			wait.ForLog("[Server] /usr/sbin/mysqld: ready for connections").
+				WithOccurrence(1).
+				WithStartupTimeout(30*time.Second)),
 	)
 	t.Require().NoError(err)
 	t.dbContainer = dbContainer
@@ -64,6 +71,8 @@ func (t *MysqlSuite) SetupSuite() {
 		connectionStr = v
 	}
 
+	time.Sleep(time.Second * 5)
+
 	t.dbConn, err = sql.Open("mysql", connectionStr)
 	require.NoError(t.T(), err)
 	err = t.dbConn.Ping()
@@ -87,8 +96,7 @@ func (t *MysqlSuite) TearDownSuite() {
 	require.NoError(t.T(), t.dbConn.Close())
 	ctx, cancel := context.WithTimeout(context.Background(), time.Second*10)
 	defer cancel()
-	timeout := time.Second * 10
-	err = t.dbContainer.Stop(ctx, &timeout)
+	err = t.dbContainer.Stop(ctx, nil)
 	t.Require().NoError(err)
 }
 

testing/integration/saga/suite/pgsuite.go

@@ -49,7 +49,7 @@ func (t *PgSuite) SetupSuite() {
 		testcontainers.WithWaitStrategy(
 			wait.ForLog("database system is ready to accept connections").
 				WithOccurrence(2).
-				WithStartupTimeout(1*time.Second)),
+				WithStartupTimeout(30*time.Second)),
 	)
 	require.NoError(t.T(), err)
 	t.dbContainer = dbContainer
@@ -64,6 +64,8 @@ func (t *PgSuite) SetupSuite() {
 		connectionStr = v
 	}
 
+	time.Sleep(time.Second * 5)
+
 	ctx, cancel := context.WithTimeout(context.Background(), time.Second*10)
 	defer cancel()