Merge pull request #35 from YASSERRMD/phase_2

phase 2: paginated GET /v1/receipts listing endpoint

Author: YASSERRMD

internal/api/ingest.go

@@ -7,6 +7,7 @@ import (
 	"errors"
 	"log"
 	"net/http"
+	"strconv"
 	"time"
 
 	"github.com/google/uuid"
@@ -97,6 +98,47 @@ func (s *Server) handleIngestBatch(w http.ResponseWriter, r *http.Request) {
 	writeJSON(w, http.StatusCreated, map[string]any{"count": len(receipts), "receipts": receipts})
 }
 
+// ListReceiptsResponse is returned by GET /v1/receipts.
+type ListReceiptsResponse struct {
+	Receipts []vur.Receipt `json:"receipts"`
+	Offset   int           `json:"offset"`
+	Limit    int           `json:"limit"`
+	Count    int           `json:"count"`
+}
+
+func (s *Server) handleListReceipts(w http.ResponseWriter, r *http.Request) {
+	const defaultLimit = 50
+	const maxLimit = 500
+
+	offset, _ := strconv.Atoi(r.URL.Query().Get("offset"))
+	limit, _ := strconv.Atoi(r.URL.Query().Get("limit"))
+	if limit <= 0 {
+		limit = defaultLimit
+	}
+	if limit > maxLimit {
+		limit = maxLimit
+	}
+	if offset < 0 {
+		offset = 0
+	}
+
+	stored, err := s.store.ListReceipts(offset, limit)
+	if err != nil {
+		writeError(w, http.StatusInternalServerError, "list receipts: "+err.Error())
+		return
+	}
+	receipts := make([]vur.Receipt, len(stored))
+	for i, sr := range stored {
+		receipts[i] = sr.Receipt
+	}
+	writeJSON(w, http.StatusOK, ListReceiptsResponse{
+		Receipts: receipts,
+		Offset:   offset,
+		Limit:    limit,
+		Count:    len(receipts),
+	})
+}
+
 func (s *Server) handleGetReceipt(w http.ResponseWriter, r *http.Request) {
 	id := r.PathValue("id")
 	sr, err := s.store.GetReceiptByID(id)

internal/api/server.go

@@ -114,6 +114,7 @@ func (s *Server) Routes() *http.ServeMux {
 	// Receipt routes
 	mux.HandleFunc("POST /v1/receipts", s.handleIngest)
 	mux.HandleFunc("POST /v1/receipts/batch", s.handleIngestBatch)
+	mux.HandleFunc("GET /v1/receipts", s.handleListReceipts)
 	mux.HandleFunc("GET /v1/receipts/{id}", s.handleGetReceipt)
 	mux.HandleFunc("GET /v1/receipts/{id}/proof", s.handleInclusionProof)
 	mux.HandleFunc("GET /v1/receipts/{id}/attestation", s.handleAttestation)

internal/store/interface.go

@@ -72,6 +72,7 @@ type Store interface {
 	// Receipt operations
 	AppendReceipt(r vur.Receipt) (int64, error)
 	GetReceiptByID(id string) (*StoredReceipt, error)
+	ListReceipts(offset, limit int) ([]StoredReceipt, error)
 	FetchUnbatched(limit int) ([]StoredReceipt, error)
 	MarkBatched(ids []int64) error
 	GetReceiptsByRange(startID, endID int64) ([]vur.Receipt, error)

internal/store/sqlite.go

@@ -62,6 +62,16 @@ func (s *SQLiteStore) GetReceiptByID(id string) (*StoredReceipt, error) {
 	return &StoredReceipt{RowID: rowID, Receipt: r}, nil
 }
 
+func (s *SQLiteStore) ListReceipts(offset, limit int) ([]StoredReceipt, error) {
+	rows, err := s.db.Query(
+		`SELECT id, receipt_json FROM receipts ORDER BY id DESC LIMIT ? OFFSET ?`, limit, offset)
+	if err != nil {
+		return nil, err
+	}
+	defer rows.Close()
+	return scanStoredReceipts(rows)
+}
+
 func (s *SQLiteStore) FetchUnbatched(limit int) ([]StoredReceipt, error) {
 	rows, err := s.db.Query(
 		`SELECT id, receipt_json FROM receipts WHERE batched=0 ORDER BY id ASC LIMIT ?`, limit)