update "misc" partition r/w operations

bbootimg/src/main/kotlin/bootloader_message/BootloaderMsg.kt

@@ -3,6 +3,9 @@ package cfig.bootloader_message
 import cfig.io.Struct3
 import org.junit.Assert
 import org.slf4j.LoggerFactory
+import java.io.File
+import java.io.FileInputStream
+import java.io.FileOutputStream
 import java.lang.IllegalStateException
 
 data class BootloaderMsg(
@@ -14,18 +17,56 @@ data class BootloaderMsg(
 ) {
     companion object {
         private const val FORMAT_STRING = "32s32s768s32s1184b"
+        private const val miscFile = "misc.file"
         const val SIZE = 2048
         private val log = LoggerFactory.getLogger("BootloaderMsg")
 
         init {
             Assert.assertEquals(SIZE, Struct3(FORMAT_STRING).calcSize())
         }
+    }
 
-        fun writeBootloaderMessage(options: Array<String>) {
+    constructor(fis: FileInputStream) : this() {
+        val info = Struct3(FORMAT_STRING).unpack(fis)
+        this.command = info[0] as String
+        this.status = info[1] as String
+        this.recovery = info[2] as String
+        this.stage = info[3] as String
+        this.reserved = info[4] as ByteArray
+    }
+
+    fun encode(): ByteArray {
+        return Struct3(FORMAT_STRING).pack(
+                this.command,
+                this.stage,
+                this.recovery,
+                this.stage,
+                byteArrayOf())
+    }
+
+    fun clearBootloaderMessage() {
         val boot = BootloaderMsg()
-            boot.updateBootloaderMessageInStruct(options)
         boot.writeBootloaderMessage()
     }
+
+    fun writeBootloaderMessage(options: Array<String>) {
+        this.updateBootloaderMessageInStruct(options)
+        this.writeBootloaderMessage()
+    }
+
+    fun readBootloaderMsg() {
+        if (File(miscFile).exists()) {
+            log.info("readBootloaderMsg() from $miscFile")
+            val fis = FileInputStream(miscFile)
+            val info = Struct3(FORMAT_STRING).unpack(fis)
+            this.command = info[0] as String
+            this.status = info[1] as String
+            this.recovery = info[2] as String
+            this.stage = info[3] as String
+            this.reserved = info[4] as ByteArray
+        } else {
+            log.info("$miscFile missing")
+        }
     }
 
     fun writeRebootBootloader() {
@@ -38,11 +79,17 @@ data class BootloaderMsg(
 
     fun writeBootloaderMessage() {
         log.info("writing ... $this")
+        if (!File(miscFile).exists()) {
+            File(miscFile).createNewFile()
+        }
+        FileOutputStream(miscFile, false).use { fos ->
+            fos.write(this.encode())
+        }
     }
 
     fun updateBootloaderMessageInStruct(options: Array<String>) {
         this.command = "boot-recovery"
-        this.recovery = "recovery"
+        this.recovery = "recovery\n"
         options.forEach {
             this.recovery += if (it.endsWith("\n")) {
                 it

bbootimg/src/main/kotlin/init/Reboot.kt

@@ -78,7 +78,7 @@ class Reboot {
                                     BootloaderMsg().writeRebootBootloader()
                                 } else {
                                     log.info("$dynamicPartitionKey=true, using fastbootd")
-                                    BootloaderMsg.writeBootloaderMessage(arrayOf("--fastboot"))
+                                    BootloaderMsg().writeBootloaderMessage(arrayOf("--fastboot"))
                                     rebootTarget = "recovery"
                                 }
                             }
@@ -86,7 +86,7 @@ class Reboot {
                                 BootloaderMsg().writeRebootBootloader()
                             }
                             "sideload", "sideload-auto-reboot" -> {
-                                BootloaderMsg.writeBootloaderMessage(
+                                BootloaderMsg().writeBootloaderMessage(
                                         arrayOf("--" + rebootTarget.replace("-", "_")))
                                 rebootTarget = "recovery"
                             }

bbootimg/src/test/kotlin/bootloader_message/BootloaderMsgTest.kt

@@ -0,0 +1,56 @@
+package bootloader_message
+
+import cfig.bootloader_message.BootloaderMsg
+import org.junit.Test
+
+import org.junit.Assert.*
+import org.slf4j.LoggerFactory
+
+class BootloaderMsgTest {
+    private val log = LoggerFactory.getLogger(BootloaderMsgTest::class.java)
+
+    @Test
+    fun writeRebootBootloaderTest() {
+        val msg = BootloaderMsg()
+        msg.clearBootloaderMessage()
+    }
+
+    @Test
+    fun readBootloaderMsgTest() {
+        val msg = BootloaderMsg()
+        msg.readBootloaderMsg()
+        log.info(msg.toString())
+    }
+
+    @Test
+    fun writeOptions() {
+        val msg = BootloaderMsg()
+        msg.updateBootloaderMessageInStruct(arrayOf(
+                "--prompt_and_wipe_data",
+                "--locale=zh_CN"))
+        msg.writeBootloaderMessage()
+    }
+
+
+    @Test
+    fun rebootRecovery() {
+        val msg = BootloaderMsg()
+        msg.updateBootloaderMessageInStruct(arrayOf())
+        msg.writeBootloaderMessage()
+    }
+
+    @Test
+    fun rebootCrash() {
+        val msg = BootloaderMsg()
+        msg.writeBootloaderMessage(arrayOf(
+                "--prompt_and_wipe_data",
+                "--reason=RescueParty",
+                "--locale=en_US"))
+    }
+
+    @Test
+    fun rebootOTA() {
+        val msg = BootloaderMsg()
+        msg.writeBootloaderMessage(arrayOf("--update_package=/cache/update.zip", "--security"))
+    }
+}

build.gradle

@@ -1,4 +1,13 @@
-apply plugin: 'java'
+apply plugin: "java"
+
+buildscript {
+    repositories {
+        jcenter()
+    }
+    dependencies {
+        classpath "org.apache.commons:commons-exec:1.3"
+    }
+}
 
 subprojects {
     tasks.withType(JavaCompile) {
@@ -11,6 +20,10 @@ subprojects {
 // ----------------------------------------------------------------------------
 import java.util.regex.Matcher
 import java.util.regex.Pattern
+import org.apache.commons.exec.CommandLine
+import org.apache.commons.exec.DefaultExecutor
+import org.apache.commons.exec.PumpStreamHandler
+
 if (parseGradleVersion(gradle.gradleVersion) < 5) {
     logger.error("ERROR: Gradle Version MUST >= 5.0, current is {}", gradle.gradleVersion)
     throw new RuntimeException("ERROR: Gradle Version")
@@ -93,27 +106,33 @@ task pull() {
     }
 
     doLast {
+        String avb_version = adbCmd("getprop ro.boot.avb_version2")
+        Boolean isAvbEnabled = false
+        if (avb_version.isEmpty()) {
+            isAvbEnabled = true
+        }
+        println("AVB: $isAvbEnabled")
         if (project.findProperty("group")) {
             println("Pull: $group")
         } else {
             println("Pull /boot, /recovery, /vbmeta")
-            pullDefault()
+            pullDefault(isAvbEnabled)
         }
     }
 }
 
-void pullDefault() {
+void pullDefault(Boolean avb = true) {
     Run(["adb", "shell", "dd if=/dev/block/by-name/boot of=/cache/boot.img"])
     Run(["adb", "shell", "dd if=/dev/block/by-name/recovery of=/cache/recovery.img"])
-    Run(["adb", "shell", "dd if=/dev/block/by-name/vbmeta of=/cache/vbmeta.img"])
+    if (avb) Run(["adb", "shell", "dd if=/dev/block/by-name/vbmeta of=/cache/vbmeta.img"])
 
     Run(["adb", "pull", "/cache/boot.img"])
     Run(["adb", "pull", "/cache/recovery.img"])
-    Run(["adb", "pull", "/cache/vbmeta.img"])
+    if (avb) Run(["adb", "pull", "/cache/vbmeta.img"])
 
     Run(["adb", "shell", "rm /cache/boot.img"])
     Run(["adb", "shell", "rm /cache/recovery.img"])
-    Run(["adb", "shell", "rm /cache/vbmeta.img"])
+    if (avb) Run(["adb", "shell", "rm /cache/vbmeta.img"])
 }
 
 void Run(List<String> inCmd, String inWorkdir = null) {
@@ -187,3 +206,14 @@ int parseGradleVersion(String version) {
     logger.info("Gradle: versionPart {}, majorPart {}", versionPart, majorPart)
     return majorPart
 }
+
+String adbCmd(String cmd) {
+    ByteArrayOutputStream outputStream = new ByteArrayOutputStream()
+    def exec = new DefaultExecutor()
+    exec.streamHandler = new PumpStreamHandler(outputStream)
+    def cmdline = "adb shell $cmd"
+    //println(cmdline)
+    exec.execute(CommandLine.parse(cmdline))
+    //println(outputStream)
+    return outputStream.toString().trim()
+}