10public T Resource { get; } = resource;

730public T Resource => resource;

2841public T Resource { get; }

53builder.Resource.Certificates.Add(certificate); 70builder.Resource.Certificates.AddRange(certificates); 87builder.Resource.Certificates.AddRange(certificates.ToArray()); 128builder.Resource.Certificates.AddRange(certificates.ToArray());

431_valueProviders.Add(valueProvider.Resource); 432_manifestExpressions.Add(valueProvider.Resource.ValueExpression); 598var unwrapped = valueProvider is IResourceBuilder<IResource> rb ? rb.Resource : valueProvider; 718builder.AppendFormatted(valueProvider.Resource, format);

598(DistributedApplicationOperation.Run, IResourceBuilder<IResource> rb) when rb.Resource is IValueProvider provider => await resource.GetValue(executionContext, key, provider, logger, cancellationToken).ConfigureAwait(false), 600(DistributedApplicationOperation.Publish, IResourceBuilder<IResource> rb) when rb.Resource is IManifestExpressionProvider provider => new(provider.ValueExpression, false), 1869VisitReferences(resourceBuilder.Resource, visitedValues, visitor);

179return resource.Resource.Name;

107loggerService.Complete(resource.Resource);

71return notificationService.WaitForDependenciesAsync(resource.Resource, CancellationToken.None); 99return notificationService.PublishUpdateAsync(resource.Resource, snapshot =>

49var endpointExpression = ReferenceExpression.Create($"{endpoint.Resource}"); 51? ReferenceExpression.Create($"{repository.Resource}") 194return builder.WithAnnotation(new ContainerRegistryReferenceAnnotation(registry.Resource));

55if (builder.Resource.IsExcludedFromPublish()) 60if (builder.Resource.RequiresImageBuild()) 64Name = $"build-{builder.Resource.Name}", 69builder.Resource, 75Resource = builder.Resource 80if (builder.Resource.RequiresImageBuildAndPush()) 84Name = $"push-{builder.Resource.Name}", 85Action = ctx => PipelineStepHelpers.PushImageToRegistryAsync(builder.Resource, ctx), 88Resource = builder.Resource 98var buildSteps = context.GetSteps(builder.Resource, WellKnownPipelineTags.BuildCompute); 99var pushSteps = context.GetSteps(builder.Resource, WellKnownPipelineTags.PushContainerImage); 342builder.Resource.Entrypoint = entrypoint; 360if (builder.Resource.Annotations.OfType<ContainerImageAnnotation>().LastOrDefault() is { } existingImageAnnotation) 366if (builder.Resource.Annotations.OfType<DockerfileBuildAnnotation>().SingleOrDefault() is { } buildAnnotation && 391if (builder.Resource.Annotations.OfType<ContainerImageAnnotation>().LastOrDefault() is { } existingImageAnnotation) 432if (builder.Resource.Annotations.OfType<ContainerImageAnnotation>().LastOrDefault() is { } imageAnnotation) 439builder.Resource.Annotations.Add(imageAnnotation); 460if (builder.Resource.Annotations.OfType<DockerfileBuildAnnotation>().SingleOrDefault() is { } buildAnnotation) 483if (builder.Resource.Annotations.OfType<ContainerImageAnnotation>().LastOrDefault() is { } existingImageAnnotation) 617throw new InvalidOperationException($"The resource '{builder.Resource.Name}' does not have a container image specified. Use WithImage to specify the container image and tag."); 631return builder.WithManifestPublishingCallback(context => context.WriteContainerAsync(builder.Resource)); 717if (builder.Resource.Annotations.OfType<ContainerImageAnnotation>().LastOrDefault() is { }) 867if (builder.Resource.Annotations.OfType<ContainerImageAnnotation>().LastOrDefault() is { }) 1154var annotation = builder.Resource.Annotations.OfType<DockerfileBuildAnnotation>().SingleOrDefault(); 1158throw new InvalidOperationException($"The resource '{builder.Resource.Name}' does not have a Dockerfile build annotation. Call WithDockerfile before calling WithBuildArg."); 1206if (value.Resource.Secret) 1208throw new InvalidOperationException($"Cannot add secret parameter '{value.Resource.Name}' as build argument '{name}' while configuring resource '{builder.Resource.Name}'. Use WithBuildSecret instead."); 1211return builder.WithBuildArg(name, value.Resource); 1285var annotation = builder.Resource.Annotations.OfType<DockerfileBuildAnnotation>().SingleOrDefault(); 1289throw new InvalidOperationException($"The resource '{builder.Resource.Name}' does not have a Dockerfile build annotation. Call WithDockerfile before calling WithBuildSecret."); 1292annotation.BuildSecrets[name] = value.Resource; 1718var callbackAnnotation = builder.Resource.Annotations.OfType<DockerfileBuilderCallbackAnnotation>().LastOrDefault();

141builder.ApplicationBuilder.Eventing.Subscribe<TEvent>(builder.Resource, (evt, ct) => callback(builder.Resource, evt, ct));

63builder.Resource.Annotations.Add(new EndpointEnvironmentInjectionFilterAnnotation(filter)); 121if (builder.Resource is not IComputeResource) 124$"Resource '{builder.Resource.Name}' must implement {nameof(IComputeResource)} to use .NET SDK publishing."); 127_ = builder.Resource.GetProjectMetadata(); 128DotnetProgramPublishing.Configure(builder.Resource);

129builder.Resource.ToolConfiguration?.PackageId = packageId; 145builder.Resource.ToolConfiguration?.Version = version; 160builder.Resource.ToolConfiguration?.Prerelease = true; 176builder.Resource.ToolConfiguration?.Sources.Add(source); 191builder.Resource.ToolConfiguration?.IgnoreExistingFeeds = true; 206builder.Resource.ToolConfiguration?.IgnoreFailedSources = true;

136if (builder.ApplicationBuilder.TryCreateResourceBuilder<ExecutableContainerResource>(builder.Resource.Name, out var existingBuilder)) 154builder.ApplicationBuilder.Resources.Remove(builder.Resource); 156var container = new ExecutableContainerResource(builder.Resource); 159cb.WithImage(builder.Resource.Name); 160var dockerfileContextPath = builder.Resource.WorkingDirectory; 161if (builder.Resource is IDotnetProgramResource && 162builder.Resource.TryGetProjectMetadata(out var projectMetadata)) 172if (builder.Resource is IDotnetProgramResource) 200var executableAnnotation = builder.Resource.Annotations.OfType<ExecutableAnnotation>().LastOrDefault(); 212builder.Resource.Annotations.Add(executableAnnotation); 231if (builder.Resource.Annotations.OfType<ExecutableAnnotation>().LastOrDefault() is { } executableAnnotation) 241throw new InvalidOperationException($"The resource '{builder.Resource.Name}' is missing the ExecutableAnnotation");

94return AddExternalServiceImpl(builder, name, urlParameter: urlParameter.Resource); 227if (builder.Resource.UrlParameter is null) 229if (builder.Resource.Uri is null) 231throw new ArgumentException($"The URL for external service '{builder.Resource.Name}' is null.", nameof(builder)); 233else if (builder.Resource.Uri.Scheme != "http" && builder.Resource.Uri.Scheme != "https") 235throw new ArgumentException($"The URL '{builder.Resource.Uri}' for external service '{builder.Resource.Name}' cannot be used for HTTP health checks because it has a non-HTTP scheme.", nameof(builder)); 239Debug.Assert(builder.Resource.Uri is not null || builder.Resource.UrlParameter is not null, "Either Uri or UrlParameter must be provided."); 244var healthCheckKey = $"{builder.Resource.Name}_external{pathKey}_{statusCode}_check"; 250if (builder.Resource.UrlParameter is not null) 256builder.Resource.UrlParameter, 266var uri = builder.Resource.Uri!;

72builder.Resource.Annotations.Add(new OtlpExporterAnnotation { RequiredProtocol = protocol }); 74builder.Resource, 219AddOtlpEnvironment(builder.Resource, builder.ApplicationBuilder.Configuration, builder.ApplicationBuilder.Environment); 256AddOtlpEnvironment(builder.Resource, builder.ApplicationBuilder.Configuration, builder.ApplicationBuilder.Environment, protocol);

212builder.Resource.Description = description; 213builder.Resource.EnableDescriptionMarkdown = enableMarkdown; 245builder.Resource.Required = required; 277builder.Resource.Annotations.Add(new InputGeneratorAnnotation(createInput)); 294builder.Resource.Annotations.Add(new InputGeneratorAnnotation(parameter => new InteractionInput 417var parameter = new ParameterResource(builder.Resource.Name, _ => "", secret: true);

123Resource = builder.Resource

537var projectMetadata = builder.Resource.GetProjectMetadata(); 541if (!builder.Resource.TryGetLastAnnotation<ProjectLaunchDefaultsAnnotation>(out var launchDefaults)) 552$"Project defaults have already been applied to resource '{builder.Resource.Name}'. " + 562builder.Resource, 565mode => ProjectLaunchConfigurationFactory.Create(builder.Resource, mode), 616if (!string.Equals(builder.Resource.Name, KnownResourceNames.AspireDashboard, StringComparisons.ResourceName)) 635var logger = resourceLogger.GetLogger(builder.Resource); 676var projectResource = builder.Resource; 1035builder.Resource.Annotations.Add(new EndpointEnvironmentInjectionFilterAnnotation(filter)); 1067if (builder.ApplicationBuilder.TryCreateResourceBuilder<ProjectContainerResource>(builder.Resource.Name, out var existingBuilder)) 1081builder.ApplicationBuilder.Resources.Remove(builder.Resource); 1083var container = new ProjectContainerResource(builder.Resource); 1086cb.WithImage(builder.Resource.Name); 1088var projectFilePath = builder.Resource.GetProjectMetadata().ProjectPath; 1193foreach (var e in builder.Resource.GetEndpoints().Where(builder.Resource.ShouldInjectEndpointEnvironment)) 1244foreach (var e in builder.Resource.GetEndpoints().Where(builder.Resource.ShouldInjectEndpointEnvironment)) 1276foreach (var e in builder.Resource.GetEndpoints().Where(builder.Resource.ShouldInjectEndpointEnvironment))

140if (builder.Resource is ContainerResource or ExecutableResource or ProjectResource) 147SourceResource = sourceBuilder.Resource 151throw new InvalidOperationException($"Resource '{builder.Resource.Name}' does not support lifetime configuration."); 208if (builder.Resource is ContainerResource or ExecutableResource or ProjectResource) 223throw new InvalidOperationException($"Resource '{builder.Resource.Name}' does not support lifetime configuration."); 229foreach (var annotation in builder.Resource.Annotations.OfType<ContainerLifetimeAnnotation>().ToArray()) 231builder.Resource.Annotations.Remove(annotation); 447builder.WithReferenceRelationship(externalService.Resource); 449if (externalService.Resource.Uri is not null) 451builder.WithEnvironment(name, externalService.Resource.Uri.ToString()); 453else if (externalService.Resource.UrlParameter is not null) 460var url = await externalService.Resource.UrlParameter.GetValueAsync(context.CancellationToken).ConfigureAwait(false); 463throw new DistributedApplicationException($"The URL parameter '{externalService.Resource.UrlParameter.Name}' for source resource '{externalService.Resource.Name}' is invalid while configuring target resource '{builder.Resource.Name}': {message}"); 467context.EnvironmentVariables[name] = externalService.Resource.UrlParameter; 489builder.WithReferenceRelationship(parameter.Resource); 493context.EnvironmentVariables[name] = parameter.Resource; 516builder.WithReferenceRelationship(resource.Resource); 520context.EnvironmentVariables[envVarName] = new ConnectionStringReference(resource.Resource, optional: false); 734builder.Resource.WithSerializedAnnotation(annotationId, json); 772return GetSerializedAnnotation(builder.Resource, annotationId); 803return HasSerializedAnnotation(builder.Resource, annotationId); 855return GetAnnotation(builder.Resource, definition); 1217var hasConnectionString = source.Resource is IResourceWithConnectionString && connectionStringSource is not null; 1218var hasServiceDiscovery = source.Resource is IResourceWithServiceDiscovery && serviceDiscoverySource is not null; 1219var hasExternalService = source.Resource is ExternalServiceResource && externalServiceSource is not null; 1269throw new InvalidOperationException($"The resource '{source.Resource.Name}' can't be used with withReference because it doesn't provide a connection string, service discovery, or a custom withReference implementation."); 1296return TryDispatchCustomWithReference(builder, source, connectionName, optional, name, source.Resource.GetType(), out dispatchedBuilder); 1369var resource = source.Resource; 1375builder.Resource.TryGetLastAnnotation<ReferenceEnvironmentInjectionAnnotation>(out var injectionAnnotation); 1521ApplyEndpoints(builder, source.Resource); 1553ApplyEndpoints(builder, source.Resource, endpointName: null, name); 1577throw new InvalidOperationException($"The URI for service reference '{name}' is invalid while configuring target resource '{builder.Resource.Name}': it must be absolute."); 1582throw new InvalidOperationException($"The URI for service reference '{name}' is invalid while configuring target resource '{builder.Resource.Name}': it cannot contain a fragment."); 1587throw new InvalidOperationException($"The URI for service reference '{name}' is invalid while configuring target resource '{builder.Resource.Name}': it cannot contain a query string."); 1591builder.Resource.TryGetLastAnnotation<ReferenceEnvironmentInjectionAnnotation>(out var injectionAnnotation); 1622builder.WithReferenceRelationship(externalService.Resource); 1625builder.Resource.TryGetLastAnnotation<ReferenceEnvironmentInjectionAnnotation>(out var injectionAnnotation); 1628if (externalService.Resource.Uri is { } uri) 1632var encodedResourceName = EnvironmentVariableNameEncoder.Encode(externalService.Resource.Name); 1638var envVarName = $"services__{externalService.Resource.Name}__{uri.Scheme}__0"; 1642else if (externalService.Resource.UrlParameter is not null) 1648var encodedResourceName = EnvironmentVariableNameEncoder.Encode(externalService.Resource.Name); 1653discoveryEnvVarName = $"services__{externalService.Resource.Name}__default__0"; 1656else if (ExternalServiceResource.UrlIsValidForExternalService(await externalService.Resource.UrlParameter.GetValueAsync(context.CancellationToken).ConfigureAwait(false), out var uri, out var message)) 1658discoveryEnvVarName = $"services__{externalService.Resource.Name}__{uri.Scheme}__0"; 1664throw new DistributedApplicationException($"The URL parameter '{externalService.Resource.UrlParameter.Name}' for source resource '{externalService.Resource.Name}' is invalid while configuring target resource '{builder.Resource.Name}': {message}"); 1669context.EnvironmentVariables[discoveryEnvVarName] = externalService.Resource.UrlParameter; 1674context.EnvironmentVariables[endpointEnvVarName] = externalService.Resource.UrlParameter; 1709var endpointReferenceAnnotation = builder.Resource.Annotations 1717if (builder.Resource.IsContainer()) 1779var endpoint = builder.Resource.Annotations 1796builder.Resource.Annotations.Add(endpoint); 1846!builder.Resource.Annotations.OfType<EndpointAnnotation>().Any(endpoint => string.Equals(endpoint.Name, endpointName, StringComparisons.EndpointAnnotationName))) 1883var existing = builder.Resource.Annotations.OfType<EndpointAnnotation>() 1964if (env is null || builder.Resource is not IResourceWithEndpoints resourceWithEndpoints || builder.Resource is not IResourceWithEnvironment) 2174if (!builder.Resource.TryGetAnnotationsOfType<EndpointAnnotation>(out var endpoints)) 2205return builder.Resource.GetEndpoint(name, contextNetworkId); 2222return builder.Resource.GetEndpoint(name); 2502if (builder.Resource is IResourceWithEndpoints resource) 2516context.Logger.LogWarning("Could not execute callback to customize endpoint URL as no endpoint with name '{EndpointName}' could be found on resource '{ResourceName}'.", endpointName, builder.Resource.Name); 2562context.Logger.LogWarning("Could not execute callback to add an endpoint URL as no endpoint with name '{EndpointName}' could be found on resource '{ResourceName}'.", endpointName, builder.Resource.Name); 2602if (resourceComparer.Equals(builder.Resource, endpoint.Resource)) 2604context.Logger.LogWarning("Could not execute callback to customize endpoint URL as no URL for endpoint '{EndpointName}' could be found on resource '{ResourceName}'.", endpoint.EndpointName, builder.Resource.Name); 2645Source = source.Resource, 2684builder.Resource.Annotations 2687.ForEach(w => builder.Resource.Annotations.Remove(w)); 2805if (builder.Resource as IResource == dependency.Resource) 2807throw new DistributedApplicationException($"The '{builder.Resource.Name}' resource cannot wait for itself."); 2810if (builder.Resource is IResourceWithParent resourceWithParent && resourceWithParent.Parent == dependency.Resource) 2812throw new DistributedApplicationException($"The '{builder.Resource.Name}' resource cannot wait for its parent '{dependency.Resource.Name}'."); 2815if (dependency.Resource is IResourceWithParent dependencyResourceWithParent) 2828builder.WithRelationship(dependency.Resource, KnownRelationshipTypes.WaitFor); 2831return builder.WithAnnotation(new WaitAnnotation(dependency.Resource, WaitType.WaitUntilHealthy) { WaitBehavior = waitBehavior }); 2928if (builder.Resource as IResource == dependency.Resource) 2930throw new DistributedApplicationException($"The '{builder.Resource.Name}' resource cannot wait for itself."); 2933if (builder.Resource is IResourceWithParent resourceWithParent && resourceWithParent.Parent == dependency.Resource) 2935throw new DistributedApplicationException($"The '{builder.Resource.Name}' resource cannot wait for its parent '{dependency.Resource.Name}'."); 2938if (dependency.Resource is IResourceWithParent dependencyResourceWithParent) 2950if (dependency.Resource is ConnectionStringResource cs) 2961builder.WithRelationship(dependency.Resource, KnownRelationshipTypes.WaitFor); 2964return builder.WithAnnotation(new WaitAnnotation(dependency.Resource, WaitType.WaitUntilStarted) { WaitBehavior = waitBehavior }); 3031if (builder.Resource as IResource == dependency.Resource) 3033throw new DistributedApplicationException($"The '{builder.Resource.Name}' resource cannot wait for itself."); 3036if (builder.Resource is IResourceWithParent resourceWithParent && resourceWithParent.Parent == dependency.Resource) 3038throw new DistributedApplicationException($"The '{builder.Resource.Name}' resource cannot wait for its parent '{dependency.Resource.Name}'."); 3041builder.WithRelationship(dependency.Resource, KnownRelationshipTypes.WaitFor); 3043return builder.WithAnnotation(new WaitAnnotation(dependency.Resource, WaitType.WaitForCompletion, exitCode)); 3091if (builder.Resource.TryGetAnnotationsOfType<HealthCheckAnnotation>(out var annotations) && annotations.Any(a => a.Key == key)) 3093throw new DistributedApplicationException($"Resource '{builder.Resource.Name}' already has a health check with key '{key}'."); 3180?? throw new DistributedApplicationException($"Could not create HTTP health check for resource '{builder.Resource.Name}' as the endpoint selector returned null."); 3184throw new DistributedApplicationException($"Could not create HTTP health check for resource '{builder.Resource.Name}' as the endpoint with name '{endpoint.EndpointName}' and scheme '{endpoint.Scheme}' is not an HTTP endpoint."); 3197throw new DistributedApplicationException($"The endpoint '{endpointName}' does not exist on the resource '{builder.Resource.Name}'."); 3203var healthCheckKey = $"{builder.Resource.Name}_{endpointName}_{path}_{statusCode}_check"; 3299var existingAnnotation = builder.Resource.Annotations.OfType<ResourceCommandAnnotation>().SingleOrDefault(a => a.Name == name); 3302builder.Resource.Annotations.Remove(existingAnnotation); 3366var existingAnnotation = builder.Resource.Annotations.OfType<ResourceCommandAnnotation>().SingleOrDefault(a => a.Name == name); 3369builder.Resource.Annotations.Remove(existingAnnotation); 4055?? throw new DistributedApplicationException($"Could not create HTTP command for resource '{builder.Resource.Name}' as the endpoint selector returned null."); 4059throw new DistributedApplicationException($"Could not create HTTP command for resource '{builder.Resource.Name}' as the endpoint with name '{endpoint.EndpointName}' and scheme '{endpoint.Scheme}' is not an HTTP endpoint."); 4367CertificateAuthorityCollections = { certificateAuthorityCollection.Resource }, 4369if (builder.Resource.TryGetLastAnnotation<CertificateAuthorityCollectionAnnotation>(out var existingAnnotation)) 4373if (existingCollection != certificateAuthorityCollection.Resource) 4426if (builder.Resource.TryGetLastAnnotation<CertificateAuthorityCollectionAnnotation>(out var existingAnnotation)) 4477if (builder.Resource.TryGetLastAnnotation<CertificateAuthorityCollectionAnnotation>(out var existingAnnotation)) 4590Password = password?.Resource, 4626Password = password?.Resource, 4733var resource = builder.Resource; 4780var endpoints = builder.Resource.GetEndpoints(); 4790throw new DistributedApplicationException($"Could not create {errorDisplayNoun} for resource '{builder.Resource.Name}' as the endpoint with name '{matchingEndpoint.EndpointName}' and scheme '{matchingEndpoint.Scheme}' is not an HTTP endpoint."); 4798throw new DistributedApplicationException($"Could not create {errorDisplayNoun} for resource '{builder.Resource.Name}' as no endpoint was found matching one of the specified names: {endpointNamesString}"); 4806var endpoints = builder.Resource.GetEndpoints(); 4818throw new DistributedApplicationException($"Could not create HTTP command for resource '{builder.Resource.Name}' as it has no HTTP endpoints."); 4855if (!builder.Resource.Annotations.OfType<ResourceRelationshipAnnotation>().Any(r => ReferenceEquals(r.Resource, resource) && r.Type == type)) 4880return builder.WithRelationship(resourceBuilder.Resource, type); 4946AddReference(resourceBuilder.Resource); 4979return builder.WithAnnotation(new ResourceRelationshipAnnotation(resourceBuilder.Resource, KnownRelationshipTypes.Reference)); 5012return builder.WithParentRelationship(parent.Resource); 5078child.WithRelationship(builder.Resource, KnownRelationshipTypes.Parent); 5172builder.WithAnnotation(new ComputeEnvironmentAnnotation(computeEnvironmentResource.Resource)); 5423builder.Resource.Name, 5452var workingDirectory = Path.GetFullPath(builder.Resource.WorkingDirectory); 5563var endpoint = endpointSelector() ?? throw new DistributedApplicationException($"Could not create HTTP probe for resource '{builder.Resource.Name}' as the endpoint selector returned null."); 5591if (builder.Resource.Annotations.OfType<ProbeAnnotation>().SingleOrDefault(a => a.Type == probeAnnotation.Type) is { } existingAnnotation) 5593builder.Resource.Annotations.Remove(existingAnnotation);

28foreach (var previous in builder.Resource.Annotations.OfType<TraitAnnotation>().Where(t => t.Name == name).ToArray()) 30builder.Resource.Annotations.Remove(previous);

79if (builder.Resource.Annotations.OfType<TerminalAnnotation>().Any()) 82$"Resource '{builder.Resource.Name}' already has a terminal configured. Call WithTerminal() only once per resource."); 101var parent = builder.Resource;

18return builder.Resource.Name.ToLowerInvariant();

33var resourceName = builder.Resource.Name;

79if (builder.Resource is not IResourceWithEnvironment) 82$"Resource '{builder.Resource.Name}' does not support environment variables and cannot use the '{env}' volume path variable.");

60return new BicepOutputReference(name, builder.Resource); 72return new BicepSecretOutputReference(name, builder.Resource); 135builder.Resource.Parameters[name] = null; 186builder.Resource.Parameters[name] = value; 203builder.Resource.Parameters[name] = value; 221builder.Resource.Parameters[name] = value; 239builder.Resource.Parameters[name] = valueCallback; 255return builder.WithParameter(name, value.Resource); 275builder.Resource.Parameters[name] = value; 293builder.WithReferenceRelationship(value.Resource); 295builder.Resource.Parameters[name] = value.Resource; 315builder.Resource.Parameters[name] = value; 335builder.Resource.Parameters[name] = value; 355builder.Resource.Parameters[name] = value;

116builder.Resource.Location = location.Resource; 140builder.Resource.ResourceGroupName = resourceGroup.Resource;

48builder.Resource.ConfigureInfrastructure += configure; 134return parameterResourceBuilder.Resource.AsProvisioningParameter(infrastructure, parameterName);

74var annotations = builder.Resource.Annotations.OfType<DefaultRoleAssignmentsAnnotation>().ToList(); 77builder.Resource.Annotations.Remove(annotation);

72builder.WithAnnotation(new AppIdentityAnnotation(identityResourceBuilder.Resource));

54return RunAsExistingCore(builder, nameParameter.Resource, resourceGroupParameter?.Resource); 110return PublishAsExistingCore(builder, nameParameter.Resource, resourceGroupParameter?.Resource); 170return AsExistingCore(builder, nameParameter.Resource, resourceGroupParameter?.Resource); 210return RunAsExistingCore(builder, nameParameter.Resource, resourceGroup: null, subscription: subscriptionParameter.Resource); 267return PublishAsExistingCore(builder, nameParameter.Resource, resourceGroup: null, subscription: subscriptionParameter.Resource); 324return AsExistingCore(builder, nameParameter.Resource, resourceGroup: null, subscription: subscriptionParameter.Resource); 381return RunAsExistingCore(builder, nameParameter.Resource, resourceGroupParameter.Resource, subscriptionParameter.Resource); 442return PublishAsExistingCore(builder, nameParameter.Resource, resourceGroupParameter.Resource, subscriptionParameter.Resource); 505return AsExistingCore(builder, nameParameter.Resource, resourceGroupParameter.Resource, subscriptionParameter.Resource); 566return RunAsExistingCore(builder, nameParameter.Resource, resourceGroup: null, subscription: null, isTenantScope: true); 618return PublishAsExistingCore(builder, nameParameter.Resource, resourceGroup: null, subscription: null, isTenantScope: true); 670return AsExistingCore(builder, nameParameter.Resource, resourceGroup: null, subscription: null, isTenantScope: true);

120var surrogate = new AzureAppConfigurationEmulatorResource(builder.Resource); 143return builder.WithBindMount(path ?? $".aace/{builder.Resource.Name}", "/app/.aace", isReadOnly: false);

15return builder.WithAnnotation(new RoleAssignmentAnnotation(target.Resource, CreateRoleDefinitions(roles, getName)));

968builder.Resource.UseAzdNamingConvention = true; 999builder.Resource.UseCompactResourceNaming = true; 1054builder.Resource.UseUniqueResourceNaming = true; 1083builder.Resource.IsExpress = true; 1097builder.Resource.EnableDashboard = enable; 1118builder.Resource.PreserveHttpEndpoints = !upgrade; 1137builder.WithAnnotation(new AzureLogAnalyticsWorkspaceReferenceAnnotation(workspaceBuilder.Resource)); 1194builder.WithAnnotation(new AzureContainerAppEnvironmentAcrPullIdentityAnnotation(identityBuilder.Resource));

45if (!ShouldPrepareIdentity(context.PipelineContext.ExecutionContext, builder.Resource)) 54Name = $"prepare-cross-scope-acr-pull-identity-{builder.Resource.Name}", 55Description = $"Prepares the ACR pull identity for {builder.Resource.Name}.", 106if (!ShouldPrepareIdentity(context.ExecutionContext, builder.Resource) || 107builder.Resource.ContainerRegistry is not AzureContainerRegistryResource registry) 115var identityName = $"{builder.Resource.Name}-mi"; 119$"Cannot create the cross-scope ACR pull identity '{identityName}' for environment '{builder.Resource.Name}' because a resource with that name already exists. Call 'WithAcrPullIdentity' on the environment to select an existing identity, or use a different resource name."); 143builder.Resource.Annotations.Add(createIdentityAnnotation(identity)); 144if (builder.Resource is AzureBicepResource environment)

156return builder.WithLogAnalyticsWorkspace(logAnalyticsWorkspace.Resource.WorkspaceId);

90if (!builder.Resource.HasAnnotationOfType<AzureAppServiceWebsiteCustomizationAnnotation>() && 91!builder.Resource.HasAnnotationOfType<AzureAppServiceWebsiteSlotCustomizationAnnotation>())

331builder.Resource.PreserveHttpEndpoints = !upgrade; 345builder.Resource.EnableDashboard = enable; 358builder.Resource.EnableApplicationInsights = true; 394builder.Resource.ApplicationInsightsLocation = applicationInsightsLocation; 408builder.Resource.ApplicationInsightsLocationParameter = applicationInsightsLocation.Resource; 422builder.Resource.ApplicationInsightsResource = applicationInsightsBuilder.Resource; 438builder.Resource.DeploymentSlotParameter = deploymentSlot.Resource; 473builder.Resource.DeploymentSlot = deploymentSlot; 542builder.WithAnnotation(new AzureAppServiceEnvironmentAcrPullIdentityAnnotation(identityBuilder.Resource));

45if (!ShouldPrepareIdentity(context.PipelineContext.ExecutionContext, builder.Resource)) 54Name = $"prepare-cross-scope-acr-pull-identity-{builder.Resource.Name}", 55Description = $"Prepares the ACR pull identity for {builder.Resource.Name}.", 106if (!ShouldPrepareIdentity(context.ExecutionContext, builder.Resource) || 107builder.Resource.ContainerRegistry is not AzureContainerRegistryResource registry) 115var identityName = $"{builder.Resource.Name}-mi"; 119$"Cannot create the cross-scope ACR pull identity '{identityName}' for environment '{builder.Resource.Name}' because a resource with that name already exists. Call 'WithAcrPullIdentity' on the environment to select an existing identity, or use a different resource name."); 143builder.Resource.Annotations.Add(createIdentityAnnotation(identity)); 144if (builder.Resource is AzureBicepResource environment)

