CommunityToolkit · richard-einfinity · Feb 10, 2025
diff --git a/Datasync.Toolkit.sln b/Datasync.Toolkit.sln
@@ -64,10 +64,16 @@ Project("{2150E333-8FDC-42A3-9474-1A3956D46DE8}") = "samples", "samples", "{75F7
 EndProject
 Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "Sample.Datasync.Server", "samples\datasync-server\src\Sample.Datasync.Server\Sample.Datasync.Server.csproj", "{A9967817-2A2C-4C6D-A133-967A6062E9B3}"
 EndProject
+Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "CommunityToolkit.Datasync.Server.CosmosDb", "src\CommunityToolkit.Datasync.Server.CosmosDb\CommunityToolkit.Datasync.Server.CosmosDb.csproj", "{D9356867-0A30-4B17-BD4C-0F7EF70984C6}"
+EndProject
+Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "Sample.Datasync.Server.SingleContainer", "samples\datasync-server\datasync-server-cosmosdb\Sample.Datasync.Server.SingleContainer\Sample.Datasync.Server.SingleContainer.csproj", "{60C73E92-9A45-4EE6-8DCF-48206CD0E5FE}"
+EndProject
 Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "CommunityToolkit.Datasync.Server.MongoDB", "src\CommunityToolkit.Datasync.Server.MongoDB\CommunityToolkit.Datasync.Server.MongoDB.csproj", "{DC20ACF9-12E9-41D9-B672-CB5FD85548E9}"
 EndProject
 Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "CommunityToolkit.Datasync.Server.MongoDB.Test", "tests\CommunityToolkit.Datasync.Server.MongoDB.Test\CommunityToolkit.Datasync.Server.MongoDB.Test.csproj", "{4FC45D20-0BA9-484B-9040-641687659AF6}"
 EndProject
+Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "CommunityToolkit.Datasync.Server.CosmosDb.Test", "tests\CommunityToolkit.Datasync.Server.CosmosDb.Test\CommunityToolkit.Datasync.Server.CosmosDb.Test.csproj", "{FC15CF34-2C1A-4B15-85CC-A99EA25C47D2}"
+EndProject
 Global
 	GlobalSection(SolutionConfigurationPlatforms) = preSolution
 		Debug|Any CPU = Debug|Any CPU
@@ -158,6 +164,18 @@ Global
 		{A9967817-2A2C-4C6D-A133-967A6062E9B3}.Debug|Any CPU.Build.0 = Debug|Any CPU
 		{A9967817-2A2C-4C6D-A133-967A6062E9B3}.Release|Any CPU.ActiveCfg = Release|Any CPU
 		{A9967817-2A2C-4C6D-A133-967A6062E9B3}.Release|Any CPU.Build.0 = Release|Any CPU
+		{D9356867-0A30-4B17-BD4C-0F7EF70984C6}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
+		{D9356867-0A30-4B17-BD4C-0F7EF70984C6}.Debug|Any CPU.Build.0 = Debug|Any CPU
+		{D9356867-0A30-4B17-BD4C-0F7EF70984C6}.Release|Any CPU.ActiveCfg = Release|Any CPU
+		{D9356867-0A30-4B17-BD4C-0F7EF70984C6}.Release|Any CPU.Build.0 = Release|Any CPU
+		{60C73E92-9A45-4EE6-8DCF-48206CD0E5FE}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
+		{60C73E92-9A45-4EE6-8DCF-48206CD0E5FE}.Debug|Any CPU.Build.0 = Debug|Any CPU
+		{60C73E92-9A45-4EE6-8DCF-48206CD0E5FE}.Release|Any CPU.ActiveCfg = Release|Any CPU
+		{60C73E92-9A45-4EE6-8DCF-48206CD0E5FE}.Release|Any CPU.Build.0 = Release|Any CPU
+		{FC15CF34-2C1A-4B15-85CC-A99EA25C47D2}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
+		{FC15CF34-2C1A-4B15-85CC-A99EA25C47D2}.Debug|Any CPU.Build.0 = Debug|Any CPU
+		{FC15CF34-2C1A-4B15-85CC-A99EA25C47D2}.Release|Any CPU.ActiveCfg = Release|Any CPU
+		{FC15CF34-2C1A-4B15-85CC-A99EA25C47D2}.Release|Any CPU.Build.0 = Release|Any CPU
 		{DC20ACF9-12E9-41D9-B672-CB5FD85548E9}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
 		{DC20ACF9-12E9-41D9-B672-CB5FD85548E9}.Debug|Any CPU.Build.0 = Debug|Any CPU
 		{DC20ACF9-12E9-41D9-B672-CB5FD85548E9}.Release|Any CPU.ActiveCfg = Release|Any CPU
