store/bigtable: fix range limits

Author: Tangui-Bitfly

db2/raw.go

@@ -131,7 +131,7 @@ func (db RawStore) parseRow(chainID uint64, number int64, data map[string][]byte
 }
 
 func (db RawStore) ReadBlocksByNumber(chainID uint64, start, end int64) ([]*FullBlockRawData, error) {
-	rows, err := db.store.GetRowsRange(blockKey(chainID, start-1), blockKey(chainID, end))
+	rows, err := db.store.GetRowsRange(blockKey(chainID, start), blockKey(chainID, end))
 	if err != nil {
 		return nil, err
 	}

db2/store/bigtable.go

@@ -263,7 +263,7 @@ func (b BigTableStore) GetRowsRange(table, high, low string) (map[string]map[str
 	ctx, cancel := context.WithTimeout(context.Background(), timeout)
 	defer cancel()
 
-	rowRange := bigtable.NewRange(low, high)
+	rowRange := bigtable.NewClosedRange(low, high)
 	data := make(map[string]map[string][]byte)
 	err := tbl.ReadRows(ctx, rowRange, func(row bigtable.Row) bool {
 		data[row.Key()] = make(map[string][]byte)

db2/store/bigtable_test.go

@@ -169,3 +169,24 @@ func TestBigTableStore(t *testing.T) {
 		t.Errorf("cannot close db: %v", err)
 	}
 }
+
+func TestRangeIncludeLimits(t *testing.T) {
+	tables := map[string][]string{"testTable": {"testFamily"}}
+	client, admin := storetest.NewBigTable(t)
+	store, err := NewBigTableWithClient(context.Background(), client, admin, tables)
+	if err != nil {
+		t.Fatal(err)
+	}
+	db := Wrap(store, "testTable", "testFamily")
+
+	db.Add("1:999999999999", "", []byte("0"), false)
+	db.Add("1:999999999998", "", []byte("1"), false)
+
+	rows, err := db.GetRowsRange("1:999999999999", "1:999999999998")
+	if err != nil {
+		t.Fatal(err)
+	}
+	if got, want := len(rows), 2; got != want {
+		t.Errorf("got %v want %v", got, want)
+	}
+}