1 write to InteractionId
Aspire.Hosting (1)
InteractionService.cs (1)
723InteractionId = Interlocked.Increment(ref s_nextInteractionId);
68 references to InteractionId
Aspire.Hosting (14)
Dashboard\DashboardService.cs (1)
88change.InteractionId = interaction.InteractionId;
Dashboard\DashboardServiceData.cs (1)
218var inputDtos = CreateInputDtos(_fileUploadStore, interaction.InteractionId, inputsInfo, submittedInputs);
InteractionService.cs (10)
202_fileUploadStore.StartInteraction(newState.InteractionId, fileInputs); 413if (!_interactionCollection.Contains(interactionState.InteractionId)) 435updateEvent = _interactionCollection.Remove(interactionUpdate.InteractionId); 439if (_interactionCollection.Contains(interactionUpdate.InteractionId)) 442throw new InvalidOperationException($"An interaction with ID {interactionUpdate.InteractionId} already exists. Interaction IDs must be unique."); 461if (!_interactionCollection.TryGetValue(interaction.InteractionId, out var interactionState)) 522_fileUploadStore.CompleteInteraction(interactionState.InteractionId); 526_fileUploadStore.CancelInteraction(interactionState.InteractionId); 532_interactionCollection.Remove(interactionState.InteractionId); 696protected override int GetKeyForItem(Interaction item) => item.InteractionId;
Pipelines\PipelineActivityReporter.cs (2)
362Id = interaction.InteractionId.ToString(CultureInfo.InvariantCulture), 393Id = interaction.InteractionId.ToString(CultureInfo.InvariantCulture),
Aspire.Hosting.Tests (54)
Dashboard\DashboardServiceTests.cs (13)
1082var (fileId, _) = fileUploadStore.CreateEntry("spoofed.txt", interaction.InteractionId, textInput.Name); 1087InteractionId = interaction.InteractionId, 1120var (fileId, filePath) = fileUploadStore.CreateEntry("document.txt", interaction.InteractionId, input.Name); 1121var (secondFileId, secondFilePath) = fileUploadStore.CreateEntry("second.txt", interaction.InteractionId, input.Name); 1124fileUploadStore.CompleteUpload(interaction.InteractionId, fileId); 1125fileUploadStore.CompleteUpload(interaction.InteractionId, secondFileId); 1128InteractionId = interaction.InteractionId, 1162Assert.Null(fileUploadStore.GetFilePath(fileId, interaction.InteractionId, input.Name)); 1163Assert.Null(fileUploadStore.GetFilePath(secondFileId, interaction.InteractionId, input.Name)); 1184var (fileId, _) = fileUploadStore.CreateEntry("document.txt", interaction.InteractionId, input.Name); 1185fileUploadStore.CompleteUpload(interaction.InteractionId, fileId); 1188InteractionId = interaction.InteractionId, 1199InteractionId = 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,