porter/server/api/user_handler.go

package api

import (
	"encoding/json"
	"fmt"
	"net/http"

	"github.com/porter-dev/porter/internal/queries"

	"github.com/porter-dev/porter/internal/models"
)

// HandleCreateUser is majestic
func (app *App) HandleCreateUser(w http.ResponseWriter, r *http.Request) {
	form := &models.CreateUserForm{}

	if err := json.NewDecoder(r.Body).Decode(form); err != nil {
		app.logger.Warn().Err(err).Msg("")
		w.WriteHeader(http.StatusUnprocessableEntity)
		fmt.Fprintf(w, `{"error": "%v"}`, appErrFormDecodingFailure)
		return
	}

	userModel, err := form.ToUser()
	if err != nil {
		app.logger.Warn().Err(err).Msg("")
		w.WriteHeader(http.StatusUnprocessableEntity)
		fmt.Fprintf(w, `{"error": "%v"}`, appErrFormDecodingFailure)
		return
	}

	user, err := queries.CreateUser(app.db, userModel)
	if err != nil {
		app.logger.Warn().Err(err).Msg("")
		w.WriteHeader(http.StatusInternalServerError)
		fmt.Fprintf(w, `{"error": "%v"}`, appErrDataCreationFailure)
		return
	}

	app.logger.Info().Msgf("New user created: %d", user.ID)

	w.WriteHeader(http.StatusCreated)
}

// HandleReadUser is majestic
func (app *App) HandleReadUser(w http.ResponseWriter, r *http.Request) {
	w.WriteHeader(http.StatusOK)
	w.Write([]byte("{}"))
}

// HandleUpdateUser is majestic
func (app *App) HandleUpdateUser(w http.ResponseWriter, r *http.Request) {
	w.WriteHeader(http.StatusAccepted)
}

// HandleDeleteUser is majestic
func (app *App) HandleDeleteUser(w http.ResponseWriter, r *http.Request) {
	w.WriteHeader(http.StatusAccepted)
}

// GenerateUser creates a new user based on a unique ID and a kubeconfig
// func GenerateUser(id string, kubeconfig []byte) *User {
// 	conf := kubernetes.KubeConfig{}

// 	err := yaml.Unmarshal(kubeconfig, &conf)

// 	// TODO -- HANDLE ERROR
// 	if err != nil {
// 		fmt.Println("ERROR IN UNMARSHALING")
// 	}

// 	// generate the user's clusters
// 	clusters := conf.ToClusterConfigs()

// 	return &User{
// 		ID:            id,
// 		Clusters:      clusters,
// 		RawKubeConfig: kubeconfig,
// 	}
// }

// // printUser is a helper function to print a user's config without sensitive information
// func (u *User) printUser() {
// 	for _, cluster := range u.Clusters {
// 		fmt.Println(cluster.Name, cluster.Context, cluster.Server, cluster.User)
// 	}
// }