Function TestResolveEffectiveConfigInvalidQueryLogEnvValues

main_test.go:301–340

(t *testing.T)

		t.Fatal("expected CLI --ducklake-delta-catalog-enabled to override env")
	}
	if got, want := resolved.Server.DuckLake.DeltaCatalogPath, "s3://warehouse/cli-delta/"; got != want {
		t.Fatalf("expected CLI Delta catalog path %q, got %q", want, got)
	}
}

func TestResolveEffectiveConfigInvalidQueryLogEnvValues(t *testing.T) {
	env := map[string]string{
		"DUCKGRES_QUERY_LOG_FLUSH_INTERVAL": "0s",
		"DUCKGRES_QUERY_LOG_BATCH_SIZE":     "-1",
	}

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

	if resolved.Server.QueryLog.FlushInterval != 5*time.Second {
		t.Fatalf("expected default flush_interval 5s, got %s", resolved.Server.QueryLog.FlushInterval)
	}
	if resolved.Server.QueryLog.BatchSize != 1000 {
		t.Fatalf("expected default batch_size 1000, got %d", resolved.Server.QueryLog.BatchSize)
	}
	wantWarnings := []string{
		"DUCKGRES_QUERY_LOG_FLUSH_INTERVAL must be > 0",
		"DUCKGRES_QUERY_LOG_BATCH_SIZE must be > 0",
	}
	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)
		}
	}
}

func TestResolveEffectiveConfigQueryLogCLIOverride(t *testing.T) {
	fileCfg := &FileConfig{}