Request snapshot aliases by record key

src/GameCult.Mesh/CultMeshSnapshots.cs

@@ -291,7 +291,7 @@ namespace GameCult.Mesh
             var descriptor = CultDocumentRegistry.Shared.GetRequired<TDocument>();
             return CultMesh.FetchSnapshotDocumentsAsync<TDocument>(
                 Endpoint,
-                CreateRequest(schemaIds ?? new[] { descriptor.SchemaId }, recordKeys),
+                CreateRequest(ResolveDefaultSchemaFilter(schemaIds, recordKeys, descriptor), recordKeys),
                 DocumentRegistry);
         }
 
@@ -308,7 +308,7 @@ namespace GameCult.Mesh
             var descriptor = CultDocumentRegistry.Shared.GetRequired<TDocument>();
             var result = await SyncSnapshotAsync(
                     node,
-                    schemaIds ?? new[] { descriptor.SchemaId },
+                    ResolveDefaultSchemaFilter(schemaIds, recordKeys, descriptor),
                     recordKeys,
                     flush)
                 .ConfigureAwait(false);
@@ -448,6 +448,19 @@ namespace GameCult.Mesh
             return request;
         }
 
+        private static IReadOnlyList<string>? ResolveDefaultSchemaFilter(
+            IReadOnlyList<string>? schemaIds,
+            IReadOnlyList<string>? recordKeys,
+            CultDocumentDescriptor descriptor)
+        {
+            if (schemaIds != null)
+                return schemaIds;
+
+            return recordKeys is { Count: > 0 }
+                ? null
+                : new[] { descriptor.SchemaId };
+        }
+
         private static CultMeshSnapshotRequestOptions CloneSnapshotRequestOptions(CultMeshSnapshotRequestOptions? source)
         {
             if (source == null)

tests/GameCult.Mesh.Tests/CultMeshStreamingTests.cs

@@ -2486,10 +2486,7 @@ public sealed class CultMeshStreamingTests
         syncedCatalogAlias.Text.Should().Be("snapshot-endpoint-catalog-synced");
         requests.Should().HaveCount(6);
         requests.Should().OnlyContain(request =>
-            request.SchemaIds!.SequenceEqual(new[]
-            {
-                CultDocumentRegistry.Shared.GetRequired<MeshNoteAliasDocument>().SchemaId
-            }) &&
+            request.SchemaIds == null &&
             request.RecordKeys!.SequenceEqual(new[] { key.Value }) &&
             request.ShardId == "primary" &&
             request.ShardEpoch == 9 &&