fix(test): UploadAndStartMission_StrictSequenceExecuting

On some slow platforms, start the mission before busy flag is released.

src/Asv.Mavlink.Test/Microservices/Commands/CommandIntComplexTest.cs

@@ -627,12 +627,9 @@ public async Task SendCommandInt_DifferentMavResults_Success(MavResult mavResult
         {
             called++;
             _taskCompletionSource.TrySetResult(args);
+            packetFromClient = args;
             return Task.FromResult(CommandResult.FromResult(mavResult));
         };
-        using var sub = Link.Client.OnTxMessage.Subscribe(p =>
-        {
-            packetFromClient = p as CommandIntPacket;
-        });
 
         // Act
         await _client.SendCommandInt(
@@ -785,13 +782,10 @@ public async Task CommandInt_WithCustomConfig_Success(int maxCommandAttempts, in
             called++;
             var result = MavResult.MavResultAccepted;
             _taskCompletionSource.TrySetResult(args);
+            packetFromClient = args;
             return Task.FromResult(CommandResult.FromResult(result));
         };
-        using var sub = Link.Client.OnTxMessage.Subscribe(p =>
-        {
-            packetFromClient = p as CommandIntPacket;
-        });
-
+
         // Act
         var result = await client.CommandInt(
             MavCmd.MavCmdUser1,

src/Asv.Mavlink.Test/Microservices/Missions/MissionExComplexTest.cs

@@ -550,7 +550,21 @@ public async Task UploadAndStartMission_StrictSequenceExecuting_Success(ushort s
         });
 
         // Act
-        _server.StartMission(skip);
+
+        // On some slow platforms, start the mission before the upload is complete.
+        // We attempt to start it multiple times. It's impossible in real life with async communication
+        start:
+        try
+        {
+            _server.StartMission(skip);
+        }
+        catch (MavlinkException e)
+        {
+            Log.WriteLine("====> tests is slow. Trying to start mission multiple times <===");
+            await Task.Delay(10);
+            goto start;
+        }
+
         await tcs.Task;
 
         // Assert

src/Asv.Mavlink/Microservices/Missions/Client/Ex/MissionClientEx.cs

@@ -156,6 +156,7 @@ public async Task Upload(CancellationToken cancel, Action<double>? progress = nu
 
         await _client.MissionSetCount((ushort) _missionSource.Count, cancel).ConfigureAwait(false);
         await tcs.Task.ConfigureAwait(false);
+        progress?.Invoke(1);
         _isMissionSynced.OnNext(true);
     }
 

src/Asv.Mavlink/Microservices/Missions/Server/Ex/IMissionServerEx.cs

@@ -19,7 +19,6 @@ public enum MissionServerState
 
 public interface IMissionServerEx : IMavlinkMicroserviceServer
 {
-
    IMissionServer Base { get; }
    ReadOnlyReactiveProperty<ushort> Current { get; }
    ReadOnlyReactiveProperty<ushort> Reached { get; }

src/Asv.Mavlink/Microservices/Missions/Server/Ex/MissionServerEx.cs

@@ -19,10 +19,7 @@ public sealed class MissionServerEx : MavlinkMicroserviceServer, IMissionServerE
     private const int InternalBusyStateClearAll = 1;
     private const int InternalBusyStateUploadMission = 2;
     private const int InternalBusyStateStartMission = 3;
-
-
-    private int _internalBusyState;
-
+    private int _internalBusyState = InternalBusyStateIdle;
 
     private readonly IStatusTextServer _statusLogger;
     private readonly ILogger _logger;