Merge pull request #201 from Bytom/v0.1

[bytom/vapor.git] / blockchain / txfeed / query.go

diff --git a/blockchain/txfeed/query.go b/blockchain/txfeed/query.go
deleted file mode 100644 (file)
index 49e74f5..0000000
--- a/blockchain/txfeed/query.go
+++ /dev/null
@@ -1,47 +0,0 @@
-package txfeed
-
-import (
-       "context"
-       //"database/sql"
-       //      "fmt"
-       //      "github.com/vapor/errors"
-)
-
-// 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.QueryContext(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
-       */
-       after = "qwertyu"
-       return nil, after, nil
-}