Index: filter/count/count_test.go |
diff --git a/filter/count/count_test.go b/filter/count/count_test.go |
index a5205db46e60382a76636245639660146e7963e5..28edc53034d9815ef928964896727fdf659693d4 100644 |
--- a/filter/count/count_test.go |
+++ b/filter/count/count_test.go |
@@ -21,14 +21,6 @@ import ( |
func TestCount(t *testing.T) { |
t.Parallel() |
- pnil := func(_ datastore.Key, err error) { |
- So(err, ShouldBeNil) |
- } |
- |
- gnil := func(_ datastore.PropertyMap, err error) { |
- So(err, ShouldBeNil) |
- } |
- |
Convey("Test Count filter", t, func() { |
c, fb := featureBreaker.FilterRDS(memory.Use(context.Background()), nil) |
c, ctr := FilterRDS(c) |
@@ -37,31 +29,24 @@ func TestCount(t *testing.T) { |
So(ctr, ShouldNotBeNil) |
ds := datastore.Get(c) |
+ vals := []datastore.PropertyMap{{ |
+ "Val": {datastore.MkProperty(100)}, |
+ "$key": {datastore.MkPropertyNI(ds.NewKey("Kind", "", 1, nil))}, |
+ }} |
Convey("Calling a ds function should reflect in counter", func() { |
- p := datastore.Property{} |
- p.SetValue(100, false) |
- keys := []datastore.Key{ds.NewKey("Kind", "", 0, nil)} |
- vals := []datastore.PropertyLoadSaver{&datastore.PropertyMap{"Val": {p}}} |
- |
- So(ds.PutMulti(keys, vals, pnil), ShouldBeNil) |
+ So(ds.PutMulti(vals), ShouldBeNil) |
So(ctr.NewKey.Successes, ShouldEqual, 1) |
So(ctr.PutMulti.Successes, ShouldEqual, 1) |
Convey("effects are cumulative", func() { |
- So(ds.PutMulti(keys, vals, pnil), ShouldBeNil) |
+ So(ds.PutMulti(vals), ShouldBeNil) |
So(ctr.PutMulti.Successes, ShouldEqual, 2) |
Convey("even within transactions", func() { |
- root := ds.NewKey("Root", "", 1, nil) |
ds.RunInTransaction(func(c context.Context) error { |
ds := datastore.Get(c) |
- keys := []datastore.Key{ |
- ds.NewKey("Kind", "hi", 0, root), |
- ds.NewKey("Kind", "there", 0, root), |
- } |
- vals = append(vals, vals[0]) |
- So(ds.PutMulti(keys, vals, pnil), ShouldBeNil) |
+ So(ds.PutMulti(append(vals, vals[0])), ShouldBeNil) |
return nil |
}, nil) |
}) |
@@ -69,23 +54,16 @@ func TestCount(t *testing.T) { |
}) |
Convey("errors count against errors", func() { |
- keys := []datastore.Key{ds.NewKey("Kind", "", 1, nil)} |
- vals := []datastore.PropertyLoadSaver{&datastore.PropertyMap{"Val": {{}}}} |
- |
fb.BreakFeatures(nil, "GetMulti") |
- ds.GetMulti(keys, gnil) |
+ ds.GetMulti(vals) |
So(ctr.GetMulti.Errors, ShouldEqual, 1) |
fb.UnbreakFeatures("GetMulti") |
- err := ds.PutMulti(keys, vals, func(k datastore.Key, err error) { |
- keys[0] = k |
- So(err, ShouldBeNil) |
- }) |
- So(err, ShouldBeNil) |
+ So(ds.PutMulti(vals), ShouldBeNil) |
- ds.GetMulti(keys, gnil) |
+ ds.GetMulti(vals) |
So(ctr.GetMulti.Errors, ShouldEqual, 1) |
So(ctr.GetMulti.Successes, ShouldEqual, 1) |
So(ctr.GetMulti.Total(), ShouldEqual, 2) |
@@ -146,13 +124,13 @@ func ExampleFilterRDS() { |
// that there are any filters at all. |
someCalledFunc := func(c context.Context) { |
ds := datastore.Get(c) |
- key := ds.NewKey("Kind", "", 1, nil) |
- prop := datastore.Property{} |
- prop.SetValue(100, false) |
- val := datastore.PropertyMap{ |
- "FieldName": {prop}, |
+ vals := []datastore.PropertyMap{{ |
+ "FieldName": {datastore.MkProperty(100)}, |
+ "$key": {datastore.MkProperty(ds.NewKey("Kind", "", 1, nil))}}, |
+ } |
+ if err := ds.PutMulti(vals); err != nil { |
+ panic(err) |
} |
- ds.PutMulti([]datastore.Key{key}, []datastore.PropertyLoadSaver{&val}, nil) |
} |
// Using the other function. |