Source repositoryrtsp.h

Go to the documentation of this file.

#pragma once
 
// standard includes
#include <array>
#include <atomic>
#include <cstddef>
#include <cstdint>
#include <string>
 
// local includes
#include "crypto.h"
#include "thread_safe.h"
 
namespace rtsp_stream {
  constexpr auto RTSP_SETUP_PORT = 21;  
 
#pragma pack(push, 1)

  struct encrypted_rtsp_header_t {
    // We set the MSB in encrypted RTSP messages to allow format-agnostic
    // parsing code to be able to tell encrypted from plaintext messages.
    static constexpr std::uint32_t ENCRYPTED_MESSAGE_TYPE_BIT = 0x80000000;  

    uint8_t *payload() {
      return (uint8_t *) (this + 1);
    }

    std::uint32_t payload_length() const {
      return util::endian::big<std::uint32_t>(typeAndLength) & ~ENCRYPTED_MESSAGE_TYPE_BIT;
    }

    bool is_encrypted() const {
      return !!(util::endian::big<std::uint32_t>(typeAndLength) & ENCRYPTED_MESSAGE_TYPE_BIT);
    }
 
    // This field is the length of the payload + ENCRYPTED_MESSAGE_TYPE_BIT in big-endian
    std::uint32_t typeAndLength;  
 
    // This field is the number used to initialize the bottom 4 bytes of the AES IV in big-endian
    std::uint32_t sequenceNumber;  
 
    // This field is the AES GCM authentication tag
    std::array<std::uint8_t, 16> tag;  
  };
 
#pragma pack(pop)
 
  static_assert(sizeof(encrypted_rtsp_header_t) == 24);
  static_assert(offsetof(encrypted_rtsp_header_t, tag) == 8);

  struct launch_session_t {
    struct audio_negotiation_t {
      bool continuous_audio {};  
      std::string codec_offered;  
    };
 
    uint32_t id;  
 
    crypto::aes_t gcm_key;  
    crypto::aes_t iv;  
 
    std::string av_ping_payload;  
    uint32_t control_connect_data;  
 
    bool host_audio;  
    std::string unique_id;  
    int width;  
    int height;  
    int fps;  
    int gcmap;  
    int appid;  
    int surround_info;  
    std::string surround_params;  
    audio_negotiation_t audio_negotiation;  
    bool enable_hdr;  
    bool enable_sops;  
    std::string client_name;  
 
    std::optional<crypto::cipher::gcm_t> rtsp_cipher;  
    std::string rtsp_url_scheme;  
    uint32_t rtsp_iv_counter;  
    std::string client_cert;  
  };

  void launch_session_raise(std::shared_ptr<launch_session_t> launch_session);

  void launch_session_clear(uint32_t launch_session_id);

  int session_count();

  void terminate_sessions();
  void terminate_sessions_by_cert(std::string_view cert);

  void start();
}  // namespace rtsp_stream