napi rs json db

Author: ntheile

bindings/lni_nodejs/index.d.ts

@@ -159,6 +159,14 @@ export interface PaymentFailedEventProperties {
   transaction: Transaction
   reason: string
 }
+export interface Payment {
+  paymentId: string
+  circId: string
+  round: number
+  relayFingerprint: string
+  updatedAt: number
+  amountMsat: number
+}
 export declare class PhoenixdNode {
   constructor(config: PhoenixdConfig)
   getUrl(): string
@@ -169,3 +177,9 @@ export declare class PhoenixdNode {
   lookupInvoice(paymentHash: string): Promise<Transaction>
   listTransactions(params: ListTransactionsParams): Promise<Array<Transaction>>
 }
+export declare class Db {
+  constructor(path: string)
+  save(): void
+  writePayment(payment: Payment): void
+  lookupPayment(paymentId: string): Payment | null
+}

bindings/lni_nodejs/index.js

@@ -310,7 +310,8 @@ if (!nativeBinding) {
   throw new Error(`Failed to load native binding`)
 }
 
-const { InvoiceType, PhoenixdNode } = nativeBinding
+const { InvoiceType, PhoenixdNode, Db } = nativeBinding
 
 module.exports.InvoiceType = InvoiceType
 module.exports.PhoenixdNode = PhoenixdNode
+module.exports.Db = Db

bindings/lni_nodejs/main.mjs

@@ -1,32 +1,45 @@
-import { PhoenixdNode, InvoiceType } from './index.js'
-import dotenv from 'dotenv';
+import { PhoenixdNode, InvoiceType, Db } from "./index.js";
+import dotenv from "dotenv";
 dotenv.config();
 
- 
 const config = {
-    url: process.env.PHOENIXD_URL,
-    password: process.env.PHOENIXD_PASSWORD,
-    test_hash: process.env.PHOENIXD_TEST_PAYMENT_HASH,
-}
-const node = new PhoenixdNode(config)
-const info = await node.getInfo()
-console.log('Node info:', info)
+  url: process.env.PHOENIXD_URL,
+  password: process.env.PHOENIXD_PASSWORD,
+  test_hash: process.env.PHOENIXD_TEST_PAYMENT_HASH,
+};
+const node = new PhoenixdNode(config);
+const info = await node.getInfo();
+console.log("Node info:", info);
 
-const configRes = await node.getConfig()
-console.log('Config:', configRes.url)
+const configRes = await node.getConfig();
+console.log("Config:", configRes.url);
 
-const invoice = await node.makeInvoice({ amount: 1000, description: 'test invoice', invoiceType: InvoiceType.Bolt11 })
-console.log('Invoice:', invoice)
+const invoice = await node.makeInvoice({
+  amount: 1000,
+  description: "test invoice",
+  invoiceType: InvoiceType.Bolt11,
+});
+console.log("Invoice:", invoice);
 
-const lookupInvoice = await node.lookupInvoice(config.test_hash)
-console.log('lookupInvoice:', lookupInvoice)
+const lookupInvoice = await node.lookupInvoice(config.test_hash);
+console.log("lookupInvoice:", lookupInvoice);
 
 const txns = await node.listTransactions({
-    from: 0,
-    until: 0,
-    limit: 10,
-    offset: 0,
-    unpaid: false,
-    invoiceType: 'all',
-})
-console.log('Transactions:', txns)
+  from: 0,
+  until: 0,
+  limit: 10,
+  offset: 0,
+  unpaid: false,
+  invoiceType: "all",
+});
+console.log("Transactions:", txns);
+
+const db = new Db("test.json");
+db.writePayment({
+  paymentId: "1",
+  circId: "1",
+  round: 1,
+  relayFingerprint: "1",
+  updatedAt: 1,
+  amountMsat: 1,
+});

bindings/lni_nodejs/src/database.rs

@@ -0,0 +1,76 @@
+use lni::DbError;
+use serde::{Deserialize, Serialize};
+use std::fs::{File, OpenOptions};
+use std::io::{Read, Write};
+use std::sync::{Arc, Mutex};
+use napi::bindgen_prelude::*;
+use napi_derive::{napi};
+
+
+#[napi]
+#[derive(Debug, Deserialize)]
+pub struct Db {
+    path: String,
+    #[serde(skip)]
+    data: Arc<Mutex<Vec<lni::Payment>>>,
+}
+
+#[napi]
+impl Db {
+    #[napi(constructor)]
+    pub fn new(path: String) -> Result<Self> {
+        let data = if let Ok(mut file) = File::open(&path) {
+            let mut contents = String::new();
+            file.read_to_string(&mut contents)
+                .map_err(|e| napi::Error::from_reason(format!("IoErr: {}", e.to_string())))?;
+            serde_json::from_str(&contents).map_err(|e| DbError::DeserializationErr {
+                reason: e.to_string(),
+            }).unwrap()
+        } else {
+            Vec::new()
+        };
+
+        Ok(Self {
+            path,
+            data: Arc::new(Mutex::new(data)),
+        })
+    }
+
+    #[napi]
+    pub fn save(&self) -> Result<()> {
+        let data = self.data.lock().unwrap();
+        let json = serde_json::to_string_pretty(&*data).map_err(|e| DbError::SerializationErr {
+            reason: e.to_string(),
+        }).unwrap();
+        let mut file = OpenOptions::new()
+            .write(true)
+            .create(true)
+            .truncate(true)
+            .open(&self.path)
+            .map_err(|e| DbError::IoErr {
+                reason: e.to_string(),
+            }).unwrap();
+        file.write_all(json.as_bytes())
+            .map_err(|e| DbError::IoErr {
+                reason: e.to_string(),
+            }).unwrap();
+        Ok(())
+    }
+
+    #[napi]
+    pub fn write_payment(&self, payment: lni::Payment) -> Result<()> {
+        let mut data = self.data.lock().unwrap();
+        data.push(payment);
+        drop(data); // Explicitly drop the lock before saving
+        self.save()
+    }
+ 
+    #[napi]
+    pub fn lookup_payment(&self, payment_id: String) -> Result<Option<lni::Payment>> {
+        let data = self.data.lock().unwrap();
+        Ok(data
+            .iter()
+            .find(|payment| payment.payment_id == payment_id)
+            .cloned())
+    }
+}

bindings/lni_nodejs/src/lib.rs

@@ -4,7 +4,9 @@ extern crate napi_derive;
 
 mod phoenixd;
 
-pub use lni::{ApiError, Result};
+pub use lni::ApiError;
 pub use phoenixd::PhoenixdNode;
 pub use lni::types::*;
 
+mod database;
+pub use database::Db;

crates/lni/database.rs

@@ -3,6 +3,8 @@ use std::fs::{File, OpenOptions};
 use std::io::{Read, Write};
 use std::sync::{Arc, Mutex};
 use thiserror::Error;
+#[cfg(feature = "napi_rs")]
+use napi_derive::napi;
 
 #[derive(Debug, Error)]
 pub enum DbError {
@@ -14,6 +16,7 @@ pub enum DbError {
     DeserializationErr { reason: String },
 }
 
+#[cfg_attr(feature = "napi_rs", napi(object))]
 #[derive(Debug, Serialize, Deserialize, Clone)]
 pub struct Payment {
     pub payment_id: String,

crates/lni/lib.rs

@@ -30,4 +30,4 @@ pub mod types;
 pub use types::*;
 
 pub mod database;
-pub use database::{Db, DbError};
+pub use database::{Db, DbError, Payment};