local-server/cmd/dkl-local-server/ws-clusters.go

136 lines
2.4 KiB
Go
Raw Normal View History

2019-02-04 02:56:43 +00:00
package main
import (
"log"
2021-11-14 14:28:40 +00:00
"sort"
2019-02-04 02:56:43 +00:00
restful "github.com/emicklei/go-restful"
2021-11-14 14:28:40 +00:00
2022-04-28 01:33:19 +00:00
"novit.tech/direktil/pkg/localconfig"
2019-02-04 02:56:43 +00:00
)
2023-02-12 10:58:26 +00:00
var clusterSecretKVs = []string{}
func newClusterSecretKV[T any](name string) KVSecrets[T] {
clusterSecretKVs = append(clusterSecretKVs, name)
return KVSecrets[T]{"clusters/"+name}
}
2019-02-04 02:56:43 +00:00
func wsListClusters(req *restful.Request, resp *restful.Response) {
cfg := wsReadConfig(resp)
if cfg == nil {
return
}
clusterNames := make([]string, len(cfg.Clusters))
for i, cluster := range cfg.Clusters {
clusterNames[i] = cluster.Name
}
resp.WriteEntity(clusterNames)
}
func wsReadCluster(req *restful.Request, resp *restful.Response) (cluster *localconfig.Cluster) {
clusterName := req.PathParameter("cluster-name")
cfg := wsReadConfig(resp)
if cfg == nil {
return
}
cluster = cfg.Cluster(clusterName)
if cluster == nil {
wsNotFound(req, resp)
return
}
return
}
func wsCluster(req *restful.Request, resp *restful.Response) {
cluster := wsReadCluster(req, resp)
if cluster == nil {
return
}
resp.WriteEntity(cluster)
}
func wsClusterAddons(req *restful.Request, resp *restful.Response) {
cluster := wsReadCluster(req, resp)
if cluster == nil {
return
}
if len(cluster.Addons) == 0 {
log.Printf("cluster %q has no addons defined", cluster.Name)
wsNotFound(req, resp)
return
}
cfg := wsReadConfig(resp)
if cfg == nil {
return
}
sslCfg, err := sslConfigFromLocalConfig(cfg)
if err != nil {
wsError(resp, err)
return
}
wsRender(resp, sslCfg, cluster.Addons, cluster)
2019-02-04 02:56:43 +00:00
}
2019-04-13 09:36:58 +00:00
2020-04-22 15:36:04 +00:00
func wsClusterCACert(req *restful.Request, resp *restful.Response) {
2021-11-14 14:28:40 +00:00
cs := secretData.clusters[req.PathParameter("cluster-name")]
if cs == nil {
wsNotFound(req, resp)
2020-04-22 15:36:04 +00:00
return
}
2021-11-14 14:28:40 +00:00
ca := cs.CAs[req.PathParameter("ca-name")]
if ca == nil {
wsNotFound(req, resp)
2020-04-22 15:36:04 +00:00
return
}
resp.Write(ca.Cert)
}
func wsClusterSignedCert(req *restful.Request, resp *restful.Response) {
2021-11-14 14:28:40 +00:00
cs := secretData.clusters[req.PathParameter("cluster-name")]
if cs == nil {
wsNotFound(req, resp)
2020-04-22 15:36:04 +00:00
return
}
2021-11-14 14:28:40 +00:00
ca := cs.CAs[req.PathParameter("ca-name")]
if ca == nil {
wsNotFound(req, resp)
return
}
name := req.QueryParameter("name")
if name == "" {
keys := make([]string, 0, len(ca.Signed))
for k := range ca.Signed {
keys = append(keys, k)
}
sort.Strings(keys)
resp.WriteJson(keys, restful.MIME_JSON)
2020-04-22 15:36:04 +00:00
return
}
2021-11-14 14:28:40 +00:00
kc := ca.Signed[name]
2020-04-22 15:36:04 +00:00
if kc == nil {
wsNotFound(req, resp)
return
}
resp.Write(kc.Cert)
}