Method analysis_phase

graphlite/src/txn/recovery.rs:99–147

Analysis phase: scan WAL to determine transaction states

(&mut self, report: &mut RecoveryReport)

    /// Analysis phase: scan WAL to determine transaction states
    fn analysis_phase(&mut self, report: &mut RecoveryReport) -> Result<(), RecoveryError> {
        log::debug!("🔍 Starting WAL analysis phase...");

        // Read all WAL files
        let mut file_number = 1u64;
        loop {
            match self.wal.read_wal_file(file_number) {
                Ok(entries) => {
                    report.total_wal_entries += entries.len();

                    for entry in entries {
                        self.process_entry_analysis(entry)?;
                    }

                    file_number += 1;
                }
                Err(WALError::IOError(msg)) if msg.contains("not found") => {
                    // No more WAL files
                    break;
                }
                Err(e) => {
                    return Err(RecoveryError::WALRead(e.to_string()));
                }
            }
        }

        // Determine which transactions need recovery
        for (txn_id, state) in &self.recovered_transactions {
            match state.status {
                RecoveryStatus::InProgress => {
                    report.incomplete_transactions.push(*txn_id);
                }
                RecoveryStatus::Committed => {
                    report.committed_transactions.push(*txn_id);
                }
                RecoveryStatus::RolledBack => {
                    report.rolled_back_transactions.push(*txn_id);
                }
                _ => {}
            }
        }

        log::debug!(
            "✅ Analysis phase complete: {} transactions to recover",
            report.incomplete_transactions.len() + report.committed_transactions.len()
        );

        Ok(())
    }

    /// Process a WAL entry during analysis
    fn process_entry_analysis(&mut self, entry: WALEntry) -> Result<(), RecoveryError> {