xrit_channel_processor.h

Go to the documentation of this file.

#pragma once

 
#include "image/image.h"
#include "products/image_product.h"
#include "xrit/segment_decoder.h"
#include "xrit/xrit_file.h"
#include <mutex>
 
namespace satdump
{
    namespace xrit
    {
        class XRITChannelProcessor
        {
        private:
            std::map<std::string, std::shared_ptr<SegmentedImageDecoder>> segmented_decoders;
 
        private:
            struct XRITProd
            {
                std::string directory_path;
                std::string pro_f_path;
                std::shared_ptr<products::ImageProduct> pro;
            };
 
        private:
            XRITProd setupProduct(xrit::XRITFileInfo &meta);

            bool saveMeta(xrit::XRITFileInfo &meta, XRITFile &file);

            void saveImg(xrit::XRITFileInfo &meta, image::Image &img);
 
        private:
            // TODOREWORK DOCUMENT
            void process_composites(std::shared_ptr<products::ImageProduct> pro, std::string pro_path);
 
        public:
            enum xrit_image_status
            {
                RECEIVING,
                SAVING,
                IDLE
            };
 
            struct wip_images
            {
                xrit_image_status imageStatus = RECEIVING;
                const int img_width = 256, img_height = 256;
 
                // UI Stuff
                bool hasToUpdate = false;
                unsigned int textureID = 0;
                uint32_t *textureBuffer;
            };
 
            std::map<std::string, std::unique_ptr<wip_images>> all_wip_images;
            std::mutex ui_img_mtx;
 
        public:
            std::string directory = "";
            bool in_memory_mode = false;
            std::map<std::string, std::shared_ptr<products::ImageProduct>> in_memory_products;
 
        public:
            ~XRITChannelProcessor();

            void push(xrit::XRITFileInfo &finfo, XRITFile &file);

            void flush();
        };
    } // namespace xrit
} // namespace satdump