diff --git a/test/integration/extension/counter/suite.go b/test/integration/extension/counter/suite.go index dc4a03c4..f2679fc5 100644 --- a/test/integration/extension/counter/suite.go +++ b/test/integration/extension/counter/suite.go @@ -71,8 +71,6 @@ func (s *CounterContractSuite) TestCounter_Next() { seq3, err := s.counter.Next(ctx, domain) require.NoError(t, err) assert.Equal(t, seq2+1, seq3, "sequence should continue incrementing") - - s.log.Logf("Next test passed: %d ā†’ %d ā†’ %d", seq1, seq2, seq3) } // TestCounter_MultipleDomains tests independent counters @@ -99,9 +97,6 @@ func (s *CounterContractSuite) TestCounter_MultipleDomains() { // Each domain should increment independently assert.Equal(t, seq1a+1, seq1b, "domain1 should increment") assert.Equal(t, seq2a+1, seq2b, "domain2 should increment") - - s.log.Logf("Multiple domains test passed: domain1=%dā†’%d, domain2=%dā†’%d", - seq1a, seq1b, seq2a, seq2b) } // TestCounter_Concurrency tests concurrent access to the same counter @@ -141,7 +136,4 @@ func (s *CounterContractSuite) TestCounter_Concurrency() { assert.Equal(t, sequences[i-1]+1, sequences[i], "sequences should be contiguous at index %d: got %d and %d", i, sequences[i-1], sequences[i]) } - - s.log.Logf("Concurrency test passed: %d goroutines generated %d contiguous sequences (%d-%d)", - numGoroutines, len(sequences), sequences[0], sequences[len(sequences)-1]) } diff --git a/test/integration/stovepipe/extension/storage/suite.go b/test/integration/stovepipe/extension/storage/suite.go index 42965ee9..2af673eb 100644 --- a/test/integration/stovepipe/extension/storage/suite.go +++ b/test/integration/stovepipe/extension/storage/suite.go @@ -70,8 +70,6 @@ func (s *QueueStoreContractSuite) TestQueueStore_Create() { LatestRequestID: "", Version: 1, }, got) - - s.log.Logf("Create passed: created queue %s", name) } // TestQueueStore_CreateWithFields verifies caller-supplied initial field values are persisted. @@ -90,8 +88,6 @@ func (s *QueueStoreContractSuite) TestQueueStore_CreateWithFields() { got, err := s.queueStore.Get(s.ctx, name) require.NoError(t, err) assert.Equal(t, toCreate, got) - - s.log.Logf("CreateWithFields passed: persisted fields for queue %s", name) } // TestQueueStore_CreateAlreadyExists verifies a duplicate Create returns ErrAlreadyExists. @@ -113,8 +109,6 @@ func (s *QueueStoreContractSuite) TestQueueStore_CreateAlreadyExists() { got, err := s.queueStore.Get(s.ctx, name) require.NoError(t, err) assert.Equal(t, first, got) - - s.log.Logf("CreateAlreadyExists passed: queue %s", name) } // TestQueueStore_GetNotFound verifies Get returns ErrNotFound for a missing queue. @@ -123,8 +117,6 @@ func (s *QueueStoreContractSuite) TestQueueStore_GetNotFound() { _, err := s.queueStore.Get(s.ctx, "contract/does-not-exist") assert.True(t, storage.IsNotFound(err)) - - s.log.Logf("GetNotFound passed") } // TestQueueStore_UpdateCAS verifies a conditional update persists all mutable fields and rejects stale versions. @@ -150,8 +142,6 @@ func (s *QueueStoreContractSuite) TestQueueStore_UpdateCAS() { err = s.queueStore.Update(s.ctx, updated, 1, 2) assert.ErrorIs(t, err, storage.ErrVersionMismatch) - - s.log.Logf("UpdateCAS passed: queue %s", name) } // TestQueueStore_UpdateNotFoundIsVersionMismatch verifies Update on a missing row returns ErrVersionMismatch. @@ -160,8 +150,6 @@ func (s *QueueStoreContractSuite) TestQueueStore_UpdateNotFoundIsVersionMismatch err := s.queueStore.Update(s.ctx, entity.Queue{Name: "contract/missing"}, 1, 2) assert.ErrorIs(t, err, storage.ErrVersionMismatch) - - s.log.Logf("UpdateNotFoundIsVersionMismatch passed") } // TestQueueStore_UpdateSequentialCAS verifies successive conditional updates advance version monotonically. @@ -182,8 +170,6 @@ func (s *QueueStoreContractSuite) TestQueueStore_UpdateSequentialCAS() { assert.Equal(t, "request/contract/sequential-cas/10", got.LatestRequestID) assert.Equal(t, int32(1), got.InFlightCount) assert.Equal(t, int32(3), got.Version) - - s.log.Logf("UpdateSequentialCAS passed: queue %s", name) } // BuildStoreContractSuite defines contract tests for storage.BuildStore. @@ -392,6 +378,4 @@ func (s *QueueStoreContractSuite) TestQueueStore_QueueIsolation() { gotB, err := s.queueStore.Get(s.ctx, nameB) require.NoError(t, err) assert.Equal(t, baseline, gotB) - - s.log.Logf("QueueIsolation passed: queues %s and %s", nameA, nameB) } diff --git a/test/integration/submitqueue/extension/storage/suite.go b/test/integration/submitqueue/extension/storage/suite.go index dd4d0b03..8f9df7e7 100644 --- a/test/integration/submitqueue/extension/storage/suite.go +++ b/test/integration/submitqueue/extension/storage/suite.go @@ -84,8 +84,6 @@ func (s *StorageContractSuite) TestStorage_CreateAndGet() { assert.Equal(t, request.Change.URIs, retrieved.Change.URIs) assert.Equal(t, request.LandStrategy, retrieved.LandStrategy) assert.Equal(t, request.Version, retrieved.Version) - - s.log.Logf("CreateAndGet test passed: created and retrieved request %s", request.ID) } // TestStorage_CreateAndGet_StackedPRs tests creating and retrieving a request with stacked PRs @@ -124,8 +122,6 @@ func (s *StorageContractSuite) TestStorage_CreateAndGet_StackedPRs() { assert.Equal(t, stackedURIs, retrieved.Change.URIs, "stacked PR URIs should be preserved exactly") assert.Equal(t, request.ID, retrieved.ID) assert.Equal(t, request.LandStrategy, retrieved.LandStrategy) - - s.log.Logf("CreateAndGet_StackedPRs test passed: %d stacked URIs", len(stackedURIs)) } // TestStorage_UpdateState tests updating request state @@ -154,8 +150,6 @@ func (s *StorageContractSuite) TestStorage_UpdateState() { require.NoError(t, err) assert.Equal(t, entity.RequestStateProcessing, retrieved.State) assert.Equal(t, int32(2), retrieved.Version, "version should increment after update") - - s.log.Logf("UpdateState test passed: updated request %s to state %s", request.ID, retrieved.State) } // TestStorage_OptimisticLocking tests version-based optimistic locking @@ -189,8 +183,6 @@ func (s *StorageContractSuite) TestStorage_OptimisticLocking() { require.NoError(t, err) assert.Equal(t, entity.RequestStateProcessing, retrieved.State, "stale update should not modify state") assert.Equal(t, int32(2), retrieved.Version) - - s.log.Logf("Optimistic locking test passed: prevented stale update for request %s", request.ID) } // TestStorage_NotFound tests getting a non-existent request @@ -202,8 +194,6 @@ func (s *StorageContractSuite) TestStorage_NotFound() { _, err := s.storage.GetRequestStore().Get(ctx, "test/nonexistent") assert.Error(t, err, "getting non-existent request should return error") assert.ErrorIs(t, err, storage.ErrNotFound, "should return ErrNotFound") - - s.log.Logf("NotFound test passed: correctly returned ErrNotFound") } // TestStorage_CreateDuplicate tests creating a request with duplicate ID @@ -227,8 +217,6 @@ func (s *StorageContractSuite) TestStorage_CreateDuplicate() { err = s.storage.GetRequestStore().Create(ctx, request) assert.Error(t, err, "creating duplicate request should return error") assert.ErrorIs(t, err, storage.ErrAlreadyExists, "should return ErrAlreadyExists") - - s.log.Logf("CreateDuplicate test passed: prevented duplicate creation") } // changeURI is a representative change URI reused across change-store contract tests. diff --git a/test/integration/submitqueue/gateway/suite_test.go b/test/integration/submitqueue/gateway/suite_test.go index ba3059fc..a49e39c1 100644 --- a/test/integration/submitqueue/gateway/suite_test.go +++ b/test/integration/submitqueue/gateway/suite_test.go @@ -140,8 +140,6 @@ func (s *GatewayIntegrationSuite) TestPingAPI() { assert.Equal(t, "gateway", resp.ServiceName) assert.NotEmpty(t, resp.Message) assert.NotZero(t, resp.Timestamp) - - s.log.Logf("Gateway Ping test passed: %s", resp.Message) } // TestLandAPI tests the Gateway Land API with queue publishing @@ -166,8 +164,6 @@ func (s *GatewayIntegrationSuite) TestLandAPI() { err = s.queueDB.QueryRow("SELECT COUNT(*) FROM queue_messages WHERE id = ?", resp.Sqid).Scan(&msgCount) require.NoError(t, err, "failed to query queue messages") assert.Equal(t, 1, msgCount, "should have 1 message in queue") - - s.log.Logf("Land API test passed: request stored and message published") } // TestListAPI verifies the queue projection is exposed in deterministic receipt order. diff --git a/test/integration/submitqueue/orchestrator/suite_test.go b/test/integration/submitqueue/orchestrator/suite_test.go index 24fe9148..2d84ecf5 100644 --- a/test/integration/submitqueue/orchestrator/suite_test.go +++ b/test/integration/submitqueue/orchestrator/suite_test.go @@ -114,6 +114,4 @@ func (s *OrchestratorIntegrationSuite) TestPingAPI() { assert.Equal(t, "orchestrator", resp.ServiceName) assert.NotEmpty(t, resp.Message) assert.NotZero(t, resp.Timestamp) - - s.log.Logf("Orchestrator Ping test passed: %s", resp.Message) }