Skip to content

[Part 2|*] Implement First Part for SQL Backend functions #10287

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Open
wants to merge 6 commits into
base: elle-payment-sql-series-new
Choose a base branch
from
Open

[Part 2|*] Implement First Part for SQL Backend functions #10287

Show file tree
Hide file tree
Changes from 1 commit
Commits
Show all changes
6 commits
Select commit Hold shift + click to select a range
18f03ec
sqldb: add index and comment to payment tables
ziggie1984 Oct 15, 2025
c908b52
multi: add relevant queries for QueryPayments implemenation
ziggie1984 Oct 12, 2025
52d466f
paymentsdb: add new internal error
ziggie1984 Oct 12, 2025
353160c
paymentsdb: implement QueryPayments for sql backend
ziggie1984 Oct 12, 2025
fc4ce67
paymentsdb: implement FetchPayment for sql backend
ziggie1984 Oct 15, 2025
0849296
docs: add release-notes
ziggie1984 Oct 12, 2025
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
19 changes: 19 additions & 0 deletions payments/db/sql_store.go
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1,14 +1,33 @@
package paymentsdb

import (
"context"
"fmt"

"github.com/lightningnetwork/lnd/sqldb"
"github.com/lightningnetwork/lnd/sqldb/sqlc"
)

// SQLQueries is a subset of the sqlc.Querier interface that can be used to
// execute queries against the SQL payments tables.
type SQLQueries interface {
/*
Payment DB read operations.
*/
FilterPayments(ctx context.Context, query sqlc.FilterPaymentsParams) ([]sqlc.FilterPaymentsRow, error)
FetchPayment(ctx context.Context, paymentIdentifier []byte) (sqlc.FetchPaymentRow, error)
FetchPaymentsByIDs(ctx context.Context, paymentIDs []int64) ([]sqlc.FetchPaymentsByIDsRow, error)

CountPayments(ctx context.Context) (int64, error)

FetchHtlcAttemptsForPayment(ctx context.Context, paymentID int64) ([]sqlc.FetchHtlcAttemptsForPaymentRow, error)
FetchAllInflightAttempts(ctx context.Context) ([]sqlc.PaymentHtlcAttempt, error)
FetchHopsForAttempt(ctx context.Context, htlcAttemptIndex int64) ([]sqlc.FetchHopsForAttemptRow, error)
FetchHopsForAttempts(ctx context.Context, htlcAttemptIndices []int64) ([]sqlc.FetchHopsForAttemptsRow, error)

FetchPaymentLevelFirstHopCustomRecords(ctx context.Context, paymentID int64) ([]sqlc.PaymentFirstHopCustomRecord, error)
FetchRouteLevelFirstHopCustomRecords(ctx context.Context, htlcAttemptIndices []int64) ([]sqlc.PaymentAttemptFirstHopCustomRecord, error)
FetchHopLevelCustomRecords(ctx context.Context, hopIDs []int64) ([]sqlc.PaymentHopCustomRecord, error)
}

// BatchedSQLQueries is a version of the SQLQueries that's capable
Expand Down
Loading