@@ -192,6 +210,9 @@ Global
 		{D3B72031-D4BD-44D3-973C-2752AB1570F6} = {84AD662A-4B9E-4E64-834D-72529FB7FCE5}
 		{2889E6B2-9CD1-437C-A43C-98CFAFF68B99} = {D59F1489-5D74-4F52-B78B-88037EAB2838}
 		{A9967817-2A2C-4C6D-A133-967A6062E9B3} = {75F709FD-8CC2-4558-A802-FE57086167C2}
+		{D9356867-0A30-4B17-BD4C-0F7EF70984C6} = {84AD662A-4B9E-4E64-834D-72529FB7FCE5}
+		{60C73E92-9A45-4EE6-8DCF-48206CD0E5FE} = {75F709FD-8CC2-4558-A802-FE57086167C2}
+		{FC15CF34-2C1A-4B15-85CC-A99EA25C47D2} = {D59F1489-5D74-4F52-B78B-88037EAB2838}
 		{DC20ACF9-12E9-41D9-B672-CB5FD85548E9} = {84AD662A-4B9E-4E64-834D-72529FB7FCE5}
 		{4FC45D20-0BA9-484B-9040-641687659AF6} = {D59F1489-5D74-4F52-B78B-88037EAB2838}
 	EndGlobalSection

diff --git a/Directory.Packages.props b/Directory.Packages.props
@@ -11,19 +11,22 @@
     <PackageVersion Include="LiteDB" Version="5.0.21" />
     <PackageVersion Include="Microsoft.AspNetCore.Mvc.Testing" Version="9.0.1" />
     <PackageVersion Include="Microsoft.AspNetCore.OData" Version="9.1.3" />
+    <PackageVersion Include="Microsoft.Azure.Cosmos" Version="3.46.1" />
     <PackageVersion Include="Microsoft.EntityFrameworkCore" Version="9.0.1" />
     <PackageVersion Include="Microsoft.EntityFrameworkCore.Cosmos" Version="9.0.1" />
     <PackageVersion Include="Microsoft.EntityFrameworkCore.InMemory" Version="9.0.1" />
     <PackageVersion Include="Microsoft.EntityFrameworkCore.Proxies" Version="9.0.1" />
     <PackageVersion Include="Microsoft.EntityFrameworkCore.Sqlite" Version="9.0.1" />
     <PackageVersion Include="Microsoft.EntityFrameworkCore.SqlServer" Version="9.0.1" />
     <PackageVersion Include="Microsoft.Extensions.Caching.Memory" Version="9.0.1" />
+    <PackageVersion Include="Microsoft.Extensions.DependencyInjection.Abstractions" Version="9.0.1" />
     <PackageVersion Include="Microsoft.Extensions.Http" Version="9.0.1" />
     <PackageVersion Include="Microsoft.Extensions.Logging.Abstractions" Version="9.0.1" />
     <PackageVersion Include="Microsoft.NET.Test.Sdk" Version="17.12.0" />
     <PackageVersion Include="Microsoft.OData.Core" Version="8.2.3" />
     <PackageVersion Include="Microsoft.SourceLink.GitHub" Version="8.0.0" />
     <PackageVersion Include="Microsoft.Spatial" Version="8.2.3" />
+    <PackageVersion Include="Newtonsoft.Json" Version="13.0.3" />
     <PackageVersion Include="MongoDB.Driver" Version="3.1.0" />
     <PackageVersion Include="NSubstitute" Version="5.3.0" />
     <PackageVersion Include="NSwag.AspNetCore" Version="14.2.0" />

