akovalenko/lnd.xprv
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Add DestAddresses field in transactions returned by SubscribeTransactions

Browse Source
This commit is contained in:
Yaacov Akiba Slama 2019-07-10 09:40:41 +03:00
parent fe2a565bec
commit 46a611cd90
1 changed files with 15 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
rpcserver.go
View File

@ -3576,6 +3576,10 @@ func (r *rpcServer) SubscribeTransactions(req *lnrpc.GetTransactionsRequest,
for { for {
select { select {
case tx := <-txClient.ConfirmedTransactions(): case tx := <-txClient.ConfirmedTransactions():
destAddresses := make([]string, 0, len(tx.DestAddresses))
for _, destAddress := range tx.DestAddresses {
destAddresses = append(destAddresses, destAddress.EncodeAddress())
}
detail := &lnrpc.Transaction{ detail := &lnrpc.Transaction{
TxHash: tx.Hash.String(), TxHash: tx.Hash.String(),
Amount: int64(tx.Value), Amount: int64(tx.Value),
@ -3583,6 +3587,7 @@ func (r *rpcServer) SubscribeTransactions(req *lnrpc.GetTransactionsRequest,
BlockHash: tx.BlockHash.String(), BlockHash: tx.BlockHash.String(),
TimeStamp: tx.Timestamp, TimeStamp: tx.Timestamp,
TotalFees: tx.TotalFees, TotalFees: tx.TotalFees,
DestAddresses: destAddresses,
RawTxHex: hex.EncodeToString(tx.RawTx), RawTxHex: hex.EncodeToString(tx.RawTx),
} }
if err := updateStream.Send(detail); err != nil { if err := updateStream.Send(detail); err != nil {
@ -3590,12 +3595,17 @@ func (r *rpcServer) SubscribeTransactions(req *lnrpc.GetTransactionsRequest,
} }
case tx := <-txClient.UnconfirmedTransactions(): case tx := <-txClient.UnconfirmedTransactions():
var destAddresses []string
for _, destAddress := range tx.DestAddresses {
destAddresses = append(destAddresses, destAddress.EncodeAddress())
}
detail := &lnrpc.Transaction{ detail := &lnrpc.Transaction{
TxHash: tx.Hash.String(), TxHash: tx.Hash.String(),
Amount: int64(tx.Value), Amount: int64(tx.Value),
TimeStamp: tx.Timestamp, TimeStamp: tx.Timestamp,
TotalFees: tx.TotalFees, TotalFees: tx.TotalFees,
RawTxHex: hex.EncodeToString(tx.RawTx), DestAddresses: destAddresses,
RawTxHex: hex.EncodeToString(tx.RawTx),
} }
if err := updateStream.Send(detail); err != nil { if err := updateStream.Send(detail); err != nil {
return err return err