···

       
145
       
 
       
	if err != nil {

     

       
146
       
 
       
		return nil, fmt.Errorf("failed to get aggregators: %w", err)

     

       
147
       
 
       
	}

     

       
148
       
-
       
	defer rows.Close()

     

       
149
       
 
       


     

       
150
       
 
       
	var results []*aggregators.Aggregator

     

       
151
       
 
       
	for rows.Next() {

     
···

       
279
       
 
       
	if err != nil {

     

       
280
       
 
       
		return nil, fmt.Errorf("failed to list aggregators: %w", err)

     

       
281
       
 
       
	}

     

       
282
       
-
       
	defer rows.Close()

     

       
283
       
 
       


     

       
284
       
 
       
	var aggs []*aggregators.Aggregator

     

       
285
       
 
       
	for rows.Next() {

     
···

       
632
       
 
       
	if err != nil {

     

       
633
       
 
       
		return nil, fmt.Errorf("failed to list authorizations for aggregator: %w", err)

     

       
634
       
 
       
	}

     

       
635
       
-
       
	defer rows.Close()

     

       
636
       
 
       


     

       
637
       
 
       
	return scanAuthorizations(rows)

     

       
638
       
 
       
}

     
···

       
662
       
 
       
	if err != nil {

     

       
663
       
 
       
		return nil, fmt.Errorf("failed to list authorizations for community: %w", err)

     

       
664
       
 
       
	}

     

       
665
       
-
       
	defer rows.Close()

     

       
666
       
 
       


     

       
667
       
 
       
	return scanAuthorizations(rows)

     

       
668
       
 
       
}

     
···

       
730
       
 
       
	if err != nil {

     

       
731
       
 
       
		return nil, fmt.Errorf("failed to get recent posts: %w", err)

     

       
732
       
 
       
	}

     

       
733
       
-
       
	defer rows.Close()

     

       
734
       
 
       


     

       
735
       
 
       
	var posts []*aggregators.AggregatorPost

     

       
