blockchain/txfeeds.go

   1 package blockchain
   2
   3 import (
   4         "context"
   5         "encoding/json"
   6
   7         "github.com/bytom/errors"
   8 )
   9
  10 func (bcr *BlockchainReactor) GetTxFeedByAlias(ctx context.Context, filter string) ([]byte, error) {
  11         jf, err := json.Marshal(filter)
  12         if err != nil {
  13                 return nil, err
  14         }
  15
  16         value := bcr.TxFeedTracker.DB.Get(jf)
  17         if value == nil {
  18                 return nil, errors.New("No transaction feed")
  19         }
  20
  21         return value, nil
  22 }