kaspad/server/rpc/handle_get_mempool_entry.go
2020-03-12 16:00:18 +02:00

33 lines
703 B
Go

package rpc
import (
"github.com/kaspanet/kaspad/rpcmodel"
"github.com/kaspanet/kaspad/util/daghash"
)
func handleGetMempoolEntry(s *Server, cmd interface{}, closeChan <-chan struct{}) (interface{}, error) {
c := cmd.(*rpcmodel.GetMempoolEntryCmd)
txID, err := daghash.NewTxIDFromStr(c.TxID)
if err != nil {
return nil, err
}
txDesc, err := s.cfg.TxMemPool.FetchTxDesc(txID)
if err != nil {
return nil, err
}
tx := txDesc.Tx
rawTx, err := createTxRawResult(s.cfg.DAGParams, tx.MsgTx(), tx.ID().String(),
nil, "", nil, true)
if err != nil {
return nil, err
}
return &rpcmodel.GetMempoolEntryResult{
Fee: txDesc.Fee,
Time: txDesc.Added.Unix(),
RawTx: *rawTx,
}, nil
}