feat: Enhance fastboot transfers and USB backend also rename multiple code namespace

Multiple improvements across the fastboot CLI and library: add retry/recovery and CRC validation to DownloadData; detect sparse images, split large raw images into chunks, and handle AVB footer padding in FlashUnsparseImage; switch FlashRaw to use FlashUnsparseImage. Add AdvancedStreams (SubStream, ConcatenatedStream, PaddingStream) to support streaming large/stitched payloads. Make USB backend default to libusb on Linux (UsbManager) and only return Linux devices that can open a handle (LinuxUsbFinder); add a --fallback CLI flag and change CLI to wait for a device if none are connected. Add user-facing NotifyCurrentStep messages for erase/format/reboot/set_active/flashall flows. Add unit tests for INFO/DATA parsing edge cases and update project dependencies (Crc32.NET, FirmwareKit.AVB). Also update .gitignore with common file patterns.

Author: 13584452567

.gitignore

@@ -3,6 +3,14 @@
 ##
 ## Get latest from https://github.com/github/gitignore/blob/master/VisualStudio.gitignore
 
+*.c
+*.h
+*.img
+*.bat
+*.cpp
+fastboot/
+*.txt
+
 # User-specific files
 *.rsuser
 *.suo

FastbootCLI/Program.cs

@@ -1,5 +1,5 @@
 using FirmwareKit.Comm.Fastboot;
-using FirmwareKit.Comm.Fastboot.Backend.Usb;
+using FirmwareKit.Comm.Fastboot.Usb;
 
 
 namespace FastbootCLI
@@ -44,7 +44,7 @@ static void Main(string[] args)
                     sparseLimit = ParseSize(sizeStr);
                 }
                 else if (arg == "--debug") FastbootDebug.IsEnabled = true;
-                else if (arg == "--libusb") UsbManager.ForceLibUsb = true;
+                else if (arg == "--fallback") UsbManager.ForceLibUsb = false;
                 else if (arg == "--version" || arg == "version") { Console.WriteLine("fastboot version 1.2.5"); return; }
                 else if (arg == "-h" || arg == "--help" || arg == "help") { ShowHelp(); return; }
                 else if (!arg.StartsWith("-"))
@@ -75,16 +75,36 @@ static void Main(string[] args)
             }
 
             var devices = UsbManager.GetAllDevices();
-            UsbDevice? target = serial != null ? devices.FirstOrDefault(d => d.SerialNumber == serial) : (devices.Count > 0 ? devices[0] : null);
+            UsbDevice? target = null;
+
+            if (serial != null)
+            {
+                target = devices.FirstOrDefault(d => d.SerialNumber == serial);
+            }
+            else if (devices.Count > 0)
+            {
+                target = devices[0];
+            }
+            else
+            {
+                // Wait for device matching AOSP behavior
+                Console.Error.WriteLine("< waiting for any device >");
+                while (target == null)
+                {
+                    System.Threading.Thread.Sleep(500);
+                    devices = UsbManager.GetAllDevices();
+                    target = devices.FirstOrDefault();
+                }
+            }
 
             if (target == null)
             {
                 Console.Error.WriteLine("fastboot: error: no devices/found");
                 Environment.Exit(1);
             }
 
-            using FastbootUtil util = new FastbootUtil(target);
-            if (sparseLimit.HasValue) FastbootUtil.SparseMaxDownloadSize = (int)Math.Min(int.MaxValue, sparseLimit.Value);
+            using FastbootDriver util = new FastbootDriver(target);
+            if (sparseLimit.HasValue) FastbootDriver.SparseMaxDownloadSize = (int)Math.Min(int.MaxValue, sparseLimit.Value);
 
             util.ReceivedFromDevice += (s, e) =>
             {
@@ -127,7 +147,7 @@ static long ParseSize(string sizeStr)
             return long.Parse(sizeStr) * multiplier;
         }
 
