RestApiSolver.h

Go to the documentation of this file.

 
 
#ifndef REST_API_SOLVER_H
#define REST_API_SOLVER_H
 
#include "ThermalHydraulicSolver.h"
#include <string>
#include <vector>
#include <map>
 
class RestApiSolver : public ThermalHydraulicSolver {
public:
    explicit RestApiSolver(const std::string& base_url);
 
    // ---- Sequence execution ----
 
    void runSequence(SolverCallback& cb) override;
 
    // ---- State accessors ----
    double currentTime() const override;        
    int stopFlag() const override;              
    bool isTerminateAll() const override;       
    void setTerminateAll(bool v) override;      
 
    // ---- Branch control ----
    void setBranchCount(int n) override;        
    void setGenNode(bool v) override;           
 
    // ---- Restart lifecycle ----
    void setNewRestart(bool v) override;        
 
    void setInputDeck(const std::string& path) override;
 
    // ---- Checkpoint/restore ----
 
    std::vector<char> checkpoint() override;
 
    void restore(const std::vector<char>& data) override;
 
    // ---- Configuration ----
    void setThermoCacheMode(int mode) override; 
    void setMembufMode(int mode) override;      
 
private:
    std::string base_url_;
    std::string session_id_;
    std::string last_checkpoint_id_;
 
    bool first_sequence_ = true;
    int checkpoint_counter_ = 0;
 
    // ncount → checkpoint_id mappings
    std::map<int, std::string> seq_checkpoints_;       // accumulated during current sequence
    std::map<int, std::string> restore_checkpoints_;   // loaded from restore() buffer
 
    // HTTP helpers
    std::string httpPost(const std::string& path, const std::string& body = "{}");
    std::string httpGet(const std::string& path);
    std::string httpDelete(const std::string& path);
 
    // Create/destroy session
    void createSession(bool fresh);
    void destroySession();
 
    // Populate r5pars_ from JSON response
    void populateR5Pars(const std::string& json_str);
 
    // Send pending interactive variable changes to solver
    void sendInterventions();
 
    // Parse ncount value from indeck.i (line "103 <ncount>")
    static int parseNcountFromIndeck(const std::string& path);
 
    // Snapshot of inter_val[] to detect changes
    std::map<int, double> last_inter_val_;
};
 
#endif // REST_API_SOLVER_H