Initial distributor implementation

appengine/cmd/dm/mutate/merge_quest_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"
         "github.com/luci/gae/service/datastore"
         "github.com/luci/luci-go/appengine/cmd/dm/model"
         "github.com/luci/luci-go/appengine/tumble"
         "github.com/luci/luci-go/common/api/dm/service/v1"
         . "github.com/luci/luci-go/common/testing/assertions"
         . "github.com/smartystreets/goconvey/convey"
 )
 
 func TestMergeQuest(t *testing.T) {
         t.Parallel()
 
         Convey("MergeQuest", t, func() {
                 ttest := &tumble.Testing{}
                 c := ttest.Context()
                 ds := datastore.Get(c)
 
-                desc := dm.NewQuestDesc("distributor", `{"data":"yes"}`)
-                qst, err := model.NewQuest(c, desc)
-                So(err, ShouldBeNil)
+                desc := dm.NewQuestDesc("distributor", `{"data":"yes"}`, nil)
+                So(desc.Normalize(), ShouldBeNil)
+                qst := model.NewQuest(c, desc)
                 qst.BuiltBy = append(qst.BuiltBy, *dm.NewTemplateSpec("a", "b", "c", "d"))
 
-                mq := &MergeQuest{qst}
+                mq := &MergeQuest{qst, nil}
 
                 Convey("root", func() {
                         So(mq.Root(c), ShouldResemble, ds.MakeKey("Quest", qst.ID))
                 })
 
                 Convey("quest doesn't exist", func() {
                         muts, err := mq.RollForward(c)
                         So(err, ShouldBeNil)
                         So(muts, ShouldBeEmpty)
 
@@ skipping 27 matching lines @@
                         Convey("datastore fail", func() {
                                 c, fb := featureBreaker.FilterRDS(c, nil)
                                 fb.BreakFeatures(nil, "GetMulti")
                                 _, err := mq.RollForward(c)
                                 So(err, ShouldBeRPCUnknown)
                         })
                 })
 
         })
 }