mediasoup-sys 0.12.2

FFI bindings to C++ libmediasoup-worker
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131

#define MS_CLASS "FuzzerRtcDtlsTransport"
// #define MS_LOG_DEV_LEVEL 3

#include "RTC/FuzzerDtlsTransport.hpp"
#include "Logger.hpp"
#include "Utils.hpp"
#include "mocks/include/MockShared.hpp"

namespace
{
	// NOLINTNEXTLINE(readability-identifier-naming)
	thread_local mocks::MockShared shared(/*getTimeMs*/
	                                      []()
	                                      {
		                                      return 1000;
	                                      });

	// DtlsTransport instance. It's reset every time DTLS handshake fails or DTLS
	// is closed.
	// NOLINTNEXTLINE(readability-identifier-naming)
	thread_local RTC::DtlsTransport* dtlsTransportSingleton{ nullptr };

	// DtlsTransport Listener instance. It's reset every time the DtlsTransport
	// singletonDTLS is reset.
	// NOLINTNEXTLINE(readability-identifier-naming)
	thread_local FuzzerRtcDtlsTransport::DtlsTransportListener* dtlsTransportListenerSingleton{ nullptr };
} // namespace

void FuzzerRtcDtlsTransport::Fuzz(const uint8_t* data, size_t len)
{
	if (!RTC::DtlsTransport::IsDtls(data, len))
	{
		return;
	}

	if (!dtlsTransportSingleton)
	{
		MS_DEBUG_DEV("no DtlsTransport singleton, creating it");

		delete dtlsTransportListenerSingleton;
		dtlsTransportListenerSingleton = new DtlsTransportListener();

		dtlsTransportSingleton =
		  new RTC::DtlsTransport(dtlsTransportListenerSingleton, std::addressof(shared));

		RTC::DtlsTransport::Role localRole;
		RTC::DtlsTransport::Fingerprint dtlsRemoteFingerprint;

		// Local DTLS role must be 'server' or 'client'. Choose it based on
		// randomness of first given byte.
		if (data[0] / 2 == 0)
		{
			localRole = RTC::DtlsTransport::Role::SERVER;
		}
		else
		{
			localRole = RTC::DtlsTransport::Role::CLIENT;
		}

		// Remote DTLS fingerprint random generation.
		// NOTE: Use a random integer in range 1..5 since FingerprintAlgorithm enum
		// has 5 possible values starting with value 1.
		dtlsRemoteFingerprint.algorithm = static_cast<RTC::DtlsTransport::FingerprintAlgorithm>(
		  Utils::Crypto::GetRandomUInt<uint16_t>(1u, 5u));

		dtlsRemoteFingerprint.value =
		  Utils::Crypto::GetRandomString(Utils::Crypto::GetRandomUInt<uint16_t>(3u, 20u));

		dtlsTransportSingleton->Run(localRole);
		dtlsTransportSingleton->SetRemoteFingerprint(dtlsRemoteFingerprint);
	}

	dtlsTransportSingleton->ProcessDtlsData(data, len);

	// DTLS may have failed or closed after ProcessDtlsData(). If so, unset it.
	if (
	  dtlsTransportSingleton->GetState() == RTC::DtlsTransport::DtlsState::FAILED ||
	  dtlsTransportSingleton->GetState() == RTC::DtlsTransport::DtlsState::CLOSED)
	{
		MS_DEBUG_DEV("DtlsTransport singleton state is 'failed' or 'closed', unsetting it");

		delete dtlsTransportSingleton;
		dtlsTransportSingleton = nullptr;
	}
	else
	{
		dtlsTransportSingleton->SendApplicationData(data, len);
	}
}

void FuzzerRtcDtlsTransport::DtlsTransportListener::OnDtlsTransportConnecting(
  const RTC::DtlsTransport* /*dtlsTransport*/)
{
	MS_DEBUG_DEV("DtlsTransport singleton connecting");
}

void FuzzerRtcDtlsTransport::DtlsTransportListener::OnDtlsTransportConnected(
  const RTC::DtlsTransport* /*dtlsTransport*/,
  RTC::SrtpSession::CryptoSuite /*srtpCryptoSuite*/,
  uint8_t* /*srtpLocalKey*/,
  size_t /*srtpLocalKeyLen*/,
  uint8_t* /*srtpRemoteKey*/,
  size_t /*srtpRemoteKeyLen*/,
  std::string& /*remoteCert*/)
{
	MS_DEBUG_DEV("DtlsTransport singleton connected");
}

void FuzzerRtcDtlsTransport::DtlsTransportListener::OnDtlsTransportFailed(
  const RTC::DtlsTransport* /*dtlsTransport*/)
{
	MS_DEBUG_DEV("DtlsTransport singleton failed");
}

void FuzzerRtcDtlsTransport::DtlsTransportListener::OnDtlsTransportClosed(
  const RTC::DtlsTransport* /*dtlsTransport*/)
{
	MS_DEBUG_DEV("DtlsTransport singleton closed");
}

void FuzzerRtcDtlsTransport::DtlsTransportListener::OnDtlsTransportSendData(
  const RTC::DtlsTransport* /*dtlsTransport*/, const uint8_t* /*data*/, size_t /*len*/)
{
	MS_DEBUG_DEV("DtlsTransport singleton wants to send data");
}

void FuzzerRtcDtlsTransport::DtlsTransportListener::OnDtlsTransportApplicationDataReceived(
  const RTC::DtlsTransport* /*dtlsTransport*/, const uint8_t* /*data*/, size_t /*len*/)
{
	MS_DEBUG_DEV("DtlsTransport singleton received application data");
}