10public T Resource { get; } = resource;

47builder.Resource.Certificates.Add(certificate); 62builder.Resource.Certificates.AddRange(certificates); 77builder.Resource.Certificates.AddRange(certificates.ToArray()); 116builder.Resource.Certificates.AddRange(certificates.ToArray());

222_valueProviders.Add(valueProvider.Resource); 223_manifestExpressions.Add(valueProvider.Resource.ValueExpression); 416builder.AppendFormatted(valueProvider.Resource, format);

539(DistributedApplicationOperation.Run, IResourceBuilder<IResource> rb) when rb.Resource is IValueProvider provider => await resource.GetValue(executionContext, key, provider, logger, cancellationToken).ConfigureAwait(false), 541(DistributedApplicationOperation.Publish, IResourceBuilder<IResource> rb) when rb.Resource is IManifestExpressionProvider provider => new(provider.ValueExpression, false),

33if (!builder.Resource.RequiresImageBuild() || builder.Resource.IsExcludedFromPublish()) 40Name = $"build-{builder.Resource.Name}", 46builder.Resource, 246builder.Resource.Entrypoint = entrypoint; 262if (builder.Resource.Annotations.OfType<ContainerImageAnnotation>().LastOrDefault() is { } existingImageAnnotation) 268if (builder.Resource.Annotations.OfType<DockerfileBuildAnnotation>().SingleOrDefault() is { } buildAnnotation && 291if (builder.Resource.Annotations.OfType<ContainerImageAnnotation>().LastOrDefault() is { } existingImageAnnotation) 330if (builder.Resource.Annotations.OfType<ContainerImageAnnotation>().LastOrDefault() is { } imageAnnotation) 337builder.Resource.Annotations.Add(imageAnnotation); 358if (builder.Resource.Annotations.OfType<DockerfileBuildAnnotation>().SingleOrDefault() is { } buildAnnotation) 379if (builder.Resource.Annotations.OfType<ContainerImageAnnotation>().LastOrDefault() is { } existingImageAnnotation) 488throw new InvalidOperationException($"The resource '{builder.Resource.Name}' does not have a container image specified. Use WithImage to specify the container image and tag."); 500return builder.WithManifestPublishingCallback(context => context.WriteContainerAsync(builder.Resource)); 558if (builder.Resource.Annotations.OfType<ContainerImageAnnotation>().LastOrDefault() is { }) 666var tempDockerfilePath = Path.Combine(Path.GetTempPath(), $"Dockerfile.{builder.Resource.Name}.{Guid.NewGuid():N}"); 678if (builder.Resource.Annotations.OfType<ContainerImageAnnotation>().LastOrDefault() is { }) 942var annotation = builder.Resource.Annotations.OfType<DockerfileBuildAnnotation>().SingleOrDefault(); 993if (value.Resource.Secret) 998return builder.WithBuildArg(name, value.Resource); 1040var annotation = builder.Resource.Annotations.OfType<DockerfileBuildAnnotation>().SingleOrDefault(); 1047annotation.BuildSecrets[name] = value.Resource; 1327var callbackAnnotation = builder.Resource.Annotations.OfType<DockerfileBuilderCallbackAnnotation>().LastOrDefault();

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

126if (builder.ApplicationBuilder.TryCreateResourceBuilder<ExecutableContainerResource>(builder.Resource.Name, out var existingBuilder)) 144builder.ApplicationBuilder.Resources.Remove(builder.Resource); 146var container = new ExecutableContainerResource(builder.Resource); 149cb.WithImage(builder.Resource.Name); 150cb.WithDockerfile(contextPath: builder.Resource.WorkingDirectory); 175var executableAnnotation = builder.Resource.Annotations.OfType<ExecutableAnnotation>().LastOrDefault(); 187builder.Resource.Annotations.Add(executableAnnotation); 204if (builder.Resource.Annotations.OfType<ExecutableAnnotation>().LastOrDefault() is { } executableAnnotation) 211throw new InvalidOperationException($"The resource '{builder.Resource.Name}' is missing the ExecutableAnnotation");

70return AddExternalServiceImpl(builder, name, urlParameter: urlParameter.Resource); 192if (builder.Resource.UrlParameter is null) 194if (builder.Resource.Uri is null) 196throw new ArgumentException($"The URL for external service '{builder.Resource.Name}' is null.", nameof(builder)); 198else if (builder.Resource.Uri.Scheme != "http" && builder.Resource.Uri.Scheme != "https") 200throw 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)); 207var healthCheckKey = $"{builder.Resource.Name}_external{pathKey}_{statusCode}_check"; 213if (builder.Resource.UrlParameter is not null) 219builder.Resource.UrlParameter, 229var uri = builder.Resource.Uri!;

170AddOtlpEnvironment(builder.Resource, builder.ApplicationBuilder.Configuration, builder.ApplicationBuilder.Environment); 191AddOtlpEnvironment(builder.Resource, builder.ApplicationBuilder.Configuration, builder.ApplicationBuilder.Environment, protocol);

167builder.Resource.Description = description; 168builder.Resource.EnableDescriptionMarkdown = enableMarkdown; 199builder.Resource.Annotations.Add(new InputGeneratorAnnotation(createInput)); 279var parameter = new ParameterResource(builder.Resource.Name, _ => "", secret: true);

438var logger = resourceLogger.GetLogger(builder.Resource); 446var projectResource = builder.Resource; 540builder.Resource.KestrelEndpointAnnotationHosts[e] = e.TargetHost; 685builder.Resource.DefaultHttpsEndpoint = e; 789builder.Resource.Annotations.Add(new EndpointEnvironmentInjectionFilterAnnotation(filter)); 818if (builder.ApplicationBuilder.TryCreateResourceBuilder<ProjectContainerResource>(builder.Resource.Name, out var existingBuilder)) 832builder.ApplicationBuilder.Resources.Remove(builder.Resource); 834var container = new ProjectContainerResource(builder.Resource); 837cb.WithImage(builder.Resource.Name); 839var projectFilePath = builder.Resource.GetProjectMetadata().ProjectPath; 904foreach (var e in builder.Resource.GetEndpoints().Where(builder.Resource.ShouldInjectEndpointEnvironment)) 953foreach (var e in builder.Resource.GetEndpoints().Where(builder.Resource.ShouldInjectEndpointEnvironment)) 956if (e.EndpointAnnotation.UriScheme == scheme && e.EndpointAnnotation != builder.Resource.DefaultHttpsEndpoint) 982if (builder.Resource.HasKestrelEndpoints) 984foreach (var e in builder.Resource.GetEndpoints().Where(builder.Resource.ShouldInjectEndpointEnvironment)) 987if (e.EndpointAnnotation == builder.Resource.DefaultHttpsEndpoint) 995builder.Resource.KestrelEndpointAnnotationHosts.TryGetValue(e.EndpointAnnotation, out var kestrelHost) ? kestrelHost : "*";

172builder.WithReferenceRelationship(externalService.Resource); 174if (externalService.Resource.Uri is not null) 176builder.WithEnvironment(name, externalService.Resource.Uri.ToString()); 178else if (externalService.Resource.UrlParameter is not null) 185var url = await externalService.Resource.UrlParameter.GetValueAsync(context.CancellationToken).ConfigureAwait(false); 188throw new DistributedApplicationException($"The URL parameter '{externalService.Resource.UrlParameter.Name}' for the external service '{externalService.Resource.Name}' is invalid: {message}"); 192context.EnvironmentVariables[name] = externalService.Resource.UrlParameter; 213builder.WithReferenceRelationship(parameter.Resource); 217context.EnvironmentVariables[name] = parameter.Resource; 239builder.WithReferenceRelationship(resource.Resource); 243context.EnvironmentVariables[envVarName] = new ConnectionStringReference(resource.Resource, optional: false); 472var resource = source.Resource; 478builder.Resource.TryGetLastAnnotation<ReferenceEnvironmentInjectionAnnotation>(out var injectionAnnotation); 548ApplyEndpoints(builder, source.Resource); 568ApplyEndpoints(builder, source.Resource, endpointName: null, name); 600builder.Resource.TryGetLastAnnotation<ReferenceEnvironmentInjectionAnnotation>(out var injectionAnnotation); 630builder.WithReferenceRelationship(externalService.Resource); 633builder.Resource.TryGetLastAnnotation<ReferenceEnvironmentInjectionAnnotation>(out var injectionAnnotation); 636if (externalService.Resource.Uri is { } uri) 640var envVarName = $"{externalService.Resource.Name.ToUpperInvariant()}"; 646var envVarName = $"services__{externalService.Resource.Name}__{uri.Scheme}__0"; 650else if (externalService.Resource.UrlParameter is not null) 660discoveryEnvVarName = $"services__{externalService.Resource.Name}__default__0"; 661endpointEnvVarName = externalService.Resource.Name.ToUpperInvariant(); 663else if (ExternalServiceResource.UrlIsValidForExternalService(await externalService.Resource.UrlParameter.GetValueAsync(context.CancellationToken).ConfigureAwait(false), out var uri, out var message)) 665discoveryEnvVarName = $"services__{externalService.Resource.Name}__{uri.Scheme}__0"; 666endpointEnvVarName = $"{externalService.Resource.Name.ToUpperInvariant()}_{uri.Scheme.ToUpperInvariant()}"; 670throw new DistributedApplicationException($"The URL parameter '{externalService.Resource.UrlParameter.Name}' for the external service '{externalService.Resource.Name}' is invalid: {message}"); 675context.EnvironmentVariables[discoveryEnvVarName] = externalService.Resource.UrlParameter; 680context.EnvironmentVariables[endpointEnvVarName] = externalService.Resource.UrlParameter; 714var endpointReferenceAnnotation = builder.Resource.Annotations 722if (builder.Resource.IsContainer()) 782var endpoint = builder.Resource.Annotations 800builder.Resource.Annotations.Add(endpoint); 845if (builder.Resource.Annotations.OfType<EndpointAnnotation>().Any(sb => string.Equals(sb.Name, annotation.Name, StringComparisons.EndpointAnnotationName))) 851if (env is not null && builder.Resource is IResourceWithEndpoints resourceWithEndpoints and IResourceWithEnvironment) 936if (!builder.Resource.TryGetAnnotationsOfType<EndpointAnnotation>(out var endpoints)) 965return builder.Resource.GetEndpoint(name, contextNetworkID); 980return builder.Resource.GetEndpoint(name); 1231context.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); 1278context.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); 1308Source = source.Resource, 1345builder.Resource.Annotations 1348.ForEach(w => builder.Resource.Annotations.Remove(w)); 1445if (builder.Resource as IResource == dependency.Resource) 1447throw new DistributedApplicationException($"The '{builder.Resource.Name}' resource cannot wait for itself."); 1450if (builder.Resource is IResourceWithParent resourceWithParent && resourceWithParent.Parent == dependency.Resource) 1452throw new DistributedApplicationException($"The '{builder.Resource.Name}' resource cannot wait for its parent '{dependency.Resource.Name}'."); 1455if (dependency.Resource is IResourceWithParent dependencyResourceWithParent) 1468builder.WithRelationship(dependency.Resource, KnownRelationshipTypes.WaitFor); 1471return builder.WithAnnotation(new WaitAnnotation(dependency.Resource, WaitType.WaitUntilHealthy) { WaitBehavior = waitBehavior }); 1549if (builder.Resource as IResource == dependency.Resource) 1551throw new DistributedApplicationException($"The '{builder.Resource.Name}' resource cannot wait for itself."); 1554if (builder.Resource is IResourceWithParent resourceWithParent && resourceWithParent.Parent == dependency.Resource) 1556throw new DistributedApplicationException($"The '{builder.Resource.Name}' resource cannot wait for its parent '{dependency.Resource.Name}'."); 1559if (dependency.Resource is IResourceWithParent dependencyResourceWithParent) 1571if (dependency.Resource is ConnectionStringResource cs) 1582builder.WithRelationship(dependency.Resource, KnownRelationshipTypes.WaitFor); 1585return builder.WithAnnotation(new WaitAnnotation(dependency.Resource, WaitType.WaitUntilStarted) { WaitBehavior = waitBehavior }); 1645if (builder.Resource as IResource == dependency.Resource) 1647throw new DistributedApplicationException($"The '{builder.Resource.Name}' resource cannot wait for itself."); 1650if (builder.Resource is IResourceWithParent resourceWithParent && resourceWithParent.Parent == dependency.Resource) 1652throw new DistributedApplicationException($"The '{builder.Resource.Name}' resource cannot wait for its parent '{dependency.Resource.Name}'."); 1655builder.WithRelationship(dependency.Resource, KnownRelationshipTypes.WaitFor); 1657return builder.WithAnnotation(new WaitAnnotation(dependency.Resource, WaitType.WaitForCompletion, exitCode)); 1701if (builder.Resource.TryGetAnnotationsOfType<HealthCheckAnnotation>(out var annotations) && annotations.Any(a => a.Key == key)) 1703throw new DistributedApplicationException($"Resource '{builder.Resource.Name}' already has a health check with key '{key}'."); 1785?? throw new DistributedApplicationException($"Could not create HTTP health check for resource '{builder.Resource.Name}' as the endpoint selector returned null."); 1789throw 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."); 1801throw new DistributedApplicationException($"The endpoint '{endpointName}' does not exist on the resource '{builder.Resource.Name}'."); 1815var healthCheckKey = $"{builder.Resource.Name}_{endpointName}_{path}_{statusCode}_check"; 1905var existingAnnotation = builder.Resource.Annotations.OfType<ResourceCommandAnnotation>().SingleOrDefault(a => a.Name == name); 1908builder.Resource.Annotations.Remove(existingAnnotation); 1970var existingAnnotation = builder.Resource.Annotations.OfType<ResourceCommandAnnotation>().SingleOrDefault(a => a.Name == name); 1973builder.Resource.Annotations.Remove(existingAnnotation); 2137?? throw new DistributedApplicationException($"Could not create HTTP command for resource '{builder.Resource.Name}' as the endpoint selector returned null."); 2141throw 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."); 2258CertificateAuthorityCollections = { certificateAuthorityCollection.Resource }, 2260if (builder.Resource.TryGetLastAnnotation<CertificateAuthorityCollectionAnnotation>(out var existingAnnotation)) 2264if (existingCollection != certificateAuthorityCollection.Resource) 2315if (builder.Resource.TryGetLastAnnotation<CertificateAuthorityCollectionAnnotation>(out var existingAnnotation)) 2363if (builder.Resource.TryGetLastAnnotation<CertificateAuthorityCollectionAnnotation>(out var existingAnnotation)) 2418var endpoints = builder.Resource.GetEndpoints(); 2428throw 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."); 2436throw new DistributedApplicationException($"Could not create {errorDisplayNoun} for resource '{builder.Resource.Name}' as no endpoint was found matching one of the specified names: {endpointNamesString}"); 2444var endpoints = builder.Resource.GetEndpoints(); 2456throw new DistributedApplicationException($"Could not create HTTP command for resource '{builder.Resource.Name}' as it has no HTTP endpoints."); 2553AddReference(resourceBuilder.Resource); 2584return builder.WithAnnotation(new ResourceRelationshipAnnotation(resourceBuilder.Resource, KnownRelationshipTypes.Reference)); 2614return builder.WithParentRelationship(parent.Resource); 2675child.WithRelationship(builder.Resource, KnownRelationshipTypes.Parent); 2762builder.WithAnnotation(new ComputeEnvironmentAnnotation(computeEnvironmentResource.Resource)); 2883var endpoint = endpointSelector() ?? throw new DistributedApplicationException($"Could not create HTTP probe for resource '{builder.Resource.Name}' as the endpoint selector returned null."); 2912if (builder.Resource.Annotations.OfType<ProbeAnnotation>().SingleOrDefault(a => a.Type == probeAnnotation.Type) is { } existingAnnotation) 2914builder.Resource.Annotations.Remove(existingAnnotation);

19return builder.Resource.TryGetLastAnnotation<SupportsDebuggingAnnotation>(out var supportsDebuggingAnnotation)

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

33var resourceName = builder.Resource.Name;

55return new BicepOutputReference(name, builder.Resource); 67return new BicepSecretOutputReference(name, builder.Resource); 135builder.Resource.Parameters[name] = null; 151builder.Resource.Parameters[name] = value; 167builder.Resource.Parameters[name] = value; 183builder.Resource.Parameters[name] = value; 199builder.Resource.Parameters[name] = valueCallback; 214return builder.WithParameter(name, value.Resource); 232builder.Resource.Parameters[name] = value; 249builder.WithReferenceRelationship(value.Resource); 251builder.Resource.Parameters[name] = value.Resource; 270builder.Resource.Parameters[name] = value; 289builder.Resource.Parameters[name] = value; 308builder.Resource.Parameters[name] = value;

68builder.Resource.Location = location.Resource; 91builder.Resource.ResourceGroupName = resourceGroup.Resource;

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

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

42builder.WithAnnotation(new ExistingAzureResourceAnnotation(nameParameter.Resource, resourceGroupParameter?.Resource)); 84builder.WithAnnotation(new ExistingAzureResourceAnnotation(nameParameter.Resource, resourceGroupParameter?.Resource)); 124builder.WithAnnotation(new ExistingAzureResourceAnnotation(nameParameter.Resource, resourceGroupParameter?.Resource));

58var deployment = new AzureAIFoundryDeploymentResource(name, modelName, modelVersion, format, builder.Resource); 62builder.Resource.AddDeployment(deployment); 67if (builder.Resource.IsEmulator) 116configure(builder.Resource); 135var resource = builder.Resource; 250var foundryResource = builder.Resource.Parent;

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

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

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

349builder.Resource.UseAzdNamingConvention = true; 361builder.Resource.EnableDashboard = enable; 378builder.WithAnnotation(new AzureLogAnalyticsWorkspaceReferenceAnnotation(workspaceBuilder.Resource));

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

229builder.Resource.EnableDashboard = enable; 241builder.Resource.EnableApplicationInsights = true; 254builder.Resource.ApplicationInsightsLocation = applicationInsightsLocation; 267builder.Resource.ApplicationInsightsLocationParameter = applicationInsightsLocation.Resource; 280builder.Resource.ApplicationInsightsResource = applicationInsightsBuilder.Resource; 291builder.Resource.EnableAutomaticScaling = true;

152builder.Resource.AddDeployment(deployment); 172var deployment = new AzureOpenAIDeploymentResource(name, modelName, modelVersion, builder.Resource); 173builder.Resource.AddDeployment(deployment); 189configure(builder.Resource);

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

79builder.WithAnnotation(new ContainerRegistryReferenceAnnotation(registryBuilder.Resource));

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

100throw new DistributedApplicationException($"ConnectionStringAvailableEvent was published for the '{builder.Resource.Name}' resource but the connection string was null."); 127var healthCheckKey = $"{builder.Resource.Name}_check"; 137var surrogate = new AzureCosmosDBEmulatorResource(builder.Resource); 176var dataPath = builder.Resource.InnerResource.IsPreviewEmulator ? "/data" : "/tmp/cosmos/appdata"; 211if (builder.Resource.InnerResource.IsPreviewEmulator) 256var database = new AzureCosmosDBDatabaseResource(name, databaseName, builder.Resource); 257builder.Resource.Databases.Add(database); 279var container = new AzureCosmosDBContainerResource(name, containerName, partitionKeyPath, builder.Resource); 280builder.Resource.Containers.Add(container); 312var container = new AzureCosmosDBContainerResource(name, containerName, partitionKeyPaths, builder.Resource); 314builder.Resource.Containers.Add(container); 326builder.Resource.UseDefaultAzureSku = true; 344if (!builder.Resource.InnerResource.IsPreviewEmulator) 393var kv = builder.ApplicationBuilder.AddAzureKeyVault($"{builder.Resource.Name}-kv") 394.WithParentRelationship(builder.Resource); 402if (builder.Resource.IsEmulator) 404data.Model.Resources.Remove(kv.Resource); 423var azureResource = builder.Resource; 424azureResource.ConnectionStringSecretOutput = keyVaultBuilder.Resource.GetSecret($"connectionstrings--{azureResource.Name}");

134var hub = new AzureEventHubResource(name, hubName, builder.Resource); 135builder.Resource.Hubs.Add(hub); 151configure(builder.Resource); 174var consumerGroup = new AzureEventHubConsumerGroupResource(name, groupName, builder.Resource); 175builder.Resource.ConsumerGroups.Add(consumerGroup); 212if (builder.Resource.IsEmulator) 239.AddAzureStorage($"{builder.Resource.Name}-storage") 245var surrogate = new AzureEventHubsEmulatorResource(builder.Resource); 259var storage = storageResource.Resource; 277var customConfigFile = builder.Resource.Annotations.OfType<ConfigFileAnnotation>().FirstOrDefault(); 290var tempConfig = JsonNode.Parse(CreateEmulatorConfigJson(builder.Resource)); 298var configJsonAnnotations = builder.Resource.Annotations.OfType<ConfigJsonAnnotation>(); 337return builder.WithBindMount(path ?? $".eventhubs/{builder.Resource.Name}", "/data", isReadOnly: false);

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

61.Resource; 163var launchProfile = builder.Resource.GetEffectiveLaunchProfile(); 207var targetEndpoint = builder.Resource.GetEndpoint(useHttps ? "https" : "http"); 224builder.Resource.HostStorage = storage.Resource; 242destination.WithReferenceRelationship(source.Resource); 246connectionName ??= source.Resource.Name; 247source.Resource.ApplyAzureFunctionsConfiguration(context.EnvironmentVariables, connectionName);

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

170return builder.Resource.GetSecret(secretName); 185return builder.AddSecret(name, name, parameterResource.Resource); 202var secret = new AzureKeyVaultSecretResource(name, name, builder.Resource, parameterResource); 203builder.Resource.Secrets.Add(secret); 222var secret = new AzureKeyVaultSecretResource(name, name, builder.Resource, value); 223builder.Resource.Secrets.Add(secret); 241return builder.AddSecret(name, secretName, parameterResource.Resource); 259var secret = new AzureKeyVaultSecretResource(name, secretName, builder.Resource, parameterResource); 260builder.Resource.Secrets.Add(secret); 280var secret = new AzureKeyVaultSecretResource(name, secretName, builder.Resource, value); 281builder.Resource.Secrets.Add(secret);

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

111var kustoDatabase = new AzureKustoReadWriteDatabaseResource(name, databaseName, builder.Resource); 112builder.Resource.Databases.Add(kustoDatabase); 122kcsb = GetConnectionStringBuilder(builder.Resource, connectionString); 165var surrogate = new AzureKustoEmulatorResource(builder.Resource); 224var resource = resourceBuilder.Resource;

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

24Assert.NotNull(resourceBuilder.Resource); 25Assert.Equal(name, resourceBuilder.Resource.Name); 26Assert.IsType<AzureKustoClusterResource>(resourceBuilder.Resource); 47var containerAnnotation = resourceBuilder.Resource.Annotations.OfType<ContainerImageAnnotation>().SingleOrDefault(); 67var endpointAnnotations = resourceBuilder.Resource.Annotations.OfType<EndpointAnnotation>().ToList(); 87var emulatorAnnotation = resourceBuilder.Resource.Annotations.OfType<EmulatorResourceAnnotation>().SingleOrDefault(); 105var nameAnnotation = resourceBuilder.Resource.Annotations.OfType<ContainerNameAnnotation>().SingleOrDefault(); 109var argsAnnotation = resourceBuilder.Resource.Annotations.OfType<ContainerRuntimeArgsCallbackAnnotation>().SingleOrDefault(); 124var annotation = resourceBuilder.Resource.Annotations.OfType<EnvironmentCallbackAnnotation>().SingleOrDefault(); 178Assert.IsType<IResourceWithConnectionString>(resourceBuilder.Resource, exactMatch: false); 197Assert.Equal(runAsEmulator, resourceBuilder.Resource.IsEmulator); 215var volumeAnnotation = resourceBuilder.Resource.Annotations.OfType<ContainerMountAnnotation>().SingleOrDefault(); 238var mountAnnotation = resourceBuilder.Resource.Annotations.OfType<ContainerMountAnnotation>().SingleOrDefault(); 260var mountAnnotations = resourceBuilder.Resource.Annotations.OfType<ContainerMountAnnotation>().ToList(); 290var containerImageAnnotation = resourceBuilder.Resource.Annotations.OfType<ContainerImageAnnotation>().SingleOrDefault(); 310var lifetimeAnnotation = resourceBuilder.Resource.Annotations.OfType<ContainerLifetimeAnnotation>().SingleOrDefault(); 326Assert.Single(kustoServer.Resource.Annotations, annotation => annotation is HealthCheckAnnotation hca && hca.Key == $"{name}_check"); 341Assert.Single(database.Resource.Annotations, annotation => annotation is HealthCheckAnnotation hca && hca.Key == $"{name}_check"); 358var endpointAnnotations = resourceBuilder.Resource.Annotations.OfType<EndpointAnnotation>().ToList(); 387var script = database.Resource.GetDatabaseCreationScript(); 404var script = database.Resource.GetDatabaseCreationScript(); 423var script = database.Resource.GetDatabaseCreationScript();

56await rns.WaitForResourceHealthyAsync(kusto.Resource.Name, cancellationToken: cts.Token); 59hb.Configuration["ConnectionStrings:KustoConnection"] = await kusto.Resource.ConnectionStringExpression.GetValueAsync(cts.Token); 107await rns.WaitForResourceHealthyAsync(kustoDb.Resource.Name, cancellationToken: cts.Token); 110hb.Configuration["ConnectionStrings:KustoTestDbConnection"] = await kustoDb.Resource.ConnectionStringExpression.GetValueAsync(cts.Token); 186await rns.WaitForResourceHealthyAsync(kusto.Resource.Name, cts.Token); 213await rns.WaitForResourceHealthyAsync(kusto.Resource.Name, cts.Token); 216await rns.WaitForResourceHealthyAsync(db1.Resource.Name, cts.Token); 217await rns.WaitForResourceAsync(db2.Resource.Name, KnownResourceStates.FailedToStart, cts.Token); 252await rns.WaitForResourceHealthyAsync(kustoDb.Resource.Name, cts.Token);

