feat: add settled_at to invoices

Cargo.toml

@@ -23,7 +23,7 @@ prost = "0.13.4"
 rcgen = { version = "0.13.2", features = ["x509-parser"] }
 tokio = { version = "1.42.0", features = ["macros", "rt-multi-thread", "sync"] }
 tonic = { version = "0.12.3", features = ["prost", "tls", "gzip", "zstd"] }
-serde = { version = "1.0.216", features = ["derive"] }
+serde = { version = "1.0.217", features = ["derive"] }
 serde_json = { version = "1.0.134", features = ["preserve_order"] }
 lightning-invoice = { version = "0.32.0", features = ["std"] }
 chrono = { version = "0.4.39", features = ["serde"] }

migrations/2024-12-29-234029_settled_at/down.sql

@@ -0,0 +1,2 @@
+ALTER TABLE invoices
+    DROP COLUMN settled_at;

migrations/2024-12-29-234029_settled_at/up.sql

@@ -0,0 +1,2 @@
+ALTER TABLE invoices
+    ADD COLUMN settled_at TIMESTAMP;

migrations_postgres/2024-12-29-234029_settled_at/down.sql

@@ -0,0 +1,2 @@
+ALTER TABLE invoices
+    DROP COLUMN settled_at;

migrations_postgres/2024-12-29-234029_settled_at/up.sql

@@ -0,0 +1,2 @@
+ALTER TABLE invoices
+    ADD COLUMN settled_at TIMESTAMP;

protos/hold.proto

@@ -89,6 +89,8 @@ message Invoice {
   string bolt11 = 4;
   InvoiceState state = 5;
   uint64 created_at = 6;
+  optional uint64 settled_at = 8;
+
   repeated Htlc htlcs = 7;
 }
 

src/commands/list.rs

@@ -43,6 +43,8 @@ struct PrettyHoldInvoice {
     pub bolt11: String,
     pub state: String,
     pub created_at: chrono::NaiveDateTime,
+    #[serde(skip_serializing_if = "Option::is_none")]
+    pub settled_at: Option<chrono::NaiveDateTime>,
     pub htlcs: Vec<Htlc>,
 }
 
@@ -55,6 +57,7 @@ impl From<HoldInvoice> for PrettyHoldInvoice {
             bolt11: value.invoice.bolt11.clone(),
             state: value.invoice.state.clone(),
             created_at: value.invoice.created_at,
+            settled_at: value.invoice.settled_at,
             htlcs: value.htlcs.clone(),
         }
     }

src/database/helpers/invoice_helper.rs

@@ -76,10 +76,20 @@ impl InvoiceHelper for InvoiceHelperDatabase {
     ) -> Result<usize> {
         state.validate_transition(new_state)?;
 
-        Ok(update(invoices::dsl::invoices)
-            .filter(invoices::dsl::id.eq(id))
-            .set(invoices::dsl::state.eq(new_state.to_string()))
-            .execute(&mut self.pool.get()?)?)
+        if new_state != InvoiceState::Paid {
+            Ok(update(invoices::dsl::invoices)
+                .filter(invoices::dsl::id.eq(id))
+                .set(invoices::dsl::state.eq(new_state.to_string()))
+                .execute(&mut self.pool.get()?)?)
+        } else {
+            Ok(update(invoices::dsl::invoices)
+                .filter(invoices::dsl::id.eq(id))
+                .set((
+                    invoices::dsl::state.eq(new_state.to_string()),
+                    invoices::dsl::settled_at.eq(Some(Utc::now().naive_utc())),
+                ))
+                .execute(&mut self.pool.get()?)?)
+        }
     }
 
     fn set_invoice_preimage(&self, id: i64, preimage: &[u8]) -> Result<usize> {

src/database/model.rs

@@ -13,6 +13,7 @@ pub struct Invoice {
     pub bolt11: String,
     pub state: String,
     pub created_at: chrono::NaiveDateTime,
+    pub settled_at: Option<chrono::NaiveDateTime>,
 }
 
 #[derive(Insertable, Debug, PartialEq, Clone)]
@@ -358,6 +359,7 @@ mod test {
                 bolt11: "".to_string(),
                 state: "".to_string(),
                 created_at: Default::default(),
+                settled_at: None,
             },
             vec![],
         );
