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

597(DistributedApplicationOperation.Run, IResourceBuilder<IResource> rb) when rb.Resource is IValueProvider provider => await resource.GetValue(executionContext, key, provider, logger, cancellationToken).ConfigureAwait(false), 599(DistributedApplicationOperation.Publish, IResourceBuilder<IResource> rb) when rb.Resource is IManifestExpressionProvider provider => new(provider.ValueExpression, false), 1805if (dependencies.Add(resourceBuilder.Resource)) 1807newDependencies.Add(resourceBuilder.Resource); 1809value = resourceBuilder.Resource;

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

58if (builder.Resource.IsExcludedFromPublish()) 63if (builder.Resource.RequiresImageBuild()) 67Name = $"build-{builder.Resource.Name}", 72builder.Resource, 78Resource = builder.Resource 83if (builder.Resource.RequiresImageBuildAndPush()) 87Name = $"push-{builder.Resource.Name}", 88Action = ctx => PipelineStepHelpers.PushImageToRegistryAsync(builder.Resource, ctx), 91Resource = builder.Resource 101var buildSteps = context.GetSteps(builder.Resource, WellKnownPipelineTags.BuildCompute); 102var pushSteps = context.GetSteps(builder.Resource, WellKnownPipelineTags.PushContainerImage); 345builder.Resource.Entrypoint = entrypoint; 363if (builder.Resource.Annotations.OfType<ContainerImageAnnotation>().LastOrDefault() is { } existingImageAnnotation) 369if (builder.Resource.Annotations.OfType<DockerfileBuildAnnotation>().SingleOrDefault() is { } buildAnnotation && 394if (builder.Resource.Annotations.OfType<ContainerImageAnnotation>().LastOrDefault() is { } existingImageAnnotation) 435if (builder.Resource.Annotations.OfType<ContainerImageAnnotation>().LastOrDefault() is { } imageAnnotation) 442builder.Resource.Annotations.Add(imageAnnotation); 463if (builder.Resource.Annotations.OfType<DockerfileBuildAnnotation>().SingleOrDefault() is { } buildAnnotation) 486if (builder.Resource.Annotations.OfType<ContainerImageAnnotation>().LastOrDefault() is { } existingImageAnnotation) 620throw new InvalidOperationException($"The resource '{builder.Resource.Name}' does not have a container image specified. Use WithImage to specify the container image and tag."); 634return builder.WithManifestPublishingCallback(context => context.WriteContainerAsync(builder.Resource)); 720if (builder.Resource.Annotations.OfType<ContainerImageAnnotation>().LastOrDefault() is { }) 870if (builder.Resource.Annotations.OfType<ContainerImageAnnotation>().LastOrDefault() is { }) 1151var annotation = builder.Resource.Annotations.OfType<DockerfileBuildAnnotation>().SingleOrDefault(); 1155throw new InvalidOperationException($"The resource '{builder.Resource.Name}' does not have a Dockerfile build annotation. Call WithDockerfile before calling WithBuildArg."); 1203if (value.Resource.Secret) 1205throw new InvalidOperationException($"Cannot add secret parameter '{value.Resource.Name}' as build argument '{name}' while configuring resource '{builder.Resource.Name}'. Use WithBuildSecret instead."); 1208return builder.WithBuildArg(name, value.Resource); 1282var annotation = builder.Resource.Annotations.OfType<DockerfileBuildAnnotation>().SingleOrDefault(); 1286throw new InvalidOperationException($"The resource '{builder.Resource.Name}' does not have a Dockerfile build annotation. Call WithDockerfile before calling WithBuildSecret."); 1289annotation.BuildSecrets[name] = value.Resource; 1707var callbackAnnotation = builder.Resource.Annotations.OfType<DockerfileBuilderCallbackAnnotation>().LastOrDefault();

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

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;

134if (builder.ApplicationBuilder.TryCreateResourceBuilder<ExecutableContainerResource>(builder.Resource.Name, out var existingBuilder)) 152builder.ApplicationBuilder.Resources.Remove(builder.Resource); 154var container = new ExecutableContainerResource(builder.Resource); 157cb.WithImage(builder.Resource.Name); 158cb.WithDockerfile(contextPath: builder.Resource.WorkingDirectory); 185var executableAnnotation = builder.Resource.Annotations.OfType<ExecutableAnnotation>().LastOrDefault(); 197builder.Resource.Annotations.Add(executableAnnotation); 216if (builder.Resource.Annotations.OfType<ExecutableAnnotation>().LastOrDefault() is { } executableAnnotation) 223throw 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!;

140AddOtlpEnvironment(builder.Resource, builder.ApplicationBuilder.Configuration, builder.ApplicationBuilder.Environment); 177AddOtlpEnvironment(builder.Resource, builder.ApplicationBuilder.Configuration, builder.ApplicationBuilder.Environment, protocol);

214builder.Resource.Description = description; 215builder.Resource.EnableDescriptionMarkdown = enableMarkdown; 247builder.Resource.Annotations.Add(new InputGeneratorAnnotation(createInput)); 264builder.Resource.Annotations.Add(new InputGeneratorAnnotation(parameter => new InteractionInput 387var parameter = new ParameterResource(builder.Resource.Name, _ => "", secret: true);

125Resource = builder.Resource

486var projectMetadata = builder.Resource.GetProjectMetadata(); 490if (!builder.Resource.TryGetLastAnnotation<ProjectLaunchDefaultsAnnotation>(out var launchDefaults)) 501$"Project defaults have already been applied to resource '{builder.Resource.Name}'. " + 508mode => ProjectLaunchConfigurationFactory.Create(builder.Resource, mode), 544if (!string.Equals(builder.Resource.Name, KnownResourceNames.AspireDashboard, StringComparisons.ResourceName)) 563var logger = resourceLogger.GetLogger(builder.Resource); 593var projectResource = builder.Resource; 950builder.Resource.Annotations.Add(new EndpointEnvironmentInjectionFilterAnnotation(filter)); 982if (builder.ApplicationBuilder.TryCreateResourceBuilder<ProjectContainerResource>(builder.Resource.Name, out var existingBuilder)) 996builder.ApplicationBuilder.Resources.Remove(builder.Resource); 998var container = new ProjectContainerResource(builder.Resource); 1001cb.WithImage(builder.Resource.Name); 1003var projectFilePath = builder.Resource.GetProjectMetadata().ProjectPath; 1100foreach (var e in builder.Resource.GetEndpoints().Where(builder.Resource.ShouldInjectEndpointEnvironment)) 1151foreach (var e in builder.Resource.GetEndpoints().Where(builder.Resource.ShouldInjectEndpointEnvironment)) 1183foreach (var e in builder.Resource.GetEndpoints().Where(builder.Resource.ShouldInjectEndpointEnvironment))

124if (builder.Resource is ContainerResource or ExecutableResource or ProjectResource) 131SourceResource = sourceBuilder.Resource 135throw new InvalidOperationException($"Resource '{builder.Resource.Name}' does not support lifetime configuration."); 192if (builder.Resource is ContainerResource or ExecutableResource or ProjectResource) 207throw new InvalidOperationException($"Resource '{builder.Resource.Name}' does not support lifetime configuration."); 213foreach (var annotation in builder.Resource.Annotations.OfType<ContainerLifetimeAnnotation>().ToArray()) 215builder.Resource.Annotations.Remove(annotation); 431builder.WithReferenceRelationship(externalService.Resource); 433if (externalService.Resource.Uri is not null) 435builder.WithEnvironment(name, externalService.Resource.Uri.ToString()); 437else if (externalService.Resource.UrlParameter is not null) 444var url = await externalService.Resource.UrlParameter.GetValueAsync(context.CancellationToken).ConfigureAwait(false); 447throw 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}"); 451context.EnvironmentVariables[name] = externalService.Resource.UrlParameter; 473builder.WithReferenceRelationship(parameter.Resource); 477context.EnvironmentVariables[name] = parameter.Resource; 500builder.WithReferenceRelationship(resource.Resource); 504context.EnvironmentVariables[envVarName] = new ConnectionStringReference(resource.Resource, optional: false); 966var hasConnectionString = source.Resource is IResourceWithConnectionString && connectionStringSource is not null; 967var hasServiceDiscovery = source.Resource is IResourceWithServiceDiscovery && serviceDiscoverySource is not null; 968var hasExternalService = source.Resource is ExternalServiceResource && externalServiceSource is not null; 1018throw 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."); 1045return TryDispatchCustomWithReference(builder, source, connectionName, optional, name, source.Resource.GetType(), out dispatchedBuilder); 1112var resource = source.Resource; 1118builder.Resource.TryGetLastAnnotation<ReferenceEnvironmentInjectionAnnotation>(out var injectionAnnotation); 1209ApplyEndpoints(builder, source.Resource); 1241ApplyEndpoints(builder, source.Resource, endpointName: null, name); 1265throw new InvalidOperationException($"The URI for service reference '{name}' is invalid while configuring target resource '{builder.Resource.Name}': it must be absolute."); 1270throw new InvalidOperationException($"The URI for service reference '{name}' is invalid while configuring target resource '{builder.Resource.Name}': it cannot contain a fragment."); 1275throw new InvalidOperationException($"The URI for service reference '{name}' is invalid while configuring target resource '{builder.Resource.Name}': it cannot contain a query string."); 1279builder.Resource.TryGetLastAnnotation<ReferenceEnvironmentInjectionAnnotation>(out var injectionAnnotation); 1310builder.WithReferenceRelationship(externalService.Resource); 1313builder.Resource.TryGetLastAnnotation<ReferenceEnvironmentInjectionAnnotation>(out var injectionAnnotation); 1316if (externalService.Resource.Uri is { } uri) 1320var encodedResourceName = EnvironmentVariableNameEncoder.Encode(externalService.Resource.Name); 1326var envVarName = $"services__{externalService.Resource.Name}__{uri.Scheme}__0"; 1330else if (externalService.Resource.UrlParameter is not null) 1336var encodedResourceName = EnvironmentVariableNameEncoder.Encode(externalService.Resource.Name); 1341discoveryEnvVarName = $"services__{externalService.Resource.Name}__default__0"; 1344else if (ExternalServiceResource.UrlIsValidForExternalService(await externalService.Resource.UrlParameter.GetValueAsync(context.CancellationToken).ConfigureAwait(false), out var uri, out var message)) 1346discoveryEnvVarName = $"services__{externalService.Resource.Name}__{uri.Scheme}__0"; 1352throw 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}"); 1357context.EnvironmentVariables[discoveryEnvVarName] = externalService.Resource.UrlParameter; 1362context.EnvironmentVariables[endpointEnvVarName] = externalService.Resource.UrlParameter; 1397var endpointReferenceAnnotation = builder.Resource.Annotations 1405if (builder.Resource.IsContainer()) 1467var endpoint = builder.Resource.Annotations 1484builder.Resource.Annotations.Add(endpoint); 1534!builder.Resource.Annotations.OfType<EndpointAnnotation>().Any(endpoint => string.Equals(endpoint.Name, endpointName, StringComparisons.EndpointAnnotationName))) 1571var existing = builder.Resource.Annotations.OfType<EndpointAnnotation>() 1652if (env is null || builder.Resource is not IResourceWithEndpoints resourceWithEndpoints || builder.Resource is not IResourceWithEnvironment) 1862if (!builder.Resource.TryGetAnnotationsOfType<EndpointAnnotation>(out var endpoints)) 1893return builder.Resource.GetEndpoint(name, contextNetworkId); 1910return builder.Resource.GetEndpoint(name); 2195context.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); 2243context.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); 2274Source = source.Resource, 2313builder.Resource.Annotations 2316.ForEach(w => builder.Resource.Annotations.Remove(w)); 2434if (builder.Resource as IResource == dependency.Resource) 2436throw new DistributedApplicationException($"The '{builder.Resource.Name}' resource cannot wait for itself."); 2439if (builder.Resource is IResourceWithParent resourceWithParent && resourceWithParent.Parent == dependency.Resource) 2441throw new DistributedApplicationException($"The '{builder.Resource.Name}' resource cannot wait for its parent '{dependency.Resource.Name}'."); 2444if (dependency.Resource is IResourceWithParent dependencyResourceWithParent) 2457builder.WithRelationship(dependency.Resource, KnownRelationshipTypes.WaitFor); 2460return builder.WithAnnotation(new WaitAnnotation(dependency.Resource, WaitType.WaitUntilHealthy) { WaitBehavior = waitBehavior }); 2557if (builder.Resource as IResource == dependency.Resource) 2559throw new DistributedApplicationException($"The '{builder.Resource.Name}' resource cannot wait for itself."); 2562if (builder.Resource is IResourceWithParent resourceWithParent && resourceWithParent.Parent == dependency.Resource) 2564throw new DistributedApplicationException($"The '{builder.Resource.Name}' resource cannot wait for its parent '{dependency.Resource.Name}'."); 2567if (dependency.Resource is IResourceWithParent dependencyResourceWithParent) 2579if (dependency.Resource is ConnectionStringResource cs) 2590builder.WithRelationship(dependency.Resource, KnownRelationshipTypes.WaitFor); 2593return builder.WithAnnotation(new WaitAnnotation(dependency.Resource, WaitType.WaitUntilStarted) { WaitBehavior = waitBehavior }); 2660if (builder.Resource as IResource == dependency.Resource) 2662throw new DistributedApplicationException($"The '{builder.Resource.Name}' resource cannot wait for itself."); 2665if (builder.Resource is IResourceWithParent resourceWithParent && resourceWithParent.Parent == dependency.Resource) 2667throw new DistributedApplicationException($"The '{builder.Resource.Name}' resource cannot wait for its parent '{dependency.Resource.Name}'."); 2670builder.WithRelationship(dependency.Resource, KnownRelationshipTypes.WaitFor); 2672return builder.WithAnnotation(new WaitAnnotation(dependency.Resource, WaitType.WaitForCompletion, exitCode)); 2720if (builder.Resource.TryGetAnnotationsOfType<HealthCheckAnnotation>(out var annotations) && annotations.Any(a => a.Key == key)) 2722throw new DistributedApplicationException($"Resource '{builder.Resource.Name}' already has a health check with key '{key}'."); 2809?? throw new DistributedApplicationException($"Could not create HTTP health check for resource '{builder.Resource.Name}' as the endpoint selector returned null."); 2813throw 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."); 2826throw new DistributedApplicationException($"The endpoint '{endpointName}' does not exist on the resource '{builder.Resource.Name}'."); 2832var healthCheckKey = $"{builder.Resource.Name}_{endpointName}_{path}_{statusCode}_check"; 2928var existingAnnotation = builder.Resource.Annotations.OfType<ResourceCommandAnnotation>().SingleOrDefault(a => a.Name == name); 2931builder.Resource.Annotations.Remove(existingAnnotation); 2995var existingAnnotation = builder.Resource.Annotations.OfType<ResourceCommandAnnotation>().SingleOrDefault(a => a.Name == name); 2998builder.Resource.Annotations.Remove(existingAnnotation); 3684?? throw new DistributedApplicationException($"Could not create HTTP command for resource '{builder.Resource.Name}' as the endpoint selector returned null."); 3688throw 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."); 3996CertificateAuthorityCollections = { certificateAuthorityCollection.Resource }, 3998if (builder.Resource.TryGetLastAnnotation<CertificateAuthorityCollectionAnnotation>(out var existingAnnotation)) 4002if (existingCollection != certificateAuthorityCollection.Resource) 4055if (builder.Resource.TryGetLastAnnotation<CertificateAuthorityCollectionAnnotation>(out var existingAnnotation)) 4106if (builder.Resource.TryGetLastAnnotation<CertificateAuthorityCollectionAnnotation>(out var existingAnnotation)) 4182Password = password?.Resource, 4218Password = password?.Resource, 4325var resource = builder.Resource; 4372var endpoints = builder.Resource.GetEndpoints(); 4382throw 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."); 4390throw new DistributedApplicationException($"Could not create {errorDisplayNoun} for resource '{builder.Resource.Name}' as no endpoint was found matching one of the specified names: {endpointNamesString}"); 4398var endpoints = builder.Resource.GetEndpoints(); 4410throw new DistributedApplicationException($"Could not create HTTP command for resource '{builder.Resource.Name}' as it has no HTTP endpoints."); 4467return builder.WithRelationship(resourceBuilder.Resource, type); 4533AddReference(resourceBuilder.Resource); 4566return builder.WithAnnotation(new ResourceRelationshipAnnotation(resourceBuilder.Resource, KnownRelationshipTypes.Reference)); 4599return builder.WithParentRelationship(parent.Resource); 4665child.WithRelationship(builder.Resource, KnownRelationshipTypes.Parent); 4759builder.WithAnnotation(new ComputeEnvironmentAnnotation(computeEnvironmentResource.Resource)); 4969builder.Resource.Name, 5074var endpoint = endpointSelector() ?? throw new DistributedApplicationException($"Could not create HTTP probe for resource '{builder.Resource.Name}' as the endpoint selector returned null."); 5103if (builder.Resource.Annotations.OfType<ProbeAnnotation>().SingleOrDefault(a => a.Type == probeAnnotation.Type) is { } existingAnnotation) 5105builder.Resource.Annotations.Remove(existingAnnotation);

75if (builder.Resource.Annotations.OfType<TerminalAnnotation>().Any()) 78$"Resource '{builder.Resource.Name}' already has a terminal configured. Call WithTerminal() only once per resource."); 97var 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;

119builder.Resource.Location = location.Resource; 144builder.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)));

915builder.Resource.UseAzdNamingConvention = true; 947builder.Resource.UseCompactResourceNaming = true; 1003builder.Resource.UseUniqueResourceNaming = true; 1017builder.Resource.EnableDashboard = enable; 1037builder.Resource.PreserveHttpEndpoints = !upgrade; 1056builder.WithAnnotation(new AzureLogAnalyticsWorkspaceReferenceAnnotation(workspaceBuilder.Resource)); 1113builder.WithAnnotation(new AzureContainerAppEnvironmentAcrPullIdentityAnnotation(identityBuilder.Resource));

49if (!ShouldPrepareIdentity(context.PipelineContext.ExecutionContext, builder.Resource)) 58Name = $"prepare-cross-scope-acr-pull-identity-{builder.Resource.Name}", 59Description = $"Prepares the ACR pull identity for {builder.Resource.Name}.", 110if (!ShouldPrepareIdentity(context.ExecutionContext, builder.Resource) || 111builder.Resource.ContainerRegistry is not AzureContainerRegistryResource registry) 119var identityName = $"{builder.Resource.Name}-mi"; 123$"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."); 147builder.Resource.Annotations.Add(createIdentityAnnotation(identity)); 148if (builder.Resource is AzureBicepResource environment)

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

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

333builder.Resource.PreserveHttpEndpoints = !upgrade; 347builder.Resource.EnableDashboard = enable; 360builder.Resource.EnableApplicationInsights = true; 396builder.Resource.ApplicationInsightsLocation = applicationInsightsLocation; 410builder.Resource.ApplicationInsightsLocationParameter = applicationInsightsLocation.Resource; 424builder.Resource.ApplicationInsightsResource = applicationInsightsBuilder.Resource; 440builder.Resource.DeploymentSlotParameter = deploymentSlot.Resource; 475builder.Resource.DeploymentSlot = deploymentSlot; 544builder.WithAnnotation(new AzureAppServiceEnvironmentAcrPullIdentityAnnotation(identityBuilder.Resource));

