ok

whatsapp-service/pkg/config/config.go

@@ -1,6 +1,7 @@
 package config
 
 import (
+	"context"
 	"database/sql"
 	"fmt"
 	"net"
@@ -80,7 +81,11 @@ func (c *Config) CreateSupabaseDB() (*sql.DB, error) {
 		return nil, fmt.Errorf("SUPABASE_DB_URL is required for the whatsmeow session store")
 	}
 
+	// Force IPv4 and enforce a dial timeout so a silent network hang (e.g. an
+	// IPv6-only host, a blackholed route) fails fast with a clear error instead
+	// of blocking startup indefinitely.
 	dsn := forceIPv4DSN(c.SupabaseDBURL)
+	dsn = withConnectTimeout(dsn, 10)
 
 	db, err := sql.Open("postgres", dsn)
 	if err != nil {
@@ -92,7 +97,9 @@ func (c *Config) CreateSupabaseDB() (*sql.DB, error) {
 	db.SetConnMaxLifetime(5 * time.Minute)
 	db.SetConnMaxIdleTime(1 * time.Minute)
 
-	if err := db.Ping(); err != nil {
+	ctx, cancel := context.WithTimeout(context.Background(), 15*time.Second)
+	defer cancel()
+	if err := db.PingContext(ctx); err != nil {
 		return nil, fmt.Errorf("failed to ping Supabase Postgres (SUPABASE_DB_URL): %v", err)
 	}
 
@@ -100,6 +107,24 @@ func (c *Config) CreateSupabaseDB() (*sql.DB, error) {
 	return db, nil
 }
 
+// withConnectTimeout appends (or updates) lib/pq's connect_timeout parameter.
+func withConnectTimeout(dsn string, seconds int) string {
+	q := url.Values{}
+	if u, err := url.Parse(dsn); err == nil {
+		for k, vs := range u.Query() {
+			for _, v := range vs {
+				q.Add(k, v)
+			}
+		}
+	}
+	q.Set("connect_timeout", strconv.Itoa(seconds))
+	if u, err := url.Parse(dsn); err == nil {
+		u.RawQuery = q.Encode()
+		return u.String()
+	}
+	return dsn
+}
+
 // forceIPv4DSN rewrites the DSN host to its resolved IPv4 address. Container
 // runtimes (HF Spaces, many CI/cloud networks) frequently have no IPv6 route;
 // a hostname whose DNS returns only an AAAA record first then fails to connect