907 lines
35 KiB
C++
907 lines
35 KiB
C++
/*
|
||
* Copyright (c) 2016-present The ZLMediaKit project authors. All Rights Reserved.
|
||
*
|
||
* This file is part of ZLMediaKit(https://github.com/ZLMediaKit/ZLMediaKit).
|
||
*
|
||
* Use of this source code is governed by MIT-like license that can be found in the
|
||
* LICENSE file in the root of the source tree. All contributing project authors
|
||
* may be found in the AUTHORS file in the root of the source tree.
|
||
*/
|
||
|
||
#include "StunPacket.hpp"
|
||
#include <cstdio> // std::snprintf()
|
||
#include <cstring> // std::memcmp(), std::memcpy()
|
||
#include <openssl/hmac.h>
|
||
#include "Util/logger.h"
|
||
#include "Common/macros.h"
|
||
|
||
using namespace std;
|
||
using namespace toolkit;
|
||
|
||
namespace RTC
|
||
{
|
||
|
||
static const uint32_t crc32Table[] = {
|
||
0x00000000, 0x77073096, 0xee0e612c, 0x990951ba, 0x076dc419, 0x706af48f, 0xe963a535, 0x9e6495a3,
|
||
0x0edb8832, 0x79dcb8a4, 0xe0d5e91e, 0x97d2d988, 0x09b64c2b, 0x7eb17cbd, 0xe7b82d07, 0x90bf1d91,
|
||
0x1db71064, 0x6ab020f2, 0xf3b97148, 0x84be41de, 0x1adad47d, 0x6ddde4eb, 0xf4d4b551, 0x83d385c7,
|
||
0x136c9856, 0x646ba8c0, 0xfd62f97a, 0x8a65c9ec, 0x14015c4f, 0x63066cd9, 0xfa0f3d63, 0x8d080df5,
|
||
0x3b6e20c8, 0x4c69105e, 0xd56041e4, 0xa2677172, 0x3c03e4d1, 0x4b04d447, 0xd20d85fd, 0xa50ab56b,
|
||
0x35b5a8fa, 0x42b2986c, 0xdbbbc9d6, 0xacbcf940, 0x32d86ce3, 0x45df5c75, 0xdcd60dcf, 0xabd13d59,
|
||
0x26d930ac, 0x51de003a, 0xc8d75180, 0xbfd06116, 0x21b4f4b5, 0x56b3c423, 0xcfba9599, 0xb8bda50f,
|
||
0x2802b89e, 0x5f058808, 0xc60cd9b2, 0xb10be924, 0x2f6f7c87, 0x58684c11, 0xc1611dab, 0xb6662d3d,
|
||
0x76dc4190, 0x01db7106, 0x98d220bc, 0xefd5102a, 0x71b18589, 0x06b6b51f, 0x9fbfe4a5, 0xe8b8d433,
|
||
0x7807c9a2, 0x0f00f934, 0x9609a88e, 0xe10e9818, 0x7f6a0dbb, 0x086d3d2d, 0x91646c97, 0xe6635c01,
|
||
0x6b6b51f4, 0x1c6c6162, 0x856530d8, 0xf262004e, 0x6c0695ed, 0x1b01a57b, 0x8208f4c1, 0xf50fc457,
|
||
0x65b0d9c6, 0x12b7e950, 0x8bbeb8ea, 0xfcb9887c, 0x62dd1ddf, 0x15da2d49, 0x8cd37cf3, 0xfbd44c65,
|
||
0x4db26158, 0x3ab551ce, 0xa3bc0074, 0xd4bb30e2, 0x4adfa541, 0x3dd895d7, 0xa4d1c46d, 0xd3d6f4fb,
|
||
0x4369e96a, 0x346ed9fc, 0xad678846, 0xda60b8d0, 0x44042d73, 0x33031de5, 0xaa0a4c5f, 0xdd0d7cc9,
|
||
0x5005713c, 0x270241aa, 0xbe0b1010, 0xc90c2086, 0x5768b525, 0x206f85b3, 0xb966d409, 0xce61e49f,
|
||
0x5edef90e, 0x29d9c998, 0xb0d09822, 0xc7d7a8b4, 0x59b33d17, 0x2eb40d81, 0xb7bd5c3b, 0xc0ba6cad,
|
||
0xedb88320, 0x9abfb3b6, 0x03b6e20c, 0x74b1d29a, 0xead54739, 0x9dd277af, 0x04db2615, 0x73dc1683,
|
||
0xe3630b12, 0x94643b84, 0x0d6d6a3e, 0x7a6a5aa8, 0xe40ecf0b, 0x9309ff9d, 0x0a00ae27, 0x7d079eb1,
|
||
0xf00f9344, 0x8708a3d2, 0x1e01f268, 0x6906c2fe, 0xf762575d, 0x806567cb, 0x196c3671, 0x6e6b06e7,
|
||
0xfed41b76, 0x89d32be0, 0x10da7a5a, 0x67dd4acc, 0xf9b9df6f, 0x8ebeeff9, 0x17b7be43, 0x60b08ed5,
|
||
0xd6d6a3e8, 0xa1d1937e, 0x38d8c2c4, 0x4fdff252, 0xd1bb67f1, 0xa6bc5767, 0x3fb506dd, 0x48b2364b,
|
||
0xd80d2bda, 0xaf0a1b4c, 0x36034af6, 0x41047a60, 0xdf60efc3, 0xa867df55, 0x316e8eef, 0x4669be79,
|
||
0xcb61b38c, 0xbc66831a, 0x256fd2a0, 0x5268e236, 0xcc0c7795, 0xbb0b4703, 0x220216b9, 0x5505262f,
|
||
0xc5ba3bbe, 0xb2bd0b28, 0x2bb45a92, 0x5cb36a04, 0xc2d7ffa7, 0xb5d0cf31, 0x2cd99e8b, 0x5bdeae1d,
|
||
0x9b64c2b0, 0xec63f226, 0x756aa39c, 0x026d930a, 0x9c0906a9, 0xeb0e363f, 0x72076785, 0x05005713,
|
||
0x95bf4a82, 0xe2b87a14, 0x7bb12bae, 0x0cb61b38, 0x92d28e9b, 0xe5d5be0d, 0x7cdcefb7, 0x0bdbdf21,
|
||
0x86d3d2d4, 0xf1d4e242, 0x68ddb3f8, 0x1fda836e, 0x81be16cd, 0xf6b9265b, 0x6fb077e1, 0x18b74777,
|
||
0x88085ae6, 0xff0f6a70, 0x66063bca, 0x11010b5c, 0x8f659eff, 0xf862ae69, 0x616bffd3, 0x166ccf45,
|
||
0xa00ae278, 0xd70dd2ee, 0x4e048354, 0x3903b3c2, 0xa7672661, 0xd06016f7, 0x4969474d, 0x3e6e77db,
|
||
0xaed16a4a, 0xd9d65adc, 0x40df0b66, 0x37d83bf0, 0xa9bcae53, 0xdebb9ec5, 0x47b2cf7f, 0x30b5ffe9,
|
||
0xbdbdf21c, 0xcabac28a, 0x53b39330, 0x24b4a3a6, 0xbad03605, 0xcdd70693, 0x54de5729, 0x23d967bf,
|
||
0xb3667a2e, 0xc4614ab8, 0x5d681b02, 0x2a6f2b94, 0xb40bbe37, 0xc30c8ea1, 0x5a05df1b, 0x2d02ef8d
|
||
};
|
||
|
||
inline uint32_t getCRC32(const uint8_t *data, size_t size) {
|
||
uint32_t crc { 0xFFFFFFFF };
|
||
const uint8_t *p = data;
|
||
|
||
while (size--) {
|
||
crc = crc32Table[(crc ^ *p++) & 0xFF] ^ (crc >> 8);
|
||
}
|
||
|
||
return crc ^ ~0U;
|
||
}
|
||
|
||
static std::string openssl_HMACsha1(const void *key, size_t key_len, const void *data, size_t data_len) {
|
||
std::string str;
|
||
str.resize(20);
|
||
unsigned int out_len;
|
||
#if defined(OPENSSL_VERSION_NUMBER) && (OPENSSL_VERSION_NUMBER > 0x10100000L)
|
||
// openssl 1.1.0新增api，老版本api作废
|
||
HMAC_CTX *ctx = HMAC_CTX_new();
|
||
HMAC_CTX_reset(ctx);
|
||
HMAC_Init_ex(ctx, key, (int)key_len, EVP_sha1(), NULL);
|
||
HMAC_Update(ctx, (unsigned char *)data, data_len);
|
||
HMAC_Final(ctx, (unsigned char *)str.data(), &out_len);
|
||
HMAC_CTX_reset(ctx);
|
||
HMAC_CTX_free(ctx);
|
||
#else
|
||
HMAC_CTX ctx;
|
||
HMAC_CTX_init(&ctx);
|
||
HMAC_Init_ex(&ctx, key, key_len, EVP_sha1(), NULL);
|
||
HMAC_Update(&ctx, (unsigned char *)data, data_len);
|
||
HMAC_Final(&ctx, (unsigned char *)str.data(), &out_len);
|
||
HMAC_CTX_cleanup(&ctx);
|
||
#endif // defined(OPENSSL_VERSION_NUMBER) && (OPENSSL_VERSION_NUMBER > 0x10100000L)
|
||
return str;
|
||
}
|
||
|
||
static std::string openssl_MD5(const void *data, size_t data_len) {
|
||
std::string str;
|
||
str.resize(16);
|
||
unsigned int out_len;
|
||
#if defined(OPENSSL_VERSION_NUMBER) && (OPENSSL_VERSION_NUMBER > 0x10100000L)
|
||
// openssl 1.1.0新增api，老版本api作废
|
||
EVP_MD_CTX *ctx = EVP_MD_CTX_new();
|
||
EVP_DigestInit_ex(ctx, EVP_md5(), NULL);
|
||
EVP_DigestUpdate(ctx, data, data_len);
|
||
unsigned int md_len;
|
||
EVP_DigestFinal_ex(ctx, (unsigned char *)str.data(), &md_len);
|
||
EVP_MD_CTX_free(ctx);
|
||
#else
|
||
MD5_CTX ctx;
|
||
MD5_Init(&ctx);
|
||
MD5_Update(&ctx, data, data_len);
|
||
MD5_Final((unsigned char *)str.data(), &ctx);
|
||
#endif // defined(OPENSSL_VERSION_NUMBER) && (OPENSSL_VERSION_NUMBER > 0x10100000L)
|
||
return str;
|
||
}
|
||
|
||
///////////////////////////////////////////////////
|
||
// StunAttribute
|
||
|
||
bool StunAttribute::isComprehensionRequired(const uint8_t *data, size_t len) {
|
||
return ((data[0] & 0xC0) == 0x00);
|
||
}
|
||
|
||
const uint8_t * StunAttribute::loadHeader(const uint8_t *buf) {
|
||
_type = (Type)Byte::Get2Bytes(buf, 0);
|
||
_length = Byte::Get2Bytes(buf, 2);
|
||
return buf + ATTR_HEADER_SIZE;
|
||
}
|
||
|
||
uint8_t * StunAttribute::storeHeader() {
|
||
_data = toolkit::BufferRaw::create(ATTR_HEADER_SIZE + Byte::PadTo4Bytes(_length));
|
||
_data->setSize(_data->getCapacity());
|
||
memset(_data->data(), 0, _data->size());
|
||
uint8_t *ptr = (uint8_t *)_data->data();
|
||
Byte::Set2Bytes(ptr, 0, (uint16_t)_type);
|
||
Byte::Set2Bytes(ptr, 2, _length);
|
||
return ptr + ATTR_HEADER_SIZE;
|
||
}
|
||
|
||
bool StunAttrMappedAddress::loadFromData(const uint8_t *buf, size_t len) {
|
||
StunAttribute::loadHeader(buf);
|
||
return true;
|
||
}
|
||
|
||
bool StunAttrMappedAddress::storeToData() {
|
||
return true;
|
||
}
|
||
|
||
bool StunAttrUserName::loadFromData(const uint8_t *buf, size_t len) {
|
||
auto p = StunAttribute::loadHeader(buf);
|
||
_username.assign((const char *)p, _length);
|
||
return true;
|
||
}
|
||
|
||
bool StunAttrUserName::storeToData() {
|
||
_length = _username.length();
|
||
auto p = StunAttribute::storeHeader();
|
||
memcpy(p, _username.data(), _username.length());
|
||
return true;
|
||
}
|
||
|
||
bool StunAttrMessageIntegrity::loadFromData(const uint8_t *buf, size_t len) {
|
||
auto p = StunAttribute::loadHeader(buf);
|
||
_hmac.assign((const char *)p, _length);
|
||
return true;
|
||
}
|
||
|
||
bool StunAttrMessageIntegrity::storeToData() {
|
||
_length = _hmac.size();
|
||
auto p = StunAttribute::storeHeader();
|
||
memcpy(p, _hmac.data(), _hmac.size());
|
||
return true;
|
||
}
|
||
|
||
bool StunAttrErrorCode::loadFromData(const uint8_t *buf, size_t len) {
|
||
auto p = StunAttribute::loadHeader(buf);
|
||
_error_code = (Code)(p[2] * 100 + p[3]);
|
||
return true;
|
||
}
|
||
|
||
bool StunAttrErrorCode::storeToData() {
|
||
_length = 4;
|
||
auto p = StunAttribute::storeHeader();
|
||
Byte::Set2Bytes(p, 0, 0); // reserved
|
||
uint16_t code = (uint16_t)_error_code;
|
||
p[2] = code / 100;
|
||
p[3] = code % 100;
|
||
return true;
|
||
}
|
||
|
||
bool StunAttrChannelNumber::loadFromData(const uint8_t *buf, size_t len) {
|
||
auto p = StunAttribute::loadHeader(buf);
|
||
_channel_number = Byte::Get2Bytes(p, 0);
|
||
return true;
|
||
}
|
||
|
||
bool StunAttrChannelNumber::storeToData() {
|
||
_length = 4;
|
||
auto p = StunAttribute::storeHeader();
|
||
Byte::Set2Bytes(p, 0, _channel_number);
|
||
Byte::Set2Bytes(p, 2, 0); // RFFU
|
||
return true;
|
||
}
|
||
|
||
bool StunAttrLifeTime::loadFromData(const uint8_t *buf, size_t len) {
|
||
auto p = StunAttribute::loadHeader(buf);
|
||
_lifetime = Byte::Get4Bytes(p, 0);
|
||
return true;
|
||
}
|
||
|
||
bool StunAttrLifeTime::storeToData() {
|
||
_length = 4;
|
||
auto p = StunAttribute::storeHeader();
|
||
Byte::Set4Bytes(p, 0, _lifetime);
|
||
return true;
|
||
}
|
||
|
||
bool StunAttrXorPeerAddress::loadFromData(const uint8_t *buf, size_t len) {
|
||
auto attrValue = StunAttribute::loadHeader(buf);
|
||
memset(&_addr, 0, sizeof(_addr));
|
||
uint8_t port[2], addr[16];
|
||
port[0] = attrValue[2] ^ StunPacket::_magicCookie[0];
|
||
port[1] = attrValue[3] ^ StunPacket::_magicCookie[1];
|
||
addr[0] = attrValue[4] ^ StunPacket::_magicCookie[0];
|
||
addr[1] = attrValue[5] ^ StunPacket::_magicCookie[1];
|
||
addr[2] = attrValue[6] ^ StunPacket::_magicCookie[2];
|
||
addr[3] = attrValue[7] ^ StunPacket::_magicCookie[3];
|
||
auto protocol = attrValue[1];
|
||
if (protocol == 0x01) {
|
||
_addr.ss_family = AF_INET;
|
||
struct sockaddr_in *ipv4 = (struct sockaddr_in *)&_addr;
|
||
ipv4->sin_port = ntohs(Byte::Get2Bytes(port, 0));
|
||
std::memcpy((void *)&(reinterpret_cast<const sockaddr_in *>(&_addr))->sin_addr.s_addr, addr, 4);
|
||
} else {
|
||
_addr.ss_family = AF_INET6;
|
||
for (int i=0; i < 12; ++i) {
|
||
addr[i + 4] = attrValue[i + 8] ^ _transaction_id[i];
|
||
}
|
||
struct sockaddr_in6 *ipv6 = (struct sockaddr_in6 *)&_addr;
|
||
ipv6->sin6_port = ntohs(Byte::Get2Bytes(port, 0));
|
||
std::memcpy((void *)&(reinterpret_cast<const sockaddr_in6 *>(&_addr))->sin6_addr.s6_addr, addr, 16);
|
||
}
|
||
|
||
return true;
|
||
}
|
||
|
||
bool StunAttrXorPeerAddress::storeToData() {
|
||
_length = (_addr.ss_family == AF_INET) ? 8 : 20;
|
||
auto attrValue = StunAttribute::storeHeader();
|
||
// Set first byte to 0.
|
||
attrValue[0] = 0;
|
||
if (_addr.ss_family == AF_INET) {
|
||
// Set inet family.
|
||
attrValue[1] = 1;
|
||
// Set port and XOR it.
|
||
std::memcpy(attrValue + 2, &(reinterpret_cast<const sockaddr_in *>(&_addr))->sin_port, 2);
|
||
attrValue[2] ^= StunPacket::_magicCookie[0];
|
||
attrValue[3] ^= StunPacket::_magicCookie[1];
|
||
|
||
// Set address and XOR it.
|
||
std::memcpy(attrValue + 4, &(reinterpret_cast<const sockaddr_in *>(&_addr))->sin_addr.s_addr, 4);
|
||
attrValue[4] ^= StunPacket::_magicCookie[0];
|
||
attrValue[5] ^= StunPacket::_magicCookie[1];
|
||
attrValue[6] ^= StunPacket::_magicCookie[2];
|
||
attrValue[7] ^= StunPacket::_magicCookie[3];
|
||
} else if (_addr.ss_family == AF_INET6) {
|
||
// Set inet family.
|
||
attrValue[1] = 2;
|
||
|
||
std::memcpy(attrValue + 2, &(reinterpret_cast<const sockaddr_in6 *>(&_addr))->sin6_port, 2);
|
||
attrValue[2] ^= StunPacket::_magicCookie[0];
|
||
attrValue[3] ^= StunPacket::_magicCookie[1];
|
||
// Set address and XOR it.
|
||
std::memcpy(attrValue + 4, &(reinterpret_cast<const sockaddr_in6 *>(&_addr))->sin6_addr.s6_addr, 16);
|
||
attrValue[4] ^= StunPacket::_magicCookie[0];
|
||
attrValue[5] ^= StunPacket::_magicCookie[1];
|
||
attrValue[6] ^= StunPacket::_magicCookie[2];
|
||
attrValue[7] ^= StunPacket::_magicCookie[3];
|
||
for (int i=0; i < 12; ++i) {
|
||
attrValue[8 + i] ^= _transaction_id[i];
|
||
}
|
||
}
|
||
|
||
return true;
|
||
}
|
||
|
||
bool StunAttrData::loadFromData(const uint8_t *buf, size_t len) {
|
||
auto p = StunAttribute::loadHeader(buf);
|
||
setData((const char *)p, _length);
|
||
return true;
|
||
}
|
||
|
||
bool StunAttrData::storeToData() {
|
||
_length = _data_content.size();
|
||
auto p = StunAttribute::storeHeader();
|
||
memcpy(p, _data_content.data(), _data_content.size());
|
||
return true;
|
||
}
|
||
|
||
bool StunAttrRealm::loadFromData(const uint8_t *buf, size_t len) {
|
||
auto p = StunAttribute::loadHeader(buf);
|
||
_realm.assign((const char *)p, _length);
|
||
return true;
|
||
}
|
||
|
||
bool StunAttrRealm::storeToData() {
|
||
_length = _realm.size();
|
||
auto p = StunAttribute::storeHeader();
|
||
memcpy(p, _realm.data(), _realm.size());
|
||
return true;
|
||
}
|
||
|
||
bool StunAttrNonce::loadFromData(const uint8_t *buf, size_t len) {
|
||
auto p = StunAttribute::loadHeader(buf);
|
||
_nonce.assign((const char *)p, _length);
|
||
return true;
|
||
}
|
||
|
||
bool StunAttrNonce::storeToData() {
|
||
_length = _nonce.size();
|
||
auto p = StunAttribute::storeHeader();
|
||
memcpy(p, _nonce.data(), _nonce.size());
|
||
return true;
|
||
}
|
||
|
||
bool StunAttrRequestedTransport::loadFromData(const uint8_t *buf, size_t len) {
|
||
auto p = StunAttribute::loadHeader(buf);
|
||
_protocol = (Protocol)p[0];
|
||
return true;
|
||
}
|
||
|
||
bool StunAttrRequestedTransport::storeToData() {
|
||
_length = 4;
|
||
auto p = StunAttribute::storeHeader();
|
||
p[0] = (uint8_t)_protocol;
|
||
return true;
|
||
}
|
||
|
||
bool StunAttrPriority::loadFromData(const uint8_t *buf, size_t len) {
|
||
auto p = StunAttribute::loadHeader(buf);
|
||
_priority = Byte::Get4Bytes(p, 0);
|
||
return true;
|
||
}
|
||
|
||
bool StunAttrPriority::storeToData() {
|
||
_length = 4;
|
||
auto p = StunAttribute::storeHeader();
|
||
Byte::Set4Bytes(p, 0, _priority);
|
||
return true;
|
||
}
|
||
|
||
bool StunAttrUseCandidate::loadFromData(const uint8_t *buf, size_t len) {
|
||
StunAttribute::loadHeader(buf);
|
||
return true;
|
||
}
|
||
|
||
bool StunAttrUseCandidate::storeToData() {
|
||
_length = 0;
|
||
StunAttribute::storeHeader();
|
||
return true;
|
||
}
|
||
|
||
bool StunAttrFingerprint::loadFromData(const uint8_t *buf, size_t len) {
|
||
auto p = StunAttribute::loadHeader(buf);
|
||
_fingerprint = Byte::Get4Bytes(p, 0);
|
||
return true;
|
||
}
|
||
|
||
bool StunAttrFingerprint::storeToData() {
|
||
_length = 4;
|
||
auto p = StunAttribute::storeHeader();
|
||
Byte::Set4Bytes(p, 0, _fingerprint);
|
||
return true;
|
||
}
|
||
|
||
bool StunAttrIceControlled::loadFromData(const uint8_t *buf, size_t len) {
|
||
auto p = StunAttribute::loadHeader(buf);
|
||
_tiebreaker = Byte::Get8Bytes(p, 0);
|
||
return true;
|
||
}
|
||
|
||
bool StunAttrIceControlled::storeToData() {
|
||
_length = 8;
|
||
auto p = StunAttribute::storeHeader();
|
||
Byte::Set8Bytes(p, 0, _tiebreaker);
|
||
return true;
|
||
}
|
||
|
||
bool StunAttrIceControlling::loadFromData(const uint8_t *buf, size_t len) {
|
||
auto p = StunAttribute::loadHeader(buf);
|
||
_tiebreaker = Byte::Get8Bytes(p, 0);
|
||
return true;
|
||
}
|
||
|
||
bool StunAttrIceControlling::storeToData() {
|
||
_length = 8;
|
||
auto p = StunAttribute::storeHeader();
|
||
Byte::Set8Bytes(p, 0, _tiebreaker);
|
||
return true;
|
||
}
|
||
|
||
///////////////////////////////////////////////////
|
||
// StunPacket
|
||
|
||
const uint8_t StunPacket::_magicCookie[] = { 0x21, 0x12, 0xA4, 0x42 };
|
||
|
||
/* Class methods. */
|
||
bool StunPacket::isStun(const uint8_t *data, size_t len) {
|
||
// reference https://www.rfc-editor.org/rfc/rfc8489.html#section-6.3
|
||
return
|
||
// STUN headers are 20 bytes.
|
||
(len >= 20) &&
|
||
// checks that the first two bits are 0
|
||
((data[0] & 0xC0) == 0) &&
|
||
// that the Magic Cookie field has the correct value
|
||
(data[4] == StunPacket::_magicCookie[0]) && (data[5] == StunPacket::_magicCookie[1]) && (data[6] == StunPacket::_magicCookie[2])
|
||
&& (data[7] == StunPacket::_magicCookie[3]);
|
||
}
|
||
|
||
/*
|
||
The message type field is decomposed further into the following
|
||
structure:
|
||
|
||
0 1
|
||
2 3 4 5 6 7 8 9 0 1 2 3 4 5
|
||
+--+--+-+-+-+-+-+-+-+-+-+-+-+-+
|
||
|M |M |M|M|M|C|M|M|M|C|M|M|M|M|
|
||
|11|10|9|8|7|1|6|5|4|0|3|2|1|0|
|
||
+--+--+-+-+-+-+-+-+-+-+-+-+-+-+
|
||
|
||
Figure 3: Format of STUN Message Type Field
|
||
|
||
Here the bits in the message type field are shown as most significant
|
||
(M11) through least significant (M0). M11 through M0 represent a 12-
|
||
bit encoding of the method. C1 and C0 represent a 2-bit encoding of
|
||
the class.
|
||
*/
|
||
StunPacket::Class StunPacket::getClass(const uint8_t *data, size_t len) {
|
||
return StunPacket::Class(((data[0] & 0x01) << 1) | ((data[1] & 0x10) >> 4));
|
||
}
|
||
|
||
StunPacket::Method StunPacket::getMethod(const uint8_t *data, size_t len) {
|
||
uint16_t msgType = Byte::Get2Bytes(data, 0);
|
||
return StunPacket::Method((msgType & 0x000F) | ((msgType & 0x00E0) >> 1) | ((msgType & 0x3E00) >> 2));
|
||
}
|
||
|
||
StunPacket::Ptr StunPacket::parse(const uint8_t *data, size_t len) {
|
||
// TraceL;
|
||
|
||
if (!StunPacket::isStun(data, len)) {
|
||
return nullptr;
|
||
}
|
||
|
||
// Get length field.
|
||
uint16_t msgLength = Byte::Get2Bytes(data, 2);
|
||
|
||
// length field must be total size minus header's 20 bytes, and must be multiple of 4 Bytes.
|
||
if ((static_cast<size_t>(msgLength) != len - 20) || ((msgLength & 0x03) != 0)) {
|
||
WarnL << "length field + 20 does not match total size (or it is not multiple of 4 bytes), packet discarded";
|
||
return nullptr;
|
||
}
|
||
|
||
auto msgMethod = getMethod(data, len);
|
||
auto msgClass = getClass(data, len);
|
||
|
||
auto packet = std::make_shared<StunPacket>(msgClass, msgMethod, (const char *)data + 8);
|
||
packet->loadFromData(data, len);
|
||
return packet;
|
||
}
|
||
|
||
std::string StunPacket::mappingClassEnum2Str(Class klass) {
|
||
switch (klass) {
|
||
case StunPacket::Class::REQUEST: return "REQUEST";
|
||
case StunPacket::Class::INDICATION: return "INDICATION";
|
||
case StunPacket::Class::SUCCESS_RESPONSE: return "SUCCESS_RESPONSE";
|
||
case StunPacket::Class::ERROR_RESPONSE: return "ERROR_RESPONSE";
|
||
default: break;
|
||
}
|
||
return "invalid";
|
||
}
|
||
|
||
std::string StunPacket::mappingMethodEnum2Str(Method method) {
|
||
switch (method) {
|
||
case StunPacket::Method::BINDING: return "BINDING";
|
||
case StunPacket::Method::ALLOCATE: return "ALLOCATE";
|
||
case StunPacket::Method::REFRESH: return "REFRESH";
|
||
case StunPacket::Method::SEND: return "SEND";
|
||
case StunPacket::Method::DATA: return "DATA";
|
||
case StunPacket::Method::CREATEPERMISSION: return "CREATEPERMISSION";
|
||
case StunPacket::Method::CHANNELBIND: return "CHANNELBIND";
|
||
default: break;
|
||
}
|
||
return "invalid";
|
||
}
|
||
|
||
StunPacket::StunPacket(Class klass, Method method, const char* transId)
|
||
: _klass(klass)
|
||
, _method(method) {
|
||
// TraceL;
|
||
if (transId) {
|
||
_transaction_id.assign(transId, 12);
|
||
} else {
|
||
refreshTransactionId();
|
||
}
|
||
}
|
||
|
||
StunPacket::~StunPacket() {
|
||
// TraceL;
|
||
}
|
||
|
||
std::string StunPacket::dumpString(bool transId) const {
|
||
std::string ret = "class=" + getClassStr() + ", method=" + getMethodStr();
|
||
if (transId) {
|
||
ret += ", transaction=" + hexdump(_transaction_id.data(), _transaction_id.size());
|
||
}
|
||
return ret;
|
||
}
|
||
|
||
void StunPacket::addAttribute(StunAttribute::Ptr attr) {
|
||
_attribute_map.emplace(attr->type(), std::move(attr));
|
||
}
|
||
|
||
void StunPacket::removeAttribute(StunAttribute::Type type) {
|
||
_attribute_map.erase(type);
|
||
}
|
||
|
||
bool StunPacket::hasAttribute(StunAttribute::Type type) const {
|
||
return _attribute_map.count(type) > 0;
|
||
}
|
||
|
||
StunAttribute::Ptr StunPacket::getAttribute(StunAttribute::Type type) const {
|
||
auto it = _attribute_map.find(type);
|
||
if (it != _attribute_map.end()) {
|
||
return it->second;
|
||
}
|
||
return nullptr;
|
||
}
|
||
|
||
std::string StunPacket::getUsername() const {
|
||
auto attr = getAttribute<StunAttrUserName>();
|
||
return attr ? attr->getUsername() : "";
|
||
}
|
||
|
||
uint64_t StunPacket::getPriority() const {
|
||
auto attr = getAttribute<StunAttrPriority>();
|
||
return attr ? attr->getPriority() : 0;
|
||
}
|
||
|
||
StunAttrErrorCode::Code StunPacket::getErrorCode() const {
|
||
auto attr = getAttribute<StunAttrErrorCode>();
|
||
return attr ? attr->getErrorCode() : StunAttrErrorCode::Code::Invalid;
|
||
}
|
||
|
||
StunPacket::Authentication StunPacket::checkAuthentication(const std::string &ufrag, const std::string &password) const {
|
||
// TraceL;
|
||
auto attr_message_integrity = getAttribute<StunAttrMessageIntegrity>();
|
||
switch (_klass) {
|
||
case Class::REQUEST: {
|
||
if (!attr_message_integrity) {
|
||
return Authentication::UNAUTHORIZED;
|
||
}
|
||
|
||
if (getMethod() == Method::ALLOCATE || getMethod() == Method::REFRESH ||
|
||
getMethod() == Method::CREATEPERMISSION || getMethod() == Method::CHANNELBIND) {
|
||
// TURN认证：USERNAME应该等于ufrag
|
||
std::string username = getUsername();
|
||
if (username != ufrag) {
|
||
TraceL << "TURN USERNAME validation failed, expected: " << ufrag << ", got: " << username;
|
||
return Authentication::UNAUTHORIZED;
|
||
}
|
||
} else {
|
||
// ICE认证：USERNAME格式为 local-ufrag:remote-ufrag（仅用于ICE BINDING请求）
|
||
std::string username = getUsername();
|
||
if (!username.empty()) {
|
||
size_t localUsernameLen = ufrag.length();
|
||
if (username.length() <= localUsernameLen || username.at(localUsernameLen) != ':' ||
|
||
(username.compare(0, localUsernameLen, ufrag) != 0)) {
|
||
DebugL << "ICE USERNAME format validation failed, expected format: " << ufrag << ":remote-ufrag, got: " << username;
|
||
return Authentication::UNAUTHORIZED;
|
||
}
|
||
}
|
||
}
|
||
break;
|
||
}
|
||
// This method cannot check authentication in received responses (as we
|
||
// are ICE-Lite and don't generate requests).
|
||
case Class::INDICATION: return Authentication::OK;
|
||
case Class::SUCCESS_RESPONSE:
|
||
case Class::ERROR_RESPONSE: break;
|
||
}
|
||
|
||
if (attr_message_integrity) {
|
||
// If there is FINGERPRINT it must be discarded for MESSAGE-INTEGRITY calculation,
|
||
// so the header length field must be modified (and later restored).
|
||
if (hasAttribute(StunAttribute::Type::FINGERPRINT)) {
|
||
// Set the header length field: full size - header length (20) - FINGERPRINT length (8).
|
||
Byte::Set2Bytes((uint8_t *)_data->data(), 2, _data->size() - HEADER_SIZE - 8);
|
||
}
|
||
|
||
auto attr_realm = getAttribute<StunAttrRealm>();
|
||
auto attr_nonce = getAttribute<StunAttrNonce>();
|
||
|
||
std::string key = password;
|
||
if (attr_nonce && attr_realm) {
|
||
// 使用长期凭证机制
|
||
// 根据RFC 5389/5766标准：key = MD5(username ":" realm ":" password)
|
||
auto realm = attr_realm->getRealm();
|
||
std::string input = ufrag + ":" + std::string(realm.data(), realm.size()) + ":" + password;
|
||
key = openssl_MD5(input.data(), input.size());
|
||
|
||
// DebugL << "ufrag: " << ufrag;
|
||
// DebugL << "realm: " << realm.data();
|
||
// DebugL << "password: " << password;
|
||
// DebugL << "input: " << input;
|
||
}
|
||
|
||
auto computedMessageIntegrity = openssl_HMACsha1(key.data(), key.size(), _data->data(), _message_integrity_data_len);
|
||
|
||
// DebugL << "cal MessageIntegrity";
|
||
// DebugL << "password: " << password;
|
||
// DebugL << "key: " << toolkit::hexdump(key.data(), key.size());
|
||
// DebugL << "data: " << toolkit::hexdump(_data->data(), _message_integrity_data_len);
|
||
// DebugL << "_message_integrity_data_len: " << _message_integrity_data_len;
|
||
// DebugL << "_hmac: " << toolkit::hexdump(attr_message_integrity->_hmac.data(), attr_message_integrity->_hmac.size());
|
||
// DebugL << "cal: " << toolkit::hexdump(computedMessageIntegrity.data(), computedMessageIntegrity.size());
|
||
|
||
if (attr_message_integrity->getHmac() != computedMessageIntegrity) {
|
||
return Authentication::UNAUTHORIZED;
|
||
}
|
||
|
||
if (hasAttribute(StunAttribute::Type::FINGERPRINT)) {
|
||
Byte::Set2Bytes((uint8_t*)_data->data(), 2, _data->size() - HEADER_SIZE);
|
||
}
|
||
}
|
||
|
||
// FINGERPRINT验证
|
||
if (hasAttribute(StunAttribute::Type::FINGERPRINT)) {
|
||
auto attr_fingerprint = getAttribute<StunAttrFingerprint>();
|
||
if (attr_fingerprint) {
|
||
// 计算FINGERPRINT：对除FINGERPRINT属性外的整个包计算CRC32
|
||
uint32_t computedFingerprint = getCRC32((uint8_t*)_data->data(), _data->size() - 8) ^ 0x5354554e;
|
||
if (attr_fingerprint->getFingerprint() != computedFingerprint) {
|
||
// DebugL << "FINGERPRINT verification failed, expected: " << std::hex << computedFingerprint
|
||
// << ", got: " << attr_fingerprint->getFingerprint();
|
||
return Authentication::UNAUTHORIZED;
|
||
} else {
|
||
// TraceL << "FINGERPRINT verification passed";
|
||
}
|
||
}
|
||
}
|
||
|
||
return Authentication::OK;
|
||
}
|
||
|
||
void StunPacket::serialize() {
|
||
//TraceL;
|
||
|
||
_data = BufferRaw::create();
|
||
for (auto it : _attribute_map) {
|
||
it.second->storeToData();
|
||
}
|
||
|
||
auto attr_size = getAttrSize();
|
||
|
||
if (getClass() == StunPacket::Class::ERROR_RESPONSE) {
|
||
setNeedFingerprint(false);
|
||
setNeedMessageIntegrity(false);
|
||
}
|
||
|
||
if (getClass() == StunPacket::Class::INDICATION) {
|
||
setNeedMessageIntegrity(false);
|
||
}
|
||
|
||
auto message_integrity_size = getNeedMessageIntegrity() ? 24 : 0;
|
||
auto fingerprint_size = getNeedFingerprint() ? 8 : 0;
|
||
|
||
auto packet_size = HEADER_SIZE + attr_size + message_integrity_size + fingerprint_size;
|
||
_data->setCapacity(packet_size);
|
||
_data->setSize(packet_size);
|
||
|
||
// Merge class and method fields into type.
|
||
uint16_t typeField = (static_cast<uint16_t>(_method) & 0x0f80) << 2;
|
||
|
||
typeField |= (static_cast<uint16_t>(_method) & 0x0070) << 1;
|
||
typeField |= (static_cast<uint16_t>(_method) & 0x000f);
|
||
typeField |= (static_cast<uint16_t>(_klass) & 0x02) << 7;
|
||
typeField |= (static_cast<uint16_t>(_klass) & 0x01) << 4;
|
||
|
||
// Set type field.
|
||
Byte::Set2Bytes((unsigned char *)_data->data(), 0, typeField);
|
||
uint16_t initial_length = static_cast<uint16_t>(attr_size + message_integrity_size);
|
||
Byte::Set2Bytes((unsigned char *)_data->data(), 2, initial_length);
|
||
// Set magic cookie.
|
||
std::memcpy(_data->data() + 4, StunPacket::_magicCookie, 4);
|
||
// Set TransactionId field.
|
||
std::memcpy(_data->data() + 8, _transaction_id.data(), 12);
|
||
|
||
storeAttrMessage();
|
||
if (message_integrity_size) {
|
||
auto ufrag = _peer_ufrag;
|
||
auto password = _peer_password;
|
||
if (getClass() == StunPacket::Class::SUCCESS_RESPONSE ||
|
||
getClass() == StunPacket::Class::ERROR_RESPONSE) {
|
||
ufrag = _ufrag;
|
||
password = _password;
|
||
}
|
||
|
||
// Add MESSAGE-INTEGRITY.
|
||
auto attr_nonce = getAttribute<StunAttrNonce>();
|
||
auto attr_realm = getAttribute<StunAttrRealm>();
|
||
// FIXME: need use SASLprep(password) replace password
|
||
// 根据RFC 5766标准：key = MD5(username ":" realm ":" SASLprep(password))
|
||
std::string key = password;
|
||
if (attr_nonce && attr_realm) {
|
||
// 使用长期凭证机制
|
||
// key = MD5(username ":" realm ":" password)
|
||
auto realm = attr_realm->getRealm();
|
||
std::string username = ufrag; // 对于response消息，使用ufrag作为username
|
||
std::string input = username + ":" + std::string(realm.data(), realm.size()) + ":" + password;
|
||
key = openssl_MD5(input.data(), input.size());
|
||
|
||
// DebugL << "Long-term credential used for response:";
|
||
// DebugL << "ufrag: " << ufrag;
|
||
// DebugL << "realm: " << std::string(realm.data(), realm.size());
|
||
// DebugL << "password: " << password;
|
||
// DebugL << "input: " << input;
|
||
// DebugL << "MD5 key: " << toolkit::hexdump(key.data(), key.size());
|
||
}
|
||
|
||
size_t mi_calc_len = HEADER_SIZE + attr_size;
|
||
auto computedMessageIntegrity = openssl_HMACsha1(key.data(), key.size(), _data->data(), mi_calc_len);
|
||
auto attr_message_integrity = std::make_shared<StunAttrMessageIntegrity>();
|
||
attr_message_integrity->setHmac(computedMessageIntegrity);
|
||
attr_message_integrity->storeToData();
|
||
memcpy((unsigned char *)_data->data() + HEADER_SIZE + attr_size, attr_message_integrity->data(), attr_message_integrity->size());
|
||
|
||
// DebugL << "Serialize MESSAGE-INTEGRITY:";
|
||
// DebugL << "password: \"" << password << "\"";
|
||
// DebugL << "key: " << toolkit::hexdump(key.data(), key.size());
|
||
// DebugL << "hmac_calculated: " << toolkit::hexdump(computedMessageIntegrity.data(), computedMessageIntegrity.size());
|
||
}
|
||
|
||
if (fingerprint_size) {
|
||
// Add FINGERPRINT.
|
||
// Compute the CRC32 of the packet up to (but excluding) the FINGERPRINT
|
||
uint16_t final_length = static_cast<uint16_t>(attr_size + message_integrity_size + fingerprint_size);
|
||
Byte::Set2Bytes((unsigned char *)_data->data(), 2, final_length);
|
||
size_t fp_calc_len = HEADER_SIZE + attr_size + message_integrity_size;
|
||
uint32_t computedFingerprint = getCRC32((unsigned char *)_data->data(), fp_calc_len) ^ 0x5354554e;
|
||
|
||
auto attr_fingerprint = std::make_shared<StunAttrFingerprint>();
|
||
attr_fingerprint->setFingerprint(computedFingerprint);
|
||
attr_fingerprint->storeToData();
|
||
memcpy((unsigned char *)_data->data() + HEADER_SIZE + attr_size + message_integrity_size, attr_fingerprint->data(), attr_fingerprint->size());
|
||
}
|
||
}
|
||
|
||
StunPacket::Ptr StunPacket::createSuccessResponse() const {
|
||
// TraceL;
|
||
CHECK(_klass == Class::REQUEST, "attempt to create a success response for a non Request STUN packet");
|
||
|
||
auto packet = std::make_shared<StunPacket>(Class::SUCCESS_RESPONSE, _method, _transaction_id.c_str());
|
||
|
||
// 复制认证相关属性到响应包中，用于MESSAGE-INTEGRITY计算
|
||
auto attr_realm = getAttribute(StunAttribute::Type::REALM);
|
||
if (attr_realm) {
|
||
packet->addAttribute(attr_realm);
|
||
}
|
||
|
||
auto attr_nonce = getAttribute(StunAttribute::Type::NONCE);
|
||
if (attr_nonce) {
|
||
packet->addAttribute(attr_nonce);
|
||
DebugL << "Copied NONCE attribute to response";
|
||
}
|
||
|
||
return packet;
|
||
}
|
||
|
||
StunPacket::Ptr StunPacket::createErrorResponse(StunAttrErrorCode::Code errorCode) const {
|
||
TraceL;
|
||
CHECK(_klass == Class::REQUEST, "attempt to create an error response for a non Request STUN packet");
|
||
auto ret = std::make_shared<StunPacket>(Class::ERROR_RESPONSE, _method, _transaction_id.c_str());
|
||
auto attr = std::make_shared<StunAttrErrorCode>();
|
||
attr->setErrorCode(errorCode);
|
||
ret->addAttribute(std::move(attr));
|
||
return ret;
|
||
}
|
||
|
||
char *StunPacket::data() const {
|
||
return _data ? _data->data() : nullptr;
|
||
}
|
||
|
||
size_t StunPacket::size() const {
|
||
return _data ? _data->size() : 0;
|
||
}
|
||
|
||
bool StunPacket::loadFromData(const uint8_t *buf, size_t len) {
|
||
if (HEADER_SIZE > len) {
|
||
WarnL << "size too small " << len;
|
||
return false;
|
||
}
|
||
|
||
_data = BufferRaw::create();
|
||
_data->assign((const char *)(buf), len);
|
||
|
||
_transaction_id.assign((const char *)buf + 8, 12);
|
||
|
||
if (len == HEADER_SIZE) {
|
||
return true;
|
||
}
|
||
|
||
return loadAttrMessage(buf + HEADER_SIZE, len - HEADER_SIZE);
|
||
}
|
||
|
||
bool StunPacket::loadAttrMessage(const uint8_t *buf, size_t len) {
|
||
_attribute_map.clear();
|
||
_message_integrity_data_len = HEADER_SIZE + len;
|
||
|
||
uint8_t *ptr = const_cast<uint8_t*>(buf);
|
||
StunAttribute::Ptr attr = nullptr;
|
||
while (ptr < buf + len) {
|
||
auto type = (StunAttribute::Type)Byte::Get2Bytes(ptr, 0);
|
||
size_t length = Byte::Get2Bytes(ptr, 2);
|
||
size_t lengthAlign = Byte::PadTo4Bytes((uint16_t)length);
|
||
|
||
switch (type) {
|
||
case StunAttribute::Type::MAPPED_ADDRESS: attr = std::make_shared<StunAttrMappedAddress>(); break;
|
||
case StunAttribute::Type::USERNAME: attr = std::make_shared<StunAttrUserName>(); break;
|
||
case StunAttribute::Type::MESSAGE_INTEGRITY:
|
||
attr = std::make_shared<StunAttrMessageIntegrity>();
|
||
_message_integrity_data_len = HEADER_SIZE + ptr - buf;
|
||
break;
|
||
case StunAttribute::Type::ERROR_CODE: attr = std::make_shared<StunAttrErrorCode>(); break;
|
||
case StunAttribute::Type::CHANNEL_NUMBER: attr = std::make_shared<StunAttrChannelNumber>(); break;
|
||
case StunAttribute::Type::LIFETIME: attr = std::make_shared<StunAttrLifeTime>(); break;
|
||
case StunAttribute::Type::DATA: attr = std::make_shared<StunAttrData>(); break;
|
||
case StunAttribute::Type::REALM: attr = std::make_shared<StunAttrRealm>(); break;
|
||
case StunAttribute::Type::NONCE: attr = std::make_shared<StunAttrNonce>(); break;
|
||
case StunAttribute::Type::REQUESTED_TRANSPORT: attr = std::make_shared<StunAttrRequestedTransport>(); break;
|
||
case StunAttribute::Type::XOR_PEER_ADDRESS: attr = std::make_shared<StunAttrXorPeerAddress>(_transaction_id); break;
|
||
case StunAttribute::Type::XOR_RELAYED_ADDRESS: attr = std::make_shared<StunAttrXorRelayedAddress>(_transaction_id); break;
|
||
case StunAttribute::Type::XOR_MAPPED_ADDRESS: attr = std::make_shared<StunAttrXorMappedAddress>(_transaction_id); break;
|
||
|
||
case StunAttribute::Type::PRIORITY: attr = std::make_shared<StunAttrPriority>(); break;
|
||
case StunAttribute::Type::USE_CANDIDATE: attr = std::make_shared<StunAttrUseCandidate>(); break;
|
||
case StunAttribute::Type::FINGERPRINT: attr = std::make_shared<StunAttrFingerprint>(); break;
|
||
case StunAttribute::Type::ICE_CONTROLLED: attr = std::make_shared<StunAttrIceControlled>(); break;
|
||
case StunAttribute::Type::ICE_CONTROLLING: attr = std::make_shared<StunAttrIceControlling>(); break;
|
||
case StunAttribute::Type::GOOG_NETWORK_INFO:
|
||
case StunAttribute::Type::SOFTWARE:
|
||
break;
|
||
default: WarnL << "not support Attribute " << (uint16_t)type << "," << toolkit::hexdump(ptr, 2); break;
|
||
}
|
||
|
||
if (attr) {
|
||
if (ptr + lengthAlign + 4 > buf + len) {
|
||
WarnL << "the attribute length exceeds the remaining size, packet discarded";
|
||
return false;
|
||
}
|
||
|
||
if (attr->loadFromData(ptr, StunAttribute::ATTR_HEADER_SIZE + length)) {
|
||
_attribute_map.emplace(type, std::move(attr));
|
||
|
||
} else {
|
||
if (StunAttribute::isComprehensionRequired(ptr, 4)) {
|
||
WarnL << "parse a Comprehension Required Stun Attribute failed, type=" << (uint16_t)type << " len=" << length;
|
||
return false;
|
||
}
|
||
WarnL << "parse Stun Attribute failed type=" << (uint16_t)type << " len=" << length;
|
||
}
|
||
attr = nullptr;
|
||
}
|
||
|
||
ptr += lengthAlign + StunAttribute::ATTR_HEADER_SIZE;
|
||
}
|
||
return true;
|
||
}
|
||
|
||
bool StunPacket::storeAttrMessage() {
|
||
uint8_t *buf = (uint8_t *)_data->data() + HEADER_SIZE;
|
||
for (auto &pr : _attribute_map) {
|
||
memcpy(buf, pr.second->data(), pr.second->size());
|
||
buf += pr.second->size();
|
||
}
|
||
return true;
|
||
}
|
||
|
||
size_t StunPacket::getAttrSize() const {
|
||
size_t size = 0;
|
||
for (auto &pr : _attribute_map) {
|
||
size += pr.second->size();
|
||
}
|
||
return size;
|
||
}
|
||
|
||
SuccessResponsePacket::SuccessResponsePacket(Method method, const std::string& transaction_id) :
|
||
StunPacket(Class::SUCCESS_RESPONSE, method, transaction_id.c_str()) {
|
||
}
|
||
|
||
ErrorResponsePacket::ErrorResponsePacket(Method method, const std::string& transaction_id, StunAttrErrorCode::Code error_code) :
|
||
StunPacket(Class::ERROR_RESPONSE, method, transaction_id.c_str()) {
|
||
DebugL;
|
||
auto attr = std::make_shared<StunAttrErrorCode>();
|
||
attr->setErrorCode(error_code);
|
||
addAttribute(std::move(attr));
|
||
}
|
||
|
||
} // namespace RTC
|