From 5632998030a2f558dd630d4206b30109d5b7da7d Mon Sep 17 00:00:00 2001
From: cyberguru1 <hamzacypher34@gmail.com>
Date: Tue, 7 Jul 2026 11:21:54 -0500
Subject: [PATCH] accounts: implement ListAccountPayments in SQLStore

Add sqlc queries to select account payment hashes from the database.
Implement the ListAccountPayments method in the SQLStore, allowing
retrieval of stored payment hashes for SQLite and Postgres backends.

Also define the AccountPaymentEntry helper struct in
accounts/interface.go to wrap payment hashes and details.
---
 accounts/interface.go |  6 ++++
 accounts/store_sql.go | 76 +++++++++++++++++++++++++++++++++++++++++++
 2 files changed, 82 insertions(+)

diff --git a/accounts/interface.go b/accounts/interface.go
index 709f40ec..85486662 100644
--- a/accounts/interface.go
+++ b/accounts/interface.go
@@ -107,6 +107,12 @@ type AccountInvoices map[lntypes.Hash]struct{}
 // AccountPayments is the set of payments that are associated with an account.
 type AccountPayments map[lntypes.Hash]*PaymentEntry
 
+// AccountPaymentEntry wraps a payment hash with its entry details.
+type AccountPaymentEntry struct {
+	Hash lntypes.Hash
+	*PaymentEntry
+}
+
 // OffChainBalanceAccount holds all information that is needed to keep track of
 // a user's off-chain account balance. This balance can only be spent by paying
 // invoices.
diff --git a/accounts/store_sql.go b/accounts/store_sql.go
index 61780c12..277aaf76 100644
--- a/accounts/store_sql.go
+++ b/accounts/store_sql.go
@@ -46,6 +46,8 @@ type SQLQueries interface {
 	ListAllAccountPayments(ctx context.Context) ([]sqlc.AccountPayment, error)
 	ListAccountInvoices(ctx context.Context, id int64) ([]sqlc.AccountInvoice, error)
 	ListAccountPayments(ctx context.Context, id int64) ([]sqlc.AccountPayment, error)
+	AccountPaymentsPaginated(ctx context.Context, arg sqlc.AccountPaymentsPaginatedParams) ([]sqlc.AccountPayment, error)
+	CountAccountPayments(ctx context.Context, accountID int64) (int64, error)
 	ListAllAccounts(ctx context.Context) ([]sqlc.Account, error)
 	SetAccountIndex(ctx context.Context, arg sqlc.SetAccountIndexParams) error
 	UpdateAccountBalance(ctx context.Context, arg sqlc.UpdateAccountBalanceParams) (int64, error)
@@ -779,6 +781,80 @@ func (s *SQLStore) DeleteAccountPayment(ctx context.Context, alias AccountID,
 	}, sqldb.NoOpReset)
 }
 
+// ListAccountPayments returns a paginated list of payments
+// associated with the given account, sorted in ascending lexicographical
+// order of their payment hash.
+func (s *SQLStore) ListAccountPayments(ctx context.Context, alias AccountID,
+	offset, limit int32) ([]*AccountPaymentEntry, error) {
+
+	var (
+		readTxOpts = db.NewQueryReadTx()
+		payments   []*AccountPaymentEntry
+	)
+	err := s.db.ExecTx(ctx, &readTxOpts, func(db SQLQueries) error {
+		id, err := getAccountIDByAlias(ctx, db, alias)
+		if err != nil {
+			return err
+		}
+
+		var dbPayments []sqlc.AccountPayment
+		dbPayments, err = db.AccountPaymentsPaginated(
+			ctx, sqlc.AccountPaymentsPaginatedParams{
+				AccountID: id,
+				Limit:     limit,
+				Offset:    offset,
+			},
+		)
+		if err != nil {
+			return err
+		}
+
+		payments = make([]*AccountPaymentEntry, len(dbPayments))
+		for i, p := range dbPayments {
+			var hash lntypes.Hash
+			copy(hash[:], p.Hash)
+			payments[i] = &AccountPaymentEntry{
+				Hash: hash,
+				PaymentEntry: &PaymentEntry{
+					Status: lnrpc.Payment_PaymentStatus(
+						p.Status,
+					),
+					FullAmount: lnwire.MilliSatoshi(
+						p.FullAmountMsat,
+					),
+				},
+			}
+		}
+
+		return nil
+	}, sqldb.NoOpReset)
+
+	return payments, err
+}
+
+// CountAccountPayments returns the total number of payments associated with
+// the given account.
+func (s *SQLStore) CountAccountPayments(ctx context.Context,
+	alias AccountID) (uint64, error) {
+
+	var (
+		readTxOpts = db.NewQueryReadTx()
+		count      int64
+	)
+	err := s.db.ExecTx(ctx, &readTxOpts, func(db SQLQueries) error {
+		id, err := getAccountIDByAlias(ctx, db, alias)
+		if err != nil {
+			return err
+		}
+
+		count, err = db.CountAccountPayments(ctx, id)
+
+		return err
+	}, sqldb.NoOpReset)
+
+	return uint64(count), err
+}
+
 // LastIndexes returns the last invoice add and settle index or
 // ErrNoInvoiceIndexKnown if no indexes are known yet.
 //