10public T Resource { get; } = resource;

730public T Resource => resource;

2647public 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); 596var unwrapped = valueProvider is IResourceBuilder<IResource> rb ? rb.Resource : valueProvider; 716builder.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), 1863VisitReferences(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)); 120if (builder.Resource is not IComputeResource) 123$"Resource '{builder.Resource.Name}' must implement {nameof(IComputeResource)} to use .NET SDK publishing."); 126_ = builder.Resource.GetProjectMetadata(); 127DotnetProgramPublishing.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.Annotations.Add(new InputGeneratorAnnotation(createInput)); 262builder.Resource.Annotations.Add(new InputGeneratorAnnotation(parameter => new InteractionInput 385var parameter = new ParameterResource(builder.Resource.Name, _ => "", secret: true);

123Resource = builder.Resource

506var projectMetadata = builder.Resource.GetProjectMetadata(); 510if (!builder.Resource.TryGetLastAnnotation<ProjectLaunchDefaultsAnnotation>(out var launchDefaults)) 521$"Project defaults have already been applied to resource '{builder.Resource.Name}'. " + 531builder.Resource, 534mode => ProjectLaunchConfigurationFactory.Create(builder.Resource, mode), 572if (!string.Equals(builder.Resource.Name, KnownResourceNames.AspireDashboard, StringComparisons.ResourceName)) 591var logger = resourceLogger.GetLogger(builder.Resource); 632var projectResource = builder.Resource; 989builder.Resource.Annotations.Add(new EndpointEnvironmentInjectionFilterAnnotation(filter)); 1021if (builder.ApplicationBuilder.TryCreateResourceBuilder<ProjectContainerResource>(builder.Resource.Name, out var existingBuilder)) 1035builder.ApplicationBuilder.Resources.Remove(builder.Resource); 1037var container = new ProjectContainerResource(builder.Resource); 1040cb.WithImage(builder.Resource.Name); 1042var projectFilePath = builder.Resource.GetProjectMetadata().ProjectPath; 1147foreach (var e in builder.Resource.GetEndpoints().Where(builder.Resource.ShouldInjectEndpointEnvironment)) 1198foreach (var e in builder.Resource.GetEndpoints().Where(builder.Resource.ShouldInjectEndpointEnvironment)) 1230foreach (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);

76if (builder.Resource.Annotations.OfType<TerminalAnnotation>().Any()) 79$"Resource '{builder.Resource.Name}' already has a terminal configured. Call WithTerminal() only once per resource."); 98var 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); 109return PublishAsExistingCore(builder, nameParameter.Resource, resourceGroupParameter?.Resource); 164return AsExistingCore(builder, nameParameter.Resource, resourceGroupParameter?.Resource); 203return RunAsExistingCore(builder, nameParameter.Resource, resourceGroup: null, subscription: subscriptionParameter.Resource); 260return PublishAsExistingCore(builder, nameParameter.Resource, resourceGroup: null, subscription: subscriptionParameter.Resource); 317return AsExistingCore(builder, nameParameter.Resource, resourceGroup: null, subscription: subscriptionParameter.Resource); 374return RunAsExistingCore(builder, nameParameter.Resource, resourceGroupParameter.Resource, subscriptionParameter.Resource); 434return PublishAsExistingCore(builder, nameParameter.Resource, resourceGroupParameter.Resource, subscriptionParameter.Resource); 494return AsExistingCore(builder, nameParameter.Resource, resourceGroupParameter.Resource, subscriptionParameter.Resource); 553return RunAsExistingCore(builder, nameParameter.Resource, resourceGroup: null, subscription: null, isTenantScope: true); 605return PublishAsExistingCore(builder, nameParameter.Resource, resourceGroup: null, subscription: null, isTenantScope: true); 657return 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)));

928builder.Resource.UseAzdNamingConvention = true; 959builder.Resource.UseCompactResourceNaming = true; 1014builder.Resource.UseUniqueResourceNaming = true; 1043builder.Resource.IsExpress = true; 1057builder.Resource.EnableDashboard = enable; 1078builder.Resource.PreserveHttpEndpoints = !upgrade; 1097builder.WithAnnotation(new AzureLogAnalyticsWorkspaceReferenceAnnotation(workspaceBuilder.Resource)); 1154builder.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}");

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)));

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

156.Resource; 266var launchProfile = builder.Resource.GetEffectiveLaunchProfile(); 310var targetEndpoint = builder.Resource.GetEndpoint(useHttps ? "https" : "http"); 328builder.Resource.HostStorage = storage.Resource; 348destination.WithReferenceRelationship(source.Resource); 352connectionName ??= source.Resource.Name; 353source.Resource.ApplyAzureFunctionsConfiguration(context.EnvironmentVariables, connectionName); 364if (source.Resource is not IResourceWithConnectionString || source.Resource is not IResourceWithAzureFunctionsConfig azureFunctionsConfig) 379destination.WithReferenceRelationship(source.Resource); 383connectionName ??= source.Resource.Name;

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);

77resource.KubernetesEnvironment = k8sEnvBuilder.Resource; 91resource.DefaultContainerRegistry = defaultRegistry.Resource; 92resource.Annotations.Add(new ContainerRegistryReferenceAnnotation(defaultRegistry.Resource)); 93k8sEnvBuilder.WithAnnotation(new ContainerRegistryReferenceAnnotation(defaultRegistry.Resource)); 98resource.Parameters["acrName"] = defaultRegistry.Resource.NameOutputReference; 177builder.Resource.NodePools.Add(config); 179var nodePool = new AksNodePoolResource(name, config, builder.Resource); 230builder.Resource.NodePools.RemoveAll(p => p.Mode is AksNodePoolMode.System); 231builder.Resource.NodePools.Insert(0, new AksNodePoolConfig("system", vmSize, minCount, maxCount, AksNodePoolMode.System)); 262builder.WithAnnotation(new AksSubnetAnnotation(subnet.Resource.Id), ResourceAnnotationMutationBehavior.Replace); 298builder.WithAnnotation(new AksSubnetAnnotation(subnet.Resource.Id)); 302builder.Resource.AksParent.NodePoolSubnets[builder.Resource.Name] = subnet.Resource.Id; 329if (builder.Resource.DefaultContainerRegistry is not null) 331builder.ApplicationBuilder.Resources.Remove(builder.Resource.DefaultContainerRegistry); 332builder.Resource.DefaultContainerRegistry = null; 338new ContainerRegistryReferenceAnnotation(registry.Resource), 344var staleAnnotations = builder.Resource.KubernetesEnvironment.Annotations 348builder.Resource.KubernetesEnvironment.Annotations.Remove(old); 351builder.Resource.KubernetesEnvironment.Annotations.Add( 352new ContainerRegistryReferenceAnnotation(registry.Resource)); 356builder.Resource.Parameters["acrName"] = registry.Resource.NameOutputReference; 426builder.Resource.GatewayApiEnabled = true; 427builder.Resource.ApplicationLoadBalancerEnabled = true; 443var existingDelegation = subnet.Resource.Annotations.OfType<AzureSubnetServiceDelegationAnnotation>().LastOrDefault(); 456builder.Resource, 457subnet.Resource.Id, 458subnet.Resource, 466builder.Resource.LoadBalancers.Add(lb); 503builder.Resource.OidcIssuerEnabled = enabled; 504builder.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);

30Assert.Equal("aks", aks.Resource.Name); 31Assert.Equal("{aks.outputs.id}", aks.Resource.Id.ValueExpression); 32Assert.Equal("{aks.outputs.clusterFqdn}", aks.Resource.ClusterFqdn.ValueExpression); 33Assert.Equal("{aks.outputs.oidcIssuerUrl}", aks.Resource.OidcIssuerUrl.ValueExpression); 35var manifest = await AzureManifestUtils.GetManifestWithBicep(aks.Resource); 52Assert.Equal(2, aks.Resource.NodePools.Count); 54Assert.Equal("gpu", gpuPool.Resource.Name); 55Assert.Equal("gpu", gpuPool.Resource.Config.Name); 56Assert.Equal("Standard_NC6s_v3", gpuPool.Resource.Config.VmSize); 57Assert.Equal(0, gpuPool.Resource.Config.MinCount); 58Assert.Equal(5, gpuPool.Resource.Config.MaxCount); 59Assert.Equal(AksNodePoolMode.User, gpuPool.Resource.Config.Mode); 60Assert.Same(aks.Resource, gpuPool.Resource.AksParent); 74Assert.Single(aks.Resource.NodePools); 75var defaultPool = aks.Resource.NodePools[0]; 94Assert.True(aks.Resource.OidcIssuerEnabled); 95Assert.True(aks.Resource.WorkloadIdentityEnabled); 96Assert.Null(aks.Resource.KubernetesVersion); 97Assert.False(aks.Resource.IsPrivateCluster); 98Assert.False(aks.Resource.ContainerInsightsEnabled); 99Assert.Null(aks.Resource.LogAnalyticsWorkspace); 113Assert.NotNull(aks.Resource.KubernetesEnvironment); 114Assert.Equal("aks", aks.Resource.KubernetesEnvironment.Name); 115Assert.True(aks.Resource.TryGetLastAnnotation<KubernetesEnvironmentAnnotation>(out var annotation)); 132Assert.Same(aks.Resource, computeEnvironment); 184Assert.True(aks.Resource.OidcIssuerEnabled); 185Assert.True(aks.Resource.WorkloadIdentityEnabled); 203Assert.True(project.Resource.TryGetLastAnnotation<AppIdentityAnnotation>(out var appIdentity)); 204Assert.Same(identity.Resource, appIdentity.IdentityResource); 216Assert.IsAssignableFrom<IAzureComputeEnvironmentResource>(aks.Resource); 228Assert.IsAssignableFrom<IAzureNspAssociationTarget>(aks.Resource); 266Assert.True(aks.Resource.TryGetLastAnnotation<AksSubnetAnnotation>(out _)); 269Assert.Single(aks.Resource.NodePoolSubnets); 270Assert.True(aks.Resource.NodePoolSubnets.ContainsKey("gpu")); 273Assert.True(gpuPool.Resource.TryGetLastAnnotation<AksSubnetAnnotation>(out _)); 292Assert.False(aks.Resource.TryGetLastAnnotation<AksSubnetAnnotation>(out _)); 295Assert.Single(aks.Resource.NodePoolSubnets); 296Assert.True(aks.Resource.NodePoolSubnets.ContainsKey("gpu")); 314Assert.True(container.Resource.TryGetLastAnnotation<KubernetesNodePoolAnnotation>(out var affinity)); 315Assert.Same(gpuPool.Resource, affinity.NodePool); 333Assert.Equal(3, aks.Resource.NodePools.Count); 334Assert.Equal("cpu", pool1.Resource.Name); 335Assert.Equal("gpu", pool2.Resource.Name); 346Assert.NotNull(aks.Resource.DefaultContainerRegistry); 347Assert.Equal("aks-acr", aks.Resource.DefaultContainerRegistry.Name); 362Assert.Null(aks.Resource.DefaultContainerRegistry); 365Assert.True(aks.Resource.TryGetLastAnnotation<ContainerRegistryReferenceAnnotation>(out var annotation)); 366Assert.Same(explicitAcr.Resource, annotation.Registry); 381Assert.True(aks.Resource.TryGetLastAnnotation<ContainerRegistryReferenceAnnotation>(out var aksAnnotation)); 382Assert.Same(aks.Resource.DefaultContainerRegistry, aksAnnotation.Registry); 384Assert.True(aks.Resource.KubernetesEnvironment 386Assert.Same(aks.Resource.DefaultContainerRegistry, annotation.Registry); 401Assert.Single(aks.Resource.NodePools, p => p.Mode is AksNodePoolMode.System); 402var systemPool = aks.Resource.NodePools.First(p => p.Mode is AksNodePoolMode.System); 421var systemPool = aks.Resource.NodePools.First(p => p.Mode is AksNodePoolMode.System); 439Assert.Equal("Standard_D2s_v5", aks.Resource.NodePools[0].VmSize); 445Assert.Single(aks.Resource.NodePools, p => p.Mode is AksNodePoolMode.System); 446Assert.Equal("Standard_B2s", aks.Resource.NodePools.First(p => p.Mode is AksNodePoolMode.System).VmSize); 462Assert.Single(aks.Resource.NodePools, p => p.Mode is AksNodePoolMode.System); 463var systemPool = aks.Resource.NodePools.First(p => p.Mode is AksNodePoolMode.System); 484Assert.Equal(2, aks.Resource.NodePools.Count); 485Assert.Equal("Standard_B2s", aks.Resource.NodePools.First(p => p.Mode is AksNodePoolMode.System).VmSize); 486Assert.Equal("gpu", gpuPool.Resource.Name); 514var manifest = await AzureManifestUtils.GetManifestWithBicep(aks.Resource); 534var manifest = await AzureManifestUtils.GetManifestWithBicep(aks.Resource); 550Assert.True(aks.Resource.GatewayApiEnabled); 551Assert.True(aks.Resource.ApplicationLoadBalancerEnabled); 552Assert.True(aks.Resource.RequiresPreviewIngressApi); 555Assert.True(albSubnet.Resource.TryGetLastAnnotation<AzureSubnetServiceDelegationAnnotation>(out var delegation)); 571Assert.Same(aks.Resource, lb.Resource.Parent); 572Assert.Equal("alb-lb", lb.Resource.AlbName); 573Assert.True(lb.Resource.TryGetAnnotationsOfType<PipelineStepAnnotation>(out var stepAnnotations)); 591Assert.NotSame(lb1.Resource, lb2.Resource); 592Assert.Equal("alb-lb1", lb1.Resource.AlbName); 593Assert.Equal("alb-lb2", lb2.Resource.AlbName); 596Assert.True(lb1.Resource.TryGetAnnotationsOfType<PipelineStepAnnotation>(out var lb1Steps)); 597Assert.True(lb2.Resource.TryGetAnnotationsOfType<PipelineStepAnnotation>(out var lb2Steps)); 603Assert.True(alb1.Resource.TryGetLastAnnotation<AzureSubnetServiceDelegationAnnotation>(out _)); 604Assert.True(alb2.Resource.TryGetLastAnnotation<AzureSubnetServiceDelegationAnnotation>(out _)); 624var delegation = Assert.Single(albSubnet.Resource.Annotations.OfType<AzureSubnetServiceDelegationAnnotation>()); 628Assert.Equal("Microsoft.Netapp/volumes", lb.Resource.DisplacedDelegationServiceName); 645var delegation = Assert.Single(albSubnet.Resource.Annotations.OfType<AzureSubnetServiceDelegationAnnotation>()); 649Assert.Null(lb1.Resource.DisplacedDelegationServiceName); 650Assert.Null(lb2.Resource.DisplacedDelegationServiceName); 666var delegation = Assert.Single(albSubnet.Resource.Annotations.OfType<AzureSubnetServiceDelegationAnnotation>()); 668Assert.Null(lb.Resource.DisplacedDelegationServiceName); 689var delegation = Assert.Single(albSubnet.Resource.Annotations.OfType<AzureSubnetServiceDelegationAnnotation>()); 693Assert.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); 46Assert.True(container.Resource.TryGetLastAnnotation<KubernetesNodePoolAnnotation>(out var affinity)); 65Assert.Equal(2, aks.Resource.NodePools.Count); // system + gpu 66Assert.DoesNotContain(aks.Resource.NodePools, p => p.Name == "workload"); 69Assert.True(container.Resource.TryGetLastAnnotation<KubernetesNodePoolAnnotation>(out var affinity)); 90Assert.True(container.Resource.TryGetLastAnnotation<KubernetesNodePoolAnnotation>(out var affinity)); 106Assert.True(container.Resource.TryGetLastAnnotation<DeploymentTargetAnnotation>(out var target)); 110Assert.Same(aks.Resource, target.ComputeEnvironment); 141Assert.Same(enva.Resource, enva.Resource.KubernetesEnvironment.OwningComputeEnvironment); 142Assert.Same(envb.Resource, envb.Resource.KubernetesEnvironment.OwningComputeEnvironment); 143Assert.True(enva.Resource.TryGetLastAnnotation<KubernetesEnvironmentAnnotation>(out var _)); 144Assert.True(envb.Resource.TryGetLastAnnotation<KubernetesEnvironmentAnnotation>(out var _)); 150Assert.True(cache.Resource.TryGetLastAnnotation<DeploymentTargetAnnotation>(out var cacheTarget), 152Assert.Same(enva.Resource, cacheTarget.ComputeEnvironment); 154Assert.True(api.Resource.TryGetLastAnnotation<DeploymentTargetAnnotation>(out var apiTarget), 156Assert.Same(enva.Resource, apiTarget.ComputeEnvironment); 159Assert.True(other.Resource.TryGetLastAnnotation<DeploymentTargetAnnotation>(out var otherTarget), 161Assert.Same(envb.Resource, otherTarget.ComputeEnvironment); 319aks.Resource.AzCliPathResolverForTesting = () => "/fake/az"; 320aks.Resource.AzCommandRunnerForTesting = (_, _, _) => Task.FromResult( 455aks.Resource.AzCliPathResolverForTesting = () => "/fake/az"; 456aks.Resource.AzCommandRunnerForTesting = (_, arguments, _) => 487Assert.Empty(aks.Resource.Outputs); 488Assert.NotNull(aks.Resource.KubernetesEnvironment.KubeConfigPath); 490["version --short", $"uninstall aks --namespace default --ignore-not-found --kubeconfig \"{aks.Resource.KubernetesEnvironment.KubeConfigPath}\""], 537aks.Resource.Scope = new AzureBicepResourceScope( 538aks.Resource.NameOutputReference, 539aks.Resource.Id); 540aks.Resource.AzCliPathResolverForTesting = () => "/fake/az"; 541aks.Resource.AzCommandRunnerForTesting = (_, arguments, _) => 570Assert.Empty(aks.Resource.Outputs); 571Assert.NotNull(aks.Resource.KubernetesEnvironment.KubeConfigPath); 573["version --short", $"uninstall aks --namespace default --ignore-not-found --kubeconfig \"{aks.Resource.KubernetesEnvironment.KubeConfigPath}\""], 601aks.Resource.AzCliPathResolverForTesting = () => 615Assert.Null(aks.Resource.KubernetesEnvironment.KubeConfigPath); 649aks.Resource.AzCliPathResolverForTesting = () => 666Assert.Null(aks.Resource.KubernetesEnvironment.KubeConfigPath); 701Assert.Null(aks.Resource.KubernetesEnvironment.KubeConfigPath); 738Assert.Null(aks.Resource.KubernetesEnvironment.KubeConfigPath); 772aks.Resource.AzCliPathResolverForTesting = () => 789Assert.Null(aks.Resource.KubernetesEnvironment.KubeConfigPath); 835aks.Resource.AzCliPathResolverForTesting = () => "/fake/az"; 836aks.Resource.AzCommandRunnerForTesting = (_, arguments, _) => 861Assert.Null(aks.Resource.KubernetesEnvironment.KubeConfigPath); 862Assert.True(aks.Resource.KubernetesEnvironment.SkipDestroyCleanup); 899aks.Resource.KubernetesEnvironment.Annotations.Add( 900new HelmReleaseNameAnnotation(ReferenceExpression.Create($"{releaseParameter.Resource}"))); 901aks.Resource.KubernetesEnvironment.Annotations.Add( 902new KubernetesNamespaceAnnotation(ReferenceExpression.Create($"{namespaceParameter.Resource}"))); 903aks.Resource.AzCliPathResolverForTesting = () => "/fake/az"; 904aks.Resource.AzCommandRunnerForTesting = (_, arguments, _) => 933Assert.Null(aks.Resource.KubernetesEnvironment.KubeConfigPath); 934Assert.True(aks.Resource.KubernetesEnvironment.SkipDestroyCleanup); 971aks.Resource.KubernetesEnvironment.Annotations.Add( 972new HelmReleaseNameAnnotation(ReferenceExpression.Create($"{aks.Resource.NameOutputReference}"))); 973aks.Resource.AzCliPathResolverForTesting = () => "/fake/az"; 974aks.Resource.AzCommandRunnerForTesting = (_, arguments, _) => 1003Assert.Null(aks.Resource.KubernetesEnvironment.KubeConfigPath); 1004Assert.True(aks.Resource.KubernetesEnvironment.SkipDestroyCleanup); 1036aks.Resource.KubernetesEnvironment.Annotations.Add( 1038aks.Resource.KubernetesEnvironment.Annotations.Add( 1040aks.Resource.AzCliPathResolverForTesting = () => "/fake/az"; 1041aks.Resource.AzCommandRunnerForTesting = (_, arguments, _) => 1063var kubeConfigPath = Assert.IsType<string>(aks.Resource.KubernetesEnvironment.KubeConfigPath); 1103Assert.Null(aks.Resource.KubernetesEnvironment.KubeConfigPath); 1346aks.Resource.Outputs["name"] = clusterName; 1349aks.Resource.AzCliPathResolverForTesting = () => "/usr/bin/az"; 1350aks.Resource.AzCommandRunnerForTesting = (path, arguments, logger) => 1374foreach (var annotation in aks.Resource.Annotations.OfType<PipelineStepAnnotation>()) 1379Resource = aks.Resource 1389Assert.NotNull(aks.Resource.ProvisioningTaskCompletionSource); 1390aks.Resource.ProvisioningTaskCompletionSource.TrySetResult(); 1419await File.ReadAllTextAsync(aks.Resource.KubernetesEnvironment.KubeConfigPath!, TestContext.Current.CancellationToken)); 1447aks.Resource.Outputs["name"] = clusterName; 1450aks.Resource.AzCliPathResolverForTesting = () => "/usr/bin/az"; 1451aks.Resource.AzCommandRunnerForTesting = (path, arguments, logger) => 1468foreach (var annotation in aks.Resource.Annotations.OfType<PipelineStepAnnotation>()) 1473Resource = aks.Resource 1479Assert.NotNull(aks.Resource.ProvisioningTaskCompletionSource); 1480aks.Resource.ProvisioningTaskCompletionSource.TrySetResult(); 1659aks.Resource.Scope = new AzureBicepResourceScope(scopeResourceGroup, scopeSubscriptionId); 1660aks.Resource.Outputs["name"] = clusterName; 1663aks.Resource.AzCliPathResolverForTesting = () => "/usr/bin/az"; 1664aks.Resource.AzCommandRunnerForTesting = (path, arguments, logger) => 1681foreach (var annotation in aks.Resource.Annotations.OfType<PipelineStepAnnotation>()) 1686Resource = aks.Resource 1692Assert.NotNull(aks.Resource.ProvisioningTaskCompletionSource); 1693aks.Resource.ProvisioningTaskCompletionSource.TrySetResult(); 1729aks.Resource.Scope = AzureBicepResourceScope.CreateForSubscription(subscriptionId); 1730aks.Resource.Outputs["name"] = clusterName; 1733aks.Resource.AzCliPathResolverForTesting = () => "/usr/bin/az"; 1734aks.Resource.AzCommandRunnerForTesting = (path, arguments, logger) => 1751foreach (var annotation in aks.Resource.Annotations.OfType<PipelineStepAnnotation>()) 1756Resource = aks.Resource 1762Assert.NotNull(aks.Resource.ProvisioningTaskCompletionSource); 1763aks.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));

