drivechain: add list sidechain deposits

proto/bitcoin/drivechaind/v1/drivechain.proto

@@ -5,6 +5,7 @@ package bitcoin.drivechaind.v1;
 service DrivechainService {
   rpc CreateSidechainDeposit(CreateSidechainDepositRequest) returns (CreateSidechainDepositResponse);
   rpc ListActiveSidechains(ListActiveSidechainsRequest) returns (ListActiveSidechainsResponse);
+  rpc ListSidechainDeposits(ListSidechainDepositsRequest) returns (ListSidechainDepositsResponse);
 }
 
 message CreateSidechainDepositRequest {
@@ -36,3 +37,20 @@ message ListActiveSidechainsResponse {
 
   repeated Sidechain sidechains = 1;
 }
+
+message ListSidechainDepositsRequest {
+  int32 slot = 1;
+}
+
+message ListSidechainDepositsResponse {
+  message SidechainDeposit {
+    int32 nsidechain = 1;
+    string strdest = 2;
+    string txhex = 3;
+    int32 nburnindex = 4;
+    int32 ntx = 5;
+    string hashblock = 6;
+  }
+
+  repeated SidechainDeposit deposits = 1;
+}

server/commands/drivechain.go

@@ -16,3 +16,9 @@ type ListSidechainCTip struct {
 	// The sidechain slot
 	Slot int `json:"slot"`
 }
+
+// ListSidechainDeposits retrieves a list of deposits for a specific sidechain
+type ListSidechainDeposits struct {
+	// The sidechain slot
+	Slot int `json:"slot"`
+}

server/drivechain_server.go

@@ -194,3 +194,26 @@ func chainToSlot(chain string) (int, error) {
 		return 0, fmt.Errorf("unknown chain: %s", chain)
 	}
 }
+
+// ListSidechainDeposits implements drivechaindv1connect.DrivechainServiceHandler.
+func (b *Bitcoind) ListSidechainDeposits(ctx context.Context, c *connect.Request[pb.ListSidechainDepositsRequest]) (*connect.Response[pb.ListSidechainDepositsResponse], error) {
+	cmd, err := btcjson.NewCmd("listsidechaindeposits", c.Msg.Slot)
+	if err != nil {
+		return nil, connect.NewError(connect.CodeInternal, fmt.Errorf("failed to create listsidechaindeposits command: %w", err))
+	}
+
+	res, err := rpcclient.ReceiveFuture(b.rpc.SendCmd(ctx, cmd))
+	if err != nil {
+		return nil, connect.NewError(connect.CodeInternal, fmt.Errorf("failed to execute listsidechaindeposits command: %w", err))
+	}
+
+	var deposits []*pb.ListSidechainDepositsResponse_SidechainDeposit
+	err = json.Unmarshal(res, &deposits)
+	if err != nil {
+		return nil, connect.NewError(connect.CodeInternal, fmt.Errorf("failed to unmarshal listsidechaindeposits response: %w", err))
+	}
+
+	return connect.NewResponse(&pb.ListSidechainDepositsResponse{
+		Deposits: deposits,
+	}), nil
+}

server/server.go

@@ -42,6 +42,7 @@ func init() {
 	btcjson.MustRegisterCmd("createsidechaindeposit", new(commands.CreateSidechainDeposit), btcjson.UFWalletOnly)
 	btcjson.MustRegisterCmd("listactivesidechains", new(commands.ListActiveSidechains), btcjson.UFWalletOnly)
 	btcjson.MustRegisterCmd("listsidechainctip", new(commands.ListSidechainCTip), btcjson.UFWalletOnly)
+	btcjson.MustRegisterCmd("listsidechaindeposits", new(commands.ListSidechainDeposits), btcjson.UFWalletOnly)
 }
 
 type Bitcoind struct {