Initial distributor implementation

appengine/cmd/dm/mutate/add_backdep_test.go

 // Copyright 2015 The LUCI Authors. All rights reserved.
 // Use of this source code is governed under the Apache License, Version 2.0
 // that can be found in the LICENSE file.
 
 package mutate
 
 import (
         "testing"
 
         "github.com/luci/gae/filter/featureBreaker"
@@ skipping 40 matching lines @@
 
                                         So(ds.GetMulti([]interface{}{bdg, bd}), ShouldBeNil)
                                         So(bd.Edge(), ShouldResemble, abd.Dep)
                                         So(bd.Propagated, ShouldBeTrue)
                                 })
 
                                 Convey("need completion", func() {
                                         abd.NeedsAck = true
                                         muts, err := abd.RollForward(c)
                                         So(err, ShouldBeNil)
-                                        So(muts, ShouldResemble, []tumble.Mutation{
-                                                &AckFwdDep{abd.Dep, true}})
+                                        So(muts, ShouldResemble, []tumble.Mutation{&AckFwdDep{abd.Dep}})
 
                                         So(ds.GetMulti([]interface{}{bdg, bd}), ShouldBeNil)
                                         So(bd.Edge(), ShouldResemble, abd.Dep)
                                         So(bd.Propagated, ShouldBeTrue)
                                 })
                         })
 
                         Convey("attempt not finished, need completion", func() {
                                 ex, err := ds.Exists(ds.KeyForObj(bdg))
                                 So(err, ShouldBeNil)
-                                So(ex, ShouldBeFalse)
+                                So(ex.Any(), ShouldBeFalse)
 
                                 abd.NeedsAck = true
                                 muts, err := abd.RollForward(c)
                                 So(err, ShouldBeNil)
-                                So(muts, ShouldResemble, []tumble.Mutation{
-                                        &AckFwdDep{abd.Dep, false}})
+                                So(muts, ShouldBeNil)
 
                                 // Note that bdg was created as a side effect.
                                 So(ds.GetMulti([]interface{}{bdg, bd}), ShouldBeNil)
                                 So(bd.Edge(), ShouldResemble, abd.Dep)
                                 So(bd.Propagated, ShouldBeFalse)
                                 So(bdg.AttemptFinished, ShouldBeFalse)
                         })
 
                         Convey("failure", func() {
                                 c, fb := featureBreaker.FilterRDS(c, nil)
                                 fb.BreakFeatures(nil, "PutMulti")
 
                                 _, err := abd.RollForward(c)
                                 So(err, ShouldErrLike, `feature "PutMulti" is broken`)
                         })
                 })
         })
 }