55var postgres = CreatePostgreSqlFlexibleServer(infrastructure, builder.ApplicationBuilder, builder.Resource.Databases); 71var resource = new AzurePostgresResource(builder.Resource, configureInfrastructure); 74.WithLoginAndPassword(builder.Resource); 83if (builder.Resource.Annotations.OfType<ContainerImageAnnotation>().SingleOrDefault() is { } containerAnnotation) 85builder.Resource.Annotations.Remove(containerAnnotation); 163var azureResource = builder.Resource; 166builder.Resource.AddDatabase(name, databaseName); 177azurePostgresDatabase.SetInnerResource(innerDb.Resource); 216var azureResource = builder.Resource; 236azureResource.SetInnerResource(postgresContainer.Resource); 246existingDb.SetInnerResource(innerDb.Resource); 293var kv = builder.ApplicationBuilder.AddAzureKeyVault($"{builder.Resource.Name}-kv") 294.WithParentRelationship(builder.Resource); 302if (builder.Resource.IsContainer()) 304data.Model.Resources.Remove(kv.Resource); 330var azureResource = builder.Resource; 332azureResource.UserNameParameter = userName?.Resource ?? 336azureResource.PasswordParameter = password?.Resource ?? 337ParameterResourceBuilderExtensions.CreateDefaultPasswordParameter(builder.ApplicationBuilder, $"{builder.Resource.Name}-password"); 340azureResource.ConnectionStringSecretOutput = keyVaultBuilder.Resource.GetSecret($"connectionstrings--{builder.Resource.Name}"); 535builder.ApplicationBuilder, $"{builder.Resource.Name}-username", secret: false, generatedUserName);

96var azureResource = builder.Resource; 101azureResource.SetInnerResource(redisContainer.Resource); 134var kv = builder.ApplicationBuilder.AddAzureKeyVault($"{builder.Resource.Name}-kv") 135.WithParentRelationship(builder.Resource); 143if (builder.Resource.IsContainer()) 145data.Model.Resources.Remove(kv.Resource); 166var azureResource = builder.Resource; 167azureResource.ConnectionStringSecretOutput = keyVaultBuilder.Resource.GetSecret($"connectionstrings--{azureResource.Name}");

59var resource = new AzureRedisResource(builder.Resource, configureInfrastructure); 70if (builder.Resource.Annotations.OfType<ContainerImageAnnotation>().SingleOrDefault() is { } containerAnnotation) 72builder.Resource.Annotations.Remove(containerAnnotation); 162var azureResource = builder.Resource; 167azureResource.SetInnerResource(redisContainer.Resource); 199var kv = builder.ApplicationBuilder.AddAzureKeyVault($"{builder.Resource.Name}-kv") 200.WithParentRelationship(builder.Resource); 208if (builder.Resource.IsContainer()) 210data.Model.Resources.Remove(kv.Resource); 230var azureResource = builder.Resource; 231azureResource.ConnectionStringSecretOutput = keyVaultBuilder.Resource.GetSecret($"connectionstrings--{azureResource.Name}");

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

146var queue = new AzureServiceBusQueueResource(name, queueName, builder.Resource); 147builder.Resource.Queues.Add(queue); 163configure(builder.Resource); 223var topic = new AzureServiceBusTopicResource(name, topicName, builder.Resource); 224builder.Resource.Topics.Add(topic); 240configure(builder.Resource); 260if (builder.Resource.Topics.FirstOrDefault(x => x.Name == topicName) is { } existingResource) 289var subscription = new AzureServiceBusSubscriptionResource(name, subscriptionName, builder.Resource); 290builder.Resource.Subscriptions.Add(subscription); 306configure(builder.Resource); 340if (builder.Resource.IsEmulator) 356var passwordParameter = ParameterResourceBuilderExtensions.CreateDefaultPasswordParameter(builder.ApplicationBuilder, $"{builder.Resource.Name}-sql-pwd", minLower: 1, minUpper: 1, minNumeric: 1); 370.AddContainer($"{builder.Resource.Name}-mssql", 384var sqlEndpoint = sqlServerResource.Resource.GetEndpoint("tcp"); 393var surrogate = new AzureServiceBusEmulatorResource(builder.Resource); 414var customConfigFile = builder.Resource.Annotations.OfType<ConfigFileAnnotation>().FirstOrDefault(); 427var tempConfig = JsonNode.Parse(CreateEmulatorConfigJson(builder.Resource)); 435var configJsonAnnotations = builder.Resource.Annotations.OfType<ConfigJsonAnnotation>();

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

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

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

28CreateSqlServer(infrastructure, builder.ApplicationBuilder, builder.Resource.Databases); 31var resource = new AzureSqlServerResource(builder.Resource, configureInfrastructure); 42if (builder.Resource.Annotations.OfType<ContainerImageAnnotation>().SingleOrDefault() is { } containerAnnotation) 44builder.Resource.Annotations.Remove(containerAnnotation); 111var azureResource = builder.Resource; 114builder.Resource.AddDatabase(azureSqlDatabase); 125azureSqlDatabase.SetInnerResource(innerDb.Resource); 140builder.Resource.UseDefaultAzureSku = true; 176var azureResource = builder.Resource; 186azureResource.SetInnerResource(sqlContainer.Resource); 196existingDb.SetInnerResource(innerDb.Resource);

181var 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."); 184var 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."); 195foreach (var container in builder.Resource.BlobContainers) 201foreach (var queue in builder.Resource.Queues) 209var healthCheckKey = $"{builder.Resource.Name}_check"; 221var surrogate = new AzureStorageEmulatorResource(builder.Resource); 242return builder.WithBindMount(path ?? $".azurite/{builder.Resource.Name}", "/data", isReadOnly); 341if (string.Equals(name, builder.Resource.Name + "-blobs", StringComparisons.ResourceName)) 378var name = builder.Resource.Name + "-blobs"; 380return builder.Resource.BlobStorageBuilder ??= CreateBlobService(builder, name); 397AzureBlobStorageContainerResource resource = new(name, blobContainerName, GetBlobService(builder).Resource); 398builder.Resource.BlobContainers.Add(resource); 434AzureBlobStorageContainerResource resource = new(name, blobContainerName, builder.Resource); 435builder.Resource.Parent.BlobContainers.Add(resource); 480if (string.Equals(name, builder.Resource.Name + "-queues", StringComparisons.ResourceName)) 499var name = builder.Resource.Name + "-queues"; 501return builder.Resource.QueueStorageBuilder ??= CreateQueueService(builder, name); 518AzureQueueStorageQueueResource resource = new(name, queueName, builder.GetQueueService().Resource); 519builder.Resource.Queues.Add(resource); 598var resource = new AzureBlobStorageResource(name, builder.Resource); 623var resource = new AzureTableStorageResource(name, builder.Resource); 629var resource = new AzureQueueStorageResource(name, builder.Resource);

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

131Assert.Equal("{myAIFoundry.connectionString};Model=gpt-4", deployment.Resource.ConnectionStringExpression.ValueExpression); 142deployment.Resource.ModelId = "custom-model-id"; 144Assert.Equal("{myAIFoundry.connectionString};Model=custom-model-id", deployment.Resource.ConnectionStringExpression.ValueExpression); 157Assert.Equal("{myAIFoundry.connectionString};Deployment=deployment1", deployment.Resource.ConnectionStringExpression.ValueExpression); 173var manifest = await AzureManifestUtils.GetManifestWithBicep(model, foundry.Resource);

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; 121_ = appConfig.Resource.AddAsExistingResource(infra); 124var (manifest, bicep) = await AzureManifestUtils.GetManifestWithBicep(module.Resource, skipPreparer: true);

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

37_ = appServiceEnvironment.Resource.AddAsExistingResource(infra); 40var (manifest, bicep) = await AzureManifestUtils.GetManifestWithBicep(module.Resource, skipPreparer: true);

44Assert.Same(env.Resource, target.ComputeEnvironment); 139project2.Resource.TryGetLastAnnotation<DeploymentTargetAnnotation>(out var target); 261Assert.NotNull(env.Resource.NameOutputReference); 262Assert.Equal("name", env.Resource.NameOutputReference.Name); 263Assert.Same(env.Resource, env.Resource.NameOutputReference.Resource); 301Assert.IsAssignableFrom<IAzureComputeEnvironmentResource>(env.Resource); 302Assert.IsAssignableFrom<IComputeEnvironmentResource>(env.Resource); 445project2.Resource.TryGetLastAnnotation<DeploymentTargetAnnotation>(out var target); 502project2.Resource.TryGetLastAnnotation<DeploymentTargetAnnotation>(out var target); 538project2.Resource.TryGetLastAnnotation<DeploymentTargetAnnotation>(out var target); 573project2.Resource.TryGetLastAnnotation<DeploymentTargetAnnotation>(out var target); 627project.Resource.TryGetLastAnnotation<DeploymentTargetAnnotation>(out var target); 658container.Resource.TryGetLastAnnotation<DeploymentTargetAnnotation>(out var target); 682var endpointReferenceEx = ((IComputeEnvironmentResource)env.Resource).GetHostAddressExpression(project.GetEndpoint("http")); 688Assert.Equal(env.Resource, output.Resource); 796project.Resource.TryGetLastAnnotation<DeploymentTargetAnnotation>(out var target);

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

29Assert.Equal("content", bicepResource.Resource.TemplateString); 30Assert.Equal("value1", bicepResource.Resource.Parameters["param1"]); 31Assert.Equal("value2", bicepResource.Resource.Parameters["param2"]); 94if (azureResourceBuilder.Resource is not AzureProvisioningResource bicepResource) 115if (azureResourceBuilder.Resource is not AzureProvisioningResource bicepResource) 133bicepResource.Resource.Outputs["resourceEndpoint"] = "https://myendpoint"; 145bicepResource.Resource.SecretOutputs["connectionString"] = "https://myendpoint;Key=43"; 191bicepResource.Resource.TempDirectory = Environment.CurrentDirectory; 193var manifest = await ManifestUtils.GetManifest(bicepResource.Resource); 226var annotation = bicepResource.Resource.Annotations.OfType<Aspire.Hosting.Pipelines.PipelineStepAnnotation>().FirstOrDefault(); 235Resource = bicepResource.Resource

39_ = containerAppEnvironment.Resource.AddAsExistingResource(infra); 42var (manifest, bicep) = await AzureManifestUtils.GetManifestWithBicep(module.Resource, skipPreparer: true); 69Assert.True(logAnalyticsWorkspace.Resource.TryGetLastAnnotation<ExistingAzureResourceAnnotation>(out var existingAnnotation)); 70Assert.Equal(lawName.Resource, existingAnnotation.Name); 71Assert.Equal(lawResourceGroup.Resource, existingAnnotation.ResourceGroup); 74Assert.True(containerAppEnvironment.Resource.TryGetLastAnnotation<AzureLogAnalyticsWorkspaceReferenceAnnotation>(out var workspaceRef)); 75Assert.Same(logAnalyticsWorkspace.Resource, workspaceRef.Workspace); 78var (manifest, bicep) = await AzureManifestUtils.GetManifestWithBicep(containerAppEnvironment.Resource);

109Assert.Same(env.Resource, target.ComputeEnvironment); 151Assert.Same(infra.Resource, target.ComputeEnvironment); 182Assert.Same(env.Resource, target?.ComputeEnvironment); 301.WithEnvironment("DATABASE_URL", pgContainer.Resource.UriExpression); 797var target = container.Resource.GetDeploymentTargetAnnotation()?.DeploymentTarget as AzureBicepResource; 1292var (manifest, bicep) = await GetManifestWithBicep(sql.Resource); 1409var managedEnvironment = (ContainerAppManagedEnvironment)env.Resource.AddAsExistingResource(infra); 1421var (manifest, bicep) = await GetManifestWithBicep(azResource.Resource); 1511Assert.IsAssignableFrom<IAzureComputeEnvironmentResource>(env.Resource); 1512Assert.IsAssignableFrom<IComputeEnvironmentResource>(env.Resource); 1981var dockerFileAnnotation = c.Resource.Annotations.OfType<DockerfileBuildAnnotation>().Single(); 2045var endpointReferenceEx = ((IComputeEnvironmentResource)env.Resource).GetHostAddressExpression(project.GetEndpoint("http")); 2051Assert.Equal(env.Resource, output.Resource);

52Assert.Same(registryBuilder.Resource, annotation!.Registry); 62var (manifest, bicep) = await GetManifestWithBicep(acr.Resource); 121_ = acr.Resource.AddAsExistingResource(infra); 124var (manifest, bicep) = await AzureManifestUtils.GetManifestWithBicep(module.Resource, skipPreparer: true);

47await 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); 93await app.ResourceNotifications.WaitForResourceHealthyAsync(db.Resource.Name, cts.Token); 96hb.Configuration[$"ConnectionStrings:{db.Resource.Name}"] = await cosmos.Resource.ConnectionStringExpression.GetValueAsync(default); 97hb.AddAzureCosmosClient(db.Resource.Name); 98hb.AddCosmosDbContext<EFCoreCosmosDbContext>(db.Resource.Name, databaseName); 173await rns.WaitForResourceHealthyAsync(cosmos1.Resource.Name, cts.Token); 181[$"ConnectionStrings:{cosmos1.Resource.Name}"] = await cosmos1.Resource.ConnectionStringExpression.GetValueAsync(default) 184hb.AddAzureCosmosClient(cosmos1.Resource.Name); 221await rns.WaitForResourceHealthyAsync(cosmos2.Resource.Name, cts.Token); 229[$"ConnectionStrings:{cosmos2.Resource.Name}"] = await cosmos2.Resource.ConnectionStringExpression.GetValueAsync(default) 232hb.AddAzureCosmosClient(cosmos2.Resource.Name); 290await rns.WaitForResourceHealthyAsync(cosmos.Resource.Name, cts.Token); 293hb.Configuration[$"ConnectionStrings:{cosmos.Resource.Name}"] = await cosmos.Resource.ConnectionStringExpression.GetValueAsync(default); 294hb.AddAzureCosmosClient(cosmos.Resource.Name);

32var endpointAnnotation = cosmos.Resource.Annotations.OfType<EndpointAnnotation>().FirstOrDefault(); 53var containerImageAnnotation = cosmos.Resource.Annotations.OfType<ContainerImageAnnotation>().FirstOrDefault(); 70var config = await EnvironmentVariableEvaluator.GetEnvironmentVariablesAsync(cosmos.Resource, DistributedApplicationOperation.Run, TestServiceProvider.Instance); 103Assert.Equal("{cosmos.outputs.connectionString}", cosmos.Resource.ConnectionStringExpression.ValueExpression); 106Assert.Equal("AccountEndpoint={cosmos.outputs.connectionString};Database=db1", db1.Resource.ConnectionStringExpression.ValueExpression); 107Assert.Equal("AccountEndpoint={cosmos.outputs.connectionString};Database=db1;Container=container1", container1.Resource.ConnectionStringExpression.ValueExpression); 133Assert.DoesNotContain(";Database=db1", cosmos.Resource.ConnectionStringExpression.ValueExpression); 134Assert.DoesNotContain(";Database=db1;Container=container1", cosmos.Resource.ConnectionStringExpression.ValueExpression); 135Assert.Contains(";Database=db1", db1.Resource.ConnectionStringExpression.ValueExpression); 136Assert.Contains(";Database=db1;Container=container1", container1.Resource.ConnectionStringExpression.ValueExpression); 138Assert.Contains(";Database=db", db2.Resource.ConnectionStringExpression.ValueExpression); 139Assert.Contains(";Database=db;Container=container", container2.Resource.ConnectionStringExpression.ValueExpression); 152((IResourceWithAzureFunctionsConfig)cosmos.Resource).ApplyAzureFunctionsConfiguration(target, "cosmos"); 159((IResourceWithAzureFunctionsConfig)db1.Resource).ApplyAzureFunctionsConfiguration(target, "db1"); 168((IResourceWithAzureFunctionsConfig)container1.Resource).ApplyAzureFunctionsConfiguration(target, "container1"); 203var manifest = await GetManifestWithBicep(model, cosmos.Resource); 254Assert.Equal("{cosmos-kv.secrets.connectionstrings--cosmos}", cosmos.Resource.ConnectionStringExpression.ValueExpression); 255Assert.Equal("{cosmos-kv.secrets.connectionstrings--db1}", database.Resource.ConnectionStringExpression.ValueExpression); 256Assert.Equal("{cosmos-kv.secrets.connectionstrings--container1}", container.Resource.ConnectionStringExpression.ValueExpression); 258var manifest = await GetManifestWithBicep(cosmos.Resource); 273Assert.True(cosmos.Resource.IsContainer()); 275var csExpr = cosmos.Resource.ConnectionStringExpression; 281Assert.Equal(cs, await ((IResourceWithConnectionString)cosmos.Resource).GetConnectionStringAsync()); 354var (manifest, bicep) = await AzureManifestUtils.GetManifestWithBicep(cosmos.Resource); 365var connectionStringResource = (IResourceWithConnectionString)cosmos.Resource; 367Assert.Equal("cosmos", cosmos.Resource.Name); 385cosmos.Resource.Outputs["connectionString"] = "mycosmosconnectionstring"; 387var manifest = await AzureManifestUtils.GetManifestWithBicep(cosmos.Resource); 408var connectionStringResource = (IResourceWithConnectionString)cosmos.Resource; 410Assert.Equal("cosmos", cosmos.Resource.Name); 448kv.Resource.SecretResolver = (secretRef, _) => 458var (manifest, bicep) = await AzureManifestUtils.GetManifestWithBicep(cosmos.Resource); 469var connectionStringResource = (IResourceWithConnectionString)cosmos.Resource; 471Assert.Equal("cosmos", cosmos.Resource.Name); 489cosmos.Resource.Outputs["connectionString"] = "mycosmosconnectionstring"; 491var manifest = await AzureManifestUtils.GetManifestWithBicep(cosmos.Resource); 510var connectionStringResource = (IResourceWithConnectionString)cosmos.Resource; 512Assert.Equal("cosmos", cosmos.Resource.Name); 523var manifest = await AzureManifestUtils.GetManifestWithBicep(cosmos.Resource); 535Assert.True(cosmos.Resource.IsEmulator()); 536Assert.Contains(cosmos.Resource.Annotations, a => a is EmulatorResourceAnnotation); 549Assert.True(cosmos.Resource.IsEmulator()); 550Assert.Contains(cosmos.Resource.Annotations, a => a is EmulatorResourceAnnotation); 580_ = cosmosdb.Resource.AddAsExistingResource(infra); 583var (manifest, bicep) = await AzureManifestUtils.GetManifestWithBicep(module.Resource, skipPreparer: true);

141var dockerFileAnnotation = c.Resource.Annotations.OfType<DockerfileBuildAnnotation>().Single(); 230Assert.Equal("testregistry", containerAppEnv.Resource.Outputs["AZURE_CONTAINER_REGISTRY_NAME"]); 231Assert.Equal("testregistry.azurecr.io", containerAppEnv.Resource.Outputs["AZURE_CONTAINER_REGISTRY_ENDPOINT"]); 232Assert.Equal("/subscriptions/test/resourceGroups/test-rg/providers/Microsoft.ManagedIdentity/userAssignedIdentities/test-identity", containerAppEnv.Resource.Outputs["AZURE_CONTAINER_REGISTRY_MANAGED_IDENTITY_ID"]); 233Assert.Equal("test.westus.azurecontainerapps.io", containerAppEnv.Resource.Outputs["AZURE_CONTAINER_APPS_ENVIRONMENT_DEFAULT_DOMAIN"]); 234Assert.Equal("/subscriptions/test/resourceGroups/test-rg/providers/Microsoft.App/managedEnvironments/testenv", containerAppEnv.Resource.Outputs["AZURE_CONTAINER_APPS_ENVIRONMENT_ID"]); 276Assert.Equal("testregistry", containerAppEnv.Resource.Outputs["AZURE_CONTAINER_REGISTRY_NAME"]); 277Assert.Equal("testregistry.azurecr.io", containerAppEnv.Resource.Outputs["AZURE_CONTAINER_REGISTRY_ENDPOINT"]); 278Assert.Equal("/subscriptions/test/resourceGroups/test-rg/providers/Microsoft.ManagedIdentity/userAssignedIdentities/test-identity", containerAppEnv.Resource.Outputs["AZURE_CONTAINER_REGISTRY_MANAGED_IDENTITY_ID"]); 279Assert.Equal("test.westus.azurecontainerapps.io", containerAppEnv.Resource.Outputs["AZURE_CONTAINER_APPS_ENVIRONMENT_DEFAULT_DOMAIN"]); 280Assert.Equal("/subscriptions/test/resourceGroups/test-rg/providers/Microsoft.App/managedEnvironments/testenv", containerAppEnv.Resource.Outputs["AZURE_CONTAINER_APPS_ENVIRONMENT_ID"]); 334Assert.Equal("testregistry", containerAppEnv.Resource.Outputs["AZURE_CONTAINER_REGISTRY_NAME"]); 335Assert.Equal("testregistry.azurecr.io", containerAppEnv.Resource.Outputs["AZURE_CONTAINER_REGISTRY_ENDPOINT"]); 336Assert.Equal("/subscriptions/test/resourceGroups/test-rg/providers/Microsoft.ManagedIdentity/userAssignedIdentities/test-identity", containerAppEnv.Resource.Outputs["AZURE_CONTAINER_REGISTRY_MANAGED_IDENTITY_ID"]); 337Assert.Equal("test.westus.azurecontainerapps.io", containerAppEnv.Resource.Outputs["AZURE_CONTAINER_APPS_ENVIRONMENT_DEFAULT_DOMAIN"]); 338Assert.Equal("/subscriptions/test/resourceGroups/test-rg/providers/Microsoft.App/managedEnvironments/testenv", containerAppEnv.Resource.Outputs["AZURE_CONTAINER_APPS_ENVIRONMENT_ID"]); 430Assert.Equal("acaregistry", acaEnv.Resource.Outputs["AZURE_CONTAINER_REGISTRY_NAME"]); 431Assert.Equal("acaregistry.azurecr.io", acaEnv.Resource.Outputs["AZURE_CONTAINER_REGISTRY_ENDPOINT"]); 432Assert.Equal("/subscriptions/test/resourceGroups/test-rg/providers/Microsoft.ManagedIdentity/userAssignedIdentities/aca-identity", acaEnv.Resource.Outputs["AZURE_CONTAINER_REGISTRY_MANAGED_IDENTITY_ID"]); 433Assert.Equal("aca.westus.azurecontainerapps.io", acaEnv.Resource.Outputs["AZURE_CONTAINER_APPS_ENVIRONMENT_DEFAULT_DOMAIN"]); 434Assert.Equal("/subscriptions/test/resourceGroups/test-rg/providers/Microsoft.App/managedEnvironments/acaenv", acaEnv.Resource.Outputs["AZURE_CONTAINER_APPS_ENVIRONMENT_ID"]); 437Assert.Equal("aasregistry", aasEnv.Resource.Outputs["AZURE_CONTAINER_REGISTRY_NAME"]); 438Assert.Equal("aasregistry.azurecr.io", aasEnv.Resource.Outputs["AZURE_CONTAINER_REGISTRY_ENDPOINT"]); 439Assert.Equal("/subscriptions/test/resourceGroups/test-rg/providers/Microsoft.ManagedIdentity/userAssignedIdentities/aas-identity", aasEnv.Resource.Outputs["AZURE_CONTAINER_REGISTRY_MANAGED_IDENTITY_ID"]); 440Assert.Equal("/subscriptions/test/resourceGroups/test-rg/providers/Microsoft.Web/serverfarms/aasplan", aasEnv.Resource.Outputs["planId"]); 441Assert.Equal("aas-client-id", aasEnv.Resource.Outputs["AZURE_CONTAINER_REGISTRY_MANAGED_IDENTITY_CLIENT_ID"]); 516var setValue = await param.Resource.GetValueAsync(default); 590var setValue = await param.Resource.GetValueAsync(default); 624Assert.Equal("testregistry", containerAppEnv.Resource.Outputs["AZURE_CONTAINER_REGISTRY_NAME"]); 625Assert.Equal("testregistry.azurecr.io", containerAppEnv.Resource.Outputs["AZURE_CONTAINER_REGISTRY_ENDPOINT"]); 626Assert.Equal("/subscriptions/test/resourceGroups/test-rg/providers/Microsoft.ManagedIdentity/userAssignedIdentities/test-identity", containerAppEnv.Resource.Outputs["AZURE_CONTAINER_REGISTRY_MANAGED_IDENTITY_ID"]); 627Assert.Equal("test.westus.azurecontainerapps.io", containerAppEnv.Resource.Outputs["AZURE_CONTAINER_APPS_ENVIRONMENT_DEFAULT_DOMAIN"]); 628Assert.Equal("/subscriptions/test/resourceGroups/test-rg/providers/Microsoft.App/managedEnvironments/testenv", containerAppEnv.Resource.Outputs["AZURE_CONTAINER_APPS_ENVIRONMENT_ID"]); 672Assert.Equal("test.westus.azurecontainerapps.io", containerAppEnv.Resource.Outputs["AZURE_CONTAINER_APPS_ENVIRONMENT_DEFAULT_DOMAIN"]); 673Assert.Equal("/subscriptions/test/resourceGroups/test-rg/providers/Microsoft.App/managedEnvironments/testenv", containerAppEnv.Resource.Outputs["AZURE_CONTAINER_APPS_ENVIRONMENT_ID"]); 862Assert.Equal("testregistry", containerAppEnv.Resource.Outputs["AZURE_CONTAINER_REGISTRY_NAME"]); 863Assert.Equal("testregistry.azurecr.io", containerAppEnv.Resource.Outputs["AZURE_CONTAINER_REGISTRY_ENDPOINT"]); 864Assert.Equal("/subscriptions/test/resourceGroups/test-rg/providers/Microsoft.ManagedIdentity/userAssignedIdentities/test-identity", containerAppEnv.Resource.Outputs["AZURE_CONTAINER_REGISTRY_MANAGED_IDENTITY_ID"]); 865Assert.Equal("test.westus.azurecontainerapps.io", containerAppEnv.Resource.Outputs["AZURE_CONTAINER_APPS_ENVIRONMENT_DEFAULT_DOMAIN"]); 866Assert.Equal("/subscriptions/test/resourceGroups/test-rg/providers/Microsoft.App/managedEnvironments/testenv", containerAppEnv.Resource.Outputs["AZURE_CONTAINER_APPS_ENVIRONMENT_ID"]); 869var funcAppDeployment = Assert.IsAssignableFrom<AzureProvisioningResource>(funcApp.Resource.GetDeploymentTargetAnnotation()?.DeploymentTarget); 871Assert.Equal(await ((BicepOutputReference)funcAppDeployment.Parameters["env_outputs_azure_container_apps_environment_default_domain"]!).GetValueAsync(), containerAppEnv.Resource.Outputs["AZURE_CONTAINER_APPS_ENVIRONMENT_DEFAULT_DOMAIN"]); 872Assert.Equal(await ((BicepOutputReference)funcAppDeployment.Parameters["env_outputs_azure_container_apps_environment_id"]!).GetValueAsync(), containerAppEnv.Resource.Outputs["AZURE_CONTAINER_APPS_ENVIRONMENT_ID"]);

