fitsConverterIf.hpp

Go to the documentation of this file.

 
#ifndef RTCTK_STANDALONETOOLS_RAWRECORDER_FITSCONVERTERIF_HPP
#define RTCTK_STANDALONETOOLS_RAWRECORDER_FITSCONVERTERIF_HPP
 
#include <taiclock/taiClock.hpp>
 
#include <gsl/span>
 
#include <CCfits/CCfits.h>
#include <CCfits/FITS.h>
 
#include <llnetio/mudpi/mudpi.hpp>
#include <llnetio/rtms/rtms.hpp>
 
#include <cstdint>
#include <variant>
#include <vector>
 
using RtmsHeaderVariant = std::variant<llnetio::rtms::LeaderHeader,
                                       llnetio::rtms::PayloadHeader,
                                       llnetio::rtms::TrailerHeader>;
 
struct PacketData {
    llnetio::mudpi::Header mudpi_header;
    llnetio::rtms::CommonHeader rtms_header;
    RtmsHeaderVariant rtms_variant;
    taiclock::TaiClock::time_point pcap_timestamp;
    gsl::span<const uint8_t> payload;
};
 
class FitsConverterIf {
public:
    FitsConverterIf(const std::string& directory, bool split_files);
    virtual ~FitsConverterIf();
    virtual void WriteData(const PacketData& data) = 0;
    void SetStoreSampleIds(bool store) {
        m_store_sampleids = store;
    }

    void SetStoreTimestamps(bool store) {
        m_store_timestamps = store;
    }

    bool GetStoreSampleIds() {
        return m_store_sampleids;
    }

    bool GetStoreTimestamps() {
        return m_store_timestamps;
    }

    bool GetSplitFiles() {
        return m_split_files;
    }

    const std::string& GetDirectory() {
        return m_directory;
    }
 
protected:
    const bool IsOpen() {
        return m_fits_handle != nullptr;
    }
    void Open(const std::string& file);
    void Close();
    void SetFitsHandle(std::unique_ptr<CCfits::FITS>&& handle);
    CCfits::FITS& GetFitsHandle();
 
private:
    std::unique_ptr<CCfits::FITS> m_fits_handle;
    std::string m_directory;
    bool m_split_files;
    bool m_store_timestamps;
    bool m_store_sampleids;
};
 
#endif  // RTCTK_STANDALONETOOLS_RAWRECORDER_FITSCONVERTERIF_HPP