httprunner/pkg/gadb/device_test.go

//go:build localtest

package gadb

import (
	"bytes"
	"context"
	"os"
	"reflect"
	"strings"
	"testing"
	"time"

	"github.com/stretchr/testify/assert"
	"github.com/stretchr/testify/require"
)

var devices []*Device

func setupDevices(t *testing.T) {
	var err error
	setupClient(t)
	devices, err = adbClient.DeviceList()
	require.Nil(t, err)
}

func TestDevice_State(t *testing.T) {
	t.Skip("Skip ADB test - requires Android Debug Bridge server and connected device")
	setupDevices(t)

	for i := range devices {
		dev := devices[i]
		state, err := dev.State()
		if err != nil {
			t.Fatal(err)
		}
		t.Log(dev.Serial(), state)

		resp, err := dev.RunShellCommand("ls")
		if err != nil {
			t.Fatal(err)
		}
		t.Log(string(resp))
	}
}

func TestDevice_DevicePath(t *testing.T) {
	t.Skip("Skip ADB test - requires Android Debug Bridge server and connected device")
	setupDevices(t)

	for i := range devices {
		dev := devices[i]
		devPath, err := dev.DevicePath()
		if err != nil {
			t.Fatal(err)
		}
		t.Log(dev.Serial(), devPath)
	}
}

func TestDevice_Product(t *testing.T) {
	t.Skip("Skip ADB test - requires Android Debug Bridge server and connected device")
	setupDevices(t)

	for i := range devices {
		dev := devices[i]
		product, err := dev.Product()
		if err != nil {
			t.Fatal(err)
		}
		t.Log(dev.Serial(), product)
	}
}

func TestDevice_Model(t *testing.T) {
	t.Skip("Skip ADB test - requires Android Debug Bridge server and connected device")
	setupDevices(t)

	for i := range devices {
		dev := devices[i]
		model, err := dev.Model()
		if err != nil {
			t.Fatal(err)
		}
		t.Log(dev.Serial(), model)
	}
}

func TestDevice_Brand(t *testing.T) {
	t.Skip("Skip ADB test - requires Android Debug Bridge server and connected device")
	setupDevices(t)

	for i := range devices {
		dev := devices[i]
		brand, err := dev.Brand()
		if err != nil {
			t.Fatal(err)
		}
		t.Log(dev.Serial(), brand)
	}
}

func TestDevice_Usb(t *testing.T) {
	t.Skip("Skip ADB test - requires Android Debug Bridge server and connected device")
	setupDevices(t)

	for i := range devices {
		dev := devices[i]
		usb, err := dev.Usb()
		if err != nil {
			t.Fatal(err)
		}
		isUsb, err := dev.IsUsb()
		if err != nil {
			t.Fatal(err)
		}
		t.Log(dev.Serial(), usb, isUsb)
	}
}

func TestDevice_DeviceInfo(t *testing.T) {
	t.Skip("Skip ADB test - requires Android Debug Bridge server and connected device")
	setupDevices(t)

	for i := range devices {
		dev := devices[i]
		t.Log(dev.DeviceInfo())
	}
}

func TestDevice_SdkVersion(t *testing.T) {
	t.Skip("Skip ADB test - requires Android Debug Bridge server and connected device")
	setupDevices(t)
	for _, device := range devices {
		sdkVersion, err := device.SdkVersion()
		assert.Nil(t, err)
		t.Log(device.Serial(), sdkVersion)
	}
}

func TestDevice_SystemVersion(t *testing.T) {
	t.Skip("Skip ADB test - requires Android Debug Bridge server and connected device")
	setupDevices(t)
	for _, device := range devices {
		systemVersion, err := device.SystemVersion()
		assert.Nil(t, err)
		t.Log(device.Serial(), systemVersion)
	}
}

func TestDevice_Forward(t *testing.T) {
	t.Skip("Skip ADB test - requires Android Debug Bridge server and connected device")
	setupDevices(t)

	for _, device := range devices {
		localPort, err := device.Forward(6790)
		if err != nil {
			t.Fatal(err)
		}

		err = device.ForwardKill(localPort)
		if err != nil {
			t.Fatal(err)
		}
	}
}

