Drover's back, baby!

go/src/infra/libs/gitiles/priv_jsonRequest.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 gitiles
+
+import (
+        "bufio"
+        "bytes"
+        "encoding/json"
+        "io"
+        "net/http"
+        "reflect"
+)
+
+// Private /////////////////////////////////////////////////////////////////////
+
+// Types ///////////////////////////////////////////////////////////////////////
+
+type jsonResult struct {
+        err     error
+        dataPtr interface{}
+}
+
+type jsonRequest struct {
+        urlPath    string
+        typ        reflect.Type
+        resultChan chan<- jsonResult
+}
+
+// Member functions ////////////////////////////////////////////////////////////
+
+func (j jsonRequest) URLPath() string { return j.urlPath + "?format=JSON" }
+func (j jsonRequest) Method() string  { return "GET" }
+func (j jsonRequest) Body() io.Reader { return nil }
+
+func (j jsonRequest) Process(resp *http.Response, err error) {
+        var rslt jsonResult
+        if err != nil {
+                rslt.err = err
+        } else {
+                bufreader := bufio.NewReader(resp.Body)
+                firstFour, err := bufreader.Peek(4)
+                if err != nil {
+                        rslt.err = err
+                } else {
+                        if bytes.Equal(firstFour, []byte(")]}'")) {
+                                bufreader.Read(make([]byte, 4))
+                        }
+
+                        data := reflect.New(j.typ).Interface()
+                        err = json.NewDecoder(bufreader).Decode(data)
+                        if err != nil {
+                                rslt.err = err
+                        } else {
+                                rslt.dataPtr = data
+                        }
+                }
+        }
+        j.resultChan <- rslt
+}