SigningChannel.h

Go to the documentation of this file.

#pragma once
 
#include <QtCore/QByteArrayView>
#include <QtCore/QDeadlineTimer>
#include <QtCore/QReadWriteLock>
#include <QtCore/QString>
#include <atomic>
#include <cstdint>
 
#include "AutoSuspendGuard.h"
#include "MAVLinkMessageType.h"
#include "MAVLinkSigning.h"
 
class SigningController;
 
class SigningChannel
{
public:
    SigningChannel() = default;
    ~SigningChannel() = default;
    SigningChannel(const SigningChannel&) = delete;
    SigningChannel& operator=(const SigningChannel&) = delete;
    SigningChannel(SigningChannel&&) = delete;
    SigningChannel& operator=(SigningChannel&&) = delete;
 
    static constexpr uint64_t kPersistedTimestampSafetyBumpTicks = 6'000'000;
 
    bool init(mavlink_channel_t channel, QByteArrayView key, mavlink_accept_unsigned_t callback,
              uint64_t persistedTimestamp = 0, const QString& keyName = {}, bool signOutgoing = true);
 
    bool setAcceptUnsignedCallback(mavlink_accept_unsigned_t callback);
 
    bool isEnabled() const;
    int streamCount() const;
 
    QString keyHint() const;
    void setKeyHint(const QString& name);
    void clearKeyHint();
 
    struct TimestampSnapshot
    {
        uint64_t timestamp;
        QString keyName;
    };
 
    TimestampSnapshot currentTimestampAndName() const;
 
    bool refreshOutgoingTimestamp();
 
    bool signOutgoing(mavlink_message_t& message);
 
    bool isAutoDetectSuspended() const;
 
    [[nodiscard]] QGC::AutoSuspendGuard suspendAutoDetect() { return QGC::AutoSuspendGuard(_autoDetectSuspended); }
 
    bool isInDetectCooldown() const;
    void recordDetectMiss();
    void clearDetectCooldown();
    static constexpr qint64 kDetectCooldownMs = 2000;
 
    MAVLinkSigning::DetectSnapshot detectSnapshot() const;
 
    bool consumeStatusTransition(mavlink_channel_t channel);
 
private:
    friend class SigningController;
 
    bool setSignOutgoing(bool signOutgoing);
 
    mavlink_signing_t _signing{};
    mavlink_signing_streams_t _streams{};
    QString _keyHint;
    bool _enabled = false;
    std::atomic<bool> _autoDetectSuspended{false};
    QDeadlineTimer _detectCooldown;  // default-constructed → expired (forever in the past)
    mavlink_signing_status_t _lastTransitionStatus = MAVLINK_SIGNING_STATUS_NONE;
    mutable QReadWriteLock _lock;
};