Drover's back, baby!

go/src/infra/libs/gitiles/priv_objRequest.go

Index: go/src/infra/libs/gitiles/priv_objRequest.go
diff --git a/go/src/infra/libs/gitiles/priv_objRequest.go b/go/src/infra/libs/gitiles/priv_objRequest.go
new file mode 100644
index 0000000000000000000000000000000000000000..58e16d2a4ef803d55f19ab7f93b84fe32e3f5dee
--- /dev/null
+++ b/go/src/infra/libs/gitiles/priv_objRequest.go
@@ -0,0 +1,52 @@
+// 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 (
+	"fmt"
+	"infra/libs/git"
+	"net/http"
+)
+
+// Types ///////////////////////////////////////////////////////////////////////
+
+type objRequest struct {
+	textRequest
+	resultChan chan<- objectResult
+}
+
+type objectResult struct {
+	err    error
+	object git.InternableObject
+}
+
+// Vars ////////////////////////////////////////////////////////////////////////
+
+var dataLoader = map[string]func([]byte) (git.InternableObject, error){
+	"blob":   func(d []byte) (git.InternableObject, error) { return git.NewBlobFromRaw(d), nil },
+	"tree":   func(d []byte) (git.InternableObject, error) { return git.NewTreeFromText(d) },
+	"commit": func(d []byte) (git.InternableObject, error) { return git.NewCommitFromRaw(d) },
+}
+
+// Member functions ////////////////////////////////////////////////////////////
+
+func (o objRequest) Process(rsp *http.Response, err error) {
+	var rslt objectResult
+
+	data, err := o.internalProcess(rsp, err)
+	if err != nil {
+		rslt.err = err
+	} else {
+		typ := rsp.Header.Get("X-Gitiles-Object-Type")
+		loader, ok := dataLoader[typ]
+		if !ok {
+			rslt.err = fmt.Errorf("Unknown object type %#v", typ)
+		} else {
+			rslt.object, rslt.err = loader(data)
+		}
+	}
+
+	o.resultChan <- rslt
+}