common/prpc, tools/cmd/cproto: prpc client

server/prpc/decoding_test.go

 // Copyright 2016 The Chromium Authors. All rights reserved.
 // Use of this source code is governed by a BSD-style license that can be
 // found in the LICENSE file.
 
 package prpc
 
 import (
         "bytes"
         "encoding/base64"
         "io/ioutil"
         "net/http"
         "testing"
         "time"
 
         "github.com/golang/protobuf/proto"
         "golang.org/x/net/context"
         "google.golang.org/grpc/metadata"
 
         "github.com/luci/luci-go/common/clock/testclock"
+        prpccommon "github.com/luci/luci-go/common/prpc"
 
         . "github.com/luci/luci-go/common/testing/assertions"
         . "github.com/smartystreets/goconvey/convey"
 )
 
 func TestDecoding(t *testing.T) {
         t.Parallel()
 
         Convey("requestFormat", t, func() {
                 test := func(contentType string, expectedFormat format, expectedErr interface{}) {
@@ skipping 108 matching lines @@
 
         Convey("parseHeader", t, func() {
                 c := context.Background()
 
                 header := func(name, value string) http.Header {
                         return http.Header{
                                 name: []string{value},
                         }
                 }
 
-                Convey(headerTimeout, func() {
+                Convey(prpccommon.HeaderTimeout, func() {
                         Convey("Works", func() {
                                 now := time.Date(2016, 1, 1, 0, 0, 0, 0, time.UTC)
                                 c, _ = testclock.UseTime(c, now)
 
-                                c, err := parseHeader(c, header(headerTimeout, "1M"))
+                                c, err := parseHeader(c, header(prpccommon.HeaderTimeout, "1M"))
                                 So(err, ShouldBeNil)
 
                                 deadline, ok := c.Deadline()
                                 So(ok, ShouldBeTrue)
                                 So(deadline, ShouldHappenWithin, time.Second, now.Add(time.Minute))
                         })
 
                         Convey("Fails", func() {
-                                c2, err := parseHeader(c, header(headerTimeout, "blah"))
+                                c2, err := parseHeader(c, header(prpccommon.HeaderTimeout, "blah"))
                                 So(c2, ShouldEqual, c)
-                                So(err, ShouldErrLike, headerTimeout+` header: unit is not recognized: "blah"`)
+                                So(err, ShouldErrLike, prpccommon.HeaderTimeout+` header: unit is not recognized: "blah"`)
                         })
                 })
 
                 Convey("Content-Type", func() {
                         c, err := parseHeader(c, header("Content-Type", "blah"))
                         So(err, ShouldBeNil)
                         _, ok := metadata.FromContext(c)
                         So(ok, ShouldBeFalse)
                 })
 
@@ skipping 44 matching lines @@
                                 })
                                 Convey("Fails", func() {
                                         c2, err := parseHeader(c, header("Name-Bin", "zzz"))
                                         So(c2, ShouldEqual, c)
                                         So(err, ShouldErrLike, "Name-Bin header: illegal base64 data at input byte 0")
                                 })
                         })
                 })
         })
 }