Feat: LNbits backend (zig-bitcoin#27)

* lnbits backend with webhook + router merging
lana-shanghai · Sep 29, 2024 · bebd791 · bebd791
1 parent 7cdb46f
commit bebd791
Show file tree

Hide file tree

Showing 18 changed files with 1,540 additions and 161 deletions.
diff --git a/src/core/database/database.zig b/src/core/database/database.zig
@@ -32,14 +32,14 @@ pub const MintDatabase = struct {
     getMintQuoteFn: *const fn (ptr: *anyopaque, gpa: std.mem.Allocator, quote_id: zul.UUID) anyerror!?MintQuote,
     updateMintQuoteStateFn: *const fn (ptr: *anyopaque, quote_id: zul.UUID, state: nuts.nut04.QuoteState) anyerror!nuts.nut04.QuoteState,
     getMintQuotesFn: *const fn (ptr: *anyopaque, allocator: std.mem.Allocator) anyerror!std.ArrayList(MintQuote),
-    getMintQuoteByRequestLookupIdFn: *const fn (ptr: *anyopaque, gpa: std.mem.Allocator, request_lookup_id: zul.UUID) anyerror!?MintQuote,
+    getMintQuoteByRequestLookupIdFn: *const fn (ptr: *anyopaque, gpa: std.mem.Allocator, request_lookup_id: []const u8) anyerror!?MintQuote,
     getMintQuoteByRequestFn: *const fn (ptr: *anyopaque, gpa: std.mem.Allocator, request: []const u8) anyerror!?MintQuote,
     removeMintQuoteStateFn: *const fn (ptr: *anyopaque, quote_id: zul.UUID) anyerror!void,
     addMeltQuoteFn: *const fn (ptr: *anyopaque, quote: MeltQuote) anyerror!void,
     getMeltQuoteFn: *const fn (ptr: *anyopaque, gpa: std.mem.Allocator, quote_id: zul.UUID) anyerror!?MeltQuote,
     updateMeltQuoteStateFn: *const fn (ptr: *anyopaque, quote_id: zul.UUID, state: nuts.nut05.QuoteState) anyerror!nuts.nut05.QuoteState,
     getMeltQuotesFn: *const fn (ptr: *anyopaque, gpa: std.mem.Allocator) anyerror!std.ArrayList(MeltQuote),
-    getMeltQuoteByRequestLookupIdFn: *const fn (ptr: *anyopaque, gpa: std.mem.Allocator, request_lookup_id: zul.UUID) anyerror!?MeltQuote,
+    getMeltQuoteByRequestLookupIdFn: *const fn (ptr: *anyopaque, gpa: std.mem.Allocator, request_lookup_id: []const u8) anyerror!?MeltQuote,
     getMeltQuoteByRequestFn: *const fn (ptr: *anyopaque, gpa: std.mem.Allocator, request: []const u8) anyerror!?MeltQuote,
     removeMeltQuoteStateFn: *const fn (ptr: *anyopaque, quote_id: zul.UUID) anyerror!void,
     addProofsFn: *const fn (ptr: *anyopaque, proofs: []const nuts.Proof) anyerror!void,
@@ -129,7 +129,7 @@ pub const MintDatabase = struct {
                 const self: *T = @ptrCast(@alignCast(pointer));
                 return self.getMintQuotes(gpa);
             }
-            pub fn getMintQuoteByRequestLookupId(pointer: *anyopaque, gpa: std.mem.Allocator, request_lookup_id: zul.UUID) anyerror!?MintQuote {
+            pub fn getMintQuoteByRequestLookupId(pointer: *anyopaque, gpa: std.mem.Allocator, request_lookup_id: []const u8) anyerror!?MintQuote {
                 const self: *T = @ptrCast(@alignCast(pointer));
                 return self.getMintQuoteByRequestLookupId(gpa, request_lookup_id);
             }
@@ -157,7 +157,7 @@ pub const MintDatabase = struct {
                 const self: *T = @ptrCast(@alignCast(pointer));
                 return self.getMeltQuotes(gpa);
             }
-            pub fn getMeltQuoteByRequestLookupId(pointer: *anyopaque, gpa: std.mem.Allocator, request_lookup_id: zul.UUID) anyerror!?MeltQuote {
+            pub fn getMeltQuoteByRequestLookupId(pointer: *anyopaque, gpa: std.mem.Allocator, request_lookup_id: []const u8) anyerror!?MeltQuote {
                 const self: *T = @ptrCast(@alignCast(pointer));
                 return self.getMeltQuoteByRequestLookupId(gpa, request_lookup_id);
             }
@@ -332,7 +332,7 @@ pub const MintDatabase = struct {
     pub fn getMintQuotes(self: Self, allocator: std.mem.Allocator) anyerror!std.ArrayList(MintQuote) {
         return self.getMintQuotesFn(self.ptr, allocator);
     }
-    pub fn getMintQuoteByRequestLookupId(self: Self, gpa: std.mem.Allocator, request_lookup_id: zul.UUID) anyerror!?MintQuote {
+    pub fn getMintQuoteByRequestLookupId(self: Self, gpa: std.mem.Allocator, request_lookup_id: []const u8) anyerror!?MintQuote {
         return self.getMintQuoteByRequestLookupIdFn(self.ptr, gpa, request_lookup_id);
     }
     pub fn getMintQuoteByRequest(self: Self, gpa: std.mem.Allocator, request: []const u8) anyerror!?MintQuote {
@@ -353,7 +353,7 @@ pub const MintDatabase = struct {
     pub fn getMeltQuotes(self: Self, gpa: std.mem.Allocator) anyerror!std.ArrayList(MeltQuote) {
         return self.getMeltQuotesFn(self.ptr, gpa);
     }
-    pub fn getMeltQuoteByRequestLookupId(self: Self, gpa: std.mem.Allocator, request_lookup_id: zul.UUID) anyerror!?MeltQuote {
+    pub fn getMeltQuoteByRequestLookupId(self: Self, gpa: std.mem.Allocator, request_lookup_id: []const u8) anyerror!?MeltQuote {
         return self.getMeltQuoteByRequestLookupIdFn(self.ptr, gpa, request_lookup_id);
     }
     pub fn getMeltQuoteByRequest(self: Self, gpa: std.mem.Allocator, request: []const u8) anyerror!?MeltQuote {

diff --git a/src/core/database/mint_memory.zig b/src/core/database/mint_memory.zig
@@ -285,7 +285,7 @@ pub const MintMemoryDatabase = struct {
     pub fn getMintQuoteByRequestLookupId(
         self: *Self,
         allocator: std.mem.Allocator,
-        request: zul.UUID,
+        request: []const u8,
     ) !?MintQuote {
         var arena = std.heap.ArenaAllocator.init(allocator);
         defer arena.deinit();
@@ -294,7 +294,7 @@ pub const MintMemoryDatabase = struct {
         const quotes = try self.getMintQuotes(arena.allocator());
         for (quotes.items) |q| {
             // if we found, cloning with allocator, so caller responsible on free resources
-            if (q.request_lookup_id.eql(request)) return try q.clone(allocator);
+            if (std.mem.eql(u8, q.request_lookup_id, request)) return try q.clone(allocator);
         }
 
         return null;
@@ -386,7 +386,7 @@ pub const MintMemoryDatabase = struct {
     pub fn getMeltQuoteByRequestLookupId(
         self: *Self,
         allocator: std.mem.Allocator,
-        request: zul.UUID,
+        request: []const u8,
     ) !?MeltQuote {
         var arena = std.heap.ArenaAllocator.init(allocator);
         defer arena.deinit();
@@ -395,7 +395,7 @@ pub const MintMemoryDatabase = struct {
         const quotes = try self.getMeltQuotes(arena.allocator());
         for (quotes.items) |q| {
             // if we found, cloning with allocator, so caller responsible on free resources
-            if (std.mem.eql(u8, q.request_lookup_id, &request.bin)) return try q.clone(allocator);
+            if (std.mem.eql(u8, q.request_lookup_id, request)) return try q.clone(allocator);
         }
 
         return null;

diff --git a/src/core/lightning/lightning.zig b/src/core/lightning/lightning.zig
@@ -30,6 +30,8 @@ pub const PayInvoiceResponse = struct {
     /// Totoal Amount Spent
     total_spent: Amount,
 
+    unit: CurrencyUnit,
+
     pub fn deinit(self: PayInvoiceResponse, allocator: std.mem.Allocator) void {
         allocator.free(self.payment_hash);
 
@@ -45,6 +47,8 @@ pub const PaymentQuoteResponse = struct {
     amount: Amount,
     /// Fee required for melt
     fee: u64,
+    /// Status
+    state: MeltQuoteState,
 
     pub fn deinit(self: PaymentQuoteResponse, allocator: std.mem.Allocator) void {
         allocator.free(self.request_lookup_id);

diff --git a/src/core/lightning/mint.zig b/src/core/lightning/mint.zig
@@ -3,6 +3,8 @@ const Self = @This();
 
 const std = @import("std");
 const core = @import("../lib.zig");
+const ref = @import("../../sync/ref.zig");
+const mpmc = @import("../../sync/mpmc.zig");
 
 const Channel = @import("../../channels/channels.zig").Channel;
 const Amount = core.amount.Amount;
@@ -21,7 +23,7 @@ ptr: *anyopaque,
 
 deinitFn: *const fn (ptr: *anyopaque) void,
 getSettingsFn: *const fn (ptr: *anyopaque) Settings,
-waitAnyInvoiceFn: *const fn (ptr: *anyopaque) anyerror!Channel(std.ArrayList(u8)).Rx,
+waitAnyInvoiceFn: *const fn (ptr: *anyopaque) ref.Arc(mpmc.UnboundedChannel(std.ArrayList(u8))),
 getPaymentQuoteFn: *const fn (ptr: *anyopaque, alloc: std.mem.Allocator, melt_quote_request: MeltQuoteBolt11Request) anyerror!PaymentQuoteResponse,
 payInvoiceFn: *const fn (ptr: *anyopaque, alloc: std.mem.Allocator, melt_quote: core.mint.MeltQuote, partial_msats: ?Amount, max_fee_msats: ?Amount) anyerror!PayInvoiceResponse,
 checkInvoiceStatusFn: *const fn (ptr: *anyopaque, request_lookup_id: []const u8) anyerror!MintQuoteState,
@@ -34,7 +36,7 @@ pub fn initFrom(comptime T: type, allocator: std.mem.Allocator, value: T) !Self
             return self.getSettings();
         }
 
-        pub fn waitAnyInvoice(pointer: *anyopaque) anyerror!Channel(std.ArrayList(u8)).Rx {
+        pub fn waitAnyInvoice(pointer: *anyopaque) ref.Arc(mpmc.UnboundedChannel(std.ArrayList(u8))) {
             const self: *T = @ptrCast(@alignCast(pointer));
             return self.waitAnyInvoice();
         }
@@ -94,7 +96,7 @@ pub fn getSettings(self: Self) Settings {
     return self.getSettingsFn(self.ptr);
 }
 
-pub fn waitAnyInvoice(self: Self) !Channel(std.ArrayList(u8)).Rx {
+pub fn waitAnyInvoice(self: Self) ref.Arc(mpmc.UnboundedChannel(std.ArrayList(u8))) {
     return self.waitAnyInvoiceFn(self.ptr);
 }
 

diff --git a/src/core/mint/lightning/lib.zig b/src/core/mint/lightning/lib.zig
@@ -1,4 +1,2 @@
 pub const lnbits = @import("lnbits.zig");
 pub const invoice = @import("invoices/lib.zig");
-
-pub const Lightning = @import("lightning.zig");