43Assert.Same(firstBuilder.Resource, secondBuilder.Resource); 88Assert.Equal(expectedLocation.Resource, resource.Location); 104Assert.Equal(expectedResourceGroup.Resource, resource.ResourceGroupName);

112.WithParameter("pgdb", pgdb.Resource.ConnectionStringExpression); 160["kvUri"] = kv.Resource.VaultUri, 161["blob"] = blobs.Resource.ConnectionStringExpression,

46await app.ResourceNotifications.WaitForResourceAsync(resource.Resource.Name, KnownResourceStates.Running, cts.Token); 47await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Waiting, cts.Token); 51await app.ResourceNotifications.WaitForResourceHealthyAsync(resource.Resource.Name, cts.Token); 53await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running, cts.Token); 76await app.ResourceNotifications.WaitForResourceHealthyAsync(eventHubns.Resource.Name, cts.Token); 82hb.Configuration["ConnectionStrings:hub"] = await eventHub.Resource.ConnectionStringExpression.GetValueAsync(CancellationToken.None); 88hb.Configuration["ConnectionStrings:eventhubns"] = await eventHubns.Resource.ConnectionStringExpression.GetValueAsync(CancellationToken.None); 89hb.AddAzureEventHubProducerClient("eventhubns", settings => settings.EventHubName = eventHub.Resource.HubName); 90hb.AddAzureEventHubConsumerClient("eventhubns", settings => settings.EventHubName = eventHub.Resource.HubName); 128await app.ResourceNotifications.WaitForResourceHealthyAsync(eventHubns.Resource.Name, cts.Token); 134hb.Configuration["ConnectionStrings:eventhubns"] = await eventHubns.Resource.ConnectionStringExpression.GetValueAsync(CancellationToken.None); 135hb.AddAzureEventHubProducerClient("eventhubns", settings => settings.EventHubName = eventHub.Resource.HubName); 136hb.AddAzureEventHubConsumerClient("eventhubns", settings => settings.EventHubName = eventHub.Resource.HubName); 140hb.Configuration["ConnectionStrings:eventhubns"] = await eventHubns.Resource.ConnectionStringExpression.GetValueAsync(CancellationToken.None) + $";EntityPath={hubName};"; 166var volumeAnnotation = eventHubs.Resource.Annotations.OfType<ContainerMountAnnotation>().Single(a => !a.Target.Contains("Config.json")); 185var volumeAnnotation = eventHubs.Resource.Annotations.OfType<ContainerMountAnnotation>().Single(a => !a.Target.Contains("Config.json")); 204var volumeAnnotation = eventHubs.Resource.Annotations.OfType<ContainerMountAnnotation>().Single(a => !a.Target.Contains("Config.json")); 223var volumeAnnotation = eventHubs.Resource.Annotations.OfType<ContainerMountAnnotation>().Single(a => !a.Target.Contains("Config.json")); 242var endpoints = eventHubs.Resource.Annotations.OfType<EndpointAnnotation>().ToList(); 270var containerImageAnnotation = eventHubs.Resource.Annotations.OfType<ContainerImageAnnotation>().FirstOrDefault(); 290var (manifest, bicep) = await AzureManifestUtils.GetManifestWithBicep(model, eventHubs.Resource); 323var manifest = await AzureManifestUtils.GetManifestWithBicep(eventHubs.Resource); 521serviceBus.Resource.TryGetLastAnnotation<ContainerLifetimeAnnotation>(out var sbLifetimeAnnotation); 546Assert.Equal("{eh.outputs.eventHubsEndpoint}", eventHubs.Resource.ConnectionStringExpression.ValueExpression); 547Assert.Equal("Endpoint={eh.outputs.eventHubsEndpoint};EntityPath=hub1", eventHub.Resource.ConnectionStringExpression.ValueExpression); 548Assert.Equal("Endpoint={eh.outputs.eventHubsEndpoint};EntityPath=hub1;ConsumerGroup=cg1", consumerGroup.Resource.ConnectionStringExpression.ValueExpression); 561((IResourceWithAzureFunctionsConfig)eventHubs.Resource).ApplyAzureFunctionsConfiguration(target, "eh"); 571((IResourceWithAzureFunctionsConfig)eventHub.Resource).ApplyAzureFunctionsConfiguration(target, "hub1"); 587((IResourceWithAzureFunctionsConfig)consumerGroup.Resource).ApplyAzureFunctionsConfiguration(target, "cg1"); 617Assert.True(eventHubs.Resource.IsEmulator()); 618Assert.Contains(eventHubs.Resource.Annotations, a => a is EmulatorResourceAnnotation); 648_ = eventHubs.Resource.AddAsExistingResource(infra); 651var (manifest, bicep) = await AzureManifestUtils.GetManifestWithBicep(module.Resource, skipPreparer: true);

35Assert.True(funcApp.Resource.TryGetAnnotationsOfType<ResourceRelationshipAnnotation>(out var relAnnotations)); 166Assert.True(funcApp.Resource.TryGetAnnotationsOfType<ResourceRelationshipAnnotation>(out var relAnnotations)); 169Assert.Equal(storage.Resource, rel.Resource); 320var (_, bicep) = await GetManifestWithBicep(funcApp.Resource.GetDeploymentTargetAnnotation()!.DeploymentTarget);

27var manifest = await ManifestUtils.GetManifest(infrastructure1.Resource); 52var manifest = await ManifestUtils.GetManifest(infrastructure1.Resource); 91var manifest = await ManifestUtils.GetManifest(infrastructure1.Resource);

20var (manifest, bicep) = await AzureManifestUtils.GetManifestWithBicep(mykv.Resource); 36var (manifest, bicep) = await AzureManifestUtils.GetManifestWithBicep(model, mykv.Resource); 56kv.Resource.SecretResolver = (s, ct) => 62var secretReference = kv.Resource.GetSecret("mySecret"); 68var runEnv = await containerBuilder.Resource.GetEnvironmentVariableValuesAsync(DistributedApplicationOperation.Run); 69var publishEnv = await containerBuilder.Resource.GetEnvironmentVariableValuesAsync(DistributedApplicationOperation.Publish); 88var secretReference = kv.Resource.GetSecret("mySecret"); 89var secretReference2 = kv.Resource.GetSecret("mySecret2"); 110var (manifest, bicep) = await AzureManifestUtils.GetManifestWithBicep(module.Resource, skipPreparer: true); 126var secretReference = kv.Resource.GetSecret("mySecret"); 127var secretReference2 = kv.Resource.GetSecret("mySecret2"); 148module2.Resource.Scope = new(existingRg.Resource); 150var (manifest, bicep) = await AzureManifestUtils.GetManifestWithBicep(module.Resource, skipPreparer: true); 151var (manifest2, bicep2) = await AzureManifestUtils.GetManifestWithBicep(module2.Resource, skipPreparer: true); 166var secretReference = kv.Resource.GetSecret("mySecret"); 167var secretReference2 = kv.Resource.GetSecret("mySecret2"); 179var (manifest, bicep) = await AzureManifestUtils.GetManifestWithBicep(module.Resource, skipPreparer: true); 196Assert.Same(kv.Resource, secret.Resource); 210Assert.IsType<AzureKeyVaultSecretResource>(secretResource.Resource); 211Assert.Equal("mySecret", secretResource.Resource.Name); 212Assert.Equal("mySecret", secretResource.Resource.SecretName); 213Assert.Same(kv.Resource, secretResource.Resource.Parent); 214Assert.Single(kv.Resource.Secrets); 215Assert.Same(secretResource.Resource, kv.Resource.Secrets[0]); 227var (manifest, bicep) = await AzureManifestUtils.GetManifestWithBicep(kv.Resource); 242var (manifest, bicep) = await AzureManifestUtils.GetManifestWithBicep(kv.Resource); 257Assert.True(secretResource.Resource.TryGetAnnotationsOfType<ManifestPublishingCallbackAnnotation>(out var manifestAnnotations)); 276var (manifest, bicep) = await AzureManifestUtils.GetManifestWithBicep(kv.Resource); 371_ = keyVault.Resource.AddAsExistingResource(infra); 374var (manifest, bicep) = await AzureManifestUtils.GetManifestWithBicep(module.Resource, skipPreparer: true); 387Assert.False(keyVault.Resource.IsEmulator); 398keyVault.Resource.Annotations.Add(new ContainerImageAnnotation 403Assert.True(keyVault.Resource.IsEmulator); 414keyVault.Resource.Annotations.Add(new ContainerImageAnnotation 422var connectionString = keyVault.Resource.ConnectionStringExpression; 424Assert.True(keyVault.Resource.IsEmulator); 435var connectionString = keyVault.Resource.ConnectionStringExpression; 437Assert.False(keyVault.Resource.IsEmulator); 453keyVault.Resource.Annotations.Add(new ConnectionStringRedirectAnnotation(redirectTarget)); 455var connectionString = keyVault.Resource.ConnectionStringExpression; 456var connectionStringValue = await keyVault.Resource.GetConnectionStringAsync(default); 474keyVault.Resource.Annotations.Add(new ContainerImageAnnotation 483keyVault.Resource.Annotations.Add(new ConnectionStringRedirectAnnotation(redirectTarget)); 485var 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.WorkspaceId.ValueExpression); 20var appInsightsManifest = await AzureManifestUtils.GetManifestWithBicep(logAnalyticsWorkspace.Resource); 59_ = logAnalyticsWorkspace.Resource.AddAsExistingResource(infra); 62var (manifest, bicep) = await AzureManifestUtils.GetManifestWithBicep(module.Resource, skipPreparer: true);

61var manifest = await GetManifestWithBicep(model, openai.Resource); 137_ = openAI.Resource.AddAsExistingResource(infra); 140var (manifest, bicep) = await AzureManifestUtils.GetManifestWithBicep(module.Resource, skipPreparer: true);

39var (manifest, bicep) = await AzureManifestUtils.GetManifestWithBicep(postgres.Resource, skipPreparer: true); 96var (manifest, bicep) = await AzureManifestUtils.GetManifestWithBicep(postgres.Resource); 131Assert.True(postgres.Resource.IsContainer(), "The resource should now be a container resource."); 132Assert.StartsWith("Host=localhost;Port=12455;Username=postgres;Password=", await postgres.Resource.ConnectionStringExpression.GetValueAsync(CancellationToken.None)); 134var db1ConnectionString = await db1.Resource.ConnectionStringExpression.GetValueAsync(CancellationToken.None); 138var db2ConnectionString = await db2.Resource.ConnectionStringExpression.GetValueAsync(CancellationToken.None); 180var endpoint = Assert.Single(innerPostgres.Resource.Annotations.OfType<EndpointAnnotation>()); 189Assert.True(postgres.Resource.IsContainer(), "The resource should now be a container resource."); 190Assert.Equal("Host=localhost;Port=12455;Username=user1;Password=p@ssw0rd1", await postgres.Resource.ConnectionStringExpression.GetValueAsync(CancellationToken.None)); 193Assert.NotNull(postgres.Resource.HostName); 194Assert.Equal("localhost:12455", await postgres.Resource.HostName.GetValueAsync(CancellationToken.None)); 196Assert.NotNull(postgres.Resource.UserName); 197Assert.Equal("user1", await postgres.Resource.UserName.GetValueAsync(CancellationToken.None)); 199Assert.NotNull(postgres.Resource.Password); 200Assert.Equal("p@ssw0rd1", await postgres.Resource.Password.GetValueAsync(CancellationToken.None)); 202var db1ConnectionString = await db1.Resource.ConnectionStringExpression.GetValueAsync(CancellationToken.None); 205var db2ConnectionString = await db2.Resource.ConnectionStringExpression.GetValueAsync(CancellationToken.None); 239Assert.Equal("Host=localhost;Port=12455;Username=user;Password=p@ssw0rd1", await postgres.Resource.ConnectionStringExpression.GetValueAsync(CancellationToken.None)); 240Assert.Equal("Host=localhost;Port=12455;Username=user;Password=p@ssw0rd1;Database=db1", await db1.Resource.ConnectionStringExpression.GetValueAsync(CancellationToken.None)); 241Assert.Equal("Host=localhost;Port=12455;Username=user;Password=p@ssw0rd1;Database=db2Name", await db2.Resource.ConnectionStringExpression.GetValueAsync(CancellationToken.None)); 316Assert.NotNull(postgres.Resource.UserName); 317Assert.NotNull(postgres.Resource.Password); 318Assert.NotNull(postgres.Resource.HostName); 321var hostValue = await postgres.Resource.HostName.GetValueAsync(CancellationToken.None); 324var userValue = await postgres.Resource.UserName.GetValueAsync(CancellationToken.None); 328var passwordValue = await postgres.Resource.Password.GetValueAsync(CancellationToken.None); 342Assert.Null(postgres.Resource.UserName); 343Assert.Null(postgres.Resource.Password); 346Assert.NotNull(postgres.Resource.HostName); 347Assert.Equal("{postgres-data.outputs.hostName}", postgres.Resource.HostName.ValueExpression); 373Assert.True(postgres.Resource.TryGetLastAnnotation<ConnectionStringRedirectAnnotation>(out var connectionStringAnnotation)); 377var manifest = await AzureManifestUtils.GetManifestWithBicep(postgres.Resource); 382Assert.Equal("myconnectionstring", await postgres.Resource.GetConnectionStringAsync(default)); 416Assert.True(postgres.Resource.TryGetLastAnnotation<ConnectionStringRedirectAnnotation>(out var connectionStringAnnotation)); 420var manifest = await AzureManifestUtils.GetManifestWithBicep(postgres.Resource); 425Assert.Equal("myconnectionstring", await postgres.Resource.GetConnectionStringAsync(default)); 460var manifest = await AzureManifestUtils.GetManifestWithBicep(postgres.Resource); 466Assert.Equal(expectedConnectionString, await postgres.Resource.GetConnectionStringAsync()); 492var manifest = await ManifestUtils.GetManifest(postgres.Resource); 512manifest = await ManifestUtils.GetManifest(postgres.Resource); 531manifest = await ManifestUtils.GetManifest(postgres.Resource); 574_ = postgres.Resource.AddAsExistingResource(infra); 577var (manifest, bicep) = await AzureManifestUtils.GetManifestWithBicep(module.Resource, skipPreparer: true);

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 (_, bicep) = await GetManifestWithBicep(model, redis.Resource); 57redisResource = c.Resource; 62Assert.True(redis.Resource.IsContainer(), "The resource should now be a container resource."); 65Assert.Equal($"localhost:12455,password={await redisResource.PasswordParameter.GetValueAsync(CancellationToken.None)}", 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:12455", 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);

39var (manifest, bicep) = await GetManifestWithBicep(model, redis.Resource); 82var (manifest, bicep) = await AzureManifestUtils.GetManifestWithBicep(redis.Resource); 98redisResource = c.Resource; 103Assert.True(redis.Resource.IsContainer(), "The resource should now be a container resource."); 107Assert.Equal($"localhost:12455,password={redisResource.PasswordParameter.Value}", await redis.Resource.ConnectionStringExpression.GetValueAsync(CancellationToken.None)); 121redisResource = c.Resource; 139Assert.True(redis.Resource.IsContainer(), "The resource should now be a container resource."); 142Assert.Equal($"localhost:12455,password=p@ssw0rd1", await redis.Resource.ConnectionStringExpression.GetValueAsync(CancellationToken.None)); 145Assert.NotNull(redis.Resource.HostName); 146Assert.Equal("localhost:12455", await redis.Resource.HostName.GetValueAsync(CancellationToken.None)); 148Assert.NotNull(redis.Resource.Password); 149Assert.Equal("p@ssw0rd1", await redis.Resource.Password.GetValueAsync(CancellationToken.None)); 197Assert.NotNull(redis.Resource.HostName); 198Assert.NotNull(redis.Resource.Password); 201var hostValue = await redis.Resource.HostName.GetValueAsync(CancellationToken.None); 204var passwordValue = await redis.Resource.Password.GetValueAsync(CancellationToken.None); 217Assert.Null(redis.Resource.Password); 220Assert.NotNull(redis.Resource.HostName); 221Assert.Equal("{redis-data.outputs.hostName}", redis.Resource.HostName.ValueExpression); 243Assert.True(redis.Resource.IsContainer()); 244Assert.NotNull(redis.Resource.PasswordParameter); 247Assert.Equal($"localhost:12455,password={redis.Resource.PasswordParameter.Value}", await redis.Resource.GetConnectionStringAsync()); 250var manifest = await AzureManifestUtils.GetManifestWithBicep(redis.Resource); 294_ = redis.Resource.AddAsExistingResource(infra); 297var (manifest, bicep) = await AzureManifestUtils.GetManifestWithBicep(module.Resource, skipPreparer: true);

64Assert.True(storage.Resource.TryGetLastAnnotation<DefaultRoleAssignmentsAnnotation>(out var defaultAssignments)); 81Assert.True(api.Resource.TryGetLastAnnotation<RoleAssignmentAnnotation>(out var apiRoleAssignments)); 82Assert.Equal(storage.Resource, apiRoleAssignments.Target); 123Assert.True(api.Resource.TryGetLastAnnotation<RoleAssignmentAnnotation>(out var apiRoleAssignments)); 124Assert.Equal(storage.Resource, apiRoleAssignments.Target); 129Assert.True(api2.Resource.TryGetLastAnnotation<RoleAssignmentAnnotation>(out var api2RoleAssignments)); 130Assert.Equal(storage.Resource, api2RoleAssignments.Target); 172context.Args.Add(blobs.Resource.ConnectionStringExpression); 178Assert.True(storage.Resource.TryGetLastAnnotation<DefaultRoleAssignmentsAnnotation>(out var defaultAssignments)); 180Assert.True(api.Resource.TryGetLastAnnotation<RoleAssignmentAnnotation>(out var apiRoleAssignments)); 181Assert.Equal(storage.Resource, apiRoleAssignments.Target);

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

38var manifest = await AzureManifestUtils.GetManifestWithBicep(serviceBus.Resource); 63var manifest = await AzureManifestUtils.GetManifestWithBicep(serviceBus.Resource); 95await app.ResourceNotifications.WaitForResourceAsync(resource.Resource.Name, KnownResourceStates.Running, cts.Token); 97await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Waiting, cts.Token); 101await app.ResourceNotifications.WaitForResourceHealthyAsync(resource.Resource.Name, cts.Token); 103await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running, cts.Token); 129hb.Configuration["ConnectionStrings:servicebusns"] = await serviceBus.Resource.ConnectionStringExpression.GetValueAsync(CancellationToken.None); 136await rns.WaitForResourceAsync(serviceBus.Resource.Name, KnownResourceStates.Running, cts.Token); 137await rns.WaitForResourceHealthyAsync(serviceBus.Resource.Name, cts.Token); 141await using var sender = serviceBusClient.CreateSender(queueResource.Resource.QueueName); 144await using var receiver = serviceBusClient.CreateReceiver(queueResource.Resource.QueueName); 164serviceBus.Resource.Annotations.OfType<EndpointAnnotation>(), 187var containerImageAnnotation = serviceBus.Resource.Annotations.OfType<ContainerImageAnnotation>().FirstOrDefault(); 265var manifest = await AzureManifestUtils.GetManifestWithBicep(serviceBus.Resource); 618serviceBus.Resource.TryGetLastAnnotation<ContainerLifetimeAnnotation>(out var sbLifetimeAnnotation); 645Assert.Equal("{sb.outputs.serviceBusEndpoint}", serviceBus.Resource.ConnectionStringExpression.ValueExpression); 646Assert.Equal("Endpoint={sb.outputs.serviceBusEndpoint};EntityPath=queue", queue.Resource.ConnectionStringExpression.ValueExpression); 647Assert.Equal("Endpoint={sb.outputs.serviceBusEndpoint};EntityPath=topic", topic.Resource.ConnectionStringExpression.ValueExpression); 648Assert.Equal("Endpoint={sb.outputs.serviceBusEndpoint};EntityPath=topic/Subscriptions/sub", subscription.Resource.ConnectionStringExpression.ValueExpression); 662((IResourceWithAzureFunctionsConfig)serviceBus.Resource).ApplyAzureFunctionsConfiguration(target, "sb"); 668((IResourceWithAzureFunctionsConfig)queue.Resource).ApplyAzureFunctionsConfiguration(target, "queue"); 675((IResourceWithAzureFunctionsConfig)topic.Resource).ApplyAzureFunctionsConfiguration(target, "topic"); 682((IResourceWithAzureFunctionsConfig)subscription.Resource).ApplyAzureFunctionsConfiguration(target, "sub"); 718serviceBus.Resource.Outputs["serviceBusEndpoint"] = "mynamespaceEndpoint"; 720var connectionStringResource = (IResourceWithConnectionString)serviceBus.Resource; 722Assert.Equal("sb", serviceBus.Resource.Name); 728var manifest = await GetManifestWithBicep(model, serviceBus.Resource); 811hb.Configuration["ConnectionStrings:servicebusns"] = await serviceBus.Resource.ConnectionStringExpression.GetValueAsync(CancellationToken.None); 814await app.ResourceNotifications.WaitForResourceAsync(serviceBus.Resource.Name, KnownResourceStates.Running, cts.Token); 815await app.ResourceNotifications.WaitForResourceHealthyAsync(serviceBus.Resource.Name, cts.Token); 822await using var sender = serviceBusClient.CreateSender(queueResource.Resource.QueueName); 825await using var receiver = serviceBusClient.CreateReceiver(queueResource.Resource.QueueName); 839Assert.True(serviceBus.Resource.IsEmulator()); 840Assert.Contains(serviceBus.Resource.Annotations, a => a is EmulatorResourceAnnotation); 870_ = serviceBus.Resource.AddAsExistingResource(infra); 873var (manifest, bicep) = await AzureManifestUtils.GetManifestWithBicep(module.Resource, skipPreparer: true);

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

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

49await rns.WaitForResourceAsync(storage.Resource.Name, KnownResourceStates.Running, cts.Token); 51await rns.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Waiting, cts.Token); 55await rns.WaitForResourceHealthyAsync(blobs.Resource.Name, cts.Token); 56await rns.WaitForResourceHealthyAsync(queues.Resource.Name, cts.Token); 57await rns.WaitForResourceHealthyAsync(tables.Resource.Name, cts.Token); 59await rns.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running, cts.Token); 94await rns.WaitForResourceAsync(storage.Resource.Name, KnownResourceStates.Running, cts.Token); 96await rns.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Waiting, cts.Token); 100await rns.WaitForResourceHealthyAsync(blobContainer.Resource.Name, cts.Token); 102await rns.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running, cts.Token); 137await rns.WaitForResourceAsync(storage.Resource.Name, KnownResourceStates.Running, cts.Token); 139await rns.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Waiting, cts.Token); 143await rns.WaitForResourceHealthyAsync(testQueue.Resource.Name, cts.Token); 145await rns.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running, cts.Token); 175hb.Configuration[$"ConnectionStrings:{blobsResourceName}"] = await blobs.Resource.ConnectionStringExpression.GetValueAsync(CancellationToken.None); 176hb.Configuration[$"ConnectionStrings:{blobContainerName}"] = await container.Resource.ConnectionStringExpression.GetValueAsync(CancellationToken.None); 177hb.Configuration[$"ConnectionStrings:{queuesResourceName}"] = await queues.Resource.ConnectionStringExpression.GetValueAsync(CancellationToken.None); 178hb.Configuration[$"ConnectionStrings:{queueName}"] = await queue.Resource.ConnectionStringExpression.GetValueAsync(CancellationToken.None); 190await rns.WaitForResourceHealthyAsync(storage.Resource.Name, cts.Token); 223await rns.WaitForResourceHealthyAsync(blobContainer.Resource.Name, cancellationToken: cts.Token); 226hb.Configuration["ConnectionStrings:BlobConnection"] = await blobs.Resource.ConnectionStringExpression.GetValueAsync(CancellationToken.None); 262await rns.WaitForResourceHealthyAsync(queue.Resource.Name, cancellationToken: cts.Token); 265hb.Configuration["ConnectionStrings:QueueConnection"] = await queues.Resource.ConnectionStringExpression.GetValueAsync(CancellationToken.None);

