fix(tests): update database host from localhost to 127.0.0.1
Integration Tests / integration-test (push) Failing after 1m15s
Integration Tests / integration-test (push) Failing after 1m15s
* Adjust connection strings in integration tests for consistency * Ensure compatibility with CI environments that use IPv4
This commit is contained in:
@@ -389,7 +389,7 @@ go test -v ./tests/integration/... # integration tests (needs local Postgres
|
|||||||
docker-compose -f docker-compose.test.yml up --build --abort-on-container-exit --exit-code-from tests
|
docker-compose -f docker-compose.test.yml up --build --abort-on-container-exit --exit-code-from tests
|
||||||
```
|
```
|
||||||
|
|
||||||
Integration tests expect Postgres reachable at `localhost:5433` (see `tests/integration/`), including `rls_test.go` (multi-tenant isolation) and `stage5_test.go`.
|
Integration tests expect Postgres reachable at `127.0.0.1:5433` (see `tests/integration/`), including `rls_test.go` (multi-tenant isolation) and `stage5_test.go`. `127.0.0.1` is used instead of `localhost` because some CI Docker hosts publish container ports on IPv4 only, and `localhost` can resolve to `::1` first and fail.
|
||||||
|
|
||||||
### Project Structure
|
### Project Structure
|
||||||
|
|
||||||
|
|||||||
+1
-1
@@ -1,6 +1,6 @@
|
|||||||
databases:
|
databases:
|
||||||
- name: test
|
- name: test
|
||||||
host: localhost
|
host: 127.0.0.1
|
||||||
port: 5433
|
port: 5433
|
||||||
database: broker_test
|
database: broker_test
|
||||||
user: user
|
user: user
|
||||||
|
|||||||
@@ -10,7 +10,7 @@ import (
|
|||||||
)
|
)
|
||||||
|
|
||||||
func TestConnection(t *testing.T) {
|
func TestConnection(t *testing.T) {
|
||||||
connStr := "user=user password=password dbname=broker_test port=5433 sslmode=disable"
|
connStr := "user=user password=password dbname=broker_test host=127.0.0.1 port=5433 sslmode=disable"
|
||||||
var db *sql.DB
|
var db *sql.DB
|
||||||
var err error
|
var err error
|
||||||
|
|
||||||
|
|||||||
@@ -47,7 +47,7 @@ func TestRLSTenantIsolation(t *testing.T) {
|
|||||||
}
|
}
|
||||||
|
|
||||||
runtimeDB, err := sql.Open("postgres",
|
runtimeDB, err := sql.Open("postgres",
|
||||||
"user=test_broker_runtime password=test-pass dbname=broker_test host=localhost port=5433 sslmode=disable options='-c search_path=broker,public'")
|
"user=test_broker_runtime password=test-pass dbname=broker_test host=127.0.0.1 port=5433 sslmode=disable options='-c search_path=broker,public'")
|
||||||
require.NoError(t, err)
|
require.NoError(t, err)
|
||||||
defer runtimeDB.Close()
|
defer runtimeDB.Close()
|
||||||
require.NoError(t, runtimeDB.Ping())
|
require.NoError(t, runtimeDB.Ping())
|
||||||
|
|||||||
@@ -14,11 +14,11 @@ import (
|
|||||||
"git.warky.dev/wdevs/pgsql-broker/pkg/broker/install"
|
"git.warky.dev/wdevs/pgsql-broker/pkg/broker/install"
|
||||||
)
|
)
|
||||||
|
|
||||||
const stage5ConnStr = "user=user password=password dbname=broker_test host=localhost port=5433 sslmode=disable"
|
const stage5ConnStr = "user=user password=password dbname=broker_test host=127.0.0.1 port=5433 sslmode=disable"
|
||||||
|
|
||||||
func newStage5Adapter(logger adapter.Logger) *adapter.PostgresAdapter {
|
func newStage5Adapter(logger adapter.Logger) *adapter.PostgresAdapter {
|
||||||
return adapter.NewPostgresAdapter(adapter.PostgresConfig{
|
return adapter.NewPostgresAdapter(adapter.PostgresConfig{
|
||||||
Host: "localhost", Port: 5433, Database: "broker_test",
|
Host: "127.0.0.1", Port: 5433, Database: "broker_test",
|
||||||
User: "user", Password: "password", SSLMode: "disable",
|
User: "user", Password: "password", SSLMode: "disable",
|
||||||
MaxOpenConns: 10, MaxIdleConns: 2,
|
MaxOpenConns: 10, MaxIdleConns: 2,
|
||||||
ConnMaxLifetime: 5 * time.Minute, ConnMaxIdleTime: 10 * time.Minute,
|
ConnMaxLifetime: 5 * time.Minute, ConnMaxIdleTime: 10 * time.Minute,
|
||||||
|
|||||||
@@ -27,7 +27,7 @@ func TestBrokerWorkflow(t *testing.T) {
|
|||||||
ctx := context.Background()
|
ctx := context.Background()
|
||||||
|
|
||||||
// Database connection string
|
// Database connection string
|
||||||
connStr := "user=user password=password dbname=broker_test host=localhost port=5433 sslmode=disable"
|
connStr := "user=user password=password dbname=broker_test host=127.0.0.1 port=5433 sslmode=disable"
|
||||||
|
|
||||||
// Connect to database with retry logic
|
// Connect to database with retry logic
|
||||||
db, err := connectWithRetry(connStr, 10, 2*time.Second)
|
db, err := connectWithRetry(connStr, 10, 2*time.Second)
|
||||||
@@ -43,7 +43,7 @@ func TestBrokerWorkflow(t *testing.T) {
|
|||||||
|
|
||||||
// Create database adapter
|
// Create database adapter
|
||||||
postgresConfig := adapter.PostgresConfig{
|
postgresConfig := adapter.PostgresConfig{
|
||||||
Host: "localhost",
|
Host: "127.0.0.1",
|
||||||
Port: 5433,
|
Port: 5433,
|
||||||
Database: "broker_test",
|
Database: "broker_test",
|
||||||
User: "user",
|
User: "user",
|
||||||
@@ -78,7 +78,7 @@ func TestBrokerWorkflow(t *testing.T) {
|
|||||||
Databases: []config.DatabaseConfig{
|
Databases: []config.DatabaseConfig{
|
||||||
{
|
{
|
||||||
Name: "test_db",
|
Name: "test_db",
|
||||||
Host: "localhost",
|
Host: "127.0.0.1",
|
||||||
Port: 5433,
|
Port: 5433,
|
||||||
Database: "broker_test",
|
Database: "broker_test",
|
||||||
User: "user",
|
User: "user",
|
||||||
|
|||||||
Reference in New Issue
Block a user