Method NodeTerminalSessionHandler

internal/api/v1/cluster/terminal.go:56–92

node shell

()

// node shell
func (h *Handler) NodeTerminalSessionHandler() iris.Handler {
	return func(ctx *context.Context) {
		nodeName := ctx.URLParam("nodeName")

		sessionID, err := terminal.GenTerminalSessionId()
		if err != nil {
			ctx.StatusCode(iris.StatusInternalServerError)
			ctx.Values().Set("message", err)
			return
		}
		clusterName := ctx.Params().GetString("name")
		u := ctx.Values().Get("profile")
		profile := u.(session.UserProfile)
		if !profile.IsAdministrator {
			ctx.StatusCode(iris.StatusForbidden)
			ctx.Values().Set("message", "only administrator can open node terminal")
			return
		}
		client, conf, _, err := clusteraccess.ClientForUser(clusterName, clusteraccess.User{
			Name:            profile.Name,
			IsAdministrator: true,
		})
		if err != nil {
			ctx.StatusCode(iris.StatusInternalServerError)
			ctx.Values().Set("message", err)
			return
		}
		terminal.TerminalSessions.Set(sessionID, terminal.TerminalSession{
			Id:       sessionID,
			Bound:    make(chan error),
			SizeChan: make(chan remotecommand.TerminalSize),
		})
		go terminal.WaitForNodeShellTerminal(client, conf, nodeName, sessionID)
		resp := TerminalResponse{ID: sessionID}
		ctx.Values().Set("data", resp)
	}
}