Method OnSend

Src/Core/DeviceBridge.cpp:209–245

///////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////

////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////
void FSecure::C3::Core::DeviceBridge::OnSend(ByteView command)
{
	// Send to peripheral
	if (!m_Device->IsChannel())
	{
		m_Device->OnCommandFromConnector(command);
		return;
	}

	// Send to channel.

	// Negotiation channel does not support chunking. Just pass packet and leave.
	if (m_IsNegotiationChannel)
	{
		auto sent = GetDevice()->OnSendToChannelInternal(command);
		if (sent != command.size())
			throw std::runtime_error{ OBF("Negotiation channel does not support chunking. Packet size: ") + std::to_string(command.size()) + OBF(" Channel sent: ") + std::to_string(sent) };

		return;
	}

	// Chunk message.
	auto originalSize = static_cast<uint32_t>(command.size());
	auto messageId = m_QoS.GetOutgoingPacketId();
	uint32_t chunkId = 0u;
	while (!command.empty())
	{
		auto data = ByteVector{}.Write(messageId, chunkId, originalSize).Concat(command);
		auto sent = GetDevice()->OnSendToChannelInternal(data);

		if (sent >= QualityOfService::s_MinFrameSize || sent == data.size()) // if this condition were not channel must resend data.
		{
			chunkId++;
			command.remove_prefix(sent - QualityOfService::s_HeaderSize);
		}
	}
}