package database

import (
	"context"
	"fmt"
)

func (r *ChunkRepository) List(ctx context.Context) ([]*Chunk, error) {
	query := `
		SELECT chunk_hash, size
		FROM chunks
		ORDER BY chunk_hash
	`

	rows, err := r.db.conn.QueryContext(ctx, query)
	if err != nil {
		return nil, fmt.Errorf("querying chunks: %w", err)
	}
	defer CloseRows(rows)

	var chunks []*Chunk
	for rows.Next() {
		var chunk Chunk

		err := rows.Scan(
			&chunk.ChunkHash,
			&chunk.Size,
		)
		if err != nil {
			return nil, fmt.Errorf("scanning chunk: %w", err)
		}

		chunks = append(chunks, &chunk)
	}

	return chunks, rows.Err()
}