175builder.Resource.AddDeployment(deployment); 198var deployment = new AzureOpenAIDeploymentResource(name, modelName, modelVersion, builder.Resource); 199builder.Resource.AddDeployment(deployment); 218configure(builder.Resource);

15return builder.WithAnnotation(new RoleAssignmentAnnotation(target.Resource, CreateRoleDefinitions(roles, getName)));

280if (builder.Resource.Connections.Any(connection => 284$"Connector connection '{connectionName}' is already registered on Connector Namespace '{builder.Resource.Name}'."); 292builder.Resource); 294builder.Resource.Connections.Add(connection); 326var configurationName = connectionName ?? connection.Resource.Name; 329connection.Resource.Parent.NameOutputReference); 332connection.Resource.ConnectionName); 348if (!string.IsNullOrWhiteSpace(builder.Resource.DisplayName)) 351$"Connector connection '{builder.Resource.Name}' configures a display name and cannot be marked as existing."); 353if (builder.Resource.AccessPolicies.Count > 0) 356$"Connector connection '{builder.Resource.Name}' configures access policies and cannot be marked as existing."); 359builder.Resource.IsExisting = true; 391if (builder.Resource.IsExisting) 394$"Existing connector connection '{builder.Resource.Name}' is read-only and cannot create an access policy."); 399var resourceName = GetValidatedAccessPolicyResourceName(builder.Resource, name, policyName); 401builder.Resource.AccessPolicies.Add(new AzureConnectorNamespaceConnectionAccessPolicyResource( 404builder.Resource, 433if (builder.Resource.IsExisting) 436$"Existing connector connection '{builder.Resource.Name}' is read-only and cannot create an access policy."); 441var resourceName = GetValidatedAccessPolicyResourceName(builder.Resource, name, policyName); 443builder.Resource.AccessPolicies.Add( 447builder.Resource, 448identity.Resource)); 471if (builder.Resource.McpServerConfigs.Any(config => 475$"MCP server configuration '{configName}' is already registered on Connector Namespace '{builder.Resource.Name}'."); 482builder.Resource); 484builder.Resource.McpServerConfigs.Add(config); 499if (builder.Resource.Connectors.Count > 0) 502$"MCP server configuration '{builder.Resource.Name}' has connector routes and cannot be marked as existing."); 505if (!string.IsNullOrWhiteSpace(builder.Resource.Description)) 508$"MCP server configuration '{builder.Resource.Name}' configures a description and cannot be marked as existing."); 511if (builder.Resource.AccessPolicies.Count > 0) 514$"MCP server configuration '{builder.Resource.Name}' configures access policies and cannot be marked as existing."); 517builder.Resource.IsExisting = true; 544if (builder.Resource.IsExisting) 547$"Existing MCP server configuration '{builder.Resource.Name}' is read-only and cannot create an access policy."); 550var resourceName = GetValidatedMcpAccessPolicyResourceName(builder.Resource, name, options.ObjectId); 551builder.Resource.AccessPolicies.Add(new AzureConnectorNamespaceMcpAccessPolicyResource( 553builder.Resource, 588if (builder.Resource.IsExisting) 591$"Existing MCP server configuration '{builder.Resource.Name}' is read-only."); 594if (!ReferenceEquals(builder.Resource.Parent, connection.Resource.Parent)) 597$"Connector connection '{connection.Resource.Name}' belongs to a different Connector Namespace."); 600if (builder.Resource.Connectors.Count > 0) 603$"MCP server configuration '{builder.Resource.Name}' already has a connector. " + 619connection.Resource); 641builder.Resource.Connectors.Add(connectorDefinition);

96builder.WithAnnotation(new ContainerRegistryReferenceAnnotation(registryBuilder.Resource)); 118var containerRegistry = builder.Resource.ContainerRegistry ?? throw new InvalidOperationException($"The resource '{builder.Resource.Name}' does not have an associated Azure Container Registry."); 119var registry = containerRegistry as AzureContainerRegistryResource ?? throw new InvalidOperationException($"The Container Registry associated with resource '{builder.Resource.Name}' is not an Azure Container Registry.");

15return builder.WithAnnotation(new RoleAssignmentAnnotation(target.Resource, CreateRoleDefinitions(roles, getName)));

105builder.Resource.IsVNextEmulator = useVNext; 126throw new DistributedApplicationException($"ConnectionStringAvailableEvent was published for the '{builder.Resource.Name}' resource but the connection string was null."); 164var emulatorSurrogate = new AzureCosmosDBEmulatorResource(builder.Resource); 185var password = ParameterResourceBuilderExtensions.CreateDefaultPasswordParameter(builder.ApplicationBuilder, $"{builder.Resource.Name}-certificate-passphrase"); 222var healthCheckKey = $"{builder.Resource.Name}_check"; 233var surrogate = new AzureCosmosDBEmulatorResource(builder.Resource); 277var isVNext = builder.Resource.InnerResource.IsVNextEmulator; 323if (builder.Resource.InnerResource.IsVNextEmulator) 372var database = new AzureCosmosDBDatabaseResource(name, databaseName, builder.Resource); 373builder.Resource.Databases.Add(database); 397var container = new AzureCosmosDBContainerResource(name, containerName, partitionKeyPath, builder.Resource); 398builder.Resource.Containers.Add(container); 454var container = new AzureCosmosDBContainerResource(name, containerName, partitionKeyPaths, builder.Resource); 456builder.Resource.Containers.Add(container); 471builder.Resource.UseDefaultAzureSku = true; 489if (!builder.Resource.InnerResource.IsVNextEmulator) 552var kv = builder.ApplicationBuilder.AddAzureKeyVault($"{builder.Resource.Name}-kv") 553.WithParentRelationship(builder.Resource); 561if (builder.Resource.IsEmulator) 563data.Model.Resources.Remove(kv.Resource); 598var azureResource = builder.Resource; 599azureResource.ConnectionStringSecretOutput = keyVaultBuilder.Resource.GetSecret($"connectionstrings--{azureResource.Name}"); 600azureResource.PrimaryAccessKeySecretOutput = keyVaultBuilder.Resource.GetSecret($"primaryaccesskey--{azureResource.Name}");

383TenantIdParameter = tenantId.Resource, 384ClientIdParameter = clientId.Resource 480resource.TenantIdParameter = (tenantId as IResourceBuilder<ParameterResource>)?.Resource; 482resource.ClientIdParameter = (clientId as IResourceBuilder<ParameterResource>)?.Resource; 541builder.Resource.TenantIdParameter = tenantId.Resource; 542builder.Resource.ClientIdParameter = clientId.Resource; 585builder.Resource.TenantId = tenantId; 586builder.Resource.ClientId = clientId; 609builder.Resource.EnsureCanBeExistingApplication(); 610SetExistingApplicationIds(builder.Resource, tenantId, clientId); 640builder.Resource.SetExistingApplication(); 685if (builder.Resource.IsExistingApplication) 691builder.Resource.ClientCredentials.OfType<EntraIdLocalDeveloperCertificateCredential>().Any()) 698builder.Resource.ClientCredentials.Add(new EntraIdLocalDeveloperCertificateCredential(builder.Resource, builder.ApplicationBuilder.ExecutionContext)); 725if (!clientSecret.Resource.Secret) 730builder.Resource.ClientCredentials.Add(new EntraIdClientSecretCredential 732ClientSecret = clientSecret.Resource 792builder.Resource.ClientCredentials.Add(new EntraIdFederatedIdentityCredential(managedIdentityClientId)); 878builder.Resource.ClientCredentials.Add(new EntraIdFederatedIdentityCredential()); 880foreach (var consumer in builder.Resource.Consumers) 934builder.Resource.ClientCredentials.Add(new EntraIdFederatedIdentityCredential 936ComputeTarget = computeResource.Resource 938EnsureManagedIdentityRequired(computeResource.Resource); 986builder.Resource.ClientCredentials.Add(new EntraIdFederatedIdentityCredential 988ManagedIdentity = identity.Resource 1023if (builder.Resource.IsExistingApplication) 1026$"Entra ID application '{builder.Resource.Name}' is an existing registration, and Aspire does not modify existing registrations, " + 1059builder.Resource.ClientCredentials.Add(new EntraIdKeyVaultCertificateCredential 1085builder.Resource.ClientCredentials.Add(new EntraIdStoreCertificateCredential 1111builder.Resource.ClientCredentials.Add(new EntraIdStoreCertificateCredential 1139Password = password?.Resource 1177builder.Resource.ClientCredentials.Add(credential); 1206builder.Resource.Instance = instance; 1259builder.Resource.SignInAudience = signInAudience; 1295builder.Resource.AddRedirectUri(redirectUri); 1342builder.Resource.AddRedirectUri(redirectUri.Resource); 1409builder.Resource.AddRedirectUri(new EntraIdEndpointRedirectUri(endpoint, path, builder.ApplicationBuilder.ExecutionContext.IsPublishMode)); 1467builder.Resource.AddRedirectUri(new EntraIdHostRedirectUri(host.Resource, path)); 1541AddOwners(builder.Resource.ApplicationOwners, ownerObjectIds, nameof(ownerObjectIds)); 1562builder.Resource.ApplicationOwners.AddRange(ownerObjectIds.Select(p => (object)p.Resource)); 1607AddOwners(builder.Resource.ServicePrincipalOwners, ownerObjectIds, nameof(ownerObjectIds)); 1625builder.Resource.ServicePrincipalOwners.AddRange(ownerObjectIds.Select(p => (object)p.Resource)); 1767if (builder.Resource.IsExistingApplication) 1772var roles = builder.Resource.AppRoles; 1778var id = role.GetStableId(builder.Resource.Name); 1779if (roles.Any(r => r.GetStableId(builder.Resource.Name) == id)) 1784builder.Resource.AddAppRole(role); 1864builder.Resource.EnableIdTokenIssuance = true; 1882builder.Resource.ClientCapabilities.Add(capability); 1897builder.Resource.AllowWebApiToBeAuthorizedByACL = true; 1916builder.Resource.SendX5C = true; 1937builder.Resource.ExtraQueryParameters[key] = value; 1955builder.Resource.Audiences.Add(audience); 1982builder.Resource.UsesDefaultApplicationIdUri = true; 1985if (!builder.Resource.IsExistingApplication) 1987builder.Resource.ApplicationIdUri = null; 2026builder.Resource.ApplicationIdUri = applicationIdUri; 2027builder.Resource.UsesDefaultApplicationIdUri = false; 2102var resource = builder.Resource; 2184return builder.Resource.GetScopeUri(scopeName); 2221var scopes = FindScopes(builder.Resource, scopeNames, nameof(scopeNames)); 2222EnsureNoDependencyCycle(builder.Resource, client.Resource); 2224var existing = builder.Resource.PreAuthorizedClients.FirstOrDefault(p => ReferenceEquals(p.Client, client.Resource)); 2227builder.Resource.PreAuthorizedClients.Remove(existing); 2231builder.Resource.PreAuthorizedClients.Add(new EntraIdPreAuthorizedClient(client.Resource, scopes)); 2277var apiResource = api.Resource; 2278if (ReferenceEquals(apiResource, builder.Resource)) 2284EnsureNoDependencyCycle(builder.Resource, apiResource); 2287var access = GetOrAddApiAccess(builder.Resource, a => a.IsFor(apiResource), () => EntraIdApiAccess.ForApplication(apiResource)); 2338var access = GetOrAddApiAccess(builder.Resource, a => a.IsFor(api), () => EntraIdApiAccess.ForApi(api)); 2408var apiResource = api.Resource; 2410var access = builder.Resource.ApiAccess.FirstOrDefault(a => a.IsFor(apiResource)); 2474var access = builder.Resource.ApiAccess.FirstOrDefault(a => a.IsFor(api)); 2724var isDotnetProgram = builder.Resource is IDotnetProgramResource; 2726connectionName ??= isDotnetProgram ? "AzureAd" : EnvironmentVariableNameEncoder.Encode(source.Resource.Name); 2767var entra = source.Resource; 2773entra.Consumers.Add(builder.Resource); 2777builder.Resource.Annotations.Add(new EntraIdReferenceAnnotation(entra, downstreamApisPrefix, environmentVariablePrefix, isDotnetProgram)); 2781EnsureManagedIdentityRequired(builder.Resource); 2830if (credential.EmitEnvironmentVariables(environmentVariables, credPrefix, separator, entra, builder.Resource, context.ExecutionContext)) 2865EntraIdApplicationResource.ValidateConsumerReferences(builder.Resource);

34Assert.Null(api.Resource.ApplicationIdUri); 35await Verify(api.Resource.GetBicepTemplateString(), "bicep"); 44await Verify(api.Resource.GetBicepTemplateString(), "bicep"); 62await Verify(api.Resource.GetBicepTemplateString(), "bicep"); 69var bicep = builder.AddEntraIdApplication("entra-api").Resource.GetBicepTemplateString(); 88Assert.Equal(api.Resource.GetBicepTemplateString(), api.Resource.GetBicepTemplateString()); 89Assert.Equal(web.Resource.GetBicepTemplateString(), web.Resource.GetBicepTemplateString()); 99return api.Resource.GetScopeId(Assert.Single(api.Resource.Scopes)); 120var id = first.Resource.GetScopeId(first.Resource.Scopes[0]); 122first.Resource.Scopes[0].Description = "A different description."; 124Assert.Equal(id, first.Resource.GetScopeId(first.Resource.Scopes[0])); 125Assert.NotEqual(id, second.Resource.GetScopeId(second.Resource.Scopes[0])); 135Assert.Equal(id, api.Resource.GetScopeId(Assert.Single(api.Resource.Scopes))); 136Assert.Contains("11112222-aaaa-3333-bbbb-4444cccc5555", api.Resource.GetBicepTemplateString()); 151Assert.Empty(api.Resource.Scopes); 173Assert.Single(api.Resource.Scopes); 186Assert.Equal(name, Assert.Single(api.Resource.Scopes).Name); 203Assert.Null(api.Resource.ApplicationIdUri); 215Assert.Equal(uri, api.Resource.ApplicationIdUri); 231Assert.Null(customThenDefault.Resource.ApplicationIdUri); 232var customThenDefaultBicep = customThenDefault.Resource.GetBicepTemplateString(); 236Assert.Equal("api://custom", defaultThenCustom.Resource.ApplicationIdUri); 237var defaultThenCustomBicep = defaultThenCustom.Resource.GetBicepTemplateString(); 250Assert.Equal("api://contoso-orders", existing.Resource.ApplicationIdUri); 281Assert.Empty(web.Resource.ApiAccess); 299var env = await EnvironmentVariableEvaluator.GetEnvironmentVariablesAsync(project.Resource, DistributedApplicationOperation.Run, TestServiceProvider.Instance); 320var env = await EnvironmentVariableEvaluator.GetEnvironmentVariablesAsync(project.Resource, DistributedApplicationOperation.Run, TestServiceProvider.Instance); 354var bicep = web.Resource.GetBicepTemplateString(); 382await Verify(web.Resource.GetBicepTemplateString(), "bicep"); 400await Verify(web.Resource.GetBicepTemplateString(), "bicep"); 411Assert.Equal("api://contoso-orders", existingApi.Resource.ApplicationIdUri); 412Assert.Throws<InvalidOperationException>(existingApi.Resource.GetBicepTemplateString); 426var exception = Assert.Throws<InvalidOperationException>(web.Resource.GetBicepTemplateString); 430existingApi.Resource.Scopes[0].Id = id; 431Assert.Contains($"id: '{id:D}'", web.Resource.GetBicepTemplateString()); 447Assert.Empty(web.Resource.ApiAccess); 460Assert.Contains("access_as_user", web.Resource.GetBicepTemplateString()); 462api.Resource.Scopes[0].IsEnabled = false; 464var template = Assert.Throws<InvalidOperationException>(web.Resource.GetBicepTemplateString); 467var validation = Assert.Throws<InvalidOperationException>(web.Resource.ValidateApiAccess); 480Assert.Contains("preAuthorizedApplications", api.Resource.GetBicepTemplateString()); 482api.Resource.Scopes[0].IsEnabled = false; 484var template = Assert.Throws<InvalidOperationException>(api.Resource.GetBicepTemplateString); 487Assert.Throws<InvalidOperationException>(api.Resource.ValidateApiAccess); 500web.Resource.ValidateApiAccess(); 502existingApi.Resource.Scopes[0].IsEnabled = false; 504var validation = Assert.Throws<InvalidOperationException>(web.Resource.ValidateApiAccess); 516var access = Assert.Single(web.Resource.ApiAccess); 531var declared = Assert.Single(web.Resource.ApiAccess).Declared; 558Assert.Empty(web.Resource.ApiAccess); 575await Verify(web.Resource.GetBicepTemplateString(), "bicep"); 613Assert.Empty(Assert.Single(web.Resource.ApiAccess).Consented); 629Assert.Equal(2, api.Resource.PreAuthorizedClients.Count); 630await Verify(api.Resource.GetBicepTemplateString(), "bicep"); 645Assert.Empty(api.Resource.PreAuthorizedClients); 657Assert.Empty(api.Resource.PreAuthorizedClients); 663Assert.Empty(otherWeb.Resource.ApiAccess); 691await Verify(api.Resource.GetBicepTemplateString(), "bicep"); 705Assert.Equal("{created-api.outputs.applicationIdUri}/access_as_user", created.Resource.GetScopeUri("access_as_user").ValueExpression); 706Assert.Equal("api://contoso-orders/orders.read", custom.Resource.GetScopeUri("orders.read").ValueExpression); 707Assert.Equal("api://existing/items.read", existing.Resource.GetScopeUri("items.read").ValueExpression); 708Assert.Throws<ArgumentException>(() => created.Resource.GetScopeUri("unknown")); 709Assert.Throws<InvalidOperationException>(() => existingWithoutUri.Resource.GetScopeUri("items.read")); 751entra.Resource.Outputs["tenantId"] = TenantId; 752entra.Resource.Outputs["clientId"] = ClientId; 753entra.Resource.Outputs["applicationIdUri"] = $"api://{prefix}-{ClientId}"; 754entra.Resource.ProvisioningTaskCompletionSource!.SetResult(); 760var env = await EnvironmentVariableEvaluator.GetEnvironmentVariablesAsync(project.Resource, operation, TestServiceProvider.Instance); 784var env = await EnvironmentVariableEvaluator.GetEnvironmentVariablesAsync(project.Resource, DistributedApplicationOperation.Run, TestServiceProvider.Instance); 785var containerEnv = await EnvironmentVariableEvaluator.GetEnvironmentVariablesAsync(container.Resource, DistributedApplicationOperation.Run, TestServiceProvider.Instance); 822web.Resource.Outputs["tenantId"] = TenantId; 823web.Resource.Outputs["clientId"] = ClientId; 824web.Resource.ProvisioningTaskCompletionSource!.SetResult(); 829var env = await EnvironmentVariableEvaluator.GetEnvironmentVariablesAsync(project.Resource, DistributedApplicationOperation.Run, TestServiceProvider.Instance); 847web.Resource.ValidateApiAccess(); 851var validation = Assert.Throws<InvalidOperationException>(web.Resource.ValidateApiAccess); 855await EnvironmentVariableEvaluator.GetEnvironmentVariablesAsync(project.Resource, DistributedApplicationOperation.Run, TestServiceProvider.Instance)); 860web.Resource.ValidateApiAccess(); 873Assert.Empty(existing.Resource.Annotations.OfType<PipelineStepAnnotation>()); 874Assert.Empty(existingWithoutDeclarations.Resource.Annotations.OfType<PipelineStepAnnotation>()); 880foreach (var resource in new[] { created.Resource, existing.Resource }) 908web.Resource.ValidateApiAccess(); 912var exception = Assert.Throws<InvalidOperationException>(web.Resource.ValidateApiAccess); 935web.Resource.ValidateApiAccess(); 936var env = await EnvironmentVariableEvaluator.GetEnvironmentVariablesAsync(project.Resource, DistributedApplicationOperation.Run, TestServiceProvider.Instance); 960var env = await EnvironmentVariableEvaluator.GetEnvironmentVariablesAsync(project.Resource, DistributedApplicationOperation.Run, TestServiceProvider.Instance); 977var env = await EnvironmentVariableEvaluator.GetEnvironmentVariablesAsync(project.Resource, DistributedApplicationOperation.Run, TestServiceProvider.Instance); 978var containerEnv = await EnvironmentVariableEvaluator.GetEnvironmentVariablesAsync(container.Resource, DistributedApplicationOperation.Run, TestServiceProvider.Instance); 992var env = await EnvironmentVariableEvaluator.GetEnvironmentVariablesAsync(project.Resource, DistributedApplicationOperation.Run, TestServiceProvider.Instance); 1010await EnvironmentVariableEvaluator.GetEnvironmentVariablesAsync(project.Resource, DistributedApplicationOperation.Run, TestServiceProvider.Instance)); 1026var env = await EnvironmentVariableEvaluator.GetEnvironmentVariablesAsync(project.Resource, DistributedApplicationOperation.Run, TestServiceProvider.Instance); 1049var env = await EnvironmentVariableEvaluator.GetEnvironmentVariablesAsync(webFrontend.Resource, DistributedApplicationOperation.Run, TestServiceProvider.Instance); 1067var env = await EnvironmentVariableEvaluator.GetEnvironmentVariablesAsync(webFrontend.Resource, DistributedApplicationOperation.Run, TestServiceProvider.Instance); 1087var env = await EnvironmentVariableEvaluator.GetEnvironmentVariablesAsync(webFrontend.Resource, DistributedApplicationOperation.Run, TestServiceProvider.Instance); 1107var env = await EnvironmentVariableEvaluator.GetEnvironmentVariablesAsync(worker.Resource, DistributedApplicationOperation.Run, TestServiceProvider.Instance); 1108var defaultEnv = await EnvironmentVariableEvaluator.GetEnvironmentVariablesAsync(defaultWorker.Resource, DistributedApplicationOperation.Run, TestServiceProvider.Instance); 1195var bicep = web.Resource.GetBicepTemplateString(); 1198Assert.Equal("orders-api", ((BicepOutputReference)web.Resource.Parameters["orders_apiClientId"]!).Resource.Name); 1199Assert.Equal("ordersApi", ((BicepOutputReference)web.Resource.Parameters["ordersApiClientId"]!).Resource.Name); 1200Assert.Equal("orders-api", ((BicepOutputReference)web.Resource.Parameters["orders_apiServicePrincipalId"]!).Resource.Name); 1201Assert.Equal("ordersApi", ((BicepOutputReference)web.Resource.Parameters["ordersApiServicePrincipalId"]!).Resource.Name); 1203Assert.Equal(bicep, web.Resource.GetBicepTemplateString()); 1220var bicep = web.Resource.GetBicepTemplateString(); 1243var bicep = web.Resource.GetBicepTemplateString(); 1264var bicep = web.Resource.GetBicepTemplateString(); 1282var bicep = web.Resource.GetBicepTemplateString(); 1285Assert.IsType<ParameterResource>(web.Resource.Parameters["orders_apiClientId"]); 1286Assert.Equal("orders-api", ((BicepOutputReference)web.Resource.Parameters["orders_apiClientId_2"]!).Resource.Name); 1299var bicep = api.Resource.GetBicepTemplateString(); 1318var bicep = registration.Resource.GetBicepTemplateString(); 1322Assert.Single(registration.Resource.Parameters, p => p.Key.StartsWith("shared", StringComparison.Ordinal)); 1363await EnvironmentVariableEvaluator.GetEnvironmentVariablesAsync(frontend.Resource, DistributedApplicationOperation.Run, TestServiceProvider.Instance)); 1369Assert.Equal(exception.Message, Assert.Throws<InvalidOperationException>(first.Resource.ValidateApiAccess).Message); 1385await EnvironmentVariableEvaluator.GetEnvironmentVariablesAsync(worker.Resource, DistributedApplicationOperation.Run, TestServiceProvider.Instance)); 1415var env = await EnvironmentVariableEvaluator.GetEnvironmentVariablesAsync(frontend.Resource, DistributedApplicationOperation.Run, TestServiceProvider.Instance); 1430await EnvironmentVariableEvaluator.GetEnvironmentVariablesAsync(worker.Resource, DistributedApplicationOperation.Run, TestServiceProvider.Instance)); 1445first.Resource.ValidateApiAccess(); 1446var env = await EnvironmentVariableEvaluator.GetEnvironmentVariablesAsync(frontend.Resource, DistributedApplicationOperation.Run, TestServiceProvider.Instance); 1463var env = await EnvironmentVariableEvaluator.GetEnvironmentVariablesAsync(worker.Resource, DistributedApplicationOperation.Run, TestServiceProvider.Instance); 1479await EnvironmentVariableEvaluator.GetEnvironmentVariablesAsync(worker.Resource, DistributedApplicationOperation.Run, TestServiceProvider.Instance)); 1490first.Resource.ValidateApiAccess(); 1491var env = await EnvironmentVariableEvaluator.GetEnvironmentVariablesAsync(frontend.Resource, DistributedApplicationOperation.Run, TestServiceProvider.Instance); 1519var derivedId = api.Resource.GetScopeId(api.Resource.Scopes[0]).ToString("D"); 1523api.Resource.Scopes[0].Id = adoptedId; 1525var apiBicep = api.Resource.GetBicepTemplateString(); 1526var webBicep = web.Resource.GetBicepTemplateString(); 1546existingApi.Resource.Scopes[0].Id = secondId; 1548var webBicep = web.Resource.GetBicepTemplateString(); 1562existingApi.Resource.Scopes[0].Id = null; 1564var exception = Assert.Throws<InvalidOperationException>(web.Resource.GetBicepTemplateString); 1579var access = Assert.Single(web.Resource.ApiAccess);

