Function startSSH

pkg/devspace/services/ssh/ssh.go:56–145

(ctx devspacecontext.Context, name, arch string, sshConfig *latest.SSH, selector targetselector.TargetSelector, parent *tomb.Tomb)

}

func startSSH(ctx devspacecontext.Context, name, arch string, sshConfig *latest.SSH, selector targetselector.TargetSelector, parent *tomb.Tomb) error {
	if ctx.IsDone() {
		return nil
	}

	// configure ssh host
	sshHost := name + "." + ctx.Config().Config().Name + ".devspace"
	if sshConfig.LocalHostname != "" {
		sshHost = sshConfig.LocalHostname
	}

	// try to find host port
	homeDir, err := homedir.Dir()
	if err != nil {
		return errors.Wrap(err, "get home dir")
	}

	// get port
	port := sshConfig.LocalPort
	if port == 0 {
		sshDevSpaceConfigPath := filepath.Join(homeDir, ".ssh", "config")
		if sshConfig.UseInclude {
			sshDevSpaceConfigPath = filepath.Join(homeDir, ".ssh", "devspace_config")
		}
		hosts, err := ParseDevSpaceHosts(sshDevSpaceConfigPath)
		if err != nil {
			ctx.Log().Debugf("error parsing %s: %v", sshDevSpaceConfigPath, err)
		} else {
			for _, h := range hosts {
				if h.Host == sshHost {
					port = h.Port
				}
			}
		}

		if port == 0 {
			port, err = GetInstance(ctx.Log()).LockPort()
			if err != nil {
				return errors.Wrap(err, "find port")
			}

			// update ssh config
			err = configureSSHConfig(sshHost, strconv.Itoa(port), sshConfig.UseInclude, ctx.Log())
			if err != nil {
				return errors.Wrap(err, "update ssh config")
			}
		}
	} else {
		err = GetInstance(ctx.Log()).LockSpecificPort(port)
		if err != nil {
			return errors.Wrap(err, "find port")
		}

		// update ssh config
		err = configureSSHConfig(sshHost, strconv.Itoa(port), sshConfig.UseInclude, ctx.Log())
		if err != nil {
			return errors.Wrap(err, "update ssh config")
		}