Add FetchIncomingPaymentsByInvoice to the client interface

examples/example.go

@@ -326,6 +326,14 @@ func main() {
 	fmt.Printf("Invoice paid with a simulated payment %v\n", testPayment.Id)
 	fmt.Println()
 
+	// Fetch the payment by invoice id:
+	paymentResponse, err := client.FetchIncomingPaymentsByInvoice(invoice.Id, nil)
+	if err != nil {
+		fmt.Printf("fetch incoming payments by invoice failed: %v", err)
+		return
+	}
+	fmt.Printf("We found %v incoming payments for the invoice.\n", len(paymentResponse.Payments))
+
 	// Create and cancel an invoice
 	fmt.Println("Creating an invoice...")
 	invoiceToCancel, err := client.CreateInvoice(nodeId, 100000, nil, nil, nil)

scripts/incoming_payments_for_invoice.go

@@ -0,0 +1,18 @@
+package scripts
+
+import "github.com/lightsparkdev/go-sdk/objects"
+
+const INCOMING_PAYMENTS_FOR_INVOICE_QUERY = `
+query IncomingPaymentsForInvoice(
+	$invoice_id: ID!
+	$statuses: [TransactionStatus!]
+) {
+	incoming_payments_for_invoice(input: {
+		invoice_id: $invoice_id
+		statuses: $statuses
+	}) {
+		...IncomingPaymentsForInvoiceQueryOutputFragment
+	}
+}
+
+` + objects.IncomingPaymentsForInvoiceQueryOutputFragment

services/lightspark_client.go

@@ -1016,6 +1016,31 @@ func (client *LightsparkClient) FetchOutgoingPaymentsByInvoice(encodedInvoice st
 	return &payments, nil
 }
 
+func (client *LightsparkClient) FetchIncomingPaymentsByInvoice(invoiceId string,
+	statuses *[]objects.TransactionStatus) (*objects.IncomingPaymentsForInvoiceQueryOutput, error) {
+	variables := map[string]interface{}{
+		"invoice_id": invoiceId,
+		"statuses":   statuses,
+	}
+
+	response, err := client.Requester.ExecuteGraphql(scripts.INCOMING_PAYMENTS_FOR_INVOICE_QUERY, variables, nil)
+	if err != nil {
+		return nil, err
+	}
+
+	output := response["incoming_payments_for_invoice"].(map[string]interface{})
+	var payments objects.IncomingPaymentsForInvoiceQueryOutput
+	paymentsJson, err := json.Marshal(output)
+	if err != nil {
+		return nil, errors.New("error parsing payments")
+	}
+	err = json.Unmarshal(paymentsJson, &payments)
+	if err != nil {
+		return nil, err
+	}
+	return &payments, nil
+}
+
 func hashPhoneNumber(e614PhoneNumber string) (*string, error) {
 	e164PhoneRegex, err := regexp.Compile(`^\+?[1-9]\d{1,14}$`)
 	if err != nil {