185if (builder.Resource.IsHnsEnabled) 218var 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."); 221var 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."); 232foreach (var container in builder.Resource.BlobContainers) 238foreach (var queue in builder.Resource.Queues) 246var healthCheckKey = $"{builder.Resource.Name}_check"; 259var surrogate = new AzureStorageEmulatorResource(builder.Resource); 281return builder.WithBindMount(path ?? $".azurite/{builder.Resource.Name}", "/data", isReadOnly); 391if (string.Equals(name, builder.Resource.Name + "-blobs", StringComparisons.ResourceName)) 396builder.Resource.ImplicitBlobService ??= defaultService; 401builder.Resource.ImplicitBlobService ??= service; 418builder.Resource.IsHnsEnabled = true; 420if (string.Equals(name, builder.Resource.Name + "-data-lake", StringComparisons.ResourceName)) 425builder.Resource.ImplicitDataLakeService ??= defaultService; 430builder.Resource.ImplicitDataLakeService ??= service; 461var name = builder.Resource.Name + "-blobs"; 463return builder.Resource.BlobStorageBuilder ??= CreateBlobService(builder, name); 470var name = builder.Resource.Name + "-data-lake"; 472return builder.Resource.DataLakeStorageBuilder ??= CreateDataLakeService(builder, name); 492var parentBuilder = builder.Resource.ImplicitBlobService ??= GetBlobService(builder); 493AzureBlobStorageContainerResource resource = new(name, blobContainerName, parentBuilder.Resource); 494builder.Resource.BlobContainers.Add(resource); 531builder.Resource.IsHnsEnabled = true; 535var parentBuilder = builder.Resource.ImplicitDataLakeService ??= GetDataLakeService(builder); 536AzureDataLakeStorageFileSystemResource resource = new(name, dataLakeFileSystemName, parentBuilder.Resource); 537builder.Resource.DataLakeFileSystems.Add(resource); 559AzureBlobStorageContainerResource resource = new(name, blobContainerName, builder.Resource); 560builder.Resource.Parent.BlobContainers.Add(resource); 611if (string.Equals(name, builder.Resource.Name + "-queues", StringComparisons.ResourceName)) 616builder.Resource.ImplicitQueueService ??= defaultService; 621builder.Resource.ImplicitQueueService ??= service; 634var name = builder.Resource.Name + "-queues"; 636return builder.Resource.QueueStorageBuilder ??= CreateQueueService(builder, name); 656var parentBuilder = builder.Resource.ImplicitQueueService ??= builder.GetQueueService(); 657AzureQueueStorageQueueResource resource = new(name, queueName, parentBuilder.Resource); 658builder.Resource.Queues.Add(resource); 798var resource = new AzureBlobStorageResource(name, builder.Resource); 824var resource = new AzureDataLakeStorageResource(name, builder.Resource); 833var resource = new AzureTableStorageResource(name, builder.Resource); 840var 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"; 95var config = await EnvironmentVariableEvaluator.GetEnvironmentVariablesAsync(serviceA.Resource, DistributedApplicationOperation.Run, TestServiceProvider.Instance); 112var (manifest, bicep) = await AzureManifestUtils.GetManifestWithBicep(appInsights.Resource); 126var (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);

48Assert.Same(env.Resource, target.ComputeEnvironment); 71var target = project.Resource.GetDeploymentTargetAnnotation(); 73Assert.Same(environment.Resource, target.ComputeEnvironment); 119var target = project.Resource.GetDeploymentTargetAnnotation(); 123var (_, virtualNetworkBicep) = await GetManifestWithBicep(vnet.Resource); 159var target = project.Resource.GetDeploymentTargetAnnotation(); 163var (_, virtualNetworkBicep) = await GetManifestWithBicep(vnet.Resource); 201var target = project.Resource.GetDeploymentTargetAnnotation(); 243var target = project.Resource.GetDeploymentTargetAnnotation(); 377project2.Resource.TryGetLastAnnotation<DeploymentTargetAnnotation>(out var target); 421SetFoundryProjectOutputs(project.Resource); 423web.Resource.TryGetLastAnnotation<DeploymentTargetAnnotation>(out var target); 552Assert.NotNull(env.Resource.NameOutputReference); 553Assert.Equal("name", env.Resource.NameOutputReference.Name); 554Assert.Same(env.Resource, env.Resource.NameOutputReference.Resource); 644var (manifest, bicep) = await GetManifestWithBicep(env.Resource); 664var (manifest, bicep) = await GetManifestWithBicep(env.Resource); 695var (manifest, bicep) = await GetManifestWithBicep(env.Resource); 713var steps = await CreateStepsAsync(app, env.Resource); 725Assert.IsAssignableFrom<IAzureComputeEnvironmentResource>(env.Resource); 726Assert.IsAssignableFrom<IComputeEnvironmentResource>(env.Resource); 887project2.Resource.TryGetLastAnnotation<DeploymentTargetAnnotation>(out var target); 923project2.Resource.TryGetLastAnnotation<DeploymentTargetAnnotation>(out var target); 959project2.Resource.TryGetLastAnnotation<DeploymentTargetAnnotation>(out var target); 997project2.Resource.TryGetLastAnnotation<DeploymentTargetAnnotation>(out var target); 1032project2.Resource.TryGetLastAnnotation<DeploymentTargetAnnotation>(out var target); 1108project.Resource.TryGetLastAnnotation<DeploymentTargetAnnotation>(out var target); 1139container.Resource.TryGetLastAnnotation<DeploymentTargetAnnotation>(out var target); 1163var endpointReferenceEx = env.Resource.GetHostAddressExpression(project.GetEndpoint("http")); 1169Assert.Equal(env.Resource, output.Resource); 1187env.Resource.Outputs["webSiteSuffix"] = "website123"; 1188env.Resource.ProvisioningTaskCompletionSource?.TrySetResult(); 1195var expression = env.Resource.GetEndpointPropertyExpression(project.GetEndpoint("http").Property(property)); 1325project.Resource.TryGetLastAnnotation<DeploymentTargetAnnotation>(out var target); 1356project.Resource.TryGetLastAnnotation<DeploymentTargetAnnotation>(out var target); 1388project.Resource.TryGetLastAnnotation<DeploymentTargetAnnotation>(out var target); 1417featureFlag.Resource,

75if (resourceEvent.Resource == entries.Resource)

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);

49enabled.Resource, bool.TrueString, nested, ReferenceExpression.Create($"disabled")); 57var apiTarget = GetTarget(api.Resource); 58var webTarget = GetTarget(web.Resource); 64Assert.Same(environment.Resource, domain.Resource); 81var host = environment.Resource.GetHostAddressExpression(endpoint); 84Assert.Same(environment.Resource, output.Resource); 85Assert.Null(api.Resource.GetDeploymentTargetAnnotation()); 89var target = GetTarget(api.Resource); 91Assert.Same(target, GetTarget(api.Resource)); 92Assert.Single(api.Resource.Annotations.OfType<DeploymentTargetAnnotation>()); 94environment.Resource.Outputs[DomainOutputName] = "salmonisland-e9e6a567.westus3.azurecontainerapps.io"; 95environment.Resource.ProvisioningTaskCompletionSource?.TrySetResult(); 109var expression = environment.Resource.GetEndpointPropertyExpression(endpoint.Property(property)); 130var expression = environment.Resource.GetEndpointPropertyExpression(api.GetEndpoint("http").Property(property)); 133Assert.Null(api.Resource.GetDeploymentTargetAnnotation()); 152environment.Resource.GetEndpointPropertyExpression(api.GetEndpoint("http").Property(property))); 174enabled.Resource, bool.TrueString, 185var exception = Assert.Throws<InvalidOperationException>(GetTarget(web.Resource).GetBicepTemplateString); 218web.WithEnvironment("EARLY_HOST", producerEnvironment.Resource.GetHostAddressExpression(api.GetEndpoint("http"))); 223var webTarget = GetTarget(web.Resource); 229output => output.Name == DomainOutputName && output.Resource == producerEnvironment.Resource); 230Assert.Same(producerEnvironment.Resource, domain.Resource); 259var target = GetTarget(web.Resource); 262output => output.Name == DomainOutputName && output.Resource == standard.Resource); 263Assert.Same(standard.Resource, domain.Resource); 291var target = GetTarget(web.Resource); 313? environment.Resource.GetEndpointPropertyExpression(endpoint.Property(EndpointProperty.Url)) 319var target = GetTarget(api.Resource); 324Assert.Same(environment.Resource, domain.Resource); 341var firstTarget = GetTarget(first.Resource); 342var secondTarget = GetTarget(second.Resource); 364var target = GetTarget(api.Resource); 365environment.Resource.Outputs[DomainOutputName] = "salmonisland-e9e6a567.westus3.azurecontainerapps.io"; 366environment.Resource.Outputs["AZURE_CONTAINER_APPS_ENVIRONMENT_ID"] = 372foreach (var annotation in environment.Resource.Annotations.OfType<PipelineStepAnnotation>()) 377Resource = environment.Resource 381environment.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"); 189var target = Assert.IsType<AzureContainerAppResource>(project.Resource.GetDeploymentTargetAnnotation()!.DeploymentTarget); 229var target = Assert.IsType<AzureContainerAppResource>(project.Resource.GetDeploymentTargetAnnotation()!.DeploymentTarget); 266var target = Assert.IsType<AzureContainerAppResource>(container.Resource.GetDeploymentTargetAnnotation()!.DeploymentTarget); 286var target = Assert.IsType<AzureContainerAppResource>(container.Resource.GetDeploymentTargetAnnotation()!.DeploymentTarget);

111Assert.Same(env.Resource, target.ComputeEnvironment); 133var target = project.Resource.GetDeploymentTargetAnnotation(); 135Assert.Same(environment.Resource, target.ComputeEnvironment); 181SetFoundryProjectOutputs(project.Resource); 183var target = web.Resource.GetDeploymentTargetAnnotation(); 233Assert.Same(infra.Resource, target.ComputeEnvironment); 264Assert.Same(env.Resource, target?.ComputeEnvironment); 383.WithEnvironment("DATABASE_URL", pgContainer.Resource.UriExpression); 942var target = container.Resource.GetDeploymentTargetAnnotation()?.DeploymentTarget as AzureBicepResource; 1621var (manifest, bicep) = await GetManifestWithBicep(sql.Resource); 1738var managedEnvironment = (ContainerAppManagedEnvironment)env.Resource.AddAsExistingResource(infra); 1750var (manifest, bicep) = await GetManifestWithBicep(azResource.Resource); 1840Assert.IsAssignableFrom<IAzureComputeEnvironmentResource>(env.Resource); 1841Assert.IsAssignableFrom<IComputeEnvironmentResource>(env.Resource); 2749var dockerFileAnnotation = c.Resource.Annotations.OfType<DockerfileBuildAnnotation>().Single(); 2813var endpointReferenceEx = env.Resource.GetHostAddressExpression(project.GetEndpoint("http")); 2819Assert.Equal(env.Resource, output.Resource); 2837env.Resource.Outputs["AZURE_CONTAINER_APPS_ENVIRONMENT_DEFAULT_DOMAIN"] = "example.azurecontainerapps.io"; 2838env.Resource.ProvisioningTaskCompletionSource?.TrySetResult(); 2845var expression = env.Resource.GetEndpointPropertyExpression(project.GetEndpoint("http").Property(property)); 2930var containerRegistryInterface = env.Resource as IContainerRegistry; 3008var webappAcaTarget = webappAcaResource.GetDeploymentTargetAnnotation(aca.Resource); 3010Assert.Same(aca.Resource, webappAcaTarget.ComputeEnvironment); 3014var webappServiceTarget = webappServiceResource.GetDeploymentTargetAnnotation(appService.Resource); 3016Assert.Same(appService.Resource, webappServiceTarget.ComputeEnvironment); 3020var containerAcaTarget = containerAcaResource.GetDeploymentTargetAnnotation(aca.Resource); 3022Assert.Same(aca.Resource, containerAcaTarget.ComputeEnvironment); 3028var containerAppServiceAcaTarget = containerAppServiceResource.GetDeploymentTargetAnnotation(aca.Resource); 3032Assert.Null(webappAcaResource.GetDeploymentTargetAnnotation(appService.Resource)); 3033Assert.Null(webappServiceResource.GetDeploymentTargetAnnotation(aca.Resource)); 3034Assert.Null(containerAcaResource.GetDeploymentTargetAnnotation(appService.Resource)); 3112featureFlag.Resource, 3153featureFlag.Resource, 3155ReferenceExpression.Create($"prefix-{connectionPrefix.Resource}-enabled"), 3194innerFlag.Resource, 3200outerFlag.Resource, 3238var steps = await CreateStepsAsync(app, env.Resource);

53Assert.Same(registryBuilder.Resource, annotation!.Registry); 63var (manifest, bicep) = await GetManifestWithBicep(acr.Resource); 122_ = acr.Resource.AddAsExistingResource(infra); 125var (manifest, bicep) = await AzureManifestUtils.GetManifestWithBicep(module.Resource, skipPreparer: true); 141var pipelineStepAnnotations = acr.Resource.Annotations.OfType<PipelineStepAnnotation>().ToList(); 147Resource = acr.Resource 171var pipelineStepAnnotations = acr.Resource.Annotations.OfType<PipelineStepAnnotation>().ToList(); 176Resource = acr.Resource 200var pipelineStepAnnotations = acr.Resource.Annotations.OfType<PipelineStepAnnotation>().ToList(); 205Resource = acr.Resource 226var configAnnotations = acr.Resource.Annotations.OfType<PipelineConfigurationAnnotation>().ToList(); 238var (_, bicep) = await GetManifestWithBicep(acr.Resource); 252var (_, bicep) = await GetManifestWithBicep(acr.Resource); 265var (_, bicep) = await GetManifestWithBicep(acr.Resource); 327await Assert.ThrowsAsync<ArgumentException>(async () => await GetManifestWithBicep(acr.Resource)); 338var (_, bicep) = await GetManifestWithBicep(acr.Resource); 354Assert.Same(acr.Resource, registryBuilder.Resource); 366Assert.NotNull(registryBuilder.Resource); 367Assert.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>())

