Method BootInstanceAndWait

src/cmd/linuxkit/scaleway.go:195–272

BootInstanceAndWait boots and wait for instance to be booted

(instanceID string)

// BootInstanceAndWait boots and wait for instance to be booted
func (s *ScalewayClient) BootInstanceAndWait(instanceID string) error {
	serverActionRequest := &instance.ServerActionRequest{
		ServerID: instanceID,
		Action:   instance.ServerActionPoweron,
	}

	_, err := s.instanceAPI.ServerAction(serverActionRequest)
	if err != nil {
		return err
	}

	log.Debugf("Waiting for server %s to be started", instanceID)

	// code taken from scaleway-cli, could need some changes
	promise := make(chan bool)
	var server *instance.Server
	var currentState instance.ServerState

	go func() {
		defer close(promise)

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

			if currentState != server.State {
				currentState = server.State
			}

			if server.State == instance.ServerStateRunning {
				break
			}
			if server.State == instance.ServerStateStopped {
				promise <- false
				return
			}
			time.Sleep(1 * time.Second)
		}

		ip := server.PublicIP.Address.String()
		dest := fmt.Sprintf("%s:22", ip)
		for {
			conn, err := net.Dial("tcp", dest)
			if err == nil {
				defer func() {
					_ = conn.Close()
				}()
				break
			} else {
				time.Sleep(1 * time.Second)
			}
		}