49if (!ShouldPrepareIdentity(context.PipelineContext.ExecutionContext, builder.Resource)) 58Name = $"prepare-cross-scope-acr-pull-identity-{builder.Resource.Name}", 59Description = $"Prepares the ACR pull identity for {builder.Resource.Name}.", 110if (!ShouldPrepareIdentity(context.ExecutionContext, builder.Resource) || 111builder.Resource.ContainerRegistry is not AzureContainerRegistryResource registry) 119var identityName = $"{builder.Resource.Name}-mi"; 123$"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."); 147builder.Resource.Annotations.Add(createIdentityAnnotation(identity)); 148if (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)));

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); 179var password = ParameterResourceBuilderExtensions.CreateDefaultPasswordParameter(builder.ApplicationBuilder, $"{builder.Resource.Name}-certificate-passphrase"); 216var healthCheckKey = $"{builder.Resource.Name}_check"; 227var surrogate = new AzureCosmosDBEmulatorResource(builder.Resource); 271var isVNext = builder.Resource.InnerResource.IsVNextEmulator; 317if (builder.Resource.InnerResource.IsVNextEmulator) 366var database = new AzureCosmosDBDatabaseResource(name, databaseName, builder.Resource); 367builder.Resource.Databases.Add(database); 391var container = new AzureCosmosDBContainerResource(name, containerName, partitionKeyPath, builder.Resource); 392builder.Resource.Containers.Add(container); 448var container = new AzureCosmosDBContainerResource(name, containerName, partitionKeyPaths, builder.Resource); 450builder.Resource.Containers.Add(container); 465builder.Resource.UseDefaultAzureSku = true; 483if (!builder.Resource.InnerResource.IsVNextEmulator) 549var kv = builder.ApplicationBuilder.AddAzureKeyVault($"{builder.Resource.Name}-kv") 550.WithParentRelationship(builder.Resource); 558if (builder.Resource.IsEmulator) 560data.Model.Resources.Remove(kv.Resource); 595var azureResource = builder.Resource; 596azureResource.ConnectionStringSecretOutput = keyVaultBuilder.Resource.GetSecret($"connectionstrings--{azureResource.Name}"); 597azureResource.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)));

190if (builder.Resource.Annotations 192.Any(a => a.Resource.Name == resource.Resource.Name)) 195$"Origin resource '{resource.Resource.Name}' has already been added to Azure Front Door resource '{builder.Resource.Name}'. " + 199return 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)); 161var emulatorResource = new DurableTaskSchedulerEmulatorResource(builder.Resource); 177.Where(th => th.Parent == builder.Resource) 220var hub = new DurableTaskHubResource(name, builder.Resource); 232var url = builder.Resource.IsEmulator 289return 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);

79resource.KubernetesEnvironment = k8sEnvBuilder.Resource; 93resource.DefaultContainerRegistry = defaultRegistry.Resource; 94resource.Annotations.Add(new ContainerRegistryReferenceAnnotation(defaultRegistry.Resource)); 95k8sEnvBuilder.WithAnnotation(new ContainerRegistryReferenceAnnotation(defaultRegistry.Resource)); 100resource.Parameters["acrName"] = defaultRegistry.Resource.NameOutputReference; 179builder.Resource.NodePools.Add(config); 181var nodePool = new AksNodePoolResource(name, config, builder.Resource); 232builder.Resource.NodePools.RemoveAll(p => p.Mode is AksNodePoolMode.System); 233builder.Resource.NodePools.Insert(0, new AksNodePoolConfig("system", vmSize, minCount, maxCount, AksNodePoolMode.System)); 264builder.WithAnnotation(new AksSubnetAnnotation(subnet.Resource.Id), ResourceAnnotationMutationBehavior.Replace); 300builder.WithAnnotation(new AksSubnetAnnotation(subnet.Resource.Id)); 304builder.Resource.AksParent.NodePoolSubnets[builder.Resource.Name] = subnet.Resource.Id; 331if (builder.Resource.DefaultContainerRegistry is not null) 333builder.ApplicationBuilder.Resources.Remove(builder.Resource.DefaultContainerRegistry); 334builder.Resource.DefaultContainerRegistry = null; 340new ContainerRegistryReferenceAnnotation(registry.Resource), 346var staleAnnotations = builder.Resource.KubernetesEnvironment.Annotations 350builder.Resource.KubernetesEnvironment.Annotations.Remove(old); 353builder.Resource.KubernetesEnvironment.Annotations.Add( 354new ContainerRegistryReferenceAnnotation(registry.Resource)); 358builder.Resource.Parameters["acrName"] = registry.Resource.NameOutputReference; 428builder.Resource.GatewayApiEnabled = true; 429builder.Resource.ApplicationLoadBalancerEnabled = true; 445var existingDelegation = subnet.Resource.Annotations.OfType<AzureSubnetServiceDelegationAnnotation>().LastOrDefault(); 458builder.Resource, 459subnet.Resource.Id, 460subnet.Resource, 468builder.Resource.LoadBalancers.Add(lb); 505builder.Resource.OidcIssuerEnabled = enabled; 506builder.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);

27Assert.Equal("aks", aks.Resource.Name); 28Assert.Equal("{aks.outputs.id}", aks.Resource.Id.ValueExpression); 29Assert.Equal("{aks.outputs.clusterFqdn}", aks.Resource.ClusterFqdn.ValueExpression); 30Assert.Equal("{aks.outputs.oidcIssuerUrl}", aks.Resource.OidcIssuerUrl.ValueExpression); 32var manifest = await AzureManifestUtils.GetManifestWithBicep(aks.Resource); 45Assert.Equal(2, aks.Resource.NodePools.Count); 47Assert.Equal("gpu", gpuPool.Resource.Name); 48Assert.Equal("gpu", gpuPool.Resource.Config.Name); 49Assert.Equal("Standard_NC6s_v3", gpuPool.Resource.Config.VmSize); 50Assert.Equal(0, gpuPool.Resource.Config.MinCount); 51Assert.Equal(5, gpuPool.Resource.Config.MaxCount); 52Assert.Equal(AksNodePoolMode.User, gpuPool.Resource.Config.Mode); 53Assert.Same(aks.Resource, gpuPool.Resource.AksParent); 63Assert.Single(aks.Resource.NodePools); 64var defaultPool = aks.Resource.NodePools[0]; 79Assert.True(aks.Resource.OidcIssuerEnabled); 80Assert.True(aks.Resource.WorkloadIdentityEnabled); 81Assert.Null(aks.Resource.KubernetesVersion); 82Assert.False(aks.Resource.IsPrivateCluster); 83Assert.False(aks.Resource.ContainerInsightsEnabled); 84Assert.Null(aks.Resource.LogAnalyticsWorkspace); 94Assert.NotNull(aks.Resource.KubernetesEnvironment); 95Assert.Equal("aks", aks.Resource.KubernetesEnvironment.Name); 96Assert.True(aks.Resource.TryGetLastAnnotation<KubernetesEnvironmentAnnotation>(out var annotation)); 113Assert.Same(aks.Resource, computeEnvironment); 157Assert.True(aks.Resource.OidcIssuerEnabled); 158Assert.True(aks.Resource.WorkloadIdentityEnabled); 172Assert.True(project.Resource.TryGetLastAnnotation<AppIdentityAnnotation>(out var appIdentity)); 173Assert.Same(identity.Resource, appIdentity.IdentityResource); 181Assert.IsAssignableFrom<IAzureComputeEnvironmentResource>(aks.Resource); 189Assert.IsAssignableFrom<IAzureNspAssociationTarget>(aks.Resource); 223Assert.True(aks.Resource.TryGetLastAnnotation<AksSubnetAnnotation>(out _)); 226Assert.Single(aks.Resource.NodePoolSubnets); 227Assert.True(aks.Resource.NodePoolSubnets.ContainsKey("gpu")); 230Assert.True(gpuPool.Resource.TryGetLastAnnotation<AksSubnetAnnotation>(out _)); 249Assert.False(aks.Resource.TryGetLastAnnotation<AksSubnetAnnotation>(out _)); 252Assert.Single(aks.Resource.NodePoolSubnets); 253Assert.True(aks.Resource.NodePoolSubnets.ContainsKey("gpu")); 267Assert.True(container.Resource.TryGetLastAnnotation<KubernetesNodePoolAnnotation>(out var affinity)); 268Assert.Same(gpuPool.Resource, affinity.NodePool); 282Assert.Equal(3, aks.Resource.NodePools.Count); 283Assert.Equal("cpu", pool1.Resource.Name); 284Assert.Equal("gpu", pool2.Resource.Name); 295Assert.NotNull(aks.Resource.DefaultContainerRegistry); 296Assert.Equal("aks-acr", aks.Resource.DefaultContainerRegistry.Name); 311Assert.Null(aks.Resource.DefaultContainerRegistry); 314Assert.True(aks.Resource.TryGetLastAnnotation<ContainerRegistryReferenceAnnotation>(out var annotation)); 315Assert.Same(explicitAcr.Resource, annotation.Registry); 330Assert.True(aks.Resource.TryGetLastAnnotation<ContainerRegistryReferenceAnnotation>(out var aksAnnotation)); 331Assert.Same(aks.Resource.DefaultContainerRegistry, aksAnnotation.Registry); 333Assert.True(aks.Resource.KubernetesEnvironment 335Assert.Same(aks.Resource.DefaultContainerRegistry, annotation.Registry); 346Assert.Single(aks.Resource.NodePools, p => p.Mode is AksNodePoolMode.System); 347var systemPool = aks.Resource.NodePools.First(p => p.Mode is AksNodePoolMode.System); 362var systemPool = aks.Resource.NodePools.First(p => p.Mode is AksNodePoolMode.System); 376Assert.Equal("Standard_D2s_v5", aks.Resource.NodePools[0].VmSize); 382Assert.Single(aks.Resource.NodePools, p => p.Mode is AksNodePoolMode.System); 383Assert.Equal("Standard_B2s", aks.Resource.NodePools.First(p => p.Mode is AksNodePoolMode.System).VmSize); 395Assert.Single(aks.Resource.NodePools, p => p.Mode is AksNodePoolMode.System); 396var systemPool = aks.Resource.NodePools.First(p => p.Mode is AksNodePoolMode.System); 413Assert.Equal(2, aks.Resource.NodePools.Count); 414Assert.Equal("Standard_B2s", aks.Resource.NodePools.First(p => p.Mode is AksNodePoolMode.System).VmSize); 415Assert.Equal("gpu", gpuPool.Resource.Name); 435var manifest = await AzureManifestUtils.GetManifestWithBicep(aks.Resource); 454var manifest = await AzureManifestUtils.GetManifestWithBicep(aks.Resource); 469Assert.True(aks.Resource.GatewayApiEnabled); 470Assert.True(aks.Resource.ApplicationLoadBalancerEnabled); 471Assert.True(aks.Resource.RequiresPreviewIngressApi); 474Assert.True(albSubnet.Resource.TryGetLastAnnotation<AzureSubnetServiceDelegationAnnotation>(out var delegation)); 489Assert.Same(aks.Resource, lb.Resource.Parent); 490Assert.Equal("alb-lb", lb.Resource.AlbName); 491Assert.True(lb.Resource.TryGetAnnotationsOfType<PipelineStepAnnotation>(out var stepAnnotations)); 508Assert.NotSame(lb1.Resource, lb2.Resource); 509Assert.Equal("alb-lb1", lb1.Resource.AlbName); 510Assert.Equal("alb-lb2", lb2.Resource.AlbName); 513Assert.True(lb1.Resource.TryGetAnnotationsOfType<PipelineStepAnnotation>(out var lb1Steps)); 514Assert.True(lb2.Resource.TryGetAnnotationsOfType<PipelineStepAnnotation>(out var lb2Steps)); 520Assert.True(alb1.Resource.TryGetLastAnnotation<AzureSubnetServiceDelegationAnnotation>(out _)); 521Assert.True(alb2.Resource.TryGetLastAnnotation<AzureSubnetServiceDelegationAnnotation>(out _)); 540var delegation = Assert.Single(albSubnet.Resource.Annotations.OfType<AzureSubnetServiceDelegationAnnotation>()); 544Assert.Equal("Microsoft.Netapp/volumes", lb.Resource.DisplacedDelegationServiceName); 560var delegation = Assert.Single(albSubnet.Resource.Annotations.OfType<AzureSubnetServiceDelegationAnnotation>()); 564Assert.Null(lb1.Resource.DisplacedDelegationServiceName); 565Assert.Null(lb2.Resource.DisplacedDelegationServiceName); 580var delegation = Assert.Single(albSubnet.Resource.Annotations.OfType<AzureSubnetServiceDelegationAnnotation>()); 582Assert.Null(lb.Resource.DisplacedDelegationServiceName); 602var delegation = Assert.Single(albSubnet.Resource.Annotations.OfType<AzureSubnetServiceDelegationAnnotation>()); 606Assert.Equal("Microsoft.Sql/managedInstances", lb.Resource.DisplacedDelegationServiceName);

24Assert.IsType<KubernetesHelmChartResource>(chart.Resource); 25Assert.IsType<KubernetesEnvironmentResource>(chart.Resource.Parent); 36Assert.Equal("cert-manager", chart.Resource.Name); 37Assert.Equal("oci://quay.io/jetstack/charts/cert-manager", chart.Resource.ChartReference); 38Assert.Equal("1.17.0", chart.Resource.ChartVersion); 51Assert.Equal(2, chart.Resource.Values.Count); 52Assert.Equal("true", chart.Resource.Values["crds.enabled"]); 53Assert.Equal("true", chart.Resource.Values["config.enableGatewayAPI"]); 65Assert.Equal("ingress-nginx", chart.Resource.Namespace); 77Assert.Equal("my-nginx", chart.Resource.ReleaseName); 89Assert.True(chart.Resource.DestroyOnUninstall); 100Assert.False(chart.Resource.DestroyOnUninstall);

34Assert.Single(aks.Resource.NodePools); 35Assert.Equal(AksNodePoolMode.System, aks.Resource.NodePools[0].Mode); 43Assert.Equal(2, aks.Resource.NodePools.Count); 44var workloadPool = aks.Resource.NodePools.First(p => p.Mode is AksNodePoolMode.User); 48Assert.True(container.Resource.TryGetLastAnnotation<KubernetesNodePoolAnnotation>(out var affinity)); 67Assert.Equal(2, aks.Resource.NodePools.Count); // system + gpu 68Assert.DoesNotContain(aks.Resource.NodePools, p => p.Name == "workload"); 71Assert.True(container.Resource.TryGetLastAnnotation<KubernetesNodePoolAnnotation>(out var affinity)); 92Assert.True(container.Resource.TryGetLastAnnotation<KubernetesNodePoolAnnotation>(out var affinity)); 108Assert.True(container.Resource.TryGetLastAnnotation<DeploymentTargetAnnotation>(out var target)); 112Assert.Same(aks.Resource, target.ComputeEnvironment); 143Assert.Same(enva.Resource, enva.Resource.KubernetesEnvironment.OwningComputeEnvironment); 144Assert.Same(envb.Resource, envb.Resource.KubernetesEnvironment.OwningComputeEnvironment); 145Assert.True(enva.Resource.TryGetLastAnnotation<KubernetesEnvironmentAnnotation>(out var _)); 146Assert.True(envb.Resource.TryGetLastAnnotation<KubernetesEnvironmentAnnotation>(out var _)); 152Assert.True(cache.Resource.TryGetLastAnnotation<DeploymentTargetAnnotation>(out var cacheTarget), 154Assert.Same(enva.Resource, cacheTarget.ComputeEnvironment); 156Assert.True(api.Resource.TryGetLastAnnotation<DeploymentTargetAnnotation>(out var apiTarget), 158Assert.Same(enva.Resource, apiTarget.ComputeEnvironment); 161Assert.True(other.Resource.TryGetLastAnnotation<DeploymentTargetAnnotation>(out var otherTarget), 163Assert.Same(envb.Resource, otherTarget.ComputeEnvironment); 396aks.Resource.Outputs["name"] = clusterName; 399aks.Resource.AzCliPathResolverForTesting = () => "/usr/bin/az"; 400aks.Resource.AzCommandRunnerForTesting = (path, arguments, logger) => 424foreach (var annotation in aks.Resource.Annotations.OfType<PipelineStepAnnotation>()) 429Resource = aks.Resource 439Assert.NotNull(aks.Resource.ProvisioningTaskCompletionSource); 440aks.Resource.ProvisioningTaskCompletionSource.TrySetResult(); 469await File.ReadAllTextAsync(aks.Resource.KubernetesEnvironment.KubeConfigPath!, TestContext.Current.CancellationToken)); 496aks.Resource.Outputs["name"] = clusterName; 499aks.Resource.AzCliPathResolverForTesting = () => "/usr/bin/az"; 500aks.Resource.AzCommandRunnerForTesting = (path, arguments, logger) => 517foreach (var annotation in aks.Resource.Annotations.OfType<PipelineStepAnnotation>()) 522Resource = aks.Resource 528Assert.NotNull(aks.Resource.ProvisioningTaskCompletionSource); 529aks.Resource.ProvisioningTaskCompletionSource.TrySetResult(); 707aks.Resource.Scope = new AzureBicepResourceScope(scopeResourceGroup, scopeSubscriptionId); 708aks.Resource.Outputs["name"] = clusterName; 711aks.Resource.AzCliPathResolverForTesting = () => "/usr/bin/az"; 712aks.Resource.AzCommandRunnerForTesting = (path, arguments, logger) => 729foreach (var annotation in aks.Resource.Annotations.OfType<PipelineStepAnnotation>()) 734Resource = aks.Resource 740Assert.NotNull(aks.Resource.ProvisioningTaskCompletionSource); 741aks.Resource.ProvisioningTaskCompletionSource.TrySetResult(); 776aks.Resource.Scope = AzureBicepResourceScope.CreateForSubscription(subscriptionId); 777aks.Resource.Outputs["name"] = clusterName; 780aks.Resource.AzCliPathResolverForTesting = () => "/usr/bin/az"; 781aks.Resource.AzCommandRunnerForTesting = (path, arguments, logger) => 798foreach (var annotation in aks.Resource.Annotations.OfType<PipelineStepAnnotation>()) 803Resource = aks.Resource 809Assert.NotNull(aks.Resource.ProvisioningTaskCompletionSource); 810aks.Resource.ProvisioningTaskCompletionSource.TrySetResult();

49Assert.IsType<KubernetesIngressResource>(ingress.Resource); 50Assert.IsType<KubernetesEnvironmentResource>(ingress.Resource.Parent); 60Assert.IsType<KubernetesGatewayResource>(gateway.Resource); 61Assert.IsType<KubernetesEnvironmentResource>(gateway.Resource.Parent); 76Assert.NotNull(gateway.Resource.GatewayClassName); 77var resolvedClass = await gateway.Resource.GatewayClassName!.GetValueAsync(default); 80Assert.True(gateway.Resource.GatewayAnnotations.TryGetValue("alb.networking.azure.io/alb-name", out var albNameRef)); 83Assert.True(gateway.Resource.GatewayAnnotations.TryGetValue("alb.networking.azure.io/alb-namespace", out var albNsRef)); 99Assert.NotNull(ingress.Resource.IngressClassName); 100var resolvedClass = await ingress.Resource.IngressClassName!.GetValueAsync(default); 103Assert.True(ingress.Resource.IngressAnnotations.TryGetValue("alb.networking.azure.io/alb-name", out var albNameRef)); 106Assert.True(ingress.Resource.IngressAnnotations.TryGetValue("alb.networking.azure.io/alb-namespace", out var albNsRef)); 126Assert.NotNull(gateway.Resource.GatewayClassName); 127var resolvedClass = await gateway.Resource.GatewayClassName!.GetValueAsync(default); 130Assert.True(gateway.Resource.GatewayAnnotations.ContainsKey("alb.networking.azure.io/alb-name")); 131Assert.True(gateway.Resource.GatewayAnnotations.ContainsKey("alb.networking.azure.io/alb-namespace"));

24Assert.Same(aks.Resource.KubernetesEnvironment, volume.Resource.Parent); 58var expectedPath = KubernetesPersistentVolumeLocalStorage.GetPath(store, volume.Resource); 60executable.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}");

