Method forward

pkg/devspace/server/port_forward.go:19–143

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

const maxPort = 40000

func (h *handler) forward(w http.ResponseWriter, r *http.Request) {
	// Kube Context
	kubeContext := h.ctx.KubeClient().CurrentContext()
	ctx, ok := r.URL.Query()["context"]
	if ok && len(ctx) == 1 && ctx[0] != "" {
		kubeContext = ctx[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
	}

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

	key := fmt.Sprintf("%s/%s/%s:%s", kubeContext, kubeNamespace, name[0], targetPort[0])

	// Check if exists
	h.portsMutex.Lock()
	defer h.portsMutex.Unlock()

	// 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
	}

	pod, err := client.KubeClient().CoreV1().Pods(kubeNamespace).Get(context.TODO(), name[0], metav1.GetOptions{})
	if err != nil {
		h.ctx.Log().Errorf("Error in %s: %v", r.URL.String(), err)
		http.Error(w, err.Error(), http.StatusInternalServerError)
		return
	}

	if h.ports[key] != nil {
		// Check if the pod is the same
		if h.ports[key].podUUID == string(pod.UID) {
			_, _ = w.Write([]byte(strconv.Itoa(h.ports[key].portForwarderPort)))
			return
		}

		close(h.ports[key].portForwarderStop)
		delete(h.ports, key)
	}