7 // "github.com/vapor/errors"
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) {
13 SELECT id, alias, filter, after FROM txfeeds
14 WHERE ($1='' OR id < $1) ORDER BY id DESC LIMIT %d
16 rows, err := t.DB.QueryContext(ctx, fmt.Sprintf(baseQ, limit), after)
18 return nil, "", errors.Wrap(err, "executing txfeeds query")
22 txfeeds := make([]*TxFeed, 0, limit)
28 err := rows.Scan(&feed.ID, &alias, &feed.Filter, &feed.After)
30 return nil, "", errors.Wrap(err, "scanning txfeed row")
34 feed.Alias = &alias.String
37 txfeeds = append(txfeeds, &feed)
41 return nil, "", errors.Wrap(err)
43 return txfeeds, after, nil
46 return nil, after, nil