diff --git a/...-server-cosmosdb/Sample.Datasync.Server.SingleContainer/Controllers/TodoItemController.cs b/...-server-cosmosdb/Sample.Datasync.Server.SingleContainer/Controllers/TodoItemController.cs
@@ -0,0 +1,18 @@
+// Licensed to the .NET Foundation under one or more agreements.
+// 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.Server;
+using Microsoft.AspNetCore.Mvc;
+using Sample.Datasync.Server.SingleContainer.Models;
+
+namespace Sample.Datasync.Server.Controllers;
+
+[Route("tables/[controller]")]
+public class TodoItemController : TableController<TodoItem>
+{
+    public TodoItemController(IRepository<TodoItem> repository) 
+        : base(repository)
+    {
+    }
+}
diff --git a/...-server-cosmosdb/Sample.Datasync.Server.SingleContainer/Controllers/TodoListController.cs b/...-server-cosmosdb/Sample.Datasync.Server.SingleContainer/Controllers/TodoListController.cs
@@ -0,0 +1,18 @@
+// Licensed to the .NET Foundation under one or more agreements.
+// 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.Server;
+using Microsoft.AspNetCore.Mvc;
+using Sample.Datasync.Server.SingleContainer.Models;
+
+namespace Sample.Datasync.Server.Controllers;
+
+[Route("tables/[controller]")]
+public class TodoListController : TableController<TodoList>
+{
+    public TodoListController(IRepository<TodoList> repository) : base(repository)
+    {
+        Options = new TableControllerOptions { EnableSoftDelete = true };
+    }
+}
diff --git a/...server/datasync-server-cosmosdb/Sample.Datasync.Server.SingleContainer/Models/TodoItem.cs b/...server/datasync-server-cosmosdb/Sample.Datasync.Server.SingleContainer/Models/TodoItem.cs
@@ -0,0 +1,16 @@
+// Licensed to the .NET Foundation under one or more agreements.
+// 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.Server.CosmosDb;
+using System.ComponentModel.DataAnnotations;
+
+namespace Sample.Datasync.Server.SingleContainer.Models;
+
+public class TodoItem : CosmosTableData<TodoItem>
+{
+    [Required, MinLength(1)]
+    public string Title { get; set; } = string.Empty;
+
+    public bool IsComplete { get; set; }
+}
diff --git a/...server/datasync-server-cosmosdb/Sample.Datasync.Server.SingleContainer/Models/TodoList.cs b/...server/datasync-server-cosmosdb/Sample.Datasync.Server.SingleContainer/Models/TodoList.cs
@@ -0,0 +1,16 @@
+// Licensed to the .NET Foundation under one or more agreements.
+// 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.Server.CosmosDb;
+using System.ComponentModel.DataAnnotations;
+
+namespace Sample.Datasync.Server.SingleContainer.Models;
+
+public class TodoList : CosmosTableData<TodoList>
+{
+    [Required, MinLength(1)]
+    public string Title { get; set; } = string.Empty;
+
+    public string? ListId { get; set; }
+}
diff --git a/...atasync-server/datasync-server-cosmosdb/Sample.Datasync.Server.SingleContainer/Program.cs b/...atasync-server/datasync-server-cosmosdb/Sample.Datasync.Server.SingleContainer/Program.cs
@@ -0,0 +1,86 @@
+// Licensed to the .NET Foundation under one or more agreements.
+// 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.Server;
+using CommunityToolkit.Datasync.Server.Abstractions.Json;
+using CommunityToolkit.Datasync.Server.CosmosDb;
+using CommunityToolkit.Datasync.Server.Swashbuckle;
+using Microsoft.Azure.Cosmos;
+using Sample.Datasync.Server.SingleContainer.Models;
+using System.Collections.ObjectModel;
+using System.Text.Json;
+using System.Text.Json.Serialization;
+
+var builder = WebApplication.CreateBuilder(args);
+
+string connectionString = builder.Configuration.GetConnectionString("DefaultConnection")
+    ?? throw new ApplicationException("DefaultConnection is not set");
+
+CosmosClient cosmosClient = new CosmosClient(connectionString,
+    new CosmosClientOptions()
+    {
+        UseSystemTextJsonSerializerWithOptions = new()
+        {
+            Converters =
+            {
+                new JsonStringEnumConverter(),
+                new DateTimeOffsetConverter(),
+                new DateTimeConverter(),
+                new TimeOnlyConverter(),
+                new SpatialGeoJsonConverter()
+            },
+            PropertyNamingPolicy = JsonNamingPolicy.CamelCase,
+            DefaultIgnoreCondition = JsonIgnoreCondition.WhenWritingNull | JsonIgnoreCondition.WhenWritingDefault,
+            NumberHandling = JsonNumberHandling.AllowNamedFloatingPointLiterals,
+            ReferenceHandler = ReferenceHandler.Preserve
+        }
+    });
+
+builder.Services.AddSingleton(cosmosClient);
+builder.Services.AddSingleton<ICosmosTableOptions<TodoItem>>(new CosmosSharedTableOptions<TodoItem>("TodoDb", "TodoContainer"));
+builder.Services.AddSingleton<ICosmosTableOptions<TodoList>>(new CosmosSharedTableOptions<TodoList>("TodoDb", "TodoContainer"));
+builder.Services.AddSingleton(typeof(IRepository<>), typeof(CosmosTableRepository<>));
+// Add services to the container.
+
+builder.Services.AddDatasyncServices();
+
+builder.Services.AddControllers();
+
+_ = builder.Services
+    .AddEndpointsApiExplorer()
+    .AddSwaggerGen(options => options.AddDatasyncControllers());
+
+var app = builder.Build();
+
+// Configure the HTTP request pipeline.
+if (app.Environment.IsDevelopment())
+{
+    _ = app.UseSwagger().UseSwaggerUI();
+    _ = app.UseDeveloperExceptionPage();
+
+    Database database = await cosmosClient.CreateDatabaseIfNotExistsAsync("TodoDb");
+
+    _ = await database.CreateContainerIfNotExistsAsync(new ContainerProperties("TodoContainer", "/entity")
+    {
+        IndexingPolicy = new()
+        {
+            CompositeIndexes =
+            {
+                new Collection<CompositePath>()
+                {
+                    new CompositePath() { Path = "/updatedAt", Order = CompositePathSortOrder.Ascending },
+                    new CompositePath() { Path = "/id", Order = CompositePathSortOrder.Ascending }
+                }
+            }
+        }
+    });
+}
+
+app.UseHttpsRedirection();
+
+app.UseAuthorization();
+
+app.MapControllers();
+
+app.Run();
diff --git a/...ync-server-cosmosdb/Sample.Datasync.Server.SingleContainer/Properties/launchSettings.json b/...ync-server-cosmosdb/Sample.Datasync.Server.SingleContainer/Properties/launchSettings.json
@@ -0,0 +1,23 @@
+{
+  "$schema": "https://json.schemastore.org/launchsettings.json",
+  "profiles": {
+    "http": {
+      "commandName": "Project",
+      "dotnetRunMessages": true,
+      "launchBrowser": false,
+      "applicationUrl": "http://localhost:5024",
+      "environmentVariables": {
+        "ASPNETCORE_ENVIRONMENT": "Development"
+      }
+    },
+    "https": {
+      "commandName": "Project",
+      "dotnetRunMessages": true,
+      "launchBrowser": false,
+      "applicationUrl": "https://localhost:7284;http://localhost:5024",
+      "environmentVariables": {
+        "ASPNETCORE_ENVIRONMENT": "Development"
+      }
+    }
+  }
+}
diff --git a/...osdb/Sample.Datasync.Server.SingleContainer/Sample.Datasync.Server.SingleContainer.csproj b/...osdb/Sample.Datasync.Server.SingleContainer/Sample.Datasync.Server.SingleContainer.csproj
@@ -0,0 +1,16 @@
+<Project Sdk="Microsoft.NET.Sdk.Web">
+
+  <PropertyGroup>
+    <TargetFramework>net9.0</TargetFramework>
+    <Nullable>enable</Nullable>
+    <ImplicitUsings>enable</ImplicitUsings>
+    <UserSecretsId>4fb4ad03-5b6a-43b8-8e71-90b9d8252f94</UserSecretsId>
+  </PropertyGroup>
+
+  <ItemGroup>
+    <ProjectReference Include="..\..\..\..\src\CommunityToolkit.Datasync.Server.CosmosDb\CommunityToolkit.Datasync.Server.CosmosDb.csproj" />
+    <ProjectReference Include="..\..\..\..\src\CommunityToolkit.Datasync.Server.Swashbuckle\CommunityToolkit.Datasync.Server.Swashbuckle.csproj" />
+    <ProjectReference Include="..\..\..\..\src\CommunityToolkit.Datasync.Server\CommunityToolkit.Datasync.Server.csproj" />
+  </ItemGroup>
+
+</Project>
diff --git a/...smosdb/Sample.Datasync.Server.SingleContainer/Sample.Datasync.Server.SingleContainer.http b/...smosdb/Sample.Datasync.Server.SingleContainer/Sample.Datasync.Server.SingleContainer.http
@@ -0,0 +1,33 @@
+@Sample.Datasync.Server.SingleContainer_HostAddress = https://localhost:7284
+
+POST {{Sample.Datasync.Server.SingleContainer_HostAddress}}/tables/TodoItem
+Content-Type: application/json
+
+{
+  "id": "2",
+  "title": "Second item",
+  "isComplete": false
+}
+
+###
+
+GET {{Sample.Datasync.Server.SingleContainer_HostAddress}}/tables/TodoItem
+Accept: application/json
+
+###
+
+POST {{Sample.Datasync.Server.SingleContainer_HostAddress}}/tables/TodoList
+Content-Type: application/json
+
+{
+  "id": "1",
+  "title": "First List",
+  "listId": "My List"
+}
+
+###
+
+GET {{Sample.Datasync.Server.SingleContainer_HostAddress}}/tables/TodoList
+Accept: application/json
+
+###
diff --git a/...async-server-cosmosdb/Sample.Datasync.Server.SingleContainer/appsettings.Development.json b/...async-server-cosmosdb/Sample.Datasync.Server.SingleContainer/appsettings.Development.json
@@ -0,0 +1,8 @@
+{
+  "Logging": {
+    "LogLevel": {
+      "Default": "Information",
+      "Microsoft.AspNetCore": "Warning"
+    }
+  }
+}
diff --git a/...c-server/datasync-server-cosmosdb/Sample.Datasync.Server.SingleContainer/appsettings.json b/...c-server/datasync-server-cosmosdb/Sample.Datasync.Server.SingleContainer/appsettings.json
@@ -0,0 +1,9 @@
+{
+  "Logging": {
+    "LogLevel": {
+      "Default": "Information",
+      "Microsoft.AspNetCore": "Warning"
+    }
+  },
+  "AllowedHosts": "*"
+}
diff --git a/...ommunityToolkit.Datasync.Server.CosmosDb/CommunityToolkit.Datasync.Server.CosmosDb.csproj b/...ommunityToolkit.Datasync.Server.CosmosDb/CommunityToolkit.Datasync.Server.CosmosDb.csproj
@@ -0,0 +1,19 @@
+<Project Sdk="Microsoft.NET.Sdk">
+
+  <PropertyGroup>
+    <ImplicitUsings>enable</ImplicitUsings>
+    <Nullable>enable</Nullable>
+  </PropertyGroup>
+
+  <ItemGroup>
+    <ProjectReference Include="..\CommunityToolkit.Datasync.Server.Abstractions\CommunityToolkit.Datasync.Server.Abstractions.csproj" />
+  </ItemGroup>
+
+  <ItemGroup>
+    <PackageReference Include="Microsoft.Azure.Cosmos" />
+    <PackageReference Include="Microsoft.Extensions.DependencyInjection.Abstractions" />
+    <PackageReference Include="Microsoft.Extensions.Logging.Abstractions" />
+    <PackageReference Include="Newtonsoft.Json" />
+  </ItemGroup>
+
+</Project>