Method CopyImageToInstance

src/cmd/linuxkit/scaleway.go:305–373

CopyImageToInstance copies the image to the instance via ssh

(instanceID, path, sshKeyPath string)

// CopyImageToInstance copies the image to the instance via ssh
func (s *ScalewayClient) CopyImageToInstance(instanceID, path, sshKeyPath string) error {
	_, base := filepath.Split(path)
	s.fileName = base

	serverResp, err := s.instanceAPI.GetServer(&instance.GetServerRequest{
		ServerID: instanceID,
	})
	if err != nil {
		return err
	}
	server := serverResp.Server

	signer, err := getSSHAuth(sshKeyPath)
	if err != nil {
		return err
	}

	s.sshConfig = &ssh.ClientConfig{
		User: "root",
		Auth: []ssh.AuthMethod{
			ssh.PublicKeys(signer),
		},
		HostKeyCallback: ssh.InsecureIgnoreHostKey(), // TODO validate server before?
	}

	client, err := ssh.Dial("tcp", server.PublicIP.Address.String()+":22", s.sshConfig) // TODO remove hardocoded port?
	if err != nil {
		return err
	}

	session, err := client.NewSession()
	if err != nil {
		return err
	}
	defer func() {
		_ = session.Close()
	}()

	f, err := os.Open(path)
	if err != nil {
		return err
	}
	defer func() {
		_ = f.Close()
	}()

	// code taken from bramvdbogaerde/go-scp
	contentBytes, err := io.ReadAll(f)
	if err != nil {
		return err
	}
	bytesReader := bytes.NewReader(contentBytes)

	log.Infof("Starting to upload %s on server", base)

	go func() {
		w, err := session.StdinPipe()
		if err != nil {