blockchain/txfeed/query.go

   1 package txfeed
   2
   3 import (
   4         "context"
   5         //"database/sql"
   6         //      "fmt"
   7         //      "github.com/vapor/errors"
   8 )
   9
  10 // Query queries the Chain Core for txfeeds matching the query.
  11 func /* (t *Tracker)*/ Query(ctx context.Context, after string, limit int) ([]*TxFeed, string, error) {
  12         /*      const baseQ = `
  13                         SELECT id, alias, filter, after FROM txfeeds
  14                         WHERE ($1='' OR id < $1) ORDER BY id DESC LIMIT %d
  15                 `
  16                 rows, err := t.DB.QueryContext(ctx, fmt.Sprintf(baseQ, limit), after)
  17                 if err != nil {
  18                         return nil, "", errors.Wrap(err, "executing txfeeds query")
  19                 }
  20                 defer rows.Close()
  21
  22                 txfeeds := make([]*TxFeed, 0, limit)
  23                 for rows.Next() {
  24                         var (
  25                                 feed  TxFeed
  26                                 alias sql.NullString
  27                         )
  28                         err := rows.Scan(&feed.ID, &alias, &feed.Filter, &feed.After)
  29                         if err != nil {
  30                                 return nil, "", errors.Wrap(err, "scanning txfeed row")
  31                         }
  32
  33                         if alias.Valid {
  34                                 feed.Alias = &alias.String
  35                         }
  36                         after = feed.ID
  37                         txfeeds = append(txfeeds, &feed)
  38                 }
  39                 err = rows.Err()
  40                 if err != nil {
  41                         return nil, "", errors.Wrap(err)
  42                 }
  43                 return txfeeds, after, nil
  44         */
  45         after = "qwertyu"
  46         return nil, after, nil
  47 }