-        static void ExecuteCommand(FastbootUtil util, string command, List<string> args)
+        static void ExecuteCommand(FastbootDriver util, string command, List<string> args)
         {
             if (command == "devices")
             {
@@ -257,7 +277,6 @@ string GetPartition(string baseName)
                         using var fs = File.OpenRead(file);
                         util.FlashUnsparseImage(part, fs, fs.Length).ThrowIfError();
                     }
-                    if (!skipReboot && (part.StartsWith("boot") || part.StartsWith("system"))) Console.Error.WriteLine("Note: Device may need a manual reboot or use 'fastboot reboot'.");
                     break;
 
                 case "flashall":
@@ -398,6 +417,7 @@ static void ShowHelp()
             Console.Error.WriteLine("  --skip-reboot                  Don't reboot device after flashing all.");
             Console.Error.WriteLine("  --force                        Force execute command (e.g. skip snapshot check).");
             Console.Error.WriteLine("  --fs-options <opt>             File system options for format (e.g. casefold).");
+            Console.Error.WriteLine("  --fallback                     Use platform native USB backend instead of libusb (on Linux libusb is default).");
 
             Console.Error.WriteLine("\nbasics:");
             Console.Error.WriteLine("  devices [-l]                   List connected devices.");

FirmwareKit.Comm.Fastboot.Tests/AospDriverTests.cs

@@ -1,5 +1,3 @@
-using FirmwareKit.Comm.Fastboot.Backend.Network;
-using FirmwareKit.Comm.Fastboot.DataModel;
 using System.Text;
 
 namespace FirmwareKit.Comm.Fastboot.Tests

FirmwareKit.Comm.Fastboot.Tests/AospFastbootDriverTests.cs

@@ -1,5 +1,3 @@
-using FirmwareKit.Comm.Fastboot.Backend.Network;
-using FirmwareKit.Comm.Fastboot.DataModel;
 using System.Text;
 
 namespace FirmwareKit.Comm.Fastboot.Tests
@@ -115,5 +113,53 @@ public void Test_Download_Fail_Aosp()
             Assert.Equal(FastbootState.Fail, response.Result);
             Assert.Equal("data too large", response.Response);
         }
+
+        [Fact]
+        public void Test_ConsecutiveInfoInSinglePacket()
+        {
+            var transport = new MockTransport();
+            var util = new FastbootUtil(transport);
+
+            // Single packet contains two INFO frames followed by OKAY
+            transport.EnqueueResponse("INFOfirst lineINFOsecond lineOKAY");
+
+            var response = util.RawCommand("oem dmesg");
+
+            Assert.Equal(FastbootState.Success, response.Result);
+            Assert.Equal(2, response.Info.Count);
+            Assert.Equal("first line", response.Info[0]);
+            Assert.Equal("second line", response.Info[1]);
+        }
+
+        [Fact]
+        public void Test_InfoWithoutDelimiterFollowedByOkay()
+        {
+            var transport = new MockTransport();
+            var util = new FastbootUtil(transport);
+
+            // INFO payload without newline then OKAY immediately in same packet
+            transport.EnqueueResponse("INFOpartial infoOKAY");
+
+            var response = util.RawCommand("getvar:all");
+
+            Assert.Equal(FastbootState.Success, response.Result);
+            Assert.Single(response.Info);
+            Assert.Equal("partial info", response.Info[0]);
+        }
+
+        [Fact]
+        public void Test_MalformedDataLength()
+        {
+            var transport = new MockTransport();
+            var util = new FastbootUtil(transport);
+
+            // DATA followed by non-hex content should be treated as malformed
+            transport.EnqueueResponse("DATAGARBAGE");
+
+            var response = util.RawCommand("download:00000010");
+
+            Assert.Equal(FastbootState.Fail, response.Result);
+            Assert.Contains("data size malformed", response.Response);
+        }
     }
 }

FirmwareKit.Comm.Fastboot.Tests/BootImageTests.cs

@@ -1,4 +1,3 @@
-using FirmwareKit.Comm.Fastboot.DataModel;
 using System.Runtime.InteropServices;
 using System.Text;
 

FirmwareKit.Comm.Fastboot.Tests/FastbootInfoTests.cs

@@ -1,4 +1,3 @@
-using FirmwareKit.Comm.Fastboot.Backend.Network;
 using System.Globalization;
 using System.Text;
 

FirmwareKit.Comm.Fastboot.Tests/FastbootProtocolTests.cs

@@ -1,8 +1,5 @@
-using FirmwareKit.Comm.Fastboot.Backend.Usb;
-using FirmwareKit.Comm.Fastboot.DataModel;
-using System.Text;
-using FirmwareKit.Comm.Fastboot.Backend.Network;
 using System.Globalization;
+using System.Text;
 
 namespace FirmwareKit.Comm.Fastboot.Tests
 {

FirmwareKit.Comm.Fastboot.Tests/TcpTransportTests.cs

@@ -1,4 +1,3 @@
-using FirmwareKit.Comm.Fastboot.Backend.Network;
 using System.Buffers.Binary;
 using System.Net;
 using System.Net.Sockets;

FirmwareKit.Comm.Fastboot.Tests/UdpTransportTests.cs

@@ -1,4 +1,3 @@
-using FirmwareKit.Comm.Fastboot.Backend.Network;
 using System.Buffers.Binary;
 using System.Net;
 using System.Net.Sockets;

FirmwareKit.Comm.Fastboot/Backend/Network/IFastbootTransport.cs

@@ -1,9 +1,10 @@
-namespace FirmwareKit.Comm.Fastboot.Backend.Network;
+namespace FirmwareKit.Comm.Fastboot;
+
 
 public interface IFastbootTransport : IDisposable
 {
     byte[] Read(int length);
     long Write(byte[] data, int length);
+}
 
 
-}