25var snapshot = await InitializeAsync(app, entra.Resource); 57var snapshot = await InitializeAsync(app, entra.Resource); 78var snapshot = await InitializeAsync(app, entra.Resource); 110var snapshot = await InitializeAsync(app, entra.Resource); 131var snapshot = await InitializeAsync(app, entra.Resource); 150var snapshot = await InitializeAsync(app, entra.Resource); 158}, await ReadLogsAsync(app, entra.Resource)); 170var snapshot = await InitializeAsync(app, entra.Resource); 176}, await ReadLogsAsync(app, entra.Resource)); 188var snapshot = await InitializeAsync(app, entra.Resource); 191var log = Assert.Single(await ReadLogsAsync(app, entra.Resource)); 203entra.Resource.Outputs["tenantId"] = TenantId; 204entra.Resource.Outputs["clientId"] = ClientId; 207entra.Resource.ProvisioningTaskCompletionSource!.SetResult(); 208var snapshot = await InitializeAsync(app, entra.Resource); 226entra.Resource.ProvisioningTaskCompletionSource!.SetException(new InvalidOperationException("Registration creation was denied.")); 227var snapshot = await InitializeAsync(app, entra.Resource); 231var log = Assert.Single(await ReadLogsAsync(app, entra.Resource)); 248await notifications.PublishUpdateAsync(entra.Resource, snapshot => snapshot with { State = new("Missing subscription configuration", KnownResourceStateStyles.Error) }); 249entra.Resource.ProvisioningTaskCompletionSource!.SetException(new MissingConfigurationException("Azure subscription is missing.")); 250var initialization = PublishInitializationAsync(app, entra.Resource, cts.Token); 256Assert.True(notifications.TryGetCurrentState(entra.Resource.Name, out var resourceEvent)); 274await notifications.PublishUpdateAsync(entra.Resource, snapshot => snapshot); 275entra.Resource.ProvisioningTaskCompletionSource!.SetException(new InvalidOperationException("Azure context is missing.")); 276var initialization = PublishInitializationAsync(app, entra.Resource, cts.Token); 280await notifications.WaitForResourceAsync(entra.Resource.Name, 282entra.Resource.ProvisioningTaskCompletionSource = new(TaskCreationOptions.RunContinuationsAsynchronously); 283await notifications.PublishUpdateAsync(entra.Resource, snapshot => snapshot with { State = KnownResourceStates.Waiting }); 284entra.Resource.Outputs["tenantId"] = TenantId; 285entra.Resource.Outputs["clientId"] = ClientId; 287await notifications.PublishUpdateAsync(entra.Resource, snapshot => snapshot with { State = KnownResourceStates.Running }); 288entra.Resource.ProvisioningTaskCompletionSource.SetResult(); 290var ready = await notifications.WaitForResourceAsync(entra.Resource.Name, 310entra.Resource.Outputs["tenantId"] = TenantId; 311entra.Resource.Outputs["clientId"] = ClientId; 312entra.Resource.ProvisioningTaskCompletionSource!.SetResult(); 316await notifications.PublishUpdateAsync(entra.Resource, snapshot => snapshot with 321var initialization = PublishInitializationAsync(app, entra.Resource, cts.Token); 325await notifications.WaitForResourceAsync(entra.Resource.Name, 331entra.Resource.ProvisioningTaskCompletionSource = new(TaskCreationOptions.RunContinuationsAsynchronously); 332await notifications.PublishUpdateAsync(entra.Resource, snapshot => snapshot with { State = KnownResourceStates.Waiting }); 333entra.Resource.Outputs["tenantId"] = updatedTenant; 334entra.Resource.Outputs["clientId"] = updatedClient; 335entra.Resource.ProvisioningTaskCompletionSource.SetResult(); 336var ready = await notifications.WaitForResourceAsync(entra.Resource.Name, 369await notifications.PublishUpdateAsync(entra.Resource, snapshot => snapshot); 372entra.Resource.Outputs["tenantId"] = TenantId; 373entra.Resource.Outputs["clientId"] = ClientId; 374entra.Resource.ProvisioningTaskCompletionSource!.SetResult(); 377var initialization = PublishInitializationAsync(app, entra.Resource, cts.Token); 382await notifications.WaitForResourceAsync(entra.Resource.Name, 390Assert.Equal(provisioningCompleted, entra.Resource.ProvisioningTaskCompletionSource!.Task.IsCompletedSuccessfully); 391Assert.False(entra.Resource.ProvisioningTaskCompletionSource.Task.IsCanceled); 408entra.Resource.TenantId = "my-tenant"; 409entra.Resource.ClientId = "my-client"; 410entra.Resource.Instance = "http://login.microsoftonline.com/"; 411entra.Resource.SignInAudience = (EntraIdSignInAudience)42; 414var snapshot = await InitializeAsync(app, entra.Resource); 424}, await ReadLogsAsync(app, entra.Resource)); 437await notifications.PublishUpdateAsync(entra.Resource, snapshot => snapshot with 443var snapshot = await InitializeAsync(app, entra.Resource); 465var snapshot = await InitializeAsync(app, entra.Resource); 468Assert.Same(entra.Resource, startedResource); 479var snapshot = await InitializeAsync(app, entra.Resource); 483var log = Assert.Single(await ReadLogsAsync(app, entra.Resource));

36Assert.True(entra.Resource.IsExistingApplication); 38Assert.Null(entra.Resource.ProvisioningTaskCompletionSource); 39Assert.Null(await ManifestUtils.GetManifestOrNull(entra.Resource)); 46consumer.Resource, DistributedApplicationOperation.Run, TestServiceProvider.Instance)); 63consumer = project.Resource; 69consumer = container.Resource; 72Assert.Same(consumer, Assert.Single(entra.Resource.Consumers)); 91Assert.Null(entra.Resource.TenantIdParameter); 92Assert.Null(entra.Resource.ClientIdParameter); 93Assert.Equal(TenantId, entra.Resource.TenantId); 94Assert.Equal(ClientId, entra.Resource.ClientId); 95Assert.Empty(entra.Resource.Annotations.OfType<PipelineStepAnnotation>()); 96Assert.Null(await ManifestUtils.GetManifestOrNull(entra.Resource)); 117Assert.Equal(TenantId, entra.Resource.TenantId); 118Assert.Equal(ClientId, entra.Resource.ClientId); 151consumer.Resource, operation, TestServiceProvider.Instance); 153Assert.Same(secret.Resource, Assert.IsType<EntraIdClientSecretCredential>(entra.Resource.ClientCredentials[0]).ClientSecret); 154Assert.Same(password.Resource, Assert.IsType<EntraIdFileCertificateCredential>(entra.Resource.ClientCredentials[5]).Password); 169Assert.Empty(entra.Resource.ClientCredentials); 189Assert.IsType<EntraIdLocalDeveloperCertificateCredential>(Assert.Single(entra.Resource.ClientCredentials)); 193Assert.Empty(entra.Resource.ClientCredentials); 207Assert.Empty(existing.Resource.ClientCredentials); 226Assert.Empty(entra.Resource.ClientCredentials); 230Assert.Collection(entra.Resource.ClientCredentials, 232c => Assert.Same(consumer.Resource, Assert.IsType<EntraIdFederatedIdentityCredential>(c).ComputeTarget), 233c => Assert.Same(identity.Resource, Assert.IsType<EntraIdFederatedIdentityCredential>(c).ManagedIdentity)); 259Assert.Equal([ClientId, owner.Resource, TenantId], entra.Resource.ApplicationOwners); 260Assert.Equal(entra.Resource.ApplicationOwners, entra.Resource.ServicePrincipalOwners); 261await Verify(entra.Resource.GetBicepTemplateString(), "bicep"); 262var expression = Assert.IsType<ReferenceExpression>(entra.Resource.Parameters["redirectUri0"]); 264Assert.Same(host.Resource, Assert.Single(expression.ValueProviders)); 281await Verify(entra.Resource.GetBicepTemplateString(), "bicep").UseParameters(operation); 282Assert.IsType<ReferenceExpression>(entra.Resource.Parameters["redirectUri0"]); 303Assert.Equal(nativeEntra.Resource.GetBicepTemplateString(), exportedEntra.Resource.GetBicepTemplateString()); 308Assert.Equal(4, exportedEntra.Resource.AppRoles.Count); 386Assert.Equal(nativeApi.Resource.GetBicepTemplateString(), exportedApi.Resource.GetBicepTemplateString()); 387Assert.Equal(nativeWeb.Resource.GetBicepTemplateString(), exportedWeb.Resource.GetBicepTemplateString()); 420consumer.Resource, DistributedApplicationOperation.Run, TestServiceProvider.Instance); 453Assert.Single(api.Resource.Scopes); 461Assert.Empty(web.Resource.ApiAccess); 466Assert.Empty(web.Resource.ApiAccess); 488Assert.Empty(entra.Resource.RedirectUris); 489Assert.Empty(entra.Resource.RedirectUriParameters); 490Assert.Empty(entra.Resource.ApplicationOwners); 491Assert.Empty(entra.Resource.ServicePrincipalOwners); 504Assert.Empty(entra.Resource.Consumers);

39await Verify(entra.Resource.GetBicepTemplateString(), "bicep"); 53return entra.Resource.GetBicepTemplateString(); 72Assert.Single(entra.Resource.AppRoles); 108var roles = Assert.IsAssignableFrom<IList<EntraIdAppRole>>(entra.Resource.AppRoles); 111Assert.Single(entra.Resource.AppRoles); 141Assert.Empty(entra.Resource.ApplicationOwners); 153Assert.Equal(2, entra.Resource.ApplicationOwners.Count); 154Assert.Equal(entra.Resource.ApplicationOwners, entra.Resource.ServicePrincipalOwners); 155await Verify(entra.Resource.GetBicepTemplateString(), "bicep"); 168Assert.Equal(["00001111-aaaa-2222-bbbb-3333cccc4444"], entra.Resource.ApplicationOwners); 177Assert.DoesNotContain("owners", entra.Resource.GetBicepTemplateString()); 188await Verify(entra.Resource.GetBicepTemplateString(), "bicep"); 202await Verify(entra.Resource.GetBicepTemplateString(), "bicep"); 224web.Resource, DistributedApplicationOperation.Publish, TestServiceProvider.Instance); 246var exception = Assert.Throws<InvalidOperationException>(entra.Resource.ValidateManagedIdentities); 260Assert.Contains("WithAzureUserAssignedIdentity", Assert.Throws<InvalidOperationException>(entra.Resource.ValidateManagedIdentities).Message); 263web.Resource, DistributedApplicationOperation.Publish, TestServiceProvider.Instance); 284var dependencies = await web.Resource.GetResourceDependenciesAsync(builder.ExecutionContext, ResourceDependencyDiscoveryMode.DirectOnly); 285Assert.Contains(entra.Resource, dependencies); 288web.WithAnnotation(new AppIdentityAnnotation(identity.Resource)); 290web.Resource, DistributedApplicationOperation.Publish, TestServiceProvider.Instance); 304Assert.DoesNotContain("web_identity_principalId", entra.Resource.GetBicepTemplateString()); 310Assert.Same(identity, Assert.Single(entra.Resource.GetFederatedIdentities())); 311Assert.Contains("web_identity_principalId", entra.Resource.GetBicepTemplateString()); 337Assert.Empty(entra.Resource.ClientCredentials); 338var bicep = entra.Resource.GetBicepTemplateString(); 353var bicep = entra.Resource.GetBicepTemplateString(); 356Assert.Empty(entra.Resource.GetFederatedIdentities()); 368var credential = Assert.Single(entra.Resource.ClientCredentials); 370Assert.True(credential.EmitEnvironmentVariables(envVars, "AzureAd__ClientCredentials__0", "__", entra.Resource, web.Resource, builder.ExecutionContext)); 390var bicep = entra.Resource.GetBicepTemplateString(); 416Assert.Contains("issuer: 'https://login.microsoftonline.com/${tenant().tenantId}/v2.0'", entra.Resource.GetBicepTemplateString()); 429var bicep = entra.Resource.GetBicepTemplateString(); 432Assert.Same(redirectUris.Resource, entra.Resource.Parameters["web_identity_principalId"]); 433Assert.Same(webIdentity.Resource, Assert.IsType<BicepOutputReference>(entra.Resource.Parameters["web_identity_principalId_2"]).Resource); 437Assert.Equal(bicep, entra.Resource.GetBicepTemplateString()); 451var bicep = entra.Resource.GetBicepTemplateString(); 453Assert.Same(redirectUris.Resource, entra.Resource.Parameters["WEB_identity_principalId"]); 454Assert.Same(webIdentity.Resource, Assert.IsType<BicepOutputReference>(entra.Resource.Parameters["web_identity_principalId_2"]).Resource); 469var bicep = entra.Resource.GetBicepTemplateString(); 486entra.Resource.ValidateManagedIdentities(); 487Assert.Same(identity.Resource, Assert.Single(entra.Resource.GetFederatedIdentities())); 488Assert.NotNull(published.Resource); 508entra.Resource.Instance = "https://login.contoso.example/"; 510var exception = Assert.Throws<InvalidOperationException>(entra.Resource.GetBicepTemplateString); 520Assert.IsAssignableFrom<AzureProvisioningResource>(entra.Resource); 521var tenantScoped = Assert.Single(entra.Resource.Annotations.OfType<TenantScopedResourceAnnotation>()); 527Assert.NotNull(entra.Resource.ProvisioningTaskCompletionSource); 528Assert.False(entra.Resource.ProvisioningTaskCompletionSource.Task.IsCompleted); 529Assert.Equal(new[] { "tenantResourceSuffix" }, entra.Resource.Parameters.Keys); 530Assert.Equal(EntraIdSignInAudience.AzureADMyOrg, entra.Resource.SignInAudience); 531Assert.Null(entra.Resource.Parameters[AzureBicepResource.KnownParameters.TenantResourceSuffix]); 534await Verify(entra.Resource.GetBicepTemplateString(), "bicep"); 535Assert.Equal(new[] { "tenantResourceSuffix" }, entra.Resource.Parameters.Keys); 557await Verify(entra.Resource.GetBicepTemplateString(), "bicep"); 568using var first = entra.Resource.GetBicepTemplateFile(workspace.Path); 570using var second = entra.Resource.GetBicepTemplateFile(workspace.Path); 574Assert.Equal(firstContents, entra.Resource.GetBicepTemplateString()); 584entra.Resource.Scope = tenantScoped 588var exception = Assert.Throws<InvalidOperationException>(entra.Resource.GetBicepTemplateString); 602var manifest = await ManifestUtils.GetManifest(entra.Resource, workspace.Path); 603Assert.Equal(new[] { "tenantResourceSuffix" }, entra.Resource.Parameters.Keys); 605.AppendContentAsFile(entra.Resource.GetBicepTemplateString(), "bicep"); 681Assert.Same(context.ParameterLookup[suffix.Resource], 769.WithParameter("tenantId", web.Resource.TenantIdOutputReference) 770.WithParameter("clientId", web.Resource.ClientIdOutputReference); 804Assert.Equal(audience, entra.Resource.SignInAudience); 805Assert.Equal(new[] { "tenantResourceSuffix" }, entra.Resource.Parameters.Keys); 806await Verify(entra.Resource.GetBicepTemplateString(), "bicep"); 819Assert.True(entra.Resource.EnableIdTokenIssuance); 820Assert.Equal(new[] { "tenantResourceSuffix" }, entra.Resource.Parameters.Keys); 821await Verify(entra.Resource.GetBicepTemplateString(), "bicep"); 835Assert.Equal(new[] { "https://localhost:7123/signin-oidc", "https://localhost:7123/signout-callback-oidc" }, entra.Resource.RedirectUris); 850Assert.Equal(new[] { signIn.Resource, signOut.Resource }, entra.Resource.RedirectUriParameters); 862await Verify(entra.Resource.GetBicepTemplateString(), "bicep"); 863Assert.Equal(new[] { "tenantResourceSuffix", "web_redirect_uris", "extra_redirect_uris" }, entra.Resource.Parameters.Keys); 873await Verify(entra.Resource.GetBicepTemplateString(), "bicep"); 884await Verify(entra.Resource.GetBicepTemplateString(), "bicep"); 885Assert.Equal(new[] { "tenantResourceSuffix", "redirectUri0", "redirectUri1" }, entra.Resource.Parameters.Keys); 887entra.Resource.Parameters.Where(p => p.Key.StartsWith("redirectUri", StringComparison.Ordinal)), 902await Verify(entra.Resource.GetBicepTemplateString(), "bicep"); 915_ = entra.Resource.GetBicepTemplateString(); 916var expression = Assert.IsType<ReferenceExpression>(entra.Resource.Parameters["redirectUri0"]); 928var context = new ResourceUrlsCallbackContext(builder.ExecutionContext, web.Resource, urls); 929foreach (var callback in web.Resource.Annotations.OfType<ResourceUrlsCallbackAnnotation>()) 948await Verify(entra.Resource.GetBicepTemplateString(), "bicep"); 949var expression = Assert.IsType<ReferenceExpression>(entra.Resource.Parameters["redirectUri0"]); 951Assert.Same(host.Resource, Assert.Single(expression.ValueProviders)); 972Assert.Single(entra.Resource.RedirectUriParameters); 985_ = entra.Resource.GetBicepTemplateString(); 986var expression = Assert.IsType<ReferenceExpression>(entra.Resource.Parameters["redirectUri0"]); 990var context = new ResourceUrlsCallbackContext(builder.ExecutionContext, web.Resource, urls); 991foreach (var callback in web.Resource.Annotations.OfType<ResourceUrlsCallbackAnnotation>()) 1012_ = entra.Resource.GetBicepTemplateString(); 1013var expression = Assert.IsType<ReferenceExpression>(entra.Resource.Parameters["redirectUri0"]); 1021var context = new ResourceUrlsCallbackContext(builder.ExecutionContext, web.Resource, urls); 1022foreach (var callback in web.Resource.Annotations.OfType<ResourceUrlsCallbackAnnotation>()) 1040_ = entra.Resource.GetBicepTemplateString(); 1041var expression = Assert.IsType<ReferenceExpression>(entra.Resource.Parameters["redirectUri0"]); 1044var context = new ResourceUrlsCallbackContext(builder.ExecutionContext, web.Resource, []); 1045foreach (var callback in web.Resource.Annotations.OfType<ResourceUrlsCallbackAnnotation>()) 1072var bicep = entra.Resource.GetBicepTemplateString(); 1073Assert.Same(existing.Resource, entra.Resource.Parameters["redirectUri0"]); 1074Assert.IsType<ReferenceExpression>(entra.Resource.Parameters["redirectUri1"]); 1079Assert.Equal(bicep, entra.Resource.GetBicepTemplateString()); 1107entra.Resource.SignInAudience = EntraIdSignInAudience.AzureADMultipleOrgs; 1108entra.Resource.AddRedirectUri("https://localhost:7123/signin-oidc"); 1109entra.Resource.EnableIdTokenIssuance = true; 1111await Verify(entra.Resource.GetBicepTemplateString(), "bicep"); 1131Assert.True(entra.Resource.IsExistingApplication); 1132Assert.Equal(TenantId, entra.Resource.TenantId); 1133Assert.Equal(ClientId, entra.Resource.ClientId); 1134Assert.Null(entra.Resource.ProvisioningTaskCompletionSource); 1135Assert.Empty(entra.Resource.Annotations.OfType<PipelineStepAnnotation>()); 1136Assert.Empty(entra.Resource.Annotations.OfType<PipelineConfigurationAnnotation>()); 1137Assert.Null(await ManifestUtils.GetManifestOrNull(entra.Resource)); 1146Assert.True(entra.Resource.IsExistingApplication); 1147Assert.Null(entra.Resource.ProvisioningTaskCompletionSource); 1148Assert.Empty(entra.Resource.Annotations.OfType<PipelineStepAnnotation>()); 1149Assert.Empty(entra.Resource.Annotations.OfType<PipelineConfigurationAnnotation>()); 1150Assert.Null(await ManifestUtils.GetManifestOrNull(entra.Resource)); 1167Assert.True(existing.Resource.IsExistingApplication); 1168Assert.Null(existing.Resource.ProvisioningTaskCompletionSource); 1170Assert.Empty(existing.Resource.Annotations.OfType<PipelineStepAnnotation>()); 1171Assert.Same(customization, Assert.Single(existing.Resource.Annotations.OfType<PipelineConfigurationAnnotation>())); 1172Assert.Null(await ManifestUtils.GetManifestOrNull(existing.Resource)); 1194Assert.True(entra.Resource.IsExistingApplication); 1241Assert.Empty(existing.Resource.Annotations.OfType<PipelineStepAnnotation>()); 1280Assert.Same(customization, Assert.Single(entra.Resource.Annotations.OfType<PipelineConfigurationAnnotation>())); 1292var exception = Assert.Throws<InvalidOperationException>(entra.Resource.GetBicepTemplateString); 1304entra.Resource.SignInAudience = (EntraIdSignInAudience)42; 1306var exception = Assert.Throws<InvalidOperationException>(entra.Resource.GetBicepTemplateString); 1324var exception = Assert.Throws<InvalidOperationException>(entra.Resource.GetBicepTemplateString); 1348entra.Resource.Outputs["tenantId"] = TenantId; 1349entra.Resource.Outputs["clientId"] = ClientId; 1350entra.Resource.ProvisioningTaskCompletionSource!.SetResult(); 1376project.Resource, operation, TestServiceProvider.Instance)); 1378container.Resource, operation, TestServiceProvider.Instance)); 1392node.Resource, DistributedApplicationOperation.Run, app.Services).AsTask(); 1395entra.Resource.Outputs["tenantId"] = TenantId; 1396entra.Resource.Outputs["clientId"] = ClientId; 1397entra.Resource.ProvisioningTaskCompletionSource!.SetResult(); 1433var initialWaits = consumer.Resource.Annotations.OfType<WaitAnnotation>().ToArray(); 1437Assert.Equal(initialWaits, consumer.Resource.Annotations.OfType<WaitAnnotation>()); 1449var wait = Assert.Single(node.Resource.Annotations.OfType<WaitAnnotation>()); 1450Assert.Same(entra.Resource, wait.Resource); 1466node.Resource, DistributedApplicationOperation.Run, app.Services).AsTask(); 1468entra.Resource.ProvisioningTaskCompletionSource!.SetException(failure); 1482var value = entra.Resource.ClientIdOutputReference.GetValueAsync(cts.Token).AsTask(); 1485entra.Resource.Outputs["clientId"] = ClientId; 1486entra.Resource.ProvisioningTaskCompletionSource!.SetResult(); 1497var value = entra.Resource.ClientIdOutputReference.GetValueAsync(cts.Token).AsTask(); 1501Assert.False(entra.Resource.ProvisioningTaskCompletionSource!.Task.IsCompleted); 1502entra.Resource.Outputs["clientId"] = ClientId; 1503entra.Resource.ProvisioningTaskCompletionSource.SetResult(); 1505Assert.Equal(ClientId, await entra.Resource.ClientIdOutputReference.GetValueAsync());

79Assert.Equal("contoso.onmicrosoft.com", entra.Resource.TenantId); 260Assert.Equal(EntraIdSignInAudience.AzureADMyOrg, entra.Resource.SignInAudience); 281Assert.True(entra.Resource.TryGetAnnotationsOfType<ManifestPublishingCallbackAnnotation>(out var annotations)); 292var annotation = Assert.Single(entra.Resource.Annotations.OfType<ResourceSnapshotAnnotation>()); 398Assert.Empty(entra.Resource.ClientCredentials); 409Assert.Empty(entra.Resource.ClientCredentials); 434web.Resource, operation, TestServiceProvider.Instance); 506container.Resource, DistributedApplicationOperation.Run, TestServiceProvider.Instance); 533container.Resource, DistributedApplicationOperation.Run, TestServiceProvider.Instance); 558container.Resource, DistributedApplicationOperation.Run, TestServiceProvider.Instance); 560Assert.Equal(signInAudience, entra.Resource.SignInAudience); 585container.Resource, DistributedApplicationOperation.Run, TestServiceProvider.Instance); 608container.Resource, DistributedApplicationOperation.Run, TestServiceProvider.Instance); 624Password = password.Resource 631container.Resource, DistributedApplicationOperation.Run, TestServiceProvider.Instance); 657container.Resource, operation, TestServiceProvider.Instance); 683project.Resource, operation, TestServiceProvider.Instance); 694explicitNull.Resource, operation, TestServiceProvider.Instance)); 717project.Resource, operation, TestServiceProvider.Instance); 755named.Resource, operation, TestServiceProvider.Instance)); 757positional.Resource, operation, TestServiceProvider.Instance)); 774project.Resource, operation, TestServiceProvider.Instance); 802container.Resource, operation, TestServiceProvider.Instance); 813explicitNull.Resource, operation, TestServiceProvider.Instance)); 828project.Resource, operation, TestServiceProvider.Instance); 854defaultConsumer.Resource, operation, TestServiceProvider.Instance); 856customConsumer.Resource, operation, TestServiceProvider.Instance); 900Password = password.Resource 922container.Resource, operation, TestServiceProvider.Instance); 1003unprefixed.Resource, operation, TestServiceProvider.Instance)); 1018container.Resource, operation, TestServiceProvider.Instance); 1040container.Resource, DistributedApplicationOperation.Run, TestServiceProvider.Instance); 1126var relationships = project.Resource.Annotations 1130Assert.Contains(relationships, r => r.Resource == entra.Resource); 1196ClientSecret = notSecret.Resource 1200Assert.Empty(entra.Resource.ClientCredentials); 1213Password = notSecret.Resource 1217Assert.Empty(entra.Resource.ClientCredentials); 1235Password = password.Resource 1238.WithCredential(new EntraIdClientSecretCredential { ClientSecret = secret.Resource }) 1241Assert.Same(password.Resource, certificate.Password); 1244certificate.Password = replacement.Resource; 1251consumer.Resource, operation, TestServiceProvider.Instance); 1297container.Resource, operation, TestServiceProvider.Instance); 1320container.Resource, operation, TestServiceProvider.Instance); 1347container.Resource, operation, TestServiceProvider.Instance);

23entra.Resource.Parameters[AzureBicepResource.KnownParameters.TenantResourceSuffix] = "dev"; 25var credential = Assert.IsType<EntraIdLocalDeveloperCertificateCredential>(Assert.Single(entra.Resource.ClientCredentials)); 26var original = await credential.GetCertificateAsync(app.Services, entra.Resource, TestContext.Current.CancellationToken); 27_ = entra.Resource.GetBicepTemplateString(); 29await BicepUtilities.SetParametersAsync(parameters, entra.Resource, builder.ExecutionContext, cancellationToken: TestContext.Current.CancellationToken); 30var initialChecksum = BicepUtilities.GetChecksum(entra.Resource, parameters, scope: null); 33Assert.Equal(initialChecksum, await BicepUtilities.GetCurrentChecksumAsync(entra.Resource, section, builder.ExecutionContext, NullLogger.Instance, TestContext.Current.CancellationToken)); 34entra.Resource.ClientCredentials.Clear(); 35var reusedCredential = new EntraIdLocalDeveloperCertificateCredential(entra.Resource, builder.ExecutionContext); 36entra.Resource.ClientCredentials.Add(reusedCredential); 37Assert.Equal(initialChecksum, await BicepUtilities.GetCurrentChecksumAsync(entra.Resource, section, builder.ExecutionContext, NullLogger.Instance, TestContext.Current.CancellationToken)); 38var reused = await reusedCredential.GetCertificateAsync(app.Services, entra.Resource, TestContext.Current.CancellationToken); 43entra.Resource.ClientCredentials.Clear(); 44var nextRun = new EntraIdLocalDeveloperCertificateCredential(entra.Resource, builder.ExecutionContext); 45entra.Resource.ClientCredentials.Add(nextRun); 47var renewedChecksum = await BicepUtilities.GetCurrentChecksumAsync(entra.Resource, section, builder.ExecutionContext, NullLogger.Instance, TestContext.Current.CancellationToken); 50var renewed = await nextRun.GetCertificateAsync(app.Services, entra.Resource, TestContext.Current.CancellationToken);

245var credential = Assert.IsType<EntraIdLocalDeveloperCertificateCredential>(Assert.Single(entra.Resource.ClientCredentials)); 248var template = entra.Resource.GetBicepTemplateString(); 249var certificate = await credential.GetCertificateAsync(app.Services, entra.Resource, TestContext.Current.CancellationToken); 266Assert.Null(created.Resource.TenantId); 267Assert.Null(created.Resource.ClientId); 271Assert.Null(created.Resource.TenantIdParameter); 272Assert.Null(created.Resource.ClientIdParameter); 273Assert.False(created.Resource.IsExistingApplication); 282var template = entra.Resource.GetBicepTemplateString(); 283Assert.Empty(entra.Resource.ClientCredentials); 286var environment = await EnvironmentVariableEvaluator.GetEnvironmentVariablesAsync(web.Resource, DistributedApplicationOperation.Publish, TestServiceProvider.Instance); 304entra.Resource.Outputs["tenantId"] = "aaaabbbb-0000-cccc-1111-dddd2222eeee"; 305entra.Resource.Outputs["clientId"] = "00001111-aaaa-2222-bbbb-3333cccc4444"; 306entra.Resource.ProvisioningTaskCompletionSource!.SetResult(); 308var result = await ExecutionConfigurationBuilder.Create(web.Resource).WithEnvironmentVariablesConfig() 323var selected = await Assert.IsType<EntraIdLocalDeveloperCertificateCredential>(Assert.Single(entra.Resource.ClientCredentials)) 324.GetCertificateAsync(app.Services, entra.Resource, TestContext.Current.CancellationToken); 336var secret = Assert.IsType<EntraIdLocalDeveloperCertificateCredential>(entra.Resource.ClientCredentials[0]).Secret; 338var dependencies = await web.Resource.GetResourceDependenciesAsync(builder.ExecutionContext, cancellationToken: TestContext.Current.CancellationToken); 343var args = await ExecutionConfigurationBuilder.Create(executable.Resource).WithArgumentsConfig() 356var credential = Assert.IsType<EntraIdLocalDeveloperCertificateCredential>(entra.Resource.ClientCredentials[0]); 357var first = await credential.GetCertificateAsync(app.Services, entra.Resource, TestContext.Current.CancellationToken); 359var second = await credential.GetCertificateAsync(app.Services, entra.Resource, TestContext.Current.CancellationToken); 363credential.EmitEnvironmentVariables(env, "AzureAd__ClientCredentials__0", "__", entra.Resource, new ProjectResource("web"), builder.ExecutionContext); 365Assert.False(entra.Resource.ProvisioningTaskCompletionSource!.Task.IsCompleted); 367Assert.False(entra.Resource.ProvisioningTaskCompletionSource.Task.IsCompleted);

49Password = password.Resource 60var configuration = await GetConfigurationAsync(project.Resource, operation); 140entra.Resource.Outputs["tenantId"] = TenantId; 141entra.Resource.Outputs["clientId"] = ClientId; 142entra.Resource.ProvisioningTaskCompletionSource!.SetResult(); 145var configuration = await GetConfigurationAsync(project.Resource, DistributedApplicationOperation.Run); 162var configuration = await GetConfigurationAsync(project.Resource, DistributedApplicationOperation.Run);

169var hub = new AzureEventHubResource(name, hubName, builder.Resource); 170builder.Resource.Hubs.Add(hub); 189configure(builder.Resource); 214var consumerGroup = new AzureEventHubConsumerGroupResource(name, groupName, builder.Resource); 215builder.Resource.ConsumerGroups.Add(consumerGroup); 256if (builder.Resource.IsEmulator) 284.AddAzureStorage($"{builder.Resource.Name}-storage") 287var surrogate = new AzureEventHubsEmulatorResource(builder.Resource); 299var storage = storageResource.Resource; 317var customConfigFile = builder.Resource.Annotations.OfType<ConfigFileAnnotation>().FirstOrDefault(); 330var tempConfig = JsonNode.Parse(CreateEmulatorConfigJson(builder.Resource)); 338var configJsonAnnotations = builder.Resource.Annotations.OfType<ConfigJsonAnnotation>(); 377return builder.WithBindMount(path ?? $".eventhubs/{builder.Resource.Name}", "/data", isReadOnly: false);

15return builder.WithAnnotation(new RoleAssignmentAnnotation(target.Resource, CreateRoleDefinitions(roles, getName)));

208if (builder.Resource.Annotations 210.Any(a => a.Resource.Name == resource.Resource.Name)) 213$"Origin resource '{resource.Resource.Name}' has already been added to Azure Front Door resource '{builder.Resource.Name}'. " + 217return builder.WithAnnotation(new AzureFrontDoorOriginAnnotation(resource.Resource));

123if (frontDoor.Resource.Annotations 125.Any(annotation => ReferenceEquals(annotation.Environment, environment.Resource))) 130frontDoor.WithAnnotation(new AzureFrontDoorPrivateLinkAnnotation(frontDoor.Resource, environment.Resource)); 134environment.WithAnnotation(new PrivateEndpointTargetAnnotation(frontDoor.Resource));