232builder.Resource.WorkloadManagedIdentityType = ManagedServiceIdentityType.None; 233builder.Resource.WorkloadUserAssignedIdentities.Clear(); 254builder.Resource.WorkloadManagedIdentityType = ManagedServiceIdentityType.SystemAssigned; 255builder.Resource.WorkloadUserAssignedIdentities.Clear(); 279builder.Resource.AddWorkloadUserAssignedIdentity(identity.Resource); 305builder.Resource.References.Add(identity.Resource); 307new AzureSandboxGroupAcrPullIdentityAnnotation(identity.Resource),

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

49if (!ShouldPrepareIdentity(context.PipelineContext.ExecutionContext, builder.Resource)) 58Name = $"prepare-cross-scope-acr-pull-identity-{builder.Resource.Name}", 59Description = $"Prepares the ACR pull identity for {builder.Resource.Name}.", 110if (!ShouldPrepareIdentity(context.ExecutionContext, builder.Resource) || 111builder.Resource.ContainerRegistry is not AzureContainerRegistryResource registry) 119var identityName = $"{builder.Resource.Name}-mi"; 123$"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."); 147builder.Resource.Annotations.Add(createIdentityAnnotation(identity)); 148if (builder.Resource is AzureBicepResource environment)

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

183var queue = new AzureServiceBusQueueResource(name, queueName, builder.Resource); 184builder.Resource.Queues.Add(queue); 203configure(builder.Resource); 269var topic = new AzureServiceBusTopicResource(name, topicName, builder.Resource); 270builder.Resource.Topics.Add(topic); 289configure(builder.Resource); 311if (builder.Resource.Topics.FirstOrDefault(x => x.Name == topicName) is { } existingResource) 342var subscription = new AzureServiceBusSubscriptionResource(name, subscriptionName, builder.Resource); 343builder.Resource.Subscriptions.Add(subscription); 362configure(builder.Resource); 400if (builder.Resource.IsEmulator) 416var passwordParameter = ParameterResourceBuilderExtensions.CreateDefaultPasswordParameter(builder.ApplicationBuilder, $"{builder.Resource.Name}-sql-pwd", minLower: 1, minUpper: 1, minNumeric: 1); 431.AddContainer($"{builder.Resource.Name}-mssql", 445var sqlEndpoint = sqlServerResource.Resource.GetEndpoint("tcp"); 452var surrogate = new AzureServiceBusEmulatorResource(builder.Resource); 467var customConfigFile = builder.Resource.Annotations.OfType<ConfigFileAnnotation>().FirstOrDefault(); 480var tempConfig = JsonNode.Parse(CreateEmulatorConfigJson(builder.Resource)); 488var configJsonAnnotations = builder.Resource.Annotations.OfType<ConfigJsonAnnotation>();

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); 127var (manifest, bicep) = await AzureManifestUtils.GetManifestWithBicep(appInsights.Resource);

42_ = appServiceEnvironment.Resource.AddAsExistingResource(infra); 45var (manifest, bicep) = await AzureManifestUtils.GetManifestWithBicep(module.Resource, skipPreparer: true); 59var registry = appServiceEnvironment.Resource.ContainerRegistry; 74var registry = appServiceEnvironment.Resource.ContainerRegistry; 75Assert.Same(acr.Resource, registry); 97var exception = Assert.Throws<InvalidOperationException>(() => appServiceEnvironment.Resource.ContainerRegistry); 126Assert.Same(finalRegistry.Resource, roles.TargetAzureResource); 128var (_, envBicep) = await AzureManifestUtils.GetManifestWithBicep(env.Resource, skipPreparer: true); 175Assert.Same(identity.Resource, Assert.Single(model.Resources.OfType<AzureUserAssignedIdentityResource>(), resource => resource.Name == "env-mi")); 211Assert.Same(registry.Resource, rolesEast.TargetAzureResource); 212Assert.Same(registry.Resource, rolesWest.TargetAzureResource);

49Assert.Same(env.Resource, target.ComputeEnvironment); 102var target = project.Resource.GetDeploymentTargetAnnotation(); 106var (_, virtualNetworkBicep) = await GetManifestWithBicep(vnet.Resource); 142var target = project.Resource.GetDeploymentTargetAnnotation(); 146var (_, virtualNetworkBicep) = await GetManifestWithBicep(vnet.Resource); 184var target = project.Resource.GetDeploymentTargetAnnotation(); 330project2.Resource.TryGetLastAnnotation<DeploymentTargetAnnotation>(out var target); 374SetFoundryProjectOutputs(project.Resource); 376web.Resource.TryGetLastAnnotation<DeploymentTargetAnnotation>(out var target); 505Assert.NotNull(env.Resource.NameOutputReference); 506Assert.Equal("name", env.Resource.NameOutputReference.Name); 507Assert.Same(env.Resource, env.Resource.NameOutputReference.Resource); 597var (manifest, bicep) = await GetManifestWithBicep(env.Resource); 617var (manifest, bicep) = await GetManifestWithBicep(env.Resource); 648var (manifest, bicep) = await GetManifestWithBicep(env.Resource); 666var steps = await CreateStepsAsync(app, env.Resource); 678Assert.IsAssignableFrom<IAzureComputeEnvironmentResource>(env.Resource); 679Assert.IsAssignableFrom<IComputeEnvironmentResource>(env.Resource); 842project2.Resource.TryGetLastAnnotation<DeploymentTargetAnnotation>(out var target); 878project2.Resource.TryGetLastAnnotation<DeploymentTargetAnnotation>(out var target); 914project2.Resource.TryGetLastAnnotation<DeploymentTargetAnnotation>(out var target); 952project2.Resource.TryGetLastAnnotation<DeploymentTargetAnnotation>(out var target); 987project2.Resource.TryGetLastAnnotation<DeploymentTargetAnnotation>(out var target); 1063project.Resource.TryGetLastAnnotation<DeploymentTargetAnnotation>(out var target); 1094container.Resource.TryGetLastAnnotation<DeploymentTargetAnnotation>(out var target); 1118var endpointReferenceEx = env.Resource.GetHostAddressExpression(project.GetEndpoint("http")); 1124Assert.Equal(env.Resource, output.Resource); 1142env.Resource.Outputs["webSiteSuffix"] = "website123"; 1143env.Resource.ProvisioningTaskCompletionSource?.TrySetResult(); 1150var expression = env.Resource.GetEndpointPropertyExpression(project.GetEndpoint("http").Property(property)); 1280project.Resource.TryGetLastAnnotation<DeploymentTargetAnnotation>(out var target); 1311project.Resource.TryGetLastAnnotation<DeploymentTargetAnnotation>(out var target); 1343project.Resource.TryGetLastAnnotation<DeploymentTargetAnnotation>(out var target); 1372featureFlag.Resource,

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

27Assert.Equal("content", bicepResource.Resource.TemplateString); 28Assert.Equal("value1", bicepResource.Resource.Parameters["param1"]); 29Assert.Equal("value2", bicepResource.Resource.Parameters["param2"]); 92if (azureResourceBuilder.Resource is not AzureProvisioningResource bicepResource) 113if (azureResourceBuilder.Resource is not AzureProvisioningResource bicepResource) 131bicepResource.Resource.Outputs["resourceEndpoint"] = "https://myendpoint"; 143bicepResource.Resource.SecretOutputs["connectionString"] = "https://myendpoint;Key=43"; 189bicepResource.Resource.TempDirectory = Environment.CurrentDirectory; 191var manifest = await ManifestUtils.GetManifest(bicepResource.Resource); 224var annotation = bicepResource.Resource.Annotations.OfType<Aspire.Hosting.Pipelines.PipelineStepAnnotation>().FirstOrDefault(); 233Resource = bicepResource.Resource

45_ = containerAppEnvironment.Resource.AddAsExistingResource(infra); 48var (manifest, bicep) = await AzureManifestUtils.GetManifestWithBicep(module.Resource, skipPreparer: true); 75Assert.True(logAnalyticsWorkspace.Resource.TryGetLastAnnotation<ExistingAzureResourceAnnotation>(out var existingAnnotation)); 76Assert.Equal(lawName.Resource, existingAnnotation.Name); 77Assert.Equal(lawResourceGroup.Resource, existingAnnotation.ResourceGroup); 80Assert.True(containerAppEnvironment.Resource.TryGetLastAnnotation<AzureLogAnalyticsWorkspaceReferenceAnnotation>(out var workspaceRef)); 81Assert.Same(logAnalyticsWorkspace.Resource, workspaceRef.Workspace); 84var (manifest, bicep) = await AzureManifestUtils.GetManifestWithBicep(containerAppEnvironment.Resource); 98var registry = containerAppEnvironment.Resource.ContainerRegistry; 113var registry = containerAppEnvironment.Resource.ContainerRegistry; 114Assert.Same(acr.Resource, registry); 136var exception = Assert.Throws<InvalidOperationException>(() => containerAppEnvironment.Resource.ContainerRegistry); 152var (_, envBicep) = await AzureManifestUtils.GetManifestWithBicep(containerAppEnvironment.Resource); 153var (_, vnetBicep) = await AzureManifestUtils.GetManifestWithBicep(vnet.Resource); 174var (manifest, bicep) = await AzureManifestUtils.GetManifestWithBicep(env.Resource); 199var (manifest, bicep) = await AzureManifestUtils.GetManifestWithBicep(env.Resource); 219var (manifest, bicep) = await AzureManifestUtils.GetManifestWithBicep(env.Resource); 250var (manifest, bicep) = await AzureManifestUtils.GetManifestWithBicep(env.Resource); 279Assert.Same(finalRegistry.Resource, roles.TargetAzureResource); 281var (_, envBicep) = await AzureManifestUtils.GetManifestWithBicep(env.Resource, skipPreparer: true); 421Assert.Same(identity.Resource, Assert.Single(model.Resources.OfType<AzureUserAssignedIdentityResource>(), resource => resource.Name == "env-mi")); 456Assert.Same(registry.Resource, rolesEast.TargetAzureResource); 457Assert.Same(registry.Resource, rolesWest.TargetAzureResource); 475() => AzureManifestUtils.GetManifestWithBicep(env.Resource)); 504() => AzureManifestUtils.GetManifestWithBicep(env.Resource, skipPreparer: true)); 528() => AzureManifestUtils.GetManifestWithBicep(env.Resource)); 601Assert.Same(environment.Resource, api.GetDeploymentTargetAnnotation()!.ComputeEnvironment);

113Assert.Same(env.Resource, target.ComputeEnvironment); 156SetFoundryProjectOutputs(project.Resource); 158var target = web.Resource.GetDeploymentTargetAnnotation(); 208Assert.Same(infra.Resource, target.ComputeEnvironment); 239Assert.Same(env.Resource, target?.ComputeEnvironment); 358.WithEnvironment("DATABASE_URL", pgContainer.Resource.UriExpression); 890var target = container.Resource.GetDeploymentTargetAnnotation()?.DeploymentTarget as AzureBicepResource; 1558var (manifest, bicep) = await GetManifestWithBicep(sql.Resource); 1675var managedEnvironment = (ContainerAppManagedEnvironment)env.Resource.AddAsExistingResource(infra); 1687var (manifest, bicep) = await GetManifestWithBicep(azResource.Resource); 1777Assert.IsAssignableFrom<IAzureComputeEnvironmentResource>(env.Resource); 1778Assert.IsAssignableFrom<IComputeEnvironmentResource>(env.Resource); 2692var dockerFileAnnotation = c.Resource.Annotations.OfType<DockerfileBuildAnnotation>().Single(); 2756var endpointReferenceEx = env.Resource.GetHostAddressExpression(project.GetEndpoint("http")); 2762Assert.Equal(env.Resource, output.Resource); 2780env.Resource.Outputs["AZURE_CONTAINER_APPS_ENVIRONMENT_DEFAULT_DOMAIN"] = "example.azurecontainerapps.io"; 2781env.Resource.ProvisioningTaskCompletionSource?.TrySetResult(); 2788var expression = env.Resource.GetEndpointPropertyExpression(project.GetEndpoint("http").Property(property)); 2873var containerRegistryInterface = env.Resource as IContainerRegistry; 2951var webappAcaTarget = webappAcaResource.GetDeploymentTargetAnnotation(aca.Resource); 2953Assert.Same(aca.Resource, webappAcaTarget.ComputeEnvironment); 2957var webappServiceTarget = webappServiceResource.GetDeploymentTargetAnnotation(appService.Resource); 2959Assert.Same(appService.Resource, webappServiceTarget.ComputeEnvironment); 2963var containerAcaTarget = containerAcaResource.GetDeploymentTargetAnnotation(aca.Resource); 2965Assert.Same(aca.Resource, containerAcaTarget.ComputeEnvironment); 2971var containerAppServiceAcaTarget = containerAppServiceResource.GetDeploymentTargetAnnotation(aca.Resource); 2975Assert.Null(webappAcaResource.GetDeploymentTargetAnnotation(appService.Resource)); 2976Assert.Null(webappServiceResource.GetDeploymentTargetAnnotation(aca.Resource)); 2977Assert.Null(containerAcaResource.GetDeploymentTargetAnnotation(appService.Resource)); 3055featureFlag.Resource, 3096featureFlag.Resource, 3098ReferenceExpression.Create($"prefix-{connectionPrefix.Resource}-enabled"), 3137innerFlag.Resource, 3143outerFlag.Resource, 3181var steps = await CreateStepsAsync(app, env.Resource);

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

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

