application.h

/*
 * Copyright 2007-2025, RTE (https://www.rte-france.com)
 * See AUTHORS.txt
 * SPDX-License-Identifier: MPL-2.0
 * This file is part of Antares-Simulator,
 * Adequacy and Performance assessment for interconnected energy networks.
 *
 * Antares_Simulator is free software: you can redistribute it and/or modify
 * it under the terms of the Mozilla Public Licence 2.0 as published by
 * the Mozilla Foundation, either version 2 of the License, or
 * (at your option) any later version.
 *
 * Antares_Simulator is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
 * Mozilla Public Licence 2.0 for more details.
 *
 * You should have received a copy of the Mozilla Public Licence 2.0
 * along with Antares_Simulator. If not, see <https://opensource.org/license/mpl-2-0/>.
 */
#pragma once
 
#include <yuni/core/string.h>
 
#include <antares/benchmarking/DurationCollector.h>
#include <antares/benchmarking/timer.h>
#include <antares/study/load-options.h>
#include <antares/study/study.h>
#include <antares/writer/i_writer.h>
#include "antares/infoCollection/StudyInfoCollector.h"
#include "antares/solver/misc/options.h"
#include "antares/solver/simulation/ISimulationObserver.h"
 
namespace Antares::Solver
{
class Application final: public Yuni::IEventObserver<Application, Yuni::Policy::SingleThreaded>
{
public:
 
 
    Application();
    ~Application() override;
 
    Application(const Application&) = delete;
 
    Application& operator=(const Application&) = delete;
 
    void prepare(int argc, const char* argv[]);
 
    void execute();
 
    void resetProcessPriority() const;
 
    void writeExectutionInfo();
 
    std::unique_ptr<Data::Study> acquireStudy()
    {
        return std::move(pStudy);
    }
 
private:
    enum class LogType
    {
        Warning,
        Error
    };
 
    void resetLogFilename() const;
 
    void readDataForTheStudy(Antares::Data::StudyLoadOptions& options);
 
    void onLogMessage(int level, const std::string& message);
 
    Settings pSettings;
    std::unique_ptr<Antares::Data::Study> pStudy;
    Antares::Data::Parameters* pParameters = nullptr;
    uint pErrorCount = 0;
    uint pWarningCount = 0;
 
    int pArgc = 0;
    const char** pArgv = nullptr;
 
    // Benchmarking
    Benchmarking::DurationCollector pDurationCollector;
    Benchmarking::OptimizationInfo pOptimizationInfo;
 
    std::shared_ptr<Yuni::Job::QueueService> ioQueueService;
    IResultWriter::Ptr resultWriter = nullptr;
    std::vector<std::pair<LogType, std::string>> messagesStack;
 
    void prepareWriter(const Antares::Data::Study& study,
                       Benchmarking::DurationCollector& duration_collector);
 
    void writeComment(Data::Study& study);
    void readStudy_makeChecks_and_printThings(Data::StudyLoadOptions& options);
    // Return false if the user requested the version ,available solvers, etc, true otherwise
    bool handleOptions(const Data::StudyLoadOptions& options);
    void LogMessageStack(std::vector<std::pair<LogType, std::string>>& stack);
    // Return false if the user requested help, true otherwise
    bool parseCommandLine(Data::StudyLoadOptions& options);
    void postParametersChecks() const;
}; // class Application
 
} // namespace Antares::Solver