736
       
 
       
	for rows.Next() {

     

···

       
145
       
 
       
	if err != nil {

     

       
146
       
 
       
		return nil, fmt.Errorf("failed to get aggregators: %w", err)

     

       
147
       
 
       
	}

     

       
148
       
+
       
	defer func() { _ = rows.Close() }()

     

       
149
       
 
       


     

       
150
       
 
       
	var results []*aggregators.Aggregator

     

       
151
       
 
       
	for rows.Next() {

     
···

       
279
       
 
       
	if err != nil {

     

       
280
       
 
       
		return nil, fmt.Errorf("failed to list aggregators: %w", err)

     

       
281
       
 
       
	}

     

       
282
       
+
       
	defer func() { _ = rows.Close() }()

     

       
283
       
 
       


     

       
284
       
 
       
	var aggs []*aggregators.Aggregator

     

       
285
       
 
       
	for rows.Next() {

     
···

       
632
       
 
       
	if err != nil {

     

       
633
       
 
       
		return nil, fmt.Errorf("failed to list authorizations for aggregator: %w", err)

     

       
634
       
 
       
	}

     

       
635
       
+
       
	defer func() { _ = rows.Close() }()

     

       
636
       
 
       


     

       
637
       
 
       
	return scanAuthorizations(rows)

     

       
638
       
 
       
}

     
···

       
662
       
 
       
	if err != nil {

     

       
663
       
 
       
		return nil, fmt.Errorf("failed to list authorizations for community: %w", err)

     

       
664
       
 
       
	}

     

       
665
       
+
       
	defer func() { _ = rows.Close() }()

     

       
666
       
 
       


     

       
667
       
 
       
	return scanAuthorizations(rows)

     

       
668
       
 
       
}

     
···

       
730
       
 
       
	if err != nil {

     

       
731
       
 
       
		return nil, fmt.Errorf("failed to get recent posts: %w", err)

     

       
732
       
 
       
	}

     

       
733
       
+
       
	defer func() { _ = rows.Close() }()

     

       
734
       
 
       


     

       
735
       
 
       
	var posts []*aggregators.AggregatorPost

     

       
736
       
 
       
	for rows.Next() {

     

···

       
96
       
 
       


     

       
97
       
 
       
// GetByVoterAndSubject retrieves a user's vote on a specific subject

     

       
98
       
 
       
// Used by service to check existing vote state before creating/toggling

     

       
99
       
-
       
func (r *postgresVoteRepo) GetByVoterAndSubject(ctx context.Context, voterDID string, subjectURI string) (*votes.Vote, error) {

     

       
100
       
 
       
	query := `

     

       
101
       
 
       
		SELECT

     

       
102
       
 
       
			id, uri, cid, rkey, voter_did,

     
···

       
170
       
 
       
	if err != nil {

     

       
171
       
 
       
		return nil, fmt.Errorf("failed to list votes by subject: %w", err)

     

       
172
       
 
       
	}

     

       
173
       
-
       
	defer rows.Close()

     

       
174
       
 
       


     

       
175
       
 
       
	var result []*votes.Vote

     

       
176
       
 
       
	for rows.Next() {

     
···

       
211
       
 
       
	if err != nil {

     

       
212
       
 
       
		return nil, fmt.Errorf("failed to list votes by voter: %w", err)

     

       
213
       
 
       
	}

     

       
214
       
-
       
	defer rows.Close()

     

       
215
       
 
       


     

       
216
       
 
       
	var result []*votes.Vote

     

       
217
       
 
       
	for rows.Next() {

     

···

       
96
       
 
       


     

       
97
       
 
       
// GetByVoterAndSubject retrieves a user's vote on a specific subject

     

       
98
       
 
       
// Used by service to check existing vote state before creating/toggling

     

       
99
       
+
       
func (r *postgresVoteRepo) GetByVoterAndSubject(ctx context.Context, voterDID, subjectURI string) (*votes.Vote, error) {

     

       
100
       
 
       
	query := `

     

       
101
       
 
       
		SELECT

     

       
102
       
 
       
			id, uri, cid, rkey, voter_did,

     
···

       
170
       
 
       
	if err != nil {

     

       
171
       
 
       
		return nil, fmt.Errorf("failed to list votes by subject: %w", err)

     

       
172
       
 
       
	}

     

       
173
       
+
       
	defer func() { _ = rows.Close() }()

     

       
174
       
 
       


     

       
175
       
 
       
	var result []*votes.Vote

     

       
176
       
 
       
	for rows.Next() {

     
···

       
211
       
 
       
	if err != nil {

     

       
212
       
 
       
		return nil, fmt.Errorf("failed to list votes by voter: %w", err)

     

       
213
       
 
       
	}

     

       
214
       
+
       
	defer func() { _ = rows.Close() }()

     

       
215
       
 
       


     

       
216
       
 
       
	var result []*votes.Vote

     

       
217
       
 
       
	for rows.Next() {

     

···

       
52
       
 
       


     

       
53
       
 
       
func TestVoteRepo_Create(t *testing.T) {

     

       
54
       
 
       
	db := setupTestDB(t)

     

       
55
       
-
       
	defer db.Close()

     

       
56
       
 
       
	defer cleanupVotes(t, db)

     

       
57
       
 
       


     

       
58
       
 
       
	repo := NewVoteRepository(db)

     
···

       
81
       
 
       


     

       
82
       
 
       
func TestVoteRepo_Create_Idempotent(t *testing.T) {

     

       
83
       
 
       
	db := setupTestDB(t)

     

       
84
       
-
       
	defer db.Close()

     

       
85
       
 
       
	defer cleanupVotes(t, db)

     

       
86
       
 
       


     

       
87
       
 
       
	repo := NewVoteRepository(db)

     
···

       
123
       
 
       


     

       
124
       
 
       
func TestVoteRepo_Create_VoterNotFound(t *testing.T) {

     

       
125
       
 
       
	db := setupTestDB(t)

     

       
126
       
-
       
	defer db.Close()

     

       
127
       
 
       
	defer cleanupVotes(t, db)

     

       
128
       
 
       


     

       
129
       
 
       
	repo := NewVoteRepository(db)

     
···

       
153
       
 
       


     

       
154
       
 
       
func TestVoteRepo_GetByURI(t *testing.T) {

     

       
155
       
 
       
	db := setupTestDB(t)

     

       
156
       
-
       
	defer db.Close()

     

       
157
       
 
       
	defer cleanupVotes(t, db)

     

       
158
       
 
       


     

       
159
       
 
       
	repo := NewVoteRepository(db)

     
···

       
187
       
 
       


     

       
188
       
 
       
func TestVoteRepo_GetByURI_NotFound(t *testing.T) {

     

       
189
       
 
       
	db := setupTestDB(t)

     

       
190
       
-
       
	defer db.Close()

     

       
191
       
 
       


     

       
192
       
 
       
	repo := NewVoteRepository(db)

     

       
193
       
 
       
	ctx := context.Background()

     
···

       
198
       
 
       


     

       
199
       
 
       
func TestVoteRepo_GetByVoterAndSubject(t *testing.T) {

     

       
200
       
 
       
	db := setupTestDB(t)

     

       
201
       
-
       
	defer db.Close()

     

       
202
       
 
       
	defer cleanupVotes(t, db)

     

       
203
       
 
       


     

       
204
       
 
       
	repo := NewVoteRepository(db)

     
···

       
233
       
 
       


     

       
234
       
 
       
func TestVoteRepo_GetByVoterAndSubject_NotFound(t *testing.T) {

     

       
235
       
 
       
	db := setupTestDB(t)

     

       
236
       
-
       
	defer db.Close()

     

       
237
       
 
       


     

       
238
       
 
       
	repo := NewVoteRepository(db)

     

       
239
       
 
       
	ctx := context.Background()

     
···

       
244
       
 
       


     

       
245
       
 
       
func TestVoteRepo_Delete(t *testing.T) {

     

       
246
       
 
       
	db := setupTestDB(t)

     

       
247
       
-
       
	defer db.Close()

     

       
248
       
 
       
	defer cleanupVotes(t, db)

     

       
249
       
 
       


     

       
250
       
 
       
	repo := NewVoteRepository(db)

     
···

       
283
       
 
       


     

       
284
       
 
       
func TestVoteRepo_Delete_Idempotent(t *testing.T) {

     

       
285
       
 
       
	db := setupTestDB(t)

     

       
286
       
-
       
	defer db.Close()

     

       
287
       
 
       
	defer cleanupVotes(t, db)

     

       
288
       
 
       


     

       
289
       
 
       
	repo := NewVoteRepository(db)

     
···

       
316
       
 
       


     

       
317
       
 
       
func TestVoteRepo_ListBySubject(t *testing.T) {

     

       
318
       
 
       
	db := setupTestDB(t)

     

       
319
       
-
       
	defer db.Close()

     

       
320
       
 
       
	defer cleanupVotes(t, db)

     

       
321
       
 
       


     

       
322
       
 
       
	repo := NewVoteRepository(db)

     
···

       
362
       
 
       


     

       
363
       
 
       
func TestVoteRepo_ListByVoter(t *testing.T) {

     

       
364
       
 
       
	db := setupTestDB(t)

     

       
365
       
-
       
	defer db.Close()

     

       
366
       
 
       
	defer cleanupVotes(t, db)

     

       
367
       
 
       


     

       
368
       
 
       
	repo := NewVoteRepository(db)

     

···

       
52
       
 
       


     

       
53
       
 
       
func TestVoteRepo_Create(t *testing.T) {

     

       
54
       
 
       
	db := setupTestDB(t)

     

       
55
       
+
       
	defer func() { _ = db.Close() }()

     

       
56
       
 
       
	defer cleanupVotes(t, db)

     

       
57
       
 
       


     

       
58
       
 
       
	repo := NewVoteRepository(db)

     
···

       
81
       
 
       


     

       
82
       
 
       
func TestVoteRepo_Create_Idempotent(t *testing.T) {

     

       
83
       
 
       
	db := setupTestDB(t)

     

       
84
       
+
       
	defer func() { _ = db.Close() }()

     

       
85
       
 
       
	defer cleanupVotes(t, db)

     

       
86
       
 
       


     

       
87
       
 
       
	repo := NewVoteRepository(db)

     
···

       
123
       
 
       


     

       
124
       
 
       
func TestVoteRepo_Create_VoterNotFound(t *testing.T) {

     

       
125
       
 
       
	db := setupTestDB(t)

     

       
126
       
+
       
	defer func() { _ = db.Close() }()

     

       
127
       
 
       
	defer cleanupVotes(t, db)

     

       
128
       
 
       


     

       
129
       
 
       
	repo := NewVoteRepository(db)

     
···

       
153
       
 
       


     

       
154
       
 
       
func TestVoteRepo_GetByURI(t *testing.T) {

     

       
155
       
 
       
	db := setupTestDB(t)

     

       
156
       
+
       
	defer func() { _ = db.Close() }()

     

       
157
       
 
       
	defer cleanupVotes(t, db)

     

       
158
       
 
       


     

       
159
       
 
       
	repo := NewVoteRepository(db)

     
···

       
187
       
 
       


     

       
188
       
 
       
func TestVoteRepo_GetByURI_NotFound(t *testing.T) {

     

       
189
       
 
       
	db := setupTestDB(t)

     

       
190
       
+
       
	defer func() { _ = db.Close() }()

     

       
191
       
 
       


     

       
192
       
 
       
	repo := NewVoteRepository(db)

     

       
193
       
 
       
	ctx := context.Background()

     
···

       
198
       
 
       


     

       
199
       
 
       
func TestVoteRepo_GetByVoterAndSubject(t *testing.T) {

     

       
200
       
 
       
	db := setupTestDB(t)

     

       
201
       
+
       
	defer func() { _ = db.Close() }()

     

       
202
       
 
       
	defer cleanupVotes(t, db)

     

       
203
       
 
       


     

       
204
       
 
       
	repo := NewVoteRepository(db)

     
···

       
233
       
 
       


     

       
234
       
 
       
func TestVoteRepo_GetByVoterAndSubject_NotFound(t *testing.T) {

     

       
235
       
 
       
	db := setupTestDB(t)

     

       
236
       
+
       
	defer func() { _ = db.Close() }()

     

       
237
       
 
       


     

       
238
       
 
       
	repo := NewVoteRepository(db)

     

       
239
       
 
       
	ctx := context.Background()

     
···

       
244
       
 
       


     

       
245
       
 
       
func TestVoteRepo_Delete(t *testing.T) {

     

       
246
       
 
       
	db := setupTestDB(t)

     

       
247
       
+
       
	defer func() { _ = db.Close() }()

     

       
248
       
 
       
	defer cleanupVotes(t, db)

     

       
249
       
 
       


     

       
250
       
 
       
	repo := NewVoteRepository(db)

     
···

       
283
       
 
       


     

       
284
       
 
       
func TestVoteRepo_Delete_Idempotent(t *testing.T) {

     

       
285
       
 
       
	db := setupTestDB(t)

     

       
286
       
+
       
	defer func() { _ = db.Close() }()

     

       
287
       
 
       
	defer cleanupVotes(t, db)

     

       
288
       
 
       


     

       
289
       
 
       
	repo := NewVoteRepository(db)

     
···

       
316
       
 
       


     

       
317
       
 
       
func TestVoteRepo_ListBySubject(t *testing.T) {

     

       
318
       
 
       
	db := setupTestDB(t)

     

       
319
       
+
       
	defer func() { _ = db.Close() }()

     

       
320
       
 
       
	defer cleanupVotes(t, db)

     

       
321
       
 
       


     

       
322
       
 
       
	repo := NewVoteRepository(db)

     
···

       
362
       
 
       


     

       
363
       
 
       
func TestVoteRepo_ListByVoter(t *testing.T) {

     

       
364
       
 
       
	db := setupTestDB(t)

     

       
365
       
+
       
	defer func() { _ = db.Close() }()

     

       
366
       
 
       
	defer cleanupVotes(t, db)

     

       
367
       
 
       


     

       
368
       
 
       
	repo := NewVoteRepository(db)

     

···

       
50
       
 
       
		t.Skipf("PDS not available at %s - run 'make dev-up' to start it", pdsURL)

     

       
51
       
 
       
	}

     

       
52
       
 
       
	if resp != nil {

     

       
53
       
-
       
		resp.Body.Close()

     

       
54
       
 
       
	}

     

       
55
       
 
       
	db := setupTestDB(t)

     

       
56
       
 
       
	defer func() {

     
···

       
513
       
 
       
			// Views is []interface{}, unmarshal to check fields

     

       
514
       
 
       
			viewJSON, _ := json.Marshal(response.Views[0])

     

       
515
       
 
       
			var view aggregator.AggregatorView

     

       
516
       
-
       
			json.Unmarshal(viewJSON, &view)

     

       
517
       
 
       


     

       
518
       
 
       
			assert.Equal(t, aggregatorDID, view.DID)

     

       
519
       
 
       
			assert.Equal(t, "RSS Feed Aggregator", view.DisplayName)

     
···

       
544
       
 
       


     

       
545
       
 
       
			viewJSON, _ := json.Marshal(response.Views[0])

     

       
546
       
 
       
			var detailedView aggregator.AggregatorViewDetailed

     

       
547
       
-
       
			json.Unmarshal(viewJSON, &detailedView)

     

       
548
       
 
       


     

       
549
       
 
       
			assert.Equal(t, aggregatorDID, detailedView.DID)

     

       
550
       
 
       
			assert.Equal(t, 1, detailedView.Stats.CommunitiesUsing)

     

···

       
50
       
 
       
		t.Skipf("PDS not available at %s - run 'make dev-up' to start it", pdsURL)

     

       
51
       
 
       
	}

     

       
52
       
 
       
	if resp != nil {

     

       
53
       
+
       
		_ = resp.Body.Close()

     

       
54
       
 
       
	}

     

       
55
       
 
       
	db := setupTestDB(t)

     

       
56
       
 
       
	defer func() {

     
···

       
513
       
 
       
			// Views is []interface{}, unmarshal to check fields

     

       
514
       
 
       
			viewJSON, _ := json.Marshal(response.Views[0])

     

       
515
       
 
       
			var view aggregator.AggregatorView

     

       
516
       
+
       
			_ = json.Unmarshal(viewJSON, &view)

     

       
517
       
 
       


     

       
518
       
 
       
			assert.Equal(t, aggregatorDID, view.DID)

     

       
519
       
 
       
			assert.Equal(t, "RSS Feed Aggregator", view.DisplayName)

     
···

       
544
       
 
       


     

       
545
       
 
       
			viewJSON, _ := json.Marshal(response.Views[0])

     

       
546
       
 
       
			var detailedView aggregator.AggregatorViewDetailed

     

       
547
       
+
       
			_ = json.Unmarshal(viewJSON, &detailedView)

     

       
548
       
 
       


     

       
549
       
 
       
			assert.Equal(t, aggregatorDID, detailedView.DID)

     

       
550
       
 
       
			assert.Equal(t, 1, detailedView.Stats.CommunitiesUsing)