func TestDevice_ReverseForward(t *testing.T) {
	t.Skip("Skip ADB test - requires Android Debug Bridge server and connected device")
	setupDevices(t)

	for _, device := range devices {
		localPort := 5005
		err := device.ReverseForward(localPort, "localabstract:scrcpy")
		if err != nil {
			t.Fatal(err)
		}
		err = device.ReverseForward(localPort, "localabstract:scrcpy1")
		if err != nil {
			t.Fatal(err)
		}

		_, err = device.ReverseForwardList()
		if err != nil {
			t.Fatal(err)
		}

		err = device.ReverseForwardKill("localabstract:scrcpy1")
		if err != nil {
			t.Fatal(err)
		}
		err = device.ReverseForwardKillAll()
		if err != nil {
			t.Fatal(err)
		}
	}
}

func TestDevice_ForwardList(t *testing.T) {
	t.Skip("Skip ADB test - requires Android Debug Bridge server and connected device")
	setupDevices(t)

	for i := range devices {
		dev := devices[i]
		forwardList, err := dev.ForwardList()
		if err != nil {
			t.Fatal(err)
		}
		t.Log(dev.serial, "->", forwardList)
	}
}

func TestDevice_ForwardKill(t *testing.T) {
	t.Skip("Skip ADB test - requires Android Debug Bridge server and connected device")
	setupDevices(t)

	for _, device := range devices {
		err := device.ForwardKill(6790)
		if err != nil {
			t.Fatal(err)
		}
	}
}

func TestDevice_RunShellCommand(t *testing.T) {
	t.Skip("Skip ADB test - requires Android Debug Bridge server and connected device")
	setupDevices(t)

	// for i := range devices {
	// 	dev := devices[i]
	// 	// cmdOutput, err := dev.RunShellCommand(`pm list packages  | grep  "bili"`)
	// 	// cmdOutput, err := dev.RunShellCommand(`pm list packages`, `| grep "bili"`)
	// 	// cmdOutput, err := dev.RunShellCommand("dumpsys activity | grep mFocusedActivity")
	// 	cmdOutput, err := dev.RunShellCommand("monkey", "-p", "tv.danmaku.bili", "-c", "android.intent.category.LAUNCHER", "1")
	// 	if err != nil {
	// 		t.Fatal(dev.serial, err)
	// 	}
	// 	t.Log("\n"+dev.serial, cmdOutput)
	// }

	for _, dev := range devices {
		// cmdOutput, err := dev.RunShellCommand("monkey", "-p", "tv.danmaku.bili", "-c", "android.intent.category.LAUNCHER", "1")
		cmdOutput, err := dev.RunShellCommand("ls /sdcard")
		// cmdOutput, err := dev.RunShellCommandWithBytes("screencap -p")
		if err != nil {
			t.Fatal(dev.serial, err)
		}
		t.Log("\n⬇️"+dev.serial+"⬇️\n", cmdOutput)
	}
}

func TestDevice_EnableAdbOverTCP(t *testing.T) {
	t.Skip("Skip ADB test - requires Android Debug Bridge server and connected device")
	setupDevices(t)

	for _, dev := range devices {
		err := dev.EnableAdbOverTCP()
		if err != nil {
			t.Fatal(err)
		}
	}
}

func TestDevice_List(t *testing.T) {
	t.Skip("Skip ADB test - requires Android Debug Bridge server and connected device")
	setupDevices(t)

	for _, dev := range devices {
		// fileEntries, err := dev.List("/sdcard")
		fileEntries, err := dev.List("/sdcard/Download")
		if err != nil {
			t.Fatal(err)
		}

		for i := range fileEntries {
			t.Log(fileEntries[i].Name, "\t", fileEntries[i].IsDir())
		}
	}
}

func TestDevice_Push(t *testing.T) {
	t.Skip("Skip ADB test - requires Android Debug Bridge server and connected device")
	setupDevices(t)

	for _, dev := range devices {
		localPath := "test.txt"
		err := dev.PushFile(localPath, "/sdcard/Download/push.txt", time.Now())
		if err != nil {
			t.Fatal(err)
		}

		err = dev.Push(strings.NewReader("world"), "/sdcard/Download/hello.txt", time.Now())
		if err != nil {
			t.Fatal(err)
		}
	}
}