362var launchProfile = builder.Resource.GetEffectiveLaunchProfile(); 406var targetEndpoint = builder.Resource.GetEndpoint(useHttps ? "https" : "http"); 423var targetEndpoint = builder.Resource.GetEndpoint("http"); 425if (builder.Resource.Language is AzureFunctionsLanguage.TypeScript) 444var resource = builder.Resource; 492if (containerBuilder.Resource.TryGetLastAnnotation<DockerfileBuildAnnotation>(out var dockerfileBuildAnnotation)) 513return WithHostStorageCore(builder, storage.Resource); 529return WithHostStorageCore(builder, storage.Resource); 535builder.Resource.HostStorage = storage; 589if (source.Resource is not IResourceWithConnectionString || source.Resource is not IResourceWithAzureFunctionsConfig azureFunctionsConfig) 614if (source.Resource is not IResourceWithConnectionString || source.Resource is not IResourceWithAzureFunctionsConfig azureFunctionsConfig) 639destination.WithReferenceRelationship(source.Resource); 643connectionName ??= source.Resource.Name; 644source.Resource.ApplyAzureFunctionsConfiguration(context.EnvironmentVariables, connectionName); 655destination.WithReferenceRelationship(source.Resource); 659connectionName ??= source.Resource.Name; 682.Resource;

98builder.WithAnnotation(new DurableTaskSchedulerConnectionStringAnnotation(connectionString.Resource)); 165var emulatorResource = new DurableTaskSchedulerEmulatorResource(builder.Resource); 181.Where(th => th.Parent == builder.Resource) 224var hub = new DurableTaskHubResource(name, builder.Resource); 236var url = builder.Resource.IsEmulator 293return builder.WithAnnotation(new DurableTaskHubNameAnnotation(taskHubName.Resource));

15return builder.WithAnnotation(new RoleAssignmentAnnotation(target.Resource, CreateRoleDefinitions(roles, getName)));

241return builder.Resource.GetSecret(secretName); 257return builder.AddSecret(name, name, parameterResource.Resource); 298var secret = new AzureKeyVaultSecretResource(name, name, builder.Resource, parameterResource); 299builder.Resource.Secrets.Add(secret); 319var secret = new AzureKeyVaultSecretResource(name, name, builder.Resource, value); 320builder.Resource.Secrets.Add(secret); 339return builder.AddSecret(name, secretName, parameterResource.Resource); 358var secret = new AzureKeyVaultSecretResource(name, secretName, builder.Resource, parameterResource); 359builder.Resource.Secrets.Add(secret); 380var secret = new AzureKeyVaultSecretResource(name, secretName, builder.Resource, value); 381builder.Resource.Secrets.Add(secret);

15return builder.WithAnnotation(new RoleAssignmentAnnotation(target.Resource, CreateRoleDefinitions(roles, getName)));

42var k8sEnvBuilder = builder.ApplicationBuilder.CreateResourceBuilder(builder.Resource.KubernetesEnvironment);

80resource.KubernetesEnvironment = k8sEnvBuilder.Resource; 94resource.DefaultContainerRegistry = defaultRegistry.Resource; 95resource.Annotations.Add(new ContainerRegistryReferenceAnnotation(defaultRegistry.Resource)); 96k8sEnvBuilder.WithAnnotation(new ContainerRegistryReferenceAnnotation(defaultRegistry.Resource)); 100resource.ControlPlaneIdentity = controlPlaneIdentity.Resource; 101resource.KubeletIdentity = kubeletIdentity.Resource; 102resource.References.Add(controlPlaneIdentity.Resource); 103resource.References.Add(kubeletIdentity.Resource); 108controlPlaneIdentity.WithAnnotation(new RoleAssignmentAnnotation(kubeletIdentity.Resource, 124foreach (var identity in new[] { controlPlaneIdentity.Resource, kubeletIdentity.Resource }) 136controlPlaneIdentity.Resource.Scope = resource.Scope; 137kubeletIdentity.Resource.Scope = resource.Scope; 162context.Model.Resources.Add(controlPlaneIdentity.Resource); 163context.Model.Resources.Add(kubeletIdentity.Resource); 291builder.Resource.NodePools.Add(config); 293var nodePool = new AksNodePoolResource(name, config, builder.Resource); 383builder.Resource.NodePools.RemoveAll(p => p.Mode is AksNodePoolMode.System); 384builder.Resource.NodePools.Insert(0, config); 428builder.WithAnnotation(new AksSubnetAnnotation(subnet.Resource.Id), ResourceAnnotationMutationBehavior.Replace); 464builder.WithAnnotation(new AksSubnetAnnotation(subnet.Resource.Id)); 468builder.Resource.AksParent.NodePoolSubnets[builder.Resource.Name] = subnet.Resource.Id; 495if (builder.Resource.DefaultContainerRegistry is not null) 497builder.ApplicationBuilder.Resources.Remove(builder.Resource.DefaultContainerRegistry); 498builder.Resource.DefaultContainerRegistry = null; 504new ContainerRegistryReferenceAnnotation(registry.Resource), 510var staleAnnotations = builder.Resource.KubernetesEnvironment.Annotations 514builder.Resource.KubernetesEnvironment.Annotations.Remove(old); 517builder.Resource.KubernetesEnvironment.Annotations.Add( 518new ContainerRegistryReferenceAnnotation(registry.Resource)); 588builder.Resource.GatewayApiEnabled = true; 589builder.Resource.ApplicationLoadBalancerEnabled = true; 605var existingDelegation = subnet.Resource.Annotations.OfType<AzureSubnetServiceDelegationAnnotation>().LastOrDefault(); 618builder.Resource, 619subnet.Resource.Id, 620subnet.Resource, 628builder.Resource.LoadBalancers.Add(lb); 665builder.Resource.OidcIssuerEnabled = enabled; 666builder.Resource.WorkloadIdentityEnabled = enabled;

51var k8sEnvBuilder = builder.ApplicationBuilder.CreateResourceBuilder(builder.Resource.KubernetesEnvironment); 81var k8sEnvBuilder = builder.ApplicationBuilder.CreateResourceBuilder(builder.Resource.KubernetesEnvironment); 135var k8sEnvBuilder = builder.ApplicationBuilder.CreateResourceBuilder(builder.Resource.KubernetesEnvironment); 168var lb = loadBalancer.Resource; 172builder.Resource.GatewayAnnotations["alb.networking.azure.io/alb-name"] = 174builder.Resource.GatewayAnnotations["alb.networking.azure.io/alb-namespace"] = 179builder.Resource.GatewayClassName ??= ReferenceExpression.Create($"azure-alb-external"); 206var lb = loadBalancer.Resource; 207builder.Resource.IngressAnnotations["alb.networking.azure.io/alb-name"] = 209builder.Resource.IngressAnnotations["alb.networking.azure.io/alb-namespace"] = 212builder.Resource.IngressClassName ??= ReferenceExpression.Create($"azure-alb-external");

60var k8sEnvBuilder = builder.ApplicationBuilder.CreateResourceBuilder(builder.Resource.KubernetesEnvironment);

31Assert.Equal("aks", aks.Resource.Name); 32Assert.Equal("{aks.outputs.id}", aks.Resource.Id.ValueExpression); 33Assert.Equal("{aks.outputs.clusterFqdn}", aks.Resource.ClusterFqdn.ValueExpression); 34Assert.Equal("{aks.outputs.oidcIssuerUrl}", aks.Resource.OidcIssuerUrl.ValueExpression); 36var manifest = await AzureManifestUtils.GetManifestWithBicep(aks.Resource); 59var manifest = await AzureManifestUtils.GetManifestWithBicep(aks.Resource); 76Assert.Equal(2, aks.Resource.NodePools.Count); 78Assert.Equal("gpu", gpuPool.Resource.Name); 79Assert.Equal("gpu", gpuPool.Resource.Config.Name); 80Assert.Equal("Standard_NC6s_v3", gpuPool.Resource.Config.VmSize); 81Assert.Equal(0, gpuPool.Resource.Config.MinCount); 82Assert.Equal(5, gpuPool.Resource.Config.MaxCount); 83Assert.Equal(AksNodePoolMode.User, gpuPool.Resource.Config.Mode); 84Assert.Null(gpuPool.Resource.Config.OsSku); 85Assert.Same(aks.Resource, gpuPool.Resource.AksParent); 99Assert.Single(aks.Resource.NodePools); 100var defaultPool = aks.Resource.NodePools[0]; 134Assert.Collection(aks.Resource.NodePools, 136pool => Assert.Same(workers.Resource.Config, pool), 137pool => Assert.Same(defaults.Resource.Config, pool)); 138Assert.Equal(new AksNodePoolConfig("workers", "Standard_D2s_v5", 0, 5, AksNodePoolMode.User, "Ubuntu"), workers.Resource.Config); 139Assert.Equal(new AksNodePoolConfig("defaults", "Standard_D2s_v5", 1, 3, AksNodePoolMode.User), defaults.Resource.Config); 165Assert.Same(systemConfig, aks.Resource.NodePools[0]); 166Assert.Same(workerConfig, workers.Resource.Config); 170workers.Resource.Config.OsSku = "AzureLinux"; 171workers.Resource.Config.VmSize = "Standard_D4s_v5"; 172workers.Resource.Config.MinCount = 2; 173workers.Resource.Config.MaxCount = 4; 175var manifest = await AzureManifestUtils.GetManifestWithBicep(aks.Resource); 180var regenerated = await AzureManifestUtils.GetManifestWithBicep(aks.Resource); 209Assert.Collection(aks.Resource.NodePools, 211pool => Assert.Same(workers.Resource.Config, pool)); 238Configure(aks.Resource.NodePools[0]); 239Configure(workers.Resource.Config); 241await Assert.ThrowsAnyAsync<ArgumentException>(() => AzureManifestUtils.GetManifestWithBicep(aks.Resource)); 244await Assert.ThrowsAnyAsync<ArgumentException>(() => AzureManifestUtils.GetManifestWithBicep(aks.Resource)); 253var original = Assert.Single(aks.Resource.NodePools); 261Assert.Same(original, Assert.Single(aks.Resource.NodePools)); 271await Assert.ThrowsAsync<ArgumentOutOfRangeException>(() => AzureManifestUtils.GetManifestWithBicep(aks.Resource)); 274await Assert.ThrowsAsync<ArgumentOutOfRangeException>(() => AzureManifestUtils.GetManifestWithBicep(aks.Resource)); 283var original = Assert.Single(aks.Resource.NodePools); 288Assert.Same(original, Assert.Single(aks.Resource.NodePools)); 305var manifest = await AzureManifestUtils.GetManifestWithBicep(aks.Resource); 306var regenerated = await AzureManifestUtils.GetManifestWithBicep(aks.Resource); 323Assert.True(aks.Resource.OidcIssuerEnabled); 324Assert.True(aks.Resource.WorkloadIdentityEnabled); 325Assert.Null(aks.Resource.KubernetesVersion); 326Assert.False(aks.Resource.IsPrivateCluster); 327Assert.False(aks.Resource.ContainerInsightsEnabled); 328Assert.Null(aks.Resource.LogAnalyticsWorkspace); 342Assert.NotNull(aks.Resource.KubernetesEnvironment); 343Assert.Equal("aks", aks.Resource.KubernetesEnvironment.Name); 344Assert.True(aks.Resource.TryGetLastAnnotation<KubernetesEnvironmentAnnotation>(out var annotation)); 361Assert.Same(aks.Resource, computeEnvironment); 413Assert.True(aks.Resource.OidcIssuerEnabled); 414Assert.True(aks.Resource.WorkloadIdentityEnabled); 432Assert.True(project.Resource.TryGetLastAnnotation<AppIdentityAnnotation>(out var appIdentity)); 433Assert.Same(identity.Resource, appIdentity.IdentityResource); 445Assert.IsAssignableFrom<IAzureComputeEnvironmentResource>(aks.Resource); 457Assert.IsAssignableFrom<IAzureNspAssociationTarget>(aks.Resource); 495Assert.True(aks.Resource.TryGetLastAnnotation<AksSubnetAnnotation>(out _)); 498Assert.Single(aks.Resource.NodePoolSubnets); 499Assert.True(aks.Resource.NodePoolSubnets.ContainsKey("gpu")); 502Assert.True(gpuPool.Resource.TryGetLastAnnotation<AksSubnetAnnotation>(out _)); 521Assert.False(aks.Resource.TryGetLastAnnotation<AksSubnetAnnotation>(out _)); 524Assert.Single(aks.Resource.NodePoolSubnets); 525Assert.True(aks.Resource.NodePoolSubnets.ContainsKey("gpu")); 543Assert.True(container.Resource.TryGetLastAnnotation<KubernetesNodePoolAnnotation>(out var affinity)); 544Assert.Same(gpuPool.Resource, affinity.NodePool); 562Assert.Equal(3, aks.Resource.NodePools.Count); 563Assert.Equal("cpu", pool1.Resource.Name); 564Assert.Equal("gpu", pool2.Resource.Name); 575Assert.NotNull(aks.Resource.DefaultContainerRegistry); 576Assert.Equal("aks-acr", aks.Resource.DefaultContainerRegistry.Name); 591Assert.Null(aks.Resource.DefaultContainerRegistry); 594Assert.True(aks.Resource.TryGetLastAnnotation<ContainerRegistryReferenceAnnotation>(out var annotation)); 595Assert.Same(explicitAcr.Resource, annotation.Registry); 610Assert.True(aks.Resource.TryGetLastAnnotation<ContainerRegistryReferenceAnnotation>(out var aksAnnotation)); 611Assert.Same(aks.Resource.DefaultContainerRegistry, aksAnnotation.Registry); 613Assert.True(aks.Resource.KubernetesEnvironment 615Assert.Same(aks.Resource.DefaultContainerRegistry, annotation.Registry); 648Assert.Same(registry.Resource, roles.TargetAzureResource); 649Assert.Same(aks.Resource.KubeletIdentity, roles.IdentityResource); 650Assert.Equal(aks.Resource.KubeletIdentity!.PrincipalId.ValueExpression, 653Assert.False(aks.Resource.Parameters.ContainsKey("acrName")); 654Assert.Equal("{aks.outputs.kubeletIdentityObjectId}", aks.Resource.KubeletIdentityObjectId.ValueExpression); 693Assert.Same(final.Resource, provisioningRoles.TargetAzureResource); 694Assert.Same(aks.Resource.KubeletIdentity, provisioningRoles.IdentityResource); 696identity => Assert.Same(aks.Resource.ControlPlaneIdentity, identity), 697identity => Assert.Same(aks.Resource.KubeletIdentity, identity)); 712.OfType<AzureRoleAssignmentResource>().Where(resource => resource.TargetAzureResource == registry.Resource); 714role => Assert.Same(first.Resource.KubeletIdentity, role.IdentityResource), 715role => Assert.Same(second.Resource.KubeletIdentity, role.IdentityResource)); 730.OfType<AzureRoleAssignmentResource>(), resource => resource.TargetAzureResource == registry.Resource); 731Assert.Same(aks.Resource.KubeletIdentity, roles.IdentityResource); 733var manifest = await AzureManifestUtils.GetManifestWithBicep(aks.Resource); 746Assert.Null(aks.Resource.ControlPlaneIdentity); 747Assert.Null(aks.Resource.KubeletIdentity); 749var manifest = await AzureManifestUtils.GetManifestWithBicep(aks.Resource); 767Assert.Same(aks.Resource.ControlPlaneIdentity, role.IdentityResource); 768Assert.Same(aks.Resource.KubeletIdentity, role.TargetAzureResource); 769Assert.Contains(role, aks.Resource.References); 773Assert.Same(aks.Resource.KubeletIdentity, role.IdentityResource); 774Assert.Same(aks.Resource.DefaultContainerRegistry, role.TargetAzureResource); 775Assert.Contains(role, aks.Resource.References); 777Assert.Collection(aks.Resource.KubeletIdentity!.Annotations.OfType<RoleAssignmentAnnotation>(), 780Assert.Collection(aks.Resource.ControlPlaneIdentity!.Annotations.OfType<RoleAssignmentAnnotation>(), 810builder.AddParameter("cluster-group", "cluster-rg").Resource, 811builder.AddParameter("cluster-subscription", "00000000-0000-0000-0000-000000000001").Resource) 819aks.Resource.Scope = scope; 825Assert.Same(scope, aks.Resource.ControlPlaneIdentity!.Scope); 826Assert.Same(scope, aks.Resource.KubeletIdentity!.Scope); 829role => role.TargetAzureResource == aks.Resource.KubeletIdentity); 833role => role.TargetAzureResource == aks.Resource.DefaultContainerRegistry); 874registry.Resource.Scope = new AzureBicepResourceScope("explicit-rg", "00000000-0000-0000-0000-000000000001"); 881.OfType<AzureRoleAssignmentResource>(), resource => resource.TargetAzureResource == registry.Resource); 882Assert.Same(registry.Resource.Scope, roles.Scope); 897builder.AddParameter("registry-group", "registry-rg").Resource, 898builder.AddParameter("registry-subscription", "00000000-0000-0000-0000-000000000001").Resource) 902builder.AddParameter("network-group", "network-rg").Resource, 903builder.AddParameter("network-subscription", "00000000-0000-0000-0000-000000000002").Resource) 915var registryRole = Assert.Single(roles, role => role.TargetAzureResource == registry.Resource); 916var networkRole = Assert.Single(roles, role => role.TargetAzureResource == network.Resource); 917Assert.Same(registryScope, registry.Resource.Scope); 919Assert.Same(aks.Resource.KubeletIdentity, registryRole.IdentityResource); 920Assert.Same(networkScope, network.Resource.Scope); 922Assert.Same(aks.Resource.ControlPlaneIdentity, networkRole.IdentityResource); 923Assert.Contains(registryRole, aks.Resource.References); 924Assert.Contains(networkRole, aks.Resource.References); 973Assert.Same(aks.Resource.ControlPlaneIdentity, role.IdentityResource); 974Assert.Same(poolNetwork.Resource, role.TargetAzureResource); 976Assert.Contains(role, aks.Resource.References); 980Assert.Same(aks.Resource.ControlPlaneIdentity, role.IdentityResource); 981Assert.Same(finalNetwork.Resource, role.TargetAzureResource); 983Assert.Contains(role, aks.Resource.References); 985foreach (var annotation in aks.Resource.ControlPlaneIdentity!.Annotations.OfType<RoleAssignmentAnnotation>() 1005Assert.Single(aks.Resource.NodePools, p => p.Mode is AksNodePoolMode.System); 1006var systemPool = aks.Resource.NodePools.First(p => p.Mode is AksNodePoolMode.System); 1025var systemPool = aks.Resource.NodePools.First(p => p.Mode is AksNodePoolMode.System); 1043Assert.Equal("Standard_D2s_v5", aks.Resource.NodePools[0].VmSize); 1049Assert.Single(aks.Resource.NodePools, p => p.Mode is AksNodePoolMode.System); 1050Assert.Equal("Standard_B2s", aks.Resource.NodePools.First(p => p.Mode is AksNodePoolMode.System).VmSize); 1066Assert.Single(aks.Resource.NodePools, p => p.Mode is AksNodePoolMode.System); 1067var systemPool = aks.Resource.NodePools.First(p => p.Mode is AksNodePoolMode.System); 1088Assert.Equal(2, aks.Resource.NodePools.Count); 1089Assert.Equal("Standard_B2s", aks.Resource.NodePools.First(p => p.Mode is AksNodePoolMode.System).VmSize); 1090Assert.Equal("gpu", gpuPool.Resource.Name); 1118var manifest = await AzureManifestUtils.GetManifestWithBicep(aks.Resource); 1136aks.Resource.GatewayApiEnabled = gatewayApiEnabled; 1137aks.Resource.ApplicationLoadBalancerEnabled = applicationLoadBalancerEnabled; 1139Assert.Equal(applicationLoadBalancerEnabled, aks.Resource.RequiresPreviewIngressApi); 1149aks.Resource.GatewayApiEnabled = true; 1151var manifest = await AzureManifestUtils.GetManifestWithBicep(aks.Resource); 1169var manifest = await AzureManifestUtils.GetManifestWithBicep(aks.Resource); 1185Assert.True(aks.Resource.GatewayApiEnabled); 1186Assert.True(aks.Resource.ApplicationLoadBalancerEnabled); 1187Assert.True(aks.Resource.RequiresPreviewIngressApi); 1190Assert.True(albSubnet.Resource.TryGetLastAnnotation<AzureSubnetServiceDelegationAnnotation>(out var delegation)); 1206Assert.Same(aks.Resource, lb.Resource.Parent); 1207Assert.Equal("alb-lb", lb.Resource.AlbName); 1208Assert.True(lb.Resource.TryGetAnnotationsOfType<PipelineStepAnnotation>(out var stepAnnotations)); 1226Assert.NotSame(lb1.Resource, lb2.Resource); 1227Assert.Equal("alb-lb1", lb1.Resource.AlbName); 1228Assert.Equal("alb-lb2", lb2.Resource.AlbName); 1231Assert.True(lb1.Resource.TryGetAnnotationsOfType<PipelineStepAnnotation>(out var lb1Steps)); 1232Assert.True(lb2.Resource.TryGetAnnotationsOfType<PipelineStepAnnotation>(out var lb2Steps)); 1238Assert.True(alb1.Resource.TryGetLastAnnotation<AzureSubnetServiceDelegationAnnotation>(out _)); 1239Assert.True(alb2.Resource.TryGetLastAnnotation<AzureSubnetServiceDelegationAnnotation>(out _)); 1259var delegation = Assert.Single(albSubnet.Resource.Annotations.OfType<AzureSubnetServiceDelegationAnnotation>()); 1263Assert.Equal("Microsoft.Netapp/volumes", lb.Resource.DisplacedDelegationServiceName); 1280var delegation = Assert.Single(albSubnet.Resource.Annotations.OfType<AzureSubnetServiceDelegationAnnotation>()); 1284Assert.Null(lb1.Resource.DisplacedDelegationServiceName); 1285Assert.Null(lb2.Resource.DisplacedDelegationServiceName); 1301var delegation = Assert.Single(albSubnet.Resource.Annotations.OfType<AzureSubnetServiceDelegationAnnotation>()); 1303Assert.Null(lb.Resource.DisplacedDelegationServiceName); 1324var delegation = Assert.Single(albSubnet.Resource.Annotations.OfType<AzureSubnetServiceDelegationAnnotation>()); 1328Assert.Equal("Microsoft.Sql/managedInstances", lb.Resource.DisplacedDelegationServiceName);

24Assert.IsType<KubernetesHelmChartResource>(chart.Resource); 25Assert.IsType<KubernetesEnvironmentResource>(chart.Resource.Parent); 37Assert.Equal("cert-manager", chart.Resource.Name); 38Assert.Equal("oci://quay.io/jetstack/charts/cert-manager", chart.Resource.ChartReference); 39Assert.Equal("1.17.0", chart.Resource.ChartVersion); 53Assert.Equal(2, chart.Resource.Values.Count); 54Assert.Equal("true", chart.Resource.Values["crds.enabled"]); 55Assert.Equal("true", chart.Resource.Values["config.enableGatewayAPI"]); 68Assert.Equal("ingress-nginx", chart.Resource.Namespace); 81Assert.Equal("my-nginx", chart.Resource.ReleaseName); 94Assert.True(chart.Resource.DestroyOnUninstall); 106Assert.False(chart.Resource.DestroyOnUninstall);

32Assert.Single(aks.Resource.NodePools); 33Assert.Equal(AksNodePoolMode.System, aks.Resource.NodePools[0].Mode); 41Assert.Equal(2, aks.Resource.NodePools.Count); 42var workloadPool = aks.Resource.NodePools.First(p => p.Mode is AksNodePoolMode.User); 47Assert.True(container.Resource.TryGetLastAnnotation<KubernetesNodePoolAnnotation>(out var affinity)); 66Assert.Equal(2, aks.Resource.NodePools.Count); // system + gpu 67Assert.DoesNotContain(aks.Resource.NodePools, p => p.Name == "workload"); 70Assert.True(container.Resource.TryGetLastAnnotation<KubernetesNodePoolAnnotation>(out var affinity)); 91Assert.True(container.Resource.TryGetLastAnnotation<KubernetesNodePoolAnnotation>(out var affinity)); 107Assert.True(container.Resource.TryGetLastAnnotation<DeploymentTargetAnnotation>(out var target)); 111Assert.Same(aks.Resource, target.ComputeEnvironment); 142Assert.Same(enva.Resource, enva.Resource.KubernetesEnvironment.OwningComputeEnvironment); 143Assert.Same(envb.Resource, envb.Resource.KubernetesEnvironment.OwningComputeEnvironment); 144Assert.True(enva.Resource.TryGetLastAnnotation<KubernetesEnvironmentAnnotation>(out var _)); 145Assert.True(envb.Resource.TryGetLastAnnotation<KubernetesEnvironmentAnnotation>(out var _)); 151Assert.True(cache.Resource.TryGetLastAnnotation<DeploymentTargetAnnotation>(out var cacheTarget), 153Assert.Same(enva.Resource, cacheTarget.ComputeEnvironment); 155Assert.True(api.Resource.TryGetLastAnnotation<DeploymentTargetAnnotation>(out var apiTarget), 157Assert.Same(enva.Resource, apiTarget.ComputeEnvironment); 160Assert.True(other.Resource.TryGetLastAnnotation<DeploymentTargetAnnotation>(out var otherTarget), 162Assert.Same(envb.Resource, otherTarget.ComputeEnvironment); 347aks.Resource.AzCliPathResolverForTesting = () => "/fake/az"; 348aks.Resource.AzCommandRunnerForTesting = (_, _, _) => Task.FromResult( 483aks.Resource.AzCliPathResolverForTesting = () => "/fake/az"; 484aks.Resource.AzCommandRunnerForTesting = (_, arguments, _) => 515Assert.Empty(aks.Resource.Outputs); 516Assert.NotNull(aks.Resource.KubernetesEnvironment.KubeConfigPath); 518["version --short", $"uninstall aks --namespace default --ignore-not-found --kubeconfig \"{aks.Resource.KubernetesEnvironment.KubeConfigPath}\""], 565aks.Resource.Scope = new AzureBicepResourceScope( 566aks.Resource.NameOutputReference, 567aks.Resource.Id); 568aks.Resource.AzCliPathResolverForTesting = () => "/fake/az"; 569aks.Resource.AzCommandRunnerForTesting = (_, arguments, _) => 598Assert.Empty(aks.Resource.Outputs); 599Assert.NotNull(aks.Resource.KubernetesEnvironment.KubeConfigPath); 601["version --short", $"uninstall aks --namespace default --ignore-not-found --kubeconfig \"{aks.Resource.KubernetesEnvironment.KubeConfigPath}\""], 629aks.Resource.AzCliPathResolverForTesting = () => 643Assert.Null(aks.Resource.KubernetesEnvironment.KubeConfigPath); 677aks.Resource.AzCliPathResolverForTesting = () => 694Assert.Null(aks.Resource.KubernetesEnvironment.KubeConfigPath); 729Assert.Null(aks.Resource.KubernetesEnvironment.KubeConfigPath); 766Assert.Null(aks.Resource.KubernetesEnvironment.KubeConfigPath); 800aks.Resource.AzCliPathResolverForTesting = () => 817Assert.Null(aks.Resource.KubernetesEnvironment.KubeConfigPath); 863aks.Resource.AzCliPathResolverForTesting = () => "/fake/az"; 864aks.Resource.AzCommandRunnerForTesting = (_, arguments, _) => 889Assert.Null(aks.Resource.KubernetesEnvironment.KubeConfigPath); 890Assert.True(aks.Resource.KubernetesEnvironment.SkipDestroyCleanup); 927aks.Resource.KubernetesEnvironment.Annotations.Add( 928new HelmReleaseNameAnnotation(ReferenceExpression.Create($"{releaseParameter.Resource}"))); 929aks.Resource.KubernetesEnvironment.Annotations.Add( 930new KubernetesNamespaceAnnotation(ReferenceExpression.Create($"{namespaceParameter.Resource}"))); 931aks.Resource.AzCliPathResolverForTesting = () => "/fake/az"; 932aks.Resource.AzCommandRunnerForTesting = (_, arguments, _) => 961Assert.Null(aks.Resource.KubernetesEnvironment.KubeConfigPath); 962Assert.True(aks.Resource.KubernetesEnvironment.SkipDestroyCleanup); 999aks.Resource.KubernetesEnvironment.Annotations.Add( 1000new HelmReleaseNameAnnotation(ReferenceExpression.Create($"{aks.Resource.NameOutputReference}"))); 1001aks.Resource.AzCliPathResolverForTesting = () => "/fake/az"; 1002aks.Resource.AzCommandRunnerForTesting = (_, arguments, _) => 1031Assert.Null(aks.Resource.KubernetesEnvironment.KubeConfigPath); 1032Assert.True(aks.Resource.KubernetesEnvironment.SkipDestroyCleanup); 1064aks.Resource.KubernetesEnvironment.Annotations.Add( 1066aks.Resource.KubernetesEnvironment.Annotations.Add( 1068aks.Resource.AzCliPathResolverForTesting = () => "/fake/az"; 1069aks.Resource.AzCommandRunnerForTesting = (_, arguments, _) => 1091var kubeConfigPath = Assert.IsType<string>(aks.Resource.KubernetesEnvironment.KubeConfigPath); 1131Assert.Null(aks.Resource.KubernetesEnvironment.KubeConfigPath); 1374aks.Resource.Outputs["name"] = clusterName; 1377aks.Resource.AzCliPathResolverForTesting = () => "/usr/bin/az"; 1378aks.Resource.AzCommandRunnerForTesting = (path, arguments, logger) => 1402foreach (var annotation in aks.Resource.Annotations.OfType<PipelineStepAnnotation>()) 1407Resource = aks.Resource 1417Assert.NotNull(aks.Resource.ProvisioningTaskCompletionSource); 1418aks.Resource.ProvisioningTaskCompletionSource.TrySetResult(); 1447await File.ReadAllTextAsync(aks.Resource.KubernetesEnvironment.KubeConfigPath!, TestContext.Current.CancellationToken)); 1475aks.Resource.Outputs["name"] = clusterName; 1478aks.Resource.AzCliPathResolverForTesting = () => "/usr/bin/az"; 1479aks.Resource.AzCommandRunnerForTesting = (path, arguments, logger) => 1496foreach (var annotation in aks.Resource.Annotations.OfType<PipelineStepAnnotation>()) 1501Resource = aks.Resource 1507Assert.NotNull(aks.Resource.ProvisioningTaskCompletionSource); 1508aks.Resource.ProvisioningTaskCompletionSource.TrySetResult(); 1687aks.Resource.Scope = new AzureBicepResourceScope(scopeResourceGroup, scopeSubscriptionId); 1688aks.Resource.Outputs["name"] = clusterName; 1691aks.Resource.AzCliPathResolverForTesting = () => "/usr/bin/az"; 1692aks.Resource.AzCommandRunnerForTesting = (path, arguments, logger) => 1709foreach (var annotation in aks.Resource.Annotations.OfType<PipelineStepAnnotation>()) 1714Resource = aks.Resource 1720Assert.NotNull(aks.Resource.ProvisioningTaskCompletionSource); 1721aks.Resource.ProvisioningTaskCompletionSource.TrySetResult(); 1757aks.Resource.Scope = AzureBicepResourceScope.CreateForSubscription(subscriptionId); 1758aks.Resource.Outputs["name"] = clusterName; 1761aks.Resource.AzCliPathResolverForTesting = () => "/usr/bin/az"; 1762aks.Resource.AzCommandRunnerForTesting = (path, arguments, logger) => 1779foreach (var annotation in aks.Resource.Annotations.OfType<PipelineStepAnnotation>()) 1784Resource = aks.Resource 1790Assert.NotNull(aks.Resource.ProvisioningTaskCompletionSource); 1791aks.Resource.ProvisioningTaskCompletionSource.TrySetResult();

49Assert.IsType<KubernetesIngressResource>(ingress.Resource); 50Assert.IsType<KubernetesEnvironmentResource>(ingress.Resource.Parent); 61Assert.IsType<KubernetesGatewayResource>(gateway.Resource); 62Assert.IsType<KubernetesEnvironmentResource>(gateway.Resource.Parent); 78Assert.NotNull(gateway.Resource.GatewayClassName); 79var resolvedClass = await gateway.Resource.GatewayClassName!.GetValueAsync(default); 82Assert.True(gateway.Resource.GatewayAnnotations.TryGetValue("alb.networking.azure.io/alb-name", out var albNameRef)); 85Assert.True(gateway.Resource.GatewayAnnotations.TryGetValue("alb.networking.azure.io/alb-namespace", out var albNsRef)); 102Assert.NotNull(ingress.Resource.IngressClassName); 103var resolvedClass = await ingress.Resource.IngressClassName!.GetValueAsync(default); 106Assert.True(ingress.Resource.IngressAnnotations.TryGetValue("alb.networking.azure.io/alb-name", out var albNameRef)); 109Assert.True(ingress.Resource.IngressAnnotations.TryGetValue("alb.networking.azure.io/alb-namespace", out var albNsRef)); 130Assert.NotNull(gateway.Resource.GatewayClassName); 131var resolvedClass = await gateway.Resource.GatewayClassName!.GetValueAsync(default); 134Assert.True(gateway.Resource.GatewayAnnotations.ContainsKey("alb.networking.azure.io/alb-name")); 135Assert.True(gateway.Resource.GatewayAnnotations.ContainsKey("alb.networking.azure.io/alb-namespace"));

24Assert.Same(aks.Resource.KubernetesEnvironment, volume.Resource.Parent); 62var expectedPath = KubernetesPersistentVolumeLocalStorage.GetPath(store, volume.Resource); 64executable.Resource,

118var kustoDatabase = new AzureKustoReadWriteDatabaseResource(name, databaseName, builder.Resource); 119builder.Resource.Databases.Add(kustoDatabase); 130kcsb = GetConnectionStringBuilder(builder.Resource, connectionString); 174var surrogate = new AzureKustoEmulatorResource(builder.Resource); 236var resource = resourceBuilder.Resource; 371if (resourceBuilder.Resource.IsEmulator) 382.Resource 386throw new DistributedApplicationException($"Connection string for Kusto resource '{resourceBuilder.Resource.Name}' is not set."); 389var result = launcher.TryLaunchKustoExplorer(title: "", resourceBuilder.Resource.Name, connectionString, requestText: ""); 397.Resource 401throw new DistributedApplicationException($"Connection string for Kusto resource '{resourceBuilder.Resource.Name}' is not set."); 404var result = launcher.TryLaunchKustoWebExplorer(title: "", resourceBuilder.Resource.Name, connectionString, requestText: ""); 415message: $"Could not automatically open Kusto Web Explorer for resource '{resourceBuilder.Resource.Name}'. Click [{connectionString}]({connectionString}) to manually open the Web Explorer.",

15return builder.WithAnnotation(new RoleAssignmentAnnotation(target.Resource, CreateRoleDefinitions(roles, getName)));

26Assert.NotNull(resourceBuilder.Resource); 27Assert.Equal(name, resourceBuilder.Resource.Name); 28Assert.IsType<AzureKustoClusterResource>(resourceBuilder.Resource); 49var containerAnnotation = resourceBuilder.Resource.Annotations.OfType<ContainerImageAnnotation>().SingleOrDefault(); 69var endpointAnnotations = resourceBuilder.Resource.Annotations.OfType<EndpointAnnotation>().ToList(); 89var emulatorAnnotation = resourceBuilder.Resource.Annotations.OfType<EmulatorResourceAnnotation>().SingleOrDefault(); 107var nameAnnotation = resourceBuilder.Resource.Annotations.OfType<ContainerNameAnnotation>().SingleOrDefault(); 111var argsAnnotation = resourceBuilder.Resource.Annotations.OfType<ContainerRuntimeArgsCallbackAnnotation>().SingleOrDefault(); 126var annotation = resourceBuilder.Resource.Annotations.OfType<EnvironmentCallbackAnnotation>().SingleOrDefault(); 180Assert.IsType<IResourceWithConnectionString>(resourceBuilder.Resource, exactMatch: false); 199Assert.Equal(runAsEmulator, resourceBuilder.Resource.IsEmulator); 217var volumeAnnotation = resourceBuilder.Resource.Annotations.OfType<ContainerMountAnnotation>().SingleOrDefault(); 240var mountAnnotation = resourceBuilder.Resource.Annotations.OfType<ContainerMountAnnotation>().SingleOrDefault(); 262var mountAnnotations = resourceBuilder.Resource.Annotations.OfType<ContainerMountAnnotation>().ToList(); 292var containerImageAnnotation = resourceBuilder.Resource.Annotations.OfType<ContainerImageAnnotation>().SingleOrDefault(); 312var persistenceAnnotation = Assert.Single(resourceBuilder.Resource.Annotations.OfType<PersistenceAnnotation>()); 327Assert.Single(kustoServer.Resource.Annotations, annotation => annotation is HealthCheckAnnotation hca && hca.Key == $"{name}_check"); 342Assert.Single(database.Resource.Annotations, annotation => annotation is HealthCheckAnnotation hca && hca.Key == $"{name}_check"); 359var endpointAnnotations = resourceBuilder.Resource.Annotations.OfType<EndpointAnnotation>().ToList(); 388var script = database.Resource.GetDatabaseCreationScript(); 405var script = database.Resource.GetDatabaseCreationScript(); 424var script = database.Resource.GetDatabaseCreationScript();

17var properties = ((IResourceWithConnectionString)kusto.Resource).GetConnectionProperties().ToArray(); 34var properties = ((IResourceWithConnectionString)kusto.Resource).GetConnectionProperties().ToArray();

56await rns.WaitForResourceHealthyAsync(kusto.Resource.Name, cancellationToken: cts.Token); 60hb.Configuration["ConnectionStrings:KustoConnection"] = await kusto.Resource.ConnectionStringExpression.GetValueAsync(cts.Token); 109await rns.WaitForResourceHealthyAsync(kustoDb.Resource.Name, cancellationToken: cts.Token); 113hb.Configuration["ConnectionStrings:KustoTestDbConnection"] = await kustoDb.Resource.ConnectionStringExpression.GetValueAsync(cts.Token); 189await rns.WaitForResourceHealthyAsync(kusto.Resource.Name, cts.Token); 217await rns.WaitForResourceHealthyAsync(kusto.Resource.Name, cts.Token); 220await rns.WaitForResourceHealthyAsync(db1.Resource.Name, cts.Token); 221await rns.WaitForResourceAsync(db2.Resource.Name, KnownResourceStates.FailedToStart, cts.Token); 258await rns.WaitForResourceHealthyAsync(kustoDb.Resource.Name, cts.Token);

85builder.Resource.PublicIPAddresses.Add(publicIPAddress.Resource);

99if (builder.Resource.SecurityRules.Any(existing => string.Equals(existing.Name, rule.Name, StringComparison.OrdinalIgnoreCase))) 102$"A security rule named '{rule.Name}' already exists in Network Security Group '{builder.Resource.Name}'.", 106builder.Resource.SecurityRules.Add(rule);

87if (builder.Resource.AccessRules.Any(existing => string.Equals(existing.Name, rule.Name, StringComparison.OrdinalIgnoreCase))) 90$"An access rule named '{rule.Name}' already exists in Network Security Perimeter '{builder.Resource.Name}'.", 94builder.Resource.AccessRules.Add(rule); 144associationName ??= $"{target.Resource.Name}-assoc"; 146if (nsp.Resource.Associations.Any(a => string.Equals(a.Name, associationName, StringComparison.OrdinalIgnoreCase))) 149$"An association named '{associationName}' already exists in Network Security Perimeter '{nsp.Resource.Name}'.", 153nsp.Resource.Associations.Add(new AzureNetworkSecurityPerimeterResource.NspAssociationConfig( 155target.Resource.Id,

58var name = $"{subnet.Resource.Name}-{target.Resource.Name}-pe"; 59var vnet = subnet.Resource.Parent; 61var resource = new AzurePrivateEndpointResource(name, subnet.Resource, target.Resource, ConfigurePrivateEndpoint); 70var zoneNames = target.Resource.GetPrivateDnsZoneNames(); 82IResource rootResource = target.Resource; 91if (target.Resource is IAzurePrivateEndpointTargetNotification notificationTarget)

74AzureVirtualNetworkResource resource = new(name, ConfigureVirtualNetwork, addressPrefix.Resource); 204var subnet = new AzureSubnetResource(name, subnetName, addressPrefix, builder.Resource); 238var subnet = new AzureSubnetResource(name, subnetName, addressPrefix.Resource, builder.Resource); 269builder.Resource.Subnets.Add(subnet); 316var target = builder.Resource; 318var subnetId = ReferenceExpression.Create($"{subnet.Resource.Id}"); 329var existingDelegation = subnet.Resource.Annotations 339$"The subnet '{subnet.Resource.Name}' is already delegated to '{existingDelegation.ServiceName}' and cannot also be delegated to '{target.DelegatedSubnetServiceName}'."); 400foreach (var existing in builder.Resource.Annotations.OfType<AzureSubnetServiceDelegationAnnotation>().ToArray()) 402builder.Resource.Annotations.Remove(existing); 436builder.Resource.NatGateway = natGateway.Resource; 469if (builder.Resource.NetworkSecurityGroup is { IsImplicitlyCreated: true }) 472$"The subnet '{builder.Resource.Name}' already has an NSG created via shorthand methods. " + 477builder.Resource.NetworkSecurityGroup = nsg.Resource; 614var subnet = builder.Resource; 621nsgBuilder.Resource.IsImplicitlyCreated = true; 622subnet.NetworkSecurityGroup = nsgBuilder.Resource;

59var postgres = CreatePostgreSqlFlexibleServer(infrastructure, builder.ApplicationBuilder, builder.Resource.Databases); 75var resource = new AzurePostgresResource(builder.Resource, configureInfrastructure); 78.WithLoginAndPassword(builder.Resource); 87if (builder.Resource.Annotations.OfType<ContainerImageAnnotation>().SingleOrDefault() is { } containerAnnotation) 89builder.Resource.Annotations.Remove(containerAnnotation); 173var azureResource = builder.Resource; 176builder.Resource.AddDatabase(name, databaseName); 187azurePostgresDatabase.SetInnerResource(innerDb.Resource); 229var azureResource = builder.Resource; 249azureResource.SetInnerResource(postgresContainer.Resource); 259existingDb.SetInnerResource(innerDb.Resource); 307var kv = builder.ApplicationBuilder.AddAzureKeyVault($"{builder.Resource.Name}-kv") 308.WithParentRelationship(builder.Resource); 316if (builder.Resource.IsContainer()) 318data.Model.Resources.Remove(kv.Resource); 362var azureResource = builder.Resource; 364azureResource.UserNameParameter = userName?.Resource ?? 368azureResource.PasswordParameter = password?.Resource ?? 369ParameterResourceBuilderExtensions.CreateDefaultPasswordParameter(builder.ApplicationBuilder, $"{builder.Resource.Name}-password"); 372azureResource.ConnectionStringSecretOutput = keyVaultBuilder.Resource.GetSecret($"connectionstrings--{builder.Resource.Name}"); 421if (!builder.Resource.IsContainer) 427var innerBuilder = builder.ApplicationBuilder.CreateResourceBuilder(builder.Resource.InnerResource); 632builder.ApplicationBuilder, $"{builder.Resource.Name}-username", secret: false, generatedUserName);

101var azureResource = builder.Resource; 106azureResource.SetInnerResource(redisContainer.Resource); 139var kv = builder.ApplicationBuilder.AddAzureKeyVault($"{builder.Resource.Name}-kv") 140.WithParentRelationship(builder.Resource); 148if (builder.Resource.IsContainer()) 150data.Model.Resources.Remove(kv.Resource); 186var azureResource = builder.Resource; 187azureResource.ConnectionStringSecretOutput = keyVaultBuilder.Resource.GetSecret($"connectionstrings--{azureResource.Name}"); 188azureResource.PrimaryAccessKeySecretOutput = keyVaultBuilder.Resource.GetSecret($"primaryaccesskey--{azureResource.Name}");

59var resource = new AzureRedisResource(builder.Resource, configureInfrastructure); 70if (builder.Resource.Annotations.OfType<ContainerImageAnnotation>().SingleOrDefault() is { } containerAnnotation) 72builder.Resource.Annotations.Remove(containerAnnotation); 165var azureResource = builder.Resource; 170azureResource.SetInnerResource(redisContainer.Resource); 203var kv = builder.ApplicationBuilder.AddAzureKeyVault($"{builder.Resource.Name}-kv") 204.WithParentRelationship(builder.Resource); 212if (builder.Resource.IsContainer()) 214data.Model.Resources.Remove(kv.Resource); 235var azureResource = builder.Resource; 236azureResource.ConnectionStringSecretOutput = keyVaultBuilder.Resource.GetSecret($"connectionstrings--{azureResource.Name}");

222builder.Resource.WorkloadManagedIdentityType = ManagedServiceIdentityType.None; 223builder.Resource.WorkloadUserAssignedIdentities.Clear(); 243builder.Resource.WorkloadManagedIdentityType = ManagedServiceIdentityType.SystemAssigned; 244builder.Resource.WorkloadUserAssignedIdentities.Clear(); 267builder.Resource.AddWorkloadUserAssignedIdentity(identity.Resource); 292builder.Resource.References.Add(identity.Resource); 294new AzureSandboxGroupAcrPullIdentityAnnotation(identity.Resource),

15return builder.WithAnnotation(new RoleAssignmentAnnotation(target.Resource, CreateRoleDefinitions(roles, getName)));

45if (!ShouldPrepareIdentity(context.PipelineContext.ExecutionContext, builder.Resource)) 54Name = $"prepare-cross-scope-acr-pull-identity-{builder.Resource.Name}", 55Description = $"Prepares the ACR pull identity for {builder.Resource.Name}.", 106if (!ShouldPrepareIdentity(context.ExecutionContext, builder.Resource) || 107builder.Resource.ContainerRegistry is not AzureContainerRegistryResource registry) 115var identityName = $"{builder.Resource.Name}-mi"; 119$"Cannot create the cross-scope ACR pull identity '{identityName}' for environment '{builder.Resource.Name}' because a resource with that name already exists. Call 'WithAcrPullIdentity' on the environment to select an existing identity, or use a different resource name."); 143builder.Resource.Annotations.Add(createIdentityAnnotation(identity)); 144if (builder.Resource is AzureBicepResource environment)

