bretton.dev / coves
A community based topic aggregation platform built on atproto
fork atom

test: update existing tests for new consumer constructor

Updates all integration tests to use the new CommunityEventConsumer
constructor signature with instance DID and skip verification flag.

Changes:
- Updated 5 integration test files
- All tests use skipVerification=true to avoid network calls
- Tests use did:web:coves.local as instance DID
- Maintains existing test behavior and coverage

Files Updated:
- community_blocking_test.go
- community_consumer_test.go
- community_e2e_test.go
- community_v2_validation_test.go
- subscription_indexing_test.go

All existing tests continue to pass with no behavior changes.

Co-Authored-By: Claude <noreply@anthropic.com>

bretton.dev 33edf8c4 16667033

options
unified split
Changed files
+20 -10
tests
integration
community_blocking_test.go
community_consumer_test.go
community_e2e_test.go
community_v2_validation_test.go
subscription_indexing_test.go
+2 -1
tests/integration/community_blocking_test.go 
···

       
22

       
 

       
	defer cleanupBlockingTestDB(t, db)


     

       
23

       
 

       



     

       
24

       
 

       
	repo := createBlockingTestCommunityRepo(t, db)


     

       
25

       
-

       
	consumer := jetstream.NewCommunityEventConsumer(repo)


     

       

       

       
     

       
26

       
 

       



     

       
27

       
 

       
	// Create test community


     

       
28

       
 

       
	testDID := fmt.Sprintf("did:plc:test-community-%d", time.Now().UnixNano())


     
···

       
22

       
 

       
	defer cleanupBlockingTestDB(t, db)


     

       
23

       
 

       



     

       
24

       
 

       
	repo := createBlockingTestCommunityRepo(t, db)


     

       
25

       
+

       
	// Skip verification in tests


     

       
26

       
+

       
	consumer := jetstream.NewCommunityEventConsumer(repo, "did:web:coves.local", true)


     

       
27

       
 

       



     

       
28

       
 

       
	// Create test community


     

       
29

       
 

       
	testDID := fmt.Sprintf("did:plc:test-community-%d", time.Now().UnixNano())
+6 -3
tests/integration/community_consumer_test.go 
···

       
19

       
 

       
	}()


     

       
20

       
 

       



     

       
21

       
 

       
	repo := postgres.NewCommunityRepository(db)


     

       
22

       
-

       
	consumer := jetstream.NewCommunityEventConsumer(repo)


     

       

       

       
     

       
23

       
 

       
	ctx := context.Background()


     

       
