Method handleUser

internal/serverapi/users.go:213–244

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

}

func (a *userAPI) handleUser(w http.ResponseWriter, r *http.Request, userID string) {
	switch r.Method {
	case http.MethodGet:
		user, err := a.users.GetUser(userID)
		if err != nil {
			writeUserError(w, err)
			return
		}
		writeJSON(w, http.StatusOK, user)
	case http.MethodPut:
		a.handleUpdateUser(w, r, userID)
	case http.MethodDelete:
		// 删除前先收集该用户所在的节点，删除后重新下发配置以踢出用户
		accesses, _ := a.users.ListUserInboundsByUser(userID)
		affectedNodeIDs := make(map[string]struct{})
		for _, acc := range accesses {
			affectedNodeIDs[acc.NodeID] = struct{}{}
		}
		if err := a.users.DeleteUser(userID); err != nil {
			writeUserError(w, err)
			return
		}
		nodeIDs := make([]string, 0, len(affectedNodeIDs))
		for id := range affectedNodeIDs {
			nodeIDs = append(nodeIDs, id)
		}
		a.applyNodes(nodeIDs)
		writeJSON(w, http.StatusOK, map[string]any{"deleted": true})
	default:
		writeMethodNotAllowed(w, http.MethodGet+", "+http.MethodPut+", "+http.MethodDelete)
	}
}

func (a *userAPI) handleUpdateUser(w http.ResponseWriter, r *http.Request, userID string) {
	user, err := a.users.GetUser(userID)