38var endpointAnnotation = cosmos.Resource.Annotations.OfType<EndpointAnnotation>().FirstOrDefault(); 59var containerImageAnnotation = cosmos.Resource.Annotations.OfType<ContainerImageAnnotation>().FirstOrDefault(); 76var config = await EnvironmentVariableEvaluator.GetEnvironmentVariablesAsync(cosmos.Resource, DistributedApplicationOperation.Run, TestServiceProvider.Instance); 107Assert.Equal("{cosmos.outputs.connectionString}", cosmos.Resource.ConnectionStringExpression.ValueExpression); 110Assert.Equal("AccountEndpoint={cosmos.outputs.connectionString};Database=db1", db1.Resource.ConnectionStringExpression.ValueExpression); 111Assert.Equal("AccountEndpoint={cosmos.outputs.connectionString};Database=db1;Container=container1", container1.Resource.ConnectionStringExpression.ValueExpression); 137Assert.DoesNotContain(";Database=db1", cosmos.Resource.ConnectionStringExpression.ValueExpression); 138Assert.DoesNotContain(";Database=db1;Container=container1", cosmos.Resource.ConnectionStringExpression.ValueExpression); 139Assert.Contains(";Database=db1", db1.Resource.ConnectionStringExpression.ValueExpression); 140Assert.Contains(";Database=db1;Container=container1", container1.Resource.ConnectionStringExpression.ValueExpression); 142Assert.Contains(";Database=db", db2.Resource.ConnectionStringExpression.ValueExpression); 143Assert.Contains(";Database=db;Container=container", container2.Resource.ConnectionStringExpression.ValueExpression); 156((IResourceWithAzureFunctionsConfig)cosmos.Resource).ApplyAzureFunctionsConfiguration(target, "cosmos"); 163((IResourceWithAzureFunctionsConfig)db1.Resource).ApplyAzureFunctionsConfiguration(target, "db1"); 172((IResourceWithAzureFunctionsConfig)container1.Resource).ApplyAzureFunctionsConfiguration(target, "container1"); 207var manifest = await GetManifestWithBicep(model, cosmos.Resource); 257Assert.Equal("{cosmos-kv.secrets.connectionstrings--cosmos}", cosmos.Resource.ConnectionStringExpression.ValueExpression); 258Assert.Equal("{cosmos-kv.secrets.connectionstrings--db1}", database.Resource.ConnectionStringExpression.ValueExpression); 259Assert.Equal("{cosmos-kv.secrets.connectionstrings--container1}", container.Resource.ConnectionStringExpression.ValueExpression); 261var manifest = await GetManifestWithBicep(cosmos.Resource); 276Assert.True(cosmos.Resource.IsContainer()); 278var csExpr = cosmos.Resource.ConnectionStringExpression; 284Assert.Equal(cs, await ((IResourceWithConnectionString)cosmos.Resource).GetConnectionStringAsync()); 297Assert.True(cosmos.Resource.IsContainer()); 299var csExpr = cosmos.Resource.ConnectionStringExpression; 305Assert.Equal(cs, await ((IResourceWithConnectionString)cosmos.Resource).GetConnectionStringAsync()); 375var (manifest, bicep) = await AzureManifestUtils.GetManifestWithBicep(cosmos.Resource); 386var connectionStringResource = (IResourceWithConnectionString)cosmos.Resource; 388Assert.Equal("cosmos", cosmos.Resource.Name); 406cosmos.Resource.Outputs["connectionString"] = "mycosmosconnectionstring"; 408var manifest = await AzureManifestUtils.GetManifestWithBicep(cosmos.Resource); 429var connectionStringResource = (IResourceWithConnectionString)cosmos.Resource; 431Assert.Equal("cosmos", cosmos.Resource.Name); 469kv.Resource.SecretResolver = (secretRef, _) => 479var (manifest, bicep) = await AzureManifestUtils.GetManifestWithBicep(cosmos.Resource); 490var connectionStringResource = (IResourceWithConnectionString)cosmos.Resource; 492Assert.Equal("cosmos", cosmos.Resource.Name); 510cosmos.Resource.Outputs["connectionString"] = "mycosmosconnectionstring"; 512var manifest = await AzureManifestUtils.GetManifestWithBicep(cosmos.Resource); 531var connectionStringResource = (IResourceWithConnectionString)cosmos.Resource; 533Assert.Equal("cosmos", cosmos.Resource.Name); 544var manifest = await AzureManifestUtils.GetManifestWithBicep(cosmos.Resource); 556Assert.True(cosmos.Resource.IsEmulator()); 557Assert.Contains(cosmos.Resource.Annotations, a => a is EmulatorResourceAnnotation); 568Assert.True(cosmos.Resource.IsEmulator()); 569Assert.Contains(cosmos.Resource.Annotations, a => a is EmulatorResourceAnnotation); 599_ = cosmosdb.Resource.AddAsExistingResource(infra); 602var (manifest, bicep) = await AzureManifestUtils.GetManifestWithBicep(module.Resource, skipPreparer: true); 629Assert.NotNull(cosmos.Resource.ConnectionStringSecretOutput); 630Assert.Same(cosmos.Resource, cosmos.Resource.ConnectionStringSecretOutput.SecretOwner); 632Assert.NotNull(cosmos.Resource.PrimaryAccessKeySecretOutput); 633Assert.Same(cosmos.Resource, cosmos.Resource.PrimaryAccessKeySecretOutput.SecretOwner); 636var references = ((IValueWithReferences)cosmos.Resource.ConnectionStringSecretOutput).References.ToList(); 637Assert.Contains(cosmos.Resource, references); 638Assert.Contains(cosmos.Resource.ConnectionStringSecretOutput.Resource, references); 649Assert.Contains(cosmos.Resource.Annotations, a => a is HttpsCertificateConfigurationCallbackAnnotation); 660Assert.DoesNotContain(cosmos.Resource.Annotations, a => a is HttpsCertificateConfigurationCallbackAnnotation); 671cosmos.Resource.Annotations.OfType<HttpsCertificateConfigurationCallbackAnnotation>()); 679Resource = cosmos.Resource, 706cosmos.Resource.Annotations.OfType<CertificateTrustConfigurationCallbackAnnotation>()); 714Resource = cosmos.Resource, 738cosmos.Resource.Annotations.OfType<HttpsCertificateConfigurationCallbackAnnotation>()); 747Resource = cosmos.Resource, 793var emulatorEndpoint = Assert.Single(cosmos.Resource.Annotations.OfType<EndpointAnnotation>(), e => e.Name == "emulator"); 825var emulatorEndpoint = Assert.Single(cosmos.Resource.Annotations.OfType<EndpointAnnotation>(), e => e.Name == "emulator"); 854var dataExplorerEndpoint = Assert.Single(cosmos.Resource.Annotations.OfType<EndpointAnnotation>(), e => e.Name == "data-explorer"); 884var dataExplorerEndpoint = Assert.Single(cosmos.Resource.Annotations.OfType<EndpointAnnotation>(), e => e.Name == "data-explorer"); 895var image = Assert.Single(cosmos.Resource.Annotations.OfType<ContainerImageAnnotation>()); 910var image = Assert.Single(cosmos.Resource.Annotations.OfType<ContainerImageAnnotation>()); 923var image = Assert.Single(cosmos.Resource.Annotations.OfType<ContainerImageAnnotation>()); 937var mount = Assert.Single(cosmos.Resource.Annotations.OfType<ContainerMountAnnotation>()); 944var config = await EnvironmentVariableEvaluator.GetEnvironmentVariablesAsync(cosmos.Resource, DistributedApplicationOperation.Run, TestServiceProvider.Instance); 956var mount = Assert.Single(cosmos.Resource.Annotations.OfType<ContainerMountAnnotation>()); 961var config = await EnvironmentVariableEvaluator.GetEnvironmentVariablesAsync(cosmos.Resource, DistributedApplicationOperation.Run, TestServiceProvider.Instance); 996var endpoint = Assert.Single(cosmos.Resource.Annotations.OfType<EndpointAnnotation>(), e => e.Name == "data-explorer"); 1001var config = await EnvironmentVariableEvaluator.GetEnvironmentVariablesAsync(cosmos.Resource, DistributedApplicationOperation.Run, TestServiceProvider.Instance); 1015var csExpr = cosmos.Resource.ConnectionStringExpression; 1030var config = await EnvironmentVariableEvaluator.GetEnvironmentVariablesAsync(cosmos.Resource, DistributedApplicationOperation.Run, TestServiceProvider.Instance); 1043var config = await EnvironmentVariableEvaluator.GetEnvironmentVariablesAsync(cosmos.Resource, DistributedApplicationOperation.Run, TestServiceProvider.Instance); 1054var healthEndpoint = Assert.Single(cosmos.Resource.Annotations.OfType<EndpointAnnotation>(), e => e.Name == "emulatorhealth"); 1059Assert.Contains(cosmos.Resource.Annotations, a => a is HealthCheckAnnotation); 1069Assert.Contains(cosmos.Resource.Annotations, a => a is HealthCheckAnnotation hc && hc.Key == "cosmos_check"); 1080var mount = Assert.Single(cosmos.Resource.Annotations.OfType<ContainerMountAnnotation>()); 1093var config = await EnvironmentVariableEvaluator.GetEnvironmentVariablesAsync(cosmos.Resource, DistributedApplicationOperation.Run, TestServiceProvider.Instance); 1105var endpoint = Assert.Single(cosmos.Resource.Annotations.OfType<EndpointAnnotation>(), e => e.Name == "data-explorer"); 1122() => builder.Eventing.PublishAsync(new ResourceReadyEvent(cosmos.Resource, app.Services))); 1139await builder.Eventing.PublishAsync(new ConnectionStringAvailableEvent(cosmos.Resource, app.Services)); 1182Assert.False(cosmos.Resource.IsEmulator); 1183Assert.DoesNotContain(cosmos.Resource.Annotations, a => a is ContainerImageAnnotation); 1184Assert.DoesNotContain(cosmos.Resource.Annotations, a => a is EmulatorResourceAnnotation); 1185Assert.DoesNotContain(cosmos.Resource.Annotations, a => a is ContainerMountAnnotation); 1195Assert.False(cosmos.Resource.IsEmulator); 1196Assert.DoesNotContain(cosmos.Resource.Annotations, a => a is ContainerImageAnnotation); 1197Assert.DoesNotContain(cosmos.Resource.Annotations, a => a is EmulatorResourceAnnotation); 1198Assert.DoesNotContain(cosmos.Resource.Annotations, a => a is ContainerMountAnnotation); 1233cosmos.Resource, 1236foreach (var callback in cosmos.Resource.Annotations.OfType<ResourceUrlsCallbackAnnotation>()) 1258cosmos.Resource, 1261foreach (var callback in cosmos.Resource.Annotations.OfType<ResourceUrlsCallbackAnnotation>())

174var dockerFileAnnotation = c.Resource.Annotations.OfType<DockerfileBuildAnnotation>().Single(); 297Assert.Equal("testregistry", containerAppEnv.Resource.Outputs["AZURE_CONTAINER_REGISTRY_NAME"]); 298Assert.Equal("testregistry.azurecr.io", containerAppEnv.Resource.Outputs["AZURE_CONTAINER_REGISTRY_ENDPOINT"]); 299Assert.Equal(GetTestResourceId("/providers/Microsoft.ManagedIdentity/userAssignedIdentities/test-identity"), containerAppEnv.Resource.Outputs["AZURE_CONTAINER_REGISTRY_MANAGED_IDENTITY_ID"]); 300Assert.Equal("test.westus.azurecontainerapps.io", containerAppEnv.Resource.Outputs["AZURE_CONTAINER_APPS_ENVIRONMENT_DEFAULT_DOMAIN"]); 301Assert.Equal($"/subscriptions/{TestSubscriptionId}/resourceGroups/{TestResourceGroupName}/providers/Microsoft.App/managedEnvironments/testenv", containerAppEnv.Resource.Outputs["AZURE_CONTAINER_APPS_ENVIRONMENT_ID"]); 357Assert.Equal("testregistry", containerAppEnv.Resource.Outputs["AZURE_CONTAINER_REGISTRY_NAME"]); 358Assert.Equal("testregistry.azurecr.io", containerAppEnv.Resource.Outputs["AZURE_CONTAINER_REGISTRY_ENDPOINT"]); 359Assert.Equal(GetTestResourceId("/providers/Microsoft.ManagedIdentity/userAssignedIdentities/test-identity"), containerAppEnv.Resource.Outputs["AZURE_CONTAINER_REGISTRY_MANAGED_IDENTITY_ID"]); 360Assert.Equal("test.westus.azurecontainerapps.io", containerAppEnv.Resource.Outputs["AZURE_CONTAINER_APPS_ENVIRONMENT_DEFAULT_DOMAIN"]); 361Assert.Equal($"/subscriptions/{TestSubscriptionId}/resourceGroups/{TestResourceGroupName}/providers/Microsoft.App/managedEnvironments/testenv", containerAppEnv.Resource.Outputs["AZURE_CONTAINER_APPS_ENVIRONMENT_ID"]); 423Assert.Equal("testregistry", containerAppEnv.Resource.Outputs["AZURE_CONTAINER_REGISTRY_NAME"]); 424Assert.Equal("testregistry.azurecr.io", containerAppEnv.Resource.Outputs["AZURE_CONTAINER_REGISTRY_ENDPOINT"]); 425Assert.Equal(GetTestResourceId("/providers/Microsoft.ManagedIdentity/userAssignedIdentities/test-identity"), containerAppEnv.Resource.Outputs["AZURE_CONTAINER_REGISTRY_MANAGED_IDENTITY_ID"]); 426Assert.Equal("test.westus.azurecontainerapps.io", containerAppEnv.Resource.Outputs["AZURE_CONTAINER_APPS_ENVIRONMENT_DEFAULT_DOMAIN"]); 427Assert.Equal($"/subscriptions/{TestSubscriptionId}/resourceGroups/{TestResourceGroupName}/providers/Microsoft.App/managedEnvironments/testenv", containerAppEnv.Resource.Outputs["AZURE_CONTAINER_APPS_ENVIRONMENT_ID"]); 491var (containerAppSubscriptionId, containerAppResourceGroupName) = GetSubscriptionAndResourceGroup((string)containerAppEnv.Resource.Outputs["AZURE_CONTAINER_APPS_ENVIRONMENT_ID"]!); 551var webSiteSuffix = Assert.IsType<string>(appServiceEnv.Resource.Outputs["webSiteSuffix"]); 553var (planSubscriptionId, planResourceGroupName) = GetSubscriptionAndResourceGroup((string)appServiceEnv.Resource.Outputs["planId"]!); 646Assert.Equal("acaregistry", acaEnv.Resource.Outputs["AZURE_CONTAINER_REGISTRY_NAME"]); 647Assert.Equal("acaregistry.azurecr.io", acaEnv.Resource.Outputs["AZURE_CONTAINER_REGISTRY_ENDPOINT"]); 648Assert.Equal(GetTestResourceId("/providers/Microsoft.ManagedIdentity/userAssignedIdentities/aca-identity"), acaEnv.Resource.Outputs["AZURE_CONTAINER_REGISTRY_MANAGED_IDENTITY_ID"]); 649Assert.Equal("aca.westus.azurecontainerapps.io", acaEnv.Resource.Outputs["AZURE_CONTAINER_APPS_ENVIRONMENT_DEFAULT_DOMAIN"]); 650Assert.Equal(GetTestResourceId("/providers/Microsoft.App/managedEnvironments/acaenv"), acaEnv.Resource.Outputs["AZURE_CONTAINER_APPS_ENVIRONMENT_ID"]); 653Assert.Equal("aasregistry", aasEnv.Resource.Outputs["AZURE_CONTAINER_REGISTRY_NAME"]); 654Assert.Equal("aasregistry.azurecr.io", aasEnv.Resource.Outputs["AZURE_CONTAINER_REGISTRY_ENDPOINT"]); 655Assert.Equal(GetTestResourceId("/providers/Microsoft.ManagedIdentity/userAssignedIdentities/aas-identity"), aasEnv.Resource.Outputs["AZURE_CONTAINER_REGISTRY_MANAGED_IDENTITY_ID"]); 656Assert.Equal(GetTestResourceId("/providers/Microsoft.Web/serverfarms/aasplan"), aasEnv.Resource.Outputs["planId"]); 657Assert.Equal("aas-client-id", aasEnv.Resource.Outputs["AZURE_CONTAINER_REGISTRY_MANAGED_IDENTITY_CLIENT_ID"]); 773var setValue = await param.Resource.GetValueAsync(default); 847var setValue = await param.Resource.GetValueAsync(default); 897Assert.Equal("testregistry", containerAppEnv.Resource.Outputs["AZURE_CONTAINER_REGISTRY_NAME"]); 898Assert.Equal("testregistry.azurecr.io", containerAppEnv.Resource.Outputs["AZURE_CONTAINER_REGISTRY_ENDPOINT"]); 899Assert.Equal(GetTestResourceId("/providers/Microsoft.ManagedIdentity/userAssignedIdentities/test-identity"), containerAppEnv.Resource.Outputs["AZURE_CONTAINER_REGISTRY_MANAGED_IDENTITY_ID"]); 900Assert.Equal("test.westus.azurecontainerapps.io", containerAppEnv.Resource.Outputs["AZURE_CONTAINER_APPS_ENVIRONMENT_DEFAULT_DOMAIN"]); 901Assert.Equal($"/subscriptions/{TestSubscriptionId}/resourceGroups/{TestResourceGroupName}/providers/Microsoft.App/managedEnvironments/testenv", containerAppEnv.Resource.Outputs["AZURE_CONTAINER_APPS_ENVIRONMENT_ID"]); 959Assert.Equal("test.westus.azurecontainerapps.io", containerAppEnv.Resource.Outputs["AZURE_CONTAINER_APPS_ENVIRONMENT_DEFAULT_DOMAIN"]); 960Assert.Equal(GetTestResourceId("/providers/Microsoft.App/managedEnvironments/testenv"), containerAppEnv.Resource.Outputs["AZURE_CONTAINER_APPS_ENVIRONMENT_ID"]); 1169Assert.Equal("testregistry", containerAppEnv.Resource.Outputs["AZURE_CONTAINER_REGISTRY_NAME"]); 1170Assert.Equal("testregistry.azurecr.io", containerAppEnv.Resource.Outputs["AZURE_CONTAINER_REGISTRY_ENDPOINT"]); 1171Assert.Equal(GetTestResourceId("/providers/Microsoft.ManagedIdentity/userAssignedIdentities/test-identity"), containerAppEnv.Resource.Outputs["AZURE_CONTAINER_REGISTRY_MANAGED_IDENTITY_ID"]); 1172Assert.Equal("test.westus.azurecontainerapps.io", containerAppEnv.Resource.Outputs["AZURE_CONTAINER_APPS_ENVIRONMENT_DEFAULT_DOMAIN"]); 1173Assert.Equal($"/subscriptions/{TestSubscriptionId}/resourceGroups/{TestResourceGroupName}/providers/Microsoft.App/managedEnvironments/testenv", containerAppEnv.Resource.Outputs["AZURE_CONTAINER_APPS_ENVIRONMENT_ID"]); 1176var funcAppDeployment = Assert.IsAssignableFrom<AzureProvisioningResource>(funcApp.Resource.GetDeploymentTargetAnnotation()?.DeploymentTarget); 1178Assert.Equal(await ((BicepOutputReference)funcAppDeployment.Parameters["env_outputs_azure_container_apps_environment_default_domain"]!).GetValueAsync(), containerAppEnv.Resource.Outputs["AZURE_CONTAINER_APPS_ENVIRONMENT_DEFAULT_DOMAIN"]); 1179Assert.Equal(await ((BicepOutputReference)funcAppDeployment.Parameters["env_outputs_azure_container_apps_environment_id"]!).GetValueAsync(), containerAppEnv.Resource.Outputs["AZURE_CONTAINER_APPS_ENVIRONMENT_ID"]); 1868Assert.Equal("secret-key-12345", await regularParam.Resource.GetValueAsync(default)); 1869Assert.Equal("Server=localhost;Database=mydb", await connectionStringParam.Resource.GetValueAsync(default)); 1870Assert.Equal("custom-value-xyz", await customKeyParam.Resource.GetValueAsync(default)); 1923Assert.Equal("secret-key-12345", await regularParam.Resource.GetValueAsync(default)); 1924Assert.Equal("Server=localhost;Database=mydb", await connectionStringParam.Resource.GetValueAsync(default)); 1925Assert.Equal("custom-value-xyz", await customKeyParam.Resource.GetValueAsync(default));

