10 writes to Data
aspire (1)
BackchannelJsonSerializerContext.PublishingActivity.g.cs (1)
30
ObjectWithParameterizedConstructorCreator = static args => new global::Aspire.Cli.Backchannel.PublishingActivity(){ Type = (string)args[0],
Data
= (global::Aspire.Cli.Backchannel.PublishingActivityData)args[1] },
Aspire.Cli.Tests (9)
Commands\PublishCommandPromptingIntegrationTests.cs (1)
811
Data
= new PublishingActivityData
TestServices\TestAppHostBackchannel.cs (8)
126
Data
= new PublishingActivityData
137
Data
= new PublishingActivityData
148
Data
= new PublishingActivityData
159
Data
= new PublishingActivityData
170
Data
= new PublishingActivityData
181
Data
= new PublishingActivityData
192
Data
= new PublishingActivityData
203
Data
= new PublishingActivityData
58 references to Data
aspire (58)
BackchannelJsonSerializerContext.PublishingActivity.g.cs (2)
75
Getter = static obj => ((global::Aspire.Cli.Backchannel.PublishingActivity)obj).
Data
,
105
PublishingActivityDataSerializeHandler(writer, ((global::Aspire.Cli.Backchannel.PublishingActivity)value).
Data
);
Commands\PublishCommandBase.cs (56)
263
if (!steps.TryGetValue(activity.
Data
.Id, out var stepStatus))
266
InteractionService.DisplaySubtleMessage($"[DEBUG] Step {stepCounter++}: {activity.
Data
.StatusText}");
267
steps[activity.
Data
.Id] = activity.
Data
.CompletionState;
269
else if (IsCompletionStateComplete(activity.
Data
.CompletionState))
272
var status = IsCompletionStateError(activity.
Data
.CompletionState) ? "FAILED" :
273
IsCompletionStateWarning(activity.
Data
.CompletionState) ? "WARNING" : "COMPLETED";
274
InteractionService.DisplaySubtleMessage($"[DEBUG] Step {activity.
Data
.Id}: {status} - {activity.
Data
.StatusText}");
275
steps[activity.
Data
.Id] = activity.
Data
.CompletionState;
285
var stepId = activity.
Data
.StepId;
286
if (IsCompletionStateComplete(activity.
Data
.CompletionState))
288
var status = IsCompletionStateError(activity.
Data
.CompletionState) ? "FAILED" :
289
IsCompletionStateWarning(activity.
Data
.CompletionState) ? "WARNING" : "COMPLETED";
290
InteractionService.DisplaySubtleMessage($"[DEBUG] Task {activity.
Data
.Id} ({stepId}): {status} - {activity.
Data
.StatusText}");
291
if (!string.IsNullOrEmpty(activity.
Data
.CompletionMessage))
293
InteractionService.DisplaySubtleMessage($"[DEBUG] {activity.
Data
.CompletionMessage}");
298
InteractionService.DisplaySubtleMessage($"[DEBUG] Task {activity.
Data
.Id} ({stepId}): {activity.
Data
.StatusText}");
303
var hasErrors = publishingActivity is not null && IsCompletionStateError(publishingActivity.
Data
.CompletionState);
304
var hasWarnings = publishingActivity is not null && IsCompletionStateWarning(publishingActivity.
Data
.CompletionState);
309
InteractionService.DisplaySubtleMessage($"[DEBUG] {OperationCompletedPrefix}: {status} - {publishingActivity.
Data
.StatusText}");
338
if (!steps.TryGetValue(activity.
Data
.Id, out var stepInfo))
347
Id = activity.
Data
.Id,
348
Title = activity.
Data
.StatusText,
351
CompletionState = activity.
Data
.CompletionState
354
steps[activity.
Data
.Id] = stepInfo;
363
else if (IsCompletionStateComplete(activity.
Data
.CompletionState))
365
stepInfo.CompletionState = activity.
Data
.CompletionState;
366
stepInfo.CompletionText = activity.
Data
.StatusText;
393
throw new InvalidOperationException($"Step activity with ID '{activity.
Data
.Id}' is not complete. Expected it to be complete before processing tasks.");
402
var stepId = activity.
Data
.StepId;
407
throw new InvalidOperationException($"Task activity with ID '{activity.
Data
.Id}' is not associated with the current step '{currentStepProgress.Step?.Id}'.");
414
if (!tasks.TryGetValue(activity.
Data
.Id, out var task))
418
Id = activity.
Data
.Id,
419
StatusText = activity.
Data
.StatusText,
421
CompletionState = activity.
Data
.CompletionState
424
tasks[activity.
Data
.Id] = task;
427
task.ProgressTask = currentStepProgress.Ctx!.AddTask($" {activity.
Data
.StatusText.EscapeMarkup()}");
433
throw new InvalidOperationException($"Task with ID '{activity.
Data
.Id}' does not have an associated ProgressTask.");
436
task.StatusText = activity.
Data
.StatusText;
437
task.CompletionState = activity.
Data
.CompletionState;
439
if (IsCompletionStateComplete(activity.
Data
.CompletionState))
444
task.CompletionMessage = activity.
Data
.CompletionMessage;
447
if (currentStepProgress.TaskCompletionMessages != null && !string.IsNullOrEmpty(activity.
Data
.CompletionMessage))
449
currentStepProgress.TaskCompletionMessages[task.ProgressTask.Id] = activity.
Data
.CompletionMessage;
463
var hasErrors = publishingActivity is not null && IsCompletionStateError(publishingActivity.
Data
.CompletionState);
464
var hasWarnings = publishingActivity is not null && IsCompletionStateWarning(publishingActivity.
Data
.CompletionState);
474
AnsiConsole.MarkupLine($"{prefix} {publishingActivity.
Data
.StatusText.EscapeMarkup()}");
507
if (activity.
Data
.IsComplete)
514
if (activity.
Data
.Inputs is not { Count: > 0 } inputs)
526
var headerText = MarkdownToSpectreConverter.ConvertToSpectre(activity.
Data
.StatusText);
543
var promptText = BuildPromptText(input, inputs.Count, activity.
Data
.StatusText);
559
await backchannel.CompletePromptResponseAsync(activity.
Data
.Id, answers, cancellationToken);