Add a package listing API to cipd.

go/src/infra/tools/cipd/remote.go

 // Copyright 2014 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"
         "encoding/json"
         "errors"
@@ skipping 400 matching lines @@
         case "SUCCESS":
                 return nil
         case "PROCESSING_NOT_FINISHED_YET":
                 return &pendingProcessingError{reply.ErrorMessage}
         case "ERROR", "PROCESSING_FAILED":
                 return errors.New(reply.ErrorMessage)
         }
         return fmt.Errorf("Unexpected status when attaching tags: %s", reply.Status)
 }
 
+func (r *remoteImpl) listPackages(prefix string) ([]string, error) {
+        endpoint, err := packageEndpoint(prefix)
+        if err != nil {
+                return nil, err
+        }
+        var reply struct {
+                Status       string   `json:"status"`
+                ErrorMessage string   `json:"error_message"`
+                Packages     []string `json:"packages"`
+        }
+        err = r.makeRequest(endpoint, "GET", nil, &reply)
+        if err != nil {
+                return nil, err
+        }
+        switch reply.Status {
+        case "SUCCESS":
+                out := reply.Packages
+                return out, nil
+        case "ERROR":
+                return nil, errors.New(reply.ErrorMessage)
+        }
+        return nil, fmt.Errorf("Unexpected list packages status: %s", reply.Status)
+}
+
 ////////////////////////////////////////////////////////////////////////////////
 
 func instanceEndpoint(pin common.Pin) (string, error) {
         err := common.ValidatePin(pin)
         if err != nil {
                 return "", err
         }
         params := url.Values{}
         params.Add("package_name", pin.PackageName)
         params.Add("instance_id", pin.InstanceID)
         return "repo/v1/instance?" + params.Encode(), nil
 }
 
 func aclEndpoint(packagePath string) (string, error) {
         err := common.ValidatePackageName(packagePath)
         if err != nil {
                 return "", err
         }
         params := url.Values{}
         params.Add("package_path", packagePath)
         return "repo/v1/acl?" + params.Encode(), nil
 }
 
+func packageEndpoint(prefix string) (string, error) {
+        params := url.Values{}
+        params.Add("prefix", prefix)
+        return "repo/v1/packages?" + params.Encode(), nil
+}
+
 func tagsEndpoint(pin common.Pin, tags []string) (string, error) {
         err := common.ValidatePin(pin)
         if err != nil {
                 return "", err
         }
         for _, tag := range tags {
                 err = common.ValidateInstanceTag(tag)
                 if err != nil {
                         return "", err
                 }
         }
         params := url.Values{}
         params.Add("package_name", pin.PackageName)
         params.Add("instance_id", pin.InstanceID)
         for _, tag := range tags {
                 params.Add("tag", tag)
         }
         return "repo/v1/tags?" + params.Encode(), nil
 }
 
 // convertTimestamp coverts string with int64 timestamp in microseconds since
 // to time.Time
 func convertTimestamp(ts string) (time.Time, error) {
         i, err := strconv.ParseInt(ts, 10, 64)
         if err != nil {
                 return time.Time{}, fmt.Errorf("Unexpected timestamp value '%s' in the server response", ts)
         }
         return time.Unix(0, i*1000), nil
 }