handlers.go

package voltoolshttp

import (
	"encoding/json"
	"io/ioutil"
	"net/http"

	cf_http_handlers "code.cloudfoundry.org/cfhttp/handlers"
	"code.cloudfoundry.org/dockerdriver/driverhttp"
	"code.cloudfoundry.org/efsdriver/efsvoltools"
	"code.cloudfoundry.org/lager"
	"github.com/tedsuo/rata"
)

func NewHandler(logger lager.Logger, client efsvoltools.VolTools) (http.Handler, error) {
	logger = logger.Session("server")
	logger.Info("start")
	defer logger.Info("end")

	var handlers = rata.Handlers{
		efsvoltools.OpenPermsRoute: newOpenPermsHandler(logger, client),
	}

	return rata.NewRouter(efsvoltools.Routes, handlers)
}

func newOpenPermsHandler(logger lager.Logger, client efsvoltools.VolTools) http.HandlerFunc {
	return func(w http.ResponseWriter, req *http.Request) {
		logger := logger.Session("handle-open-perms")
		logger.Info("start")
		defer logger.Info("end")

		body, err := ioutil.ReadAll(req.Body)
		if err != nil {
			logger.Error("failed-reading-request-body", err)
			cf_http_handlers.WriteJSONResponse(w, http.StatusBadRequest, efsvoltools.ErrorResponse{Err: err.Error()})
			return
		}

		var request efsvoltools.OpenPermsRequest
		if err = json.Unmarshal(body, &request); err != nil {
			logger.Error("failed-unmarshalling-request-body", err)
			cf_http_handlers.WriteJSONResponse(w, http.StatusBadRequest, efsvoltools.ErrorResponse{Err: err.Error()})
			return
		}
		env := driverhttp.EnvWithMonitor(logger, req.Context(), w)

		openPermsResponse := client.OpenPerms(env, request)
		if openPermsResponse.Err != "" {
			logger.Error("failed-modifying-permissions", err, lager.Data{"volume": request.Name})
			cf_http_handlers.WriteJSONResponse(w, http.StatusInternalServerError, openPermsResponse)
			return
		}

		cf_http_handlers.WriteJSONResponse(w, http.StatusOK, openPermsResponse)
	}
}