package main
import (
"encoding/json"
"net/http"
"rebootx-on-prem/http-server-go/resources/dashboard"
"rebootx-on-prem/http-server-go/resources/runnable"
"rebootx-on-prem/http-server-go/utils"
"github.com/gorilla/mux"
"openapi"
)
func getDashboardsHandler(service dashboard.Service) func(w http.ResponseWriter, r *http.Request) {
return http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
encoder := json.NewEncoder(w)
params := openapi.NewListDashboardsQueryParams()
query := r.URL.Query()
limitAsString := query.Get("limit")
limit := utils.ParseInt(&limitAsString)
if limit != nil {
params.SetLimit(*limit)
}
offsetAsString := query.Get("offset")
offset := utils.ParseInt(&offsetAsString)
if offset != nil {
params.SetOffset(*offset)
}
params.SetQ(query.Get("q"))
res, err := service.List(params)
if err != nil {
w.WriteHeader(err.HTTPStatus)
encoder.Encode(openapi.NewErrorRes(err.Error()))
return
}
encoder.Encode(res)
})
}
func getRunnablesHandler(service runnable.Service) func(w http.ResponseWriter, r *http.Request) {
return http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
encoder := json.NewEncoder(w)
params := openapi.NewListRunnablesQueryParams()
query := r.URL.Query()
limitAsString := query.Get("limit")
limit := utils.ParseInt(&limitAsString)
if limit != nil {
params.SetLimit(*limit)
}
offsetAsString := query.Get("offset")
offset := utils.ParseInt(&offsetAsString)
if offset != nil {
params.SetOffset(*offset)
}
params.SetQ(query.Get("q"))
res, err := service.List(params)
if err != nil {
w.WriteHeader(err.HTTPStatus)
encoder.Encode(openapi.NewErrorRes(err.Error()))
return
}
encoder.Encode(res)
})
}
func postRunnableRebootHandler(service runnable.Service) func(w http.ResponseWriter, r *http.Request) {
return http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
encoder := json.NewEncoder(w)
vars := mux.Vars(r)
id := vars["id"]
res, err := service.Reboot(id)
if err != nil {
w.WriteHeader(err.HTTPStatus)
encoder.Encode(openapi.NewErrorRes(err.Error()))
return
}
w.WriteHeader(http.StatusCreated)
encoder.Encode(res)
})
}
func postRunnableStopHandler(service runnable.Service) func(w http.ResponseWriter, r *http.Request) {
return http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
encoder := json.NewEncoder(w)
vars := mux.Vars(r)
id := vars["id"]
res, err := service.Stop(id)
if err != nil {
w.WriteHeader(err.HTTPStatus)
encoder.Encode(openapi.NewErrorRes(err.Error()))
return
}
w.WriteHeader(http.StatusCreated)
encoder.Encode(res)
})
}