35var volumeAnnotation = storage.Resource.Annotations.OfType<ContainerMountAnnotation>().Single(); 61var volumeAnnotation = storage.Resource.Annotations.OfType<ContainerMountAnnotation>().Single(); 87var volumeAnnotation = storage.Resource.Annotations.OfType<ContainerMountAnnotation>().Single(); 113var volumeAnnotation = storage.Resource.Annotations.OfType<ContainerMountAnnotation>().Single(); 132storage.Resource.Annotations.OfType<EndpointAnnotation>(), 146var args = await ArgumentEvaluator.GetArgumentListAsync(storage.Resource); 166var args = await ArgumentEvaluator.GetArgumentListAsync(storage.Resource); 185Assert.True(storage.Resource.IsContainer()); 189Assert.Equal(expected, await ((IResourceWithConnectionString)blobs.Resource).ConnectionStringExpression.GetValueAsync(default)); 201storage.Resource.Outputs["blobEndpoint"] = blobsConnectionString; 205Assert.Equal(blobsConnectionString, await ((IResourceWithConnectionString)blobs.Resource).ConnectionStringExpression.GetValueAsync(default)); 216Assert.Equal("{storage.outputs.blobEndpoint}", blobs.Resource.ConnectionStringExpression.ValueExpression); 233Assert.True(storage.Resource.IsContainer()); 238string? blobConnectionString = await ((IResourceWithConnectionString)blobs.Resource).ConnectionStringExpression.GetValueAsync(default); 239string? blobContainerConnectionString = await ((IResourceWithConnectionString)blobContainer.Resource).ConnectionStringExpression.GetValueAsync(default); 255storage.Resource.Outputs["blobEndpoint"] = "https://myblob"; 260string? blobsConnectionString = await ((IResourceWithConnectionString)blobs.Resource).ConnectionStringExpression.GetValueAsync(default); 263Assert.Equal(expected, await ((IResourceWithConnectionString)blobContainer.Resource).ConnectionStringExpression.GetValueAsync(default)); 274Assert.Equal("Endpoint={storage.outputs.blobEndpoint};ContainerName=myContainer", blobContainer.Resource.ConnectionStringExpression.ValueExpression); 291Assert.True(storage.Resource.IsContainer()); 295Assert.Equal(expected, await ((IResourceWithConnectionString)queues.Resource).GetConnectionStringAsync()); 307storage.Resource.Outputs["queueEndpoint"] = connectionString; 311Assert.Equal(connectionString, await ((IResourceWithConnectionString)queues.Resource).GetConnectionStringAsync()); 322Assert.Equal("{storage.outputs.queueEndpoint}", queues.Resource.ConnectionStringExpression.ValueExpression); 339Assert.True(storage.Resource.IsContainer()); 344string? connectionString = await ((IResourceWithConnectionString)queues.Resource).GetConnectionStringAsync(); 347Assert.Equal(expected, await ((IResourceWithConnectionString)queue.Resource).GetConnectionStringAsync()); 359storage.Resource.Outputs["queueEndpoint"] = "https://myqueue"; 364string? connectionString = await ((IResourceWithConnectionString)queues.Resource).GetConnectionStringAsync(); 367Assert.Equal(expected, await ((IResourceWithConnectionString)queue.Resource).GetConnectionStringAsync()); 379Assert.Equal("Endpoint={storage.outputs.queueEndpoint};QueueName=myqueue", queue.Resource.ConnectionStringExpression.ValueExpression); 394var manifest = await AzureManifestUtils.GetManifestWithBicep(storage.Resource); 411Assert.True(storage.Resource.IsContainer()); 418=> new(storage.Resource, new EndpointAnnotation(ProtocolType.Tcp, name: name, targetPort: port)); 424Assert.Equal(blobqs, blob.Resource.ConnectionStringExpression.ValueExpression); 425Assert.Equal(queueqs, queue.Resource.ConnectionStringExpression.ValueExpression); 426Assert.Equal(tableqs, table.Resource.ConnectionStringExpression.ValueExpression); 433Assert.Equal(Resolve(blobqs, "blob", 10000), await ((IResourceWithConnectionString)blob.Resource).GetConnectionStringAsync()); 434Assert.Equal(Resolve(queueqs, "queue", 10001), await ((IResourceWithConnectionString)queue.Resource).GetConnectionStringAsync()); 435Assert.Equal(Resolve(tableqs, "table", 10002), await ((IResourceWithConnectionString)table.Resource).GetConnectionStringAsync()); 454storage.Resource.Outputs["blobEndpoint"] = "https://myblob"; 455storage.Resource.Outputs["queueEndpoint"] = "https://myqueue"; 456storage.Resource.Outputs["tableEndpoint"] = "https://mytable"; 459Assert.Equal("storage", storage.Resource.Name); 461var storageManifest = await AzureManifestUtils.GetManifestWithBicep(storage.Resource); 479var connectionStringBlobResource = (IResourceWithConnectionString)blob.Resource; 488var blobManifest = await ManifestUtils.GetManifest(blob.Resource); 494var connectionStringQueueResource = (IResourceWithConnectionString)queue.Resource; 503var queueManifest = await ManifestUtils.GetManifest(queue.Resource); 509var connectionStringTableResource = (IResourceWithConnectionString)table.Resource; 518var tableManifest = await ManifestUtils.GetManifest(table.Resource); 539storage.Resource.Outputs["blobEndpoint"] = "https://myblob"; 540storage.Resource.Outputs["queueEndpoint"] = "https://myqueue"; 541storage.Resource.Outputs["tableEndpoint"] = "https://mytable"; 544Assert.Equal("storage", storage.Resource.Name); 546var storageManifest = await AzureManifestUtils.GetManifestWithBicep(storage.Resource); 564var connectionStringBlobResource = (IResourceWithConnectionString)blob.Resource; 573var blobManifest = await ManifestUtils.GetManifest(blob.Resource); 579var connectionStringQueueResource = (IResourceWithConnectionString)queue.Resource; 588var queueManifest = await ManifestUtils.GetManifest(queue.Resource); 594var connectionStringTableResource = (IResourceWithConnectionString)table.Resource; 603var tableManifest = await ManifestUtils.GetManifest(table.Resource); 627storage.Resource.Outputs["blobEndpoint"] = "https://myblob"; 628storage.Resource.Outputs["queueEndpoint"] = "https://myqueue"; 629storage.Resource.Outputs["tableEndpoint"] = "https://mytable"; 632Assert.Equal("storage", storage.Resource.Name); 636var storageManifest = await GetManifestWithBicep(model, storage.Resource); 702var connectionStringBlobResource = (IResourceWithConnectionString)blob.Resource; 711var blobManifest = await ManifestUtils.GetManifest(blob.Resource); 715var connectionStringQueueResource = (IResourceWithConnectionString)queue.Resource; 724var queueManifest = await ManifestUtils.GetManifest(queue.Resource); 728var connectionStringTableResource = (IResourceWithConnectionString)table.Resource; 737var tableManifest = await ManifestUtils.GetManifest(table.Resource); 758storage.Resource.Outputs["blobEndpoint"] = "https://myblob"; 759storage.Resource.Outputs["queueEndpoint"] = "https://myqueue"; 760storage.Resource.Outputs["tableEndpoint"] = "https://mytable"; 763Assert.Equal("storage", storage.Resource.Name); 765var storageManifest = await AzureManifestUtils.GetManifestWithBicep(storage.Resource); 784var connectionStringBlobResource = (IResourceWithConnectionString)blob.Resource; 793var blobManifest = await ManifestUtils.GetManifest(blob.Resource); 799var connectionStringQueueResource = (IResourceWithConnectionString)queue.Resource; 808var queueManifest = await ManifestUtils.GetManifest(queue.Resource); 814var connectionStringTableResource = (IResourceWithConnectionString)table.Resource; 823var tableManifest = await ManifestUtils.GetManifest(table.Resource); 850Assert.Equal("storage-blobs", blobService.Resource.Name); 851Assert.Equal(blobService.Resource, blobStorageResource); 877Assert.Equal("storage-queues", queueService.Resource.Name); 878Assert.Equal(queueService.Resource, queueStorageResource); 889Assert.True(storage.Resource.IsEmulator()); 890Assert.Contains(storage.Resource.Annotations, a => a is EmulatorResourceAnnotation); 920_ = storage.Resource.AddAsExistingResource(infra); 923var (manifest, bicep) = await AzureManifestUtils.GetManifestWithBicep(module.Resource, skipPreparer: true);

123Assert.Same(identity.Resource, identityAnnotation.IdentityResource); 169Assert.Same(identity.Resource, identityAnnotation.IdentityResource); 224Assert.Same(identity.Resource, identityAnnotation.IdentityResource); 304Assert.Same(identity.Resource, identityAnnotation.IdentityResource); 305Assert.Same(identity.Resource, identityAnnotation2.IdentityResource); 358_ = userAssignedIdentity.Resource.AddAsExistingResource(infra); 361var (manifest, bicep) = await AzureManifestUtils.GetManifestWithBicep(module.Resource, skipPreparer: true);

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; 336var bicep = builder.AddBicepTemplateString("test", "param name string").Resource; 354var bicep = builder.AddBicepTemplateString("test", "param name string").Resource; 372var bicep = builder.AddBicepTemplateString("test", "param name string").Resource; 387var bicep = builder.AddBicepTemplateString("test", "param name string").Resource; 408var bicep = builder.AddBicepTemplateString("test", "param name string").Resource;

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

25var (manifest, bicep) = await AzureManifestUtils.GetManifestWithBicep(serviceBus.Resource); 42var (manifest, bicep) = await AzureManifestUtils.GetManifestWithBicep(serviceBus.Resource); 59var (manifest, bicep) = await AzureManifestUtils.GetManifestWithBicep(serviceBus.Resource); 79var (manifest, bicep) = await GetManifestWithBicep(model, serviceBus.Resource); 99var (manifest, bicep) = await AzureManifestUtils.GetManifestWithBicep(serviceBus.Resource); 116var (manifest, bicep) = await AzureManifestUtils.GetManifestWithBicep(storageAccount.Resource); 131var (manifest, bicep) = await AzureManifestUtils.GetManifestWithBicep(storageAccount.Resource); 148var (manifest, bicep) = await AzureManifestUtils.GetManifestWithBicep(appConfiguration.Resource); 165var (manifest, bicep) = await AzureManifestUtils.GetManifestWithBicep(eventHubs.Resource); 182var (manifest, bicep) = await AzureManifestUtils.GetManifestWithBicep(keyVault.Resource); 199var (manifest, bicep) = await AzureManifestUtils.GetManifestWithBicep(logAnalytics.Resource); 216var (manifest, bicep) = await AzureManifestUtils.GetManifestWithBicep(postgresSql.Resource); 237var (manifest, bicep) = await AzureManifestUtils.GetManifestWithBicep(postgresSql.Resource); 254var (manifest, bicep) = await AzureManifestUtils.GetManifestWithBicep(search.Resource); 271var (manifest, bicep) = await AzureManifestUtils.GetManifestWithBicep(signalR.Resource); 288var (manifest, bicep) = await AzureManifestUtils.GetManifestWithBicep(webPubSub.Resource); 305var (manifest, bicep) = await AzureManifestUtils.GetManifestWithBicep(sqlServer.Resource); 321var (manifest, bicep) = await AzureManifestUtils.GetManifestWithBicep(sqlServer.Resource); 338var (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);

22var parent = new AzureCosmosDBDatabaseResource("database", "cosmos-db", resource.Resource); 42var parent = new AzureCosmosDBDatabaseResource("database", "cosmos-db", resource.Resource); 62var parent = new AzureCosmosDBDatabaseResource("database", "cosmos-db", resource.Resource); 82var parent = new AzureCosmosDBDatabaseResource("database", "cosmos-db", resource.Resource); 102var parent = new AzureCosmosDBDatabaseResource("database", "cosmos-db", resource.Resource); 120var parent = new AzureCosmosDBDatabaseResource("database", "cosmos-db", resource.Resource); 136var parent = new AzureCosmosDBDatabaseResource("database", "cosmos-db", resource.Resource); 154var parent = new AzureCosmosDBDatabaseResource("database", "cosmos-db", resource.Resource); 200var action = () => new AzureCosmosDBDatabaseResource(name, databaseName, parent.Resource); 218var 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);

163if (!builder.Resource.Hubs.TryGetValue(hubName, out hubResource)) 165hubResource = new AzureWebPubSubHubResource(name, hubName, builder.Resource); 166builder.Resource.Hubs[hubName] = hubResource; 219builder.Resource.EventHandlers.Add((urlExpression, userEventPattern, systemEvents, authSettings));

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

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

131var args = await ArgumentEvaluator.GetArgumentListAsync(c2.Resource); 141Assert.False(c2.Resource.TryGetAnnotationsOfType<ResourceRelationshipAnnotation>(out var relationships)); 143var manifest = await ManifestUtils.GetManifest(c2.Resource);

105Assert.True(dockerFile.Resource.TryGetContainerImageName(out var imageName)); 109Assert.True(dockerFile.Resource.TryGetLastAnnotation<DockerfileBuildAnnotation>(out var buildAnnotation)); 129Assert.True(dockerFile.Resource.TryGetLastAnnotation<ContainerImageAnnotation>(out var containerImageAnnotation)); 133Assert.True(dockerFile.Resource.TryGetLastAnnotation<DockerfileBuildAnnotation>(out var buildAnnotation)); 137Assert.True(dockerFile.Resource.TryGetContainerImageName(out var imageName)); 151Assert.True(dockerFile.Resource.TryGetLastAnnotation<DockerfileBuildAnnotation>(out var buildAnnotation1)); 155Assert.True(dockerFile.Resource.TryGetLastAnnotation<DockerfileBuildAnnotation>(out var buildAnnotation2)); 172Assert.True(dockerFile.Resource.TryGetLastAnnotation<DockerfileBuildAnnotation>(out var buildAnnotation1)); 176Assert.True(dockerFile.Resource.TryGetLastAnnotation<DockerfileBuildAnnotation>(out var buildAnnotation2)); 183Assert.True(dockerFile.Resource.TryGetContainerImageName(out var imageName)); 276var manifest = await ManifestUtils.GetManifest(container.Resource, manifestDirectory: tempContextPath); 323var manifest = await ManifestUtils.GetManifest(container.Resource, manifestDirectory: tempContextPath); 369var manifest = await ManifestUtils.GetManifest(container.Resource, manifestDirectory: tempContextPath); 414var manifest = await ManifestUtils.GetManifest(container.Resource, manifestDirectory: tempContextPath); 643var annotation = Assert.Single(container.Resource.Annotations.OfType<DockerfileBuildAnnotation>()); 658var annotation = Assert.Single(container.Resource.Annotations.OfType<DockerfileBuildAnnotation>()); 674var 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>()); 720var annotation = Assert.Single(container.Resource.Annotations.OfType<DockerfileBuildAnnotation>()); 736var annotation = Assert.Single(container.Resource.Annotations.OfType<DockerfileBuildAnnotation>()); 751var annotation = Assert.Single(container.Resource.Annotations.OfType<DockerfileBuildAnnotation>()); 775var annotation = Assert.Single(container.Resource.Annotations.OfType<DockerfileBuildAnnotation>()); 779var stepsAnnotation = Assert.Single(container.Resource.Annotations.OfType<PipelineStepAnnotation>()); 784Resource = container.Resource 797Resource = container.Resource, 821var annotation = Assert.Single(container.Resource.Annotations.OfType<DockerfileBuildAnnotation>()); 829Resource = container.Resource, 853var manifest = await ManifestUtils.GetManifest(container.Resource, manifestDirectory: tempContextPath); 871var annotation = Assert.Single(container.Resource.Annotations.OfType<DockerfileBuildAnnotation>());

255foreach (var endpoint in resourceBuilder.Resource.GetEndpoints()) 318tunnelBuilder.Resource.Options.AllowAnonymous = true; 338return tunnelBuilder.GetEndpoint(resourceBuilder.Resource, endpointName); 354var portResource = tunnelBuilder.Resource.Ports 359return CreateEndpointReferenceWithError(tunnelBuilder.Resource, resource, endpointName); 376var portResource = tunnelBuilder.Resource.Ports 382return CreateEndpointReferenceWithError(tunnelBuilder.Resource, targetEndpointReference.Resource, targetEndpointReference.EndpointName); 431foreach (var port in tunnelResource.Resource.Ports.Where(p => p.TargetEndpoint.Resource == targetResource.Resource)) 433var serviceName = targetResource.Resource.Name; 456var tunnel = tunnelBuilder.Resource;

23var tunnelPort = tunnel.Resource.Ports.FirstOrDefault(); 28var values = await consumer.Resource.GetEnvironmentVariableValuesAsync(); 42Assert.True(tunnel.Resource.Options.AllowAnonymous); 52Assert.Equal("custom-id", tunnel.Resource.TunnelId); 65Assert.Single(tunnel.Resource.Ports); 66var port = tunnel.Resource.Ports.First(); 80var tunnelEndpoint = tunnel.GetEndpoint(target.Resource, "https"); 83Assert.Equal(target.Resource, tunnelEndpoint.Resource); 100Assert.Equal(target.Resource, tunnelEndpoint.Resource); 118Assert.Equal(target.Resource, tunnelEndpoint.Resource); 132var endpointRef = tunnel.GetEndpoint(target.Resource, "nonexistent"); 172var endpointRef = tunnel.GetEndpoint(target.Resource, "https"); 192var httpTunnelEndpoint = tunnel.GetEndpoint(target.Resource, "http"); 193var httpsTunnelEndpoint = tunnel.GetEndpoint(target.Resource, "https");

69configure(builder.Resource); 85builder.Resource.ConfigureComposeFile += configure; 99builder.Resource.DashboardEnabled = enabled; 116builder.Resource.DashboardEnabled = true; 118configure(builder.Resource.Dashboard ?? throw new InvalidOperationException("Dashboard resource is not initialized"));

39if (environment.DashboardEnabled && environment.Dashboard?.Resource is DockerComposeAspireDashboardResource dashboard) 53if (environment.DashboardEnabled && environment.Dashboard?.Resource.OtlpGrpcEndpoint is EndpointReference otlpGrpcEndpoint)

77IEnumerable<IResource> resources = environment.Dashboard?.Resource is IResource r

78return builder.Resource.AsEnvironmentPlaceholder(dockerComposeService);

79.WithArgs("--cs", cs.Resource) 289var parmeters = paramNames.Select(name => builder.AddParameter(name).Resource).ToArray();

34Assert.Same(composeEnv.Resource, container.Resource.GetDeploymentTargetAnnotation()?.ComputeEnvironment); 216var endpointReferenceEx = ((IComputeEnvironmentResource)env.Resource).GetHostAddressExpression(project.GetEndpoint("http"));

106var passwordParameter = password?.Resource ?? ParameterResourceBuilderExtensions.CreateDefaultPasswordParameter(builder, $"{name}-password", special: false);

93var manifest = await ManifestUtils.GetManifest(garnet.Resource); 133var manifest = await ManifestUtils.GetManifest(garnet.Resource); 169var manifest = await ManifestUtils.GetManifest(garnet.Resource); 214var volumeAnnotation = garnet.Resource.Annotations.OfType<ContainerMountAnnotation>().Single(); 239var volumeAnnotation = garnet.Resource.Annotations.OfType<ContainerMountAnnotation>().Single(); 254Assert.True(garnet.Resource.TryGetAnnotationsOfType<CommandLineArgsCallbackAnnotation>(out var argsCallbacks)); 278Assert.True(garnet.Resource.TryGetAnnotationsOfType<CommandLineArgsCallbackAnnotation>(out var argsCallbacks)); 286var args = await ArgumentEvaluator.GetArgumentListAsync(builder.Resource); 309Assert.True(garnet.Resource.TryGetAnnotationsOfType<CommandLineArgsCallbackAnnotation>(out var argsCallbacks)); 326Assert.True(garnet.Resource.TryGetAnnotationsOfType<CommandLineArgsCallbackAnnotation>(out var argsAnnotations));

40await app.ResourceNotifications.WaitForResourceAsync(resource.Resource.Name, KnownResourceStates.Running, cts.Token); 42await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Waiting, cts.Token); 46await app.ResourceNotifications.WaitForResourceHealthyAsync(resource.Resource.Name, cts.Token); 48await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running, cts.Token); 74hb.Configuration[$"ConnectionStrings:{garnet.Resource.Name}"] = await garnet.Resource.ConnectionStringExpression.GetValueAsync(default); 76hb.AddRedisClient(garnet.Resource.Name); 153hb.Configuration[$"ConnectionStrings:{garnet1.Resource.Name}"] = $"{await garnet1.Resource.ConnectionStringExpression.GetValueAsync(default)}"; 204hb.Configuration[$"ConnectionStrings:{garnet2.Resource.Name}"] = $"{await garnet2.Resource.ConnectionStringExpression.GetValueAsync(default)}";

