loadTableSnapshot method

@override Future<List<Map<String, dynamic>>?> loadTableSnapshot(String tableName)

Implementation

@override
Future<List<Map<String, dynamic>>?> loadTableSnapshot(
  String tableName,
) async {
  return _tracked(() async {
    await _ensureInitialized();
    return _locks.getTableLock(tableName).synchronized(() async {
      final file = _tableFile(tableName);
      final content = await _fileStore.readWithFallback(file);
      if (content == null) return null;

      try {
        final data = jsonDecode(content);
        if (data is! List) {
          throw FormatException(
            'Expected JSON list, got ${data.runtimeType}',
          );
        }
        await _fileStore.cleanupBackup(file);
        return data.cast<Map<String, dynamic>>();
      } catch (e) {
        SdkLogger.e('Failed to parse table snapshot for "$tableName": $e');
        final backupFile = File('${file.path}.bak');
        if (await backupFile.exists()) {
          try {
            final backupContent = await backupFile.readAsString();
            final data = jsonDecode(backupContent);
            if (data is! List) {
              throw FormatException(
                'Expected JSON list in backup, got ${data.runtimeType}',
              );
            }
            SdkLogger.i(
              'Recovered table snapshot for "$tableName" from backup',
            );
            return data.cast<Map<String, dynamic>>();
          } catch (backupError) {
            SdkLogger.e(
              'Backup also corrupted for "$tableName": $backupError',
            );
          }
        }
        return null;
      }
    });
  });
}