carbon_client.hpp

Go to the documentation of this file.

// Copyright (c) 2024-2025 Voyant Photonics, Inc.
// All rights reserved.
 
#pragma once
 
#include <carbon_client_ffi.hpp>
#include <carbon_config.hpp>
#include <csignal>
#include <cstdint>
#include <memory>
#include <sdl_types_generated.hpp>
#include <voyant_frame_wrapper.hpp>
#include <voyant_types_ffi.hpp>

class CarbonClient
{
public:
    explicit CarbonClient(const CarbonConfig& config);
 
    ~CarbonClient();
 
    // Non-copyable, non-movable (owns async runtime)
    CarbonClient(const CarbonClient&)            = delete;
    CarbonClient& operator=(const CarbonClient&) = delete;
    CarbonClient(CarbonClient&&)                 = delete;
    CarbonClient& operator=(CarbonClient&&)      = delete;

    bool start();

    void stop();

    bool isRunning() const;

    bool tryReceiveFrame();

    VoyantFrameWrapper&       latestFrame();
    const VoyantFrameWrapper& latestFrame() const;

    SensorState getSensorState() const;

    TimeSyncState getTimeSyncState() const;

    SdlStatus sendSdl(const SdlCommandParams& cmd);
    SdlStatus pollSdl();

    SdlStatus sendSdlBlocking(const SdlCommandParams& cmd);

    bool waitForHeartbeat();

    bool ensureIdleForCalibration();

    bool applyDefaultBackgroundNoise();

    bool refineBackgroundNoise(uint32_t iterations = 0);

    bool startPeakDump(const std::string& path, uint64_t maxFrames = 0, uint64_t maxPeaks = 0, bool addTimestamp = false);

    void stopPeakDump();

    bool isPeakDumping() const;

    static void setupSignalHandling(int signal = SIGINT);

    static bool isTerminated();

    static void resetTerminationFlag();
 
private:
    CarbonClientHandleC*       handle_; // opaque pointer — type defined in carbon_client_ffi.hpp
    std::unique_ptr<uint8_t[]> buffer_;
    static constexpr size_t    kBufferSize_ = 8 * 1024 * 1024; // 8MB
    VoyantFrameWrapper         latestFrame_;
 
    static volatile std::sig_atomic_t terminated_;
    static void                       signalHandler(int);
};

SdlCommandParams toSdlCommand(const SensorState& state);

SdlCommandParams makeLinescanCommand(SdlState reqState, float rampBandwidthGhz, float hfovCenterDeg = 0.0f);