Method Query

core/txfeed/query.go:12–45

Query queries the Chain Core for txfeeds matching the query.

(ctx context.Context, after string, limit int)

// Query queries the Chain Core for txfeeds matching the query.
func (t *Tracker) Query(ctx context.Context, after string, limit int) ([]*TxFeed, string, error) {
	const baseQ = `
		SELECT id, alias, filter, after FROM txfeeds
		WHERE ($1='' OR id < $1) ORDER BY id DESC LIMIT %d
	`
	rows, err := t.DB.Query(ctx, fmt.Sprintf(baseQ, limit), after)
	if err != nil {
		return nil, "", errors.Wrap(err, "executing txfeeds query")
	}
	defer rows.Close()

	txfeeds := make([]*TxFeed, 0, limit)
	for rows.Next() {
		var (
			feed  TxFeed
			alias sql.NullString
		)
		err := rows.Scan(&feed.ID, &alias, &feed.Filter, &feed.After)
		if err != nil {
			return nil, "", errors.Wrap(err, "scanning txfeed row")
		}

		if alias.Valid {
			feed.Alias = &alias.String
		}
		after = feed.ID
		txfeeds = append(txfeeds, &feed)
	}
	err = rows.Err()
	if err != nil {
		return nil, "", errors.Wrap(err)
	}
	return txfeeds, after, nil
}