171var dockerFileAnnotation = c.Resource.Annotations.OfType<DockerfileBuildAnnotation>().Single(); 294Assert.Equal("testregistry", containerAppEnv.Resource.Outputs["AZURE_CONTAINER_REGISTRY_NAME"]); 295Assert.Equal("testregistry.azurecr.io", containerAppEnv.Resource.Outputs["AZURE_CONTAINER_REGISTRY_ENDPOINT"]); 296Assert.Equal(GetTestResourceId("/providers/Microsoft.ManagedIdentity/userAssignedIdentities/test-identity"), containerAppEnv.Resource.Outputs["AZURE_CONTAINER_REGISTRY_MANAGED_IDENTITY_ID"]); 297Assert.Equal("test.westus.azurecontainerapps.io", containerAppEnv.Resource.Outputs["AZURE_CONTAINER_APPS_ENVIRONMENT_DEFAULT_DOMAIN"]); 298Assert.Equal($"/subscriptions/{TestSubscriptionId}/resourceGroups/{TestResourceGroupName}/providers/Microsoft.App/managedEnvironments/testenv", containerAppEnv.Resource.Outputs["AZURE_CONTAINER_APPS_ENVIRONMENT_ID"]); 354Assert.Equal("testregistry", containerAppEnv.Resource.Outputs["AZURE_CONTAINER_REGISTRY_NAME"]); 355Assert.Equal("testregistry.azurecr.io", containerAppEnv.Resource.Outputs["AZURE_CONTAINER_REGISTRY_ENDPOINT"]); 356Assert.Equal(GetTestResourceId("/providers/Microsoft.ManagedIdentity/userAssignedIdentities/test-identity"), containerAppEnv.Resource.Outputs["AZURE_CONTAINER_REGISTRY_MANAGED_IDENTITY_ID"]); 357Assert.Equal("test.westus.azurecontainerapps.io", containerAppEnv.Resource.Outputs["AZURE_CONTAINER_APPS_ENVIRONMENT_DEFAULT_DOMAIN"]); 358Assert.Equal($"/subscriptions/{TestSubscriptionId}/resourceGroups/{TestResourceGroupName}/providers/Microsoft.App/managedEnvironments/testenv", containerAppEnv.Resource.Outputs["AZURE_CONTAINER_APPS_ENVIRONMENT_ID"]); 420Assert.Equal("testregistry", containerAppEnv.Resource.Outputs["AZURE_CONTAINER_REGISTRY_NAME"]); 421Assert.Equal("testregistry.azurecr.io", containerAppEnv.Resource.Outputs["AZURE_CONTAINER_REGISTRY_ENDPOINT"]); 422Assert.Equal(GetTestResourceId("/providers/Microsoft.ManagedIdentity/userAssignedIdentities/test-identity"), containerAppEnv.Resource.Outputs["AZURE_CONTAINER_REGISTRY_MANAGED_IDENTITY_ID"]); 423Assert.Equal("test.westus.azurecontainerapps.io", containerAppEnv.Resource.Outputs["AZURE_CONTAINER_APPS_ENVIRONMENT_DEFAULT_DOMAIN"]); 424Assert.Equal($"/subscriptions/{TestSubscriptionId}/resourceGroups/{TestResourceGroupName}/providers/Microsoft.App/managedEnvironments/testenv", containerAppEnv.Resource.Outputs["AZURE_CONTAINER_APPS_ENVIRONMENT_ID"]); 488var (containerAppSubscriptionId, containerAppResourceGroupName) = GetSubscriptionAndResourceGroup((string)containerAppEnv.Resource.Outputs["AZURE_CONTAINER_APPS_ENVIRONMENT_ID"]!); 524var envResource = Assert.IsAssignableFrom<AzureBicepResource>(environment.Resource); 525var apiTarget = Assert.IsAssignableFrom<AzureBicepResource>(api.Resource.GetDeploymentTargetAnnotation()!.DeploymentTarget); 526var webTarget = Assert.IsAssignableFrom<AzureBicepResource>(web.Resource.GetDeploymentTargetAnnotation()!.DeploymentTarget); 610var webSiteSuffix = Assert.IsType<string>(appServiceEnv.Resource.Outputs["webSiteSuffix"]); 612var (planSubscriptionId, planResourceGroupName) = GetSubscriptionAndResourceGroup((string)appServiceEnv.Resource.Outputs["planId"]!); 705Assert.Equal("acaregistry", acaEnv.Resource.Outputs["AZURE_CONTAINER_REGISTRY_NAME"]); 706Assert.Equal("acaregistry.azurecr.io", acaEnv.Resource.Outputs["AZURE_CONTAINER_REGISTRY_ENDPOINT"]); 707Assert.Equal(GetTestResourceId("/providers/Microsoft.ManagedIdentity/userAssignedIdentities/aca-identity"), acaEnv.Resource.Outputs["AZURE_CONTAINER_REGISTRY_MANAGED_IDENTITY_ID"]); 708Assert.Equal("aca.westus.azurecontainerapps.io", acaEnv.Resource.Outputs["AZURE_CONTAINER_APPS_ENVIRONMENT_DEFAULT_DOMAIN"]); 709Assert.Equal(GetTestResourceId("/providers/Microsoft.App/managedEnvironments/acaenv"), acaEnv.Resource.Outputs["AZURE_CONTAINER_APPS_ENVIRONMENT_ID"]); 712Assert.Equal("aasregistry", aasEnv.Resource.Outputs["AZURE_CONTAINER_REGISTRY_NAME"]); 713Assert.Equal("aasregistry.azurecr.io", aasEnv.Resource.Outputs["AZURE_CONTAINER_REGISTRY_ENDPOINT"]); 714Assert.Equal(GetTestResourceId("/providers/Microsoft.ManagedIdentity/userAssignedIdentities/aas-identity"), aasEnv.Resource.Outputs["AZURE_CONTAINER_REGISTRY_MANAGED_IDENTITY_ID"]); 715Assert.Equal(GetTestResourceId("/providers/Microsoft.Web/serverfarms/aasplan"), aasEnv.Resource.Outputs["planId"]); 716Assert.Equal("aas-client-id", aasEnv.Resource.Outputs["AZURE_CONTAINER_REGISTRY_MANAGED_IDENTITY_CLIENT_ID"]); 832var setValue = await param.Resource.GetValueAsync(default); 906var setValue = await param.Resource.GetValueAsync(default); 956Assert.Equal("testregistry", containerAppEnv.Resource.Outputs["AZURE_CONTAINER_REGISTRY_NAME"]); 957Assert.Equal("testregistry.azurecr.io", containerAppEnv.Resource.Outputs["AZURE_CONTAINER_REGISTRY_ENDPOINT"]); 958Assert.Equal(GetTestResourceId("/providers/Microsoft.ManagedIdentity/userAssignedIdentities/test-identity"), containerAppEnv.Resource.Outputs["AZURE_CONTAINER_REGISTRY_MANAGED_IDENTITY_ID"]); 959Assert.Equal("test.westus.azurecontainerapps.io", containerAppEnv.Resource.Outputs["AZURE_CONTAINER_APPS_ENVIRONMENT_DEFAULT_DOMAIN"]); 960Assert.Equal($"/subscriptions/{TestSubscriptionId}/resourceGroups/{TestResourceGroupName}/providers/Microsoft.App/managedEnvironments/testenv", containerAppEnv.Resource.Outputs["AZURE_CONTAINER_APPS_ENVIRONMENT_ID"]); 1018Assert.Equal("test.westus.azurecontainerapps.io", containerAppEnv.Resource.Outputs["AZURE_CONTAINER_APPS_ENVIRONMENT_DEFAULT_DOMAIN"]); 1019Assert.Equal(GetTestResourceId("/providers/Microsoft.App/managedEnvironments/testenv"), containerAppEnv.Resource.Outputs["AZURE_CONTAINER_APPS_ENVIRONMENT_ID"]); 1228Assert.Equal("testregistry", containerAppEnv.Resource.Outputs["AZURE_CONTAINER_REGISTRY_NAME"]); 1229Assert.Equal("testregistry.azurecr.io", containerAppEnv.Resource.Outputs["AZURE_CONTAINER_REGISTRY_ENDPOINT"]); 1230Assert.Equal(GetTestResourceId("/providers/Microsoft.ManagedIdentity/userAssignedIdentities/test-identity"), containerAppEnv.Resource.Outputs["AZURE_CONTAINER_REGISTRY_MANAGED_IDENTITY_ID"]); 1231Assert.Equal("test.westus.azurecontainerapps.io", containerAppEnv.Resource.Outputs["AZURE_CONTAINER_APPS_ENVIRONMENT_DEFAULT_DOMAIN"]); 1232Assert.Equal($"/subscriptions/{TestSubscriptionId}/resourceGroups/{TestResourceGroupName}/providers/Microsoft.App/managedEnvironments/testenv", containerAppEnv.Resource.Outputs["AZURE_CONTAINER_APPS_ENVIRONMENT_ID"]); 1235var funcAppDeployment = Assert.IsAssignableFrom<AzureProvisioningResource>(funcApp.Resource.GetDeploymentTargetAnnotation()?.DeploymentTarget); 1237Assert.Equal(await ((BicepOutputReference)funcAppDeployment.Parameters["env_outputs_azure_container_apps_environment_default_domain"]!).GetValueAsync(), containerAppEnv.Resource.Outputs["AZURE_CONTAINER_APPS_ENVIRONMENT_DEFAULT_DOMAIN"]); 1238Assert.Equal(await ((BicepOutputReference)funcAppDeployment.Parameters["env_outputs_azure_container_apps_environment_id"]!).GetValueAsync(), containerAppEnv.Resource.Outputs["AZURE_CONTAINER_APPS_ENVIRONMENT_ID"]); 1930Assert.Equal("secret-key-12345", await regularParam.Resource.GetValueAsync(default)); 1931Assert.Equal("Server=localhost;Database=mydb", await connectionStringParam.Resource.GetValueAsync(default)); 1932Assert.Equal("custom-value-xyz", await customKeyParam.Resource.GetValueAsync(default)); 1986Assert.Equal("secret-key-12345", await regularParam.Resource.GetValueAsync(default)); 1987Assert.Equal("Server=localhost;Database=mydb", await connectionStringParam.Resource.GetValueAsync(default)); 1988Assert.Equal("custom-value-xyz", await customKeyParam.Resource.GetValueAsync(default));

