112 lines
3.8 KiB
Go
112 lines
3.8 KiB
Go
package main
|
|
|
|
import (
|
|
"encoding/json"
|
|
"fmt"
|
|
"github.com/elazarl/go-bindata-assetfs"
|
|
"github.com/gorilla/mux"
|
|
"io/ioutil"
|
|
"net/http"
|
|
)
|
|
|
|
type WebProvider struct {
|
|
Address string
|
|
}
|
|
|
|
type Page struct {
|
|
Configuration Configuration
|
|
}
|
|
|
|
func (provider *WebProvider) Provide(configurationChan chan<- *Configuration) {
|
|
systemRouter := mux.NewRouter()
|
|
systemRouter.Methods("GET").Path("/").Handler(http.HandlerFunc(GetHtmlConfigHandler))
|
|
systemRouter.Methods("GET").Path("/health").Handler(http.HandlerFunc(GetHealthHandler))
|
|
systemRouter.Methods("GET").Path("/api").Handler(http.HandlerFunc(GetConfigHandler))
|
|
systemRouter.Methods("PUT").Path("/api").Handler(http.HandlerFunc(
|
|
func(rw http.ResponseWriter, r *http.Request) {
|
|
configuration := new(Configuration)
|
|
b, _ := ioutil.ReadAll(r.Body)
|
|
err := json.Unmarshal(b, configuration)
|
|
if err == nil {
|
|
configurationChan <- configuration
|
|
GetConfigHandler(rw, r)
|
|
} else {
|
|
log.Error("Error parsing configuration %+v\n", err)
|
|
http.Error(rw, fmt.Sprintf("%+v", err), http.StatusBadRequest)
|
|
}
|
|
}))
|
|
systemRouter.Methods("GET").Path("/api/backends").Handler(http.HandlerFunc(GetBackendsHandler))
|
|
systemRouter.Methods("GET").Path("/api/backends/{backend}").Handler(http.HandlerFunc(GetBackendHandler))
|
|
systemRouter.Methods("GET").Path("/api/backends/{backend}/servers").Handler(http.HandlerFunc(GetServersHandler))
|
|
systemRouter.Methods("GET").Path("/api/backends/{backend}/servers/{server}").Handler(http.HandlerFunc(GetServerHandler))
|
|
systemRouter.Methods("GET").Path("/api/frontends").Handler(http.HandlerFunc(GetFrontendsHandler))
|
|
systemRouter.Methods("GET").Path("/api/frontends/{frontend}").Handler(http.HandlerFunc(GetFrontendHandler))
|
|
systemRouter.Methods("GET").PathPrefix("/static/").Handler(http.StripPrefix("/static/", http.FileServer(&assetfs.AssetFS{Asset: Asset, AssetDir: AssetDir, Prefix: "static"})))
|
|
|
|
go http.ListenAndServe(provider.Address, systemRouter)
|
|
}
|
|
|
|
func GetConfigHandler(rw http.ResponseWriter, r *http.Request) {
|
|
templatesRenderer.JSON(rw, http.StatusOK, currentConfiguration)
|
|
}
|
|
|
|
func GetHtmlConfigHandler(response http.ResponseWriter, request *http.Request) {
|
|
templatesRenderer.HTML(response, http.StatusOK, "configuration", Page{Configuration: *currentConfiguration})
|
|
}
|
|
|
|
func GetHealthHandler(rw http.ResponseWriter, r *http.Request) {
|
|
templatesRenderer.JSON(rw, http.StatusOK, metrics.Data())
|
|
}
|
|
|
|
func GetBackendsHandler(rw http.ResponseWriter, r *http.Request) {
|
|
templatesRenderer.JSON(rw, http.StatusOK, currentConfiguration.Backends)
|
|
}
|
|
|
|
func GetBackendHandler(rw http.ResponseWriter, r *http.Request) {
|
|
vars := mux.Vars(r)
|
|
id := vars["backend"]
|
|
if backend, ok := currentConfiguration.Backends[id]; ok {
|
|
templatesRenderer.JSON(rw, http.StatusOK, backend)
|
|
}else{
|
|
http.NotFound(rw, r)
|
|
}
|
|
}
|
|
|
|
func GetFrontendsHandler(rw http.ResponseWriter, r *http.Request) {
|
|
templatesRenderer.JSON(rw, http.StatusOK, currentConfiguration.Frontends)
|
|
}
|
|
|
|
func GetFrontendHandler(rw http.ResponseWriter, r *http.Request) {
|
|
vars := mux.Vars(r)
|
|
id := vars["frontend"]
|
|
if frontend, ok := currentConfiguration.Frontends[id]; ok {
|
|
templatesRenderer.JSON(rw, http.StatusOK, frontend)
|
|
}else{
|
|
http.NotFound(rw, r)
|
|
}
|
|
}
|
|
|
|
func GetServersHandler(rw http.ResponseWriter, r *http.Request) {
|
|
vars := mux.Vars(r)
|
|
backend := vars["backend"]
|
|
if backend, ok := currentConfiguration.Backends[backend]; ok {
|
|
templatesRenderer.JSON(rw, http.StatusOK, backend.Servers)
|
|
}else{
|
|
http.NotFound(rw, r)
|
|
}
|
|
}
|
|
|
|
func GetServerHandler(rw http.ResponseWriter, r *http.Request) {
|
|
vars := mux.Vars(r)
|
|
backend := vars["backend"]
|
|
server := vars["server"]
|
|
if backend, ok := currentConfiguration.Backends[backend]; ok {
|
|
if server, ok := backend.Servers[server]; ok {
|
|
templatesRenderer.JSON(rw, http.StatusOK, server)
|
|
}else{
|
|
http.NotFound(rw, r)
|
|
}
|
|
}else{
|
|
http.NotFound(rw, r)
|
|
}
|
|
}
|