mirror of
https://github.com/SatDump/SatDump
synced 2026-08-13 17:47:30 -04:00
39 lines
No EOL
1.3 KiB
C++
39 lines
No EOL
1.3 KiB
C++
#include "logger.h"
|
|
#include "module.h"
|
|
#include "pipeline.h"
|
|
#include <filesystem>
|
|
#include "nlohmann/json.hpp"
|
|
#include <fstream>
|
|
#include "processing.h"
|
|
#include "main_ui.h"
|
|
|
|
namespace processing
|
|
{
|
|
void process(std::string downlink_pipeline,
|
|
std::string input_level,
|
|
std::string input_file,
|
|
std::string output_level,
|
|
std::string output_file,
|
|
nlohmann::json parameters)
|
|
{
|
|
satdumpUiStatus = OFFLINE_PROCESSING;
|
|
|
|
logger->info("Starting processing pipeline " + downlink_pipeline + "...");
|
|
logger->debug("Input file (" + input_level + ") : " + input_file);
|
|
logger->debug("Output file (" + output_level + ") : " + output_file);
|
|
|
|
if (!std::filesystem::exists(output_file))
|
|
std::filesystem::create_directories(output_file);
|
|
|
|
// Get pipeline
|
|
std::optional<Pipeline> pipeline = getPipelineFromName(downlink_pipeline);
|
|
|
|
if (pipeline.has_value())
|
|
pipeline.value().run(input_file, output_file, parameters, input_level, true, uiCallList, uiCallListMutex);
|
|
else
|
|
logger->critical("Pipeline " + downlink_pipeline + " does not exist!");
|
|
|
|
logger->info("Done! Goodbye");
|
|
satdumpUiStatus = MAIN_MENU;
|
|
}
|
|
} |