Switch to memory storage for improved resilience

Author: kzu

src/Tests/ConversationStorageTests.cs

@@ -1,5 +1,17 @@
 namespace Devlooped.WhatsApp;
 
+class TestConversationStorage : ConversationStorage
+{
+    public TestConversationStorage(CloudStorageAccount storage) : base(storage) { }
+
+    protected override IDocumentRepository<IMessage> CreateMessagesRepository()
+        => new MemoryRepository<IMessage>("WhatsAppMessages", x => x.UserNumber, x => x.Id);
+    protected override ITableStorage<Conversation> CreateConversationsRepository()
+        => new MemoryRepository<Conversation>("WhatsAppConversations");
+    protected override IDocumentRepository<Conversation> CreateActiveConversationRepository()
+        => new MemoryRepository<Conversation>("WhatsAppActiveConversations", partitionKey: null, rowKey: _ => "active");
+}
+
 public class ConversationStorageTests
 {
     readonly static Service service = new("1234", "1234");
@@ -8,12 +20,7 @@ public class ConversationStorageTests
     [Fact]
     public async Task StoreAndLoadAdditionalProperties()
     {
-        CloudStorageAccount.DevelopmentStorageAccount.CreateTableServiceClient()
-            .CreateTableIfNotExists("WhatsAppMessages");
-        CloudStorageAccount.DevelopmentStorageAccount.CreateTableServiceClient()
-            .CreateTableIfNotExists("WhatsAppConversations");
-
-        var storage = new ConversationStorage(CloudStorageAccount.DevelopmentStorageAccount);
+        var storage = new TestConversationStorage(CloudStorageAccount.DevelopmentStorageAccount);
         var messageId = Ulid.NewUlid().ToString();
         var conversationId = Ulid.NewUlid().ToString();
 

src/Tests/IntegrationTests.cs

@@ -33,14 +33,10 @@ public async Task RunConversationAsync()
                 { "Meta:Numbers:1234567890", "test-access-token" }
             })
             .Build();
-        var services = new ServiceCollection()
-            .AddSingleton(CloudStorageAccount.DevelopmentStorageAccount)
-            .AddSingleton<IConfiguration>(configuration);
 
-        CloudStorageAccount.DevelopmentStorageAccount.CreateTableServiceClient()
-            .CreateTableIfNotExists("WhatsAppMessages");
-        CloudStorageAccount.DevelopmentStorageAccount.CreateTableServiceClient()
-            .CreateTableIfNotExists("WhatsAppConversations");
+        var services = new ServiceCollection()
+            .AddSingleton<IConfiguration>(configuration)
+            .AddSingleton<IConversationStorage>(new TestConversationStorage(CloudStorageAccount.DevelopmentStorageAccount));
 
         IEnumerable<IMessage>? messages = null;
 

src/Tests/Tests.csproj

@@ -12,7 +12,7 @@
 
   <ItemGroup>
     <PackageReference Include="coverlet.collector" Version="6.0.4" />
-    <PackageReference Include="Devlooped.TableStorage.Memory" Version="5.3.1" />
+    <PackageReference Include="Devlooped.TableStorage.Memory" Version="5.4.0" />
     <PackageReference Include="Microsoft.CodeAnalysis.CSharp.Analyzer.Testing" Version="1.1.2" />
     <PackageReference Include="Microsoft.CodeAnalysis.CSharp.Workspaces" Version="4.13.0" />
     <PackageReference Include="Microsoft.Extensions.Configuration" Version="9.0.7" />
@@ -42,7 +42,7 @@
 
   <ItemGroup>
     <Content Include="Content\**\*.*" CopyToOutputDirectory="PreserveNewest" />
-    <ProjectProperty Include="BundledNETCoreAppPackageVersion"/>
+    <ProjectProperty Include="BundledNETCoreAppPackageVersion" />
   </ItemGroup>
 
 </Project>