Gabriel Radureau
93bd384ca8
Reverts PR #26 (BDD_SCHEMA_ISOLATION caused empty schemas with no tables, 500 errors). Adds sequential package execution (-p 1) + cache flush AfterScenario. AuthBDD goes from 0/5 PASS to 5/5 PASS deterministically. Parallel BDD deferred as architectural follow-up (requires per-schema migrations + dedicated connection pools). Co-authored-by: Gabriel Radureau <arcodange@gmail.com> Co-committed-by: Gabriel Radureau <arcodange@gmail.com>
92 lines
2.6 KiB
Go
92 lines
2.6 KiB
Go
package testserver
|
|
|
|
import (
|
|
"fmt"
|
|
"os"
|
|
"path/filepath"
|
|
"time"
|
|
)
|
|
|
|
// TraceStateScenarioStart logs the start of a scenario
|
|
func TraceStateScenarioStart(feature, scenario string) {
|
|
writeTraceLine(feature, scenario, "SCENARIO_START", "")
|
|
}
|
|
|
|
// TraceStateScenarioEnd logs the end of a scenario
|
|
func TraceStateScenarioEnd(feature, scenario string, err error) {
|
|
status := "PASSED"
|
|
if err != nil {
|
|
status = fmt.Sprintf("FAILED: %v", err)
|
|
}
|
|
writeTraceLine(feature, scenario, "SCENARIO_END", status)
|
|
}
|
|
|
|
// TraceStateDBCleanup logs a database cleanup operation
|
|
func TraceStateDBCleanup(feature, scenario, table string) {
|
|
writeTraceLine(feature, scenario, "DB_CLEANUP", table)
|
|
}
|
|
|
|
// TraceStateJWTSecretOperation logs a JWT secret operation
|
|
func TraceStateJWTSecretOperation(feature, scenario, operation, details string) {
|
|
writeTraceLine(feature, scenario, "JWT_"+operation, details)
|
|
}
|
|
|
|
// TraceStateCacheOperation logs a cache operation
|
|
func TraceStateCacheOperation(feature, scenario, operation, details string) {
|
|
writeTraceLine(feature, scenario, "CACHE_"+operation, details)
|
|
}
|
|
|
|
// TraceStateSchemaIsolation logs a schema isolation operation
|
|
func TraceStateSchemaIsolation(feature, scenario, operation, details string) {
|
|
writeTraceLine(feature, scenario, "SCHEMA_"+operation, details)
|
|
}
|
|
|
|
// TraceStateTransaction logs a transaction boundary
|
|
func TraceStateTransaction(feature, scenario, action, details string) {
|
|
writeTraceLine(feature, scenario, "TX_"+action, details)
|
|
}
|
|
|
|
// TraceStateDBRead logs a database read operation
|
|
func TraceStateDBRead(feature, scenario, table, details string) {
|
|
writeTraceLine(feature, scenario, "DB_SELECT", fmt.Sprintf("table=%s %s", table, details))
|
|
}
|
|
|
|
// StateTracingEnabled returns true if BDD_TRACE_STATE environment variable is set to "1"
|
|
func StateTracingEnabled() bool {
|
|
return os.Getenv("BDD_TRACE_STATE") == "1"
|
|
}
|
|
|
|
// writeTraceLine writes a trace line to the state trace file in $TMPDIR
|
|
func writeTraceLine(feature, scenario, action, details string) {
|
|
if !StateTracingEnabled() {
|
|
return
|
|
}
|
|
tmpDir := os.Getenv("TMPDIR")
|
|
if tmpDir == "" {
|
|
tmpDir = "/tmp"
|
|
}
|
|
timestamp := time.Now().Format("20060102-150405")
|
|
pid := os.Getpid()
|
|
filename := fmt.Sprintf("bdd-state-trace-%s-%d.log", timestamp, pid)
|
|
filePath := filepath.Join(tmpDir, filename)
|
|
|
|
line := fmt.Sprintf("%s | %-15s | %-40s | %-16s | %s\n",
|
|
time.Now().Format("2006-01-02T15:04:05.000000"),
|
|
feature,
|
|
scenario,
|
|
action,
|
|
details,
|
|
)
|
|
|
|
file, err := os.OpenFile(filePath, os.O_CREATE|os.O_APPEND|os.O_WRONLY, 0644)
|
|
if err != nil {
|
|
return
|
|
}
|
|
defer file.Close()
|
|
|
|
if _, err := file.WriteString(line); err != nil {
|
|
return
|
|
}
|
|
file.Sync()
|
|
}
|