diff --git a/client/example/client.go b/client/example/client.go index f041c16..5f29d15 100644 --- a/client/example/client.go +++ b/client/example/client.go @@ -20,6 +20,7 @@ import ( "fmt" fabcli "github.com/hyperledger-labs/fabex/client" "github.com/hyperledger-labs/fabex/helpers" + pb "github.com/hyperledger-labs/fabex/proto" "log" ) @@ -42,9 +43,9 @@ func main() { //txs, err := client.GetRange(1, 15) //txs, err := client.Get(&pb.Entry{Txid:"3a3e933a3d9953b0b10e6573254b6d3cf2347d72058c0347a55054babdd8e1a1"}) - //txs, err := client.Get(&pb.Entry{Payload: "WriteSet"}) - //txs, err := client.Get(&pb.Entry{Blocknum: 5}) - txs, err := client.Get(nil) + //txs, err := client.Get(&pb.Entry{Payload: "car0"}) + //txs, err := client.Get(nil) + txs, err := client.Get(&pb.Entry{Blocknum: 5}) if err != nil { log.Fatal(err) } diff --git a/client/fabex_client_test.go b/client/fabex_client_test.go index b5f740a..8ec68c2 100644 --- a/client/fabex_client_test.go +++ b/client/fabex_client_test.go @@ -144,7 +144,13 @@ func TestGet(t *testing.T) { } assert.Greater(t, len(txs), 0, "No transactions found") - txs, err = fabcli.Get(&pb.Entry{Payload: "WriteSet"}) + txs, err = fabcli.Get(&pb.Entry{Payload: "car0"}) + if err != nil { + t.Errorf(err.Error()) + } + assert.Greater(t, len(txs), 0, "No transactions found") + + txs, err = fabcli.Get(nil) if err != nil { t.Errorf(err.Error()) } diff --git a/db/mongodb.go b/db/mongodb.go index 7ea1b23..2e7d7dc 100644 --- a/db/mongodb.go +++ b/db/mongodb.go @@ -111,7 +111,7 @@ func (db *DBmongo) GetByBlocknum(blocknum uint64) ([]Tx, error) { } func (db *DBmongo) GetBlockInfoByPayload(payload string) ([]Tx, error) { - return db.getByFilter(bson.D{{"Payload", primitive.Regex{Pattern: payload, Options: ""}}}) + return db.getByFilter(bson.D{{"Payload", primitive.Regex{Pattern: payload, Options: "i"}}}) } func (db *DBmongo) QueryAll() ([]Tx, error) { diff --git a/rest/router_test.go b/rest/router_test.go index b135ba4..afb3837 100644 --- a/rest/router_test.go +++ b/rest/router_test.go @@ -170,7 +170,7 @@ func TestEndpoints(t *testing.T) { }) t.Run("bykey", func(t *testing.T) { - resp, err := http.Get("http://localhost:5252/bykey/WriteSet") + resp, err := http.Get("http://localhost:5252/bykey/car0") if err != nil { t.Errorf(err.Error()) }