func TestDevice_Pull(t *testing.T) {
	t.Skip("Skip ADB test - requires Android Debug Bridge server and connected device")
	setupDevices(t)

	for _, dev := range devices {
		buffer := bytes.NewBufferString("")
		err := dev.Pull("/sdcard/Download/hello.txt", buffer)
		if err != nil {
			t.Fatal(err)
		}

		userHomeDir, _ := os.UserHomeDir()
		if err = os.WriteFile(userHomeDir+"/Desktop/hello.txt", buffer.Bytes(), DefaultFileMode); err != nil {
			t.Fatal(err)
		}
	}
}

func TestDevice_ScreenRecord(t *testing.T) {
	t.Skip("Skip ADB test - requires Android Debug Bridge server and connected device")
	setupDevices(t)

	for _, dev := range devices {
		// screen record with time limit 5 seconds
		ctx, cancel := context.WithTimeout(context.Background(), time.Second*5)
		if _, err := dev.ScreenRecord(ctx); err != nil {
			assert.Nil(t, err)
		}
		cancel()
	}

	for _, dev := range devices {
		// screen record with cancel signal
		ctx, cancel := context.WithCancel(context.Background())
		done := make(chan error)
		go func() {
			_, err := dev.ScreenRecord(ctx)
			done <- err
		}()

		// record for 3 seconds
		time.Sleep(time.Second * 3)
		cancel()

		err := <-done
		assert.Nil(t, err)
	}
}

func TestDevice_RunShellCommandBackgroundWithBytes(t *testing.T) {
	t.Skip("Skip ADB test - requires Android Debug Bridge server and connected device")
	type fields struct {
		adbClient Client
		serial    string
		attrs     map[string]string
	}
	type args struct {
		cmd  string
		args []string
	}
	tests := []struct {
		name    string
		fields  fields
		args    args
		want    []byte
		wantErr bool
	}{
		{
			name: "runShellCommandBackground",
			fields: fields{
				adbClient: func() Client {
					c, _ := NewClient()
					return c
				}(),
				serial: "63c1ee94",
			},
			args: args{
				cmd: "nohup sleep 10 2>/dev/null 1>/dev/null &",
				// cmd:  "sleep 10",

			},
		},
	}
	for _, tt := range tests {
		t.Run(tt.name, func(t *testing.T) {
			d := Device{
				adbClient: tt.fields.adbClient,
				serial:    tt.fields.serial,
				attrs:     tt.fields.attrs,
			}
			got, err := d.RunShellCommandV2WithBytes(tt.args.cmd, tt.args.args...)
			if (err != nil) != tt.wantErr {
				t.Errorf("Device.RunShellCommandBackgroundWithBytes() error = %v, wantErr %v", err, tt.wantErr)
				return
			}
			if !reflect.DeepEqual(got, tt.want) {
				t.Errorf("Device.RunShellCommandBackgroundWithBytes() = %v, want %v", got, tt.want)
			}
		})
	}
}

func TestDevice_InstallAPK(t *testing.T) {
	t.Skip("Skip ADB test - requires Android Debug Bridge server and connected device")
	setupDevices(t)

	apkPath := "test.apk"
	for _, dev := range devices {
		res, err := dev.InstallAPK(apkPath)
		if err != nil {
			t.Fatal(err)
		}
		t.Log(res)
	}
}

func TestDevice_ListPackages(t *testing.T) {
	t.Skip("Skip ADB test - requires Android Debug Bridge server and connected device")
	setupDevices(t)
	for _, dev := range devices {
		res, err := dev.ListPackages()
		if err != nil {
			t.Fatal(err)
		}
		t.Log(res)
		installed := dev.IsPackageInstalled("io.appium.uiautomator2.server")
		if err != nil {
			t.Fatal(err)
		}
		t.Log(installed)
	}
}

func TestDevice_HasFeature(t *testing.T) {
	t.Skip("Skip ADB test - requires Android Debug Bridge server and connected device")
	setupDevices(t)

	for _, dev := range devices {
		t.Log(dev.GetFeatures())
	}
}