Method openLocal

cmd/open.go:285–360

(ctx devspacecontext.Context, domain string)

}

func (cmd *OpenCmd) openLocal(ctx devspacecontext.Context, domain string) error {
	_, servicePort, serviceLabels, err := cmd.getService(ctx.KubeClient(), ctx.KubeClient().Namespace(), domain, true)
	if err != nil {
		return errors.Errorf("Unable to get service: %v", err)
	}

	localPort := servicePort
	if cmd.Port != 0 {
		localPort = cmd.Port
	} else {
		if localPort < 1024 {
			localPort = localPort + 8000
		}

		// Check if port is open
		portOpen, _ := port.IsAvailable(fmt.Sprintf(":%d", localPort))
		for i := 0; i < 10 && !portOpen; i++ {
			localPort++
			portOpen, _ = port.IsAvailable(fmt.Sprintf(":%d", localPort))
		}
	}

	domain = "http://localhost:" + strconv.Itoa(localPort)
	portMappings := []*latest.PortMapping{
		{
			Port: fmt.Sprintf("%d:%d", localPort, servicePort),
		},
	}

	labelSelector := map[string]string{}
	for key, value := range *serviceLabels {
		labelSelector[key] = value
	}

	devPod := &latest.DevPod{
		Name:          "open",
		LabelSelector: labelSelector,
		Ports:         portMappings,
	}
	fakeConfig := &latest.Config{
		Dev: map[string]*latest.DevPod{
			"open": devPod,
		},
	}

	devSpaceConfig := config.Ensure(config.NewConfig(nil, nil, fakeConfig, nil, nil, nil, constants.DefaultConfigPath))
	ctx = ctx.WithConfig(devSpaceConfig)
	options := targetselector.NewEmptyOptions().
		WithLabelSelector(labels.Set(labelSelector).String()).
		WithWaitingStrategy(targetselector.NewUntilNewestRunningWaitingStrategy(time.Second))

	// start port-forwarding for localhost access
	ctx, t := ctx.WithNewTomb()
	<-t.NotifyGo(func() error {
		return portforwarding.StartPortForwarding(ctx, devPod, targetselector.NewTargetSelector(options), t)
	})
	if !t.Alive() {
		return t.Err()