15return builder.WithAnnotation(new RoleAssignmentAnnotation(target.Resource, CreateRoleDefinitions(roles, getName)));

185var queue = new AzureServiceBusQueueResource(name, queueName, builder.Resource); 186builder.Resource.Queues.Add(queue); 205configure(builder.Resource); 271var topic = new AzureServiceBusTopicResource(name, topicName, builder.Resource); 272builder.Resource.Topics.Add(topic); 291configure(builder.Resource); 313if (builder.Resource.Topics.FirstOrDefault(x => x.Name == topicName) is { } existingResource) 344var subscription = new AzureServiceBusSubscriptionResource(name, subscriptionName, builder.Resource); 345builder.Resource.Subscriptions.Add(subscription); 364configure(builder.Resource); 402if (builder.Resource.IsEmulator) 429var surrogate = new AzureServiceBusEmulatorResource(builder.Resource); 440if (!builder.Resource.HasAnnotationOfType<SqlServerConnectionAnnotation>()) 446$"{builder.Resource.Name}-sql-pwd", 453.AddSqlServer($"{builder.Resource.Name}-mssql", passwordBuilder) 462foreach (var sqlServerConfiguration in builder.Resource.Annotations.OfType<SqlServerConfigurationAnnotation>()) 467if (!sqlServerBuilder.Resource.Annotations.OfType<EndpointAnnotation>().Any(e => e.Name == SqlServerEndpointName)) 475builder.WithAnnotation(new SqlServerConnectionAnnotation(sqlServerBuilder.Resource, [])); 484if (!builder.Resource.TryGetLastAnnotation<SqlServerConnectionAnnotation>(out var sqlConnection)) 503var customConfigFile = builder.Resource.Annotations.OfType<ConfigFileAnnotation>().FirstOrDefault(); 516var tempConfig = JsonNode.Parse(CreateEmulatorConfigJson(builder.Resource)); 524var configJsonAnnotations = builder.Resource.Annotations.OfType<ConfigJsonAnnotation>(); 672if (builder.Resource.HasAnnotationOfType<SqlServerConnectionAnnotation>()) 713if (builder.Resource.HasAnnotationOfType<SqlServerConfigurationAnnotation>()) 720if (builder.Resource.TryGetLastAnnotation<SqlServerConnectionAnnotation>(out var previousConnection)) 722RemoveWaitFor(builder.Resource, previousConnection.WaitAnnotations); 726var existingAnnotations = builder.Resource.Annotations.ToHashSet(); 728var waitAnnotations = builder.Resource.Annotations 732return builder.WithAnnotation(new SqlServerConnectionAnnotation(sqlServer.Resource, waitAnnotations), ResourceAnnotationMutationBehavior.Replace);

15return builder.WithAnnotation(new RoleAssignmentAnnotation(target.Resource, CreateRoleDefinitions(roles, getName)));

172var surrogate = new AzureSignalREmulatorResource(builder.Resource);

15return builder.WithAnnotation(new RoleAssignmentAnnotation(target.Resource, CreateRoleDefinitions(roles, getName)));

32CreateSqlServer(infrastructure, builder.ApplicationBuilder, builder.Resource.Databases); 35var resource = new AzureSqlServerResource(builder.Resource, configureInfrastructure); 46if (builder.Resource.Annotations.OfType<ContainerImageAnnotation>().SingleOrDefault() is { } containerAnnotation) 48builder.Resource.Annotations.Remove(containerAnnotation); 120var azureResource = builder.Resource; 123builder.Resource.AddDatabase(azureSqlDatabase); 134azureSqlDatabase.SetInnerResource(innerDb.Resource); 151builder.Resource.UseDefaultAzureSku = true; 190var azureResource = builder.Resource; 200azureResource.SetInnerResource(sqlContainer.Resource); 210existingDb.SetInnerResource(innerDb.Resource); 409builder.Resource.Annotations.Add(new AdminDeploymentScriptSubnetAnnotation(subnet.Resource)); 461builder.Resource.DeploymentScriptStorage = storage.Resource; 464if (!storage.Resource.IsExisting())

536DeploymentScriptDependsOn.Add(privateEndpoint.Resource); 552DeploymentScriptStorage = CreateDeploymentScriptStorage(builder, builder.CreateResourceBuilder(this)).Resource; 558AdminIdentity = admin.Resource; 584}).Resource; 621var sqlName = azureSqlServer.Resource.Name; 689sql.DeploymentScriptDependsOn.Add(storagePe.Resource); 706var vnet = builder.CreateResourceBuilder(peSubnet.Resource.Parent); 709.Where(s => ReferenceEquals(s.Parent, vnet.Resource)); 711var aciSubnetCidr = SubnetAddressAllocator.AllocateDeploymentScriptSubnet(vnet.Resource, existingSubnets); 714aciSubnetResource = aciSubnet.Resource; 716sql.Annotations.Add(new AdminDeploymentScriptSubnetAnnotation(aciSubnet.Resource));

188if (builder.Resource.IsHnsEnabled) 221var blobConnectionString = await builder.Resource.GetBlobConnectionString().GetValueAsync(ct).ConfigureAwait(false) ?? throw new DistributedApplicationException($"{nameof(ConnectionStringAvailableEvent)} was published for the '{builder.Resource.Name}' resource but the connection string was null."); 224var queueConnectionString = await builder.Resource.GetQueueConnectionString().GetValueAsync(ct).ConfigureAwait(false) ?? throw new DistributedApplicationException($"{nameof(ConnectionStringAvailableEvent)} was published for the '{builder.Resource.Name}' resource but the connection string was null."); 235foreach (var container in builder.Resource.BlobContainers) 241foreach (var queue in builder.Resource.Queues) 249var healthCheckKey = $"{builder.Resource.Name}_check"; 262var surrogate = new AzureStorageEmulatorResource(builder.Resource); 284return builder.WithBindMount(path ?? $".azurite/{builder.Resource.Name}", "/data", isReadOnly); 394if (string.Equals(name, builder.Resource.Name + "-blobs", StringComparisons.ResourceName)) 399builder.Resource.ImplicitBlobService ??= defaultService; 404builder.Resource.ImplicitBlobService ??= service; 421builder.Resource.IsHnsEnabled = true; 423if (string.Equals(name, builder.Resource.Name + "-data-lake", StringComparisons.ResourceName)) 428builder.Resource.ImplicitDataLakeService ??= defaultService; 433builder.Resource.ImplicitDataLakeService ??= service; 464var name = builder.Resource.Name + "-blobs"; 466return builder.Resource.BlobStorageBuilder ??= CreateBlobService(builder, name); 473var name = builder.Resource.Name + "-data-lake"; 475return builder.Resource.DataLakeStorageBuilder ??= CreateDataLakeService(builder, name); 495var parentBuilder = builder.Resource.ImplicitBlobService ??= GetBlobService(builder); 496AzureBlobStorageContainerResource resource = new(name, blobContainerName, parentBuilder.Resource); 497builder.Resource.BlobContainers.Add(resource); 534builder.Resource.IsHnsEnabled = true; 538var parentBuilder = builder.Resource.ImplicitDataLakeService ??= GetDataLakeService(builder); 539AzureDataLakeStorageFileSystemResource resource = new(name, dataLakeFileSystemName, parentBuilder.Resource); 540builder.Resource.DataLakeFileSystems.Add(resource); 562AzureBlobStorageContainerResource resource = new(name, blobContainerName, builder.Resource); 563builder.Resource.Parent.BlobContainers.Add(resource); 614if (string.Equals(name, builder.Resource.Name + "-queues", StringComparisons.ResourceName)) 619builder.Resource.ImplicitQueueService ??= defaultService; 624builder.Resource.ImplicitQueueService ??= service; 637var name = builder.Resource.Name + "-queues"; 639return builder.Resource.QueueStorageBuilder ??= CreateQueueService(builder, name); 659var parentBuilder = builder.Resource.ImplicitQueueService ??= builder.GetQueueService(); 660AzureQueueStorageQueueResource resource = new(name, queueName, parentBuilder.Resource); 661builder.Resource.Queues.Add(resource); 812var resource = new AzureBlobStorageResource(name, builder.Resource); 838var resource = new AzureDataLakeStorageResource(name, builder.Resource); 847var resource = new AzureTableStorageResource(name, builder.Resource); 854var resource = new AzureQueueStorageResource(name, builder.Resource);

15return builder.WithAnnotation(new RoleAssignmentAnnotation(target.Resource, CreateRoleDefinitions(roles, getName)));

19appConfig.Resource.Outputs["appConfigEndpoint"] = "https://myendpoint"; 20Assert.Equal("https://myendpoint", await appConfig.Resource.ConnectionStringExpression.GetValueAsync(default)); 24var manifest = await GetManifestWithBicep(model, appConfig.Resource); 26var connectionStringResource = (IResourceWithConnectionString)appConfig.Resource; 123_ = appConfig.Resource.AddAsExistingResource(infra); 126var (manifest, bicep) = await AzureManifestUtils.GetManifestWithBicep(module.Resource, skipPreparer: true); 140appConfiguration.Resource.Annotations,

19appInsights.Resource.Outputs["appInsightsConnectionString"] = "myinstrumentationkey"; 21var connectionStringResource = (IResourceWithConnectionString)appInsights.Resource; 23Assert.Equal("appInsights", appInsights.Resource.Name); 25Assert.Equal("{appInsights.outputs.appInsightsConnectionString}", appInsights.Resource.ConnectionStringExpression.ValueExpression); 27var (appInsightsManifest, bicep) = await AzureManifestUtils.GetManifestWithBicep(appInsights.Resource); 40appInsights.Resource.Outputs["appInsightsConnectionString"] = "myinstrumentationkey"; 42var connectionStringResource = (IResourceWithConnectionString)appInsights.Resource; 44Assert.Equal("appInsights", appInsights.Resource.Name); 46Assert.Equal("{appInsights.outputs.appInsightsConnectionString}", appInsights.Resource.ConnectionStringExpression.ValueExpression); 48var appInsightsManifest = await AzureManifestUtils.GetManifestWithBicep(appInsights.Resource); 69appInsights.Resource.Outputs["appInsightsConnectionString"] = "myinstrumentationkey"; 71var connectionStringResource = (IResourceWithConnectionString)appInsights.Resource; 73Assert.Equal("appInsights", appInsights.Resource.Name); 75Assert.Equal("{appInsights.outputs.appInsightsConnectionString}", appInsights.Resource.ConnectionStringExpression.ValueExpression); 77var (appInsightsManifest, bicep) = await AzureManifestUtils.GetManifestWithBicep(appInsights.Resource); 90appInsights.Resource.Outputs["appInsightsConnectionString"] = "myinstrumentationkey"; 97var config = await EnvironmentVariableEvaluator.GetEnvironmentVariablesAsync(serviceA.Resource, DistributedApplicationOperation.Run, TestServiceProvider.Instance); 114var (manifest, bicep) = await AzureManifestUtils.GetManifestWithBicep(appInsights.Resource); 128var (manifest, bicep) = await AzureManifestUtils.GetManifestWithBicep(appInsights.Resource);

41_ = appServiceEnvironment.Resource.AddAsExistingResource(infra); 44var (manifest, bicep) = await AzureManifestUtils.GetManifestWithBicep(module.Resource, skipPreparer: true); 58var registry = appServiceEnvironment.Resource.ContainerRegistry; 73var registry = appServiceEnvironment.Resource.ContainerRegistry; 74Assert.Same(acr.Resource, registry); 96var exception = Assert.Throws<InvalidOperationException>(() => appServiceEnvironment.Resource.ContainerRegistry); 125Assert.Same(finalRegistry.Resource, roles.TargetAzureResource); 127var (_, envBicep) = await AzureManifestUtils.GetManifestWithBicep(env.Resource, skipPreparer: true); 174Assert.Same(identity.Resource, Assert.Single(model.Resources.OfType<AzureUserAssignedIdentityResource>(), resource => resource.Name == "env-mi")); 210Assert.Same(registry.Resource, rolesEast.TargetAzureResource); 211Assert.Same(registry.Resource, rolesWest.TargetAzureResource);