@@ -407,6 +409,7 @@ mod test {
                 bolt11: "".to_string(),
                 state: "".to_string(),
                 created_at: Default::default(),
+                settled_at: None,
             },
             vec![
                 Htlc {

src/database/schema.rs

@@ -6,6 +6,7 @@ diesel::table! {
         bolt11 -> Text,
         state -> Text,
         created_at -> Timestamp,
+        settled_at -> Nullable<Timestamp>,
     }
 }
 

src/grpc/transformers.rs

@@ -27,6 +27,10 @@ impl From<HoldInvoice> for hold::Invoice {
                 InvoiceState::try_from(value.invoice.state.as_str()).unwrap(),
             ),
             created_at: value.invoice.created_at.and_utc().timestamp() as u64,
+            settled_at: value
+                .invoice
+                .settled_at
+                .map(|t| t.and_utc().timestamp() as u64),
             htlcs: value.htlcs.into_iter().map(|htlc| htlc.into()).collect(),
         }
     }

src/handler.rs

@@ -299,11 +299,12 @@ mod test {
             Ok(Some(HoldInvoice {
                 invoice: Invoice {
                     id: 0,
-                    payment_hash: vec![],
                     preimage: None,
+                    settled_at: None,
+                    payment_hash: vec![],
                     bolt11: "".to_string(),
-                    state: InvoiceState::Paid.to_string(),
                     created_at: Default::default(),
+                    state: InvoiceState::Paid.to_string(),
                 },
                 htlcs: vec![],
             }))
@@ -349,8 +350,9 @@ mod test {
             Ok(Some(HoldInvoice {
                 invoice: Invoice {
                     id: 0,
-                    payment_hash: vec![],
                     preimage: None,
+                    settled_at: None,
+                    payment_hash: vec![],
                     bolt11: INVOICE.to_string(),
                     state: InvoiceState::Unpaid.to_string(),
                     created_at: Default::default(),
@@ -408,8 +410,9 @@ mod test {
             Ok(Some(HoldInvoice {
                 invoice: Invoice {
                     id: 0,
-                    payment_hash: vec![],
                     preimage: None,
+                    settled_at: None,
+                    payment_hash: vec![],
                     bolt11: INVOICE.to_string(),
                     state: InvoiceState::Unpaid.to_string(),
                     created_at: Default::default(),
@@ -470,8 +473,9 @@ mod test {
             Ok(Some(HoldInvoice {
                 invoice: Invoice {
                     id: 0,
-                    payment_hash: vec![],
                     preimage: None,
+                    settled_at: None,
+                    payment_hash: vec![],
                     bolt11: INVOICE.to_string(),
                     state: InvoiceState::Unpaid.to_string(),
                     created_at: Default::default(),
@@ -537,6 +541,7 @@ mod test {
                 invoice: Invoice {
                     id: 0,
                     preimage: None,
+                    settled_at: None,
                     bolt11: INVOICE.to_string(),
                     created_at: Default::default(),
                     payment_hash: payment_hash_cp.clone(),
@@ -557,6 +562,7 @@ mod test {
                     invoice: Invoice {
                         id: 0,
                         preimage: None,
+                        settled_at: None,
                         bolt11: INVOICE.to_string(),
                         created_at: Default::default(),
                         state: InvoiceState::Unpaid.to_string(),

src/main.rs

@@ -27,8 +27,6 @@ struct State<T, E> {
     invoice_helper: T,
 }
 
-// TODO: backfill records from old datastore
-
 #[tokio::main]
 async fn main() -> Result<()> {
     std::env::set_var(

tests-regtest/hold/regtest_grpc.py

@@ -305,6 +305,7 @@ def track_states() -> list[InvoiceState]:
 
             invoice_state = cl.List(ListRequest(payment_hash=payment_hash)).invoices[0]
             assert invoice_state.state == InvoiceState.PAID
+            assert invoice_state.settled_at - int(time_now().timestamp()) < 2
             assert len(invoice_state.htlcs) == 1
             assert invoice_state.htlcs[0].state == InvoiceState.PAID
 

tests-regtest/hold/regtest_rpc.py

@@ -3,7 +3,7 @@
 import time
 from typing import Any
 
-from hold.utils import LndPay, lightning, new_preimage
+from hold.utils import LndPay, lightning, new_preimage, time_now
 
 
 def check_unpaid_invoice(
@@ -84,6 +84,7 @@ def test_settle(self) -> None:
 
         data = lightning("listholdinvoices", payment_hash)["holdinvoices"][0]
         assert data["state"] == "paid"
+        assert data["settled_at"].startswith(time_now().strftime("%Y-%m-%dT%H:%M"))
 
         htlcs = data["htlcs"]
         assert len(htlcs) == 1