commit 71d7d8d0db93cfe8e6520a7589d1c6a11551ca67 · bretton.dev/coves

+5 -3
internal/db/postgres/community_repo_blocks.go
···

       5
       5
        
       	"context"

     

       6
       6
        
       	"database/sql"

     

       7
       7
        
       	"fmt"

     

       8
       8
       +
       	"log"

     

       8
       9
        
       )

     

       9
       10
        
       

     

       10
       11
        
       // BlockCommunity creates a new block record (idempotent)

     
···

       123
       124
        
       	defer func() {

     

       124
       125
        
       		if closeErr := rows.Close(); closeErr != nil {

     

       125
       126
        
       			// Log error but don't override the main error

     

       126
       126
       -
       			fmt.Printf("Failed to close rows: %v\n", closeErr)

     

       127
       127
       +
       			log.Printf("Failed to close rows: %v", closeErr)

     

       127
       128
        
       		}

     

       128
       129
        
       	}()

     

       129
       130
        
       

     

       130
       131
        
       	var blocks []*communities.CommunityBlock

     

       131
       132
        
       	for rows.Next() {

     

       132
       132
       -
       		var block communities.CommunityBlock

     

       133
       133
       +
       		// Allocate a new block for each iteration to avoid pointer reuse bug

     

       134
       134
       +
       		block := &communities.CommunityBlock{}

     

       133
       135
        
       

     

       134
       136
        
       		err = rows.Scan(

     

       135
       137
        
       			&block.ID,

     
···

       143
       145
        
       			return nil, fmt.Errorf("failed to scan block: %w", err)

     

       144
       146
        
       		}

     

       145
       147
        
       

     

       146
       146
       -
       		blocks = append(blocks, &block)

     

       148
       148
       +
       		blocks = append(blocks, block)

     

       147
       149
        
       	}

     

       148
       150
        
       

     

       149
       151
        
       	if err = rows.Err(); err != nil {