1 write to InteractionId
Aspire.Hosting (1)
InteractionService.cs (1)
766InteractionId = Interlocked.Increment(ref s_nextInteractionId);
79 references to InteractionId
Aspire.Hosting (15)
Dashboard\DashboardService.cs (1)
107change.InteractionId = interaction.InteractionId;
Dashboard\DashboardServiceData.cs (1)
225var inputDtos = CreateInputDtos(_fileUploadStore, interaction.InteractionId, inputsInfo, submittedInputs);
InteractionService.cs (11)
206_fileUploadStore.StartInteraction(newState.InteractionId, fileInputs); 417if (_interactionCollection.Contains(interaction.InteractionId)) 456if (!_interactionCollection.Contains(interactionState.InteractionId)) 478updateEvent = _interactionCollection.Remove(interactionUpdate.InteractionId); 482if (_interactionCollection.Contains(interactionUpdate.InteractionId)) 485throw new InvalidOperationException($"An interaction with ID {interactionUpdate.InteractionId} already exists. Interaction IDs must be unique."); 504if (!_interactionCollection.TryGetValue(interaction.InteractionId, out var interactionState)) 565_fileUploadStore.CompleteInteraction(interactionState.InteractionId); 569_fileUploadStore.CancelInteraction(interactionState.InteractionId); 575_interactionCollection.Remove(interactionState.InteractionId); 739protected override int GetKeyForItem(Interaction item) => item.InteractionId;
Pipelines\PipelineActivityReporter.cs (2)
360Id = interaction.InteractionId.ToString(CultureInfo.InvariantCulture), 391Id = interaction.InteractionId.ToString(CultureInfo.InvariantCulture),
Aspire.Hosting.Tests (64)
Dashboard\DashboardServiceTests.cs (14)
660InteractionId = interaction.InteractionId, 1201var (fileId, _) = fileUploadStore.CreateEntry("spoofed.txt", interaction.InteractionId, textInput.Name); 1206InteractionId = interaction.InteractionId, 1239var (fileId, filePath) = fileUploadStore.CreateEntry("document.txt", interaction.InteractionId, input.Name); 1240var (secondFileId, secondFilePath) = fileUploadStore.CreateEntry("second.txt", interaction.InteractionId, input.Name); 1243fileUploadStore.CompleteUpload(interaction.InteractionId, fileId); 1244fileUploadStore.CompleteUpload(interaction.InteractionId, secondFileId); 1247InteractionId = interaction.InteractionId, 1281Assert.Null(fileUploadStore.GetFilePath(fileId, interaction.InteractionId, input.Name)); 1282Assert.Null(fileUploadStore.GetFilePath(secondFileId, interaction.InteractionId, input.Name)); 1303var (fileId, _) = fileUploadStore.CreateEntry("document.txt", interaction.InteractionId, input.Name); 1304fileUploadStore.CompleteUpload(interaction.InteractionId, fileId); 1307InteractionId = interaction.InteractionId, 1318InteractionId = interaction.InteractionId,
InteractionServiceTests.cs (41)
35await CompleteInteractionAsync(interactionService, interaction.InteractionId, new InteractionCompletionState { Complete = true, State = true }); 87id1 = interaction.InteractionId; 91id2 = interaction.InteractionId; 95id3 = interaction.InteractionId; 105interaction => Assert.Equal(interaction.InteractionId, id2), 106interaction => Assert.Equal(interaction.InteractionId, id3)); 112Assert.Equal(id3.Value, Assert.Single(interactionService.GetCurrentInteractions()).InteractionId); 138Assert.Equal(interaction1.InteractionId, (await updates.Reader.ReadAsync().DefaultTimeout()).InteractionId); 143Assert.Equal(interaction2.InteractionId, (await updates.Reader.ReadAsync().DefaultTimeout()).InteractionId); 147await CompleteInteractionAsync(interactionService, interaction1.InteractionId, result1); 149Assert.Equal(interaction2.InteractionId, Assert.Single(interactionService.GetCurrentInteractions()).InteractionId); 155await CompleteInteractionAsync(interactionService, interaction2.InteractionId, result2); 382interaction.InteractionId, 406interaction.InteractionId, 429interaction.InteractionId, 452interaction.InteractionId, 473interaction.InteractionId, 496interaction.InteractionId, 531interaction.InteractionId, 867interaction.InteractionId, 992interaction.InteractionId, 1049interaction.InteractionId, 1174await CompleteInteractionAsync(interactionService, interaction.InteractionId, new InteractionCompletionState { Complete = true, State = false }); 1210await CompleteInteractionAsync(interactionService, interaction.InteractionId, new InteractionCompletionState { Complete = true, State = false }); 1285await CompleteInteractionAsync(interactionService, interaction.InteractionId, new InteractionCompletionState { Complete = true, State = false }); 1360interaction.InteractionId, 1368Assert.Equal(interaction.InteractionId, Assert.Single(fileUploadStore.StartedInteractions)); 1369Assert.Equal(interaction.InteractionId, Assert.Single(fileUploadStore.CompletedInteractions)); 1388interaction.InteractionId, 1395Assert.Equal(interaction.InteractionId, Assert.Single(fileUploadStore.StartedInteractions)); 1396Assert.Equal(interaction.InteractionId, Assert.Single(fileUploadStore.CanceledInteractions)); 1415Assert.Equal(interaction.InteractionId, Assert.Single(fileUploadStore.StartedInteractions)); 1416Assert.Equal(interaction.InteractionId, Assert.Single(fileUploadStore.CanceledInteractions)); 1431interaction.InteractionId, 1455interaction.InteractionId, 1479interaction.InteractionId, 1502interaction.InteractionId, 1536interaction.InteractionId,
ResourceCommandServiceTests.cs (1)
1388interaction.InteractionId,
Terminals\InteractionServiceTerminalTests.cs (8)
121await CompleteInteractionAsync(service, interaction.InteractionId, new[] { input }); 171await CompleteInteractionAsync(service, interaction.InteractionId, completion); 250await CompleteInteractionAsync(service, interaction.InteractionId, false); 291var firstId = updates.Current.InteractionId; 323Assert.Equal(firstId, updates.Current.InteractionId); 332Assert.NotEqual(firstId, updates.Current.InteractionId); 378await CompleteInteractionAsync(service, interaction.InteractionId, !cancel); 411await CompleteInteractionAsync(service, interaction.InteractionId, false);