add api for running adb command

Author: mingshun

packages/cli/internal/device/manager.go

@@ -1,6 +1,7 @@
 package device
 
 import (
+	"bytes"
 	"fmt"
 	"log"
 	"os/exec"
@@ -170,6 +171,37 @@ func (m *Manager) getDeviceSerialnoAndAndroidId(deviceID string) (serialno strin
 	return
 }
 
+type AdbCommandResult struct {
+	Stdout   string `json:"stdout"`
+	Stderr   string `json:"stderr"`
+	ExitCode int    `json:"exitCode"`
+}
+
+func (m *Manager) ExecAdbCommand(deviceID, command string) (*AdbCommandResult, error) {
+	cmd := exec.Command("sh", "-c", strings.Join([]string{m.adbPath, "-s", deviceID, command}, " "))
+
+	var stdoutBuf, stderrBuf bytes.Buffer
+	cmd.Stdout = &stdoutBuf
+	cmd.Stderr = &stderrBuf
+
+	if err := cmd.Run(); err != nil {
+		if exitError, ok := err.(*exec.ExitError); ok {
+			return &AdbCommandResult{
+				Stdout:   stdoutBuf.String(),
+				Stderr:   stderrBuf.String(),
+				ExitCode: exitError.ExitCode(),
+			}, nil
+		}
+		return nil, errors.Wrapf(err, "failed to exec adb command on device %s", deviceID)
+	}
+
+	return &AdbCommandResult{
+		Stdout:   stdoutBuf.String(),
+		Stderr:   stderrBuf.String(),
+		ExitCode: 0,
+	}, nil
+}
+
 // GetDeviceSerialnoAndAndroidId is a standalone function for backward compatibility
 func GetDeviceSerialnoAndAndroidId(deviceID string) (serialno string, androidID string, err error) {
 	manager := NewManager()

packages/cli/internal/server/handlers/devices.go

@@ -603,6 +603,49 @@ func (h *DeviceHandlers) HandleWebSocket(w http.ResponseWriter, r *http.Request)
 	}
 }
 
+func (h *DeviceHandlers) HandleDeviceAdb(w http.ResponseWriter, req *http.Request) {
+	path := strings.TrimPrefix(req.URL.Path, "/api/devices/")
+	parts := strings.Split(path, "/")
+	deviceSerial := parts[0]
+
+	if strings.Contains(req.Header.Get("via"), "gbox-device-ap") {
+		deviceSerial = h.serverService.GetAdbSerialByGboxDeviceId(deviceSerial)
+	}
+
+	if deviceSerial == "" {
+		http.Error(w, "Device serial required", http.StatusBadRequest)
+		return
+	}
+
+	if !isValidDeviceSerial(deviceSerial) {
+		http.Error(w, "Invalid device serial", http.StatusBadRequest)
+		return
+	}
+
+	log.Printf("[HandleDeviceAdb] Processing adb request for device: %s", deviceSerial)
+
+	decoder := json.NewDecoder(req.Body)
+	var reqBody struct {
+		Command string `json:"command"`
+	}
+	if err := decoder.Decode(&reqBody); err != nil {
+		http.Error(w, errors.Wrap(err, "failed to parse request body").Error(), http.StatusBadRequest)
+		return
+	}
+
+	manager := device.NewManager()
+	result, err := manager.ExecAdbCommand(deviceSerial, reqBody.Command)
+	if err != nil {
+		http.Error(w, err.Error(), http.StatusInternalServerError)
+		return
+	}
+
+	RespondJSON(w, http.StatusOK, map[string]interface{}{
+		"success": true,
+		"data":    result,
+	})
+}
+
 // Private helper methods
 
 func (h *DeviceHandlers) handleDeviceConnect(w http.ResponseWriter, r *http.Request, deviceID string) {

packages/cli/internal/server/router/api.go

@@ -43,6 +43,7 @@ func (r *APIRouter) RegisterRoutes(mux *http.ServeMux, server interface{}) {
 	mux.HandleFunc("/api/devices/{serial}/audio", deviceHandlers.HandleDeviceAudio)
 	mux.HandleFunc("/api/devices/{serial}/stream", deviceHandlers.HandleDeviceStream)
 	mux.HandleFunc("/api/devices/{serial}/control", deviceHandlers.HandleDeviceControl)
+	mux.HandleFunc("/api/devices/{serial}/adb", deviceHandlers.HandleDeviceAdb)
 
 	// Box management endpoints (proxy to remote GBOX API)
 	mux.HandleFunc("/api/boxes", boxHandlers.HandleBoxList)