61Assert.Same(firstBuilder.Resource, secondBuilder.Resource); 328storage.Resource.Outputs["blobEndpoint"] = "https://storage.blob.core.windows.net/"; 339await notifications.PublishUpdateAsync(storage.Resource, state => state with 378Assert.Empty(storage.Resource.Outputs); 384Assert.True(notifications.TryGetCurrentState(storage.Resource.Name, out var storageEvent)); 496Assert.True(notifications.TryGetCurrentState(storage.Resource.Name, out var storageEvent)); 498Assert.Equal("https://storage.blob.core.windows.net/", storage.Resource.Outputs["blobEndpoint"]); 515storage.Resource.ProvisioningTaskCompletionSource = existingTcs; 525Assert.Same(existingTcs, storage.Resource.ProvisioningTaskCompletionSource); 559Assert.Empty(storage.Resource.Outputs); 569Assert.True(notifications.TryGetCurrentState(storage.Resource.Name, out var storageEvent)); 571Assert.Equal("https://storage.blob.core.windows.net/", storage.Resource.Outputs["blobEndpoint"]); 607Assert.Equal("https://storage.blob.core.windows.net/", storage.Resource.Outputs["blobEndpoint"]); 636Assert.Equal("https://storage.blob.core.windows.net/", storage.Resource.Outputs["blobEndpoint"]); 657Assert.Contains(storage.Resource.Annotations.OfType<ResourceCommandAnnotation>(), c => c.Name == AzureProvisioningController.ForgetStateCommandName); 658var changeLocationCommand = Assert.Single(storage.Resource.Annotations.OfType<ResourceCommandAnnotation>(), c => c.Name == AzureProvisioningController.ChangeResourceLocationCommandName); 675Assert.Contains(storage.Resource.Annotations.OfType<ResourceCommandAnnotation>(), c => c.Name == AzureProvisioningController.GetAzureResourceCommandName); 676var cancelCommand = Assert.Single(storage.Resource.Annotations.OfType<ResourceCommandAnnotation>(), c => c.Name == AzureProvisioningController.CancelCommandName); 677var deleteCommand = Assert.Single(storage.Resource.Annotations.OfType<ResourceCommandAnnotation>(), c => c.Name == AzureProvisioningController.DeleteAzureResourceCommandName); 678var reprovisionCommand = Assert.Single(storage.Resource.Annotations.OfType<ResourceCommandAnnotation>(), c => c.Name == AzureProvisioningController.ReprovisionResourceCommandName); 682Assert.DoesNotContain(blobs.Resource.Annotations.OfType<ResourceCommandAnnotation>(), c => 706await notifications.PublishUpdateAsync(keyVault.Resource, state => state with { State = KnownResourceStates.Running }); 708Assert.True(notifications.TryGetCurrentState(keyVault.Resource.Name, out var keyVaultEvent)); 741await notifications.PublishUpdateAsync(postgres.Resource, state => state with { State = KnownResourceStates.Running }); 743Assert.True(notifications.TryGetCurrentState(postgres.Resource.Name, out var postgresEvent)); 746var changeLocationCommand = Assert.Single(postgres.Resource.Annotations.OfType<ResourceCommandAnnotation>(), c => c.Name == AzureProvisioningController.ChangeResourceLocationCommandName); 751ResourceName = postgres.Resource.Name, 827var getResourceCommand = Assert.Single(storage.Resource.Annotations.OfType<ResourceCommandAnnotation>(), c => c.Name == AzureProvisioningController.GetAzureResourceCommandName); 832ResourceName = storage.Resource.Name, 911var getResourceCommand = Assert.Single(storage.Resource.Annotations.OfType<ResourceCommandAnnotation>(), c => c.Name == AzureProvisioningController.GetAzureResourceCommandName); 916ResourceName = storage.Resource.Name, 1180var getResourceCommand = Assert.Single(storage.Resource.Annotations.OfType<ResourceCommandAnnotation>(), c => c.Name == AzureProvisioningController.GetAzureResourceCommandName); 1185ResourceName = storage.Resource.Name, 1244var getResourceCommand = Assert.Single(storage.Resource.Annotations.OfType<ResourceCommandAnnotation>(), c => c.Name == AzureProvisioningController.GetAzureResourceCommandName); 1249ResourceName = storage.Resource.Name, 1305var getResourceCommand = Assert.Single(storage.Resource.Annotations.OfType<ResourceCommandAnnotation>(), c => c.Name == AzureProvisioningController.GetAzureResourceCommandName); 1310ResourceName = storage.Resource.Name, 1364await notifications.PublishUpdateAsync(storage.Resource, state => state with { State = new("Waiting for Deployment", KnownResourceStateStyles.Info) }); 1366var cancelCommand = Assert.Single(storage.Resource.Annotations.OfType<ResourceCommandAnnotation>(), c => c.Name == AzureProvisioningController.CancelCommandName); 1371ResourceName = storage.Resource.Name, 1385Assert.True(notifications.TryGetCurrentState(storage.Resource.Name, out var storageEvent)); 1419await notifications.PublishUpdateAsync(storage.Resource, state => state with { State = new("Creating ARM Deployment", KnownResourceStateStyles.Info) }); 1421Assert.True(notifications.TryGetCurrentState(storage.Resource.Name, out var storageEvent)); 1496await notifications.PublishUpdateAsync(storage.Resource, state => state with { State = new(AzureProvisioningController.WaitingForDeploymentState, KnownResourceStateStyles.Info) }); 1498Assert.True(notifications.TryGetCurrentState(storage.Resource.Name, out var storageEvent)); 1501var cancelCommand = Assert.Single(storage.Resource.Annotations.OfType<ResourceCommandAnnotation>(), c => c.Name == AzureProvisioningController.CancelCommandName); 1506ResourceName = storage.Resource.Name, 1546var activeReprovisionTask = controller.ReprovisionResourceAsync(model, storage.Resource.Name, CancellationToken.None); 1559var command = Assert.Single(storage.Resource.Annotations.OfType<ResourceCommandAnnotation>(), c => c.Name == commandName); 1564ResourceName = storage.Resource.Name, 1575Assert.Equal([storage.Resource.Name], testBicepProvisioner.ProvisionedResources); 1605var activeReprovisionTask = controller.ReprovisionResourceAsync(model, storage1.Resource.Name, CancellationToken.None); 1611var queuedReprovisionCommand = Assert.Single(storage2.Resource.Annotations.OfType<ResourceCommandAnnotation>(), c => c.Name == AzureProvisioningController.ReprovisionResourceCommandName); 1615ResourceName = storage2.Resource.Name, 1623var conflictingCommand = Assert.Single(storage2.Resource.Annotations.OfType<ResourceCommandAnnotation>(), c => c.Name == AzureProvisioningController.DeleteAzureResourceCommandName); 1627ResourceName = storage2.Resource.Name, 1666await notifications.PublishUpdateAsync(storage.Resource, state => state with { State = KnownResourceStates.Running }); 1668Assert.True(notifications.TryGetCurrentState(storage.Resource.Name, out var storageEvent)); 1704await notifications.PublishUpdateAsync(storage.Resource, state => state with { State = KnownResourceStates.Running }); 1706var cancelCommand = Assert.Single(storage.Resource.Annotations.OfType<ResourceCommandAnnotation>(), c => c.Name == AzureProvisioningController.CancelCommandName); 1711ResourceName = storage.Resource.Name, 1723Assert.True(notifications.TryGetCurrentState(storage.Resource.Name, out var storageEvent)); 1784storage.Resource.Outputs["blobEndpoint"] = "https://storage.blob.core.windows.net/"; 1785storage2.Resource.Outputs["blobEndpoint"] = "https://storage2.blob.core.windows.net/"; 1787await notifications.PublishUpdateAsync(storage.Resource, state => state with { State = new("Failed to Provision", KnownResourceStateStyles.Error) }); 1788await notifications.PublishUpdateAsync(storage2.Resource, state => state with { State = KnownResourceStates.Running }); 1790var deleteCommand = Assert.Single(storage.Resource.Annotations.OfType<ResourceCommandAnnotation>(), c => c.Name == AzureProvisioningController.DeleteAzureResourceCommandName); 1795ResourceName = storage.Resource.Name, 1823Assert.Empty(storage.Resource.Outputs); 1824Assert.Equal("https://storage2.blob.core.windows.net/", storage2.Resource.Outputs["blobEndpoint"]); 1826Assert.True(notifications.TryGetCurrentState(storage.Resource.Name, out var storageEvent)); 1829Assert.True(notifications.TryGetCurrentState(storage2.Resource.Name, out var storage2Event)); 1882await notifications.PublishUpdateAsync(keyVault.Resource, state => state with { State = new("Failed to Provision", KnownResourceStateStyles.Error) }); 1884var deleteCommand = Assert.Single(keyVault.Resource.Annotations.OfType<ResourceCommandAnnotation>(), c => c.Name == AzureProvisioningController.DeleteAzureResourceCommandName); 1889ResourceName = keyVault.Resource.Name, 1908Assert.True(notifications.TryGetCurrentState(keyVault.Resource.Name, out var keyVaultEvent)); 1952await notifications.PublishUpdateAsync(storage.Resource, state => state with { State = KnownResourceStates.Running }); 1953await notifications.PublishUpdateAsync(storage2.Resource, state => state with { State = KnownResourceStates.Running }); 1955var deleteCommand = Assert.Single(storage.Resource.Annotations.OfType<ResourceCommandAnnotation>(), c => c.Name == AzureProvisioningController.DeleteAzureResourceCommandName); 1960ResourceName = storage.Resource.Name, 1974Assert.True(notifications.TryGetCurrentState(storage.Resource.Name, out var storageEvent)); 1978Assert.True(notifications.TryGetCurrentState(storage2.Resource.Name, out var storage2Event)); 2030await notifications.PublishUpdateAsync(storage.Resource, state => state with { State = KnownResourceStates.Running }); 2032var deleteCommand = Assert.Single(storage.Resource.Annotations.OfType<ResourceCommandAnnotation>(), c => c.Name == AzureProvisioningController.DeleteAzureResourceCommandName); 2033var cancelCommand = Assert.Single(storage.Resource.Annotations.OfType<ResourceCommandAnnotation>(), c => c.Name == AzureProvisioningController.CancelCommandName); 2038ResourceName = storage.Resource.Name, 2052ResourceName = storage.Resource.Name, 2062Assert.True(notifications.TryGetCurrentState(storage.Resource.Name, out var storageEvent)); 2095storage.Resource.Outputs["blobEndpoint"] = "https://storage.blob.core.windows.net/"; 2096storage2.Resource.Outputs["blobEndpoint"] = "https://storage2.blob.core.windows.net/"; 2098await notifications.PublishUpdateAsync(storage.Resource, state => state with 2105await notifications.PublishUpdateAsync(storage2.Resource, state => state with 2112var forgetCommand = Assert.Single(storage.Resource.Annotations.OfType<ResourceCommandAnnotation>(), c => c.Name == AzureProvisioningController.ForgetStateCommandName); 2117ResourceName = storage.Resource.Name, 2132Assert.Empty(storage.Resource.Outputs); 2133Assert.Equal("https://storage2.blob.core.windows.net/", storage2.Resource.Outputs["blobEndpoint"]); 2135Assert.True(notifications.TryGetCurrentState(storage.Resource.Name, out var storageEvent)); 2140Assert.True(notifications.TryGetCurrentState(storage2.Resource.Name, out var storage2Event)); 2173await notifications.PublishUpdateAsync(storage.Resource, state => state with { State = KnownResourceStates.Running }); 2174await notifications.PublishUpdateAsync(storage2.Resource, state => state with { State = KnownResourceStates.Running }); 2176var reprovisionCommand = Assert.Single(storage.Resource.Annotations.OfType<ResourceCommandAnnotation>(), c => c.Name == AzureProvisioningController.ReprovisionResourceCommandName); 2181ResourceName = storage.Resource.Name, 2189Assert.Contains(storage.Resource.Outputs, output => output.Key == "blobEndpoint"); 2197Assert.True(notifications.TryGetCurrentState(storage.Resource.Name, out var storageEvent)); 2200Assert.True(notifications.TryGetCurrentState(storage2.Resource.Name, out var storage2Event)); 2227await notifications.PublishUpdateAsync(storage.Resource, state => state with { State = KnownResourceStates.Running }); 2228await notifications.PublishUpdateAsync(storage2.Resource, state => state with { State = KnownResourceStates.Running }); 2230var reprovisionCommand = Assert.Single(storage.Resource.Annotations.OfType<ResourceCommandAnnotation>(), c => c.Name == AzureProvisioningController.ReprovisionResourceCommandName); 2235ResourceName = storage.Resource.Name, 2249Assert.True(notifications.TryGetCurrentState(storage.Resource.Name, out var storageEvent)); 2252Assert.True(notifications.TryGetCurrentState(storage2.Resource.Name, out var storage2Event)); 2263Assert.True(notifications.TryGetCurrentState(storage.Resource.Name, out storageEvent)); 2288await notifications.PublishUpdateAsync(storage.Resource, state => state with { State = KnownResourceStates.Running }); 2290var reprovisionCommand = Assert.Single(storage.Resource.Annotations.OfType<ResourceCommandAnnotation>(), c => c.Name == AzureProvisioningController.ReprovisionResourceCommandName); 2295ResourceName = storage.Resource.Name, 2309Assert.True(notifications.TryGetCurrentState(storage.Resource.Name, out var storageEvent)); 2321Assert.True(notifications.TryGetCurrentState(storage.Resource.Name, out storageEvent)); 2366var reprovisionStorageCommand = Assert.Single(storage.Resource.Annotations.OfType<ResourceCommandAnnotation>(), c => c.Name == AzureProvisioningController.ReprovisionResourceCommandName); 2367var reprovisionStorage2Command = Assert.Single(storage2.Resource.Annotations.OfType<ResourceCommandAnnotation>(), c => c.Name == AzureProvisioningController.ReprovisionResourceCommandName); 2372ResourceName = storage.Resource.Name, 2386ResourceName = storage2.Resource.Name, 2443var reprovisionCommand = Assert.Single(storage.Resource.Annotations.OfType<ResourceCommandAnnotation>(), c => c.Name == AzureProvisioningController.ReprovisionResourceCommandName); 2444var cancelCommand = Assert.Single(storage.Resource.Annotations.OfType<ResourceCommandAnnotation>(), c => c.Name == AzureProvisioningController.CancelCommandName); 2449ResourceName = storage.Resource.Name, 2460Assert.True(notifications.TryGetCurrentState(storage.Resource.Name, out var storageEvent)); 2466ResourceName = storage.Resource.Name, 2477Assert.True(notifications.TryGetCurrentState(storage.Resource.Name, out storageEvent)); 2480Assert.True(notifications.TryGetCurrentState(blobs.Resource.Name, out var blobsEvent)); 2489Assert.True(notifications.TryGetCurrentState(storage.Resource.Name, out storageEvent)); 2538await WaitForResourceStateAsync(notifications, storage2.Resource.Name, "Running"); 2539Assert.True(notifications.TryGetCurrentState(storage2.Resource.Name, out var runningStorage2Event)); 2542var cancelCommand = Assert.Single(storage.Resource.Annotations.OfType<ResourceCommandAnnotation>(), c => c.Name == AzureProvisioningController.CancelCommandName); 2547ResourceName = storage.Resource.Name, 2555Assert.True(notifications.TryGetCurrentState(storage.Resource.Name, out var storageEvent)); 2559Assert.True(notifications.TryGetCurrentState(storage2.Resource.Name, out var storage2Event)); 2564Assert.True(notifications.TryGetCurrentState(storage2.Resource.Name, out storage2Event)); 2588var cancelCommand = Assert.Single(storage.Resource.Annotations.OfType<ResourceCommandAnnotation>(), c => c.Name == AzureProvisioningController.CancelCommandName); 2593ResourceName = storage.Resource.Name, 2640var reprovisionCommand = Assert.Single(storage.Resource.Annotations.OfType<ResourceCommandAnnotation>(), c => c.Name == AzureProvisioningController.ReprovisionResourceCommandName); 2641var cancelCommand = Assert.Single(storage2.Resource.Annotations.OfType<ResourceCommandAnnotation>(), c => c.Name == AzureProvisioningController.CancelCommandName); 2646ResourceName = storage.Resource.Name, 2660ResourceName = storage2.Resource.Name, 2705await notifications.PublishUpdateAsync(storage.Resource, state => state with { State = KnownResourceStates.Running }); 2706await notifications.PublishUpdateAsync(storage2.Resource, state => state with { State = KnownResourceStates.Running }); 2708var changeLocationCommand = Assert.Single(storage.Resource.Annotations.OfType<ResourceCommandAnnotation>(), c => c.Name == AzureProvisioningController.ChangeResourceLocationCommandName); 2713ResourceName = storage.Resource.Name, 2729Assert.True(notifications.TryGetCurrentState(storage.Resource.Name, out var storageEvent)); 2738Assert.True(notifications.TryGetCurrentState(storage2.Resource.Name, out var storage2Event)); 2778await notifications.PublishUpdateAsync(storage.Resource, state => state with { State = new("Failed to Provision", KnownResourceStateStyles.Error) }); 2779await notifications.PublishUpdateAsync(storage2.Resource, state => state with { State = KnownResourceStates.Running }); 2781var changeLocationCommand = Assert.Single(storage.Resource.Annotations.OfType<ResourceCommandAnnotation>(), c => c.Name == AzureProvisioningController.ChangeResourceLocationCommandName); 2786ResourceName = storage.Resource.Name, 2832await notifications.PublishUpdateAsync(storage.Resource, state => state with { State = KnownResourceStates.Running }); 2834var changeLocationCommand = Assert.Single(storage.Resource.Annotations.OfType<ResourceCommandAnnotation>(), c => c.Name == AzureProvisioningController.ChangeResourceLocationCommandName); 2839ResourceName = storage.Resource.Name, 2947await notifications.PublishUpdateAsync(storage.Resource, state => state with { State = KnownResourceStates.Running }); 2949var changeLocationCommand = Assert.Single(storage.Resource.Annotations.OfType<ResourceCommandAnnotation>(), c => c.Name == AzureProvisioningController.ChangeResourceLocationCommandName); 2960ResourceName = storage.Resource.Name, 3020await notifications.PublishUpdateAsync(storage.Resource, state => state with 3026var changeLocationCommand = Assert.Single(storage.Resource.Annotations.OfType<ResourceCommandAnnotation>(), c => c.Name == AzureProvisioningController.ChangeResourceLocationCommandName); 3030ResourceName = storage.Resource.Name, 3039Assert.True(notifications.TryGetCurrentState(storage.Resource.Name, out var storageEvent)); 3080await notifications.PublishUpdateAsync(storage.Resource, state => state with 3086var changeLocationCommand = Assert.Single(storage.Resource.Annotations.OfType<ResourceCommandAnnotation>(), c => c.Name == AzureProvisioningController.ChangeResourceLocationCommandName); 3091ResourceName = storage.Resource.Name, 3153await notifications.PublishUpdateAsync(storage.Resource, state => state with { State = KnownResourceStates.Running }); 3155var changeLocationCommand = Assert.Single(storage.Resource.Annotations.OfType<ResourceCommandAnnotation>(), c => c.Name == AzureProvisioningController.ChangeResourceLocationCommandName); 3160ResourceName = storage.Resource.Name, 3206await notifications.PublishUpdateAsync(storage.Resource, state => state with 3212var changeLocationCommand = Assert.Single(storage.Resource.Annotations.OfType<ResourceCommandAnnotation>(), c => c.Name == AzureProvisioningController.ChangeResourceLocationCommandName); 3217ResourceName = storage.Resource.Name, 3269await notifications.PublishUpdateAsync(storage.Resource, state => state with 3275var changeLocationCommand = Assert.Single(storage.Resource.Annotations.OfType<ResourceCommandAnnotation>(), c => c.Name == AzureProvisioningController.ChangeResourceLocationCommandName); 3280ResourceName = storage.Resource.Name, 3341await notifications.PublishUpdateAsync(storage.Resource, state => state with 3347var changeLocationCommand = Assert.Single(storage.Resource.Annotations.OfType<ResourceCommandAnnotation>(), c => c.Name == AzureProvisioningController.ChangeResourceLocationCommandName); 3351ResourceName = storage.Resource.Name, 3398await notifications.PublishUpdateAsync(storage.Resource, state => state with { State = KnownResourceStates.Running }); 3399await notifications.PublishUpdateAsync(storage2.Resource, state => state with { State = KnownResourceStates.Running }); 3613await notifications.PublishUpdateAsync(storage.Resource, state => state with 3843await notifications.PublishUpdateAsync(storage.Resource, state => state with { State = KnownResourceStates.Running }); 3845var reprovisionCommand = Assert.Single(storage.Resource.Annotations.OfType<ResourceCommandAnnotation>(), c => c.Name == AzureProvisioningController.ReprovisionResourceCommandName); 3850ResourceName = storage.Resource.Name, 3915await notifications.PublishUpdateAsync(keyVault.Resource, state => state with { State = new("Canceled", KnownResourceStateStyles.Info) }); 3917var reprovisionCommand = Assert.Single(keyVault.Resource.Annotations.OfType<ResourceCommandAnnotation>(), c => c.Name == AzureProvisioningController.ReprovisionResourceCommandName); 3922ResourceName = keyVault.Resource.Name, 3935Assert.True(notifications.TryGetCurrentState(keyVault.Resource.Name, out var keyVaultEvent)); 3995await notifications.PublishUpdateAsync(keyVault.Resource, state => state with { State = new("Canceled", KnownResourceStateStyles.Info) }); 3997var reprovisionCommand = Assert.Single(keyVault.Resource.Annotations.OfType<ResourceCommandAnnotation>(), c => c.Name == AzureProvisioningController.ReprovisionResourceCommandName); 4002ResourceName = keyVault.Resource.Name, 4039Assert.True(notifications.TryGetCurrentState(keyVault.Resource.Name, out var keyVaultEvent)); 4069await notifications.PublishUpdateAsync(postgres.Resource, state => state with { State = KnownResourceStates.Running }); 4071var reprovisionCommand = Assert.Single(postgres.Resource.Annotations.OfType<ResourceCommandAnnotation>(), c => c.Name == AzureProvisioningController.ReprovisionResourceCommandName); 4076ResourceName = postgres.Resource.Name, 4121await notifications.PublishUpdateAsync(storage.Resource, state => state with { State = KnownResourceStates.Running }); 4123var changeLocationCommand = Assert.Single(storage.Resource.Annotations.OfType<ResourceCommandAnnotation>(), c => c.Name == AzureProvisioningController.ChangeResourceLocationCommandName); 4128ResourceName = storage.Resource.Name, 4167await notifications.PublishUpdateAsync(keyVault.Resource, state => state with { State = KnownResourceStates.Running }); 4169var changeLocationCommand = Assert.Single(keyVault.Resource.Annotations.OfType<ResourceCommandAnnotation>(), c => c.Name == AzureProvisioningController.ChangeResourceLocationCommandName); 4174ResourceName = keyVault.Resource.Name, 4213await notifications.PublishUpdateAsync(storage.Resource, state => state with { State = KnownResourceStates.Running }); 4215var reprovisionCommand = Assert.Single(storage.Resource.Annotations.OfType<ResourceCommandAnnotation>(), c => c.Name == AzureProvisioningController.ReprovisionResourceCommandName); 4220ResourceName = storage.Resource.Name, 4246Assert.True(notifications.TryGetCurrentState(storage.Resource.Name, out var storageEvent)); 4281var reprovisionCommand = Assert.Single(storage.Resource.Annotations.OfType<ResourceCommandAnnotation>(), c => c.Name == AzureProvisioningController.ReprovisionResourceCommandName); 4288ResourceName = storage.Resource.Name, 4328await notifications.PublishUpdateAsync(storage.Resource, state => state with { State = KnownResourceStates.Running }); 4341Assert.True(notifications.TryGetCurrentState(storage.Resource.Name, out var resourceEvent)); 4381await notifications.PublishUpdateAsync(storage.Resource, state => state with { State = KnownResourceStates.Running }); 4388Assert.True(notifications.TryGetCurrentState(storage.Resource.Name, out var resourceEvent)); 4439await notifications.PublishUpdateAsync(storage.Resource, state => state with { State = KnownResourceStates.Running }); 4440await notifications.PublishUpdateAsync(storage2.Resource, state => state with { State = KnownResourceStates.Running }); 4447Assert.True(notifications.TryGetCurrentState(storage.Resource.Name, out var storageEvent)); 4450Assert.True(notifications.TryGetCurrentState(storage2.Resource.Name, out var storage2Event)); 4483await notifications.PublishUpdateAsync(storage.Resource, state => state with { State = KnownResourceStates.Running }); 4490Assert.True(notifications.TryGetCurrentState(storage.Resource.Name, out var resourceEvent)); 4547Assert.Empty(storage.Resource.Outputs); 4592Assert.Empty(storage.Resource.Outputs); 4638Assert.Empty(storage.Resource.Outputs); 4808var cancelCommand = Assert.Single(storage.Resource.Annotations.OfType<ResourceCommandAnnotation>(), c => c.Name == AzureProvisioningController.CancelCommandName); 4812ResourceName = storage.Resource.Name, 4822Assert.True(notifications.TryGetCurrentState(storage.Resource.Name, out var storageEvent)); 4828Assert.True(notifications.TryGetCurrentState(storage.Resource.Name, out storageEvent)); 4858Assert.Equal([storage.Resource.Name, storage2.Resource.Name], Assert.IsType<string[]>(failedResourcesProperty.Value)); 4931Assert.Equal(expectedLocation.Resource, resource.Location); 4947Assert.Equal(expectedResourceGroup.Resource, resource.ResourceGroupName);

113.WithParameter("pgdb", pgdb.Resource.ConnectionStringExpression); 161["kvUri"] = kv.Resource.VaultUri, 162["blob"] = blobs.Resource.ConnectionStringExpression, 192roles.Resource.Parameters[AzureBicepResource.KnownParameters.PrincipalId] = null; 193roles.Resource.Parameters[AzureBicepResource.KnownParameters.PrincipalType] = null; 218resourceGroupScoped.Resource.Scope = new(resourceGroup.Resource, subscription.Resource); 228subscriptionScoped.Resource.Scope = AzureBicepResourceScope.CreateForSubscription(subscription.Resource); 238tenantScoped.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); 529Assert.Same(eventHubs.Resource.Annotations, sourceResource.Annotations); 531var persistenceAnnotation = Assert.Single(eventHubs.Resource.Annotations.OfType<PersistenceAnnotation>()); 580Assert.Equal("{eh.outputs.eventHubsEndpoint}", eventHubs.Resource.ConnectionStringExpression.ValueExpression); 581Assert.Equal("Endpoint={eh.outputs.eventHubsEndpoint};EntityPath=hub1", eventHub.Resource.ConnectionStringExpression.ValueExpression); 582Assert.Equal("Endpoint={eh.outputs.eventHubsEndpoint};EntityPath=hub1;ConsumerGroup=cg1", consumerGroup.Resource.ConnectionStringExpression.ValueExpression); 595((IResourceWithAzureFunctionsConfig)eventHubs.Resource).ApplyAzureFunctionsConfiguration(target, "eh"); 605((IResourceWithAzureFunctionsConfig)eventHub.Resource).ApplyAzureFunctionsConfiguration(target, "hub1"); 621((IResourceWithAzureFunctionsConfig)consumerGroup.Resource).ApplyAzureFunctionsConfiguration(target, "cg1"); 651Assert.True(eventHubs.Resource.IsEmulator()); 652Assert.Contains(eventHubs.Resource.Annotations, a => a is EmulatorResourceAnnotation); 682_ = eventHubs.Resource.AddAsExistingResource(infra); 685var (manifest, bicep) = await AzureManifestUtils.GetManifestWithBicep(module.Resource, skipPreparer: true);

23Assert.Equal("frontdoor", frontDoor.Resource.Name); 24Assert.IsType<AzureFrontDoorResource>(frontDoor.Resource); 38var annotations = frontDoor.Resource.Annotations.OfType<AzureFrontDoorOriginAnnotation>().ToList(); 56var annotations = frontDoor.Resource.Annotations.OfType<AzureFrontDoorOriginAnnotation>().ToList(); 78var (_, bicep) = await GetManifestWithBicep(frontDoor.Resource); 83var endpointUrl = frontDoor.Resource.GetEndpointUrl("my-api"); 109var (_, bicep) = await GetManifestWithBicep(frontDoor.Resource); 140var endpointUrl = frontDoor.Resource.GetEndpointUrl("api"); 181var (_, bicep) = await GetManifestWithBicep(frontDoor.Resource); 204var (_, bicep) = await GetManifestWithBicep(frontDoor.Resource); 229var (_, 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);

87Assert.True(storage.Resource.TryGetLastAnnotation<DefaultRoleAssignmentsAnnotation>(out var defaultAssignments)); 94Assert.Same(storage.Resource, storageRoles.TargetAzureResource); 106Assert.True(api.Resource.TryGetLastAnnotation<RoleAssignmentAnnotation>(out var apiRoleAssignments)); 107Assert.Equal(storage.Resource, apiRoleAssignments.Target); 140Assert.Same(storage.Resource, storageRoles.TargetAzureResource); 150Assert.True(api.Resource.TryGetLastAnnotation<RoleAssignmentAnnotation>(out var apiRoleAssignments)); 151Assert.Equal(storage.Resource, apiRoleAssignments.Target); 156Assert.True(api2.Resource.TryGetLastAnnotation<RoleAssignmentAnnotation>(out var api2RoleAssignments)); 157Assert.Equal(storage.Resource, api2RoleAssignments.Target); 199context.Args.Add(blobs.Resource.ConnectionStringExpression); 205Assert.True(storage.Resource.TryGetLastAnnotation<DefaultRoleAssignmentsAnnotation>(out var defaultAssignments)); 207Assert.True(api.Resource.TryGetLastAnnotation<RoleAssignmentAnnotation>(out var apiRoleAssignments)); 208Assert.Equal(storage.Resource, apiRoleAssignments.Target); 237var deploymentTarget = Assert.IsAssignableFrom<AzureBicepResource>(api.Resource.GetDeploymentTargetAnnotation()?.DeploymentTarget); 239Assert.Same(storage.Resource, roleAssignmentResource.TargetAzureResource); 240Assert.Same(api.Resource, roleAssignmentResource.OwnerResource); 242Assert.Contains(blobPE.Resource, deploymentTarget.References); 243Assert.Contains(queuesPE.Resource, deploymentTarget.References); 272.Where(resource => resource.TargetAzureResource == keyVault.Resource) 287Assert.Same(keyVault.Resource, resource.TargetAzureResource); 288Assert.Same(api.Resource, resource.OwnerResource); 293Assert.Same(keyVault.Resource, resource.TargetAzureResource); 294Assert.Same(worker.Resource, resource.OwnerResource); 299resource => resource.TargetAzureResource == storage.Resource); 300Assert.Same(api.Resource, storageRoleAssignment.OwnerResource); 329.Where(resource => resource.TargetAzureResource == signalR.Resource) 344Assert.Same(signalR.Resource, resource.TargetAzureResource); 345Assert.Same(serviceA.Resource, resource.OwnerResource); 350Assert.Same(signalR.Resource, resource.TargetAzureResource); 351Assert.Same(serviceB.Resource, resource.OwnerResource); 381Assert.Same(storage.Resource, storageRoles.TargetAzureResource); 383Assert.Single(storage.Resource.Annotations.OfType<RoleAssignmentResourceAnnotation>()); 554agent.Resource.Annotations.Add(new ReferenceRoleAssignmentAnnotation( 555storage.Resource, 564Assert.True(consumer.Resource.TryGetLastAnnotation<RoleAssignmentAnnotation>(out var consumerRoleAssignments)); 565Assert.Equal(storage.Resource, consumerRoleAssignments.Target); 579agent.Resource.Annotations.Add(new ReferenceRoleAssignmentAnnotation( 580storage.Resource, 591Assert.Same(storage.Resource, storageRoles.TargetAzureResource); 604agent.Resource.Annotations.Add(new ReferenceRoleAssignmentAnnotation( 605storage.Resource, 615Assert.False(bystander.Resource.TryGetLastAnnotation<RoleAssignmentAnnotation>(out _)); 633agent1.Resource.Annotations.Add(new ReferenceRoleAssignmentAnnotation(storage.Resource, role)); 636agent2.Resource.Annotations.Add(new ReferenceRoleAssignmentAnnotation(storage.Resource, role)); 647Assert.Same(storage.Resource, roleAssignmentResource.TargetAzureResource); 648Assert.Same(consumer.Resource, roleAssignmentResource.OwnerResource); 667agent.Resource.Annotations.Add(new ReferenceRoleAssignmentAnnotation( 668storage.Resource, 683var roleIds = consumer.Resource.Annotations.OfType<RoleAssignmentAnnotation>() 684.Where(a => a.Target == storage.Resource) 710agent.Resource.Annotations.Add(new ReferenceRoleAssignmentAnnotation( 711storage.Resource, 724var roleIds = consumer.Resource.Annotations.OfType<RoleAssignmentAnnotation>() 725.Where(a => a.Target == storage.Resource)

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

37Assert.Equal("{sandboxes.outputs.id}", sandboxGroup.Resource.IdOutputReference.ValueExpression); 38Assert.Equal("{sandboxes.outputs.name}", sandboxGroup.Resource.NameOutputReference.ValueExpression); 47sandboxGroup.Resource.Outputs["id"] = "/subscriptions/11111111-1111-1111-1111-111111111111/resourceGroups/existing-rg/providers/Microsoft.App/sandboxGroups/existing-group"; 48sandboxGroup.Resource.Outputs["location"] = "eastus2"; 50var scope = AzureSandboxContainerDeployment.CreateDataPlaneScope(sandboxGroup.Resource); 71var (hostGroupManifest, hostGroupBicep) = await AzureManifestUtils.GetManifestWithBicep(model, hostGroup.Resource); 72var (workerGroupManifest, workerGroupBicep) = await AzureManifestUtils.GetManifestWithBicep(model, workerGroup.Resource); 108var (_, sandbox1Bicep) = await AzureManifestUtils.GetManifestWithBicep(model, sandbox1.Resource); 109var (_, sandbox2Bicep) = await AzureManifestUtils.GetManifestWithBicep(model, sandbox2.Resource); 134Assert.Equal(ManagedServiceIdentityType.SystemAssignedUserAssigned, sandboxGroup.Resource.WorkloadManagedIdentityType); 135Assert.Equal(identity.Resource, Assert.Single(sandboxGroup.Resource.WorkloadUserAssignedIdentities)); 146var (_, bicep) = await AzureManifestUtils.GetManifestWithBicep(sandboxGroup.Resource, skipPreparer: true); 159var (_, bicep) = await AzureManifestUtils.GetManifestWithBicep(sandboxGroup.Resource, skipPreparer: true); 175.WithAnnotation(new AppIdentityAnnotation(computeIdentity.Resource)) 181Assert.Equal(ManagedServiceIdentityType.UserAssigned, sandboxGroup.Resource.WorkloadManagedIdentityType); 182Assert.Equal(computeIdentity.Resource, Assert.Single(sandboxGroup.Resource.WorkloadUserAssignedIdentities)); 184var (_, bicep) = await AzureManifestUtils.GetManifestWithBicep(sandboxGroup.Resource, skipPreparer: true); 197.WithAnnotation(new AppIdentityAnnotation(identity.Resource)) 202Assert.Equal(ManagedServiceIdentityType.UserAssigned, sandboxGroup.Resource.WorkloadManagedIdentityType); 203Assert.Equal(identity.Resource, Assert.Single(sandboxGroup.Resource.WorkloadUserAssignedIdentities)); 204Assert.Empty(otherGroup.Resource.WorkloadUserAssignedIdentities); 205var (_, bicep) = await AzureManifestUtils.GetManifestWithBicep(sandboxGroup.Resource, skipPreparer: true); 222.WithAnnotation(new AppIdentityAnnotation(identity.Resource)) 247var (_, bicep) = await AzureManifestUtils.GetManifestWithBicep(model, sandboxGroup.Resource); 249var annotation = Assert.Single(sandboxGroup.Resource.Annotations.OfType<AzureSandboxGroupAcrPullIdentityAnnotation>()); 250Assert.Same(pullIdentity.Resource, annotation.Identity); 271() => AzureManifestUtils.GetManifestWithBicep(model, sandboxGroup.Resource)); 329var annotation = Assert.Single(sandboxGroup.Resource.Annotations.OfType<AzureSandboxGroupAcrPullIdentityAnnotation>()); 331Assert.Same(registry.Resource, roles.TargetAzureResource); 333Assert.Contains(identity, sandboxGroup.Resource.References); 335var (_, sandboxBicep) = await AzureManifestUtils.GetManifestWithBicep(sandboxGroup.Resource, skipPreparer: true); 374var buildOptionsCallbackCount = container.Resource.Annotations.OfType<ContainerBuildOptionsCallbackAnnotation>().Count(); 388Assert.Null(computeResource.GetDeploymentTargetAnnotation(sandboxGroup.Resource)); 390Assert.Equal(buildOptionsCallbackCount, container.Resource.Annotations.OfType<ContainerBuildOptionsCallbackAnnotation>().Count()); 495sandboxGroup.Resource.ContainerRegistry!.Outputs["loginServer"] = "example.azurecr.io"; 496sandboxGroup.Resource.Outputs[AzureSandboxGroupResource.ImagePullIdentityClientIdOutputName] = 500sandboxGroup.Resource, 504sandboxGroup.Resource, 1083sandboxGroup.Resource.Outputs["id"] = "/subscriptions/11111111-1111-1111-1111-111111111111/resourceGroups/existing-rg/providers/Microsoft.App/sandboxGroups/existing-group"; 1084sandboxGroup.Resource.Outputs["location"] = "eastus2"; 1085var existingScope = AzureSandboxContainerDeployment.CreateDataPlaneScope(sandboxGroup.Resource); 1088var targetResource = builder.AddContainer("frontend", "example/image").Resource; 1092sandboxGroup.Resource); 1829var deploymentTarget = computeResource.GetDeploymentTargetAnnotation(sandboxGroup.Resource); 1905defaultResource.Resource.GetDeploymentTargetAnnotation(sandboxGroup.Resource)?.DeploymentTarget); 1907disabledResource.Resource.GetDeploymentTargetAnnotation(sandboxGroup.Resource)?.DeploymentTarget); 1909enabledResource.Resource.GetDeploymentTargetAnnotation(sandboxGroup.Resource)?.DeploymentTarget); 2004var deploymentTarget = computeResource.GetDeploymentTargetAnnotation(sandboxGroup.Resource); 2030Assert.True(AzureSandboxContainerDeployment.TryResolveEndpointReferenceValue(api.GetEndpoint("http"), sandboxGroup.Resource, out var urlExpression)); 2035Assert.True(AzureSandboxContainerDeployment.TryResolveEndpointReferenceValue(api.GetEndpoint("http").Property(EndpointProperty.TargetPort), sandboxGroup.Resource, out var targetPortExpression)); 2066var deploymentTarget = computeResource.GetDeploymentTargetAnnotation(sandboxGroup.Resource); 2105var deploymentTarget = computeResource.GetDeploymentTargetAnnotation(sandboxGroup.Resource); 2129var deploymentTarget = computeResource.GetDeploymentTargetAnnotation(sandboxGroup.Resource); 2162var frontendCallbackCount = frontend.Resource.Annotations.OfType<ContainerBuildOptionsCallbackAnnotation>().Count(); 2163var backendCallbackCount = backend.Resource.Annotations.OfType<ContainerBuildOptionsCallbackAnnotation>().Count(); 2173Assert.Same(sandboxGroup.Resource, computeResource.GetComputeEnvironment()); 2174Assert.Same(sandboxGroup.Resource, explicitComputeResource.GetComputeEnvironment()); 2214var deploymentTarget = computeResource.GetDeploymentTargetAnnotation(sandboxGroup.Resource); 2216Assert.Same(sandboxGroup.Resource.ContainerRegistry, deploymentTarget.ContainerRegistry); 2217Assert.Same(sandboxGroup.Resource, deploymentTarget.ComputeEnvironment); 2221Assert.Same(sandboxGroup.Resource, sandboxContainer.Parent); 2252Resource = sandboxGroup.Resource.ContainerRegistry, 2305foreach (var annotation in sandboxGroup.Resource.Annotations.OfType<PipelineConfigurationAnnotation>() 2350Assert.Same(sandboxGroup.Resource, computeResource.GetComputeEnvironment()); 2352var deploymentTarget = computeResource.GetDeploymentTargetAnnotation(sandboxGroup.Resource); 2375var deploymentTarget = computeResource.GetDeploymentTargetAnnotation(sandboxGroup.Resource); 2396container.Resource.GetDeploymentTargetAnnotation(sandboxGroup.Resource)?.DeploymentTarget); 2398var registry = Assert.IsType<AzureContainerRegistryResource>(sandboxGroup.Resource.ContainerRegistry); 2418Assert.Empty(context.GetSteps(container.Resource, WellKnownPipelineTags.PushContainerImage)); 2440api.Resource.GetDeploymentTargetAnnotation(sandboxGroup.Resource)?.DeploymentTarget); 2467var value = await AzureSandboxContainerDeployment.ResolveValueWithEgressHostsAsync(stepContext, web.Resource, endpointExpression); 2468var environment = await AzureSandboxContainerDeployment.ResolveEnvironmentVariablesAsync(stepContext, web.Resource); 2493var dependencies = await web.Resource.GetResourceDependenciesAsync( 2496Assert.Contains(api.Resource, dependencies); 2497var steps = await CreateStepsAsync(app, sandboxGroup.Resource); 2504foreach (var annotation in sandboxGroup.Resource.Annotations.OfType<PipelineConfigurationAnnotation>()) 2531var steps = await CreateStepsAsync(app, consumerGroup.Resource); 2541foreach (var annotation in consumerGroup.Resource.Annotations.OfType<PipelineConfigurationAnnotation>()) 2571var firstDependencies = await first.Resource.GetResourceDependenciesAsync( 2574var secondDependencies = await second.Resource.GetResourceDependenciesAsync( 2577Assert.Contains(second.Resource, firstDependencies); 2578Assert.Contains(first.Resource, secondDependencies); 2579var steps = await CreateStepsAsync(app, sandboxGroup.Resource); 2588foreach (var annotation in sandboxGroup.Resource.Annotations.OfType<PipelineConfigurationAnnotation>()) 2621project.Resource); 2625Assert.True(AzureSandboxContainerDeployment.HasModeledCommandConfiguration(project.Resource)); 2629Assert.True(AzureSandboxContainerDeployment.HasModeledCommandConfiguration(container.Resource)); 2650api.Resource.GetDeploymentTargetAnnotation(sandboxGroup.Resource)?.DeploymentTarget); 2674var command = await AzureSandboxContainerDeployment.ResolveModeledCommandAsync(stepContext, worker.Resource); 2709worker.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();

41var manifest = await AzureManifestUtils.GetManifestWithBicep(serviceBus.Resource); 66var manifest = await AzureManifestUtils.GetManifestWithBicep(serviceBus.Resource); 98await app.ResourceNotifications.WaitForResourceAsync(resource.Resource.Name, KnownResourceStates.Running, cts.Token); 100await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Waiting, cts.Token); 104await app.ResourceNotifications.WaitForResourceHealthyAsync(resource.Resource.Name, cts.Token); 106await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running, cts.Token); 132hb.Configuration["ConnectionStrings:servicebusns"] = await serviceBus.Resource.ConnectionStringExpression.GetValueAsync(CancellationToken.None); 139await rns.WaitForResourceAsync(serviceBus.Resource.Name, KnownResourceStates.Running, cts.Token); 140await rns.WaitForResourceHealthyAsync(serviceBus.Resource.Name, cts.Token); 144await using var sender = serviceBusClient.CreateSender(queueResource.Resource.QueueName); 147await using var receiver = serviceBusClient.CreateReceiver(queueResource.Resource.QueueName); 167serviceBus.Resource.Annotations.OfType<EndpointAnnotation>(), 190var containerImageAnnotation = serviceBus.Resource.Annotations.OfType<ContainerImageAnnotation>().FirstOrDefault(); 268var manifest = await AzureManifestUtils.GetManifestWithBicep(serviceBus.Resource); 626Assert.Same(serviceBus.Resource.Annotations, sourceResource.Annotations); 628var persistenceAnnotation = Assert.Single(serviceBus.Resource.Annotations.OfType<PersistenceAnnotation>()); 679Assert.Equal("{sb.outputs.serviceBusEndpoint}", serviceBus.Resource.ConnectionStringExpression.ValueExpression); 680Assert.Equal("Endpoint={sb.outputs.serviceBusEndpoint};EntityPath=queue", queue.Resource.ConnectionStringExpression.ValueExpression); 681Assert.Equal("Endpoint={sb.outputs.serviceBusEndpoint};EntityPath=topic", topic.Resource.ConnectionStringExpression.ValueExpression); 682Assert.Equal("Endpoint={sb.outputs.serviceBusEndpoint};EntityPath=topic/Subscriptions/sub", subscription.Resource.ConnectionStringExpression.ValueExpression); 696((IResourceWithAzureFunctionsConfig)serviceBus.Resource).ApplyAzureFunctionsConfiguration(target, "sb"); 702((IResourceWithAzureFunctionsConfig)queue.Resource).ApplyAzureFunctionsConfiguration(target, "queue"); 709((IResourceWithAzureFunctionsConfig)topic.Resource).ApplyAzureFunctionsConfiguration(target, "topic"); 716((IResourceWithAzureFunctionsConfig)subscription.Resource).ApplyAzureFunctionsConfiguration(target, "sub"); 752serviceBus.Resource.Outputs["serviceBusEndpoint"] = "mynamespaceEndpoint"; 754var connectionStringResource = (IResourceWithConnectionString)serviceBus.Resource; 756Assert.Equal("sb", serviceBus.Resource.Name); 762var manifest = await GetManifestWithBicep(model, serviceBus.Resource); 845hb.Configuration["ConnectionStrings:servicebusns"] = await serviceBus.Resource.ConnectionStringExpression.GetValueAsync(CancellationToken.None); 848await app.ResourceNotifications.WaitForResourceAsync(serviceBus.Resource.Name, KnownResourceStates.Running, cts.Token); 849await app.ResourceNotifications.WaitForResourceHealthyAsync(serviceBus.Resource.Name, cts.Token); 856await using var sender = serviceBusClient.CreateSender(queueResource.Resource.QueueName); 859await using var receiver = serviceBusClient.CreateReceiver(queueResource.Resource.QueueName); 923Assert.True(serviceBus.Resource.IsEmulator()); 924Assert.Contains(serviceBus.Resource.Annotations, a => a is EmulatorResourceAnnotation); 954_ = serviceBus.Resource.AddAsExistingResource(infra); 957var (manifest, bicep) = await AzureManifestUtils.GetManifestWithBicep(module.Resource, skipPreparer: true); 976_ = serviceBus.Resource.AddAsExistingResource(infra); 979var (manifest, bicep) = await AzureManifestUtils.GetManifestWithBicep(module.Resource, skipPreparer: true); 995_ = serviceBus.Resource.AddAsExistingResource(infra); 998var (manifest, bicep) = await AzureManifestUtils.GetManifestWithBicep(module.Resource, skipPreparer: true); 1016_ = serviceBus.Resource.AddAsExistingResource(infra); 1019var (manifest, bicep) = await AzureManifestUtils.GetManifestWithBicep(module.Resource, skipPreparer: true); 1036_ = serviceBus.Resource.AddAsExistingResource(infra); 1039var (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);

127Assert.Same(identity.Resource, identityAnnotation.IdentityResource); 174Assert.Same(identity.Resource, identityAnnotation.IdentityResource); 179Assert.Same(storage.Resource, roleAssignmentResource.TargetAzureResource); 232Assert.Same(identity.Resource, identityAnnotation.IdentityResource); 237Assert.Same(storage.Resource, roleAssignmentResource.TargetAzureResource); 315Assert.Same(identity.Resource, identityAnnotation.IdentityResource); 316Assert.Same(identity.Resource, identityAnnotation2.IdentityResource); 323Assert.Same(storage.Resource, roleAssignmentResource.TargetAzureResource); 325Assert.Same(storage.Resource, roleAssignmentResource2.TargetAzureResource); 373_ = userAssignedIdentity.Resource.AddAsExistingResource(infra); 376var (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);

23await BicepUtilities.SetParametersAsync(parameters, bicep0.Resource); 55.WithParameter("expr", ReferenceExpression.Create($"{param.Resource}/1")) 59await BicepUtilities.SetParametersAsync(parameters, bicep0.Resource); 73Assert.True(bicep0.Resource.TryGetAnnotationsOfType<ResourceRelationshipAnnotation>(out var relationships)); 78Assert.Equal(connectionStringResource.Resource, r.Resource); 83Assert.Equal(param.Resource, r.Resource); 88Assert.Equal(container.Resource, r.Resource); 110await BicepUtilities.SetParametersAsync(parameters0, bicep0.Resource); 111var checkSum0 = BicepUtilities.GetChecksum(bicep0.Resource, parameters0, null); 114await BicepUtilities.SetParametersAsync(parameters1, bicep1.Resource); 115var checkSum1 = BicepUtilities.GetChecksum(bicep1.Resource, parameters1, null); 137await BicepUtilities.SetParametersAsync(parameters0, bicep0.Resource); 138var checkSum0 = BicepUtilities.GetChecksum(bicep0.Resource, parameters0, null); 141await BicepUtilities.SetParametersAsync(parameters1, bicep1.Resource); 142var checkSum1 = BicepUtilities.GetChecksum(bicep1.Resource, parameters1, null); 154bicep0.Resource.Scope = new("rg0"); 158bicep1.Resource.Scope = new("rg1"); 162await BicepUtilities.SetParametersAsync(parameters0, bicep0.Resource); 163await BicepUtilities.SetScopeAsync(scope0, bicep0.Resource); 164var checkSum0 = BicepUtilities.GetChecksum(bicep0.Resource, parameters0, scope0); 168await BicepUtilities.SetParametersAsync(parameters1, bicep1.Resource); 169await BicepUtilities.SetScopeAsync(scope1, bicep1.Resource); 170var checkSum1 = BicepUtilities.GetChecksum(bicep1.Resource, parameters1, scope1); 182bicep0.Resource.Scope = new("rg0"); 186bicep1.Resource.Scope = new("rg0"); 190await BicepUtilities.SetParametersAsync(parameters0, bicep0.Resource); 191await BicepUtilities.SetScopeAsync(scope0, bicep0.Resource); 192var checkSum0 = BicepUtilities.GetChecksum(bicep0.Resource, parameters0, scope0); 196await BicepUtilities.SetParametersAsync(parameters1, bicep1.Resource); 197await BicepUtilities.SetScopeAsync(scope1, bicep1.Resource); 198var checkSum1 = BicepUtilities.GetChecksum(bicep1.Resource, parameters1, scope1); 208var bicep1 = builder.AddBicepTemplateString("test1", "param name string").Resource; 209var bicep2 = builder.AddBicepTemplateString("test2", "param name string").Resource; 229var bicep = builder.AddBicepTemplateString("test", "param name string").Resource; 254var bicep = builder.AddBicepTemplateString("test", "param name string").Resource; 282var bicep = builder.AddBicepTemplateString("test", "param name string").Resource; 314var bicep = builder.AddBicepTemplateString("test", "param name string").Resource; 335var bicep = builder.AddBicepTemplateString("test", "param name string").Resource; 350var bicep = builder.AddBicepTemplateString("test", "param name string").Resource; 366var bicep = builder.AddBicepTemplateString("test", "param name string").Resource; 381var bicep = builder.AddBicepTemplateString("test", "param name string").Resource; 400var bicep = builder.AddBicepTemplateString("test", "param name string").Resource; 415var bicep = builder.AddBicepTemplateString("test", "param name string").Resource; 429var bicep = builder.AddBicepTemplateString("test", "param name string").Resource; 441var bicep = builder.AddBicepTemplateString("test", "param name string").Resource; 459var bicep = builder.AddBicepTemplateString("test", "param name string").Resource; 486.Resource; 523var bicep = builder.AddBicepTemplateString("test", "param name string").Resource;

30var connectionString = await dts.Resource.ConnectionStringExpression.GetValueAsync(default); 46var connectionString = await dts.Resource.ConnectionStringExpression.GetValueAsync(default); 64var connectionString = await dts.Resource.ConnectionStringExpression.GetValueAsync(default); 89var connectionString = await taskHub.Resource.ConnectionStringExpression.GetValueAsync(default); 101Assert.True(dts.Resource.TryGetAnnotationsOfType<ManifestPublishingCallbackAnnotation>(out var manifestAnnotations)); 114Assert.True(taskHub.Resource.TryGetAnnotationsOfType<ManifestPublishingCallbackAnnotation>(out var manifestAnnotations)); 130var ex = Assert.Throws<InvalidOperationException>(() => _ = dts.Resource.ConnectionStringExpression); 142Assert.False(dts.Resource.IsEmulator); 143Assert.DoesNotContain(dts.Resource.Annotations, a => a is EmulatorResourceAnnotation); 145Assert.Throws<InvalidOperationException>(() => _ = dts.Resource.ConnectionStringExpression); 156Assert.True(dts.Resource.IsEmulator); 158var emulatorAnnotation = dts.Resource.Annotations.OfType<EmulatorResourceAnnotation>().SingleOrDefault(); 161var containerImageAnnotation = dts.Resource.Annotations.OfType<ContainerImageAnnotation>().SingleOrDefault(); 167var endpointAnnotations = dts.Resource.Annotations.OfType<EndpointAnnotation>().ToList(); 193var env = await EnvironmentVariableEvaluator.GetEnvironmentVariablesAsync(dts.Resource, DistributedApplicationOperation.Run, TestServiceProvider.Instance); 208var env = await EnvironmentVariableEvaluator.GetEnvironmentVariablesAsync(dts.Resource, DistributedApplicationOperation.Run, TestServiceProvider.Instance); 224var env1 = await EnvironmentVariableEvaluator.GetEnvironmentVariablesAsync(dts1.Resource, DistributedApplicationOperation.Run, TestServiceProvider.Instance); 225var env2 = await EnvironmentVariableEvaluator.GetEnvironmentVariablesAsync(dts2.Resource, DistributedApplicationOperation.Run, TestServiceProvider.Instance); 244var connectionString = await hub.Resource.ConnectionStringExpression.GetValueAsync(default); 255var ex = Assert.Throws<InvalidOperationException>(() => _ = dts.Resource.ConnectionStringExpression);

22Assert.False(serviceBus.Resource.IsExisting()); 36Assert.True(serviceBus.Resource.TryGetLastAnnotation<ExistingAzureResourceAnnotation>(out var existingAzureResourceAnnotation)); 57Assert.True(serviceBus.Resource.TryGetLastAnnotation<ExistingAzureResourceAnnotation>(out var existingAzureResourceAnnotation)); 75Assert.True(serviceBus.Resource.TryGetLastAnnotation<ExistingAzureResourceAnnotation>(out var existingAzureResourceAnnotation)); 96Assert.True(serviceBus.Resource.TryGetLastAnnotation<ExistingAzureResourceAnnotation>(out var existingAzureResourceAnnotation)); 116Assert.True(serviceBus.Resource.TryGetLastAnnotation<ExistingAzureResourceAnnotation>(out var existingAzureResourceAnnotation)); 134Assert.True(serviceBus.Resource.TryGetLastAnnotation<ExistingAzureResourceAnnotation>(out var existingAzureResourceAnnotation)); 155Assert.True(serviceBus.Resource.TryGetLastAnnotation<ExistingAzureResourceAnnotation>(out var existingAzureResourceAnnotation)); 173Assert.True(serviceBus.Resource.TryGetLastAnnotation<ExistingAzureResourceAnnotation>(out var existingAzureResourceAnnotation)); 193Assert.True(serviceBus.Resource.TryGetLastAnnotation<ExistingAzureResourceAnnotation>(out var existingAzureResourceAnnotation)); 214Assert.True(serviceBus.Resource.TryGetLastAnnotation<ExistingAzureResourceAnnotation>(out var existingAzureResourceAnnotation));

23var (manifest, bicep) = await AzureManifestUtils.GetManifestWithBicep(serviceBus.Resource); 40var (manifest, bicep) = await AzureManifestUtils.GetManifestWithBicep(serviceBus.Resource); 57var (manifest, bicep) = await AzureManifestUtils.GetManifestWithBicep(serviceBus.Resource); 77var (manifest, bicep) = await GetManifestWithBicep(model, serviceBus.Resource); 97var (manifest, bicep) = await AzureManifestUtils.GetManifestWithBicep(serviceBus.Resource); 114var (manifest, bicep) = await AzureManifestUtils.GetManifestWithBicep(storageAccount.Resource); 129var (manifest, bicep) = await AzureManifestUtils.GetManifestWithBicep(storageAccount.Resource); 146var (manifest, bicep) = await AzureManifestUtils.GetManifestWithBicep(appConfiguration.Resource); 163var (manifest, bicep) = await AzureManifestUtils.GetManifestWithBicep(eventHubs.Resource); 180var (manifest, bicep) = await AzureManifestUtils.GetManifestWithBicep(keyVault.Resource); 197var (manifest, bicep) = await AzureManifestUtils.GetManifestWithBicep(logAnalytics.Resource); 214var (manifest, bicep) = await AzureManifestUtils.GetManifestWithBicep(postgresSql.Resource); 235var (manifest, bicep) = await AzureManifestUtils.GetManifestWithBicep(postgresSql.Resource); 252var (manifest, bicep) = await AzureManifestUtils.GetManifestWithBicep(search.Resource); 269var (manifest, bicep) = await AzureManifestUtils.GetManifestWithBicep(signalR.Resource); 286var (manifest, bicep) = await AzureManifestUtils.GetManifestWithBicep(webPubSub.Resource); 303var (manifest, bicep) = await AzureManifestUtils.GetManifestWithBicep(sqlServer.Resource); 319var (manifest, bicep) = await AzureManifestUtils.GetManifestWithBicep(sqlServer.Resource); 337var (manifest, bicep) = await AzureManifestUtils.GetManifestWithBicep(redis.Resource); 354var (manifest, bicep) = await AzureManifestUtils.GetManifestWithBicep(redis.Resource); 371var (manifest, bicep) = await AzureManifestUtils.GetManifestWithBicep(redis.Resource); 386var (manifest, bicep) = await AzureManifestUtils.GetManifestWithBicep(redis.Resource); 402var (manifest, bicep) = await AzureManifestUtils.GetManifestWithBicep(appInsights.Resource); 425var (manifest, bicep) = await AzureManifestUtils.GetManifestWithBicep(openAI.Resource); 445var (manifest, bicep) = await AzureManifestUtils.GetManifestWithBicep(cosmos.Resource); 466var (manifest, bicep) = await AzureManifestUtils.GetManifestWithBicep(cosmos.Resource); 482var (manifest, bicep) = await AzureManifestUtils.GetManifestWithBicep(acr.Resource); 499var (manifest, bicep) = await AzureManifestUtils.GetManifestWithBicep(acr.Resource); 521Assert.Null(serviceBus.Resource.GetDeploymentTargetAnnotation()); 522Assert.True(serviceBus.Resource.TryGetLastAnnotation<ExistingAzureResourceAnnotation>(out var existingAzureResourceAnnotation)); 541Assert.Null(serviceBus.Resource.GetDeploymentTargetAnnotation()); 542Assert.True(serviceBus.Resource.TryGetLastAnnotation<ExistingAzureResourceAnnotation>(out var existingAzureResourceAnnotation)); 562var (manifest, bicep) = await GetManifestWithBicep(model, serviceBus.Resource); 588resource.Resource.Scope = AzureBicepResourceScope.CreateForSubscription(existingSubscriptionId.Resource); 590var (manifest, bicep) = await AzureManifestUtils.GetManifestWithBicep(resource.Resource, skipPreparer: true); 607resource.Resource.Scope = AzureBicepResourceScope.CreateForTenant(); 609var (manifest, bicep) = await AzureManifestUtils.GetManifestWithBicep(resource.Resource, skipPreparer: true);

17var properties = ((IResourceWithConnectionString)aiFoundry.Resource).GetConnectionProperties().ToArray(); 40aiFoundry.Resource.EmulatorServiceUri = new Uri("http://localhost:8080"); 41aiFoundry.Resource.ApiKey = "OPENAI_KEY"; 43var properties = ((IResourceWithConnectionString)aiFoundry.Resource).GetConnectionProperties().ToArray();

21deployment.Resource.Parent.EmulatorServiceUri = new Uri("http://localhost:8080"); 22deployment.Resource.Parent.ApiKey = "OPENAI_KEY"; 24var properties = ((IResourceWithConnectionString)deployment.Resource).GetConnectionProperties().ToArray(); 67var properties = ((IResourceWithConnectionString)deployment.Resource).GetConnectionProperties().ToArray();

157Assert.Equal("{myAIFoundry.connectionString};Model=gpt-4", deployment.Resource.ConnectionStringExpression.ValueExpression); 168deployment.Resource.ModelId = "custom-model-id"; 170Assert.Equal("{myAIFoundry.connectionString};Model=custom-model-id", deployment.Resource.ConnectionStringExpression.ValueExpression); 183Assert.Equal("{myAIFoundry.connectionString};Deployment=deployment1", deployment.Resource.ConnectionStringExpression.ValueExpression); 199var manifest = await AzureManifestUtils.GetManifestWithBicep(model, foundry.Resource); 217Assert.Same(foundry.Resource, project.Resource.Parent); 230Assert.Null(project.Resource.ContainerRegistry); 245var (_, bicepText) = await AzureManifestUtils.GetManifestWithBicep(model, project.Resource); 265var (_, bicepText) = await AzureManifestUtils.GetManifestWithBicep(model, project.Resource); 283var (_, bicepText) = await AzureManifestUtils.GetManifestWithBicep(model, foundry.Resource); 330SetFoundryProjectOutputs(project.Resource); 336advisorAgent.Resource, 359SetFoundryProjectOutputs(project.Resource); 365advisorAgent.Resource, 400SetFoundryProjectOutputs(project.Resource); 406advisorAgent.Resource, 441SetFoundryProjectOutputs(project.Resource); 447advisorAgent.Resource, 483advisorAgent.Resource,

21var parent = new AzureCosmosDBDatabaseResource("database", "cosmos-db", resource.Resource); 41var parent = new AzureCosmosDBDatabaseResource("database", "cosmos-db", resource.Resource); 61var parent = new AzureCosmosDBDatabaseResource("database", "cosmos-db", resource.Resource); 81var parent = new AzureCosmosDBDatabaseResource("database", "cosmos-db", resource.Resource); 101var parent = new AzureCosmosDBDatabaseResource("database", "cosmos-db", resource.Resource); 119var parent = new AzureCosmosDBDatabaseResource("database", "cosmos-db", resource.Resource); 135var parent = new AzureCosmosDBDatabaseResource("database", "cosmos-db", resource.Resource); 153var parent = new AzureCosmosDBDatabaseResource("database", "cosmos-db", resource.Resource); 199var action = () => new AzureCosmosDBDatabaseResource(name, databaseName, parent.Resource); 217var action = () => new AzureCosmosDBDatabaseResource(name, databaseName, parent.Resource);

21var parent = new AzureEventHubResource("hub", "event-hub", resource.Resource); 40var parent = new AzureEventHubResource("hub", "event-hub", resource.Resource);

16var storageResource = builder.AddAzureStorage("storage").Resource; 28var blobResource = storageResource.AddBlobs("blobs").Resource; 40var queueResource = storageResource.AddQueues("queues").Resource; 51var cosmosResource = builder.AddAzureCosmosDB("cosmos").Resource; 63var dbResource = cosmosResource.AddCosmosDatabase("database").Resource; 76var containerResource = dbResource.AddContainer("container", "/id").Resource; 87var eventHubsResource = builder.AddAzureEventHubs("eventhubs").Resource; 98var serviceBusResource = builder.AddAzureServiceBus("servicebus").Resource; 109var storage = builder.AddAzureStorage("storage").RunAsEmulator().Resource; 127var storage = builder.AddAzureStorage("storage").Resource; 148var blobResource = storage.AddBlobs("blobs").Resource; 165var tableResource = storage.AddTables("tables").Resource; 182var queueResource = storage.AddQueues("queues").Resource; 198var cosmosResource = builder.AddAzureCosmosDB("cosmos").RunAsEmulator().Resource; 214var cosmosResource = builder.AddAzureCosmosDB("cosmos").WithAccessKeyAuthentication().Resource; 230var cosmosResource = builder.AddAzureCosmosDB("cosmos").Resource; 247var dbResource = cosmosResource.AddCosmosDatabase("database").Resource; 256Assert.Equal(cosmosResource.Resource.ConnectionStringExpression.ValueExpression, targetReferenceExpression.ValueExpression); 259Assert.Equal(cosmosResource.Resource.ConnectionStringExpression.ValueExpression, targetReferenceExpression.ValueExpression); 272var containerResource = cosmosResource.AddCosmosDatabase("database").AddContainer("container", "/partitionKey").Resource; 281Assert.Equal(targetReferenceExpression.ValueExpression, cosmosResource.Resource.ConnectionStringExpression.ValueExpression); 284Assert.Equal(targetReferenceExpression.ValueExpression, cosmosResource.Resource.ConnectionStringExpression.ValueExpression); 300var dbResource = cosmosResource.AddCosmosDatabase("database").Resource; 309Assert.Equal(targetReferenceExpression.ValueExpression, cosmosResource.Resource.ConnectionStringExpression.ValueExpression); 322var containerResource = cosmosResource.AddCosmosDatabase("database").AddContainer("container", "/partitionKey").Resource; 331Assert.Equal(targetReferenceExpression.ValueExpression, cosmosResource.Resource.ConnectionStringExpression.ValueExpression); 342var eventHubsResource = builder.AddAzureEventHubs("eventhubs").RunAsEmulator().Resource; 362var eventHubsResource = builder.AddAzureEventHubs("eventhubs").Resource; 382var serviceBusResource = builder.AddAzureServiceBus("servicebus").Resource; 399var queueResource = serviceBusResource.AddServiceBusQueue("ordersqueue").Resource; 418var queueResource = serviceBusResource.AddServiceBusQueue("ordersqueue").Resource; 438var topicResource = serviceBusResource.AddServiceBusTopic("notificationstopic").Resource; 457var topicResource = serviceBusResource.AddServiceBusTopic("notificationstopic").Resource; 478var subscriptionResource = topicResource.AddServiceBusSubscription("usersubscription").Resource; 500var subscriptionResource = topicResource.AddServiceBusSubscription("usersubscription").Resource; 515Assert.Equal(serviceBusResource.Resource.ConnectionStringExpression.ValueExpression, connectionStringExpression.ValueExpression);

190if (!builder.Resource.Hubs.TryGetValue(hubName, out hubResource)) 192hubResource = new AzureWebPubSubHubResource(name, hubName, builder.Resource); 193builder.Resource.Hubs[hubName] = hubResource; 250builder.Resource.EventHandlers.Add((urlExpression, userEventPattern, systemEvents, authSettings));

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

233var pathPrefix = wasmApp.Resource.Name; 238var referencedServices = GetServiceDiscoveryReferences(wasmApp.Resource); 244var existingGatewayRefs = GetReferencedResourceNames(gateway.Resource); 256wasmApp.Resource.Parent = gateway.Resource; 269gateway.Resource, 271wasmApp.Resource.ProjectPath, 273browser: wasmApp.Resource.DebuggerBrowser); 293wasmApp.Resource.DebuggerBrowser = browser; 317var annotation = GetOrAddGatewayAppsAnnotation(gateway.Resource); 320GetBlazorStorePath(gateway.ApplicationBuilder), "gateways", gateway.Resource.Name); 329var registeredApps = GetRegisteredApps(gateway.Resource); 330var httpsGatewayEndpoint = GetEndpointIfDefined(gateway.Resource, "https"); 331var httpGatewayEndpoint = GetEndpointIfDefined(gateway.Resource, "http"); 333?? throw new InvalidOperationException($"The gateway '{gateway.Resource.Name}' must define an HTTP or HTTPS endpoint."); 410gateway.ApplicationBuilder.Eventing.Subscribe<InitializeResourceEvent>(gateway.Resource, (e, ct) => 413_ = Task.Run(() => WatchGatewayStateAsync(gateway.Resource, notificationService, ct), ct); 442await notificationService.PublishUpdateAsync(reg.AppBuilder.Resource, snapshot => snapshot with 535var publishResourceName = $"{wasmApp.Resource.Name}publish"; 536var project = GetProjectInfo(wasmApp.Resource.ProjectPath, gateway.ApplicationBuilder.AppHostDirectory); 538project.SolutionRoot, wasmApp.Resource.ProjectPath).Replace('\\', '/'); 574Source = companion.Resource,

36var annotation = GetOrAddHostedClientAnnotation(host.Resource); 37annotation.Services.Add(new HostedClientService(service.Resource.Name, apiPrefix)); 40var existingRefs = GetReferencedResourceNames(host.Resource); 41if (!existingRefs.Contains(service.Resource.Name)) 64var annotation = GetOrAddHostedClientAnnotation(host.Resource); 85var annotation = GetOrAddHostedClientAnnotation(host.Resource); 105var debuggerName = $"{host.Resource.Name}-wasm-debugger"; 108var projectMetadata = host.Resource.GetProjectMetadata(); 136var httpsHostEndpoint = GetEndpointIfDefined(host.Resource, "https"); 137var httpHostEndpoint = GetEndpointIfDefined(host.Resource, "http"); 139?? throw new InvalidOperationException($"The host '{host.Resource.Name}' must define an HTTP or HTTPS endpoint."); 156$"{host.Resource.Name} (client)", 291host.Resource,

70? $"{parentResource.Name}-{commandTarget.Resource.Name}-debugger" 183commandTarget.Resource, 197await notificationService.PublishUpdateAsync(commandTarget.Resource, s => s).ConfigureAwait(false); 256await notificationService.PublishUpdateAsync(commandTarget.Resource, s => s).ConfigureAwait(false);

26public BlazorWasmAppResource Resource => AppBuilder.Resource;

23Assert.True(gateway.Resource.TryGetLastAnnotation<IProjectMetadata>(out var projectMetadata)); 29gateway.Resource.Annotations.OfType<EndpointAnnotation>().Select(e => e.Name)); 31var annotation = gateway.Resource.Annotations.OfType<GatewayAppsAnnotation>().SingleOrDefault(); 54var gatewayRefs = gateway.Resource.Annotations

179Assert.Same(host.Resource, parentRelationship.Resource); 181var commands = host.Resource.Annotations 214host.Resource.Annotations.OfType<ResourceCommandAnnotation>(), 240host.Resource.Annotations.OfType<ResourceCommandAnnotation>(), 250ResourceName = host.Resource.Name, 338var endpointRef = host.Resource.Annotations 389var weatherRefs = host.Resource.Annotations 411var referencedNames = host.Resource.Annotations 469var (_, sink) = await GetEnvironmentVariablesWithLogs(gateway.Resource, builder); 490var (_, sink) = await GetEnvironmentVariablesWithLogs(gateway.Resource, builder);

28var annotation = gateway.Resource.Annotations.OfType<GatewayAppsAnnotation>().SingleOrDefault(); 50var annotation = gateway.Resource.Annotations.OfType<GatewayAppsAnnotation>().SingleOrDefault(); 74var annotations = gateway.Resource.Annotations.OfType<GatewayAppsAnnotation>().ToList(); 97var gatewayRefs = gateway.Resource.Annotations 124var weatherRefs = gateway.Resource.Annotations 152var refs = gateway.Resource.Annotations 173var annotation = gateway.Resource.Annotations.OfType<GatewayAppsAnnotation>().SingleOrDefault(); 202Assert.Same(gateway.Resource, parentRelationship.Resource); 208var commandNames = wasmApp.Resource.Annotations 214Assert.DoesNotContain(gateway.Resource.Annotations, annotation => annotation is ResourceCommandAnnotation); 231Assert.DoesNotContain(wasmApp.Resource.Annotations, annotation => annotation is ResourceCommandAnnotation); 232Assert.Single(gateway.Resource.Annotations.OfType<GatewayAppsAnnotation>()); 249var commands = wasmApp.Resource.Annotations.OfType<ResourceCommandAnnotation>().ToDictionary(annotation => annotation.Name); 289wasmApp.Resource.Annotations.OfType<ResourceCommandAnnotation>(), 316wasmApp.Resource.Annotations.OfType<ResourceCommandAnnotation>(), 323ResourceName = wasmApp.Resource.Name, 355Assert.Equal(wasmApp.Resource.ProjectPath, launchConfiguration.WebRoot); 372var annotation = gateway.Resource.Annotations.OfType<GatewayAppsAnnotation>().SingleOrDefault(); 397var endpointRef = gateway.Resource.Annotations 426var endpointRef = gateway.Resource.Annotations 437var annotation = gateway.Resource.Annotations.OfType<GatewayAppsAnnotation>().Single(); 467var endpointRef = gateway.Resource.Annotations 478var annotation = gateway.Resource.Annotations.OfType<GatewayAppsAnnotation>().Single();

130var parentResource = builder.Resource;

49Assert.Equal(web.Resource.Name, browserLogsResource.ParentResource.Name); 56Assert.Equal(web.Resource.Name, parentRelationship.Resource.Name); 1353await app.ResourceNotifications.PublishUpdateAsync(web.Resource, snapshot => snapshot with 1359await eventing.PublishAsync(new ResourceReadyEvent(web.Resource, app.Services)).DefaultTimeout();

130var parentResource = builder.Resource;

16Assert.Equal("redis-stack", redis.Resource.Annotations.OfType<ContainerImageAnnotation>().Single().Image); 24Assert.Equal("redis-stack", redis.Resource.Annotations.OfType<ContainerImageAnnotation>().Single().Image); 25Assert.Equal("1.0.0", redis.Resource.Annotations.OfType<ContainerImageAnnotation>().Single().Tag); 33container.Resource.Annotations.RemoveAt(0); 36Assert.Equal("new-image", container.Resource.Annotations.OfType<ContainerImageAnnotation>().Single().Image); 37Assert.Equal("latest", container.Resource.Annotations.OfType<ContainerImageAnnotation>().Single().Tag); 45container.Resource.Annotations.Add(new ContainerImageAnnotation { Image = "another-image" }); 48Assert.Equal("new-image", container.Resource.Annotations.OfType<ContainerImageAnnotation>().Last().Image); 49Assert.Equal("latest", container.Resource.Annotations.OfType<ContainerImageAnnotation>().Last().Tag); 57Assert.Equal("7.1", redis.Resource.Annotations.OfType<ContainerImageAnnotation>().Single().Tag); 65Assert.Equal("myregistry.azurecr.io", redis.Resource.Annotations.OfType<ContainerImageAnnotation>().Single().Registry); 73Assert.Equal("42b5c726e719639fcc1e9dbc13dd843f567dcd37911d0e1abb9f47f2cc1c95cd", redis.Resource.Annotations.OfType<ContainerImageAnnotation>().Single().SHA256); 151var annotation = redis.Resource.Annotations.OfType<ContainerImageAnnotation>().Single(); 163var annotation = redis.Resource.Annotations.OfType<ContainerImageAnnotation>().Single(); 176var annotation = redis.Resource.Annotations.OfType<ContainerImageAnnotation>().Single(); 212var annotation = redis.Resource.Annotations.OfType<ContainerImagePullPolicyAnnotation>().Single(); 220var containerImage = builder.Resource.Annotations.OfType<ContainerImageAnnotation>().Single();

125var args = await ArgumentEvaluator.GetArgumentListAsync(c2.Resource); 135Assert.False(c2.Resource.TryGetAnnotationsOfType<ResourceRelationshipAnnotation>(out var relationships)); 137var manifest = await ManifestUtils.GetManifest(c2.Resource);

34await app.ResourceNotifications.WaitForResourceAsync(container.Resource.Name, KnownResourceStates.FailedToStart, cts.Token).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 58await app.ResourceNotifications.WaitForResourceAsync(container.Resource.Name, KnownResourceStates.FailedToStart, cts.Token).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 82await app.ResourceNotifications.WaitForResourceAsync(container.Resource.Name, KnownResourceStates.FailedToStart, cts.Token).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 105await app.ResourceNotifications.WaitForResourceAsync(container.Resource.Name, [KnownResourceStates.Exited, KnownResourceStates.FailedToStart], cts.Token).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 118var category = $"{builder.ApplicationBuilder.Environment.ApplicationName}.Resources.{builder.Resource.Name}";

106Assert.True(dockerFile.Resource.TryGetContainerImageName(out var imageName)); 110Assert.True(dockerFile.Resource.TryGetLastAnnotation<DockerfileBuildAnnotation>(out var buildAnnotation)); 131Assert.True(dockerFile.Resource.TryGetLastAnnotation<ContainerImageAnnotation>(out var containerImageAnnotation)); 135Assert.True(dockerFile.Resource.TryGetLastAnnotation<DockerfileBuildAnnotation>(out var buildAnnotation)); 139Assert.True(dockerFile.Resource.TryGetContainerImageName(out var imageName)); 154Assert.True(dockerFile.Resource.TryGetLastAnnotation<DockerfileBuildAnnotation>(out var buildAnnotation1)); 158Assert.True(dockerFile.Resource.TryGetLastAnnotation<DockerfileBuildAnnotation>(out var buildAnnotation2)); 176Assert.True(dockerFile.Resource.TryGetLastAnnotation<DockerfileBuildAnnotation>(out var buildAnnotation1)); 180Assert.True(dockerFile.Resource.TryGetLastAnnotation<DockerfileBuildAnnotation>(out var buildAnnotation2)); 187Assert.True(dockerFile.Resource.TryGetContainerImageName(out var imageName)); 282var manifest = await ManifestUtils.GetManifest(container.Resource, manifestDirectory: tempContextPath); 331var manifest = await ManifestUtils.GetManifest(container.Resource, manifestDirectory: tempContextPath); 379var manifest = await ManifestUtils.GetManifest(container.Resource, manifestDirectory: tempContextPath); 426var manifest = await ManifestUtils.GetManifest(container.Resource, manifestDirectory: tempContextPath); 656var annotation = Assert.Single(container.Resource.Annotations.OfType<DockerfileBuildAnnotation>()); 672var annotation = Assert.Single(container.Resource.Annotations.OfType<DockerfileBuildAnnotation>()); 689var annotation = Assert.Single(container.Resource.Annotations.OfType<DockerfileBuildAnnotation>()); 705var annotation = Assert.Single(container.Resource.Annotations.OfType<DockerfileBuildAnnotation>()); 722var annotation = Assert.Single(container.Resource.Annotations.OfType<DockerfileBuildAnnotation>()); 738var annotation = Assert.Single(container.Resource.Annotations.OfType<DockerfileBuildAnnotation>()); 755var annotation = Assert.Single(container.Resource.Annotations.OfType<DockerfileBuildAnnotation>()); 771var annotation = Assert.Single(container.Resource.Annotations.OfType<DockerfileBuildAnnotation>()); 796var annotation = Assert.Single(container.Resource.Annotations.OfType<DockerfileBuildAnnotation>()); 800var stepsAnnotation = Assert.Single(container.Resource.Annotations.OfType<PipelineStepAnnotation>()); 805Resource = container.Resource 823Resource = container.Resource, 848var annotation = Assert.Single(container.Resource.Annotations.OfType<DockerfileBuildAnnotation>()); 856Resource = container.Resource, 882var manifest = await ManifestUtils.GetManifest(container.Resource, manifestDirectory: tempContextPath); 901var annotation = Assert.Single(container.Resource.Annotations.OfType<DockerfileBuildAnnotation>());