Function TestResolveEffectiveConfigInvalidEnvValues

main_test.go:122–176

(t *testing.T)

func TestResolveEffectiveConfigWorkerQueueTimeoutDefault(t *testing.T) {
	resolved := configresolve.ResolveEffective(nil, configresolve.CLIInputs{}, envFromMap(nil), nil)
	if resolved.WorkerQueueTimeout != 60*time.Second {
		t.Fatalf("expected worker queue timeout default 60s, got %s", resolved.WorkerQueueTimeout)
	}
}

func TestResolveEffectiveConfigInvalidEnvValues(t *testing.T) {
	enabled := true
	fileCfg := &FileConfig{
		ProcessIsolation: true,
		IdleTimeout:      "45m",
		DuckLake: DuckLakeFileConfig{
			S3UseSSL:                        true,
			DisableMetadataThreadLocalCache: &enabled,
		},
	}

	env := map[string]string{
		"DUCKGRES_PROCESS_ISOLATION":                            "not-a-bool",
		"DUCKGRES_DUCKLAKE_S3_USE_SSL":                          "not-a-bool",
		"DUCKGRES_DUCKLAKE_DISABLE_METADATA_THREAD_LOCAL_CACHE": "not-a-bool",
		"DUCKGRES_IDLE_TIMEOUT":                                 "bad-duration",
	}

	var warns []string
	resolved := configresolve.ResolveEffective(fileCfg, configresolve.CLIInputs{}, envFromMap(env), func(msg string) {
		warns = append(warns, msg)
	})

	if !resolved.Server.ProcessIsolation {
		t.Fatalf("invalid env process isolation should not override valid file value")
	}
	if !resolved.Server.DuckLake.S3UseSSL {
		t.Fatalf("invalid env S3_USE_SSL should not override valid file value")
	}
	if resolved.Server.DuckLake.DisableMetadataThreadLocalCache == nil || !*resolved.Server.DuckLake.DisableMetadataThreadLocalCache {
		t.Fatalf("invalid env disable_metadata_thread_local_cache should not override valid file value")
	}
	if resolved.Server.IdleTimeout != 45*time.Minute {
		t.Fatalf("invalid env idle timeout should not override valid file value, got %s", resolved.Server.IdleTimeout)
	}

	wantWarnings := []string{
		"Invalid DUCKGRES_PROCESS_ISOLATION",
		"Invalid DUCKGRES_DUCKLAKE_S3_USE_SSL",
		"Invalid DUCKGRES_DUCKLAKE_DISABLE_METADATA_THREAD_LOCAL_CACHE",
		"Invalid DUCKGRES_IDLE_TIMEOUT duration",
	}
	for _, w := range wantWarnings {
		found := false
		for _, got := range warns {
			if strings.Contains(got, w) {
				found = true
				break
			}
		}
		if !found {
			t.Fatalf("expected warning containing %q, warnings: %v", w, warns)
		}