58Assert.Same(firstBuilder.Resource, secondBuilder.Resource); 325storage.Resource.Outputs["blobEndpoint"] = "https://storage.blob.core.windows.net/"; 336await notifications.PublishUpdateAsync(storage.Resource, state => state with 375Assert.Empty(storage.Resource.Outputs); 381Assert.True(notifications.TryGetCurrentState(storage.Resource.Name, out var storageEvent)); 493Assert.True(notifications.TryGetCurrentState(storage.Resource.Name, out var storageEvent)); 495Assert.Equal("https://storage.blob.core.windows.net/", storage.Resource.Outputs["blobEndpoint"]); 512storage.Resource.ProvisioningTaskCompletionSource = existingTcs; 522Assert.Same(existingTcs, storage.Resource.ProvisioningTaskCompletionSource); 556Assert.Empty(storage.Resource.Outputs); 566Assert.True(notifications.TryGetCurrentState(storage.Resource.Name, out var storageEvent)); 568Assert.Equal("https://storage.blob.core.windows.net/", storage.Resource.Outputs["blobEndpoint"]); 604Assert.Equal("https://storage.blob.core.windows.net/", storage.Resource.Outputs["blobEndpoint"]); 633Assert.Equal("https://storage.blob.core.windows.net/", storage.Resource.Outputs["blobEndpoint"]); 654Assert.Contains(storage.Resource.Annotations.OfType<ResourceCommandAnnotation>(), c => c.Name == AzureProvisioningController.ForgetStateCommandName); 655var changeLocationCommand = Assert.Single(storage.Resource.Annotations.OfType<ResourceCommandAnnotation>(), c => c.Name == AzureProvisioningController.ChangeResourceLocationCommandName); 672Assert.Contains(storage.Resource.Annotations.OfType<ResourceCommandAnnotation>(), c => c.Name == AzureProvisioningController.GetAzureResourceCommandName); 673var cancelCommand = Assert.Single(storage.Resource.Annotations.OfType<ResourceCommandAnnotation>(), c => c.Name == AzureProvisioningController.CancelCommandName); 674var deleteCommand = Assert.Single(storage.Resource.Annotations.OfType<ResourceCommandAnnotation>(), c => c.Name == AzureProvisioningController.DeleteAzureResourceCommandName); 675var reprovisionCommand = Assert.Single(storage.Resource.Annotations.OfType<ResourceCommandAnnotation>(), c => c.Name == AzureProvisioningController.ReprovisionResourceCommandName); 679Assert.DoesNotContain(blobs.Resource.Annotations.OfType<ResourceCommandAnnotation>(), c => 703await notifications.PublishUpdateAsync(keyVault.Resource, state => state with { State = KnownResourceStates.Running }); 705Assert.True(notifications.TryGetCurrentState(keyVault.Resource.Name, out var keyVaultEvent)); 738await notifications.PublishUpdateAsync(postgres.Resource, state => state with { State = KnownResourceStates.Running }); 740Assert.True(notifications.TryGetCurrentState(postgres.Resource.Name, out var postgresEvent)); 743var changeLocationCommand = Assert.Single(postgres.Resource.Annotations.OfType<ResourceCommandAnnotation>(), c => c.Name == AzureProvisioningController.ChangeResourceLocationCommandName); 748ResourceName = postgres.Resource.Name, 824var getResourceCommand = Assert.Single(storage.Resource.Annotations.OfType<ResourceCommandAnnotation>(), c => c.Name == AzureProvisioningController.GetAzureResourceCommandName); 829ResourceName = storage.Resource.Name, 908var getResourceCommand = Assert.Single(storage.Resource.Annotations.OfType<ResourceCommandAnnotation>(), c => c.Name == AzureProvisioningController.GetAzureResourceCommandName); 913ResourceName = storage.Resource.Name, 1177var getResourceCommand = Assert.Single(storage.Resource.Annotations.OfType<ResourceCommandAnnotation>(), c => c.Name == AzureProvisioningController.GetAzureResourceCommandName); 1182ResourceName = storage.Resource.Name, 1241var getResourceCommand = Assert.Single(storage.Resource.Annotations.OfType<ResourceCommandAnnotation>(), c => c.Name == AzureProvisioningController.GetAzureResourceCommandName); 1246ResourceName = storage.Resource.Name, 1302var getResourceCommand = Assert.Single(storage.Resource.Annotations.OfType<ResourceCommandAnnotation>(), c => c.Name == AzureProvisioningController.GetAzureResourceCommandName); 1307ResourceName = storage.Resource.Name, 1361await notifications.PublishUpdateAsync(storage.Resource, state => state with { State = new("Waiting for Deployment", KnownResourceStateStyles.Info) }); 1363var cancelCommand = Assert.Single(storage.Resource.Annotations.OfType<ResourceCommandAnnotation>(), c => c.Name == AzureProvisioningController.CancelCommandName); 1368ResourceName = storage.Resource.Name, 1382Assert.True(notifications.TryGetCurrentState(storage.Resource.Name, out var storageEvent)); 1416await notifications.PublishUpdateAsync(storage.Resource, state => state with { State = new("Creating ARM Deployment", KnownResourceStateStyles.Info) }); 1418Assert.True(notifications.TryGetCurrentState(storage.Resource.Name, out var storageEvent)); 1493await notifications.PublishUpdateAsync(storage.Resource, state => state with { State = new(AzureProvisioningController.WaitingForDeploymentState, KnownResourceStateStyles.Info) }); 1495Assert.True(notifications.TryGetCurrentState(storage.Resource.Name, out var storageEvent)); 1498var cancelCommand = Assert.Single(storage.Resource.Annotations.OfType<ResourceCommandAnnotation>(), c => c.Name == AzureProvisioningController.CancelCommandName); 1503ResourceName = storage.Resource.Name, 1543var activeReprovisionTask = controller.ReprovisionResourceAsync(model, storage.Resource.Name, CancellationToken.None); 1556var command = Assert.Single(storage.Resource.Annotations.OfType<ResourceCommandAnnotation>(), c => c.Name == commandName); 1561ResourceName = storage.Resource.Name, 1572Assert.Equal([storage.Resource.Name], testBicepProvisioner.ProvisionedResources); 1602var activeReprovisionTask = controller.ReprovisionResourceAsync(model, storage1.Resource.Name, CancellationToken.None); 1608var queuedReprovisionCommand = Assert.Single(storage2.Resource.Annotations.OfType<ResourceCommandAnnotation>(), c => c.Name == AzureProvisioningController.ReprovisionResourceCommandName); 1612ResourceName = storage2.Resource.Name, 1620var conflictingCommand = Assert.Single(storage2.Resource.Annotations.OfType<ResourceCommandAnnotation>(), c => c.Name == AzureProvisioningController.DeleteAzureResourceCommandName); 1624ResourceName = storage2.Resource.Name, 1663await notifications.PublishUpdateAsync(storage.Resource, state => state with { State = KnownResourceStates.Running }); 1665Assert.True(notifications.TryGetCurrentState(storage.Resource.Name, out var storageEvent)); 1701await notifications.PublishUpdateAsync(storage.Resource, state => state with { State = KnownResourceStates.Running }); 1703var cancelCommand = Assert.Single(storage.Resource.Annotations.OfType<ResourceCommandAnnotation>(), c => c.Name == AzureProvisioningController.CancelCommandName); 1708ResourceName = storage.Resource.Name, 1720Assert.True(notifications.TryGetCurrentState(storage.Resource.Name, out var storageEvent)); 1781storage.Resource.Outputs["blobEndpoint"] = "https://storage.blob.core.windows.net/"; 1782storage2.Resource.Outputs["blobEndpoint"] = "https://storage2.blob.core.windows.net/"; 1784await notifications.PublishUpdateAsync(storage.Resource, state => state with { State = new("Failed to Provision", KnownResourceStateStyles.Error) }); 1785await notifications.PublishUpdateAsync(storage2.Resource, state => state with { State = KnownResourceStates.Running }); 1787var deleteCommand = Assert.Single(storage.Resource.Annotations.OfType<ResourceCommandAnnotation>(), c => c.Name == AzureProvisioningController.DeleteAzureResourceCommandName); 1792ResourceName = storage.Resource.Name, 1820Assert.Empty(storage.Resource.Outputs); 1821Assert.Equal("https://storage2.blob.core.windows.net/", storage2.Resource.Outputs["blobEndpoint"]); 1823Assert.True(notifications.TryGetCurrentState(storage.Resource.Name, out var storageEvent)); 1826Assert.True(notifications.TryGetCurrentState(storage2.Resource.Name, out var storage2Event)); 1879await notifications.PublishUpdateAsync(keyVault.Resource, state => state with { State = new("Failed to Provision", KnownResourceStateStyles.Error) }); 1881var deleteCommand = Assert.Single(keyVault.Resource.Annotations.OfType<ResourceCommandAnnotation>(), c => c.Name == AzureProvisioningController.DeleteAzureResourceCommandName); 1886ResourceName = keyVault.Resource.Name, 1905Assert.True(notifications.TryGetCurrentState(keyVault.Resource.Name, out var keyVaultEvent)); 1949await notifications.PublishUpdateAsync(storage.Resource, state => state with { State = KnownResourceStates.Running }); 1950await notifications.PublishUpdateAsync(storage2.Resource, state => state with { State = KnownResourceStates.Running }); 1952var deleteCommand = Assert.Single(storage.Resource.Annotations.OfType<ResourceCommandAnnotation>(), c => c.Name == AzureProvisioningController.DeleteAzureResourceCommandName); 1957ResourceName = storage.Resource.Name, 1971Assert.True(notifications.TryGetCurrentState(storage.Resource.Name, out var storageEvent)); 1975Assert.True(notifications.TryGetCurrentState(storage2.Resource.Name, out var storage2Event)); 2027await notifications.PublishUpdateAsync(storage.Resource, state => state with { State = KnownResourceStates.Running }); 2029var deleteCommand = Assert.Single(storage.Resource.Annotations.OfType<ResourceCommandAnnotation>(), c => c.Name == AzureProvisioningController.DeleteAzureResourceCommandName); 2030var cancelCommand = Assert.Single(storage.Resource.Annotations.OfType<ResourceCommandAnnotation>(), c => c.Name == AzureProvisioningController.CancelCommandName); 2035ResourceName = storage.Resource.Name, 2049ResourceName = storage.Resource.Name, 2059Assert.True(notifications.TryGetCurrentState(storage.Resource.Name, out var storageEvent)); 2092storage.Resource.Outputs["blobEndpoint"] = "https://storage.blob.core.windows.net/"; 2093storage2.Resource.Outputs["blobEndpoint"] = "https://storage2.blob.core.windows.net/"; 2095await notifications.PublishUpdateAsync(storage.Resource, state => state with 2102await notifications.PublishUpdateAsync(storage2.Resource, state => state with 2109var forgetCommand = Assert.Single(storage.Resource.Annotations.OfType<ResourceCommandAnnotation>(), c => c.Name == AzureProvisioningController.ForgetStateCommandName); 2114ResourceName = storage.Resource.Name, 2129Assert.Empty(storage.Resource.Outputs); 2130Assert.Equal("https://storage2.blob.core.windows.net/", storage2.Resource.Outputs["blobEndpoint"]); 2132Assert.True(notifications.TryGetCurrentState(storage.Resource.Name, out var storageEvent)); 2137Assert.True(notifications.TryGetCurrentState(storage2.Resource.Name, out var storage2Event)); 2170await notifications.PublishUpdateAsync(storage.Resource, state => state with { State = KnownResourceStates.Running }); 2171await notifications.PublishUpdateAsync(storage2.Resource, state => state with { State = KnownResourceStates.Running }); 2173var reprovisionCommand = Assert.Single(storage.Resource.Annotations.OfType<ResourceCommandAnnotation>(), c => c.Name == AzureProvisioningController.ReprovisionResourceCommandName); 2178ResourceName = storage.Resource.Name, 2186Assert.Contains(storage.Resource.Outputs, output => output.Key == "blobEndpoint"); 2194Assert.True(notifications.TryGetCurrentState(storage.Resource.Name, out var storageEvent)); 2197Assert.True(notifications.TryGetCurrentState(storage2.Resource.Name, out var storage2Event)); 2224await notifications.PublishUpdateAsync(storage.Resource, state => state with { State = KnownResourceStates.Running }); 2225await notifications.PublishUpdateAsync(storage2.Resource, state => state with { State = KnownResourceStates.Running }); 2227var reprovisionCommand = Assert.Single(storage.Resource.Annotations.OfType<ResourceCommandAnnotation>(), c => c.Name == AzureProvisioningController.ReprovisionResourceCommandName); 2232ResourceName = storage.Resource.Name, 2246Assert.True(notifications.TryGetCurrentState(storage.Resource.Name, out var storageEvent)); 2249Assert.True(notifications.TryGetCurrentState(storage2.Resource.Name, out var storage2Event)); 2260Assert.True(notifications.TryGetCurrentState(storage.Resource.Name, out storageEvent)); 2285await notifications.PublishUpdateAsync(storage.Resource, state => state with { State = KnownResourceStates.Running }); 2287var reprovisionCommand = Assert.Single(storage.Resource.Annotations.OfType<ResourceCommandAnnotation>(), c => c.Name == AzureProvisioningController.ReprovisionResourceCommandName); 2292ResourceName = storage.Resource.Name, 2306Assert.True(notifications.TryGetCurrentState(storage.Resource.Name, out var storageEvent)); 2318Assert.True(notifications.TryGetCurrentState(storage.Resource.Name, out storageEvent)); 2363var reprovisionStorageCommand = Assert.Single(storage.Resource.Annotations.OfType<ResourceCommandAnnotation>(), c => c.Name == AzureProvisioningController.ReprovisionResourceCommandName); 2364var reprovisionStorage2Command = Assert.Single(storage2.Resource.Annotations.OfType<ResourceCommandAnnotation>(), c => c.Name == AzureProvisioningController.ReprovisionResourceCommandName); 2369ResourceName = storage.Resource.Name, 2383ResourceName = storage2.Resource.Name, 2440var reprovisionCommand = Assert.Single(storage.Resource.Annotations.OfType<ResourceCommandAnnotation>(), c => c.Name == AzureProvisioningController.ReprovisionResourceCommandName); 2441var cancelCommand = Assert.Single(storage.Resource.Annotations.OfType<ResourceCommandAnnotation>(), c => c.Name == AzureProvisioningController.CancelCommandName); 2446ResourceName = storage.Resource.Name, 2457Assert.True(notifications.TryGetCurrentState(storage.Resource.Name, out var storageEvent)); 2463ResourceName = storage.Resource.Name, 2474Assert.True(notifications.TryGetCurrentState(storage.Resource.Name, out storageEvent)); 2477Assert.True(notifications.TryGetCurrentState(blobs.Resource.Name, out var blobsEvent)); 2486Assert.True(notifications.TryGetCurrentState(storage.Resource.Name, out storageEvent)); 2535await WaitForResourceStateAsync(notifications, storage2.Resource.Name, "Running"); 2536Assert.True(notifications.TryGetCurrentState(storage2.Resource.Name, out var runningStorage2Event)); 2539var cancelCommand = Assert.Single(storage.Resource.Annotations.OfType<ResourceCommandAnnotation>(), c => c.Name == AzureProvisioningController.CancelCommandName); 2544ResourceName = storage.Resource.Name, 2552Assert.True(notifications.TryGetCurrentState(storage.Resource.Name, out var storageEvent)); 2556Assert.True(notifications.TryGetCurrentState(storage2.Resource.Name, out var storage2Event)); 2561Assert.True(notifications.TryGetCurrentState(storage2.Resource.Name, out storage2Event)); 2585var cancelCommand = Assert.Single(storage.Resource.Annotations.OfType<ResourceCommandAnnotation>(), c => c.Name == AzureProvisioningController.CancelCommandName); 2590ResourceName = storage.Resource.Name, 2637var reprovisionCommand = Assert.Single(storage.Resource.Annotations.OfType<ResourceCommandAnnotation>(), c => c.Name == AzureProvisioningController.ReprovisionResourceCommandName); 2638var cancelCommand = Assert.Single(storage2.Resource.Annotations.OfType<ResourceCommandAnnotation>(), c => c.Name == AzureProvisioningController.CancelCommandName); 2643ResourceName = storage.Resource.Name, 2657ResourceName = storage2.Resource.Name, 2702await notifications.PublishUpdateAsync(storage.Resource, state => state with { State = KnownResourceStates.Running }); 2703await notifications.PublishUpdateAsync(storage2.Resource, state => state with { State = KnownResourceStates.Running }); 2705var changeLocationCommand = Assert.Single(storage.Resource.Annotations.OfType<ResourceCommandAnnotation>(), c => c.Name == AzureProvisioningController.ChangeResourceLocationCommandName); 2710ResourceName = storage.Resource.Name, 2726Assert.True(notifications.TryGetCurrentState(storage.Resource.Name, out var storageEvent)); 2735Assert.True(notifications.TryGetCurrentState(storage2.Resource.Name, out var storage2Event)); 2775await notifications.PublishUpdateAsync(storage.Resource, state => state with { State = new("Failed to Provision", KnownResourceStateStyles.Error) }); 2776await notifications.PublishUpdateAsync(storage2.Resource, state => state with { State = KnownResourceStates.Running }); 2778var changeLocationCommand = Assert.Single(storage.Resource.Annotations.OfType<ResourceCommandAnnotation>(), c => c.Name == AzureProvisioningController.ChangeResourceLocationCommandName); 2783ResourceName = storage.Resource.Name, 2829await notifications.PublishUpdateAsync(storage.Resource, state => state with { State = KnownResourceStates.Running }); 2831var changeLocationCommand = Assert.Single(storage.Resource.Annotations.OfType<ResourceCommandAnnotation>(), c => c.Name == AzureProvisioningController.ChangeResourceLocationCommandName); 2836ResourceName = storage.Resource.Name, 2944await notifications.PublishUpdateAsync(storage.Resource, state => state with { State = KnownResourceStates.Running }); 2946var changeLocationCommand = Assert.Single(storage.Resource.Annotations.OfType<ResourceCommandAnnotation>(), c => c.Name == AzureProvisioningController.ChangeResourceLocationCommandName); 2957ResourceName = storage.Resource.Name, 3017await notifications.PublishUpdateAsync(storage.Resource, state => state with 3023var changeLocationCommand = Assert.Single(storage.Resource.Annotations.OfType<ResourceCommandAnnotation>(), c => c.Name == AzureProvisioningController.ChangeResourceLocationCommandName); 3027ResourceName = storage.Resource.Name, 3036Assert.True(notifications.TryGetCurrentState(storage.Resource.Name, out var storageEvent)); 3077await notifications.PublishUpdateAsync(storage.Resource, state => state with 3083var changeLocationCommand = Assert.Single(storage.Resource.Annotations.OfType<ResourceCommandAnnotation>(), c => c.Name == AzureProvisioningController.ChangeResourceLocationCommandName); 3088ResourceName = 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, 3203await notifications.PublishUpdateAsync(storage.Resource, state => state with 3209var changeLocationCommand = Assert.Single(storage.Resource.Annotations.OfType<ResourceCommandAnnotation>(), c => c.Name == AzureProvisioningController.ChangeResourceLocationCommandName); 3214ResourceName = storage.Resource.Name, 3266await notifications.PublishUpdateAsync(storage.Resource, state => state with 3272var changeLocationCommand = Assert.Single(storage.Resource.Annotations.OfType<ResourceCommandAnnotation>(), c => c.Name == AzureProvisioningController.ChangeResourceLocationCommandName); 3277ResourceName = 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, 3395await notifications.PublishUpdateAsync(storage.Resource, state => state with { State = KnownResourceStates.Running }); 3396await notifications.PublishUpdateAsync(storage2.Resource, state => state with { State = KnownResourceStates.Running }); 3610await notifications.PublishUpdateAsync(storage.Resource, state => state with 3840await notifications.PublishUpdateAsync(storage.Resource, state => state with { State = KnownResourceStates.Running }); 3842var reprovisionCommand = Assert.Single(storage.Resource.Annotations.OfType<ResourceCommandAnnotation>(), c => c.Name == AzureProvisioningController.ReprovisionResourceCommandName); 3847ResourceName = storage.Resource.Name, 3912await notifications.PublishUpdateAsync(keyVault.Resource, state => state with { State = new("Canceled", KnownResourceStateStyles.Info) }); 3914var reprovisionCommand = Assert.Single(keyVault.Resource.Annotations.OfType<ResourceCommandAnnotation>(), c => c.Name == AzureProvisioningController.ReprovisionResourceCommandName); 3919ResourceName = keyVault.Resource.Name, 3932Assert.True(notifications.TryGetCurrentState(keyVault.Resource.Name, out var keyVaultEvent)); 3992await notifications.PublishUpdateAsync(keyVault.Resource, state => state with { State = new("Canceled", KnownResourceStateStyles.Info) }); 3994var reprovisionCommand = Assert.Single(keyVault.Resource.Annotations.OfType<ResourceCommandAnnotation>(), c => c.Name == AzureProvisioningController.ReprovisionResourceCommandName); 3999ResourceName = keyVault.Resource.Name, 4036Assert.True(notifications.TryGetCurrentState(keyVault.Resource.Name, out var keyVaultEvent)); 4066await notifications.PublishUpdateAsync(postgres.Resource, state => state with { State = KnownResourceStates.Running }); 4068var reprovisionCommand = Assert.Single(postgres.Resource.Annotations.OfType<ResourceCommandAnnotation>(), c => c.Name == AzureProvisioningController.ReprovisionResourceCommandName); 4073ResourceName = postgres.Resource.Name, 4118await notifications.PublishUpdateAsync(storage.Resource, state => state with { State = KnownResourceStates.Running }); 4120var changeLocationCommand = Assert.Single(storage.Resource.Annotations.OfType<ResourceCommandAnnotation>(), c => c.Name == AzureProvisioningController.ChangeResourceLocationCommandName); 4125ResourceName = storage.Resource.Name, 4164await notifications.PublishUpdateAsync(keyVault.Resource, state => state with { State = KnownResourceStates.Running }); 4166var changeLocationCommand = Assert.Single(keyVault.Resource.Annotations.OfType<ResourceCommandAnnotation>(), c => c.Name == AzureProvisioningController.ChangeResourceLocationCommandName); 4171ResourceName = keyVault.Resource.Name, 4210await notifications.PublishUpdateAsync(storage.Resource, state => state with { State = KnownResourceStates.Running }); 4212var reprovisionCommand = Assert.Single(storage.Resource.Annotations.OfType<ResourceCommandAnnotation>(), c => c.Name == AzureProvisioningController.ReprovisionResourceCommandName); 4217ResourceName = storage.Resource.Name, 4243Assert.True(notifications.TryGetCurrentState(storage.Resource.Name, out var storageEvent)); 4278var reprovisionCommand = Assert.Single(storage.Resource.Annotations.OfType<ResourceCommandAnnotation>(), c => c.Name == AzureProvisioningController.ReprovisionResourceCommandName); 4285ResourceName = storage.Resource.Name, 4325await notifications.PublishUpdateAsync(storage.Resource, state => state with { State = KnownResourceStates.Running }); 4338Assert.True(notifications.TryGetCurrentState(storage.Resource.Name, out var resourceEvent)); 4378await notifications.PublishUpdateAsync(storage.Resource, state => state with { State = KnownResourceStates.Running }); 4385Assert.True(notifications.TryGetCurrentState(storage.Resource.Name, out var resourceEvent)); 4436await notifications.PublishUpdateAsync(storage.Resource, state => state with { State = KnownResourceStates.Running }); 4437await notifications.PublishUpdateAsync(storage2.Resource, state => state with { State = KnownResourceStates.Running }); 4444Assert.True(notifications.TryGetCurrentState(storage.Resource.Name, out var storageEvent)); 4447Assert.True(notifications.TryGetCurrentState(storage2.Resource.Name, out var storage2Event)); 4480await notifications.PublishUpdateAsync(storage.Resource, state => state with { State = KnownResourceStates.Running }); 4487Assert.True(notifications.TryGetCurrentState(storage.Resource.Name, out var resourceEvent)); 4544Assert.Empty(storage.Resource.Outputs); 4589Assert.Empty(storage.Resource.Outputs); 4635Assert.Empty(storage.Resource.Outputs); 4805var cancelCommand = Assert.Single(storage.Resource.Annotations.OfType<ResourceCommandAnnotation>(), c => c.Name == AzureProvisioningController.CancelCommandName); 4809ResourceName = storage.Resource.Name, 4819Assert.True(notifications.TryGetCurrentState(storage.Resource.Name, out var storageEvent)); 4825Assert.True(notifications.TryGetCurrentState(storage.Resource.Name, out storageEvent)); 4855Assert.Equal([storage.Resource.Name, storage2.Resource.Name], Assert.IsType<string[]>(failedResourcesProperty.Value)); 4894var icon = Assert.Single(resourceBuilder.Resource.Annotations.OfType<ResourceIconAnnotation>()); 4940Assert.Equal(expectedLocation.Resource, resource.Location); 4956Assert.Equal(expectedResourceGroup.Resource, resource.ResourceGroupName);

114.WithParameter("pgdb", pgdb.Resource.ConnectionStringExpression); 162["kvUri"] = kv.Resource.VaultUri, 163["blob"] = blobs.Resource.ConnectionStringExpression, 194roles.Resource.Parameters[AzureBicepResource.KnownParameters.PrincipalId] = null; 195roles.Resource.Parameters[AzureBicepResource.KnownParameters.PrincipalType] = null; 220resourceGroupScoped.Resource.Scope = new(resourceGroup.Resource, subscription.Resource); 230subscriptionScoped.Resource.Scope = AzureBicepResourceScope.CreateForSubscription(subscription.Resource); 240tenantScoped.Resource.Scope = AzureBicepResourceScope.CreateForTenant(); 325module.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);

22Assert.Equal("frontdoor", frontDoor.Resource.Name); 23Assert.IsType<AzureFrontDoorResource>(frontDoor.Resource); 37var annotations = frontDoor.Resource.Annotations.OfType<AzureFrontDoorOriginAnnotation>().ToList(); 55var annotations = frontDoor.Resource.Annotations.OfType<AzureFrontDoorOriginAnnotation>().ToList(); 77var (_, bicep) = await GetManifestWithBicep(frontDoor.Resource); 82var endpointUrl = frontDoor.Resource.GetEndpointUrl("my-api"); 108var (_, bicep) = await GetManifestWithBicep(frontDoor.Resource); 139var endpointUrl = frontDoor.Resource.GetEndpointUrl("api"); 180var (_, bicep) = await GetManifestWithBicep(frontDoor.Resource); 203var (_, bicep) = await GetManifestWithBicep(frontDoor.Resource); 228var (_, bicep) = await GetManifestWithBicep(frontDoor.Resource);

45Assert.True(funcApp.Resource.TryGetAnnotationsOfType<ResourceRelationshipAnnotation>(out var relAnnotations)); 176Assert.True(funcApp.Resource.TryGetAnnotationsOfType<ResourceRelationshipAnnotation>(out var relAnnotations)); 179Assert.Equal(storage.Resource, rel.Resource); 293Assert.True(funcApp.Resource.TryGetAnnotationsOfType<EnvironmentCallbackAnnotation>(out var envAnnotations)); 354var (_, bicep) = await GetManifestWithBicep(funcApp.Resource.GetDeploymentTargetAnnotation()!.DeploymentTarget); 663Assert.True(funcApp.Resource.TryGetLastAnnotation<IProjectMetadata>(out var projectMetadata)); 683Assert.True(funcApp.Resource.TryGetLastAnnotation<IProjectMetadata>(out var projectMetadata)); 767Assert.True(funcApp.Resource.TryGetAnnotationsOfType<ResourceRelationshipAnnotation>(out var relAnnotations)); 770Assert.Equal(customStorage.Resource, rel.Resource); 801var annotation = funcApp.Resource.Annotations.OfType<RequiredCommandAnnotation>().SingleOrDefault();

27var manifest = await ManifestUtils.GetManifest(infrastructure1.Resource); 52var manifest = await ManifestUtils.GetManifest(infrastructure1.Resource); 91var 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);

23Assert.Equal("web-nsg", nsg.Resource.Name); 24Assert.IsType<AzureNetworkSecurityGroupResource>(nsg.Resource); 34Assert.DoesNotContain(nsg.Resource, builder.Resources); 47var manifest = await AzureManifestUtils.GetManifestWithBicep(vnet.Resource); 110var manifest = await AzureManifestUtils.GetManifestWithBicep(nsg.Resource); 179Assert.Same(nsg.Resource, subnet.Resource.NetworkSecurityGroup); 293var manifest = await AzureManifestUtils.GetManifestWithBicep(nsg.Resource); 314SourceAddressPrefixReference = ReferenceExpression.Create($"{pip.Resource.IpAddress}") 336DestinationAddressPrefixReference = ReferenceExpression.Create($"{pip.Resource.IpAddress}")

23Assert.Equal("my-nsp", nsp.Resource.Name); 24Assert.IsType<AzureNetworkSecurityPerimeterResource>(nsp.Resource); 34Assert.DoesNotContain(nsp.Resource, builder.Resources); 44var manifest = await AzureManifestUtils.GetManifestWithBicep(nsp.Resource); 68var manifest = await AzureManifestUtils.GetManifestWithBicep(nsp.Resource); 86var manifest = await AzureManifestUtils.GetManifestWithBicep(nsp.Resource); 123var manifest = await AzureManifestUtils.GetManifestWithBicep(nsp.Resource); 138var manifest = await AzureManifestUtils.GetManifestWithBicep(nsp.Resource); 162var manifest = await AzureManifestUtils.GetManifestWithBicep(nsp.Resource);

62var manifest = await GetManifestWithBicep(model, openai.Resource); 262_ = openAI.Resource.AddAsExistingResource(infra); 265var (manifest, bicep) = await AzureManifestUtils.GetManifestWithBicep(module.Resource, skipPreparer: true);

41var (manifest, bicep) = await AzureManifestUtils.GetManifestWithBicep(postgres.Resource, skipPreparer: true); 98var (manifest, bicep) = await AzureManifestUtils.GetManifestWithBicep(postgres.Resource); 133Assert.True(postgres.Resource.IsContainer(), "The resource should now be a container resource."); 134Assert.StartsWith("Host=localhost;Port=12455;Username=postgres;Password=", await postgres.Resource.ConnectionStringExpression.GetValueAsync(CancellationToken.None)); 136var db1ConnectionString = await db1.Resource.ConnectionStringExpression.GetValueAsync(CancellationToken.None); 140var db2ConnectionString = await db2.Resource.ConnectionStringExpression.GetValueAsync(CancellationToken.None); 182var endpoint = Assert.Single(innerPostgres.Resource.Annotations.OfType<EndpointAnnotation>()); 191Assert.True(postgres.Resource.IsContainer(), "The resource should now be a container resource."); 192Assert.Equal("Host=localhost;Port=12455;Username=user1;Password=p@ssw0rd1", await postgres.Resource.ConnectionStringExpression.GetValueAsync(CancellationToken.None)); 195Assert.NotNull(postgres.Resource.Host); 196Assert.Equal("localhost", await postgres.Resource.Host.GetValueAsync(CancellationToken.None)); 198Assert.NotNull(postgres.Resource.Port); 199Assert.Equal("12455", await postgres.Resource.Port.GetValueAsync(CancellationToken.None)); 201Assert.NotNull(postgres.Resource.HostName); 202Assert.Equal("localhost:12455", await postgres.Resource.HostName.GetValueAsync(CancellationToken.None)); 204Assert.NotNull(postgres.Resource.UserName); 205Assert.Equal("user1", await postgres.Resource.UserName.GetValueAsync(CancellationToken.None)); 207Assert.NotNull(postgres.Resource.Password); 208Assert.Equal("p@ssw0rd1", await postgres.Resource.Password.GetValueAsync(CancellationToken.None)); 210var db1ConnectionString = await db1.Resource.ConnectionStringExpression.GetValueAsync(CancellationToken.None); 213var db2ConnectionString = await db2.Resource.ConnectionStringExpression.GetValueAsync(CancellationToken.None); 247Assert.Equal("Host=localhost;Port=12455;Username=user;Password=p@ssw0rd1", await postgres.Resource.ConnectionStringExpression.GetValueAsync(CancellationToken.None)); 248Assert.Equal("Host=localhost;Port=12455;Username=user;Password=p@ssw0rd1;Database=db1", await db1.Resource.ConnectionStringExpression.GetValueAsync(CancellationToken.None)); 249Assert.Equal("Host=localhost;Port=12455;Username=user;Password=p@ssw0rd1;Database=db2Name", await db2.Resource.ConnectionStringExpression.GetValueAsync(CancellationToken.None)); 324Assert.NotNull(postgres.Resource.UserName); 325Assert.NotNull(postgres.Resource.Password); 326Assert.NotNull(postgres.Resource.HostName); 329var hostValue = await postgres.Resource.HostName.GetValueAsync(CancellationToken.None); 332var userValue = await postgres.Resource.UserName.GetValueAsync(CancellationToken.None); 336var passwordValue = await postgres.Resource.Password.GetValueAsync(CancellationToken.None); 350Assert.Null(postgres.Resource.UserName); 351Assert.Null(postgres.Resource.Password); 354Assert.NotNull(postgres.Resource.HostName); 355Assert.Equal("{postgres-data.outputs.hostName}", postgres.Resource.HostName.ValueExpression); 442Assert.True(postgres.Resource.TryGetLastAnnotation<ConnectionStringRedirectAnnotation>(out var connectionStringAnnotation)); 446var manifest = await AzureManifestUtils.GetManifestWithBicep(postgres.Resource); 451Assert.Equal("myconnectionstring", await postgres.Resource.GetConnectionStringAsync(default)); 485Assert.True(postgres.Resource.TryGetLastAnnotation<ConnectionStringRedirectAnnotation>(out var connectionStringAnnotation)); 489var manifest = await AzureManifestUtils.GetManifestWithBicep(postgres.Resource); 494Assert.Equal("myconnectionstring", await postgres.Resource.GetConnectionStringAsync(default)); 529var manifest = await AzureManifestUtils.GetManifestWithBicep(postgres.Resource); 535Assert.Equal(expectedConnectionString, await postgres.Resource.GetConnectionStringAsync()); 561var manifest = await ManifestUtils.GetManifest(postgres.Resource); 581manifest = await ManifestUtils.GetManifest(postgres.Resource); 600manifest = await ManifestUtils.GetManifest(postgres.Resource); 643_ = postgres.Resource.AddAsExistingResource(infra); 646var (manifest, bicep) = await AzureManifestUtils.GetManifestWithBicep(module.Resource, skipPreparer: true); 674Assert.NotNull(postgres.Resource.ConnectionStringSecretOutput); 675Assert.Same(postgres.Resource, postgres.Resource.ConnectionStringSecretOutput.SecretOwner); 678var references = ((IValueWithReferences)postgres.Resource.ConnectionStringSecretOutput).References.ToList(); 679Assert.Contains(postgres.Resource, references); 680Assert.Contains(postgres.Resource.ConnectionStringSecretOutput.Resource, references);

25Assert.Equal("pesubnet-blobs-pe", pe.Resource.Name); 26Assert.IsType<AzurePrivateEndpointResource>(pe.Resource); 27Assert.Same(subnet.Resource, pe.Resource.Subnet); 28Assert.Same(blobs.Resource, pe.Resource.Target); 42Assert.Empty(storage.Resource.Annotations.OfType<PrivateEndpointTargetAnnotation>()); 47var annotation = storage.Resource.Annotations.OfType<PrivateEndpointTargetAnnotation>().SingleOrDefault(); 63var annotation = storage.Resource.Annotations.OfType<PrivateEndpointTargetAnnotation>().SingleOrDefault(); 79var manifest = await AzureManifestUtils.GetManifestWithBicep(pe.Resource); 96var manifest = await AzureManifestUtils.GetManifestWithBicep(pe.Resource); 114Assert.DoesNotContain(pe.Resource, builder.Resources); 125Assert.IsAssignableFrom<IAzurePrivateEndpointTarget>(blobs.Resource); 127var target = (IAzurePrivateEndpointTarget)blobs.Resource; 140Assert.IsAssignableFrom<IAzurePrivateEndpointTarget>(queues.Resource); 142var target = (IAzurePrivateEndpointTarget)queues.Resource; 178var (_, pe1Bicep) = await AzureManifestUtils.GetManifestWithBicep(pe1.Resource); 179var (_, pe2Bicep) = await AzureManifestUtils.GetManifestWithBicep(pe2.Resource); 234Assert.Equal(3, pe.Resource.DnsZones.Count); 237var manifest = await AzureManifestUtils.GetManifestWithBicep(pe.Resource);

23var manifest = await AzureManifestUtils.GetManifestWithBicep(cosmos.Resource); 39var manifest = await AzureManifestUtils.GetManifestWithBicep(sql.Resource); 55var manifest = await AzureManifestUtils.GetManifestWithBicep(postgres.Resource); 71var manifest = await AzureManifestUtils.GetManifestWithBicep(redis.Resource); 87var manifest = await AzureManifestUtils.GetManifestWithBicep(serviceBus.Resource); 103var manifest = await AzureManifestUtils.GetManifestWithBicep(eventHubs.Resource); 119var manifest = await AzureManifestUtils.GetManifestWithBicep(keyVault.Resource); 135var manifest = await AzureManifestUtils.GetManifestWithBicep(appConfig.Resource); 151var manifest = await AzureManifestUtils.GetManifestWithBicep(search.Resource); 167var manifest = await AzureManifestUtils.GetManifestWithBicep(signalR.Resource); 183var manifest = await AzureManifestUtils.GetManifestWithBicep(webPubSub.Resource); 199var manifest = await AzureManifestUtils.GetManifestWithBicep(openai.Resource); 215var manifest = await AzureManifestUtils.GetManifestWithBicep(foundry.Resource); 231var manifest = await AzureManifestUtils.GetManifestWithBicep(acr.Resource);

48var manifest = await AzureManifestUtils.GetManifestWithBicep(resource1.Resource);

29Assert.Same(apiProject.Resource, containerAppResource.TargetResource); 45Assert.Same(apiProject.Resource, provisioningResource.TargetResource); 63Assert.Same(apiProject.Resource, webSiteResource.TargetResource); 79Assert.Same(apiProject.Resource, provisioningResource.TargetResource); 96Assert.Same(container.Resource, containerAppResource.TargetResource); 111Assert.Same(container.Resource, provisioningResource.TargetResource);

40var (manifest, bicep) = await GetManifestWithBicep(model, redis.Resource); 83var (manifest, bicep) = await AzureManifestUtils.GetManifestWithBicep(redis.Resource); 99redisResource = c.Resource; 104Assert.True(redis.Resource.IsContainer(), "The resource should now be a container resource."); 108Assert.Equal($"localhost:12455,password={redisResource.PasswordParameter.Value}", await redis.Resource.ConnectionStringExpression.GetValueAsync(CancellationToken.None)); 122redisResource = c.Resource; 140Assert.True(redis.Resource.IsContainer(), "The resource should now be a container resource."); 143Assert.Equal($"localhost:12455,password=p@ssw0rd1", await redis.Resource.ConnectionStringExpression.GetValueAsync(CancellationToken.None)); 146Assert.NotNull(redis.Resource.HostName); 147Assert.Equal("localhost:12455", await redis.Resource.HostName.GetValueAsync(CancellationToken.None)); 149Assert.NotNull(redis.Resource.Password); 150Assert.Equal("p@ssw0rd1", await redis.Resource.Password.GetValueAsync(CancellationToken.None)); 198Assert.NotNull(redis.Resource.HostName); 199Assert.NotNull(redis.Resource.Password); 202var hostValue = await redis.Resource.HostName.GetValueAsync(CancellationToken.None); 205var passwordValue = await redis.Resource.Password.GetValueAsync(CancellationToken.None); 218Assert.Null(redis.Resource.Password); 221Assert.NotNull(redis.Resource.HostName); 222Assert.Equal("{redis-data.outputs.hostName}", redis.Resource.HostName.ValueExpression); 244Assert.True(redis.Resource.IsContainer()); 245Assert.NotNull(redis.Resource.PasswordParameter); 248Assert.Equal($"localhost:12455,password={redis.Resource.PasswordParameter.Value}", await redis.Resource.GetConnectionStringAsync()); 251var manifest = await AzureManifestUtils.GetManifestWithBicep(redis.Resource); 295_ = redis.Resource.AddAsExistingResource(infra); 298var (manifest, bicep) = await AzureManifestUtils.GetManifestWithBicep(module.Resource, skipPreparer: true); 325Assert.NotNull(redis.Resource.ConnectionStringSecretOutput); 326Assert.Same(redis.Resource, redis.Resource.ConnectionStringSecretOutput.SecretOwner); 329var references = ((IValueWithReferences)redis.Resource.ConnectionStringSecretOutput).References.ToList(); 330Assert.Contains(redis.Resource, references); 331Assert.Contains(redis.Resource.ConnectionStringSecretOutput.Resource, references);

86Assert.True(storage.Resource.TryGetLastAnnotation<DefaultRoleAssignmentsAnnotation>(out var defaultAssignments)); 93Assert.Same(storage.Resource, storageRoles.TargetAzureResource); 105Assert.True(api.Resource.TryGetLastAnnotation<RoleAssignmentAnnotation>(out var apiRoleAssignments)); 106Assert.Equal(storage.Resource, apiRoleAssignments.Target); 139Assert.Same(storage.Resource, storageRoles.TargetAzureResource); 149Assert.True(api.Resource.TryGetLastAnnotation<RoleAssignmentAnnotation>(out var apiRoleAssignments)); 150Assert.Equal(storage.Resource, apiRoleAssignments.Target); 155Assert.True(api2.Resource.TryGetLastAnnotation<RoleAssignmentAnnotation>(out var api2RoleAssignments)); 156Assert.Equal(storage.Resource, api2RoleAssignments.Target); 198context.Args.Add(blobs.Resource.ConnectionStringExpression); 204Assert.True(storage.Resource.TryGetLastAnnotation<DefaultRoleAssignmentsAnnotation>(out var defaultAssignments)); 206Assert.True(api.Resource.TryGetLastAnnotation<RoleAssignmentAnnotation>(out var apiRoleAssignments)); 207Assert.Equal(storage.Resource, apiRoleAssignments.Target); 236var deploymentTarget = Assert.IsAssignableFrom<AzureBicepResource>(api.Resource.GetDeploymentTargetAnnotation()?.DeploymentTarget); 238Assert.Same(storage.Resource, roleAssignmentResource.TargetAzureResource); 239Assert.Same(api.Resource, roleAssignmentResource.OwnerResource); 241Assert.Contains(blobPE.Resource, deploymentTarget.References); 242Assert.Contains(queuesPE.Resource, deploymentTarget.References); 271.Where(resource => resource.TargetAzureResource == keyVault.Resource) 286Assert.Same(keyVault.Resource, resource.TargetAzureResource); 287Assert.Same(api.Resource, resource.OwnerResource); 292Assert.Same(keyVault.Resource, resource.TargetAzureResource); 293Assert.Same(worker.Resource, resource.OwnerResource); 298resource => resource.TargetAzureResource == storage.Resource); 299Assert.Same(api.Resource, storageRoleAssignment.OwnerResource); 328.Where(resource => resource.TargetAzureResource == signalR.Resource) 343Assert.Same(signalR.Resource, resource.TargetAzureResource); 344Assert.Same(serviceA.Resource, resource.OwnerResource); 349Assert.Same(signalR.Resource, resource.TargetAzureResource); 350Assert.Same(serviceB.Resource, resource.OwnerResource); 380Assert.Same(storage.Resource, storageRoles.TargetAzureResource); 382Assert.Single(storage.Resource.Annotations.OfType<RoleAssignmentResourceAnnotation>()); 553agent.Resource.Annotations.Add(new ReferenceRoleAssignmentAnnotation( 554storage.Resource, 563Assert.True(consumer.Resource.TryGetLastAnnotation<RoleAssignmentAnnotation>(out var consumerRoleAssignments)); 564Assert.Equal(storage.Resource, consumerRoleAssignments.Target); 578agent.Resource.Annotations.Add(new ReferenceRoleAssignmentAnnotation( 579storage.Resource, 590Assert.Same(storage.Resource, storageRoles.TargetAzureResource); 603agent.Resource.Annotations.Add(new ReferenceRoleAssignmentAnnotation( 604storage.Resource, 614Assert.False(bystander.Resource.TryGetLastAnnotation<RoleAssignmentAnnotation>(out _)); 632agent1.Resource.Annotations.Add(new ReferenceRoleAssignmentAnnotation(storage.Resource, role)); 635agent2.Resource.Annotations.Add(new ReferenceRoleAssignmentAnnotation(storage.Resource, role)); 646Assert.Same(storage.Resource, roleAssignmentResource.TargetAzureResource); 647Assert.Same(consumer.Resource, roleAssignmentResource.OwnerResource); 666agent.Resource.Annotations.Add(new ReferenceRoleAssignmentAnnotation( 667storage.Resource, 682var roleIds = consumer.Resource.Annotations.OfType<RoleAssignmentAnnotation>() 683.Where(a => a.Target == storage.Resource) 709agent.Resource.Annotations.Add(new ReferenceRoleAssignmentAnnotation( 710storage.Resource, 723var roleIds = consumer.Resource.Annotations.OfType<RoleAssignmentAnnotation>() 724.Where(a => a.Target == storage.Resource)

14{ "Azure App Configuration", (builder, configure) => builder.AddAzureAppConfiguration("appconfig").RunAsEmulator(_ => configure()).Resource }, 15{ "Azure Cosmos DB", (builder, configure) => builder.AddAzureCosmosDB("cosmos").RunAsEmulator(_ => configure()).Resource }, 16{ "Azure Cosmos DB classic", (builder, configure) => builder.AddAzureCosmosDB("cosmos").RunAsClassicEmulator(_ => configure()).Resource }, 17{ "Azure Event Hubs", (builder, configure) => builder.AddAzureEventHubs("eventhubs").RunAsEmulator(_ => configure()).Resource }, 18{ "Azure Kusto", (builder, configure) => builder.AddAzureKustoCluster("kusto").RunAsEmulator(_ => configure()).Resource }, 19{ "Azure Service Bus", (builder, configure) => builder.AddAzureServiceBus("servicebus").RunAsEmulator(_ => configure()).Resource }, 20{ "Azure SignalR", (builder, configure) => builder.AddAzureSignalR("signalr").RunAsEmulator(_ => configure()).Resource }, 21{ "Azure Storage", (builder, configure) => builder.AddAzureStorage("storage").RunAsEmulator(_ => configure()).Resource },

35Assert.Equal("{sandboxes.outputs.id}", sandboxGroup.Resource.IdOutputReference.ValueExpression); 36Assert.Equal("{sandboxes.outputs.name}", sandboxGroup.Resource.NameOutputReference.ValueExpression); 44firstGroup.Resource.Outputs["id"] = "/subscriptions/11111111-1111-1111-1111-111111111111/resourceGroups/example-rg/providers/Microsoft.App/sandboxGroups/first-group"; 45firstGroup.Resource.Outputs["location"] = "westus3"; 47secondGroup.Resource.Outputs["id"] = "/subscriptions/22222222-2222-2222-2222-222222222222/resourceGroups/other-rg/providers/Microsoft.App/sandboxGroups/second-group"; 48secondGroup.Resource.Outputs["location"] = "eastus2"; 51var firstSteps = await CreateStepsAsync(app, firstGroup.Resource); 57var secondSteps = await CreateStepsAsync(app, secondGroup.Resource); 105var steps = await CreateStepsAsync(app, sandboxGroup.Resource); 138sandboxGroup.Resource.Outputs["id"] = "/subscriptions/11111111-1111-1111-1111-111111111111/resourceGroups/existing-rg/providers/Microsoft.App/sandboxGroups/existing-group"; 139sandboxGroup.Resource.Outputs["location"] = "eastus2"; 141var scope = AzureSandboxContainerDeployment.CreateDataPlaneScope(sandboxGroup.Resource); 162var (hostGroupManifest, hostGroupBicep) = await AzureManifestUtils.GetManifestWithBicep(model, hostGroup.Resource); 163var (workerGroupManifest, workerGroupBicep) = await AzureManifestUtils.GetManifestWithBicep(model, workerGroup.Resource); 200var (_, sandbox1Bicep) = await AzureManifestUtils.GetManifestWithBicep(model, sandbox1.Resource); 201var (_, sandbox2Bicep) = await AzureManifestUtils.GetManifestWithBicep(model, sandbox2.Resource); 226Assert.Equal(ManagedServiceIdentityType.SystemAssignedUserAssigned, sandboxGroup.Resource.WorkloadManagedIdentityType); 227Assert.Equal(identity.Resource, Assert.Single(sandboxGroup.Resource.WorkloadUserAssignedIdentities)); 238var (_, bicep) = await AzureManifestUtils.GetManifestWithBicep(sandboxGroup.Resource, skipPreparer: true); 251var (_, bicep) = await AzureManifestUtils.GetManifestWithBicep(sandboxGroup.Resource, skipPreparer: true); 267.WithAnnotation(new AppIdentityAnnotation(computeIdentity.Resource)) 273Assert.Equal(ManagedServiceIdentityType.UserAssigned, sandboxGroup.Resource.WorkloadManagedIdentityType); 274Assert.Equal(computeIdentity.Resource, Assert.Single(sandboxGroup.Resource.WorkloadUserAssignedIdentities)); 276var (_, bicep) = await AzureManifestUtils.GetManifestWithBicep(sandboxGroup.Resource, skipPreparer: true); 289.WithAnnotation(new AppIdentityAnnotation(identity.Resource)) 295Assert.Equal(ManagedServiceIdentityType.UserAssigned, sandboxGroup.Resource.WorkloadManagedIdentityType); 296Assert.Equal(identity.Resource, Assert.Single(sandboxGroup.Resource.WorkloadUserAssignedIdentities)); 297Assert.Empty(otherGroup.Resource.WorkloadUserAssignedIdentities); 298var (_, bicep) = await AzureManifestUtils.GetManifestWithBicep(sandboxGroup.Resource, skipPreparer: true); 315.WithAnnotation(new AppIdentityAnnotation(identity.Resource)) 340var (_, bicep) = await AzureManifestUtils.GetManifestWithBicep(model, sandboxGroup.Resource); 342var annotation = Assert.Single(sandboxGroup.Resource.Annotations.OfType<AzureSandboxGroupAcrPullIdentityAnnotation>()); 343Assert.Same(pullIdentity.Resource, annotation.Identity); 364() => AzureManifestUtils.GetManifestWithBicep(model, sandboxGroup.Resource)); 422var annotation = Assert.Single(sandboxGroup.Resource.Annotations.OfType<AzureSandboxGroupAcrPullIdentityAnnotation>()); 424Assert.Same(registry.Resource, roles.TargetAzureResource); 426Assert.Contains(identity, sandboxGroup.Resource.References); 428var (_, sandboxBicep) = await AzureManifestUtils.GetManifestWithBicep(sandboxGroup.Resource, skipPreparer: true); 467var buildOptionsCallbackCount = container.Resource.Annotations.OfType<ContainerBuildOptionsCallbackAnnotation>().Count(); 481Assert.Null(computeResource.GetDeploymentTargetAnnotation(sandboxGroup.Resource)); 483Assert.Equal(buildOptionsCallbackCount, container.Resource.Annotations.OfType<ContainerBuildOptionsCallbackAnnotation>().Count()); 588sandboxGroup.Resource.ContainerRegistry!.Outputs["loginServer"] = "example.azurecr.io"; 589sandboxGroup.Resource.Outputs[AzureSandboxGroupResource.ImagePullIdentityClientIdOutputName] = 593sandboxGroup.Resource, 597sandboxGroup.Resource, 1169sandboxGroup.Resource.Outputs["id"] = "/subscriptions/11111111-1111-1111-1111-111111111111/resourceGroups/existing-rg/providers/Microsoft.App/sandboxGroups/existing-group"; 1170sandboxGroup.Resource.Outputs["location"] = "eastus2"; 1171var existingScope = AzureSandboxContainerDeployment.CreateDataPlaneScope(sandboxGroup.Resource); 1174var targetResource = builder.AddContainer("frontend", "example/image").Resource; 1178sandboxGroup.Resource); 2019var deploymentTarget = computeResource.GetDeploymentTargetAnnotation(sandboxGroup.Resource); 2094defaultResource.Resource.GetDeploymentTargetAnnotation(sandboxGroup.Resource)?.DeploymentTarget); 2096disabledResource.Resource.GetDeploymentTargetAnnotation(sandboxGroup.Resource)?.DeploymentTarget); 2098enabledResource.Resource.GetDeploymentTargetAnnotation(sandboxGroup.Resource)?.DeploymentTarget); 2185var deploymentTarget = computeResource.GetDeploymentTargetAnnotation(sandboxGroup.Resource); 2211Assert.True(AzureSandboxContainerDeployment.TryResolveEndpointReferenceValue(api.GetEndpoint("http"), sandboxGroup.Resource, out var urlExpression)); 2216Assert.True(AzureSandboxContainerDeployment.TryResolveEndpointReferenceValue(api.GetEndpoint("http").Property(EndpointProperty.TargetPort), sandboxGroup.Resource, out var targetPortExpression)); 2247var deploymentTarget = computeResource.GetDeploymentTargetAnnotation(sandboxGroup.Resource); 2286var deploymentTarget = computeResource.GetDeploymentTargetAnnotation(sandboxGroup.Resource); 2310var deploymentTarget = computeResource.GetDeploymentTargetAnnotation(sandboxGroup.Resource); 2343var frontendCallbackCount = frontend.Resource.Annotations.OfType<ContainerBuildOptionsCallbackAnnotation>().Count(); 2344var backendCallbackCount = backend.Resource.Annotations.OfType<ContainerBuildOptionsCallbackAnnotation>().Count(); 2354Assert.Same(sandboxGroup.Resource, computeResource.GetComputeEnvironment()); 2355Assert.Same(sandboxGroup.Resource, explicitComputeResource.GetComputeEnvironment()); 2395var deploymentTarget = computeResource.GetDeploymentTargetAnnotation(sandboxGroup.Resource); 2397Assert.Same(sandboxGroup.Resource.ContainerRegistry, deploymentTarget.ContainerRegistry); 2398Assert.Same(sandboxGroup.Resource, deploymentTarget.ComputeEnvironment); 2402Assert.Same(sandboxGroup.Resource, sandboxContainer.Parent); 2433Resource = sandboxGroup.Resource.ContainerRegistry, 2486foreach (var annotation in sandboxGroup.Resource.Annotations.OfType<PipelineConfigurationAnnotation>() 2535Assert.Same(sandboxGroup.Resource, computeResource.GetComputeEnvironment()); 2537var deploymentTarget = computeResource.GetDeploymentTargetAnnotation(sandboxGroup.Resource); 2598var deploymentTarget = computeResource.GetDeploymentTargetAnnotation(sandboxGroup.Resource); 2655Assert.Same(sandboxGroup.Resource, project.GetComputeEnvironment()); 2661project.GetDeploymentTargetAnnotation(sandboxGroup.Resource)?.DeploymentTarget); 2699project.GetDeploymentTargetAnnotation(sandboxGroup.Resource)?.DeploymentTarget); 2725project.GetDeploymentTargetAnnotation(sandboxGroup.Resource)?.DeploymentTarget); 2746project.Resource.GetDeploymentTargetAnnotation(sandboxGroup.Resource)?.DeploymentTarget); 2781project.GetDeploymentTargetAnnotation(sandboxGroup.Resource)?.DeploymentTarget); 2813sandboxGroup.Resource, 2817sandboxGroup.Resource, 2842frontend.Resource.GetDeploymentTargetAnnotation(frontendGroup.Resource)?.DeploymentTarget); 2844backend.Resource.GetDeploymentTargetAnnotation(backendGroup.Resource)?.DeploymentTarget); 2845Assert.Null(frontend.Resource.GetDeploymentTargetAnnotation(backendGroup.Resource)); 2846Assert.Null(backend.Resource.GetDeploymentTargetAnnotation(frontendGroup.Resource)); 2866var deploymentTarget = computeResource.GetDeploymentTargetAnnotation(sandboxGroup.Resource); 2887container.Resource.GetDeploymentTargetAnnotation(sandboxGroup.Resource)?.DeploymentTarget); 2889var registry = Assert.IsType<AzureContainerRegistryResource>(sandboxGroup.Resource.ContainerRegistry); 2909Assert.Empty(context.GetSteps(container.Resource, WellKnownPipelineTags.PushContainerImage)); 2931api.Resource.GetDeploymentTargetAnnotation(sandboxGroup.Resource)?.DeploymentTarget); 2958var value = await AzureSandboxContainerDeployment.ResolveValueWithEgressHostsAsync(stepContext, web.Resource, endpointExpression); 2959var environment = await AzureSandboxContainerDeployment.ResolveEnvironmentVariablesAsync(stepContext, web.Resource); 2980storage.Resource.Outputs["blobEndpoint"] = "https://storage.blob.core.windows.net/"; 2996worker.Resource); 3033worker.Resource); 3058var dependencies = await web.Resource.GetResourceDependenciesAsync( 3061Assert.Contains(api.Resource, dependencies); 3062var steps = await CreateStepsAsync(app, sandboxGroup.Resource); 3069foreach (var annotation in sandboxGroup.Resource.Annotations.OfType<PipelineConfigurationAnnotation>()) 3098var steps = await CreateStepsAsync(app, consumerGroup.Resource); 3108foreach (var annotation in consumerGroup.Resource.Annotations.OfType<PipelineConfigurationAnnotation>()) 3138var firstDependencies = await first.Resource.GetResourceDependenciesAsync( 3141var secondDependencies = await second.Resource.GetResourceDependenciesAsync( 3144Assert.Contains(second.Resource, firstDependencies); 3145Assert.Contains(first.Resource, secondDependencies); 3146var steps = await CreateStepsAsync(app, sandboxGroup.Resource); 3155foreach (var annotation in sandboxGroup.Resource.Annotations.OfType<PipelineConfigurationAnnotation>()) 3188project.Resource); 3192Assert.True(AzureSandboxContainerDeployment.HasModeledCommandConfiguration(project.Resource)); 3196Assert.True(AzureSandboxContainerDeployment.HasModeledCommandConfiguration(container.Resource)); 3217api.Resource.GetDeploymentTargetAnnotation(sandboxGroup.Resource)?.DeploymentTarget); 3241var command = await AzureSandboxContainerDeployment.ResolveModeledCommandAsync(stepContext, worker.Resource); 3276worker.Resource);

30search.Resource.Outputs["connectionString"] = fakeConnectionString; 32var connectionStringResource = (IResourceWithConnectionString)search.Resource; 35Assert.Equal("search", search.Resource.Name); 41var manifest = await GetManifestWithBicep(model, search.Resource); 126_ = search.Resource.AddAsExistingResource(infra); 129var (manifest, bicep) = await AzureManifestUtils.GetManifestWithBicep(module.Resource, skipPreparer: true);

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

42var manifest = await AzureManifestUtils.GetManifestWithBicep(serviceBus.Resource); 67var manifest = await AzureManifestUtils.GetManifestWithBicep(serviceBus.Resource); 99await app.ResourceNotifications.WaitForResourceAsync(resource.Resource.Name, KnownResourceStates.Running, cts.Token); 101await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Waiting, cts.Token); 105await app.ResourceNotifications.WaitForResourceHealthyAsync(resource.Resource.Name, cts.Token); 107await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running, cts.Token); 133hb.Configuration["ConnectionStrings:servicebusns"] = await serviceBus.Resource.ConnectionStringExpression.GetValueAsync(CancellationToken.None); 140await rns.WaitForResourceAsync(serviceBus.Resource.Name, KnownResourceStates.Running, cts.Token); 141await rns.WaitForResourceHealthyAsync(serviceBus.Resource.Name, cts.Token); 145await using var sender = serviceBusClient.CreateSender(queueResource.Resource.QueueName); 148await using var receiver = serviceBusClient.CreateReceiver(queueResource.Resource.QueueName); 168serviceBus.Resource.Annotations.OfType<EndpointAnnotation>(), 191var containerImageAnnotation = serviceBus.Resource.Annotations.OfType<ContainerImageAnnotation>().FirstOrDefault(); 269var manifest = await AzureManifestUtils.GetManifestWithBicep(serviceBus.Resource); 612Assert.Same(serviceBus.Resource.Annotations, sourceResource.Annotations); 614var persistenceAnnotation = Assert.Single(serviceBus.Resource.Annotations.OfType<PersistenceAnnotation>()); 655var env = await EnvironmentVariableEvaluator.GetEnvironmentVariablesAsync(serviceBus.Resource, DistributedApplicationOperation.Run, TestServiceProvider.Instance); 671AssertWaitsForHealthy(serviceBus.Resource, sql); 730var env = await EnvironmentVariableEvaluator.GetEnvironmentVariablesAsync(serviceBus.Resource, DistributedApplicationOperation.Run, TestServiceProvider.Instance); 747resource => Assert.Same(sql.Resource, resource)); 748AssertWaitsForHealthy(serviceBus.Resource, sql.Resource); 750AllocateContainerNetworkEndpoint(sql.Resource, "sql.dev.internal", 1433); 752var env = await EnvironmentVariableEvaluator.GetEnvironmentVariablesAsync(serviceBus.Resource, DistributedApplicationOperation.Run, TestServiceProvider.Instance); 756Assert.Equal(await sql.Resource.PasswordParameter.GetValueAsync(CancellationToken.None), env["MSSQL_SA_PASSWORD"]); 771AllocateContainerNetworkEndpoint(sql.Resource, "sql.dev.internal", 1433); 773var env = await EnvironmentVariableEvaluator.GetEnvironmentVariablesAsync(serviceBus.Resource, DistributedApplicationOperation.Run, TestServiceProvider.Instance); 792AllocateContainerNetworkEndpoint(sql.Resource, "host.docker.internal", 52133); 794var env = await EnvironmentVariableEvaluator.GetEnvironmentVariablesAsync(serviceBus.Resource, DistributedApplicationOperation.Run, TestServiceProvider.Instance); 808var endpoint = sql.Resource.Annotations.OfType<EndpointAnnotation>().Single(e => e.Name == "tcp"); 809sql.Resource.Annotations.Remove(endpoint); 844AllocateContainerNetworkEndpoint(sql2.Resource, "sql2.dev.internal", 1433); 846var env = await EnvironmentVariableEvaluator.GetEnvironmentVariablesAsync(serviceBus.Resource, DistributedApplicationOperation.Run, TestServiceProvider.Instance); 849Assert.Equal(await sql2.Resource.PasswordParameter.GetValueAsync(CancellationToken.None), env["MSSQL_SA_PASSWORD"]); 852AssertWaitsForHealthy(serviceBus.Resource, sql2.Resource); 854serviceBus.Resource.Annotations.OfType<ResourceRelationshipAnnotation>(), 855relationship => Assert.Same(sql2.Resource, relationship.Resource)); 871var waits = serviceBus.Resource.Annotations.OfType<WaitAnnotation>().ToArray(); 874wait => Assert.Same(sql1.Resource, wait.Resource), 875wait => Assert.Same(sql2.Resource, wait.Resource)); 945var env = await EnvironmentVariableEvaluator.GetEnvironmentVariablesAsync(serviceBus.Resource, DistributedApplicationOperation.Run, TestServiceProvider.Instance); 1010Assert.Equal("{sb.outputs.serviceBusEndpoint}", serviceBus.Resource.ConnectionStringExpression.ValueExpression); 1011Assert.Equal("Endpoint={sb.outputs.serviceBusEndpoint};EntityPath=queue", queue.Resource.ConnectionStringExpression.ValueExpression); 1012Assert.Equal("Endpoint={sb.outputs.serviceBusEndpoint};EntityPath=topic", topic.Resource.ConnectionStringExpression.ValueExpression); 1013Assert.Equal("Endpoint={sb.outputs.serviceBusEndpoint};EntityPath=topic/Subscriptions/sub", subscription.Resource.ConnectionStringExpression.ValueExpression); 1027((IResourceWithAzureFunctionsConfig)serviceBus.Resource).ApplyAzureFunctionsConfiguration(target, "sb"); 1033((IResourceWithAzureFunctionsConfig)queue.Resource).ApplyAzureFunctionsConfiguration(target, "queue"); 1040((IResourceWithAzureFunctionsConfig)topic.Resource).ApplyAzureFunctionsConfiguration(target, "topic"); 1047((IResourceWithAzureFunctionsConfig)subscription.Resource).ApplyAzureFunctionsConfiguration(target, "sub"); 1083serviceBus.Resource.Outputs["serviceBusEndpoint"] = "mynamespaceEndpoint"; 1085var connectionStringResource = (IResourceWithConnectionString)serviceBus.Resource; 1087Assert.Equal("sb", serviceBus.Resource.Name); 1093var manifest = await GetManifestWithBicep(model, serviceBus.Resource); 1176hb.Configuration["ConnectionStrings:servicebusns"] = await serviceBus.Resource.ConnectionStringExpression.GetValueAsync(CancellationToken.None); 1179await app.ResourceNotifications.WaitForResourceAsync(serviceBus.Resource.Name, KnownResourceStates.Running, cts.Token); 1180await app.ResourceNotifications.WaitForResourceHealthyAsync(serviceBus.Resource.Name, cts.Token); 1187await using var sender = serviceBusClient.CreateSender(queueResource.Resource.QueueName); 1190await using var receiver = serviceBusClient.CreateReceiver(queueResource.Resource.QueueName); 1254Assert.True(serviceBus.Resource.IsEmulator()); 1255Assert.Contains(serviceBus.Resource.Annotations, a => a is EmulatorResourceAnnotation); 1285_ = serviceBus.Resource.AddAsExistingResource(infra); 1288var (manifest, bicep) = await AzureManifestUtils.GetManifestWithBicep(module.Resource, skipPreparer: true); 1307_ = serviceBus.Resource.AddAsExistingResource(infra); 1310var (manifest, bicep) = await AzureManifestUtils.GetManifestWithBicep(module.Resource, skipPreparer: true); 1326_ = serviceBus.Resource.AddAsExistingResource(infra); 1329var (manifest, bicep) = await AzureManifestUtils.GetManifestWithBicep(module.Resource, skipPreparer: true); 1347_ = serviceBus.Resource.AddAsExistingResource(infra); 1350var (manifest, bicep) = await AzureManifestUtils.GetManifestWithBicep(module.Resource, skipPreparer: true); 1367_ = serviceBus.Resource.AddAsExistingResource(infra); 1370var (manifest, bicep) = await AzureManifestUtils.GetManifestWithBicep(module.Resource, skipPreparer: true);

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

