(#244) Added 2 MongoDB instances (Community and Cosmos) and centralized connection strings.

Author: Adrian Hall

infra/main.bicep

@@ -51,6 +51,7 @@ module resources './resources.bicep' = {
 output AZSQL_CONNECTION_STRING string = resources.outputs.AZSQL_CONNECTIONSTRING
 output COSMOS_CONNECTION_STRING string = resources.outputs.COSMOS_CONNECTIONSTRING
 output MONGO_CONNECTION_STRING string = resources.outputs.MONGO_CONNECTIONSTRING
+output MONGOACI_CONNECTION_STRING string = resources.outputs.MONGOACI_CONNECTIONSTRING
 output MYSQL_CONNECTION_STRING string = resources.outputs.MYSQL_CONNECTIONSTRING
 output PGSQL_CONNECTION_STRING string = resources.outputs.PGSQL_CONNECTIONSTRING
 output SERVICE_ENDPOINT string = resources.outputs.SERVICE_ENDPOINT

infra/modules/aci-mongodb.bicep

@@ -0,0 +1,74 @@
+targetScope = 'resourceGroup'
+
+@secure()
+@description('The password for the administrator')
+param administratorPassword string
+
+@description('The username for the administrator')
+param administratorUsername string = 'tester'
+
+@description('The image URI to use.')
+param image string = 'mongo'
+
+@minLength(1)
+@description('Primary location for all resources')
+param location string = resourceGroup().location
+
+@description('The port # to expose in the Docker image')
+param port int = 27017
+
+@description('The name of the Mongo Server to create.')
+param serverName string
+
+@description('The list of tags to apply to all resources.')
+param tags object = {}
+
+/*********************************************************************************/
+
+resource containerGroup 'Microsoft.ContainerInstance/containerGroups@2023-05-01' = {
+  name: toLower(serverName)
+  location: location
+  tags: tags
+  properties: {
+    containers: [
+      {
+        name: toLower(serverName)
+        properties: {
+          image: image
+          environmentVariables: [
+            { name: 'MONGO_INITDB_ROOT_USERNAME', value: administratorUsername }
+            { name: 'MONGO_INITDB_ROOT_PASSWORD', secureValue: administratorPassword }
+          ]
+          ports: [
+            {
+              port: port
+              protocol: 'TCP'
+            }
+          ]
+          resources: {
+            requests: {
+              cpu: 2
+              memoryInGB: 2
+            }
+          }
+        }
+      }
+    ]
+    osType: 'Linux'
+    restartPolicy: 'Always'
+    ipAddress: {
+      type: 'Public'
+      ports: [
+        {
+          port: port
+          protocol: 'TCP'
+        }
+      ]
+    }
+  }
+}
+
+/*********************************************************************************/
+
+#disable-next-line outputs-should-not-contain-secrets
+output MONGO_CONNECTIONSTRING string = 'mongodb://${administratorUsername}:${administratorPassword}@${containerGroup.properties.ipAddress.ip}:27017/'

infra/modules/cosmos-mongodb.bicep

@@ -179,4 +179,4 @@ resource collection 'Microsoft.DocumentDb/databaseAccounts/mongodbDatabases/coll
 /*********************************************************************************/
 
 #disable-next-line outputs-should-not-contain-secrets
-output MONGODB_CONNECTIONSTRING string = 'mongodb://${account.properties.documentEndpoint}/${containerName}'
+output MONGODB_CONNECTIONSTRING string = account.listConnectionStrings().connectionStrings[1].connectionString

infra/resources.bicep

@@ -36,6 +36,7 @@ var cosmosServerName = 'cosmos-${resourceToken}'
 var pgsqlServerName = 'pgsql-${resourceToken}'
 var mysqlServerName = 'mysql-${resourceToken}'
 var mongoServerName = 'mongo-${resourceToken}'
+var mongoaciServerName = 'mongoaci-${resourceToken}'
 
 var testDatabaseName = 'unittests'
 var cosmosContainerName = 'Movies'
@@ -115,6 +116,17 @@ module mongodb './modules/cosmos-mongodb.bicep' = {
     }
 }
 
+module mongoaci './modules/aci-mongodb.bicep' = {
+    name: 'mongoaci-deployment-${resourceToken}'
+    params: {
+        location: location
+        tags: tags
+        serverName: mongoaciServerName
+        administratorPassword: sqlAdminPassword
+
+    }
+}
+
 module app_service './modules/appservice.bicep' = {
     name: 'appsvc-deployment-${resourceToken}'
     params: {
@@ -137,6 +149,7 @@ module app_service './modules/appservice.bicep' = {
 output AZSQL_CONNECTIONSTRING string = azuresql.outputs.AZSQL_CONNECTIONSTRING
 output COSMOS_CONNECTIONSTRING string = cosmos.outputs.COSMOS_CONNECTIONSTRING
 output MONGO_CONNECTIONSTRING string = mongodb.outputs.MONGODB_CONNECTIONSTRING
+output MONGOACI_CONNECTIONSTRING string = mongoaci.outputs.MONGO_CONNECTIONSTRING
 output MYSQL_CONNECTIONSTRING string = mysql.outputs.MYSQL_CONNECTIONSTRING
 output PGSQL_CONNECTIONSTRING string = pgsql.outputs.PGSQL_CONNECTIONSTRING
 output SERVICE_ENDPOINT string = app_service.outputs.SERVICE_ENDPOINT

infra/scripts/write-runsettings.ps1

@@ -6,21 +6,26 @@
 $outputs = (azd env get-values --output json | ConvertFrom-Json)
 $outputFile = "tests\.runsettings"
 
-$fileContents = @"
+$prefix = @"
 <?xml version="1.0" encoding="utf-8"?>
 <RunSettings>
   <RunConfiguration>
     <EnvironmentVariables>
-      <DATASYNC_AZSQL_CONNECTIONSTRING>$($outputs.AZSQL_CONNECTION_STRING)</DATASYNC_AZSQL_CONNECTIONSTRING>
-      <DATASYNC_COSMOS_CONNECTIONSTRING>$($outputs.COSMOS_CONNECTION_STRING)</DATASYNC_COSMOS_CONNECTIONSTRING>
-      <DATASYNC_MONGO_CONNECTIONSTRING>$($outputs.MONGO_CONNECTION_STRING)</DATASYNC_MONGO_CONNECTIONSTRING>
-      <DATASYNC_MYSQL_CONNECTIONSTRING>$($outputs.MYSQL_CONNECTION_STRING)</DATASYNC_MYSQL_CONNECTIONSTRING>
-      <DATASYNC_PGSQL_CONNECTIONSTRING>$($outputs.PGSQL_CONNECTION_STRING)</DATASYNC_PGSQL_CONNECTIONSTRING>
-      <DATASYNC_SERVICE_ENDPOINT>$($outputs.SERVICE_ENDPOINT)</DATASYNC_SERVICE_ENDPOINT>
+
+"@
+
+$postfix = @"
       <ENABLE_SQL_LOGGING>true</ENABLE_SQL_LOGGING>
     </EnvironmentVariables>
   </RunConfiguration>
 </RunSettings>
 "@
 
-$fileContents | Out-File -FilePath $outputFile
+$sb = New-Object System.Text.StringBuilder
+$outputs | Get-Member -MemberType Properties | Foreach-Object {
+    $propertyName = $_.Name
+    $propertyValue = [System.Security.SecurityElement]::Escape($outputs.$propertyName)
+    $sb.AppendLine("      <$($propertyName)>$($propertyValue)</$($propertyName)>") | Out-Null
+}
+
+$prefix + $sb.ToString() + $postfix | Out-File -FilePath $outputFile

tests/CommunityToolkit.Datasync.Client.Test/Live/SampleServerTests.cs

@@ -2,6 +2,7 @@
 // The .NET Foundation licenses this file to you under the MIT license.
 // See the LICENSE file in the project root for more information.
 
+using CommunityToolkit.Datasync.TestCommon.Databases;
 using System.Net;
 using System.Net.Http.Json;
 
@@ -10,8 +11,8 @@ namespace CommunityToolkit.Datasync.Client.Test.Live;
 [ExcludeFromCodeCoverage]
 public class SampleServerTests
 {
-    private readonly bool liveTestsAreEnabled = Environment.GetEnvironmentVariable("DATASYNC_SERVICE_ENDPOINT") is not null;
-    private readonly string serviceEndpoint = Environment.GetEnvironmentVariable("DATASYNC_SERVICE_ENDPOINT");
+    private readonly bool liveTestsAreEnabled = ConnectionStrings.Service is not null;
+    private readonly string serviceEndpoint = ConnectionStrings.Service;
 
     [SkippableFact]
     public async Task Metadata_GetsSetByServer()

tests/CommunityToolkit.Datasync.Server.EntityFrameworkCore.Test/AzureSqlEntityTableRepository_Tests.cs

@@ -17,14 +17,13 @@ public class AzureSqlEntityTableRepository_Tests(DatabaseFixture fixture, ITestO
 {
     #region Setup
     private readonly Random random = new();
-    private readonly string connectionString = Environment.GetEnvironmentVariable("DATASYNC_AZSQL_CONNECTIONSTRING");
     private List<AzureSqlEntityMovie> movies = [];
 
     public async Task InitializeAsync()
     {
-        if (!string.IsNullOrEmpty(this.connectionString))
+        if (!string.IsNullOrEmpty(ConnectionStrings.AzureSql))
         {
-            Context = await AzureSqlDbContext.CreateContextAsync(this.connectionString, output);
+            Context = await AzureSqlDbContext.CreateContextAsync(ConnectionStrings.AzureSql, output);
             this.movies = await Context.Movies.AsNoTracking().ToListAsync();
         }
     }
@@ -39,7 +38,7 @@ public async Task DisposeAsync()
 
     private AzureSqlDbContext Context { get; set; }
 
-    protected override bool CanRunLiveTests() => !string.IsNullOrEmpty(this.connectionString);
+    protected override bool CanRunLiveTests() => !string.IsNullOrEmpty(ConnectionStrings.AzureSql);
 
     protected override async Task<AzureSqlEntityMovie> GetEntityAsync(string id)
         => await Context.Movies.AsNoTracking().SingleOrDefaultAsync(m => m.Id == id);

tests/CommunityToolkit.Datasync.Server.EntityFrameworkCore.Test/CosmosEntityTableRepository_Tests.cs

@@ -17,14 +17,13 @@ public class CosmosEntityTableRepository_Tests(DatabaseFixture fixture, ITestOut
 {
     #region Setup
     private readonly Random random = new();
-    private readonly string connectionString = Environment.GetEnvironmentVariable("DATASYNC_COSMOS_CONNECTIONSTRING");
     private List<CosmosEntityMovie> movies = [];
 
     public async Task InitializeAsync()
     {
-        if (!string.IsNullOrEmpty(this.connectionString))
+        if (!string.IsNullOrEmpty(ConnectionStrings.CosmosDb))
         {
-            Context = await CosmosDbContext.CreateContextAsync(this.connectionString, output);
+            Context = await CosmosDbContext.CreateContextAsync(ConnectionStrings.CosmosDb, output);
             this.movies = await Context.Movies.AsNoTracking().ToListAsync();
         }
     }
@@ -39,7 +38,7 @@ public async Task DisposeAsync()
 
     private CosmosDbContext Context { get; set; }
 
-    protected override bool CanRunLiveTests() => !string.IsNullOrEmpty(this.connectionString);
+    protected override bool CanRunLiveTests() => !string.IsNullOrEmpty(ConnectionStrings.CosmosDb);
 
     protected override async Task<CosmosEntityMovie> GetEntityAsync(string id)
         => await Context.Movies.AsNoTracking().SingleOrDefaultAsync(m => m.Id == id);

tests/CommunityToolkit.Datasync.Server.EntityFrameworkCore.Test/MySqlEntityTableRepository_Tests.cs

@@ -17,14 +17,13 @@ public class MysqlEntityTableRepository_Tests(DatabaseFixture fixture, ITestOutp
 {
     #region Setup
     private readonly Random random = new();
-    private readonly string connectionString = Environment.GetEnvironmentVariable("DATASYNC_MYSQL_CONNECTIONSTRING");
     private List<MysqlEntityMovie> movies = [];
 
     public async Task InitializeAsync()
     {
-        if (!string.IsNullOrEmpty(this.connectionString))
+        if (!string.IsNullOrEmpty(ConnectionStrings.MySql))
         {
-            Context = await MysqlDbContext.CreateContextAsync(this.connectionString, output);
+            Context = await MysqlDbContext.CreateContextAsync(ConnectionStrings.MySql, output);
             this.movies = await Context.Movies.AsNoTracking().ToListAsync();
         }
     }
@@ -39,7 +38,7 @@ public async Task DisposeAsync()
 
     private MysqlDbContext Context { get; set; }
 
-    protected override bool CanRunLiveTests() => !string.IsNullOrEmpty(this.connectionString);
+    protected override bool CanRunLiveTests() => !string.IsNullOrEmpty(ConnectionStrings.MySql);
 
     protected override async Task<MysqlEntityMovie> GetEntityAsync(string id)
         => await Context.Movies.AsNoTracking().SingleOrDefaultAsync(m => m.Id == id);

tests/CommunityToolkit.Datasync.Server.EntityFrameworkCore.Test/PgEntityTableRepository_Tests.cs

@@ -17,14 +17,13 @@ public class PgEntityTableRepository_Tests(DatabaseFixture fixture, ITestOutputH
 {
     #region Setup
     private readonly Random random = new();
-    private readonly string connectionString = Environment.GetEnvironmentVariable("DATASYNC_PGSQL_CONNECTIONSTRING");
     private List<PgEntityMovie> movies = [];
 
     public async Task InitializeAsync()
     {
-        if (!string.IsNullOrEmpty(this.connectionString))
+        if (!string.IsNullOrEmpty(ConnectionStrings.PgSql))
         {
-            Context = await PgDbContext.CreateContextAsync(this.connectionString, output);
+            Context = await PgDbContext.CreateContextAsync(ConnectionStrings.PgSql, output);
             this.movies = await Context.Movies.AsNoTracking().ToListAsync();
         }
     }
@@ -39,7 +38,7 @@ public async Task DisposeAsync()
 
     private PgDbContext Context { get; set; }
 
-    protected override bool CanRunLiveTests() => !string.IsNullOrEmpty(this.connectionString);
+    protected override bool CanRunLiveTests() => !string.IsNullOrEmpty(ConnectionStrings.PgSql);
 
     protected override async Task<PgEntityMovie> GetEntityAsync(string id)
         => await Context.Movies.AsNoTracking().SingleOrDefaultAsync(m => m.Id == id);