mirror of https://github.com/helm/helm
You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
92 lines
3.1 KiB
92 lines
3.1 KiB
/*
|
|
Copyright 2015 The Kubernetes Authors All rights reserved.
|
|
Licensed under the Apache License, Version 2.0 (the "License");
|
|
you may not use this file except in compliance with the License.
|
|
You may obtain a copy of the License at
|
|
http://www.apache.org/licenses/LICENSE-2.0
|
|
Unless required by applicable law or agreed to in writing, software
|
|
distributed under the License is distributed on an "AS IS" BASIS,
|
|
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
|
See the License for the specific language governing permissions and
|
|
limitations under the License.
|
|
*/
|
|
|
|
package service
|
|
|
|
import (
|
|
"github.com/kubernetes/deployment-manager/expandybird/expander"
|
|
"github.com/kubernetes/deployment-manager/util"
|
|
|
|
"errors"
|
|
"fmt"
|
|
"net/http"
|
|
|
|
restful "github.com/emicklei/go-restful"
|
|
)
|
|
|
|
// A Service wraps a web service that performs template expansion.
|
|
type Service struct {
|
|
*restful.WebService
|
|
}
|
|
|
|
// NewService creates and returns a new Service, initalized with a new
|
|
// restful.WebService configured with a route that dispatches to the supplied
|
|
// handler. The new Service must be registered before accepting traffic by
|
|
// calling Register.
|
|
func NewService(handler restful.RouteFunction) *Service {
|
|
restful.EnableTracing(true)
|
|
webService := new(restful.WebService)
|
|
webService.Consumes(restful.MIME_JSON, restful.MIME_XML)
|
|
webService.Produces(restful.MIME_JSON, restful.MIME_XML)
|
|
webService.Route(webService.POST("/expand").To(handler).
|
|
Doc("Expand a template.").
|
|
Reads(&expander.Template{}))
|
|
return &Service{webService}
|
|
}
|
|
|
|
// Register adds the web service wrapped by the Service to the supplied
|
|
// container. If the supplied container is nil, then the default container is
|
|
// used, instead.
|
|
func (s *Service) Register(container *restful.Container) {
|
|
if container == nil {
|
|
container = restful.DefaultContainer
|
|
}
|
|
|
|
container.Add(s.WebService)
|
|
}
|
|
|
|
// NewExpansionHandler returns a route function that handles an incoming
|
|
// template expansion request, bound to the supplied expander.
|
|
func NewExpansionHandler(backend expander.Expander) restful.RouteFunction {
|
|
return func(req *restful.Request, resp *restful.Response) {
|
|
util.LogHandlerEntry("expandybird: expand", req.Request)
|
|
template := &expander.Template{}
|
|
if err := req.ReadEntity(&template); err != nil {
|
|
logAndReturnErrorFromHandler(http.StatusBadRequest, err.Error(), resp)
|
|
return
|
|
}
|
|
|
|
output, err := backend.ExpandTemplate(template)
|
|
if err != nil {
|
|
message := fmt.Sprintf("error expanding template: %s", err)
|
|
logAndReturnErrorFromHandler(http.StatusBadRequest, message, resp)
|
|
return
|
|
}
|
|
|
|
response, err := expander.NewExpansionResponse(output)
|
|
if err != nil {
|
|
message := fmt.Sprintf("error marshaling output: %s", err)
|
|
logAndReturnErrorFromHandler(http.StatusBadRequest, message, resp)
|
|
return
|
|
}
|
|
|
|
util.LogHandlerExit("expandybird", http.StatusOK, "OK", resp.ResponseWriter)
|
|
resp.WriteEntity(response)
|
|
}
|
|
}
|
|
|
|
func logAndReturnErrorFromHandler(statusCode int, message string, resp *restful.Response) {
|
|
util.LogHandlerExit("expandybird: expand", statusCode, message, resp.ResponseWriter)
|
|
resp.WriteError(statusCode, errors.New(message))
|
|
}
|