41defaultApiKeyParameter.Resource.Description = """ 46defaultApiKeyParameter.Resource.EnableDescriptionMarkdown = true; 47var resource = new GitHubModelResource(name, model, organization?.Resource, defaultApiKeyParameter.Resource); 119if (!apiKey.Resource.Secret) 125if (builder.Resource.DefaultKeyParameter == builder.Resource.Key) 127builder.ApplicationBuilder.Resources.Remove(builder.Resource.Key); 130builder.Resource.Key = apiKey.Resource; 160var healthCheckKey = $"{builder.Resource.Name}_check"; 182var resource = builder.Resource;

20Assert.Equal("github", github.Resource.Name); 21Assert.Equal("openai/gpt-4o-mini", github.Resource.Model); 32Assert.NotNull(github.Resource.Key); 33Assert.Equal("mymodel-gh-apikey", github.Resource.Key.Name); 34Assert.True(github.Resource.Key.Secret); 45var connectionString = github.Resource.ConnectionStringExpression.ValueExpression; 57var connectionString = github.Resource.ConnectionStringExpression.ValueExpression; 78var connectionString = await github.Resource.ConnectionStringExpression.GetValueAsync(default); 80Assert.Equal(apiKeyParameter.Resource, github.Resource.Key); 91Assert.NotNull(github.Resource.Key); 92Assert.Equal("github-gh-apikey", github.Resource.Key.Name); 93Assert.True(github.Resource.Key.Secret); 104Assert.Null(github.Resource.Organization); 118Assert.NotNull(github.Resource.Organization); 119Assert.Equal("github-org", github.Resource.Organization.Name); 120Assert.Equal(orgParameter.Resource, github.Resource.Organization); 134var connectionString = github.Resource.ConnectionStringExpression.ValueExpression; 154var connectionString = await github.Resource.ConnectionStringExpression.GetValueAsync(default); 169var connectionString = github.Resource.ConnectionStringExpression.ValueExpression; 188var resource = new GitHubModelResource("test", "openai/gpt-4o-mini", orgParameter.Resource, apiKeyParameter.Resource); 192Assert.Equal(orgParameter.Resource, resource.Organization); 193Assert.Equal(apiKeyParameter.Resource, resource.Key); 204var resource = new GitHubModelResource("test", "openai/gpt-4o-mini", null, apiKeyParameter.Resource); 209Assert.Equal(apiKeyParameter.Resource, resource.Key); 223var resource = new GitHubModelResource("test", "openai/gpt-4o-mini", null, apiKeyParameter.Resource); 226resource.Organization = orgParameter.Resource; 227Assert.Equal(orgParameter.Resource, resource.Organization); 255Assert.Equal(apiKey.Resource, github.Resource.Key); 287var healthCheckAnnotations = github.Resource.Annotations.OfType<HealthCheckAnnotation>().ToList();

41await app.ResourceNotifications.WaitForResourceAsync(resource.Resource.Name, KnownResourceStates.Running, cts.Token); 43await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Waiting, cts.Token); 47await app.ResourceNotifications.WaitForResourceHealthyAsync(resource.Resource.Name, cts.Token); 49await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running, cts.Token);

156if (resourceBuilder.Resource.TryGetAnnotationsOfType<ContainerFilesDestinationAnnotation>(out var containerFilesAnnotations)) 158var buildSteps = context.GetSteps(resourceBuilder.Resource, WellKnownPipelineTags.BuildCompute); 178if (resourceBuilder.Resource.TryGetLastAnnotation<JavaScriptRunScriptAnnotation>(out _) && 179resourceBuilder.Resource.TryGetLastAnnotation<JavaScriptPackageManagerAnnotation>(out var packageManager)) 276if (c.Resource.TryGetLastAnnotation<JavaScriptPackageManagerAnnotation>(out var packageManager)) 287if (c.Resource.TryGetLastAnnotation<JavaScriptInstallCommandAnnotation>(out var installCommand)) 292if (c.Resource.TryGetLastAnnotation<JavaScriptBuildScriptAnnotation>(out var buildCommand)) 326if (resourceBuilder.Resource.TryGetLastAnnotation<JavaScriptPackageManagerAnnotation>(out var packageManager)) 411File.Exists(Path.Combine(resource.Resource.WorkingDirectory, "package-lock.json")) 438var workingDirectory = resource.Resource.WorkingDirectory; 483File.Exists(Path.Combine(resource.Resource.WorkingDirectory, "pnpm-lock.yaml")) 528var installerName = $"{resource.Resource.Name}-installer"; 536resource.ApplicationBuilder.Resources.Remove(existingResource.Resource); 537resource.Resource.Annotations.OfType<WaitAnnotation>() 538.Where(w => w.Resource == existingResource.Resource) 540.ForEach(w => resource.Resource.Annotations.Remove(w)); 541resource.Resource.Annotations.OfType<JavaScriptPackageInstallerAnnotation>() 543.ForEach(a => resource.Resource.Annotations.Remove(a)); 558var installer = new JavaScriptInstallerResource(installerName, resource.Resource.WorkingDirectory); 560.WithParentRelationship(resource.Resource) 567if (!resource.Resource.TryGetLastAnnotation<JavaScriptPackageManagerAnnotation>(out var packageManager) || 568!resource.Resource.TryGetLastAnnotation<JavaScriptInstallCommandAnnotation>(out var installCommand)) 575.WithWorkingDirectory(resource.Resource.WorkingDirectory)

25await ManifestUtils.GetManifest(yarnApp.Resource, tempDir.Path); 39var dockerBuildAnnotation = yarnApp.Resource.Annotations.OfType<DockerfileBuildAnnotation>().Single(); 42var containerFilesSource = yarnApp.Resource.Annotations.OfType<ContainerFilesSourceAnnotation>().Single(); 60await ManifestUtils.GetManifest(pnpmApp.Resource, tempDir.Path);

23var manifest = await ManifestUtils.GetManifest(nodeApp.Resource); 55manifest = await ManifestUtils.GetManifest(npmApp.Resource); 103await ManifestUtils.GetManifest(nodeApp.Resource, tempDir.Path); 129var dockerBuildAnnotation = nodeApp.Resource.Annotations.OfType<DockerfileBuildAnnotation>().Single(); 132Assert.Empty(nodeApp.Resource.Annotations.OfType<ContainerFilesSourceAnnotation>()); 150await ManifestUtils.GetManifest(nodeApp.Resource, tempDir.Path); 195await ManifestUtils.GetManifest(nodeApp.Resource, tempDir.Path);

29var manifest = await ManifestUtils.GetManifest(nodeApp.Resource, tempDir.Path); 67var dockerBuildAnnotation = nodeApp.Resource.Annotations.OfType<DockerfileBuildAnnotation>().Single(); 70var containerFilesSource = nodeApp.Resource.Annotations.OfType<ContainerFilesSourceAnnotation>().Single(); 94var manifest = await ManifestUtils.GetManifest(nodeApp.Resource, tempDir.Path); 114var manifest = await ManifestUtils.GetManifest(nodeApp.Resource, tempDir.Path); 134var manifest = await ManifestUtils.GetManifest(nodeApp.Resource, tempDir.Path); 159var manifest = await ManifestUtils.GetManifest(nodeApp.Resource, tempDir.Path); 177var manifest = await ManifestUtils.GetManifest(nodeApp.Resource, tempDir.Path); 201var manifest = await ManifestUtils.GetManifest(nodeApp.Resource, tempDir.Path); 219var manifest = await ManifestUtils.GetManifest(nodeApp.Resource, tempDir.Path);

109using var client = App.CreateHttpClient(NodeAppBuilder!.Resource.Name, endpointName: "http");

26using var nodeClient = _nodeJsFixture.App.CreateHttpClient(_nodeJsFixture.NodeAppBuilder!.Resource.Name, "http"); 39using var npmClient = _nodeJsFixture.App.CreateHttpClient(_nodeJsFixture.NpmAppBuilder!.Resource.Name, "http");

451Assert.True(app.Resource.TryGetLastAnnotation<JavaScriptInstallCommandAnnotation>(out var installCommand)); 463Assert.True(app.Resource.TryGetLastAnnotation<JavaScriptInstallCommandAnnotation>(out var installCommand)); 478Assert.True(app.Resource.TryGetLastAnnotation<JavaScriptInstallCommandAnnotation>(out var installCommand)); 484Assert.True(app2.Resource.TryGetLastAnnotation<JavaScriptInstallCommandAnnotation>(out installCommand)); 500Assert.True(app.Resource.TryGetLastAnnotation<JavaScriptInstallCommandAnnotation>(out var installCommand)); 516Assert.True(app.Resource.TryGetLastAnnotation<JavaScriptInstallCommandAnnotation>(out var installCommand)); 531Assert.True(app.Resource.TryGetLastAnnotation<JavaScriptInstallCommandAnnotation>(out var installCommand));

81var manifest = await ManifestUtils.GetManifest(kafka.Resource); 121var config = await kafka.Resource.GetEnvironmentVariableValuesAsync(); 123var volumeAnnotation = kafka.Resource.Annotations.OfType<ContainerMountAnnotation>().Single(); 139var config = await kafka.Resource.GetEnvironmentVariableValuesAsync(); 141var volumeAnnotation = kafka.Resource.Annotations.OfType<ContainerMountAnnotation>().Single(); 190var config1 = await kafka.Resource.GetEnvironmentVariableValuesAsync(); 191var config2 = await kafka.Resource.GetEnvironmentVariableValuesAsync();

42await app.ResourceNotifications.WaitForResourceAsync(resource.Resource.Name, KnownResourceStates.Running).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 44await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Waiting).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 48await app.ResourceNotifications.WaitForResourceHealthyAsync(resource.Resource.Name).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 50await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 74hb.Configuration[$"ConnectionStrings:{kafka.Resource.Name}"] = await kafka.Resource.ConnectionStringExpression.GetValueAsync(default); 169hb.Configuration[$"ConnectionStrings:{kafka1.Resource.Name}"] = await kafka1.Resource.ConnectionStringExpression.GetValueAsync(default); 218hb.Configuration[$"ConnectionStrings:{kafka2.Resource.Name}"] = await kafka2.Resource.ConnectionStringExpression.GetValueAsync(default);

55var passwordParameter = adminPassword?.Resource ?? ParameterResourceBuilderExtensions.CreateDefaultPasswordParameter(builder, $"{name}-password"); 57var resource = new KeycloakResource(name, adminUsername?.Resource, passwordParameter);

165var containerAnnotation = keycloak.Resource.Annotations.OfType<ContainerFileSystemCallbackAnnotation>().Single(); 192var containerAnnotation = keycloak.Resource.Annotations.OfType<ContainerFileSystemCallbackAnnotation>().Single();

65var volumeAnnotation = keycloak.Resource.Annotations.OfType<ContainerMountAnnotation>().Single(); 80var volumeAnnotation = keycloak.Resource.Annotations.OfType<ContainerMountAnnotation>().Single(); 95Assert.Equal("Aspire.Hosting.ApplicationModel.UserSecretsParameterDefault", rmq.Resource.AdminPasswordParameter.Default?.GetType().FullName); 105Assert.NotEqual("Aspire.Hosting.ApplicationModel.UserSecretsParameterDefault", rmq.Resource.AdminPasswordParameter.Default?.GetType().FullName); 114var manifest = await ManifestUtils.GetManifest(keycloak.Resource);

64configure(builder.Resource);

107var endpointReferenceEx = ((IComputeEnvironmentResource)env.Resource).GetHostAddressExpression(project.GetEndpoint("http"));

37.WithArgs("--cs", cs.Resource);

43var name = $"{builder.Resource.Name}-maccatalyst"; 84.FirstOrDefault(r => r.Parent == builder.Resource && 90$"Mac Catalyst device with name '{name}' already exists on MAUI project '{builder.Resource.Name}'. " + 97var macCatalystResource = new MauiMacCatalystPlatformResource(name, builder.Resource);

25var projectPath = builder.Resource.ProjectPath;

43var name = $"{builder.Resource.Name}-windows"; 84.FirstOrDefault(r => r.Parent == builder.Resource && 90$"Windows device with name '{name}' already exists on MAUI project '{builder.Resource.Name}'. " + 97var windowsResource = new MauiWindowsPlatformResource(name, builder.Resource);

37Assert.Equal("mauiapp-maccatalyst", macCatalyst.Resource.Name); 38Assert.Equal(maui.Resource, macCatalyst.Resource.Parent); 68Assert.Equal("custom-maccatalyst", macCatalyst.Resource.Name); 129Assert.Contains(device1.Resource, appBuilder.Resources); 130Assert.Contains(device2.Resource, appBuilder.Resources); 160var executableAnnotation = macCatalyst.Resource.Annotations.OfType<ExecutableAnnotation>().Single(); 163Assert.Equal(maui.Resource, macCatalyst.Resource.Parent); 195var args = await ArgumentEvaluator.GetArgumentListAsync(macCatalyst.Resource); 230Assert.Equal("mauiapp-maccatalyst", macCatalyst.Resource.Name); 239.PublishAsync(new BeforeResourceStartedEvent(macCatalyst.Resource, app.Services), CancellationToken.None);

37Assert.Equal("mauiapp-windows", windows.Resource.Name); 38Assert.Same(maui.Resource, windows.Resource.Parent); 45Assert.Same(windows.Resource, windowsDeviceInModel); 75Assert.Equal("custom-windows", windows.Resource.Name); 137.Where(r => r.Parent == maui.Resource) 141Assert.Contains(windows1.Resource, windowsDevices); 142Assert.Contains(windows2.Resource, windowsDevices); 172var resource = windows.Resource; 217Assert.Equal("mauiapp-windows", windows.Resource.Name); 226.PublishAsync(new BeforeResourceStartedEvent(windows.Resource, app.Services), CancellationToken.None);

49var apiKeyParameter = apiKey?.Resource ?? 103builder.Resource.AddDatabase(name, databaseName); 104var milvusDatabaseResource = new MilvusDatabaseResource(name, databaseName, builder.Resource); 135containerName ??= $"{builder.Resource.Name}-attu"; 142.WithEnvironment(context => ConfigureAttuContainer(context, builder.Resource))

85var connectionStringResource = milvus.Resource as IResourceWithConnectionString; 105var config = await EnvironmentVariableEvaluator.GetEnvironmentVariablesAsync(projectA.Resource, DistributedApplicationOperation.Run, TestServiceProvider.Instance); 116var containerConfig = await EnvironmentVariableEvaluator.GetEnvironmentVariablesAsync(container1.Resource, DistributedApplicationOperation.Run, TestServiceProvider.Instance); 132var serverManifest = await ManifestUtils.GetManifest(milvus.Resource); // using this method does not get any ExecutionContext.IsPublishMode changes 133var dbManifest = await ManifestUtils.GetManifest(db1.Resource);

30await app.WaitForTextAsync("Milvus Proxy successfully initialized and ready to serve", milvus.Resource.Name); 34hb.Configuration[$"ConnectionStrings:{db.Resource.Name}"] = await db.Resource.ConnectionStringExpression.GetValueAsync(default); 36hb.AddMilvusClient(db.Resource.Name); 80var password = milvus1.Resource.ApiKeyParameter.Value; 106await app.WaitForTextAsync("Milvus Proxy successfully initialized and ready to serve", milvus1.Resource.Name); 112hb.Configuration[$"ConnectionStrings:{db1.Resource.Name}"] = await db1.Resource.ConnectionStringExpression.GetValueAsync(default); 114hb.AddMilvusClient(db1.Resource.Name); 153await app.WaitForTextAsync("Milvus Proxy successfully initialized and ready to serve", milvus2.Resource.Name); 159hb.Configuration[$"ConnectionStrings:{db2.Resource.Name}"] = await db2.Resource.ConnectionStringExpression.GetValueAsync(default); 161hb.AddMilvusClient(db2.Resource.Name);

56var passwordParameter = password?.Resource ?? ParameterResourceBuilderExtensions.CreateDefaultPasswordParameter(builder, $"{name}-password", special: false); 58var mongoDBContainer = new MongoDBServerResource(name, userName?.Resource, passwordParameter); 108builder.Resource.AddDatabase(name, databaseName); 109var mongoDBDatabase = new MongoDBDatabaseResource(name, databaseName, builder.Resource); 152containerName ??= $"{builder.Resource.Name}-mongoexpress"; 158.WithEnvironment(context => ConfigureMongoExpressContainer(context, builder.Resource))

199var mongoManifest = await ManifestUtils.GetManifest(mongo.Resource); 200var dbManifest = await ManifestUtils.GetManifest(db.Resource); 265Assert.Equal("customers1", db1.Resource.DatabaseName); 266Assert.Equal("customers2", db2.Resource.DatabaseName); 268Assert.Equal("mongodb://admin:{mongo1-password.value}@{mongo1.bindings.tcp.host}:{mongo1.bindings.tcp.port}/customers1?authSource=admin&authMechanism=SCRAM-SHA-256", db1.Resource.ConnectionStringExpression.ValueExpression); 269Assert.Equal("mongodb://admin:{mongo1-password.value}@{mongo1.bindings.tcp.host}:{mongo1.bindings.tcp.port}/customers2?authSource=admin&authMechanism=SCRAM-SHA-256", db2.Resource.ConnectionStringExpression.ValueExpression); 283Assert.Equal("imports", db1.Resource.DatabaseName); 284Assert.Equal("imports", db2.Resource.DatabaseName); 286Assert.Equal("mongodb://admin:{mongo1-password.value}@{mongo1.bindings.tcp.host}:{mongo1.bindings.tcp.port}/imports?authSource=admin&authMechanism=SCRAM-SHA-256", db1.Resource.ConnectionStringExpression.ValueExpression); 287Assert.Equal("mongodb://admin:{mongo2-password.value}@{mongo2.bindings.tcp.host}:{mongo2.bindings.tcp.port}/imports?authSource=admin&authMechanism=SCRAM-SHA-256", db2.Resource.ConnectionStringExpression.ValueExpression);

52await app.ResourceNotifications.WaitForResourceAsync(resource.Resource.Name, KnownResourceStates.Running, cts.Token); 54await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Waiting, cts.Token); 58await app.ResourceNotifications.WaitForResourceHealthyAsync(resource.Resource.Name, cts.Token); 60await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running, cts.Token); 85hb.Configuration[$"ConnectionStrings:{db.Resource.Name}"] = await db.Resource.ConnectionStringExpression.GetValueAsync(default); 87hb.AddMongoDBClient(db.Resource.Name); 121var password = mongodb1.Resource.PasswordParameter!.Value; 149hb.Configuration[$"ConnectionStrings:{db1.Resource.Name}"] = await db1.Resource.ConnectionStringExpression.GetValueAsync(default); 151hb.AddMongoDBClient(db1.Resource.Name); 193hb.Configuration[$"ConnectionStrings:{db2.Resource.Name}"] = await db2.Resource.ConnectionStringExpression.GetValueAsync(default); 195hb.AddMongoDBClient(db2.Resource.Name); 305hb.Configuration[$"ConnectionStrings:{db.Resource.Name}"] = await db.Resource.ConnectionStringExpression.GetValueAsync(default); 307hb.AddMongoDBClient(db.Resource.Name); 396hb.Configuration[$"ConnectionStrings:{db.Resource.Name}"] = await db.Resource.ConnectionStringExpression.GetValueAsync(default); 398hb.AddMongoDBClient(db.Resource.Name);

37var passwordParameter = password?.Resource ?? ParameterResourceBuilderExtensions.CreateDefaultPasswordParameter(builder, $"{name}-password"); 116var mySqlDatabase = new MySqlDatabaseResource(name, databaseName, builder.Resource); 118builder.Resource.AddDatabase(mySqlDatabase); 202builder.Resource.PasswordParameter = password.Resource; 268var configStoreFilename = aspireStore.GetFileNameWithContent($"{builder.Resource.Name}-config.user.inc.php", tempConfigFile);

23Assert.Equal("Aspire.Hosting.ApplicationModel.UserSecretsParameterDefault", mysql.Resource.PasswordParameter.Default?.GetType().FullName); 33Assert.NotEqual("Aspire.Hosting.ApplicationModel.UserSecretsParameterDefault", mysql.Resource.PasswordParameter.Default?.GetType().FullName); 160var mySqlManifest = await ManifestUtils.GetManifest(mysql.Resource); 161var dbManifest = await ManifestUtils.GetManifest(db.Resource); 199var serverManifest = await ManifestUtils.GetManifest(mysql.Resource); 251Assert.Equal($"{mysql.Resource.Name}:{mysql.Resource.PrimaryEndpoint.TargetPort}", config["PMA_HOST"]); 283string pattern1 = $@"\$cfg\['Servers'\]\[\$i\]\['host'\] = '{mysql1.Resource.Name}:{mysql1.Resource.PrimaryEndpoint.TargetPort}';"; 284string pattern2 = $@"\$cfg\['Servers'\]\[\$i\]\['host'\] = '{mysql2.Resource.Name}:{mysql2.Resource.PrimaryEndpoint.TargetPort}';"; 324Assert.Equal(["db1", "db2"], mysql1.Resource.Databases.Keys); 325Assert.Equal(["customers1", "customers2"], mysql1.Resource.Databases.Values); 327Assert.Equal("customers1", db1.Resource.DatabaseName); 328Assert.Equal("customers2", db2.Resource.DatabaseName); 330Assert.Equal("{mysql1.connectionString};Database=customers1", db1.Resource.ConnectionStringExpression.ValueExpression); 331Assert.Equal("{mysql1.connectionString};Database=customers2", db2.Resource.ConnectionStringExpression.ValueExpression); 345Assert.Equal("imports", db1.Resource.DatabaseName); 346Assert.Equal("imports", db2.Resource.DatabaseName); 348Assert.Equal("{mysql1.connectionString};Database=imports", db1.Resource.ConnectionStringExpression.ValueExpression); 349Assert.Equal("{mysql2.connectionString};Database=imports", db2.Resource.ConnectionStringExpression.ValueExpression);

49await app.ResourceNotifications.WaitForResourceAsync(resource.Resource.Name, KnownResourceStates.Running, cts.Token); 51await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Waiting, cts.Token); 55await app.ResourceNotifications.WaitForResourceHealthyAsync(resource.Resource.Name, cts.Token); 57await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running, cts.Token); 90[$"ConnectionStrings:{db.Resource.Name}"] = await db.Resource.ConnectionStringExpression.GetValueAsync(default) 93hb.AddMySqlDataSource(db.Resource.Name); 133var password = mysql1.Resource.PasswordParameter.Value; 166[$"ConnectionStrings:{db1.Resource.Name}"] = await db1.Resource.ConnectionStringExpression.GetValueAsync(default) 169hb.AddMySqlDataSource(db1.Resource.Name); 235[$"ConnectionStrings:{db2.Resource.Name}"] = await db2.Resource.ConnectionStringExpression.GetValueAsync(cts.Token) 238hb.AddMySqlDataSource(db2.Resource.Name); 338[$"ConnectionStrings:{db.Resource.Name}"] = await db.Resource.ConnectionStringExpression.GetValueAsync(cts.Token) 341hb.AddMySqlDataSource(db.Resource.Name); 424[$"ConnectionStrings:{db.Resource.Name}"] = await db.Resource.ConnectionStringExpression.GetValueAsync(cts.Token) 427hb.AddMySqlDataSource(db.Resource.Name); 494[$"ConnectionStrings:{db.Resource.Name}"] = await db.Resource.ConnectionStringExpression.GetValueAsync(cts.Token) 497hb.AddMySqlDbContext<TestDbContext>(db.Resource.Name); 651hb.Configuration[$"ConnectionStrings:{newDb.Resource.Name}"] = await newDb.Resource.ConnectionStringExpression.GetValueAsync(default); 653hb.AddMySqlDataSource(newDb.Resource.Name); 659await app.ResourceNotifications.WaitForResourceHealthyAsync(newDb.Resource.Name, cts.Token); 726hb.Configuration[$"ConnectionStrings:{newDb.Resource.Name}"] = await newDb.Resource.ConnectionStringExpression.GetValueAsync(default); 728hb.AddMySqlDataSource(newDb.Resource.Name); 734await app.ResourceNotifications.WaitForResourceHealthyAsync(mysql.Resource.Name, cts.Token); 785hb.Configuration[$"ConnectionStrings:{db.Resource.Name}"] = await db.Resource.ConnectionStringExpression.GetValueAsync(default); 786hb.AddKeyedMySqlDataSource(db.Resource.Name); 795await app.ResourceNotifications.WaitForResourceHealthyAsync(db.Resource.Name, cts.Token); 797var conn = host.Services.GetRequiredKeyedService<MySqlConnection>(db.Resource.Name); 827hb.Configuration[$"ConnectionStrings:{newDb.Resource.Name}"] = await newDb.Resource.ConnectionStringExpression.GetValueAsync(default); 828hb.AddMySqlDataSource(newDb.Resource.Name); 833await app.ResourceNotifications.WaitForResourceHealthyAsync(newDb.Resource.Name, cts.Token);

54var passwordParameter = password?.Resource ?? ParameterResourceBuilderExtensions.CreateDefaultPasswordParameter(builder, $"{name}-password", special: false); 56var nats = new NatsServerResource(name, userName?.Resource, passwordParameter);

20Assert.Equal("Aspire.Hosting.ApplicationModel.UserSecretsParameterDefault", nats.Resource.PasswordParameter!.Default?.GetType().FullName); 30Assert.NotEqual("Aspire.Hosting.ApplicationModel.UserSecretsParameterDefault", nats.Resource.PasswordParameter!.Default?.GetType().FullName); 41Assert.NotNull(nats.Resource.PasswordParameter); 43Assert.False(string.IsNullOrEmpty(nats.Resource.PasswordParameter!.Value)); 71Assert.NotNull(nats.Resource.UserNameParameter); 72Assert.NotNull(nats.Resource.PasswordParameter); 75Assert.Equal("usr", nats.Resource.UserNameParameter!.Value); 76Assert.Equal("password", nats.Resource.PasswordParameter!.Value); 193var manifest = await ManifestUtils.GetManifest(nats.Resource); 230var manifest = await ManifestUtils.GetManifest(nats.Resource); 258manifest = await ManifestUtils.GetManifest(nats.Resource); 285manifest = await ManifestUtils.GetManifest(nats.Resource);

35await app.WaitForTextAsync("Listening for client connections", nats.Resource.Name); 39hb.Configuration[$"ConnectionStrings:{nats.Resource.Name}"] = await nats.Resource.ConnectionStringExpression.GetValueAsync(default); 80await app.WaitForTextAsync("Listening for client connections", nats.Resource.Name); 84var connectionString = await nats.Resource.ConnectionStringExpression.GetValueAsync(default); 85hb.Configuration[$"ConnectionStrings:{nats.Resource.Name}"] = connectionString; 122await app.WaitForTextAsync("Listening for client connections", nats.Resource.Name); 126var connectionString = await nats.Resource.ConnectionStringExpression.GetValueAsync(default); 131hb.Configuration[$"ConnectionStrings:{nats.Resource.Name}"] = modifiedConnectionString; 184await app.WaitForTextAsync("Listening for client connections", nats1.Resource.Name); 189hb.Configuration[$"ConnectionStrings:{nats1.Resource.Name}"] = await nats1.Resource.ConnectionStringExpression.GetValueAsync(default); 232await app.WaitForTextAsync("Listening for client connections", nats2.Resource.Name); 237hb.Configuration[$"ConnectionStrings:{nats2.Resource.Name}"] = await nats2.Resource.ConnectionStringExpression.GetValueAsync(default); 342await app.ResourceNotifications.WaitForResourceAsync(resource.Resource.Name, KnownResourceStates.Running, cts.Token); 344await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Waiting, cts.Token); 348await app.ResourceNotifications.WaitForResourceHealthyAsync(resource.Resource.Name, cts.Token); 350await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running, cts.Token);

178var action = () => new NatsServerResource(name, user?.Resource, password?.Resource);

37defaultApiKeyParameter.Resource.Description = """ 41defaultApiKeyParameter.Resource.EnableDescriptionMarkdown = true; 43var resource = new OpenAIResource(name, defaultApiKeyParameter.Resource); 108var resource = new OpenAIModelResource(name, model, builder.Resource); 147builder.Resource.Endpoint = endpoint; 159if (!apiKey.Resource.Secret) 165if (builder.Resource.DefaultKeyParameter == builder.Resource.Key) 167builder.ApplicationBuilder.Resources.Remove(builder.Resource.Key); 170builder.Resource.Key = apiKey.Resource; 200var healthCheckKey = $"{builder.Resource.Name}_check"; 222var resource = builder.Resource;

21var parentCs = await parent.Resource.ConnectionStringExpression.GetValueAsync(default); 22var modelCs = await model.Resource.ConnectionStringExpression.GetValueAsync(default); 41var parentCs = await parent.Resource.ConnectionStringExpression.GetValueAsync(default); 42var modelCs = await model.Resource.ConnectionStringExpression.GetValueAsync(default); 61Assert.Equal("chat", model.Resource.Name); 62Assert.Equal("gpt-4o-mini", model.Resource.Model); 73Assert.NotNull(parent.Resource.Key); 74Assert.Equal("openai-openai-apikey", parent.Resource.Key.Name); 75Assert.True(parent.Resource.Key.Secret); 77Assert.NotNull(parent.Resource.Key); 90var expression = openai.Resource.ConnectionStringExpression.ValueExpression; 95var resolved = await openai.Resource.ConnectionStringExpression.GetValueAsync(default); 108var expression = openai.Resource.ConnectionStringExpression.ValueExpression; 114var resolved = await openai.Resource.ConnectionStringExpression.GetValueAsync(default); 134var connectionString = await openai.Resource.ConnectionStringExpression.GetValueAsync(default); 136Assert.Equal(apiKeyParameter.Resource, parent.Resource.Key); 148Assert.NotNull(parent.Resource.Key); 149Assert.Equal("openai-openai-apikey", parent.Resource.Key.Name); 150Assert.True(parent.Resource.Key.Secret); 151Assert.Equal(parent.Resource.Key, parent.Resource.Key); 163var resource = new OpenAIModelResource("test", "gpt-4o-mini", parent.Resource); 168Assert.Equal(parent.Resource.Key, parent.Resource.Key); 198Assert.Equal(apiKey.Resource, parent.Resource.Key); 232var healthCheckAnnotations = openai.Resource.Annotations.OfType<HealthCheckAnnotation>().ToList(); 282var connectionString = await openai.Resource.ConnectionStringExpression.GetValueAsync(default); 363Assert.Equal("chat", openai.Resource.Name); 364Assert.Equal(modelName, openai.Resource.Model); 366var connectionString = openai.Resource.ConnectionStringExpression.ValueExpression;

43await app.ResourceNotifications.WaitForResourceAsync(resource.Resource.Name, KnownResourceStates.Running, cts.Token); 45await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Waiting, cts.Token); 49await app.ResourceNotifications.WaitForResourceHealthyAsync(resource.Resource.Name, cts.Token); 51await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running, cts.Token); 77Assert.Single(resource.Resource.Annotations, a => a is HealthCheckAnnotation hca && hca.Key == "resource_check"); 80var statusPageHealthCheck = Enumerable.Single(resource.Resource.Annotations, x => x is HealthCheckAnnotation hca && hca.Key == "resource_check"); 81resource.Resource.Annotations.Remove(statusPageHealthCheck); 90await app.ResourceNotifications.WaitForResourceAsync(resource.Resource.Name, KnownResourceStates.Running, cts.Token); 92await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Waiting, cts.Token); 96await app.ResourceNotifications.WaitForResourceHealthyAsync(resource.Resource.Name, cts.Token); 98await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running, cts.Token);

37var passwordParameter = password?.Resource ?? ParameterResourceBuilderExtensions.CreateDefaultPasswordParameter(builder, $"{name}-password"); 86builder.Resource.AddDatabase(name, databaseName); 87var oracleDatabase = new OracleDatabaseResource(name, databaseName, builder.Resource);

21Assert.Equal("Aspire.Hosting.ApplicationModel.UserSecretsParameterDefault", orcl.Resource.PasswordParameter.Default?.GetType().FullName); 31Assert.NotEqual("Aspire.Hosting.ApplicationModel.UserSecretsParameterDefault", orcl.Resource.PasswordParameter.Default?.GetType().FullName); 199var serverManifest = await ManifestUtils.GetManifest(oracleServer.Resource); 200var dbManifest = await ManifestUtils.GetManifest(db.Resource); 238var serverManifest = await ManifestUtils.GetManifest(oracleServer.Resource); 294Assert.Equal("customers1", db1.Resource.DatabaseName); 295Assert.Equal("customers2", db2.Resource.DatabaseName); 297Assert.Equal("{oracle1.connectionString}/customers1", db1.Resource.ConnectionStringExpression.ValueExpression); 298Assert.Equal("{oracle1.connectionString}/customers2", db2.Resource.ConnectionStringExpression.ValueExpression); 312Assert.Equal("imports", db1.Resource.DatabaseName); 313Assert.Equal("imports", db2.Resource.DatabaseName); 315Assert.Equal("{oracle1.connectionString}/imports", db1.Resource.ConnectionStringExpression.ValueExpression); 316Assert.Equal("{oracle2.connectionString}/imports", db2.Resource.ConnectionStringExpression.ValueExpression);

