Add a package listing API to cipd.

go/src/infra/tools/cipd/client_test.go

 // Copyright 2015 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 cipd
 
 import (
         "bytes"
         "fmt"
         "io"
@@ skipping 349 matching lines @@
                 _, err := call(c, "pkg/a 0000", nil)
                 So(err, ShouldNotBeNil)
         })
 
         Convey("ProcessEnsureFile bad line", t, func(c C) {
                 _, err := call(c, "pkg/a", nil)
                 So(err, ShouldNotBeNil)
         })
 }
 
+func TestListPackages(t *testing.T) {
+        call := func(c C, dirPath string, recursive bool, calls []expectedHTTPCall) ([]string, error) {
+                client := mockClient(c, "", calls)
+                return client.ListPackages(dirPath, recursive)
+        }
+
+        Convey("ListPackages merges directories", t, func(c C) {
+                out, err := call(c, "", true, []expectedHTTPCall{
+                        {
+                                Method: "GET",
+                                Path:   "/_ah/api/repo/v1/package/search",
+                                Query: url.Values{
+                                        "path":      []string{""},
+                                        "recursive": []string{"true"},
+                                },
+                                Reply: `{"status":"SUCCESS","packages":["dir/pkg"],"directories":["dir"]}`,
+                        },
+                })
+                So(err, ShouldBeNil)
+                So(out, ShouldResemble, []string{"dir/", "dir/pkg"})
+        })
+}
+
 func TestEnsurePackages(t *testing.T) {
         Convey("Mocking temp dir", t, func() {
                 tempDir, err := ioutil.TempDir("", "cipd_test")
                 So(err, ShouldBeNil)
                 Reset(func() { os.RemoveAll(tempDir) })
 
                 assertFile := func(relPath, data string) {
                         body, err := ioutil.ReadFile(filepath.Join(tempDir, relPath))
                         So(err, ShouldBeNil)
                         So(string(body), ShouldEqual, data)
@@ skipping 266 matching lines @@
                                 w.Header().Add(k, s)
                         }
                 }
                 w.WriteHeader(exp.Status)
         }
         if exp.Reply != "" {
                 w.Write([]byte(exp.Reply))
         }
         s.index++
 }