Synchronize recording lifecycle regression tests

MeetingAssistant.Tests/RecordingCoordinatorTests.cs

@@ -53,8 +53,14 @@ public sealed class RecordingCoordinatorTests
     {
         try
         {
-            return File.Exists(path) &&
-                File.ReadAllText(path).Contains(text, StringComparison.Ordinal);
+            if (!File.Exists(path))
+            {
+                return false;
+            }
+
+            using var stream = File.Open(path, FileMode.Open, FileAccess.Read, FileShare.ReadWrite | FileShare.Delete);
+            using var reader = new StreamReader(stream);
+            return reader.ReadToEnd().Contains(text, StringComparison.Ordinal);
         }
         catch (IOException)
         {
@@ -3290,6 +3296,7 @@ public sealed class RecordingCoordinatorTests
 
         await coordinator.StartAsync(CancellationToken.None);
         await audioSource.WaitUntilCapturedAsync();
+        await artifactStore.WaitUntilTranscribingAsync();
 
         await coordinator.StopAsync(CancellationToken.None);
 
@@ -3433,6 +3440,7 @@ public sealed class RecordingCoordinatorTests
     {
         var audioSource = new CapturedChunkThenCancelAudioSource(new AudioChunk([1, 0, 2, 0], 16000, 1));
         var artifactStore = new InMemoryMeetingArtifactStore();
+        var metadataProvider = new BlockingMeetingMetadataProvider(new MeetingMetadata("Summary failure", [], "", null));
         var coordinator = new MeetingRecordingCoordinator(
             audioSource,
             new TestSpeechRecognitionPipelineFactory(new FinalSegmentOnAudioCompletionProvider()),
@@ -3443,11 +3451,15 @@ public sealed class RecordingCoordinatorTests
             new InMemoryRecordedAudioStore(),
             new CapturingMeetingSummaryPipeline(succeeded: false),
             Options.Create(CreateOptionsWithoutFinalizer()),
-            NullLogger<MeetingRecordingCoordinator>.Instance);
+            NullLogger<MeetingRecordingCoordinator>.Instance,
+            meetingMetadataProvider: metadataProvider);
 
         await coordinator.StartAsync(CancellationToken.None);
+        await metadataProvider.WaitUntilRequestedAsync();
         await audioSource.WaitUntilCapturedAsync();
 
+        metadataProvider.Release();
+        await artifactStore.WaitUntilTranscribingAsync();
         await coordinator.StopAsync(CancellationToken.None);
 
         Assert.Equal(
@@ -3481,6 +3493,7 @@ public sealed class RecordingCoordinatorTests
 
         await coordinator.StartAsync(CancellationToken.None);
         await audioSource.WaitUntilCapturedAsync();
+        await artifactStore.WaitUntilTranscribingAsync();
 
         await coordinator.StopAsync(CancellationToken.None);
 
@@ -4497,6 +4510,7 @@ public sealed class RecordingCoordinatorTests
 
     private sealed class InMemoryMeetingArtifactStore : IMeetingArtifactStore
     {
+        private readonly TaskCompletionSource transcribing = new(TaskCreationOptions.RunContinuationsAsynchronously);
         private readonly bool createAssistantContextFile;
         private bool failNextMetadataUpdate;
 
@@ -4512,6 +4526,11 @@ public sealed class RecordingCoordinatorTests
 
         public List<AssistantContextState> States { get; } = [];
 
+        public Task WaitUntilTranscribingAsync()
+        {
+            return transcribing.Task.WaitAsync(TimeSpan.FromSeconds(15));
+        }
+
         public string? Agenda { get; private set; }
 
         public DateTimeOffset? ScheduledEnd { get; private set; }
@@ -4553,6 +4572,10 @@ public sealed class RecordingCoordinatorTests
             CancellationToken cancellationToken)
         {
             States.Add(state);
+            if (state == AssistantContextState.Transcribing)
+            {
+                transcribing.TrySetResult();
+            }
             return Task.CompletedTask;
         }