50hb.Configuration[$"ConnectionStrings:{db.Resource.Name}"] = await db.Resource.ConnectionStringExpression.GetValueAsync(default); 52hb.AddOracleDatabaseDbContext<TestDbContext>(db.Resource.Name); 98var password = oracle1.Resource.PasswordParameter.Value; 135hb.Configuration[$"ConnectionStrings:{db1.Resource.Name}"] = await db1.Resource.ConnectionStringExpression.GetValueAsync(default); 137hb.AddOracleDatabaseDbContext<TestDbContext>(db1.Resource.Name); 195hb.Configuration[$"ConnectionStrings:{db2.Resource.Name}"] = await db2.Resource.ConnectionStringExpression.GetValueAsync(default); 197hb.AddOracleDatabaseDbContext<TestDbContext>(db2.Resource.Name); 302hb.Configuration[$"ConnectionStrings:{db.Resource.Name}"] = await db.Resource.ConnectionStringExpression.GetValueAsync(default); 304hb.AddOracleDatabaseDbContext<TestDbContext>(db.Resource.Name); 399hb.Configuration[$"ConnectionStrings:{db.Resource.Name}"] = await db.Resource.ConnectionStringExpression.GetValueAsync(default); 401hb.AddOracleDatabaseDbContext<TestDbContext>(db.Resource.Name); 462await app.ResourceNotifications.WaitForResourceAsync(resource.Resource.Name, KnownResourceStates.Running, cts.Token); 464await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Waiting, cts.Token); 468await app.ResourceNotifications.WaitForResourceHealthyAsync(resource.Resource.Name, cts.Token); 470await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running, cts.Token);

208var parent = builder.Resource; 227var parent = builder.Resource;

55orleansServiceBuilder.ClusterId = clusterId.Resource; 83orleansServiceBuilder.ServiceId = serviceId.Resource; 131=> WithGrainStorage(orleansServiceBuilder, provider.Resource.Name, provider); 183=> WithStreaming(orleansServiceBuilder, provider.Resource.Name, provider); 299=> WithGrainDirectory(orleansServiceBuilder, provider.Resource.Name, provider);

21var serviceKey = resourceBuilder.Resource.Name; 22var resourceType = resourceBuilder.Resource.GetType().Name;

50var passwordParameter = password?.Resource ?? ParameterResourceBuilderExtensions.CreateDefaultPasswordParameter(builder, $"{name}-password"); 52var postgresServer = new PostgresServerResource(name, userName?.Resource, passwordParameter); 148var postgresDatabase = new PostgresDatabaseResource(name, databaseName, builder.Resource); 150builder.Resource.AddDatabase(postgresDatabase.Name, postgresDatabase.DatabaseName); 224pgAdminContainerBuilder.WithRelationship(builder.Resource, "PgAdmin"); 312pgwebContainerBuilder.WithRelationship(builder.Resource, "PgWeb"); 468builder.Resource.PasswordParameter = password.Resource; 483builder.Resource.UserNameParameter = userName.Resource;

21Assert.Single(redis.Resource.Annotations, a => a is HealthCheckAnnotation hca && hca.Key == "postgres_check"); 31Assert.Equal("Aspire.Hosting.ApplicationModel.UserSecretsParameterDefault", pg.Resource.PasswordParameter.Default?.GetType().FullName); 41Assert.NotEqual("Aspire.Hosting.ApplicationModel.UserSecretsParameterDefault", pg.Resource.PasswordParameter.Default?.GetType().FullName); 157var connectionStringResource = postgres.Resource as IResourceWithConnectionString; 162Assert.Equal($"Host=localhost;Port=2000;Username=postgres;Password={postgres.Resource.PasswordParameter.Value}", connectionString); 250var serverManifest = await ManifestUtils.GetManifest(pgServer.Resource); 251var dbManifest = await ManifestUtils.GetManifest(db.Resource); 294var serverManifest = await ManifestUtils.GetManifest(pgServer.Resource); 320serverManifest = await ManifestUtils.GetManifest(pgServer.Resource); 346serverManifest = await ManifestUtils.GetManifest(pgServer.Resource); 489Assert.Equal(pg1.Resource.Name, servers.GetProperty("1").GetProperty("Name").GetString()); 497Assert.Equal($"echo '{pg1.Resource.PasswordParameter.Value}'", servers.GetProperty("1").GetProperty("PasswordExecCommand").GetString()); 501Assert.Equal(pg2.Resource.Name, servers.GetProperty("2").GetProperty("Name").GetString()); 509Assert.Equal($"echo '{pg2.Resource.PasswordParameter.Value}'", servers.GetProperty("2").GetProperty("PasswordExecCommand").GetString()); 557Assert.Equal(CreatePgWebBookmarkfileContent(db1.Resource), file.Contents); 564Assert.Equal(CreatePgWebBookmarkfileContent(db2.Resource), file.Contents); 601Assert.Equal("customers1", db1.Resource.DatabaseName); 602Assert.Equal("customers2", db2.Resource.DatabaseName); 604Assert.Equal("{postgres1.connectionString};Database=customers1", db1.Resource.ConnectionStringExpression.ValueExpression); 605Assert.Equal("{postgres1.connectionString};Database=customers2", db2.Resource.ConnectionStringExpression.ValueExpression); 619Assert.Equal("imports", db1.Resource.DatabaseName); 620Assert.Equal("imports", db2.Resource.DatabaseName); 622Assert.Equal("{postgres1.connectionString};Database=imports", db1.Resource.ConnectionStringExpression.ValueExpression); 623Assert.Equal("{postgres2.connectionString};Database=imports", db2.Resource.ConnectionStringExpression.ValueExpression); 668var connectionString = await postgres.Resource.GetConnectionStringAsync(); 682var connectionString = await postgres.Resource.GetConnectionStringAsync(); 684Assert.Equal($"Host=localhost;Port=2000;Username=user1;Password={postgres.Resource.PasswordParameter.Value}", connectionString); 697var config1 = await postgres.Resource.GetEnvironmentVariableValuesAsync(); 698var config2 = await postgres.Resource.GetEnvironmentVariableValuesAsync();

257var postgresParentResource = new PostgresServerResource("postgresServer", userName, builder.Resource); 277var postgresParentResource = new PostgresServerResource("postgresServer", userName, builder.Resource); 310var action = () => new PostgresServerResource(name, userName, builder.Resource);

52await app.ResourceNotifications.WaitForResourceAsync(postgres.Resource.Name, KnownResourceStates.Running).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 55await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Waiting).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 61await app.ResourceNotifications.WaitForResourceHealthyAsync(postgres.Resource.Name).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 64await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 86await app.WaitForTextAsync("Listening at", resourceName: adminBuilder.Resource.Name); 88var client = app.CreateHttpClient(adminBuilder.Resource.Name, "http"); 119[$"ConnectionStrings:{db.Resource.Name}"] = await db.Resource.ConnectionStringExpression.GetValueAsync(default) 122hb.AddNpgsqlDataSource(db.Resource.Name); 128await app.ResourceNotifications.WaitForResourceHealthyAsync(postgres.Resource.Name, cts.Token); 165var client = app.CreateHttpClient(pgWebBuilder.Resource.Name, "http"); 167await app.ResourceNotifications.WaitForResourceHealthyAsync(pgWebBuilder.Resource.Name).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 233await app.ResourceNotifications.WaitForResourceHealthyAsync(db1.Resource.Name, cts.Token); 241[$"ConnectionStrings:{db1.Resource.Name}"] = await db1.Resource.ConnectionStringExpression.GetValueAsync(default) 244hb.AddNpgsqlDataSource(db1.Resource.Name); 295await app.ResourceNotifications.WaitForResourceHealthyAsync(db2.Resource.Name, cts.Token); 303[$"ConnectionStrings:{db2.Resource.Name}"] = await db2.Resource.ConnectionStringExpression.GetValueAsync(default) 306hb.AddNpgsqlDataSource(db2.Resource.Name); 398[$"ConnectionStrings:{db.Resource.Name}"] = await db.Resource.ConnectionStringExpression.GetValueAsync(default) 401hb.AddNpgsqlDataSource(db.Resource.Name); 407await app.ResourceNotifications.WaitForResourceHealthyAsync(db.Resource.Name, cts.Token); 484[$"ConnectionStrings:{db.Resource.Name}"] = await db.Resource.ConnectionStringExpression.GetValueAsync(default) 487hb.AddNpgsqlDataSource(db.Resource.Name); 493await app.ResourceNotifications.WaitForResourceHealthyAsync(db.Resource.Name, cts.Token); 611hb.Configuration[$"ConnectionStrings:{newDb.Resource.Name}"] = await newDb.Resource.ConnectionStringExpression.GetValueAsync(default); 613hb.AddNpgsqlDataSource(newDb.Resource.Name); 619await app.ResourceNotifications.WaitForResourceHealthyAsync(newDb.Resource.Name, cts.Token); 652hb.Configuration[$"ConnectionStrings:{newDb.Resource.Name}"] = await newDb.Resource.ConnectionStringExpression.GetValueAsync(default); 654hb.AddNpgsqlDataSource(newDb.Resource.Name); 660await app.ResourceNotifications.WaitForResourceHealthyAsync(newDb.Resource.Name, cts.Token); 721hb.Configuration[$"ConnectionStrings:{newDb.Resource.Name}"] = await newDb.Resource.ConnectionStringExpression.GetValueAsync(default); 723hb.AddNpgsqlDataSource(newDb.Resource.Name); 729await app.ResourceNotifications.WaitForResourceHealthyAsync(postgres.Resource.Name, cts.Token); 780hb.Configuration[$"ConnectionStrings:{db.Resource.Name}"] = await db.Resource.ConnectionStringExpression.GetValueAsync(default); 781hb.AddKeyedNpgsqlDataSource(db.Resource.Name); 790await app.ResourceNotifications.WaitForResourceHealthyAsync(db.Resource.Name, cts.Token); 792var conn = host.Services.GetRequiredKeyedService<NpgsqlConnection>(db.Resource.Name);

447if (resourceBuilder.Resource.TryGetAnnotationsOfType<ContainerFilesDestinationAnnotation>(out var containerFilesAnnotations)) 449var buildSteps = context.GetSteps(resourceBuilder.Resource, WellKnownPipelineTags.BuildCompute); 464var resourceToSetup = resourceBuilder.Resource; 811: Path.GetFullPath(virtualEnvironmentPath, builder.Resource.WorkingDirectory); 816if (!builder.Resource.TryGetLastAnnotation<PythonEntrypointAnnotation>(out var entrypointAnnotation)) 870if (!builder.Resource.TryGetLastAnnotation<PythonEntrypointAnnotation>(out var entrypointAnnotation)) 883programPath = Path.GetFullPath(entrypoint, builder.Resource.WorkingDirectory); 888programPath = builder.Resource.WorkingDirectory; 896if (!builder.Resource.TryGetLastAnnotation<PythonEnvironmentAnnotation>(out var annotation) || annotation.VirtualEnvironment is null) 904: Path.GetFullPath(annotation.VirtualEnvironment.VirtualEnvironmentPath, builder.Resource.WorkingDirectory); 996if (!builder.Resource.TryGetLastAnnotation<PythonEnvironmentAnnotation>(out var pythonEnv) || 1091if (!builder.Resource.TryGetLastAnnotation<PythonEnvironmentAnnotation>(out var pythonEnv) || 1096pythonEnv = builder.Resource.Annotations.OfType<PythonEnvironmentAnnotation>().Last(); 1103var workingDirectory = builder.Resource.WorkingDirectory; 1247var installerName = $"{builder.Resource.Name}-installer"; 1255builder.ApplicationBuilder.Resources.Remove(existingResource.Resource); 1256builder.Resource.Annotations.OfType<PythonPackageInstallerAnnotation>() 1258.ForEach(a => builder.Resource.Annotations.Remove(a)); 1269var installer = new PythonInstallerResource(installerName, builder.Resource); 1271.WithParentRelationship(builder.Resource) 1278if (!builder.Resource.TryGetLastAnnotation<PythonPackageManagerAnnotation>(out var packageManager) || 1279!builder.Resource.TryGetLastAnnotation<PythonInstallCommandAnnotation>(out var installCommand)) 1288.WithWorkingDirectory(builder.Resource.WorkingDirectory) 1306if (!builder.Resource.TryGetLastAnnotation<PythonEnvironmentAnnotation>(out var pythonEnv) || 1314: Path.GetFullPath(pythonEnv.VirtualEnvironment.VirtualEnvironmentPath, builder.Resource.WorkingDirectory); 1317var venvCreatorName = $"{builder.Resource.Name}-venv-creator"; 1327var venvCreator = new PythonVenvCreatorResource(venvCreatorName, builder.Resource, venvPath); 1345.WithWorkingDirectory(builder.Resource.WorkingDirectory) 1346.WithParentRelationship(builder.Resource) 1354var venvCreatorName = $"{builder.Resource.Name}-venv-creator"; 1359builder.ApplicationBuilder.Resources.Remove(venvCreatorBuilder.Resource); 1412var isUsingUv = builder.Resource.TryGetLastAnnotation<PythonPackageManagerAnnotation>(out var pkgMgr) && 1422if (!builder.Resource.TryGetLastAnnotation<PythonEnvironmentAnnotation>(out var pythonEnv) || 1436: Path.GetFullPath(pythonEnv.VirtualEnvironment.VirtualEnvironmentPath, builder.Resource.WorkingDirectory); 1452if (!builder.Resource.TryGetLastAnnotation<PythonEnvironmentAnnotation>(out var existing))

38var manifest = await ManifestUtils.GetManifest(pyproj.Resource, manifestDirectory: projectDirectory); 76var manifest = await ManifestUtils.GetManifest(pyproj.Resource, manifestDirectory: projectDirectory); 136var environmentVariables = await EnvironmentVariableEvaluator.GetEnvironmentVariablesAsync(pyproj.Resource, DistributedApplicationOperation.Run, TestServiceProvider.Instance); 733Assert.True(pythonApp.Resource.TryGetLastAnnotation<PythonPackageManagerAnnotation>(out var packageManager)); 737Assert.True(pythonApp.Resource.TryGetLastAnnotation<PythonInstallCommandAnnotation>(out var installAnnotation)); 757Assert.True(pythonApp.Resource.TryGetLastAnnotation<PythonInstallCommandAnnotation>(out var installAnnotation)); 841Assert.True(pythonApp.Resource.TryGetLastAnnotation<PythonPackageManagerAnnotation>(out var packageManager)); 845Assert.True(pythonApp.Resource.TryGetLastAnnotation<PythonInstallCommandAnnotation>(out var installAnnotation)); 872Assert.True(pythonApp.Resource.TryGetLastAnnotation<PythonPackageManagerAnnotation>(out var packageManager)); 876Assert.True(pythonApp.Resource.TryGetLastAnnotation<PythonInstallCommandAnnotation>(out var installAnnotation)); 1152var initialCommand = pythonBuilder.Resource.Command; 1157var newCommand = pythonBuilder.Resource.Command; 1375var resource = pythonApp.Resource; 1413var resource = pythonApp.Resource; 1453var resource = pythonApp.Resource; 1490var resource = pythonApp.Resource; 1521var resource = pythonApp.Resource; 1544pythonApp.Resource, DistributedApplicationOperation.Run, TestServiceProvider.Instance); 1566pythonApp.Resource, DistributedApplicationOperation.Run, TestServiceProvider.Instance); 1584pythonApp.Resource, DistributedApplicationOperation.Publish, TestServiceProvider.Instance); 1819Assert.True(pythonApp.Resource.TryGetLastAnnotation<PythonPackageManagerAnnotation>(out var packageManager)); 1823Assert.True(pythonApp.Resource.TryGetLastAnnotation<PythonInstallCommandAnnotation>(out var installAnnotation)); 1853Assert.True(pythonApp.Resource.TryGetLastAnnotation<PythonPackageManagerAnnotation>(out var packageManager)); 1857Assert.True(pythonApp.Resource.TryGetLastAnnotation<PythonInstallCommandAnnotation>(out var installAnnotation)); 1890Assert.True(pythonApp.Resource.TryGetLastAnnotation<PythonPackageManagerAnnotation>(out var packageManager)); 1894Assert.True(pythonApp.Resource.TryGetLastAnnotation<PythonInstallCommandAnnotation>(out var installAnnotation)); 1914Assert.False(pythonApp.Resource.TryGetLastAnnotation<PythonPackageManagerAnnotation>(out _)); 2020Assert.True(pythonApp.Resource.TryGetLastAnnotation<PythonPackageManagerAnnotation>(out var packageManager)); 2055Assert.True(pythonApp.Resource.TryGetLastAnnotation<PythonPackageManagerAnnotation>(out var packageManager)); 2059Assert.True(pythonApp.Resource.TryGetLastAnnotation<PythonEnvironmentAnnotation>(out var envAnnotation)); 2095Assert.True(pythonApp.Resource.TryGetLastAnnotation<PythonEnvironmentAnnotation>(out var envAnnotation)); 2125Assert.True(pythonApp.Resource.TryGetLastAnnotation<PythonEnvironmentAnnotation>(out var envAnnotation)); 2226Assert.True(pythonApp.Resource.TryGetLastAnnotation<PythonPackageManagerAnnotation>(out var packageManager)); 2258Assert.True(pythonApp.Resource.TryGetLastAnnotation<PythonPackageManagerAnnotation>(out var packageManager));

24Assert.IsType<UvicornAppResource>(uvicornApp.Resource); 25Assert.Equal("uvicorn-app", uvicornApp.Resource.Name);

46var apiKeyParameter = apiKey?.Resource ?? 158var resource = (IResourceWithConnectionString)qdrantResource.Resource; 164var injectionAnnotation = builder.Resource.TryGetLastAnnotation<ReferenceEnvironmentInjectionAnnotation>(out var annotation) ? annotation : null; 172context.EnvironmentVariables[$"{connectionStringName}"] = qdrantResource.Resource.ConnectionStringExpression; 175context.EnvironmentVariables[$"{connectionStringName}_{QdrantServerResource.HttpEndpointName}"] = qdrantResource.Resource.HttpConnectionStringExpression;

24Assert.Equal("Aspire.Hosting.ApplicationModel.UserSecretsParameterDefault", qd.Resource.ApiKeyParameter.Default?.GetType().FullName); 34Assert.NotEqual("Aspire.Hosting.ApplicationModel.UserSecretsParameterDefault", qd.Resource.ApiKeyParameter.Default?.GetType().FullName); 158var connectionStringResource = qdrant.Resource as IResourceWithConnectionString; 179var config = await EnvironmentVariableEvaluator.GetEnvironmentVariablesAsync(projectA.Resource, DistributedApplicationOperation.Run, TestServiceProvider.Instance); 191var containerConfig = await EnvironmentVariableEvaluator.GetEnvironmentVariablesAsync(container1.Resource, DistributedApplicationOperation.Run, TestServiceProvider.Instance); 206var serverManifest = await ManifestUtils.GetManifest(qdrant.Resource); // using this method does not get any ExecutionContext.IsPublishMode changes 244var serverManifest = await ManifestUtils.GetManifest(qdrant.Resource); // using this method does not get any ExecutionContext.IsPublishMode changes

44[$"ConnectionStrings:{qdrant.Resource.Name}"] = await qdrant.Resource.ConnectionStringExpression.GetValueAsync(default) 47hb.AddQdrantClient(qdrant.Resource.Name); 129[$"ConnectionStrings:{qdrant1.Resource.Name}"] = await qdrant1.Resource.ConnectionStringExpression.GetValueAsync(default) 132hb.AddQdrantClient(qdrant1.Resource.Name); 174[$"ConnectionStrings:{qdrant2.Resource.Name}"] = await qdrant2.Resource.ConnectionStringExpression.GetValueAsync(default) 177hb.AddQdrantClient(qdrant2.Resource.Name); 242var urls = qdrant.Resource.Annotations.OfType<ResourceUrlAnnotation>(); 273await app.ResourceNotifications.WaitForResourceAsync(resource.Resource.Name, KnownResourceStates.Running, cts.Token); 275await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Waiting, cts.Token); 279await app.ResourceNotifications.WaitForResourceAsync(resource.Resource.Name, (re => re.Snapshot.HealthStatus == HealthStatus.Healthy), cts.Token); 281await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running, cts.Token);

39var passwordParameter = password?.Resource ?? ParameterResourceBuilderExtensions.CreateDefaultPasswordParameter(builder, $"{name}-password", special: false); 41var rabbitMq = new RabbitMQServerResource(name, userName?.Resource, passwordParameter); 155var containerAnnotations = builder.Resource.Annotations.OfType<ContainerImageAnnotation>().ToList(); 211throw new DistributedApplicationException($"Cannot configure the RabbitMQ resource '{builder.Resource.Name}' to enable the management plugin as it uses an unrecognized container image registry, name, or tag."); 265var nodeName = $"{builder.Resource.Name}@localhost";

20Assert.Equal("Aspire.Hosting.ApplicationModel.UserSecretsParameterDefault", rmq.Resource.PasswordParameter.Default?.GetType().FullName); 30Assert.NotEqual("Aspire.Hosting.ApplicationModel.UserSecretsParameterDefault", rmq.Resource.PasswordParameter.Default?.GetType().FullName); 207var manifest = await ManifestUtils.GetManifest(rabbit.Resource); 252var manifest = await ManifestUtils.GetManifest(rabbit.Resource); 276manifest = await ManifestUtils.GetManifest(rabbit.Resource); 300manifest = await ManifestUtils.GetManifest(rabbit.Resource);

42await app.ResourceNotifications.WaitForResourceAsync(resource.Resource.Name, KnownResourceStates.Running).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 44await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Waiting).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 48await app.ResourceNotifications.WaitForResourceHealthyAsync(resource.Resource.Name).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 50await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 70hb.Configuration[$"ConnectionStrings:{rabbitMQ.Resource.Name}"] = await rabbitMQ.Resource.ConnectionStringExpression.GetValueAsync(default); 71hb.AddRabbitMQClient(rabbitMQ.Resource.Name); 108var password = rabbitMQ1.Resource.PasswordParameter.Value; 133hb.Configuration[$"ConnectionStrings:{rabbitMQ1.Resource.Name}"] = await rabbitMQ1.Resource.ConnectionStringExpression.GetValueAsync(default); 135hb.AddRabbitMQClient(rabbitMQ1.Resource.Name); 190hb.Configuration[$"ConnectionStrings:{rabbitMQ2.Resource.Name}"] = await rabbitMQ2.Resource.ConnectionStringExpression.GetValueAsync(default); 192hb.AddRabbitMQClient(rabbitMQ2.Resource.Name);

68var passwordParameter = password?.Resource ?? ParameterResourceBuilderExtensions.CreateDefaultPasswordParameter(builder, $"{name}-password", special: false); 191resourceBuilder.WithRelationship(builder.Resource, "RedisCommander"); 252.WithRelationship(builder.Resource, "RedisInsight") 422builder.Resource.SetPassword(password?.Resource);

19Assert.Single(redis.Resource.Annotations, a => a is HealthCheckAnnotation hca && hca.Key == "redis_check"); 135var manifest = await ManifestUtils.GetManifest(redis.Resource); 169var manifest = await ManifestUtils.GetManifest(redis.Resource); 204var manifest = await ManifestUtils.GetManifest(redis.Resource); 239var manifest = await ManifestUtils.GetManifest(redis.Resource); 309Assert.Equal(redis1.Resource.Name, item.Value); 314Assert.Equal($"{redis1.Resource.PrimaryEndpoint.TargetPort!.Value}", item.Value); 319Assert.Equal(redis1.Resource.Name, item.Value); 325Assert.Equal(redis1.Resource.PasswordParameter!.Value, item.Value); 331Assert.Equal(redis2.Resource.Name, item.Value); 336Assert.Equal($"{redis2.Resource.PrimaryEndpoint.TargetPort!.Value}", item.Value); 341Assert.Equal(redis2.Resource.Name, item.Value); 347Assert.Equal(redis2.Resource.PasswordParameter!.Value, item.Value); 353Assert.Equal(redis3.Resource.Name, item.Value); 358Assert.Equal($"{redis3.Resource.PrimaryEndpoint.TargetPort!.Value}", item.Value); 363Assert.Equal(redis3.Resource.Name, item.Value); 504Assert.Equal($"myredis1:{redis.Resource.Name}:6379:0:{redis.Resource.PasswordParameter?.Value}", config["REDIS_HOSTS"]); 526Assert.Equal($"myredis1:{redis.Resource.Name}:6379:0:{password}", config["REDIS_HOSTS"]); 551Assert.Equal($"myredis1:{redis1.Resource.Name}:6379:0:{redis1.Resource.PasswordParameter?.Value},myredis2:myredis2:6379:0:{redis2.Resource.PasswordParameter?.Value}", config["REDIS_HOSTS"]); 572var volumeAnnotation = redis.Resource.Annotations.OfType<ContainerMountAnnotation>().Single(); 597var volumeAnnotation = redis.Resource.Annotations.OfType<ContainerMountAnnotation>().Single(); 667var args = await ArgumentEvaluator.GetArgumentListAsync(builder.Resource); 678Assert.True(redis.Resource.TryGetAnnotationsOfType<CommandLineArgsCallbackAnnotation>(out var argsAnnotations));

