mirror of
https://github.com/SatDump/SatDump
synced 2026-08-13 17:47:30 -04:00
92 lines
No EOL
3.1 KiB
C++
92 lines
No EOL
3.1 KiB
C++
#include "logger.h"
|
|
#include "module.h"
|
|
#include "pipeline.h"
|
|
#include <signal.h>
|
|
#include <filesystem>
|
|
#include "nlohmann/json.hpp"
|
|
#include <fstream>
|
|
|
|
int main(int argc, char *argv[])
|
|
{
|
|
// Ignore SIGPIPE
|
|
#ifndef _WIN32
|
|
signal(SIGPIPE, SIG_IGN);
|
|
#endif
|
|
|
|
initLogger();
|
|
|
|
if (argc < 6)
|
|
{
|
|
logger->info("Usage : " + std::string(argv[0]) + " [downlink] [input_level] [input_file] [output_level] [output_file_or_directory]");
|
|
exit(1);
|
|
}
|
|
|
|
std::string downlink_pipeline = argv[1];
|
|
std::string input_level = argv[2];
|
|
std::string input_file = argv[3];
|
|
std::string output_level = argv[4];
|
|
std::string output_file = argv[5];
|
|
|
|
std::map<std::string, std::string> parameters;
|
|
|
|
if (argc > 6)
|
|
{
|
|
for (int i = 6; i < argc; i++)
|
|
{
|
|
if (i + 1 != argc)
|
|
{
|
|
if (strcmp(argv[i], "-samplerate") == 0) // This is your parameter name
|
|
{
|
|
parameters.emplace("samplerate", argv[i + 1]); // The next value in the array is your value
|
|
i++; // Move to the next flag
|
|
}
|
|
else if (strcmp(argv[i], "-baseband_format") == 0) // This is your parameter name
|
|
{
|
|
parameters.emplace("baseband_format", argv[i + 1]); // The next value in the array is your value
|
|
i++; // Move to the next flag
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
logger->info(" _____ __ ____ ");
|
|
logger->info(" / ___/____ _/ /_/ __ \\__ ______ ___ ____ ");
|
|
logger->info(" \\__ \\/ __ `/ __/ / / / / / / __ `__ \\/ __ \\");
|
|
logger->info(" ___/ / /_/ / /_/ /_/ / /_/ / / / / / / /_/ /");
|
|
logger->info("/____/\\__,_/\\__/_____/\\__,_/_/ /_/ /_/ .___/ ");
|
|
logger->info(" /_/ ");
|
|
logger->info("Starting SatDump v1.0");
|
|
logger->info("");
|
|
|
|
registerModules();
|
|
|
|
loadPipelines("pipelines");
|
|
|
|
logger->debug("Registered pipelines :");
|
|
for (Pipeline &pipeline : pipelines)
|
|
logger->debug(" - " + pipeline.name);
|
|
|
|
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_directory(output_file);
|
|
|
|
std::vector<Pipeline>::iterator it = std::find_if(pipelines.begin(),
|
|
pipelines.end(),
|
|
[&downlink_pipeline](const Pipeline &e) {
|
|
return e.name == downlink_pipeline;
|
|
});
|
|
|
|
if (it != pipelines.end())
|
|
{
|
|
it->run(input_file, output_file, parameters, input_level);
|
|
}
|
|
else
|
|
{
|
|
logger->critical("Pipeline " + downlink_pipeline + " does not exist!");
|
|
}
|
|
|
|
logger->info("Done! Goodbye");
|
|
} |