caraspace.hpp

#ifndef CARASPACE_H_INCLUDED
#define CARASPACE_H_INCLUDED
#include <iostream>
#include <fstream>
#include <cmath>
 
#include "tof_typedefs.h"
#include "packets/tof_packet.h"
#include "telemetry_dataclasses.hpp"
#include "calibration.h"
#include "errors.hpp"
#include "result/result.h"
#ifdef BUILD_CXXDB
#include "database.h"
#endif
 
namespace r = result;
 
namespace Gaps {
  std::vector<std::string> list_path_contents_sorted(const std::string& input);
 
  enum class CRFrameObjectType : u8 {
    Unknown           = 0,
    TofPacket         = 10,
    TelemetryPacket   = 20,
  };
 
  struct CRFrameObject {
    static constexpr u16 HEAD = 0xAAAA;
    static constexpr u16 TAIL = 0x5555;
    
    u8 version;
    CRFrameObjectType ftype;
    Vec<u8> payload;
  
    static auto from_bytestream(Vec<u8> stream, usize &pos) -> CRFrameObject;
     
    auto to_string() -> std::string;
  };
 
 
  struct CRFrame {
    static constexpr u16 HEAD = 0xAAAA;
    static constexpr u16 TAIL = 0x5555;
      
    static auto from_bytestream(Vec<u8> stream, usize &pos) -> CRFrame;
    
    std::map<std::string, std::tuple<u64, CRFrameObjectType>> index;
    Vec<u8> bytestorage;
    auto to_string() const -> std::string;
    
    static auto parse_index(Vec<u8> stream, usize &pos) -> std::map<std::string, std::tuple<u64, CRFrameObjectType>>;
 
    auto get_tofpacket(std::string name) -> r::Result<TofPacket,Gaps::IOError>;
    auto get_telemetrypacket(std::string name) -> Gaps::Telemetry::Packet;
  };
 
  struct CRReader {
    CRReader();
    CRReader(std::string pathname);
    CRReader(const CRReader&) = delete;
    
    auto set_path(std:: string pathname) -> void;
    auto get_next_frame()       -> CRFrame;
    auto get_filenames()  const -> Vec<std::string>;
    auto is_exhausted()   const -> bool;
    auto n_packets_read() const -> bool;
    auto get_rbcalibrations(u8 n_rb) -> RBCalibrationMap;     
 
  private:  
    #ifdef BUILD_CXXDB
    TofPaddleMap     paddles_          ; 
    #endif 
    bool             exhausted_        ;
    usize            n_packets_read_   ;
    Vec<std::string> filenames_        ;
    std::ifstream    stream_file_      ;
    usize            fileindex_        ;
    auto             prime_next_file_() -> void;
  };
}
#endif