51await app.ResourceNotifications.WaitForResourceAsync(resource.Resource.Name, KnownResourceStates.Running, cts.Token); 53await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Waiting, cts.Token); 57await app.ResourceNotifications.WaitForResourceHealthyAsync(resource.Resource.Name, cts.Token); 59await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running, cts.Token); 80await app.WaitForTextAsync("Redis Connection", resourceName: commanderBuilder.Resource.Name); 82var client = app.CreateHttpClient(commanderBuilder.Resource.Name, "http"); 85var path = $"/apiv2/server/R:{redis.Resource.Name}:{endpoint.TargetPort}:0/info"; 106[$"ConnectionStrings:{redis.Resource.Name}"] = await redis.Resource.GetConnectionStringAsync() 109hb.AddRedisClient(redis.Resource.Name); 145await rns.WaitForResourceAsync(redisInsightBuilder.Resource.Name, KnownResourceStates.Running).WaitAsync(cts.Token); 147var client = app.CreateHttpClient(redisInsightBuilder.Resource.Name, "http"); 163Assert.Equal(redis1.Resource.Name, db.Name); 164Assert.Equal(redis1.Resource.Name, db.Host); 165Assert.Equal(redis1.Resource.PrimaryEndpoint.TargetPort, db.Port); 169Assert.Equal(redis2.Resource.Name, db.Name); 170Assert.Equal(redis2.Resource.Name, db.Host); 171Assert.Equal(redis2.Resource.PrimaryEndpoint.TargetPort, db.Port); 175Assert.Equal(redis3.Resource.Name, db.Name); 176Assert.Equal(redis3.Resource.Name, db.Host); 177Assert.Equal(redis3.Resource.PrimaryEndpoint.TargetPort, db.Port); 212[$"ConnectionStrings:{redis1.Resource.Name}"] = $"{await redis1.Resource.GetConnectionStringAsync()},allowAdmin=true" 215hb.AddRedisClient(redis1.Resource.Name); 248[$"ConnectionStrings:{redis2.Resource.Name}"] = await redis2.Resource.GetConnectionStringAsync() 251hb.AddRedisClient(redis2.Resource.Name); 295[$"ConnectionStrings:{redis1.Resource.Name}"] = $"{await redis1.Resource.GetConnectionStringAsync()},allowAdmin=true" 298hb.AddRedisClient(redis1.Resource.Name); 330[$"ConnectionStrings:{redis2.Resource.Name}"] = await redis2.Resource.GetConnectionStringAsync() 333hb.AddRedisClient(redis2.Resource.Name); 379[$"ConnectionStrings:{redis1.Resource.Name}"] = $"{await redis1.Resource.GetConnectionStringAsync()},allowAdmin=true" 382hb.AddRedisClient(redis1.Resource.Name); 409[$"ConnectionStrings:{redis2.Resource.Name}"] = await redis2.Resource.GetConnectionStringAsync() 412hb.AddRedisClient(redis2.Resource.Name); 477await rns.WaitForResourceAsync(redisInsightBuilder1.Resource.Name, KnownResourceStates.Running).WaitAsync(cts.Token); 481var httpClient = app.CreateHttpClient(redisInsightBuilder1.Resource.Name, "http"); 512await rns.WaitForResourceAsync(redisInsightBuilder2.Resource.Name, KnownResourceStates.Running).WaitAsync(cts.Token); 516var httpClient = app.CreateHttpClient(redisInsightBuilder2.Resource.Name, "http"); 615await app.ResourceNotifications.WaitForResourceHealthyAsync(redis.Resource.Name, cts.Token);

92var manifest = await ManifestUtils.GetManifest(seq.Resource); 133var volumeAnnotation = seq.Resource.Annotations.OfType<ContainerMountAnnotation>().Single(); 158var volumeAnnotation = seq.Resource.Annotations.OfType<ContainerMountAnnotation>().Single(); 253var manifest = await ManifestUtils.GetManifest(seq.Resource); 283var manifest = await ManifestUtils.GetManifest(seq.Resource);

26await app.WaitForTextAsync("Seq listening on", seq.Resource.Name); 28var seqUrl = await seq.Resource.ConnectionStringExpression.GetValueAsync(default); 35await app.ResourceNotifications.WaitForResourceHealthyAsync(seq.Resource.Name, default); 104await app.WaitForTextAsync("Seq listening on", seq1.Resource.Name); 108var seqUrl = await seq1.Resource.ConnectionStringExpression.GetValueAsync(default); 115await app.ResourceNotifications.WaitForResourceHealthyAsync(seq1.Resource.Name, default); 143await app.WaitForTextAsync("Seq listening on", seq2.Resource.Name); 147var seqUrl = await seq2.Resource.ConnectionStringExpression.GetValueAsync(default); 154await app.ResourceNotifications.WaitForResourceHealthyAsync(seq2.Resource.Name, default);

42var passwordParameter = password?.Resource ?? ParameterResourceBuilderExtensions.CreateDefaultPasswordParameter(builder, $"{name}-password", minLower: 1, minUpper: 1, minNumeric: 1); 120var sqlServerDatabase = new SqlServerDatabaseResource(name, databaseName, builder.Resource); 122builder.Resource.AddDatabase(sqlServerDatabase); 224builder.Resource.SetPassword(password.Resource);

21Assert.Equal("Aspire.Hosting.ApplicationModel.UserSecretsParameterDefault", sql.Resource.PasswordParameter.Default?.GetType().FullName); 31Assert.NotEqual("Aspire.Hosting.ApplicationModel.UserSecretsParameterDefault", sql.Resource.PasswordParameter.Default?.GetType().FullName); 129var serverManifest = await ManifestUtils.GetManifest(sqlServer.Resource); 130var dbManifest = await ManifestUtils.GetManifest(db.Resource); 170var serverManifest = await ManifestUtils.GetManifest(sqlServer.Resource); 227Assert.Equal("customers1", db1.Resource.DatabaseName); 228Assert.Equal("customers2", db2.Resource.DatabaseName); 230Assert.Equal("{sqlserver1.connectionString};Initial Catalog=customers1", db1.Resource.ConnectionStringExpression.ValueExpression); 231Assert.Equal("{sqlserver1.connectionString};Initial Catalog=customers2", db2.Resource.ConnectionStringExpression.ValueExpression); 245Assert.Equal("imports", db1.Resource.DatabaseName); 246Assert.Equal("imports", db2.Resource.DatabaseName); 248Assert.Equal("{sqlserver1.connectionString};Initial Catalog=imports", db1.Resource.ConnectionStringExpression.ValueExpression); 249Assert.Equal("{sqlserver2.connectionString};Initial Catalog=imports", db2.Resource.ConnectionStringExpression.ValueExpression);

43await app.ResourceNotifications.WaitForResourceAsync(resource.Resource.Name, KnownResourceStates.Running, cts.Token); 45await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Waiting, cts.Token); 49await app.ResourceNotifications.WaitForResourceHealthyAsync(resource.Resource.Name, cts.Token); 51await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running, cts.Token); 80hb.Configuration[$"ConnectionStrings:{newDb.Resource.Name}"] = await newDb.Resource.ConnectionStringExpression.GetValueAsync(default); 82hb.AddSqlServerDbContext<TestDbContext>(newDb.Resource.Name); 83hb.AddSqlServerClient(newDb.Resource.Name); 142var password = sqlserver1.Resource.PasswordParameter.Value; 180await app1.ResourceNotifications.WaitForResourceHealthyAsync(db1.Resource.Name, cts.Token); 188[$"ConnectionStrings:{db1.Resource.Name}"] = await db1.Resource.ConnectionStringExpression.GetValueAsync(default), 191hb1.AddSqlServerClient(db1.Resource.Name); 265await app2.ResourceNotifications.WaitForResourceHealthyAsync(db2.Resource.Name, cts.Token); 273[$"ConnectionStrings:{db2.Resource.Name}"] = await db2.Resource.ConnectionStringExpression.GetValueAsync(default), 276hb2.AddSqlServerClient(db2.Resource.Name); 369hb.Configuration[$"ConnectionStrings:{newDb.Resource.Name}"] = await newDb.Resource.ConnectionStringExpression.GetValueAsync(default); 371hb.AddSqlServerClient(newDb.Resource.Name); 377await app.ResourceNotifications.WaitForResourceHealthyAsync(newDb.Resource.Name, cts.Token); 422hb.Configuration[$"ConnectionStrings:{newDb.Resource.Name}"] = await newDb.Resource.ConnectionStringExpression.GetValueAsync(default); 424hb.AddSqlServerClient(newDb.Resource.Name); 430await app.ResourceNotifications.WaitForResourceHealthyAsync(newDb.Resource.Name, cts.Token); 494hb.Configuration[$"ConnectionStrings:{newDb.Resource.Name}"] = await newDb.Resource.ConnectionStringExpression.GetValueAsync(default); 496hb.AddSqlServerClient(newDb.Resource.Name); 502await app.ResourceNotifications.WaitForResourceHealthyAsync(sqlserver.Resource.Name, cts.Token); 554hb.Configuration[$"ConnectionStrings:{db.Resource.Name}"] = await db.Resource.ConnectionStringExpression.GetValueAsync(default); 555hb.AddKeyedSqlServerClient(db.Resource.Name); 564await app.ResourceNotifications.WaitForResourceHealthyAsync(db.Resource.Name, cts.Token); 566var conn = host.Services.GetRequiredKeyedService<SqlConnection>(db.Resource.Name);

36await rns.WaitForResourceHealthyAsync(resource.Resource.Name, cancellationToken);

81cs.Resource.TryGetAnnotationsOfType<WaitAnnotation>(out var waitAnnotations); 88Assert.Same(redis.Resource, wa.Resource); 93Assert.Same(key.Resource, wa.Resource);

53parameter.Resource.Default = new TestParameterDefault("DefaultValue"); 251Assert.IsType<UserSecretsParameterDefault>(parameter1.Resource.Default); 255Assert.IsType<GenerateParameterDefault>(parameter2.Resource.Default); 351Assert.Equal("This is a test parameter", parameter.Resource.Description); 352Assert.False(parameter.Resource.EnableDescriptionMarkdown); 366Assert.Equal("This is a **markdown** description", parameter.Resource.Description); 367Assert.True(parameter.Resource.EnableDescriptionMarkdown); 390Assert.Equal("Custom input parameter", parameter.Resource.Description); 391Assert.True(parameter.Resource.Annotations.OfType<InputGeneratorAnnotation>().Any()); 403var input = parameter.Resource.CreateInput(); 422var input = parameter.Resource.CreateInput(); 450var input = parameter.Resource.CreateInput(); 469var input = parameter.Resource.CreateInput(); 494Assert.True(parameter.Resource.Annotations.OfType<InputGeneratorAnnotation>().Any()); 496var input = parameter.Resource.CreateInput();

26var callbackAnnotation = container.Resource.Annotations.OfType<DockerfileBuilderCallbackAnnotation>().LastOrDefault(); 50var callbackAnnotation = container.Resource.Annotations.OfType<DockerfileBuilderCallbackAnnotation>().LastOrDefault(); 69var buildAnnotation = container.Resource.Annotations.OfType<DockerfileBuildAnnotation>().LastOrDefault(); 90var buildAnnotation = container.Resource.Annotations.OfType<DockerfileBuildAnnotation>().LastOrDefault(); 97Resource = container.Resource, 142var buildAnnotation = container.Resource.Annotations.OfType<DockerfileBuildAnnotation>().LastOrDefault(); 148Resource = container.Resource, 178var buildAnnotation = container.Resource.Annotations.OfType<DockerfileBuildAnnotation>().LastOrDefault(); 184Resource = container.Resource, 212var buildAnnotation = container.Resource.Annotations.OfType<DockerfileBuildAnnotation>().LastOrDefault(); 218Resource = container.Resource, 253var buildAnnotation = container.Resource.Annotations.OfType<DockerfileBuildAnnotation>().LastOrDefault(); 259Resource = container.Resource, 288Assert.Equal("mycontainer", container.Resource.Name); 289var callbackAnnotation = container.Resource.Annotations.OfType<DockerfileBuilderCallbackAnnotation>().LastOrDefault(); 309Assert.Equal("mycontainer", container.Resource.Name); 310var callbackAnnotation = container.Resource.Annotations.OfType<DockerfileBuilderCallbackAnnotation>().LastOrDefault(); 332var buildAnnotation = container.Resource.Annotations.OfType<DockerfileBuildAnnotation>().LastOrDefault(); 339Resource = container.Resource, 368var buildAnnotation = container.Resource.Annotations.OfType<DockerfileBuildAnnotation>().LastOrDefault(); 375Resource = container.Resource, 400var buildAnnotation = container.Resource.Annotations.OfType<DockerfileBuildAnnotation>().LastOrDefault(); 434var buildAnnotation = container.Resource.Annotations.OfType<DockerfileBuildAnnotation>().LastOrDefault(); 440Resource = container.Resource, 470var envAnnotation = container.Resource.Annotations.OfType<EnvironmentAnnotation>().FirstOrDefault(); 472var endpointAnnotation = container.Resource.Annotations.OfType<EndpointAnnotation>().FirstOrDefault();

34var httpEndpoints = testProgram.ServiceABuilder.Resource.Annotations.OfType<EndpointAnnotation>().Where(sb => sb.UriScheme == "http" || sb.UriScheme == "https"); 49var endpoints = testProgram.ServiceABuilder.Resource.Annotations.OfType<EndpointAnnotation>();

72await app.ResourceNotifications.PublishUpdateAsync(resource.Resource, s => s with 80resource.Resource.Name,

113Assert.Same(container.Resource, dashboard); 215Assert.Same(container.Resource, dashboard);

60.WithReplicas(2).Resource; 186}).Resource; 1176HasKnownCommandAnnotations(exe.Resource); 1177HasKnownCommandAnnotations(container.Resource); 1178HasKnownCommandAnnotations(project.Resource);

33Assert.Same(originalRedis.Resource, newRedisBuilder.Resource); 42Assert.Same(originalRedis.Resource, newRedisBuilder.Resource); 74Assert.Same(originalRedis.Resource, newRedisBuilder.Resource); 85Assert.Same(originalRedis.Resource, newRedisBuilder.Resource);

31item => Assert.Equal(container1.Resource, item), 32item => Assert.Equal(container2.Resource, item), 33item => Assert.Equal(project.Resource, item), 34item => Assert.Equal(emulator.Resource, item));

494using var clientA = app.CreateHttpClient(testProgram.ServiceABuilder.Resource.Name, "http"); 495using var clientC = app.CreateHttpClient(testProgram.ServiceCBuilder.Resource.Name, "http"); 502var uri = app.GetEndpoint(testProgram.ServiceBBuilder.Resource.Name, "http"); 860var dependentRunningResourceEvent = await rns.WaitForResourceAsync(container.Resource.Name, e => e.Snapshot.State?.Text == KnownResourceStates.Running).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 1396await app.WaitForTextAsync("Content root path:", resourceName: testProgram.ServiceABuilder.Resource.Name).DefaultTimeout(TestConstants.LongTimeoutDuration); 1399var httpEndPoint = app.GetEndpoint(testProgram.ServiceABuilder.Resource.Name, endpointName: "http"); 1417var httpsEndpoint = app.GetEndpoint(testProgram.ServiceABuilder.Resource.Name, endpointName: "https"); 1465using var clientA = app.CreateHttpClient(servicea.Resource.Name, "http"); 1474Assert.Equal($"localhost:1234,password={redis.Resource.PasswordParameter?.Value}", env.Value); 1483Assert.Equal($"localhost:6379,password={redisNoPort.Resource.PasswordParameter?.Value}", otherRedisEnv.Value); 1519using var clientA = app.CreateHttpClient(servicea.Resource.Name, "http"); 1532Assert.Equal($"localhost:1234,password={redis.Resource.PasswordParameter!.Value}", env.Value); 1541Assert.Equal($"localhost:6379,password={redisNoPort.Resource.PasswordParameter!.Value}", otherRedisEnv.Value);

301var testResourceEvent = new ResourceEvent(resource.Resource, "test-resource", testSnapshot); 302var testEvent = new ResourceStoppedEvent(resource.Resource, app.Services, testResourceEvent); 306Assert.Equal(resource.Resource, resourceStopped);

23var annotation = executable.Resource.Annotations.OfType<ExecutableAnnotation>().Single(); 34var annotation = executable.Resource.Annotations.OfType<ExecutableAnnotation>().Single(); 49var annotation = executable.Resource.Annotations.OfType<ExecutableAnnotation>().Single(); 70var annotation = executable.Resource.Annotations.OfType<ExecutableAnnotation>().Single(); 82var annotation = executable.Resource.Annotations.OfType<SupportsDebuggingAnnotation>().SingleOrDefault(); 100var annotation = executable.Resource.Annotations.OfType<SupportsDebuggingAnnotation>().SingleOrDefault();

44var args = await ArgumentEvaluator.GetArgumentListAsync(exe2.Resource).DefaultTimeout(); 57Assert.True(exe2.Resource.TryGetAnnotationsOfType<ResourceRelationshipAnnotation>(out var relationships)); 67var manifest = await ManifestUtils.GetManifest(exe2.Resource).DefaultTimeout();

131var csRef = new ConnectionStringReference(target.Resource, false); 147var config = await EnvironmentVariableEvaluator.GetEnvironmentVariablesAsync(source.Resource, DistributedApplicationOperation.Run, TestServiceProvider.Instance).DefaultTimeout(); 185var config = await EnvironmentVariableEvaluator.GetEnvironmentVariablesAsync(test.Resource, DistributedApplicationOperation.Run, testServiceProvider).DefaultTimeout(); 210var config = await EnvironmentVariableEvaluator.GetEnvironmentVariablesAsync(test.Resource, DistributedApplicationOperation.Run, testServiceProvider).DefaultTimeout(); 231var config = await EnvironmentVariableEvaluator.GetEnvironmentVariablesAsync(dep.Resource, DistributedApplicationOperation.Run, TestServiceProvider.Instance).DefaultTimeout();

21Assert.Equal("nuget", externalService.Resource.Name); 22Assert.Equal("https://nuget.org/", externalService.Resource.Uri?.ToString()); 23Assert.Null(externalService.Resource.UrlParameter); 34Assert.Equal("nuget", externalService.Resource.Name); 35Assert.Equal("https://nuget.org/", externalService.Resource.Uri?.ToString()); 36Assert.Null(externalService.Resource.UrlParameter); 47Assert.Equal("nuget", externalService.Resource.Name); 48Assert.Null(externalService.Resource.Uri); 49Assert.NotNull(externalService.Resource.UrlParameter); 50Assert.Equal("nuget-url", externalService.Resource.UrlParameter.Name); 97Assert.Equal("nuget", externalService.Resource.Name); 98Assert.Equal(validUrl, externalService.Resource.Uri?.ToString()); 111var config = await EnvironmentVariableEvaluator.GetEnvironmentVariablesAsync(project.Resource, DistributedApplicationOperation.Run, TestServiceProvider.Instance).DefaultTimeout(); 128var config = await EnvironmentVariableEvaluator.GetEnvironmentVariablesAsync(project.Resource, DistributedApplicationOperation.Run, TestServiceProvider.Instance).DefaultTimeout(); 147var config = await EnvironmentVariableEvaluator.GetEnvironmentVariablesAsync(project.Resource, DistributedApplicationOperation.Run, TestServiceProvider.Instance).DefaultTimeout(); 167var config = await EnvironmentVariableEvaluator.GetEnvironmentVariablesAsync(project.Resource, DistributedApplicationOperation.Publish, app.Services).DefaultTimeout(); 172Assert.Equal(urlParam.Resource.ValueExpression, urlValue); 190await EnvironmentVariableEvaluator.GetEnvironmentVariablesAsync(project.Resource, DistributedApplicationOperation.Run, TestServiceProvider.Instance).DefaultTimeout(); 206Assert.True(externalService.Resource.TryGetAnnotationsOfType<HealthCheckAnnotation>(out var healthCheckAnnotations)); 207Assert.NotNull(healthCheckAnnotations.FirstOrDefault(hc => hc.Key.StartsWith($"{externalService.Resource.Name}_external"))); 222Assert.True(externalService.Resource.TryGetAnnotationsOfType<HealthCheckAnnotation>(out var healthCheckAnnotations)); 223Assert.NotNull(healthCheckAnnotations.FirstOrDefault(hc => hc.Key.StartsWith($"{externalService.Resource.Name}_external"))); 245Assert.True(externalService.Resource.TryGetAnnotationsOfType<ResourceSnapshotAnnotation>(out var snapshotAnnotations)); 259Assert.True(externalService.Resource.TryGetAnnotationsOfType<ManifestPublishingCallbackAnnotation>(out var manifestAnnotations)); 299externalService.Resource.Name, 326externalService.Resource.Name, 353externalService.Resource.Name, 377Assert.True(externalService.Resource.TryGetAnnotationsOfType<HealthCheckAnnotation>(out var healthCheckAnnotations)); 378var healthCheckAnnotation = healthCheckAnnotations.FirstOrDefault(hc => hc.Key.StartsWith($"{externalService.Resource.Name}_external")); 398Assert.True(externalService.Resource.TryGetAnnotationsOfType<HealthCheckAnnotation>(out var healthCheckAnnotations)); 399var healthCheckAnnotation = healthCheckAnnotations.FirstOrDefault(hc => hc.Key.StartsWith($"{externalService.Resource.Name}_external")); 423Assert.True(externalService.Resource.TryGetAnnotationsOfType<HealthCheckAnnotation>(out var healthCheckAnnotations)); 424var healthCheckKey = healthCheckAnnotations.First(hc => hc.Key.StartsWith($"{externalService.Resource.Name}_external")).Key; 448var manifest = await ManifestUtils.GetManifest(project.Resource);

