298 lines
7.6 KiB
Go
298 lines
7.6 KiB
Go
package adb
|
||
|
||
import (
|
||
"bufio"
|
||
"fmt"
|
||
"io"
|
||
"log"
|
||
"net"
|
||
"path/filepath"
|
||
"strings"
|
||
"time"
|
||
)
|
||
|
||
// DeviceInfo 包含从 adb server 列表和设备端 getprop 收集到的信息
|
||
type DeviceInfo struct {
|
||
Serial string
|
||
State string
|
||
Product string
|
||
Model string
|
||
Device string
|
||
TransportID string
|
||
Props map[string]string
|
||
}
|
||
|
||
// listDevicesRaw: 请求 host:devices 并返回原始 payload
|
||
func listDevicesRaw(addr string, timeout time.Duration) (string, error) {
|
||
conn, err := DialADB(addr, timeout)
|
||
if err != nil {
|
||
return "", err
|
||
}
|
||
defer conn.Close()
|
||
|
||
if err := WriteAdbCmd(conn, "host:devices-l"); err != nil {
|
||
return "", err
|
||
}
|
||
status, err := ReadStatus(conn)
|
||
if err != nil {
|
||
return "", err
|
||
}
|
||
if status == "FAIL" {
|
||
msg, _ := ReadLenFrame(conn)
|
||
return "", fmt.Errorf("adb FAIL: %s", string(msg))
|
||
}
|
||
if status != "OKAY" {
|
||
return "", fmt.Errorf("unexpected status: %s", status)
|
||
}
|
||
|
||
var parts []string
|
||
for {
|
||
data, err := ReadLenFrame(conn)
|
||
if err != nil {
|
||
// treat short read timeout as finish
|
||
if ne, ok := err.(net.Error); ok && ne.Timeout() {
|
||
break
|
||
}
|
||
if err == io.EOF {
|
||
break
|
||
}
|
||
return "", err
|
||
}
|
||
if len(data) == 0 {
|
||
break
|
||
}
|
||
parts = append(parts, string(data))
|
||
}
|
||
log.Println(parts)
|
||
return strings.Join(parts, ""), nil
|
||
}
|
||
|
||
// parseDevicesPayload: 解析 host:devices 返回的 payload，提取可能的 product/model/device/transport_id
|
||
func parseDevicesPayload(payload string) []DeviceInfo {
|
||
out := []DeviceInfo{}
|
||
lines := strings.Split(payload, "\n")
|
||
for _, ln := range lines {
|
||
ln = strings.TrimSpace(ln)
|
||
if ln == "" || strings.HasPrefix(ln, "List of devices attached") {
|
||
continue
|
||
}
|
||
// adb -l 格式通常：serial <state> key:val key:val ...
|
||
fields := strings.Fields(ln)
|
||
if len(fields) < 2 {
|
||
continue
|
||
}
|
||
dev := DeviceInfo{
|
||
Serial: fields[0],
|
||
State: fields[1],
|
||
Props: map[string]string{},
|
||
}
|
||
// parse remaining key:val pairs
|
||
for _, kv := range fields[2:] {
|
||
if strings.Contains(kv, ":") {
|
||
parts := strings.SplitN(kv, ":", 2)
|
||
k := parts[0]
|
||
v := parts[1]
|
||
switch k {
|
||
case "product":
|
||
dev.Product = v
|
||
case "model":
|
||
dev.Model = v
|
||
case "device":
|
||
dev.Device = v
|
||
case "transport_id":
|
||
dev.TransportID = v
|
||
default:
|
||
// store any extra short fields into Props under prefixed key
|
||
dev.Props["short."+k] = v
|
||
}
|
||
}
|
||
}
|
||
out = append(out, dev)
|
||
}
|
||
return out
|
||
}
|
||
|
||
// parseGetprop parses getprop output "key]: [value" lines into map
|
||
func parseGetprop(raw []byte) map[string]string {
|
||
m := map[string]string{}
|
||
sc := bufio.NewScanner(strings.NewReader(string(raw)))
|
||
for sc.Scan() {
|
||
line := strings.TrimSpace(sc.Text())
|
||
// getprop lines are like: [ro.build.version.release]: [10]
|
||
if line == "" {
|
||
continue
|
||
}
|
||
// find first ']:' separator
|
||
// safe parse: extract between first '[' and first ']: [' pattern
|
||
// simpler: split by "]: [" into two parts after trimming surrounding brackets
|
||
parts := strings.SplitN(line, "]: [", 2)
|
||
if len(parts) == 2 {
|
||
k := strings.TrimPrefix(parts[0], "[")
|
||
v := strings.TrimSuffix(parts[1], "]")
|
||
m[k] = v
|
||
} else {
|
||
// fallback: try split by ": "
|
||
kv := strings.SplitN(line, ": ", 2)
|
||
if len(kv) == 2 {
|
||
m[strings.Trim(kv[0], "[]")] = strings.Trim(kv[1], "[]")
|
||
}
|
||
}
|
||
}
|
||
return m
|
||
}
|
||
|
||
func parseDevicesMap(payload string) (map[string]string, []string) {
|
||
m := make(map[string]string)
|
||
lines := strings.Split(payload, "\n")
|
||
for _, ln := range lines {
|
||
ln = strings.TrimSpace(ln)
|
||
if ln == "" || strings.HasPrefix(ln, "List of devices attached") {
|
||
continue
|
||
}
|
||
fields := strings.Fields(ln)
|
||
if len(fields) < 2 {
|
||
continue
|
||
}
|
||
serial := fields[0]
|
||
product := ""
|
||
for _, kv := range fields[2:] {
|
||
if strings.HasPrefix(kv, "product:") {
|
||
product = strings.TrimPrefix(kv, "product:")
|
||
break
|
||
}
|
||
}
|
||
m[serial] = product
|
||
}
|
||
return m, lines
|
||
}
|
||
|
||
// Find device serial by product value and return serial (first match)
|
||
func FindSerialByProduct(addr, targetProduct string) (string, error) {
|
||
payload, err := listDevicesRaw(addr, 3*time.Second)
|
||
if err != nil {
|
||
return "", err
|
||
}
|
||
m, _ := parseDevicesMap(payload)
|
||
for serial, product := range m {
|
||
if product == targetProduct {
|
||
return serial, nil
|
||
}
|
||
}
|
||
// fallback: if no product fields in devices-l, try per-device getprop
|
||
payloadBasic, _ := listDevicesRaw(addr, 3*time.Second) // reuse; could be host:devices if preferred
|
||
lines := strings.Split(payloadBasic, "\n")
|
||
for _, ln := range lines {
|
||
ln = strings.TrimSpace(ln)
|
||
if ln == "" || strings.HasPrefix(ln, "List of devices attached") {
|
||
continue
|
||
}
|
||
fields := strings.Fields(ln)
|
||
if len(fields) < 1 {
|
||
continue
|
||
}
|
||
serial := fields[0]
|
||
// query getprop ro.product.model for this serial
|
||
conn, err := DialADB(addr, 2*time.Second)
|
||
if err != nil {
|
||
continue
|
||
}
|
||
// ensure close
|
||
defer conn.Close()
|
||
if err := TransportTo(conn, serial); err != nil {
|
||
continue
|
||
}
|
||
out, err := ExecShell(conn, "getprop ro.product.model")
|
||
if err == nil {
|
||
if strings.TrimSpace(string(out)) == targetProduct {
|
||
return serial, nil
|
||
}
|
||
}
|
||
}
|
||
return "", fmt.Errorf("no device with product=%s found", targetProduct)
|
||
}
|
||
|
||
func InstallApkOnDevice(conn net.Conn, serial, localApkPath string, pmArgs string, debug bool) (string, error) {
|
||
// 1. 准备远端临时路径
|
||
base := filepath.Base(localApkPath)
|
||
remoteTmp := "/data/local/tmp/" + base
|
||
if pmArgs == "" {
|
||
pmArgs = "-r"
|
||
}
|
||
|
||
// 执行 shell: pm install ...
|
||
// 使用 exec shell（非 interactive）通过 "shell:<cmd>"
|
||
installCmd := "pm install " + pmArgs + " " + remoteTmp
|
||
if debug {
|
||
fmt.Printf("[DEBUG] running shell command: %s\n", installCmd)
|
||
}
|
||
outBuf, err := ExecShell(conn, "shell:"+installCmd)
|
||
|
||
if err != nil {
|
||
return "", err
|
||
}
|
||
|
||
outStr := string(outBuf)
|
||
if debug {
|
||
fmt.Printf("[DEBUG] pm install output:\n%s\n", outStr)
|
||
}
|
||
|
||
// 4. 删除临时文件（best-effort）
|
||
_ = WriteAdbCmd(conn, "host:transport:"+serial)
|
||
_, _ = readN(conn, 4, 10*time.Second)
|
||
_ = WriteAdbCmd(conn, "shell:rm -f "+remoteTmp)
|
||
// read and discard
|
||
_, _ = readN(conn, 4, 10*time.Second)
|
||
|
||
// 5. 根据 pm 输出判断成功（pm install 成功通常包含 "Success"）
|
||
if containsSuccess(outStr) {
|
||
return outStr, nil
|
||
}
|
||
return outStr, fmt.Errorf("install failed: %s", outStr)
|
||
}
|
||
|
||
func containsSuccess(s string) bool {
|
||
// 简单判断：忽略大小写包含 "success"
|
||
return (len(s) > 0) && (stringContainsFold(s, "success"))
|
||
}
|
||
|
||
func stringContainsFold(s, sub string) bool {
|
||
// 不依赖 strings 包的 ToLower 性能差别，这里直接用标准方法
|
||
return (len(s) >= len(sub)) && (IndexFold(s, sub) >= 0)
|
||
}
|
||
|
||
func IndexFold(s, sub string) int {
|
||
// 直接使用 strings 包实现（为了清晰，这里直接调用）
|
||
return indexFoldUsingStrings(s, sub)
|
||
}
|
||
|
||
func indexFoldUsingStrings(s, sub string) int {
|
||
// 实际工程里直接用 strings.Contains(strings.ToLower(s), strings.ToLower(sub))
|
||
// 但为了最小示例，这里直接实现：
|
||
// 换成标准库实现：
|
||
//
|
||
// 注意：下面两行才是简洁实现
|
||
//
|
||
// import "strings"
|
||
// return strings.Index(strings.ToLower(s), strings.ToLower(sub))
|
||
//
|
||
// 这里我们直接调用：
|
||
return stringsIndexFold(s, sub)
|
||
}
|
||
|
||
func stringsIndexFold(s, sub string) int {
|
||
// 调用标准库
|
||
// 把此函数简单实现为：
|
||
// strings.Index(strings.ToLower(s), strings.ToLower(sub))
|
||
// 以便示例完整可运行
|
||
// 这里需要引入 strings 包
|
||
// 为了保持示例简洁，我在文件顶部添加下面两行导入：
|
||
//
|
||
// "strings"
|
||
//
|
||
// 然后直接实现：
|
||
return stringsIndex(stringsToLower(s), stringsToLower(sub))
|
||
}
|
||
|
||
func stringsToLower(s string) string { return strings.ToLower(s) }
|
||
func stringsIndex(a, b string) int { return strings.Index(a, b) }
|