// -------------------------------------------------------------
// Only the superuser should be allowed to issue /index requests.
- // ---------------------------
- // enforce_permissions enabled
+ // ---------------------------
+ // enforce_permissions enabled
// This setting should not affect tests passing.
- enforce_permissions = true
+ enforce_permissions = true
// unauthenticated /index request
// => UnauthorizedError
http.StatusOK,
response)
-
-
expected := `^` + TEST_HASH + `\+\d+ \d+\n` +
TEST_HASH_2 + `\+\d+ \d+\n$`
match, _ := regexp.MatchString(expected, response.Body.String())
if rt.api_token != "" {
req.Header.Set("Authorization", "OAuth2 "+rt.api_token)
}
- loggingRouter := MakeLoggingRESTRouter()
- loggingRouter.ServeHTTP(response, req)
+ loggingRouter := MakeLoggingRESTRouter()
+ loggingRouter.ServeHTTP(response, req)
return response
}
KeepVM = MakeRRVolumeManager(goodvols)
// Tell the built-in HTTP server to direct all requests to the REST router.
- loggingRouter := MakeLoggingRESTRouter()
- http.HandleFunc("/", func(resp http.ResponseWriter, req *http.Request) {
- loggingRouter.ServeHTTP(resp, req)
- })
+ loggingRouter := MakeLoggingRESTRouter()
+ http.HandleFunc("/", func(resp http.ResponseWriter, req *http.Request) {
+ loggingRouter.ServeHTTP(resp, req)
+ })
// Set up a TCP listener.
listener, err := net.Listen("tcp", listen)
)
type LoggingResponseWriter struct {
- Status int
- Length int
- http.ResponseWriter
+ Status int
+ Length int
+ http.ResponseWriter
}
func (loggingWriter *LoggingResponseWriter) WriteHeader(code int) {
- loggingWriter.Status = code
- loggingWriter.ResponseWriter.WriteHeader(code)
+ loggingWriter.Status = code
+ loggingWriter.ResponseWriter.WriteHeader(code)
}
-func (loggingWriter *LoggingResponseWriter) Write(data []byte) (int, error){
- loggingWriter.Length = len(data)
- return loggingWriter.ResponseWriter.Write(data)
+func (loggingWriter *LoggingResponseWriter) Write(data []byte) (int, error) {
+ loggingWriter.Length = len(data)
+ return loggingWriter.ResponseWriter.Write(data)
}
type LoggingRESTRouter struct {
- router *mux.Router
+ router *mux.Router
}
-func MakeLoggingRESTRouter() (*LoggingRESTRouter) {
- router := MakeRESTRouter()
- return (&LoggingRESTRouter{router})
+func MakeLoggingRESTRouter() *LoggingRESTRouter {
+ router := MakeRESTRouter()
+ return (&LoggingRESTRouter{router})
}
func (loggingRouter *LoggingRESTRouter) ServeHTTP(resp http.ResponseWriter, req *http.Request) {
- loggingWriter := LoggingResponseWriter{200, 0, resp}
- loggingRouter.router.ServeHTTP(&loggingWriter, req)
- if loggingWriter.Status == 200 {
- log.Printf("[%s] %s %s %d %d", req.RemoteAddr, req.Method, req.URL.Path[1:], loggingWriter.Status, loggingWriter.Length)
- } else {
- log.Printf("[%s] %s %s %d", req.RemoteAddr, req.Method, req.URL.Path[1:], loggingWriter.Status)
- }
+ loggingWriter := LoggingResponseWriter{200, 0, resp}
+ loggingRouter.router.ServeHTTP(&loggingWriter, req)
+ if loggingWriter.Status == 200 {
+ log.Printf("[%s] %s %s %d %d", req.RemoteAddr, req.Method, req.URL.Path[1:], loggingWriter.Status, loggingWriter.Length)
+ } else {
+ log.Printf("[%s] %s %s %d", req.RemoteAddr, req.Method, req.URL.Path[1:], loggingWriter.Status)
+ }
}