32await app.ResourceNotifications.PublishUpdateAsync(resource.Resource, s => s with 40await app.ResourceNotifications.PublishUpdateAsync(resource.Resource, s => s with 72await app.ResourceNotifications.PublishUpdateAsync(resource.Resource, s => s with 80await app.ResourceNotifications.PublishUpdateAsync(resource.Resource, s => s with 115await app.ResourceNotifications.PublishUpdateAsync(resource.Resource, s => s with 123await app.ResourceNotifications.PublishUpdateAsync(resource.Resource, s => s with 162await app.ResourceNotifications.PublishUpdateAsync(resource.Resource, s => s with 171Assert.Equal(resource.Resource, e1.Resource); 177await app.ResourceNotifications.PublishUpdateAsync(resource.Resource, s => s with 185await app.ResourceNotifications.PublishUpdateAsync(resource.Resource, s => s with 199Assert.Equal(resource.Resource, e2.Resource); 228await app.ResourceNotifications.PublishUpdateAsync(resource.Resource, s => s with 232await app.ResourceNotifications.WaitForResourceHealthyAsync(resource.Resource.Name, abortTokenSource.Token).DefaultTimeout(); 269await app.ResourceNotifications.PublishUpdateAsync(resource.Resource, s => s with 312await app.ResourceNotifications.PublishUpdateAsync(resource.Resource, s => s with 316await app.ResourceNotifications.WaitForResourceAsync(resource.Resource.Name, KnownResourceStates.Running, abortTokenSource.Token).DefaultTimeout(); 348await app.ResourceNotifications.PublishUpdateAsync(resource.Resource, s => s with 354Assert.Equal(resource.Resource, @event.Resource); 379await app.ResourceNotifications.PublishUpdateAsync(resource.Resource, s => s with 441await app.ResourceNotifications.PublishUpdateAsync(parent.Resource, s => s with 486await app.ResourceNotifications.PublishUpdateAsync(parent.Resource, s => s with 526var child = builder.AddResource(new ChildResource("child", parent.Resource)) 537await app.ResourceNotifications.PublishUpdateAsync(parent.Resource, s => s with 545await app.ResourceNotifications.PublishUpdateAsync(child.Resource, s => s with 551Assert.Equal(parentReadyEvent.Resource, parent.Resource); 554Assert.Equal(childReadyEvent.Resource, child.Resource); 581await app.ResourceNotifications.PublishUpdateAsync(resource.Resource, s => s with 589await app.ResourceNotifications.PublishUpdateAsync(resource.Resource, s => s with 627await app.ResourceNotifications.PublishUpdateAsync(resource.Resource, s => s with 635await app.ResourceNotifications.PublishUpdateAsync(resource.Resource, s => s with

103await rns.WaitForResourceAsync(resource.Resource.Name, KnownResourceStates.Running).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 105await rns.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Waiting).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 109await rns.WaitForResourceHealthyAsync(resource.Resource.Name).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 111await rns.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout);

103var redisManifest = await ManifestUtils.GetManifest(redis.Resource).DefaultTimeout(); 514param.Resource.Default = new GenerateParameterDefault() 552var manifest = await ManifestUtils.GetManifest(param.Resource).DefaultTimeout(); 572Source = sourceContainer.Resource, 578var destManifest = await ManifestUtils.GetManifest(destContainer.Resource).DefaultTimeout(); 615Source = sourceContainer.Resource, 621var destManifest = await ManifestUtils.GetManifest(destContainer.Resource).DefaultTimeout(); 661Source = source1.Resource, 666Source = source2.Resource, 672var destManifest = await ManifestUtils.GetManifest(destContainer.Resource).DefaultTimeout();

31var childResource = builder.AddResource(new CustomChildResource("child", parentResource.Resource)); 48if (item.Resource == parentResource.Resource) 52else if (item.Resource == childResource.Resource) 95if (item.Resource == parentResource.Resource) 99else if (item.Resource == childResource.Resource) 141applicationEventing.Subscribe<InitializeResourceEvent>(resource.Resource, (@event, ct) => 159Assert.Equal(resource.Resource, initEvent.Resource); 193if (item.Resource == parent.Resource) 197else if (item.Resource == child.Resource) 202else if (item.Resource == nestedChild.Resource) 206else if (item.Resource == child2.Resource) 258if (item.Resource == firstParent.Resource) 262else if (item.Resource == secondParent.Resource) 266else if (item.Resource == child.Resource) 309if (item.Resource == projectA.Resource) 313else if (item.Resource == projectB.Resource) 358new ChildResourceWithConnectionString("child", new Dictionary<string, string> { { "Namespace", "ns" } }, parentResource.Resource) 361new ChildResourceWithConnectionString("grand-child", new Dictionary<string, string> { { "Database", "db" } }, childResource.Resource) 378applicationEventing.Subscribe<ConnectionStringAvailableEvent>(parentResource.Resource, (_, _) => 383applicationEventing.Subscribe<ConnectionStringAvailableEvent>(childResource.Resource, (_, _) => 388applicationEventing.Subscribe<ConnectionStringAvailableEvent>(grandChildResource.Resource, (_, _) => 394await events.PublishAsync(new OnResourceStartingContext(CancellationToken.None, KnownResourceTypes.Container, parentResource.Resource, parentResource.Resource.Name)); 424if (item.Resource == resource.Resource) 438await applicationEventing.PublishAsync(new ConnectionStringAvailableEvent(resource.Resource, app.Services), CancellationToken.None); 585var customChild = builder.AddResource(new CustomChildResource("custom-child", parentContainer.Resource)); 603parentContainer.Resource, 610var childContainerState = resourceNotificationService.TryGetCurrentState(childContainer.Resource.Name, out var childContainerEvent) ? childContainerEvent.Snapshot.State?.Text : null; 611var customChildState = resourceNotificationService.TryGetCurrentState(customChild.Resource.Name, out var customChildEvent) ? customChildEvent.Snapshot.State?.Text : null; 631var customChild = builder.AddResource(new CustomChildResource("custom-child", parentContainer.Resource)); 649parentContainer.Resource, 656var childProjectState = resourceNotificationService.TryGetCurrentState(childProject.Resource.Name, out var childProjectEvent) ? childProjectEvent.Snapshot.State?.Text : null; 657var customChildState = resourceNotificationService.TryGetCurrentState(customChild.Resource.Name, out var customChildEvent) ? customChildEvent.Snapshot.State?.Text : null; 697if (item.Resource == parent.Resource) 701else if (item.Resource == child.Resource) 705else if (item.Resource == child2.Resource) 734parent.WithChildRelationship(child.Resource) 735.WithChildRelationship(child2.Resource); 753if (item.Resource == parent.Resource) 757else if (item.Resource == child.Resource) 761else if (item.Resource == child2.Resource) 806if (item.Resource == parentProject.Resource) 810else if (item.Resource == childProject.Resource)

17var childResource = builder.AddResource(new CustomChildResource("child", parentResource.Resource)); 18var grandChildResource = builder.AddResource(new CustomChildResource("grandchild", childResource.Resource)); 19var greatGrandChildResource = builder.AddResource(new CustomChildResource("greatgrandchild", grandChildResource.Resource)); 33Assert.Collection(parentChildLookup[parentResource.Resource], 34x => Assert.Equal(childResource.Resource, x), 35x => Assert.Equal(childWithAnnotationsResource.Resource, x)); 37Assert.Single(parentChildLookup[childResource.Resource], grandChildResource.Resource); 38Assert.Single(parentChildLookup[grandChildResource.Resource], greatGrandChildResource.Resource); 40Assert.Empty(parentChildLookup[greatGrandChildResource.Resource]); 42Assert.Single(parentChildLookup[childWithAnnotationsResource.Resource], grandChildWithAnnotationsResource.Resource); 44Assert.Empty(parentChildLookup[grandChildWithAnnotationsResource.Resource]); 65Assert.Collection(parentChildLookup[parentResource.Resource], 66x => Assert.Equal(child1Resource.Resource, x), 67x => Assert.Equal(child2Resource.Resource, x)); 79parentResource.WithChildRelationship(child1Resource.Resource) 80.WithChildRelationship(child2Resource.Resource); 88Assert.Collection(parentChildLookup[parentResource.Resource], 89x => Assert.Equal(child1Resource.Resource, x), 90x => Assert.Equal(child2Resource.Resource, x)); 111Assert.Collection(parentChildLookup[parentResource.Resource], 112x => Assert.Equal(child1Resource.Resource, x), 113x => Assert.Equal(child2Resource.Resource, x)); 134Assert.Single(parentChildLookup[grandParentResource.Resource], parentResource.Resource); 135Assert.Single(parentChildLookup[parentResource.Resource], childResource.Resource);

612var args = await ArgumentEvaluator.GetArgumentListAsync(project.Resource).DefaultTimeout(); 620Assert.False(project.Resource.TryGetAnnotationsOfType<ResourceRelationshipAnnotation>(out var relationships)); 799Assert.Equal(sourceContainer.Resource, containerFilesAnnotation.Source);

18Assert.True(redis.Resource.TryGetLastAnnotation<ManifestPublishingCallbackAnnotation>(out _)); 20var manifest = await ManifestUtils.GetManifest(redis.Resource).DefaultTimeout();

28var manifest = await ManifestUtils.GetManifest(frontend.Resource, manifestDirectory: path).DefaultTimeout(); 74var manifest = await ManifestUtils.GetManifest(frontend.Resource, manifestDirectory: path).DefaultTimeout(); 123var manifest = await ManifestUtils.GetManifest(frontend.Resource, manifestDirectory: path).DefaultTimeout(); 172var manifest = await ManifestUtils.GetManifest(frontend.Resource, manifestDirectory: path).DefaultTimeout(); 232var manifest = await ManifestUtils.GetManifest(project.Resource, manifestDirectory: path).DefaultTimeout();

37await imageBuilder.BuildImageAsync(servicea.Resource, options: null, cts.Token); 69await imageBuilder.BuildImageAsync(servicea.Resource, options: null, cts.Token); 101await imageBuilder.BuildImageAsync(servicea.Resource, options: null, cts.Token); 139await imageBuilder.BuildImageAsync(servicea.Resource, options, cts.Token); 177await imageBuilder.BuildImageAsync(servicea.Resource, options, cts.Token); 211await imageBuilder.BuildImageAsync(servicea.Resource, options, cts.Token); 249await imageBuilder.BuildImageAsync(container.Resource, options, cts.Token); 290await imageBuilder.BuildImageAsync(container.Resource, options, cts.Token); 329await imageBuilder.BuildImageAsync(servicea.Resource, options, cts.Token); 365await imageBuilder.BuildImageAsync(servicea.Resource, options, cts.Token); 396await imageBuilder.BuildImageAsync(servicea.Resource, options: null, cts.Token); 447await imageBuilder.BuildImageAsync(servicea.Resource, options: null, cts.Token); 575await imageBuilder.BuildImagesAsync([servicea.Resource], options: options, cts.Token); 604await imageBuilder.BuildImagesAsync([dockerfileResource.Resource], options: null, cts.Token); 636await imageBuilder.BuildImagesAsync([dockerfileResource.Resource], options: null, cts.Token); 674imageBuilder.BuildImagesAsync([container.Resource], options: null, cts.Token)); 718await imageBuilder.BuildImageAsync(container.Resource, options: null, cts.Token); 790await imageBuilder.BuildImageAsync(container.Resource, options: null, cts.Token); 885await imageBuilder.BuildImageAsync(container.Resource, options: null, cts.Token);

49resourceBuilder.Resource.AddLifeCycleCommands(); 51var startCommand = resourceBuilder.Resource.Annotations.OfType<ResourceCommandAnnotation>().Single(a => a.Name == commandName);

67var result = await app.ResourceCommands.ExecuteCommandAsync(custom.Resource, "NotFound"); 104var resolvedResourceNames = custom.Resource.GetResolvedResourceNames().ToList(); 135var result = await app.ResourceCommands.ExecuteCommandAsync(resourceBuilder.Resource, "mycommand"); 141var resolvedResourceNames = resourceBuilder.Resource.GetResolvedResourceNames().ToList(); 148foreach (var resourceName in resourceBuilder.Resource.GetResolvedResourceNames()) 150var r = await app.ResourceCommands.ExecuteCommandAsync(resourceBuilder.Resource, "mycommand"); 178var result = await app.ResourceCommands.ExecuteCommandAsync(resourceBuilder.Resource, "mycommand"); 183var resourceNames = resourceBuilder.Resource.GetResolvedResourceNames(); 209var result = await app.ResourceCommands.ExecuteCommandAsync(custom.Resource, "mycommand"); 237var result = await app.ResourceCommands.ExecuteCommandAsync(resourceBuilder.Resource, "mycommand"); 272var result = await app.ResourceCommands.ExecuteCommandAsync(resourceBuilder.Resource, "mycommand"); 278var resourceNames = resourceBuilder.Resource.GetResolvedResourceNames(); 315var result = await app.ResourceCommands.ExecuteCommandAsync(custom.Resource, "mycommand");

20Assert.False(parent.Resource.HasAnnotationOfType<DummyAnnotation>()); 21Assert.False(parent.Resource.TryGetAnnotationsOfType<DummyAnnotation>(out var annotations)); 32Assert.False(parent.Resource.HasAnnotationOfType<DummyAnnotation>()); 33Assert.False(parent.Resource.TryGetAnnotationsOfType<DummyAnnotation>(out var annotations)); 44Assert.True(parent.Resource.HasAnnotationOfType<DummyAnnotation>()); 45Assert.True(parent.Resource.TryGetAnnotationsOfType<DummyAnnotation>(out var annotations)); 56Assert.True(parent.Resource.HasAnnotationIncludingAncestorsOfType<DummyAnnotation>()); 57Assert.True(parent.Resource.TryGetAnnotationsIncludingAncestorsOfType<DummyAnnotation>(out var annotations)); 67Assert.False(parent.Resource.HasAnnotationIncludingAncestorsOfType<DummyAnnotation>()); 68Assert.False(parent.Resource.TryGetAnnotationsIncludingAncestorsOfType<DummyAnnotation>(out var annotations)); 79Assert.False(parent.Resource.HasAnnotationIncludingAncestorsOfType<DummyAnnotation>()); 80Assert.False(parent.Resource.TryGetAnnotationsIncludingAncestorsOfType<DummyAnnotation>(out var annotations)); 91var child = builder.AddResource(new ChildResource("child", parent.Resource)) 94Assert.False(parent.Resource.HasAnnotationIncludingAncestorsOfType<DummyAnnotation>()); 95Assert.False(child.Resource.TryGetAnnotationsIncludingAncestorsOfType<DummyAnnotation>(out var annotations)); 106var child = builder.AddResource(new ChildResource("child", parent.Resource)); 108Assert.True(parent.Resource.HasAnnotationIncludingAncestorsOfType<DummyAnnotation>()); 109Assert.True(child.Resource.TryGetAnnotationsIncludingAncestorsOfType<DummyAnnotation>(out var annotations)); 120var child = builder.AddResource(new ChildResource("child", parent.Resource)) 123Assert.True(parent.Resource.HasAnnotationIncludingAncestorsOfType<DummyAnnotation>()); 124Assert.True(child.Resource.TryGetAnnotationsIncludingAncestorsOfType<DummyAnnotation>(out var annotations)); 135var child = builder.AddResource(new ChildResource("child", parent: parent.Resource)) 138var grandchild = builder.AddResource(new ChildResource("grandchild", parent: child.Resource)) 141Assert.True(parent.Resource.HasAnnotationIncludingAncestorsOfType<DummyAnnotation>()); 142Assert.True(grandchild.Resource.TryGetAnnotationsIncludingAncestorsOfType<DummyAnnotation>(out var annotations)); 152Assert.True(container.Resource.TryGetContainerImageName(out var imageName)); 162Assert.True(container.Resource.TryGetContainerImageName(out var imageName)); 180var env = await container.Resource.GetEnvironmentVariableValuesAsync().DefaultTimeout(); 213var env = await container.Resource.GetEnvironmentVariableValuesAsync().DefaultTimeout(); 246var env = await container.Resource.GetEnvironmentVariableValuesAsync(DistributedApplicationOperation.Publish).DefaultTimeout(); 278.Resource.GetArgumentValuesAsync().DefaultTimeout(); 290.Resource.GetArgumentValuesAsync().DefaultTimeout(); 306.WithAnnotation(new DeploymentTargetAnnotation(compute1.Resource) { ComputeEnvironment = compute1.Resource }) 307.WithAnnotation(new DeploymentTargetAnnotation(compute2.Resource) { ComputeEnvironment = compute2.Resource }); 309var ex = Assert.Throws<InvalidOperationException>(() => resourceBuilder.Resource.GetDeploymentTargetAnnotation()); 314Assert.Equal(compute2.Resource, resourceBuilder.Resource.GetDeploymentTargetAnnotation()!.ComputeEnvironment); 330var annotation = Assert.Single(containerResource.Resource.Annotations.OfType<DeploymentImageTagCallbackAnnotation>()); 335Resource = containerResource.Resource, 371var annotations = containerResource.Resource.Annotations.OfType<DeploymentImageTagCallbackAnnotation>().ToList(); 376Resource = containerResource.Resource, 393Assert.Single(containerResource.Resource.Annotations.OfType<DeploymentImageTagCallbackAnnotation>()); 398Assert.Single(projectResource.Resource.Annotations.OfType<DeploymentImageTagCallbackAnnotation>()); 403Assert.Single(executableResource.Resource.Annotations.OfType<DeploymentImageTagCallbackAnnotation>()); 415var annotation = Assert.Single(containerResource.Resource.Annotations.OfType<DeploymentImageTagCallbackAnnotation>()); 419Resource = containerResource.Resource, 442var annotation = Assert.Single(containerResource.Resource.Annotations.OfType<DeploymentImageTagCallbackAnnotation>()); 448Resource = containerResource.Resource, 463Assert.Collection(resource.Resource.Annotations.OfType<ContainerFilesSourceAnnotation>(), 471var annotation = Assert.Single(resource.Resource.Annotations.OfType<ContainerFilesSourceAnnotation>()); 475Assert.Collection(resource.Resource.Annotations.OfType<ContainerFilesSourceAnnotation>(),

28var annotation = custom.Resource.Annotations.OfType<ResourceSnapshotAnnotation>().SingleOrDefault();

18var annotations = resource.Resource.Annotations.OfType<ProbeAnnotation>().ToArray(); 32var annotations = resource.Resource.Annotations.OfType<ProbeAnnotation>().ToArray(); 52var annotations = resource.Resource.Annotations.OfType<ProbeAnnotation>().ToArray();

35using var clientA = app.CreateHttpClientWithResilience(testProgram.ServiceABuilder.Resource.Name, "http"); 38using var clientB = app.CreateHttpClientWithResilience(testProgram.ServiceBBuilder.Resource.Name, "http"); 41using var clientC = app.CreateHttpClientWithResilience(testProgram.ServiceCBuilder.Resource.Name, "http"); 58var endpoint = projectBuilders.Resource.Annotations.OfType<EndpointAnnotation>().Single(); 77var endpoint = projectBuilders.Resource.Annotations.OfType<EndpointAnnotation>().Single();

68using var clientA = App.CreateHttpClientWithResilience(TestProgram.ServiceABuilder.Resource.Name, "http"); 72using var clientB = App.CreateHttpClientWithResilience(TestProgram.ServiceBBuilder.Resource.Name, "http"); 76using var clientC = App.CreateHttpClientWithResilience(TestProgram.ServiceCBuilder.Resource.Name, "http");

36await rns.WaitForResourceHealthyAsync(resource.Resource.Name, cancellationToken);

24Assert.Equal($"{volumePrefix}-{resource.Resource.Name}-data", volumeName); 68Assert.Equal($"{runVolumePrefix}-{runResource.Resource.Name}-data", runVolumeName); 69Assert.Equal($"{publishVolumePrefix}-{publishResource.Resource.Name}-data", publishVolumeName);

16var dummyAnnotations = redis.Resource.Annotations.OfType<DummyAnnotation>(); 30var dummyAnnotations = redis.Resource.Annotations.OfType<DummyAnnotation>(); 42var firstAnnotation = redis.Resource.Annotations.OfType<DummyAnnotation>().Single(); 46var secondAnnotation = redis.Resource.Annotations.OfType<DummyAnnotation>().Single();

33await app.ResourceNotifications.WaitForResourceAsync(throwingResource.Resource.Name, KnownResourceStates.FailedToStart, abortCts.Token); 34await app.ResourceNotifications.WaitForResourceAsync(dependingContainerResource.Resource.Name, KnownResourceStates.FailedToStart, abortCts.Token); 35await app.ResourceNotifications.WaitForResourceAsync(dependingExecutableResource.Resource.Name, KnownResourceStates.FailedToStart, abortCts.Token); 66var childResourceBuilder = builder.AddResource(new CustomChildResource("child", parentResourceBuilder.Resource)); 108await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name, KnownResourceStates.Waiting, waitingStateCts.Token); 110await app.ResourceNotifications.PublishUpdateAsync(dependency.Resource, s => s with 139await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name, KnownResourceStates.Waiting, waitingStateCts.Token); 141await app.ResourceNotifications.PublishUpdateAsync(dependency.Resource, s => s with 176await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name, KnownResourceStates.Waiting, waitingStateCts.Token); 181await app.ResourceNotifications.PublishUpdateAsync(dependency.Resource, s => s with 217await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name, KnownResourceStates.Waiting, waitingStateCts.Token); 219await app.ResourceNotifications.PublishUpdateAsync(dependency.Resource, s => s with 224await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name, KnownResourceStates.FailedToStart, waitingStateCts.Token); 245dependency.Resource.Name, 269dependency.Resource.Name, 299await app.ResourceNotifications.WaitForResourceHealthyAsync(dependency.Resource.Name) 328await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name, KnownResourceStates.Waiting, waitingStateCts.Token); 330await app.ResourceNotifications.PublishUpdateAsync(dependency.Resource, s => s with 335await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name, KnownResourceStates.FailedToStart, waitingStateCts.Token); 362await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name, KnownResourceStates.Waiting, waitingStateCts.Token); 364await app.ResourceNotifications.PublishUpdateAsync(dependency.Resource, s => s with 369await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name, KnownResourceStates.Waiting, waitingStateCts.Token); 372await app.ResourceNotifications.PublishUpdateAsync(dependency.Resource, s => s with 377await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name, KnownResourceStates.Running, waitingStateCts.Token); 409await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name, KnownResourceStates.Waiting, waitingStateCts.Token); 411await app.ResourceNotifications.PublishUpdateAsync(dependency.Resource, s => s with 416await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name, KnownResourceStates.Waiting, waitingStateCts.Token); 419await app.ResourceNotifications.PublishUpdateAsync(dependency.Resource, s => s with 424await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name, KnownResourceStates.Running, waitingStateCts.Token); 454await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name, KnownResourceStates.Waiting, waitingStateCts.Token); 459await app.ResourceNotifications.PublishUpdateAsync(dependency.Resource, s => s with 469await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name, KnownResourceStates.Running, runningStateCts.Token); 501await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name, "Waiting", waitingStateCts.Token); 506await app.ResourceNotifications.PublishUpdateAsync(dependency.Resource, s => s with 516await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name, KnownResourceStates.FailedToStart, runningStateCts.Token); 556await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name, "Waiting", waitingStateCts.Token); 561await app.ResourceNotifications.PublishUpdateAsync(dependency.Resource, s => s with 572await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name, KnownResourceStates.FailedToStart, runningStateCts.Token); 610await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name, KnownResourceStates.Waiting, waitingStateCts.Token); 615await app.ResourceNotifications.PublishUpdateAsync(dependency.Resource, s => s with 624await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name, KnownResourceStates.FailedToStart, runningStateCts.Token); 661await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name, KnownResourceStates.Waiting, waitingStateCts.Token); 664await app.ResourceNotifications.PublishUpdateAsync(dependency.Resource, "test0", s => s with 669await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name, KnownResourceStates.Waiting, waitingStateCts.Token); 672await app.ResourceNotifications.PublishUpdateAsync(dependency.Resource, "test1", s => s with 677await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name, KnownResourceStates.Running, waitingStateCts.Token); 714await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name, KnownResourceStates.Waiting, waitingStateCts.Token); 717await app.ResourceNotifications.PublishUpdateAsync(dependency.Resource, "test0", s => s with 722await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name, KnownResourceStates.Waiting, waitingStateCts.Token); 725await app.ResourceNotifications.PublishUpdateAsync(dependency.Resource, "test1", s => s with 730await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name, KnownResourceStates.Running, waitingStateCts.Token); 763await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name, KnownResourceStates.Waiting, waitingStateCts.Token); 766await app.ResourceNotifications.PublishUpdateAsync(dependency.Resource, s => s with 771await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name, KnownResourceStates.Running, waitingStateCts.Token); 783var childResource = builder.AddResource(new CustomChildResource("child", parentResource.Resource)); 787Assert.True(containerResource.Resource.TryGetAnnotationsOfType<WaitAnnotation>(out var waitAnnotations)); 790a => Assert.Equal(a.Resource, parentResource.Resource), 791a => Assert.Equal(a.Resource, childResource.Resource) 794Assert.True(containerResource.Resource.TryGetAnnotationsOfType<ResourceRelationshipAnnotation>(out var relationshipAnnotations)); 797Assert.Equal(childResource.Resource, relationshipAnnotation.Resource); 809Assert.True(resource.Resource.TryGetAnnotationsOfType<WaitAnnotation>(out var waitAnnotations)); 812Assert.Equal(dependency.Resource, waitAnnotation.Resource); 825Assert.True(resource.Resource.TryGetAnnotationsOfType<WaitAnnotation>(out var waitAnnotations)); 828Assert.Equal(dependency.Resource, waitAnnotation.Resource); 875await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name, KnownResourceStates.Waiting, waitingStateCts.Token); 878await app.ResourceNotifications.PublishUpdateAsync(dependency.Resource, s => s with 885await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name, KnownResourceStates.Running, runningStateCts.Token);

30Assert.True(container.Resource.TryGetAnnotationsOfType<CertificateAuthorityCollectionAnnotation>(out var annotations)); 33Assert.Contains(bundle1.Resource, annotation.CertificateAuthorityCollections); 34Assert.Contains(bundle2.Resource, annotation.CertificateAuthorityCollections);

28var endpoint = projectA.Resource.Annotations.OfType<EndpointAnnotation>() 45var endpoint = projectA.Resource.Annotations.OfType<EndpointAnnotation>() 80var endpoint = projectA.Resource.Annotations.OfType<EndpointAnnotation>() 118Assert.False(projectA.Resource.TryGetAnnotationsOfType<EndpointAnnotation>(out var annotations)); 135Assert.True(projectA.Resource.TryGetAnnotationsOfType<EndpointAnnotation>(out _)); 152Assert.True(projectA.Resource.TryGetAnnotationsOfType<EndpointAnnotation>(out _)); 253var manifest = await ManifestUtils.GetManifest(container.Resource).DefaultTimeout(); 281var manifest = await ManifestUtils.GetManifest(container.Resource).DefaultTimeout(); 308var manifest = await ManifestUtils.GetManifest(container.Resource).DefaultTimeout(); 335var manifest = await ManifestUtils.GetManifest(container.Resource).DefaultTimeout(); 362var manifest = await ManifestUtils.GetManifest(container.Resource).DefaultTimeout(); 389var manifest = await ManifestUtils.GetManifest(container.Resource).DefaultTimeout(); 416var manifest = await ManifestUtils.GetManifest(container.Resource).DefaultTimeout(); 447var manifest = await ManifestUtils.GetManifest(project.Resource).DefaultTimeout(); 517var manifest = await ManifestUtils.GetManifest(project.Resource).DefaultTimeout(); 544var manifests = await ManifestUtils.GetManifests([container0.Resource, container1.Resource]).DefaultTimeout(); 589var endpoint = projectA.Resource.Annotations.OfType<EndpointAnnotation>() 620var urls = projectA.Resource.Annotations.OfType<ResourceUrlAnnotation>(); 625EndpointAnnotation endpoint = Assert.Single(projectA.Resource.Annotations.OfType<EndpointAnnotation>()); 654var urls = projectA.Resource.Annotations.OfType<ResourceUrlAnnotation>(); 659EndpointAnnotation endpoint = Assert.Single(projectA.Resource.Annotations.OfType<EndpointAnnotation>());

32container.Resource, 54var config = await EnvironmentVariableEvaluator.GetEnvironmentVariablesAsync(projectB.Resource, DistributedApplicationOperation.Run, TestServiceProvider.Instance).DefaultTimeout(); 58Assert.True(projectB.Resource.TryGetAnnotationsOfType<ResourceRelationshipAnnotation>(out var relationships)); 63Assert.Same(projectA.Resource, r.Resource); 75var config = await EnvironmentVariableEvaluator.GetEnvironmentVariablesAsync(project.Resource, DistributedApplicationOperation.Run, TestServiceProvider.Instance).DefaultTimeout(); 91var config = await EnvironmentVariableEvaluator.GetEnvironmentVariablesAsync(project.Resource, DistributedApplicationOperation.Run, TestServiceProvider.Instance).DefaultTimeout(); 107var config = await EnvironmentVariableEvaluator.GetEnvironmentVariablesAsync(projectA.Resource, DistributedApplicationOperation.Run, TestServiceProvider.Instance).DefaultTimeout(); 124var config = await EnvironmentVariableEvaluator.GetEnvironmentVariablesAsync(projectA.Resource, DistributedApplicationOperation.Run, TestServiceProvider.Instance).DefaultTimeout(); 128Assert.True(projectA.Resource.TryGetAnnotationsOfType<ResourceRelationshipAnnotation>(out var relationships)); 133Assert.Same(parameter.Resource, r.Resource); 147var config = await EnvironmentVariableEvaluator.GetEnvironmentVariablesAsync(projectA.Resource, 164projectA.Resource, 189var config = await EnvironmentVariableEvaluator.GetEnvironmentVariablesAsync(projectA.Resource, DistributedApplicationOperation.Run, TestServiceProvider.Instance).DefaultTimeout(); 213var config = await EnvironmentVariableEvaluator.GetEnvironmentVariablesAsync(projectA.Resource, DistributedApplicationOperation.Run, TestServiceProvider.Instance).DefaultTimeout(); 238.WithEnvironment("HOST", $"{test.Resource};name=1"); 240var config = await EnvironmentVariableEvaluator.GetEnvironmentVariablesAsync(containerB.Resource).DefaultTimeout(); 241var manifestConfig = await EnvironmentVariableEvaluator.GetEnvironmentVariablesAsync(containerB.Resource, DistributedApplicationOperation.Publish).DefaultTimeout(); 255Assert.True(containerB.Resource.TryGetAnnotationsOfType<ResourceRelationshipAnnotation>(out var relationships)); 260Assert.Same(container.Resource, r.Resource); 265Assert.Same(test.Resource, r.Resource); 286Assert.True(containerB.Resource.TryGetAnnotationsOfType<ResourceRelationshipAnnotation>(out var relationships)); 291Assert.Same(container.Resource, r.Resource); 321var config = await EnvironmentVariableEvaluator.GetEnvironmentVariablesAsync(containerB.Resource).DefaultTimeout(); 345var runConfig = await EnvironmentVariableEvaluator.GetEnvironmentVariablesAsync(targetBuilder.Resource, DistributedApplicationOperation.Run).DefaultTimeout(); 351var publishConfig = await EnvironmentVariableEvaluator.GetEnvironmentVariablesAsync(targetBuilder.Resource, DistributedApplicationOperation.Publish).DefaultTimeout(); 356Assert.True(targetBuilder.Resource.TryGetAnnotationsOfType<ResourceRelationshipAnnotation>(out var relationships)); 361Assert.Same(sourceBuilder.Resource, r.Resource); 376projectA.Resource, 384projectA.Resource, 397var testValue = new TestValueWithReferences("test-value", resourceA.Resource); 403Assert.True(projectA.Resource.TryGetAnnotationsOfType<ResourceRelationshipAnnotation>(out var relationships)); 406Assert.Same(resourceA.Resource, relationship.Resource); 410projectA.Resource, 457projectA.Resource, 465projectA.Resource, 472Assert.True(projectA.Resource.TryGetAnnotationsOfType<ResourceRelationshipAnnotation>(out var relationships)); 475Assert.Same(container.Resource, relationship.Resource);