ojj

whatsapp-service/pkg/config/config.go

@@ -3,6 +3,7 @@ package config
 import (
 	"database/sql"
 	"fmt"
+	"net"
 	"net/url"
 	"os"
 	"strconv"
@@ -79,7 +80,9 @@ func (c *Config) CreateSupabaseDB() (*sql.DB, error) {
 		return nil, fmt.Errorf("SUPABASE_DB_URL is required for the whatsmeow session store")
 	}
 
-	db, err := sql.Open("postgres", c.SupabaseDBURL)
+	dsn := forceIPv4DSN(c.SupabaseDBURL)
+
+	db, err := sql.Open("postgres", dsn)
 	if err != nil {
 		return nil, err
 	}
@@ -97,6 +100,46 @@ func (c *Config) CreateSupabaseDB() (*sql.DB, error) {
 	return db, nil
 }
 
+// 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
+// ("network is unreachable"). lib/pq dials whatever family the URL names, so
+// pin the address to IPv4 to keep the connection working on IPv6-less hosts.
+func forceIPv4DSN(dsn string) string {
+	if dsn == "" {
+		return dsn
+	}
+	u, err := url.Parse(dsn)
+	if err != nil {
+		return dsn
+	}
+	host := u.Hostname()
+	if host == "" || net.ParseIP(host) != nil {
+		return dsn
+	}
+	port := u.Port()
+	ips, err := net.LookupIP(host)
+	if err != nil {
+		return dsn
+	}
+	var v4 string
+	for _, ip := range ips {
+		if ip4 := ip.To4(); ip4 != nil {
+			v4 = ip4.String()
+			break
+		}
+	}
+	if v4 == "" {
+		return dsn
+	}
+	if port != "" {
+		u.Host = net.JoinHostPort(v4, port)
+	} else {
+		u.Host = v4
+	}
+	return u.String()
+}
+
 func Load() *Config {
 	supabaseURL := os.Getenv(config_env.SUPABASE_URL)
 	supabaseServiceKey := os.Getenv(config_env.SUPABASE_SERVICE_KEY)