http utils for protobuf/json

json_utils.go

package main

import (
    "encoding/json"
    "io/ioutil"
    "log"
    "net/http"
    "strconv"
)

func readJson(r *http.Request, v interface{}) bool {
    defer r.Body.Close()

    var (
        body []byte
        err  error
    )

    body, err = ioutil.ReadAll(r.Body)

    if err != nil {
        log.Printf("ReadJson couldn't read request body %v", err)
        return false
    }

    if err = json.Unmarshal(body, v); err != nil {
        log.Printf("ReadJson couldn't parse request body %v", err)
        return false
    }

    return true
}

func writeJson(w http.ResponseWriter, v interface{}) {
    // avoid json vulnerabilities, always wrap v in an object literal
    doc := map[string]interface{}{"d": v}

    if data, err := json.Marshal(doc); err != nil {
        log.Printf("Error marshalling json: %v", err)
    } else {
        w.Header().Set("Content-Length", strconv.Itoa(len(data)))
        w.Header().Set("Content-Type", "application/json")
        w.Write(data)
    }
}

proto_utils.go

package main

import (
    "code.google.com/p/goprotobuf/proto"
    "io/ioutil"
    "log"
    "net/http"
    "strconv"
)

func readProto(r *http.Request, v proto.Message) bool {
    defer r.Body.Close()

    body, err := ioutil.ReadAll(r.Body)
    if err != nil {
        log.Printf("Couldn't read request body %v", err)
        return false
    }

    if err = proto.Unmarshal(body, v); err != nil {
        log.Printf("Couldn't parse request body %v", err)
        return false
    }
    return true
}

func writeProto(w http.ResponseWriter, v proto.Message) {
    if data, err := proto.Marshal(v); err != nil {
        log.Printf("Error marshalling proto: %v", err)
    } else {
        w.Header().Set("Content-Length", strconv.Itoa(len(data)))
        w.Header().Set("Content-Type", "application/protobuf")
        w.Write(data)
    }

}