34.WithEnvironment(context => context.EnvironmentVariables["CLIENT_ID"] = new TestBicepOutputReferenceProvider(identity.Resource.ClientId)); 40var website = Assert.IsAssignableFrom<AzureProvisioningResource>(api.Resource.GetDeploymentTargetAnnotation()?.DeploymentTarget); 72Assert.Same(env.Resource, target.ComputeEnvironment); 95var target = project.Resource.GetDeploymentTargetAnnotation(); 97Assert.Same(environment.Resource, target.ComputeEnvironment); 143var target = project.Resource.GetDeploymentTargetAnnotation(); 147var (_, virtualNetworkBicep) = await GetManifestWithBicep(vnet.Resource); 183var target = project.Resource.GetDeploymentTargetAnnotation(); 187var (_, virtualNetworkBicep) = await GetManifestWithBicep(vnet.Resource); 225var target = project.Resource.GetDeploymentTargetAnnotation(); 267var target = project.Resource.GetDeploymentTargetAnnotation(); 401project2.Resource.TryGetLastAnnotation<DeploymentTargetAnnotation>(out var target); 445SetFoundryProjectOutputs(project.Resource); 447web.Resource.TryGetLastAnnotation<DeploymentTargetAnnotation>(out var target); 576Assert.NotNull(env.Resource.NameOutputReference); 577Assert.Equal("name", env.Resource.NameOutputReference.Name); 578Assert.Same(env.Resource, env.Resource.NameOutputReference.Resource); 668var (manifest, bicep) = await GetManifestWithBicep(env.Resource); 688var (manifest, bicep) = await GetManifestWithBicep(env.Resource); 719var (manifest, bicep) = await GetManifestWithBicep(env.Resource); 737var steps = await CreateStepsAsync(app, env.Resource); 749Assert.IsAssignableFrom<IAzureComputeEnvironmentResource>(env.Resource); 750Assert.IsAssignableFrom<IComputeEnvironmentResource>(env.Resource); 911project2.Resource.TryGetLastAnnotation<DeploymentTargetAnnotation>(out var target); 947project2.Resource.TryGetLastAnnotation<DeploymentTargetAnnotation>(out var target); 983project2.Resource.TryGetLastAnnotation<DeploymentTargetAnnotation>(out var target); 1021project2.Resource.TryGetLastAnnotation<DeploymentTargetAnnotation>(out var target); 1056project2.Resource.TryGetLastAnnotation<DeploymentTargetAnnotation>(out var target); 1132project.Resource.TryGetLastAnnotation<DeploymentTargetAnnotation>(out var target); 1163container.Resource.TryGetLastAnnotation<DeploymentTargetAnnotation>(out var target); 1187var endpointReferenceEx = env.Resource.GetHostAddressExpression(project.GetEndpoint("http")); 1193Assert.Equal(env.Resource, output.Resource); 1211env.Resource.Outputs["webSiteSuffix"] = "website123"; 1212env.Resource.ProvisioningTaskCompletionSource?.TrySetResult(); 1219var expression = env.Resource.GetEndpointPropertyExpression(project.GetEndpoint("http").Property(property)); 1349project.Resource.TryGetLastAnnotation<DeploymentTargetAnnotation>(out var target); 1380project.Resource.TryGetLastAnnotation<DeploymentTargetAnnotation>(out var target); 1412project.Resource.TryGetLastAnnotation<DeploymentTargetAnnotation>(out var target); 1441featureFlag.Resource,

39await BicepUtilities.SetParametersAsync(parameters, registration.Resource, builder.ExecutionContext); 42cached.Data[BicepUtilities.DeploymentStateChecksumKey] = BicepUtilities.GetChecksum(registration.Resource, parameters, null); 47Assert.True(await provisioner.ConfigureResourceAsync(registration.Resource, CancellationToken.None)); 48Assert.Equal("original-client", registration.Resource.Outputs["clientId"]); 49registration.Resource.Outputs.Clear(); 55Assert.False(await provisioner.ConfigureResourceAsync(registration.Resource, CancellationToken.None)); 56Assert.Empty(registration.Resource.Outputs); 108if (resourceEvent.Resource == entries.Resource) 500await CreateProvisioner(services).GetOrCreateResourceAsync(resource.Resource, context, CancellationToken.None); 502Assert.Equal(hasLocation || explicitlyBound, resource.Resource.HasLocationParameter);

24Assert.Equal("content", bicepResource.Resource.TemplateString); 25Assert.Equal("value1", bicepResource.Resource.Parameters["param1"]); 26Assert.Equal("value2", bicepResource.Resource.Parameters["param2"]); 89if (azureResourceBuilder.Resource is not AzureProvisioningResource bicepResource) 110if (azureResourceBuilder.Resource is not AzureProvisioningResource bicepResource) 128bicepResource.Resource.Outputs["resourceEndpoint"] = "https://myendpoint"; 140bicepResource.Resource.SecretOutputs["connectionString"] = "https://myendpoint;Key=43"; 186bicepResource.Resource.TempDirectory = Environment.CurrentDirectory; 188var manifest = await ManifestUtils.GetManifest(bicepResource.Resource); 221var annotation = bicepResource.Resource.Annotations.OfType<Aspire.Hosting.Pipelines.PipelineStepAnnotation>().FirstOrDefault(); 230Resource = bicepResource.Resource

52worker.Resource, 77worker.Resource, 183Assert.Same(gateway.Resource, connection.Resource.Parent); 184Assert.Same(gateway.Resource, mcp.Resource.Parent); 187Assert.Single(connection.Resource.Annotations.OfType<ManifestPublishingCallbackAnnotation>())); 190Assert.Single(mcp.Resource.Annotations.OfType<ManifestPublishingCallbackAnnotation>())); 191var (manifest, bicep) = await AzureManifestUtils.GetManifestWithBicep(model, gateway.Resource); 223var (manifest, bicep) = await AzureManifestUtils.GetManifestWithBicep(model, gateway.Resource); 257() => AzureManifestUtils.GetManifestWithBicep(model, gateway.Resource)); 284() => AzureManifestUtils.GetManifestWithBicep(model, gateway.Resource)); 311Assert.Single(gateway.Resource.Connections); 331Assert.Single(gateway.Resource.McpServerConfigs); 360Assert.NotEqual(firstConnection.Resource.BicepIdentifier, secondConnection.Resource.BicepIdentifier); 361Assert.NotEqual(secondConnection.Resource.BicepIdentifier, mcp.Resource.BicepIdentifier); 369Assert.StartsWith("connectorConnection_location_abcdefghijklmnop_", firstConnection.Resource.BicepIdentifier, StringComparison.Ordinal); 370Assert.StartsWith("connectorMcpServer_location_abcdefghijklmnop_", mcp.Resource.BicepIdentifier, StringComparison.Ordinal); 374var (_, bicep) = await AzureManifestUtils.GetManifestWithBicep(model, gateway.Resource); 389var (_, firstBicep) = await AzureManifestUtils.GetManifestWithBicep(model, firstGateway.Resource); 390var (_, secondBicep) = await AzureManifestUtils.GetManifestWithBicep(model, secondGateway.Resource); 425Assert.Single(mcp.Resource.Connectors); 449Assert.Empty(mcp.Resource.AccessPolicies); 473Assert.False(mcp.Resource.IsExisting); 513Assert.Empty(mcp.Resource.AccessPolicies); 555Assert.Single(mcp.Resource.AccessPolicies); 578Assert.False(connection.Resource.IsExisting); 609Assert.Empty(connection.Resource.AccessPolicies); 639Assert.Empty(connection.Resource.AccessPolicies); 640Assert.Empty(mcp.Resource.AccessPolicies); 663Assert.Empty(connection.Resource.AccessPolicies); 707Assert.Single(office365.Resource.AccessPolicies).Name, 711Assert.Single(sharepoint.Resource.AccessPolicies).Name, 714Assert.Single(compoundParentName.Resource.AccessPolicies).Name, 715Assert.Single(compoundPolicyName.Resource.AccessPolicies).Name); 759Assert.Single(connection.Resource.AccessPolicies); 800connection.Resource.AccessPolicies, 804connection.Resource.AccessPolicies[0].BicepIdentifier, 805connection.Resource.AccessPolicies[1].BicepIdentifier); 835connection.Resource.BicepIdentifier, 836Assert.Single(connection.Resource.AccessPolicies).BicepIdentifier, 837mcp.Resource.BicepIdentifier, 838Assert.Single(mcp.Resource.AccessPolicies).BicepIdentifier

44_ = containerAppEnvironment.Resource.AddAsExistingResource(infra); 47var (manifest, bicep) = await AzureManifestUtils.GetManifestWithBicep(module.Resource, skipPreparer: true); 74Assert.True(logAnalyticsWorkspace.Resource.TryGetLastAnnotation<ExistingAzureResourceAnnotation>(out var existingAnnotation)); 75Assert.Equal(lawName.Resource, existingAnnotation.Name); 76Assert.Equal(lawResourceGroup.Resource, existingAnnotation.ResourceGroup); 79Assert.True(containerAppEnvironment.Resource.TryGetLastAnnotation<AzureLogAnalyticsWorkspaceReferenceAnnotation>(out var workspaceRef)); 80Assert.Same(logAnalyticsWorkspace.Resource, workspaceRef.Workspace); 83var (manifest, bicep) = await AzureManifestUtils.GetManifestWithBicep(containerAppEnvironment.Resource); 97var registry = containerAppEnvironment.Resource.ContainerRegistry; 112var registry = containerAppEnvironment.Resource.ContainerRegistry; 113Assert.Same(acr.Resource, registry); 135var exception = Assert.Throws<InvalidOperationException>(() => containerAppEnvironment.Resource.ContainerRegistry); 151var (_, envBicep) = await AzureManifestUtils.GetManifestWithBicep(containerAppEnvironment.Resource); 152var (_, vnetBicep) = await AzureManifestUtils.GetManifestWithBicep(vnet.Resource); 173var (manifest, bicep) = await AzureManifestUtils.GetManifestWithBicep(env.Resource); 198var (manifest, bicep) = await AzureManifestUtils.GetManifestWithBicep(env.Resource); 218var (manifest, bicep) = await AzureManifestUtils.GetManifestWithBicep(env.Resource); 249var (manifest, bicep) = await AzureManifestUtils.GetManifestWithBicep(env.Resource); 278Assert.Same(finalRegistry.Resource, roles.TargetAzureResource); 280var (_, envBicep) = await AzureManifestUtils.GetManifestWithBicep(env.Resource, skipPreparer: true); 420Assert.Same(identity.Resource, Assert.Single(model.Resources.OfType<AzureUserAssignedIdentityResource>(), resource => resource.Name == "env-mi")); 455Assert.Same(registry.Resource, rolesEast.TargetAzureResource); 456Assert.Same(registry.Resource, rolesWest.TargetAzureResource); 474() => AzureManifestUtils.GetManifestWithBicep(env.Resource)); 503() => AzureManifestUtils.GetManifestWithBicep(env.Resource, skipPreparer: true)); 527() => AzureManifestUtils.GetManifestWithBicep(env.Resource)); 600Assert.Same(environment.Resource, api.GetDeploymentTargetAnnotation()!.ComputeEnvironment);

53enabled.Resource, bool.TrueString, nested, ReferenceExpression.Create($"disabled")); 61var apiTarget = GetTarget(api.Resource); 62var webTarget = GetTarget(web.Resource); 68Assert.Same(environment.Resource, domain.Resource); 85var host = environment.Resource.GetHostAddressExpression(endpoint); 88Assert.Same(environment.Resource, output.Resource); 89Assert.Null(api.Resource.GetDeploymentTargetAnnotation()); 93var target = GetTarget(api.Resource); 95Assert.Same(target, GetTarget(api.Resource)); 96Assert.Single(api.Resource.Annotations.OfType<DeploymentTargetAnnotation>()); 98environment.Resource.Outputs[DomainOutputName] = "salmonisland-e9e6a567.westus3.azurecontainerapps.io"; 99environment.Resource.ProvisioningTaskCompletionSource?.TrySetResult(); 113var expression = environment.Resource.GetEndpointPropertyExpression(endpoint.Property(property)); 134var expression = environment.Resource.GetEndpointPropertyExpression(api.GetEndpoint("http").Property(property)); 137Assert.Null(api.Resource.GetDeploymentTargetAnnotation()); 156environment.Resource.GetEndpointPropertyExpression(api.GetEndpoint("http").Property(property))); 178enabled.Resource, bool.TrueString, 189var exception = Assert.Throws<InvalidOperationException>(GetTarget(web.Resource).GetBicepTemplateString); 222web.WithEnvironment("EARLY_HOST", producerEnvironment.Resource.GetHostAddressExpression(api.GetEndpoint("http"))); 227var webTarget = GetTarget(web.Resource); 233output => output.Name == DomainOutputName && output.Resource == producerEnvironment.Resource); 234Assert.Same(producerEnvironment.Resource, domain.Resource); 263var target = GetTarget(web.Resource); 266output => output.Name == DomainOutputName && output.Resource == standard.Resource); 267Assert.Same(standard.Resource, domain.Resource); 295var target = GetTarget(web.Resource); 317? environment.Resource.GetEndpointPropertyExpression(endpoint.Property(EndpointProperty.Url)) 323var target = GetTarget(api.Resource); 328Assert.Same(environment.Resource, domain.Resource); 345var firstTarget = GetTarget(first.Resource); 346var secondTarget = GetTarget(second.Resource); 368var target = GetTarget(api.Resource); 369environment.Resource.Outputs[DomainOutputName] = "salmonisland-e9e6a567.westus3.azurecontainerapps.io"; 370environment.Resource.Outputs["AZURE_CONTAINER_APPS_ENVIRONMENT_ID"] = 376foreach (var annotation in environment.Resource.Annotations.OfType<PipelineStepAnnotation>()) 381Resource = environment.Resource 385environment.Resource.ProvisioningTaskCompletionSource?.TrySetResult();

72var exception = Assert.Throws<InvalidOperationException>(environment.Resource.GetBicepTemplateString); 93var (_, expressBicep) = await GetManifestWithBicep(express.Resource); 94var (_, standardBicep) = await GetManifestWithBicep(standard.Resource); 110var (manifest, bicep) = await GetManifestWithBicep(environment.Resource); 126var expressFirstBicep = expressFirst.Resource.GetBicepTemplateString(); 130Assert.Equal(expressFirstBicep, dashboardFirst.Resource.GetBicepTemplateString()); 144var target = Assert.IsType<AzureContainerAppResource>(worker.Resource.GetDeploymentTargetAnnotation()!.DeploymentTarget); 164await Verify(environment.Resource.GetBicepTemplateString(), "bicep"); 191var target = Assert.IsType<AzureContainerAppResource>(project.Resource.GetDeploymentTargetAnnotation()!.DeploymentTarget); 233var target = Assert.IsType<AzureContainerAppResource>(project.Resource.GetDeploymentTargetAnnotation()!.DeploymentTarget); 270var target = Assert.IsType<AzureContainerAppResource>(container.Resource.GetDeploymentTargetAnnotation()!.DeploymentTarget); 290var target = Assert.IsType<AzureContainerAppResource>(container.Resource.GetDeploymentTargetAnnotation()!.DeploymentTarget);

36.WithEnvironment(context => context.EnvironmentVariables["CLIENT_ID"] = new TestBicepOutputReferenceProvider(identity.Resource.ClientId)); 42var resource = Assert.IsAssignableFrom<AzureProvisioningResource>(api.Resource.GetDeploymentTargetAnnotation()?.DeploymentTarget); 134Assert.Same(env.Resource, target.ComputeEnvironment); 156var target = project.Resource.GetDeploymentTargetAnnotation(); 158Assert.Same(environment.Resource, target.ComputeEnvironment); 208SetFoundryProjectOutputs(project.Resource); 210var target = web.Resource.GetDeploymentTargetAnnotation(); 260Assert.Same(infra.Resource, target.ComputeEnvironment); 291Assert.Same(env.Resource, target?.ComputeEnvironment); 412.WithEnvironment("DATABASE_URL", pgContainer.Resource.UriExpression); 975var target = container.Resource.GetDeploymentTargetAnnotation()?.DeploymentTarget as AzureBicepResource; 1662var (manifest, bicep) = await GetManifestWithBicep(sql.Resource); 1783var managedEnvironment = (ContainerAppManagedEnvironment)env.Resource.AddAsExistingResource(infra); 1795var (manifest, bicep) = await GetManifestWithBicep(azResource.Resource); 1885Assert.IsAssignableFrom<IAzureComputeEnvironmentResource>(env.Resource); 1886Assert.IsAssignableFrom<IComputeEnvironmentResource>(env.Resource); 2808var dockerFileAnnotation = c.Resource.Annotations.OfType<DockerfileBuildAnnotation>().Single(); 2874var endpointReferenceEx = env.Resource.GetHostAddressExpression(project.GetEndpoint("http")); 2880Assert.Equal(env.Resource, output.Resource); 2898env.Resource.Outputs["AZURE_CONTAINER_APPS_ENVIRONMENT_DEFAULT_DOMAIN"] = "example.azurecontainerapps.io"; 2899env.Resource.ProvisioningTaskCompletionSource?.TrySetResult(); 2908var expression = env.Resource.GetEndpointPropertyExpression(project.GetEndpoint("http").Property(property)); 2999var containerRegistryInterface = env.Resource as IContainerRegistry; 3083var webappAcaTarget = webappAcaResource.GetDeploymentTargetAnnotation(aca.Resource); 3085Assert.Same(aca.Resource, webappAcaTarget.ComputeEnvironment); 3089var webappServiceTarget = webappServiceResource.GetDeploymentTargetAnnotation(appService.Resource); 3091Assert.Same(appService.Resource, webappServiceTarget.ComputeEnvironment); 3095var containerAcaTarget = containerAcaResource.GetDeploymentTargetAnnotation(aca.Resource); 3097Assert.Same(aca.Resource, containerAcaTarget.ComputeEnvironment); 3103var containerAppServiceAcaTarget = containerAppServiceResource.GetDeploymentTargetAnnotation(aca.Resource); 3107Assert.Null(webappAcaResource.GetDeploymentTargetAnnotation(appService.Resource)); 3108Assert.Null(webappServiceResource.GetDeploymentTargetAnnotation(aca.Resource)); 3109Assert.Null(containerAcaResource.GetDeploymentTargetAnnotation(appService.Resource)); 3193featureFlag.Resource, 3236featureFlag.Resource, 3238ReferenceExpression.Create($"prefix-{connectionPrefix.Resource}-enabled"), 3279innerFlag.Resource, 3285outerFlag.Resource, 3323var steps = await CreateStepsAsync(app, env.Resource);

53Assert.Same(registryBuilder.Resource, annotation!.Registry); 63var (manifest, bicep) = await GetManifestWithBicep(acr.Resource); 124_ = acr.Resource.AddAsExistingResource(infra); 127var (manifest, bicep) = await AzureManifestUtils.GetManifestWithBicep(module.Resource, skipPreparer: true); 143var pipelineStepAnnotations = acr.Resource.Annotations.OfType<PipelineStepAnnotation>().ToList(); 149Resource = acr.Resource 173var pipelineStepAnnotations = acr.Resource.Annotations.OfType<PipelineStepAnnotation>().ToList(); 178Resource = acr.Resource 202var pipelineStepAnnotations = acr.Resource.Annotations.OfType<PipelineStepAnnotation>().ToList(); 207Resource = acr.Resource 228var configAnnotations = acr.Resource.Annotations.OfType<PipelineConfigurationAnnotation>().ToList(); 240var (_, bicep) = await GetManifestWithBicep(acr.Resource); 254var (_, bicep) = await GetManifestWithBicep(acr.Resource); 267var (_, bicep) = await GetManifestWithBicep(acr.Resource); 329await Assert.ThrowsAsync<ArgumentException>(async () => await GetManifestWithBicep(acr.Resource)); 340var (_, bicep) = await GetManifestWithBicep(acr.Resource); 356Assert.Same(acr.Resource, registryBuilder.Resource); 368Assert.NotNull(registryBuilder.Resource); 369Assert.IsType<AzureContainerRegistryResource>(registryBuilder.Resource);

48await app.ResourceNotifications.WaitForResourceAsync(resource.Resource.Name, KnownResourceStates.Running, cts.Token); 50await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Waiting, cts.Token); 54await app.ResourceNotifications.WaitForResourceHealthyAsync(resource.Resource.Name, cts.Token); 56await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running, cts.Token); 94await app.ResourceNotifications.WaitForResourceHealthyAsync(db.Resource.Name, cts.Token); 98hb.Configuration[$"ConnectionStrings:{db.Resource.Name}"] = await cosmos.Resource.ConnectionStringExpression.GetValueAsync(default); 99hb.AddAzureCosmosClient(db.Resource.Name); 100hb.AddCosmosDbContext<EFCoreCosmosDbContext>(db.Resource.Name, databaseName); 175await rns.WaitForResourceHealthyAsync(cosmos1.Resource.Name, cts.Token); 183[$"ConnectionStrings:{cosmos1.Resource.Name}"] = await cosmos1.Resource.ConnectionStringExpression.GetValueAsync(default) 186hb.AddAzureCosmosClient(cosmos1.Resource.Name); 223await rns.WaitForResourceHealthyAsync(cosmos2.Resource.Name, cts.Token); 232[$"ConnectionStrings:{cosmos2.Resource.Name}"] = await cosmos2.Resource.ConnectionStringExpression.GetValueAsync(default) 235hb.AddAzureCosmosClient(cosmos2.Resource.Name); 293await rns.WaitForResourceHealthyAsync(cosmos.Resource.Name, cts.Token); 297hb.Configuration[$"ConnectionStrings:{cosmos.Resource.Name}"] = await cosmos.Resource.ConnectionStringExpression.GetValueAsync(default); 298hb.AddAzureCosmosClient(cosmos.Resource.Name);

38var endpointAnnotation = cosmos.Resource.Annotations.OfType<EndpointAnnotation>().FirstOrDefault(); 59var containerImageAnnotation = cosmos.Resource.Annotations.OfType<ContainerImageAnnotation>().FirstOrDefault(); 76var config = await EnvironmentVariableEvaluator.GetEnvironmentVariablesAsync(cosmos.Resource, DistributedApplicationOperation.Run, TestServiceProvider.Instance); 107Assert.Equal("{cosmos.outputs.connectionString}", cosmos.Resource.ConnectionStringExpression.ValueExpression); 110Assert.Equal("AccountEndpoint={cosmos.outputs.connectionString};Database=db1", db1.Resource.ConnectionStringExpression.ValueExpression); 111Assert.Equal("AccountEndpoint={cosmos.outputs.connectionString};Database=db1;Container=container1", container1.Resource.ConnectionStringExpression.ValueExpression); 137Assert.DoesNotContain(";Database=db1", cosmos.Resource.ConnectionStringExpression.ValueExpression); 138Assert.DoesNotContain(";Database=db1;Container=container1", cosmos.Resource.ConnectionStringExpression.ValueExpression); 139Assert.Contains(";Database=db1", db1.Resource.ConnectionStringExpression.ValueExpression); 140Assert.Contains(";Database=db1;Container=container1", container1.Resource.ConnectionStringExpression.ValueExpression); 142Assert.Contains(";Database=db", db2.Resource.ConnectionStringExpression.ValueExpression); 143Assert.Contains(";Database=db;Container=container", container2.Resource.ConnectionStringExpression.ValueExpression); 156((IResourceWithAzureFunctionsConfig)cosmos.Resource).ApplyAzureFunctionsConfiguration(target, "cosmos"); 163((IResourceWithAzureFunctionsConfig)db1.Resource).ApplyAzureFunctionsConfiguration(target, "db1"); 172((IResourceWithAzureFunctionsConfig)container1.Resource).ApplyAzureFunctionsConfiguration(target, "container1"); 207var manifest = await GetManifestWithBicep(model, cosmos.Resource); 257Assert.Equal("{cosmos-kv.secrets.connectionstrings--cosmos}", cosmos.Resource.ConnectionStringExpression.ValueExpression); 258Assert.Equal("{cosmos-kv.secrets.connectionstrings--db1}", database.Resource.ConnectionStringExpression.ValueExpression); 259Assert.Equal("{cosmos-kv.secrets.connectionstrings--container1}", container.Resource.ConnectionStringExpression.ValueExpression); 261var manifest = await GetManifestWithBicep(cosmos.Resource); 276Assert.True(cosmos.Resource.IsContainer()); 278var csExpr = cosmos.Resource.ConnectionStringExpression; 284Assert.Equal(cs, await ((IResourceWithConnectionString)cosmos.Resource).GetConnectionStringAsync()); 297Assert.True(cosmos.Resource.IsContainer()); 299var csExpr = cosmos.Resource.ConnectionStringExpression; 305Assert.Equal(cs, await ((IResourceWithConnectionString)cosmos.Resource).GetConnectionStringAsync()); 375var (manifest, bicep) = await AzureManifestUtils.GetManifestWithBicep(cosmos.Resource); 386var connectionStringResource = (IResourceWithConnectionString)cosmos.Resource; 388Assert.Equal("cosmos", cosmos.Resource.Name); 406cosmos.Resource.Outputs["connectionString"] = "mycosmosconnectionstring"; 408var manifest = await AzureManifestUtils.GetManifestWithBicep(cosmos.Resource); 429var connectionStringResource = (IResourceWithConnectionString)cosmos.Resource; 431Assert.Equal("cosmos", cosmos.Resource.Name); 469kv.Resource.SecretResolver = (secretRef, _) => 479var (manifest, bicep) = await AzureManifestUtils.GetManifestWithBicep(cosmos.Resource); 490var connectionStringResource = (IResourceWithConnectionString)cosmos.Resource; 492Assert.Equal("cosmos", cosmos.Resource.Name); 510cosmos.Resource.Outputs["connectionString"] = "mycosmosconnectionstring"; 512var manifest = await AzureManifestUtils.GetManifestWithBicep(cosmos.Resource); 531var connectionStringResource = (IResourceWithConnectionString)cosmos.Resource; 533Assert.Equal("cosmos", cosmos.Resource.Name); 544var manifest = await AzureManifestUtils.GetManifestWithBicep(cosmos.Resource); 556Assert.True(cosmos.Resource.IsEmulator()); 557Assert.Contains(cosmos.Resource.Annotations, a => a is EmulatorResourceAnnotation); 568Assert.True(cosmos.Resource.IsEmulator()); 569Assert.Contains(cosmos.Resource.Annotations, a => a is EmulatorResourceAnnotation); 579Assert.NotEmpty(cosmos.Resource.Annotations.OfType<OtlpExporterAnnotation>()); 583var config = await EnvironmentVariableEvaluator.GetEnvironmentVariablesAsync(cosmos.Resource, DistributedApplicationOperation.Run, serviceProvider); 615_ = cosmosdb.Resource.AddAsExistingResource(infra); 618var (manifest, bicep) = await AzureManifestUtils.GetManifestWithBicep(module.Resource, skipPreparer: true); 645Assert.NotNull(cosmos.Resource.ConnectionStringSecretOutput); 646Assert.Same(cosmos.Resource, cosmos.Resource.ConnectionStringSecretOutput.SecretOwner); 648Assert.NotNull(cosmos.Resource.PrimaryAccessKeySecretOutput); 649Assert.Same(cosmos.Resource, cosmos.Resource.PrimaryAccessKeySecretOutput.SecretOwner); 652var references = ((IValueWithReferences)cosmos.Resource.ConnectionStringSecretOutput).References.ToList(); 653Assert.Contains(cosmos.Resource, references); 654Assert.Contains(cosmos.Resource.ConnectionStringSecretOutput.Resource, references); 665Assert.Contains(cosmos.Resource.Annotations, a => a is HttpsCertificateConfigurationCallbackAnnotation); 676Assert.DoesNotContain(cosmos.Resource.Annotations, a => a is HttpsCertificateConfigurationCallbackAnnotation); 687cosmos.Resource.Annotations.OfType<HttpsCertificateConfigurationCallbackAnnotation>()); 695Resource = cosmos.Resource, 722cosmos.Resource.Annotations.OfType<CertificateTrustConfigurationCallbackAnnotation>()); 730Resource = cosmos.Resource, 754cosmos.Resource.Annotations.OfType<HttpsCertificateConfigurationCallbackAnnotation>()); 763Resource = cosmos.Resource, 809var emulatorEndpoint = Assert.Single(cosmos.Resource.Annotations.OfType<EndpointAnnotation>(), e => e.Name == "emulator"); 841var emulatorEndpoint = Assert.Single(cosmos.Resource.Annotations.OfType<EndpointAnnotation>(), e => e.Name == "emulator"); 870var dataExplorerEndpoint = Assert.Single(cosmos.Resource.Annotations.OfType<EndpointAnnotation>(), e => e.Name == "data-explorer"); 900var dataExplorerEndpoint = Assert.Single(cosmos.Resource.Annotations.OfType<EndpointAnnotation>(), e => e.Name == "data-explorer"); 911var image = Assert.Single(cosmos.Resource.Annotations.OfType<ContainerImageAnnotation>()); 926var image = Assert.Single(cosmos.Resource.Annotations.OfType<ContainerImageAnnotation>()); 939var image = Assert.Single(cosmos.Resource.Annotations.OfType<ContainerImageAnnotation>()); 953var mount = Assert.Single(cosmos.Resource.Annotations.OfType<ContainerMountAnnotation>()); 961var config = await EnvironmentVariableEvaluator.GetEnvironmentVariablesAsync(cosmos.Resource, DistributedApplicationOperation.Run, serviceProvider); 973var mount = Assert.Single(cosmos.Resource.Annotations.OfType<ContainerMountAnnotation>()); 978var config = await EnvironmentVariableEvaluator.GetEnvironmentVariablesAsync(cosmos.Resource, DistributedApplicationOperation.Run, TestServiceProvider.Instance); 1013var endpoint = Assert.Single(cosmos.Resource.Annotations.OfType<EndpointAnnotation>(), e => e.Name == "data-explorer"); 1019var config = await EnvironmentVariableEvaluator.GetEnvironmentVariablesAsync(cosmos.Resource, DistributedApplicationOperation.Run, serviceProvider); 1033var csExpr = cosmos.Resource.ConnectionStringExpression; 1049var config = await EnvironmentVariableEvaluator.GetEnvironmentVariablesAsync(cosmos.Resource, DistributedApplicationOperation.Run, serviceProvider); 1062var config = await EnvironmentVariableEvaluator.GetEnvironmentVariablesAsync(cosmos.Resource, DistributedApplicationOperation.Run, TestServiceProvider.Instance); 1073var healthEndpoint = Assert.Single(cosmos.Resource.Annotations.OfType<EndpointAnnotation>(), e => e.Name == "emulatorhealth"); 1078Assert.Contains(cosmos.Resource.Annotations, a => a is HealthCheckAnnotation); 1088Assert.Contains(cosmos.Resource.Annotations, a => a is HealthCheckAnnotation hc && hc.Key == "cosmos_check"); 1099var mount = Assert.Single(cosmos.Resource.Annotations.OfType<ContainerMountAnnotation>()); 1112var config = await EnvironmentVariableEvaluator.GetEnvironmentVariablesAsync(cosmos.Resource, DistributedApplicationOperation.Run, TestServiceProvider.Instance); 1124var endpoint = Assert.Single(cosmos.Resource.Annotations.OfType<EndpointAnnotation>(), e => e.Name == "data-explorer"); 1141() => builder.Eventing.PublishAsync(new ResourceReadyEvent(cosmos.Resource, app.Services))); 1158await builder.Eventing.PublishAsync(new ConnectionStringAvailableEvent(cosmos.Resource, app.Services)); 1201Assert.False(cosmos.Resource.IsEmulator); 1202Assert.DoesNotContain(cosmos.Resource.Annotations, a => a is ContainerImageAnnotation); 1203Assert.DoesNotContain(cosmos.Resource.Annotations, a => a is EmulatorResourceAnnotation); 1204Assert.DoesNotContain(cosmos.Resource.Annotations, a => a is ContainerMountAnnotation); 1214Assert.False(cosmos.Resource.IsEmulator); 1215Assert.DoesNotContain(cosmos.Resource.Annotations, a => a is ContainerImageAnnotation); 1216Assert.DoesNotContain(cosmos.Resource.Annotations, a => a is EmulatorResourceAnnotation); 1217Assert.DoesNotContain(cosmos.Resource.Annotations, a => a is ContainerMountAnnotation); 1252cosmos.Resource, 1255foreach (var callback in cosmos.Resource.Annotations.OfType<ResourceUrlsCallbackAnnotation>()) 1277cosmos.Resource, 1280foreach (var callback in cosmos.Resource.Annotations.OfType<ResourceUrlsCallbackAnnotation>())