28Assert.True(signalR.Resource.IsEmulator); 30var connectionStringExpr = signalR.Resource.ConnectionStringExpression; 35Assert.Equal(connectionString, await ((IResourceWithConnectionString)signalR.Resource).GetConnectionStringAsync()); 60await app.ResourceNotifications.WaitForResourceAsync(signalR.Resource.Name, KnownResourceStates.Running, cts.Token); 61await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Waiting, cts.Token); 65await app.ResourceNotifications.WaitForResourceHealthyAsync(signalR.Resource.Name, cts.Token); 67await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running, cts.Token); 98var connectionString = await signalR.Resource.ConnectionStringExpression.GetValueAsync(default);

24var (manifest, bicep) = await GetManifestWithBicep(signalr.Resource, skipPreparer: true); 46var (manifest, bicep) = await GetManifestWithBicep(signalr.Resource, skipPreparer: true); 65Assert.True(signalR.Resource.IsEmulator()); 66Assert.Contains(signalR.Resource.Annotations, a => a is EmulatorResourceAnnotation); 96_ = signalR.Resource.AddAsExistingResource(infra); 99var (manifest, bicep) = await AzureManifestUtils.GetManifestWithBicep(module.Resource, skipPreparer: true);

94var resource = sqlServer.Resource; 145var resource = database.Resource;

