output.h

Go to the documentation of this file.

// === output.h ========================================================================================================
//                                               Sen Infrastructure
//                   Released under the Apache License v2.0 (SPDX-License-Identifier Apache-2.0).
//                                    See the LICENSE.txt file for more information.
//                   © Airbus SAS, Airbus Helicopters, and Airbus Defence and Space SAU/GmbH/SAS.
// =====================================================================================================================
 
#ifndef SEN_DB_OUTPUT_H
#define SEN_DB_OUTPUT_H
 
// sen
#include "sen/core/base/class_helpers.h"
#include "sen/core/base/timestamp.h"
#include "sen/core/meta/type.h"
 
// generated code
#include "stl/sen/db/basic_types.stl.h"
#include "stl/sen/kernel/basic_types.stl.h"
 
// std
#include <functional>
 
namespace sen::db
{

using ErrorHandler = std::function<void()>;

struct ObjectInfo
{
  const Object* instance;
  std::string session;
  std::string bus;
};

using ObjectInfoList = std::vector<ObjectInfo>;

class Output
{
  SEN_MOVE_ONLY(Output)
 
public:
  Output(OutSettings settings, std::function<void()> errorHandler);
  ~Output();
 
public:
  [[nodiscard]] const OutSettings& getSettings() const noexcept;

  [[nodiscard]] const TimeStamp& getCreationTime() const noexcept;

  [[nodiscard]] OutStats fetchStats() const;
 
public:
  void keyframe(TimeStamp time, const ObjectInfoList& objects);

  void creation(TimeStamp time, const ObjectInfo& object, bool indexed);

  void deletion(TimeStamp time, ObjectId objectId);

  void propertyChange(TimeStamp time, ObjectId objectId, MemberHash propertyId, ::sen::kernel::Buffer&& propertyValue);

  void event(TimeStamp time, ObjectId objectId, MemberHash eventId, ::sen::kernel::Buffer&& args);

  void annotation(TimeStamp time, const Type* type, ::sen::kernel::Buffer&& value);
 
private:
  class Impl;
 
private:
  std::unique_ptr<Impl> pimpl_;
};
 
}  // namespace sen::db
 
#endif  // SEN_DB_OUTPUT_H