mediasoup-sys 0.2.3

#define MS_CLASS "RTC::RtpCodecParameters"
// #define MS_LOG_DEV_LEVEL 3

#include "Logger.hpp"
#include "MediaSoupErrors.hpp"
#include "Utils.hpp"
#include "RTC/RtpDictionaries.hpp"

namespace RTC
{
	/* Instance methods. */

	RtpCodecParameters::RtpCodecParameters(json& data)
	{
		MS_TRACE();

		if (!data.is_object())
			MS_THROW_TYPE_ERROR("data is not an object");

		auto jsonMimeTypeIt     = data.find("mimeType");
		auto jsonPayloadTypeIt  = data.find("payloadType");
		auto jsonClockRateIt    = data.find("clockRate");
		auto jsonChannelsIt     = data.find("channels");
		auto jsonParametersIt   = data.find("parameters");
		auto jsonRtcpFeedbackIt = data.find("rtcpFeedback");

		// mimeType is mandatory.
		if (jsonMimeTypeIt == data.end() || !jsonMimeTypeIt->is_string())
			MS_THROW_TYPE_ERROR("missing mimeType");

		// Set MIME field.
		// This may throw.
		this->mimeType.SetMimeType(jsonMimeTypeIt->get<std::string>());

		// payloadType is mandatory.
		// clang-format off
		if (
			jsonPayloadTypeIt == data.end() ||
			!Utils::Json::IsPositiveInteger(*jsonPayloadTypeIt)
		)
		// clang-format on
		{
			MS_THROW_TYPE_ERROR("missing payloadType");
		}

		this->payloadType = jsonPayloadTypeIt->get<uint8_t>();

		// clockRate is mandatory.
		// clang-format off
		if (
			jsonClockRateIt == data.end() ||
			!Utils::Json::IsPositiveInteger(*jsonClockRateIt)
		)
		// clang-format on
		{
			MS_THROW_TYPE_ERROR("missing clockRate");
		}

		this->clockRate = jsonClockRateIt->get<uint32_t>();

		// channels is optional.
		// clang-format off
		if (
			jsonChannelsIt != data.end() &&
			Utils::Json::IsPositiveInteger(*jsonChannelsIt)
		)
		// clang-format on
		{
			this->channels = jsonChannelsIt->get<uint8_t>();
		}

		// parameters is optional.
		if (jsonParametersIt != data.end() && jsonParametersIt->is_object())
			this->parameters.Set(*jsonParametersIt);

		// rtcpFeedback is optional.
		if (jsonRtcpFeedbackIt != data.end() && jsonRtcpFeedbackIt->is_array())
		{
			this->rtcpFeedback.reserve(jsonRtcpFeedbackIt->size());

			for (auto& entry : *jsonRtcpFeedbackIt)
			{
				// This may throw due the constructor of RTC::RtcpFeedback.
				this->rtcpFeedback.emplace_back(entry);
			}
		}

		// Check codec.
		CheckCodec();
	}

	void RtpCodecParameters::FillJson(json& jsonObject) const
	{
		MS_TRACE();

		// Add mimeType.
		jsonObject["mimeType"] = this->mimeType.ToString();

		// Add payloadType.
		jsonObject["payloadType"] = this->payloadType;

		// Add clockRate.
		jsonObject["clockRate"] = this->clockRate;

		// Add channels.
		if (this->channels > 1)
			jsonObject["channels"] = this->channels;

		// Add parameters.
		this->parameters.FillJson(jsonObject["parameters"]);

		// Add rtcpFeedback.
		jsonObject["rtcpFeedback"] = json::array();
		auto jsonRtcpFeedbackIt    = jsonObject.find("rtcpFeedback");

		for (size_t i{ 0 }; i < this->rtcpFeedback.size(); ++i)
		{
			jsonRtcpFeedbackIt->emplace_back(json::value_t::object);

			auto& jsonEntry = (*jsonRtcpFeedbackIt)[i];
			auto& fb        = this->rtcpFeedback[i];

			fb.FillJson(jsonEntry);
		}
	}

	inline void RtpCodecParameters::CheckCodec()
	{
		MS_TRACE();

		static std::string aptString{ "apt" };

		// Check per MIME parameters and set default values.
		switch (this->mimeType.subtype)
		{
			case RTC::RtpCodecMimeType::Subtype::RTX:
			{
				// A RTX codec must have 'apt' parameter.
				if (!this->parameters.HasPositiveInteger(aptString))
					MS_THROW_TYPE_ERROR("missing apt parameter in RTX codec");

				break;
			}

			default:;
		}
	}
} // namespace RTC