201var delegation = Assert.Single(aciSubnet.Resource.Annotations.OfType<AzureSubnetServiceDelegationAnnotation>());

46var manifest = await AzureManifestUtils.GetManifestWithBicep(sql.Resource, skipPreparer: true); 92Assert.True(sql.Resource.IsContainer(), "The resource should now be a container resource."); 93var serverConnectionString = await sql.Resource.ConnectionStringExpression.GetValueAsync(CancellationToken.None); 97var db1ConnectionString = await db1.Resource.ConnectionStringExpression.GetValueAsync(CancellationToken.None); 101var db2ConnectionString = await db2.Resource.ConnectionStringExpression.GetValueAsync(CancellationToken.None); 105var db3ConnectionString = await db3.Resource.ConnectionStringExpression.GetValueAsync(CancellationToken.None); 149var endpoint = Assert.Single(innerSql.Resource.Annotations.OfType<EndpointAnnotation>()); 158Assert.True(sql.Resource.IsContainer(), "The resource should now be a container resource."); 159var serverConnectionString = await sql.Resource.ConnectionStringExpression.GetValueAsync(CancellationToken.None); 162var db1ConnectionString = await db1.Resource.ConnectionStringExpression.GetValueAsync(CancellationToken.None); 165var db2ConnectionString = await db2.Resource.ConnectionStringExpression.GetValueAsync(CancellationToken.None); 168var db3ConnectionString = await db3.Resource.ConnectionStringExpression.GetValueAsync(CancellationToken.None); 248var manifest = await AzureManifestUtils.GetManifestWithBicep(sql.Resource); 250Assert.True(sql.Resource.TryGetLastAnnotation<ConnectionStringRedirectAnnotation>(out var connectionStringAnnotation)); 254Assert.Equal("Server=tcp:myserver,1433;Encrypt=True;Authentication=\"Active Directory Default\"", await sql.Resource.GetConnectionStringAsync(default)); 255Assert.Equal("Server=tcp:{sql.outputs.sqlServerFqdn},1433;Encrypt=True;Authentication=\"Active Directory Default\"", sql.Resource.ConnectionStringExpression.ValueExpression); 279var manifest = await AzureManifestUtils.GetManifestWithBicep(sql.Resource); 281Assert.True(sql.Resource.TryGetLastAnnotation<ConnectionStringRedirectAnnotation>(out var connectionStringAnnotation)); 285Assert.Equal("Server=tcp:myserver,1433;Encrypt=True;Authentication=\"Active Directory Default\"", await sql.Resource.GetConnectionStringAsync(default)); 286Assert.Equal("Server=tcp:{sql.outputs.sqlServerFqdn},1433;Encrypt=True;Authentication=\"Active Directory Default\"", sql.Resource.ConnectionStringExpression.ValueExpression); 327_ = sql.Resource.AddAsExistingResource(infra); 330var (manifest, bicep) = await AzureManifestUtils.GetManifestWithBicep(module.Resource, skipPreparer: true);

