15308555518/ kubekey
1
0
Fork 0
mirror of https://github.com/kubesphere/kubekey.git synced 2025-12-25 17:12:50 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

Update resources.go

This commit is contained in:
liujian 2025-08-25 13:47:07 +08:00 committed by GitHub
parent cf754e0394
commit ba98704f30
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 8 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
pkg/web/handler/resources.go
View File

@ -72,7 +72,13 @@ func (h ResourceHandler) PostConfig(request *restful.Request, response *restful.
oldConfig map[string]map[string]any
newConfig map[string]map[string]any
)
if err := request.ReadEntity(&newConfig); err != nil {
bodyBytes, err := io.ReadAll(request.Request.Body)
if err != nil {
_ = response.WriteError(http.StatusInternalServerError, err)
return
}
// Read new config from request body.
if err := json.Unmarshal(bodyBytes, &newConfig); err != nil {
_ = response.WriteError(http.StatusInternalServerError, err)
return
}
@ -93,10 +99,6 @@ func (h ResourceHandler) PostConfig(request *restful.Request, response *restful.
// Iterate over new config and trigger precheck playbooks if config changed.
for fileName, newVal := range newConfig {
// if config is not change skip it
if reflect.DeepEqual(newVal, oldConfig[fileName]) {
continue
}
// if playbook has created should skip it.
playbookList := &kkcorev1.PlaybookList{}
if err := h.client.List(request.Request.Context(), playbookList, ctrlclient.InNamespace(namespace),
@ -168,13 +170,8 @@ func (h ResourceHandler) PostConfig(request *restful.Request, response *restful.
}
}
data, err := json.Marshal(newConfig)
if err != nil {
_ = response.WriteError(http.StatusInternalServerError, err)
return
}
// Write new config to file.
if err := os.WriteFile(filepath.Join(h.rootPath, api.SchemaConfigFile), data, 0644); err != nil {
if err := os.WriteFile(filepath.Join(h.rootPath, api.SchemaConfigFile), bodyBytes, 0644); err != nil {
_ = response.WriteError(http.StatusInternalServerError, err)
return
}