invariants_test.go
package db
import (
"testing"
)
// ============================================================================
// Phase 1, Test 1: UniqueFileHash invariant
// Spec: validation.allium - UniqueFileHash
// "for f1 in Files: for f2 in Files: f1 != f2 implies f1.xxh64_hash != f2.xxh64_hash"
// ============================================================================
func TestInvariant_UniqueFileHash(t *testing.T) {
db := SetupTestDB(t)
defer db.Close()
// Setup: create dataset → location → cluster → file
InsertTestDataset(t, db, "ds_test12345", "Test Dataset")
InsertTestLocation(t, db, "loc_test1234", "ds_test12345", "Test Location")
InsertTestCluster(t, db, "clustest1234", "ds_test12345", "loc_test1234", "Test Cluster")
// Insert first file with a specific hash
InsertTestFile(t, db, "filetest1234567890123", "abcd1234efgh5678", "loc_test1234")
// Test: Attempting to insert a second file with the same hash should fail
t.Run("duplicate hash rejected", func(t *testing.T) {
_, err := db.Exec(
`INSERT INTO file (id, file_name, xxh64_hash, location_id, timestamp_local, duration, sample_rate, active)
VALUES ('filetest_diffhash01', 'test2.wav', 'abcd1234efgh5678', 'loc_test1234', CURRENT_TIMESTAMP, 1.0, 48000, true)`,
)
if err == nil {
t.Error("expected error for duplicate xxh64_hash, got nil")
}
})
// Test: Different hash should succeed
t.Run("different hash accepted", func(t *testing.T) {
_, err := db.Exec(
`INSERT INTO file (id, file_name, xxh64_hash, location_id, timestamp_local, duration, sample_rate, active)
VALUES ('filetest_diffhash02', 'test3.wav', '9876zyxw5432vuts', 'loc_test1234', CURRENT_TIMESTAMP, 1.0, 48000, true)`,
)
if err != nil {
t.Errorf("unexpected error for different hash: %v", err)
}
})
// Test: Same hash with inactive file should still fail (constraint applies to all rows)
t.Run("inactive file still blocks duplicate", func(t *testing.T) {
// Mark first file as inactive
_, err := db.Exec("UPDATE file SET active = false WHERE id = 'filetest1234567890123'")
if err != nil {
t.Fatalf("failed to deactivate file: %v", err)
}
// Attempt duplicate hash with new file
_, err = db.Exec(
`INSERT INTO file (id, file_name, xxh64_hash, location_id, timestamp_local, duration, sample_rate, active)
VALUES ('filetest_inactblk01', 'test4.wav', 'abcd1234efgh5678', 'loc_test1234', CURRENT_TIMESTAMP, 1.0, 48000, true)`,
)
if err == nil {
t.Error("expected error for duplicate xxh64_hash even with inactive file, got nil")
}
})
}
// ============================================================================
// Phase 1, Test 2: LocationBelongsToDataset invariant
// ============================================================================
func TestInvariant_LocationBelongsToDataset(t *testing.T) {
db := SetupTestDB(t)
defer db.Close()
InsertTestDataset(t, db, "ds_valid123456", "Valid Dataset")
t.Run("location with valid dataset accepted", func(t *testing.T) {
_, err := db.Exec(
`INSERT INTO location (id, dataset_id, name, latitude, longitude, timezone_id, active)
VALUES ('loc_valid12345', 'ds_valid123456', 'Valid Location', -36.8485, 174.7633, 'Pacific/Auckland', true)`,
)
if err != nil {
t.Errorf("unexpected error: %v", err)
}
})
t.Run("location with nonexistent dataset rejected", func(t *testing.T) {
_, err := db.Exec(
`INSERT INTO location (id, dataset_id, name, latitude, longitude, timezone_id, active)
VALUES ('loc_bad_ds_001', 'ds_nonexistent', 'Bad Location', -36.8485, 174.7633, 'Pacific/Auckland', true)`,
)
if err == nil {
t.Error("expected error for nonexistent dataset_id, got nil")
}
})
t.Run("duplicate location name in same dataset rejected", func(t *testing.T) {
_, err := db.Exec(
`INSERT INTO location (id, dataset_id, name, latitude, longitude, timezone_id, active)
VALUES ('loc_dup_name01', 'ds_valid123456', 'Valid Location', -40.9006, 174.8860, 'Pacific/Auckland', true)`,
)
if err == nil {
t.Error("expected error for duplicate location name in same dataset, got nil")
}
})
t.Run("same location name in different datasets accepted", func(t *testing.T) {
InsertTestDataset(t, db, "ds_second_1234", "Second Dataset")
_, err := db.Exec(
`INSERT INTO location (id, dataset_id, name, latitude, longitude, timezone_id, active)
VALUES ('loc_same_name2', 'ds_second_1234', 'Valid Location', -36.8485, 174.7633, 'Pacific/Auckland', true)`,
)
if err != nil {
t.Errorf("unexpected error for same name in different dataset: %v", err)
}
})
}
// ============================================================================
// Phase 1, Test 3: ClusterBelongsToLocation invariant
// ============================================================================
func TestInvariant_ClusterBelongsToLocation(t *testing.T) {
db := SetupTestDB(t)
defer db.Close()
InsertTestDataset(t, db, "ds_cluster_t01", "Cluster Test Dataset 1")
InsertTestDataset(t, db, "ds_cluster_t02", "Cluster Test Dataset 2")
InsertTestLocation(t, db, "loc_clust_t001", "ds_cluster_t01", "Location in DS1")
InsertTestLocation(t, db, "loc_clust_t002", "ds_cluster_t02", "Location in DS2")
t.Run("cluster with valid location accepted", func(t *testing.T) {
_, err := db.Exec(
`INSERT INTO cluster (id, dataset_id, location_id, name, sample_rate, active)
VALUES ('cl_valid123456', 'ds_cluster_t01', 'loc_clust_t001', 'Valid Cluster', 48000, true)`,
)
if err != nil {
t.Errorf("unexpected error: %v", err)
}
})
t.Run("cluster with nonexistent location rejected", func(t *testing.T) {
_, err := db.Exec(
`INSERT INTO cluster (id, dataset_id, location_id, name, sample_rate, active)
VALUES ('cl_badloc12345', 'ds_cluster_t01', 'loc_nonexistent', 'Bad Location Cluster', 48000, true)`,
)
if err == nil {
t.Error("expected error for nonexistent location_id, got nil")
}
})
t.Run("duplicate cluster name in same location rejected", func(t *testing.T) {
_, err := db.Exec(
`INSERT INTO cluster (id, dataset_id, location_id, name, sample_rate, active)
VALUES ('cl_dup_name_01', 'ds_cluster_t01', 'loc_clust_t001', 'Valid Cluster', 48000, true)`,
)
if err == nil {
t.Error("expected error for duplicate cluster name in same location, got nil")
}
})
t.Run("same cluster name in different locations accepted", func(t *testing.T) {
_, err := db.Exec(
`INSERT INTO cluster (id, dataset_id, location_id, name, sample_rate, active)
VALUES ('cl_same_nam_02', 'ds_cluster_t02', 'loc_clust_t002', 'Valid Cluster', 48000, true)`,
)
if err != nil {
t.Errorf("unexpected error for same name in different location: %v", err)
}
})
}
// ============================================================================
// Cross-invariant: Hierarchical integrity
// ============================================================================
func TestInvariant_HierarchicalIntegrity(t *testing.T) {
db := SetupTestDB(t)
defer db.Close()
InsertTestDataset(t, db, "ds_hier_test01", "Hierarchy Test")
InsertTestLocation(t, db, "loc_hier_test1", "ds_hier_test01", "Hier Location")
InsertTestCluster(t, db, "cl_hier_test01", "ds_hier_test01", "loc_hier_test1", "Hier Cluster")
t.Run("file must have valid location", func(t *testing.T) {
_, err := db.Exec(
`INSERT INTO file (id, file_name, xxh64_hash, location_id, timestamp_local, duration, sample_rate, active)
VALUES ('file_badloc001', 'test.wav', '1111111111111111', 'loc_nonexistent', CURRENT_TIMESTAMP, 1.0, 48000, true)`,
)
if err == nil {
t.Error("expected error for file with invalid location, got nil")
}
})
t.Run("file with valid location but invalid cluster rejected", func(t *testing.T) {
_, err := db.Exec(
`INSERT INTO file (id, file_name, xxh64_hash, location_id, cluster_id, timestamp_local, duration, sample_rate, active)
VALUES ('file_badcl_001', 'test.wav', '2222222222222222', 'loc_hier_test1', 'cl_nonexistent', CURRENT_TIMESTAMP, 1.0, 48000, true)`,
)
if err == nil {
t.Error("expected error for file with invalid cluster, got nil")
}
})
t.Run("valid file through full hierarchy accepted", func(t *testing.T) {
_, err := db.Exec(
`INSERT INTO file (id, file_name, xxh64_hash, location_id, cluster_id, timestamp_local, duration, sample_rate, active)
VALUES ('file_valid0001', 'test.wav', '3333333333333333', 'loc_hier_test1', 'cl_hier_test01', CURRENT_TIMESTAMP, 1.0, 48000, true)`,
)
if err != nil {
t.Errorf("unexpected error: %v", err)
}
})
}