24

       
 

       



     

       
25

       
 

       
	t.Run("creates community from firehose event", func(t *testing.T) {


     
···

       
215

       
 

       
	}()


     

       
216

       
 

       



     

       
217

       
 

       
	repo := postgres.NewCommunityRepository(db)


     

       
218

       
-

       
	consumer := jetstream.NewCommunityEventConsumer(repo)


     

       

       

       
     

       
219

       
 

       
	ctx := context.Background()


     

       
220

       
 

       



     

       
221

       
 

       
	t.Run("creates subscription from event", func(t *testing.T) {


     
···

       
299

       
 

       
	}()


     

       
300

       
 

       



     

       
301

       
 

       
	repo := postgres.NewCommunityRepository(db)


     

       
302

       
-

       
	consumer := jetstream.NewCommunityEventConsumer(repo)


     

       

       

       
     

       
303

       
 

       
	ctx := context.Background()


     

       
304

       
 

       



     

       
305

       
 

       
	t.Run("ignores identity events", func(t *testing.T) {


     
···

       
19

       
 

       
	}()


     

       
20

       
 

       



     

       
21

       
 

       
	repo := postgres.NewCommunityRepository(db)


     

       
22

       
+

       
	// Skip verification in tests


     

       
23

       
+

       
	consumer := jetstream.NewCommunityEventConsumer(repo, "did:web:coves.local", true)


     

       
24

       
 

       
	ctx := context.Background()


     

       
25

       
 

       



     

       
26

       
 

       
	t.Run("creates community from firehose event", func(t *testing.T) {


     
···

       
216

       
 

       
	}()


     

       
217

       
 

       



     

       
218

       
 

       
	repo := postgres.NewCommunityRepository(db)


     

       
219

       
+

       
	// Skip verification in tests


     

       
220

       
+

       
	consumer := jetstream.NewCommunityEventConsumer(repo, "did:web:coves.local", true)


     

       
221

       
 

       
	ctx := context.Background()


     

       
222

       
 

       



     

       
223

       
 

       
	t.Run("creates subscription from event", func(t *testing.T) {


     
···

       
301

       
 

       
	}()


     

       
302

       
 

       



     

       
303

       
 

       
	repo := postgres.NewCommunityRepository(db)


     

       
304

       
+

       
	// Skip verification in tests


     

       
305

       
+

       
	consumer := jetstream.NewCommunityEventConsumer(repo, "did:web:coves.local", true)


     

       
306

       
 

       
	ctx := context.Background()


     

       
307

       
 

       



     

       
308

       
 

       
	t.Run("ignores identity events", func(t *testing.T) {
+2 -1
tests/integration/community_e2e_test.go 
···

       
142

       
 

       
		svc.SetPDSAccessToken(accessToken)


     

       
143

       
 

       
	}


     

       
144

       
 

       



     

       
145

       
-

       
	consumer := jetstream.NewCommunityEventConsumer(communityRepo)


     

       

       

       
     

       
146

       
 

       



     

       
147

       
 

       
	// Setup HTTP server with XRPC routes


     

       
148

       
 

       
	r := chi.NewRouter()


     
···

       
142

       
 

       
		svc.SetPDSAccessToken(accessToken)


     

       
143

       
 

       
	}


     

       
144

       
 

       



     

       
145

       
+

       
	// Skip verification in tests


     

       
146

       
+

       
	consumer := jetstream.NewCommunityEventConsumer(communityRepo, "did:web:coves.local", true)


     

       
147

       
 

       



     

       
148

       
 

       
	// Setup HTTP server with XRPC routes


     

       
149

       
 

       
	r := chi.NewRouter()
+4 -2
tests/integration/community_v2_validation_test.go 
···

       
19

       
 

       
	}()


     

       
20

       
 

       



     

       
21

       
 

       
	repo := postgres.NewCommunityRepository(db)


     

       
22

       
-

       
	consumer := jetstream.NewCommunityEventConsumer(repo)


     

       

       

       
     

       
23

       
 

       
	ctx := context.Background()


     

       
24

       
 

       



     

       
25

       
 

       
	t.Run("accepts V2 community with rkey=self", func(t *testing.T) {


     
···

       
241

       
 

       
	}()


     

       
242

       
 

       



     

       
243

       
 

       
	repo := postgres.NewCommunityRepository(db)


     

       
244

       
-

       
	consumer := jetstream.NewCommunityEventConsumer(repo)


     

       

       

       
     

       
245

       
 

       
	ctx := context.Background()


     

       
246

       
 

       



     

       
247

       
 

       
	t.Run("indexes community with atProto handle", func(t *testing.T) {


     
···

       
19

       
 

       
	}()


     

       
20

       
 

       



     

       
21

       
 

       
	repo := postgres.NewCommunityRepository(db)


     

       
22

       
+

       
	// Skip verification in tests


     

       
23

       
+

       
	consumer := jetstream.NewCommunityEventConsumer(repo, "did:web:coves.local", true)


     

       
24

       
 

       
	ctx := context.Background()


     

       
25

       
 

       



     

       
26

       
 

       
	t.Run("accepts V2 community with rkey=self", func(t *testing.T) {


     
···

       
242

       
 

       
	}()


     

       
243

       
 

       



     

       
244

       
 

       
	repo := postgres.NewCommunityRepository(db)


     

       
245

       
+

       
	// Skip verification in tests


     

       
246

       
+

       
	consumer := jetstream.NewCommunityEventConsumer(repo, "did:web:coves.local", true)


     

       
247

       
 

       
	ctx := context.Background()


     

       
248

       
 

       



     

       
249

       
 

       
	t.Run("indexes community with atProto handle", func(t *testing.T) {
+6 -3
tests/integration/subscription_indexing_test.go 
···

       
23

       
 

       
	defer cleanupTestDB(t, db)


     

       
24

       
 

       



     

       
25

       
 

       
	repo := createTestCommunityRepo(t, db)


     

       
26

       
-

       
	consumer := jetstream.NewCommunityEventConsumer(repo)


     

       

       

       
     

       
27

       
 

       



     

       
28

       
 

       
	// Create a test community first (with unique DID)


     

       
29

       
 

       
	testDID := fmt.Sprintf("did:plc:test-community-%d", time.Now().UnixNano())


     
···

       
246

       
 

       
	defer cleanupTestDB(t, db)


     

       
247

       
 

       



     

       
248

       
 

       
	repo := createTestCommunityRepo(t, db)


     

       
249

       
-

       
	consumer := jetstream.NewCommunityEventConsumer(repo)


     

       

       

       
     

       
250

       
 

       



     

       
251

       
 

       
	// Create test community (with unique DID)


     

       
252

       
 

       
	testDID := fmt.Sprintf("did:plc:test-unsub-%d", time.Now().UnixNano())


     
···

       
360

       
 

       
	defer cleanupTestDB(t, db)


     

       
361

       
 

       



     

       
362

       
 

       
	repo := createTestCommunityRepo(t, db)


     

       
363

       
-

       
	consumer := jetstream.NewCommunityEventConsumer(repo)


     

       

       

       
     

       
364

       
 

       



     

       
365

       
 

       
	// Create test community (with unique DID)


     

       
366

       
 

       
	testDID := fmt.Sprintf("did:plc:test-subcount-%d", time.Now().UnixNano())


     
···

       
23

       
 

       
	defer cleanupTestDB(t, db)


     

       
24

       
 

       



     

       
25

       
 

       
	repo := createTestCommunityRepo(t, db)


     

       
26

       
+

       
	// Skip verification in tests


     

       
27

       
+

       
	consumer := jetstream.NewCommunityEventConsumer(repo, "did:web:coves.local", true)


     

       
28

       
 

       



     

       
29

       
 

       
	// Create a test community first (with unique DID)


     

       
30

       
 

       
	testDID := fmt.Sprintf("did:plc:test-community-%d", time.Now().UnixNano())


     
···

       
247

       
 

       
	defer cleanupTestDB(t, db)


     

       
248

       
 

       



     

       
249

       
 

       
	repo := createTestCommunityRepo(t, db)


     

       
250

       
+

       
	// Skip verification in tests


     

       
251

       
+

       
	consumer := jetstream.NewCommunityEventConsumer(repo, "did:web:coves.local", true)


     

       
252

       
 

       



     

       
253

       
 

       
	// Create test community (with unique DID)


     

       
254

       
 

       
	testDID := fmt.Sprintf("did:plc:test-unsub-%d", time.Now().UnixNano())


     
···

       
362

       
 

       
	defer cleanupTestDB(t, db)


     

       
363

       
 

       



     

       
364

       
 

       
	repo := createTestCommunityRepo(t, db)


     

       
365

       
+

       
	// Skip verification in tests


     

       
366

       
+

       
	consumer := jetstream.NewCommunityEventConsumer(repo, "did:web:coves.local", true)


     

       
367

       
 

       



     

       
368

       
 

       
	// Create test community (with unique DID)


     

       
369

       
 

       
	testDID := fmt.Sprintf("did:plc:test-subcount-%d", time.Now().UnixNano())