Method enter

pkg/devspace/server/enter.go:19–104

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

)

func (h *handler) enter(w http.ResponseWriter, r *http.Request) {
	// Kube Context
	kubeContext := h.ctx.KubeClient().CurrentContext()
	context, ok := r.URL.Query()["context"]
	if ok && len(context) == 1 && context[0] != "" {
		kubeContext = context[0]
	}

	// Namespace
	kubeNamespace := h.ctx.KubeClient().Namespace()
	namespace, ok := r.URL.Query()["namespace"]
	if ok && len(namespace) == 1 && namespace[0] != "" {
		kubeNamespace = namespace[0]
	}

	name, ok := r.URL.Query()["name"]
	if !ok || len(name) != 1 {
		http.Error(w, "name is missing", http.StatusBadRequest)
		return
	}
	container, ok := r.URL.Query()["container"]
	if !ok || len(container) != 1 {
		http.Error(w, "container is missing", http.StatusBadRequest)
		return
	}

	var terminalResizeQueue TerminalResizeQueue
	resizeID, ok := r.URL.Query()["resize_id"]
	if ok && len(resizeID) == 1 {
		h.terminalResizeQueuesMutex.Lock()
		terminalResizeQueue = newTerminalSizeQueue()
		h.terminalResizeQueues[resizeID[0]] = terminalResizeQueue
		h.terminalResizeQueuesMutex.Unlock()

		defer func() {
			h.terminalResizeQueuesMutex.Lock()
			defer h.terminalResizeQueuesMutex.Unlock()

			delete(h.terminalResizeQueues, resizeID[0])
		}()
	}

	// Create kubectl client
	client, err := h.getClientFromCache(kubeContext, kubeNamespace)
	if err != nil {
		h.ctx.Log().Errorf("Error in %s: %v", r.URL.String(), err)
		http.Error(w, err.Error(), http.StatusInternalServerError)
		return
	}

	ws, err := upgrader.Upgrade(w, r, nil)
	if err != nil {
		h.ctx.Log().Errorf("Error upgrading connection: %v", err)
		http.Error(w, err.Error(), http.StatusInternalServerError)
		return
	}

	defer ws.Close()