--- /dev/null
+package keep_utils
+
+// RESTRouterWrapper
+// LoggingResponseWriter
+
+import (
+ "github.com/gorilla/mux"
+ "log"
+ "net/http"
+)
+
+type LoggingResponseWriter struct {
+ status int
+ data []byte
+ http.ResponseWriter
+}
+
+func (loggingWriter *LoggingResponseWriter) WriteHeader(code int) {
+ loggingWriter.status = code
+ loggingWriter.ResponseWriter.WriteHeader(code)
+}
+
+func (loggingWriter *LoggingResponseWriter) Write(data []byte) (int, error){
+ loggingWriter.data = data
+ return loggingWriter.ResponseWriter.Write(data)
+}
+
+type RESTRouterWrapper struct {
+ router *mux.Router
+}
+
+func MakeRESTRouterWrapper(r *mux.Router) (RESTRouterWrapper) {
+ return (RESTRouterWrapper{r})
+}
+
+func (this RESTRouterWrapper) ServeHTTP(resp http.ResponseWriter, req *http.Request) {
+ loggingWriter := LoggingResponseWriter{200, nil, resp}
+ this.router.ServeHTTP(&loggingWriter, req)
+ if loggingWriter.data != nil && loggingWriter.status == 200 {
+ data_len := len(loggingWriter.data)
+ if data_len > 200 { // this could be a block, so just print the size
+ log.Printf("[%s] %s %s %d %d", req.RemoteAddr, req.Method, req.URL.Path[1:], loggingWriter.status, data_len)
+ } else { // this could be a hash or status or a small block etc
+ log.Printf("[%s] %s %s %d %s", req.RemoteAddr, req.Method, req.URL.Path[1:], loggingWriter.status, loggingWriter.data)
+ }
+ } else {
+ log.Printf("[%s] %s %s %d", req.RemoteAddr, req.Method, req.URL.Path[1:], loggingWriter.status)
+ }
+}
"strings"
"testing"
"time"
+ "git.curoverse.com/arvados.git/services/keep"
)
// A RequestTester represents the parameters for an HTTP request to
if rt.api_token != "" {
req.Header.Set("Authorization", "OAuth2 "+rt.api_token)
}
- routerWrapper := RESTRouterWrapper{router}
+ routerWrapper := keep_utils.MakeRESTRouterWrapper(router)
routerWrapper.ServeHTTP(response, req)
return response
}
func IsDataManagerToken(api_token string) bool {
return data_manager_token != "" && api_token == data_manager_token
}
-
-type LoggingResponseWriter struct {
- status int
- data []byte
- http.ResponseWriter
-}
-
-func (loggingWriter *LoggingResponseWriter) WriteHeader(code int) {
- loggingWriter.status = code
- loggingWriter.ResponseWriter.WriteHeader(code)
-}
-
-func (loggingWriter *LoggingResponseWriter) Write(data []byte) (int, error){
- loggingWriter.data = data
- return loggingWriter.ResponseWriter.Write(data)
-}
-
-type RESTRouterWrapper struct {
- router *mux.Router
-}
-
-func (wrapper *RESTRouterWrapper) ServeHTTP(resp http.ResponseWriter, req *http.Request) {
- loggingWriter := LoggingResponseWriter{200, nil, resp}
- wrapper.router.ServeHTTP(&loggingWriter, req)
- if loggingWriter.data != nil && loggingWriter.status == 200 {
- data_len := len(loggingWriter.data)
- if data_len > 200 { // this could be a block, so just print the size
- log.Printf("[%s] %s %s %d %d", req.RemoteAddr, req.Method, req.URL.Path[1:], loggingWriter.status, data_len)
- } else { // this could be a hash or status or a small block etc
- log.Printf("[%s] %s %s %d %s", req.RemoteAddr, req.Method, req.URL.Path[1:], loggingWriter.status, loggingWriter.data)
- }
- } else {
- log.Printf("[%s] %s %s %d", req.RemoteAddr, req.Method, req.URL.Path[1:], loggingWriter.status)
- }
-}
"strings"
"syscall"
"time"
+ "git.curoverse.com/arvados.git/services/keep"
)
// ======================
KeepVM = MakeRRVolumeManager(goodvols)
// Tell the built-in HTTP server to direct all requests to the REST router.
- routerWrapper := RESTRouterWrapper{MakeRESTRouter()}
+ routerWrapper := keep_utils.MakeRESTRouterWrapper(MakeRESTRouter())
http.HandleFunc("/", func(resp http.ResponseWriter, req *http.Request) {
routerWrapper.ServeHTTP(resp, req)
})