Update internal/storage/transactions.go

internal/storage/transactions.go

@@ -54,6 +54,9 @@
 //   - GetAllSagas у SagaManager — читает все SAGA (включая завершённые)
 //     с диска через SagaPersistentStorage.ListAll(). Используется
 //     REPL-командой "saga list --all".
+//
+// ИЗМЕНЕНО (2026-10): удалён AOF. BatchManager больше не содержит
+// поле aof, и Commit не пишет в AOF. Единственный источник истины — WAL.
 
 package storage
 
@@ -209,7 +212,6 @@ type BatchManager struct {
 	logger      LoggerInterface
 	walPath     string
 	stats       *BatchStats
-	aof         *AOFManager
 
 	// activeBatches — реестр активных (незакоммиченных) batch'ей.
 	activeBatches sync.Map
@@ -261,13 +263,6 @@ func InitBatchManagerWithConfig(walPath string, config map[string]interface{}) e
 		if err != nil {
 			return
 		}
-
-		globalBatchManager.aof, err = NewAOFManager(
-			filepath.Join(filepath.Dir(walPath), "aof"),
-			fsyncEnabled, nil)
-		if err != nil {
-			return
-		}
 	})
 	return err
 }
@@ -282,9 +277,6 @@ func SetBatchLogger(logger LoggerInterface) {
 		if globalBatchManager.wal != nil {
 			globalBatchManager.wal.logger = logger
 		}
-		if globalBatchManager.aof != nil {
-			globalBatchManager.aof.SetLogger(logger)
-		}
 	}
 }
 
@@ -442,14 +434,6 @@ func (b *Batch) Commit() error {
 		return fmt.Errorf("batch apply failed: %v", err)
 	}
 
-	if globalBatchManager.aof != nil {
-		if err := globalBatchManager.aof.AppendBatch(b); err != nil {
-			if globalBatchManager.logger != nil {
-				globalBatchManager.logger.Warn(fmt.Sprintf("AOF append failed: %v", err))
-			}
-		}
-	}
-
 	globalBatchManager.stats.TotalBatches.Add(1)
 	globalBatchManager.stats.TotalOperations.Add(uint64(len(b.Operations)))
 	return nil
@@ -1106,6 +1090,7 @@ func (im *WALIndexManager) load() error {
 	}
 	return json.Unmarshal(data, &im.index)
 }
+
 // =============================================================================
 // SAGA — ИНТЕРФЕЙСЫ ДЛЯ RAFT
 // =============================================================================
@@ -2602,9 +2587,6 @@ func StopBatchManager() error {
 		globalBatchManager.wal.Sync()
 		globalBatchManager.wal.Close()
 	}
-	if globalBatchManager.aof != nil {
-		globalBatchManager.aof.Close()
-	}
 	return nil
 }