360var dockerFileAnnotation = c.Resource.Annotations.OfType<DockerfileBuildAnnotation>().Single(); 483Assert.Equal("testregistry", containerAppEnv.Resource.Outputs["AZURE_CONTAINER_REGISTRY_NAME"]); 484Assert.Equal("testregistry.azurecr.io", containerAppEnv.Resource.Outputs["AZURE_CONTAINER_REGISTRY_ENDPOINT"]); 485Assert.Equal(GetTestResourceId("/providers/Microsoft.ManagedIdentity/userAssignedIdentities/test-identity"), containerAppEnv.Resource.Outputs["AZURE_CONTAINER_REGISTRY_MANAGED_IDENTITY_ID"]); 486Assert.Equal("test.westus.azurecontainerapps.io", containerAppEnv.Resource.Outputs["AZURE_CONTAINER_APPS_ENVIRONMENT_DEFAULT_DOMAIN"]); 487Assert.Equal($"/subscriptions/{TestSubscriptionId}/resourceGroups/{TestResourceGroupName}/providers/Microsoft.App/managedEnvironments/testenv", containerAppEnv.Resource.Outputs["AZURE_CONTAINER_APPS_ENVIRONMENT_ID"]); 543Assert.Equal("testregistry", containerAppEnv.Resource.Outputs["AZURE_CONTAINER_REGISTRY_NAME"]); 544Assert.Equal("testregistry.azurecr.io", containerAppEnv.Resource.Outputs["AZURE_CONTAINER_REGISTRY_ENDPOINT"]); 545Assert.Equal(GetTestResourceId("/providers/Microsoft.ManagedIdentity/userAssignedIdentities/test-identity"), containerAppEnv.Resource.Outputs["AZURE_CONTAINER_REGISTRY_MANAGED_IDENTITY_ID"]); 546Assert.Equal("test.westus.azurecontainerapps.io", containerAppEnv.Resource.Outputs["AZURE_CONTAINER_APPS_ENVIRONMENT_DEFAULT_DOMAIN"]); 547Assert.Equal($"/subscriptions/{TestSubscriptionId}/resourceGroups/{TestResourceGroupName}/providers/Microsoft.App/managedEnvironments/testenv", containerAppEnv.Resource.Outputs["AZURE_CONTAINER_APPS_ENVIRONMENT_ID"]); 609Assert.Equal("testregistry", containerAppEnv.Resource.Outputs["AZURE_CONTAINER_REGISTRY_NAME"]); 610Assert.Equal("testregistry.azurecr.io", containerAppEnv.Resource.Outputs["AZURE_CONTAINER_REGISTRY_ENDPOINT"]); 611Assert.Equal(GetTestResourceId("/providers/Microsoft.ManagedIdentity/userAssignedIdentities/test-identity"), containerAppEnv.Resource.Outputs["AZURE_CONTAINER_REGISTRY_MANAGED_IDENTITY_ID"]); 612Assert.Equal("test.westus.azurecontainerapps.io", containerAppEnv.Resource.Outputs["AZURE_CONTAINER_APPS_ENVIRONMENT_DEFAULT_DOMAIN"]); 613Assert.Equal($"/subscriptions/{TestSubscriptionId}/resourceGroups/{TestResourceGroupName}/providers/Microsoft.App/managedEnvironments/testenv", containerAppEnv.Resource.Outputs["AZURE_CONTAINER_APPS_ENVIRONMENT_ID"]); 677var (containerAppSubscriptionId, containerAppResourceGroupName) = GetSubscriptionAndResourceGroup((string)containerAppEnv.Resource.Outputs["AZURE_CONTAINER_APPS_ENVIRONMENT_ID"]!); 713var envResource = Assert.IsAssignableFrom<AzureBicepResource>(environment.Resource); 714var apiTarget = Assert.IsAssignableFrom<AzureBicepResource>(api.Resource.GetDeploymentTargetAnnotation()!.DeploymentTarget); 715var webTarget = Assert.IsAssignableFrom<AzureBicepResource>(web.Resource.GetDeploymentTargetAnnotation()!.DeploymentTarget); 799var webSiteSuffix = Assert.IsType<string>(appServiceEnv.Resource.Outputs["webSiteSuffix"]); 801var (planSubscriptionId, planResourceGroupName) = GetSubscriptionAndResourceGroup((string)appServiceEnv.Resource.Outputs["planId"]!); 894Assert.Equal("acaregistry", acaEnv.Resource.Outputs["AZURE_CONTAINER_REGISTRY_NAME"]); 895Assert.Equal("acaregistry.azurecr.io", acaEnv.Resource.Outputs["AZURE_CONTAINER_REGISTRY_ENDPOINT"]); 896Assert.Equal(GetTestResourceId("/providers/Microsoft.ManagedIdentity/userAssignedIdentities/aca-identity"), acaEnv.Resource.Outputs["AZURE_CONTAINER_REGISTRY_MANAGED_IDENTITY_ID"]); 897Assert.Equal("aca.westus.azurecontainerapps.io", acaEnv.Resource.Outputs["AZURE_CONTAINER_APPS_ENVIRONMENT_DEFAULT_DOMAIN"]); 898Assert.Equal(GetTestResourceId("/providers/Microsoft.App/managedEnvironments/acaenv"), acaEnv.Resource.Outputs["AZURE_CONTAINER_APPS_ENVIRONMENT_ID"]); 901Assert.Equal("aasregistry", aasEnv.Resource.Outputs["AZURE_CONTAINER_REGISTRY_NAME"]); 902Assert.Equal("aasregistry.azurecr.io", aasEnv.Resource.Outputs["AZURE_CONTAINER_REGISTRY_ENDPOINT"]); 903Assert.Equal(GetTestResourceId("/providers/Microsoft.ManagedIdentity/userAssignedIdentities/aas-identity"), aasEnv.Resource.Outputs["AZURE_CONTAINER_REGISTRY_MANAGED_IDENTITY_ID"]); 904Assert.Equal(GetTestResourceId("/providers/Microsoft.Web/serverfarms/aasplan"), aasEnv.Resource.Outputs["planId"]); 905Assert.Equal("aas-client-id", aasEnv.Resource.Outputs["AZURE_CONTAINER_REGISTRY_MANAGED_IDENTITY_CLIENT_ID"]); 1021var setValue = await param.Resource.GetValueAsync(default); 1095var setValue = await param.Resource.GetValueAsync(default); 1145Assert.Equal("testregistry", containerAppEnv.Resource.Outputs["AZURE_CONTAINER_REGISTRY_NAME"]); 1146Assert.Equal("testregistry.azurecr.io", containerAppEnv.Resource.Outputs["AZURE_CONTAINER_REGISTRY_ENDPOINT"]); 1147Assert.Equal(GetTestResourceId("/providers/Microsoft.ManagedIdentity/userAssignedIdentities/test-identity"), containerAppEnv.Resource.Outputs["AZURE_CONTAINER_REGISTRY_MANAGED_IDENTITY_ID"]); 1148Assert.Equal("test.westus.azurecontainerapps.io", containerAppEnv.Resource.Outputs["AZURE_CONTAINER_APPS_ENVIRONMENT_DEFAULT_DOMAIN"]); 1149Assert.Equal($"/subscriptions/{TestSubscriptionId}/resourceGroups/{TestResourceGroupName}/providers/Microsoft.App/managedEnvironments/testenv", containerAppEnv.Resource.Outputs["AZURE_CONTAINER_APPS_ENVIRONMENT_ID"]); 1207Assert.Equal("test.westus.azurecontainerapps.io", containerAppEnv.Resource.Outputs["AZURE_CONTAINER_APPS_ENVIRONMENT_DEFAULT_DOMAIN"]); 1208Assert.Equal(GetTestResourceId("/providers/Microsoft.App/managedEnvironments/testenv"), containerAppEnv.Resource.Outputs["AZURE_CONTAINER_APPS_ENVIRONMENT_ID"]); 1417Assert.Equal("testregistry", containerAppEnv.Resource.Outputs["AZURE_CONTAINER_REGISTRY_NAME"]); 1418Assert.Equal("testregistry.azurecr.io", containerAppEnv.Resource.Outputs["AZURE_CONTAINER_REGISTRY_ENDPOINT"]); 1419Assert.Equal(GetTestResourceId("/providers/Microsoft.ManagedIdentity/userAssignedIdentities/test-identity"), containerAppEnv.Resource.Outputs["AZURE_CONTAINER_REGISTRY_MANAGED_IDENTITY_ID"]); 1420Assert.Equal("test.westus.azurecontainerapps.io", containerAppEnv.Resource.Outputs["AZURE_CONTAINER_APPS_ENVIRONMENT_DEFAULT_DOMAIN"]); 1421Assert.Equal($"/subscriptions/{TestSubscriptionId}/resourceGroups/{TestResourceGroupName}/providers/Microsoft.App/managedEnvironments/testenv", containerAppEnv.Resource.Outputs["AZURE_CONTAINER_APPS_ENVIRONMENT_ID"]); 1424var funcAppDeployment = Assert.IsAssignableFrom<AzureProvisioningResource>(funcApp.Resource.GetDeploymentTargetAnnotation()?.DeploymentTarget); 1426Assert.Equal(await ((BicepOutputReference)funcAppDeployment.Parameters["env_outputs_azure_container_apps_environment_default_domain"]!).GetValueAsync(), containerAppEnv.Resource.Outputs["AZURE_CONTAINER_APPS_ENVIRONMENT_DEFAULT_DOMAIN"]); 1427Assert.Equal(await ((BicepOutputReference)funcAppDeployment.Parameters["env_outputs_azure_container_apps_environment_id"]!).GetValueAsync(), containerAppEnv.Resource.Outputs["AZURE_CONTAINER_APPS_ENVIRONMENT_ID"]); 2119Assert.Equal("secret-key-12345", await regularParam.Resource.GetValueAsync(default)); 2120Assert.Equal("Server=localhost;Database=mydb", await connectionStringParam.Resource.GetValueAsync(default)); 2121Assert.Equal("custom-value-xyz", await customKeyParam.Resource.GetValueAsync(default)); 2175Assert.Equal("secret-key-12345", await regularParam.Resource.GetValueAsync(default)); 2176Assert.Equal("Server=localhost;Database=mydb", await connectionStringParam.Resource.GetValueAsync(default)); 2177Assert.Equal("custom-value-xyz", await customKeyParam.Resource.GetValueAsync(default));

