update UDM/AMF for testing purpose

src/ngap/CMakeLists.txt_bak

-################################################################################
-# Licensed to the OpenAirInterface (OAI) Software Alliance under one or more
-# contributor license agreements.  See the NOTICE file distributed with
-# this work for additional information regarding copyright ownership.
-# The OpenAirInterface Software Alliance licenses this file to You under
-# the OAI Public License, Version 1.1  (the "License"); you may not use this file
-# except in compliance with the License.
-# You may obtain a copy of the License at
-#
-#      http://www.openairinterface.org/?page_id=698
-#
-# Unless required by applicable law or agreed to in writing, software
-# distributed under the License is distributed on an "AS IS" BASIS,
-# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-# See the License for the specific language governing permissions and
-# limitations under the License.
-#-------------------------------------------------------------------------------
-# For more information about the OpenAirInterface (OAI) Software Alliance:
-#      contact@openairinterface.org
-################################################################################
-#for NGAP_SMF_LAYTER
-set(NGAP_SMF_DIR "${CMAKE_CURRENT_SOURCE_DIR}")
-
-include_directories(${SRC_TOP_DIR}/ngap)
-
-file(GLOB NGAP_SMF_src_files
-       ${SRC_TOP_DIR}/ngap/*.c
-)   
-
-add_library(NGAP_SMF_LAYER ${NGAP_SMF_DIR}/ng_pdu_session_resource_setup_request.c  ${NGAP_SMF_src_files} ${NETTLE_LIBRARIES} ${CRYPTO_LIBRARIES})

src/test/amf/api/N1N2MessageCollectionDocumentApi.h

@@ -44,7 +44,7 @@ public:
     virtual ~N1N2MessageCollectionDocumentApi() {}
     void init();
 
-    const std::string base = "/namf-comm/v1";
+    const std::string base = "/namf-comm/v2";
 
 private:
     void setupRoutes();

src/test/amf_client/CMakeLists.txt

+cmake_minimum_required (VERSION 3.2)
+
+project(amf-client)
+
+set(CMAKE_CXX_FLAGS "${CMAKE_CXX_FLAGS} -std=c++17 -pg -g3" )
+
+
+file(GLOB SRCS
+    ${CMAKE_CURRENT_SOURCE_DIR}/*.cpp
+)
+
+add_executable(${PROJECT_NAME} ${SRCS} )
+target_link_libraries(${PROJECT_NAME} pistache pthread curl)

src/test/amf_client/amf-client.cpp

+
+#include <curl/curl.h>
+#include <nlohmann/json.hpp>
+#include <iostream>
+#include <string>
+#include <unistd.h>
+/*
+ * To read content of the response from UDM
+ */
+static std::size_t callback(
+    const char* in,
+    std::size_t size,
+    std::size_t num,
+    std::string* out)
+{
+  const std::size_t totalBytes(size * num);
+  out->append(in, totalBytes);
+  return totalBytes;
+}
+
+#define ENCODE_U8(buffer, value, size)    \
+    *(uint8_t*)(buffer) = value;    \
+    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::cout << "[AMF N11] PDU Session Establishment Request"<<std::endl;
+
+  nlohmann::json pdu_session_establishment_request;
+  std::string n1_msg = "2e0101c1ffff95";
+  std::string n2_msg;
+
+  //format string as hex
+  unsigned char *n1_msg_hex  = format_string_as_hex(n1_msg);
+
+  //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");
+
+  //Fill the json part
+  pdu_session_establishment_request["supi"] = "imsi-200000000000001";
+  pdu_session_establishment_request["pei"] = "imei-200000000000001";
+  pdu_session_establishment_request["gpsi"] = "msisdn-200000000001";
+  pdu_session_establishment_request["dnn"] = "carrier.com";
+  pdu_session_establishment_request["sNssai"]["sst"] = 222;
+  pdu_session_establishment_request["sNssai"]["sd"] = "0000D4";
+  pdu_session_establishment_request["pduSessionId"] = 1;
+  pdu_session_establishment_request["requestType"] = "INITIAL_REQUEST";
+  pdu_session_establishment_request["servingNfId"] = "servingNfId";
+  pdu_session_establishment_request["servingNetwork"]["mcc"] = "234";
+  pdu_session_establishment_request["servingNetwork"]["mnc"] = "067";
+  pdu_session_establishment_request["anType"] = "3GPP_ACCESS";
+  pdu_session_establishment_request["smContextStatusUri"] = "smContextStatusUri";
+
+  pdu_session_establishment_request["n1MessageContainer"]["n1MessageClass"] = "SM";
+  pdu_session_establishment_request["n1MessageContainer"]["n1MessageContent"]["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_establishment_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);
+    std::string n1_msg = "2e0101c1ffff95";
+    curl_mime_data(part, reinterpret_cast<const char*>(n1_msg_hex), 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.
+    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 establishment 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_modification()
+{
+  std::cout << "[AMF N11] PDU Session 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, 0 , size);
+  ENCODE_U8 (buffer+size, 3 , size);
+  ENCODE_U8 (buffer+size, 0xe0 , size);
+  ENCODE_U8 (buffer+size, 0xac , size);
+  ENCODE_U8 (buffer+size, 0x0a , size);
+  ENCODE_U8 (buffer+size, 0x05 , size);
+  ENCODE_U8 (buffer+size, 0x01 , size);
+  ENCODE_U8 (buffer+size, 0x00 , size);
+  ENCODE_U8 (buffer+size, 0x00 , size);
+  ENCODE_U8 (buffer+size, 0x00 , size);
+  ENCODE_U8 (buffer+size, 0x01 , size);
+  ENCODE_U8 (buffer+size, 0x00 , size);
+  ENCODE_U8 (buffer+size, 0x00 , size);
+
+
+/*
+  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;
+  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://172.16.1.101/nsmf-pdusession/v2/sm-contexts/1/modify");
+
+  //Fill the json part
+  pdu_session_modification_request["n2SmInfoType"] = "PDU_RES_SETUP_RSP";
+  pdu_session_modification_request["n2SmInfo"]["contentId"] = "n2SmMsg"; //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.ngap");
+    curl_mime_name (part, "n2SmMsg");
+
+    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);
+  }
+
+}
+int main(int argc, char* argv[])
+{
+
+  send_pdu_session_establishment_request();
+  usleep(10000);
+  send_pdu_session_modification();
+
+  return 0;
+}
+

src/test/udm/impl/SessionManagementSubscriptionDataRetrievalApiImpl.cpp

@@ -42,11 +42,11 @@ void SessionManagementSubscriptionDataRetrievalApiImpl::get_sm_data(const std::s
 	}
 	 */
 	nlohmann::json jsonData;
-	jsonData["singleNssai"]["sst"] = 1;
+	jsonData["singleNssai"]["sst"] = 222;
 	jsonData["singleNssai"]["sd"] = 123;
 	jsonData["dnnConfigurations"]["default"]["pduSessionTypes"]["defaultSessionType"] = "IPV4";
 	jsonData["dnnConfigurations"]["default"]["sscModes"]["defaultSscMode"] = "SSC_MODE_1";
-	jsonData["dnnConfigurations"]["default"]["5gQosProfile"]["5qi"] = 123;
+	jsonData["dnnConfigurations"]["default"]["5gQosProfile"]["5qi"] = 80;
 	jsonData["dnnConfigurations"]["default"]["5gQosProfile"]["arp"]["priorityLevel"] = 1;
 	jsonData["dnnConfigurations"]["default"]["5gQosProfile"]["arp"]["preemptCap"] = "NOT_PREEMPT";
 	jsonData["dnnConfigurations"]["default"]["5gQosProfile"]["arp"]["preemptVuln"] = "NOT_PREEMPTABLE";