18var properties = ((IResourceWithConnectionString)blobs.Resource).GetConnectionProperties().ToArray(); 36var properties = ((IResourceWithConnectionString)queues.Resource).GetConnectionProperties().ToArray(); 54var properties = ((IResourceWithConnectionString)tables.Resource).GetConnectionProperties().ToArray();

51await rns.WaitForResourceAsync(storage.Resource.Name, KnownResourceStates.Running, cts.Token); 53await rns.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Waiting, cts.Token); 57await rns.WaitForResourceHealthyAsync(blobs.Resource.Name, cts.Token); 58await rns.WaitForResourceHealthyAsync(queues.Resource.Name, cts.Token); 59await rns.WaitForResourceHealthyAsync(tables.Resource.Name, cts.Token); 61await rns.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running, cts.Token); 96await rns.WaitForResourceAsync(storage.Resource.Name, KnownResourceStates.Running, cts.Token); 98await rns.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Waiting, cts.Token); 102await rns.WaitForResourceHealthyAsync(blobContainer.Resource.Name, cts.Token); 104await rns.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running, cts.Token); 139await rns.WaitForResourceAsync(storage.Resource.Name, KnownResourceStates.Running, cts.Token); 141await rns.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Waiting, cts.Token); 145await rns.WaitForResourceHealthyAsync(testQueue.Resource.Name, cts.Token); 147await rns.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running, cts.Token); 178hb.Configuration[$"ConnectionStrings:{blobsResourceName}"] = await blobs.Resource.ConnectionStringExpression.GetValueAsync(CancellationToken.None); 179hb.Configuration[$"ConnectionStrings:{blobContainerName}"] = await container.Resource.ConnectionStringExpression.GetValueAsync(CancellationToken.None); 180hb.Configuration[$"ConnectionStrings:{queuesResourceName}"] = await queues.Resource.ConnectionStringExpression.GetValueAsync(CancellationToken.None); 181hb.Configuration[$"ConnectionStrings:{queueName}"] = await queue.Resource.ConnectionStringExpression.GetValueAsync(CancellationToken.None); 193await rns.WaitForResourceHealthyAsync(storage.Resource.Name, cts.Token); 225await rns.WaitForResourceHealthyAsync(blobContainer.Resource.Name, cancellationToken: cts.Token); 229hb.Configuration["ConnectionStrings:BlobConnection"] = await blobs.Resource.ConnectionStringExpression.GetValueAsync(CancellationToken.None); 265await rns.WaitForResourceHealthyAsync(queue.Resource.Name, cancellationToken: cts.Token); 269hb.Configuration["ConnectionStrings:QueueConnection"] = await queues.Resource.ConnectionStringExpression.GetValueAsync(CancellationToken.None);

36var volumeAnnotation = storage.Resource.Annotations.OfType<ContainerMountAnnotation>().Single(); 62var volumeAnnotation = storage.Resource.Annotations.OfType<ContainerMountAnnotation>().Single(); 88var volumeAnnotation = storage.Resource.Annotations.OfType<ContainerMountAnnotation>().Single(); 114var volumeAnnotation = storage.Resource.Annotations.OfType<ContainerMountAnnotation>().Single(); 133storage.Resource.Annotations.OfType<EndpointAnnotation>(), 147var args = await ArgumentEvaluator.GetArgumentListAsync(storage.Resource); 167var args = await ArgumentEvaluator.GetArgumentListAsync(storage.Resource); 187Assert.True(storage.Resource.IsContainer()); 191Assert.Equal(expected, await ((IResourceWithConnectionString)blobs.Resource).ConnectionStringExpression.GetValueAsync(default)); 203storage.Resource.Outputs["blobEndpoint"] = blobsConnectionString; 207Assert.Equal(blobsConnectionString, await ((IResourceWithConnectionString)blobs.Resource).ConnectionStringExpression.GetValueAsync(default)); 218Assert.Equal("{storage.outputs.blobEndpoint}", blobs.Resource.ConnectionStringExpression.ValueExpression); 235Assert.True(storage.Resource.IsContainer()); 240string? blobConnectionString = await ((IResourceWithConnectionString)blobs.Resource).ConnectionStringExpression.GetValueAsync(default); 241string? blobContainerConnectionString = await ((IResourceWithConnectionString)blobContainer.Resource).ConnectionStringExpression.GetValueAsync(default); 257storage.Resource.Outputs["blobEndpoint"] = "https://myblob"; 262string? blobsConnectionString = await ((IResourceWithConnectionString)blobs.Resource).ConnectionStringExpression.GetValueAsync(default); 265Assert.Equal(expected, await ((IResourceWithConnectionString)blobContainer.Resource).ConnectionStringExpression.GetValueAsync(default)); 276Assert.Equal("Endpoint={storage.outputs.blobEndpoint};ContainerName=myContainer", blobContainer.Resource.ConnectionStringExpression.ValueExpression); 293Assert.True(storage.Resource.IsContainer()); 297Assert.Equal(expected, await ((IResourceWithConnectionString)queues.Resource).GetConnectionStringAsync()); 309storage.Resource.Outputs["queueEndpoint"] = connectionString; 313Assert.Equal(connectionString, await ((IResourceWithConnectionString)queues.Resource).GetConnectionStringAsync()); 324Assert.Equal("{storage.outputs.queueEndpoint}", queues.Resource.ConnectionStringExpression.ValueExpression); 341Assert.True(storage.Resource.IsContainer()); 346string? connectionString = await ((IResourceWithConnectionString)queues.Resource).GetConnectionStringAsync(); 349Assert.Equal(expected, await ((IResourceWithConnectionString)queue.Resource).GetConnectionStringAsync()); 361storage.Resource.Outputs["queueEndpoint"] = "https://myqueue"; 366string? connectionString = await ((IResourceWithConnectionString)queues.Resource).GetConnectionStringAsync(); 369Assert.Equal(expected, await ((IResourceWithConnectionString)queue.Resource).GetConnectionStringAsync()); 381Assert.Equal("Endpoint={storage.outputs.queueEndpoint};QueueName=myqueue", queue.Resource.ConnectionStringExpression.ValueExpression); 396var manifest = await AzureManifestUtils.GetManifestWithBicep(storage.Resource); 413Assert.True(storage.Resource.IsContainer()); 420=> new(storage.Resource, new EndpointAnnotation(ProtocolType.Tcp, name: name, targetPort: port)); 426Assert.Equal(blobqs, blob.Resource.ConnectionStringExpression.ValueExpression); 427Assert.Equal(queueqs, queue.Resource.ConnectionStringExpression.ValueExpression); 428Assert.Equal(tableqs, table.Resource.ConnectionStringExpression.ValueExpression); 435Assert.Equal(Resolve(blobqs, "blob", 10000), await ((IResourceWithConnectionString)blob.Resource).GetConnectionStringAsync()); 436Assert.Equal(Resolve(queueqs, "queue", 10001), await ((IResourceWithConnectionString)queue.Resource).GetConnectionStringAsync()); 437Assert.Equal(Resolve(tableqs, "table", 10002), await ((IResourceWithConnectionString)table.Resource).GetConnectionStringAsync()); 456storage.Resource.Outputs["blobEndpoint"] = "https://myblob"; 457storage.Resource.Outputs["queueEndpoint"] = "https://myqueue"; 458storage.Resource.Outputs["tableEndpoint"] = "https://mytable"; 461Assert.Equal("storage", storage.Resource.Name); 463var storageManifest = await AzureManifestUtils.GetManifestWithBicep(storage.Resource); 481var connectionStringBlobResource = (IResourceWithConnectionString)blob.Resource; 490var blobManifest = await ManifestUtils.GetManifest(blob.Resource); 496var connectionStringQueueResource = (IResourceWithConnectionString)queue.Resource; 505var queueManifest = await ManifestUtils.GetManifest(queue.Resource); 511var connectionStringTableResource = (IResourceWithConnectionString)table.Resource; 520var tableManifest = await ManifestUtils.GetManifest(table.Resource); 541storage.Resource.Outputs["blobEndpoint"] = "https://myblob"; 542storage.Resource.Outputs["queueEndpoint"] = "https://myqueue"; 543storage.Resource.Outputs["tableEndpoint"] = "https://mytable"; 546Assert.Equal("storage", storage.Resource.Name); 548var storageManifest = await AzureManifestUtils.GetManifestWithBicep(storage.Resource); 566var connectionStringBlobResource = (IResourceWithConnectionString)blob.Resource; 575var blobManifest = await ManifestUtils.GetManifest(blob.Resource); 581var connectionStringQueueResource = (IResourceWithConnectionString)queue.Resource; 590var queueManifest = await ManifestUtils.GetManifest(queue.Resource); 596var connectionStringTableResource = (IResourceWithConnectionString)table.Resource; 605var tableManifest = await ManifestUtils.GetManifest(table.Resource); 629storage.Resource.Outputs["blobEndpoint"] = "https://myblob"; 630storage.Resource.Outputs["queueEndpoint"] = "https://myqueue"; 631storage.Resource.Outputs["tableEndpoint"] = "https://mytable"; 634Assert.Equal("storage", storage.Resource.Name); 638var storageManifest = await GetManifestWithBicep(model, storage.Resource); 704var connectionStringBlobResource = (IResourceWithConnectionString)blob.Resource; 713var blobManifest = await ManifestUtils.GetManifest(blob.Resource); 717var connectionStringQueueResource = (IResourceWithConnectionString)queue.Resource; 726var queueManifest = await ManifestUtils.GetManifest(queue.Resource); 730var connectionStringTableResource = (IResourceWithConnectionString)table.Resource; 739var tableManifest = await ManifestUtils.GetManifest(table.Resource); 760storage.Resource.Outputs["blobEndpoint"] = "https://myblob"; 761storage.Resource.Outputs["queueEndpoint"] = "https://myqueue"; 762storage.Resource.Outputs["tableEndpoint"] = "https://mytable"; 765Assert.Equal("storage", storage.Resource.Name); 767var storageManifest = await AzureManifestUtils.GetManifestWithBicep(storage.Resource); 786var connectionStringBlobResource = (IResourceWithConnectionString)blob.Resource; 795var blobManifest = await ManifestUtils.GetManifest(blob.Resource); 801var connectionStringQueueResource = (IResourceWithConnectionString)queue.Resource; 810var queueManifest = await ManifestUtils.GetManifest(queue.Resource); 816var connectionStringTableResource = (IResourceWithConnectionString)table.Resource; 825var tableManifest = await ManifestUtils.GetManifest(table.Resource); 852Assert.Equal("storage-blobs", blobService.Resource.Name); 853Assert.Equal(blobService.Resource, blobStorageResource); 879Assert.Equal("storage-queues", queueService.Resource.Name); 880Assert.Equal(queueService.Resource, queueStorageResource); 897Assert.Same(blobs.Resource, container1.Resource.Parent); 898Assert.Same(blobs.Resource, container2.Resource.Parent); 914Assert.Same(queues.Resource, q1.Resource.Parent); 915Assert.Same(queues.Resource, q2.Resource.Parent); 931Assert.Same(dataLake.Resource, fs1.Resource.Parent); 932Assert.Same(dataLake.Resource, fs2.Resource.Parent); 957Assert.Equal("blobs", customBlobs.Resource.Name); 958Assert.Same(customBlobService, customBlobs.Resource); 960Assert.Same(defaultBlobService, originals.Resource.Parent); 961Assert.Same(defaultBlobService, derived.Resource.Parent); 977Assert.NotSame(customBlobs.Resource, defaultBlobs.Resource); 978Assert.Equal("blobs", customBlobs.Resource.Name); 979Assert.Equal("storage-blobs", defaultBlobs.Resource.Name); 994Assert.Same(first.Resource, container.Resource.Parent); 1005Assert.True(storage.Resource.IsEmulator()); 1006Assert.Contains(storage.Resource.Annotations, a => a is EmulatorResourceAnnotation); 1036_ = storage.Resource.AddAsExistingResource(infra); 1039var (manifest, bicep) = await AzureManifestUtils.GetManifestWithBicep(module.Resource, skipPreparer: true);