89directory.Resource.Outputs["objectId"] = "aaaabbbb-0000-cccc-1111-dddd2222eeee"; 90directory.Resource.Outputs["servicePrincipalId"] = "00001111-aaaa-2222-bbbb-3333cccc4444"; 91directory.Resource.Outputs["tenantId"] = "87654321-4321-4321-4321-210987654321"; 93var originalOutputs = new Dictionary<string, object?>(directory.Resource.Outputs); 97storage.Resource.Outputs["id"] = "storage-resource"; 99await notifications.PublishUpdateAsync(directory.Resource, snapshot => snapshot with 119Assert.Equal(originalOutputs, directory.Resource.Outputs); 120Assert.True(notifications.TryGetCurrentState(directory.Resource.Name, out var directorySnapshot)); 126Assert.Empty(storage.Resource.Outputs); 140Assert.Equal("storage-resource", storage.Resource.Outputs["id"]); 166}.Order(), directory.Resource.Annotations.OfType<ResourceCommandAnnotation>().Select(command => command.Name).Order()); 205arm.Resource.Scope = AzureBicepResourceScope.CreateForTenant(); 215arm.Resource.Annotations.OfType<ResourceCommandAnnotation>().Select(command => command.Name).Order()); 233? controller.DeleteAzureResourceAsync(model, directory.Resource.Name) 234: controller.ChangeResourceLocationAsync(model, directory.Resource.Name, CancellationToken.None)); 357Assert.Same(firstBuilder.Resource, secondBuilder.Resource); 624storage.Resource.Outputs["blobEndpoint"] = "https://storage.blob.core.windows.net/"; 635await notifications.PublishUpdateAsync(storage.Resource, state => state with 674Assert.Empty(storage.Resource.Outputs); 680Assert.True(notifications.TryGetCurrentState(storage.Resource.Name, out var storageEvent)); 792Assert.True(notifications.TryGetCurrentState(storage.Resource.Name, out var storageEvent)); 794Assert.Equal("https://storage.blob.core.windows.net/", storage.Resource.Outputs["blobEndpoint"]); 811storage.Resource.ProvisioningTaskCompletionSource = existingTcs; 821Assert.Same(existingTcs, storage.Resource.ProvisioningTaskCompletionSource); 855Assert.Empty(storage.Resource.Outputs); 865Assert.True(notifications.TryGetCurrentState(storage.Resource.Name, out var storageEvent)); 867Assert.Equal("https://storage.blob.core.windows.net/", storage.Resource.Outputs["blobEndpoint"]); 903Assert.Equal("https://storage.blob.core.windows.net/", storage.Resource.Outputs["blobEndpoint"]); 932Assert.Equal("https://storage.blob.core.windows.net/", storage.Resource.Outputs["blobEndpoint"]); 975Assert.Contains(storage.Resource.Annotations.OfType<ResourceCommandAnnotation>(), c => c.Name == AzureProvisioningController.ForgetStateCommandName); 976var changeLocationCommand = Assert.Single(storage.Resource.Annotations.OfType<ResourceCommandAnnotation>(), c => c.Name == AzureProvisioningController.ChangeResourceLocationCommandName); 993Assert.Contains(storage.Resource.Annotations.OfType<ResourceCommandAnnotation>(), c => c.Name == AzureProvisioningController.GetAzureResourceCommandName); 994var cancelCommand = Assert.Single(storage.Resource.Annotations.OfType<ResourceCommandAnnotation>(), c => c.Name == AzureProvisioningController.CancelCommandName); 995var deleteCommand = Assert.Single(storage.Resource.Annotations.OfType<ResourceCommandAnnotation>(), c => c.Name == AzureProvisioningController.DeleteAzureResourceCommandName); 996var reprovisionCommand = Assert.Single(storage.Resource.Annotations.OfType<ResourceCommandAnnotation>(), c => c.Name == AzureProvisioningController.ReprovisionResourceCommandName); 1000Assert.DoesNotContain(blobs.Resource.Annotations.OfType<ResourceCommandAnnotation>(), c => 1024await notifications.PublishUpdateAsync(keyVault.Resource, state => state with { State = KnownResourceStates.Running }); 1026Assert.True(notifications.TryGetCurrentState(keyVault.Resource.Name, out var keyVaultEvent)); 1059await notifications.PublishUpdateAsync(postgres.Resource, state => state with { State = KnownResourceStates.Running }); 1061Assert.True(notifications.TryGetCurrentState(postgres.Resource.Name, out var postgresEvent)); 1064var changeLocationCommand = Assert.Single(postgres.Resource.Annotations.OfType<ResourceCommandAnnotation>(), c => c.Name == AzureProvisioningController.ChangeResourceLocationCommandName); 1069ResourceName = postgres.Resource.Name, 1145var getResourceCommand = Assert.Single(storage.Resource.Annotations.OfType<ResourceCommandAnnotation>(), c => c.Name == AzureProvisioningController.GetAzureResourceCommandName); 1150ResourceName = storage.Resource.Name, 1229var getResourceCommand = Assert.Single(storage.Resource.Annotations.OfType<ResourceCommandAnnotation>(), c => c.Name == AzureProvisioningController.GetAzureResourceCommandName); 1234ResourceName = storage.Resource.Name, 1498var getResourceCommand = Assert.Single(storage.Resource.Annotations.OfType<ResourceCommandAnnotation>(), c => c.Name == AzureProvisioningController.GetAzureResourceCommandName); 1503ResourceName = storage.Resource.Name, 1562var getResourceCommand = Assert.Single(storage.Resource.Annotations.OfType<ResourceCommandAnnotation>(), c => c.Name == AzureProvisioningController.GetAzureResourceCommandName); 1567ResourceName = storage.Resource.Name, 1623var getResourceCommand = Assert.Single(storage.Resource.Annotations.OfType<ResourceCommandAnnotation>(), c => c.Name == AzureProvisioningController.GetAzureResourceCommandName); 1628ResourceName = storage.Resource.Name, 1682await notifications.PublishUpdateAsync(storage.Resource, state => state with { State = new("Waiting for Deployment", KnownResourceStateStyles.Info) }); 1684var cancelCommand = Assert.Single(storage.Resource.Annotations.OfType<ResourceCommandAnnotation>(), c => c.Name == AzureProvisioningController.CancelCommandName); 1689ResourceName = storage.Resource.Name, 1703Assert.True(notifications.TryGetCurrentState(storage.Resource.Name, out var storageEvent)); 1737await notifications.PublishUpdateAsync(storage.Resource, state => state with { State = new("Creating ARM Deployment", KnownResourceStateStyles.Info) }); 1739Assert.True(notifications.TryGetCurrentState(storage.Resource.Name, out var storageEvent)); 1814await notifications.PublishUpdateAsync(storage.Resource, state => state with { State = new(AzureProvisioningController.WaitingForDeploymentState, KnownResourceStateStyles.Info) }); 1816Assert.True(notifications.TryGetCurrentState(storage.Resource.Name, out var storageEvent)); 1819var cancelCommand = Assert.Single(storage.Resource.Annotations.OfType<ResourceCommandAnnotation>(), c => c.Name == AzureProvisioningController.CancelCommandName); 1824ResourceName = storage.Resource.Name, 1864var activeReprovisionTask = controller.ReprovisionResourceAsync(model, storage.Resource.Name, CancellationToken.None); 1877var command = Assert.Single(storage.Resource.Annotations.OfType<ResourceCommandAnnotation>(), c => c.Name == commandName); 1882ResourceName = storage.Resource.Name, 1893Assert.Equal([storage.Resource.Name], testBicepProvisioner.ProvisionedResources); 1923var activeReprovisionTask = controller.ReprovisionResourceAsync(model, storage1.Resource.Name, CancellationToken.None); 1929var queuedReprovisionCommand = Assert.Single(storage2.Resource.Annotations.OfType<ResourceCommandAnnotation>(), c => c.Name == AzureProvisioningController.ReprovisionResourceCommandName); 1933ResourceName = storage2.Resource.Name, 1941var conflictingCommand = Assert.Single(storage2.Resource.Annotations.OfType<ResourceCommandAnnotation>(), c => c.Name == AzureProvisioningController.DeleteAzureResourceCommandName); 1945ResourceName = storage2.Resource.Name, 1984await notifications.PublishUpdateAsync(storage.Resource, state => state with { State = KnownResourceStates.Running }); 1986Assert.True(notifications.TryGetCurrentState(storage.Resource.Name, out var storageEvent)); 2022await notifications.PublishUpdateAsync(storage.Resource, state => state with { State = KnownResourceStates.Running }); 2024var cancelCommand = Assert.Single(storage.Resource.Annotations.OfType<ResourceCommandAnnotation>(), c => c.Name == AzureProvisioningController.CancelCommandName); 2029ResourceName = storage.Resource.Name, 2041Assert.True(notifications.TryGetCurrentState(storage.Resource.Name, out var storageEvent)); 2102storage.Resource.Outputs["blobEndpoint"] = "https://storage.blob.core.windows.net/"; 2103storage2.Resource.Outputs["blobEndpoint"] = "https://storage2.blob.core.windows.net/"; 2105await notifications.PublishUpdateAsync(storage.Resource, state => state with { State = new("Failed to Provision", KnownResourceStateStyles.Error) }); 2106await notifications.PublishUpdateAsync(storage2.Resource, state => state with { State = KnownResourceStates.Running }); 2108var deleteCommand = Assert.Single(storage.Resource.Annotations.OfType<ResourceCommandAnnotation>(), c => c.Name == AzureProvisioningController.DeleteAzureResourceCommandName); 2113ResourceName = storage.Resource.Name, 2141Assert.Empty(storage.Resource.Outputs); 2142Assert.Equal("https://storage2.blob.core.windows.net/", storage2.Resource.Outputs["blobEndpoint"]); 2144Assert.True(notifications.TryGetCurrentState(storage.Resource.Name, out var storageEvent)); 2147Assert.True(notifications.TryGetCurrentState(storage2.Resource.Name, out var storage2Event)); 2200await notifications.PublishUpdateAsync(keyVault.Resource, state => state with { State = new("Failed to Provision", KnownResourceStateStyles.Error) }); 2202var deleteCommand = Assert.Single(keyVault.Resource.Annotations.OfType<ResourceCommandAnnotation>(), c => c.Name == AzureProvisioningController.DeleteAzureResourceCommandName); 2207ResourceName = keyVault.Resource.Name, 2226Assert.True(notifications.TryGetCurrentState(keyVault.Resource.Name, out var keyVaultEvent)); 2270await notifications.PublishUpdateAsync(storage.Resource, state => state with { State = KnownResourceStates.Running }); 2271await notifications.PublishUpdateAsync(storage2.Resource, state => state with { State = KnownResourceStates.Running }); 2273var deleteCommand = Assert.Single(storage.Resource.Annotations.OfType<ResourceCommandAnnotation>(), c => c.Name == AzureProvisioningController.DeleteAzureResourceCommandName); 2278ResourceName = storage.Resource.Name, 2292Assert.True(notifications.TryGetCurrentState(storage.Resource.Name, out var storageEvent)); 2296Assert.True(notifications.TryGetCurrentState(storage2.Resource.Name, out var storage2Event)); 2348await notifications.PublishUpdateAsync(storage.Resource, state => state with { State = KnownResourceStates.Running }); 2350var deleteCommand = Assert.Single(storage.Resource.Annotations.OfType<ResourceCommandAnnotation>(), c => c.Name == AzureProvisioningController.DeleteAzureResourceCommandName); 2351var cancelCommand = Assert.Single(storage.Resource.Annotations.OfType<ResourceCommandAnnotation>(), c => c.Name == AzureProvisioningController.CancelCommandName); 2356ResourceName = storage.Resource.Name, 2370ResourceName = storage.Resource.Name, 2380Assert.True(notifications.TryGetCurrentState(storage.Resource.Name, out var storageEvent)); 2413storage.Resource.Outputs["blobEndpoint"] = "https://storage.blob.core.windows.net/"; 2414storage2.Resource.Outputs["blobEndpoint"] = "https://storage2.blob.core.windows.net/"; 2416await notifications.PublishUpdateAsync(storage.Resource, state => state with 2423await notifications.PublishUpdateAsync(storage2.Resource, state => state with 2430var forgetCommand = Assert.Single(storage.Resource.Annotations.OfType<ResourceCommandAnnotation>(), c => c.Name == AzureProvisioningController.ForgetStateCommandName); 2435ResourceName = storage.Resource.Name, 2450Assert.Empty(storage.Resource.Outputs); 2451Assert.Equal("https://storage2.blob.core.windows.net/", storage2.Resource.Outputs["blobEndpoint"]); 2453Assert.True(notifications.TryGetCurrentState(storage.Resource.Name, out var storageEvent)); 2458Assert.True(notifications.TryGetCurrentState(storage2.Resource.Name, out var storage2Event)); 2491await notifications.PublishUpdateAsync(storage.Resource, state => state with { State = KnownResourceStates.Running }); 2492await notifications.PublishUpdateAsync(storage2.Resource, state => state with { State = KnownResourceStates.Running }); 2494var reprovisionCommand = Assert.Single(storage.Resource.Annotations.OfType<ResourceCommandAnnotation>(), c => c.Name == AzureProvisioningController.ReprovisionResourceCommandName); 2499ResourceName = storage.Resource.Name, 2507Assert.Contains(storage.Resource.Outputs, output => output.Key == "blobEndpoint"); 2515Assert.True(notifications.TryGetCurrentState(storage.Resource.Name, out var storageEvent)); 2518Assert.True(notifications.TryGetCurrentState(storage2.Resource.Name, out var storage2Event)); 2545await notifications.PublishUpdateAsync(storage.Resource, state => state with { State = KnownResourceStates.Running }); 2546await notifications.PublishUpdateAsync(storage2.Resource, state => state with { State = KnownResourceStates.Running }); 2548var reprovisionCommand = Assert.Single(storage.Resource.Annotations.OfType<ResourceCommandAnnotation>(), c => c.Name == AzureProvisioningController.ReprovisionResourceCommandName); 2553ResourceName = storage.Resource.Name, 2567Assert.True(notifications.TryGetCurrentState(storage.Resource.Name, out var storageEvent)); 2570Assert.True(notifications.TryGetCurrentState(storage2.Resource.Name, out var storage2Event)); 2581Assert.True(notifications.TryGetCurrentState(storage.Resource.Name, out storageEvent)); 2606await notifications.PublishUpdateAsync(storage.Resource, state => state with { State = KnownResourceStates.Running }); 2608var reprovisionCommand = Assert.Single(storage.Resource.Annotations.OfType<ResourceCommandAnnotation>(), c => c.Name == AzureProvisioningController.ReprovisionResourceCommandName); 2613ResourceName = storage.Resource.Name, 2627Assert.True(notifications.TryGetCurrentState(storage.Resource.Name, out var storageEvent)); 2639Assert.True(notifications.TryGetCurrentState(storage.Resource.Name, out storageEvent)); 2684var reprovisionStorageCommand = Assert.Single(storage.Resource.Annotations.OfType<ResourceCommandAnnotation>(), c => c.Name == AzureProvisioningController.ReprovisionResourceCommandName); 2685var reprovisionStorage2Command = Assert.Single(storage2.Resource.Annotations.OfType<ResourceCommandAnnotation>(), c => c.Name == AzureProvisioningController.ReprovisionResourceCommandName); 2690ResourceName = storage.Resource.Name, 2704ResourceName = storage2.Resource.Name, 2761var reprovisionCommand = Assert.Single(storage.Resource.Annotations.OfType<ResourceCommandAnnotation>(), c => c.Name == AzureProvisioningController.ReprovisionResourceCommandName); 2762var cancelCommand = Assert.Single(storage.Resource.Annotations.OfType<ResourceCommandAnnotation>(), c => c.Name == AzureProvisioningController.CancelCommandName); 2767ResourceName = storage.Resource.Name, 2778Assert.True(notifications.TryGetCurrentState(storage.Resource.Name, out var storageEvent)); 2784ResourceName = storage.Resource.Name, 2795Assert.True(notifications.TryGetCurrentState(storage.Resource.Name, out storageEvent)); 2798Assert.True(notifications.TryGetCurrentState(blobs.Resource.Name, out var blobsEvent)); 2807Assert.True(notifications.TryGetCurrentState(storage.Resource.Name, out storageEvent)); 2856await WaitForResourceStateAsync(notifications, storage2.Resource.Name, "Running"); 2857Assert.True(notifications.TryGetCurrentState(storage2.Resource.Name, out var runningStorage2Event)); 2860var cancelCommand = Assert.Single(storage.Resource.Annotations.OfType<ResourceCommandAnnotation>(), c => c.Name == AzureProvisioningController.CancelCommandName); 2865ResourceName = storage.Resource.Name, 2873Assert.True(notifications.TryGetCurrentState(storage.Resource.Name, out var storageEvent)); 2877Assert.True(notifications.TryGetCurrentState(storage2.Resource.Name, out var storage2Event)); 2882Assert.True(notifications.TryGetCurrentState(storage2.Resource.Name, out storage2Event)); 2906var cancelCommand = Assert.Single(storage.Resource.Annotations.OfType<ResourceCommandAnnotation>(), c => c.Name == AzureProvisioningController.CancelCommandName); 2911ResourceName = storage.Resource.Name, 2958var reprovisionCommand = Assert.Single(storage.Resource.Annotations.OfType<ResourceCommandAnnotation>(), c => c.Name == AzureProvisioningController.ReprovisionResourceCommandName); 2959var cancelCommand = Assert.Single(storage2.Resource.Annotations.OfType<ResourceCommandAnnotation>(), c => c.Name == AzureProvisioningController.CancelCommandName); 2964ResourceName = storage.Resource.Name, 2978ResourceName = storage2.Resource.Name, 3023await notifications.PublishUpdateAsync(storage.Resource, state => state with { State = KnownResourceStates.Running }); 3024await notifications.PublishUpdateAsync(storage2.Resource, state => state with { State = KnownResourceStates.Running }); 3026var changeLocationCommand = Assert.Single(storage.Resource.Annotations.OfType<ResourceCommandAnnotation>(), c => c.Name == AzureProvisioningController.ChangeResourceLocationCommandName); 3031ResourceName = storage.Resource.Name, 3047Assert.True(notifications.TryGetCurrentState(storage.Resource.Name, out var storageEvent)); 3056Assert.True(notifications.TryGetCurrentState(storage2.Resource.Name, out var storage2Event)); 3096await notifications.PublishUpdateAsync(storage.Resource, state => state with { State = new("Failed to Provision", KnownResourceStateStyles.Error) }); 3097await notifications.PublishUpdateAsync(storage2.Resource, state => state with { State = KnownResourceStates.Running }); 3099var changeLocationCommand = Assert.Single(storage.Resource.Annotations.OfType<ResourceCommandAnnotation>(), c => c.Name == AzureProvisioningController.ChangeResourceLocationCommandName); 3104ResourceName = storage.Resource.Name, 3150await notifications.PublishUpdateAsync(storage.Resource, state => state with { State = KnownResourceStates.Running }); 3152var changeLocationCommand = Assert.Single(storage.Resource.Annotations.OfType<ResourceCommandAnnotation>(), c => c.Name == AzureProvisioningController.ChangeResourceLocationCommandName); 3157ResourceName = storage.Resource.Name, 3265await notifications.PublishUpdateAsync(storage.Resource, state => state with { State = KnownResourceStates.Running }); 3267var changeLocationCommand = Assert.Single(storage.Resource.Annotations.OfType<ResourceCommandAnnotation>(), c => c.Name == AzureProvisioningController.ChangeResourceLocationCommandName); 3278ResourceName = storage.Resource.Name, 3338await notifications.PublishUpdateAsync(storage.Resource, state => state with 3344var changeLocationCommand = Assert.Single(storage.Resource.Annotations.OfType<ResourceCommandAnnotation>(), c => c.Name == AzureProvisioningController.ChangeResourceLocationCommandName); 3348ResourceName = storage.Resource.Name, 3357Assert.True(notifications.TryGetCurrentState(storage.Resource.Name, out var storageEvent)); 3398await notifications.PublishUpdateAsync(storage.Resource, state => state with 3404var changeLocationCommand = Assert.Single(storage.Resource.Annotations.OfType<ResourceCommandAnnotation>(), c => c.Name == AzureProvisioningController.ChangeResourceLocationCommandName); 3409ResourceName = storage.Resource.Name, 3471await notifications.PublishUpdateAsync(storage.Resource, state => state with { State = KnownResourceStates.Running }); 3473var changeLocationCommand = Assert.Single(storage.Resource.Annotations.OfType<ResourceCommandAnnotation>(), c => c.Name == AzureProvisioningController.ChangeResourceLocationCommandName); 3478ResourceName = storage.Resource.Name, 3524await notifications.PublishUpdateAsync(storage.Resource, state => state with 3530var changeLocationCommand = Assert.Single(storage.Resource.Annotations.OfType<ResourceCommandAnnotation>(), c => c.Name == AzureProvisioningController.ChangeResourceLocationCommandName); 3535ResourceName = storage.Resource.Name, 3587await notifications.PublishUpdateAsync(storage.Resource, state => state with 3593var changeLocationCommand = Assert.Single(storage.Resource.Annotations.OfType<ResourceCommandAnnotation>(), c => c.Name == AzureProvisioningController.ChangeResourceLocationCommandName); 3598ResourceName = storage.Resource.Name, 3659await notifications.PublishUpdateAsync(storage.Resource, state => state with 3665var changeLocationCommand = Assert.Single(storage.Resource.Annotations.OfType<ResourceCommandAnnotation>(), c => c.Name == AzureProvisioningController.ChangeResourceLocationCommandName); 3669ResourceName = storage.Resource.Name, 3716await notifications.PublishUpdateAsync(storage.Resource, state => state with { State = KnownResourceStates.Running }); 3717await notifications.PublishUpdateAsync(storage2.Resource, state => state with { State = KnownResourceStates.Running }); 3931await notifications.PublishUpdateAsync(storage.Resource, state => state with 4161await notifications.PublishUpdateAsync(storage.Resource, state => state with { State = KnownResourceStates.Running }); 4163var reprovisionCommand = Assert.Single(storage.Resource.Annotations.OfType<ResourceCommandAnnotation>(), c => c.Name == AzureProvisioningController.ReprovisionResourceCommandName); 4168ResourceName = storage.Resource.Name, 4233await notifications.PublishUpdateAsync(keyVault.Resource, state => state with { State = new("Canceled", KnownResourceStateStyles.Info) }); 4235var reprovisionCommand = Assert.Single(keyVault.Resource.Annotations.OfType<ResourceCommandAnnotation>(), c => c.Name == AzureProvisioningController.ReprovisionResourceCommandName); 4240ResourceName = keyVault.Resource.Name, 4253Assert.True(notifications.TryGetCurrentState(keyVault.Resource.Name, out var keyVaultEvent)); 4313await notifications.PublishUpdateAsync(keyVault.Resource, state => state with { State = new("Canceled", KnownResourceStateStyles.Info) }); 4315var reprovisionCommand = Assert.Single(keyVault.Resource.Annotations.OfType<ResourceCommandAnnotation>(), c => c.Name == AzureProvisioningController.ReprovisionResourceCommandName); 4320ResourceName = keyVault.Resource.Name, 4357Assert.True(notifications.TryGetCurrentState(keyVault.Resource.Name, out var keyVaultEvent)); 4387await notifications.PublishUpdateAsync(postgres.Resource, state => state with { State = KnownResourceStates.Running }); 4389var reprovisionCommand = Assert.Single(postgres.Resource.Annotations.OfType<ResourceCommandAnnotation>(), c => c.Name == AzureProvisioningController.ReprovisionResourceCommandName); 4394ResourceName = postgres.Resource.Name, 4439await notifications.PublishUpdateAsync(storage.Resource, state => state with { State = KnownResourceStates.Running }); 4441var changeLocationCommand = Assert.Single(storage.Resource.Annotations.OfType<ResourceCommandAnnotation>(), c => c.Name == AzureProvisioningController.ChangeResourceLocationCommandName); 4446ResourceName = storage.Resource.Name, 4485await notifications.PublishUpdateAsync(keyVault.Resource, state => state with { State = KnownResourceStates.Running }); 4487var changeLocationCommand = Assert.Single(keyVault.Resource.Annotations.OfType<ResourceCommandAnnotation>(), c => c.Name == AzureProvisioningController.ChangeResourceLocationCommandName); 4492ResourceName = keyVault.Resource.Name, 4531await notifications.PublishUpdateAsync(storage.Resource, state => state with { State = KnownResourceStates.Running }); 4533var reprovisionCommand = Assert.Single(storage.Resource.Annotations.OfType<ResourceCommandAnnotation>(), c => c.Name == AzureProvisioningController.ReprovisionResourceCommandName); 4538ResourceName = storage.Resource.Name, 4564Assert.True(notifications.TryGetCurrentState(storage.Resource.Name, out var storageEvent)); 4599var reprovisionCommand = Assert.Single(storage.Resource.Annotations.OfType<ResourceCommandAnnotation>(), c => c.Name == AzureProvisioningController.ReprovisionResourceCommandName); 4606ResourceName = storage.Resource.Name, 4646await notifications.PublishUpdateAsync(storage.Resource, state => state with { State = KnownResourceStates.Running }); 4659Assert.True(notifications.TryGetCurrentState(storage.Resource.Name, out var resourceEvent)); 4699await notifications.PublishUpdateAsync(storage.Resource, state => state with { State = KnownResourceStates.Running }); 4706Assert.True(notifications.TryGetCurrentState(storage.Resource.Name, out var resourceEvent)); 4757await notifications.PublishUpdateAsync(storage.Resource, state => state with { State = KnownResourceStates.Running }); 4758await notifications.PublishUpdateAsync(storage2.Resource, state => state with { State = KnownResourceStates.Running }); 4765Assert.True(notifications.TryGetCurrentState(storage.Resource.Name, out var storageEvent)); 4768Assert.True(notifications.TryGetCurrentState(storage2.Resource.Name, out var storage2Event)); 4801await notifications.PublishUpdateAsync(storage.Resource, state => state with { State = KnownResourceStates.Running }); 4808Assert.True(notifications.TryGetCurrentState(storage.Resource.Name, out var resourceEvent)); 4865Assert.Empty(storage.Resource.Outputs); 4910Assert.Empty(storage.Resource.Outputs); 4956Assert.Empty(storage.Resource.Outputs); 5126var cancelCommand = Assert.Single(storage.Resource.Annotations.OfType<ResourceCommandAnnotation>(), c => c.Name == AzureProvisioningController.CancelCommandName); 5130ResourceName = storage.Resource.Name, 5140Assert.True(notifications.TryGetCurrentState(storage.Resource.Name, out var storageEvent)); 5146Assert.True(notifications.TryGetCurrentState(storage.Resource.Name, out storageEvent)); 5176Assert.Equal([storage.Resource.Name, storage2.Resource.Name], Assert.IsType<string[]>(failedResourcesProperty.Value)); 5215var icon = Assert.Single(resourceBuilder.Resource.Annotations.OfType<ResourceIconAnnotation>()); 5261Assert.Equal(expectedLocation.Resource, resource.Location); 5277Assert.Equal(expectedResourceGroup.Resource, resource.ResourceGroupName);

115.WithParameter("pgdb", pgdb.Resource.ConnectionStringExpression); 167["kvUri"] = kv.Resource.VaultUri, 168["blob"] = blobs.Resource.ConnectionStringExpression, 199roles.Resource.Parameters[AzureBicepResource.KnownParameters.PrincipalId] = null; 200roles.Resource.Parameters[AzureBicepResource.KnownParameters.PrincipalType] = null; 225resourceGroupScoped.Resource.Scope = new(resourceGroup.Resource, subscription.Resource); 235subscriptionScoped.Resource.Scope = AzureBicepResourceScope.CreateForSubscription(subscription.Resource); 245tenantScoped.Resource.Scope = AzureBicepResourceScope.CreateForTenant(); 355module.Resource.Parameters["clientId"] = new TestBicepOutputReferenceProvider(identity.Resource.ClientId); 383module.Resource.Scope = AzureBicepResourceScope.CreateForTenant();

17var properties = ((IResourceWithConnectionString)eventHubs.Resource).GetConnectionProperties().ToArray(); 39var properties = ((IResourceWithConnectionString)eventHubs.Resource).GetConnectionProperties().ToArray();

48await app.ResourceNotifications.WaitForResourceAsync(resource.Resource.Name, KnownResourceStates.Running, cts.Token); 49await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Waiting, cts.Token); 53await app.ResourceNotifications.WaitForResourceHealthyAsync(resource.Resource.Name, cts.Token); 55await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running, cts.Token); 78await app.ResourceNotifications.WaitForResourceHealthyAsync(eventHubns.Resource.Name, cts.Token); 84hb.Configuration["ConnectionStrings:hub"] = await eventHub.Resource.ConnectionStringExpression.GetValueAsync(CancellationToken.None); 90hb.Configuration["ConnectionStrings:eventhubns"] = await eventHubns.Resource.ConnectionStringExpression.GetValueAsync(CancellationToken.None); 91hb.AddAzureEventHubProducerClient("eventhubns", settings => settings.EventHubName = eventHub.Resource.HubName); 92hb.AddAzureEventHubConsumerClient("eventhubns", settings => settings.EventHubName = eventHub.Resource.HubName); 130await app.ResourceNotifications.WaitForResourceHealthyAsync(eventHubns.Resource.Name, cts.Token); 136hb.Configuration["ConnectionStrings:eventhubns"] = await eventHubns.Resource.ConnectionStringExpression.GetValueAsync(CancellationToken.None); 137hb.AddAzureEventHubProducerClient("eventhubns", settings => settings.EventHubName = eventHub.Resource.HubName); 138hb.AddAzureEventHubConsumerClient("eventhubns", settings => settings.EventHubName = eventHub.Resource.HubName); 142hb.Configuration["ConnectionStrings:eventhubns"] = await eventHubns.Resource.ConnectionStringExpression.GetValueAsync(CancellationToken.None) + $";EntityPath={hubName};"; 168var volumeAnnotation = eventHubs.Resource.Annotations.OfType<ContainerMountAnnotation>().Single(a => !a.Target.Contains("Config.json")); 187var volumeAnnotation = eventHubs.Resource.Annotations.OfType<ContainerMountAnnotation>().Single(a => !a.Target.Contains("Config.json")); 206var volumeAnnotation = eventHubs.Resource.Annotations.OfType<ContainerMountAnnotation>().Single(a => !a.Target.Contains("Config.json")); 225var volumeAnnotation = eventHubs.Resource.Annotations.OfType<ContainerMountAnnotation>().Single(a => !a.Target.Contains("Config.json")); 244var endpoints = eventHubs.Resource.Annotations.OfType<EndpointAnnotation>().ToList(); 272var containerImageAnnotation = eventHubs.Resource.Annotations.OfType<ContainerImageAnnotation>().FirstOrDefault(); 292var (manifest, bicep) = await AzureManifestUtils.GetManifestWithBicep(model, eventHubs.Resource); 325var manifest = await AzureManifestUtils.GetManifestWithBicep(eventHubs.Resource); 517Assert.Same(eventHubs.Resource.Annotations, sourceResource.Annotations); 519var persistenceAnnotation = Assert.Single(eventHubs.Resource.Annotations.OfType<PersistenceAnnotation>()); 568Assert.Equal("{eh.outputs.eventHubsEndpoint}", eventHubs.Resource.ConnectionStringExpression.ValueExpression); 569Assert.Equal("Endpoint={eh.outputs.eventHubsEndpoint};EntityPath=hub1", eventHub.Resource.ConnectionStringExpression.ValueExpression); 570Assert.Equal("Endpoint={eh.outputs.eventHubsEndpoint};EntityPath=hub1;ConsumerGroup=cg1", consumerGroup.Resource.ConnectionStringExpression.ValueExpression); 583((IResourceWithAzureFunctionsConfig)eventHubs.Resource).ApplyAzureFunctionsConfiguration(target, "eh"); 593((IResourceWithAzureFunctionsConfig)eventHub.Resource).ApplyAzureFunctionsConfiguration(target, "hub1"); 609((IResourceWithAzureFunctionsConfig)consumerGroup.Resource).ApplyAzureFunctionsConfiguration(target, "cg1"); 639Assert.True(eventHubs.Resource.IsEmulator()); 640Assert.Contains(eventHubs.Resource.Annotations, a => a is EmulatorResourceAnnotation); 670_ = eventHubs.Resource.AddAsExistingResource(infra); 673var (manifest, bicep) = await AzureManifestUtils.GetManifestWithBicep(module.Resource, skipPreparer: true);

38var (_, bicep) = await GetManifestWithBicep(frontDoor.Resource); 61var (_, bicep) = await GetManifestWithBicep(environment.Resource); 83var (_, bicep) = await GetManifestWithBicep(frontDoor.Resource); 126var (_, bicep) = await GetManifestWithBicep(frontDoor.Resource); 156var (_, bicep) = await GetManifestWithBicep(GetContainerApp(web.Resource)); 185var (_, frontDoorBicep) = await GetManifestWithBicep(frontDoor.Resource); 186var (_, publicEnvironmentBicep) = await GetManifestWithBicep(publicEnvironment.Resource); 215var (_, firstBicep) = await GetManifestWithBicep(first.Resource); 216var (_, secondBicep) = await GetManifestWithBicep(second.Resource); 251var (_, bicep) = await GetManifestWithBicep(frontDoor.Resource); 362Assert.Single(frontDoor.Resource.Annotations.OfType<AzureFrontDoorPrivateLinkAnnotation>()); 363Assert.Single(environment.Resource.Annotations.OfType<PrivateEndpointTargetAnnotation>()); 377Assert.Empty(environment.Resource.Annotations.OfType<PrivateEndpointTargetAnnotation>()); 378Assert.Empty(frontDoor.Resource.Annotations.OfType<AzureFrontDoorPrivateLinkAnnotation>()); 402var connection = Assert.Single(frontDoor.Resource.Annotations.OfType<AzureFrontDoorPrivateLinkAnnotation>()); 453var (_, bicep) = await GetManifestWithBicep(frontDoor.Resource); 479var (_, bicep) = await GetManifestWithBicep(frontDoor.Resource); 486Assert.Single(target.Resource.Annotations.OfType<PrivateEndpointTargetAnnotation>()); 496var target = Assert.IsAssignableFrom<IAzureCdnPrivateLinkTarget>(environment.Resource);

23Assert.Equal("frontdoor", frontDoor.Resource.Name); 24Assert.IsType<AzureFrontDoorResource>(frontDoor.Resource); 38var annotations = frontDoor.Resource.Annotations.OfType<AzureFrontDoorOriginAnnotation>().ToList(); 56var annotations = frontDoor.Resource.Annotations.OfType<AzureFrontDoorOriginAnnotation>().ToList(); 78var (_, bicep) = await GetManifestWithBicep(frontDoor.Resource); 83var endpointUrl = frontDoor.Resource.GetEndpointUrl("my-api"); 109var (_, bicep) = await GetManifestWithBicep(frontDoor.Resource); 140var endpointUrl = frontDoor.Resource.GetEndpointUrl("api"); 155var endpointId = frontDoor.Resource.GetEndpointId(originResourceName); 196var (_, bicep) = await GetManifestWithBicep(frontDoor.Resource); 219var (_, bicep) = await GetManifestWithBicep(frontDoor.Resource); 244var (_, bicep) = await GetManifestWithBicep(frontDoor.Resource);

46Assert.True(funcApp.Resource.TryGetAnnotationsOfType<ResourceRelationshipAnnotation>(out var relAnnotations)); 177Assert.True(funcApp.Resource.TryGetAnnotationsOfType<ResourceRelationshipAnnotation>(out var relAnnotations)); 180Assert.Equal(storage.Resource, rel.Resource); 294Assert.True(funcApp.Resource.TryGetAnnotationsOfType<EnvironmentCallbackAnnotation>(out var envAnnotations)); 319Assert.True(funcApp.Resource.TryGetAnnotationsOfType<EnvironmentCallbackAnnotation>(out var envAnnotations)); 350Assert.True(funcApp.Resource.TryGetAnnotationsOfType<ResourceRelationshipAnnotation>(out var relAnnotations)); 375Assert.True(funcApp.Resource.TryGetAnnotationsOfType<ResourceRelationshipAnnotation>(out var relAnnotations)); 378Assert.Equal(storage.Resource, rel.Resource); 421Assert.Equal("npm", funcApp.Resource.Command); 423var args = await ArgumentEvaluator.GetArgumentListAsync(funcApp.Resource); 448Assert.Equal("func", funcApp.Resource.Command); 450var args = await ArgumentEvaluator.GetArgumentListAsync(funcApp.Resource); 483var manifest = await ManifestUtils.GetManifest(funcApp.Resource, tempDir.Path); 496var endpoint = Assert.Single(funcApp.Resource.Annotations.OfType<EndpointAnnotation>(), e => e.Name == "http"); 515var dockerBuildAnnotation = funcApp.Resource.Annotations.OfType<DockerfileBuildAnnotation>().Single(); 537await ManifestUtils.GetManifest(funcApp.Resource, tempDir.Path); 555var dockerBuildAnnotation = funcApp.Resource.Annotations.OfType<DockerfileBuildAnnotation>().Single(); 570var manifest = await ManifestUtils.GetManifest(funcApp.Resource, tempDir.Path); 576var dockerBuildAnnotation = funcApp.Resource.Annotations.OfType<DockerfileBuildAnnotation>().Single(); 596var (_, bicep) = await GetManifestWithBicep(funcApp.Resource.GetDeploymentTargetAnnotation()!.DeploymentTarget); 610var commands = funcApp.Resource.Annotations.OfType<RequiredCommandAnnotation>().Select(a => a.Command).ToArray(); 624var commands = funcApp.Resource.Annotations.OfType<RequiredCommandAnnotation>().Select(a => a.Command).ToArray(); 677var (_, bicep) = await GetManifestWithBicep(funcApp.Resource.GetDeploymentTargetAnnotation()!.DeploymentTarget); 986Assert.True(funcApp.Resource.TryGetLastAnnotation<IProjectMetadata>(out var projectMetadata)); 1006Assert.True(funcApp.Resource.TryGetLastAnnotation<IProjectMetadata>(out var projectMetadata)); 1090Assert.True(funcApp.Resource.TryGetAnnotationsOfType<ResourceRelationshipAnnotation>(out var relAnnotations)); 1093Assert.Equal(customStorage.Resource, rel.Resource); 1124var annotation = funcApp.Resource.Annotations.OfType<RequiredCommandAnnotation>().SingleOrDefault();

28await Verify(graph.Resource.GetBicepTemplateString(), "bicep"); 40await Verify(graph.Resource.GetBicepTemplateString(), "bicep"); 55var exception = Assert.Throws<ArgumentException>(graph.Resource.GetBicepTemplateString); 70var exception = Assert.Throws<ArgumentException>(graph.Resource.GetBicepTemplateString); 89var manifest = await ManifestUtils.GetManifest(infrastructure1.Resource); 114var manifest = await ManifestUtils.GetManifest(infrastructure1.Resource); 153var manifest = await ManifestUtils.GetManifest(infrastructure1.Resource);

17var properties = ((IResourceWithConnectionString)keyVault.Resource).GetConnectionProperties().ToArray();

21var (manifest, bicep) = await AzureManifestUtils.GetManifestWithBicep(mykv.Resource); 37var (manifest, bicep) = await AzureManifestUtils.GetManifestWithBicep(model, mykv.Resource); 57kv.Resource.SecretResolver = (s, ct) => 63var secretReference = kv.Resource.GetSecret("mySecret"); 72containerBuilder.Resource, 77containerBuilder.Resource, 98var secretReference = kv.Resource.GetSecret("mySecret"); 99var secretReference2 = kv.Resource.GetSecret("mySecret2"); 120var (manifest, bicep) = await AzureManifestUtils.GetManifestWithBicep(module.Resource, skipPreparer: true); 136var secretReference = kv.Resource.GetSecret("mySecret"); 137var secretReference2 = kv.Resource.GetSecret("mySecret2"); 158module2.Resource.Scope = new(existingRg.Resource); 160var (manifest, bicep) = await AzureManifestUtils.GetManifestWithBicep(module.Resource, skipPreparer: true); 161var (manifest2, bicep2) = await AzureManifestUtils.GetManifestWithBicep(module2.Resource, skipPreparer: true); 176var secretReference = kv.Resource.GetSecret("mySecret"); 177var secretReference2 = kv.Resource.GetSecret("mySecret2"); 189var (manifest, bicep) = await AzureManifestUtils.GetManifestWithBicep(module.Resource, skipPreparer: true); 206Assert.Same(kv.Resource, secret.Resource); 220Assert.IsType<AzureKeyVaultSecretResource>(secretResource.Resource); 221Assert.Equal("mySecret", secretResource.Resource.Name); 222Assert.Equal("mySecret", secretResource.Resource.SecretName); 223Assert.Same(kv.Resource, secretResource.Resource.Parent); 224Assert.Single(kv.Resource.Secrets); 225Assert.Same(secretResource.Resource, kv.Resource.Secrets[0]); 237var (manifest, bicep) = await AzureManifestUtils.GetManifestWithBicep(kv.Resource); 252var (manifest, bicep) = await AzureManifestUtils.GetManifestWithBicep(kv.Resource); 267Assert.True(secretResource.Resource.TryGetAnnotationsOfType<ManifestPublishingCallbackAnnotation>(out var manifestAnnotations)); 286var (manifest, bicep) = await AzureManifestUtils.GetManifestWithBicep(kv.Resource); 381_ = keyVault.Resource.AddAsExistingResource(infra); 384var (manifest, bicep) = await AzureManifestUtils.GetManifestWithBicep(module.Resource, skipPreparer: true); 397Assert.False(keyVault.Resource.IsEmulator); 408keyVault.Resource.Annotations.Add(new ContainerImageAnnotation 413Assert.True(keyVault.Resource.IsEmulator); 424keyVault.Resource.Annotations.Add(new ContainerImageAnnotation 432var connectionString = keyVault.Resource.ConnectionStringExpression; 434Assert.True(keyVault.Resource.IsEmulator); 445var connectionString = keyVault.Resource.ConnectionStringExpression; 447Assert.False(keyVault.Resource.IsEmulator); 463keyVault.Resource.Annotations.Add(new ConnectionStringRedirectAnnotation(redirectTarget)); 465var connectionString = keyVault.Resource.ConnectionStringExpression; 466var connectionStringValue = await keyVault.Resource.GetConnectionStringAsync(default); 484keyVault.Resource.Annotations.Add(new ContainerImageAnnotation 493keyVault.Resource.Annotations.Add(new ConnectionStringRedirectAnnotation(redirectTarget)); 495var connectionStringValue = await keyVault.Resource.GetConnectionStringAsync(default);

20kusto.Resource.Outputs["clusterUri"] = "https://kusto-cluster.eastus.kusto.windows.net"; 21Assert.Equal("https://kusto-cluster.eastus.kusto.windows.net", await kusto.Resource.ConnectionStringExpression.GetValueAsync(default)); 25var manifest = await GetManifestWithBicep(model, kusto.Resource); 27var connectionStringResource = (IResourceWithConnectionString)kusto.Resource; 64_ = kusto.Resource.AddAsExistingResource(infra); 67var (manifest, bicep) = await AzureManifestUtils.GetManifestWithBicep(module.Resource, skipPreparer: true); 91Assert.True(kusto.Resource.TryGetLastAnnotation<EmulatorResourceAnnotation>(out _)); 94var connectionStringExpr = kusto.Resource.ConnectionStringExpression; 98Assert.True(kusto.Resource.IsEmulator);

17Assert.Equal("logAnalyticsWorkspace", logAnalyticsWorkspace.Resource.Name); 18Assert.Equal("{logAnalyticsWorkspace.outputs.logAnalyticsWorkspaceId}", logAnalyticsWorkspace.Resource.Id.ValueExpression); 20var appInsightsManifest = await AzureManifestUtils.GetManifestWithBicep(logAnalyticsWorkspace.Resource); 59_ = logAnalyticsWorkspace.Resource.AddAsExistingResource(infra); 62var (manifest, bicep) = await AzureManifestUtils.GetManifestWithBicep(module.Resource, skipPreparer: true);

17var properties = ((IResourceWithConnectionString)redis.Resource).GetConnectionProperties().ToArray(); 44var properties = ((IResourceWithConnectionString)redis.Resource).GetConnectionProperties().ToArray(); 78var properties = ((IResourceWithConnectionString)redis.Resource).GetConnectionProperties().ToArray(); 92var properties = ((IResourceWithConnectionString)redis.Resource).GetConnectionProperties().ToArray();

38var (_, bicep) = await GetManifestWithBicep(model, redis.Resource); 55redisResource = c.Resource; 60Assert.True(redis.Resource.IsContainer(), "The resource should now be a container resource."); 65Assert.Equal($"localhost:12455,password={await redisResource.PasswordParameter.GetValueAsync(CancellationToken.None)}{sslArg}", await redis.Resource.ConnectionStringExpression.GetValueAsync(CancellationToken.None)); 78redisResource = c.Resource; 96Assert.True(redis.Resource.IsContainer(), "The resource should now be a container resource."); 99Assert.Equal($"localhost:12455,password=p@ssw0rd1", await redis.Resource.ConnectionStringExpression.GetValueAsync(CancellationToken.None)); 102Assert.NotNull(redis.Resource.HostName); 103Assert.Equal("localhost", await redis.Resource.HostName.GetValueAsync(CancellationToken.None)); 105Assert.NotNull(redis.Resource.Password); 106Assert.Equal("p@ssw0rd1", await redis.Resource.Password.GetValueAsync(CancellationToken.None)); 154Assert.NotNull(redis.Resource.HostName); 155Assert.NotNull(redis.Resource.Password); 158var hostValue = await redis.Resource.HostName.GetValueAsync(CancellationToken.None); 161var passwordValue = await redis.Resource.Password.GetValueAsync(CancellationToken.None); 174Assert.Null(redis.Resource.Password); 177Assert.NotNull(redis.Resource.HostName); 178Assert.Equal("{redis-data.outputs.hostName}", redis.Resource.HostName.ValueExpression); 216_ = redis.Resource.AddAsExistingResource(infra); 219var (manifest, bicep) = await GetManifestWithBicep(module.Resource, skipPreparer: true); 242var (_, bicep) = await GetManifestWithBicep(redis.Resource);

20Assert.Equal("mynat", natGw.Resource.Name); 21Assert.IsType<AzureNatGatewayResource>(natGw.Resource); 31Assert.DoesNotContain(natGw.Resource, builder.Resources); 70Assert.Same(natGw.Resource, subnet.Resource.NatGateway); 81Assert.Equal("mypip", pip.Resource.Name); 82Assert.IsType<AzurePublicIPAddressResource>(pip.Resource); 104Assert.Equal("ipAddress", pip.Resource.IpAddress.Name);