io.hpp

#ifndef TOFIO_H_INCLUDED
#define TOFIO_H_INCLUDED
 
#include <fstream>
#include <functional>
 
#include "result/result.h"
 
#include "events.h"
#include "packets/tof_packet.h"
#include "serialization.h"
#include "errors.hpp"
 
namespace r = result;
 
//template<typename T>
//requires HasFromByteStream<T>
//Vec<T> unpack<T>(String filename) {
//  usize pos = 0;
//  auto packets = get_tofpackets(filename);
//  for (const auto &p : packets) {
//    T data = T::from_bytestream(p.payload, 0);
// 
//
//  Vec<T> data;
//  return data;
//}
 
[[deprecated("This might not even be correct!")]]
Vec<u32> get_event_ids_from_raw_stream(const Vec<u8> &bytestream, u64 &start_pos);
 
Vec<TofPacket> get_tofpackets(const Vec<u8> &bytestream, u64 start_pos, PacketType filter=PacketType::Unknown);
 
Vec<TofPacket> get_tofpackets(const String filename, PacketType filter = PacketType::Unknown);
 
Vec<TofEvent> unpack_tofevents_from_tofpackets(const Vec<u8> &bytestream, u64 start_pos);
 
Vec<TofEvent> unpack_tofevents_from_tofpackets(const String filename);
 
namespace Gaps {
 
  class TofPacketReader {
    public: 
      TofPacketReader();
      TofPacketReader(String filename);
      TofPacketReader(const TofPacketReader&) = delete;
      //TofPacketReader& operator=(const TofPacketReader&) = delete;
      void set_filename(String filename);
      auto get_next_packet() -> r::Result<TofPacket, Gaps::IOError>;
      auto get_filename() const -> std::string;
      auto is_exhausted() const -> bool;
      auto n_packets_read() const -> usize;
 
    private:
      std::ifstream  stream_file_;
      bool           exhausted_;
      usize          n_packets_read_;
      String         filename_;
  };
}
 
 
#endif