recovery_worker.hpp

Go to the documentation of this file.

#pragma once
 
#include "models.hpp"
#include "recovery_exporter.hpp"
 
#include <atomic>
#include <functional>
#include <string>
#include <thread>
#include <vector>
 
struct RecoveryResult {
    bool ok {false};
    RecoverySummary summary;
    std::vector<std::string> logs;
    std::string error;
};
 
class RecoveryWorker {
public:
    using CompletionCallback = std::function<void(const RecoveryResult&)>;
 
    RecoveryWorker();
    ~RecoveryWorker();
 
    void start(const ScanReport& report,
               const std::string& output_dir,
               const std::vector<size_t>& selected_result_indices,
               CompletionCallback cb);
    bool running() const;
    void join();
    std::atomic<bool> cancel_requested_{false};
 
    void request_cancel();
private:
    std::atomic<bool> running_ {false};
    std::thread thread_;
};