feat: update MsSqlDataStore schema hash and timestamp on sync

After sync, compare the new schema hash with the stored one. If they
differ, update SchemaHash, LastSchemaImport, and clear NeedsResync on
the MsSqlDataStoreConfiguration.

Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>

Author: Mike Blair

src/FractalDataWorks.Data.DataStores.SqlServer/MsSqlSchemaImportPersister.cs

@@ -33,6 +33,7 @@ public sealed class MsSqlSchemaImportPersister : ISchemaImportPersister
     private readonly IOptionsMonitor<List<DataContainerConfiguration>> _containerOptions;
     private readonly IOptionsMonitor<List<DataContainerFieldConfiguration>> _fieldOptions;
     private readonly IOptionsMonitor<List<Services.Connections.MsSql.MsSqlConnectionConfiguration>> _connectionOptions;
+    private readonly IOptionsMonitor<List<Services.Connections.MsSql.MsSqlDataStoreConfiguration>> _msSqlDataStoreOptions;
     private readonly ILogger<MsSqlSchemaImportPersister> _logger;
 
     /// <summary>
@@ -43,20 +44,23 @@ public sealed class MsSqlSchemaImportPersister : ISchemaImportPersister
     /// <param name="containerOptions">Options monitor for container configurations.</param>
     /// <param name="fieldOptions">Options monitor for field configurations.</param>
     /// <param name="connectionOptions">Options monitor for MsSql connection configurations.</param>
+    /// <param name="msSqlDataStoreOptions">Options monitor for MsSql data store configurations.</param>
     /// <param name="logger">Logger instance.</param>
     public MsSqlSchemaImportPersister(
         IConfigurationWriterFactory writerFactory,
         IOptionsMonitor<List<DataPathConfiguration>> dataPathOptions,
         IOptionsMonitor<List<DataContainerConfiguration>> containerOptions,
         IOptionsMonitor<List<DataContainerFieldConfiguration>> fieldOptions,
         IOptionsMonitor<List<Services.Connections.MsSql.MsSqlConnectionConfiguration>> connectionOptions,
+        IOptionsMonitor<List<Services.Connections.MsSql.MsSqlDataStoreConfiguration>> msSqlDataStoreOptions,
         ILogger<MsSqlSchemaImportPersister> logger)
     {
         _writerFactory = writerFactory ?? throw new ArgumentNullException(nameof(writerFactory));
         _dataPathOptions = dataPathOptions ?? throw new ArgumentNullException(nameof(dataPathOptions));
         _containerOptions = containerOptions ?? throw new ArgumentNullException(nameof(containerOptions));
         _fieldOptions = fieldOptions ?? throw new ArgumentNullException(nameof(fieldOptions));
         _connectionOptions = connectionOptions ?? throw new ArgumentNullException(nameof(connectionOptions));
+        _msSqlDataStoreOptions = msSqlDataStoreOptions ?? throw new ArgumentNullException(nameof(msSqlDataStoreOptions));
         _logger = logger ?? throw new ArgumentNullException(nameof(logger));
     }
 
@@ -142,7 +146,7 @@ public async Task<IGenericResult<Guid>> Persist(
     }
 
     /// <inheritdoc />
-    [ConventionOverride(MaxMethodLines = 70)]
+    [ConventionOverride(MaxMethodLines = 75)]
     public async Task<IGenericResult<SchemaImportSyncResult>> Sync(
         Guid existingDataStoreId,
         IDataStore dataStore,
@@ -232,6 +236,9 @@ await DeleteRemovedPaths(
 
         var newSchemaHash = ComputeSchemaHash(schemaBuilder.ToString());
 
+        // Update MsSqlDataStore hash and timestamp if schema changed
+        await UpdateDataStoreSchemaHash(existingDataStoreId, newSchemaHash, cancellationToken).ConfigureAwait(false);
+
         var syncResult = new SchemaImportSyncResult
         {
             DataStoreId = existingDataStoreId,
@@ -809,6 +816,33 @@ private static async Task DeleteRemovedFields(
         }
     }
 
+    private async Task UpdateDataStoreSchemaHash(Guid dataStoreId, string newSchemaHash, CancellationToken cancellationToken)
+    {
+        var dataStores = _msSqlDataStoreOptions.CurrentValue ?? [];
+        var msSqlDataStore = dataStores.Find(ds => ds.DataStoreId == dataStoreId);
+        if (msSqlDataStore is null)
+        {
+            return;
+        }
+
+        if (string.Equals(msSqlDataStore.SchemaHash, newSchemaHash, StringComparison.Ordinal))
+        {
+            return;
+        }
+
+        var writerResult = _writerFactory.Create<Services.Connections.MsSql.MsSqlDataStoreConfiguration>();
+        if (!writerResult.IsSuccess)
+        {
+            return;
+        }
+
+        msSqlDataStore.SchemaHash = newSchemaHash;
+        msSqlDataStore.LastSchemaImport = DateTimeOffset.UtcNow;
+        msSqlDataStore.NeedsResync = false;
+
+        await writerResult.Value!.Save(msSqlDataStore, cancellationToken).ConfigureAwait(false);
+    }
+
     private async Task UpdateConnectionAssociation(Guid connectionId, Guid dataStoreId)
     {
         var connectionWriterResult = _writerFactory.Create<Services.Connections.MsSql.MsSqlConnectionConfiguration>();