10 writes to Data
aspire (1)
BackchannelJsonSerializerContext.PublishingActivity.g.cs (1)
32
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)
812
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
74 references to Data
aspire (74)
BackchannelJsonSerializerContext.PublishingActivity.g.cs (2)
81
Getter = static obj => ((global::Aspire.Cli.Backchannel.PublishingActivity)obj).
Data
,
114
PublishingActivityDataSerializeHandler(writer, ((global::Aspire.Cli.Backchannel.PublishingActivity)value).
Data
);
Commands\PipelineCommandBase.cs (72)
323
if (!steps.TryGetValue(activity.
Data
.Id, out var stepStatus))
326
var statusText = ConvertTextWithMarkdownFlag(activity.
Data
.StatusText, activity.
Data
);
328
steps[activity.
Data
.Id] = activity.
Data
.CompletionState;
330
else if (IsCompletionStateComplete(activity.
Data
.CompletionState))
333
var status = IsCompletionStateError(activity.
Data
.CompletionState) ? "FAILED" :
334
IsCompletionStateWarning(activity.
Data
.CompletionState) ? "WARNING" : "COMPLETED";
335
var statusText = ConvertTextWithMarkdownFlag(activity.
Data
.StatusText, activity.
Data
);
336
InteractionService.DisplaySubtleMessage($"[[DEBUG]] Step {activity.
Data
.Id}: {status} - {statusText}", escapeMarkup: false);
337
steps[activity.
Data
.Id] = activity.
Data
.CompletionState;
347
var logLevel = activity.
Data
.LogLevel ?? "Information";
348
var message = ConvertTextWithMarkdownFlag(activity.
Data
.StatusText, activity.
Data
);
349
var timestamp = activity.
Data
.Timestamp?.ToString("HH:mm:ss", CultureInfo.InvariantCulture) ?? DateTimeOffset.UtcNow.ToString("HH:mm:ss", CultureInfo.InvariantCulture);
376
var stepId = activity.
Data
.StepId;
377
if (IsCompletionStateComplete(activity.
Data
.CompletionState))
379
var status = IsCompletionStateError(activity.
Data
.CompletionState) ? "FAILED" :
380
IsCompletionStateWarning(activity.
Data
.CompletionState) ? "WARNING" : "COMPLETED";
381
var statusText = ConvertTextWithMarkdownFlag(activity.
Data
.StatusText, activity.
Data
);
382
InteractionService.DisplaySubtleMessage($"[[DEBUG]] Task {activity.
Data
.Id} ({stepId}): {status} - {statusText}", escapeMarkup: false);
383
if (!string.IsNullOrEmpty(activity.
Data
.CompletionMessage))
385
var completionMessage = ConvertTextWithMarkdownFlag(activity.
Data
.CompletionMessage, activity.
Data
);
391
var statusText = ConvertTextWithMarkdownFlag(activity.
Data
.StatusText, activity.
Data
);
392
InteractionService.DisplaySubtleMessage($"[[DEBUG]] Task {activity.
Data
.Id} ({stepId}): {statusText}", escapeMarkup: false);
397
var hasErrors = publishingActivity is not null && IsCompletionStateError(publishingActivity.
Data
.CompletionState);
398
var hasWarnings = publishingActivity is not null && IsCompletionStateWarning(publishingActivity.
Data
.CompletionState);
403
var statusText = ConvertTextWithMarkdownFlag(publishingActivity.
Data
.StatusText, publishingActivity.
Data
);
434
if (!steps.TryGetValue(activity.
Data
.Id, out var stepInfo))
436
var title = ConvertTextWithMarkdownFlag(activity.
Data
.StatusText, activity.
Data
);
439
Id = activity.
Data
.Id,
443
CompletionState = activity.
Data
.CompletionState
446
steps[activity.
Data
.Id] = stepInfo;
450
else if (IsCompletionStateComplete(activity.
Data
.CompletionState))
452
stepInfo.CompletionState = activity.
Data
.CompletionState;
453
stepInfo.CompletionText = ConvertTextWithMarkdownFlag(activity.
Data
.StatusText, activity.
Data
);
478
var stepId = activity.
Data
.StepId;
481
var logLevel = activity.
Data
.LogLevel ?? "Information";
482
var message = ConvertTextWithMarkdownFlag(activity.
Data
.StatusText, activity.
Data
);
525
var stepId = activity.
Data
.StepId;
530
throw new InvalidOperationException($"Step '{stepId}' not found for task '{activity.
Data
.Id}'");
535
if (!tasks.TryGetValue(activity.
Data
.Id, out var task))
537
var statusText = ConvertTextWithMarkdownFlag(activity.
Data
.StatusText, activity.
Data
);
540
Id = activity.
Data
.Id,
543
CompletionState = activity.
Data
.CompletionState
546
tasks[activity.
Data
.Id] = task;
550
task.StatusText = ConvertTextWithMarkdownFlag(activity.
Data
.StatusText, activity.
Data
);
551
task.CompletionState = activity.
Data
.CompletionState;
553
if (IsCompletionStateComplete(activity.
Data
.CompletionState))
555
task.CompletionMessage = !string.IsNullOrEmpty(activity.
Data
.CompletionMessage)
556
? ConvertTextWithMarkdownFlag(activity.
Data
.CompletionMessage, activity.
Data
)
590
var hasErrors = IsCompletionStateError(publishingActivity.
Data
.CompletionState);
591
var hasWarnings = IsCompletionStateWarning(publishingActivity.
Data
.CompletionState);
673
if (activity.
Data
.IsComplete)
680
if (activity.
Data
.Inputs is not { Count: > 0 } inputs)
692
var headerText = ConvertTextWithMarkdownFlag(activity.
Data
.StatusText, activity.
Data
);
709
var promptText = BuildPromptText(input, inputs.Count, activity.
Data
.StatusText, activity.
Data
);
725
await backchannel.CompletePromptResponseAsync(activity.
Data
.Id, answers, cancellationToken);