Skip to content
Snippets Groups Projects
Commit 53c2392f authored by Tien-Thinh Nguyen's avatar Tien-Thinh Nguyen
Browse files

Fix issues when 0x00 included in the message (AMF client)

parent 01cfcdfd
No related branches found
No related tags found
1 merge request!3Bug fixes for various issues before finalizing PDU Session Establishment procedure
Hide whitespace changes
Inline Side-by-side
src/test/amf_client/amf-client.cpp
+ 43
− 225
View file @ 53c2392f
...@@ -22,61 +22,33 @@ static std::size_t callback( ...@@ -22,61 +22,33 @@ static std::size_t callback(
*(uint8_t*)(buffer) = value; \ *(uint8_t*)(buffer) = value; \
size += sizeof(uint8_t) size += sizeof(uint8_t)
//---------------------------------------------------------------------------------------------
unsigned char * format_string_as_hex(std::string str){
unsigned int str_len = str.length();
unsigned char * datavalue = (unsigned char *)malloc(str_len/2 + 1);
unsigned char *data = (unsigned char *)malloc(str_len + 1);
memset(data,0,str_len + 1);
memcpy ((void *)data, (void *)str.c_str(),str_len);
std::cout << "Data: " << data << " (" << str_len <<" bytes)" <<std::endl;
std::cout <<"Data (formatted): \n";
for(int i=0;i<str_len;i++)
{
char datatmp[3] = {0};
memcpy(datatmp,&data[i],2);
// Ensure both characters are hexadecimal
bool bBothDigits = true;
for(int j = 0; j < 2; ++j)
{
if(!isxdigit(datatmp[j]))
bBothDigits = false;
}
if(!bBothDigits)
break;
// Convert two hexadecimal characters into one character
unsigned int nAsciiCharacter;
sscanf(datatmp, "%x", &nAsciiCharacter);
printf("%x ",nAsciiCharacter);
// Concatenate this character onto the output
datavalue[i/2] = (unsigned char)nAsciiCharacter;
// Skip the next character
i++;
}
printf("\n");
free(data);
data = nullptr;
return datavalue;
}
void send_pdu_session_establishment_request(std::string smf_ip_address) void send_pdu_session_establishment_request(std::string smf_ip_address)
{ {
std::cout << "[AMF N11] PDU Session Establishment Request"<<std::endl; std::cout << "[AMF N11] PDU Session Establishment Request"<<std::endl;
nlohmann::json pdu_session_establishment_request; nlohmann::json pdu_session_establishment_request;
std::string n1_msg = "2e0101c1ffff91"; //encode
std::string n2_msg; /*
0000 2e 01 01 c1 ff ff 91 00 00 00 00 00 00 00 00 00
*/
size_t buffer_size = 128;
char *buffer = (char *)calloc(1,buffer_size);
int size = 0;
ENCODE_U8 (buffer, 0x2e , size);
ENCODE_U8 (buffer+size, 0x01 , size);
ENCODE_U8 (buffer+size, 0x01 , size);
ENCODE_U8 (buffer+size, 0xc1 , size);
ENCODE_U8 (buffer+size, 0xff , size);
ENCODE_U8 (buffer+size, 0xff , size);
// ENCODE_U8 (buffer+size, 0x00 , size);
ENCODE_U8 (buffer+size, 0x91 , size);
//format string as hex std::cout << "Buffer: "<<std::endl;
unsigned char *n1_msg_hex = format_string_as_hex(n1_msg); for(int i=0;i<size;i++)
{
printf("%02x ", buffer[i]);
}
std::cout << "Buffer: "<<std::endl;
//Fill Json part //Fill Json part
//get supi and put into URL //get supi and put into URL
...@@ -101,21 +73,15 @@ void send_pdu_session_establishment_request(std::string smf_ip_address) ...@@ -101,21 +73,15 @@ void send_pdu_session_establishment_request(std::string smf_ip_address)
pdu_session_establishment_request["smContextStatusUri"] = "smContextStatusUri"; pdu_session_establishment_request["smContextStatusUri"] = "smContextStatusUri";
pdu_session_establishment_request["n1MessageContainer"]["n1MessageClass"] = "SM"; pdu_session_establishment_request["n1MessageContainer"]["n1MessageClass"] = "SM";
pdu_session_establishment_request["n1MessageContainer"]["n1MessageContent"]["contentId"] = "n1SmMsg"; //part 2 pdu_session_establishment_request["n1MessageContainer"]["n1MessageContent"]["contentId"] = "n1SmMsg"; // NAS
//N1SM
//pdu_session_establishment_request["n1SmMsg"] = "SM";
//pdu_session_establishment_request["n1SmMsg"]["contentId"] = "n1SmMsg"; //part 2
CURL *curl = curl_easy_init(); CURL *curl = curl_easy_init();
//N1N2MessageTransfer Notification URI??
std::string json_part = pdu_session_establishment_request.dump(); std::string json_part = pdu_session_establishment_request.dump();
std::cout<< " Sending message to SMF....\n"; std::cout<< "Sending message to SMF....\n";
if(curl) { if(curl) {
std::cout << "send curl command"<<std::endl;
CURLcode res; CURLcode res;
struct curl_slist *headers = nullptr; struct curl_slist *headers = nullptr;
struct curl_slist *slist = nullptr; struct curl_slist *slist = nullptr;
...@@ -129,6 +95,7 @@ void send_pdu_session_establishment_request(std::string smf_ip_address) ...@@ -129,6 +95,7 @@ void send_pdu_session_establishment_request(std::string smf_ip_address)
curl_easy_setopt(curl, CURLOPT_URL, url.c_str()); curl_easy_setopt(curl, CURLOPT_URL, url.c_str());
curl_easy_setopt(curl, CURLOPT_HTTPGET,1); curl_easy_setopt(curl, CURLOPT_HTTPGET,1);
curl_easy_setopt(curl, CURLOPT_TIMEOUT_MS, 100L); curl_easy_setopt(curl, CURLOPT_TIMEOUT_MS, 100L);
curl_easy_setopt(curl, CURLOPT_INTERFACE, "eno1:amf"); //hardcoded
mime = curl_mime_init(curl); mime = curl_mime_init(curl);
alt = curl_mime_init(curl); alt = curl_mime_init(curl);
...@@ -139,13 +106,12 @@ void send_pdu_session_establishment_request(std::string smf_ip_address) ...@@ -139,13 +106,12 @@ void send_pdu_session_establishment_request(std::string smf_ip_address)
curl_mime_type(part, "application/json"); curl_mime_type(part, "application/json");
part = curl_mime_addpart(mime); part = curl_mime_addpart(mime);
std::string n1_msg = "2e0101c1ffff95"; //curl_mime_data(part, reinterpret_cast<const char*>(n1_msg_hex), CURL_ZERO_TERMINATED);
curl_mime_data(part, reinterpret_cast<const char*>(n1_msg_hex), CURL_ZERO_TERMINATED); curl_mime_data(part, reinterpret_cast<const char*>(buffer), size);
curl_mime_type(part, "application/vnd.3gpp.5gnas"); curl_mime_type(part, "application/vnd.3gpp.5gnas");
//curl_mime_name (part, "n1SmMsg"); //curl_mime_name (part, "n1SmMsg");
curl_easy_setopt(curl, CURLOPT_MIMEPOST, mime); curl_easy_setopt(curl, CURLOPT_MIMEPOST, mime);
//res = curl_easy_perform(curl);
// Response information. // Response information.
long httpCode(0); long httpCode(0);
...@@ -164,16 +130,15 @@ void send_pdu_session_establishment_request(std::string smf_ip_address) ...@@ -164,16 +130,15 @@ void send_pdu_session_establishment_request(std::string smf_ip_address)
response_data = nlohmann::json::parse(*httpData.get()); response_data = nlohmann::json::parse(*httpData.get());
} catch (nlohmann::json::exception& e){ } catch (nlohmann::json::exception& e){
std::cout << "Could not get the cause from the response" <<std::endl; std::cout << "Could not get the cause from the response" <<std::endl;
//Set the default Cause
response_data["cause"] = "504 Gateway Timeout";
} }
std::cout << "[AMF N11] PDU session establishment request, response from SMF, Http Code " << httpCode << " cause "<< response_data["cause"].dump().c_str()<<std::endl; std::cout << "[AMF N11] PDU session establishment request, response from SMF, Http Code " << httpCode <<std::endl;
curl_slist_free_all(headers); curl_slist_free_all(headers);
curl_easy_cleanup(curl); curl_easy_cleanup(curl);
curl_mime_free(mime); curl_mime_free(mime);
} }
free(buffer);
} }
...@@ -181,20 +146,17 @@ void send_pdu_session_update_sm_context_establishment(std::string smf_ip_address ...@@ -181,20 +146,17 @@ void send_pdu_session_update_sm_context_establishment(std::string smf_ip_address
{ {
std::cout << "[AMF N11] send_pdu_session_update_sm_context_establishment"<<std::endl; std::cout << "[AMF N11] send_pdu_session_update_sm_context_establishment"<<std::endl;
nlohmann::json pdu_session_modification_request; nlohmann::json pdu_session_update_request;
std::string n2_msg = "0003e0ac0a0501000000010000";
//format string as hex
unsigned char *n2_msg_hex = format_string_as_hex(n2_msg);
//encode //encode
/*
00 03 e0 ac 0a 05 01 00 00 00 01 00 3c
*/
size_t buffer_size = 128; size_t buffer_size = 128;
char *buffer = (char *)calloc(1,buffer_size); char *buffer = (char *)calloc(1,buffer_size);
int size = 0; int size = 0;
ENCODE_U8 (buffer, 0x00 , size);
ENCODE_U8 (buffer, 0 , size); ENCODE_U8 (buffer+size, 0x03 , size);
ENCODE_U8 (buffer+size, 3 , size);
ENCODE_U8 (buffer+size, 0xe0 , size); ENCODE_U8 (buffer+size, 0xe0 , size);
ENCODE_U8 (buffer+size, 0xac , size); ENCODE_U8 (buffer+size, 0xac , size);
ENCODE_U8 (buffer+size, 0x0a , size); ENCODE_U8 (buffer+size, 0x0a , size);
...@@ -205,17 +167,7 @@ void send_pdu_session_update_sm_context_establishment(std::string smf_ip_address ...@@ -205,17 +167,7 @@ void send_pdu_session_update_sm_context_establishment(std::string smf_ip_address
ENCODE_U8 (buffer+size, 0x00 , size); ENCODE_U8 (buffer+size, 0x00 , size);
ENCODE_U8 (buffer+size, 0x01 , size); ENCODE_U8 (buffer+size, 0x01 , size);
ENCODE_U8 (buffer+size, 0x00 , size); ENCODE_U8 (buffer+size, 0x00 , size);
ENCODE_U8 (buffer+size, 0x3c , size); ENCODE_U8 (buffer+size, 0x3c , size); //QFI: 60
/*
0000 00 00 04 00 82 00 04 00 01 00 02 00 8b 00 0a 01
0010 f0 04 03 02 01 7f 00 00 01 00 86 00 01 10 00 88
0020 00 07 00 3c 00 00 3c 00 00 00 00 00 00 00 00 00
0030 00 00 00 00 00 00 00 00 00 00 00 00 00 00 00 00
0040 00 00 00 00 00 00 00 00 00 00 00 00 00 00 00 00
*/
std::cout << "Buffer: "<<std::endl; std::cout << "Buffer: "<<std::endl;
for(int i=0;i<2;i++) for(int i=0;i<2;i++)
...@@ -225,30 +177,21 @@ void send_pdu_session_update_sm_context_establishment(std::string smf_ip_address ...@@ -225,30 +177,21 @@ void send_pdu_session_update_sm_context_establishment(std::string smf_ip_address
std::cout << "Buffer: "<<std::endl; std::cout << "Buffer: "<<std::endl;
//Fill Json part //Fill Json part
//get supi and put into URL
std::string supi_str;
//std::string url = std::string("http://172.16.1.101/nsmf-pdusession/v2/sm-contexts");
//std::string url = std::string("http://172.16.1.101/nsmf-pdusession/v2/sm-contexts/imsi-200000000000001/modify"); //std::string url = std::string("http://172.16.1.101/nsmf-pdusession/v2/sm-contexts/imsi-200000000000001/modify");
std::string url = std::string("http://"); std::string url = std::string("http://");
url.append(smf_ip_address); url.append(smf_ip_address);
url.append(std::string("/nsmf-pdusession/v2/sm-contexts/1/modify")); url.append(std::string("/nsmf-pdusession/v2/sm-contexts/1/modify"));
//Fill the json part //Fill the json part
pdu_session_modification_request["n2SmInfoType"] = "PDU_RES_SETUP_RSP"; pdu_session_update_request["n2SmInfoType"] = "PDU_RES_SETUP_RSP";
pdu_session_modification_request["n2SmInfo"]["contentId"] = "n2SmMsg"; //part 2 pdu_session_update_request["n2SmInfo"]["contentId"] = "n2SmMsg"; //NGAP
//N1SM
//pdu_session_establishment_request["n1SmMsg"] = "SM";
//pdu_session_establishment_request["n1SmMsg"]["contentId"] = "n1SmMsg"; //part 2
CURL *curl = curl_easy_init(); CURL *curl = curl_easy_init();
//N1N2MessageTransfer Notification URI?? std::string json_part = pdu_session_update_request.dump();
std::string json_part = pdu_session_modification_request.dump();
std::cout<< " Sending message to SMF....\n"; std::cout<< "Sending message to SMF....\n";
if(curl) { if(curl) {
std::cout << "send curl command"<<std::endl;
CURLcode res; CURLcode res;
struct curl_slist *headers = nullptr; struct curl_slist *headers = nullptr;
...@@ -263,6 +206,8 @@ void send_pdu_session_update_sm_context_establishment(std::string smf_ip_address ...@@ -263,6 +206,8 @@ void send_pdu_session_update_sm_context_establishment(std::string smf_ip_address
curl_easy_setopt(curl, CURLOPT_URL, url.c_str()); curl_easy_setopt(curl, CURLOPT_URL, url.c_str());
curl_easy_setopt(curl, CURLOPT_HTTPGET,1); curl_easy_setopt(curl, CURLOPT_HTTPGET,1);
curl_easy_setopt(curl, CURLOPT_TIMEOUT_MS, 100L); curl_easy_setopt(curl, CURLOPT_TIMEOUT_MS, 100L);
curl_easy_setopt(curl, CURLOPT_INTERFACE, "eno1:amf"); //hardcoded
mime = curl_mime_init(curl); mime = curl_mime_init(curl);
alt = curl_mime_init(curl); alt = curl_mime_init(curl);
...@@ -274,137 +219,11 @@ void send_pdu_session_update_sm_context_establishment(std::string smf_ip_address ...@@ -274,137 +219,11 @@ void send_pdu_session_update_sm_context_establishment(std::string smf_ip_address
part = curl_mime_addpart(mime); part = curl_mime_addpart(mime);
curl_mime_data(part, reinterpret_cast<const char*>(buffer), size); curl_mime_data(part, reinterpret_cast<const char*>(buffer), size);
//curl_mime_data(part, "\x00\x03\xe0\xac\x0a\x05\x01\x01\x01\x01\x01\x00\x00", CURL_ZERO_TERMINATED);
//curl_mime_data(part, "\x2e\x01\x01\xc1\xff\xff\x95", CURL_ZERO_TERMINATED);
curl_mime_type(part, "application/vnd.3gpp.ngap"); curl_mime_type(part, "application/vnd.3gpp.ngap");
curl_mime_name (part, "n2SmMsg"); curl_mime_name (part, "n2SmMsg");
curl_easy_setopt(curl, CURLOPT_MIMEPOST, mime); curl_easy_setopt(curl, CURLOPT_MIMEPOST, mime);
//res = curl_easy_perform(curl);
// Response information.
long httpCode(0);
std::unique_ptr<std::string> httpData(new std::string());
// Hook up data handling function.
curl_easy_setopt(curl, CURLOPT_WRITEFUNCTION, &callback);
curl_easy_setopt(curl, CURLOPT_WRITEDATA, httpData.get());
res = curl_easy_perform(curl);
curl_easy_getinfo(curl, CURLINFO_RESPONSE_CODE, &httpCode);
//get cause from the response
nlohmann::json response_data;
try{
response_data = nlohmann::json::parse(*httpData.get());
} catch (nlohmann::json::exception& e){
std::cout << "Could not get the cause from the response" <<std::endl;
//Set the default Cause
response_data["cause"] = "504 Gateway Timeout";
}
std::cout << "[AMF N11] PDU session modification request, response from SMF, Http Code " << httpCode << " cause "<< response_data["cause"].dump().c_str()<<std::endl;
curl_slist_free_all(headers);
curl_easy_cleanup(curl);
curl_mime_free(mime);
}
}
void send_pdu_session_update_sm_context_modification(std::string smf_ip_address)
{
std::cout << "[AMF N11] send_pdu_session_update_sm_context_modification"<<std::endl;
nlohmann::json pdu_session_modification_request;
std::string n2_msg = "0003e0ac0a0501000000010000";
//format string as hex
unsigned char *n2_msg_hex = format_string_as_hex(n2_msg);
//encode
size_t buffer_size = 128;
char *buffer = (char *)calloc(1,buffer_size);
int size = 0;
ENCODE_U8 (buffer, 0x2e , size);
ENCODE_U8 (buffer+size, 0x01 , size);
ENCODE_U8 (buffer+size, 0x01 , size);
ENCODE_U8 (buffer+size, 0xc1 , size);
ENCODE_U8 (buffer+size, 0xff , size);
ENCODE_U8 (buffer+size, 0xff , size);
ENCODE_U8 (buffer+size, 0x95 , size);
////step 1.a,UE-initiated: SM Context ID + N1 (PDU Session Modification Request)
std::cout << "Buffer: "<<std::endl;
for(int i=0;i<2;i++)
{
printf("%02x ", buffer[i]);
}
std::cout << "Buffer: "<<std::endl;
//Fill Json part
//get supi and put into URL
std::string supi_str;
//std::string url = std::string("http://172.16.1.101/nsmf-pdusession/v2/sm-contexts");
//std::string url = std::string("http://172.16.1.101/nsmf-pdusession/v2/sm-contexts/imsi-200000000000001/modify");
std::string url = std::string("http://");
url.append(smf_ip_address);
url.append(std::string("/nsmf-pdusession/v2/sm-contexts/1/modify"));
//Fill the json part
pdu_session_modification_request["n1SmMsg"]["contentId"] = "n1SmMsg"; //part 2
//N1SM
//pdu_session_establishment_request["n1SmMsg"] = "SM";
//pdu_session_establishment_request["n1SmMsg"]["contentId"] = "n1SmMsg"; //part 2
CURL *curl = curl_easy_init();
//N1N2MessageTransfer Notification URI??
std::string json_part = pdu_session_modification_request.dump();
std::cout<< " Sending message to SMF....\n";
if(curl) {
std::cout << "send curl command"<<std::endl;
CURLcode res;
struct curl_slist *headers = nullptr;
struct curl_slist *slist = nullptr;
curl_mime *mime;
curl_mime *alt;
curl_mimepart *part;
headers = curl_slist_append(headers, "charsets: utf-8");
headers = curl_slist_append(headers, "content-type: multipart/related");
curl_easy_setopt(curl, CURLOPT_HTTPHEADER, headers);
curl_easy_setopt(curl, CURLOPT_URL, url.c_str());
curl_easy_setopt(curl, CURLOPT_HTTPGET,1);
curl_easy_setopt(curl, CURLOPT_TIMEOUT_MS, 100L);
mime = curl_mime_init(curl);
alt = curl_mime_init(curl);
//part with N1N2MessageTransferReqData (JsonData)
part = curl_mime_addpart(mime);
curl_mime_data(part, json_part.c_str(), CURL_ZERO_TERMINATED);
curl_mime_type(part, "application/json");
part = curl_mime_addpart(mime);
curl_mime_data(part, reinterpret_cast<const char*>(buffer), size);
//curl_mime_data(part, "\x00\x03\xe0\xac\x0a\x05\x01\x01\x01\x01\x01\x00\x00", CURL_ZERO_TERMINATED);
//curl_mime_data(part, "\x2e\x01\x01\xc1\xff\xff\x95", CURL_ZERO_TERMINATED);
curl_mime_type(part, "application/vnd.3gpp.5gnas");
curl_mime_name (part, "n1SmMsg");
curl_easy_setopt(curl, CURLOPT_MIMEPOST, mime);
//res = curl_easy_perform(curl);
// Response information. // Response information.
long httpCode(0); long httpCode(0);
...@@ -432,7 +251,7 @@ void send_pdu_session_update_sm_context_modification(std::string smf_ip_address) ...@@ -432,7 +251,7 @@ void send_pdu_session_update_sm_context_modification(std::string smf_ip_address)
curl_easy_cleanup(curl); curl_easy_cleanup(curl);
curl_mime_free(mime); curl_mime_free(mime);
} }
free(buffer);
} }
int main(int argc, char* argv[]) int main(int argc, char* argv[])
...@@ -466,7 +285,6 @@ int main(int argc, char* argv[]) ...@@ -466,7 +285,6 @@ int main(int argc, char* argv[])
send_pdu_session_establishment_request(smf_ip_address); send_pdu_session_establishment_request(smf_ip_address);
usleep(100000); usleep(100000);
send_pdu_session_update_sm_context_establishment(smf_ip_address); send_pdu_session_update_sm_context_establishment(smf_ip_address);
//send_pdu_session_update_sm_context_modification(smf_ip_address);
return 0; return 0;
} }
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment