Method handleKubeConfigApi

thirdparty/gotty/server/handlers.go:270–326

(w http.ResponseWriter, r *http.Request)

}

func (server *Server) handleKubeConfigApi(w http.ResponseWriter, r *http.Request) {
	result := ApiResponse{
		Success: false,
	}
	w.Header().Set("Content-Type", "application/json;charset=utf-8")
	if !strings.EqualFold(r.Method, "POST") {
		result.Message = "Method Not Allowed"
		json.NewEncoder(w).Encode(result)
		w.WriteHeader(405)
		return
	}
	body, err := io.ReadAll(r.Body)
	if err != nil {
		fmt.Printf("read body err, %v\n", err)
		result.Message = "Invalid Request Body"
		json.NewEncoder(w).Encode(result)
		w.WriteHeader(406)
		return
	}
	var request KubeConfigRequest
	if err = json.Unmarshal(body, &request); err != nil {
		fmt.Printf("Unmarshal err, %v\n", err)
		result.Message = "Invalid Request Body"
		json.NewEncoder(w).Encode(result)
		w.WriteHeader(406)
		return
	}
	if len(request.KubeConfig) < 10 {
		result.Message = "Invalid Kube Config"
		json.NewEncoder(w).Encode(result)
		w.WriteHeader(406)
		return
	}
	if _, base64err := base64.StdEncoding.DecodeString(request.KubeConfig); base64err != nil {
		result.Message = "Invalid Base64 Content"
		json.NewEncoder(w).Encode(result)
		w.WriteHeader(406)
		return
	}

	//fmt.Printf("%+v", requst)
	token := randomstring.Generate(20)
	ttyParameter := cache.TtyParameter{
		Title: request.Name,
		Arg:   strings.Replace(request.KubeConfig, " ", "", -1),
	}
	if err := server.cache.Add(token, &ttyParameter, time.Duration(server.options.TokenExpiresDuration)*time.Second); err != nil {
		log.Printf("save token and ttyParam err:%s", err.Error())
		result.Success = false
		result.Message = err.Error()
		json.NewEncoder(w).Encode(result)
		return
	}
	result.Success = true
	result.Token = token
	json.NewEncoder(w).Encode(result)
}