mirror of
https://github.com/hanzoai/replicate.git
synced 2026-10-30 18:23:20 +00:00
zeekay
a671dee75a
A version written into a manifest is written into every manifest that wants it, which is how eslint came to exist in a hundred and four forms across this estate and how a package came to resolve twice at run time. The catalog moves the number out of the manifest: a manifest names the package, the workspace names the version. Four are held below their latest because the newer release cannot be used, and the reason is recorded rather than the version alone: @noble/hashes 2 renamed every subpath the web3 stack imports, @splinetool/runtime 2 depends on a package that was never published, @dynamic-labs 5.4.1 the same, and react-resizable-panels 3 points its types condition at the bundle.
122 lines
2.9 KiB
Go
122 lines
2.9 KiB
Go
//go:build integration
|
|
|
|
package integration
|
|
|
|
import (
|
|
"context"
|
|
"path/filepath"
|
|
"testing"
|
|
"time"
|
|
|
|
_ "github.com/hanzoai/sqlite"
|
|
)
|
|
|
|
func TestQuickValidation(t *testing.T) {
|
|
if testing.Short() {
|
|
t.Skip("skipping integration test in short mode")
|
|
}
|
|
|
|
RequireBinaries(t)
|
|
|
|
startTime := time.Now()
|
|
duration := GetTestDuration(t, 30*time.Minute)
|
|
t.Logf("Testing: Quick validation test (duration: %v)", duration)
|
|
t.Log("Default: 30 minutes, configurable via test duration")
|
|
|
|
db := SetupTestDB(t, "quick-validation")
|
|
defer db.Cleanup()
|
|
defer db.PrintTestSummary(t, "Quick Validation Test", startTime)
|
|
|
|
t.Log("[1] Creating and populating database...")
|
|
if err := db.Create(); err != nil {
|
|
t.Fatalf("Failed to create database: %v", err)
|
|
}
|
|
|
|
if err := db.Populate("10MB"); err != nil {
|
|
t.Fatalf("Failed to populate database: %v", err)
|
|
}
|
|
|
|
t.Log("✓ Database populated to 10MB")
|
|
|
|
t.Log("[2] Starting Replicate...")
|
|
if err := db.StartReplicate(); err != nil {
|
|
t.Fatalf("Failed to start Replicate: %v", err)
|
|
}
|
|
|
|
time.Sleep(5 * time.Second)
|
|
|
|
t.Log("[3] Generating wave pattern load...")
|
|
ctx, cancel := context.WithTimeout(context.Background(), duration)
|
|
defer cancel()
|
|
|
|
config := DefaultLoadConfig()
|
|
config.WriteRate = 100
|
|
config.Duration = duration
|
|
config.Pattern = LoadPatternWave
|
|
config.PayloadSize = 4 * 1024
|
|
config.Workers = 4
|
|
|
|
if err := db.GenerateLoad(ctx, config.WriteRate, config.Duration, string(config.Pattern)); err != nil && ctx.Err() == nil {
|
|
t.Fatalf("Load generation failed: %v", err)
|
|
}
|
|
|
|
t.Log("✓ Load generation complete")
|
|
|
|
time.Sleep(10 * time.Second)
|
|
|
|
t.Log("[4] Checking replica status...")
|
|
fileCount, err := db.GetReplicaFileCount()
|
|
if err != nil {
|
|
t.Fatalf("Failed to check replica: %v", err)
|
|
}
|
|
|
|
if fileCount == 0 {
|
|
t.Fatal("No LTX segments created!")
|
|
}
|
|
|
|
t.Logf("✓ LTX segments created: %d files", fileCount)
|
|
|
|
dbSize, err := db.GetDatabaseSize()
|
|
if err != nil {
|
|
t.Fatalf("Failed to get database size: %v", err)
|
|
}
|
|
|
|
t.Logf("Database size: %.2f MB", float64(dbSize)/(1024*1024))
|
|
|
|
t.Log("[5] Checking for errors...")
|
|
errors, err := db.CheckForErrors()
|
|
if err != nil {
|
|
t.Fatalf("Failed to check errors: %v", err)
|
|
}
|
|
|
|
if len(errors) > 10 {
|
|
t.Fatalf("Too many critical errors (%d), showing first 5:\n%v", len(errors), errors[:5])
|
|
} else if len(errors) > 0 {
|
|
t.Logf("Found %d errors (showing first 3):", len(errors))
|
|
for i := 0; i < min(len(errors), 3); i++ {
|
|
t.Logf(" %s", errors[i])
|
|
}
|
|
} else {
|
|
t.Log("✓ No errors detected")
|
|
}
|
|
|
|
db.StopReplicate()
|
|
time.Sleep(2 * time.Second)
|
|
|
|
t.Log("[6] Testing restore...")
|
|
restoredPath := filepath.Join(db.TempDir, "quick-restored.db")
|
|
if err := db.Restore(restoredPath); err != nil {
|
|
t.Fatalf("Restore failed: %v", err)
|
|
}
|
|
|
|
t.Log("✓ Restore successful")
|
|
|
|
t.Log("[7] Validating restoration...")
|
|
if err := db.QuickValidate(restoredPath); err != nil {
|
|
t.Fatalf("Validation failed: %v", err)
|
|
}
|
|
|
|
t.Log("✓ Validation passed")
|
|
t.Log("TEST PASSED: Quick validation successful")
|
|
}
|