wip

Author: lucarin91

pkg/board/board_test.go

@@ -16,6 +16,7 @@
 package board
 
 import (
+	"fmt"
 	"os"
 	"testing"
 
@@ -31,3 +32,28 @@ func TestEnsurePlatformInstalled(t *testing.T) {
 	err := EnsurePlatformInstalled(t.Context(), "arduino:zephyr:unoq")
 	require.NoError(t, err)
 }
+
+func TestAdbKillIssue(t *testing.T) {
+	var (
+		boards []Board
+		err    error
+	)
+	for range 5 {
+		boards, err = FromFQBN(t.Context(), "arduino:zephyr:unoq")
+		require.NoError(t, err)
+	}
+
+	for _, b := range boards {
+		fmt.Printf("Board: %s %s %s %s\n", b.BoardName, b.Protocol, b.Address, b.Serial)
+	}
+	selectedBoard := boards[0]
+
+	conn, err := selectedBoard.GetConnection()
+	require.NoError(t, err)
+
+	files, err := conn.List("/home/arduino")
+	require.NoError(t, err)
+	for _, file := range files {
+		fmt.Printf("File: %s\n", file.Name)
+	}
+}

pkg/board/remote/adb/adb.go

@@ -51,10 +51,18 @@ func FromSerial(serial string, adbPath string) (*ADBConnection, error) {
 		adbPath = FindAdbPath()
 	}
 
-	return &ADBConnection{
+	conn := &ADBConnection{
 		host:    serial,
 		adbPath: adbPath,
-	}, nil
+	}
+
+	if connected, err := conn.IsConnected(); err != nil {
+		return nil, err
+	} else if !connected {
+		return nil, fmt.Errorf("device %s is not connected", serial)
+	}
+
+	return conn, nil
 }
 
 func FromHost(host string, adbPath string) (*ADBConnection, error) {
@@ -71,6 +79,23 @@ func FromHost(host string, adbPath string) (*ADBConnection, error) {
 	return FromSerial(host, adbPath)
 }
 
+func (a *ADBConnection) IsConnected() (bool, error) {
+	cmd, err := paths.NewProcess(nil, a.adbPath, "-s", a.host, "get-state")
+	if err != nil {
+		return false, fmt.Errorf("failed to create ADB command: %w", err)
+	}
+
+	output, err := cmd.RunAndCaptureCombinedOutput(context.TODO())
+	if err != nil {
+		if strings.Contains(string(output), "device offline") {
+			return false, nil
+		}
+		return false, fmt.Errorf("failed to get ADB device state: %w: %s", err, output)
+	}
+
+	return string(bytes.TrimSpace(output)) == "device", nil
+}
+
 func (a *ADBConnection) Forward(ctx context.Context, localPort int, remotePort int) error {
 	if !ports.IsAvailable(localPort) {
 		return remote.ErrPortAvailable