any_message_log_reader.h

Go to the documentation of this file.

// Copyright (c) Space-ng, inc. All rights reserved.
 
#pragma once
 
#include "sol3/core/message_schema.h"
#include "sol3/core/size_delimited_log_reader.h"
#include "sol3/cpp/filesystem.h"
 
#include <flatbuffers/flatbuffers.h>
 
#include <cstddef>
#include <memory>
#include <optional>
#include <string>
#include <string_view>
#include <vector>
 
namespace sol3::core {
class AnyMessageLogReader {
 public:
  explicit AnyMessageLogReader(cpp::fs::path const& log_path);
 
  class Item {
   public:
    explicit Item(
        SizeDelimitedLogReader::Iterator header_it,
        SizeDelimitedLogReader::Iterator payload_it);
 
    tl::expected<
        SizeDelimitedLogReader::FrameView,
        SizeDelimitedLogReader::ReadError>
    headerView() const;
    tl::expected<
        SizeDelimitedLogReader::FrameView,
        SizeDelimitedLogReader::ReadError>
    payloadView() const;
 
   private:
    SizeDelimitedLogReader::Iterator header_it_;
    SizeDelimitedLogReader::Iterator payload_it_;
  };
 
  class Iterator {
   public:
    using value_type = Item;
    using reference = Item;
 
    Iterator() = default;
    explicit Iterator(
        SizeDelimitedLogReader::Iterator header_it,
        SizeDelimitedLogReader::Iterator payload_it);
    Iterator(Iterator const&) = default;
    Iterator& operator=(Iterator const& other) = default;
    Iterator(Iterator&&) = default;
    Iterator& operator=(Iterator&& other) = default;
    ~Iterator() = default;
 
    reference operator*() const;
    Iterator& operator++();
    bool operator==(Iterator const& other) const;
    bool operator!=(Iterator const& other) const;
 
   private:
    SizeDelimitedLogReader::Iterator header_it_;
    SizeDelimitedLogReader::Iterator payload_it_;
  };
 
  MessageSchema schemaForMessageLogHeader() const;
  MessageSchema schemaForMessageHeader() const;
  MessageSchema schemaForPayload() const;
 
  using ReadError = SizeDelimitedLogReader::ReadError;
 
  tl::expected<flatbuffers::span<uint8_t const>, ReadError> logHeaderSpan()
      const;
 
  Iterator begin() const;
  Iterator end() const;
 
 private:
  void open(cpp::fs::path const& log_path);
 
  std::shared_ptr<SizeDelimitedLogReader> reader_;
  MessageSchema log_header_schema_;
  MessageSchema message_header_schema_;
  MessageSchema payload_schema_;
  SizeDelimitedLogReader::Iterator log_header_it_;
};
}  // namespace sol3::core