31var manifest = await AzureManifestUtils.GetManifestWithBicep(storage.Resource); 52var manifest = await AzureManifestUtils.GetManifestWithBicep(storage.Resource); 69var manifest = await AzureManifestUtils.GetManifestWithBicep(storage.Resource); 91var manifest = await AzureManifestUtils.GetManifestWithBicep(storage.Resource);

124Assert.Same(identity.Resource, identityAnnotation.IdentityResource); 171Assert.Same(identity.Resource, identityAnnotation.IdentityResource); 176Assert.Same(storage.Resource, roleAssignmentResource.TargetAzureResource); 229Assert.Same(identity.Resource, identityAnnotation.IdentityResource); 234Assert.Same(storage.Resource, roleAssignmentResource.TargetAzureResource); 312Assert.Same(identity.Resource, identityAnnotation.IdentityResource); 313Assert.Same(identity.Resource, identityAnnotation2.IdentityResource); 320Assert.Same(storage.Resource, roleAssignmentResource.TargetAzureResource); 322Assert.Same(storage.Resource, roleAssignmentResource2.TargetAzureResource); 370_ = userAssignedIdentity.Resource.AddAsExistingResource(infra); 373var (manifest, bicep) = await AzureManifestUtils.GetManifestWithBicep(module.Resource, skipPreparer: true);

22Assert.Equal("myvnet", vnet.Resource.Name); 23Assert.IsType<AzureVirtualNetworkResource>(vnet.Resource); 34Assert.Equal("myvnet", vnet.Resource.Name); 35Assert.Equal("10.1.0.0/16", vnet.Resource.AddressPrefix); 36Assert.Null(vnet.Resource.AddressPrefixParameter); 48Assert.Equal("myvnet", vnet.Resource.Name); 49Assert.Null(vnet.Resource.AddressPrefix); 50Assert.Same(vnetPrefixParam.Resource, vnet.Resource.AddressPrefixParameter); 61var manifest = await AzureManifestUtils.GetManifestWithBicep(vnet.Resource); 76Assert.Equal("mysubnet", subnet.Resource.Name); 77Assert.Equal("mysubnet", subnet.Resource.SubnetName); 78Assert.Equal("10.0.1.0/24", subnet.Resource.AddressPrefix); 79Assert.Same(vnet.Resource, subnet.Resource.Parent); 90Assert.Equal("mysubnet", subnet.Resource.Name); 91Assert.Equal("custom-subnet-name", subnet.Resource.SubnetName); 92Assert.Equal("10.0.1.0/24", subnet.Resource.AddressPrefix); 105Assert.Same(vnet.Resource, subnet1.Resource.Parent); 106Assert.Same(vnet.Resource, subnet2.Resource.Parent); 108Assert.NotSame(subnet1.Resource, subnet2.Resource); 121var manifest = await AzureManifestUtils.GetManifestWithBicep(vnet.Resource); 135Assert.DoesNotContain(vnet.Resource, builder.Resources); 137Assert.DoesNotContain(subnet.Resource, builder.Resources); 152var subnetAnnotation = env.Resource.Annotations.OfType<DelegatedSubnetAnnotation>().SingleOrDefault(); 157var delegationAnnotation = subnet.Resource.Annotations.OfType<AzureSubnetServiceDelegationAnnotation>().SingleOrDefault(); 171var delegationAnnotation = subnet.Resource.Annotations.OfType<AzureSubnetServiceDelegationAnnotation>().SingleOrDefault(); 186var delegationAnnotation = subnet.Resource.Annotations.OfType<AzureSubnetServiceDelegationAnnotation>().SingleOrDefault(); 201var delegationAnnotation = subnet.Resource.Annotations.OfType<AzureSubnetServiceDelegationAnnotation>().SingleOrDefault(); 226var delegationAnnotation = subnet.Resource.Annotations.OfType<AzureSubnetServiceDelegationAnnotation>().Single(); 245var delegationAnnotation = Assert.Single(subnet.Resource.Annotations.OfType<AzureSubnetServiceDelegationAnnotation>()); 283var subnetAnnotation = environment.Resource.Annotations.OfType<DelegatedSubnetAnnotation>().SingleOrDefault(); 287var delegationAnnotation = subnet.Resource.Annotations.OfType<AzureSubnetServiceDelegationAnnotation>().SingleOrDefault(); 304var subnetAnnotation = Assert.Single(environment.Resource.Annotations.OfType<DelegatedSubnetAnnotation>()); 307var delegationAnnotation = Assert.Single(subnet.Resource.Annotations.OfType<AzureSubnetServiceDelegationAnnotation>()); 323Assert.Single(environment.Resource.Annotations.OfType<DelegatedSubnetAnnotation>()); 324var delegationAnnotation = Assert.Single(subnet.Resource.Annotations.OfType<AzureSubnetServiceDelegationAnnotation>()); 341Assert.Single(environment.Resource.Annotations.OfType<DelegatedSubnetAnnotation>()); 342var delegationAnnotation = Assert.Single(subnet.Resource.Annotations.OfType<AzureSubnetServiceDelegationAnnotation>()); 364Assert.Single(environment.Resource.Annotations.OfType<DelegatedSubnetAnnotation>()); 365Assert.Single(firstSubnet.Resource.Annotations.OfType<AzureSubnetServiceDelegationAnnotation>()); 366Assert.Empty(secondSubnet.Resource.Annotations.OfType<AzureSubnetServiceDelegationAnnotation>()); 386Assert.Empty(appServiceEnvironment.Resource.Annotations.OfType<DelegatedSubnetAnnotation>()); 388var delegation = Assert.Single(subnet.Resource.Annotations.OfType<AzureSubnetServiceDelegationAnnotation>()); 402Assert.Equal("mysubnet", subnet.Resource.Name); 403Assert.Equal("mysubnet", subnet.Resource.SubnetName); 404Assert.Null(subnet.Resource.AddressPrefix); 405Assert.Same(addressPrefixParam.Resource, subnet.Resource.AddressPrefixParameter); 406Assert.Same(vnet.Resource, subnet.Resource.Parent); 418Assert.Equal("mysubnet", subnet.Resource.Name); 419Assert.Equal("custom-subnet-name", subnet.Resource.SubnetName); 420Assert.Null(subnet.Resource.AddressPrefix); 421Assert.Same(addressPrefixParam.Resource, subnet.Resource.AddressPrefixParameter); 433var manifest = await AzureManifestUtils.GetManifestWithBicep(vnet.Resource); 448var manifest = await AzureManifestUtils.GetManifestWithBicep(vnet.Resource); 462Assert.NotNull(subnet.Resource.NetworkSecurityGroup); 463Assert.Equal("web-nsg", subnet.Resource.NetworkSecurityGroup.Name); 464Assert.Single(subnet.Resource.NetworkSecurityGroup.SecurityRules); 478Assert.Same(nsg.Resource, subnet.Resource.NetworkSecurityGroup); 479Assert.Single(nsg.Resource.SecurityRules); 493var rules = subnet.Resource.NetworkSecurityGroup!.SecurityRules; 510var rules = subnet.Resource.NetworkSecurityGroup!.SecurityRules; 527var rules = subnet.Resource.NetworkSecurityGroup!.SecurityRules; 543var rules = subnet.Resource.NetworkSecurityGroup!.SecurityRules; 557var rules = subnet.Resource.NetworkSecurityGroup!.SecurityRules; 572var rules = subnet.Resource.NetworkSecurityGroup!.SecurityRules; 587var rules = subnet.Resource.NetworkSecurityGroup!.SecurityRules; 603var rule = Assert.Single(subnet.Resource.NetworkSecurityGroup!.SecurityRules); 616var rule = Assert.Single(subnet.Resource.NetworkSecurityGroup!.SecurityRules); 634var vnetManifest = await AzureManifestUtils.GetManifestWithBicep(vnet.Resource); 635var nsgManifest = await AzureManifestUtils.GetManifestWithBicep(vnet.Resource.Subnets[0].NetworkSecurityGroup!); 653var rules = subnet.Resource.NetworkSecurityGroup!.SecurityRules; 713var rules = subnet.Resource.NetworkSecurityGroup!.SecurityRules;

35Assert.Equal(hubName, hub.Resource.Name); 36var manifest = await AzureManifestUtils.GetManifestWithBicep(wps.Resource); 57var manifest = await AzureManifestUtils.GetManifestWithBicep(wps.Resource); 63Assert.Equal("wps1", wps.Resource.Name); 76Assert.Equal("{wps1.outputs.endpoint}", wps.Resource.ConnectionStringExpression.ValueExpression); 77Assert.Equal("Endpoint={wps1.outputs.endpoint};Hub=abc", hub.Resource.ConnectionStringExpression.ValueExpression); 79Assert.Equal("Endpoint={wps1.outputs.endpoint};Hub=hij", otherHub.Resource.ConnectionStringExpression.ValueExpression); 102var manifest = await AzureManifestUtils.GetManifestWithBicep(wps.Resource); 108Assert.Equal("wps1", wps.Resource.Name); 132var manifest = await AzureManifestUtils.GetManifestWithBicep(wps.Resource); 138Assert.Equal("wps1", wps.Resource.Name); 158wps.Resource.Outputs["endpoint"] = "https://mywebpubsubendpoint"; 159var manifest = await AzureManifestUtils.GetManifestWithBicep(wps.Resource); 164Assert.Equal("wps1", wps.Resource.Name); 193wps.Resource.Outputs["endpoint"] = "https://mywebpubsubendpoint"; 208var connectionStringResource = (IResourceWithConnectionString)wps.Resource; 211var manifest = await AzureManifestUtils.GetManifestWithBicep(wps.Resource); 218Assert.Equal("wps1", wps.Resource.Name); 234Assert.Equal("hub1", hub1.Resource.Name); 235Assert.Equal("resource2", hub2.Resource.Name); 236Assert.Equal("hub3", hub3.Resource.Name); 237Assert.Equal("hub4", hub4.Resource.Name); 239Assert.Equal("hub1", hub1.Resource.HubName); 240Assert.Equal("hub2", hub2.Resource.HubName); 241Assert.Equal("hub3", hub3.Resource.HubName); 242Assert.Equal("hub4", hub4.Resource.HubName); 244Assert.Equal("Endpoint={wps1.outputs.endpoint};Hub=hub1", hub1.Resource.ConnectionStringExpression.ValueExpression); 245Assert.Equal("Endpoint={wps1.outputs.endpoint};Hub=hub2", hub2.Resource.ConnectionStringExpression.ValueExpression); 246Assert.Equal("Endpoint={wps1.outputs.endpoint};Hub=hub3", hub3.Resource.ConnectionStringExpression.ValueExpression); 247Assert.Equal("Endpoint={wps1.outputs.endpoint};Hub=hub4", hub4.Resource.ConnectionStringExpression.ValueExpression); 261Assert.Same(hub1.Resource, hub2.Resource); 262Assert.Equal("resource1", hub1.Resource.Name); 263Assert.Equal("same-hub", hub1.Resource.HubName); 272wps.Resource.Outputs["endpoint"] = "https://mywebpubsubendpoint"; 282var connectionStringResource = (IResourceWithConnectionString)wps.Resource; 288var manifest = await GetManifestWithBicep(model, wps.Resource); 292Assert.Equal("wps1", wps.Resource.Name); 332wps.Resource.Outputs["endpoint"] = "https://mywebpubsubendpoint"; 345var manifest = await AzureManifestUtils.GetManifestWithBicep(wps.Resource); 348Assert.Equal("wps1", wps.Resource.Name); 380_ = webPubSub.Resource.AddAsExistingResource(infra); 383var (manifest, bicep) = await AzureManifestUtils.GetManifestWithBicep(module.Resource, skipPreparer: true);

24await BicepUtilities.SetParametersAsync(parameters, bicep0.Resource, builder.ExecutionContext); 56.WithParameter("expr", ReferenceExpression.Create($"{param.Resource}/1")) 60await BicepUtilities.SetParametersAsync(parameters, bicep0.Resource, builder.ExecutionContext); 74Assert.True(bicep0.Resource.TryGetAnnotationsOfType<ResourceRelationshipAnnotation>(out var relationships)); 79Assert.Equal(connectionStringResource.Resource, r.Resource); 84Assert.Equal(param.Resource, r.Resource); 89Assert.Equal(container.Resource, r.Resource); 99var bicep = builder.AddBicepTemplateString("test", "param value string").Resource; 143await BicepUtilities.SetParametersAsync(parameters0, bicep0.Resource, builder.ExecutionContext); 144var checkSum0 = BicepUtilities.GetChecksum(bicep0.Resource, parameters0, null); 147await BicepUtilities.SetParametersAsync(parameters1, bicep1.Resource, builder.ExecutionContext); 148var checkSum1 = BicepUtilities.GetChecksum(bicep1.Resource, parameters1, null); 170await BicepUtilities.SetParametersAsync(parameters0, bicep0.Resource, builder.ExecutionContext); 171var checkSum0 = BicepUtilities.GetChecksum(bicep0.Resource, parameters0, null); 174await BicepUtilities.SetParametersAsync(parameters1, bicep1.Resource, builder.ExecutionContext); 175var checkSum1 = BicepUtilities.GetChecksum(bicep1.Resource, parameters1, null); 187bicep0.Resource.Scope = new("rg0"); 191bicep1.Resource.Scope = new("rg1"); 195await BicepUtilities.SetParametersAsync(parameters0, bicep0.Resource, builder.ExecutionContext); 196await BicepUtilities.SetScopeAsync(scope0, bicep0.Resource); 197var checkSum0 = BicepUtilities.GetChecksum(bicep0.Resource, parameters0, scope0); 201await BicepUtilities.SetParametersAsync(parameters1, bicep1.Resource, builder.ExecutionContext); 202await BicepUtilities.SetScopeAsync(scope1, bicep1.Resource); 203var checkSum1 = BicepUtilities.GetChecksum(bicep1.Resource, parameters1, scope1); 215bicep0.Resource.Scope = new("rg0"); 219bicep1.Resource.Scope = new("rg0"); 223await BicepUtilities.SetParametersAsync(parameters0, bicep0.Resource, builder.ExecutionContext); 224await BicepUtilities.SetScopeAsync(scope0, bicep0.Resource); 225var checkSum0 = BicepUtilities.GetChecksum(bicep0.Resource, parameters0, scope0); 229await BicepUtilities.SetParametersAsync(parameters1, bicep1.Resource, builder.ExecutionContext); 230await BicepUtilities.SetScopeAsync(scope1, bicep1.Resource); 231var checkSum1 = BicepUtilities.GetChecksum(bicep1.Resource, parameters1, scope1); 241var bicep1 = builder.AddBicepTemplateString("test1", "param name string").Resource; 242var bicep2 = builder.AddBicepTemplateString("test2", "param name string").Resource; 262var bicep = builder.AddBicepTemplateString("test", "param name string").Resource; 287var bicep = builder.AddBicepTemplateString("test", "param name string").Resource; 315var bicep = builder.AddBicepTemplateString("test", "param name string").Resource; 347var bicep = builder.AddBicepTemplateString("test", "param name string").Resource; 368var bicep = builder.AddBicepTemplateString("test", "param name string").Resource; 383var bicep = builder.AddBicepTemplateString("test", "param name string").Resource; 399var bicep = builder.AddBicepTemplateString("test", "param name string").Resource; 414var bicep = builder.AddBicepTemplateString("test", "param name string").Resource; 433var bicep = builder.AddBicepTemplateString("test", "param name string").Resource; 448var bicep = builder.AddBicepTemplateString("test", "param name string").Resource; 462var bicep = builder.AddBicepTemplateString("test", "param name string").Resource; 474var bicep = builder.AddBicepTemplateString("test", "param name string").Resource; 490var bicep = builder.AddBicepTemplateString("test", "param name string").Resource; 515.Resource; 550var bicep = builder.AddBicepTemplateString("test", "param name string").Resource;