Initial distributor implementation

appengine/cmd/dm/mutate/add_finished_deps_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/impl/memory"
@@ skipping 15 matching lines @@
                 f := &AddFinishedDeps{
                         &dm.Execution_Auth{
                                 Id:    dm.NewExecutionID("quest", 1, 7),
                                 Token: []byte("sup"),
                         },
                         []*model.Quest{
                                 {
                                         ID: "to",
                                         BuiltBy: model.TemplateInfo{
                                                 *dm.NewTemplateSpec("a", "b", "c", "d"),
-                                        }},
+                                        },
+                                },
                         },
                         dm.NewAttemptList(map[string][]uint32{
                                 "to": {1, 2, 3},
                         }),
                 }
 
                 base := f.Auth.Id.AttemptID()
                 fs := model.FwdDepsFromList(c, base, f.FinishedAttempts)
 
                 ds := datastore.Get(c)
@@ skipping 16 matching lines @@
                                 datastore.ErrNoSuchEntity,
                                 nil,
                                 datastore.ErrNoSuchEntity,
                         })
 
                         muts, err := f.RollForward(c)
                         So(err, ShouldBeNil)
                         So(muts, ShouldResemble, []tumble.Mutation{
                                 &AddBackDep{Dep: fs[0].Edge()},
                                 &AddBackDep{Dep: fs[2].Edge()},
-                                &MergeQuest{f.MergeQuests[0]},
+                                &MergeQuest{f.MergeQuests[0], nil},
                         })
 
                         So(ds.Get(fs), ShouldBeNil)
                         So(fs[0].ForExecution, ShouldEqual, 7)
                         So(fs[1].ForExecution, ShouldEqual, 1)
                         So(fs[2].ForExecution, ShouldEqual, 7)
 
                         muts, err = f.RollForward(c)
                         So(err, ShouldBeNil)
                         So(muts, ShouldBeEmpty)
                 })
 
                 Convey("RollForward (bad)", func() {
                         So(ds.Delete(ak), ShouldBeNil)
                         _, err := f.RollForward(c)
-                        So(err, ShouldBeRPCUnauthenticated, "execution Auth")
+                        So(err, ShouldBeRPCInternal, "execution Auth")
                 })
         })
 }